Merge branch 'master' of http://git.shengws.com/csx/gdyb

conf/app.conf

@@ -1,6 +1,6 @@
 appname = 血透
 httpport = 9532
-runmode = prod
+runmode = dev
 
 
 #
@@ -166,14 +166,14 @@ front_end_domain = "http://xt.test.sgjyun.com/#"
 
 org_id = 4
 #url  = "http://192.168.1.228:17001/szsi-portal/transData"
-gdyb_url = "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/"
+# gdyb_url = "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/"
 #gdyb_url = "http://10.97.240.206/ebus/sztest_hosp/poc/hsa/hgs/"
 #url = "http://192.168.1.88:6666/szsi-portal/transData"
 #gdyb_url = "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/"
 #gdyb_url = "http://10.87.67.83:8080/mbs-hi-intf/web/api/webservices/hb/interface/"
 #gdyb_paasid = "test_sz"
 #gdyb_paasid = zh_cs
-gdyb_paasid = test_hosp
+# gdyb_paasid = test_hosp
 #gdyb_paasid = zq_prd_yjyy
 
 #gdyb_paasid = "zh_prd_yjyy"

controllers/js/jsyb_controller.go

@@ -0,0 +1,402 @@
+package js
+
+import (
+	"encoding/json"
+	"fmt"
+	"gdyb/controllers"
+	"gdyb/models"
+	"gdyb/service"
+	"gdyb/utils"
+	"github.com/astaxie/beego"
+	"io/ioutil"
+)
+
+type JSybController struct {
+	controllers.BaseAuthAPIController
+}
+
+func JSybRegistRouters() {
+	beego.Router("/jsyb/1101", &JSybController{}, "get:PostOne")
+	beego.Router("/jsyb/2201", &JSybController{}, "get:PostTwo")
+	beego.Router("/jsyb/2202", &JSybController{}, "get:PostThree")
+	beego.Router("/jsyb/2203", &JSybController{}, "post:PostFour")
+	beego.Router("/jsyb/2204", &JSybController{}, "post:PostFive")
+	beego.Router("/jsyb/2205", &JSybController{}, "get:PostSix")
+	beego.Router("/jsyb/2206", &JSybController{}, "get:PostSeven")
+	beego.Router("/jsyb/2207", &JSybController{}, "get:PostEight")
+	beego.Router("/jsyb/2208", &JSybController{}, "get:PostNine")
+	beego.Router("/jsyb/5203", &JSybController{}, "get:PostTen")
+}
+
+func (c *JSybController) PostOne() {
+	certNo := c.GetString("cert_no")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	id_card_type, _ := c.GetInt64("id_card_type")
+	card_sn := c.GetString("card_sn")
+	certificates := c.GetString("certificates")
+	url := c.GetString("url")
+	ak := c.GetString("ak")
+	result, inputLog := service.Jsyb1101(certNo, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type, card_sn, certificates, url, ak)
+	fmt.Println(result)
+	fmt.Println(inputLog)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+
+	} else {
+
+	}
+
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(inputLog), &dat2); err == nil {
+
+	} else {
+
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": dat,
+		"log": dat2,
+	})
+}
+func (c *JSybController) PostTwo() {
+	psnNo := c.GetString("psn_no")
+	insutype := c.GetString("insutype")
+	certNo := c.GetString("cert_no")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	ipt_otp_no := c.GetString("ipt_otp_no")
+	dept := c.GetString("dept")
+	fixmedins_code := c.GetString("fixmedins_code")
+
+	dept_code := c.GetString("dept_code")
+	doctor_id := c.GetString("doctor_id")
+
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+
+	secret_key := c.GetString("secret_key")
+
+	id_card_type, _ := c.GetInt64("id_card_type")
+
+	result, _ := service.Hbyb2201(psnNo, insutype, certNo, org_name, doctor, ipt_otp_no, dept, fixmedins_code, dept_code, doctor_id, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type)
+
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		//fmt.Println(dat["status"])
+	} else {
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": dat,
+	})
+}
+func (c *JSybController) PostThree() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	iptOtpNo := c.GetString("ipt_otp_no")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	fixmedins_code := c.GetString("fixmedins_code")
+	result, requestLog := service.Hbyb2202(psnNo, mdtrtId, iptOtpNo, org_name, doctor, insuplc_admdvs, mdtrtarea_admvs, secret_key, fixmedins_code)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": requestLog,
+	})
+}
+
+func (c *JSybController) PostFour() {
+
+	body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
+	var respJSON map[string]interface{}
+	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+		return
+	}
+	userJSONBytes, _ := json.Marshal(respJSON["config"])
+	var config []*models.HisXtDiagnoseConfig
+	if err := json.Unmarshal(userJSONBytes, &config); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+	fmt.Println(respJSON["psn_no"].(string))
+	fmt.Println(respJSON["mdtrt_id"].(string))
+
+	psnNo := respJSON["psn_no"].(string)
+	mdtrtId := respJSON["mdtrt_id"].(string)
+	doctor := respJSON["doctor"].(string)
+	department := respJSON["department"].(string)
+
+	org_name := respJSON["org_name"].(string)
+	med_type := respJSON["med_type"].(string)
+	doctor_id := respJSON["doctor_id"].(string)
+	fixmedins_code := respJSON["fixmedins_code"].(string)
+	sick_code := respJSON["sick_code"].(string)
+	sick_name := respJSON["sick_name"].(string)
+	dept := respJSON["dept"].(string)
+
+	insuplc_admdvs := respJSON["insuplc_admdvs"].(string)
+	mdtrtarea_admvs := respJSON["mdtrtarea_admvs"].(string)
+	secret_key := respJSON["secret_key"].(string)
+
+	result, request_log := service.Hbyb2203(psnNo, mdtrtId, doctor, department, org_name, med_type, doctor_id, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, sick_code, sick_name, dept, config)
+
+	fmt.Println(request_log)
+
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": dat,
+	})
+}
+
+type All struct {
+	HisPrescription HisPrescription
+	mdtrt_id        string
+	psn_no          string
+}
+type HisPrescription struct {
+	ID                     int64                            `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId              int64                            `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	RecordDate             int64                            `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	PatientId              int64                            `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	HisPatientId           int64                            `gorm:"column:his_patient_id" json:"his_patient_id" form:"his_patient_id"`
+	Status                 int64                            `gorm:"column:status" json:"status" form:"status"`
+	Ctime                  int64                            `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime                  int64                            `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Number                 string                           `gorm:"column:number" json:"number" form:"number"`
+	Type                   int64                            `gorm:"column:type" json:"type" form:"type"`
+	Doctor                 int64                            `gorm:"column:doctor" json:"doctor" form:"doctor"`
+	Creator                int64                            `gorm:"column:creator" json:"creator" form:"creator"`
+	Modifier               int64                            `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	HisDoctorAdviceInfo    []*models.HisDoctorAdviceInfo    `gorm:"ForeignKey:PatientId,RecordDate,PrescriptionId;AssociationForeignKey:PatientId,RecordDate,ID" json:"advices"`
+	HisPrescriptionProject []*models.HisPrescriptionProject `gorm:"ForeignKey:PatientId,RecordDate,PrescriptionId;AssociationForeignKey:PatientId,RecordDate,ID" json:"project"`
+}
+
+func (c *JSybController) PostFive() {
+	body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
+	var respJSON map[string]interface{}
+	if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+		utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+		return
+	}
+	userJSONBytes, _ := json.Marshal(respJSON["pre"])
+	var hp []*models.HisPrescription
+	if err := json.Unmarshal(userJSONBytes, &hp); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+	fmt.Println(respJSON["psn_no"].(string))
+	fmt.Println(respJSON["mdtrt_id"].(string))
+
+	fmt.Println(respJSON["chrg_bchno"].(string))
+	fmt.Println(respJSON["org_name"].(string))
+	fmt.Println(respJSON["doctor"].(string))
+	fmt.Println(respJSON["dept"].(string))
+
+	fmt.Println(respJSON["fixmedins_code"].(string))
+	fmt.Println(respJSON["dept_code"].(string))
+	fmt.Println(respJSON["doctor_id"].(string))
+
+	fmt.Println(respJSON["insuplc_admdvs"].(string))
+	fmt.Println(respJSON["mdtrtarea_admvs"].(string))
+	fmt.Println(respJSON["secret_key"].(string))
+
+	result, requestLog := service.Hbyb2204(respJSON["psn_no"].(string), respJSON["mdtrt_id"].(string), hp, respJSON["chrg_bchno"].(string), respJSON["org_name"].(string),
+		respJSON["doctor"].(string), respJSON["dept"].(string), respJSON["fixmedins_code"].(string), respJSON["dept_code"].(string), respJSON["doctor_id"].(string), respJSON["insuplc_admdvs"].(string), respJSON["mdtrtarea_admvs"].(string), respJSON["secret_key"].(string), respJSON["balance_accounts_type"].(string))
+
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(requestLog), &dat2); err == nil {
+		fmt.Println(dat2)
+	} else {
+		fmt.Println(err)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": requestLog,
+	})
+}
+func (c *JSybController) PostSix() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	chrgBchno := c.GetString("chrg_bchno")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+
+	secret_key := c.GetString("secret_key")
+	fixmedins_code := c.GetString("fixmedins_code")
+
+	result, requestlog := service.Hbyb2205(psnNo, mdtrtId, chrgBchno, org_name, doctor, insuplc_admdvs, mdtrtarea_admvs, secret_key, fixmedins_code)
+	fmt.Println(requestlog)
+	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 *JSybController) PostSeven() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	chrgBchno := c.GetString("chrg_bchno")
+	certNo := c.GetString("cert_no")
+	insutype := c.GetString("insutype")
+	total := c.GetString("total")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	med_type := c.GetString("med_type")
+	id_card_type, _ := c.GetInt64("id_card_type")
+	certificates, _ := c.GetInt64("certificates")
+
+	result, requestlog := service.Hbyb2206(psnNo, mdtrtId, chrgBchno, certNo, insutype, total, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, med_type, id_card_type, 0, 0, 0, 0, certificates)
+	fmt.Println(requestlog)
+
+	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 *JSybController) PostEight() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	chrgBchno := c.GetString("chrg_bchno")
+	certNo := c.GetString("cert_no")
+	insutype := c.GetString("insutype")
+	total := c.GetString("total")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	med_type := c.GetString("med_type")
+	id_card_type, _ := c.GetInt64("id_card_type")
+	certificates, _ := c.GetInt64("certificates")
+
+	fulamt_ownpay_amt, _ := c.GetFloat("fulamt_ownpay_amt")
+	overlmt_selfpay, _ := c.GetFloat("overlmt_selfpay")
+	preselfpay_amt, _ := c.GetFloat("preselfpay_amt")
+	inscp_scp_amt, _ := c.GetFloat("inscp_scp_amt")
+
+	acct_used_flag, _ := c.GetInt64("acct_used_flag")
+
+	result, srcRequest := service.Hbyb2207(psnNo, mdtrtId, chrgBchno, certNo, insutype, total, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, med_type, id_card_type, fulamt_ownpay_amt, overlmt_selfpay, preselfpay_amt, inscp_scp_amt, certificates, acct_used_flag)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(srcRequest), &dat2); err == nil {
+		fmt.Println(dat2)
+	} else {
+		fmt.Println(err)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":  dat,
+		"pre2": dat2,
+	})
+}
+func (c *JSybController) PostNine() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	setlId := c.GetString("setl_id")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	secret_key := c.GetString("secret_key")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	result, src_request := service.Hbyb2208(psnNo, mdtrtId, setlId, org_name, doctor, secret_key, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+	fmt.Println(src_request)
+	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 *JSybController) PostTen() {
+	psnNo := c.GetString("psn_no")
+	mdtrtId := c.GetString("mdtrt_id")
+	setlId := c.GetString("setl_id")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	med_type := c.GetString("med_type")
+
+	secret_key := c.GetString("secret_key")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+
+	baseParams := models.BaseParams{
+		SecretKey:      secret_key,
+		FixmedinsCode:  fixmedins_code,
+		InsuplcAdmdvs:  insuplc_admdvs,
+		MdtrtareaAdmvs: mdtrtarea_admvs,
+		OrgName:        org_name,
+		Doctor:         doctor,
+	}
+
+	businessParams := models.BusinessParams{
+		PsnNo:   psnNo,
+		MdtrtId: mdtrtId,
+		SetlId:  setlId,
+	}
+
+	result := service.Hbyb5203(baseParams, businessParams, med_type)
+	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,
+	})
+}

controllers/sg/gdyb_controller.go

@@ -561,16 +561,16 @@ func (c *GdybController) PostZHFive() {
 	fmt.Println(respJSON["mdtrtarea_admvs"].(string))
 	fmt.Println(respJSON["secret_key"].(string))
 
-	result := service.ZHGdyb2301(respJSON["psn_no"].(string), respJSON["mdtrt_id"].(string), hp, respJSON["chrg_bchno"].(string), respJSON["org_name"].(string),
-		respJSON["doctor"].(string), respJSON["dept"].(string), respJSON["fixmedins_code"].(string), respJSON["dept_code"].(string), respJSON["doctor_id"].(string), respJSON["insuplc_admdvs"].(string), respJSON["mdtrtarea_admvs"].(string), respJSON["secret_key"].(string), respJSON["med_type"].(string))
+	//result := service.ZHGdyb2301(respJSON["psn_no"].(string), respJSON["mdtrt_id"].(string), hp, respJSON["chrg_bchno"].(string), respJSON["org_name"].(string),
+	//	respJSON["doctor"].(string), respJSON["dept"].(string), respJSON["fixmedins_code"].(string), respJSON["dept_code"].(string), respJSON["doctor_id"].(string), respJSON["insuplc_admdvs"].(string), respJSON["mdtrtarea_admvs"].(string), respJSON["secret_key"].(string), respJSON["med_type"].(string))
 
-	var dat map[string]interface{}
-	if err := json.Unmarshal([]byte(result), &dat); err == nil {
-		fmt.Println(dat)
-	} else {
-		fmt.Println(err)
-	}
+	//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,
+		"pre": "",
 	})
 }

controllers/sg/his_api_controller.go

@@ -80,12 +80,6 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/psn/info", &HisApiController{}, "get:GetPsnNcdsInfo")
 
-	//beego.Router("/api/checkdetailaccount/handle", &HisApiController{}, "get:HandleCheckDetailAccount")
-
-	//beego.Router("/api/settlelist/get", &HisApiController{}, "get:GetSettleList")
-	//beego.Router("/api/testinit", &HisApiController{}, "get:TestGetBasBaseInit")
-	//beego.Router("/api/test", &HisApiController{}, "get:TestGetBasBaseInfo")
-
 }
 func (c *HisApiController) GetPsnNcdsInfo() {
 	admin_user_id, _ := c.GetInt64("admin_user_id")
@@ -512,19 +506,6 @@ func (c *HisApiController) GetBasBaseInfo() string {
 	return string(str)
 }
 
-func prttostr(vcode uintptr) string {
-	var vbyte []byte
-	for i := 0; i < 10; i++ {
-		sbyte := *((*byte)(unsafe.Pointer(vcode)))
-		if sbyte == 0 {
-			break
-		}
-		vbyte = append(vbyte, sbyte)
-		vcode += 1
-	}
-	return string(vbyte)
-}
-
 type CustomFundPay struct {
 	FundPayType string  `json:"fund_pay_type"`
 	FundPayamt  float64 `json:"fund_payamt"`
@@ -1786,90 +1767,6 @@ func (c *HisApiController) GetBatchSettleList() {
 	}
 }
 
-//func (c *HisApiController) TestPay() {
-//	DllDef2 := syscall.MustLoadDLL("SSSE32.dll")
-//	readCards := DllDef2.MustFindProc("BankTrans")
-//	inputData := make(map[string]interface{})
-//	inputData["transId"] = "05"
-//	inputData["amount"] = "0.01"
-//	inputData["traceNo"] = "20210227093601325405377"
-//	inputData["cardNo"] = "F36084348"
-//	inputData["id"] = "44022919620927046X"
-//	//jsonStr := `
-//	//    {
-//	//            "transId": "05",
-//	//            "amount":"1.00",
-//	//            "traceNo":"20210227093601325405377",
-//	//            "cardNo":"F36084348",
-//	//            "id":"44022919620927046X"
-//	//
-//	//    }
-//	//`
-//
-//	bytes_arr, _ := json.Marshal(inputData)
-//	str3 := make([]byte, 256)
-//	ret4, _, err4 := readCards.Call(StrPtr(string(bytes_arr)), (uintptr)(unsafe.Pointer(&str3[0])))
-//	fmt.Println(":", string(str3))
-//
-//	if err4 != nil {
-//		fmt.Println("SSCard的运算结果为:", ret4)
-//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
-//		return
-//	}
-//
-//}
-
-//func (c *HisApiController) TestGetBasBaseInfo() {
-//
-//	//result := C.Init(StrPtr("http://igb.hsa.gdgov.cn/gdyb_inf/poc/api/card/initDll"), StrPtr("440200"))
-//	//fmt.Println(result)
-//	//cs1 := C.CString("")
-//	//cs2 := C.CString("")
-//	//C.ReadCardBas(cs1, IntPtr(1024), cs2, IntPtr(1024))
-//	//fmt.Println(cs1)
-//	//fmt.Println(cs2)
-//	//C.free(unsafe.Pointer(cs1))
-//	//C.free(unsafe.Pointer(cs2))
-//
-//	//
-//
-//	DllDef := syscall.MustLoadDLL("SSCard.dll")
-//	Iinit := DllDef.MustFindProc("Init")
-//	readCard := DllDef.MustFindProc("ReadCardBas")
-//	ret, _, err := Iinit.Call(StrPtr("http://igb.hsa.gdgov.cn/gdyb_inf/poc/api/card/initDll"), StrPtr("440200"))
-//	if ret != 0 {
-//		fmt.Println("SSCard的报错原因:", err)
-//		fmt.Println("SSCard的运算结果为:", ret)
-//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
-//		return
-//	}
-//
-//	result := int(ret)
-//	fmt.Println("SSCard的运算结果为1:", result)
-//
-//	//path := ""
-//	//bytePath := []byte(  "\x00")
-//	//bytePath2 := []byte(  "\x00")
-//	//ssss
-//
-//	str := make([]byte, 256)
-//	str1 := make([]byte, 256)
-//	s2 := []byte(string(str))
-//	s3 := []byte(string(str1))
-//	ret2, _, err2 := readCard.Call((uintptr)(unsafe.Pointer(&s2[0])), IntPtr(256), (uintptr)(unsafe.Pointer(&s3[0])), IntPtr(256))
-//	fmt.Println(" Add(4,5)的结果为:", ret2)
-//	fmt.Println(" str:", s2)
-//	fmt.Println(" str1:", s3)
-//	if err2 != nil {
-//		fmt.Println("SSCard的运算结果为:", ret2)
-//		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException)
-//		return
-//	}
-//
-//	//DllDef := syscall.MustLoadDLL("SSCard.dll")
-//
-//}
-
 func (c *HisApiController) GetOrgInfo() {
 	miConfig, _ := service.FindMedicalInsuranceInfo(4)
 	service.Gdyb1201("", miConfig.OrgName, "1122", miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, 1, "")
@@ -2020,6 +1917,49 @@ func StrPtr(s string) uintptr {
 	return uintptr(unsafe.Pointer(syscall.StringBytePtr(s)))
 }
 
+type Result2001 struct {
+	Cainfo      interface{} `json:"cainfo"`
+	ErrMsg      string      `json:"err_msg"`
+	InfRefmsgid string      `json:"inf_refmsgid"`
+	Infcode     int64       `json:"infcode"`
+	Output      struct {
+		Trtinfo struct {
+			PsnNo          string `json:"psn_no"`
+			TrtChkType     string `json:"trt_chk_type"`
+			FundPayType    string `json:"fund_pay_type"`
+			TrtEnjymntFlag string `json:"trt_enjymnt_flag"`
+			Begndate       string `json:"begndate"`
+			Enddate        string `json:"enddate"`
+			TrtChkRslt     string `json:"trt_chk_rslt"`
+		} `json:"trtinfo"`
+	} `json:"output"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Signtype    interface{} `json:"signtype"`
+	WarnMsg     interface{} `json:"warn_msg"`
+}
+type Result2001Org10265 struct {
+	Cainfo      interface{} `json:"cainfo"`
+	ErrMsg      string      `json:"err_msg"`
+	InfRefmsgid string      `json:"inf_refmsgid"`
+	Infcode     string      `json:"infcode"`
+	Output      struct {
+		Trtinfo struct {
+			PsnNo          string `json:"psn_no"`
+			TrtChkType     string `json:"trt_chk_type"`
+			FundPayType    string `json:"fund_pay_type"`
+			TrtEnjymntFlag string `json:"trt_enjymnt_flag"`
+			Begndate       string `json:"begndate"`
+			Enddate        string `json:"enddate"`
+			TrtChkRslt     string `json:"trt_chk_rslt"`
+		} `json:"trtinfo"`
+	} `json:"output"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Signtype    interface{} `json:"signtype"`
+	WarnMsg     interface{} `json:"warn_msg"`
+}
+
 type ResultTwo struct {
 	ErrMsg      string `json:"err_msg"`
 	InfRefmsgid string `json:"inf_refmsgid"`
@@ -2996,6 +2936,41 @@ func (c *HisApiController) GetRegisterInfo() {
 			infoStr = psn_info.Insuinfo
 			idetinfoStr = psn_info.Idetinfo
 
+		} else if miConfig.MdtrtareaAdmvs == "320921" {
+			var res ResultTwo
+			api := "http://192.168.3.130:9532/" + "jsyb/1101?cert_no=" + "" +
+				"&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code +
+				"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(certificates, 10) + "&url=" + miConfig.Url + "&ak=" + "fb4f41a047934d588a89cdac7a102410"
+			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
+			}
+			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
+			}
+
+			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+			result, _ := json.Marshal(respJSON)
+			fmt.Println("log")
+			fmt.Println(string(result))
+
+			if err := json.Unmarshal([]byte(result), &res); err != nil {
+				utils.ErrorLog("解析失败：%v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
 		} else {
 			result, requestLog := service.Gdyb1101(patient.IdCardNo, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, "", strconv.FormatInt(certificates, 10), name)
 			saveLog(result, requestLog, "1101", "人员基本信息获取")
@@ -7156,25 +7131,47 @@ func (c *HisApiController) GetSettleAccounts() {
 }
 
 func (c *HisApiController) CheckTreatment() {
-	patient_id, _ := c.GetInt64("patient_id", 0)
-	record_time := c.GetString("record_time")
+	patient_id, _ := c.GetInt64("patient_id")
+	id_card_no := c.GetString("id_card_no")
 	insutype := c.GetString("insutype")
+	med_type := c.GetString("med_type")
+	admin_user_id, _ := c.GetInt64("admin_user_id")
 
-	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)
+	patient, _ := service.GetPatientByID(adminUser.CurrentOrgId, patient_id)
 
 	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
 	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+	roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id)
+
+	result := service.Gdyb1101A(id_card_no, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, patient.Name)
+	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 ResultTwo
+	var res10265 ResultTwo10265
+	if miConfig.Code == "H15049901371" {
+		if err := json.Unmarshal(userJSONBytes, &res10265); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		res.ErrMsg = res10265.ErrMsg
+		infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64)
+		res.Infcode = infocode
+		res.Output = res10265.Output
+		res.InfRefmsgid = res10265.InfRefmsgid
+	} else {
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+	}
 
 	var user_name string
 	role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, adminUser.AdminUser.Id)
@@ -7194,16 +7191,50 @@ func (c *HisApiController) CheckTreatment() {
 	}
 
 	if config.IsOpen == 1 {
-		result := service.Gdyb2001(baseParams, his.PsnNo, insutype, strconv.FormatInt(patientPrescription.RegisterType, 10))
+		if miConfig.Code == "H15049901371" {
+			if med_type == "14" {
+				if insutype == "390" {
+					med_type = "9933"
+				} else if insutype == "310" {
+					med_type = "990502"
+				}
+			} else if med_type == "11" {
+				med_type = "11"
+			}
+		}
+		result := service.Gdyb2001(baseParams, res.Output.Baseinfo.PsnNo, insutype, med_type)
 		var dat map[string]interface{}
 		if err := json.Unmarshal([]byte(result), &dat); err == nil {
 			fmt.Println(dat)
 		} else {
 			fmt.Println(err)
 		}
-
+		var res Result2001
+		var res10265 Result2001Org10265
+		if miConfig.Code == "H15049901371" {
+			if err := json.Unmarshal([]byte(result), &res10265); err != nil {
+				utils.ErrorLog("解析失败：%v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+			res.ErrMsg = res10265.ErrMsg
+			res.Output = res10265.Output
+			res.InfRefmsgid = res10265.InfRefmsgid
+			infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64)
+			res.Infcode = infocode
+		} else {
+			if err := json.Unmarshal([]byte(result), &res); err != nil {
+				utils.ErrorLog("解析失败：%v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+		}
+		if res.Infcode == 0 {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"msg": res.Output.Trtinfo,
+			})
+		}
 	}
-
 }
 
 //func (c *HisApiController) PutRecord() {

controllers/zh/zh_his_api_controller.go

@@ -1,7 +1,6 @@
 package zh
 
 import (
-	"bytes"
 	"encoding/json"
 	"fmt"
 	"gdyb/controllers"
@@ -11,10 +10,8 @@ import (
 	"gdyb/utils"
 	"github.com/astaxie/beego"
 	"github.com/axgle/mahonia"
-	"io/ioutil"
 	"math"
 	"math/rand"
-	"net/http"
 	"os"
 	"strconv"
 	"strings"
@@ -1355,7 +1352,7 @@ func (c *ZHHisApiController) GetUploadInfo() {
 	department, _ := service.GetDepartMentDetail(record.Departments)
 	strconv.FormatInt(record.PatientId, 10)
 
-	client := &http.Client{}
+	//client := &http.Client{}
 	data["psn_no"] = record.PsnNo
 	data["mdtrt_id"] = record.Number
 	data["chrg_bchno"] = chrg_bchno
@@ -1501,26 +1498,27 @@ func (c *ZHHisApiController) GetUploadInfo() {
 				stop = len(customs)
 			}
 
-			data["pre"] = customs[start-1 : stop]
-			bytesData, _ := json.Marshal(data)
-			req, _ := http.NewRequest("POST", "http://127.0.0.1:9532/"+"gdyb/zh/five", bytes.NewReader(bytesData))
-			resp, _ := client.Do(req)
-			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(body), &respJSON); err != nil {
-				utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
-				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
-				return
-			}
+			//data["pre"] = customs[start-1 : stop]
+			//bytesData, _ := json.Marshal(data)
+			//req, _ := http.NewRequest("POST", "http://127.0.0.1:9532/"+"gdyb/zh/five", bytes.NewReader(bytesData))
+			//resp, _ := client.Do(req)
+			//defer resp.Body.Close()
+			//body, ioErr := ioutil.ReadAll(resp.Body)
+			//if ioErr != nil {
+			//	utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+			//	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			//	return
+			//}
+			resultLog, requestLog := service.ZHGdyb2301(record.PsnNo, record.Number, customs[start-1:stop], chrg_bchno, miConfig.OrgName, roles.UserName, strconv.FormatInt(department.ID, 10), miConfig.Code, department.Number, strconv.FormatInt(roles.AdminUserId, 10), miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, data["med_type"].(string))
+			saveLog(resultLog, requestLog, "2301", "上传明细")
 
-			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
-			userJSONBytes, _ := json.Marshal(respJSON)
+			var dat map[string]interface{}
+			if err := json.Unmarshal([]byte(resultLog), &dat); err == nil {
+				fmt.Println(dat)
+			} else {
+				fmt.Println(err)
+			}
+			userJSONBytes, _ := json.Marshal(dat)
 			var res ResultFour
 			var resFour10265 ResultFour10265
 			if miConfig.Code == "H15049901371" {

main.go

@@ -5,7 +5,6 @@ import (
 	"fmt"
 	"gdyb/models"
 	_ "gdyb/routers"
-	"gdyb/service"
 	"github.com/astaxie/beego"
 	"github.com/qiniu/api.v7/auth/qbox"
 	"github.com/qiniu/api.v7/storage"

models/his_models.go

@@ -857,6 +857,7 @@ type MedicalInsuranceOrgConfig struct {
 	MdtrtareaAdmvs string `gorm:"column:mdtrtarea_admvs" json:"mdtrtarea_admvs" form:"mdtrtarea_admvs"`
 	InsuplcAdmdvs  string `gorm:"column:insuplc_admdvs" json:"insuplc_admdvs" form:"insuplc_admdvs"`
 	SecretKey      string `gorm:"column:secret_key" json:"secret_key" form:"secret_key"`
+	Url            string `gorm:"column:url" json:"url" form:"url"`
 }
 
 func (MedicalInsuranceOrgConfig) TableName() string {

routers/router.go

@@ -1,10 +1,10 @@
 package routers
 
 import (
-	//"gdyb/controllers/sz"
-
 	"gdyb/controllers/hb"
+	"gdyb/controllers/js"
 	"gdyb/controllers/sg"
+	"gdyb/controllers/sz"
 	"gdyb/controllers/zh"
 
 	//"gdyb/controllers/sz"
@@ -27,7 +27,8 @@ func init() {
 	sg.HisManagerApiRegistRouters()
 	sg.GdybRegistRouters()
 	hb.HbybRegistRouters()
-	//sz.SZHisManagerApiRegistRouters()
+	sz.SZHisManagerApiRegistRouters()
 	zh.ZHHisManagerApiRegistRouters()
+	js.JSybRegistRouters()
 
 }

service/gdyb_service.go

@@ -513,9 +513,7 @@ func Gdyb2202(psnNo string, mdtrtId string, ipt_otp_no string, org_name string,
 		}
 
 		request.Header.Set("Content-Type", "application/json;charset=UTF-8")
-		//request.Header.Set("x-tif-paasid", "test_hosp")
 		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)
@@ -2046,6 +2044,7 @@ func Gdyb2001(baseParams models.BaseParams, psn_no string, insutype string, med_
 	if med_type == "1111" || med_type == "1112" {
 		med_type = "11"
 	}
+
 	// 生成签名
 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
@@ -3714,7 +3713,3 @@ func Gdyb90100(psn_no string, org_name string, doctor string, fixmedins_code str
 	str := string(respBytes)
 	return str
 }
-
-//func StrPtr(s string) uintptr {
-//	return uintptr(unsafe.Pointer(syscall.StringBytePtr(s)))
-//}

service/jsyb_service.go

@@ -0,0 +1,107 @@
+package service
+
+import (
+	"crypto/hmac"
+	"crypto/sha1"
+	"encoding/base64"
+	"encoding/json"
+	"fmt"
+	"gdyb/utils/csbhttp"
+	"strconv"
+	"time"
+)
+
+// 人员基本信息
+func Jsyb1101(certNo string, org_name string, doctor string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, id_card_type int64, card_sn string, certificates string, request_url string, access_key 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)
+
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "1101" // 交易编码
+
+	if certificates == "3" {
+		inputData["mdtrt_cert_type"] = "99" // 就诊凭证类型
+		inputData["certno"] = certNo        // 证件号码
+		inputData["psn_cert_type"] = "99"   // 人员证件类型
+
+	} else {
+		if id_card_type == 1 {
+			inputData["mdtrt_cert_type"] = "03" // 就诊凭证类型
+			inputData["card_sn"] = card_sn      // 卡识别码
+			inputData["certno"] = certNo        // 证件号码
+			inputData["psn_cert_type"] = "01"   // 人员证件类型
+
+		} else {
+			inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
+			inputData["card_sn"] = ""           // 卡识别码
+			inputData["certno"] = certNo        // 证件号码
+			inputData["psn_cert_type"] = "01"   // 人员证件类型
+		}
+	}
+
+	inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
+	inputData["begntime"] = ""          // 开始时间
+	inputData["psn_name"] = ""          // 人员姓名
+	input["data"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	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(), ""
+	}
+
+	return HttpRequest(request_url, access_key, secret_key, timestamp, bytesData, string(bytesData)), inputLog
+
+}
+func HttpRequest(url string, ak string, sk string, timestamp int64, requestByte []byte, json string) string {
+
+	//step 1. 设置请求参数
+	csbHP := csbhttp.NewHttpParams(url) //设置请求地址及url参数
+	//设置调用方式 get 或者 post
+	csbHP.SetMethod("post")
+	//设置 调用的服务名和版本
+	csbHP.SetApi("hssServives")
+	csbHP.SetVersion("1.0.0")
+
+	//添加附加的http请求头 (可以定义多条)
+	key := "_api_access_key=" + ak + "&_api_name=" + "hssServives" + "&_api_timestamp=" + strconv.FormatInt(timestamp, 10) + "&_api_version=" + "1.0.0"
+	csbHP.AddHeader("_api_timestamp", strconv.FormatInt(timestamp, 10))
+	csbHP.AddHeader("_api_name", "hssServives")
+	csbHP.AddHeader("_api_version", "1.0.0")
+	csbHP.AddHeader("_api_access_key", ak)
+	csbHP.AddHeader("_api_signature", hmacsha1(key, sk))
+	//还可以,设置附加的byte[]或者json请求体
+	csbHP.SetContentBody(json, requestByte)
+	//设置请求的ak和sk
+	csbHP.SetAK(ak)
+	csbHP.SetSK(sk)
+	//打印请求参数信息
+	csbHP.Print()
+	//进行调用, 返回的第二项为resonse http headers (map[string][]string类型)
+	res, _, err := csbhttp.Invoke(*csbHP)
+	//是否发成错误
+	if err != nil {
+		fmt.Println(err)
+		return ""
+	}
+	return res
+}
+func hmacsha1(keyStr, value string) string {
+
+	key := []byte(keyStr)
+	mac := hmac.New(sha1.New, key)
+	mac.Write([]byte(value))
+	//进行base64编码
+	res := base64.StdEncoding.EncodeToString(mac.Sum(nil))
+
+	return res
+}

service/zh_his_service.go

@@ -554,7 +554,7 @@ type ZHResult struct {
 }
 
 //  住院费用明细信息上传
-func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCustom, chrg_bchno string, org_name string, doctor string, dept string, fixmedins_code string, dept_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, med_type string) string {
+func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCustom, chrg_bchno string, org_name string, doctor string, dept string, fixmedins_code string, dept_code string, doctor_id string, insuplc_admdvs string, mdtrtarea_admvs string, secret_key string, med_type string) (string, string) {
 	// 生成签名
 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
@@ -632,10 +632,11 @@ func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCusto
 	fmt.Println("----------")
 	fmt.Println(string(bytesData))
 	fmt.Println("----------")
+	requestLog := string(bytesData)
 
 	if err != nil {
 		fmt.Println(err.Error())
-		return ""
+		return "", ""
 	}
 	reader := bytes.NewReader(bytesData)
 
@@ -648,7 +649,7 @@ func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCusto
 	request, err := http.NewRequest("POST", url, reader)
 	if err != nil {
 		fmt.Println(err.Error())
-		return ""
+		return "", ""
 	}
 
 	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
@@ -661,14 +662,14 @@ func ZHGdyb2301(psnNo string, mdtrtId string, hisPrescription []*models.NewCusto
 	resp, err := client.Do(request)
 	if err != nil {
 		fmt.Println(err.Error())
-		return ""
+		return "", ""
 	}
 	respBytes, err := ioutil.ReadAll(resp.Body)
 	if err != nil {
 		fmt.Println(err.Error())
-		return ""
+		return "", ""
 	}
-	return string(respBytes)
+	return string(respBytes), requestLog
 
 }
 

utils/csbhttp/httpcaller.go

@@ -0,0 +1,294 @@
+/**
+Copyright 1999-2017 Alibaba Group Holding Ltd.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+CSB-HTTP-SDK based on GO language.
+
+*/
+package csbhttp
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net"
+	"net/http"
+	"net/url"
+	"strconv"
+	"strings"
+	"sync"
+	//"crypto/tls"
+	"time"
+)
+
+var settingMutex sync.Mutex
+
+const (
+	CSB_SDK_VERSION = "1.1.0"
+
+	API_NAME_KEY               = "_api_name"
+	VERSION_KEY                = "_api_version"
+	ACCESS_KEY                 = "_api_access_key"
+	SECRET_KEY                 = "_api_secret_key"
+	SIGNATURE_KEY              = "_api_signature"
+	TIMESTAMP_KEY              = "_api_timestamp"
+	RESTFUL_PATH_SIGNATURE_KEY = "csb_restful_path_signature_key" //TODO: fix the terrible key name!
+)
+
+/**
+CSBHttp的基本设置结构
+*/
+type CSBHTTPSettings struct {
+	ShowDebug        bool          //  "运行时是否显示调试信息"
+	UserAgent        string        //  "调用CSB服务的客户端代理, 默认为 csbBroker"
+	ConnectTimeout   time.Duration //  "连接超时时间"
+	ReadWriteTimeout time.Duration //  "读写超时时间"
+
+	Retries                int  // if set to -1 means will retry forever
+	CareResponseHttpHeader bool // if return the response http headers
+	SignPath               bool
+
+	/* TODO:support the following fields
+	TLSClientConfig  *tls.Config
+	Proxy            func(*http.Request) (*url.URL, error)
+	Transport        http.RoundTripper
+	CheckRedirect    func(req *http.Request, via []*http.Request) error
+	EnableCookie     bool
+	*/
+}
+
+var defaultSetting = CSBHTTPSettings{
+	ShowDebug:              true,
+	UserAgent:              "csbBroker",
+	ConnectTimeout:         60 * time.Second,
+	ReadWriteTimeout:       60 * time.Second,
+	CareResponseHttpHeader: true,
+}
+
+/**
+  定义自己的http属性的结构来覆盖默认的设置
+*/
+func SetDefaultSetting(setting CSBHTTPSettings) {
+	settingMutex.Lock()
+	defer settingMutex.Unlock()
+	defaultSetting = setting
+}
+
+/**
+内部方法: 拼接请求参数
+*/
+func appendParams(reqUrl string, params string) string {
+	if strings.Contains(reqUrl, "?") {
+		return reqUrl + "&" + params
+	} else {
+		return reqUrl + "?" + params
+	}
+}
+
+/**
+内部方法: 将请求串中的请求参数装换为map
+*/
+func parseUrlParamsMap(reqUrl string) (params map[string]string, err *HttpCallerException) {
+	params = make(map[string]string) //must init the map
+	if strings.Contains(reqUrl, "?") {
+		i := strings.Index(reqUrl, "?")
+		reqUrl = string(reqUrl[i+1:])
+		fmt.Println(reqUrl)
+		kvs := strings.Split(reqUrl, "&")
+
+		if len(kvs) > 0 {
+			for _, kv := range kvs {
+				i = strings.Index(kv, "=")
+				if i >= 0 {
+					params[string(kv[0:i])] = string(kv[i+1:])
+				} else {
+					//TODO: write or throw exception
+					fmt.Errorf("bad kv pair:", kv)
+				}
+			}
+		}
+	}
+	return params, nil
+}
+
+/**
+内部方法: 进行参数的签名处理
+*/
+func signParams(params map[string]string, api string, version string, ak string, sk string) (headMaps map[string]string) {
+	headMaps = make(map[string]string)
+
+	params[API_NAME_KEY] = api
+	headMaps[API_NAME_KEY] = api
+
+	params[VERSION_KEY] = version
+	headMaps[VERSION_KEY] = version
+
+	//https://currentmillis.com/  calc current time with varies languages
+	v := time.Now().UnixNano() / 1000000
+	params[TIMESTAMP_KEY] = strconv.FormatInt(v, 10)
+	headMaps[TIMESTAMP_KEY] = strconv.FormatInt(v, 10)
+
+	if ak != "" {
+		params[ACCESS_KEY] = ak
+		headMaps[ACCESS_KEY] = ak
+
+		delete(params, SECRET_KEY)
+		delete(params, SIGNATURE_KEY)
+
+		signValue := doSign(params, sk)
+
+		headMaps[SIGNATURE_KEY] = signValue
+	}
+
+	return headMaps
+}
+
+/**
+调用CSB开放出来的服务(后者CSB控制台的Open API),并放回结果
+
+请求参数的内容根据 HttpParams 的定义进行设置
+
+返回的结果包含: 调用fa返回结果串, 返回的httpheaders 和 异常
+当处理正常时,异常为nil
+
+*/
+func Invoke(params HttpParams) (str string, rtnHeaders map[string][]string, hcError *HttpCallerException) {
+	//init rtnHeaders
+	rtnHeaders = make(map[string][]string)
+
+	hcError = params.Validate()
+	if hcError != nil {
+		return str, rtnHeaders, hcError
+	}
+
+	_, err := url.Parse(params.requestUrl)
+	if err != nil {
+		return str, rtnHeaders, &HttpCallerException{CauseErr: err}
+	}
+
+	client := &http.Client{
+		Transport: &http.Transport{
+			Dial: func(netw, addr string) (net.Conn, error) {
+				conn, err := net.DialTimeout(netw, addr, defaultSetting.ConnectTimeout) //设置建立连接超时
+				if err != nil {
+					return nil, err
+				}
+				conn.SetDeadline(time.Now().Add(defaultSetting.ReadWriteTimeout)) //设置发送接受数据超时
+				return conn, nil
+			},
+			ResponseHeaderTimeout: time.Second * 2,
+		},
+	}
+
+	//resp := &http.Response{}
+	//for request parmas
+	data := url.Values{}
+	if params.params != nil {
+		for k, v := range params.params {
+			//strParams += fmt.Sprintf("%s=%s", k, url.QueryEscape())
+			data.Set(k, v)
+		}
+	}
+	var reqStr string
+	var method string
+	//method := "GET"
+	if params.method == "post" {
+		//genSignHeaders
+		method = "POST"
+	} else {
+		method = "GET"
+	}
+
+	reqUrl := params.requestUrl
+
+	defaultContentType := "application/x-www-form-urlencoded"
+	if params.ct.jsonBody != "" {
+		_, err = json.Marshal(params.ct.jsonBody)
+		if err == nil {
+			return str, rtnHeaders, &HttpCallerException{Message: "failed to bad content type json string", CauseErr: err}
+		}
+		reqStr = params.ct.jsonBody
+		defaultContentType = params.ct.contentType
+		reqUrl = appendParams(reqUrl, data.Encode())
+	} else if params.ct.bytesBody != nil {
+		reqStr = string(params.ct.bytesBody)
+		defaultContentType = params.ct.contentType
+		reqUrl = appendParams(reqUrl, data.Encode())
+	} else {
+		reqStr = data.Encode()
+	}
+
+	req, err := http.NewRequest(method, reqUrl, bytes.NewBufferString(reqStr))
+
+	if err != nil {
+		return str, rtnHeaders, &HttpCallerException{Message: "failed to construct http post request", CauseErr: err}
+	}
+
+	//set signature related headers
+	urlParams, hcError := parseUrlParamsMap(params.requestUrl)
+	if err != nil {
+		return str, rtnHeaders, hcError
+	}
+	printDebug("urlparams", urlParams)
+	mergeTwoMaps(urlParams, params.params)
+	printDebug("merged urlparams", urlParams)
+	signHeaders := signParams(urlParams, params.api, params.version, params.ak, params.sk)
+	printDebug("signHeaders", signHeaders)
+
+	req.Header.Add("Content-Type", defaultContentType)
+	if params.headers != nil {
+		for k, v := range params.headers {
+			req.Header.Add(k, v)
+		}
+	}
+	//add sign related headers
+	if signHeaders != nil {
+		for k, v := range signHeaders {
+			req.Header.Add(k, v)
+		}
+	}
+
+	//client.Timeout
+	resp, err := client.Do(req)
+
+	if err != nil {
+		return str, rtnHeaders, &HttpCallerException{Message: "failed to invoke http post", CauseErr: err}
+	}
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	defer resp.Body.Close()
+
+	body, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err)
+	}
+	str = string(body)
+	if defaultSetting.CareResponseHttpHeader {
+		rtnHeaders = resp.Header
+	}
+	/*
+		fmt.Println("jsonStr", jsonStr)
+		var dat map[string]string
+		if err := json.Unmarshal([]byte(jsonStr), &dat); err == nil {
+			fmt.Println("token", dat["token"])
+		} else {
+			fmt.Println("json str to struct error")
+		}
+	*/
+	return str, rtnHeaders, nil
+}

utils/csbhttp/httpexception.go

@@ -0,0 +1,36 @@
+/**
+Copyright 1999-2017 Alibaba Group Holding Ltd.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+CSB-HTTP-SDK based on GO language.
+
+*/
+
+package csbhttp
+
+import "fmt"
+
+/**
+  CSB调用异常结构
+*/
+type HttpCallerException struct {
+	Message   string `xml:"Message"`   // CSB给出的详细错误信息
+	RequestID string `xml:"RequestId"` // 用于唯一标识该次请求的UUID
+	CauseErr  error  //具体的error
+}
+
+// Implement interface error
+func (e HttpCallerException) Error() string {
+	return fmt.Sprintf("csb: service returned error: ErrorMessage=%s, RequestId=%s, CauseErr=%v", e.Message, e.RequestID, e.CauseErr)
+}

utils/csbhttp/httpparams.go

@@ -0,0 +1,154 @@
+/**
+Copyright 1999-2017 Alibaba Group Holding Ltd.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+CSB-HTTP-SDK based on GO language.
+
+*/
+package csbhttp
+
+import (
+	"encoding/json"
+	"fmt"
+	"strings"
+)
+
+/**
+构造Http请求参数的struct
+*/
+const (
+	JSON   = "application/json"
+	BINARY = "application/octet-stream"
+)
+
+type contentBody struct {
+	jsonBody    string
+	bytesBody   []byte
+	contentType string
+}
+
+type (
+	HttpParams struct {
+		method     string // "设置方法: get, post"
+		api        string
+		version    string
+		ak         string
+		sk         string
+		requestUrl string
+		params     map[string]string // "form 参数对"
+		headers    map[string]string // "http headers"
+		ct         contentBody       //  "设置传输的jsonBody 或者 byte[]"
+	}
+	Builder func(map[string]HttpParams) string
+)
+
+func NewHttpParams(reqUrl string) *HttpParams {
+	hp := HttpParams{
+		requestUrl: reqUrl,
+		method:     "get",
+		params:     make(map[string]string),
+		headers:    make(map[string]string),
+	}
+
+	hp.ct.contentType = "unknown"
+
+	return &hp
+}
+
+func (hp *HttpParams) SetApi(api string) *HttpParams {
+	hp.api = api
+	return hp
+}
+
+func (hp *HttpParams) SetVersion(version string) *HttpParams {
+	hp.version = version
+	return hp
+}
+
+func (hp *HttpParams) SetAK(ak string) *HttpParams {
+	hp.ak = ak
+	return hp
+}
+
+func (hp *HttpParams) SetSK(sk string) *HttpParams {
+	hp.sk = sk
+	return hp
+}
+
+func (hp *HttpParams) SetRequest(reqUrl string) *HttpParams {
+	hp.requestUrl = reqUrl
+	return hp
+}
+
+func (hp *HttpParams) SetMethod(method string) *HttpParams {
+	hp.method = method
+	return hp
+}
+
+func (hp *HttpParams) AddParam(key string, value string) *HttpParams {
+	hp.params[key] = value
+	return hp
+}
+
+func (hp *HttpParams) AddHeader(key string, value string) *HttpParams {
+	hp.headers[key] = value
+	return hp
+}
+
+func (hp *HttpParams) SetContentBody(jsonStr string, byteArr []byte) error {
+	if jsonStr != "" && byteArr != nil {
+		errRtn := HttpCallerException{Message: "can not set jsonStr and byteArr parameters together!"}
+		return errRtn
+	}
+
+	if jsonStr != "" {
+		hp.ct.jsonBody = jsonStr
+		hp.ct.contentType = JSON
+	}
+
+	if byteArr != nil {
+		hp.ct.bytesBody = byteArr //TODO: copy or pointer ?
+		hp.ct.contentType = BINARY
+	}
+
+	return nil
+}
+
+/**
+校验设置的请求参数项是否有效
+*/
+func (hp *HttpParams) Validate() *HttpCallerException {
+	hp.method = strings.ToLower(hp.method)
+	if hp.method != "get" && hp.method != "post" {
+		return &HttpCallerException{Message: "bad method, only support 'get' or 'post'"}
+	}
+
+	if hp.ak != "" && hp.sk == "" {
+		return &HttpCallerException{Message: "bad request params, ak and sk must be defined together"}
+	}
+
+	if hp.api == "" || hp.version == "" {
+		return &HttpCallerException{Message: "bad request params, api or version is not defined"}
+	}
+
+	return nil
+}
+
+/**
+打印设置的参数值
+*/
+func (hp *HttpParams) Print() {
+	j, _ := json.Marshal(*hp)
+	fmt.Println(string(j))
+}

utils/csbhttp/signutil.go

@@ -0,0 +1,102 @@
+/**
+Copyright 1999-2017 Alibaba Group Holding Ltd.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+CSB-HTTP-SDK based on GO language.
+
+*/
+package csbhttp
+
+import (
+	"bytes"
+	"crypto/hmac"
+	"crypto/sha1"
+	"encoding/base64"
+	"hash"
+	"io"
+	"sort"
+)
+
+/**
+  签名处理逻辑
+  将请求map中的key按字典顺序排序,然后使用secretKey进行签名处理
+*/
+
+// 用于signParms的字典排序存放容器。
+type paramsSorter struct {
+	Keys []string
+	Vals []string
+}
+
+// params map 转换为paramsSorter格式
+func newParamsSorter(m map[string]string) *paramsSorter {
+	hs := &paramsSorter{
+		Keys: make([]string, 0, len(m)),
+		Vals: make([]string, 0, len(m)),
+	}
+
+	for k, v := range m {
+		hs.Keys = append(hs.Keys, k)
+		hs.Vals = append(hs.Vals, v)
+	}
+	return hs
+}
+
+// 进行字典顺序排序 sort required method
+func (hs *paramsSorter) Sort() {
+	sort.Sort(hs)
+}
+
+// Additional function for function  sort required method
+func (hs *paramsSorter) Len() int {
+	return len(hs.Vals)
+}
+
+// Additional function for function  sort required method
+func (hs *paramsSorter) Less(i, j int) bool {
+	return bytes.Compare([]byte(hs.Keys[i]), []byte(hs.Keys[j])) < 0
+}
+
+// Additional function for function paramsSorter.
+func (hs *paramsSorter) Swap(i, j int) {
+	hs.Vals[i], hs.Vals[j] = hs.Vals[j], hs.Vals[i]
+	hs.Keys[i], hs.Keys[j] = hs.Keys[j], hs.Keys[i]
+}
+
+// 做签名处理
+func doSign(params map[string]string, secretKey string) string {
+	hs := newParamsSorter(params)
+
+	// Sort the temp by the Ascending Order
+	hs.Sort()
+
+	// Get the CanonicalizedOSSHeaders
+	canonicalizedParams := ""
+	for i := range hs.Keys {
+		if i > 0 {
+			canonicalizedParams += "&"
+		}
+		canonicalizedParams += hs.Keys[i] + "=" + hs.Vals[i]
+	}
+
+	printDebug("canonicalizedParams", canonicalizedParams)
+
+	signStr := canonicalizedParams
+
+	h := hmac.New(func() hash.Hash { return sha1.New() }, []byte(secretKey))
+	io.WriteString(h, signStr)
+	signedStr := base64.StdEncoding.EncodeToString(h.Sum(nil))
+
+	return signedStr
+}

utils/csbhttp/utils.go

@@ -0,0 +1,38 @@
+/**
+Copyright 1999-2017 Alibaba Group Holding Ltd.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+
+CSB-HTTP-SDK based on GO language.
+
+*/
+package csbhttp
+
+import "fmt"
+
+/**
+  工具相关的方法定义在这个文件中
+*/
+// print debug info
+func printDebug(prompt string, a ...interface{}) {
+	if defaultSetting.ShowDebug {
+		fmt.Println(prompt, a)
+	}
+}
+
+// merge two maps
+func mergeTwoMaps(toMap map[string]string, fromMap map[string]string) {
+	for k, v := range fromMap {
+		toMap[k] = v
+	}
+}