监测点稳态指标超标明细算法提交

pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/RMpPartHarmonicDetailD.java

@@ -93,7 +93,7 @@ public class RMpPartHarmonicDetailD implements Serializable {
     /**
      * 谐波电压超标次数
      */
-    @TableField(value = "v_times")
+    @TableField(value = "v_times", exist = false)
     private Integer vTimes;
 
     /**
@@ -105,14 +105,14 @@ public class RMpPartHarmonicDetailD implements Serializable {
     /**
      * 谐波电流超标次数
      */
-    @TableField(value = "i_times")
+    @TableField(value = "i_times", exist = false)
     private Integer iTimes;
 
     /**
      * 2次谐波电压含有率是否超标(0:否 1:是)
      */
     @TableField(value = "is_v_2")
-    private Integer isV2;
+        private Integer isV2;
 
     /**
      * 3次谐波电压含有率是否超标(0:否 1:是)
@@ -711,17 +711,22 @@ public class RMpPartHarmonicDetailD implements Serializable {
     /**
      * 三相电压不平衡度超标次数
      */
-    @TableField(value = "unbalance_times")
+    @TableField(value = "unbalance_times", exist = false)
     private Integer unbalanceTimes;
 
     /**
      * 负序电流超标次数
      */
-    @TableField(value = "i_neg_times")
+    @TableField(value = "i_neg_times", exist = false)
     private Integer iNegTimes;
 
     @TableField(exist = false)
     private static final long serialVersionUID = 1L;
 
+    @TableField(exist = false)
+    private Integer isFlicker;
+
+    @TableField(exist = false)
+    private Integer isInuharm;
 
 }

pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/po/RMpSurplusHarmonicDetailD.java

