onlineRateData(@RequestBody @Validated LineParam lineParam){
+ log.info(LocalDateTime.now()+"onlineRateData开始执行");
+ String methodDescribe = getMethodDescribe("onlineRateData");
+ onlineRateService.onlineRateData(lineParam);
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+ }
+
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/ThsSuperviseController.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/ThsSuperviseController.java
index eca9597e9..028d8df0e 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/ThsSuperviseController.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/line/ThsSuperviseController.java
@@ -1,25 +1,27 @@
package com.njcn.prepare.harmonic.controller.line;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.response.HttpResult;
import com.njcn.common.utils.HttpResultUtil;
+import com.njcn.prepare.harmonic.pojo.dto.SuperviseDto;
import com.njcn.prepare.harmonic.pojo.param.SuperviseParam;
-import com.njcn.prepare.harmonic.pojo.po.ThsOverRunLog;
+import com.njcn.prepare.harmonic.pojo.vo.SuperviceRunLogVo;
+import com.njcn.prepare.harmonic.pojo.vo.SuperviseVo;
import com.njcn.prepare.harmonic.service.mysql.line.ThsOverRunLogService;
import com.njcn.prepare.harmonic.service.mysql.line.ThsSuperviseService;
import com.njcn.web.controller.BaseController;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
+import org.springframework.web.multipart.MultipartFile;
-import java.util.List;
+import javax.servlet.http.HttpServletResponse;
/**
*
@@ -41,18 +43,55 @@ public class ThsSuperviseController extends BaseController {
@ApiOperation("预警/告警事务生成")
@ApiImplicitParam(name = "superviseParam", value = "创建技术监督参数", required = true)
@PostMapping("/initSupervise")
- public HttpResult> initSupervise(@RequestBody @Validated SuperviseParam superviseParam) {
+ public HttpResult initSupervise(@RequestBody @Validated SuperviseParam superviseParam) {
return thsSuperviseService.initSupervise(superviseParam);
}
@ApiOperation("保存技术监督监测点")
- @ApiImplicitParam(name = "superviseParam", value = "技术监督监测点参数", required = true)
+ @ApiImplicitParam(name = "superviceRunLogVo", value = "技术监督监测点参数", required = true)
@PostMapping("/saveOverRunLog")
- public HttpResult saveOverRunLog(@RequestBody SuperviseParam superviseParam) {
- thsOverRunLogService.saveOverRunLog(superviseParam);
- String methodDescribe = getMethodDescribe("superviseParam");
+ public HttpResult saveOverRunLog(@RequestBody SuperviceRunLogVo superviceRunLogVo) {
+ thsSuperviseService.saveOverRunLog(superviceRunLogVo);
+ String methodDescribe = getMethodDescribe("saveOverRunLog");
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
}
+ @ApiOperation("技术监督详情")
+ @ApiImplicitParam(name = "supIndex", value = "技术监督id", required = true)
+ @PostMapping("/superviseDetail")
+ public HttpResult superviseDetail(@RequestParam String supIndex) {
+ SuperviceRunLogVo result = thsOverRunLogService.superviseDetail(supIndex);
+ String methodDescribe = getMethodDescribe("superviseDetail");
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
+ }
+
+ @ApiOperation("删除技术监督")
+ @ApiImplicitParam(name = "superviseDto", value = "删除技术监督请求体", required = true)
+ @PostMapping("/deleteSupervise")
+ public HttpResult deleteSupervise(@RequestBody SuperviseDto superviseDto) {
+ return thsSuperviseService.deleteSupervise(superviseDto);
+ }
+
+ @ApiOperation("查询技术监督列表")
+ @ApiImplicitParam(name = "superviseDto", value = "查询技术监督列表参数", required = true)
+ @PostMapping("/querySuperviseList")
+ public HttpResult> querySuperviseList(@RequestBody SuperviseDto superviseDto) {
+ Page pageResult = thsSuperviseService.querySuperviseList(superviseDto);
+ String methodDescribe = getMethodDescribe("querySuperviseList");
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, pageResult, methodDescribe);
+ }
+
+ @ApiOperation("上传技术监督单据")
+ @PostMapping("/uploadSuperviseTicket")
+ public HttpResult uploadSuperviseTicket(@ApiParam(value = "文件", required = true)
+ @RequestPart(value = "files") MultipartFile[] files,
+ @ApiParam(name = "越限监测点记录id", value = "id", required = true) @RequestParam("id") String id,
+ @ApiParam(name = "上传单据类型", value = "ticketType", required = true) @RequestParam("ticketType") String ticketType,
+ HttpServletResponse response) {
+ thsSuperviseService.uploadSuperviseTicket(id, ticketType, files, response);
+ String methodDescribe = getMethodDescribe("uploadSuperviseTicket");
+ return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+
+ }
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatAssesDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatAssesDMapper.java
new file mode 100644
index 000000000..ec1a0bfd3
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatComassesDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatComassesDMapper.java
new file mode 100644
index 000000000..1398f7528
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlickerDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlickerDMapper.java
new file mode 100644
index 000000000..f63c4c414
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlucDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataFlucDMapper.java
new file mode 100644
index 000000000..e821700c2
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateIDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateIDMapper.java
new file mode 100644
index 000000000..e41637a89
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateVDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmRateVDMapper.java
new file mode 100644
index 000000000..4182e08d2
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicIDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicIDMapper.java
new file mode 100644
index 000000000..7cbef0a01
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicVDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmphasicVDMapper.java
new file mode 100644
index 000000000..4d32a03a6
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerPDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerPDMapper.java
new file mode 100644
index 000000000..9130b0590
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerQDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerQDMapper.java
new file mode 100644
index 000000000..071c3fd1e
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerSDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataHarmpowerSDMapper.java
new file mode 100644
index 000000000..7c2bd74a6
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataIDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataIDMapper.java
new file mode 100644
index 000000000..22c52e606
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmIDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmIDMapper.java
new file mode 100644
index 000000000..36e8bfe1f
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmVDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataInHarmVDMapper.java
new file mode 100644
index 000000000..0c85c0f3a
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataPltDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataPltDMapper.java
new file mode 100644
index 000000000..7b9fe3d07
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataVDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatDataVDMapper.java
new file mode 100644
index 000000000..c22e63f40
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatIntegrityDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatIntegrityDMapper.java
new file mode 100644
index 000000000..7a2cf4925
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitRateDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitRateDMapper.java
new file mode 100644
index 000000000..b792d3368
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitTargetDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatLimitTargetDMapper.java
new file mode 100644
index 000000000..f3b2dc632
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatOnlineRateDMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/RStatOnlineRateDMapper.java
new file mode 100644
index 000000000..332327679
--- /dev/null
+++ b/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 {
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatAssesDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatAssesDMapper.xml
new file mode 100644
index 000000000..31b3157d7
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatAssesDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatComassesDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatComassesDMapper.xml
new file mode 100644
index 000000000..fa64b2af1
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatComassesDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlickerDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlickerDMapper.xml
new file mode 100644
index 000000000..d94c381c7
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlickerDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlucDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlucDMapper.xml
new file mode 100644
index 000000000..afaecb69e
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataFlucDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateIDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateIDMapper.xml
new file mode 100644
index 000000000..f0d7b005c
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateIDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateVDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateVDMapper.xml
new file mode 100644
index 000000000..0f0ad1cf8
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmRateVDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicIDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicIDMapper.xml
new file mode 100644
index 000000000..4f17a53ec
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicIDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicVDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicVDMapper.xml
new file mode 100644
index 000000000..5dccf09a1
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmphasicVDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerPDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerPDMapper.xml
new file mode 100644
index 000000000..ddb4dd60b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerPDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerQDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerQDMapper.xml
new file mode 100644
index 000000000..c30b9f948
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerQDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerSDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerSDMapper.xml
new file mode 100644
index 000000000..e5cc30a3b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataHarmpowerSDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIDMapper.xml
new file mode 100644
index 000000000..0d9cb540b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmIDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmIDMapper.xml
new file mode 100644
index 000000000..2729d193b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmIDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmVDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmVDMapper.xml
new file mode 100644
index 000000000..528a8f677
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataInHarmVDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIntegrityDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIntegrityDMapper.xml
new file mode 100644
index 000000000..74738c730
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataIntegrityDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataPltDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataPltDMapper.xml
new file mode 100644
index 000000000..c6dc2a909
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataPltDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataVDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataVDMapper.xml
new file mode 100644
index 000000000..2a953176c
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatDataVDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitRateDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitRateDMapper.xml
new file mode 100644
index 000000000..feae0b79b
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitRateDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitTargetDMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitTargetDMapper.xml
new file mode 100644
index 000000000..399e3173c
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatLimitTargetDMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatOnlineRateMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatOnlineRateMapper.xml
new file mode 100644
index 000000000..004ac166f
--- /dev/null
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/day/mapping/RStatOnlineRateMapper.xml
@@ -0,0 +1,5 @@
+
+
+
+
+
\ No newline at end of file
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsSuperviseMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsSuperviseMapper.java
index 6f601a961..b79ed0c91 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsSuperviseMapper.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsSuperviseMapper.java
@@ -2,8 +2,12 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.njcn.prepare.harmonic.pojo.dto.SuperviseDto;
import com.njcn.prepare.harmonic.pojo.po.ThsSupervise;
+import com.njcn.prepare.harmonic.pojo.vo.SuperviseVo;
import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
/**
*
@@ -16,5 +20,11 @@ import org.apache.ibatis.annotations.Mapper;
@DS("process")
@Mapper
public interface ThsSuperviseMapper extends BaseMapper {
-
+ /**
+ * 查询技术监督列表
+ *
+ * @param superviseDto
+ * @return
+ */
+ Page querySuperviseList(Page page, @Param("param") SuperviseDto superviseDto);
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsWarnStrategyMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsWarnStrategyMapper.java
index d40dac8c7..e59847ea1 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsWarnStrategyMapper.java
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/ThsWarnStrategyMapper.java
@@ -3,6 +3,7 @@ package com.njcn.prepare.harmonic.mapper.mysql.line;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.harmonic.pojo.vo.ThsStrategyVo;
+import com.njcn.prepare.harmonic.pojo.dto.SuperviseDto;
import com.njcn.prepare.harmonic.pojo.param.SuperviseParam;
import com.njcn.process.pojo.po.ThsWarnStrategy;
import org.apache.ibatis.annotations.Mapper;
@@ -26,4 +27,5 @@ public interface ThsWarnStrategyMapper extends BaseMapper {
*/
List selectStrategyList(@Param("param") SuperviseParam superviseParam);
+
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsSuperviseMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsSuperviseMapper.xml
index 61751ed4b..5af886dad 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsSuperviseMapper.xml
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsSuperviseMapper.xml
@@ -1,5 +1,19 @@
-
+
+
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsWarnStrategyMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsWarnStrategyMapper.xml
index 9c3b03de2..b4b3d3acb 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsWarnStrategyMapper.xml
+++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/line/mapping/ThsWarnStrategyMapper.xml
@@ -29,7 +29,15 @@
and tda.Dept_Id=#{param.deptId}
+
+ AND tda.Monitor_Id IN
+
+ #{item.lineIndex}
+
+
and tws.Big_Type=1
+
+
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlickerDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlickerDServiceImpl.java
new file mode 100644
index 000000000..f12b256d0
--- /dev/null
+++ b/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 implements IRStatDataFlickerDService {
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlucDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataFlucDServiceImpl.java
new file mode 100644
index 000000000..4d087f88c
--- /dev/null
+++ b/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 implements IRStatDataFlucDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateIDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateIDServiceImpl.java
new file mode 100644
index 000000000..273565cff
--- /dev/null
+++ b/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 implements IRStatDataHarmRateIDService {
+
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateVDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmRateVDServiceImpl.java
new file mode 100644
index 000000000..95d013f8c
--- /dev/null
+++ b/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 implements IRStatDataHarmRateVDService {
+
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicIDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicIDServiceImpl.java
new file mode 100644
index 000000000..d9c4f27d5
--- /dev/null
+++ b/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 implements IRStatDataHarmphasicIDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicVDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmphasicVDServiceImpl.java
new file mode 100644
index 000000000..2ff329113
--- /dev/null
+++ b/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 implements IRStatDataHarmphasicVDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerPDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerPDServiceImpl.java
new file mode 100644
index 000000000..95b586cb2
--- /dev/null
+++ b/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 implements IRStatDataHarmpowerPDService {
+
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerQDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerQDServiceImpl.java
new file mode 100644
index 000000000..9642c5dd3
--- /dev/null
+++ b/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 implements IRStatDataHarmpowerQDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerSDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataHarmpowerSDServiceImpl.java
new file mode 100644
index 000000000..62e05f3c6
--- /dev/null
+++ b/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 implements IRStatDataHarmpowerSDService {
+
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataIDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataIDServiceImpl.java
new file mode 100644
index 000000000..94ab9f212
--- /dev/null
+++ b/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 implements IRStatDataIDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmIDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmIDServiceImpl.java
new file mode 100644
index 000000000..048337954
--- /dev/null
+++ b/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 implements IRStatDataInharmIDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmVDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataInharmVDServiceImpl.java
new file mode 100644
index 000000000..06caaafe5
--- /dev/null
+++ b/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 implements IRStatDataInharmVDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataPltDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataPltDServiceImpl.java
new file mode 100644
index 000000000..b0ecfb498
--- /dev/null
+++ b/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 implements IRStatDataPltDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataVDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatDataVDServiceImpl.java
new file mode 100644
index 000000000..ad0b8f51d
--- /dev/null
+++ b/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 implements IRStatDataVDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatch(list,50);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatLimitRateDServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/day/RStatLimitRateDServiceImpl.java
new file mode 100644
index 000000000..75fe2866d
--- /dev/null
+++ b/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 implements IRStatLimitRateDService {
+
+ @Override
+ public void insert(List list) {
+ this.saveOrUpdateBatchByMultiId(list,50);
+ }
+
+ @Override
+ public List findList(List list, String time) {
+ LambdaQueryWrapper lambdaQueryWrapper = new LambdaQueryWrapper<>();
+ lambdaQueryWrapper.in(CollUtil.isNotEmpty(list),RStatLimitRateDPO::getLineId,list).eq(RStatLimitRateDPO::getTime,time).eq(RStatLimitRateDPO::getPhasicType,"T");
+ return this.list(lambdaQueryWrapper);
+ }
+}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
index 60ae0f9e8..aeb41970b 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/DayDataServiceImpl.java
+++ b/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 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 dataFlickerPOList = new ArrayList<> ();
+ List dataVPOList = new ArrayList<> ();
+ List dataIPOList = new ArrayList<> ();
+ List dataFlucPOList = new ArrayList<> ();
+ List dataHarmPhasicIPOList = new ArrayList<> ();
+ List dataHarmPhasicVPOList = new ArrayList<> ();
+ List dataHarmPowerPPOList = new ArrayList<> ();
+ List dataHarmPowerQPOList = new ArrayList<> ();
+ List dataHarmPowerSPOList = new ArrayList<> ();
+ List dataHarmRateIPOList = new ArrayList<> ();
+ List dataHarmRateVPOList = new ArrayList<> ();
+ List dataInHarmIPOList = new ArrayList<> ();
+ List dataInHarmVPOList = new ArrayList<> ();
+ List dataPltPOList = new ArrayList<> ();
+
+ for (String lineIndex : indexLists) {
+ /*生成dayV表*/
+ List 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 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 = 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 = 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 = 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 = 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 = 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 = 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 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 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 = 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 = 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 = 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 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 {
}
-
-
-
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicGeneralServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicGeneralServiceImpl.java
index 20f7ae4e0..08debc917 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicGeneralServiceImpl.java
+++ b/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 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 list = new ArrayList<>();
+ List lineIdOutList;
+ if (CollUtil.isEmpty(lineParam.getLineIds())){
+ List 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 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 getGeneralData(String lineId, String date){
InfluxDBResultMapper mapper = new InfluxDBResultMapper();
BigDecimal hundred = BigDecimal.valueOf(100);
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicMetricServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicMetricServiceImpl.java
index 41c6d6355..e9cc09b9b 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/HarmonicMetricServiceImpl.java
+++ b/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 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 list = new ArrayList<>();
+ List lineIdList;
+ if (CollUtil.isEmpty(lineParam.getLineIds())){
+ List 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 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 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);
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
index f9bfa7cdb..2bdfaf756 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/IntegrityServiceImpl.java
+++ b/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 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 lineDetailList = new ArrayList<>();
+ if (CollUtil.isEmpty(lineParam.getLineIds())){
+ List overLimitList = getAllLinesLimitData();
+ List 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 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 list = resultMapper.toPOJO(sqlResult, DataVPO.class);
- return list.size();
+ if (CollectionUtils.isEmpty(list)){
+ return 0;
+ } else {
+ return list.size();
+ }
}
private List getAllLinesLimitData() {
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateService.java
index 7c7a1001c..5e43cba8b 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitRateService.java
+++ b/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 {
-
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 limitRateJobHandler(List lineList, String startTime, String endTime) {
+ public void limitRateJobHandler(List lineList, String startTime, String endTime) {
List limitRates = new ArrayList<> ();
List limitRateList = new ArrayList<> ();
-
Instant instant = new SimpleDateFormat ("yyyy-MM-dd").parse (startTime).toInstant ( );
Long time= instant.toEpochMilli();
-
for (int i = 0; i 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 lineList, String startTime, String endTime) {
+ List list = new ArrayList<>();
+ List 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 map1 = getAllTime(lineIndex,startTime,endTime);
+ List map2 = getFlickerAllTime(lineIndex,startTime,endTime);
+ List map3 = getDataHarmRateV(lineIndex,startTime,endTime);
+ List map4 = getDataI(lineIndex,startTime,endTime);
+ List map5 = getDataInHarmV(lineIndex,startTime,endTime);
+ List map6 = getDataV(lineIndex,startTime,endTime);
+ List map7 = getDataVUnbalance(lineIndex,startTime,endTime);
+ List map8 = getDataINeg(lineIndex,startTime,endTime);
+ List map9 = getDataVFreq(lineIndex,startTime,endTime);
+ List map10 = getDataVDev(lineIndex,startTime,endTime);
+ List map11 = getDataPlt(lineIndex,startTime,endTime);
+ List result = getData(overlimit,map1,map2,map3,map4,map5,map6,map7,map8,map9,map10,map11);
+ limitRateList.addAll (result);
+ Date finalDate = date;
+ List 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);
+ }
}
diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitTargetServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitTargetServiceImpl.java
index e423c6dfb..da0e97963 100644
--- a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/Impl/line/LimitTargetServiceImpl.java
+++ b/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