| | |
| | | } |
| | | 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; |