284 lines
13 KiB
C#
284 lines
13 KiB
C#
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Basic.Enums;
|
|
using Dlhis.Entity.Device.Entities;
|
|
using Dlhis.Entity.Device.Enums;
|
|
using Dlhis.Jip.Api;
|
|
using Dlhis.Jip.Api.Requests;
|
|
using Dlhis.ScheduledTask.DeviceUploadLog.Request;
|
|
using Dlhis.ScheduledTask.DeviceUploadLog.Response;
|
|
using Kurisu.AspNetCore.Authentication.Abstractions;
|
|
using Kurisu.AspNetCore.CustomClass;
|
|
using Kurisu.AspNetCore.DataAccess.Dto;
|
|
using Kurisu.AspNetCore.DataAccess.SqlSugar.Services;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using SqlSugar;
|
|
|
|
namespace Dlhis.ScheduledTask.DeviceUploadLog.Services.Implements;
|
|
|
|
public class DeviceUploadLogService : IDeviceUploadLogService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ICurrentUser _currentUser;
|
|
private readonly IJinkoJipApi _jinkoJipApi;
|
|
|
|
public DeviceUploadLogService(IDbContext dbContext, ICurrentUser currentUser, IJinkoJipApi jinkoJipApi)
|
|
{
|
|
_dbContext = dbContext;
|
|
_currentUser = currentUser;
|
|
_jinkoJipApi = jinkoJipApi;
|
|
}
|
|
|
|
public async Task UploadLogsAsync(List<DeviceUploadLogUploadRequest> requests)
|
|
{
|
|
var deviceUniqueNos = requests.Select(x => x.DeviceUniqueNo).Distinct().ToList();
|
|
var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => deviceUniqueNos.Contains(x.UniqueNo)).ToListAsync();
|
|
var existsDeviceUniqueNos = devices.Select(x => x.UniqueNo).ToList();
|
|
|
|
var userCodes = requests.Where(x => x.UserUniqueNo.IsPresent()).Select(x => x.UserUniqueNo).Distinct().ToList();
|
|
var gainfo1 = await _dbContext.Queryable<GainfoEntity>().Where(x => userCodes.Contains(x.Code)).Select(x => new { x.Code, x.Type }).ToListAsync();
|
|
var gainfo2 = await _dbContext.Queryable<GainfoEntity>().AS("GainfoLeave").Where(x => userCodes.Contains(x.Code)).Select(x => new { x.Code, x.Type }).ToListAsync();
|
|
var gainfos = gainfo1.Concat(gainfo2).DistinctBy(x => x.Code).ToList();
|
|
|
|
var inserts = new List<DeviceUploadLogEntity>();
|
|
foreach (var request in requests.Where(x => existsDeviceUniqueNos.Contains(x.DeviceUniqueNo)))
|
|
{
|
|
if (await _dbContext.Queryable<DeviceUploadLogEntity>().Where(x => x.DeviceUniqueNo == request.DeviceUniqueNo
|
|
&& x.SerialNo == request.SerialNo
|
|
&& x.RaiseDateTime == request.RaiseDateTime).AnyAsync())
|
|
{
|
|
continue;
|
|
}
|
|
|
|
if (request.CardNo.IsPresent() && request.UserUniqueNo != request.CardNo)
|
|
{
|
|
//UserUniqueNo为老系统档案号(自动生成),CardNo为工号
|
|
if (await _dbContext.Queryable<OldDeviceGainfoEntity>()
|
|
.Where(x => x.DeviceUniqueNo == request.DeviceUniqueNo)
|
|
.Where(x => x.No == request.UserUniqueNo && x.Code == request.CardNo)
|
|
.Select(x => x.Code)
|
|
.AnyAsync())
|
|
{
|
|
request.UserUniqueNo = request.CardNo;
|
|
}
|
|
}
|
|
|
|
var device = devices.First(x => x.UniqueNo == request.DeviceUniqueNo);
|
|
|
|
var userType = gainfos.FirstOrDefault(x => x.Code == request.UserUniqueNo)?.Type;
|
|
var needUpload = userType == GainfoUserTypeEnumType.Normal && (device.Type == DeviceTypeEnumType.Attendance || (device.Type == DeviceTypeEnumType.Door && device.AsAttendance));
|
|
var dataType = device.Type == DeviceTypeEnumType.Attendance
|
|
? DeviceUploadLogTypeEnumType.Attendance
|
|
: DeviceUploadLogTypeEnumType.Door;
|
|
inserts.Add(new DeviceUploadLogEntity
|
|
{
|
|
DeviceCode = device.Code,
|
|
DeviceUniqueNo = request.DeviceUniqueNo,
|
|
UserUniqueNo = request.UserUniqueNo,
|
|
UserType = userType,
|
|
RaiseDateTime = request.RaiseDateTime,
|
|
SerialNo = request.SerialNo ?? string.Empty,
|
|
Type = dataType,
|
|
NeedUpload = needUpload,
|
|
TenantId = device.TenantId,
|
|
Status = request.Status ?? true,
|
|
Image = request.Image,
|
|
CreatedBy = 1,
|
|
ModifiedBy = 1
|
|
});
|
|
}
|
|
|
|
await _dbContext.InsertAsync(inserts);
|
|
}
|
|
|
|
|
|
public async Task<List<DeviceUploadLogResponse>> GetMyRecordsAsync(DeviceUploadLogMyRecordRequest request)
|
|
{
|
|
var jinkoCode = _currentUser.GetUserClaim("jinko-code") ?? string.Empty;
|
|
|
|
return await _dbContext.Queryable<DeviceUploadLogEntity>()
|
|
.LeftJoin<DeviceEntity>((log, d) => log.DeviceUniqueNo == d.UniqueNo)
|
|
.Where(log => log.UserUniqueNo == jinkoCode)
|
|
.Where(log => log.Status)
|
|
.WhereIF(request.DateTimePeriod.HasValue(), log => log.RaiseDateTime >= request.DateTimePeriod.Start && log.RaiseDateTime <= request.DateTimePeriod.End)
|
|
.Where((log, d) => d.Type == DeviceTypeEnumType.Attendance || (d.Type == DeviceTypeEnumType.Door && d.AsAttendance))
|
|
.OrderBy(log => log.RaiseDateTime)
|
|
.Select((log, d) => new DeviceUploadLogResponse
|
|
{
|
|
OriginUserUniqueNo = log.UserUniqueNo,
|
|
DeviceUniqueNo = log.DeviceUniqueNo,
|
|
Id = log.Id,
|
|
RaiseDateTime = log.RaiseDateTime,
|
|
CreateTime = log.CreateTime,
|
|
SerialNo = log.SerialNo,
|
|
DeployPlace = d.DeployPlace,
|
|
Sync = log.Sync,
|
|
Status = log.Status
|
|
})
|
|
.ToListAsync();
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task ManuallyUploadAsync(List<long> requestIds)
|
|
{
|
|
var existsOther = await _dbContext.Queryable<DeviceUploadLogEntity>()
|
|
.Where(x => requestIds.Contains(x.Id))
|
|
.Where(x => x.Type != DeviceUploadLogTypeEnumType.Attendance)
|
|
.AnyAsync();
|
|
|
|
existsOther.ThrowIfTrue("存在非考勤通行记录,无法上传");
|
|
|
|
var requests = await _dbContext.Queryable<DeviceUploadLogEntity>()
|
|
.LeftJoin<DeviceEntity>((x, device) => x.DeviceUniqueNo == device.UniqueNo)
|
|
.Where(x => x.Sync == false)
|
|
.Where(x => !string.IsNullOrEmpty(x.UserUniqueNo))
|
|
.Where(x => SqlFunc.Subqueryable<OutsourceEntity>().Where(p => p.Code == x.UserUniqueNo).NotAny())
|
|
.Where(x => requestIds.Contains(x.Id))
|
|
.Select((x, device) => new UploadAttendanceRequestItem
|
|
{
|
|
Id = x.Id,
|
|
RaiseDateTime = x.RaiseDateTime,
|
|
ZNOTE = device.DeployPlace,
|
|
ZWORKCODE = x.UserUniqueNo
|
|
})
|
|
.ToListAsync();
|
|
|
|
if (requests.Any())
|
|
{
|
|
foreach (var items in requests.Chunk(500))
|
|
{
|
|
var ids = items.Select(x => x.Id).ToList();
|
|
var r = await _jinkoJipApi.UploadAttendancesAsync(new UploadAttendanceRequest { Data = items.ToList() });
|
|
if (r.OLX == "0")
|
|
{
|
|
await _dbContext.Updateable<DeviceUploadLogEntity>()
|
|
.SetColumns(x => x.Sync == true)
|
|
.SetColumns(x => x.ModifiedTime == DateTime.Now)
|
|
.Where(x => ids.Contains(x.Id))
|
|
.ExecuteCommandAsync();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task ManuallySetTimeInfoAsync(string deviceNo, DateTime start, DateTime end)
|
|
{
|
|
var device = await _dbContext.Queryable<DeviceEntity>().Where(x => x.UniqueNo == deviceNo).SingleAsync();
|
|
(device.Type != DeviceTypeEnumType.Attendance && device.Type != DeviceTypeEnumType.Door).ThrowIfTrue("不支持该设备类型");
|
|
var exists = await _dbContext.Queryable<DeviceUploadLogManuallyEntity>().Where(x => x.DeviceNo == deviceNo).Where(x => x.IsFinished == false).AnyAsync();
|
|
exists.ThrowIfTrue("已存在配置尚未完成");
|
|
|
|
await _dbContext.InsertAsync(new DeviceUploadLogManuallyEntity
|
|
{
|
|
DeviceNo = deviceNo,
|
|
Start = start,
|
|
End = end,
|
|
IsFinished = false
|
|
});
|
|
}
|
|
|
|
public async Task QiaoqiaoGaoshiqingAsync(DeviceUploadLogSecretAddRequest request)
|
|
{
|
|
var device = await _dbContext.Queryable<DeviceEntity>().Where(x => x.UniqueNo == request.DeviceUniqueNo).SingleAsync();
|
|
|
|
await _dbContext.InsertAsync(new DeviceUploadLogEntity
|
|
{
|
|
DeviceUniqueNo = device.UniqueNo,
|
|
UserUniqueNo = request.UserCode,
|
|
RaiseDateTime = request.RaiseDateTime,
|
|
SerialNo = string.Empty,
|
|
Type = device.Type == DeviceTypeEnumType.Attendance
|
|
? DeviceUploadLogTypeEnumType.Attendance
|
|
: device.Type == DeviceTypeEnumType.Door && device.AsAttendance
|
|
? DeviceUploadLogTypeEnumType.Attendance
|
|
: DeviceUploadLogTypeEnumType.Door,
|
|
|
|
TenantId = device.TenantId,
|
|
Status = true,
|
|
CreatedBy = 1,
|
|
ModifiedBy = 1
|
|
});
|
|
}
|
|
|
|
public async Task<DateTimePeriod> GetDeviceUploadRecordSettingAsync(string deviceNo)
|
|
{
|
|
var start = await _dbContext.Queryable<DeviceUploadLogEntity>()
|
|
.Where(x => x.DeviceUniqueNo == deviceNo)
|
|
.Select(x => SqlFunc.AggregateMax(x.RaiseDateTime))
|
|
.SingleAsync();
|
|
|
|
//0001-01-01 00:00:00
|
|
return new DateTimePeriod
|
|
{
|
|
Start = start,
|
|
End = DateTime.Now.AddDays(1)
|
|
};
|
|
}
|
|
|
|
public async Task<Pagination<DeviceUploadLogResponse>> GetPageAsync(DeviceUploadLogPageRequest request)
|
|
{
|
|
DeviceUploadLogTypeEnumType? type = request.Type switch
|
|
{
|
|
DeviceTypeEnumType.Attendance => DeviceUploadLogTypeEnumType.Attendance,
|
|
DeviceTypeEnumType.Door => DeviceUploadLogTypeEnumType.Door,
|
|
_ => throw new UserFriendlyException("不支持当前设备类型")
|
|
};
|
|
|
|
var userType = request.IsOutsource.HasValue && request.IsOutsource.Value
|
|
? GainfoUserTypeEnumType.Outsource
|
|
: GainfoUserTypeEnumType.Normal;
|
|
|
|
if (request.UserType.HasValue)
|
|
{
|
|
userType = request.UserType.Value;
|
|
}
|
|
|
|
var r = await _dbContext.Queryable<DeviceUploadLogEntity>()
|
|
.LeftJoin<DeviceEntity>((x, device) => x.DeviceUniqueNo == device.UniqueNo)
|
|
.LeftJoin<GainfoEntity>((x, device, ga) => x.UserUniqueNo == ga.Code)
|
|
.LeftJoin<OutsourceEntity>((x, device, ga, os) => x.UserUniqueNo == os.Code)
|
|
.LeftJoin<GainfoEntity>((x, device, ga, os, gaSap) => gaSap.Code == os.SapCode)
|
|
.WhereIF(request.SearchDateTimePeriod.HasValue(), x => x.RaiseDateTime >= request.SearchDateTimePeriod.Start
|
|
&& x.RaiseDateTime <= request.SearchDateTimePeriod.End)
|
|
.Where((x, device) => x.Type == type && x.UserType == userType)
|
|
.WhereIF(request.Sync.HasValue, x => x.Sync == request.Sync)
|
|
.WhereIF(request.Search.IsPresent() && userType == GainfoUserTypeEnumType.Outsource, (x, device, ga, os) =>
|
|
x.UserUniqueNo == request.Search
|
|
|| x.DeviceUniqueNo == request.Search
|
|
|| os.Supplier == request.Search
|
|
|| os.SapCode == request.Search
|
|
)
|
|
.WhereIF(request.Search.IsPresent() && userType != GainfoUserTypeEnumType.Outsource, (x, device, ga, os) =>
|
|
x.UserUniqueNo == request.Search
|
|
|| x.DeviceUniqueNo == request.Search
|
|
)
|
|
.OrderBy(x => x.RaiseDateTime, OrderByType.Desc)
|
|
.Select((x, device, ga, os, gaSap) => new DeviceUploadLogResponse
|
|
{
|
|
Id = x.Id,
|
|
OriginUserUniqueNo = x.UserUniqueNo,
|
|
OutsourceSupplier = os.Supplier,
|
|
SapUserCode = os.SapCode,
|
|
SapUserName = gaSap.Name,
|
|
DeviceUniqueNo = x.DeviceUniqueNo,
|
|
RaiseDateTime = x.RaiseDateTime,
|
|
CreateTime = x.CreateTime,
|
|
SerialNo = x.SerialNo,
|
|
UserNo = ga.No,
|
|
UserCode = ga.Code,
|
|
UserName = ga.Name,
|
|
DeployPlace = device.DeployPlace,
|
|
NeedUpload = x.NeedUpload,
|
|
Sync = x.Sync,
|
|
Status = x.Status,
|
|
}).ToPageListAsync(request.PageIndex, request.PageSize);
|
|
|
|
return new Pagination<DeviceUploadLogResponse>
|
|
{
|
|
PageIndex = request.PageIndex,
|
|
PageSize = request.PageSize,
|
|
Total = 0,
|
|
Data = r
|
|
};
|
|
}
|
|
} |