Commit e433e10a9ec1a06d8b0a95e2bc1b1bfad924f1eb
Exists in
master
and in
8 other branches
Merge remote-tracking branch 'origin/master'
Showing 6 changed files
- platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/IEmergenceTreatmentDao.java
- platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/EmergenceTreatmentDaoImpl.java
- platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/EmergenceTreatmentService.java
- platform-dal/src/main/java/com/lyms/platform/pojo/EmergenceTreatmentModel.java
- platform-dal/src/main/java/com/lyms/platform/query/EmergenceTreatmentQuery.java
- platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/EmergenceController.java
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/IEmergenceTreatmentDao.java
View file @
e433e10
1 | +package com.lyms.platform.biz.dal; | |
2 | + | |
3 | + | |
4 | +import com.lyms.platform.common.dao.operator.MongoQuery; | |
5 | +import com.lyms.platform.pojo.EmergenceTreatmentModel; | |
6 | + | |
7 | +import java.util.List; | |
8 | + | |
9 | +/** | |
10 | + * Created by Administrator on 2016/10/13 0013. | |
11 | + */ | |
12 | +public interface IEmergenceTreatmentDao { | |
13 | + | |
14 | + public EmergenceTreatmentModel getEmergenceTreatmentModel(String id); | |
15 | + | |
16 | + public void addEmergenceTreatmentModel(EmergenceTreatmentModel emergenceTreatmentModel); | |
17 | + | |
18 | + public void updateEmergenceTreatmentModel(EmergenceTreatmentModel emergenceTreatmentModel,String id); | |
19 | + | |
20 | + public void deleteEmergenceTreatmentModel(String id); | |
21 | + | |
22 | + public List<EmergenceTreatmentModel> queryEmergenceTreatmentModel(MongoQuery query); | |
23 | + | |
24 | + public int queryEmergenceTreatmentModelCount(MongoQuery query); | |
25 | + | |
26 | +} |
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/EmergenceTreatmentDaoImpl.java
View file @
e433e10
1 | +package com.lyms.platform.biz.dal.impl; | |
2 | + | |
3 | +import com.lyms.platform.biz.dal.IEmergenceTreatmentDao; | |
4 | +import com.lyms.platform.common.dao.BaseMongoDAOImpl; | |
5 | +import com.lyms.platform.common.dao.operator.MongoCondition; | |
6 | +import com.lyms.platform.common.dao.operator.MongoOper; | |
7 | +import com.lyms.platform.common.dao.operator.MongoQuery; | |
8 | +import com.lyms.platform.pojo.EmergenceTreatmentModel; | |
9 | +import org.springframework.stereotype.Repository; | |
10 | + | |
11 | +import java.util.List; | |
12 | + | |
13 | +/** | |
14 | + * Created by Administrator on 2016/10/13 0013. | |
15 | + */ | |
16 | +@Repository("emergenceTreatmentDao") | |
17 | +public class EmergenceTreatmentDaoImpl extends BaseMongoDAOImpl<EmergenceTreatmentModel> implements IEmergenceTreatmentDao{ | |
18 | + @Override | |
19 | + public EmergenceTreatmentModel getEmergenceTreatmentModel(String id) { | |
20 | + return findById(id); | |
21 | + } | |
22 | + | |
23 | + @Override | |
24 | + public int queryEmergenceTreatmentModelCount(MongoQuery query) { | |
25 | + return (int)count(query.convertToMongoQuery()); | |
26 | + } | |
27 | + | |
28 | + @Override | |
29 | + public void addEmergenceTreatmentModel(EmergenceTreatmentModel obj) { | |
30 | + save(obj); | |
31 | + } | |
32 | + | |
33 | + @Override | |
34 | + public void updateEmergenceTreatmentModel(EmergenceTreatmentModel obj,String id) { | |
35 | + update(new MongoQuery(new MongoCondition("id",id, MongoOper.IS)).convertToMongoQuery(),obj); | |
36 | + } | |
37 | + | |
38 | + @Override | |
39 | + public void deleteEmergenceTreatmentModel(String id) { | |
40 | + delete(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery()); | |
41 | + } | |
42 | + | |
43 | + @Override | |
44 | + public List<EmergenceTreatmentModel> queryEmergenceTreatmentModel(MongoQuery query) { | |
45 | + return find(query.convertToMongoQuery()); | |
46 | + } | |
47 | +} |
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/EmergenceTreatmentService.java
View file @
e433e10
1 | +package com.lyms.platform.biz.service; | |
2 | + | |
3 | +import com.lyms.platform.biz.dal.IEmergenceTreatmentDao; | |
4 | +import com.lyms.platform.common.dao.operator.MongoCondition; | |
5 | +import com.lyms.platform.common.dao.operator.MongoQuery; | |
6 | +import com.lyms.platform.pojo.EmergenceTreatmentModel; | |
7 | +import com.lyms.platform.query.EmergenceTreatmentQuery; | |
8 | +import org.apache.commons.lang.StringUtils; | |
9 | +import org.springframework.beans.factory.annotation.Autowired; | |
10 | +import org.springframework.data.domain.Sort; | |
11 | +import org.springframework.stereotype.Service; | |
12 | + | |
13 | +import java.util.List; | |
14 | + | |
15 | +/** | |
16 | + * Created by Administrator on 2016/10/13 0013. | |
17 | + */ | |
18 | +@Service | |
19 | +public class EmergenceTreatmentService { | |
20 | + | |
21 | + @Autowired | |
22 | + private IEmergenceTreatmentDao emergenceTreatmentDao; | |
23 | + | |
24 | + public EmergenceTreatmentModel getEmergenceTreatmentModel(String id){ | |
25 | + return emergenceTreatmentDao.getEmergenceTreatmentModel(id); | |
26 | + } | |
27 | + | |
28 | + public void addEmergenceTreatmentModel(EmergenceTreatmentModel obj){ | |
29 | + emergenceTreatmentDao.addEmergenceTreatmentModel(obj); | |
30 | + } | |
31 | + | |
32 | + public void updateEmergenceTreatmentModel(EmergenceTreatmentModel obj,String id){ | |
33 | + emergenceTreatmentDao.updateEmergenceTreatmentModel(obj,id); | |
34 | + } | |
35 | + | |
36 | + public void deleteEmergenceTreatmentModel(String id){ | |
37 | + emergenceTreatmentDao.deleteEmergenceTreatmentModel(id); | |
38 | + } | |
39 | + | |
40 | + public List<EmergenceTreatmentModel> queryEmergenceTreatmentModel(EmergenceTreatmentQuery query){ | |
41 | + MongoQuery mongoQuery = query.convertToQuery(); | |
42 | + if (StringUtils.isNotEmpty(query.getNeed())){ | |
43 | + query.mysqlBuild(emergenceTreatmentDao.queryEmergenceTreatmentModelCount(query.convertToQuery())); | |
44 | + mongoQuery.start(query.getOffset()).end(query.getLimit()); | |
45 | + } | |
46 | + return emergenceTreatmentDao.queryEmergenceTreatmentModel(mongoQuery.addOrder(Sort.Direction.DESC, "id")); | |
47 | + } | |
48 | + | |
49 | +} |
platform-dal/src/main/java/com/lyms/platform/pojo/EmergenceTreatmentModel.java
View file @
e433e10
1 | +package com.lyms.platform.pojo; | |
2 | + | |
3 | +import com.lyms.platform.common.result.BaseModel; | |
4 | +import org.springframework.data.mongodb.core.mapping.Document; | |
5 | + | |
6 | +import java.util.Date; | |
7 | + | |
8 | +/** | |
9 | + * 危急治疗意见 | |
10 | + * | |
11 | + * Created by Administrator on 2016/10/13 0013. | |
12 | + */ | |
13 | +@Document(collection = "lyms_emergence_treatment") | |
14 | +public class EmergenceTreatmentModel extends BaseModel{ | |
15 | + | |
16 | + private String id; | |
17 | + //处理内容 | |
18 | + private String content; | |
19 | + //患者危急信息ID | |
20 | + private String emergenceId; | |
21 | + //状态 | |
22 | + private Integer status; | |
23 | + //状态名称 | |
24 | + private String statusName; | |
25 | + //处理医生 | |
26 | + private String doctorName; | |
27 | + | |
28 | + private Integer yn; | |
29 | + private Date modified; | |
30 | + private Date created; | |
31 | + | |
32 | + public String getId() { | |
33 | + return id; | |
34 | + } | |
35 | + | |
36 | + public void setId(String id) { | |
37 | + this.id = id; | |
38 | + } | |
39 | + | |
40 | + public String getContent() { | |
41 | + return content; | |
42 | + } | |
43 | + | |
44 | + public void setContent(String content) { | |
45 | + this.content = content; | |
46 | + } | |
47 | + | |
48 | + public String getEmergenceId() { | |
49 | + return emergenceId; | |
50 | + } | |
51 | + | |
52 | + public void setEmergenceId(String emergenceId) { | |
53 | + this.emergenceId = emergenceId; | |
54 | + } | |
55 | + | |
56 | + public Integer getStatus() { | |
57 | + return status; | |
58 | + } | |
59 | + | |
60 | + public void setStatus(Integer status) { | |
61 | + this.status = status; | |
62 | + } | |
63 | + | |
64 | + public String getStatusName() { | |
65 | + return statusName; | |
66 | + } | |
67 | + | |
68 | + public void setStatusName(String statusName) { | |
69 | + this.statusName = statusName; | |
70 | + } | |
71 | + | |
72 | + public String getDoctorName() { | |
73 | + return doctorName; | |
74 | + } | |
75 | + | |
76 | + public void setDoctorName(String doctorName) { | |
77 | + this.doctorName = doctorName; | |
78 | + } | |
79 | + | |
80 | + public Integer getYn() { | |
81 | + return yn; | |
82 | + } | |
83 | + | |
84 | + public void setYn(Integer yn) { | |
85 | + this.yn = yn; | |
86 | + } | |
87 | + | |
88 | + public Date getModified() { | |
89 | + return modified; | |
90 | + } | |
91 | + | |
92 | + public void setModified(Date modified) { | |
93 | + this.modified = modified; | |
94 | + } | |
95 | + | |
96 | + public Date getCreated() { | |
97 | + return created; | |
98 | + } | |
99 | + | |
100 | + public void setCreated(Date created) { | |
101 | + this.created = created; | |
102 | + } | |
103 | +} |
platform-dal/src/main/java/com/lyms/platform/query/EmergenceTreatmentQuery.java
View file @
e433e10
1 | +package com.lyms.platform.query; | |
2 | + | |
3 | +import com.lyms.platform.common.base.IConvertToNativeQuery; | |
4 | +import com.lyms.platform.common.dao.BaseQuery; | |
5 | +import com.lyms.platform.common.dao.operator.MongoCondition; | |
6 | +import com.lyms.platform.common.dao.operator.MongoOper; | |
7 | +import com.lyms.platform.common.dao.operator.MongoQuery; | |
8 | +import org.apache.commons.lang.StringUtils; | |
9 | + | |
10 | +import java.util.Date; | |
11 | + | |
12 | +/** | |
13 | + * Created by Administrator on 2016/10/13 0013. | |
14 | + */ | |
15 | +public class EmergenceTreatmentQuery extends BaseQuery implements IConvertToNativeQuery { | |
16 | + | |
17 | + private String id; | |
18 | + //处理内容 | |
19 | + private String content; | |
20 | + //患者危急信息ID | |
21 | + private String emergenceId; | |
22 | + //状态 | |
23 | + private Integer status; | |
24 | + //状态名称 | |
25 | + private String statusName; | |
26 | + //处理医生 | |
27 | + private String doctorName; | |
28 | + | |
29 | + private Integer yn; | |
30 | + private Date modified; | |
31 | + private Date created; | |
32 | + | |
33 | + public String getId() { | |
34 | + return id; | |
35 | + } | |
36 | + | |
37 | + public void setId(String id) { | |
38 | + this.id = id; | |
39 | + } | |
40 | + | |
41 | + public String getContent() { | |
42 | + return content; | |
43 | + } | |
44 | + | |
45 | + public void setContent(String content) { | |
46 | + this.content = content; | |
47 | + } | |
48 | + | |
49 | + public String getEmergenceId() { | |
50 | + return emergenceId; | |
51 | + } | |
52 | + | |
53 | + public void setEmergenceId(String emergenceId) { | |
54 | + this.emergenceId = emergenceId; | |
55 | + } | |
56 | + | |
57 | + public Integer getStatus() { | |
58 | + return status; | |
59 | + } | |
60 | + | |
61 | + public void setStatus(Integer status) { | |
62 | + this.status = status; | |
63 | + } | |
64 | + | |
65 | + public String getStatusName() { | |
66 | + return statusName; | |
67 | + } | |
68 | + | |
69 | + public void setStatusName(String statusName) { | |
70 | + this.statusName = statusName; | |
71 | + } | |
72 | + | |
73 | + public String getDoctorName() { | |
74 | + return doctorName; | |
75 | + } | |
76 | + | |
77 | + public void setDoctorName(String doctorName) { | |
78 | + this.doctorName = doctorName; | |
79 | + } | |
80 | + | |
81 | + public Integer getYn() { | |
82 | + return yn; | |
83 | + } | |
84 | + | |
85 | + public void setYn(Integer yn) { | |
86 | + this.yn = yn; | |
87 | + } | |
88 | + | |
89 | + public Date getModified() { | |
90 | + return modified; | |
91 | + } | |
92 | + | |
93 | + public void setModified(Date modified) { | |
94 | + this.modified = modified; | |
95 | + } | |
96 | + | |
97 | + public Date getCreated() { | |
98 | + return created; | |
99 | + } | |
100 | + | |
101 | + public void setCreated(Date created) { | |
102 | + this.created = created; | |
103 | + } | |
104 | + | |
105 | + @Override | |
106 | + public MongoQuery convertToQuery() { | |
107 | + MongoCondition condition = MongoCondition.newInstance(); | |
108 | + if (StringUtils.isNotEmpty(id)) { | |
109 | + condition = condition.and("id", id, MongoOper.IS); | |
110 | + } | |
111 | + if (StringUtils.isNotEmpty(content)) { | |
112 | + condition = condition.and("content", content, MongoOper.IS); | |
113 | + } | |
114 | + if (StringUtils.isNotEmpty(emergenceId)) { | |
115 | + condition = condition.and("emergenceId", emergenceId, MongoOper.IS); | |
116 | + } | |
117 | + if (null != status) { | |
118 | + condition = condition.and("status", status, MongoOper.IS); | |
119 | + } | |
120 | + if (StringUtils.isNotEmpty(statusName)) { | |
121 | + condition = condition.and("statusName", statusName, MongoOper.IS); | |
122 | + } | |
123 | + if (StringUtils.isNotEmpty(doctorName)) { | |
124 | + condition = condition.and("doctorName", doctorName, MongoOper.IS); | |
125 | + } | |
126 | + if (null != yn) { | |
127 | + condition = condition.and("yn", yn, MongoOper.IS); | |
128 | + } | |
129 | + if (null != modified) { | |
130 | + condition = condition.and("modified", modified, MongoOper.IS); | |
131 | + } | |
132 | + if (null != created) { | |
133 | + condition = condition.and("created", created, MongoOper.IS); | |
134 | + } | |
135 | + | |
136 | + return condition.toMongoQuery(); | |
137 | + | |
138 | + } | |
139 | +} |
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/EmergenceController.java
View file @
e433e10
1 | +package com.lyms.platform.operate.web.controller; | |
2 | + | |
3 | +import com.lyms.platform.biz.service.EmergenceTreatmentService; | |
4 | +import com.lyms.platform.biz.service.LisCrisisItemService; | |
5 | +import com.lyms.platform.common.annotation.TokenRequired; | |
6 | +import com.lyms.platform.common.base.BaseController; | |
7 | +import com.lyms.platform.common.base.LoginContext; | |
8 | +import com.lyms.platform.common.constants.ErrorCodeConstants; | |
9 | +import com.lyms.platform.common.enums.YnEnums; | |
10 | +import com.lyms.platform.common.utils.DateUtil; | |
11 | +import com.lyms.platform.common.utils.JsonUtil; | |
12 | +import com.lyms.platform.common.utils.ResultUtils; | |
13 | +import com.lyms.platform.operate.web.request.EmergenceTreatmentRequest; | |
14 | +import com.lyms.platform.operate.web.utils.PatientRelateMemberUtil; | |
15 | +import com.lyms.platform.permission.model.Users; | |
16 | +import com.lyms.platform.permission.service.UsersService; | |
17 | +import com.lyms.platform.pojo.EmergenceTreatmentModel; | |
18 | +import com.lyms.platform.pojo.LisCrisisItem; | |
19 | +import com.lyms.platform.query.EmergenceTreatmentQuery; | |
20 | +import org.apache.commons.collections.CollectionUtils; | |
21 | +import org.apache.commons.lang.StringUtils; | |
22 | +import org.springframework.beans.factory.annotation.Autowired; | |
23 | +import org.springframework.stereotype.Controller; | |
24 | +import org.springframework.web.bind.annotation.RequestMapping; | |
25 | +import org.springframework.web.bind.annotation.RequestMethod; | |
26 | +import org.springframework.web.bind.annotation.RequestParam; | |
27 | + | |
28 | +import javax.servlet.http.HttpServletRequest; | |
29 | +import javax.servlet.http.HttpServletResponse; | |
30 | +import javax.validation.Valid; | |
31 | +import java.util.*; | |
32 | + | |
33 | +/** | |
34 | + * | |
35 | + * 患者危急接口 | |
36 | + * | |
37 | + * Created by Administrator on 2016/10/13 0013. | |
38 | + */ | |
39 | +@Controller | |
40 | +public class EmergenceController extends BaseController{ | |
41 | + | |
42 | + @Autowired | |
43 | + private EmergenceTreatmentService emergenceTreatmentService; | |
44 | + @Autowired | |
45 | + private UsersService usersService; | |
46 | + @Autowired | |
47 | + private LisCrisisItemService lisCrisisItemService; | |
48 | + | |
49 | + | |
50 | + /** | |
51 | + * 危急处理 | |
52 | + * @param request | |
53 | + */ | |
54 | + @RequestMapping(value = "/emergenceTreatments", method = RequestMethod.POST) | |
55 | +// @TokenRequired | |
56 | + public void addDepartments(HttpServletRequest request, | |
57 | + @RequestParam("id") String emergenceId, | |
58 | + @RequestParam("content") String content, | |
59 | + @RequestParam("status") String status, | |
60 | + @RequestParam(value = "message", required = false) String message) { | |
61 | + Map<String, Object> map = new HashMap<>(); | |
62 | + //判断emergenceId是否存在 | |
63 | + LisCrisisItem crisisItem = new LisCrisisItem(); | |
64 | + crisisItem.setId(emergenceId); | |
65 | + | |
66 | + | |
67 | + //拿到登录用户的ID | |
68 | + LoginContext loginState = (LoginContext) request.getAttribute("loginContext"); | |
69 | + Users users = usersService.getUsers(loginState.getId()); | |
70 | + if (users==null || users.getYn()==YnEnums.NO.getId()){ | |
71 | + map.put("errorcode",ErrorCodeConstants.PARAMETER_ERROR); | |
72 | + map.put("errormsg","用户不存在"); | |
73 | + return; | |
74 | + } | |
75 | + | |
76 | + // | |
77 | + EmergenceTreatmentModel model = new EmergenceTreatmentModel(); | |
78 | + model.setEmergenceId(emergenceId); | |
79 | + model.setYn(YnEnums.YES.getId()); | |
80 | + model.setCreated(new Date()); | |
81 | + model.setModified(new Date()); | |
82 | + | |
83 | + model.setDoctorName(users.getName()); | |
84 | + | |
85 | + //修改危急信息的状态和处理信息的状态 | |
86 | + | |
87 | + //当状态code和状态名称,危急信息的Messages不为null时,修改危急信息数据 | |
88 | + | |
89 | + | |
90 | + //找到患者,拿到她的手机号,发送短信 | |
91 | + | |
92 | + | |
93 | + //找到患者对应的用户,发送推送 | |
94 | + | |
95 | + } | |
96 | + | |
97 | + | |
98 | + /** | |
99 | + * | |
100 | + * 危急跟踪,获取危急意见 | |
101 | + * | |
102 | + */ | |
103 | + @RequestMapping(value = "/emergenceTreatments", method = RequestMethod.GET) | |
104 | +// @TokenRequired | |
105 | + public void getEmergenceTreatments(HttpServletResponse response, | |
106 | + @Valid EmergenceTreatmentRequest emergenceTreatmentRequest) { | |
107 | + | |
108 | +// EmergenceTreatmentModel model = new EmergenceTreatmentModel(); | |
109 | +// model.setYn(YnEnums.YES.getId()); | |
110 | +// model.setCreated(new Date()); | |
111 | +// model.setModified(new Date()); | |
112 | +// model.setEmergenceId("12345678"); | |
113 | +// model.setContent("快来检查"); | |
114 | +// model.setStatus(1); | |
115 | +// model.setStatusName("待处理"); | |
116 | +// model.setDoctorName("王医生"); | |
117 | +// emergenceTreatmentService.addEmergenceTreatmentModel(model); | |
118 | + | |
119 | + System.out.println("emergenceTreatmentService :" + emergenceTreatmentService); | |
120 | + | |
121 | + | |
122 | + String emergenceId = null; | |
123 | + | |
124 | + if (StringUtils.isNotEmpty(emergenceTreatmentRequest.getId())){ | |
125 | + //判断emergenceId是否存在 | |
126 | + emergenceId = emergenceTreatmentRequest.getId(); | |
127 | + } | |
128 | + | |
129 | + //查询满足条件的数据 | |
130 | + EmergenceTreatmentQuery query = new EmergenceTreatmentQuery(); | |
131 | + query.setEmergenceId(emergenceTreatmentRequest.getId()); | |
132 | + query.setPage(emergenceTreatmentRequest.getPage()); | |
133 | + query.setLimit(emergenceTreatmentRequest.getLimit()); | |
134 | + query.setYn(YnEnums.YES.getId()); | |
135 | + query.setNeed("y"); | |
136 | + | |
137 | + List<Map> list = new ArrayList<>(); | |
138 | + | |
139 | + List<EmergenceTreatmentModel> modelList = emergenceTreatmentService.queryEmergenceTreatmentModel(query); | |
140 | + if (CollectionUtils.isNotEmpty(modelList)){ | |
141 | + for (EmergenceTreatmentModel data : modelList){ | |
142 | + Map<String, Object> emergence = new HashMap<>(); | |
143 | + emergence.put("id", data.getId()); | |
144 | + emergence.put("content", data.getContent()); | |
145 | + emergence.put("status", data.getStatus()); | |
146 | + emergence.put("statusName", data.getStatusName()); | |
147 | + emergence.put("emergenceId", data.getEmergenceId()); | |
148 | + emergence.put("doctorName", data.getDoctorName()); | |
149 | + emergence.put("created", DateUtil.getSecond(data.getCreated())); | |
150 | + list.add(emergence); | |
151 | + } | |
152 | + } | |
153 | + ResultUtils.buildSuccessResultAndWrite(response, list); | |
154 | + } | |
155 | +} |