更新

service/ah_dianzichufang.go

@@ -7,8 +7,10 @@ import (
 	"gdyb/models"
 	"io/ioutil"
 	"net/http"
-	"strconv"
+	//"strconv"
 	"time"
+
+
 )
 
 func GetAHCFYLJG001(org_name string, opera string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, url string, cFYLJG001 models.CFYLJG001, isu string, cainfo string) (string, string) {
@@ -392,140 +394,10 @@ func GetAHCFYLJG004(org_name string, doctor string, fixmedins_code string, insup
 	}
 
 	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
-	request.Header.Set("x-tif-paasid", gdyb_paasid)
-	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(), ""
-	}
-	fmt.Println(string(respBytes))
-	str := string(respBytes)
-	return str, inputLog
-
-}
-
-func GetAHCFYLJG005(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG005 models.CFYLJG005, cainfo string) (string, string) {
-	//生成签名
-	nonce := GetRandomString(32)
-	timestamp := time.Now().Unix()
-	signature := setSignature(timestamp, nonce, secret_key)
-	//生成输入报文
-	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
-
-	inputData := make(map[string]interface{})
-
-	inputData2 := make(map[string]interface{})
-	//inputDatas := make([]map[string]interface{}, 0)
-	inputMessage["infno"] = "7105"
-	inputData["fixmedinsCode"] = fixmedins_code
-	inputData["hiRxno"] = cFYLJG005.HiRxno
-	inputData["mdtrtId"] = cFYLJG005.MdtrtID
-	inputData["psnName"] = cFYLJG005.PsnName
-	inputData["psnCertType"] = cFYLJG005.PsnCertType
-	inputData["certno"] = cFYLJG005.Certno
-	inputData2["data"] = inputData
-	inputMessage["input"] = inputData2
-	argInputMessage := make(map[string]interface{})
-	argInputMessage["arg0"] = inputMessage
-	var inputLog string
-	bytesData, err := json.Marshal(inputMessage)
-	inputLog = string(bytesData)
-	fmt.Println(string(bytesData))
-	if err != nil {
-		fmt.Println(err.Error())
-		return err.Error(), ""
-	}
-	reader := bytes.NewReader(bytesData)
-
-	var url string
-
-	url = url + "7105"
-
-	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
-	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")
-	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(), ""
-	}
-	fmt.Println(string(respBytes))
-	str := string(respBytes)
-	return str, inputLog
-
-}
-func GetAHCFYLJG006(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG006 models.CFYLJG006) (string, string) {
-	//生成签名
-	nonce := GetRandomString(32)
-	timestamp := time.Now().Unix()
-	signature := setSignature(timestamp, nonce, secret_key)
-	//生成输入报文
-	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
-	inputData := make(map[string]interface{})
-	//inputDatas := make([]map[string]interface{}, 0)
-	inputData2 := make(map[string]interface{})
-
-	inputMessage["infno"] = "CFYLJG006"
-	inputData["fixmedinsCode"] = fixmedins_code
-	inputData["hiRxno"] = cFYLJG006.HiRxno
-	inputData["mdtrtId"] = cFYLJG006.MdtrtID
-	inputData["psnName"] = cFYLJG006.PsnName
-	inputData["psnCertType"] = cFYLJG006.PsnCertType
-	inputData["certno"] = cFYLJG006.Certno
-	inputData2["data"] = inputData
-	inputMessage["input"] = inputData2
-	var inputLog string
-	bytesData, err := json.Marshal(inputMessage)
-	inputLog = string(bytesData)
-	fmt.Println(string(bytesData))
-	if err != nil {
-		fmt.Println(err.Error())
-		return err.Error(), ""
-	}
-	reader := bytes.NewReader(bytesData)
-	gdyb_url := beego.AppConfig.String("gdyb_url")
-	gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
-
-	var url string
-	if fixmedins_code == "H15049901371" {
-		url = gdyb_url
-	} else {
-		url = gdyb_url + "CFYLJG006"
-	}
-
-	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
-	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", gdyb_paasid)
-	request.Header.Set("x-tif-signature", signature)
-	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
-	request.Header.Set("x-tif-nonce", nonce)
+	//request.Header.Set("x-tif-paasid", gdyb_paasid)
+	//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)
@@ -543,78 +415,208 @@ func GetAHCFYLJG006(org_name string, doctor string, fixmedins_code string, insup
 	return str, inputLog
 
 }
-func GetAHCFYLJG007(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG007 models.CFYLJG007) (string, string) {
-	//生成签名
-	nonce := GetRandomString(32)
-	timestamp := time.Now().Unix()
-	signature := setSignature(timestamp, nonce, secret_key)
-	//生成输入报文
-	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
-	inputData := make(map[string]interface{})
-	inputData2 := make(map[string]interface{})
-
-	//inputDatas := make([]map[string]interface{}, 0)
-
-	inputMessage["infno"] = "CFYLJG007"
-
-	inputData["fixmedinsCode"] = fixmedins_code
-	inputData["hiRxno"] = cFYLJG007.HiRxno
-	inputData["mdtrtId"] = cFYLJG007.MdtrtID
-	inputData["psnCertType"] = cFYLJG007.PsnCertType
-	inputData["certno"] = cFYLJG007.Certno
-	inputData["psnName"] = cFYLJG007.PsnName
-
-	inputData2["data"] = inputData
 
-	inputMessage["input"] = inputData2
-	var inputLog string
-	bytesData, err := json.Marshal(inputMessage)
-	inputLog = string(bytesData)
-	fmt.Println(string(bytesData))
-	if err != nil {
-		fmt.Println(err.Error())
-		return err.Error(), ""
-	}
-	reader := bytes.NewReader(bytesData)
-	gdyb_url := beego.AppConfig.String("gdyb_url")
-	gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
-
-	var url string
-	if fixmedins_code == "H15049901371" {
-		url = gdyb_url
-	} else {
-		url = gdyb_url + "CFYLJG007"
-	}
-
-	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
-	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", gdyb_paasid)
-	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(), ""
-	}
-	fmt.Println(string(respBytes))
-	str := string(respBytes)
-	return str, inputLog
-
-}
+//func GetAHCFYLJG005(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG005 models.CFYLJG005, cainfo string) (string, string) {
+//	//生成签名
+//	nonce := GetRandomString(32)
+//	timestamp := time.Now().Unix()
+//	//signature := setSignature(timestamp, nonce, secret_key)
+//	//生成输入报文
+//	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+//
+//	inputData := make(map[string]interface{})
+//
+//	inputData2 := make(map[string]interface{})
+//	//inputDatas := make([]map[string]interface{}, 0)
+//	inputMessage["infno"] = "7105"
+//	inputData["fixmedinsCode"] = fixmedins_code
+//	inputData["hiRxno"] = cFYLJG005.HiRxno
+//	inputData["mdtrtId"] = cFYLJG005.MdtrtID
+//	inputData["psnName"] = cFYLJG005.PsnName
+//	inputData["psnCertType"] = cFYLJG005.PsnCertType
+//	inputData["certno"] = cFYLJG005.Certno
+//	inputData2["data"] = inputData
+//	inputMessage["input"] = inputData2
+//	argInputMessage := make(map[string]interface{})
+//	argInputMessage["arg0"] = inputMessage
+//	var inputLog string
+//	bytesData, err := json.Marshal(inputMessage)
+//	inputLog = string(bytesData)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error(), ""
+//	}
+//	reader := bytes.NewReader(bytesData)
+//
+//	var url string
+//
+//	url = url + "7105"
+//
+//	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
+//	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")
+//	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(), ""
+//	}
+//	fmt.Println(string(respBytes))
+//	str := string(respBytes)
+//	return str, inputLog
+//
+//}
+//func GetAHCFYLJG006(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG006 models.CFYLJG006) (string, string) {
+//	//生成签名
+//	nonce := GetRandomString(32)
+//	timestamp := time.Now().Unix()
+//	signature := setSignature(timestamp, nonce, secret_key)
+//	//生成输入报文
+//	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+//	inputData := make(map[string]interface{})
+//	//inputDatas := make([]map[string]interface{}, 0)
+//	inputData2 := make(map[string]interface{})
+//
+//	inputMessage["infno"] = "CFYLJG006"
+//	inputData["fixmedinsCode"] = fixmedins_code
+//	inputData["hiRxno"] = cFYLJG006.HiRxno
+//	inputData["mdtrtId"] = cFYLJG006.MdtrtID
+//	inputData["psnName"] = cFYLJG006.PsnName
+//	inputData["psnCertType"] = cFYLJG006.PsnCertType
+//	inputData["certno"] = cFYLJG006.Certno
+//	inputData2["data"] = inputData
+//	inputMessage["input"] = inputData2
+//	var inputLog string
+//	bytesData, err := json.Marshal(inputMessage)
+//	inputLog = string(bytesData)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error(), ""
+//	}
+//	reader := bytes.NewReader(bytesData)
+//	gdyb_url := beego.AppConfig.String("gdyb_url")
+//	gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
+//
+//	var url string
+//	if fixmedins_code == "H15049901371" {
+//		url = gdyb_url
+//	} else {
+//		url = gdyb_url + "CFYLJG006"
+//	}
+//
+//	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
+//	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", gdyb_paasid)
+//	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(), ""
+//	}
+//	fmt.Println(string(respBytes))
+//	str := string(respBytes)
+//	return str, inputLog
+//
+//}
+//func GetAHCFYLJG007(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG007 models.CFYLJG007) (string, string) {
+//	//生成签名
+//	nonce := GetRandomString(32)
+//	timestamp := time.Now().Unix()
+//	signature := setSignature(timestamp, nonce, secret_key)
+//	//生成输入报文
+//	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+//	inputData := make(map[string]interface{})
+//	inputData2 := make(map[string]interface{})
+//
+//	//inputDatas := make([]map[string]interface{}, 0)
+//
+//	inputMessage["infno"] = "CFYLJG007"
+//
+//	inputData["fixmedinsCode"] = fixmedins_code
+//	inputData["hiRxno"] = cFYLJG007.HiRxno
+//	inputData["mdtrtId"] = cFYLJG007.MdtrtID
+//	inputData["psnCertType"] = cFYLJG007.PsnCertType
+//	inputData["certno"] = cFYLJG007.Certno
+//	inputData["psnName"] = cFYLJG007.PsnName
+//
+//	inputData2["data"] = inputData
+//
+//	inputMessage["input"] = inputData2
+//	var inputLog string
+//	bytesData, err := json.Marshal(inputMessage)
+//	inputLog = string(bytesData)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error(), ""
+//	}
+//	reader := bytes.NewReader(bytesData)
+//	gdyb_url := beego.AppConfig.String("gdyb_url")
+//	gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
+//
+//	var url string
+//	if fixmedins_code == "H15049901371" {
+//		url = gdyb_url
+//	} else {
+//		url = gdyb_url + "CFYLJG007"
+//	}
+//
+//	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/1101"
+//	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", gdyb_paasid)
+//	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(), ""
+//	}
+//	fmt.Println(string(respBytes))
+//	str := string(respBytes)
+//	return str, inputLog
+//
+//}
 
 //func GetAHCFYLJG008(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, cFYLJG008 models.CFYLJG008) (string, string) {
 //	//生成签名

