feat(零碳): 长庆

1.对接第三方接口,接入第三方数据,完成Token接口验证,抽取公用方法封装调用工具类;
2.对接第三方接口,完成获取日耗电日产液等信息接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
3.对接第三方接口,完成获取有功功率数据信息接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
4.对接第三方接口,完成获取甘特图数据接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
5.对接第三方接口,完成本日累计数据接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
6.对接第三方接口,完成光伏发电量接口调用,创建数据表,同时生成对应代码,开发定时任务及对外接口,完成第三方数据接入及系统展示功能,添加线上接口文档并完成接口及定时任务冒烟测试;
7.对接第三方接口,完成三叠登录接口调用,添加线上接口文档并完成接口及定时任务冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C09-base/pps-cloud-base/src/main/java/pps/cloud/base/service/IBaseWeatherCloudService.java

@@ -4,8 +4,6 @@ import xstartup.annotation.XService;
 import xstartup.annotation.XText;
 import xstartup.base.XContext;
 import xstartup.data.XServiceResult;
-import xstartup.feature.api.annotation.XApiAnonymous;
-import xstartup.feature.api.annotation.XApiGet;
 
 /**
  * 天气数据接收Cloud模块
@@ -23,8 +21,6 @@ public interface IBaseWeatherCloudService {
      * @param context 上下文
      * @return {@link XServiceResult}
      */
-    @XApiAnonymous
-    @XApiGet
     @XText("天气数据接收Cloud模块--天气数据处理")
     XServiceResult weatherDataProcess(XContext context);
 }

C09-base/pps-core-base/src/main/java/pps/core/base/service/BaseWeatherCloudServiceImpl.java

@@ -130,6 +130,10 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
                     List<String> timeList = Arrays.asList("15:00", "30:00", "45:00");
                     //读取附件
                     for (Message message : messageList) {
+                        String subject = message.getSubject();
+                        if (!CharSequenceUtil.endWith(subject, "天气预测数据")) {
+                            continue;
+                        }
                         String tempFilePath = this.saveAttachment(message);
                         logger.info("------ weatherDataProcess load file: {}", tempFilePath);
                         FileReader fileReader = new FileReader(tempFilePath);
@@ -307,6 +311,7 @@ public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
                         }
                         logger.info("------ weatherDataProcess del temp file path: {}", tempFilePath);
                         FileUtil.del(tempFilePath);
+                        message.setFlag(Flags.Flag.DELETED, true);
                     }
                 }
             } catch (MessagingException e) {

C10-task/pps-core-task/src/main/java/pps/core/task/constant/TaskConstant.java

@@ -51,7 +51,7 @@ public class TaskConstant {
     /**
      * 半小时执行一次 12:05:00 12:35:00...
      */
-    public static final String HALF_HOUR = "0 5/30 * * * ?";
+    public static final String HALF_HOUR_35 = "0 5/30 * * * ?";
 
     /**
      * 任务锁定键

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

@@ -27,7 +27,7 @@ public class WeatherReceiveJob implements XJob {
      * @param xContext x上下文
      * @return {@link XServiceResult}
      */
-    @XCronTrigger(value = TaskConstant.HALF_HOUR)
+    @XCronTrigger(value = TaskConstant.HALF_HOUR_35)
     @Override
     public XServiceResult execute(XContext xContext) {
         xContext.getLogger().info("------ WeatherReceiveJob start:{}", System.currentTimeMillis());