服务端的TigerApi 框架，基于.NET6 2024 版本
blame | 历史 | 补丁 | 提交 | 提交对比 | 忽略空白
Rodney Chen
10 天以前 531f16f2f15bf792e3e719e00abb57a95356dedd 
 Tiger.Business.MES/Transaction/Position.cs


@@ -30,22 +30,23 @@


            UserCode = userCode;


            ApiHost = apiHost;


            PostCode = postCode;


            _MainDB = Biz.Db;




            CurPosition = Biz.Db.Queryable<MES_POSITION>().Where(q => q.POST_CODE == postCode).First();


            CurPosition = MainDB.Queryable<MES_POSITION>().Where(q => q.POST_CODE == postCode).First();


            //if (CurPosition.IsNullOrEmpty()) throw new InvalidDataException($"MES.Transaction.Position.PositionNotExistsException", new Exception($"{postCode}|"));


            if (CurPosition.IsNullOrEmpty()) throw new InvalidDataException($"岗位[{postCode}]不存在，请提交正确的岗位代码", new Exception($"{postCode}|"));


            CurLine = Biz.Db.Queryable<MES_LINE>().Where(q => q.LINE_CODE == CurPosition.LINE_CODE).First();


            CurLine = MainDB.Queryable<MES_LINE>().Where(q => q.LINE_CODE == CurPosition.LINE_CODE).First();


            //if (CurLine.IsNullOrEmpty()) throw new InvalidDataException($"MES.Transaction.Position.LineNotExistsException", new Exception($"{postCode}|{CurPosition.LINE_CODE}"));


            if (CurLine.IsNullOrEmpty()) throw new InvalidDataException($"岗位[{postCode}]所属的产线[{CurPosition.LINE_CODE}]不存在，请先设置所属产线", new Exception($"{postCode}|{CurPosition.LINE_CODE}"));


            CurWorkshop = Biz.Db.Queryable<MES_WORKSHOP>().Where(q => q.WS_CODE == CurLine.WS_CODE).First();


            CurWorkshop = MainDB.Queryable<MES_WORKSHOP>().Where(q => q.WS_CODE == CurLine.WS_CODE).First();


            //if (CurWorkshop.IsNullOrEmpty()) throw new InvalidDataException($"MES.Transaction.Position.WorkshopNotExistsException", new Exception($"{postCode}|{CurLine.WS_CODE}"));


            if (CurWorkshop.IsNullOrEmpty()) throw new InvalidDataException($"岗位[{postCode}]所属的车间[{CurLine.WS_CODE}]不存在，请先设置所属车间", new Exception($"{postCode}|{CurLine.WS_CODE}"));


            CurFactory = Biz.Db.Queryable<MES_FACTORY>().Where(q => q.FTY_CODE == CurWorkshop.FTY_CODE).First();


            CurFactory = MainDB.Queryable<MES_FACTORY>().Where(q => q.FTY_CODE == CurWorkshop.FTY_CODE).First();


            //if (CurFactory.IsNullOrEmpty()) throw new InvalidDataException($"MES.Transaction.Position.FactoryNotExistsException", new Exception($"{postCode}|{CurWorkshop.FTY_CODE}"));


            if (CurFactory.IsNullOrEmpty()) throw new InvalidDataException($"岗位[{postCode}]所属的工厂[{CurWorkshop.FTY_CODE}]不存在，请先设置所属工厂", new Exception($"{postCode}|{CurWorkshop.FTY_CODE}"));




            //加载当前产线的班制


            CurShiftSys = Biz.Db.Queryable<MES_SHIFT_SYS>().Where(q => q.SFTS_CODE == CurLine.SFTS_CODE).IncludesAllFirstLayer().IncludesAllSecondLayer(q => q.Shifts).First();


            CurShiftSys = MainDB.Queryable<MES_SHIFT_SYS>().Where(q => q.SFTS_CODE == CurLine.SFTS_CODE).IncludesAllFirstLayer().IncludesAllSecondLayer(q => q.Shifts).First();




            return this;


        }


