From d0796679591cc61da1c3718e1a17c6b29975d218 Mon Sep 17 00:00:00 2001
From: hudong <Administrator@PC-20250329JZUF>
Date: 星期一, 02 六月 2025 14:40:32 +0800
Subject: [PATCH] 1

---
 api/WmsSpaHelper.cs |  532 +++++++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 443 insertions(+), 89 deletions(-)

diff --git a/api/WmsSpaHelper.cs b/api/WmsSpaHelper.cs
index 375c0b3..4f9ea2b 100644
--- a/api/WmsSpaHelper.cs
+++ b/api/WmsSpaHelper.cs
@@ -30,11 +30,11 @@
 using System.Security.Policy;
 using HH.WCS.Mobox3.pinggao.models;
 using static HH.WCS.Mobox3.pinggao.wms.WMSHelper;
-using WHTest;
 using System.Net;
 using SqlSugar;
 using static HH.WCS.Mobox3.pinggao.models.SapRoot.GYSDto;
 using System.Web.Services.Protocols;
+using System.Web.Http.ValueProviders;
 
 namespace HH.WCS.Mobox3.pinggao.api
 {
@@ -45,6 +45,34 @@
 
         }
 
+        public static bool MaterPanduan(string ItemCode,double count) {
+            bool panduan = true;
+            var db = new SqlHelper<object>().GetInstance();
+
+            var po = db.Queryable<TN_Material_KC>().Where(a => a.S_ITEM_CODE == ItemCode).First();
+
+            var po1 = db.Queryable<CntrItemRel>().Where(a => a.S_ITEM_CODE == ItemCode).First();
+            if (po != null)
+            {
+                if (po1!=null)
+                {
+                    double sl= po1.F_QTY + count;
+                    if (sl>po.N_COUNT)
+                    {
+                        panduan = false;
+                    }
+                }
+                if (count > po.N_COUNT)
+                {
+                    panduan = false;
+                }
+            }
+            else
+            {
+                panduan = false;
+            }
+            return panduan;
+        }
         /// <summary>
         /// 鏁版嵁
         /// </summary>
@@ -423,6 +451,17 @@
                             }
                             foreach (var item in items.ITEM)
                             {
+                              //bool v=  MaterPanduan(item.WLBM, item.SL);
+                              //  if (!v)
+                              //  {
+                              //      result.resultMsg = "澶辫触";
+                              //      result.WLPZBH = items.HEAD.WLPZH;
+                              //      result.resultCode = 1;
+                              //      result.WLPZND = items.HEAD.WLPZND;
+                              //      result.resultMsg = $"鐗╂枡{item.WLBM}鏁伴噺瓒呰繃 搴撳瓨鎬绘暟";
+                              //      simpleResults.Add(result);
+                              //      continue;
+                              //  }
                                 ///鍒ゆ柇鏄惁閮芥湁鍐查攢鍑瘉缂栧彿
                                 if (string.IsNullOrEmpty(item.CXPZH))
                                 {
@@ -1133,9 +1172,9 @@
 
                                             result.resultCode = 1;
                                             result.resultMsg = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
-                                            result.resultMsg = "澶辫触";
                                             result.WLPZBH = itemwlpz.HEAD.WLPZH;
                                             result.WLPZND = itemwlpz.HEAD.ND;
+                                            simpleResults.Add(result);
                                             continue;
                                             /*  throw new Exception($"鐗╂枡{a.WLH}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�)*/
                                             ;
@@ -1260,12 +1299,13 @@
                             }
                         }
                     }
-                    result.resultMsg = "鎴愬姛";
-                    result.WLPZBH = itemwlpz.HEAD.WLPZH;
-                    result.WLPZND = itemwlpz.HEAD.ND;
-                    result.resultCode = 0;
-                    result.resultMsg = "";
-                    simpleResults.Add(result);
+
+                    var result2 = new SimpleResult();
+                    result2.resultMsg = "鎴愬姛";
+                    result2.WLPZBH = itemwlpz.HEAD.WLPZH;
+                    result2.WLPZND = itemwlpz.HEAD.ND;
+                    result2.resultCode = 0;
+                    simpleResults.Add(result2);
                     db.CommitTran();
                 }
             }
