Commit 3ebfc8f9 authored by ZWT's avatar ZWT

feat(能源管理系统): 间开优化定时任务

1.开发间开优化长期间开优化定时任务,完成并网流程绿电消纳优先策略;
2.开发间开优化长期间开优化定时任务,完成并网流程消峰平谷策略;
3.开发间开优化中短期间开优化定时任务,创建定时任务并添加配置;
4.抽取间开优化定时任务逻辑处理父类,对长期间开优化定时任务/中短期间开优化定时任务代码结构进行优化;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 538a2f8a
package pps.core.space.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import pps.core.common.entity.BaseModel;
import xstartup.annotation.XText;
import java.io.Serializable;
/**
* 间开优化井口制度记录
*
* @author ZWT
* @date 2023/09/05
*/
@Data
public class SpaceOptimizeDurationDTO extends BaseModel implements Serializable {
@XText("井口记录ID")
@TableField
private String recordId;
@XText("间开优化周期ID")
@TableField
private String periodId;
@XText("井口ID")
@TableField
private String wellheadId;
@XText("是否优化(0_是;1_否)")
@TableField
private Integer isOptimize;
@XText("发电类型key(字典获取)")
@TableField
private String generationTypeKey;
@XText("开井时间")
@TableField
private String openWellTime;
@XText("关井时间")
@TableField
private String closeWellTime;
}
package pps.core.space.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import pps.core.common.entity.BaseModel;
import xstartup.annotation.XText;
import java.io.Serializable;
import java.util.Date;
/**
* 间开优化周期记录
*
* @author ZWT
* @date 2023/09/05
*/
@Data
public class SpaceOptimizePeriodDTO extends BaseModel implements Serializable {
@XText("线路ID")
@TableField
private String lineId;
@XText("间开制度ID")
@TableField
private String institutionId;
@XText("执行周期")
@TableField
private String executionCycle;
@XText("优化状态(0_已优化;1_未优化)")
@TableField
private Integer optimizeState;
@XText("优化截止日期")
@TableField
private Date optimizeDeadline;
}
package pps.core.space.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import pps.core.common.entity.BaseModel;
import xstartup.annotation.XText;
import java.io.Serializable;
/**
* 间开优化井口记录
*
* @author ZWT
* @date 2023/09/05
*/
@Data
public class SpaceOptimizeWellheadDTO extends BaseModel implements Serializable {
@XText("间开优化周期ID")
@TableField
private String periodId;
@XText("井口ID")
@TableField
private String wellheadId;
@XText("井号")
@TableField
private String wellNumber;
}
...@@ -21,7 +21,7 @@ public interface SpaceOptimizeViewMapper { ...@@ -21,7 +21,7 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int longPeriodBatchInsertList(@Param(value = "list") List<SpaceOptimizeLongPeriodView> list); int longPeriodBatchInsertList(@Param(value = "list") List<SpaceOptimizePeriodDTO> list);
/** /**
* 长期间开优化井口批量新增 * 长期间开优化井口批量新增
...@@ -29,7 +29,7 @@ public interface SpaceOptimizeViewMapper { ...@@ -29,7 +29,7 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int longWellheadBatchInsertList(@Param(value = "list") List<SpaceOptimizeLongWellheadView> list); int longWellheadBatchInsertList(@Param(value = "list") List<SpaceOptimizeWellheadDTO> list);
/** /**
* 长期间开优化井口配置批量新增 * 长期间开优化井口配置批量新增
...@@ -37,7 +37,7 @@ public interface SpaceOptimizeViewMapper { ...@@ -37,7 +37,7 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int longDurationBatchInsertList(@Param(value = "list") List<SpaceOptimizeLongDurationView> list); int longDurationBatchInsertList(@Param(value = "list") List<SpaceOptimizeDurationDTO> list);
/** /**
* 长期间开优化批量新增 * 长期间开优化批量新增
...@@ -45,7 +45,7 @@ public interface SpaceOptimizeViewMapper { ...@@ -45,7 +45,7 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int midPeriodBatchInsertList(@Param(value = "list") List<SpaceOptimizeMidPeriodView> list); int midPeriodBatchInsertList(@Param(value = "list") List<SpaceOptimizePeriodDTO> list);
/** /**
* 长期间开优化井口批量新增 * 长期间开优化井口批量新增
...@@ -53,7 +53,7 @@ public interface SpaceOptimizeViewMapper { ...@@ -53,7 +53,7 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int midWellheadBatchInsertList(@Param(value = "list") List<SpaceOptimizeMidWellheadView> list); int midWellheadBatchInsertList(@Param(value = "list") List<SpaceOptimizeWellheadDTO> list);
/** /**
* 长期间开优化井口配置批量新增 * 长期间开优化井口配置批量新增
...@@ -61,5 +61,5 @@ public interface SpaceOptimizeViewMapper { ...@@ -61,5 +61,5 @@ public interface SpaceOptimizeViewMapper {
* @param list 列表 * @param list 列表
* @return int * @return int
*/ */
int midDurationBatchInsertList(@Param(value = "list") List<SpaceOptimizeMidDurationView> list); int midDurationBatchInsertList(@Param(value = "list") List<SpaceOptimizeDurationDTO> list);
} }
...@@ -38,7 +38,7 @@ ...@@ -38,7 +38,7 @@
#{item.modifyById}, #{item.modifyById},
#{item.modifyByName}, #{item.modifyByName},
#{item.modifyTime}, #{item.modifyTime},
#{item.longPeriodId}, #{item.periodId},
#{item.wellheadId}, #{item.wellheadId},
#{item.wellNumber} #{item.wellNumber}
) )
...@@ -73,7 +73,7 @@ ...@@ -73,7 +73,7 @@
#{item.modifyByName}, #{item.modifyByName},
#{item.modifyTime}, #{item.modifyTime},
#{item.recordId}, #{item.recordId},
#{item.longPeriodId}, #{item.periodId},
#{item.wellheadId}, #{item.wellheadId},
#{item.isOptimize}, #{item.isOptimize},
<choose> <choose>
...@@ -126,7 +126,7 @@ ...@@ -126,7 +126,7 @@
#{item.modifyById}, #{item.modifyById},
#{item.modifyByName}, #{item.modifyByName},
#{item.modifyTime}, #{item.modifyTime},
#{item.midPeriodId}, #{item.periodId},
#{item.wellheadId}, #{item.wellheadId},
#{item.wellNumber} #{item.wellNumber}
) )
...@@ -161,7 +161,7 @@ ...@@ -161,7 +161,7 @@
#{item.modifyByName}, #{item.modifyByName},
#{item.modifyTime}, #{item.modifyTime},
#{item.recordId}, #{item.recordId},
#{item.midPeriodId}, #{item.periodId},
#{item.wellheadId}, #{item.wellheadId},
#{item.isOptimize}, #{item.isOptimize},
<choose> <choose>
......
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