服务端的TigerApi 框架，基于.NET6 2024 版本
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Rodney Chen
2024-12-19 eb0ad83719de660e5c4f7676aea4710625b6bd51 
 Tiger.Business.MES/Common/WorkBatch.cs


@@ -10,7 +10,6 @@


using Tiger.IBusiness;


using Tiger.Model.Entitys.MES.Position;


using Tiger.Business.MES;


using static Microsoft.CodeAnalysis.CSharp.SyntaxTokenParser;


using Org.BouncyCastle.Ocsp;


using System.IO;




@@ -50,7 +49,7 @@




        #region Functions


        /// <summary>


        /// 初始化工单资料


        /// 初始化工单批次资料


        /// </summary>


        /// <returns></returns>


        public WorkBatch Init(string lineCode)


@@ -63,6 +62,10 @@


            return this;


        }




        /// <summary>


        /// 更新工单批次资料


        /// </summary>


        /// <param name="updateAll"></param>


        public void Update(bool updateAll = false)


        {


            var strat = DateTime.Now;


@@ -166,20 +169,22 @@


                action.LocaleMsg = new("MES.WorkBatch.WoStatusCanNotWork", WO.ORDER_NO, Batch.STATUS.GetEnumDesc<BIZ_MES_WO.STATUSs>());


            }


            //工单批次投入数量减去报废数量如果大于等于计划数量，则不允许生产


            if (curNode.IS_FIRST_NODE == "Y" && WoSNs.Count(q => q.BATCH_NO == Batch.BATCH_NO && BIZ_MES_WO_SN.STATUSs.NotInput.GetValue() < q.STATUS && q.STATUS <= BIZ_MES_WO_SN.STATUSs.Finished.GetValue()) >= Batch.PLAN_QTY)


            var batchInput = WoSNs.Where(q => q.BATCH_NO == Batch.BATCH_NO && BIZ_MES_WO_SN.STATUSs.NotInput.GetValue() < q.STATUS && q.STATUS <= BIZ_MES_WO_SN.STATUSs.Finished.GetValue()).DistinctBy(q => q.WIP_ID).Sum(q => q.QTY);


            if (curNode.IS_FIRST_NODE == "Y" && batchInput >= Batch.PLAN_QTY)


            {


                action.IsSuccessed = false;


                action.Data.SetValue(this, null);


                //action.LocaleMsg = new($"工单批次[{0}]已投入 {1}，其中报废 {2}，以满足计划数量[{3}]，无需继续投入");


                action.LocaleMsg = new("MES.WorkBatch.BatchInputEnough", Batch.BATCH_NO, WoSNs.Count(q => q.BATCH_NO == Batch.BATCH_NO), WoSNs.Count(q => q.BATCH_NO == Batch.BATCH_NO && q.STATUS > BIZ_MES_WO_SN.STATUSs.Finished.GetValue()), Batch.PLAN_QTY);


                action.LocaleMsg = new("MES.WorkBatch.BatchInputEnough", Batch.BATCH_NO, batchInput, WoSNs.Where(q => q.BATCH_NO == Batch.BATCH_NO && q.STATUS > BIZ_MES_WO_SN.STATUSs.Finished.GetValue()).DistinctBy(q => q.WIP_ID).Sum(q => q.QTY), Batch.PLAN_QTY);


            }


            //工单投入数量减去报废数量如果大于等于计划数量，则不允许生产


            if (curNode.IS_FIRST_NODE == "Y" && WoSNs.Count(q =>q.WORK_ORDER == WO.ORDER_NO && BIZ_MES_WO_SN.STATUSs.NotInput.GetValue() < q.STATUS && q.STATUS <= BIZ_MES_WO_SN.STATUSs.Finished.GetValue()) >= WO.PLAN_QTY)


            var woInput = WoSNs.Where(q => q.WORK_ORDER == WO.ORDER_NO && BIZ_MES_WO_SN.STATUSs.NotInput.GetValue() < q.STATUS && q.STATUS <= BIZ_MES_WO_SN.STATUSs.Finished.GetValue()).DistinctBy(q => q.WIP_ID).Sum(q => q.QTY);


            if (curNode.IS_FIRST_NODE == "Y" && woInput >= WO.PLAN_QTY)


            {


                action.IsSuccessed = false;


                action.Data.SetValue(this, null);


                //action.LocaleMsg = new($"工单[{0}]已投入 {1}，其中报废 {2}，以满足计划数量[{3}]，无需继续投入");


                action.LocaleMsg = new("MES.WorkBatch.WoInputEnough", WO.ORDER_NO, WoSNs.Count(q => q.WORK_ORDER == WO.ORDER_NO), WoSNs.Count(q => q.WORK_ORDER == WO.ORDER_NO && q.STATUS > BIZ_MES_WO_SN.STATUSs.Finished.GetValue()), WO.PLAN_QTY);


                action.LocaleMsg = new("MES.WorkBatch.WoInputEnough", WO.ORDER_NO, woInput, WoSNs.Where(q => q.WORK_ORDER == WO.ORDER_NO && q.STATUS > BIZ_MES_WO_SN.STATUSs.Finished.GetValue()).DistinctBy(q => q.WIP_ID).Sum(q => q.QTY), WO.PLAN_QTY);


            }




            return action;


