jiangjiazhi / regional-platform

Commit 5728bd0643e6a9e414f5b835a701fd509e45b676

Authored by wtt about 5 years ago

Exists in master and in 6 other branches

秦皇岛儿童诊断

Showing 3 changed files with 61 additions and 3 deletions

platform-operate-api/src/main/java/com/lyms/hospitalapi/qhdfy/QhdfyHisService.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/BabyBuildController.java
platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/BabyBookbuildingFacade.java

...	...	@@ -35,6 +35,8 @@
35	35	import org.apache.commons.io.FileUtils;
36	36	import org.apache.commons.lang.StringUtils;
37	37	import org.joda.time.DateTime;
	38	+import org.slf4j.Logger;
	39	+import org.slf4j.LoggerFactory;
38	40	import org.springframework.beans.factory.annotation.Autowired;
39	41	import org.springframework.data.mongodb.core.MongoTemplate;
40	42	import org.springframework.data.mongodb.core.query.Criteria;
...	...	@@ -52,6 +54,7 @@
52	54	*/
53	55	@Service("qhdfyHisService")
54	56	public class QhdfyHisService {
	57	+ private static final Logger logger = LoggerFactory.getLogger(QhdfyHisService.class);
55	58
56	59	//血红蛋白70~99g/L
57	60	private static final String MSG1="提示：您好，您在产检过程中，检验报告提示血红蛋白为datag/L，属于中度贫血，为避免对您和您的宝宝带来不好的结局，请收到消息后尽快到产科门诊105室就诊。";
...	...	@@ -979,6 +982,58 @@
979	982	return map;
980	983	}
981	984
	985	+ public Map<String, Object> queryHisBabyDiagnosis2(String blNo) {
	986	+
	987	+ Map<String, Object> map = new HashMap<>();
	988	+ StringBuffer sb = new StringBuffer();
	989	+ if (StringUtils.isNotBlank(blNo)) {
	990	+ Connection conn = com.lyms.hospitalapi.qhdfy.ConnTools.makeHisConnection();
	991	+ QueryRunner queryRunner = new QueryRunner();
	992	+ String sql = "select syxh from VW_LYMS_XSE_BRSYK where blh = '" + blNo + "' and cyrq is not null and ksdm ='2545' and bqdm = '206' ";
	993	+ logger.info("----1-----VW_LYMS_XSE_BRSYK---------"+sql);
	994	+ try {
	995	+ List<BabyDischargeDiagnosisModel> list = queryRunner.query(conn,sql , new BeanListHandler<BabyDischargeDiagnosisModel>(BabyDischargeDiagnosisModel.class));
	996	+ if (CollectionUtils.isNotEmpty(list)) {
	997	+ for (BabyDischargeDiagnosisModel info : list) {
	998	+ if(info!=null && StringUtils.isNotEmpty(info.getSyxh())){
	999	+ continue;
	1000	+ }
	1001	+ String sqlstr = "select ZDMC as cyzdmc from jhemr.V_DIAGNOSIS_LYMS where syxh='"+info.getSyxh()+"' ORDER BY ZDRQ desc ";
	1002	+ logger.info("----2-----hemr.V_DIAGNOSIS_LYMS---------"+sqlstr);
	1003	+ Connection conn2 = null;
	1004	+ try {
	1005	+ conn2 = ConnTools.qhdzdConnection();
	1006	+ QueryRunner queryRunner2 = new QueryRunner();
	1007	+ List<BabyDischargeDiagnosisModel> listxq = queryRunner2.query(conn2, sqlstr, new BeanListHandler<BabyDischargeDiagnosisModel>(BabyDischargeDiagnosisModel.class));
	1008	+ String cyzdxq = "";
	1009	+ for (int j = 0; j < listxq.size(); j++) {
	1010	+ BabyDischargeDiagnosisModel babyDischargeDiagnosisModel1 = listxq.get(j);
	1011	+ if(babyDischargeDiagnosisModel1 !=null && StringUtils.isNotEmpty(babyDischargeDiagnosisModel1.getCyzdmc())){
	1012	+ cyzdxq += babyDischargeDiagnosisModel1.getCyzdmc()+" ";
	1013	+ }
	1014	+ }
	1015	+ if(StringUtils.isNotEmpty(cyzdxq)){
	1016	+ map.put("diagnosisItem", cyzdxq);
	1017	+ }
	1018	+ } catch (SQLException e) {
	1019	+ e.printStackTrace();
	1020	+ }finally {
	1021	+ DbUtils.closeQuietly(conn2);
	1022	+ }
	1023	+
	1024	+ }
	1025	+
	1026	+
	1027	+ }
	1028	+ DbUtils.closeQuietly(conn);
	1029	+ } catch (SQLException e) {
	1030	+ DbUtils.closeQuietly(conn);
	1031	+ e.printStackTrace();
	1032	+ }
	1033	+ }
	1034	+ return map;
	1035	+ }
	1036	+
