From fe4a8ec610b23d33c697dbb76c298ff3b2e31ef1 Mon Sep 17 00:00:00 2001
From: Ben Lin <maobin001@msn.com>
Date: 星期二, 29 四月 2025 01:14:39 +0800
Subject: [PATCH] 来料打印更新

---
 Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs |   84 +++++++++++++++++++++++++++++++++++++----
 1 files changed, 75 insertions(+), 9 deletions(-)

diff --git a/Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs b/Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs
index 4e2370d..8563ffa 100644
--- a/Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs
+++ b/Tiger.Business.WMS/Transaction/Yada/Print_BIZ_U9_ASN.cs
@@ -55,7 +55,32 @@
         {
             var _Sns = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.ORDER_NO == SqlFunc.Subqueryable<BIZ_U9_ASN_DTL>().Where(s => SqlFunc.StartsWith(s.UPDATE_USER, $"GenerateASN_{UserCode}")).Select(s => s.ORDER_NO)).ToList();
             CurSn.AddRange(_Sns);
+            OrderList = MainDB.Queryable<BIZ_U9_ASN_SN>().Where(q => q.RECEIVER == $"{UserCode}_NoSource" && SqlFunc.Subqueryable<BIZ_U9_ASN>().Where(s => s.ORDER_NO == q.ORDER_NO && s.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue()).Any()).Select(q => q.ORDER_NO).ToList();
+        } 
+        
+        /// <summary>
+          ///  鑾峰彇褰撳墠鎵�鏈夊崟鎹俊鎭�
+          /// </summary>
+          /// <returns></returns>
+        public async Task<ApiAction<List<BIZ_U9_ASN>>> GetOrderList()
+        {
+            var action = new ApiAction<List<BIZ_U9_ASN>>();
+            action.Data = await Biz.Db.Queryable<BIZ_U9_ASN>().Where(q => OrderList.Contains(q.ORDER_NO)).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().ToListAsync();
+            if (!action.Data.IsNullOrEmpty())
+            {
+                foreach (var order in action.Data)
+                {
+                    foreach (var dtl in order.Details)
+                    {
+                        dtl.SnList = order.SnList.Where(q => q.LINE_NO == dtl.LINE_NO).OrderByDescending(q => q.STATUS).ToList();
+                        dtl.QTY_COUNTED = dtl.SnList.Where(q => q.STATUS == WMS_ITEM.STATUSs.Counted.GetValue() || q.STATUS == WMS_ITEM.STATUSs.Rejected.GetValue()).Sum(q => q.QTY);
+                    }
+                    order.IsFinished = !order.Details.Where(q => q.STATUS != BIZ_U9_ASN.STATUSs.Finished.GetValue()).Any();
+                }
+            }
+            return action;
         }
+
         /// <summary>
         /// 鎵弿鍏ュ彛
         /// </summary>
@@ -186,7 +211,10 @@
                     action.LocaleMsg = Biz.L($"鎵弿鐨勬潯鐮佺殑ASN鍗昜{AsnSn.ORDER_NO}]鐨勮鍙穂{AsnSn.LINE_NO}]宸茬粡瀛樺湪锛岃鍏堝畬鎴愭湭瀹屾垚鐨勬搷浣�");
                     return action;
                 }
-                CurSn.Add(AsnSn);
+                if (!CurSn.Any(q=>q.SN == AsnSn.SN))
+                {
+                    CurSn.Add(AsnSn);
+                }
                 if (!CurOrder.ORDER_NO.StartsWith("WASN"))
                 {
                     CurOrder.ORDER_NO = $"WASN{DateTime.Now.ToString("yyyyMMddHHmmss")}";
@@ -222,6 +250,10 @@
                     CurReqType = reqType;
                 }
                 var dtl = input.Options["record"].ToString().JsonToObject<BIZ_U9_ASN_DTL>();
