| | |
| | | } |
| | | Logger.Scheduler.Info($"物料信息存入实体中,总数:[{items.Count}]"); |
| | | db = Biz.Db; |
| | | var dbTran = db.UseTran(() => |
| | | { |
| | | //var dbTran = db.UseTran(() => |
| | | //{ |
| | | if (items.Any()) |
| | | { |
| | | if (items.Count > 100) |
| | |
| | | s.AsUpdateable.IgnoreColumns(x => x.ID).ExecuteCommand(); |
| | | } |
| | | } |
| | | }); |
| | | if (!dbTran.IsSuccess) |
| | | { |
| | | action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | Logger.Scheduler.Error(action.Message); |
| | | } |
| | | //}); |
| | | //if (!dbTran.IsSuccess) |
| | | //{ |
| | | // action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | // Logger.Scheduler.Error(action.Message); |
| | | //} |
| | | Logger.Scheduler.Info($"物料信息存入数据库,总数:[{items.Count}]"); |
| | | action.Message = $"物料信息存入数据库,总数:[{items.Count}]"; |
| | | return action; |
| | |
| | | } |
| | | Logger.Scheduler.Info($"客户信息存入实体中,总数:[{items.Count}]"); |
| | | db = Biz.Db; |
| | | var dbTran = db.UseTran(() => |
| | | { |
| | | //var dbTran = db.UseTran(() => |
| | | // { |
| | | if (items.Any()) |
| | | { |
| | | if (items.Count > 100) |
| | |
| | | } |
| | | } |
| | | |
| | | }); |
| | | if (!dbTran.IsSuccess) |
| | | { |
| | | action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | Logger.Scheduler.Error(action.Message); |
| | | } |
| | | // }); |
| | | //if (!dbTran.IsSuccess) |
| | | //{ |
| | | // action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | // Logger.Scheduler.Error(action.Message); |
| | | //} |
| | | Logger.Scheduler.Info($"客户信息存入数据库,总数:[{items.Count}]"); |
| | | action.Message = $"客户信息存入数据库,总数:[{items.Count}]"; |
| | | return action; |
| | |
| | | } |
| | | Logger.Scheduler.Info($"供应商信息存入实体中,总数:[{items.Count}]"); |
| | | db = Biz.Db; |
| | | var dbTran = db.UseTran(() => |
| | | { |
| | | if (items.Any()) |
| | | //var dbTran = db.UseTran(() => |
| | | // { |
| | | if (items.Any()) |
| | | { |
| | | if (items.Count > 100) |
| | | { |
| | |
| | | } |
| | | } |
| | | |
| | | }); |
| | | if (!dbTran.IsSuccess) |
| | | { |
| | | action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | Logger.Scheduler.Error(action.Message); |
| | | } |
| | | //}); |
| | | //if (!dbTran.IsSuccess) |
| | | //{ |
| | | // action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败"); |
| | | // Logger.Scheduler.Error(action.Message); |
| | | //} |
| | | Logger.Scheduler.Info($"供应商信息存入数据库,总数:[{items.Count}]"); |
| | | action.Message = $"供应商信息存入数据库,总数:[{items.Count}]"; |
| | | return action; |
| | |
| | | UPDATE_TIME = di["ModifiedOn"].ToDateTime(), |
| | | PLAN_START_TIME = di["CreatedOn"].ToDateTime(), |
| | | STATUS = 0, |
| | | WS_CODE = di["DepartmentName"] == null ? "" : di["DepartmentName"].ToString(), |
| | | AUTH_ORG = orgs.Where(x => x.ID == orgId).Select(q => q.ORG_CODE).FirstOrDefault(), |
| | | SALES_ORDER = di["SrcDoc_SrcDocNo"] == null ? "" : di["SrcDoc_SrcDocNo"].ToString(), |
| | | SALES_REMARK = di["SoLineMemo"] == null ? "" : di["SoLineMemo"].ToString(), |