耗材参数

controllers/self_drug_api_congtroller.go

@@ -78,6 +78,7 @@ func SelfDrugRouters() {
 	beego.Router("/api/drug/getdruginventoryprintlist", &SelfDrugApiController{}, "Get:GetDrugInventoryPrintList")
 	beego.Router("/api/drug/getinventorydetaillist", &SelfDrugApiController{}, "Get:GetDrugInventoryDetailList")
 	beego.Router("/api/drug/savedrugproofinventory", &SelfDrugApiController{}, "Get:SaveDrugProofInventory")
+	beego.Router("/api/drug/getdrugwarehouseinfototal", &StockManagerApiController{}, "Get:GetDrugWarehouseInfoTotal")
 }
 
 func (this *SelfDrugApiController) GetCurrentPatient() {
@@ -959,7 +960,7 @@ func (this *SelfDrugApiController) PostSearchDrugWarehouseList() {
 }
 
 func (this *SelfDrugApiController) SaveDrugPrice() {
-	fmt.Println("999999999999999999999")
+
 	timeLayout := "2006-01-02"
 	loc, _ := time.LoadLocation("Local")
 	dataBody := make(map[string]interface{}, 0)
@@ -1020,12 +1021,12 @@ func (this *SelfDrugApiController) SaveDrugPrice() {
 			}
 			manufacturer := items["manufacturer"].(string)
 
-			//if items["specification_name"] == nil || reflect.TypeOf(items["specification_name"]).String() != "string" {
-			//  utils.ErrorLog("specification_name")
-			//  this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			//  return
-			//}
-			//specification_name := items["specification_name"].(string)
+			if items["specification_name"] == nil || reflect.TypeOf(items["specification_name"]).String() != "string" {
+				utils.ErrorLog("specification_name")
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+				return
+			}
+			specification_name := items["specification_name"].(string)
 
 			if items["remark"] == nil || reflect.TypeOf(items["remark"]).String() != "string" {
 				utils.ErrorLog("remark")
@@ -1047,13 +1048,6 @@ func (this *SelfDrugApiController) SaveDrugPrice() {
 				return
 			}
 			last_price, _ := strconv.ParseFloat(items["last_price"].(string), 64)
-			//
-			//if items["count"] == nil || reflect.TypeOf(items["count"]).String() != "float64" {
-			//	utils.ErrorLog("count")
-			//	this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
-			//	return
-			//}
-			//count := int64(items["count"].(float64))
 
 			if items["new_price"] == nil || reflect.TypeOf(items["new_price"]).String() != "string" {
 				utils.ErrorLog("new_price")
@@ -1090,7 +1084,7 @@ func (this *SelfDrugApiController) SaveDrugPrice() {
 
 			drugAdjust := models.XtDrugAdjustPrice{
 				DrugName:          drug_name,
-				SpecificationName: "",
+				SpecificationName: specification_name,
 				WarehousingUnit:   warehousing_unit,
 				LastPrice:         last_price,
 				RetailPrice:       retail_price,
@@ -1199,7 +1193,8 @@ func (this *SelfDrugApiController) SaveCheckDrugPrice() {
 	list, _ := service.GetDrugAdjuestPrice(ids)
 	for _, item := range list {
 		drug := models.BaseDrugLib{
-			RetailPrice: item.RetailPrice,
+			RetailPrice: item.NewPrice,
+			LastPrice:   item.NewPrice,
 		}
 		service.UpdateBaseDrugOne(drug, item.DrugId)
 	}
@@ -1221,7 +1216,6 @@ func (this *SelfDrugApiController) SaveDrugDamage() {
 		for _, item := range tableData {
 			items := item.(map[string]interface{})
 			drug_name := items["drug_name"].(string)
-			fmt.Println("durg_nae232333223332232323323223232323", drug_name)
 			if items["drug_name"] == nil || reflect.TypeOf(items["drug_name"]).String() != "string" {
 				utils.ErrorLog("drug_name")
 				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
@@ -1360,6 +1354,26 @@ func (this *SelfDrugApiController) SaveDrugDamage() {
 			orgId := this.GetAdminUserInfo().CurrentOrgId
 			Creater := this.GetAdminUserInfo().AdminUser.Id
 
+			if items["stock_max_number"] == nil || reflect.TypeOf(items["stock_max_number"]).String() != "float64" {
+				utils.ErrorLog("stock_max_number")
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+				return
+			}
+			stock_max_number := int64(items["stock_max_number"].(float64))
+
+			if items["stock_min_number"] == nil || reflect.TypeOf(items["stock_min_number"]).String() != "float64" {
+				utils.ErrorLog("stock_min_number")
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+				return
+			}
+			stock_min_number := int64(items["stock_min_number"].(float64))
+
+			if items["total"] == nil || reflect.TypeOf(items["total"]).String() != "string" {
+				utils.ErrorLog("total")
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+				return
+			}
+			total := items["total"].(string)
 			drugDamage := models.XtDrugDamage{
 				DrugName:          drug_name,
 				SpecificationName: specification_name,
@@ -1387,6 +1401,9 @@ func (this *SelfDrugApiController) SaveDrugDamage() {
 				ProductDate:       product_date,
 				WarehousingInfoId: warehousing_info_id,
 				DrugOriginPlace:   drug_origin_place,
+				StockMaxNumber:    stock_max_number,
+				StockMinNumber:    stock_min_number,
+				Total:             total,
 			}
 
 			err := service.CreateDrugDamage(drugDamage)
@@ -1407,7 +1424,7 @@ func (this *SelfDrugApiController) GetDrugDamageList() {
 	fmt.Println(err)
 	orgId := this.GetAdminUserInfo().CurrentOrgId
 	keyword := this.GetString("keyword")
-	fmt.Println("keywoer2r2r32rwrwr", keyword)
+
 	start_time := this.GetString("start_time")
 	end_time := this.GetString("end_time")
 	var startTime int64
@@ -1564,6 +1581,12 @@ func (this *SelfDrugApiController) SaveDrugDamagePrice() {
 		service.CreateWareHouseOutInfo(&warehouseOutInfo)
 		service.CreateDrugFlowOne(drugflow)
 
+		info, _ := service.GetDrugByWarehouseInfo(item.WarehousingInfoId)
+		//扣减库存
+		warehouseInfo := models.XtDrugWarehouseInfo{
+			StockMaxNumber: info.StockMaxNumber - info.StockMaxNumber,
+		}
+		service.UpdateDrugWarehouseingInfo(item.WarehousingInfoId, warehouseInfo)
 	}
 	this.ServeSuccessJSON(map[string]interface{}{
 		"damage": damage,
@@ -1583,6 +1606,10 @@ func (this *SelfDrugApiController) GetDrugModifyPrice() {
 func (this *SelfDrugApiController) ModifyDrugPrice() {
 
 	drug_name := this.GetString("drug_name")
+	specification_name := this.GetString("specification_name")
+	warehousing_unit := this.GetString("warehousing_unit")
+	manufacturer := this.GetString("manufacturer")
+	number := this.GetString("number")
 	retailPrice := this.GetString("retail_price")
 	retail_price, _ := strconv.ParseFloat(retailPrice, 64)
 	newPrice := this.GetString("new_price")
@@ -1590,12 +1617,18 @@ func (this *SelfDrugApiController) ModifyDrugPrice() {
 	count, _ := this.GetInt64("count")
 	remark := this.GetString("remark")
 	id, _ := this.GetInt64("id")
+	drug_id, _ := this.GetInt64("drug_id")
 	adjustPrice := models.XtDrugAdjustPrice{
-		DrugName:    drug_name,
-		Count:       count,
-		RetailPrice: retail_price,
-		NewPrice:    new_price,
-		Remark:      remark,
+		DrugName:          drug_name,
+		Count:             count,
+		RetailPrice:       retail_price,
+		NewPrice:          new_price,
+		Remark:            remark,
+		SpecificationName: specification_name,
+		WarehousingUnit:   warehousing_unit,
+		Manufacturer:      manufacturer,
+		Number:            number,
+		DrugId:            drug_id,
 	}
 	err := service.ModifyDrugPrice(id, adjustPrice)
 	fmt.Println(err)
@@ -1629,7 +1662,7 @@ func (this *SelfDrugApiController) ModifyDrugDamage() {
 	id, _ := this.GetInt64("id")
 	drug_id, _ := this.GetInt64("drug_id")
 	drug_name := this.GetString("drug_name")
-	//drug_origin_place := this.GetString("drug_origin_place")
+	drug_origin_place := this.GetString("drug_origin_place")
 	lastPrice := this.GetString("last_price")
 	last_price, _ := strconv.ParseFloat(lastPrice, 64)
 	newPrice := this.GetString("new_price")
@@ -1641,7 +1674,9 @@ func (this *SelfDrugApiController) ModifyDrugDamage() {
 	remark := this.GetString("remark")
 	count, _ := this.GetInt64("count")
 	warehousing_unit := this.GetString("warehousing_unit")
-
+	stock_max_number, _ := this.GetInt64("stock_max_number")
+	stock_min_number, _ := this.GetInt64("stock_min_number")
+	warehousing_info_id, _ := this.GetInt64("warehousing_info_id")
 	damage := models.XtDrugDamage{
 		DrugName:          drug_name,
 		SpecificationName: "",
@@ -1655,6 +1690,10 @@ func (this *SelfDrugApiController) ModifyDrugDamage() {
 		Remark:            remark,
 		DrugId:            drug_id,
 		Number:            number,
+		StockMaxNumber:    stock_max_number,
+		StockMinNumber:    stock_min_number,
+		WarehousingInfoId: warehousing_info_id,
+		DrugOriginPlace:   drug_origin_place,
 	}
 	err := service.ModifyDrugDamage(id, damage)
 	fmt.Println(err)
@@ -1967,6 +2006,190 @@ func (this *SelfDrugApiController) SaveDrugCheckInventory() {
 	}
 	err = service.UpdateDrugInventory(ids, inventory)
 	fmt.Println(err)
+
+	list, _ := service.GetDrugInventoryListByIds(ids)
+
+	adminUserInfo := this.GetAdminUserInfo()
+	var stock_total int64
+	var proof_count int64
+	var maxNumber int64
+	var minNumber int64
+	for _, item := range list {
+
+		//查询库存信息
+		drug, _ := service.GetDrugDetailByDrugId(item.DrugId)
+
+		//查询库存
+		info, _ := service.GetDrugWareInfoById(item.WarehouseInfoId)
+
+		//获取最晚的库存数量
+		lastInfo, _ := service.GetLastDrugWarehouseInfo(item.DrugId)
+		firstInfo, _ := service.GetFirstDrugWarehouseInfo(item.DrugId)
+		stock_total = info.StockMaxNumber*drug.MinNumber + info.StockMinNumber
+		proof_count = item.StockMaxNumber*drug.MinNumber + item.StockMinNumber
+
+		//判断 如果库存数量 大于盘点库存，则出库
+		if stock_total > proof_count {
+			minNumber = (stock_total - proof_count) % drug.MinNumber
+			maxNumber = (stock_total - proof_count) / drug.MinNumber
+
+			ctime := time.Now().Unix()
+
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := service.FindAllDrugWarehouseOut(adminUserInfo.CurrentOrgId)
+
+			total = total + 1
+			warehousing_out_order := strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000"
+			number, _ := strconv.ParseInt(warehousing_out_order, 10, 64)
+			number = number + total
+			warehousing_out_order = "YPCKD" + strconv.FormatInt(number, 10)
+			operation_time := time.Now().Unix()
+			creater := adminUserInfo.AdminUser.Id
+
+			warehouseOut := models.DrugWarehouseOut{
+				WarehouseOutOrderNumber: warehousing_out_order,
+				OperationTime:           operation_time,
+				OrgId:                   adminUserInfo.CurrentOrgId,
+				Creater:                 creater,
+				Ctime:                   ctime,
+				Status:                  1,
+				WarehouseOutTime:        ctime,
+				Type:                    1,
+			}
+
+			warehouseOutInfo := models.DrugWarehouseOutInfo{
+				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+				WarehouseOutId:          warehouseOut.ID,
+				DrugId:                  firstInfo.DrugId,
+				Count:                   maxNumber,
+				Price:                   firstInfo.Price,
+				TotalPrice:              firstInfo.TotalPrice,
+				Status:                  1,
+				Ctime:                   ctime,
+				Remark:                  item.Remark,
+				OrgId:                   adminUserInfo.CurrentOrgId,
+				Type:                    1,
+				Manufacturer:            firstInfo.Manufacturer,
+				Dealer:                  firstInfo.Dealer,
+				RetailPrice:             firstInfo.RetailPrice,
+				RetailTotalPrice:        firstInfo.RetailTotalPrice,
+				CountUnit:               drug.MaxUnit,
+				ExpiryDate:              firstInfo.ExpiryDate,
+				ProductDate:             firstInfo.ProductDate,
+				Number:                  firstInfo.Number,
+				BatchNumber:             firstInfo.BatchNumber,
+				IsSys:                   0,
+				WarehouseInfoId:         firstInfo.ID,
+			}
+
+			drugflow := models.DrugFlow{
+				WarehouseOutId:          warehouseOut.ID,
+				WarehouseOutOrderNumber: warehousing_out_order,
+				DrugId:                  firstInfo.DrugId,
+				Number:                  firstInfo.Number,
+				ProductDate:             firstInfo.ProductDate,
+				ExpireDate:              firstInfo.ExpiryDate,
+				Count:                   maxNumber,
+				Price:                   firstInfo.Price,
+				Status:                  1,
+				Ctime:                   ctime,
+				UserOrgId:               adminUserInfo.CurrentOrgId,
+				Manufacturer:            firstInfo.Manufacturer,
+				Dealer:                  firstInfo.Dealer,
+				BatchNumber:             firstInfo.BatchNumber,
+				MaxUnit:                 drug.MaxUnit,
+				ConsumableType:          2,
+				IsEdit:                  1,
+				Creator:                 adminUserInfo.AdminUser.Id,
+				IsSys:                   0,
+			}
+
+			service.AddSigleDrugWarehouseOut(&warehouseOut)
+			service.CreateDrugWarehouseOutInfo(warehouseOutInfo)
+			service.CreateDrugFlowOne(drugflow)
+
+		}
+
+		//判断 如果库存数量 小于于盘点库存，则入库
+		if stock_total < proof_count {
+
+			maxNumber = (proof_count - stock_total) / drug.MinNumber
+			minNumber = (proof_count - stock_total) % drug.MinNumber
+			ctime := time.Now().Unix()
+
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := service.FindAllWarehouseTotalOne(adminUserInfo.CurrentOrgId)
+			total = total + 1
+			fmt.Println("total2323232323232", total)
+			warehousing_order := "YPRKD" + strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+
+			operation_time := time.Now().Unix()
+			creater := adminUserInfo.AdminUser.Id
+			warehousing := models.DrugWarehouse{
+				WarehousingOrder: warehousing_order,
+				OperationTime:    operation_time,
+				OrgId:            adminUserInfo.CurrentOrgId,
+				Creater:          creater,
+				Ctime:            ctime,
+				Status:           1,
+				WarehousingTime:  ctime,
+				Type:             1,
+			}
+
+			warehouseInfo := models.DrugWarehouseInfo{
+				WarehousingOrder: warehousing.WarehousingOrder,
+				WarehousingId:    warehousing.ID,
+				DrugId:           lastInfo.DrugId,
+				Number:           lastInfo.Number,
+				ProductDate:      lastInfo.ProductDate,
+				ExpiryDate:       lastInfo.ExpiryDate,
+				WarehousingCount: lastInfo.WarehousingCount,
+				Price:            lastInfo.Price,
+				TotalPrice:       lastInfo.TotalPrice,
+				Status:           1,
+				Ctime:            ctime,
+				Remark:           item.Remark,
+				OrgId:            adminUserInfo.CurrentOrgId,
+				Type:             1,
+				Manufacturer:     lastInfo.Manufacturer,
+				Dealer:           lastInfo.Dealer,
+				StockMaxNumber:   maxNumber,
+				StockMinNumber:   minNumber,
+				RetailTotalPrice: lastInfo.RetailTotalPrice,
+				BatchNumber:      lastInfo.BatchNumber,
+				MaxUnit:          drug.MaxUnit,
+				MinUnit:          drug.MinUnit,
+			}
+
+			drugflow := models.DrugFlow{
+				WarehousingOrder: warehousing.WarehousingOrder,
+				WarehousingId:    warehousing.ID,
+				DrugId:           lastInfo.DrugId,
+				Number:           lastInfo.Number,
+				ProductDate:      lastInfo.ProductDate,
+				ExpireDate:       lastInfo.ExpiryDate,
+				Count:            maxNumber,
+				Price:            lastInfo.Price,
+				Status:           1,
+				Ctime:            ctime,
+				UserOrgId:        adminUserInfo.CurrentOrgId,
+				Manufacturer:     lastInfo.Manufacturer,
+				Dealer:           lastInfo.Dealer,
+				BatchNumber:      lastInfo.BatchNumber,
+				MaxUnit:          drug.MaxUnit,
+				MinUnit:          drug.MinUnit,
+				ConsumableType:   1,
+				IsEdit:           1,
+				Creator:          adminUserInfo.AdminUser.Id,
+				IsSys:            0,
+			}
+			service.AddSigleDrugWarehouse(&warehousing)
+			service.CreateDrugWarehouseInfo(warehouseInfo)
+			service.CreateDrugFlowOne(drugflow)
+		}
+	}
 	returnData := make(map[string]interface{}, 0)
 	returnData["msg"] = "ok"
 	this.ServeSuccessJSON(returnData)
@@ -2004,6 +2227,10 @@ func (this *SelfDrugApiController) ModifyInventory() {
 	last_price, _ := strconv.ParseFloat(lastPrice, 64)
 	count, _ := this.GetInt64("count")
 	drug_origin_place := this.GetString("drug_origin_place")
+
+	stock_max_number, _ := this.GetInt64("stock_max_number")
+	stock_min_number, _ := this.GetInt64("stock_min_number")
+	warehouse_info_id, _ := this.GetInt64("warehouse_info_id")
 	inventory := models.XtDrugInventory{
 		DrugName:          drug_name,
 		SpecificationName: specification_name,
@@ -2018,6 +2245,9 @@ func (this *SelfDrugApiController) ModifyInventory() {
 		Number:            number,
 		Total:             total,
 		DrugOriginPlace:   drug_origin_place,
+		StockMaxNumber:    stock_max_number,
+		StockMinNumber:    stock_min_number,
+		WarehouseInfoId:   warehouse_info_id,
 	}
 	err := service.ModifyDrugInventory(id, inventory)
 	if err != nil {
@@ -2106,3 +2336,13 @@ func (this *SelfDrugApiController) SaveDrugProofInventory() {
 		"inventory": inventory,
 	})
 }
+
+func (this *StockManagerApiController) GetDrugWarehouseInfoTotal() {
+
+	id, _ := this.GetInt64("id")
+	list, _ := service.GetDrugWarehouseInfoTotal(id)
+
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}

controllers/stock_in_api_controller.go

@@ -127,6 +127,7 @@ func StockManagerApiRegistRouters() {
 	beego.Router("/api/drug/deletedrugprice", &StockManagerApiController{}, "Get:DeleteDrugPrice")
 	beego.Router("/api/stock/getgoodwarehouselist", &StockManagerApiController{}, "Get:GetGoodWarehouseList")
 	beego.Router("/api/stock/proofinventory", &StockManagerApiController{}, "Get:ProofInventory")
+	beego.Router("/api/stock/getwarehousetotal", &StockManagerApiController{}, "Get:GetWarehouseTotal")
 
 }
 
@@ -1993,7 +1994,7 @@ func (c *StockManagerApiController) CreateCancelStock() {
 		}
 
 		//查询该批次入库的值
-		infolist, _ := service.GetWarehouseInfoById(item.WarehouseInfoId)
+		infolist, _ := service.GetWarehouseInfoByIdSeven(item.WarehouseInfoId)
 
 		if item.Count > infolist.WarehousingCount {
 			c.ServeSuccessJSON(map[string]interface{}{
@@ -4975,6 +4976,7 @@ func (this *StockManagerApiController) SaveCheckPrice() {
 	for _, item := range list {
 		info := models.GoodInfo{
 			PackingPrice: item.NewPrice,
+			BuyPrice:     item.BuyPrice,
 		}
 		err = service.UpdateAdjustCheckPrice(&info, item.GoodId)
 		fmt.Println(err)
@@ -5659,7 +5661,196 @@ func (this *StockManagerApiController) SaveCheckInventory() {
 		CheckerStatus: 1,
 		CheckerTime:   checkTime,
 	}
+	adminUserInfo := this.GetAdminUserInfo()
 	err = service.UpdateCheckInventory(ids, inventory)
+	manufacturerList, _ := service.GetAllManufacturerList(adminUserInfo.CurrentOrgId)
+	dealerList, _ := service.GetAllDealerList(adminUserInfo.CurrentOrgId)
+	var manufactuer_id int64
+	var dealer_id int64
+	//查询耗材信息
+	list, _ := service.GetInventoryDetailById(ids)
+	for _, item := range list {
+		for _, it := range manufacturerList {
+			if item.Manufacturer == it.ManufacturerName {
+				manufactuer_id = it.ID
+			}
+		}
+
+		for _, its := range dealerList {
+			if item.Dealer == its.DealerName {
+				dealer_id = its.ID
+			}
+		}
+		//查寻该批次的库存量
+		list, _ := service.GetWarehouseInfoById(item.WarehousingInfoId)
+
+		//查询该耗材最后1条批次
+		info, _ := service.GetLastWarehouseInfo(item.GoodId)
+		fmt.Println("总共", item.Count)
+		fmt.Println("数据", list.StockCount)
+		//盘点盘点库存和et实际库存的大小
+		// 如果盘点库存大于实际库存，怎需要入库
+		if item.Count > list.StockCount {
+
+			ctime := time.Now().Unix()
+
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := service.FindAllWarehouseTotal(adminUserInfo.CurrentOrgId)
+			total = total + 1
+			warehousing_order := "RKD" + strconv.FormatInt(adminUserInfo.CurrentOrgId, 10) + timeArr[0] + timeArr[1] + timeArr[2] + "000" + strconv.FormatInt(total, 10)
+			operation_time := time.Now().Unix()
+			creater := adminUserInfo.AdminUser.Id
+			warehousing := models.Warehousing{
+				WarehousingOrder: warehousing_order,
+				OperationTime:    operation_time,
+				OrgId:            adminUserInfo.CurrentOrgId,
+				Creater:          creater,
+				Ctime:            ctime,
+				Status:           1,
+				WarehousingTime:  ctime,
+				Type:             1,
+			}
+			service.AddSigleWarehouse(&warehousing)
+
+			//获取最
+			//入库单表格
+			warehouseInfo := models.WarehousingInfo{
+				WarehousingOrder: warehousing.WarehousingOrder,
+				WarehousingId:    warehousing.ID,
+				GoodId:           item.GoodId,
+				Number:           info.Number,
+				ProductDate:      info.ProductDate,
+				ExpiryDate:       info.ExpiryDate,
+				WarehousingCount: item.Count - list.StockCount,
+				Price:            info.Price,
+				Status:           1,
+				Ctime:            ctime,
+				Remark:           item.Remark,
+				OrgId:            adminUserInfo.CurrentOrgId,
+				Type:             1,
+				Manufacturer:     manufactuer_id,
+				StockCount:       item.Count - list.StockCount,
+				Dealer:           dealer_id,
+				LicenseNumber:    info.LicenseNumber,
+			}
+
+			flow := models.VmStockFlow{
+				WarehousingOrder:    warehousing.WarehousingOrder,
+				WarehousingId:       warehousing.ID,
+				GoodId:              item.GoodId,
+				Number:              info.Number,
+				ProductDate:         info.ProductDate,
+				ExpireDate:          info.ExpiryDate,
+				Count:               item.Count - list.StockCount,
+				Price:               item.BuyPrice,
+				Status:              1,
+				Ctime:               ctime,
+				UserOrgId:           adminUserInfo.CurrentOrgId,
+				Manufacturer:        info.Manufacturer,
+				Dealer:              info.Dealer,
+				LicenseNumber:       info.LicenseNumber,
+				IsEdit:              1,
+				Creator:             adminUserInfo.AdminUser.Id,
+				SystemTime:          operation_time,
+				ConsumableType:      1,
+				WarehousingDetailId: warehouseInfo.ID,
+			}
+
+			service.CreateWarehouseInfo(warehouseInfo)
+			service.CreateStockFlowOne(flow)
+		}
+
+		//如果盘点库存小于实际库存，需要出库
+		if item.Count < list.StockCount {
+			timeStr := time.Now().Format("2006-01-02")
+			timeArr := strings.Split(timeStr, "-")
+			total, _ := service.FindAllWarehouseOut(adminUserInfo.CurrentOrgId)
+
+			total = total + 1
+			warehousing_out_order := strconv.FormatInt(adminUserInfo.CurrentOrgId, 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 := adminUserInfo.AdminUser.Id
+
+			//查询最早的1条批次
+			warehouseInfo, _ := service.GetFirstWarehouseInfo(item.GoodId)
+			warehouseOut := models.WarehouseOut{
+				WarehouseOutOrderNumber: warehousing_out_order,
+				OperationTime:           operation_time,
+				OrgId:                   adminUserInfo.CurrentOrgId,
+				Creater:                 creater,
+				Ctime:                   time.Now().Unix(),
+				Status:                  1,
+				WarehouseOutTime:        time.Now().Unix(),
+				Type:                    1,
+			}
+			err = service.CreateWarehouseOut(warehouseOut)
+			fmt.Println(err)
+			warehouseOutInfo := &models.WarehouseOutInfo{
+				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+				WarehouseOutId:          warehouseOut.ID,
+				GoodId:                  warehouseInfo.GoodId,
+				Count:                   list.StockCount - item.Count,
+				Price:                   warehouseInfo.Price,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				Remark:                  item.Remark,
+				OrgId:                   adminUserInfo.CurrentOrgId,
+				Type:                    1,
+				Manufacturer:            manufactuer_id,
+				Number:                  warehouseInfo.Number,
+				ExpiryDate:              warehouseInfo.ExpiryDate,
+				ProductDate:             warehouseInfo.ProductDate,
+				Dealer:                  dealer_id,
+				LicenseNumber:           warehouseInfo.LicenseNumber,
+			}
+
+			stockFlow := models.VmStockFlow{
+				WarehousingId:           item.WarehousingInfoId,
+				GoodId:                  warehouseInfo.GoodId,
+				Number:                  warehouseInfo.Number,
+				LicenseNumber:           warehouseInfo.LicenseNumber,
+				Count:                   list.StockCount - item.Count,
+				UserOrgId:               warehouseInfo.OrgId,
+				PatientId:               0,
+				SystemTime:              0,
+				ConsumableType:          2,
+				IsSys:                   2,
+				WarehousingOrder:        "",
+				WarehouseOutId:          warehouseOut.ID,
+				WarehouseOutOrderNumber: warehouseOut.WarehouseOutOrderNumber,
+				IsEdit:                  1,
+				CancelStockId:           0,
+				CancelOrderNumber:       "",
+				Manufacturer:            manufactuer_id,
+				Dealer:                  dealer_id,
+				Creator:                 adminUserInfo.AdminUser.Id,
+				UpdateCreator:           0,
+				Status:                  1,
+				Ctime:                   time.Now().Unix(),
+				Mtime:                   0,
+				Price:                   warehouseInfo.Price,
+				WarehousingDetailId:     0,
+				WarehouseOutDetailId:    warehouseOutInfo.ID,
+				CancelOutDetailId:       0,
+				ProductDate:             warehouseInfo.ProductDate,
+				ExpireDate:              warehouseInfo.ExpiryDate,
+			}
+			errOne := service.AddSigleWarehouseOutInfo(warehouseOutInfo)
+			fmt.Println(errOne)
+			//创建出库明细
+			service.CreateStockFlowOne(stockFlow)
+
+			//更改库存
+			warehousingInfos := models.WarehousingInfo{
+				StockCount: item.Count,
+			}
+			service.UpdateStockOut(item.WarehousingInfoId, warehousingInfos)
+		}
+	}
 	fmt.Println(err)
 	this.ServeSuccessJSON(map[string]interface{}{
 		"inventory": inventory,
@@ -5935,3 +6126,12 @@ func (this *StockManagerApiController) ProofInventory() {
 		"list": info,
 	})
 }
+
+func (this *StockManagerApiController) GetWarehouseTotal() {
+
+	id, _ := this.GetInt64("id")
+	list, _ := service.GetWarehouseTotal(id)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"list": list,
+	})
+}

models/self_drug_models.go

@@ -756,6 +756,9 @@ type XtDrugDamage struct {
 	DrugOriginPlace   string  `gorm:"column:drug_origin_place" json:"drug_origin_place" form:"drug_origin_place"`
 	WarehousingInfoId int64   `gorm:"column:warehousing_info_id" json:"warehousing_info_id" form:"warehousing_info_id"`
 	BatchNumber       string  `gorm:"column:batch_number" json:"batch_number" form:"batch_number"`
+	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"`
+	Total             string  `gorm:"column:total" json:"total" form:"total"`
 }
 
 func (XtDrugDamage) TableName() string {
@@ -794,6 +797,8 @@ type XtDrugInventory struct {
 	DrugOriginPlace   string  `gorm:"column:drug_origin_place" json:"drug_origin_place" form:"drug_origin_place"`
 	WarehouseInfoId   int64   `gorm:"column:warehouse_info_id" json:"warehouse_info_id" form:"warehouse_info_id"`
 	ProofCount        int64   `gorm:"column:proof_count" json:"proof_count" form:"proof_count"`
+	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"`
 }
 
 func (XtDrugInventory) TableName() string {

service/dialysis_service.go

@@ -1230,6 +1230,6 @@ func SaveHisProject(advice *models.HisPrescriptionProject) (err error) {
 }
 
 func FindAllHisProjectById(orgID int64, patient_id int64, record_time int64) (advice []*models.HisPrescriptionProject, err error) {
-	err = readDb.Model(&models.HisPrescriptionProject{}).Where("user_org_id=? and status=1 and patient_id = ? AND record_date = ?", orgID, patient_id, record_time).Find(&advice).Error
+	err = readDb.Model(&models.HisPrescriptionProject{}).Preload("HisProject", "status = 1").Where("user_org_id=? and status=1 and patient_id = ? AND record_date = ?", orgID, patient_id, record_time).Find(&advice).Error
 	return
 }

service/patientmanage_service.go

@@ -1668,7 +1668,7 @@ func GetInspectionItemlist(patientid int64, inspect_date []string, projectid []s
 	table := XTReadDB().Table("xt_inspection_reference as s").Where("s.status = 1")
 	fmt.Println(table)
 	if patientid > 0 {
-		db = db.Where("x.patient_id = ?", patientid)
+		db = db.Where("x.patient_id = ? and x.inspect_value <> ''", patientid)
 	}
 	if len(inspect_date) > 0 {
 		db = db.Where("x.inspect_date in(?)", inspect_date)

service/print_data_service/schedule_dialysis/print_schedule_dialysis_models.go

@@ -210,6 +210,7 @@ type PrescriptionVM struct {
 	PunctureNeedleCount        float64 `gorm:"column:puncture_needle_count" json:"puncture_needle_count" form:"puncture_needle_count"`
 	Epo                        string  `gorm:"column:epo" json:"epo" form:"epo"`
 	EpoCount                   float64 `gorm:"column:epo_count" json:"epo_count" form:"epo_count"`
+	MaxUltrafiltrationRate     float64 `gorm:"column:max_ultrafiltration_rate" json:"max_ultrafiltration_rate" form:"max_ultrafiltration_rate"`
 }
 
 func (PrescriptionVM) TableName() string {
@@ -354,6 +355,7 @@ type AssessmentAfterDislysisVM struct {
 	BloodFlow                       int64   `gorm:"column:blood_flow" json:"blood_flow" form:"blood_flow"`
 	SealingFluidDispose             string  `gorm:"column:sealing_fluid_dispose" json:"sealing_fluid_dispose" form:"sealing_fluid_dispose"`
 	SealingFluidSpecial             string  `gorm:"column:sealing_fluid_special" json:"sealing_fluid_special" form:"sealing_fluid_special"`
+	MachineRun                      string  `gorm:"column:machine_run" json:"machine_run" form:"machine_run"`
 }
 
 func (AssessmentAfterDislysisVM) TableName() string {
@@ -525,6 +527,11 @@ type MonitoringRecordVM struct {
 	Modify                    int64   `gorm:"column:modify" json:"modify" form:"modify"`
 	Heparin                   float64 `gorm:"column:heparin" json:"heparin" form:"heparin"`
 	DialysateFlow             float64 `gorm:"column:dialysate_flow" json:"dialysate_flow" form:"dialysate_flow"`
+	AccumulatedBloodVolume    float64 `gorm:"column:accumulated_blood_volume" json:"accumulated_blood_volume" form:"accumulated_blood_volume"`
+	BloodTemperature          float64 `gorm:"column:blood_temperature" json:"blood_temperature" form:"blood_temperature"`
+	UreaMonitoring            float64 `gorm:"column:urea_monitoring" json:"urea_monitoring" form:"urea_monitoring"`
+	BloodThickness            float64 `gorm:"column:blood_thickness" json:"blood_thickness" form:"blood_thickness"`
+	BloodMonitor              float64 `gorm:"column:blood_monitor" json:"blood_monitor" form:"blood_monitor"`
 }
 
 func (MonitoringRecordVM) TableName() string {

service/self_drug_service.go

@@ -817,7 +817,7 @@ func PostSearchDrugWarehouseList(keyword string, orgid int64) (info []*models.Bl
 	if orgid > 0 {
 		db = db.Where("x.org_id = ?", orgid)
 	}
-	err = db.Select("x.id,x.warehousing_id,x.drug_id,x.number,x.product_date,x.expiry_date,x.warehousing_count,x.price,x.total_price,x.dealer,x.remark,x.warehousing_order,x.warehouseing_unit,x.stock_max_number,x.stock_min_number,x.batch_number,t.drug_origin_place,t.drug_name,t.min_unit,x.manufacturer,t.retail_price,t.max_unit,t.min_number,t.dose,t.dose_unit,t.last_price,t.drug_origin_place").Joins("left join xt_base_drug as t on t.id = x.drug_id").Where("t.drug_name like ? and t.org_id = ?", likeKey, orgid).Order("x.ctime desc").Scan(&info).Error
+	err = db.Group("x.drug_id").Select("x.id,x.warehousing_id,x.drug_id,t.number,x.product_date,x.expiry_date,x.warehousing_count,x.price,x.total_price,x.dealer,x.remark,x.warehousing_order,x.warehouseing_unit,x.stock_max_number,x.stock_min_number,x.batch_number,t.drug_origin_place,t.drug_name,t.min_unit,x.manufacturer,t.retail_price,t.max_unit,t.min_number,t.dose,t.dose_unit,t.last_price,t.drug_origin_place").Joins("left join xt_base_drug as t on t.id = x.drug_id").Where("t.drug_name like ? and t.org_id = ?", likeKey, orgid).Order("x.ctime desc").Scan(&info).Error
 	return info, err
 
 }
@@ -889,20 +889,23 @@ func CreateDrugDamage(damage models.XtDrugDamage) error {
 func GetDrugDamageList(startime int64, endtime int64, orgId int64, keyword string, limit int64, page int64) (adjust []*models.XtDrugDamage, total int64, err error) {
 	likeKey := "%" + keyword + "%"
 	offset := (page - 1) * limit
-	db := XTReadDB().Model(&adjust).Where("status = 1")
-	if startime > 0 {
-		db = db.Where("ctime >=?", startime)
-	}
-	if endtime > 0 {
-		db = db.Where("ctime<=?", endtime)
+	db := XTReadDB().Table("xt_drug_damage as x").Where("x.status = 1")
+	table := XTReadDB().Table("xt_base_drug as t").Where("t.status = 1")
+	tab := UserReadDB().Table("sgj_user_admin_role as r").Where("r.status = 1")
+	fmt.Println(table, tab)
+	if len(keyword) > 0 {
+		db = db.Where("x.warehousing_order = ? or r.user_name like ?", keyword, likeKey)
 	}
 	if orgId > 0 {
-		db = db.Where("user_org_id = ?", orgId)
+		db = db.Where("x.user_org_id = ?", orgId)
 	}
-	if len(keyword) > 0 {
-		db = db.Where("warehousing_order like ?", likeKey)
+	if startime > 0 {
+		db = db.Where("x.ctime >=?", startime)
 	}
-	err = db.Count(&total).Offset(offset).Limit(limit).Find(&adjust).Error
+	if endtime > 0 {
+		db = db.Where("x.ctime <=?", endtime)
+	}
+	err = db.Group("x.id").Select("x.id,x.drug_name,x.specification_name,x.warehousing_unit,x.count,x.last_price,x.retail_price,x.new_price,x.manufacturer,x.dealer,x.remark,x.drug_id,x.warehousing_order,x.start_time,x.creater,x.checker,x.checker_status,x.checker_time,x.number,x.drug_origin_place,x.warehousing_info_id,x.batch_number,x.stock_max_number,x.stock_min_number").Joins("left join sgj_users.sgj_user_admin_role as r on r.admin_user_id = x.creater").Joins("left join xt_base_drug as t on t.id =x.drug_id").Count(&total).Offset(offset).Limit(limit).Scan(&adjust).Error
 	return adjust, total, err
 }
 
@@ -920,7 +923,7 @@ func GetDrugModifyPrice(id int64) (models.XtDrugAdjustPrice, error) {
 
 func ModifyDrugPrice(id int64, adjust models.XtDrugAdjustPrice) error {
 
-	err := XTWriteDB().Model(&adjust).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": adjust.DrugName, "retail_price": adjust.RetailPrice, "new_price": adjust.NewPrice, "count": adjust.Count, "remark": adjust.Remark}).Error
+	err := XTWriteDB().Model(&adjust).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": adjust.DrugName, "retail_price": adjust.RetailPrice, "new_price": adjust.NewPrice, "count": adjust.Count, "remark": adjust.Remark, "specification_name": adjust.SpecificationName, "warehousing_unit": adjust.WarehousingUnit, "manufacturer": adjust.Manufacturer, "number": adjust.Number, "drug_id": adjust.DrugId}).Error
 	return err
 }
 
@@ -939,7 +942,7 @@ func GetDrugDamageDetail(id int64) (models.XtDrugDamage, error) {
 
 func ModifyDrugDamage(id int64, damage models.XtDrugDamage) error {
 
-	err := XTWriteDB().Model(&damage).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": damage.DrugName, "warehousing_unit": damage.WarehousingUnit, "count": damage.Count, "last_price": damage.LastPrice, "retail_price": damage.RetailPrice, "new_price": damage.NewPrice, "manufacturer": damage.Manufacturer, "remark": damage.Remark, "number": damage.Number, "drug_id": damage.DrugId}).Error
+	err := XTWriteDB().Model(&damage).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": damage.DrugName, "warehousing_unit": damage.WarehousingUnit, "count": damage.Count, "last_price": damage.LastPrice, "retail_price": damage.RetailPrice, "new_price": damage.NewPrice, "manufacturer": damage.Manufacturer, "remark": damage.Remark, "number": damage.Number, "drug_id": damage.DrugId, "stock_max_number": damage.StockMaxNumber, "stock_min_number": damage.StockMinNumber, "warehousing_info_id": damage.WarehousingInfoId, "drug_origin_place": damage.DrugOriginPlace}).Error
 	return err
 }
 
@@ -997,6 +1000,39 @@ func UpdateDrugInventory(ids []string, inventory models.XtDrugInventory) error {
 	return err
 }
 
+func GetDrugInventoryListByIds(ids []string) (inventory []*models.XtDrugInventory, err error) {
+
+	err = XTReadDB().Model(&inventory).Where("id in(?) and status = 1", ids).Find(&inventory).Error
+	return inventory, err
+}
+
+func GetDrugDetailByDrugId(drug_id int64) (models.XtBaseDrug, error) {
+
+	drug := models.XtBaseDrug{}
+	err := XTReadDB().Model(&drug).Where("id = ? and status = 1", drug_id).Find(&drug).Error
+	return drug, err
+}
+
+func GetDrugWareInfoById(id int64) (models.XtDrugWarehouseInfo, error) {
+	info := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Model(&info).Where("id = ? and status = 1", id).Find(&info).Error
+	return info, err
+}
+
+func GetLastDrugWarehouseInfo(drugid int64) (models.XtDrugWarehouseInfo, error) {
+
+	info := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Model(&info).Where("id=? and status = 1", drugid).Last(&info).Error
+	return info, err
+}
+
+func GetFirstDrugWarehouseInfo(drugid int64) (models.XtDrugWarehouseInfo, error) {
+
+	info := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Model(&info).Where("id=? and status = 1", drugid).First(&info).Error
+	return info, err
+}
+
 func GetDrugInventoryDetail(id int64) (models.XtDrugInventory, error) {
 
 	inventory := models.XtDrugInventory{}
@@ -1006,7 +1042,7 @@ func GetDrugInventoryDetail(id int64) (models.XtDrugInventory, error) {
 
 func ModifyDrugInventory(id int64, info models.XtDrugInventory) error {
 
-	err := XTWriteDB().Model(&info).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": info.DrugName, "specification_name": info.SpecificationName, "warehousing_unit": info.WarehousingUnit, "count": info.Count, "last_price": info.LastPrice, "manufacturer": info.Manufacturer, "remark": info.Remark, "drug_id": info.DrugId, "warehousing_order": info.WarehousingOrder, "number": info.Number, "total": info.Number, "drug_origin_place": info.DrugOriginPlace}).Error
+	err := XTWriteDB().Model(&info).Where("id=? and status = 1", id).Updates(map[string]interface{}{"drug_name": info.DrugName, "specification_name": info.SpecificationName, "warehousing_unit": info.WarehousingUnit, "count": info.Count, "last_price": info.LastPrice, "manufacturer": info.Manufacturer, "remark": info.Remark, "drug_id": info.DrugId, "warehousing_order": info.WarehousingOrder, "number": info.Number, "total": info.Number, "drug_origin_place": info.DrugOriginPlace, "stock_max_number": info.StockMaxNumber, "stock_min_number": info.StockMinNumber, "warehouse_info_id": info.WarehouseInfoId}).Error
 	return err
 }
 
@@ -1051,3 +1087,22 @@ func UpdateDrugWarehouseInfoById(id int64, inventory *models.XtDrugWarehouseInfo
 	err := XTWriteDB().Model(&inventory).Where("id = ?", id).Updates(map[string]interface{}{"stock_max_number": inventory.StockMaxNumber}).Error
 	return err
 }
+
+func GetDrugWarehouseInfoTotal(id int64) (models.XtDrugWarehouseInfo, error) {
+
+	info := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Where("id = ? and status = 1", id).Preload("XtBaseDrug", "status = 1").Find(&info).Error
+	return info, err
+}
+
+func CreateDrugWarehouseInfo(info models.DrugWarehouseInfo) error {
+
+	err := XTWriteDB().Create(&info).Error
+	return err
+}
+
+func CreateDrugWarehouseOutInfo(info models.DrugWarehouseOutInfo) error {
+
+	err := XTWriteDB().Create(&info).Error
+	return err
+}

service/stock_service.go

@@ -508,7 +508,7 @@ func UpdateBaseDrug(lib *models.BaseDrugLib, id int64) error {
 
 func UpdateBaseDrugOne(lib models.BaseDrugLib, id int64) error {
 
-	err := XTWriteDB().Model(&lib).Where("id = ?", id).Updates(map[string]interface{}{"retail_price": lib.RetailPrice}).Error
+	err := XTWriteDB().Model(&lib).Where("id = ?", id).Updates(map[string]interface{}{"retail_price": lib.RetailPrice, "last_price": lib.LastPrice}).Error
 	return err
 }
 func FindeLastWarehouseInfo(id int64) (models.DrugWarehouseInfo, error) {
@@ -571,6 +571,20 @@ func CreateDrugFlow(drugflow []*models.DrugFlow) (err error) {
 	return
 }
 
+func GetDrugByWarehouseInfo(id int64) (models.XtDrugWarehouseInfo, error) {
+
+	info := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Where("id=? and status = 1", id).Find(&info).Error
+	return info, err
+}
+
+func UpdateDrugWarehouseingInfo(id int64, info models.XtDrugWarehouseInfo) error {
+
+	warehouseInfo := models.XtDrugWarehouseInfo{}
+	err := XTReadDB().Model(&warehouseInfo).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"stock_max_number": info.StockMaxNumber}).Error
+	return err
+}
+
 func CreateDrugFlowOne(flow models.DrugFlow) error {
 
 	err := XTWriteDB().Create(&flow).Error
@@ -2542,6 +2556,12 @@ func AddSigleWarehouseOutInfo(info *models.WarehouseOutInfo) error {
 
 }
 
+func UpdateStockOut(warehouseinfoid int64, info models.WarehousingInfo) error {
+
+	err := XTWriteDB().Model(&info).Where("id=? and status = 1", warehouseinfoid).Updates(map[string]interface{}{"stock_count": info.StockCount}).Error
+	return err
+}
+
 func AddSigleDrugWarehouseOutInfo(info *models.DrugWarehouseOutInfo) error {
 	ut := writeDb.Begin()
 	err := ut.Create(&info).Error
@@ -3299,17 +3319,19 @@ func GetAutoDiallysisBefor(startime int64, endtime int64, orgid int64) (info []*
 
 func GetOutStockTotalCountFour(startime int64, endtime int64, orgid int64) (autoMatic []*models.NewXtAutomaticReduceDetail, err error) {
 
-	if startime > 0 {
-		err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time >=?  and `status` = 1)  as b GROUP BY good_id", orgid, startime).Scan(&autoMatic).Error
-	} else {
-		err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and `status` = 1)  as b GROUP BY good_id", orgid).Scan(&autoMatic).Error
-	}
+	//if startime > 0 {
+	//	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time >=?  and `status` = 1)  as b GROUP BY good_id", orgid, startime).Scan(&autoMatic).Error
+	//} else {
+	//	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and `status` = 1)  as b GROUP BY good_id", orgid).Scan(&autoMatic).Error
+	//}
+	//
+	//if endtime > 0 {
+	//	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time <=?  and `status` = 1)  as b GROUP BY good_id", orgid, endtime).Scan(&autoMatic).Error
+	//} else {
+	//	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and `status` = 1)  as b GROUP BY good_id", orgid).Scan(&autoMatic).Error
+	//}
 
-	if endtime > 0 {
-		err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time <=?  and `status` = 1)  as b GROUP BY good_id", orgid, endtime).Scan(&autoMatic).Error
-	} else {
-		err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and `status` = 1)  as b GROUP BY good_id", orgid).Scan(&autoMatic).Error
-	}
+	err = XTReadDB().Raw("SELECT good_id,SUM(b.count) as count FROM (SELECT DISTINCT x.patient_id,x.good_id,x.record_time,x.count FROM xt_automatic_reduce_detail as x WHERE x.org_id = ? and x.record_time >= ? and x.record_time<=? and `status` = 1)  as b GROUP BY good_id", orgid, startime, endtime).Scan(&autoMatic).Error
 
 	return autoMatic, err
 
@@ -4223,13 +4245,38 @@ func UpdateWarehouseInfoOne(count int64, drugid int64, orgid int64) error {
 	return err
 }
 
-func GetWarehouseInfoById(id int64) (models.WarehousingInfo, error) {
+func GetWarehouseInfoByIdSeven(id int64) (models.WarehousingInfo, error) {
 
 	info := models.WarehousingInfo{}
 	err := XTReadDB().Model(&info).Where("id = ? and status = 1", id).Find(&info).Error
 	return info, err
 }
 
+func GetLastWarehouseInfo(goodid int64) (models.WarehousingInfo, error) {
+
+	info := models.WarehousingInfo{}
+	err := XTReadDB().Model(&info).Where("good_id = ? and status = 1", goodid).Last(&info).Error
+	return info, err
+}
+
+func GetFirstWarehouseInfo(goodid int64) (models.WarehousingInfo, error) {
+	info := models.WarehousingInfo{}
+	err := XTReadDB().Model(&info).Where("good_id = ? and status = 1", goodid).First(&info).Error
+	return info, err
+}
+
+func CreateWarehouseOut(out models.WarehouseOut) error {
+
+	err := XTWriteDB().Create(&out).Error
+	return err
+}
+
+func CreateWarehouseInfo(info models.WarehousingInfo) error {
+
+	err := XTReadDB().Create(&info).Error
+	return err
+}
+
 func UpdateGoodWarehouseInfo(id int64, info models.WarehousingInfo) error {
 
 	err := XTWriteDB().Model(&info).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"stock_count": info.StockCount}).Error
@@ -4352,7 +4399,7 @@ func UpdateAdjustPrice(ids []string, info models.XtStockAdjustPrice) error {
 
 func UpdateAdjustCheckPrice(info *models.GoodInfo, id int64) error {
 
-	err := XTWriteDB().Model(&info).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"packing_price": info.PackingPrice}).Error
+	err := XTWriteDB().Model(&info).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"packing_price": info.PackingPrice, "buy_price": info.BuyPrice}).Error
 	return err
 }
 
@@ -4430,11 +4477,9 @@ func GetInventorylist(startime int64, endtime int64, page int64, limit int64, in
 		db = db.Where("x.end_time<=?", endtime)
 	}
 	if len(keyword) > 0 {
-		db = db.Where("x.warehousing_order like ?", likeKey)
-	}
-	if len(keyword) > 0 {
-		db = db.Where("r.user_name like ?", likeKey)
+		db = db.Where("x.warehousing_order like ? or r.user_name like ?", likeKey, likeKey)
 	}
+
 	if orgid > 0 {
 		db = db.Where("x.user_org_id = ?", orgid)
 	}
@@ -4457,6 +4502,19 @@ func GetModifyPriceDetail(id int64) (models.XtStockAdjustPrice, error) {
 	return info, err
 }
 
+func GetInventoryDetailById(id []string) (list []*models.XtStockInventory, err error) {
+
+	err = XTReadDB().Model(&list).Where("id in(?) and status = 1", id).Find(&list).Error
+	return list, err
+}
+
+func GetWarehouseInfoById(id int64) (models.WarehousingInfo, error) {
+
+	info := models.WarehousingInfo{}
+	err := XTReadDB().Model(&info).Where("id = ? and status = 1", id).Find(&info).Error
+	return info, err
+}
+
 func UpdateStockPrice(info models.XtStockAdjustPrice, id int64) error {
 
 	err := XTWriteDB().Model(&info).Where("id = ? and status = 1", id).Updates(map[string]interface{}{"new_price": info.NewPrice, "good_name": info.GoodName, "packing_price": info.PackingPrice, "good_id": info.GoodId, "remark": info.Remark, "manufacturer": info.Manufacturer, "dealer": info.Dealer}).Error
@@ -4578,3 +4636,9 @@ func CeateStockCorrectRecord(record models.XtStockCorrectRecord) error {
 	err := XTWriteDB().Create(&record).Error
 	return err
 }
+
+func GetWarehouseTotal(id int64) (models.WarehousingInfo, error) {
+	info := models.WarehousingInfo{}
+	err := XTReadDB().Where("id=? and status = 1", id).Find(&info).Error
+	return info, err
+}