微调

detection/src/main/java/com/njcn/gather/detection/controller/PreDetectionController.java

@@ -155,4 +155,25 @@ public class PreDetectionController extends BaseController {
         LogUtil.njcnDebug(log, "{}", methodDescribe);
         preDetectionService.exportAlignData();
     }
+
+    @OperateInfo(info = LogEnum.SYSTEM_COMMON)
+    @GetMapping("/canCoefficient")
+    @ApiOperation("比对模式是否能够进行系数校验")
+    public HttpResult<Boolean> canCoefficient() {
+        String methodDescribe = getMethodDescribe("canCoefficient");
+        LogUtil.njcnDebug(log, "{}", methodDescribe);
+
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, preDetectionService.getCanCoefficient(), methodDescribe);
+    }
+
+    @OperateInfo(info = LogEnum.SYSTEM_COMMON)
+    @GetMapping("/startCoefficient")
+    @ApiOperation("比对模式开启系数校验")
+    public HttpResult<String> startCoefficient() {
+        String methodDescribe = getMethodDescribe("startCoefficient");
+        LogUtil.njcnDebug(log, "{}", methodDescribe);
+
+        preDetectionService.startCoefficient();
+        return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
+    }
 }

detection/src/main/java/com/njcn/gather/detection/handler/SocketContrastResponseService.java

@@ -11,7 +11,9 @@ import cn.hutool.core.util.StrUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.google.common.collect.HashBiMap;
+import com.njcn.common.pojo.enums.common.DataStateEnum;
 import com.njcn.common.pojo.exception.BusinessException;
+import com.njcn.gather.detection.pojo.dto.DevXiNumData;
 import com.njcn.gather.detection.pojo.dto.WaveCommandDTO;
 import com.njcn.gather.detection.pojo.dto.WaveResultDTO;
 import com.njcn.gather.detection.pojo.enums.*;
@@ -24,15 +26,17 @@ import com.njcn.gather.detection.pojo.vo.*;
 import com.njcn.gather.detection.service.IAdPariService;
 import com.njcn.gather.detection.service.impl.DetectionServiceImpl;
 import com.njcn.gather.detection.util.DetectionUtil;
-import com.njcn.gather.detection.util.socket.CnSocketUtil;
-import com.njcn.gather.detection.util.socket.FormalTestManager;
-import com.njcn.gather.detection.util.socket.MsgUtil;
-import com.njcn.gather.detection.util.socket.SocketManager;
+import com.njcn.gather.detection.util.socket.*;
 import com.njcn.gather.detection.util.socket.websocket.WebServiceManager;
 import com.njcn.gather.device.pojo.enums.PatternEnum;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
+import com.njcn.gather.device.pojo.po.PqStandardDevGainRecord;
 import com.njcn.gather.device.pojo.vo.PreDetection;
 import com.njcn.gather.device.service.IPqDevService;
+import com.njcn.gather.device.service.IPqStandardDevGainRecordService;
+import com.njcn.gather.device.service.IPqStandardDevGainService;
 import com.njcn.gather.device.service.IPqStandardDevService;
+import com.njcn.gather.monitor.pojo.po.PqMonitor;
 import com.njcn.gather.monitor.service.IPqMonitorService;
 import com.njcn.gather.plan.pojo.enums.DataSourceEnum;
 import com.njcn.gather.plan.service.IAdPlanService;
@@ -62,6 +66,7 @@ import java.io.IOException;
 import java.io.InputStream;
 import java.lang.reflect.Field;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.text.DecimalFormat;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -92,6 +97,8 @@ public class SocketContrastResponseService {
     private final IAdPariService adPairService;
     private final ICompareWaveService compareWaveService;
     private final IAdPlanTestConfigService adPlanTestConfigService;
+    private final IPqStandardDevGainService pqStandardDevGainService;
+    private final IPqStandardDevGainRecordService pqStandardDevGainRecordService;
 
 
     /**
@@ -185,6 +192,7 @@ public class SocketContrastResponseService {
         FormalTestManager.isXu = param.getPhaseCheck() == 1 ? true : false;
 //        FormalTestManager.isXu = true;
         FormalTestManager.nonWaveDataSourceEnum = null;
+        DetectionServiceImpl.vAndIResultMap = new HashMap<>();
 
         String[] datasourceIds = FormalTestManager.currentTestPlan.getDatasourceId().split(",");
         for (String datasourceId : datasourceIds) {
@@ -377,6 +385,10 @@ public class SocketContrastResponseService {
             case RECORD_WAVE_STEP1:
                 this.recordWave(param, socketDataMsg);
                 break;
+            //系数校验
+            case Coefficient_Check:
+                this.coefficient(param, socketDataMsg);
+                break;
             //退出关闭
             case QUITE:
                 quitDeal(socketDataMsg, param);
@@ -1405,6 +1417,28 @@ public class SocketContrastResponseService {
                                                 pqDevService.updateResult(id1.split(CnSocketUtil.SPLIT_TAG)[0], param.getUserId());
                                             });
                                             FormalTestManager.isTesting = false;
+
+                                            if (CollUtil.isNotEmpty(DetectionServiceImpl.vAndIResultMap)) {
+                                                // 是否进行系数校准
+                                                //万一录波了这里就进不来了，但是在误差处理的时候DetectionServiceImpl.vAndIResultMap该集合会保留不符合的结果
+
+                                                XiNumberManager.xiDevList.clear();
+                                                XiNumberManager.devXiNumDataMap.clear();
+                                                List<String> stdIpList = DetectionServiceImpl.vAndIResultMap.values().stream().map(DetectionServiceImpl.VAndIResult::getIp).collect(Collectors.toList());
+                                                XiNumberManager.xiDevList = FormalTestManager.standardDevList.stream().filter(d -> stdIpList.contains(d.getDevIP())).collect(Collectors.toList());
+                                                // 逐一设备向通讯模块要原始系数
+                                                SocketMsg<String> socketMsg = new SocketMsg<>();
+                                                socketMsg.setRequestId(SourceOperateCodeEnum.Coefficient_Check.getValue());
+                                                socketMsg.setOperateCode(SourceOperateCodeEnum.DATA_CHNFACTOR$01.getValue());
+                                                PreDetection preDetection = XiNumberManager.xiDevList.get(0);
+                                                Map<String, Object> map = new HashMap<>();
+                                                map.put("devIP", preDetection.getDevIP());
+                                                map.put("chnNum", preDetection.getDevChns());
+                                                socketMsg.setData(JSON.toJSONString(map));
+                                                SocketManager.sendMsg(param.getUserPageId() + CnSocketUtil.CONTRAST_DEV_TAG, JSON.toJSONString(socketMsg));
+
+                                                FormalTestManager.currentStep = SourceOperateCodeEnum.Coefficient_Check;
+                                            }
                                         }
                                     } else {
                                         // 配对关系入库
@@ -1682,6 +1716,160 @@ public class SocketContrastResponseService {
         }
     }
 
+    private void coefficient(PreDetectionParam param, SocketDataMsg socketDataMsg) {
+        SourceOperateCodeEnum sourceOperateCodeEnum = SourceOperateCodeEnum.getDictDataEnumByCode(socketDataMsg.getOperateCode());
+        SourceResponseCodeEnum dictDataEnumByCode = SourceResponseCodeEnum.getDictDataEnumByCode(socketDataMsg.getCode());
+        SocketMsg<String> xiSocket = new SocketMsg<>();
+        xiSocket.setRequestId(SourceOperateCodeEnum.Coefficient_Check.getValue());
+
+        switch (Objects.requireNonNull(sourceOperateCodeEnum)) {
+            case DATA_CHNFACTOR$01:
+                //获取系数
+                switch (Objects.requireNonNull(dictDataEnumByCode)) {
+                    case SUCCESS:
+                        if (CollUtil.isNotEmpty(XiNumberManager.xiDevList)) {
+                            List<DevXiNumData.GF> gfList = JSON.parseArray(socketDataMsg.getData(), DevXiNumData.GF.class);
+                            DevXiNumData devXiNumData = new DevXiNumData();
+                            String ip = XiNumberManager.xiDevList.get(0).getDevIP();
+                            devXiNumData.setDevIP(ip);
+                            //String stdMonitorId = DetectionServiceImpl.vAndIResultMap.keySet().stream().filter(key -> key.contains(ip)).findFirst().get();
+
+                            List<PqStandardDevGain> pqStandardDevGainList = new ArrayList<>();
+                            List<PqStandardDevGainRecord> recordList = new ArrayList<>();
+                            for (int i = 0; i < gfList.size(); i++) {
+                                DevXiNumData.GF gf = gfList.get(i);
+                                String stdDevMonitorId = FormalTestManager.devIdMapComm.get(ip) + CnSocketUtil.SPLIT_TAG + (gf.getUMonitorPoint() + 1);
+                                String devMonitorId = FormalTestManager.pairsIdMap.inverse().get(stdDevMonitorId);
+                                PqStandardDevGain pqStandardDevGain = new PqStandardDevGain();
+                                pqStandardDevGain.setStdDevMonitorId(stdDevMonitorId);
+
+                                DevXiNumData.F f = gf.getF();
+                                pqStandardDevGain.setUaGain(f.getUa_gain());
+                                pqStandardDevGain.setUbGain(f.getUb_gain());
+                                pqStandardDevGain.setUcGain(f.getUc_gain());
+                                pqStandardDevGain.setU0Gain(f.getU0_gain());
+                                pqStandardDevGain.setIaGain(f.getIa_gain());
+                                pqStandardDevGain.setIbGain(f.getIb_gain());
+                                pqStandardDevGain.setIcGain(f.getIc_gain());
+                                pqStandardDevGain.setI0Gain(f.getI0_gain());
+                                pqStandardDevGain.setUabGain(f.getUab_gain());
+                                pqStandardDevGain.setUbcGain(f.getUbc_gain());
+                                pqStandardDevGain.setUcaGain(f.getUca_gain());
+                                pqStandardDevGain.setState(DataStateEnum.ENABLE.getCode());
+                                pqStandardDevGainList.add(pqStandardDevGain);
+                                DetectionServiceImpl.VAndIResult vAndIResult = DetectionServiceImpl.vAndIResultMap.get(ip + CnSocketUtil.SPLIT_TAG + (gf.getUMonitorPoint() + 1));
+                                if (ObjectUtil.isNotNull(vAndIResult)) {
+                                    int maxNum = pqStandardDevGainRecordService.getMaxNum(stdDevMonitorId, devMonitorId);
+                                    PqStandardDevGainRecord record = new PqStandardDevGainRecord();
+                                    record.setStdDevMonitorId(stdDevMonitorId);
+                                    record.setDevMonitorId(devMonitorId);
+                                    record.setNum(maxNum + 1);
+                                    recordList.add(record);
+                                    updateGfList(f, vAndIResult, stdDevMonitorId, maxNum);
+                                }
+                            }
+
+                            xiSocket.setOperateCode(SourceOperateCodeEnum.DATA_CHNFACTOR$02.getValue());
+                            devXiNumData.setGf(gfList);
+                            xiSocket.setData(JSON.toJSONString(devXiNumData));
+                            SocketManager.sendMsg(param.getUserPageId() + CnSocketUtil.CONTRAST_DEV_TAG, JSON.toJSONString(xiSocket));
+
+                            // 原始系数入库
+                            pqStandardDevGainService.add(pqStandardDevGainList);
+                            pqStandardDevGainRecordService.addOrUpdate(recordList);
+                        }
+                        break;
+                    case UNPROCESSED_BUSINESS:
+                        break;
+                    case NORMAL_RESPONSE:
+                        break;
+                    case DATA_RESOLVE:
+                        break;
+                    case COMMUNICATION_ERR:
+                        break;
+                    default:
+                        break;
+                }
+
+                break;
+            case DATA_CHNFACTOR$02:
+                //系数下发后的响应
+                switch (Objects.requireNonNull(dictDataEnumByCode)) {
+                    case SUCCESS:
+                        //单台装置系数下发后，需要删除集合中存在的当前装置
+                        XiNumberManager.xiDevList.remove(0);
+                        //继续下发每台装置系数，只到集合为空
+                        if (CollUtil.isNotEmpty(XiNumberManager.xiDevList)) {
+                            xiSocket.setOperateCode(SourceOperateCodeEnum.DATA_CHNFACTOR$01.getValue());
+                            xiSocket.setData(JSON.toJSONString(XiNumberManager.devXiNumDataMap.get(XiNumberManager.xiDevList.get(0))));
+                            PreDetection preDetection = XiNumberManager.xiDevList.get(0);
+                            Map<String, Object> map = new HashMap<>();
+                            map.put("devIP", preDetection.getDevIP());
+                            map.put("chnNum", preDetection.getDevChns());
+                            xiSocket.setData(JSON.toJSONString(map));
+                            SocketManager.sendMsg(param.getUserPageId() + CnSocketUtil.CONTRAST_DEV_TAG, JSON.toJSONString(xiSocket));
+                        } else {
+                            //{"requestId":"Coefficient_Check","operateCode":"DATA_CHNFACTOR$02","data":"end","code":10200}
+                            // 通知前端全部下发系数完成
+                        }
+                        break;
+                    case UNPROCESSED_BUSINESS:
+                        break;
+                    case NORMAL_RESPONSE:
+                        break;
+                    case DATA_RESOLVE:
+                        //quitSend(param);
+                        break;
+                    case COMMUNICATION_ERR:
+                        break;
+                    default:
+                        break;
+                }
+                break;
+//            case DEV_DATA_REQUEST_02:
+//                //实时采集申请
+//                String data = socketDataMsg.getData();
+//                DevData devData = JSON.parseObject(data, DevData.class);
+//                if (ObjectUtil.isNotNull(dictDataEnumByCode)) {
+//                    switch (dictDataEnumByCode) {
+//                        case SUCCESS:
+//                            if (devData.getResult()) {
+//                                FormalTestManager.realDataXiList.add(devData);
+//                                successComm.add(devData.getId());
+//                                System.out.println(successComm.size() + " ==" + FormalTestManager.monitorIdListComm.size() + "FormalTestManager.realDataXiList:" + FormalTestManager.realDataXiList.size() + "当前步骤" + XiNumberManager.stepNumber);
+//                                if (successComm.size() == FormalTestManager.monitorIdListComm.size()) {
+//                                    processData(param, xiSocket);
+//                                }
+//                            } else {
+//                                System.out.println("系数校准抛除数据" + devData);
+//                            }
+//                            break;
+//                        case UNPROCESSED_BUSINESS:
+//                            WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg));
+//                            break;
+//                        case NORMAL_RESPONSE:
+//                            if (devData.getResult()) {
+//                                FormalTestManager.realDataXiList.add(devData);
+//                            } else {
+//                                System.out.println("系数校准抛除数据" + devData);
+//                            }
+//                            break;
+//                        default:
+//                            xiSocket.setRequestId(socketDataMsg.getRequestId());
+//                            xiSocket.setOperateCode(socketDataMsg.getOperateCode());
+//                            xiSocket.setData(dictDataEnumByCode.getMessage());
+//                            WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(xiSocket));
+//                            break;
+//                    }
+//                }
+//                break;
+            default:
+                WebServiceManager.sendUnknownErrorMessage(param.getUserPageId());
+                break;
+        }
+
+    }
+
 
     /**
      * 退出检测返回
@@ -1856,13 +2044,13 @@ public class SocketContrastResponseService {
      */
     private Integer getTargetCount() {
         if (FormalTestManager.isPstData) {
-            return FormalTestManager.curretntTestPlanConfig.getFlicker();
+            return FormalTestManager.curretntTestPlanConfig.getFlicker() * 2;
         }
         if (ObjectUtil.isNotNull(FormalTestManager.nonWaveDataSourceEnum)) {
             if (FormalTestManager.nonWaveDataSourceEnum == DataSourceEnum.REAL_DATA) {
-                return FormalTestManager.curretntTestPlanConfig.getRealTime();
+                return FormalTestManager.curretntTestPlanConfig.getRealTime() * 2;
             } else {
-                return FormalTestManager.curretntTestPlanConfig.getStatistics();
+                return FormalTestManager.curretntTestPlanConfig.getStatistics() * 2;
             }
         }
         return -1;
@@ -1948,8 +2136,13 @@ public class SocketContrastResponseService {
                         isStar = true;
                         isDelta = false;
                     } else {
-                        isStar = false;
-                        isDelta = true;
+                        if (DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection())) {
+                            isStar = true;
+                            isDelta = false;
+                        } else {
+                            isStar = false;
+                            isDelta = true;
+                        }
                     }
                 }
 