@@ -350,6 +355,7 @@


                    action.IsSuccessed = false;


                    action.Data.SetValue(this, null);


                    var nextList = Nodes.Where(q => q.IS_FIRST_NODE == "Y");


                    //action.LocaleMsg = new($"条码[{0}]在工序[{1}]过站扫描错误，请先通过以下工序：{2}");


                    action.LocaleMsg = new("MES.WorkBatch.GotoNextNodeException", input.SN, nextNode.NODE_NAME, string.Join(", ", nextList.Select(q => q.NODE_NAME + (GetNodeSetting(q)?.CAN_SKIP == "Y" ? $"({Biz.T(Biz.L("MES.WorkBatch.Optional"), input.Locale)})" : ""))));


                    return action;


                }


@@ -386,22 +392,25 @@


                        action.IsSuccessed = false;


                        action.Data.SetValue(this, null);


                        var nextList = reflowNodes.Where(q => wipSN.REFLOW_NODE.IsNullOrEmpty() || wipSN.REFLOW_NODE == q.NODE_NAME);


                        //action.LocaleMsg = new($"工序[{0}]不是条码[{1}]在工序[{2}]维修后可回流的工序，请选择回流到以下工序：{3}");


                        action.LocaleMsg = new("MES.WorkBatch.ReflowToNodeException", nextNode.NODE_NAME, input.SN, curNode.NODE_NAME, string.Join(", ", nextList.Select(q => q.NODE_NAME + (GetNodeSetting(q)?.CAN_SKIP == "Y" ? $"({Biz.T(Biz.L("MES.WorkBatch.Optional"), input.Locale)})" : ""))));


                        return action;


                    }


                }


                //不良品入站：如果产品有不良记录且目标工序不是维修工序且不允许不良品入站，则报错


                else if (wipSN.Defects.Any(q => q.WORK_ORDER == WO.ORDER_NO && q.STATUS < MES_WIP_DFT.STATUSs.Resolved.GetValue())


                     && nextSetting.ALLOW_DFT_IN != "Y" && nextNode.Operation.OPER_TYPE != MES_OPERATION.OPER_TYPEs.Repair.GetValue())


                {


                    action.IsSuccessed = false;


                    action.Data.SetValue(this, null);


                    action.LocaleMsg = new("MES.WorkBatch.PleaseGotoRepair", curNode.NODE_NAME, input.SN);


                    return action;


                }


                //正常工序过站


                else


                {


                    //不良品入站：如果产品有不良记录且目标工序不是维修工序且不允许不良品入站，则报错


                    if (wipSN.Defects.Any(q => q.STATUS < MES_WIP_DFT.STATUSs.Resolved.GetValue())


                     && nextSetting.ALLOW_DFT_IN != "Y" && nextNode.Operation.OPER_TYPE != MES_OPERATION.OPER_TYPEs.Repair.GetValue())


                    {


                        action.IsSuccessed = false;


                        action.Data.SetValue(this, null);


                        //action.LocaleMsg = new($"工序[{0}]不允许不良品入站，条码[{1}]存在不良记录，请先按流程指引操作或者进入维修");


                        action.LocaleMsg = new("MES.WorkBatch.PleaseGotoRepair", curNode.NODE_NAME, input.SN);


                        return action;


                    }




                    //添加条码当前工序的下一个可执行工序


                    var nextNodes = GetNextNodes(curNode, wipSN);


                    //如果下一个可执行工序包含目标工序则允许进站


@@ -416,7 +425,8 @@


                    {


                        action.IsSuccessed = false;


                        action.Data.SetValue(this, null);


                        var nextList = nextNodes.Where(q => NodeSets.Any(s => s.NODE_ID == q.ID && s.IS_ACTIVE == "Y" && s.CAN_SKIP != "Y"));


                        var nextList = nextNodes.Where(q => NodeSets.Any(s => s.NODE_ID == q.ID && s.IS_ACTIVE == "Y"));


                        //action.LocaleMsg = new($"条码[{0}]在工序[{1}]过站扫描错误，请先通过以下工序：{2}");


                        action.LocaleMsg = new("MES.WorkBatch.GotoNextNodeException", input.SN, nextNode.NODE_NAME, string.Join(", ", nextList.Select(q => q.NODE_NAME + (GetNodeSetting(q)?.CAN_SKIP == "Y" ? $"({Biz.T(Biz.L("MES.WorkBatch.Optional"), input.Locale)})" : ""))));


                        return action;


                    }


@@ -446,6 +456,7 @@


                            action.IsSuccessed = false;


                            action.Data.SetValue(this, null);


                            var nextList = nextNodes.Where(q => NodeSets.Any(s => s.NODE_ID == q.ID && s.IS_ACTIVE == "Y"));


                            //action.LocaleMsg = new($"条码[{0}]在工序[{1}]过站扫描错误，请先通过以下工序：{2}");


                            action.LocaleMsg = new("MES.WorkBatch.GotoNextNodeException", input.SN, nextNode.NODE_NAME, string.Join(", ", nextList.Select(q => q.NODE_NAME + (GetNodeSetting(q)?.CAN_SKIP == "Y" ? $"({Biz.T(Biz.L("MES.WorkBatch.Optional"), input.Locale)})" : ""))));


                            return action;


                        }


