fangcheng / regional-platform

Commit 236d0f5a99d4121db69db5b2763f584e31c23f68

Authored by hanshaofeng over 8 years ago

hahahah

Showing 3 changed files with 14 additions and 12 deletions

platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java
platform-common/src/main/java/com/lyms/platform/common/pojo/UpdateMultiData.java
platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java

...	...	@@ -142,7 +142,7 @@
142	142	// 数据上传
143	143	UpdateMultiData data = new UpdateMultiData();
144	144	data.setMongoQuery(query);
145		- data.setUpdate(update);
	145	+ data.setUpdate(ReflectionUtils.getUpdateField(obj));
146	146	addSyncData("UPDATEMULTI", data, "0");
147	147	}
148	148

...	...	@@ -13,7 +13,7 @@
13	13	public class UpdateMultiData {
14	14
15	15	private Map<String, Object> query;
16		- private Update update;
	16	+ private Map<String, Object> update;
17	17
18	18	public void setQuery(Map<String, Object> query) {
19	19	this.query = query;
20	20
...	...	@@ -33,11 +33,11 @@
33	33	}
34	34	}
35	35
36		- public Update getUpdate() {
	36	+ public Map<String, Object> getUpdate() {
37	37	return update;
38	38	}
39	39
40		- public void setUpdate(Update update) {
	40	+ public void setUpdate(Map<String, Object> update) {
41	41	this.update = update;
42	42	}
43	43	}

...	...	@@ -11,6 +11,9 @@
11	11	import org.springframework.data.mongodb.core.query.Query;
12	12	import org.springframework.data.mongodb.core.query.Update;
13	13
	14	+import java.util.HashMap;
	15	+import java.util.Map;
	16	+
14	17	/**
15	18	* Created by Administrator on 2016/9/13 0013.
16	19	*/
17	20
18	21
...	...	@@ -101,18 +104,17 @@
101	104	System.out.println(ssss);
102	105	UpdateMultiData data = new UpdateMultiData();
103	106	data.setMongoQuery(new MongoQuery(new MongoCondition("parentId", "581a91c528b67bb1fa239ce3", MongoOper.IS)).convertToMongoQuery());
104		- Update u = new Update();
105		- u.set("score", 0).set("rRisk", "[\"年龄??35??\"]");
	107	+ Map<String, Object> u = new HashMap<>();
	108	+ u.put("score", 0);
	109	+ u.put("rRisk", "[\"年龄??35??\"]");
106	110	data.setUpdate(u);
107		- System.out.println(JsonUtil.obj2Str(data));
	111	+ System.out.println("---"+JsonUtil.obj2Str(data));
108	112	System.out.println(LymsEncodeUtil.aesEncrypt(JsonUtil.obj2Str(data), "Lymsh@2016"));
109	113
110	114
111		- Query query = new MongoQuery(new MongoCondition("id", "aaa", MongoOper.IS).and("name", "bbb", MongoOper.IS)).convertToMongoQuery();
112		- System.out.println(JsonUtil.obj2Str(query));
113		- String s = "{\"restrictedTypes\":[],\"skip\":0,\"limit\":0,\"hint\":null,\"queryObject\":{\"id\":\"aaa\"},\"fieldsObject\":null,\"sortObject\":null}";
114		- query = JsonUtil.str2Obj(s, Query.class);
115		- System.out.println(JsonUtil.obj2Str(query));
	115	+ String s = "{\"query\":{\"parentId\":\"581a91c528b67bb1fa239ce3\"},\"update\":{\"score\":0,\"rRisk\":\"[\\\"年龄??35??\\\"]\"}}";
	116	+ UpdateMultiData updateMultiData = JsonUtil.str2Obj(s, UpdateMultiData.class);
	117	+ System.out.println(JsonUtil.obj2Str(updateMultiData));
116	118	}
117	119
118	120	}