From e4e8e991ccfa2531b066011fcc0ec248ecdf108b Mon Sep 17 00:00:00 2001 From: zhuxinyu <1799009482@qq.com> Date: Thu, 20 Apr 2023 15:33:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=A5=E5=91=8A=E6=A8=A1=E7=89=88=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E8=81=94=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../pq/pojo/vo/LineFlowMealDetailVO.java | 10 ++-- .../device/pq/mapper/mapping/LineMapper.xml | 9 ++-- .../mapper/RStatLimitTargetMapper.java | 2 +- .../mapper/mapping/RStatLimitTargetMapper.xml | 2 +- .../service/impl/AnalyzeServiceImpl.java | 12 ++--- .../system/pojo/param/EventDictParam.java | 6 ++- .../com/njcn/system/pojo/po/ReportDict.java | 2 + .../system/pojo/vo/EventReportDictVO.java | 3 ++ .../controller/EventDictController.java | 22 ++++++-- .../njcn/system/mapper/EventDictMapper.java | 3 +- .../system/mapper/mapping/EventDictMapper.xml | 2 +- .../system/service/IEventDictService.java | 5 +- .../service/impl/EventDictServiceImpl.java | 53 +++++++++++++++++-- 13 files changed, 104 insertions(+), 27 deletions(-) diff --git a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/LineFlowMealDetailVO.java b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/LineFlowMealDetailVO.java index eafe56b68..cbdf9f670 100644 --- a/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/LineFlowMealDetailVO.java +++ b/pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/LineFlowMealDetailVO.java @@ -20,20 +20,20 @@ public class LineFlowMealDetailVO implements Serializable { private String id; @ApiModelProperty("监测点对应的设备id") - private String DeviceId; + private String deviceId; @ApiModelProperty("监测点对应的设备名称") - private String DeviceName; + private String deviceName; @ApiModelProperty("监测点对应的设备IP") - private String DeviceIP; + private String deviceIP; @ApiModelProperty("供电公司") - private String ElectricPowerCompany; + private String electricPowerCompany; @ApiModelProperty("变电站") - private String Substation; + private String substation; @ApiModelProperty("pid") private String pid; diff --git a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml index fc3b8cbca..5116d1a42 100644 --- a/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml +++ b/pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml @@ -842,17 +842,20 @@ + - SELECT * from report_dict WHERE State = 1 + SELECT * from report_dict WHERE State = 1 AND Type = #{type} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventDictService.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventDictService.java index 7d133905f..b523806a9 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventDictService.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/IEventDictService.java @@ -40,6 +40,8 @@ public interface IEventDictService { */ Page getList(EventDictParam.DictQueryParam dictQueryParam); + List getReportDictList (EventDictParam.DictQueryParam dictQueryParam); + /** * 查询字典 * @param id @@ -50,6 +52,7 @@ public interface IEventDictService { /** * 获取字典树 * @return + * @param type */ - List getDictTree(); + List getDictTree(String type); } diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java index 619d3fd3e..e313206c8 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/EventDictServiceImpl.java @@ -26,6 +26,7 @@ import org.springframework.stereotype.Service; import java.util.ArrayList; import java.util.List; +import java.util.Map; import java.util.Objects; import java.util.stream.Collectors; @@ -101,7 +102,7 @@ public class EventDictServiceImpl extends ServiceImpl getList(EventDictParam.DictQueryParam dictQueryParam){ + public Page getList (EventDictParam.DictQueryParam dictQueryParam) { QueryWrapper queryWrapper = new QueryWrapper<>(); if (Objects.nonNull(dictQueryParam)) { //查询参数不为空,进行条件填充 @@ -124,6 +125,51 @@ public class EventDictServiceImpl extends ServiceImpl(PageFactory.getPageNum(dictQueryParam),PageFactory.getPageSize(dictQueryParam)),queryWrapper); } + public List getReportDictList (EventDictParam.DictQueryParam dictQueryParam) { + QueryWrapper queryWrapper = new QueryWrapper<>(); + if (Objects.nonNull(dictQueryParam)) { + //查询参数不为空,进行条件填充 + if (StrUtil.isNotBlank(dictQueryParam.getSearchValue())) { + //字典类型表,提供名称、编码模糊查询 + queryWrapper + .and(param -> param.like("report_dict.name",dictQueryParam.getSearchValue()) + .or().like("report_dict.report_describe",dictQueryParam.getSearchValue())); + } + //排序 + if (ObjectUtil.isAllNotEmpty(dictQueryParam.getSortBy(), dictQueryParam.getOrderBy())) { + queryWrapper.orderBy(true, dictQueryParam.getOrderBy().equals(DbConstant.ASC), StrUtil.toUnderlineCase(dictQueryParam.getSortBy())); + } else { + //没有排序参数,默认根据sort字段排序,没有排序字段的,根据updateTime更新时间排序 + queryWrapper.orderBy(true, true, "report_dict.update_time"); + } + } + queryWrapper.eq("report_dict.state", DataStateEnum.ENABLE.getCode()); + List reportAllDicts = this.baseMapper.selectList(queryWrapper); + List reportDicts = new ArrayList<>(); + reportAllDicts.stream().filter(reportDict -> reportDict.getId().equals(dictQueryParam.getId())).forEach(reportDict -> { + reportDicts.add(reportDict); + getChild(reportDicts, reportDict, reportAllDicts); + }); + Map map = reportAllDicts.stream().collect(Collectors.toMap(ReportDict::getId, ReportDict::getName)); + List list = new ArrayList<>(); + reportDicts.forEach(dict -> { + EventReportDictVO dictVO = new EventReportDictVO(); + BeanUtil.copyProperties(dict, dictVO); + dictVO.setPidName(map.get(dict.getPid())); + list.add(dictVO); + }); + return list; + } + + private void getChild(List reportDicts, ReportDict reportDict, List reportAllDicts) { + for (ReportDict dict : reportAllDicts) { + if (dict.getPid().equals(reportDict.getId())) { + reportDicts.add(dict); + getChild(reportDicts,dict,reportAllDicts); + } + } + } + /** * 查询字典 * @param id @@ -137,11 +183,12 @@ public class EventDictServiceImpl extends ServiceImpl getDictTree() { + public List getDictTree(String type) { List list = new ArrayList<>(); - List dictList = eventDictMapper.getAllDict(); + List dictList = eventDictMapper.getAllDict(type); dictList.forEach(item -> { EventReportDictVO dictVO = new EventReportDictVO(); BeanUtil.copyProperties(item, dictVO);