From 05fdade2564f0880fcba935aadf12e79a467764b Mon Sep 17 00:00:00 2001
From: Rodney Chen <rodney.chen@hotmail.com>
Date: 星期二, 18 三月 2025 00:15:47 +0800
Subject: [PATCH] 优化清点逻辑

---
 Tiger.Business.WMS/Transaction/In_Default.cs |  358 +++++++++++++++++++++++++++++++----------------------------
 1 files changed, 188 insertions(+), 170 deletions(-)

diff --git a/Tiger.Business.WMS/Transaction/In_Default.cs b/Tiger.Business.WMS/Transaction/In_Default.cs
index f83e6fb..9f0f1cd 100644
--- a/Tiger.Business.WMS/Transaction/In_Default.cs
+++ b/Tiger.Business.WMS/Transaction/In_Default.cs
@@ -11,35 +11,25 @@
 using Tiger.IBusiness;
 using Tiger.Model.Sharetronic.Shelf;
 using Tiger.Business.WMS.Sharetronic.Shelf;
-using Microsoft.IdentityModel.Tokens;
-using Apache.NMS.ActiveMQ.Commands;
+//using Microsoft.IdentityModel.Tokens;
 using Tiger.Model.MES.Yada;
-using Tiger.Model.Entitys.MES.Position;
 
 namespace Tiger.Business.WMS.Transaction
 {
     /// <summary>
     /// 鏍囧噯涓婃灦浜嬪姟
     /// </summary>
-    public class In_Default : WMSTransactionBase, IIn_Default
+    public class In_Default : WmsTask, IIn_Default
     {
         public IIn_Default Init(string id, string userCode, string apiHost, string orgCode)
         {
-            TransID = id;
-            UserCode = userCode;
-            ApiHost = apiHost;
-            OrgCode = orgCode;
+            base.Init(id, userCode, apiHost, orgCode);
             Logger.Console.Info($"Start {this.GetType().Name} Transaction[ID: {TransID}]");
             return this;
         }
 
         #region Propertys & Variables
-        public string UserCode { get; set; }
-        public long UserId { get; set; }
-        public string OrgCode { get; set; }
-        public Inventory CurInvItem { get; set; }
-        public ScanShelfInfo CurScanShelf { get; set; }
-        public string Command { get; set; } = "Normal";
+        
         #endregion
 
         #region Functions
@@ -48,7 +38,7 @@
         /// </summary>
         public async Task<ApiAction<ScanOutput>> Scan(BaseInput input)
         {
-            var action = new ApiAction<ScanOutput>();
+            var action = new ApiAction<ScanOutput>(new ScanOutput());
             try
             {
                 if (input.SN.IsNullOrEmpty())
@@ -58,12 +48,14 @@
                     action.LocaleMsg = Biz.L("WMS.Default.ScanItem.SnEmptyFailure");
                     return SetOutPutMqttMsg(action, input.Locale);
                 }
-                //璐ф灦涓虹┖鍒欐壂鎻忕殑璁や负鏄揣鏋�
-                if (string.IsNullOrEmpty(CurScanShelf?.ShelfCode))
+                //鍒ゆ柇鎵弿鐨勬槸鍚﹁揣鏋�
+                var whUnit = await MainDB.Queryable<V_WH_UNIT>().Where(t => (t.SHELF_CODE.ToUpper() == input.SN || t.LOCATION_CODE.ToUpper() == input.SN) && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();
+                //if (string.IsNullOrEmpty(CurScanShelf?.ShelfCode))
+                if (!whUnit.IsNullOrEmpty() || string.IsNullOrEmpty(CurScanShelf?.ShelfCode))
                 {
-                    action = await ScanShelf(input.SN);
+                    action = await ScanShelf(input.SN, whUnit);
                 }
-                //鎵弿鐗╂枡骞跺鏍�
+                else//鎵弿鐗╂枡骞跺鏍�
                 {
                     action = await ScanItem(input);
                 }
@@ -71,7 +63,7 @@
             catch (Exception ex)
             {
                 //鍙栨秷褰撳墠鎿嶄綔
-                ResetInfo();
+                ResetScan();
                 //action.CatchExceptionWithLog(ex, $"鎵弿[{input.SN}]寮傚父");
                 action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.Scan.ScanException", input.SN));
             }
@@ -88,42 +80,117 @@
             {
                 if (CurInvItem.IsNullOrEmpty())
                 {
-	                Result<IInventory> result = WMS_ITEM_Biz.WmsItem.Get(input.SN, input.AuthOption, true);
+                    //瑙f瀽鏉$爜
+                    Result<IInventory> result = WMS_ITEM_Biz.WmsItem.Get(input.SN, input.AuthOption, true);
 	                if (!result.IsSuccessed)
 	                {
 	                    action.IsSuccessed = false;
 	                    action.LocaleMsg = result.LocaleMsg;
 	                    return action;
 	                }
-	                CurInvItem = result.Data as Inventory;
+	                var inv = result.Data as Inventory;
 
                     //楠岃瘉鏉$爜鏄惁姝g‘
-                    if (new[] { WMS_ITEM.STATUSs.InStore, WMS_ITEM.STATUSs.Loaded, WMS_ITEM.STATUSs.UseUp }.Contains(CurInvItem.Status))
+                    if (new[] { WMS_ITEM.STATUSs.InStore, WMS_ITEM.STATUSs.Loaded, WMS_ITEM.STATUSs.UseUp }.Contains(inv.Status))
                     {
                         action.IsSuccessed = false;
                         //action.LocaleMsg = Biz.L("鐘舵�乕{0}]寮傚父锛岃閲嶆柊鎵弿");
-                        action.LocaleMsg = Biz.L("WMS.Default.ScanItem.StatusException", string.Join(',', CurInvItem.StatusList.Select(q => q.GetDesc())));
+                        action.LocaleMsg = Biz.L("WMS.Default.ScanItem.StatusException", string.Join(',', inv.StatusList.Select(q => q.GetDesc())));
                         return action;
                     }
                     //鐗╂枡楠岃瘉
-                    if (CurInvItem.ItemInfo.IsNullOrEmpty() || CurInvItem.ItemInfo.IS_ACTIVE == "N")
+                    if (inv.ItemInfo.IsNullOrEmpty() || inv.ItemInfo.IS_ACTIVE == "N")
                     {
                         action.IsSuccessed = false;
                         //action.LocaleMsg = Biz.L("鐗╂枡缂栫爜[{0}]涓嶅瓨鍦ㄦ垨鑰呰鐗╂枡鏈惎鐢�");
-                        action.LocaleMsg = Biz.L("WMS.Default.ScanItem.ItemCodeNotExistsOrNotActive", CurInvItem.ItemInfo.ITEM_CODE.IsNullOrEmpty(CurInvItem.Barcode.ItemCode));
+                        action.LocaleMsg = Biz.L("WMS.Default.ScanItem.ItemCodeNotExistsOrNotActive", inv.ItemInfo?.ITEM_CODE.IsNullOrEmpty(inv.Barcode.ItemCode));
                         return action;
                     }
 
+                    if (inv.Items.Count == 0)
+                    {
+                        List<WMS_ITEM_HIS> ItemHistorys = new List<WMS_ITEM_HIS>();
+                        WMS_ITEM Item;
+                        WMS_ITEM_PKG ItemPkgs;
+
+                        Item = new()
+                        {
+                            SN = inv.Barcode.SN,
+                            ITEM_CODE = inv.Barcode.ItemCode,
+                            AUTH_ORG = input.AuthOption.CurOrg,
+                            STATUS = WMS_ITEM.STATUSs.WaitIn.GetValue(),
+                            QTY = inv.Barcode.Qty.ToDouble(),
+                            PROD_DATE = inv.Barcode.DateCode.ToDateTime(),
+                            ERP_WH = CurScanShelf.WarehouseCode,
+                            UNIT = inv.Barcode.Unit,
+                        };
+
+                        WMS_ITEM_HIS his = new(Item, $"鏍囧噯涓婃灦鍏ュ簱");
+                        ItemHistorys.Add(his);
+                        ItemPkgs = new()
+                        {
+                            SN = inv.Barcode.SN,
+                            AUTH_ORG = input.AuthOption.CurOrg,
+                            ITEM_CODE = inv.Barcode.ItemCode,
+                            QTY = inv.Barcode.Qty.ToDouble(),
+                            ERP_WH = CurScanShelf.WarehouseCode,
+                            UNIT = inv.Barcode.Unit,
+                        };
+
+                        var noExt = inv.Items.Where(q => !inv.ItemsExt.Any(s => s.SN == q.SN)).ToList();
+                        //鎵╁睍琛ㄤ笉瀛樺湪鏃舵柊寤�
+                        foreach (var item in noExt)
+                        {
+                            inv.ItemsExt.Add(new()
+                            {
+                                SN = item.SN,
+                                META_SN = inv.Barcode.MetaSn,
+                                QR_CODE = inv.Barcode.MetaSn
+                            });
+                        }
+
+                        inv.Items.Add(Item);
+                        inv.History.Add(his);
+                        inv.Packages.Add(ItemPkgs);
+                    }
+                    //闆呰揪涓嶄粠鏉$爜涓婃洿鏂版暟閲�
+                    //else if (inv.Items.Count == 1)
+                    //{
+                    //    inv.Items.First().QTY = inv.Barcode.Qty.ToDouble();
+                    //    inv.Items.First().ERP_WH = CurScanShelf.WarehouseCode;
+                    //    inv.Items.First().AUTH_ORG = input.AuthOption.CurOrg;
+
+                    //    inv.Packages.First().QTY = inv.Barcode.Qty.ToDouble();
+                    //    inv.Packages.First().ERP_WH = CurScanShelf.WarehouseCode;
+                    //    inv.Packages.First().AUTH_ORG = input.AuthOption.CurOrg;
+                    //}
+                    //濡傛灉鎵弿澶栫鐨勪笉鑳芥洿鏂版暟閲�
+                    else
+                    {
+                        foreach (var item in inv.Items)
+                        {
+                            item.ERP_WH = CurScanShelf.WarehouseCode;
+                            item.AUTH_ORG = input.AuthOption.CurOrg;
+                        }
+                        foreach (var item in inv.Packages)
+                        {
+                            item.ERP_WH = CurScanShelf.WarehouseCode;
+                            item.AUTH_ORG = input.AuthOption.CurOrg;
+                        }
+                    }
+                    CurInvItem = inv;
+
                     //妫�鏌ョ墿鏂欐暟閲忥紝濡傛灉娌℃湁鍒欐煡璇㈤泤杈炬潯鐮佷富妗o紝鎶婃暟閲忚繑鍥炲墠绔‘璁�
-                    if (CurInvItem.Items.Any(q => q.QTY <= 0))
+                    //if (CurInvItem.Items.Any(q => q.QTY <= 0))
                     {
                         var qtyList = Biz.DataSource["YadaU9C"].Client.Queryable<mes_MaterialBarCode>().Where(q => CurInvItem.Items.Select(q => q.SN).Contains(q.Code)).ToList();
                         foreach (var qty in qtyList)
                         {
                             var item = CurInvItem.Items.First(q => q.SN == qty.Code);
                             item.QTY = qty.WhQty;
+                            item.SUPP_LOTNO = qty.Segment7;
                         }
-                        action.Data.Data = CurInvItem.Items.ToDictionary(k => k.SN, v => v.QTY);
+                        action.Data.Data = CurInvItem.Items.Select(q => new { q.SN, q.QTY });
                         action.Data.Command = Command = "ComfirmQty";
                         //action.LocaleMsg = Biz.L("璇风‘璁ゆ潯鐮乕{0}]鐨勬暟閲忔槸鍚︽纭�");
                         action.LocaleMsg = Biz.L("WMS.Default.ScanItem.ComfirmQty", input.SN);
@@ -134,11 +201,11 @@
                 //鏇存柊宸茬‘璁ょ墿鏂欐暟閲�
                 if (Command == "ComfirmQty")
                 {
-                    var qtyList = (input.Data ?? "").JsonToObject<Dictionary<string, decimal>>() ?? new Dictionary<string, decimal>();
-                    if (qtyList.Any(q => q.Value <= 0))
+                    var qtyList = (input.Data ?? "").JsonToObject<List<WMS_ITEM>>() ?? new List<WMS_ITEM>();
+                    if (!qtyList.Any() || qtyList.Any(q => q.QTY <= 0))
                     {
                         action.IsSuccessed = false;
-                        action.Data.Data = CurInvItem.Items.ToDictionary(k => k.SN, v => v.QTY);
+                        action.Data.Data = CurInvItem.Items.Select(q => new { q.SN, q.QTY });
                         action.Data.Command = Command = "ComfirmQty";
                         //action.LocaleMsg = Biz.L("鏁伴噺涓嶈兘灏忎簬绛変簬闆讹紝璇烽噸鏂扮‘璁ゆ潯鐮乕{0}]鐨勬暟閲�");
                         action.LocaleMsg = Biz.L("WMS.Default.ScanItem.ReComfirmQty", input.SN); 
@@ -148,81 +215,14 @@
                     {
 	                    foreach (var qty in qtyList)
 	                    {
-	                        var item = CurInvItem.Items.First(q => q.SN == qty.Key);
-	                        item.QTY = qty.Value;
-	                    }
+	                        var item = CurInvItem.Items.First(q => q.SN == qty.SN);
+	                        item.QTY = qty.QTY;
+                            var pkg = CurInvItem.Packages.First(q => q.SN == qty.SN);
+                            pkg.QTY = qty.QTY;
+                        }
+                        CurInvItem.UpdatePkgQty();
+
                         Command = "Normal";
-                    }
-                }
-
-                if (CurInvItem.Items.Count == 0)
-                {
-                    List<WMS_ITEM_HIS> ItemHistorys = new List<WMS_ITEM_HIS>();
-                    WMS_ITEM Item;
-                    WMS_ITEM_PKG ItemPkgs;
-
-                    Item = new()
-                    {
-                        SN = CurInvItem.Barcode.SN,
-                        ITEM_CODE = CurInvItem.Barcode.ItemCode,
-                        AUTH_ORG = input.AuthOption.CurOrg,
-                        STATUS = WMS_ITEM.STATUSs.WaitIn.GetValue(),
-                        QTY = CurInvItem.Barcode.Qty.ToDecimal(),
-                        PROD_DATE = CurInvItem.Barcode.DateCode.ToDateTime(),
-                        ERP_WH = CurScanShelf.WarehouseCode,
-                        UNIT = CurInvItem.Barcode.Unit,
-                    };
-
-                    WMS_ITEM_HIS his = new(Item, $"鏍囧噯涓婃灦鍏ュ簱");
-                    ItemHistorys.Add(his);
-                    ItemPkgs = new()
-                    {
-                        SN = CurInvItem.Barcode.SN,
-                        AUTH_ORG = input.AuthOption.CurOrg,
-                        ITEM_CODE = CurInvItem.Barcode.ItemCode,
-                        QTY = CurInvItem.Barcode.Qty.ToDecimal(),
-                        ERP_WH = CurScanShelf.WarehouseCode,
-                        UNIT = CurInvItem.Barcode.Unit,
-                    };
-
-                    var noExt = CurInvItem.Items.Where(q => !CurInvItem.ItemsExt.Any(s => s.SN == q.SN)).ToList();
-                    //鎵╁睍琛ㄤ笉瀛樺湪鏃舵柊寤�
-                    foreach (var item in noExt)
-                    {
-                        CurInvItem.ItemsExt.Add(new()
-                        {
-                            SN = item.SN,
-                            META_SN = CurInvItem.Barcode.MetaSn,
-                            QR_CODE = CurInvItem.Barcode.MetaSn
-                        });
-                    }
-
-                    CurInvItem.Items.Add(Item);
-                    CurInvItem.History.Add(his);
-                    CurInvItem.Packages.Add(ItemPkgs);
-                }
-                else if (CurInvItem.Items.Count == 1)
-                {
-                    CurInvItem.Items.First().QTY = CurInvItem.Barcode.Qty.ToDecimal();
-                    CurInvItem.Items.First().ERP_WH = CurScanShelf.WarehouseCode;
-                    CurInvItem.Items.First().AUTH_ORG = input.AuthOption.CurOrg;
-
-                    CurInvItem.Packages.First().QTY = CurInvItem.Barcode.Qty.ToDecimal();
-                    CurInvItem.Packages.First().ERP_WH = CurScanShelf.WarehouseCode;
-                    CurInvItem.Packages.First().AUTH_ORG = input.AuthOption.CurOrg;
-                }
-                //濡傛灉鎵弿澶栫鐨勪笉鑳芥洿鏂版暟閲�
-                else
-                {
-                    foreach (var item in CurInvItem.Items)
-                    {
-                        item.ERP_WH = CurScanShelf.WarehouseCode;
-                        item.AUTH_ORG = input.AuthOption.CurOrg;
-                    }
-                    foreach (var item in CurInvItem.Packages)
-                    {
-                        item.ERP_WH = CurScanShelf.WarehouseCode;
-                        item.AUTH_ORG = input.AuthOption.CurOrg;
                     }
                 }
 
@@ -247,7 +247,7 @@
                         action.LocaleMsg = Biz.L("WMS.Default.ScanItem.LocationNotExistsInShelf", CurScanShelf.Shelf.SHELF_CODE, reaultShelf.ledAddr);
                         return action;
                     }
-                    var locationData = Biz.Db.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == nLocation.ID).First();
+                    var locationData = MainDB.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == nLocation.ID).First();
                     if (!locationData.IsNullOrEmpty())
                     {
                         action.IsSuccessed = false;
@@ -267,7 +267,7 @@
                         return action;
                     }
 
-                    nLocation = await Biz.Db.Queryable<WMS_LOCATION>().Where(t => t.LOCATION_CODE == CurScanShelf.LocationCode && t.AUTH_ORG == OrgCode).FirstAsync();
+                    nLocation = await MainDB.Queryable<WMS_LOCATION>().Where(t => t.LOCATION_CODE == CurScanShelf.LocationCode && t.AUTH_ORG == OrgCode).FirstAsync();
                 }
 
                 //鍒ゆ柇鍌ㄤ綅鏄惁鍗曟斁
@@ -276,62 +276,32 @@
                     action.IsSuccessed = false;
                     //action.LocaleMsg = Biz.L("鍌ㄤ綅[{0}]鍙兘瀛樻斁涓�涓墿鏂�");
                     action.LocaleMsg = Biz.L("WMS.Default.ScanItem.LocationSingleFailure", nLocation.LOCATION_CODE);
+                    ResetScan();
                     return action;
                 }
 
-                //鎵ц涓婃灦
+                //鎵ц涓婃灦鏁版嵁澶勭悊
                 foreach (var item in CurInvItem.Items)
                 {
                     item.TRANS_CODE = "In_Default";
                     item.TRANS_NO = $"In_Default_{DateTime.Now:yyyyMMdd}";
                 }
-                Result<PutOnInfo> putonResult = WMS_ITEM_Biz.WmsItem.PutOn(CurInvItem, input.AuthOption, nLocation.LOCATION_CODE);
+                Result putonResult = PutOn(input.AuthOption, nLocation.LOCATION_CODE);
                 if (!putonResult.IsSuccessed)
                 {
                     action.IsSuccessed = false;
                     action.LocaleMsg = putonResult.LocaleMsg;
+                    ResetScan();
                     return action;
                 }
-                PutOnInfo putOnInfo = putonResult.Data;
 
-                //淇濆瓨鍒版暟鎹簱
-                var db = Business.Biz.Db;
-                var dbTran = db.UseTran(() =>
-                {
-                    //鍏ュ簱
-                    db.Storageable(putOnInfo.Items, UserCode).ExecuteCommand();
-                    db.Storageable(putOnInfo.Packages, UserCode).ExecuteCommand();
-                    db.Insertable(putOnInfo.History, UserCode).ExecuteCommand();
-                    var x = db.Storageable(putOnInfo.ItemsExt, UserCode).ToStorage();
-                    x.AsInsertable.ExecuteCommand();//涓嶅瓨鍦ㄦ彃鍏�
-                    x.AsUpdateable.ExecuteCommand();//瀛樺湪鏇存柊
-                });
-                if (!dbTran.IsSuccess)
-                {
-                    Logger.Default.Fatal(dbTran.ErrorException, "Database transaction save exception");
-                    throw dbTran.ErrorException;
-                }
-                // 杩斿洖鍏朵粬鍏ュ簱瀵硅薄
-                action.Data.Data = new DefaultInStoreOutput
-                {
-                    Barcode = CurInvItem.SN,
-                    MaterialCode = CurInvItem.ItemInfo.ITEM_CODE,
-                    MaterialName = CurInvItem.ItemInfo.ITEM_NAME,
-                    CurrentQty = CurInvItem.Items[0].QTY,
-                    Unit = CurInvItem.Items[0].UNIT,
-                    DateCode = CurInvItem.Items[0].PROD_DATE,
-                    WarehouseCode = putOnInfo.Warehouse.WH_CODE,
-                    RegionCode = putOnInfo.Region.REGION_CODE,
-                    ShelfCode = putOnInfo.Shelf.SHELF_CODE,
-                    LocationCode = putOnInfo.Location.LOCATION_CODE,
-                };
-                //action.LocaleMsg = Biz.L($"鎵弿鏉$爜[{0}]涓婃灦鍒板偍浣峓{1}]鎴愬姛");
-                action.LocaleMsg = Biz.L("WMS.Default.ScanItem.PutOnSucceeded", CurInvItem.SN, putOnInfo.Location.LOCATION_CODE);
+                //瀹屾垚鎵�鏈夊鐞嗗悗浣跨敤浜嬪姟淇濆瓨鏁版嵁
+                action = DoIfFinish(action, input.Locale);
             }
             catch (Exception ex)
             {
                 //鍙栨秷褰撳墠鎿嶄綔
-                ResetInfo();
+                ResetScan();
                 //action.CatchExceptionWithLog(ex, $"鎵弿鏉$爜[{input.SN}]澶嶆牳寮傚父");
                 action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.ScanItem.ScanException", input.SN));
             }
@@ -341,9 +311,9 @@
         /// <summary>
         /// 鎵弿璐ф灦鎴栬�呭偍浣�
         /// </summary>
-        public async Task<ApiAction<ScanOutput>> ScanShelf(string Code)
+        public async Task<ApiAction<ScanOutput>> ScanShelf(string Code, V_WH_UNIT whUnit)
         {
-            var action = new ApiAction<ScanOutput>();
+            var action = new ApiAction<ScanOutput>(new ScanOutput() { Command = Command });
             try
             {
                 if (Code.IsNullOrEmpty())
@@ -357,10 +327,10 @@
                 CurScanShelf = new ScanShelfInfo();
 
                 // 鏌ヨ璐ф灦淇℃伅
-                var whUnit = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.SHELF_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();
+                whUnit = whUnit.IsNullOrEmpty(await MainDB.Queryable<V_WH_UNIT>().Where(t => (t.SHELF_CODE.ToUpper() == Code || t.LOCATION_CODE.ToUpper() == Code) && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync());
 
                 // 鎵弿璐ф灦浠g爜锛屼笖涓烘櫤鑳借揣鏋�
-                if (whUnit != null && whUnit.SHELF_TYPE == WMS_SHELF.SHELF_TYPEs.Smart.GetValue())
+                if (!whUnit.IsNullOrEmpty() && whUnit.SHELF_CODE  == Code)
                 {
                     CurScanShelf.Shelf = whUnit.Shelf;
                     CurScanShelf.WarehouseCode = whUnit.WH_CODE;
@@ -370,26 +340,26 @@
                     CurScanShelf.IsSmartRack = true;
                 }
                 // 鎵弿搴撲綅浠g爜
-                else
+                else if (!whUnit.IsNullOrEmpty() && whUnit.LOCATION_CODE == Code)
                 {
-                    var nLocation = await Biz.Db.Queryable<V_WH_UNIT>().Where(t => t.LOCATION_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();
-                    if (nLocation == null)
-                    {
-                        action.IsSuccessed = false;
-                        //action.LocaleMsg = Biz.L("鍌ㄤ綅[{0}]涓嶅瓨鍦�");
-                        action.LocaleMsg = Biz.L("WMS.Default.ScanShelf.LocationNotExist", Code);
-                        return action;
-                    }
-                    if (nLocation.IS_ACTIVE == "N")
+                    //var nLocation = await MainDB.Queryable<V_WH_UNIT>().Where(t => t.LOCATION_CODE.ToUpper() == Code.ToUpper() && t.AUTH_ORG == OrgCode).IncludesAllFirstLayer().FirstAsync();
+                    //if (nLocation == null)
+                    //{
+                    //    action.IsSuccessed = false;
+                    //    //action.LocaleMsg = Biz.L("鍌ㄤ綅[{0}]涓嶅瓨鍦�");
+                    //    action.LocaleMsg = Biz.L("WMS.Default.ScanShelf.LocationNotExist", Code);
+                    //    return action;
+                    //}
+                    if (whUnit.IS_ACTIVE == "N")
                     {
                         action.IsSuccessed = false;
                         //action.LocaleMsg = Biz.L("鎵弿鐨勫偍浣峓{0}]鏈惎鐢�");
                         action.LocaleMsg = Biz.L("WMS.Default.ScanShelf.ShelfOrLocationDisabled", Code);
                         return action;
                     }
-                    if (nLocation.Shelf.IsLightShelf || nLocation.Location.IS_SINGLE == "Y")
+                    if (whUnit.Shelf.IsLightShelf || whUnit.Location.IS_SINGLE == "Y")
                     {
-                        var locationData = Biz.Db.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == nLocation.LOCATION_ID && q.AUTH_ORG == OrgCode).First();
+                        var locationData = MainDB.Queryable<WMS_ITEM>().Where(q => q.LOCATION_ID == whUnit.LOCATION_ID && q.AUTH_ORG == OrgCode).First();
                         if (!locationData.IsNullOrEmpty())
                         {
                             action.IsSuccessed = false;
@@ -398,13 +368,20 @@
                             return action;
                         }
                     }
-                    CurScanShelf.Shelf = nLocation.Shelf;
-                    CurScanShelf.Location = nLocation.Location;
-                    CurScanShelf.WarehouseCode = nLocation.WH_CODE;
-                    CurScanShelf.RegionCode = nLocation.REGION_CODE;
-                    CurScanShelf.ShelfCode = nLocation.SHELF_CODE;
-                    CurScanShelf.LocationCode = nLocation.LOCATION_CODE;
+                    CurScanShelf.Shelf = whUnit.Shelf;
+                    CurScanShelf.Location = whUnit.Location;
+                    CurScanShelf.WarehouseCode = whUnit.WH_CODE;
+                    CurScanShelf.RegionCode = whUnit.REGION_CODE;
+                    CurScanShelf.ShelfCode = whUnit .SHELF_CODE;
+                    CurScanShelf.LocationCode = whUnit.LOCATION_CODE;
                     CurScanShelf.IsSmartRack = false;
+                }
+                else
+                {
+                    action.IsSuccessed = false;
+                    //action.LocaleMsg = Biz.L("璇疯緭鍏ユ垨鎵弿鏈夋晥鐨勮揣鏋�/鍌ㄤ綅鐮�");
+                    action.LocaleMsg = Biz.L("WMS.Default.ScanShelf.ShelfCanNotEmpty");
+                    return action;
                 }
 
                 CurScanShelf.IsScanShelf = true;
@@ -415,10 +392,43 @@
             catch (Exception ex)
             {
                 //鍙栨秷褰撳墠鎿嶄綔
-                ResetInfo();
+                ResetScan();
                 //action.CatchExceptionWithLog(ex, $"鎵弿璐ф灦/鍌ㄤ綅[{0}]寮傚父");
                 action.CatchExceptionWithLog(ex, Biz.L("WMS.Default.ScanShelf.ScanException", Code));
             }
+            return action;
+        }
+
+        /// <summary>
+        /// 瀹屾垚鎵�鏈夊鐞嗗悗浣跨敤浜嬪姟淇濆瓨鏁版嵁
+        /// </summary>
+        /// <param name="action"></param>
+        /// <returns></returns>
+        public ApiAction<ScanOutput> DoIfFinish(ApiAction<ScanOutput> action, string locale)
+        {
+            //淇濆瓨鏁版嵁搴�
+            SaveCommitListToDB();
+
+            // 杩斿洖鏁版嵁
+            action.Data.Data = new DefaultInStoreOutput
+            {
+                Barcode = CurInvItem.SN,
+                MaterialCode = CurInvItem.ItemInfo.ITEM_CODE,
+                MaterialName = CurInvItem.ItemInfo.ITEM_NAME,
+                CurrentQty = CurInvItem.Items[0].QTY,
+                Unit = CurInvItem.Items[0].UNIT,
+                DateCode = CurInvItem.Items[0].PROD_DATE,
+                WarehouseCode = CurInvItem.Warehouse.WH_CODE,
+                RegionCode = CurInvItem.Region.REGION_CODE,
+                ShelfCode = CurInvItem.Shelf.SHELF_CODE,
+                LocationCode = CurInvItem.Location.LOCATION_CODE,
+            };
+
+            //action.LocaleMsg = Biz.L($"鎵弿鏉$爜[{0}]涓婃灦鍒板偍浣峓{1}]鎴愬姛");
+            action.LocaleMsg = Biz.L("WMS.Default.ScanItem.PutOnSucceeded", CurInvItem.SN, CurInvItem.Location.LOCATION_CODE);
+
+            //閲嶇疆鎵爜淇℃伅
+            ResetScanInfo();
             return action;
         }
 
@@ -427,12 +437,20 @@
         /// <summary>
         /// 閲嶇疆褰撳墠鎿嶄綔锛屾湁闇�瑕佸垯閲嶅啓姝ゆ柟娉�
         /// </summary>
-        public override void ResetInfo()
+        public override void ResetScan()
         {
-            base.ResetInfo();
+            base.ResetScan();
+            ResetScanInfo();
+            CurScanShelf = null;
+        }
+
+        /// <summary>
+        /// 閲嶇疆鎵爜淇℃伅
+        /// </summary>
+        public void ResetScanInfo()
+        {
             Command = null;
             CurInvItem = null;
-            CurScanShelf = null;
         }
 
         public override bool Close(bool needSaveHistoryLog = false)

--
Gitblit v1.9.3