11111

controllers/gdyb_controller.go

@@ -8,6 +8,7 @@ import (
 	"fmt"
 	"github.com/astaxie/beego"
 	"io/ioutil"
+	"unsafe"
 )
 
 type GdybController struct {
@@ -24,13 +25,12 @@ func GdybRegistRouters() {
 	beego.Router("/gdyb/seven", &GdybController{}, "get:PostSeven")
 	beego.Router("/gdyb/eight", &GdybController{}, "get:PostEight")
 	beego.Router("/gdyb/nine", &GdybController{}, "get:PostNine")
-
-	//beego.Router("/gdyb/tem", &GdybController{}, "get:PostTen")
+	beego.Router("/gdyb/ten", &GdybController{}, "get:PostTen")
+	beego.Router("/gdyb/eleven", &GdybController{}, "get:PostEleven")
+	beego.Router("/gdyb/twelve", &GdybController{}, "get:PostTwelve")
 
 }
 
-//provinces, _ := service.GetDistrictsByUpid(0)21
-
 type Result struct {
 	ErrMsg      interface{} `json:"err_msg"`
 	InfRefmsgid string      `json:"inf_refmsgid"`
@@ -312,12 +312,133 @@ func (c *GdybController) PostNine() {
 	})
 }
 
-//func (c *GdybController) PostTen() {
-//	fixmedins_type := c.GetString("fixmedins_type")
-//	//fixmedins_type := c.GetString("org_name")
-//
-//	result := service.Gdyb1201(fixmedins_type)
-//	c.ServeSuccessJSON(map[string]interface{}{
-//		"pre": result,
-//	})
-//}
+func (c *GdybController) PostTen() {
+	insutype := c.GetString("insutype")
+	clrType := c.GetString("clr_type")
+	setlOptins := c.GetString("setl_optins")
+	stmtBegndate := c.GetString("stmt_begndate")
+	stmtEnddate := c.GetString("stm_enddate")
+	medfeeSumamt, _ := c.GetFloat("medfee_sumamt", 0)
+	fundPaySumamt, _ := c.GetFloat("fund_pay_sumamt", 0)
+	acctPay, _ := c.GetFloat("acct_pay", 0)
+	fixmedinsSetlCnt, _ := c.GetInt64("fixmedins_setl_cnt", 0)
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+
+	baseParams := models.BaseParams{
+		SecretKey:      secret_key,
+		FixmedinsCode:  fixmedins_code,
+		InsuplcAdmdvs:  insuplc_admdvs,
+		MdtrtareaAdmvs: mdtrtarea_admvs,
+		OrgName:        org_name,
+		Doctor:         doctor,
+	}
+	businessParams := models.BusinessParams{
+		Insutype:         insutype,
+		ClrType:          clrType,
+		SetlOptins:       setlOptins,
+		StmtBegndate:     stmtBegndate,
+		StmtEnddate:      stmtEnddate,
+		MedfeeSumamt:     medfeeSumamt,
+		FundPaySumamt:    fundPaySumamt,
+		AcctPay:          acctPay,
+		FixmedinsSetlCnt: fixmedinsSetlCnt,
+	}
+
+	result := service.Gdyb3201(baseParams, businessParams)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": result,
+	})
+}
+
+func (c *GdybController) PostEleven() {
+	file_byte := c.GetString("file_byte")
+	file_name := c.GetString("file_name")
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+
+	baseParams := models.BaseParams{
+		SecretKey:      secret_key,
+		FixmedinsCode:  fixmedins_code,
+		InsuplcAdmdvs:  insuplc_admdvs,
+		MdtrtareaAdmvs: mdtrtarea_admvs,
+		OrgName:        org_name,
+		Doctor:         doctor,
+	}
+
+	x := (*[2]uintptr)(unsafe.Pointer(&file_byte))
+	h := [3]uintptr{x[0], x[1], x[1]}
+	bytes := *(*[]byte)(unsafe.Pointer(&h))
+
+	result := service.Gdyb9101(baseParams, file_name, bytes)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": result,
+	})
+}
+
+func (c *GdybController) PostTwelve() {
+	fileQuryNo := c.GetString("file_qury_no")
+	setlOptins := c.GetString("setl_optins")
+	stmtBegndate := c.GetString("stmt_begndate")
+	stmtEnddate := c.GetString("stm_enddate")
+	medfeeSumamt, _ := c.GetFloat("medfee_sumamt", 0)
+	fundPaySumamt, _ := c.GetFloat("fund_pay_sumamt", 0)
+	fixmedinsSetlCnt, _ := c.GetInt64("fixmedins_setl_cnt", 0)
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+	cashPayamt, _ := c.GetFloat("cash_payamt", 0)
+
+	baseParams := models.BaseParams{
+		SecretKey:      secret_key,
+		FixmedinsCode:  fixmedins_code,
+		InsuplcAdmdvs:  insuplc_admdvs,
+		MdtrtareaAdmvs: mdtrtarea_admvs,
+		OrgName:        org_name,
+		Doctor:         doctor,
+	}
+	businessParams := models.BusinessParams{
+		FileQuryNo:       fileQuryNo,
+		SetlOptins:       setlOptins,
+		StmtBegndate:     stmtBegndate,
+		StmtEnddate:      stmtEnddate,
+		MedfeeSumamt:     medfeeSumamt,
+		FundPaySumamt:    fundPaySumamt,
+		FixmedinsSetlCnt: fixmedinsSetlCnt,
+		CashPayamt:       cashPayamt,
+	}
+
+	result := service.Gdyb3202(baseParams, businessParams)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": result,
+	})
+}

