医保对接

controllers/his_api_controller.go

@@ -5211,9 +5211,52 @@ func (c *HisApiController) GetUploadInfo() {
 			}
 		}
 		if err == nil {
+			houseConfig, _ := service.GetAllStoreHouseConfig(adminUser.CurrentOrgId)
+			var goods []*models.DialysisBeforePrepareGoods
+			var newGoods []*models.NewDialysisBeforePrepareGoods
+			var infos []*models.HisDoctorAdviceInfo
+
+			for _, info := range prescriptions {
+				if info.Type == 1 {
+					infos = append(infos, info.HisDoctorAdviceInfo...)
+				}
+				if info.Type == 2 {
+					for _, sumItem := range info.HisPrescriptionProject {
+						if sumItem.Type == 3 {
+							var good models.DialysisBeforePrepareGoods
+							var newGood models.NewDialysisBeforePrepareGoods
+							good.GoodId = sumItem.GoodInfo.ID
+							good.GoodTypeId = sumItem.GoodInfo.GoodTypeId
+							count, _ := strconv.Atoi(sumItem.Count)
+							good.Count = int64(count)
+							good.StorehouseId = houseConfig.StorehouseOutInfo
+							good.ProjectId = sumItem.ID
+							goods = append(goods, &good)
+
+							newGood.GoodId = sumItem.GoodInfo.ID
+							newGood.GoodTypeId = sumItem.GoodInfo.GoodTypeId
+							count2, _ := strconv.Atoi(sumItem.Count)
+							newGood.Count = int64(count2)
+							newGood.StorehouseId = houseConfig.StorehouseOutInfo
+							newGood.ProjectId = sumItem.ID
+							newGoods = append(newGoods, &newGood)
+						}
+
+					}
+
+				}
+			}
+			for _, item := range infos {
+				service.HisDrugsDelivery(item.UserOrgId, adminUser.AdminUser.Id, item)
+				//service.DrugAutoAddCancelInfo(item, adminUser.AdminUser.Id)
+
+			}
+			service.ConsumablesDeliveryTotal(adminUser.CurrentOrgId, his.PatientId, his.RecordDate, goods, newGoods, adminUser.AdminUser.Id)
+
 			c.ServeSuccessJSON(map[string]interface{}{
 				"msg": "结算成功",
 			})
+
 		}
 	} else {
 		if tempOrder.IsPre > 0 {
@@ -5241,6 +5284,48 @@ func (c *HisApiController) GetUploadInfo() {
 				return
 			}
 			if err == nil {
+
+				houseConfig, _ := service.GetAllStoreHouseConfig(adminUser.CurrentOrgId)
+				var goods []*models.DialysisBeforePrepareGoods
+				var newGoods []*models.NewDialysisBeforePrepareGoods
+				var infos []*models.HisDoctorAdviceInfo
+
+				for _, info := range prescriptions {
+					if info.Type == 1 {
+						infos = append(infos, info.HisDoctorAdviceInfo...)
+					}
+					if info.Type == 2 {
+						for _, sumItem := range info.HisPrescriptionProject {
+							if sumItem.Type == 3 {
+								var good models.DialysisBeforePrepareGoods
+								var newGood models.NewDialysisBeforePrepareGoods
+								good.GoodId = sumItem.GoodInfo.ID
+								good.GoodTypeId = sumItem.GoodInfo.GoodTypeId
+								count, _ := strconv.Atoi(sumItem.Count)
+								good.Count = int64(count)
+								good.StorehouseId = houseConfig.StorehouseOutInfo
+								good.ProjectId = sumItem.ID
+								goods = append(goods, &good)
+
+								newGood.GoodId = sumItem.GoodInfo.ID
+								newGood.GoodTypeId = sumItem.GoodInfo.GoodTypeId
+								count2, _ := strconv.Atoi(sumItem.Count)
+								newGood.Count = int64(count2)
+								newGood.StorehouseId = houseConfig.StorehouseOutInfo
+								newGood.ProjectId = sumItem.ID
+								newGoods = append(newGoods, &newGood)
+							}
+
+						}
+
+					}
+				}
+				for _, item := range infos {
+					service.HisDrugsDelivery(item.UserOrgId, adminUser.AdminUser.Id, item)
+
+				}
+				service.ConsumablesDeliveryTotal(adminUser.CurrentOrgId, his.PatientId, his.RecordDate, goods, newGoods, adminUser.AdminUser.Id)
+
 				c.ServeSuccessJSON(map[string]interface{}{
 					"msg": "结算成功",
 				})
@@ -5269,6 +5354,47 @@ func (c *HisApiController) Refund() {
 			return
 		}
 	}
+
+	if order.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	orders, _ := service.GetHisOrderDetailByNumberThree(order.Number, order.UserOrgId)
+	houseConfig, _ := service.GetAllStoreHouseConfig(order.UserOrgId)
+	var goods []*models.DialysisBeforePrepareGoods
+	var newGoods []*models.NewDialysisBeforePrepareGoods
+	var infos []*models.HisDoctorAdviceInfo
+
+	for _, info := range orders {
+		if info.AdviceId > 0 && info.ProjectId == 0 {
+			infos = append(infos, &info.HisDoctorAdviceInfo)
+		}
+		if info.ProjectId > 0 && info.AdviceId == 0 {
+			if info.HisPrescriptionProject.Type == 3 {
+				var good models.DialysisBeforePrepareGoods
+				var newGood models.NewDialysisBeforePrepareGoods
+				good.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				good.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				good.Count = int64(count)
+				good.StorehouseId = houseConfig.StorehouseOutInfo
+				good.ProjectId = info.HisPrescriptionProject.ID
+				goods = append(goods, &good)
+
+				newGood.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				newGood.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count2, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				newGood.Count = int64(count2)
+				newGood.StorehouseId = houseConfig.StorehouseOutInfo
+				newGood.ProjectId = info.HisPrescriptionProject.ID
+				newGoods = append(newGoods, &newGood)
+			}
+		}
+	}
+	for _, item := range infos {
+		service.DrugAutoAddCancelInfo(item, order.Creator)
+	}
+
 	c.ServeSuccessJSON(map[string]interface{}{
 		"msg": "退费成功",
 	})

controllers/stock_in_api_controller.go

@@ -147,6 +147,101 @@ func StockManagerApiRegistRouters() {
 	beego.Router("/api/stock/checkstockwarehouseinfo", &StockManagerApiController{}, "Get:CheckStockWarehouseInfo")
 	beego.Router("/api/stock/checkreturnstockwarehouseinfo", &StockManagerApiController{}, "Get:CheckReturnStockWarehouseInfo")
 	beego.Router("/api/stock/getprintlist", &StockManagerApiController{}, "Get:GetPrintList")
+
+	//结算成功后调用操作库存相关接口
+	beego.Router("/api/settle/stock", &StockManagerApiController{}, "Get:HandleSettleStock")
+	beego.Router("/api/settle/cancelstock", &StockManagerApiController{}, "Get:HandleRefundStock")
+
+}
+func (c *StockManagerApiController) HandleRefundStock() {
+	order_id, _ := c.GetInt64("order_id", 0)
+	order, _ := service.GetHisOrderByIDThree(order_id)
+	if order.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	orders, _ := service.GetHisOrderDetailByNumberThree(order.Number, order.UserOrgId)
+	houseConfig, _ := service.GetAllStoreHouseConfig(order.UserOrgId)
+	var goods []*models.DialysisBeforePrepareGoods
+	var newGoods []*models.NewDialysisBeforePrepareGoods
+	var infos []*models.HisDoctorAdviceInfo
+
+	for _, info := range orders {
+		if info.AdviceId > 0 && info.ProjectId == 0 {
+			infos = append(infos, &info.HisDoctorAdviceInfo)
+		}
+		if info.ProjectId > 0 && info.AdviceId == 0 {
+			if info.HisPrescriptionProject.Type == 3 {
+				var good models.DialysisBeforePrepareGoods
+				var newGood models.NewDialysisBeforePrepareGoods
+				good.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				good.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				good.Count = int64(count)
+				good.StorehouseId = houseConfig.StorehouseOutInfo
+				good.ProjectId = info.HisPrescriptionProject.ID
+				goods = append(goods, &good)
+
+				newGood.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				newGood.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count2, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				newGood.Count = int64(count2)
+				newGood.StorehouseId = houseConfig.StorehouseOutInfo
+				newGood.ProjectId = info.HisPrescriptionProject.ID
+				newGoods = append(newGoods, &newGood)
+			}
+		}
+	}
+	for _, item := range infos {
+		//service.HisDrugsDelivery(item.UserOrgId, order.Creator, item)
+		service.DrugAutoAddCancelInfo(item, order.Creator)
+
+	}
+
+}
+func (c *StockManagerApiController) HandleSettleStock() {
+	order_id, _ := c.GetInt64("order_id", 0)
+	order, _ := service.GetHisOrderByID(order_id)
+	if order.ID == 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	orders, _ := service.GetHisOrderDetailByNumberTwo(order.Number, order.UserOrgId)
+	houseConfig, _ := service.GetAllStoreHouseConfig(order.UserOrgId)
+	var goods []*models.DialysisBeforePrepareGoods
+	var newGoods []*models.NewDialysisBeforePrepareGoods
+	var infos []*models.HisDoctorAdviceInfo
+
+	for _, info := range orders {
+		if info.AdviceId > 0 && info.ProjectId == 0 {
+			infos = append(infos, &info.HisDoctorAdviceInfo)
+		}
+		if info.ProjectId > 0 && info.AdviceId == 0 {
+			if info.HisPrescriptionProject.Type == 3 {
+				var good models.DialysisBeforePrepareGoods
+				var newGood models.NewDialysisBeforePrepareGoods
+				good.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				good.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				good.Count = int64(count)
+				good.StorehouseId = houseConfig.StorehouseOutInfo
+				good.ProjectId = info.HisPrescriptionProject.ID
+				goods = append(goods, &good)
+
+				newGood.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
+				newGood.GoodTypeId = info.HisPrescriptionProject.VMGoodInfo.GoodTypeId
+				count2, _ := strconv.Atoi(info.HisPrescriptionProject.Count)
+				newGood.Count = int64(count2)
+				newGood.StorehouseId = houseConfig.StorehouseOutInfo
+				newGood.ProjectId = info.HisPrescriptionProject.ID
+				newGoods = append(newGoods, &newGood)
+			}
+		}
+	}
+	service.ConsumablesDeliveryTotal(order.UserOrgId, order.PatientId, order.SettleAccountsDate, goods, newGoods, order.Creator)
+	for _, item := range infos {
+		service.HisDrugsDelivery(item.UserOrgId, order.Creator, item)
+	}
 }
 
 func (c *StockManagerApiController) CreateWarehouse() {

service/his_config_service.go

@@ -864,7 +864,7 @@ func GetDataConfig(orgid int64) (dataconfig []*models.DictDataconfig, err error)
 //翻译项目中的组
 func TranslateZu(sc, orgid int64, types string) (s string, err error) {
 	var dataconfig []*models.DictDataconfig
-	tmp := "select * from xt_drug_data_config where parent_id in (select id from xt_drug_data_config where name = \"" + types + "\" and parent_id = 0) and value = " + config.ToString(sc) + " and status = 1 and (org_id = " + config.ToString(orgid) + " or org_id = 0)"
+	tmp := "select * from xt_drug_data_config where parent_id in (select id from xt_d·rug_data_config where name = \"" + types + "\" and parent_id = 0) and value = " + config.ToString(sc) + " and status = 1 and (org_id = " + config.ToString(orgid) + " or org_id = 0)"
 
 	err = XTReadDB().Raw(tmp).Scan(&dataconfig).Error
 	if err != nil {

service/his_hospital_service.go

@@ -560,3 +560,8 @@ func GetPsnByPatientId(patient_id int64) (psn models.HisPsn, err error) {
 	err = readDb.Model(&models.HisPsn{}).Where("patient_id = ?", patient_id).Last(&psn).Error
 	return
 }
+
+func GetHisPrescriptionProjectByIDTwo(id int64) (projects models.HisPrescriptionProject, err error) {
+	err = readDb.Model(&models.HisPrescriptionProject{}).Preload("HisProject", "status = 1").Preload("GoodInfo", "status = 1").Where("id = ? AND status = 1", id).First(&projects).Error
+	return
+}

service/his_service.go

@@ -44,11 +44,13 @@ func (HisPatient) TableName() string {
 }
 
 type Schedule struct {
-	ID           int64 `gorm:"column:id" json:"id" form:"id"`
-	UserOrgId    int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
-	PatientId    int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	Status       int64 `gorm:"column:status" json:"status" form:"status"`
-	ScheduleDate int64 `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ID                  int64  `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId           int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId           int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	Status              int64  `gorm:"column:status" json:"status" form:"status"`
+	ScheduleDate        int64  `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ModeId              int64  `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	DialysisMachineName string `gorm:"column:dialysis_machine_name" json:"dialysis_machine_name" form:"dialysis_machine_name"`
 }
 
 func (Schedule) TableName() string {
@@ -2532,3 +2534,51 @@ func UpDateOrderTwo(order *models.HisOrder) (err error) {
 	err = writeDb.Save(&order).Error
 	return
 }
+
+type HisOrderInfoTwo struct {
+	ID                     int64                      `gorm:"column:id" json:"id" form:"id"`
+	OrderNumber            string                     `gorm:"column:order_number" json:"order_number" form:"order_number"`
+	UploadDate             int64                      `gorm:"column:upload_date" json:"upload_date" form:"upload_date"`
+	AdviceId               int64                      `gorm:"column:advice_id" json:"advice_id" form:"advice_id"`
+	DetItemFeeSumamt       float64                    `gorm:"column:det_item_fee_sumamt" json:"det_item_fee_sumamt" form:"det_item_fee_sumamt"`
+	Cnt                    float64                    `gorm:"column:cnt" json:"cnt" form:"cnt"`
+	Pric                   float64                    `gorm:"column:pric" json:"pric" form:"pric"`
+	PatientId              int64                      `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	MedChrgitmType         string                     `gorm:"column:med_chrgitm_type" json:"med_chrgitm_type" form:"med_chrgitm_type"`
+	Status                 int64                      `gorm:"column:status" json:"status" form:"status"`
+	FeedetlSn              string                     `gorm:"column:feedetl_sn" json:"feedetl_sn" form:"feedetl_sn"`
+	ChldMedcFlag           string                     `gorm:"column:chld_medc_flag" json:"chld_medc_flag" form:"chld_medc_flag"`
+	ChrgitmLv              string                     `gorm:"column:chrgitm_lv" json:"chrgitm_lv" form:"chrgitm_lv"`
+	UserOrgId              int64                      `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	ProjectId              int64                      `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemId                 int64                      `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	FulamtOwnpayAmt        float64                    `gorm:"column:fulamt_ownpay_amt" json:"fulamt_ownpay_amt" form:"fulamt_ownpay_amt"`
+	HisPrescriptionProject HisPrescriptionProject     `gorm:"ForeignKey:ID;AssociationForeignKey:ProjectId" json:"project"`
+	HisDoctorAdviceInfo    models.HisDoctorAdviceInfo `gorm:"ForeignKey:ID;AssociationForeignKey:AdviceId" json:"advice"`
+}
+
+func (HisOrderInfoTwo) TableName() string {
+	return "his_order_info"
+}
+func GetHisOrderDetailByNumberTwo(order_number string, org_id int64) (order []*HisOrderInfoTwo, err error) {
+	err = readDb.Model(&HisOrderInfoTwo{}).Where("order_number = ? AND status = 1", order_number).Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("VMHisProject", "status = 1 AND user_org_id = ?", org_id).Preload("VMGoodInfo", "status = 1 AND org_id = ?", org_id)
+	}).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("Drug", "status = 1 AND org_id = ?", org_id)
+	}).Find(&order).Error
+	return
+}
+
+func GetHisOrderDetailByNumberThree(order_number string, org_id int64) (order []*HisOrderInfoTwo, err error) {
+	err = readDb.Model(&HisOrderInfoTwo{}).Where("order_number = ?", order_number).Preload("HisPrescriptionProject", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("VMHisProject", "status = 1 AND user_org_id = ?", org_id).Preload("VMGoodInfo", "status = 1 AND org_id = ?", org_id)
+	}).Preload("HisDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {
+		return db.Where("status = 1 AND user_org_id = ?", org_id).Preload("Drug", "status = 1 AND org_id = ?", org_id)
+	}).Find(&order).Error
+	return
+}
+
+func GetHisOrderByIDThree(order_id int64) (order models.HisOrder, err error) {
+	err = readDb.Model(&models.HisOrder{}).Where("id = ?", order_id).First(&order).Error
+	return
+}

