1.代码调整

This commit is contained in:
wr
2024-02-19 15:02:29 +08:00
parent 06c2cf095c
commit 0bee509621
4 changed files with 29 additions and 10 deletions

View File

@@ -164,11 +164,7 @@ public class PmsStatationStatController extends BaseController {
public HttpResult<List<StatationStat>> getPowerInfo(@RequestBody PmsStatationStatInfoParam param) { public HttpResult<List<StatationStat>> getPowerInfo(@RequestBody PmsStatationStatInfoParam param) {
String methodDescribe = getMethodDescribe("getStatationStatInfo"); String methodDescribe = getMethodDescribe("getStatationStatInfo");
List<StatationStat> powerInfo = statationStatService.getPowerInfo(param); List<StatationStat> powerInfo = statationStatService.getPowerInfo(param);
if (CollectionUtil.isEmpty(powerInfo)) { return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, powerInfo, methodDescribe);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.NO_DATA, null, methodDescribe);
} else {
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, powerInfo, methodDescribe);
}
} }
/** /**

View File

@@ -2,6 +2,7 @@ package com.njcn.device.pms.service.majornetwork.impl;
import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.NumberUtil;
import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.njcn.common.pojo.dto.SimpleDTO; import com.njcn.common.pojo.dto.SimpleDTO;
@@ -104,10 +105,11 @@ public class RMpDevEvaluateDetailServiceImpl extends ServiceImpl<RMpDevEvaluateD
//封装返回数据 //封装返回数据
DecimalFormat df = new DecimalFormat("###.00"); DecimalFormat df = new DecimalFormat("###.00");
List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>(); List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>();
String time = time(startTime, rMpDevEvaluateDetailParam.getType());
terminalListMapByOrgId.forEach((key, terminalListByOrg) -> { terminalListMapByOrgId.forEach((key, terminalListByOrg) -> {
RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO(); RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO();
rMpDevEvaluateDetailVO.setDataDate(startTime); //日期(前端传递的时间) rMpDevEvaluateDetailVO.setDataDate(time); //日期(前端传递的时间)
rMpDevEvaluateDetailVO.setOrgId(key); //单位id(字段是id实际数据是单位code) rMpDevEvaluateDetailVO.setOrgId(key); //单位id(字段是id实际数据是单位code)
rMpDevEvaluateDetailVO.setOrgName(terminalListByOrg.get(0).getOrgName()); //单位名称 rMpDevEvaluateDetailVO.setOrgName(terminalListByOrg.get(0).getOrgName()); //单位名称
@@ -179,10 +181,11 @@ public class RMpDevEvaluateDetailServiceImpl extends ServiceImpl<RMpDevEvaluateD
//封装返回数据 //封装返回数据
DecimalFormat df = new DecimalFormat("###.00"); DecimalFormat df = new DecimalFormat("###.00");
List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>(); List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>();
String time = time(startTime, rMpDevEvaluateDetailParam.getType());
terminalListMapByManufacture.forEach((key, terminalListByManufacture) -> { terminalListMapByManufacture.forEach((key, terminalListByManufacture) -> {
RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO(); RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO();
rMpDevEvaluateDetailVO.setDataDate(startTime); //日期(前端传递的时间) rMpDevEvaluateDetailVO.setDataDate(time); //日期(前端传递的时间)
rMpDevEvaluateDetailVO.setManufactureId(key); //厂商id rMpDevEvaluateDetailVO.setManufactureId(key); //厂商id
//终端有效接入率 //终端有效接入率
@@ -248,10 +251,11 @@ public class RMpDevEvaluateDetailServiceImpl extends ServiceImpl<RMpDevEvaluateD
//封装返回数据 //封装返回数据
DecimalFormat df = new DecimalFormat("###.00"); DecimalFormat df = new DecimalFormat("###.00");
List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>(); List<RMpDevEvaluateDetailVO> resultList = new ArrayList<>();
String time = time(startTime, rMpDevEvaluateDetailParam.getType());
terminalListMapByModel.forEach((key, terminalListByModel) -> { terminalListMapByModel.forEach((key, terminalListByModel) -> {
RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO(); RMpDevEvaluateDetailVO rMpDevEvaluateDetailVO = new RMpDevEvaluateDetailVO();
rMpDevEvaluateDetailVO.setDataDate(startTime); //日期(前端传递的时间) rMpDevEvaluateDetailVO.setDataDate(time); //日期(前端传递的时间)
rMpDevEvaluateDetailVO.setDeviceModel(key); //终端型号 rMpDevEvaluateDetailVO.setDeviceModel(key); //终端型号
//终端有效接入率 //终端有效接入率
@@ -277,6 +281,17 @@ public class RMpDevEvaluateDetailServiceImpl extends ServiceImpl<RMpDevEvaluateD
return resultList; return resultList;
} }
private String time(String starTime,Integer type){
if(ObjectUtil.isNull(type)){
return starTime;
}else{
if(type==1){
return starTime.substring(0,4);
}else {
return starTime.substring(0,7);
}
}
}
} }

View File

@@ -3,7 +3,9 @@ package com.njcn.harmonic.pojo.vo;
import io.swagger.annotations.ApiModelProperty; import io.swagger.annotations.ApiModelProperty;
import lombok.Data; import lombok.Data;
import java.util.Comparator;
import java.util.List; import java.util.List;
import java.util.stream.Collectors;
/** /**
* 类的介绍: * 类的介绍:
@@ -32,4 +34,9 @@ public class PollutionVO {
@ApiModelProperty("子级") @ApiModelProperty("子级")
private List<PollutionVO> children; private List<PollutionVO> children;
public void setChildren(List<PollutionVO> children) {
List<PollutionVO> listSort = children.stream().filter(x -> x.getData() != 3.14159).sorted(Comparator.comparing(PollutionVO::getData).reversed().thenComparing(PollutionVO::getName)).collect(Collectors.toList());
listSort.addAll(children.stream().filter(x -> x.getData() == 3.14159).collect(Collectors.toList()));
this.children = listSort;
}
} }

View File

@@ -254,12 +254,13 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
subPollutionVO.add(pollutionsubVO); subPollutionVO.add(pollutionsubVO);
}); });
pollutionVO.setChildren(subPollutionVO); pollutionVO.setChildren(subPollutionVO);
list.add(pollutionVO); list.add(pollutionVO);
} }
} }
if (!CollectionUtils.isEmpty(list)){ if (!CollectionUtils.isEmpty(list)){
return list.stream().sorted(Comparator.comparing(PollutionVO::getData).reversed().thenComparing(PollutionVO::getName)).collect(Collectors.toList()); List<PollutionVO> listSort = list.stream().filter(x -> x.getData() != 3.14159).sorted(Comparator.comparing(PollutionVO::getData).reversed().thenComparing(PollutionVO::getName)).collect(Collectors.toList());
listSort.addAll(list.stream().filter(x -> x.getData() == 3.14159).collect(Collectors.toList()));
return listSort;
} }
return list; return list;
} }