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