基础数据移植进Mysql

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

@@ -68,4 +68,23 @@ public class DayDataController extends BaseController {
             return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
         }
     }
+
+    @ApiOperation("day表定时任务(MySQL库)")
+    @ApiImplicitParam(value = "jobParam",name = "jobParam",required = true)
+    @PostMapping("dataToDay")
+    @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+    public HttpResult<Boolean> dataToDayHandler(@RequestBody LineParam jobParam ){
+        log.info(LocalDateTime.now()+"dataToDayHandler开始执行");
+        String methodDescribe = getMethodDescribe("dataToDayHandler");
+        List<String> indexLists = new ArrayList<> ();
+        if(CollectionUtils.isEmpty (jobParam.getLineIds())){
+            indexLists = lineFeignClient.getLineList().getData();
+        }else{
+            indexLists = jobParam.getLineIds();
+        }
+        String startTime = jobParam.getDataDate()+" "+"00:00:00";
+        String endTime = jobParam.getDataDate()+" "+"23:59:59";
+        dayDataService.dataToDayHandler(indexLists,startTime,endTime);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+    }
 }

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

@@ -19,6 +19,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
+
 /**
  * @author xiaoyao
  * @version 1.0.0
@@ -42,4 +44,15 @@ public class HarmonicGeneralController extends BaseController {
         harmonicGeneralService.generalData(lineParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/generalDataToMysql")
+    @ApiOperation("稳态综合评估日数据计算(MySQL入库)")
+    @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+    public HttpResult<String> generalDataToMysql(@RequestBody @Validated LineParam lineParam){
+        log.info(LocalDateTime.now()+"generalDataToMysql开始执行");
+        String methodDescribe = getMethodDescribe("generalDataToMysql");
+        harmonicGeneralService.generalDataToMysql(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
 }

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

@@ -19,6 +19,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
+
 /**
  * @author xiaoyao
  * @version 1.0.0
@@ -43,4 +45,15 @@ public class HarmonicMetricController extends BaseController {
         harmonicMetricService.metricData(lineParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/metricDataToMysql")
+    @ApiOperation("稳态指标评估日数据计算(MySQL入库)")
+    @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+    public HttpResult<String> metricDataToMysql(@RequestBody @Validated LineParam lineParam){
+        log.info(LocalDateTime.now()+"metricDataToMysql开始执行");
+        String methodDescribe = getMethodDescribe("metricDataToMysql");
+        harmonicMetricService.metricDataToMysql(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
 }

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

@@ -19,6 +19,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
+
 /**
  * @author xiaoyao
  * @version 1.0.0
@@ -43,4 +45,15 @@ public class IntegrityController extends BaseController {
         String out = integrityService.computeDataIntegrity(lineParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, out, methodDescribe);
     }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/dataIntegrity")
+    @ApiOperation("数据完整性统计(MySQL库)")
+    @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+    public HttpResult<String> dataIntegrity(@RequestBody @Validated LineParam lineParam){
+        log.info(LocalDateTime.now()+"dataIntegrity开始执行");
+        String methodDescribe = getMethodDescribe("dataIntegrity");
+        integrityService.dataIntegrity(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, CommonResponseEnum.SUCCESS.getMessage(), methodDescribe);
+    }
 }

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

@@ -19,6 +19,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
+
 /**
  * @author xiaoyao
  * @version 1.0.0
@@ -43,4 +45,15 @@ public class LimitTargetController extends BaseController {
         limitTargetService.getLimitTargetData(lineParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
+
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/limitTargetData")
+    @ApiOperation("生成limit_target表(MySQL入库)")
+    @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+    public HttpResult<String> limitTargetData(@RequestBody @Validated LineParam lineParam){
+        log.info(LocalDateTime.now()+"limitTargetData开始执行");
+        String methodDescribe = getMethodDescribe("limitTargetData");
+        limitTargetService.limitTargetData(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
 }

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

@@ -20,6 +20,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -67,4 +68,23 @@ public class LimitrateController extends BaseController {
             return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.FAIL, false, methodDescribe);
         }
     }
+
+    @ApiOperation("生成limitRate表(MySQL入库)")
+    @ApiImplicitParam(value = "limitRateHanlderParam",name = "limitRateHanlderParam",required = true)
+    @PostMapping("LimitRate")
+    @OperateInfo(info = LogEnum.BUSINESS_MEDIUM)
+    public HttpResult<Boolean> limitRate(@RequestBody LineParam limitRateHanlderParam ){
+        log.info(LocalDateTime.now()+"limitRate开始执行");
+        String methodDescribe = getMethodDescribe("limitRate");
+        List<String> indexLists = new ArrayList<> ();
+        if(CollectionUtils.isEmpty (limitRateHanlderParam.getLineIds ())){
+            indexLists = lineFeignClient.getLineList ( ).getData ( );
+        }else{
+            indexLists = limitRateHanlderParam.getLineIds ();
+        }
+        String startTime = limitRateHanlderParam.getDataDate ()+" "+"00:00:00";
+        String endTime = limitRateHanlderParam.getDataDate ()+" "+"23:59:59";
+        limitRateService.limitRate(indexLists,startTime,endTime);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
+    }
 }

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

@@ -19,6 +19,8 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.time.LocalDateTime;
+
 /**
  * 生成在线率数据表
  *
@@ -46,4 +48,15 @@ public class OnlineRateController  extends BaseController {
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
     }
 
+    @OperateInfo(info = LogEnum.BUSINESS_COMMON)
+    @PostMapping("/onlineRateData")
+    @ApiOperation("生成在线率数据(MySQL入库)")
+    @ApiImplicitParam(name = "lineParam", value = "参数", required = true)
+    public HttpResult<String> onlineRateData(@RequestBody @Validated LineParam lineParam){
+        log.info(LocalDateTime.now()+"onlineRateData开始执行");
+        String methodDescribe = getMethodDescribe("onlineRateData");
+        onlineRateService.onlineRateData(lineParam);
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
+
 }

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatAssesDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatAssesDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatOnlineRateDPO;
+
+public interface RStatAssesDMapper extends MppBaseMapper<RStatAssesDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatComassesDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatAssesDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatComassesDPO;
+
+public interface RStatComassesDMapper extends MppBaseMapper<RStatComassesDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlickerDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+
+public interface RStatDataFlickerDMapper extends MppBaseMapper<RStatDataFlickerDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlucDMapper.java

@@ -0,0 +1,7 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlucDPO;
+
+public interface RStatDataFlucDMapper extends MppBaseMapper<RStatDataFlucDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateIDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateIDPO;
+
+public interface RStatDataHarmRateIDMapper extends MppBaseMapper<RStatDataHarmrateIDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateVDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateVDPO;
+
+public interface RStatDataHarmRateVDMapper extends MppBaseMapper<RStatDataHarmrateVDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicIDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicIDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+
+public interface RStatDataHarmphasicIDMapper extends MppBaseMapper<RStatDataHarmphasicIDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicVDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicVDPO;
+
+public interface RStatDataHarmphasicVDMapper extends MppBaseMapper<RStatDataHarmphasicVDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerPDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerPDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+
+public interface RStatDataHarmpowerPDMapper extends MppBaseMapper<RStatDataHarmpowerPDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerQDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerQDPO;
+
+public interface RStatDataHarmpowerQDMapper extends MppBaseMapper<RStatDataHarmpowerQDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerSDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerSDPO;
+
+public interface RStatDataHarmpowerSDMapper extends MppBaseMapper<RStatDataHarmpowerSDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataIDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataIDPO;
+
+public interface RStatDataIDMapper extends MppBaseMapper<RStatDataIDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmIDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmIDPO;
+
+public interface RStatDataInHarmIDMapper extends MppBaseMapper<RStatDataInharmIDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmVDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmVDPO;
+
+public interface RStatDataInHarmVDMapper extends MppBaseMapper<RStatDataInharmVDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataPltDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataPltDPO;
+
+public interface RStatDataPltDMapper extends MppBaseMapper<RStatDataPltDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataVDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+
+public interface RStatDataVDMapper extends MppBaseMapper<RStatDataVDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatIntegrityDMapper.java

@@ -0,0 +1,7 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatIntegrityDPO;
+
+public interface RStatIntegrityDMapper extends MppBaseMapper<RStatIntegrityDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitRateDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitRateDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitTargetDPO;
+
+public interface RStatLimitRateDMapper extends MppBaseMapper<RStatLimitRateDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitTargetDMapper.java

@@ -0,0 +1,8 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitTargetDPO;
+
+public interface RStatLimitTargetDMapper extends MppBaseMapper<RStatLimitTargetDPO> {
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatOnlineRateDMapper.java

@@ -0,0 +1,9 @@
+package com.njcn.prepare.harmonic.mapper.mysql.day;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatIntegrityDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatOnlineRateDPO;
+
+public interface RStatOnlineRateDMapper extends MppBaseMapper<RStatOnlineRateDPO> {
+}

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatAssesDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatComassesDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataFlickerDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataFlucDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmRateIDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmRateVDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmphasicIDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmphasicVDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerPDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerQDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerSDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataIDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataInHarmIDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataInHarmVDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatIntegrityDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataPltDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatDataVDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatLimitRateDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatLimitTargetDMapper">
+
+</mapper>

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

@@ -0,0 +1,5 @@
+<?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.prepare.harmonic.mapper.mysql.day.RStatOnlineRateDMapper">
+
+</mapper>

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlickerDServiceImpl.java

@@ -0,0 +1,25 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataFlickerDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataFlickerDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataFlickerDServiceImpl extends MppServiceImpl<RStatDataFlickerDMapper, RStatDataFlickerDPO> implements IRStatDataFlickerDService {
+    @Override
+    public void insert(List<RStatDataFlickerDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlucDServiceImpl.java

@@ -0,0 +1,25 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataFlucDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlucDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataFlucDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataFlucDServiceImpl extends MppServiceImpl<RStatDataFlucDMapper, RStatDataFlucDPO> implements IRStatDataFlucDService {
+
+    @Override
+    public void insert(List<RStatDataFlucDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateIDServiceImpl.java

@@ -0,0 +1,30 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmRateIDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerSDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerSDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateIDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmRateIDService;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmpowerSDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmRateIDServiceImpl extends MppServiceImpl<RStatDataHarmRateIDMapper, RStatDataHarmrateIDPO> implements IRStatDataHarmRateIDService {
+
+
+    @Override
+    public void insert(List<RStatDataHarmrateIDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateVDServiceImpl.java

@@ -0,0 +1,28 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmRateVDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateIDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateVDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmRateVDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmRateVDServiceImpl extends MppServiceImpl<RStatDataHarmRateVDMapper, RStatDataHarmrateVDPO> implements IRStatDataHarmRateVDService {
+
+
+    @Override
+    public void insert(List<RStatDataHarmrateVDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicIDServiceImpl.java

@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmphasicIDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicIDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmphasicIDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmphasicIDServiceImpl extends MppServiceImpl<RStatDataHarmphasicIDMapper, RStatDataHarmphasicIDPO> implements IRStatDataHarmphasicIDService {
+
+    @Override
+    public void insert(List<RStatDataHarmphasicIDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicVDServiceImpl.java

@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmphasicVDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicVDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmphasicVDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmphasicVDServiceImpl extends MppServiceImpl<RStatDataHarmphasicVDMapper, RStatDataHarmphasicVDPO> implements IRStatDataHarmphasicVDService {
+
+    @Override
+    public void insert(List<RStatDataHarmphasicVDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerPDServiceImpl.java

@@ -0,0 +1,27 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerPDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerPDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmpowerPDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmpowerPDServiceImpl extends MppServiceImpl<RStatDataHarmpowerPDMapper, RStatDataHarmpowerPDPO> implements IRStatDataHarmpowerPDService {
+
+
+    @Override
+    public void insert(List<RStatDataHarmpowerPDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerQDServiceImpl.java

@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerQDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerQDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmpowerQDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmpowerQDServiceImpl extends MppServiceImpl<RStatDataHarmpowerQDMapper, RStatDataHarmpowerQDPO> implements IRStatDataHarmpowerQDService {
+
+    @Override
+    public void insert(List<RStatDataHarmpowerQDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerSDServiceImpl.java

@@ -0,0 +1,27 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataHarmpowerSDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerSDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataHarmpowerSDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataHarmpowerSDServiceImpl extends MppServiceImpl<RStatDataHarmpowerSDMapper, RStatDataHarmpowerSDPO> implements IRStatDataHarmpowerSDService {
+
+
+    @Override
+    public void insert(List<RStatDataHarmpowerSDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataIDServiceImpl.java

@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataIDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataIDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataIDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataIDServiceImpl extends MppServiceImpl<RStatDataIDMapper, RStatDataIDPO> implements IRStatDataIDService {
+
+    @Override
+    public void insert(List<RStatDataIDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmIDServiceImpl.java

@@ -0,0 +1,30 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataIDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataInHarmIDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateIDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataIDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmIDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataIDService;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataInharmIDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataInharmIDServiceImpl extends MppServiceImpl<RStatDataInHarmIDMapper, RStatDataInharmIDPO> implements IRStatDataInharmIDService {
+
+    @Override
+    public void insert(List<RStatDataInharmIDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmVDServiceImpl.java

@@ -0,0 +1,29 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataInHarmIDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataInHarmVDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmIDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmVDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataInharmIDService;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataInharmVDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataInharmVDServiceImpl extends MppServiceImpl<RStatDataInHarmVDMapper, RStatDataInharmVDPO> implements IRStatDataInharmVDService {
+
+    @Override
+    public void insert(List<RStatDataInharmVDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataPltDServiceImpl.java

@@ -0,0 +1,29 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataFlickerDMapper;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataPltDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataPltDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataFlickerDService;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataPltDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataPltDServiceImpl extends MppServiceImpl<RStatDataPltDMapper, RStatDataPltDPO> implements IRStatDataPltDService {
+
+    @Override
+    public void insert(List<RStatDataPltDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataVDServiceImpl.java

@@ -0,0 +1,26 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatDataVDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatDataVDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatDataVDServiceImpl extends MppServiceImpl<RStatDataVDMapper, RStatDataVDPO> implements IRStatDataVDService {
+
+    @Override
+    public void insert(List<RStatDataVDPO> list) {
+        this.saveOrUpdateBatch(list,50);
+    }
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatLimitRateDServiceImpl.java

@@ -0,0 +1,38 @@
+package com.njcn.prepare.harmonic.service.mysql.Impl.day;
+
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
+import com.njcn.device.pq.pojo.po.AlarmStrategy;
+import com.njcn.energy.pojo.po.EleEvtParm;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatLimitRateDMapper;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitRateDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatLimitRateDService;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 类的介绍：
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/3/24 9:53
+ */
+@Service
+public class RStatLimitRateDServiceImpl extends MppServiceImpl<RStatLimitRateDMapper, RStatLimitRateDPO> implements IRStatLimitRateDService {
+
+    @Override
+    public void insert(List<RStatLimitRateDPO> list) {
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+
+    @Override
+    public List<RStatLimitRateDPO> findList(List<String> list, String time) {
+        LambdaQueryWrapper<RStatLimitRateDPO> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.in(CollUtil.isNotEmpty(list),RStatLimitRateDPO::getLineId,list).eq(RStatLimitRateDPO::getTime,time).eq(RStatLimitRateDPO::getPhasicType,"T");
+        return this.list(lambdaQueryWrapper);
+    }
+}

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

@@ -9,6 +9,8 @@ import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpFlickerReportDPO;
 import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpHarmonicPReportDPO;
 import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpInharmonicIMagReportDPO;
 import com.njcn.prepare.harmonic.pojo.mysql.po.line.RMpPltReportDPO;
+import com.njcn.prepare.harmonic.pojo.po.*;
+import com.njcn.prepare.harmonic.service.mysql.day.*;
 import com.njcn.prepare.harmonic.service.mysql.line.*;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -44,7 +46,7 @@ import java.util.stream.Collectors;
 @Slf4j
 @Component
 @RequiredArgsConstructor
-public class DayDataServiceImpl  implements DayDataService {
+public class DayDataServiceImpl implements DayDataService {
 
     private final RMpHarmonicVRateReportDPOService rMpHarmonicVRateReportDPOService;
     private final RMpHarmonicIMagReportDPOService rMpHarmonicIMagReportDPOService;
@@ -58,6 +60,21 @@ public class DayDataServiceImpl  implements DayDataService {
     private final RMpMeasurePhaseReportDPOService rMpMeasurePhaseReportDPOService;
     private final RMpMeasureReportDPOService rMpMeasureReportDPOService;
 
+    //MySQL
+    private final IRStatDataFlickerDService statDataFlickerDService;
+    private final IRStatDataVDService statDataVDService;
+    private final IRStatDataIDService statDataIDService;
+    private final IRStatDataFlucDService statDataFlucDService;
+    private final IRStatDataHarmphasicIDService statDataHarmphasicIDService;
+    private final IRStatDataHarmphasicVDService statDataHarmphasicVDService;
+    private final IRStatDataHarmpowerPDService statDataHarmpowerPDService;
+    private final IRStatDataHarmpowerQDService statDataHarmpowerQDService;
+    private final IRStatDataHarmpowerSDService statDataHarmpowerSDService;
+    private final IRStatDataHarmRateIDService statDataHarmRateIDService;
+    private final IRStatDataHarmRateVDService statDataHarmRateVDService;
+    private final IRStatDataInharmIDService statDataInharmIDService;
+    private final IRStatDataInharmVDService statDataInharmVDService;
+    private final IRStatDataPltDService statDataPltDService;
 
     private final InfluxDbUtils influxDbUtils;
 
@@ -517,6 +534,232 @@ public class DayDataServiceImpl  implements DayDataService {
 
     }
 
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    @Async("asyncExecutor")
+    public void dataToDayHandler(List<String> indexLists, String startTime, String endTime) {
+        Date time = null;
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        try {
+            time = simpleDateFormat.parse(startTime);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        List<RStatDataFlickerDPO> dataFlickerPOList = new ArrayList<> ();
+        List<RStatDataVDPO> dataVPOList = new ArrayList<> ();
+        List<RStatDataIDPO> dataIPOList = new ArrayList<> ();
+        List<RStatDataFlucDPO> dataFlucPOList = new ArrayList<> ();
+        List<RStatDataHarmphasicIDPO> dataHarmPhasicIPOList = new ArrayList<> ();
+        List<RStatDataHarmphasicVDPO> dataHarmPhasicVPOList = new ArrayList<> ();
+        List<RStatDataHarmpowerPDPO> dataHarmPowerPPOList = new ArrayList<> ();
+        List<RStatDataHarmpowerQDPO> dataHarmPowerQPOList = new ArrayList<> ();
+        List<RStatDataHarmpowerSDPO> dataHarmPowerSPOList = new ArrayList<> ();
+        List<RStatDataHarmrateIDPO> dataHarmRateIPOList = new ArrayList<> ();
+        List<RStatDataHarmrateVDPO> dataHarmRateVPOList = new ArrayList<> ();
+        List<RStatDataInharmIDPO> dataInHarmIPOList  = new ArrayList<> ();
+        List<RStatDataInharmVDPO> dataInHarmVPOList = new ArrayList<> ();
+        List<RStatDataPltDPO> dataPltPOList = new ArrayList<> ();
+
+        for (String lineIndex : indexLists) {
+            /*生成dayV表*/
+            List<DataVPO> dataV = getDataV(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataV)) {
+                for (DataVPO item : dataV) {
+                    RStatDataVDPO po1 = new RStatDataVDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataVPOList.add(po1);
+                }
+            }
+            /*生成dayI表*/
+            List<DataIPO> dataI = getDataI(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataI)) {
+                for (DataIPO item : dataI) {
+                    RStatDataIDPO po1 = new RStatDataIDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataIPOList.add(po1);
+                }
+            }
+            /*生成dayFlicker表*/
+            List<DataFlickerPO> dataFlickerPO = getDataFlicker(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataFlickerPO)) {
+                for (DataFlickerPO item : dataFlickerPO) {
+                    RStatDataFlickerDPO po1 = new RStatDataFlickerDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataFlickerPOList.add(po1);
+                }
+            }
+            /*生成dayFluc表*/
+            List<DataFlucPO> dataFlucPO = getDataFluc(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataFlucPO)) {
+                for (DataFlucPO item : dataFlucPO) {
+                    RStatDataFlucDPO po1 = new RStatDataFlucDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataFlucPOList.add(po1);
+                }
+            }
+            /*生成dayHarmphasicI表*/
+            List<DataHarmPhasicIPO> dataHarmphasicIPO = getDataHarmphasicI(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmphasicIPO)) {
+                for (DataHarmPhasicIPO item : dataHarmphasicIPO) {
+                    RStatDataHarmphasicIDPO po1 = new RStatDataHarmphasicIDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmPhasicIPOList.add(po1);
+                }
+            }
+            /*生成dayHarmphasicV表*/
+            List<DataHarmPhasicVPO> dataHarmphasicVPO = getDataHarmphasicV(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmphasicVPO)) {
+                for (DataHarmPhasicVPO item : dataHarmphasicVPO) {
+                    RStatDataHarmphasicVDPO po1 = new RStatDataHarmphasicVDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmPhasicVPOList.add(po1);
+                }
+            }
+            /*生成dayHarmPowerP表*/
+            List<DataHarmPowerPPO> dataHarmPowerPPO = getDataHarmPowerP(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmPowerPPO)) {
+                for (DataHarmPowerPPO item : dataHarmPowerPPO) {
+                    RStatDataHarmpowerPDPO po1 = new RStatDataHarmpowerPDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmPowerPPOList.add(po1);
+                }
+            }
+            /*生成dayHarmPowerQ表*/
+            List<DataHarmPowerQPO> dataHarmPowerQPO = getDataHarmPowerQ(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmPowerQPO)) {
+                for (DataHarmPowerQPO item : dataHarmPowerQPO) {
+                    RStatDataHarmpowerQDPO po1 = new RStatDataHarmpowerQDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmPowerQPOList.add(po1);
+                }
+            }
+            /*生成dayHarmPowerS表*/
+            List<DataHarmPowerSPO> dataHarmPowers = getDataHarmPowerS(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmPowers)) {
+                for (DataHarmPowerSPO item : dataHarmPowers) {
+                    RStatDataHarmpowerSDPO po1 = new RStatDataHarmpowerSDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmPowerSPOList.add(po1);
+                }
+            }
+            /*生成dayHarmRateI*/
+            List<DataHarmRateIPO> dataHarmRateI = getDataHarmRateI(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmRateI)) {
+                for (DataHarmRateIPO item : dataHarmRateI) {
+                    RStatDataHarmrateIDPO po1 = new RStatDataHarmrateIDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmRateIPOList.add(po1);
+                }
+            }
+            /*生成dayHarmRateV*/
+            List<DataHarmRateVPO> dataHarmRateVPO = getDataHarmRateV(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataHarmRateVPO)) {
+                for (DataHarmRateVPO item : dataHarmRateVPO) {
+                    RStatDataHarmrateVDPO po1 = new RStatDataHarmrateVDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataHarmRateVPOList.add(po1);
+                }
+            }
+            /*生成dayInHarmI*/
+            List<DataInHarmIPO> dataInHarmIPO = getDataInHarmI(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataInHarmIPO)) {
+                for (DataInHarmIPO item : dataInHarmIPO) {
+                    RStatDataInharmIDPO po1 = new RStatDataInharmIDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataInHarmIPOList.add(po1);
+                }
+            }
+            /*生成dayInHarmV*/
+            List<DataInHarmVPO> dataInHarmVPO = getDataInHarmV(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataInHarmVPO)) {
+                for (DataInHarmVPO item : dataInHarmVPO) {
+                    RStatDataInharmVDPO po1 = new RStatDataInharmVDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataInHarmVPOList.add(po1);
+                }
+            }
+            /*生成dayPlt*/
+            List<DataPltPO> dataPlt = getDataPlt(lineIndex, startTime, endTime);
+            if (!CollectionUtils.isEmpty(dataPlt)) {
+                for (DataPltPO item : dataPlt) {
+                    RStatDataPltDPO po1 = new RStatDataPltDPO();
+                    BeanUtils.copyProperties(item,po1);
+                    po1.setTime(time);
+                    po1.setQualityFlag(Integer.parseInt(item.getQualityFlag()));
+                    dataPltPOList.add(po1);
+                }
+            }
+        }
+
+        if (!CollectionUtils.isEmpty(dataVPOList)){
+            statDataVDService.insert(dataVPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataIPOList)){
+            statDataIDService.insert(dataIPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataFlickerPOList)){
+            statDataFlickerDService.insert(dataFlickerPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataFlucPOList)){
+            statDataFlucDService.insert(dataFlucPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmPhasicIPOList)){
+            statDataHarmphasicIDService.insert(dataHarmPhasicIPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmPhasicVPOList)){
+            statDataHarmphasicVDService.insert(dataHarmPhasicVPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmPowerPPOList)){
+            statDataHarmpowerPDService.insert(dataHarmPowerPPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmPowerQPOList)){
+            statDataHarmpowerQDService.insert(dataHarmPowerQPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmPowerSPOList)){
+            statDataHarmpowerSDService.insert(dataHarmPowerSPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmRateIPOList)){
+            statDataHarmRateIDService.insert(dataHarmRateIPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataHarmRateVPOList)){
+            statDataHarmRateVDService.insert(dataHarmRateVPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataInHarmIPOList)){
+            statDataInharmIDService.insert(dataInHarmIPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataInHarmVPOList)){
+            statDataInharmVDService.insert(dataInHarmVPOList);
+        }
+        if (!CollectionUtils.isEmpty(dataPltPOList)){
+            statDataPltDService.insert(dataPltPOList);
+        }
+    }
 
 
     /**
@@ -741,6 +984,7 @@ public class DayDataServiceImpl  implements DayDataService {
         return result;
     }
 
+
     /**
      * 功能描述:获取dataFluc数据
      * @author xy
@@ -3601,7 +3845,4 @@ public class DayDataServiceImpl  implements DayDataService {
 
         }
 
-
-
-
 }

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

@@ -2,12 +2,15 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.device.pq.api.LineFeignClient;
 import com.njcn.device.pq.pojo.po.Overlimit;
 import com.njcn.influxdb.utils.InfluxDbUtils;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatComassesDMapper;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.DataFlickerPO;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.DataVPO;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.pojo.po.RStatComassesDPO;
 import com.njcn.prepare.harmonic.service.mysql.line.HarmonicGeneralService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -34,7 +37,7 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @AllArgsConstructor
-public class HarmonicGeneralServiceImpl implements HarmonicGeneralService {
+public class HarmonicGeneralServiceImpl extends MppServiceImpl<RStatComassesDMapper, RStatComassesDPO> implements HarmonicGeneralService {
 
     private final InfluxDbUtils influxDbUtils;
 
@@ -67,6 +70,62 @@ public class HarmonicGeneralServiceImpl implements HarmonicGeneralService {
         influxDbUtils.batchInsert(influxDbUtils.getDbName(),"", InfluxDB.ConsistencyLevel.ALL, records);
     }
 
+    @Override
+    public void generalDataToMysql(LineParam lineParam) {
+        List<RStatComassesDPO> list = new ArrayList<>();
+        List<String> lineIdOutList;
+        if (CollUtil.isEmpty(lineParam.getLineIds())){
+            List<Overlimit> overLimitList = getAllLineOutData();
+            lineIdOutList = overLimitList.stream().map(Overlimit::getId).collect(Collectors.toList());
+        }else {
+            lineIdOutList = new ArrayList<>(lineParam.getLineIds());
+        }
+        Date dateOut = DateUtil.parse(lineParam.getDataDate());
+        for (String lineId : lineIdOutList){
+            RStatComassesDPO rStatComassesDpo = new RStatComassesDPO();
+            rStatComassesDpo.setTime(dateOut);
+            rStatComassesDpo.setLineId(lineId);
+            Map<String, Object> fields = getGeneralData(lineId,lineParam.getDataDate());
+            rStatComassesDpo.setFreqDev1(Objects.isNull(fields.get("freq_dev1"))?0.0:Double.parseDouble(fields.get("freq_dev1").toString()));
+            rStatComassesDpo.setFreqDev2(Objects.isNull(fields.get("freq_dev2"))?0.0:Double.parseDouble(fields.get("freq_dev2").toString()));
+            rStatComassesDpo.setFreqDev3(Objects.isNull(fields.get("freq_dev3"))?0.0:Double.parseDouble(fields.get("freq_dev3").toString()));
+            rStatComassesDpo.setFreqDev4(Objects.isNull(fields.get("freq_dev4"))?0.0:Double.parseDouble(fields.get("freq_dev4").toString()));
+            rStatComassesDpo.setFreqDev5(Objects.isNull(fields.get("freq_dev5"))?0.0:Double.parseDouble(fields.get("freq_dev5").toString()));
+
+            rStatComassesDpo.setVuDev1(Objects.isNull(fields.get("vu_dev1"))?0.0:Double.parseDouble(fields.get("vu_dev1").toString()));
+            rStatComassesDpo.setVuDev2(Objects.isNull(fields.get("vu_dev2"))?0.0:Double.parseDouble(fields.get("vu_dev2").toString()));
+            rStatComassesDpo.setVuDev3(Objects.isNull(fields.get("vu_dev3"))?0.0:Double.parseDouble(fields.get("vu_dev3").toString()));
+            rStatComassesDpo.setVuDev4(Objects.isNull(fields.get("vu_dev4"))?0.0:Double.parseDouble(fields.get("vu_dev4").toString()));
+            rStatComassesDpo.setVuDev5(Objects.isNull(fields.get("vu_dev5"))?0.0:Double.parseDouble(fields.get("vu_dev5").toString()));
+
+            rStatComassesDpo.setDataPst1(Objects.isNull(fields.get("data_pst1"))?0.0:Double.parseDouble(fields.get("data_pst1").toString()));
+            rStatComassesDpo.setDataPst2(Objects.isNull(fields.get("data_pst2"))?0.0:Double.parseDouble(fields.get("data_pst2").toString()));
+            rStatComassesDpo.setDataPst3(Objects.isNull(fields.get("data_pst3"))?0.0:Double.parseDouble(fields.get("data_pst3").toString()));
+            rStatComassesDpo.setDataPst4(Objects.isNull(fields.get("data_pst4"))?0.0:Double.parseDouble(fields.get("data_pst4").toString()));
+            rStatComassesDpo.setDataPst5(Objects.isNull(fields.get("data_pst5"))?0.0:Double.parseDouble(fields.get("data_pst5").toString()));
+
+            rStatComassesDpo.setVUnbalance1(Objects.isNull(fields.get("v_unbalance1"))?0.0:Double.parseDouble(fields.get("v_unbalance1").toString()));
+            rStatComassesDpo.setVUnbalance2(Objects.isNull(fields.get("v_unbalance2"))?0.0:Double.parseDouble(fields.get("v_unbalance2").toString()));
+            rStatComassesDpo.setVUnbalance3(Objects.isNull(fields.get("v_unbalance3"))?0.0:Double.parseDouble(fields.get("v_unbalance3").toString()));
+            rStatComassesDpo.setVUnbalance4(Objects.isNull(fields.get("v_unbalance4"))?0.0:Double.parseDouble(fields.get("v_unbalance4").toString()));
+            rStatComassesDpo.setVUnbalance5(Objects.isNull(fields.get("v_unbalance5"))?0.0:Double.parseDouble(fields.get("v_unbalance5").toString()));
+
+            rStatComassesDpo.setVThd1(Objects.isNull(fields.get("v_thd1"))?0.0:Double.parseDouble(fields.get("v_thd1").toString()));
+            rStatComassesDpo.setVThd2(Objects.isNull(fields.get("v_thd2"))?0.0:Double.parseDouble(fields.get("v_thd2").toString()));
+            rStatComassesDpo.setVThd3(Objects.isNull(fields.get("v_thd3"))?0.0:Double.parseDouble(fields.get("v_thd3").toString()));
+            rStatComassesDpo.setVThd4(Objects.isNull(fields.get("v_thd4"))?0.0:Double.parseDouble(fields.get("v_thd4").toString()));
+            rStatComassesDpo.setVThd5(Objects.isNull(fields.get("v_thd5"))?0.0:Double.parseDouble(fields.get("v_thd5").toString()));
+
+            rStatComassesDpo.setEvent1(Objects.isNull(fields.get("event1"))?0.0:Double.parseDouble(fields.get("event1").toString()));
+            rStatComassesDpo.setEvent2(Objects.isNull(fields.get("event2"))?0.0:Double.parseDouble(fields.get("event2").toString()));
+            rStatComassesDpo.setEvent3(Objects.isNull(fields.get("event3"))?0.0:Double.parseDouble(fields.get("event3").toString()));
+            rStatComassesDpo.setEvent4(Objects.isNull(fields.get("event4"))?0.0:Double.parseDouble(fields.get("event4").toString()));
+            rStatComassesDpo.setEvent5(Objects.isNull(fields.get("event5"))?0.0:Double.parseDouble(fields.get("event5").toString()));
+            list.add(rStatComassesDpo);
+        }
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+
     private Map<String, Object> getGeneralData(String lineId, String date){
         InfluxDBResultMapper mapper = new InfluxDBResultMapper();
         BigDecimal hundred = BigDecimal.valueOf(100);

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

@@ -2,12 +2,15 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.device.pq.api.LineFeignClient;
 import com.njcn.device.pq.pojo.po.Overlimit;
 import com.njcn.influxdb.utils.InfluxDbUtils;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatAssesDMapper;
 import com.njcn.prepare.harmonic.pojo.param.LineParam;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.DataPltPO;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.DataVPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatAssesDPO;
 import com.njcn.prepare.harmonic.service.mysql.line.HarmonicMetricService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -32,7 +35,7 @@ import java.util.stream.Collectors;
 @Slf4j
 @Service
 @AllArgsConstructor
-public class HarmonicMetricServiceImpl implements HarmonicMetricService {
+public class HarmonicMetricServiceImpl extends MppServiceImpl<RStatAssesDMapper, RStatAssesDPO> implements HarmonicMetricService {
 
     private final InfluxDbUtils influxDbUtils;
 
@@ -62,6 +65,33 @@ public class HarmonicMetricServiceImpl implements HarmonicMetricService {
         influxDbUtils.batchInsert(influxDbUtils.getDbName(),"", InfluxDB.ConsistencyLevel.ALL, records);
     }
 
+    @Override
+    @Async("asyncExecutor")
+    public void metricDataToMysql(LineParam lineParam) {
+        List<RStatAssesDPO> list = new ArrayList<>();
+        List<String> lineIdList;
+        if (CollUtil.isEmpty(lineParam.getLineIds())){
+            List<Overlimit> overLimitList = getAllLineData();
+            lineIdList = overLimitList.stream().map(Overlimit::getId).collect(Collectors.toList());
+        }else {
+            lineIdList = new ArrayList<>(lineParam.getLineIds());
+        }
+        Date dateOut = DateUtil.parse(lineParam.getDataDate());
+        for (String lineId : lineIdList){
+            RStatAssesDPO rStatAssesDpo = new RStatAssesDPO();
+            rStatAssesDpo.setTime(dateOut);
+            rStatAssesDpo.setLineId(lineId);
+            Map<String, Object> fields = getMetricData(lineId,lineParam.getDataDate());
+            rStatAssesDpo.setVuDev(Double.parseDouble(fields.get("vu_dev").toString()));
+            rStatAssesDpo.setFreqDev(Double.parseDouble(fields.get("freq_dev").toString()));
+            rStatAssesDpo.setDataPlt(Double.parseDouble(fields.get("data_plt").toString()));
+            rStatAssesDpo.setVUnbalanceCp95(Double.parseDouble(fields.get("v_unbalance_cp95").toString()));
+            rStatAssesDpo.setVThdCp95(Double.parseDouble(fields.get("v_thd_cp95").toString()));
+            list.add(rStatAssesDpo);
+        }
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+
     private Map<String, Object> getMetricData(String lineId,String date){
         String processParam = " and line_id = '"+lineId+"' and time >= '"+date+" 00:00:00' and time <= '"+date+" 23:59:59' tz('Asia/Shanghai')";
         QueryResult vuDevResult = influxDbUtils.query("select abs(vu_dev) as vu_dev from data_v where phasic_type != 'T' and value_type = 'AVG'"+processParam);

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

@@ -2,12 +2,15 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.device.pq.api.LineFeignClient;
 import com.njcn.device.pq.pojo.po.LineDetail;
 import com.njcn.device.pq.pojo.po.Overlimit;
 import com.njcn.influxdb.utils.InfluxDbUtils;
-import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatIntegrityDMapper;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.DataVPO;
+import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.pojo.po.RStatIntegrityDPO;
 import com.njcn.prepare.harmonic.service.mysql.line.IntegrityService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -18,6 +21,7 @@ import org.influxdb.dto.QueryResult;
 import org.influxdb.impl.InfluxDBResultMapper;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -36,7 +40,7 @@ import static com.njcn.influxdb.param.InfluxDBPublicParam.DAY_MINUTE;
 @Slf4j
 @Service
 @AllArgsConstructor
-public class IntegrityServiceImpl implements IntegrityService {
+public class IntegrityServiceImpl extends MppServiceImpl<RStatIntegrityDMapper, RStatIntegrityDPO> implements IntegrityService{
 
     private final InfluxDbUtils influxDbUtils;
 
@@ -75,11 +79,40 @@ public class IntegrityServiceImpl implements IntegrityService {
         return "成功！";
     }
 
+    @Override
+    @Async("asyncExecutor")
+    public void dataIntegrity(LineParam lineParam) {
+        List<LineDetail> lineDetailList = new ArrayList<>();
+        if (CollUtil.isEmpty(lineParam.getLineIds())){
+            List<Overlimit> overLimitList = getAllLinesLimitData();
+            List<String> lineList = overLimitList.stream().map(Overlimit::getId).collect(Collectors.toList());
+            lineDetailList = lineFeignClient.getLineDetail(lineList).getData();
+        }else {
+            lineDetailList = lineFeignClient.getLineDetail(lineParam.getLineIds()).getData();
+        }
+        Date dateOut = DateUtil.parse(lineParam.getDataDate());
+        List<RStatIntegrityDPO> list = new ArrayList<>();
+        for (LineDetail lineDetail :lineDetailList){
+            int dataCount = getDataCount(lineDetail.getId(),lineParam.getDataDate());
+            RStatIntegrityDPO integrityDpo = new RStatIntegrityDPO();
+            integrityDpo.setTime(dateOut);
+            integrityDpo.setLineId(lineDetail.getId());
+            integrityDpo.setDueTime(DAY_MINUTE/lineDetail.getTimeInterval());
+            integrityDpo.setRealTime(dataCount);
+            list.add(integrityDpo);
+        }
+        this.saveOrUpdateBatchByMultiId(list,500);
+    }
+
     private int getDataCount(String lineId,String date){
         QueryResult sqlResult = influxDbUtils.query("SELECT * FROM data_v WHERE time >= '" + date + " 00:00:00' and time <= '" + date + " 23:59:59' and line_id = '" + lineId + "' and phasic_type = 'T' tz('Asia/Shanghai')");
         InfluxDBResultMapper resultMapper = new InfluxDBResultMapper();
         List<DataVPO> list = resultMapper.toPOJO(sqlResult, DataVPO.class);
-        return list.size();
+        if (CollectionUtils.isEmpty(list)){
+            return 0;
+        } else {
+            return list.size();
+        }
     }
 
     private List<Overlimit> getAllLinesLimitData() {

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

@@ -10,6 +10,8 @@ import com.njcn.influxdb.param.InfluxDBPublicParam;
 import com.njcn.influxdb.utils.InfluxDbUtils;
 import com.njcn.prepare.harmonic.mapper.mysql.line.LimitRatePOMapper;
 import com.njcn.prepare.harmonic.pojo.influxdb.po.*;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitRateDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatLimitRateDService;
 import lombok.AllArgsConstructor;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
@@ -24,6 +26,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.util.CollectionUtils;
 
+import java.text.ParseException;
 import java.text.SimpleDateFormat;
 import java.time.Instant;
 import java.util.*;
@@ -44,15 +47,11 @@ import java.util.stream.Collectors;
 @AllArgsConstructor
 public class LimitRateService  extends MppServiceImpl<LimitRatePOMapper, LimitRatePO> {
 
-
     private final InfluxDbUtils influxDbUtils;
 
     private final LineFeignClient lineFeignClient;
 
-
-    private final LimitRatePOMapper limitRatePOMapper;
-
-
+    private final IRStatLimitRateDService statLimitRateDService;
 
     /**
      * @Description: 处理 limitrate批处理逻辑
@@ -66,15 +65,12 @@ public class LimitRateService  extends MppServiceImpl<LimitRatePOMapper, LimitRa
     )
     @SneakyThrows
     @Async("asyncExecutor")
-    public List<LimitRatePO> limitRateJobHandler(List<String> lineList, String startTime, String endTime)  {
+    public void limitRateJobHandler(List<String> lineList, String startTime, String endTime)  {
         List<LimitRatePO> limitRates = new ArrayList<> ();
         List<LimitRate> limitRateList = new ArrayList<> ();
-
         Instant instant = new SimpleDateFormat ("yyyy-MM-dd").parse (startTime).toInstant ( );
         Long time= instant.toEpochMilli();
-
         for (int i = 0; i <lineList.size () ; i++) {
-
             String lineIndex =lineList.get (i);
             Overlimit overlimit = lineFeignClient.getOverLimitData(lineIndex).getData ();
             if(!Optional.ofNullable (overlimit).isPresent ()){
@@ -98,9 +94,7 @@ public class LimitRateService  extends MppServiceImpl<LimitRatePOMapper, LimitRa
             List<LimitRatePO> collect = result.stream ( ).map (t -> {
                 LimitRatePO limitRatePO = new LimitRatePO ( );
                 NjcnBeanUtil.copyPropertiesIgnoreCase (t,limitRatePO);
-
                 limitRatePO.setTime (instant);
-
                 return limitRatePO;
             }).collect (Collectors.toList ( ));
             limitRates.addAll (collect);
@@ -111,9 +105,54 @@ public class LimitRateService  extends MppServiceImpl<LimitRatePOMapper, LimitRa
             /*插入mysql*/
             this.saveOrUpdateBatchByMultiId (limitRates,50);
         }
