望铁关口触发边界

 ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOnPowerOptimTask.java

@@ -1,5 +1,6 @@
package com.iailab.module.ansteel.job.task;

import com.iailab.module.ansteel.page.service.PageParamService;
import com.iailab.module.data.api.point.DataPointApi;
import com.iailab.module.data.api.point.dto.ApiPointValueDTO;
import com.iailab.module.data.api.point.dto.ApiPointValueQueryDTO;
@@ -46,8 +47,8 @@
    @Autowired
    private McsApi mcsApi;

    // 望铁关口触发边界
    private final static double LIM = -20d;
    @Autowired
    private PageParamService pageParamService;

    private final static String POINT_NO = "C0000201107";

@@ -55,11 +56,17 @@
    public void run(String params) {
        logger.info("RunOnPowerOptimTask定时任务正在执行，参数为：{}", params);
        try {
            // 查询配置参数
            // 触发频率
            Integer cfpl = Integer.parseInt(pageParamService.getValue(""));
            // 望铁关口触发边界
            Double wtbj = Double.parseDouble(pageParamService.getValue(""));

            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.MILLISECOND, 0);
            calendar.set(Calendar.SECOND, 0);
            Date endTime = calendar.getTime();
            calendar.add(Calendar.MINUTE, -5);
            calendar.add(Calendar.MINUTE, cfpl * -1);
            Date startTime = calendar.getTime();

            ApiPointValueQueryDTO pointValueQueryDTO = new ApiPointValueQueryDTO();
@@ -72,7 +79,7 @@
                flag = false;
            }
            for (ApiPointValueDTO apiPointValueDTO : valueList) {
                if (apiPointValueDTO.getV() < LIM) {
                if (apiPointValueDTO.getV() < wtbj) {
                    flag = false;
                    break;
                }

 ansteel-biz/src/main/java/com/iailab/module/ansteel/page/service/PageParamService.java

@@ -1,6 +1,5 @@
package com.iailab.module.ansteel.page.service;

import com.iailab.module.ansteel.page.entity.PageParamEntity;
import com.iailab.module.ansteel.page.vo.PageParamRespVO;
import com.iailab.module.ansteel.page.vo.PageParamValueReqVO;

@@ -13,6 +12,8 @@
 */
public interface PageParamService {

    String getValue(String paramCode);

    List<PageParamRespVO> list(String paramType);

    void updateValue(PageParamValueReqVO reqVO);

 ansteel-biz/src/main/java/com/iailab/module/ansteel/page/service/impl/PageParamServiceImpl.java

@@ -29,6 +29,15 @@
    private PageParamDao pageParamDao;

    @Override
    public String getValue(String paramCode) {
        PageParamEntity entity = pageParamDao.selectOne(new QueryWrapper<PageParamEntity>().eq("param_code", paramCode));
        if (entity == null) {
            return null;
        }
        return entity.getParamValue();
    }

    @Override
    public List<PageParamRespVO> list(String paramType) {
        if (StringUtils.isBlank(paramType)) {
            return new ArrayList<>();