controllers/his_api_controller.go

@@ -5,14 +5,19 @@ import (
 	"XT_New/models"
 	"XT_New/service"
 	"XT_New/utils"
+	"archive/zip"
 	"bytes"
 	"encoding/json"
 	"fmt"
 	"github.com/astaxie/beego"
 	"github.com/jinzhu/gorm"
+	"github.com/shopspring/decimal"
+	"io"
 	"io/ioutil"
 	"math/rand"
 	"net/http"
+	"os"
+	"path/filepath"
 	"reflect"
 	"strconv"
 	"strings"
@@ -51,6 +56,9 @@ func HisManagerApiRegistRouters() {
 	beego.Router("/api/register/get", &HisApiController{}, "get:GetRegisterInfo")
 	beego.Router("/api/upload/get", &HisApiController{}, "get:GetUploadInfo")
 
+	beego.Router("/api/checkaccount/get", &HisApiController{}, "get:GetCheckAccount")
+	beego.Router("/api/checkdetailaccount/get", &HisApiController{}, "get:GetCheckDetailAccount")
+
 	beego.Router("/api/refund/post", &HisApiController{}, "post:Refund")
 
 	beego.Router("/api/medicalinsurance/config", &HisApiController{}, "get:GetMedicalInsuranceConfig")
@@ -1238,6 +1246,39 @@ type ResultSeven struct {
 	Signtype    interface{} `json:"signtype"`
 	WarnMsg     interface{} `json:"warn_msg"`
 }
+
+type ResultEight struct {
+	Cainfo      string `json:"cainfo"`
+	ErrMsg      string `json:"err_msg"`
+	InfRefmsgid string `json:"inf_refmsgid"`
+	Infcode     int64  `json:"infcode"`
+	Output      struct {
+		Stmtinfo struct {
+			SetlOptins   string `json:"setl_optins"`
+			StmtRslt     string `json:"stmt_rslt"`
+			StmtRsltDscr string `json:"stmt_rslt_dscr"`
+		} `json:"stmtinfo"`
+	} `json:"output"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Signtype    interface{} `json:"signtype"`
+	WarnMsg     interface{} `json:"warn_msg"`
+}
+
+type ResultNine struct {
+	Cainfo      string `json:"cainfo"`
+	ErrMsg      string `json:"err_msg"`
+	InfRefmsgid string `json:"inf_refmsgid"`
+	Infcode     int64  `json:"infcode"`
+	Output      struct {
+		FileQuryNo string `json:"file_qury_no"`
+	} `json:"output"`
+	RefmsgTime  string      `json:"refmsg_time"`
+	RespondTime string      `json:"respond_time"`
+	Signtype    interface{} `json:"signtype"`
+	WarnMsg     interface{} `json:"warn_msg"`
+}
+
 type Custom struct {
 	DetItemFeeSumamt string
 	Cut              string
@@ -1650,6 +1691,7 @@ func (c *HisApiController) GetUploadInfo() {
 				FoundPrice:            found_price,
 				MedicalInsurancePrice: medical_insurance_price,
 				PrivatePrice:          private_price,
+				IsMedicineInsurance:   1,
 			}
 			err = service.CreateOrder(order)
 			if err != nil {
@@ -2021,10 +2063,10 @@ func (c *HisApiController) Refund() {
 	recordDateTime := theTime.Unix()
 
 	his, _ := service.GetVMHisPatientInfo(adminUser.CurrentOrgId, patient_id, recordDateTime)
-	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
 	patientPrescription, _ := service.FindPatientPrescriptionInfo(adminUser.CurrentOrgId, patient_id, recordDateTime)
 	order, _ := service.GetHisOrderByID(order_id)
 
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
 	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
 	if config.IsOpen == 1 { //对接了医保，走医保流程
 		api := "http://127.0.0.1:9531/" + "gdyb/nine?psn_no=" + his.PsnNo +
@@ -2095,6 +2137,228 @@ func (c *HisApiController) Refund() {
 	}
 }
 
+func (c *HisApiController) GetCheckAccount() {
+	start_time := c.GetString("start_time")
+	end_time := c.GetString("end_time")
+	insutype := c.GetString("insutype")
+	clr_type := c.GetString("clr_type")
+
+	adminUser := c.GetAdminUserInfo()
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+	orders, _ := service.GetOrderByTime(startime.Unix(), endtime.Unix(), adminUser.CurrentOrgId, insutype, clr_type)
+
+	decimal.DivisionPrecision = 2
+	var medfee_sumamt float64
+	var acct_pay float64
+	var fund_pay_sumamt float64
+	fixmedins_setl_cnt := int64(len(orders))
+
+	for _, item := range orders {
+		medfee_sumamt, _ = decimal.NewFromFloat(medfee_sumamt).Add(decimal.NewFromFloat(item.MedfeeSumamt)).Float64()
+		acct_pay, _ = decimal.NewFromFloat(acct_pay).Add(decimal.NewFromFloat(item.AcctPay)).Float64()
+		fund_pay_sumamt, _ = decimal.NewFromFloat(fund_pay_sumamt).Add(decimal.NewFromFloat(item.FundPaySumamt)).Float64()
+	}
+
+	if config.IsOpen == 1 {
+		api := "http://127.0.0.1:9532/" + "gdyb/ten?insutype=" + insutype +
+			"&clr_type=" + clr_type +
+			"&setl_optins=" + miConfig.OrgName +
+			"&stmt_begndate=" + start_time +
+			"&stm_enddate=" + end_time +
+			"&medfee_sumamt=" + fmt.Sprintf("%2f", medfee_sumamt) +
+			"&fund_pay_sumamt=" + fmt.Sprintf("%2f", fund_pay_sumamt) +
+			"&acct_pay=" + fmt.Sprintf("%2f", acct_pay) +
+			"&fixmedins_setl_cnt=" + strconv.FormatInt(fixmedins_setl_cnt, 10) +
+			"&fixmedins_code=" + miConfig.Code +
+			"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs +
+			"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
+			"&secret_key=" + miConfig.SecretKey +
+			"&org_name=" + miConfig.OrgName +
+			"&doctor="
+
+		resp, requestErr := http.Get(api)
+		if requestErr != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		body, ioErr := ioutil.ReadAll(resp.Body)
+		if ioErr != nil {
+			utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		var respJSON map[string]interface{}
+		if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+			utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+		userJSONBytes, _ := json.Marshal(respJSON)
+
+		var res ResultEight
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		if res.Infcode == 0 {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"stmt_rslt":      res.Output.Stmtinfo.StmtRslt,
+				"stmt_rslt_dscr": res.Output.Stmtinfo.StmtRsltDscr,
+			})
+		} else {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		}
+	}
+}
+func (c *HisApiController) GetCheckDetailAccount() {
+	start_time := c.GetString("start_time")
+	end_time := c.GetString("end_time")
+
+	adminUser := c.GetAdminUserInfo()
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+	orders, _ := service.GetOrderByTimeTwo(startime.Unix(), endtime.Unix(), adminUser.CurrentOrgId)
+
+	Mkdir(miConfig.OrgName)
+	file := strconv.FormatInt(adminUser.CurrentOrgId, 10) + strconv.FormatInt(time.Now().Unix(), 10)
+	file_name := file + ".txt"
+	zip_name := file + ".zip"
+	zip_path := miConfig.OrgName + "/" + zip_name
+	file_path := miConfig.OrgName + "/" + file_name
+
+	decimal.DivisionPrecision = 2
+	var medfee_sumamt float64
+	var psn_cash_pay float64
+	var fund_pay_sumamt float64
+	fixmedins_setl_cnt := int64(len(orders))
+
+	for _, item := range orders {
+		medfee_sumamt, _ = decimal.NewFromFloat(medfee_sumamt).Add(decimal.NewFromFloat(item.MedfeeSumamt)).Float64()
+		psn_cash_pay, _ = decimal.NewFromFloat(psn_cash_pay).Add(decimal.NewFromFloat(item.PsnCashPay)).Float64()
+		fund_pay_sumamt, _ = decimal.NewFromFloat(fund_pay_sumamt).Add(decimal.NewFromFloat(item.FundPaySumamt)).Float64()
+	}
+
+	f, err := os.Create(miConfig.OrgName + "/" + file_name)
+	defer f.Close()
+	if err != nil {
+		fmt.Println(err.Error())
+	} else {
+		for _, item := range orders {
+			var refd_setl_flag string
+			if item.OrderStatus == 2 {
+				refd_setl_flag = "0"
+			}
+			if item.OrderStatus == 3 {
+				refd_setl_flag = "1"
+			}
+			var str string
+			str = item.SetlId + "	" +
+				item.MdtrtId + "	" +
+				item.PsnNo + "	" +
+				fmt.Sprintf("%2f", item.MedfeeSumamt) + "	" +
+				fmt.Sprintf("%2f", item.FundPaySumamt) + "	" +
+				fmt.Sprintf("%2f", item.AcctPay) + "	" + refd_setl_flag + "\n"
+			_, err = f.Write([]byte(str))
+		}
+
+	}
+	Zip(file_path, zip_path)
+	if config.IsOpen == 1 {
+		api := "http://127.0.0.1:9532/" + "gdyb/eleven?" +
+			"file_byte=" + string(ReadFile(zip_path)) +
+			"&file_name=" + zip_name +
+			"&fixmedins_code=" + miConfig.Code +
+			"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs +
+			"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
+			"&secret_key=" + miConfig.SecretKey +
+			"&org_name=" + miConfig.OrgName +
+			"&doctor="
+
+		resp, requestErr := http.Get(api)
+		if requestErr != nil {
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		body, ioErr := ioutil.ReadAll(resp.Body)
+		if ioErr != nil {
+			utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		var respJSON map[string]interface{}
+		if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+			utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+		userJSONBytes, _ := json.Marshal(respJSON)
+
+		var res ResultNine
+		if err := json.Unmarshal(userJSONBytes, &res); err != nil {
+			utils.ErrorLog("解析失败：%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		if res.Infcode == 0 {
+
+			api := "http://127.0.0.1:9532/" + "gdyb/twelve?" +
+				"file_qury_no=" + res.Output.FileQuryNo +
+				"&setl_optins=" + miConfig.OrgName +
+				"&stmt_begndate=" + start_time +
+				"&stm_enddate=" + end_time +
+				"&medfee_sumamt=" + fmt.Sprintf("%2f", medfee_sumamt) +
+				"&fund_pay_sumamt=" + fmt.Sprintf("%2f", fund_pay_sumamt) +
+				"&cash_payamt=" + fmt.Sprintf("%2f", psn_cash_pay) +
+				"&fixmedins_setl_cnt=" + strconv.FormatInt(fixmedins_setl_cnt, 10) +
+				"&fixmedins_code=" + miConfig.Code +
+				"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs +
+				"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
+				"&secret_key=" + miConfig.SecretKey +
+				"&org_name=" + miConfig.OrgName +
+				"&doctor="
+
+			resp, requestErr := http.Get(api)
+			if requestErr != nil {
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+			body, ioErr := ioutil.ReadAll(resp.Body)
+			if ioErr != nil {
+				utils.ErrorLog("接口返回数据读取失败: %v", ioErr)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+			var respJSON map[string]interface{}
+			if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+				utils.ErrorLog("接口返回数据解析JSON失败: %v", err)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+			respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{})
+			userJSONBytes, _ := json.Marshal(respJSON)
+			fmt.Println(respJSON)
+			fmt.Println(userJSONBytes)
+
+		} else {
+
+		}
+	}
+}
+
 func (this *HisApiController) AdditionalCharge() {
 
 	dataBody := make(map[string]interface{}, 0)
@@ -2229,3 +2493,100 @@ func (this *DialysisApiController) GetCallHisPrescription() {
 		return
 	}
 }
+
+func PathExists(path string) (bool, error) {
+	_, err := os.Stat(path)
+	if err == nil {
+		return true, nil
+	}
+	if os.IsNotExist(err) {
+		return false, nil
+	}
+	return false, err
+}
+
+//创建文件夹
+func Mkdir(dir string) {
+	// 创建文件夹
+	exist, err := PathExists(dir)
+	if err != nil {
+		fmt.Println(err.Error())
+	} else {
+		if exist {
+			fmt.Println(dir + "文件夹已存在！")
+		} else {
+			// 文件夹名称，权限
+			err := os.Mkdir(dir, os.ModePerm)
+			if err != nil {
+				fmt.Println(dir+"文件夹创建失败：", err.Error())
+			} else {
+				fmt.Println(dir + "文件夹创建成功！")
+			}
+		}
+	}
+}
+
+//压缩文件
+func Zip(srcFile string, destZip string) error {
+	zipfile, err := os.Create(destZip)
+	if err != nil {
+		return err
+	}
+	defer zipfile.Close()
+
+	archive := zip.NewWriter(zipfile)
+	defer archive.Close()
+
+	filepath.Walk(srcFile, func(path string, info os.FileInfo, err error) error {
+		if err != nil {
+			return err
+		}
+
+		header, err := zip.FileInfoHeader(info)
+		if err != nil {
+			return err
+		}
+
+		header.Name = strings.TrimPrefix(path, filepath.Dir(srcFile)+"/")
+		// header.Name = path
+		if info.IsDir() {
+			header.Name += "/"
+		} else {
+			header.Method = zip.Deflate
+		}
+
+		writer, err := archive.CreateHeader(header)
+		if err != nil {
+			return err
+		}
+
+		if !info.IsDir() {
+			file, err := os.Open(path)
+			if err != nil {
+				return err
+			}
+			defer file.Close()
+			_, err = io.Copy(writer, file)
+		}
+		return err
+	})
+
+	return err
+}
+
+func ReadFile(filePath string) []byte {
+	f, err := os.Open(filePath)
+	if err != nil {
+		fmt.Println("read file fail", err)
+		return nil
+	}
+	defer f.Close()
+
+	fd, err := ioutil.ReadAll(f)
+	if err != nil {
+		fmt.Println("read to fd fail", err)
+		return nil
+	}
+
+	return fd
+}

models/his_models.go

@@ -579,74 +579,74 @@ func (XtHisPatient) TableName() string {
 }
 
 type HisOrder struct {
-	ID                 int64     `gorm:"column:id" json:"id" form:"id"`
-	UserOrgId          int64     `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
-	HisPatientId       int64     `gorm:"column:his_patient_id" json:"his_patient_id" form:"his_patient_id"`
-	SettleAccountsDate int64     `gorm:"column:settle_accounts_date" json:"settle_accounts_date" form:"settle_accounts_date"`
-	Ctime              int64     `gorm:"column:ctime" json:"ctime" form:"ctime"`
-	Mtime              int64     `gorm:"column:mtime" json:"mtime" form:"mtime"`
-	Status             int64     `gorm:"column:status" json:"status" form:"status"`
-	Number             string    `gorm:"column:number" json:"number" form:"number"`
-	PatientId          int64     `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	Infcode            int64     `gorm:"column:infcode" json:"infcode" form:"infcode"`
-	WarnMsg            string    `gorm:"column:warn_msg" json:"warn_msg" form:"warn_msg"`
-	Cainfo             string    `gorm:"column:cainfo" json:"cainfo" form:"cainfo"`
-	ErrMsg             string    `gorm:"column:err_msg" json:"err_msg" form:"err_msg"`
-	RespondTime        string    `gorm:"column:respond_time" json:"respond_time" form:"respond_time"`
-	InfRefmsgid        string    `gorm:"column:inf_refmsgid" json:"inf_refmsgid" form:"inf_refmsgid"`
-	OrderStatus        int64     `gorm:"column:order_status" json:"order_status" form:"order_status"`
-	MdtrtId            string    `gorm:"column:mdtrt_id" json:"mdtrt_id" form:"mdtrt_id"`
-	SetlId             string    `gorm:"column:setl_id" json:"setl_id" form:"setl_id"`
-	PsnNo              string    `gorm:"column:psn_no" json:"psn_no" form:"psn_no"`
-	PsnName            string    `gorm:"column:psn_name" json:"psn_name" form:"psn_name"`
-	PsnCertType        string    `gorm:"column:psn_cert_type" json:"psn_cert_type" form:"psn_cert_type"`
-	Certno             string    `gorm:"column:certno" json:"certno" form:"certno"`
-	Gend               string    `gorm:"column:gend" json:"gend" form:"gend"`
-	Naty               string    `gorm:"column:naty" json:"naty" form:"naty"`
-	Brdy               time.Time `gorm:"column:brdy" json:"brdy" form:"brdy"`
-	Age                float64   `gorm:"column:age" json:"age" form:"age"`
-	Insutype           string    `gorm:"column:insutype" json:"insutype" form:"insutype"`
-	PsnType            string    `gorm:"column:psn_type" json:"psn_type" form:"psn_type"`
-	CvlservFlag        string    `gorm:"column:cvlserv_flag" json:"cvlserv_flag" form:"cvlserv_flag"`
-	SetlTime           string    `gorm:"column:setl_time" json:"setl_time" form:"setl_time"`
-	MdtrtCertType      string    `gorm:"column:mdtrt_cert_type" json:"mdtrt_cert_type" form:"mdtrt_cert_type"`
-	MedType            string    `gorm:"column:med_type" json:"med_type" form:"med_type"`
-	MedfeeSumamt       float64   `gorm:"column:medfee_sumamt" json:"medfee_sumamt" form:"medfee_sumamt"`
-	FulamtOwnpayAmt    float64   `gorm:"column:fulamt_ownpay_amt" json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
-	OverlmtSelfPay     float64   `gorm:"column:overlmt_self_pay" json:"overlmt_self_pay" form:"overlmt_self_pay"`
-	PreselfpayAmt      float64   `gorm:"column:preselfpay_amt" json:"preselfpay_amt" form:"preselfpay_amt"`
-	InscpScpAmt        float64   `gorm:"column:inscp_scp_amt" json:"inscp_scp_amt" form:"inscp_scp_amt"`
-	ActPayDedc         float64   `gorm:"column:act_pay_dedc" json:"act_pay_dedc" form:"act_pay_dedc"`
-	HifpPay            float64   `gorm:"column:hifp_pay" json:"hifp_pay" form:"hifp_pay"`
-	CvlservPay         float64   `gorm:"column:cvlserv_pay" json:"cvlserv_pay" form:"cvlserv_pay"`
-	PoolPropSelfpay    float64   `gorm:"column:pool_prop_selfpay" json:"pool_prop_selfpay" form:"pool_prop_selfpay"`
-	HifesPay           float64   `gorm:"column:hifes_pay" json:"hifes_pay" form:"hifes_pay"`
-	HifmiPay           float64   `gorm:"column:hifmi_pay" json:"hifmi_pay" form:"hifmi_pay"`
-	HifobPay           float64   `gorm:"column:hifob_pay" json:"hifob_pay" form:"hifob_pay"`
-	MafPay             float64   `gorm:"column:maf_pay" json:"maf_pay" form:"maf_pay"`
-	OthPay             float64   `gorm:"column:oth_pay" json:"oth_pay" form:"oth_pay"`
-	FundPaySumamt      float64   `gorm:"column:fund_pay_sumamt" json:"fund_pay_sumamt" form:"fund_pay_sumamt"`
-	PsnPartAmt         float64   `gorm:"column:psn_part_amt" json:"psn_part_amt" form:"psn_part_amt"`
-	AcctPay            float64   `gorm:"column:acct_pay" json:"acct_pay" form:"acct_pay"`
-	PsnCashPay         float64   `gorm:"column:psn_cash_pay" json:"psn_cash_pay" form:"psn_cash_pay"`
-	HospPartAmt        float64   `gorm:"column:hosp_part_amt" json:"hosp_part_amt" form:"hosp_part_amt"`
-	Balc               float64   `gorm:"column:balc" json:"balc" form:"balc"`
-	AcctMulaidPay      float64   `gorm:"column:acct_mulaid_pay" json:"acct_mulaid_pay" form:"acct_mulaid_pay"`
-	MedinsSetlId       string    `gorm:"column:medins_setl_id" json:"medins_setl_id" form:"medins_setl_id"`
-	ClrOptins          string    `gorm:"column:clr_optins" json:"clr_optins" form:"clr_optins"`
-	ClrWay             string    `gorm:"column:clr_way" json:"clr_way" form:"clr_way"`
-	ClrType            string    `gorm:"column:clr_type" json:"clr_type" form:"clr_type"`
-	SetlDetail         string    `gorm:"column:setl_detail" json:"setl_detail" form:"setl_detail"`
-
-	PayWay                int64   `gorm:"column:pay_way" json:"pay_way" form:"pay_way"`
-	PayPrice              float64 `gorm:"column:pay_price" json:"pay_price" form:"pay_price"`
-	PayCardNo             string  `gorm:"column:pay_card_no" json:"pay_card_no" form:"pay_card_no"`
-	DiscountPrice         float64 `gorm:"column:discount_price" json:"discount_price" form:"discount_price"`
-	PreferentialPrice     float64 `gorm:"column:preferential_price" json:"preferential_price" form:"preferential_price"`
-	RealityPrice          float64 `gorm:"column:reality_price" json:"reality_price" form:"reality_price"`
-	FoundPrice            float64 `gorm:"column:found_price" json:"found_price" form:"found_price"`
-	MedicalInsurancePrice float64 `gorm:"column:medical_insurance_price" json:"medical_insurance_price" form:"medical_insurance_price"`
-	PrivatePrice          float64 `gorm:"column:private_price" json:"private_price" form:"private_price"`
+	ID                    int64     `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId             int64     `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	HisPatientId          int64     `gorm:"column:his_patient_id" json:"his_patient_id" form:"his_patient_id"`
+	SettleAccountsDate    int64     `gorm:"column:settle_accounts_date" json:"settle_accounts_date" form:"settle_accounts_date"`
+	Ctime                 int64     `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime                 int64     `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Status                int64     `gorm:"column:status" json:"status" form:"status"`
+	Number                string    `gorm:"column:number" json:"number" form:"number"`
+	PatientId             int64     `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Infcode               int64     `gorm:"column:infcode" json:"infcode" form:"infcode"`
+	WarnMsg               string    `gorm:"column:warn_msg" json:"warn_msg" form:"warn_msg"`
+	Cainfo                string    `gorm:"column:cainfo" json:"cainfo" form:"cainfo"`
+	ErrMsg                string    `gorm:"column:err_msg" json:"err_msg" form:"err_msg"`
+	RespondTime           string    `gorm:"column:respond_time" json:"respond_time" form:"respond_time"`
+	InfRefmsgid           string    `gorm:"column:inf_refmsgid" json:"inf_refmsgid" form:"inf_refmsgid"`
+	OrderStatus           int64     `gorm:"column:order_status" json:"order_status" form:"order_status"`
+	MdtrtId               string    `gorm:"column:mdtrt_id" json:"mdtrt_id" form:"mdtrt_id"`
+	SetlId                string    `gorm:"column:setl_id" json:"setl_id" form:"setl_id"`
+	PsnNo                 string    `gorm:"column:psn_no" json:"psn_no" form:"psn_no"`
+	PsnName               string    `gorm:"column:psn_name" json:"psn_name" form:"psn_name"`
+	PsnCertType           string    `gorm:"column:psn_cert_type" json:"psn_cert_type" form:"psn_cert_type"`
+	Certno                string    `gorm:"column:certno" json:"certno" form:"certno"`
+	Gend                  string    `gorm:"column:gend" json:"gend" form:"gend"`
+	Naty                  string    `gorm:"column:naty" json:"naty" form:"naty"`
+	Brdy                  time.Time `gorm:"column:brdy" json:"brdy" form:"brdy"`
+	Age                   float64   `gorm:"column:age" json:"age" form:"age"`
+	Insutype              string    `gorm:"column:insutype" json:"insutype" form:"insutype"`
+	PsnType               string    `gorm:"column:psn_type" json:"psn_type" form:"psn_type"`
+	CvlservFlag           string    `gorm:"column:cvlserv_flag" json:"cvlserv_flag" form:"cvlserv_flag"`
+	SetlTime              string    `gorm:"column:setl_time" json:"setl_time" form:"setl_time"`
+	MdtrtCertType         string    `gorm:"column:mdtrt_cert_type" json:"mdtrt_cert_type" form:"mdtrt_cert_type"`
+	MedType               string    `gorm:"column:med_type" json:"med_type" form:"med_type"`
+	MedfeeSumamt          float64   `gorm:"column:medfee_sumamt" json:"medfee_sumamt" form:"medfee_sumamt"`
+	FulamtOwnpayAmt       float64   `gorm:"column:fulamt_ownpay_amt" json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
+	OverlmtSelfPay        float64   `gorm:"column:overlmt_self_pay" json:"overlmt_self_pay" form:"overlmt_self_pay"`
+	PreselfpayAmt         float64   `gorm:"column:preselfpay_amt" json:"preselfpay_amt" form:"preselfpay_amt"`
+	InscpScpAmt           float64   `gorm:"column:inscp_scp_amt" json:"inscp_scp_amt" form:"inscp_scp_amt"`
+	ActPayDedc            float64   `gorm:"column:act_pay_dedc" json:"act_pay_dedc" form:"act_pay_dedc"`
+	HifpPay               float64   `gorm:"column:hifp_pay" json:"hifp_pay" form:"hifp_pay"`
+	CvlservPay            float64   `gorm:"column:cvlserv_pay" json:"cvlserv_pay" form:"cvlserv_pay"`
+	PoolPropSelfpay       float64   `gorm:"column:pool_prop_selfpay" json:"pool_prop_selfpay" form:"pool_prop_selfpay"`
+	HifesPay              float64   `gorm:"column:hifes_pay" json:"hifes_pay" form:"hifes_pay"`
+	HifmiPay              float64   `gorm:"column:hifmi_pay" json:"hifmi_pay" form:"hifmi_pay"`
+	HifobPay              float64   `gorm:"column:hifob_pay" json:"hifob_pay" form:"hifob_pay"`
+	MafPay                float64   `gorm:"column:maf_pay" json:"maf_pay" form:"maf_pay"`
+	OthPay                float64   `gorm:"column:oth_pay" json:"oth_pay" form:"oth_pay"`
+	FundPaySumamt         float64   `gorm:"column:fund_pay_sumamt" json:"fund_pay_sumamt" form:"fund_pay_sumamt"`
+	PsnPartAmt            float64   `gorm:"column:psn_part_amt" json:"psn_part_amt" form:"psn_part_amt"`
+	AcctPay               float64   `gorm:"column:acct_pay" json:"acct_pay" form:"acct_pay"`
+	PsnCashPay            float64   `gorm:"column:psn_cash_pay" json:"psn_cash_pay" form:"psn_cash_pay"`
+	HospPartAmt           float64   `gorm:"column:hosp_part_amt" json:"hosp_part_amt" form:"hosp_part_amt"`
+	Balc                  float64   `gorm:"column:balc" json:"balc" form:"balc"`
+	AcctMulaidPay         float64   `gorm:"column:acct_mulaid_pay" json:"acct_mulaid_pay" form:"acct_mulaid_pay"`
+	MedinsSetlId          string    `gorm:"column:medins_setl_id" json:"medins_setl_id" form:"medins_setl_id"`
+	ClrOptins             string    `gorm:"column:clr_optins" json:"clr_optins" form:"clr_optins"`
+	ClrWay                string    `gorm:"column:clr_way" json:"clr_way" form:"clr_way"`
+	ClrType               string    `gorm:"column:clr_type" json:"clr_type" form:"clr_type"`
+	SetlDetail            string    `gorm:"column:setl_detail" json:"setl_detail" form:"setl_detail"`
+	IsMedicineInsurance   int64     `gorm:"column:is_medicine_insurance" json:"is_medicine_insurance" form:"is_medicine_insurance"`
+	PayWay                int64     `gorm:"column:pay_way" json:"pay_way" form:"pay_way"`
+	PayPrice              float64   `gorm:"column:pay_price" json:"pay_price" form:"pay_price"`
+	PayCardNo             string    `gorm:"column:pay_card_no" json:"pay_card_no" form:"pay_card_no"`
+	DiscountPrice         float64   `gorm:"column:discount_price" json:"discount_price" form:"discount_price"`
+	PreferentialPrice     float64   `gorm:"column:preferential_price" json:"preferential_price" form:"preferential_price"`
+	RealityPrice          float64   `gorm:"column:reality_price" json:"reality_price" form:"reality_price"`
+	FoundPrice            float64   `gorm:"column:found_price" json:"found_price" form:"found_price"`
+	MedicalInsurancePrice float64   `gorm:"column:medical_insurance_price" json:"medical_insurance_price" form:"medical_insurance_price"`
+	PrivatePrice          float64   `gorm:"column:private_price" json:"private_price" form:"private_price"`
 
 	HisOrderInfo        HisOrderInfo        `gorm:"ForeignKey:ID;AssociationForeignKey:OrderId" json:"order_info"`
 	Patients            Patients            `gorm:"ForeignKey:PatientId;AssociationForeignKey:ID" json:"patient"`
@@ -920,3 +920,27 @@ type HisXtDiagnoseConfig struct {
 func (HisXtDiagnoseConfig) TableName() string {
 	return "his_xt_diagnose_config"
 }
+
+type BaseParams struct {
+	SecretKey      string
+	FixmedinsCode  string
+	InsuplcAdmdvs  string
+	MdtrtareaAdmvs string
+	OrgName        string
+	Doctor         string
+}
+
+type BusinessParams struct {
+	Insutype         string
+	ClrType          string
+	SetlOptins       string
+	MdtrtareaAdmvs   string
+	StmtBegndate     string
+	StmtEnddate      string
+	MedfeeSumamt     float64
+	FundPaySumamt    float64
+	AcctPay          float64
+	FixmedinsSetlCnt int64
+	FileQuryNo       string
+	CashPayamt       float64
+}

service/gdyb_service.go

@@ -32,7 +32,7 @@ func Gdyb1101(certNo string, org_name string, doctor string, fixmedins_code stri
 	inputData := make(map[string]interface{})
 	inputMessage["infno"] = "1101"      // 交易编码
 	inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
-	inputData["mdtrt_cert_no"] = ""     // 就诊凭证编号
+	inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
 	inputData["card_sn"] = ""           // 卡识别码
 	inputData["begntime"] = ""          // 开始时间
 	inputData["psn_cert_type"] = ""     // 人员证件类型
@@ -622,7 +622,7 @@ func Gdyb2207(psnNo string, mdtrtId string, chrgBchno string, certNo string, ins
 
 	inputData["psn_no"] = psnNo         // 人员编号 （来自1101接口返回）
 	inputData["mdtrt_cert_type"] = "02" // 就诊凭证类型
-	inputData["mdtrt_cert_no"] = certNo // 就诊凭证编号
+	inputData["mdtrt_cert_no"] = ""     // 就诊凭证编号
 	inputData["med_type"] = "11"        // 医疗类别 11 普通门诊  12 门诊挂号
 	inputData["medfee_sumamt"] = total  // 医疗费总额
 	inputData["psn_setlway"] = "01"     // 个人结算方式 01 按项目结 02 按定额结算
@@ -729,22 +729,83 @@ func Gdyb2208(psnNo string, mdtrtId string, setlId string, org_name string, doct
 	return str
 }
 
-//  门诊结算撤销
-func Gdyb3201(psnNo string, mdtrtId string, setlId string, org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) string {
+//  医药机构费用结算对总账 func Gdyb3201( org_name string, doctor string, secret_key string, fixmedins_code string, insuplc_admdvs string, mdtrtarea_admvs string) string {
+func Gdyb3201(baseParams models.BaseParams, businessParams models.BusinessParams) string {
 	// 生成签名
 	nonce := GetRandomString(32)
 	timestamp := time.Now().Unix()
-	signature := setSignature(timestamp, nonce, secret_key)
+	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
 
 	// 生成输入报文
-	inputMessage := SetInputMessage(nonce, timestamp, org_name, doctor, fixmedins_code, insuplc_admdvs, mdtrtarea_admvs)
+	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
 	input := make(map[string]interface{})
 	inputData := make(map[string]interface{})
-	inputMessage["infno"] = "2208" // 交易编码
+	inputMessage["infno"] = "3201"                                    // 交易编码
+	inputData["insutype"] = businessParams.Insutype                   // 险种
+	inputData["clr_type"] = businessParams.ClrType                    // 就诊 ID（来自2201接口返回）
+	inputData["setl_optins"] = baseParams.OrgName                     // 结算经办机构
+	inputData["stmt_begndate"] = businessParams.StmtBegndate          // 对帐开始时间
+	inputData["stmt_enddate"] = businessParams.StmtEnddate            //对帐结束时间
+	inputData["medfee_sumamt"] = businessParams.StmtEnddate           //医疗费总额
+	inputData["fund_pay_sumamt"] = businessParams.StmtEnddate         //基金支付总额
+	inputData["acct_pay"] = businessParams.AcctPay                    //个人账户支付金额
+	inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt //定点医药机构结算笔数
 
-	inputData["psn_no"] = psnNo     // 人员编号 （来自1101接口返回）
-	inputData["mdtrt_id"] = mdtrtId // 就诊 ID（来自2201接口返回）
-	inputData["setl_id"] = setlId   // 结算 ID
+	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()
+	}
+	reader := bytes.NewReader(bytesData)
+
+	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3102"
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	request.Header.Set("x-tif-paasid", "test_hosp")
+	request.Header.Set("x-tif-signature", signature)
+	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+	request.Header.Set("x-tif-nonce", nonce)
+
+	client := http.Client{}
+	resp, err := client.Do(request)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	str := string(respBytes)
+	fmt.Println(str)
+	return str
+}
+
+//文件上传
+func Gdyb9101(baseParams models.BaseParams, file_name string, file_byte []byte) string {
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
+
+	// 生成输入报文
+	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["in"] = "3201"                            // 交易编码
+	inputData["file_name"] = file_name                     //文件名
+	inputData["in"] = file_byte                            //文件数据
+	inputData["fixmedins_code"] = baseParams.FixmedinsCode //编码
 
 	input["data"] = inputData
 	inputMessage["input"] = input //交易输入
@@ -757,7 +818,7 @@ func Gdyb3201(psnNo string, mdtrtId string, setlId string, org_name string, doct
 	}
 	reader := bytes.NewReader(bytesData)
 
-	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/2208"
+	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/9101"
 	request, err := http.NewRequest("POST", url, reader)
 	if err != nil {
 		fmt.Println(err.Error())
@@ -786,6 +847,63 @@ func Gdyb3201(psnNo string, mdtrtId string, setlId string, org_name string, doct
 	return str
 }
 
+func Gdyb3202(baseParams models.BaseParams, businessParams models.BusinessParams) string {
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+	signature := setSignature(timestamp, nonce, baseParams.SecretKey)
+
+	// 生成输入报文
+	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3201"                                    // 交易编码
+	inputData["file_qury_no"] = businessParams.FileQuryNo             // 险种
+	inputData["setl_optins"] = baseParams.OrgName                     // 结算经办机构
+	inputData["stmt_begndate"] = businessParams.StmtBegndate          // 对帐开始时间
+	inputData["stmt_enddate"] = businessParams.StmtEnddate            //对帐结束时间
+	inputData["medfee_sumamt"] = businessParams.StmtEnddate           //医疗费总额
+	inputData["fund_pay_sumamt"] = businessParams.StmtEnddate         //基金支付总额
+	inputData["cash_payamt"] = businessParams.CashPayamt              //现金支付金额
+	inputData["fixmedins_setl_cnt"] = businessParams.FixmedinsSetlCnt //定点医药机构结算笔数
+
+	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()
+	}
+	reader := bytes.NewReader(bytesData)
+
+	url := "http://igb.hsa.gdgov.cn/ebus/gdyb_inf/poc/hsa/hgs/3202"
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	request.Header.Set("x-tif-paasid", "test_hosp")
+	request.Header.Set("x-tif-signature", signature)
+	request.Header.Set("x-tif-timestamp", strconv.FormatInt(timestamp, 10))
+	request.Header.Set("x-tif-nonce", nonce)
+	client := http.Client{}
+	resp, err := client.Do(request)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	str := string(respBytes)
+	fmt.Println(str)
+	return str
+}
+
 //  门诊结算撤销
 //func Gdyb4101(psnNo string, mdtrtId string, setlId string) string {
 //	// 生成签名

service/his_service.go

@@ -798,3 +798,13 @@ func GetHisOrderByID(order_id int64) (order models.HisOrder, err error) {
 	err = readDb.Model(&models.HisOrder{}).Where("id = ?", order_id).First(&order).Error
 	return
 }
+
+func GetOrderByTime(start_time int64, end_time int64, org_id int64, insutype string, clr_type string) (orders []*models.HisOrder, err error) {
+	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = ? AND status = 1 AND is_medicine_insurance = 1 AND settle_accounts_date <= ? AND settle_accounts_date >= ? AND insutype = ? AND clr_type = ? ", org_id, end_time, start_time, insutype, clr_type).Find(&orders).Error
+	return
+}
+
+func GetOrderByTimeTwo(start_time int64, end_time int64, org_id int64) (orders []*models.HisOrder, err error) {
+	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = ? AND status = 1 AND is_medicine_insurance = 1 AND settle_accounts_date <= ? AND settle_accounts_date >= ? ", org_id, end_time, start_time).Find(&orders).Error
+	return
+}