医嘱

controllers/doctors_api_controller.go

 		hisAdvices, err := service.GetHisDoctorAdvicesTwentyOne(orgID, date.Unix(), delivery_way, schedule_type, partition_type, patient_id, excution_way, 0, execution_frequency)
 		adminUser, _ := service.GetAllAdminUsers(orgID, adminUserInfo.CurrentAppId)
 		project, _ := service.GetPCHisPrescriptionProject(orgID, date.Unix(), delivery_way, patientType, partition_type, patient_id, excution_way)
+
+		drug, _ := service.GetAllBaseDrugListTwenty(orgID)
 		for _, item := range project {
 			index := 0
 			for _, subItem := range item.HisPrescriptionTeamProject {
 				"config":         config,
 				"project_config": project_config,
 				"project":        project,
+				"drug":           drug,
 			})
 		}
 	}

controllers/his_api_controller.go

 
 											}
 
-											//删除记录
 											service.DeleteAutoWarehouse(patient_id, recordDateTime)
 
 										}

controllers/mobile_api_controllers/dialysis_api_controller.go

 			}
 		}
 
-		fmt.Println("active------------------------------------", active)
-		fmt.Println("len------------------------------", len(goods))
 		//新增
 		if active == 1 && len(goods) > 0 {
 			for _, item := range dialysisBefor {
 
 				}
 
-				//退库
-				for _, item := range cancelbefor {
-					warehouseOut, _ := service.FindStockOutByIsSys(adminInfo.Org.Id, 1, record_time)
-					creater := adminInfo.AdminUser.Id
+				if len(cancelbefor) > 0 {
 					//退库
-					//err = ConsumablesDeliveryTotalSeven(adminInfo.Org.Id, patient_id, record_time, cancelbefor, adminInfo.AdminUser.Id, item.Count)
-					//查询该患者当天已经出库的耗材信息
+					for _, item := range cancelbefor {
+						warehouseOut, _ := service.FindStockOutByIsSys(adminInfo.Org.Id, 1, record_time)
+						creater := adminInfo.AdminUser.Id
 
-					warehouseOutInfos, _ := service.FindStockOutInfoByStockTwo(adminInfo.Org.Id, item.GoodTypeId, item.GoodId, record_time, patient_id)
+						//查询该患者当天已经出库的耗材信息
+						warehouseOutInfos, _ := service.FindStockOutInfoByStockTwo(adminInfo.Org.Id, item.GoodTypeId, item.GoodId, record_time, patient_id)
 
-					var delete_count int64 = 0
+						var delete_count int64 = 0
 
-					delete_count = warehouseOutInfos.Count - item.Count
+						delete_count = warehouseOutInfos.Count - item.Count
 
-					//增加库存数量
-					service.ModifyGoodAddInformation(item.GoodId, delete_count, adminInfo.Org.Id)
+						//增加库存数量
+						service.ModifyGoodAddInformation(item.GoodId, delete_count, adminInfo.Org.Id)
 
-					//增加出库库存数量
-					service.ModifyReduceGoodSumCount(houseConfig.StorehouseOutInfo, delete_count, adminInfo.Org.Id, item.GoodId)
+						//减少实际出库库存数量
+						service.ModifyReduceGoodSumCountTwenty(houseConfig.StorehouseOutInfo, delete_count, adminInfo.Org.Id, item.GoodId)
 
-					// 删除出库完成后，要增加对应批次的库存数量
+						// 删除出库完成后，要增加对应批次的库存数量
 
-					service.UpDateWarehouseInfoByStockDelete(warehouseOutInfos.WarehouseInfotId, delete_count, patient_id, record_time, item.GoodId)
+						service.UpDateWarehouseInfoByStockDelete(warehouseOutInfos.WarehouseInfotId, delete_count, patient_id, record_time, item.GoodId)
 
-					houseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+						houseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
 
-					//更新剩余库存
-					goodListOne, _ := service.GetSumGoodList(adminInfo.Org.Id, houseConfig.StorehouseOutInfo, item.GoodId)
-					var flush_count int64
-					for _, it := range goodListOne {
-						flush_count += it.StockCount
-					}
-					service.UpdateSumGood(adminInfo.Org.Id, houseConfig.StorehouseOutInfo, item.GoodId, flush_count)
+						//更新剩余库存
+						goodListOne, _ := service.GetSumGoodList(adminInfo.Org.Id, houseConfig.StorehouseOutInfo, item.GoodId)
+						var flush_count int64
+						for _, it := range goodListOne {
+							flush_count += it.StockCount
+						}
+						service.UpdateSumGood(adminInfo.Org.Id, houseConfig.StorehouseOutInfo, item.GoodId, flush_count)
 
-					//查询剩余库存
-					goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminInfo.Org.Id, houseConfig.StorehouseOutInfo)
-					var sum_count int64
-					for _, item := range goodList {
-						sum_count += item.StockCount
-					}
+						//查询剩余库存
+						goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminInfo.Org.Id, houseConfig.StorehouseOutInfo)
+						var sum_count int64
+						for _, item := range goodList {
+							sum_count += item.StockCount
+						}
 
-					// 在出库记录表里记录退库详情
-					warehouseOutInfo := &models.WarehouseOutInfo{
-						WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
-						WarehouseOutId:          warehouseOut.ID,
-						Status:                  1,
-						Ctime:                   time.Now().Unix(),
-						OrgId:                   adminInfo.Org.Id,
-						Type:                    1,
-						IsSys:                   1,
-						SysRecordTime:           record_time,
-						GoodTypeId:              item.GoodTypeId,
-						GoodId:                  item.GoodId,
-						PatientId:               patient_id,
-						ConsumableType:          2,
-						StorehouseId:            houseConfig.StorehouseOutInfo,
-						IsCheck:                 1,
-						OverCount:               sum_count,
-					}
-					warehouseOutInfo.Count = item.Count
-
-					stockInInfo, _ := service.FindLastStockInInfoRecord(item.GoodId, adminInfo.Org.Id)
-					warehouseOutInfo.Price = stockInInfo.Price
-					warehouseOutInfo.Dealer = stockInInfo.Dealer
-					warehouseOutInfo.Manufacturer = stockInInfo.Manufacturer
-					warehouseOutInfo.ExpiryDate = stockInInfo.ExpiryDate
-					warehouseOutInfo.ProductDate = stockInInfo.ProductDate
-					warehouseOutInfo.Number = warehouseOutInfos.Number
-					warehouseOutInfo.LicenseNumber = stockInInfo.LicenseNumber
-					warehouseOutInfo.WarehouseInfotId = stockInInfo.ID
-					//查找当天是否存在出库记录
-					_, errcod := service.GetWarehouseOutInfoIsExistOne(item.GoodId, patient_id, record_time, 0)
-
-					if errcod == gorm.ErrRecordNotFound {
-						service.AddSigleWarehouseOutInfo(warehouseOutInfo)
-						//插入详情明细表
-						stockFlow := models.VmStockFlow{
+						// 在出库记录表里记录退库详情
+						warehouseOutInfo := &models.WarehouseOutInfo{
 							WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 							WarehouseOutId:          warehouseOut.ID,
-							GoodId:                  item.GoodId,
-							Number:                  warehouseOutInfos.Number,
-							ProductDate:             stockInInfo.ProductDate,
-							ExpireDate:              stockInInfo.ExpiryDate,
-							Count:                   item.Count,
-							Price:                   stockInInfo.Price,
 							Status:                  1,
 							Ctime:                   time.Now().Unix(),
-							UserOrgId:               adminInfo.Org.Id,
-							Manufacturer:            stockInInfo.Manufacturer,
-							Dealer:                  stockInInfo.Dealer,
-							LicenseNumber:           stockInInfo.LicenseNumber,
-							IsEdit:                  2,
-							Creator:                 creater,
-							SystemTime:              record_time,
-							ConsumableType:          3,
-							WarehousingDetailId:     0,
+							OrgId:                   adminInfo.Org.Id,
+							Type:                    1,
 							IsSys:                   1,
-							UpdateCreator:           creater,
+							SysRecordTime:           record_time,
+							GoodTypeId:              item.GoodTypeId,
+							GoodId:                  item.GoodId,
 							PatientId:               patient_id,
+							ConsumableType:          2,
 							StorehouseId:            houseConfig.StorehouseOutInfo,
+							IsCheck:                 1,
+							OverCount:               sum_count,
 						}
-						exsit, errflow := service.GetStockFlowIsExsit(warehouseOutInfos.WarehouseInfotId, patient_id, record_time, item.GoodId)
-						if errflow == gorm.ErrRecordNotFound {
-							//创建流水表
-							err := service.CreateStockFlowOne(stockFlow)
-							fmt.Println("err", err)
-						} else if errflow == nil {
+						warehouseOutInfo.Count = item.Count
+
+						stockInInfo, _ := service.FindLastStockInInfoRecord(item.GoodId, adminInfo.Org.Id)
+						warehouseOutInfo.Price = stockInInfo.Price
+						warehouseOutInfo.Dealer = stockInInfo.Dealer
+						warehouseOutInfo.Manufacturer = stockInInfo.Manufacturer
+						warehouseOutInfo.ExpiryDate = stockInInfo.ExpiryDate
+						warehouseOutInfo.ProductDate = stockInInfo.ProductDate
+						warehouseOutInfo.Number = warehouseOutInfos.Number
+						warehouseOutInfo.LicenseNumber = stockInInfo.LicenseNumber
+						warehouseOutInfo.WarehouseInfotId = stockInInfo.ID
+						//查找当天是否存在出库记录
+						_, errcod := service.GetWarehouseOutInfoIsExistOne(item.GoodId, patient_id, record_time, 0)
+
+						if errcod == gorm.ErrRecordNotFound {
+							service.AddSigleWarehouseOutInfo(warehouseOutInfo)
 							//插入详情明细表
 							stockFlow := models.VmStockFlow{
-								ID:                      exsit.ID,
-								WarehousingId:           warehouseOutInfos.WarehouseInfotId,
 								WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 								WarehouseOutId:          warehouseOut.ID,
 								GoodId:                  item.GoodId,
 								Number:                  warehouseOutInfos.Number,
 								ProductDate:             stockInInfo.ProductDate,
 								ExpireDate:              stockInInfo.ExpiryDate,
-								Count:                   exsit.Count - delete_count,
+								Count:                   item.Count,
 								Price:                   stockInInfo.Price,
 								Status:                  1,
 								Ctime:                   time.Now().Unix(),
 								PatientId:               patient_id,
 								StorehouseId:            houseConfig.StorehouseOutInfo,
 							}
+							exsit, errflow := service.GetStockFlowIsExsit(warehouseOutInfos.WarehouseInfotId, patient_id, record_time, item.GoodId)
+							if errflow == gorm.ErrRecordNotFound {
+								//创建流水表
+								err := service.CreateStockFlowOne(stockFlow)
+								fmt.Println("err", err)
+							} else if errflow == nil {
+								//插入详情明细表
+								stockFlow := models.VmStockFlow{
+									ID:                      exsit.ID,
+									WarehousingId:           warehouseOutInfos.WarehouseInfotId,
+									WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+									WarehouseOutId:          warehouseOut.ID,
+									GoodId:                  item.GoodId,
+									Number:                  warehouseOutInfos.Number,
+									ProductDate:             stockInInfo.ProductDate,
+									ExpireDate:              stockInInfo.ExpiryDate,
+									Count:                   exsit.Count - delete_count,
+									Price:                   stockInInfo.Price,
+									Status:                  1,
+									Ctime:                   time.Now().Unix(),
+									UserOrgId:               adminInfo.Org.Id,
+									Manufacturer:            stockInInfo.Manufacturer,
+									Dealer:                  stockInInfo.Dealer,
+									LicenseNumber:           stockInInfo.LicenseNumber,
+									IsEdit:                  2,
+									Creator:                 creater,
+									SystemTime:              record_time,
+									ConsumableType:          3,
+									WarehousingDetailId:     0,
+									IsSys:                   1,
+									UpdateCreator:           creater,
+									PatientId:               patient_id,
+									StorehouseId:            houseConfig.StorehouseOutInfo,
+								}
 
-							service.UpdatedStockFlowOne(stockFlow, warehouseOut.ID, patient_id, record_time, item.GoodId)
-						}
+								service.UpdatedStockFlowOne(stockFlow, warehouseOut.ID, patient_id, record_time, item.GoodId)
+							}
 
-					} else if errcod == nil {
-						service.UpdatedWarehouseOutInfo(warehouseOutInfo, item.GoodId, patient_id, record_time, 0)
+						} else if errcod == nil {
+							service.UpdatedWarehouseOutInfo(warehouseOutInfo, item.GoodId, patient_id, record_time, 0)
 
-						fmt.Println("进来-------------------------------------------------")
+							//查询剩余库存
+							goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminInfo.Org.Id, houseConfig.StorehouseOutInfo)
+							var sum_count int64
+							for _, item := range goodList {
+								sum_count += item.StockCount
+							}
 
-						//查询剩余库存
-						goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminInfo.Org.Id, houseConfig.StorehouseOutInfo)
-						var sum_count int64
-						for _, item := range goodList {
-							sum_count += item.StockCount
+							//创建退库单,生成退库数据
+							houseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+							good, _ := service.FindGoodInfoByIdTwo(item.GoodId)
+
+							operation_time := time.Now().Unix()
+							creater := adminInfo.AdminUser.Id
+							//创建退库单
+							timeStr := time.Now().Format("2006-01-02")
+							timeArr := strings.Split(timeStr, "-")
+							total, _ := service.FindAllCancelStockTotal(adminInfo.Org.Id)
+							total = total + 1
+							orderNumber := "CKTKD" + strconv.FormatInt(adminInfo.Org.Id, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+
+							cancelStock := models.CancelStock{
+								OrderNumber:  orderNumber,
+								OperaTime:    operation_time,
+								OrgId:        adminInfo.Org.Id,
+								Creater:      creater,
+								Ctime:        time.Now().Unix(),
+								Status:       1,
+								ReturnTime:   record_time,
+								Type:         1,
+								StorehouseId: houseConfig.StorehouseOutInfo,
+								IsCheck:      1,
+							}
+							_, msgerrkonde := service.GetCancelStockDetailByOrderNumberOne(record_time, adminInfo.Org.Id)
+							if msgerrkonde == gorm.ErrRecordNotFound {
+								service.AddSigleCancelStock(&cancelStock)
+							}
+							cancel, _ := service.GetLastCancelStockById(adminInfo.Org.Id)
+
+							//查询是否有出库
+							info, _ := service.GetLastWarehoseByGoodId(item.GoodId, patient_id, record_time)
+
+							manufacturer, _ := service.GetManufactureById(info.Manufacturer)
+							deaerler, _ := service.GetDealerById(info.Dealer)
+
+							if info.ID > 0 {
+								cancelInfo, _ := service.GetLastCancelStockInfoByGoodId(item.GoodId)
+								cancelStockInfo := models.CancelStockInfo{
+									GoodId:          item.GoodId,
+									CancelStockId:   cancel.ID,
+									GoodTypeId:      good.GoodTypeId,
+									Count:           delete_count,
+									Price:           info.Price,
+									Total:           0,
+									ProductDate:     info.ProductDate,
+									ExpiryDate:      info.ExpiryDate,
+									Ctime:           time.Now().Unix(),
+									Status:          1,
+									OrgId:           adminInfo.Org.Id,
+									OrderNumber:     cancel.OrderNumber,
+									Type:            0,
+									Dealer:          deaerler.DealerName,
+									Manufacturer:    manufacturer.ManufacturerName,
+									Number:          info.Number,
+									RegisterAccount: "",
+									Remark:          "",
+									WarehouseInfoId: info.WarehouseInfotId,
+									PatientId:       info.PatientId,
+									RecordDate:      info.SysRecordTime,
+									StorehouseId:    houseConfig.StorehouseOutInfo,
+									IsCheck:         1,
+								}
+
+								service.CreateCancelStockInfoOne(&cancelStockInfo)
+
+								//退库数量增加
+								service.UpdateSumAddCancelCount(adminInfo.Org.Id, item.GoodId, houseConfig.StorehouseOutInfo, delete_count)
+
+								//查询剩余库存
+								goodList, _ := service.GetSumGoodList(adminInfo.Org.Id, houseConfig.StorehouseOutInfo, item.GoodId)
+								var over_count int64
+								for _, it := range goodList {
+									over_count += it.StockCount
+								}
+
+								flow := models.VmStockFlow{
+									WarehousingId:           info.WarehouseInfotId,
+									GoodId:                  item.GoodId,
+									Number:                  info.Number,
+									LicenseNumber:           info.LicenseNumber,
+									Count:                   delete_count,
+									UserOrgId:               adminInfo.Org.Id,
+									PatientId:               patient_id,
+									SystemTime:              info.SysRecordTime,
+									ConsumableType:          7,
+									IsSys:                   0,
+									WarehousingOrder:        "",
+									WarehouseOutId:          info.WarehouseOutId,
+									WarehouseOutOrderNumber: info.WarehouseOutOrderNumber,
+									IsEdit:                  0,
+									CancelStockId:           cancel.ID,
+									CancelOrderNumber:       cancel.OrderNumber,
+									Manufacturer:            manufacturer.ID,
+									Dealer:                  0,
+									Creator:                 adminInfo.AdminUser.Id,
+									UpdateCreator:           0,
+									Status:                  1,
+									Ctime:                   time.Now().Unix(),
+									Mtime:                   0,
+									Price:                   info.Price,
+									WarehousingDetailId:     info.WarehouseInfotId,
+									WarehouseOutDetailId:    info.ID,
+									CancelOutDetailId:       cancelInfo.ID,
+									ProductDate:             info.ProductDate,
+									ExpireDate:              info.ExpiryDate,
+									StorehouseId:            houseConfig.StorehouseOutInfo,
+									OverCount:               over_count,
+								}
+								service.CreateStockFlowOne(flow)
+
+							}
 						}
-						//插入详情明细表
-						stockFlow := models.VmStockFlow{
-							WarehousingId:           warehouseOutInfos.WarehouseInfotId,
-							WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
-							WarehouseOutId:          warehouseOut.ID,
+
+						//更改自动出库的表格
+						details := models.BloodAutomaticReduceDetail{
+							WarehouseOutId:          warehouseOutInfo.ID,
+							WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
+							PatientId:               patient_id,
+							Ctime:                   time.Now().Unix(),
+							Mtime:                   time.Now().Unix(),
+							Status:                  1,
+							RecordTime:              record_time,
+							OrgId:                   adminInfo.Org.Id,
 							GoodId:                  item.GoodId,
-							Number:                  warehouseOutInfos.Number,
-							ProductDate:             stockInInfo.ProductDate,
-							ExpireDate:              stockInInfo.ExpiryDate,
+							GoodTypeId:              item.GoodTypeId,
 							Count:                   item.Count,
-							Price:                   stockInInfo.Price,
-							Status:                  1,
-							Ctime:                   time.Now().Unix(),
-							UserOrgId:               adminInfo.Org.Id,
-							Manufacturer:            stockInInfo.Manufacturer,
-							Dealer:                  stockInInfo.Dealer,
-							LicenseNumber:           stockInInfo.LicenseNumber,
-							IsEdit:                  2,
-							Creator:                 creater,
-							SystemTime:              record_time,
-							ConsumableType:          3,
-							WarehousingDetailId:     0,
-							IsSys:                   1,
-							UpdateCreator:           creater,
-							PatientId:               patient_id,
-							ReturnCount:             delete_count,
 							StorehouseId:            houseConfig.StorehouseOutInfo,
-							OverCount:               sum_count,
-						}
-						exsit, errflows := service.GetStockFlowIsExsit(warehouseOutInfos.WarehouseInfotId, patient_id, record_time, item.GoodId)
-
-						if errflows == gorm.ErrRecordNotFound {
-							//创建流水表
-							service.CreateStockFlowOne(stockFlow)
-						} else if errflows == nil {
-							stockFlow := models.VmStockFlow{
-								WarehousingId:           warehouseOutInfos.WarehouseInfotId,
-								ID:                      exsit.ID,
-								WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
-								WarehouseOutId:          warehouseOut.ID,
-								GoodId:                  item.GoodId,
-								Number:                  warehouseOutInfos.Number,
-								ProductDate:             stockInInfo.ProductDate,
-								ExpireDate:              stockInInfo.ExpiryDate,
-								Count:                   exsit.Count - delete_count,
-								Price:                   stockInInfo.Price,
-								Status:                  1,
-								Ctime:                   time.Now().Unix(),
-								UserOrgId:               adminInfo.Org.Id,
-								Manufacturer:            stockInInfo.Manufacturer,
-								Dealer:                  stockInInfo.Dealer,
-								LicenseNumber:           stockInInfo.LicenseNumber,
-								IsEdit:                  2,
-								Creator:                 creater,
-								SystemTime:              record_time,
-								ConsumableType:          3,
-								WarehousingDetailId:     0,
-								IsSys:                   1,
-								UpdateCreator:           creater,
-								PatientId:               patient_id,
-								ReturnCount:             delete_count,
-								StorehouseId:            houseConfig.StorehouseOutInfo,
-								OverCount:               exsit.OverCount + delete_count,
-							}
-							fmt.Println("stockFlow--------------------", stockFlow.OverCount)
-							service.UpdatedStockFlowFive(stockFlow, warehouseOut.ID, patient_id, record_time, item.GoodId)
 						}
+						//查询当天耗材是否已经存在数据
+						_, errcode := service.GetAutoMaticReduceDetail(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
 
-					}
-
-					//更改自动出库的表格
-					details := models.BloodAutomaticReduceDetail{
-						WarehouseOutId:          warehouseOutInfo.ID,
-						WarehouseOutOrderNumber: warehouseOutInfo.WarehouseOutOrderNumber,
-						PatientId:               patient_id,
-						Ctime:                   time.Now().Unix(),
-						Mtime:                   time.Now().Unix(),
-						Status:                  1,
-						RecordTime:              record_time,
-						OrgId:                   adminInfo.Org.Id,
-						GoodId:                  item.GoodId,
-						GoodTypeId:              item.GoodTypeId,
-						Count:                   item.Count,
-						StorehouseId:            houseConfig.StorehouseOutInfo,
-					}
-					//查询当天耗材是否已经存在数据
-					_, errcode := service.GetAutoMaticReduceDetail(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
-
-					if errcode == gorm.ErrRecordNotFound {
-						service.CreateAutoReduceRecord(&details)
+						if errcode == gorm.ErrRecordNotFound {
+							service.CreateAutoReduceRecord(&details)
 
-					} else if errcode == nil {
-						service.DeleteAutoRedeceDetailTwo(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
-						service.CreateAutoReduceRecord(&details)
+						} else if errcode == nil {
+							service.DeleteAutoRedeceDetailTwo(adminInfo.Org.Id, patient_id, record_time, item.GoodId, item.GoodTypeId)
+							service.CreateAutoReduceRecord(&details)
 
-					}
+						}
 
-					//errOne := service.UpDateWarehouStockFlowByStockDelete(warehouseOutInfos.WarehouseInfotId, record_time, item.GoodId, delete_count, patient_id)
-					//fmt.Println("errOne", errOne)
+						//查询默认仓库
+						storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+						stockList, _ := service.GetStockCountByGoodId(item.GoodId, storeHouseConfig.StorehouseOutInfo, adminInfo.Org.Id)
+						var total_count int64
+						for _, it := range stockList {
+							total_count += it.StockCount
+						}
+						//基础库插入数据
+						service.UpdateGoodInfoReduceSumCount(item.GoodId, total_count, adminInfo.Org.Id)
 
-					//查询默认仓库
-					storeHouseConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
-					stockList, _ := service.GetStockCountByGoodId(item.GoodId, storeHouseConfig.StorehouseOutInfo, adminInfo.Org.Id)
-					var total_count int64
-					for _, it := range stockList {
-						total_count += it.StockCount
 					}
-					//基础库插入数据
-					service.UpdateGoodInfoReduceSumCount(item.GoodId, total_count, adminInfo.Org.Id)
-
 				}
 
 				fmt.Println("lnet---------------------------", len(outbefor))
 						//计算当前出库和最后一次出库数据相差数据
 						last_total = item.Count - goodInfoOne.Count
 
-						//查询该批次剩余库存
-						lastInfo, _ := service.GetLastStockOut(goodInfoOne.WarehouseInfotId)
-
-						if lastInfo.StockCount == 0 {
-							//查询该耗材的总库存
-							wareinfo, _ := service.GetStockGoodCount(item.GoodId)
-							if wareinfo.StockCount == 0 {
-								goodObj, _ := service.GetGoodInformationByGoodId(item.GoodId)
-								c.ServeSuccessJSON(map[string]interface{}{
-									"message":            "1",
-									"good_name":          goodObj.GoodName,
-									"specification_name": goodObj.SpecificationName,
-								})
-								return
-							}
-
-						}
-
 						//查询该耗材的总库存
 						wareinfo, _ := service.GetStockGoodCount(item.GoodId)
+
 						// 如果库存差大于剩余库存则提示库存不足
 						if last_total > wareinfo.StockCount {
 							goodObj, _ := service.GetGoodInformationByGoodId(item.GoodId)
 								ProjectId:    0,
 								StorehouseId: houseConfig.StorehouseOutInfo,
 							}
-							//fmt.Println("prepare", prepare.Count)
-							//fmt.Println("count", item.Count)
+
 							service.ConsumablesGoodDelivery(adminInfo.Org.Id, patient_id, record_time, &prepare, &out, item.Count)
 							//增加出库数量
 							service.ModifyGoodSumCount(houseConfig.StorehouseOutInfo, prepare.Count, adminInfo.Org.Id, item.GoodId)
 					for _, it := range goodList {
 						flush_count += it.StockCount
 					}
+
 					service.UpdateSumGood(adminInfo.Org.Id, storeHouseConfig.StorehouseOutInfo, it.GoodId, flush_count)
 
 				}
 				}
 				project_id := int64(items["project_id"].(float64))
 
+				new_count := int64(items["new_count"].(float64))
+				old_count := int64(items["old_count"].(float64))
+
 				prepare := &models.DialysisBeforePrepareGoods{
 					GoodId:       good_id,
 					GoodTypeId:   good_type_id,
 					Count:        count,
 					ProjectId:    project_id,
 					StorehouseId: houseConfig.StorehouseOutInfo,
+					NewCount:     new_count,
+					OldCount:     old_count,
 				}
+
 				beforePrepares = append(beforePrepares, prepare)
 
 				newPrepare := &models.NewDialysisBeforePrepareGoods{
 					Count:        count,
 					ProjectId:    project_id,
 					StorehouseId: houseConfig.StorehouseOutInfo,
+					NewCount:     new_count,
+					OldCount:     old_count,
 				}
+
 				newBeforePrepares = append(newBeforePrepares, newPrepare)
+
 			}
 		}
 	}
 
 	//查询是否有库存
+
 	for _, item := range beforePrepares {
-		storeConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
-		warehouse, _ := service.FindFirstWarehousingInfoByStockTwo(item.GoodId, item.GoodTypeId, storeConfig.StorehouseOutInfo)
-		if item.Count > warehouse.Count {
-			goodObj, _ := service.GetGoodInformationByGoodId(item.GoodId)
-			c.ServeSuccessJSON(map[string]interface{}{
-				"message":            "1",
-				"good_name":          goodObj.GoodName,
-				"specification_name": goodObj.SpecificationName,
-			})
-			return
+
+		if item.NewCount > 0 {
+			storeConfig, _ := service.GetAllStoreHouseConfig(adminInfo.Org.Id)
+			warehouse, _ := service.FindFirstWarehousingInfoByStockTwo(item.GoodId, item.GoodTypeId, storeConfig.StorehouseOutInfo)
+
+			if item.Count > warehouse.Count {
+				goodObj, _ := service.GetGoodInformationByGoodId(item.GoodId)
+				c.ServeSuccessJSON(map[string]interface{}{
+					"message":            "1",
+					"good_name":          goodObj.GoodName,
+					"specification_name": goodObj.SpecificationName,
+				})
+				return
+			}
 		}
+
 	}
 
 	//出库逻辑

controllers/new_mobile_api_controllers/dialysis_parameter_api_controller.go

 	loc, _ := time.LoadLocation("Local")
 	adminUserInfo := this.GetMobileAdminUserInfo()
 	orgid := adminUserInfo.Org.Id
-	fmt.Println(orgid)
 	keywords := this.GetString("keyword")
 	start_time := this.GetString("start_time")
-	fmt.Println("start_time", start_time)
 	limit, _ := this.GetInt64("limit")
-	fmt.Println(limit)
 	page, _ := this.GetInt64("page")
-	fmt.Println(page)
 	partitionType, _ := this.GetInt64("partitionType")
-	fmt.Println("partiontype", partitionType)
 	scheduleType, _ := this.GetInt64("scheduleType")
-	fmt.Println(scheduleType)
 
 	theTime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
 	if len(keywords) > 0 {

controllers/self_drug_api_congtroller.go

 	})
 }
 