+                if (CurReqType == "2")
+                {
+                    CurOrder = await MainDB.Queryable<BIZ_U9_ASN>().Where(q => q.ORDER_NO == SqlFunc.Subqueryable<BIZ_U9_ASN_DTL>().Where(s => SqlFunc.StartsWith(s.UPDATE_USER, $"GenerateASN_{UserCode}_Sample")).Select(s => s.ORDER_NO)).Includes(q => q.Details, d => d._ItemInfos).IncludesAllFirstLayer().FirstAsync();
+                }
                 CurOrder = CurOrder??new() { 
                     ORDER_NO= $"WASN{DateTime.Now.ToString("yyyyMMddHHmmss")}",
                     SUPP_CODE = dtl.SUPP_CODE,
@@ -229,15 +261,25 @@
                     PLANARRIVED_DATE = DateTime.Now,
                     AUTH_ORG = OrgCode,
                 };
-                if (!CurOrder.ORDER_NO.IsNullOrEmpty() && CurOrder.ORDER_NO.StartsWith("WASN") && CurOrder.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue())
+                if (MainDB.Queryable<BIZ_U9_ASN_DTL>().Any(q => q.ORDER_NO == CurOrder.ORDER_NO && q.ITEM_CODE == dtl.ITEM_CODE))
                 {
                     action.IsSuccessed = false;
-                    action.LocaleMsg = Biz.L($"宸茬粡鐢熸垚ASN鍗昜{CurOrder.ORDER_NO}]锛岃缁х画涓嬩竴姝ユ搷浣�");
+                    action.LocaleMsg = Biz.L($"鎵綋鍓嶇敓鎴愮殑鍗曞彿[{CurOrder.ORDER_NO}]鍙婄墿鏂欑紪鐮乕{dtl.ITEM_CODE}]宸茬粡瀛樺湪锛岃鍏堝畬鎴愭湭瀹屾垚鐨勬搷浣�");
                     return action;
                 }
+                //濡傛灉娌℃湁渚涘簲鍟嗗悕绉帮紝鍒欎粠渚涘簲鍟嗚〃涓幏鍙�
+                if (CurOrder.SUPP_NAME.IsNullOrEmpty()) {
+                    CurOrder.SUPP_NAME = MainDB.Queryable<BAS_SUPPLIER>().Where(q => q.SUPP_CODE == CurOrder.SUPP_CODE).First()?.SUPP_NAME_CN;
+                }
+                //if (!CurOrder.ORDER_NO.IsNullOrEmpty() && CurOrder.ORDER_NO.StartsWith("WASN") && CurOrder.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue())
+                //{
+                //    action.IsSuccessed = false;
+                //    action.LocaleMsg = Biz.L($"宸茬粡鐢熸垚ASN鍗昜{CurOrder.ORDER_NO}]锛岃缁х画涓嬩竴姝ユ搷浣�");
+                //    return action;
+                //}
 
-                dtl.UPDATE_USER = $"GenerateASN_{UserCode}";
-                dtl.REMARK = CurSn.Where(q => q.ORDER_NO == dtl.ORDER_NO && q.LINE_NO == dtl.LINE_NO).FirstOrDefault()?.SN;
+                dtl.UPDATE_USER = CurReqType == "2" ? $"GenerateASN_{UserCode}_Sample": $"GenerateASN_{UserCode}";
+                dtl.REMARK = CurReqType == "1"? CurSn.Where(q => q.ORDER_NO == dtl.ORDER_NO && q.LINE_NO == dtl.LINE_NO).FirstOrDefault()?.SN: dtl.REMARK;
                 dtl.ORDER_NO = CurOrder.ORDER_NO;
                 BIZ_U9_ASN Asn = new()
                 {
@@ -260,7 +302,7 @@
                 _dtl.ID = Guid.NewGuid().ToString("N");
                 _dtl.IS_GIFT = reqType == "1" ? "Y" : "N";
                 _dtl.AUTH_ORG = CurOrder.AUTH_ORG;
-                _dtl.LINE_NO = _dtl.LINE_NO ?? "10";
+                _dtl.LINE_NO = _dtl.LINE_NO ?? "0";
                 input.Options["record"] = _dtl.ToJson();
                 var _Asn = Asn.Clone();
                 AddCommitAction("GenerateASN", () =>
@@ -268,10 +310,26 @@
                     //浣跨敤缁熶竴鐨勪簨鍔B瀵硅薄
                     var db = GetCommitDB();
                     //鏁版嵁淇濆瓨閫昏緫
-                    db.Insertable(_Asn, UserCode).ExecuteCommand();
+                    var x = db.Storageable(_Asn).WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW }).ToStorage();
+                    x.AsInsertable.ExecuteCommand();
+                    x.AsUpdateable
+                        .IgnoreColumns(x => x.ID)
+                        .UpdateColumns(q => new { q.ORDER_NO, q.AUTH_ORG, q.DELIVERY_DATE, q.STATUS, q.SUPP_CODE, q.SUPP_NAME, q.PLANARRIVED_DATE, q.ORDER_DATE, q.UPDATE_TIME, q.UPDATE_USER })
+                        .ExecuteCommand();
+
                     var y = db.Storageable(_dtl).WhereColumns(t => new { t.ORDER_NO, t.LINE_NO, t.GHOST_ROW }).ToStorage();
                     y.AsInsertable.ExecuteCommand();
