From 1e20867615150dce50f2a834cfe277bfa4749dbb Mon Sep 17 00:00:00 2001
From: hudong <Administrator@PC-20250329JZUF>
Date: 星期一, 30 六月 2025 17:25:04 +0800
Subject: [PATCH] 1.分拣接口拆分出回库接口 2.自动回库接口逻辑完成

---
 api/WmsSpaHelper.cs |  334 +++++++++++++++++++++++++++++++++++++++++++------------
 1 files changed, 258 insertions(+), 76 deletions(-)

diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index 616cc30..bb2979d 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -1009,7 +1009,7 @@
                 {
                     var result = new SimpleResult();
                     //鍒ゆ柇鍐查攢鍑瘉缂栧彿 鏄惁涓虹┖ 濡傛灉涓虹┖ 鍒欎负鍐查攢(瀹℃牳鍓嶆墠鑳藉啿閿�紝闈炲緟鎵ц鐘舵�鎻愮ず鎵ц涓笉鍙啿閿� 涓嶄负绌�鍒欎负澶栭噰鍏ュ簱
-                    if ((itemwlpz.HEAD.YDLX == "351" || itemwlpz.HEAD.YDLX == "Z89") && itemwlpz.ITEM[0].FHGC == "3040")
+                    if (itemwlpz.ITEM[0].JDBS=="H" && itemwlpz.ITEM[0].GC == "3040")
                     {
                         var po = db.Queryable<TN_Ll_Order>().Includes(a => a.Details).Where(s => s.S_NO == itemwlpz.HEAD.WLPZH).First();
                         //鍒涘缓鍑哄簱鍗曚富瀛愯〃
@@ -1245,7 +1245,7 @@
                         }
                         #endregion
                     }