-//库存优化接口
+// 库存优化接口
 func (this *SelfDrugApiController) GetStorehouseList() {
 
 	orgId := this.GetAdminUserInfo().CurrentOrgId

models/dialysis.go

 	PatientId         int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
 	OrderId           int64  `gorm:"column:order_id" json:"order_id" form:"order_id"`
 	NewCount          int64  `gorm:"column:new_count" json:"new_count" form:"new_count"`
+	OldCount          int64  `gorm:"column:old_count" json:"old_count" form:"old_count"`
 }
 
 type NewDialysisBeforePrepareGoods struct {
 	ChildNewDialysisBeforePrepareGoods []*NewDialysisBeforePrepareGoods `gorm:"ForeignKey:GoodId;AssociationForeignKey:GoodId" json:"child"`
 	PatientId                          int64                            `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
 	OrderId                            int64                            `gorm:"column:order_id" json:"order_id" form:"order_id"`
+	OldCount                           int64                            `gorm:"column:old_count" json:"old_count" form:"old_count"`
 }
 
 type OldDialysisBeforePrepareGoods struct {

routers/router.go

 func init() {
 	beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
 		//AllowAllOrigins:  true,
-		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://localhost:9529", "http://localhost:9531", "http://xt.test.shengws.com", "http://new_mobile.test.sgjyun.com", "https://xt.test.shengws.com", "http://xt.test.sgjyun.com", "https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com"},
+		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://localhost:9529", "http://localhost:9531", "http://xt.test.shengws.com", "http://new_mobile.test.sgjyun.com", "https://api.xt.test.sgjyun.com", "https://xt.test.shengws.com", "http://xt.test.sgjyun.com", "https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com"},
 		//AllowOrigins:     []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://xt.test.shengws.com","https://xt.test.shengws.com", "http://xt.test.sgjyun.com","https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com","https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com","http://mobile.sgjyun.com","http://mobile.kuyicloud.com"},
 		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
 		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type", "X-XSRF-TOKEN", "Permission", "KyToken"},

service/dialysis_service.go

 	advice_list_str, _ := redis.Get(key).Result()
 
 	if len(advice_list_str) == 0 { //没有到缓存数据，从数据库中获取数据，进行缓存到redis
-		err = readDb.Where("status = 1 AND user_org_id = ? AND advice_type = 2 AND advice_date = ? ", orgID, scheduleDate).Find(&advices).Error
+		err = readDb.Where("status = 1 AND user_org_id = ? AND advice_type = 2 AND advice_date = ? and id desc ", orgID, scheduleDate).Find(&advices).Error
 		if err != nil {
 			if err == gorm.ErrRecordNotFound {
 				if len(advices) <= 0 {

service/new_warehouse_service.go

 	// 如果没有对应的库存，则报错
 
 	warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId, goods.StorehouseId)
-	if err != nil {
-		return errors.New("库存数量不足")
+	if goods.Count > 0 {
+		if err != nil {
+			return errors.New("库存数量不足")
+		}
 	}
 
 	stock_number = warehouse.StockCount
 	if stock_number >= deliver_number {
 
 		maxNumber = goods.Count
+
 		//出库
 		warehouse.StockCount = warehouse.StockCount - maxNumber
 		warehouse.Mtime = time.Now().Unix()
 			warehouseOutInfo.Price = goodsInfo.PackingPrice
 		}
 		_, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
-		//fmt.Println("errcodes23332322332323223", errcodes, goods.ProjectId)
+
 		if errcodes == gorm.ErrRecordNotFound {
 			errOne := AddSigleWarehouseOutInfo(warehouseOutInfo)
 			if errOne != nil {
 		if warehouse.StockCount < 0 {
 			return errors.New("库存数量不足")
 		}
-		err := tx.Save(&warehouse).Error
+		var info models.WarehousingInfo
+		err := tx.Model(&info).Where("id = ?", warehouse.ID).Updates(map[string]interface{}{"stock_count": warehouse.StockCount}).Error
 		if err != nil {
 			return err
 		}
 	}
 	return err
 }
+
+func ConsumablesGoodDeliveryNew(orgID int64, patient_id int64, record_time int64, goods *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut, count int64) (err error) {
+
+	//开事务
+	tx := XTWriteDB().Begin()
+	if err != nil {
+		utils.ErrorLog("事务失败，原因为: %v", err)
+		tx.Rollback()
+	} else {
+		fmt.Println("err-----------------------", err)
+		tx.Commit()
+	}
+	var deliver_number int64 = 0
+	var stock_number int64 = 0
+	var maxNumber int64 = 0
+
+	deliver_number = goods.Count
+
+	// 根据先进先出原则，查询最先入库的批次，进行出库
+	// 如果没有对应的库存，则报错
+
+	warehouse, err := FindFirstWarehousingInfoByStock(goods.GoodId, goods.GoodTypeId, goods.StorehouseId)
+	if goods.Count > 0 {
+		if err != nil {
+			return errors.New("库存数量不足")
+		}
+	}
+
+	stock_number = warehouse.StockCount
+
+	// 当库存数量大于或等于出库数量的话，则正常出库该批次
+	if stock_number >= deliver_number {
+
+		maxNumber = goods.Count
+
+		//出库
+		warehouse.StockCount = warehouse.StockCount - maxNumber
+		warehouse.Mtime = time.Now().Unix()
+		if warehouse.StockCount < 0 {
+			return errors.New("库存数量不足")
+		}
+
+		err := tx.Save(&warehouse).Error
+		if err != nil {
+			return err
+		}
+		//更新his_prescripton_project出库状态值
+		UpdateHisPrescriptionProjectStatus(goods.GoodId, record_time, orgID, patient_id)
+
+		var info []*models.WarehousingInfo
+		err = tx.Where("good_id = ? and org_id = ? and is_check =1 and status= 1 and stock_count > 0 and storehouse_id = ?", goods.GoodId, orgID, goods.StorehouseId).Find(&info).Error
+		var sum_count int64
+		for _, item := range info {
+			sum_count += item.StockCount
+		}
+
+		warehouseOutInfo := &models.WarehouseOutInfo{
+			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+			WarehouseOutId:          warehouseOut.ID,
+			WarehouseInfotId:        warehouse.ID,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Remark:                  warehouse.Remark,
+			OrgId:                   orgID,
+			Type:                    1,
+			Manufacturer:            warehouse.Manufacturer,
+			Dealer:                  warehouse.Dealer,
+			IsSys:                   1,
+			SysRecordTime:           record_time,
+			GoodTypeId:              goods.GoodTypeId,
+			GoodId:                  goods.GoodId,
+			PatientId:               patient_id,
+			Number:                  warehouse.Number,
+			LicenseNumber:           warehouse.LicenseNumber,
+			Price:                   warehouse.PackingPrice,
+			ExpiryDate:              warehouse.ExpiryDate,
+			ProductDate:             warehouse.ProductDate,
+			ProjectId:               goods.ProjectId,
+			SupplyWarehouseId:       warehouse.SupplyWarehouseId,
+			StorehouseId:            goods.StorehouseId,
+			IsCheck:                 1,
+			OverCount:               sum_count,
+			RegisterNumber:          warehouse.RegisterNumber,
+		}
+		warehouseOutInfo.Count = count
+		if orgID == 9671 || orgID == 10265 {
+			goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+			warehouseOutInfo.Price = goodsInfo.PackingPrice
+		}
+		_, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
+		if errcodes == gorm.ErrRecordNotFound {
+			err := tx.Create(&warehouseOutInfo).Error
+			if err != nil {
+				return err
+			}
+		} else if errcodes == nil {
+
+			outInfoOne, _ := GetWarehouseOutInfoIsExistTwo(goods.GoodId, patient_id, record_time, goods.ProjectId)
+			if count != outInfoOne.Count {
+
+				outInfo := models.WarehouseOutInfo{}
+				err := tx.Model(&outInfo).Where("good_id = ? and patient_id = ? and sys_record_time  =? and status = 1", goods.GoodId, patient_id, record_time).Updates(map[string]interface{}{"warehouse_out_id": warehouseOutInfo.WarehouseOutId, "WarehouseOutOrderNumber": warehouseOutInfo.WarehouseOutOrderNumber, "sys_record_time": warehouseOutInfo.SysRecordTime, "good_type_id": warehouseOutInfo.GoodTypeId, "patient_id": warehouseOutInfo.PatientId, "consumable_type": warehouseOutInfo.ConsumableType, "count": warehouseOutInfo.Count, "price": warehouseOutInfo.Price, "dealer": warehouseOutInfo.Dealer, "manufacturer": warehouseOutInfo.Manufacturer, "number": warehouseOutInfo.Number, "license_number": warehouseOutInfo.LicenseNumber, "over_count": warehouseOutInfo.OverCount}).Error
+				if err != nil {
+					return err
+				}
+			}
+
+		}
+		lastOut, _ := FindWarehouseOutInfoByPatientId(patient_id, record_time, goods.GoodId, orgID)
+
+		//查询已经出库的数据
+		flowGood, _ := GetStockFlowIsBatchNumber(warehouse.ID, patient_id, record_time, goods.GoodId)
+		var out_count int64
+		var out_count_one int64
+		for _, item := range flowGood {
+			out_count += item.Count
+		}
+
+		//查询退库数据
+		flowGoodTwo, _ := GetStockFlowIsBatchNumberThree(patient_id, record_time, goods.GoodId)
+		for _, item := range flowGoodTwo {
+			out_count_one += item.Count
+		}
+		//如果本次出库数据大于历史出库数据 新增1条流水
+		if count > (out_count - out_count_one) {
+
+			flow := models.VmStockFlow{
+				WarehouseOutId:          warehouseOut.ID,
+				WarehousingId:           warehouse.ID,
+				GoodId:                  goods.GoodId,
+				Number:                  warehouse.Number,
+				ProductDate:             warehouse.ProductDate,
+				ExpireDate:              warehouse.ExpiryDate,
+				Count:                   count - out_count + out_count_one,
+				Price:                   warehouse.PackingPrice,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				UserOrgId:               orgID,
+				Manufacturer:            warehouse.Manufacturer,
+				Dealer:                  warehouse.Dealer,
+				LicenseNumber:           warehouse.LicenseNumber,
+				IsEdit:                  2,
+				Creator:                 warehouseOut.Creater,
+				SystemTime:              record_time,
+				ConsumableType:          3,
+				WarehouseOutDetailId:    lastOut.ID,
+				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+				IsSys:                   1,
+				PatientId:               patient_id,
+				ProjectId:               goods.ProjectId,
+				SupplyWarehouseId:       warehouse.SupplyWarehouseId,
+				StorehouseId:            goods.StorehouseId,
+				OverCount:               sum_count,
+				BuyPrice:                warehouse.Price,
+				RegisterNumber:          warehouse.RegisterNumber,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				flow.Price = goodsInfo.PackingPrice
+				flow.BuyPrice = goodsInfo.BuyPrice
+			}
+
+			err := tx.Create(&flow).Error
+			if err != nil {
+				return err
+			}
+
+		}
+
+		//如果本次出库数据小于历史出库数据 新增1条退库流水
+
+		if count < (out_count - out_count_one) {
+
+			operation_time := time.Now().Unix()
+
+			//创建退库单
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := FindAllCancelStockTotal(orgID)
+			total = total + 1
+			orderNumber := "CKTKD" + strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+
+			cancelStock := models.CancelStock{
+				OrderNumber:  orderNumber,
+				OperaTime:    operation_time,
+				OrgId:        orgID,
+				Creater:      warehouseOut.Creater,
+				Ctime:        time.Now().Unix(),
+				Status:       1,
+				ReturnTime:   record_time,
+				Type:         1,
+				StorehouseId: goods.StorehouseId,
+				IsCheck:      1,
+			}
+			_, msgerrkonde := GetCancelStockDetailByOrderNumberOne(record_time, orgID)
+			if msgerrkonde == gorm.ErrRecordNotFound {
+
+				err := tx.Create(&cancelStock).Error
+				if err != nil {
+					return err
+				}
+			}
+
+			cancel, _ := GetLastCancelStockById(orgID)
+
+			manufacturer, _ := GetManufactureById(warehouse.Manufacturer)
+			deaerler, _ := GetDealerById(warehouse.Dealer)
+			cancelStockInfo := models.CancelStockInfo{
+				GoodId:          goods.GoodId,
+				CancelStockId:   cancel.ID,
+				GoodTypeId:      goods.GoodTypeId,
+				Count:           out_count - out_count_one - count,
+				Price:           warehouse.PackingPrice,
+				Total:           0,
+				ProductDate:     warehouse.ProductDate,
+				ExpiryDate:      warehouse.ExpiryDate,
+				Ctime:           time.Now().Unix(),
+				Status:          1,
+				OrgId:           orgID,
+				OrderNumber:     cancel.OrderNumber,
+				Type:            0,
+				Dealer:          deaerler.DealerName,
+				Manufacturer:    manufacturer.ManufacturerName,
+				Number:          warehouse.Number,
+				RegisterAccount: "",
+				Remark:          "",
+				WarehouseInfoId: warehouse.ID,
+				PatientId:       patient_id,
+				RecordDate:      record_time,
+				StorehouseId:    goods.StorehouseId,
+				IsCheck:         1,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				cancelStockInfo.Price = goodsInfo.PackingPrice
+			}
+
+			err := tx.Create(&cancelStockInfo).Error
+			if err != nil {
+				return err
+			}
+
+			cancelInfo, _ := GetLastCancelStockInfoByGoodId(goods.GoodId)
+
+			flow := models.VmStockFlow{
+				WarehousingId:           warehouse.ID,
+				GoodId:                  goods.GoodId,
+				Number:                  warehouse.Number,
+				LicenseNumber:           warehouse.LicenseNumber,
+				Count:                   out_count - out_count_one - count,
+				UserOrgId:               orgID,
+				PatientId:               patient_id,
+				SystemTime:              record_time,
+				ConsumableType:          7,
+				IsSys:                   1,
+				WarehousingOrder:        "",
+				WarehouseOutId:          lastOut.WarehouseOutId,
+				WarehouseOutOrderNumber: lastOut.WarehouseOutOrderNumber,
+				IsEdit:                  0,
+				CancelStockId:           cancel.ID,
+				CancelOrderNumber:       cancel.OrderNumber,
+				Manufacturer:            manufacturer.ID,
+				Dealer:                  0,
+				Creator:                 warehouseOut.Creater,
+				UpdateCreator:           0,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   0,
+				Price:                   warehouse.PackingPrice,
+				WarehousingDetailId:     warehouse.ID,
+				WarehouseOutDetailId:    lastOut.ID,
+				CancelOutDetailId:       cancelInfo.ID,
+				ProductDate:             warehouse.ProductDate,
+				ExpireDate:              warehouse.ExpiryDate,
+				StorehouseId:            goods.StorehouseId,
+				BuyPrice:                warehouse.Price,
+				ProjectId:               goods.ProjectId,
+				OverCount:               sum_count,
+				RegisterNumber:          warehouse.RegisterNumber,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				flow.Price = goodsInfo.PackingPrice
+				flow.BuyPrice = goodsInfo.BuyPrice
+			}
+
+			err = tx.Create(&flow).Error
+			if err != nil {
+				return err
+			}
+		}
+
+		details := models.BloodAutomaticReduceDetail{
+			WarehouseOutId:          lastOut.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:                   count,
+			ProjectId:               goods.ProjectId,
+			StorehouseId:            goods.StorehouseId,
+		}
+
+		////查询该耗材已经出库的数量
+		_, errcode := GetAutoMaticReduceDetailTwenty(orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId)
+		if errcode == gorm.ErrRecordNotFound {
+
+			err := tx.Create(&details).Error
+			if err != nil {
+				return err
+			}
+		} else if errcode == nil {
+
+			detail := models.BloodAutomaticReduceDetail{}
+			err := tx.Model(&detail).Where("org_id = ? and patient_id = ? and record_time = ? and status =1 and good_id = ? and good_type_id = ?", orgID, patient_id, record_time, goods.GoodId, goods.GoodTypeId).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
+			if err != nil {
+				return err
+			}
+
+			err = tx.Create(&detail).Error
+			if err != nil {
+				return err
+			}
+		}
+
+		return nil
+	} else {
+
+		// 当刚批次的库存数量小于出库数量的话，则先把该批次出库完后，再进行递归出库
+		warehouse.StockCount = 0
+		warehouse.Mtime = time.Now().Unix()
+
+		err := tx.Save(&warehouse).Error
+		if err != nil {
+			return err
+		}
+		var info []*models.WarehousingInfo
+		err = tx.Where("good_id = ? and org_id = ? and is_check =1 and status= 1 and stock_count > 0 and storehouse_id = ?", goods.GoodId, orgID, goods.StorehouseId).Find(&info).Error
+		var sum_count int64
+		for _, item := range info {
+			sum_count += item.StockCount
+		}
+		warehouseOutInfo := &models.WarehouseOutInfo{
+			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+			WarehouseOutId:          warehouseOut.ID,
+			WarehouseInfotId:        warehouse.ID,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Remark:                  warehouse.Remark,
+			OrgId:                   orgID,
+			Type:                    1,
+			Manufacturer:            warehouse.Manufacturer,
+			Dealer:                  warehouse.Dealer,
+			IsSys:                   1,
+			SysRecordTime:           record_time,
+			GoodTypeId:              goods.GoodTypeId,
+			GoodId:                  goods.GoodId,
+			PatientId:               patient_id,
+			Number:                  warehouse.Number,
+			LicenseNumber:           warehouse.LicenseNumber,
+			Price:                   warehouse.PackingPrice,
+			ExpiryDate:              warehouse.ExpiryDate,
+			ProductDate:             warehouse.ProductDate,
+			ProjectId:               goods.ProjectId,
+			SupplyWarehouseId:       warehouse.SupplyWarehouseId,
+			StorehouseId:            goods.StorehouseId,
+			IsCheck:                 1,
+			OverCount:               sum_count,
+			RegisterNumber:          warehouse.RegisterNumber,
+		}
+		warehouseOutInfo.Count = stock_number
+		if orgID == 9671 || orgID == 10265 {
+			goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+			warehouseOutInfo.Price = goodsInfo.PackingPrice
+		}
+		_, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
+
+		if errcodes == gorm.ErrRecordNotFound {
+
+			errors := tx.Create(warehouseOutInfo).Error
+			if errors != nil {
+				return errors
+			}
+		} else if errcodes == nil {
+			goods.Count = deliver_number - stock_number
+			//更新数量为  该批次剩余数量  + 还有未出的数量
+			warehouseOutInfo.Count = stock_number
+			outInfoOne, _ := GetWarehouseOutInfoIsExistTwo(goods.GoodId, patient_id, record_time, goods.ProjectId)
+			if count != outInfoOne.Count {
+
+				outInfo := models.WarehouseOutInfo{}
+				err := tx.Model(&outInfo).Where("good_id = ? and patient_id = ? and sys_record_time  =? and status = 1", goods.GoodId, patient_id, record_time).Updates(map[string]interface{}{"warehouse_out_id": warehouseOutInfo.WarehouseOutId, "WarehouseOutOrderNumber": warehouseOutInfo.WarehouseOutOrderNumber, "sys_record_time": warehouseOutInfo.SysRecordTime, "good_type_id": warehouseOutInfo.GoodTypeId, "patient_id": warehouseOutInfo.PatientId, "consumable_type": warehouseOutInfo.ConsumableType, "count": warehouseOutInfo.Count, "price": warehouseOutInfo.Price, "dealer": warehouseOutInfo.Dealer, "manufacturer": warehouseOutInfo.Manufacturer, "number": warehouseOutInfo.Number, "license_number": warehouseOutInfo.LicenseNumber, "over_count": warehouseOutInfo.OverCount}).Error
+				if err != nil {
+					return err
+				}
+			}
+
+		}
+		lastOut, _ := FindWarehouseOutInfoByPatientId(patient_id, record_time, goods.GoodId, orgID)
+		//查询该该批次已经出库的数据
+		flowGood, _ := GetStockFlowIsBatchNumber(warehouse.ID, patient_id, record_time, goods.GoodId)
+		var out_count int64
+		var out_count_one int64
+		for _, item := range flowGood {
+			out_count += item.Count
+		}
+		flowGoodTwo, _ := GetStockFlowIsBatchNumberThree(patient_id, record_time, goods.GoodId)
+		for _, item := range flowGoodTwo {
+			out_count_one += item.Count
+		}
+		//如果出库数量 大于 历史出库数据 新增1条流水
+		if count > out_count-out_count_one {
+			flow := models.VmStockFlow{
+				WarehouseOutId:          warehouseOut.ID,
+				WarehousingId:           warehouse.ID,
+				GoodId:                  goods.GoodId,
+				Number:                  warehouse.Number,
+				ProductDate:             warehouse.ProductDate,
+				ExpireDate:              warehouse.ExpiryDate,
+				Count:                   stock_number,
+				Price:                   warehouse.PackingPrice,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				UserOrgId:               orgID,
+				Manufacturer:            warehouse.Manufacturer,
+				Dealer:                  warehouse.Dealer,
+				LicenseNumber:           warehouse.LicenseNumber,
+				IsEdit:                  2,
+				Creator:                 warehouseOut.Creater,
+				SystemTime:              record_time,
+				ConsumableType:          3,
+				WarehouseOutDetailId:    lastOut.ID,
+				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+				IsSys:                   1,
+				PatientId:               patient_id,
+				ProjectId:               goods.ProjectId,
+				SupplyWarehouseId:       warehouse.SupplyWarehouseId,
+				StorehouseId:            goods.StorehouseId,
+				OverCount:               sum_count,
+				BuyPrice:                warehouse.Price,
+				RegisterNumber:          warehouse.RegisterNumber,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				flow.Price = goodsInfo.PackingPrice
+				flow.BuyPrice = goodsInfo.BuyPrice
+			}
+
+			err := tx.Create(&flow).Error
+			if err != nil {
+				return err
+			}
+		}
+		//退库
+		if count < out_count-out_count_one {
+			operation_time := time.Now().Unix()
+
+			//创建退库单
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := FindAllCancelStockTotal(orgID)
+			total = total + 1
+			orderNumber := "CKTKD" + strconv.FormatInt(orgID, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+
+			cancelStock := models.CancelStock{
+				OrderNumber:  orderNumber,
+				OperaTime:    operation_time,
+				OrgId:        orgID,
+				Creater:      warehouseOut.Creater,
+				Ctime:        time.Now().Unix(),
+				Status:       1,
+				ReturnTime:   record_time,
+				Type:         1,
+				StorehouseId: goods.StorehouseId,
+				IsCheck:      1,
+			}
+			_, msgerrkonde := GetCancelStockDetailByOrderNumberOne(record_time, orgID)
+			if msgerrkonde == gorm.ErrRecordNotFound {
+
+				err := tx.Create(&cancelStock).Error
+				if err != nil {
+					return err
+				}
+			}
+
+			cancel, _ := GetLastCancelStockById(orgID)
+
+			manufacturer, _ := GetManufactureById(warehouse.Manufacturer)
+			deaerler, _ := GetDealerById(warehouse.Dealer)
+			cancelStockInfo := models.CancelStockInfo{
+				GoodId:          goods.GoodId,
+				CancelStockId:   cancel.ID,
+				GoodTypeId:      goods.GoodTypeId,
+				Count:           out_count - out_count_one - count,
+				Price:           warehouse.PackingPrice,
+				Total:           0,
+				ProductDate:     warehouse.ProductDate,
+				ExpiryDate:      warehouse.ExpiryDate,
+				Ctime:           time.Now().Unix(),
+				Status:          1,
+				OrgId:           orgID,
+				OrderNumber:     cancel.OrderNumber,
+				Type:            0,
+				Dealer:          deaerler.DealerName,
+				Manufacturer:    manufacturer.ManufacturerName,
+				Number:          warehouse.Number,
+				RegisterAccount: "",
+				Remark:          "",
+				WarehouseInfoId: warehouse.ID,
+				PatientId:       patient_id,
+				RecordDate:      record_time,
+				StorehouseId:    goods.StorehouseId,
+				IsCheck:         1,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				cancelStockInfo.Price = goodsInfo.PackingPrice
+			}
+
+			err := tx.Create(&cancelStockInfo).Error
+			if err != nil {
+				return err
+			}
+
+			cancelInfo, _ := GetLastCancelStockInfoByGoodId(goods.GoodId)
+
+			flow := models.VmStockFlow{
+				WarehousingId:           warehouse.ID,
+				GoodId:                  goods.GoodId,
+				Number:                  warehouse.Number,
+				LicenseNumber:           warehouse.LicenseNumber,
+				Count:                   out_count - count,
+				UserOrgId:               orgID,
+				PatientId:               patient_id,
+				SystemTime:              record_time,
+				ConsumableType:          7,
+				IsSys:                   1,
+				WarehousingOrder:        "",
+				WarehouseOutId:          lastOut.WarehouseOutId,
+				WarehouseOutOrderNumber: lastOut.WarehouseOutOrderNumber,
+				IsEdit:                  0,
+				CancelStockId:           cancel.ID,
+				CancelOrderNumber:       cancel.OrderNumber,
+				Manufacturer:            manufacturer.ID,
+				Dealer:                  0,
+				Creator:                 warehouseOut.Creater,
+				UpdateCreator:           0,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   0,
+				Price:                   warehouse.PackingPrice,
+				WarehousingDetailId:     warehouse.ID,
+				WarehouseOutDetailId:    lastOut.ID,
+				CancelOutDetailId:       cancelInfo.ID,
+				ProductDate:             warehouse.ProductDate,
+				ExpireDate:              warehouse.ExpiryDate,
+				StorehouseId:            goods.StorehouseId,
+				BuyPrice:                warehouse.Price,
+				ProjectId:               goods.ProjectId,
+				OverCount:               sum_count,
+				RegisterNumber:          warehouse.RegisterNumber,
+			}
+			if orgID == 9671 || orgID == 10265 {
+				goodsInfo, _ := FindeGoodInfo(orgID, goods.ProjectId)
+				flow.Price = goodsInfo.PackingPrice
+				flow.BuyPrice = goodsInfo.BuyPrice
+			}
+			err = tx.Create(&flow).Error
+			if err != nil {
+				return err
+			}
+		}
+
+		// 清零完该库存后，还有剩余出库未出完，进行对应的递归操作
+		goods.Count = deliver_number - stock_number
+
+		ConsumablesGoodDelivery(orgID, patient_id, record_time, goods, warehouseOut, count)
+
+	}
+
+	return nil
+}

service/patientmanage_service.go

 	if projectid > 0 {
 		db = db.Where("x.project_id = ?", projectid)
 	}
-	err = db.Group("x.id").Select("x.id,x.patient_id,x.org_id,x.project_id,x.item_id,x.item_name,x.project_name,x.inspect_type,x.inspect_value,x.inspect_date,x.status,x.created_time,x.updated_time,r.range_type,r.range_min,r.range_max,r.range_value,r.range_options,r.unit").Joins("left join xt_inspection_reference as r on (r.item_id = x.item_id AND r.org_id > 0) OR ( x.item_id = r.id AND r.org_id = 0)   ").Scan(&inspection).Error
+	err = db.Group("x.id").Select("x.id,x.patient_id,x.org_id,x.project_id,x.item_id,x.item_name,x.project_name,x.inspect_type,x.inspect_value,x.inspect_date,x.status,x.created_time,x.updated_time,r.range_type,r.range_min,r.range_max,r.range_value,r.range_options,r.unit").Joins("left join xt_inspection_reference as r on (r.item_id = x.item_id AND r.org_id = x.org_id) OR ( x.item_id = r.id AND r.org_id = 0)   ").Scan(&inspection).Error
 	return inspection, err
 }
 

service/pharmacy_service.go

 	XTWriteDB().Create(&tmp)
 }
 
-//
 func SavePharmacy() (err error) {
 	var advice_info []*models.HisDoctorAdviceInfo
 	err = XTReadDB().Raw("select * from xt_doctor_advice where id > 21780 and id < 21790").Scan(&advice_info).Error
 	return nil
 }
 
-//查询药房中某一天的患者人数,is_medicine:0未发，1已发(改)
+// 查询药房中某一天的患者人数,is_medicine:0未发，1已发(改)
 func GetTodayPharmacy(stime, etime, orgid, is_medicine int64) (num int, err error) {
 	//orgid = 9675
 	InitDrugidIsNil(orgid, stime, etime)
 
 }
 
-//(改)
+// (改)
 func GetTodayDrug(stime, etime, orgid, is_medicine int64, keyword string) (list []*models.TmpPatient, err error) {
 	InitDrugidIsNil(orgid, stime, etime)
 	//病人
 
 }
 
-//查询患者（改）
+// 查询患者（改）
 func GetManyUsers(tmp []int64) (list []*models.TmpPatient, err error) {
 
 	for i := 0; i < len(tmp); i++ {
 	return
 }
 
-//查询患者当天时间段中的药,is_medicine:0未发，1已发(改)
+// 查询患者当天时间段中的药,is_medicine:0未发，1已发(改)
 func GetPatientMedication(orgid, patient_id, stime, etime, is_medicine int64) (pp []*models.PharmacyContent, err error) {
 	InitDrugidIsNil(orgid, stime, etime)
 	var tmp []*models.HisDoctorAdviceInfoL
 	return
 }
 
-//获取创建者姓名(改)
+// 获取创建者姓名(改)
 func GetAdminUserName(doctor, orgid int64) string {
 	var tmp models.VmUserAdminRole
 	XTReadDB().Model(&models.VmUserAdminRole{}).Where("admin_user_id = ? and org_id = ? and status = 1", doctor, orgid).Find(&tmp)
 	return tmp.UserName
 }
 
-//查询该机构的药房配置,true: 通过药房发药，false：不通过药房发药。如果没有该机构的信息则生成一条数据
+// 查询该机构的药房配置,true: 通过药房发药，false：不通过药房发药。如果没有该机构的信息则生成一条数据
 func GetOrgIdPharmacyConfig(orgid int64) bool {
 	var total int
 	var tmp_pharmacy models.PharmacyConfig
 	}
 }
 
-//修改该机构的药房配置
+// 修改该机构的药房配置
 func ModifyPharmacyConfig(orgid, isopen int64) (err error) {
 	if isopen == 1 || isopen == 2 {
 		err = XTWriteDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and status = 1", orgid).Updates(map[string]interface{}{
 	return
 }
 
-//查询该药品是否通过药房发药.0否；1是
+// 查询该药品是否通过药房发药.0否；1是
 func DrugAllocation(drug_id int64) (is_pharmacy int64, err error) {
 	tmp := models.BaseDrugLib{}
 	err = XTReadDB().Model(&models.BaseDrugLib{}).Where("id = ?", drug_id).Find(&tmp).Error
 	return tmp.IsPharmacy, err
 }
 
-//根据id查询该药是否发药
+// 根据id查询该药是否发药
 func MedicineState(id int64) (is_medicine models.HisDoctorAdviceInfoL, err error) {
 	tmp := models.HisDoctorAdviceInfoL{}
 	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("id = ?", id).Find(&tmp).Error
 	return tmp, err
 }
 
-//发药明细列表(
+// 发药明细列表(
 func DispensingDetailsList(stime, etime, orgid, page, limit int64, keyword string) (dislist []*models.DispensingList, total int64, err error) {
 	var fenye []*models.Pharmary //分页用的
 	offset := (page - 1) * limit
 	return
 }
 
-//处方详情//////////////////////
+// 处方详情//////////////////////
 func PrescriptionDetails(patient_id, record_date, orgid int64) (pre []*models.PrescripDetails, err error) {
 	var tmp []*models.HisDoctorAdviceInfoL
 	err = XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where(
 	return
 }
 
-//查询病人的his id
+// 查询病人的his id
 func GetHisID(prescription_id, orgid int64) (id int64) {
 	var tmp models.HisPrintPrescription
 	XTReadDB().Model(&models.HisPrintPrescription{}).Where("id = ?", prescription_id).Find(&tmp)
 	return fin.ID
 }
 
-//根据药品id获取药品信息
+// 根据药品id获取药品信息
 func GetDrugNameTX(id int64, tx *gorm.DB) (tmp models.SpBaseDrug, err error) {
 	err = tx.Model(&models.SpBaseDrug{}).Where("id = ? and status = 1", id).Find(&tmp).Error
 	return
 	return
 }
 
-//查询药品（使用keyword）
+// 查询药品（使用keyword）
 func GetManyDrugs(orgid int64, keyword string) (map[int64]models.PharmacyBaseDrug, error) {
 	var tmp []*models.PharmacyBaseDrug
 	tt := make(map[int64]models.PharmacyBaseDrug)
 	return tt, err
 }
 
-//查询(
+// 查询(
 func GetTodayMedicine(stime, etime, orgid, is_medicine int64, keyword string) (finlly []*models.ListOfDrugs, err error) {
 	InitDrugidIsNil(orgid, stime, etime)
 	var tmp []*models.TmpLLL
 	return
 }
 
-//根据药品id获取药品规格(
+// 根据药品id获取药品规格(
 func FindDrugSpecifications(id int64) (name, specifications string) {
 	var tmp models.PharmacyBaseDrug
 	XTReadDB().Model(&models.PharmacyBaseDrug{}).Where("id = ?", id).Find(&tmp)
 	return
 }
 
-//根据药品id获取当前药品出库仓库的库存数量
+// 根据药品id获取当前药品出库仓库的库存数量
 func GetInventoryQuantity(orgid, drugid int64) (number string, err error) {
 	//获取药品拆零数量
 	var phar models.PharmacyBaseDrug
 	return
 }
 
-//获取该药品的病人信息(
+// 获取该药品的病人信息(
 func FindMedicationList(orgid, drug_id, stime, etime, is_medicine int64) (pp []*models.PatientInformation, err error) { ///////////////
 	InitDrugidIsNil(orgid, stime, etime)
 	var tmp []*models.HisDoctorAdviceInfoL
 	return
 }
 
-//患者发药按钮点击（
+// 患者发药按钮点击（
 func DispensingMedicine(orgid, patient_id, stime, etime, creater int64) (err error) {
 	//开事务
 	tx := XTWriteDB().Begin()
 	return
 }
 
-//患者退药按钮点击
+// 患者退药按钮点击
 func DrugWithdrawal(orgid, patient_id, stime, etime, creater int64) (err error) {
 	//开事务
 	tx := XTWriteDB().Begin()
 	return
 }
 
-//获取患者名称
+// 获取患者名称
 func FindUserName(patient_id int64) (name string) {
 	var tmp models.GetHisName
 	XTReadDB().Model(&models.GetHisName{}).Where("id = ?", patient_id).Find(&tmp)
 	return
 }
 
-//获取药品名称
+// 获取药品名称
 func FindDrugsName(drug_id int64) (name string) {
 	var tmp models.Drug
 	XTReadDB().Model(&models.Drug{}).Where("id = ?", drug_id).Find(&tmp)
 	return
 }
 
-//药品发药按钮点击(
+// 药品发药按钮点击(
 func MedicineDeparture(ids string, creater, orgid int64) (err error) {
 	//开事务
 	tx := XTWriteDB().Begin()
 	return
 }
 
-//获取领药人姓名（
+// 获取领药人姓名（
 func GetUserAdminName(id, orgID int64) string {
 	var tmp models.XTSgjUserAdminRole
 	XTReadDB().Model(&models.XTSgjUserAdminRole{}).Where("admin_user_id = ? and org_id = ?", id, orgID).Find(&tmp)
 	return tmp.UserName
 }
 
-//根据id查询是否已发药,true已发药，false未发药gai
+// 根据id查询是否已发药,true已发药，false未发药gai
 func GiveTheMedicine(id int64) bool {
 	var xue models.PharmacyDoctorAdvice
 	XTReadDB().Model(&models.PharmacyDoctorAdvice{}).Where("id = ?", id).Find(&xue)
 	return false
 }
 
-//查询改组中的药品是否包含已发药的，true已发药，false未发药
+// 查询改组中的药品是否包含已发药的，true已发药，false未发药
 func GiveGroupMedicine(orgid, groupNo int64) bool {
 	var total int
 	XTReadDB().Model(&models.DoctorAdvice{}).Where("user_org_id = ? and groupno = ? and status = 1 and is_medicine = 1", orgid, groupNo).Count(&total)
 	return false
 }
 
-//查询处方中是否包含已发药的
+// 查询处方中是否包含已发药的
 func GiveChuMedicine(id int64) bool {
 	var total int
 	XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("prescription_id = ? and status = 1 and is_medicine = 1", id).Count(&total)
 	return false
 }
 
-//根据处方id查找该处方中是否存在已发药的药品
+// 根据处方id查找该处方中是否存在已发药的药品
 func IsChuIssuedDrugs(prescription_id int64) bool {
 	var total int
 	XTReadDB().Model(&models.HisDoctorAdviceInfoL{}).Where("prescription_id = ? and status = 1 and is_medicine = 1", prescription_id).Count(&total)
 	return false
 }
 
-//判断该药品是否通过药房管理出库，true是，false否
-//id 药品id,org_id 机构id
+// 判断该药品是否通过药房管理出库，true是，false否
+// id 药品id,org_id 机构id
 func IsPharmacyDelivery(id, org_id int64) bool {
 	//判断药品是否通过药房管理
 	var total01 int
 	return false
 }
 
-//判断机构是否通过药房管理出库
+// 判断机构是否通过药房管理出库
 func IsPharmacyConfig(orgid int64) (bo bool) {
 	var total int
 	XTReadDB().Model(&models.PharmacyConfig{}).Where("user_org_id = ? and is_open = 1 and status = 1", orgid).Count(&total)
 	return false
 }
 
-//根据患者id和发药时间，获取医生的id和姓名
+// 根据患者id和发药时间，获取医生的id和姓名
 func GetDoctorIds(id, recordtime, orgid int64) (doctor_id int64, doctor_name string, err error) {
 	var tmp []*models.TmpAdviceDoctor
 	//var tmp []int64
 	return dataString
 }
 
-//封装扣减库存
+// 封装扣减库存
 func FenStock(orgid, creater int64, v *models.HisDoctorAdviceInfo) (err error) {
 
 	err = HisDrugsDelivery(orgid, creater, v)
 	return
 }
 
-//封装查询药品库存是否足够
+// 封装查询药品库存是否足够
 func FenDrugInventory(item *models.HisDoctorAdviceInfo, orgid int64) bool {
 	var total int64
 	var prescribing_number_total int64
 	return false, err
 }
 
-//判断药品是否零用
+// 判断药品是否零用
 func PettyCash(id int64) bool {
 	drug := models.XtBaseDrug{}
 	XTReadDB().Model(&drug).Where("id = ? and status = 1", id).Find(&drug)
 	return false
 }
 
-//初始化
+// 初始化
 func InitDrugidIsNil(orgid, stime, etime int64) {
 	var advice []*models.DoctorAdvice
 	XTReadDB().Model(&models.DoctorAdvice{}).Where("drug_id = 0 and user_org_id = ? and status = 1 and created_time >= ? and created_time <= ?", orgid, stime, etime).Find(&advice)
 	for _, v := range advice {
-		XTWriteDB().Exec("update xt_doctor_advice set drug_id = (select id from xt_base_drug where drug_name = ? and org_id = ?) where id = ?", v.AdviceName, v.UserOrgId, v.ID)
+		XTWriteDB().Exec("update xt_doctor_advice set drug_id = (select id from xt_base_drug where drug_name = ? and org_id = ? and status = 1 limit 1) where id = ?", v.AdviceName, v.UserOrgId, v.ID)
 	}
 }
 
-//改变处方状态(发药
+// 改变处方状态(发药
 func ChangeHisPrescription(tmp []int64) (err error) {
 	var advice_info []*models.HisDoctorAdviceInfo
 	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1", tmp).Find(&advice_info).Error
 	return
 }
 
-//改变处方状态(退药
+// 改变处方状态(退药
 func ChangeHisPrescriptionT(tmp []int64) (err error) {
 	var advice_info []*models.HisDoctorAdviceInfo
 	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id in (?) and status = 1", tmp).Find(&advice_info).Error
 	return
 }
 
-//改变处方状态
+// 改变处方状态
 func ChangeHisPrescriptionid(id string) (err error) {
 	var advice models.HisDoctorAdviceInfo
 	err = XTReadDB().Model(&models.HisDoctorAdviceInfo{}).Where("id = ? and status = 1", id).Find(&advice).Error
 	return
 }
 
-//获取药品规格
+// 获取药品规格
 func ReplacementDrugs(orgid int64, special bool) (list []*models.ReplacementDrugs, err error) {
 	var g errgroup.Group
 	var lib []*models.BaseDrugLib
 	return
 }
 
-//获取药品规格，不考虑特殊病
+// 获取药品规格，不考虑特殊病
 func ReplacementDrugsT(orgid int64) (list []*models.ReplacementDrugs, err error) {
 	var lib []*models.BaseDrugLib
 	err = readDb.Model(&models.BaseDrugLib{}).Where("org_id = ?  AND status = 1 and drug_status not like '%停用%' ", orgid).Find(&lib).Error
 	return
 }
 
-//根据药品id获取药品名字
+// 根据药品id获取药品名字
 func IdToDrugName(id int64) (name string) {
 	var lib models.BaseDrugLib
 	readDb.Model(&models.BaseDrugLib{}).Where("id = ?", id).Find(&lib)
 	return lib.DrugName
 }
 
-//获取项目和耗材和套餐
+// 获取项目和耗材和套餐
 func ProjectConsumables3(orgid int64) (list []*models.DropDownList, err error) {
 
 	var project []*models.XtHisProject
 	return
 }
 
-//获取项目和耗材
+// 获取项目和耗材
 func ProjectConsumables2(orgid int64, special bool) (list []*models.DropDownList, err error) {
 
 	var project []*models.XtHisProject
 	return
 }
 
-//获取项目和耗材不考虑特殊病
+// 获取项目和耗材不考虑特殊病
 func ProjectConsumables2T(orgid int64) (list []*models.DropDownList, err error) {
 
 	var project []*models.XtHisProject
 	return
 }
 
-//查询药品
+// 查询药品
 func FindPatientDrug(orgid, patient_id, drugid, mode int64) bool {
 	var total int
 	XTReadDB().Model(&models.HisPrescriptionAdviceTemplate{}).Where("user_org_id = ? and patient_id = ? and drug_id = ? and status = 1 and "+
 	return false
 }
 
-//查询项目
+// 查询项目
 func FindPatientXiang(orgid, patient_id, drugid, mode int64) bool {
 	var total int
 	XTReadDB().Model(&models.HisPrescriptionProjectTemplate{}).Where("user_org_id = ? and patient_id = ? and project_id = ? and status = 1 and type = 2 and "+
 	return false
 }
 
-//查询耗材
+// 查询耗材
 func FindPatientXiang2(orgid, patient_id, drugid, mode int64) bool {
 	var total int
 	XTReadDB().Model(&models.HisPrescriptionProjectTemplate{}).Where("user_org_id = ? and patient_id = ? and project_id = ? and status = 1 and type = 3 and "+
 	return false
 }
 
-//types处方类型，1.药品 2.项目,model透析模式
+// types处方类型，1.药品 2.项目,model透析模式
 func GetHisInfoTempalteId(model, orgid, types int64) (tp []int64) {
 	type tmpid struct {
 		Id int64
 	return
 }
 
-//替换药品处方模板
+// 替换药品处方模板
 func ReplaceDrugPrescriptionTemplate(orgid, patient_id, drugid int64, ids []int64, s models.HisPrescriptionAdviceTemplate, tx *gorm.DB) (err error) {
 	err = tx.Model(&models.HisPrescriptionAdviceTemplate{}).Where("user_org_id = ? and patient_id = ? and drug_id = ? and "+
 		"status = 1 and prescription_id in (?)", orgid, patient_id, drugid, ids).Updates(map[string]interface{}{
 	return err
 }
 
-//替换项目模板
+// 替换项目模板
 func ReplaceProjectPrescriptionTemplate(orgid, patient_id, drugid int64, ids []int64, s models.HisPrescriptionProjectTemplate, tx *gorm.DB) (err error) {
 	err = tx.Model(&models.HisPrescriptionProjectTemplate{}).Where("user_org_id = ? and patient_id = ? and project_id = ? and "+
 		"status = 1 and prescription_id in (?)", orgid, patient_id, drugid, ids).Updates(map[string]interface{}{
 	return err
 }
 
-//删除项目模板
+// 删除项目模板
 func DeleteProjectTemplate(orgid, patient_id, drugid int64, ids []int64, tx *gorm.DB) (err error) {
 	err = tx.Model(&models.HisPrescriptionProjectTemplate{}).Where("user_org_id = ? and patient_id = ? and project_id = ? and "+
 		"prescription_id in (?)", orgid, patient_id, drugid, ids).Updates(map[string]interface{}{
 	return err
 }
 
-//删除处方模板
+// 删除处方模板
 func DeletePrescriptionTemplate(orgid, patient_id, drugid int64, ids []int64, tx *gorm.DB) (err error) {
 	err = tx.Model(&models.HisPrescriptionAdviceTemplate{}).Where("user_org_id = ? and patient_id = ? and drug_id = ? and "+
 		"prescription_id in (?)", orgid, patient_id, drugid, ids).Updates(map[string]interface{}{
 	return err
 }
 
-//根据透析模式和患者id获取该患者的处方内容
+// 根据透析模式和患者id获取该患者的处方内容
 func PTemplateInformation(orgid, mode_id, patient_id int64) (tmp interface{}, err error) {
 	//获取处方id
 	var tt []*models.HisPrescriptionTemplate
 
 }
 
-//收尾工作
+// 收尾工作
 func Scavenger(orgid int64) (err error) {
 	//开事务
 	tx := XTWriteDB().Begin()
 	return
 }
 
-//分区和收费(患者发药
+// 分区和收费(患者发药
 func PartitionAndLayout(stime, etime, orgid, shift, partition int64, flist []*models.TmpPatient) (tmp []*models.TmpPatient, err error) {
 	//获取排班
 	var sch []*models.XtScheduleTwo
 	return
 }
 
-//分区和收费(药品发药
+// 分区和收费(药品发药
 func PartitionAndLayoutDrug(deliveryway string, stime, etime, orgid, shift, partition int64, flist []*models.PatientInformation) (tmp []*models.PatientInformation, err error) {
 	//获取排班
 	var sch []*models.XtScheduleTwo
 	return
 }
 
-//给药途径
+// 给药途径
 func Administration(deliveryway string, orgid int64, flist []*models.ListOfDrugs) (tmp []*models.ListOfDrugs, err error) {
 	//查询药品
 	var pp []*models.PharmacyBaseDrug
 	return
 }
 
-//计算总量
+// 计算总量
 func CalculateTheTotalAmount(tmp []*models.PatientInformation, drug_id int64) (total string, err error) {
 	//获取药品信息
 	var t models.SpBaseDrug

service/stock_service.go

 	err := XTReadDB().Where("user_org_id = ? and status = 1", user_org_id).Find(&config).Error
 	return config, err
 }
+
+func UpdateDeleteAutoGood(good_id int64, record_date int64, patient_id int64) error {
+
+	err := XTWriteDB().Model(&models.AutomaticReduceDetail{}).Where("good_id = ? and record_time = ? and patient_id = ?", good_id, record_date, patient_id).Updates(map[string]interface{}{"status": 1}).Error
+
+	err = XTWriteDB().Model(&models.DialysisBeforePrepare{}).Where("good_id = ? and record_date = ? and patient_id = ?", good_id, record_date, patient_id).Updates(map[string]interface{}{"status": 1}).Error
+	return err
+}

service/warhouse_service.go

 
 	//查询该患者当天已经出库的耗材信息
 	goods_yc, _ := FindConsumablesByDateTwo(orgID, patient_id, record_time)
+
 	// 和新请求的出库数据进行对比，分出那些是继续出库的，那些是需要删除出库的
 	for i := len(goods_yc) - 1; i >= 0; i-- {
 		goods_yc_temp := goods_yc[i]
 
 	// goods_yc 这个数据就是需要已经出库了，但是现在需要删除出库的耗材数据
 	// goods 这个数据就是需要出库的耗材的数据(新增的数据)
-
+	fmt.Println("len233333333333333w", len(goods_yc))
+	fmt.Println("需要出库的数据", len(goods))
 	if len(goods) > 0 {
 		out, err := FindStockOutByIsSys(orgID, 1, record_time)
 		houseConfig, _ := GetAllStoreHouseConfig(orgID)
 
 			var cha_count int64
 			var cha_count_two int64
+			//查询已经出库的数量
 			flowGood, _ := GetStockFlowIsBatchNumberTwo(patient_id, record_time, item.GoodId)
 			var out_count int64
 			for _, item := range flowGood {
 				out_count += item.Count
 			}
+			//已经出库的数量 减掉目前需要出库的数据
 			cha_count = item.Count - out_count
-			//fmt.Println("item.Count", item.Count)
-			//fmt.Println("item.Count", out_count)
-			//fmt.Println("cha_count2323223232323223", cha_count)
+
 			cha_count_two = out_count - item.Count
 
 			prepare := models.DialysisBeforePrepare{
 			}
 
 			ConsumablesGoodDelivery(orgID, patient_id, record_time, &prepare, &out, newCount)
+
 			//数量增加
 			if cha_count > 0 {
 				//出库数量累加
 				ModifyGoodSumCount(houseConfig.StorehouseOutInfo, cha_count, orgID, item.GoodId)
 			}
-			//数量减少
+
+			//已经出库的数据 大于 目前需要出库的数据
 			if cha_count_two > 0 {
+
 				ModifyAddGoodSumCount(houseConfig.StorehouseOutInfo, cha_count_two, orgID, item.GoodId)
 				//退库数量增加
 				UpdateSumAddCancelCount(orgID, item.GoodId, houseConfig.StorehouseOutInfo, cha_count_two)
 
+				//生成退库单
+
 			}
 			//更新剩余库存
 			goodListSix, _ := GetSumGoodList(orgID, houseConfig.StorehouseOutInfo, item.GoodId)
 		if errThree != nil {
 			return errThree
 		}
+		fmt.Println("errThreee23333333333333333333333", errThree)
 		//查询剩余库存
 		houseConfig, _ := GetAllStoreHouseConfig(orgID)
 		goodList, _ := GetAllGoodSumCount(good_yc.GoodId, orgID, houseConfig.StorehouseOutInfo)
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		}
+		fmt.Println("sum_count++++++++++++++++++++++++++++++++=", sum_count)
 		// 判断当前出库的数据和删除出库数量
 		if good_yc.Count <= ware.Count {
 			delete_count = good_yc.Count
 		//退库数量相加
 		UpdateSumAddCancelCount(good_yc.UserOrgId, good_yc.GoodId, houseConfig.StorehouseOutInfo, delete_count)
 
+		operation_time := time.Now().Unix()
+		//创建退库单
+		timeStr := time.Now().Format("2006-01-02")
+		timeArr := strings.Split(timeStr, "-")
+		total, _ := FindAllCancelStockTotal(good_yc.UserOrgId)
+		total = total + 1
+		orderNumber := "CKTKD" + strconv.FormatInt(good_yc.UserOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+
+		cancelStock := models.CancelStock{
+			OrderNumber:  orderNumber,
+			OperaTime:    operation_time,
+			OrgId:        good_yc.UserOrgId,
+			Creater:      warehouseOut.Creater,
+			Ctime:        time.Now().Unix(),
+			Status:       1,
+			ReturnTime:   record_time,
+			Type:         1,
+			StorehouseId: houseConfig.StorehouseOutInfo,
+			IsCheck:      1,
+		}
+		_, msgerrkonde := GetCancelStockDetailByOrderNumberOne(record_time, good_yc.UserOrgId)
+		if msgerrkonde == gorm.ErrRecordNotFound {
+			AddSigleCancelStock(&cancelStock)
+		}
+		cancel, _ := GetLastCancelStockById(good_yc.UserOrgId)
+
+		manufacturer, _ := GetManufactureById(ware.Manufacturer)
+		deaerler, _ := GetDealerById(ware.Dealer)
+
+		cancelStockInfo := models.CancelStockInfo{
+			GoodId:          ware.GoodId,
+			CancelStockId:   cancel.ID,
+			GoodTypeId:      ware.GoodTypeId,
+			Count:           delete_count,
+			Price:           ware.Price,
+			Total:           0,
+			ProductDate:     ware.ProductDate,
+			ExpiryDate:      ware.ExpiryDate,
+			Ctime:           time.Now().Unix(),
+			Status:          1,
+			OrgId:           good_yc.UserOrgId,
+			OrderNumber:     cancel.OrderNumber,
+			Type:            0,
+			Dealer:          deaerler.DealerName,
+			Manufacturer:    manufacturer.ManufacturerName,
+			Number:          ware.Number,
+			RegisterAccount: "",
+			Remark:          "",
+			WarehouseInfoId: ware.WarehouseInfotId,
+			PatientId:       ware.PatientId,
+			RecordDate:      record_time,
+			StorehouseId:    houseConfig.StorehouseOutInfo,
+			IsCheck:         1,
+		}
+
+		CreateCancelStockInfoOne(&cancelStockInfo)
+		cancelInfo, _ := GetLastCancelStockInfoByGoodId(ware.GoodId)
+		goodListOne, _ := GetSumGoodList(good_yc.UserOrgId, houseConfig.StorehouseOutInfo, good_yc.GoodId)
+		var over_count int64
+		for _, it := range goodListOne {
+			over_count += it.StockCount
+		}
+		flow := models.VmStockFlow{
+			WarehousingId:           ware.WarehouseInfotId,
+			GoodId:                  ware.GoodId,
+			Number:                  ware.Number,
+			LicenseNumber:           ware.LicenseNumber,
+			Count:                   ware.Count,
+			UserOrgId:               ware.OrgId,
+			PatientId:               ware.PatientId,
+			SystemTime:              record_time,
+			ConsumableType:          7,
+			IsSys:                   0,
+			WarehousingOrder:        "",
+			WarehouseOutId:          ware.WarehouseOutId,
+			WarehouseOutOrderNumber: ware.WarehouseOutOrderNumber,
+			IsEdit:                  0,
+			CancelStockId:           cancel.ID,
+			CancelOrderNumber:       cancel.OrderNumber,
+			Manufacturer:            manufacturer.ID,
+			Dealer:                  0,
+			Creator:                 warehouseOut.Creater,
+			UpdateCreator:           0,
+			Status:                  1,
+			Ctime:                   time.Now().Unix(),
+			Mtime:                   0,
+			Price:                   ware.Price,
+			WarehousingDetailId:     ware.WarehouseInfotId,
+			WarehouseOutDetailId:    ware.ID,
+			CancelOutDetailId:       cancelInfo.ID,
+			ProductDate:             ware.ProductDate,
+			ExpireDate:              ware.ExpiryDate,
+			StorehouseId:            houseConfig.StorehouseOutInfo,
+			OverCount:               over_count,
+		}
+		CreateStockFlowOne(flow)
+
 		// 增加了对应的库存后，看看还有多少需要退库的
 		good_yc.Count = good_yc.Count - delete_count
 		if good_yc.Count == 0 {
 	return err
 }
 
+func ModifyReduceGoodSumCountTwenty(storehouse_id int64, count int64, user_org_id int64, good_id int64) error {
+	ut := XTWriteDB().Begin()
+
+	err = ut.Model(&models.XtGoodStockCount{}).Where("storehouse_id = ? and status = 1 and user_org_id  = ? and good_id =?", storehouse_id, user_org_id, good_id).UpdateColumn("stock_out_count", gorm.Expr("stock_out_count - ?", count)).Error
+	if err != nil {
+		ut.Rollback()
+		return err
+	}
+	ut.Commit()
+	return err
+}
+
 func ModifyAddGoodSumCount(storehouse_id int64, count int64, user_org_id int64, good_id int64) error {
 	ut := XTWriteDB().Begin()