From 8d9e78c5d8605a641eaf50fb50c6012a7f38cc0b Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Fri, 14 Jul 2017 17:42:18 +0800
Subject: [PATCH] update code

---
 .../operate/web/service/SyncDataTaskService.java   | 57 ++++++++++++++++++++++
 1 file changed, 57 insertions(+)

diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java
index de148b4..edf2fa4 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/service/SyncDataTaskService.java
@@ -289,6 +289,57 @@ public class SyncDataTaskService {
     }
 
     /**
+     * 同步聊城东昌区妇幼数据到线上
+     * 定时任务配置applicationContext.xml
+     */
+    public void lcdcqfySyncDataSSL() {
+
+        try{
+            String json = HttpClientUtil.doPost("https://area-lc-api.healthbaby.com.cn:55581/findSyncData", new HashMap<String, String>(), "utf-8");
+            if (com.lyms.platform.common.utils.StringUtils.isNotEmpty(json))
+            {
+                List<SyncDataModel> list = JsonUtil.toList(json, SyncDataModel.class);
+                System.out.println("lcdcqfy syncdata size = "+ list.size());
+                int batchSize = 200;
+                int end = 0;
+                for (int i = 0; i < list.size(); i += batchSize) {
+                    end = (end + batchSize);
+                    if (end > list.size()) {
+                        end = list.size();
+                    }
+                    System.out.println("lcdcqfy start:" + i + ",end:" + end);
+                    final List<SyncDataModel> tempList = list.subList(i, end);
+                    new Thread(new Runnable() {
+                        @Override
+                        public void run() {
+                            if (CollectionUtils.isNotEmpty(tempList))
+                            {
+                                StringBuffer ids = new StringBuffer();
+                                for (SyncDataModel model : tempList) {
+                                    boolean boo = mongoSyncService.syncData(model.getAction(), model.getDataId(), model.getClassName(), model.getJsonData());
+                                    if (boo) {
+                                        ids.append(model.getId());
+                                        ids.append(",");
+                                    }
+                                }
+                                if (ids.length() > 0) {
+                                    Map<String,String> params = new HashMap<String, String>();
+                                    params.put("ids", ids.toString());
+                                    String result = HttpClientUtil.doPost("https://area-lc-api.healthbaby.com.cn:55581/updateSyncData", params, "utf-8");
+                                    System.out.println("lcdcqfy exc result = "+ result);
+                                }
+                            }
+                        }
+                    }).start();
+                }
+            }
+        }catch(Exception ex){
+            ExceptionUtils.catchException(ex, "lcdcqfy Error.");
+        }
+    }
+
+
+    /**
      * 定时任务配置applicationContext.xml
      *
      */
@@ -315,6 +366,12 @@ public class SyncDataTaskService {
                 nczxyySyncDataSSL();
             }
         },"nczxyy-thread").start();
+        new Thread(new Runnable() {
+            @Override
+            public void run() {
+                lcdcqfySyncDataSSL();
+            }
+        },"lcdcqfy-thread").start();
 
     }
 
-- 
1.8.3.1