diff --git a/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java b/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java index 2e8099a..5b7ca4f 100644 --- a/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java +++ b/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java @@ -142,7 +142,7 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { // 数据上传 UpdateMultiData data = new UpdateMultiData(); data.setMongoQuery(query); - data.setUpdate(update); + data.setUpdate(ReflectionUtils.getUpdateField(obj)); addSyncData("UPDATEMULTI", data, "0"); } diff --git a/platform-common/src/main/java/com/lyms/platform/common/pojo/UpdateMultiData.java b/platform-common/src/main/java/com/lyms/platform/common/pojo/UpdateMultiData.java index 227120a..32e3e5d 100644 --- a/platform-common/src/main/java/com/lyms/platform/common/pojo/UpdateMultiData.java +++ b/platform-common/src/main/java/com/lyms/platform/common/pojo/UpdateMultiData.java @@ -13,7 +13,7 @@ import java.util.Map; public class UpdateMultiData { private Map query; - private Update update; + private Map update; public void setQuery(Map query) { this.query = query; @@ -33,11 +33,11 @@ public class UpdateMultiData { } } - public Update getUpdate() { + public Map getUpdate() { return update; } - public void setUpdate(Update update) { + public void setUpdate(Map update) { this.update = update; } } 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 78bf1ed..a6e1d9c 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 @@ -11,6 +11,9 @@ import org.apache.commons.httpclient.methods.PostMethod; import org.springframework.data.mongodb.core.query.Query; import org.springframework.data.mongodb.core.query.Update; +import java.util.HashMap; +import java.util.Map; + /** * Created by Administrator on 2016/9/13 0013. */ @@ -101,18 +104,17 @@ public class MongoSyncUtil { System.out.println(ssss); UpdateMultiData data = new UpdateMultiData(); data.setMongoQuery(new MongoQuery(new MongoCondition("parentId", "581a91c528b67bb1fa239ce3", MongoOper.IS)).convertToMongoQuery()); - Update u = new Update(); - u.set("score", 0).set("rRisk", "[\"年龄??35??\"]"); + Map u = new HashMap<>(); + u.put("score", 0); + u.put("rRisk", "[\"年龄??35??\"]"); data.setUpdate(u); - System.out.println(JsonUtil.obj2Str(data)); + System.out.println("---"+JsonUtil.obj2Str(data)); System.out.println(LymsEncodeUtil.aesEncrypt(JsonUtil.obj2Str(data), "Lymsh@2016")); - Query query = new MongoQuery(new MongoCondition("id", "aaa", MongoOper.IS).and("name", "bbb", MongoOper.IS)).convertToMongoQuery(); - System.out.println(JsonUtil.obj2Str(query)); - String s = "{\"restrictedTypes\":[],\"skip\":0,\"limit\":0,\"hint\":null,\"queryObject\":{\"id\":\"aaa\"},\"fieldsObject\":null,\"sortObject\":null}"; - query = JsonUtil.str2Obj(s, Query.class); - System.out.println(JsonUtil.obj2Str(query)); + String s = "{\"query\":{\"parentId\":\"581a91c528b67bb1fa239ce3\"},\"update\":{\"score\":0,\"rRisk\":\"[\\\"年龄??35??\\\"]\"}}"; + UpdateMultiData updateMultiData = JsonUtil.str2Obj(s, UpdateMultiData.class); + System.out.println(JsonUtil.obj2Str(updateMultiData)); } }