From 8c998a765b56cba071e4d41f417589f6c0159dce Mon Sep 17 00:00:00 2001
From: Ben Lin <maobin001@msn.com>
Date: 星期二, 19 十一月 2024 20:33:53 +0800
Subject: [PATCH] 获取出货信息更新

---
 Tiger.Business.MES/BIZ/BIZ_MES_WO.cs |  263 +++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 248 insertions(+), 15 deletions(-)

diff --git a/Tiger.Business.MES/BIZ/BIZ_MES_WO.cs b/Tiger.Business.MES/BIZ/BIZ_MES_WO.cs
index f135d86..e494d65 100644
--- a/Tiger.Business.MES/BIZ/BIZ_MES_WO.cs
+++ b/Tiger.Business.MES/BIZ/BIZ_MES_WO.cs
@@ -18,6 +18,8 @@
 using System.Drawing.Printing;
 using System.Net.NetworkInformation;
 using Tiger.Model.MES.Yada;
+using static Microsoft.CodeAnalysis.CSharp.SyntaxTokenParser;
+using Tiger.Model.Minsun;
 
 namespace Tiger.Business.MES
 {
@@ -453,28 +455,143 @@
         }
 
         /// <summary>
-        /// 鑾峰彇閲嶆墦鏍囩淇℃伅
+        /// 鏇存柊琛屼负涓殑绠卞彿
         /// </summary>
-        /// <param name="input"></param>
+        /// <param name="code"></param>
         /// <returns></returns>
-        public async Task<ApiAction<LOG_LABEL_PRINT>> GetRePrintInfo(RePrintInput input)
+        public async Task<ApiAction> SavePrintLabelInAct(string code)
         {
-            var result = new ApiAction<LOG_LABEL_PRINT>();
+            var result = new ApiAction();
             try
             {
-                //鍏堟煡鍑哄伐鍗曟潯鐮佷腑鏄惁瀛樺湪
-                var woSn = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN.Equals(input.Code) || q.FLOW_SN.Equals(input.Code)).FirstAsync();
+                var woSn = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q=>q.SN == code || q.FLOW_SN == code || q.OUTER_SN == code).FirstAsync();
                 if (woSn == null)
                 {
                     result.IsSuccessed = false;
                     result.LocaleMsg = new($"鏉$爜涓嶅瓨鍦紒");
                     return result;
                 }
