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


@@ -16,6 +16,11 @@


using Tiger.Model.Entitys.MES.Position;


using Microsoft.AspNetCore.Mvc.RazorPages;


using System.Drawing.Printing;


using System.Net.NetworkInformation;


using Tiger.Model.MES.Yada;


using static Microsoft.CodeAnalysis.CSharp.SyntaxTokenParser;


using Tiger.Model.Minsun;


using Tiger.Model.Entitys.MES.U9C;




namespace Tiger.Business.MES


{


@@ -127,20 +132,30 @@


                    return result;


                }


                var batchs = await Biz.Db.Queryable<BIZ_MES_WO_BATCH>().Where(x => x.ORDER_NO == input.Wo.ORDER_NO).ToListAsync();


                if ((batchs.Count > 0 && batchs.Sum(x => x.PLAN_QTY) + input.WoBatch.PLAN_QTY > _wo.PLAN_QTY) || input.WoBatch.PLAN_QTY > _wo.PLAN_QTY)


                if (batchs.Count > 0)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"工单下发的数量超过工单计划数量，不能下发！");


                    return result;


                }


                var _batch = Biz.Db.Queryable<BIZ_MES_WO_BATCH>().Where(x => x.ORDER_NO == input.Wo.ORDER_NO && x.ACT_LINE == input.WoBatch.ACT_LINE && x.STATUS < BIZ_MES_WO.STATUSs.Closed.GetValue()).First();


                if (_batch != null)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"工单[{input.Wo.ORDER_NO}]已经存在工单批次[{_batch.BATCH_NO}]在线体[{input.WoBatch.ACT_LINE}]中状态为[{_batch.STATUS.GetEnumDesc<BIZ_MES_WO.STATUSs>()}]，不能下发！");


                    return result;


                    if ((batchs.Sum(x => x.PLAN_QTY) + input.WoBatch.PLAN_QTY > _wo.PLAN_QTY) || input.WoBatch.PLAN_QTY > _wo.PLAN_QTY)


                    {


                        result.IsSuccessed = false;


                        result.LocaleMsg = new($"工单下发的数量超过工单计划数量，不能下发！");


                        return result;


                    }


                    if (batchs.Any(x => x.ORDER_NO == input.Wo.ORDER_NO && x.ACT_LINE == input.WoBatch.ACT_LINE && x.STATUS < BIZ_MES_WO.STATUSs.Closed.GetValue()))


                    {


                        result.IsSuccessed = false;


                        result.LocaleMsg = new($"工单[{input.Wo.ORDER_NO}]已经有批次存在线体[{input.WoBatch.ACT_LINE}]中，而且状态不为关闭，不能下发！");


                        return result;


                    }


                    if (batchs.Any(x => x.ORDER_NO == input.Wo.ORDER_NO && x.STATUS == BIZ_MES_WO.STATUSs.Init.GetValue() && SqlFunc.DateIsSame(x.PLAN_DATE, DateTime.Now)))


                    {


                        result.IsSuccessed = false;


                        result.LocaleMsg = new($"工单[{input.Wo.ORDER_NO}]已经有批次存在计划日期相同，而且状态为[初始化]，请转到工单批次中下发！");


                        return result;


                    }


                }


                //WoContext.RemoveBatch(input.WoBatch.BATCH_NO);


                input.WoBatch.PLAN_DATE = DateTime.Now;


                input.Wo.PLAN_DATE = (input.Wo.PLAN_DATE ?? "") + ((input.Wo.PLAN_DATE ?? "").Contains(input.WoBatch.PLAN_DATE.ToString("yyyy-MM-dd")) ? "" : $",{input.WoBatch.PLAN_DATE.ToString("yyyy-MM-dd")}");


                input.Wo.ACT_LINE = input.WoBatch.ACT_LINE;


                input.Wo.RELEASE_TIME = DateTime.Now;


                input.Wo.RELEASE_USER = input.WoBatch.UPDATE_USER;


@@ -162,7 +177,7 @@


                       .WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW })


                       .ToStorage();


                    y.AsInsertable.ExecuteCommand();


                    y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();


                    y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new { q.STATUS, q.PLAN_DATE, q.ACT_LINE, q.RELEASE_TIME, q.RELEASE_USER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand();




                    db.Insertable(input.WoBatch).ExecuteCommand();


                });


