Merge remote-tracking branch 'origin/master'

 iailab-framework/iailab-common/src/main/java/com/iailab/framework/common/exception/enums/GlobalErrorCodeConstants.java

@@ -36,6 +36,7 @@
    // ========== 自定义错误段 ==========
    ErrorCode REPEATED_REQUESTS = new ErrorCode(900, "重复请求，请稍后重试"); // 重复请求
    ErrorCode DEMO_DENY = new ErrorCode(901, "演示模式，禁止写操作");
    ErrorCode NOT_GENERAT = new ErrorCode(902, "测试运行模型前请先生成代码");

    ErrorCode UNKNOWN = new ErrorCode(999, "未知错误");


 iailab-module-model/iailab-module-model-api/src/main/java/com/iailab/module/model/api/mcs/McsApi.java

@@ -12,7 +12,6 @@
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestParam;

import javax.validation.Valid;
import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
@@ -169,4 +168,8 @@
    @Operation(summary = "根据预测时间获取最后预测值")
    Map<String, BigDecimal> getPredictValueByTime(@RequestBody PredictLastValueReqVO reqVO);

    @GetMapping(PREFIX + "/predict/model/setting/update")
    @Operation(summary = "修改预测模型配置")
    Boolean updatePredictModelSetting(@RequestParam("modelCode") String modelCode, @RequestParam("key") String key, @RequestParam("value") String value);

}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/McsApiImpl.java

@@ -23,6 +23,7 @@
import com.iailab.module.model.mcs.pre.entity.DmModuleEntity;
import com.iailab.module.model.mcs.pre.entity.MmItemOutputEntity;
import com.iailab.module.model.mcs.pre.entity.MmPredictAlarmMessageEntity;
import com.iailab.module.model.mcs.pre.entity.MmPredictModelEntity;
import com.iailab.module.model.mcs.pre.enums.PredGranularityEnum;
import com.iailab.module.model.mcs.pre.service.*;
import com.iailab.module.model.mcs.pre.vo.MmItemOutputRespVO;
@@ -117,6 +118,13 @@

    @Autowired
    private StScheduleModelSettingService stScheduleModelSettingService;

    @Autowired
    private MmPredictModelService mmPredictModelService;

    @Autowired
    private MmModelArithSettingsService mmModelArithSettingsService;

    private int HOUR_MINS = 60;

    @Override
@@ -989,6 +997,13 @@
        return stScheduleSuggestService.getLastSuggest(params);
    }

    @Override
    public Boolean updatePredictModelSetting(String modelCode, String key, String value) {
        MmPredictModelEntity model = mmPredictModelService.getByModelCode(modelCode);
        mmModelArithSettingsService.updateByModelIdAndKey(model.getId(), key, value);
        return true;
    }

    private Date[] calResultTime(ItemVO predictItem, Date startTimeReq, Date endTimeReq, int lengthLeft, int lengthRight) {
        Date[] result = new Date[3];
        Date predictTime = predictItem.getLastTime();

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/api/controller/admin/McsApiController.java

@@ -275,4 +275,11 @@
        List<ScheduleSuggestRespDTO> data = mcsApi.getLastSuggest(params);
        return CommonResult.success(data);
    }

    @GetMapping("/predict/model/setting/update")
    @Operation(summary = "修改调度模型配置")
    public CommonResult<Boolean> updatePredictModelSetting(@RequestParam("modelCode") String modelCode, @RequestParam("key") String key, @RequestParam("value") String value){
        mcsApi.updatePredictModelSetting(modelCode, key, value);
        return success( true);
    }
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/dao/MmModelArithSettingsDao.java

@@ -33,4 +33,6 @@
    void insertList(List<MmModelArithSettingsEntity> list);

    void updatePyFile(@Param("likeValue") String likeValue,@Param("value") String value);

    void updateByModelIdAndKey(@Param("modelId") String modelId,@Param("key") String key,@Param("value") String value);
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/MmModelArithSettingsService.java

@@ -15,4 +15,6 @@
    List<MmModelArithSettingsEntity> getByModelId(String modelId);

    void updatePyFile(String pyModule, String fileName);

    void updateByModelIdAndKey(String modelId, String key, String value);
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/MmPredictModelService.java

@@ -27,4 +27,6 @@
    MmPredictModelEntity getActiveModelByItemId(String itemId);

    void clearCache();

    MmPredictModelEntity getByModelCode(String modelCode);
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmModelArithSettingsServiceImpl.java

@@ -60,4 +60,9 @@
        // 清空缓存
        modelIdMap.clear();
    }

    @Override
    public void updateByModelIdAndKey(String modelId, String key, String value) {
        baseMapper.updateByModelIdAndKey(modelId,key,value);
    }
}

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java

@@ -61,6 +61,11 @@
    }

    @Override
    public MmPredictModelEntity getByModelCode(String modelCode) {
        return mmPredictModelDao.selectOne("modelno", modelCode);
    }

    @Override
    public MmPredictModelEntity getInfo(String id) {
        return mmPredictModelDao.selectById(id);
    }

 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mpk/controller/admin/MdkController.java

@@ -38,6 +38,7 @@
import java.util.*;
import java.util.stream.Collectors;

import static com.iailab.framework.common.exception.enums.GlobalErrorCodeConstants.NOT_GENERAT;
import static com.iailab.framework.common.pojo.CommonResult.error;
import static com.iailab.framework.common.pojo.CommonResult.success;

@@ -72,11 +73,13 @@
        try {
            File jarFile = new File(mpkTenantBakFilePath + File.separator + MdkConstant.JAR + File.separator + dto.getPyName() + ".jar");
            if (!jarFile.exists()) {
                throw new RuntimeException("jar包不存在，请先生成代码。jarPath:" + jarFile.getAbsolutePath());
                log.error("jar包不存在，请先生成代码。jarPath:" + jarFile.getAbsolutePath());
                return CommonResult.error(NOT_GENERAT.getCode(),NOT_GENERAT.getMsg());
            }
            File dllFile = new File(mpkTenantBakFilePath + File.separator + MdkConstant.DLL + File.separator + dto.getPyName() + ".dll");
            if (!dllFile.exists()) {
                throw new RuntimeException("dll文件不存在，请先生成代码。dllPath:" + dllFile.getAbsolutePath());
                log.error("dll文件不存在，请先生成代码。dllPath:" + dllFile.getAbsolutePath());
                return CommonResult.error(NOT_GENERAT.getCode(),NOT_GENERAT.getMsg());
            }
            // 加载jar包
            classLoader = DllUtils.loadJar(jarFile.getAbsolutePath());
@@ -152,7 +155,6 @@
                DllUtils.unloadDll(classLoader);
                DllUtils.unloadJar(classLoader);
            }
            System.gc();
        }
    }


 iailab-module-model/iailab-module-model-biz/src/main/resources/mapper/mcs/MmModelArithSettings.xml

@@ -27,4 +27,7 @@
            (#{item.id}, #{item.modelid}, #{item.key}, #{item.value}, #{item.name}, #{item.valuetype})
        </foreach>
    </insert>
    <update id="updateByModelIdAndKey">
        update t_mm_model_arith_settings set value = #{value} where `modelid` = #{modelId} and `key` = #{key}
    </update>
</mapper>