+                //鍙栧緱鍖呰鍒楄〃
+                var pkgList = Biz.Db.Queryable<MES_WIP_PKG>().Where(q => q.PARENT_SN == woSn.OUTER_SN && q.OPER_CODE == "SpecPackingNode").ToList();
+                if (pkgList.Count == 0)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"鏉$爜涓嶅瓨鍦紒");
+                    return result;
+                }
+                List<MES_WIP_ACT> actlist = new List<MES_WIP_ACT>();
+                //瀹㈡埛鏍囩
+                var wipAct = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.CARTON_SN == woSn.OUTER_SN && q.NODE_ID == pkgList[0].NODE_ID && !SqlFunc.IsNullOrEmpty(q.ACT_VALUE_3)).First();
+                if (!wipAct.IsNullOrEmpty())
+                {
+                    var label = JsonConvert.DeserializeObject<BAS_LABEL_TEMP>(wipAct.ACT_VALUE_3);
+                    var cardNo = label.Variables.Where(q => q.VAR_NAME == "CardQR").FirstOrDefault();
+                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !cardNo.IsNullOrEmpty() && !cardNo.Value.StartsWith(woSn.OUTER_SN))
+                    {
+                        cardNo.Value = $"{woSn.OUTER_SN}{cardNo.Value}";
+                    }
+                    string ACT_VALUE_3 = JsonConvert.SerializeObject(label);
+                    foreach (var pkg in pkgList)
+                    {
+                        var actSn = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.WIP_ID == pkg.WIP_ID && q.NODE_ID == pkg.NODE_ID && q.ACT_VALUE_4 == "Customer").First();
+                        if (!actSn.IsNullOrEmpty())
+                        {
+                            actSn.ACT_VALUE_3 = ACT_VALUE_3;
+                            actlist.Add(actSn);
+                        }
+                    }
+                }
+                //鍏ュ簱鏍囩
+                var wipActInStore = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.SN == woSn.SN && q.NODE_ID == pkgList[0].NODE_ID && !SqlFunc.IsNullOrEmpty(q.ACT_VALUE_3) && q.ACT_VALUE_4 == "InStore").First();
+                if (!wipActInStore.IsNullOrEmpty())
+                {
+                    var label = JsonConvert.DeserializeObject<BAS_LABEL_TEMP>(wipActInStore.ACT_VALUE_3);
+                    var cardNo = label.Variables.Where(q => q.VAR_NAME == "CardQR").FirstOrDefault();
+                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !cardNo.IsNullOrEmpty() && !cardNo.Value.StartsWith(woSn.OUTER_SN))
+                    {
+                        cardNo.Value = $"{woSn.OUTER_SN}{cardNo.Value}";
+                    }
+                    var xh = label.Variables.Where(q => q.VAR_NAME == "XH").FirstOrDefault();
+                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !xh.IsNullOrEmpty())
+                    {
+                        xh.Value = $"{woSn.OUTER_SN}";
+                    }
+                    string ACT_VALUE_3 = JsonConvert.SerializeObject(label);
+                    foreach (var pkg in pkgList)
+                    {
+                        var actSn = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.WIP_ID == pkg.WIP_ID && q.NODE_ID == pkg.NODE_ID && q.ACT_VALUE_4 == "InStore").First();
+                        if (!actSn.IsNullOrEmpty())
+                        {
+                            actSn.ACT_VALUE_3 = ACT_VALUE_3;
+                            actlist.Add(actSn);
+                        }
+                    }
+                }
+                var db = Biz.Db;
+                var dbTran = db.UseTran(() =>
+                {
+                    db.Updateable(actlist).UpdateColumns(q => new { q.ACT_VALUE_3 }).ExecuteCommand();
+                });
+                if (!dbTran.IsSuccess)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"鏇存柊琛屼负鏃ュ織涓殑绠卞彿寮傚父");
+                }
+            }
+            catch (Exception ex)
+            {
+                result.CatchExceptionWithLog(ex, "鏇存柊琛屼负鏃ュ織涓殑绠卞彿寮傚父");
+            }
+            return result;
+        }
 
-                result.Data = await Biz.Db.Queryable<LOG_LABEL_PRINT>()
+        /// <summary>
+        /// 鑾峰彇閲嶆墦鏍囩淇℃伅
+        /// </summary>
+        /// <param name="input"></param>
+        /// <returns></returns>
+        public async Task<ApiAction> GetRePrintInfo(RePrintInput input)
+        {
+            var result = new ApiAction();
+            try
+            {
+                //鍏堟煡鍑哄伐鍗曟潯鐮佷腑鏄惁瀛樺湪
+                var outerSn = input.Code.Split('|')[0];
+                var woSn = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN.Equals(input.Code) || q.FLOW_SN.Equals(input.Code) || q.OUTER_SN == outerSn).FirstAsync();
+                if (woSn == null)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"鏉$爜涓嶅瓨鍦紒");
+                    return result;
+                }
+                var woNode = await Biz.Db.Queryable<MES_WO_NODE>().Where(q => q.WORK_ORDER.Equals(woSn.WORK_ORDER) && q.OPER_CODE== "SpecPackingNode").FirstAsync();
+                if (woNode == null)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"宸ヨ壓璺嚎鑺傜偣[SpecPackingNode-瑁呯]涓嶅瓨鍦�");
+                    return result;
+                }
+                string printParam = "";
+                var labelPrint = await Biz.Db.Queryable<LOG_LABEL_PRINT>()
                     .WhereIF(input.ReqType == 0, q => q.SN.Equals(woSn.SN) || q.SN.Equals(woSn.FLOW_SN)) //鐧界洅鏍囩