@@ -182,7 +197,6 @@


                            pars[1].Direction = System.Data.ParameterDirection.Output;


                            pars[2].Direction = System.Data.ParameterDirection.Output;


                            Biz.Db.Ado.UseStoredProcedure().ExecuteCommand("SP_MES_WO2CUST", pars);


                            //response.LocaleMsg = new(pars[2].Value.ToString());


                            if (pars[1].Value.ToInt32() == 0)


                            {


                                Logger.Default.Info($"工单[{input.Wo.ORDER_NO}]下发完成后保存工艺路线数据到产品[{input.Wo.ITEM_CODE}]的客户[{input.Wo.CUST_CODE ?? ""}]的工艺路线中，{pars[2].Value.ToString()}");


@@ -221,6 +235,8 @@


                var _wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(x => x.ORDER_NO == input.WorkOrder).FirstAsync();


                if (_wo != null)


                {


                    _wo.CHANGE_TIME = _wo.STATUS == BIZ_MES_WO.STATUSs.Paused.GetValue() && input.Status == BIZ_MES_WO.STATUSs.Working.GetValue() ? DateTime.Now : _wo.CHANGE_TIME;


                    _wo.CHANGE_USER = _wo.STATUS == BIZ_MES_WO.STATUSs.Paused.GetValue() && input.Status == BIZ_MES_WO.STATUSs.Working.GetValue() ? input.UserId : _wo.CHANGE_USER;


                    _wo.STATUS = input.Status < 0 ? _wo.STATUS : input.Status;


                    _wo.ROUTE_STATUS = input.RouteStatus;


                }


@@ -265,6 +281,8 @@


                var _woBatch = await Biz.Db.Queryable<BIZ_MES_WO_BATCH>().Where(x => x.BATCH_NO == input.WoBatch).FirstAsync();


                if (_woBatch != null)


                {


                    _woBatch.CHANGE_TIME = _woBatch.STATUS == BIZ_MES_WO_BATCH.STATUSs.Paused.GetValue() && input.Status == BIZ_MES_WO_BATCH.STATUSs.Working.GetValue() ? DateTime.Now : _woBatch.CHANGE_TIME;


                    _woBatch.CHANGE_USER = _woBatch.STATUS == BIZ_MES_WO_BATCH.STATUSs.Paused.GetValue() && input.Status == BIZ_MES_WO_BATCH.STATUSs.Working.GetValue() ? input.UserId : _woBatch.CHANGE_USER;


                    _woBatch.STATUS = input.Status < 0 ? _woBatch.STATUS : input.Status;


                    if (input.Status == BIZ_MES_WO_BATCH.STATUSs.Paused.GetValue())


                    {


@@ -282,6 +300,16 @@


                        _woBatch.RELEASE_TIME = DateTime.Now;


                        _woBatch.RELEASE_USER = input.UserId;


                        _woBatch.ACT_LINE = input.ActLine;


                        _woBatch.CHANGE_USER = input.UserId;


                        _woBatch.CHANGE_TIME = DateTime.Now;


                        _wo.STATUS = BIZ_MES_WO.STATUSs.Release.GetValue();


                    }


                    else


                    {


                        if (input.Status == BIZ_MES_WO_BATCH.STATUSs.Init.GetValue() && !Biz.Db.Queryable<BIZ_MES_WO_BATCH>().Where(x => x.ORDER_NO == input.WorkOrder && x.BATCH_NO != input.WoBatch && x.STATUS > BIZ_MES_WO_BATCH.STATUSs.Init.GetValue()).Any())


                        {


                            _wo.STATUS = BIZ_MES_WO.STATUSs.Init.GetValue();


                        }


                    }


                }


                else


@@ -297,11 +325,15 @@


                    //如果是下发


                    if (input.Status == BIZ_MES_WO_BATCH.STATUSs.Release.GetValue())


                    {


                        db.Updateable(_woBatch, input.UserId).UpdateColumns(x => new { x.STATUS, x.RELEASE_USER, x.RELEASE_TIME, x.ACT_LINE, x.UPDATE_USER, x.UPDATE_TIME }).ExecuteCommand();


                        db.Updateable(_woBatch, input.UserId).UpdateColumns(x => new { x.STATUS, x.RELEASE_USER, x.RELEASE_TIME, x.ACT_LINE, x.UPDATE_USER, x.UPDATE_TIME, x.CHANGE_USER, x.CHANGE_TIME }).ExecuteCommand();


                    }


                    else


                    {


                        db.Updateable(_woBatch, input.UserId).UpdateColumns(x => new { x.STATUS, x.UPDATE_USER, x.UPDATE_TIME }).ExecuteCommand();


                        db.Updateable(_woBatch, input.UserId).UpdateColumns(x => new { x.STATUS, x.UPDATE_USER, x.UPDATE_TIME, x.CHANGE_USER, x.CHANGE_TIME }).ExecuteCommand();


                    }


                    if (!_wo.IsNullOrEmpty())


                    {


                        db.Updateable(_wo, input.UserId).UpdateColumns(x => new { x.STATUS, x.UPDATE_USER, x.UPDATE_TIME }).ExecuteCommand();


                    }


                });


                if (!dbTran.IsSuccess)


