Commit 2e8c26ae authored by ZWT's avatar ZWT

feat(吉林演示): 松原

1.修改实际功率数据获取定时任务功能,修改定时配置,增加接入吉林实际功率数据逻辑,完成功能验证;
2.修改实际井口状态定时任务功能,修改定时配置,增加接入吉林实际功率数据逻辑,完成功能验证;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent ebca1438
......@@ -12,7 +12,9 @@ import pps.cloud.base.service.data.base_photovoltaic_plant.GetBasePhotovoltaicPl
import pps.cloud.base.service.data.base_power_line.DynamicQueryBasePowerLineInput;
import pps.cloud.base.service.data.base_power_line.DynamicQueryBasePowerLineOutput;
import pps.cloud.middle.service.IThirdActivePowerCloudService;
import pps.cloud.middle.service.IThirdCurrentWellConditionCloudService;
import pps.cloud.middle.service.data.third_active_power.GetThirdActivePowerViewInput;
import pps.cloud.middle.service.data.third_current_well_condition.GetThirdCurrentWellConditionOutput;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.constant.BusinessConstant;
import pps.core.prediction.constant.ThirdPartyApiConstant;
......@@ -160,15 +162,29 @@ public class ThirdDataAccessCloudServiceImpl implements IThirdDataAccessCloudSer
*/
@Override
public XServiceResult thirdCurrentWellConditionJob(XContext context) {
List<GetThirdCurrentWellConditionViewOutput> outputs;
//区分环境
String oilFieldCode = ServiceUtil.getOilFieldCode(context);
switch (oilFieldCode) {
case BusinessConstant.ENV_SY:
IThirdCurrentWellConditionCloudService service = context.getBean(IThirdCurrentWellConditionCloudService.class);
XListResult<GetThirdCurrentWellConditionOutput> result = service.getCurrentWellConditionList(context, null);
result.throwIfFail();
outputs = XCopyUtils.copyNewList(result.getResult(), GetThirdCurrentWellConditionViewOutput.class);
break;
case BusinessConstant.ENV_CQ:
String resultStr = ServiceUtil.doPostFormCq(context,
ThirdPartyApiConstant.CQ_WELL_REAL_PV_DATA,
new HashMap<>(0));
context.getLogger().info("*** CQ_WELL_REAL_PV_DATA : {}", resultStr);
List<GetThirdCurrentWellConditionViewOutput> outputs = JSON.parseArray(resultStr, GetThirdCurrentWellConditionViewOutput.class);
outputs = JSON.parseArray(resultStr, GetThirdCurrentWellConditionViewOutput.class);
break;
default:
return XServiceResult.OK;
}
if (CollUtil.isEmpty(outputs)) {
return XServiceResult.OK;
}
String oilFieldCode = ServiceUtil.getOilFieldCode(context);
DateTime date = DateUtil.date();
//先删后增
BigDecimal cumulativeProduction;
......
package pps.cloud.middle.service;
import pps.cloud.middle.service.data.third_current_well_condition.GetThirdCurrentWellConditionInput;
import pps.cloud.middle.service.data.third_current_well_condition.GetThirdCurrentWellConditionOutput;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XListResult;
/**
* 油井状态
*
* @author ZWT
* @date 2024/10/19 16:15
*/
@XText("油井状态Cloud模块")
@XService
public interface IThirdCurrentWellConditionCloudService {
/**
* 油井状态列表
*
* @param context 上下文
* @param input 输入
* @return {@link XListResult }<{@link GetThirdCurrentWellConditionOutput }>
*/
@XText("油井状态列表")
XListResult<GetThirdCurrentWellConditionOutput> getCurrentWellConditionList(XContext context, GetThirdCurrentWellConditionInput input);
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class CreateThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class CreateThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class DeleteThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class DeleteThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class DynamicQueryThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class DynamicQueryThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class DynamicQueryThirdCurrentWellConditionViewOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
/**
* 油井状态
*
* @author ZWT
* @date 2024/10/19
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class GetThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
......@@ -29,69 +43,4 @@ public class GetThirdCurrentWellConditionInput {
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import lombok.Data;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
/**
* 油井状态
*
* @author ZWT
* @date 2024/10/19
*/
@Data
public class GetThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
......@@ -29,69 +37,4 @@ public class GetThirdCurrentWellConditionOutput {
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class GetThirdCurrentWellConditionViewInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class GetThirdCurrentWellConditionViewOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import xstartup.base.data.XPageInput;
import java.math.BigDecimal;
import java.util.Date;
public class QueryThirdCurrentWellConditionInput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import xstartup.base.data.XPageInput;
import java.math.BigDecimal;
import java.util.Date;
public class QueryThirdCurrentWellConditionOutput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import xstartup.base.data.XPageInput;
import java.math.BigDecimal;
import java.util.Date;
public class QueryThirdCurrentWellConditionViewInput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import xstartup.base.data.XPageInput;
import java.math.BigDecimal;
import java.util.Date;
public class QueryThirdCurrentWellConditionViewOutput extends XPageInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class UpdateThirdCurrentWellConditionInput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
package pps.cloud.middle.service.data.third_current_well_condition;
import xstartup.annotation.XText;
import java.math.BigDecimal;
import java.util.Date;
public class UpdateThirdCurrentWellConditionOutput {
@XText("ID")
private Long id;
@XText("井号")
private String wellNumber;
@XText("下次启停时间")
private Date nextTime;
@XText("井口状态(开/停井)")
private String wellStatus;
@XText("累计产液量(m3)")
private BigDecimal cumulativeProduction;
@XText("开井时长(h)")
private BigDecimal runningTime;
@XText("来源系统")
private String systemSource;
@XText("更新时间")
private Date updateTime;
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 BigDecimal getRunningTime() {
return this.runningTime;
}
public void setRunningTime(BigDecimal value) {
this.runningTime = value;
}
public String getSystemSource() {
return this.systemSource;
}
public void setSystemSource(String value) {
this.systemSource = value;
}
public Date getUpdateTime() {
return this.updateTime;
}
public void setUpdateTime(Date value) {
this.updateTime = value;
}
}
......@@ -4,6 +4,12 @@ import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springframework.stereotype.Repository;
import pps.core.middle.entity.ThirdCurrentWellConditionEnt;
/**
* 油井状态
*
* @author ZWT
* @date 2024/10/19
*/
@Repository(value = "pps.core.middle.mapper.ThirdCurrentWellConditionMapper")
public interface ThirdCurrentWellConditionMapper extends BaseMapper<ThirdCurrentWellConditionEnt> {
}
package pps.core.middle.service;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import pps.cloud.middle.service.IThirdCurrentWellConditionCloudService;
import pps.cloud.middle.service.data.third_current_well_condition.GetThirdCurrentWellConditionInput;
import pps.cloud.middle.service.data.third_current_well_condition.GetThirdCurrentWellConditionOutput;
import pps.core.middle.entity.ThirdCurrentWellConditionEnt;
import pps.core.middle.mapper.ThirdCurrentWellConditionMapper;
import xstartup.annotation.XService;
import xstartup.base.XContext;
import xstartup.base.util.XCopyUtils;
import xstartup.data.XListResult;
import java.util.List;
/**
* 井口状态
*
* @author ZWT
* @date 2024/10/19 16:22
*/
@XService
public class ThirdCurrentWellConditionCloudServiceImpl implements IThirdCurrentWellConditionCloudService {
@Override
public XListResult<GetThirdCurrentWellConditionOutput> getCurrentWellConditionList(XContext context, GetThirdCurrentWellConditionInput input) {
ThirdCurrentWellConditionMapper mapper = context.getBean(ThirdCurrentWellConditionMapper.class);
List<ThirdCurrentWellConditionEnt> list = mapper.selectList(new LambdaQueryWrapper<>());
return XListResult.success(XCopyUtils.copyNewList(list, GetThirdCurrentWellConditionOutput.class));
}
}
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