@@ -1736,6 +1776,7 @@
             using (var db = new SqlHelper<object>().GetInstance())
             {
                 var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();
+
                 if (locinfo?.N_LOCK_STATE != 0)
                 {
                     result.resultCode = 3;
@@ -1754,7 +1795,7 @@
                 result.resultMsg = "鎴愬姛";
                 result.resultCode = 0;
                 //鏍¢獙鍏ュ簱鍗曟暟閲忥紝涓嶅彲浠ヨ秴锛屾垚鍔熷悗鎻掑叆鎵樼洏鐗╂枡琛紝鏇存柊鍏ュ簱鍗曠疮璁℃暟閲�-                result = AddInboundOrder(model.MaterList, model.cntr_code);
+                result = AddInboundOrder(model.MaterList, model.cntr_code,model.cntr_type);
                 #region MyRegion
 
 
@@ -1823,7 +1864,223 @@
             }
 
         }
+        /// <summary>
+        /// 鍒嗘嫞
+        /// </summary>
+        /// <param name="model"></param>
+        /// <returns></returns>
+        internal static async Task<SimpleResult> KtSorting(KtSorting model)
+        {
 
+            var result = new SimpleResult();
+
+            // var db = new SqlHelper<object>().GetInstance();
+
+            using (var db = new SqlHelper<object>().GetInstance())
+            {
+                try
+                {
+
+
+                    result.resultMsg = "鎴愬姛";
+                    result.resultCode = 0;
+                    var locinfo = db.Queryable<Location>().Where(a => a.S_CODE == model.start).First();
+
+                    if (locinfo?.N_LOCK_STATE != 0)
+                    {
+                        result.resultCode = 3;
+                        result.resultMsg = $"璧峰搴撲綅宸查攣/涓嶅瓨鍦�;
+                        return result;
+                    }
+                    //鍒ゆ柇鎵樼洏鏄惁宸茬粡鐢熸垚浠诲姟锛屽鏋滄病鏈夊垯鐢熸垚
+                    if (!string.IsNullOrEmpty(model.cntr_code))
+                    {
+                        var wmsTaskcs = WMSHelper.GetWmsTaskByCntr(model.cntr_code);
+                        if (wmsTaskcs != null)
+                        {
+                            result.resultCode = 3;
+                            result.resultMsg = $"璧风偣{model.start} 鎵樼洏{model.cntr_code}宸茬粡鍒涘缓浠诲姟锛岃鍕块噸澶嶇敵璇�;
+                            return result;
+                        }
+                    }
+                   
+                    //鍑哄簱
+                    if (model.Type==2)
+                    {
+                        Location start = new Location();
+                        if (!string.IsNullOrEmpty(model.cntr_code))
+                        {
+                           var loc= db.Queryable<LocCntrRel>().Where(it => it.S_CNTR_CODE == model.cntr_code).First();
+
+
+                            if (loc==null)
+                            {
+                                LogHelper.Info($"瀹瑰櫒{model.cntr_code}鎵句笉鍒板搴旇揣浣�);
+                                result.resultMsg = $"瀹瑰櫒{model.cntr_code}鎵句笉鍒板搴旇揣浣�;
+                                result.resultCode = 1;
+                                return result;
+                            }
+                            else
+                            {
+                                start= db.Queryable<Location>().Where(it => it.S_CODE == loc.S_LOC_CODE).First();
+                            }
+                        }
+                        else if (!string.IsNullOrEmpty(model.item_code))
+                        {
+                            start = db.Queryable<LocCntrRel>()
+                                   .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE&&cir.S_CNTR_TYPE=="鍗婃墭")
+                                   .Where((lcr, cir) => cir.S_CNTR_CODE != null)  
+                                   .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ")
+                                   .Select((lcr, cir, loc) => loc).ToList()  // 杩斿洖 Location 瀵硅薄
+                                   .FirstOrDefault();  // 鎴栬� Take(1).ToList()[0]
+                        }
+                        else
+                        {
+                            #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 usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList();
+
+                            //// 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜
+                            //var availableLocationCodes = db.Queryable<LocCntrRel>()
+                            //    .Where(s => !usedContainerCodes.Contains(s.S_CNTR_CODE))
+                            //    .Select(s => s.S_LOC_CODE)
+                            //    .ToList();
+
+                            //// 鑾峰彇绗竴涓彲鐢ㄨ揣浣嶏紙濡傛灉娌℃湁鍒欒繑鍥瀗ull锛�+                            //var startLocation = db.Queryable<Location>()
+                            //    .Where(it => availableLocationCodes.Contains(it.S_CODE))
+                            //    .ToList().FirstOrDefault();
+
+
+                            #endregion
+                            start = db.Queryable<LocCntrRel>()
+                                    .LeftJoin<CntrItemRel>((lcr, cir) => lcr.S_CNTR_CODE == cir.S_CNTR_CODE)
+                                    .Where((lcr, cir) => cir.S_CNTR_CODE == null)  // 鎵惧嚭鏈鍗犵敤鐨勫鍣�+                                    .LeftJoin<Location>((lcr, cir, loc) => lcr.S_LOC_CODE == loc.S_CODE && loc.S_AREA_CODE == "HJQ")
+                                    .Select((lcr, cir, loc) => loc).ToList()  // 杩斿洖 Location 瀵硅薄
+                                    .FirstOrDefault();  // 鎴栬� Take(1).ToList()[0]
+                        }
+                        if (start==null)
+                        {
+                            LogHelper.Info($"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�);
+                            result.resultMsg = $"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�;
+                            result.resultCode = 1;
+                            return result;
+                        }
+                        //搴撲綅淇℃伅
+
+                        var endinfo = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First();
+                        var wmsTask = new WMSTask
+                        {
+                            S_CNTR_CODE = model.cntr_code,
+                            S_CODE = WMSHelper.GenerateTaskNo(),
+                            S_START_LOC = start.S_CODE,
+                            S_START_AREA = start.S_AREA_CODE,
+                            S_START_WH = start.S_WH_CODE,
+                            S_END_LOC = endinfo.S_CODE,
+                            S_END_AREA = endinfo.S_AREA_CODE,
+                            S_END_WH = endinfo.S_WH_CODE,
+
+                            N_TYPE = 2,
+                            // S_TYPE = WMSTask.GetTypeStr(1),
+                            S_TYPE = "鍑哄簱绌烘墭鐩�,
+                            S_OP_DEF_CODE = "",
+                            S_OP_DEF_NAME = "pda鍑哄簱"
+                        };
+                        if (WMSHelper.CreateWmsTask(wmsTask))
+                        {
+                            LocationHelper.LockLoc(start.S_CODE, 2);
+                            result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}";
+                        }
+
+
+                    }
+                    else //鍏ュ簱
+                    {
+                        Location end = new Location();
+                        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 usedContainerCodes = db.Queryable<CntrItemRel>().Select(s => s.S_CNTR_CODE).ToList();
+
+                            // 鑾峰彇鏈鍗犵敤鐨勫鍣ㄥ搴旂殑璐т綅缂栫爜
+                            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();
+
+
+                            #endregion
+                        }
+                        else
+                        {
+                            LogHelper.Info($"鍏ュ簱 瀹瑰櫒{model.cntr_code}涓嶈兘涓虹┖");
+                            result.resultMsg = $"鍏ュ簱 瀹瑰櫒{model.cntr_code}涓嶈兘涓虹┖";
+                            result.resultCode = 1;
+                            return result;
+
+                        }
+                        if (end==null)
+                        {
+                            LogHelper.Info($"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�);
+                            result.resultMsg = $"{model.cntr_code}鏈壘鍒板彲鐢ㄨ揣浣�;
+                            result.resultCode = 1;
+                            return result;
+                        }
+                        var sart = db.Queryable<Location>().Where(it => it.S_CODE == model.start).First();
+                        var wmsTask = new WMSTask
+                        {
+                            S_CNTR_CODE = model.cntr_code,
+                            S_CODE = WMSHelper.GenerateTaskNo(),
+                            S_START_LOC = sart.S_CODE,
+                            S_START_AREA = sart.S_AREA_CODE,
+                            S_START_WH = sart.S_WH_CODE,
+                            S_END_LOC = end.S_CODE,
+                            S_END_AREA = end.S_AREA_CODE,
+                            S_END_WH = end.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(end.S_CODE, 1);
+                            result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}";
+                        }
+
+                    }
+                    //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛
+
+                    return result;
+
+                }
+                catch (Exception e)
+                {
+                    result.resultMsg = e.Message;
+                    db.RollbackTran();
+                    return result;
+                    throw;
+                }
+            }
+
+        }
         /// <summary>
         /// 鍒嗘嫞
         /// </summary>