@@ -328,25 +360,34 @@


            try


            {


                //保存前的判断


                if (input.WORK_ORDER.IsNullOrEmpty())


                if (input.WORK_ORDER.IsNullOrEmpty() && input.PROD_CODE.IsNullOrEmpty())


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"工单号不能为空！");


                    result.LocaleMsg = new($"工单号或者产品编码不能为空！");


                    return result;


                }


                List<BAS_LABEL_VAR_WO> varWoList = new();


                if (File.Exists(input.LABEL_VIEW_PATH))


                string imageFileName = Path.GetFileNameWithoutExtension(input.LABEL_VIEW_PATH);


                string path = @$"{BizConfig.Configuration["UploadAddress"]}//Upload/Template//Temp//{imageFileName}.png";


                if (File.Exists(path))


                {


                    string imageFileName = Path.GetFileNameWithoutExtension(input.LABEL_VIEW_PATH);


                    string? path = Path.GetDirectoryName(input.LABEL_VIEW_PATH);


                    input.LABEL_VIEW_PATH = $"{path}//Temp//{imageFileName}.png";


                    varWoList = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(x => x.LABEL_ID == input.LABEL_ID && x.WORK_ORDER == input.WORK_ORDER).ToListAsync();


                    varWoList = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>()


                        .Where(x => x.LABEL_ID == input.LABEL_ID)


                        .WhereIF(!input.WORK_ORDER.IsNullOrEmpty(), x => x.WORK_ORDER == input.WORK_ORDER)


                        .WhereIF(!input.PROD_CODE.IsNullOrEmpty(), x => x.PROD_CODE == input.PROD_CODE)


                        .ToListAsync();


                    foreach (var item in varWoList)


                    {


                        item.LABEL_VIEW_PATH = $"{BizConfig.Configuration["DownloadAddress"]}//Template//Temp//{imageFileName}.png";


                    }


                }


                var db = Biz.Db;


                var dbTran = db.UseTran(() =>


                {


                    Expression<Func<BAS_LABEL_VAR_WO, object>> predicate = !input.WORK_ORDER.IsNullOrEmpty() ? t => new { t.LABEL_ID, t.WORK_ORDER, t.VAR_NAME, t.GHOST_ROW } :


                    !input.PROD_CODE.IsNullOrEmpty() ? t => new { t.LABEL_ID, t.PROD_CODE, t.VAR_NAME, t.GHOST_ROW } : t => new { t.LABEL_ID, t.VAR_NAME, t.GHOST_ROW };


                    var y = db.Storageable(input)


                       .WhereColumns(t => new { t.LABEL_ID, t.WORK_ORDER, t.VAR_NAME, t.GHOST_ROW })


                       .WhereColumns(predicate)


                       .ToStorage();


                    y.AsInsertable.ExecuteCommand();


                    y.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand();


@@ -380,12 +421,12 @@


            try


            {


                QueryAble<BAS_LABEL_VAR_WO> query = new();


                if (input.WorkOrder.IsNullOrEmpty())


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"工单号不能为空！");


                    return result;


                }


                //if (input.WorkOrder.IsNullOrEmpty())


                //{


                //    result.IsSuccessed = false;


                //    result.LocaleMsg = new($"工单号不能为空！");


                //    return result;


                //}


                var labeltemp = Biz.Db.Queryable<BAS_LABEL_TEMP>().Where(q => q.LABEL_CODE.Equals(input.LabelId) || q.ID.Equals(input.LabelId)).First();


                if (labeltemp == null)


                {


@@ -393,13 +434,24 @@


                    result.LocaleMsg = new($"模板不存在！");


                    return result;


                }


                var lableVars = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(q => SqlFunc.IsNullOrEmpty(q.WORK_ORDER) && q.LABEL_ID.Equals(labeltemp.ID)).ToListAsync();


                var queryable = Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(q => q.WORK_ORDER.Equals(input.WorkOrder) && q.LABEL_ID.Equals(labeltemp.ID));


                query.page = await queryable.ToPageAsync(input.pageIndex, input.pageSize);


                var lableVars = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(q => SqlFunc.IsNullOrEmpty(q.WORK_ORDER)


                && SqlFunc.IsNullOrEmpty(q.PROD_CODE)


                && SqlFunc.IsNullOrEmpty(q.CUST_CODE)


                && q.LABEL_ID.Equals(labeltemp.ID)).ToListAsync();


                var queryable = Biz.Db.Queryable<BAS_LABEL_VAR_WO>()


                    .Where(q => q.LABEL_ID.Equals(labeltemp.ID))


                    .WhereIF(!input.WorkOrder.IsNullOrEmpty(), q => q.WORK_ORDER.Equals(input.WorkOrder))


                    .WhereIF(!input.ProdCode.IsNullOrEmpty(), q => q.PROD_CODE.Equals(input.ProdCode))


                    .WhereIF(!input.CustCode.IsNullOrEmpty(), q => q.PROD_CODE.Equals(input.CustCode));


                query.page = await queryable.ToPageAsync(input.page, input.pageSize);


                //如果不存在，则返回初始数据


                if (query.page.totals == 0)


                {


                    query.page = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(q => SqlFunc.IsNullOrEmpty(q.WORK_ORDER) && q.LABEL_ID.Equals(labeltemp.ID)).ToPageAsync(input.pageIndex, input.pageSize);


                    query.page = await Biz.Db.Queryable<BAS_LABEL_VAR_WO>().Where(q => SqlFunc.IsNullOrEmpty(q.WORK_ORDER)


                     && SqlFunc.IsNullOrEmpty(q.PROD_CODE)


                     && SqlFunc.IsNullOrEmpty(q.CUST_CODE)


                     && q.LABEL_ID.Equals(labeltemp.ID))


                     .ToPageAsync(input.page, input.pageSize);


                    query.Items = query.page.data;


                }


                //如果初始变量数大于工单设置的变量数


@@ -409,11 +461,15 @@


                    {


                        if (queryable.ToList().Any(q => q.VAR_NAME == item.VAR_NAME))


                        {


                            var list = queryable.ToList().Where(q => q.VAR_NAME == item.VAR_NAME).First();


                            item.ID = list?.ID;


                            item.WORK_ORDER = input.WorkOrder;


                            item.VAR_VALUE = queryable.ToList().Where(q => q.VAR_NAME == item.VAR_NAME).First()?.VAR_VALUE;


                            item.PROD_CODE = input.ProdCode;


                            item.VAR_VALUE = list?.VAR_VALUE;


                            item.LABEL_VIEW_PATH = list?.LABEL_VIEW_PATH;


                        }


                    }


                    query.Items = lableVars.Skip((input.pageIndex - 1) * input.pageSize).Take(input.pageSize).ToList();


                    query.Items = lableVars.Skip((input.page - 1) * input.pageSize).Take(input.pageSize).ToList();


                    query.page.totals = lableVars.Count;


                    query.page.data = query.Items;


                }


