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 Newtonsoft.Json.Linq;
using System.Collections.Generic;

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)
              .Select((deviceTask, ga) => new DeviceTaskAssignmentResponse
              {
                  DeviceUniqueNo = deviceTask.DeviceUniqueNo,
                  ResultMessage = deviceTask.ResultMessage,
                  RetryCount = deviceTask.Version,
                  Status = deviceTask.Status,
                  UserNo = deviceTask.UserNo,
                  UserName = ga.Name,
                  UserCode = deviceTask.UserCode,
                  Type = deviceTask.Type,
                  LastUpdateTime = deviceTask.ModifiedTime
              })
              .ToPageListAsync(request);
        return page;
    }

}