namespace SafeCampus.Application;
///
public class OrgService : DbRepository, IOrgService
{
private readonly ISysOrgService _sysOrgService;
private readonly ISysUserService _sysUserService;
public OrgService(ISysOrgService sysOrgService, ISysUserService sysUserService)
{
_sysOrgService = sysOrgService;
_sysUserService = sysUserService;
}
///
public async Task> Page(SysOrgPageInput input)
{
//获取数据范围
var dataScope = await _sysUserService.GetLoginUserApiDataScope();
dataScope?.Remove(UserManager.OrgId);
//构建查询
var query = Context.Queryable()
.WhereIF(dataScope != null, it => dataScope.Contains(it.Id))//机构ID查询
.WhereIF(input.ParentId > 0,
it => it.ParentId == input.ParentId || SqlFunc.JsonLike(it.ParentIdList, input.ParentId.ToString()))//父级
.WhereIF(!string.IsNullOrEmpty(input.Name), it => it.Name.Contains(input.Name))//根据名称查询
.WhereIF(!string.IsNullOrEmpty(input.Code), it => it.Code.Contains(input.Code))//根据编码查询
.WhereIF(!string.IsNullOrEmpty(input.Status), it => it.Status == input.Status)//根据状态查询
.OrderByIF(!string.IsNullOrEmpty(input.SortField), $"{input.SortField} {input.SortOrder}").OrderBy(it => it.SortCode)
.OrderBy(it => it.CreateTime);//排序
var pageInfo = await query.ToPagedListAsync(input.PageNum, input.PageSize);//分页
return pageInfo;
}
///
public async Task> Tree(SysOrgTreeInput input = null)
{
//获取数据范围
var dataScope = await _sysUserService.GetLoginUserApiDataScope();
//构建机构树
var result = await _sysOrgService.Tree(dataScope, input);
return result;
}
///
public async Task Add(SysOrgAddInput input)
{
await CheckInput(input, SystemConst.ADD);//检查参数
await _sysOrgService.Add(input, ApplicationConst.BIZ_ORG);
}
///
public async Task Edit(SysOrgEditInput input)
{
await CheckInput(input, SystemConst.EDIT);//检查参数
await _sysOrgService.Edit(input, ApplicationConst.BIZ_ORG);
}
///
public async Task Copy(SysOrgCopyInput input)
{
//获取数据范围
var dataScope = await _sysUserService.GetLoginUserApiDataScope();
if (dataScope == null || dataScope.Count > 0)//如果有机构
{
if (dataScope is { Count: > 0 } && (!dataScope.ContainsAll(input.Ids) || !dataScope.Contains(input.TargetId)))//判断目标机构和需要复制的机构是否都在数据范围里面
throw Oops.Bah("您没有权限复制这些机构");
await _sysOrgService.Copy(input);//复制操作
}
}
///
public async Task Delete(BaseIdListInput input)
{
//获取所有ID
var ids = input.Ids;
//获取要删除的机构列表
var orgList = (await _sysOrgService.GetListAsync()).Where(it => ids.Contains(it.Id)).ToList();
if (orgList.Any(it => it.Category == CateGoryConst.ORG_COMPANY))//如果有公司{
throw Oops.Bah("不能删除根机构");
//检查数据范围
var orgIds = orgList.Select(it => it.Id).ToList();
var createUserIds = orgList.Select(it => it.CreateUserId.GetValueOrDefault()).ToList();
await _sysUserService.CheckApiDataScope(orgIds, createUserIds, "您没有权限删除这些机构");
await _sysOrgService.Delete(input, ApplicationConst.BIZ_ORG);//删除操作
}
///
public async Task Detail(BaseIdInput input)
{
var org = await _sysOrgService.GetSysOrgById(input.Id);//获取机构
var errorMessage = "您没有权限查看该机构";
//判断数据范围
await _sysUserService.CheckApiDataScope(org.Id, org.CreateUserId.GetValueOrDefault(), errorMessage);
return org;
}
#region 方法
///
/// 检查输入参数
///
/// 参数
/// 操作名称
private async Task CheckInput(SysOrg sysOrg, string operate)
{
sysOrg.Category = CateGoryConst.ORG_DEPT;//设置分类为部门,业务只能操作部门
if (sysOrg.ParentId == SafeCampusConst.ZERO)
{
throw Oops.Bah($"不能{operate}根机构");
}
var errorMessage = $"您没有权限{operate}该机构";
//获取数据范围
var dataScope = await _sysUserService.GetLoginUserApiDataScope();
if (dataScope is { Count: > 0 })//如果有机构
{
if (sysOrg.Id > 0 && !dataScope.Contains(sysOrg.Id))//如果id不为0判断是否在数据范围
throw Oops.Bah(errorMessage);
if (!dataScope.Contains(sysOrg.ParentId))//判断父ID是否在数据范围
throw Oops.Bah($"{errorMessage}下的机构");
}
else if (dataScope is { Count: 0 })
{
//如果id大于0表示编辑
if (sysOrg.Id > 0)
{
var org = await _sysOrgService.GetSysOrgById(sysOrg.Id);//获取机构
if (org.CreateUserId != UserManager.UserId)
throw Oops.Bah(errorMessage);//机构的创建人不是自己则报错
}
else
{
throw Oops.Bah(errorMessage);
}
}
}
#endregion 方法
}