using Admin.Core.Common.Attributes;
using Admin.Core.Common.Configs;
using Admin.Core.Common.Helpers;
using Admin.Core.Common.Input;
using Admin.Core.Common.Output;
using Admin.Core.Model.Personnel;
using Admin.Core.Repository;
using Admin.Core.Repository.Personnel;
using Admin.Core.Service.Personnel.Employee.Input;
using Admin.Core.Service.Personnel.Employee.Output;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace Admin.Core.Service.Personnel.Employee
{
///
/// 员工服务
///
public class EmployeeService : BaseService, IEmployeeService
{
private readonly IEmployeeRepository _employeeRepository;
private readonly IRepositoryBase _employeeOrganizationRepository;
public EmployeeService(
IEmployeeRepository userRepository,
IRepositoryBase employeeOrganizationRepository
)
{
_employeeRepository = userRepository;
_employeeOrganizationRepository = employeeOrganizationRepository;
}
public async Task> GetAsync(long id)
{
var res = new ResponseOutput();
var dto = await _employeeRepository.Select
.WhereDynamic(id)
.IncludeMany(a => a.Organizations.Select(b => new OrganizationEntity { Id = b.Id }))
.ToOneAsync(a => new EmployeeGetOutput
{
OrganizationName = a.Organization.Name,
PositionName = a.Position.Name
});
return res.Ok(dto);
}
public async Task PageAsync(PageInput input)
{
var list = await _employeeRepository.Select
.WhereDynamicFilter(input.DynamicFilter)
.Count(out var total)
.OrderByDescending(true, a => a.Id)
.IncludeMany(a => a.Organizations.Select(b => new OrganizationEntity { Name = b.Name }))
.Page(input.CurrentPage, input.PageSize)
.ToListAsync(a => new EmployeeListOutput
{
OrganizationName = a.Organization.Name,
PositionName = a.Position.Name
});
var data = new PageOutput()
{
List = list,
Total = total
};
return ResponseOutput.Ok(data);
}
[Transaction]
public async Task AddAsync(EmployeeAddInput input)
{
var entity = Mapper.Map(input);
var employeeId = (await _employeeRepository.InsertAsync(entity))?.Id;
if (!(employeeId > 0))
{
return ResponseOutput.NotOk();
}
//附属部门
if (input.OrganizationIds != null && input.OrganizationIds.Any())
{
var organizations = input.OrganizationIds.Select(organizationId => new EmployeeOrganizationEntity { EmployeeId = employeeId.Value, OrganizationId = organizationId });
await _employeeOrganizationRepository.InsertAsync(organizations);
}
return ResponseOutput.Ok();
}
[Transaction]
public async Task UpdateAsync(EmployeeUpdateInput input)
{
if (!(input?.Id > 0))
{
return ResponseOutput.NotOk();
}
var employee = await _employeeRepository.GetAsync(input.Id);
if (!(employee?.Id > 0))
{
return ResponseOutput.NotOk("用户不存在!");
}
Mapper.Map(input, employee);
await _employeeRepository.UpdateAsync(employee);
await _employeeOrganizationRepository.DeleteAsync(a => a.EmployeeId == employee.Id);
//附属部门
if (input.OrganizationIds != null && input.OrganizationIds.Any())
{
var organizations = input.OrganizationIds.Select(organizationId => new EmployeeOrganizationEntity { EmployeeId = employee.Id, OrganizationId = organizationId });
await _employeeOrganizationRepository.InsertAsync(organizations);
}
return ResponseOutput.Ok();
}
[Transaction]
public async Task DeleteAsync(long id)
{
//删除员工附属部门
await _employeeOrganizationRepository.DeleteAsync(a => a.EmployeeId == id);
//删除员工
await _employeeRepository.DeleteAsync(m => m.Id == id);
return ResponseOutput.Ok();
}
public async Task SoftDeleteAsync(long id)
{
await _employeeRepository.SoftDeleteAsync(id);
return ResponseOutput.Ok();
}
public async Task BatchSoftDeleteAsync(long[] ids)
{
await _employeeRepository.SoftDeleteAsync(ids);
return ResponseOutput.Ok();
}
}
}