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 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 implements BaseMongoDAO { 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