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

conf/app.conf

@@ -45,7 +45,7 @@ appsecret="61ee2e6268497d5aa9de0b0187c39aea"
 
 
 [prod]
-org_id = 10106
+org_id = 10217
 mobile_token_expiration_second = 86400
 httpdomain = https://api.xt.kuyicloud.com
 sso_domain = https://sso.kuyicloud.com

controllers/js/jsyb_controller.go

@@ -50,10 +50,237 @@ func JSybRegistRouters() {
 	beego.Router("/jsyb/4101", &JSybController{}, "post:Get4101")
 	beego.Router("/jsyb/readcard", &JSybController{}, "get:ReadCard")
 
-	beego.Router("/jsyb/3501", &JSybController{}, "get:Get3501")
+	beego.Router("/jsyb/3501", &JSybController{}, "post:Get3501")
+	beego.Router("/jsyb/3502", &JSybController{}, "post:Get3502")
+	beego.Router("/jsyb/3503", &JSybController{}, "post:Get3503")
+	beego.Router("/jsyb/3504", &JSybController{}, "post:Get3504")
+	beego.Router("/jsyb/3505", &JSybController{}, "post:Get3505")
+	beego.Router("/jsyb/3506", &JSybController{}, "post:Get3506")
+	beego.Router("/jsyb/3507", &JSybController{}, "post:Get3507")
 
 }
 func (c *JSybController) Get3501() {
+	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 struct3501 []models.Struct3501
+	if err := json.Unmarshal(userJSONBytes, &struct3501); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3501(struct3501[0])
+	saveJsLog(result, request_log, "3501", "库存盘点", struct3501[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3502() {
+	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 struct3502s []models.Struct3502
+	if err := json.Unmarshal(userJSONBytes, &struct3502s); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3502(struct3502s[0])
+	saveJsLog(result, request_log, "3501", "库存盘点", struct3502s[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3503() {
+	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 struct3503 []models.Struct3503
+	if err := json.Unmarshal(userJSONBytes, &struct3503); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3503(struct3503[0])
+	saveJsLog(result, request_log, "3501", "库存盘点", struct3503[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3504() {
+	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 struct3504 []models.Struct3504
+	if err := json.Unmarshal(userJSONBytes, &struct3504); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3504(struct3504[0])
+	saveJsLog(result, request_log, "3504", "库存盘点", struct3504[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3505() {
+	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 struct3505 []models.Struct3505
+	if err := json.Unmarshal(userJSONBytes, &struct3505); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3505(struct3505[0])
+	saveJsLog(result, request_log, "3505", "库存盘点", struct3505[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3506() {
+	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 struct3506 []models.Struct3506
+	if err := json.Unmarshal(userJSONBytes, &struct3506); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3506(struct3506[0])
+	saveJsLog(result, request_log, "3506", "库存盘点", struct3506[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
+
+}
+func (c *JSybController) Get3507() {
+	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 struct3507 []models.Struct3507
+	if err := json.Unmarshal(userJSONBytes, &struct3507); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		return
+	}
+
+	result, request_log := service.Jsyb3507(struct3507[0])
+	saveJsLog(result, request_log, "3507", "库存盘点", struct3507[0].OrgName)
+	var dat2 map[string]interface{}
+	if err := json.Unmarshal([]byte(request_log), &dat2); err == nil {
+	} else {
+	}
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+	} else {
+
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre":         dat,
+		"request_log": dat2,
+	})
 
 }
 func (c *JSybController) Get9001() {
@@ -799,7 +1026,10 @@ func (c *JSybController) ReadCard() {
 		if len(token) > 0 {
 			userName := ConvertByte2String([]byte(ele.Data.UserName), GB18030)
 			userName = Remove0000(userName)
-			result, _ := service.Jsyb1101ForEleCert(org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IDNo, userName)
+			fmt.Println(userName)
+			enc := mahonia.NewEncoder("gbk")
+			fmt.Println(enc.ConvertString(userName))
+			result, _ := service.Jsyb1101ForEleCert(org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, secret_key, url, ak, token, cainfo, ele.Data.IDNo, enc.ConvertString(userName))
 			var dat map[string]interface{}
 			if err := json.Unmarshal([]byte(result), &dat); err == nil {
 				fmt.Println(dat)

controllers/sg/his_api_controller.go

@@ -85,6 +85,8 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/3202", &HisApiController{}, "get:Post3202")
 
+	beego.Router("/api/3501", &HisApiController{}, "post:Post3501")
+
 }
 
 type Result3101 struct {
@@ -13273,3 +13275,550 @@ func (c *HisApiController) Post3202() {
 		}
 	}
 }
+
+func (c *HisApiController) Post3501() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-17"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-17"
+	struct3501.Invdate = "2022-08-17"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3502() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3502s []models.Struct3502
+	var struct3502 models.Struct3502
+	struct3502.OrgName = miConfig.OrgName
+	struct3502.AccessKey = miConfig.AccessKey
+	struct3502.RequestUrl = miConfig.Url
+	struct3502.SecretKey = miConfig.SecretKey
+	struct3502.ManuDate = "2022-08-15"
+	struct3502.FixmedinsBchno = ""
+	struct3502.ManuLotnum = ""
+	struct3502.RxFlag = "0"
+	struct3502.ExpyEnd = "2022-08-15"
+	struct3502.Invdate = "2022-08-15"
+	struct3502.InvCnt = "20.25"
+	struct3502.Memo = ""
+	struct3502.MedListCodg = "XB01ABD056B002020200517"
+	struct3502.FixmedinsHilistId = miConfig.Code
+	struct3502.FixmedinsHilistName = miConfig.OrgName
+	struct3502s = append(struct3502s, struct3502)
+	data["struct_3502s"] = struct3502s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3503() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-15"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-15"
+	struct3501.Invdate = "2022-08-15"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3504() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-15"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-15"
+	struct3501.Invdate = "2022-08-15"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3505() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-15"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-15"
+	struct3501.Invdate = "2022-08-15"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3506() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-15"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-15"
+	struct3501.Invdate = "2022-08-15"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}
+func (c *HisApiController) Post3507() {
+	miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId)
+	data := make(map[string]interface{})
+	var struct3501s []models.Struct3501
+	var struct3501 models.Struct3501
+	struct3501.OrgName = miConfig.OrgName
+	struct3501.AccessKey = miConfig.AccessKey
+	struct3501.RequestUrl = miConfig.Url
+	struct3501.SecretKey = miConfig.SecretKey
+	struct3501.ManuDate = "2022-08-15"
+	struct3501.FixmedinsBchno = ""
+	struct3501.ManuLotnum = ""
+	struct3501.RxFlag = "0"
+	struct3501.ExpyEnd = "2022-08-15"
+	struct3501.Invdate = "2022-08-15"
+	struct3501.InvCnt = "20.25"
+	struct3501.Memo = ""
+	struct3501.MedListCodg = "XB01ABD056B002020200517"
+	struct3501.FixmedinsHilistId = miConfig.Code
+	struct3501.FixmedinsHilistName = miConfig.OrgName
+	struct3501s = append(struct3501s, struct3501)
+	data["struct_3501s"] = struct3501s
+	client := &http.Client{}
+	bytesData, _ := json.Marshal(data)
+	var req *http.Request
+
+	if miConfig.MdtrtareaAdmvs == "320921" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110:9532/"+"jsyb/3501", bytes.NewReader(bytesData))
+	} else {
+		req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3501", 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
+	}
+	var res ResultSix
+	var resSix10265 ResultSix10265 //1101结果
+
+	respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{})
+	result, _ := json.Marshal(respJSON)
+	if err := json.Unmarshal([]byte(result), &resSix10265); err != nil {
+		utils.ErrorLog("解析失败：%v", err)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+	res.InfRefmsgid = resSix10265.InfRefmsgid
+	res.Output = resSix10265.Output
+	res.ErrMsg = resSix10265.ErrMsg
+	res.Cainfo = resSix10265.Cainfo
+	res.WarnMsg = resSix10265.WarnMsg
+	infocode, _ := strconv.ParseInt(resSix10265.Infcode, 10, 64)
+	res.Infcode = infocode
+
+	if infocode == 0 {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"msg": "上传成功",
+		})
+		return
+
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"failed_code": -10,
+			"msg":         res.ErrMsg,
+		})
+		return
+	}
+}

controllers/zh/zh_his_api_controller.go

@@ -495,7 +495,473 @@ func ZHHisManagerApiRegistRouters() {
 	beego.Router("/zh/api/clearsettle", &ZHHisApiController{}, "get:ClearSettle")
 	beego.Router("/zh/api/readelecard", &ZHHisApiController{}, "get:ReadEleCard")
 
+	//beego.Router("/zh/api/readelecard", &ZHHisApiController{}, "get:ReadEleCard")
+	beego.Router("/zh/api/lingbao/upload", &ZHHisApiController{}, "get:UploadLingBao")
+	beego.Router("/zh/api/lingbao/refund", &ZHHisApiController{}, "get:RefundLingBao")
+	beego.Router("/zh/api/lingbao/get", &ZHHisApiController{}, "get:GetLingBao")
+
 }
+
+func (c *ZHHisApiController) UploadLingBao() {
+	id, _ := c.GetInt64("id")
+	record_time := c.GetString("record_time")
+	in_hospital_id, _ := c.GetInt64("in_hospital_id")
+	settle_accounts_type, _ := c.GetInt64("settle_accounts_type")
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 00:00:00", loc)
+	if err != nil {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	recordDateTime := theTime.Unix()
+	adminUser := c.GetAdminUserInfo()
+	var prescriptions []*models.HisPrescription
+	data := make(map[string]interface{})
+	if settle_accounts_type == 1 { //日结
+		prescriptions, _ = service.GetZHHisPrescription(adminUser.CurrentOrgId, id, recordDateTime)
+
+	} else { //月结
+		start_time_str := c.GetString("start_time")
+		end_time_str := c.GetString("end_time")
+		timeLayout := "2006-01-02"
+		loc, _ := time.LoadLocation("Local")
+		theStartTime, err := time.ParseInLocation(timeLayout+" 15:04:05", start_time_str+" 00:00:00", loc)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		recordStartTime := theStartTime.Unix()
+		theEndTime, err := time.ParseInLocation(timeLayout+" 15:04:05", end_time_str+" 00:00:00", loc)
+		if err != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			return
+		}
+		recordEndTime := theEndTime.Unix()
+		prescriptions, _ = service.GetZHMonthHisPrescription(adminUser.CurrentOrgId, id, recordStartTime, recordEndTime)
+
+	}
+	roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id)
+	record, _ := service.GetInHospitalRecord(in_hospital_id)
+	if record.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+
+	timestamp := time.Now().Unix()
+	tempTime := time.Unix(timestamp, 0)
+	timeFormat := tempTime.Format("20060102150405")
+	chrgBchno := rand.Intn(100000) + 10000
+	chrg_bchno := timeFormat + strconv.FormatInt(int64(chrgBchno), 10) + strconv.FormatInt(record.PatientId, 10)
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	patientPrescription, _ := service.FindPatientPrescriptionInfo(adminUser.CurrentOrgId, id, recordDateTime)
+	department, _ := service.GetDepartMentDetail(record.Departments)
+	strconv.FormatInt(record.PatientId, 10)
+
+	doctor_info, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, record.Doctor)
+
+	//client := &http.Client{}
+	data["psn_no"] = record.PsnNo
+	data["mdtrt_id"] = record.Number
+	data["chrg_bchno"] = chrg_bchno
+	data["org_name"] = miConfig.OrgName
+	data["doctor"] = roles.UserName
+	data["doctor_id"] = strconv.FormatInt(roles.AdminUserId, 10)
+	data["dept"] = strconv.FormatInt(department.ID, 10)
+	data["fixmedins_code"] = miConfig.Code
+	if (department.ID == 0 && adminUser.CurrentOrgId == 9919) || (department.ID == 0 && adminUser.CurrentOrgId == 10106) {
+		data["dept_code"] = "15"
+	} else {
+		data["dept_code"] = department.Number
+	}
+	if miConfig.Code == "H15049901371" {
+		if record.MedType == 14 {
+			if record.InsutypeType == "390" {
+
+				data["med_type"] = "9933"
+
+			} else if record.InsutypeType == "310" {
+
+				data["med_type"] = "990502"
+
+			}
+
+		} else if record.MedType == 11 {
+
+			data["med_type"] = strconv.FormatInt(record.MedType, 10)
+
+		}
+
+	} else {
+		if record.MedType == 1112 {
+			data["med_type"] = strconv.FormatInt(11, 10)
+		} else {
+			data["med_type"] = strconv.FormatInt(record.MedType, 10)
+		}
+
+	}
+	data["insuplc_admdvs"] = record.InsuplcAdmdvs
+	data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs
+	data["secret_key"] = miConfig.SecretKey
+	var ids []int64
+
+	fmt.Println(data)
+
+	for _, item := range prescriptions {
+		ids = append(ids, item.ID)
+	}
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+	if config.IsOpen == 1 { //对接了医保，走医保流程
+
+		var pagesize int = 100
+		var start int = 1
+		var stop int
+		var pagecount int
+		var curpage int
+		var isSuccess bool = true
+
+		var customs []*models.NewCustom
+
+		for _, item := range prescriptions {
+			tm := time.Unix(item.PreTime, 0)
+			if item.Type == 1 { //药品
+				for _, subItem := range item.HisDoctorAdviceInfo {
+					if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 && subItem.BaseDrugLib.IsUser != 1 {
+						//var randNum int
+						//randNum = rand.Intn(10000) + 1000
+						cus := &models.NewCustom{
+							DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*subItem.PrescribingNumber),
+							Cut:              fmt.Sprintf("%.4f", subItem.PrescribingNumber),
+							FeedetlSn:        subItem.FeedetlSn,
+							Price:            fmt.Sprintf("%.4f", subItem.Price),
+							MedListCodg:      subItem.BaseDrugLib.MedicalInsuranceNumber,
+							HospApprFlag:     subItem.BaseDrugLib.HospApprFlag,
+							FeeOcurTime:      tm.Format("2006-01-02 15:04:05"),
+						}
+
+						customs = append(customs, cus)
+					}
+				}
+			}
+
+			if item.Type == 2 { //项目
+				for _, subItem := range item.HisPrescriptionProject {
+					//var randNum int
+					//randNum = rand.Intn(10000) + 1000
+					if subItem.Type == 2 {
+						if len(subItem.HisProject.MedicalCode) > 0 {
+							cnt, _ := strconv.ParseFloat(subItem.Count, 64)
+							cus := &models.NewCustom{
+								DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
+								Cut:              fmt.Sprintf("%.4f", cnt),
+								FeedetlSn:        subItem.FeedetlSn,
+								Price:            fmt.Sprintf("%.4f", float64(subItem.Price)),
+								MedListCodg:      subItem.HisProject.MedicalCode,
+								HospApprFlag:     -1,
+								FeeOcurTime:      tm.Format("2006-01-02 15:04:05"),
+							}
+							customs = append(customs, cus)
+						}
+					} else if subItem.Type == 3 {
+						if len(subItem.GoodInfo.MedicalInsuranceNumber) > 0 && subItem.GoodInfo.IsUser != 1 {
+							cnt, _ := strconv.ParseFloat(subItem.Count, 64)
+
+							cus := &models.NewCustom{
+								DetItemFeeSumamt: fmt.Sprintf("%.4f", subItem.Price*cnt),
+								Cut:              fmt.Sprintf("%.4f", cnt),
+								FeedetlSn:        subItem.FeedetlSn,
+								Price:            fmt.Sprintf("%.4f", float64(subItem.Price)),
+								MedListCodg:      subItem.GoodInfo.MedicalInsuranceNumber,
+								HospApprFlag:     -1,
+								FeeOcurTime:      tm.Format("2006-01-02 15:04:05"),
+							}
+							customs = append(customs, cus)
+						}
+					}
+				}
+			}
+
+		}
+
+		//总页数,向上取整,注意除之前要先转换类型为float64
+		pagecount = int(math.Ceil(float64(len(customs)) / float64(pagesize)))
+		var ress []*ResultFour
+		for curpage = 1; curpage <= pagecount; curpage++ {
+			if curpage == 1 {
+				start = 1
+			} else {
+				start = (curpage-1)*pagesize + 1
+			}
+			stop = curpage * pagesize
+			if stop > len(customs) {
+				stop = len(customs)
+			}
+
+			var result string
+			var requestLog string
+			if miConfig.MdtrtareaAdmvs == "150499" {
+				data := make(map[string]interface{})
+				if record.MedType == 14 {
+					if record.InsutypeType == "390" {
+
+						data["med_type"] = "9933"
+
+					} else if record.InsutypeType == "310" {
+
+						data["med_type"] = "990502"
+
+					}
+
+				} else if record.MedType == 11 {
+
+					data["med_type"] = strconv.FormatInt(record.MedType, 10)
+
+				}
+				data["psn_no"] = record.PsnNo
+				data["number"] = record.Number
+				data["customs"] = customs[start-1 : stop]
+				data["chrg_bchno"] = chrg_bchno
+				data["dept"] = strconv.FormatInt(department.ID, 10)
+				data["dept_code"] = department.Number
+				data["doctor_code"] = doctor_info.DoctorNumber
+				data["doctor_name"] = doctor_info.UserName
+				data["org_name"] = miConfig.OrgName
+				data["opertor"] = roles.UserName
+				data["fixmedins_code"] = miConfig.Code
+				data["insuplc_admdvs"] = record.InsuplcAdmdvs
+				data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs
+				data["secret_key"] = miConfig.SecretKey
+
+				var req *http.Request
+				bytesData, _ := json.Marshal(data)
+				req, _ = http.NewRequest("POST", "http://172.16.13.254:9532/"+"nmyb/2301", bytes.NewReader(bytesData))
+				client := &http.Client{}
+				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
+				}
+				respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+				result_byte, _ := json.Marshal(respJSON)
+				result = string(result_byte)
+			} else {
+				result, 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), record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, data["med_type"].(string), doctor_info.DoctorNumber, doctor_info.UserName)
+				saveLog(result, requestLog, "2301", "上传明细")
+			}
+
+			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 ResultFour
+			var resFour10265 ResultFour10265
+			if miConfig.Code == "H15049901371" {
+				if err := json.Unmarshal(userJSONBytes, &resFour10265); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				res.WarnMsg = resFour10265.WarnMsg
+				res.Output = resFour10265.Output
+				res.ErrMsg = resFour10265.ErrMsg
+				res.RespondTime = resFour10265.RespondTime
+				res.InfRefmsgid = resFour10265.InfRefmsgid
+				Infcode, _ := strconv.ParseInt(resFour10265.Infcode, 10, 64)
+				res.Infcode = Infcode
+
+			} else {
+				if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			}
+
+			if res.Infcode == 0 {
+				ress = append(ress, &res)
+			} else {
+				isSuccess = false
+				errlog := &models.HisOrderError{
+					UserOrgId:  adminUser.CurrentOrgId,
+					Ctime:      time.Now().Unix(),
+					Mtime:      time.Now().Unix(),
+					Number:     chrg_bchno,
+					ErrMsg:     "",
+					Status:     1,
+					PatientId:  id,
+					RecordTime: recordDateTime,
+					Stage:      4,
+				}
+				service.CreateErrMsgLog(errlog)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"failed_code": -10,
+					"msg":         "上传明细错误,请联系his厂商",
+				})
+				return
+			}
+		}
+
+		if isSuccess == true {
+			if settle_accounts_type == 1 {
+				for _, subItem := range ress {
+					for _, item := range subItem.Output.Result {
+						temp := strings.Split(item.FeedetlSn, "-")
+						var advice_id int64 = 0
+						var project_id int64 = 0
+						var types int64 = 0
+
+						id, _ := strconv.ParseInt(temp[2], 10, 64)
+						types, _ = strconv.ParseInt(temp[1], 10, 64)
+
+						if temp[1] == "1" {
+							advice_id = id
+							project_id = 0
+						} else if temp[1] == "2" {
+							advice_id = 0
+							project_id = id
+						}
+						info := &models.HisOrderInfo{
+							OrderNumber:      record.Number,
+							FeedetlSn:        item.FeedetlSn,
+							UploadDate:       recordDateTime,
+							AdviceId:         advice_id,
+							DetItemFeeSumamt: item.DetItemFeeSumamt,
+							Cnt:              item.Cnt,
+							Pric:             float64(item.Pric),
+							PatientId:        record.PatientId,
+							PricUplmtAmt:     item.PricUplmtAmt,
+							SelfpayProp:      item.SelfpayProp,
+							FulamtOwnpayAmt:  item.FulamtOwnpayAmt,
+							OverlmtAmt:       item.OverlmtAmt,
+							PreselfpayAmt:    item.PreselfpayAmt,
+							BasMednFlag:      item.BasMednFlag,
+							MedChrgitmType:   item.MedChrgitmType,
+							HiNegoDrugFlag:   item.HiNegoDrugFlag,
+							Status:           1,
+							Memo:             item.Memo,
+							Mtime:            time.Now().Unix(),
+							InscpScpAmt:      item.InscpScpAmt,
+							DrtReimFlag:      item.DrtReimFlag,
+							Ctime:            time.Now().Unix(),
+							ListSpItemFlag:   item.ListSpItemFlag,
+							ChldMedcFlag:     item.ChldMedcFlag,
+							LmtUsedFlag:      item.LmtUsedFlag,
+							ChrgitmLv:        item.ChrgitmLv,
+							UserOrgId:        adminUser.CurrentOrgId,
+							HisPatientId:     record.ID,
+							OrderId:          0,
+							ProjectId:        project_id,
+							Type:             types,
+							SettleType:       settle_accounts_type,
+						}
+						service.CreateOrderInfo(info)
+					}
+				}
+
+				err := service.UpDatePrescriptionOrderStatus(adminUser.CurrentOrgId, ids)
+				service.UpDatePrescriptionNumber(adminUser.CurrentOrgId, ids, record.Number)
+				service.UpDatePrescriptionInfoNumber(adminUser.CurrentOrgId, patientPrescription.PatientId, record.Number, recordDateTime)
+				if err == nil {
+					c.ServeSuccessJSON(map[string]interface{}{
+						"msg": "上传费用明细成功",
+					})
+					return
+				} else {
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+					return
+				}
+
+			} else {
+
+				for _, subItem := range ress {
+					for _, item := range subItem.Output.Result {
+						temp := strings.Split(item.FeedetlSn, "-")
+						var advice_id int64 = 0
+						var project_id int64 = 0
+						var types int64 = 0
+
+						id, _ := strconv.ParseInt(temp[2], 10, 64)
+						types, _ = strconv.ParseInt(temp[1], 10, 64)
+
+						if temp[1] == "1" {
+							advice_id = id
+							project_id = 0
+						} else if temp[1] == "2" {
+							advice_id = 0
+							project_id = id
+						}
+						info := &models.HisOrderInfo{
+							OrderNumber:      record.Number,
+							FeedetlSn:        item.FeedetlSn,
+							UploadDate:       time.Now().Unix(),
+							AdviceId:         advice_id,
+							DetItemFeeSumamt: item.DetItemFeeSumamt,
+							Cnt:              item.Cnt,
+							Pric:             float64(item.Pric),
+							PatientId:        record.PatientId,
+							PricUplmtAmt:     item.PricUplmtAmt,
+							SelfpayProp:      item.SelfpayProp,
+							FulamtOwnpayAmt:  item.FulamtOwnpayAmt,
+							OverlmtAmt:       item.OverlmtAmt,
+							PreselfpayAmt:    item.PreselfpayAmt,
+							BasMednFlag:      item.BasMednFlag,
+							MedChrgitmType:   item.MedChrgitmType,
+							HiNegoDrugFlag:   item.HiNegoDrugFlag,
+							Status:           1,
+							Memo:             item.Memo,
+							Mtime:            time.Now().Unix(),
+							InscpScpAmt:      item.InscpScpAmt,
+							DrtReimFlag:      item.DrtReimFlag,
+							Ctime:            time.Now().Unix(),
+							ListSpItemFlag:   item.ListSpItemFlag,
+							ChldMedcFlag:     item.ChldMedcFlag,
+							LmtUsedFlag:      item.LmtUsedFlag,
+							ChrgitmLv:        item.ChrgitmLv,
+							UserOrgId:        adminUser.CurrentOrgId,
+							HisPatientId:     record.ID,
+							ProjectId:        project_id,
+							Type:             types,
+							SettleType:       settle_accounts_type,
+						}
+						service.CreateOrderInfo(info)
+					}
+				}
+				service.UpDatePrescriptionOrderStatus(adminUser.CurrentOrgId, ids)
+				service.UpDatePrescriptionNumber(adminUser.CurrentOrgId, ids, record.Number)
+				service.UpDatePrescriptionInfoNumber(adminUser.CurrentOrgId, patientPrescription.PatientId, record.Number, recordDateTime)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"msg": "上传费用明细成功",
+				})
+
+			}
+
+		}
+
+	}
+}
+
+func (c *ZHHisApiController) RefundLingBao() {
+
+}
+
+func (c *ZHHisApiController) GetLingBao() {
+
+}
+
 func (c *ZHHisApiController) ReadEleCard() {
 	id_card_type, _ := c.GetInt64("id_card_type")
 	admin_user_id, _ := c.GetInt64("admin_user_id")

main.go

@@ -4,8 +4,6 @@ import (
 	//"github.com/qiniu/api.v7/auth/qbox"
 	//"github.com/qiniu/api.v7/storage"
 
-	"gdyb/service"
-
 	//"gdyb/models"
 	_ "gdyb/routers"
 	//"github.com/qiniu/api.v7/auth/qbox"
@@ -21,14 +19,14 @@ import (
 )
 
 func init() {
-	service.ConnectDB()
-	org_id, _ := beego.AppConfig.Int64("org_id")
-	miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
+	//service.ConnectDB()
+	//org_id, _ := beego.AppConfig.Int64("org_id")
+	//miConfig, _ := service.FindMedicalInsuranceInfo(org_id)
 	//CreateLog(miConfig)
 	//UploadLog(miConfig)
-	if org_id == 10191 {
-		service.GetFjAuthorizationInfo(miConfig.Code)
-	}
+	//if org_id == 10191 {
+	//	service.GetFjAuthorizationInfo(miConfig.Code)
+	//}
 }
 func main() {
 	beego.Run()

models/models_3501.go

@@ -0,0 +1,201 @@
+package models
+
+type Struct3501 struct {
+	MedListCodg         string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	RxFlag              string
+	Invdate             string
+	InvCnt              string
+	ManuLotnum          string
+	FixmedinsBchno      string
+	ManuDate            string
+	ExpyEnd             string
+	Memo                string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3502 struct {
+	MedListCodg         string
+	InvChgType          string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	FixmedinsBchno      string
+	Pric                string
+	Cnt                 string
+	RxFlag              string
+	InvChgTime          string
+	Invdate             string
+	InvCnt              string
+	ManuLotnum          string
+	ManuDate            string
+	ExpyEnd             string
+	Memo                string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3503 struct {
+	MedListCodg         string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	DyntNo              string
+	FixmedinsBchno      string
+	SplerName           string
+	SplerPmtno          string
+	ManuLotnum          string
+	ProdentpName        string
+	Aprvno              string
+	ManuDate            string
+	ExpyEnd             string
+	FinlTrnsPric        string
+	PurcRetnCnt         string
+	PurcInvoCodg        string
+	PurcInvoNo          string
+	RxFlag              string
+	PurcRetnStoinTime   string
+	PurcRetnOpterName   string
+	ProdGeayFlag        string
+	Memo                string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3504 struct {
+	MedListCodg         string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	FixmedinsBchno      string
+	SplerName           string
+	SplerPmtno          string
+	ManuDate            string
+	ExpyEnd             string
+	FinlTrnsPric        string
+	PurcRetnCnt         string
+	PurcInvoCodg        string
+	PurcInvoNo          string
+	RxFlag              string
+	PurcRetnStoinTime   string
+	PurcRetnOpterName   string
+	Memo                string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3505 struct {
+	MedListCodg         string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	FixmedinsBchno      string
+	PrscDrCertType      string
+	PrscDrCertno        string
+	PrscDrName          string
+	PharCertType        string
+	PharCertno          string
+	PharName            string
+	PharPracCertNo      string
+	HiFeesetlType       string
+	SetlId              string
+	MdtrtSn             string
+	PsnNo               string
+	PsnCertType         string
+	CertNo              string
+	PsnName             string
+	ManuLotnum          string
+	ManuDate            string
+	ExpyEnd             string
+	RxFlag              string
+	TrdnFlag            string
+	FinlTrnsPric        string
+	Rxno                string
+	RxCircFlag          string
+	RtalDocno           string
+	StooutNo            string
+	Bchno               string
+	DrugTracCodg        string
+	DrugProdBarc        string
+	ShelfPosi           string
+	SelRetnCnt          string
+	SelRetnTime         string
+	SelRetnOpterName    string
+	Memo                string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3506 struct {
+	MedListCodg         string
+	FixmedinsHilistId   string
+	FixmedinsHilistName string
+	FixmedinsBchno      string
+	SetlId              string
+	PsnNo               string
+	PsnCertType         string
+	Certno              string
+	PsnName             string
+	ManuLotnum          string
+	ManuDate            string
+	ExpyEnd             string
+	RxFlag              string
+	TrdnFlag            string
+	FinlTrnsPric        string
+	SelTrnsPric         string
+	SelRetnCnt          string
+	SelRetnTime         string
+	SelRetnOpterName    string
+	Memo                string
+	MedinsProdSelNo     string
+	OrgName             string
+	Opter               string
+	SecretKey           string
+	FixmedinsCode       string
+	InsuplcAdmdvs       string
+	MdtrtareaAdmvs      string
+	RequestUrl          string
+	AccessKey           string
+	Cainfo              string
+}
+type Struct3507 struct {
+	FixmedinsBchno string
+	InvDataType    string
+	OrgName        string
+	Opter          string
+	SecretKey      string
+	FixmedinsCode  string
+	InsuplcAdmdvs  string
+	MdtrtareaAdmvs string
+	RequestUrl     string
+	AccessKey      string
+	Cainfo         string
+}

service/jsyb_service.go

@@ -1702,25 +1702,24 @@ func Jsyb4101(struct4101 Struct4101, params models.PublicParams) (string, string
 
 }
 
-func Jsyb3501(med_list_codg string, rx_flag string, invdate string, inv_cnt float64, fixmedins_bchno string, manu_date string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
+func Jsyb3501(struct3501 models.Struct3501) (string, string) {
 	timestamp := time.Now().Unix()
 	// 生成输入报文
-	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
+	inputMessage := SetJSInputMessage(timestamp, struct3501.OrgName, struct3501.Opter, struct3501.FixmedinsCode, struct3501.InsuplcAdmdvs, struct3501.MdtrtareaAdmvs, struct3501.Cainfo)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "3501"                    // 交易编码
-	inputData["med_list_codg"] = med_list_codg        // 定点医药机构目录编号
-	inputData["fixmedins_hilist_id"] = fixmedins_code // 定点医药机构目录编号
-	inputData["fixmedins_hilist_name"] = org_name     // 定点医药机构目录名称
-	inputData["rx_flag"] = rx_flag                    //
-	inputData["invdate"] = invdate                    // 人员编号 （来自1101接口返回）
-	inputData["inv_cnt"] = inv_cnt                    // 人员编号 （来自1101接口返回）
-	inputData["manu_lotnum"] = ""                     // 人员编号 （来自1101接口返回）
-	inputData["fixmedins_bchno"] = fixmedins_bchno    // 人员编号 （来自1101接口返回）
-	inputData["manu_date"] = manu_date                // 人员编号 （来自1101接口返回）
-	inputData["expy_end"] = expy_end                  // 人员编号 （来自1101接口返回）
-	inputData["memo"] = ""                            // 人员编号 （来自1101接口返回）
-
+	inputMessage["infno"] = "3501"                                  // 交易编码
+	inputData["med_list_codg"] = struct3501.MedListCodg             // 定点医药机构目录编号
+	inputData["fixmedins_hilist_id"] = struct3501.FixmedinsHilistId // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3501.OrgName         // 定点医药机构目录名称
+	inputData["rx_flag"] = struct3501.RxFlag                        //
+	inputData["invdate"] = struct3501.Invdate                       // 人员编号 （来自1101接口返回）
+	inputData["inv_cnt"] = struct3501.InvCnt                        // 人员编号 （来自1101接口返回）
+	inputData["manu_lotnum"] = struct3501.ManuLotnum                // 人员编号 （来自1101接口返回）
+	inputData["fixmedins_bchno"] = struct3501.FixmedinsBchno        // 人员编号 （来自1101接口返回）
+	inputData["manu_date"] = struct3501.ManuDate                    // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3501.ExpyEnd                      // 人员编号 （来自1101接口返回）
+	inputData["memo"] = ""                                          // 人员编号 （来自1101接口返回）
 	input["invinfo"] = inputData
 	inputMessage["input"] = input //交易输入
 
@@ -1730,31 +1729,31 @@ func Jsyb3501(med_list_codg string, rx_flag string, invdate string, inv_cnt floa
 		fmt.Println(err.Error())
 		return err.Error(), ""
 	}
-	request_url = request_url + "3501"
-	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
+	struct3501.RequestUrl = struct3501.RequestUrl + "3501"
+	return HttpRequest(struct3501.RequestUrl, struct3501.AccessKey, struct3501.SecretKey, timestamp, string(bytesData)), string(bytesData)
 
 }
-func Jsyb3502(med_list_codg string, rx_flag string, inv_chg_type string, cnt float64, pric float64, fixmedins_bchno string, inv_chg_time string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
+func Jsyb3502(struct3502 models.Struct3502) (string, string) {
 	timestamp := time.Now().Unix()
 	// 生成输入报文
-	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
+	inputMessage := SetJSInputMessage(timestamp, struct3502.OrgName, struct3502.Opter, struct3502.FixmedinsCode, struct3502.InsuplcAdmdvs, struct3502.MdtrtareaAdmvs, struct3502.Cainfo)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "3502"             // 交易编码
-	inputData["med_list_codg"] = med_list_codg // 定点医药机构目录编号
-	inputData["inv_chg_type"] = inv_chg_type   // 定点医药机构目录编号
-
-	inputData["fixmedins_hilist_id"] = fixmedins_code // 定点医药机构目录编号
-	inputData["fixmedins_hilist_name"] = org_name     // 定点医药机构目录名称
-	inputData["fixmedins_bchno"] = fixmedins_bchno    // 人员编号 （来自1101接口返回）
-	inputData["pric"] = pric                          // 人员编号 （来自1101接口返回）
-	inputData["cnt"] = cnt                            // 人员编号 （来自1101接口返回）
-	inputData["rx_flag"] = rx_flag                    //
-
-	inputData["inv_chg_time"] = inv_chg_time // 人员编号 （来自1101接口返回）
-	inputData["inv_chg_opter_name"] = ""     // 人员编号 （来自1101接口返回）
-	inputData["memo"] = ""                   // 人员编号 （来自1101接口返回）
-	inputData["trdn_flag"] = ""              // 人员编号 （来自1101接口返回）
+	inputMessage["infno"] = "3502"                      // 交易编码
+	inputData["med_list_codg"] = struct3502.MedListCodg // 定点医药机构目录编号
+	inputData["inv_chg_type"] = struct3502.InvChgType   // 定点医药机构目录编号
+
+	inputData["fixmedins_hilist_id"] = struct3502.FixmedinsCode // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3502.OrgName     // 定点医药机构目录名称
+	inputData["fixmedins_bchno"] = struct3502.FixmedinsBchno    // 人员编号 （来自1101接口返回）
+	inputData["pric"] = struct3502.Pric                         // 人员编号 （来自1101接口返回）
+	inputData["cnt"] = struct3502.Cnt                           // 人员编号 （来自1101接口返回）
+	inputData["rx_flag"] = struct3502.RxFlag                    //
+
+	inputData["inv_chg_time"] = struct3502.InvChgTime // 人员编号 （来自1101接口返回）
+	inputData["inv_chg_opter_name"] = ""              // 人员编号 （来自1101接口返回）
+	inputData["memo"] = struct3502.Memo               // 人员编号 （来自1101接口返回）
+	inputData["trdn_flag"] = ""                       // 人员编号 （来自1101接口返回）
 
 	input["invinfo"] = inputData
 	inputMessage["input"] = input //交易输入
@@ -1765,220 +1764,221 @@ func Jsyb3502(med_list_codg string, rx_flag string, inv_chg_type string, cnt flo
 		fmt.Println(err.Error())
 		return err.Error(), ""
 	}
-	request_url = request_url + "3502"
-	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
+	struct3502.RequestUrl = struct3502.RequestUrl + "3502"
+	return HttpRequest(struct3502.RequestUrl, struct3502.AccessKey, struct3502.SecretKey, timestamp, string(bytesData)), string(bytesData)
+
+}
+
+func Jsyb3503(struct3503 models.Struct3503) (string, string) {
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJSInputMessage(timestamp, struct3503.OrgName, struct3503.Opter, struct3503.FixmedinsCode, struct3503.InsuplcAdmdvs, struct3503.MdtrtareaAdmvs, struct3503.Cainfo)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3503"
+	inputData["med_list_codg"] = struct3503.MedListCodg
+	inputData["fixmedins_hilist_id"] = struct3503.FixmedinsCode
+	inputData["fixmedins_hilist_name"] = struct3503.OrgName
+
+	inputData["dynt_no"] = ""
+	inputData["fixmedins_bchno"] = struct3503.FixmedinsBchno // 人员编号 （来自1101接口返回）
+
+	inputData["spler_name"] = struct3503.SplerName       // 人员编号 （来自1101接口返回）
+	inputData["spler_pmtno"] = ""                        // 人员编号 （来自1101接口返回）
+	inputData["manu_lotnum"] = struct3503.ManuLotnum     // 人员编号 （来自1101接口返回）
+	inputData["prodentp_name"] = struct3503.ProdentpName // 人员编号 （来自1101接口返回）
+	inputData["aprvno"] = struct3503.Aprvno              // 人员编号 （来自1101接口返回）
+	inputData["manu_date"] = struct3503.ManuDate         // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3503.ExpyEnd           // 人员编号 （来自1101接口返回）
+
+	inputData["finl_trns_pric"] = struct3503.FinlTrnsPric // 人员编号 （来自1101接口返回）
+	inputData["purc_retn_cnt"] = struct3503.PurcRetnCnt   // 人员编号 （来自1101接口返回）
+	inputData["purc_invo_codg"] = struct3503.PurcInvoCodg // 人员编号 （来自1101接口返回）
+	inputData["purc_invo_no"] = struct3503.PurcInvoNo     // 人员编号 （来自1101接口返回）
+
+	inputData["rx_flag"] = struct3503.RxFlag // 人员编号 （来自1101接口返回）
+
+	inputData["purc_retn_stoin_time"] = struct3503.PurcRetnStoinTime // 人员编号 （来自1101接口返回）
+	inputData["purc_retn_opter_name"] = struct3503.PurcRetnOpterName // 人员编号 （来自1101接口返回）
+	inputData["prod_geay_flag"] = ""                                 // 人员编号 （来自1101接口返回）
+	inputData["memo"] = ""                                           // 人员编号 （来自1101接口返回）
+	input["purcinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	struct3503.RequestUrl = struct3503.RequestUrl + "3503"
+	return HttpRequest(struct3503.RequestUrl, struct3503.AccessKey, struct3503.SecretKey, timestamp, string(bytesData)), string(bytesData)
 
 }
+func Jsyb3504(struct3504 models.Struct3504) (string, string) {
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJSInputMessage(timestamp, struct3504.OrgName, struct3504.Opter, struct3504.FixmedinsCode, struct3504.InsuplcAdmdvs, struct3504.MdtrtareaAdmvs, struct3504.Cainfo)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3504"                                      // 交易编码
+	inputData["med_list_codg"] = struct3504.MedListCodg                 // 定点医药机构目录编号
+	inputData["fixmedins_hilist_id"] = struct3504.FixmedinsHilistId     // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3504.FixmedinsHilistName // 定点医药机构目录名称
+	inputData["fixmedins_bchno"] = struct3504.FixmedinsBchno            // 人员编号 （来自1101接口返回）
+	inputData["spler_name"] = struct3504.SplerName                      // 人员编号 （来自1101接口返回）
+	inputData["spler_pmtno"] = ""                                       // 人员编号 （来自1101接口返回）
+
+	inputData["manu_date"] = struct3504.ManuDate                     // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3504.ExpyEnd                       // 人员编号 （来自1101接口返回）
+	inputData["finl_trns_pric"] = struct3504.FinlTrnsPric            // 人员编号 （来自1101接口返回）
+	inputData["purc_retn_cnt"] = struct3504.PurcRetnCnt              // 人员编号 （来自1101接口返回）
+	inputData["purc_invo_codg"] = struct3504.PurcInvoCodg            // 人员编号 （来自1101接口返回）
+	inputData["purc_invo_no"] = struct3504.PurcInvoNo                // 人员编号 （来自1101接口返回）
+	inputData["rx_flag"] = struct3504.RxFlag                         // 人员编号 （来自1101接口返回）
+	inputData["purc_retn_stoin_time"] = struct3504.PurcRetnStoinTime // 人员编号 （来自1101接口返回）
+	inputData["purc_retn_opter_name"] = struct3504.PurcRetnOpterName // 人员编号 （来自1101接口返回）
+	inputData["medins_prod_purc_no"] = ""                            // 人员编号 （来自1101接口返回）
+	inputData["memo"] = ""                                           // 人员编号 （来自1101接口返回）
+	input["purcinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	struct3504.RequestUrl = struct3504.RequestUrl + "3504"
+	return HttpRequest(struct3504.RequestUrl, struct3504.AccessKey, struct3504.SecretKey, timestamp, string(bytesData)), string(bytesData)
+
+}
+
+func Jsyb3505(struct3505 models.Struct3505) (string, string) {
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJSInputMessage(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 //交易输入
 
-//func Jsyb3503(med_list_codg string, spler_name string, manu_lotnum string, prodentp_name string, aprvno string, fixmedins_bchno string, inv_chg_time string, manu_date string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string, purc_retn_cnt float64, rx_flag string, purc_retn_stoin_time string, purc_retn_opter_name string) (string, string) {
-//	timestamp := time.Now().Unix()
-//	// 生成输入报文
-//	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
-//	input := make(map[string]interface{})
-//	inputData := make(map[string]interface{})
-//	inputMessage["infno"] = "3503"
-//	inputData["med_list_codg"] = med_list_codg
-//	inputData["fixmedins_hilist_id"] = fixmedins_code
-//	inputData["fixmedins_hilist_name"] = org_name
-//
-//	inputData["dynt_no"] = ""
-//	inputData["fixmedins_bchno"] = fixmedins_bchno // 人员编号 （来自1101接口返回）
-//
-//	inputData["spler_name"] = spler_name       // 人员编号 （来自1101接口返回）
-//	inputData["spler_pmtno"] = ""              // 人员编号 （来自1101接口返回）
-//	inputData["manu_lotnum"] = manu_lotnum     // 人员编号 （来自1101接口返回）
-//	inputData["prodentp_name"] = prodentp_name // 人员编号 （来自1101接口返回）
-//	inputData["aprvno"] = aprvno               // 人员编号 （来自1101接口返回）
-//	inputData["manu_date"] = manu_date         // 人员编号 （来自1101接口返回）
-//	inputData["expy_end"] = expy_end           // 人员编号 （来自1101接口返回）
-//
-//	inputData["finl_trns_pric"] = ""           // 人员编号 （来自1101接口返回）
-//	inputData["purc_retn_cnt"] = purc_retn_cnt // 人员编号 （来自1101接口返回）
-//	inputData["purc_invo_codg"] = ""           // 人员编号 （来自1101接口返回）
-//	inputData["purc_invo_no"] = ""             // 人员编号 （来自1101接口返回）
-//
-//	inputData["rx_flag"] = rx_flag // 人员编号 （来自1101接口返回）
-//
-//	inputData["purc_retn_stoin_time"] = purc_retn_stoin_time // 人员编号 （来自1101接口返回）
-//	inputData["purc_retn_opter_name"] = purc_retn_opter_name // 人员编号 （来自1101接口返回）
-//	inputData["prod_geay_flag"] = ""                         // 人员编号 （来自1101接口返回）
-//	inputData["memo"] = ""                                   // 人员编号 （来自1101接口返回）
-//	input["purcinfo"] = 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 + "3503"
-//	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
-//
-//}
-//func Jsyb3504(med_list_codg string, spler_name string, manu_lotnum string, fixmedins_bchno string, inv_chg_time string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string, manu_date string) (string, string) {
-//	timestamp := time.Now().Unix()
-//	// 生成输入报文
-//	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
-//	input := make(map[string]interface{})
-//	inputData := make(map[string]interface{})
-//	inputMessage["infno"] = "3504"                    // 交易编码
-//	inputData["med_list_codg"] = med_list_codg        // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_id"] = fixmedins_code // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_name"] = org_name     // 定点医药机构目录名称
-//	inputData["fixmedins_bchno"] = fixmedins_bchno    // 人员编号 （来自1101接口返回）
-//	inputData["spler_name"] = spler_name              // 人员编号 （来自1101接口返回）
-//	inputData["spler_pmtno"] = ""                     // 人员编号 （来自1101接口返回）
-//	inputData["manu_lotnum"] = manu_lotnum            // 人员编号 （来自1101接口返回）
-//
-//	inputData["manu_date"] = manu_date                       // 人员编号 （来自1101接口返回）
-//	inputData["expy_end"] = expy_end                         // 人员编号 （来自1101接口返回）
-//	inputData["finl_trns_pric"] = finl_trns_pric             // 人员编号 （来自1101接口返回）
-//	inputData["purc_retn_cnt"] = purc_retn_cnt               // 人员编号 （来自1101接口返回）
-//	inputData["purc_invo_codg"] = purc_invo_codg             // 人员编号 （来自1101接口返回）
-//	inputData["purc_invo_no"] = purc_invo_no                 // 人员编号 （来自1101接口返回）
-//	inputData["rx_flag"] = rx_flag                           // 人员编号 （来自1101接口返回）
-//	inputData["purc_retn_stoin_time"] = purc_retn_stoin_time // 人员编号 （来自1101接口返回）
-//	inputData["purc_retn_opter_name"] = purc_retn_opter_name // 人员编号 （来自1101接口返回）
-//	inputData["medins_prod_purc_no"] = medins_prod_purc_no   // 人员编号 （来自1101接口返回）
-//	inputData["memo"] = ""                                   // 人员编号 （来自1101接口返回）
-//	input["purcinfo"] = 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 + "3504"
-//	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
-//
-//}
-//func Jsyb3505(med_list_codg string, cnt float64, pric float64, fixmedins_bchno string, inv_chg_time string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
-//	timestamp := time.Now().Unix()
-//	// 生成输入报文
-//	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
-//	input := make(map[string]interface{})
-//	inputData := make(map[string]interface{})
-//	inputMessage["infno"] = "3505"                    // 交易编码
-//	inputData["med_list_codg"] = med_list_codg        // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_id"] = fixmedins_code // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_name"] = org_name     // 定点医药机构目录名称
-//	inputData["fixmedins_bchno"] = fixmedins_bchno    // 人员编号 （来自1101接口返回）
-//
-//	inputData["prsc_dr_cert_type"] = prsc_dr_cert_type // 人员编号 （来自1101接口返回）
-//	inputData["prsc_dr_certno"] = prsc_dr_certno       // 人员编号 （来自1101接口返回）
-//	inputData["prsc_dr_name"] = prsc_dr_name           // 人员编号 （来自1101接口返回）
-//	inputData["phar_cert_type"] = phar_cert_type       // 人员编号 （来自1101接口返回）
-//	inputData["phar_certno"] = phar_certno             // 人员编号 （来自1101接口返回）
-//
-//	inputData["spler_name"] = spler_name               // 人员编号 （来自1101接口返回）
-//	inputData["phar_prac_cert_no"] = phar_prac_cert_no // 人员编号 （来自1101接口返回）
-//	inputData["hi_feesetl_type"] = hi_feesetl_type     // 人员编号 （来自1101接口返回）
-//	inputData["setl_id"] = setl_id                     // 人员编号 （来自1101接口返回）
-//	inputData["mdtrt_sn"] = mdtrt_sn                   // 人员编号 （来自1101接口返回）
-//	inputData["psn_no"] = psn_no                       // 人员编号 （来自1101接口返回）
-//	inputData["psn_cert_type"] = psn_cert_type         // 人员编号 （来自1101接口返回）
-//	inputData["certno"] = certno                       // 人员编号 （来自1101接口返回）
-//	inputData["psn_name"] = psn_name                   // 人员编号 （来自1101接口返回）
-//	inputData["manu_lotnum"] = manu_lotnum             // 人员编号 （来自1101接口返回）
-//	inputData["manu_date"] = manu_date                 // 人员编号 （来自1101接口返回）
-//	inputData["expy_end"] = expy_end                   // 人员编号 （来自1101接口返回）
-//
-//	inputData["rx_flag"] = rx_flag     // 人员编号 （来自1101接口返回）
-//	inputData["trdn_flag"] = trdn_flag // 人员编号 （来自1101接口返回）
-//
-//	inputData["finl_trns_pric"] = finl_trns_pric // 人员编号 （来自1101接口返回）
-//	inputData["rxno"] = rxno                     // 人员编号 （来自1101接口返回）
-//	inputData["rx_circ_flag"] = rx_circ_flag     // 人员编号 （来自1101接口返回）
-//
-//	inputData["rtal_docno"] = rtal_docno // 人员编号 （来自1101接口返回）
-//	inputData["stoout_no"] = stoout_no   // 人员编号 （来自1101接口返回）
-//
-//	inputData["bchno"] = bchno            // 人员编号 （来自1101接口返回）
-//	inputData["drug_trac_codg"] = ""      // 人员编号 （来自1101接口返回）
-//	inputData["drug_prod_barc"] = ""      // 人员编号 （来自1101接口返回）
-//	inputData["shelf_posi"] = ""          // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_cnt"] = ""        // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_time"] = ""       // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_opter_name"] = "" // 人员编号 （来自1101接口返回）
-//	inputData["memo"] = ""                // 人员编号 （来自1101接口返回）
-//	input["selinfo"] = 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 + "3505"
-//	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
-//
-//}
-//func Jsyb3506(med_list_codg string, cnt float64, pric float64, fixmedins_bchno string, inv_chg_time string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
-//	timestamp := time.Now().Unix()
-//	// 生成输入报文
-//	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
-//	input := make(map[string]interface{})
-//	inputData := make(map[string]interface{})
-//	inputMessage["infno"] = "3506"                    // 交易编码
-//	inputData["med_list_codg"] = med_list_codg        // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_id"] = fixmedins_code // 定点医药机构目录编号
-//	inputData["fixmedins_hilist_name"] = org_name     // 定点医药机构目录名称
-//	inputData["fixmedins_bchno"] = fixmedins_bchno    // 人员编号 （来自1101接口返回）
-//
-//	inputData["setl_id"] = setl_id               // 人员编号 （来自1101接口返回）
-//	inputData["psn_no"] = psn_no                 // 人员编号 （来自1101接口返回）
-//	inputData["psn_cert_type"] = psn_cert_type   // 人员编号 （来自1101接口返回）
-//	inputData["certno"] = certno                 // 人员编号 （来自1101接口返回）
-//	inputData["psn_name"] = psn_name             // 人员编号 （来自1101接口返回）
-//	inputData["manu_lotnum"] = manu_lotnum       // 人员编号 （来自1101接口返回）
-//	inputData["manu_date"] = manu_date           // 人员编号 （来自1101接口返回）
-//	inputData["expy_end"] = expy_end             // 人员编号 （来自1101接口返回）
-//	inputData["rx_flag"] = rx_flag               // 人员编号 （来自1101接口返回）
-//	inputData["trdn_flag"] = trdn_flag           // 人员编号 （来自1101接口返回）
-//	inputData["finl_trns_pric"] = finl_trns_pric // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_cnt"] = ""               // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_time"] = ""              // 人员编号 （来自1101接口返回）
-//	inputData["sel_retn_opter_name"] = ""        // 人员编号 （来自1101接口返回）
-//	inputData["memo"] = ""                       // 人员编号 （来自1101接口返回）
-//	inputData["medins_prod_sel_no"] = ""         // 人员编号 （来自1101接口返回）
-//
-//	input["selinfo"] = 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 + "3506"
-//	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
-//
-//}
-//func Jsyb3507(med_list_codg string, cnt float64, pric float64, fixmedins_bchno string, inv_chg_time string, expy_end string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string, request_url string, access_key string, cainfo string) (string, string) {
-//	timestamp := time.Now().Unix()
-//	// 生成输入报文
-//	inputMessage := SetJSInputMessage(timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs, cainfo)
-//	input := make(map[string]interface{})
-//	inputData := make(map[string]interface{})
-//	inputMessage["infno"] = "3507"                 // 交易编码
-//	inputData["fixmedins_bchno"] = fixmedins_bchno // 人员编号 （来自1101接口返回）
-//	inputData["inv_data_type"] = inv_data_type     // 人员编号 （来自1101接口返回）
-//
-//	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 + "3507"
-//	return HttpRequest(request_url, access_key, secret_key, timestamp, string(bytesData)), string(bytesData)
-//
-//}
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	struct3505.RequestUrl = struct3505.RequestUrl + "3505"
+	return HttpRequest(struct3505.RequestUrl, struct3505.AccessKey, struct3505.SecretKey, timestamp, string(bytesData)), string(bytesData)
+
+}
+func Jsyb3506(struct3506 models.Struct3506) (string, string) {
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJSInputMessage(timestamp, struct3506.OrgName, struct3506.Opter, struct3506.FixmedinsCode, struct3506.InsuplcAdmdvs, struct3506.MdtrtareaAdmvs, struct3506.Cainfo)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3506"                                  // 交易编码
+	inputData["med_list_codg"] = struct3506.MedListCodg             // 定点医药机构目录编号
+	inputData["fixmedins_hilist_id"] = struct3506.FixmedinsHilistId // 定点医药机构目录编号
+	inputData["fixmedins_hilist_name"] = struct3506.OrgName         // 定点医药机构目录名称
+	inputData["fixmedins_bchno"] = struct3506.FixmedinsBchno        // 人员编号 （来自1101接口返回）
+
+	inputData["setl_id"] = struct3506.SetlId                       // 人员编号 （来自1101接口返回）
+	inputData["psn_no"] = struct3506.PsnNo                         // 人员编号 （来自1101接口返回）
+	inputData["psn_cert_type"] = struct3506.PsnCertType            // 人员编号 （来自1101接口返回）
+	inputData["certno"] = struct3506.Certno                        // 人员编号 （来自1101接口返回）
+	inputData["psn_name"] = struct3506.PsnName                     // 人员编号 （来自1101接口返回）
+	inputData["manu_lotnum"] = struct3506.ManuLotnum               // 人员编号 （来自1101接口返回）
+	inputData["manu_date"] = struct3506.ManuDate                   // 人员编号 （来自1101接口返回）
+	inputData["expy_end"] = struct3506.ExpyEnd                     // 人员编号 （来自1101接口返回）
+	inputData["rx_flag"] = struct3506.RxFlag                       // 人员编号 （来自1101接口返回）
+	inputData["trdn_flag"] = struct3506.TrdnFlag                   // 人员编号 （来自1101接口返回）
+	inputData["finl_trns_pric"] = struct3506.FinlTrnsPric          // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_cnt"] = struct3506.SelRetnCnt              // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_time"] = struct3506.SelRetnTime            // 人员编号 （来自1101接口返回）
+	inputData["sel_retn_opter_name"] = struct3506.SelRetnOpterName // 人员编号 （来自1101接口返回）
+	inputData["memo"] = ""                                         // 人员编号 （来自1101接口返回）
+	inputData["medins_prod_sel_no"] = ""                           // 人员编号 （来自1101接口返回）
+
+	input["selinfo"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	struct3506.RequestUrl = struct3506.RequestUrl + "3506"
+	return HttpRequest(struct3506.RequestUrl, struct3506.AccessKey, struct3506.SecretKey, timestamp, string(bytesData)), string(bytesData)
+
+}
+
+func Jsyb3507(struct3507 models.Struct3507) (string, string) {
+	timestamp := time.Now().Unix()
+	// 生成输入报文
+	inputMessage := SetJSInputMessage(timestamp, struct3507.OrgName, struct3507.Opter, struct3507.FixmedinsCode, struct3507.InsuplcAdmdvs, struct3507.MdtrtareaAdmvs, struct3507.Cainfo)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3507"                          // 交易编码
+	inputData["fixmedins_bchno"] = struct3507.FixmedinsCode // 人员编号 （来自1101接口返回）
+	inputData["inv_data_type"] = struct3507.InvDataType     // 人员编号 （来自1101接口返回）
+
+	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(), ""
+	}
+	struct3507.RequestUrl = struct3507.RequestUrl + "3507"
+	return HttpRequest(struct3507.RequestUrl, struct3507.AccessKey, struct3507.SecretKey, timestamp, string(bytesData)), string(bytesData)
+
+}