288 lines
13 KiB
C#
288 lines
13 KiB
C#
using Dlhis.Basic.Common.ApiLog.Services;
|
|
using Dlhis.Basic.WorkGrids.Request;
|
|
using Dlhis.Basic.WorkGrids.Response;
|
|
using Dlhis.Constants;
|
|
using Dlhis.Entity.Basic.Entity;
|
|
using Dlhis.Entity.Basic.Enums;
|
|
using Dlhis.Entity.Common.Enums;
|
|
using Kurisu.AspNetCore.Authentication.Abstractions;
|
|
using Kurisu.AspNetCore.DataAccess.Dto;
|
|
using Kurisu.AspNetCore.DataAccess.SqlSugar.Extensions;
|
|
using Kurisu.AspNetCore.DataAccess.SqlSugar.Services;
|
|
using Kurisu.AspNetCore.Utils.Extensions;
|
|
using Mapster;
|
|
using SqlSugar;
|
|
|
|
namespace Dlhis.Basic.WorkGrids.Services.Implements;
|
|
|
|
public class WorkGridService : IWorkGridService
|
|
{
|
|
private readonly IDbContext _dbContext;
|
|
private readonly ICurrentUser _currentUser;
|
|
private readonly IWorkGridScheduleService _workGridScheduleService;
|
|
private readonly IOperateLog _operateLog;
|
|
|
|
public WorkGridService(IDbContext dbContext,
|
|
ICurrentUser currentUser,
|
|
IWorkGridScheduleService workGridScheduleService,
|
|
IOperateLog operateLog)
|
|
{
|
|
_dbContext = dbContext;
|
|
_currentUser = currentUser;
|
|
_workGridScheduleService = workGridScheduleService;
|
|
_operateLog = operateLog;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<Pagination<WorkGridGainfoPageResponse>> GetPageAsync(WorkGridGainfoPageRequest request)
|
|
{
|
|
var factory = _currentUser.GetStringTenantId();
|
|
|
|
var r = await _dbContext.Queryable<GainfoEntity>()
|
|
.LeftJoin<DepartmentEntity>((x, dept) => x.DepartmentNo == dept.No)
|
|
.LeftJoin<WorkGridUserEntity>((x, dept, wgu) => x.Code == wgu.UserCode)
|
|
.LeftJoin<WorkGridEntity>((x, dept, wgu, wg) => wgu.WorkGridCode == wg.Code)
|
|
.Where(x => x.Factory == factory && (x.Type == GainfoUserTypeEnumType.Normal || x.Type == GainfoUserTypeEnumType.SecurityWhite))
|
|
.WhereIF(request.Search.IsPresent(), x => x.Code == request.Search || x.Name.Contains(request.Search))
|
|
.Select((x, dept, wgu, wg) => new WorkGridGainfoPageResponse
|
|
{
|
|
Id = x.Id,
|
|
No = x.No,
|
|
Type = x.Type,
|
|
Name = x.Name,
|
|
Code = x.Code,
|
|
Gender = x.Gender,
|
|
DepartmentNo = x.DepartmentNo,
|
|
DepartmentName = dept.Name,
|
|
Remark = x.Remark,
|
|
WorkGridName = wg.Name,
|
|
})
|
|
.ToPageListAsync(request);
|
|
|
|
var userCodes = r.Data.Select(x => x.Code).ToList();
|
|
if (userCodes.Any())
|
|
{
|
|
var maximumConsecutiveUserCodes = await _workGridScheduleService.MaximumConsecutiveUserCodesAsync(userCodes, 1, DateOnly.FromDateTime(request.Date));
|
|
|
|
foreach (var item in r.Data)
|
|
{
|
|
item.MaximumConsecutiveSchedules = maximumConsecutiveUserCodes.FirstOrDefault(x => x.UserCode == item.Code);
|
|
}
|
|
}
|
|
|
|
return r;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task SaveAsync(List<WorkGridSaveRequest> requests)
|
|
{
|
|
var insertGrids = new List<string>();
|
|
var updateGrids = new List<string>();
|
|
|
|
var leaderUserCodes = requests.Select(x => x.LeaderUserCode).Distinct().ToList();
|
|
var existsUserCodes = await _dbContext.Queryable<GainfoEntity>().Where(x => leaderUserCodes.Contains(x.Code)).Select(x => x.Code).ToListAsync();
|
|
var notExistsUserCodes = leaderUserCodes.Except(existsUserCodes).ToList();
|
|
notExistsUserCodes.ThrowIfExists($"工号:{notExistsUserCodes.Join(",")}不存在");
|
|
|
|
foreach (var request in requests)
|
|
{
|
|
if (await _dbContext.Queryable<WorkGridEntity>().Where(x => x.Name == request.Name)
|
|
.WhereIF(request.Id.HasValue, x => x.Id != request.Id)
|
|
.AnyAsync())
|
|
{
|
|
true.ThrowIfTrue($"网格区域名称[{request.Name}]重复");
|
|
}
|
|
|
|
if (!request.Id.HasValue)
|
|
{
|
|
var exists = await _dbContext.Queryable<WorkGridEntity>()
|
|
.Where(x => x.LeaderUserCode == request.LeaderUserCode)
|
|
.WhereIF(request.Id.HasValue, x => x.Id != request.Id)
|
|
.AnyAsync();
|
|
exists.ThrowIfTrue($"{request.LeaderUserCode}人员存在管理中的网格,无法添加");
|
|
|
|
var entity = request.Adapt<WorkGridEntity>();
|
|
entity.Code = Guid.NewGuid();
|
|
entity.LeaderUserCode = request.LeaderUserCode;
|
|
|
|
await _dbContext.InsertAsync(entity);
|
|
insertGrids.Add($"{entity.Name}({entity.LeaderUserCode}),最大用户数:{entity.MaxUserTipCount}");
|
|
}
|
|
else
|
|
{
|
|
var entity = await _dbContext.Queryable<WorkGridEntity>().Where(x => x.Id == request.Id).SingleAsync();
|
|
entity.ThrowIfNull("网格不存在");
|
|
|
|
updateGrids.Add($"{entity.Name}->{request.Name},排版用户数{entity.MaxUserTipCount}->{request.MaxUserTipCount},连续排班天数:{entity.MaxConsecutiveTipCount}->{request.MaxConsecutiveTipCount}");
|
|
request.Adapt(entity);
|
|
|
|
await _dbContext.UpdateAsync(entity);
|
|
}
|
|
}
|
|
|
|
await _operateLog.LogAsync(OperateLogType.WorkGrid, "创建网格:" + insertGrids.Join("\r\n"));
|
|
await _operateLog.LogAsync(OperateLogType.WorkGrid, "修改网格:" + updateGrids.Join("\r\n"));
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<Pagination<WorkGridPageResponse>> GetPageAsync(WorkGridPageRequest request)
|
|
{
|
|
var role = _currentUser.GetRole();
|
|
var factory = _currentUser.GetStringTenantId();
|
|
var userCode = _currentUser.GetUserClaim(UserClaimConstants.JinkoCode);
|
|
var isAll = role is "admin" or "tenant-admin" or "WGZGLY";
|
|
|
|
return await _dbContext.Queryable<WorkGridEntity>()
|
|
.LeftJoin<GainfoEntity>((x, ga) => x.LeaderUserCode == ga.Code)
|
|
.WhereIF(!isAll, x => x.LeaderUserCode == userCode)
|
|
.WhereIF(request.Search.IsPresent(), x => x.Name.Contains(request.Search) || x.LeaderUserCode == request.Search)
|
|
.Where(x => SqlFunc.Subqueryable<GainfoEntity>().Where(p => p.Code == x.LeaderUserCode && p.Factory == factory).Any())
|
|
.Select((x, ga) => new WorkGridPageResponse
|
|
{
|
|
Id = x.Id,
|
|
Code = x.Code,
|
|
Name = x.Name,
|
|
LeaderUserCode = x.LeaderUserCode,
|
|
UserName = ga.Name,
|
|
Remark = x.Remark,
|
|
MaxUserTipCount = x.MaxUserTipCount,
|
|
MaxConsecutiveTipCount = x.MaxConsecutiveTipCount,
|
|
UserCount = SqlFunc.Subqueryable<WorkGridUserEntity>().Where(p => p.WorkGridCode == x.Code && p.IsDeleted == false).Count()
|
|
})
|
|
.ToPageListAsync(request);
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task ChangeAsync(string from, string to)
|
|
{
|
|
var workGrid = await _dbContext.Queryable<WorkGridEntity>().Where(x => x.LeaderUserCode == from).SingleAsync();
|
|
workGrid.ThrowIfNull("网格不存在");
|
|
|
|
var beforeGainfo = await _dbContext.Queryable<GainfoEntity>().Where(x => x.Code == from).SingleAsync();
|
|
beforeGainfo.ThrowIfNull($"{from}人员不存在");
|
|
|
|
var gainfo = await _dbContext.Queryable<GainfoEntity>().Where(x => x.Code == to).SingleAsync();
|
|
gainfo.ThrowIfNull($"{to}人员不存在");
|
|
|
|
(gainfo.Factory != beforeGainfo.Factory).ThrowIfTrue($"必须选择相同厂区({beforeGainfo.Factory})人员管理({gainfo.Factory}错误)");
|
|
|
|
workGrid.LeaderUserCode = to;
|
|
await _dbContext.UpdateAsync(workGrid);
|
|
|
|
await _operateLog.LogAsync(OperateLogType.WorkGrid, $"网格({workGrid.Name})修改负责人{from}->{to}");
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task<WorkGridUserPageResponse> GetMyWorkGridAsync(WorkGridPageRequest request)
|
|
{
|
|
var currentUserCode = _currentUser.GetUserClaim(UserClaimConstants.JinkoCode);
|
|
var myWorkGrid = await _dbContext.Queryable<WorkGridEntity>()
|
|
.WhereIF(request.WorkGridCode.HasValue == false, x => x.LeaderUserCode == currentUserCode)
|
|
.WhereIF(request.WorkGridCode.HasValue, x => x.Code == request.WorkGridCode)
|
|
.Select(x => new WorkGridUserPageResponse
|
|
{
|
|
Id = x.Id,
|
|
Code = x.Code,
|
|
Name = x.Name,
|
|
Remark = x.Remark,
|
|
MaxUserTipCount = x.MaxUserTipCount,
|
|
MaxConsecutiveTipCount = x.MaxConsecutiveTipCount
|
|
})
|
|
.SingleAsync();
|
|
|
|
if (myWorkGrid != null)
|
|
{
|
|
myWorkGrid.UserCount = await _dbContext.Queryable<WorkGridUserEntity>().Where(x => x.WorkGridCode == myWorkGrid.Code).CountAsync();
|
|
myWorkGrid.UserInfos = await _dbContext.Queryable<WorkGridUserEntity>()
|
|
.LeftJoin<GainfoEntity>((x, ga) => x.UserCode == ga.Code)
|
|
.Where((x, ga) => x.WorkGridCode == myWorkGrid.Code)
|
|
.WhereIF(request.Search.IsPresent(), (x, ga) => x.UserCode == request.Search || ga.Name.Contains(request.Search))
|
|
.Select((x, ga) => new WorkGridUserPageDetailResponse
|
|
{
|
|
Code = x.UserCode,
|
|
Name = ga.Name
|
|
}).ToListAsync();
|
|
|
|
var userCodes = myWorkGrid.UserInfos.Select(x => x.Code).ToList();
|
|
if (userCodes.Any())
|
|
{
|
|
var maximumConsecutiveUserCodes = await _workGridScheduleService.MaximumConsecutiveUserCodesAsync(userCodes, 1, DateOnly.FromDateTime(request.Date));
|
|
|
|
foreach (var item in myWorkGrid.UserInfos)
|
|
{
|
|
item.MaximumConsecutiveSchedules = maximumConsecutiveUserCodes.FirstOrDefault(x => x.UserCode == item.Code);
|
|
}
|
|
}
|
|
}
|
|
|
|
return myWorkGrid;
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task AssignAsync(WorkGridUserAssignRequest request)
|
|
{
|
|
var currentFactory = _currentUser.GetStringTenantId();
|
|
var role = _currentUser.GetRole();
|
|
var specific = (role is "admin" or "tenant-admin" or "WGZGLY") && request.WorkGridCode.HasValue;
|
|
var currentUserCode = _currentUser.GetUserClaim(UserClaimConstants.JinkoCode);
|
|
|
|
var myWorkGrid = await _dbContext.Queryable<WorkGridEntity>()
|
|
.WhereIF(specific, x => x.Code == request.WorkGridCode)
|
|
.WhereIF(specific == false, x => x.LeaderUserCode == currentUserCode)
|
|
.SingleAsync();
|
|
|
|
myWorkGrid.ThrowIfNull("工作网格尚未配置,请联系管理员");
|
|
|
|
//检查配置的人员
|
|
var count = await _dbContext.Queryable<GainfoEntity>()
|
|
.Where(x => x.Factory == currentFactory)
|
|
.Where(x => request.UserCodes.Contains(x.Code))
|
|
.CountAsync();
|
|
|
|
(count != request.UserCodes.Count).ThrowIfTrue("存在非当前厂区人员,请检查");
|
|
|
|
var existsAssigned = await _dbContext.Queryable<WorkGridUserEntity>()
|
|
.Where(x => request.UserCodes.Contains(x.UserCode))
|
|
.AnyAsync();
|
|
existsAssigned.ThrowIfTrue("存在已经分配人员,操作失败!");
|
|
|
|
var dataToInserts = request.UserCodes.Select(x => new WorkGridUserEntity
|
|
{
|
|
WorkGridCode = myWorkGrid.Code,
|
|
UserCode = x
|
|
}).ToList();
|
|
|
|
await _dbContext.InsertAsync(dataToInserts);
|
|
await _operateLog.LogAsync(OperateLogType.WorkGrid, $"分配人员到网格({myWorkGrid.Name}),人员:{dataToInserts.Select(x => x.UserCode).Join(",")}");
|
|
}
|
|
|
|
/// <inheritdoc />
|
|
public async Task RemoveAsync(WorkGridUserRemoveRequest request)
|
|
{
|
|
var role = _currentUser.GetRole();
|
|
var specific = (role is "admin" or "tenant-admin" or "WGZGLY") && request.WorkGridCode.HasValue;
|
|
var currentUserCode = _currentUser.GetUserClaim(UserClaimConstants.JinkoCode);
|
|
|
|
var myWorkGrid = await _dbContext.Queryable<WorkGridEntity>()
|
|
.WhereIF(specific, x => x.Code == request.WorkGridCode)
|
|
.WhereIF(specific == false, x => x.LeaderUserCode == currentUserCode)
|
|
.SingleAsync();
|
|
|
|
var workGridUsers = await _dbContext.Queryable<WorkGridUserEntity>()
|
|
.Where(x => x.WorkGridCode == myWorkGrid.Code)
|
|
.Where(x => request.UserCodes.Contains(x.UserCode))
|
|
.ToListAsync();
|
|
|
|
var date = DateOnly.FromDateTime(DateTime.Today);
|
|
var workGridSchedules = await _dbContext.Queryable<WorkGridScheduleEntity>()
|
|
.Where(x => x.Date > date)
|
|
.Where(x => x.WorkGridCode == myWorkGrid.Code)
|
|
.Where(x => request.UserCodes.Contains(x.UserCode))
|
|
.ToListAsync();
|
|
|
|
await _dbContext.DeleteAsync(workGridUsers);
|
|
await _dbContext.DeleteAsync(workGridSchedules);
|
|
|
|
await _operateLog.LogAsync(OperateLogType.WorkGrid, $"从网格({myWorkGrid.Name})移除人员:{request.UserCodes.Join(",")}");
|
|
}
|
|
} |