-                    else if ((itemwlpz.HEAD.YDLX == "351" || itemwlpz.HEAD.YDLX == "Z89") && itemwlpz.ITEM[0].GC == "3040")
+                    else if (itemwlpz.ITEM[0].JDBS == "S" && itemwlpz.ITEM[0].GC == "3040")
                     {
                         //鍒涘缓鍏ュ簱鍗曚富瀛愯〃
                         var po = WMSHelper.GetInboundOrder(itemwlpz.HEAD.WLPZH);
@@ -1733,6 +1733,8 @@
         /// <returns></returns>
         internal static SimpleResult InboundOrderSorting(MPSorting model)
         {
+           
+
             var result = new SimpleResult();
             foreach (var a in model.MaterList)
             {
@@ -1747,6 +1749,27 @@
             // var db = new SqlHelper<object>().GetInstance();
             using (var db = new SqlHelper<object>().GetInstance())
             {
+                Location endloc = new Location();
+                var hwbd = db.Queryable<TN_Container_Code>().Where(a => a.S_CNTR_CODE.Trim() == model.cntr_code).First();
+                if (hwbd!=null)
+                {
+                    endloc = db.Queryable<Location>().Where(a => a.S_CODE == hwbd.S_LOC_CODE.Trim()).First();
+                    if (endloc?.N_LOCK_STATE != 0)
+                    {
+                        result.resultCode = 3;
+                        result.resultMsg = $"缁堢偣搴撲綅宸查攣/涓嶅瓨鍦�;
+                        return result;
+                    }
+                }
+                else
+                {
+                    result.resultCode = 3;
+                    result.resultMsg = $"{model.cntr_code}鎵樼洏鎵句笉鍒拌揣浣�;
+                    return result;
+                }
+                   
+
+
                 var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();
 
                 if (locinfo?.N_LOCK_STATE != 0)
@@ -1819,7 +1842,9 @@
                     S_START_LOC = model.start,
                     S_START_AREA = locinfo.S_AREA_CODE,
                     S_START_WH = locinfo.S_WH_CODE,
-                    S_END_LOC = model.start,
+                    S_END_LOC = endloc.S_CODE,
+                    S_END_AREA = endloc.S_AREA_CODE,
+                    S_END_WH = endloc.S_WH_CODE,
                     S_BS_NO = model.MaterList[0].arrival_no,
                     N_TYPE = 1,
                     S_TYPE = WMSTask.GetTypeStr(1),
@@ -1904,7 +1929,7 @@
 
                             if (khsta != null)
                             {
-                                LogHelper.Info($"starts{khsta}");
+                                LogHelper.Info($"starts{khsta?.S_CNTR_CODE}");
                                 var starts12 = db.Queryable<LocCntrRel>().Where(lcr => lcr.S_CNTR_CODE == khsta.S_CNTR_CODE).First();
                                 if (starts12==null)
                                 {
@@ -1916,9 +1941,9 @@
                                 else
                                 {
 
-                                    LogHelper.Info($"starts1{starts12}");
+                                    LogHelper.Info($"starts1{starts12.S_LOC_CODE}");
                                     start = db.Queryable<Location>().Where(loc => loc.S_AREA_CODE == "HJQ" && loc.S_CODE == starts12.S_LOC_CODE).ToList().FirstOrDefault();
-                                    LogHelper.Info($"starts2{start}");
+                                    LogHelper.Info($"starts2{start?.S_CODE}");
 
                                     model.cntr_code = starts12?.S_CNTR_CODE;
                                 }
@@ -2000,26 +2025,42 @@
                         if (!string.IsNullOrEmpty(model.cntr_code))
                         {
 
-                            #region MyRegion
-                            //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray();
-                            //var S_LOC_CODElist =   db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray();
-                            //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First();
+                            var hwbd = db.Queryable<TN_Container_Code>().Where(a => a.S_CNTR_CODE.Trim() == model.cntr_code).First();
+                            if (hwbd!=null)
+                            {
+                                end = db.Queryable<Location>().Where(s => s.S_CODE == hwbd.S_LOC_CODE.Trim()).First();
+                            }
+                            else
+                            {
 
-                            //// 鑾峰彇鎵�湁琚崰鐢ㄧ殑瀹瑰櫒缂栫爜
-                            //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList();
+                                #region MyRegion
+                                //var list = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToArray();
+                                //var S_LOC_CODElist =   db.Queryable<LocCntrRel>().Where(s=>!list.Contains(s.S_CNTR_CODE)).Select(s=>s.S_LOC_CODE).ToArray();
+                                //start = db.Queryable<Location>().Where(it => S_LOC_CODElist.Contains(it.S_CODE)).First();
 
-                            // 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜
-                            var availableLocationCodes = db.Queryable<LocCntrRel>()
-                                .Select(s => s.S_LOC_CODE)
-                                .ToList();
+                                //// 鑾峰彇鎵�湁琚崰鐢ㄧ殑瀹瑰櫒缂栫爜
+                                //var usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList();
+                                #endregion
+                                // 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜
+                                var availableLocationCodes = db.Queryable<LocCntrRel>()
+                                    .Select(s => s.S_LOC_CODE)
+                                    .ToList();
 
                             // 鑾峰彇绗竴涓彲鐢ㄨ揣浣嶏紙濡傛灉娌℃湁鍒欒繑鍥瀗ull锛�                             end = db.Queryable<Location>()
                                .Where(it => !availableLocationCodes.Contains(it.S_CODE) && it.S_AREA_CODE == "HJQ")
                                .ToList().FirstOrDefault();
 
+                                if (end!=null)
+                                {
+                                    TN_Container_Code tN_Container_Code = new TN_Container_Code();
+                                    tN_Container_Code.S_CNTR_CODE= model.cntr_code;
+                                    tN_Container_Code.S_LOC_CODE = end.S_CODE;
+                                    var sss = db.Insertable<TN_Container_Code>(tN_Container_Code).ExecuteCommand();
+                                }
 
-                            #endregion
+                            }
+                           
                         }
                         else
                         {
@@ -2086,16 +2127,25 @@
         {
 
             var result = new SimpleResult();
-
             // var db = new SqlHelper<object>().GetInstance();
 
             using (var db = new SqlHelper<object>().GetInstance())
             {
                 try
                 {
-
-
-                    result.resultMsg = "鎴愬姛";
+                    var start = "";
+                    var startloc = db.Queryable<LocCntrRel>().Where(a => a.S_CNTR_CODE == model.cntr_code).First();
+                    if (startloc!=null)
+                    {
+                        start = startloc.S_LOC_CODE;
+                    }
+                    else
+                    {
+                        result.resultMsg = $"{model.cntr_code}瀹瑰櫒鏈壘鍒拌揣浣嶄俊鎭�;
+                        result.resultCode = 1;
+                        return result;
+                    }
+                        result.resultMsg = "鎴愬姛";
                     result.resultCode = 0;
                     if (string.IsNullOrEmpty(model.arrival_no))
                     {
@@ -2118,27 +2168,27 @@
                     //鏍规嵁涓嶅悓鍑哄簱绫诲瀷 鍥炶皟sap
                     if (po.S_OUT_TYPE == "鍐查攢鍑哄簱")
                     {
-                        result = await CXAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start);
+                        result = await CXAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, start);
                     }
                     else
                     if (po.S_OUT_TYPE == "鍑哄簱")//鏅�鍑哄簱
                     {
                         LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}");
-                        result = await AddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start);
+                        result = await AddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, start);
                     }
                     else if (po.S_OUT_TYPE == "璁″垝澶栧彂鏂欏嚭搴�)
                     {
-                        result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start);
+                        result = await jhwtlAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, start);
                     }
                     else if (po.S_OUT_TYPE == "鎴愭湰涓績鍑哄簱")
                     {
-                        result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.start);
+                        result = await CBAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, start);
                     }
 
                     //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛
-                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE, model.cntr_type);
+                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, start, po.S_OUT_TYPE, model.cntr_type);
                     if (result.resultCode == 1)
-                    {
+                    {   
                         return result;
                     }
                     #region 鍗囬檷閲�@@ -2275,9 +2325,10 @@
 
                 //鍥炲弬鐗╂枡淇℃伅
                 List<OutboundRecord> records = new List<OutboundRecord>();
-                var pz = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).First();
+                var pzlist = db.Queryable<MaterialVoucher>().Where(a => a.S_NO == arrival_no).ToList();
                 foreach (var item in MaterList)
                 {
+                    var pz=pzlist.Where(s=>s.S_WLBM== item.item_code).FirstOrDefault();
                     // 鎻掑叆鍒版墭鐩樻槑缁嗚〃
                     var cntr = db.Queryable<CntrItemRel>().Where(a => a.S_CNTR_CODE == cntr_code).ToList();
                     if (cntr.Count() > 0)
@@ -2298,7 +2349,7 @@
                             else
                             {
                                 db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.S_CNTR_TYPE, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
-                                //娣诲姞鍥炲簱浣滀笟
+                           
                             }
                         }
                         else
@@ -2346,6 +2397,28 @@
                             result.resultMsg += $"浠诲姟{locs.S_CODE}鏉ユ簮鍙穥locs.S_BS_NO}鎵句笉鍒伴厤鐩樹俊鎭�;
                             return result;
                         }