-                    .WhereIF(input.ReqType == 1, q => q.SN.Equals(woSn.OUTER_SN)) //绠辨爣绛�
+                    .WhereIF(input.ReqType == 1, q => q.SN.Equals(woSn.OUTER_SN) && q.PRINT_LABEL != "InStoreLabel") //绠辨爣绛�-瀹㈡埛
+                    .WhereIF(input.ReqType == 2, q => q.SN.Equals(woSn.OUTER_SN) && q.PRINT_LABEL == "InStoreLabel") //绠辨爣绛�-鍏ュ簱
                     .FirstAsync();
+                //濡傛灉鏌ヤ笉鍒板氨鍘昏涓烘棩蹇楁煡
+                if (labelPrint.IsNullOrEmpty() && input.ReqType == 1)
+                {
+                    printParam = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.CARTON_SN.Equals(woSn.OUTER_SN) && q.ACT_VALUE_4 == "Customer").First()?.ACT_VALUE_3 ?? "";
+                }
+                else if (labelPrint.IsNullOrEmpty() && input.ReqType == 2)
+                {
+                    printParam = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.SN.Equals(woSn.SN) && q.ACT_VALUE_4 == "InStore").First()?.ACT_VALUE_3 ?? "";
+                }
+                else
+                {
+                    printParam = labelPrint?.PRINT_PARAM ?? "";
+                }
+                result.Data = printParam;
+                result.LocaleMsg = new($"閲嶆墦鏉$爜[{input.Code}]鐨勬爣绛炬垚鍔�");
             }
             catch (Exception ex)
             {
@@ -488,21 +605,44 @@
         /// </summary>
         /// <param name="wo"></param>
         /// <returns></returns>
-        public async Task<ApiAction> GetShipList(string wo, string orgCode)
+        public async Task<ApiAction<ShippingOutput>> GetShipList(ShippingInput input)
         {
-            var result = new ApiAction();
+            var result = new ApiAction<ShippingOutput>();
             try
             {
                 DbClient db = Biz.DataSource["YadaU9C"].Client;
-                var org = await Biz.Db.Queryable<SYS_ORGANIZATION>().Where(q=>q.ORG_CODE == orgCode).FirstAsync();
-                if (db.Queryable<mes_ShipList>().Any(q => q.MoDoc.Equals(wo) && SqlFunc.DateIsSame(q.BusinessDate, DateTime.Now) && q.Status == 2 && q.Org == org.ID.ToInt64()))
+                var org = await Biz.Db.Queryable<SYS_ORGANIZATION>().Where(q => q.ORG_CODE == input.orgCode).FirstAsync();
+                string wo = input.wo;
+                if (!input.SN.IsNullOrEmpty() && input.wo.IsNullOrEmpty()) {
+                    var woSn = Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN == input.SN || q.FLOW_SN == input.SN).First();
+                    if (!woSn.IsNullOrEmpty()) {
+                        wo = woSn.WORK_ORDER;
+                    }
+                }
+                var ship = db.Queryable<mes_ShipList>().Where(q => q.MoDoc.Equals(wo) && q.Org == org.ID.ToInt64()).First();
+                if (!ship.IsNullOrEmpty())
                 {
-                    result.Data = "Customer";
+                    result.Data = ship.BusinessDate.Date == DateTime.Now.Date ? new()
+                    {
+                        ShipDoc = ship.ShipDoc,
+                        ShippingQty = ship.ShipQty,
+                        Tag = "Customer"
+                    } : new()
+                    {
+                        ShipDoc = ship.ShipDoc,
+                        ShippingQty = ship.ShipQty,
+                        Tag = "InStoreLabel"
+                    };
+                    result.LocaleMsg = new($"鍑鸿揣淇℃伅瀛樺湪锛�");
                 }
                 else
                 {
-                    result.LocaleMsg = new($"鍑鸿揣淇℃伅瀛樺湪锛�");
-                    result.Data = "InStore";
+                    result.Data = new()
+                    {
+                        ShipDoc = "",
+                        ShippingQty = 0,
+                        Tag = "InStoreLabel"
+                    };
                 }
             }
             catch (Exception ex)
@@ -511,5 +651,98 @@
             }
             return result;
         }