@@ -51,7 +51,7 @@ public class RMpSurplusHarmonicDetailD implements Serializable {
     /**
      * 间谐波电压超标次数
      */
-    @TableField(value = "inuharm_times")
+    @TableField(value = "inuharm_times", exist = false)
     private Integer inuharmTimes;
 
     /**

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/HarmonicOverLimitController.java

@@ -0,0 +1,64 @@
+package com.njcn.prepare.harmonic.controller.line;
+
+import com.njcn.common.pojo.annotation.OperateInfo;
+import com.njcn.common.pojo.constant.OperateType;
+import com.njcn.common.pojo.enums.common.LogEnum;
+import com.njcn.common.pojo.enums.response.CommonResponseEnum;
+import com.njcn.common.pojo.response.HttpResult;
+import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.IRMpPartHarmonicDetailDService;
+import com.njcn.prepare.harmonic.service.mysql.line.IRMpSurplusHarmonicDetailDService;
+import com.njcn.web.controller.BaseController;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiOperation;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/4/20 16:05
+ */
+@Validated
+@Slf4j
+@RestController
+@RequestMapping("/harmonicOverLimit")
+@Api(tags = "监测点稳态指标统计")
+@AllArgsConstructor
+public class HarmonicOverLimitController extends BaseController {
+
+    private final IRMpPartHarmonicDetailDService mpPartHarmonicDetailDService;
+
+    private final IRMpSurplusHarmonicDetailDService mpSurplusHarmonicDetailDService;
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+    @PostMapping("/harmonicDetailDay1")
+    @ApiOperation("监测点稳态指标超标明细日表1")
+    @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+    public HttpResult<Boolean> harmonicDetailDay1(@RequestBody @Validated LineParam lineParam) {
+        String methodDescribe = getMethodDescribe("harmonicDetailDay1");
+        mpPartHarmonicDetailDService.insertHarmonicDetailDayOne(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
+    @PostMapping("/harmonicDetailDay2")
+    @ApiOperation("监测点稳态指标超标明细日表2")
+    @ApiImplicitParam(name = "lineParam", value = "算法通用查询参数", required = true)
+    public HttpResult<Boolean> harmonicDetailDay2(@RequestBody @Validated LineParam lineParam) {
+        String methodDescribe = getMethodDescribe("harmonicDetailDay2");
+        mpSurplusHarmonicDetailDService.insertHarmonicDetailDayTwo(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
+
+
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/SteadyIndexExceedController.java

@@ -35,6 +35,7 @@ public class SteadyIndexExceedController extends BaseController {
 
     private final SteadyIndexExceedService steadyIndexExceedService;
 
+    @Deprecated
     @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
     @PostMapping("/isValueExceedID")
     @ApiOperation("日统计I、II、III类监测点是否超标限值")
@@ -50,6 +51,7 @@ public class SteadyIndexExceedController extends BaseController {
 
     }
 
+    @Deprecated
     @OperateInfo(info = LogEnum.BUSINESS_COMMON,operateType = OperateType.ADD)
     @PostMapping("/isValueExceedIID")
     @ApiOperation("日统计I、II类监测点是否超标限值")

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpPartHarmonicDetailDMapper.java

@@ -1,11 +1,12 @@
 package com.njcn.prepare.harmonic.mapper.mysql.line;
 
-import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
 import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD;
 import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailM;
 import org.apache.ibatis.annotations.Param;
 
 import java.time.LocalDate;
+import java.util.List;
 
 /**
  * RMpPartHarmonicDetailDMapper
@@ -14,7 +15,14 @@ import java.time.LocalDate;
  * @version 1.0.0
  * @createTime 2022/12/5 - 15:21
  */
-public interface RMpPartHarmonicDetailDMapper extends BaseMapper<RMpPartHarmonicDetailD> {
+public interface RMpPartHarmonicDetailDMapper extends MppBaseMapper<RMpPartHarmonicDetailD> {
 
     RMpPartHarmonicDetailM getPartSumByData(@Param("lineId") String lineId, @Param("startTime") LocalDate startTime, @Param("endTime") LocalDate endTime);
+
+    /**
+     * 获取监测点稳态指标超标明细日表1数据
+     * @param time 时间
+     * @return 集合
+     */
+    List<RMpPartHarmonicDetailD> getHarmonicDetailDayOne(String time);
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/RMpSurplusHarmonicDetailDMapper.java

@@ -1,11 +1,14 @@
 package com.njcn.prepare.harmonic.mapper.mysql.line;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD;
 import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailD;
 import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailM;
 import org.apache.ibatis.annotations.Param;
 
 import java.time.LocalDate;
+import java.util.List;
 
 /**
  * RMpSurplusHarmonicDetailDMapper
@@ -14,7 +17,14 @@ import java.time.LocalDate;
  * @version 1.0.0
  * @createTime 2022/12/8 - 15:21
  */
-public interface RMpSurplusHarmonicDetailDMapper extends BaseMapper<RMpSurplusHarmonicDetailD> {
+public interface RMpSurplusHarmonicDetailDMapper extends MppBaseMapper<RMpSurplusHarmonicDetailD> {
 
     RMpSurplusHarmonicDetailM getSurplusSumByData(@Param("lineId") String lineId, @Param("startTime") LocalDate startTime, @Param("endTime") LocalDate endTime);
+
+    /**
+     * 获取监测点稳态指标超标明细日表2数据
+     * @param time 时间
+     * @return 集合
+     */
+    List<RMpSurplusHarmonicDetailD> getHarmonicDetailDayTwo(String time);
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpPartHarmonicDetailDMapper.xml

@@ -73,4 +73,342 @@
         measurement_point_id
     </select>
 
+    <select id="getHarmonicDetailDayOne" resultType="com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD">
+        select
+        t0.time_id dataDate,
+        t0.my_index measurementPointId,
+        case
+        when t0.freq_dev_overtime>0 then 1
+        else 0
+        end isFreq,
+        t0.freq_dev_overtime freqTimes,
+        t0.voltage_dev_overtime vDevTimes,
+        case
+        when (t0.voltage_dev_overtime>0) then 1
+        else 0
+        end isVDev,
+        case
+        when t0.uaberrance_overtime>0 then 1
+        else 0
+        end isVThd,
+        case
+        when t0.ubalance_overtime>0 then 1
+        else 0
+        end isUnbalance,
+        case
+        when t0.i_neg_overtime>0 then 1
+        else 0
+        end isINeg,
+        case
+        when t0.uharm_2_overtime>0 then 1
+        else 0
+        end isV2,
+        case
+        when t0.uharm_3_overtime>0 then 1
+        else 0
+        end isV3,
+        case
+        when t0.uharm_4_overtime>0 then 1
+        else 0
+        end isV4,
+        case
+        when t0.uharm_5_overtime>0 then 1
+        else 0
+        end isV5,
+        case
+        when t0.uharm_6_overtime>0 then 1
+        else 0
+        end isV6,
+        case
+        when t0.uharm_7_overtime>0 then 1
+        else 0
+        end isV7,
+        case
+        when t0.uharm_8_overtime>0 then 1
+        else 0
+        end isV8,
+        case
+        when t0.uharm_9_overtime>0 then 1
+        else 0
+        end isV9,
+        case
+        when t0.uharm_10_overtime>0 then 1
+        else 0
+        end isV10,
+        case
+        when t0.uharm_11_overtime>0 then 1
+        else 0
+        end isV11,
+        case
+        when t0.uharm_12_overtime>0 then 1
+        else 0
+        end isV12,
+        case
+        when t0.uharm_13_overtime>0 then 1
+        else 0
+        end isV13,
+        case
+        when t0.uharm_14_overtime>0 then 1
+        else 0
+        end isV14,
+        case
+        when t0.uharm_15_overtime>0 then 1
+        else 0
+        end isV15,
+        case
+        when t0.uharm_16_overtime>0 then 1
+        else 0
+        end isV16,
+        case
+        when t0.uharm_17_overtime>0 then 1
+        else 0
+        end isV17,
+        case
+        when t0.uharm_18_overtime>0 then 1
+        else 0
+        end isV18,
+        case
+        when t0.uharm_19_overtime>0 then 1
+        else 0
+        end isV19,
+        case
+        when t0.uharm_20_overtime>0 then 1
+        else 0
+        end isV20,
+        case
+        when t0.uharm_21_overtime>0 then 1
+        else 0
+        end isV21,
+        case
+        when t0.uharm_22_overtime>0 then 1
+        else 0
+        end isV22,
+        case
+        when t0.uharm_23_overtime>0 then 1
+        else 0
+        end isV23,
+        case
+        when t0.uharm_24_overtime>0 then 1
+        else 0
+        end isV24,
+        case
+        when t0.uharm_25_overtime>0 then 1
+        else 0
+        end isV25,
+        case
+        when t0.iharm_2_overtime>0 then 1
+        else 0
+        end isI2,
+        case
+        when t0.iharm_3_overtime>0 then 1
+        else 0
+        end isI3,
+        case
+        when t0.iharm_4_overtime>0 then 1
+        else 0
+        end isI4,
+        case
+        when t0.iharm_5_overtime>0 then 1
+        else 0
+        end isI5,
+        case
+        when t0.iharm_6_overtime>0 then 1
+        else 0
+        end isI6,
+        case
+        when t0.iharm_7_overtime>0 then 1
+        else 0
+        end isI7,
+        case
+        when t0.iharm_8_overtime>0 then 1
+        else 0
+        end isI8,
+        case
+        when t0.iharm_9_overtime>0 then 1
+        else 0
+        end isI9,
+        case
+        when t0.iharm_10_overtime>0 then 1
+        else 0
+        end isI10,
+        case
+        when t0.iharm_11_overtime>0 then 1
+        else 0
+        end isI11,
+        case
+        when t0.iharm_12_overtime>0 then 1
+        else 0
+        end isI12,
+        case
+        when t0.iharm_13_overtime>0 then 1
+        else 0
+        end isI13,
+        case
+        when t0.iharm_14_overtime>0 then 1
+        else 0
+        end isI14,
+        case
+        when t0.iharm_15_overtime>0 then 1
+        else 0
+        end isI15,
+        case
+        when t0.iharm_16_overtime>0 then 1
+        else 0
+        end isI16,
+        case
+        when t0.iharm_17_overtime>0 then 1
+        else 0
+        end isI17,
+        case
+        when t0.iharm_18_overtime>0 then 1
+        else 0
+        end isI18,
+        case
+        when t0.iharm_19_overtime>0 then 1
+        else 0
+        end isI19,
+        case
+        when t0.iharm_20_overtime>0 then 1
+        else 0
+        end isI20,
+        case
+        when t0.iharm_21_overtime>0 then 1
+        else 0
+        end isI21,
+        case
+        when t0.iharm_22_overtime>0 then 1
+        else 0
+        end isI22,
+        case
+        when t0.iharm_23_overtime>0 then 1
+        else 0
+        end isI23,
+        case
+        when t0.iharm_24_overtime>0 then 1
+        else 0
+        end isI24,
+        case
+        when t0.iharm_25_overtime>0 then 1
+        else 0
+        end isI25,
+        case
+        when ifnull(t1.up, 0)>0 then 1
+        else 0
+        end isVDevUp,
+        case
+        when ifnull(t1.down, 0)>0 then 1
+        else 0
+        end isVDevLow,
+        case
+        when (
+        t0.uaberrance_overtime>0
+        or t0.uharm_2_overtime>0
+        or t0.uharm_3_overtime>0
+        or t0.uharm_4_overtime>0
+        or t0.uharm_5_overtime>0
+        or t0.uharm_6_overtime>0
+        or t0.uharm_7_overtime>0
+        or t0.uharm_8_overtime>0
+        or t0.uharm_9_overtime>0
+        or t0.uharm_10_overtime>0
+        or t0.uharm_11_overtime>0
+        or t0.uharm_12_overtime>0
+        or t0.uharm_13_overtime>0
+        or t0.uharm_14_overtime>0
+        or t0.uharm_15_overtime>0
+        or t0.uharm_16_overtime>0
+        or t0.uharm_17_overtime>0
+        or t0.uharm_18_overtime>0
+        or t0.uharm_19_overtime>0
+        or t0.uharm_20_overtime>0
+        or t0.uharm_21_overtime>0
+        or t0.uharm_22_overtime>0
+        or t0.uharm_23_overtime>0
+        or t0.uharm_24_overtime>0
+        or t0.uharm_25_overtime>0
+        ) then 1
+        else 0
+        end isV,
+        case
+        when (
+        t0.iharm_2_overtime>0
+        or t0.iharm_3_overtime>0
+        or t0.iharm_4_overtime>0
+        or t0.iharm_5_overtime>0
+        or t0.iharm_6_overtime>0
+        or t0.iharm_7_overtime>0
+        or t0.iharm_8_overtime>0
+        or t0.iharm_9_overtime>0
+        or t0.iharm_10_overtime>0
+        or t0.iharm_11_overtime>0
+        or t0.iharm_12_overtime>0
+        or t0.iharm_13_overtime>0
+        or t0.iharm_14_overtime>0
+        or t0.iharm_15_overtime>0
+        or t0.iharm_16_overtime>0
+        or t0.iharm_17_overtime>0
+        or t0.iharm_18_overtime>0
+        or t0.iharm_19_overtime>0
+        or t0.iharm_20_overtime>0
+        or t0.iharm_21_overtime>0
+        or t0.iharm_22_overtime>0
+        or t0.iharm_23_overtime>0
+        or t0.iharm_24_overtime>0
+        or t0.iharm_25_overtime>0
+        ) then 1
+        else 0
+        end isI,
+        case
+        when t0.flicker_overtime>0 then 1
+        else 0
+        end isFlicker,
+        case
+        when (
+        t0.inuharm_1_overtime>0
+        or t0.inuharm_2_overtime>0
+        or t0.inuharm_3_overtime>0
+        or t0.inuharm_4_overtime>0
+        or t0.inuharm_5_overtime>0
+        or t0.inuharm_6_overtime>0
+        or t0.inuharm_7_overtime>0
+        or t0.inuharm_8_overtime>0
+        or t0.inuharm_9_overtime>0
+        or t0.inuharm_10_overtime>0
+        or t0.inuharm_11_overtime>0
+        or t0.inuharm_12_overtime>0
+        or t0.inuharm_13_overtime>0
+        or t0.inuharm_14_overtime>0
+        or t0.inuharm_15_overtime>0
+        or t0.inuharm_16_overtime>0
+        ) then 1
+        else 0
+        end isInuharm
+        from
+        r_stat_limit_rate_d t0
+        left join
+        (
+        select
+        t0.`time` time,
+        t0.line_id lineId,
+        sum(case when t0.vl_dev&gt;=0 and t0.vl_dev>t1.Voltage_Dev then 1 else 0 end) up,
+        sum(case when t0.vl_dev&lt;0 and abs(t0.vl_dev)>abs(t1.Voltage_Dev) then 1 else 0 end) down
+        from
+        r_stat_data_v_d t0
+        left join pq_overlimit t1 on
+        t0.line_id = t1.Id
+        where
+        value_type = 'MAX'
+        and phasic_type in ('A', 'B', 'C')
+        and `time` = #{time}
+        group by
+        t0.`time`,
+        t0.line_id
+        ) t1 on
+        t0.time_id = t1.time
+        and t0.my_index = t1.lineId
+        where
+        t0.phasic_type = 'T'
+        and t0.time_id = #{time}
+    </select>
+
 </mapper>

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/RMpSurplusHarmonicDetailDMapper.xml

@@ -33,4 +33,105 @@
         measurement_point_id
     </select>
 
+    <select id="getHarmonicDetailDayTwo" resultType="com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailD">
+        select
+        t0.time_id dataDate,
+        t0.my_index measurementPointId,
+        case
+            when t0.flicker_overtime>0 then 1
+            else 0
+        end isFlicker,
+        t0.flicker_overtime flickerTimes,
+        case
+            when (
+            t0.inuharm_1_overtime>0
+            or t0.inuharm_2_overtime>0
+            or t0.inuharm_3_overtime>0
+            or t0.inuharm_4_overtime>0
+            or t0.inuharm_5_overtime>0
+            or t0.inuharm_6_overtime>0
+            or t0.inuharm_7_overtime>0
+            or t0.inuharm_8_overtime>0
+            or t0.inuharm_9_overtime>0
+            or t0.inuharm_10_overtime>0
+            or t0.inuharm_11_overtime>0
+            or t0.inuharm_12_overtime>0
+            or t0.inuharm_13_overtime>0
+            or t0.inuharm_14_overtime>0
+            or t0.inuharm_15_overtime>0
+            or t0.inuharm_16_overtime>0
+        ) then 1
+            else 0
+        end isInuharm,
+        case
+            when t0.inuharm_1_overtime>0 then 1
+            else 0
+        end isInuharm1,
+        case
+            when t0.inuharm_2_overtime>0 then 1
+            else 0
+        end isInuharm2,
+        case
+            when t0.inuharm_3_overtime>0 then 1
+            else 0
+        end isInuharm3,
+        case
+            when t0.inuharm_4_overtime>0 then 1
+            else 0
+        end isInuharm4,
+        case
+            when t0.inuharm_5_overtime>0 then 1
+            else 0
+        end isInuharm5,
+        case
+            when t0.inuharm_6_overtime>0 then 1
+            else 0
+        end isInuharm6,
+        case
+            when t0.inuharm_7_overtime>0 then 1
+            else 0
+        end isInuharm7,
+        case
+            when t0.inuharm_8_overtime>0 then 1
+            else 0
+        end isInuharm8,
+        case
+            when t0.inuharm_9_overtime>0 then 1
+            else 0
+        end isInuharm9,
+        case
+            when t0.inuharm_10_overtime>0 then 1
+            else 0
+        end isInuharm10,
+        case
+            when t0.inuharm_11_overtime>0 then 1
+            else 0
+        end isInuharm11,
+        case
+            when t0.inuharm_12_overtime>0 then 1
+            else 0
+        end isInuharm12,
+        case
+            when t0.inuharm_13_overtime>0 then 1
+            else 0
+        end isInuharm13,
+        case
+            when t0.inuharm_14_overtime>0 then 1
+            else 0
+        end isInuharm14,
+        case
+            when t0.inuharm_15_overtime>0 then 1
+            else 0
+        end isInuharm15,
+        case
+            when t0.inuharm_16_overtime>0 then 1
+            else 0
+        end isInuharm16
+    from
+        r_stat_limit_rate_d t0
+    where
+        t0.phasic_type = 'T'
+        and t0.time_id = #{time}
+    </select>
+
 </mapper>

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpPartHarmonicDetailDServiceImpl.java

@@ -0,0 +1,41 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.line;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD;
+import com.njcn.prepare.harmonic.mapper.mysql.line.RMpPartHarmonicDetailDMapper;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.IRMpPartHarmonicDetailDService;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/4/23 15:08
+ */
+@Service
+public class RMpPartHarmonicDetailDServiceImpl extends MppServiceImpl<RMpPartHarmonicDetailDMapper, RMpPartHarmonicDetailD> implements IRMpPartHarmonicDetailDService {
+
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    @Async("asyncExecutor")
+    public void insertHarmonicDetailDayOne(LineParam lineParam) {
+        List<RMpPartHarmonicDetailD> list = this.baseMapper.getHarmonicDetailDayOne(lineParam.getDataDate());
+        if (!CollectionUtils.isEmpty(list)){
+            list.forEach(item->{
+                if (item.getIsFreq()>0 || item.getIsVDev()>0 || item.getIsV()>0 || item.getIsI()>0 || item.getIsUnbalance()>0 || item.getIsINeg()>0 || item.getIsFlicker()>0 || item.getIsInuharm()>0){
+                    item.setIsHarmonic(1);
+                } else {
+                    item.setIsHarmonic(0);
+                }
+            });
+            this.saveOrUpdateBatchByMultiId(list,50);
+        }
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/RMpSurplusHarmonicDetailDServiceImpl.java

@@ -0,0 +1,37 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.line;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.harmonic.pojo.po.RMpPartHarmonicDetailD;
+import com.njcn.harmonic.pojo.po.RMpSurplusHarmonicDetailD;
+import com.njcn.prepare.harmonic.mapper.mysql.line.RMpPartHarmonicDetailDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.line.RMpSurplusHarmonicDetailDMapper;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.service.mysql.line.IRMpPartHarmonicDetailDService;
+import com.njcn.prepare.harmonic.service.mysql.line.IRMpSurplusHarmonicDetailDService;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/4/23 15:08
+ */
+@Service
+public class RMpSurplusHarmonicDetailDServiceImpl extends MppServiceImpl<RMpSurplusHarmonicDetailDMapper, RMpSurplusHarmonicDetailD> implements IRMpSurplusHarmonicDetailDService {
+
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    @Async("asyncExecutor")
+    public void insertHarmonicDetailDayTwo(LineParam lineParam) {
+        List<RMpSurplusHarmonicDetailD> list = this.baseMapper.getHarmonicDetailDayTwo(lineParam.getDataDate());
+        if (!CollectionUtils.isEmpty(list)){
+            this.saveOrUpdateBatchByMultiId(list,50);
+        }
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/IRMpPartHarmonicDetailDService.java

@@ -0,0 +1,17 @@
+package com.njcn.prepare.harmonic.service.mysql.line;
+
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+
+/**
+ * @author xy
+ */
+public interface IRMpPartHarmonicDetailDService {
+
+    /**
+     * 计算监测点稳态指标超标明细日表1数据
+     * @param lineParam
+     */
+    void insertHarmonicDetailDayOne(LineParam lineParam);
+
+
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/line/IRMpSurplusHarmonicDetailDService.java

@@ -0,0 +1,16 @@
+package com.njcn.prepare.harmonic.service.mysql.line;
+
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+
+/**
+ * @author xy
+ */
+public interface IRMpSurplusHarmonicDetailDService {
+
+    /**
+     * 计算监测点稳态指标超标明细日表2数据
+     * @param lineParam
+     */
+    void insertHarmonicDetailDayTwo(LineParam lineParam);
+
+}