From b16681cd79a341946e41366499b4cf38c31fe90d Mon Sep 17 00:00:00 2001
From: jiangjiazhi <jiangjiazhi@lymsh.com>
Date: Thu, 25 Aug 2016 17:52:51 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../lyms/platform/biz/dal/impl/PatientDaoImpl.java  |  2 +-
 .../lyms/platform/common/dao/BaseMongoDAOImpl.java  | 21 +++++++++++++++++++--
 2 files changed, 20 insertions(+), 3 deletions(-)

diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/PatientDaoImpl.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/PatientDaoImpl.java
index dfd7f95..8ab4501 100644
--- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/PatientDaoImpl.java
+++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/PatientDaoImpl.java
@@ -32,7 +32,7 @@ public class PatientDaoImpl extends BaseMongoDAOImpl<Patients> implements IPatie
         return save(obj);
     }
     public void findAndModify(MongoQuery query,Patients obj){
-        findAndModify(query.convertToMongoQuery(),obj);
+        updateMulti(query.convertToMongoQuery(),obj);
     }
     @Override
     public void updatePatient(Patients obj, String id) {
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 00cbf91..f1f2d68 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
@@ -100,16 +100,33 @@ public class BaseMongoDAOImpl<T> implements BaseMongoDAO<T> {
         mongoTemplate.findAllAndRemove(query, this.getEntityClass());
     }
 
-
+    /**
+     * 修改找到的第一条数据
+     *
+     * @param query
+     * @param obj
+     */
     public void findAndModify(Query query,T obj){
         Assert.notNull(obj, "execute findAndModify method must not  null.");
         Update update = MongoConvertHelper
                 .convertToNativeUpdate(ReflectionUtils.getUpdateField(obj));
-        Assert.notNull(update, "execute findAndModify method must not  null.update:"+update);
+        Assert.notNull(update, "execute findAndModify method must not  null.update:" + update);
         mongoTemplate.findAndModify(query,update,this.getEntityClass());
     }
 
     /**
+     * 修改符合条件的所有数据
+     * @param query
+     * @param obj
+     */
+    public void updateMulti(Query query,T obj){
+        Assert.notNull(obj, "execute findAndModify method must not  null.");
+        Update update = MongoConvertHelper
+                .convertToNativeUpdate(ReflectionUtils.getUpdateField(obj));
+        Assert.notNull(update, "execute findAndModify method must not  null.update:" + update);
+        mongoTemplate.updateMulti(query,update,this.getEntityClass());
+    }
+    /**
      * 获取需要操作的实体类class
      *
      * @return
-- 
1.8.3.1