| | |
| | | .GroupBy(x => new { x.DocNo }) |
| | | .Select(x => new BIZ_WMS_TRANSFER |
| | | { |
| | | ORDER_NO = x.Key.DocNo, //单据号 |
| | | ORDER_NO = x.Key.DocNo, //调拨单号 |
| | | ORDER_DATE = x.Max(t => t.BusinessDate), //单据日期 |
| | | STATUS = BIZ_WMS_TRANSFER.STATUSs.Init.GetValue(), //状态 |
| | | //OUT_WH_CODE 调出仓库 |
| | |
| | | IN_WH_CODE = item.TransInWhCode, // 拨入仓库 |
| | | OUT_LOTNO = item.LotCode,// 调出批次 -- 批次 |
| | | IN_LOTNO = item.LotCode, // 拨入批次 -- 批次 |
| | | //SOURCE_CODE = item.BenefitDept,// 来源单据编码,多个用“,”分隔 |
| | | //SOURCE_ORDER = item.BenefitDeptName, // 来源单行号,多个用“,”分隔,跟编码一一对应 |
| | | //SOURCE_LINE = item.ReturnStorageReason,// |
| | | //SOURCE_CODE = item.BenefitDept,// 来源单据编码 |
| | | SOURCE_ORDER = item.TransferInId.ToString(), // 来源单行号-- 单头ID |
| | | SOURCE_LINE = item.DocLineNo.ToString(),// 来源单行号 ---行号 |
| | | // ERP_ORDER = item.InStorageReason, // ERP单据号码 |
| | | //REMARK 备注 |
| | | //REMARK 备注 |
| | | AUTH_ORG = orgs.FirstOrDefault(q => q.ID == org.Org.ToString())?.ORG_CODE, //组织 |
| | | CREATE_TIME = item.ModifiedOn,//--时间不更新 |
| | | CREATE_USER = UserCode, |
| | | CREATE_TIME = item.CreatedOn,//--时间不更新 |
| | | CREATE_USER = item.CreatedBy, |
| | | UPDATE_TIME = item.ModifiedOn, |
| | | UPDATE_USER = UserCode, |
| | | }; |
| | |
| | | .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.ORDER_NO, q.ORDER_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, q.HANDLED, q.HANDLED_DATE, }).ExecuteCommand(); |
| | | y.AsUpdateable.IgnoreColumns(x => x.ID).UpdateColumns(q => new {q.ORDER_NO, q.ORDER_DATE, q.STATUS,q.SOURCE_CODE,q.SOURCE_ORDER,q.HANDLED,q.HANDLED_DATE, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER,}).ExecuteCommand(); |
| | | }); |
| | | } |
| | | |
| | |
| | | .WhereColumns(t => new { t.ORDER_NO, t.ORDER_LINE, t.GHOST_ROW }) |
| | | .ToStorage(); |
| | | y.AsInsertable.ExecuteCommand(); |
| | | y.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO, q.ORDER_LINE, q.STATUS, q.ITEM_CODE, q.UNIT, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER }).ExecuteCommand(); |
| | | y.AsUpdateable.UpdateColumns(q => new { q.ORDER_NO, q.ORDER_LINE, q.STATUS, q.ITEM_CODE, q.UNIT, q.QTY_REQ,q.QTY_OUT,q.OUT_WH_CODE,q.IN_WH_CODE,q.OUT_LOTNO,q.IN_LOTNO, q.AUTH_ORG, q.CREATE_USER, q.UPDATE_TIME, q.UPDATE_USER, }).ExecuteCommand(); |
| | | }); |
| | | } |
| | | Logger.Scheduler.Info($"调拨单据表头信息存入数据库,总数:[{resultDt.Count}]"); |