From c598e4bf57de2b4703d6c0e4d0905c9159273d26 Mon Sep 17 00:00:00 2001 From: Rodney Chen <rodney.chen@hotmail.com> Date: 星期二, 06 八月 2024 10:16:18 +0800 Subject: [PATCH] 条码增加托盘批量过站逻辑和包装外箱过站逻辑 --- Tiger.Business.MES/WorkAction/Assembly.cs | 153 ++++++++++++++++++++++++++++++++------------------ 1 files changed, 97 insertions(+), 56 deletions(-) diff --git a/Tiger.Business.MES/WorkAction/Assembly.cs b/Tiger.Business.MES/WorkAction/Assembly.cs index a32e6e2..1a7a4fa 100644 --- a/Tiger.Business.MES/WorkAction/Assembly.cs +++ b/Tiger.Business.MES/WorkAction/Assembly.cs @@ -69,6 +69,7 @@ ItemInfo = info, RuleCode = assy.RULE_CODE, LoadQty = assy.QTY, + IsBatchItem = assy.IsBatchItem, }; var bom = Boms.FirstOrDefault(q => q.ITEM_CODE == assy.ITEM_CODE); if (!bom.IsNullOrEmpty()) @@ -104,7 +105,7 @@ { var action = new ApiAction<SubmitOutput>(new SubmitOutput()); - if (input.SN != CurPosition.CurWipSN.SN) + if (!CurPosition.CurWipSNs.Any(w => w.SN == input.SN)) { action = SaveAssembly(input, action); return action; @@ -170,31 +171,65 @@ //楠岃瘉閫氳繃鍒欎繚瀛樹笂鏂欎俊鎭� if (isOK) { - var record = new MES_WIP_ASSY() + //鎵规鐗╂枡鍒欏彧璁板綍涓�娆★紝闈炴壒娆$墿鏂欏垯瑕佹寜涓暟楠岃瘉鏁伴噺 + if (item.IsBatchItem) { - AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG, - AUTH_PROD = CurPosition.CurLine.LINE_CODE, - SN = input.SN, - PROD_SN = CurPosition.CurWipSN.SN, - ITEM_CODE = item.ItemInfo.ITEM_CODE, - QTY = 1, - UNIT = item.ItemInfo.UNIT, - WORK_ORDER = CurPosition.CurWipSN.WORK_ORDER, - BATCH_NO = CurPosition.CurWipSN.BATCH_NO, - ROT_CODE = CurPosition.CurWipSN.ROT_CODE, - NODE_ID = CurPosition.CurWipSN.NODE_ID, - NODE_NAME = CurPosition.CurWipSN.NODE_NAME, - FTY_CODE = CurPosition.CurWipSN.FTY_CODE, - WS_CODE = CurPosition.CurWipSN.WS_CODE, - LINE_CODE = CurPosition.CurWipSN.LINE_CODE, - POST_CODE = CurPosition.CurWipSN.POST_CODE, - OPER_CODE = CurPosition.CurWipSN.OPER_CODE, - SEGMENT = CurPosition.CurWipSN.SEGMENT, - }; - item.Records.Add(record); - if (item.Records.Sum(q => q.QTY) >= item.LoadQty) + foreach (var wipSn in CurPosition.CurWipSNs) + { + var record = new MES_WIP_ASSY() + { + AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG, + AUTH_PROD = CurPosition.CurLine.LINE_CODE, + SN = input.SN, + PROD_SN = wipSn.SN, + ITEM_CODE = item.ItemInfo.ITEM_CODE, + QTY = 1, + UNIT = item.ItemInfo.UNIT, + WORK_ORDER = wipSn.WORK_ORDER, + BATCH_NO = wipSn.BATCH_NO, + ROT_CODE = wipSn.ROT_CODE, + NODE_ID = wipSn.NODE_ID, + NODE_NAME = wipSn.NODE_NAME, + FTY_CODE = wipSn.FTY_CODE, + WS_CODE = wipSn.WS_CODE, + LINE_CODE = wipSn.LINE_CODE, + POST_CODE = wipSn.POST_CODE, + OPER_CODE = wipSn.OPER_CODE, + SEGMENT = wipSn.SEGMENT, + }; + item.Records.Add(record); + } + item.IsFinished = true; + } + else { - item.IsFinished = true; + var record = new MES_WIP_ASSY() + { + AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG, + AUTH_PROD = CurPosition.CurLine.LINE_CODE, + SN = input.SN, + PROD_SN = CurPosition.CurSN, + ITEM_CODE = item.ItemInfo.ITEM_CODE, + QTY = 1, + UNIT = item.ItemInfo.UNIT, + WORK_ORDER = CurPosition.CurWipSNs.First().WORK_ORDER, + BATCH_NO = CurPosition.CurWipSNs.First().BATCH_NO, + ROT_CODE = CurPosition.CurWipSNs.First().ROT_CODE, + NODE_ID = CurPosition.CurWipSNs.First().NODE_ID, + NODE_NAME = CurPosition.CurWipSNs.First().NODE_NAME, + FTY_CODE = CurPosition.CurWipSNs.First().FTY_CODE, + WS_CODE = CurPosition.CurWipSNs.First().WS_CODE, + LINE_CODE = CurPosition.CurWipSNs.First().LINE_CODE, + POST_CODE = CurPosition.CurWipSNs.First().POST_CODE, + OPER_CODE = CurPosition.CurWipSNs.First().OPER_CODE, + SEGMENT = CurPosition.CurWipSNs.First().SEGMENT, + }; + item.Records.Add(record); + + if (item.Records.Sum(q => q.QTY) >= item.LoadQty * CurPosition.CurWipSNs.Count) + { + item.IsFinished = true; + } } action.IsSuccessed = true; @@ -235,38 +270,44 @@ var action = new ApiAction<SubmitOutput>(new SubmitOutput()); //璁板綍琛屼负鎿嶄綔璁板綍 - var wipAct = new MES_WIP_ACT() + var wipActs = new List<MES_WIP_ACT>(); + foreach (var wipSn in CurPosition.CurWipSNs) { - AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG, - AUTH_PROD = CurPosition.CurLine.LINE_CODE, - HIS_ID = CurPosition.CurWipSNHis.ID, - SN = CurPosition.CurWipSN.SN, - STATUS = CurPosition.CurWipSN.STATUS, - ITEM_CODE = CurPosition.CurWipSN.ITEM_CODE, - WORK_ORDER = CurPosition.CurWipSN.WORK_ORDER, - BATCH_NO = CurPosition.CurWipSN.BATCH_NO, - ROT_CODE = CurPosition.CurWipSN.ROT_CODE, - NODE_ID = CurPosition.CurWipSN.NODE_ID, - NODE_NAME = CurPosition.CurWipSN.NODE_NAME, - ACT_ID = NodeAct.ID, - ACT_NAME = NodeAct.ACT_NAME, - FTY_CODE = CurPosition.CurWipSN.FTY_CODE, - WS_CODE = CurPosition.CurWipSN.WS_CODE, - LINE_CODE = CurPosition.CurWipSN.LINE_CODE, - POST_CODE = CurPosition.CurWipSN.POST_CODE, - OPER_CODE = CurPosition.CurWipSN.OPER_CODE, - SEGMENT = CurPosition.CurWipSN.SEGMENT, - TRAY_SN = CurPosition.CurWipSN.TRAY_SN, - OPERATION_TIME = DateTime.Now, - SFTS_CODE = CurPosition.CurWipSN.SFTS_CODE, - SFT_CODE = CurPosition.CurWipSN.SFT_CODE, - PRD_CODE = CurPosition.CurWipSN.PRD_CODE, - ACT_TYPE = NodeAct.ACT_TYPE, - ACT_SN = CurPosition.CurWipSN.SN, - ACT_VALUE_1 = CurAssembly.ToJson(), - ACT_RESULT = "Y", - TRACE_INFO = $"浠ヤ笅鐗╂枡涓婃枡瀹屾垚锛歿string.Join(",", CurAssembly.Items.Select(q => $"{q.ItemInfo.ITEM_NAME}({q.ItemInfo.ITEM_CODE})"))}", - }; + var wipAct = new MES_WIP_ACT() + { + AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG, + AUTH_PROD = CurPosition.CurLine.LINE_CODE, + HIS_ID = CurPosition.CurWipSNHiss.First(q => q.SN == wipSn.SN).ID, + SN = wipSn.SN, + STATUS = wipSn.STATUS, + ITEM_CODE = wipSn.ITEM_CODE, + WORK_ORDER = wipSn.WORK_ORDER, + BATCH_NO = wipSn.BATCH_NO, + ROT_CODE = wipSn.ROT_CODE, + NODE_ID = wipSn.NODE_ID, + NODE_NAME = wipSn.NODE_NAME, + ACT_ID = NodeAct.ID, + ACT_NAME = NodeAct.ACT_NAME, + FTY_CODE = wipSn.FTY_CODE, + WS_CODE = wipSn.WS_CODE, + LINE_CODE = wipSn.LINE_CODE, + POST_CODE = wipSn.POST_CODE, + OPER_CODE = wipSn.OPER_CODE, + SEGMENT = wipSn.SEGMENT, + TRAY_SN = wipSn.TRAY_SN, + OPERATION_TIME = DateTime.Now, + SFTS_CODE = wipSn.SFTS_CODE, + SFT_CODE = wipSn.SFT_CODE, + PRD_CODE = wipSn.PRD_CODE, + ACT_TYPE = NodeAct.ACT_TYPE, + ACT_SN = wipSn.SN, + ACT_VALUE_1 = CurAssembly.ToJson(), + ACT_RESULT = "Y", + TRACE_INFO = $"浠ヤ笅鐗╂枡涓婃枡瀹屾垚锛歿string.Join(",", CurAssembly.Items.Select(q => $"{q.ItemInfo.ITEM_NAME}({q.ItemInfo.ITEM_CODE})"))}", + }; + wipActs.Add(wipAct); + } + //鏁寸悊涓婃枡璁板綍 var records = new List<MES_WIP_ASSY>(); foreach (var item in CurAssembly.Items) { @@ -277,7 +318,7 @@ CurStep.DBSubmitAction = () => { var db = CurPosition.GetCommitDB(); - db.Storageable(wipAct, CurPosition.UserCode).ExecuteCommand(); + db.Storageable(wipActs, CurPosition.UserCode).ExecuteCommand(); db.Insertable(records, CurPosition.UserCode).ExecuteCommand(); }; -- Gitblit v1.9.3