Преглед изворни кода

add 增加聊天室创建时间

18339543638 пре 3 година
родитељ
комит
2b32857820

+ 23 - 23
nb-service/web-service/src/main/java/com/nb/web/service/bus/hospital/HospitalManager.java

@@ -99,29 +99,29 @@ public class HospitalManager {
         this.patientService=SpringUtil.getBean(LocalBusPatientService.class);
         init(configStorageManager);
 
-        singleOffsetsDeviceExecutor.scheduleWithFixedDelay(()->{
-                    try {
-                        PatientMonitorQuery query = new PatientMonitorQuery();
-                        query.setTenantId(this.getHospitalId());
-                        List<PatientMonitorResult> patientMonitorResults = patientService.selectAll(query);
-                        patientMonitorResults
-                                .forEach(infusionInfo->{
-                                    BusDeviceRunningEntity source = BeanUtil.toBean(infusionInfo, BusDeviceRunningEntity.class);
-                                    source.setRunState(infusionInfo.getDeviceRunState());
-                                    source.setAlarm(infusionInfo.getDeviceAlarm());
-                                    source.setInfusionId(infusionInfo.getInfusionId());
-                                    source.setUploadTime(infusionInfo.getLastUploadTime());
-                                    source.setTenantId(this.getHospitalId());
-                                    extraConfigHandler.handler(source);
-                                    autoUndoConfigHandler.handler(source);
-                                    finishMonitorConfigHandler.handler(source);
-                                });
-                    }catch (Exception e){
-                        e.printStackTrace();
-                    }
-                },
-                //启动间隔分开,避免数据库瞬时压力过大,最长有小时延迟
-                RandomUtil.randomInt(1,60),  Math.addExact(30,RandomUtil.randomInt(0,60)),TimeUnit.MINUTES);
+//        singleOffsetsDeviceExecutor.scheduleWithFixedDelay(()->{
+//                    try {
+//                        PatientMonitorQuery query = new PatientMonitorQuery();
+//                        query.setTenantId(this.getHospitalId());
+//                        List<PatientMonitorResult> patientMonitorResults = patientService.selectAll(query);
+//                        patientMonitorResults
+//                                .forEach(infusionInfo->{
+//                                    BusDeviceRunningEntity source = BeanUtil.toBean(infusionInfo, BusDeviceRunningEntity.class);
+//                                    source.setRunState(infusionInfo.getDeviceRunState());
+//                                    source.setAlarm(infusionInfo.getDeviceAlarm());
+//                                    source.setInfusionId(infusionInfo.getInfusionId());
+//                                    source.setUploadTime(infusionInfo.getLastUploadTime());
+//                                    source.setTenantId(this.getHospitalId());
+//                                    extraConfigHandler.handler(source);
+//                                    autoUndoConfigHandler.handler(source);
+//                                    finishMonitorConfigHandler.handler(source);
+//                                });
+//                    }catch (Exception e){
+//                        e.printStackTrace();
+//                    }
+//                },
+//                //启动间隔分开,避免数据库瞬时压力过大,最长有小时延迟
+//                RandomUtil.randomInt(1,60),  Math.addExact(30,RandomUtil.randomInt(1,60)),TimeUnit.MINUTES);
     }
 
     private void init(ConfigStorageManager configStorageManager){