-                    y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.QTY, q.STATUS, q.SUPP_CODE, q.SUPP_LOTNO, q.QTY_PACKING, q.QTY_GIFT, q.IS_GIFT, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();
+                    y.AsUpdateable
+                        .IgnoreColumns(x => x.ID)
+                        .UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.QTY, q.STATUS, q.SUPP_CODE, q.SUPP_LOTNO, q.QTY_PACKING, q.QTY_GIFT, q.IS_GIFT, q.UPDATE_TIME, q.UPDATE_USER })
+                        .ExecuteCommand();
+                    if (reqType == "2")
+                    {
+                        db.Updateable<BIZ_U9_ASN_DTL>()
+                            .SetColumns( it => it.LINE_NO == SqlFunc.Subqueryable<BIZ_U9_ASN_DTL>().Where(q=>q.ORDER_NO == _dtl.ORDER_NO).Select(q => (SqlFunc.AggregateMax(SqlFunc.ToInt32(q.LINE_NO)) + 10).ToString()))
+                            .Where(q=>q.ORDER_NO == _dtl.ORDER_NO && q.LINE_NO == _dtl.LINE_NO)
+                            .ExecuteCommand();
+                    }
                 });
                 action = await Submit(input);
             }
@@ -335,7 +393,7 @@
                         QTY = sn.QTY,
                         LOTNO = barcode.LotNo,
                         CARTON_NO = barcode.SN,
-                        RECEIVER = UserCode,
+                        RECEIVER = $"{UserCode}_NoSource",
                         RECEIVE_DATE = DateTime.Now,
                     };
                     sns.Add(info);
@@ -393,6 +451,14 @@
                     //鏁版嵁淇濆瓨閫昏緫
                     db.Updateable<BIZ_U9_ASN>(UserCode).SetColumns(q => q.STATUS == BIZ_U9_ASN.STATUSs.Counting.GetValue()).Where(q => q.ORDER_NO == dtl.ORDER_NO).ExecuteCommand();
                     db.Storageable(sns, UserCode).ExecuteCommand();
+                    if (reqType == "2")
+                    {
+                        db.Updateable<BIZ_U9_ASN_SN>()
+                            .SetColumns(q => q.LINE_NO == SqlFunc.Subqueryable<BIZ_U9_ASN_DTL>().Where(t1 => t1.ID == dtl.ID).Select(t1 => t1.LINE_NO))
+                            .Where(q=>sns.Select(s=>s.ID).Contains(q.ID))
+                            .ExecuteCommand();
+                    }
+
                     var s = db.Storageable(items, UserCode).WhereColumns(t => new { t.SN, t.GHOST_ROW }).ToStorage();
                     s.AsInsertable.ExecuteCommand();
                     s.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.ITEM_CODE, q.AUTH_ORG, q.STATUS, q.QTY, q.PROD_DATE, q.UNIT, q.TRANS_CODE, q.TRANS_NO, q.TRANS_LINE, q.SUPP_CODE, q.SUPP_LOTNO, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand();

--
Gitblit v1.9.3