医保对接

controllers/gdyb_controller.go

@@ -391,40 +391,40 @@ func (c *GdybController) PostTen() {
 }
 
 func (c *GdybController) PostEleven() {
-	fmt.Println("777777666666-----")
-
-	file_byte := c.GetString("file_byte")
-	file_name := c.GetString("file_name")
-	fixmedins_code := c.GetString("fixmedins_code")
-	insuplc_admdvs := c.GetString("insuplc_admdvs")
-	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
-	secret_key := c.GetString("secret_key")
-	org_name := c.GetString("org_name")
-	doctor := c.GetString("doctor")
-
-	baseParams := models.BaseParams{
-		SecretKey:      secret_key,
-		FixmedinsCode:  fixmedins_code,
-		InsuplcAdmdvs:  insuplc_admdvs,
-		MdtrtareaAdmvs: mdtrtarea_admvs,
-		OrgName:        org_name,
-		Doctor:         doctor,
-	}
+	//fmt.Println("777777666666-----")
+	//
+	//file_byte := c.GetString("file_byte")
+	//file_name := c.GetString("file_name")
+	//fixmedins_code := c.GetString("fixmedins_code")
+	//insuplc_admdvs := c.GetString("insuplc_admdvs")
+	//mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	//secret_key := c.GetString("secret_key")
+	//org_name := c.GetString("org_name")
+	//doctor := c.GetString("doctor")
+	//
+	//baseParams := models.BaseParams{
+	//	SecretKey:      secret_key,
+	//	FixmedinsCode:  fixmedins_code,
+	//	InsuplcAdmdvs:  insuplc_admdvs,
+	//	MdtrtareaAdmvs: mdtrtarea_admvs,
+	//	OrgName:        org_name,
+	//	Doctor:         doctor,
+	//}
 
 	//x := (*[2]uintptr)(unsafe.Pointer(&file_byte))
 	//h := [3]uintptr{x[0], x[1], x[1]}
 	//bytes := *(*[]byte)(unsafe.Pointer(&h))
 
-	result := service.Gdyb9101(baseParams, file_name, []byte(file_byte))
-	var dat map[string]interface{}
-	if err := json.Unmarshal([]byte(result), &dat); err == nil {
-		fmt.Println(dat)
-	} else {
-		fmt.Println(err)
-	}
-	c.ServeSuccessJSON(map[string]interface{}{
-		"pre": dat,
-	})
+	//result := service.Gdyb9101(baseParams, file_name, []byte(file_byte))
+	//var dat map[string]interface{}
+	//if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	//	fmt.Println(dat)
+	//} else {
+	//	fmt.Println(err)
+	//}
+	//c.ServeSuccessJSON(map[string]interface{}{
+	//	"pre": dat,
+	//})
 }
 
 func (c *GdybController) PostTwelve() {

controllers/his_api_controller.go

@@ -59,7 +59,7 @@ func HisManagerApiRegistRouters() {
 	beego.Router("/api/checkaccount/get", &HisApiController{}, "get:GetCheckAccount")
 	beego.Router("/api/checkdetailaccount/get", &HisApiController{}, "get:GetCheckDetailAccount")
 
-	beego.Router("/api/refund/post", &HisApiController{}, "post:Refund")
+	beego.Router("/api/refund/post", &HisApiController{}, "get:Refund")
 
 	beego.Router("/api/medicalinsurance/config", &HisApiController{}, "get:GetMedicalInsuranceConfig")
 
@@ -1190,6 +1190,7 @@ type ResultSix struct {
 	Signtype    interface{} `json:"signtype"`
 	WarnMsg     interface{} `json:"warn_msg"`
 }
+
 type ResultSeven struct {
 	Cainfo      string `json:"cainfo"`
 	ErrMsg      string `json:"err_msg"`
@@ -1279,6 +1280,22 @@ type ResultNine struct {
 	WarnMsg     interface{} `json:"warn_msg"`
 }
 
+type ResultTen struct {
+	Cainfo      string `json:"cainfo"`
+	ErrMsg      string `json:"err_msg"`
+	InfRefmsgid string `json:"inf_refmsgid"`
+	Infcode     int64  `json:"infcode"`
+	Output      struct {
+		DldEndtime string `json:"dld_endtime"`
+		FileQuryNo string `json:"file_qury_no"`
+		Filename   string `json:"filename"`
+	} `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
@@ -1893,7 +1910,8 @@ func (c *HisApiController) GetUploadInfo() {
 					}
 				}
 			} else {
-
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCalOrderException)
+				return
 			}
 
 		} else {
@@ -2298,36 +2316,30 @@ func (c *HisApiController) GetCheckDetailAccount() {
 
 	}
 	Zip(file_path, zip_path)
+	fmt.Println(ReadFile(zip_path))
+	fmt.Println(string(ReadFile(zip_path)))
+
 	if config.IsOpen == 1 {
-		api := "http://127.0.0.1:9532/" + "gdyb/eleven?" +
-			"file_byte=" + string(ReadFile(zip_path)) +
-			"&file_name=" + zip_name +
-			"&fixmedins_code=" + miConfig.Code +
-			"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs +
-			"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
-			"&secret_key=" + miConfig.SecretKey +
-			"&org_name=" + miConfig.OrgName +
-			"&doctor=某人"
 
-		resp, requestErr := http.Get(api)
-		if requestErr != nil {
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-			return
-		}
-		body, ioErr := ioutil.ReadAll(resp.Body)
-		if ioErr != nil {
-			utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
-			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-			return
+		baseParams := models.BaseParams{
+			SecretKey:      miConfig.SecretKey,
+			FixmedinsCode:  miConfig.Code,
+			InsuplcAdmdvs:  miConfig.InsuplcAdmdvs,
+			MdtrtareaAdmvs: miConfig.MdtrtareaAdmvs,
+			OrgName:        miConfig.OrgName,
+			Doctor:         "某人",
 		}
-		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
+
+		result := service.Gdyb9101(baseParams, zip_name, ReadFile(zip_path))
+
+		var dat map[string]interface{}
+		if err := json.Unmarshal([]byte(result), &dat); err == nil {
+			fmt.Println(dat)
+		} else {
+			fmt.Println(err)
 		}
-		respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
-		userJSONBytes, _ := json.Marshal(respJSON)
+
+		userJSONBytes, _ := json.Marshal(dat)
 
 		var res ResultNine
 		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
@@ -2336,7 +2348,6 @@ func (c *HisApiController) GetCheckDetailAccount() {
 			return
 		}
 		if res.Infcode == 0 {
-
 			api := "http://127.0.0.1:9532/" + "gdyb/twelve?" +
 				"file_qury_no=" + res.Output.FileQuryNo +
 				"&setl_optins=" + miConfig.OrgName +
@@ -2352,7 +2363,6 @@ func (c *HisApiController) GetCheckDetailAccount() {
 				"&secret_key=" + miConfig.SecretKey +
 				"&org_name=" + miConfig.OrgName +
 				"&doctor=某人"
-
 			resp, requestErr := http.Get(api)
 			if requestErr != nil {
 				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
@@ -2371,9 +2381,21 @@ func (c *HisApiController) GetCheckDetailAccount() {
 				return
 			}
 			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+
 			userJSONBytes, _ := json.Marshal(respJSON)
-			fmt.Println(respJSON)
-			fmt.Println(userJSONBytes)
+			var res ResultTen
+			if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+				utils.ErrorLog("解析失败：%v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			if res.Infcode == 0 {
+				service.Gdyb9102(baseParams, zip_name, res.Output.FileQuryNo)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"msg": "明细对账成功",
+				})
+			}
 
 		} else {
 

enums/error_code.go

@@ -220,6 +220,8 @@ const ( // ErrorCode
 	ErrorCodeRegisterTwoException = 20067
 
 	ErrorCodeCreateOrderException = 20068
+
+	ErrorCodeCalOrderException = 20069
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -430,6 +432,8 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodeRegisterTwoException: "挂号失败",
 
 	ErrorCodeCreateOrderException: "创建预结算订单失败",
+
+	ErrorCodeCalOrderException: "结算失败",
 }
 
 type SGJError struct {

service/gdyb_service.go

@@ -13,7 +13,9 @@ import (
 	"mime/multipart"
 	"net/http"
 	"os"
+	"path/filepath"
 	"strconv"
+	"strings"
 	"time"
 	_ "unsafe"
 )
@@ -38,7 +40,7 @@ func Gdyb1101(certNo string, org_name string, doctor string, fixmedins_code stri
 	inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
 	inputData["card_sn"] = ""           // 卡识别码
 	inputData["begntime"] = ""          // 开始时间
-	inputData["psn_cert_type"] = ""     // 人员证件类型
+	inputData["psn_cert_type"] = "1"    // 人员证件类型
 	inputData["certno"] = certNo        // 证件号码
 	inputData["psn_name"] = ""          // 人员姓名
 	input["data"] = inputData
@@ -798,23 +800,31 @@ func Gdyb3201(baseParams models.BaseParams, businessParams models.BusinessParams
 	return str
 }
 
+type Params struct {
+	FileName      string `json:"file_name"`      //产品ID
+	In            []byte `json:"in"`             //
+	FixmedinsCode string `json:"fixmedins_code"` //调用环境生产为1 沙盒2
+}
+
+//文件上传
 //文件上传
 func Gdyb9101(baseParams models.BaseParams, file_name string, file_byte []byte) string {
 
-	//http.Post(strinUrl,"multipart/form-data",bytes.NewReader(file_byte))
-
 	// 生成签名
 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
 	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
 
-	// 生成输入报文
+	buf := new(bytes.Buffer)
+	buf.ReadFrom(strings.NewReader(string(file_byte)))
+
 	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"] = "9101"                         // 交易编码
 	inputData["file_name"] = file_name                     //文件名
-	inputData["in"] = file_byte                            //文件数据
+	inputData["in"] = bytes.NewBuffer(file_byte).Bytes()   //文件数据
 	inputData["fixmedins_code"] = baseParams.FixmedinsCode //编码
 
 	input["fsUploadIn"] = inputData
@@ -857,6 +867,59 @@ func Gdyb9101(baseParams models.BaseParams, file_name string, file_byte []byte)
 	return str
 }
 
+func Gdyb9102(baseParams models.BaseParams, file_name string, file_qury_no 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"] = "9102"                                 // 交易编码
+	inputData["file_name"] = file_name                             //文件名
+	inputData["file_qury_no"] = "fsi/H44022900158/" + file_qury_no //文件数据
+	inputData["fixmedins_code"] = baseParams.FixmedinsCode         //编码
+	input["fsDownloadIn"] = 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/9102"
+	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 Gdyb3202(baseParams models.BaseParams, businessParams models.BusinessParams) string {
 	// 生成签名
 	nonce := GetRandomString(32)
@@ -867,15 +930,15 @@ func Gdyb3202(baseParams models.BaseParams, businessParams models.BusinessParams
 	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"] = "3202"                                    // 交易编码
-	inputData["file_qury_no"] = businessParams.FileQuryNo             // 险种
-	inputData["setl_optins"] = baseParams.OrgName                     // 结算经办机构
-	inputData["stmt_begndate"] = businessParams.StmtBegndate          // 对帐开始时间
-	inputData["stmt_enddate"] = businessParams.StmtEnddate            //对帐结束时间
-	inputData["medfee_sumamt"] = businessParams.MedfeeSumamt          //医疗费总额
-	inputData["fund_pay_sumamt"] = businessParams.FundPaySumamt       //基金支付总额
-	inputData["cash_payamt"] = businessParams.CashPayamt              //现金支付金额
-	inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt //定点医药机构结算笔数
+	inputMessage["infno"] = "3202"                                              // 交易编码
+	inputData["file_qury_no"] = "fsi/H44022900158/" + businessParams.FileQuryNo // 险种
+	inputData["setl_optins"] = baseParams.OrgName                               // 结算经办机构
+	inputData["stmt_begndate"] = businessParams.StmtBegndate                    // 对帐开始时间
+	inputData["stmt_enddate"] = businessParams.StmtEnddate                      //对帐结束时间
+	inputData["medfee_sumamt"] = businessParams.MedfeeSumamt                    //医疗费总额
+	inputData["fund_pay_sumamt"] = businessParams.FundPaySumamt                 //基金支付总额
+	inputData["cash_payamt"] = businessParams.CashPayamt                        //现金支付金额
+	inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt           //定点医药机构结算笔数
 
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入
@@ -1261,3 +1324,31 @@ func postFile(filename string, target_url string) (*http.Response, error) {
 //	fmt.Println(str)
 //	return str
 //}
+
+func newfileUploadRequest(uri string, params map[string]string, paramName, path string) (*http.Request, error) {
+	file, err := os.Open(path)
+	if err != nil {
+		return nil, err
+	}
+	defer file.Close()
+
+	body := &bytes.Buffer{}
+	writer := multipart.NewWriter(body)
+	part, err := writer.CreateFormFile(paramName, filepath.Base(path))
+	if err != nil {
+		return nil, err
+	}
+	_, err = io.Copy(part, file)
+
+	for key, val := range params {
+		_ = writer.WriteField(key, val)
+	}
+	err = writer.Close()
+	if err != nil {
+		return nil, err
+	}
+
+	req, err := http.NewRequest("POST", uri, body)
+	req.Header.Set("Content-Type", writer.FormDataContentType())
+	return req, err
+}