|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (stock.IsFull) | 
|---|
|  |  |  | { | 
|---|
|  |  |  | // 查询符合条件的库存信息 | 
|---|
|  |  |  | var stocks = _stockInfoRepository.QueryData(x => x.AreaCode == stock.AreaCode && x.ProductionLine == stock.ProductionLine && x.SpecialParameterDuration != stock.SpecialParameterDuration); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 查询任务信息 | 
|---|
|  |  |  | var tasks = BaseDal.QueryData(x => x.PalletCode != stock.PalletCode && x.ProductionLine == stock.ProductionLine).Select(x => x.PalletCode).ToList(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (stocks != null && stocks.Count > 0) | 
|---|
|  |  |  | { | 
|---|
|  |  |  | foreach (var item in stocks) | 
|---|
|  |  |  | // 过滤出需要更新的库存信息 | 
|---|
|  |  |  | var stocksToUpdate = stocks.Where(item => !tasks.Contains(item.PalletCode)).ToList(); | 
|---|
|  |  |  | foreach (var item in stocksToUpdate) | 
|---|
|  |  |  | { | 
|---|
|  |  |  | // 更新库存信息的特定参数 | 
|---|
|  |  |  | item.SpecialParameterDuration = stock.SpecialParameterDuration; | 
|---|
|  |  |  | item.ParameterInfos = stock.ParameterInfos; | 
|---|
|  |  |  | item.OutboundTime = Convert.ToDateTime(item.LinedProcessFeedbackTime == null ? item.CreateDate : item.LinedProcessFeedbackTime).AddHours(Convert.ToDouble(stock.SpecialParameterDuration)); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocks); | 
|---|
|  |  |  | if (stocksToUpdate.Count > 0) | 
|---|
|  |  |  | { | 
|---|
|  |  |  | // 异步更新库存信息 | 
|---|
|  |  |  | var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocksToUpdate); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 添加历史任务 | 
|---|
|  |  |  | var isTaskHtyAdd = await _task_HtyRepository.AddDataAsync(taskHty) > 0; | 
|---|
|  |  |  |  | 
|---|