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);