diff --git a/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java b/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java index 56e73009..4f9f8f3e 100644 --- a/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java @@ -273,14 +273,14 @@ public class PreDetectionServiceImpl implements PreDetectionService { @Override public void sendScript(SimulateDetectionParam param) { Channel channel = SocketManager.getChannelByUserId(param.getUserPageId() + DetectionCommunicateConstant.SOURCE); -// if (Objects.isNull(channel) || !channel.isActive()) { -// // 进行源通信连接 -// PreDetectionParam preDetectionParam = new PreDetectionParam(); -// preDetectionParam.setSourceId(param.getSourceId()); -// preDetectionParam.setUserPageId(param.getUserPageId()); -// preDetectionParam.setSendWebMsg(false); -// this.sendYtxSocketSimulate(preDetectionParam); -// } + if (Objects.isNull(channel) || !channel.isActive()) { + // 进行源通信连接 + PreDetectionParam preDetectionParam = new PreDetectionParam(); + preDetectionParam.setSourceId(param.getSourceId()); + preDetectionParam.setUserPageId(param.getUserPageId()); + preDetectionParam.setSendWebMsg(false); + this.sendYtxSocketSimulate(preDetectionParam); + } //组装源控制脚本 PqScriptIssueParam issueParam = new PqScriptIssueParam(); issueParam.setSourceId(param.getSourceId()); diff --git a/detection/src/main/java/com/njcn/gather/monitor/mapper/mapping/PqMonitorMapper.xml b/detection/src/main/java/com/njcn/gather/monitor/mapper/mapping/PqMonitorMapper.xml index bd5289cd..eb0ea731 100644 --- a/detection/src/main/java/com/njcn/gather/monitor/mapper/mapping/PqMonitorMapper.xml +++ b/detection/src/main/java/com/njcn/gather/monitor/mapper/mapping/PqMonitorMapper.xml @@ -39,6 +39,7 @@ #{devId} + order by Num diff --git a/detection/src/main/java/com/njcn/gather/script/service/impl/PqScriptDtlsServiceImpl.java b/detection/src/main/java/com/njcn/gather/script/service/impl/PqScriptDtlsServiceImpl.java index e37a2bb5..4c2453ca 100644 --- a/detection/src/main/java/com/njcn/gather/script/service/impl/PqScriptDtlsServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/script/service/impl/PqScriptDtlsServiceImpl.java @@ -628,9 +628,9 @@ public class PqScriptDtlsServiceImpl extends ServiceImpl contrastNonHarmonicResultList = BeanUtil.copyToList(nonHarmonicResultList, ContrastNonHarmonicResult.class); - List monitorIds = contrastNonHarmonicResultList.stream().map(ContrastNonHarmonicResult::getDevMonitorId).distinct().collect(Collectors.toList()); - if (CollUtil.isNotEmpty(monitorIds)) { - contrastNonHarmonicService.remove(new LambdaQueryWrapper().in(ContrastNonHarmonicResult::getDevMonitorId, monitorIds) - .eq(ContrastNonHarmonicResult::getNum, contrastNonHarmonicResultList.get(0).getNum()) - .eq(ContrastNonHarmonicResult::getDataType, contrastNonHarmonicResultList.get(0).getDataType()) - .eq(ObjectUtil.isNotNull(contrastNonHarmonicResultList.get(0).getWaveNum()), ContrastNonHarmonicResult::getWaveNum, contrastNonHarmonicResultList.get(0).getWaveNum()) - .isNull(ObjectUtil.isNull(contrastNonHarmonicResultList.get(0).getWaveNum()), ContrastNonHarmonicResult::getWaveNum)); - } + ContrastNonHarmonicResult contrastNonHarmonicResult = contrastNonHarmonicResultList.get(0); + contrastNonHarmonicService.remove(new LambdaQueryWrapper().in(ContrastNonHarmonicResult::getDevMonitorId, contrastNonHarmonicResult.getDevMonitorId()) + .eq(ContrastNonHarmonicResult::getNum, contrastNonHarmonicResult.getNum()) + .eq(ContrastNonHarmonicResult::getAdType, contrastNonHarmonicResult.getAdType()) + .eq(ContrastNonHarmonicResult::getDataType, contrastNonHarmonicResult.getDataType()) + .eq(ObjectUtil.isNotNull(contrastNonHarmonicResult.getWaveNum()), ContrastNonHarmonicResult::getWaveNum, contrastNonHarmonicResult.getWaveNum()) + .isNull(ObjectUtil.isNull(contrastNonHarmonicResult.getWaveNum()), ContrastNonHarmonicResult::getWaveNum)); contrastNonHarmonicService.saveBatch(contrastNonHarmonicResultList); } DynamicTableNameHandler.remove(); @@ -143,14 +142,13 @@ public class DetectionDataServiceImpl extends ReplenishMybatisServiceImpl contrastHarmonicResultList = BeanUtil.copyToList(harmonicResultList, ContrastHarmonicResult.class); - List monitorIds = contrastHarmonicResultList.stream().map(ContrastHarmonicResult::getDevMonitorId).distinct().collect(Collectors.toList()); - if (CollUtil.isNotEmpty(monitorIds)) { - contrastHarmonicService.remove(new LambdaQueryWrapper().in(ContrastHarmonicResult::getDevMonitorId, monitorIds) - .eq(ContrastHarmonicResult::getNum, contrastHarmonicResultList.get(0).getNum()) - .eq(ContrastHarmonicResult::getDataType, contrastHarmonicResultList.get(0).getDataType()) - .eq(ObjectUtil.isNotNull(contrastHarmonicResultList.get(0).getWaveNum()), ContrastHarmonicResult::getWaveNum, contrastHarmonicResultList.get(0).getWaveNum()) - .isNull(ObjectUtil.isNull(contrastHarmonicResultList.get(0).getWaveNum()), ContrastHarmonicResult::getWaveNum)); - } + ContrastHarmonicResult contrastHarmonicResult = contrastHarmonicResultList.get(0); + contrastHarmonicService.remove(new LambdaQueryWrapper().eq(ContrastHarmonicResult::getDevMonitorId, contrastHarmonicResult.getDevMonitorId()) + .eq(ContrastHarmonicResult::getNum, contrastHarmonicResult.getNum()) + .eq(ContrastHarmonicResult::getAdType, contrastHarmonicResult.getAdType()) + .eq(ContrastHarmonicResult::getDataType, contrastHarmonicResult.getDataType()) + .eq(ObjectUtil.isNotNull(contrastHarmonicResult.getWaveNum()), ContrastHarmonicResult::getWaveNum, contrastHarmonicResult.getWaveNum()) + .isNull(ObjectUtil.isNull(contrastHarmonicResult.getWaveNum()), ContrastHarmonicResult::getWaveNum)); contrastHarmonicService.saveBatch(contrastHarmonicResultList); } DynamicTableNameHandler.remove();