Commit 857194991562bc8b4c6c67195e022042fe2f2456

Authored by yangfei
1 parent c5e8360660

儿童服务数据同步

Showing 3 changed files with 26 additions and 10 deletions

platform-operate-api/src/main/java/com/lyms/platform/operate/web/Test.java View file @ 8571949
1 1 package com.lyms.platform.operate.web;
2 2  
3   -import com.lyms.platform.common.enums.RiskDefaultTypeEnum;
  3 +import com.lyms.platform.common.enums.YnEnums;
4 4 import com.lyms.platform.pojo.BasicConfig;
5   -import com.lyms.platform.query.BasicConfigQuery;
6   -import com.mongodb.Mongo;
  5 +import com.lyms.platform.query.BabyModelQuery;
7 6 import net.sourceforge.pinyin4j.PinyinHelper;
8 7 import org.apache.log4j.Logger;
9   -import org.springframework.data.authentication.UserCredentials;
10   -import org.springframework.data.mongodb.core.MongoTemplate;
11 8  
12   -import java.util.*;
  9 +import java.util.ArrayList;
  10 +import java.util.Comparator;
  11 +import java.util.List;
  12 +import java.util.Map;
13 13  
14 14 /**
15 15 * Created by Administrator on 2016/8/22 0022.
... ... @@ -20,7 +20,21 @@
20 20  
21 21 public static void main(String[] args) throws Exception {
22 22  
23   - Mongo mongo = new Mongo("119.90.57.26", 10001);
  23 + BabyModelQuery babyQuery = new BabyModelQuery();
  24 + List list = new ArrayList();
  25 + list.add("1");//转诊,建档已接受
  26 + list.add("2");//隐藏建档
  27 + babyQuery.setEnableListNot(list);
  28 + List buildType = new ArrayList();
  29 + buildType.add(1);//儿童直接建档
  30 + buildType.add(2);//产妇分娩建档
  31 + babyQuery.setBuildTypeList(buildType);
  32 + babyQuery.setYn(YnEnums.YES.getId());
  33 + babyQuery.setNeed("need");
  34 + System.out.println(babyQuery.convertToQuery().convertToMongoQuery());
  35 +
  36 +
  37 + /* Mongo mongo = new Mongo("119.90.57.26", 10001);
24 38 UserCredentials credentials = new UserCredentials("platform", "platform123");
25 39 MongoTemplate mongoTemplate = new MongoTemplate(mongo, "sync-platform-data", credentials);
26 40  
... ... @@ -65,7 +79,7 @@
65 79 for (BasicConfig bs : mainBasicConfigList) {
66 80 configData(bs, basicConfigList,slaveBasicConfigMap);
67 81 }
68   - System.out.println(mainBasicConfigList);
  82 + System.out.println(mainBasicConfigList);*/
69 83  
70 84  
71 85  
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MatdeliverFollowController.java View file @ 8571949
... ... @@ -56,7 +56,7 @@
56 56 @TokenRequired
57 57 @RequestMapping(value = "/addMatdeliverInfo", method = RequestMethod.POST)
58 58 public BaseResponse addMatdeliverInfo(MatDeliverFollowAddRequest matDeliverFollowAddRequest, HttpServletRequest request) {
59   - System.out.println("保存或修改随访记录:"+matDeliverFollowAddRequest);
  59 + // System.out.println("保存或修改随访记录:"+matDeliverFollowAddRequest);
60 60 Integer userId = getUserId(request);
61 61 return matdeliverFollowFacade.addOrUpdateMatDeliverFollow(matDeliverFollowAddRequest, userId);
62 62 }
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java View file @ 8571949
... ... @@ -241,7 +241,9 @@
241 241  
242 242 //计算每个线程需要处理的数据量,默认1000,必须是分页条数的倍数,不然多线程处理的数据会重复
243 243 int batchSize = 1000;
244   - if (patientCount > 10000) {
  244 + if (patientCount > 100000) {
  245 + batchSize = 30000;
  246 + }else if(patientCount > 10000){
245 247 batchSize = 10000;
246 248 }
247 249