@@ -2052,8 +2245,13 @@ public class SocketContrastResponseService {
                         isStar = true;
                         isDelta = false;
                     } else {
-                        isStar = false;
-                        isDelta = true;
+                        if (DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection())) {
+                            isStar = true;
+                            isDelta = false;
+                        } else {
+                            isStar = false;
+                            isDelta = true;
+                        }
                     }
                 }
 
@@ -2273,8 +2471,13 @@ public class SocketContrastResponseService {
                 isStar = true;
                 isDelta = false;
             } else {
-                isStar = false;
-                isDelta = true;
+                if (DetectionCodeEnum.STAR.getCode().equals(monitorListDTO.getConnection())) {
+                    isStar = true;
+                    isDelta = false;
+                } else {
+                    isStar = false;
+                    isDelta = true;
+                }
             }
         }
 
@@ -2592,18 +2795,30 @@ public class SocketContrastResponseService {
                     devInfo = pqDevService.getDevInfo(Collections.singletonList(devId));
                 }
                 Integer usePhaseIndex = devInfo.get(0).getUsePhaseIndex();
-
                 List<String> allDesc = data.getSqlData().stream().map(x -> x.getDesc()).collect(Collectors.toList());
                 allDesc.addAll(data.getSqlDataHarm().stream().map(x -> x.getDesc()).collect(Collectors.toList()));
 
