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 |  125 +++++++++++++++++++++++++++++++----------
 1 files changed, 94 insertions(+), 31 deletions(-)

diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index 05cf173..bb2979d 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -1929,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)
                                 {
@@ -1941,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;
                                 }
@@ -2141,7 +2141,7 @@
                     }
                     else
                     {
-                        result.resultMsg = "鍑哄簱鍗曞彿涓嶈兘涓虹┖";
+                        result.resultMsg = $"{model.cntr_code}瀹瑰櫒鏈壘鍒拌揣浣嶄俊鎭�;
                         result.resultCode = 1;
                         return result;
                     }
@@ -2473,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>
@@ -2532,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;
@@ -2572,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悊绫诲疄渚�@@ -2606,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)
@@ -2621,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;
@@ -2631,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
 
@@ -2731,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(',');
@@ -3091,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();
@@ -3527,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,

--
Gitblit v1.9.1