service/his_summary_service.go

@@ -9,7 +9,7 @@ import (
 func GetHisSummaryDetailList(keyword string, item_type int64, patient_id int64, org_id int64, start_time int64, end_time int64) (patients []*models.ChargePatient, err error) {
 
 	err = XTReadDB().Table("xt_patients as p").Select("p.id,p.user_org_id,p.name,p.lapseto,p.status").Joins("JOIN his_order AS orders ON orders.patient_id = p.id AND orders.status = 1  AND orders.ctime >= ? AND orders.ctime <= ? AND orders.user_org_id = ? AND orders.order_status = 2 and orders.patient_id = ?", start_time, end_time, org_id, patient_id).Preload("HisChargeOrder", func(db *gorm.DB) *gorm.DB {
-		return db.Select("id,user_org_id,his_patient_id,settle_accounts_date,status,number,order_status,mdtrt_id,patient_id,psn_cash_pay,acct_pay,fund_pay_sumamt,is_medicine_insurance,medfee_sumamt").
+		return db.Select("id,user_org_id,his_patient_id,settle_accounts_date,status,number,order_status,mdtrt_id,patient_id,psn_cash_pay,acct_pay,fund_pay_sumamt,is_medicine_insurance,medfee_sumamt,maf_pay,hifes_pay").
 			Preload("HisChargeOrderInfo", func(db *gorm.DB) *gorm.DB {
 				return db.Select("id,order_number,advice_id,det_item_fee_sumamt,cnt,pric,med_chrgitm_type,status,chld_medc_flag,chrgitm_lv,user_org_id,project_id,type").Where("status = 1").
 					Preload("HisChargeDoctorAdviceInfo", func(db *gorm.DB) *gorm.DB {