+                        Location endloc = new Location();
+
+                        LogHelper.Info($"鑾峰彇鎵樼洏淇℃伅{cntr_code}瀹瑰櫒");
+                        var hwbd = db.Queryable<TN_Container_Code>().Where(a => a.S_CNTR_CODE.Trim() == cntr_code).First();
+                        if (hwbd != null)
+                        {
+                            endloc = db.Queryable<Location>().Where(a => a.S_CODE == hwbd.S_LOC_CODE.Trim()).First();
+                            if (endloc?.N_LOCK_STATE != 0)
+                            {
+                                result.resultCode = 3;
+                                result.resultMsg = $"缁堢偣搴撲綅宸查攣/涓嶅瓨鍦�;
+                                return result;
+                            }
+
+                        }
+                        else
+                        {
+                            result.resultCode = 3;
+                            result.resultMsg = $"{cntr_code}鎵樼洏鎵句笉鍒拌揣浣�;
+                            return result;
+                        }
+
                         //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First();
                         var wmsTask = new WMSTask
                         {
@@ -2355,12 +2428,12 @@
                             S_START_AREA = startinfo.S_AREA_CODE,
                             S_START_WH = startinfo.S_WH_CODE,
 
-                            S_END_LOC = start,
-                            S_END_AREA = startinfo.S_AREA_CODE,
-                            S_END_WH = startinfo.S_AREA_CODE,
-                            //S_END_LOC = locs?.S_START_LOC,
-                            //S_END_AREA = locs?.S_START_AREA,
-                            //S_END_WH = locs?.S_START_WH,
+                            //S_END_LOC = start,
+                            //S_END_AREA = startinfo.S_AREA_CODE,
+                            //S_END_WH = startinfo.S_AREA_CODE,
+                            S_END_LOC = endloc?.S_CODE,
+                            S_END_AREA = endloc?.S_AREA_CODE,
+                            S_END_WH = endloc?.S_WH_CODE,
 
                             N_TYPE = 1,
                             // S_TYPE = WMSTask.GetTypeStr(1),
@@ -2400,7 +2473,85 @@
         }
 
         //}
