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