YBEE.EQM/YBEE.EQM.Application/Exam/ExamDataPublish/Services/ExamDataPublishService.cs

using Furion.DatabaseAccessor.Extensions;
using YBEE.EQM.Core;

namespace YBEE.EQM.Application;

/// <summary>
/// 监测发布内容管理服务
/// </summary>
public class ExamDataPublishService(IRepository<ExamDataPublish> rep, IExamSampleService examSampleService) : IExamDataPublishService, ITransient
{
    #region 创建更新
    /// <summary>
    /// 添加发布内容
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Add(AddExamDataPublishInput input)
    {
        //if (await _rep.AnyAsync(t => t.ExamPlanId == input.ExamPlanId && t.Type == input.Type))
        //{
        //    throw Oops.Oh(ErrorCode.E2002, "该类型");
        //}
        var item = input.Adapt<ExamDataPublish>();
        await item.InsertAsync();
    }
    /// <summary>
    /// 更新发布内容
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Update(UpdateExamDataPublishInput input)
    {
        var item = await rep.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
        item.Name = input.Name;
        item.Remark = input.Remark;
        await item.UpdateIncludeAsync([nameof(item.Name), nameof(item.Remark)]);
    }
    /// <summary>
    /// 删除发布内容
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Del(BaseId input)
    {
        var item = await rep.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
        if (item.Status != PublishStatus.UNPUBLISH)
        {
            throw Oops.Oh(ErrorCode.E3001);
        }
        await item.DeleteAsync();
    }
    #endregion

    #region 状态处理
    /// <summary>
    /// 发布
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Publish(BaseId input)
    {
        var item = await rep.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
        if (item.Status == PublishStatus.PUBLISHED)
        {
            throw Oops.Oh(ErrorCode.E2006);
        }

        if (item.Type == DataPublishType.STUDENT_SAMPLE_LIST || item.Type == DataPublishType.STUDENT_SAMPLE_COUNT_LIST)
        {
            var selected = await examSampleService.CheckSelectedByExamPlanId(item.ExamPlanId);
            // 未选定抽样方案不能发布
            if (!selected)
            {
                throw Oops.Oh(ErrorCode.E3008);
            }
        }

        item.Status = PublishStatus.PUBLISHED;
        item.PublishTime = DateTime.Now;
        item.PublishSysUserId = CurrentSysUserInfo.SysUserId;
        await item.UpdateIncludeAsync([nameof(item.Status), nameof(item.PublishTime), nameof(item.PublishSysUserId)]);
    }
    /// <summary>
    /// 取消
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task Unpublish(BaseId input)
    {
        var item = await rep.FirstOrDefaultAsync(t => t.Id == input.Id) ?? throw Oops.Oh(ErrorCode.E2001);
        if (item.Status != PublishStatus.PUBLISHED)
        {
            throw Oops.Oh(ErrorCode.E2006);
        }
        item.Status = PublishStatus.UNPUBLISH; // 设置为未发布
        await item.UpdateIncludeAsync([nameof(item.Status)]);
    }
    #endregion

    #region 查询
    /// <summary>
    /// 根据ID获取监测数据发布内容
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    public async Task<ExamDataPublishOutput> GetById(int id)
    {
        var item = await rep.DetachedEntities.FirstOrDefaultAsync(t => t.Id == id) ?? throw Oops.Oh(ErrorCode.E2001);
        return item.Adapt<ExamDataPublishOutput>();
    }
    /// <summary>
    /// 根据监测计划ID获取数据发布内容列表
    /// </summary>
    /// <param name="examPlanId">监测计划ID</param>
    /// <param name="type">发布类型</param>
    /// <returns></returns>
    public async Task<List<ExamDataPublishOutput>> GetListByExamPlanId(int examPlanId, DataPublishType? type)
    {
        var items = await rep.DetachedEntities
                             .Where(t => t.ExamPlanId == examPlanId)
                             .Where(type.HasValue, t => t.Type == type)
                             .ProjectToType<ExamDataPublishOutput>()
                             .OrderBy(t => t.Type)
                             .ToListAsync();
        return items;
    }
    /// <summary>
    /// 分页查询面向机构发布的内容列表
    /// </summary>
    /// <param name="input"></param>
    /// <returns></returns>
    public async Task<PageResult<ExamDataPublishOrgOutput>> QueryOrgPageList(ExamDataPublishOrgPageInput input)
    {
        string where = $"T1.sys_org_id = @sysOrgId AND T2.type = @type AND T2.`status` = {(int)PublishStatus.PUBLISHED} AND T2.is_deleted = 0 AND T3.is_deleted = 0";
        if (input.SemesterId.HasValue)
        {
            where = $"{where} AND T3.semester_id = {input.SemesterId.Value}";
        }
        if (!string.IsNullOrEmpty(input.Name?.Trim()))
        {
            where = $"{where} AND T3.full_name LIKE '%{input.Name.Trim()}%'";
        }

        var p = new
        {
            CurrentSysUserInfo.SysOrgId,
            input.PageSize,
            PageOffset = (input.PageIndex - 1) * input.PageSize,
            input.Type,
            input.Name,
            input.SemesterId,
        };

        var totalCount = await rep.SqlScalarAsync<int>($@"
SELECT COUNT(1) AS total_count
FROM exam_org AS T1
JOIN exam_data_publish AS T2 ON T1.exam_plan_id = T2.exam_plan_id
JOIN exam_plan AS T3 ON T1.exam_plan_id = T3.id
JOIN base_semester AS T4 ON T3.semester_id = T4.id
WHERE {where}
", p);

        var items = await rep.SqlQueriesAsync<ExamDataPublishOrgOutput>($@"
SELECT ROW_NUMBER() OVER (ORDER BY T1.exam_plan_id DESC, T2.type) AS `row_number`, 
    T1.exam_plan_id,
	T1.sys_org_id,
    T2.id AS exam_data_publish_id,
	T2.type,
	T2.`name` AS exam_data_publish_name,
    T3.full_name AS exam_plan_full_name, 
	T3.`name` AS exam_plan_name, 
	T3.short_name AS exam_plan_short_name,
    T3.`status` AS exam_plan_status, 
	T3.education_stage, 
	T3.semester_id,
    T4.nick_short_name AS semesterNickShortName
FROM exam_org AS T1
JOIN exam_data_publish AS T2 ON T1.exam_plan_id = T2.exam_plan_id
JOIN exam_plan AS T3 ON T1.exam_plan_id = T3.id
JOIN base_semester AS T4 ON T3.semester_id = T4.id
WHERE {where}
LIMIT @pageSize OFFSET @pageOffset;
", p);
        PageResult<ExamDataPublishOrgOutput> ret = new()
        {
            PageIndex = input.PageIndex,
            PageSize = input.PageSize,
            TotalCount = totalCount,
            Items = items
        };
        return ret;
    }

    #endregion

    #region 上传匹配

    #endregion
}