1111

controllers/his_api_controller.go

@@ -46,6 +46,9 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/treatment/check", &HisApiController{}, "get:CheckTreatment")
 
+	beego.Router("/api/record/put", &HisApiController{}, "get:PutRecord")
+	beego.Router("/api/returnrecord/put", &HisApiController{}, "get:ReturnRecord")
+
 }
 
 func (c *HisApiController) Sscard() {
@@ -2043,6 +2046,122 @@ func (c *HisApiController) CheckTreatment() {
 
 }
 
+func (c *HisApiController) PutRecord() {
+	id, _ := c.GetInt64("id")
+	record_time := c.GetString("record_time")
+	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
+	}
+	recordDateTime := theTime.Unix()
+
+	adminInfo := c.GetAdminUserInfo()
+	patient, _ := service.GetPatientByID(adminInfo.CurrentOrgId, id)
+	patientPrescription, _ := service.FindPatientPrescriptionInfo(adminInfo.CurrentOrgId, id, recordDateTime)
+
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId)
+
+	fmt.Println(miConfig.SecretKey)
+
+	if patient == nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist)
+		return
+	}
+	if len(patient.IdCardNo) == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeIDCartNo)
+		return
+	}
+	config, _ := service.GetMedicalInsuranceConfig(adminInfo.CurrentOrgId)
+	if config.IsOpen == 1 {
+		api := "http://127.0.0.1:9532/" + "gdyb/one?cert_no=" + patient.IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + patientPrescription.Doctor + "&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,
+				PatientId:   patient.ID,
+				RecordDate:  theTime.Unix(),
+				UserOrgId:   adminInfo.CurrentOrgId,
+				AdminUserId: adminInfo.AdminUser.Id,
+				IsReturn:    1,
+			}
+
+			doctor_id := strconv.FormatInt(patientPrescription.DoctorId, 10)
+			result := service.Gdyb2503(his.PsnNo, res.Output.Iinfo[0].Insutype, miConfig.OrgName, patientPrescription.Doctor, miConfig.Code, doctor_id, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, "重症尿毒症透析(血透)", "M07801")
+
+			var dat map[string]interface{}
+			if err := json.Unmarshal([]byte(result), &dat); err == nil {
+				fmt.Println(dat)
+			} else {
+				fmt.Println(err)
+			}
+
+		} else {
+			adminUser := c.GetAdminUserInfo()
+			errlog := &models.HisOrderError{
+				UserOrgId:  adminUser.CurrentOrgId,
+				Ctime:      time.Now().Unix(),
+				Mtime:      time.Now().Unix(),
+				ErrMsg:     res.ErrMsg,
+				Status:     1,
+				PatientId:  id,
+				RecordTime: recordDateTime,
+				Stage:      1,
+			}
+			service.CreateErrMsgLog(errlog)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeGdybOneException)
+			return
+		}
+	}
+
+}
+
 func PathExists(path string) (bool, error) {
 	_, err := os.Stat(path)
 	if err == nil {

service/gdyb_service.go

@@ -1155,6 +1155,147 @@ func Gdyb2001(baseParams models.BaseParams, psn_no string, insutype string, med_
 	return str
 }
 
+//func Gdyb2503(psnNo string, doctor string, department string, diag string, org_name string, med_type string, doctor_id int64, fixmedins_code string, diag_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_code string, sick_name string) string {
+//	// 生成签名
+//	nonce := GetRandomString(32)
+//	timestamp := time.Now().Unix()
+//	signature := setSignature(timestamp, nonce, secret_key)
+//	tempTime := time.Unix(timestamp, 0)
+//	timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
+//
+//	// 生成输入报文
+//	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+//	input := make(map[string]interface{})
+//	inputData := make(map[string]interface{})
+//	diseinfo := make([]map[string]interface{}, 0)
+//
+//	inputMessage["infno"] = "2203"        // 交易编码
+//	inputData["mdtrt_id"] = mdtrtId       // 就诊 ID（来自2201接口返回）
+//	inputData["psn_no"] = psnNo           // 人员编号 （来自1101接口返回）
+//	inputData["med_type"] = med_type      // 医疗类别 16门诊特殊病
+//	inputData["begntime"] = timeFormatOne // 开始时间
+//	inputData["main_cond_dscr"] = ""      // 主要病情描述
+//	inputData["dise_codg"] = sick_code    // 病种编码
+//	inputData["dise_name"] = sick_name    // 病种名称
+//	inputData["birctrl_type"] = ""        // 计划生育手术类别
+//	inputData["birctrl_matn_date"] = ""   // 计划生育手术或生育日期
+//
+//	diseinfo_sun := make(map[string]interface{})
+//	diseinfo_sun["diag_type"] = "1"           // 诊断类别
+//	diseinfo_sun["diag_srt_no"] = "1"         // 诊断排序号
+//	diseinfo_sun["diag_code"] = diag_code     // 诊断代码
+//	diseinfo_sun["diag_name"] = diag          // 诊断名称
+//	diseinfo_sun["diag_dept"] = department    // 诊断科室
+//	diseinfo_sun["dise_dor_no"] = doctor_id   // 诊断医生编码
+//	diseinfo_sun["dise_dor_name"] = doctor    // 诊断医生姓名
+//	diseinfo_sun["diag_time"] = timeFormatOne // 诊断时间
+//	diseinfo_sun["vali_flag"] = "1"           // 有效标志
+//
+//	diseinfo = append(diseinfo, diseinfo_sun)
+//	input["diseinfo"] = diseinfo
+//	input["mdtrtinfo"] = inputData
+//	inputMessage["input"] = input //交易输入
+//
+//	bytesData, err := json.Marshal(inputMessage)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//	reader := bytes.NewReader(bytesData)
+//
+//	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2203"
+//
+//	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2203"
+//	request, err := http.NewRequest("POST", url, reader)
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//
+//	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+//	request.Header.Set("x-tif-paasid", "sg03_prd")
+//	request.Header.Set("x-tif-signature", signature)
+//	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+//	request.Header.Set("x-tif-nonce", nonce)
+//
+//	client := http.Client{}
+//	resp, err := client.Do(request)
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//	respBytes, err := ioutil.ReadAll(resp.Body)
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error()
+//	}
+//	str := string(respBytes)
+//	fmt.Println(str)
+//	return str
+//}
+func Gdyb2503(psnNo string, insutype string, org_name string, doctor string, fixmedins_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, sick_name string, sick_code string) string {
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce, secret_key)
+	tempTime := time.Unix(timestamp, 0)
+	timeFormatOne := tempTime.Format("2006-01-02 15:04:05")
+
+	// 生成输入报文
+	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"] = "2503"                 // 交易编码
+	inputData["psn_no"] = psnNo                    // 人员编号 （来自1101接口返回）
+	inputData["insutype"] = insutype               // 险种类型（来自1101接口返回）
+	inputData["opsp_dise_code"] = sick_code        // 险种类型（来自1101接口返回）
+	inputData["opsp_dise_name"] = sick_name        // 险种类型（来自1101接口返回）
+	inputData["insu_optins"] = mdtrtarea_admvs     // 险种类型（来自1101接口返回）
+	inputData["ide_fixmedins_no"] = fixmedins_code // 险种类型（来自1101接口返回）
+	inputData["ide_fixmedins_name"] = org_name     // 险种类型（来自1101接口返回）
+	inputData["hosp_ide_date"] = timeFormatOne     // 险种类型（来自1101接口返回）
+	inputData["diag_dr_codg"] = doctor_id          // 开始时间
+	inputData["diag_dr_name"] = doctor             // 开始时间
+	inputData["begndate"] = timeFormatOne          // 医师编码
+	input["data"] = inputData
+	inputMessage["input"] = input //交易输入
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	reader := bytes.NewReader(bytesData)
+	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/2503"
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	request.Header.Set("x-tif-paasid", "sg03_prd")
+	request.Header.Set("x-tif-signature", signature)
+	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+	request.Header.Set("x-tif-nonce", nonce)
+
+	client := http.Client{}
+	resp, err := client.Do(request)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	str := string(respBytes)
+	fmt.Println(str)
+	return str
+}
+
 //  门诊结算撤销
 //func Gdyb4101(psnNo string, mdtrtId string, setlId string) string {
 //	// 生成签名