|
@@ -72,16 +72,10 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private LabRiskPlanSensorRelationMapper labRiskPlanSensorRelationMapper;
|
|
private LabRiskPlanSensorRelationMapper labRiskPlanSensorRelationMapper;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
- private ILabOperateHardwareService labOperateHardwareService;
|
|
|
|
|
- @Autowired
|
|
|
|
|
private LabRiskPlanAbnormalLogMapper labRiskPlanAbnormalLogMapper;
|
|
private LabRiskPlanAbnormalLogMapper labRiskPlanAbnormalLogMapper;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
- private LabSubjectMapper labSubjectMapper;
|
|
|
|
|
- @Autowired
|
|
|
|
|
private LabRiskPlanAbnormalGroupMapper labRiskPlanAbnormalGroupMapper;
|
|
private LabRiskPlanAbnormalGroupMapper labRiskPlanAbnormalGroupMapper;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
- private LabSensorMapper labSensorMapper;
|
|
|
|
|
- @Autowired
|
|
|
|
|
private SubMessageSendManager messageSendService;
|
|
private SubMessageSendManager messageSendService;
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private LabWarnPushMessageMapper labWarnPushMessageMapper;
|
|
private LabWarnPushMessageMapper labWarnPushMessageMapper;
|
|
@@ -118,8 +112,6 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
@Lazy
|
|
@Lazy
|
|
|
private LabRiskPlanLevelService labRiskPlanLevelService;
|
|
private LabRiskPlanLevelService labRiskPlanLevelService;
|
|
|
|
|
|
|
|
- @Autowired
|
|
|
|
|
- private ILabSubjectService labSubjectService;
|
|
|
|
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private ILabSensorService labSensorService;
|
|
private ILabSensorService labSensorService;
|
|
@@ -298,7 +290,6 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
*/
|
|
*/
|
|
|
@Override
|
|
@Override
|
|
|
public Map<String, Object> getLabRiskPlanRepeat(LabRiskPlan labRiskPlan) {
|
|
public Map<String, Object> getLabRiskPlanRepeat(LabRiskPlan labRiskPlan) {
|
|
|
- SysUser user = tokenService.getLoginUser().getSysUser();
|
|
|
|
|
//获取页面传感器列表
|
|
//获取页面传感器列表
|
|
|
List<LabRiskPlanSensorRelation> newRiskPlanSesorList = new ArrayList<>();
|
|
List<LabRiskPlanSensorRelation> newRiskPlanSesorList = new ArrayList<>();
|
|
|
List<LabRiskPlanSensorRelation> labRiskPlanSensorRelationList = labRiskPlan.getRiskPlanSensorList();
|
|
List<LabRiskPlanSensorRelation> labRiskPlanSensorRelationList = labRiskPlan.getRiskPlanSensorList();
|
|
@@ -326,17 +317,6 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
});
|
|
});
|
|
|
-// Optional.ofNullable(sensorRelationList).orElseGet(Collections::emptyList).stream()
|
|
|
|
|
-// .forEach(a->Optional.ofNullable(labRiskPlanSensorRelationList)
|
|
|
|
|
-// .orElseGet(Collections::emptyList).stream().forEach(b->{
|
|
|
|
|
-// if(a.getFunNum().equals(b.getFunNum())){
|
|
|
|
|
-// if(b.getMinMonitor().floatValue()>=a.getMinMonitor().floatValue() && b.getMinMonitor().floatValue()<=a.getMaxMonitor().floatValue()){
|
|
|
|
|
-// newRiskPlanSesorList.add(a);
|
|
|
|
|
-// }else if(b.getMaxMonitor().floatValue()>=a.getMinMonitor().floatValue() && b.getMaxMonitor().floatValue()<=a.getMaxMonitor().floatValue()){
|
|
|
|
|
-// newRiskPlanSesorList.add(a);
|
|
|
|
|
-// }
|
|
|
|
|
-// }
|
|
|
|
|
-// }));
|
|
|
|
|
//根据预案id和实验室id查询当前用户是否有冲突的预案
|
|
//根据预案id和实验室id查询当前用户是否有冲突的预案
|
|
|
List<LabRiskPlanjoinsub> labRiskPlanjoinsubList = labRiskPlan.getLabRiskPlanjoinsubList();
|
|
List<LabRiskPlanjoinsub> labRiskPlanjoinsubList = labRiskPlan.getLabRiskPlanjoinsubList();
|
|
|
List<LabRiskPlanjoinsubVO> riskPlanjoinsubList = new ArrayList<>();
|
|
List<LabRiskPlanjoinsubVO> riskPlanjoinsubList = new ArrayList<>();
|
|
@@ -893,7 +873,7 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
List<LabNoticeconfig> noticeconfigList = labNoticeconfigMapper.selectLabNoticeconfigList(new LabNoticeconfig());
|
|
List<LabNoticeconfig> noticeconfigList = labNoticeconfigMapper.selectLabNoticeconfigList(new LabNoticeconfig());
|
|
|
if (!noticeconfigList.isEmpty()) {
|
|
if (!noticeconfigList.isEmpty()) {
|
|
|
LabNoticeconfig labNoticeconfig = noticeconfigList.get(0);
|
|
LabNoticeconfig labNoticeconfig = noticeconfigList.get(0);
|
|
|
- StringBuffer radioStr = new StringBuffer();
|
|
|
|
|
|
|
+ StringBuilder radioStr = new StringBuilder();
|
|
|
radioStr.append(noticeconfigList.get(0).getRiskRadio());
|
|
radioStr.append(noticeconfigList.get(0).getRiskRadio());
|
|
|
labRiskPlanLevel.setMessage(labNoticeconfig.getRiskMessage());
|
|
labRiskPlanLevel.setMessage(labNoticeconfig.getRiskMessage());
|
|
|
labRiskPlanLevel.setVoicebroadcast(labNoticeconfig.getRiskVoice());
|
|
labRiskPlanLevel.setVoicebroadcast(labNoticeconfig.getRiskVoice());
|
|
@@ -910,7 +890,7 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
try {
|
|
try {
|
|
|
Map<SenseType, List<SensorFunctionStatus>> sensorFunctionStatusListMap = hardwareFunctionStatusConfig.getSensorFunctionStatusListMap();
|
|
Map<SenseType, List<SensorFunctionStatus>> sensorFunctionStatusListMap = hardwareFunctionStatusConfig.getSensorFunctionStatusListMap();
|
|
|
//处理预案下的传感器翻译
|
|
//处理预案下的传感器翻译
|
|
|
- StringBuffer sb = new StringBuffer();
|
|
|
|
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
for (LabRiskPlanSensorRelation rps : labRiskPlanLevel.getRiskPlanSensorList()) {
|
|
for (LabRiskPlanSensorRelation rps : labRiskPlanLevel.getRiskPlanSensorList()) {
|
|
|
//硬件社保统一传入的传感器设备列表
|
|
//硬件社保统一传入的传感器设备列表
|
|
|
for (SensorFunctionStatus sensorFunc : subFunction.getFunctionStatuses()) {
|
|
for (SensorFunctionStatus sensorFunc : subFunction.getFunctionStatuses()) {
|
|
@@ -1188,7 +1168,6 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
operateHardWareInfo(labRiskPlanLevel, labRiskPlanAbnormalGroup.getSubjectId(), labRiskPlanAbnormalLog.getGroupId(), riskPlanJson.toString());
|
|
operateHardWareInfo(labRiskPlanLevel, labRiskPlanAbnormalGroup.getSubjectId(), labRiskPlanAbnormalLog.getGroupId(), riskPlanJson.toString());
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
log.error("操作硬件设备异!{}",e);
|
|
log.error("操作硬件设备异!{}",e);
|
|
|
- } finally {
|
|
|
|
|
}
|
|
}
|
|
|
return groupId;
|
|
return groupId;
|
|
|
} else {
|
|
} else {
|
|
@@ -1231,7 +1210,6 @@ public class LabRiskPlanServiceImpl extends ServiceImpl<LabRiskPlanMapper, LabRi
|
|
|
});
|
|
});
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
log.error("操作硬件设备异常{}",e);
|
|
log.error("操作硬件设备异常{}",e);
|
|
|
- } finally {
|
|
|
|
|
}
|
|
}
|
|
|
return groupId;
|
|
return groupId;
|
|
|
}
|
|
}
|