job迁移

common/ruoyi-common-security/src/main/java/com/ruoyi/common/security/handler/GlobalExceptionHandler.java → common/ruoyi-common-security/src/main/java/com/ruoyi/common/security/handler/RuoyiGlobalExceptionHandler.java

@@ -27,9 +27,9 @@ import com.ruoyi.common.core.web.domain.AjaxResult;
  * @author ruoyi
  */
 @RestControllerAdvice
-public class GlobalExceptionHandler
+public class RuoyiGlobalExceptionHandler
 {
-    private static final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
+    private static final Logger log = LoggerFactory.getLogger(RuoyiGlobalExceptionHandler.class);
 
     /**
      * 权限码异常

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/DistOSSSvgFileProcessor.java

@@ -0,0 +1,31 @@
+package com.hdkj.lt.job.task;
+
+import com.alibaba.fastjson.JSON;
+import com.hdkj.lt.job.service.IDistOSSSvgFileService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.Optional;
+
+@Slf4j
+@Component("distOSSSvgFile")
+@RequiredArgsConstructor
+public class DistOSSSvgFileProcessor {
+
+    private final IDistOSSSvgFileService distOSSSvgFileService;
+
+    public void params(String params) {
+        log.info("OSSSvgFile定时任务 param：{}", JSON.toJSONString(params));
+        long startTime = System.nanoTime();
+        String fileDir = Optional.ofNullable(params)// 获取参数内容
+                .map(JSON::parseObject)
+                .filter(ObjectUtils::isNotEmpty) // 过滤参数不为为空的逻辑
+                .map(e -> e.getString("fileDir"))
+                .orElse("harmony"); // 默认值
+        distOSSSvgFileService.saveBatchFileInfo(fileDir);
+        long endTime = System.nanoTime();
+        log.info("=====OSSSvgFile定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/FeederBaseProcessor.java

@@ -0,0 +1,27 @@
+package com.hdkj.lt.job.task;
+
+import com.hdkj.lt.job.service.IDealFeederBaseService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author rj
+ * @date 2025/12/22 15:17
+ * @description
+ */
+@Slf4j
+@Component("feederBase")
+@RequiredArgsConstructor
+public class FeederBaseProcessor  {
+
+    private final IDealFeederBaseService dealFeederBaseService;
+
+    public void noParams(){
+        log.info("=====FeederBase定时任务定时任务=====");
+        long startTime = System.nanoTime();
+        dealFeederBaseService.dealFeederBase();
+        long endTime = System.nanoTime();
+        log.info("=====FeederBase定时任务定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/FeederCacheRefreshProcessor.java

@@ -0,0 +1,27 @@
+package com.hdkj.lt.job.task;
+
+import com.hdkj.lt.core.sys.service.DwdShbDsFeederBaseService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @author luorui
+ * @date 2025/6/24 18:47
+ * @discription 定时刷新，线路信息缓存
+ **/
+@Slf4j
+@Component("feederCacheRefresh")
+@RequiredArgsConstructor
+public class FeederCacheRefreshProcessor {
+
+    private final DwdShbDsFeederBaseService dwdShbDsFeederBaseService;
+
+    public void noParams() {
+        log.info("=====线路信息缓存刷新定时任务开始执行=====");
+        long startTime = System.nanoTime();
+        dwdShbDsFeederBaseService.refreshAllFeederCache();
+        long endTime = System.nanoTime();
+        log.info("=====线路信息缓存刷新定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/FeederSpanSegmentBakProcessor.java

@@ -0,0 +1,28 @@
+package com.hdkj.lt.job.task;
+
+import com.hdkj.lt.job.service.IDealPsrDeviceService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description 馈线和档距段在中台接入前备份
+ * @Author wcx
+ * @Date 2025/9/1 14:38
+ * @Version 1.0
+ */
+@Slf4j
+@Component("feederSpanSegmentBak")
+@RequiredArgsConstructor
+public class FeederSpanSegmentBakProcessor {
+
+    private final IDealPsrDeviceService dealPsrDeviceService;
+
+    public void noParams() {
+        log.info("=====馈线和档距段在中台接入前备份定时任务=====");
+        long startTime = System.nanoTime();
+        dealPsrDeviceService.dealFeederSpanSegmentBak();
+        long endTime = System.nanoTime();
+        log.info("=====馈线和档距段在中台接入前备份定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/FeederSpanSegmentSupplyProcessor.java

@@ -0,0 +1,28 @@
+package com.hdkj.lt.job.task;
+
+import com.hdkj.lt.job.service.IDealPsrDeviceService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Description 馈线和档距段根据备份表非中台补充字段
+ * @Author wcx
+ * @Date 2025/9/1 14:45
+ * @Version 1.0
+ */
+@Slf4j
+@Component("feederSpanSegmentSupply")
+@RequiredArgsConstructor
+public class FeederSpanSegmentSupplyProcessor {
+
+    private final IDealPsrDeviceService dealPsrDeviceService;
+
+    public void noParams() {
+        log.info("=====>馈线和档距段根据备份表补充中台字段定时任务=====");
+        long startTime = System.nanoTime();
+        dealPsrDeviceService.dealFeederSpanSegmentBak();
+        long endTime = System.nanoTime();
+        log.info("=====>馈线和档距段根据备份表补充中台字段定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/JoinEcTransformerProcessor.java

@@ -0,0 +1,37 @@
+package com.hdkj.lt.job.task;
+
+import com.alibaba.fastjson.JSON;
+import com.hdkj.lt.job.service.IDealPsrDeviceService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.Optional;
+
+/**
+ * @Description 中压接入点和接入点变压器关联台账信息
+ * @Author wcx
+ * @Date 2025/7/30 15:07
+ * @Version 1.0
+ */
+@Slf4j
+@Component("joinEcTransformer")
+@RequiredArgsConstructor
+public class JoinEcTransformerProcessor {
+
+    private final IDealPsrDeviceService dealPsrDeviceService;
+
+    public void params(String params) {
+        log.info("=====中压接入点和接入点变压器关联台账信息定时任务开始=====");
+        long startTime = System.nanoTime();
+        String cityShort = Optional.ofNullable(params)// 获取参数内容,多个简称，隔开
+                .map(JSON::parseObject)
+                .filter(ObjectUtils::isNotEmpty) // 过滤参数不为为空的逻辑
+                .map(e -> e.getString("cityShort"))
+                .orElse("-"); // 默认值
+        dealPsrDeviceService.saveJoinEcTransformerInfo(cityShort);
+        long endTime = System.nanoTime();
+        log.info("=====中压接入点和接入点变压器关联台账信息定时任务开始执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/SegmentPsrDeviceProcessor.java

@@ -0,0 +1,37 @@
+package com.hdkj.lt.job.task;
+
+import com.alibaba.fastjson.JSON;
+import com.hdkj.lt.job.service.IDealPsrDeviceService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.Optional;
+
+/**
+ * @Description 导线、电缆段台账信息同步
+ * @Author wcx
+ * @Date 2025/9/1 15:00
+ * @Version 1.0
+ */
+@Slf4j
+@Component("segmentPsrDevice")
+@RequiredArgsConstructor
+public class SegmentPsrDeviceProcessor {
+
+    private final IDealPsrDeviceService dealPsrDeviceService;
+
+    public void params(String params) {
+        log.info("=====导线、电缆段台账信息接入定时任务开始=====");
+        long startTime = System.nanoTime();
+        String cityShort = Optional.ofNullable(params)// 获取参数内容,多个简称，隔开
+                .map(JSON::parseObject)
+                .filter(ObjectUtils::isNotEmpty) // 过滤参数不为为空的逻辑
+                .map(e -> e.getString("cityShort"))
+                .orElse("-"); // 默认值
+        dealPsrDeviceService.saveSegmentPsrDeviceInfo(cityShort);
+        long endTime = System.nanoTime();
+        log.info("=====导线、电缆段台账信息接入定时任务执行完成耗时：{}ms=====", (endTime - startTime) / 1_000_000);
+    }
+}

services/ruoyi-job/src/main/java/com/hdkj/lt/job/task/StruTreeCacheRefreshProcessor.java

@@ -6,7 +6,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 @Slf4j
-@Component("struTreeCacheRefreshProcessor")
+@Component("struTreeCacheRefresh")
 @RequiredArgsConstructor
 public class StruTreeCacheRefreshProcessor {