服务端的TigerApi 框架，基于.NET6 2024 版本
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Ben Lin
2024-12-03 6cc05f3689e7616431886ec183948c433a30220c 
 Tiger.Business.MES/Transaction/YadaPacking.cs


@@ -13,6 +13,7 @@


using Tiger.Business.MES.WorkAction;


using Tiger.Model.MES.Yada;


using System.Data;


using System.Diagnostics;




namespace Tiger.Business.MES.Transaction


{


@@ -24,6 +25,7 @@


        public new IYadaPacking Init(string id, string apiHost, string userCode, string postCode)


        {


            base.Init(id, apiHost, userCode, postCode);


            U9CDB = Biz.DataSource["YadaU9C"].Client;


            Logger.Console.Info($"User[{userCode}] start a {this.GetType().Name}[{postCode}] Transaction[ID: {TransID}]");


            return this;


        }


@@ -39,6 +41,8 @@


        public PackingAction TempPkgAction { get; set; }


        public bool IsPrintCustomerLabel { get; set; }


        public string ShippingOrder { get; set; }


        public DbClient U9CDB { get; set; }


        public Model.TraceDebug debug { get; set; }


        public DateTime curtime = DateTime.Now;


        public DateTime prevtime = DateTime.Now;


        #endregion Propertys & Variables


@@ -51,7 +55,8 @@


        /// <returns></returns>


        public async Task<ApiAction<SubmitOutput>> Submit(SubmitInput input)


