1.调整适配辽宁现场新能源场站

This commit is contained in:
2026-06-29 10:38:13 +08:00
parent 709262c2b4
commit ae14d9a820
7 changed files with 19 additions and 10 deletions

View File

@@ -111,7 +111,6 @@ public class LineDetail{
/** /**
* 监测点对象名称 * 监测点对象名称
*/ */
@Deprecated
private String objName; private String objName;
/** /**
@@ -171,19 +170,16 @@ public class LineDetail{
/** /**
* 监测点拥有者 * 监测点拥有者
*/ */
@Deprecated
private String owner; private String owner;
/** /**
* 拥有者职务 * 拥有者职务
*/ */
@Deprecated
private String ownerDuty; private String ownerDuty;
/** /**
* 拥有者联系方式 * 拥有者联系方式
*/ */
@Deprecated
private String ownerTel; private String ownerTel;
/** /**

View File

@@ -1504,7 +1504,10 @@
<select id="getCustomDetailByLineId" resultType="map"> <select id="getCustomDetailByLineId" resultType="map">
SELECT line.id AS lineId, SELECT line.id AS lineId,
CONCAT(CONCAT(CONCAT(sub.NAME, '_'), vo.NAME), CONCAT('_', line.NAME)) AS lineName, CASE
WHEN detail.obj_id IS NOT NULL AND detail.obj_id != '' THEN CONCAT(obj.PROJECT_NAME,'_', line.NAME)
ELSE CONCAT(sub.NAME, '_', vo.NAME, '_', line.NAME)
END AS lineName,
CONCAT(detail.pt1, ':', detail.pt2) AS pt, CONCAT(detail.pt1, ':', detail.pt2) AS pt,
CONCAT(detail.ct1, ':', detail.ct2) AS ct, CONCAT(detail.ct1, ':', detail.ct2) AS ct,
detail.Dev_Capacity AS Dev_Capacity, detail.Dev_Capacity AS Dev_Capacity,
@@ -1521,6 +1524,7 @@
JOIN pq_device pqd ON pqd.id = dev.id JOIN pq_device pqd ON pqd.id = dev.id
JOIN sys_dict_data dic ON vg.scale = dic.id JOIN sys_dict_data dic ON vg.scale = dic.id
JOIN pq_line sub ON sub.id = dev.pid JOIN pq_line sub ON sub.id = dev.pid
LEFT JOIN SUPERVISION_USER_REPORT obj on detail.obj_id = obj.id
WHERE line.id = #{lineId} WHERE line.id = #{lineId}
</select> </select>

View File

@@ -162,6 +162,7 @@ public class LineServiceImpl extends ServiceImpl<LineMapper, Line> implements Li
lineDetailDataVO.setDevId(device.getId()); lineDetailDataVO.setDevId(device.getId());
lineDetailDataVO.setBusinessType(dicDataFeignClient.getDicDataById(lineDetail.getBusinessType()).getData().getName()); lineDetailDataVO.setBusinessType(dicDataFeignClient.getDicDataById(lineDetail.getBusinessType()).getData().getName());
lineDetailDataVO.setLoadType(dicDataFeignClient.getDicDataById(lineDetail.getLoadType()).getData().getName()); lineDetailDataVO.setLoadType(dicDataFeignClient.getDicDataById(lineDetail.getLoadType()).getData().getName());
lineDetailDataVO.setObjId(lineDetail.getObjId());
lineDetailDataVO.setObjName(lineDetail.getObjName()); lineDetailDataVO.setObjName(lineDetail.getObjName());
lineDetailDataVO.setId(lineDetail.getNum()); lineDetailDataVO.setId(lineDetail.getNum());
lineDetailDataVO.setPtType(PubUtils.ptType(lineDetail.getPtType())); lineDetailDataVO.setPtType(PubUtils.ptType(lineDetail.getPtType()));

View File

@@ -69,7 +69,7 @@
select select
if(sum(real_time*1.0)/sum(due_time)*100>100, if(sum(real_time*1.0)/sum(due_time)*100>100,
100, 100,
IFNULL(ROUND( sum(real_time)/sum(due_time)*100,2),0)) IFNULL(ROUND( sum(real_time*1.0)/sum(due_time)*100,2),0))
as integrityRate as integrityRate
from from
r_stat_integrity_d r_stat_integrity_d

View File

@@ -577,7 +577,7 @@ public class GridServiceImpl implements IGridService {
//筛选出9项指标(电压偏差、频率偏差、电压总谐波畸变率、电压闪变、三相电压不平衡度、负序电流、谐波电流、间谐波电压、谐波电压)超标监测点 //筛选出9项指标(电压偏差、频率偏差、电压总谐波畸变率、电压闪变、三相电压不平衡度、负序电流、谐波电流、间谐波电压、谐波电压)超标监测点
long allNum = list2.stream().filter(o -> o.getAllOvertime() > 0 || o.getFlickerAllTime() > 0 ).count(); long allNum = list2.stream().filter(o -> o.getAllOvertime() > 0 || o.getFlickerAllTime() > 0 ).count();
detail.setOverNum((int) allNum); detail.setOverNum((int) allNum);
detail.setOverRatio(PubUtils.doubleRound(2, detail.getOverNum() * 100.0 / detail.getOnlineNum())); detail.setOverRatio(detail.getOnlineNum() == 0 ? 0 : PubUtils.doubleRound(2, detail.getOverNum() * 100.0 / detail.getOnlineNum()));
//筛选出电压偏差超标监测点 //筛选出电压偏差超标监测点
long num1 = list2.stream().filter(o -> o.getFreqDevOvertime() > 0).count(); long num1 = list2.stream().filter(o -> o.getFreqDevOvertime() > 0).count();
Integer day1 = list2.stream().max(Comparator.comparingInt(RStatLimitTargetVO::getFreqDevOvertime)).get().getFreqDevOvertime(); Integer day1 = list2.stream().max(Comparator.comparingInt(RStatLimitTargetVO::getFreqDevOvertime)).get().getFreqDevOvertime();

View File

@@ -10,9 +10,11 @@ import com.baomidou.dynamic.datasource.annotation.DS;
import com.njcn.common.pojo.enums.response.CommonResponseEnum; import com.njcn.common.pojo.enums.response.CommonResponseEnum;
import com.njcn.common.pojo.exception.BusinessException; import com.njcn.common.pojo.exception.BusinessException;
import com.njcn.common.utils.PubUtils; import com.njcn.common.utils.PubUtils;
import com.njcn.device.biz.commApi.CommLineClient;
import com.njcn.device.pms.api.MonitorClient; import com.njcn.device.pms.api.MonitorClient;
import com.njcn.device.pms.pojo.po.Monitor; import com.njcn.device.pms.pojo.po.Monitor;
import com.njcn.device.pq.api.DeviceUnitClient; import com.njcn.device.pq.api.DeviceUnitClient;
import com.njcn.device.pq.api.LineFeignClient;
import com.njcn.harmonic.common.pojo.dto.DeviceUnitCommDTO; import com.njcn.harmonic.common.pojo.dto.DeviceUnitCommDTO;
import com.njcn.harmonic.common.pojo.dto.HarmLineDetailDataCommDTO; import com.njcn.harmonic.common.pojo.dto.HarmLineDetailDataCommDTO;
import com.njcn.harmonic.common.pojo.dto.OverLimitInfoCommDTO; import com.njcn.harmonic.common.pojo.dto.OverLimitInfoCommDTO;
@@ -48,6 +50,7 @@ import java.text.SimpleDateFormat;
import java.time.LocalDateTime; import java.time.LocalDateTime;
import java.util.*; import java.util.*;
import java.util.stream.Collectors; import java.util.stream.Collectors;
import java.util.stream.Stream;
/** /**
* pqs * pqs
@@ -132,7 +135,12 @@ public class MonitorHarmonicReportServiceImpl implements MonitorHarmonicReportSe
if (ObjectUtil.isNull(lineDto)) { if (ObjectUtil.isNull(lineDto)) {
throw new BusinessException(CommonResponseEnum.NO_DATA); throw new BusinessException(CommonResponseEnum.NO_DATA);
} }
if(StrUtil.isNotBlank(lineDto.getObjId())){
bdname = lineDto.getObjName();
name = lineDto.getLineName();
}else {
bdname = lineDto.getBdName(); bdname = lineDto.getBdName();
}
areaName = lineDto.getAreaName(); areaName = lineDto.getAreaName();
if("冀北".equals(areaName)){ if("冀北".equals(areaName)){
areaName="国网"+areaName; areaName="国网"+areaName;

View File

@@ -64,11 +64,11 @@
<version>1.0.0</version> <version>1.0.0</version>
<scope>compile</scope> <scope>compile</scope>
</dependency> </dependency>
<dependency> <!-- <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>prepare-api</artifactId> <artifactId>prepare-api</artifactId>
<version>${project.version}</version> <version>${project.version}</version>
</dependency> </dependency>-->
<dependency> <dependency>
<groupId>com.njcn</groupId> <groupId>com.njcn</groupId>
<artifactId>process-api</artifactId> <artifactId>process-api</artifactId>