@@ -464,7 +475,7 @@


        private List<MES_WO_NODE> GetNextNodes(MES_WO_NODE parent, MES_WIP_DATA wipSN)


        {


            var result = new List<MES_WO_NODE>();


            var nextNodes = Nodes.Where(q => q.Operation.OPER_TYPE != MES_OPERATION.OPER_TYPEs.Repair.GetValue()


            var nextNodes =  Nodes.Where(q => q.Operation.OPER_TYPE != MES_OPERATION.OPER_TYPEs.Repair.GetValue()


                                                                && Edges.Any(e => e.SRC_NODE == parent.ID && e.TGT_NODE == q.ID)


                                                                && !wipSN.History.Any(h => h.WORK_ORDER == WO.ORDER_NO && h.UNBIND_FLAG != "Y" && h.NODE_ID == q.ID && h.IsFinished)


                                                             ).ToList();


@@ -634,7 +645,7 @@


                            .ExecuteCommand();


                //MES_WIP_DATA & MES_WIP_HIS


                var wipHiss = new List<MES_WIP_HIS>();


                foreach (var wipSN in wipList.Where(q => q.STATUS != MES_WIP_DATA.STATUSs.Offline.GetValue()))


                foreach (var wipSN in wipList) //.Where(q => q.STATUS != MES_WIP_DATA.STATUSs.Offline.GetValue())


                {


                    wipSN.STATUS = MES_WIP_DATA.STATUSs.Offline.GetValue();


                    wipSN.TRAY_SN = wipSN.INNER_SN = wipSN.CARTON_SN = wipSN.PALLET_SN = wipSN.SHIPPING_ORDER = null;


@@ -669,10 +680,16 @@


                while (curpkg.Any());


                db.Updateable(pkgs, user).ExecuteCommand();


                //MES_WIP_DFT，在上仓库装配和维修之前，先把不良记录标记为已处理


                db.Updateable<MES_WIP_DFT>(user)


                           .SetColumns(q => q.STATUS == MES_WIP_DFT.STATUSs.Resolved.GetValue())


                           .Where(q => q.WORK_ORDER == wo.ORDER_NO && wipIDs.Contains(q.WIP_ID))


                db.Updateable<MES_WIP_DATA>(user)


                           .SetColumns(q => q.DFT_FLAG == "N")


                           .SetColumns(q => q.DFT_COUNT == 0)


                           .SetColumns(q => q.DFT_CODE == null)


                           .Where(q => q.WORK_ORDER == wo.ORDER_NO && wipIDs.Contains(q.ID))


                           .ExecuteCommand();


                db.Updateable<MES_WIP_DFT>(user)


                          .SetColumns(q => q.STATUS == MES_WIP_DFT.STATUSs.Resolved.GetValue())


                          .Where(q => q.WORK_ORDER == wo.ORDER_NO && wipIDs.Contains(q.WIP_ID))


                          .ExecuteCommand();


            });


            if (!dbTran.IsSuccess)


            {