diff --git a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java index b565762..ed8fe6c 100644 --- a/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java +++ b/platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java @@ -29,6 +29,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import org.springframework.util.StopWatch; + import java.io.File; import java.io.RandomAccessFile; import java.util.*; @@ -114,6 +115,8 @@ public class SyncDataWork { //高危因素 private java.util.Map bgHighRisk = new HashMap<>(); private static Map map = new HashMap<>(); + + private static Timer timer = null; /** * mongo 里面省市区的id */ @@ -240,20 +243,20 @@ public class SyncDataWork { babyModelQuery.setGteModified(new Date(lastSyncTime)); babyModelQuery.setGteCreated(new Date(lastSyncTime)); } - List babyModels= babyService.queryBabyWithQuery(babyModelQuery); - if(CollectionUtils.isNotEmpty(babyModels)){ - for(BabyModel babyModel:babyModels){ - Patients patients= ConvertHelper.convertToMamiBaby(babyModel); + List babyModels = babyService.queryBabyWithQuery(babyModelQuery); + if (CollectionUtils.isNotEmpty(babyModels)) { + for (BabyModel babyModel : babyModels) { + Patients patients = ConvertHelper.convertToMamiBaby(babyModel); patientsService.aouPatients(patients); - BabyCheckModelQuery babyCheckModelQuery=new BabyCheckModelQuery(); + BabyCheckModelQuery babyCheckModelQuery = new BabyCheckModelQuery(); babyCheckModelQuery.setYn(YnEnums.YES.getId()); babyCheckModelQuery.setBuildId(babyModel.getId()); babyCheckModelQuery.setHospitalId(hospitalId); - List babyCheckModels= babyCheckService.queryBabyCheckRecord(babyCheckModelQuery); - if(CollectionUtils.isNotEmpty(babyCheckModels)){ - for(BabyCheckModel babyCheckModel:babyCheckModels){ - Reports reports= ConvertHelper.convertToBabyCheck(babyCheckModel, babyModel); + List babyCheckModels = babyCheckService.queryBabyCheckRecord(babyCheckModelQuery); + if (CollectionUtils.isNotEmpty(babyCheckModels)) { + for (BabyCheckModel babyCheckModel : babyCheckModels) { + Reports reports = ConvertHelper.convertToBabyCheck(babyCheckModel, babyModel); reportsService.aouReports(reports); } } @@ -304,7 +307,7 @@ public class SyncDataWork { writeLastSyncTime(); // clearAll(); //单独同步秦皇岛 - syncQHDWork(); +// syncQHDWork(); logger.info("sync end costTime:" + (System.currentTimeMillis() - l) + " ms."); } @@ -315,17 +318,19 @@ public class SyncDataWork { } private void syncQHDWork() { - Timer timer = new Timer(); - timer.schedule(new TimerTask() { - @Override - public void run() { - logger.info("syncQHDWork start ." + DateUtil.getymdhm(new Date())); - CountDownLatch countDownLatch = new CountDownLatch(1); - String hospitalId = "216"; - new SyncWork(hospitalId, countDownLatch).start(); - logger.info("syncQHDWork end ." + DateUtil.getymdhm(new Date())); - } - }, 600000, 300000); + if (null == timer) { + timer = new Timer(); + timer.schedule(new TimerTask() { + @Override + public void run() { + logger.info("syncQHDWork start ." + DateUtil.getymdhm(new Date())); + CountDownLatch countDownLatch = new CountDownLatch(1); + String hospitalId = "216"; + new SyncWork(hospitalId, countDownLatch).start(); + logger.info("syncQHDWork end ." + DateUtil.getymdhm(new Date())); + } + }, 600000, 300000); + } }