@@ -75,6 +76,8 @@


        public bool IsFinishNodeSteps => !Steps.Any(q => q.NodeType == IWorkStep.NodeTypes.Node && !q.IsFinished);


        public bool IsFinishAllSteps => Steps.Any() && !Steps.Any(q => !q.IsFinished);


        //public int CurStep => Steps.Where(q => !q.IsFinished).OrderBy(q => q.Sequence).FirstOrDefault()?.Sequence ?? 0;


        private DbClient _MainDB;


        public DbClient MainDB => _MainDB;


        private DbClient CommitDB;


        /// <summary>


        /// 是否需要临时存储数据库提交操作，待需要的时候再提交


@@ -107,7 +110,7 @@


            {


                if (!WoContext.ExistsBatch(input.OrderNo, CurLine.LINE_CODE, batchNo, true))


                {


                    var wo = await Biz.Db.Queryable<BIZ_MES_WO>().ByAuth(input.AuthOption).Where(q => q.ORDER_NO == input.OrderNo).FirstAsync();


                    var wo = await MainDB.Queryable<BIZ_MES_WO>().ByAuth(input.AuthOption).Where(q => q.ORDER_NO == input.OrderNo).FirstAsync();


                    //验证明细是否正确


                    if (wo.IsNullOrEmpty())


                    {


@@ -123,7 +126,7 @@


                        action.LocaleMsg = new("MES.Transaction.Position.SelectOrder.StatusException", input.OrderNo, wo.STATUS.GetEnumDesc<BIZ_MES_WO.STATUSs>());


                        return action;


                    }


                    var batch = await Biz.Db.Queryable<BIZ_MES_WO_BATCH>().ByAuth(input.AuthOption)


                    var batch = await MainDB.Queryable<BIZ_MES_WO_BATCH>().ByAuth(input.AuthOption)


                        .Where(q => q.ORDER_NO == input.OrderNo && q.ACT_LINE == CurLine.LINE_CODE)


                        .WhereIF(!batchNo.IsNullOrEmpty(), q => q.BATCH_NO == batchNo)


                        .OrderBy(q => q.STATUS).FirstAsync();


@@ -141,8 +144,7 @@


                        action.LocaleMsg = new("MES.Transaction.Position.SelectOrder.BatchStatusException", input.OrderNo, batch.BATCH_NO, batch.STATUS.GetEnumDesc<BIZ_MES_WO_BATCH.STATUSs>());


                        return action;


                    }


                    var wb = new WorkBatch(input.OrderNo).Init(CurLine.LINE_CODE);


                    WoContext.WoBatchDic.Add(wb.Batch.BATCH_NO, wb);


                    var wb = WoContext.Add(input.OrderNo, CurLine.LINE_CODE);


                    batchNo = wb.Batch.BATCH_NO;


                }


                CurBatch = WoContext.GetBatch(input.OrderNo, CurLine.LINE_CODE, batchNo);


@@ -242,6 +244,62 @@


                info.NextNode = "   —   ";


            }


            return info;


        }




        /// <summary>


        /// 设置当前条码的工序信息


        /// </summary>


        public ApiAction<SubmitOutput> SetOutPutMqttMsg(ApiAction<SubmitOutput> action, string locale = null)


        {


            MQTT.Message msg = new()


            {


                IsSuccessed = action.IsSuccessed,


                Content = Biz.T(action.LocaleMsg, locale),


            };


            switch (action.Status)


            {


                case ApiAction.StatusCodes.Success:


                    msg.Voice = MQTT.Voice.Success;


                    msg.Color = "#FF1E90FF";


                    break;


                case ApiAction.StatusCodes.Warning:


                    msg.Voice = MQTT.Voice.Warning;


                    msg.Color = "#FFB8860B";


                    break;


                case ApiAction.StatusCodes.Error:


                case ApiAction.StatusCodes.Failed:


                    msg.Voice = MQTT.Voice.Fail;


                    msg.Color = "#FFFF0000";


                    break;


                case ApiAction.StatusCodes.Exception:


                    msg.Voice = MQTT.Voice.Fail;


                    msg.Color = "#FF8B0000";


                    break;


                case ApiAction.StatusCodes.Normal:


                case ApiAction.StatusCodes.NeedConfrim:


                case ApiAction.StatusCodes.Confrimed:


                default:


                    msg.Voice = MQTT.Voice.Silent;


                    msg.Color = "#FF000000";


                    break;


            }


            if (action.Data.IsFinished && action.IsSuccessed)


            {


                msg.Voice = MQTT.Voice.Pass;


                msg.Color = "#FF228B22";


            }


            else if (!action.IsSuccessed)


            {


                msg.Voice = MQTT.Voice.Fail;


                msg.Color = "#FFFF0000";


            }


            else


            {


                msg.Voice = MQTT.Voice.Silent;


                msg.Color = "#FF000000";


            }


            action.Data.MqttMsg = msg;


            return action;


        }




        /// <summary>


