diff --git a/platform-common/src/main/java/com/lyms/platform/common/utils/HttpClientUtil.java b/platform-common/src/main/java/com/lyms/platform/common/utils/HttpClientUtil.java index ec607c7..06f60ac 100644 --- a/platform-common/src/main/java/com/lyms/platform/common/utils/HttpClientUtil.java +++ b/platform-common/src/main/java/com/lyms/platform/common/utils/HttpClientUtil.java @@ -4,7 +4,6 @@ package com.lyms.platform.common.utils; * Created by Administrator on 2017-01-18. */ -import com.lyms.platform.common.pojo.SyncDataModel; import org.apache.http.HttpEntity; import org.apache.http.HttpResponse; import org.apache.http.HttpStatus; @@ -174,6 +173,51 @@ public class HttpClientUtil { return httpStr; } + + /** + * sslpost + * @param apiUrl + * @param list + * @return + */ + public static String doPostSSL(String apiUrl, List list) { + HttpClient httpClient = null; + HttpPost httpPost = new HttpPost(apiUrl); + HttpResponse response = null; + String httpStr = null; + + try { + httpClient = new SSLClient(); + httpPost.setConfig(requestConfig); + //4.将参数写入到httpost中,并设置编码格式为UTF-8 + UrlEncodedFormEntity paramEntity = new UrlEncodedFormEntity(list,"UTF-8"); + httpPost.setEntity(paramEntity); + response = httpClient.execute(httpPost); + int statusCode = response.getStatusLine().getStatusCode(); + System.out.println("return code = "+ statusCode); + if (statusCode != HttpStatus.SC_OK) { + return null; + } + HttpEntity entity = response.getEntity(); + if (entity == null) { + return null; + } + httpStr = EntityUtils.toString(entity, "utf-8"); + } catch (Exception e) { + e.printStackTrace(); + } finally { + if (response != null) { + try { + EntityUtils.consume(response.getEntity()); + } catch (IOException e) { + e.printStackTrace(); + } + } + } + return httpStr; + } + + public static void main(String[] args) throws Exception { Map map = new HashMap(); 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 50c9ce8..fb2f4c4 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 @@ -8,10 +8,11 @@ import com.lyms.platform.common.pojo.UpdateMultiData; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.NameValuePair; import org.apache.commons.httpclient.methods.PostMethod; -import org.springframework.data.mongodb.core.query.Query; -import org.springframework.data.mongodb.core.query.Update; +import org.apache.http.message.BasicNameValuePair; +import java.util.ArrayList; import java.util.HashMap; +import java.util.List; import java.util.Map; /** @@ -57,6 +58,32 @@ public class MongoSyncUtil { return true; } + + public static boolean syncSll(String action, String jsonData, String id, String className) { + if ("1".equals(mongo_sync)) { + boolean boo = false; + try { + List list = new ArrayList<>(); + //将用户名与密码作为参数写入(username,password这两个参数是 根据你的接口协议而定) + list.add(new NameValuePair("action", action)); + list.add(new NameValuePair("token", mongo_sync_token)); + list.add(new NameValuePair("className", className)); + list.add(new NameValuePair("jsonData", jsonData)); + list.add(new NameValuePair("id", id)); + String result = HttpClientUtil.doPostSSL(mongo_sync_url,list); + if (StringUtils.isNotEmpty(result) && "success".equals(result)) + { + boo = true; + } + return boo; + } catch (Exception e) { + e.printStackTrace(); + return boo; + } + } + return false; + } + public static boolean sync(String action, Object data, String id) { if ("1".equals(mongo_sync)) { boolean boo = false; 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 de725c2..2e9e5ed 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 @@ -98,7 +98,7 @@ public class SyncDataTaskService { query.setNeed("0"); List list = syncDataService.querySyncData(query); for (SyncDataModel model : list) { - if (MongoSyncUtil.sync(model.getAction(), model.getJsonData(), model.getDataId(), model.getClassName())) { + if (MongoSyncUtil.syncSll(model.getAction(), model.getJsonData(), model.getDataId(), model.getClassName())) { model.setStatus(0); model.setModified(new Date()); syncDataService.updateSyncData(model);