@@ -1861,7 +2118,7 @@
                         return result;
 
                     }
-
+                    LogHelper.Info($"S_OUT_TYPE{po.S_OUT_TYPE}");
                     //鏍规嵁涓嶅悓鍑哄簱绫诲瀷 鍥炶皟sap
                     if (po.S_OUT_TYPE == "鍐查攢鍑哄簱")
                     {
@@ -1870,7 +2127,7 @@
                     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);
                     }
                     else if (po.S_OUT_TYPE == "璁″垝澶栧彂鏂欏嚭搴�)
@@ -1883,7 +2140,11 @@
                     }
 
                     //閫氱敤鎺ュ彛 瀵瑰鍣ㄨ揣鍝佺殑鍒犲噺 鍜岀敓鎴愬洖搴撳崟 閮借鐢ㄧ殑鎺ュ彛
-                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE);
+                    result = await TYAddOutboundOrder(db, model.MaterList, model.arrival_no, model.cntr_code, model.IsHK, model.start, po.S_OUT_TYPE,model.cntr_type);
+                    if (result.resultCode==1)
+                    {
+                        return result;
+                    }
                     #region 鍗囬檷閲� 
                     bool adds = true;
@@ -1901,32 +2162,40 @@
                         if (string.IsNullOrEmpty(po.S_WH_CODE))
                         {
                             S_WH_CODE = util.Settings.WHCode;
-                        }  
+                        }
+                        else
+                        {
+                            S_WH_CODE = po.S_WH_CODE;
+                        }
                         if (string.IsNullOrEmpty(po.S_AREA_CODE))
                         {
                             S_AREA_CODE = util.Settings.AREACode;
                         }
