Merge remote-tracking branch 'origin/master'

conf/app.conf

@@ -45,8 +45,7 @@ appsecret="61ee2e6268497d5aa9de0b0187c39aea"
 
 
 [prod]
-org_id = 10215
-
+org_id = 10088
 mobile_token_expiration_second = 86400
 httpdomain = https://api.xt.kuyicloud.com
 sso_domain = https://sso.kuyicloud.com
@@ -73,7 +72,7 @@ gdyb_url = "http://igb.hsa.gdgov.cn/ebus/gdyb_api/prd/hsa/hgs/"
 #深圳
 #gdyb_paasid = "sz_prd_yjyy"
 #肇庆
-gdyb_paasid = "zq_prd_yjyy"
+# gdyb_paasid = "zq_prd_yjyy"
 # gdyb_paasid = "sztest_hosp"
 #广州
 #gdyb_paasid = "gdyb_inf"

controllers/hb/hbyb_controller.go

@@ -27,10 +27,53 @@ func HbybRegistRouters() {
 	beego.Router("/hbyb/2208", &HBybController{}, "get:PostNine")
 	beego.Router("/hbyb/5203", &HBybController{}, "get:PostTen")
 	beego.Router("/hbyb/2001", &HBybController{}, "get:Post2001")
-
+	beego.Router("/hbyb/3202", &HBybController{}, "get:Post3202a")
 	beego.Router("/hbyb/4101", &HBybController{}, "post:Post4101")
 
 }
+func (c *HBybController) Post3202a() {
+	insutype := c.GetString("insutype")
+	clrType := c.GetString("clr_type")
+	setlOptins := c.GetString("setl_optins")
+	stmtBegndate := c.GetString("stmt_begndate")
+	stmtEnddate := c.GetString("stm_enddate")
+	fundPaySumamt, _ := c.GetFloat("fund_pay_sumamt", 0)
+	acctPay, _ := c.GetFloat("acct_pay", 0)
+	fixmedins_code := c.GetString("fixmedins_code")
+	insuplc_admdvs := c.GetString("insuplc_admdvs")
+	mdtrtarea_admvs := c.GetString("mdtrtarea_admvs")
+	secret_key := c.GetString("secret_key")
+	org_name := c.GetString("org_name")
+	doctor := c.GetString("doctor")
+
+	var baseParams models.BaseParams
+	baseParams.InsuplcAdmdvs = insuplc_admdvs
+	baseParams.MdtrtareaAdmvs = mdtrtarea_admvs
+	baseParams.SecretKey = secret_key
+	baseParams.OrgName = org_name
+	baseParams.Doctor = doctor
+	baseParams.FixmedinsCode = fixmedins_code
+	businessParams := models.BusinessParams{
+		Insutype:      insutype,
+		ClrType:       clrType,
+		SetlOptins:    setlOptins,
+		StmtBegndate:  stmtBegndate,
+		StmtEnddate:   stmtEnddate,
+		FundPaySumamt: fundPaySumamt,
+		AcctPay:       acctPay,
+	}
+	result := service.Hbyb3202a(baseParams, businessParams)
+	var dat map[string]interface{}
+	if err := json.Unmarshal([]byte(result), &dat); err == nil {
+		fmt.Println(dat)
+	} else {
+		fmt.Println(err)
+	}
+	c.ServeSuccessJSON(map[string]interface{}{
+		"pre": dat,
+	})
+}
+
 func (c *HBybController) Post4101() {
 	body, _ := ioutil.ReadAll(c.Ctx.Request.Body)
 	var respJSON map[string]interface{}

controllers/sg/his_api_controller.go

@@ -83,16 +83,18 @@ func HisManagerApiRegistRouters() {
 
 	beego.Router("/api/readelecard", &HisApiController{}, "get:ReadEleCard")
 
+	beego.Router("/api/3202", &HisApiController{}, "get:Post3202")
+
 }
 
 type Result3101 struct {
-	Infcode     string      `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      interface{} `json:"err_msg"`
+	Infcode     string `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 {
@@ -145,6 +147,288 @@ func (c *HisApiController) Get9001() {
 	}
 
 }
+func Check3101ForOne(c *HisApiController, patient_id int64, his models.VMHisPatient, 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.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()
+
+	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)
+		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.Brdy = his.Brdy
+	pd.Poolarea = his.InsuplcAdmdvs
+	pd.CurrMdtrtID = his.Number
+
+	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 == "2" {
+		//处方医嘱信息
+		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 = 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 = ""
+				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 = 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 = ""
+					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 = 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 = ""
+					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)
+
+				}
+			}
+		}
+		//处方医嘱信息
+	}
+	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" {
+		req, _ = http.NewRequest("POST", "http://192.168.2.110: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{})["pre"].(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
+
+}
+
 func Check3101(c *HisApiController, 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()
@@ -5566,6 +5850,31 @@ func (c *HisApiController) GetRegisterInfo() {
 					cert_no = bas[2]
 				}
 
+				var hisPrescription []*models.HisPrescription
+				res3101 := Check3101ForOne(c, patient.ID, his, admin_user_id, "1", record_time, hisPrescription)
+
+				if res3101.Infcode == "0" && len(res3101.Output.Result) > 0 {
+					for _, item := range res3101.Output.Result {
+						if len(res3101.ErrMsg) == 0 {
+							res3101.ErrMsg = item.VolaCont
+						} else {
+							res3101.ErrMsg = res3101.ErrMsg + "\n" + item.VolaCont
+						}
+					}
+					c.ServeSuccessJSON(map[string]interface{}{
+						"failed_code": -10,
+						"msg":         res3101.ErrMsg,
+					})
+					return
+
+				} else if res3101.Infcode != "0" {
+					c.ServeSuccessJSON(map[string]interface{}{
+						"failed_code": -10,
+						"msg":         res3101.ErrMsg,
+					})
+					return
+				}
+
 				var api string
 				if miConfig.MdtrtareaAdmvs == "320921" {
 
@@ -6622,6 +6931,22 @@ func (c *HisApiController) GetUploadInfo() {
 							}
 
 						} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+							result3101 := Check3102(c, id, his_patient_id, admin_user_id, "6", 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
+								}
+							}
+
 							psn_info, _ := service.GetPsnByPatientId(his.PatientId)
 							psn_info.VerifyNumber = strings.Replace(psn_info.VerifyNumber, "+", "%2B", -1)
 							bas := strings.Split(psn_info.CardInfo, "|")
