更新

controllers/ah/ahyb_controller.go

 	//c.TestGetBasBaseInit(fixmedins_code, secret_key, ak)
 	switch id_card_type {
 	case "1":
-		pCardInfo, pBusiCardInfo := c.GetBasBaseInfo()
-		pBusiCardInfo = Remove0000(pBusiCardInfo)
+		pCardInfo := c.GetBasBaseInfo()
 		pCardInfo = Remove0000(pCardInfo)
 		fmt.Println(":", ConvertToString(pCardInfo, "gbk", "utf-8"))
-
-		fmt.Println(pBusiCardInfo)
 		fmt.Println(pCardInfo)
 		bas := strings.Split(pCardInfo, "|")
 		basNumber := bas[2]
 		id_card_no := bas[1]
 		card_sn := bas[3]
-
 		id_card_type_int, _ := strconv.ParseInt(id_card_type, 10, 64)
 
-		if len(pCardInfo) > 0 && len(pBusiCardInfo) > 0 {
-			result, _ := service.AHyb1101A(basNumber, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type_int, card_sn, "1", url, ak, pBusiCardInfo, id_card_no, cainfo)
+		if len(pCardInfo) > 0 {
+			result, _ := service.AHyb1101A(basNumber, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, id_card_type_int, card_sn, "1", url, ak, id_card_no, cainfo)
 			var dat map[string]interface{}
 			if err := json.Unmarshal([]byte(result), &dat); err == nil {
 				fmt.Println(dat)
 			c.ServeSuccessJSON(map[string]interface{}{
 				"status":         "0",
 				"card_info":      pCardInfo,
-				"busi_card_info": pBusiCardInfo,
 				"result":         dat,
 				"type":           "1",
 			})
 	//initFlag = 1
 	return
 }
-func (c *AHybController) GetBasBaseInfo() (string, string) {
-	DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll")
-	readCard := DllDef.MustFindProc("ReadCardBas")
+func (c *AHybController) GetBasBaseInfo() (string) {
+	DllDef := syscall.MustLoadDLL("SSCardDriver.dll")
+	readCard := DllDef.MustFindProc("iReadCardBas")
 	fmt.Println(readCard)
 	fmt.Println("!!!!!")
 	pCardInfo := make([]byte, 2048)
-	pBusiCardInfo := make([]byte, 8192)
-	ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&pCardInfo[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0])))
+	ret2, _, _ := readCard.Call(uintptr(3), (uintptr)(unsafe.Pointer(&pCardInfo[0])))
 	fmt.Println(ret2)
 	fmt.Println(DeleteExtraSpace(string(pCardInfo)))
-	fmt.Println(DeleteExtraSpace(string(pBusiCardInfo)))
 	fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pCardInfo)), "gbk", "utf-8"))
-	fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8"))
 	if ret2 != 0 {
-		return "", ""
+		return ""
 	}
-	return DeleteExtraSpace(string(pCardInfo)), DeleteExtraSpace(string(pBusiCardInfo))
+	return DeleteExtraSpace(string(pCardInfo))
 }
 
 func (c *AHybController) GetELeInfo(code string, operator_id string, operator_name string) (string, string) {

controllers/zh/zh_his_api_controller.go

 			result = string(result_byte)
 			saveLog(result_log, request_log, "1101", "人员基本信息获取")
 
-		} else if miConfig.MdtrtareaAdmvs == "360399" {
+		} else if miConfig.MdtrtareaAdmvs == "360399" ||  miConfig.MdtrtareaAdmvs == "361025" {
 			result, request_log = service.JxybZY1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, "", miConfig.MdtrtareaAdmvs, miConfig.SecretKey, 2, "", 0, miConfig.Url, miConfig.AccessKey, "", patient.IdCardNo, "")
 			saveLog(result_log, request_log, "1101", "人员基本信息获取")
 		}else if miConfig.MdtrtareaAdmvs == "341203"{
 				return
 			}
 
