1
This commit is contained in:
@@ -76,7 +76,6 @@ namespace Tnb.WarehouseMgr
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}, stoppingToken);
|
}, stoppingToken);
|
||||||
|
|
||||||
var timedTask = Task.Run(() =>
|
var timedTask = Task.Run(() =>
|
||||||
@@ -101,7 +100,7 @@ namespace Tnb.WarehouseMgr
|
|||||||
var transferSignService = App.GetRequiredService<IWmsPDATransferSignService>();
|
var transferSignService = App.GetRequiredService<IWmsPDATransferSignService>();
|
||||||
TimedTask(cts => transferSignService.IsMinStorage(cts), isMinStorageCts, 30, TimeSpanUnit.Minutes);
|
TimedTask(cts => transferSignService.IsMinStorage(cts), isMinStorageCts, 30, TimeSpanUnit.Minutes);
|
||||||
|
|
||||||
});
|
}, stoppingToken);
|
||||||
|
|
||||||
return Task.WhenAll(queueTask, timedTask);
|
return Task.WhenAll(queueTask, timedTask);
|
||||||
}
|
}
|
||||||
@@ -134,12 +133,12 @@ namespace Tnb.WarehouseMgr
|
|||||||
}));
|
}));
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
await Task.Delay(1000);
|
await TaskDelay(timeType, interval);
|
||||||
}
|
}
|
||||||
}, token);
|
}, token);
|
||||||
}
|
}
|
||||||
|
|
||||||
private Task GetDelayTask(TimeSpanUnit timeType, int interval)
|
private Task TaskDelay(TimeSpanUnit timeType, int interval)
|
||||||
{
|
{
|
||||||
Task delayTask = timeType switch
|
Task delayTask = timeType switch
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user