耗材出库

models/dialysis.go

@@ -993,6 +993,14 @@ func (DialysisBeforePrepare) TableName() string {
 	return "dialysis_before_prepare"
 }
 
+type DialysisBeforePrepareGoods struct {
+	GoodId       int64  `gorm:"column:good_id" json:"good_id" form:"good_id"`
+	Count       int64  `gorm:"column:count" json:"count" form:"count"`
+	GoodTypeId   int64  `gorm:"column:good_type_id" json:"good_type_id" form:"good_type_id"`
+	TypeName   	 string  `gorm:"column:type_name" json:"type_name" form:"type_name"`
+	SpecificationName   string  `gorm:"column:specification_name" json:"specification_name" form:"specification_name"`
+}
+
 type QueueCallConfig struct {
 	ID         int64 `gorm:"column:id" json:"id" form:"id"`
 	OrgId      int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`

models/service/stock_service.go

@@ -1255,6 +1255,11 @@ func UpDateWarehouseInfo(warehouseInfo *models.WarehousingInfo) (err error) {
 	return
 }
 
+func UpDateWarehouseInfoByStock(warehouseInfo *models.WarehousingInfo) (err error) {
+	err = writeDb.Save(&warehouseInfo).Error
+	return
+}
+
 func UpDateWarehouseStatus(id int64) (err error) {
 	err = readDb.Model(&models.WarehousingInfo{}).Where("id = ? AND status = 1", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
 	return

models/stock_models.go

@@ -80,10 +80,7 @@ type WarehousingInfo struct {
 	ExpiryDate       int64       `gorm:"column:expiry_date" json:"expiry_date"`
 	WarehousingCount int64       `gorm:"column:warehousing_count" json:"warehousing_count"`
 	WarehousingUnit  string      `gorm:"column:warehousing_unit" json:"warehousing_unit"`
-	MaxUnit 		 string       `gorm:"column:max_unit" json:"max_unit"`
-	MinUnit 		 string       `gorm:"column:min_unit" json:"min_unit"`
-	StockMaxNumber   int64       `gorm:"column:stock_max_number" json:"stock_max_number"`
-	StockMinNumber   int64       `gorm:"column:stock_min_number" json:"stock_min_number"`
+	StockNumber   	 int64       `gorm:"column:stock_number" json:"stock_number"`
 	Price            float64     `gorm:"column:price" json:"price"`
 	TotalPrice       float64     `gorm:"column:total_price" json:"total_price"`
 	Dealer           int64       `gorm:"column:dealer" json:"dealer"`
@@ -131,6 +128,7 @@ func (WarehouseOut) TableName() string {
 type WarehouseOutInfo struct {
 	ID                      int64        `gorm:"column:id" json:"id"`
 	WarehouseOutId          int64        `gorm:"column:warehouse_out_id" json:"warehouse_out_id"`
+	WarehouseInfotId        int64        `gorm:"column:warehouse_info_id" json:"warehouse_info_id"`
 	GoodId                  int64        `gorm:"column:good_id" json:"good_id"`
 	GoodTypeId              int64        `gorm:"column:good_type_id" json:"good_type_id"`
 	WarehousingOutTarget    int64        `gorm:"column:warehousing_out_target" json:"warehousing_out_target"`
@@ -153,6 +151,7 @@ type WarehouseOutInfo struct {
 	Manufacturer            int64        `gorm:"column:manufacturer" json:"manufacturer"`
 	IsSys                   int64        `gorm:"column:is_sys" json:"is_sys"`
 	SysRecordTime           int64        `gorm:"column:sys_record_time" json:"sys_record_time"`
+	PatientId				int64 		 `gorm:"column:patient_id" json:"patient_id"`
 }
 
 func (WarehouseOutInfo) TableName() string {
@@ -308,6 +307,7 @@ type AutomaticReduceDetail struct {
 	GoodsType               GoodsType `gorm:"ForeignKey:GoodTypeId;AssociationForeignKey:ID" json:"type"`
 	Patients                Patients  `gorm:"ForeignKey:PatientId;AssociationForeignKey:ID" json:"user"`
 	Count                   int64     `gorm:"column:count" json:"count"`
+	Type                    int64     `gorm:"column:type" json:"type"`
 }
 
 func (AutomaticReduceDetail) TableName() string {

service/mobile_dialysis_service.go

@@ -1469,6 +1469,11 @@ func FindConsumablesByDate(orgID int64, patient_id int64, recordDate int64) (con
 	return
 }
 
+func FindConsumablesByDateTwo(orgID int64, patient_id int64, recordDate int64) (consumables []*models.DialysisBeforePrepare, err error) {
+	err = readDb.Model(&models.DialysisBeforePrepare{}).Where("user_org_id = ? AND patient_id = ? AND record_date = ? AND status = 1 AND count > 0", orgID, patient_id, recordDate).Find(&consumables).Error
+	return
+}
+
 //func FindLastConsumables(orgID int64, patient_id int64, recordDate int64) (consumables []*models.DialysisBeforePrepare, err error){
 //	err = readDb.Model(&models.DialysisBeforePrepare{}).Where("user_org_id = ? AND patient_id = ? AND record_date = ? AND status = 1", orgID, patient_id,recordDate).Find(&consumables).Error
 //	return

service/stock_service.go

@@ -453,13 +453,16 @@ func CreateDrugWarehousingInfo(warehousingInfo []*models.DrugWarehouseInfo) (err
 
 func FindLastWarehousingInfo(order string) (info models.WarehousingInfo, err error) {
 	err = readDb.Model(&models.WarehousingInfo{}).Where("warehousing_order = ? AND status = 1", order).Last(&info).Error
-
 	return info, err
+}
 
+func FindFirstWarehousingInfoByStock(good_id int64,good_type_id int64) (info models.WarehousingInfo, err error) {
+	err = readDb.Model(&models.WarehousingInfo{}).Where("good_id = ? AND good_type_id = ? AND status = 1 and stock_count > 0", order).Order("ctime").First(&info).Error
+	return info, err
 }
 
 // 出库时先进先出，找出最先入库的批次
-func FindLastWarehousingInfoByID(drug_id int64) (info models.WarehousingInfo, err error) {
+func  (drug_id int64) (info models.WarehousingInfo, err error) {
 	err = readDb.Model(&models.WarehousingInfo{}).Where("drup_id = ? AND status = 1 AND (stock_max_number > 0 or stock_min_number > 0) ", drug_id).Order("ctime").First(&info).Error
 
 	return info, err
@@ -1601,6 +1604,11 @@ func UpDateWarehouseInfoByStock(info *models.WarehousingInfo) (err error) {
 	return err
 }
 
+func UpDateWarehouseInfoByStockDelete(id int64,count int64) (err error) {
+	err = DB.Model(&models.WarehousingInfo{}).Where("id = ?",info.ID).UpdateColumn("stock_count", gorm.Expr("stock_count + ?", count)).Error
+	return err
+}
+
 func UpDateDrugWarehouseOutStatus(id int64) (err error) {
 	err = readDb.Model(&models.DrugWarehouseOutInfo{}).Where("id = ? AND status = 1", id).Update(map[string]interface{}{"status": 0, "mtime": time.Now().Unix()}).Error
 	return
@@ -2062,6 +2070,11 @@ func FindStockOutInfoByTypeId(org_id int64, good_type_id int64, good_id int64, o
 	return
 }
 
+func FindStockOutInfoByStock(org_id int64, good_type_id int64, good_id int64, record_date int64,patient_id int64) (out []*models.WarehouseOutInfo, err error) {
+	err = readDb.Model(&models.WarehouseOutInfo{}).Where("status = 1 AND org_id = ? AND good_type_id = ? AND good_id = ? AND is_sys = 1 AND sys_record_time = ? AND patient_id = ?", org_id, good_type_id, good_id, record_date, patient_id).Order("ctime desc").Find(&out).Error
+	return
+}
+
 func FindDrugStockOutInfoByTypeId(org_id int64, drug_id int64, out_id int64, number string) (out models.DrugWarehouseOutInfo, err error) {
 	err = readDb.Model(&models.DrugWarehouseOutInfo{}).Where("status = 1 AND org_id = ? AND  drug_id = ? AND is_sys = 1 AND  (warehouse_out_id = ? or warehouse_out_order_number = ?)", org_id, drug_id, out_id, number).First(&out).Error
 	return

service/warhouse_service.go

@@ -229,4 +229,318 @@ func DrugDeliverInfo(orgID int64,prescribingNumber float64,warehouseout *models.
 		advice.PrescribingNumberUnit = drup.MinUnit
 		DrugDeliverInfo(orgID ,prescribingNumber,warehouseout,drup ,advice )
 	}
+	return nil
+}
+
+// 耗材出库
+func ConsumablesDeliveryTotal(orgID int64,patient_id int64,record_time int64,goods []models.DialysisBeforePrepareGoods) (err error) {
+	//查询该患者当天已经出库的耗材信息
+	goods_yc,_ := FindConsumablesByDateTwo(orgID, patient_id, record_time)
+	// 和新请求的出库数据进行对比，分出那些是继续出库的，那些是需要删除出库的
+	for i := len(goods_yc) - 1; i >= 0; i--{
+		goods_yc_temp := goods_yc[i]
+		for j := len(goods) - 1; j >= 0; j-- {
+			goods_temp := goods[j]
+			// 已经出库和新请求出库都存在该耗材，则判断出库数量，分成是继续出库，还是删除出库
+			if goods_yc_temp.GoodTypeId == goods_temp.GoodTypeId && goods_yc_temp.GoodId == goods_temp.GoodId{
+				// 已经出库和新请求出库的出库数量一致，则清除两个结构体里的数据（既不出库，也不删除出库）
+				if goods_yc_temp.Count == goods_temp.Count {
+					goods_yc = append(goods_yc[:i],goods_yc[i+1:]...)
+					goods = append(goods[:j],goods[j+1:]...)
+				}
+
+				// 如果已经出库的数量 大于 新请求出库的数量，则代表需要删除出库
+				if goods_yc_temp.Count > goods_temp.Count {
+					temp_count := goods_yc_temp.Count - goods_temp.Count
+					goods_yc[i].Count = temp_count
+					goods = append(goods[:j],goods[j+1:]...)
+				}
+
+				// 如果已经出库的数量 小于 新请求出库的梳理，则代表需要增加出库
+				if goods_yc_temp.Count < goods_temp.Count {
+					temp_count := goods_temp.Count - goods_yc_temp.Count
+					goods[j].Count = temp_count
+					goods_yc = append(goods_yc[:i],goods_yc[i+1:]...)
+				}
+			}
+		}
+	}
+
+	// goods_yc 这个数据就是需要已经出库了，但是现在需要删除出库的耗材数据
+	// goods 这个数据就是需要出库的耗材的数据
+	if len(goods) > 0 {
+		out, err := FindStockOutByIsSys(orgID, 1, record_time)
+		if err == gorm.ErrRecordNotFound {
+			//没有记录，则创建出库单
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ :=  FindAllWarehouseOut(orgID)
+			total = total + 1
+			warehousing_out_order := strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
+			number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
+			number = number + total
+			warehousing_out_order = "CKD" + strconv.FormatInt(number, 10)
+			warehouseOut := models.WarehouseOut{
+				WarehouseOutOrderNumber: warehousing_out_order,
+				OperationTime:           time.Now().Unix(),
+				OrgId:                   orgID,
+				Creater:                 0,
+				Ctime:                   time.Now().Unix(),
+				Status:                  1,
+				WarehouseOutTime:        record_time,
+				Dealer:                  0,
+				Manufacturer:            0,
+				Type:                    1,
+				IsSys:                   1,
+			}
+			err := AddSigleWarehouseOut(&warehouseOut)
+			if err != nil {
+				utils.TraceLog("创建出库单失败 err = %v", err)
+				return err
+			} else {
+				out = warehouseOut
+			}
+		}
+		for _,good := range goods {
+			ConsumablesDelivery(orgID ,patient_id ,record_time ,good,out )
+		}
+	}
+
+	if len(goods_yc) > 0 {
+		for _,good_yc := range goods_yc{
+			ConsumablesDeliveryDelete(orgID ,patient_id ,record_time ,good_yc ,out )
+		}
+	} 
+	
+	return nil 
+}
+
+// 耗材出库
+func ConsumablesDelivery(orgID int64,patient_id int64,record_time int64,goods models.DialysisBeforePrepareGoods,warehouseOut models.WarehouseOut) (err error) {
+	// 判断处方里药品单位是拆零单位还是包装单位,	如果是包装单位，则根据规格，将包装数量转为拆零数量
+	var deliver_number int64 = 0
+	var stock_number int64 = 0
+
+	deliver_number = good.Count
+	
+
+	// 根据先进先出原则，查询最先入库的批次，进行出库
+	// 如果没有对应的库存，则报错
+	warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId,goods.GoodTypeId)
+	if err != nil {
+		return err
+	}
+
+	// 将该批次的剩余库存数量转换为拆零数量
+	stock_number = warehouse.StockCount
+	// 当库存数量大于或等于出库数量的话，则正常出库该批次
+	if stock_number >= deliver_number {
+		warehouseOutInfo := &models.WarehouseOutInfo{
+			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+			WarehouseOutId:          warehouseOut.ID,
+			WarehouseInfoId:		 warehouse.ID,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Remark:                  "",
+			OrgId:                   orgID,
+			Type:                    1,
+			Manufacturer:            0,
+			Dealer:                  0,
+			IsSys:                   1,
+			SysRecordTime:           record_time,
+			GoodTypeId:              goods..GoodTypeId,
+			GoodId:                  goods.GoodId,
+			PatientId:				 patient_id,
+		}
+		warehouseOutInfo.Count = goods.Count
+		stockInInfo, _ := FindLastStockInInfoRecord(goods.GoodId, orgID)
+		warehouseOutInfo.Price = stockInInfo.Price
+		errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
+		if errOne != nil {
+			return errOne
+		} else {
+			details := &models.AutomaticReduceDetail{
+				WarehouseOutId:          warehouseOutInfo.ID,
+				WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
+				PatientId:               patient_id,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   time.Now().Unix(),
+				Status:                  1,
+				RecordTime:              record_time,
+				OrgId:                   orgID,
+				GoodId:                  goods.GoodId,
+				GoodTypeId:              goods.GoodTypeId,
+				Count:                   goods.Count,
+			}
+			errTwo := service.AddSigleAutoReduceRecordInfo(details)
+			if errTwo != nil {
+				return errTwo
+			}
+		}
+
+		// 出库完成后，要减去对应批次的库存数量
+		
+		maxNumber = goods.Count
+		
+
+		if warehouse.StockMaxNumber < maxNumber {
+			return errors.New("库存数量不足")
+		}
+
+		warehouse.StockNumber = warehouse.StockMaxNumber - maxNumber
+		warehouse.Mtime = time.Now().Unix()
+	
+
+		if warehouse.StockNumber < 0 {
+			return errors.New("库存数量不足")
+		}
+		errThree := UpDateWarehouseInfoByStock(&warehouse)
+		if errThree != nil {
+			return errThree
+		}
+
+		return nil
+	}  else {
+		// 当改批次的库存数量小于出库数量的话，则先把该批次出库完后，再进行递归出库
+		warehouseOutInfo := &models.WarehouseOutInfo{
+			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+			WarehouseOutId:          warehouseOut.ID,
+			WarehouseInfoId:		 warehouse.ID,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Remark:                  "",
+			OrgId:                   orgID,
+			Type:                    1,
+			Manufacturer:            0,
+			Dealer:                  0,
+			IsSys:                   1,
+			SysRecordTime:           record_time,
+			GoodTypeId:              goods..GoodTypeId,
+			GoodId:                  goods.GoodId,
+			PatientId:				 patient_id,
+		}
+		warehouseOutInfo.Count = stock_number
+		stockInInfo, _ := service.FindLastStockInInfoRecord(goods.GoodId, orgID)
+		warehouseOutInfo.Price = stockInInfo.Price
+		errOne := service.AddSigleWarehouseOutInfo(warehouseOutInfo)
+		if errOne != nil {
+			return errOne
+		} else {
+			details := &models.AutomaticReduceDetail{
+				WarehouseOutId:          warehouseOutInfo.ID,
+				WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
+				PatientId:               patient_id,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   time.Now().Unix(),
+				Status:                  1,
+				RecordTime:              record_time,
+				OrgId:                   orgID,
+				GoodId:                  goods.GoodId,
+				GoodTypeId:              goods.GoodTypeId,
+				Count:                   goods.Count,
+			}
+			errTwo := service.AddSigleAutoReduceRecordInfo(details)
+			if errTwo != nil {
+				return errTwo
+			}
+		}
+		// 出库完成后，要将该批次库存清零
+		warehouse.StockNumber = 0
+		warehouse.Mtime = time.Now().Unix()
+		errThree := UpDateWarehouseInfoByStock(&warehouse)
+		if errThree != nil {
+			return errThree
+		}
+		// 清零完该库存后，还有剩余出库未出完，进行对应的递归操作
+		goods.Count := deliver_number - stock_number
+	
+		ConsumablesDelivery(orgID ,patient_id ,record_time ,good,out )
+	}
+	return nil
+}
+
+// 耗材出库删除
+func ConsumablesDeliveryDelete(orgID int64,patient_id int64,record_time int64,good_yc models.DialysisBeforePrepare,warehouseOut models.WarehouseOut) (err error) {
+	// 先根据相关信息查询当天该耗材的出库信息
+	warehouseOutInfos,err :=FindStockOutInfoByStock(orgID,good_yc.GoodTypeId,good_yc.GoodId,record_time,patient_id)
+	if err != nil {
+		return err
+	}
+	
+	var delete_count int64 = 0
+
+	for _ , ware := range warehouseOutInfos{
+		// 判断当前出库的数据和删除出库数量
+		if good_yc.Count <= ware.Count {
+			delete_count = good_yc.Count
+		} else {
+			delete_count = ware.Count
+		}
+		// 在出库记录表里记录退库详情
+		warehouseOutInfo := &models.WarehouseOutInfo{
+			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+			WarehouseOutId:          warehouseOut.ID,
+			WarehouseInfoId:		 warehouse.ID,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Remark:                  "",
+			OrgId:                   orgID,
+			Type:                    1,
+			Manufacturer:            0,
+			Dealer:                  0,
+			IsSys:                   2,
+			SysRecordTime:           record_time,
+			GoodTypeId:              goods..GoodTypeId,
+			GoodId:                  goods.GoodId,
+			PatientId:				 patient_id,
+		}
+		warehouseOutInfo.Count = delete_count
+		stockInInfo, _ := FindLastStockInInfoRecord(goods.GoodId, orgID)
+		warehouseOutInfo.Price = stockInInfo.Price
+		errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
+		if errOne != nil {
+			return errOne
+		} else {
+			details := &models.AutomaticReduceDetail{
+				WarehouseOutId:          warehouseOutInfo.ID,
+				WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
+				PatientId:               patient_id,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   time.Now().Unix(),
+				Status:                  1,
+				RecordTime:              record_time,
+				OrgId:                   orgID,
+				GoodId:                  goods.GoodId,
+				GoodTypeId:              goods.GoodTypeId,
+				Count:                   delete_count,
+				Type:					 2,
+			}
+			errTwo := AddSigleAutoReduceRecordInfo(details)
+			if errTwo != nil {
+				return errTwo
+			}
+		}
+
+		// 删除出库完成后，要增加对应批次的库存数量
+			
+		warehouse.StockNumber = warehouse.StockMaxNumber - maxNumber
+		warehouse.Mtime = time.Now().Unix()
+		
+
+		errThree := UpDateWarehouseInfoByStockDelete(ware.WarehouseInfoId,delete_count)
+		if errThree != nil {
+			return errThree
+		}
+
+		// 增加了对应的库存后，看看还有多少需要退库的
+		good_yc.Count = goods_yc - delete_count 
+		if good_yc.Count == 0 {
+			return nil
+		}
+	}
+	if good_yd.Count == 0 {
+		return nil 
+	}  else {
+		return errors.New("退库和出库数据不匹配")
+	}
 }