+        public static async Task<SimpleResult>  HkGets(HuiK model) {
 
+            var db = new SqlHelper<object>().GetInstance();
+
+            SimpleResult result = new SimpleResult();
+                var locs = db.Queryable<WCSTask>().Where(a => a.S_TYPE.Contains("鍑哄簱") && a.S_CNTR_CODE == model.cntr_code && a.N_B_STATE == 3).OrderByDescending(s => s.T_END_TIME).First();
+                if (locs != null)
+                {
+                    var cntr = db.Queryable<TN_Distribution_CNTR>().Where(a => a.S_DC_NO == locs.S_BS_NO).First();
+                    if (cntr != null)
+                    {
+                        cntr.S_SORT_TYPE = "宸插垎鎷�;
+                        db.Updateable(cntr).UpdateColumns(it => new { it.S_SORT_TYPE }).ExecuteCommand();
+                    }
+                    else
+                    {
+                        result.resultCode = 1;
+                        result.resultMsg += $"浠诲姟{locs.S_CODE}鏉ユ簮鍙穥locs.S_BS_NO}鎵句笉鍒伴厤鐩樹俊鎭�;
+                        return result;
+                    }
+                    Location endloc = new Location();
+
+                    LogHelper.Info($"鑾峰彇鎵樼洏淇℃伅{model.cntr_code}瀹瑰櫒");
+                    var hwbd = db.Queryable<TN_Container_Code>().Where(a => a.S_CNTR_CODE.Trim() == model.cntr_code).First();
+                    if (hwbd != null)
+                    {
+                        endloc = db.Queryable<Location>().Where(a => a.S_CODE == hwbd.S_LOC_CODE.Trim()).First();
+                        if (endloc?.N_LOCK_STATE != 0)
+                        {
+                            result.resultCode = 3;
+                            result.resultMsg = $"缁堢偣搴撲綅宸查攣/涓嶅瓨鍦�;
+                            return result;
+                        }
+
+                    }
+                    else
+                    {
+                        result.resultCode = 3;
+                        result.resultMsg = $"{model.cntr_code}鎵樼洏鎵句笉鍒拌揣浣�;
+                        return result;
+                    }
+                var startloc = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();
+                //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First();
+                var wmsTask = new WMSTask
+                    {
+                        S_CNTR_CODE = model.cntr_code,
+                        S_CODE = WMSHelper.GenerateTaskNo(),
+                        S_START_LOC = model.start,
+                        S_START_AREA = startloc.S_AREA_CODE,
+                        S_START_WH = startloc.S_WH_CODE,
+
+                        //S_END_LOC = start,
+                        //S_END_AREA = startinfo.S_AREA_CODE,
+                        //S_END_WH = startinfo.S_AREA_CODE,
+                        S_END_LOC = endloc?.S_CODE,
+                        S_END_AREA = endloc?.S_AREA_CODE,
+                        S_END_WH = endloc?.S_WH_CODE,
+
+                        N_TYPE = 1,
+                        // S_TYPE = WMSTask.GetTypeStr(1),
+                        S_TYPE = "鍥炲簱",
+                        S_OP_DEF_CODE = "",
+                        S_OP_DEF_NAME = "pda鍏ュ簱"
+                    };
+                    if (WMSHelper.CreateWmsTask(wmsTask))
+                    {
+                        LocationHelper.LockLoc(model.start, 1);
+                        result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}";
+                    }
+                }
+                else
+                {
+                    result.resultCode = 1;
+                    result.resultMsg += $"鎵句笉鍒板鍣ㄥ搴斾换鍔′俊鎭瘂model.cntr_code}";
+                    return result;
+                }
+                return result;
+         
+        }
 
 
         /// <summary>
@@ -2459,7 +2610,7 @@
                     ckbitem.CBZX = po.S_CBZX;
                     ckbitem.WLBH = item.item_code;
                     ckbitem.SL = item.qty;
