海南bug修改提交

2.解决优化部分台账信息

pqs-advance/advance-boot/src/main/java/com/njcn/advance/controller/EventRelevantAnalysisController.java

@@ -83,10 +83,10 @@ public class EventRelevantAnalysisController extends BaseController {
     public HttpResult<Page<RmpEventDetailAssPO>> queryEventsAssPage(@RequestBody BaseParam baseParam){
         String methodDescribe = getMethodDescribe("queryEventsAssPage");
         String searchValue = baseParam.getSearchValue();
-        Pattern pattern = Pattern.compile(PatternRegex.SPECIAL_REGEX);
-        if(pattern.matcher(searchValue).find()){
-            throw new BusinessException(ValidMessage.SPECIAL_REGEX);
-        }
+//        Pattern pattern = Pattern.compile(PatternRegex.SPECIAL_REGEX);
+//        if(pattern.matcher(searchValue).find()){
+//            throw new BusinessException(ValidMessage.SPECIAL_REGEX);
+//        }
         Page<RmpEventDetailAssPO> page = eventRelevantAnalysisService.queryEventsAssPage(baseParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, page, methodDescribe);
     }

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/assess/impl/SecondaryEvaluationServiceImpl.java

@@ -565,7 +565,7 @@ public class SecondaryEvaluationServiceImpl implements SecondaryEvaluationServic
             unblance.add(evaluationResult);
 
             evaluationResult = new AssessResultVO.EvaluationResult();
-            evaluationResult.setData(result.getApproUnblance().multiply(BigDecimal.valueOf(200)));
+            evaluationResult.setData(result.getApproUnblance());
             evaluationResult.setLimitData(overLimit.getUnblance());
             evaluationResult.setIsQualified(NumberUtil.isLess(evaluationResult.getData(), evaluationResult.getLimitData()));
             unblance.add(evaluationResult);

pqs-advance/advance-boot/src/main/java/com/njcn/advance/service/impl/EventRelevantAnalysisServiceImpl.java

@@ -471,6 +471,8 @@ public class EventRelevantAnalysisServiceImpl extends ServiceImpl<RmpEventAdvanc
 
         List<AdvanceEventDetailVO> advanceEventDetailVOList = BeanUtil.copyToList(rmpEventDetailPOList, AdvanceEventDetailVO.class);
         advanceEventDetailVOList = advanceEventDetailVOList.stream().peek(item -> {
+            item.setFeatureAmplitude(item.getFeatureAmplitude()*100);
+
             if (map.containsKey(item.getLineId())) {
                 AreaLineInfoVO areaLineInfoVO = map.get(item.getLineId());
                 item.setGdName(areaLineInfoVO.getGdName());

pqs-bpm/bpm-boot/src/main/java/com/njcn/bpm/BpmApplication.java

@@ -14,7 +14,6 @@ import org.springframework.context.annotation.DependsOn;
  * @date 2022/11/10
  */
 @Slf4j
-@DependsOn("proxyMapperRegister")
 @MapperScan("com.njcn.**.mapper")
 @EnableFeignClients(basePackages = "com.njcn")
 @SpringBootApplication(scanBasePackages = "com.njcn")

pqs-device/common-device-biz/src/main/java/com/njcn/device/biz/pojo/param/DeptGetLineParam.java

@@ -47,4 +47,7 @@ public class DeptGetLineParam {
     @ApiModelProperty("监测点运行状态")
     @Range(min = 0, max = 2, message = "监测点运行状态" + ValidMessage.PARAM_FORMAT_ERROR)
     private Integer lineRunFlag;
+
+    @ApiModelProperty("搜索值")
+    private String searchValue;
 }

pqs-device/pms-device/pms-device-boot/src/main/java/com/njcn/device/pms/mapper/distribution/mapping/PwMonitorMapper.xml

@@ -7,10 +7,10 @@
         SELECT DISTINCT
         monitor.Org_Id AS orgId,
         monitor.Org_Name AS orgName,
-        monitor.`Powerr_Id` AS powerId,
-        monitor.`Powerr_Name` AS powerName,
+        monitor.Powerr_Id AS powerId,
+        monitor.Powerr_Name AS powerName,
         monitor.id AS monitorId,
-        monitor.`Name` AS monitorName,
+        monitor.Name AS monitorName,
         monitor.Line_Id,
         monitor.Line_Name,
         pdm.Monitor_Sort AS monitorSort,
@@ -29,8 +29,8 @@
         (
         SELECT
         pm.id,
-        pm.`Name`,
-        pm.`Status`,
+        pm.Name,
+        pm.Status,
         pm.Org_Id,
         pm.Org_Name,
         pm.Powerr_Id,
@@ -51,8 +51,8 @@
         ) AS monitor
         INNER JOIN pms_distribution_monitor AS pdm ON monitor.id = pdm.Monitor_Id
         WHERE
-        monitor.`Status` = 1
-        AND pdm.`Status` = 1
+        monitor.Status = 1
+        AND pdm.Status = 1
         AND monitor.Org_Id IN
         <foreach collection="deptIdList" item="orgId" open="(" close=")" separator=",">
             #{orgId}
@@ -85,7 +85,7 @@
             AND pdm.If_Power_User = #{pwPmsMonitorParam.ifPowerUser}
         </if>
         <if test="pwPmsMonitorParam.monitorName !=null and pwPmsMonitorParam.monitorName != ''">
-            AND monitor.`Name` LIKE CONCAT('%',#{pwPmsMonitorParam.monitorName},'%')
+            AND monitor.Name LIKE CONCAT('%',#{pwPmsMonitorParam.monitorName},'%')
         </if>
     </select>
 

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/DeviceParam.java

@@ -93,7 +93,7 @@ public class DeviceParam {
     @NotBlank(message = "设备制造商不能为空")
     private String manufacturer;
 
-    @ApiModelProperty(name = "electroplate",value = "电镀功能",required = true)
+    @ApiModelProperty(name = "electroplate",value = "电度功能",required = true)
     @NotNull(message = "电镀标识不能为空")
     private Integer electroplate;
 

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/param/dataClean/MonitorBaseParam.java

@@ -41,4 +41,6 @@ public class MonitorBaseParam extends BaseParam {
     @ApiModelProperty(value = "监测点运行状态")
     private Integer lineRunFlag;
 
+    @ApiModelProperty(value = "异常天数时间")
+    private List<String> time;
 }

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/PqDataVerifyCount.java

@@ -52,17 +52,5 @@ public class PqDataVerifyCount implements Serializable {
     @TableField(value = "total_all")
     private Integer totalAll ;
 
-    /**
-     * 异常短时闪变数量
-     */
-    @TableField(value = "flicker")
-    private Integer flicker ;
-
-    /**
-     * 短时闪变总数量
-     */
-    @TableField(value = "flicker_all")
-    private Integer flickerAll;
-
 
 }

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/jb/DistributionArea.java

@@ -15,7 +15,7 @@ import lombok.EqualsAndHashCode;
  */
 @Data
 @EqualsAndHashCode(callSuper = true)
-@TableName("distribution_area")
+@TableName("fbs_distribution_area")
 public class DistributionArea extends BaseEntity {
 
     private static final long serialVersionUID = 1L;

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/po/jb/GenerationUser.java

@@ -17,7 +17,7 @@ import java.time.LocalDate;
  */
 @Data
 @EqualsAndHashCode(callSuper = true)
-@TableName("power_generation_user")
+@TableName("fbs_power_generation_user")
 public class GenerationUser extends BaseEntity {
 
     private static final long serialVersionUID = 1L;

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/AreaLineInfoVO.java

@@ -130,11 +130,16 @@ public class AreaLineInfoVO implements Serializable {
     @ApiModelProperty(name = "smallObjType",value = "检测对象小类")
     private String smallObjType;
 
+    @ApiModelProperty(name = "powerFlag",value = "电网标志（0-电网侧；1-非电网侧）")
+    private Integer powerFlag;
+
     @ApiModelProperty(name = "objId",value = "对象id")
     private String objId;
 
-    private Double vHarmonicValue; ;
+    @ApiModelProperty(name = "vHarmonicValue",value = "污染值")
+    private Double vHarmonicValue;
 
+    @ApiModelProperty(name = "userList",value = "敏感用户信息")
     private List<User> userList;
 
     @Data

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/DeviceVO.java

@@ -96,7 +96,7 @@ public class DeviceVO implements Serializable {
     @ApiModelProperty(name = "manufacturer",value = "设备制造商Guid")
     private String manufacturer;
 
-    @ApiModelProperty(name = "electroplate",value = "电镀功能")
+    @ApiModelProperty(name = "electroplate",value = "电度功能")
     private Integer electroplate;
 
     @ApiModelProperty(name = "thisTimeCheck",value = "本次定检时间")

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/dataClean/DetailAbnormalVO.java

@@ -17,6 +17,8 @@ public class DetailAbnormalVO {
 
     private String date;
 
+    private List<String> dateList;
+
     private String monitorName;
 
     private String bdName;
@@ -58,6 +60,15 @@ public class DetailAbnormalVO {
 
     }
 
+    @Data
+    public static class DetailAbnormalCountVO {
+
+        private Integer timeSum;
+        private Integer errCount;
+        private List<DetailAbnormalInnerVO> time;
+    }
+
+
     @Data
     public static class DetailLimitInnerVO{
 
@@ -92,49 +103,6 @@ public class DetailAbnormalVO {
         private Double freqData = 3.14159;
         @ApiModelProperty("频率偏差限值")
         private Float freqLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> freqDataList;
-
-        /**
-         * 电压偏差上
-         */
-        @ApiModelProperty("电压上偏差")
-        private Double vDevData = 3.14159;
-
-        @ApiModelProperty("电压上偏差限值")
-        private Float vDevLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> vDevDataList;
-
-        /**
-         * 电压偏差下
-         */
-        @ApiModelProperty("电压下偏差")
-        private Double uDevData = 3.14159;
-        @ApiModelProperty("电压下偏差限值")
-        private Float uDevLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> uDevDataList;
-        /**
-         * 总谐波畸变率
-         */
-        @ApiModelProperty("总谐波畸变率")
-        private Double uaberranceData = 3.14159;
-        @ApiModelProperty("总谐波畸变率限值")
-        private Float uaberranceLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> uaberranceDataList;
-
-        /**
-         * 三相电压不平衡度
-         */
-        @ApiModelProperty("三相电压不平衡度")
-        private Double unbalanceData = 3.14159;
-        @ApiModelProperty("三相电压不平衡度限值")
-        private Float unbalanceLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> unbalanceDataList;
-
 
         /**
          * 电压闪变
@@ -143,8 +111,76 @@ public class DetailAbnormalVO {
         private Double flickerData = 3.14159;
         @ApiModelProperty("电压闪变限值")
         private Float flickerLimit = 3.14159F;
-        @ApiModelProperty("频率偏差信息")
-        private List<DetailLimitInnerVO> flickerDataList;
+
+
+        /**
+         * 电压偏差上
+         */
+        @ApiModelProperty("电压上偏差")
+        private Double vDevData = 3.14159;
+        @ApiModelProperty("电压上偏差限值")
+        private Float vDevLimit = 3.14159F;
+
+
+        /**
+         * 电压偏差下
+         */
+        @ApiModelProperty("电压下偏差")
+        private Double uDevData = 3.14159;
+        @ApiModelProperty("电压下偏差限值")
+        private Float uDevLimit = 3.14159F;
+
+        /**
+         * 三相电压不平衡度
+         */
+        @ApiModelProperty("三相电压不平衡度")
+        private Double unbalanceData = 3.14159;
+        @ApiModelProperty("三相电压不平衡度限值")
+        private Float unbalanceLimit = 3.14159F;
+
+
+        /**
+         * 总谐波畸变率
+         */
+        @ApiModelProperty("总谐波畸变率")
+        private Double uaberranceData = 3.14159;
+        @ApiModelProperty("总谐波畸变率限值")
+        private Float uaberranceLimit = 3.14159F;
+
+
+        /**
+         * 负序电流限值天数
+         */
+        @ApiModelProperty("负序电流")
+        private Double iNegData= 3.14159;
+        @ApiModelProperty("负序电流限值")
+        private Float iNegLimit= 3.14159F;
+
+
+        /**
+         * 谐波电压越限天数
+         */
+        @ApiModelProperty("谐波电压")
+        private Double uharmData = 3.14159;
+        @ApiModelProperty("谐波电压限值")
+        private Float uharmLimit= 3.14159F;
+        /**
+         * 谐波电流越限天数
+         */
+        @ApiModelProperty("谐波电流")
+        private Double iharmData = 3.14159;
+        @ApiModelProperty("谐波电流限值")
+        private Float iharmLimit= 3.14159F;
+        /**
+         * 间谐波限值天数
+         */
+        @ApiModelProperty("间谐波电压")
+        private Double inuharmData = 3.14159;
+        @ApiModelProperty("间谐波电压限值")
+        private Float inuharmLimit= 3.14159F;
+
+
+
     }
 
 

pqs-device/pq-device/pq-device-api/src/main/java/com/njcn/device/pq/pojo/vo/dataClean/PowerQualityIndicatorsVO.java

@@ -13,10 +13,10 @@ public class PowerQualityIndicatorsVO {
 
     @ApiModelProperty(name = "monitorId",value = "监测点id")
     private String monitorId;
-    //监测点名称
+
     @ApiModelProperty(name = "monitorName",value = "监测点名称")
     private String monitorName;
-    //所属终端名称
+
     @ApiModelProperty(name = "devName",value = "所属终端名称")
     private String devName;
 
@@ -25,23 +25,25 @@ public class PowerQualityIndicatorsVO {
 
     @ApiModelProperty(name = "manufacturer",value = "所属厂商")
     private String manufacturer;
-    //所属电站
+
     @ApiModelProperty(name = "stationName",value = "所属电站")
     private String stationName;
-    //监测对象类型
+
     @ApiModelProperty(name = "objType",value = "监测对象类型")
     private String objType;
-    //监测对象名称
+
     @ApiModelProperty(name = "objName",value = "监测对象名称")
     private String objName;
-    //电压等级
+
     @ApiModelProperty(name = "voltageLevel",value = "电压等级")
     private String voltageLevel;
-    //异常天数
+
     @ApiModelProperty(name = "abnormalDay",value = "异常天数")
     private Integer abnormalDay;
-    //严重度
+
     @ApiModelProperty(name = "severity",value = "严重度")
     private Integer severity;
 
+    @ApiModelProperty("地市")
+    private String city;
 }

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/DataVerifyController.java

@@ -86,9 +86,9 @@ public class DataVerifyController extends BaseController {
     @OperateInfo(info = LogEnum.BUSINESS_COMMON)
     @PostMapping("/monitorAbnormalTableDetail")
     @ApiOperation("弹框-获取异常监测点列表详情")
-    public HttpResult<List<DetailAbnormalVO.DetailAbnormalInnerVO>> monitorAbnormalTableDetail(@RequestBody MonitorBaseParam monitorBaseParam){
+    public HttpResult<DetailAbnormalVO.DetailAbnormalCountVO> monitorAbnormalTableDetail(@RequestBody MonitorBaseParam monitorBaseParam) {
         String methodDescribe = getMethodDescribe("monitorAbnormalTableDetail");
-        List<DetailAbnormalVO.DetailAbnormalInnerVO> list = iPqDataVerifyBakService.monitorAbnormalTableDetail(monitorBaseParam);
+        DetailAbnormalVO.DetailAbnormalCountVO list = iPqDataVerifyBakService.monitorAbnormalTableDetail(monitorBaseParam);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, list, methodDescribe);
     }
 

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/PqDataVerifyCountMapper.xml

@@ -8,9 +8,7 @@
 		SELECT
 		line_id AS lineId,
 		SUM(total) AS total,
-		SUM(total_all) AS totalAll,
-		SUM(flicker) AS flicker,
-		SUM(flicker_all) AS flickerAll
+		SUM(total_all) AS totalAll
 		FROM
 		pq_data_verify_count
 		<where>
@@ -32,12 +30,12 @@
 
 	<select id="getAnomalousData" resultType="OnlineMonitorVo">
 		SELECT DISTINCT
-		t6.`Name` gdName,
-		t5.`Name` subName,
-		t4.`Name` deviceName,
+		t6.Name gdName,
+		t5.Name subName,
+		t4.Name deviceName,
 		t1.Line_Id lineId,
-		t2.`Name` lineName,
-		t8.`Name` monitorObjType,
+		t2.Name lineName,
+		t8.Name monitorObjType,
 		t7.Obj_Name monitorObj,
 		"异常数据" as target,
 		count(t1.time_id) lastDay
@@ -51,7 +49,7 @@
 		left join pq_line_detail t7 on t1.Line_Id = t7.Id
 		left join sys_dict_data t8 on t7.Load_Type = t8.Id
 		WHERE
-		(t1.total + t1.flicker) > 0
+		t1.total > 0
 		<if test="lineIds!=null and lineIds.size > 0">
 			and Line_Id in
 			<foreach collection="lineIds" item="item" open="(" close=")" separator=",">
@@ -69,4 +67,4 @@
 		order by lastDay desc
 	</select>
 
-</mapper>
+</mapper>

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TreeMapper.xml

@@ -381,7 +381,7 @@
             line.LEVEL,
             line.sort,
             line.pids,
-            CONCAT(voltage.name, '_', line.name, '(',device.`Name`,')') name,
+            CONCAT(voltage.name, '_', line.name, '(',device.Name,')') name,
             comFlag.Com_Flag,
             detail.pt_type,
             detail.obj_id

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/IPqDataVerifyBakService.java

@@ -27,8 +27,7 @@ public interface IPqDataVerifyBakService extends IService<PqDataVerifyBak> {
     List<DetailAbnormalVO> monitorAbnormalTable(MonitorBaseParam monitorBaseParam);
 
 
-
-    List<DetailAbnormalVO.DetailAbnormalInnerVO> monitorAbnormalTableDetail(MonitorBaseParam monitorBaseParam);
+    DetailAbnormalVO.DetailAbnormalCountVO monitorAbnormalTableDetail(MonitorBaseParam monitorBaseParam);
 
 
 

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/CommTerminalServiceImpl.java

@@ -264,7 +264,11 @@ public class CommTerminalServiceImpl implements CommTerminalService {
     public List<DeptGetSubStationDTO.Info> deptSubStationInfo(DeptGetLineParam deptGetLineParam) {
         List<DeptGetSubStationDTO.Info> result = new ArrayList<>();
         List<DeptGetBase> temDept = getDeptChildrenByParent(deptGetLineParam);
-        List<TerminalGetBase.Extend> anExtends = deptLineService.orgSubStationInfoGet(filterDataTypeNew(deptGetLineParam.getServerName()), deptGetLineParam.getPowerFlag(), deptGetLineParam.getLineRunFlag(), deptGetLineParam.getIsUpToGrid());
+        List<TerminalGetBase.Extend> anExtends = deptLineService.orgSubStationInfoGet(filterDataTypeNew(deptGetLineParam.getServerName()),
+                                                                                        deptGetLineParam.getPowerFlag(),
+                                                                                        deptGetLineParam.getLineRunFlag(),
+                                                                                        deptGetLineParam.getIsUpToGrid(),
+                                                                                        deptGetLineParam.getSearchValue());
         Map<String, List<TerminalGetBase.Extend>> orgSub = anExtends.stream().collect(Collectors.groupingBy(TerminalGetBase::getUnitId));
         Map<String, String> deptNameMap = temDept.stream().collect(Collectors.toMap(DeptGetBase::getUnitId, DeptGetBase::getUnitName));
         temDept.forEach(item -> {

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DataVerifyServiceImpl.java

@@ -4,6 +4,7 @@ package com.njcn.device.pq.service.impl;
 import cn.hutool.core.codec.Base64;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.*;
+import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.json.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -19,36 +20,34 @@ import com.njcn.dataProcess.param.LineCountEvaluateParam;
 import com.njcn.dataProcess.pojo.dto.DataLimitRateDetailDto;
 import com.njcn.dataProcess.pojo.dto.DataLimitTargetDto;
 import com.njcn.dataProcess.pojo.dto.PqReasonableRangeDto;
-import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
 import com.njcn.device.biz.enums.DeviceResponseEnum;
 import com.njcn.device.biz.pojo.dto.LineDevGetDTO;
 import com.njcn.device.biz.pojo.po.Overlimit;
 import com.njcn.device.line.mapper.LineMapper;
+import com.njcn.device.line.service.DeptLineService;
 import com.njcn.device.overlimit.service.IOverLimitService;
 import com.njcn.device.pq.mapper.DataVerifyMapper;
-import com.njcn.device.pq.mapper.PqDataVerifyBakMapper;
 import com.njcn.device.pq.pojo.param.dataClean.MonitorBaseParam;
 import com.njcn.device.pq.pojo.po.DataVerify;
+import com.njcn.device.pq.pojo.po.DeptLine;
 import com.njcn.device.pq.pojo.vo.AreaLineInfoVO;
 import com.njcn.device.pq.pojo.vo.LineDetailDataVO;
 import com.njcn.device.pq.pojo.vo.dataClean.*;
 import com.njcn.device.pq.service.CommTerminalService;
 import com.njcn.device.pq.service.IDataVerifyService;
 import com.njcn.supervision.api.UserLedgerFeignClient;
-import com.njcn.supervision.pojo.vo.user.NewUserReportVO;
 import com.njcn.system.api.DicDataFeignClient;
 import com.njcn.system.api.DictTreeFeignClient;
 import com.njcn.system.enums.DicDataEnum;
 import com.njcn.system.enums.DicDataTypeEnum;
 import com.njcn.system.pojo.po.DictData;
-import com.njcn.system.pojo.po.SysDicTreePO;
 import lombok.RequiredArgsConstructor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Service;
 
 import java.lang.reflect.Field;
-import java.math.BigDecimal;
+import java.lang.reflect.Method;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -70,28 +69,21 @@ import java.util.stream.Collectors;
 public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVerify> implements IDataVerifyService {
 
     private static final Logger logger = LoggerFactory.getLogger(DataVerifyServiceImpl.class);
-
     private static final String SEPARATOR = "&";
     private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern(DatePattern.NORM_DATE_PATTERN);
-
     private final CommTerminalService commTerminalService;
-
     private final LineMapper lineMapper;
-
     private final DictTreeFeignClient dictTreeFeignClient;
-
     private final UserLedgerFeignClient userLedgerFeignClient;
-
     private final PqReasonableRangeFeignClient pqReasonableRangeFeignClient;
-
     private final DataLimitTargetFeignClient dataLimitTargetFeignClient;
-
     private final DataLimitRateFeignClient dataLimitRateFeignClient;
-
     private final DataLimitRateDetailFeignClient dataLimitRateDetailFeignClient;
     private final DicDataFeignClient dicDataFeignClient;
-
     private final IOverLimitService overLimitService;
+    private final DeptLineService deptLineService;
+
+
 
     @Override
     public VerifyMonitorVO getMonitorVerifyData(MonitorBaseParam monitorBaseParam) {
@@ -351,7 +343,7 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
                         });
                     }
                 } else {
-                    if(StrUtil.isNotBlank(jonsStr)){
+                    if (StrUtil.isNotBlank(jonsStr)) {
                         JSONArray jsonArray = new JSONArray(jonsStr);
                         List<JsonBaseVO> jsonBaseVOList = jsonArray.toList(JsonBaseVO.class);
                         jsonBaseVOList.forEach(it -> {
@@ -360,13 +352,13 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
                     }
                 }
 
-                if(timeSet.size()>0){
+                if (timeSet.size() > 0) {
                     DetailAbnormalVO detailAbnormalVO = new DetailAbnormalVO();
                     detailAbnormalVO.setMonitorId(lineId);
                     detailAbnormalVO.setDate(date.format(DATE_FORMAT));
                     detailAbnormalVO.setMonitorName(lineInfoVO.getLineName());
                     detailAbnormalVO.setBdName(lineInfoVO.getBdName());
-                    detailAbnormalVO.setTimeSum(String.valueOf(timeInterval*timeSet.size()));
+                    detailAbnormalVO.setTimeSum(String.valueOf(timeInterval * timeSet.size()));
                     detailAbnormalVO.setTargetKey(monitorBaseParam.getTargetKey());
                     result.add(detailAbnormalVO);
                 }
@@ -403,7 +395,7 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
         LineCountEvaluateParam lineCountEvaluateParam = new LineCountEvaluateParam();
         lineCountEvaluateParam.setLineId(Collections.singletonList(monitorBaseParam.getMonitorIds().get(0)));
         lineCountEvaluateParam.setStartTime(monitorBaseParam.getSearchBeginTime());
-        lineCountEvaluateParam.setEndTime(monitorBaseParam.getSearchBeginTime());
+        lineCountEvaluateParam.setEndTime(monitorBaseParam.getSearchEndTime());
         List<DataLimitRateDetailDto> dtoList = dataLimitRateDetailFeignClient.getRawData(lineCountEvaluateParam).getData();
         Overlimit overLimitDataById = overLimitService.getOverLimitDataById(monitorBaseParam.getMonitorIds().get(0));
 
@@ -412,73 +404,198 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
         List<DetailAbnormalVO.DetailLimitInnerVO> uaberrance = new ArrayList<>();
         List<DetailAbnormalVO.DetailLimitInnerVO> ubalance = new ArrayList<>();
         List<DetailAbnormalVO.DetailLimitInnerVO> flicker = new ArrayList<>();
+        List<DetailAbnormalVO.DetailLimitInnerVO> iNeg = new ArrayList<>();
+
+        List<DetailAbnormalVO.DetailLimitInnerVO> uharm = new ArrayList<>();
+        List<DetailAbnormalVO.DetailLimitInnerVO> iharm = new ArrayList<>();
+        List<DetailAbnormalVO.DetailLimitInnerVO> inuharm = new ArrayList<>();
+
         for (DataLimitRateDetailDto dto : dtoList) {
-            dealJsonArr(new JSONArray(dto.getFreqDevOvertime()), freq, DicDataEnum.FREQUENCY_DEV.getCode(), null);
-            dealJsonArr(new JSONArray(dto.getVoltageDevOvertime()), voltage, DicDataEnum.VOLTAGE_DEV.getCode(), null);
-            dealJsonArr(new JSONArray(dto.getUaberranceOvertime()), uaberrance, DicDataEnum.THD_V.getCode(), null);
-            dealJsonArr(new JSONArray(dto.getUbalanceOvertime()), ubalance, DicDataEnum.phase_Voltage.getCode(), null);
-            dealJsonArr(new JSONArray(dto.getFlickerOvertime()), flicker, DicDataEnum.FLICKER.getCode(), null);
+            dealJsonArr(new JSONArray(dto.getFreqDevOvertime()), freq, DicDataEnum.FREQUENCY_DEV.getName(), null);
+            dealJsonArr(new JSONArray(dto.getVoltageDevOvertime()), voltage, DicDataEnum.VOLTAGE_DEV.getName(), null);
+            dealJsonArr(new JSONArray(dto.getUaberranceOvertime()), uaberrance, DicDataEnum.THD_V.getName(), null);
+            dealJsonArr(new JSONArray(dto.getUbalanceOvertime()), ubalance, DicDataEnum.phase_Voltage.getName(), null);
+            dealJsonArr(new JSONArray(dto.getFlickerOvertime()), flicker, DicDataEnum.FLICKER.getName(), null);
+            dealJsonArr(new JSONArray(dto.getINegOvertime()), iNeg, DicDataEnum.NEG_CURRENT.getName(), null);
+            // 处理谐波类指标
+            processHarmonicTargetHarm(dto, DicDataEnum.HARMONIC_VOLTAGE.getName(), "uharm", 2, 25, uharm);
+            processHarmonicTargetHarm(dto, DicDataEnum.HARMONIC_CURRENT.getName(), "iharm", 2, 25, iharm);
+            processHarmonicTargetHarm(dto, DicDataEnum.INTERHARMONIC_VOLTAGE.getName(), "inuharm", 1, 16, inuharm);
         }
+        assess.setFreqLimit(overLimitDataById.getFreqDev());
+        assess.setVDevLimit(overLimitDataById.getVoltageDev());
+        assess.setUDevLimit(overLimitDataById.getUvoltageDev());
+        assess.setUaberranceLimit(overLimitDataById.getUaberrance());
+        assess.setUnbalanceLimit(overLimitDataById.getUbalance());
+        assess.setFlickerLimit(overLimitDataById.getFlicker());
+        assess.setINegLimit(overLimitDataById.getINeg());
+        Map<String, List<PqReasonableRangeDto>> map = new HashMap<>();
+        DataCleanParam param = new DataCleanParam();
+        param.setSystemType(DataCleanEnum.Pqs.getCode());
+        List<PqReasonableRangeDto> list = pqReasonableRangeFeignClient.getData(param).getData();
+        if (CollUtil.isNotEmpty(list)) {
+            map = list.stream().collect(Collectors.groupingBy(PqReasonableRangeDto::getInfluxdbTableName));
+        }
+
+        List<PqReasonableRangeDto> dataV = map.get(DataCleanEnum.DataV.getCode());
+        Map<String, PqReasonableRangeDto> dataVCode = dataV.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
+        //频率偏差
         if (CollUtil.isNotEmpty(freq)) {
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect = freq.stream().sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
-            DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
-            assess.setFreqData(Double.valueOf(val.getVal()));
-            assess.setFreqLimit(val.getOverLimitValue());
-            assess.setFreqDataList(collect);
-        } else {
-            assess.setFreqLimit(overLimitDataById.getFreqDev());
+            PqReasonableRangeDto dto = dataVCode.get(DataCleanEnum.FreqDev.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(freq, dto);
+            assess.setFreqData(NumberUtil.round(val.getVal(), 2).doubleValue());
         }
+
+        //电压偏差
         if (CollUtil.isNotEmpty(voltage)) {
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect = voltage.stream().filter(x->Double.valueOf(x.getVal()) > 0).sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
-            if(CollUtil.isNotEmpty(collect)){
-                DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
-                assess.setVDevData(Double.valueOf(val.getVal()));
-                assess.setVDevLimit(val.getOverLimitValue());
-                assess.setVDevDataList(collect);
+            //上偏差
+            PqReasonableRangeDto dto1 = dataVCode.get(DataCleanEnum.VuDev.getCode());
+            List<DetailAbnormalVO.DetailLimitInnerVO> collect = voltage.stream()
+                    .filter(x -> Double.valueOf(x.getVal()) > 0)
+                    .filter(x -> Double.valueOf(x.getVal()) < dto1.getMaxValue())
+                    .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
+            if (CollUtil.isNotEmpty(collect)) {
+                DetailAbnormalVO.DetailLimitInnerVO val;
+                if (CollUtil.isNotEmpty(collect)) {
+                    val = collect.get(0);
+                } else {
+                    List<DetailAbnormalVO.DetailLimitInnerVO> collect2 = voltage.stream()
+                            .filter(x -> Double.valueOf(x.getVal()) > 0)
+                            .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed())
+                            .collect(Collectors.toList());
+                    val = collect2.get(0);
+                    val.setVal(dto1.getMaxValue().toString());
+                }
+                assess.setVDevData(NumberUtil.round(val.getVal(), 2).doubleValue());
             }
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect2 = voltage.stream().filter(x->Double.valueOf(x.getVal()) < 0).sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal)).collect(Collectors.toList());
-            if(CollUtil.isNotEmpty(collect2)){
-                DetailAbnormalVO.DetailLimitInnerVO val2 = collect2.get(0);
-                assess.setUDevData(Double.valueOf(val2.getVal()));
-                assess.setUDevLimit(val2.getOverLimitValue());
-                assess.setUDevDataList(collect2);
+            //下偏差
+            PqReasonableRangeDto dto2 = dataVCode.get(DataCleanEnum.VlDev.getCode());
+            List<DetailAbnormalVO.DetailLimitInnerVO> collect2 = voltage.stream()
+                    .filter(x -> Double.valueOf(x.getVal()) < 0)
+                    .filter(x -> dto2.getMinValue() < Double.valueOf(x.getVal()))
+                    .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal)).collect(Collectors.toList());
+            if (CollUtil.isNotEmpty(collect2)) {
+                DetailAbnormalVO.DetailLimitInnerVO val2;
+                if (CollUtil.isNotEmpty(collect)) {
+                    val2 = collect.get(0);
+                } else {
+                    List<DetailAbnormalVO.DetailLimitInnerVO> collect3 = voltage.stream()
+                            .filter(x -> Double.valueOf(x.getVal()) < 0)
+                            .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed())
+                            .collect(Collectors.toList());
+                    val2 = collect3.get(0);
+                    val2.setVal(dto2.getMaxValue().toString());
+                }
+                assess.setUDevData(NumberUtil.round(val2.getVal(), 2).doubleValue());
             }
-        }else{
-            assess.setVDevLimit(overLimitDataById.getVoltageDev());
-            assess.setUDevLimit(overLimitDataById.getUvoltageDev());
         }
-
+        //负序电流
+        if (CollUtil.isNotEmpty(iNeg)) {
+            List<DetailAbnormalVO.DetailLimitInnerVO> collect = iNeg.stream()
+                    .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed())
+                    .collect(Collectors.toList());
+            DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
+            assess.setINegData(NumberUtil.round(val.getVal(), 2).doubleValue());
+        }
+        //电压总谐波
         if (CollUtil.isNotEmpty(uaberrance)) {
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect = uaberrance.stream().sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
-            DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
-            assess.setUaberranceData(Double.valueOf(val.getVal()));
-            assess.setUaberranceLimit(val.getOverLimitValue());
-            assess.setUaberranceDataList(collect);
-        }else {
-            assess.setUaberranceLimit(overLimitDataById.getUaberrance());
+            PqReasonableRangeDto dto = dataVCode.get(DataCleanEnum.VThd.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(uaberrance, dto);
+            assess.setUaberranceData(NumberUtil.round(val.getVal(), 2).doubleValue());
         }
-
+        //三相不平衡度
         if (CollUtil.isNotEmpty(ubalance)) {
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect = ubalance.stream().sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
-            DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
-            assess.setUnbalanceData(Double.valueOf(val.getVal()));
-            assess.setUnbalanceLimit(val.getOverLimitValue());
-            assess.setUnbalanceDataList(collect);
-        }else{
-            assess.setUnbalanceLimit(overLimitDataById.getUbalance());
+            PqReasonableRangeDto dto = dataVCode.get(DataCleanEnum.VUnbalance.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(ubalance, dto);
+            assess.setUnbalanceData(NumberUtil.round(val.getVal(), 2).doubleValue());
         }
+        //闪变
+        List<PqReasonableRangeDto> dataPlt = map.get(DataCleanEnum.DataPlt.getCode());
+        Map<String, PqReasonableRangeDto> dataPltCode = dataPlt.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
         if (CollUtil.isNotEmpty(flicker)) {
-            List<DetailAbnormalVO.DetailLimitInnerVO> collect = flicker.stream().sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
+            PqReasonableRangeDto dto = dataPltCode.get(DataCleanEnum.Plt.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(flicker, dto);
+            assess.setFlickerData(NumberUtil.round(val.getVal(), 2).doubleValue());
+        }
+        //谐波电压
+        List<PqReasonableRangeDto> dataHarmRate = map.get(DataCleanEnum.DataHarmRateV.getCode());
+        Map<String, PqReasonableRangeDto> dataHarmRateCode = dataHarmRate.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
+        if (CollUtil.isNotEmpty(uharm)) {
+            PqReasonableRangeDto dto = dataHarmRateCode.get(DataCleanEnum.V_Rate.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(uharm, dto);
+            assess.setUharmData(NumberUtil.round(val.getVal(), 2).doubleValue());
+            String[] split = val.getTargetName().split("次");
+            try {
+                Class<?> clazz = overLimitDataById.getClass();
+                String methodName = "getUharm" + split[0];
+                Method method = clazz.getMethod(methodName);
+                Float value = (Float) method.invoke(overLimitDataById);
+                assess.setUharmLimit(value);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+        }else{
+            PqReasonableRangeDto dto = dataVCode.get(DataCleanEnum.VThd.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(uaberrance, dto);
+            assess.setUharmData(NumberUtil.round(val.getVal(), 2).doubleValue());
+        }
+        //谐波电流
+        if (CollUtil.isNotEmpty(iharm)) {
+            List<DetailAbnormalVO.DetailLimitInnerVO> collect = iharm.stream()
+                    .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed())
+                    .collect(Collectors.toList());
             DetailAbnormalVO.DetailLimitInnerVO val = collect.get(0);
-            assess.setFlickerData(Double.valueOf(val.getVal()));
-            assess.setFlickerLimit(val.getOverLimitValue());
-            assess.setFlickerDataList(collect);
-        }else {
-            assess.setFlickerLimit(overLimitDataById.getFlicker());
+            assess.setIharmData(NumberUtil.round(val.getVal(), 2).doubleValue());
+            String[] split = val.getTargetName().split("次");
+            try {
+                Class<?> clazz = overLimitDataById.getClass();
+                String methodName = "getIharm" + split[0];
+                Method method = clazz.getMethod(methodName);
+                Float value = (Float) method.invoke(overLimitDataById);
+                assess.setIharmLimit(value);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
+
+        }
+        //间谐波电压
+        List<PqReasonableRangeDto> dataInHarm = map.get(DataCleanEnum.DataInHarmV.getCode());
+        Map<String, PqReasonableRangeDto> dataInHarmCode = dataInHarm.stream().collect(Collectors.toMap(PqReasonableRangeDto::getIndexCode, Function.identity()));
+        if (CollUtil.isNotEmpty(inuharm)) {
+            PqReasonableRangeDto dto = dataInHarmCode.get(DataCleanEnum.V_InHarm.getCode());
+            DetailAbnormalVO.DetailLimitInnerVO val = reasonAble(inuharm, dto);
+            assess.setInuharmData(NumberUtil.round(val.getVal(), 2).doubleValue());
+            String[] split = val.getTargetName().split("次");
+            try {
+                Class<?> clazz = overLimitDataById.getClass();
+                String methodName = "getInuharm" + split[0];
+                Method method = clazz.getMethod(methodName);
+                Float value = (Float) method.invoke(overLimitDataById);
+                assess.setInuharmLimit(value);
+            } catch (Exception e) {
+                throw new RuntimeException(e);
+            }
         }
         return assess;
     }
 
+    private DetailAbnormalVO.DetailLimitInnerVO reasonAble(List<DetailAbnormalVO.DetailLimitInnerVO> limit, PqReasonableRangeDto dto) {
+        List<DetailAbnormalVO.DetailLimitInnerVO> collect = limit.stream()
+                .filter(x -> dto.getMinValue() < Double.valueOf(x.getVal()) && Double.valueOf(x.getVal()) < dto.getMaxValue())
+                .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed()).collect(Collectors.toList());
+        DetailAbnormalVO.DetailLimitInnerVO val;
+        if (CollUtil.isNotEmpty(collect)) {
+            val = collect.get(0);
+        } else {
+            List<DetailAbnormalVO.DetailLimitInnerVO> collect2 = limit.stream()
+                    .sorted(Comparator.comparing(DetailAbnormalVO.DetailLimitInnerVO::getVal).reversed())
+                    .collect(Collectors.toList());
+            val = collect2.get(0);
+            val.setVal(dto.getMaxValue().toString());
+        }
+        return val;
+    }
+
     private Map<String, DictData> getTargetMap() {
         List<DictData> dictDataList = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.STEADY_STATIS.getCode()).getData();
         return dictDataList.stream().collect(Collectors.toMap(DictData::getCode, Function.identity()));
@@ -547,6 +664,7 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
         processHarmonicTarget(dto, targetMap, DicDataEnum.HARMONIC_CURRENT.getCode(), "iharm", 2, 25, result);
         processHarmonicTarget(dto, targetMap, DicDataEnum.INTERHARMONIC_VOLTAGE.getCode(), "inuharm", 1, 16, result);
     }
+
     private void processStandardTarget(DataLimitRateDetailDto dto, Map<String, DictData> targetMap,
                                        String targetCode, String data,
                                        List<DetailAbnormalVO.DetailLimitInnerVO> result) {
@@ -566,6 +684,13 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
         processSpecialTargets(tempList, result, targetName);
     }
 
+    private void processHarmonicTargetHarm(DataLimitRateDetailDto dto, String targetCode, String prefix, int start, int end,
+                                           List<DetailAbnormalVO.DetailLimitInnerVO> result) {
+        List<String> tempList = new ArrayList<>();
+        collectHarmonicData(dto, prefix, start, end, tempList);
+        processSpecialTargets(tempList, result, targetCode);
+    }
+
     private void processSpecialTargets(List<String> specialTargetList, List<DetailAbnormalVO.DetailLimitInnerVO> result, String targetName) {
         for (String strJson : specialTargetList) {
             String[] temStr = strJson.split(SEPARATOR);
@@ -844,7 +969,7 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
             List<LocalDate> dateList = list.stream().map(it -> it.getTime().toLocalDate()).distinct().sorted(Comparator.comparing(Function.identity())).collect(Collectors.toList());
             processTable(monitorBaseParam, dateList, result, key);
         });
-        dealTableResult(result);
+        dealTableResult(result, monitorBaseParam.getSearchValue());
         return result;
     }
 
@@ -856,7 +981,7 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
             List<LocalDate> dateList = list.stream().map(DataLimitTargetDto::getTime).distinct().sorted(Comparator.comparing(Function.identity())).collect(Collectors.toList());
             processTable(monitorBaseParam, dateList, result, key);
         });
-        dealTableResult(result);
+        dealTableResult(result, monitorBaseParam.getSearchValue());
         return result;
     }
 
@@ -883,34 +1008,44 @@ public class DataVerifyServiceImpl extends ServiceImpl<DataVerifyMapper, DataVer
         }
     }
 
-    private void dealTableResult(List<PowerQualityIndicatorsVO> result) {
+    private void dealTableResult(List<PowerQualityIndicatorsVO> result, String searchValue) {
         if (CollUtil.isNotEmpty(result)) {
-            List<SysDicTreePO> dicTreePOList = dictTreeFeignClient.queryAllByType(Integer.valueOf(DicDataEnum.Obj_Type.getCode())).getData();
-            Map<String, SysDicTreePO> sysDicTreePOMap = dicTreePOList.stream().collect(Collectors.toMap(SysDicTreePO::getId, Function.identity()));
+//            List<SysDicTreePO> dicTreePOList = dictTreeFeignClient.queryAllByType(Integer.valueOf(DicDataEnum.Obj_Type.getCode())).getData();
+//            Map<String, SysDicTreePO> sysDicTreePOMap = dicTreePOList.stream().collect(Collectors.toMap(SysDicTreePO::getId, Function.identity()));
             List<String> ids = result.stream().map(PowerQualityIndicatorsVO::getMonitorId).distinct().collect(Collectors.toList());
-            List<AreaLineInfoVO> areaLineInfoVOList = lineMapper.getBaseLineAreaInfo(ids, null, null);
-            Map<String, AreaLineInfoVO> areaMap = areaLineInfoVOList.stream().collect(Collectors.toMap(AreaLineInfoVO::getLineId, Function.identity()));
-
-            List<String> objIds = areaLineInfoVOList.stream().map(AreaLineInfoVO::getObjId).distinct().collect(Collectors.toList());
-            List<NewUserReportVO> userLedgerVOList = userLedgerFeignClient.getUserReportByIds(objIds).getData();
-            Map<String, NewUserReportVO> userMap = userLedgerVOList.stream().collect(Collectors.toMap(NewUserReportVO::getId, Function.identity()));
-            result.forEach(it -> {
-                if (areaMap.containsKey(it.getMonitorId())) {
-                    AreaLineInfoVO areaLineInfoVO = areaMap.get(it.getMonitorId());
-                    it.setMonitorName(areaLineInfoVO.getLineName());
-                    it.setStationName(areaLineInfoVO.getSubName());
-                    it.setDevName(areaLineInfoVO.getDeviceName());
-                    it.setVoltageLevel(areaLineInfoVO.getVoltageScale());
-                    it.setIp(Base64.encode(areaLineInfoVO.getIp()));
-                    it.setManufacturer(areaLineInfoVO.getManufacturer());
-                    if (sysDicTreePOMap.containsKey(areaLineInfoVO.getSmallObjType())) {
-                        it.setObjType(sysDicTreePOMap.get(areaLineInfoVO.getSmallObjType()).getName());
-                    }
-                    if (userMap.containsKey(areaLineInfoVO.getObjId())) {
-                        it.setObjName(userMap.get(areaLineInfoVO.getObjId()).getProjectName());
+            List<AreaLineInfoVO> areaLineInfoVOList = lineMapper.getBaseLineAreaInfo(ids, searchValue, null);
+            Map<String, PowerQualityIndicatorsVO> areaMap = result.stream().collect(Collectors.toMap(PowerQualityIndicatorsVO::getMonitorId, Function.identity()));
+            List<DeptLine> deptLines = deptLineService.selectDeptLine(ids);
+            Map<String, String> deptName = deptLines.stream().collect(Collectors.toMap(DeptLine::getLineId, DeptLine::getId));
+//            List<String> objIds = areaLineInfoVOList.stream().map(AreaLineInfoVO::getObjId).distinct().collect(Collectors.toList());
+//            List<NewUserReportVO> userLedgerVOList = userLedgerFeignClient.getUserReportByIds(objIds).getData();
+//            Map<String, NewUserReportVO> userMap = userLedgerVOList.stream().collect(Collectors.toMap(NewUserReportVO::getId, Function.identity()));
+            List<PowerQualityIndicatorsVO> info = new ArrayList<>();
+            for (AreaLineInfoVO lineDetail : areaLineInfoVOList) {
+                if (areaMap.containsKey(lineDetail.getLineId())) {
+                    PowerQualityIndicatorsVO it = areaMap.get(lineDetail.getLineId());
+                    it.setMonitorName(lineDetail.getLineName());
+                    it.setStationName(lineDetail.getSubName());
+                    if(deptName.containsKey(lineDetail.getLineId())){
+                        it.setCity(deptName.get(lineDetail.getLineId()));
                     }
+                    it.setDevName(lineDetail.getDeviceName());
+                    it.setVoltageLevel(lineDetail.getVoltageScale());
+                    it.setIp(Base64.encode(lineDetail.getIp()));
+                    it.setManufacturer(lineDetail.getManufacturer());
+                    it.setObjType(lineDetail.getLoadType());
+                    it.setObjName(lineDetail.getObjName());
+                    info.add(it);
+//                    if (sysDicTreePOMap.containsKey(areaLineInfoVO.getSmallObjType())) {
+//                        it.setObjType(sysDicTreePOMap.get(areaLineInfoVO.getSmallObjType()).getName());
+//                    }
+//                    if (userMap.containsKey(areaLineInfoVO.getObjId())) {
+//                        it.setObjName(userMap.get(areaLineInfoVO.getObjId()).getProjectName());
+//                    }
                 }
-            });
+            }
+            result.clear();
+            result.addAll(info);
         }
     }
 

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/DeviceRunEvaluateServiceImpl.java

@@ -350,8 +350,10 @@ public class DeviceRunEvaluateServiceImpl implements DeviceRunEvaluateService {
         Map<String, String> deptMap = deptList.stream().collect(Collectors.toMap(Dept::getId, Dept::getName));
 
         List<DeviceRunEvaluateVO.Detail> info = new ArrayList<>();
+        List<Integer> devRun=ObjectUtil.isNull(param.getLineRunFlag()) ? null : Arrays.asList(param.getLineRunFlag());
+        param.setLineRunFlag(null);
         //获取终端台账类信息
-        List<GeneralDeviceDTO> deviceInfo = deviceService.getDeviceInfo(param, ObjectUtil.isNull(param.getLineRunFlag()) ? null : Arrays.asList(param.getLineRunFlag()), Arrays.asList(1));
+        List<GeneralDeviceDTO> deviceInfo = deviceService.getDeviceInfo(param, devRun, Arrays.asList(1));
         if (CollUtil.isNotEmpty(deviceInfo)) {
             List<String> deviceIds = deviceInfo.stream()
                     .flatMap(x -> x.getDeviceIndexes().stream()).collect(Collectors.toList())
@@ -382,8 +384,6 @@ public class DeviceRunEvaluateServiceImpl implements DeviceRunEvaluateService {
             onlineRateParam.setIds(lineIds);
             List<PqDataVerifyCount> sumVerify = pqDataVerifyCountService.getSumVerify(onlineRateParam);
 
-            //超标率
-            // List<RStatLimitRateDPO> limitRatePOList = rStatLimitRateDClient.monitorIdsGetLimitInfo(rStatLimitQueryParam).getData();
 
             for (GeneralDeviceDTO dto : deviceInfo) {
                 detail = new DeviceRunEvaluateVO.Detail();
@@ -391,7 +391,7 @@ public class DeviceRunEvaluateServiceImpl implements DeviceRunEvaluateService {
                 detail.setCount(dto.getDeviceIndexes().size());
                 detail.setOnline(onLineRate(onlineRateByDev, dto.getDeviceIndexes()));
                 detail.setIntegrity(integrity(integrityList, dto.getLineIndexes()));
-                detail.setQualified(verify(sumVerify, dto.getLineIndexes()));
+                detail.setQualified(verifyDev(sumVerify, dto.getLineIndexes(), dto.getDeviceIndexes()));
                 detail.setScore(ONINTEGRITY.multiply(detail.getIntegrity())
                         .add(ONLINERATE.multiply(detail.getOnline())
                                 .add(LIMITRATE.multiply(detail.getQualified()))).stripTrailingZeros().setScale(2, RoundingMode.HALF_UP));
@@ -434,18 +434,28 @@ public class DeviceRunEvaluateServiceImpl implements DeviceRunEvaluateService {
         return info;
     }
 
+    private BigDecimal verifyDev(List<PqDataVerifyCount> sumVerify, List<String> lineIds, List<String> devIds) {
+        //异常率
+        List<PqDataVerifyCount> verifyList = sumVerify.stream().filter(x->x.getTotal()>0).filter(x -> lineIds.contains(x.getLineId())).collect(Collectors.toList());
+        List<String> verifyLine = verifyList.stream().map(PqDataVerifyCount::getLineId).distinct().collect(Collectors.toList());
+        List<String> devIdsLine = lineMapper.getDevIdsLine(verifyLine);
+        if (CollUtil.isNotEmpty(devIdsLine)) {
+            return NumberUtil.round(Math.min(devIdsLine.size()  * 100.0 / devIds.size(), 100), 2);
+        } else {
+            return new BigDecimal(0);
+        }
+    }
+
     private BigDecimal verify(List<PqDataVerifyCount> sumVerify, List<String> lineIds) {
         //异常率
         List<PqDataVerifyCount> verifyList = sumVerify.stream().filter(x -> lineIds.contains(x.getLineId())).collect(Collectors.toList());
         if (CollUtil.isNotEmpty(verifyList)) {
             double total = verifyList.stream().mapToDouble(PqDataVerifyCount::getTotal).sum();
             double totalAll = verifyList.stream().mapToDouble(PqDataVerifyCount::getTotalAll).sum();
-            double flicker = verifyList.stream().mapToDouble(PqDataVerifyCount::getFlicker).sum();
-            double flickerAll = verifyList.stream().mapToDouble(PqDataVerifyCount::getFlickerAll).sum();
-            if (totalAll + flickerAll == 0) {
+            if (totalAll  == 0) {
                 return new BigDecimal(0);
             }
-            return NumberUtil.round(Math.min((total + flicker) * 100 / (totalAll + flickerAll), 100), 2);
+            return NumberUtil.round(Math.min(total  * 100.0 / totalAll, 100), 2);
         } else {
             return new BigDecimal(0);
         }
@@ -460,7 +470,7 @@ public class DeviceRunEvaluateServiceImpl implements DeviceRunEvaluateService {
             if (dueTime == 0) {
                 return new BigDecimal(0);
             }
-            return NumberUtil.round(Math.min(realTime * 100 / dueTime, 100), 2);
+            return NumberUtil.round(Math.min(realTime * 100.0 / dueTime, 100), 2);
         } else {
             return new BigDecimal(0);
         }

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/PqDataVerifyBakServiceImpl.java

@@ -18,10 +18,12 @@ import com.njcn.dataProcess.enums.DataCleanEnum;
 import com.njcn.dataProcess.param.DataCleanParam;
 import com.njcn.dataProcess.pojo.dto.PqReasonableRangeDto;
 import com.njcn.device.line.mapper.LineMapper;
+import com.njcn.device.line.service.DeptLineService;
 import com.njcn.device.pq.constant.Param;
 import com.njcn.device.pq.enums.LineBaseEnum;
 import com.njcn.device.pq.mapper.PqDataVerifyBakMapper;
 import com.njcn.device.pq.pojo.param.dataClean.MonitorBaseParam;
+import com.njcn.device.pq.pojo.po.DeptLine;
 import com.njcn.device.pq.pojo.po.PqDataVerifyBak;
 import com.njcn.device.pq.pojo.vo.AreaLineInfoVO;
 import com.njcn.device.pq.pojo.vo.LineDetailDataVO;
@@ -33,10 +35,7 @@ import com.njcn.device.pq.service.CommTerminalService;
 import com.njcn.device.pq.service.IPqDataVerifyBakService;
 import com.njcn.oss.utils.FileStorageUtil;
 import com.njcn.supervision.api.UserLedgerFeignClient;
-import com.njcn.supervision.pojo.vo.user.NewUserReportVO;
 import com.njcn.system.api.DictTreeFeignClient;
-import com.njcn.system.enums.DicDataEnum;
-import com.njcn.system.pojo.po.SysDicTreePO;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -65,19 +64,13 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
 
     private static final String SEPARATOR = "-";
     private static final DateTimeFormatter DATE_FORMAT = DateTimeFormatter.ofPattern(DatePattern.NORM_DATE_PATTERN);
-
     private final CommTerminalService commTerminalService;
-
     private final PqReasonableRangeFeignClient pqReasonableRangeFeignClient;
-
     private final LineMapper lineMapper;
-
     private final DictTreeFeignClient dictTreeFeignClient;
-
     private final UserLedgerFeignClient userLedgerFeignClient;
-
     private final FileStorageUtil fileStorageUtil;
-
+    private final DeptLineService deptLineService;
 
     @Override
     public VerifyMonitorVO getMonitorVerifyData(MonitorBaseParam monitorBaseParam) {
@@ -94,7 +87,6 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
         } else {
             verifyMonitorVO.setRunNum(0);
             verifyMonitorVO.setAbnormalNum(0);
-
             verifyMonitorVO.setMapList(getRangeAbnormalMonitor(monitorBaseParam, new ArrayList<>()));
             verifyMonitorVO.setTargetList(getAbnormalTarget(new ArrayList<>()));
             verifyMonitorVO.setMonitorAlarmInfo(getAbnormalTable(new ArrayList<>(), monitorBaseParam));
@@ -111,7 +103,7 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
             List<LocalDate> dateList = list.stream().map(PqDataVerifyBak::getTimeId).sorted(Comparator.comparing(Function.identity())).collect(Collectors.toList());
             processTable(monitorBaseParam, dateList, result, key);
         });
-        dealTableResult(result);
+        dealTableResult(result, monitorBaseParam.getSearchValue());
         return result;
     }
 
@@ -137,34 +129,44 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
         }
     }
 
-    private void dealTableResult(List<PowerQualityIndicatorsVO> result) {
+    private void dealTableResult(List<PowerQualityIndicatorsVO> result, String searchValue) {
         if (CollUtil.isNotEmpty(result)) {
-            List<SysDicTreePO> dicTreePOList = dictTreeFeignClient.queryAllByType(Integer.valueOf(DicDataEnum.Obj_Type.getCode())).getData();
-            Map<String, SysDicTreePO> sysDicTreePOMap = dicTreePOList.stream().collect(Collectors.toMap(SysDicTreePO::getId, Function.identity()));
+//            List<SysDicTreePO> dicTreePOList = dictTreeFeignClient.queryAllByType(Integer.valueOf(DicDataEnum.Obj_Type.getCode())).getData();
+//            Map<String, SysDicTreePO> sysDicTreePOMap = dicTreePOList.stream().collect(Collectors.toMap(SysDicTreePO::getId, Function.identity()));
             List<String> ids = result.stream().map(PowerQualityIndicatorsVO::getMonitorId).distinct().collect(Collectors.toList());
-            List<AreaLineInfoVO> areaLineInfoVOList = lineMapper.getBaseLineAreaInfo(ids, null, null);
-            Map<String, AreaLineInfoVO> areaMap = areaLineInfoVOList.stream().collect(Collectors.toMap(AreaLineInfoVO::getLineId, Function.identity()));
-
-            List<String> objIds = areaLineInfoVOList.stream().map(AreaLineInfoVO::getObjId).distinct().collect(Collectors.toList());
-            List<NewUserReportVO> userLedgerVOList = userLedgerFeignClient.getUserReportByIds(objIds).getData();
-            Map<String, NewUserReportVO> userMap = userLedgerVOList.stream().collect(Collectors.toMap(NewUserReportVO::getId, Function.identity()));
-            result.forEach(it -> {
-                if (areaMap.containsKey(it.getMonitorId())) {
-                    AreaLineInfoVO areaLineInfoVO = areaMap.get(it.getMonitorId());
-                    it.setMonitorName(areaLineInfoVO.getLineName());
-                    it.setStationName(areaLineInfoVO.getSubName());
-                    it.setDevName(areaLineInfoVO.getDeviceName());
-                    it.setVoltageLevel(areaLineInfoVO.getVoltageScale());
-                    it.setIp(Base64.encode(areaLineInfoVO.getIp()));
-                    it.setManufacturer(areaLineInfoVO.getManufacturer());
-                    if (sysDicTreePOMap.containsKey(areaLineInfoVO.getSmallObjType())) {
-                        it.setObjType(sysDicTreePOMap.get(areaLineInfoVO.getSmallObjType()).getName());
-                    }
-                    if (userMap.containsKey(areaLineInfoVO.getObjId())) {
-                        it.setObjName(userMap.get(areaLineInfoVO.getObjId()).getProjectName());
+            List<AreaLineInfoVO> areaLineInfoVOList = lineMapper.getBaseLineAreaInfo(ids, searchValue, null);
+            Map<String, PowerQualityIndicatorsVO> areaMap = result.stream().collect(Collectors.toMap(PowerQualityIndicatorsVO::getMonitorId, Function.identity()));
+            List<DeptLine> deptLines = deptLineService.selectDeptLine(ids);
+            Map<String, String> deptName = deptLines.stream().collect(Collectors.toMap(DeptLine::getLineId, DeptLine::getId));
+//            List<String> objIds = areaLineInfoVOList.stream().map(AreaLineInfoVO::getObjId).distinct().collect(Collectors.toList());
+//            List<NewUserReportVO> userLedgerVOList = userLedgerFeignClient.getUserReportByIds(objIds).getData();
+//            Map<String, NewUserReportVO> userMap = userLedgerVOList.stream().collect(Collectors.toMap(NewUserReportVO::getId, Function.identity()));
+            List<PowerQualityIndicatorsVO> info = new ArrayList<>();
+            for (AreaLineInfoVO lineDetail : areaLineInfoVOList) {
+                if (areaMap.containsKey(lineDetail.getLineId())) {
+                    PowerQualityIndicatorsVO it = areaMap.get(lineDetail.getLineId());
+                    it.setMonitorName(lineDetail.getLineName());
+                    it.setStationName(lineDetail.getSubName());
+                    it.setDevName(lineDetail.getDeviceName());
+                    if(deptName.containsKey(lineDetail.getLineId())){
+                        it.setCity(deptName.get(lineDetail.getLineId()));
                     }
+                    it.setVoltageLevel(lineDetail.getVoltageScale());
+                    it.setIp(Base64.encode(lineDetail.getIp()));
+                    it.setManufacturer(lineDetail.getManufacturer());
+                    it.setObjType(lineDetail.getLoadType());
+                    it.setObjName(lineDetail.getObjName());
+                    info.add(it);
+//                    if (sysDicTreePOMap.containsKey(areaLineInfoVO.getSmallObjType())) {
+//                        it.setObjType(sysDicTreePOMap.get(areaLineInfoVO.getSmallObjType()).getName());
+//                    }
+//                    if (userMap.containsKey(areaLineInfoVO.getObjId())) {
+//                        it.setObjName(userMap.get(areaLineInfoVO.getObjId()).getProjectName());
+//                    }
                 }
-            });
+            }
+            result.clear();
+            result.addAll(info);
         }
     }
 
@@ -267,97 +269,29 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
             }
         }
         List<PqDataVerifyBak> dataVerifyList = this.list(lambdaQueryWrapper);
-        for (PqDataVerifyBak pqDataVerifyBak : dataVerifyList) {
-            LineDetailDataVO lineDevGetDTO = lineDetailMap.get(pqDataVerifyBak.getLineId());
+        Map<String, List<PqDataVerifyBak>> VerifyMap = dataVerifyList.stream().collect(Collectors.groupingBy(PqDataVerifyBak::getLineId));
+        VerifyMap.forEach((key, value) -> {
+            LineDetailDataVO lineDevGetDTO = lineDetailMap.get(key);
             String temBgName = "";
             if (lineDevGetDTO.getPowerFlag().equals(LineBaseEnum.POWER_FLAG.getCode())) {
                 temBgName = lineDevGetDTO.getBdName();
             } else if (lineDevGetDTO.getPowerFlag().equals(LineBaseEnum.POWER_FLAG_NOT.getCode())) {
                 temBgName = lineDevGetDTO.getObjName();
             }
-            try (InputStream fileStream = fileStorageUtil.getFileStream(pqDataVerifyBak.getPath())) {
-                JSONArray jsonArray = new JSONArray(new JSONTokener(fileStream, new JSONConfig()));
-                String[] errorTimeCount = {"0"};
-                Long[] errAllCount = {0L};
-                jsonArray.forEach(it -> {
-                    JSONObject targetJson = (JSONObject) it;
-                    if (StrUtil.isNotBlank(monitorBaseParam.getTargetKey())) {
-                        if (targetJson.containsKey(monitorBaseParam.getTargetKey())) {
-                            JSONArray innerJson = targetJson.getJSONArray(monitorBaseParam.getTargetKey());
-                            PqReasonableRangeDto dto = rangeMap.get(monitorBaseParam.getTargetKey());
-                            if (Objects.nonNull(dto.getHarmStart()) && Objects.nonNull(dto.getHarmEnd())) {
-                                errorTimeCount[0] = targetJson.get("errorTimes").toString();
-                                for (Object oJson : innerJson) {
-                                    JSONObject jsonObjectTem = (JSONObject) oJson;
-                                    JSONArray list = jsonObjectTem.getJSONArray("list");
-                                    list.forEach(listItem -> {
-                                        JSONObject object = (JSONObject) listItem;
-                                        long errCount = Long.parseLong(object.get("errorCounts").toString());
-                                        errAllCount[0] += errCount;
-                                    });
-                                }
-                            } else {
-                                for (Object oJson : innerJson) {
-                                    JSONObject jsonObjectTem = (JSONObject) oJson;
-                                    JSONArray list = jsonObjectTem.getJSONArray("list");
-                                    list.forEach(listItem -> {
-                                        JSONObject object = (JSONObject) listItem;
-                                        long errCount = Long.parseLong(object.get("errorCounts").toString());
-                                        errAllCount[0] += errCount;
-                                    });
-                                    errorTimeCount[0] = jsonObjectTem.get("errorTimes").toString();
-                                }
-                            }
-                        }
-                    } else {
-                        rangeMap.forEach((rangeKey, val) -> {
-                            if (targetJson.containsKey(rangeKey)) {
-                                JSONArray innerJson = targetJson.getJSONArray(rangeKey);
-                                for (Object oJson : innerJson) {
-                                    JSONObject jsonObjectTem = (JSONObject) oJson;
-                                    JSONArray list = jsonObjectTem.getJSONArray("list");
-                                    list.forEach(listItem -> {
-                                        JSONObject object = (JSONObject) listItem;
-                                        long errCount = Long.parseLong(object.get("errorCounts").toString());
-                                        errAllCount[0] += errCount;
-                                    });
-                                }
-                            }
-                        });
-                        if (targetJson.containsKey("lineErrorTimes")) {
-                            errorTimeCount[0] = targetJson.get("lineErrorTimes").toString();
-                        }
-                    }
-                });
-                DetailAbnormalVO detailAbnormalVO = new DetailAbnormalVO();
-                detailAbnormalVO.setTimeSum(errorTimeCount[0]);
-                detailAbnormalVO.setDate(pqDataVerifyBak.getTimeId().format(DateTimeFormatter.ofPattern(DatePattern.NORM_DATE_PATTERN)));
-                detailAbnormalVO.setMonitorName(lineDevGetDTO.getLineName());
-                detailAbnormalVO.setBdName(temBgName);
-                detailAbnormalVO.setMonitorId(lineDevGetDTO.getLineId());
-                detailAbnormalVO.setTargetKey(monitorBaseParam.getTargetKey());
-                detailAbnormalVO.setErrCount(errAllCount[0].toString());
-                result.add(detailAbnormalVO);
-            } catch (BusinessException b) {
-                //文件为空时候的特殊处理
-                DetailAbnormalVO detailAbnormalVO = new DetailAbnormalVO();
-                detailAbnormalVO.setTimeSum("/");
-                detailAbnormalVO.setDate(pqDataVerifyBak.getTimeId().format(DateTimeFormatter.ofPattern(DatePattern.NORM_DATE_PATTERN)));
-                detailAbnormalVO.setMonitorName(lineDevGetDTO.getLineName());
-                detailAbnormalVO.setBdName(temBgName);
-                detailAbnormalVO.setMonitorId(lineDevGetDTO.getLineId());
-                detailAbnormalVO.setTargetKey(monitorBaseParam.getTargetKey());
-                result.add(detailAbnormalVO);
-            } catch (Exception e) {
-                throw new BusinessException("数据异常");
-            }
-        }
+            DetailAbnormalVO detailAbnormalVO = new DetailAbnormalVO();
+            detailAbnormalVO.setDateList(value.stream().map(x -> x.getTimeId().format(DatePattern.NORM_DATE_FORMATTER)).collect(Collectors.toList()));
+            detailAbnormalVO.setMonitorName(lineDevGetDTO.getLineName());
+            detailAbnormalVO.setBdName(temBgName);
+            detailAbnormalVO.setMonitorId(lineDevGetDTO.getLineId());
+            detailAbnormalVO.setTargetKey(monitorBaseParam.getTargetKey());
+            result.add(detailAbnormalVO);
+        });
         return result;
     }
 
 
     @Override
-    public List<DetailAbnormalVO.DetailAbnormalInnerVO> monitorAbnormalTableDetail(MonitorBaseParam monitorBaseParam) {
+    public DetailAbnormalVO.DetailAbnormalCountVO monitorAbnormalTableDetail(MonitorBaseParam monitorBaseParam) {
         Map<String, PqReasonableRangeDto> dtoMap = getStandRange();
         if (StrUtil.isNotBlank(monitorBaseParam.getTargetKey())) {
             if (!dtoMap.containsKey(monitorBaseParam.getTargetKey())) {
@@ -366,44 +300,50 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
         }
         List<DetailAbnormalVO.DetailAbnormalInnerVO> result = new ArrayList<>();
         LambdaQueryWrapper<PqDataVerifyBak> lambdaQueryWrapper = new LambdaQueryWrapper<>();
-        lambdaQueryWrapper.eq(PqDataVerifyBak::getTimeId, DateUtil.beginOfDay(DateUtil.parse(monitorBaseParam.getSearchBeginTime())))
-                .in(PqDataVerifyBak::getLineId, monitorBaseParam.getMonitorIds()).orderByAsc(PqDataVerifyBak::getTimeId);
+        lambdaQueryWrapper.in(PqDataVerifyBak::getTimeId, monitorBaseParam.getTime())
+                .in(PqDataVerifyBak::getLineId, monitorBaseParam.getMonitorIds());
 
-        PqDataVerifyBak pqDataVerifyBak = this.getOne(lambdaQueryWrapper);
-        try (InputStream fileStream = fileStorageUtil.getFileStream(pqDataVerifyBak.getPath())) {
-            JSONArray jsonArray = new JSONArray(new JSONTokener(fileStream, new JSONConfig()));
-            for (Object it : jsonArray) {
-                JSONObject targetJson = (JSONObject) it;
-                if (targetJson.containsKey("lineErrorTimes")) {
-                    continue;
-                }
-                if (StrUtil.isNotBlank(monitorBaseParam.getTargetKey())) {
-                    if (targetJson.containsKey(monitorBaseParam.getTargetKey())) {
-                        resultDeal(dtoMap, monitorBaseParam.getTargetKey(), targetJson, result);
-                        break;
-                    }
-                } else {
-                    String tarKey = "";
-                    for (Map.Entry<String, PqReasonableRangeDto> entry : dtoMap.entrySet()) {
-                        String key = entry.getKey();
-                        if (targetJson.containsKey(key)) {
-                            tarKey = key;
-                            break;
+        List<PqDataVerifyBak> pqDataVerifyBak = this.list(lambdaQueryWrapper);
+        Integer[] errorTimeCount = {0};
+        Integer[] errAllCount = {0};
+        for (PqDataVerifyBak dataVerifyBak : pqDataVerifyBak) {
+            try (InputStream fileStream = fileStorageUtil.getFileStream(dataVerifyBak.getPath())) {
+                JSONArray jsonArray = new JSONArray(new JSONTokener(fileStream, new JSONConfig()));
+                jsonArray.forEach(it->{
+                    JSONObject targetJson = (JSONObject) it;
+                    if (targetJson.containsKey("lineErrorTimes")) {
+                        errorTimeCount[0] += Integer.valueOf(targetJson.get("lineErrorTimes").toString());
+                    }else{
+                        if (StrUtil.isNotBlank(monitorBaseParam.getTargetKey())) {
+                            if (targetJson.containsKey(monitorBaseParam.getTargetKey())) {
+                                resultDeal(dtoMap, monitorBaseParam.getTargetKey(), targetJson, result, dataVerifyBak.getTimeId().toString(), errAllCount);
+                            }
+                        } else {
+                            String tarKey = "";
+                            for (Map.Entry<String, PqReasonableRangeDto> entry : dtoMap.entrySet()) {
+                                String key = entry.getKey();
+                                if (targetJson.containsKey(key)) {
+                                    tarKey = key;
+                                }
+                            }
+                            resultDeal(dtoMap, tarKey, targetJson, result, dataVerifyBak.getTimeId().toString(), errAllCount);
                         }
                     }
-                    resultDeal(dtoMap, tarKey, targetJson, result);
-                }
+                });
+            } catch (Exception e) {
+                throw new BusinessException("数据异常" + e);
             }
-        } catch (Exception e) {
-            throw new BusinessException("数据异常");
         }
         // 排序实现
-        result = result.stream()
-                .sorted(Comparator.comparing(DetailAbnormalVO.DetailAbnormalInnerVO::getTime)
+        DetailAbnormalVO.DetailAbnormalCountVO info = new DetailAbnormalVO.DetailAbnormalCountVO();
+        info.setTimeSum(errorTimeCount[0]);
+        info.setErrCount(errAllCount[0]);
+        info.setTime(result.stream()
+                .sorted(Comparator.comparing(DetailAbnormalVO.DetailAbnormalInnerVO::getTargetName)
                         .thenComparing(vo -> extractHarmonicOrder(vo.getTargetName()))
-                        .thenComparing(DetailAbnormalVO.DetailAbnormalInnerVO::getTargetName))
-                .collect(Collectors.toList());
-        return result;
+                        .thenComparing(DetailAbnormalVO.DetailAbnormalInnerVO::getTime))
+                .collect(Collectors.toList()));
+        return info;
     }
 
 
@@ -431,12 +371,13 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
      * 处理json对象中list数组
      */
 
-    private void resultDeal(Map<String, PqReasonableRangeDto> dtoMap, String targetKey, JSONObject targetJson, List<DetailAbnormalVO.DetailAbnormalInnerVO> result) {
+    private void resultDeal(Map<String, PqReasonableRangeDto> dtoMap, String targetKey, JSONObject targetJson, List<DetailAbnormalVO.DetailAbnormalInnerVO> result, String date, Integer[] errorCounts) {
         PqReasonableRangeDto pqReasonableRangeDto = dtoMap.get(targetKey);
         JSONArray innerJson = targetJson.getJSONArray(targetKey);
         innerJson.forEach(oo -> {
             JSONObject jsonObjectTem = (JSONObject) oo;
             String targetName = jsonObjectTem.get("targetName").toString();
+            errorCounts[0] += Integer.valueOf(jsonObjectTem.get("errorCounts").toString());
             JSONArray list = jsonObjectTem.getJSONArray("list");
             List<DetailAbnormalVO.DetailLimitInnerVO> temList = new ArrayList<>();
             list.forEach(listItem -> {
@@ -447,7 +388,7 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
                 String valueType = object.get("valueType").toString();
                 for (int i = 0; i < timeArr.size(); i++) {
                     DetailAbnormalVO.DetailLimitInnerVO temData = new DetailAbnormalVO.DetailLimitInnerVO();
-                    temData.setTime(timeArr.get(i).toString());
+                    temData.setTime(date + " " + timeArr.get(i).toString());
                     temData.setVal(valueArr.get(i).toString());
                     temData.setTargetName(targetName);
                     temData.setTargetKey(targetKey);
@@ -475,11 +416,11 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
                         vo.setTargetKey(targetKey);
                         vo.setPhaseType(phaseKey);
 
-                        if ((DataCleanEnum.DataI.getCode() + SEPARATOR + DataCleanEnum.RmsI.getCode() ).equals(targetKey)) {
-                            vo.setRangeDesc(pqReasonableRangeDto.getMinValue() + unit + " ~ " + pqReasonableRangeDto.getMaxValue() + "*CT1" + unit);
-                        } else {
+//                        if ((DataCleanEnum.DataI.getCode() + SEPARATOR + DataCleanEnum.RmsI.getCode() ).equals(targetKey)) {
+//                            vo.setRangeDesc(pqReasonableRangeDto.getMinValue() + unit + " ~ " + pqReasonableRangeDto.getMaxValue() + "*CT1" + unit);
+//                        } else {
                             vo.setRangeDesc(pqReasonableRangeDto.getMinValue() + unit + " ~ " + pqReasonableRangeDto.getMaxValue() + unit);
-                        }
+//                        }
                         valueList.forEach(ites -> {
                             switch (ites.getType()) {
                                 case "AVG":
@@ -493,6 +434,7 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
                                     break;
                                 case "CP95":
                                     vo.setCp95(ites.getVal());
+                                    break;
                                 case "Feature_Amplitude":
                                     vo.setFeatureAmplitude(ites.getVal());
                                     break;
@@ -685,12 +627,11 @@ public class PqDataVerifyBakServiceImpl extends ServiceImpl<PqDataVerifyBakMappe
         if (StrUtil.isNotBlank(dto.getUnit())) {
             unit = dto.getUnit();
         }
-        if (temStr.equals(Param.rms_i)) {
-            verifyTargetVO.setRangeDesc(dto.getMinValue() + unit + " ~ " + dto.getMaxValue() + "*CT1" + unit);
-        } else {
+//        if (temStr.equals(Param.rms_i)) {
+//            verifyTargetVO.setRangeDesc(dto.getMinValue() + unit + " ~ " + dto.getMaxValue() + "*CT1" + unit);
+//        } else {
             verifyTargetVO.setRangeDesc(dto.getMinValue() + unit + " ~ " + dto.getMaxValue() + unit);
-        }
-
+//        }
         result.add(verifyTargetVO);
     }
 

pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/RunManageServiceImpl.java

@@ -82,7 +82,7 @@ public class RunManageServiceImpl implements RunManageService {
             DeviceInfoParam deviceInfoParam = new DeviceInfoParam();
             BeanUtil.copyProperties(runManageParam, deviceInfoParam);
             deviceInfoParam.setServerName("pqs-common");
-            List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceService.getDeviceInfo(deviceInfoParam, Stream.of(0,1,2).collect(Collectors.toList()), Stream.of(1).collect(Collectors.toList()));
+            List<GeneralDeviceDTO> generalDeviceDTOList = generalDeviceService.getDeviceInfo(deviceInfoParam, null, Stream.of(1).collect(Collectors.toList()));
             lineIndexes = generalDeviceDTOList.stream().flatMap(list -> list.getLineIndexes().stream()).collect(Collectors.toList());
         }
         if (!CollectionUtils.isEmpty(lineIndexes)) {

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/device/mapper/mapping/DeviceMapper.xml

@@ -339,10 +339,10 @@
         </if>
         <if test="searchValue != '' and searchValue != null ">
             <bind name="searchValueLike" value="'%'+searchValue+'%'"/>
-            AND sub.NAME LIKE #{searchValueLike}
+            AND (sub.NAME LIKE #{searchValueLike}
             OR dev.NAME LIKE #{searchValueLike}
             OR devT.Name LIKE #{searchValueLike}
-            OR device.IP LIKE #{searchValueLike}
+            OR device.IP LIKE #{searchValueLike})
         </if>
         ORDER BY
         gdName,

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/device/service/impl/OnLineRateServiceImpl.java

@@ -36,8 +36,10 @@ public class OnLineRateServiceImpl extends ServiceImpl<OnLineRateMapper, RStatOn
     @Override
     public DeviceOnlineRate deviceOnlineRateInfo(DeviceInfoParam.BusinessParam param) {
         DeviceOnlineRate rate = new DeviceOnlineRate();
+        List<Integer> devRun = ObjectUtil.isNull(param.getLineRunFlag()) ? null : Arrays.asList(param.getLineRunFlag());
+        param.setLineRunFlag(null);
         //获取终端台账类信息
-        List<GeneralDeviceDTO> deviceInfo = deviceService.getDeviceInfo(param, ObjectUtil.isNull(param.getLineRunFlag()) ? null : Arrays.asList(param.getLineRunFlag()), Arrays.asList(1));
+        List<GeneralDeviceDTO> deviceInfo = deviceService.getDeviceInfo(param, devRun, Arrays.asList(1));
         if (CollUtil.isNotEmpty(deviceInfo)) {
             List<String> deviceIds = deviceInfo.stream()
                     .flatMap(x -> x.getDeviceIndexes().stream()).collect(Collectors.toList())

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/DeptLineMapper.java

@@ -81,7 +81,8 @@ public interface DeptLineMapper extends BaseMapper<DeptLine> {
     List<TerminalGetBase.Extend> orgSubStationInfoGet(@Param("list")List<Integer> devType,
                                                       @Param("powerFlag")Integer powerFlag,
                                                       @Param("lineRunFlag") Integer lineRunFlag,
-                                                      @Param("monitorFlag") Integer monitorFlag
+                                                      @Param("monitorFlag") Integer monitorFlag,
+                                                      @Param("searchValue") String searchValue
     );
 
     List<String> getLineIdByDeptIds(@Param("deptIds")List<String> deptIds,

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/LineMapper.java

@@ -579,4 +579,13 @@ public interface LineMapper extends BaseMapper<Line> {
      * 根据Pid获取所有子节点
      */
     List<String> getSubIdByPid(@Param("pid") String pid);
+
+
+    /**
+     * 根据监测点id获取终端id
+     *
+     * @param ids 监测点集合
+     * @return 结果
+     */
+    List<String> getDevIdsLine(@Param("ids") List<String> ids);
 }

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/DeptLineMapper.xml

@@ -194,6 +194,12 @@
         <if test="monitorFlag!=null ">
             and lineDetail.Monitor_Flag = #{monitorFlag}
         </if>
+        <if test="searchValue != '' and searchValue != null ">
+            <bind name="searchValueLike" value="'%'+searchValue+'%'"/>
+            AND (substation.name LIKE #{searchValueLike}
+            OR point.NAME LIKE #{searchValueLike}
+            )
+        </if>
     </select>
     <select id="getLineIdByDeptIds" resultType="string">
         select

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/mapper/mapping/LineMapper.xml

@@ -294,7 +294,7 @@
                 #{item.id}
             </foreach>
         </if>
-        <if test="deviceInfoParam.searchValue!=null  and deviceInfoParam.lineOrDevice==0">
+        <if test="deviceInfoParam.searchValue!=null and  deviceInfoParam.searchValue!='' and deviceInfoParam.lineOrDevice==0">
             AND t1.name like CONCAT(CONCAT('%', #{deviceInfoParam.searchValue}), '%')
         </if>
         <!-- xy -->
@@ -344,7 +344,7 @@
                     #{item.id}
                 </foreach>
             </if>
-            <if test="deviceInfoParam.searchValue!=null  and deviceInfoParam.lineOrDevice==1">
+            <if test="deviceInfoParam.searchValue!=null and deviceInfoParam.searchValue!='' and deviceInfoParam.lineOrDevice==1">
                 AND t1.name like CONCAT(CONCAT('%', #{deviceInfoParam.searchValue}), '%')
             </if>
             <if test="devIds!=null and devIds.size()!=0">
@@ -570,7 +570,8 @@
         detail.New_Station_Id as newStationId,
         detail.obj_id,
         detail.big_obj_type,
-        detail.small_obj_type
+        detail.small_obj_type,
+        detail.Power_Flag powerFlag
         FROM
         pq_line line,
         pq_line_detail detail,
@@ -1541,7 +1542,7 @@
     <select id="selectByIds" resultType="com.njcn.device.pq.pojo.vo.LineDetailVO$Detail">
         SELECT DISTINCT
             line.id as lineId,
-            dept.`Name` deptName,
+            dept.Name deptName,
             area.name as areaId,
             gd.NAME gdName,
             substation.NAME subName,
@@ -1934,5 +1935,19 @@
             AND t2.Monitor_Flag = 0
         </if>
     </select>
+    <select id="getDevIdsLine" resultType="java.lang.String">
+        SELECT
+            DISTINCT   d.id
+        FROM
+            pq_line a
+        INNER JOIN pq_line v ON a.pid = v.id
+        INNER JOIN pq_line d ON v.pid = d.id
+        where
+            a.id in
+            <foreach collection="ids" separator="," open="(" close=")" item="item">
+                #{item}
+            </foreach>
+
+    </select>
 
 </mapper>

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/service/DeptLineService.java

@@ -44,6 +44,13 @@ public interface DeptLineService extends IService<DeptLine> {
     List<DeptLine> selectDeptBindLines(List<String> ids);
 
 
+    /**
+     * 根据监测点id获取部门信息
+     * @param ids
+     * @return
+     */
+    List<DeptLine> selectDeptLine(List<String> ids);
+
     /**
      * 根据部门ids集合查询所有监测点id
      * @param ids 部门ids
@@ -115,7 +122,7 @@ public interface DeptLineService extends IService<DeptLine> {
     Map<String, List<TerminalGetBase>> orgSubStationGet(List<Integer> devType);
 
 
-    List<TerminalGetBase.Extend> orgSubStationInfoGet(List<Integer> devType,Integer powerFlag,Integer lineRunFlag,Integer monitorFlag);
+    List<TerminalGetBase.Extend> orgSubStationInfoGet(List<Integer> devType,Integer powerFlag,Integer lineRunFlag,Integer monitorFlag,String searchValue);
 
     List<SubGetBase> getSubStationList(SubstationParam substationParam);
 

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/line/service/impl/DeptLineServiceImpl.java

@@ -27,6 +27,7 @@ import com.njcn.system.pojo.vo.DictTreeVO;
 import com.njcn.user.api.DeptFeignClient;
 import com.njcn.user.pojo.dto.DeptDTO;
 import com.njcn.user.pojo.po.Dept;
+import com.njcn.user.pojo.vo.PvTerminalTreeVO;
 import com.njcn.web.pojo.param.DeptLineParam;
 import com.njcn.web.utils.WebUtil;
 import lombok.RequiredArgsConstructor;
@@ -34,9 +35,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -81,6 +80,15 @@ public class DeptLineServiceImpl extends ServiceImpl<DeptLineMapper, DeptLine> i
                 detailMapper.update(null, new LambdaUpdateWrapper<LineDetail>()
                         .set(LineDetail::getActualArea, data.getArea())
                         .in(LineDetail::getId, lineIds));
+            } else {
+                List<String> deptList = Arrays.asList("130700000000", "130300000000", "130800000000", "130200000000", "131000000000");
+                Dept data = deptFeignClient.getDeptById(deptLineParam.getId()).getData();
+                if (deptList.contains(data.getArea())) {
+                    List<String> lineIds = list.stream().map(LineDetail::getId).collect(Collectors.toList());
+                    detailMapper.update(null, new LambdaUpdateWrapper<LineDetail>()
+                            .set(LineDetail::getActualArea, data.getArea())
+                            .in(LineDetail::getId, lineIds));
+                }
             }
         }
         this.saveBatch(deptLines);
@@ -101,6 +109,22 @@ public class DeptLineServiceImpl extends ServiceImpl<DeptLineMapper, DeptLine> i
         return this.lambdaQuery().in(DeptLine::getId, ids).list();
     }
 
+    @Override
+    public List<DeptLine> selectDeptLine(List<String> ids) {
+        List<DeptLine> list = this.lambdaQuery().in(DeptLine::getLineId, ids).list();
+        if (CollUtil.isNotEmpty(list)) {
+            List<Dept> data = deptFeignClient.getAllDept().getData();
+            Map<String, String> deptName = data.stream().collect(Collectors.toMap(Dept::getId, Dept::getName));
+            for (DeptLine deptLine : list) {
+                if (deptName.containsKey(deptLine.getId())) {
+                    deptLine.setId(deptName.get(deptLine.getId()));
+                }
+            }
+            return list;
+        }
+        return new ArrayList<>();
+    }
+
     @Override
     public List<String> getLineByDeptIds(List<String> ids,String manufacturer, List<Integer> runFlag, List<Integer> dataType, String objType) {
         return this.baseMapper.getLineIdByDeptIds(ids, manufacturer ,runFlag, dataType, objType);
@@ -182,8 +206,13 @@ public class DeptLineServiceImpl extends ServiceImpl<DeptLineMapper, DeptLine> i
     }
 
     @Override
-    public List<TerminalGetBase.Extend> orgSubStationInfoGet(List<Integer> devType, Integer powerFlag, Integer lineRunFlag,Integer monitorFlag) {
-        return deptLineMapper.orgSubStationInfoGet(devType, powerFlag, lineRunFlag,monitorFlag);
+    public List<TerminalGetBase.Extend> orgSubStationInfoGet(List<Integer> devType,
+                                                             Integer powerFlag,
+                                                             Integer lineRunFlag,
+                                                             Integer monitorFlag,
+                                                             String searchValue
+    ) {
+        return deptLineMapper.orgSubStationInfoGet(devType, powerFlag, lineRunFlag,monitorFlag,searchValue);
     }
 
     @Override

pqs-device/pq-device/pq-device-com/src/main/java/com/njcn/device/rstatintegrity/mapper/mapping/RStatIntegrityDMapper.xml

@@ -112,12 +112,12 @@
 
     <select id="getNoData" resultType="OnlineMonitorVo">
         SELECT DISTINCT
-            t6.`Name` gdName,
-            t5.`Name` subName,
-            t4.`Name` deviceName,
+            t6.Name gdName,
+            t5.Name subName,
+            t4.Name deviceName,
             t1.line_index lineId,
-            t2.`Name` lineName,
-            t8.`Name` monitorObjType,
+            t2.Name lineName,
+            t8.Name monitorObjType,
             t7.Obj_Name monitorObj,
             "完整性为0" as target,
             count(t1.time_id) lastDay

pqs-event/event-api/src/main/java/com/njcn/event/pojo/po/PqDevice.java

@@ -92,7 +92,7 @@ public class PqDevice implements Serializable {
      */
     private Date nextTimeCheck;
     /**
-     * 电镀功能 0关闭 1开启 默认关闭
+     * 电度功能 0关闭 1开启 默认关闭
      */
     private Integer electroplate;
     /**

pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaAnalysisServiceImpl.java

@@ -55,10 +55,10 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
     @Override
     public AreaAnalysisVO getEventReason(DeviceInfoParam.BusinessParam deviceInfoParam) {
         //获取暂降字典信息
-//        DictData voltageData = dicDataFeignClient.getDicDataByCode(DicDataEnum.VOLTAGE_DIP.getCode()).getData();
-//        if(ObjectUtil.isNull(voltageData)){
-//            throw new BusinessException(DeviceResponseEnum.DIC_GET_EMPTY);
-//        }
+        DictData voltageData = dicDataFeignClient.getDicDataByCode(DicDataEnum.VOLTAGE_DIP.getCode()).getData();
+        if(ObjectUtil.isNull(voltageData)){
+            throw new BusinessException(DeviceResponseEnum.DIC_GET_EMPTY);
+        }
         AreaAnalysisVO areaAnalysisVO = new AreaAnalysisVO();
         List<DictData> dicReasonList = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_REASON.getName()).getData();
         List<DictData> dicTypeList = dicDataFeignClient.getDicDataByTypeName(DicDataTypeEnum.EVENT_TYPE.getName()).getData();
@@ -67,11 +67,11 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
         List<String> lineIds = getAllLineIdList(generalDeviceDTOList);
 
         //查询数据
-//        List<AreaAnalysisVO.Children> reasonList = assData(dicReasonList, lineIds, deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(), "event_reason");
+      //  List<AreaAnalysisVO.Children> reasonList = assData(dicReasonList, lineIds, deviceInfoParam.getSearchBeginTime(), deviceInfoParam.getSearchEndTime(), "event_reason");
         List<RmpEventDetailPO> info = eventDetailService.list(new QueryWrapper<RmpEventDetailPO>()
                 .select("advance_reason,advance_type,count(event_id) as count")
                 .in("measurement_point_id", lineIds)
-//                .eq("event_type", voltageData.getId())
+                .eq("event_type", voltageData.getId())
                 .in("advance_reason", dicReasonList.stream().map(DictData::getId).collect(Collectors.toList()))
                 .in("advance_type", dicTypeList.stream().map(DictData::getId).collect(Collectors.toList()))
                 .ge(StrUtil.isNotBlank(deviceInfoParam.getSearchBeginTime()),"start_time" ,DateUtil.beginOfDay(DateUtil.parse(deviceInfoParam.getSearchBeginTime())))
@@ -259,12 +259,10 @@ public class AreaAnalysisServiceImpl implements AreaAnalysisService {
 
     private List<AreaAnalysisVO.Children> assReasonPQ(Map<String, List<String>> stringListMap, List<RmpEventDetailPO> info, String typeId){
         List<AreaAnalysisVO.Children> reasonList = new ArrayList<>();
-
-        List<RmpEventDetailPO> reasons = info.stream().filter(x -> typeId.equals(x.getAdvanceReason())).collect(Collectors.toList());
         Integer allCount = 0;
         for (Map.Entry<String, List<String>> stringListEntry : stringListMap.entrySet()) {
             List<String> value = stringListEntry.getValue();
-            Integer count = reasons.stream().filter(x -> value.contains(x.getAdvanceType())).mapToInt(RmpEventDetailPO::getCount).sum();
+            Integer count = info.stream().filter(x -> value.contains(x.getAdvanceType())).mapToInt(RmpEventDetailPO::getCount).sum();
             AreaAnalysisVO.Children  allType = new AreaAnalysisVO.Children();
             allType.setName(stringListEntry.getKey());
             allType.setValue(count);

pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/AreaInfoServiceImpl.java

@@ -22,10 +22,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.stereotype.Service;
 
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -67,7 +64,7 @@ public class AreaInfoServiceImpl implements AreaInfoService {
 
         if (CollectionUtil.isNotEmpty(lineIds)) {
             List<AreaLineInfoVO> resList = lineFeignClient.getBaseLineAreaInfo(lineIds).getData();
-            if (1 == deviceInfoParam.getIsPollution()) {
+            if (Objects.equals(1,deviceInfoParam.getIsPollution())) {
                 OnlineRateParam.Info param = new OnlineRateParam.Info();
                 param.setIds(resList.stream().map(AreaLineInfoVO::getLineId).distinct().collect(Collectors.toList()));
                 param.setDicData(deviceInfoParam.getDicData());
@@ -151,6 +148,8 @@ public class AreaInfoServiceImpl implements AreaInfoService {
                 eventDetailNew = BeanUtil.copyProperties(eventDetail, EventDetailNew.class);
                 //监测点id
                 eventDetailNew.setLineId(eventDetail.getMeasurementPointId());
+                //需要转成百分比*100
+                eventDetailNew.setFeatureAmplitude(eventDetail.getFeatureAmplitude()*100);
                 //持续时间
                 eventDetailNew.setDuration(eventDetail.getDuration());
                 //特征幅值

pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/RmpEventDetailServiceImpl.java

@@ -490,7 +490,7 @@ public class RmpEventDetailServiceImpl extends ServiceImpl<RmpEventDetailMapper,
     public Page<AdvanceEventDetailVO> getEventByLineIdsCount(EventBaseParam.Info param) {
         Page<AdvanceEventDetailVO> pageResult = new Page<>();
         param.setLineOrDevice(0);
-        param.setDeptIndex("0d52f9f6e43ec0ee83013cd32da93f66");
+        param.setDeptIndex(param.getDeptIndex());
         param.setStatisticalType(new SimpleDTO());
         //获取终端台账类信息
         List<GeneralDeviceDTO> deviceInfo = generalDeviceInfoClient.getPracticalRunDeviceInfo(param).getData();
@@ -500,6 +500,7 @@ public class RmpEventDetailServiceImpl extends ServiceImpl<RmpEventDetailMapper,
                 .eq(StrUtil.isNotBlank(param.getDicData()), RmpEventDetailPO::getEventType, param.getDicData())
                 .ge(StrUtil.isNotBlank(param.getSearchBeginTime()), RmpEventDetailPO::getStartTime, DateUtil.beginOfDay(DateUtil.parse(param.getSearchBeginTime())))
                 .le(StrUtil.isNotBlank(param.getSearchEndTime()), RmpEventDetailPO::getStartTime, DateUtil.endOfDay(DateUtil.parse(param.getSearchEndTime())))
+                .orderByDesc(RmpEventDetailPO::getStartTime)
         );
         List<String> tempLineIds = poPage.getRecords().stream().map(RmpEventDetailPO::getLineId).distinct().collect(Collectors.toList());
         if(CollUtil.isNotEmpty(tempLineIds)){

pqs-event/event-boot/src/main/java/com/njcn/event/service/majornetwork/Impl/TransientServiceImpl.java

@@ -204,13 +204,41 @@ public class TransientServiceImpl implements TransientService {
         if (generalInfo.getBusinessWaveFileStorage() == GeneralConstant.LOCAL_DISK) {
             cfgPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.CFG;
             datPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.DAT;
-            log.info("本地磁盘波形文件路径----" + cfgPath);
-            InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath);
-            InputStream datStream = waveFileComponent.getFileInputStreamByFilePath(datPath);
-            if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
-                throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND);
+
+            //适配文件后缀小写
+            cfgPath2 = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.CFG.toLowerCase();
+            datPath2 = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.DAT.toLowerCase();
+            log.info("本地磁盘波形文件路径----" + cfgPath2);
+            log.info("本地磁盘波形文件路径----" + datPath2);
+            try (
+                InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath);
+                InputStream datStream = waveFileComponent.getFileInputStreamByFilePath(datPath);
+                )
+            {
+                if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
+
+                    throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND);
+
+                }
+                waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);
+
+
+
+            } catch (Exception e) {
+                log.info("大写文件流为空");
+                try {
+                    InputStream cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath2);
+                    InputStream datStream = waveFileComponent.getFileInputStreamByFilePath(datPath2);
+                    if (Objects.isNull(cfgStream) || Objects.isNull(datStream)) {
+                        throw new BusinessException(WaveFileResponseEnum.ANALYSE_WAVE_NOT_FOUND);
+                    }
+                    waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);
+                } catch (Exception e1) {
+                    throw new BusinessException(WaveFileResponseEnum.WAVE_DATA_INVALID);
+                }
+
             }
-            waveDataDTO = waveFileComponent.getComtrade(cfgStream, datStream, 1);
+
         } else {
             cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG;
             datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT;
@@ -495,22 +523,23 @@ public class TransientServiceImpl implements TransientService {
                     try {
                         if (generalInfo.getBusinessWaveFileStorage() == GeneralConstant.LOCAL_DISK) {
                             cfgPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.CFG;
+                            log.info("cfg-----"+cfgPath);
+                            log.info("cfg-----"+datPath);
+
                             //判断文件是否存在
-                            boolean result1 = minIoUtils.checkFileIsExist(minIossProperties.getBucket(), cfgPath);
-                            if (!result1) {
-                                cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG_LOWER;
-                                cfg = GeneralConstant.CFG_LOWER;
+                            File file = new File(cfgPath);
+                            if(!file.exists()){
+                                cfgPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.CFG_LOWER;
                             }
 
                             datPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.DAT;
-                            boolean result2 = minIoUtils.checkFileIsExist(minIossProperties.getBucket(), datPath);
-                            if (!result2) {
-                                datPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.DAT_LOWER;
-                                dat = GeneralConstant.DAT_LOWER;
+                            File file2 = new File(datPath);
+                            if(!file2.exists()){
+                                datPath = generalInfo.getBusinessWavePath() + File.separator + ip + File.separator + waveName + GeneralConstant.DAT_LOWER;
                             }
-
+                            log.info("cfg-----"+cfgPath);
+                            log.info("cfg-----"+datPath);
                             cfgStream = waveFileComponent.getFileInputStreamByFilePath(cfgPath);
-                            datStream = waveFileComponent.getFileInputStreamByFilePath(datPath);
                         } else {
                             cfgPath = OssPath.WAVE_DIR + ip + StrUtil.SLASH + waveName + GeneralConstant.CFG;
                             boolean result1 = minIoUtils.checkFileIsExist(minIossProperties.getBucket(), cfgPath);

pqs-harmonic/harmonic-api/src/main/java/com/njcn/harmonic/pojo/vo/hebeinorth/EvaluationVo.java

@@ -32,6 +32,9 @@ public class EvaluationVo {
 
         @ApiModelProperty("越限占比")
         private Double ratio = 3.14159;
+
+        @ApiModelProperty("超标监测点数量")
+        private Integer size=0;
     }
 
 }

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/PollutionSubstationController.java

@@ -123,7 +123,8 @@ public class PollutionSubstationController extends BaseController {
     public HttpResult<List<SubstationVo>> getSubstationInfo(@RequestParam(value = "deptIndex") String deptIndex,
                                                             @RequestParam(value = "searchValue",required=false) String searchValue,
                                                             @RequestParam(value = "startTime") String startTime,
-                                                            @RequestParam(value = "endTime") String endTime) {
+                                                            @RequestParam(value = "endTime") String endTime
+                                                            ) {
         String methodDescribe = getMethodDescribe("getSubstationInfo");
         LogUtil.njcnDebug(log, "{}，实体参数：{},{}", methodDescribe, deptIndex, searchValue);
         List<SubstationVo> list = pollutionSubstationService.getSubstationInfo(deptIndex,searchValue,startTime,endTime);

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/controller/report/QualifiedReportController.java

@@ -54,11 +54,11 @@ public class QualifiedReportController extends BaseController {
     @ApiImplicitParam(name = "qualifiedReportParam", value = "合格率报告参数", required = true)
     public HttpResult<Page<FpyReportDTO>> pageTable(@RequestBody @Validated QualifiedReportParam qualifiedReportParam) {
         TimeInterval timeInterval = new TimeInterval();
-        String searchValue = qualifiedReportParam.getSearchValue();
-        Pattern pattern = Pattern.compile(PatternRegex.SPECIAL_REGEX);
-        if(pattern.matcher(searchValue).find()){
-            throw new BusinessException(ValidMessage.SPECIAL_REGEX);
-        }
+//        String searchValue = qualifiedReportParam.getSearchValue();
+//        Pattern pattern = Pattern.compile(PatternRegex.SPECIAL_REGEX);
+//        if(pattern.matcher(searchValue).find()){
+//            throw new BusinessException(ValidMessage.SPECIAL_REGEX);
+//        }
         String methodDescribe = getMethodDescribe("pageTable");
         Page<FpyReportDTO> result = qualifiedReportService.pageTable(qualifiedReportParam);
         log.info("合格率报告执行时长:"+timeInterval.interval());

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/mapper/mapping/PmsLineWarningMapper.xml

@@ -7,10 +7,10 @@
             p1.id id,
             p2.Org_Name dept,
             p2.Powerr_Name substation,
-            p3.`Name` deviceName,
-            p2.`Name` lineName,
+            p3.Name deviceName,
+            p2.Name lineName,
             p1.line_id lineId,
-            p4.`Name` businessType,
+            p4.Name businessType,
             p2.Monitor_Object_Name objectName,
             p1.target_type targetType,
             p1.over_limit_day overLimitDay,

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/GridServiceImpl.java

@@ -2,6 +2,7 @@ package com.njcn.harmonic.service.impl;
 
 import cn.hutool.core.bean.BeanUtil;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.NumberUtil;
 import com.njcn.common.utils.PubUtils;
 import com.njcn.device.biz.commApi.CommTerminalGeneralClient;
 import com.njcn.device.biz.pojo.dto.DeptGetChildrenMoreDTO;
@@ -297,23 +298,22 @@ public class GridServiceImpl implements IGridService {
                     if (CollUtil.isNotEmpty(limitRateList)) {
                         List<RStatLimitRateDPO> l1 = limitRateList.stream().filter(it -> ll.contains(it.getLineId())).collect(Collectors.toList());
                         if (CollUtil.isNotEmpty(l1)) {
-                            this.getDataByTarget(param.getHarmonicType(), l1, children);
+                            this.getDataByTarget(param.getHarmonicType(), l1, children, ll.size());
                         }
                     }
                     childrenList.add(children);
                 }
             });
             result.setChildrenList(childrenList);
+            int overCount = 0;
             if (CollUtil.isNotEmpty(childrenList)) {
-                OptionalDouble optionalAvg = childrenList.stream()
-                        .filter(child -> child.getRatio() != null && !child.getRatio().equals(3.14159))
-                        .mapToDouble(EvaluationVo.Children::getRatio)
-                        .average();
-                if (optionalAvg.isPresent()) {
-                    double avg = optionalAvg.getAsDouble();
-                    result.setLineRatio(PubUtils.doubleRound(2, avg));
+                for (EvaluationVo.Children children : childrenList) {
+                    overCount = overCount + children.getSize();
                 }
             }
+            if (!lineList.isEmpty()) {
+                result.setLineRatio(NumberUtil.round(overCount * 100.0/lineList.size(),2).doubleValue());
+            }
         }
         return result;
     }
@@ -708,6 +708,7 @@ public class GridServiceImpl implements IGridService {
             List<Integer> list3 = getList(1, 16, "getInuharm", item2);
             Integer maxValue3 = list3.stream().max(Integer::compareTo).orElse(null);
             qualifiedDetail.setInuHarm(Objects.isNull(maxValue3) ? null : PubUtils.doubleRound(2, 100.0 - (maxValue3 * 100.0 / item2.getAllTime())));
+            //负序电流
             qualifiedDetail.setINeg(PubUtils.doubleRound(2, 100.0 - (item2.getINegOvertime() * 100.0 / item2.getAllTime())));
         }
         if (item2.getFlickerAllTime() > 0) {
@@ -813,77 +814,88 @@ public class GridServiceImpl implements IGridService {
     /**
      * 根据指标类型计算数据
      */
-    public void getDataByTarget(Integer type, List<RStatLimitRateDPO> limitRateList, EvaluationVo.Children children) {
+    public void getDataByTarget(Integer type, List<RStatLimitRateDPO> limitRateList, EvaluationVo.Children children,int monitorTotal) {
         switch (type) {
             //全指标
             case 0:
                 List<RStatLimitRateDPO> filteredList0 = limitRateList.stream()
                         .filter(data -> data.getFreqDevOvertime() + data.getVoltageDevOvertime() + data.getFlickerOvertime() + data.getUaberranceOvertime() + data.getUbalanceOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList0.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList0.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList0.size() * 100.0 / monitorTotal));
                 break;
             //电压偏差
             case 1:
                 List<RStatLimitRateDPO> filteredList1 = limitRateList.stream()
                         .filter(data -> data.getVoltageDevOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList1.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList1.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList1.size() * 100.0 / monitorTotal));
                 break;
             //频率偏差
             case 2:
                 List<RStatLimitRateDPO> filteredList2 = limitRateList.stream()
                         .filter(data -> data.getFreqDevOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList2.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList2.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList2.size() * 100.0 / monitorTotal));
                 break;
             //电压总谐波畸变率
             case 3:
                 List<RStatLimitRateDPO> filteredList3 = limitRateList.stream()
                         .filter(data -> data.getUaberranceOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList3.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList3.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList3.size() * 100.0 / monitorTotal));
                 break;
             //电压闪变
             case 4:
                 List<RStatLimitRateDPO> filteredList4 = limitRateList.stream()
                         .filter(data -> data.getFlickerOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList4.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList4.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList4.size() * 100.0 / monitorTotal));
                 break;
             //三相电压不平衡度
             case 5:
                 List<RStatLimitRateDPO> filteredList5 = limitRateList.stream()
                         .filter(data -> data.getUbalanceOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList5.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList5.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList5.size() * 100.0 / monitorTotal));
                 break;
-            //谐波电压
+            // 谐波电压
+            // 谐波电压含有率 + 谐波电压有效值
             case 6:
                 List<RStatLimitRateDPO> filteredList6 = limitRateList.stream()
-                        .filter(x -> getLimitRateStats(x, 2, 26, "uharm", "Overtime"))
+                        .filter(x -> getLimitRateStats(x, 2, 26, "uharm", "Overtime") || x.getUaberranceOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList6.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList6.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList6.size() * 100.0 / monitorTotal));
                 break;
             //谐波电流
             case 7:
                 List<RStatLimitRateDPO> filteredList7 = limitRateList.stream()
                         .filter(x -> getLimitRateStats(x, 2, 26, "iharm", "Overtime"))
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList7.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList7.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList7.size() * 100.0 / monitorTotal));
                 break;
             //间谐波电压
             case 8:
                 List<RStatLimitRateDPO> filteredList8 = limitRateList.stream()
                         .filter(x -> getLimitRateStats(x, 1, 16, "inuharm", "Overtime"))
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList8.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList8.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList8.size() * 100.0 / monitorTotal));
                 break;
             //负序电流
             case 9:
                 List<RStatLimitRateDPO> filteredList9 = limitRateList.stream()
                         .filter(data -> data.getINegOvertime() > 0)
                         .collect(Collectors.toList());
-                children.setRatio(PubUtils.doubleRound(2, filteredList9.size() * 100.0 / limitRateList.size()));
+                children.setSize(filteredList9.size());
+                children.setRatio(PubUtils.doubleRound(2, filteredList9.size() * 100.0 / monitorTotal));
                 break;
             default:
                 break;

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/PollutionSubstationServiceImpl.java

@@ -948,6 +948,7 @@ public class PollutionSubstationServiceImpl extends ServiceImpl<RStatPollutionSu
         DeptGetLineParam deptGetLineParam = new DeptGetLineParam();
         deptGetLineParam.setDeptId(deptIndex);
         deptGetLineParam.setMonitorStateRunning(false);
+        deptGetLineParam.setSearchValue(searchValue);
         List<DeptGetSubStationDTO.Info> deptGetChildrenMoreDTOS = commTerminalGeneralClient.deptGetSubStationInfo(deptGetLineParam).getData();
         List<String> lineIds = deptGetChildrenMoreDTOS.stream().flatMap(x -> x.getStationIds().stream()).flatMap(x -> x.getUnitChildrenList().stream()).distinct().collect(Collectors.toList());
 

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/RMpTargetWarnDServiceImpl.java

@@ -72,10 +72,12 @@ public class RMpTargetWarnDServiceImpl extends ServiceImpl<RMpTargetWarnDMapper,
         List<Dept> data = deptFeignClient.getDirectSonSelf(param.getId()).getData();
         DeptGetLineParam deptGetLineParam = new DeptGetLineParam();
         deptGetLineParam.setDeptId(param.getId());
+        deptGetLineParam.setMonitorStateRunning(false);
         List<DeptGetSubStationDTO.Info> deptGetChildrenMoreDTOS = commTerminalGeneralClient.deptGetSubStationInfo(deptGetLineParam).getData();
 
         List<String> lineIDS = deptGetChildrenMoreDTOS.stream()
                 .flatMap(x -> x.getStationIds().stream().flatMap(l -> l.getUnitChildrenList().stream()))
+                .distinct()
                 .collect(Collectors.toList());
         //根据r_stat_limit_target_d来判断是否告警allTime flicker_overtime
 

pqs-harmonic/harmonic-boot/src/main/java/com/njcn/harmonic/service/impl/ReportServiceImpl.java

@@ -4,10 +4,12 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.njcn.harmonic.mapper.RStatDataHarmRateVDMapper;
 import com.njcn.harmonic.mapper.RStatDataIDMapper;
 import com.njcn.harmonic.mapper.RStatDataInharmVDMapper;
 import com.njcn.harmonic.mapper.ReportMapper;
 import com.njcn.harmonic.pojo.po.RStatDataVD;
+import com.njcn.harmonic.pojo.po.day.RStatDataHarmrateVDPO;
 import com.njcn.harmonic.pojo.po.day.RStatDataIDPO;
 import com.njcn.harmonic.pojo.param.ReportQueryParam;
 import com.njcn.harmonic.pojo.po.day.RStatDataInharmVDPO;
@@ -32,6 +34,7 @@ public class ReportServiceImpl implements ReportService {
 
     private final ReportMapper reportMapper;
     private final IRStatDataVDService statDataVDService;
+    private final RStatDataHarmRateVDMapper rStatDataHarmRateVDMapper;
     private final RStatDataIDMapper rStatDataIDMapper;
     private final RStatDataInharmVDMapper rStatDataInharmVDMapper;
 
@@ -220,7 +223,7 @@ public class ReportServiceImpl implements ReportService {
         }
 
         //获取电压含有率，不包含基波
-        List<ReportValue> listRate = dataV(param, Arrays.asList("A", "B", "C"), 2, 51, false, 1);
+        List<ReportValue> listRate = dataHarmV(param, Arrays.asList("A", "B", "C"), 2, 51, false, 1);
 
         if (CollUtil.isEmpty(listRate)) {
             for (int i = 0; i < 49; i++) {
@@ -382,6 +385,76 @@ public class ReportServiceImpl implements ReportService {
         return a;
     }
 
+    /**
+     * 电压信息
+     *
+     * @param param      查询条件
+     * @param valueTypes 区分类别 例如"A","B","C"
+     * @param num        循环开始
+     * @param size       循环结束
+     * @param fly        否是启用获取属性电压
+     * @param index      获取属性位置名称
+     * @return
+     */
+    private List<ReportValue> dataHarmV(ReportQueryParam param, List<String> valueTypes, Integer num, Integer size, Boolean fly, Integer index) {
+        List<RStatDataHarmrateVDPO> harmRateVDPOS = rStatDataHarmRateVDMapper.selectList(new LambdaQueryWrapper<RStatDataHarmrateVDPO>()
+                .eq(RStatDataHarmrateVDPO::getLineId, param.getLineId())
+                .in(CollUtil.isNotEmpty(valueTypes), RStatDataHarmrateVDPO::getPhaseType, valueTypes)
+                .ge(StrUtil.isNotBlank(param.getStartTime()), RStatDataHarmrateVDPO::getTime, DateUtil.beginOfDay(DateUtil.parse(param.getStartTime())))
+                .le(StrUtil.isNotBlank(param.getEndTime()), RStatDataHarmrateVDPO::getTime, DateUtil.endOfDay(DateUtil.parse(param.getEndTime())))
+        );
+        String max = "MAX";
+        String avg = "AVG";
+        String min = "MIN";
+        String cp95 = "CP95";
+        List<ReportValue> a = new ArrayList<>();
+        Map<String, List<RStatDataHarmrateVDPO>> collect = harmRateVDPOS.stream().collect(Collectors.groupingBy(RStatDataHarmrateVDPO::getPhaseType));
+        collect.forEach((key, value) -> {
+            Map<String, List<RStatDataHarmrateVDPO>> valueTypeMap = value.stream().collect(Collectors.groupingBy(RStatDataHarmrateVDPO::getValueType));
+
+            for (int i = num; i < size; i++) {
+                ReportValue reportValue = new ReportValue();
+                String attribute = "";
+                if (fly) {
+                    if (index == 0) {
+                        attribute = attributeV(i);
+                    } else {
+                        attribute = attributeV(index);
+                    }
+                } else {
+                    attribute = "v" + i;
+                }
+
+                if (valueTypeMap.containsKey(max)) {
+                    List<Float> aa = reflectDataHarmV(valueTypeMap.get(max), max, attribute);
+                    reportValue.setPhaseType(key);
+                    Float maxNum = aa.stream().distinct().max(Float::compareTo).get();
+                    reportValue.setFmaxValue(maxNum);
+                }
+                if (valueTypeMap.containsKey(avg)) {
+                    List<Float> aa = reflectDataHarmV(valueTypeMap.get(avg), avg, attribute);
+                    reportValue.setPhaseType(key);
+                    Double avgNum = aa.stream().distinct().collect(Collectors.averagingDouble(Float::doubleValue));
+                    reportValue.setMeanValue(avgNum.floatValue());
+                }
+                if (valueTypeMap.containsKey(min)) {
+                    List<Float> aa = reflectDataHarmV(valueTypeMap.get(min), min, attribute);
+                    reportValue.setPhaseType(key);
+                    double minNum = aa.stream().distinct().min(Float::compareTo).get();
+                    reportValue.setMinValue((float) minNum);
+                }
+                if (valueTypeMap.containsKey(cp95)) {
+                    List<Float> aa = reflectDataHarmV(valueTypeMap.get(cp95), cp95, attribute);
+                    reportValue.setPhaseType(key);
+                    List<Float> cp95Num = aa.stream().distinct().sorted(Comparator.comparing(Float::doubleValue).reversed()).collect(Collectors.toList());
+                    reportValue.setCp95Value(cp95Num.get(0).floatValue());
+                }
+                a.add(reportValue);
+            }
+        });
+        return a;
+    }
+
     /**
      * 电压反射取属性值
      *
@@ -411,6 +484,27 @@ public class ReportServiceImpl implements ReportService {
         }).collect(Collectors.toList());
     }
 
+    private List<Float> reflectDataHarmV(List<RStatDataHarmrateVDPO> value, String name, String attribute) {
+        Field field = null;
+        try {
+            field = RStatDataHarmrateVDPO.class.getDeclaredField(attribute);
+        } catch (NoSuchFieldException e) {
+            throw new RuntimeException(e);
+        }
+        field.setAccessible(true);
+
+        Field finalField = field;
+        return value.stream().filter(x -> x.getValueType().equals(name)).map(temp -> {
+            Double o = null;
+            try {
+                o = (Double) finalField.get(temp);
+            } catch (IllegalAccessException e) {
+                throw new RuntimeException(e);
+            }
+            return o.floatValue();
+        }).collect(Collectors.toList());
+    }
+
     /**
      * 电压反射取属性值
      *

pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/EventMapper.xml

@@ -19,7 +19,7 @@
       line_index id,
       LEAST(ROUND(SUM(real_time) / SUM(due_time), 2) * 100,100) integrityData
     FROM
-        `r_stat_integrity_d`
+        r_stat_integrity_d
     WHERE time_id between #{startTime} and #{endTime}
     GROUP BY line_index
   </select>
@@ -35,9 +35,9 @@
         100
         ) integrityData
     FROM
-        `r_stat_onlinerate_d`
+        r_stat_onlinerate_d
     WHERE time_id between #{startTime} and #{endTime}
     GROUP BY dev_index
   </select>
 
-</mapper>
+</mapper>

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/dto/SensitiveReportExcel.java

@@ -54,7 +54,7 @@ public class SensitiveReportExcel implements Serializable {
 //    private String orgId;
 
 
-    @Excel(name = "工程预期投产日期(yyyy-MM-dd)", width = 30)
+    @Excel(name = "*工程预期投产日期(yyyy-MM-dd)", width = 30)
     private String expectedProductionDate;
 
     @Excel(name = "电压等级", width = 30)

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/dto/SensitiveUserSExcel.java

@@ -57,7 +57,7 @@ public class SensitiveUserSExcel implements Serializable {
 //    private String orgId;
 
 
-    @Excel(name = "工程预期投产日期(yyyy-MM-dd)", width = 30)
+    @Excel(name = "*工程预期投产日期(yyyy-MM-dd)", width = 30)
     @NotBlank(message = "工程预期投产日期不能为空")
     private String expectedProductionDate;
 

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/dto/SupervisionDevMainReportExcel.java

@@ -209,16 +209,16 @@ public class SupervisionDevMainReportExcel {
     private String timeSyncFunction = "0";
 
     /**
-     * 电镀功能
+     * 电度功能
      */
-    @Excel(name = "电镀功能", width = 30, replace = {"关闭_0", "开启_1"})
+    @Excel(name = "电度功能", width = 30, replace = {"关闭_0", "开启_1"})
     private String electroplatingFunction = "0";
 
 
     /**
-     * 召换标志
+     * 召唤标志
      */
-    @Excel(name = "召换标志", width = 30, replace = {"周期触发_0", "变位触发_1"})
+    @Excel(name = "召唤标志", width = 30, replace = {"周期触发_0", "变位触发_1"})
     private String summonFlag = "0";
 
     /**

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/param/device/SupervisionTempDeviceReportParam.java

@@ -206,9 +206,9 @@ public class SupervisionTempDeviceReportParam {
     private Integer timeSyncFunction;
 
     /**
-     * 电镀功能
+     * 电度功能
      */
-    @ApiModelProperty(value="电镀功能")
+    @ApiModelProperty(value="电度功能")
     private Integer electroplatingFunction;
 
     /**
@@ -218,9 +218,9 @@ public class SupervisionTempDeviceReportParam {
     private String monitoringDeviceInstallationPosition;
 
     /**
-     * 召换标志
+     * 召唤标志
      */
-    @ApiModelProperty(value="召换标志")
+    @ApiModelProperty(value="召唤标志")
     private String summonFlag;
 
     /**

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/device/SupervisionTempDeviceReport.java

@@ -204,7 +204,7 @@ public class SupervisionTempDeviceReport {
     private Integer timeSyncFunction;
 
     /**
-     * 电镀功能
+     * 电度功能
      */
     @TableField(value = "electroplating_function")
     private Integer electroplatingFunction;
@@ -216,7 +216,7 @@ public class SupervisionTempDeviceReport {
     private String monitoringDeviceInstallationPosition;
 
     /**
-     * 召换标志
+     * 召唤标志
      */
     @TableField(value = "summon_flag")
     private String summonFlag;

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/user/UserReportPO.java

@@ -161,6 +161,9 @@ public class UserReportPO extends BaseEntity {
     @TableField(value = "line_id")
     private String lineId;
 
+    @TableField(value = "second_assessment_id")
+    private String secondAssessmentId;
+
     /**
      * 审批状态：1:审批中；2：审批通过；3：审批不通过；4：已取消
      */
@@ -176,4 +179,5 @@ public class UserReportPO extends BaseEntity {
 
 
 
+
 }

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/user/UserReportProjectPO.java

@@ -1,9 +1,6 @@
 package com.njcn.supervision.pojo.po.user;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
 import com.njcn.common.pojo.constant.PatternRegex;
 import com.njcn.db.bo.BaseEntity;
 import com.njcn.web.constant.ValidMessage;
@@ -35,14 +32,14 @@ public class UserReportProjectPO extends BaseEntity {
     /**
      * 用户协议容量
      */
-    @TableField(value = "agreement_capacity")
+    @TableField(value = "agreement_capacity",updateStrategy = FieldStrategy.IGNORED)
     @Pattern(regexp = PatternRegex.COORDINATE, message = ValidMessage.PARAM_FORMAT_ERROR)
     private Double agreementCapacity;
 
     /**
      * 非线性设备类型
      */
-    @TableField(value = "nonlinear_device_type")
+    @TableField(value = "nonlinear_device_type",updateStrategy = FieldStrategy.IGNORED)
     private String nonlinearDeviceType;
 
     /**

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/po/user/UserReportSubstationPO.java

@@ -1,9 +1,6 @@
 package com.njcn.supervision.pojo.po.user;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
 import com.njcn.common.pojo.constant.PatternRegex;
 import com.njcn.db.bo.BaseEntity;
 import com.njcn.web.constant.ValidMessage;
@@ -40,28 +37,28 @@ public class UserReportSubstationPO  extends BaseEntity {
     /**
      * 基准短路容量（MVA）
      */
-    @TableField(value = "base_short_circuit_capacity")
+    @TableField(value = "base_short_circuit_capacity",updateStrategy = FieldStrategy.IGNORED)
     @Pattern(regexp = PatternRegex.COORDINATE, message = ValidMessage.PARAM_FORMAT_ERROR)
     private BigDecimal baseShortCircuitCapacity;
 
     /**
      * 系统最小短路容量（MVA）
      */
-    @TableField(value = "min_short_circuit_capacity")
+    @TableField(value = "min_short_circuit_capacity",updateStrategy = FieldStrategy.IGNORED)
     @Pattern(regexp = PatternRegex.COORDINATE, message = ValidMessage.PARAM_FORMAT_ERROR)
     private BigDecimal minShortCircuitCapacity;
 
     /**
      * PCC供电设备容量（MVA）
      */
-    @TableField(value = "pcc_equipment_capacity")
+    @TableField(value = "pcc_equipment_capacity",updateStrategy = FieldStrategy.IGNORED)
     @Pattern(regexp = PatternRegex.COORDINATE, message = ValidMessage.PARAM_FORMAT_ERROR)
     private BigDecimal pccEquipmentCapacity;
 
     /**
      * 用户用电协议容量（MVA）
      */
-    @TableField(value = "user_agreement_capacity")
+    @TableField(value = "user_agreement_capacity",updateStrategy = FieldStrategy.IGNORED)
     @Pattern(regexp = PatternRegex.COORDINATE, message = ValidMessage.PARAM_FORMAT_ERROR)
     private BigDecimal userAgreementCapacity;
 
@@ -74,7 +71,7 @@ public class UserReportSubstationPO  extends BaseEntity {
     /**
      * 非线性负荷类型
      */
-    @TableField(value = "nonlinear_load_type")
+    @TableField(value = "nonlinear_load_type",updateStrategy = FieldStrategy.IGNORED)
     private String nonlinearLoadType;
 
     /**

pqs-supervision/supervision-api/src/main/java/com/njcn/supervision/pojo/vo/device/OnlineVo.java

@@ -82,4 +82,7 @@ public class OnlineVo implements Serializable {
     @ApiModelProperty("最新数据时间")
     @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss",timezone="GMT+8")
     private LocalDateTime updateTime;
+
+    @ApiModelProperty("数据类型 0:无数据 1:超标告警 2:异常数据")
+    private Integer dataType;
 }

pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/LineWarningServiceImpl.java

@@ -292,7 +292,11 @@ public class LineWarningServiceImpl extends MppServiceImpl<LineWarningMapper, Li
             }
         }
         queryWrapper.orderBy(true, true, "D.Name", "p4.Name", "p3.Name");
-        return this.baseMapper.page(new Page<>(PageFactory.getPageNum(param), PageFactory.getPageSize(param)), queryWrapper);
+        Page<OnlineVo> page = this.baseMapper.page(new Page<>(PageFactory.getPageNum(param), PageFactory.getPageSize(param)), queryWrapper);
+        page.getRecords().forEach(item -> {
+            item.setDataType(param.getDataType());
+        });
+        return page;
     }
 
     @Override
@@ -344,6 +348,8 @@ public class LineWarningServiceImpl extends MppServiceImpl<LineWarningMapper, Li
                     }
                 });
                 dataMap.put("${noData}", CollUtil.isEmpty(dataList1) ? "0" : String.valueOf(dataList1.size()));
+            } else {
+                dataMap.put("${noData}", "0");
             }
             if (CollUtil.isNotEmpty(list2)) {
                 list2.forEach(item -> {

pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/device/impl/SupervisionDevMainReportPOServiceImpl.java

@@ -56,6 +56,7 @@ import com.njcn.web.factory.PageFactory;
 import com.njcn.web.utils.RequestUtil;
 import com.njcn.web.utils.WebUtil;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.jetbrains.annotations.NotNull;
 import org.springframework.beans.BeanUtils;
@@ -65,6 +66,7 @@ import org.springframework.web.multipart.MultipartFile;
 
 import javax.servlet.http.HttpServletResponse;
 import java.time.LocalDate;
+import java.time.LocalDateTime;
 import java.util.*;
 import java.util.stream.Collectors;
 import java.util.stream.Stream;
@@ -78,6 +80,7 @@ import java.util.stream.Stream;
  */
 @Service
 @RequiredArgsConstructor
+@Slf4j
 public class SupervisionDevMainReportPOServiceImpl extends ServiceImpl<SupervisionDevMainReportPOMapper, SupervisionDevMainReportPO> implements SupervisionDevMainReportPOService {
 
 
@@ -502,6 +505,7 @@ public class SupervisionDevMainReportPOServiceImpl extends ServiceImpl<Supervisi
 
     @Override
     public void importDevData(MultipartFile file, HttpServletResponse response) {
+        log.info("beginImport-------------------"+ LocalDateTime.now());
         ImportParams params = new ImportParams();
         //表头
         params.setHeadRows(1);
@@ -528,8 +532,11 @@ public class SupervisionDevMainReportPOServiceImpl extends ServiceImpl<Supervisi
             throw new BusinessException(SupervisionResponseEnum.IMPORT_DEV_ERROR);
         }
         List<SupervisionDevMainReportExcel.ExcelMsg> devMsgList =  new ArrayList<>();
+        log.info("beginqueryjiBeiArea-------------------"+ LocalDateTime.now());
+
         //所属地市
         List<DictData> jiBeiArea = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.JIBEI_AREA.getCode()).getData();
+        log.info("beginquerydeptS-------------------"+ LocalDateTime.now());
 
         //所属供电公司
         List<DeptDTO> deptS = deptFeignClient.getDeptDescendantIndexes(RequestUtil.getDeptIndex(), WebUtil.filterDeptType()).getData();
@@ -542,6 +549,7 @@ public class SupervisionDevMainReportPOServiceImpl extends ServiceImpl<Supervisi
         //获取所有前置机
         List<Node> nodes = nodeClient.nodeAllList().getData();
         Map<String, String> nodeMap = nodes.stream().collect(Collectors.toMap(Node::getName, Node::getId, (k1, k2) -> k1));
+        log.info("beginquerydevConnect-------------------"+ LocalDateTime.now());
 
         //接线方式
         List<DictData> devConnect = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.DEV_CONNECT.getCode()).getData();
@@ -552,10 +560,14 @@ public class SupervisionDevMainReportPOServiceImpl extends ServiceImpl<Supervisi
         List<DictData> voltageTransformer = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.VOLTAGE_TRANSFORMER.getCode()).getData();
         //中性点接线方式
         List<DictData> neutralPoint = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.Neutral_Point.getCode()).getData();
+        log.info("beginqueryneutralPoint-------------------"+ LocalDateTime.now());
 
         SubstationParam substationParam=new SubstationParam();
         substationParam.setOrgIds(deptS.stream().map(DeptDTO::getId).distinct().collect(Collectors.toList()));
+        log.info("beginquerySubGetBase-------------------"+ LocalDateTime.now());
+
         List<SubGetBase> data = commterminalGeneralClient.tagOrIdGetSub(substationParam).getData();
+        log.info("endquerySubGetBase-------------------"+ LocalDateTime.now());
 
         SupervisionDevMainReportPO po;
         if (CollectionUtil.isNotEmpty(devExcels)) {

pqs-supervision/supervision-boot/src/main/java/com/njcn/supervision/service/user/impl/UserReportPOServiceImpl.java

@@ -25,6 +25,7 @@ import com.njcn.common.pojo.constant.PatternRegex;
 import com.njcn.common.pojo.enums.common.DataStateEnum;
 import com.njcn.common.pojo.enums.response.CommonResponseEnum;
 import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.common.utils.FileUtil;
 import com.njcn.device.pms.utils.PubUtil;
 import com.njcn.device.pq.api.LineFeignClient;
@@ -63,6 +64,7 @@ import com.njcn.web.factory.PageFactory;
 import com.njcn.web.utils.RequestUtil;
 import com.njcn.web.utils.WebUtil;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.BeanWrapper;
@@ -87,6 +89,7 @@ import java.util.stream.Stream;
  * @author clam
  * @version V1.0.0
  */
+@Slf4j
 @Service
 @RequiredArgsConstructor
 public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, UserReportPO> implements UserReportPOService {
@@ -492,9 +495,9 @@ public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, Use
         List<String> data = deptFeignClient.getDepSonIdtByDeptId(userReportQueryParam.getOrgId()).getData();
         //此处仅查询敏感及重要用户
         userReportVOQueryWrapper.and(wrapper ->
-                wrapper.in("supervision_user_report.create_by", colleaguesIds)
-                        .or()
-                        .in("supervision_user_report.org_id", data)
+                        wrapper.in("supervision_user_report.create_by", colleaguesIds)
+                                .or()
+                                .in("supervision_user_report.org_id", data)
                 )
                 .eq("supervision_user_report.state", DataStateEnum.ENABLE.getCode());
         if (!allDataFlag) {
@@ -790,8 +793,9 @@ public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, Use
         params.setHeadRows(1);
         //标题
         params.setTitleRows(1);
-        params.setNeedVerify(true);
+        params.setNeedVerify(false);
         params.setStartSheetIndex(0);
+        params.setReadRows(100);  // 最多读取100行数据
         params.setSheetNum(1);
         List<SensitiveUserSExcel> sensitiveUserExcels;
         try {
@@ -1013,19 +1017,36 @@ public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, Use
         params.setHeadRows(1);
         //标题
         params.setTitleRows(1);
-        params.setNeedVerify(true);
+        params.setNeedVerify(false);  // 关闭校验，避免校验导致的性能问题
         params.setStartSheetIndex(0);
+        params.setReadRows(100);  // 最多读取100行数据
         params.setSheetNum(1);
-        List<SensitiveReportExcel> sensitiveUserExcels = new ArrayList<>();
+        // 限制最大读取行数，防止Excel模板带下拉列表导致读取大量空行
+        // 如果实际数据超过此限制，需要分批导入或调整此参数
+        params.setReadRows(100);  // 最多读取100行数据
+        List<SensitiveReportExcel> sensitiveUserExcels;
         try {
+            log.info("开始解析 Excel，文件名：{}", file.getOriginalFilename());
             ExcelImportResult<SensitiveReportExcel> sensitiveUserExcelExcelImportResult = ExcelImportUtil.importExcelMore(file.getInputStream(), SensitiveReportExcel.class, params);
+            log.info("Excel 解析完成，原始数据行数：{}", sensitiveUserExcelExcelImportResult.getList().size());
             //如果存在非法数据，将不合格的数据导出
             if (sensitiveUserExcelExcelImportResult.isVerifyFail()) {
+                log.warn("存在校验失败的数据");
                 PoiUtil.exportFileByWorkbook(sensitiveUserExcelExcelImportResult.getFailWorkbook(), "非法用户数据.xlsx", response);
+                return;  // 校验失败直接返回
             } else {
-                sensitiveUserExcels = sensitiveUserExcelExcelImportResult.getList();
+                // 过滤掉空行数据（projectName 为空的行）
+                sensitiveUserExcels = sensitiveUserExcelExcelImportResult.getList().stream()
+                        .filter(x -> StringUtils.isNotBlank(x.getProjectName()))
+                        .collect(Collectors.toList());
+                log.info("过滤后有效数据：{} 条", sensitiveUserExcels.size());
+
+                if (CollectionUtil.isEmpty(sensitiveUserExcels)) {
+                    throw new BusinessException(SupervisionResponseEnum.IMPORT_DEV_DATA_ERROR);
+                }
             }
         } catch (Exception e) {
+            log.error("导入失败，文件：{}", file.getOriginalFilename(), e);
             throw new BusinessException(SupervisionResponseEnum.IMPORT_SENSITIVE_REPORT_ERROR);
         }
         //主要非线性设备类型-冀北
@@ -1036,7 +1057,7 @@ public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, Use
         //评估类型
         List<DictData> evaluationType = dicDataFeignClient.getDicDataByTypeCode(DicDataTypeEnum.EVALUATION_TYPE.getCode()).getData();
         //解决填报部门问题
-        List<DeptDTO> data = deptFeignClient.getDeptDescendantIndexes(RequestUtil.getUserIndex(), WebUtil.filterDeptType()).getData();
+        List<DeptDTO> data = deptFeignClient.getDeptDescendantIndexes(RequestUtil.getDeptIndex(), WebUtil.filterDeptType()).getData();
 
         //执行批量导入敏感及重要用户，入库过程中会进行数据校验
         List<SensitiveReportExcel.SensitiveReportExcelMsg> sensitiveUserExcelMsgs = new ArrayList<>();
@@ -1182,7 +1203,7 @@ public class UserReportPOServiceImpl extends ServiceImpl<UserReportPOMapper, Use
         lambdaQueryWrapper.eq(UserReportPO::getId,id).eq(UserReportPO::getState,DataStateEnum.ENABLE.getCode());
         UserReportPO userReportPO = this.getById(id);
         if(Objects.nonNull(userReportPO)){
-           return BeanUtil.copyProperties(userReportPO,UserLedgerVO.class);
+            return BeanUtil.copyProperties(userReportPO,UserLedgerVO.class);
         }
         return null;
     }

pqs-system/system-boot/src/main/java/com/njcn/system/mapper/mapping/PqDashboardPageMapper.xml

@@ -18,7 +18,7 @@
   </resultMap>
   <sql id="Base_Column_List">
     <!--@mbg.generated-->
-    Id, page_name, thumbnail, remark, container_config, sort, `state`, Create_By, Create_Time, 
+    Id, page_name, thumbnail, remark, container_config, sort, "state", Create_By, Create_Time,
     Update_By, Update_Time
   </sql>
 
@@ -31,4 +31,4 @@
        ${ew.sqlSegment}
     </where>
   </select>
-</mapper>
+</mapper>

pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/PqDashboardPageServiceImpl.java

@@ -40,7 +40,8 @@ public class PqDashboardPageServiceImpl extends ServiceImpl<PqDashboardPageMappe
 //        checkName(pqDashboardPageParam,false);
 
         BeanUtils.copyProperties(pqDashboardPageParam,pqDashboardPage);
-        pqDashboardPage.setState(0);
+        //根据前端传递状态赋值
+        //pqDashboardPage.setState(0);
         pqDashboardPage.setUserId(RequestUtil.getUserIndex());
         this.save(pqDashboardPage);
         return true;

pqs-system/system-boot/src/main/java/com/njcn/system/service/impl/PqFrontLogsServiceImpl.java

@@ -98,11 +98,11 @@ public class PqFrontLogsServiceImpl extends ServiceImpl<PqFrontLogsMapper, PqFro
     @Override
     public Page<PqFrontLogsVO> queryPage(PqFrontLogsParam baseParam) {
         QueryWrapper<PqFrontLogs> queryWrapper = new QueryWrapper<>();
-        if (Objects.nonNull(baseParam.getSearchBeginTime()) && Objects.nonNull(baseParam.getSearchEndTime())) {
+        if (StringUtils.isNotBlank(baseParam.getSearchBeginTime()) && StringUtils.isNotBlank(baseParam.getSearchEndTime())) {
             queryWrapper.between("A.update_Time", baseParam.getSearchBeginTime()+" 00:00:00", baseParam.getSearchEndTime()+" 23:59:59");
         }
 
-        if(Objects.nonNull(baseParam.getSearchValue())){
+        if(StringUtils.isNotBlank(baseParam.getSearchValue())){
             queryWrapper.like("line.name", baseParam.getSearchValue());
         }
         queryWrapper.eq(StringUtils.isNotBlank(baseParam.getCode()),"A.code",baseParam.getCode());

pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/ComponentServiceImpl.java

@@ -26,10 +26,7 @@ import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -110,13 +107,15 @@ public class ComponentServiceImpl extends ServiceImpl<ComponentMapper, Component
                 ComponentVO componentVO = new ComponentVO();
                 componentVO.setId(dictData.getId());
                 componentVO.setName(dictData.getName());
+                componentVO.setSort(dictData.getSort());
                 componentVO.setChildren(
                         v.stream()
                                 .filter(fun -> Objects.equals(ComponentState.FATHER_PID, fun.getPid()))
-                                .peek(funS -> funS.setChildren(getChildCategoryList(funS, v)))
+                                .peek(funS -> funS.setChildren(getChildCategoryList(funS, v))).sorted(Comparator.comparing(ComponentVO::getSort))
                                 .collect(Collectors.toList()));
                 result.add(componentVO);
             });
+            result.sort(Comparator.comparing(ComponentVO::getSort));
         }
         return result;
     }
@@ -182,7 +181,7 @@ public class ComponentServiceImpl extends ServiceImpl<ComponentMapper, Component
      */
     private List<ComponentVO> getChildCategoryList(ComponentVO currMenu, List<ComponentVO> categories) {
         return categories.stream().filter(o -> Objects.equals(o.getPid(), currMenu.getId()))
-                .peek(o -> o.setChildren(getChildCategoryList(o, categories)))
+                .peek(o -> o.setChildren(getChildCategoryList(o, categories))).sorted(Comparator.comparing(ComponentVO::getSort))
                 .collect(Collectors.toList());
     }
 

pqs-user/user-boot/src/main/java/com/njcn/user/service/impl/UserServiceImpl.java

@@ -495,10 +495,12 @@ public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IU
         List<User> users1 = this.listByIds(collect);
         if (CollectionUtil.isNotEmpty(users1)) {
             users1.forEach(item->{
-                UserVO userVO = new UserVO();
-                userVO.setId(item.getId());
-                userVO.setName(item.getName());
-                users.add(userVO);
+                if (item.getState() == 1) {
+                    UserVO userVO = new UserVO();
+                    userVO.setId(item.getId());
+                    userVO.setName(item.getName());
+                    users.add(userVO);
+                }
             });
         }
         return users;