liquanyu / regional-platform

Download as
Browse Code »

Commit 2cd38534d7cb14e9adb328e935485e285d396deb

Authored by jiangjiazhi
1 parent bd546df0e7
Exists in master and in 3 other branches 0116, dev, nobuildprocess

修改产检删除

Showing 1 changed file with 26 additions and 21 deletions

platform-job-index/src/main/java/com/lyms/platform/job/index/restore/data/SyncDataWork.java View file @ 2cd3853
... ... @@ -29,6 +29,7 @@
29 29 import org.springframework.beans.factory.annotation.Value;
30 30 import org.springframework.stereotype.Component;
31 31 import org.springframework.util.StopWatch;
  32 +
32 33 import java.io.File;
33 34 import java.io.RandomAccessFile;
34 35 import java.util.*;
... ... @@ -114,6 +115,8 @@
114 115 //高危因素
115 116 private java.util.Map<String, String> bgHighRisk = new HashMap<>();
116 117 private static Map<String, RiskColorEnum> map = new HashMap<>();
  118 +
  119 + private static Timer timer = null;
117 120 /**
118 121 * mongo 里面省市区的id
119 122 */
120 123  
121 124  
... ... @@ -240,20 +243,20 @@
240 243 babyModelQuery.setGteModified(new Date(lastSyncTime));
241 244 babyModelQuery.setGteCreated(new Date(lastSyncTime));
242 245 }
243   - List<BabyModel> babyModels= babyService.queryBabyWithQuery(babyModelQuery);
244   - if(CollectionUtils.isNotEmpty(babyModels)){
245   - for(BabyModel babyModel:babyModels){
246   - Patients patients= ConvertHelper.convertToMamiBaby(babyModel);
  246 + List<BabyModel> babyModels = babyService.queryBabyWithQuery(babyModelQuery);
  247 + if (CollectionUtils.isNotEmpty(babyModels)) {
  248 + for (BabyModel babyModel : babyModels) {
  249 + Patients patients = ConvertHelper.convertToMamiBaby(babyModel);
247 250 patientsService.aouPatients(patients);
248 251  
249   - BabyCheckModelQuery babyCheckModelQuery=new BabyCheckModelQuery();
  252 + BabyCheckModelQuery babyCheckModelQuery = new BabyCheckModelQuery();
250 253 babyCheckModelQuery.setYn(YnEnums.YES.getId());
251 254 babyCheckModelQuery.setBuildId(babyModel.getId());
252 255 babyCheckModelQuery.setHospitalId(hospitalId);
253   - List<BabyCheckModel> babyCheckModels= babyCheckService.queryBabyCheckRecord(babyCheckModelQuery);
254   - if(CollectionUtils.isNotEmpty(babyCheckModels)){
255   - for(BabyCheckModel babyCheckModel:babyCheckModels){
256   - Reports reports= ConvertHelper.convertToBabyCheck(babyCheckModel, babyModel);
  256 + List<BabyCheckModel> babyCheckModels = babyCheckService.queryBabyCheckRecord(babyCheckModelQuery);
  257 + if (CollectionUtils.isNotEmpty(babyCheckModels)) {
  258 + for (BabyCheckModel babyCheckModel : babyCheckModels) {
  259 + Reports reports = ConvertHelper.convertToBabyCheck(babyCheckModel, babyModel);
257 260 reportsService.aouReports(reports);
258 261 }
259 262 }
... ... @@ -304,7 +307,7 @@
304 307 writeLastSyncTime();
305 308 // clearAll();
306 309 //单独同步秦皇岛
307   - syncQHDWork();
  310 +// syncQHDWork();
308 311 logger.info("sync end costTime:" + (System.currentTimeMillis() - l) + " ms.");
309 312 }
310 313  
... ... @@ -315,17 +318,19 @@
315 318 }
316 319  
317 320 private void syncQHDWork() {
318   - Timer timer = new Timer();
319   - timer.schedule(new TimerTask() {
320   - @Override
321   - public void run() {
322   - logger.info("syncQHDWork start ." + DateUtil.getymdhm(new Date()));
323   - CountDownLatch countDownLatch = new CountDownLatch(1);
324   - String hospitalId = "216";
325   - new SyncWork(hospitalId, countDownLatch).start();
326   - logger.info("syncQHDWork end ." + DateUtil.getymdhm(new Date()));
327   - }
328   - }, 600000, 300000);
  321 + if (null == timer) {
  322 + timer = new Timer();
  323 + timer.schedule(new TimerTask() {
  324 + @Override
  325 + public void run() {
  326 + logger.info("syncQHDWork start ." + DateUtil.getymdhm(new Date()));
  327 + CountDownLatch countDownLatch = new CountDownLatch(1);
  328 + String hospitalId = "216";
  329 + new SyncWork(hospitalId, countDownLatch).start();
  330 + logger.info("syncQHDWork end ." + DateUtil.getymdhm(new Date()));
  331 + }
  332 + }, 600000, 300000);
  333 + }
329 334 }
330 335  
331 336