feat(能源管理系统): 修改架构

1.修改架构添加cse;
2.修改各微服务服务名,启动验证,完成cse注册;
3.修改各模块pom及配置文件,解决服务间无法调用问题;
4.修改各服务配置,解决gateway模块跨域问题;
5.暂时删除部分编译错误代码,完成本地登录流程等基础功能测试,验证改造后链路是否正常;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C00-common/pps-common/src/main/java/pps/core/common/cache/TaskLockCache.java

@@ -22,10 +22,6 @@ public class TaskLockCache implements XCacheObject, XCacheLife {
      * Redis Value
      */
     private String redisValue;
-    /**
-     * 过期时间(分钟)
-     */
-    private Integer validity;
 
     /**
      * 获取持续时间
@@ -34,7 +30,7 @@ public class TaskLockCache implements XCacheObject, XCacheLife {
      */
     @Override
     public Integer getDuration() {
-        return validity * 60;
+        return 600;
     }
 
     /**

C10-task/pps-core-task/src/main/java/pps/core/task/job/WeatherReceiveJob.java

 package pps.core.task.job;
 
+import cn.hutool.core.util.ObjectUtil;
 import pps.cloud.base.service.IBaseWeatherCloudService;
+import pps.core.common.cache.TaskLockCache;
 import pps.core.task.constant.TaskConstant;
 import xstartup.annotation.XService;
 import xstartup.annotation.XText;
 import xstartup.base.XContext;
-import xstartup.base.tool.XLoggerTool;
 import xstartup.data.XServiceResult;
 import xstartup.service.job.XJob;
 import xstartup.service.job.annotation.XCronTrigger;
@@ -29,12 +30,25 @@ public class WeatherReceiveJob implements XJob {
     @XCronTrigger(value = TaskConstant.HALF_HOUR)
     @Override
     public XServiceResult execute(XContext xContext) {
-        XLoggerTool logger = xContext.getLogger();
-        logger.info("------ WeatherReceiveJob start:{}", System.currentTimeMillis());
-        IBaseWeatherCloudService service = xContext.getBean(IBaseWeatherCloudService.class);
-        XServiceResult result = service.weatherDataProcess(xContext);
-        result.throwIfFail();
-        logger.info("------ WeatherReceiveJob end:{}", System.currentTimeMillis());
+        String key = TaskConstant.TASK_LOCK_KEY + "WeatherReceiveJob";
+        TaskLockCache exist = TaskLockCache.exist(xContext, key);
+        if (ObjectUtil.isNull(exist)) {
+            TaskLockCache cache = new TaskLockCache();
+            cache.setRedisKey(key);
+            cache.setRedisValue(key);
+            TaskLockCache.set(xContext, cache);
+            try {
+                xContext.getLogger().info("------ WeatherReceiveJob start:{}", System.currentTimeMillis());
+                IBaseWeatherCloudService service = xContext.getBean(IBaseWeatherCloudService.class);
+                XServiceResult result = service.weatherDataProcess(xContext);
+                result.throwIfFail();
+            } catch (Exception e) {
+                xContext.getLogger().error("------ WeatherReceiveJob Exception: ", e);
+            } finally {
+                xContext.getLogger().info("------ WeatherReceiveJob end:{}", System.currentTimeMillis());
+                TaskLockCache.delete(xContext, key);
+            }
+        }
         return XServiceResult.OK;
     }
 }