1

huangxiaoqiang

4 天以前 85d9ca4ec972ce4d020db046d930e8991709ae2d

 ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA_OrderServices/Dt_ProductionOutboundOrderService.cs

@@ -18,7 +18,9 @@
using WIDESEA_IStorageTaskRepository;
using WIDESEA_IStorageTaskServices;
using WIDESEA_Model.Models;
using WIDESEA_Model.Models.ERP;
using WIDESEA_Model.Models.Order;
using WIDESEA_OrderRepository;

namespace WIDESEA_OrderServices
{
@@ -32,7 +34,8 @@
        private readonly IDt_TaskService _taskService;
        private readonly ILocationInfoRepository _locationRepository;
        private readonly IDt_TaskRepository _taskRepository;
        private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository;
        private readonly ILocationStatusChangeRecordRepository _locationStatusChangeRecordRepository; 
        private readonly IDt_OrderOutDetailsRepository _outDetailsRepository;

        public Dt_ProductionOutboundOrderService(IDt_ProductionOutboundOrderRepository BaseDal,
                                        IUnitOfWorkManage unitOfWorkManage,
@@ -43,7 +46,8 @@
                                        IDt_TaskService taskService,
                                        ILocationInfoRepository locationRepository,
                                        IDt_TaskRepository taskRepository,
                                        ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository) : base(BaseDal)
                                        ILocationStatusChangeRecordRepository locationStatusChangeRecordRepository,
                                        IDt_OrderOutDetailsRepository outDetailsRepository) : base(BaseDal)
        {
            _unitOfWorkManage = unitOfWorkManage;
            _productionoutboundOrderDetailRepository = productionoutboundOrderDetailRepository;
@@ -54,8 +58,8 @@
            _locationRepository = locationRepository;
            _taskRepository = taskRepository;
            _locationStatusChangeRecordRepository = locationStatusChangeRecordRepository;
            _outDetailsRepository = outDetailsRepository;
        }

        public WebResponseContent GetProductOutboundOrder(OutboundOrderGetDTO outboundOrderGetDTO)
        {
            WebResponseContent content = new WebResponseContent();
@@ -158,7 +162,7 @@
                        {
                            return content.Error($"订单{outboundOrder.UpperOrderNo}物料编码{outboundOrderdetail.MaterielCode}未找到库存分配，请确认是否存在库存或单据数量已出完");
                        }

                        List<Dt_OrderOutDetails> outDetails = new List<Dt_OrderOutDetails>();
                        result.Item1.Distinct().ForEach(item =>
                        {
                            RequestTaskDto task = new RequestTaskDto
@@ -173,16 +177,35 @@
                            taskDtos.Add(task);
                            item.StockInfoDetails.Where(x => x.MaterielCode == outboundOrderdetail.MaterielCode).FirstOrDefault().Status = (int)StockStateEmun.出库锁定;
                            item.StockStatus = (int)StockStateEmun.出库锁定;

                            item.StockInfoDetails.Where(x => x.OutboundQuantity > 0 && x.MaterielCode == outboundOrderdetail.MaterielCode).ForEach(x =>
                            {
                                outDetails.Add(new Dt_OrderOutDetails()
                                {
                                    OrderNo = outboundOrder.UpperOrderNo,
                                    PalletCode = item.PalletCode,
                                    OrderType = outboundOrder.OrderType,
                                    ERPOrderId = outboundOrderdetail.ERPOrderId,
                                    MaterielCode = outboundOrderdetail.MaterielCode,
                                    MaterielName = outboundOrderdetail.MaterielName,
                                    Warehouse = "智能立库",
                                    WareHouseId = "107",
                                    OutboundQuantity = x.OutboundQuantity,
                                });
                            });
                        });
                        List<Dt_Task> taskNews = new List<Dt_Task>();
                        List<WMSTaskDTO> taskDTOs = new List<WMSTaskDTO>();
                        foreach (var item in taskDtos)
                        {
                            taskNews.Add(await _taskService.RequestOutboundTaskAsync(item));

                        }
                        List<DtLocationStatusChangeRecord> locationStatusChangeRecords = new List<DtLocationStatusChangeRecord>();
                        List<DtLocationInfo> locations = new List<DtLocationInfo>();
                        if (taskNews.Count <= 0)
                        {
                            throw new Exception($"{outboundOrderdetail.MaterielCode}未找到可出库托盘");
                        }
                        foreach (var item in taskNews)
                        {
                            taskDTOs.Add(CreateTaskDTO(item));
@@ -201,6 +224,7 @@
                            await _locationStatusChangeRecordRepository.AddDataAsync(locationStatusChangeRecords);
                            await _locationRepository.UpdateDataAsync(locations);
                            _productionoutboundOrderDetailRepository.UpdateData(result.Item2);
                            _outDetailsRepository.AddData(outDetails);
                        });
                        content = await _taskService.SendWCSTask(taskDTOs);
                    }
@@ -250,8 +274,7 @@

            foreach (var item in outStocks)
            {
                var stockDetail = item.StockInfoDetails
                .Where(d => d.MaterielCode == outboundOrderdetail.MaterielCode && d.Quantity > 0);
                var stockDetail = item.StockInfoDetails.Where(d => d.MaterielCode == outboundOrderdetail.MaterielCode && d.Quantity > 0);
                if (needQuantity <= 0)
                {
                    continue;