diff --git a/mh-admin/src/main/java/com/mh/web/controller/comprehensive/ProOverviewController.java b/mh-admin/src/main/java/com/mh/web/controller/comprehensive/ProOverviewController.java index 4f0030c..0eae057 100644 --- a/mh-admin/src/main/java/com/mh/web/controller/comprehensive/ProOverviewController.java +++ b/mh-admin/src/main/java/com/mh/web/controller/comprehensive/ProOverviewController.java @@ -47,7 +47,7 @@ public class ProOverviewController extends BaseController { * 头像上传 */ @Log(title = "项目图标", businessType = BusinessType.UPDATE) - @PutMapping("/logo") + @PostMapping("/logo") public AjaxResult avatar(@RequestParam("logo") MultipartFile file, @RequestParam("proId") String proId) throws Exception { if (!file.isEmpty()) diff --git a/mh-common/src/main/java/com/mh/common/core/domain/vo/CollectionParamsManageVO.java b/mh-common/src/main/java/com/mh/common/core/domain/vo/CollectionParamsManageVO.java index e2f624c..ff5b115 100644 --- a/mh-common/src/main/java/com/mh/common/core/domain/vo/CollectionParamsManageVO.java +++ b/mh-common/src/main/java/com/mh/common/core/domain/vo/CollectionParamsManageVO.java @@ -34,6 +34,16 @@ public class CollectionParamsManageVO { private String paramType; + /** + * 台账排序 + */ + private int dlOrderNum; + + /** + * 采集参数排序 + */ + private int cmpOrderNum; + @Override public String toString() { return new ToStringBuilder(this) @@ -45,7 +55,8 @@ public class CollectionParamsManageVO { .append("curValue", curValue) .append("curTime", curTime) .append("paramType", paramType) + .append("dlOrderNum", dlOrderNum) + .append("cmpOrderNum", cmpOrderNum) .toString(); } - } diff --git a/mh-common/src/main/java/com/mh/common/core/domain/vo/DeviceOperateMonitorVO.java b/mh-common/src/main/java/com/mh/common/core/domain/vo/DeviceOperateMonitorVO.java index 88a8138..ff3cb04 100644 --- a/mh-common/src/main/java/com/mh/common/core/domain/vo/DeviceOperateMonitorVO.java +++ b/mh-common/src/main/java/com/mh/common/core/domain/vo/DeviceOperateMonitorVO.java @@ -43,6 +43,8 @@ public class DeviceOperateMonitorVO { private String paramType; + private int orderNum; + private List children; @Override @@ -53,6 +55,7 @@ public class DeviceOperateMonitorVO { .append("value", value) .append("time", time) .append("paramType", paramType) + .append("orderNum", orderNum) .append("children", children) .toString(); } diff --git a/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java b/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java index 56ea0e7..5c39198 100644 --- a/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java +++ b/mh-system/src/main/java/com/mh/system/mapper/device/CollectionParamsManageMapper.java @@ -171,7 +171,9 @@ public interface CollectionParamsManageMapper extends BaseMapper selectBySystemType(@Param("systemType") String systemType); @Select("select " + diff --git a/mh-system/src/main/java/com/mh/system/mapper/device/DataProcessMapper.java b/mh-system/src/main/java/com/mh/system/mapper/device/DataProcessMapper.java index acff0aa..5d90248 100644 --- a/mh-system/src/main/java/com/mh/system/mapper/device/DataProcessMapper.java +++ b/mh-system/src/main/java/com/mh/system/mapper/device/DataProcessMapper.java @@ -132,19 +132,19 @@ public interface DataProcessMapper { void insertTable(@Param("data") DeviceReport data, @Param("tableName") String tableName); @Update("update ${tableName} set cur_time = #{data.curTime},cur_value = #{data.curValue},calc_value = (#{data.curValue} - last_value)*ratio,used_value = #{data.curValue} - last_value " + - "where device_num = #{data.deviceNum} and EXTRACT(MONTH FROM AGE(cur_time, #{curTime})) = 0 ") + "where device_num = #{data.deviceNum} and EXTRACT(MONTH FROM AGE(cur_time, #{data.curTime})) = 0 ") void updateTableMM(@Param("data") DeviceReport data, @Param("tableName") String tableName); @Update("update ${tableName} set cur_time = #{data.curTime},cur_value = #{data.curValue},calc_value = (#{data.curValue} - last_value)*ratio,used_value = #{data.curValue} - last_value " + - "where device_num = #{data.deviceNum} and EXTRACT(YEAR FROM AGE(cur_time, #{curTime})) = 0 ") + "where device_num = #{data.deviceNum} and EXTRACT(YEAR FROM AGE(cur_time, #{data.curTime})) = 0 ") void updateTableYY(@Param("data") DeviceReport data, @Param("tableName") String tableName); @Update("update ${tableName} set cur_time = #{data.curTime},cur_value = #{data.curValue},calc_value = (#{data.curValue} - last_value)*ratio,used_value = #{data.curValue} - last_value " + - "where device_num = #{data.deviceNum} and EXTRACT(DAY FROM AGE(cur_time, #{curTime})) = 0 ") + "where device_num = #{data.deviceNum} and EXTRACT(DAY FROM AGE(cur_time, #{data.curTime})) = 0 ") void updateTableDD(@Param("data") DeviceReport data, @Param("tableName") String tableName); @Update("update ${tableName} set cur_time = #{data.curTime},cur_value = #{data.curValue},calc_value = (#{data.curValue} - last_value)*ratio,used_value = #{data.curValue} - last_value " + - "where device_num = #{data.deviceNum} and EXTRACT(HOUR FROM AGE(cur_time, #{curTime})) = 0 ") + "where device_num = #{data.deviceNum} and EXTRACT(HOUR FROM AGE(cur_time, #{data.curTime})) = 0 ") void updateTableHH(@Param("data") DeviceReport data, @Param("tableName") String tableName); /** diff --git a/mh-system/src/main/java/com/mh/system/service/device/impl/CollectionParamsManageServiceImpl.java b/mh-system/src/main/java/com/mh/system/service/device/impl/CollectionParamsManageServiceImpl.java index 4a768f8..6988fed 100644 --- a/mh-system/src/main/java/com/mh/system/service/device/impl/CollectionParamsManageServiceImpl.java +++ b/mh-system/src/main/java/com/mh/system/service/device/impl/CollectionParamsManageServiceImpl.java @@ -264,6 +264,7 @@ public class CollectionParamsManageServiceImpl implements ICollectionParamsManag // 根据deviceLedgerId进行分组,然后得出deviceLedgerId,deviceName赋值给DeviceOperateMonitorVO的id和name // 按设备台账ID分组 Map> groupedByDevice = collectionParamsManages.stream() + .sorted(Comparator.comparing(CollectionParamsManageVO::getDlOrderNum)) .collect(Collectors.groupingBy(CollectionParamsManageVO::getDeviceLedgerId)); // 转换分组结果为监控VO列表 @@ -275,12 +276,13 @@ public class CollectionParamsManageServiceImpl implements ICollectionParamsManag DeviceOperateMonitorVO vo = new DeviceOperateMonitorVO(); vo.setId(firstItem.getDeviceLedgerId()); vo.setName(firstItem.getDeviceName()); + vo.setOrderNum(firstItem.getDlOrderNum()); // 可补充其他需要聚合的字段 // vo.setStatus(calculateStatus(group)); - return vo; }) + .sorted(Comparator.comparing(DeviceOperateMonitorVO::getOrderNum)) .toList(); // 在遍历monitorData,根据deviceLedgerId查询出collectionParamsManages集合对应的设备id,otherName对应name,curValue对应value,curTime对应time,paramType对应paramType,然后拼接到monitorData中children中 // 处理子节点数据 @@ -295,8 +297,10 @@ public class CollectionParamsManageServiceImpl implements ICollectionParamsManag child.setValue(String.valueOf(param.getCurValue())); child.setTime(param.getCurTime()); child.setParamType(param.getParamType()); + child.setOrderNum(param.getCmpOrderNum()); return child; }) + .sorted(Comparator.comparing(DeviceOperateMonitorVO::getOrderNum)) .collect(Collectors.toList()); mainVO.setChildren(children); }); diff --git a/mh-system/src/main/resources/mapper/system/SysParamsMapper.xml b/mh-system/src/main/resources/mapper/system/SysParamsMapper.xml index bff5afb..e4d98bb 100644 --- a/mh-system/src/main/resources/mapper/system/SysParamsMapper.xml +++ b/mh-system/src/main/resources/mapper/system/SysParamsMapper.xml @@ -20,7 +20,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"