jinko.yikatong/Src/Dlhis.ScheduledTask/DeviceUploadLog/Services/Implements/DeviceUploadLogService.cs

using Dlhis.Entity.Basic.Entity;
using Dlhis.Entity.Device.Entities;
using Dlhis.ScheduledTask.DeviceUploadLog.Request;
using Dlhis.ScheduledTask.DeviceUploadLog.Response;
using Kurisu.AspNetCore.Utils.Extensions;
using Kurisu.Core.DataAccess.Dto;
using Kurisu.SqlSugar.Attributes;
using Kurisu.SqlSugar.Extensions;
using Kurisu.SqlSugar.Services;

namespace Dlhis.ScheduledTask.DeviceUploadLog.Services.Implements;

public class DeviceUploadLogService : IDeviceUploadLogService
{
    private readonly IDbContext _dbContext;

    public DeviceUploadLogService(IDbContext dbContext)
    {
        _dbContext = dbContext;
    }

    public async Task<Pagination<DeviceUploadLogResponse>> GetPageAsync(DeviceUploadLogPageRequest request)
    {
        var page = await _dbContext.Queryable<DeviceUploadLogEntity>()
            .LeftJoin<GainfoEntity>((deviceUp, ga) => deviceUp.UserNo == ga.No)
            .WhereIF(request.SearchDateTimePeriod?.Start.HasValue == true, deviceUp => deviceUp.UploadTime >= request.SearchDateTimePeriod.Start)
            .WhereIF(request.SearchDateTimePeriod?.End.HasValue == true, deviceUp => deviceUp.UploadTime <= request.SearchDateTimePeriod.End)
            .Select((deviceUp, ga) => new DeviceUploadLogResponse
            {
                DeviceUniqueNo = deviceUp.DeviceUniqueNo,
                Id = deviceUp.Id,
                Ip = deviceUp.Ip,
                UploadTime = deviceUp.UploadTime,
                UserNo = deviceUp.UserNo,
                UserCode = deviceUp.UserCode,
                UserName = ga.Name,
            })
            .ToPageListAsync(request);

        return page;
    }

    [IgnoreTenant]
    public async Task UploadLogAsync(DeviceUploadLogUploadRequest request)
    {
        var device = await _dbContext.Queryable<DeviceEntity>().Where(x => x.UniqueNo == request.DeviceUniqueNo).SingleAsync();
        device.ThrowIfNull("设备信息不存在");

        var gainfo = await _dbContext.Queryable<GainfoEntity>().Where(x => x.Code == request.UserCode).FirstAsync();
        device.ThrowIfNull("人员信息不存在");

        var entity = new DeviceUploadLogEntity
        {
            DeviceUniqueNo = request.DeviceUniqueNo,
            UploadTime = request.UploadTime,
            UserCode = request.UserCode,
            UserNo = gainfo.No,
            TenantId = device.TenantId,
        };

        await _dbContext.InsertAsync(entity);
    }
}