package zh import ( "bytes" "encoding/json" "fmt" "gdyb/controllers" "gdyb/enums" "gdyb/models" "gdyb/service" "gdyb/utils" "github.com/astaxie/beego" "github.com/axgle/mahonia" "github.com/jinzhu/gorm" "io/ioutil" "math" "math/rand" "net/http" "os" "regexp" "strconv" "strings" "syscall" "time" "unsafe" "github.com/gorilla/websocket" "net/url" ) type ZHHisApiController struct { controllers.BaseAuthAPIController } type ResultSix struct { Cainfo interface{} `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultTwo struct { ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Baseinfo struct { Age float64 `json:"age"` Certno string `json:"certno"` Gend string `json:"gend"` //Brdy string `json:"brdy"` Naty string `json:"naty"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` } `json:"baseinfo"` Idetinfo []interface{} `json:"idetinfo"` Iinfo []struct { Balc float64 `json:"balc"` CvlservFlag string `json:"cvlserv_flag"` EmpName string `json:"emp_name"` InsuplcAdmdvs string `json:"insuplc_admdvs"` Insutype string `json:"insutype"` PausInsuDansuplcAdmdvs string `json:"paus_insu_dansuplc_admdvs"` //PausInsuDate string `json:"paus_insu_date"` //PsnInsuDate string `json:"psn_insu_date"` PsnInsuStas string `json:"psn_insu_stas"` PsnType string `json:"psn_type"` } `json:"insuinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnInfo interface{} `json:"warn_info"` } type ResultTwohb struct { ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Baseinfo struct { Age float64 `json:"age"` Certno string `json:"certno"` Gend string `json:"gend"` //Brdy string `json:"brdy"` Naty string `json:"naty"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` ExpContent ExpContent `json:"exp_content"` } `json:"baseinfo"` Idetinfo []interface{} `json:"idetinfo"` Iinfo []struct { Balc float64 `json:"balc"` CvlservFlag string `json:"cvlserv_flag"` EmpName string `json:"emp_name"` InsuplcAdmdvs string `json:"insuplc_admdvs"` Insutype string `json:"insutype"` PausInsuDansuplcAdmdvs string `json:"paus_insu_dansuplc_admdvs"` //PausInsuDate string `json:"paus_insu_date"` //PsnInsuDate string `json:"psn_insu_date"` PsnInsuStas string `json:"psn_insu_stas"` PsnType string `json:"psn_type"` } `json:"insuinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnInfo interface{} `json:"warn_info"` } type ExpContent struct { MdtrtCertType string `json:"mdtrt_cert_type"` MdtrtCertNo string `json:"mdtrt_cert_no"` } type AHResultTwo struct { ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Baseinfo struct { Age float64 `json:"age"` Certno string `json:"certno"` Gend string `json:"gend"` Naty string `json:"naty"` //Brdy string `json:"brdy"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` } `json:"baseinfo"` Idetinfo []interface{} `json:"idetinfo"` Iinfo []struct { Balc float64 `json:"balc"` CvlservFlag string `json:"cvlserv_flag"` EmpName string `json:"emp_name"` InsuplcAdmdvs string `json:"insuplc_admdvs"` Insutype string `json:"insutype"` PausInsuDansuplcAdmdvs string `json:"paus_insu_dansuplc_admdvs"` PsnInsuStas string `json:"psn_insu_stas"` PsnType string `json:"psn_type"` } `json:"insuinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnInfo interface{} `json:"warn_info"` } type ResultTwo10265 struct { ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { Baseinfo struct { Age float64 `json:"age"` Certno string `json:"certno"` Gend string `json:"gend"` //Brdy string `json:"brdy"` Naty string `json:"naty"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` } `json:"baseinfo"` Idetinfo []interface{} `json:"idetinfo"` Iinfo []struct { Balc float64 `json:"balc"` CvlservFlag string `json:"cvlserv_flag"` EmpName string `json:"emp_name"` InsuplcAdmdvs string `json:"insuplc_admdvs"` Insutype string `json:"insutype"` PausInsuDansuplcAdmdvs string `json:"paus_insu_dansuplc_admdvs"` PsnInsuStas string `json:"psn_insu_stas"` PsnType string `json:"psn_type"` } `json:"insuinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnInfo interface{} `json:"warn_info"` } type ResultThree struct { Cainfo interface{} `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Result struct { MdtrtID string `json:"mdtrt_id"` } `json:"result"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultThree10265 struct { Cainfo interface{} `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { Result struct { MdtrtID string `json:"mdtrt_id"` } `json:"result"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultFour struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Result []struct { BasMednFlag string `json:"bas_medn_flag"` ChldMedcFlag string `json:"chld_medc_flag"` ChrgitmLv string `json:"chrgitm_lv"` Cnt float64 `json:"cnt"` DetItemFeeSumamt float64 `json:"det_item_fee_sumamt"` DrtReimFlag string `json:"drt_reim_flag"` FeedetlSn string `json:"feedetl_sn"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` HiNegoDrugFlag string `json:"hi_nego_drug_flag"` InscpScpAmt float64 `json:"inscp_scp_amt"` ListSpItemFlag string `json:"list_sp_item_flag"` LmtUsedFlag string `json:"lmt_used_flag"` MedChrgitmType string `json:"med_chrgitm_type"` Memo string `json:"memo"` OverlmtAmt float64 `json:"overlmt_amt"` PreselfpayAmt float64 `json:"preselfpay_amt"` Pric float64 `json:"pric"` PricUplmtAmt float64 `json:"pric_uplmt_amt"` SelfpayProp float64 `json:"selfpay_prop"` } `json:"result"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype string `json:"signtype"` WarnMsg string `json:"warn_msg"` } type ResultFour10265 struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { Result []struct { BasMednFlag string `json:"bas_medn_flag"` ChldMedcFlag string `json:"chld_medc_flag"` ChrgitmLv string `json:"chrgitm_lv"` Cnt float64 `json:"cnt"` DetItemFeeSumamt float64 `json:"det_item_fee_sumamt"` DrtReimFlag string `json:"drt_reim_flag"` FeedetlSn string `json:"feedetl_sn"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` HiNegoDrugFlag string `json:"hi_nego_drug_flag"` InscpScpAmt float64 `json:"inscp_scp_amt"` ListSpItemFlag string `json:"list_sp_item_flag"` LmtUsedFlag string `json:"lmt_used_flag"` MedChrgitmType string `json:"med_chrgitm_type"` Memo string `json:"memo"` OverlmtAmt float64 `json:"overlmt_amt"` PreselfpayAmt float64 `json:"preselfpay_amt"` Pric float64 `json:"pric"` PricUplmtAmt float64 `json:"pric_uplmt_amt"` SelfpayProp float64 `json:"selfpay_prop"` } `json:"result"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype string `json:"signtype"` WarnMsg string `json:"warn_msg"` } type ResultFive struct { Balc float64 `json:"balc"` CvlservFlag string `json:"cvlserv_flag"` EmpName string `json:"emp_name"` InsuplcAdmdvs string `json:"insuplc_admdvs"` Insutype string `json:"insutype"` PausInsuDansuplcAdmdvs string `json:"paus_insu_dansuplc_admdvs"` PausInsuDate string `json:"paus_insu_date"` PsnInsuDate string `json:"psn_insu_date"` PsnInsuStas string `json:"psn_insu_stas"` PsnType string `json:"psn_type"` } type ResultSevenTwo struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Setldetail []interface{} `json:"setldetail"` Setlinfo struct { AcctMulaidPay float64 `json:"acct_mulaid_pay"` AcctPay float64 `json:"acct_pay"` ActPayDedc float64 `json:"act_pay_dedc"` Age string `json:"age"` Balc float64 `json:"balc"` //Brdy string `json:"brdy"` Certno string `json:"certno"` ClrOptins string `json:"clr_optins"` ClrType string `json:"clr_type"` ClrWay string `json:"clr_way"` CvlservFlag string `json:"cvlserv_flag"` CvlservPay float64 `json:"cvlserv_pay"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` FundPaySumamt float64 `json:"fund_pay_sumamt"` Gend string `json:"gend"` HifesPay float64 `json:"hifes_pay"` HifmiPay float64 `json:"hifmi_pay"` HifpPay float64 `json:"hifp_pay"` HospPartAmt float64 `json:"hosp_part_amt"` InscpScpAmt float64 `json:"inscp_scp_amt"` Insutype string `json:"insutype"` MafPay float64 `json:"maf_pay"` MdtrtCertType string `json:"mdtrt_cert_type"` HifobPay float64 `json:"hifob_pay"` MdtrtID string `json:"mdtrt_id"` MedType string `json:"med_type"` MedfeeSumamt float64 `json:"medfee_sumamt"` MedinsSetlID string `json:"medins_setl_id"` Naty string `json:"naty"` OthPay float64 `json:"oth_pay"` OverlmtSelfpay float64 `json:"overlmt_selfpay"` PoolPropSelfpay float64 `json:"pool_prop_selfpay"` PreselfpayAmt float64 `json:"preselfpay_amt"` PsnCashPay float64 `json:"psn_cash_pay"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` PsnPartAmt float64 `json:"psn_part_amt"` PsnType string `json:"psn_type"` SetlID string `json:"setl_id"` SetlTime string `json:"setl_time"` } `json:"setlinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultSeven struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Setldetail []interface{} `json:"setldetail"` Setlinfo struct { AcctMulaidPay float64 `json:"acct_mulaid_pay"` AcctPay float64 `json:"acct_pay"` ActPayDedc float64 `json:"act_pay_dedc"` Age float64 `json:"age"` Balc float64 `json:"balc"` //Brdy string `json:"brdy"` Certno string `json:"certno"` ClrOptins string `json:"clr_optins"` ClrType string `json:"clr_type"` ClrWay string `json:"clr_way"` CvlservFlag string `json:"cvlserv_flag"` CvlservPay float64 `json:"cvlserv_pay"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` FundPaySumamt float64 `json:"fund_pay_sumamt"` Gend string `json:"gend"` HifesPay float64 `json:"hifes_pay"` HifmiPay float64 `json:"hifmi_pay"` HifpPay float64 `json:"hifp_pay"` HospPartAmt float64 `json:"hosp_part_amt"` InscpScpAmt float64 `json:"inscp_scp_amt"` Insutype string `json:"insutype"` MafPay float64 `json:"maf_pay"` MdtrtCertType string `json:"mdtrt_cert_type"` HifobPay float64 `json:"hifob_pay"` MdtrtID string `json:"mdtrt_id"` MedType string `json:"med_type"` MedfeeSumamt float64 `json:"medfee_sumamt"` MedinsSetlID string `json:"medins_setl_id"` Naty string `json:"naty"` OthPay float64 `json:"oth_pay"` OverlmtSelfpay float64 `json:"overlmt_selfpay"` PoolPropSelfpay float64 `json:"pool_prop_selfpay"` PreselfpayAmt float64 `json:"preselfpay_amt"` PsnCashPay float64 `json:"psn_cash_pay"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` PsnPartAmt float64 `json:"psn_part_amt"` PsnType string `json:"psn_type"` SetlID string `json:"setl_id"` SetlTime string `json:"setl_time"` } `json:"setlinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultSeven10265 struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { Setldetail []interface{} `json:"setldetail"` Setlinfo struct { AcctMulaidPay float64 `json:"acct_mulaid_pay"` AcctPay float64 `json:"acct_pay"` ActPayDedc float64 `json:"act_pay_dedc"` Age float64 `json:"age"` Balc float64 `json:"balc"` //Brdy string `json:"brdy"` Certno string `json:"certno"` ClrOptins string `json:"clr_optins"` ClrType string `json:"clr_type"` ClrWay string `json:"clr_way"` CvlservFlag string `json:"cvlserv_flag"` CvlservPay float64 `json:"cvlserv_pay"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` FundPaySumamt float64 `json:"fund_pay_sumamt"` Gend string `json:"gend"` HifesPay float64 `json:"hifes_pay"` HifmiPay float64 `json:"hifmi_pay"` HifpPay float64 `json:"hifp_pay"` HospPartAmt float64 `json:"hosp_part_amt"` InscpScpAmt float64 `json:"inscp_scp_amt"` Insutype string `json:"insutype"` MafPay float64 `json:"maf_pay"` MdtrtCertType string `json:"mdtrt_cert_type"` HifobPay float64 `json:"hifob_pay"` MdtrtID string `json:"mdtrt_id"` MedType string `json:"med_type"` MedfeeSumamt float64 `json:"medfee_sumamt"` MedinsSetlID string `json:"medins_setl_id"` Naty string `json:"naty"` OthPay float64 `json:"oth_pay"` OverlmtSelfpay float64 `json:"overlmt_selfpay"` PoolPropSelfpay float64 `json:"pool_prop_selfpay"` PreselfpayAmt float64 `json:"preselfpay_amt"` PsnCashPay float64 `json:"psn_cash_pay"` PsnCertType string `json:"psn_cert_type"` PsnName string `json:"psn_name"` PsnNo string `json:"psn_no"` PsnPartAmt float64 `json:"psn_part_amt"` PsnType string `json:"psn_type"` SetlID string `json:"setl_id"` SetlTime string `json:"setl_time"` } `json:"setlinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultSixteen struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { Setldetail []interface{} `json:"setldetail"` Setlinfo struct { MdtrtID string `json:"mdtrt_id"` SetlID string `json:"setl_id"` ClrOptins string `json:"clr_optins"` SetlTime string `json:"setl_time"` MedfeeSumamt float64 `json:"medfee_sumamt"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` OverlmtSelfpay float64 `json:"overlmt_selfpay"` PreselfpayAmt float64 `json:"preselfpay_amt"` InscpScpAmt float64 `json:"inscp_scp_amt"` ActPayDedc float64 `json:"act_pay_dedc"` HifpPay float64 `json:"hifp_pay"` PoolPropSe float64 `json:"pool_prop_selfpay"` Lfpay float64 `json:"selfpay"` CvlservPay float64 `json:"cvlserv_pay"` HifesPay float64 `json:"hifes_pay"` HifmiPay float64 `json:"hifmi_pay"` HifobPay float64 `json:"hifob_pay"` MafPay float64 `json:"maf_pay"` OthPay float64 `json:"oth_pay"` FundPaySumamt float64 `json:"fund_pay_sumamt"` PsnPartAmt float64 `json:"psn_part_amt"` AcctPay float64 `json:"acct_pay"` Balc float64 `json:"balc"` AcctMulaidPay float64 `json:"acct_mulaid_pay"` HospPartAmt float64 `json:"hosp_part_amt"` MedinsSetlID string `json:"medins_setl_id"` PdnCashPay string `json:"pdn_cash_pay"` } `json:"setlinfo"` } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultSixteen10265 struct { Cainfo string `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { Setldetail []interface{} `json:"setldetail"` Setlinfo struct { MdtrtID string `json:"mdtrt_id"` SetlID string `json:"setl_id"` ClrOptins string `json:"clr_optins"` SetlTime string `json:"setl_time"` MedfeeSumamt float64 `json:"medfee_sumamt"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` OverlmtSelfpay float64 `json:"overlmt_selfpay"` PreselfpayAmt float64 `json:"preselfpay_amt"` InscpScpAmt float64 `json:"inscp_scp_amt"` ActPayDedc float64 `json:"act_pay_dedc"` HifpPay float64 `json:"hifp_pay"` PoolPropSe float64 `json:"pool_prop_selfpay"` Lfpay float64 `json:"selfpay"` CvlservPay float64 `json:"cvlserv_pay"` HifesPay float64 `json:"hifes_pay"` HifmiPay float64 `json:"hifmi_pay"` HifobPay float64 `json:"hifob_pay"` MafPay float64 `json:"maf_pay"` OthPay float64 `json:"oth_pay"` FundPaySumamt float64 `json:"fund_pay_sumamt"` PsnPartAmt float64 `json:"psn_part_amt"` AcctPay float64 `json:"acct_pay"` Balc float64 `json:"balc"` AcctMulaidPay float64 `json:"acct_mulaid_pay"` HospPartAmt float64 `json:"hosp_part_amt"` MedinsSetlID string `json:"medins_setl_id"` PdnCashPay string `json:"pdn_cash_pay"` } `json:"setlinfo"` } `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 FeedetlSn string Price string MedListCodg string Type int64 AdviceId int64 ProjectId int64 ItemId int64 } type ResultEmpty struct { Cainfo interface{} `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode int64 `json:"infcode"` Output struct { } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type ResultEmpty10265 struct { Cainfo interface{} `json:"cainfo"` ErrMsg string `json:"err_msg"` InfRefmsgid string `json:"inf_refmsgid"` Infcode string `json:"infcode"` Output struct { } `json:"output"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Signtype interface{} `json:"signtype"` WarnMsg interface{} `json:"warn_msg"` } type CustomResult struct { BasMednFlag string `json:"bas_medn_flag"` ChldMedcFlag string `json:"chld_medc_flag"` ChrgitmLv string `json:"chrgitm_lv"` Cnt float64 `json:"cnt"` DetItemFeeSumamt float64 `json:"det_item_fee_sumamt"` DrtReimFlag string `json:"drt_reim_flag"` FeedetlSn string `json:"feedetl_sn"` FulamtOwnpayAmt float64 `json:"fulamt_ownpay_amt"` HiNegoDrugFlag string `json:"hi_nego_drug_flag"` InscpScpAmt float64 `json:"inscp_scp_amt"` ListSpItemFlag string `json:"list_sp_item_flag"` LmtUsedFlag string `json:"lmt_used_flag"` MedChrgitmType string `json:"med_chrgitm_type"` Memo string `json:"memo"` OverlmtAmt float64 `json:"overlmt_amt"` PreselfpayAmt float64 `json:"preselfpay_amt"` Pric float64 `json:"pric"` PricUplmtAmt float64 `json:"pric_uplmt_amt"` SelfpayProp float64 `json:"selfpay_prop"` } func ZHHisManagerApiRegistRouters() { beego.Router("/zh/api/inhopitalcheck/get", &ZHHisApiController{}, "get:GetZHInHospitalCheck") beego.Router("/zh/api/outhopitalcheck/get", &ZHHisApiController{}, "get:GetZHOutHospitalCheck") beego.Router("/zh/api/uploadinfo/get", &ZHHisApiController{}, "get:GetUploadInfo") beego.Router("/zh/api/presettle/get", &ZHHisApiController{}, "get:GetPreSettleInfo") beego.Router("/zh/api/settle/get", &ZHHisApiController{}, "get:GetSettleInfo") beego.Router("/zh/api/inthopitaluncheck/get", &ZHHisApiController{}, "get:GetZHInHospitalUnCheck") beego.Router("/zh/api/outhopitaluncheck/get", &ZHHisApiController{}, "get:GetZHOutHospitalUnCheck") beego.Router("/zh/api/refund", &ZHHisApiController{}, "get:ZHRefund") beego.Router("/zh/api/refunddetail", &ZHHisApiController{}, "get:ZHRefundDetail") beego.Router("/zh/api/patient/info", &ZHHisApiController{}, "get:GetZHPatientInfo") beego.Router("/zh/api/readcard", &ZHHisApiController{}, "get:ReadCard") beego.Router("/zh/api/clearsettle", &ZHHisApiController{}, "get:ClearSettle") beego.Router("/zh/api/readelecard", &ZHHisApiController{}, "get:ReadEleCard") beego.Router("/zh/api/deviceinit", &ZHHisApiController{}, "get:ReadEleCardfordevice") //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") beego.Router("/api/token/get", &ZHHisApiController{}, "post:GetToken") beego.Router("/api/ele/info", &ZHHisApiController{}, "post:GetEleInfo") beego.Router("/api/4102", &ZHHisApiController{}, "get:Get4102") beego.Router("/api/4103", &ZHHisApiController{}, "get:Get4103") //beego.Router("/api/4104", &ZHHisApiController{}, "get:Get4104") beego.Router("/api/cardstatus", &ZHHisApiController{}, "get:GetCardStatus") //beego.Router("/api/2403", &ZHHisApiController{}, "get:Get2403") beego.Router("/api/5201", &ZHHisApiController{}, "get:Get5201") } func (c *ZHHisApiController) Get5201() { } // func (c *ZHHisApiController) Get2403(){ // id, _ := c.GetInt64("order_id") // order,_ := service.GetHisOrderByID(id) // hosp,_ := service.GetInHospitalRecordByNumber(order.MdtrtId) // // // med_type := "21" // id_card_type := hosp.IdCardType // // // // diagnosis_ids_arr := strings.Split(hosp.Diagnosis, "-") // adminInfo := c.GetAdminUserInfo() // var patient service.Patients // if id == 0 { // patient, _ = service.GetPatientByIDCard(order.Certno, adminInfo.CurrentOrgId) // } else { // patient, _ = service.GetPatientByIDTwo(adminInfo.CurrentOrgId, id) // } // diagnosisConfig, _ := service.FindDiagnoseByIds(diagnosis_ids_arr) // // doctorInfo, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, hosp.Doctor) // //deviceNumber, _ := service.GetDeviceNumberByID(adm_bed, adminInfo.CurrentOrgId) // departmentInfo, _ := service.GetDepartMentDetail(hosp.Departments) // // // // // var struct2401 service.Struct2401 // struct2401.Insutype = "390" // psn_info, _ := service.GetPsnByPatientId(patient.ID) // if id_card_type == 1 { // struct2401.MdtrtCertType = "03" // bas := strings.Split(psn_info.CardInfo, "|") // cardNumber := bas[2] // struct2401.MdtrtCertNo = cardNumber // struct2401.PsnNo = order.PsnNo // } else if id_card_type == 4 { // struct2401.MdtrtCertType = "01" // struct2401.MdtrtCertNo = psn_info.VerifyNumber // struct2401.PsnNo = psn_info.PsnNo // } else { // struct2401.MdtrtCertType = "02" // struct2401.MdtrtCertNo = hosp.Certno // struct2401.PsnNo = hosp.PsnNo // } // // struct2401.IptNo = "2023061415103410808113442" // struct2401.AtddrNo = doctorInfo.DoctorNumber // struct2401.ChfpdrName = doctorInfo.UserName // struct2401.AdmDiagDscr = diagnosisConfig[0].ClassName // struct2401.AdmDeptCodg = strconv.FormatInt(int64(departmentInfo.ID), 10) // struct2401.AdmDeptName = departmentInfo.Name // struct2401.AdmBed = "" // struct2401.AdmBed = "待定" // // struct2401.DscgMaindiagName = diagnosisConfig[0].ClassName // struct2401.DscgMaindiagCode = diagnosisConfig[0].CountryCode // struct2401.Begntime = "2023" // struct2401.DiseCodg = sickConfig.CountryCode // struct2401.DiseName = sickConfig.ClassName // // } func (c *ZHHisApiController) GetCardStatus() { //patient_id, _ := c.GetInt64("patient_id") //record_date, _ := c.GetInt64("record_date") //psn, _ := service.GetPsnByPatientIdtWO(patient_id,record_date) //if len(psn.VerifyNumber) > 0{ // c.ServeSuccessJSON(map[string]interface{}{ // "msg": "读卡成功", // }) //} else{ // c.ServeSuccessJSON(map[string]interface{}{ // "msg": "", // }) //} } func (c *ZHHisApiController) GetEleInfo() { 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 } token := respJSON["token"].(string) respJSON = respJSON["result"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result := string(result_byte) fmt.Println("token") fmt.Println(token) fmt.Println("result") fmt.Println(result) var res ResultTwo var res10265 ResultTwo10265 //1101结果 if err := json.Unmarshal([]byte(result), &res10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.ErrMsg = res10265.ErrMsg infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64) res.Infcode = infocode res.Output = res10265.Output res.InfRefmsgid = res10265.InfRefmsgid if res.Infcode == 0 { patient, err := service.GetPatientByNumber(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: "", VerifyNumber: token, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": token, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } func (c *ZHHisApiController) GetToken() { 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 } token := respJSON["token"].(string) id_card_no := respJSON["id_card_no"].(string) fmt.Println("token") fmt.Println(token) fmt.Println("result") fmt.Println(id_card_no) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) patient, _ := service.GetPatientByIDCard(id_card_no, c.GetAdminUserInfo().CurrentOrgId) var api string api = "http://172.16.13.254:9532/" + "api/eleinfo?" + "fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&org_name=" + miConfig.OrgName + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&cainfo=" + miConfig.Cainfo + "&token=" + token + "&user_name=" + patient.Name + "&id_card_no=" + patient.IdCardNo 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 } c.ServeSuccessJSON(map[string]interface{}{ "msg": "读卡成功", }) } 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") roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) var api string api = "http://172.16.13.254:9532/" + "nmyb/readcard?" + "fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&cainfo=" + miConfig.Cainfo + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&operator_id=" + strconv.FormatInt(admin_user_id, 10) + "&operator=" + roles.UserName fmt.Println(api) 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 } var status string status = respJSON["data"].(map[string]interface{})["status"].(string) //card_type := respJSON["data"].(map[string]interface{})["type"].(string) var token string var res ResultTwo //1101结果 var res10265 ResultTwo10265 //1101结果 if status == "0" { //读卡成功 token = respJSON["data"].(map[string]interface{})["token"].(string) respJSON = respJSON["data"].(map[string]interface{})["result"].(map[string]interface{}) result, _ := json.Marshal(respJSON) if err := json.Unmarshal([]byte(result), &res10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.ErrMsg = res10265.ErrMsg infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64) res.Infcode = infocode res.Output = res10265.Output res.InfRefmsgid = res10265.InfRefmsgid if res.Infcode == 0 { c.ServeSuccessJSON(map[string]interface{}{ "number": token, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } func (c *ZHHisApiController) ClearSettle() { order_id, _ := c.GetInt64("order_id") admin_user_id, _ := c.GetInt64("admin_user_id") adminUser := c.GetAdminUserInfo() var order models.HisOrder order, _ = service.GetHisOrderByID(order_id) record, _ := service.GetInHospitalRecordByNumber(order.MdtrtId) roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId) if miConfig.MdtrtareaAdmvs == "350500" { record, _ := service.GetUploadRecord(order_id) record.Status = 0 service.UpdateRecord(&record) c.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销成功", }) } else { if config.IsOpen == 1 { //对接了医保，走医保流程 var result string var requestLog string result, requestLog = service.Gdyb90306(order.PsnNo, order.MdtrtId, order.SetlId, miConfig.OrgName, roles.UserName, miConfig.SecretKey, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs) saveLog(result, requestLog, "90306", "撤销结算清单") 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 ResultSix //var resSixteen ResultSixteen10265 if miConfig.Code == "H15049901371" { //if err := json.Unmarshal(userJSONBytes, &resSixteen); err != nil { // utils.ErrorLog("解析失败：%v", err) // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) // return //} //res.Cainfo = resSixteen.Cainfo //res.WarnMsg = resSixteen.WarnMsg //res.Output = resSixteen.Output //res.ErrMsg = resSixteen.ErrMsg //res.RespondTime = resSixteen.RespondTime //Infcode, _ := strconv.ParseInt(resSixteen.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 { record, _ := service.GetUploadRecord(order_id) record.Status = 0 service.UpdateRecord(&record) c.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销成功", }) } else { c.ServeSuccessJSON(map[string]interface{}{ "code": -10, "msg": res.ErrMsg, }) } } } } func (c *ZHHisApiController) GetZHPatientInfo() { id_card_no := c.GetString("id_card_no") admin_user_id, _ := c.GetInt64("admin_user_id") patient, _ := service.GetPatientByIDCard(id_card_no, c.GetAdminUserInfo().CurrentOrgId) if patient.ID == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePatientNoExist) return } role, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) config, _ := service.GetMedicalInsuranceConfig(c.GetAdminUserInfo().CurrentOrgId) if config.IsOpen == 1 { var result string var request_log string var result_log string if miConfig.MdtrtareaAdmvs == "150499" { var insuplc_admdvs string if len(patient.InsuplcAdmdvs) > 0 { insuplc_admdvs = patient.InsuplcAdmdvs } else { insuplc_admdvs = miConfig.InsuplcAdmdvs } //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/1101?cert_no=" + patient.IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + insuplc_admdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(2, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(1, 10) + "&name=" + patient.Name resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result_log, request_log, "1101", "人员基本信息获取") } else if miConfig.MdtrtareaAdmvs == "360399" || miConfig.MdtrtareaAdmvs == "361025" { result, request_log = service.JxybZY1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, 2, "", 0, miConfig.Url, miConfig.AccessKey, patient.Name, patient.IdCardNo, patient.Name) saveLog(result_log, request_log, "1101", "人员基本信息获取") }else if miConfig.MdtrtareaAdmvs == "341203"{ var insuplc_admdvs string if len(patient.InsuplcAdmdvs) > 0 { insuplc_admdvs = patient.InsuplcAdmdvs } else { insuplc_admdvs = miConfig.InsuplcAdmdvs } //请求内网数据 api := miConfig.SecretKey + "ahyb/1101?url=" + miConfig.Url + "&cert_no=" + patient.IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + insuplc_admdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(2, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(1, 10) + "&name=" + patient.Name+"&token="+"" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } status := respJSON["data"].(map[string]interface{})["status"].(string) if status == "0"{ err_msg := respJSON["data"].(map[string]interface{})["msg"].(string) c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": err_msg, }) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result_log, request_log, "1101", "人员基本信息获取") }else if miConfig.MdtrtareaAdmvs == "340699"{ var insuplc_admdvs string if len(patient.InsuplcAdmdvs) > 0 { insuplc_admdvs = patient.InsuplcAdmdvs } else { insuplc_admdvs = miConfig.InsuplcAdmdvs } //请求内网数据 api := miConfig.SecretKey + "ahyb/1101?url=" + miConfig.Url + "&cert_no=" + patient.IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + insuplc_admdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(2, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(1, 10) + "&name=" + patient.Name+"&token="+"" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } status := respJSON["data"].(map[string]interface{})["status"].(string) if status == "0"{ err_msg := respJSON["data"].(map[string]interface{})["msg"].(string) c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": err_msg, }) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result_log, request_log, "1101", "人员基本信息获取") } else { var insuplc_admdvs string if len(patient.InsuplcAdmdvs) > 0 { insuplc_admdvs = patient.InsuplcAdmdvs } else { insuplc_admdvs = miConfig.InsuplcAdmdvs } result, request_log, result_log = service.ZHGdyb1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, insuplc_admdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, 2, "", 1, "",admin_user_id) saveLog(result_log, request_log, "1101", "人员基本信息获取") } //result := service.Gdyb1101A(id_card_no, miConfig.OrgName, role.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, patient.Name) var dat map[string]interface{} if err := json.Unmarshal([]byte(result), &dat); err == nil { fmt.Println(dat) } else { fmt.Println(err) } userJSONBytes, _ := json.Marshal(dat) var res ResultTwo var resTwo10265 ResultTwo10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resTwo10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resTwo10265.Infcode, 10, 64) res.Infcode = Infcode res.ErrMsg = resTwo10265.ErrMsg res.Output = resTwo10265.Output res.InfRefmsgid = resTwo10265.InfRefmsgid res.RespondTime = resTwo10265.RespondTime res.WarnInfo = resTwo10265.WarnInfo }else if miConfig.MdtrtareaAdmvs == "441799" { //请求内网数据 api := miConfig.Url + "gdyb/1101?cert_no=" + patient.IdCardNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(2, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(1, 10) + "&name=" + patient.Name resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result_log, request_log, "1101", "人员基本信息获取") if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } else if miConfig.MdtrtareaAdmvs == "450721"{ c.ServeSuccessJSON(map[string]interface{}{ "msg": "", }) } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } var InsuplcAdmdvs string for _, item := range res.Output.Iinfo { utils.ErrorLog("解析失败：%v", item.Insutype) utils.ErrorLog("解析失败：%v", insutype) if item.Insutype == insutype { InsuplcAdmdvs = item.InsuplcAdmdvs } } utils.ErrorLog("解析失败：%v", InsuplcAdmdvs) Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, VerifyNumber: "", InsuplcAdmdvs: InsuplcAdmdvs, } service.CreateHisPsn(psn) if res.Infcode == -1 { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": 0, "info": res, "insutype": insutype, }) } } } func (c *ZHHisApiController) GetZHInHospitalCheck() { id, _ := c.GetInt64("id") record_time := c.GetString("record_time") name := c.GetString("name") phone := c.GetString("phone") id_card_type, _ := c.GetInt64("id_card_type") certificates, _ := c.GetInt64("certificates") id_card_no := c.GetString("id_card_no") doctor, _ := c.GetInt64("doctor") admin_user_id, _ := c.GetInt64("admin_user_id") department, _ := c.GetInt64("department") adm_bed, _ := c.GetInt64("adm_bed") diagnosis_ids := c.GetString("diagnosis") sick_type, _ := c.GetInt64("sick_type") start_time := c.GetString("start_time") insuplc_admdvs := c.GetString("insuplc_admdvs") balance_accounts_type, _ := c.GetInt64("balance_accounts_type") social_type, _ := c.GetInt64("social_type") psn_type, _ := c.GetInt64("psn_type") //reg_type, _ := c.GetInt64("p_type") med_type, _ := c.GetInt64("med_type") diagnosis_ids_arr := strings.Split(diagnosis_ids, "-") 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() adminInfo := c.GetAdminUserInfo() record, _ := service.GetLastHospitalRecord(id, adminInfo.CurrentOrgId) if record.ID != 0 { if record.InHospitalStatus == 1 && record.OutHospitalStatus != 1 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHospitalExistDataException) return } } var patient service.Patients if id == 0 { patient, _ = service.GetPatientByIDCard(id_card_no, adminInfo.CurrentOrgId) } else { patient, _ = service.GetPatientByIDTwo(adminInfo.CurrentOrgId, id) } diagnosisConfig, _ := service.FindDiagnoseByIds(diagnosis_ids_arr) sickConfig, _ := service.FindSickById(sick_type) departmentInfo, _ := service.GetDepartMentDetail(department) miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId) role, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, admin_user_id) var result string var request_log string var result_log string var res2 ResultTwo var resTwo10265 ResultTwo10265 psn_info, _ := service.GetPsnByPatientId(patient.ID) if miConfig.MdtrtareaAdmvs == "150499" { if id_card_type == 2 { mdtrt_cert_no := "" mdtrt_cert_no = id_card_no //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/1101?cert_no=" + mdtrt_cert_no + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(certificates, 10) + "&name=" + patient.Name resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) 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) if err := json.Unmarshal(userJSONBytes, &resTwo10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resTwo10265.Infcode, 10, 64) res2.Infcode = Infcode res2.ErrMsg = resTwo10265.ErrMsg res2.Output = resTwo10265.Output res2.InfRefmsgid = resTwo10265.InfRefmsgid res2.RespondTime = resTwo10265.RespondTime res2.WarnInfo = resTwo10265.WarnInfo } else { res2.Infcode = 0 res2.Output.Baseinfo.PsnNo = psn_info.PsnNo res2.Output.Baseinfo.Certno = patient.IdCardNo } } else if miConfig.MdtrtareaAdmvs == "421182" { res2.Infcode = 0 res2.Output.Baseinfo.PsnNo = psn_info.PsnNo res2.Output.Baseinfo.Certno = patient.IdCardNo } else if miConfig.MdtrtareaAdmvs == "360399" { //res2.Infcode = 0 //res2.Output.Baseinfo.PsnNo = psn_info.PsnNo //res2.Output.Baseinfo.Certno = patient.IdCardNo //result, request_log = service.JxybZY1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, insuplc_admdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, ca, certificates, miConfig.Url, miConfig.AccessKey, "", patient.IdCardNo, "") if id_card_type == 1{ bas := strings.Split(psn_info.CardInfo, "|") cardNumber := bas[3] result, request_log = service.Jxyb1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, cardNumber, "1", miConfig.Url, miConfig.AccessKey, "") saveLog(result, request_log, "1101", "人员基本信息获取") }else{ cardNumber := psn_info.VerifyNumber result, request_log = service.Jxyb1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, cardNumber, "1", miConfig.Url, miConfig.AccessKey, psn_info.PsnName) saveLog(result, request_log, "1101", "人员基本信息获取") } } else { result, request_log, result_log = service.ZHGdyb1101(patient.IdCardNo, miConfig.OrgName, role.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, "", certificates, name,admin_user_id) saveLog(result_log, request_log, "1101", "人员基本信息获取") } doctorInfo, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, doctor) deviceNumber, _ := service.GetDeviceNumberByID(adm_bed, adminInfo.CurrentOrgId) if miConfig.MdtrtareaAdmvs != "150499" && miConfig.MdtrtareaAdmvs != "421182" { 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) if err := json.Unmarshal(userJSONBytes, &res2); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } var infoStr string if miConfig.MdtrtareaAdmvs == "150499" { if id_card_type == 2 { Iinfos, _ := json.Marshal(res2.Output.Iinfo) infoStr = string(Iinfos) } else { infoStr = psn_info.Insuinfo } } else if miConfig.MdtrtareaAdmvs == "421182" { infoStr = psn_info.Insuinfo } else { Iinfos, _ := json.Marshal(res2.Output.Iinfo) infoStr = string(Iinfos) } var rf []*ResultFive json.Unmarshal([]byte(infoStr), &rf) var insutypes []*ResultFive var insutype string var is390 int = 0 var is310 int = 0 for _, item := range rf { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item) } } if len(insutypes) == 1 { insutype = insutypes[0].Insutype //insuplc_admdvs = insutypes[0].InsuplcAdmdvs } else { for _, i := range insutypes { if i.Insutype == "390" { is390 = 1 } if i.Insutype == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } if len(insutypes) == 2 { insutype = strconv.FormatInt(social_type, 10) } //for _, item := range rf { // if item.Insutype == insutype { // insuplc_admdvs = item.InsuplcAdmdvs // } //} if res2.Infcode == 0 { //var insutypes []string // //var insutype string //var is390 int = 0 //var is310 int = 0 //for _, item := range res2.Output.Iinfo { // if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { // insutypes = append(insutypes, item.Insutype) // } //} //if len(insutypes) == 1 { // insutype = insutypes[0] //} else { // for _, i := range insutypes { // if i == "390" { // is390 = 1 // } // // if i == "310" { // is310 = 1 // } // } //} //if is390 == 1 { // insutype = "390" //} //if is310 == 1 { // insutype = "310" //} // //if len(insutypes) == 0 { // insutype = "310" //} if len(insuplc_admdvs) == 0 { insuplc_admdvs = miConfig.InsuplcAdmdvs } timestamp := time.Now().Unix() tempTime := time.Unix(timestamp, 0) timeFormat := tempTime.Format("20060102150405") chrgBchno := rand.Intn(100000) + 10000 ipt_otp_no := timeFormat + strconv.FormatInt(int64(chrgBchno), 10) + strconv.FormatInt(id, 10) timeFormatOne := tempTime.Format("2006-01-02 15:04:05") var struct2401 service.Struct2401 //insutype = "310" struct2401.Insutype = insutype psn_info, _ := service.GetPsnByPatientId(patient.ID) if id_card_type == 1 { struct2401.MdtrtCertType = "03" bas := strings.Split(psn_info.CardInfo, "|") cardNumber := bas[2] struct2401.MdtrtCertNo = cardNumber struct2401.PsnNo = res2.Output.Baseinfo.PsnNo } else if id_card_type == 4 { struct2401.MdtrtCertType = "01" struct2401.MdtrtCertNo = psn_info.VerifyNumber struct2401.PsnNo = psn_info.PsnNo } else { struct2401.MdtrtCertType = "02" struct2401.MdtrtCertNo = id_card_no struct2401.PsnNo = res2.Output.Baseinfo.PsnNo } if miConfig.Code == "H15049901371" { if med_type == 14 { if insutype == "390" { struct2401.MedType = "9933" } else if insutype == "310" { struct2401.MedType = "990502" } } else if med_type == 11 { struct2401.MedType = "21" } } else { if med_type == 11 { struct2401.MedType = "21" med_type = 21 } else { struct2401.MedType = strconv.FormatInt(int64(med_type), 10) } } struct2401.IptNo = ipt_otp_no struct2401.AtddrNo = doctorInfo.DoctorNumber struct2401.ChfpdrName = doctorInfo.UserName struct2401.AdmDiagDscr = diagnosisConfig[0].ClassName struct2401.AdmDeptCodg = strconv.FormatInt(int64(departmentInfo.ID), 10) struct2401.AdmDeptName = departmentInfo.Name struct2401.AdmBed = deviceNumber.Number struct2401.AdmBed = "待定" struct2401.DscgMaindiagName = diagnosisConfig[0].ClassName struct2401.DscgMaindiagCode = diagnosisConfig[0].CountryCode struct2401.Begntime = start_time struct2401.DiseCodg = sickConfig.CountryCode struct2401.DiseName = sickConfig.ClassName var dises []service.DiseinfoStruct for index, item := range diagnosisConfig { var dise service.DiseinfoStruct if id_card_type == 4 || id_card_type == 1 { dise.PsnNo = psn_info.PsnNo } else { dise.PsnNo = res2.Output.Baseinfo.PsnNo } dise.DiagType = "1" if index == 0 { dise.MaindiagFlag = "1" } else { dise.MaindiagFlag = "2" } dise.DiagSrtNo = strconv.FormatInt(int64(index), 10) dise.DiseDorName = doctorInfo.UserName dise.DiagCode = item.CountryCode dise.DiagName = item.ClassName dise.DiagDept = departmentInfo.Name dise.DiseDorNo = doctorInfo.DoctorNumber dise.DiagTime = timeFormatOne dises = append(dises, dise) } struct2401.Diseinfo = dises var result string var request_log string if miConfig.MdtrtareaAdmvs == "150499" { data := make(map[string]interface{}) data["org_name"] = miConfig.OrgName data["doctor"] = role.UserName data["fixmedins_code"] = miConfig.Code data["insuplc_admdvs"] = insuplc_admdvs data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs data["secret_key"] = miConfig.SecretKey data["struct_2401"] = struct2401 var req *http.Request bytesData, _ := json.Marshal(data) req, _ = http.NewRequest("POST", "http://172.16.13.254:9532/"+"nmyb/2401", 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 if miConfig.MdtrtareaAdmvs == "421182" { data := make(map[string]interface{}) data["org_name"] = miConfig.OrgName data["doctor"] = role.UserName data["fixmedins_code"] = miConfig.Code data["insuplc_admdvs"] = insuplc_admdvs data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs data["secret_key"] = miConfig.SecretKey data["struct_2401"] = struct2401 var req *http.Request bytesData, _ := json.Marshal(data) req, _ = http.NewRequest("POST", miConfig.Url +"hbyb/2401", 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, _ := json.Marshal(respJSON) //result = string(result_byte) //decoder := simplifiedchinese.GBK.NewDecoder() result_byte, _ := json.Marshal(respJSON) result = string(result_byte) //enc := mahonia.NewEncoder("gbk") //result = enc.ConvertString(string(result_byte)) fmt.Println(string(result)) // 输出：中文 } else if miConfig.MdtrtareaAdmvs == "360399" { if !strings.Contains(insuplc_admdvs, "3603") { if id_card_type == 1 { bas := strings.Split(psn_info.CardInfo, "|") card_sn := bas[3] card_no := bas[1] struct2401.Cardsn = card_sn struct2401.PsnCertType = "01" struct2401.Certno = card_no struct2401.PsnType = psn_type struct2401.PsnName = patient.Name } } result, request_log = service.Jxyb2401(struct2401, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, insuplc_admdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, request_log, "2401", "入院登记") } else { //住院登记调用事前 //var hisPrescription []*models.HisPrescription //res3101 := Check3101ForOne(c, patient.ID, struct2401, admin_user_id, "3", record_time, hisPrescription, res2, recordDateTime) var res3101 Result3101 res3101.Infcode = 0 if res3101.Infcode == 0 { result, request_log = service.ZHGdyb2401(struct2401, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, insuplc_admdvs, miConfig.MdtrtareaAdmvs) saveLog(result, request_log, "2401", "入院登记") } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res3101.ErrMsg, }) return } } 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 ResultThree var resThree10265 ResultThree10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resThree10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resThree10265.Infcode, 10, 64) res.Infcode = Infcode res.ErrMsg = resThree10265.ErrMsg res.Output = resThree10265.Output res.InfRefmsgid = resThree10265.InfRefmsgid res.RespondTime = resThree10265.RespondTime } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode == 0 { //result2 := service.Gdyb5301Two(res2.Output.Baseinfo.PsnNo, miConfig.OrgName, role.UserName, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey) //fmt.Println(result2) Iinfos, _ := json.Marshal(res2.Output.Iinfo) Idetinfos, _ := json.Marshal(res2.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) inHospital := &models.HisHospitalCheckRecord{ PatientId: id, Name: name, MedicalTreatmentType: med_type, RecordDate: recordDateTime, IdCardNo: id_card_no, AdminUserId: admin_user_id, Departments: department, UserOrgId: adminInfo.CurrentOrgId, Status: 1, Ctime: time.Now().Unix(), Mtime: time.Now().Unix(), Number: res.Output.Result.MdtrtID, Doctor: doctor, PsnNo: res2.Output.Baseinfo.PsnNo, PsnCertType: res2.Output.Baseinfo.PsnCertType, Certno: res2.Output.Baseinfo.Certno, PsnName: res2.Output.Baseinfo.PsnName, Gend: res2.Output.Baseinfo.Gend, Naty: res2.Output.Baseinfo.Naty, MedType: med_type, InsutypeType: insutype, Iinfo: infoStr, Idetinfo: idetinfoStr, IptOtpNo: ipt_otp_no, AdmBed: adm_bed, IdCardType: id_card_type, Diagnosis: diagnosis_ids, SickType: sick_type, MdtrtCertType: "02", InHosptialTime: start_time, OutHosptialTime: "", InHospitalStatus: 1, Certificates: certificates, Phone: phone, BalanceAccountsType: balance_accounts_type, PsnType: psn_type, InsuplcAdmdvs: insuplc_admdvs, } service.CreateHospitalRecord(inHospital) c.ServeSuccessJSON(map[string]interface{}{ "msg": "办理入院成功", "info": inHospital, }) } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res2.ErrMsg, }) return } } func (this *ZHHisApiController) GetZHOutHospitalCheck() { id, _ := this.GetInt64("id") patient_id, _ := this.GetInt64("patient_id") admin_user_id, _ := this.GetInt64("admin_user_id") record_time := this.GetString("record_time") out_time := this.GetString("out_time") adminInfo := this.GetAdminUserInfo() miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId) role, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, admin_user_id) //service.getpre record, _ := service.GetInHospitalRecord(id) if record.ID == 0 { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeInHospitalNoExistDataException) return } infos, _ := service.FindLastPatientPrescriptionInfoTwo2(this.GetAdminUserInfo().CurrentOrgId, patient_id, strings.Split(record.InHosptialTime, " ")[0], strings.Split(out_time, " ")[0]) 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 { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } recordDateTime := theTime.Unix() //var patient service.Patients //if patient_id == 0 { // patient, _ = service.GetPatientByIDCard(record.IdCardNo, adminInfo.CurrentOrgId) //} else { // patient, _ = service.GetPatientByIDTwo(adminInfo.CurrentOrgId, id) //} for _, item := range infos { record.Diagnosis = record.Diagnosis + "," + item.Diagnosis } diagnosis_ids_arr := strings.Split(record.Diagnosis, ",") fmt.Println(diagnosis_ids_arr) diagnosis_ids_arr = RemoveRepeatedPurviewElement2(diagnosis_ids_arr) fmt.Println(diagnosis_ids_arr) diagnosisConfig, _ := service.FindDiagnoseByIds(diagnosis_ids_arr) departmentInfo, _ := service.GetDepartMentDetail(record.Departments) doctorInfo, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, record.Doctor) //deviceNumber, _ := service.GetDeviceNumberByID(record.AdmBed, adminInfo.CurrentOrgId) sickConfig, _ := service.FindSickById(record.SickType) var struct2402 service.Struct2402 timestamp := time.Now().Unix() tempTime := time.Unix(timestamp, 0) //timeFormat := tempTime.Format("20060102150405") timeFormatOne := tempTime.Format("2006-01-02 15:04:05") struct2402.PsnNo = record.PsnNo struct2402.Insutype = record.InsutypeType struct2402.DscgWay = "1" struct2402.Endtime = out_time struct2402.DscgDeptName = departmentInfo.Number struct2402.DscgDeptCodg = strconv.FormatInt(int64(departmentInfo.ID), 10) struct2402.MdtrtId = record.Number var dises []service.Diseinfo2402Struct for index, item := range diagnosisConfig { var dise service.Diseinfo2402Struct dise.PsnNo = record.PsnNo if index == 0 { dise.DiagType = "1" dise.MaindiagFlag = "1" } else { dise.DiagType = "1" dise.MaindiagFlag = "0" } dise.MdtrtId = record.Number dise.DiagSrtNo = strconv.FormatInt(int64(index), 10) dise.DiseDorName = doctorInfo.UserName dise.DiagCode = item.CountryCode dise.DiagName = item.ClassName dise.DiagDept = departmentInfo.Name dise.DiseDorNo = doctorInfo.DoctorNumber dise.DiagTime = timeFormatOne dises = append(dises, dise) } struct2402.Diseinfo = dises struct2402.DiseName = sickConfig.ClassName struct2402.DiseCode = sickConfig.CountryCode var result string var request_log string if miConfig.MdtrtareaAdmvs == "150499" { data := make(map[string]interface{}) data["org_name"] = miConfig.OrgName data["doctor"] = role.UserName data["fixmedins_code"] = miConfig.Code data["insuplc_admdvs"] = record.InsuplcAdmdvs data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs data["secret_key"] = miConfig.SecretKey data["struct_2402"] = struct2402 var req *http.Request bytesData, _ := json.Marshal(data) req, _ = http.NewRequest("POST", "http://172.16.13.254:9532/"+"nmyb/2402", 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) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(body), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "421182" { data := make(map[string]interface{}) data["org_name"] = miConfig.OrgName data["doctor"] = role.UserName data["fixmedins_code"] = miConfig.Code data["insuplc_admdvs"] = record.InsuplcAdmdvs data["mdtrtarea_admvs"] = miConfig.MdtrtareaAdmvs data["secret_key"] = miConfig.SecretKey data["struct_2402"] = struct2402 var req *http.Request bytesData, _ := json.Marshal(data) req, _ = http.NewRequest("POST", miConfig.Url +"hbyb/2402", 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) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(body), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { result, request_log = service.Jxyb2402(struct2402, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, request_log, "2402", "出院") } else { result, request_log = service.ZHGdyb2402(struct2402, miConfig.OrgName, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, miConfig.Code) saveLog(result, request_log, "2402", "出院") } 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 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res.Infcode = Infcode res.RespondTime = resEmpty10265.RespondTime res.ErrMsg = resEmpty10265.ErrMsg res.Output = resEmpty10265.Output res.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode == 0 { record.OutHospitalStatus = 1 record.OutHosptialTime = struct2402.Endtime record.OutWay = 1 service.CreateHospitalRecord(&record) orders, _ := service.GetHisOrderInfoByNumberFour(record.Number) var total float64 for _, item := range orders { total = total + item.DetItemFeeSumamt } order := &models.HisOrder{ UserOrgId: adminInfo.CurrentOrgId, HisPatientId: record.ID, PatientId: record.PatientId, SettleAccountsDate: recordDateTime, Ctime: time.Now().Unix(), Mtime: time.Now().Unix(), Status: 1, Number: record.Number, Infcode: 0, WarnMsg: "", Cainfo: "", ErrMsg: "", RespondTime: "", InfRefmsgid: "", OrderStatus: 1, MdtrtId: record.Number, IsMedicineInsurance: 1, PType: 1, MedfeeSumamt: total, } err = service.CreateOrder(order) if err != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreatePreOrderException) return } this.ServeSuccessJSON(map[string]interface{}{ "msg": "出院成功", }) } else { this.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } } func (c *ZHHisApiController) Get4102() { order_id, _ := c.GetInt64("order_id") admin_user_id, _ := c.GetInt64("admin_user_id") stas_type := c.GetString("stas_type") adminUser := c.GetAdminUserInfo() order, _ := service.GetHisOrderByID(order_id) miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) var user_name string role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) if role.ID == 0 { user_name = "管理员" } else { user_name = role.UserName } baseParams := models.BaseParams{ SecretKey: miConfig.SecretKey, FixmedinsCode: miConfig.Code, InsuplcAdmdvs: miConfig.InsuplcAdmdvs, MdtrtareaAdmvs: miConfig.MdtrtareaAdmvs, OrgName: miConfig.OrgName, Doctor: user_name, RequestUrl: miConfig.Url, AccessKey: miConfig.AccessKey, } businessParams := models.BusinessParams{ PsnNo: order.PsnNo, MdtrtId: order.MdtrtId, SetlId: order.SetlId, StasType: stas_type, } api := "http://172.16.13.254:9532/" + "nmyb/4102?psn_no=" + businessParams.PsnNo + "&mdtrt_id=" + businessParams.MdtrtId + "&setl_id=" + businessParams.SetlId + "&org_name=" + miConfig.OrgName + "&doctor=" + baseParams.Doctor + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&stas_type=" + stas_type resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result, _ := json.Marshal(respJSON) fmt.Println("log") fmt.Println(string(result)) var res2 ResultSix var resEmpty10265 ResultEmpty10265 if err := json.Unmarshal(result, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res2.Infcode = Infcode res2.RespondTime = resEmpty10265.RespondTime res2.ErrMsg = resEmpty10265.ErrMsg res2.Output = resEmpty10265.Output res2.WarnMsg = resEmpty10265.WarnMsg if res2.Infcode == 0 { c.ServeSuccessJSON(map[string]interface{}{ "msg": "确认成功", }) } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res2.ErrMsg, }) } } func (c *ZHHisApiController) Get4103() { order_id, _ := c.GetInt64("order_id") admin_user_id, _ := c.GetInt64("admin_user_id") stas_type := c.GetString("stas_type") adminUser := c.GetAdminUserInfo() order, _ := service.GetHisOrderByID(order_id) miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) var user_name string role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) if role.ID == 0 { user_name = "管理员" } else { user_name = role.UserName } baseParams := models.BaseParams{ SecretKey: miConfig.SecretKey, FixmedinsCode: miConfig.Code, InsuplcAdmdvs: miConfig.InsuplcAdmdvs, MdtrtareaAdmvs: miConfig.MdtrtareaAdmvs, OrgName: miConfig.OrgName, Doctor: user_name, RequestUrl: miConfig.Url, AccessKey: miConfig.AccessKey, } businessParams := models.BusinessParams{ PsnNo: order.PsnNo, MdtrtId: order.MdtrtId, SetlId: order.SetlId, StasType: stas_type, } api := "http://172.16.13.254:9532/" + "nmyb/4103?psn_no=" + businessParams.PsnNo + "&mdtrt_id=" + businessParams.MdtrtId + "&setl_id=" + businessParams.SetlId + "&org_name=" + miConfig.OrgName + "&doctor=" + baseParams.Doctor + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&stas_type=" + stas_type resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result, _ := json.Marshal(respJSON) fmt.Println("log") fmt.Println(string(result)) var res2 ResultSix var resEmpty10265 ResultEmpty10265 if err := json.Unmarshal(result, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res2.Infcode = Infcode res2.RespondTime = resEmpty10265.RespondTime res2.ErrMsg = resEmpty10265.ErrMsg res2.Output = resEmpty10265.Output res2.WarnMsg = resEmpty10265.WarnMsg if res2.Infcode == 0 { c.ServeSuccessJSON(map[string]interface{}{ "msg": string(result), }) } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res2.ErrMsg, }) } } //func (c *ZHHisApiController) Get4104() { // order_id, _ := c.GetInt64("order_id") // admin_user_id, _ := c.GetInt64("admin_user_id") // adminUser := c.GetAdminUserInfo() // order, _ := service.GetHisOrderByID(order_id) // miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) // var user_name string // role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) // if role.ID == 0 { // user_name = "管理员" // } else { // user_name = role.UserName // } // baseParams := models.BaseParams{ // SecretKey: miConfig.SecretKey, // FixmedinsCode: miConfig.Code, // InsuplcAdmdvs: miConfig.InsuplcAdmdvs, // MdtrtareaAdmvs: miConfig.MdtrtareaAdmvs, // OrgName: miConfig.OrgName, // Doctor: user_name, // RequestUrl: miConfig.Url, // AccessKey: miConfig.AccessKey, // } // // businessParams := models.BusinessParams{ // PsnNo: order.PsnNo, // MdtrtId: order.MdtrtId, // SetlId: order.SetlId, // } // // api := "http://172.16.13.254:9532/" + "nmyb/4104?psn_no=" + businessParams.PsnNo + "&mdtrt_id=" + businessParams.MdtrtId + "&setl_id=" + businessParams.SetlId + // "&org_name=" + miConfig.OrgName + "&doctor=" + baseParams.Doctor + "&fixmedins_code=" + miConfig.Code + // "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&stas_type=" + stas_type // resp, requestErr := http.Get(api) // if requestErr != nil { // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) // return // } // body, ioErr := ioutil.ReadAll(resp.Body) // if ioErr != nil { // utils.ErrorLog("接口返回数据读取失败: %v", ioErr) // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) // return // } // var respJSON map[string]interface{} // if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { // utils.ErrorLog("接口返回数据解析JSON失败: %v", err) // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) // return // } // // respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) // result, _ := json.Marshal(respJSON) // fmt.Println("log") // fmt.Println(string(result)) // // var res2 ResultSix // var resEmpty10265 ResultEmpty10265 // // if err := json.Unmarshal(result, &resEmpty10265); err != nil { // utils.ErrorLog("解析失败：%v", err) // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) // return // } // Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) // res2.Infcode = Infcode // res2.RespondTime = resEmpty10265.RespondTime // res2.ErrMsg = resEmpty10265.ErrMsg // res2.Output = resEmpty10265.Output // res2.WarnMsg = resEmpty10265.WarnMsg // // if res2.Infcode == 0 { // c.ServeSuccessJSON(map[string]interface{}{ // "msg": "确认成功", // }) // // } else { // c.ServeSuccessJSON(map[string]interface{}{ // "failed_code": -10, // "msg": res2.ErrMsg, // }) // // } // //} func (c *ZHHisApiController) GetSettleInfo() { order_id, _ := c.GetInt64("order_id") patient_id, _ := c.GetInt64("patient_id") in_hospital_id, _ := c.GetInt64("in_hospital_id") admin_user_id, _ := c.GetInt64("admin_user_id") pay_way, _ := c.GetInt64("pay_way") pay_price, _ := c.GetFloat("pay_price") pay_card_no := c.GetString("pay_card_no") discount_price, _ := c.GetFloat("discount_price") preferential_price, _ := c.GetFloat("preferential_price") reality_price, _ := c.GetFloat("reality_price") found_price, _ := c.GetFloat("found_price") medical_insurance_price, _ := c.GetFloat("medical_insurance_price") private_price, _ := c.GetFloat("private_price") fapiao_code := c.GetString("fapiao_code") fapiao_number := c.GetString("fapiao_number") record, _ := service.GetInHospitalRecord(in_hospital_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) order, _ := service.GetHisOrderByID(order_id) //dec_way := c.GetString("dec_way") //是否使用押金支付bool类型 //tmp_decimal := c.GetString("tmp_decimal") //var decimal float64 //本次使用的押金 dec_way := c.GetString("dec_way") //是否使用押金支付bool类型 tmp_decimal := c.GetString("tmp_decimal") var decimal float64 //本次使用的押金 var errmsg error if dec_way == "true" && tmp_decimal == "0" || dec_way == "true" && tmp_decimal == "" { c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金不能为0") return } if len(tmp_decimal) > 0 { if tmp_decimal[0] == 45 { c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金不能为负数") return } } tt, errs := strconv.ParseFloat(tmp_decimal, 64) if errs != nil { c.ServeFailJsonSend(enums.ErrorCodeParamWrong, "押金金额错误") return } decimal = tt var rf []*ResultFive json.Unmarshal([]byte(record.Iinfo), &rf) chrg_bchno := order.Number cert_no := record.Certno if record.ID == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } if record.InHospitalStatus == 1 && record.OutHospitalStatus == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHospitalNoExistDataException) return } if record.IdCardType == 1 { } else { cert_no = record.Certno } var result string var src_resquest string timeLayout := "2006-01-02" loc, _ := time.LoadLocation("Local") theTime, err := time.ParseInLocation(timeLayout+" 15:04:05", record.InHosptialTime, loc) if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } recordStartDateTime := theTime.Unix() theTimeEnd, err := time.ParseInLocation(timeLayout+" 15:04:05", record.OutHosptialTime, loc) if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } recordEndDateTime := theTimeEnd.Unix() prescriptions, _ := service.GetZHSettleMonthHisPrescription(c.GetAdminUserInfo().CurrentOrgId, patient_id, recordStartDateTime, recordEndDateTime) var total float64 for _, item := range prescriptions { if item.Type == 1 { //药品 for _, subItem := range item.HisDoctorAdviceInfo { total = total + (subItem.Price * subItem.PrescribingNumber) } } if item.Type == 2 { //项目 for _, subItem := range item.HisPrescriptionProject { cnt, _ := strconv.ParseFloat(subItem.Count, 64) total = total + (subItem.Price * cnt) } } } //allTotal := fmt.Sprintf("%.2f", total) var allTotal string if record.OutHospitalStatus == 0 && order.ID == 0 { orders, _ := service.GetHisOrderInfoByNumberFour(record.Number) var total float64 for _, item := range orders { total = total + item.DetItemFeeSumamt } allTotal = fmt.Sprintf("%.4f", total) } else { allTotal = fmt.Sprintf("%.4f", order.MedfeeSumamt) } if miConfig.MdtrtareaAdmvs == "150499" { psn_info, _ := service.GetPsnByPatientId(patient_id) mdtrt_cert_no := "" if record.IdCardType == 1 { bas := strings.Split(psn_info.CardInfo, "|") cardNumber := bas[2] mdtrt_cert_no = cardNumber } else { mdtrt_cert_no = record.Certno } var acct_used_flag string if pay_way == 4 { acct_used_flag = "1" } else { acct_used_flag = "0" } if pay_way == 6 { mdtrt_cert_no = psn_info.VerifyNumber acct_used_flag = "1" record.IdCardType = 4 } else { acct_used_flag = "0" } fmt.Println(mdtrt_cert_no) fmt.Println(acct_used_flag) fmt.Println(record.IdCardType) //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2304?psn_no=" + record.PsnNo + "&mdtrt_id=" + record.Number + "&chrg_bchno=" + chrg_bchno + "&insutype_type=" + record.InsutypeType + "&total=" + allTotal + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(record.IdCardType, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(record.Certificates, 10) + "&name=" + record.Name + "&cert_no=" + mdtrt_cert_no + "&fapiao_number=" + fapiao_number + "&acct_used_flag=" + acct_used_flag resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "421182" { psn_info, _ := service.GetPsnByPatientId(patient_id) mdtrt_cert_no := "" if record.IdCardType == 1 { bas := strings.Split(psn_info.CardInfo, "|") cardNumber := bas[2] mdtrt_cert_no = cardNumber } else { mdtrt_cert_no = record.Certno } var acct_used_flag string if pay_way == 4 { acct_used_flag = "1" } else { acct_used_flag = "0" } if pay_way == 6 { mdtrt_cert_no = psn_info.VerifyNumber acct_used_flag = "1" record.IdCardType = 4 } else { acct_used_flag = "0" } fmt.Println(mdtrt_cert_no) fmt.Println(acct_used_flag) fmt.Println(record.IdCardType) //请求内网数据 api := miConfig.Url + "hbyb/2304?psn_no=" + record.PsnNo + "&mdtrt_id=" + record.Number + "&chrg_bchno=" + chrg_bchno + "&insutype_type=" + record.InsutypeType + "&total=" + allTotal + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(record.IdCardType, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(record.Certificates, 10) + "&name=" + record.Name + "&cert_no=" + mdtrt_cert_no + "&fapiao_number=" + fapiao_number + "&acct_used_flag=" + acct_used_flag resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { psn_info, _ := service.GetPsnByPatientId(patient_id) if len(psn_info.CardInfo) > 0 && len(psn_info.VerifyNumber) == 0{ cert_no = record.Certno } else if len(psn_info.CardInfo) == 0 && len(psn_info.VerifyNumber) > 0{ cert_no = psn_info.VerifyNumber } //result, src_resquest = service.Jxyb2304(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey, "", "1") if strings.Contains(record.InsuplcAdmdvs, "3603") { bas := strings.Split(psn_info.CardInfo, "|") card_sn := bas[3] result, src_resquest = service.Jxyb2304(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey, "", "1",card_sn,"","","","") saveLog(result, src_resquest, "2304", "住院结算") //if record.IdCardType == 1 { //basNumber := bas[2] // result, src_resquest = service.Jxyb2303(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey, card_sn, record.PsnType, record.PsnCertType, record.IdCardNo, record.Name) // saveLog(result, src_resquest, "2303", "住院预结算") //} }else{ bas := strings.Split(psn_info.CardInfo, "|") card_sn := bas[3] result, src_resquest = service.Jxyb2304a(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey, "", "1",card_sn,record.PsnType,record.PsnCertType,record.IdCardNo,record.Name) //result, src_resquest = service.Jxyb2303(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey,"",record.PsnType,record.PsnCertType,record.IdCardNo,record.Name) saveLog(result, src_resquest, "2303", "住院预结算") } } else { result3101 := Check3102(c, record.PatientId, record.ID, admin_user_id, "8", order.ID) if result3101.Infcode == 0 { if len(result3101.Output.Result) > 0 { var errMsgs []string for _, item := range result3101.Output.Result { errMsgs = append(errMsgs, item.VolaCont) } c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": errMsgs, }) return } else { result, src_resquest = service.ZHGdyb2304(record.PsnNo, record.Number, chrg_bchno, cert_no, record.InsutypeType, allTotal, miConfig.OrgName, roles.UserName, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, "0", record.IdCardType, 0, 0, 0, 0, record.Certificates, "", "1") saveLog(result, src_resquest, "2304", "住院结算") } } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": result3101.ErrMsg, }) return } } 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 ResultSeven var resSeven10265 ResultSeven10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resSeven10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resSeven10265.Infcode, 10, 64) res.Infcode = Infcode res.InfRefmsgid = resSeven10265.InfRefmsgid res.RespondTime = resSeven10265.RespondTime res.ErrMsg = resSeven10265.ErrMsg res.Output = resSeven10265.Output res.WarnMsg = resSeven10265.WarnMsg res.Cainfo = resSeven10265.Cainfo } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode != 0 { errlog := &models.HisOrderError{ UserOrgId: c.GetAdminUserInfo().CurrentOrgId, Ctime: time.Now().Unix(), Mtime: time.Now().Unix(), Number: chrg_bchno, ErrMsg: res.ErrMsg, Status: 1, PatientId: patient_id, RecordTime: time.Now().Unix(), Stage: 6, } service.CreateErrMsgLog(errlog) c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) return } else { //order, _ := service.GetHisOrderTwo(adminUser.CurrentOrgId, chrg_bchno, id) order.OrderStatus = 2 order.DiscountPrice = discount_price order.MedicalInsurancePrice = medical_insurance_price order.FaPiaoNumber = fapiao_number order.FaPiaoCode = fapiao_code order.PayWay = pay_way order.PayPrice = pay_price order.PayCardNo = pay_card_no order.PreferentialPrice = preferential_price order.RealityPrice = reality_price order.FoundPrice = found_price order.PrivatePrice = private_price order.MdtrtId = res.Output.Setlinfo.MdtrtID order.SetlId = res.Output.Setlinfo.SetlID order.PsnNo = res.Output.Setlinfo.PsnNo order.PsnName = res.Output.Setlinfo.PsnName order.PsnCertType = res.Output.Setlinfo.PsnCertType order.Certno = res.Output.Setlinfo.Certno order.Gend = res.Output.Setlinfo.Gend order.Naty = res.Output.Setlinfo.Naty order.Age = res.Output.Setlinfo.Age order.Insutype = res.Output.Setlinfo.Insutype order.PsnType = res.Output.Setlinfo.PsnType order.CvlservFlag = res.Output.Setlinfo.CvlservFlag order.SetlTime = res.Output.Setlinfo.SetlTime order.MdtrtCertType = res.Output.Setlinfo.MdtrtCertType if res.Output.Setlinfo.MedType == "140104" { order.MedType = "14" } else { order.MedType = res.Output.Setlinfo.MedType } order.MedfeeSumamt = res.Output.Setlinfo.MedfeeSumamt order.FulamtOwnpayAmt = res.Output.Setlinfo.FulamtOwnpayAmt order.OverlmtSelfPay = res.Output.Setlinfo.OverlmtSelfpay order.PreselfpayAmt = res.Output.Setlinfo.PreselfpayAmt order.InscpScpAmt = res.Output.Setlinfo.InscpScpAmt order.ActPayDedc = res.Output.Setlinfo.ActPayDedc order.HifpPay = res.Output.Setlinfo.HifpPay order.CvlservPay = res.Output.Setlinfo.CvlservPay order.PoolPropSelfpay = res.Output.Setlinfo.PoolPropSelfpay order.HifesPay = res.Output.Setlinfo.HifesPay order.HifobPay = res.Output.Setlinfo.HifobPay order.MafPay = res.Output.Setlinfo.MafPay order.OthPay = res.Output.Setlinfo.OthPay order.FundPaySumamt = res.Output.Setlinfo.FundPaySumamt order.PsnPartAmt = res.Output.Setlinfo.PsnPartAmt order.AcctPay = res.Output.Setlinfo.AcctPay order.PsnCashPay = res.Output.Setlinfo.PsnCashPay order.HospPartAmt = res.Output.Setlinfo.HospPartAmt order.Balc = res.Output.Setlinfo.Balc order.AcctMulaidPay = res.Output.Setlinfo.AcctMulaidPay order.MedinsSetlId = res.Output.Setlinfo.MedinsSetlID order.ClrOptins = res.Output.Setlinfo.ClrOptins order.ClrWay = res.Output.Setlinfo.ClrWay order.Creator = order.Creator order.Modify = roles.AdminUserId order.RequestLog = src_resquest setlDetail, _ := json.Marshal(res.Output.Setldetail) detailStr := string(setlDetail) order.SetlDetail = detailStr err := service.UpdataOrderStatusTwo(chrg_bchno, c.GetAdminUserInfo().CurrentOrgId) err = service.UpDateOrder(order) if err == nil { //判断是否使用了押金 if dec_way == "true" { tmpstring := strconv.FormatInt(order.ID, 10) order.Decimal = decimal err = service.UpDateOrder(order) //扣押金 errmsg = service.SpendDeposit(c.GetAdminUserInfo().CurrentOrgId, patient_id, c.GetAdminUserInfo().AdminUser.Id, tmpstring, decimal) if errmsg != nil { c.ServeFailJsonSend(enums.ErrorCodeParamWrong, errmsg.Error()) //c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeCreateOrderException) return } } c.ServeSuccessJSON(map[string]interface{}{ "msg": "结算成功", }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAmountAccountException) return } } } func (c *ZHHisApiController) GetPreSettleInfo() { order_id, _ := c.GetInt64("order_id") patient_id, _ := c.GetInt64("patient_id") in_hospital_id, _ := c.GetInt64("in_hospital_id") admin_user_id, _ := c.GetInt64("admin_user_id") record, _ := service.GetInHospitalRecord(in_hospital_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) order, _ := service.GetHisOrderByID(order_id) var allTotal string if record.OutHospitalStatus == 0 && order.ID == 0 { orders, _ := service.GetHisOrderInfoByNumberFour(record.Number) var total float64 for _, item := range orders { total = total + item.DetItemFeeSumamt } allTotal = fmt.Sprintf("%.2f", total) } else { allTotal = fmt.Sprintf("%.2f", order.MedfeeSumamt) } var rf []*ResultFive json.Unmarshal([]byte(record.Iinfo), &rf) chrg_bchno := order.Number cert_no := record.Certno if record.ID == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } //if record.InHospitalStatus == 1 && record.OutHospitalStatus == 0 { // c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHospitalNoExistDataException) // return //} psn_info, _ := service.GetPsnByPatientId(patient_id) if record.IdCardType == 1 { bas := strings.Split(psn_info.CardInfo, "|") cardNumber := bas[2] cert_no = cardNumber } else if record.IdCardType == 4 { cert_no = psn_info.VerifyNumber } else { cert_no = record.Certno } var result string var src_resquest string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2303?psn_no=" + record.PsnNo + "&mdtrt_id=" + record.Number + "&chrg_bchno=" + chrg_bchno + "&insutype_type=" + record.InsutypeType + "&total=" + allTotal + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(record.IdCardType, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(record.Certificates, 10) + "&name=" + record.Name + "&cert_no=" + cert_no resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) }else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2303?psn_no=" + record.PsnNo + "&mdtrt_id=" + record.Number + "&chrg_bchno=" + chrg_bchno + "&insutype_type=" + record.InsutypeType + "&total=" + allTotal + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(record.IdCardType, 10) + "&card_sn=" + "" + "&certificates=" + strconv.FormatInt(record.Certificates, 10) + "&name=" + record.Name + "&cert_no=" + cert_no resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { if !strings.Contains(record.InsuplcAdmdvs, "3603") { if record.IdCardType == 1 { bas := strings.Split(psn_info.CardInfo, "|") //basNumber := bas[2] card_sn := bas[3] result, src_resquest = service.Jxyb2303(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey, card_sn, record.PsnType, record.PsnCertType, record.IdCardNo, record.Name) saveLog(result, src_resquest, "2303", "住院预结算") } }else{ result, src_resquest = service.Jxyb2303(record.PsnNo, record.Number, cert_no, record.InsutypeType, allTotal, record.Certificates, record.IdCardType, "", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey,"",record.PsnType,record.PsnCertType,record.IdCardNo,record.Name) saveLog(result, src_resquest, "2303", "住院预结算") } } else { if record.OutHospitalStatus == 1 && order.ID > 0 { //出院的情况下，再去做事中监测 result3101 := Check3102(c, record.PatientId, record.ID, admin_user_id, "8", order.ID) if result3101.Infcode == 0 { if len(result3101.Output.Result) > 0 { var errMsgs []string for _, item := range result3101.Output.Result { errMsgs = append(errMsgs, item.VolaCont) } c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": errMsgs, }) return } else { result, src_resquest = service.ZHGdyb2303(record.PsnNo, record.Number, chrg_bchno, cert_no, record.InsutypeType, allTotal, miConfig.OrgName, roles.UserName, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, "0", record.IdCardType, 0, 0, 0, 0, record.Certificates) saveLog(result, src_resquest, "2303", "住院预结算") } } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": result3101.ErrMsg, }) return } } else { result, src_resquest = service.ZHGdyb2303(record.PsnNo, record.Number, chrg_bchno, cert_no, record.InsutypeType, allTotal, miConfig.OrgName, roles.UserName, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, "0", record.IdCardType, 0, 0, 0, 0, record.Certificates) saveLog(result, src_resquest, "2303", "住院预结算") } } 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 res2 ResultSevenTwo var res ResultSeven var resSeven10265 ResultSeven10265 if miConfig.MdtrtareaAdmvs == "360399" { if err := json.Unmarshal(userJSONBytes, &res2); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res2.Infcode != 0 { errlog := &models.HisOrderError{ UserOrgId: c.GetAdminUserInfo().CurrentOrgId, Ctime: time.Now().Unix(), Mtime: time.Now().Unix(), Number: chrg_bchno, ErrMsg: res.ErrMsg, Status: 1, PatientId: patient_id, RecordTime: time.Now().Unix(), Stage: 6, } service.CreateErrMsgLog(errlog) c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) return } else { //order, _ := service.GetHisOrderTwo(adminUser.CurrentOrgId, chrg_bchno, id) order.OrderStatus = 1 order.MdtrtId = res2.Output.Setlinfo.MdtrtID order.SetlId = res2.Output.Setlinfo.SetlID order.PsnNo = res2.Output.Setlinfo.PsnNo order.PsnName = res2.Output.Setlinfo.PsnName order.PsnCertType = res2.Output.Setlinfo.PsnCertType order.Certno = res2.Output.Setlinfo.Certno order.Gend = res2.Output.Setlinfo.Gend order.Naty = res2.Output.Setlinfo.Naty val, _ := strconv.ParseFloat(res2.Output.Setlinfo.Age, 64) order.Age = val order.Insutype = res2.Output.Setlinfo.Insutype order.PsnType = res2.Output.Setlinfo.PsnType order.CvlservFlag = res2.Output.Setlinfo.CvlservFlag order.SetlTime = res2.Output.Setlinfo.SetlTime order.MdtrtCertType = res2.Output.Setlinfo.MdtrtCertType if res.Output.Setlinfo.MedType == "140104" { order.MedType = "14" } else { order.MedType = res2.Output.Setlinfo.MedType } order.MedfeeSumamt = res2.Output.Setlinfo.MedfeeSumamt order.FulamtOwnpayAmt = res2.Output.Setlinfo.FulamtOwnpayAmt order.OverlmtSelfPay = res2.Output.Setlinfo.OverlmtSelfpay order.PreselfpayAmt = res2.Output.Setlinfo.PreselfpayAmt order.InscpScpAmt = res2.Output.Setlinfo.InscpScpAmt order.ActPayDedc = res2.Output.Setlinfo.ActPayDedc order.HifmiPay = res2.Output.Setlinfo.HifmiPay order.HifpPay = res2.Output.Setlinfo.HifpPay order.HifesPay = res2.Output.Setlinfo.HifesPay order.HifobPay = res2.Output.Setlinfo.HifobPay order.MafPay = res2.Output.Setlinfo.MafPay order.OthPay = res2.Output.Setlinfo.OthPay order.CvlservPay = res2.Output.Setlinfo.CvlservPay order.PoolPropSelfpay = res2.Output.Setlinfo.PoolPropSelfpay order.FundPaySumamt = res2.Output.Setlinfo.FundPaySumamt order.PsnPartAmt = res2.Output.Setlinfo.PsnPartAmt order.AcctPay = res2.Output.Setlinfo.AcctPay order.PsnCashPay = res2.Output.Setlinfo.PsnCashPay order.HospPartAmt = res2.Output.Setlinfo.HospPartAmt order.Balc = res2.Output.Setlinfo.Balc order.AcctMulaidPay = res2.Output.Setlinfo.AcctMulaidPay order.MedinsSetlId = res2.Output.Setlinfo.MedinsSetlID order.ClrOptins = res2.Output.Setlinfo.ClrOptins order.ClrWay = res2.Output.Setlinfo.ClrWay order.Creator = order.Creator order.Modify = roles.AdminUserId order.RequestLog = src_resquest setlDetail, _ := json.Marshal(res2.Output.Setldetail) detailStr := string(setlDetail) order.SetlDetail = detailStr //err := service.UpdataOrderStatusTwo(chrg_bchno, c.GetAdminUserInfo().CurrentOrgId) if record.OutHospitalStatus == 1 && order.ID > 0 { err := service.UpDateOrder(order) if err == nil { c.ServeSuccessJSON(map[string]interface{}{ "msg": "预结算成功", "order_way": 1, }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAmountAccountException) return } } else if record.OutHospitalStatus == 0 && order.ID == 0 { var order models.HisOrder //order, _ := service.GetHisOrderTwo(adminUser.CurrentOrgId, chrg_bchno, id) order.OrderStatus = 1 order.MdtrtId = res2.Output.Setlinfo.MdtrtID order.SetlId = res2.Output.Setlinfo.SetlID order.PsnNo = res2.Output.Setlinfo.PsnNo order.PsnName = res2.Output.Setlinfo.PsnName order.PsnCertType = res2.Output.Setlinfo.PsnCertType order.Certno = res2.Output.Setlinfo.Certno order.Gend = res2.Output.Setlinfo.Gend order.Naty = res2.Output.Setlinfo.Naty val, _ := strconv.ParseFloat(res2.Output.Setlinfo.Age, 64) order.Age = val order.Insutype = res2.Output.Setlinfo.Insutype order.PsnType = res2.Output.Setlinfo.PsnType order.CvlservFlag = res2.Output.Setlinfo.CvlservFlag order.SetlTime = res2.Output.Setlinfo.SetlTime order.MdtrtCertType = res2.Output.Setlinfo.MdtrtCertType if res2.Output.Setlinfo.MedType == "140104" { order.MedType = "14" } else { order.MedType = res2.Output.Setlinfo.MedType } order.MedfeeSumamt = res2.Output.Setlinfo.MedfeeSumamt order.FulamtOwnpayAmt = res2.Output.Setlinfo.FulamtOwnpayAmt order.OverlmtSelfPay = res2.Output.Setlinfo.OverlmtSelfpay order.PreselfpayAmt = res2.Output.Setlinfo.PreselfpayAmt order.InscpScpAmt = res2.Output.Setlinfo.InscpScpAmt order.ActPayDedc = res2.Output.Setlinfo.ActPayDedc order.HifmiPay = res2.Output.Setlinfo.HifmiPay order.HifpPay = res2.Output.Setlinfo.HifpPay order.HifesPay = res2.Output.Setlinfo.HifesPay order.HifobPay = res2.Output.Setlinfo.HifobPay order.MafPay = res2.Output.Setlinfo.MafPay order.OthPay = res2.Output.Setlinfo.OthPay order.CvlservPay = res2.Output.Setlinfo.CvlservPay order.PoolPropSelfpay = res2.Output.Setlinfo.PoolPropSelfpay order.FundPaySumamt = res2.Output.Setlinfo.FundPaySumamt order.PsnPartAmt = res2.Output.Setlinfo.PsnPartAmt order.AcctPay = res2.Output.Setlinfo.AcctPay order.PsnCashPay = res2.Output.Setlinfo.PsnCashPay order.HospPartAmt = res2.Output.Setlinfo.HospPartAmt order.Balc = res2.Output.Setlinfo.Balc order.AcctMulaidPay = res2.Output.Setlinfo.AcctMulaidPay order.MedinsSetlId = res2.Output.Setlinfo.MedinsSetlID order.ClrOptins = res2.Output.Setlinfo.ClrOptins order.ClrWay = res2.Output.Setlinfo.ClrWay order.Creator = order.Creator order.Modify = roles.AdminUserId order.RequestLog = src_resquest setlDetail, _ := json.Marshal(res2.Output.Setldetail) detailStr := string(setlDetail) order.SetlDetail = detailStr c.ServeSuccessJSON(map[string]interface{}{ "msg": "预结算成功", "order": order, "order_way": 2, }) } } } else { if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resSeven10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resSeven10265.Infcode, 10, 64) res.Infcode = Infcode res.InfRefmsgid = resSeven10265.InfRefmsgid res.RespondTime = resSeven10265.RespondTime res.ErrMsg = resSeven10265.ErrMsg res.Output = resSeven10265.Output res.WarnMsg = resSeven10265.WarnMsg res.Cainfo = resSeven10265.Cainfo } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode != 0 { errlog := &models.HisOrderError{ UserOrgId: c.GetAdminUserInfo().CurrentOrgId, Ctime: time.Now().Unix(), Mtime: time.Now().Unix(), Number: chrg_bchno, ErrMsg: res.ErrMsg, Status: 1, PatientId: patient_id, RecordTime: time.Now().Unix(), Stage: 6, } service.CreateErrMsgLog(errlog) c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) return } else { //order, _ := service.GetHisOrderTwo(adminUser.CurrentOrgId, chrg_bchno, id) order.OrderStatus = 1 order.MdtrtId = res.Output.Setlinfo.MdtrtID order.SetlId = res.Output.Setlinfo.SetlID order.PsnNo = res.Output.Setlinfo.PsnNo order.PsnName = res.Output.Setlinfo.PsnName order.PsnCertType = res.Output.Setlinfo.PsnCertType order.Certno = res.Output.Setlinfo.Certno order.Gend = res.Output.Setlinfo.Gend order.Naty = res.Output.Setlinfo.Naty order.Age = res.Output.Setlinfo.Age order.Insutype = res.Output.Setlinfo.Insutype order.PsnType = res.Output.Setlinfo.PsnType order.CvlservFlag = res.Output.Setlinfo.CvlservFlag order.SetlTime = res.Output.Setlinfo.SetlTime order.MdtrtCertType = res.Output.Setlinfo.MdtrtCertType if res.Output.Setlinfo.MedType == "140104" { order.MedType = "14" } else { order.MedType = res.Output.Setlinfo.MedType } order.MedfeeSumamt = res.Output.Setlinfo.MedfeeSumamt order.FulamtOwnpayAmt = res.Output.Setlinfo.FulamtOwnpayAmt order.OverlmtSelfPay = res.Output.Setlinfo.OverlmtSelfpay order.PreselfpayAmt = res.Output.Setlinfo.PreselfpayAmt order.InscpScpAmt = res.Output.Setlinfo.InscpScpAmt order.ActPayDedc = res.Output.Setlinfo.ActPayDedc order.HifmiPay = res.Output.Setlinfo.HifmiPay order.HifpPay = res.Output.Setlinfo.HifpPay order.HifesPay = res.Output.Setlinfo.HifesPay order.HifobPay = res.Output.Setlinfo.HifobPay order.MafPay = res.Output.Setlinfo.MafPay order.OthPay = res.Output.Setlinfo.OthPay order.CvlservPay = res.Output.Setlinfo.CvlservPay order.PoolPropSelfpay = res.Output.Setlinfo.PoolPropSelfpay order.FundPaySumamt = res.Output.Setlinfo.FundPaySumamt order.PsnPartAmt = res.Output.Setlinfo.PsnPartAmt order.AcctPay = res.Output.Setlinfo.AcctPay order.PsnCashPay = res.Output.Setlinfo.PsnCashPay order.HospPartAmt = res.Output.Setlinfo.HospPartAmt order.Balc = res.Output.Setlinfo.Balc order.AcctMulaidPay = res.Output.Setlinfo.AcctMulaidPay order.MedinsSetlId = res.Output.Setlinfo.MedinsSetlID order.ClrOptins = res.Output.Setlinfo.ClrOptins order.ClrWay = res.Output.Setlinfo.ClrWay order.Creator = order.Creator order.Modify = roles.AdminUserId order.RequestLog = src_resquest setlDetail, _ := json.Marshal(res.Output.Setldetail) detailStr := string(setlDetail) order.SetlDetail = detailStr //err := service.UpdataOrderStatusTwo(chrg_bchno, c.GetAdminUserInfo().CurrentOrgId) if record.OutHospitalStatus == 1 && order.ID > 0 { err := service.UpDateOrder(order) if err == nil { c.ServeSuccessJSON(map[string]interface{}{ "msg": "预结算成功", "order_way": 1, }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAmountAccountException) return } } else if record.OutHospitalStatus == 0 && order.ID == 0 { c.ServeSuccessJSON(map[string]interface{}{ "msg": "预结算成功", "order": order, "order_way": 2, }) } } } } func (c *ZHHisApiController) GetUploadInfo() { 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, patientPrescription.Creator) //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"] = "" } else if record.InsutypeType == "310" { data["med_type"] = "" } } 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 = 10 var start int = 1 var stop int var pagecount int var curpage int var isSuccess bool = true var customs []*models.NewCustom var empty_code_errs []string for _, item := range prescriptions { if item.Type == 1 { //药品 for _, subItem := range item.HisDoctorAdviceInfo { if len(subItem.BaseDrugLib.MedicalInsuranceNumber) == 0 && subItem.Price > 0{ empty_code_errs = append(empty_code_errs,subItem.BaseDrugLib.DrugName) } } } 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 && subItem.Price > 0{ empty_code_errs = append(empty_code_errs,subItem.HisProject.ProjectName) } } else if subItem.Type == 3 { if len(subItem.GoodInfo.MedicalInsuranceNumber) == 0 && subItem.Price > 0 { empty_code_errs = append(empty_code_errs,subItem.GoodInfo.GoodName) } } } } } if len(empty_code_errs) > 0{ var err string for _, item := range empty_code_errs{ if len(err) == 0{ err = item }else{ err = err +"," + item } } c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": err +" "+ "没有填写国家编码", }) return } for _, item := range prescriptions { tm := time.Unix(item.PreTime, 0) if item.Type == 1 { //药品 for _, subItem := range item.HisDoctorAdviceInfo { //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"), DoctorId: item.Creator, } 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 { 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"), DoctorId: item.Creator, } customs = append(customs, cus) } else if subItem.Type == 3 { 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"), DoctorId: item.Creator, } 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 if miConfig.MdtrtareaAdmvs == "421182" { 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", miConfig.Url +"hbyb/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 if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2301(record.PsnNo, record.Number, customs[start-1:stop], data["med_type"].(string), chrg_bchno, department.Number, strconv.FormatInt(department.ID, 10), strconv.FormatInt(roles.AdminUserId, 10), miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2301", "上传明细") } else { fmt.Println("--------") fmt.Println(prescriptions) fmt.Println("--------") res3101 := Check3101(c, record.PatientId, record.ID, admin_user_id, "4", record_time, prescriptions) if res3101.Infcode == 0 { if len(res3101.Output.Result) > 0 { var errMsgs []string for _, item := range res3101.Output.Result { errMsgs = append(errMsgs, item.VolaCont) } c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": errMsgs, }) return } 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.UserName, doctor_info.DoctorNumber) saveLog(result, requestLog, "2301", "上传明细") } } else { c.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res3101.ErrMsg, }) return } } 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) ZHRefund() { order_id, _ := c.GetInt64("order_id") admin_user_id, _ := c.GetInt64("admin_user_id") adminUser := c.GetAdminUserInfo() var order models.HisOrder order, _ = service.GetHisOrderByID(order_id) record, _ := service.GetInHospitalRecordByNumber(order.MdtrtId) roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId) if config.IsOpen == 1 { //对接了医保，走医保流程 var result string var requestLog string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2305?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&setl_id=" + order.SetlId + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) //saveLog(result, requestLog, "2404", "入院登记撤销") saveLog(result, requestLog, "2305", "退费") } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2305?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&setl_id=" + order.SetlId + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result, requestLog, "2305", "退费") } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog := service.Jxyb2305(order.PsnNo, order.MdtrtId, order.SetlId, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2305", "退费") } else { result, requestLog := service.Gdyb2305(order.PsnNo, order.MdtrtId, order.SetlId, miConfig.OrgName, roles.UserName, miConfig.SecretKey, miConfig.Code, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs) saveLog(result, requestLog, "2305", "退费") } 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 ResultSixteen var resSixteen ResultSixteen10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resSixteen); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.Cainfo = resSixteen.Cainfo res.WarnMsg = resSixteen.WarnMsg res.Output = resSixteen.Output res.ErrMsg = resSixteen.ErrMsg res.RespondTime = resSixteen.RespondTime Infcode, _ := strconv.ParseInt(resSixteen.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 { err := service.UpdataOrderStatusThree(order_id, order.Number, adminUser.CurrentOrgId, "", result) //不同地区退费流程不一样，肇庆那边退费就包括撤销出院，内蒙古退费不包括撤销明细，所以下面需要根据不同情况进行判断 if miConfig.UserOrgId == 10215 { record.OutHospitalStatus = 0 service.CreateHospitalRecord(&record) } service.UpdataOrderStatusByNumber(record.Number) if err == nil { ////当押金不为零时产生退费记录 if order.Decimal != 0 { tmp := strconv.FormatInt(order.ID, 10) err = service.MoneyIncrease(adminUser.CurrentOrgId, order.PatientId, tmp, order.Decimal) if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } c.ServeSuccessJSON(map[string]interface{}{ "msg": "退费成功", }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } else { c.ServeSuccessJSON(map[string]interface{}{ "code": -10, "msg": res.ErrMsg, }) } } else { err := service.UpdataOrderStatus(order_id, order.Number, adminUser.CurrentOrgId, "", "") if err == nil { c.ServeSuccessJSON(map[string]interface{}{ "msg": "退费成功", }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } } func (c *ZHHisApiController) ZHRefundDetail() { patient_id, _ := c.GetInt64("patient_id") his_patient_id, _ := c.GetInt64("his_patient_id") record_time := c.GetString("record_time") settle_accounts_type, _ := c.GetInt64("settle_accounts_type") //order_id, _ := c.GetInt64("order_id") 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() theTimeTwo, err := time.ParseInLocation(timeLayout+" 15:04:05", record_time+" 23:59:59", loc) if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong) return } recordDateTimeTwo := theTimeTwo.Unix() //var prescriptions []*models.HisPrescription miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId) roles, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id) if settle_accounts_type == 1 { //日结 record, _ := service.GetInHospitalRecord(his_patient_id) infos, _ := service.GetZHHisUploadOrderInfo(adminUser.CurrentOrgId, patient_id, recordDateTime, recordDateTimeTwo, record.Number) var isSuccess bool = true for _, item := range infos { var result string var requestLog string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&feedetl_sn=" + item.FeedetlSn + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=" + "1" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result, requestLog, "2302", "日结退明细") } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&feedetl_sn=" + item.FeedetlSn + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=" + "1" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result, requestLog, "2302", "日结退明细") } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog := service.Jxyb2302(record.PsnNo, record.Number, 1, item.FeedetlSn, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2302", "日结退明细") } else { result, requestLog := service.Gdyb2302(record.PsnNo, record.Number, miConfig.OrgName, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, miConfig.Code, item.FeedetlSn, 1) saveLog(result, requestLog, "2302", "日结退明细") } 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 res2 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res2.Infcode = Infcode res2.RespondTime = resEmpty10265.RespondTime res2.ErrMsg = resEmpty10265.ErrMsg res2.Output = resEmpty10265.Output res2.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res2); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res2.Infcode == -1 { isSuccess = false } } if isSuccess { err := service.UpDateOrderInfoStatus(patient_id, recordDateTime, adminUser.CurrentOrgId, recordDateTimeTwo) if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } err1 := service.UpDatePrescriptionOrderStatusTwo(patient_id, recordDateTime, adminUser.CurrentOrgId) if err1 != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } c.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销明细成功", }) } } else { //prescriptions, _ = service.GetZHMonthHisUploadPrescription(adminUser.CurrentOrgId, patient_id, recordDateTime) //var order models.HisOrder //order, _ = service.GetHisOrderByID(order_id) //record, _ := service.GetInHospitalRecordByNumber(order.MdtrtId) var result string var requestLog string record, _ := service.GetInHospitalRecord(his_patient_id) config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId) if config.IsOpen == 1 { //对接了医保，走医保流程 if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&number=0000" + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=" + "0" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) //saveLog(result, requestLog, "2302", "日结退明细") } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&number=0000" + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=" + "0" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) //saveLog(result, requestLog, "2302", "日结退明细") } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2302(record.PsnNo, record.Number, 0, "0000", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2302", "月结退明细") } else { result, requestLog = service.Gdyb2302(record.PsnNo, record.Number, miConfig.OrgName, roles.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, miConfig.Code, "0000", 0) saveLog(result, requestLog, "2302", "月结退明细") } 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 res2 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res2.Infcode = Infcode res2.RespondTime = resEmpty10265.RespondTime res2.ErrMsg = resEmpty10265.ErrMsg res2.Output = resEmpty10265.Output res2.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res2); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res2.Infcode == 0 { err := service.UpdataHospitalOrderStatus(record.Number, adminUser.CurrentOrgId) if err == nil { c.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销明细成功", }) } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } else { c.ServeSuccessJSON(map[string]interface{}{ "code": -10, "msg": res2.ErrMsg, }) } } } } func (this *ZHHisApiController) GetZHOutHospitalUnCheck() { id, _ := this.GetInt64("id") admin_user_id, _ := this.GetInt64("admin_user_id") adminInfo := this.GetAdminUserInfo() miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId) role, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, admin_user_id) record, _ := service.GetInHospitalRecord(id) if record.ID == 0 { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeInHospitalNoExistDataException) return } var result string var requestLog string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2405?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey fmt.Println(api) resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2405?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey fmt.Println(api) resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2405(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2405", "出院登记撤销") } else { result, requestLog = service.ZHGdyb2405(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs) saveLog(result, requestLog, "2405", "出院登记撤销") } 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 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res.Infcode = Infcode res.RespondTime = resEmpty10265.RespondTime res.ErrMsg = resEmpty10265.ErrMsg res.Output = resEmpty10265.Output res.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode == 0 { record.OutHospitalStatus = 0 service.CreateHospitalRecord(&record) service.UpdataOrderStatusByNumber(record.Number) this.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销出院成功", }) } else { this.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } } func (this *ZHHisApiController) GetZHInHospitalUnCheck() { id, _ := this.GetInt64("id") admin_user_id, _ := this.GetInt64("admin_user_id") adminInfo := this.GetAdminUserInfo() miConfig, _ := service.FindMedicalInsuranceInfo(adminInfo.CurrentOrgId) role, _ := service.GetAdminUserInfoByID(adminInfo.CurrentOrgId, admin_user_id) record, _ := service.GetInHospitalRecord(id) if record.ID == 0 { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeInHospitalNoExistDataException) return } var result string var requestLog string orders, _ := service.GetHisOrderInfoByNumber(record.Number) if len(orders) > 0 { //判断是否上传过明细，有的话需要退明细，后撤销入院 if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&number=" + "0000" + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=0" resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result, requestLog, "2302", "月结退明细") }else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2302?psn_no=" + record.PsnNo + "&mdtrtId=" + record.Number + "&number=" + "0000" + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&refund_type=0" resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) saveLog(result, requestLog, "2302", "月结退明细") } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2302(record.PsnNo, record.Number, 0, "0000", miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2302", "月结退明细") } else { result, requestLog = service.Gdyb2302(record.PsnNo, record.Number, miConfig.OrgName, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, miConfig.Code, "0000", 0) saveLog(result, requestLog, "2302", "月结退明细") } 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 res2 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res2.Infcode = Infcode res2.RespondTime = resEmpty10265.RespondTime res2.ErrMsg = resEmpty10265.ErrMsg res2.Output = resEmpty10265.Output res2.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res2); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res2.Infcode == 0 { service.UpdataHospitalOrderStatus(record.Number, adminInfo.CurrentOrgId) var result string var requestLog string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2404?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2404?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2404(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2404", "入院登记撤销") } else { result, requestLog = service.ZHGdyb2404(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs) saveLog(result, requestLog, "2404", "入院登记撤销") } 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 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res.Infcode = Infcode res.RespondTime = resEmpty10265.RespondTime res.ErrMsg = resEmpty10265.ErrMsg res.Output = resEmpty10265.Output res.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode == 0 { record.Status = 0 service.CreateHospitalRecord(&record) this.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销入院成功", }) } else { this.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } } else { this.ServeSuccessJSON(map[string]interface{}{ "code": -10, "msg": res2.ErrMsg, }) } } else { //没有上传过明细的，直接撤销入院 var result string var requestLog string if miConfig.MdtrtareaAdmvs == "150499" { //请求内网数据 api := "http://172.16.13.254:9532/" + "nmyb/2404?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "421182" { //请求内网数据 api := miConfig.Url + "hbyb/2404?mdtrt_id=" + record.Number + "&psn_no=" + record.PsnNo + "&org_name=" + miConfig.OrgName + "&doctor=" + role.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + record.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey resp, requestErr := http.Get(api) if requestErr != nil { this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result_byte, _ := json.Marshal(respJSON) result = string(result_byte) } else if miConfig.MdtrtareaAdmvs == "360399" { result, requestLog = service.Jxyb2404(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.Url, "", miConfig.AccessKey) saveLog(result, requestLog, "2404", "入院登记撤销") } else { result, requestLog = service.ZHGdyb2404(record.Number, record.PsnNo, miConfig.SecretKey, miConfig.OrgName, miConfig.Code, role.UserName, record.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs) saveLog(result, requestLog, "2404", "入院登记撤销") } 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 ResultEmpty var resEmpty10265 ResultEmpty10265 if miConfig.Code == "H15049901371" { if err := json.Unmarshal(userJSONBytes, &resEmpty10265); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } Infcode, _ := strconv.ParseInt(resEmpty10265.Infcode, 10, 64) res.Infcode = Infcode res.RespondTime = resEmpty10265.RespondTime res.ErrMsg = resEmpty10265.ErrMsg res.Output = resEmpty10265.Output res.WarnMsg = resEmpty10265.WarnMsg } else { if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } } if res.Infcode == 0 { record.Status = 0 service.CreateHospitalRecord(&record) this.ServeSuccessJSON(map[string]interface{}{ "msg": "撤销入院成功", }) } else { this.ServeSuccessJSON(map[string]interface{}{ "failed_code": -10, "msg": res.ErrMsg, }) } } } func saveLog(result string, request string, infno string, desc string) { org_id, _ := beego.AppConfig.Int64("org_id") miConfig, _ := service.FindMedicalInsuranceInfo(org_id) dir := miConfig.OrgName + "日志" utils.Mkdir(dir) month := time.Unix(1557042972, 0).Format("1") year := time.Now().Format("2006") month = time.Now().Format("01") day := time.Now().Format("02") hour := time.Now().Format("15") min := time.Now().Format("04") sec := time.Now().Format("05") result_time := year + "-" + month + "-" + day + " " + hour + ":" + min + ":" + sec file := strconv.FormatInt(org_id, 10) + "_" + year + month + day + "_log" file_name := file + ".txt" file_path := miConfig.OrgName + "日志" + "/" + file_name exist, _ := utils.PathExists(file_path) if exist { //存在 fmt.Println("存在") f, err := os.OpenFile(file_path, os.O_WRONLY, 0644) if err != nil { fmt.Println("read fail") } content := "\r\n" + "\r\n" + "\r\n" + result_time + " " + "【 " + desc + infno + "入参" + " 】：" + "\r\n" + request + "\r\n" + result_time + " " + "【 " + desc + infno + "出参" + " 】：" + "\r\n" + result n, _ := f.Seek(0, 2) _, err = f.WriteAt([]byte(content), n) } else { //不存在 fmt.Println("文件不存在，创建文件") f, err := os.Create(miConfig.OrgName + "日志" + "/" + file_name) defer f.Close() if err != nil { } else { _, err = f.Write([]byte("记录日志")) } } } type Charset string const ( UTF8 = Charset("UTF-8") GB18030 = Charset("GB18030") ) func ConvertToString(src string, srcCode string, tagCode string) string { srcCoder := mahonia.NewDecoder(srcCode) srcResult := srcCoder.ConvertString(src) tagCoder := mahonia.NewDecoder(tagCode) _, cdata, _ := tagCoder.Translate([]byte(srcResult), true) result := string(cdata) return result } type ELeData struct { Data struct { IdNo string `json:"idNo"` IdType string `json:"idType"` UserName string `json:"userName"` EcToken string `json:"ecToken"` InsuOrg string `json:"insuOrg"` Gender string `json:"gender"` Birthday string `json:"birthday"` Nationality string `json:"nationality"` Email string `json:"email"` Extra string `json:"extra"` } `json:"data"` Code int `json:"code"` Message string `json:"message"` } var initFlagTwo int64 = 0 func (c *ZHHisApiController) TestGetJiangXiBasBaseInit() { DllDef := syscall.MustLoadDLL("SSCard.dll") Iinit := DllDef.MustFindProc("Init") //miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) //http://10.77.211.236/CSB/hsa-fsi-1303 ret, _, err := Iinit.Call(StrPtr("http://10.77.224.18:9001/1.0.0/agent-card-init"), StrPtr("360399")) if ret != 0 { fmt.Println("SSCard的报错原因:", err) fmt.Println("SSCard的运算结果为:", ret) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException) return } result := int(ret) fmt.Println("SSCard的运算结果为1:", result) initFlag = 1 return } func (c *ZHHisApiController) GetBasBaseInfoxxx() string { DllDef := syscall.MustLoadDLL("SSCard.dll") readCard := DllDef.MustFindProc("ReadCardBas") if readCard == nil { fmt.Println("readcard is nil") readCard = DllDef.MustFindProc("ReadCardBas") } str := make([]byte, 1024) str1 := make([]byte, 1024) ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&str[0])), uintptr(1024), (uintptr)(unsafe.Pointer(&str1[0])), uintptr(1024)) fmt.Println(string(str1)) fmt.Println(string(str)) fmt.Println(":", ConvertToString(string(str1), "gbk", "utf-8")) fmt.Println(":", ConvertToString(string(str), "gbk", "utf-8")) if ret2 != 0 { return "" } return string(str) } func (c *ZHHisApiController) ReadEleCardfordevice() { admin_user_id, _ := c.GetInt64("admin_user_id") roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) GetjxELekeyInfo(miConfig.Code, "1", roles.UserName) } func (c *ZHHisApiController) ReadCard() { id_card_type, _ := c.GetInt64("id_card_type") admin_user_id, _ := c.GetInt64("admin_user_id") is_settle := c.GetString("is_settle") roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) switch id_card_type { case 1: //社保卡 if miConfig.MdtrtareaAdmvs == "150499" { var api string api = "http://172.16.13.254:9532/" + "nmyb/readcard?" + "fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&cainfo=" + miConfig.Cainfo + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&operator_id=" + strconv.FormatInt(admin_user_id, 10) + "&operator=" + roles.UserName fmt.Println(api) 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 } var status string status = respJSON["data"].(map[string]interface{})["status"].(string) card_type := respJSON["data"].(map[string]interface{})["type"].(string) //console.log() fmt.Println("type===") fmt.Println(card_type) var token string var res ResultTwo //1101结果 var res10265 ResultTwo10265 //1101结果 var card_info string //卡信息 var busi_card_info string card_info = respJSON["data"].(map[string]interface{})["card_info"].(string) busi_card_info = respJSON["data"].(map[string]interface{})["busi_card_info"].(string) if status == "0" { //读卡成功 if card_type == "1" { respJSON = respJSON["data"].(map[string]interface{})["result"].(map[string]interface{}) result, _ := json.Marshal(respJSON) if err := json.Unmarshal([]byte(result), &res10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.ErrMsg = res10265.ErrMsg infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64) res.Infcode = infocode res.Output = res10265.Output res.InfRefmsgid = res10265.InfRefmsgid } else { //var card_info string //卡信息 //var busi_card_info string token = respJSON["data"].(map[string]interface{})["token"].(string) //busi_card_info = respJSON["data"].(map[string]interface{})["busi_card_info"].(string) //fmt.Println(card_info) //fmt.Println(busi_card_info) respJSON = respJSON["data"].(map[string]interface{})["result"].(map[string]interface{}) result, _ := json.Marshal(respJSON) if err := json.Unmarshal([]byte(result), &res10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.ErrMsg = res10265.ErrMsg infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64) res.Infcode = infocode res.Output = res10265.Output res.InfRefmsgid = res10265.InfRefmsgid } if res.Infcode == 0 { var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } patient, err := service.GetPatientByIDCard(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { if card_type == "1" { bas := strings.Split(card_info, "|") basNumber := bas[2] Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: card_info, VerifyNumber: busi_card_info, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": basNumber, "info": res, "insutype": insutype, }) } else { Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: card_info, VerifyNumber: token, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": token, "info": res, "insutype": insutype, }) } } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } else { //读卡失败 c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } else if miConfig.MdtrtareaAdmvs == "421182" { var res ResultTwohb api := miConfig.Url + "hbyb/1101?cert_no=" + "" + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=1" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result, _ := json.Marshal(respJSON) fmt.Println("log") fmt.Println(string(result)) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByIDCard(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { var insuplc_admdvs_temp string var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } for _, item := range insutypes { if item == insutype { insuplc_admdvs_temp = item } } //insuplcAdmdvs := strconv.Itoa(insuplc_admdvs_temp) card_info_two := insuplc_admdvs_temp + "|" + res.Output.Baseinfo.Certno + "|" + res.Output.Baseinfo.ExpContent.MdtrtCertNo Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, InsuplcAdmdvs: insuplc_admdvs_temp, CardInfo:card_info_two, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": res.Output.Baseinfo.Certno, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } else if miConfig.MdtrtareaAdmvs == "360399" { fmt.Println(initFlag) fmt.Println("initFlag") if initFlag == 0 { c.TestGetJiangXiBasBaseInit() } basStr := c.GetBasBaseInfoxxx() if len(basStr) == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException) return } fmt.Println(basStr) bas := strings.Split(basStr, "|") basNumber := bas[1] fmt.Println(basNumber) card_sn := bas[3] fmt.Println(card_sn) result, _ := service.Jxyb1101(basNumber, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, card_sn, "1", miConfig.Url, miConfig.AccessKey, "") //result := service.Jxyb1101(basNumber, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, card_sn, certificates) var dat map[string]interface{} if err := json.Unmarshal([]byte(result), &dat); err == nil { fmt.Println(dat) } else { fmt.Println(err) } userJSONBytes, _ := json.Marshal(dat) var res ResultTwo if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByNumber(basNumber, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: basStr, VerifyNumber: "", } service.CreateHisPsn(psn) var rf []*ResultFive json.Unmarshal([]byte(infoStr), &rf) var insutypes []*ResultFive var insutype string var is390 int = 0 var is310 int = 0 for _, item := range rf { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item) } } if len(insutypes) == 1 { insutype = insutypes[0].Insutype //insuplc_admdvs = insutypes[0].InsuplcAdmdvs } else { for _, i := range insutypes { if i.Insutype == "390" { is390 = 1 } if i.Insutype == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": basNumber, "info": res, "insutype": insutype, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } else { if initFlagTwo == 0 { c.TestGetBasBaseInitTwo() } basStr := c.GetBasBaseInfoTwo() if len(basStr) == 0 { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException) return } fmt.Println(basStr) bas := strings.Split(basStr, "|") id_card_no := bas[1] result, _ := service.ZHGdyb1101B(id_card_no, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, 1, "", 1, "") //result := service.Gdyb1101B(basNumber, miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, id_card_type, card_sn, certificates) var dat map[string]interface{} if err := json.Unmarshal([]byte(result), &dat); err == nil { fmt.Println(dat) } else { fmt.Println(err) } userJSONBytes, _ := json.Marshal(dat) var res ResultTwo if err := json.Unmarshal(userJSONBytes, &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByNumber(id_card_no, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: basStr, VerifyNumber: "", } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": id_card_no, "info": res, "insutype": insutype, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } break case 2: if miConfig.MdtrtareaAdmvs == "421182" { var res ResultTwohb api := miConfig.Url + "hbyb/1101?cert_no=" + "" + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=1" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result, _ := json.Marshal(respJSON) fmt.Println("log") fmt.Println(string(result)) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByIDCard(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { var insuplc_admdvs_temp string var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } for _, item := range insutypes { if item == insutype { insuplc_admdvs_temp = item } } //insuplcAdmdvs := strconv.Itoa(insuplc_admdvs_temp) card_info_two := insuplc_admdvs_temp + "|" + res.Output.Baseinfo.Certno + "|" + res.Output.Baseinfo.ExpContent.MdtrtCertNo Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, InsuplcAdmdvs: insuplc_admdvs_temp, CardInfo:card_info_two, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": res.Output.Baseinfo.Certno, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } case 4: //电子凭证 if miConfig.MdtrtareaAdmvs == "150499" { var api string api = "http://172.16.13.254:9532/" + "nmyb/readcard?" + "fixmedins_code=" + miConfig.Code + "&secret_key=" + miConfig.SecretKey + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&url=" + miConfig.Url + "&cainfo=" + miConfig.Cainfo + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&operator_id=" + strconv.FormatInt(admin_user_id, 10) + "&operator=" + roles.UserName + "&is_settle=" + is_settle 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 } var status string status = respJSON["data"].(map[string]interface{})["status"].(string) //card_type := respJSON["data"].(map[string]interface{})["type"].(string) var token string var res ResultTwo //1101结果 var res10265 ResultTwo10265 //1101结果 if status == "0" { //读卡成功 token = respJSON["data"].(map[string]interface{})["token"].(string) respJSON = respJSON["data"].(map[string]interface{})["result"].(map[string]interface{}) result, _ := json.Marshal(respJSON) if err := json.Unmarshal([]byte(result), &res10265); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } res.ErrMsg = res10265.ErrMsg infocode, _ := strconv.ParseInt(res10265.Infcode, 10, 64) res.Infcode = infocode res.Output = res10265.Output res.InfRefmsgid = res10265.InfRefmsgid if res.Infcode == 0 { patient, err := service.GetPatientByNumber(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: "", VerifyNumber: token, } service.CreateHisPsn(psn) var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "390" } c.ServeSuccessJSON(map[string]interface{}{ "failed_code": 0, "info": res, "insutype": insutype, "patient": patient, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } } else if miConfig.MdtrtareaAdmvs == "421182" { var res ResultTwohb api := miConfig.Url + "hbyb/1101?cert_no=" + "" + "&org_name=" + miConfig.OrgName + "&doctor=" + roles.UserName + "&fixmedins_code=" + miConfig.Code + "&insuplc_admdvs=" + miConfig.InsuplcAdmdvs + "&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs + "&secret_key=" + miConfig.SecretKey + "&id_card_type=" + strconv.FormatInt(id_card_type, 10) + "&card_sn=" + "" + "&certificates=1" resp, requestErr := http.Get(api) if requestErr != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } body, ioErr := ioutil.ReadAll(resp.Body) if ioErr != nil { utils.ErrorLog("接口返回数据读取失败: %v", ioErr) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } respJSON = respJSON["data"].(map[string]interface{})["pre"].(map[string]interface{}) result, _ := json.Marshal(respJSON) fmt.Println("log") fmt.Println(string(result)) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByIDCard(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { var insuplc_admdvs_temp string var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } for _, item := range insutypes { if item == insutype { insuplc_admdvs_temp = item } } //insuplcAdmdvs := strconv.Itoa(insuplc_admdvs_temp) card_info_two := insuplc_admdvs_temp + "|" + res.Output.Baseinfo.Certno + "|" + res.Output.Baseinfo.ExpContent.MdtrtCertNo Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, InsuplcAdmdvs: insuplc_admdvs_temp, CardInfo:card_info_two, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": res.Output.Baseinfo.Certno, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } else if miConfig.MdtrtareaAdmvs =="360399"{ //if initFlag == 0 { //c.TestGetJiangXiBasBaseInit() //} //if initEleFlag == 0 { // GetJxEleBaseInitInfo(c.GetAdminUserInfo().CurrentOrgId) //} //_, result2 := GetjxELekeyInfo(miConfig.Code, "1", roles.UserName) _, result := GetjxELeInfoaaa(miConfig.Code, "1", roles.UserName) //json_result := GetJxEleBaseInfo(c.GetAdminUserInfo().CurrentOrgId) type ELeData struct { Data struct { IdNo string `json:"idNo"` IdType string `json:"idType"` UserName string `json:"userName"` EcToken string `json:"ecToken"` InsuOrg string `json:"insuOrg"` Gender string `json:"gender"` Birthday string `json:"birthday"` Nationality string `json:"nationality"` Email string `json:"email"` Extra string `json:"extra"` } `json:"data"` Code int `json:"code"` Message string `json:"message"` } var ele ELeData err := json.Unmarshal([]byte(result), &ele) if err != nil { utils.ErrorLog("解析失败：%v", err) } token := ele.Data.EcToken token = Remove0000(token) result2, requestLog2 := service.Jxyb1101ForEleCert(miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, miConfig.Url, miConfig.AccessKey, token, "", ele.Data.IdNo, ele.Data.UserName) saveLog(result2, requestLog2, "1101", "获取人员信息") var res ResultTwo if err := json.Unmarshal([]byte(result2), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByNumber(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: "", VerifyNumber: token, } service.CreateHisPsn(psn) var rf []*ResultFive json.Unmarshal([]byte(infoStr), &rf) var insutypes []*ResultFive var insutype string var is390 int = 0 var is310 int = 0 for _, item := range rf { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item) } } if len(insutypes) == 1 { insutype = insutypes[0].Insutype //insuplc_admdvs = insutypes[0].InsuplcAdmdvs } else { for _, i := range insutypes { if i.Insutype == "390" { is390 = 1 } if i.Insutype == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": token, "info": res, "insutype": insutype, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } }else { if initFlagTwo == 0 { c.TestGetBasBaseInitTwo() } token := c.GetEleBaseInfoTwo() token = Remove0000(token) result2, requestLog2 := service.Gdyb1101ForEleCert(miConfig.OrgName, roles.UserName, miConfig.Code, miConfig.InsuplcAdmdvs, miConfig.MdtrtareaAdmvs, miConfig.SecretKey, token, "", "") saveLog(result2, requestLog2, "1101", "获取人员信息") // var res ResultTwo if err := json.Unmarshal([]byte(result2), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } if res.Infcode == 0 { patient, err := service.GetPatientByNumber(res.Output.Baseinfo.Certno, c.GetAdminUserInfo().CurrentOrgId) if err == gorm.ErrRecordNotFound { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNoPateintException) return } else if err != nil { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError) return } else { var insutypes []string var insutype string var is390 int = 0 var is310 int = 0 for _, item := range res.Output.Iinfo { if (item.Insutype == "390" && item.PsnInsuStas == "1") || (item.Insutype == "310" && item.PsnInsuStas == "1") { insutypes = append(insutypes, item.Insutype) } } if len(insutypes) == 1 { insutype = insutypes[0] } else { for _, i := range insutypes { if i == "390" { is390 = 1 } if i == "310" { is310 = 1 } } } if is390 == 1 { insutype = "390" } if is310 == 1 { insutype = "310" } if len(insutypes) == 0 { insutype = "310" } Iinfos, _ := json.Marshal(res.Output.Iinfo) Idetinfos, _ := json.Marshal(res.Output.Idetinfo) infoStr := string(Iinfos) idetinfoStr := string(Idetinfos) psn := &models.HisPsn{ PsnNo: res.Output.Baseinfo.PsnNo, Age: res.Output.Baseinfo.Age, PatientId: patient.ID, Certno: res.Output.Baseinfo.Certno, Gend: res.Output.Baseinfo.Gend, Naty: res.Output.Baseinfo.Naty, PsnCertType: res.Output.Baseinfo.PsnCertType, PsnName: res.Output.Baseinfo.PsnName, Idetinfo: idetinfoStr, Insuinfo: infoStr, UserOrgId: c.GetAdminUserInfo().CurrentOrgId, CardInfo: "", VerifyNumber: token, } service.CreateHisPsn(psn) c.ServeSuccessJSON(map[string]interface{}{ "patient": patient, "number": token, "info": res, "insutype": insutype, }) } } else { c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeHisFailedException) return } } break } } func GetjxELekeyInfo(code string, operator_id string, operator_name string) (string, string) { // WebSocket服务器地址 serverURL := "ws://127.0.0.1:8899" // 解析WebSocket服务器地址 u, err := url.Parse(serverURL) if err != nil { } // 建立WebSocket连接 conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil) if err != nil { } defer conn.Close() input2 := make(map[string]interface{}) input := make(map[string]interface{}) inputData := make(map[string]interface{}) inputData["orgId"] = code inputData["businessType"] = "01101" inputData["operatorId"] = operator_id inputData["operatorName"] = operator_name inputData["officeId"] = "001" inputData["officeName"] = "血透室" inputData["deviceType"] = "" input["data"] = inputData input["orgId"] = code input["transType"] = "ec.query" //if md == "" input2["url"] = "http://10.77.211.236/1.0.0/getEncDynamicKey" input2["indata"] = input fmt.Println(input2) bytesData, _ := json.Marshal(input2) err = conn.WriteMessage(websocket.TextMessage, bytesData) if err != nil { fmt.Println(err) } // 接收消息 _, receivedMessage, err := conn.ReadMessage() if err != nil { fmt.Println(err) } return "", string(receivedMessage) } func GetjxELeInfoaaa(code string, operator_id string, operator_name string) (string, string) { // WebSocket服务器地址 serverURL := "ws://127.0.0.1:8899" // 解析WebSocket服务器地址 u, err := url.Parse(serverURL) if err != nil { } // 建立WebSocket连接 conn, _, err := websocket.DefaultDialer.Dial(u.String(), nil) if err != nil { } defer conn.Close() input2 := make(map[string]interface{}) input := make(map[string]interface{}) inputData := make(map[string]interface{}) inputData["orgId"] = code inputData["businessType"] = "01103" inputData["operatorId"] = operator_id inputData["operatorName"] = operator_name inputData["officeId"] = "001" inputData["officeName"] = "血透室" inputData["deviceType"] = "" input["data"] = inputData input["orgId"] = code input["transType"] = "ec.query" //if md == input2["url"] = "http://10.77.211.236/1.0.0/localQrCodeQuery" input2["indata"] = input fmt.Println(input2) bytesData, _ := json.Marshal(input2) err = conn.WriteMessage(websocket.TextMessage, bytesData) if err != nil { fmt.Println(err) } // 接收消息 _, receivedMessage, err := conn.ReadMessage() if err != nil { fmt.Println(err) } return "", string(receivedMessage) } func (c *ZHHisApiController) GetEleBaseInfoTwo() string { DllDef := syscall.MustLoadDLL("SSCard.dll") readCard := DllDef.MustFindProc("GetQRBase") fmt.Println(readCard) if readCard == nil { fmt.Println("readcard is nil") readCard = DllDef.MustFindProc("GetQRBase") } str := make([]byte, 1024) str1 := make([]byte, 1024) ret2, _, _ := readCard.Call(uintptr(180), (uintptr)(unsafe.Pointer(&str[0])), uintptr(1024), (uintptr)(unsafe.Pointer(&str1[0])), uintptr(1024)) fmt.Println(ret2) fmt.Println(string(str1)) fmt.Println(string(str)) fmt.Println(":", ConvertToString(string(str1), "gbk", "utf-8")) fmt.Println(":", ConvertToString(string(str), "gbk", "utf-8")) if ret2 != 0 { return "" } return string(str) } func (c *ZHHisApiController) TestGetBasBaseInitTwo() { DllDef := syscall.MustLoadDLL("SSCard.dll") Iinit := DllDef.MustFindProc("Init") miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) ret, _, err := Iinit.Call(StrPtr("http://igb.hsa.gdgov.cn/gdyb_api/prd/api/card/initDll"), StrPtr(miConfig.MdtrtareaAdmvs)) if ret != 0 { fmt.Println("SSCard的报错原因:", err) fmt.Println("SSCard的运算结果为:", ret) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException) return } result := int(ret) fmt.Println("SSCard的运算结果为1:", result) initFlagTwo = 1 return } func (c *ZHHisApiController) GetBasBaseInfoTwo() string { DllDef := syscall.MustLoadDLL("SSCard.dll") readCard := DllDef.MustFindProc("ReadCardBas") if readCard == nil { fmt.Println("readcard is nil") readCard = DllDef.MustFindProc("ReadCardBas") } str := make([]byte, 1024) str1 := make([]byte, 1024) ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&str[0])), uintptr(1024), (uintptr)(unsafe.Pointer(&str1[0])), uintptr(1024)) fmt.Println(string(str1)) fmt.Println(string(str)) fmt.Println(":", ConvertToString(string(str1), "gbk", "utf-8")) fmt.Println(":", ConvertToString(string(str), "gbk", "utf-8")) if ret2 != 0 { return "" } return string(str) } var initFlag int64 = 0 func (c *ZHHisApiController) TestGetBasBaseInit() { DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll") Iinit := DllDef.MustFindProc("Init") //miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) str := make([]byte, 2048) inputData := make(map[string]interface{}) inputData["IP"] = "10.144.211.75" inputData["PORT"] = 7021 inputData["TIMEOUT"] = 180 inputData["LOG_PATH"] = "C:\\log\\" //inputData["SFZ_DRIVER_TYPE"] = 0 inputData["URL"] = "/call1" bytesData, _ := json.Marshal(inputData) fmt.Println(inputData) fmt.Println(bytesData) ret, _, err := Iinit.Call((uintptr)(unsafe.Pointer(&bytesData[0])), (uintptr)(unsafe.Pointer(&str[0]))) if ret != 0 { fmt.Println("SSCard的报错原因:", err) fmt.Println("SSCard的运算结果为:", ret) fmt.Println("SSCard的返回结果为:", string(str)) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeReadCardException) return } fmt.Println("SSCard的返回结果为:", string(str)) result := int(ret) fmt.Println("SSCard的运算结果为1:", result) //initFlag = 1 return } func (c *ZHHisApiController) GetSFZBaseInfo() string { DllDef := syscall.MustLoadDLL("SSCard.dll") readCard := DllDef.MustFindProc("ReadSFZ") if readCard == nil { fmt.Println("readcard is nil") readCard = DllDef.MustFindProc("ReadSFZ") } str := make([]byte, 256) str1 := make([]byte, 256) r, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&str[0])), IntPtr(1024), (uintptr)(unsafe.Pointer(&str1[0])), IntPtr(1024)) fmt.Println(r) return string(str) } func (c *ZHHisApiController) GetBasBaseInfo(fixmedins_code string, mdtrtarea_admvs string, opter_name string, opter_id string, fixmedins_name string) string { DllDef := syscall.MustLoadDLL("HeaSecReadInfo.dll") readCard := DllDef.MustFindProc("ReadCardBas") fmt.Println(readCard) fmt.Println("!!!!!") month := time.Unix(1557042972, 0).Format("1") year := time.Now().Format("2006") month = time.Now().Format("01") day := time.Now().Format("02") hour := time.Now().Format("15") min := time.Now().Format("04") sec := time.Now().Format("05") msec := time.Now().Format("000") timestamp := time.Now().Unix() tempTime := time.Unix(timestamp, 0) //timeFormat := tempTime.Format("20060102150405") timeFormatOne := tempTime.Format("2006-01-02 15:04:05") //randNum := rand.New(rand.NewSource(time.Now().UnixNano())).Int31n(10000) inputData := make(map[string]interface{}) inputData["infno"] = "1199" //inputData["msgid"] = "7021" inputData["msgid"] = fixmedins_code + year + month + day + hour + min + sec + msec + "0" // 发送方报文 ID inputData["mdtrtarea_admvs"] = mdtrtarea_admvs // 发送方报文 ID inputData["recer_sys_code"] = "01" inputData["infver"] = "V1.0" inputData["opter_type"] = "1" inputData["opter"] = opter_id inputData["opter_name"] = opter_name inputData["inf_time"] = timeFormatOne inputData["fixmedins_code"] = fixmedins_code inputData["fixmedins_name"] = fixmedins_name inputData["dev_no"] = "" inputData["dev_safe_info"] = "" inputData["cainfo"] = "" inputData["signtype"] = "" inputData["sign_no"] = "" bytesData, _ := json.Marshal(inputData) fmt.Println(string(bytesData)) pBusiCardInfo := make([]byte, 8192) ret2, _, _ := readCard.Call((uintptr)(unsafe.Pointer(&bytesData[0])), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0]))) fmt.Println(ret2) fmt.Println(DeleteExtraSpace(string(pBusiCardInfo))) fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8")) if ret2 != 0 { return "" } return DeleteExtraSpace(string(pBusiCardInfo)) } func DeleteExtraSpace(s string) string { //删除字符串中的多余空格，有多个空格时，仅保留一个空格 s1 := strings.Replace(s, " ", " ", -1) //替换tab为空格 regstr := "\\s{2,}" //两个及两个以上空格的正则表达式 reg, _ := regexp.Compile(regstr) //编译正则表达式 s2 := make([]byte, len(s1)) //定义字符数组切片 copy(s2, s1) //将字符串复制到切片 spc_index := reg.FindStringIndex(string(s2)) //在字符串中搜索 for len(spc_index) > 0 { //找到适配项 s2 = append(s2[:spc_index[0]+1], s2[spc_index[1]:]...) //删除多余空格 spc_index = reg.FindStringIndex(string(s2)) //继续在字符串中搜索 } return string(s2) } func (c *ZHHisApiController) GetELeInfo(code string, operator_id string, operator_name string) (string, string) { DllDef := syscall.MustLoadDLL("NationECCode.dll") readCard := DllDef.MustFindProc("NationEcTrans") fmt.Println(readCard) fmt.Println("!!!!!") pBusiCardInfo := make([]byte, 8192) input := make(map[string]interface{}) inputData := make(map[string]interface{}) inputData["orgId"] = code inputData["businessType"] = "01101" inputData["operatorId"] = operator_id inputData["operatorName"] = operator_name inputData["officeId"] = "001" inputData["officeName"] = "血透室" inputData["deviceType"] = "" input["data"] = inputData input["orgId"] = code input["transType"] = "ec.query" bytesData, _ := json.Marshal(input) gdyb_url := beego.AppConfig.String("gdyb_url") url := gdyb_url + "/localcfc/api/hsecfc/localQrCodeQuery" ret2, _, _ := readCard.Call(StrPtr(url), StrPtr(string(bytesData)), (uintptr)(unsafe.Pointer(&pBusiCardInfo[0]))) fmt.Println(ret2) fmt.Println(DeleteExtraSpace(string(pBusiCardInfo))) fmt.Println(":", ConvertToString(DeleteExtraSpace(string(pBusiCardInfo)), "gbk", "utf-8")) if ret2 != 0 { return "", "" } return DeleteExtraSpace(""), DeleteExtraSpace(string(pBusiCardInfo)) } func StrPtr(s string) uintptr { return uintptr(unsafe.Pointer(syscall.StringBytePtr(s))) } func Remove0000(s string) string { str := make([]rune, 0, len(s)) for _, v := range []rune(s) { if v == 0 { continue } str = append(str, v) } return string(str) } func IntPtr(n int) uintptr { return uintptr(n) } func RemoveRepeatedPurviewElement2(arr []string) (newArr []string) { newArr = make([]string, 0) for i := 0; i < len(arr); i++ { repeat := false for j := i + 1; j < len(arr); j++ { if arr[i] == arr[j] { repeat = true break } } if !repeat { newArr = append(newArr, arr[i]) } } return } type Result3101 struct { Infcode int64 `json:"infcode"` InfRefmsgid string `json:"inf_refmsgid"` RefmsgTime string `json:"refmsg_time"` RespondTime string `json:"respond_time"` Enctype string `json:"enctype"` Signtype string `json:"signtype"` ErrMsg string `json:"err_msg"` Output struct { Result []struct { JudgeResultDetailDtos []struct { VolaItemType string `json:"vola_item_type"` MdtrtID string `json:"mdtrt_id"` JrdID string `json:"jrd_id"` PatnID string `json:"patn_id"` RxID string `json:"rx_id"` VolaAmt interface{} `json:"vola_amt"` } `json:"judge_result_detail_dtos"` RuleID string `json:"rule_id"` VolaEvid string `json:"vola_evid"` MdtrtID string `json:"mdtrt_id"` RuleName string `json:"rule_name"` VolaAmtStas string `json:"vola_amt_stas"` JrID string `json:"jr_id"` PatnID string `json:"patn_id"` SevDeg string `json:"sev_deg"` VolaAmt float64 `json:"vola_amt"` VolaBhvrType string `json:"vola_bhvr_type"` VolaCont string `json:"vola_cont"` } `json:"result"` } `json:"output"` } func Check3101ForOne(c *ZHHisApiController, patient_id int64, his service.Struct2401, admin_user_id int64, trig_scen string, record_time string, prescriptions []*models.HisPrescription, ress ResultTwo, record_date int64) (res2 Result3101) { var res Result3101 adminUser := c.GetAdminUserInfo() roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) //his, _ := service.GetNewHisPatientInfoFour(c.GetAdminUserInfo().CurrentOrgId, his_patient_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) //record_time := c.GetString("record_time") //trig_scen := c.GetString("trig_scen") 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 res } recordDateTime := theTime.Unix() p, _ := service.GetPatientByID(adminUser.CurrentOrgId, patient_id) var patientPrescription models.HisPrescriptionInfo //patientPrescription, _ = service.FindHisPatientPrescriptionInfo(adminUser.CurrentOrgId, his_patient_id, recordDateTime) //if patientPrescription.ID == 0 { patientPrescription, _ = service.FindLastPatientPrescriptionInfoTwo(adminUser.CurrentOrgId, patient_id, recordDateTime) //} department, _ := service.GetDepartMentDetail(patientPrescription.Departments) doctor_info, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, patientPrescription.DoctorId) // diagnosis_ids := strings.Split(patientPrescription.Diagnosis, ",") //prescriptions, _ := service.GetNewHisPrescriptionTen(adminUser.CurrentOrgId, his_patient_id, recordDateTime) var pp models.PublicParams pp.InsuplcAdmdvs = miConfig.InsuplcAdmdvs pp.MdtrtareaAdmvs = miConfig.MdtrtareaAdmvs pp.FixmedinsName = miConfig.OrgName pp.FixmedinsCode = miConfig.Code pp.RequestUrl = miConfig.Url pp.Cainfo = miConfig.Cainfo pp.SecretKey = miConfig.SecretKey pp.AccessKey = miConfig.AccessKey pp.OpterName = roles.UserName var config []*models.HisXtDiagnoseConfig for _, item := range diagnosis_ids { id, _ := strconv.ParseInt(item, 10, 64) if id > 0 { diagnosisConfig, _ := service.FindDiagnoseById(id) config = append(config, &diagnosisConfig) } } var pd models.PatientDtos pd.PatnID = his.PsnNo pd.PatnName = p.Name pd.Gend = ress.Output.Baseinfo.Gend pd.Poolarea = miConfig.MdtrtareaAdmvs pd.CurrMdtrtID = strconv.FormatInt(patientPrescription.ID, 10) var fed models.FsiEncounterDtos fed.MdtrtID = p.IdCardNo fed.MedinsID = miConfig.Code fed.MedinsName = miConfig.OrgName fed.MedinsAdmdvs = miConfig.MdtrtareaAdmvs fed.MedMdtrtType = "1" fed.MedinsType = "1" fed.MedinsLv = "11" tm := time.Unix(record_date, 0) s_tm := tm.Format("2006-01-02 15:04:05") fed.AdmDate = s_tm fed.DscgDate = s_tm fed.DscgMainDiseCodg = config[0].CountryCode fed.DscgMainDiseName = config[0].CountryContentName //诊断信息 var fdds []*models.FsiDiagnoseDtos for index, item := range config { if index == 0 { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = "1" fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } else { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = strconv.FormatInt(int64(index), 10) fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } } fed.DrCodg = strconv.FormatInt(doctor_info.ID, 10) fed.AdmDeptCodg = strconv.FormatInt(department.ID, 10) fed.AdmDeptName = department.Name fed.DscgDeptCodg = strconv.FormatInt(department.ID, 10) fed.DscgDeptName = department.Name fed.MedMdtrtType = "1" fed.MedType = "11" //if his.Insutype == "390" { // fed.MedType = "1402" //} else { // fed.MedType = "9933" //} var orders []*models.FsiOrderDtos if trig_scen == "4" { //处方医嘱信息 for _, item := range prescriptions { for _, subItem := range item.HisDoctorAdviceInfo { if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 && subItem.BaseDrugLib.IsUser != 1 { spec := (subItem.BaseDrugLib.Dose + subItem.BaseDrugLib.DoseUnit) + "*" + strconv.FormatInt(subItem.BaseDrugLib.MinNumber, 10) + subItem.BaseDrugLib.MinUnit + "/" + subItem.BaseDrugLib.MaxUnit var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.Cnt = fmt.Sprintf("%.2f", subItem.PrescribingNumber) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", (subItem.PrescribingNumber * subItem.Price)) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = spec order.SpecUnt = subItem.PrescribingNumberUnit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } for _, subItem := range item.HisPrescriptionProject { if len(subItem.HisProject.MedicalCode) > 0 { if subItem.Type == 2 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.Unit order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } if subItem.Type == 3 { if len(subItem.GoodInfo.MedicalInsuranceNumber) > 0 && subItem.GoodInfo.IsUser != 1 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.GoodInfo.SpecificationName order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } } } //处方医嘱信息 } fed.MatnStas = "0" fed.MedfeeSumamt = "0" fed.OwnpayAmt = "0" fed.SelfpayAmt = "0" fed.AcctPayamt = "0" fed.MaAmt = "0" fed.HifpPayamt = "0" fed.SetlTotlnum = "1" fed.Insutype = his.Insutype fed.ReimFlag = "0" fed.OutSetlFlag = "0" var fopd []*models.FsiOperationDtosData data := make(map[string]interface{}) data["fed"] = fed data["fdd"] = fdds data["fod"] = orders data["pd"] = pd data["pp"] = pp data["fopd"] = fopd data["trig_scen"] = trig_scen fmt.Println(data) fmt.Println(fed) fmt.Println(fdds) fmt.Println(orders) fmt.Println(pd) fmt.Println(pp) fmt.Println(fopd) client := &http.Client{} bytesData, _ := json.Marshal(data) var req *http.Request if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" { if miConfig.MdtrtareaAdmvs == "320921" { req, _ = http.NewRequest("POST", "http://192.168.2.3:9532/"+"jsyb/3101", bytes.NewReader(bytesData)) } else { req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3101", 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 res } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(body), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{}) fmt.Println(respJSON) result, _ := json.Marshal(respJSON) fmt.Println(result) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } return res } else { //if miConfig.MdtrtareaAdmvs == "441202" { output, input := service.Gdyb3101(pd, fed, fdds, orders, fopd, pp, trig_scen) saveLog(output, input, "3101", "事前") if err := json.Unmarshal([]byte(output), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } return res //} } } func Check3101(c *ZHHisApiController, patient_id int64, his_patient_id int64, admin_user_id int64, trig_scen string, record_time string, prescriptions []*models.HisPrescription) (res Result3101) { adminUser := c.GetAdminUserInfo() roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) his, _ := service.GetInHospitalRecord(his_patient_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) //record_time := c.GetString("record_time") //trig_scen := c.GetString("trig_scen") 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 res } recordDateTime := theTime.Unix() var patientPrescription models.HisPrescriptionInfo patientPrescription, _ = service.FindHisPatientPrescriptionInfo(adminUser.CurrentOrgId, his_patient_id, recordDateTime) if patientPrescription.ID == 0 { patientPrescription, _ = service.FindLastPatientPrescriptionInfo(adminUser.CurrentOrgId, patient_id, recordDateTime) } department, _ := service.GetDepartMentDetail(patientPrescription.Departments) doctor_info, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, patientPrescription.DoctorId) // diagnosis_ids := strings.Split(patientPrescription.Diagnosis, ",") p, _ := service.GetPatientByID(c.GetAdminUserInfo().CurrentOrgId, patient_id) //prescriptions, _ := service.GetNewHisPrescriptionTen(adminUser.CurrentOrgId, his_patient_id, recordDateTime) var pp models.PublicParams pp.InsuplcAdmdvs = miConfig.InsuplcAdmdvs pp.MdtrtareaAdmvs = miConfig.MdtrtareaAdmvs pp.FixmedinsName = miConfig.OrgName pp.FixmedinsCode = miConfig.Code pp.RequestUrl = miConfig.Url pp.Cainfo = miConfig.Cainfo pp.SecretKey = miConfig.SecretKey pp.AccessKey = miConfig.AccessKey pp.OpterName = roles.UserName var config []*models.HisXtDiagnoseConfig for _, item := range diagnosis_ids { id, _ := strconv.ParseInt(item, 10, 64) if id > 0 { diagnosisConfig, _ := service.FindDiagnoseById(id) config = append(config, &diagnosisConfig) } } var pd models.PatientDtos pd.PatnID = his.PsnNo pd.PatnName = his.Name pd.Gend = his.Gend pd.Poolarea = his.InsuplcAdmdvs pd.CurrMdtrtID = his.Number birthday := time.Unix(p.Birthday, 0) // 格式化为生日字符串 birthdayStr := birthday.Format("2006-01-02") // 格式化模板为 "年-月-日" pd.Brdy = birthdayStr var fed models.FsiEncounterDtos fed.MdtrtID = his.Number fed.MedinsID = miConfig.Code fed.MedinsName = miConfig.OrgName fed.MedinsAdmdvs = miConfig.MdtrtareaAdmvs fed.MedMdtrtType = "1" fed.MedinsType = "1" fed.MedinsLv = "11" tm := time.Unix(his.RecordDate, 0) s_tm := tm.Format("2006-01-02 15:04:05") fed.AdmDate = s_tm fed.DscgDate = s_tm fed.DscgMainDiseCodg = config[0].CountryCode fed.DscgMainDiseName = config[0].CountryContentName //诊断信息 var fdds []*models.FsiDiagnoseDtos for index, item := range config { if index == 0 { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = "1" fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } else { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = strconv.FormatInt(int64(index), 10) fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } } fed.DrCodg = strconv.FormatInt(doctor_info.ID, 10) fed.AdmDeptCodg = strconv.FormatInt(department.ID, 10) fed.AdmDeptName = department.Name fed.DscgDeptCodg = strconv.FormatInt(department.ID, 10) fed.DscgDeptName = department.Name fed.MedMdtrtType = "1" fed.MedType = "11" //if his.Insutype == "390" { // fed.MedType = "1402" //} else { // fed.MedType = "9933" //} var orders []*models.FsiOrderDtos if trig_scen == "4" { //处方医嘱信息 for _, item := range prescriptions { for _, subItem := range item.HisDoctorAdviceInfo { if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 && subItem.BaseDrugLib.IsUser != 1 { spec := (subItem.BaseDrugLib.Dose + subItem.BaseDrugLib.DoseUnit) + "*" + strconv.FormatInt(subItem.BaseDrugLib.MinNumber, 10) + subItem.BaseDrugLib.MinUnit + "/" + subItem.BaseDrugLib.MaxUnit var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.Cnt = fmt.Sprintf("%.2f", subItem.PrescribingNumber) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", (subItem.PrescribingNumber * subItem.Price)) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = spec order.SpecUnt = subItem.PrescribingNumberUnit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } for _, subItem := range item.HisPrescriptionProject { if len(subItem.HisProject.MedicalCode) > 0 { if subItem.Type == 2 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.Unit order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } if subItem.Type == 3 { if len(subItem.GoodInfo.MedicalInsuranceNumber) > 0 && subItem.GoodInfo.IsUser != 1 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.GoodInfo.SpecificationName order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } } } //处方医嘱信息 } fed.MatnStas = "0" fed.MedfeeSumamt = "0" fed.OwnpayAmt = "0" fed.SelfpayAmt = "0" fed.AcctPayamt = "0" fed.MaAmt = "0" fed.HifpPayamt = "0" fed.SetlTotlnum = "1" fed.Insutype = his.InsutypeType fed.ReimFlag = "0" fed.OutSetlFlag = "0" var fopd []*models.FsiOperationDtosData data := make(map[string]interface{}) data["fed"] = fed data["fdd"] = fdds data["fod"] = orders data["pd"] = pd data["pp"] = pp data["fopd"] = fopd data["trig_scen"] = trig_scen fmt.Println(data) fmt.Println(fed) fmt.Println(fdds) fmt.Println(orders) fmt.Println(pd) fmt.Println(pp) fmt.Println(fopd) client := &http.Client{} bytesData, _ := json.Marshal(data) var req *http.Request if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" { if miConfig.MdtrtareaAdmvs == "320921" { req, _ = http.NewRequest("POST", "http://192.168.2.3:9532/"+"jsyb/3101", bytes.NewReader(bytesData)) } else { req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3101", 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 res } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(body), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{}) fmt.Println(respJSON) result, _ := json.Marshal(respJSON) fmt.Println(result) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } return res } else { output, input := service.Gdyb3101(pd, fed, fdds, orders, fopd, pp, trig_scen) saveLog(output, input, "3101", "事前") if err := json.Unmarshal([]byte(output), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } return res } return res } func Check3102(c *ZHHisApiController, patient_id int64, his_patient_id int64, admin_user_id int64, trig_scen string, order_id int64) (res Result3101) { ////patient_id, _ := c.GetInt64("patient_id") //order_id, _ := c.GetInt64("order_id") ////his_patient_id, _ := c.GetInt64("his_patient_id") ////admin_user_id, _ := c.GetInt64("admin_user_id") //trig_scen := c.GetString("trig_scen") adminUser := c.GetAdminUserInfo() roles, _ := service.GetAdminUserInfoByID(c.GetAdminUserInfo().CurrentOrgId, admin_user_id) //his, _ := service.GetNewHisPatientInfoFour(c.GetAdminUserInfo().CurrentOrgId, his_patient_id) his, _ := service.GetInHospitalRecord(his_patient_id) p, _ := service.GetPatientByID(c.GetAdminUserInfo().CurrentOrgId, patient_id) miConfig, _ := service.FindMedicalInsuranceInfo(c.GetAdminUserInfo().CurrentOrgId) record_time := c.GetString("record_time") order, _ := service.GetHisOrderByID(order_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() var patientPrescription models.HisPrescriptionInfo patientPrescription, _ = service.FindHisPatientPrescriptionInfo(adminUser.CurrentOrgId, his_patient_id, recordDateTime) if patientPrescription.ID == 0 { patientPrescription, _ = service.FindLastPatientPrescriptionInfo(adminUser.CurrentOrgId, patient_id, recordDateTime) } department, _ := service.GetDepartMentDetail(patientPrescription.Departments) doctor_info, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, patientPrescription.DoctorId) // diagnosis_ids := strings.Split(his.Diagnosis, ",") prescriptions, _ := service.GetNewHisPrescriptionTenone(adminUser.CurrentOrgId, his.Number) var pp models.PublicParams pp.InsuplcAdmdvs = miConfig.InsuplcAdmdvs pp.MdtrtareaAdmvs = miConfig.MdtrtareaAdmvs pp.FixmedinsName = miConfig.OrgName pp.FixmedinsCode = miConfig.Code pp.RequestUrl = miConfig.Url pp.Cainfo = miConfig.Cainfo pp.SecretKey = miConfig.SecretKey pp.AccessKey = miConfig.AccessKey pp.OpterName = roles.UserName var config []*models.HisXtDiagnoseConfig for _, item := range diagnosis_ids { id, _ := strconv.ParseInt(item, 10, 64) if id > 0 { diagnosisConfig, _ := service.FindDiagnoseById(id) config = append(config, &diagnosisConfig) } } var pd models.PatientDtos pd.PatnID = his.PsnNo pd.PatnName = his.Name pd.Gend = his.Gend pd.Poolarea = his.InsuplcAdmdvs pd.CurrMdtrtID = his.Number // 将时间戳转换为 time.Time 类型 birthday := time.Unix(p.Birthday, 0) // 格式化为生日字符串 birthdayStr := birthday.Format("2006-01-02") // 格式化模板为 "年-月-日" pd.Brdy = birthdayStr var fed models.FsiEncounterDtos fed.MdtrtID = his.Number fed.MedinsID = miConfig.Code fed.MedinsName = miConfig.OrgName fed.MedinsAdmdvs = miConfig.MdtrtareaAdmvs fed.MedMdtrtType = "1" fed.MedinsType = "1" fed.MedinsLv = "11" tm := time.Unix(his.RecordDate, 0) s_tm := tm.Format("2006-01-02 15:04:05") fed.AdmDate = s_tm fed.DscgDate = s_tm fed.DscgMainDiseCodg = config[0].CountryCode fed.DscgMainDiseName = config[0].CountryContentName //诊断信息 var fdds []*models.FsiDiagnoseDtos for index, item := range config { if index == 0 { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = "1" fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } else { var fdd models.FsiDiagnoseDtos fdd.DiseID = strconv.FormatInt(item.ID, 10) fdd.InoutDiseType = "1" fdd.MaindiseFlag = "1" fdd.DiseDate = s_tm fdd.DiasSrtNo = strconv.FormatInt(int64(index), 10) fdd.DiseName = item.CountryContentName fdd.DiseCodg = item.CountryCode fdds = append(fdds, &fdd) } } fed.DrCodg = strconv.FormatInt(doctor_info.ID, 10) fed.AdmDeptCodg = strconv.FormatInt(department.ID, 10) fed.AdmDeptName = department.Name fed.DscgDeptCodg = strconv.FormatInt(department.ID, 10) fed.DscgDeptName = department.Name fed.MedType = "14" //处方医嘱信息 var orders []*models.FsiOrderDtos //for _, item := range prescriptions { // for _, subItem := range item.HisDoctorAdviceInfo { // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "-" // order.HilistCode = subItem.BaseDrugLib.MedicalInsuranceNumber // order.HosplistName = subItem.BaseDrugLib.DrugName // order.HilistLv = "1" // order.HilistPric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.HosplistCode = subItem.BaseDrugLib.MedicalInsuranceNumber // order.HosplistName = subItem.BaseDrugLib.DrugName // order.Cnt = strconv.FormatFloat(subItem.PrescribingNumber, 'E', -1, 64) // order.Pric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.Sumamt = strconv.FormatFloat((subItem.Price * subItem.PrescribingNumber), 'E', -1, 64) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = "" // order.SpecUnt = "" // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = "1" // order.DrordDeptName = department.Name // order.DrordDrCodg = "1" // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // } // for _, subItem := range item.HisPrescriptionProject { // if subItem.Type == 2 { // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "-" // order.HilistCode = subItem.HisProject.MedicalCode // order.HosplistName = subItem.HisProject.ProjectName // order.HilistLv = "1" // order.HilistPric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.HosplistCode = subItem.HisProject.MedicalCode // order.HosplistName = subItem.HisProject.ProjectName // order.Cnt = subItem.Count // cnt, _ := strconv.ParseFloat(subItem.Count, 64) // // order.Pric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.Sumamt = strconv.FormatFloat((subItem.Price * cnt), 'E', -1, 64) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = "" // order.SpecUnt = "" // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = "1" // order.DrordDeptName = department.Name // order.DrordDrCodg = "1" // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // // } // if subItem.Type == 3 { // // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "-" // order.HilistCode = subItem.GoodInfo.MedicalInsuranceNumber // order.HosplistName = subItem.GoodInfo.GoodName // order.HilistLv = "1" // order.HilistPric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.HosplistCode = subItem.GoodInfo.MedicalInsuranceNumber // order.HosplistName = subItem.GoodInfo.GoodName // order.Cnt = subItem.Count // cnt, _ := strconv.ParseFloat(subItem.Count, 64) // order.Pric = strconv.FormatFloat(subItem.Price, 'E', -1, 64) // order.Sumamt = strconv.FormatFloat((subItem.Price * cnt), 'E', -1, 64) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = "" // order.SpecUnt = "" // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = "1" // order.DrordDeptName = department.Name // order.DrordDrCodg = "1" // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // // } // } //} for _, item := range prescriptions { for _, subItem := range item.HisDoctorAdviceInfo { if len(subItem.BaseDrugLib.MedicalInsuranceNumber) > 0 && subItem.BaseDrugLib.IsUser != 1 { spec := (subItem.BaseDrugLib.Dose + subItem.BaseDrugLib.DoseUnit) + "*" + strconv.FormatInt(subItem.BaseDrugLib.MinNumber, 10) + subItem.BaseDrugLib.MinUnit + "/" + subItem.BaseDrugLib.MaxUnit var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.BaseDrugLib.MedicalInsuranceNumber order.HosplistName = subItem.BaseDrugLib.DrugName order.Cnt = fmt.Sprintf("%.2f", subItem.PrescribingNumber) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", (subItem.PrescribingNumber * subItem.Price)) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = spec order.SpecUnt = subItem.PrescribingNumberUnit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } for _, subItem := range item.HisPrescriptionProject { if len(subItem.HisProject.MedicalCode) > 0 { if subItem.Type == 2 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.HisProject.MedicalCode order.HosplistName = subItem.HisProject.ProjectName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.Unit order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } if subItem.Type == 3 { if len(subItem.GoodInfo.MedicalInsuranceNumber) > 0 && subItem.GoodInfo.IsUser != 1 { var order models.FsiOrderDtos order.RxID = strconv.FormatInt(item.ID, 10) order.Rxno = strconv.FormatInt(item.ID, 10) order.LongDrordFlag = "0" order.HilistType = "1" order.ChrgType = "1" order.DrordBhvr = "0" order.HilistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.HilistLv = "1" order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) order.HosplistCode = subItem.GoodInfo.MedicalInsuranceNumber order.HosplistName = subItem.GoodInfo.GoodName order.Cnt = subItem.Count cnt, _ := strconv.ParseFloat(subItem.Count, 64) order.Pric = fmt.Sprintf("%.2f", subItem.Price) order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) order.OwnpayAmt = "" order.SelfpayAmt = "" order.Spec = subItem.GoodInfo.SpecificationName order.SpecUnt = subItem.Unit order.DrordBegnDate = s_tm order.DrordStopDate = "" order.DrordDrCodg = doctor_info.DoctorNumber order.DrordDeptName = department.Name order.DrordDeptCodg = department.Number order.DrordDrName = doctor_info.UserName order.DrordDrProfttl = "234" order.CurrDrordFlag = "1" orders = append(orders, &order) } } } } //for _, item := range prescriptions { // for _, subItem := range item.HisDoctorAdviceInfo { // spec := (subItem.BaseDrugLib.Dose + subItem.BaseDrugLib.DoseUnit) + "*" + strconv.FormatInt(subItem.BaseDrugLib.MinNumber, 10) + subItem.BaseDrugLib.MinUnit + "/" + subItem.BaseDrugLib.MaxUnit // // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "0" // order.HilistCode = subItem.BaseDrugLib.MedicalInsuranceNumber // order.HosplistName = subItem.BaseDrugLib.DrugName // order.HilistLv = "1" // order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) // order.HosplistCode = subItem.BaseDrugLib.MedicalInsuranceNumber // order.HosplistName = subItem.BaseDrugLib.DrugName // order.Cnt = fmt.Sprintf("%.2f", subItem.PrescribingNumber) // order.Pric = fmt.Sprintf("%.2f", subItem.Price) // order.Sumamt = fmt.Sprintf("%.2f", (subItem.PrescribingNumber * subItem.Price)) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = spec // order.SpecUnt = subItem.PrescribingNumberUnit // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = doctor_info.DoctorNumber // order.DrordDeptName = department.Name // order.DrordDeptCodg = department.Number // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "234" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // } // for _, subItem := range item.HisPrescriptionProject { // if subItem.Type == 2 { // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "0" // order.HilistCode = subItem.HisProject.MedicalCode // order.HosplistName = subItem.HisProject.ProjectName // order.HilistLv = "1" // order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) // order.HosplistCode = subItem.HisProject.MedicalCode // order.HosplistName = subItem.HisProject.ProjectName // order.Cnt = subItem.Count // cnt, _ := strconv.ParseFloat(subItem.Count, 64) // order.Pric = fmt.Sprintf("%.2f", subItem.Price) // order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = subItem.Unit // order.SpecUnt = subItem.Unit // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = doctor_info.DoctorNumber // order.DrordDeptName = department.Name // order.DrordDeptCodg = department.Number // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "234" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // // } // if subItem.Type == 3 { // // var order models.FsiOrderDtos // order.RxID = strconv.FormatInt(item.ID, 10) // order.Rxno = strconv.FormatInt(item.ID, 10) // order.LongDrordFlag = "0" // order.HilistType = "1" // order.ChrgType = "1" // order.DrordBhvr = "0" // order.HilistCode = subItem.GoodInfo.MedicalInsuranceNumber // order.HosplistName = subItem.GoodInfo.GoodName // order.HilistLv = "1" // order.HilistPric = fmt.Sprintf("%.2f", subItem.Price) // order.HosplistCode = subItem.GoodInfo.MedicalInsuranceNumber // order.HosplistName = subItem.GoodInfo.GoodName // order.Cnt = subItem.Count // cnt, _ := strconv.ParseFloat(subItem.Count, 64) // order.Pric = fmt.Sprintf("%.2f", subItem.Price) // order.Sumamt = fmt.Sprintf("%.2f", subItem.Price*cnt) // order.OwnpayAmt = "" // order.SelfpayAmt = "" // order.Spec = subItem.GoodInfo.SpecificationName // order.SpecUnt = subItem.Unit // order.DrordBegnDate = s_tm // order.DrordStopDate = "" // order.DrordDrCodg = doctor_info.DoctorNumber // order.DrordDeptName = department.Name // order.DrordDeptCodg = department.Number // order.DrordDrName = doctor_info.UserName // order.DrordDrProfttl = "234" // order.CurrDrordFlag = "1" // orders = append(orders, &order) // // } // } //} //处方医嘱信息 fed.MatnStas = "0" fed.MedfeeSumamt = fmt.Sprintf("%.2f", order.MedfeeSumamt) fed.OwnpayAmt = fmt.Sprintf("%.2f", order.FulamtOwnpayAmt) fed.SelfpayAmt = fmt.Sprintf("%.2f", order.PreselfpayAmt) fed.AcctPayamt = fmt.Sprintf("%.2f", order.AcctPay) fed.MaAmt = fmt.Sprintf("%.2f", order.MafPay) fed.HifpPayamt = fmt.Sprintf("%.2f", order.HifpPay) fed.SetlTotlnum = "1" fed.Insutype = his.InsutypeType fed.ReimFlag = "0" fed.OutSetlFlag = "0" var fopd []*models.FsiOperationDtosData data := make(map[string]interface{}) data["fed"] = fed data["fdd"] = fdds data["fod"] = orders data["pd"] = pd data["pp"] = pp data["fopd"] = fopd data["trig_scen"] = trig_scen client := &http.Client{} bytesData, _ := json.Marshal(data) var req *http.Request if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" { if miConfig.MdtrtareaAdmvs == "320921" { req, _ = http.NewRequest("POST", "http://192.168.2.3:9532/"+"jsyb/3102", bytes.NewReader(bytesData)) } else { req, _ = http.NewRequest("POST", "http://192.168.5.251:9532/"+"jsyb/3102", 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 res } var respJSON map[string]interface{} if err := json.Unmarshal([]byte(body), &respJSON); err != nil { utils.ErrorLog("接口返回数据解析JSON失败: %v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } respJSON = respJSON["data"].(map[string]interface{})["request_log"].(map[string]interface{}) result, _ := json.Marshal(respJSON) if err := json.Unmarshal([]byte(result), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return res } return res } else { output, input := service.Gdyb3102(pd, fed, fdds, orders, fopd, pp, trig_scen) saveLog(output, input, "3102", "事中") if err := json.Unmarshal([]byte(output), &res); err != nil { utils.ErrorLog("解析失败：%v", err) c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException) return } return res } return res }