feat(零碳): 长庆

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

BREAKING CHANGE: 无

Closes 无

[skip ci]

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/ThirdDataAccessCloudServiceImpl.java

 package pps.core.prediction.service;
 
 import pps.cloud.prediction.service.IThirdDataAccessCloudService;
-import pps.core.auth.HttpRequestClient;
 import pps.core.prediction.constant.ThirdPartyApiConstant;
 import pps.core.prediction.utils.ServiceUtil;
 import xstartup.annotation.XService;
 import xstartup.annotation.XText;
 import xstartup.base.XContext;
-import xstartup.base.XStartup;
 import xstartup.data.XServiceResult;
 
 import java.util.HashMap;
-import java.util.Map;
 
 /**
  * 第三方数据接入Cloud模块
@@ -23,20 +20,6 @@ import java.util.Map;
 @XService
 public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudService {
 
-    /**
-     * 调用接口
-     *
-     * @param context 上下文
-     * @param api     应用程序编程接口
-     * @param param   参数
-     * @return {@link String}
-     */
-    private String doPostForm(XContext context, String api, Map<String, Object> param) {
-        String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
-        String token = ServiceUtil.getToken(context);
-        HttpRequestClient client = new HttpRequestClient(token);
-        return client.doPostForm(url + api, param);
-    }
 
     /**
      * 第三方有功功率定时任务
@@ -46,7 +29,7 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
      */
     @Override
     public XServiceResult thirdActivePowerJob(XContext context) {
-        String resultStr = this.doPostForm(context,
+        String resultStr = ServiceUtil.doPostFormCq(context,
                 ThirdPartyApiConstant.CQ_WELL_STATION_PV_DATA,
                 new HashMap<>(0));
 
@@ -62,6 +45,10 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
      */
     @Override
     public XServiceResult thirdCurrentWellConditionJob(XContext context) {
+        String resultStr = ServiceUtil.doPostFormCq(context,
+                ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA,
+                new HashMap<>(0));
+
         return null;
     }
 
@@ -73,6 +60,10 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
      */
     @Override
     public XServiceResult thirdPhotovoltaicPowerJob(XContext context) {
+        String resultStr = ServiceUtil.doPostFormCq(context,
+                ThirdPartyApiConstant.CQ_STATION_DAILY_PV_DATA,
+                new HashMap<>(0));
+
         return null;
     }
 }

C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/utils/ServiceUtil.java

@@ -5,6 +5,8 @@ import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.json.JSONObject;
 import cn.hutool.json.JSONUtil;
+import com.alibaba.fastjson2.JSON;
+import pps.core.auth.HttpRequestClient;
 import pps.core.common.cache.ThirdPartyConfigCache;
 import pps.core.prediction.constant.ThirdPartyApiConstant;
 import xstartup.base.XContext;
@@ -22,6 +24,23 @@ import java.util.Map;
  */
 public class ServiceUtil {
 
+    /**
+     * 调用接口(长庆)
+     *
+     * @param context 上下文
+     * @param api     应用程序编程接口
+     * @param param   参数
+     * @return {@link String}
+     */
+    public static String doPostFormCq(XContext context, String api, Map<String, Object> param) {
+        String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
+        String token = ServiceUtil.getToken(context);
+        HttpRequestClient client = new HttpRequestClient(token);
+        String resultStr = client.doPostForm(url + api, param);
+        com.alibaba.fastjson2.JSONObject jsonObject = JSON.parseObject(resultStr);
+        return jsonObject.getString("data");
+    }
+
     /**
      * 获取长庆TOKEN
      *