@@ -442,8 +500,8 @@


                    {


                        DBCommitList.Add("AppendSaveAction", new List<Action>());


                    }


                    var commitList = DBCommitList["AppendSaveAction"];


                    commitList.Add(appendToSave);


                    var appendList = DBCommitList["AppendSaveAction"];


                    appendList.Add(appendToSave);


                }


            }




@@ -512,12 +570,12 @@


        /// <param name="labelPVs">过程变量列表</param>


        /// <param name="label">标签模板</param>


        /// <returns></returns>


        public BAS_LABEL_TEMP SetLabelVariables(List<BAS_LABEL_PV> labelPVs, BAS_LABEL_TEMP label, IWorkAction action)


        public BAS_LABEL_TEMP SetLabelVariables(List<BAS_PROCESS_VAR> labelPVs, BAS_LABEL_TEMP label, IWorkAction action)


        {


            return SetLabelVariables(labelPVs, label, action, null);


        }




        public BAS_LABEL_TEMP SetLabelVariables(List<BAS_LABEL_PV> labelPVs, BAS_LABEL_TEMP label, IWorkAction action, WipPkg? CurPkg)


        public BAS_LABEL_TEMP SetLabelVariables(List<BAS_PROCESS_VAR> labelPVs, BAS_LABEL_TEMP label, IWorkAction action, WipPkg? CurPkg)


        {


            foreach (var item in label.Variables.OrderBy(q => q.VAR_TYPE == BAS_LABEL_VAR.VAR_TYPEs.BarcodeGenerate.GetValue() ? 0 : 1))


            {


@@ -550,14 +608,14 @@


        /// <param name="labelPVs">过程变量列表</param>


        /// <param name="lv">标签模板变量</param>


        /// <returns></returns>


        public string GetPrintProcessValue(List<BAS_LABEL_PV> labelPVs, BAS_LABEL_VAR lv, List<BAS_LABEL_VAR> lvars, IWorkAction curAction, WipPkg? CurPkg)


        public string GetPrintProcessValue(List<BAS_PROCESS_VAR> labelPVs, BAS_LABEL_VAR lv, List<BAS_LABEL_VAR> lvars, IWorkAction curAction, WipPkg? CurPkg)


        {


            var pv = labelPVs.FirstOrDefault(q => q.VAR_CODE == lv.VAR_VALUE);


            if (!pv.IsNullOrEmpty())


            {


                switch (pv.VAR_TYPE.GetEnum<BAS_LABEL_PV.VAR_TYPEs>())


                switch (pv.VAR_TYPE.GetEnum<BAS_PROCESS_VAR.VAR_TYPEs>())


                {


                    case BAS_LABEL_PV.VAR_TYPEs.ServerMethod:


                    case BAS_PROCESS_VAR.VAR_TYPEs.ServerMethod:


                        {


                            switch (pv.VAR_METHOD)


                            {


@@ -592,6 +650,10 @@


                                        {


                                            minPkgList = GetMinPkgList(_pkaction);


                                        }


                                        if (curAction is PrintInStoreLabel)


                                        {


                                            minPkgList = (curAction as PrintInStoreLabel).CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                        }


                                    }


                                    return string.Join("\r\n", minPkgList);


                                case "GetDescription":


@@ -614,6 +676,10 @@


                                        if (_action != null)


                                        {


                                            list = _action.CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                        }


                                        if (curAction is PrintInStoreLabel)


                                        {


                                            list = (curAction as PrintInStoreLabel).CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                        }


                                    }


                                    return GetHuaWeiWeek(WorkBatch.Batch.ORDER_NO, list);


@@ -648,39 +714,41 @@


                                case "GetVarByWo":


                                    return GetLabelVarWo(lv, "");


                                case "GetLOTNO":


                                    List<string> snList = new List<string>();


                                    string _lotnos = "";


                                    var _orderAction = curAction is PackingAction ? curAction as PackingAction : null;


                                    if (!CurPkg.IsNullOrEmpty())


                                    {


                                        qtylist = CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                        snList = CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                    }


                                    else


                                    {


                                        if (_orderAction != null)


                                        {


                                            var snList = _orderAction.CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                            if (!snList.Any())


                                            {


                                                snList.Add(_orderAction.CurPkg.CustSN?.FLOW_SN);


                                            }


                                            _lotnos = string.Join(",", Biz.Db.Queryable<MES_CUST_SN>()


                                                .Where((q) => snList.Contains(q.FLOW_SN))


                                                .Select((q) => q.WORK_ORDER).Distinct().ToList());


                                            return _lotnos;


                                            snList = _orderAction.CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                            snList.Add(_orderAction.CurPkg.CustSN?.FLOW_SN);


                                        }


                                        if (curAction is PrintInStoreLabel)


                                        {


                                            snList = (curAction as PrintInStoreLabel).CurPkg.Item.GetWipSnList().Select(q => q.Value).ToList();


                                            snList.Add((curAction as PrintInStoreLabel).CurPkg.CustSN?.FLOW_SN);


                                        }


                                    }


                                    return "";


                                    _lotnos = string.Join(",", MainDB.Queryable<MES_CUST_SN>()


                                        .Where((q) => snList.Contains(q.FLOW_SN))


                                        .Select((q) => q.WORK_ORDER).Distinct().ToList());


                                    return _lotnos;


                                case "GetNOTES":


                                    return GetLabelVarWo(lv, WorkBatch.Product.ExtInfo?.Remark);


                                case "GetXH":


                                    return "";


                                case "GetCardNo":


                                    return $"{Context["CurWaitShipmentCarton"].ToInt32() + 1}";


                                    return $"{Context.GetOrDefault("CurWaitShipmentCarton").ToInt32() + 1}";


                                case "GetCardTotal":


                                    var total = "";


                                    var _curaction = curAction is PackingAction ? curAction as PackingAction : null;


                                    if (!_curaction.IsNullOrEmpty()) {


                                        total = $"{Math.Ceiling(Context["CurShipQty"].ToDecimal()/_curaction.PkgRule.GetTotalQty().ToDecimal())}";


                                        total = $"{Math.Ceiling(Context.GetOrDefault("CurShipQty").ToDecimal()/_curaction.PkgRule.GetTotalQty().ToDecimal())}";


                                    }


                                    return total;


                                case "GetModelSpec": //Model+空格+SPEC,


@@ -691,9 +759,9 @@


                                    return "";


                            }


                        }


                    case BAS_LABEL_PV.VAR_TYPEs.WebApi:


                    case BAS_PROCESS_VAR.VAR_TYPEs.WebApi:


                        break;


                    case BAS_LABEL_PV.VAR_TYPEs.StoredProcedure:


                    case BAS_PROCESS_VAR.VAR_TYPEs.StoredProcedure:


                        break;


                    default:


                        break;


@@ -708,21 +776,21 @@


        /// <param name="labelPVs"></param>


        /// <param name="lv"></param>


        /// <returns></returns>


        public string GetGeneratePValue(List<BAS_LABEL_PV> labelPVs, BAS_LABEL_VAR lv)


        public string GetGeneratePValue(List<BAS_PROCESS_VAR> labelPVs, BAS_LABEL_VAR lv)


        {


            var pv = labelPVs.FirstOrDefault(q => q.VAR_CODE == lv.VAR_VALUE);


            if (!pv.IsNullOrEmpty())


            {


                switch (pv.VAR_TYPE.GetEnum<BAS_LABEL_PV.VAR_TYPEs>())


                switch (pv.VAR_TYPE.GetEnum<BAS_PROCESS_VAR.VAR_TYPEs>())


                {


                    case BAS_LABEL_PV.VAR_TYPEs.BarcodeGenerate:


                    case BAS_PROCESS_VAR.VAR_TYPEs.BarcodeGenerate:


                        {


                            switch (pv.VAR_METHOD)


                            {


                                case "GetCartonGenerate":


                                    return Biz.CodeRule[lv.BARCODE_RULE ?? ""]?.Generate("B", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


                                    return Cache.CodeRule[lv.BARCODE_RULE ?? ""]?.Generate("B", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


                                case "GetHW21SNGenerate":


                                    return Biz.CodeRule[lv.BARCODE_RULE ?? ""]?.Generate("SN:", "05").Data.ToString() ?? "";


                                    return Cache.CodeRule[lv.BARCODE_RULE ?? ""]?.Generate("SN:", "05").Data.ToString() ?? "";


                                default:


                                    return "";


                            }


@@ -742,7 +810,7 @@


        private string GetLabelVarWo(BAS_LABEL_VAR lv, string value)


        {


            string result = "";


            var labelVarwos = Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(x => x.LABEL_ID == lv.LABEL_ID && x.VAR_NAME == lv.VAR_NAME).ToList();


            var labelVarwos = MainDB.Queryable<BAS_LABEL_VAR_WO>().Where(x => x.LABEL_ID == lv.LABEL_ID && x.VAR_NAME == lv.VAR_NAME).ToList();


            if (labelVarwos.Any(q => q.WORK_ORDER == WorkBatch.Batch.ORDER_NO))


            {


                result = labelVarwos.First(q => q.WORK_ORDER == WorkBatch.Batch.ORDER_NO).VAR_VALUE;


@@ -779,7 +847,7 @@


        /// <returns></returns>


        private string GetBoxCode()


        {


            return Biz.CodeRule["WhiteBoxNo"]?.Generate("W", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


            return Cache.CodeRule["WhiteBoxNo"]?.Generate("W", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


        }




        /// <summary>


@@ -788,7 +856,7 @@


        /// <returns></returns>


        private string GetCardCode()


        {


            return Biz.CodeRule["CartonNo"]?.Generate("B", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


            return Cache.CodeRule["CartonNo"]?.Generate("B", $"{WorkBatch.Batch.BATCH_NO}-{WorkBatch.Batch.PLAN_QTY}-").Data.ToString() ?? "";


        }




        /// <summary>


@@ -854,7 +922,7 @@


        private string GetHuaWeiWeek(string pkgOrder, List<string> snList)


        {


            Dictionary<string, string> dic = new();


            var snOrder = Biz.Db.Queryable<MES_CUST_SN, BIZ_MES_WO>((q, w) => new JoinQueryInfos(JoinType.Left, q.WORK_ORDER == w.ORDER_NO))


            var snOrder = MainDB.Queryable<MES_CUST_SN, BIZ_MES_WO>((q, w) => new JoinQueryInfos(JoinType.Left, q.WORK_ORDER == w.ORDER_NO))


                                            .Where((q, w) => q.PKG_ORDER == pkgOrder && (snList.Contains(q.FLOW_SN) || snList.Contains(q.CUST_SN)))


                                           .Select((q, w) => new { q.PKG_ORDER, q.WORK_ORDER, w.ACT_START_TIME, w.PLAN_START_TIME, q.FLOW_SN, q.CUST_SN }).ToList();


            foreach (var sn in snList)


@@ -898,7 +966,7 @@


        /// <returns></returns>


        public string GenerateSN(string ruleCode, IWorkAction curAction)


        {


            var rule = Biz.CodeRule[ruleCode ?? ""];


            var rule = Cache.CodeRule[ruleCode ?? ""];


            if (!rule.IsNullOrEmpty())


            {


                switch (rule.RULE_CODE)