-                    ckbitem.KCDD = podetail?.S_KCDD;
+                    ckbitem.KCDD = podetail?.S_ERP_WH_CODE;
                     ckbitem.LRZX = po.S_LRZX;
                     ckbitem.ZZKM = po.S_ZZKM;
                     ckbitem.GC = po.S_FACTORY;
@@ -2499,17 +2650,7 @@
                 string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml;
 
                 LogHelper.Info($"鎴愭湰涓績鍑哄簱xml鏁版嵁{xml}");
-                //// 鍒涘缓 StringContent 骞舵寚瀹氬獟浣撶被鍨嬩负 "text/xml"
-                //HttpContent content = new StringContent(xml, Encoding.UTF8, "application/xml");
-                //string url = Settings.WCSSeverUrl + "/api/WmsSap/cesReceiveXmlData";
-                //string responseXml = "";
-                //using (HttpClient client = new HttpClient())
-                //{
-                //    // 鍙戦� POST 璇锋眰骞舵帴鏀跺搷搴�-                //    HttpResponseMessage responsess = await client.PostAsync(url, content);
-                //    responseXml = await responsess.Content.ReadAsStringAsync();
-
-                //}
+            
 
                 #region sap鍥炶皟
                 // 鍒涘缓Web Service浠g悊绫诲疄渚�@@ -2533,12 +2674,13 @@
                 XmlDocument xmlDoc = new XmlDocument();
                 xmlDoc.LoadXml(responses.Output.ToString());
                 JObject jsonObject = JsonConvert.DeserializeObject<JObject>(JsonConvert.SerializeXmlNode(xmlDoc));
-                var data = JsonConvert.DeserializeObject<ReturnWcBcak.Root>(jsonObject.ToString());
+                EnsureArrayFormat(jsonObject, "ITEM", "");
+                var data = JsonConvert.DeserializeObject<CbbReturnWcBcak.Root>(jsonObject.ToString());
 
                 //娣诲姞鍑瘉璁板綍琛�-                result.resultMsg = data.ROOT.ITEM.MSGDESP;
-                result.resultCode = data.ROOT.ITEM.MSGCODE;
-                if (data.ROOT.ITEM.MSGCODE == 0)
+                result.resultMsg = data.ROOT.ITEM[0].MSGDESP;
+                result.resultCode = data.ROOT.ITEM[0].MSGCODE;
+                if (data.ROOT.ITEM[0].MSGCODE == 0)
                 {
 
                     foreach (var item in MaterList)
@@ -2548,8 +2690,8 @@
                         materialVoucher.S_TYPE = po.S_OUT_TYPE;
                         materialVoucher.S_WLBM = item.item_code;
                         materialVoucher.S_WLH = item.N_ROW_NO;
-                        materialVoucher.S_WLPZBH = data.ROOT.ITEM?.WLPZH;
-                        materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
+                        materialVoucher.S_WLPZBH = data.ROOT.ITEM?[0].WLPZBH;
+                        //materialVoucher.S_WLPZND = data.ROOT.ITEM?.WLPZND;
                         materialVoucher.S_WH_CODE = po.S_WH_CODE;
                         materialVoucher.S_AREA_CODE = po.S_AREA_CODE;
                         materialVoucher.F_QTY = item.qty;
@@ -2558,13 +2700,6 @@
                         materialVoucher.UNAME = po.UNAME;
                         db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                     }
-                    //MaterialVoucher materialVoucher = new MaterialVoucher();
-                    //materialVoucher.S_NO = po.S_NO;
-                    //materialVoucher.S_TYPE = po.S_OUT_TYPE;
-                    //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZBH;
-                    //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
-                    //materialVoucher.STATUS = 0;
-                    //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
                 }
                 #endregion
 
@@ -2658,7 +2793,7 @@
                     ckbitem.DDH = podetail?.S_DDH;
                     //ckbitem.DDHXM = (podetail?.N_ROW_NO);
                     ckbitem.WBS = podetail?.S_WBS;
-                    ckbitem.KCDD = podetail?.S_KCDD;
+                    ckbitem.KCDD = podetail?.S_ERP_WH_CODE;
                     ckbitem.PC = podetail?.S_BATCH_NO;
                     JHWBackDto.ITEM1 listitem1 = new JHWBackDto.ITEM1();
                     //string[] xlhValues = item.S_SERIAL_NO.Split(',');
