From 0dc20b9af69e5ee13ea95523322f06631be7f8a1 Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Mon, 5 Jun 2017 10:54:15 +0800
Subject: [PATCH] update

---
 .../operate/web/service/SyncDataTaskService.java   | 58 ++++++++++++++++++++++
 1 file changed, 58 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 cc80414..de148b4 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
@@ -237,6 +237,57 @@ public class SyncDataTaskService {
         }
     }
 
+
+    /**
+     * 同步南充中心医院的数据到线上
+     * 定时任务配置applicationContext.xml
+     */
+    public void nczxyySyncDataSSL() {
+
+        try{
+            String json = HttpClientUtil.doPost("https://area-nc-api.healthbaby.com.cn:12356/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("nczxyy 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("nczxyy 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-nc-api.healthbaby.com.cn:12356/updateSyncData", params, "utf-8");
+                                    System.out.println("exc result = "+ result);
+                                }
+                            }
+                        }
+                    }).start();
+                }
+            }
+        }catch(Exception ex){
+            ExceptionUtils.catchException(ex, "nczxyySyncDataSSL Error.");
+        }
+    }
+
     /**
      * 定时任务配置applicationContext.xml
      *
@@ -258,6 +309,13 @@ public class SyncDataTaskService {
             }
         },"dzfy-thread").start();
 
+        new Thread(new Runnable() {
+            @Override
+            public void run() {
+                nczxyySyncDataSSL();
+            }
+        },"nczxyy-thread").start();
+
     }
 
 
-- 
1.8.3.1