feat(吉林演示): 松原

1.开发间开优化结果统计功能,创建间开优化效果统计表,生成对应代码;
2.修改15天,10天,3天,1天间开优化功能,修改代码结构;

BREAKING CHANGE: 无

Closes 无

[skip ci]

C11-space/pps-core-space/src/main/java/pps/core/space/service/SpaceOptimizeBaseService.java

@@ -1850,7 +1850,10 @@ public class SpaceOptimizeBaseService {
         DateTime firstStartTime = null;
         //井口累积运行总功率
         BigDecimal totalOperatingPower = BigDecimal.ZERO;
+        //临时间开
+        List<SpaceOptimizeDurationDTO> newDurationDTOList;
         for (int w = 0, wellheadSize = wellheadViewList.size(); w < wellheadSize; w++) {
+            newDurationDTOList = new ArrayList<>(12);
             SpaceInstitutionWellheadView wellhead = wellheadViewList.get(w);
             String wellheadId = wellhead.getWellheadId();
             String recordId = this.createOptimizeWellhead(wellheadDTOList, periodId, wellheadId, wellhead.getWellNumber(), wellhead.getStartSeq(), optimizeDate, BusinessConstant.ONE);
@@ -1904,21 +1907,21 @@ public class SpaceOptimizeBaseService {
                         int startDuration = (int) startTime.between(endTime, DateUnit.MINUTE);
                         DateTime endTimeOptimize = startTimeOptimize.offsetNew(DateField.MINUTE, startDuration);
                         if (startTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) < 0 && endTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) > 0) {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                     BusinessConstant.ZERO, optimizeDate
                             );
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     BusinessConstant.START_OF_DAY_TIME, endTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT),
                                     BusinessConstant.ZERO, optimizeDate
                             );
                         } else if (endTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) == 0) {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                     BusinessConstant.ZERO, optimizeDate
                             );
                         } else {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), endTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT),
                                     BusinessConstant.ZERO, optimizeDate
                             );
@@ -1960,21 +1963,21 @@ public class SpaceOptimizeBaseService {
                         }
                         //记录
                         if (startTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) < 0 && endTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) > 0) {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                     BusinessConstant.ZERO, optimizeDate
                             );
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     BusinessConstant.START_OF_DAY_TIME, endTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT),
                                     BusinessConstant.ZERO, optimizeDate
                             );
                         } else if (endTimeOptimize.compareTo(BusinessConstant.DATE_FLAG) == 0) {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                     BusinessConstant.ZERO, optimizeDate
                             );
                         } else {
-                            this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                            this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                     startTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT), endTimeOptimize.toString(BusinessConstant.MINUTES_FORMAT),
                                     BusinessConstant.ZERO, optimizeDate
                             );
@@ -1988,27 +1991,46 @@ public class SpaceOptimizeBaseService {
                     DateTime startOffset = DateUtil.offsetMinute(startTime, between);
                     DateTime endOffset = DateUtil.offsetMinute(endTime, between);
                     if (startOffset.compareTo(BusinessConstant.DATE_FLAG) < 0 && endOffset.compareTo(BusinessConstant.DATE_FLAG) > 0) {
-                        this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                        this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                 startOffset.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                 BusinessConstant.ONE, optimizeDate
                         );
-                        this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                        this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                 BusinessConstant.START_OF_DAY_TIME, endOffset.toString(BusinessConstant.MINUTES_FORMAT),
                                 BusinessConstant.ONE, optimizeDate
                         );
                     } else if (endOffset.compareTo(BusinessConstant.DATE_FLAG) == 0) {
-                        this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                        this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                 startOffset.toString(BusinessConstant.MINUTES_FORMAT), BusinessConstant.END_OF_DAY_TIME,
                                 BusinessConstant.ONE, optimizeDate
                         );
                     } else {
-                        this.createOptimizeDuration(durationDTOList, periodId, recordId, wellheadId, null,
+                        this.createOptimizeDuration(newDurationDTOList, periodId, recordId, wellheadId, null,
                                 startOffset.toString(BusinessConstant.MINUTES_FORMAT), endOffset.toString(BusinessConstant.MINUTES_FORMAT),
                                 BusinessConstant.ONE, optimizeDate
                         );
                     }
                 }
             }
+            //数据处理
+            if (CollUtil.isNotEmpty(newDurationDTOList)) {
+                newDurationDTOList.sort(Comparator.comparing(SpaceOptimizeDurationDTO::getOpenWellTime));
+                List<SpaceOptimizeDurationDTO> tempDurationDTOList = new ArrayList<>(newDurationDTOList.size());
+                tempDurationDTOList.add(newDurationDTOList.get(0));
+                for (int i = 1; i < newDurationDTOList.size(); i++) {
+                    SpaceOptimizeDurationDTO nowOne = newDurationDTOList.get(i);
+                    SpaceOptimizeDurationDTO lastOne = tempDurationDTOList.get(tempDurationDTOList.size() - 1);
+                    if (CharSequenceUtil.equals(lastOne.getCloseWellTime(), nowOne.getOpenWellTime())) {
+                        lastOne.setCloseWellTime(nowOne.getCloseWellTime());
+                    } else {
+                        tempDurationDTOList.add(nowOne);
+                    }
+                }
+                //保存结果
+                for (SpaceOptimizeDurationDTO dto : tempDurationDTOList) {
+                    durationDTOList.add(dto);
+                }
+            }
         }
     }