方舱智能密集库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
dengjunjie
2025-10-26 26dbfbfc18fe54c9f36121111275300a7c102be7 
 н¨Îļþ¼Ð/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs


@@ -13,6 +13,8 @@


using static WIDESEA_DTO.SquareCabin.TowcsDto;


using WIDESEA_Common.WareHouseEnum;


using WIDESEA_DTO.SquareCabin;


using WIDESEA_Common;


using System.Xml.Linq;




namespace WIDESEA_WMSServer


{


@@ -22,24 +24,16 @@


        private readonly ICabinOrderDetailServices _cabinDetailServices;


        private readonly IDeliveryOrderServices _deliveryOrderServices;


        private readonly IDeliveryOrderDetailServices _deliveryOrderDetailServices;


        private readonly IBasicService _basicService;


        private readonly IMessageInfoService _messageInfoService;


        private readonly IUnitOfWorkManage _unitOfWorkManage;


        private readonly IInventory_BatchServices _inventory_BatchServices;


        private readonly IInventoryInfoService _inventoryInfoService;


        private readonly ISupplyTaskService _supplyTaskService;


        private readonly ITacticsService _tacticsService;


        public Business(IDeliveryOrderServices deliveryOrderServices, IBasicService basicService, IUnitOfWorkManage unitOfWorkManage, IInventory_BatchServices inventory_BatchServices, IInventoryInfoService inventoryInfoService, IDeliveryOrderDetailServices deliveryOrderDetailServices, ISupplyTaskService supplyTaskService, ICabinOrderServices cabinOrderServices, ITacticsService tacticsService, ICabinOrderDetailServices cabinDetailServices)


        public Business(IDeliveryOrderServices deliveryOrderServices, IUnitOfWorkManage unitOfWorkManage, IDeliveryOrderDetailServices deliveryOrderDetailServices, ICabinOrderServices cabinOrderServices, ICabinOrderDetailServices cabinDetailServices, IMessageInfoService messageInfoService)


        {


            _deliveryOrderServices = deliveryOrderServices;


            _basicService = basicService;


            _unitOfWorkManage = unitOfWorkManage;


            _inventory_BatchServices = inventory_BatchServices;


            _inventoryInfoService = inventoryInfoService;


            _deliveryOrderDetailServices = deliveryOrderDetailServices;


            _supplyTaskService = supplyTaskService;


            _cabinOrderServices = cabinOrderServices;


            _tacticsService = tacticsService;


            _cabinDetailServices = cabinDetailServices;


            _messageInfoService = messageInfoService;


        }


        #region èŽ·å–ERP入库单


        static string SearchInDate = "2025-09-10 00:00:00";


@@ -99,7 +93,9 @@




                //存储入库单号


                List<string> orderNos = new List<string>();




                string name = string.Empty;


                MessageGroupByEnum messageGroupBy = MessageGroupByEnum.InOrderAlarm;


                MessageStatusEnum messageStatus = MessageStatusEnum.Emergency;


                foreach (var order in newOrders)


                {


                    try


@@ -107,6 +103,7 @@


                        _unitOfWorkManage.BeginTran();


                        if (order.order_type == "1") //正常入库


                        {


                            name = "创建正常入库单";


                            responseContent = _cabinOrderServices.CreateInboundOrder(order);


                            if (!responseContent.Status) throw new Exception(responseContent.Message);


                            List<Dt_CabinOrder>? dt_CabinOrders = responseContent.Data as List<Dt_CabinOrder>;


@@ -115,6 +112,8 @@


                        }


                        else if (order.order_type == "3")//入库退料


                        {


                            messageGroupBy = MessageGroupByEnum.OutOrderAlarm;


                            name = "创建入库退货单";


                            //创建出库单


                            #region è½¬æ¢ä¸ºå‡ºåº“单


                            UpstramOutOrderInfo upstramOutOrderInfo = new UpstramOutOrderInfo()


@@ -141,6 +140,8 @@


                        }


                        else if (order.order_type == "5")//报溢入库


                        {


                            name = "创建盘盈入库单";


                            messageStatus = MessageStatusEnum.Undisposed;


                            var content = _cabinOrderServices.CreateCheckInOrder(order);


                            if (!content.Status) throw new Exception(content.Message);


                        }


@@ -149,14 +150,11 @@


                    catch (Exception ex)


                    {


                        _unitOfWorkManage.RollbackTran();


                        _messageInfoService.AddMessageInfo(messageGroupBy, name, ex.Message, messageStatus);


                        SendErrorToUpstream(1, "", ex.Message, "");


                        return responseContent.Error("同步失败: " + ex.Message);


                    }


                };




