Skip to content

G
gf_back
Commit 4b1c323f authored by ZWT's avatar ZWT
Browse files
Options

feat(零碳): 长庆 

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

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent cecab810
Hide whitespace changes
Inline Side-by-side
Showing with 61 additions and 60 deletions
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/WellheadDailyProductionSituationService.java
View file @ 4b1c323f
...@@ -109,72 +109,73 @@ public class WellheadDailyProductionSituationService { ...@@ -109,72 +109,73 @@ public class WellheadDailyProductionSituationService {
@XText("井口生产情况--test") @XText("井口生产情况--test")
@XApiGet @XApiGet
public XServiceResult test(XContext context) { public XServiceResult test(XContext context) {
context.getLogger().info("---------------------------cqToken---------------------------"); // context.getLogger().info("---------------------------cqToken---------------------------");
String cqToken = ""; // String cqToken = "";
String api; // String api;
try { // try {
cqToken = ServiceUtil.getToken(context); // cqToken = ServiceUtil.getToken(context);
context.getLogger().info("cqToken: " + cqToken); // context.getLogger().info("cqToken: " + cqToken);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url"); // String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
Map<String, String> header = new HashMap<>(4); // Map<String, String> header = new HashMap<>(4);
header.put("token", cqToken); // header.put("token", cqToken);
context.getLogger().info("---------------------------CQ_WELL_TECH_DAILY---------------------------"); // context.getLogger().info("---------------------------CQ_WELL_TECH_DAILY---------------------------");
HttpRequestClient client = new HttpRequestClient(cqToken); // HttpRequestClient client = new HttpRequestClient(cqToken);
try { // try {
api = url + ThirdPartyApiConstant.CQ_WELL_TECH_DAILY; // api = url + ThirdPartyApiConstant.CQ_WELL_TECH_DAILY;
Map<String, Object> param = new HashMap<>(4); // Map<String, Object> param = new HashMap<>(4);
param.put("Calc_Date", "2024-03-18"); // param.put("Calc_Date", "2024-03-18");
String s = client.doPostForm(api, param); // String s = client.doPostForm(api, param);
context.getLogger().info("CQ_WELL_TECH_DAILY: " + s); // context.getLogger().info("CQ_WELL_TECH_DAILY: " + s);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
context.getLogger().info("---------------------------CQ_WELL_STATION_PV_DATA---------------------------"); // context.getLogger().info("---------------------------CQ_WELL_STATION_PV_DATA---------------------------");
try { // try {
api = url + ThirdPartyApiConstant.CQ_WELL_STATION_PV_DATA; // api = url + ThirdPartyApiConstant.CQ_WELL_STATION_PV_DATA;
String s = client.doPostForm(api, new HashMap<>(4)); // String s = client.doPostForm(api, new HashMap<>(4));
context.getLogger().info("CQ_WELL_STATION_PV_DATA: " + s); // context.getLogger().info("CQ_WELL_STATION_PV_DATA: " + s);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
context.getLogger().info("---------------------------CQ_RPT_SYSTEM_START_STOP---------------------------"); // context.getLogger().info("---------------------------CQ_RPT_SYSTEM_START_STOP---------------------------");
try { // try {
api = url + ThirdPartyApiConstant.CQ_RPT_SYSTEM_START_STOP; // api = url + ThirdPartyApiConstant.CQ_RPT_SYSTEM_START_STOP;
Map<String, Object> param = new HashMap<>(4); // Map<String, Object> param = new HashMap<>(4);
param.put("WELL_NAME", "王101-23"); // param.put("WELL_NAME", "王101-23");
String s = client.doPostForm(api, param); // String s = client.doPostForm(api, param);
context.getLogger().info("CQ_RPT_SYSTEM_START_STOP: " + s); // context.getLogger().info("CQ_RPT_SYSTEM_START_STOP: " + s);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
context.getLogger().info("---------------------------CQ_WELL_REAL_PV_DATA---------------------------"); // context.getLogger().info("---------------------------CQ_WELL_REAL_PV_DATA---------------------------");
try { // try {
api = url + ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA; // api = url + ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA;
String s = client.doPostForm(api, new HashMap<>(4)); // String s = client.doPostForm(api, new HashMap<>(4));
context.getLogger().info("CQ_WELL_REAL_PV_DATA: " + s); // context.getLogger().info("CQ_WELL_REAL_PV_DATA: " + s);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
context.getLogger().info("---------------------------CQ_STATION_DAILY_PV_DATA---------------------------"); // context.getLogger().info("---------------------------CQ_STATION_DAILY_PV_DATA---------------------------");
try { // try {
api = url + ThirdPartyApiConstant.CQ_STATION_DAILY_PV_DATA; // api = url + ThirdPartyApiConstant.CQ_STATION_DAILY_PV_DATA;
Map<String, Object> param = new HashMap<>(4); // Map<String, Object> param = new HashMap<>(4);
param.put("Calc_Date", "2024-03-18"); // param.put("Calc_Date", "2024-03-18");
String s = client.doPostForm(api, param); // String s = client.doPostForm(api, param);
context.getLogger().info("CQ_STATION_DAILY_PV_DATA: " + s); // context.getLogger().info("CQ_STATION_DAILY_PV_DATA: " + s);
} catch (Exception e) { // } catch (Exception e) {
e.printStackTrace(); // e.printStackTrace();
} // }
context.getLogger().info("---------------------------JI_CHENG_TOKEN---------------------------"); context.getLogger().info("---------------------------JI_CHENG_TOKEN---------------------------");
try { try {
String t = "http://10.59.249.10:8183/admin-api/system/auth/login"; String t = "http://10.59.249.10:8183/admin-api/system/auth/login";
Map<String, String> param = new HashMap<>(4); Map<String, String> param = new HashMap<>(4);
param.put("username", "31b5604627e345ebb48175de8f2ee0bdem55ajAwMQ==kj"); param.put("username", "31b5604627e345ebb48175de8f2ee0bdem55ajAwMQ==kj");
param.put("password", "sdSktfem55ajAwMSFAIzEw8ef354f215d44c0eafd403ab7a1ce74a"); param.put("password", "sdSktfem55ajAwMSFAIzEw8ef354f215d44c0eafd403ab7a1ce74a");
String result = XHttpUtils.postAsJson(url, JSON.toJSONString(param)); String result = XHttpUtils.postAsJson(t, JSON.toJSONString(param));
context.getLogger().info("JI_CHENG_TOKEN: " + JSON.toJSONString(param));
context.getLogger().info("JI_CHENG_TOKEN: " + result); context.getLogger().info("JI_CHENG_TOKEN: " + result);
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment