From 237a636a302fde9a1109a389eddbc1eb5509d518 Mon Sep 17 00:00:00 2001 From: hanshaofeng Date: Thu, 3 Nov 2016 11:01:53 +0800 Subject: [PATCH] hahahah --- .../main/java/com/lyms/platform/biz/service/MongoSyncService.java | 4 +++- .../main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java | 3 ++- .../src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java | 6 +++--- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java index 188ad94..2c5e973 100644 --- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java @@ -53,6 +53,8 @@ public class MongoSyncService { try { if ("UPDATEMULTI".equals(action)) { Class cla = Class.forName(LymsEncodeUtil.aesDecrypt(className, mongo_crypto_key)); + // 批量修改的情况下,ID字段是要修改的CLASS + Class updateClass = Class.forName(LymsEncodeUtil.aesDecrypt(id, mongo_crypto_key)); Object obj = JsonUtil.jkstr2Obj(LymsEncodeUtil.aesDecrypt(json, mongo_crypto_key), cla); if (obj instanceof UpdateMultiData) { UpdateMultiData data = (UpdateMultiData) obj; @@ -68,7 +70,7 @@ public class MongoSyncService { if (c != null) { Update update = MongoConvertHelper .convertToNativeUpdate(data.getUpdate()); - mongoTemplate.updateMulti(new MongoQuery(c).convertToMongoQuery(), update, cla); + mongoTemplate.updateMulti(new MongoQuery(c).convertToMongoQuery(), update, updateClass); return true; } } 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 5b7ca4f..5180165 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 @@ -143,7 +143,8 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { UpdateMultiData data = new UpdateMultiData(); data.setMongoQuery(query); data.setUpdate(ReflectionUtils.getUpdateField(obj)); - addSyncData("UPDATEMULTI", data, "0"); + // 批量修改的情况下,ID字段是要修改的CLASS + addSyncData("UPDATEMULTI", data, obj.getClass().getName()); } public static String mongo_crypto_key = Config.getItem("mongo_crypto_key", "0"); 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 a6e1d9c..ddbc2c5 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 @@ -97,13 +97,13 @@ public class MongoSyncUtil { info.setLimit(456); Object aaa = JsonUtil.str2Obj(JsonUtil.obj2JsonString(info), Class.forName(info.getClass().getName())); System.out.println(MD5Utils.md5(aaa.getClass().getName())); - System.out.println(LymsEncodeUtil.aesDecrypt("FB0E820DE59A082E147571B3519FBF05", "Lymsh@2016")); - System.out.println(LymsEncodeUtil.aesDecrypt("26EB0301C4A2410E90985A3E55856E4B94848F070CCE3F6400CF502216F6DD18ED0A0A43348E4AB0AB97B38E4CEFEA7A4E1D74EE1671DAD6AC72560C5329BC05","Lymsh@2016")); + System.out.println(LymsEncodeUtil.aesDecrypt("26EB0301C4A2410E90985A3E55856E4B15E06845FEEF3E804F1E467AF7CAD7F17221606C305AC2686157B1226A844BED", "Lymsh@2016")); + System.out.println(LymsEncodeUtil.aesDecrypt("816A1245685928DEFB0013DE333FDBE5E23240E37A06898638F6ECB360C45EF7CFD98EA2B2C954BA93DDDDDFF01C12741408F02334BD3629C04306D7D436C0B6BB326A08B319194512E863A75E87ACD2B06E058F110B1480BBB1AB608ECD7A567B590F564416A1804F21E9E9528604B3","Lymsh@2016")); String ssss = LymsEncodeUtil.aesDecrypt("FE679036A0EE365E30DD51E0E3C38460E8B20EEDC76E8E0B04267438BFFCFFFD76D0C562244A2C914B1254B7E706BA124EE8FF560F8DEF9AD8C87EA9C793F0E16CED2A06DF8BB124DF034D21FF38F41B6CC9B1ECB30E408073D62327F5ADF8F17E7C44235EF3BCF169A1E5AFA51AD746AB28C908FBB355847E77CD2329B15174533858177A5BED3610A115C9797B61794E9CF9D5A84C6892F0D6DB9A7DB5CF2180F0CC847201108564856B536842F3DAFC9E80428D06880396DDCA4AFF0ABD1E78D41F6418638C0427768158860490112A138B3FBE4ACA572EEBDCAE06070314AAB11E02D65759BB940B2D92F9A6AB7B8C195E19E3CACD1FB05301790B7A689C", "Lymsh@2016"); ssss = new String(ssss.getBytes(),"utf-8"); System.out.println(ssss); UpdateMultiData data = new UpdateMultiData(); - data.setMongoQuery(new MongoQuery(new MongoCondition("parentId", "581a91c528b67bb1fa239ce3", MongoOper.IS)).convertToMongoQuery()); + data.setMongoQuery(new MongoQuery(new MongoCondition("parentId", "57d27d83f0f09ff4e51db341", MongoOper.IS)).convertToMongoQuery()); Map u = new HashMap<>(); u.put("score", 0); u.put("rRisk", "[\"年龄??35??\"]"); -- 1.8.3.1