OnboardXAdmin/SimpleAdmin.Application/Services/Onboarding/Lifecycle/OnboardingTaskLifecycleService.cs

namespace SimpleAdmin.Application;

/// <summary>
/// 实现入职任务生命周期业务能力。
/// </summary>
public class OnboardingTaskLifecycleService : IOnboardingTaskLifecycleService
{
    private readonly SqlSugarScope _db;
    private readonly IConfigService _config;

    public OnboardingTaskLifecycleService(IConfigService config)
    {
        _db = DbContext.DB;
        _config = config;
    }

    /// <summary>
    /// 归档已审核通过的入职任务。
    /// </summary>
    public async Task Archive(OnboardingAuditActionInput input)
    {
        var task = await Authorize(input.TaskId);
        if (task.TaskStatus != OnboardingTaskStatus.Approved)
        {
            throw Oops.Bah("仅审核通过任务可归档");
        }

        task.TaskStatus = OnboardingTaskStatus.Archived;
        task.ArchivedAt = DateTime.Now;
        await _db.Updateable(task).ExecuteCommandAsync();
        await Log(task, OnboardingAuditAction.Archive, input.AuditOpinion);
    }

    /// <summary>
    /// 撤销入职任务并同步撤销仍然有效的员工填写链接。
    /// </summary>
    public async Task Revoke(OnboardingAuditActionInput input)
    {
        var task = await Authorize(input.TaskId);
        if (task.TaskStatus == OnboardingTaskStatus.Approved || task.TaskStatus == OnboardingTaskStatus.Archived)
        {
            throw Oops.Bah("已通过或已归档任务不能撤销");
        }

        task.TaskStatus = OnboardingTaskStatus.Revoked;
        await _db.Updateable(task).ExecuteCommandAsync();
        await _db.Updateable<ObTaskLink>()
            .SetColumns(item => new ObTaskLink
            {
                LinkStatus = OnboardingLinkStatus.Revoked,
                RevokedAt = DateTime.Now
            })
            .Where(item => item.TaskId == task.Id && item.LinkStatus == OnboardingLinkStatus.Active)
            .ExecuteCommandAsync();
        await Log(task, OnboardingAuditAction.Revoke, input.AuditOpinion);
    }

    /// <summary>
    /// 删除已撤销的入职任务及其全部关联快照数据。
    /// </summary>
    public async Task Delete(BaseIdInput input)
    {
        var task = await Authorize(input.Id);
        if (task.TaskStatus != OnboardingTaskStatus.Revoked)
        {
            throw Oops.Bah("仅已撤销的任务可以删除");
        }

        await _db.Ado.BeginTranAsync();
        try
        {
            var taskContractIds = await _db.Queryable<ObTaskContract>()
                .Where(x => x.TaskId == task.Id)
                .Select(x => x.Id)
                .ToListAsync();

            if (taskContractIds.Count > 0)
            {
                await _db.Deleteable<ObTaskContractVariable>()
                    .Where(x => taskContractIds.Contains(x.TaskContractId))
                    .ExecuteCommandAsync();
            }

            await _db.Deleteable<ObTaskContract>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskLink>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskFormRequirement>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskMaterialRequirement>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskMaterial>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskFormValue>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskEmployeeInfo>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObTaskAudit>().Where(x => x.TaskId == task.Id).ExecuteCommandAsync();
            await _db.Deleteable<ObOnboardingTask>().In(task.Id).ExecuteCommandAsync();
            await _db.Ado.CommitTranAsync();
        }
        catch
        {
            await _db.Ado.RollbackTranAsync();
            throw;
        }
    }

    private async Task<ObOnboardingTask> Authorize(long taskId)
    {
        var task = await _db.Queryable<ObOnboardingTask>().InSingleAsync(taskId)
            ?? throw Oops.Bah("入职任务不存在");
        var config = await _config.GetByConfigKey(CateGoryConst.CONFIG_BIZ_DEFINE, "onboard.reviewer.userIds")
            ?? throw Oops.Bah("请配置入职审核人");

        using var configJson = global::System.Text.Json.JsonDocument.Parse(config.ConfigValue);
        var reviewerIds = new List<long>();
        if (configJson.RootElement.TryGetProperty("all", out var allReviewers))
        {
            reviewerIds.AddRange(allReviewers.EnumerateArray().Select(item => item.GetInt64()));
        }

        if (configJson.RootElement.TryGetProperty("company", out var companyReviewers)
            && companyReviewers.TryGetProperty(task.CompanyId.ToString(), out var reviewers))
        {
            reviewerIds.AddRange(reviewers.EnumerateArray().Select(item => item.GetInt64()));
        }

        if (!reviewerIds.Contains(UserManager.UserId))
        {
            throw Oops.Bah("您不是该入职任务的审核人");
        }

        return task;
    }

    private Task Log(ObOnboardingTask task, string action, string opinion)
    {
        return _db.Insertable(new ObTaskAudit
        {
            Id = global::SimpleAdmin.Core.Utils.CommonUtils.GetSingleId(),
            TaskId = task.Id,
            AuditRound = task.SubmitCount,
            AuditAction = action,
            AuditorUserId = UserManager.UserId,
            AuditOpinion = opinion,
            AuditedAt = DateTime.Now
        }).ExecuteCommandAsync();
    }
}