| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | #region 更新库存信息（暂时不需要） |
|---|
| | | if (stock.IsFull) |
|---|
| | | { |
|---|
| | | // 查询符合条件的库存信息 |
|---|
| | | var stocks = _stockInfoRepository.QueryData(x => x.AreaCode == stock.AreaCode && x.ProductionLine == stock.ProductionLine && x.SpecialParameterDuration != stock.SpecialParameterDuration); |
|---|
| | | //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(); |
|---|
| | | // // 查询任务信息 |
|---|
| | | // var tasks = BaseDal.QueryData(x => x.PalletCode != stock.PalletCode && x.ProductionLine == stock.ProductionLine).Select(x => x.PalletCode).ToList(); |
|---|
| | | |
|---|
| | | if (stocks != null && stocks.Count > 0) |
|---|
| | | { |
|---|
| | | // 过滤出需要更新的库存信息 |
|---|
| | | 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)); |
|---|
| | | } |
|---|
| | | if (stocksToUpdate.Count > 0) |
|---|
| | | { |
|---|
| | | // 异步更新库存信息 |
|---|
| | | var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocksToUpdate); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // if (stocks != null && stocks.Count > 0) |
|---|
| | | // { |
|---|
| | | // // 过滤出需要更新的库存信息 |
|---|
| | | // 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)); |
|---|
| | | // } |
|---|
| | | // if (stocksToUpdate.Count > 0) |
|---|
| | | // { |
|---|
| | | // // 异步更新库存信息 |
|---|
| | | // var isUpdates = await _stockInfoRepository.UpdateDataAsync(stocksToUpdate); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | //} |
|---|
| | | #endregion |
|---|
| | | |
|---|
| | | // 添加历史任务 |
|---|
