From dd05ce0fe597c0f4c9e3a02228e1b4f6188546aa Mon Sep 17 00:00:00 2001
From: dengjunjie <dengjunjie@hnkhzn.com>
Date: 星期二, 28 十月 2025 19:12:02 +0800
Subject: [PATCH] Merge branch 'master' of http://115.159.85.185:8098/r/ZhiHuiQiCe/FangCangZhiNeng

---
 新建文件夹/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs |   41 ++++++++++++++++++++++++-----------------
 1 files changed, 24 insertions(+), 17 deletions(-)

diff --git "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs" "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs"
index 02586ea..955a9ba 100644
--- "a/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs"
+++ "b/\346\226\260\345\273\272\346\226\207\344\273\266\345\244\271/WIDESEA_WMSServer/WIDESEA_SquareCabinServices/Business.cs"
@@ -65,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 ?? "涓婃父鎺ュ彛杩斿洖澶辫触", "");
@@ -76,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();
 
@@ -86,7 +88,7 @@
                     .Where(order => !existingOrderNos.Contains(order.order_no))
                     .ToList();
 
-                if (!newOrders.Any())
+                if (newOrders.Count < 1)
                 {
                     return responseContent.OK("鎵�鏈夊叆搴撳崟宸插瓨鍦紝鏃犻渶鏂板");
                 }
@@ -152,7 +154,7 @@
                         _unitOfWorkManage.RollbackTran();
                         _messageInfoService.AddMessageInfo(messageGroupBy, name, ex.Message, messageStatus);
                         SendErrorToUpstream(1, "", ex.Message, "");
-                        return responseContent.Error("鍚屾澶辫触: " + ex.Message);
+                        //return responseContent.Error("鍚屾澶辫触: " + ex.Message);
                     }
                 };
                 return responseContent.OK("鍚屾鍏ュ簱鍗曟垚鍔�");
@@ -174,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
@@ -198,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();
 
@@ -211,7 +214,7 @@
 
                 List<string> order_no = newOutOrders.Select(x => x.order_no).ToList();
 
-                if (!newOutOrders.Any())
+                if (newOutOrders.Count < 1)
                 {
                     return responseContent.OK("鎵�鏈夊嚭搴撳崟宸插瓨鍦紝鏃犻渶鏂板");
                 }
@@ -279,7 +282,7 @@
                         _unitOfWorkManage.RollbackTran();
                         _messageInfoService.AddMessageInfo(messageGroupBy, name, ex.Message, messageStatus);
                         SendErrorToUpstream(3, "", ex.Message, "");
-                        return responseContent.Error("鍚屾澶辫触: " + ex.Message);
+                        //return responseContent.Error("鍚屾澶辫触: " + ex.Message);
                     }
                 }
                 return responseContent.OK($"鍚屾鍑哄簱鍗曟垚鍔燂紝鍏眥_DeliveryOrders.Count}鏉�");
@@ -480,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);
@@ -545,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();
                         }
@@ -596,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
                         {

--
Gitblit v1.9.3