河北技术监督，国网上送接口bug修改

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/SupvPlanMapper.java

@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.njcn.process.pojo.param.SupvPlanParam;
 import com.njcn.process.pojo.po.SupvPlan;
 import com.njcn.process.pojo.vo.SupvPlanVO;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
@@ -17,5 +18,6 @@ import com.njcn.process.pojo.vo.SupvPlanVO;
  */
 public interface SupvPlanMapper extends BaseMapper<SupvPlan> {
 
-
+    Boolean updateId(@Param("isUploadHead")Integer isUploadHead,
+                     @Param("id") String id);
 }

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/SupvProblemMapper.java

@@ -3,6 +3,7 @@ package com.njcn.process.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.njcn.process.pojo.po.SupvProblem;
+import org.apache.ibatis.annotations.Param;
 
 /**
  * <p>
@@ -14,4 +15,6 @@ import com.njcn.process.pojo.po.SupvProblem;
  */
 public interface SupvProblemMapper extends BaseMapper<SupvProblem> {
 
+    Boolean updateId(@Param("isUploadHead")Integer isUploadHead,
+                     @Param("id") String id);
 }

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/SupvReportMMapper.java

@@ -25,4 +25,6 @@ public interface SupvReportMMapper extends MppBaseMapper<SupvReportM> {
 
 
     List<ProcessPublicDTO> statisticQueReport(@Param("startTime")LocalDateTime startTime, @Param("endTime")LocalDateTime endTime, @Param("statisticType")String statisticType,@Param("rectificationStatus")String rectificationStatus,@Param("objType")String objType);
+    Boolean updateId(@Param("isUploadHead")Integer isUploadHead,
+                     @Param("id") String id);
 }

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/mapping/SupvPlanMapper.xml

@@ -3,4 +3,7 @@
 <mapper namespace="com.njcn.process.mapper.SupvPlanMapper">
 
 
+    <update id="updateId">
+        update supv_plan set is_upload_head= #{isUploadHead} where plan_Id=#{id}
+    </update>
 </mapper>

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/mapping/SupvProblemMapper.xml

@@ -2,4 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.njcn.process.mapper.SupvProblemMapper">
 
+    <update id="updateId">
+        update supv_problem set is_upload_head= #{isUploadHead} where problem_Id=#{id}
+    </update>
 </mapper>

pqs-process/process-boot/src/main/java/com/njcn/process/mapper/mapping/SupvReportMMapper.xml

@@ -1,6 +1,9 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.njcn.process.mapper.SupvReportMMapper">
+    <update id="updateId">
+        update supv_report_m set is_upload_head= #{isUploadHead} where month_Report_Id=#{id}
+    </update>
 
     <select id="statisticPlanReport" resultType="ProcessPublicDTO">
         select count(1) value,supv_Org_Id id from supv_plan

pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/SupvPushGwServiceImpl.java

@@ -217,10 +217,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
             String status = mapData.get("status").toString();
             if ("000000".equals(status)) {
                 for (SupvPlan supvPlan : supvPlanList) {
-                    SupvPlan supvPlanPO = new SupvPlan();
+                    supvPlanMapper.updateId(1,supvPlan.getPlanId());
-                    supvPlanPO.setPlanId(supvPlan.getPlanId());
-                    supvPlanPO.setIsUploadHead(1);
-                    supvPlanMapper.updateById(supvPlanPO);
                 }
                 String result = mapData.get("result").toString();
                 Map mapCount = JSON.parseObject(result, Map.class);
@@ -299,10 +296,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
             String status = map.get("status").toString();
             if ("000000".equals(status)) {
                 for (SupvProblem supvProblem : supvProblemList) {
-                    SupvProblem supvProblemPO = new SupvProblem();
+                    supvProblemMapper.updateId(1,supvProblem.getProblemId());
-                    supvProblemPO.setProblemId(supvProblem.getProblemId());
-                    supvProblemPO.setIsUploadHead(1);
-                    supvProblemMapper.updateById(supvProblemPO);
                 }
                 String result = map.get("result").toString();
                 Map mapCount = JSON.parseObject(result, Map.class);
@@ -385,10 +379,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
             String status = map.get("status").toString();
             if ("000000".equals(status)) {
                 for (SupvReportM supvReportM : supvReportMList) {
-                    SupvReportM supvReportMPO = new SupvReportM();
+                    supvReportMMapper.updateId(1,supvReportM.getMonthReportId());
-                    supvReportMPO.setMonthReportId(supvReportM.getMonthReportId());
-                    supvReportMPO.setIsUploadHead(1);
-                    supvReportMMapper.updateById(supvReportMPO);
                 }
                 String result = map.get("result").toString();
                 Map mapCount = JSON.parseObject(result, Map.class);
@@ -439,8 +430,7 @@ public class SupvPushGwServiceImpl implements SupvPushGwService {
             String status = map.get("status").toString();
             if ("000000".equals(status)) {
                 for (SupvPlan supvPlan : supvPlanList) {
-                    supvPlan.setIsUploadHead(2);
+                    supvPlanMapper.updateId(2,supvPlan.getPlanId());
-                    supvPlanMapper.updateById(supvPlan);
                 }
                 String result = map.get("result").toString();
                 Map mapCount = JSON.parseObject(result, Map.class);

pqs-process/process-boot/src/main/java/com/njcn/process/service/impl/SupvReportMServiceImpl.java

@@ -135,11 +135,11 @@ public class SupvReportMServiceImpl extends MppServiceImpl<SupvReportMMapper, Su
         List<ProcessPublicDTO> processPublicDTOMingGanY = this.baseMapper.statisticPlanReport(firstYearDay,endYearDay,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),null,null);
         List<ProcessPublicDTO> processPublicDTOMingGanAll = this.baseMapper.statisticPlanReport(firstYearDay,endTime,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),null,Stream.of("02","03","04").collect(Collectors.toList()));
 
-        //换流站问题总数量
+        //敏感用户问题总数量
         List<ProcessPublicDTO> processPublicDTOQesMingGanM = this.baseMapper.statisticQueReport(firstDay,endTime,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),null,null);
         List<ProcessPublicDTO> processPublicDTOQesMingGanAll = this.baseMapper.statisticQueReport(firstYearDay,endTime,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),null,null);
 
-        //换流站问题已整改数量
+        //敏感用户问题已整改数量
         List<ProcessPublicDTO> processPublicDTOQesMingGanYesM = this.baseMapper.statisticQueReport(firstDay,endTime,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),"01",null);
         List<ProcessPublicDTO> processPublicDTOQesMingGanYesAll = this.baseMapper.statisticQueReport(firstYearDay,endTime,mapStatistic.get(DicDataEnum.POWER_QUALITY.getCode()).getId(),"01",null);