From be67e60514d16d4e1c55978658c0f02d60f036ae Mon Sep 17 00:00:00 2001 From: baohanddd Date: Tue, 13 Sep 2016 17:00:16 +0800 Subject: [PATCH] add mongo sync --- .../platform/biz/service/MongoSyncService.java | 54 ++++++++ .../lyms/platform/common/dao/BaseMongoDAOImpl.java | 11 ++ .../lyms/platform/common/utils/LymsEncodeUtil.java | 152 +++++++++++++++++++++ .../lyms/platform/common/utils/MongoSyncUtil.java | 69 ++++++++++ .../web/controller/MongoSyncController.java | 37 +++++ .../src/main/resources/config.properties | 3 +- .../src/main/resources/database.properties | 9 +- pom.xml | 1 + 8 files changed, 334 insertions(+), 2 deletions(-) create mode 100644 platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java create mode 100644 platform-common/src/main/java/com/lyms/platform/common/utils/LymsEncodeUtil.java create mode 100644 platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java create mode 100644 platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MongoSyncController.java 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 new file mode 100644 index 0000000..205f032 --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java @@ -0,0 +1,54 @@ +package com.lyms.platform.biz.service; + +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.lyms.platform.common.utils.*; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.data.mongodb.core.query.Update; +import org.springframework.stereotype.Service; +import org.springframework.util.Assert; + +/** + * Created by Administrator on 2016/9/13 0013. + */ +@Service("mongoSyncService") +public class MongoSyncService { + + /** + * spring mongodb　集成操作类 + */ + @Autowired + protected MongoTemplate mongoTemplate; + + public static String mongo_crypto_key = Config.getItem("mongo_crypto_key", "0"); + + public boolean syncData(String action, String id, String className, String json) { + try { + if ("ADD".equals(action)) { + Object entity = JsonUtil.str2Obj(LymsEncodeUtil.aesDecrypt(json, mongo_crypto_key), Class.forName(LymsEncodeUtil.aesDecrypt(className, mongo_crypto_key))); + Assert.notNull(entity, "execute insert method must not null."); + mongoTemplate.save(entity); + return true; + } else if ("UPDATE".equals(action)) { + Class cla = Class.forName(LymsEncodeUtil.aesDecrypt(className, mongo_crypto_key)); + Object obj = JsonUtil.str2Obj(LymsEncodeUtil.aesDecrypt(json, mongo_crypto_key), cla); + Update update = MongoConvertHelper.convertToNativeUpdate(ReflectionUtils.getUpdateField(obj)); + Assert.notNull(update, "execute update method must not null."); + mongoTemplate.updateMulti(new MongoQuery(new MongoCondition("id", LymsEncodeUtil.aesDecrypt(id, mongo_crypto_key), MongoOper.IS)).convertToMongoQuery(), update, cla); + return true; + } else if ("DELETE".equals(action)) { + Class cla = Class.forName(LymsEncodeUtil.aesDecrypt(className, mongo_crypto_key)); + mongoTemplate.findAllAndRemove(new MongoQuery(new MongoCondition("id", LymsEncodeUtil.aesDecrypt(id, mongo_crypto_key), MongoOper.IS)).convertToMongoQuery(), cla); + return true; + } + return false; + } catch (Exception e) { + e.printStackTrace(); + return false; + } + } + + +} 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 44ef8e2..e8d2203 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 @@ -2,6 +2,7 @@ package com.lyms.platform.common.dao; import com.lyms.platform.common.dao.operator.Page; import com.lyms.platform.common.utils.MongoConvertHelper; +import com.lyms.platform.common.utils.MongoSyncUtil; import com.lyms.platform.common.utils.ReflectionUtils; import org.apache.commons.collections.CollectionUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -47,13 +48,19 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { Update update = MongoConvertHelper .convertToNativeUpdate(ReflectionUtils.getUpdateField(obj)); Assert.notNull(update, "execute update method must not null."); +// query.getQueryObject().get() mongoTemplate.updateMulti(query, update, this.getEntityClass()); + Object id = query.getQueryObject().get("id"); + if (id != null) { + MongoSyncUtil.sync("UPDATE", obj, id.toString()); + } } @Override public T save(T entity) { Assert.notNull(entity, "execute insert method must not null."); mongoTemplate.insert(entity); + MongoSyncUtil.sync("ADD", entity, ""); return entity; } @@ -97,6 +104,10 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { } public void delete(Query query) { + Object id = query.getQueryObject().get("id"); + if (id != null) { + MongoSyncUtil.sync("DELETE", "", id.toString()); + } mongoTemplate.findAllAndRemove(query, this.getEntityClass()); } public void delete(Query query,Class clazz) { diff --git a/platform-common/src/main/java/com/lyms/platform/common/utils/LymsEncodeUtil.java b/platform-common/src/main/java/com/lyms/platform/common/utils/LymsEncodeUtil.java new file mode 100644 index 0000000..c86175c --- /dev/null +++ b/platform-common/src/main/java/com/lyms/platform/common/utils/LymsEncodeUtil.java @@ -0,0 +1,152 @@ +package com.lyms.platform.common.utils; + +import org.apache.commons.lang.*; +import sun.misc.BASE64Decoder; +import sun.misc.BASE64Encoder; + +import javax.crypto.Cipher; +import javax.crypto.KeyGenerator; +import javax.crypto.spec.SecretKeySpec; +import java.math.BigInteger; +import java.security.MessageDigest; +import java.security.SecureRandom; + +/** + * Created by Administrator on 2016/9/13 0013. + */ +public class LymsEncodeUtil { + + public static void main(String[] args) throws Exception { + String content = "我爱你"; + System.out.println("加密前：" + content); + + String key = "123456"; + System.out.println("加密密钥和解密密钥：" + key); + + String encrypt = aesEncrypt(content, key); + System.out.println("加密后：" + encrypt); + + String decrypt = aesDecrypt(encrypt, key); + System.out.println("解密后：" + decrypt); + } + + /** + * 将byte[]转为各种进制的字符串 + * @param bytes byte[] + * @param radix 可以转换进制的范围，从Character.MIN_RADIX到Character.MAX_RADIX，超出范围后变为10进制 + * @return 转换后的字符串 + */ + public static String binary(byte[] bytes, int radix){ + return new BigInteger(1, bytes).toString(radix);// 这里的1代表正数 + } + + /** + * base 64 encode + * @param bytes 待编码的byte[] + * @return 编码后的base 64 code + */ + public static String base64Encode(byte[] bytes){ + return new BASE64Encoder().encode(bytes); + } + + /** + * base 64 decode + * @param base64Code 待解码的base 64 code + * @return 解码后的byte[] + * @throws Exception + */ + public static byte[] base64Decode(String base64Code) throws Exception{ + return StringUtils.isEmpty(base64Code) ? null : new BASE64Decoder().decodeBuffer(base64Code); + } + + /** + * 获取byte[]的md5值 + * @param bytes byte[] + * @return md5 + * @throws Exception + */ + public static byte[] md5(byte[] bytes) throws Exception { + MessageDigest md = MessageDigest.getInstance("MD5"); + md.update(bytes); + + return md.digest(); + } + + /** + * 获取字符串md5值 + * @param msg + * @return md5 + * @throws Exception + */ + public static byte[] md5(String msg) throws Exception { + return StringUtils.isEmpty(msg) ? null : md5(msg.getBytes()); + } + + /** + * 结合base64实现md5加密 + * @param msg 待加密字符串 + * @return 获取md5后转为base64 + * @throws Exception + */ + public static String md5Encrypt(String msg) throws Exception{ + return StringUtils.isEmpty(msg) ? null : base64Encode(md5(msg)); + } + + /** + * AES加密 + * @param content 待加密的内容 + * @param encryptKey 加密密钥 + * @return 加密后的byte[] + * @throws Exception + */ + public static byte[] aesEncryptToBytes(String content, String encryptKey) throws Exception { + KeyGenerator kgen = KeyGenerator.getInstance("AES"); + kgen.init(128, new SecureRandom(encryptKey.getBytes())); + + Cipher cipher = Cipher.getInstance("AES"); + cipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(kgen.generateKey().getEncoded(), "AES")); + + return cipher.doFinal(content.getBytes("utf-8")); + } + + /** + * AES加密为base 64 code + * @param content 待加密的内容 + * @param encryptKey 加密密钥 + * @return 加密后的base 64 code + * @throws Exception + */ + public static String aesEncrypt(String content, String encryptKey) throws Exception { + return base64Encode(aesEncryptToBytes(content, encryptKey)); + } + + /** + * AES解密 + * @param encryptBytes 待解密的byte[] + * @param decryptKey 解密密钥 + * @return 解密后的String + * @throws Exception + */ + public static String aesDecryptByBytes(byte[] encryptBytes, String decryptKey) throws Exception { + KeyGenerator kgen = KeyGenerator.getInstance("AES"); + kgen.init(128, new SecureRandom(decryptKey.getBytes())); + + Cipher cipher = Cipher.getInstance("AES"); + cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(kgen.generateKey().getEncoded(), "AES")); + byte[] decryptBytes = cipher.doFinal(encryptBytes); + + return new String(decryptBytes); + } + + /** + * 将base 64 code AES解密 + * @param encryptStr 待解密的base 64 code + * @param decryptKey 解密密钥 + * @return 解密后的string + * @throws Exception + */ + public static String aesDecrypt(String encryptStr, String decryptKey) throws Exception { + return StringUtils.isEmpty(encryptStr) ? null : aesDecryptByBytes(base64Decode(encryptStr), decryptKey); + } + +} 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 new file mode 100644 index 0000000..98736b6 --- /dev/null +++ b/platform-common/src/main/java/com/lyms/platform/common/utils/MongoSyncUtil.java @@ -0,0 +1,69 @@ +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. + */ +public class MongoSyncUtil { + + public static String mongo_sync = Config.getItem("mongo_sync", "0"); + public static String mongo_sync_url = Config.getItem("mongo_sync_url", "0"); + 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, Object data, String id) { + 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", LymsEncodeUtil.aesEncrypt(data.getClass().getName(), mongo_crypto_key)), + new NameValuePair("jsonData", LymsEncodeUtil.aesEncrypt(JsonUtil.obj2JsonString(data), mongo_crypto_key)), + new NameValuePair("id", LymsEncodeUtil.aesEncrypt(id, mongo_crypto_key)), + }; + post.setRequestBody(pairs); + client.executeMethod(post); + int statusCode = post.getStatusCode(); + post.releaseConnection(); + if (200 == statusCode) { + boo = true; + } + return boo; + } catch (Exception e) { + e.printStackTrace(); + return boo; + } + } + return true; + } + + public static void main(String[] a) throws Exception { + System.out.println(MongoSyncUtil.mongo_sync); + MongoSyncUtil util = new MongoSyncUtil(); + System.out.println(util.getClass().getName()); + PageInfo info = new PageInfo(); + info.setCount(123); + info.setLimit(456); + Object aaa = JsonUtil.str2Obj(JsonUtil.obj2JsonString(info), Class.forName(info.getClass().getName())); + System.out.println(MD5Utils.md5(aaa.getClass().getName())); + + } + +} diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MongoSyncController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MongoSyncController.java new file mode 100644 index 0000000..e2065be --- /dev/null +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MongoSyncController.java @@ -0,0 +1,37 @@ +package com.lyms.platform.operate.web.controller; + +import com.lyms.platform.biz.service.MongoSyncService; +import com.lyms.platform.common.base.BaseController; +import com.lyms.platform.common.utils.Config; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Controller; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestMethod; +import org.springframework.web.bind.annotation.ResponseBody; + +/** + * Created by Administrator on 2016/9/13 0013. + */ +@Controller +public class MongoSyncController extends BaseController { + + public static String mongo_sync_token = Config.getItem("mongo_sync_token", "0"); + + @Autowired + private MongoSyncService mongoSyncService; + + @ResponseBody + @RequestMapping(method = RequestMethod.POST,value = "/syncmongo") + public String syncmongo(String action, String token, String className, String jsonData, String id){ + if (StringUtils.isNotBlank(token) && mongo_sync_token.equals(token)) { + boolean boo = mongoSyncService.syncData(action,id, className, jsonData); + if (boo) { + return "success"; + } + return "fail"; + } + return "token vaild"; + } + +} diff --git a/platform-operate-api/src/main/resources/config.properties b/platform-operate-api/src/main/resources/config.properties index 30b762f..43c1d1a 100644 --- a/platform-operate-api/src/main/resources/config.properties +++ b/platform-operate-api/src/main/resources/config.properties @@ -5,4 +5,5 @@ center_base_url=http://sms.api.stage.platform.healthbaby.com.cn/v1/ center_token=e0c56363-00d6-42ee-bbe0-23c553583062 #His系统版本 0：未使用，1：桓台，2：新乐 -his_version=0 \ No newline at end of file +his_version=0 + diff --git a/platform-operate-api/src/main/resources/database.properties b/platform-operate-api/src/main/resources/database.properties index 6ed77f0..9f37816 100644 --- a/platform-operate-api/src/main/resources/database.properties +++ b/platform-operate-api/src/main/resources/database.properties @@ -58,4 +58,11 @@ report.initialpoolsize=2 report.minpoolsize=2 #添加管理员默认所属机构 -defaultAdminOrgId=203 \ No newline at end of file +defaultAdminOrgId=203 + + +#mongo数据是否上传 1：上传，0：不上传 +mongo_sync=0 +mongo_sync_url=http://mms.api.stage.platform.healthbaby.com.cn/syncmongo +mongo_sync_token=68884AD1832AB397E2F85F87FE371C74 +mongo_crypto_key=Lymsh@2016 \ No newline at end of file diff --git a/pom.xml b/pom.xml index 87d30ec..b175279 100644 --- a/pom.xml +++ b/pom.xml @@ -529,5 +529,6 @@ + -- 1.8.3.1