Merge branch 'master' of http://git.shengws.com/csx/gdyb

controllers/sg/his_api_controller.go

@@ -85,6 +85,39 @@ func HisManagerApiRegistRouters() {
 
 }
 
+type Result3101 struct {
+	Infcode     string      `json:"infcode"`
+	InfRefmsgid string      `json:"inf_refmsgid"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Enctype     string      `json:"enctype"`
+	Signtype    string      `json:"signtype"`
+	ErrMsg      interface{} `json:"err_msg"`
+	Output      struct {
+		Result []struct {
+			JudgeResultDetailDtos []struct {
+				VolaItemType string      `json:"vola_item_type"`
+				MdtrtID      string      `json:"mdtrt_id"`
+				JrdID        string      `json:"jrd_id"`
+				PatnID       string      `json:"patn_id"`
+				RxID         string      `json:"rx_id"`
+				VolaAmt      interface{} `json:"vola_amt"`
+			} `json:"judge_result_detail_dtos"`
+			RuleID       string  `json:"rule_id"`
+			VolaEvid     string  `json:"vola_evid"`
+			MdtrtID      string  `json:"mdtrt_id"`
+			RuleName     string  `json:"rule_name"`
+			VolaAmtStas  string  `json:"vola_amt_stas"`
+			JrID         string  `json:"jr_id"`
+			PatnID       string  `json:"patn_id"`
+			SevDeg       string  `json:"sev_deg"`
+			VolaAmt      float64 `json:"vola_amt"`
+			VolaBhvrType string  `json:"vola_bhvr_type"`
+			VolaCont     string  `json:"vola_cont"`
+		} `json:"result"`
+	} `json:"output"`
+}
+
 func (c *HisApiController) Get9001() {
 	adminUser := c.GetAdminUserInfo()
 	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
@@ -112,21 +145,21 @@ func (c *HisApiController) Get9001() {
 	}
 
 }
-func (c *HisApiController) Check3101(patient_id int64, his_patient_id int64, admin_user_id int64) {
+func Check3101(c *HisApiController, patient_id int64, his_patient_id int64, admin_user_id int64, trig_scen string, record_time string, prescriptions []*models.HisPrescription) (res Result3101) {
 
 	adminUser := c.GetAdminUserInfo()
 	roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
 	his, _ := service.GetNewHisPatientInfoFour(c.GetAdminUserInfo().CurrentOrgId, his_patient_id)
 	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
-	record_time := c.GetString("record_time")
-	trig_scen := c.GetString("trig_scen")
+	//record_time := c.GetString("record_time")
+	//trig_scen := c.GetString("trig_scen")
 
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
 	if err != nil {
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-		return
+		return res
 	}
 	recordDateTime := theTime.Unix()
 
@@ -140,7 +173,7 @@ func (c *HisApiController) Check3101(patient_id int64, his_patient_id int64, adm
 	//
 	diagnosis_ids := strings.Split(patientPrescription.Diagnosis, ",")
 
-	prescriptions, _ := service.GetNewHisPrescriptionTen(adminUser.CurrentOrgId, his_patient_id, recordDateTime)
+	//prescriptions, _ := service.GetNewHisPrescriptionTen(adminUser.CurrentOrgId, his_patient_id, recordDateTime)
 
 	var pp models.PublicParams
 	pp.InsuplcAdmdvs = miConfig.InsuplcAdmdvs
@@ -374,26 +407,32 @@ func (c *HisApiController) Check3101(patient_id int64, his_patient_id int64, adm
 	if ioErr != nil {
 		utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
+		return res
 	}
 	var respJSON map[string]interface{}
 	if err := json.Unmarshal([]byte(body), &respJSON); err != nil {
 		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
+		return res
+	}
+	respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &res); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return res
 	}
 
-	//手术操作集合
-	//手术操作集合
+	return res
 
 }
 
-func (c *HisApiController) Check3102() {
-	patient_id, _ := c.GetInt64("patient_id")
-	order_id, _ := c.GetInt64("order_id")
-	his_patient_id, _ := c.GetInt64("his_patient_id")
-	admin_user_id, _ := c.GetInt64("admin_user_id")
-	trig_scen := c.GetString("trig_scen")
+func Check3102(c *HisApiController, patient_id int64, his_patient_id int64, admin_user_id int64, trig_scen string, order_id int64) (res Result3101) {
+	////patient_id, _ := c.GetInt64("patient_id")
+	//order_id, _ := c.GetInt64("order_id")
+	////his_patient_id, _ := c.GetInt64("his_patient_id")
+	////admin_user_id, _ := c.GetInt64("admin_user_id")
+	//trig_scen := c.GetString("trig_scen")
 
 	adminUser := c.GetAdminUserInfo()
 	roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id)
@@ -741,15 +780,24 @@ func (c *HisApiController) Check3102() {
 	if ioErr != nil {
 		utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
+		return res
 	}
 	var respJSON map[string]interface{}
 	if err := json.Unmarshal([]byte(body), &respJSON); err != nil {
 		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-		return
+		return res
+	}
+
+	respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &res); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return res
 	}
 
+	return res
 	//手术操作集合
 
 	//手术操作集合
@@ -5553,6 +5601,8 @@ func (c *HisApiController) GetRegisterInfo() {
 				}
 				infocode, _ = strconv.ParseInt(resThree10265.Infcode, 10, 64)
 			} else {
+				//Check3101(c, patient.ID, his.ID, admin_user_id)
+
 				psn_info, _ := service.GetPsnByPatientId(id)
 				result, requestLog := service.Gdyb2201A(res.Output.Baseinfo.PsnNo, insutype, IdCardNo, miConfig.OrgName, roles.UserName, ipt_otp_no, department.Name, miConfig.Code, department.Number, doctor_info.DoctorNumber, insuplc_admdvs_temp, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, doctor_info.UserName, record_time, psn_info.VerifyNumber)
 				saveLog(result, requestLog, "2201A", "挂号")
@@ -5618,9 +5668,94 @@ func (c *HisApiController) GetRegisterInfo() {
 			service.UpdateHisPatientStatus(&his)
 			service.UpdateHisPrescriptionHisID(his.ID, patient.ID, recordDateTime, adminInfo.CurrentOrgId)
 
-			c.ServeSuccessJSON(map[string]interface{}{
-				"his_info": his,
-			})
+			var prescriptions []*models.HisPrescription
+			res := Check3101(c, patient.ID, his.ID, admin_user_id, "1", record_time, prescriptions)
+
+			if res.Infcode == "0" {
+				if len(res.Output.Result) > 0 {
+					var res2 ResultSix
+					var resSix10265 ResultSix10265
+					var api3 string
+					if miConfig.MdtrtareaAdmvs == "320921" {
+						api3 = "http://192.168.2.110:9532/" + "jsyb/2202?psn_no=" + his.PsnNo +
+							"&mdtrt_id=" + his.Number + "&ipt_otp_no=" + his.IptOtpNo + "&doctor=" + roles.UserName + "&org_name=" + miConfig.OrgName + "&fixmedins_code=" + miConfig.Code +
+							"&insuplc_admdvs=" + his.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&ak=" + miConfig.AccessKey + "&cainfo=" + miConfig.Cainfo
+
+						//req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/2204", bytes.NewReader(bytesData))
+
+					} else {
+						//req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/2204", bytes.NewReader(bytesData))
+						api3 = "http://192.168.5.251:9532/" + "jsyb/2202?psn_no=" + his.PsnNo +
+							"&mdtrt_id=" + his.Number + "&ipt_otp_no=" + his.IptOtpNo + "&doctor=" + roles.UserName + "&org_name=" + miConfig.OrgName + "&fixmedins_code=" + miConfig.Code +
+							"&insuplc_admdvs=" + his.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&ak=" + miConfig.AccessKey + "&cainfo=" + miConfig.Cainfo
+					}
+
+					resp3, requestErr3 := http.Get(api3)
+					if requestErr3 != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+
+					body3, ioErr3 := ioutil.ReadAll(resp3.Body)
+					if ioErr3 != nil {
+						utils.ErrorLog("接口返回数据读取失败: %v", ioErr3)
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+					var respJSON3 map[string]interface{}
+					if err := json.Unmarshal([]byte(string(body3)), &respJSON3); err != nil {
+						utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+
+					respJSON3 = respJSON3["data"].(map[string]interface{})["pre"].(map[string]interface{})
+					userJSONBytes3, _ := json.Marshal(respJSON3)
+					if err := json.Unmarshal(userJSONBytes3, &resSix10265); err != nil {
+						utils.ErrorLog("解析失败：%v", err)
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+						return
+					}
+
+					res2.InfRefmsgid = resSix10265.InfRefmsgid
+					res2.Output = resSix10265.Output
+					res2.ErrMsg = resSix10265.ErrMsg
+					res2.Cainfo = resSix10265.Cainfo
+					res2.WarnMsg = resSix10265.WarnMsg
+					infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+					res2.Infcode = infocode
+
+					if res2.Infcode == 0 {
+						var msg []string
+						msg = append(msg, "挂号失败")
+						for _, item := range res.Output.Result {
+							msg = append(msg, item.VolaCont)
+						}
+						c.ServeSuccessJSON(map[string]interface{}{
+							"failed_code": -10,
+							"msg":         msg,
+						})
+
+					} else {
+						c.ServeSuccessJSON(map[string]interface{}{
+							"failed_code": -10,
+							"msg":         res2.ErrMsg,
+						})
+
+					}
+
+				} else {
+					c.ServeSuccessJSON(map[string]interface{}{
+						"his_info": his,
+					})
+				}
+			} else {
+				c.ServeSuccessJSON(map[string]interface{}{
+					"failed_code": -10,
+					"msg":         res.ErrMsg,
+				})
+
+			}
 
 		} else {
 			adminUser := c.GetAdminUserInfo()
@@ -6129,8 +6264,22 @@ func (c *HisApiController) GetUploadInfo() {
 					}
 
 				} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
-					bytesData, _ := json.Marshal(data)
+					result3101 := Check3101(c, id, his_patient_id, admin_user_id, "2", record_time, prescriptions)
+					if result3101.Infcode == "0" {
+						if len(result3101.Output.Result) > 0 {
+							var errMsgs []string
+							for _, item := range result3101.Output.Result {
+								errMsgs = append(errMsgs, item.VolaCont)
 
+							}
+							c.ServeSuccessJSON(map[string]interface{}{
+								"failed_code": -10,
+								"msg":         errMsgs,
+							})
+							return
+						}
+					}
+					bytesData, _ := json.Marshal(data)
 					var req *http.Request
 					if miConfig.MdtrtareaAdmvs == "320921" {
 						req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/2204", bytes.NewReader(bytesData))
@@ -7881,7 +8030,6 @@ func (c *HisApiController) GetPreUploadInfo() {
 
 			//api = "http://192.168.2.110:9532/" + "jsyb/readcard?" + "fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&ak=" + miConfig.AccessKey + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName +
 			//	"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&cainfo=" + miConfig.Cainfo
-
 		} else {
 			req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/2203", bytes.NewReader(bytesData))