service/db.go

@@ -76,7 +76,7 @@ func ConnectDB() {
 
 	readDb, err = gorm.Open("mysql", rdsn)
 	if err != nil {
-		//beego.Error(err)
+		beego.Error(err)
 	}
 	readDb.DB().SetMaxIdleConns(10)
 	readDb.DB().SetMaxOpenConns(100)
@@ -84,7 +84,7 @@ func ConnectDB() {
 
 	writeDb, err = gorm.Open("mysql", wdsn)
 	if err != nil {
-		//beego.Error(err)
+		beego.Error(err)
 	}
 	writeDb.DB().SetMaxIdleConns(10)
 	writeDb.DB().SetMaxOpenConns(100)
@@ -94,7 +94,7 @@ func ConnectDB() {
 
 	readUserDb, err = gorm.Open("mysql", rudsn)
 	if err != nil {
-		//beego.Error(err)
+		beego.Error(err)
 	}
 	readUserDb.DB().SetMaxIdleConns(10)
 	readUserDb.DB().SetMaxOpenConns(100)
@@ -102,7 +102,7 @@ func ConnectDB() {
 
 	writeUserDb, err = gorm.Open("mysql", wudsn)
 	if err != nil {
-		//beego.Error(err)
+		beego.Error(err)
 	}
 	writeUserDb.DB().SetMaxIdleConns(10)
 	writeUserDb.DB().SetMaxOpenConns(100)

service/jx_service.go

@@ -2089,6 +2089,37 @@ func Jxyb3201(fixmedins_setl_cnt int64,  stmt_begndate string, stmt_enddate stri
 	return JXHttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData), "3201"), string(bytesData)
 }
 
+func Jxyb32012(fixmedins_setl_cnt int64,  stmt_begndate string, stmt_enddate string, clr_type string, insutype string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, secret_key string,medfee_sumamt string,fund_pay_sumamt string,acct_pay string) (string, string) {
+	// 生成签名
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJXInputMessage(timestamp, org_name, doctor, fixmedins_code, "361025", "361025", "")
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3201"                       // 交易编码
+	inputData["insutype"] = insutype                     // 险种
+	inputData["clr_type"] = clr_type                     // 就诊 ID（来自2201接口返回）
+	inputData["setl_optins"] = "361025"               // 结算经办机构
+	inputData["stmt_begndate"] = stmt_begndate           // 对帐开始时间
+	inputData["stmt_enddate"] = stmt_enddate             //对帐结束时间
+	inputData["medfee_sumamt"] = medfee_sumamt           //医疗费总额
+	inputData["fund_pay_sumamt"] = fund_pay_sumamt       //基金支付总额
+	inputData["acct_pay"] = acct_pay                     //个人账户支付金额
+	inputData["fixmedins_setl_cnt"] = fixmedins_setl_cnt //定点医药机构结算笔数
+	inputData["refd_setl_flag"] = 0                  //
+
+	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(), ""
+	}
+	request_url = request_url + "3201"
+	return JXHttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData), "3201"), string(bytesData)
+}
+
 func Jxyb9001(org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, admin_user_id int64, request_url string, cainfo string, access_key string) (string, string) {
 
 	// 生成签名