@@ -3018,7 +3153,7 @@
                     ckbitem.YLBH = podetail?.S_YLBH;
                     ckbitem.YLXMH = podetail?.S_YLXMH;
                     ckbitem.GC = po.S_FACTORY;
-                    ckbitem.KCDD = podetail?.S_KCDD;
+                    ckbitem.KCDD = podetail?.S_ERP_WH_CODE;
 
                     CkBcakDto.ITEM1 listitem1 = new CkBcakDto.ITEM1();
                     //var CntrItemRels = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == item.item_code&&a.N_ROW_NO==item.N_ROW_NO).ToList();
@@ -3454,6 +3589,7 @@
                                         S_YLXMH = a.YLHXM,
                                         S_BATCH_NO = "",
                                         S_ERP_WH_CODE = a.KCDD,
+
                                         S_ZJWLTH = a.ZJWLTH,
                                         S_ZJWLMS = a.ZJWLMS,
                                         S_ZHFHBS = a.ZHFHBS,
@@ -4324,7 +4460,7 @@
                     List<TN_Inbound_Detail> tN_Inbound_Details = new List<TN_Inbound_Detail>();
                     po.Details = po.Details.Where(d => model.Wlist.Any(w =>
                                 w.S_ITEM_CODE == d.S_ITEM_CODE &&
-                                w.N_ROW_NO == d.N_ROW_NO))
+                                w.N_ROW_NO == d.N_ROW_NO)).OrderBy(s => s.N_ROW_NO)
                             .ToList();
                     if (po.S_IN_TYPE == "鍐呴噰鍏ュ簱")
                     {
@@ -4364,6 +4500,13 @@
                             tN_Inbound_Details.Add(item);
 
                         }
+                        string combinedIds= string.Join(",", po.Details.Select(x => x.N_ROW_NO));
+                        var KEY = WCSHelper.Generate13DigitIds();
+                        var s_key=   db.Queryable<TN_InBounder_Sh>().Where(a => a.S_NO == model.S_NO&&a.N_ROW_NO == combinedIds).First();
+                        if (s_key!=null)
+                        {
+                            KEY = s_key.S_KEY;
+                        }
                         NcRkDto.Root roots = new NcRkDto.Root
                         {
                             ROOT = new NcRkDto.ROOT
@@ -4373,9 +4516,9 @@
                                     HEAD = new NcRkDto.HEAD
                                     {
 
-                                        KEY = po.S_NO,
+                                        KEY = KEY,
                                         GZRQ = DateTime.Now.ToString("yyyyMMdd"),
-                                        GZRY = model.GZRY,
+                                        GZRY = model.GZRY,//GenerateTaskNo
                                         WLPZBH = po.S_NO,
                                         WLPZND = po.S_WLPZND
                                     },
@@ -4390,8 +4533,7 @@
                         var json = JsonConvert.SerializeObject(roots.ROOT);
                         string xml = JsonConvert.DeserializeXmlNode(json, "ROOT").OuterXml;
 
-                        // 鐜板湪 root 瀵硅薄鍖呭惈浜嗘偍瀹氫箟鐨勫亣鏁版嵁
-                        // 鍙戦�POST璇锋眰
+                       
                         LogHelper.Info($"鍐呴噰鏀惰揣xml鏁版嵁{xml}");
 
                         #region MyRegion
@@ -4449,15 +4591,9 @@
                         //娣诲姞鍑瘉璁板綍琛�                         result.resultMsg = data.ROOT.ITEM.MSGDESP;
                         result.resultCode = data.ROOT.ITEM.MSGCODE;
-                        //MaterialVoucher materialVoucher = new MaterialVoucher();
                         if (data.ROOT.ITEM.MSGCODE == 0)
                         {
-                            //materialVoucher.S_NO = model.S_NO;
-                            //materialVoucher.S_TYPE = po.S_IN_TYPE;
-                            //materialVoucher.S_WLPZBH = data.ROOT.ITEM.WLPZH;
-                            //materialVoucher.S_WLPZND = data.ROOT.ITEM.WLPZND;
-                            //materialVoucher.STATUS = 0;
-                            //db.Insertable<MaterialVoucher>(materialVoucher).ExecuteCommand();
+
                             List<MaterialVoucher> materials = new List<MaterialVoucher>();
                             foreach (var item in model.Wlist)
                             {
@@ -4478,6 +4614,16 @@
                                 db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
                             }
                         }
+                        else
+                        {
+
+                            TN_InBounder_Sh tN_InBounder_Sh = new TN_InBounder_Sh();
+                            tN_InBounder_Sh.S_KEY = KEY;
+                            tN_InBounder_Sh.N_ROW_NO = combinedIds;
+                            tN_InBounder_Sh.S_NO = po.S_NO;
+                            db.Insertable<TN_InBounder_Sh>(tN_InBounder_Sh).ExecuteCommand();
+
+                        }
 
 
                     }
