1111

controllers/his_api_controller.go

@@ -44,6 +44,8 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/code/get", &HisApiController{}, "get:GetCode")
 
+	beego.Router("/api/treatment/check", &HisApiController{}, "get:CheckTreatment")
+
 }
 
 func (c *HisApiController) Sscard() {
@@ -938,7 +940,7 @@ func (c *HisApiController) GetUploadInfo() {
 				mdtrt_id := his.Number
 				chrg_bchno := chrg_bchno
 				cert_no := his.Certno
-				insutype := "310"
+				insutype := rf[0].Insutype
 				api := "http://127.0.0.1:9532/" + "gdyb/eight?cert_no=" + cert_no + "&insutype=" +
 					insutype + "&psn_no=" + psn_no + "&chrg_bchno=" + chrg_bchno + "&mdtrt_id=" + mdtrt_id +
 					"&total=" + allTotal + "&org_name=" + miConfig.OrgName + "&doctor=" + patientPrescription.Doctor + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey
@@ -1983,6 +1985,58 @@ func (c *HisApiController) GetCode() {
 
 }
 
+func (c *HisApiController) CheckTreatment() {
+
+	patient_id, _ := c.GetInt64("patient_id", 0)
+	record_time := c.GetString("record_time")
+	insutype := c.GetString("insutype")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	adminUser := c.GetAdminUserInfo()
+	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
+	fmt.Println(err)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordDateTime := theTime.Unix()
+	his, _ := service.GetVMHisPatientInfo(adminUser.CurrentOrgId, patient_id, recordDateTime)
+	patientPrescription, _ := service.FindPatientPrescriptionInfo(adminUser.CurrentOrgId, patient_id, recordDateTime)
+
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+
+	var user_name string
+	role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, adminUser.AdminUser.Id)
+	if role.ID == 0 {
+		user_name = "xxx"
+	} else {
+		user_name = role.UserName
+	}
+
+	baseParams := models.BaseParams{
+		SecretKey:      miConfig.SecretKey,
+		FixmedinsCode:  miConfig.Code,
+		InsuplcAdmdvs:  miConfig.InsuplcAdmdvs,
+		MdtrtareaAdmvs: miConfig.MdtrtareaAdmvs,
+		OrgName:        miConfig.OrgName,
+		Doctor:         user_name,
+	}
+
+	if config.IsOpen == 1 {
+		result := service.Gdyb2001(baseParams, his.PsnNo, insutype, strconv.FormatInt(patientPrescription.RegisterType, 10))
+		var dat map[string]interface{}
+		if err := json.Unmarshal([]byte(result), &dat); err == nil {
+			fmt.Println(dat)
+		} else {
+			fmt.Println(err)
+		}
+
+	}
+
+}
+
 func PathExists(path string) (bool, error) {
 	_, err := os.Stat(path)
 	if err == nil {

service/gdyb_service.go

@@ -1102,6 +1102,59 @@ func Gdyb3301(baseParams models.BaseParams, name string, codg string) string {
 	return str
 }
 
+func Gdyb2001(baseParams models.BaseParams, psn_no string, insutype string, med_type string) string {
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
+
+	// 生成输入报文
+	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "2001" // 交易编码
+	inputData["psn_no"] = psn_no
+	inputData["insutype"] = insutype
+	inputData["med_type"] = med_type
+	inputData["begntime"] = "2021-01-01 00:00:00"
+	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/2001"
+
+	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/5203"
+	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 {
 //	// 生成签名