服务端的TigerApi 框架，基于.NET6 2024 版本
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Rodney Chen
2025-01-02 87422530bec9baf531d2e0715b9c786a4d35667f 
 Tiger.Business.MES/WorkAction/Assembly.cs


@@ -16,6 +16,7 @@


    {


        #region Propertys & Variables


        #region 固定写法，工序中的必要信息


        public DbClient MainDB { get; set; }


        public bool IsFinished { get; set; } = false;


        public IWorkStep CurStep { get; set; }


        public IPosition CurPosition { get; set; }


@@ -34,6 +35,7 @@


        public void Init(IWorkStep curStep, IPosition position, MES_WO_NODE_ACT nodeAct, MES_WO_ACTION setting)


        {


            #region 固定写法，给默认变量赋值


            MainDB = position.MainDB;


            CurStep = curStep;


            CurPosition = position;


            NodeAct = nodeAct;


@@ -41,7 +43,7 @@


            #endregion




            //获取产品BOM


            Boms = Biz.Db.Queryable<BAS_PROD_BOM>().Where(q => q.PROD_CODE == CurPosition.WorkBatch.WO.ITEM_CODE).ToList();


            Boms = MainDB.Queryable<BAS_PROD_BOM>().Where(q => q.PROD_CODE == CurPosition.WorkBatch.WO.ITEM_CODE).ToList();


            //获取上料物料


            var assyList = new List<AssemblySetting>();


            try


@@ -57,7 +59,7 @@


                }


            }


            var codes = assyList.Select(q => q.ITEM_CODE).ToList();


            var items = Biz.Db.Queryable<BAS_ITEM>().Where(q => codes.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();


            var items = MainDB.Queryable<BAS_ITEM>().Where(q => codes.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();


            //获取上料物料的替代料


            foreach (var assy in assyList)


            {


@@ -74,7 +76,7 @@


                   if (!bom.IsNullOrEmpty())


                   {


                      var subs = bom.SUB_CODE.Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries);


                      var surItems = Biz.Db.Queryable<BAS_ITEM>().Where(q => subs.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();


                      var surItems = MainDB.Queryable<BAS_ITEM>().Where(q => subs.Contains(q.ITEM_CODE) && q.AUTH_ORG == CurPosition.WorkBatch.WO.AUTH_ORG).ToList();


                        foreach (var sub in surItems)


                        {


                            if (!item.SubItems.Any(q => q.ITEM_CODE == sub.ITEM_CODE))


@@ -156,9 +158,9 @@


                    //根据条码规则验证上料是否正确


                    if (!item.RuleCode.IsNullOrEmpty())


                    {


                        if (!Biz.CodeRule[item.RuleCode].IsNullOrEmpty())


                        if (!Cache.CodeRule[item.RuleCode].IsNullOrEmpty())


                        {


                            var result = Biz.CodeRule[item.RuleCode].Verify(input.SN);


                            var result = Cache.CodeRule[item.RuleCode].Verify(input.SN);


                            if (!result.IsSuccessed)


                            {


                                isOK = false;


@@ -184,9 +186,9 @@


                        {


                            if (!subItem.RULE_CODE.IsNullOrEmpty())


                            {


                                if (!Biz.CodeRule[subItem.RULE_CODE].IsNullOrEmpty())


                                if (!Cache.CodeRule[subItem.RULE_CODE].IsNullOrEmpty())


                                {


                                    var result = Biz.CodeRule[item.RuleCode].Verify(input.SN);


                                    var result = Cache.CodeRule[item.RuleCode].Verify(input.SN);


                                    //只要有一个替代料通过验证则可以上料


                                    if (result.IsSuccessed)


                                    {


@@ -315,6 +317,7 @@




            //记录行为操作记录


            var wipActs = new List<MES_WIP_ACT>();


            var wipVars = new List<MES_WIP_ACT_VAR>();


            foreach (var wipSn in CurPosition.CurWipSNs)


            {


                var wipAct = new MES_WIP_ACT()


@@ -351,15 +354,61 @@


                    ACT_TYPE = NodeAct.ACT_TYPE,


                    ACT_SN = wipSn.SN,


                    ACT_VALUE_1 = CurAssembly.ToJson(),


                    ACT_VAR_DIC = CurStep.ActionDic.ToJson(),


                    ACT_RESULT = "Y",


                    ELAPSED_TIME = CurStep.GetElapsedTime().TotalMilliseconds.ToInt64(),


                    TRACE_INFO = $"以下物料上料完成：{string.Join(",", CurAssembly.Items.Select(q => $"{q.ItemInfo.ITEM_NAME}({q.ItemInfo.ITEM_CODE})"))}",


                };


                wipActs.Add(wipAct);


                foreach (var item in NodeAct.Variables)


                {


                    var wipVar = new MES_WIP_ACT_VAR()


                    {


                        AUTH_ORG = CurPosition.WorkBatch.WO.AUTH_ORG,


                        AUTH_PROD = CurPosition.CurLine.LINE_CODE,


                        HIS_ID = CurPosition.CurWipSNHiss.First(q => q.SN == wipSn.SN).ID,


                        WIP_ID = wipSn.ID,


                        SN = wipSn.SN,


                        ITEM_CODE = wipSn.ITEM_CODE,


                        WORK_ORDER = wipSn.WORK_ORDER,


                        BATCH_NO = wipSn.BATCH_NO,


                        CUST_CODE = CurPosition.WorkBatch.WO.CUST_CODE,


                        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,


                        FLOW_SN = wipSn.FLOW_SN,


                        TRAY_SN = wipSn.TRAY_SN,


                        INNER_SN = wipSn.INNER_SN,


                        CARTON_SN = wipSn.CARTON_SN,


                        PALLET_SN = wipSn.PALLET_SN,


                        OPERATION_TIME = DateTime.Now,


                        SFTS_CODE = wipSn.SFTS_CODE,


                        SFT_CODE = wipSn.SFT_CODE,


                        PRD_CODE = wipSn.PRD_CODE,


                        VAR_CODE = item.VAR_CODE,


                        VAR_NAME = item.VAR_NAME,


                        VAR_CONTROL = item.VAR_CONTROL,


                        VALUE_TYPE = item.VALUE_TYPE,


                        PROCESS_VAR = item.PROCESS_VAR,


                        INPUT_VALUE = CurStep.ActionDic.GetOrDefault(item.VAR_CODE),


                        TRACE_INFO = CurStep.ActionDic.ToJson(),


                    };


                    wipVars.Add(wipVar);


                }


            }






            //创建变量克隆对象用于传入DBSubmitAction中保存当前需要暂存的数据值


            var _wipActs = wipActs.Clone();


            var _wipVars = wipVars.Clone();


            //整理上料记录


            var _records = new List<MES_WIP_ASSY>();


            foreach (var item in CurAssembly.Items)


@@ -371,6 +420,7 @@


            {


                var db = CurPosition.GetCommitDB();


                db.Storageable(_wipActs, CurPosition.UserCode).ExecuteCommand();


                db.Storageable(_wipVars, CurPosition.UserCode).ExecuteCommand();


                db.Insertable(_records, CurPosition.UserCode).ExecuteCommand();


            };