@@ -425,5 +481,400 @@


            }


            return result;


        }




        /// <summary>


        /// 更新行为中的箱号


        /// </summary>


        /// <param name="code"></param>


        /// <returns></returns>


        public async Task<ApiAction> SavePrintLabelInAct(string code)


        {


            var result = new ApiAction();


            try


            {


                var woSn = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN == code || q.FLOW_SN == code || q.OUTER_SN == code).FirstAsync();


                if (woSn == null)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"条码不存在！");


                    return result;


                }


                //取得包装列表


                var pkgList = Biz.Db.Queryable<MES_WIP_PKG>().Where(q => q.PARENT_SN == woSn.OUTER_SN && q.OPER_CODE == "SpecPackingNode").ToList();


                if (pkgList.Count == 0)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"条码不存在！");


                    return result;


                }


                List<MES_WIP_ACT> actlist = new List<MES_WIP_ACT>();


                //客户标签


                var wipAct = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.CARTON_SN == woSn.OUTER_SN && q.NODE_ID == pkgList[0].NODE_ID && !SqlFunc.IsNullOrEmpty(q.ACT_VALUE_3)).First();


                if (!wipAct.IsNullOrEmpty())


                {


                    var label = JsonConvert.DeserializeObject<BAS_LABEL_TEMP>(wipAct.ACT_VALUE_3);


                    var cardNo = label.Variables.Where(q => q.VAR_NAME == "CardQR").FirstOrDefault();


                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !cardNo.IsNullOrEmpty() && !cardNo.Value.StartsWith(woSn.OUTER_SN))


                    {


                        cardNo.Value = $"{woSn.OUTER_SN}{cardNo.Value}";


                    }


                    string ACT_VALUE_3 = JsonConvert.SerializeObject(label);


                    foreach (var pkg in pkgList)


                    {


                        var actSn = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.WIP_ID == pkg.WIP_ID && q.NODE_ID == pkg.NODE_ID && q.ACT_VALUE_4 == "Customer").First();


                        if (!actSn.IsNullOrEmpty())


                        {


                            actSn.ACT_VALUE_3 = ACT_VALUE_3;


                            actlist.Add(actSn);


                        }


                    }


                }


                //入库标签


                var wipActInStore = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.SN == woSn.SN && q.NODE_ID == pkgList[0].NODE_ID && !SqlFunc.IsNullOrEmpty(q.ACT_VALUE_3) && q.ACT_VALUE_4 == "InStore").First();


                if (!wipActInStore.IsNullOrEmpty())


                {


                    var label = JsonConvert.DeserializeObject<BAS_LABEL_TEMP>(wipActInStore.ACT_VALUE_3);


                    var cardNo = label.Variables.Where(q => q.VAR_NAME == "CardQR").FirstOrDefault();


                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !cardNo.IsNullOrEmpty() && !cardNo.Value.StartsWith(woSn.OUTER_SN))


                    {


                        cardNo.Value = $"{woSn.OUTER_SN}{cardNo.Value}";


                    }


                    var xh = label.Variables.Where(q => q.VAR_NAME == "XH").FirstOrDefault();


                    if (!woSn.OUTER_SN.IsNullOrEmpty() && !xh.IsNullOrEmpty())


                    {


                        xh.Value = $"{woSn.OUTER_SN}";


                    }


                    string ACT_VALUE_3 = JsonConvert.SerializeObject(label);


                    foreach (var pkg in pkgList)


                    {


                        var actSn = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.WIP_ID == pkg.WIP_ID && q.NODE_ID == pkg.NODE_ID && q.ACT_VALUE_4 == "InStore").First();


                        if (!actSn.IsNullOrEmpty())


                        {


                            actSn.ACT_VALUE_3 = ACT_VALUE_3;


                            actlist.Add(actSn);


                        }


                    }


                }


                var db = Biz.Db;


                var dbTran = db.UseTran(() =>


                {


                    db.Updateable(actlist).UpdateColumns(q => new { q.ACT_VALUE_3 }).ExecuteCommand();


                });


                if (!dbTran.IsSuccess)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"更新行为日志中的箱号异常");


                }


            }


            catch (Exception ex)


            {


                result.CatchExceptionWithLog(ex, "更新行为日志中的箱号异常");


            }


            return result;


        }




        /// <summary>


        /// 获取重打标签信息


        /// </summary>


        /// <param name="input"></param>


        /// <returns></returns>


        public async Task<ApiAction> GetRePrintInfo(RePrintInput input)


        {


            var result = new ApiAction();


            try


            {


                //先查出工单条码中是否存在


                var outerSn = input.Code.Split('|')[0];


                var woSn = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN.Equals(input.Code) || q.FLOW_SN.Equals(input.Code) || q.OUTER_SN == outerSn).FirstAsync();


                if (woSn == null)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"条码不存在！");


                    return result;


                }


                var woNode = await Biz.Db.Queryable<MES_WO_NODE>().Where(q => q.WORK_ORDER.Equals(woSn.WORK_ORDER) && q.OPER_CODE == "SpecPackingNode").FirstAsync();


                if (woNode == null)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"工艺路线节点[SpecPackingNode-装箱]不存在");


                    return result;


                }


                string printParam = "";


                var labelPrint = await Biz.Db.Queryable<LOG_LABEL_PRINT>()


                    .WhereIF(input.ReqType == 0, q => q.SN.Equals(woSn.SN) || q.SN.Equals(woSn.FLOW_SN)) //白盒标签


                    .WhereIF(input.ReqType == 1, q => q.SN.Equals(woSn.OUTER_SN) && q.PRINT_LABEL != "InStoreLabel") //箱标签-客户


                    .WhereIF(input.ReqType == 2, q => q.SN.Equals(woSn.OUTER_SN) && q.PRINT_LABEL == "InStoreLabel") //箱标签-入库


                    .FirstAsync();


                //如果查不到就去行为日志查


                if (labelPrint.IsNullOrEmpty() && input.ReqType == 1)


                {


                    printParam = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.CARTON_SN.Equals(woSn.OUTER_SN) && q.ACT_VALUE_4 == "Customer" && !SqlFunc.IsNullOrEmpty(q.ACT_VALUE_3)).First()?.ACT_VALUE_3 ?? "";


                }


                else if (labelPrint.IsNullOrEmpty() && input.ReqType == 2)


                {


                    printParam = Biz.Db.Queryable<MES_WIP_ACT>().Where(q => q.SN.Equals(woSn.SN) && q.ACT_VALUE_4 == "InStore").First()?.ACT_VALUE_3 ?? "";


                }


                else


                {


                    printParam = labelPrint?.PRINT_PARAM ?? "";


                }


                result.Data = printParam;


                result.LocaleMsg = new($"重打条码[{input.Code}]的标签成功");


            }


            catch (Exception ex)


            {


                result.CatchExceptionWithLog(ex, "获取重打标签信息异常");


            }


            return result;


        }




        /// <summary>


        /// 获取出货信息


        /// </summary>


        /// <param name="wo"></param>


        /// <returns></returns>


        public async Task<ApiAction<ShippingOutput>> GetShipList(ShippingInput input)


        {


            var result = new ApiAction<ShippingOutput>();


            try


            {


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


                var org = await Biz.Db.Queryable<SYS_ORGANIZATION>().Where(q => q.ORG_CODE == input.orgCode).FirstAsync();


                string wo = input.wo;


                if (!input.SN.IsNullOrEmpty() && input.wo.IsNullOrEmpty())


                {


                    var woSn = Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.SN == input.SN || q.FLOW_SN == input.SN).First();


                    if (!woSn.IsNullOrEmpty())


                    {


                        wo = woSn.WORK_ORDER;


                    }


                }


                var ship = db.Queryable<mes_ShipList>().Where(q => q.MoDoc.Equals(wo) && q.Org == org.ID.ToInt64() && q.Status == 2).First();


                if (!ship.IsNullOrEmpty())


                {


                    result.Data = ship.BusinessDate.Date == DateTime.Now.Date ? new()


                    {


                        ShipDoc = ship.ShipDoc,


                        ShippingQty = ship.ShipQty.ToDouble(),


                        Tag = "Customer"


                    } : new()


                    {


                        ShipDoc = ship.ShipDoc,


                        ShippingQty = ship.ShipQty.ToDouble(),


                        Tag = "InStoreLabel"


                    };


                    result.LocaleMsg = new($"出货信息存在！");


                }


                else


                {


                    result.Data = new()


                    {


                        ShipDoc = "",


                        ShippingQty = 0,


                        Tag = "InStoreLabel"


                    };


                }


            }


            catch (Exception ex)


            {


                result.CatchExceptionWithLog(ex, "获取出货信息异常");


            }


            return result;


        }




        /// <summary>


        /// 


        /// </summary>


        /// <param name="SN"></param>


        /// <param name="user"></param>


        /// <returns></returns>


        public async Task<ApiAction> UnbindWipSnFromWO(UnbindWipSnInput input)


        {


            var result = new ApiAction();


            try


            {


                var cartonSn = input.SN.Split('|')[0];


                var wipList = await Biz.Db.Queryable<MES_WIP_DATA>().Where(q => q.SN.Equals(input.SN) || q.FLOW_SN.Equals(input.SN) || q.CARTON_SN == cartonSn).ToListAsync();


                if (wipList.Count == 0)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"解绑的条码不存在当前操作表中！");


                    return result;


                }


                var wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == wipList[0].WORK_ORDER).FirstAsync();


                result = WorkBatch.UnbindWipSnFromWO(wo, wipList, input.user);


                if (result.IsSuccessed)


                {


                    var newList = await Biz.Db.Queryable<MES_WIP_PKG>().Where(q => q.WORK_ORDER == wo.ORDER_NO && q.BATCH_NO == wipList[0].BATCH_NO && SqlFunc.IsNullOrEmpty(q.PARENT_SN) && q.QTY > 0).ToListAsync();


                    result.Data = newList;


                }


            }


            catch (Exception ex)


            {


                result.CatchExceptionWithLog(ex, "解绑条码异常");


            }


            return result;


        }




        /// <summary>


        /// 生成入库获取条码工单信息及包装信息


        /// </summary>


        /// <param name="code"></param>


        /// <returns></returns>


        public async Task<ApiAction<InStoreInfo>> GetErpProdInBth(string code)


        {


            var result = new ApiAction<InStoreInfo>();


            try


            {


                //得到工单条码记录


                var cartonSn = code.Split('|')[0];


                var woSns = await Biz.Db.Queryable<BIZ_MES_WO_SN>().Where(q => q.OUTER_SN == cartonSn).ToListAsync();


                if (woSns.Count == 0)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"条码不存在！");


                    return result;


                }


                var wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == woSns[0].WORK_ORDER).IncludesAllFirstLayer().IncludesAllSecondLayer(q => q._ItemInfos).FirstAsync();


                if (wo == null)


                {


                    result.IsSuccessed = false;


                    result.LocaleMsg = new($"条码对应的工单不存在");


                    return result;


                }


                //判断工单是否已经全部入库






                InStoreInfo inStoreInfo = new()


                {


                    ErpProdInBth = new()


                    {


                        WORK_ORDER = wo.ORDER_NO,


                        BATCH_NO = woSns[0].BATCH_NO,


                        SALES_ORDER = wo.SALES_ORDER,


                        ITEM_CODE = wo.ITEM_CODE,


                        ITEM_NAME = wo.ItemInfo?.ITEM_DESC,


                        SapCode = wo.ItemInfo?.ExtInfo?.SapCode,


                        SCAN_QTY = woSns.Count,


                        IS_HANDLED = "N" //Y-已生成，N-未生成，F-失败


                    },


                    InStoreScanInfo = new()


                    {


                        SN = cartonSn,


                        SALES_ORDER = wo.SALES_ORDER,


                        WORK_ORDER = wo.ORDER_NO,


                        BATCH_NO = woSns[0].BATCH_NO,


                        SCAN_QTY = woSns.Count


                    }


                };


                result.Data = inStoreInfo;


                result.LocaleMsg = new($"获取条码[{code}]工单信息及包装信息成功");


            }


            catch (Exception ex)


            {


                result.CatchExceptionWithLog(ex, $"获取条码[{code}]工单信息及包装信息异常");


            }


            return result;


        }




        /// <summary>


        /// 获取工单备料信息


        /// </summary>


        /// <param name="code"></param>


        /// <returns></returns>


        public async Task<ApiAction<List<WoFlowCardPrintJson>>> GetWoPickList(string code)


        {


            var action = new ApiAction<List<WoFlowCardPrintJson>>($"成功", new List<WoFlowCardPrintJson>());


            try


            {


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


                var moPickLists = db.Queryable<mes_MOPickList>().Where(q => q.MoDocNo == code).ToList();


                var ids = moPickLists.Select(x => SqlFunc.ToString(x.ItemMaster)).ToList();


                var items = Biz.Db.Queryable<BAS_ITEM>().Where(q => ids.Contains(q.ID)).IncludesAllFirstLayer().ToList();


                var wo = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == code).IncludesAllFirstLayer().FirstAsync();


                SugarParameter[] pars = Biz.Db.Ado.GetParameters(new { WO = code });


                var routeList = Biz.Db.Ado.UseStoredProcedure().SqlQuery<V_MES_WO_PTREE>("SP_MES_GET_WO_PTREE", pars);//返回List


                var routeStr = string.Join("->", routeList.Where(q => q.type == "Node" && q.name != "完工").OrderBy(x=>x.seq).Select(q=>q.name).ToList());


                List<WoFlowCardPrintJson> woFlowCardPrintJson = new();


                //生成打印实体


                int i = 1;


                WoFlowCardPrintJson printJson = new()


                {


                    ID = Guid.NewGuid().ToString("N"),


                    OrderNo = code,


                    ItemCode = wo.ITEM_CODE,


                    ItemDesc = wo.ItemInfo?.ITEM_DESC,


                    SapCode = wo.ItemInfo?.ExtInfo?.SapCode,


                    Qty = wo.PLAN_QTY,


                    Model = "",


                    Remark = wo.SALES_REMARK,


                    RouteStr = routeStr,


                    Items = new() { }


                };


                foreach (var item in moPickLists)


                {


                    PrintWoPickList list = new()


                    {


                        LineNo = item.DocLineNO,


                        SapCode = items.Where(q=> q.ID == SqlFunc.ToString(item.ItemMaster)).FirstOrDefault()?.ExtInfo?.SapCode,


                        ItemCode = item.Code,


                        ItemDesc = items.Where(q => q.ID == SqlFunc.ToString(item.ItemMaster)).FirstOrDefault()?.ITEM_DESC,


                        PickQty = item.ActualReqQty,


                        LineRemark = "",


                        WhCode = item.BinCode,


                        WhCode07 = item.WhCode == "10107" ? item.BinCode : "",


                        Method = item.IssueStyleName,


                    };


                    printJson.Items.Add(list);


                    if (i % 6 == 0)


                    {


                        woFlowCardPrintJson.Add(printJson);


                        printJson = new()


                        {


                            ID = Guid.NewGuid().ToString("N"),


                            OrderNo = code,


                            ItemCode = wo.ITEM_CODE,


                            ItemDesc = wo.ItemInfo?.ITEM_DESC,


                            SapCode = wo.ItemInfo?.ExtInfo?.SapCode,


                            Qty = wo.PLAN_QTY,


                            Model = "",


                            Remark = wo.SALES_REMARK,


                            RouteStr = routeStr,


                            Items = new() { }


                        };


                    }


                    i++;


                }


                action.Data = woFlowCardPrintJson;


            }


            catch (Exception ex)


            {


                action.CatchExceptionWithLog(ex, $"获取工单{code}备料信息异常");


            }


            return action;


        }




        #region 提交前通用方法


        /// <summary>


        /// 提交前检查是否岗位、工单和不良代码


        /// </summary>


        /// <param name="code"></param>


        /// <returns></returns>


        public async Task<ApiAction<CheckCodeOutput>> CheckCode(string code)


        {


            var action = new ApiAction<CheckCodeOutput>($"检查条码{code}成功", new CheckCodeOutput());


            try


            {


                action.Data.Position = DbCache.Cache.Position[code];


                action.Data.WorkOrder = await Biz.Db.Queryable<BIZ_MES_WO>().Where(q => q.ORDER_NO == code).FirstAsync();


                action.Data.Defect = DbCache.Cache.Defect[code];


            }


            catch (Exception ex)


            {


                action.CatchExceptionWithLog(ex, $"检查条码{code}异常");


            }


            return action;


        }


        #endregion


    }


}