+                String bzDevId = devId;
+                if (isStdDev) {
+                    String s = FormalTestManager.pairsIdMap.inverse().get(devId + CnSocketUtil.SPLIT_TAG + splitArr[1]);
+                    bzDevId = s.split(CnSocketUtil.SPLIT_TAG)[0];
+                }
+                PqMonitor monitor = pqMonitorService.getByDevIdAndNum(bzDevId, Integer.parseInt(splitArr[1]));
+                DictData dictData = dictDataService.getById(monitor.getConnection());
                 for (DevData.SqlDataDTO sqlDataDTO : data.getSqlData()) {
                     if (usePhaseIndex.equals(1)) {
                         if (DetectionCodeEnum.PVRMS.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.PU1.getCode().equals(sqlDataDTO.getDesc())) {
                             continue;
                         }
                     } else {
-                        if (DetectionCodeEnum.VRMS.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.U1.getCode().equals(sqlDataDTO.getDesc())) {
-                            continue;
+                        if (DetectionCodeEnum.STAR.getCode().equals(dictData.getCode())) {
+                            if (DetectionCodeEnum.PVRMS.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.PU1.getCode().equals(sqlDataDTO.getDesc())) {
+                                continue;
+                            }
+                        } else {
+                            if ((DetectionCodeEnum.VRMS.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.U1.getCode().equals(sqlDataDTO.getDesc()))) {
+                                continue;
+                            }
                         }
                     }
 
@@ -2651,8 +2866,14 @@ public class SocketContrastResponseService {
                             continue;
                         }
                     } else {
-                        if (DetectionCodeEnum.V2_50.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.SV_1_49.getCode().equals(sqlDataDTO.getDesc())) {
-                            continue;
+                        if (DetectionCodeEnum.STAR.getCode().equals(dictData.getCode())) {
+                            if (DetectionCodeEnum.PV2_50.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.PSV_1_49.getCode().equals(sqlDataDTO.getDesc())) {
+                                continue;
+                            }
+                        } else {
+                            if (DetectionCodeEnum.V2_50.getCode().equals(sqlDataDTO.getDesc()) || DetectionCodeEnum.SV_1_49.getCode().equals(sqlDataDTO.getDesc())) {
+                                continue;
+                            }
                         }
                     }
 
@@ -3289,4 +3510,46 @@ public class SocketContrastResponseService {
         devData.setSqlDataHarm(sqlDataHarmDTOS);
         return devData;
     }
+
+    /**
+     * 修改通道系数
+     *
+     * @param f
+     */
+    private void updateGfList(DevXiNumData.F f, DetectionServiceImpl.VAndIResult vAndIResult, String stdDevMonitorId, int maxNum) {
+        DevXiNumData.F originF = BeanUtil.copyProperties(f, DevXiNumData.F.class);
+        if (maxNum != 0) {
+            PqStandardDevGain pqStandardDevGain = pqStandardDevGainService.get(stdDevMonitorId);
+            originF.setUa_gain(pqStandardDevGain.getUaGain());
+            originF.setUb_gain(pqStandardDevGain.getUbGain());
+            originF.setUc_gain(pqStandardDevGain.getUcGain());
+            originF.setU0_gain(pqStandardDevGain.getU0Gain());
+            originF.setIa_gain(pqStandardDevGain.getIaGain());
+            originF.setIb_gain(pqStandardDevGain.getIbGain());
+            originF.setIc_gain(pqStandardDevGain.getIcGain());
+            originF.setI0_gain(pqStandardDevGain.getI0Gain());
+            originF.setUab_gain(pqStandardDevGain.getUabGain());
+            originF.setUbc_gain(pqStandardDevGain.getUbcGain());
+            originF.setUca_gain(pqStandardDevGain.getUcaGain());
+        }
+
+        if (vAndIResult.getVa() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getVaXi() * 10000), BigDecimal.valueOf(originF.getUa_gain() * 0.95), BigDecimal.valueOf(originF.getUa_gain() * 1.05))) {
+            f.setUa_gain(BigDecimal.valueOf(f.getUa_gain()).multiply(BigDecimal.valueOf(vAndIResult.getVaXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+        if (vAndIResult.getVb() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getVbXi() * 10000), BigDecimal.valueOf(originF.getUb_gain() * 0.95), BigDecimal.valueOf(originF.getUb_gain() * 1.05))) {
+            f.setUb_gain(BigDecimal.valueOf(f.getUb_gain()).multiply(BigDecimal.valueOf(vAndIResult.getVbXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+        if (vAndIResult.getVc() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getVcXi() * 10000), BigDecimal.valueOf(originF.getUc_gain() * 0.95), BigDecimal.valueOf(originF.getUc_gain() * 1.05))) {
+            f.setUc_gain(BigDecimal.valueOf(f.getUc_gain()).multiply(BigDecimal.valueOf(vAndIResult.getVcXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+        if (vAndIResult.getIa() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getIaXi() * 10000), BigDecimal.valueOf(originF.getIa_gain() * 0.95), BigDecimal.valueOf(originF.getIa_gain() * 1.05))) {
+            f.setIa_gain(BigDecimal.valueOf(f.getIa_gain()).multiply(BigDecimal.valueOf(vAndIResult.getIaXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+        if (vAndIResult.getIb() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getIbXi() * 10000), BigDecimal.valueOf(originF.getIb_gain() * 0.95), BigDecimal.valueOf(originF.getIb_gain() * 1.05))) {
+            f.setIb_gain(BigDecimal.valueOf(f.getIb_gain()).multiply(BigDecimal.valueOf(vAndIResult.getIbXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+        if (vAndIResult.getIc() && NumberUtil.isIn(BigDecimal.valueOf(vAndIResult.getIcXi() * 10000), BigDecimal.valueOf(originF.getIc_gain() * 0.95), BigDecimal.valueOf(originF.getIc_gain() * 1.05))) {
+            f.setIc_gain(BigDecimal.valueOf(f.getIc_gain()).multiply(BigDecimal.valueOf(vAndIResult.getIcXi())).setScale(0, RoundingMode.HALF_UP).intValue());
+        }
+    }
 }

detection/src/main/java/com/njcn/gather/detection/service/PreDetectionService.java

@@ -4,6 +4,7 @@ import com.njcn.gather.detection.pojo.param.ContrastDetectionParam;
 import com.njcn.gather.detection.pojo.param.PreDetectionParam;
 import com.njcn.gather.detection.pojo.param.SimulateDetectionParam;
 
+import java.util.List;
 import java.util.Map;
 
 
@@ -63,4 +64,8 @@ public interface PreDetectionService {
      * 导出实时数据对齐过程中的数据
      */
     void exportAlignData();
+
+    boolean getCanCoefficient();
+
+    void startCoefficient();
 }

detection/src/main/java/com/njcn/gather/detection/service/impl/DetectionServiceImpl.java

@@ -16,8 +16,10 @@ import com.njcn.gather.detection.pojo.vo.DetectionData;
 import com.njcn.gather.detection.pojo.vo.DevLineTestResult;
 import com.njcn.gather.detection.util.DetectionUtil;
 import com.njcn.gather.detection.util.socket.CnSocketUtil;
+import com.njcn.gather.detection.util.socket.FormalTestManager;
 import com.njcn.gather.device.pojo.vo.PreDetection;
 import com.njcn.gather.device.service.IPqDevService;
+import com.njcn.gather.device.service.IPqStandardDevGainRecordService;
 import com.njcn.gather.err.pojo.param.PqErrSysParam;
 import com.njcn.gather.err.pojo.po.PqErrSysDtls;
 import com.njcn.gather.err.pojo.vo.ErrDtlsCheckDataVO;
@@ -36,7 +38,10 @@ import com.njcn.gather.system.cfg.pojo.po.SysTestConfig;
 import com.njcn.gather.system.cfg.service.ISysTestConfigService;
 import com.njcn.gather.system.dictionary.pojo.enums.DictDataEnum;
 import com.njcn.gather.util.StorageUtil;
+import lombok.AllArgsConstructor;
+import lombok.Data;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.log4j.Log4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.stereotype.Service;
 
@@ -56,6 +61,7 @@ import java.util.stream.Stream;
  * @description
  * @date 2024/12/20 13:52
  */
+@Log4j
 @Service
 @RequiredArgsConstructor
 public class DetectionServiceImpl {
@@ -66,6 +72,7 @@ public class DetectionServiceImpl {
     private final ISysTestConfigService sysTestConfigService;
     private final IPqMonitorService pqMonitorService;
     private final IPqDevService pqDevService;
+    private final IPqStandardDevGainRecordService pqStandardDevGainRecordService;
 
     public static final String TYPE_A = "A";
     public static final String TYPE_B = "B";
@@ -82,6 +89,44 @@ public class DetectionServiceImpl {
     private static final Integer INHARMONIC_FLAG = 1;
     private static final Integer HARMONIC_FLAG = 2;
 
+//    @Value("${error.removeCount:14}")
+//    private Integer removeErrorValueCount;
+
+    @Data
+    @AllArgsConstructor
+    public static class VAndIResult {
+        private String ip;
+        private Integer chnNum;
+        private Boolean va;
+        private Boolean vb;
+        private Boolean vc;
+        private Boolean ia;
+        private Boolean ib;
+        private Boolean ic;
+        private Double vaXi;
+        private Double vbXi;
+        private Double vcXi;
+        private Double iaXi;
+        private Double ibXi;
+        private Double icXi;
+        // 皮尔逊相关系数
+        private BigDecimal pearsonCorrelationCoefficientVa;
+        private BigDecimal pearsonCorrelationCoefficientVb;
+        private BigDecimal pearsonCorrelationCoefficientVc;
+        private BigDecimal pearsonCorrelationCoefficientIa;
+        private BigDecimal pearsonCorrelationCoefficientIb;
+        private BigDecimal pearsonCorrelationCoefficientIc;
+        // 比值一致性 CV 系数
+        private BigDecimal cVCoefficientVa;
+        private BigDecimal cVCoefficientVb;
+        private BigDecimal cVCoefficientVc;
+        private BigDecimal cVCoefficientIa;
+        private BigDecimal cVCoefficientIb;
+        private BigDecimal cVCoefficientIc;
+    }
+
+    public static Map<String, VAndIResult> vAndIResultMap = null;
+
 
     /**
      * 开始处理指标类型
@@ -1572,6 +1617,23 @@ public class DetectionServiceImpl {
         if (CollUtil.isNotEmpty(devDataList) && CollUtil.isNotEmpty(standardDevDataList) && CollUtil.isNotEmpty(testItemCodeList)) {
             devDataList = devDataList.stream().sorted(Comparator.comparing(DevData::getTime)).collect(Collectors.toList());
             standardDevDataList = standardDevDataList.stream().sorted(Comparator.comparing(DevData::getTime)).collect(Collectors.toList());
+
+            boolean isRemoveMaxElement = ObjectUtil.isNotNull(waveNum) ? false : true;
+//            List<Double> freqStdDevData = standardDevDataList.stream().flatMap(standardDevData -> standardDevData.getSqlData().stream())
+//                    .filter(sqlDataDTO -> DetectionCodeEnum.FREQ.getCode().equals(sqlDataDTO.getDesc()))
+//                    .map(sqlDataDTO -> sqlDataDTO.getList().getT()).collect(Collectors.toList());
+
+//            Double maxFreq = CollUtil.isNotEmpty(freqStdDevData) ? CollUtil.max(freqStdDevData) : null;
+//            Double minFreq = CollUtil.isNotEmpty(freqStdDevData) ? CollUtil.min(freqStdDevData) : null;
+
+//            if (maxFreq != null && minFreq != null) {
+//                isRemoveMaxElement = DictDataEnum.AVG_VALUE.equals(dataRule);
+//                double freqErrorValue = maxFreq - minFreq;
+//                if (NumberUtil.isGreaterOrEqual(BigDecimal.valueOf(freqErrorValue), BigDecimal.valueOf(0.02))) {
+//                    isRemoveMaxElement = isRemoveMaxElement && true;
+//                }
+//            }
+
             // 处理谐波数据
             SysTestConfig oneConfig = sysTestConfigService.getOneConfig();
             String[] split1 = devDataList.get(0).getId().split("_");
@@ -1618,12 +1680,12 @@ public class DetectionServiceImpl {
 //                                sqlData.setList(listDTO);
 //                            }));
 //                        }
-                        resultMap.put(PowerIndexEnum.FREQ.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fHz, DetectionCodeEnum.FREQ.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.FREQ.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fHz, DetectionCodeEnum.FREQ.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case VRMS:
                     case PVRMS:
                         // 如果是角型接法且存在角型接法的一些指标，则不进行使用角型接线的指标。反之，则使用相别的指标。
-                        resultMap.put(PowerIndexEnum.V.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fUn, (isDelta && isExitDelta ? DetectionCodeEnum.PVRMS.getCode() : DetectionCodeEnum.VRMS.getCode()), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.V.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fUn, (isDelta && isExitDelta ? DetectionCodeEnum.PVRMS.getCode() : DetectionCodeEnum.VRMS.getCode()), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case IRMS:
 //                        if (ObjectUtil.isNotNull(waveNum) && (waveNum.equals(2) || waveNum.equals(5))) {
@@ -1634,33 +1696,33 @@ public class DetectionServiceImpl {
 //                                sqlData.setList(listDTO);
 //                            }));
 //                        }
-                        resultMap.put(PowerIndexEnum.I.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fIn, DetectionCodeEnum.IRMS.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.I.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fIn, DetectionCodeEnum.IRMS.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case V_UNBAN:
-                        resultMap.put(PowerIndexEnum.IMBV.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, false, fUn, DetectionCodeEnum.V_UNBAN.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.IMBV.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, false, fUn, DetectionCodeEnum.V_UNBAN.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case I_UNBAN:
-                        resultMap.put(PowerIndexEnum.IMBA.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, false, fIn, DetectionCodeEnum.I_UNBAN.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.IMBA.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, false, fIn, DetectionCodeEnum.I_UNBAN.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case V2_50:
                     case PV2_50:
-                        resultMap.put(PowerIndexEnum.HV.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, U, fUn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.HV.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, U, fUn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case I2_50:
-                        resultMap.put(PowerIndexEnum.HI.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, I, fIn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.HI.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, I, fIn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case P2_50:
-                        resultMap.put(PowerIndexEnum.HP.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, HP, fUn * fIn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.HP.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, HP, fUn * fIn, HARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case SV_1_49:
                     case PSV_1_49:
-                        resultMap.put(PowerIndexEnum.HSV.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, U, fUn, INHARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.HSV.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, U, fUn, INHARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case SI_1_49:
-                        resultMap.put(PowerIndexEnum.HSI.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, I, fIn, INHARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum));
+                        resultMap.put(PowerIndexEnum.HSI.getKey(), isHarmQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, I, fIn, INHARMONIC_FLAG, isDelta && isExitDelta, dataRule, num, code, oneConfig.getScale(), waveNum, dataSourceEnum, isRemoveMaxElement));
                         break;
                     case PST:
-                        resultMap.put(PowerIndexEnum.F.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fUn, DetectionCodeEnum.PST.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, DataSourceEnum.MINUTE_STATISTICS_AVG));
+                        resultMap.put(PowerIndexEnum.F.getKey(), isQualified(devDataList, standardDevDataList, devIdMapComm, pqErrSysDtls, true, fUn, DetectionCodeEnum.PST.getCode(), dataRule, num, code, oneConfig.getScale(), waveNum, DataSourceEnum.MINUTE_STATISTICS_AVG, isRemoveMaxElement));
                         break;
                     case UNKNOWN_ERROR:
                         break;
@@ -1734,22 +1796,29 @@ public class DetectionServiceImpl {
                                 String code,
                                 Integer scale,
                                 Integer waveNum,
-                                DataSourceEnum dataSourceEnum) {
+                                DataSourceEnum dataSourceEnum,
+                                boolean isRemoveMaxElement) {
         List<ContrastNonHarmonicResult> info = new ArrayList<>();
         if (CollUtil.isNotEmpty(devDataList) && CollUtil.isNotEmpty(standardDevDataList) && CollUtil.isNotEmpty(errSysDtls)) {
 
-            Map<String, List<List<Double>>> map = devListMap(devDataList, standardDevDataList, desc, dataRule);
+            Map<String, List<List<Double>>> phaseValueList = this.getPhaseValueList(devDataList, standardDevDataList, desc);
+            Map<String, List<List<Double>>> map = devListMap(phaseValueList, dataRule, isRemoveMaxElement);
             if (ObjectUtil.isNull(map)) {
                 return 4;
             }
             ContrastNonHarmonicResult result = new ContrastNonHarmonicResult();
             result.setWaveNum(waveNum);
 
-            String[] split1 = devDataList.get(0).getId().split(CnSocketUtil.SPLIT_TAG);
-            String[] split2 = standardDevDataList.get(0).getId().split(CnSocketUtil.SPLIT_TAG);
+            String devId = devDataList.get(0).getId();
+            String stdId = standardDevDataList.get(0).getId();
+
+            String[] split1 = devId.split(CnSocketUtil.SPLIT_TAG);
+            String[] split2 = stdId.split(CnSocketUtil.SPLIT_TAG);
             result.setNum(num);
-            result.setDevMonitorId(devIdMapComm.get(split1[0]) + "_" + split1[1]);
-            result.setStdDevMonitorId(devIdMapComm.get(split2[0]) + "_" + split2[1]);
+            String devMonitorId = devIdMapComm.get(split1[0]) + "_" + split1[1];
+            result.setDevMonitorId(devMonitorId);
+            String stdDevMonitorId = devIdMapComm.get(split2[0]) + "_" + split2[1];
+            result.setStdDevMonitorId(stdDevMonitorId);
             result.setAdType(errSysDtls.get(0).getScriptType());
             result.setDataType(dataSourceEnum.getValue());
             if (ObjectUtil.isNotNull(waveNum)) {
@@ -1790,6 +1859,78 @@ public class DetectionServiceImpl {
                     List<DetectionData> phaseList = rangeComparisonList(map.get(phase).get(0), map.get(phase).get(1), errSysDtls, fData, scale, dataRule);
                     this.setValidGroupNum(phaseList, validGroupNum);
                     resultFlag.addAll(phaseList);
+                    if (FormalTestManager.isTesting && ObjectUtil.isNull(waveNum)) { //只有“正式检测并且不是录波数据”的时候才能进入这段代码，重新计算、切换误差体系额操作不会进入这段代码，提升效率。
+//                    if (true) { //只有“正式检测并且不是录波数据”的时候才能进入这段代码，重新计算、切换误差体系额操作不会进入这段代码，提升效率。
+                        if (DetectionCodeEnum.PVRMS.getCode().equals(desc) || DetectionCodeEnum.VRMS.getCode().equals(desc) || DetectionCodeEnum.IRMS.getCode().equals(desc)) {
+                            Integer phaseResultFlag = setResultFlag(phaseList);
+                            boolean b = phaseResultFlag == 2 ? true : false;
+
+                            SysTestConfig oneConfig = sysTestConfigService.getOneConfig();
+                            if (b && oneConfig.getCoefficient() == 1) {
+                                BigDecimal pearsonCorrelationCoefficient = DetectionUtil.getPearsonCorrelationCoefficient(phaseValueList.get(phase).get(0), phaseValueList.get(phase).get(1));
+                                if (NumberUtil.isGreaterOrEqual(pearsonCorrelationCoefficient, BigDecimal.valueOf(0.8))) {
+                                    BigDecimal cvCoefficient = DetectionUtil.getCvCoefficient(phaseValueList.get(phase).get(0), phaseValueList.get(phase).get(1));
+                                    if (NumberUtil.isLess(cvCoefficient, BigDecimal.valueOf(0.05))) {
+                                        int maxNum = pqStandardDevGainRecordService.getMaxNum(stdDevMonitorId, devMonitorId);
+                                        // 如果没有超出次数限制
+                                        if (maxNum + 1 <= 5) {
+                                            VAndIResult vAndIResult = vAndIResultMap.getOrDefault(stdId, new VAndIResult(split2[0], Integer.valueOf(split2[1]), false, false, false, false, false, false,
+                                                    1.0, 1.0, 1.0, 1.0, 1.0, 1.0,
+                                                    BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO, BigDecimal.ZERO,
+                                                    BigDecimal.valueOf(0.2), BigDecimal.valueOf(0.2), BigDecimal.valueOf(0.2), BigDecimal.valueOf(0.2), BigDecimal.valueOf(0.2), BigDecimal.valueOf(0.2)));
+
+                                            Double newXi = DetectionUtil.getNewXi(map.get(phase).get(0), map.get(phase).get(1));
+                                            switch (phase) {
+                                                case TYPE_A:
+                                                    if (DetectionCodeEnum.IRMS.getCode().equals(desc)) {
+                                                        vAndIResult.setIa(b);
+                                                        vAndIResult.setIaXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientIa(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientIa(cvCoefficient);
+                                                    } else {
+                                                        vAndIResult.setVa(b);
+                                                        vAndIResult.setVaXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientVa(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientVa(cvCoefficient);
+                                                    }
+                                                    break;
+                                                case TYPE_B:
+                                                    if (DetectionCodeEnum.IRMS.getCode().equals(desc)) {
+                                                        vAndIResult.setIb(b);
+                                                        vAndIResult.setIbXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientIb(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientIb(cvCoefficient);
+                                                    } else {
+                                                        vAndIResult.setVb(b);
+                                                        vAndIResult.setVbXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientVb(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientVb(cvCoefficient);
+                                                    }
+                                                    break;
+                                                case TYPE_C:
+                                                    if (DetectionCodeEnum.IRMS.getCode().equals(desc)) {
+                                                        vAndIResult.setIc(b);
+                                                        vAndIResult.setIcXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientIc(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientIc(cvCoefficient);
+                                                    } else {
+                                                        vAndIResult.setVc(b);
+                                                        vAndIResult.setVcXi(newXi);
+                                                        vAndIResult.setPearsonCorrelationCoefficientVc(pearsonCorrelationCoefficient);
+                                                        vAndIResult.setCVCoefficientVc(cvCoefficient);
+                                                    }
+                                                    break;
+                                                default:
+                                                    break;
+                                            }
+
+                                            vAndIResultMap.put(stdId, vAndIResult);
+                                        }
+                                    }
+                                }
+                            }
+                        }
+                    }
                     BiConsumer<ContrastNonHarmonicResult, List<DetectionData>> setter = setters.get(phase);
                     setter.accept(result, phaseList);
                 }
@@ -1999,7 +2140,8 @@ public class DetectionServiceImpl {
                                    String code,
                                    Integer scale,
                                    Integer waveNum,
-                                   DataSourceEnum dataSourceEnum) {
+                                   DataSourceEnum dataSourceEnum,
+                                   boolean isRemoveMaxElement) {
         List<ContrastHarmonicResult> info = new ArrayList<>();
         if (CollUtil.isNotEmpty(devDataList) && CollUtil.isNotEmpty(standardDevDataList) && CollUtil.isNotEmpty(errSysDtls)) {
             String fundCode = "";
@@ -2034,7 +2176,7 @@ public class DetectionServiceImpl {
                 harmCode = DetectionCodeEnum.P2_50.getCode();
             }
 
-            Map<String, List<Map<Double, List<Double>>>> devMap = devHarmListMap(devDataList, standardDevDataList, fundCode, harmCode, harmonicFlag, dataRule);
+            Map<String, List<Map<Double, List<Double>>>> devMap = devHarmListMap(devDataList, standardDevDataList, fundCode, harmCode, harmonicFlag, dataRule, isRemoveMaxElement);
             if (ObjectUtil.isNull(devMap)) {
                 return 4;
             }
@@ -2141,14 +2283,285 @@ public class DetectionServiceImpl {
     /**
      * 处理非谐波类取值
      *
-     * @param dev         被检设备原始数据
-     * @param standardDev 与之对齐的标准设备原始数据
-     * @param desc        检测项
-     * @param dataRule    数据处理原则
+     * @param dataRule 数据处理原则
      */
-    public Map<String, List<List<Double>>> devListMap(List<DevData> dev, List<DevData> standardDev, String desc, DictDataEnum dataRule) {
+    public Map<String, List<List<Double>>> devListMap(Map<String, List<List<Double>>> phaseValueList, DictDataEnum dataRule, boolean isRemoveMaxElement) {
         Map<String, List<List<Double>>> resultMap = new HashMap<>(3);
 
+        List<Double> aDev = new ArrayList<>();
+        List<Double> aStandardDev = new ArrayList<>();
+
+        if (phaseValueList.containsKey(TYPE_A)) {
+            if (phaseValueList.get(TYPE_A).size() >= 1) {
+                aDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_A).get(0), Double.class));
+                aStandardDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_A).get(1), Double.class));
+            } else {
+                log.error("数据异常，phaseValueList.get(TYPE_A).size()=" + phaseValueList.get(TYPE_A).size());
+            }
+        } else {
+            log.equals("数据异常，phaseValueList.containsKey(TYPE_A)=" + phaseValueList.containsKey(TYPE_A));
+        }
+
+        List<Double> bDev = new ArrayList<>();
+        List<Double> bStandardDev = new ArrayList<>();
+
+        if (phaseValueList.containsKey(TYPE_B)) {
+            if (phaseValueList.get(TYPE_B).size() >= 1) {
+                bDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_B).get(0), Double.class));
+                bStandardDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_B).get(1), Double.class));
+            } else {
+                log.error("数据异常，phaseValueList.get(TYPE_B).size()=" + phaseValueList.get(TYPE_B).size());
+            }
+        } else {
+            log.equals("数据异常，phaseValueList.containsKey(TYPE_B)=" + phaseValueList.containsKey(TYPE_B));
+        }
+
+        List<Double> cDev = new ArrayList<>();
+        List<Double> cStandardDev = new ArrayList<>();
+        if (phaseValueList.containsKey(TYPE_C)) {
+            if (phaseValueList.get(TYPE_C).size() >= 1) {
+                cDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_C).get(0), Double.class));
+                cStandardDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_C).get(1), Double.class));
+            } else {
+                log.error("数据异常，phaseValueList.get(TYPE_C).size()=" + phaseValueList.get(TYPE_C).size());
+            }
+        } else {
+            log.equals("数据异常，phaseValueList.containsKey(TYPE_C)=" + phaseValueList.containsKey(TYPE_C));
+        }
+
+        List<Double> tDev = new ArrayList<>();
+        List<Double> tStandardDev = new ArrayList<>();
+        if (phaseValueList.containsKey(TYPE_T)) {
+            if (phaseValueList.get(TYPE_T).size() >= 1) {
+                tDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_T).get(0), Double.class));
+                tStandardDev.addAll(BeanUtil.copyToList(phaseValueList.get(TYPE_T).get(1), Double.class));
+            } else {
+                log.error("数据异常，phaseValueList.get(TYPE_T).size()=" + phaseValueList.get(TYPE_T).size());
+            }
+        } else {
+            log.equals("数据异常，phaseValueList.containsKey(TYPE_T)=" + phaseValueList.containsKey(TYPE_T));
+        }
+
+        if (isRemoveMaxElement) {
+            List<Double> aErrorValueList = new ArrayList<>();
+            List<Double> bErrorValueList = new ArrayList<>();
+            List<Double> cErrorValueList = new ArrayList<>();
+            List<Double> tErrorValueList = new ArrayList<>();
+            for (int i = 0; i < aStandardDev.size(); i++) {
+                aErrorValueList.add(Math.abs(aStandardDev.get(i) - aDev.get(i)));
+            }
+            for (int i = 0; i < bStandardDev.size(); i++) {
+                bErrorValueList.add(Math.abs(bStandardDev.get(i) - bDev.get(i)));
+            }
+            for (int i = 0; i < cStandardDev.size(); i++) {
+                cErrorValueList.add(Math.abs(cStandardDev.get(i) - cDev.get(i)));
+            }
+            for (int i = 0; i < tStandardDev.size(); i++) {
+                tErrorValueList.add(Math.abs(tStandardDev.get(i) - tDev.get(i)));
+            }
+            List<Integer> aErrorValueIdxs = DetectionUtil.sort(aErrorValueList, false);
+            List<Integer> bErrorValueIdxs = DetectionUtil.sort(bErrorValueList, false);
+            List<Integer> cErrorValueIdxs = DetectionUtil.sort(cErrorValueList, false);
+            List<Integer> tErrorValueIdxs = DetectionUtil.sort(tErrorValueList, false);
+
+            int removeCount = aErrorValueIdxs.size() / 2;
+            List<Double> newArray = DetectionUtil.getNewArray(aStandardDev, aErrorValueIdxs.subList(removeCount, aErrorValueIdxs.size()));
+            aStandardDev.clear();
+            aStandardDev.addAll(newArray);
+            newArray = DetectionUtil.getNewArray(aDev, aErrorValueIdxs.subList(removeCount, aErrorValueIdxs.size()));
+            aDev.clear();
+            aDev.addAll(newArray);
+
+            removeCount = bErrorValueIdxs.size() / 2;
+            newArray = DetectionUtil.getNewArray(bStandardDev, bErrorValueIdxs.subList(removeCount, bErrorValueIdxs.size()));
+            bStandardDev.clear();
+            bStandardDev.addAll(newArray);
+            newArray = DetectionUtil.getNewArray(bDev, bErrorValueIdxs.subList(removeCount, bErrorValueIdxs.size()));
+            bDev.clear();
+            bDev.addAll(newArray);
+
+            removeCount = cErrorValueIdxs.size() / 2;
+            newArray = DetectionUtil.getNewArray(cStandardDev, cErrorValueIdxs.subList(removeCount, cErrorValueIdxs.size()));
+            cStandardDev.clear();
+            cStandardDev.addAll(newArray);
+            newArray = DetectionUtil.getNewArray(cDev, cErrorValueIdxs.subList(removeCount, cErrorValueIdxs.size()));
+            cDev.clear();
+            cDev.addAll(newArray);
+
+            removeCount = tErrorValueIdxs.size() / 2;
+            newArray = DetectionUtil.getNewArray(tStandardDev, tErrorValueIdxs.subList(removeCount, tErrorValueIdxs.size()));
+            tStandardDev.clear();
+            tStandardDev.addAll(newArray);
+            newArray = DetectionUtil.getNewArray(tDev, tErrorValueIdxs.subList(removeCount, tErrorValueIdxs.size()));
+            tDev.clear();
+            tDev.addAll(newArray);
+        }
+
+        switch (dataRule) {
+            case SECTION_VALUE: {
+                List<Integer> aIdxs = DetectionUtil.sort(aStandardDev, false);
+                List<Integer> bIdxs = DetectionUtil.sort(bStandardDev, false);
+                List<Integer> cIdxs = DetectionUtil.sort(cStandardDev, false);
+                List<Integer> tIdxs = DetectionUtil.sort(tStandardDev, false);
+                if (aStandardDev.size() > 2) {
+                    aStandardDev.remove(0);
+                    aStandardDev.remove(aStandardDev.size() - 1);
+                    List<Double> newArray = DetectionUtil.getNewArray(aDev, aIdxs.subList(1, aIdxs.size() - 1));
+                    aDev.clear();
+                    aDev.addAll(newArray);
+                }
+                if (bStandardDev.size() > 2) {
+                    bStandardDev.remove(0);
+                    bStandardDev.remove(bStandardDev.size() - 1);
+                    List<Double> newArray = DetectionUtil.getNewArray(bDev, bIdxs.subList(1, bIdxs.size() - 1));
+                    bDev.clear();
+                    bDev.addAll(newArray);
+                }
+                if (cStandardDev.size() > 2) {
+                    cStandardDev.remove(0);
+                    cStandardDev.remove(cStandardDev.size() - 1);
+                    List<Double> newArray = DetectionUtil.getNewArray(cDev, cIdxs.subList(1, cIdxs.size() - 1));
+                    cDev.clear();
+                    cDev.addAll(newArray);
+                }
+                if (tStandardDev.size() > 2) {
+                    tStandardDev.remove(0);
+                    tStandardDev.remove(tStandardDev.size() - 1);
+                    List<Double> newArray = DetectionUtil.getNewArray(tDev, tIdxs.subList(1, tIdxs.size() - 1));
+                    tDev.clear();
+                    tDev.addAll(newArray);
+                }
+            }
+            break;
+            case CP95_VALUE: {
+                List<Integer> aIdxs = DetectionUtil.sort(aStandardDev, false);
+                List<Integer> bIdxs = DetectionUtil.sort(bStandardDev, false);
+                List<Integer> cIdxs = DetectionUtil.sort(cStandardDev, false);
+                List<Integer> tIdxs = DetectionUtil.sort(tStandardDev, false);
+                if (CollUtil.isNotEmpty(aStandardDev)) {
+                    int cp95Idx = DetectionUtil.getCP95Idx(aStandardDev);
+                    aStandardDev = Collections.singletonList(aStandardDev.get(cp95Idx));
+                    aDev = Collections.singletonList(aDev.get(aIdxs.get(cp95Idx)));
+                }
+                if (CollUtil.isNotEmpty(bStandardDev)) {
+                    int cp95Idx = DetectionUtil.getCP95Idx(bStandardDev);
+                    bStandardDev = Collections.singletonList(bStandardDev.get(cp95Idx));
+                    bDev = Collections.singletonList(bDev.get(bIdxs.get(cp95Idx)));
+                }
+                if (CollUtil.isNotEmpty(cStandardDev)) {
+                    int cp95Idx = DetectionUtil.getCP95Idx(cStandardDev);
+                    cStandardDev = Collections.singletonList(cStandardDev.get(cp95Idx));
+                    cDev = Collections.singletonList(cDev.get(cIdxs.get(cp95Idx)));
+                }
+                if (CollUtil.isNotEmpty(tStandardDev)) {
+                    int cp95Idx = DetectionUtil.getCP95Idx(tStandardDev);
+                    tStandardDev = Collections.singletonList(tStandardDev.get(cp95Idx));
+                    tDev = Collections.singletonList(tDev.get(tIdxs.get(cp95Idx)));
+                }
+            }
+            break;
+            case AVG_VALUE:
+                aDev = DetectionUtil.getAvgDoubles(aDev);
+                bDev = DetectionUtil.getAvgDoubles(bDev);
+                cDev = DetectionUtil.getAvgDoubles(cDev);
+                tDev = DetectionUtil.getAvgDoubles(tDev);
+
+                aStandardDev = DetectionUtil.getAvgDoubles(aStandardDev);
+                bStandardDev = DetectionUtil.getAvgDoubles(bStandardDev);
+                cStandardDev = DetectionUtil.getAvgDoubles(cStandardDev);
+                tStandardDev = DetectionUtil.getAvgDoubles(tStandardDev);
+                break;
+            case Own_value:
+                break;
+            case AT_WILL_VALUE:
+                if (isRemoveMaxElement) {
+                    if (CollUtil.isNotEmpty(aStandardDev) && CollUtil.isNotEmpty(aDev)) {
+                        aStandardDev = aStandardDev.subList(aStandardDev.size() - 1, aStandardDev.size());
+                        aDev = aDev.subList(aDev.size() - 1, aDev.size());
+                    }
+                    if (CollUtil.isNotEmpty(bStandardDev) && CollUtil.isNotEmpty(bDev)) {
+                        bStandardDev = bStandardDev.subList(bStandardDev.size() - 1, bStandardDev.size());
+                        bDev = bDev.subList(bDev.size() - 1, bDev.size());
+                    }
+                    if (CollUtil.isNotEmpty(cStandardDev) && CollUtil.isNotEmpty(cDev)) {
+                        cStandardDev = cStandardDev.subList(cStandardDev.size() - 1, cStandardDev.size());
+                        cDev = cDev.subList(cDev.size() - 1, cDev.size());
+                    }
+                    if (CollUtil.isNotEmpty(tStandardDev) && CollUtil.isNotEmpty(tDev)) {
+                        tStandardDev = tStandardDev.subList(tStandardDev.size() - 1, tStandardDev.size());
+                        tDev = tDev.subList(tDev.size() - 1, tDev.size());
+                    }
+                } else {
+                    List<Double> aErrorValueList = new ArrayList<>();
+                    List<Double> bErrorValueList = new ArrayList<>();
+                    List<Double> cErrorValueList = new ArrayList<>();
+                    List<Double> tErrorValueList = new ArrayList<>();
+                    for (int i = 0; i < aStandardDev.size(); i++) {
+                        aErrorValueList.add(Math.abs(aStandardDev.get(i) - aDev.get(i)));
+                    }
+                    for (int i = 0; i < bStandardDev.size(); i++) {
+                        bErrorValueList.add(Math.abs(bStandardDev.get(i) - bDev.get(i)));
+                    }
+                    for (int i = 0; i < cStandardDev.size(); i++) {
+                        cErrorValueList.add(Math.abs(cStandardDev.get(i) - cDev.get(i)));
+                    }
+                    for (int i = 0; i < tStandardDev.size(); i++) {
+                        tErrorValueList.add(Math.abs(tStandardDev.get(i) - tDev.get(i)));
+                    }
+                    List<Integer> aErrorValueIdxs = DetectionUtil.sort(aErrorValueList, true);
+                    List<Integer> bErrorValueIdxs = DetectionUtil.sort(bErrorValueList, true);
+                    List<Integer> cErrorValueIdxs = DetectionUtil.sort(cErrorValueList, true);
+                    List<Integer> tErrorValueIdxs = DetectionUtil.sort(tErrorValueList, true);
+
+                    if (CollUtil.isNotEmpty(aStandardDev) && CollUtil.isNotEmpty(aDev)) {
+                        Double v = aStandardDev.get(aErrorValueIdxs.get(0));
+                        aStandardDev.clear();
+                        aStandardDev.add(v);
+                        v = aDev.get(aErrorValueIdxs.get(0));
+                        aDev.clear();
+                        aDev.add(v);
+                    }
+
+                    if (CollUtil.isNotEmpty(bStandardDev) && CollUtil.isNotEmpty(bDev)) {
+                        Double v = bStandardDev.get(bErrorValueIdxs.get(0));
+                        bStandardDev.clear();
+                        bStandardDev.add(v);
+                        v = bDev.get(bErrorValueIdxs.get(0));
+                        bDev.clear();
+                        bDev.add(v);
+                    }
+
+                    if (CollUtil.isNotEmpty(cStandardDev) && CollUtil.isNotEmpty(cDev)) {
+                        Double v = cStandardDev.get(cErrorValueIdxs.get(0));
+                        cStandardDev.clear();
+                        cStandardDev.add(v);
+                        v = cDev.get(cErrorValueIdxs.get(0));
+                        cDev.clear();
+                        cDev.add(v);
+                    }
+
+                    if (CollUtil.isNotEmpty(tStandardDev) && CollUtil.isNotEmpty(tDev)) {
+                        Double v = tStandardDev.get(tErrorValueIdxs.get(0));
+                        tStandardDev.clear();
+                        tStandardDev.add(v);
+                        v = tDev.get(tErrorValueIdxs.get(0));
+                        tDev.clear();
+                        tDev.add(v);
+                    }
+                }
+                break;
+        }
+        resultMap.put(TYPE_A, Arrays.asList(aDev, aStandardDev));
+        resultMap.put(TYPE_B, Arrays.asList(bDev, bStandardDev));
+        resultMap.put(TYPE_C, Arrays.asList(cDev, cStandardDev));
+        if (CollUtil.isNotEmpty(tDev)) {
+            resultMap.put(TYPE_T, Arrays.asList(tDev, tStandardDev));
+        }
+        return resultMap;
+    }
+
+    private Map<String, List<List<Double>>> getPhaseValueList(List<DevData> dev, List<DevData> standardDev, String desc) {
+        Map<String, List<List<Double>>> resultMap = new HashMap<>(3);
         List<Double> aDev = new ArrayList<>();
         List<Double> aStandardDev = new ArrayList<>();
         List<Double> bDev = new ArrayList<>();
@@ -2202,87 +2615,12 @@ public class DetectionServiceImpl {
                     .map(x -> x.getT().doubleValue())
                     .collect(Collectors.toList()));
         }
