:sparkles: 长江经济带添加portId=1146的数据,数据源为102

src/main/java/com/shcd/mapper/SpStatementShipUsageMonthMapper.java

@@ -2,6 +2,7 @@ package com.shcd.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.shcd.entity.SpStatementShipUsageMonth;
+import com.shcd.vo.ShorePowerDataVo;
 import com.shcd.vo.SpQuarterReportBlVo;
 import com.shcd.vo.SpQuarterReportOriginVo;
 import com.shcd.vo.SpShipUsageMonthQuarterVo;
@@ -21,8 +22,8 @@ import java.util.List;
 public interface SpStatementShipUsageMonthMapper extends BaseMapper<SpStatementShipUsageMonth> {
 
   List<SpStatementShipUsageDetail> selectOriginDataMonth(
-          @Param("thisDate") Date thisDate, @Param("lastDate") Date lastDate,
-          @Param("lastCycleStart") Date lastCycleStart, @Param("lastCycleEnd") Date lastCycleEnd);
+      @Param("thisDate") Date thisDate, @Param("lastDate") Date lastDate,
+      @Param("lastCycleStart") Date lastCycleStart, @Param("lastCycleEnd") Date lastCycleEnd);
 
   SpStatementShipUsageMonthVo selectOriginDataYear(@Param("toDate") String thisDate);
 
@@ -71,11 +72,16 @@ public interface SpStatementShipUsageMonthMapper extends BaseMapper<SpStatementS
       @Param("end") Date end);
 
   List<SpStatementShipUsageDetail> selectNhAndWgMonth(@Param("thisDate") Date thisDate,
-                                                      @Param("lastDate") Date lastDate,
-                                                      @Param("lastCycleStart") Date lastCycleStart,
-                                                      @Param("lastCycleEnd") Date lastCycleEnd);
+      @Param("lastDate") Date lastDate,
+      @Param("lastCycleStart") Date lastCycleStart,
+      @Param("lastCycleEnd") Date lastCycleEnd);
+
+  SpStatementShipUsageMonthVo selectNhAndWgLastMonthSum(@Param("thisMonth") Date thisDate);
 
-    SpStatementShipUsageMonthVo selectNhAndWgLastMonthSum(@Param("thisMonth") Date thisDate);
+  List<ShorePowerDataVo> selectPortIdEq1146(@Param("currentCycleStart") String currentCycleStart,
+      @Param("currentCycleEnd") String currentCycleEnd,
+      @Param("lastCycleStart") String lastCycleStart,
+      @Param("lastCycleEnd") String lastCycleEnd);
 }
 
 

src/main/java/com/shcd/service/impl/SpStatementShipUsageMonthServiceImpl.java

@@ -1,6 +1,7 @@
 package com.shcd.service.impl;
 
 import cn.hutool.core.lang.generator.SnowflakeGenerator;
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.shanghaigeography.Util.DateUtils;
@@ -11,6 +12,7 @@ import com.shcd.mapper.SpStatementShipUsageMonthMapper;
 import com.shcd.service.SpStatementSgService;
 import com.shcd.service.SpStatementShipUsageMonthService;
 import com.shcd.service.SpStatementYearAnalysisService;
+import com.shcd.vo.ShorePowerDataVo;
 import com.shcd.vo.SpStatementShipUsageDetail;
 import com.shcd.vo.SpStatementShipUsageMonthVo;
 import java.math.BigDecimal;
