diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/IRecordsDao.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/IRecordsDao.java new file mode 100644 index 0000000..6c40784 --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/IRecordsDao.java @@ -0,0 +1,19 @@ +package com.lyms.platform.biz.dal; + +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.pojo.Records; + +import java.util.List; + +/** + * Created by Administrator on 2019/1/11. + */ +public interface IRecordsDao { + + public List queryRecordsList(MongoQuery query); + + public void deleteOneRecord(MongoQuery query); + + public void updateRecordsById(Records obj,String id); + +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/RecordsDaoImpl.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/RecordsDaoImpl.java new file mode 100644 index 0000000..67397ba --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/RecordsDaoImpl.java @@ -0,0 +1,32 @@ +package com.lyms.platform.biz.dal.impl; + +import com.lyms.platform.biz.dal.IRecordsDao; +import com.lyms.platform.common.dao.BaseMongoDAOImpl; +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.pojo.PostpartumRecords; +import com.lyms.platform.pojo.Records; +import org.springframework.stereotype.Repository; + +import java.util.List; + +/** + * Created by Administrator on 2019/1/11. + */ +@Repository("recordsDao") +public class RecordsDaoImpl extends BaseMongoDAOImpl implements IRecordsDao { + + public List queryRecordsList(MongoQuery query){ + return find(query.convertToMongoQuery()); + } + + public void deleteOneRecord(MongoQuery query){ + delete(query.convertToMongoQuery()); + } + + public void updateRecordsById(Records obj,String id){ + update(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), obj); + } + +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/RecordsService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/RecordsService.java new file mode 100644 index 0000000..cb2b056 --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/RecordsService.java @@ -0,0 +1,36 @@ +package com.lyms.platform.biz.service; + +import com.lyms.platform.biz.dal.IRecordsDao; +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.pojo.Records; +import com.lyms.platform.query.RecordsQuery; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.domain.Sort; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * Created by Administrator on 2019/1/11. + */ +@Service("recordsService") +public class RecordsService { + @Autowired + private IRecordsDao recordsDao; + + public List getBabySieveQuery(RecordsQuery recordsQuery){ + MongoQuery query = recordsQuery.convertToQuery(); + return recordsDao.queryRecordsList(query.addOrder(Sort.Direction.DESC, "created")); + } + + public void deleteOneRecord(RecordsQuery recordsQuery){ + MongoQuery query = recordsQuery.convertToQuery(); + recordsDao.deleteOneRecord(query); + } + + public void updateRecordsById(Records obj,String id){ + recordsDao.updateRecordsById(obj,id); + } + +} diff --git a/platform-dal/src/main/java/com/lyms/platform/pojo/Records.java b/platform-dal/src/main/java/com/lyms/platform/pojo/Records.java new file mode 100644 index 0000000..1b5864a --- /dev/null +++ b/platform-dal/src/main/java/com/lyms/platform/pojo/Records.java @@ -0,0 +1,139 @@ +package com.lyms.platform.pojo; + +import org.springframework.data.mongodb.core.mapping.Document; +import com.lyms.platform.beans.SerialIdEnum; + +/** + * Created by Administrator on 2019/1/11. + *产后观察记录详情 + */ +@Document(collection = "lyms_records") +public class Records { + private static final long serialVersionUID = SerialIdEnum.Records.getCid(); + private String id; + private String postId;//产后观察基本表ID + private String date;//时间 + private String tw;//体温 + private String xy;//血压 + private String mb;//脉搏 + private String xybhd;//血氧饱和度 + private String gd;//宫底 + private String cxl;//出血量 + private String pgjc;//膀胱检查 + private String hyqk;//会阴情况 + private String nz;//内诊 + private String fz;//附注 + private String qm;//签名 + + public String getPostId() { + return postId; + } + + public void setPostId(String postId) { + this.postId = postId; + } + + public String getDate() { + return date; + } + + public void setDate(String date) { + this.date = date; + } + + public String getTw() { + return tw; + } + + public void setTw(String tw) { + this.tw = tw; + } + + public String getXy() { + return xy; + } + + public void setXy(String xy) { + this.xy = xy; + } + + public String getMb() { + return mb; + } + + public void setMb(String mb) { + this.mb = mb; + } + + public String getXybhd() { + return xybhd; + } + + public void setXybhd(String xybhd) { + this.xybhd = xybhd; + } + + public String getGd() { + return gd; + } + + public void setGd(String gd) { + this.gd = gd; + } + + public String getCxl() { + return cxl; + } + + public void setCxl(String cxl) { + this.cxl = cxl; + } + + public String getPgjc() { + return pgjc; + } + + public void setPgjc(String pgjc) { + this.pgjc = pgjc; + } + + public String getHyqk() { + return hyqk; + } + + public void setHyqk(String hyqk) { + this.hyqk = hyqk; + } + + public String getNz() { + return nz; + } + + public void setNz(String nz) { + this.nz = nz; + } + + public String getFz() { + return fz; + } + + public void setFz(String fz) { + this.fz = fz; + } + + public String getQm() { + return qm; + } + + public void setQm(String qm) { + this.qm = qm; + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } +} diff --git a/platform-dal/src/main/java/com/lyms/platform/query/RecordsQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/RecordsQuery.java new file mode 100644 index 0000000..15f5ad4 --- /dev/null +++ b/platform-dal/src/main/java/com/lyms/platform/query/RecordsQuery.java @@ -0,0 +1,44 @@ +package com.lyms.platform.query; + +import com.lyms.platform.common.base.IConvertToNativeQuery; +import com.lyms.platform.common.dao.BaseQuery; +import com.lyms.platform.common.dao.operator.MongoCondition; +import com.lyms.platform.common.dao.operator.MongoOper; +import com.lyms.platform.common.dao.operator.MongoQuery; + +/** + * Created by Administrator on 2019/1/11. + * 产后观察记录详情查询模板 + */ +public class RecordsQuery extends BaseQuery implements IConvertToNativeQuery { + + private String id;//主键ID + private String postId;//产后观察基本表ID + + public MongoQuery convertToQuery() { + MongoCondition condition = MongoCondition.newInstance(); + if(null != id){ + condition = condition.and("id", id, MongoOper.IS); + } + if(null !=postId){ + condition = condition.and("postId", postId, MongoOper.IS); + } + return condition.toMongoQuery(); + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } + + public String getPostId() { + return postId; + } + + public void setPostId(String postId) { + this.postId = postId; + } +}