Skip to content

G
gf_back
Commit 25c616cf authored by ZWT's avatar ZWT
Browse files
Options

nocommit

parent c538741f
Hide whitespace changes
Inline Side-by-side
Showing with 427 additions and 18 deletions
C00-common/pps-common/pom.xml
View file @ 25c616cf
...@@ -180,6 +180,13 @@ ...@@ -180,6 +180,13 @@
<artifactId>easyexcel</artifactId> <artifactId>easyexcel</artifactId>
<version>3.3.3</version> <version>3.3.3</version>
</dependency> </dependency>
<!-- https://mvnrepository.com/artifact/com.alibaba.fastjson2/fastjson2 -->
<dependency>
<groupId>com.alibaba.fastjson2</groupId>
<artifactId>fastjson2</artifactId>
<version>2.0.47</version>
</dependency>
</dependencies> </dependencies>
<build> <build>
<plugins> <plugins>
......
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/PlantPredictedPowerCloudServiceImpl.java
View file @ 25c616cf
package pps.core.prediction.service; package pps.core.prediction.service;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.date.DateUtil; import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import pps.cloud.prediction.service.IPlantPredictedPowerCloudService; import pps.cloud.prediction.service.IPlantPredictedPowerCloudService;
import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerInput; import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerInput;
import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerOutput; import pps.cloud.prediction.service.data.plant_predicted_power_data.DynamicQueryPlantPredictedPowerOutput;
import pps.core.auth.HttpRequestClient;
import pps.core.prediction.constant.ThirdPartyApiConstant;
import pps.core.prediction.entity.PlantPredictedPowerDataEnt; import pps.core.prediction.entity.PlantPredictedPowerDataEnt;
import pps.core.prediction.entity.PlantPredictedPowerLongTermDataEnt; import pps.core.prediction.entity.PlantPredictedPowerLongTermDataEnt;
import pps.core.prediction.mapper.PlantPredictedPowerDataMapper; import pps.core.prediction.mapper.PlantPredictedPowerDataMapper;
import pps.core.prediction.mapper.PlantPredictedPowerLongTermDataMapper; import pps.core.prediction.mapper.PlantPredictedPowerLongTermDataMapper;
import pps.core.prediction.utils.ServiceUtil; import pps.core.prediction.service.data.wellhead_daily_production_situation.WellheadDailyProductionSituationJob;
import xstartup.annotation.XService; import xstartup.annotation.XService;
import xstartup.base.XContext; import xstartup.base.XContext;
import xstartup.base.XStartup;
import xstartup.base.util.XCopyUtils; import xstartup.base.util.XCopyUtils;
import xstartup.data.XListResult; import xstartup.data.XListResult;
import xstartup.data.XServiceResult; import xstartup.data.XServiceResult;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map;
/** /**
* 光伏预测Cloud模块 * 光伏预测Cloud模块
...@@ -175,13 +171,384 @@ public class PlantPredictedPowerCloudServiceImpl implements IPlantPredictedPower ...@@ -175,13 +171,384 @@ public class PlantPredictedPowerCloudServiceImpl implements IPlantPredictedPower
*/ */
@Override @Override
public XServiceResult wellTechDailyJob(XContext context) { public XServiceResult wellTechDailyJob(XContext context) {
String token = ServiceUtil.getToken(context); String s = "{\n" +
HttpRequestClient client = new HttpRequestClient(token); "\t\"status\": 100,\n" +
String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url"); "\t\"msg\": \"执行成功！\",\n" +
String api = url + ThirdPartyApiConstant.CQ_WELL_TECH_DAILY; "\t\"data\": [\n" +
Map<String, Object> param = new HashMap<>(2); "\t\t{\n" +
param.put("Calc_Date", DateUtil.date().toString("yyyy-MM-dd")); "\t\t\t\"welL_NAME\": \"王侧11-8\",\n" +
String s = client.doPostForm(api, param); "\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 40.37,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.2,\n" +
"\t\t\t\"starthours\": 900,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塞侧29-4\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 39.71,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.04,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山31-14\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 78.33,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.69,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山33-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 56.01,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 3.74,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山33-14\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": null,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.8,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山34-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": null,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 4.6,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山36-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 25.09,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 4.49,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山39-12\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 25.36,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.29,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山40-11\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 26.54,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.19,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山41-9\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 68.46,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0.58,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山43-5\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 16.67,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.03,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午249-9\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 18.71,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.44,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午252-9\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 42.02,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 6.65,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午291\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": null,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.36,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午侧249-8\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 206.96,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 6.01,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午平231-04\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 81.51,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 5.9,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山30-15\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 25.11,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.31,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山35-12\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 189.94,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.41,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山38-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 25.52,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.71,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山39-11\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 19.98,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.73,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山41-6\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 55.08,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 5.04,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午250-10\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 62.34,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 6.71,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午251-10\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 39.17,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 8.26,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山37-11\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 40.29,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 4.52,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山33-15\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 236.27,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.92,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"午222-210X\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 43.76,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0.93,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山37-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 17.33,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.85,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山35-14\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": null,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0.66,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山35-15\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 169.45,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.61,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山38-11\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 34.55,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 3.57,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山42-9\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 27.9,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.29,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"山32-13\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": null,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"成36-46\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 65.95,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.79,\n" +
"\t\t\t\"starthours\": 40,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬49-90\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 178,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 4.99,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬46-89\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 56.22,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0.4,\n" +
"\t\t\t\"starthours\": 8,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬46-93\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 86.54,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.88,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬32-92\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 44.45,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.53,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"成37-46\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 59.16,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 0.81,\n" +
"\t\t\t\"starthours\": 44,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬46-90\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 74.08,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 1.85,\n" +
"\t\t\t\"starthours\": 44,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"成63-10\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 68.32,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 2.59,\n" +
"\t\t\t\"starthours\": 40,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t},\n" +
"\t\t{\n" +
"\t\t\t\"welL_NAME\": \"塬46-92\",\n" +
"\t\t\t\"caL_DATE\": \"2024-03-15T00:00:00\",\n" +
"\t\t\t\"poweR_CONSUME_DAILY\": 60.54,\n" +
"\t\t\t\"reaL_LIQUID_DAILY\": 3.62,\n" +
"\t\t\t\"starthours\": 0,\n" +
"\t\t\t\"status\": null,\n" +
"\t\t\t\"next_ExecDate\": \"0001-01-01T00:00:00\"\n" +
"\t\t}\n" +
"\t]\n" +
"}";
JSONObject jsonObject = JSON.parseObject(s);
String data = jsonObject.getString("data");
List<WellheadDailyProductionSituationJob> wellheadDailyProductionSituationJobs = JSON.parseArray(data, WellheadDailyProductionSituationJob.class);
return XServiceResult.OK; return XServiceResult.OK;
} }
} }
C12-prediction/pps-core-prediction/src/main/java/pps/core/prediction/service/data/wellhead_daily_production_situation/WellheadDailyProductionSituationJob.java 0 → 100644
View file @ 25c616cf
package pps.core.prediction.service.data.wellhead_daily_production_situation;
import com.alibaba.fastjson2.annotation.JSONField;
import lombok.Data;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
/**
* 井口生产情况表
*
* @author ZWT
* @date 2023/09/27
*/
@Data
public class WellheadDailyProductionSituationJob {
@XText("井号")
@JSONField(name = "welL_NAME")
private String wellNumber;
@XText("日期")
@JSONField(name = "caL_DATE")
private Date dataDate;
@XText("生产时间(h)")
@JSONField(name = "starthours")
private BigDecimal productionTime;
@XText("日耗电量(kW-h)")
@JSONField(name = "poweR_CONSUME_DAILY")
private BigDecimal dailyElectricityConsumption;
@XText("日产液量(t)")
@JSONField(name = "reaL_LIQUID_DAILY")
private BigDecimal dailyLiquidProduction;
}
D03-deploy/deploy-pps-task/src/main/java/app/DeployPpsTaskApplication.java
View file @ 25c616cf
...@@ -21,7 +21,6 @@ import xstartup.service.job.conf.XJobServiceConf; ...@@ -21,7 +21,6 @@ import xstartup.service.job.conf.XJobServiceConf;
public class DeployPpsTaskApplication { public class DeployPpsTaskApplication {
public static void main(String... args) { public static void main(String... args) {
System.out.println("println--DeployPpsTaskApplication");
CounterBuilder.globalCounterBuilder.setFieldValue(CounterBuilder.DEPLOY_KEY, DeployPpsTaskApplication.class.getSimpleName()); CounterBuilder.globalCounterBuilder.setFieldValue(CounterBuilder.DEPLOY_KEY, DeployPpsTaskApplication.class.getSimpleName());
XStartup startup = new XStartupApplication("pps"); XStartup startup = new XStartupApplication("pps");
startup.config(new XServerConf(22062).naming("pps-task")) startup.config(new XServerConf(22062).naming("pps-task"))
...@@ -37,16 +36,14 @@ public class DeployPpsTaskApplication { ...@@ -37,16 +36,14 @@ public class DeployPpsTaskApplication {
startup.enable(XJobFeature.class).config(new XJobServiceConf(SpaceCalibrationJob.class)); startup.enable(XJobFeature.class).config(new XJobServiceConf(SpaceCalibrationJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(SpaceOptimizeShortJob.class)); startup.enable(XJobFeature.class).config(new XJobServiceConf(SpaceOptimizeShortJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherReceiveJob.class)); startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherReceiveJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WellTechDailyJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(PlantPredictedPowerLongTermDataJob.class)); startup.enable(XJobFeature.class).config(new XJobServiceConf(PlantPredictedPowerLongTermDataJob.class));
startup.enable(XRpcFeature.class); startup.enable(XRpcFeature.class);
startup.enable(XCloudHuaweiCseFeature.class) startup.enable(XCloudHuaweiCseFeature.class)
.config(XCloudBundlesConf.with( .config(XCloudBundlesConf.with(
// XCloudBundle.naming("pps-workflow").addModule("pps", "cloud", "task"),
XCloudBundle.naming("pps-base-info").addModule("pps", "cloud", "system"), XCloudBundle.naming("pps-base-info").addModule("pps", "cloud", "system"),
XCloudBundle.naming("pps-base-prediction").addModule("pps", "cloud", "prediction"), XCloudBundle.naming("pps-base-prediction").addModule("pps", "cloud", "prediction"),
XCloudBundle.naming("pps-base-info").addModule("pps", "cloud", "base"))); XCloudBundle.naming("pps-base-info").addModule("pps", "cloud", "base")));
startup.run(args); startup.run(args);
} }
} }
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