-                        model.MaterList.ForEach(a =>
+                        else
                         {
-                            LogHelper.Info($"濉厖鏁版嵁{util.Settings.WHCode}");
-                            LogHelper.Info($"鍑忎粨搴撻噺{util.Settings.AREACode}琛ㄦ暟鎹�浠撳簱{po.S_WH_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}");
-                            req.item_info.Add(new AddChangeModel.itemModel
+                            S_AREA_CODE = po.S_AREA_CODE;
+                        }
+                            model.MaterList.ForEach(a =>
                             {
-                                wh_code = S_WH_CODE,
-                                item_code = a.item_code,
-                                item_name = "",
-                                qty = a.qty
+                                LogHelper.Info($"濉厖鏁版嵁{util.Settings.WHCode}");
+                                LogHelper.Info($"鍑忎粨搴撻噺{util.Settings.AREACode}琛ㄦ暟鎹�浠撳簱{po.S_WH_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}");
+                                req.item_info.Add(new AddChangeModel.itemModel
+                                {
+                                    wh_code = S_WH_CODE,
+                                    item_code = a.item_code,
+                                    item_name = "",
+                                    qty = a.qty
+                                });
+                                LogHelper.Info($"鍑忓簱鍖洪噺琛ㄦ暟鎹�搴撳尯{po.S_AREA_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}");
+                                req2.item_info.Add(new AddChangeModel.itemModel
+                                {
+                                    wh_code = S_WH_CODE,
+                                    area_code = S_AREA_CODE,
+                                    item_code = a.item_code,
+                                    item_name = "",
+                                    qty = a.qty
+                                });
                             });
-                            LogHelper.Info($"鍑忓簱鍖洪噺琛ㄦ暟鎹�搴撳尯{po.S_AREA_CODE} 鐗╂枡缂栫爜{a.item_code} 鐗╂枡鍚嶇О 鏁伴噺{a.qty}");
-                            req2.item_info.Add(new AddChangeModel.itemModel
-                            {
-                                wh_code = S_WH_CODE,
-                                area_code = S_AREA_CODE,
-                                item_code = a.item_code,
-                                item_name = "",
-                                qty = a.qty
-                            });
-                        });
                         var reqData = JsonConvert.SerializeObject(req);
                         var AppKey = Settings.AppKey;
                         var AppSecret = Settings.AppSecret;
@@ -1972,7 +2241,7 @@
                             LogHelper.Info($"mobox 搴撳尯闄嶉噺鎺ュ彛杩斿洖涓虹┖");
 
                         }
