| | |
| | | .WhereColumns(t => new { t.ORDER_NO, t.GHOST_ROW }) |
| | | .ToStorage(); |
| | | y.AsInsertable.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(); |
| | | 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(); |
| | | }); |
| | |
| | | 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.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()) |
| | | { |
| | |
| | | //如果是下发 |
| | | 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, x.CHANGE_USER,x.CHANGE_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 |
| | | { |
| | |
| | | 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 } : |
| | | 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(predicate) |
| | |
| | | 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(); |
| | | 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 woNode = await Biz.Db.Queryable<MES_WO_NODE>().Where(q => q.WORK_ORDER.Equals(woSn.WORK_ORDER) && q.OPER_CODE== "SpecPackingNode").FirstAsync(); |
| | | 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; |
| | |
| | | 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()) { |
| | | 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()) { |
| | | 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(); |
| | | 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() |
| | |
| | | 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(); |
| | | 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; |
| | |
| | | //判断工单是否已经全部入库 |
| | | |
| | | |
| | | InStoreInfo inStoreInfo = new() { |
| | | ErpProdInBth= new() { |
| | | InStoreInfo inStoreInfo = new() |
| | | { |
| | | ErpProdInBth = new() |
| | | { |
| | | WORK_ORDER = wo.ORDER_NO, |
| | | BATCH_NO = woSns[0].BATCH_NO, |
| | | SALES_ORDER = wo.SALES_ORDER, |
| | |
| | | SCAN_QTY = woSns.Count, |
| | | IS_HANDLED = "N" //Y-已生成,N-未生成,F-失败 |
| | | }, |
| | | InStoreScanInfo = new() { |
| | | InStoreScanInfo = new() |
| | | { |
| | | SN = cartonSn, |
| | | SALES_ORDER = wo.SALES_ORDER, |
| | | WORK_ORDER = wo.ORDER_NO, |
| | |
| | | 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> |
| | | /// 提交前检查是否岗位、工单和不良代码 |