+
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="SN"></param>
+        /// <param name="user"></param>
+        /// <returns></returns>
+        public async Task<ApiAction> UnbindWipSnFromWO(UnbindWipSnInput input)
+        {
+            var result = new ApiAction();
+            try
+            {
+                var cartonSn = input.SN.Split('|')[0];
+                var wipList = await Biz.Db.Queryable<MES_WIP_DATA>().Where(q => q.SN.Equals(input.SN) || q.FLOW_SN.Equals(input.SN) || q.CARTON_SN == cartonSn).ToListAsync();
+                if (wipList.Count == 0)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"瑙g粦鐨勬潯鐮佷笉瀛樺湪褰撳墠鎿嶄綔琛ㄤ腑锛�");
+                    return result;
+                }
+                var wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == wipList[0].WORK_ORDER).FirstAsync();
+                result = WorkBatch.UnbindWipSnFromWO(wo, wipList, input.user);
+                if (result.IsSuccessed)
+                {
+                    var newList = await Biz.Db.Queryable<MES_WIP_PKG>().Where(q => q.WORK_ORDER == wo.ORDER_NO && q.BATCH_NO == wipList[0].BATCH_NO && SqlFunc.IsNullOrEmpty(q.PARENT_SN) && q.QTY > 0).ToListAsync();
+                    result.Data = newList;
+                }
+            }
+            catch (Exception ex)
+            {
+                result.CatchExceptionWithLog(ex, "瑙g粦鏉$爜寮傚父");
+            }
+            return result;
+        }
+
+        /// <summary>
+        /// 鐢熸垚鍏ュ簱鑾峰彇鏉$爜宸ュ崟淇℃伅鍙婂寘瑁呬俊鎭�
+        /// </summary>
+        /// <param name="code"></param>
+        /// <returns></returns>
+        public async Task<ApiAction<InStoreInfo>> GetErpProdInBth(string code)
+        {
+            var result = new ApiAction<InStoreInfo>();
+            try
+            {
+                //寰楀埌宸ュ崟鏉$爜璁板綍
+                var woSns = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.OUTER_SN == code).ToListAsync();
+                if (woSns.Count == 0)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"鏉$爜涓嶅瓨鍦紒");
+                    return result;
+                }
+                var wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == woSns[0].WORK_ORDER ).IncludesAllFirstLayer().FirstAsync();
+                if (wo == null)
+                {
+                    result.IsSuccessed = false;
+                    result.LocaleMsg = new($"鏉$爜瀵瑰簲鐨勫伐鍗曚笉瀛樺湪");
+                    return result;
+                }
+                InStoreInfo inStoreInfo = new() {
+                    ErpProdInBth= new() { 
+                        WORK_ORDER = wo.ORDER_NO,
+                        BATCH_NO = woSns[0].BATCH_NO,
+                        ITEM_CODE = wo.ITEM_CODE,
+                        ITEM_NAME = wo.ItemInfo?.ITEM_NAME,
+                        SCAN_QTY = woSns.Count
+                    },
+                    ProdInBatch = new()
+                    {
+                        WORK_ORDER = wo.ORDER_NO,
+                        BATCH_NO = woSns[0].BATCH_NO,
+                        ITEM_CODE = wo.ITEM_CODE,
+                        ITEM_NAME = wo.ItemInfo?.ITEM_NAME,
+                        PLAN_QTY = wo.PLAN_QTY,
+                        SCAN_QTY = woSns.Count
+                    },
+                    InStoreScanInfo = new() { 
+                        SN = code,
+                        WORK_ORDER = wo.ORDER_NO,
+                        BATCH_NO = woSns[0].BATCH_NO,
+                        SCAN_QTY = woSns.Count
+                    }
+                };
+                result.Data = inStoreInfo;
+                result.LocaleMsg = new($"鑾峰彇鏉$爜[{code}]宸ュ崟淇℃伅鍙婂寘瑁呬俊鎭垚鍔�");
+            }
+            catch (Exception ex)
+            {
+                result.CatchExceptionWithLog(ex, $"鑾峰彇鏉$爜[{code}]宸ュ崟淇℃伅鍙婂寘瑁呬俊鎭紓甯�");
+            }
+            return result;
+        }
     }
 }

--
Gitblit v1.9.3