Commit 8c4e6b2c authored by ZWT's avatar ZWT

feat(零碳): 长庆

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

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent b8f135dd
package pps.core.prediction.service; package pps.core.prediction.service;
import cn.hutool.core.collection.CollUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import pps.cloud.base.service.IBasePowerLineCloudService;
import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadInput;
import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadViewOutput;
import pps.core.prediction.entity.ThirdCurrentWellConditionEnt;
import pps.core.prediction.mapper.ThirdCurrentWellConditionMapper;
import pps.core.prediction.service.data.third_current_well_condition.QueryThirdCurrentWellConditionInput;
import pps.core.prediction.service.data.third_current_well_condition.QueryThirdCurrentWellConditionOutput;
import xstartup.annotation.XService; import xstartup.annotation.XService;
import xstartup.annotation.XText; import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.base.util.XCopyUtils;
import xstartup.data.XListResult;
import xstartup.feature.api.annotation.XApiAnonymous;
import xstartup.feature.api.annotation.XApiPost;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
/** /**
* 第三方当日油井状态 * 第三方当日油井状态
...@@ -13,4 +31,37 @@ import xstartup.annotation.XText; ...@@ -13,4 +31,37 @@ import xstartup.annotation.XText;
@XService @XService
public class ThirdCurrentWellConditionService { public class ThirdCurrentWellConditionService {
/**
* 油井状态
* POST /prediction/wellhead-daily-production-situation/query-well-real-pv-data
* 接口ID:156558765
* 接口地址:https://app.apifox.com/project/3196988/apis/api-156558765
*
* @param context 上下文
* @param input 输入
* @return {@link XListResult}<{@link QueryThirdCurrentWellConditionOutput}>
*/
@XApiAnonymous
@XText("井口生产情况--油井状态")
@XApiPost
public XListResult<QueryThirdCurrentWellConditionOutput> queryWellRealPvData(XContext context, QueryThirdCurrentWellConditionInput input) {
IBasePowerLineCloudService service = context.getBean(IBasePowerLineCloudService.class);
XListResult<DynamicQueryBasePowerLineWellheadViewOutput> result = service.getPowerLineWellheadList(context, DynamicQueryBasePowerLineWellheadInput.builder()
.lineId(input.getLineId())
.build()
);
result.throwIfFail();
List<QueryThirdCurrentWellConditionOutput> outputs;
List<DynamicQueryBasePowerLineWellheadViewOutput> list = result.getResult();
if (CollUtil.isEmpty(list)) {
return XListResult.success(new ArrayList<>(0));
}
ThirdCurrentWellConditionMapper mapper = context.getBean(ThirdCurrentWellConditionMapper.class);
List<ThirdCurrentWellConditionEnt> selectList = mapper.selectList(new LambdaQueryWrapper<ThirdCurrentWellConditionEnt>()
.in(ThirdCurrentWellConditionEnt::getWellNumber, list.stream()
.map(DynamicQueryBasePowerLineWellheadViewOutput::getWellNumber)
.collect(Collectors.toList()))
);
return XListResult.success(XCopyUtils.copyNewList(selectList, QueryThirdCurrentWellConditionOutput.class));
}
} }
...@@ -8,14 +8,14 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; ...@@ -8,14 +8,14 @@ import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import com.github.pagehelper.page.PageMethod; import com.github.pagehelper.page.PageMethod;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import pps.cloud.base.service.IBasePowerLineCloudService;
import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadInput;
import pps.cloud.base.service.data.base_power_line_wellhead.DynamicQueryBasePowerLineWellheadViewOutput;
import pps.core.auth.HttpRequestClient; import pps.core.auth.HttpRequestClient;
import pps.core.prediction.constant.ThirdPartyApiConstant; import pps.core.prediction.constant.ThirdPartyApiConstant;
import pps.core.prediction.entity.WellheadDailyProductionSituationEnt; import pps.core.prediction.entity.WellheadDailyProductionSituationEnt;
import pps.core.prediction.mapper.WellheadDailyProductionSituationMapper; import pps.core.prediction.mapper.WellheadDailyProductionSituationMapper;
import pps.core.prediction.service.data.wellhead_daily_production_situation.*; import pps.core.prediction.service.data.wellhead_daily_production_situation.GetWellheadDailyProductionSituationInput;
import pps.core.prediction.service.data.wellhead_daily_production_situation.GetWellheadDailyProductionSituationOutput;
import pps.core.prediction.service.data.wellhead_daily_production_situation.QueryWellheadDailyProductionSituationInput;
import pps.core.prediction.service.data.wellhead_daily_production_situation.QueryWellheadDailyProductionSituationOutput;
import pps.core.prediction.utils.ServiceUtil; import pps.core.prediction.utils.ServiceUtil;
import xstartup.annotation.XService; import xstartup.annotation.XService;
import xstartup.annotation.XText; import xstartup.annotation.XText;
...@@ -30,8 +30,10 @@ import xstartup.feature.api.annotation.XApiAnonymous; ...@@ -30,8 +30,10 @@ import xstartup.feature.api.annotation.XApiAnonymous;
import xstartup.feature.api.annotation.XApiGet; import xstartup.feature.api.annotation.XApiGet;
import xstartup.feature.api.annotation.XApiPost; import xstartup.feature.api.annotation.XApiPost;
import java.util.*; import java.util.ArrayList;
import java.util.stream.Collectors; import java.util.HashMap;
import java.util.List;
import java.util.Map;
/** /**
* 井口生产情况模块 * 井口生产情况模块
...@@ -103,53 +105,6 @@ public class WellheadDailyProductionSituationService { ...@@ -103,53 +105,6 @@ public class WellheadDailyProductionSituationService {
return XListResult.success(outputs); return XListResult.success(outputs);
} }
/**
* 油井状态
* POST /prediction/wellhead-daily-production-situation/query-well-real-pv-data
* 接口ID:156558765
* 接口地址:https://app.apifox.com/project/3196988/apis/api-156558765
*
* @param context 上下文
* @param input 输入
* @return {@link XListResult}<{@link GetWellRealPvOutput}>
*/
@XApiAnonymous
@XText("井口生产情况--油井状态")
@XApiPost
public XListResult<GetWellRealPvOutput> queryWellRealPvData(XContext context, GetWellRealPvInput input) {
IBasePowerLineCloudService service = context.getBean(IBasePowerLineCloudService.class);
XListResult<DynamicQueryBasePowerLineWellheadViewOutput> result = service.getPowerLineWellheadList(context, DynamicQueryBasePowerLineWellheadInput.builder()
.lineId(input.getLineId())
.build()
);
result.throwIfFail();
List<GetWellRealPvOutput> outputs;
List<DynamicQueryBasePowerLineWellheadViewOutput> list = result.getResult();
if (CollUtil.isEmpty(list)) {
return XListResult.success(new ArrayList<>(0));
}
String token = ServiceUtil.getToken(context);
HttpRequestClient client = new HttpRequestClient(token);
String url = XStartup.getCurrent().getProperty("third-party.chang-qing.url");
url += ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA;
String resultStr = client.doPostForm(url, new HashMap<>(0));
JSONObject jsonObject = JSON.parseObject(resultStr);
String data = jsonObject.getString("data");
outputs = JSON.parseArray(data, GetWellRealPvOutput.class);
if (CollUtil.isEmpty(outputs)) {
return XListResult.success(new ArrayList<>(0));
} else {
Set<String> collect = list.stream()
.map(DynamicQueryBasePowerLineWellheadViewOutput::getWellNumber)
.collect(Collectors.toSet());
outputs = outputs.stream()
.filter(o -> collect.contains(o.getWellNumber()))
.collect(Collectors.toList());
}
return XListResult.success(outputs);
}
@XApiAnonymous @XApiAnonymous
@XText("井口生产情况--test") @XText("井口生产情况--test")
@XApiGet @XApiGet
......
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class CreateThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class CreateThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class DeleteThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class DeleteThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class DynamicQueryThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class DynamicQueryThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class DynamicQueryThirdCurrentWellConditionViewOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class GetThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class GetThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class GetThirdCurrentWellConditionViewInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition; package pps.core.prediction.service.data.third_current_well_condition;
import jakarta.validation.constraints.NotBlank;
import lombok.Data;
import xstartup.annotation.XText; import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
import xstartup.base.data.XPageInput;
public class QueryThirdCurrentWellConditionInput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
/**
* 第三方当日油井状态
*
* @author ZWT
* @date 2024/03/19
*/
@Data
public class QueryThirdCurrentWellConditionInput {
@XText("线路ID")
@NotBlank(message = "缺少线路ID")
private String lineId;
} }
package pps.core.prediction.service.data.third_current_well_condition; package pps.core.prediction.service.data.third_current_well_condition;
import lombok.Data;
import xstartup.annotation.XText; import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal; import java.math.BigDecimal;
import java.util.Date;
import xstartup.base.data.XPageInput; /**
public class QueryThirdCurrentWellConditionOutput extends XPageInput { * 第三方当日油井状态
*
* @author ZWT
* @date 2024/03/19
*/
@Data
public class QueryThirdCurrentWellConditionOutput {
@XText("ID") @XText("ID")
private Long id; private Long id;
...@@ -26,61 +34,4 @@ public class QueryThirdCurrentWellConditionOutput extends XPageInput { ...@@ -26,61 +34,4 @@ public class QueryThirdCurrentWellConditionOutput extends XPageInput {
@XText("来源系统") @XText("来源系统")
private String systemSource; private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
} }
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
import xstartup.base.data.XPageInput;
public class QueryThirdCurrentWellConditionViewInput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
import xstartup.base.data.XPageInput;
public class QueryThirdCurrentWellConditionViewOutput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class UpdateThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.util.Date;
import java.math.BigDecimal;
public class UpdateThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m³)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private Integer runningTime;
@XText("来源系统")
private String systemSource;
public Long getId() {
return this.id;
}
public void setId(Long value) {
this.id = value;
}
public String getWellNumber() {
return this.wellNumber;
}
public void setWellNumber(String value) {
this.wellNumber = value;
}
public Date getNextTime() {
return this.nextTime;
}
public void setNextTime(Date value) {
this.nextTime = value;
}
public String getWellStatus() {
return this.wellStatus;
}
public void setWellStatus(String value) {
this.wellStatus = value;
}
public BigDecimal getCumulativeProduction() {
return this.cumulativeProduction;
}
public void setCumulativeProduction(BigDecimal value) {
this.cumulativeProduction = value;
}
public Integer getRunningTime() {
return this.runningTime;
}
public void setRunningTime(Integer value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
}
package pps.core.prediction.service.data.wellhead_daily_production_situation;
import jakarta.validation.constraints.NotBlank;
import lombok.Data;
import xstartup.annotation.XText;
/**
* 油井状态
*
* @author ZWT
* @date 2024/03/18 17:24
*/
@Data
public class GetWellRealPvInput {
@XText("线路ID")
@NotBlank(message = "缺少线路ID")
private String lineId;
}
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 2024/03/18 17:24
*/
@Data
public class GetWellRealPvOutput {
@XText("井号")
@JSONField(name = "welL_NAME")
private String wellNumber;
@XText("下次启停时间")
@JSONField(name = "next_ExecDate")
private Date nextTime;
@XText("井口状态:停井/开井")
@JSONField(name = "status")
private String status;
@XText("累计产液量")
@JSONField(name = "reaL_LIQUID_DAILY")
private BigDecimal realLiquidProduction;
@XText("累计开井时长")
@JSONField(name = "starthours")
private Integer hours;
}
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