From 66fa6b72a6251f38040f712e280e25e258232747 Mon Sep 17 00:00:00 2001
From: liquanyu <liquanyu@lymsh.com>
Date: Wed, 9 Sep 2020 16:01:06 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../platform/biz/service/MongoSyncService.java     | 25 +++++++++++++++
 .../operate/web/controller/TestController.java     | 37 ++--------------------
 2 files changed, 27 insertions(+), 35 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 4bd58a5..d23d4ef 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
@@ -3,12 +3,14 @@ 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.enums.YnEnums;
 import com.lyms.platform.common.pojo.UpdateMultiData;
 import com.lyms.platform.common.utils.*;
 import com.lyms.platform.pojo.*;
 import com.mongodb.Mongo;
 import com.mongodb.WriteResult;
 import org.apache.commons.codec.binary.Base64;
+import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.lang.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -110,6 +112,29 @@ public class MongoSyncService {
                 Update update = MongoConvertHelper.convertToNativeUpdate(ReflectionUtils.getUpdateField(obj));
                 Assert.notNull(update, "execute update method must not  null.");
                 WriteResult result = mongoTemplate.upsert(new MongoQuery(new MongoCondition("id", LymsEncodeUtil.aesDecrypt(id, mongo_crypto_key), MongoOper.IS)).convertToMongoQuery(), update, cla);
+
+                //解决衡水问题
+                try {
+
+                    if ("com.lyms.platform.pojo.Patients".equals(cla.getName()))
+                    {
+                        Patients pat =  (Patients)obj;
+                        PersonModel pmodel = new PersonModel();
+                        pmodel.setId(pat.getPid());
+                        pmodel.setName(pat.getUsername());
+                        pmodel.setBirth(pat.getBirth());
+                        pmodel.setPhone(pat.getPhone());
+                        pmodel.setCardNo(pat.getCardNo());
+                        pmodel.setType(pat.getType());
+                        pmodel.setModified(pat.getModified());
+                        pmodel.setYn(YnEnums.YES.getId());
+                        pmodel.setCreated(pat.getCreated());
+                        mongoTemplate.save(pmodel);
+                    }
+                }catch (Exception e)
+                {
+                    System.out.println(e.toString());
+                }
                 return true;
             } else if ("DELETE".equals(action)) {
                 Class cla = Class.forName(LymsEncodeUtil.aesDecrypt(className, mongo_crypto_key));
diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
index e366f3b..441a8d6 100644
--- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
+++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/TestController.java
@@ -1569,41 +1569,8 @@ public class TestController extends BaseController {
 
 
     public static void main(String[] a) throws Exception {
-        Mongo mongo = new Mongo("119.90.57.26", 10001);
-        UserCredentials credentials = new UserCredentials("platform", "platform123");
-        MongoTemplate mongoTemplate = new MongoTemplate(mongo, "platform", credentials);
-        PatientWeight pw = mongoTemplate.findById("123", PatientWeight.class);
-        Map<String, String> s = new HashMap<>();
-        s.put("name", "1");
-        s.put("name2", "12");
-        pw.setDayWeights(s);
-        String json = JSON.toJSONString(pw);
-        String clazz = "com.lyms.platform.pojo.PatientWeight";
-        JSON.parseObject(json, Class.forName(clazz));
-        mongoTemplate.save(pw);
-
-       /* try {
-            List<String> list = FileUtils.readLines(new File("D:\\QHD.csv"), "gbk");
-            List<String> linenums = new ArrayList<>();
-            for (String line : list) {
-                String ss[] = line.split(",");
-                if (ss.length > 0 && ss[0].trim().length() > 0) {
-                    System.out.println(ss[0] + "   " + ss[1]);
-                }
-            }
-//            List<String> list1 = FileUtils.readLines(new File("D:\\temp\\qhd-jd.csv"), "utf-8");
-//            StringBuffer sb = new StringBuffer();
-//            for (String line:list1) {
-//                String ss[] = line.split(",");
-//                if (ss.length > 0 && ss[0].trim().length() > 0 && linenums.contains(ss[0].trim())) {
-//                    sb.append(line);
-//                    sb.append("\r\n");
-//                }
-//            }
-//            FileUtils.writeStringToFile(new File("d:\\temp\\qhdfy_lost_data.csv"), sb.toString());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }*/
+        Class clazz = Patients.class;
+        System.out.println(clazz.getName());
     }
 
     @RequestMapping("/poll")
-- 
1.8.3.1