修改为 先升级A两次,后再升级 B两次,循环往复
This commit is contained in:
@@ -33,25 +33,42 @@ namespace BLW_Log.services
|
||||
request.AddParameter("hostid_lists", "[24540]");
|
||||
request.AddParameter("upgradefileName", "C1F_A_L4_41_250605_NM.bin");
|
||||
var response = await client.ExecutePostAsync(request);
|
||||
_logger.Error("ShengJiCaoZuoB 执行结果:" + response.Content);
|
||||
_logger.Error("ShengJiCaoZuo 研发测试房型_1 执行结果:" + response.Content);
|
||||
|
||||
// 直接启动JobB
|
||||
var jobA = JobBuilder.Create<ShengJiCaoZuoA>().Build();
|
||||
var triggerA = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
ShengJiCaoZuoBCount = ShengJiCaoZuoBCount + 1;
|
||||
if (ShengJiCaoZuoBCount >= 2)
|
||||
{
|
||||
|
||||
await context.Scheduler.ScheduleJob(jobA, triggerA);
|
||||
// 直接启动JobA
|
||||
var jobA = JobBuilder.Create<ShengJiCaoZuoA>().Build();
|
||||
var triggerA = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
|
||||
await context.Scheduler.ScheduleJob(jobA, triggerA);
|
||||
}
|
||||
else
|
||||
{
|
||||
// 直接启动JobB
|
||||
var jobA = JobBuilder.Create<ShengJiCaoZuoB>().Build();
|
||||
var triggerA = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
|
||||
await context.Scheduler.ScheduleJob(jobA, triggerA);
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.Error("ShengJiCaoZuoB 执行失败:" + ex.Message);
|
||||
}
|
||||
}
|
||||
public static int ShengJiCaoZuoBCount = 0;
|
||||
}
|
||||
public class ShengJiCaoZuoA : IJob
|
||||
{
|
||||
|
||||
public static int ShengJiCaoZuoACount = 0;
|
||||
private readonly Logger _logger = LogManager.GetCurrentClassLogger();
|
||||
private readonly Dictionary<string, IRestClient> _clients;
|
||||
|
||||
@@ -82,14 +99,27 @@ namespace BLW_Log.services
|
||||
request.AddParameter("hostid_lists", "[24540]");
|
||||
request.AddParameter("upgradefileName", "C1F_A_L4_31_240723_NM.bin");
|
||||
var response = await client.ExecutePostAsync(request);
|
||||
_logger.Error("ShengJiCaoZuoA 执行成功:" + response.Content);
|
||||
_logger.Error("ShengJiCaoZuo YHF_T 执行成功:" + response.Content);
|
||||
|
||||
var jobB = JobBuilder.Create<ShengJiCaoZuoB>().Build();
|
||||
var triggerB = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
ShengJiCaoZuoACount = ShengJiCaoZuoACount + 1;
|
||||
|
||||
await context.Scheduler.ScheduleJob(jobB, triggerB);
|
||||
if (ShengJiCaoZuoACount >= 2)
|
||||
{
|
||||
var jobB = JobBuilder.Create<ShengJiCaoZuoB>().Build();
|
||||
var triggerB = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
|
||||
await context.Scheduler.ScheduleJob(jobB, triggerB);
|
||||
}
|
||||
else
|
||||
{
|
||||
var jobA = JobBuilder.Create<ShengJiCaoZuoA>().Build();
|
||||
var triggerA = TriggerBuilder.Create()
|
||||
.StartAt(DateTimeOffset.Now.AddMinutes(10))
|
||||
.Build();
|
||||
await context.Scheduler.ScheduleJob(jobA, triggerA);
|
||||
}
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user