@@ -26,6 +28,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
 /**
  * @author csdl
  * @description 针对表【SP_STATEMENT_SHIP_USAGE_MONTH(上海市长江经济带船舶使用岸电情况报表)】的数据库操作Service实现
@@ -84,7 +88,8 @@ public class SpStatementShipUsageMonthServiceImpl extends
       Date toDate = DateUtils.stringToDate(thisYear + "-" + thisMonth + "-01", "yyyy-MM-dd");
       Date toDateBegin = DateUtils.stringToDate(thisYear + "-01-01", "yyyy-MM-dd");
       Date yearCountBegin = DateUtils.stringToDate(thisYear - 1 + "-12-25", "yyyy-MM-dd");
-      Date lastCycleStart = DateUtils.stringToDate(lastCycleYear + "-" + lastCycleMonth + "-25", "yyyy-MM-dd");
+      Date lastCycleStart = DateUtils.stringToDate(lastCycleYear + "-" + lastCycleMonth + "-25",
+          "yyyy-MM-dd");
       Date lastCycleEnd = DateUtils.stringToDate(lastYear + "-" + lastMonth + "-25", "yyyy-MM-dd");
       //删除
       String dateStr = thisYear + "-" + thisMonth + "-01";
@@ -97,7 +102,8 @@ public class SpStatementShipUsageMonthServiceImpl extends
       spStatementShipUsageMonthMapper.deleteByDate(dateStr);
       //先算本次月度的
       CompletableFuture<List<SpStatementShipUsageDetail>> future1 = CompletableFuture.supplyAsync(
-          () -> spStatementShipUsageMonthMapper.selectOriginDataMonth(thisDate, lastDate,lastCycleStart,lastCycleEnd));
+          () -> spStatementShipUsageMonthMapper.selectOriginDataMonth(thisDate, lastDate,
+              lastCycleStart, lastCycleEnd));
       CompletableFuture<SpStatementShipUsageMonthVo> future2 = CompletableFuture.supplyAsync(
           () -> spStatementShipUsageMonthMapper.selectGhDataMonth(toDate));
       CompletableFuture<SpStatementShipUsageMonthVo> future5 = CompletableFuture.supplyAsync(
@@ -139,19 +145,22 @@ public class SpStatementShipUsageMonthServiceImpl extends
       origin.setId(snowflakeGenerator.next().toString());
       origin.setShipUsageMonth(originMonth.getShipUsage().add(originSelfMonth.getShipUsage())
           .setScale(2, RoundingMode.HALF_UP));
-      origin.setShipUsageYear(originYear.getShipUsage().add(originMonth.getShipUsage()).add(originSelfMonth.getShipUsage())
+      origin.setShipUsageYear(originYear.getShipUsage().add(originMonth.getShipUsage())
+          .add(originSelfMonth.getShipUsage())
           .setScale(2, RoundingMode.HALF_UP));
       origin.setShorePowerTimeMonth(
           originMonth.getShorePowerTime().add(originSelfMonth.getShorePowerTime())
               .setScale(2, RoundingMode.HALF_UP));
       origin.setShorePowerTimeYear(
-          originYear.getShorePowerTime().add(originMonth.getShorePowerTime()).add(originSelfMonth.getShorePowerTime())
+          originYear.getShorePowerTime().add(originMonth.getShorePowerTime())
+              .add(originSelfMonth.getShorePowerTime())
               .setScale(2, RoundingMode.HALF_UP));
       origin.setShorePowerCountMonth(
           originMonth.getShorePowerCount().add(originSelfMonth.getShorePowerCount())
               .setScale(2, RoundingMode.HALF_UP));
       origin.setShorePowerCountYear(
-          originYear.getShorePowerCount().add(originMonth.getShorePowerCount()).add(originSelfMonth.getShorePowerCount())
+          originYear.getShorePowerCount().add(originMonth.getShorePowerCount())
+              .add(originSelfMonth.getShorePowerCount())
               .setScale(2, RoundingMode.HALF_UP));
       origin.setReportDate(DateUtils.stringToDate(thisYear + "-" + thisMonth, "yyyy-MM"));
       origin.setDataSource(0);
@@ -180,10 +189,10 @@ public class SpStatementShipUsageMonthServiceImpl extends
           toDateBegin, toDate);
       SpStatementShipUsageMonth underLine = new SpStatementShipUsageMonth();
       if (underLineMonth != null || underLineYear != null) {
-        if (underLineMonth == null){
+        if (underLineMonth == null) {
           underLineMonth = new SpStatementShipUsageMonthVo();
         }
-        if (underLineYear == null){
+        if (underLineYear == null) {
           underLineYear = new SpStatementShipUsageMonthVo();
         }
         underLine.setId(snowflakeGenerator.next().toString());
@@ -231,7 +240,7 @@ public class SpStatementShipUsageMonthServiceImpl extends
       spStatementShipUsageMonths.add(sum);
       //傻逼一样的要多算一部分数据，外电1，2，3
       List<SpStatementShipUsageDetail> sbWgq = spStatementShipUsageMonthMapper.selectWgqMonth(
-          thisDate, lastDate,lastCycleStart,lastCycleEnd);
+          thisDate, lastDate, lastCycleStart, lastCycleEnd);
       SpStatementShipUsageMonthVo wgqMonth = makeOriginMonthData(sbWgq);
       SpStatementShipUsageMonthVo wgqYear = spStatementShipUsageMonthMapper.selectWgqYear(
           dateStrLast);
@@ -254,12 +263,14 @@ public class SpStatementShipUsageMonthServiceImpl extends
       spStatementShipUsageMonths.add(wgq);
       //有一个合计的用于上海市岸电使用指标完成情况统计表，对应的dataSource为101
       //获取对应月的数据
-      List<SpStatementShipUsageDetail> nwSum = spStatementShipUsageMonthMapper.selectNhAndWgMonth(thisDate,lastDate,lastCycleStart,lastCycleEnd);
+      List<SpStatementShipUsageDetail> nwSum = spStatementShipUsageMonthMapper.selectNhAndWgMonth(
+          thisDate, lastDate, lastCycleStart, lastCycleEnd);
       SpStatementShipUsageMonthVo realSum = makeOriginMonthData(nwSum);
       //获取该月前一个月的合计数据
-      SpStatementShipUsageMonthVo nwSumLastSum = spStatementShipUsageMonthMapper.selectNhAndWgLastMonthSum(DateUtils.stringToDate(dateStrLast,"yyyy-MM"));
+      SpStatementShipUsageMonthVo nwSumLastSum = spStatementShipUsageMonthMapper.selectNhAndWgLastMonthSum(
+          DateUtils.stringToDate(dateStrLast, "yyyy-MM"));
       SpStatementShipUsageMonth nwSumSave = new SpStatementShipUsageMonth();
-      if (nwSumLastSum == null){
+      if (nwSumLastSum == null) {
         nwSumLastSum = new SpStatementShipUsageMonthVo();
       }
       nwSumSave.setId(snowflakeGenerator.next().toString());
@@ -268,15 +279,21 @@ public class SpStatementShipUsageMonthServiceImpl extends
       nwSumSave.setShipUsageMonth(realSum.getShipUsage());
       nwSumSave.setShorePowerCountMonth(realSum.getShorePowerCount());
       nwSumSave.setShorePowerTimeMonth(realSum.getShorePowerTime());
-      nwSumSave.setShipUsageYear(nwSumLastSum.getShipUsage().add(realSum.getShipUsage()).setScale(2,RoundingMode.HALF_UP));
-      nwSumSave.setShorePowerTimeYear(nwSumLastSum.getShorePowerTime().add(realSum.getShorePowerTime()).setScale(2,RoundingMode.HALF_UP));
-      nwSumSave.setShorePowerCountYear(nwSumLastSum.getShorePowerCount().add(realSum.getShorePowerCount()).setScale(2,RoundingMode.HALF_UP));
+      nwSumSave.setShipUsageYear(nwSumLastSum.getShipUsage().add(realSum.getShipUsage())
+          .setScale(2, RoundingMode.HALF_UP));
+      nwSumSave.setShorePowerTimeYear(
+          nwSumLastSum.getShorePowerTime().add(realSum.getShorePowerTime())
+              .setScale(2, RoundingMode.HALF_UP));
+      nwSumSave.setShorePowerCountYear(
+          nwSumLastSum.getShorePowerCount().add(realSum.getShorePowerCount())
+              .setScale(2, RoundingMode.HALF_UP));
       spStatementShipUsageMonths.add(nwSumSave);
       //获取对应年的合计
       //计算内河平台数据
       //先获取本月的数据
       CompletableFuture<List<SpStatementShipUsageDetail>> futureInRiver = CompletableFuture.supplyAsync(
-          () -> spStatementShipUsageMonthMapper.getInRiverDataThisMonth(thisDate, lastDate,lastCycleStart,lastCycleEnd));
+          () -> spStatementShipUsageMonthMapper.getInRiverDataThisMonth(thisDate, lastDate,
+              lastCycleStart, lastCycleEnd));
       CompletableFuture<SpStatementShipUsageMonthVo> futureInRiverSelf = CompletableFuture.supplyAsync(
           () -> spStatementShipUsageMonthMapper.getInRiverDataSelfThisMonth(thisDate, lastDate));
       //获取本月之前合计数据
@@ -334,6 +351,58 @@ public class SpStatementShipUsageMonthServiceImpl extends
       outRiverShipUsage.setShorePowerTimeYear(
           origin.getShorePowerTimeYear().subtract(inRiverShipUsage.getShorePowerTimeYear()));
       spStatementShipUsageMonths.add(outRiverShipUsage);
+      // 计算portId = 1146的每个月数据存储到长江经济带中间表 dataSource102
+      ShorePowerDataVo portIdEq1146;
+      SpStatementShipUsageMonth portIdEq1146Data = new SpStatementShipUsageMonth();
+      String portIdEq1146ReportDate = currentDate + "-01";
+      String portIdEq1146Year = portIdEq1146ReportDate.split("-")[0];
+      String portIdEq1146LastYear = String.valueOf(Integer.parseInt(portIdEq1146Year) - 1);
+      String portIdEq1146CurrentStart;
+      String portIdEq1146CurrentEnd = "";
+      String portIdEq1146LastStart = "";
+      String portIdEq1146LastEnd = "";
+      if (portIdEq1146ReportDate.split("-")[1].equals("01")) {
+        portIdEq1146CurrentStart = portIdEq1146LastYear + "-12-25 00:00:00";
+        portIdEq1146CurrentEnd = portIdEq1146Year + "-01-24 23:59:59";
+        portIdEq1146LastStart = portIdEq1146LastYear + "-11-25 00:00:00";
+        portIdEq1146LastEnd = portIdEq1146LastYear + "-12-24 23:59:59";
+      } else if (portIdEq1146ReportDate.split("-")[1].equals("02")) {
+        portIdEq1146CurrentStart = portIdEq1146Year + "-01-25 00:00:00";
+        portIdEq1146CurrentEnd = portIdEq1146Year + "-02-24 23:59:59";
+        portIdEq1146LastStart = portIdEq1146LastYear + "-12-25 00:00:00";
+        portIdEq1146LastEnd = portIdEq1146Year + "-01-24 23:59:59";
+      } else {
+        Integer portIdEq1146lastMonth = Integer.parseInt(portIdEq1146ReportDate.split("-")[1]) - 1;
+        Integer last2Month = Integer.parseInt(portIdEq1146ReportDate.split("-")[1]) - 2;
+        portIdEq1146CurrentStart = portIdEq1146Year + "-" + portIdEq1146lastMonth + "-25 00:00:00";
+        portIdEq1146CurrentEnd =
+            portIdEq1146Year + "-" + Integer.parseInt(portIdEq1146ReportDate.split("-")[1])
+                + "-24 23:59:59";
+        portIdEq1146LastStart = portIdEq1146Year + "-" + last2Month + "-25 00:00:00";
+        portIdEq1146LastEnd = portIdEq1146Year + "-" + portIdEq1146lastMonth + "-24 23:59:59";
+      }
+      log.info("========>当前月份{} 查询参数为 :{},{},{},{}", portIdEq1146ReportDate,
+          portIdEq1146CurrentStart, portIdEq1146CurrentEnd, portIdEq1146LastStart,
+          portIdEq1146LastEnd);
+      List<ShorePowerDataVo> dataVos = spStatementShipUsageMonthMapper.selectPortIdEq1146(
+          portIdEq1146CurrentStart, portIdEq1146CurrentEnd, portIdEq1146LastStart,
+          portIdEq1146LastEnd);
+      if (CollectionUtils.isEmpty(dataVos)) {
+        portIdEq1146 = new ShorePowerDataVo();
+      } else {
+        portIdEq1146 = dataVos.get(0);
+      }
+      log.info("当月{},添加的portId等于1146的数据为:{}", portIdEq1146ReportDate,
+          JSONObject.toJSONString(portIdEq1146));
+      portIdEq1146Data.setId(snowflakeGenerator.next().toString());
+      portIdEq1146Data.setReportDate(DateUtils.stringToDate(portIdEq1146ReportDate,DateUtils.DATE_FORMAT_10));
+      portIdEq1146Data.setDataSource(102);
+      portIdEq1146Data.setShipUsageMonth(portIdEq1146.getBoatUse());
+      portIdEq1146Data.setShorePowerTimeMonth(portIdEq1146.getElectTime());
+      portIdEq1146Data.setShorePowerCountMonth(portIdEq1146.getElectCount());
+      log.info("当月{},长江经济带存储的portId等于1146的数据为:{}", portIdEq1146ReportDate,
+          JSONObject.toJSONString(portIdEq1146Data));
+      spStatementShipUsageMonths.add(portIdEq1146Data);
       this.saveBatch(spStatementShipUsageMonths);
       //岸电年比
       ArrayList<SpStatementYearAnalysis> save = new ArrayList<>();
@@ -528,7 +597,8 @@ public class SpStatementShipUsageMonthServiceImpl extends
               thisYear - 1 + "-" + (thisMonth < 10 ? "0" + thisMonth : thisMonth)));
       //获取去年最后一个月
       SpStatementSg last = spStatementSgService.getOne(
-          Wrappers.<SpStatementSg>lambdaQuery().eq(SpStatementSg::getReportDate, thisYear -1 + "-12"));
+          Wrappers.<SpStatementSg>lambdaQuery()
+              .eq(SpStatementSg::getReportDate, thisYear - 1 + "-12"));
       SpStatementSg spStatementSg = new SpStatementSg();
       spStatementSg.setId(snowflakeGenerator.next().toString());
       spStatementSg.setReportDate(DateUtils.dateToString(toDate, "yyyy-MM"));
@@ -566,7 +636,8 @@ public class SpStatementShipUsageMonthServiceImpl extends
         //查询往期合计，计算本月合计
         SpStatementSg lastMonthSg = spStatementSgService.getOne(
             Wrappers.<SpStatementSg>lambdaQuery()
-                .eq(SpStatementSg::getReportDate, thisYear + "-" + (lastMonth < 10 ? "0" + lastMonth : lastMonth)));
+                .eq(SpStatementSg::getReportDate,
+                    thisYear + "-" + (lastMonth < 10 ? "0" + lastMonth : lastMonth)));
         spStatementSg.setSumChargeTime(
             underLineSg.getShorePowerTime().add(lastMonthSg.getSumChargeTime())
                 .setScale(2, RoundingMode.HALF_UP));

src/main/java/com/shcd/vo/ShorePowerDataVo.java

@@ -0,0 +1,16 @@
+package com.shcd.vo;
+
+import java.math.BigDecimal;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class ShorePowerDataVo {
+  String district;
+  BigDecimal boatUse = BigDecimal.ZERO;
+  BigDecimal electTime = BigDecimal.ZERO;
+  BigDecimal electCount = BigDecimal.ZERO;
+}

src/main/resources/mapper/SpStatementShipUsageMonthMapper.xml

@@ -4,117 +4,203 @@
   "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.shcd.mapper.SpStatementShipUsageMonthMapper">
 
-    <resultMap id="BaseResultMap" type="com.shcd.entity.SpStatementShipUsageMonth">
-            <result property="reportDate" column="REPORT_DATE" jdbcType="TIMESTAMP"/>
-            <result property="shipUsageYear" column="SHIP_USAGE_YEAR" jdbcType="DECIMAL"/>
-            <result property="shorePowerTimeMonth" column="SHORE_POWER_TIME_MONTH" jdbcType="DECIMAL"/>
-            <result property="shorePowerTimeYear" column="SHORE_POWER_TIME_YEAR" jdbcType="DECIMAL"/>
-            <result property="shorePowerCountMonth" column="SHORE_POWER_COUNT_MONTH" jdbcType="DECIMAL"/>
-            <result property="shorePowerCountYear" column="SHORE_POWER_COUNT_YEAR" jdbcType="DECIMAL"/>
-            <result property="dataSource" column="DATA_SOURCE" jdbcType="DECIMAL"/>
-            <result property="shipUsageMonth" column="SHIP_USAGE_MONTH" jdbcType="DECIMAL"/>
-    </resultMap>
-    <delete id="deleteByDate">
-        delete from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH where trunc(REPORT_DATE) = to_date(#{toDate},'yyyy-mm-dd')
-    </delete>
-    <select id="selectOriginDataMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
-        select STARTTIME chargeStartDate, ENDTIME chargeEndDate ,ELECT shorePowerCount  from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
-        where (ENDTIME between #{lastDate} and #{thisDate}) OR (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND MODIFYTIME between #{lastDate} and #{thisDate})
-    </select>
-    <select id="selectGhDataMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select decode(sum(SHORE_POWER_BOAT_USE_NUMBER),null,0,sum(SHORE_POWER_BOAT_USE_NUMBER)) shipUsage,decode(sum(POWER_CONN_HOURS),null,0,sum(POWER_CONN_HOURS)) shorePowerTime,decode(sum(ELECTRICITY_CONSUMPTION),null,0,sum(ELECTRICITY_CONSUMPTION)) shorePowerCount  from GHJG_PORT_MANAGE.SHORE_POWER_DEVICE_USAGE
-        where trunc(REPORT_DATE) = #{thisDate}
-    </select>
-    <select id="selectOriginDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select SHIP_USAGE_YEAR shipUsage, SHORE_POWER_COUNT_YEAR shorePowerCount,SHORE_POWER_TIME_YEAR shorePowerTime from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH where trunc(REPORT_DATE) = to_date(#{toDate},'yyyy-mm-dd')
-        and DATA_SOURCE = 0
-    </select>
-    <select id="selectGhDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select SHIP_USAGE_YEAR shipUsage, SHORE_POWER_COUNT_YEAR shorePowerCount,SHORE_POWER_TIME_YEAR shorePowerTime from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH where trunc(REPORT_DATE) = to_date(#{toDate},'yyyy-mm-dd')
-        and DATA_SOURCE = 10
-    </select>
-    <select id="getInRiverDataBeforeThisMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select SHIP_USAGE_YEAR shipUsage, SHORE_POWER_COUNT_YEAR shorePowerCount,SHORE_POWER_TIME_YEAR shorePowerTime from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH WHERE trunc(REPORT_DATE) = to_date(#{toDate},'yyyy-mm-dd')
-        AND DATA_SOURCE = 1
-    </select>
-    <select id="getUnderLineMonthData" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  ship_usage shipUsage, power_time_use shorePowerTime, power_elec_use  shorePowerCount from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
-        where trunc(REPORT_DATE) = #{toDate} and NAME = '上海市黄浦江码头岸线建设管理有限公司'
-    </select>
-    <select id="getUnderLineYearData" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  SUM(ship_usage) shipUsage, SUM(power_time_use) shorePowerTime , SUM(power_elec_use) shorePowerCount from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
-        where  trunc(REPORT_DATE) >= #{yearCountBegin} and trunc(REPORT_DATE) &lt;= #{yearCountEnd} and NAME = '上海市黄浦江码头岸线建设管理有限公司'
-    </select>
-    <select id="selectOriginSelfDataMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  sum(USE_COUNT) shipUsage, sum(ELE_TIME) shorePowerCount, sum(USE_ELECTRICITY) shorePowerTime from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse
-        where MODIFY_TIME >= #{lastDate} and MODIFY_TIME &lt;= #{thisDate}
-    </select>
-    <select id="selectOriginSelfDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  sum(USE_COUNT) shipUsage, sum(ELE_TIME) shorePowerCount, sum(USE_ELECTRICITY) shorePowerTime from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse
-        where MODIFY_TIME >= #{yearCountBegin} and MODIFY_TIME &lt;= #{yearCountEnd}
-    </select>
-    <select id="selectQuarterOrigin" resultType="com.shcd.vo.SpQuarterReportOriginVo">
-      select b.BERTHTYPE, b.CAPACITY, i.STARTTIME, i.ENDTIME, i.ELECT
-      from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO i
-             left join GHJG_PORT_MANAGE.SHORE_POWER_BERTH_INFO_NEW b on i.BERTHID = b.BERTHID
-      where b.BERTHTYPE is not null
-        AND ((i.ENDTIME >= #{startDate}
-        AND i.ENDTIME &lt;= #{endDate})
-        OR (i.ENDTIME >= #{newStartDate} and i.ENDTIME &lt;= #{newStartEnd} AND
-            i.MODIFYTIME >= #{startDate} and i.MODIFYTIME &lt;= #{endDate}))
-    </select>
-    <select id="selectQuarterBlBerth" resultType="com.shcd.vo.SpQuarterReportBlVo">
-        select B.BERTH_TYPE berthType, b.TONNAGE capacity , m.USE_COUNT useCount, m.ELE_TIME elect, m.USE_ELECTRICITY useElectricity
-        from GHJG_PORT_MANAGE.SHORE_POWER_BLBERTHMONTHUSE m
-                 left join
-             GHJG_PORT_MANAGE.SHORE_POWER_CHDEVICEFBO b on m.USER_BERTH_ID = b.ID
-        where m.MODIFY_TIME >= #{startDate}
-        and  m.MODIFY_TIME &lt;= #{endDate} AND b.BERTH_TYPE is not null
-    </select>
-    <select id="selectWgqMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
-        select STARTTIME chargeStartDate, ENDTIME chargeEndDate ,ELECT shorePowerCount  from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
-        where ((ENDTIME between #{lastDate} and #{thisDate}) OR (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND MODIFYTIME between #{lastDate} and #{thisDate})) and ENTERPRISESNAME in ('上海外高桥发电有限责任公司','上海外高桥第二发电有限责任公司','上海外高桥第三发电有限责任公司')
-    </select>
-    <select id="selectWgqYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select SHIP_USAGE_YEAR shipUsage, SHORE_POWER_COUNT_YEAR shorePowerCount,SHORE_POWER_TIME_YEAR shorePowerTime
-        from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH where trunc(REPORT_DATE) = to_date(#{toDate},'yyyy-mm-dd')
-        and DATA_SOURCE = 100
-    </select>
-    <select id="getInRiverDataThisMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
-        select STARTTIME chargeStartDate, ENDTIME chargeEndDate ,ELECT shorePowerCount  from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO i
-        left join GHJG_PORT_MANAGE.SHORE_POWER_PORT_INFO_NEW b on B.PORTID = i.PORTID
-        where ((ENDTIME between #{lastDate} and #{thisDate}) OR (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND MODIFYTIME between #{lastDate} and #{thisDate})) and (CONNTYPE = '低压(标准化)' and area >= 2 AND b.AREA &lt;= 12)
-    </select>
-    <select id="getInRiverDataSelfThisMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  sum(USE_COUNT) shipUsage, sum(ELE_TIME) shorePowerCount, sum(USE_ELECTRICITY) shorePowerTime from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse b
-                                                                                                             left join GHJG_PORT_MANAGE.SHORE_POWER_CHDEVICEFBO c on b.USER_BERTH_ID = c.ID
-        where b.MODIFY_TIME >= #{lastDate} and b.MODIFY_TIME &lt;= #{thisDate} and c.AREA >= 2 AND c.AREA &lt;= 12
-    </select>
-    <select id="getUnderLineMonthDataSg" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select  ship_usage shipUsage, power_time_use shorePowerTime, power_elec_use shorePowerCount from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
-        where trunc(REPORT_DATE) = #{toDate} and NAME = '上海国际港务（集团）股份有限公司'
-    </select>
-    <select id="selectThreeMonthsDataTotal" resultType="com.shcd.vo.SpShipUsageMonthQuarterVo">
-      SELECT SUM(T.SHIP_USAGE_MONTH) shipUsageMonth,
-             MAX(T.SHIP_USAGE_YEAR) shipUsageYear,
-             SUM(T.SHORE_POWER_TIME_MONTH) shorePowerCountMonth,
-             MAX(T.SHORE_POWER_TIME_YEAR) shorePowerCountYear,
-             SUM(T.SHORE_POWER_COUNT_MONTH) shorePowerTimeMonth,
-             MAX(T.SHORE_POWER_COUNT_YEAR) shorePowerTimeYear
-      FROM GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH T
-      where T.DATA_SOURCE = 99
-      AND T.REPORT_DATE >= #{start} AND T.REPORT_DATE &lt;= #{end}
-    </select>
-    <select id="selectNhAndWgMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
-        select STARTTIME chargeStartDate, ENDTIME chargeEndDate, ELECT shorePowerCount
-        from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
-        where CONNTYPE = '低压(标准化)'
-          and (ENDTIME > #{lastDate} and ENDTIME &lt; #{thisDate}
-                   or
-               (ENDTIME > #{lastCycleStart} and ENDTIME &lt; #{lastDate} and MODIFYTIME > #{lastDate} and MODIFYTIME &lt; #{thisDate}))
-    </select>
-    <select id="selectNhAndWgLastMonthSum" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
-        select SHIP_USAGE_YEAR shipUsage, SHORE_POWER_TIME_YEAR shorePowerTime, SHORE_POWER_COUNT_YEAR shorePowerCount  from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
-        where trunc(REPORT_DATE) = trunc(#{thisMonth}) and DATA_SOURCE = 101
-    </select>
+  <resultMap id="BaseResultMap" type="com.shcd.entity.SpStatementShipUsageMonth">
+    <result property="reportDate" column="REPORT_DATE" jdbcType="TIMESTAMP"/>
+    <result property="shipUsageYear" column="SHIP_USAGE_YEAR" jdbcType="DECIMAL"/>
+    <result property="shorePowerTimeMonth" column="SHORE_POWER_TIME_MONTH" jdbcType="DECIMAL"/>
+    <result property="shorePowerTimeYear" column="SHORE_POWER_TIME_YEAR" jdbcType="DECIMAL"/>
+    <result property="shorePowerCountMonth" column="SHORE_POWER_COUNT_MONTH" jdbcType="DECIMAL"/>
+    <result property="shorePowerCountYear" column="SHORE_POWER_COUNT_YEAR" jdbcType="DECIMAL"/>
+    <result property="dataSource" column="DATA_SOURCE" jdbcType="DECIMAL"/>
+    <result property="shipUsageMonth" column="SHIP_USAGE_MONTH" jdbcType="DECIMAL"/>
+  </resultMap>
+  <delete id="deleteByDate">
+    delete
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    where trunc(REPORT_DATE) = to_date(#{toDate}, 'yyyy-mm-dd')
+  </delete>
+  <select id="selectOriginDataMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
+    select STARTTIME chargeStartDate, ENDTIME chargeEndDate, ELECT shorePowerCount
+    from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
+    where (ENDTIME between #{lastDate} and #{thisDate})
+       OR (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND
+           MODIFYTIME between #{lastDate} and #{thisDate})
+  </select>
+  <select id="selectGhDataMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select decode(sum(SHORE_POWER_BOAT_USE_NUMBER), null, 0,
+                  sum(SHORE_POWER_BOAT_USE_NUMBER))                      shipUsage,
+           decode(sum(POWER_CONN_HOURS), null, 0, sum(POWER_CONN_HOURS)) shorePowerTime,
+           decode(sum(ELECTRICITY_CONSUMPTION), null, 0,
+                  sum(ELECTRICITY_CONSUMPTION))                          shorePowerCount
+    from GHJG_PORT_MANAGE.SHORE_POWER_DEVICE_USAGE
+    where trunc(REPORT_DATE) = #{thisDate}
+  </select>
+  <select id="selectOriginDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SHIP_USAGE_YEAR        shipUsage,
+           SHORE_POWER_COUNT_YEAR shorePowerCount,
+           SHORE_POWER_TIME_YEAR  shorePowerTime
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    where trunc(REPORT_DATE) = to_date(#{toDate}, 'yyyy-mm-dd')
+      and DATA_SOURCE = 0
+  </select>
+  <select id="selectGhDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SHIP_USAGE_YEAR        shipUsage,
+           SHORE_POWER_COUNT_YEAR shorePowerCount,
+           SHORE_POWER_TIME_YEAR  shorePowerTime
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    where trunc(REPORT_DATE) = to_date(#{toDate}, 'yyyy-mm-dd')
+      and DATA_SOURCE = 10
+  </select>
+  <select id="getInRiverDataBeforeThisMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SHIP_USAGE_YEAR        shipUsage,
+           SHORE_POWER_COUNT_YEAR shorePowerCount,
+           SHORE_POWER_TIME_YEAR  shorePowerTime
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    WHERE trunc(REPORT_DATE) = to_date(#{toDate}, 'yyyy-mm-dd')
+      AND DATA_SOURCE = 1
+  </select>
+  <select id="getUnderLineMonthData" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select ship_usage shipUsage, power_time_use shorePowerTime, power_elec_use shorePowerCount
+    from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
+    where trunc(REPORT_DATE) = #{toDate}
+      and NAME = '上海市黄浦江码头岸线建设管理有限公司'
+  </select>
+  <select id="getUnderLineYearData" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SUM(ship_usage)     shipUsage,
+           SUM(power_time_use) shorePowerTime,
+           SUM(power_elec_use) shorePowerCount
+    from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
+    where trunc(REPORT_DATE) >= #{yearCountBegin}
+      and trunc(REPORT_DATE) &lt;= #{yearCountEnd}
+      and NAME = '上海市黄浦江码头岸线建设管理有限公司'
+  </select>
+  <select id="selectOriginSelfDataMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select sum(USE_COUNT)       shipUsage,
+           sum(ELE_TIME)        shorePowerCount,
+           sum(USE_ELECTRICITY) shorePowerTime
+    from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse
+    where MODIFY_TIME >= #{lastDate}
+      and MODIFY_TIME &lt;= #{thisDate}
+  </select>
+  <select id="selectOriginSelfDataYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select sum(USE_COUNT)       shipUsage,
+           sum(ELE_TIME)        shorePowerCount,
+           sum(USE_ELECTRICITY) shorePowerTime
+    from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse
+    where MODIFY_TIME >= #{yearCountBegin}
+      and MODIFY_TIME &lt;= #{yearCountEnd}
+  </select>
+  <select id="selectQuarterOrigin" resultType="com.shcd.vo.SpQuarterReportOriginVo">
+    select b.BERTHTYPE, b.CAPACITY, i.STARTTIME, i.ENDTIME, i.ELECT
+    from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO i
+           left join GHJG_PORT_MANAGE.SHORE_POWER_BERTH_INFO_NEW b on i.BERTHID = b.BERTHID
+    where b.BERTHTYPE is not null
+      AND ((i.ENDTIME >= #{startDate}
+      AND i.ENDTIME &lt;= #{endDate})
+      OR (i.ENDTIME >= #{newStartDate} and i.ENDTIME &lt;= #{newStartEnd} AND
+          i.MODIFYTIME >= #{startDate} and i.MODIFYTIME &lt;= #{endDate}))
+  </select>
+  <select id="selectQuarterBlBerth" resultType="com.shcd.vo.SpQuarterReportBlVo">
+    select B.BERTH_TYPE      berthType,
+           b.TONNAGE         capacity,
+           m.USE_COUNT       useCount,
+           m.ELE_TIME        elect,
+           m.USE_ELECTRICITY useElectricity
+    from GHJG_PORT_MANAGE.SHORE_POWER_BLBERTHMONTHUSE m
+           left join
+         GHJG_PORT_MANAGE.SHORE_POWER_CHDEVICEFBO b on m.USER_BERTH_ID = b.ID
+    where m.MODIFY_TIME >= #{startDate}
+      and m.MODIFY_TIME &lt;= #{endDate}
+      AND b.BERTH_TYPE is not null
+  </select>
+  <select id="selectWgqMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
+    select STARTTIME chargeStartDate, ENDTIME chargeEndDate, ELECT shorePowerCount
+    from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
+    where ((ENDTIME between #{lastDate} and #{thisDate}) OR
+           (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND
+            MODIFYTIME between #{lastDate} and #{thisDate}))
+      and ENTERPRISESNAME in ('上海外高桥发电有限责任公司', '上海外高桥第二发电有限责任公司',
+                              '上海外高桥第三发电有限责任公司')
+  </select>
+  <select id="selectWgqYear" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SHIP_USAGE_YEAR        shipUsage,
+           SHORE_POWER_COUNT_YEAR shorePowerCount,
+           SHORE_POWER_TIME_YEAR  shorePowerTime
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    where trunc(REPORT_DATE) = to_date(#{toDate}, 'yyyy-mm-dd')
+      and DATA_SOURCE = 100
+  </select>
+  <select id="getInRiverDataThisMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
+    select STARTTIME chargeStartDate, ENDTIME chargeEndDate, ELECT shorePowerCount
+    from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO i
+           left join GHJG_PORT_MANAGE.SHORE_POWER_PORT_INFO_NEW b on B.PORTID = i.PORTID
+    where ((ENDTIME between #{lastDate} and #{thisDate}) OR
+           (ENDTIME between #{lastCycleStart} and #{lastCycleEnd} AND
+            MODIFYTIME between #{lastDate} and #{thisDate}))
+      and (CONNTYPE = '低压(标准化)' and area >= 2 AND b.AREA &lt;= 12)
+  </select>
+  <select id="getInRiverDataSelfThisMonth" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select sum(USE_COUNT)       shipUsage,
+           sum(ELE_TIME)        shorePowerCount,
+           sum(USE_ELECTRICITY) shorePowerTime
+    from GHJG_PORT_MANAGE.Shore_Power_Blberthmonthuse b
+           left join GHJG_PORT_MANAGE.SHORE_POWER_CHDEVICEFBO c on b.USER_BERTH_ID = c.ID
+    where b.MODIFY_TIME >= #{lastDate}
+      and b.MODIFY_TIME &lt;= #{thisDate}
+      and c.AREA >= 2
+      AND c.AREA &lt;= 12
+  </select>
+  <select id="getUnderLineMonthDataSg" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select ship_usage shipUsage, power_time_use shorePowerTime, power_elec_use shorePowerCount
+    from GHJG_PORT_MANAGE.SP_STATEMENT_UNDERLINE
+    where trunc(REPORT_DATE) = #{toDate}
+      and NAME = '上海国际港务（集团）股份有限公司'
+  </select>
+  <select id="selectThreeMonthsDataTotal" resultType="com.shcd.vo.SpShipUsageMonthQuarterVo">
+    SELECT SUM(T.SHIP_USAGE_MONTH)        shipUsageMonth,
+           MAX(T.SHIP_USAGE_YEAR)         shipUsageYear,
+           SUM(T.SHORE_POWER_TIME_MONTH)  shorePowerCountMonth,
+           MAX(T.SHORE_POWER_TIME_YEAR)   shorePowerCountYear,
+           SUM(T.SHORE_POWER_COUNT_MONTH) shorePowerTimeMonth,
+           MAX(T.SHORE_POWER_COUNT_YEAR)  shorePowerTimeYear
+    FROM GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH T
+    where T.DATA_SOURCE = 99
+      AND T.REPORT_DATE >= #{start}
+      AND T.REPORT_DATE &lt;= #{end}
+  </select>
+  <select id="selectNhAndWgMonth" resultType="com.shcd.vo.SpStatementShipUsageDetail">
+    select STARTTIME chargeStartDate, ENDTIME chargeEndDate, ELECT shorePowerCount
+    from GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO
+    where CONNTYPE = '低压(标准化)'
+      and (ENDTIME > #{lastDate} and ENDTIME &lt; #{thisDate}
+      or
+           (ENDTIME > #{lastCycleStart} and ENDTIME &lt; #{lastDate} and
+            MODIFYTIME > #{lastDate} and MODIFYTIME &lt; #{thisDate}))
+  </select>
+  <select id="selectNhAndWgLastMonthSum" resultType="com.shcd.vo.SpStatementShipUsageMonthVo">
+    select SHIP_USAGE_YEAR        shipUsage,
+           SHORE_POWER_TIME_YEAR  shorePowerTime,
+           SHORE_POWER_COUNT_YEAR shorePowerCount
+    from GHJG_PORT_MANAGE.SP_STATEMENT_SHIP_USAGE_MONTH
+    where trunc(REPORT_DATE) = trunc(#{thisMonth})
+      and DATA_SOURCE = 101
+  </select>
+  <select id="selectPortIdEq1146" resultType="com.shcd.vo.ShorePowerDataVo">
+    SELECT PORT.AREA                                     district,
+           SUM(T.ELECT)                                  electCount,
+           SUM(ROUND((T.ENDTIME - T.STARTTIME) * 24, 2)) electTime,
+           COUNT(T.CONNRECORDSEQ)                        boatUse
+    FROM GHJG_PORT_MANAGE.SHORE_POWER_CONN_RECORD_INFO T
+           LEFT JOIN GHJG_PORT_MANAGE.SHORE_POWER_PORT_INFO_NEW PORT
+                     ON PORT.PORTID = T.PORTID
+    WHERE (T.CONNTYPE = '低压(标准化)'
+      AND PORT.AREA is not null
+      and PORT.AREA != 1
+      AND PORT.PORTID = '1146')
+      AND ((T.ENDTIME &lt;=
+            TO_DATE(#{currentCycleEnd}, 'yyyy-MM-dd HH24:mi:ss')
+      AND T.ENDTIME &gt;=
+          TO_DATE(#{currentCycleStart}, 'yyyy-MM-dd HH24:mi:ss')))
+    GROUP BY PORT.AREA
+  </select>
 </mapper>