1111

controllers/gdyb_controller.go

@@ -75,8 +75,9 @@ func (c *GdybController) PostOne() {
 	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
 
 	secret_key := c.GetString("secret_key")
+	id_card_type, _ := c.GetInt64("id_card_type")
 
-	result := service.Gdyb1101(certNo, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key)
+	result := service.Gdyb1101(certNo, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type)
 
 	var dat map[string]interface{}
 	if err := json.Unmarshal([]byte(result), &dat); err == nil {

controllers/his_api_controller.go

@@ -42,41 +42,192 @@ func HisManagerApiRegistRouters() {
 	beego.Router("/api/refunddetail/post", &HisApiController{}, "get:RefundDetail")
 	beego.Router("/api/treatment/check", &HisApiController{}, "get:CheckTreatment")
 	beego.Router("/api/record/put", &HisApiController{}, "get:PutRecord")
+
+	beego.Router("/api/patient/info", &HisApiController{}, "get:GetHisPatientInfo")
+
+}
+
+func (c *HisApiController) GetHisPatientInfo() {
+
+	medical_insurance_card := c.GetString("medical_insurance_card")
+	id_card_type, _ := c.GetInt64("id_card_type")
+	id_card := c.GetString("id_card")
+
+	adminInfo := c.GetAdminUserInfo()
+	config, _ := service.GetMedicalInsuranceConfig(adminInfo.CurrentOrgId)
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId)
+
+	appRole, _ := service.GetAppRole(adminInfo.CurrentOrgId)
+
+	IdCardNo := ""
+
+	if id_card_type == 1 {
+		IdCardNo = medical_insurance_card
+	} else if id_card_type == 2 {
+		IdCardNo = id_card
+	}
+
+	if config.IsOpen == 1 {
+
+		api := "http://127.0.0.1:9532/" + "gdyb/one?cert_no=" + IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + appRole.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey
+		resp, requestErr := http.Get(api)
+		if requestErr != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		defer resp.Body.Close()
+		body, ioErr := ioutil.ReadAll(resp.Body)
+		if ioErr != nil {
+			utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		var respJSON map[string]interface{}
+
+		if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+			utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+
+		userJSON := respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+		userJSONBytes, _ := json.Marshal(userJSON)
+		var res ResultTwo
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		Iinfos, _ := json.Marshal(res.Output.Iinfo)
+		Idetinfos, _ := json.Marshal(res.Output.Idetinfo)
+		infoStr := string(Iinfos)
+		idetinfoStr := string(Idetinfos)
+
+		if res.Infcode == 0 {
+			his := models.VMHisPatient{
+				Status:      1,
+				Ctime:       time.Now().Unix(),
+				Mtime:       time.Now().Unix(),
+				PsnNo:       res.Output.Baseinfo.PsnNo,
+				PsnCertType: res.Output.Baseinfo.PsnCertType,
+				Certno:      res.Output.Baseinfo.Certno,
+				PsnName:     res.Output.Baseinfo.PsnName,
+				Gend:        res.Output.Baseinfo.Gend,
+				Naty:        res.Output.Baseinfo.Naty,
+				Brdy:        res.Output.Baseinfo.Brdy,
+				Age:         res.Output.Baseinfo.Age,
+				Iinfo:       infoStr,
+				Idetinfo:    idetinfoStr,
+				UserOrgId:   adminInfo.CurrentOrgId,
+				IsReturn:    1,
+				IdCardType:  id_card_type,
+			}
+			c.ServeSuccessJSON(map[string]interface{}{
+				"info": his,
+			})
+		} else {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+			return
+		}
+	}
+
 }
 
 func (c *HisApiController) Sscard() {
 	id_card_type, _ := c.GetInt64("id_card_type")
 	adminUser := c.GetAdminUserInfo()
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+
 	r := CardInit()
 	if r == 0 {
 		switch id_card_type {
 		case 1:
 			basStr, err := GetBasBaseInfo()
-			fmt.Println("~~~~~")
-			fmt.Println(basStr)
-			fmt.Println("~~~~~")
 
 			if err != nil {
 				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
 				return
 
 			} else {
+
 				bas := strings.Split(basStr, "|")
 				basNumber := bas[1]
-				patient, err := service.GetPatientByNumber(basNumber, adminUser.CurrentOrgId)
-				if err == gorm.ErrRecordNotFound {
-					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+
+				appRole, _ := service.GetAppRole(adminUser.CurrentOrgId)
+
+				api := "http://127.0.0.1:9532/" + "gdyb/one?cert_no=" + basNumber + "&org_name=" + miConfig.OrgName + "&doctor=" + appRole.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(int64(id_card_type), 10)
+				resp, requestErr := http.Get(api)
+				if requestErr != nil {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
+				}
+				defer resp.Body.Close()
+				body, ioErr := ioutil.ReadAll(resp.Body)
+				if ioErr != nil {
+					utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				var respJSON map[string]interface{}
 
-				} else if err != nil {
-					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+				if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+
+				userJSON := respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+				userJSONBytes, _ := json.Marshal(userJSON)
+				var res ResultTwo
+				if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
+				}
+				Iinfos, _ := json.Marshal(res.Output.Iinfo)
+				Idetinfos, _ := json.Marshal(res.Output.Idetinfo)
+				infoStr := string(Iinfos)
+				idetinfoStr := string(Idetinfos)
+
+				if res.Infcode == 0 {
+					his := models.VMHisPatient{
+						Status:      1,
+						Ctime:       time.Now().Unix(),
+						Mtime:       time.Now().Unix(),
+						PsnNo:       res.Output.Baseinfo.PsnNo,
+						PsnCertType: res.Output.Baseinfo.PsnCertType,
+						Certno:      res.Output.Baseinfo.Certno,
+						PsnName:     res.Output.Baseinfo.PsnName,
+						Gend:        res.Output.Baseinfo.Gend,
+						Naty:        res.Output.Baseinfo.Naty,
+						Brdy:        res.Output.Baseinfo.Brdy,
+						Age:         res.Output.Baseinfo.Age,
+						Iinfo:       infoStr,
+						Idetinfo:    idetinfoStr,
+						UserOrgId:   adminUser.CurrentOrgId,
+						IsReturn:    1,
+						IdCardType:  id_card_type,
+					}
 
+					patient, err := service.GetPatientByNumber(his.Certno, adminUser.CurrentOrgId)
+					if err == gorm.ErrRecordNotFound {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+						return
+
+					} else if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+						return
+
+					} else {
+						c.ServeSuccessJSON(map[string]interface{}{
+							"patient": patient,
+							"info":    his,
+							"number":  basNumber,
+						})
+					}
 				} else {
-					c.ServeSuccessJSON(map[string]interface{}{
-						"patient": patient,
-						"number":  basNumber,
-					})
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+					return
 				}
 
 			}
@@ -84,9 +235,6 @@ func (c *HisApiController) Sscard() {
 			break
 		case 2:
 			SFZStr, err := GetSFZBaseInfo()
-			fmt.Println("~~~~~----")
-			fmt.Println(SFZStr)
-			fmt.Println("~~~~~---")
 			if err != nil {
 				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
 				return
@@ -95,34 +243,87 @@ func (c *HisApiController) Sscard() {
 
 				id_card_str := strings.Split(SFZStr, "^")
 				id_card_number := id_card_str[0]
-				patient, err := service.GetPatientByIDCard(id_card_number, adminUser.CurrentOrgId)
-				if err == gorm.ErrRecordNotFound {
-					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+				appRole, _ := service.GetAppRole(adminUser.CurrentOrgId)
+
+				api := "http://127.0.0.1:9532/" + "gdyb/one?cert_no=" + id_card_number + "&org_name=" + miConfig.OrgName + "&doctor=" + appRole.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(int64(id_card_type), 10)
+				resp, requestErr := http.Get(api)
+				if requestErr != nil {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
+				}
+				defer resp.Body.Close()
+				body, ioErr := ioutil.ReadAll(resp.Body)
+				if ioErr != nil {
+					utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				var respJSON map[string]interface{}
 
-				} else if err != nil {
-					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+				if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+					utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+
+				userJSON := respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+				userJSONBytes, _ := json.Marshal(userJSON)
+				var res ResultTwo
+				if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
 					return
+				}
+				Iinfos, _ := json.Marshal(res.Output.Iinfo)
+				Idetinfos, _ := json.Marshal(res.Output.Idetinfo)
+				infoStr := string(Iinfos)
+				idetinfoStr := string(Idetinfos)
+
+				if res.Infcode == 0 {
+					his := models.VMHisPatient{
+						Status:      1,
+						Ctime:       time.Now().Unix(),
+						Mtime:       time.Now().Unix(),
+						PsnNo:       res.Output.Baseinfo.PsnNo,
+						PsnCertType: res.Output.Baseinfo.PsnCertType,
+						Certno:      res.Output.Baseinfo.Certno,
+						PsnName:     res.Output.Baseinfo.PsnName,
+						Gend:        res.Output.Baseinfo.Gend,
+						Naty:        res.Output.Baseinfo.Naty,
+						Brdy:        res.Output.Baseinfo.Brdy,
+						Age:         res.Output.Baseinfo.Age,
+						Iinfo:       infoStr,
+						Idetinfo:    idetinfoStr,
+						UserOrgId:   adminUser.CurrentOrgId,
+						IsReturn:    1,
+						IdCardType:  id_card_type,
+					}
 
+					patient, err := service.GetPatientByNumber(his.Certno, adminUser.CurrentOrgId)
+					if err == gorm.ErrRecordNotFound {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException)
+						return
+
+					} else if err != nil {
+						c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+						return
+
+					} else {
+						c.ServeSuccessJSON(map[string]interface{}{
+							"patient": patient,
+							"info":    his,
+							"number":  id_card_number,
+						})
+					}
 				} else {
-					c.ServeSuccessJSON(map[string]interface{}{
-						"patient": patient,
-					})
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException)
+					return
 				}
 
 			}
 			break
 		case 3:
-			//QRStr, err :=GetQRBaseInfo()
-			//if err != nil{
-			//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
-			//	return
-			//
-			//}else{
-			//
-			//
-			//
-			//}
+
 			break
 
 		}

enums/error_code.go

@@ -234,6 +234,8 @@ const ( // ErrorCode
 	ErrorCodeReadCardException = 20074
 
 	ErrorCodeNoPateintException = 20075
+
+	ErrorCodeHisFailedException = 20076
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -450,7 +452,9 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeAmountAccountException:  "结算失败",
 
 	ErrorCodeReadCardException:  "读卡失败",
-	ErrorCodeNoPateintException: "该患者不存在血透系统中,请在血透系统中添加该患者",
+	ErrorCodeNoPateintException: "读卡失败！请先在系统录入患者信息或检查患者身份证信息是否正确，再重新读卡",
+
+	ErrorCodeHisFailedException: "获取人员信息失败",
 }
 
 type SGJError struct {

service/gdyb_service.go

@@ -25,7 +25,7 @@ const (
 )
 
 // 人员基本信息
-func Gdyb1101(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string) string {
+func Gdyb1101(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, id_card_type int64) string {
 	// 生成签名
 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
@@ -35,8 +35,14 @@ func Gdyb1101(certNo string, org_name string, doctor string, fixmedins_code stri
 	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "1101"      // 交易编码
-	inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
+	inputMessage["infno"] = "1101" // 交易编码
+
+	if id_card_type == 1 {
+		inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
+	} else if id_card_type == 2 {
+		inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
+	}
+
 	inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
 	inputData["card_sn"] = ""           // 卡识别码
 	inputData["begntime"] = ""          // 开始时间

service/his_service.go

@@ -927,7 +927,7 @@ func GetMonthHisPrescription(org_id int64, patient_id int64, start_time int64, e
 }
 
 func GetPatientByNumber(number string, user_org_id int64) (patient Patients, err error) {
-	err = readDb.Model(&Patients{}).Where("health_care_no = ? AND user_org_id = ?", number, user_org_id).First(&patient).Error
+	err = readDb.Model(&Patients{}).Where("(health_care_no = ? OR id_card_no = ?)  AND user_org_id = ?", number, number, user_org_id).First(&patient).Error
 	return
 }
 
@@ -940,3 +940,9 @@ func GetHisOrderThree(record_time int64, patient_id int64, user_org_id int64) (o
 	err = readDb.Model(&models.HisOrder{}).Where("patient_id = ? AND user_org_id = ? AND settle_accounts_date = ? AND status = 1", patient_id, user_org_id, record_time).First(&order).Error
 	return
 }
+
+func GetAppRole(orgID int64) (models.App_Role, error) {
+	var appRole models.App_Role
+	err := readUserDb.Model(models.App_Role{}).Where("org_id = ? AND user_type = 2", orgID).First(&appRole).Error
+	return appRole, err
+}