@@ -7041,6 +7366,21 @@ func (c *HisApiController) GetUploadInfo() {
 				}
 
 			} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+				result3101 := Check3102(c, id, his_patient_id, admin_user_id, "6", 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
+					}
+				}
 				psn_info, _ := service.GetPsnByPatientId(his.PatientId)
 				psn_info.VerifyNumber = strings.Replace(psn_info.VerifyNumber, "+", "%2B", -1)
 
@@ -8234,6 +8574,22 @@ func (c *HisApiController) GetPreUploadInfo() {
 				}
 
 			} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+				result3101 := Check3101(c, id, his_patient_id, admin_user_id, "2", record_time, prescriptions)
+				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
+					}
+				}
+
 				bytesData, _ := json.Marshal(data)
 				var req *http.Request
 				if miConfig.MdtrtareaAdmvs == "320921" {
@@ -8556,6 +8912,22 @@ func (c *HisApiController) GetPreUploadInfo() {
 						}
 
 					} else if miConfig.MdtrtareaAdmvs == "320921" || miConfig.MdtrtareaAdmvs == "320982" {
+						result3101 := Check3102(c, id, his_patient_id, admin_user_id, "6", 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
+							}
+						}
+
 						psn_info, _ := service.GetPsnByPatientId(his.PatientId)
 						psn_info.VerifyNumber = strings.Replace(psn_info.VerifyNumber, "+", "%2B", -1)
 
@@ -12688,3 +13060,102 @@ func DeleteExtraSpace(s string) string {
 	}
 	return string(s2)
 }