982	1037	public BaseListResponse getBabyDiacrisis(String startDischargeDate, String endDischargeDate,
983	1038	String startBirthDate, String endBirthDate,
984	1039	String hospitalizationNo, String babyName,
...	...	@@ -1181,7 +1236,8 @@
1181	1236	for (int i = 0; i <list.size() ; i++) {
1182	1237	BabyDischargeDiagnosisModel babyDischargeDiagnosisModel = list.get(i);
1183	1238	if(babyDischargeDiagnosisModel!=null && StringUtils.isNotEmpty(babyDischargeDiagnosisModel.getSyxh())){
1184		- String sqlstr = "select ZDMC as cyzdmc from jhemr.v_卫宁诊断数据 where syxh='"+babyDischargeDiagnosisModel.getSyxh()+"' ORDER BY ZDRQ desc ";
	1239	+// String sqlstr = "select ZDMC as cyzdmc from jhemr.v_卫宁诊断数据 where syxh='"+babyDischargeDiagnosisModel.getSyxh()+"' ORDER BY ZDRQ desc ";
	1240	+ String sqlstr = "select ZDMC as cyzdmc from jhemr.V_DIAGNOSIS_LYMS where syxh='"+babyDischargeDiagnosisModel.getSyxh()+"' ORDER BY ZDRQ desc ";
1185	1241	try {
1186	1242	conn = ConnTools.qhdzdConnection();
1187	1243	QueryRunner queryRunner = new QueryRunner();
...	...	@@ -1190,7 +1246,7 @@
1190	1246	for (int j = 0; j < listxq.size(); j++) {
1191	1247	BabyDischargeDiagnosisModel babyDischargeDiagnosisModel1 = listxq.get(j);
1192	1248	if(babyDischargeDiagnosisModel1 !=null && StringUtils.isNotEmpty(babyDischargeDiagnosisModel1.getCyzdmc())){
1193		- cyzdxq = babyDischargeDiagnosisModel1.getCyzdmc()+" ";
	1249	+ cyzdxq += babyDischargeDiagnosisModel1.getCyzdmc()+" ";
1194	1250	}
1195	1251	}
1196	1252	if(StringUtils.isNotEmpty(cyzdxq)){

...	...	@@ -709,6 +709,7 @@
709	709	@RequestParam(value = "type", required = true) String type,
710	710	@RequestParam(value = "lrrqEnd", required = true) String lrrqEnd
711	711	) {
	712	+
712	713	return babyBookbuildingFacade.queryNewBabyDiagnoseQhd(lrrqStart, lrrqEnd, type);
713	714	}
714	715

...	...	@@ -3757,7 +3757,8 @@
3757	3757	public BaseResponse queryHisBabyDiagnosis(String blNo) {
3758	3758	BaseObjectResponse objectResponse = new BaseObjectResponse();
3759	3759	if ("4".equals(HIS_VERSION)) {
3760		- Map <String, Object> results = qhdfyHisService.queryHisBabyDiagnosis(blNo);
	3760	+// Map <String, Object> results = qhdfyHisService.queryHisBabyDiagnosis(blNo);
	3761	+ Map <String, Object> results = qhdfyHisService.queryHisBabyDiagnosis2(blNo);//20210108 新规则
3761	3762	//results.put("diagnosisItem", "用于测试，暂时固定，测试完成后通知修改恢复！");
3762	3763	objectResponse.setData(results);
3763	3764	objectResponse.setErrorcode(ErrorCodeConstants.SUCCESS);