-        List<Integer> aIdxs = DetectionUtil.sort(aStandardDev, false);
-        List<Integer> bIdxs = DetectionUtil.sort(bStandardDev, false);
-        List<Integer> cIdxs = DetectionUtil.sort(cStandardDev, false);
-        List<Integer> tIdxs = DetectionUtil.sort(tStandardDev, false);
-        switch (dataRule) {
-            case SECTION_VALUE:
-                if (aStandardDev.size() > 2) {
-                    aStandardDev.remove(0);
-                    aStandardDev.remove(aStandardDev.size() - 1);
-                    List<Double> newArray = DetectionUtil.getNewArray(aDev, aIdxs.subList(1, aIdxs.size() - 1));
-                    aDev.clear();
-                    aDev.addAll(newArray);
-                }
 
-                if (bStandardDev.size() > 2) {
-                    bStandardDev.remove(0);
-                    bStandardDev.remove(bStandardDev.size() - 1);
-                    List<Double> newArray = DetectionUtil.getNewArray(bDev, bIdxs.subList(1, bIdxs.size() - 1));
-                    bDev.clear();
-                    bDev.addAll(newArray);
-                }
-
-                if (cStandardDev.size() > 2) {
-                    cStandardDev.remove(0);
-                    cStandardDev.remove(cStandardDev.size() - 1);
-                    List<Double> newArray = DetectionUtil.getNewArray(cDev, cIdxs.subList(1, cIdxs.size() - 1));
-                    cDev.clear();
-                    cDev.addAll(newArray);
-                }
-
-                if (tStandardDev.size() > 2) {
-                    tStandardDev.remove(0);
-                    tStandardDev.remove(tStandardDev.size() - 1);
-                    List<Double> newArray = DetectionUtil.getNewArray(tDev, tIdxs.subList(1, tIdxs.size() - 1));
-                    tDev.clear();
-                    tDev.addAll(newArray);
-                }
-                break;
-            case CP95_VALUE:
-                if (CollUtil.isNotEmpty(aStandardDev)) {
-                    int cp95Idx = DetectionUtil.getCP95Idx(aStandardDev);
-                    aStandardDev = Collections.singletonList(aStandardDev.get(cp95Idx));
-                    aDev = Collections.singletonList(aDev.get(aIdxs.get(cp95Idx)));
-                }
-                if (CollUtil.isNotEmpty(bStandardDev)) {
-                    int cp95Idx = DetectionUtil.getCP95Idx(bStandardDev);
-                    bStandardDev = Collections.singletonList(bStandardDev.get(cp95Idx));
-                    bDev = Collections.singletonList(bDev.get(bIdxs.get(cp95Idx)));
-                }
-
-                if (CollUtil.isNotEmpty(cStandardDev)) {
-                    int cp95Idx = DetectionUtil.getCP95Idx(cStandardDev);
-                    cStandardDev = Collections.singletonList(cStandardDev.get(cp95Idx));
-                    cDev = Collections.singletonList(cDev.get(cIdxs.get(cp95Idx)));
-                }
-
-                if (CollUtil.isNotEmpty(tStandardDev)) {
-                    int cp95Idx = DetectionUtil.getCP95Idx(tStandardDev);
-                    tStandardDev = Collections.singletonList(tStandardDev.get(cp95Idx));
-                    tDev = Collections.singletonList(tDev.get(tIdxs.get(cp95Idx)));
-                }
-
-                break;
-            case AVG_VALUE:
-                aDev = DetectionUtil.getAvgDoubles(aDev);
-                bDev = DetectionUtil.getAvgDoubles(bDev);
-                cDev = DetectionUtil.getAvgDoubles(cDev);
-                tDev = DetectionUtil.getAvgDoubles(tDev);
-
-                aStandardDev = DetectionUtil.getAvgDoubles(aStandardDev);
-                bStandardDev = DetectionUtil.getAvgDoubles(bStandardDev);
-                cStandardDev = DetectionUtil.getAvgDoubles(cStandardDev);
-                tStandardDev = DetectionUtil.getAvgDoubles(tStandardDev);
-                break;
-        }
         resultMap.put(TYPE_A, Arrays.asList(aDev, aStandardDev));
         resultMap.put(TYPE_B, Arrays.asList(bDev, bStandardDev));
         resultMap.put(TYPE_C, Arrays.asList(cDev, cStandardDev));