-                        if (adds) addOnShelves(po, model.cntr_code, 2);
+                        //if (adds) addOnShelves(po, model.cntr_code, 2);
 
                     }
                     else LogHelper.Info($"鎵樼洏{model.cntr_code}鏃犻渶瑕佸崌闄嶉噺鐨勭墿鏂�);
@@ -1983,6 +2252,7 @@
                 }
                 catch (Exception e)
                 {
+                    LogHelper.Info($"鎶ラ敊{e.Message}");
                     result.resultMsg = e.Message;
                     db.RollbackTran();
                     return result;
@@ -1991,7 +2261,7 @@
             }
 
         }
-        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE)
+        public static async Task<SimpleResult> TYAddOutboundOrder(SqlSugarClient db, List<Mater> MaterList, string arrival_no, string cntr_code, bool isHK, string start, string S_OUT_TYPE,string cntr_type)
         {
             // var db = new SqlHelper<object>().GetInstance();
             //using (var db = new SqlHelper<object>().GetInstance())
@@ -2022,6 +2292,7 @@
                         if (cir != null)
                         {
                             cir.F_QTY -= item.qty;
+                            cir.S_CNTR_TYPE = cntr_type;
                             cir.F_ALLOC_QTY -= item.qty;
                             cir.T_MODIFY = DateTime.Now;
                             if (cir.F_QTY == 0)
@@ -2030,10 +2301,8 @@
                             }
                             else
                             {
-                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
+                                db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE, it.F_ALLOC_QTY, it.T_MODIFY }).ExecuteCommand();
                                 //娣诲姞鍥炲簱浣滀笟
-
-
                             }
                         }
                         else
@@ -2044,31 +2313,7 @@
                             LogHelper.Info($"鐗╂枡涓嶅瓨鍦▄item.item_code}");
                             return result;
                         }
-                        if (isHK)
-                        {
-                            var wmsTask = new WMSTask
-                            {
-                                S_CNTR_CODE = cntr_code,
-                                S_CODE = WMSHelper.GenerateTaskNo(),
-                                S_START_LOC = start,
-                                S_START_AREA = startinfo.S_AREA_CODE,
-                                S_START_WH = startinfo.S_WH_CODE,
-                                S_END_LOC = startinfo.S_CODE,
-                                S_END_AREA = startinfo.S_AREA_CODE,
-                                S_END_WH = startinfo.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(start, 1);
-                                result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}";
-                            }
-                        }
+                      
                         OutboundRecord outboundRecord = new OutboundRecord();
                         outboundRecord.S_WLPZBH = pz?.S_WLPZBH;
                         outboundRecord.S_WLPZND = pz?.S_WLPZND;
@@ -2088,14 +2333,65 @@
                         return result;
                     }
                 }
