74 lines
2.9 KiB
C#
74 lines
2.9 KiB
C#
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Device.Entities;
|
|
using Dlhis.Entity.Device.Enums;
|
|
using Dlhis.ScheduledTask.TaskAssignment.Request;
|
|
using Dlhis.ScheduledTask.TaskAssignment.Response;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Kurisu.Core.DataAccess.Dto;
|
|
using Kurisu.SqlSugar.Extensions;
|
|
using Kurisu.SqlSugar.Services;
|
|
using SqlSugar;
|
|
|
|
namespace Dlhis.ScheduledTask.TaskAssignment.Services.Implements;
|
|
|
|
public class DeviceTaskAssignmentService : IDeviceTaskAssignmentService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
|
|
public DeviceTaskAssignmentService(IDbContext dbContext)
|
|
{
|
|
_dbContext = dbContext;
|
|
}
|
|
|
|
public async Task<Pagination<DeviceTaskAssignmentResponse>> GetPageAsync(DeviceTaskAssignmentRequest request)
|
|
{
|
|
var page = await _dbContext.Queryable<DeviceTaskEntity>()
|
|
.LeftJoin<GainfoEntity>((deviceTask, ga) => deviceTask.UserNo == ga.No)
|
|
.WhereIF(!request.Search.IsEmpty(), (deviceTask, ga) => deviceTask.UserNo == request.Search || ga.Name.Contains(request.Search))
|
|
.WhereIF(request.Type.HasValue, deviceTask => deviceTask.Type == request.Type)
|
|
.WhereIF(request.Status.HasValue, deviceTask => deviceTask.Status == request.Status)
|
|
.OrderBy(deviceTask => deviceTask.CreateTime, OrderByType.Desc)
|
|
.Select((deviceTask, ga) => new DeviceTaskAssignmentResponse
|
|
{
|
|
Id = deviceTask.Id,
|
|
DeviceUniqueNo = deviceTask.DeviceUniqueNo,
|
|
ResultMessage = deviceTask.ResultMessage,
|
|
RetryCount = deviceTask.Version,
|
|
Status = deviceTask.Status,
|
|
UserNo = deviceTask.UserNo,
|
|
UserName = ga.Name,
|
|
UserCode = ga.Code,
|
|
Type = deviceTask.Type,
|
|
CreateTime = deviceTask.CreateTime,
|
|
LastUpdateTime = deviceTask.ModifiedTime
|
|
})
|
|
.ToPageListAsync(request);
|
|
|
|
return page;
|
|
}
|
|
|
|
public async Task ResetAsync(DeviceTaskResetRequest request)
|
|
{
|
|
var tasks = await _dbContext.Queryable<DeviceTaskEntity>()
|
|
.Where(x => request.Ids.Contains(x.Id))
|
|
.Where(x => x.Status == DeviceTaskStatusEnumType.Process || x.Status == DeviceTaskStatusEnumType.Error)
|
|
.ToListAsync();
|
|
|
|
//判断process任务时间
|
|
if (!request.Force)
|
|
{
|
|
var now = DateTime.Now;
|
|
tasks.Any(x => x.ModifiedTime.AddMinutes(10) < now && x.Status == DeviceTaskStatusEnumType.Process).ThrowIfTrue("请等待任务处理完成");
|
|
}
|
|
|
|
//更新任务状态
|
|
await _dbContext.Updateable<DeviceTaskEntity>()
|
|
.SetColumns(x => x.Status == DeviceTaskStatusEnumType.Wait)
|
|
.Where(x => request.Ids.Contains(x.Id))
|
|
.Where(x => x.Status == DeviceTaskStatusEnumType.Process || x.Status == DeviceTaskStatusEnumType.Error)
|
|
.ExecuteCommandAsync();
|
|
}
|
|
}
|
|
|
|
|