admin/raven
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
John Cardinal
2020-05-25 21:16:04 +00:00
parent 125caee9dc
commit ea65e63d1c
1 changed files with 11 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
server/AyaNova/biz/JobsBiz.cs
View File

@@ -23,11 +23,11 @@ namespace AyaNova.Biz
/// Get a non tracked list of jobs for an object /// Get a non tracked list of jobs for an object
/// </summary> /// </summary>
/// <param name="ayObj"></param> /// <param name="ayObj"></param>
/// ///
/// <returns></returns> /// <returns></returns>
internal static async Task<List<OpsJob>> GetJobsForObjectAsync(AyaTypeId ayObj) internal static async Task<List<OpsJob>> GetJobsForObjectAsync(AyaTypeId ayObj)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
return await ct.OpsJob return await ct.OpsJob
.AsNoTracking() .AsNoTracking()
.Where(z => z.ObjectId == ayObj.ObjectId && z.ObjectType == ayObj.ObjectType) .Where(z => z.ObjectId == ayObj.ObjectId && z.ObjectType == ayObj.ObjectType)
@@ -63,7 +63,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
private static async Task<List<OpsJob>> GetReadyJobsAsync(bool exclusiveOnly) private static async Task<List<OpsJob>> GetReadyJobsAsync(bool exclusiveOnly)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
var ret = await ct.OpsJob var ret = await ct.OpsJob
.AsNoTracking() .AsNoTracking()
.Where(z => z.StartAfter < System.DateTime.UtcNow && z.Exclusive == exclusiveOnly && z.JobStatus == JobStatus.Sleeping) .Where(z => z.StartAfter < System.DateTime.UtcNow && z.Exclusive == exclusiveOnly && z.JobStatus == JobStatus.Sleeping)
@@ -81,7 +81,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
internal static async Task<List<OpsJob>> GetAllSleepingOrRunningJobsAsync() internal static async Task<List<OpsJob>> GetAllSleepingOrRunningJobsAsync()
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
var ret = await ct.OpsJob var ret = await ct.OpsJob
.AsNoTracking() .AsNoTracking()
.Where(z => z.JobStatus == JobStatus.Sleeping || z.JobStatus == JobStatus.Running) .Where(z => z.JobStatus == JobStatus.Sleeping || z.JobStatus == JobStatus.Running)
@@ -98,7 +98,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
internal static async Task<List<OpsJob>> GetAllJobsForJobTypeAsync(JobType jobType) internal static async Task<List<OpsJob>> GetAllJobsForJobTypeAsync(JobType jobType)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
var ret = await ct.OpsJob var ret = await ct.OpsJob
.AsNoTracking() .AsNoTracking()
.Where(z => z.JobType == jobType) .Where(z => z.JobType == jobType)
@@ -115,7 +115,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
internal static async Task<List<OpsJob>> GetPotentiallyDeadRunningJobsAsync() internal static async Task<List<OpsJob>> GetPotentiallyDeadRunningJobsAsync()
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
var ret = await ct.OpsJob var ret = await ct.OpsJob
.AsNoTracking() .AsNoTracking()
.Where(z => z.JobStatus == JobStatus.Sleeping || z.JobStatus == JobStatus.Running) .Where(z => z.JobStatus == JobStatus.Sleeping || z.JobStatus == JobStatus.Running)
@@ -132,7 +132,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
internal static async Task<long> GetCountForJobStatusAsync(JobStatus jobStatus) internal static async Task<long> GetCountForJobStatusAsync(JobStatus jobStatus)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
var ret = await ct.OpsJob var ret = await ct.OpsJob
.Where(z => z.JobStatus == jobStatus) .Where(z => z.JobStatus == jobStatus)
.LongCountAsync(); .LongCountAsync();
@@ -149,7 +149,7 @@ namespace AyaNova.Biz
/// <returns></returns> /// <returns></returns>
internal static async Task<OpsJob> AddJobAsync(OpsJob newJob) internal static async Task<OpsJob> AddJobAsync(OpsJob newJob)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;
await ct.OpsJob.AddAsync(newJob); await ct.OpsJob.AddAsync(newJob);
await ct.SaveChangesAsync(); await ct.SaveChangesAsync();
return newJob; return newJob;
@@ -159,7 +159,6 @@ namespace AyaNova.Biz
/// Remove any jobs or logs for the object in question /// Remove any jobs or logs for the object in question
/// </summary> /// </summary>
/// <param name="ayObj"></param> /// <param name="ayObj"></param>
///
internal static async Task DeleteJobsForObjectAsync(AyaTypeId ayObj) internal static async Task DeleteJobsForObjectAsync(AyaTypeId ayObj)
{ {
//Get a list of all jobid's for the object passed in //Get a list of all jobid's for the object passed in
@@ -206,7 +205,7 @@ namespace AyaNova.Biz
/// </summary> /// </summary>
/// <param name="jobId">(NOTE: Guid.empty indicates internal job)</param> /// <param name="jobId">(NOTE: Guid.empty indicates internal job)</param>
/// <param name="statusText"></param> /// <param name="statusText"></param>
/// ///
internal static async Task<OpsJobLog> LogJobAsync(Guid jobId, string statusText) internal static async Task<OpsJobLog> LogJobAsync(Guid jobId, string statusText)
{ {
var ct = ServiceProviderProvider.DBContext; var ct = ServiceProviderProvider.DBContext;