From fd3101c9ef4332b8e25c4d7e8181ef4c3b66eb5d Mon Sep 17 00:00:00 2001 From: zhuxinyu <1799009482@qq.com> Date: Fri, 14 Apr 2023 15:30:18 +0800 Subject: [PATCH 01/10] =?UTF-8?q?=E7=A8=B3=E6=80=81=E6=8C=87=E6=A0=87?= =?UTF-8?q?=E8=B6=85=E6=A0=87=E6=98=8E=E7=BB=86=E6=8E=A5=E5=8F=A3=E4=BC=98?= =?UTF-8?q?=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mapper/RStatLimitRateDMapper.java | 6 ++ .../mapper/mapping/RStatLimitRateDMapper.xml | 76 +++++++++++++++ .../service/impl/AnalyzeServiceImpl.java | 97 +++++++------------ 3 files changed, 118 insertions(+), 61 deletions(-) diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/RStatLimitRateDMapper.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/RStatLimitRateDMapper.java index 943e9424f..2ba594935 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/RStatLimitRateDMapper.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/RStatLimitRateDMapper.java @@ -1,6 +1,7 @@ package com.njcn.harmonic.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.njcn.harmonic.pojo.po.day.RStatLimitRateDPO; import com.njcn.harmonic.pojo.vo.MonitorOverLimitVO; import com.njcn.harmonic.pojo.vo.RStatLimitRateDVO; @@ -28,4 +29,9 @@ public interface RStatLimitRateDMapper extends BaseMapper { @Param("ids") List lineIndexes, @Param("statTime") String searchBeginTime, @Param("endTime") String searchEndTime); + + Page getSumLimitRatePage(Page p, + @Param("ids") List lineIndexes, + @Param("statTime") String searchBeginTime, + @Param("endTime") String searchEndTime); } diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/mapping/RStatLimitRateDMapper.xml b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/mapping/RStatLimitRateDMapper.xml index 0c7875077..885ea675a 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/mapping/RStatLimitRateDMapper.xml +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/mapping/RStatLimitRateDMapper.xml @@ -107,4 +107,80 @@ GROUP BY my_index + diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java index e9a015151..e0cb375ea 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java @@ -296,39 +296,49 @@ public class AnalyzeServiceImpl implements IAnalyzeService { p.setSize(param.getPageSize()); p.setCurrent(param.getPageNum()); if (CollectionUtil.isNotEmpty(lineList)) { - QueryWrapper queryWrapper = new QueryWrapper<>(); - queryWrapper.in("r_stat_limit_rate_d.my_index",lineList) - .between("r_stat_limit_rate_d.time_id", - DateUtil.beginOfDay(DateUtil.parse(param.getSearchBeginTime())), - DateUtil.endOfDay(DateUtil.parse(param.getSearchEndTime()))); - Page rateDPOPage = rateDMapper.selectPage(p,queryWrapper); - List records = rateDPOPage.getRecords(); - Map> lineMap = records.stream().collect(Collectors.groupingBy(RStatLimitRateDPO::getLineId)); + Page sumLimitRatePage = rateDMapper.getSumLimitRatePage(p, lineList, param.getSearchBeginTime(), param.getSearchEndTime()); + List pageRecords = sumLimitRatePage.getRecords(); + Map> monMap = pageRecords.stream().collect(Collectors.groupingBy(MonitorOverLimitVO::getId)); ArrayList list = new ArrayList<>(); - list.addAll(lineMap.keySet()); + list.addAll(monMap.keySet()); PollutionParamDTO pollutionParamDTO = new PollutionParamDTO(); pollutionParamDTO.setLineList(list); List overLimitLineList = lineFeignClient.getOverLimitLineInfo(pollutionParamDTO).getData(); - List groupList = rateDMapper.getSumLimitRateByLineIndexes(list, param.getSearchBeginTime(), param.getSearchEndTime()); - Map> groupMap = groupList.stream().collect(Collectors.groupingBy(MonitorOverLimitVO::getId)); + List rStatLimitRateDPOS = rateDMapper.selectList(new QueryWrapper() + .in("r_stat_limit_rate_d.my_index", list) + .between("r_stat_limit_rate_d.time_id", + DateUtil.beginOfDay(DateUtil.parse(param.getSearchBeginTime())), + DateUtil.endOfDay(DateUtil.parse(param.getSearchEndTime()))) + ); + Map> rsMap = rStatLimitRateDPOS.stream().collect(Collectors.groupingBy(RStatLimitRateDPO::getLineId)); for (OverLimitLineDTO vo : overLimitLineList) { MonitorOverLimitVO monitorOverLimitVO = new MonitorOverLimitVO(); BeanUtil.copyProperties(vo,monitorOverLimitVO); - List limitRateDPOS = lineMap.get(vo.getId()); - MonitorOverLimitVO overLimitVO = groupMap.get(vo.getId()).get(0); - BeanUtil.copyProperties(overLimitVO,monitorOverLimitVO); - - System.out.println(monitorOverLimitVO); - - - // 超标天数 -// long allTimeCount = limitRateDPOS.stream().filter(t -> t.getAllTime() != 0).count(); - // 频率偏差超标天数 -// long freqDevOverCount = limitRateDPOS.stream().filter(t -> t.getFreqDevOvertime() != 0).count(); - // 电压偏差超标天数 -// long voltageDevOverCount = limitRateDPOS.stream().filter(t -> t.getVoltageDevOvertime() != 0).count(); - // 电压谐波畸变率越限次数 -// long UaberranceOverCount = limitRateDPOS.stream().filter(t -> t.getUaberranceOvertime() != 0).count(); + MonitorOverLimitVO source = monMap.get(vo.getId()).get(0); + monitorOverLimitVO.setOverDay(source.getOverDay()); + monitorOverLimitVO.setVolDevOverDay(source.getVolDevOverDay()); + monitorOverLimitVO.setFreqOverDay(source.getFreqOverDay()); + monitorOverLimitVO.setFlickerOverDay(source.getFlickerOverDay()); + monitorOverLimitVO.setNegativeOverDay(source.getNegativeOverDay()); + monitorOverLimitVO.setThreeUnbalance(source.getThreeUnbalance()); + monitorOverLimitVO.setVolDisOverDay(source.getVolDisOverDay()); + monitorOverLimitVO.setOverVolThreeTimes(source.getOverVolThreeTimes()); + monitorOverLimitVO.setOverVolFiveTimes(source.getOverVolFiveTimes()); + monitorOverLimitVO.setOverVolSevenTimes(source.getOverVolSevenTimes()); + monitorOverLimitVO.setOverVolElevenTimes(source.getOverVolElevenTimes()); + monitorOverLimitVO.setOverVolThirteenTimes(source.getOverVolThirteenTimes()); + monitorOverLimitVO.setOverVolTwentyThreeTimes(source.getOverVolTwentyThreeTimes()); + monitorOverLimitVO.setOverVolTwentyFiveTimes(source.getOverVolTwentyFiveTimes()); + monitorOverLimitVO.setOverVolOtherTimes(source.getOverVolOtherTimes()); + monitorOverLimitVO.setOverCurThreeTimes(source.getOverCurThreeTimes()); + monitorOverLimitVO.setOverCurFiveTimes(source.getOverCurFiveTimes()); + monitorOverLimitVO.setOverCurSevenTimes(source.getOverCurSevenTimes()); + monitorOverLimitVO.setOverCurElevenTimes(source.getOverCurElevenTimes()); + monitorOverLimitVO.setOverCurThirteenTimes(source.getOverCurThirteenTimes()); + monitorOverLimitVO.setOverCurTwentyThreeTimes(source.getOverCurTwentyThreeTimes()); + monitorOverLimitVO.setOverCurTwentyFiveTimes(source.getOverCurTwentyFiveTimes()); + monitorOverLimitVO.setOverCurOtherTimes(source.getOverCurOtherTimes()); + List limitRateDPOS = rsMap.get(vo.getId()); // 谐波电压含有率超标天数 long volContainOverDay = limitRateDPOS.stream().filter(t -> FilterNotQualifiedUharmData(t)).count(); // 谐波电流超标天数 @@ -350,41 +360,6 @@ public class AnalyzeServiceImpl implements IAnalyzeService { return page; } return page; -// if (CollectionUtil.isNotEmpty (lineList)) { -// page.setTotal(lineList.size()); -// int pages = (int)Math.ceil(lineList.size()*1.0/param.getPageSize()); -// page.setPages(pages); -// List> pageList = Lists.partition(lineList,param.getPageSize()); -// List temList = pageList.get(param.getPageNum()-1); -// List list = rateDMapper.getSumLimitRateByLineIndexes(lineList, param.getSearchBeginTime(), param.getSearchEndTime()); -// Map> mapperMap = list.stream().collect(Collectors.groupingBy(MonitorOverLimitVO::getId)); -// PollutionParamDTO pollutionParamDTO = new PollutionParamDTO(); -// pollutionParamDTO.setLineList(temList); -// List overLimitLineList = lineFeignClient.getOverLimitLineInfo(pollutionParamDTO).getData(); -// for (OverLimitLineDTO overLimitLineDTO : overLimitLineList) { -// MonitorOverLimitVO vo = mapperMap.get(overLimitLineDTO.getId()).get(0); -// if (Objects.isNull(vo)) { -// continue; -// } -// vo.setProvinceCompany(overLimitLineDTO.getProvinceCompany()); -// vo.setCityCompany(overLimitLineDTO.getCityCompany()); -// vo.setLineName(overLimitLineDTO.getLineName()); -// vo.setLoadType(overLimitLineDTO.getLoadType()); -// vo.setLineObjectName(overLimitLineDTO.getLineObjectName()); -// vo.setLineScale(overLimitLineDTO.getLineScale()); -// vo.setSubName(overLimitLineDTO.getSubName()); -// vo.setSubScale(overLimitLineDTO.getSubScale()); -// result.add(vo); -// } -// } -// if (!CollectionUtils.isEmpty(result)){ -// List recordList = new ArrayList<>(); -// //默认 根据在线监测点个数 倒叙排序 -// recordList = result.stream().sorted(Comparator.comparing(MonitorOverLimitVO::getOverDay).reversed()).collect(Collectors.toList()); -// page.setRecords(recordList); -// return page; -// } -// return page; // if (!CollectionUtils.isEmpty(lineList)){ // page.setTotal(lineList.size()); // int pages = (int)Math.ceil(lineList.size()*1.0/param.getPageSize()); From 062fd5ae15c67087d68e32abbe21c8d814409592 Mon Sep 17 00:00:00 2001 From: zhuxinyu <1799009482@qq.com> Date: Fri, 14 Apr 2023 16:23:56 +0800 Subject: [PATCH 02/10] =?UTF-8?q?=E7=A8=B3=E6=80=81=E6=8C=87=E6=A0=87?= =?UTF-8?q?=E6=98=8E=E7=BB=86=E6=8E=A5=E5=8F=A3=E5=BC=80=E5=8F=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/AnalyzeServiceImpl.java | 24 ++++++++++++++----- 1 file changed, 18 insertions(+), 6 deletions(-) diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java index e0cb375ea..ee3229b4d 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java @@ -340,11 +340,14 @@ public class AnalyzeServiceImpl implements IAnalyzeService { monitorOverLimitVO.setOverCurOtherTimes(source.getOverCurOtherTimes()); List limitRateDPOS = rsMap.get(vo.getId()); // 谐波电压含有率超标天数 - long volContainOverDay = limitRateDPOS.stream().filter(t -> FilterNotQualifiedUharmData(t)).count(); + long volContainOverDay = limitRateDPOS.stream().filter(t -> filterNotQualifiedUharmData(t)).count(); // 谐波电流超标天数 - long harmCurOverDay = limitRateDPOS.stream().filter(t -> FilterNotQualifiedIharmData(t)).count(); + long harmCurOverDay = limitRateDPOS.stream().filter(t -> filterNotQualifiedIharmData(t)).count(); // 间谐波电压含有率超标天数 - long intHarmOverDay = limitRateDPOS.stream().filter(t -> FilterNotQualifiedInuharmData(t)).count(); + long intHarmOverDay = limitRateDPOS.stream().filter(t -> filterNotQualifiedInuharmData(t)).count(); + // 谐波电压超标天数 + long harmVolOverDay = limitRateDPOS.stream().filter(t -> filterNotQualifiedHarmVolData(t)).count(); + monitorOverLimitVO.setHarmVolOverDay((int) harmVolOverDay); monitorOverLimitVO.setVolContainOverDay((int) volContainOverDay); monitorOverLimitVO.setHarmCurOverDay((int) harmCurOverDay); monitorOverLimitVO.setIntHarmOverDay((int) intHarmOverDay); @@ -503,7 +506,16 @@ public class AnalyzeServiceImpl implements IAnalyzeService { // return page; } - private boolean FilterNotQualifiedInuharmData(RStatLimitRateDPO t) { + private boolean filterNotQualifiedHarmVolData(RStatLimitRateDPO t) { + // 电压畸变率+谐波电压含有率（2-25次） + int i = t.getUaberranceOvertime() + t.getUharm2Overtime() + t.getUharm3Overtime() + t.getUharm4Overtime() + t.getUharm5Overtime() + t.getUharm6Overtime() + t.getUharm7Overtime() + t.getUharm8Overtime() + t.getUharm9Overtime() + t.getUharm10Overtime() + t.getUharm11Overtime() + t.getUharm12Overtime() + t.getUharm13Overtime() + t.getUharm14Overtime() + t.getUharm15Overtime() + t.getUharm16Overtime() + t.getUharm17Overtime() + t.getUharm18Overtime() + t.getUharm19Overtime() + t.getUharm20Overtime() + t.getUharm21Overtime() + t.getUharm22Overtime() + t.getUharm23Overtime() + t.getUharm24Overtime() + t.getUharm25Overtime(); + if (i>0){ + return true; + } + return false; + } + + private boolean filterNotQualifiedInuharmData(RStatLimitRateDPO t) { int i =t.getInuharm1Overtime()+ t.getInuharm2Overtime() + t.getInuharm3Overtime() + t.getInuharm4Overtime() + t.getInuharm5Overtime() + t.getInuharm6Overtime() + t.getInuharm7Overtime() + t.getInuharm8Overtime() + t.getInuharm9Overtime() + t.getInuharm10Overtime() + t.getInuharm11Overtime() + t.getInuharm12Overtime() + t.getInuharm13Overtime() + t.getInuharm14Overtime() + t.getInuharm15Overtime() + t.getInuharm16Overtime(); if (i>0){ return true; @@ -511,7 +523,7 @@ public class AnalyzeServiceImpl implements IAnalyzeService { return false; } - private boolean FilterNotQualifiedIharmData(RStatLimitRateDPO t) { + private boolean filterNotQualifiedIharmData(RStatLimitRateDPO t) { int i = t.getIharm2Overtime() + t.getIharm3Overtime() + t.getIharm4Overtime() + t.getIharm5Overtime() + t.getIharm6Overtime() + t.getIharm7Overtime() + t.getIharm8Overtime() + t.getIharm9Overtime() + t.getIharm10Overtime() + t.getIharm11Overtime() + t.getIharm12Overtime() + t.getIharm13Overtime() + t.getIharm14Overtime() + t.getIharm15Overtime() + t.getIharm16Overtime() + t.getIharm17Overtime() + t.getIharm18Overtime() + t.getIharm19Overtime() + t.getIharm20Overtime() + t.getIharm21Overtime() + t.getIharm22Overtime() + t.getIharm23Overtime() + t.getIharm24Overtime() + t.getIharm25Overtime(); if (i>0){ return true; @@ -519,7 +531,7 @@ public class AnalyzeServiceImpl implements IAnalyzeService { return false; } - private boolean FilterNotQualifiedUharmData(RStatLimitRateDPO t) { + private boolean filterNotQualifiedUharmData(RStatLimitRateDPO t) { int i = t.getUharm2Overtime() + t.getUharm3Overtime() + t.getUharm4Overtime() + t.getUharm5Overtime() + t.getUharm6Overtime() + t.getUharm7Overtime() + t.getUharm8Overtime() + t.getUharm9Overtime() + t.getUharm10Overtime() + t.getUharm11Overtime() + t.getUharm12Overtime() + t.getUharm13Overtime() + t.getUharm14Overtime() + t.getUharm15Overtime() + t.getUharm16Overtime() + t.getUharm17Overtime() + t.getUharm18Overtime() + t.getUharm19Overtime() + t.getUharm20Overtime() + t.getUharm21Overtime() + t.getUharm22Overtime() + t.getUharm23Overtime() + t.getUharm24Overtime() + t.getUharm25Overtime(); if (i>0){ From d7592e8b2b2a83bdb4cbc98cb5c069bc365aa238 Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Mon, 17 Apr 2023 09:23:52 +0800 Subject: [PATCH 03/10] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AF=B9=E5=A4=96?= =?UTF-8?q?=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/fallback/DevModelFeignClientFallbackFactory.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/api/fallback/DevModelFeignClientFallbackFactory.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/api/fallback/DevModelFeignClientFallbackFactory.java index 09cd656d0..dca331fdf 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/api/fallback/DevModelFeignClientFallbackFactory.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/api/fallback/DevModelFeignClientFallbackFactory.java @@ -1,16 +1,14 @@ package com.njcn.algorithm.api.fallback; import com.njcn.algorithm.api.DevModelFeignClient; -import com.njcn.algorithm.api.EquipmentFeignClient; import com.njcn.algorithm.pojo.param.CsDevModelAddParm; import com.njcn.algorithm.pojo.param.CsDevModelQueryListParm; import com.njcn.algorithm.pojo.vo.CsDevModelPageVO; -import com.njcn.algorithm.pojo.vo.CsEquipmentDeliveryVO; import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.response.HttpResult; +import feign.hystrix.FallbackFactory; import lombok.extern.slf4j.Slf4j; -import org.springframework.cloud.openfeign.FallbackFactory; import org.springframework.stereotype.Component; import java.util.List; From 2be275027e708456f925f3dcdb5a9cfd897d6f3b Mon Sep 17 00:00:00 2001 From: huangzj <826100833@qq.com> Date: Mon, 17 Apr 2023 09:28:29 +0800 Subject: [PATCH 04/10] =?UTF-8?q?bug=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pojo/param/CsDevModelAddParm.java | 4 +- .../pojo/param/CsDevModelAuditParm.java | 4 +- .../pojo/param/CsDevModelQueryListParm.java | 15 ++++-- .../pojo/param/CsDevModelQueryParm.java | 10 ++-- .../algorithm/pojo/param/CsDictAddParm.java | 1 + .../algorithm/pojo/param/CsEdDataAddParm.java | 4 +- .../pojo/param/CsEdDataAuditParm.java | 4 +- .../pojo/param/CsEdDataQueryParm.java | 8 +-- .../param/CsEngineeringQueryPageParm.java | 49 ++++++++++++++++++ .../algorithm/pojo/vo/CsEngineeringVO.java | 6 +++ .../algorithm/pojo/vo/ProjectEquipmentVO.java | 11 ++++ .../Equipment/DevModelController.java | 4 +- .../project/EngineeringController.java | 13 +++++ .../mapper/mapping/CsDevModelMapper.xml | 12 +++-- .../mapping/CsEquipmentDeliveryMapper.xml | 6 ++- ...apper.xml => CsProjectEquipmentMapper.xml} | 0 .../service/CsEngineeringService.java | 12 ++++- .../impl/CsEngineeringServiceImpl.java | 51 +++++++++++++++++++ 18 files changed, 184 insertions(+), 30 deletions(-) create mode 100644 pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringQueryPageParm.java rename pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/{CsProject EquipmentMapper.xml => CsProjectEquipmentMapper.xml} (100%) diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java index ecb2bcf46..819163b20 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java @@ -37,8 +37,8 @@ public class CsDevModelAddParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private Date versionDate; /** diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java index e7a83e28d..4039fcbc1 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java @@ -39,8 +39,8 @@ public class CsDevModelAuditParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private Date versionDate; /** diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java index a61300a9e..c99e33785 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java @@ -31,14 +31,19 @@ public class CsDevModelQueryListParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") - @DateTimeFormat(pattern="yyyy-MM-dd") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") private String versionStartDate; @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") - private String versionendDate; + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + private String versionEndDate; + + @ApiModelProperty(value = "版本准确日期") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + private String versionDate; diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java index cc535e912..d27a5e297 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java @@ -43,14 +43,14 @@ public class CsDevModelQueryParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") - @DateTimeFormat(pattern="yyyy-MM-dd") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") private String versionStartDate; @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") - private String versionendDate; + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + private String versionEndDate; diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDictAddParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDictAddParm.java index 1207b04b7..78f5f7aca 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDictAddParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDictAddParm.java @@ -41,4 +41,5 @@ public class CsDictAddParm { @ApiModelProperty(value = "sort") private Integer sort; + } \ No newline at end of file diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAddParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAddParm.java index 46f01eecb..db4cfaea8 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAddParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAddParm.java @@ -50,8 +50,8 @@ public class CsEdDataAddParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private Date versionDate; /** diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAuditParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAuditParm.java index 4a722abe3..ee922c83b 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAuditParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataAuditParm.java @@ -47,8 +47,8 @@ public class CsEdDataAuditParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private LocalDate versionDate; /** diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataQueryParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataQueryParm.java index 739b19580..b2fda15c1 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataQueryParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEdDataQueryParm.java @@ -43,13 +43,13 @@ public class CsEdDataQueryParm { * 版本日期 */ @ApiModelProperty(value = "版本日期") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") - @DateTimeFormat(pattern="yyyy-MM-dd") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") private String versionStartDate; @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd") - @JsonFormat(pattern = "yyyy-MM-dd",timezone = "GMT+8") + @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") private String versionendDate; diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringQueryPageParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringQueryPageParm.java new file mode 100644 index 000000000..e061bacd3 --- /dev/null +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsEngineeringQueryPageParm.java @@ -0,0 +1,49 @@ +package com.njcn.algorithm.pojo.param; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import javax.validation.constraints.Min; +import javax.validation.constraints.NotNull; + +/** + * Description: + * 接口文档访问地址：http://serverIP:port/swagger-ui.html + * Date: 2023/4/10 19:47【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Data +public class CsEngineeringQueryPageParm { + + @NotNull(message="当前页不能为空！") + @Min(value = 1, message = "当前页不能为0") + @ApiModelProperty(value = "当前页",name = "currentPage",dataType ="Integer",required = true) + private Integer currentPage; + /**显示条数*/ + @NotNull(message="显示条数不能为空！") + @ApiModelProperty(value = "显示条数",name = "pageSize",dataType ="Integer",required = true) + private Integer pageSize; + @ApiModelProperty(value = "工程名称") + private String name; + + /** + * 用户id + */ + @ApiModelProperty(value = "用户id") + private String userId; + + /** + * 省 + */ + @ApiModelProperty(value = "省") + private String province; + + /** + * 市 + */ + @ApiModelProperty(value = "市") + private String city; + +} diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEngineeringVO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEngineeringVO.java index 21925d84f..c54484e1d 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEngineeringVO.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsEngineeringVO.java @@ -45,12 +45,18 @@ public class CsEngineeringVO extends BaseEntity { @ApiModelProperty(value = "省") private String province; + @ApiModelProperty(value = "省名称") + private String provinceName; + /** * 市 */ @ApiModelProperty(value = "市") private String city; + @ApiModelProperty(value = "市名称") + private String cityName; + /** * 描述 */ diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/ProjectEquipmentVO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/ProjectEquipmentVO.java index cfa439bd0..c618518b6 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/ProjectEquipmentVO.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/ProjectEquipmentVO.java @@ -17,6 +17,17 @@ import lombok.Data; @Data public class ProjectEquipmentVO { + /** + * id + */ + @ApiModelProperty(value = "工程id") + private String engineeringid; + + /** + * 工程名称 + */ + @ApiModelProperty(value = "工程名称") + private String engineeringName; @ApiModelProperty(value = "项目id") private String projectId; diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java index ebac5a6fe..7546bd1b2 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java @@ -81,8 +81,8 @@ public class DevModelController extends BaseController { @OperateInfo(info = LogEnum.BUSINESS_COMMON) @PostMapping("/queryEquipmentByProject") - @ApiOperation("通过项目查询出厂设备") - @ApiImplicitParam(name = "csDevModelQueryListParm", value = "项目信息", required = true) + @ApiOperation("设备模板列表查询") + @ApiImplicitParam(name = "csDevModelQueryListParm", value = "信息", required = true) public HttpResult> queryEquipmentByProject(@RequestBody CsDevModelQueryListParm csDevModelQueryListParm){ String methodDescribe = getMethodDescribe("queryEquipmentByProject"); diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/EngineeringController.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/EngineeringController.java index 2aac52f41..80ce57f75 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/EngineeringController.java +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/project/EngineeringController.java @@ -1,7 +1,9 @@ package com.njcn.algorithm.controller.project; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.njcn.algorithm.pojo.param.CsEngineeringAddParm; import com.njcn.algorithm.pojo.param.CsEngineeringAuditParm; +import com.njcn.algorithm.pojo.param.CsEngineeringQueryPageParm; import com.njcn.algorithm.pojo.param.CsEngineeringQueryParm; import com.njcn.algorithm.pojo.vo.CsEngineeringVO; import com.njcn.algorithm.service.CsEngineeringService; @@ -74,4 +76,15 @@ public class EngineeringController extends BaseController { List csEngineeringVOList = csEngineeringService.queryEngineering(csEngineeringQueryParm); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, csEngineeringVOList, methodDescribe); } + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/queryEngineeringPage") + @ApiOperation("分页查询工程列表") + @ApiImplicitParam(name = "csEngineeringQueryPageParm", value = "修改项目参数", required = true) + public HttpResult> queryEngineeringPage(@Validated @RequestBody CsEngineeringQueryPageParm csEngineeringQueryPageParm){ + String methodDescribe = getMethodDescribe("queryEngineeringPage"); + + IPage page = csEngineeringService.queryEngineeringPage(csEngineeringQueryPageParm); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, page, methodDescribe); + } } diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml index 61a53632b..f0455fb44 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml @@ -29,8 +29,8 @@ AND a.version_date >= #{csDevModelQueryParm.versionStartDate } - - AND a.version_date <= #{csDevModelQueryParm.versionendDate } + + AND a.version_date <= #{csDevModelQueryParm.versionEndDate } @@ -49,8 +49,12 @@ AND a.version_date >= #{csDevModelQueryListParm.versionStartDate } - - AND a.version_date <= #{csDevModelQueryListParm.versionendDate } + + AND a.version_date <= #{csDevModelQueryListParm.versionEndDate } + + + + AND a.version_date = #{csDevModelQueryListParm.versionDate } diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsEquipmentDeliveryMapper.xml b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsEquipmentDeliveryMapper.xml index ad4ba21eb..5d082d682 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsEquipmentDeliveryMapper.xml +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsEquipmentDeliveryMapper.xml @@ -32,15 +32,19 @@ \ No newline at end of file From 709e47c61d7aa6c729c65c3d75f1e40cab746d61 Mon Sep 17 00:00:00 2001 From: huangzj <826100833@qq.com> Date: Mon, 17 Apr 2023 11:11:54 +0800 Subject: [PATCH 06/10] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AD=97=E6=AE=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/algorithm/pojo/param/CsDevModelAddParm.java | 4 ++++ .../algorithm/pojo/param/CsDevModelAuditParm.java | 3 ++- .../algorithm/pojo/param/CsDevModelQueryListParm.java | 6 ++++-- .../algorithm/pojo/param/CsDevModelQueryParm.java | 7 ++++--- .../java/com/njcn/algorithm/pojo/po/CsDevModelPO.java | 6 ++++++ .../com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java | 7 ++++--- .../algorithm/mapper/mapping/CsDevModelMapper.xml | 11 +++++++++-- 7 files changed, 33 insertions(+), 11 deletions(-) diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java index 819163b20..000e18cba 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAddParm.java @@ -27,6 +27,10 @@ public class CsDevModelAddParm { @ApiModelProperty(value = "装置型号") private String devType; + + @ApiModelProperty(value = "模板名称") + private String name; + /** * 版本号 */ diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java index 4039fcbc1..f85358e39 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelAuditParm.java @@ -28,7 +28,8 @@ public class CsDevModelAuditParm { */ @ApiModelProperty(value = "装置型号") private String devType; - + @ApiModelProperty(value = "模板名称") + private String name; /** * 版本号 */ diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java index a049e5724..d97819dd4 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java @@ -23,11 +23,13 @@ public class CsDevModelQueryListParm { /** * 装置型号(字典数据) */ - @ApiModelProperty(value = "装置型号") + @ApiModelProperty(value = "装置模板型号") private String devType; - @ApiModelProperty(value = "装置型号名称") + @ApiModelProperty(value = "装置模板型号名称") private String devName; + @ApiModelProperty(value = "模板名称") + private String name; @ApiModelProperty(value = "版本号") private String versionNo; diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java index d27a5e297..20a97734e 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryParm.java @@ -33,11 +33,12 @@ public class CsDevModelQueryParm { /** * 装置型号(字典数据) */ - @ApiModelProperty(value = "装置型号") + @ApiModelProperty(value = "装置模板型号") private String devType; - @ApiModelProperty(value = "装置名称") + @ApiModelProperty(value = "装置模板型号名称") private String devName; - + @ApiModelProperty(value = "模板名称") + private String name; /** * 版本日期 diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java index 7f68f925c..c6a190ffd 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/po/CsDevModelPO.java @@ -36,6 +36,12 @@ public class CsDevModelPO extends BaseEntity { @TableField(value = "dev_type") private String devType; + /** + * 模板名称 + */ + @TableField(value = "模板名称") + private String name; + /** * 版本号 */ diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java index 36af3db85..8b71e07cb 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java @@ -29,11 +29,12 @@ public class CsDevModelPageVO extends BaseEntity { /** * 设备型号(字典数据) */ - @ApiModelProperty(value = "设备型号") + @ApiModelProperty(value = "设备模板型号id") private String devType; - @ApiModelProperty(value = "设备名称") + @ApiModelProperty(value = "设备模板型号id名称") private String devName; - + @TableField(value = "模板名称") + private String name; /** * 版本号 diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml index e9331ff45..f74fef4ec 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml @@ -39,6 +39,9 @@ AND a.dev_type = #{csDevModelQueryParm.devType} + + AND a.name = #{csDevModelQueryParm.name} + \ No newline at end of file From 460b46adf03bb2cbd2a169b7c23e83899fc990e5 Mon Sep 17 00:00:00 2001 From: zhuxinyu <1799009482@qq.com> Date: Mon, 17 Apr 2023 11:41:35 +0800 Subject: [PATCH 07/10] =?UTF-8?q?=E9=97=AE=E9=A2=98=E5=8D=95=E4=BF=AE?= =?UTF-8?q?=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/CommunicateServiceImpl.java | 4 +-- .../majornetwork/RStatOnlinerateDMapper.java | 23 +++++++++++++++++ .../mapping/RStatOnlinerateDMapper.xml | 25 +++++++++++++++++++ .../Impl/AreaLineServiceImpl.java | 15 ++++++----- .../service/impl/AnalyzeServiceImpl.java | 3 +-- 5 files changed, 60 insertions(+), 10 deletions(-) create mode 100644 pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/RStatOnlinerateDMapper.java create mode 100644 pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/mapping/RStatOnlinerateDMapper.xml diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/CommunicateServiceImpl.java b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/CommunicateServiceImpl.java index 0eb5322d5..6108bfb3c 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/CommunicateServiceImpl.java +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/CommunicateServiceImpl.java @@ -135,7 +135,7 @@ public class CommunicateServiceImpl implements CommunicateService { param.setIds(Arrays.asList(lineList)); param.setStartTime( DateUtil.beginOfDay(DateUtil.parse(startTime)).toString()); param.setEndTime( DateUtil.endOfDay(DateUtil.parse(endTime)).toString()); - if(state == 0){ + if(state == 1){ //在线率 List onlineRateByDevIds = onlinerateDMapper.getOnlineRateByDevIds(param); if (CollUtil.isNotEmpty(onlineRateByDevIds)) { @@ -144,7 +144,7 @@ public class CommunicateServiceImpl implements CommunicateService { resultList[0] = po.getOnlineRate() == null ? null : BigDecimal.valueOf(Float.parseFloat(po.getOnlineRate().toString())).setScale(4, BigDecimal.ROUND_HALF_UP).floatValue(); }); } - }else{ + } else { //数据完整率 List onIntegrityByIds = integrityDMapper.getOnIntegrityByIds(param); if (CollUtil.isNotEmpty(onIntegrityByIds)) { diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/RStatOnlinerateDMapper.java b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/RStatOnlinerateDMapper.java new file mode 100644 index 000000000..c4a64129f --- /dev/null +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/RStatOnlinerateDMapper.java @@ -0,0 +1,23 @@ +package com.njcn.event.mapper.majornetwork; + + + + +import com.njcn.event.pojo.po.PqsOnlinerate; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + *

+ * 在线率日表 Mapper 接口 + *

+ * + * @author hongawen + * @since 2023-03-28 + */ +public interface RStatOnlinerateDMapper { + + + List getOnlineRateByDevIds (@Param("list") List devIds,@Param("startTime") String startTime,@Param("endTime") String endTime); +} diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/mapping/RStatOnlinerateDMapper.xml b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/mapping/RStatOnlinerateDMapper.xml new file mode 100644 index 000000000..b365d243f --- /dev/null +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/mapper/majornetwork/mapping/RStatOnlinerateDMapper.xml @@ -0,0 +1,25 @@ + + + + + diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java index 877336a72..9f55f3c64 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaLineServiceImpl.java @@ -13,8 +13,8 @@ import com.njcn.device.pq.pojo.param.DeviceInfoParam; import com.njcn.device.pq.pojo.vo.AreaLineInfoVO; import com.njcn.device.pq.pojo.vo.LineDeviceStateVO; import com.njcn.device.pq.pojo.vo.SubstationDetailVO; -import com.njcn.event.influxdb.PqsOnlinerateQuery; import com.njcn.event.mapper.majornetwork.PqDeviceMapper; +import com.njcn.event.mapper.majornetwork.RStatOnlinerateDMapper; import com.njcn.event.pojo.po.PqDevice; import com.njcn.event.pojo.po.PqsOnlinerate; import com.njcn.event.pojo.po.RmpEventDetailPO; @@ -63,7 +63,9 @@ public class AreaLineServiceImpl implements AreaLineService { private final InfluxDbUtils influxDbUtils; - private final PqsOnlinerateQuery pqsOnlinerateQuery; + // private final PqsOnlinerateQuery pqsOnlinerateQuery; + + private final RStatOnlinerateDMapper rStatOnlinerateDMapper; private final PqDeviceMapper pqDeviceMapper; private final EventDetailService eventDetailService; @@ -149,7 +151,7 @@ public class AreaLineServiceImpl implements AreaLineService { substationDetailVOList.addAll(substationDetailVOS); if (lineIndexs.size() > 0) { areaLineVO.setSubstationDetailVOList(substationDetailVOList); - objectList.add(generalDeviceDTO.getName() + "\n(" + tail + ")"); + objectList.add(generalDeviceDTO.getName()); objectList.add(tail); objectList.add(stateZc); objectList.add(stateZd); @@ -296,9 +298,10 @@ public class AreaLineServiceImpl implements AreaLineService { return TerminalRunningVO.empty(); } - List pqsOnlinerateList = pqsOnlinerateQuery.selectList(Arrays.asList("dev_id", "offlinemin", "onlinemin"), - devIdOr(deviceIndexList), - timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime()))); +// List pqsOnlinerateList = pqsOnlinerateQuery.selectList(Arrays.asList("dev_id", "offlinemin", "onlinemin"), +// devIdOr(deviceIndexList), +// timeAnd(beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime()))); + List pqsOnlinerateList = rStatOnlinerateDMapper.getOnlineRateByDevIds(deviceIndexList,beginOfDay(deviceInfoParam.getSearchBeginTime()), endOfDay(deviceInfoParam.getSearchEndTime())); List pqDeviceList = pqDeviceMapper.queryRunFlagByDeviceIndexs(deviceIndexList); diff --git a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java index ee3229b4d..3f5462ae1 100644 --- a/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java +++ b/pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/AnalyzeServiceImpl.java @@ -38,14 +38,12 @@ import com.njcn.poi.excel.ExcelUtil; import com.njcn.web.utils.RequestUtil; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.beanutils.BeanUtils; import org.influxdb.dto.QueryResult; import org.influxdb.impl.InfluxDBResultMapper; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import java.io.File; -import java.lang.reflect.Array; import java.math.BigDecimal; import java.math.RoundingMode; import java.time.Instant; @@ -303,6 +301,7 @@ public class AnalyzeServiceImpl implements IAnalyzeService { list.addAll(monMap.keySet()); PollutionParamDTO pollutionParamDTO = new PollutionParamDTO(); pollutionParamDTO.setLineList(list); +// List data = lineFeignClient.getBaseLineAreaInfo(list).getData(); List overLimitLineList = lineFeignClient.getOverLimitLineInfo(pollutionParamDTO).getData(); List rStatLimitRateDPOS = rateDMapper.selectList(new QueryWrapper() .in("r_stat_limit_rate_d.my_index", list) From 8e263ad50a2ba2a3416268ce17b4c09d3992586d Mon Sep 17 00:00:00 2001 From: huangzj <826100833@qq.com> Date: Mon, 17 Apr 2023 14:14:56 +0800 Subject: [PATCH 08/10] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pojo/param/CsDevModelQueryListParm.java | 24 +++++++++---------- .../algorithm/pojo/vo/CsDevModelPageVO.java | 7 +++--- .../Equipment/DevModelController.java | 12 ++++------ .../algorithm/mapper/CsDevModelMapper.java | 4 +--- .../mapper/mapping/CsDevModelMapper.xml | 14 +++++------ .../algorithm/service/CsDevModelService.java | 11 +++++---- .../service/impl/CsDevModelServiceImpl.java | 14 ++++++----- 7 files changed, 42 insertions(+), 44 deletions(-) diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java index d97819dd4..64d0c377d 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/param/CsDevModelQueryListParm.java @@ -33,18 +33,18 @@ public class CsDevModelQueryListParm { @ApiModelProperty(value = "版本号") private String versionNo; - /** - * 版本日期 - */ - @ApiModelProperty(value = "版本日期") - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") - @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") - private String versionStartDate; - - @ApiModelProperty(value = "版本日期") - @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") - @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") - private String versionEndDate; +// /** +// * 版本日期 +// */ +// @ApiModelProperty(value = "版本日期") +// @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") +// @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") +// private String versionStartDate; +// +// @ApiModelProperty(value = "版本日期") +// @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") +// @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone = "GMT+8") +// private String versionEndDate; @ApiModelProperty(value = "版本准确日期") @DateTimeFormat(pattern="yyyy-MM-dd HH:mm:ss") diff --git a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java index 8b71e07cb..97f7c5b72 100644 --- a/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java +++ b/pqs-algorithm/algorithm-api/src/main/java/com/njcn/algorithm/pojo/vo/CsDevModelPageVO.java @@ -1,6 +1,5 @@ package com.njcn.algorithm.pojo.vo; -import com.baomidou.mybatisplus.annotation.TableField; import com.njcn.db.bo.BaseEntity; import io.swagger.annotations.ApiModelProperty; import lombok.Data; @@ -33,7 +32,7 @@ public class CsDevModelPageVO extends BaseEntity { private String devType; @ApiModelProperty(value = "设备模板型号id名称") private String devName; - @TableField(value = "模板名称") + @ApiModelProperty(value = "模板名称") private String name; /** @@ -52,13 +51,13 @@ public class CsDevModelPageVO extends BaseEntity { /** * 装置模板文件路径 */ - @TableField(value = "file_path") + @ApiModelProperty(value = "file_path") private String filePath; /** * 状态(0：删除 1：正常) */ - @TableField(value = "status") + @ApiModelProperty(value = "status") private String status; } \ No newline at end of file diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java index 7546bd1b2..231454acb 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/controller/Equipment/DevModelController.java @@ -24,8 +24,6 @@ import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; -import java.util.List; - /** * Description: * 接口文档访问地址：http://serverIP:port/swagger-ui.html @@ -80,14 +78,14 @@ public class DevModelController extends BaseController { } @OperateInfo(info = LogEnum.BUSINESS_COMMON) - @PostMapping("/queryEquipmentByProject") + @PostMapping("/queryDevModelOne") @ApiOperation("设备模板列表查询") @ApiImplicitParam(name = "csDevModelQueryListParm", value = "信息", required = true) - public HttpResult> queryEquipmentByProject(@RequestBody CsDevModelQueryListParm csDevModelQueryListParm){ - String methodDescribe = getMethodDescribe("queryEquipmentByProject"); + public HttpResult queryDevModelOne(@RequestBody CsDevModelQueryListParm csDevModelQueryListParm){ + String methodDescribe = getMethodDescribe("queryDevModelOne"); - List list = csDevModelService.queryList(csDevModelQueryListParm); - return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe); + CsDevModelPageVO csDevModelPageVO = csDevModelService.queryDevModelOne(csDevModelQueryListParm); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, csDevModelPageVO, methodDescribe); } diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/CsDevModelMapper.java b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/CsDevModelMapper.java index 72782f51e..54350e376 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/CsDevModelMapper.java +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/CsDevModelMapper.java @@ -8,8 +8,6 @@ import com.njcn.algorithm.pojo.po.CsDevModelPO; import com.njcn.algorithm.pojo.vo.CsDevModelPageVO; import org.apache.ibatis.annotations.Param; -import java.util.List; - /** * * Description: @@ -22,5 +20,5 @@ import java.util.List; public interface CsDevModelMapper extends BaseMapper { Page getPage(Page returnpage,@Param("csDevModelQueryParm") CsDevModelQueryParm csDevModelQueryParm); - List queryList(@Param("csDevModelQueryListParm")CsDevModelQueryListParm csDevModelQueryListParm); + CsDevModelPageVO queryOne(@Param("csDevModelQueryListParm")CsDevModelQueryListParm csDevModelQueryListParm); } \ No newline at end of file diff --git a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml index f74fef4ec..32c28537e 100644 --- a/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml +++ b/pqs-algorithm/algorithm-boot/src/main/java/com/njcn/algorithm/mapper/mapping/CsDevModelMapper.xml @@ -42,19 +42,19 @@ AND a.name = #{csDevModelQueryParm.name} -