方舱智能密集库
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
yanjinhui
10 天以前 b330b8ff1b5315684b25afb534f74044dea1654b 
 н¨Îļþ¼Ð/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";


@@ -71,7 +65,7 @@


                // ååºåˆ—化


                var response = JsonConvert.DeserializeObject<UpstreamResponse<UpstreamOrderInfo>>(result);




                if (response.resultCode != "0")


                if (response == null || response.resultCode != "0" || requestData == null)


                {


                    // è°ƒç”¨å¼‚常接口


                    SendErrorToUpstream(1, "", response.resultMsg ?? "上游接口返回失败", "");


@@ -82,8 +76,10 @@


                {


                    return responseContent.OK("无新入库单数据");


                }


                var ordernos = response.data.Select(x => x.order_no).ToList();


                // èŽ·å–所有已存在的入库单号


                var existingOrderNos = _cabinOrderServices.Db.Queryable<Dt_CabinOrder>()


                    .Where(x => ordernos.Contains(x.Order_no))


                    .Select(x => x.Order_no)


                    .Distinct().ToList();




@@ -92,14 +88,16 @@


                    .Where(order => !existingOrderNos.Contains(order.order_no))


                    .ToList();




                if (!newOrders.Any())


                if (newOrders.Count < 1)


                {


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


                }




                //存储入库单号


                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 +105,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 +114,8 @@


                        }


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


                        {


                            messageGroupBy = MessageGroupByEnum.OutOrderAlarm;


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


                            //创建出库单


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


                            UpstramOutOrderInfo upstramOutOrderInfo = new UpstramOutOrderInfo()


@@ -141,6 +142,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 +152,11 @@


                    catch (Exception ex)


                    {


                        _unitOfWorkManage.RollbackTran();


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


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


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


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


                    }


                };




                //在下发给wcs 


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


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


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




            }


@@ -176,8 +176,8 @@


            var responseContent = new WebResponseContent();


            try


            {


                //var url = "http://121.37.118.63:80/GYZ2/95fck/outOrder";


                var url = "http://127.0.0.1:4523/m1/5660322-5340849-default/GYZ2/95fck/outOrder";


                var url = "http://121.37.118.63:80/GYZ2/95fck/outOrder";


                //var url = "http://127.0.0.1:4523/m1/5660322-5340849-default/GYZ2/95fck/outOrder";


                if (string.IsNullOrEmpty(SearchOutDate)) SearchOutDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");


                //// è¯·æ±‚参数


                var requestData = new


@@ -200,9 +200,10 @@


                {


                    return responseContent.OK("无新出库单数据");


                }




                var ordernos = response.data.Select(x => x.order_no).ToList();


                // å·²å­˜åœ¨å‡ºåº“单号


                var existingOutOrderNos = _deliveryOrderServices.Db.Queryable<Dt_DeliveryOrder>()


                    .Where(x => ordernos.Contains(x.Out_no))


                    .Select(x => x.Out_no)


                    .Distinct().ToList();




@@ -213,26 +214,31 @@




                List<string> order_no = newOutOrders.Select(x => x.order_no).ToList();




                if (!newOutOrders.Any())


                if (newOutOrders.Count < 1)


                {


                    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 +270,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)


            {


@@ -488,8 +483,8 @@


                        };




                        // 4. è°ƒç”¨æŽ¥å£


                        //var url = "http://172.16.1.2:9357/file-admin/api/out/ediOut";


                        var url = "http://127.0.0.1:4523/m2/5660322-5340849-default/363076920";


                        var url = "http://172.16.1.2:9357/file-admin/api/out/ediOut";


                        //var url = "http://127.0.0.1:4523/m2/5660322-5340849-default/363076920";




                        var result = HttpHelper.Post(url, ediDto.ToJsonString());


                        var resp = JsonConvert.DeserializeObject<TowcsDto.TowcsResponse<object>>(result);


@@ -553,17 +548,19 @@


                    if (!Orders.Where(x => x.OdrderStatus != "已完成").Any())


                    {


                        _unitOfWorkManage.BeginTran();


                        _cabinOrderServices.Repository.DeleteAndMoveIntoHty(Orders, OperateTypeEnum.自动完成);


                        foreach (var item in Orders)


                        {


                            _cabinDetailServices.Repository.DeleteAndMoveIntoHty(item.Details, OperateTypeEnum.自动完成);


                        }


                        // è°ƒç”¨ä¸Šæ¸¸æŽ¥å£


                        var url = "http://121.37.118.63:80/GYZ2/95fck/inOrderOk";


                        var result = HttpHelper.Post(url, new { order_no = inorder }.ToJsonString());


                        var response = JsonConvert.DeserializeObject<UpstreamOrderResponse>(result);


                        if (response.resultCode == "0")


                        {


                            foreach (var item in Orders)


                            {


                                if (item.Details != null)


                                    _cabinDetailServices.Repository.DeleteAndMoveIntoHty(item.Details, OperateTypeEnum.自动完成);


                                item.Details = null;


                            }


                            _cabinOrderServices.Repository.DeleteAndMoveIntoHty(Orders, OperateTypeEnum.自动完成);


                            // æäº¤äº‹åŠ¡


                            _unitOfWorkManage.CommitTran();


                        }


@@ -604,11 +601,13 @@


                    if (!Orders.Where(x => x.OutStatus != "已完成").Any())


                    {


                        _unitOfWorkManage.BeginTran();


                        _deliveryOrderServices.Repository.DeleteAndMoveIntoHty(Orders, OperateTypeEnum.自动完成);


                        foreach (var item in Orders)


                        {


                            _deliveryOrderDetailServices.Repository.DeleteAndMoveIntoHty(item.Details, OperateTypeEnum.自动完成);


                            if (item.Details != null)


                                _deliveryOrderDetailServices.Repository.DeleteAndMoveIntoHty(item.Details, OperateTypeEnum.自动完成);


                            item.Details = null;


                        }


                        _deliveryOrderServices.Repository.DeleteAndMoveIntoHty(Orders, OperateTypeEnum.自动完成);


                        var url = "http://121.37.118.63:80/GYZ2/95fck/outOrderOk";


                        var requestDate = new


                        {