+
+//对账
+func (c *HisApiController) Post3202() {
+	start_time := c.GetString("start_time")
+	end_time := c.GetString("end_time")
+	insutype := c.GetString("insutype")
+	clr_type := c.GetString("clr_type")
+	clr_org := c.GetString("clr_optins")
+
+	admin_user_id, _ := c.GetInt64("admin_user_id")
+
+	adminUser := c.GetAdminUserInfo()
+	miConfig, _ := service.FindMedicalInsuranceInfo(adminUser.CurrentOrgId)
+	config, _ := service.GetMedicalInsuranceConfig(adminUser.CurrentOrgId)
+	if len(clr_org) == 0 {
+		clr_org = miConfig.MdtrtareaAdmvs
+	}
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+	endtime, _ := time.ParseInLocation(timeLayout+" 15:04:05", end_time+" 23:59:59", loc)
+	orders, _ := service.GetOrderByTimeFour(startime.Unix(), endtime.Unix(), adminUser.CurrentOrgId, insutype, "", clr_type)
+	fixmedins_setl_cnt := int64(len(orders))
+	var medfee_sumamt float64
+	var acct_pay float64
+	var fund_pay_sumamt float64
+	for _, item := range orders {
+		medfee_sumamt = medfee_sumamt + item.MedfeeSumamt
+		acct_pay = acct_pay + item.AcctPay
+		fund_pay_sumamt = fund_pay_sumamt + item.FundPaySumamt
+	}
+	var user_name string
+	role, _ := service.GetAdminUserInfoByID(adminUser.CurrentOrgId, admin_user_id)
+	if role.ID == 0 {
+		user_name = "xxx"
+	} else {
+		user_name = role.UserName
+	}
+	var res ResultSix
+	if config.IsOpen == 1 {
+		if miConfig.MdtrtareaAdmvs == "421300" {
+			api := "http://192.168.124.4:9532/" + "hbyb/3202?" +
+				"insutype=" + insutype +
+				"&clr_type=" + clr_type +
+				"&setl_optins=" + clr_org +
+				"&stmt_begndate=" + start_time +
+				"&stm_enddate=" + end_time +
+				"&fund_pay_sumamt=" + fmt.Sprintf("%.4f", fund_pay_sumamt) +
+				"&acct_pay=" + fmt.Sprintf("%.4f", acct_pay) +
+				"&fixmedins_setl_cnt=" + strconv.FormatInt(fixmedins_setl_cnt, 10) +
+				"&fixmedins_code=" + miConfig.Code +
+				"&insuplc_admdvs=" + miConfig.InsuplcAdmdvs +
+				"&mdtrtarea_admvs=" + miConfig.MdtrtareaAdmvs +
+				"&secret_key=" + miConfig.SecretKey +
+				"&org_name=" + miConfig.OrgName +
+				"&doctor=" + user_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, _ := 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 {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"msg": "发起成功",
+			})
+		} else {
+			c.ServeSuccessJSON(map[string]interface{}{
+				"code": -10,
+				"msg":  res.ErrMsg,
+			})
+
+		}
+	}
+}

main.go

