|
|
@@ -25,7 +25,7 @@ public class JobClusterServer : IJobClusterServer
|
|
|
/// <param name="context">作业集群服务上下文</param>
|
|
|
public async void Start(JobClusterContext context)
|
|
|
{
|
|
|
- var _sysJobClusterRep = App.GetService<SqlSugarRepository<SysJobCluster>>();
|
|
|
+ var _sysJobClusterRep = App.GetRequiredService<SqlSugarRepository<SysJobCluster>>();
|
|
|
// 在作业集群表中,如果 clusterId 不存在,则新增一条(否则更新一条),并设置 status 为 ClusterStatus.Waiting
|
|
|
if (await _sysJobClusterRep.IsAnyAsync(u => u.ClusterId == context.ClusterId))
|
|
|
{
|
|
|
@@ -53,11 +53,11 @@ public class JobClusterServer : IJobClusterServer
|
|
|
|
|
|
try
|
|
|
{
|
|
|
- ICache _cache = App.GetService<ICache>();
|
|
|
- //使用分布式锁
|
|
|
+ ICache _cache = App.GetRequiredService<ICache>();
|
|
|
+ // 使用分布式锁
|
|
|
using (_cache.AcquireLock("lock:JobClusterServer:WaitingForAsync", 1000))
|
|
|
{
|
|
|
- var _sysJobClusterRep = App.GetService<SqlSugarRepository<SysJobCluster>>();
|
|
|
+ var _sysJobClusterRep = App.GetRequiredService<SqlSugarRepository<SysJobCluster>>();
|
|
|
// 在这里查询数据库,根据以下两种情况处理
|
|
|
// 1) 如果作业集群表已有 status 为 ClusterStatus.Working 则继续循环
|
|
|
// 2) 如果作业集群表中还没有其他服务或只有自己,则插入一条集群服务或调用 await WorkNowAsync(clusterId); 之后 return;
|
|
|
@@ -79,7 +79,7 @@ public class JobClusterServer : IJobClusterServer
|
|
|
/// <param name="context">作业集群服务上下文</param>
|
|
|
public async void Stop(JobClusterContext context)
|
|
|
{
|
|
|
- var _sysJobClusterRep = App.GetService<SqlSugarRepository<SysJobCluster>>();
|
|
|
+ var _sysJobClusterRep = App.GetRequiredService<SqlSugarRepository<SysJobCluster>>();
|
|
|
// 在作业集群表中,更新 clusterId 的 status 为 ClusterStatus.Crashed
|
|
|
await _sysJobClusterRep.UpdateAsync(u => new SysJobCluster { Status = ClusterStatus.Crashed }, u => u.ClusterId == context.ClusterId);
|
|
|
}
|
|
|
@@ -90,7 +90,7 @@ public class JobClusterServer : IJobClusterServer
|
|
|
/// <param name="context">作业集群服务上下文</param>
|
|
|
public async void Crash(JobClusterContext context)
|
|
|
{
|
|
|
- var _sysJobClusterRep = App.GetService<SqlSugarRepository<SysJobCluster>>();
|
|
|
+ var _sysJobClusterRep = App.GetRequiredService<SqlSugarRepository<SysJobCluster>>();
|
|
|
// 在作业集群表中,更新 clusterId 的 status 为 ClusterStatus.Crashed
|
|
|
await _sysJobClusterRep.UpdateAsync(u => new SysJobCluster { Status = ClusterStatus.Crashed }, u => u.ClusterId == context.ClusterId);
|
|
|
}
|
|
|
@@ -102,7 +102,7 @@ public class JobClusterServer : IJobClusterServer
|
|
|
/// <returns></returns>
|
|
|
private async Task WorkNowAsync(string clusterId)
|
|
|
{
|
|
|
- var _sysJobClusterRep = App.GetService<SqlSugarRepository<SysJobCluster>>();
|
|
|
+ var _sysJobClusterRep = App.GetRequiredService<SqlSugarRepository<SysJobCluster>>();
|
|
|
// 在作业集群表中,更新 clusterId 的 status 为 ClusterStatus.Working
|
|
|
await _sysJobClusterRep.UpdateAsync(u => new SysJobCluster { Status = ClusterStatus.Working }, u => u.ClusterId == clusterId);
|
|
|
}
|