医保对接

controllers/his_api_controller.go

@@ -56,9 +56,13 @@ func HisManagerApiRegistRouters() {
 	beego.Router("/api/register/get", &HisApiController{}, "get:GetRegisterInfo")
 	beego.Router("/api/upload/get", &HisApiController{}, "get:GetUploadInfo")
 
+	beego.Router("/api/settle/query", &HisApiController{}, "get:GetSettleAccounts")
+
 	beego.Router("/api/checkaccount/get", &HisApiController{}, "get:GetCheckAccount")
 	beego.Router("/api/checkdetailaccount/get", &HisApiController{}, "get:GetCheckDetailAccount")
 
+	beego.Router("/api/checkdetailaccount/get", &HisApiController{}, "get:GetCheckDetailAccount")
+
 	beego.Router("/api/refund/post", &HisApiController{}, "get:Refund")
 
 	beego.Router("/api/medicalinsurance/config", &HisApiController{}, "get:GetMedicalInsuranceConfig")
@@ -1296,6 +1300,54 @@ type ResultTen struct {
 	WarnMsg     interface{} `json:"warn_msg"`
 }
 
+type ResultEleven struct {
+	Cainfo      string `json:"cainfo"`
+	ErrMsg      string `json:"err_msg"`
+	InfRefmsgid string `json:"inf_refmsgid"`
+	Infcode     int64  `json:"infcode"`
+	Output      struct {
+		Setlinfo struct {
+			FixmedinsName   string  `json:"fixmedins_name"`
+			FixmedinsCode   string  `json:"fixmedins_code"`
+			PsnNo           string  `json:"psn_no"`
+			Name            string  `json:"name"`
+			Gend            string  `json:"gend"`
+			Brdy            string  `json:"brdy"`
+			PsnCertType     string  `json:"psn_cert_type"`
+			PsnType         string  `json:"psn_type"`
+			EmpName         string  `json:"emp_name"`
+			Certno          string  `json:"certno"`
+			Insutype        string  `json:"insutype"`
+			MedfeeSumamt    float64 `json:"medfee_sumamt"`
+			FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"`
+			OverlmtSelfpay  float64 `json:"overlmt_selfpay"`
+			PreselfpayAmt   float64 `json:"preselfpay_amt"`
+			InscpScpAmt     float64 `json:"inscp_scp_amt"`
+			ActPayDedc      float64 `json:"act_pay_dedc"`
+			HifpPay         float64 `json:"hifp_pay"`
+			PoolPropSelfpay float64 `json:"pool_prop_selfpay"`
+			CvlservPay      float64 `json:"cvlserv_pay"`
+			HifesPay        float64 `json:"hifes_pay"`
+			HifmiPay        float64 `json:"hifmi_pay"`
+			MafPay          float64 `json:"maf_pay"`
+			OthPay          float64 `json:"oth_pay"`
+			FundPaySumamt   float64 `json:"fund_pay_sumamt"`
+			PsnPay          float64 `json:"psn_pay"`
+			AcctPay         float64 `json:"acct_pay"`
+			CashPayamt      float64 `json:"cash_payamt"`
+			Balc            float64 `json:"balc"`
+			AcctMulaidPay   float64 `json:"acct_mulaid_pay"`
+			MedinsSetlId    string  `json:"medins_setl_id"`
+			RefdSetlFlag    string  `json:"refd_setl_flag"`
+			SetlTime        string  `json:"setl_time"`
+		} `json:"setlinfo"`
+	} `json:"output"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Signtype    interface{} `json:"signtype"`
+	WarnMsg     interface{} `json:"warn_msg"`
+}
+
 type Custom struct {
 	DetItemFeeSumamt string
 	Cut              string
@@ -1584,9 +1636,7 @@ func (c *HisApiController) GetRegisterInfo() {
 		c.ServeSuccessJSON(map[string]interface{}{
 			"his_info": hisPatient,
 		})
-
 	}
-
 }
 
 //上传明细----结算
@@ -2173,6 +2223,7 @@ func (c *HisApiController) Refund() {
 	}
 }
 
+//对账
 func (c *HisApiController) GetCheckAccount() {
 	start_time := c.GetString("start_time")
 	end_time := c.GetString("end_time")
@@ -2199,6 +2250,15 @@ func (c *HisApiController) GetCheckAccount() {
 		medfee_sumamt, _ = decimal.NewFromFloat(medfee_sumamt).Add(decimal.NewFromFloat(item.MedfeeSumamt)).Float64()
 		acct_pay, _ = decimal.NewFromFloat(acct_pay).Add(decimal.NewFromFloat(item.AcctPay)).Float64()
 		fund_pay_sumamt, _ = decimal.NewFromFloat(fund_pay_sumamt).Add(decimal.NewFromFloat(item.FundPaySumamt)).Float64()
+
+	}
+
+	var user_name string
+	role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, adminUser.AdminUser.Id)
+	if role.ID == 0 {
+		user_name = "xxx"
+	} else {
+		user_name = role.UserName
 	}
 
 	if config.IsOpen == 1 {
@@ -2217,7 +2277,7 @@ func (c *HisApiController) GetCheckAccount() {
 			"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
 			"&secret_key=" + miConfig.SecretKey +
 			"&org_name=" + miConfig.OrgName +
-			"&doctor=某人"
+			"&doctor=" + user_name
 
 		fmt.Println(api)
 		resp, requestErr := http.Get(api)
@@ -2258,6 +2318,8 @@ func (c *HisApiController) GetCheckAccount() {
 		}
 	}
 }
+
+//对账明细
 func (c *HisApiController) GetCheckDetailAccount() {
 	start_time := c.GetString("start_time")
 	end_time := c.GetString("end_time")
@@ -2321,13 +2383,21 @@ func (c *HisApiController) GetCheckDetailAccount() {
 
 	if config.IsOpen == 1 {
 
+		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:         "某人",
+			Doctor:         user_name,
 		}
 
 		result := service.Gdyb9101(baseParams, zip_name, ReadFile(zip_path))
@@ -2362,7 +2432,7 @@ func (c *HisApiController) GetCheckDetailAccount() {
 				"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
 				"&secret_key=" + miConfig.SecretKey +
 				"&org_name=" + miConfig.OrgName +
-				"&doctor=某人"
+				"&doctor=" + user_name
 			resp, requestErr := http.Get(api)
 			if requestErr != nil {
 				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
@@ -2403,6 +2473,213 @@ func (c *HisApiController) GetCheckDetailAccount() {
 	}
 }
 
+func (c *HisApiController) GetSettleAccounts() {
+	//id, _ := c.GetInt64("id")
+	//record_time := c.GetString("record_time")
+	order_id, _ := c.GetInt64("order_id")
+
+	//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()
+	adminUser := c.GetAdminUserInfo()
+	//his, _ := service.GetVMHisPatientInfo(adminUser.CurrentOrgId, id, recordDateTime)
+	order, _ := service.GetHisOrderByID(order_id)
+	orderInfos, _ := service.GetHisOrderInfoByNumber(order.Number)
+
+	var bedCostTotal float64 = 0         //床位总费
+	var bedCostSelfTotal float64 = 0     //床位自费
+	var bedCostPartSelfTotal float64 = 0 //床位部分项目自费
+
+	var operationCostTotal float64 = 0         //手术费
+	var operationCostSelfTotal float64 = 0     //手术费
+	var operationCostPartSelfTotal float64 = 0 //手术费
+
+	var otherCostTotal float64 = 0         //其他费用
+	var otherCostSelfTotal float64 = 0     //其他费用
+	var otherCostPartSelfTotal float64 = 0 //其他费用
+
+	var materialCostTotal float64 = 0         //材料费
+	var materialCostSelfTotal float64 = 0     //材料费
+	var materialCostPartSelfTotal float64 = 0 //材料费
+
+	var westernMedicineCostTotal float64 = 0         //西药费
+	var westernMedicineCostSelfTotal float64 = 0     //西药费
+	var westernMedicineCostPartSelfTotal float64 = 0 //西药费
+
+	var chineseTraditionalMedicineCostTotal float64 = 0         //中成药
+	var chineseTraditionalMedicineCostSelfTotal float64 = 0     //中成药
+	var chineseTraditionalMedicineCostPartSelfTotal float64 = 0 //中成药
+
+	var checkCostTotal float64 = 0         //检查费
+	var checkCostSelfTotal float64 = 0     //检查费
+	var checkCostPartSelfTotal float64 = 0 //检查费
+
+	var laboratoryCostTotal float64 = 0         //化验费
+	var laboratoryCostSelfTotal float64 = 0     //化验费
+	var laboratoryCostPartSelfTotal float64 = 0 //化验费
+
+	var treatCostTotal float64 = 0         //治疗费用
+	var treatCostSelfTotal float64 = 0     //治疗费用
+	var treatCostPartSelfTotal float64 = 0 //治疗费用
+
+	decimal.DivisionPrecision = 2
+
+	for _, item := range orderInfos {
+		if item.MedChrgitmType == "01" { //床位费
+
+			bedCostTotal, _ = decimal.NewFromFloat(bedCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			bedCostSelfTotal, _ = decimal.NewFromFloat(bedCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			bedCostPartSelfTotal, _ = decimal.NewFromFloat(bedCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "03" { //检查费
+
+			checkCostTotal, _ = decimal.NewFromFloat(checkCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			checkCostSelfTotal, _ = decimal.NewFromFloat(checkCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			checkCostPartSelfTotal, _ = decimal.NewFromFloat(checkCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "04" { //化验费
+
+			laboratoryCostTotal, _ = decimal.NewFromFloat(laboratoryCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			laboratoryCostSelfTotal, _ = decimal.NewFromFloat(laboratoryCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			laboratoryCostPartSelfTotal, _ = decimal.NewFromFloat(laboratoryCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "05" { //治疗费
+
+			treatCostTotal, _ = decimal.NewFromFloat(treatCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			treatCostSelfTotal, _ = decimal.NewFromFloat(treatCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			treatCostPartSelfTotal, _ = decimal.NewFromFloat(treatCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "06" { //手术费
+
+			operationCostTotal, _ = decimal.NewFromFloat(operationCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			operationCostSelfTotal, _ = decimal.NewFromFloat(operationCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			operationCostPartSelfTotal, _ = decimal.NewFromFloat(operationCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "08" { //材料费
+
+			materialCostTotal, _ = decimal.NewFromFloat(materialCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			materialCostSelfTotal, _ = decimal.NewFromFloat(materialCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			materialCostPartSelfTotal, _ = decimal.NewFromFloat(materialCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "09" { //西药费
+
+			westernMedicineCostTotal, _ = decimal.NewFromFloat(westernMedicineCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			westernMedicineCostSelfTotal, _ = decimal.NewFromFloat(westernMedicineCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			westernMedicineCostPartSelfTotal, _ = decimal.NewFromFloat(westernMedicineCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "11" { //中成费
+
+			chineseTraditionalMedicineCostTotal, _ = decimal.NewFromFloat(chineseTraditionalMedicineCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			chineseTraditionalMedicineCostSelfTotal, _ = decimal.NewFromFloat(chineseTraditionalMedicineCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			chineseTraditionalMedicineCostPartSelfTotal, _ = decimal.NewFromFloat(chineseTraditionalMedicineCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+
+		}
+
+		if item.MedChrgitmType == "14" { //其他费
+			otherCostTotal, _ = decimal.NewFromFloat(otherCostTotal).Add(decimal.NewFromFloat(item.DetItemFeeSumamt)).Float64()
+			otherCostSelfTotal, _ = decimal.NewFromFloat(otherCostSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+			otherCostPartSelfTotal, _ = decimal.NewFromFloat(otherCostPartSelfTotal).Add(decimal.NewFromFloat(item.FulamtOwnpayAmt)).Float64()
+		}
+
+	}
+
+	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,
+	}
+
+	businessParams := models.BusinessParams{
+		PsnNo:   order.PsnNo,
+		MdtrtId: order.MdtrtId,
+		SetlId:  order.SetlId,
+	}
+
+	if config.IsOpen == 1 {
+		result := service.Gdyb5203(baseParams, businessParams)
+		var dat map[string]interface{}
+		if err := json.Unmarshal([]byte(result), &dat); err == nil {
+			fmt.Println(dat)
+		} else {
+			fmt.Println(err)
+		}
+		userJSONBytes, _ := json.Marshal(dat)
+		var res ResultEleven
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		if res.Infcode == 0 {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"info":                                        res.Output.Setlinfo,
+				"bedCostTotal":                                bedCostTotal,
+				"bedCostSelfTotal":                            bedCostSelfTotal,
+				"bedCostPartSelfTotal":                        bedCostPartSelfTotal,
+				"operationCostTotal":                          operationCostTotal,
+				"operationCostSelfTotal":                      operationCostSelfTotal,
+				"operationCostPartSelfTotal":                  operationCostPartSelfTotal,
+				"otherCostTotal":                              otherCostTotal,
+				"otherCostSelfTotal":                          otherCostSelfTotal,
+				"otherCostPartSelfTotal":                      otherCostPartSelfTotal,
+				"materialCostTotal":                           materialCostTotal,
+				"materialCostSelfTotal":                       materialCostSelfTotal,
+				"materialCostPartSelfTotal":                   materialCostPartSelfTotal,
+				"westernMedicineCostTotal":                    westernMedicineCostTotal,
+				"westernMedicineCostSelfTotal":                westernMedicineCostSelfTotal,
+				"westernMedicineCostPartSelfTotal":            westernMedicineCostPartSelfTotal,
+				"chineseTraditionalMedicineCostTotal":         chineseTraditionalMedicineCostTotal,
+				"chineseTraditionalMedicineCostSelfTotal":     chineseTraditionalMedicineCostSelfTotal,
+				"chineseTraditionalMedicineCostPartSelfTotal": chineseTraditionalMedicineCostPartSelfTotal,
+				"checkCostTotal":                              checkCostTotal,
+				"checkCostSelfTotal":                          checkCostSelfTotal,
+				"checkCostPartSelfTotal":                      checkCostPartSelfTotal,
+				"laboratoryCostTotal":                         laboratoryCostTotal,
+				"laboratoryCostSelfTotal":                     laboratoryCostSelfTotal,
+				"laboratoryCostPartSelfTotal":                 laboratoryCostPartSelfTotal,
+				"treatCostTotal":                              treatCostTotal,
+				"treatCostSelfTotal":                          treatCostSelfTotal,
+				"treatCostPartSelfTotal":                      treatCostPartSelfTotal,
+			})
+		}
+	}
+
+}
+
 func (this *HisApiController) AdditionalCharge() {
 
 	dataBody := make(map[string]interface{}, 0)

models/his_models.go

@@ -943,4 +943,7 @@ type BusinessParams struct {
 	FixmedinsSetlCnt int64
 	FileQuryNo       string
 	CashPayamt       float64
+	PsnNo            string
+	MdtrtId          string
+	SetlId           string
 }

service/gdyb_service.go

@@ -977,6 +977,57 @@ func Gdyb3202(baseParams models.BaseParams, businessParams models.BusinessParams
 	return str
 }
 
+func Gdyb5203(baseParams models.BaseParams, businessParams models.BusinessParams) 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"] = "5203" // 交易编码
+	inputData["psn_no"] = businessParams.PsnNo
+	inputData["setl_id"] = businessParams.SetlId
+	inputData["mdtrt_id"] = businessParams.MdtrtId
+	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_inf/poc/hsa/hgs/3202"
+	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", "test_hosp")
+	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 {
 //	// 生成签名

service/his_service.go

@@ -795,7 +795,12 @@ func GetCallHisPrescriptions(start_time int64, end_time int64, org_id int64, pat
 }
 
 func GetHisOrderByID(order_id int64) (order models.HisOrder, err error) {
-	err = readDb.Model(&models.HisOrder{}).Where("id = ?", order_id).First(&order).Error
+	err = readDb.Model(&models.HisOrder{}).Where("id = ? AND status = 1", order_id).First(&order).Error
+	return
+}
+
+func GetHisOrderInfoByNumber(order_number string) (order []*models.HisOrderInfo, err error) {
+	err = readDb.Model(&models.HisOrderInfo{}).Where("order_number = ? AND status = 1", order_number).Find(&order).Error
 	return
 }