From 30ea291d49c8258a3521f7a49061e2e938a9c41d Mon Sep 17 00:00:00 2001
From: riecard <hanshaofeng@lymsh.com>
Date: Mon, 26 Sep 2016 23:37:12 +0800
Subject: [PATCH] add sync data task

---
 .../lyms/platform/common/utils/MongoSyncUtil.java  | 41 +++++++++++++++++-----
 .../operate/web/service/SyncDataTaskService.java   |  2 +-
 2 files changed, 33 insertions(+), 10 deletions(-)

diff --git a/platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java b/platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java
index b8ad158..c6c3336 100644
--- a/platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java
+++ b/platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java
@@ -1,18 +1,10 @@
 package com.lyms.platform.common.utils;
 
-import com.lyms.platform.common.base.LoginContext;
 import com.lyms.platform.common.base.PageInfo;
-import com.lyms.platform.common.dao.operator.MongoCondition;
-import com.lyms.platform.common.dao.operator.MongoOper;
-import com.lyms.platform.common.dao.operator.MongoQuery;
-import com.mchange.lang.LongUtils;
 import org.apache.commons.httpclient.HttpClient;
 import org.apache.commons.httpclient.NameValuePair;
 import org.apache.commons.httpclient.methods.PostMethod;
 
-import java.util.HashMap;
-import java.util.Map;
-
 /**
  * Created by Administrator on 2016/9/13 0013.
  */
@@ -23,8 +15,39 @@ public class MongoSyncUtil {
     public static String mongo_sync_token = Config.getItem("mongo_sync_token", "0");
     public static String mongo_crypto_key = Config.getItem("mongo_crypto_key", "0");
 
+    public static boolean sync(String action, String jsonData, String id, String className) {
+        if ("1".equals(mongo_sync)) {
+            boolean boo = false;
+            try {
+                HttpClient client = new HttpClient();
+                client.getHttpConnectionManager().getParams().setConnectionTimeout(3000);
+                client.getHttpConnectionManager().getParams().setSoTimeout(3000);
+                PostMethod post = new MessageUtil.UTF8PostMethod(mongo_sync_url);
+                NameValuePair[] pairs = {
+                        new NameValuePair("action", action),
+                        new NameValuePair("token", mongo_sync_token),
+                        new NameValuePair("className", className),
+                        new NameValuePair("jsonData", jsonData),
+                        new NameValuePair("id", id),
+                };
+                post.setRequestBody(pairs);
+                client.executeMethod(post);
+                int statusCode = post.getStatusCode();
+                System.out.println(post.getResponseBodyAsString());
+                post.releaseConnection();
+                if (200 == statusCode) {
+                    boo = true;
+                }
+                return boo;
+            } catch (Exception e) {
+                e.printStackTrace();
+                return boo;
+            }
+        }
+        return true;
+    }
+
     public static boolean sync(String action, Object data, String id) {
-        System.out.println(mongo_sync +" :: "+id+"  --  "+action);
         if ("1".equals(mongo_sync)) {
             boolean boo = false;
             try {
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 ed50e26..8fedf75 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
@@ -26,7 +26,7 @@ public class SyncDataTaskService {
         query.setNeed("0");
         List<SyncDataModel> list = syncDataService.querySyncData(query);
         for (SyncDataModel model:list) {
-            if (MongoSyncUtil.sync(model.getAction(),model.getJsonData(),model.getDataId())) {
+            if (MongoSyncUtil.sync(model.getAction(),model.getJsonData(),model.getDataId(),model.getClassName())) {
                 model.setStatus(0);
                 model.setModified(new Date());
                 syncDataService.updateSyncData(model);
-- 
1.8.3.1