-                db.Insertable<OutboundRecord>(records).ExecuteCommand();
+                if (isHK)
+                {
+                    var locs= db.Queryable<WCSTask>().Where(a =>a.S_TYPE.Contains("鍑哄簱")&& a.S_CNTR_CODE == 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;
+                        }
+                            //var location = db.Queryable<Location>().Where(a => a.S_CODE == locs.S_LOC_CODE).First();
+                            var wmsTask = new WMSTask
+                            {
+                                S_CNTR_CODE = cntr_code,
+                                S_CODE = WMSHelper.GenerateTaskNo(),
+                                S_START_LOC = start,
+                                S_START_AREA = startinfo.S_AREA_CODE,
+                                S_START_WH = startinfo.S_WH_CODE,
+                                S_END_LOC = locs?.S_START_LOC,
+                                S_END_AREA = locs?.S_START_AREA,
+                                S_END_WH = locs?.S_START_WH,
 
+                                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(start, 1);
+                            result.resultMsg = $"鍒涘缓浣滀笟鎴愬姛锛屼綔涓氬彿{wmsTask.S_CODE}";
+                        }
+                    }
+                    else
+                    {
+                        result.resultCode = 1;
+                        result.resultMsg += $"鎵句笉鍒板鍣ㄥ搴斾换鍔′俊鎭瘂cntr_code}";
+                        return result;
+                    }
+                  
+                }
+               var sss= db.Insertable<OutboundRecord>(records).ExecuteCommand();
+              
                 //db.CommitTran();
             }
             catch (Exception ex)
             {
                 //db.RollbackTran();
                 LogHelper.Info("鐗╂枡淇℃伅缁戝畾鍒版弧瀹瑰櫒涓� + ex.Message);
+                result.resultCode = 1;
+                result.resultMsg += ex.Message;
                 Console.WriteLine(ex.Message);
 
                 throw;
@@ -2677,15 +2973,15 @@
                 var po = db.Queryable<TN_Outbound_Order>().Includes(s => s.Details).Where(a => a.S_NO == arrival_no).First();
                 string GZRQ = "";
                 string PZZDRQ = "";
-                if (po.BUDAT != null)
-                {
-                    GZRQ = DateTime.Parse(po.BUDAT.ToString()).ToString("yyyyMMdd");
-                }
-                if (po.BLDAT != null)
-                {
-                    PZZDRQ = DateTime.Parse(po.BLDAT.ToString()).ToString("yyyyMMdd");
+                //if (po.Details[0].S_CJRQ != null)
+                //{
+                //    GZRQ = DateTime.Parse(po.Details[0].S_CJRQ.ToString()).ToString("yyyyMMdd");
+                //}
+                //if (po.Details[0].S_XQRQ != null)
+                //{
+                //    PZZDRQ = DateTime.Parse(po.Details[0].S_XQRQ.ToString()).ToString("yyyyMMdd");
 
-                }
+                //}
                 CkBcakDto.Root myRoot = new CkBcakDto.Root
                 {
                     ROOT = new CkBcakDto.ROOT
@@ -2693,10 +2989,10 @@
                         WLPZ = new CkBcakDto.WLPZ
                         {
                             KEY = po.S_NO,
-                            ZYWLX = "涓氬姟绫诲瀷鍊�,
-                            PZRQ = PZZDRQ,
-                            GZRQ = GZRQ, // 鍋囪鏃ユ湡鏍煎紡涓�骞�鏈�鏃�
-                            GZRY = po.UNAME,
+                            ZYWLX = "2",
+                            PZRQ = DateTime.Now.ToString("yyyyMMdd"),
+                            GZRQ =DateTime.Now.ToString("yyyyMMdd"), // 鍋囪鏃ユ湡鏍煎紡涓�骞�鏈�鏃�
+                            GZRY = po.S_CREATOR_NAME,
                             ITEM = new List<CkBcakDto.ITEM>
                             {
                             }
@@ -2730,7 +3026,7 @@
                     //var serialNos = string.Join(",", CntrItemRels
                     //                    .Where(s => s.S_ITEM_CODE == item.item_code)
                     //                    .Select(s => s.S_SERIAL_NO));
-                    listitem1.XLH = podetail?.S_SERIAL_NO.Split(',').ToList();
+                    listitem1.XLH = podetail?.S_SERIAL_NO==null?null: podetail?.S_SERIAL_NO.Split(',').ToList();
                     //foreach (var xlhValue in xlhValues)
                     //{
                     //    CkBcakDto.ITEM1 newItem = new CkBcakDto.ITEM1 { XLH = xlhValue };
@@ -2740,6 +3036,10 @@
                     iTEMs.Add(ckbitem);
                 }
                 myRoot.ROOT.WLPZ.ITEM = iTEMs;
+                if (myRoot.ROOT.WLPZ.ITEM.Where(s=>!string.IsNullOrEmpty(s.SCDD) && !string.IsNullOrEmpty(s.YLBH) && !string.IsNullOrEmpty(s.YLXMH)).Count()==0)
+                {
+                    myRoot.ROOT.WLPZ.ZYWLX = "2";
+                }
                 //db.Insertable<OutboundRecord>(records).ExecuteCommand();
                 #region wms-sap鍥炶皟
                 //绫昏浆json
@@ -2839,9 +3139,9 @@
         /// <param name="cntr_code"></param>
         /// <returns></returns>
         [ApiExplorerSettings(IgnoreApi = true)]
-        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code)
+        public static SimpleResult AddInboundOrder(List<Mater> MaterList, string cntr_code,string S_CNTR_TYPE)
         {
-            var result = new SimpleResult();
+            var result = new SimpleResult();     
             //  var db = new SqlHelper<object>().GetInstance();
             using (var db = new SqlHelper<object>().GetInstance())
             {
@@ -2884,12 +3184,13 @@
                                     if (cir != null)
                                     {
                                         cir.F_QTY += item.qty;
-                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY }).ExecuteCommand();
+                                        cir.S_CNTR_TYPE = S_CNTR_TYPE;
+                                        db.Updateable(cir).UpdateColumns(it => new { it.F_QTY,it.S_CNTR_TYPE }).ExecuteCommand();
                                     }
                                     else
                                     {
                                         //2.鎻掑叆鏂扮殑瀹瑰櫒鐗╂枡淇℃伅锛堝鍣ㄥ彿涓嶅彉S_SERIAL_NO = item.S_SERIAL_NO,锛�-                                        cir = new CntrItemRel { S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no };
+                                        cir = new CntrItemRel { S_CNTR_TYPE= S_CNTR_TYPE, S_CNTR_CODE = cntr.S_CODE.Trim(), S_UOM = info.S_UOM, S_BATCH_NO = item.S_BATCH_NO, N_BS_ROW_NO = item.N_ROW_NO, F_QTY = item.qty, S_ITEM_CODE = item.item_code, S_BS_NO = item.arrival_no };
                                         db.Insertable<CntrItemRel>(cir).ExecuteCommand();
                                     }
                                     var count = db.Queryable<CntrItemRel>().Count(a => a.S_CNTR_CODE == cntr.S_CODE);
@@ -2988,7 +3289,7 @@
                                         lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
                                         iTEMs.Add(lLDReturnRoots);
 
-                                        continue;
+                                        break ;
                                     }
                                     po.Details.Add(new TN_Ll_detail
                                     {
@@ -2998,14 +3299,27 @@
                                         S_ITEM_CODE = a.WLBM,
                                         S_ITEM_NAME = item.S_ITEM_NAME,
                                         F_QTY = a.XQSL,
+                                        S_ZJBM = a.ZJBM,
+                                        S_YLBH = a.YLBH,
+                                        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,
+                                        S_CJRQ = a.CJRQ,
+                                        S_LLDSCBS = a.LLDSCBS,
+                                        S_SCGLY = a.SCGLY,
+                                        S_GXH = a.GXH,
+                                        S_XQRQ = a.XQRQ,
                                         N_ITEM_STATE = 1
                                     });
                                 }
