AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Order/ContractReviewService.cs

namespace Admin.NET.Plugin.AiDOP.Order;

/// <summary>
/// 合同评审服务 📋
/// 路由前缀：/api/Order/contract/...
/// 审批：由审批流插件（BizType=CONTRACT_REVIEW）+ 前端 ApprovalPanel 发起与办理；本服务仅保留列表/详情/保存/删除。
///
/// 【租户安全边界】需认证访问（已移除类级 <c>[AllowAnonymous]</c>）；租户一律经
/// <c>AidopTenantScope.ResolveOrThrow</c> 从认证后 JWT 解析，无有效租户即拒绝，
/// 不读前端 tenantId、无默认回退（原实现：类级匿名 + 直接取 <c>_userManager.TenantId</c>，
/// 匿名时 TenantId=0 使租户过滤失效/查不到数据）。
/// </summary>
[ApiDescriptionSettings(Order = 250, Description = "合同评审")]
[Route("api/Order")]
[NonUnify]
public class ContractReviewService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly SqlSugarRepository<ContractReview> _reviewRep;
    private readonly SqlSugarRepository<ContractReviewFlow> _flowRep;
    private readonly UserManager _userManager;

    public ContractReviewService(
        ISqlSugarClient db,
        SqlSugarRepository<ContractReview> reviewRep,
        SqlSugarRepository<ContractReviewFlow> flowRep,
        UserManager userManager)
    {
        _db = db;
        _reviewRep = reviewRep;
        _flowRep = flowRep;
        _userManager = userManager;
    }

    // ══════════════════════════════════════════════════════════════
    // 列表 GET /api/Order/contract/list
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取合同评审分页列表 📋</summary>
    [DisplayName("获取合同评审列表")]
    [HttpGet("contract/list")]
    public async Task<object> GetContractReviewList([FromQuery] ContractReviewListInput input)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var conditions = new List<string> { "tenant_id = @TenantId" };

        if (!string.IsNullOrWhiteSpace(input.BillNo))
        {
            conditions.Add("BillNo LIKE @BillNo");
            pars.Add(new SugarParameter("@BillNo", $"%{input.BillNo.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.Title))
        {
            conditions.Add("Title LIKE @Title");
            pars.Add(new SugarParameter("@Title", $"%{input.Title.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.CustomerName))
        {
            conditions.Add("CustomerName LIKE @CustomerName");
            pars.Add(new SugarParameter("@CustomerName", $"%{input.CustomerName.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.FlowStatus))
        {
            conditions.Add("FlowStatus = @FlowStatus");
            pars.Add(new SugarParameter("@FlowStatus", input.FlowStatus.Trim()));
        }

        var whereClause = "WHERE " + string.Join(" AND ", conditions);
        var baseSql = $"SELECT * FROM ado_contract_review {whereClause}";

        var offset = (input.Page - 1) * input.PageSize;
        var total = await _db.Ado.GetIntAsync($"SELECT COUNT(*) FROM ({baseSql}) AS t", pars);
        var list = await _db.Ado.SqlQueryAsync<ContractReviewListRow>(
            $"SELECT * FROM ({baseSql}) AS t ORDER BY t.RecID DESC LIMIT {input.PageSize} OFFSET {offset}",
            pars);

        return new { total, page = input.Page, pageSize = input.PageSize, list };
    }

    // ══════════════════════════════════════════════════════════════
    // 详情 GET /api/Order/contract/{id}
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取合同评审详情（含流程节点）📋</summary>
    [DisplayName("获取合同评审详情")]
    [HttpGet("contract/{id}")]
    public async Task<object> GetContractReviewDetail(int id)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var review = await _reviewRep.GetFirstAsync(u => u.RecID == id && u.TenantId == tenantId)
                     ?? throw Oops.Oh("合同评审记录不存在");

        var flows = await _flowRep.GetListAsync(u => u.ReviewRecID == id && u.TenantId == tenantId);

        return new
        {
            recID = review.RecID,
            billNo = review.BillNo,
            title = review.Title,
            customerName = review.CustomerName,
            customerNo = review.CustomerNo,
            salesCompany = review.SalesCompany,
            salesArea = review.SalesArea,
            projectCode = review.ProjectCode,
            crmNo = review.CrmNo,
            responsibleAccount = review.ResponsibleAccount,
            responsibleName = review.ResponsibleName,
            projectStartDate = review.ProjectStartDate?.ToString("yyyy-MM-dd"),
            currentStage = review.CurrentStage ?? 0,
            currentDept = review.CurrentDept,
            projectStatus = review.ProjectStatus,
            winRate = review.WinRate,
            expectedOrderMonth = review.ExpectedOrderMonth?.ToString("yyyy-MM"),
            expectedDeliveryDate = review.ExpectedDeliveryDate?.ToString("yyyy-MM-dd"),
            projectRequirement = review.ProjectRequirement,
            remark = review.Remark,
            flowStatus = review.FlowStatus ?? "draft",
            createUser = review.CreateUser,
            createTime = review.CreateTime?.ToString("yyyy-MM-dd HH:mm:ss"),
            updateTime = review.UpdateTime?.ToString("yyyy-MM-dd HH:mm:ss"),
            flows = flows.OrderBy(f => f.StageNo).ThenBy(f => f.Seq).Select(f => new
            {
                recID          = f.RecID,
                reviewRecID    = f.ReviewRecID,
                reviewBillNo   = f.ReviewBillNo,
                stageNo        = f.StageNo,
                stageName      = f.StageName,
                department     = f.Department,
                deptNo         = f.DeptNo,
                seq            = f.Seq,
                reviewerAccount = f.ReviewerAccount,
                reviewerName   = f.ReviewerName,
                opinion        = f.Opinion,
                startTime      = f.StartTime?.ToString("yyyy-MM-dd HH:mm:ss"),
                completeTime   = f.CompleteTime?.ToString("yyyy-MM-dd HH:mm:ss"),
                actualDays     = f.ActualDays,
                nodeStatus     = f.NodeStatus ?? "pending",
            })
        };
    }

    // ══════════════════════════════════════════════════════════════
    // 保存（新增/编辑）POST /api/Order/contract/save
    // ══════════════════════════════════════════════════════════════
    /// <summary>保存合同评审（草稿新增或编辑）📋</summary>
    [DisplayName("保存合同评审")]
    [ApiDescriptionSettings(Name = "SaveContractReview"), HttpPost("contract/save")]
    public async Task<object> SaveContractReview([FromBody] ContractReviewSaveInput input)
    {
        // 必填校验
        if (string.IsNullOrWhiteSpace(input.ProjectCode))
            throw Oops.Oh("合同编号不能为空");
        if (string.IsNullOrWhiteSpace(input.ProjectStartDate))
            throw Oops.Oh("合同开始时间不能为空");
        if (string.IsNullOrWhiteSpace(input.SalesCompany))
            throw Oops.Oh("销售公司不能为空");
        if (string.IsNullOrWhiteSpace(input.CustomerName))
            throw Oops.Oh("客户名称不能为空");
        if (string.IsNullOrWhiteSpace(input.Title))
            throw Oops.Oh("合同标题不能为空");

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);

        // 合同编号唯一性校验
        var existingId = input.RecID ?? 0;
        var codeExists = await _reviewRep.IsAnyAsync(u =>
            u.ProjectCode == input.ProjectCode.Trim()
            && u.TenantId == tenantId
            && u.RecID != existingId);
        if (codeExists)
            throw Oops.Oh($"合同编号「{input.ProjectCode.Trim()}」已存在，请使用其他编号");

        var now = DateTime.Now;
        var user = _userManager.Account ?? "system";

        if (input.RecID is null or 0)
        {
            // ── 新增：参照 SysJobService.AddJobDetail ──
            var month = now.ToString("yyyyMM");
            var maxSeq = await _db.Ado.GetIntAsync(
                $"SELECT IFNULL(MAX(CAST(SUBSTRING(BillNo, 9) AS UNSIGNED)), 0) FROM ado_contract_review WHERE BillNo LIKE 'CR{month}%' AND tenant_id = @TenantId",
                new SugarParameter("@TenantId", tenantId));
            var billNo = $"CR{month}{(maxSeq + 1):D4}";

            var entity = new ContractReview
            {
                BillNo              = billNo,
                Title               = input.Title,
                CustomerName        = input.CustomerName,
                CustomerNo          = input.CustomerNo,
                SalesCompany        = input.SalesCompany,
                SalesArea           = input.SalesArea,
                ProjectCode         = input.ProjectCode,
                CrmNo               = input.CrmNo,
                ResponsibleAccount  = input.ResponsibleAccount,
                ResponsibleName     = input.ResponsibleName,
                ProjectStartDate    = string.IsNullOrWhiteSpace(input.ProjectStartDate) ? null : DateTime.Parse(input.ProjectStartDate),
                ProjectStatus       = input.ProjectStatus,
                WinRate             = input.WinRate,
                ExpectedOrderMonth  = string.IsNullOrWhiteSpace(input.ExpectedOrderMonth) ? null : DateTime.Parse(input.ExpectedOrderMonth + "-01"),
                ExpectedDeliveryDate = string.IsNullOrWhiteSpace(input.ExpectedDeliveryDate) ? null : DateTime.Parse(input.ExpectedDeliveryDate),
                ProjectRequirement  = input.ProjectRequirement,
                Remark              = input.Remark,
                FlowStatus          = "draft",
                CurrentStage        = 0,
                CreateUser          = user,
                CreateTime          = now,
                IsActive            = 1,
                TenantId            = tenantId,
            };
            await _reviewRep.InsertAsync(entity);

            // 取刚插入行的 RecID
            var newId = await _db.Ado.GetIntAsync(
                "SELECT MAX(RecID) FROM ado_contract_review WHERE BillNo = @BillNo",
                new SugarParameter("@BillNo", billNo));

            return new { id = newId, billNo, message = "新增成功" };
        }
        else
        {
            // ── 编辑：参照 SysJobService.UpdateJobDetail ──
            var entity = await _reviewRep.GetFirstAsync(u => u.RecID == input.RecID.Value && u.TenantId == tenantId)
                         ?? throw Oops.Oh("合同评审记录不存在");

            if (entity.FlowStatus == "reviewing")
                throw Oops.Oh("审批中的合同评审不允许编辑，如需修改请先驳回");

            entity.Title               = input.Title;
            entity.CustomerName        = input.CustomerName;
            entity.CustomerNo          = input.CustomerNo;
            entity.SalesCompany        = input.SalesCompany;
            entity.SalesArea           = input.SalesArea;
            entity.ProjectCode         = input.ProjectCode;
            entity.CrmNo               = input.CrmNo;
            entity.ResponsibleAccount  = input.ResponsibleAccount;
            entity.ResponsibleName     = input.ResponsibleName;
            entity.ProjectStartDate    = string.IsNullOrWhiteSpace(input.ProjectStartDate) ? null : DateTime.Parse(input.ProjectStartDate);
            entity.ProjectStatus       = input.ProjectStatus;
            entity.WinRate             = input.WinRate;
            entity.ExpectedOrderMonth  = string.IsNullOrWhiteSpace(input.ExpectedOrderMonth) ? null : DateTime.Parse(input.ExpectedOrderMonth + "-01");
            entity.ExpectedDeliveryDate = string.IsNullOrWhiteSpace(input.ExpectedDeliveryDate) ? null : DateTime.Parse(input.ExpectedDeliveryDate);
            entity.ProjectRequirement  = input.ProjectRequirement;
            entity.Remark              = input.Remark;
            entity.UpdateUser          = user;
            entity.UpdateTime          = now;

            await _reviewRep.UpdateAsync(entity);
            return new { id = entity.RecID, billNo = entity.BillNo, message = "编辑成功" };
        }
    }

    // ══════════════════════════════════════════════════════════════
    // 删除 POST /api/Order/contract/delete
    // ══════════════════════════════════════════════════════════════
    /// <summary>删除合同评审（审批中不允许删除）📋</summary>
    [DisplayName("删除合同评审")]
    [ApiDescriptionSettings(Name = "DeleteContractReview"), HttpPost("contract/delete")]
    public async Task<object> DeleteContractReview([FromBody] ContractReviewDeleteInput input)
    {
        // 参照 SysJobService.DeleteJobDetail：先查再删，同时删关联数据
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var entity = await _reviewRep.GetFirstAsync(u => u.RecID == input.RecID && u.TenantId == tenantId)
                     ?? throw Oops.Oh("合同评审记录不存在");

        if (entity.FlowStatus == "reviewing")
            throw Oops.Oh("审批中的合同评审不允许删除");

        await _flowRep.DeleteAsync(u => u.ReviewRecID == input.RecID);
        await _reviewRep.DeleteAsync(u => u.RecID == input.RecID);

        return new { message = "删除成功" };
    }

    // ══════════════════════════════════════════════════════════════
    // 合同编号唯一性校验 GET /api/Order/contract/check-project-code
    // ══════════════════════════════════════════════════════════════
    /// <summary>校验合同编号唯一性 📋</summary>
    [DisplayName("校验合同编号唯一性")]
    [HttpGet("contract/check-project-code")]
    public async Task<object> CheckProjectCode([FromQuery] string projectCode, [FromQuery] int excludeId = 0)
    {
        if (string.IsNullOrWhiteSpace(projectCode))
            return new { exists = false };

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var exists = await _reviewRep.IsAnyAsync(u =>
            u.ProjectCode == projectCode.Trim()
            && u.TenantId == tenantId
            && u.RecID != excludeId);

        return new { exists };
    }

    // ══════════════════════════════════════════════════════════════
    // 合同负责人下拉框 GET /api/Order/contract/responsible-users
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取合同负责人下拉选项（当前租户用户列表）📋</summary>
    [DisplayName("获取合同负责人下拉选项")]
    [HttpGet("contract/responsible-users")]
    public async Task<List<object>> GetResponsibleUsers([FromQuery] string? keyword)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var conditions = new List<string> { "TenantId = @TenantId" };

        if (!string.IsNullOrWhiteSpace(keyword))
        {
            conditions.Add("(Account LIKE @Keyword OR RealName LIKE @Keyword)");
            pars.Add(new SugarParameter("@Keyword", $"%{keyword.Trim()}%"));
        }

        var whereClause = "WHERE " + string.Join(" AND ", conditions);
        var sql = $"SELECT Account, RealName FROM SysUser {whereClause} ORDER BY Account LIMIT 100";

        var rows = await _db.Ado.SqlQueryAsync<ResponsibleUserRow>(sql, pars);

        return rows.Select(r => (object)new { value = r.Account, label = r.RealName }).ToList();
    }

    // ──────────────── 内部查询结果映射类 ────────────────

    private sealed class ResponsibleUserRow
    {
        public string? Account { get; set; }
        public string? RealName { get; set; }
    }

    private sealed class ContractReviewListRow
    {
        public int RecID { get; set; }
        public string? BillNo { get; set; }
        public string? Title { get; set; }
        public string? CustomerName { get; set; }
        public string? SalesCompany { get; set; }
        public int? CurrentStage { get; set; }
        public string? CurrentDept { get; set; }
        public string? FlowStatus { get; set; }
        public string? ResponsibleAccount { get; set; }
        public string? ResponsibleName { get; set; }
        public DateTime? CreateTime { get; set; }
        public DateTime? UpdateTime { get; set; }
    }
}