feat(能源管理系统): 邮件接收

1.添加天气数据邮件方式接收定时任务;
2.修改配置文件,增加新建定时任务,同时增加自定义参数;
3.创建天气邮件数据接收处理实现类,同时验证获取自定义参数方法;

BREAKING CHANGE: 无

Closes 无

[skip ci]

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

+package pps.cloud.base.service;
+
+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模块
+ *
+ * @author ZWT
+ * @date 2023/11/13 17:49
+ */
+@XService
+@XText("天气数据接收Cloud模块")
+public interface IBaseWeatherCloudService {
+
+    /**
+     * 天气数据接收Cloud模块--天气数据处理
+     *
+     * @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

+package pps.core.base.service;
+
+import pps.cloud.base.service.IBaseWeatherCloudService;
+import xstartup.annotation.XService;
+import xstartup.base.XContext;
+import xstartup.base.XStartup;
+import xstartup.data.XServiceResult;
+
+/**
+ * 天气数据接收Cloud模块
+ *
+ * @author ZWT
+ * @date 2023/11/13 17:54
+ */
+@XService
+public class BaseWeatherCloudServiceImpl implements IBaseWeatherCloudService {
+
+    /**
+     * 天气数据接收Cloud模块--天气数据处理
+     *
+     * @param context 上下文
+     * @return {@link XServiceResult}
+     */
+    @Override
+    public XServiceResult weatherDataProcess(XContext context) {
+        String property = XStartup.getCurrent().getProperty("weather.file.temp.path");
+        return XServiceResult.OK;
+    }
+}

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

 package pps.core.task.job;
 
+import pps.cloud.base.service.IBaseWeatherCloudService;
 import xstartup.annotation.XService;
 import xstartup.annotation.XText;
 import xstartup.base.XContext;
-import xstartup.base.XStartup;
 import xstartup.base.tool.XLoggerTool;
 import xstartup.data.XServiceResult;
 import xstartup.service.job.XJob;
@@ -30,8 +30,10 @@ public class WeatherReceiveJob implements XJob {
     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 property = XStartup.getCurrent().getProperty("weather.file.temp.path");
         return XServiceResult.OK;
     }
 }