@@ -2,6 +2,10 @@ package main
 
 import (
 	"gdyb/service"
+	"github.com/qiniu/api.v7/auth/qbox"
+	"github.com/qiniu/api.v7/storage"
+
+	//"gdyb/service"
 
 	//"context"
 	"fmt"
@@ -832,42 +836,42 @@ func CreateLog(miConfig models.MedicalInsuranceOrgConfig) {
 
 }
 
-//func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
-//	//获取七牛云上的文件信息，不存在则表示没上传到七牛云，上传昨天日志信息
-//	nTime := time.Now()
-//	yesTime := nTime.AddDate(0, 0, -1)
-//	file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
-//	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
-//	cfg := storage.Config{
-//		// 是否使用https域名进行资源管理
-//		UseHTTPS: true,
-//	}
-//	// 指定空间所在的区域，如果不指定将自动探测
-//	// 如果没有特殊需求，默认不需要指定
-//	//cfg.Zone=&storage.ZoneHuabei
-//	bucketManager := storage.NewBucketManager(mac, &cfg)
-//	bucket := beego.AppConfig.String("qiniu_bucket")
-//	key := file_key
-//	file, sErr := bucketManager.Stat(bucket, key)
-//	fmt.Println(file)
-//	fmt.Println(sErr)
-//	fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
-//
-//	if sErr != nil {
-//		fmt.Println("七牛云上文件不存在，上传到七牛云")
-//		//判断本地文件是否存在，存在则执行上传操作
-//		exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
-//		if exist {
-//			upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
-//		} else {
-//			fmt.Println("本地文件不存在")
-//
-//		}
-//	} else {
-//		fmt.Println("七牛云文件存在")
-//	}
-//
-//}
+func UploadLog(miConfig models.MedicalInsuranceOrgConfig) {
+	//获取七牛云上的文件信息，不存在则表示没上传到七牛云，上传昨天日志信息
+	nTime := time.Now()
+	yesTime := nTime.AddDate(0, 0, -1)
+	file_key := strconv.FormatInt(miConfig.UserOrgId, 10) + "_" + yesTime.Format("20060102") + "_log.txt"
+	mac := qbox.NewMac(beego.AppConfig.String("qiniu_accesskey"), beego.AppConfig.String("qiniu_secretkey"))
+	cfg := storage.Config{
+		// 是否使用https域名进行资源管理
+		UseHTTPS: true,
+	}
+	// 指定空间所在的区域，如果不指定将自动探测
+	// 如果没有特殊需求，默认不需要指定
+	//cfg.Zone=&storage.ZoneHuabei
+	bucketManager := storage.NewBucketManager(mac, &cfg)
+	bucket := beego.AppConfig.String("qiniu_bucket")
+	key := file_key
+	file, sErr := bucketManager.Stat(bucket, key)
+	fmt.Println(file)
+	fmt.Println(sErr)
+	fmt.Println(miConfig.OrgName + "日志" + "/" + file_key)
+
+	if sErr != nil {
+		fmt.Println("七牛云上文件不存在，上传到七牛云")
+		//判断本地文件是否存在，存在则执行上传操作
+		exist, _ := PathExists(miConfig.OrgName + "日志" + "/" + file_key)
+		if exist {
+			//upload_qiniu(miConfig.OrgName+"日志"+"/"+file_key, file_key)
+		} else {
+			fmt.Println("本地文件不存在")
+
+		}
+	} else {
+		fmt.Println("七牛云文件存在")
+	}
+
+}
 func Mkdir(dir string) {
 	// 创建文件夹
 	exist, err := PathExists(dir)

service/hbyb_service.go

@@ -875,7 +875,50 @@ func Hbyb3201(baseParams models.BaseParams, businessParams models.BusinessParams
 	return str
 }
 
+func Hbyb3202a(baseParams models.BaseParams, businessParams models.BusinessParams) string {
+	fmt.Println("11222333-----")
+
+	fmt.Println(baseParams)
+	fmt.Println(businessParams)
+	// 生成签名
+	nonce := GetRandomString(32)
+	timestamp := time.Now().Unix()
+
+	// 生成输入报文
+	inputMessage := SetInputMessage(nonce, timestamp, baseParams.OrgName, baseParams.Doctor, baseParams.FixmedinsCode, baseParams.InsuplcAdmdvs, baseParams.MdtrtareaAdmvs)
+	input := make(map[string]interface{})
+	inputData := make(map[string]interface{})
+	inputMessage["infno"] = "3202a"                             // 交易编码
+	inputData["insutype"] = businessParams.Insutype             // 险种
+	inputData["clr_type"] = businessParams.ClrType              // 就诊 ID（来自2201接口返回）
+	inputData["setl_optins"] = baseParams.InsuplcAdmdvs         // 结算经办机构
+	inputData["stmt_begndate"] = businessParams.StmtBegndate    // 对帐开始时间
+	inputData["stmt_enddate"] = businessParams.StmtEnddate      //对帐结束时间
+	inputData["fund_pay_sumamt"] = businessParams.FundPaySumamt //基金支付总额
+	inputData["acct_pay"] = businessParams.AcctPay              //个人账户支付金额
+
+	input["data"] = inputData
+	inputMessage["input"] = input //交易输入
+
+	bytesData, err := json.Marshal(inputMessage)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error()
+	}
+	var json2 string
+	cmd := exec.Command("java", "-jar", "yh_hb_fat.jar", "3202a", string(bytesData), json2)
+	out, err := cmd.Output()
+	if err != nil {
+		fmt.Println("error:", err.Error())
+	}
+	fmt.Println(string(out))
+	return ConvertToString(string(out), "gbk", "utf-8")
+
+}
+
 //文件上传
+
 //文件上传
 func Hbyb9101(baseParams models.BaseParams, file_name string, file_byte []byte) string {
 

service/his_service.go

@@ -520,6 +520,11 @@ func FindLastPatientPrescriptionInfo(org_id int64, patient_id int64, record_date
 	return
 }
 
+func FindLastPatientPrescriptionInfoTwo(org_id int64, patient_id int64, record_date int64) (info models.HisPrescriptionInfo, err error) {
+	err = readDb.Model(&models.HisPrescriptionInfo{}).Where("user_org_id = ? AND status = 1 AND patient_id = ?", org_id, record_date, patient_id).Last(&info).Error
+	return
+}
+
 func SavePatientPrescriptionInfo(info models.HisPrescriptionInfo) (err error) {
 	err = writeDb.Save(&info).Error
 	return
@@ -986,6 +991,13 @@ func GetOrderByTime(start_time int64, end_time int64, org_id int64, insutype str
 	return
 }
 
+func GetOrderByTimeFour(start_time int64, end_time int64, org_id int64, insutype string, clr_org string, clr_type string) (orders []*models.HisOrder, err error) {
+	db := readDb.Model(&models.HisOrder{})
+	db = db.Where("user_org_id = ? AND status = 1 AND order_status = 2 AND is_medicine_insurance = 1 AND UNIX_TIMESTAMP(setl_time)  <= ? AND UNIX_TIMESTAMP(setl_time) >= ? AND insutype = ?", org_id, end_time, start_time, insutype)
+	err = db.Find(&orders).Error
+	return
+}
+
 func GetOrderByTimeThree(start_time int64, end_time int64, org_id int64, insutype string, clr_type string) (orders []*models.HisOrder, err error) {
 	err = readDb.Model(&models.HisOrder{}).Where("user_org_id = ? AND status = 1  AND is_medicine_insurance = 1 AND UNIX_TIMESTAMP(setl_time) <= ? AND UNIX_TIMESTAMP(setl_time) >= ? AND insutype = ?", org_id, end_time, start_time, insutype).Find(&orders).Error
 	return