11月9日库存管理

.idea/vcs.xml

   </component>
   <component name="VcsDirectoryMappings">
     <mapping directory="$PROJECT_DIR$" vcs="Git" />
-    <mapping directory="$PROJECT_DIR$/src/golang.org/x/sync" vcs="Git" />
   </component>
 </project>

conf/app.conf

 appname = 血透
-httpport = 9531
+httpport = 9529
 runmode =dev
 #dev/prod
 

controllers/data_api_controller.go

 	}
 	dataconfig.Module = module
 
-	if module == "education" || module == "summary" || module == "course_disease" || module == "rescue_record" || module == "nursing_record" || module == "special_record" || module == "special_treatment" || module == "template_summary" || module == "template_plan" || module == "admitting_diagnosis" || module == "discharge_diagnosis" || module == "diagnosis_admission" || module == "treatment" || module == "illness_discharge" || module == "discharge_advice" {
+	if module == "education" || module == "summary" || module == "course_disease" || module == "rescue_record" || module == "nursing_record" || module == "special_record" || module == "special_treatment" || module == "template_summary" || module == "template_plan" || module == "admitting_diagnosis" || module == "discharge_diagnosis" || module == "diagnosis_admission" || module == "treatment" || module == "illness_discharge" || module == "discharge_advice" || module == "dialysis_remark" {
 		if configBody["title"] == nil || reflect.TypeOf(configBody["title"]).String() != "string" {
 			utils.ErrorLog("title")
 			code = enums.ErrorCodeParamWrong

controllers/dialysis_api_controller.go

 	beego.Router("/api/schedule/settlenewdoctoradvice", &DialysisApiController{}, "Get:SettleNewDoctorAdvice")
 
 	beego.Router("/api/schedule/excutiondoctoradvicebyid", &DialysisApiController{}, "Get:ExcutionDoctorAdviceById")
+
+	beego.Router("/api/patient/getdialysisadvicetoday", &DialysisApiController{}, "Get:GetDialysisAdviceToday")
 }
 
 func (c *DialysisApiController) GetQueueCall() {
 	water_machine := c.GetString("water_machine")
 	add_amount, _ := c.GetFloat("add_amount")
 	reduce_amount, _ := c.GetFloat("reduce_amount")
+	dialysis_remark := c.GetString("dialysis_remark")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.CurrentOrgId)
 
 		WaterMachine:               water_machine,
 		AddAmount:                  add_amount,
 		ReduceAmount:               reduce_amount,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	if appRole.UserType == 2 || appRole.UserType == 1 {
 	water_machine := c.GetString("water_machine")
 	add_amount, _ := c.GetFloat("add_amount")
 	reduce_amount, _ := c.GetFloat("reduce_amount")
+	dialysis_remark := c.GetString("dialysis_remark")
 	var prescription_doctor int64
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.CurrentAppId, adminUserInfo.AdminUser.Id, adminUserInfo.CurrentAppId)
 
 		WaterMachine:               water_machine,
 		AddAmount:                  add_amount,
 		ReduceAmount:               reduce_amount,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	//查询最近透析准备表里是否存在 透析器 灌流器
 		OxygenTime:                 oxygen_time,
 		PreImpulse:                 preImpules,
 		SolutionStatus:             1,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	//针对河间咸得
 					prescribing_number = parseIntPrescribingNumber
 				}
 				sum_out_count += prescribing_number
-				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(it.DrugId, orgId)
+				houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(it.DrugId, orgId, houseConfig.DrugStorehouseOut)
 				//库存不足
 				if sum_out_count > drugStockOut.FlushCount {
 					this.ServeSuccessJSON(map[string]interface{}{
 					prescribing_number = parseIntPrescribingNumber
 				}
 				sum_out_count += prescribing_number
-				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(it.DrugId, orgId)
+				houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(it.DrugId, orgId, houseConfig.DrugStorehouseOut)
 				//库存不足
 				if sum_out_count > drugStockOut.FlushCount {
 					this.ServeSuccessJSON(map[string]interface{}{
 		if advice.PrescribingNumberUnit == medical.MinUnit && medical.MaxUnit == medical.MinUnit {
 			prescribing_number = parseIntPrescribingNumber
 		}
-
-		drugStockOut, _ := service.GetDrugSumOutCountByDrugId(advice.DrugId, orgId)
+		houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+		drugStockOut, _ := service.GetDrugSumOutCountByDrugId(advice.DrugId, orgId, houseConfig.DrugStorehouseOut)
 		//库存不足
 		if prescribing_number > drugStockOut.FlushCount {
 			this.ServeSuccessJSON(map[string]interface{}{
 		if advice.PrescribingNumberUnit == medical.MinUnit && medical.MaxUnit == medical.MinUnit {
 			prescribing_number = parseIntPrescribingNumber
 		}
-		drugStockOut, _ := service.GetDrugSumOutCountByDrugId(advice.DrugId, orgId)
+		houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+		drugStockOut, _ := service.GetDrugSumOutCountByDrugId(advice.DrugId, orgId, houseConfig.DrugStorehouseOut)
 		//库存不足
 		if prescribing_number > drugStockOut.FlushCount {
 			this.ServeSuccessJSON(map[string]interface{}{
 	return
 
 }
+
+func (this *DialysisApiController) GetDialysisAdviceToday() {
+
+	orgId := this.GetAdminUserInfo().CurrentOrgId
+
+	schedule_type, _ := this.GetInt64("schedule_type")
+
+	partion_type, _ := this.GetInt64("partion_type")
+
+	start_time := this.GetString("selected_date")
+	timeLayout := "2006-01-02"
+	loc, _ := time.LoadLocation("Local")
+	startTime, _ := time.ParseInLocation(timeLayout+" 15:04:05", start_time+" 00:00:00", loc)
+
+	list, err := service.GetDialysisAdviceSchedulist(orgId, schedule_type, partion_type, startTime.Unix())
+
+	drug, _ := service.GetAllBaseDrugListTwenty(orgId)
+	_, config := service.FindXTHisRecordByOrgId(orgId)
+	if err == nil {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"list":   list,
+			"drug":   drug,
+			"config": config,
+		})
+		return
+
+	} else {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+}

controllers/dialysis_record_api_controller.go

 	createErr := service.MobileCreateDialysisOrder(adminUserInfo.CurrentOrgId, patientID, dialysisRecord)
 	//更新患者表排班备注
 	service.UpdateMobilePatient(adminUserInfo.CurrentOrgId, patientID, schedule_remark)
+
+	//统计该患者总次数
+	dialysisCount, _ := service.GetDialysisTotalCount(adminUserInfo.CurrentOrgId, patientID)
+
+	service.UpdateDialysisOrder(patientID, recordDate.Unix(), adminUserInfo.CurrentOrgId, dialysisCount.Count)
+
 	key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_order"
 	redis := service.RedisClient()
 	//清空key 值

controllers/his_api_controller.go

 	//耗材保存处方出库
 	goodOutConfig, _ := service.FindGoodOutConfigById(c.GetAdminUserInfo().CurrentOrgId)
 
+	settleConfig, _ := service.FindeDrugSettleConfigById(c.GetAdminUserInfo().CurrentOrgId)
+
 	//已发药和已收费限制逻辑
 	isMidicine := false
 	isCharge := false
 	}
 	//已发药和已收费限制逻辑
 
-	if drugStockConfig.IsOpen == 1 {
+	if drugStockConfig.IsOpen == 1 || settleConfig.IsOpen == 1 {
 		//校验库存总量
 		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
 			prescriptions, _ := dataBody["prescriptions"].([]interface{})
 		}
 	}
 
+	//校验耗材库存
+	if goodOutConfig.IsOpen == 1 {
+
+		if dataBody["prescriptions"] != nil && reflect.TypeOf(dataBody["prescriptions"]).String() == "[]interface {}" {
+			prescriptions, _ := dataBody["prescriptions"].([]interface{})
+
+			if len(prescriptions) > 0 {
+				for _, item := range prescriptions {
+
+					items := item.(map[string]interface{})
+					if items["project"] != nil && reflect.TypeOf(items["project"]).String() == "[]interface {}" {
+						projects := items["project"].([]interface{})
+						if len(projects) > 0 {
+
+							for _, project := range projects {
+								var project_id int64
+								var project_type int64
+								var totals float64
+								var project_name string
+								var parsetotal int64
+								var id int64
+								if project.(map[string]interface{})["project_id"] != nil || reflect.TypeOf(project.(map[string]interface{})["project_id"]).String() == "float64" {
+									project_id = int64(project.(map[string]interface{})["project_id"].(float64))
+								}
+								if project.(map[string]interface{})["type"] != nil || reflect.TypeOf(project.(map[string]interface{})["type"]).String() == "float64" {
+									project_type = int64(project.(map[string]interface{})["type"].(float64))
+								}
+								if project.(map[string]interface{})["total"] != nil || reflect.TypeOf(project.(map[string]interface{})["total"]).String() == "string" {
+									total, _ := project.(map[string]interface{})["total"].(string)
+									totals, _ = strconv.ParseFloat(total, 64)
+								}
+
+								if project.(map[string]interface{})["project_name"] != nil || reflect.TypeOf(project.(map[string]interface{})["project_name"]).String() == "string" {
+									project_name = project.(map[string]interface{})["project_name"].(string)
+
+								}
+								if project_type == 3 {
+
+									//查找该耗材的出库记录
+									goodWarehouseInfo, _ := service.GetAutoRecordByGoodIdSevenEight(project_id, patient_id, recordDateTime)
+
+									if len(goodWarehouseInfo) == 0 {
+										//查询耗材库存
+										list, _ := service.GetGoodWarehouseInfoSevenTen(project_id, storeConfig.StorehouseOutInfo)
+										var stock_count int64
+										for _, it := range list {
+											stock_count += it.StockCount
+										}
+										stock_counts := strconv.FormatInt(stock_count, 10)
+										stock_total_count, _ := strconv.ParseFloat(stock_counts, 64)
+										if totals > stock_total_count {
+											c.ServeDynamicFailJsonSend(project_name + "库存不足")
+											return
+										}
+									}
+
+									if len(goodWarehouseInfo) > 0 {
+										//查询该患者耗材的历史数据
+										ordProject, _ := service.GetHisProjectPrescriptionByPatientIdOne(id)
+										count, _ := strconv.ParseInt(ordProject.Count, 10, 64)
+										//数量发生改变
+										if parsetotal != count {
+											//如果现在的数量大于历史数量，就要看库存是否足够
+											if parsetotal > count {
+
+												//查询耗材所有库存
+												list, _ := service.GetGoodWarehouseInfoSevenTen(project_id, storeConfig.StorehouseOutInfo)
+												var stock_count int64
+												for _, it := range list {
+													stock_count += it.StockCount
+												}
+
+												//库存不足
+												if (parsetotal - count) > stock_count {
+													c.ServeDynamicFailJsonSend(project_name + "库存不足")
+													return
+												}
+											}
+										}
+									}
+
+								}
+
+							}
+						}
+					}
+				}
+			}
+		}
+	}
+
 	//不使用耗材保存处方出库
 	if goodOutConfig.IsOpen != 1 {
 		if stockConfig.IsOpen == 1 {
 
 			//查询今日耗材出库数量
 			hisgoodlist, _ := service.GetHisGoodList(patient_id, recordDateTime, adminInfo.CurrentOrgId)
+
 			for _, item := range hisgoodlist {
 				//查询耗材最后一次出库记录
 				wareOut, _ := service.GetLastGoodWarehouseOutInfoByProjectId(item.ProjectId, patient_id, recordDateTime, item.ID)
+				fmt.Println("hh23h232323o23o23o2o32o23o2o3o2o23o32o23o2o323o23o23o23o23o23o")
+				//查询默认出库仓库库存
+				storeConfig, _ := service.GetAllStoreHouseConfig(adminInfo.CurrentOrgId)
 				if len(wareOut) > 0 {
+
 					for _, it := range wareOut {
 						//回退库存
 						service.ModifyGoodWarehouseInfo(it.GoodId, it.WarehouseInfotId, it.OrgId, it.Count)
 						//删除出库记录
 						service.DeleteGoodWarehouseOutInfo(it.GoodId, it.SysRecordTime, it.OrgId, it.ProjectId)
+						//出库数量减少
+						service.UpdateSumCount(it.OrgId, storeConfig.StorehouseOutInfo, it.ProjectId, it.Count)
 					}
 				}
 
 
 				operation_time := time.Now().Unix()
 				creater := c.GetAdminUserInfo().AdminUser.Id
-				//查询默认出库仓库库存
-				storeConfig, _ := service.GetAllStoreHouseConfig(adminInfo.CurrentOrgId)
+
 				recordDateStr := time.Now().Format("2006-01-02")
 				recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
 				nowtime := recordDate.Unix()
 				goodObj, _ := service.GetGoodInformationByGoodIdThirty(item.ProjectId)
 				houseConfig, _ := service.GetAllStoreHouseConfig(item.UserOrgId)
 				parseIntCount, _ := strconv.ParseInt(item.Count, 10, 64)
+
 				dialyPrepareOne := models.DialysisBeforePrepare{
 					GoodTypeId:   goodObj.GoodTypeId,
 					GoodId:       item.ProjectId,
 					ProjectId:    item.ID,
 				}
 
-				service.ConsumablePrescriptionDelivery(adminInfo.CurrentOrgId, item.PatientId, item.RecordDate, &dialyPrepareOne, &lastOut, creater)
+				service.ConsumablePrescriptionDelivery(adminInfo.CurrentOrgId, item.PatientId, item.RecordDate, &dialyPrepareOne, &lastOut, creater, parseIntCount)
 
 				//查询剩余库存
-				goodList, _ := service.GetAllGoodSumCount(item.ProjectId, adminInfo.CurrentOrgId)
+				goodList, _ := service.GetAllGoodSumCount(item.ProjectId, adminInfo.CurrentOrgId, houseConfig.StorehouseOutInfo)
 				var sum_count int64
 				for _, item := range goodList {
 					sum_count += item.StockCount
 
 							if prescribingNumber >= dialysisInfo.Count {
 								//删除出库表
-								service.DeleteAutoRedeceDetailTen(c.GetAdminUserInfo().CurrentOrgId, info.PatientId, info.SysRecordTime, item.ProjectId)
+								service.DeleteAutoRedeceDetailTen(c.GetAdminUserInfo().CurrentOrgId, info.PatientId, info.SysRecordTime, item.ProjectId, item.ID)
 							}
 
 							//更新库存
 				}
 			}
 
-			fmt.Println("goodOutConfig.IsOpen23232332233232232323232323", goodOutConfig.IsOpen)
 			//保存耗材出库
 			if goodOutConfig.IsOpen == 1 {
 
 				if item.Type == 3 {
+					fmt.Println("出库数量99999999999999999999999999", item.Count)
 					good, _ := service.FindGoodInfoByIdTwo(item.ProjectId)
 					f_count, _ := strconv.ParseFloat(item.Count, 64)
 					good.Total = good.Total + f_count
 					for _, it := range goodList {
 						flush_count += it.StockCount
 					}
-					fmt.Println("nfo.Count342232332323223232323", info.Count)
-					fmt.Println("total_count0999923923932923", total_count)
+					fmt.Println("历史出库数据", info.Count)
+					fmt.Println("出库数量", total_count)
 					if info.ID > 0 {
-						if info.Count >= total_count {
-
-							//回退库存
-							service.UpDateWarehouseInfoByStockDelete(info.WarehouseInfotId, total_count, info.PatientId, info.SysRecordTime, item.ProjectId)
-							cancelStockInfo := models.CancelStockInfo{
-								GoodId:          item.ProjectId,
-								CancelStockId:   cancel.ID,
-								GoodTypeId:      good.GoodTypeId,
-								Count:           prescribingNumber,
-								Price:           info.Price,
-								Total:           0,
-								ProductDate:     info.ProductDate,
-								ExpiryDate:      info.ExpiryDate,
-								Ctime:           time.Now().Unix(),
-								Status:          1,
-								OrgId:           c.GetAdminUserInfo().CurrentOrgId,
-								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)
-
-							cancelInfo, _ := service.GetLastCancelStockInfoByGoodId(item.ProjectId)
-
-							flow := models.VmStockFlow{
-								WarehousingId:           info.WarehouseInfotId,
-								GoodId:                  item.ProjectId,
-								Number:                  info.Number,
-								LicenseNumber:           info.LicenseNumber,
-								Count:                   prescribingNumber,
-								UserOrgId:               c.GetAdminUserInfo().CurrentOrgId,
-								PatientId:               item.PatientId,
-								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:                 c.GetAdminUserInfo().CurrentOrgId,
-								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:               flush_count,
-							}
-							service.CreateStockFlowOne(flow)
-
-							//退库数量增加
-							service.UpdateSumAddCancelCount(c.GetAdminUserInfo().CurrentOrgId, item.ProjectId, houseConfig.StorehouseOutInfo, total_count)
-							//出库数量减少
-							service.UpdateSumCount(c.GetAdminUserInfo().CurrentOrgId, houseConfig.StorehouseOutInfo, item.ProjectId, total_count)
 
+						//回退库存
+						service.UpDateWarehouseInfoByStockDelete(info.WarehouseInfotId, total_count, info.PatientId, info.SysRecordTime, item.ProjectId)
+						cancelStockInfo := models.CancelStockInfo{
+							GoodId:          item.ProjectId,
+							CancelStockId:   cancel.ID,
+							GoodTypeId:      good.GoodTypeId,
+							Count:           prescribingNumber,
+							Price:           info.Price,
+							Total:           0,
+							ProductDate:     info.ProductDate,
+							ExpiryDate:      info.ExpiryDate,
+							Ctime:           time.Now().Unix(),
+							Status:          1,
+							OrgId:           c.GetAdminUserInfo().CurrentOrgId,
+							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,
 						}
 
-						if info.Count < total_count {
-							//回退库存
-							service.UpDateWarehouseInfoByStockDelete(info.WarehouseInfotId, info.Count, info.PatientId, info.SysRecordTime, item.ProjectId)
-							cancelStockInfo := models.CancelStockInfo{
-								GoodId:          item.ProjectId,
-								CancelStockId:   cancel.ID,
-								GoodTypeId:      good.GoodTypeId,
-								Count:           info.Count,
-								Price:           info.Price,
-								Total:           0,
-								ProductDate:     info.ProductDate,
-								ExpiryDate:      info.ExpiryDate,
-								Ctime:           time.Now().Unix(),
-								Status:          1,
-								OrgId:           c.GetAdminUserInfo().CurrentOrgId,
-								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)
-
-							cancelInfo, _ := service.GetLastCancelStockInfoByGoodId(item.ProjectId)
-
-							flow := models.VmStockFlow{
-								WarehousingId:           info.WarehouseInfotId,
-								GoodId:                  item.ProjectId,
-								Number:                  info.Number,
-								LicenseNumber:           info.LicenseNumber,
-								Count:                   info.Count,
-								UserOrgId:               c.GetAdminUserInfo().CurrentOrgId,
-								PatientId:               item.PatientId,
-								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:                 c.GetAdminUserInfo().CurrentOrgId,
-								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:               flush_count,
-							}
-							service.CreateStockFlowOne(flow)
+						service.CreateCancelStockInfoOne(&cancelStockInfo)
 
-							//退库数量增加
-							service.UpdateSumAddCancelCount(c.GetAdminUserInfo().CurrentOrgId, item.ProjectId, houseConfig.StorehouseOutInfo, info.Count)
-							//出库数量减少
-							service.UpdateSumCount(c.GetAdminUserInfo().CurrentOrgId, houseConfig.StorehouseOutInfo, item.ProjectId, info.Count)
+						cancelInfo, _ := service.GetLastCancelStockInfoByGoodId(item.ProjectId)
 
+						flow := models.VmStockFlow{
+							WarehousingId:           info.WarehouseInfotId,
+							GoodId:                  item.ProjectId,
+							Number:                  info.Number,
+							LicenseNumber:           info.LicenseNumber,
+							Count:                   prescribingNumber,
+							UserOrgId:               c.GetAdminUserInfo().CurrentOrgId,
+							PatientId:               item.PatientId,
+							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:                 c.GetAdminUserInfo().CurrentOrgId,
+							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:               flush_count,
 						}
+						service.CreateStockFlowOne(flow)
+
+						//退库数量增加
+						service.UpdateSumAddCancelCount(c.GetAdminUserInfo().CurrentOrgId, item.ProjectId, houseConfig.StorehouseOutInfo, total_count)
+						//出库数量减少
+						service.UpdateSumCount(c.GetAdminUserInfo().CurrentOrgId, houseConfig.StorehouseOutInfo, item.ProjectId, total_count)
+
+						//if info.Count < total_count {
+						//	//回退库存
+						//	service.UpDateWarehouseInfoByStockDelete(info.WarehouseInfotId, info.Count, info.PatientId, info.SysRecordTime, item.ProjectId)
+						//	cancelStockInfo := models.CancelStockInfo{
+						//		GoodId:          item.ProjectId,
+						//		CancelStockId:   cancel.ID,
+						//		GoodTypeId:      good.GoodTypeId,
+						//		Count:           info.Count,
+						//		Price:           info.Price,
+						//		Total:           0,
+						//		ProductDate:     info.ProductDate,
+						//		ExpiryDate:      info.ExpiryDate,
+						//		Ctime:           time.Now().Unix(),
+						//		Status:          1,
+						//		OrgId:           c.GetAdminUserInfo().CurrentOrgId,
+						//		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)
+						//
+						//	cancelInfo, _ := service.GetLastCancelStockInfoByGoodId(item.ProjectId)
+						//
+						//	flow := models.VmStockFlow{
+						//		WarehousingId:           info.WarehouseInfotId,
+						//		GoodId:                  item.ProjectId,
+						//		Number:                  info.Number,
+						//		LicenseNumber:           info.LicenseNumber,
+						//		Count:                   info.Count,
+						//		UserOrgId:               c.GetAdminUserInfo().CurrentOrgId,
+						//		PatientId:               item.PatientId,
+						//		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:                 c.GetAdminUserInfo().CurrentOrgId,
+						//		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:               flush_count,
+						//	}
+						//	service.CreateStockFlowOne(flow)
+						//
+						//	//退库数量增加
+						//	service.UpdateSumAddCancelCount(c.GetAdminUserInfo().CurrentOrgId, item.ProjectId, houseConfig.StorehouseOutInfo, info.Count)
+						//	//出库数量减少
+						//	service.UpdateSumCount(c.GetAdminUserInfo().CurrentOrgId, houseConfig.StorehouseOutInfo, item.ProjectId, info.Count)
+						//
+						//}
 
 						//查询已出库数量
 						dialysisInfo, _ := service.GetGoodDialysisOutInfoSix(c.GetAdminUserInfo().CurrentOrgId, info.PatientId, info.SysRecordTime, item.ProjectId)
 
 						if prescribingNumber >= dialysisInfo.Count {
 							//删除出库表
-							service.DeleteAutoRedeceDetailTen(c.GetAdminUserInfo().CurrentOrgId, info.PatientId, info.SysRecordTime, item.ProjectId)
+							service.DeleteAutoRedeceDetailTen(c.GetAdminUserInfo().CurrentOrgId, info.PatientId, info.SysRecordTime, item.ProjectId, item.ID)
 						}
 
 						goodList, _ := service.GetSumGoodList(c.GetAdminUserInfo().CurrentOrgId, houseConfig.StorehouseOutInfo, item.ProjectId)
 
 					if prescribingNumber >= dialysisInfo.Count {
 						//删除出库表
-						service.DeleteAutoRedeceDetailTen(adminInfo.CurrentOrgId, info.PatientId, info.SysRecordTime, project.ProjectId)
+						service.DeleteAutoRedeceDetailTen(adminInfo.CurrentOrgId, info.PatientId, info.SysRecordTime, project.ProjectId, id)
 					}
 
 					//更新剩余库存
 
 				if prescribingNumber >= dialysisInfo.Count {
 					//删除出库表
-					service.DeleteAutoRedeceDetailTen(adminInfo.CurrentOrgId, info.PatientId, info.SysRecordTime, project.ProjectId)
+					service.DeleteAutoRedeceDetailTen(adminInfo.CurrentOrgId, info.PatientId, info.SysRecordTime, project.ProjectId, id)
 				}
 
 				//更新剩余库存
 			}
 
 			for _, info := range prescriptionsOne {
+
 				if info.Type == 1 {
 					hisAdvice = append(hisAdvice, info.HisDoctorAdviceInfo...)
 				}
 
 			//判断
 			for _, itemOne := range infos {
+
 				for _, itemTwo := range hisAdvice {
 					if itemOne.DrugId == itemTwo.DrugId {
-						itemTwo.Child = append(itemTwo.ChildDoctorAdvice, itemOne)
+						itemTwo.Child = append(itemTwo.Child, itemOne)
 					}
 				}
 			}
 					if itemThree.PrescribingNumberUnit == medical.MinUnit && medical.MaxUnit == medical.MinUnit {
 						prescribing_number = parseIntPrescribingNumber
 					}
+
 					sum_out_count += prescribing_number
 				}
-				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(itemTwo.DrugId, adminUser.CurrentOrgId)
+				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(itemTwo.DrugId, adminUser.CurrentOrgId, houseConfig.DrugStorehouseOut)
 
+				fmt.Println("sum_out_count233232323232wo", sum_out_count)
+				fmt.Println("drugStockOut.FlushCount", drugStockOut.FlushCount)
 				if sum_out_count > drugStockOut.FlushCount {
 					c.ServeSuccessJSON(map[string]interface{}{
 						"msg":  "2",
 					return
 				}
 			}
-
+			fmt.Println("newGoods99999988882os", newGoods)
 			for _, itemOne := range newGoods {
 				for _, item := range newGoodOne {
-					if itemOne.ProjectId == item.ProjectId {
-						item.ChildNewDialysisBeforePrepareGoods = append(item.ChildNewDialysisBeforePrepareGoods, item)
+					if itemOne.GoodId == item.GoodId {
+						item.ChildNewDialysisBeforePrepareGoods = append(item.ChildNewDialysisBeforePrepareGoods, itemOne)
 					}
 				}
 			}
 			for _, item := range newGoodOne {
 				var sum_out_count_one int64
 				good, _ := service.GetGoodInformationByGoodIdOne(item.GoodId)
-
 				for _, itemOne := range item.ChildNewDialysisBeforePrepareGoods {
 					sum_out_count_one += itemOne.Count
 				}
-				list, _ := service.GetStockGoodList(item.GoodId, adminUser.CurrentOrgId)
+				list, _ := service.GetStockGoodList(item.GoodId, adminUser.CurrentOrgId, houseConfig.StorehouseOutInfo)
 				fmt.Println("sum_out_count_one", sum_out_count_one)
 				fmt.Println("list.FlushCount", list.FlushCount)
 				if sum_out_count_one > list.FlushCount {
 
 						service.ConsumableSettleDelivery(adminUser.CurrentOrgId, his.PatientId, his.RecordDate, &dialyPrepareOne, &lastOut, adminUser.AdminUser.Id, order.ID)
 						//查询剩余库存
-						goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminUser.CurrentOrgId)
+						goodList, _ := service.GetAllGoodSumCount(item.GoodId, adminUser.CurrentOrgId, houseConfig.StorehouseOutInfo)
 						var sum_count int64
 						for _, item := range goodList {
 							sum_count += item.StockCount
 							}
 							sum_out_count += prescribing_number
 						}
-						drugStockOut, _ := service.GetDrugSumOutCountByDrugId(itemTwo.DrugId, adminUser.CurrentOrgId)
+						houseConfig, _ := service.GetAllStoreHouseConfig(adminUser.CurrentOrgId)
+						drugStockOut, _ := service.GetDrugSumOutCountByDrugId(itemTwo.DrugId, adminUser.CurrentOrgId, houseConfig.DrugStorehouseOut)
 
 						if sum_out_count > drugStockOut.FlushCount {
 							c.ServeSuccessJSON(map[string]interface{}{
 						for _, itemOne := range item.ChildNewDialysisBeforePrepareGoods {
 							sum_out_count_one += itemOne.Count
 						}
-						list, _ := service.GetStockGoodList(item.GoodId, adminUser.CurrentOrgId)
+						list, _ := service.GetStockGoodList(item.GoodId, adminUser.CurrentOrgId, houseConfig.StorehouseOutInfo)
 						fmt.Println("sum_out_count_one", sum_out_count_one)
 						fmt.Println("list.FlushCount", list.FlushCount)
 						if sum_out_count_one > list.FlushCount {
 			infos = append(infos, &info.HisDoctorAdviceInfo)
 		}
 		if info.ProjectId > 0 && info.AdviceId == 0 {
-			fmt.Println("info232323233232233", info.PatientId)
+			fmt.Println("info232323233232233", order_id)
 			if info.HisPrescriptionProject.Type == 3 {
 				var good models.DialysisBeforePrepareGoods
 				var newGood models.NewDialysisBeforePrepareGoods
 				good.StorehouseId = houseConfig.StorehouseOutInfo
 				good.ProjectId = info.HisPrescriptionProject.ID
 				good.PatientId = info.PatientId
+				good.OrderId = order_id
 				goods = append(goods, &good)
 
 				newGood.GoodId = info.HisPrescriptionProject.VMGoodInfo.ID
 				newGood.RecordDate = order.SettleAccountsDate
 				newGood.UserOrgId = order.UserOrgId
 				newGood.PatientId = info.PatientId
+				newGood.OrderId = order_id
 				newGoods = append(newGoods, &newGood)
 			}
 		}

controllers/mobile_api_controllers/dialysis_api_controller.go

 	water_machine := c.GetString("water_machine")
 	add_amount, _ := c.GetFloat("add_amount")
 	reduce_amount, _ := c.GetFloat("reduce_amount")
+	dialysis_remark := c.GetString("dialysis_remark")
 	appRole, _ := service.FindAdminRoleTypeById(adminUserInfo.Org.Id, adminUserInfo.AdminUser.Id, adminUserInfo.App.Id)
 
 	//template, _ := service.GetOrgInfoTemplate(adminUserInfo.Org.Id)
 		WaterMachine:               water_machine,
 		AddAmount:                  add_amount,
 		ReduceAmount:               reduce_amount,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	//查询最近透析准备表里是否存在 透析器 灌流器
 		tempassessmentAfterDislysis.BreathingRate = endmonitorRecords.BreathingRate
 		tempassessmentAfterDislysis.SystolicBloodPressure = endmonitorRecords.SystolicBloodPressure
 		tempassessmentAfterDislysis.DiastolicBloodPressure = endmonitorRecords.DiastolicBloodPressure
-		tempassessmentAfterDislysis.ActualUltrafiltration = endmonitorRecords.UltrafiltrationVolume
+		if adminUserInfo.Org.Id != 10445 {
+			tempassessmentAfterDislysis.ActualUltrafiltration = endmonitorRecords.UltrafiltrationVolume
+		}
+
 		tempassessmentAfterDislysis.ActualDisplacement = endmonitorRecords.DisplacementQuantity
 
 	}
 		redis.Set(keyOne, "", time.Second)
 		//结束时候透析次数加1
 		service.UpdateSolutionByPatientId(id)
+
 		dialysisOrder.Stage = 2
 		dialysisOrder.FinishNurse = nurseID
 		dialysisOrder.FinishCreator = adminUserInfo.AdminUser.Id
 
 		createErr := service.MobileCreateDialysisOrder(adminUserInfo.Org.Id, patientID, dialysisRecord)
 		service.UpdateMobilePatient(adminUserInfo.Org.Id, patientID, schedule_remark)
+
+		//统计该患者总次数
+		dialysisCount, _ := service.GetDialysisTotalCount(adminUserInfo.Org.Id, patientID)
+		service.UpdateDialysisOrder(patientID, recordDate.Unix(), adminUserInfo.Org.Id, dialysisCount.Count)
 		redis := service.RedisClient()
 		key := strconv.FormatInt(adminUserInfo.Org.Id, 10) + ":" + strconv.FormatInt(patientID, 10) + ":" + strconv.FormatInt(recordDate.Unix(), 10) + ":dialysis_order"
 		redis.Set(key, "", time.Second)
 	drhy_water := c.GetString("drhy_water")
 	dry_water_hour := c.GetString("dry_water_hour")
 	water_machine := c.GetString("water_machine")
+	dialysis_remark := c.GetString("dialysis_remark")
 	if mode_id > 0 {
 		service.ModifyScheduleMode(mode_id, patient.ID, recordDate.Unix(), adminUserInfo.Org.Id)
 	}
 		WaterMachine:               water_machine,
 		AddAmount:                  add_amount,
 		ReduceAmount:               reduce_amount,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	_, dialysisPrescription := service.FindDialysisPrescriptionByReordDate(id, recordDate.Unix(), adminUserInfo.Org.Id)
 		MaxUltrafiltrationRate:     max_ultrafiltration_rate,
 		PreImpulse:                 impulse,
 		SolutionStatus:             1,
+		DialysisRemark:             dialysis_remark,
 	}
 
 	//针对河间咸的
 	//扣减出库数量
 	service.ModifyAddGoodSumCount(houseConfig.StorehouseOutInfo, delete_count, orgID, good_yc.GoodId)
 	//查询剩余库存
-	goodList, _ := service.GetAllGoodSumCount(good_yc.GoodId, orgID)
+	goodList, _ := service.GetAllGoodSumCount(good_yc.GoodId, orgID, houseConfig.StorehouseOutInfo)
 	var sum_count int64
 	for _, item := range goodList {
 		sum_count += item.StockCount
 				}
 				sum_out_count += prescribing_number
 			}
-			drugStockOut, _ := service.GetDrugSumOutCountByDrugId(item.DrugId, orgId)
+			houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+			drugStockOut, _ := service.GetDrugSumOutCountByDrugId(item.DrugId, orgId, houseConfig.DrugStorehouseOut)
 
 			//库存不足
 			if sum_out_count > drugStockOut.FlushCount {
 					}
 					sum_out_count += prescribing_number
 				}
-				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(item.DrugId, orgId)
+				houseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+				drugStockOut, _ := service.GetDrugSumOutCountByDrugId(item.DrugId, orgId, houseConfig.DrugStorehouseOut)
 
 				//库存不足
 				if sum_out_count > drugStockOut.FlushCount {
 		if schedule.ID == 0 {
 			this.ServeSuccessJSON(map[string]interface{}{
 				"status": 0,
+				"msg":    "请求失败",
 			})
 
 		} else {
 					} else {
 						this.ServeSuccessJSON(map[string]interface{}{
 							"status": 0,
+							"msg":    "请求失败",
 						})
 					}
 				}
 	} else {
 		this.ServeSuccessJSON(map[string]interface{}{
 			"status": 0,
+			"msg":    "请求失败",
 		})
 
 	}

controllers/secondary_order_api_contorller.go

 		}
 	}
 
-	//获取所有的入库仓库
-	//druglist, _ := service.GetDrugWarehouseInfoStorehouseList(orgId)
-	//for _, item := range druglist {
-	//	//查询该药品该仓库是否有数据
-	//	drug, _ := service.GetDrugStockCout(item.DrugId, item.StorehouseId, item.OrgId)
-	//
-	//	//查询该仓库该药品的入库数量
-	//	medical, _ := service.GetBaseDrugMedical(item.DrugId)
-	//
-	//	var sum_in_count int64
-	//	var flush_count int64
-	//	var sum_out_count int64
-	//	var cancel_out_count int64
-	//	//查询入库数量和剩余库存
-	//	infolist, _ := service.GetDrugWarehouseInfoByStorehouseId(item.StorehouseId, item.DrugId, item.OrgId)
-	//	for _, it := range infolist {
-	//		if it.MaxUnit == medical.MaxUnit {
-	//			it.WarehousingCount = it.WarehousingCount * medical.MinNumber
-	//			it.StockMaxNumber = it.StockMaxNumber * medical.MinNumber
-	//		}
-	//		sum_in_count += it.WarehousingCount
-	//		flush_count += it.StockMaxNumber + it.StockMinNumber
-	//	}
-	//
-	//	//获取出库数量
-	//	outinfolist, _ := service.GetDrugFlowStockOutCount(item.StorehouseId, item.DrugId, item.OrgId)
-	//	for _, it := range outinfolist {
-	//		if it.MaxUnit == medical.MaxUnit {
-	//			it.Count = it.Count * medical.MinNumber
-	//		}
-	//		sum_out_count += it.Count
-	//	}
-	//
-	//	//获取退库数量
-	//	cancelinfolist, _ := service.GetDrugFlowStockCancelCount(item.StorehouseId, item.DrugId, item.OrgId)
-	//	for _, it := range cancelinfolist {
-	//		if it.MaxUnit == medical.MaxUnit {
-	//			it.Count = it.Count * medical.MinNumber
-	//		}
-	//		cancel_out_count += it.Count
-	//	}
-	//
-	//	//新增
-	//	if drug.ID == 0 {
-	//		drugstock := models.XtDrugStockCount{
-	//			UserOrgId:      orgId,
-	//			StorehouseId:   item.StorehouseId,
-	//			SumInCount:     sum_in_count,
-	//			SumOutCount:    sum_out_count - cancel_out_count,
-	//			SumCancelCount: cancel_out_count,
-	//			DrugId:         item.DrugId,
-	//			Ctime:          time.Now().Unix(),
-	//			Mtime:          0,
-	//			Status:         1,
-	//			FlushCount:     flush_count,
-	//			SumActOutCount: sum_out_count,
-	//		}
-	//		service.CreateDrugStockCount(drugstock)
-	//	}
-	//}
-	//
-	////获取入库数量
-	//
-	//
-	//
-	//////获取入库数据
-	//goodlist, _ := service.GetSendGoodInformation(orgId)
-	//for _, it := range goodlist {
-	//	//查询是否有数据
-	//	_, errcode := service.GetStockFlush(it.StorehouseId, it.GoodId, it.OrgId)
-	//	//获取总退库数量
-	//	var cancel_count int64
-	//	var out_count int64
-	//	var act_count int64
-	//	//退库总数量
-	//	cancellist, _ := service.GetAllCancelCount(it.StorehouseId, it.GoodId, it.OrgId)
-	//	for _, item := range cancellist {
-	//		cancel_count += item.Count
-	//	}
-	//	//出库总数量
-	//	outlist, _ := service.GetAllStockOutCount(it.StorehouseId, it.GoodId, it.OrgId)
-	//	for _, item := range outlist {
-	//		out_count += item.Count
-	//	}
-	//
-	//	//实际出库总数量
-	//	actlist, _ := service.GetActStockOutCount(it.StorehouseId, it.GoodId, it.OrgId)
-	//	for _, item := range actlist {
-	//		act_count += item.Count
-	//	}
-	//
-	//	if errcode == gorm.ErrRecordNotFound {
-	//		good := models.XtGoodStockCount{
-	//			UserOrgId:        it.OrgId,
-	//			GoodId:           it.GoodId,
-	//			StorehouseId:     it.StorehouseId,
-	//			Status:           1,
-	//			Ctime:            time.Now().Unix(),
-	//			Mtime:            0,
-	//			StockInCount:     it.WarehousingCount,
-	//			StockOutCount:    out_count - cancel_count,
-	//			StockCancelCount: cancel_count,
-	//			FlushCount:       it.StockCount,
-	//			StockActOutCount: act_count,
-	//		}
-	//		service.CreateGoodCountSix(good)
-	//	}
-	//	if errcode == nil {
-	//		service.UpdateGoodCountSend(it.WarehousingCount, it.StockCount, out_count, it.StorehouseId, it.GoodId, it.OrgId, cancel_count, act_count)
-	//	}
-	//}
-
 	this.ServeSuccessJSON(map[string]interface{}{
 		"msg": 1,
 	})
 	for _, item := range list {
 		//药品
 		if item.IsSource == 1 {
+
 			medical, _ := service.GetBaseDrugMedical(item.ProjectId)
 			//查询该仓库的药品库存是否满足调出数量
 			drugInfoList, _ := service.GetDrugWarehouseInfoByStoreHouseIdOne(item.ProjectId, item.StorehouseInId, item.UserOrgId, item.ID)
 			}
 
 			if total_count > total {
+
 				goodObj, _ := service.GetDrugByGoodId(item.ProjectId)
 				storehouse, _ := service.FindStoreHouseByStorehouseId(item.StorehouseInId, item.UserOrgId)
 				this.ServeSuccessJSON(map[string]interface{}{
 				total_count = item.Count
 			}
 
+			fmt.Println("total_count2332232333233223", total_count)
+			fmt.Println("totoal2323232332322332", total)
 			if total_count <= total {
 
-				//回退库存,查询该订单出库记录
-				drugOutList, _ := service.GetStoreDrugWarehouseOutList(item.ProjectId, item.ID, item.UserOrgId)
-				for _, it := range drugOutList {
-
-					if medical.MaxUnit == it.CountUnit && medical.MaxUnit != medical.MinUnit {
-						//回退库存
-						service.ModifyDrugStoreWarehouseInfo(it.WarehouseInfoId, it.Count)
-					}
+				timeStr := time.Now().Format("2006-01-02")
+				timeArr := strings.Split(timeStr, "-")
+				creater := this.GetAdminUserInfo().AdminUser.Id
+				drug_total, _ := service.FindAllDrugWarehouseOut(orgId)
+				recordDateStr := time.Now().Format("2006-01-02")
+				recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+				record_date := recordDate.Unix()
+				drug_total = drug_total + 1
+				drug_warehousing_out_order := strconv.FormatInt(orgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
+				number, _ := strconv.ParseInt(drug_warehousing_out_order, 10, 64)
+				number = number + drug_total
+				drug_warehousing_out_order = "YPCKD" + strconv.FormatInt(number, 10)
+				operation_time := time.Now().Unix()
+
+				drugWarehouseOut := models.DrugWarehouseOut{
+					WarehouseOutOrderNumber: drug_warehousing_out_order,
+					OperationTime:           operation_time,
+					OrgId:                   orgId,
+					Creater:                 creater,
+					Ctime:                   time.Now().Unix(),
+					Status:                  1,
+					WarehouseOutTime:        record_date,
+					Type:                    2,
+					StorehouseId:            item.StorehouseInId,
+					SecondWarehouseId:       item.WarehouseId,
+					IsSys:                   12,
+					IsCheck:                 1,
+				}
+				_, drugerrcodes := service.GetDrugWarehouseBySyS(orgId, 12, item.WarehouseId, record_date)
 
-					if medical.MaxUnit == it.CountUnit && medical.MaxUnit == medical.MinUnit {
-						//回退库存
-						service.ModifyDrugStoreWarehouseInfo(it.WarehouseInfoId, it.Count)
-					}
+				if drugerrcodes == gorm.ErrRecordNotFound {
+					service.AddSigleDrugWarehouseOut(&drugWarehouseOut)
+				}
 
-					if medical.MinUnit == it.CountUnit && medical.MaxUnit != medical.MinUnit {
+				drugOut, _ := service.GetLastDrugWarehouseOutById(12, item.WarehouseId, orgId, record_date)
 
-						service.ModifyDrugStoreWarehouseInfoOne(it.WarehouseInfoId, it.Count)
-					}
+				warehouseOutInfo := &models.DrugWarehouseOutInfo{
+					WarehouseOutOrderNumber: drugOut.WarehouseOutOrderNumber,
+					WarehouseOutId:          drugOut.ID,
+					DrugId:                  item.ProjectId,
+					Count:                   item.Count,
+					Price:                   medical.RetailPrice,
+					TotalPrice:              0,
+					Status:                  1,
+					Ctime:                   time.Now().Unix(),
+					Remark:                  item.Remake,
+					OrgId:                   orgId,
+					Type:                    2,
+					Manufacturer:            0,
+					Dealer:                  0,
+					RetailPrice:             item.MinPrice,
+					RetailTotalPrice:        0,
+					CountUnit:               item.SencondUnit,
+					ExpiryDate:              0,
+					ProductDate:             0,
+					Number:                  "",
+					BatchNumber:             "",
+					IsSys:                   0,
+					WarehouseInfoId:         0,
+					StorehouseId:            item.StorehouseInId,
+					SecondWarehouseInfoId:   item.ID,
+					IsCheck:                 1,
+				}
+				drup, _ := service.FindBaseDrugLibRecord(orgId, item.ProjectId)
+
+				drug_in_total, _ := service.FindAllWarehouseTotalOne(orgId)
+				drug_in_total = drug_in_total + 1
+
+				warehousing_order := "YPRKD" + strconv.FormatInt(orgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(drug_in_total, 10)
+
+				drug_warehousing := models.DrugWarehouse{
+					WarehousingOrder:  warehousing_order,
+					OperationTime:     operation_time,
+					OrgId:             orgId,
+					Creater:           creater,
+					Ctime:             time.Now().Unix(),
+					Status:            1,
+					WarehousingTime:   record_date,
+					Type:              1,
+					StorehouseId:      item.StorehouseOutId,
+					IsSys:             13,
+					SecondWarehouseId: item.WarehouseId,
+					IsCheck:           1,
+				}
 
-					//查询入库单
-					storeWareing, _ := service.GetStoreDrugWarehouseById(item.WarehouseId, it.OrgId)
-					//删除入库单
-					service.DeleteStoreWarehousingId(storeWareing.ID, storeWareing.OrgId, item.ProjectId)
+				//查询该调拨单是否有生成入库单
+				_, drugerrcodess := service.GetDrugWarehouseingBySys(13, item.WarehouseId, orgId, record_date)
+				if drugerrcodess == gorm.ErrRecordNotFound {
+					service.CreateDrugWaresing(drug_warehousing)
+				}
 
-					//查询出单
-					storeWarehouseOut, _ := service.GetStoreDrugWarehouseOutById(it.WarehouseOutId, it.OrgId)
+				drugInfoObj, _ := service.GetLastDrugWarehouseBySys(13, item.WarehouseId, orgId, record_date)
+
+				drugwarehouseInfo := &models.DrugWarehouseInfo{
+					WarehousingOrder:      drugInfoObj.WarehousingOrder,
+					WarehousingId:         drugInfoObj.ID,
+					DrugId:                item.ProjectId,
+					Number:                "",
+					ProductDate:           0,
+					ExpiryDate:            0,
+					WarehousingCount:      0,
+					Price:                 0,
+					TotalPrice:            0,
+					Status:                1,
+					Ctime:                 time.Now().Unix(),
+					Remark:                "",
+					OrgId:                 orgId,
+					Type:                  2,
+					Manufacturer:          0,
+					Dealer:                0,
+					StockMaxNumber:        0,
+					RetailTotalPrice:      0,
+					BatchNumber:           "",
+					MaxUnit:               "",
+					MinUnit:               "",
+					RetailPrice:           0,
+					StorehouseId:          item.StorehouseOutId,
+					SecondWarehouseInfoId: item.ID,
+					IsCheck:               1,
+				}
+				fmt.Println("尽力发的233223323232")
+				service.AutoDrugDeliverInfoTwelve(orgId, item.Count, &drugWarehouseOut, &drup, warehouseOutInfo, drugwarehouseInfo)
 
-					//删除出库单
-					service.DeleteStoreWarehouseOut(storeWarehouseOut.ID, storeWarehouseOut.OrgId, item.ProjectId)
+				//查询默认仓库
+				storeHouseConfig, _ := service.GetAllStoreHouseConfig(orgId)
+				//更新字典里面的库存
+				stockInfo, _ := service.GetDrugAllStockInfo(storeHouseConfig.DrugStorehouseOut, item.UserOrgId, item.ProjectId)
+				var sum_count int64
+				for _, its := range stockInfo {
+					baseDrug, _ := service.GetBaseDrugMedical(its.DrugId)
+					if its.MaxUnit == baseDrug.MaxUnit {
+						its.StockMaxNumber = its.StockMaxNumber * baseDrug.MinNumber
+					}
+					sum_count += its.StockMaxNumber + its.StockMinNumber
 				}
+				service.UpdateBaseDrugSumTwo(item.ProjectId, sum_count, item.UserOrgId)
+
+				//回退库存,查询该订单出库记录
+				//drugOutList, _ := service.GetStoreDrugWarehouseOutList(item.ProjectId, item.ID, item.UserOrgId)
+				//for _, it := range drugOutList {
+				//
+				//	if medical.MaxUnit == it.CountUnit && medical.MaxUnit != medical.MinUnit {
+				//		//回退库存
+				//		service.ModifyDrugStoreWarehouseInfo(it.WarehouseInfoId, it.Count)
+				//	}
+				//
+				//	if medical.MaxUnit == it.CountUnit && medical.MaxUnit == medical.MinUnit {
+				//		//回退库存
+				//		service.ModifyDrugStoreWarehouseInfo(it.WarehouseInfoId, it.Count)
+				//	}
+				//
+				//	if medical.MinUnit == it.CountUnit && medical.MaxUnit != medical.MinUnit {
+				//
+				//		service.ModifyDrugStoreWarehouseInfoOne(it.WarehouseInfoId, it.Count)
+				//	}
+				//
+				//	//查询入库单
+				//	//storeWareing, _ := service.GetStoreDrugWarehouseById(item.WarehouseId, it.OrgId)
+				//	//删除入库单
+				//	//service.DeleteStoreWarehousingId(storeWareing.ID, storeWareing.OrgId, item.ProjectId)
+				//
+				//	//查询出单
+				//	//storeWarehouseOut, _ := service.GetStoreDrugWarehouseOutById(it.WarehouseOutId, it.OrgId)
+				//
+				//	//删除出库单
+				// 	//service.DeleteStoreWarehouseOut(storeWarehouseOut.ID, storeWarehouseOut.OrgId, item.ProjectId)
+				//}
 
 			}
 
 			//满足调拨
 			if item.Count <= total {
 
-				//回退库存,查询该订单出库记录
-				outList, _ := service.GetStoreWarehouseOutList(item.ProjectId, item.ID, item.UserOrgId)
-				for _, it := range outList {
-					//回退库存
-					service.ModifyStoreWarehouseById(it.WarehouseInfotId, it.Count)
-
-					//获取入库单
-					storeWareing, _ := service.GetStoreWarehouseById(item.WarehouseId, it.OrgId)
-					//删除入库单 入库流水
-					service.ModifyStoreWarehouse(storeWareing.ID, storeWareing.OrgId, item.ProjectId)
-					//获取出库单
-					storeWarehouseOut, _ := service.GetStoreWarehouseOutById(it.WarehouseOutId, it.OrgId)
-					//删除出库单
-					service.ModifyWarehouseOut(storeWarehouseOut.ID, storeWarehouseOut.OrgId, item.ProjectId)
+				timeStr := time.Now().Format("2006-01-02")
+				timeArr := strings.Split(timeStr, "-")
+				total, _ := service.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)
+				operation_time := time.Now().Unix()
+				creater := this.GetAdminUserInfo().AdminUser.Id
+				recordDateStr := time.Now().Format("2006-01-02")
+				recordDate, _ := utils.ParseTimeStringToTime("2006-01-02", recordDateStr)
+				record_date := recordDate.Unix()
+
+				totals, _ := service.FindAllWarehouseTotal(orgId)
+				totals = totals + 1
+				warehousing_order := "RKD" + strconv.FormatInt(orgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(totals, 10)
+				//创建出库单
+				goodObj, _ := service.GetGoodInformationByGoodId(item.ProjectId)
+				warehouseOut := models.WarehouseOut{
+					WarehouseOutOrderNumber: warehousing_out_order,
+					OperationTime:           operation_time,
+					OrgId:                   orgId,
+					Creater:                 creater,
+					Ctime:                   time.Now().Unix(),
+					Status:                  1,
+					WarehouseOutTime:        record_date,
+					Type:                    1,
+					StorehouseId:            item.StorehouseInId,
+					IsSys:                   12,
+					SecondWarehouseId:       item.WarehouseId,
+					IsCheck:                 1,
+				}
+
+				//查询今日是否存在调拨出库
+				_, errcodes := service.FindStockOutByIsSysSix(orgId, 12, record_date, item.WarehouseId)
+				if errcodes == gorm.ErrRecordNotFound {
+					service.AddSigleWarehouseOut(&warehouseOut)
+				}
+
+				out, _ := service.GetLastWarehouseOutBySys(12, orgId, record_date, item.WarehouseId)
+				warehouseOutInfo := &models.WarehouseOutInfo{
+					WarehouseOutOrderNumber: out.WarehouseOutOrderNumber,
+					WarehouseOutId:          out.ID,
+					GoodId:                  item.ProjectId,
+					GoodTypeId:              goodObj.GoodTypeId,
+					Count:                   item.Count,
+					Price:                   item.MinPrice,
+					TotalPrice:              0,
+					Status:                  1,
+					Ctime:                   time.Now().Unix(),
+					Remark:                  item.Remake,
+					OrgId:                   orgId,
+					Type:                    1,
+					Manufacturer:            0,
+					Number:                  "",
+					ExpiryDate:              0,
+					ProductDate:             0,
+					Dealer:                  0,
+					LicenseNumber:           "",
+					WarehouseInfotId:        0,
+					StorehouseId:            item.StorehouseInId,
+					SecondWarehouseInfoId:   item.ID,
+					IsCheck:                 1,
+				}
+
+				//入库操作
+				warehousing := models.Warehousing{
+					WarehousingOrder:  warehousing_order,
+					OperationTime:     operation_time,
+					OrgId:             orgId,
+					Creater:           creater,
+					Ctime:             time.Now().Unix(),
+					Status:            1,
+					WarehousingTime:   record_date,
+					Type:              1,
+					StorehouseId:      item.StorehouseOutId,
+					IsSys:             12,
+					SecondWarehouseId: item.WarehouseId,
+					IsCheck:           1,
+				}
+				//查询该调拨单是否有生成入库单
+				_, errcodess := service.GetWarehouseBySecondWarehouseId(12, item.WarehouseId, orgId, record_date)
+				if errcodess == gorm.ErrRecordNotFound {
+					service.AddSigleWarehouse(&warehousing)
 				}
+				infoObj, _ := service.GetLastWarehouseById(12, item.WarehouseId, orgId, record_date)
+
+				warehouseInfo := &models.WarehousingInfo{
+					WarehousingOrder:      infoObj.WarehousingOrder,
+					WarehousingId:         infoObj.ID,
+					GoodId:                item.ProjectId,
+					Number:                "",
+					GoodTypeId:            goodObj.GoodTypeId,
+					ProductDate:           0,
+					ExpiryDate:            0,
+					WarehousingCount:      item.Count,
+					Price:                 goodObj.BuyPrice,
+					TotalPrice:            0,
+					Status:                1,
+					Ctime:                 time.Now().Unix(),
+					Remark:                item.Remake,
+					OrgId:                 orgId,
+					Type:                  1,
+					Manufacturer:          0,
+					StockCount:            item.Count,
+					Dealer:                0,
+					LicenseNumber:         "",
+					PackingPrice:          item.MinPrice,
+					StorehouseId:          item.StorehouseOutId,
+					SecondWarehouseInfoId: item.ID,
+					IsCheck:               1,
+				}
+
+				//出库逻辑
+				parseDateErr := service.ConsumablesDeliveryTwelve(orgId, record_date, warehouseOutInfo, &warehouseOut, item.Count, creater, warehouseInfo)
+				fmt.Println(parseDateErr)
+
+				//回退库存,查询该订单出库记录
+				//outList, _ := service.GetStoreWarehouseOutList(item.ProjectId, item.ID, item.UserOrgId)
+				//for _, it := range outList {
+				//	//回退库存
+				//	service.ModifyStoreWarehouseById(it.WarehouseInfotId, it.Count)
+				//
+				//	//获取入库单
+				//	//storeWareing, _ := service.GetStoreWarehouseById(item.WarehouseId, it.OrgId)
+				//	//删除入库单 入库流水
+				//	//service.ModifyStoreWarehouse(storeWareing.ID, storeWareing.OrgId, item.ProjectId)
+				//	//获取出库单
+				//	//storeWarehouseOut, _ := service.GetStoreWarehouseOutById(it.WarehouseOutId, it.OrgId)
+				//	//删除出库单
+				//	//service.ModifyWarehouseOut(storeWarehouseOut.ID, storeWarehouseOut.OrgId, item.ProjectId)
+				//}
 			}
 
 			//查询默认仓库

models/dialysis.go

 	NucleinDate                int64         `gorm:"column:nuclein_date" json:"nuclein_date" form:"nuclein_date"`
 	ScheduleRemark             string        `gorm:"column:schedule_remark" json:"schedule_remark" form:"schedule_remark"`
 	OrderRemark                string        `gorm:"column:order_remark" json:"order_remark" form:"order_remark"`
+	DialysisTotal              int64         `gorm:"column:dialysis_total" json:"dialysis_total" form:"dialysis_total"`
 }
 
 func (DialysisOrder) TableName() string {
 	ProjectId         int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
 	StorehouseId      int64  `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
 	PatientId         int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	OrderId           int64  `gorm:"column:order_id" json:"order_id" form:"order_id"`
 }
 
 type NewDialysisBeforePrepareGoods struct {
 	UserOrgId                          int64                            `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
 	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"`
 }
 
 type OldDialysisBeforePrepareGoods struct {
 func (XtDialysisOrderSix) TableName() string {
 	return "xt_dialysis_order"
 }
+
+type HisDoctorAdviceFourty struct {
+	ID                    int64                    `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId             int64                    `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId             int64                    `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	AdviceDate            int64                    `gorm:"column:advice_date" json:"advice_date" form:"advice_date"`
+	StartTime             int64                    `gorm:"column:start_time" json:"start_time" form:"start_time"`
+	AdviceName            string                   `gorm:"column:advice_name" json:"advice_name" form:"advice_name"`
+	PrescribingNumber     float64                  `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
+	PrescribingNumberUnit string                   `gorm:"column:prescribing_number_unit" json:"prescribing_number_unit" form:"prescribing_number_unit"`
+	Status                int64                    `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime           int64                    `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime           int64                    `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	ParentId              int64                    `gorm:"column:parent_id" json:"parent_id" form:"parent_id"`
+	ExecutionTime         int64                    `gorm:"column:execution_time" json:"execution_time" form:"execution_time"`
+	ExecutionStaff        int64                    `gorm:"column:execution_staff" json:"execution_staff" form:"execution_staff"`
+	ExecutionState        int64                    `gorm:"column:execution_state" json:"execution_state" form:"execution_state"`
+	Checker               int64                    `gorm:"column:checker" json:"checker" form:"checker"`
+	CheckTime             int64                    `gorm:"column:check_time" json:"check_time" form:"check_time"`
+	CheckState            int64                    `gorm:"column:check_state" json:"check_state" form:"check_state"`
+	ChildDoctorAdvice     []*HisDoctorAdviceFourty `gorm:"ForeignKey:DrugId;AssociationForeignKey:DrugId" json:"child"`
+	IsCheck               int64                    `gorm:"-" json:"is_check" form:"is_check"`
+	Way                   int64                    `gorm:"column:way" json:"way" form:"way"`
+	DrugId                int64                    `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
+	IsSettle              int64                    `gorm:"column:is_settle" json:"is_settle" form:"is_settle"`
+	Drug                  Drug                     `gorm:"ForeignKey:ID;AssociationForeignKey:DrugId" json:"drug"`
+}
+
+func (HisDoctorAdviceFourty) TableName() string {
+	return "his_doctor_advice_info"
+}

models/drug_stock.go

 func (XtDrugWarehouseFlushInfo) TableName() string {
 	return "xt_drug_warehouse_flush_info"
 }
+
+type DrugFlowNight struct {
+	ID                        int64             `gorm:"column:id" json:"id" form:"id"`
+	WarehousingId             int64             `gorm:"column:warehousing_id" json:"warehousing_id" form:"warehousing_id"`
+	DrugId                    int64             `gorm:"column:drug_id" json:"drug_id" form:"drug_id"`
+	Number                    string            `gorm:"column:number" json:"number" form:"number"`
+	BatchNumber               string            `gorm:"column:batch_number" json:"batch_number" form:"batch_number"`
+	Count                     int64             `gorm:"column:count" json:"count" form:"count"`
+	UserOrgId                 int64             `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId                 int64             `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	SystemTime                int64             `gorm:"column:system_time" json:"system_time" form:"system_time"`
+	ConsumableType            int64             `gorm:"column:consumable_type" json:"consumable_type" form:"consumable_type"`
+	IsSys                     int64             `gorm:"column:is_sys" json:"is_sys" form:"is_sys"`
+	WarehousingOrder          string            `gorm:"column:warehousing_order" json:"warehousing_order" form:"warehousing_order"`
+	WarehouseOutId            int64             `gorm:"column:warehouse_out_id" json:"warehouse_out_id" form:"warehouse_out_id"`
+	WarehouseOutOrderNumber   string            `gorm:"column:warehouse_out_order_number" json:"warehouse_out_order_number" form:"warehouse_out_order_number"`
+	IsEdit                    int64             `gorm:"column:is_edit" json:"is_edit" form:"is_edit"`
+	CancelStockId             int64             `gorm:"column:cancel_stock_id" json:"cancel_stock_id" form:"cancel_stock_id"`
+	CancelOrderNumber         string            `gorm:"column:cancel_order_number" json:"cancel_order_number" form:"cancel_order_number"`
+	Manufacturer              int64             `gorm:"column:manufacturer" json:"manufacturer" form:"manufacturer"`
+	Dealer                    int64             `gorm:"column:dealer" json:"dealer" form:"dealer"`
+	Creator                   int64             `gorm:"column:creator" json:"creator" form:"creator"`
+	UpdateCreator             int64             `gorm:"column:update_creator" json:"update_creator" form:"update_creator"`
+	Status                    int64             `gorm:"column:status" json:"status" form:"status"`
+	Ctime                     int64             `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime                     int64             `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Price                     float64           `gorm:"column:price" json:"price" form:"price"`
+	WarehousingDetailId       int64             `gorm:"column:warehousing_detail_id" json:"warehousing_detail_id" form:"warehousing_detail_id"`
+	WarehouseOutDetailId      int64             `gorm:"column:warehouse_out_detail_id" json:"warehouse_out_detail_id" form:"warehouse_out_detail_id"`
+	CancelOutDetailId         int64             `gorm:"column:cancel_out_detail_id" json:"cancel_out_detail_id" form:"cancel_out_detail_id"`
+	ExpireDate                int64             `gorm:"column:expire_date" json:"expire_date" form:"expire_date"`
+	ProductDate               int64             `gorm:"column:product_date" json:"product_date" form:"product_date"`
+	MaxUnit                   string            `gorm:"column:max_unit" json:"max_unit" form:"max_unit"`
+	MinUnit                   string            `gorm:"column:min_unit" json:"min_unit" form:"min_unit"`
+	StockMaxNumber            int64             `gorm:"column:stock_max_number" json:"stock_max_number" form:"stock_max_number"`
+	StockMinNumber            int64             `gorm:"column:stock_min_number" json:"stock_min_number" form:"stock_min_number"`
+	LastStockMaxNumber        int64             `gorm:"column:last_stock_max_number" json:"last_stock_max_number" form:"last_stock_max_number"`
+	LastStockMinNumber        int64             `gorm:"column:last_stock_min_number" json:"last_stock_min_number" form:"last_stock_min_number"`
+	BaseDrugLibSeven          BaseDrugLibSeven  `gorm:"ForeignKey:ID;AssociationForeignKey:DrugId" `
+	AdviceId                  int64             `gorm:"column:advice_id" json:"advice_id" form:"advice_id"`
+	SupplyWarehouseId         int64             `gorm:"column:supply_warehouse_id" json:"supply_warehouse_id" form:"supply_warehouse_id"`
+	SupplyCancelOutId         int64             `gorm:"column:supply_cancel_out_id" json:"supply_cancel_out_id" form:"supply_cancel_out_id"`
+	SupplyWarehouseDetailInfo int64             `gorm:"column:supply_warehouse_detail_info" json:"supply_warehouse_detail_info" form:"supply_warehouse_detail_info"`
+	StorehouseId              int64             `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
+	SecondWarehouseInfoId     int64             `gorm:"column:second_warehouse_info_id" json:"second_warehouse_info_id" form:"second_warehouse_info_id"`
+	AdminUserId               int64             `gorm:"column:admin_user_id" json:"admin_user_id" form:"admin_user_id"`
+	LastPrice                 float64           `gorm:"column:last_price" json:"last_price" form:"last_price"`
+	StockCount                string            `gorm:"column:stock_count" json:"stock_count" form:"stock_count"`
+	PharmacyId                int64             `gorm:"column:pharmacy_id" json:"pharmacy_id" form:"pharmacy_id"`
+	DrugWarehouseInfoOne      DrugWarehouseInfo `gorm:"ForeignKey:ID;AssociationForeignKey:WarehousingDetailId"json:"xt_drug_warehouse_info" `
+	IsRead                    int64             `gorm:"column:is_read" json:"is_read" form:"is_read"`
+	IsCheck                   int64             `gorm:"column:is_check" json:"is_check" form:"is_check"`
+	OverCount                 int64             `gorm:"column:over_count" json:"over_count" form:"over_count"`
+	RetailPrice               float64           `gorm:"column:retail_price" json:"retail_price" form:"retail_price"`
+	OrderId                   int64             `gorm:"column:order_id" json:"order_id" form:"order_id"`
+}
+
+func (DrugFlowNight) TableName() string {
+	return "xt_drug_flow"
+}

models/patient_models.go

 	WaterMachine               string        `gorm:"column:water_machine" json:"water_machine" form:"water_machine"`
 	AddAmount                  float64       `gorm:"column:add_amount" json:"add_amount" form:"add_amount"`
 	ReduceAmount               float64       `gorm:"column:reduce_amount" json:"reduce_amount" form:"reduce_amount"`
+	DialysisRemark             string        `gorm:"column:dialysis_remark" json:"dialysis_remark" form:"dialysis_remark"`
 }
 
 func (DialysisPrescription) TableName() string {
 	MaxUltrafiltrationRate     float64 `gorm:"column:max_ultrafiltration_rate" json:"max_ultrafiltration_rate" form:"max_ultrafiltration_rate"`
 	PreImpulse                 float64 `gorm:"column:pre_impulse" json:"pre_impulse" form:"pre_impulse"`
 	SolutionStatus             int64   `gorm:"column:solution_status" json:"solution_status" form:"solution_status"`
+	DialysisRemark             string  `gorm:"column:dialysis_remark" json:"dialysis_remark" form:"dialysis_remark"`
 }
 
 func (DialysisSolution) TableName() string {

models/schedule_models.go

 func (ScheduleTwentyOne) TableName() string {
 	return "xt_schedule"
 }
+
+type VmBloodScheduleOne struct {
+	ID              int64                      `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId       int64                      `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PartitionId     int64                      `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId           int64                      `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId       int64                      `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate    int64                      `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType    int64                      `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek    int64                      `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId          int64                      `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status          int64                      `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime     int64                      `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime     int64                      `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	IsExport        int64                      `gorm:"column:is_export" json:"is_export" form:"is_export"`
+	DeviceNumber    *NewMDeviceNumberVM        `gorm:"ForeignKey:BedId" json:"device_number"`
+	SchedualPatient *NewMSchedualPatientVMList `gorm:"ForeignKey:PatientId" json:"patient"`
+	XtDoctorAdvice  []*XtDoctorAdvice          `gorm:"ForeignKey:PatientId,AdviceDate;AssociationForeignKey:PatientId,ScheduleDate" json:"xt_doctor_advice"`
+	HisDoctorAdvice []*HisDoctorAdviceFourty   `gorm:"ForeignKey:PatientId,AdviceDate;AssociationForeignKey:PatientId,ScheduleDate" json:"his_doctor_advice"`
+}
+
+func (VmBloodScheduleOne) TableName() string {
+	return "xt_schedule"
+}

models/stock_models.go

 }
 
 type WarehousingInfoSeven struct {
-	StockCount int64 `gorm:"column:stock_count" json:"stock_count" form:"stock_count"`
+	StockCount   int64 `gorm:"column:stock_count" json:"stock_count" form:"stock_count"`
+	StorehouseId int64 `gorm:"column:storehouse_id" json:"storehouse_id" form:"storehouse_id"`
 }
 
 func (WarehousingInfoSeven) TableName() string {

service/dialysis_solution_service.go

 
 }
 
-func GetDialysisAdviceSchedulist(orgID int64, schedule_type int64, partition_id int64, scheduleDate int64) (schedule []*models.VmBloodSchedule, err error) {
+func GetDialysisAdviceSchedulist(orgID int64, schedule_type int64, partition_id int64, scheduleDate int64) (schedule []*models.VmBloodScheduleOne, err error) {
 
-	db := XTReadDB().Model(&models.VmBloodSchedule{}).Where("status = 1")
+	db := XTReadDB().Model(&models.VmBloodScheduleOne{}).Where("status = 1")
 
 	if scheduleDate > 0 {
 		db = db.Where("schedule_date = ?", scheduleDate)
 	err = db.Preload("SchedualPatient", "status = 1 AND user_org_id = ?", orgID).
 		Preload("DeviceNumber", "status = 1 AND org_id = ?", orgID).
 		Preload("XtDoctorAdvice", "status = 1 AND user_org_id = ? and advice_date = ?", orgID, scheduleDate).
-		Preload("HisDoctorAdvice", "status = 1 AND user_org_id = ? and advice_date = ?", orgID, scheduleDate).
-		Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).Find(&schedule).Error
+		Preload("HisDoctorAdvice", func(db *gorm.DB) *gorm.DB {
+			return db.Where("user_org_id = ? and status = 1 and advice_date = ?", orgID, scheduleDate).Preload("Drug", "org_id =? and status = 1", orgID)
+		}).Preload("DeviceNumber.Zone", "status = 1 AND org_id = ?", orgID).Find(&schedule).Error
 
 	return schedule, err
 
 }
 
 func GetHisPatientDialysisSolutionGroupList(keywords string, limit int64, page int64, partition_id int64, schedule_type int64, scheduleDate int64, orgID int64, ids []string) (schedule []*models.VmBloodScheduleTwo, total int64, err error) {
-	fmt.Println("ids23322332323232hhha", ids)
 	db := XTReadDB().Model(&models.VmBloodScheduleTwo{}).Where("xt_schedule.status = 1")
 	offset := (page - 1) * limit
 	if scheduleDate > 0 {
 			Preload("HisPrescriptionTemplateSix", func(db *gorm.DB) *gorm.DB {
 				return db.Where("user_org_id = ? and status = 1", orgID).Preload("HisPrescriptionInfoTemplateSix", func(db *gorm.DB) *gorm.DB {
 					return db.Where("user_org_id = ? and status = 1 and type = 2", orgID).Preload("HisPrescriptionProjectTemplateSeven", func(db *gorm.DB) *gorm.DB {
-						return db.Where("user_org_id = ? and status = 1 and type = 3", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
+						return db.Where("user_org_id = ? and status = 1 and type = 3 and (frequency_type =1 or (frequency_type =2 and day_count >0) or (frequency_type =3 and week_day<>''))", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
 					})
 				})
 			})
 			Preload("HisPrescriptionTemplateSix", func(db *gorm.DB) *gorm.DB {
 				return db.Where("user_org_id = ? and status = 1", orgID).Preload("HisPrescriptionInfoTemplateSix", func(db *gorm.DB) *gorm.DB {
 					return db.Where("user_org_id = ? and status = 1 and type = 2", orgID).Preload("HisPrescriptionProjectTemplateSeven", func(db *gorm.DB) *gorm.DB {
-						return db.Where("user_org_id = ? and status = 1 and type = 3", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
+						return db.Where("user_org_id = ? and status = 1 and type = 3 and (frequency_type =1 or (frequency_type =2 and day_count >0) or (frequency_type =3 and week_day<>''))", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
 					})
 				})
 			}).Find(&schedule).Error
 		Preload("HisPrescriptionTemplateSix", func(db *gorm.DB) *gorm.DB {
 			return db.Where("user_org_id = ? and status = 1", orgID).Preload("HisPrescriptionInfoTemplateSix", func(db *gorm.DB) *gorm.DB {
 				return db.Where("user_org_id = ? and status = 1 and type = 2", orgID).Preload("HisPrescriptionProjectTemplateSeven", func(db *gorm.DB) *gorm.DB {
-					return db.Where("user_org_id = ? and status = 1 and type = 3", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
+					return db.Where("user_org_id = ? and status = 1 and type = 3 and (frequency_type =1 or (frequency_type =2 and day_count >0) or (frequency_type =3 and week_day<>''))", orgID).Preload("GoodInfo", "org_id =? and status = 1", orgID)
 				})
 			})
 		}).Find(&schedule).Error
 
 	return schedule, err
 }
+
+func GeAdviceListToday(user_org_id int64, advice_date int64) (advice []*models.DoctorAdvice, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and status = 1 and advice_date = ?", user_org_id, advice_date).Find(&advice).Error
+	return advice, err
+}
+
+func GetHisAdviceListToday(user_org_id int64, advice_date int64) (advice []*models.HisDoctorAdviceFourty, err error) {
+
+	err = XTReadDB().Where("user_org_id = ? and status = 1 and advice_date = ?", user_org_id, advice_date).Preload("Drug", "org_id = ? and status=1", user_org_id).Find(&advice).Error
+	return advice, err
+}

service/gobal_config_service.go

 	return stockflow, err
 }
 
-func GetDrugFlowListGroupById(id int64, orgid int64) (drugFlow []*models.DrugFlow, err error) {
+func GetDrugFlowListGroupById(id int64, orgid int64) (drugFlow []*models.DrugFlowNight, err error) {
 
 	err = XTReadDB().Where("warehouse_out_id in(?) and user_org_id = ? and status = 1", id, orgid).Group("warehousing_detail_id").Find(&drugFlow).Error
 	return drugFlow, err

service/his_service.go

 	return
 }
 
-func GetDrugSumOutCountByDrugId(drug_id int64, user_org_id int64) (models.XtDrugStockCount, error) {
+func GetDrugSumOutCountByDrugId(drug_id int64, user_org_id int64, storehouse_id int64) (models.XtDrugStockCount, error) {
 
 	drug := models.XtDrugStockCount{}
 
-	err := XTReadDB().Where("drug_id = ? and user_org_id = ? and status = 1", drug_id, user_org_id).Find(&drug).Error
+	err := XTReadDB().Where("drug_id = ? and user_org_id = ? and status = 1 and storehouse_id =?", drug_id, user_org_id, storehouse_id).Find(&drug).Error
 
 	return drug, err
 }
 
-func GetStockGoodList(good_id int64, org_id int64) (models.XtGoodStockCount, error) {
+func GetStockGoodList(good_id int64, org_id int64, storehouse_id int64) (models.XtGoodStockCount, error) {
 
 	stockCount := models.XtGoodStockCount{}
-	err = XTReadDB().Where("good_id = ? and user_org_id = ? and status= 1", good_id, org_id).Find(&stockCount).Error
+	err = XTReadDB().Where("good_id = ? and user_org_id = ? and status= 1 and storehouse_id = ?", good_id, org_id, storehouse_id).Find(&stockCount).Error
 	return stockCount, err
 }
 

service/manage_center_service.go

 
 import (
 	"XT_New/models"
+	"fmt"
 	"github.com/jinzhu/gorm"
 	"strconv"
 	"strings"
 	return detail, err
 }
 
+func GetDrugAutoWarehouseOutTen(patient_id int64, advicedate int64, drugid int64, adviceid int64, warehouse_info_id int64) (models.DrugWarehouseOutInfo, error) {
+	detail := models.DrugWarehouseOutInfo{}
+	err = XTReadDB().Model(&detail).Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ? and warehouse_info_id = ?", patient_id, advicedate, drugid, adviceid, warehouse_info_id).Find(&detail).Error
+	return detail, err
+}
+
 func GetDrugAutoWarehouseOutNight(patient_id int64, advicedate int64, drugid int64, adviceid int64) (night []*models.DrugWarehouseOutInfo, err error) {
 
 	err = XTReadDB().Where("patient_id = ? and sys_record_time =? and drug_id = ? and status = 1 and advice_id = ?", patient_id, advicedate, drugid, adviceid).Find(&night).Error
 
 func DrugAutoAddCancelInfo(advice *models.HisDoctorAdviceInfo, creater int64) error {
 
-	//查询该病人该药品是否有库存记录
+	//查询该批次病人该药品出库数据
 	info, _ := GetDrugAutoWarehouseOutEight(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID)
-
 	list, _ := GetDrugAutoWarehouseOutNight(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID)
 
+	fmt.Println("lsit233323232323233232332wo", list)
 	storeHouseConfig, _ := GetAllStoreHouseConfig(advice.UserOrgId)
 	//退库
 	drug, _ := FindBaseDrugLibRecord(advice.UserOrgId, advice.DrugId)
 	//如果剩余数量 + 退库数量 < 总入库数量
 	if len(list) > 0 {
 		for _, its := range list {
+			fmt.Println("its,23322323323223232332wo", its.WarehouseInfoId)
+
+			//查询该批次病人该药品出库数据
+			infos, _ := GetDrugAutoWarehouseOutTen(advice.PatientId, advice.AdviceDate, advice.DrugId, advice.ID, its.WarehouseInfoId)
+			fmt.Println("info2332323232332233223wo", infos.Count)
 			//查询该药品出库批次总入库数量
-			druginfo, _ := GetDrugInfoSix(its.WarehouseInfoId, info.OrgId)
+			druginfo, _ := GetDrugInfoSix(its.WarehouseInfoId, infos.OrgId)
 
 			var out_count int64  //该批次出库库存
 			var sum_count int64  //该批次总库存
 			var over_count int64 //剩余数量
 
 			over_count = druginfo.StockMaxNumber*drug.MinNumber + druginfo.StockMinNumber
-			if info.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
+			if infos.CountUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
 				out_count = info.Count * drug.MinNumber
 
 			}
-			if info.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
-				out_count = info.Count
+			if infos.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
+				out_count = infos.Count
 			}
 
-			if info.CountUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
-				out_count = info.Count
+			if infos.CountUnit == drug.MaxUnit && drug.MaxUnit == drug.MinUnit {
+				out_count = infos.Count
 			}
 
 			if druginfo.MaxUnit == drug.MaxUnit && drug.MaxUnit != drug.MinUnit {
 				sum_count = druginfo.WarehousingCount
 			}
 
+			fmt.Println("//剩余数量", over_count)
+			fmt.Println("该批出出库数量3223323232wo", out_count)
+			fmt.Println("g该批次总库存wowowoowow", sum_count)
 			if (over_count + out_count) <= sum_count {
 				if its.CountUnit == drug.MinUnit && drug.MaxUnit != drug.MinUnit {
 
 
 func GoodAutoAddCancelInfo(good *models.NewDialysisBeforePrepareGoods, creater int64) error {
 
+	fmt.Print("order_id223233232323223323223wo", good.OrderId)
 	//查询已经出库数量
-	info, _ := GetWareOutInfo(good.GoodId, good.RecordDate, good.UserOrgId, good.PatientId)
+	info, _ := GetWareOutInfo(good.GoodId, good.RecordDate, good.UserOrgId, good.PatientId, good.OrderId)
 	if len(info) > 0 {
 		houseConfig, _ := GetAllStoreHouseConfig(good.UserOrgId)
 
 			//出库数量减少
 			UpdateSumCount(good.UserOrgId, houseConfig.StorehouseOutInfo, good.GoodId, good.Count)
 			//删除出库表
-			DeleteAutoRedeceDetailTen(good.UserOrgId, item.PatientId, item.SysRecordTime, item.GoodId)
+			DeleteAutoRedeceDetailTenOne(good.UserOrgId, item.PatientId, item.SysRecordTime, item.GoodId, item.OrderId)
 
 			goodListOne, _ := GetSumGoodList(item.OrgId, houseConfig.StorehouseOutInfo, item.GoodId)
 			var flush_count int64

service/mobile_dialysis_service.go

 	err = XTWriteDB().Model(models.XtPatientsNew{}).Where("user_org_id = ? and id = ? and status = 1", org_id, patient_id).Updates(map[string]interface{}{"schedule_remark": schedule_remark}).Error
 	return err
 }
+
+func GetDialysisTotalCount(org_id int64, patient_id int64) (models.BloodDialysisOrderCount, error) {
+
+	order := models.BloodDialysisOrderCount{}
+	db := XTReadDB().Table("xt_dialysis_order as o")
+
+	err = db.Raw("select count(o.id) as count,o.patient_id from xt_dialysis_order as o left join xt_schedule as x on x.patient_id = o.patient_id where o.status =1 and o.user_org_id = ? and o.patient_id = ? and  x.schedule_date = o.dialysis_date and x.status = 1 ", org_id, patient_id).Scan(&order).Error
+
+	return order, err
+}
+
+func UpdateDialysisOrder(patient_id int64, dialysis_date int64, user_org_id int64, dialysis_total int64) (models.DialysisOrder, error) {
+
+	order := models.DialysisOrder{}
+
+	err := XTWriteDB().Model(&order).Where("patient_id = ? and dialysis_date = ? and user_org_id = ? and status = 1", patient_id, dialysis_date, user_org_id).Updates(map[string]interface{}{"dialysis_total": dialysis_total}).Error
+
+	return order, err
+}

service/new_stock_service.go

 	return err
 }
 
-func GetWareOutInfo(good_id int64, record_date int64, user_org_id int64, patient_id int64) (outinfo []*models.WarehouseOutInfo, err error) {
+func GetWareOutInfo(good_id int64, record_date int64, user_org_id int64, patient_id int64, order_id int64) (outinfo []*models.WarehouseOutInfo, err error) {
 
-	err = XTReadDB().Where("good_id = ? and sys_record_time = ? and org_id = ? and status = 1 and patient_id = ?", good_id, record_date, user_org_id, patient_id).Find(&outinfo).Error
+	err = XTReadDB().Where("good_id = ? and sys_record_time = ? and org_id = ? and status = 1 and patient_id = ? and order_id = ?", good_id, record_date, user_org_id, patient_id, order_id).Find(&outinfo).Error
 	return outinfo, err
 }
 

service/new_warehouse_service.go

 		UpdateHisPrescriptionProjectStatus(goods.GoodId, record_time, orgID, patient_id)
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		if errThree != nil {
 			return errThree
 		}
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 
 		//查询今日该药品该患者是否有出库数据
 		lastDrugOutInfo, _ := GetNewDrugWarehouseOutInfoSix(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID, warehouse.ID)
-		fmt.Println("lastDrugOutInfowwowowowoowowowowowowowowo", lastDrugOutInfo.ID)
 		if lastDrugOutInfo.ID == 0 {
 			errOne := AddSigleDrugWarehouseOutInfo(warehouseOutInfo)
 			if errOne != nil {
 func GetSigleDrugWarehouseOutInfoOne(patient_id int64, advice_date int64, orgid int64) (models.XtDrugWarehouseOutInfo, error) {
 
 	info := models.XtDrugWarehouseOutInfo{}
-	err = XTReadDB().Where("patient_id = ? and advice_date = ? and org_id = ? and status = 1", patient_id, advice_date, orgid).Find(&info).Error
+	err = XTReadDB().Where("patient_id = ? and sys_record_time = ? and org_id = ? and status = 1", patient_id, advice_date, orgid).Find(&info).Error
 	return info, err
 }
 
 	return flow, err
 }
 
+func FindDrugSettleWarehouseOutInfoCount(drugid int64, patient_id int64, record_date int64, org_id int64, advice_id int64) (flow []*models.DrugFlow, err error) {
+
+	err = XTReadDB().Where("drug_id = ? and patient_id = ? and system_time = ? and user_org_id = ? and consumable_type = 15 and status = 1 and advice_id = ?", drugid, patient_id, record_date, org_id, advice_id).Find(&flow).Error
+	return flow, err
+}
+
 func FindDrugCancelOutInfo(drugid int64, patient_id int64, record_date int64, org_id int64, advice_id int64) (flow []*models.DrugFlow, err error) {
 	err = XTReadDB().Where("drug_id = ? and patient_id = ? and system_time = ? and user_org_id = ? and consumable_type = 7 and status = 1 and advice_id = ?", drugid, patient_id, record_date, org_id, advice_id).Find(&flow).Error
 	return flow, err
 	}
 
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
+	fmt.Println("stock_nbumber3223323232", stock_number)
+	fmt.Println("deliver_number", deliver_number)
 	if stock_number >= deliver_number {
 
 		var maxNumber int64 = 0
 		var out_count int64
 		var cancel_count int64
 		//查询出库数据
-		infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
+		infoCountList, _ := FindDrugSettleWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
 		//查询退库数据
 		cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
 		for _, item := range infoCountList {
 
 		}
 
+		if deliver_number == (out_count - cancel_count) {
+			drugflow := models.DrugFlow{
+				WarehouseOutOrderNumber: warehouseout.WarehouseOutOrderNumber,
+				WarehouseOutId:          warehouseout.ID,
+				DrugId:                  advice.DrugId,
+				Number:                  warehouse.Number,
+				ProductDate:             warehouse.ProductDate,
+				ExpireDate:              warehouse.ExpiryDate,
+				Count:                   deliver_number, //按最小单位计算,
+				Price:                   warehouse.RetailPrice,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				UserOrgId:               orgID,
+				Manufacturer:            warehouse.Manufacturer,
+				Dealer:                  warehouse.Dealer,
+				BatchNumber:             warehouse.BatchNumber,
+				MaxUnit:                 drup.MinUnit,
+				ConsumableType:          15,
+				IsEdit:                  1,
+				Creator:                 advice.ExecutionStaff,
+				IsSys:                   1,
+				PatientId:               advice.PatientId,
+				SystemTime:              advice.AdviceDate,
+				WarehousingDetailId:     warehouse.ID,
+				SupplyWarehouseId:       warehouse.SupplyWarehouseId,
+				StorehouseId:            storeConfig.DrugStorehouseOut,
+				WarehouseOutDetailId:    lastDrugOutInfo.ID,
+				OverCount:               sum_count,
+				AdviceId:                advice.ID,
+				LastPrice:               warehouse.Price,
+				OrderId:                 warehouseout.OrderId,
+			}
+
+			CreateDrugFlowOne(drugflow)
+			//出库数量相加
+			AddDrugCount(advice.DrugId, orgID, storeConfig.DrugStorehouseOut, drugflow.Count)
+
+		}
+
 		//如果本次出库数据小于历史出库数据 新增1条退库流水
 		if deliver_number < (out_count - cancel_count) {
 
 				UserOrgId:               advice.UserOrgId,
 				PatientId:               advice.PatientId,
 				SystemTime:              advice.AdviceDate,
-				ConsumableType:          16,
+				ConsumableType:          7,
 				IsSys:                   0,
 				WarehousingOrder:        "",
 				WarehouseOutId:          0,
 				WarehouseOutOrderNumber: "",
 				IsEdit:                  0,
 				CancelStockId:           cancelStock.ID,
-				CancelOrderNumber:       cancelStock.OrderNumber,
+				CancelOrderNumber:       lastDrugCancelStock.OrderNumber,
 				Manufacturer:            warehouse.Manufacturer,
 				Dealer:                  warehouse.Dealer,
 				Creator:                 advice.ExecutionStaff,
 		var out_count int64
 		var cancel_count int64
 		//查询出库数据
-		infoCountList, _ := FindDrugWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
+		infoCountList, _ := FindDrugSettleWarehouseOutInfoCount(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
 		//查询退库数据
 		cancelInfoList, _ := FindDrugCancelOutInfo(advice.DrugId, advice.PatientId, advice.RecordDate, advice.UserOrgId, advice.ID)
 		for _, item := range infoCountList {
 				UserOrgId:               advice.UserOrgId,
 				PatientId:               advice.PatientId,
 				SystemTime:              advice.AdviceDate,
-				ConsumableType:          16,
+				ConsumableType:          7,
 				IsSys:                   0,
 				WarehousingOrder:        "",
 				WarehouseOutId:          0,
 				WarehouseOutOrderNumber: "",
 				IsEdit:                  0,
 				CancelStockId:           cancelStock.ID,
-				CancelOrderNumber:       cancelStock.OrderNumber,
+				CancelOrderNumber:       lastDrugCancelStock.OrderNumber,
 				Manufacturer:            warehouse.Manufacturer,
 				Dealer:                  warehouse.Dealer,
 				Creator:                 advice.ExecutionStaff,

service/self_drug_service.go

 
 func GetWarehouseOutDetailByPatientIdOne(orgid int64, patient_id int64, startime int64, endtime int64, limit int64, page int64) (info []*models.WarehouseOutInfo, total int64, err error) {
 
-	db := XTReadDB().Model(&info).Where("status = 1 and is_sys = 1")
+	db := XTReadDB().Model(&info).Where("status = 1 and (is_sys = 1 or is_sys = 5)")
 	offset := (page - 1) * limit
 	if orgid > 0 {
 		db = db.Where("org_id = ?", orgid)
 
 func GetWarehouseOutDetailByPatientId(orgid int64, patient_id int64, startime int64, endtime int64) (info []*models.WarehouseOutInfo, err error) {
 
-	db := XTReadDB().Model(&info).Where("status = 1 and is_sys = 1")
+	db := XTReadDB().Model(&info).Where("status = 1 and (is_sys = 1 or is_sys =5)")
 	if orgid > 0 {
 		db = db.Where("org_id = ?", orgid)
 	}

service/stock_service.go

 	return err
 }
 
-func DeleteAutoRedeceDetailTen(orgid int64, patient_id int64, recordtime int64, goodid int64) error {
+func DeleteAutoRedeceDetailTen(orgid int64, patient_id int64, recordtime int64, goodid int64, project_id int64) error {
 
 	detail := models.BloodAutomaticReduceDetail{}
 	err := XTWriteDB().Model(&detail).Where("org_id = ? and patient_id = ? and record_time = ? and status =1 and good_id = ? ", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
 	info := models.WarehouseOutInfo{}
-	err = XTWriteDB().Model(&info).Where("org_id = ? and patient_id = ? and sys_record_time = ? and good_id = ? and status = 1", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
+	err = XTWriteDB().Model(&info).Where("org_id = ? and patient_id = ? and sys_record_time = ? and good_id = ? and status = 1 and project_id = ?", orgid, patient_id, recordtime, goodid, project_id).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
 	prepare := models.DialysisBeforePrepare{}
 	err = XTWriteDB().Model(&prepare).Where("user_org_id = ? and patient_id = ? and record_date = ? and good_id = ? and status = 1", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
 	flow := models.VmStockFlow{}
-	err = XTWriteDB().Model(&flow).Where("user_org_id = ? and patient_id = ? and system_time = ? and good_id = ? and status = 1", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"is_read": 1}).Error
+	err = XTWriteDB().Model(&flow).Where("user_org_id = ? and patient_id = ? and system_time = ? and good_id = ? and status = 1 and project_id = ?", orgid, patient_id, recordtime, goodid, project_id).Updates(map[string]interface{}{"is_read": 1}).Error
+	return err
+
+}
+
+func DeleteAutoRedeceDetailTenOne(orgid int64, patient_id int64, recordtime int64, goodid int64, order_id int64) error {
+
+	detail := models.BloodAutomaticReduceDetail{}
+	err := XTWriteDB().Model(&detail).Where("org_id = ? and patient_id = ? and record_time = ? and status =1 and good_id = ? ", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
+	info := models.WarehouseOutInfo{}
+	err = XTWriteDB().Model(&info).Where("org_id = ? and patient_id = ? and sys_record_time = ? and good_id = ? and status = 1 and order_id = ?", orgid, patient_id, recordtime, goodid, order_id).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
+	prepare := models.DialysisBeforePrepare{}
+	err = XTWriteDB().Model(&prepare).Where("user_org_id = ? and patient_id = ? and record_date = ? and good_id = ? and status = 1", orgid, patient_id, recordtime, goodid).Updates(map[string]interface{}{"status": 0, "count": 0}).Error
+	flow := models.VmStockFlow{}
+	err = XTWriteDB().Model(&flow).Where("user_org_id = ? and patient_id = ? and system_time = ? and good_id = ? and status = 1 and order_id = ?", orgid, patient_id, recordtime, goodid, order_id).Updates(map[string]interface{}{"is_read": 1}).Error
 	return err
 
 }
 	return info, err
 }
 
+func GetGoodWarehouseInfoSevenTen(good_id int64, storehouse_id int64) (info []*models.WarehousingInfoSeven, err error) {
+
+	err = readDb.Select("stock_count").Where("good_id = ? and status = 1 and stock_count<>0 and storehouse_id = ?", good_id, storehouse_id).Find(&info).Error
+	return info, err
+}
+
 func GetAllStockList(page int64, limit int64, startime int64, endtime int64, good_type int64, keyword string, orgid int64) (info []*models.VmWarehousingInfo, total int64, err error) {
 
 	offset := (page - 1) * limit
 	return flow, nil
 }
 
+func GetStockFlowIsBatchNumberFour(patient_id int64, record_time int64, good_id int64, project_id int64) (flow []*models.VmStockFlow, err error) {
+
+	err = XTReadDB().Where("patient_id = ? and system_time = ? and good_id = ? and status = 1 and consumable_type =7 and project_id = ?", patient_id, record_time, good_id, project_id).Find(&flow).Error
+	return flow, nil
+}
+
 func GetWarehouseOutInfoIsExist(id int64) (*models.WarehouseOutInfo, error) {
 
 	info := models.WarehouseOutInfo{}
 	err := XTReadDB().Where("good_id = ? and sys_record_time = ? and status = 1 and patient_id = ? and project_id = ?", good_id, record_time, patient_id, project_id).Find(&info).Error
 	return info, err
 }
+
+func GetWarehouseOutInfoIsExistSix(good_id int64, patient_id int64, record_time int64, project_id int64) (*models.WarehouseOutInfo, error) {
+
+	info := models.WarehouseOutInfo{}
+	var err error
+	err = XTReadDB().Model(&info).Where("good_id = ? and sys_record_time = ? and status = 1 and patient_id = ? and project_id = ?", good_id, record_time, patient_id, project_id).Find(&info).Error
+	if err == gorm.ErrRecordNotFound {
+		return nil, err
+	}
+	if err != nil {
+		return nil, err
+	}
+	return &info, nil
+}

service/warhouse_service.go

 			return errThree
 		}
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		if errThree != nil {
 			return errThree
 		}
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 			return errThree
 		}
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(good_yc.GoodId, orgID)
+		houseConfig, _ := GetAllStoreHouseConfig(orgID)
+		goodList, _ := GetAllGoodSumCount(good_yc.GoodId, orgID, houseConfig.StorehouseOutInfo)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		} else {
 			delete_count = ware.Count
 		}
-		houseConfig, _ := GetAllStoreHouseConfig(orgID)
+
 		// 在出库记录表里记录退库详情
 		warehouseOutInfo := &models.WarehouseOutInfo{
 			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 // 药品出库 递归方式
 func AutoDrugDeliverInfoTwelve(orgID int64, prescribingNumber int64, warehouseout *models.DrugWarehouseOut, drup *models.BaseDrugLib, advice *models.DrugWarehouseOutInfo, drugWarehouse *models.DrugWarehouseInfo) (err error) {
 
+	fmt.Println("尽力2333223333233323322332")
 	// 判断处方里药品单位是拆零单位还是包装单位,	如果是包装单位，则根据规格，将包装数量转为拆零数量
 	var deliver_number int64 = 0
 	var stock_number int64 = 0
 	// 根据先进先出原则，查询最先入库的批次，进行出库
 	// 如果没有对应的库存，则报错
 	//开启事物
-	storeConfig, _ := GetAllStoreHouseConfig(orgID)
-	lastWarehouse, _ := FindLastDrugWarehousingInfoByID(advice.DrugId, storeConfig.DrugStorehouseOut)
+	//storeConfig, _ := GetAllStoreHouseConfig(orgID)
+	lastWarehouse, _ := FindLastDrugWarehousingInfoByID(advice.DrugId, warehouseout.StorehouseId)
+	fmt.Println("lastWarehouse.StockMinNumber", lastWarehouse.StockMinNumber)
+	fmt.Println("drup.MinNumber", drup.MinNumber)
 	if lastWarehouse.StockMinNumber >= drup.MinNumber {
 		var stockMax int64
 		var stockMin int64
 
 	stock_number = warehouse.StockMaxNumber*drup.MinNumber + warehouse.StockMinNumber
 
+	fmt.Println("stock23233233232", stock_number)
+	fmt.Println("deliver_number", deliver_number)
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
 	if stock_number >= deliver_number {
 
 			maxNumber = prescribingNumber
 		}
 
+		//fmt.Println("warehouse.StockMaxNumber",warehouse.StockMaxNumber)
+		//fmt.Println("maxNumber9899923323232wo",maxNumber)
 		if warehouse.StockMaxNumber < maxNumber {
 
 			return errors.New("库存数量不足")
 			warehouse.StockMinNumber = 0
 		}
 
+		fmt.Println("warehouse.StockMaxNumber323232323233232332", warehouse.StockMaxNumber)
 		if warehouse.StockMaxNumber < 0 {
 			return errors.New("库存数量不足")
 		}
 
-		////扣减库存
-		//if(warehouse.StockMaxNumber > 0){
-		//  var sum_count int64
-		//  sum_count = maxNumber * drup.MinNumber
-		//  ModifyDrugReduceInformationSix(warehouse.DrugId,sum_count,warehouse.OrgId,warehouse.RetailPrice)
-		//}
-		//if(warehouse.StockMinNumber > 0){
-		//  var sum_count int64
-		//  sum_count = minNumber
-		//  ModifyDrugReduceInformationSix(warehouse.DrugId,sum_count,warehouse.OrgId,warehouse.RetailPrice)
-		//}
-
 		errThree := UpDateDrugWarehouseInfoByStock(&warehouse)
 
 		if errThree != nil {
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 			OverCount:               over_count,
 			RetailPrice:             retail_price, //手动出库出库价格
 			WarehousingId:           warehouse.ID,
+			SystemTime:              advice.SysRecordTime,
 		}
 		if warehouse.RetailPrice == 0 {
 			drugflow.Price = advice.Price
 			RetailPrice:             retail_price, //手动出库出库价格
 			WarehousingId:           warehouse.ID,
 			WarehousingDetailId:     warehouse.ID,
+			SystemTime:              advice.SysRecordTime,
 		}
 
 		CreateDrugFlowOne(drugflow)
 	return info, err
 }
 
-func GetAllGoodSumCount(goodid int64, orgid int64) (info []*models.WarehousingInfo, err error) {
+func GetAllGoodSumCount(goodid int64, orgid int64, storehouse_id int64) (info []*models.WarehousingInfo, err error) {
 
-	err = XTReadDB().Where("good_id = ? and org_id = ? and is_check =1 and status= 1 and stock_count > 0", goodid, orgid).Find(&info).Error
+	err = XTReadDB().Where("good_id = ? and org_id = ? and is_check =1 and status= 1 and stock_count > 0 and storehouse_id = ?", goodid, orgid, storehouse_id).Find(&info).Error
 	return info, err
 }
 
 	stock_number = warehouse.StockCount
 
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
+
+	fmt.Println("stock_numnber233232232323", stock_number)
+	fmt.Println("deliver_nmuberwooeooo2oo23", deliver_number)
 	if stock_number >= deliver_number {
 		maxNumber = goods.Count
 		warehouse.StockCount = warehouse.StockCount - maxNumber
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 			RegisterNumber:          warehouse.RegisterNumber,
 			OrderId:                 order_id,
 		}
-		OutInfo.Count = goods.Count
+		OutInfo.Count = stock_number
 
 		AddSigleWarehouseOutInfo(OutInfo)
 
 
 	goods.Count = deliver_number - stock_number
 	prepare := &models.DialysisBeforePrepare{
-		Count: deliver_number - stock_number,
+		Count:        deliver_number - stock_number,
+		GoodTypeId:   goods.GoodTypeId,
+		GoodId:       goods.GoodId,
+		PatientId:    goods.PatientId,
+		RecordDate:   goods.RecordDate,
+		UserOrgId:    orgID,
+		Ctime:        time.Now().Unix(),
+		Creater:      goods.Creater,
+		CommdityCode: goods.CommdityCode,
+		Status:       1,
+		StorehouseId: goods.StorehouseId,
 	}
 	ConsumableSettleDelivery(orgID, patient_id, record_time, prepare, warehouseOut, creator, order_id)
 
 }
 
 //保存处方出库
-func ConsumablePrescriptionDelivery(orgID int64, patient_id int64, record_time int64, goods *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut, creator int64) (err error) {
+func ConsumablePrescriptionDelivery(orgID int64, patient_id int64, record_time int64, goods *models.DialysisBeforePrepare, warehouseOut *models.WarehouseOut, creator int64, count int64) (err error) {
 
 	var deliver_number int64 = 0
 	var stock_number int64 = 0
 	var maxNumber int64 = 0
-	fmt.Println("223323233233223233223233223woo", goods.Count)
+
 	deliver_number = goods.Count
 
 	// 根据先进先出原则，查询最先入库的批次，进行出库
 
 	stock_number = warehouse.StockCount
 
+	fmt.Println("sotck_number233223322o", stock_number)
+	fmt.Println("deliver_number", deliver_number)
 	// 当库存数量大于或等于出库数量的话，则正常出库该批次
 	if stock_number >= deliver_number {
 		maxNumber = goods.Count
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 			RegisterNumber:          warehouse.RegisterNumber,
 		}
 		fmt.Println("goods.count2323232233232233232322332322332", goods.Count)
-		OutInfo.Count = goods.Count
+		OutInfo.Count = count
 
-		_, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
+		_, errcodes := GetWarehouseOutInfoIsExistSix(goods.GoodId, patient_id, record_time, goods.ProjectId)
 		if errcodes == gorm.ErrRecordNotFound {
 			errOne := AddSigleWarehouseOutInfo(OutInfo)
 			if errOne != nil {
 		} else if errcodes == nil {
 
 			outInfoOne, _ := GetWarehouseOutInfoIsExistThree(goods.GoodId, patient_id, record_time, goods.ProjectId)
-			if goods.Count != outInfoOne.Count {
+			if count != outInfoOne.Count {
 				UpdatedWarehouseOutInfo(OutInfo, goods.GoodId, patient_id, record_time, goods.ProjectId)
 			}
 
 		lastOut, _ := FindWarehouseOutInfoByPatientIdTwo(patient_id, record_time, goods.GoodId, orgID, goods.ProjectId)
 		//查询已经出库的数据
 		flowGood, _ := GetStockFlowIsBatchNumberSix(patient_id, record_time, goods.GoodId, goods.ProjectId)
+		fmt.Println("flowgood23323223323222323wo", flowGood)
 		var out_count int64
 		var out_count_one int64
 		for _, item := range flowGood {
 		}
 
 		//查询退库数据
-		flowGoodTwo, _ := GetStockFlowIsBatchNumberThree(patient_id, record_time, goods.GoodId)
+		flowGoodTwo, _ := GetStockFlowIsBatchNumberFour(patient_id, record_time, goods.GoodId, goods.ProjectId)
 		for _, item := range flowGoodTwo {
 			out_count_one += item.Count
 		}
 
 		//如果本次出库数据大于历史出库数据 新增1条流水
-		fmt.Println("goods_count233232323223", goods.Count)
-		fmt.Println("out_count - out_count_one", out_count-out_count_one)
-		if goods.Count > (out_count - out_count_one) {
+		fmt.Println("out_count23323233232wo", out_count)
+		fmt.Println("goods_count233232323223", count)
+		fmt.Println("out_count - out_count_one", out_count_one)
+		if count > (out_count - out_count_one) {
 
 			stockFlow := models.VmStockFlow{
 				WarehousingId:           warehouse.ID,
 				GoodId:                  goods.GoodId,
 				Number:                  warehouse.Number,
 				LicenseNumber:           warehouse.LicenseNumber,
-				Count:                   goods.Count - out_count + out_count_one,
+				Count:                   count - out_count + out_count_one,
 				UserOrgId:               orgID,
 				PatientId:               goods.PatientId,
 				SystemTime:              record_time,
 
 		//如果本次出库数据小于历史出库数据 新增1条退库流水
 
-		if goods.Count < (out_count - out_count_one) {
+		if count < (out_count - out_count_one) {
 
 			operation_time := time.Now().Unix()
 
 				GoodId:          goods.GoodId,
 				CancelStockId:   cancel.ID,
 				GoodTypeId:      goods.GoodTypeId,
-				Count:           out_count - out_count_one - goods.Count,
+				Count:           out_count - out_count_one - count,
 				Price:           warehouse.PackingPrice,
 				Total:           0,
 				ProductDate:     warehouse.ProductDate,
 				GoodId:                  goods.GoodId,
 				Number:                  warehouse.Number,
 				LicenseNumber:           warehouse.LicenseNumber,
-				Count:                   out_count - out_count_one - goods.Count,
+				Count:                   out_count - out_count_one - count,
 				UserOrgId:               orgID,
 				PatientId:               patient_id,
 				SystemTime:              record_time,
 
 			//退库数量增加
 			UpdateSumAddCancelCount(orgID, goods.GoodId, goods.StorehouseId, flow.Count)
+			ModifyAddGoodSumCount(goods.StorehouseId, flow.Count, orgID, goods.GoodId)
 		}
 
 		//添加入库ID
 		}
 
 		//查询剩余库存
-		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID)
+		goodList, _ := GetAllGoodSumCount(goods.GoodId, orgID, goods.StorehouseId)
 		var sum_count int64
 		for _, item := range goodList {
 			sum_count += item.StockCount
 		}
+		fmt.Println("剩余库存", sum_count)
 
 		OutInfo := &models.WarehouseOutInfo{
 			WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
 			OverCount:               sum_count,
 			RegisterNumber:          warehouse.RegisterNumber,
 		}
-		OutInfo.Count = goods.Count
+		OutInfo.Count = stock_number
 
-		_, errcodes := GetWarehouseOutInfoIsExistOne(goods.GoodId, patient_id, record_time, goods.ProjectId)
+		_, errcodes := GetWarehouseOutInfoIsExistSix(goods.GoodId, patient_id, record_time, goods.ProjectId)
 		if errcodes == gorm.ErrRecordNotFound {
 			errOne := AddSigleWarehouseOutInfo(OutInfo)
 			if errOne != nil {
 		} else if errcodes == nil {
 
 			outInfoOne, _ := GetWarehouseOutInfoIsExistThree(goods.GoodId, patient_id, record_time, goods.ProjectId)
-			if goods.Count != outInfoOne.Count {
+			if count != outInfoOne.Count {
 				UpdatedWarehouseOutInfo(OutInfo, goods.GoodId, patient_id, record_time, goods.ProjectId)
 			}
 
 		for _, item := range flowGoodTwo {
 			out_count_one += item.Count
 		}
+		fmt.Println("出库数量", stock_number)
+		fmt.Println("历史出库数据", out_count-out_count_one)
 		//如果出库数量 大于 历史出库数据 新增1条流水
-		if goods.Count > out_count-out_count_one {
+		if count > out_count-out_count_one {
 			stockFlow := models.VmStockFlow{
 				WarehousingId:           warehouse.ID,
 				GoodId:                  goods.GoodId,
 		}
 
 		//退库
-		if goods.Count < out_count-out_count_one {
+		if count < out_count-out_count_one {
 
 			operation_time := time.Now().Unix()
 
 				GoodId:          goods.GoodId,
 				CancelStockId:   cancel.ID,
 				GoodTypeId:      goods.GoodTypeId,
-				Count:           out_count - out_count_one - goods.Count,
+				Count:           out_count - out_count_one - count,
 				Price:           warehouse.PackingPrice,
 				Total:           0,
 				ProductDate:     warehouse.ProductDate,
 				GoodId:                  goods.GoodId,
 				Number:                  warehouse.Number,
 				LicenseNumber:           warehouse.LicenseNumber,
-				Count:                   out_count - goods.Count,
+				Count:                   out_count - count,
 				UserOrgId:               orgID,
 				PatientId:               patient_id,
 				SystemTime:              record_time,
 
 			//退库数量增加
 			UpdateSumAddCancelCount(orgID, goods.GoodId, goods.StorehouseId, flow.Count)
+			//实际出库减少
+			ModifyAddGoodSumCount(goods.StorehouseId, flow.Count, orgID, goods.GoodId)
 		}
 
 		errWarehouse := UpdateGoodWarehouseOutById(goods.ID, warehouse.ID, orgID, sum_count)
 
 	goods.Count = deliver_number - stock_number
 	prepare := &models.DialysisBeforePrepare{
-		Count: deliver_number - stock_number,
+		Count:        deliver_number - stock_number,
+		GoodTypeId:   goods.GoodTypeId,
+		GoodId:       goods.GoodId,
+		PatientId:    goods.PatientId,
+		RecordDate:   goods.RecordDate,
+		UserOrgId:    orgID,
+		Ctime:        time.Now().Unix(),
+		Creater:      creator,
+		Status:       1,
+		StorehouseId: goods.StorehouseId,
+		ProjectId:    goods.ProjectId,
 	}
-	ConsumablePrescriptionDelivery(orgID, patient_id, record_time, prepare, warehouseOut, creator)
+	fmt.Println("剩余出库数量", prepare.Count)
+	ConsumablePrescriptionDelivery(orgID, patient_id, record_time, prepare, warehouseOut, creator, count)
 
 	return nil
 }