-        if (CollUtil.isNotEmpty(tDev)) {
-            resultMap.put(TYPE_T, Arrays.asList(tDev, tStandardDev));
-        }
+        resultMap.put(TYPE_T, Arrays.asList(tDev, tStandardDev));
+
         return resultMap;
     }
 
@@ -2302,8 +2640,7 @@ public class DetectionServiceImpl {
                                                                        String fundCode,
                                                                        String harmCode,
                                                                        Integer harmonicFlag,
-                                                                       DictDataEnum dataRule) {
-        System.out.println("aaa" + dev.size() + "  " + standardDev.size());
+                                                                       DictDataEnum dataRule, boolean isRemoveMaxElement) {
         Map<String, List<Map<Double, List<Double>>>> resultMap = new HashMap<>(3);
 
         // key为相别、value{key为谐波次数，value为按数据处理原则处理后的数据}
@@ -2328,27 +2665,6 @@ public class DetectionServiceImpl {
                 first1 = devSqlData.stream().filter(j -> fundCode.equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
                 first2 = standardDevSqlData.stream().filter(j -> fundCode.equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
             }
-//            // 如果角型接法中，不存在线电压谐波电压基波有效值，则取相电压谐波电压基波有效值进行计算
-//            if (!first1.isPresent()) {
-//                if (DetectionCodeEnum.PU1.getCode().equals(fundCode)) {
-//                    first1 = devSqlData.stream().filter(j -> DetectionCodeEnum.U1.getCode().equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
-//                }
-//            } else {
-//                // 防止出现有PU1而没有PV2_50、SV_1_49的情况
-//                if ((DetectionCodeEnum.PV2_50.getCode().equals(harmCode) || DetectionCodeEnum.PSV_1_49.getCode().equals(harmCode)) && DetectionCodeEnum.PU1.getCode().equals(fundCode)) {
-//                    first1 = devSqlData.stream().filter(j -> DetectionCodeEnum.U1.getCode().equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
-//                }
-//            }
-//            if (!first2.isPresent()) {
-//                if (DetectionCodeEnum.PU1.getCode().equals(fundCode)) {
-//                    first2 = devSqlData.stream().filter(j -> DetectionCodeEnum.U1.getCode().equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
-//                }
-//            } else {
-//                // 防止出现有PU1而没有PV2_50、SV_1_49的情况
-//                if ((DetectionCodeEnum.PV2_50.getCode().equals(harmCode) || DetectionCodeEnum.PSV_1_49.getCode().equals(harmCode)) && DetectionCodeEnum.PU1.getCode().equals(fundCode)) {
-//                    first2 = devSqlData.stream().filter(j -> DetectionCodeEnum.U1.getCode().equals(j.getDesc())).collect(Collectors.toList()).stream().findFirst();
-//                }
-//            }
 
             DevData.SqlDataDTO fund1 = null;
             DevData.SqlDataDTO fund2 = null;
@@ -2365,23 +2681,6 @@ public class DetectionServiceImpl {
             if (CollUtil.isEmpty(devHarmList) || CollUtil.isEmpty(stdDevHarmList)) {
                 return null;
             }
-//            // 如果角型接法中，不存在线电压谐波电压含有率，则取相电压谐波电压含有率进行计算
-//            if (CollUtil.isEmpty(devHarmList)) {
-//                if (DetectionCodeEnum.PV2_50.getCode().equals(harmCode)) {
-//                    devHarmList = dev.get(i).getSqlDataHarm().stream().filter(x -> DetectionCodeEnum.V2_50.getCode().equals(x.getDesc())).collect(Collectors.toList());
-//                }
-//                if (DetectionCodeEnum.PSV_1_49.getCode().equals(harmCode)) {
-//                    devHarmList = dev.get(i).getSqlDataHarm().stream().filter(x -> DetectionCodeEnum.SV_1_49.getCode().equals(x.getDesc())).collect(Collectors.toList());
-//                }
-//            }
-//            if (CollUtil.isEmpty(stdDevHarmList)) {
-//                if (DetectionCodeEnum.PV2_50.getCode().equals(harmCode)) {
-//                    stdDevHarmList = standardDev.get(i).getSqlDataHarm().stream().filter(x -> DetectionCodeEnum.V2_50.getCode().equals(x.getDesc())).collect(Collectors.toList());
-//                }
-//                if (DetectionCodeEnum.PSV_1_49.getCode().equals(harmCode)) {
-//                    stdDevHarmList = standardDev.get(i).getSqlDataHarm().stream().filter(x -> DetectionCodeEnum.SV_1_49.getCode().equals(x.getDesc())).collect(Collectors.toList());
-//                }
-//            }
 
             if (CollUtil.isNotEmpty(devHarmList) && CollUtil.isNotEmpty(stdDevHarmList)) {
                 DevData.SqlDataHarmDTO devHarm = devHarmList.get(0);
@@ -2403,38 +2702,87 @@ public class DetectionServiceImpl {
                 }
             }
         }
-        standardDevMap.forEach((typeKey, typeValue) -> {
-            typeValue.forEach((key, value) -> {
+        standardDevMap.forEach((phase, harmonicMap) -> {
+            harmonicMap.forEach((harmonicNum, value) -> {
+                List<Double> devPhaseHarmData = devMap.get(phase).get(harmonicNum);
+                if (isRemoveMaxElement) {
+                    List<Double> errorValueList = new ArrayList<>();
+                    for (int i = 0; i < value.size(); i++) {
+                        errorValueList.add(Math.abs(value.get(i) - devPhaseHarmData.get(i)));
+                    }
+
+                    List<Integer> idxErrorValueList = DetectionUtil.sort(errorValueList, false);
+                    int removeCount = idxErrorValueList.size() / 2;
+                    List<Double> newArray = DetectionUtil.getNewArray(value, idxErrorValueList.subList(removeCount, idxErrorValueList.size()));
+                    value.clear();
+                    value.addAll(newArray);
+                    newArray = DetectionUtil.getNewArray(devPhaseHarmData, idxErrorValueList.subList(removeCount, idxErrorValueList.size()));
+                    devPhaseHarmData.clear();
+                    devPhaseHarmData.addAll(newArray);
+                }
+
                 if (CollUtil.isNotEmpty(value)) {
-                    List<Integer> idx = DetectionUtil.sort(value, false);
+
                     switch (dataRule) {
-                        case SECTION_VALUE:
+                        case SECTION_VALUE: {
+                            List<Integer> idx = DetectionUtil.sort(value, false);
                             if (value.size() > 2) {
                                 value.remove(0);
                                 value.remove(value.size() - 1);
-                                List<Double> newArray = DetectionUtil.getNewArray(devMap.get(typeKey).get(key), idx.subList(1, idx.size() - 1));
-                                devMap.get(typeKey).get(key).clear();
-                                devMap.get(typeKey).get(key).addAll(newArray);
+                                List<Double> newArray = DetectionUtil.getNewArray(devPhaseHarmData, idx.subList(1, idx.size() - 1));
+                                devPhaseHarmData.clear();
+                                devPhaseHarmData.addAll(newArray);
                             }
-                            break;
+                        }
+                        break;
                         case CP95_VALUE:
                             if (CollUtil.isNotEmpty(value)) {
+                                List<Integer> idx = DetectionUtil.sort(value, false);
                                 int cp95Idx = DetectionUtil.getCP95Idx(value);
                                 List<Double> newValue = Collections.singletonList(value.get(cp95Idx));
                                 value.clear();
                                 value.addAll(newValue);
-                                Double devCP95Data = devMap.get(typeKey).get(key).get(idx.get(cp95Idx));
-                                devMap.get(typeKey).get(key).clear();
-                                devMap.get(typeKey).get(key).add(devCP95Data);
+                                Double devCP95Data = devPhaseHarmData.get(idx.get(cp95Idx));
+                                devPhaseHarmData.clear();
+                                devPhaseHarmData.add(devCP95Data);
                             }
                             break;
                         case AVG_VALUE:
                             List<Double> avgDoubles = DetectionUtil.getAvgDoubles(value);
                             value.clear();
                             value.addAll(avgDoubles);
-                            List<Double> devAvgData = DetectionUtil.getAvgDoubles(devMap.get(typeKey).get(key));
-                            devMap.get(typeKey).get(key).clear();
-                            devMap.get(typeKey).get(key).addAll(devAvgData);
+                            List<Double> devAvgData = DetectionUtil.getAvgDoubles(devMap.get(phase).get(harmonicNum));
+                            devPhaseHarmData.clear();
+                            devPhaseHarmData.addAll(devAvgData);
+                            break;
+                        case Own_value:
+                            break;
+                        case AT_WILL_VALUE:
+                            if (isRemoveMaxElement) {
+                                if (CollUtil.isNotEmpty(value)) {
+                                    Double v = value.get(value.size() - 1);
+                                    value.clear();
+                                    value.add(v);
+                                }
+                                if (CollUtil.isNotEmpty(devPhaseHarmData)) {
+                                    Double v = devPhaseHarmData.get(devPhaseHarmData.size() - 1);
+                                    devPhaseHarmData.clear();
+                                    devPhaseHarmData.add(v);
+                                }
+                            } else {
+                                List<Double> errorValueList = new ArrayList<>();
+                                for (int i = 0; i < value.size(); i++) {
+                                    errorValueList.add(Math.abs(value.get(i) - devPhaseHarmData.get(i)));
+                                }
+
+                                List<Integer> idxErrorValueList = DetectionUtil.sort(errorValueList, true);
+                                Double v = value.get(idxErrorValueList.get(0));
+                                value.clear();
+                                value.add(v);
+                                v = devPhaseHarmData.get(idxErrorValueList.get(0));
+                                devPhaseHarmData.clear();
+                                devPhaseHarmData.add(v);
+                            }
                             break;
                     }
                 }

detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java

@@ -21,6 +21,8 @@ import com.njcn.gather.detection.util.business.DetectionCommunicateUtil;
 import com.njcn.gather.detection.util.socket.CnSocketUtil;
 import com.njcn.gather.detection.util.socket.FormalTestManager;
 import com.njcn.gather.detection.util.socket.SocketManager;
+import com.njcn.gather.detection.util.socket.XiNumberManager;
+import com.njcn.gather.detection.util.socket.cilent.NettyContrastClientHandler;
 import com.njcn.gather.detection.util.socket.websocket.WebServiceManager;
 import com.njcn.gather.device.pojo.po.PqDev;
 import com.njcn.gather.device.pojo.vo.PreDetection;
@@ -38,6 +40,7 @@ import com.njcn.gather.script.service.IPqScriptCheckDataService;
 import com.njcn.gather.script.service.IPqScriptDtlsService;
 import com.njcn.gather.source.pojo.po.SourceInitialize;
 import com.njcn.gather.source.service.IPqSourceService;
+import com.njcn.gather.system.cfg.service.ISysTestConfigService;
 import com.njcn.gather.system.dictionary.pojo.enums.DictDataEnum;
 import com.njcn.gather.system.dictionary.service.IDictDataService;
 import com.njcn.web.utils.HttpServletUtil;
@@ -75,6 +78,8 @@ public class PreDetectionServiceImpl implements PreDetectionService {
     private final SocketContrastResponseService socketContrastResponseService;
     private final IPqScriptCheckDataService iPqScriptCheckDataService;
     private final SocketManager socketManager;
+    private final ISysTestConfigService sysTestConfigService;
+
 
     @Value("${report.reportDir}")
     private String alignDataFilePath;
@@ -358,6 +363,36 @@ public class PreDetectionServiceImpl implements PreDetectionService {
         }
     }
 
+    @Override
+    public boolean getCanCoefficient() {
+        return CollUtil.isNotEmpty(DetectionServiceImpl.vAndIResultMap);
+    }
+
+    @Override
+    public void startCoefficient() {
+        if (CollUtil.isNotEmpty(DetectionServiceImpl.vAndIResultMap)) {
+            // 是否进行系数校准
+            //万一录波了这里就进不来了，但是在误差处理的时候DetectionServiceImpl.vAndIResultMap该集合会保留不符合的结果
+
+            XiNumberManager.xiDevList.clear();
+            XiNumberManager.devXiNumDataMap.clear();
+            List<String> stdIpList = DetectionServiceImpl.vAndIResultMap.values().stream().map(DetectionServiceImpl.VAndIResult::getIp).collect(Collectors.toList());
+            XiNumberManager.xiDevList = FormalTestManager.standardDevList.stream().filter(d -> stdIpList.contains(d.getDevIP())).collect(Collectors.toList());
+            // 逐一设备向通讯模块要原始系数
+            SocketMsg<String> socketMsg = new SocketMsg<>();
+            socketMsg.setRequestId(SourceOperateCodeEnum.Coefficient_Check.getValue());
+            socketMsg.setOperateCode(SourceOperateCodeEnum.DATA_CHNFACTOR$01.getValue());
+            PreDetection preDetection = XiNumberManager.xiDevList.get(0);
+            Map<String, Object> map = new HashMap<>();
+            map.put("devIP", preDetection.getDevIP());
+            map.put("chnNum", preDetection.getDevChns());
+            socketMsg.setData(JSON.toJSONString(map));
+            SocketManager.sendMsg(NettyContrastClientHandler.param.getUserPageId() + CnSocketUtil.CONTRAST_DEV_TAG, JSON.toJSONString(socketMsg));
+
+            FormalTestManager.currentStep = SourceOperateCodeEnum.Coefficient_Check;
+        }
+    }
+
     /**
      * 比对式-与通信模块进行连接
      *

detection/src/main/java/com/njcn/gather/detection/util/DetectionUtil.java

@@ -1,6 +1,7 @@
 package com.njcn.gather.detection.util;
 
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.NumberUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.njcn.gather.detection.pojo.po.DevData;
 import lombok.extern.slf4j.Slf4j;
@@ -421,7 +422,7 @@ public class DetectionUtil {
             }
             return newList;
         }
-        return null;
+        return Collections.emptyList();
     }
 
     /**
@@ -437,4 +438,94 @@ public class DetectionUtil {
             System.out.println("  文件大小: " + file.length() + " bytes");
         }
     }
+
+    /**
+     * 获取皮尔逊系数
+     *
+     * <p>相关系数绝对值|r|所代表的相关强度</p>
+     * <ul>
+     *     <li>0.8 - 1.0：极强相关</li>
+     *     <li>0.6 - 0.8：强相关</li>
+     *     <li>0.4 - 0.6：中等程度相关</li>
+     *     <li>0.2 - 0.4：弱相关</li>
+     *     <li>0.0 - 0.2：极弱相关或无相关</li>
+     * </ul>
+     *
+     * @return
+     */
+    public static BigDecimal getPearsonCorrelationCoefficient(List<Double> x, List<Double> y) {
+        Double xAvg = x.parallelStream().mapToDouble(Double::doubleValue).average().orElse(0.0);
+        Double yAvg = y.parallelStream().mapToDouble(Double::doubleValue).average().orElse(0.0);
+
+        // 协方差求和
+        BigDecimal covarianceSum = BigDecimal.ZERO;
+        // x的方差
+        BigDecimal varianceX = BigDecimal.ZERO;
+        // y的方差
+        BigDecimal varianceY = BigDecimal.ZERO;
+        for (int i = 0; i < x.size(); i++) {
+            covarianceSum = covarianceSum.add(BigDecimal.valueOf((x.get(i) - xAvg) * (y.get(i) - yAvg)));
+            varianceX = varianceX.add(BigDecimal.valueOf(Math.pow(x.get(i) - xAvg, 2)));
+            varianceY = varianceY.add(BigDecimal.valueOf(Math.pow(y.get(i) - yAvg, 2)));
+        }
+        BigDecimal fm = BigDecimal.valueOf(Math.sqrt(varianceX.doubleValue()) * Math.sqrt(varianceY.doubleValue()));
+        if (NumberUtil.equals(fm.doubleValue(), BigDecimal.ZERO.doubleValue())) {
+            if (NumberUtil.equals(covarianceSum, BigDecimal.ZERO)) {
+                return BigDecimal.valueOf(1.0);
+            } else {
+                return BigDecimal.ZERO;
+            }
+        } else {
+            return BigDecimal.valueOf(Math.abs(covarianceSum.divide(fm, 8, BigDecimal.ROUND_HALF_UP).doubleValue())); //相关系数
+        }
+    }
+
+    /**
+     * 比值一致性，获取CV系数
+     *
+     * <p>一致性等级</p>
+     * <ul>
+     *     <li>CV<1%：非常优秀</li>
+     *     <li>1%≤CV＜5%：优良</li>
+     *     <li>5%≤CV＜10%：良好</li>
+     *     <li>10%≤CV＜20%：中等</li>
+     *     <li>20%≤CV：较差</li>
+     * </ul>
+     *
+     * @param x
+     * @param y
+     * @return
+     */
+    public static BigDecimal getCvCoefficient(List<Double> x, List<Double> y) {
+        List<BigDecimal> ratioList = new ArrayList<>();
+        for (int i = 0; i < x.size(); i++) {
+            ratioList.add(BigDecimal.valueOf(x.get(i) / y.get(i)));
+        }
+
+        BigDecimal avg = BigDecimal.valueOf(ratioList.parallelStream().mapToDouble(BigDecimal::doubleValue).average().orElse(0.0));
+        BigDecimal variance = BigDecimal.valueOf(
+                ratioList.parallelStream().mapToDouble(BigDecimal::doubleValue)
+                        .map(v -> Math.pow(v - avg.doubleValue(), 2)).average().orElse(0.0));
+
+        return BigDecimal.valueOf(Math.sqrt(variance.doubleValue()) / avg.doubleValue());
+    }
+
+    /**
+     * 计算新的系数
+     *
+     * @param devList
+     * @param stdDevList
+     * @return
+     */
+    public static Double getNewXi(List<Double> devList, List<Double> stdDevList) {
+        ArrayList<Double> xiList = new ArrayList<>();
+        for (int i = 0; i < stdDevList.size(); i++) {
+            if (!stdDevList.get(i).equals(0)) {
+                BigDecimal bigDecimalDev = BigDecimal.valueOf(devList.get(i));
+                BigDecimal bigDecimalStdDev = BigDecimal.valueOf(stdDevList.get(i));
+                xiList.add((bigDecimalDev.subtract(bigDecimalStdDev)).divide(BigDecimal.valueOf(2.0).multiply(bigDecimalDev), 8, BigDecimal.ROUND_HALF_UP).doubleValue() + 1.0);
+            }
+        }
+        return xiList.stream().mapToDouble(Double::doubleValue).average().orElse(1.0);
+    }
 }

detection/src/main/java/com/njcn/gather/device/controller/PqStandardDevController.java

@@ -12,6 +12,7 @@ import com.njcn.common.pojo.response.HttpResult;
 import com.njcn.common.utils.LogUtil;
 import com.njcn.gather.device.pojo.param.PqStandardDevParam;
 import com.njcn.gather.device.pojo.po.PqStandardDev;
+import com.njcn.gather.device.pojo.vo.PqStandardDevVO;
 import com.njcn.gather.device.service.IPqStandardDevService;
 import com.njcn.web.controller.BaseController;
 import com.njcn.web.utils.FileUtil;
@@ -55,10 +56,10 @@ public class PqStandardDevController extends BaseController {
     @GetMapping("/getById")
     @ApiOperation("根据id查询标准设备")
     @ApiImplicitParam(name = "id", value = "标准设备id", required = true)
-    public HttpResult<PqStandardDev> getById(@RequestParam("id") String id) {
+    public HttpResult<PqStandardDevVO> getById(@RequestParam("id") String id) {
         String methodDescribe = getMethodDescribe("getById");
         LogUtil.njcnDebug(log, "{}，查询ID为：{}", methodDescribe, id);
-        PqStandardDev result = pqStandardDevService.getPqStandardDevById(id);
+        PqStandardDevVO result = pqStandardDevService.getPqStandardDevById(id);
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
     }
 

detection/src/main/java/com/njcn/gather/device/mapper/PqStandardDevGainMapper.java

@@ -0,0 +1,13 @@
+package com.njcn.gather.device.mapper;
+
+import com.github.yulichang.base.MPJBaseMapper;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
+
+/**
+ * @author caozehui
+ * @date 2026-01-12
+ */
+public interface PqStandardDevGainMapper extends MPJBaseMapper<PqStandardDevGain> {
+
+}
+

detection/src/main/java/com/njcn/gather/device/mapper/PqStandardDevGainRecordMapper.java

@@ -0,0 +1,13 @@
+package com.njcn.gather.device.mapper;
+
+import com.github.yulichang.base.MPJBaseMapper;
+import com.njcn.gather.device.pojo.po.PqStandardDevGainRecord;
+
+/**
+ * @author caozehui
+ * @date 2026-01-15
+ */
+public interface PqStandardDevGainRecordMapper extends MPJBaseMapper<PqStandardDevGainRecord> {
+
+}
+

detection/src/main/java/com/njcn/gather/device/mapper/mapping/PqStandardDevGainMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.gather.device.mapper.PqStandardDevGainMapper">
+
+
+</mapper>
+

detection/src/main/java/com/njcn/gather/device/mapper/mapping/PqStandardDevGainRecordMapper.xml

@@ -0,0 +1,7 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.njcn.gather.device.mapper.PqStandardDevGainRecordMapper">
+
+
+</mapper>
+

detection/src/main/java/com/njcn/gather/device/pojo/po/PqStandardDevGain.java

@@ -0,0 +1,61 @@
+package com.njcn.gather.device.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.mybatisplus.bo.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * @author caozehui
+ * @date 2026-01-12
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+@TableName("pq_standard_dev_gain")
+public class PqStandardDevGain extends BaseEntity implements Serializable {
+    private static final long serialVersionUID = -46280767885558804L;
+
+
+    /**
+     * 标准设备Id_通道号
+     */
+    @TableId
+    private String stdDevMonitorId;
+
+    private Integer uaGain;
+
+    private Integer ubGain;
+
+
+    private Integer ucGain;
+
+
+    private Integer u0Gain;
+
+
+    private Integer iaGain;
+
+
+    private Integer ibGain;
+
+
+    private Integer icGain;
+
+
+    private Integer i0Gain;
+
+
+    private Integer uabGain;
+
+
+    private Integer ubcGain;
+
+
+    private Integer ucaGain;
+
+    private Integer state;
+}
+

detection/src/main/java/com/njcn/gather/device/pojo/po/PqStandardDevGainRecord.java

@@ -0,0 +1,35 @@
+package com.njcn.gather.device.pojo.po;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.njcn.db.mybatisplus.bo.BaseEntity;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * @author caozehui
+ * @date 2026-01-15
+ */
+@Data
+@TableName("pq_standard_dev_gain_record")
+public class PqStandardDevGainRecord implements Serializable {
+    private static final long serialVersionUID = 477276215572686991L;
+
+    /**
+     * 标准设备监测点id,由设备id_通道号组成
+     */
+    private String stdDevMonitorId;
+
+    /**
+     * 被检设备监测点id,由设备id_通道号组成
+     */
+    private String devMonitorId;
+
+    /**
+     * 系数下发次数
+     */
+    private Integer num;
+
+}
+

detection/src/main/java/com/njcn/gather/device/pojo/vo/PqStandardDevVO.java

@@ -0,0 +1,20 @@
+package com.njcn.gather.device.pojo.vo;
+
+import com.njcn.gather.device.pojo.po.PqStandardDev;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @data 2026-01-19
+ */
+@Data
+public class PqStandardDevVO extends PqStandardDev {
+
+    /**
+     * 通道系数
+     */
+    List<PqStandardDevGain> gainList;
+}

detection/src/main/java/com/njcn/gather/device/service/IPqStandardDevGainRecordService.java

@@ -0,0 +1,29 @@
+package com.njcn.gather.device.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.gather.device.pojo.po.PqStandardDevGainRecord;
+
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @date 2026-01-15
+ */
+public interface IPqStandardDevGainRecordService extends IService<PqStandardDevGainRecord> {
+
+    /**
+     * 获取最大下发系数的次数
+     *
+     * @param stdDevMonitorId
+     * @param devMonitorId
+     * @return
+     */
+    int getMaxNum(String stdDevMonitorId, String devMonitorId);
+
+    /**
+     * 批量新增或更新记录
+     * @param recordList
+     * @return
+     */
+    boolean addOrUpdate(List<PqStandardDevGainRecord> recordList);
+}

detection/src/main/java/com/njcn/gather/device/service/IPqStandardDevGainService.java

@@ -0,0 +1,19 @@
+package com.njcn.gather.device.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
+
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @date 2026-01-12
+ */
+public interface IPqStandardDevGainService extends IService<PqStandardDevGain> {
+
+    boolean add(List<PqStandardDevGain> pqStandardDevGainList);
+
+    PqStandardDevGain get(String stdDevMonitorId);
+
+    List<PqStandardDevGain> list(String stdDevId);
+}

detection/src/main/java/com/njcn/gather/device/service/IPqStandardDevService.java

@@ -4,6 +4,7 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.IService;
 import com.njcn.gather.device.pojo.param.PqStandardDevParam;
 import com.njcn.gather.device.pojo.po.PqStandardDev;
+import com.njcn.gather.device.pojo.vo.PqStandardDevVO;
 import com.njcn.gather.device.pojo.vo.PreDetection;
 import org.springframework.web.multipart.MultipartFile;
 
@@ -30,7 +31,7 @@ public interface IPqStandardDevService extends IService<PqStandardDev> {
      * @param id 设备id
      * @return 设备对象
      */
-    PqStandardDev getPqStandardDevById(String id);
+    PqStandardDevVO getPqStandardDevById(String id);
 
     /**
      * 新增标准设备

detection/src/main/java/com/njcn/gather/device/service/impl/PqStandardDevGainRecordServiceImpl.java

@@ -0,0 +1,45 @@
+package com.njcn.gather.device.service.impl;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.gather.device.mapper.PqStandardDevGainRecordMapper;
+import com.njcn.gather.device.pojo.po.PqStandardDevGainRecord;
+import com.njcn.gather.device.service.IPqStandardDevGainRecordService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @author caozehui
+ * @date 2026-01-15
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class PqStandardDevGainRecordServiceImpl extends ServiceImpl<PqStandardDevGainRecordMapper, PqStandardDevGainRecord> implements IPqStandardDevGainRecordService {
+
+    @Override
+    public int getMaxNum(String stdDevMonitorId, String devMonitorId) {
+        return this.lambdaQuery().eq(PqStandardDevGainRecord::getStdDevMonitorId, stdDevMonitorId)
+                .eq(PqStandardDevGainRecord::getDevMonitorId, devMonitorId)
+                .list().stream().mapToInt(PqStandardDevGainRecord::getNum).max().orElse(0);
+    }
+
+    @Override
+    public boolean addOrUpdate(List<PqStandardDevGainRecord> recordList) {
+        recordList.forEach(record -> {
+            List<PqStandardDevGainRecord> list = this.lambdaQuery().eq(PqStandardDevGainRecord::getStdDevMonitorId, record.getStdDevMonitorId())
+                    .eq(PqStandardDevGainRecord::getDevMonitorId, record.getDevMonitorId()).list();
+            if (CollectionUtil.isNotEmpty(list)) {
+                this.lambdaUpdate().eq(PqStandardDevGainRecord::getStdDevMonitorId, record.getStdDevMonitorId())
+                        .eq(PqStandardDevGainRecord::getDevMonitorId, record.getDevMonitorId())
+                        .set(PqStandardDevGainRecord::getNum, record.getNum()).update();
+            } else {
+                this.save(record);
+            }
+        });
+        return true;
+    }
+}

detection/src/main/java/com/njcn/gather/device/service/impl/PqStandardDevGainServiceImpl.java

@@ -0,0 +1,42 @@
+package com.njcn.gather.device.service.impl;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.njcn.gather.device.mapper.PqStandardDevGainMapper;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
+import com.njcn.gather.device.service.IPqStandardDevGainService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+/**
+ * @author caozehui
+ * @date 2026-01-12
+ */
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class PqStandardDevGainServiceImpl extends ServiceImpl<PqStandardDevGainMapper, PqStandardDevGain> implements IPqStandardDevGainService {
+
+    @Override
+    public boolean add(List<PqStandardDevGain> pqStandardDevGainList) {
+        log.info("add PqStandardDevGainList: {}", pqStandardDevGainList.size());
+        List<String> stdMonitorIdList = pqStandardDevGainList.stream().map(PqStandardDevGain::getStdDevMonitorId).distinct().collect(Collectors.toList());
+        List<String> existingStdMonitorIdList = this.listByIds(stdMonitorIdList).stream().map(PqStandardDevGain::getStdDevMonitorId).collect(Collectors.toList());
+
+        pqStandardDevGainList = pqStandardDevGainList.stream().filter(pqStandardDevGain -> !existingStdMonitorIdList.contains(pqStandardDevGain.getStdDevMonitorId())).collect(Collectors.toList());
+        return this.saveBatch(pqStandardDevGainList);
+    }
+
+    @Override
+    public PqStandardDevGain get(String stdDevMonitorId) {
+        return this.lambdaQuery().eq(PqStandardDevGain::getStdDevMonitorId, stdDevMonitorId).one();
+    }
+
+    @Override
+    public List<PqStandardDevGain> list(String stdDevId) {
+        return this.lambdaQuery().likeRight(PqStandardDevGain::getStdDevMonitorId, stdDevId).orderByAsc(PqStandardDevGain::getStdDevMonitorId).list();
+    }
+}

detection/src/main/java/com/njcn/gather/device/service/impl/PqStandardDevServiceImpl.java

@@ -19,8 +19,11 @@ import com.njcn.common.utils.EncryptionUtil;
 import com.njcn.gather.device.mapper.PqStandardDevMapper;
 import com.njcn.gather.device.pojo.param.PqStandardDevParam;
 import com.njcn.gather.device.pojo.po.PqStandardDev;
+import com.njcn.gather.device.pojo.po.PqStandardDevGain;
 import com.njcn.gather.device.pojo.vo.PqStandardDevExcel;
+import com.njcn.gather.device.pojo.vo.PqStandardDevVO;
 import com.njcn.gather.device.pojo.vo.PreDetection;
+import com.njcn.gather.device.service.IPqStandardDevGainService;
 import com.njcn.gather.device.service.IPqStandardDevService;
 import com.njcn.gather.plan.mapper.AdPlanStandardDevMapper;
 import com.njcn.gather.plan.service.IAdPlanStandardDevService;
@@ -58,8 +61,7 @@ public class PqStandardDevServiceImpl extends ServiceImpl<PqStandardDevMapper, P
     private final IDevTypeService devTypeService;
     private final IDictDataService dictDataService;
     private final IDictTypeService dictTypeService;
-    private final AdPlanStandardDevMapper adPlanStandardDevMapper;
-    private final IAdPlanStandardDevService adPlanStandardDevService;
+    private final IPqStandardDevGainService pqStandardDevGainService;
 
     @Override
     public Page<PqStandardDev> listPqStandardDevs(PqStandardDevParam.QueryParam queryParam) {
@@ -73,13 +75,17 @@ public class PqStandardDevServiceImpl extends ServiceImpl<PqStandardDevMapper, P
     }
 
     @Override
-    public PqStandardDev getPqStandardDevById(String id) {
+    public PqStandardDevVO getPqStandardDevById(String id) {
         PqStandardDev standardDev = this.getById(id);
+        PqStandardDevVO pqStandardDevVO = BeanUtil.copyProperties(standardDev, PqStandardDevVO.class);
         if (standardDev.getEncryptionFlag() == 1) {
-            standardDev.setSeries(EncryptionUtil.decoderString(1, standardDev.getSeries()));
-            standardDev.setDevKey(EncryptionUtil.decoderString(1, standardDev.getDevKey()));
+            pqStandardDevVO.setSeries(EncryptionUtil.decoderString(1, standardDev.getSeries()));
+            pqStandardDevVO.setDevKey(EncryptionUtil.decoderString(1, standardDev.getDevKey()));
         }
-        return standardDev;
+
+        List<PqStandardDevGain> gainList = pqStandardDevGainService.list(id);
+        pqStandardDevVO.setGainList(gainList);
+        return pqStandardDevVO;
     }
 
     @Override

detection/src/main/java/com/njcn/gather/monitor/service/IPqMonitorService.java

@@ -121,8 +121,8 @@ public interface IPqMonitorService extends IService<PqMonitor> {
 
     /**
      * 根据被检设备id和监测点编号获取监测点信息
-     * @param id 被检设备id
+     * @param devId 设备id
      * @param monitorNum 监测点编号
      */
-    PqMonitor getByDevAndNum(String id, int monitorNum);
+    PqMonitor getByDevIdAndNum(String devId, int monitorNum);
 }

detection/src/main/java/com/njcn/gather/monitor/service/impl/PqMonitorServiceImpl.java

@@ -84,6 +84,7 @@ public class PqMonitorServiceImpl extends ServiceImpl<PqMonitorMapper, PqMonitor
             if (ObjectUtil.isNotNull(pqMonitor)) {
                 BeanUtil.copyProperties(monitorList.get(0), pqMonitor, "id", "realtimeResult", "statisticsResult", "recordedResult", "realtimeNum", "statisticsNum", "recordedNum", "resultType", "qualifiedNum");
                 newMonitorList.add(pqMonitor);
+                existedMonitorList.remove(pqMonitor);
             } else {
                 newMonitorList.addAll(monitorList);
             }
@@ -168,6 +169,7 @@ public class PqMonitorServiceImpl extends ServiceImpl<PqMonitorMapper, PqMonitor
                 this.baseMapper.updatePlanReportRState(plan.getId(), PlanReportStateEnum.REPORT_STATE_NOT_GENERATED.getValue());
             }
         }
+        this.removeByIds(existedMonitorList.stream().map(PqMonitor::getId).collect(Collectors.toList()));
         return this.saveOrUpdateBatch(newMonitorList);
     }
 
@@ -438,7 +440,7 @@ public class PqMonitorServiceImpl extends ServiceImpl<PqMonitorMapper, PqMonitor
     }
 
     @Override
-    public PqMonitor getByDevAndNum(String devId, int monitorNum) {
+    public PqMonitor getByDevIdAndNum(String devId, int monitorNum) {
         QueryWrapper<PqMonitor> wrapper = new QueryWrapper<>();
         wrapper.eq("pq_monitor.Dev_Id", devId)
                 .eq("pq_monitor.Num", monitorNum);

detection/src/main/java/com/njcn/gather/report/service/impl/PqReportServiceImpl.java

@@ -1173,7 +1173,7 @@ public class PqReportServiceImpl extends ServiceImpl<PqReportMapper, PqReport> i
             Integer monitorNum = next.getKey();
             // 线路下的指标数据
             List<ContrastTestResult> contrastTestResults = next.getValue();
-            PqMonitor pqMonitor = pqMonitorService.getByDevAndNum(pqDevVO.getId(), monitorNum);
+            PqMonitor pqMonitor = pqMonitorService.getByDevIdAndNum(pqDevVO.getId(), monitorNum);
             // 插入回路号前，先换个页
             todoInsertList.add(Docx4jUtil.createPageBreakParagraph());
             // 回路标题
@@ -2063,7 +2063,7 @@ public class PqReportServiceImpl extends ServiceImpl<PqReportMapper, PqReport> i
         // 委托方
         String delegate = pqDevVO.getDelegate();
         if (StrUtil.isNotBlank(delegate)) {
-            DictData delegateDictData = dictDataService.getDictDataById(pqDevVO.getManufacturer());
+            DictData delegateDictData = dictDataService.getDictDataById(pqDevVO.getDelegate());
             if (ObjectUtil.isNotNull(delegateDictData)) {
                 baseModelMap.put(BaseReportKeyEnum.DELEGATE.getKey(), delegateDictData.getName());
             } else {
@@ -2503,7 +2503,7 @@ public class PqReportServiceImpl extends ServiceImpl<PqReportMapper, PqReport> i
      * 创建回路标题到报告中
      */
     private P getContrastLineTitle(Map<String, List<Docx4jUtil.HeadingContent>> contentMap, int monitorNum, int index, ObjectFactory factory, PqDevVO pqDevVO) {
-        PqMonitor pqMonitor = pqMonitorService.getByDevAndNum(pqDevVO.getId(), monitorNum);
+        PqMonitor pqMonitor = pqMonitorService.getByDevIdAndNum(pqDevVO.getId(), monitorNum);
         String monitorInfoName = "";
         if (StrUtil.isNotBlank(pqDevVO.getSubName()) && Objects.nonNull(pqMonitor)) {
             monitorInfoName = "(" + pqDevVO.getSubName() + "-" + pqMonitor.getName() + ")";

detection/src/main/java/com/njcn/gather/result/controller/ResultController.java

@@ -198,7 +198,7 @@ public class ResultController extends BaseController {
         String methodDescribe = getMethodDescribe("getCheckItem");
 
         LogUtil.njcnDebug(log, "{}，查询数据为：{}", methodDescribe, monitorQueryParam);
-        List<ContrastTestItemVO> result = resultService.getCheckItem(monitorQueryParam.getPlanId(), monitorQueryParam.getDevId(), monitorQueryParam.getChnNum(), monitorQueryParam.getNum());
+        List<ContrastTestItemVO> result = resultService.getCheckItem(monitorQueryParam.getPlanId(), monitorQueryParam.getDevId(), monitorQueryParam.getChnNum(), monitorQueryParam.getNum(), monitorQueryParam.getCode());
         return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, result, methodDescribe);
     }
 }

detection/src/main/java/com/njcn/gather/result/pojo/param/MonitorQueryParam.java

@@ -17,4 +17,6 @@ public class MonitorQueryParam {
     private Integer waveNum;
 
     private String planId;
+
+    private String code;
 }

detection/src/main/java/com/njcn/gather/result/service/IResultService.java

@@ -123,9 +123,10 @@ public interface IResultService {
      * @param devId
      * @param chnNum
      * @param num
+     * @param code
      * @return
      */
-    List<ContrastTestItemVO> getCheckItem(String planId, String devId, String chnNum, Integer num);
+    List<ContrastTestItemVO> getCheckItem(String planId, String devId, String chnNum, Integer num,String code);
 
     /**
      * 获取设备比对式结果，用于出比对检测的报告

detection/src/main/java/com/njcn/gather/result/service/impl/ResultServiceImpl.java

@@ -341,10 +341,19 @@ public class ResultServiceImpl implements IResultService {
     private void dipScriptTypeName(List<PqScriptDtls> subValue, List<TreeDataVO> subTypeList, Map<Integer, Set<Integer>> finalResultMap, Boolean isValueType, String name, Integer start, Integer end) {
         List<TreeDataVO> info = new ArrayList<>();
         List<PqScriptDtls> dip = subValue.stream()
-                .filter(x -> "Dip".equals(x.getValueType()) && "A".equals(x.getPhase()))
+//                .filter(x -> "Dip".equals(x.getValueType()) && "A".equals(x.getPhase()))
+                .filter(x -> "Dip".equals(x.getValueType()))
                 .filter(x -> x.getTransValue() >= start && x.getTransValue() <= end)
                 .sorted(Comparator.comparing(PqScriptDtls::getScriptIndex))
                 .collect(Collectors.toList());
+        LinkedHashMap<Integer, List<PqScriptDtls>> idxDipMap = dip.stream().collect(Collectors.groupingBy(d -> d.getScriptIndex(), LinkedHashMap::new, Collectors.toList()));
+
+        dip.clear();
+        idxDipMap.forEach((idx, scriptDtlList) -> {
+            scriptDtlList.sort(Comparator.comparing(PqScriptDtls::getPhase));
+            dip.add(scriptDtlList.get(0));
+        });
+
         TreeDataVO vo = new TreeDataVO();
         vo.setScriptTypeName(name);
         vo.setScriptTypeCode("Base_" + start + "_" + end);
@@ -1883,10 +1892,10 @@ public class ResultServiceImpl implements IResultService {
     }
 
     @Override
-    public List<ContrastTestItemVO> getCheckItem(String planId, String devId, String chnNum, Integer num) {
+    public List<ContrastTestItemVO> getCheckItem(String planId, String devId, String chnNum, Integer num, String code) {
 //        PqDev dev = pqDevService.getById(devId);
         AdPlan plan = adPlanService.getById(planId);
-        String code = String.valueOf(plan.getCode());
+//        String code = String.valueOf(plan.getCode());
 
         String monitorId = devId + CnSocketUtil.SPLIT_TAG + chnNum;
 

entrance/src/main/resources/application.yml

@@ -36,9 +36,9 @@ mybatis-plus:
     #驼峰命名
     map-underscore-to-camel-case: true
     #配置sql日志输出
-    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
+    # log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
     #关闭日志输出
-  #    log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl
+    log-impl: org.apache.ibatis.logging.nologging.NoLoggingImpl
   global-config:
     db-config:
       #指定主键生成策略
@@ -122,4 +122,4 @@ power-quality:
 # 激活配置
 activate:
   private-key: "MIIEvQIBADANBgkqhkiG9w0BAQEFAASCBKcwggSjAgEAAoIBAQCcUyYhVqczGxblL+o/xZzF/8nf+LjrfUE/dS1aRHM7uMDD0cgCArhjtfneFePrMxt+Z7W8yNBzSarub8qsfhaVNikV7Es7oaeTygfjQXTi2n4AFkir3fM07J08RpWhl5M8f8uWTCuvFUYAw00gq55typqmnbkmJa2VIUy/iQf+cMCP7abz4/jNhUzUR3qA7TV4oMRgTdIEDUp63YF8dOC+JH8XxYrCVeHXV6fLCwmesdMzl0lB2VTEKMfLbXhOmF5g7P9y/16VCcN8UBuZlbyYfn+GAxJOSbeHi5HshOKfoSuD7Jz+3WQZpNavOWjIFExKIU38/CvnJCOP7XBCqpSTAgMBAAECggEAYeWokWRE3TpvwiOZnUpR/aVMdVi75a3ROL5XIpqPV61B+t/bU3cEpl0GF9C5pUeiRi0IoStZb3mI9D1KPW/REKyUWkhabQO1gFYbTnRlkNOn6MILzKX4cwJjDaZeeo4EBPU7N+qHyOOXrU6hdH5FfxhMdV983ajm5eeuupxER1C2kAcIklTeVpTX6EKOgZb5LBp5ssOVm2P42pOauvcRozRcvZmqnErXmukv0H4l3EVNt4rHpTn9riHUC63e8JfiYzVaF6zuNUxv6nHEft0/SRMw11XSTnNfDzcKqgjz6ksFBS/6eQQYKESk+ONC53HUuYHFAknkwsPupDCT2W8FIQKBgQDLHT/xCU3nxGr4vFKBDNaO2D5oK20ECbBO4oDvLWWmQG7f+6TsMy8PgVdMnoL4RfqGlwFAKEpS6KVFHnBVqnNEhcdy9uCI7x7Xx8UnyUtxj1EDTm76uta9Ki9OrlqB6tImDM9+Ya3vGktW37ht4WOx2OsJRhG1dbf6RLwFlH7DWwKBgQDFBxvi5I1BR6hg6Tj7xd2SqOT2Y+BED3xuSYENhWbmMhLJDResaB7mjztbxlYaY2mOE0holWm2uDmVFFhMh4jYXik4hYH8nmDzq9mDpZCZ9pyjYqnAP8THoAa8EbgrUWB8A6BPH4iL3KbMnBfBKY0pIr2xrvnjQjNBAgta7KDRKQKBgCe6oe4wxrdF2TKsC2tIqpMoQxS3Icy/ZGgZr+SYuaBKTCWtoDW/UT40K3JGMxIDBhzbXphBCUCsVt9tM8Xd4EwP6tJW7dZ7B0pnve2pVwNwaAVAiz6p2yUHIle+jN+Koe5lZRSwYIg7WW81tWpwwsJfzqFyvjYDP6hJV4mz4ROvAoGAaRcdnKvjXApomShMqJ4lTPChD3q+SA8qg3jZSOj6tZXHx00gb2kp8jg7pPvpOTIFPy6x1Ha9aCRjMk0ju84fA6lVuzwa1S907wOehUVuF3Eeo1cgy9Y3k3KbpPyeixxgpkUY4JslLdSHc2NemD0dee951qhJyRmqVOZOQDUuoeECgYEAqBw2cAFk3vM97WY06TSldGA8ajVHx3BYRjj+zl62NTQthy8fw3tqxb3c5e8toOmZWKjZvDhg2TRLhsDDQWEYg3LZG87REqVIjgEPcpjNLidjygGX8n3JF2o0O5I/EMvl0s/+LVQONfduOBvhwDqr8QNisbLsyneiAq7umewMolo="
-  public-key: "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAnFMmIVanMxsW5S/qP8Wcxf/J3/i4631BP3UtWkRzO7jAw9HIAgK4Y7X53hXj6zMbfme1vMjQc0mq7m/KrH4WlTYpFexLO6Gnk8oH40F04tp+ABZIq93zNOydPEaVoZeTPH/LlkwrrxVGAMNNIKuebcqapp25JiWtlSFMv4kH/nDAj+2m8+P4zYVM1Ed6gO01eKDEYE3SBA1Ket2BfHTgviR/F8WKwlXh11enywsJnrHTM5dJQdlUxCjHy214TpheYOz/cv9elQnDfFAbmZW8mH5/hgMSTkm3h4uR7ITin6Erg+yc/t1kGaTWrzloyBRMSiFN/Pwr5yQjj+1wQqqUkwIDAQAB"
+  public-key: "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAnFMmIVanMxsW5S/qP8Wcxf/J3/i4631BP3UtWkRzO7jAw9HIAgK4Y7X53hXj6zMbfme1vMjQc0mq7m/KrH4WlTYpFexLO6Gnk8oH40F04tp+ABZIq93zNOydPEaVoZeTPH/LlkwrrxVGAMNNIKuebcqapp25JiWtlSFMv4kH/nDAj+2m8+P4zYVM1Ed6gO01eKDEYE3SBA1Ket2BfHTgviR/F8WKwlXh11enywsJnrHTM5dJQdlUxCjHy214TpheYOz/cv9elQnDfFAbmZW8mH5/hgMSTkm3h4uR7ITin6Erg+yc/t1kGaTWrzloyBRMSiFN/Pwr5yQjj+1wQqqUkwIDAQAB"

system/src/main/java/com/njcn/gather/system/cfg/pojo/param/SysTestConfigParam.java

@@ -28,6 +28,9 @@ public class SysTestConfigParam {
     @ApiModelProperty(value = "场景")
     private String scene;
 
+    @ApiModelProperty(value = "比对监测后，当电压、电流不符合时，是否对标准设备进行系数校准")
+    private Integer coefficient;
+
     @Data
     public static class UpdateParam extends SysTestConfigParam {
         @ApiModelProperty("id")

system/src/main/java/com/njcn/gather/system/cfg/pojo/po/SysTestConfig.java

@@ -51,6 +51,11 @@ public class SysTestConfig extends BaseEntity implements Serializable {
      */
     private Integer scale;
 
+    /**
+     * 比对监测后，当电压、电流不符合时，是否对标准设备进行系数校准
+     */
+    private Integer coefficient;
+
 
     /**
      * 状态：0-删除 1-正常

system/src/main/java/com/njcn/gather/system/cfg/service/impl/SysTestConfigServiceImpl.java

@@ -49,6 +49,7 @@ public class SysTestConfigServiceImpl extends ServiceImpl<SysTestConfigMapper, S
         oneConfig.setScale(ObjectUtil.isNotNull(param.getScale()) ? param.getScale() : oneConfig.getScale());
         oneConfig.setMaxTime(ObjectUtil.isNotNull(param.getMaxTime()) ? param.getMaxTime() : oneConfig.getMaxTime());
         oneConfig.setScene(StringUtils.isNotBlank(param.getScene()) ? param.getScene() : oneConfig.getScene());
+        oneConfig.setCoefficient(param.getCoefficient());
         return this.updateById(oneConfig);
     }