From c8e3d31ccf5cb8525149f527379e84b863275c71 Mon Sep 17 00:00:00 2001 From: 潘志宝 <979469083@qq.com> Date: 星期三, 09 四月 2025 11:57:20 +0800 Subject: [PATCH] 异常工况下的负荷移植 --- ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOffPowerOptimTask.java | 56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 56 insertions(+), 0 deletions(-) diff --git a/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOffPowerOptimTask.java b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOffPowerOptimTask.java new file mode 100644 index 0000000..1f02179 --- /dev/null +++ b/ansteel-biz/src/main/java/com/iailab/module/ansteel/job/task/RunOffPowerOptimTask.java @@ -0,0 +1,56 @@ +package com.iailab.module.ansteel.job.task; + +import com.iailab.module.model.api.mdk.MdkApi; +import com.iailab.module.model.api.mdk.dto.MdkPredictReqDTO; +import org.apache.commons.lang3.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.util.Arrays; +import java.util.Calendar; +import java.util.Date; +import java.util.List; + +/** + * 无功优化模型 + * + * @author PanZhibao + * @Description + * @createTime 2025年04月02日 + */ +@Component("runOffPowerOptimTask") +public class RunOffPowerOptimTask implements ITask { + + private Logger logger = LoggerFactory.getLogger(getClass()); + + @Autowired + private MdkApi mdkApi; + + @Override + public void run(String params) { + logger.info("runPredictModuleTask定时任务正在执行,参数为:{}", params); + try { + Calendar calendar = Calendar.getInstance(); + calendar.set(Calendar.SECOND, 0); + calendar.set(Calendar.MILLISECOND, 0); + Date predictTime = calendar.getTime(); + if (StringUtils.isEmpty(params)) { + logger.info("参数为空"); + return; + } + List<String> moduleTypeList = Arrays.asList(params.split(",")); + moduleTypeList.forEach(type -> { + MdkPredictReqDTO dto = new MdkPredictReqDTO(); + dto.setPredictTime(predictTime); + dto.setModuleType(type); + mdkApi.predictModule(dto); + logger.info(type + "模块预测完成。"); + }); + } catch (Exception ex) { + logger.error("runPredictModuleTask运行异常",ex); + } + logger.info("runPredictModuleTask运行完成"); + } +} \ No newline at end of file -- Gitblit v1.9.3