Browse Source

请求重试作业

master
mahao 2 years ago
parent
commit
9e34710082
  1. 2
      src/WmsWebApi.Application/Boms/BomService.cs
  2. 2
      src/WmsWebApi.Application/PPlan/PPlanService.cs
  3. 2
      src/WmsWebApi.Application/ProductRecieve/ProductRecieveService.cs
  4. 2
      src/WmsWebApi.Application/StockMove/StockMoveService.cs
  5. 2
      src/WmsWebApi.Application/TbParts/PartService.cs
  6. 5
      src/WmsWebApi.Application/ZlldcjLogs/ZlldcjLogAppService.cs
  7. 6
      src/WmsWebApi.EntityFrameworkCore/EntityFrameworkCore/WmsWebApiDbContextModelCreatingExtensions.cs

2
src/WmsWebApi.Application/Boms/BomService.cs

@ -214,7 +214,7 @@ public class BomService : ApplicationService, IBomService
if (IsRequestRetry == false)
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.BomAdd, content.ToString());
//await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.BomAdd, content.ToString());
}
throw new Exception($"接口异常,请稍后重试:{ex.GetBaseException().Message}", ex);

2
src/WmsWebApi.Application/PPlan/PPlanService.cs

@ -181,7 +181,7 @@ public class PPlanService : ApplicationService, IPPlanService
if (IsRequestRetry == false)
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.PPlanAdd, content.ToString());
//await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.PPlanAdd, content.ToString());
}
throw new Exception($"接口异常,请稍后重试:{ex.GetBaseException().Message}", ex);

2
src/WmsWebApi.Application/ProductRecieve/ProductRecieveService.cs

@ -266,7 +266,7 @@ public class ProductRecieveService : ApplicationService, IProductRecieveService
if (IsRequestRetry == false)
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.ProductRecieveAdd, content.ToString());
//await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.ProductRecieveAdd, content.ToString());
}
throw new Exception($"接口异常,请稍后重试:{ex.GetBaseException().Message}", ex);

2
src/WmsWebApi.Application/StockMove/StockMoveService.cs

@ -395,7 +395,7 @@ public class StockMoveService : ApplicationService, IStockMoveService
if (IsRequestRetry == false)
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.StockMoveAdd, content.ToString());
//await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.StockMoveAdd, content.ToString());
}
throw new Exception($"接口异常,请稍后重试:{ex.GetBaseException().Message}", ex);

2
src/WmsWebApi.Application/TbParts/PartService.cs

@ -284,7 +284,7 @@ public class PartService : ApplicationService, IPartService
if (IsRequestRetry == false)
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.PartAdd, content.ToString());
//await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.PartAdd, content.ToString());
}
throw new Exception($"接口异常,请稍后重试:{ex.GetBaseException().Message}", ex);

5
src/WmsWebApi.Application/ZlldcjLogs/ZlldcjLogAppService.cs

@ -213,7 +213,7 @@ public class ZlldcjLogAppService : ApplicationService, IZlldcjLogAppService
{
item.IType = ex.GetBaseException().Message;
}
throw new Exception("操作数据库失败,请稍后重试。", ex);
throw;
}
finally
{
@ -244,8 +244,7 @@ public class ZlldcjLogAppService : ApplicationService, IZlldcjLogAppService
{
await _backgroundJobRequestRetry.AddBackgroundJobAsync(EnumActionName.ZlldcjLogAdd, content.ToString());
}
throw;
throw new Exception("操作数据库失败,稍后系统自动重试。", ex);
}
finally
{

6
src/WmsWebApi.EntityFrameworkCore/EntityFrameworkCore/WmsWebApiDbContextModelCreatingExtensions.cs

@ -537,9 +537,9 @@ namespace WmsWebApi.EntityFrameworkCore
{
b.ToTable("WmsWebApiPURCHASEDTO", WmsWebApiDbProperties.DbSchema);
b.ConfigureByConvention();
b.Property(q => q.MBLNR).IsRequired().HasMaxLength(10);
b.Property(q => q.MJAHR).IsRequired().HasMaxLength(10);
b.Property(q => q.BUDAT).IsRequired();
b.Property(q => q.MBLNR).IsRequired().HasMaxLength(20);
b.Property(q => q.MJAHR).IsRequired().HasMaxLength(20);
b.Property(q => q.BUDAT).IsRequired().HasMaxLength(20);
b.Property(q => q.JSON);
b.Property(q => q.DYSJ);
b.Property(q => q.ITYPE);

Loading…
Cancel
Save