diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ITrackDownRecordDao.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ITrackDownRecordDao.java new file mode 100644 index 0000000..fc9a58e --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ITrackDownRecordDao.java @@ -0,0 +1,38 @@ +package com.lyms.platform.biz.dal; + +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.common.dao.operator.Page; +import com.lyms.platform.pojo.Patients; +import com.lyms.platform.pojo.TrackDownRecord; + +import java.util.List; + +/** + * 追访列表dao + *

+ * 详细描述 + *

+ * 示例代码 + *

+ * 
+ * + * @author JIAZHI.JIANG + * @version BME V100R001 2018/1/17 0017 + * @since BME V100R001C40B104 + */ +public interface ITrackDownRecordDao { + + TrackDownRecord addTrackDown(TrackDownRecord downRecord); + + void updateTrackDown(TrackDownRecord obj, String id); + + void deleteTrackDown(String id); + + TrackDownRecord getTrackDown(String id); + + int queryTrackDownCount(MongoQuery query); + + List queryTrackDown(MongoQuery query); + + Page findPage(MongoQuery query); +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/TrackDownRecordDaoImpl.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/TrackDownRecordDaoImpl.java new file mode 100644 index 0000000..a4b149c --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/TrackDownRecordDaoImpl.java @@ -0,0 +1,71 @@ +package com.lyms.platform.biz.dal.impl; + +import com.lyms.platform.biz.dal.ITrackDownRecordDao; +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.common.dao.operator.Page; +import com.lyms.platform.pojo.TrackDownRecord; +import org.bson.types.ObjectId; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.stereotype.Repository; + +import java.util.List; + + +/** + * 添加类的一句话简单描述。 + *

+ * 详细描述 + *

+ * 示例代码 + *

+ * 
+ * + * @author JIAZHI.JIANG + * @version BME V100R001 2018-01-17 16:26 + * @since BME V100R001C40B104 + */ +@Repository("trackDownRecordDao") +public class TrackDownRecordDaoImpl extends BaseMongoDAOImpl implements ITrackDownRecordDao { + + //日志调测器 + private static final Logger logger = LoggerFactory.getLogger(TrackDownRecordDaoImpl.class); + + @Override + public TrackDownRecord addTrackDown(TrackDownRecord downRecord) { + return save(downRecord); + } + + @Override + public void updateTrackDown(TrackDownRecord obj, String id) { + update(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), obj); + } + + @Override + public void deleteTrackDown(String id) { + delete(new MongoQuery(new MongoCondition("id", new ObjectId(id), MongoOper.IS)).convertToMongoQuery()); + } + + @Override + public TrackDownRecord getTrackDown(String id) { + return findById(id); + } + + @Override + public int queryTrackDownCount(MongoQuery query) { + return (int) count(query.convertToMongoQuery()); + } + + @Override + public List queryTrackDown(MongoQuery query) { + return find(query.convertToMongoQuery()); + } + + @Override + public Page findPage(MongoQuery query) { + return findPage(query.convertToMongoQuery()); + } +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/TrackDownRecordService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/TrackDownRecordService.java new file mode 100644 index 0000000..f91389b --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/TrackDownRecordService.java @@ -0,0 +1,70 @@ +package com.lyms.platform.biz.service; + +import com.lyms.platform.biz.dal.ITrackDownRecordDao; +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.pojo.TrackDownRecord; +import com.lyms.platform.query.TrackDownRecordQuery; +import org.apache.commons.lang.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.Date; +import java.util.List; + + +/** + * 添加类的一句话简单描述。 + *

+ * 详细描述 + *

+ * 示例代码 + *

+ * 
+ * + * @author JIAZHI.JIANG + * @version BME V100R001 2018-01-17 16:34 + * @since BME V100R001C40B104 + */ +@Service +public class TrackDownRecordService { + + //日志调测器 + private static final Logger logger = LoggerFactory.getLogger(TrackDownRecordService.class); + + @Autowired + private ITrackDownRecordDao iTrackDownRecordDao; + + public TrackDownRecord addTrackDown(TrackDownRecord downRecord) { + downRecord.setCreated(new Date()); + downRecord.setModified(new Date()); + return iTrackDownRecordDao.addTrackDown(downRecord); + } + + public void updateTrackDown(TrackDownRecord obj, String id) { + obj.setModified(new Date()); + iTrackDownRecordDao.updateTrackDown(obj, id); + } + + public void deleteTrackDown(String id) { + iTrackDownRecordDao.deleteTrackDown(id); + } + + public TrackDownRecord getTrackDown(String id) { + return iTrackDownRecordDao.getTrackDown(id); + } + + public int queryTrackDownCount(TrackDownRecordQuery query) { + return iTrackDownRecordDao.queryTrackDownCount(query.convertToQuery()); + } + + public List queryTrackDown(TrackDownRecordQuery query) { + MongoQuery query1 = query.convertToQuery(); + if (StringUtils.isNotEmpty(query.getNeed())) { + query.mysqlBuild(iTrackDownRecordDao.queryTrackDownCount(query1)); + query1.start(query.getOffset()).end(query.getLimit()); + } + return iTrackDownRecordDao.queryTrackDown(query1); + } +} \ No newline at end of file diff --git a/platform-dal/src/main/java/com/lyms/platform/pojo/TrackDownRecord.java b/platform-dal/src/main/java/com/lyms/platform/pojo/TrackDownRecord.java new file mode 100644 index 0000000..832454d --- /dev/null +++ b/platform-dal/src/main/java/com/lyms/platform/pojo/TrackDownRecord.java @@ -0,0 +1,203 @@ +package com.lyms.platform.pojo; + +import com.lyms.platform.common.result.BaseModel; +import org.springframework.data.mongodb.core.mapping.Document; + +import java.util.Date; + + +/** + * 追访列表的数据 + *

+ * 详细描述 + *

+ * 示例代码 + *

+ * 
+ * + * @author JIAZHI.JIANG + * @version BME V100R001 2018-01-17 15:35 + * @since BME V100R001C40B104 + */ +@Document(collection = "lyms_trackdown_record") +public class TrackDownRecord extends BaseModel{ + + private String id; + private String username; + private Date birth; + private String phone; + private String cardNo; + //末次月经 + private Date lastMenses; + /** + * 孕妇居住地 + */ + private String addressRegister; + private String provinceRegisterId; + private String cityRegisterId; + private String areaRegisterId; + private String streetRegisterId; + + private String parentId; + private String pid; + private Date modified; + private String hospitalId; + private Date created; + //这条数据的状态 + private Integer status; + private Integer trackType; + //是否还在这个列表显示 + private Integer done; + + public Integer getTrackType() { + return trackType; + } + + public void setTrackType(Integer trackType) { + this.trackType = trackType; + } + + public String getId() { + return id; + } + + public Date getLastMenses() { + return lastMenses; + } + + public void setLastMenses(Date lastMenses) { + this.lastMenses = lastMenses; + } + + public void setId(String id) { + this.id = id; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public Date getBirth() { + return birth; + } + + public void setBirth(Date birth) { + this.birth = birth; + } + + public String getPhone() { + return phone; + } + + public void setPhone(String phone) { + this.phone = phone; + } + + public String getCardNo() { + return cardNo; + } + + public void setCardNo(String cardNo) { + this.cardNo = cardNo; + } + + public String getAddressRegister() { + return addressRegister; + } + + public void setAddressRegister(String addressRegister) { + this.addressRegister = addressRegister; + } + + public String getProvinceRegisterId() { + return provinceRegisterId; + } + + public void setProvinceRegisterId(String provinceRegisterId) { + this.provinceRegisterId = provinceRegisterId; + } + + public String getCityRegisterId() { + return cityRegisterId; + } + + public void setCityRegisterId(String cityRegisterId) { + this.cityRegisterId = cityRegisterId; + } + + public String getAreaRegisterId() { + return areaRegisterId; + } + + public void setAreaRegisterId(String areaRegisterId) { + this.areaRegisterId = areaRegisterId; + } + + public String getStreetRegisterId() { + return streetRegisterId; + } + + public void setStreetRegisterId(String streetRegisterId) { + this.streetRegisterId = streetRegisterId; + } + + public String getParentId() { + return parentId; + } + + public void setParentId(String parentId) { + this.parentId = parentId; + } + + public String getPid() { + return pid; + } + + public void setPid(String pid) { + this.pid = pid; + } + + public Date getModified() { + return modified; + } + + public void setModified(Date modified) { + this.modified = modified; + } + + public String getHospitalId() { + return hospitalId; + } + + public void setHospitalId(String hospitalId) { + this.hospitalId = hospitalId; + } + + public Date getCreated() { + return created; + } + + public void setCreated(Date created) { + this.created = created; + } + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + + public Integer getDone() { + return done; + } + + public void setDone(Integer done) { + this.done = done; + } +} diff --git a/platform-dal/src/main/java/com/lyms/platform/query/TrackDownRecordQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/TrackDownRecordQuery.java new file mode 100644 index 0000000..3fd604c --- /dev/null +++ b/platform-dal/src/main/java/com/lyms/platform/query/TrackDownRecordQuery.java @@ -0,0 +1,136 @@ +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; +import org.apache.commons.collections.CollectionUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.util.List; + + +/** + * 添加类的一句话简单描述。 + *

+ * 详细描述 + *

+ * 示例代码 + *

+ * 
+ * + * @author JIAZHI.JIANG + * @version BME V100R001 2018-01-17 16:30 + * @since BME V100R001C40B104 + */ +public class TrackDownRecordQuery extends BaseQuery implements IConvertToNativeQuery { + private String provinceId; + private String cityId; + private String areaId; + private String streetId; + private String key; + private Integer trackType; + private String parentId; + private List pids; + private String hospitalId; + + public String getHospitalId() { + return hospitalId; + } + + public void setHospitalId(String hospitalId) { + this.hospitalId = hospitalId; + } + + public String getParentId() { + return parentId; + } + + public void setParentId(String parentId) { + this.parentId = parentId; + } + + public List getPids() { + return pids; + } + + public void setPids(List pids) { + this.pids = pids; + } + + public String getProvinceId() { + return provinceId; + } + + public void setProvinceId(String provinceId) { + this.provinceId = provinceId; + } + + public String getCityId() { + return cityId; + } + + public void setCityId(String cityId) { + this.cityId = cityId; + } + + public String getAreaId() { + return areaId; + } + + public void setAreaId(String areaId) { + this.areaId = areaId; + } + + public String getStreetId() { + return streetId; + } + + public void setStreetId(String streetId) { + this.streetId = streetId; + } + + public String getKey() { + return key; + } + + public void setKey(String key) { + this.key = key; + } + + public Integer getTrackType() { + return trackType; + } + + public void setTrackType(Integer trackType) { + this.trackType = trackType; + } + @Override + public MongoQuery convertToQuery() { + MongoCondition condition=MongoCondition.newInstance(); + if(null!=provinceId){ + condition= condition.and("provinceId",provinceId, MongoOper.IS); + } + if(null!=cityId){ + condition= condition.and("cityId",cityId, MongoOper.IS); + } + if(null!=areaId){ + condition= condition.and("areaId",areaId, MongoOper.IS); + } + if(null!=areaId){ + condition= condition.and("hospitalId",hospitalId, MongoOper.IS); + } + if(null!=streetId){ + condition = condition.and("streetId", streetId, MongoOper.IS); + } + if(null!=parentId){ + condition = condition.and("parentId", parentId, MongoOper.IS); + } + if (null != pids) { + condition = condition.and("pid", pids, MongoOper.IN); + } + return condition.toMongoQuery(); + } +}