-
-                                var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
-                                db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
+                                if (po.Details.Count()>0)
+                                {
+                                    var result1 = db.Insertable<TN_Ll_Order>(po).ExecuteCommand() > 0;
+                                    db.Insertable<TN_Ll_detail>(po.Details).ExecuteCommand();
+                                }
 
                             }
                         }
@@ -3027,7 +3341,7 @@
                                         lLDReturnRoots.MSGCODE = 1;
                                         lLDReturnRoots.MSGDESP = $"鎵ц涓鏂欏崟锛岀墿鏂檣a.WLBM}鐗╂枡涓嶅厑璁稿垹闄�;
                                         iTEMs.Add(lLDReturnRoots);
-                                        continue;
+                                        break;
                                     }
                                     var po1 = po.Details.Where(s => a.WLBM == s.S_ITEM_CODE).ToList();
                                     if (po1.Count() == 0)  //鏃犲垯鏂板鐗╂枡鏄庣粏
@@ -3043,7 +3357,7 @@
                                             lLDReturnRoots.MSGCODE = 1;
                                             lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
                                             iTEMs.Add(lLDReturnRoots);
-                                            continue;
+                                            break;
                                         }
                                         TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail
                                         {
@@ -3053,6 +3367,17 @@
                                             S_ITEM_CODE = a.WLBM,
                                             S_ITEM_NAME = item.S_ITEM_NAME,
                                             F_QTY = a.XQSL,
+                                            S_ZJBM = a.ZJBM,
+                                            S_YLBH = a.YLBH,
+                                            S_YLXMH = a.YLHXM,
+                                            S_ZJWLTH = a.ZJWLTH,
+                                            S_ZJWLMS = a.ZJWLMS,
+                                            S_ZHFHBS = a.ZHFHBS,
+                                            S_CJRQ = a.CJRQ,
+                                            S_LLDSCBS = a.LLDSCBS,
+                                            S_GXH = a.GXH,
+                                            S_XQRQ = a.XQRQ,
+                                            S_SCGLY = a.SCGLY,
                                             S_BATCH_NO = "鏃�,
                                             S_ERP_WH_CODE = a.KCDD,
                                             N_ITEM_STATE = 1
@@ -3076,7 +3401,7 @@
                                             lLDReturnRoots.MSGCODE = 1;
                                             lLDReturnRoots.MSGDESP = $"鏇存柊澶辫触锛屾洿鏂版暟閲忓繀椤诲ぇ浜庡綋鍓嶇墿鏂欐暟閲弡a.WLBM}";
                                             iTEMs.Add(lLDReturnRoots);
-                                            continue;
+                                            break;
                                         }
                                     }
                                 }