+			status := respJSON["data"].(map[string]interface{})["status"].(string)
+			if  status == "0"{
+				err_msg := respJSON["data"].(map[string]interface{})["msg"].(string)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"failed_code": -10,
+					"msg":        err_msg,
+				})
+				return
+			}
+			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+			result_byte, _ := json.Marshal(respJSON)
+			result = string(result_byte)
+			saveLog(result_log, request_log, "1101", "人员基本信息获取")
+		}else if miConfig.MdtrtareaAdmvs == "340699"{
+			var insuplc_admdvs string
+			if len(patient.InsuplcAdmdvs) > 0 {
+				insuplc_admdvs = patient.InsuplcAdmdvs
+			} else {
+				insuplc_admdvs = miConfig.InsuplcAdmdvs
+			}
+			//请求内网数据
+			api := miConfig.SecretKey + "ahyb/1101?url=" + miConfig.Url + "&cert_no=" + patient.IdCardNo +
+				"&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code +
+				"&insuplc_admdvs=" + insuplc_admdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(2, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(1, 10) + "&name=" + patient.Name+"&token="+""
+
+			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
+			}
+
 			status := respJSON["data"].(map[string]interface{})["status"].(string)
 			if  status == "0"{
 				err_msg := respJSON["data"].(map[string]interface{})["msg"].(string)

main.go

 	_ "gdyb/routers"
 	 "gdyb/service"
 	"gdyb/models"
+	//"gdyb/controllers/sg"
+	"time"
 	"strings"
 	"strconv"
-	"time"
 	"encoding/json"
 	"gdyb/utils"
 	"os"
 	//GetbrBatchSettleList()
 
 	//a, _ := service.GetResultRecord("2023-01-01")
-
+	//ticker := time.Tick(2 * time.Hour)
+	//// 无限循环，等待定时器触发
+	//for {
+	//	select {
+	//	case <-ticker:
+	//		sg.ChangeDrugTenone()
+	//	}
+	//}
 
 
 

service/ahyb_service.go

 	"io/ioutil"
 	"net/http"
 	"strconv"
+	"strings"
 	"time"
 )
 
 }
 
 //人员基本信息版本2
-func AHyb1101A(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, pBusiCardInfo string, id_card_no string, cainfo string) (string, string) {
+func AHyb1101A(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, id_card_no string, cainfo string) (string, string) {
 	timestamp := time.Now().Unix()
 	//生成输入报文
 	inputMessage := SetAHInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
 		}
 	}
 
-	inputData["mdtrt_cert_no"] = certNo + "|" + pBusiCardInfo // 就诊凭证编号
-	inputData["begntime"] = ""                                // 开始时间
+	inputData["mdtrt_cert_no"] = certNo  // 就诊凭证编号
+	month := time.Unix(1557042972, 0).Format("1")
+	year := time.Now().Format("2006")
+	month = time.Now().Format("01")
+	day := time.Now().Format("02")
+	inputData["begntime"] = year + "-" +month + "-" + day          // 开始时间                               // 开始时间
 	inputData["psn_name"] = ""                                // 人员姓名
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入
 
 }
 