                //在下发给wcs 


                //EdiIn(); //发给下游


                //如果这个方法成功了，那么就调用CompleteOrder接口，然后改变


                return responseContent.OK("同步入库单成功");




            }


@@ -218,21 +216,26 @@


                    return responseContent.OK("所有出库单已存在，无需新增");


                }




                _unitOfWorkManage.BeginTran();


                try


                List<Dt_DeliveryOrder> _DeliveryOrders = new List<Dt_DeliveryOrder>();


                List<string> orderNos = new List<string>();


                string name = string.Empty;


                MessageGroupByEnum messageGroupBy = MessageGroupByEnum.OutOrderAlarm;


                MessageStatusEnum messageStatus = MessageStatusEnum.Emergency;


                foreach (var outorder in newOutOrders)


                {


                    List<Dt_DeliveryOrder> _DeliveryOrders = new List<Dt_DeliveryOrder>();


                    List<string> orderNos = new List<string>();




                    foreach (var outorder in newOutOrders)


                    try


                    {


                        _unitOfWorkManage.BeginTran();


                        if (outorder.order_type == "1") // æ­£å¸¸å‡ºåº“单


                        {


                            name = "创建正常出库单";


                            var content = _deliveryOrderServices.CreateOutboundOrder(outorder);


                            if (!content.Status) throw new Exception(content.Message);


                        }


                        else if (outorder.order_type == "2")//出库退货


                        {


                            name = "创建出库退货单";


                            messageGroupBy = MessageGroupByEnum.InOrderAlarm;


                            // åˆ›å»ºå‡ºåº“退货单 - è¿™é‡Œéœ€è¦æ ¹æ®ä¸šåŠ¡é€»è¾‘实现


                            // æš‚时跳过或实现退货逻辑


                            //continue;


@@ -264,33 +267,22 @@


                        }


                        else if (outorder.order_type == "6")//报损出库


                        {


                            name = "创建盘损出库单";


                            messageStatus = MessageStatusEnum.Undisposed;


                            var content = _deliveryOrderServices.CreateCheckOutOrder(outorder);


                            if (!content.Status) throw new Exception(content.Message);


                        }


                        _unitOfWorkManage.CommitTran();


                    }




                    // æ‰¹é‡æ’入出库单和明细


                    //if (_DeliveryOrders.Any())


                    //{


                    //    BaseDal.Db.InsertNav(_DeliveryOrders).Include(x => x.Details).ExecuteCommand();


                    //}


                    //下发出库单任务给wcs






                    _unitOfWorkManage.CommitTran();


                    //var tex = CreateSupplyTask(order_no);


                    //if (!tex)


                    //{


                    //    return responseContent.Error("创建供应任务失败");


                    //}


                    return responseContent.OK($"同步出库单成功，共{_DeliveryOrders.Count}条");


                    catch (Exception ex)


                    {


                        _unitOfWorkManage.RollbackTran();


                        _messageInfoService.AddMessageInfo(messageGroupBy, name, ex.Message, messageStatus);


                        SendErrorToUpstream(3, "", ex.Message, "");


                        return responseContent.Error("同步失败: " + ex.Message);


                    }


                }


                catch (Exception ex)


                {


                    _unitOfWorkManage.RollbackTran();


                    SendErrorToUpstream(3, "", ex.Message, "");


                    return responseContent.Error("同步失败: " + ex.Message);


                }


                return responseContent.OK($"同步出库单成功，共{_DeliveryOrders.Count}条");


            }


            catch (Exception ex)


            {