@@ -4496,13 +4642,20 @@
                             PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd");
 
                         }
+                        string combinedIds = string.Join(",", po.Details.Select(x => x.N_ROW_NO));
+                        var KEY = WCSHelper.Generate13DigitIds();
+                        var s_key = db.Queryable<TN_InBounder_Sh>().Where(a => a.S_NO == model.S_NO && a.N_ROW_NO == combinedIds).ToList().FirstOrDefault();
+                        if (s_key != null)
+                        {
+                            KEY = s_key.S_KEY;
+                        }
                         JHWBackDto.Root myRoot = new JHWBackDto.Root
                         {
                             ROOT = new JHWBackDto.ROOT
                             {
                                 HEAD = new JHWBackDto.HEAD
                                 {
-                                    KEY = po.S_NO,
+                                    KEY = KEY,
                                     GZRQ = GZRQ,
                                     PZZDRQ = PZZDRQ,
                                     YHM = po.UNAME,
@@ -4517,6 +4670,7 @@
 
                             }
                         };
+                    
                         //鍥炲弬鐗╂枡淇℃伅
                         List<JHWBackDto.ITEM> iTEMs = new List<JHWBackDto.ITEM>();
                         foreach (var item in po.Details)
@@ -4627,6 +4781,17 @@
                                 db.Insertable<MaterialVoucher>(materials).ExecuteCommand();
                             }
                         }
+                        else
+                        {
+
+                            TN_InBounder_Sh tN_InBounder_Sh = new TN_InBounder_Sh();
+                            tN_InBounder_Sh.S_KEY = KEY;
+                            tN_InBounder_Sh.N_ROW_NO = combinedIds;
+                            tN_InBounder_Sh.S_NO = po.S_NO;
+                            db.Insertable<TN_InBounder_Sh>(tN_InBounder_Sh).ExecuteCommand();
+
+                        }
+
                         #endregion
 
                     }
@@ -4668,6 +4833,13 @@
                             tN_Inbound_Details.Add(item);
 
                         }
+                        string combinedIds = string.Join(",", po.Details.Select(x => x.N_ROW_NO));
+                        var KEY = WCSHelper.Generate13DigitIds();
+                        var s_key = db.Queryable<TN_InBounder_Sh>().Where(a => a.S_NO == model.S_NO && a.N_ROW_NO == combinedIds).First();
+                        if (s_key != null)
+                        {
+                            KEY = s_key.S_KEY;
+                        }
                         WcRkBc.Root roots = new WcRkBc.Root
                         {
                             ROOT = new WcRkBc.ROOT
@@ -4676,7 +4848,7 @@
                                 {
                                     HEAD = new WcRkBc.HEAD
                                     {
-                                        KEY = po.S_NO,
+                                        KEY = KEY,
                                         GZRQ = DateTime.Now.ToString("yyyyMMdd"),
                                         GZRY = model.GZRY,
                                         GC = po.S_FACTORY
@@ -4773,6 +4945,16 @@
                             }
 
                         }
+                        else
+                        {
+
+                            TN_InBounder_Sh tN_InBounder_Sh = new TN_InBounder_Sh();
+                            tN_InBounder_Sh.S_KEY = KEY;
+                            tN_InBounder_Sh.N_ROW_NO = combinedIds;
+                            tN_InBounder_Sh.S_NO = po.S_NO;
+                            db.Insertable<TN_InBounder_Sh>(tN_InBounder_Sh).ExecuteCommand();
+
+                        }
 
                     }
 

--
Gitblit v1.9.1