        {


            curtime = prevtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 1 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug = new(new StackFrame(true));


            debug.Log(new StackFrame(true), "***** 1", info => { ConsoleExt.WriteLine(info.ToString()); });


            var action = new ApiAction<SubmitOutput>(new SubmitOutput());


            try


            {


@@ -65,11 +70,11 @@


                //    //action.LocaleMsg = new("MES.Transaction.PackingNode.Submit.QtyError", input.Qty);


                //    return SetOutPutMqttMsg(action, input.Locale);


                //}


                if (input.Options.ContainsKey("IsPrintCustomerLabel"))


                {


                    IsPrintCustomerLabel = input.Options["IsPrintCustomerLabel"].ToBoolean();


                }


          


                //if (input.Options.ContainsKey("IsPrintCustomerLabel"))


                //{


                //    IsPrintCustomerLabel = input.Options["IsPrintCustomerLabel"].ToBoolean();


                //}




                //if (input.Options.ContainsKey("ShippingOrder"))


                //{


                //    ShippingOrder = IsPrintCustomerLabel ? input.Options["ShippingOrder"].ToString() : "";


@@ -90,17 +95,17 @@


                {


                    //工步列表为空或者工序节点工步有未完成时，优先完成工序节点工步


                    if (Steps.IsNullOrEmpty() || !IsFinishNodeSteps)


                    {   


                    {


                        var wosns = MainDB.Queryable<BIZ_MES_WO_BATCH, BIZ_MES_WO_SN>((q, s) => new JoinQueryInfos(JoinType.Inner, q.ORDER_NO == s.WORK_ORDER && q.BATCH_NO == s.BATCH_NO))


                                                .ByAuth(input.AuthOption)//.Where((q, s) => s.STATUS < BIZ_MES_WO_SN.STATUSs.Finished.GetValue())


                                                .Where((q, s) => s.SN == input.SN || s.FLOW_SN == input.SN || s.TRAY_SN == input.SN).Select((q, s) => new { Batch = q, SN = s }).ToList();


                        curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 2 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                        debug.Log(new StackFrame(true), "***** 2", info => { ConsoleExt.WriteLine(info.ToString()); });


                        //先判断当前工单不为空且当前岗位在当前工单是不是首站，如果是则不允许变更当前工单，尝试把条码绑定到当前工单


                        if (!CurBatch.IsNullOrEmpty() && CurBatch.IsFirstNode(PostCode))


                        {


                            //更新CurBatch


                            CurBatch?.Update();


                            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 3 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                            debug.Log(new StackFrame(true), "***** 3", info => { ConsoleExt.WriteLine(info.ToString()); });


                            var wosn = wosns.FirstOrDefault(q => q.Batch.ORDER_NO == CurBatch.WO.ORDER_NO && (q.SN.STATUS == BIZ_MES_WO_SN.STATUSs.Finished.GetValue() || q.SN.STATUS == BIZ_MES_WO_SN.STATUSs.Scrap.GetValue()));


                            if (!wosn.IsNullOrEmpty())


                            {


@@ -114,7 +119,7 @@


                            {


                                //提交数据


                                action = NodeSubmit(action, input);


                                curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 4 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                                debug.Log(new StackFrame(true), "***** 4", info => { ConsoleExt.WriteLine(info.ToString()); });


                                //更新工序信息


                                if (!action.IsSuccessed)


                                {


@@ -235,23 +240,23 @@


                    {


                        //更新CurBatch


                        CurBatch?.Update();


                        curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 5 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                        debug.Log(new StackFrame(true), "***** 5", info => { ConsoleExt.WriteLine(info.ToString()); });


                        var submitStep = Steps.Where(q => q.ID == input.CurStepID && !q.IsFinished).FirstOrDefault();


                        //如果客户端返回的当前工步ID找不到未完成的行为工步，则直接开始下一个行为工步


                        if (submitStep.IsNullOrEmpty())


                        {


                            action = BeginNextActionStep(input);


                            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 6 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                            debug.Log(new StackFrame(true), "***** 6", info => { ConsoleExt.WriteLine(info.ToString()); });


                        }


                        else


                        {


                            action = submitStep.Submit(input);


                            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 7 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                            debug.Log(new StackFrame(true), "***** 7", info => { ConsoleExt.WriteLine(info.ToString()); });


                            //如果当前工步已完成，开始执行下一工步


                            if (action.IsSuccessed && submitStep.IsFinished)


                            {


                                action = BeginNextActionStep(input);


                                curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 8 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                                debug.Log(new StackFrame(true), "***** 8", info => { ConsoleExt.WriteLine(info.ToString()); });


                            }


                            //如果当前工步未完成


                            else


@@ -296,7 +301,7 @@


                //action.CatchExceptionWithLog(ex, $"包装工序：提交操作数据异常");


                action.CatchExceptionWithLog(ex, Biz.L("MES.Transaction.PackingNode.SubmitException"));


            }


            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 9 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug.Log(new StackFrame(true), "***** 9", info => { ConsoleExt.WriteLine(info.ToString()); });


            return SetOutPutMqttMsg(action, input.Locale);


        }




@@ -308,7 +313,7 @@


        /// <returns></returns>


        public ApiAction<SubmitOutput> NodeSubmit(ApiAction<SubmitOutput> action, SubmitInput input)


        {


            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 10 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug.Log(new StackFrame(true), "***** 10", info => { ConsoleExt.WriteLine(info.ToString()); });


            var curNode = CurBatch.GetNode(PostCode);


            try


            {


@@ -392,15 +397,15 @@




                    //设置当前指令为正常产品过站


                    NodeCmd = "NodeSubmit";


                    curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 11 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                    debug.Log(new StackFrame(true), "***** 11", info => { ConsoleExt.WriteLine(info.ToString()); });




                    //获取出货状态


                    DbClient db = Biz.DataSource["YadaU9C"].Client;


                    var ship = db.Queryable<mes_ShipList>().Where(q => q.MoDoc == CurBatch.WO.ORDER_NO && q.Status == 2 && SqlFunc.DateIsSame(q.BusinessDate, DateTime.Now)).First();


                    var ship = U9CDB.Queryable<mes_ShipList>().Where(q => q.MoDoc == CurBatch.WO.ORDER_NO && q.Status == 2 && SqlFunc.DateIsSame(q.BusinessDate, DateTime.Now)).First();


                    int CurShipQty = 0;


                    int WaitShipmentCarton = 0;


                    int WaitShipment = 0;


                    if (ship.IsNullOrEmpty()) { IsPrintCustomerLabel = false; } else


                    if (ship.IsNullOrEmpty()) { IsPrintCustomerLabel = false; }


                    else


                    {


                        CurShipQty = ship.ShipQty;


                        IsPrintCustomerLabel = true;


@@ -437,7 +442,7 @@


                    //    Context.Add("CurWaitShipmentCarton", WaitShipmentCarton);


                    //}




                    curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 12 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                    debug.Log(new StackFrame(true), "***** 12", info => { ConsoleExt.WriteLine(info.ToString()); });


                    //绑定条码到工单


                    foreach (var wipSN in wipSNs)


                    {


@@ -581,7 +586,7 @@


                    var _curNodeSetting = curNodeSetting.Clone();


                    var _Batch = CurBatch.Batch.Clone();




                    curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 13 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


                    debug.Log(new StackFrame(true), "***** 13", info => { ConsoleExt.WriteLine(info.ToString()); });


                    //初始化工步列表


                    Steps.Clear();


                    var curStep = new WorkStep(IWorkStep.NodeTypes.Node, this)


@@ -705,7 +710,7 @@


                //action.CatchExceptionWithLog(ex, $"{curNode.NODE_NAME}：工序节点工步提交数据异常，请检查工序节点设置");


                action.CatchExceptionWithLog(ex, Biz.L("MES.Transaction.PackingNode.NodeSubmitException", curNode.NODE_NAME));


            }


            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 13.1 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug.Log(new StackFrame(true), "***** 13.1", info => { ConsoleExt.WriteLine(info.ToString()); });


            return action;


        }




@@ -719,7 +724,7 @@


            var curPkg = Context.ContainsKey("CurPackage") ? Context["CurPackage"] as WipPkg : null;


            var operInfo = SetOperNodeInfo(CurOperInfo(locale));


            Action endAction = null;


            curtime = DateTime.Now;  Logger.Console.Info($"{CurSN} : ***** 14 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug.Log(new StackFrame(true), "***** 14", info => { ConsoleExt.WriteLine(info.ToString()); });




            //如果当前条码已经走到流程终点则记录条码完工


            if (operInfo.IsReachedEndNode)


@@ -787,7 +792,7 @@




            //保存数据库


            SaveStepsCommitActionToDB(endAction);


            




            //保存成功，返回过站消息


            operInfo.InputQty += CurWipSNs.Count;


            action.Data.Data = new PackingActionOutput() { PkgInfo = curPkg };


@@ -804,7 +809,7 @@




            //重置工序


            ResetNode();


            curtime = DateTime.Now; Logger.Console.Info($"{CurSN} : ***** 15 : {(curtime - prevtime).TotalSeconds}s", ConsoleColor.Green); prevtime = curtime;


            debug.Log(new StackFrame(true), "***** 15", info => { ConsoleExt.WriteLine(info.ToString()); });


            return action;


        }




@@ -953,7 +958,7 @@


                var CurPkg = Context.ContainsKey("CurPackage") ? Context["CurPackage"] as WipPkg : null;


                var LabelPV = MainDB.Queryable<BAS_LABEL_PV>().ToList();


                var label = CurPkg.Item.LABEL_CODE.IsNullOrEmpty() ? null : MainDB.Queryable<BAS_LABEL_TEMP>().Where(q => q.LABEL_CODE == CurPkg.Item.LABEL_CODE).IncludesAllFirstLayer().First();


                var printLb =  SetLabelVariables(LabelPV, label, new PackingAction(), CurPkg);


                var printLb = SetLabelVariables(LabelPV, label, new PackingAction(), CurPkg);


                action.Data = new PackingActionOutput()


                {


                    ExecCode = "PrintTest",


@@ -977,9 +982,11 @@


            var action = new ApiAction<ShipingInfo>();


            try


            {


                action.Data = new ShipingInfo() { 


                    IsPrintCustomerLabel= IsPrintCustomerLabel,


                    ShipQty =Context.GetOrDefault("CurWaitShipment").ToInt32()>= Context.GetOrDefault("CurShipQty").ToInt32()? CurBatch.Batch.PLAN_QTY - Context.GetOrDefault("CurShipQty").ToInt32(): Context.GetOrDefault("CurShipQty").ToInt32() };


                action.Data = new ShipingInfo()


                {


                    IsPrintCustomerLabel = IsPrintCustomerLabel,


                    ShipQty = Context.GetOrDefault("CurWaitShipment").ToInt32() >= Context.GetOrDefault("CurShipQty").ToInt32() ? CurBatch.Batch.PLAN_QTY - Context.GetOrDefault("CurShipQty").ToInt32() : Context.GetOrDefault("CurShipQty").ToInt32()


                };


            }


            catch (Exception ex)


            {