@@ -3103,7 +3428,7 @@
                                             lLDReturnRoots.MSGCODE = 1;
                                             lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡鏁版嵁涓嶅瓨鍦�鏃犳硶鍒犻櫎";
                                             iTEMs.Add(lLDReturnRoots);
-                                            continue;
+                                            break;
                                         }
                                     }
                                     else
@@ -3122,7 +3447,7 @@
                                                 lLDReturnRoots.MSGCODE = 1;
                                                 lLDReturnRoots.MSGDESP = $"鐗╂枡{a.WLBM}鐗╂枡涓绘暟鎹笉瀛樺湪璇ョ墿鏂�;
                                                 iTEMs.Add(lLDReturnRoots);
-                                                continue;
+                                                break;
                                             }
                                             TN_Ll_detail tN_Outbound_Detail = new TN_Ll_detail
                                             {
@@ -3132,6 +3457,17 @@
                                                 S_ITEM_CODE = a.WLBM,
                                                 S_ITEM_NAME = item.S_ITEM_NAME,
                                                 F_QTY = a.XQSL,
+                                                S_ZJBM = a.ZJBM,
+                                                S_YLBH = a.YLBH,
+                                                S_YLXMH = a.YLHXM,
+                                                S_ZJWLTH = a.ZJWLTH,
+                                                S_ZJWLMS = a.ZJWLMS,
+                                                S_ZHFHBS = a.ZHFHBS,
+                                                S_CJRQ = a.CJRQ,
+                                                S_LLDSCBS = a.LLDSCBS,
+                                                S_SCGLY = a.SCGLY,
+                                                S_GXH = a.GXH,
+                                                S_XQRQ = a.XQRQ,
                                                 S_BATCH_NO = "鏃�,
                                                 S_ERP_WH_CODE = a.KCDD,
                                                 N_ITEM_STATE = 1
@@ -3153,6 +3489,13 @@
                                 db.Insertable<TN_Ll_detail>(listtn).ExecuteCommand();
                             }
                         }
+
+
+                        lLDReturnRoots.GC = itemscddll.GC;
+                        lLDReturnRoots.LLDH = itemscddll.LLDH;
+                        lLDReturnRoots.MSGCODE = 0;
+                        lLDReturnRoots.MSGDESP = $"鎴愬姛";
+                        iTEMs.Add(lLDReturnRoots);
                         db.CommitTran();
                     }
 
@@ -3240,6 +3583,17 @@
                                         S_BATCH_NO = a.S_BATCH_NO,
                                         S_SERIAL_NO = a.S_SERIAL_NO,
                                         S_CGPZH = a.S_CGPZH,
+                                        S_ZJBM = a.S_ZJBM,
+                                        S_YLBH = a.S_YLBH,
+                                        S_ZJWLTH = a.S_ZJWLTH,
+                                        S_ZJWLMS = a.S_ZJWLMS,
+                                        S_ZHFHBS = a.S_ZHFHBS,
+                                        S_CJRQ = a.S_CJRQ,
+                                        S_LLDSCBS = a.S_LLDSCBS,
+                                        S_SCGLY = a.S_SCGLY,
+                                        S_GXH = a.S_GXH,
+                                        S_XQRQ = a.S_XQRQ,
+                                        S_YLXMH = a.S_YLXMH,
                                         S_CGPZXMBH = a.S_CGPZXMBH,
                                         S_ERP_WH_CODE = a.S_ERP_WH_CODE,
                                         N_ITEM_STATE = a.N_ITEM_STATE
@@ -3802,7 +4156,7 @@
                         // 鍑嗗璇锋眰鍙傛暟
                         ZscmNc request = new ZscmNc();
                         request.Input = "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + xml;
-                        LogHelper.Info($"鍐呴噰SAP鍥炶皟");
+                        LogHelper.Info($"鍐呴噰SAP鍥炶皟{service.Url}");
                         // 璋冪敤Web Service
                         ZscmNcResponse responses = service.ZscmNc(request);
 

--
Gitblit v1.9.1