+    }
 
-        return limitRates;
+    @Transactional(rollbackFor = {Exception.class})
+    @SneakyThrows
+    @Async("asyncExecutor")
+    public void limitRate(List<String> lineList, String startTime, String endTime)  {
+        List<RStatLimitRateDPO> list = new ArrayList<>();
+        List<LimitRate> limitRateList = new ArrayList<> ();
+        Date date = null;
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        try {
+            date = simpleDateFormat.parse(startTime);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        for (int i = 0; i <lineList.size () ; i++) {
+            String lineIndex =lineList.get (i);
+            Overlimit overlimit = lineFeignClient.getOverLimitData(lineIndex).getData ();
+            if(!Optional.ofNullable (overlimit).isPresent ()){
+                continue;
+            }
+            List<DataVPO> map1 = getAllTime(lineIndex,startTime,endTime);
+            List<DataPltPO> map2 = getFlickerAllTime(lineIndex,startTime,endTime);
+            List<DataHarmRateVPO> map3 = getDataHarmRateV(lineIndex,startTime,endTime);
+            List<DataIPO> map4 = getDataI(lineIndex,startTime,endTime);
+            List<DataInHarmVPO> map5 = getDataInHarmV(lineIndex,startTime,endTime);
+            List<DataVPO> map6 = getDataV(lineIndex,startTime,endTime);
+            List<DataVPO> map7 = getDataVUnbalance(lineIndex,startTime,endTime);
+            List<DataIPO> map8 = getDataINeg(lineIndex,startTime,endTime);
+            List<DataVPO> map9 = getDataVFreq(lineIndex,startTime,endTime);
+            List<DataVPO> map10 = getDataVDev(lineIndex,startTime,endTime);
+            List<DataPltPO> map11 = getDataPlt(lineIndex,startTime,endTime);
 
+            List<LimitRate> result = getData(overlimit,map1,map2,map3,map4,map5,map6,map7,map8,map9,map10,map11);
+            limitRateList.addAll (result);
+            Date finalDate = date;
+            List<RStatLimitRateDPO> collect = result.stream ( ).map (t -> {
+                RStatLimitRateDPO po = new RStatLimitRateDPO ( );
+                NjcnBeanUtil.copyPropertiesIgnoreCase (t,po);
+                po.setTime(finalDate);
+                return po;
+            }).collect (Collectors.toList ( ));
+            list.addAll(collect);
+        }
+        if (!CollectionUtils.isEmpty(limitRateList)){
+            /*插入mysql*/
+            statLimitRateDService.insert(list);
+        }
     }
 
 

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

@@ -3,9 +3,15 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.harmonic.pojo.po.LimitRate;
 import com.njcn.influxdb.utils.InfluxDbUtils;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatLimitTargetDMapper;
 import com.njcn.prepare.harmonic.pojo.param.LineParam;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitRateDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitTargetDPO;
+import com.njcn.prepare.harmonic.service.mysql.day.IRStatLimitRateDService;
 import com.njcn.prepare.harmonic.service.mysql.line.LimitTargetService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -16,6 +22,7 @@ import org.influxdb.dto.QueryResult;
 import org.influxdb.impl.InfluxDBResultMapper;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -30,10 +37,12 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Service
 @AllArgsConstructor
-public class LimitTargetServiceImpl implements LimitTargetService {
+public class LimitTargetServiceImpl extends MppServiceImpl<RStatLimitTargetDMapper, RStatLimitTargetDPO> implements LimitTargetService {
 
     private final InfluxDbUtils influxDbUtils;
 
+    private final IRStatLimitRateDService statLimitRateDService;
+
     @Override
     @Async("asyncExecutor")
     public void getLimitTargetData(LineParam lineParam) {
@@ -53,6 +62,30 @@ public class LimitTargetServiceImpl implements LimitTargetService {
         influxDbUtils.batchInsert(influxDbUtils.getDbName(),"", InfluxDB.ConsistencyLevel.ALL, records);
     }
 
+    @Override
+    @Async("asyncExecutor")
+    public void limitTargetData(LineParam lineParam) {
+        List<RStatLimitTargetDPO> list = new ArrayList<>();
+        Date dateOut = DateUtil.parse(lineParam.getDataDate());
+        List<RStatLimitRateDPO> limitRateData = new ArrayList<>();
+        if (CollUtil.isEmpty(lineParam.getLineIds())){
+            limitRateData = getLimitRateDataFromMysql(null,lineParam.getDataDate());
+        } else {
+            limitRateData = getLimitRateDataFromMysql(lineParam.getLineIds(),lineParam.getDataDate());
+        }
+        if (!CollectionUtils.isEmpty(limitRateData)){
+            for (RStatLimitRateDPO limitRate : limitRateData){
+                RStatLimitTargetDPO limitTarget = new RStatLimitTargetDPO();
+                limitTarget.setTime(dateOut);
+                limitTarget.setLineId(limitRate.getLineId());
+                limitTarget.setPhasicType(limitRate.getPhasicType());
+                chanelData(limitRate,limitTarget);
+                list.add(limitTarget);
+            }
+        }
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+
     private List<LimitRate> getLimitRateData(String lineId,String date){
         StringBuilder sql = new StringBuilder();
         sql.append("SELECT * FROM limit_rate WHERE time >= '").append(date).append(" 00:00:00' and time <= '")
@@ -66,6 +99,11 @@ public class LimitTargetServiceImpl implements LimitTargetService {
         return resultMapper.toPOJO(sqlResult, LimitRate.class);
     }
 
+    private List<RStatLimitRateDPO> getLimitRateDataFromMysql(List<String> lineList, String date){
+        return statLimitRateDService.findList(lineList,date);
+    }
+
+
     private List<String> processOutData(List<LimitRate> limitRateData,Date dateOut){
         List<String> records = new ArrayList<>();
         for (LimitRate limitRate : limitRateData){
@@ -162,4 +200,83 @@ public class LimitTargetServiceImpl implements LimitTargetService {
         fields.put("inuharm_16_overtime",(limitRate.getInuHarm16OverTime()>1)?1:0);
         return fields;
     }
+
+    private void chanelData(RStatLimitRateDPO limitRate, RStatLimitTargetDPO limitTarget){
+        limitTarget.setAllTime((limitRate.getAllTime()>1)?1:0);
+        limitTarget.setFlickerAllTime((limitRate.getFlickerAllTime()>1)?1:0);
+        limitTarget.setFreqDevOvertime((limitRate.getFreqDevOvertime()>1)?1:0);
+        limitTarget.setVoltageDevOvertime((limitRate.getVoltageDevOvertime()>1)?1:0);
+        limitTarget.setUbalanceOvertime((limitRate.getUbalanceOvertime()>1)?1:0);
+        limitTarget.setFlickerOvertime((limitRate.getFlickerOvertime()>1)?1:0);
+        limitTarget.setUaberranceOvertime((limitRate.getUaberranceOvertime()>1)?1:0);
+        limitTarget.setINegOvertime((limitRate.getINegOvertime()>1)?1:0);
+
+        limitTarget.setUharm2Overtime((limitRate.getUharm2Overtime()>1)?1:0);
+        limitTarget.setUharm2Overtime((limitRate.getUharm2Overtime()>1)?1:0);
+        limitTarget.setUharm3Overtime((limitRate.getUharm3Overtime()>1)?1:0);
+        limitTarget.setUharm4Overtime((limitRate.getUharm4Overtime()>1)?1:0);
+        limitTarget.setUharm5Overtime((limitRate.getUharm5Overtime()>1)?1:0);
+        limitTarget.setUharm6Overtime((limitRate.getUharm6Overtime()>1)?1:0);
+        limitTarget.setUharm7Overtime((limitRate.getUharm7Overtime()>1)?1:0);
+        limitTarget.setUharm8Overtime((limitRate.getUharm8Overtime()>1)?1:0);
+        limitTarget.setUharm9Overtime((limitRate.getUharm9Overtime()>1)?1:0);
+        limitTarget.setUharm10Overtime((limitRate.getUharm10Overtime()>1)?1:0);
+        limitTarget.setUharm11Overtime((limitRate.getUharm11Overtime()>1)?1:0);
+        limitTarget.setUharm12Overtime((limitRate.getUharm12Overtime()>1)?1:0);
+        limitTarget.setUharm13Overtime((limitRate.getUharm13Overtime()>1)?1:0);
+        limitTarget.setUharm14Overtime((limitRate.getUharm14Overtime()>1)?1:0);
+        limitTarget.setUharm15Overtime((limitRate.getUharm15Overtime()>1)?1:0);
+        limitTarget.setUharm16Overtime((limitRate.getUharm16Overtime()>1)?1:0);
+        limitTarget.setUharm17Overtime((limitRate.getUharm17Overtime()>1)?1:0);
+        limitTarget.setUharm18Overtime((limitRate.getUharm18Overtime()>1)?1:0);
+        limitTarget.setUharm19Overtime((limitRate.getUharm19Overtime()>1)?1:0);
+        limitTarget.setUharm20Overtime((limitRate.getUharm20Overtime()>1)?1:0);
+        limitTarget.setUharm21Overtime((limitRate.getUharm21Overtime()>1)?1:0);
+        limitTarget.setUharm22Overtime((limitRate.getUharm22Overtime()>1)?1:0);
+        limitTarget.setUharm23Overtime((limitRate.getUharm23Overtime()>1)?1:0);
+        limitTarget.setUharm24Overtime((limitRate.getUharm24Overtime()>1)?1:0);
+        limitTarget.setUharm25Overtime((limitRate.getUharm25Overtime()>1)?1:0);
+
+        limitTarget.setIharm2Overtime((limitRate.getIharm2Overtime()>1)?1:0);
+        limitTarget.setIharm3Overtime((limitRate.getIharm3Overtime()>1)?1:0);
+        limitTarget.setIharm4Overtime((limitRate.getIharm4Overtime()>1)?1:0);
+        limitTarget.setIharm5Overtime((limitRate.getIharm5Overtime()>1)?1:0);
+        limitTarget.setIharm6Overtime((limitRate.getIharm6Overtime()>1)?1:0);
+        limitTarget.setIharm7Overtime((limitRate.getIharm7Overtime()>1)?1:0);
+        limitTarget.setIharm8Overtime((limitRate.getIharm8Overtime()>1)?1:0);
+        limitTarget.setIharm9Overtime((limitRate.getIharm9Overtime()>1)?1:0);
+        limitTarget.setIharm10Overtime((limitRate.getIharm10Overtime()>1)?1:0);
+        limitTarget.setIharm11Overtime((limitRate.getIharm11Overtime()>1)?1:0);
+        limitTarget.setIharm12Overtime((limitRate.getIharm12Overtime()>1)?1:0);
+        limitTarget.setIharm13Overtime((limitRate.getIharm13Overtime()>1)?1:0);
+        limitTarget.setIharm14Overtime((limitRate.getIharm14Overtime()>1)?1:0);
+        limitTarget.setIharm15Overtime((limitRate.getIharm15Overtime()>1)?1:0);
+        limitTarget.setIharm16Overtime((limitRate.getIharm16Overtime()>1)?1:0);
+        limitTarget.setIharm17Overtime((limitRate.getIharm17Overtime()>1)?1:0);
+        limitTarget.setIharm18Overtime((limitRate.getIharm18Overtime()>1)?1:0);
+        limitTarget.setIharm19Overtime((limitRate.getIharm19Overtime()>1)?1:0);
+        limitTarget.setIharm20Overtime((limitRate.getIharm20Overtime()>1)?1:0);
+        limitTarget.setIharm21Overtime((limitRate.getIharm21Overtime()>1)?1:0);
+        limitTarget.setIharm22Overtime((limitRate.getIharm22Overtime()>1)?1:0);
+        limitTarget.setIharm23Overtime((limitRate.getIharm23Overtime()>1)?1:0);
+        limitTarget.setIharm24Overtime((limitRate.getIharm24Overtime()>1)?1:0);
+        limitTarget.setIharm25Overtime((limitRate.getIharm25Overtime()>1)?1:0);
+
+        limitTarget.setInuharm1Overtime((limitRate.getInuharm1Overtime()>1)?1:0);
+        limitTarget.setInuharm2Overtime((limitRate.getInuharm2Overtime()>1)?1:0);
+        limitTarget.setInuharm3Overtime((limitRate.getInuharm3Overtime()>1)?1:0);
+        limitTarget.setInuharm4Overtime((limitRate.getInuharm4Overtime()>1)?1:0);
+        limitTarget.setInuharm5Overtime((limitRate.getInuharm5Overtime()>1)?1:0);
+        limitTarget.setInuharm6Overtime((limitRate.getInuharm6Overtime()>1)?1:0);
+        limitTarget.setInuharm7Overtime((limitRate.getInuharm7Overtime()>1)?1:0);
+        limitTarget.setInuharm8Overtime((limitRate.getInuharm8Overtime()>1)?1:0);
+        limitTarget.setInuharm9Overtime((limitRate.getInuharm9Overtime()>1)?1:0);
+        limitTarget.setInuharm10Overtime((limitRate.getInuharm10Overtime()>1)?1:0);
+        limitTarget.setInuharm11Overtime((limitRate.getInuharm11Overtime()>1)?1:0);
+        limitTarget.setInuharm12Overtime((limitRate.getInuharm12Overtime()>1)?1:0);
+        limitTarget.setInuharm13Overtime((limitRate.getInuharm13Overtime()>1)?1:0);
+        limitTarget.setInuharm14Overtime((limitRate.getInuharm14Overtime()>1)?1:0);
+        limitTarget.setInuharm15Overtime((limitRate.getInuharm15Overtime()>1)?1:0);
+        limitTarget.setInuharm16Overtime((limitRate.getInuharm16Overtime()>1)?1:0);
+    }
 }

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

@@ -3,13 +3,17 @@ package com.njcn.prepare.harmonic.service.mysql.Impl.line;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.github.jeffreyning.mybatisplus.service.MppServiceImpl;
 import com.njcn.device.pq.api.LineFeignClient;
 import com.njcn.energy.pojo.constant.ModelState;
 import com.njcn.influxdb.utils.InfluxDbUtils;
+import com.njcn.prepare.harmonic.mapper.mysql.day.RStatOnlineRateDMapper;
 import com.njcn.prepare.harmonic.pojo.dto.OnLineRateDTO;
 import com.njcn.prepare.harmonic.pojo.param.LineParam;
 
 import com.njcn.prepare.harmonic.pojo.influxdb.po.PqsCommunicatePO;
+import com.njcn.prepare.harmonic.pojo.po.RStatOnlineRateDPO;
 import com.njcn.prepare.harmonic.service.mysql.line.OnlineRateService;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -38,7 +42,7 @@ import static com.njcn.influxdb.param.InfluxDBPublicParam.DAY_MINUTE;
 @Slf4j
 @Service
 @AllArgsConstructor
-public class OnlineRateServiceImpl implements OnlineRateService {
+public class OnlineRateServiceImpl extends MppServiceImpl<RStatOnlineRateDMapper, RStatOnlineRateDPO> implements OnlineRateService {
 
     private final InfluxDbUtils influxDbUtils;
 
@@ -75,6 +79,33 @@ public class OnlineRateServiceImpl implements OnlineRateService {
         influxDbUtils.batchInsert(influxDbUtils.getDbName(),"", InfluxDB.ConsistencyLevel.ALL, records);
     }
 
+    @Override
+    @Async("asyncExecutor")
+    public void onlineRateData(LineParam lineParam) {
+        List<String> lineIdList = lineParam.getLineIds();
+        if (CollUtil.isEmpty(lineParam.getLineIds())){
+            lineIdList = lineFeignClient.getDeviceList().getData();
+        }
+        List<PqsCommunicatePO> outCommunicateData = new ArrayList<>();
+        for (String lineId : lineIdList){
+            List<PqsCommunicatePO> communicateData = getCommunicateData(lineId);
+            outCommunicateData.addAll(communicateData);
+        }
+        List<RStatOnlineRateDPO> list = new ArrayList<>();
+        Date dateOut = DateUtil.parse(lineParam.getDataDate());
+        for (PqsCommunicatePO pqsCommunicate : outCommunicateData){
+            RStatOnlineRateDPO onlineRateDpo = new RStatOnlineRateDPO();
+            Date newDate = Date.from(pqsCommunicate.getTime());
+            OnLineRateDTO onLineRate = onLineMinute(newDate,dateOut,pqsCommunicate.getType(),pqsCommunicate.getDevId(),lineParam.getDataDate());
+            onlineRateDpo.setTime(dateOut);
+            onlineRateDpo.setDevId(pqsCommunicate.getDevId());
+            onlineRateDpo.setOnlineMin(onLineRate.getOnLineMinute());
+            onlineRateDpo.setOfflineMin(onLineRate.getOffLineMinute());
+            list.add(onlineRateDpo);
+        }
+        this.saveOrUpdateBatchByMultiId(list,50);
+    }
+
     /**
      * 获取pqs_communicate数据
      */

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataFlickerDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+
+import java.util.List;
+
+public interface IRStatDataFlickerDService {
+
+    void insert(List<RStatDataFlickerDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataFlucDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlucDPO;
+
+import java.util.List;
+
+public interface IRStatDataFlucDService {
+
+    void insert(List<RStatDataFlucDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmRateIDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateIDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmRateIDService {
+
+    void insert(List<RStatDataHarmrateIDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmRateVDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmrateVDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmRateVDService {
+
+    void insert(List<RStatDataHarmrateVDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmphasicIDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicIDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmphasicIDService {
+
+    void insert(List<RStatDataHarmphasicIDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmphasicVDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmphasicVDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmphasicVDService {
+
+    void insert(List<RStatDataHarmphasicVDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmpowerPDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerPDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmpowerPDService {
+
+    void insert(List<RStatDataHarmpowerPDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmpowerQDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerQDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmpowerQDService {
+
+    void insert(List<RStatDataHarmpowerQDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataHarmpowerSDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataHarmpowerSDPO;
+
+import java.util.List;
+
+public interface IRStatDataHarmpowerSDService {
+
+    void insert(List<RStatDataHarmpowerSDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataIDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataIDPO;
+
+import java.util.List;
+
+public interface IRStatDataIDService {
+
+    void insert(List<RStatDataIDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataInharmIDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmIDPO;
+
+import java.util.List;
+
+public interface IRStatDataInharmIDService {
+
+    void insert(List<RStatDataInharmIDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataInharmVDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataInharmVDPO;
+
+import java.util.List;
+
+public interface IRStatDataInharmVDService {
+
+    void insert(List<RStatDataInharmVDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataPltDService.java

@@ -0,0 +1,10 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataPltDPO;
+
+import java.util.List;
+
+public interface IRStatDataPltDService {
+
+    void insert(List<RStatDataPltDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatDataVDService.java

@@ -0,0 +1,11 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataFlickerDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+
+import java.util.List;
+
+public interface IRStatDataVDService {
+
+    void insert(List<RStatDataVDPO> list);
+}

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/day/IRStatLimitRateDService.java

@@ -0,0 +1,13 @@
+package com.njcn.prepare.harmonic.service.mysql.day;
+
+import com.njcn.prepare.harmonic.pojo.po.RStatDataVDPO;
+import com.njcn.prepare.harmonic.pojo.po.RStatLimitRateDPO;
+
+import java.util.List;
+
+public interface IRStatLimitRateDService {
+
+    void insert(List<RStatLimitRateDPO> list);
+
+    List<RStatLimitRateDPO> findList(List<String> list, String time);
+}

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

@@ -19,4 +19,12 @@ public interface DayDataService {
     * @Date: 2022/10/24 
     */ 
     void dayDataJobHandler(List<String> indexLists, String startTime, String endTime);
+
+    /**
+     * 处理day表，并将数据入MySQL库中
+     * @param indexLists
+     * @param startTime
+     * @param endTime
+     */
+    void dataToDayHandler(List<String> indexLists, String startTime, String endTime);
 }

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

@@ -10,4 +10,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam;
 public interface HarmonicGeneralService {
 
     void generalData(LineParam lineParam);
+
+    void generalDataToMysql(LineParam lineParam);
 }

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

@@ -10,4 +10,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam;
 public interface HarmonicMetricService {
 
     void metricData(LineParam lineParam);
+
+    void metricDataToMysql(LineParam lineParam);
 }

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

@@ -10,4 +10,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam;
 public interface IntegrityService {
 
     String computeDataIntegrity(LineParam lineParam);
+
+    void dataIntegrity(LineParam lineParam);
 }

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

@@ -10,4 +10,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam;
 public interface LimitTargetService {
 
     void getLimitTargetData(LineParam lineParam);
+
+    void limitTargetData(LineParam lineParam);
 }

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

@@ -10,4 +10,6 @@ import com.njcn.prepare.harmonic.pojo.param.LineParam;
 public interface OnlineRateService {
 
     void getOnlineRateData(LineParam lineParam);
+
+    void onlineRateData(LineParam lineParam);
 }