-func AHyb3505(struct3505 models.Struct3505) (string, string) {
-	timestamp := time.Now().Unix()
-	// 生成输入报文
-	inputMessage := SetAHInputMessage(timestamp, struct3505.OrgName, struct3505.Opter, struct3505.FixmedinsCode, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, struct3505.Cainfo)
-	input := make(map[string]interface{})
-	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "3505"                              // 交易编码
-	inputData["med_list_codg"] = struct3505.MedListCodg         // 定点医药机构目录编号
-	inputData["fixmedins_hilist_id"] = struct3505.FixmedinsCode // 定点医药机构目录编号
-	inputData["fixmedins_hilist_name"] = struct3505.OrgName     // 定点医药机构目录名称
-	inputData["fixmedins_bchno"] = struct3505.FixmedinsCode     // 人员编号 （来自1101接口返回）
-
-	inputData["prsc_dr_cert_type"] = struct3505.PrscDrCertType // 人员编号 （来自1101接口返回）
-	inputData["prsc_dr_certno"] = struct3505.PrscDrCertno      // 人员编号 （来自1101接口返回）
-	inputData["prsc_dr_name"] = struct3505.PrscDrName          // 人员编号 （来自1101接口返回）
-	inputData["phar_cert_type"] = struct3505.PharCertType      // 人员编号 （来自1101接口返回）
-	inputData["phar_certno"] = struct3505.PharCertno           // 人员编号 （来自1101接口返回）
-
-	inputData["phar_name"] = struct3505.PharName               // 人员编号 （来自1101接口返回）
-	inputData["phar_prac_cert_no"] = struct3505.PharPracCertNo // 人员编号 （来自1101接口返回）
-	inputData["hi_feesetl_type"] = struct3505.HiFeesetlType    // 人员编号 （来自1101接口返回）
-	inputData["setl_id"] = struct3505.SetlId                   // 人员编号 （来自1101接口返回）
-	inputData["mdtrt_sn"] = struct3505.MdtrtSn                 // 人员编号 （来自1101接口返回）
-	inputData["psn_no"] = struct3505.PsnNo                     // 人员编号 （来自1101接口返回）
-	inputData["psn_cert_type"] = struct3505.PsnCertType        // 人员编号 （来自1101接口返回）
-	inputData["certno"] = struct3505.CertNo                    // 人员编号 （来自1101接口返回）
-	inputData["psn_name"] = struct3505.PsnName                 // 人员编号 （来自1101接口返回）
-	inputData["manu_lotnum"] = struct3505.ManuLotnum           // 人员编号 （来自1101接口返回）
-	inputData["manu_date"] = struct3505.ManuDate               // 人员编号 （来自1101接口返回）
-	inputData["expy_end"] = struct3505.ExpyEnd                 // 人员编号 （来自1101接口返回）
-
-	inputData["rx_flag"] = struct3505.RxFlag     // 人员编号 （来自1101接口返回）
-	inputData["trdn_flag"] = struct3505.TrdnFlag // 人员编号 （来自1101接口返回）
-
-	inputData["finl_trns_pric"] = struct3505.FinlTrnsPric // 人员编号 （来自1101接口返回）
-	inputData["rxno"] = struct3505.Rxno                   // 人员编号 （来自1101接口返回）
-	inputData["rx_circ_flag"] = struct3505.RxCircFlag     // 人员编号 （来自1101接口返回）
-
-	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
-	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
-
-	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
-	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
-	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
-	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
-	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
-	inputData["sel_retn_time"] = struct3505.SelRetnTime            // 人员编号 （来自1101接口返回）
-	inputData["sel_retn_opter_name"] = struct3505.SelRetnOpterName // 人员编号 （来自1101接口返回）
-	inputData["memo"] = struct3505.Memo                            // 人员编号 （来自1101接口返回）
-	input["selinfo"] = inputData
-	inputMessage["input"] = input //交易输入
-	argInputMessage  := make(map[string]interface{})
-	argInputMessage["arg0"] = inputMessage
-	bytesData, err := json.Marshal(argInputMessage)
-	fmt.Println(string(bytesData))
-	if err != nil {
-		fmt.Println(err.Error())
-		return err.Error(), ""
-	}
-	struct3505.RequestUrl = struct3505.RequestUrl + "3505"
-	return AHHttpRequest(struct3505.RequestUrl, struct3505.AccessKey, struct3505.SecretKey, timestamp, string(bytesData), "3505"), string(bytesData)
-
-}
+//func AHyb3505(struct3505 models.Struct3505) (string, string) {
+//	timestamp := time.Now().Unix()
+//	// 生成输入报文
+//	inputMessage := SetAHInputMessage(timestamp, struct3505.OrgName, struct3505.Opter, struct3505.FixmedinsCode, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, struct3505.Cainfo)
+//	input := make(map[string]interface{})
+//	inputData := make(map[string]interface{})
+//	inputMessage["infno"] = "3505"                              // 交易编码
+//	inputData["med_list_codg"] = struct3505.MedListCodg         // 定点医药机构目录编号
+//	inputData["fixmedins_hilist_id"] = struct3505.FixmedinsCode // 定点医药机构目录编号
+//	inputData["fixmedins_hilist_name"] = struct3505.OrgName     // 定点医药机构目录名称
+//	inputData["fixmedins_bchno"] = struct3505.FixmedinsCode     // 人员编号 （来自1101接口返回）
+//
+//	inputData["prsc_dr_cert_type"] = struct3505.PrscDrCertType // 人员编号 （来自1101接口返回）
+//	inputData["prsc_dr_certno"] = struct3505.PrscDrCertno      // 人员编号 （来自1101接口返回）
+//	inputData["prsc_dr_name"] = struct3505.PrscDrName          // 人员编号 （来自1101接口返回）
+//	inputData["phar_cert_type"] = struct3505.PharCertType      // 人员编号 （来自1101接口返回）
+//	inputData["phar_certno"] = struct3505.PharCertno           // 人员编号 （来自1101接口返回）
+//
+//	inputData["phar_name"] = struct3505.PharName               // 人员编号 （来自1101接口返回）
+//	inputData["phar_prac_cert_no"] = struct3505.PharPracCertNo // 人员编号 （来自1101接口返回）
+//	inputData["hi_feesetl_type"] = struct3505.HiFeesetlType    // 人员编号 （来自1101接口返回）
+//	inputData["setl_id"] = struct3505.SetlId                   // 人员编号 （来自1101接口返回）
+//	inputData["mdtrt_sn"] = struct3505.MdtrtSn                 // 人员编号 （来自1101接口返回）
+//	inputData["psn_no"] = struct3505.PsnNo                     // 人员编号 （来自1101接口返回）
+//	inputData["psn_cert_type"] = struct3505.PsnCertType        // 人员编号 （来自1101接口返回）
+//	inputData["certno"] = struct3505.CertNo                    // 人员编号 （来自1101接口返回）
+//	inputData["psn_name"] = struct3505.PsnName                 // 人员编号 （来自1101接口返回）
+//	inputData["manu_lotnum"] = struct3505.ManuLotnum           // 人员编号 （来自1101接口返回）
+//	inputData["manu_date"] = struct3505.ManuDate               // 人员编号 （来自1101接口返回）
+//	inputData["expy_end"] = struct3505.ExpyEnd                 // 人员编号 （来自1101接口返回）
+//
+//	inputData["rx_flag"] = struct3505.RxFlag     // 人员编号 （来自1101接口返回）
+//	inputData["trdn_flag"] = struct3505.TrdnFlag // 人员编号 （来自1101接口返回）
+//
+//	inputData["finl_trns_pric"] = struct3505.FinlTrnsPric // 人员编号 （来自1101接口返回）
+//	inputData["rxno"] = struct3505.Rxno                   // 人员编号 （来自1101接口返回）
+//	inputData["rx_circ_flag"] = struct3505.RxCircFlag     // 人员编号 （来自1101接口返回）
+//
+//	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
+//	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
+//
+//	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
+//	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
+//	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
+//	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
+//	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
+//	inputData["sel_retn_time"] = struct3505.SelRetnTime            // 人员编号 （来自1101接口返回）
+//	inputData["sel_retn_opter_name"] = struct3505.SelRetnOpterName // 人员编号 （来自1101接口返回）
+//	inputData["memo"] = struct3505.Memo                            // 人员编号 （来自1101接口返回）
+//	input["selinfo"] = inputData
+//	inputMessage["input"] = input //交易输入
+//	argInputMessage  := make(map[string]interface{})
+//	argInputMessage["arg0"] = inputMessage
+//	bytesData, err := json.Marshal(argInputMessage)
+//	fmt.Println(string(bytesData))
+//	if err != nil {
+//		fmt.Println(err.Error())
+//		return err.Error(), ""
+//	}
+//	struct3505.RequestUrl = struct3505.RequestUrl + "3505"
+//	return AHHttpRequest(struct3505.RequestUrl, struct3505.AccessKey, struct3505.SecretKey, timestamp, string(bytesData), "3505"), string(bytesData)
+//
+//}
 func AHyb3506(struct3506 models.Struct3506) (string, string) {
 	timestamp := time.Now().Unix()
 	// 生成输入报文
 
 
 
+
+
+func AHyb3505(struct3505 models.Struct3505, secret_key string,request_url string) (string, string) {
+	// 生成签名
+	//nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	//signature := setSignature(timestamp, nonce, secret_key)
+
+	// 生成输入报文
+	inputMessage := SetAHInputMessage(timestamp, struct3505.OrgName, struct3505.Opter, struct3505.Code, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, struct3505.Cainfo)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3505"                                      // 交易编码
+	inputData["med_list_codg"] = struct3505.MedListCodg                 // 定点医药机构目录编号
+	inputData["fixmedins_hilist_id"] = struct3505.FixmedinsHilistId     // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3505.FixmedinsHilistName // 定点医药机构目录名称
+	inputData["fixmedins_bchno"] = struct3505.FixmedinsBchno            // 人员编号 （来自1101接口返回）
+
+	inputData["prsc_dr_cert_type"] = struct3505.PrscDrCertType // 人员编号 （来自1101接口返回）
+	inputData["prsc_dr_certno"] = struct3505.PrscDrCertno      // 人员编号 （来自1101接口返回）
+	inputData["prsc_dr_name"] = struct3505.PrscDrName          // 人员编号 （来自1101接口返回）
+	inputData["phar_cert_type"] = struct3505.PharCertType      // 人员编号 （来自1101接口返回）
+	inputData["phar_certno"] = struct3505.PharCertno           // 人员编号 （来自1101接口返回）
+
+	inputData["phar_name"] = struct3505.PharName               // 人员编号 （来自1101接口返回）
+	inputData["phar_prac_cert_no"] = struct3505.PharPracCertNo // 人员编号 （来自1101接口返回）
+	inputData["hi_feesetl_type"] = struct3505.HiFeesetlType    // 人员编号 （来自1101接口返回）
+	inputData["setl_id"] = struct3505.SetlId                   // 人员编号 （来自1101接口返回）
+	inputData["mdtrt_sn"] = struct3505.MdtrtSn                 // 人员编号 （来自1101接口返回）
+	inputData["psn_no"] = struct3505.PsnNo                     // 人员编号 （来自1101接口返回）
+	inputData["psn_cert_type"] = struct3505.PsnCertType        // 人员编号 （来自1101接口返回）
+	inputData["certno"] = struct3505.CertNo                    // 人员编号 （来自1101接口返回）
+	inputData["psn_name"] = struct3505.PsnName                 // 人员编号 （来自1101接口返回）
+	inputData["manu_lotnum"] = struct3505.ManuLotnum           // 人员编号 （来自1101接口返回）
+	inputData["manu_date"] = struct3505.ManuDate               // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3505.ExpyEnd                 // 人员编号 （来自1101接口返回）
+
+	inputData["rx_flag"] = struct3505.RxFlag     // 人员编号 （来自1101接口返回）
+	inputData["trdn_flag"] = struct3505.TrdnFlag // 人员编号 （来自1101接口返回）
+
+	inputData["finl_trns_pric"] = struct3505.FinlTrnsPric // 人员编号 （来自1101接口返回）
+	inputData["rxno"] = struct3505.Rxno                   // 人员编号 （来自1101接口返回）
+	inputData["rx_circ_flag"] = struct3505.RxCircFlag     // 人员编号 （来自1101接口返回）
+
+	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
+	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
+
+	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
+	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
+	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
+	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_time"] = struct3505.SelRetnTime            // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_opter_name"] = struct3505.SelRetnOpterName // 人员编号 （来自1101接口返回）
+	inputData["mdtrt_setl_type"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
+
+
+	inputData["memo"] = struct3505.Memo                            // 人员编号 （来自1101接口返回）
+	//input["selinfo"] = inputData
+	feedetail := make([]map[string]interface{}, 0)
+
+	codes := strings.Split(struct3505.DrugTracCodg, ",")
+	for _, item := range codes {
+		druginputData := make(map[string]interface{})
+		druginputData["drug_trac_codg"] = item
+		feedetail = append(feedetail, druginputData)
+	}
+	inputData["drugtracinfo"] = feedetail
+	input["selinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+	argInputMessage  := make(map[string]interface{})
+	argInputMessage["arg0"] = inputMessage
+
+	bytesData, err := json.Marshal(argInputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	reader := bytes.NewReader(bytesData)
+	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/5301"
+	//gdyb_url := beego.AppConfig.String("gdyb_url")
+	//gdyb_paasid := beego.AppConfig.String("gdyb_paasid")
+	//url := "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/1101"
+	//url := gdyb_url + "3505"
+	request_url = request_url + "1101"
+
+	request, err := http.NewRequest("POST", request_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(), ""
+	}
+	str := string(respBytes)
+	fmt.Println(str)
+	return str , string(bytesData)
+}

service/gdyb_service.go

 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
 	signature := setSignature(timestamp, nonce, secret_key)
-
 	// 生成输入报文
-	inputMessage := SetGdInputMessage(timestamp, struct3501.OrgName, struct3501.Opter, struct3501.FixmedinsHilistId, struct3501.InsuplcAdmdvs, struct3501.MdtrtareaAdmvs, struct3501.Cainfo)
+	inputMessage := SetGdInputMessage(timestamp, struct3501.OrgName, struct3501.Opter, struct3501.Code, struct3501.InsuplcAdmdvs, struct3501.MdtrtareaAdmvs, struct3501.Cainfo)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
 	inputMessage["infno"] = "3501"                                      // 交易编码
 	inputData["manu_date"] = struct3501.ManuDate                        // 人员编号 （来自1101接口返回）
 	inputData["expy_end"] = struct3501.ExpyEnd                          // 人员编号 （来自1101接口返回）
 	inputData["memo"] = ""                                              // 人员编号 （来自1101接口返回）
+
 	feedetail := make([]map[string]interface{}, 0)
-	druginputData := make(map[string]interface{})
-	druginputData["drug_trac_codg"] = struct3501.DrugTracCodg
-	feedetail = append(feedetail, druginputData)
+
+	codes := strings.Split(struct3501.DrugTracCodg, ",")
+	for _, item := range codes {
+		if len(item) > 0 {
+			druginputData := make(map[string]interface{})
+			druginputData["drug_trac_codg"] = item
+			feedetail = append(feedetail, druginputData)
+		}
+	}
 	inputData["drugtracinfo"] = feedetail
 	input["invinfo"] = inputData
 	inputMessage["input"] = input //交易输入
 
+
 	bytesData, err := json.Marshal(inputMessage)
 	fmt.Println(string(bytesData))
 	if err != nil {
 	signature := setSignature(timestamp, nonce, secret_key)
 
 	// 生成输入报文
-	inputMessage := SetGdInputMessage(timestamp, struct3505.OrgName, struct3505.Opter, struct3505.FixmedinsHilistId, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, struct3505.Cainfo)
+	inputMessage := SetGdInputMessage(timestamp, struct3505.OrgName, struct3505.Opter, struct3505.Code, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, struct3505.Cainfo)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
 	inputMessage["infno"] = "3505"                                      // 交易编码
 
 	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
 	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
+	inputData["MDTRT_SETL_TYPE"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
 
 	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
 	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
 
 	codes := strings.Split(struct3505.DrugTracCodg, ",")
 	for _, item := range codes {
-		druginputData := make(map[string]interface{})
-		druginputData["drug_trac_codg"] = item
-		feedetail = append(feedetail, druginputData)
+		if len(item) > 0 {
+			druginputData := make(map[string]interface{})
+			druginputData["drug_trac_codg"] = item
+			feedetail = append(feedetail, druginputData)
+		}
 	}
 	inputData["drugtracinfo"] = feedetail
 	input["selinfo"] = inputData
 	inputData["MDTRT_SETL_TYPE"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
 
 	inputData["bchno"] = struct3505.Bchno // 人员编号 （来自1101接口返回）
-	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
+	codes := strings.Split(struct3505.DrugTracCodg, ",")
+
+	inputData["drug_trac_codg"] = codes[0]          // 人员编号 （来自1101接口返回）
 	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
 	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
 	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
 	//drug_trac_cod .g
 	feedetail := make([]map[string]interface{}, 0)
 
-	codes := strings.Split(struct3505.DrugTracCodg, ",")
+	//codes = strings.Split(struct3505.DrugTracCodg, ",")
 	for _, item := range codes {
 		if len(item) > 0{
 			druginputData := make(map[string]interface{})

service/his_service.go

 	return
 }
 
-func GetNewDrugFlowInforTen(system_time int,org_id int64) (flows []*models.DrugFlow, err error) {
+func GetNewDrugFlowInforTen(system_time int64,org_id int64) (flows []*models.DrugFlow, err error) {
 	err = readDb.Model(&models.DrugFlow{}).Joins("join his_doctor_advice_info info on info.patient_id = xt_drug_flow.patient_id and info.drug_id = xt_drug_flow.drug_id and info.record_date = xt_drug_flow.system_time").Where("xt_drug_flow.user_org_id = ? and xt_drug_flow.status = 1 and xt_drug_flow.consumable_type = 3 and xt_drug_flow.is_sale = 0 and xt_drug_flow.system_time = ?", org_id,system_time).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
 		return db.Where("status = 1 and drug_code <> ''").Preload("BaseDrugLib", "status=1")
 	}).Preload("NewDrugWarehouseInfo", "status = 1").Find(&flows).Error
 	return
 }
 
+func GetNewDrugFlowInforTenone(start_system_time int64,end_system_time int64,org_id int64) (flows []*models.DrugFlow, err error) {
+	err = readDb.Model(&models.DrugFlow{}).Joins("join his_doctor_advice_info info on info.patient_id = xt_drug_flow.patient_id and info.drug_id = xt_drug_flow.drug_id and info.record_date = xt_drug_flow.system_time").Where("xt_drug_flow.user_org_id = ? and xt_drug_flow.status = 1 and xt_drug_flow.consumable_type = 3 and xt_drug_flow.is_sale = 0 and xt_drug_flow.system_time >= ? and xt_drug_flow.system_time <= ?", org_id,start_system_time,end_system_time).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 and drug_code <> ''").Preload("BaseDrugLib", "status=1")
+	}).Preload("NewDrugWarehouseInfo", "status = 1").Find(&flows).Error
+	return
+}
+
 func GetHisPrescriptionByID(id int64) (pre models.HisPrescription) {
 	err = readDb.Model(&models.HisPrescription{}).Where("id = ? and status = 1", id).Find(&pre).Error
 	return
 
 func FindeHisAdviceDocAdvice(orgid int64, patient_id int64, stime int64, etime int64) (advice []*models.HisDoctorAdviceInfo, err error) {
 
-	db := XTReadDB().Model(&advice).Where("status= 1 and is_medicine = 0")
+	db := XTReadDB().Model(&advice).Where("status= 1 and is_medicine = 0 and drug_code <> ''")
 
 	if orgid > 0 {
 		db = db.Where("user_org_id = ?", orgid)

service/jsyb_service.go

 
 	inputData["rtal_docno"] = struct3505.RtalDocno // 人员编号 （来自1101接口返回）
 	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
-
+	inputData["stoout_no"] = struct3505.StooutNo   // 人员编号 （来自1101接口返回）
+	inputData["MDTRT_SETL_TYPE"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
 	inputData["bchno"] = struct3505.Bchno                          // 人员编号 （来自1101接口返回）
 	inputData["drug_trac_codg"] = struct3505.DrugTracCodg          // 人员编号 （来自1101接口返回）
 	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
 
 	codes := strings.Split(struct3505.DrugTracCodg, ",")
 	for _, item := range codes {
-		druginputData := make(map[string]interface{})
-		druginputData["drug_trac_codg"] = item
-		feedetail = append(feedetail, druginputData)
+		if len(item) > 0 {
+			druginputData := make(map[string]interface{})
+			druginputData["drug_trac_codg"] = item
+			feedetail = append(feedetail, druginputData)
+		}
 	}
 	inputData["drugtracinfo"] = feedetail
 	input["selinfo"] = inputData

service/jx_service.go

 	"gdyb/models"
 	"gdyb/utils/csbhttp"
 	"github.com/astaxie/beego"
-
+	"strings"
 	//"net/http"
 	"strconv"
 	"time"
 
 }
 
+
+func JXyb3505(struct3505 models.Struct3505, secret_key string, ak string,request_url string) (string, string) {
+	// 生成签名
+	// 生成签名
+	timestamp := time.Now().Unix()
+	inputMessage := SetJXInputMessage(timestamp, struct3505.OrgName, struct3505.Opter,  struct3505.Code, struct3505.InsuplcAdmdvs,  struct3505.MdtrtareaAdmvs, "")
+	//inputMessage := SetGZInputMessage(nonce, timestamp, struct3505.OrgName, struct3505.Opter, struct3505.FixmedinsCode, struct3505.InsuplcAdmdvs, struct3505.MdtrtareaAdmvs, sign)
+
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3505"                                      // 交易编码
+	inputData["med_list_codg"] = struct3505.MedListCodg                 // 定点医药机构目录编号
+	inputData["fixmedins_hilist_id"] = struct3505.FixmedinsHilistId     // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3505.FixmedinsHilistName // 定点医药机构目录名称
+	inputData["fixmedins_bchno"] = struct3505.FixmedinsBchno            // 人员编号 （来自1101接口返回）
+
+	inputData["prsc_dr_cert_type"] = struct3505.PrscDrCertType // 人员编号 （来自1101接口返回）
+	inputData["prsc_dr_certno"] = struct3505.PrscDrCertno      // 人员编号 （来自1101接口返回）
+	inputData["prsc_dr_name"] = struct3505.PrscDrName          // 人员编号 （来自1101接口返回）
+	inputData["phar_cert_type"] = struct3505.PharCertType      // 人员编号 （来自1101接口返回）
+	inputData["phar_certno"] = struct3505.PharCertno           // 人员编号 （来自1101接口返回）
+
+	inputData["phar_name"] = struct3505.PharName               // 人员编号 （来自1101接口返回）
+	inputData["phar_prac_cert_no"] = struct3505.PharPracCertNo // 人员编号 （来自1101接口返回）
+	inputData["hi_feesetl_type"] = struct3505.HiFeesetlType    // 人员编号 （来自1101接口返回）
+	inputData["setl_id"] = struct3505.SetlId                   // 人员编号 （来自1101接口返回）
+	inputData["mdtrt_sn"] = struct3505.MdtrtSn                 // 人员编号 （来自1101接口返回）
+	inputData["psn_no"] = struct3505.PsnNo                     // 人员编号 （来自1101接口返回）
+	inputData["psn_cert_type"] = struct3505.PsnCertType        // 人员编号 （来自1101接口返回）
+	inputData["certno"] = struct3505.CertNo                    // 人员编号 （来自1101接口返回）
+	inputData["psn_name"] = struct3505.PsnName                 // 人员编号 （来自1101接口返回）
+	inputData["manu_lotnum"] = struct3505.ManuLotnum           // 人员编号 （来自1101接口返回）
+	inputData["manu_date"] = struct3505.ManuDate               // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3505.ExpyEnd                 // 人员编号 （来自1101接口返回）
+
+	inputData["rx_flag"] = struct3505.RxFlag     // 人员编号 （来自1101接口返回）
+	inputData["trdn_flag"] = struct3505.TrdnFlag // 人员编号 （来自1101接口返回）
+
+	inputData["finl_trns_pric"] = struct3505.FinlTrnsPric // 人员编号 （来自1101接口返回）
+	inputData["rxno"] = struct3505.Rxno                   // 人员编号 （来自1101接口返回）
+	inputData["rx_circ_flag"] = struct3505.RxCircFlag     // 人员编号 （来自1101接口返回）
+
+	inputData["rtal_docno"] = struct3505.RtalDocno          // 人员编号 （来自1101接口返回）
+	inputData["stoout_no"] = struct3505.StooutNo            // 人员编号 （来自1101接口返回）
+	inputData["MDTRT_SETL_TYPE"] = struct3505.MdtrtSetlType // 人员编号 （来自1101接口返回）
+
+	inputData["bchno"] = struct3505.Bchno // 人员编号 （来自1101接口返回）
+	codes := strings.Split(struct3505.DrugTracCodg, ",")
+
+	inputData["drug_trac_codg"] = codes[0]          // 人员编号 （来自1101接口返回）
+	inputData["drug_prod_barc"] = struct3505.DrugProdBarc          // 人员编号 （来自1101接口返回）
+	inputData["shelf_posi"] = struct3505.ShelfPosi                 // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_cnt"] = struct3505.SelRetnCnt              // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_time"] = struct3505.SelRetnTime            // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_opter_name"] = struct3505.SelRetnOpterName // 人员编号 （来自1101接口返回）
+	inputData["memo"] = struct3505.Memo                            // 人员编号 （来自1101接口返回）
+	//drug_trac_cod .g
+	feedetail := make([]map[string]interface{}, 0)
+
+	//codes = strings.Split(struct3505.DrugTracCodg, ",")
+	for _, item := range codes {
+		if len(item) > 0{
+			druginputData := make(map[string]interface{})
+			druginputData["drug_trac_codg"] = item
+			feedetail = append(feedetail, druginputData)
+		}
+	}
+	inputData["drugtracinfo"] = feedetail
+	input["selinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	input["selinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	requestLog := string(bytesData)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	request_url = request_url + "3505"
+	return JXHttpRequest(request_url, ak, secret_key, timestamp, string(bytesData), "3505"), requestLog
+
+}
+
+
 //CBS总线
 func JXHttpRequest(url string, ak string, sk string, timestamp int64, json string, infno string) string {
 	fmt.Println(url)
 	inputData["medfee_sumamt"] = medfee_sumamt           //医疗费总额
 	inputData["fund_pay_sumamt"] = fund_pay_sumamt       //基金支付总额
 	inputData["acct_pay"] = acct_pay                     //个人账户支付金额
-	inputData["fixmedins_setl_cnt"] = 20 //定点医药机构结算笔数
-	inputData["refd_setl_flag"] = 1                  //
+	inputData["fixmedins_setl_cnt"] = fixmedins_setl_cnt //定点医药机构结算笔数
+	inputData["refd_setl_flag"] = 0                  //
 
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入