From c1d68009ca027733b8e25e3a9e9b4d5668cb8655 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com> Date: Thu, 25 Jan 2024 08:34:21 +0800 Subject: [PATCH] =?UTF-8?q?1.pmsBug=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../njcn/device/pms/pojo/po/PmsTerminal.java | 39 +++++++++++- .../majornetwork/mapping/TerminalMapper.xml | 3 +- .../impl/RStatDevSignalDServiceImpl.java | 60 +------------------ .../com/njcn/event/pojo/vo/RStatOrgVO.java | 4 +- ...ticsOfTransientIndicatorssServiceImpl.java | 8 +-- .../src/main/resources/bootstrap.yml | 2 +- 6 files changed, 47 insertions(+), 69 deletions(-) diff --git a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/PmsTerminal.java b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/PmsTerminal.java index 2d5e07f7e..09a42defa 100644 --- a/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/PmsTerminal.java +++ b/pqs-device/pms-device/pms-device-api/src/main/java/com/njcn/device/pms/pojo/po/PmsTerminal.java @@ -1,11 +1,19 @@ package com.njcn.device.pms.pojo.po; +import com.baomidou.mybatisplus.annotation.FieldFill; +import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.databind.annotation.JsonDeserialize; +import com.fasterxml.jackson.databind.annotation.JsonSerialize; +import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer; +import com.fasterxml.jackson.datatype.jsr310.ser.LocalDateTimeSerializer; import com.njcn.db.bo.BaseEntity; import lombok.Data; import lombok.EqualsAndHashCode; import java.time.LocalDate; +import java.time.LocalDateTime; /** *

@@ -16,9 +24,8 @@ import java.time.LocalDate; * @since 2022-10-14 */ @Data -@EqualsAndHashCode(callSuper = true) @TableName("pms_terminal") -public class PmsTerminal extends BaseEntity { +public class PmsTerminal{ private static final long serialVersionUID = 1L; @@ -132,4 +139,32 @@ public class PmsTerminal extends BaseEntity { * 中台终端编号 */ private String terminalCode; + + + /** + * 创建用户 + */ + @TableField(fill = FieldFill.INSERT) + private String createBy; + + + /** + * 创建时间 + */ + @TableField(fill = FieldFill.INSERT) + @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") + @JsonDeserialize(using = LocalDateTimeDeserializer.class) + @JsonSerialize(using = LocalDateTimeSerializer.class) + private LocalDateTime createTime; + + /** + * 更新用户 + */ + @TableField(fill = FieldFill.INSERT_UPDATE) + private String updateBy; + + /** + * 更新时间 + */ + private LocalDateTime updateTime; } diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml index ed58c44b6..cde493236 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/majornetwork/mapping/TerminalMapper.xml @@ -9,7 +9,7 @@ diff --git a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatDevSignalDServiceImpl.java b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatDevSignalDServiceImpl.java index a93c551bc..9f09fdf7c 100644 --- a/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatDevSignalDServiceImpl.java +++ b/pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/service/majornetwork/impl/RStatDevSignalDServiceImpl.java @@ -48,9 +48,6 @@ public class RStatDevSignalDServiceImpl extends ServiceImpl getRStatDevSignalList(RStatDevSignalParam rStatDevSignalParam) { //提取查询条件 String id = rStatDevSignalParam.getId(); //单位id - String deviceName = rStatDevSignalParam.getDeviceName(); //终端名称 - String deviceStatus = rStatDevSignalParam.getDeviceStatus(); //终端状态 - String runStatus = rStatDevSignalParam.getRunStatus(); //运行状态 if (StringUtils.isBlank(id)) { throw new BusinessException(CommonResponseEnum.NO_DATA, "单位id不可为空"); @@ -58,69 +55,14 @@ public class RStatDevSignalDServiceImpl extends ServiceImpl deptDTOList = deptFeignClient.getDeptDescendantIndexes(id, WebUtil.filterDeptType()).getData(); -// /*获取下一级子部门信息*/ -// List deptDTOList = deptFeignClient.getDepSonDetailByDeptId (id).getData ( ); + if (CollUtil.isEmpty(deptDTOList)) { throw new BusinessException(CommonResponseEnum.NO_DATA, "部门不存在"); } //单位id集合 List orgCodeList = deptDTOList.stream().map(DeptDTO::getCode).collect(Collectors.toList()); return terminalMapper.selectTerminalList(orgCodeList, rStatDevSignalParam); - /* - //查询终端数据 - LambdaQueryWrapper terminalWrapper = new LambdaQueryWrapper<>(); - terminalWrapper.in(PmsTerminal::getOrgId, orgCodeList) - .eq(PmsTerminal::getStatus, DataStateEnum.ENABLE.getCode()) - .like(StringUtils.isNotBlank(deviceName), PmsTerminal::getName, deviceName); - List terminalList = iTerminalService.list(terminalWrapper); - //提取终端id - List terminalIdList = terminalList.stream().map(PmsTerminal::getId).collect(Collectors.toList()); - //将终端信息转为map集合 key: 终端id value: 终端实体 - Map terminalMap = terminalList.stream().collect(Collectors.toMap(PmsTerminal::getId, terminal -> terminal)); - if (CollUtil.isEmpty(terminalIdList)) { - return new ArrayList<>(); - } - //查询业务数据 - LambdaQueryWrapper businessWrapper = new LambdaQueryWrapper<>(); - businessWrapper.in(RStatDevSignalD::getDeviceId, terminalIdList) - .eq(StringUtils.isNotBlank(deviceStatus), RStatDevSignalD::getDeviceStatus, deviceStatus) - .eq(StringUtils.isNotBlank(runStatus), RStatDevSignalD::getRunStatus, runStatus); - List list = this.list(businessWrapper); - //封装返回数据 - List resultList = list.stream().map(item -> { - RStatDevSignalVO rStatDevSignalVO = new RStatDevSignalVO(); - BeanUtils.copyProperties(item, rStatDevSignalVO); //设备状态、运行状态、最后通讯时间(更新时间) - rStatDevSignalVO.setTerminalId(item.getDeviceId()); //终端id(终端编号) - rStatDevSignalVO.setOrgId(terminalMap.get(item.getDeviceId()).getOrgId()); //单位id - rStatDevSignalVO.setOrgName(terminalMap.get(item.getDeviceId()).getOrgName()); //单位名称 - rStatDevSignalVO.setTerminalName(terminalMap.get(item.getDeviceId()).getName()); //终端名称 - rStatDevSignalVO.setIp(terminalMap.get(item.getDeviceId()).getIp()); //ip - rStatDevSignalVO.setPort(terminalMap.get(item.getDeviceId()).getPort()); //端口 - return rStatDevSignalVO; - }).collect(Collectors.toList()); - Map signalMap = list.stream().collect(Collectors.toMap(RStatDevSignalD::getDeviceId, Function.identity(),(key1, key2)->key1)); - - List notList = terminalList.stream().filter(r -> !signalMap.containsKey(r.getId())) - .collect(Collectors.toList()); - if(CollectionUtil.isNotEmpty(notList)){ - RStatDevSignalVO rStatDevSignalVO ; - for (PmsTerminal terminal : notList) { - rStatDevSignalVO = new RStatDevSignalVO(); - rStatDevSignalVO.setTerminalId(terminal.getId()); - rStatDevSignalVO.setOrgId(terminal.getOrgId()); - rStatDevSignalVO.setOrgName(terminal.getOrgName()); - rStatDevSignalVO.setTerminalName(terminal.getName()); - rStatDevSignalVO.setDeviceStatus("/"); - rStatDevSignalVO.setRunStatus("/"); - rStatDevSignalVO.setIp(terminal.getIp()); - rStatDevSignalVO.setPort(terminal.getPort()); - rStatDevSignalVO.setUpdateTime("/"); - resultList.add(rStatDevSignalVO); - } - } - return resultList; - */ } } diff --git a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatOrgVO.java b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatOrgVO.java index d49d1de7d..f1498841d 100644 --- a/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatOrgVO.java +++ b/pqs-event/event-api/src/main/java/com/njcn/event/pojo/vo/RStatOrgVO.java @@ -110,4 +110,6 @@ public class RStatOrgVO implements Serializable { @ApiModelProperty(name = "dataType",value = "数据类型（01：主网测点 02：配网测点）") private String dataType; -} \ No newline at end of file + private Integer sort; + +} diff --git a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/StatisticsOfTransientIndicatorssServiceImpl.java b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/StatisticsOfTransientIndicatorssServiceImpl.java index 5a552eba2..bcd5d0331 100644 --- a/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/StatisticsOfTransientIndicatorssServiceImpl.java +++ b/pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/StatisticsOfTransientIndicatorssServiceImpl.java @@ -30,10 +30,7 @@ import org.apache.commons.lang.StringUtils; import org.springframework.stereotype.Service; import java.text.DecimalFormat; -import java.util.ArrayList; -import java.util.Collections; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.stream.Collectors; /** @@ -126,7 +123,8 @@ public class StatisticsOfTransientIndicatorssServiceImpl implements StatisticsOf Map deptDTOMap = deptDTOList.stream().collect(Collectors.toMap(DeptDTO::getCode, DeptDTO -> DeptDTO)); return result.stream().peek(vo -> { vo.setOrgName(deptDTOMap.get(vo.getOrgNo()).getName()); - }).collect(Collectors.toList()); + vo.setSort(deptDTOMap.get(vo.getOrgNo()).getSort()); + }).sorted(Comparator.comparing(RStatOrgVO::getSort)).collect(Collectors.toList()); } diff --git a/pqs-harmonic/harmonic-boot/src/main/resources/bootstrap.yml b/pqs-harmonic/harmonic-boot/src/main/resources/bootstrap.yml index 13099624e..9c15bf1b6 100644 --- a/pqs-harmonic/harmonic-boot/src/main/resources/bootstrap.yml +++ b/pqs-harmonic/harmonic-boot/src/main/resources/bootstrap.yml @@ -31,7 +31,7 @@ spring: - data-id: share-config.yaml refresh: true # - data-Id: share-config-datasource-db.yaml - - data-Id: share-config-harmonic-db2.yaml + - data-Id: share-config-harmonic-db.yaml refresh: true main: allow-bean-definition-overriding: true