Browse Source

同步

master
赵新宇 3 weeks ago
parent
commit
8bdedf4ba3
  1. 3
      API/Wood.Admin.WebApi/Startup.cs
  2. 2
      API/Wood.Service/Controllers/CheryRecurringJobInputPageController.cs
  3. 7
      API/Wood.Service/Controllers/CheryRecurringJobOutPageController.cs

3
API/Wood.Admin.WebApi/Startup.cs

@ -419,6 +419,7 @@ namespace Wood.Admin.WebApi
app.UseEndpoints(endpoints => app.UseEndpoints(endpoints =>
{ {
endpoints.MapControllerRoute("default", "{controller=ApiHome}/{action=Index}/{id?}"); endpoints.MapControllerRoute("default", "{controller=ApiHome}/{action=Index}/{id?}");
endpoints.MapFallbackToFile("Index.Html");
}); });
//启用 自动job //启用 自动job
@ -437,7 +438,7 @@ namespace Wood.Admin.WebApi
{ {
c.RoutePrefix = "api-doc"; c.RoutePrefix = "api-doc";
foreach (var assembly in assembly) foreach (var assembly in assembly)
c.SwaggerEndpoint(assembly.GetName().Name + "/swagger.json", "Wood Api " + assembly.GetName().Name); c.SwaggerEndpoint(assembly.GetName().Name + "/swagger.json", "TaskManager" + assembly.GetName().Name);
}); });
//自动 注册所有事件 //自动 注册所有事件
app.UseEventBus(assembly); app.UseEventBus(assembly);

2
API/Wood.Service/Controllers/CheryRecurringJobInputPageController.cs

@ -146,7 +146,7 @@ namespace TaskManager.Controllers
await _logger.AddError("任务名称或客户端不能为空",taskName); await _logger.AddError("任务名称或客户端不能为空",taskName);
return; return;
} }
var sublist = _jobDbContext.TaskSub.Where(p => p.TaskName == taskName && p.WriteState == false && p.Subscriber == client ).ToList(); var sublist = _jobDbContext.TaskSub.Where(p => taskName.Contains(p.TaskName) && p.WriteState == false && p.Subscriber == client ).ToList();
int pageSize = 1000; int pageSize = 1000;
if (!sublist.Any()) if (!sublist.Any())
{ {

7
API/Wood.Service/Controllers/CheryRecurringJobOutPageController.cs

@ -48,7 +48,12 @@ namespace TaskManager.Controllers
var tran = transaction.GetDbTransaction(); var tran = transaction.GetDbTransaction();
try try
{ {
_jobDbContext.BulkInsert(list); await _jobDbContext.BulkInsertAsync(list);
//_jobDbContext.BulkMerge(list, options => {
// options.ColumnPrimaryKeyExpression = p => p.Id;
//});
await ConfirmDataInsertAsync(list, _jobDbContext, tran); await ConfirmDataInsertAsync(list, _jobDbContext, tran);
// 提交事务 // 提交事务

Loading…
Cancel
Save