From 16107d3e7b928d7951bf8b122d7490d8737add49 Mon Sep 17 00:00:00 2001 From: huangzj <826100833@qq.com> Date: Mon, 18 Sep 2023 10:36:00 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=8F=90=E4=BA=A4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../RStatSubstationVoltageController.java | 83 +++++++++++++++++++ .../newalgorithm/RStatLoadTypeDPOMapper.java | 16 ++++ .../newalgorithm/RStatLoadTypeMPOMapper.java | 16 ++++ .../newalgorithm/RStatLoadTypeQPOMapper.java | 16 ++++ .../newalgorithm/RStatLoadTypeYPOMapper.java | 16 ++++ .../RStatOrgBusbarVoltageDPOMapper.java | 16 ++++ .../RStatOrgBusbarVoltageMPOMapper.java | 16 ++++ .../RStatOrgBusbarVoltageQPOMapper.java | 16 ++++ .../RStatOrgBusbarVoltageYPOMapper.java | 16 ++++ .../RStatSubstationVoltageMPOMapper.java | 16 ++++ .../mapping/RStatLoadTypeDPOMapper.xml | 20 +++++ .../mapping/RStatLoadTypeMPOMapper.xml | 28 +++++++ .../mapping/RStatLoadTypeQPOMapper.xml | 28 +++++++ .../mapping/RStatLoadTypeYPOMapper.xml | 28 +++++++ .../RStatOrgBusbarVoltageDPOMapper.xml | 23 +++++ .../RStatOrgBusbarVoltageMPOMapper.xml | 23 +++++ .../RStatOrgBusbarVoltageQPOMapper.xml | 23 +++++ .../RStatOrgBusbarVoltageYPOMapper.xml | 23 +++++ .../RStatSubstationVoltageMPOMapper.xml | 18 ++++ .../newalgorithm/RStatLoadTypeDPOService.java | 17 ++++ .../newalgorithm/RStatLoadTypeMPOService.java | 17 ++++ .../newalgorithm/RStatLoadTypeQPOService.java | 17 ++++ .../newalgorithm/RStatLoadTypeYPOService.java | 17 ++++ .../RStatOrgBusbarVoltageDPOService.java | 17 ++++ .../RStatOrgBusbarVoltageMPOService.java | 17 ++++ .../RStatOrgBusbarVoltageQPOService.java | 17 ++++ .../RStatOrgBusbarVoltageYPOService.java | 17 ++++ .../RStatSubstationVoltageMPOService.java | 22 +++++ .../impl/RStatLoadTypeDPOServiceImpl.java | 22 +++++ .../impl/RStatLoadTypeMPOServiceImpl.java | 22 +++++ .../impl/RStatLoadTypeQPOServiceImpl.java | 22 +++++ .../impl/RStatLoadTypeYPOServiceImpl.java | 22 +++++ .../RStatOrgBusbarVoltageDPOServiceImpl.java | 22 +++++ .../RStatOrgBusbarVoltageMPOServiceImpl.java | 22 +++++ .../RStatOrgBusbarVoltageQPOServiceImpl.java | 22 +++++ .../RStatOrgBusbarVoltageYPOServiceImpl.java | 22 +++++ .../RStatSubstationVoltageMPOServiceImpl.java | 67 +++++++++++++++ 37 files changed, 842 insertions(+) create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RStatSubstationVoltageController.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeDPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeMPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeQPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeYPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageDPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageMPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageQPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageYPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatSubstationVoltageMPOMapper.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeDPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeMPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeQPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeYPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageDPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageMPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageQPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageYPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatSubstationVoltageMPOMapper.xml create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeDPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeMPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeQPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeYPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageDPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageMPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageQPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageYPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatSubstationVoltageMPOService.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeDPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeMPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeQPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeYPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageDPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageMPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageQPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageYPOServiceImpl.java create mode 100644 pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationVoltageMPOServiceImpl.java diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RStatSubstationVoltageController.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RStatSubstationVoltageController.java new file mode 100644 index 000000000..7e9ff6b22 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/controller/newalgorithm/RStatSubstationVoltageController.java @@ -0,0 +1,83 @@ +package com.njcn.prepare.harmonic.controller.newalgorithm; + +import com.njcn.common.pojo.annotation.OperateInfo; +import com.njcn.common.pojo.constant.ServerInfo; +import com.njcn.common.pojo.enums.common.LogEnum; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.common.utils.HttpResultUtil; +import com.njcn.device.biz.commApi.CommTerminalGeneralClient; +import com.njcn.device.biz.pojo.dto.DeptGetSubStationDTO; +import com.njcn.device.biz.pojo.param.DeptGetLineParam; +import com.njcn.prepare.harmonic.pojo.param.OrgParam; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatSubstationService; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatSubstationVoltageMPOService; +import com.njcn.user.api.DeptFeignClient; +import com.njcn.user.pojo.po.Dept; +import com.njcn.web.controller.BaseController; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiImplicitParam; +import io.swagger.annotations.ApiOperation; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.util.StringUtils; +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 java.time.LocalDateTime; +import java.util.List; + +/** + * Description: + * 接口文档访问地址：http://serverIP:port/swagger-ui.html + * Date: 2022/12/28 13:47【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Slf4j +@Api(tags = "变电站指标统计") +@RestController +@RequestMapping("/rStartSubstationVoltage") +@RequiredArgsConstructor +public class RStatSubstationVoltageController extends BaseController { + + private final RStatSubstationVoltageMPOService service; + + private final CommTerminalGeneralClient commTerminalGeneralClient; + + private final DeptFeignClient deptFeignClient; + + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/rStartSubstationHandler") + @ApiOperation("变电站指标统计") + @ApiImplicitParam(name = "orgParam", value = "参数", required = true) + public HttpResult rStartSubstationHandler(@RequestBody @Validated OrgParam orgParam) { + log.info(LocalDateTime.now() + "rStartSubstationHandler开始执行"); + String methodDescribe = getMethodDescribe("rStartSubstationHandler"); + /** + * 支持补录 + */ + DeptGetLineParam deptGetLineParam = new DeptGetLineParam(); + + if (StringUtils.isEmpty(orgParam.getOrgId())) { + Dept data = deptFeignClient.getRootDept().getData(); + deptGetLineParam.setDeptId(data.getId()); + } else { + deptGetLineParam.setDeptId(orgParam.getOrgId()); + } + deptGetLineParam.setServerName(ServerInfo.PREPARE_BOOT); + List data = commTerminalGeneralClient.deptSubStation(deptGetLineParam).getData(); + + long start = System.currentTimeMillis(); + service.handler(data,orgParam.getDataDate(),orgParam.getType()); + long end = System.currentTimeMillis(); + System.out.println("该方法总耗时为 ---> "+(end-start)); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeDPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeDPOMapper.java new file mode 100644 index 000000000..9cabe2f7d --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeDPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeDPO; + +/** + * + * Description: + * Date: 2023/8/4 15:48【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeDPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeMPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeMPOMapper.java new file mode 100644 index 000000000..be2d8c62f --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeMPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeMPO; + +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeMPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeQPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeQPOMapper.java new file mode 100644 index 000000000..9be71af9b --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeQPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeQPO; + +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeQPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeYPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeYPOMapper.java new file mode 100644 index 000000000..94960ae01 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatLoadTypeYPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeYPO; + +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeYPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageDPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageDPOMapper.java new file mode 100644 index 000000000..3d6dc1a53 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageDPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageDPO; + +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageDPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageMPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageMPOMapper.java new file mode 100644 index 000000000..4ebe5a2dd --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageMPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageMPO; + +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageMPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageQPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageQPOMapper.java new file mode 100644 index 000000000..d313af7cb --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageQPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageQPO; + +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageQPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageYPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageYPOMapper.java new file mode 100644 index 000000000..cd97d3c50 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatOrgBusbarVoltageYPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageYPO; + +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageYPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatSubstationVoltageMPOMapper.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatSubstationVoltageMPOMapper.java new file mode 100644 index 000000000..bf64f367b --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/RStatSubstationVoltageMPOMapper.java @@ -0,0 +1,16 @@ +package com.njcn.prepare.harmonic.mapper.mysql.newalgorithm; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.github.jeffreyning.mybatisplus.base.MppBaseMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatSubstationVoltageMPO; + +/** + * + * Description: + * Date: 2023/8/4 14:57【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatSubstationVoltageMPOMapper extends MppBaseMapper { +} \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeDPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeDPOMapper.xml new file mode 100644 index 000000000..267487675 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeDPOMapper.xml @@ -0,0 +1,20 @@ + + + + + + + + + + + + + + + + + + org_no, data_date, load_type, v_ratio, i_ratio, unbalance_ratio, i_neg_ratio, flicker_ratio + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeMPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeMPOMapper.xml new file mode 100644 index 000000000..bab5b6c3f --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeMPOMapper.xml @@ -0,0 +1,28 @@ + + + + + + + + + + + + + + + + + + + + + + + + org_no, data_date, load_type, effective_measurement, v_average, v_count, i_average, + i_count, unbalance_average, unbalance_count, i_neg_average, i_neg_count, flicker_average, + flicker_count + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeQPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeQPOMapper.xml new file mode 100644 index 000000000..95c12d11d --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeQPOMapper.xml @@ -0,0 +1,28 @@ + + + + + + + + + + + + + + + + + + + + + + + + org_no, data_date, load_type, effective_measurement, v_average, v_count, i_average, + i_count, unbalance_average, unbalance_count, i_neg_average, i_neg_count, flicker_average, + flicker_count + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeYPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeYPOMapper.xml new file mode 100644 index 000000000..767c249b7 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatLoadTypeYPOMapper.xml @@ -0,0 +1,28 @@ + + + + + + + + + + + + + + + + + + + + + + + + org_no, data_date, load_type, effective_measurement, v_average, v_count, i_average, + i_count, unbalance_average, unbalance_count, i_neg_average, i_neg_count, flicker_average, + flicker_count + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageDPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageDPOMapper.xml new file mode 100644 index 000000000..cce588bf4 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageDPOMapper.xml @@ -0,0 +1,23 @@ + + + + + + + + + + + + + + + + + + + + org_no, data_date, busbar_id, measurement_count, v_count, v_ratio, unbalance_count, + unbalance_ratio, flicker_count, flicker_ratio + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageMPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageMPOMapper.xml new file mode 100644 index 000000000..f86e324cc --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageMPOMapper.xml @@ -0,0 +1,23 @@ + + + + + + + + + + + + + + + + + + + + org_no, data_date, busbar_id, measurement_count, v_average, v_accrued, unbalance_average, + unbalance_accrued, flicker_average, flicker_accrued + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageQPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageQPOMapper.xml new file mode 100644 index 000000000..2551e3105 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageQPOMapper.xml @@ -0,0 +1,23 @@ + + + + + + + + + + + + + + + + + + + + org_no, data_date, busbar_id, measurement_count, v_average, v_accrued, unbalance_average, + unbalance_accrued, flicker_average, flicker_accrued + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageYPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageYPOMapper.xml new file mode 100644 index 000000000..17d540b23 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatOrgBusbarVoltageYPOMapper.xml @@ -0,0 +1,23 @@ + + + + + + + + + + + + + + + + + + + + org_no, data_date, busbar_id, measurement_count, v_average, v_accrued, unbalance_average, + unbalance_accrued, flicker_average, flicker_accrued + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatSubstationVoltageMPOMapper.xml b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatSubstationVoltageMPOMapper.xml new file mode 100644 index 000000000..b40faf59f --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/newalgorithm/mapping/RStatSubstationVoltageMPOMapper.xml @@ -0,0 +1,18 @@ + + + + + + + + + + + + + + + + org_no, data_date, substation_voltage, substation_count, harmonic_count, event_count + + \ No newline at end of file diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeDPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeDPOService.java new file mode 100644 index 000000000..aa239f909 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeDPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeDPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:48【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeDPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeMPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeMPOService.java new file mode 100644 index 000000000..40cc6a176 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeMPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeMPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeMPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeQPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeQPOService.java new file mode 100644 index 000000000..b8fae2c08 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeQPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeQPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeQPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeYPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeYPOService.java new file mode 100644 index 000000000..6daba22d4 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatLoadTypeYPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeYPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatLoadTypeYPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageDPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageDPOService.java new file mode 100644 index 000000000..65c83b72a --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageDPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageDPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageDPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageMPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageMPOService.java new file mode 100644 index 000000000..736534f26 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageMPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageMPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageMPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageQPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageQPOService.java new file mode 100644 index 000000000..a51d27e14 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageQPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageQPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageQPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageYPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageYPOService.java new file mode 100644 index 000000000..9856b7ffd --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatOrgBusbarVoltageYPOService.java @@ -0,0 +1,17 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageYPO; +import com.baomidou.mybatisplus.extension.service.IService; + /** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatOrgBusbarVoltageYPOService extends IMppService { + + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatSubstationVoltageMPOService.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatSubstationVoltageMPOService.java new file mode 100644 index 000000000..dcffff9ef --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/RStatSubstationVoltageMPOService.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm; + +import com.github.jeffreyning.mybatisplus.service.IMppService; +import com.njcn.device.biz.pojo.dto.DeptGetSubStationDTO; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatSubstationVoltageMPO; +import com.baomidou.mybatisplus.extension.service.IService; + +import java.util.List; + +/** + * + * Description: + * Date: 2023/8/4 14:57【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +public interface RStatSubstationVoltageMPOService extends IMppService { + + + void handler(List data, String dataDate, Integer type); + } diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeDPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeDPOServiceImpl.java new file mode 100644 index 000000000..a990d19bb --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeDPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatLoadTypeDPOMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeDPO; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatLoadTypeDPOService; +/** + * + * Description: + * Date: 2023/8/4 15:48【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatLoadTypeDPOServiceImpl extends MppServiceImpl implements RStatLoadTypeDPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeMPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeMPOServiceImpl.java new file mode 100644 index 000000000..3be35322e --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeMPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeMPO; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatLoadTypeMPOMapper; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatLoadTypeMPOService; +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatLoadTypeMPOServiceImpl extends MppServiceImpl implements RStatLoadTypeMPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeQPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeQPOServiceImpl.java new file mode 100644 index 000000000..d6013f2b8 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeQPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeQPO; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatLoadTypeQPOMapper; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatLoadTypeQPOService; +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatLoadTypeQPOServiceImpl extends MppServiceImpl implements RStatLoadTypeQPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeYPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeYPOServiceImpl.java new file mode 100644 index 000000000..969fc790d --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatLoadTypeYPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatLoadTypeYPO; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatLoadTypeYPOMapper; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatLoadTypeYPOService; +/** + * + * Description: + * Date: 2023/8/4 15:49【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatLoadTypeYPOServiceImpl extends MppServiceImpl implements RStatLoadTypeYPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageDPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageDPOServiceImpl.java new file mode 100644 index 000000000..fea5d438e --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageDPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatOrgBusbarVoltageDPOMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageDPO; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatOrgBusbarVoltageDPOService; +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatOrgBusbarVoltageDPOServiceImpl extends MppServiceImpl implements RStatOrgBusbarVoltageDPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageMPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageMPOServiceImpl.java new file mode 100644 index 000000000..6af949d27 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageMPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatOrgBusbarVoltageMPOMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageMPO; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatOrgBusbarVoltageMPOService; +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatOrgBusbarVoltageMPOServiceImpl extends MppServiceImpl implements RStatOrgBusbarVoltageMPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageQPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageQPOServiceImpl.java new file mode 100644 index 000000000..46f9fff81 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageQPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatOrgBusbarVoltageQPOMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageQPO; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatOrgBusbarVoltageQPOService; +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatOrgBusbarVoltageQPOServiceImpl extends MppServiceImpl implements RStatOrgBusbarVoltageQPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageYPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageYPOServiceImpl.java new file mode 100644 index 000000000..bac5f7181 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatOrgBusbarVoltageYPOServiceImpl.java @@ -0,0 +1,22 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.util.List; +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatOrgBusbarVoltageYPO; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatOrgBusbarVoltageYPOMapper; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatOrgBusbarVoltageYPOService; +/** + * + * Description: + * Date: 2023/8/4 15:36【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatOrgBusbarVoltageYPOServiceImpl extends MppServiceImpl implements RStatOrgBusbarVoltageYPOService{ + +} diff --git a/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationVoltageMPOServiceImpl.java b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationVoltageMPOServiceImpl.java new file mode 100644 index 000000000..45339a197 --- /dev/null +++ b/pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/service/mysql/newalgorithm/impl/RStatSubstationVoltageMPOServiceImpl.java @@ -0,0 +1,67 @@ +package com.njcn.prepare.harmonic.service.mysql.newalgorithm.impl; + +import cn.hutool.core.date.DateUtil; +import com.github.jeffreyning.mybatisplus.service.MppServiceImpl; +import com.njcn.device.biz.pojo.dto.DeptGetSubStationDTO; +import com.njcn.device.biz.pojo.dto.LineDevGetBandDTO; +import com.njcn.device.biz.pojo.dto.LineDevGetDTO; +import com.njcn.prepare.harmonic.pojo.po.RStatSubstationMPO; +import org.springframework.stereotype.Service; +import javax.annotation.Resource; +import java.text.SimpleDateFormat; +import java.time.LocalDate; +import java.time.ZoneId; +import java.util.*; +import java.util.stream.Collectors; + +import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.njcn.prepare.harmonic.mapper.mysql.newalgorithm.RStatSubstationVoltageMPOMapper; +import com.njcn.prepare.harmonic.pojo.mysql.po.RStatSubstationVoltageMPO; +import com.njcn.prepare.harmonic.service.mysql.newalgorithm.RStatSubstationVoltageMPOService; +import org.springframework.util.CollectionUtils; + +/** + * + * Description: + * Date: 2023/8/4 14:57【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Service +public class RStatSubstationVoltageMPOServiceImpl extends MppServiceImpl implements RStatSubstationVoltageMPOService{ + + @Override + public void handler(List data, String dataDate, Integer type) { + List result = new ArrayList<>(); + Date date = DateUtil.parse(dataDate); + LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate(); + + + + List zwList = new ArrayList<>(); + List pwList = new ArrayList<>(); + + for (DeptGetSubStationDTO datum : data) { + if (!CollectionUtils.isEmpty(datum.getStationIds())) { + zwList.addAll(datum.getStationIds()); + } + if (!CollectionUtils.isEmpty(datum.getPwStationIds())) { + pwList.addAll(datum.getPwStationIds()); + } + } + + zwList.addAll(pwList); + List resultL = zwList.stream().distinct().collect(Collectors.toList()); + + if (!CollectionUtils.isEmpty(resultL)) { + resultL.forEach(temp->{ + + }); + } + + if (!CollectionUtils.isEmpty(result)) { + this.saveOrUpdateBatchByMultiId(result, 500); + } + } +}