AiDOPWarehouse/server/Plugins/Admin.NET.Plugin.AiDOP/Supply/DemandScheduleService.cs

using Yitter.IdGenerator;

namespace Admin.NET.Plugin.AiDOP.Supply;

/// <summary>
/// 物料需求计划服务
///
/// 【租户安全边界】租户一律经 <see cref="AidopTenantScope.ResolveOrThrow"/> 从认证后 JWT 解析，
/// 无有效租户即拒绝，不读前端 tenantId、无默认回退。
/// <para>
/// 原实现：类级 <c>[AllowAnonymous]</c> + 多处以 <c>_userManager.TenantId</c> 拼接条件
/// （<c>if (TenantId > 0)</c> / <c>tenantId <= 0 ||</c> 跳过形态）。匿名请求下 TenantId=0，
/// 租户过滤整体被跳过，等价于未认证可跨租户读/软删/发布需求计划。
/// </para>
/// </summary>
[ApiDescriptionSettings(Order = 305, Description = "物料需求计划")]
[Route("api/Supply")]
[NonUnify]
public class DemandScheduleService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly SqlSugarRepository<DemandSchedule> _rep;
    private readonly UserManager _userManager;

    public DemandScheduleService(
        ISqlSugarClient db,
        SqlSugarRepository<DemandSchedule> rep,
        UserManager userManager)
    {
        _db = db;
        _rep = rep;
        _userManager = userManager;
    }

    [DisplayName("物料需求计划列表")]
    [HttpGet("demand-schedule/list")]
    public async Task<object> GetList([FromQuery] DemandScheduleListInput input)
    {
        var page = input.Page <= 0 ? 1 : input.Page;
        var pageSize = input.PageSize <= 0 ? 10 : input.PageSize;
        var offset = (page - 1) * pageSize;

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = new List<string>
        {
            "(a.ishistoryversion = 'N' OR a.ishistoryversion IS NULL)",
            "IFNULL(a.IsDeleted,0)=0",
            "a.tenant_id = @TenantId"
        };
        if (!string.IsNullOrWhiteSpace(input.ItemNum))
        {
            where.Add("a.itemnum LIKE @ItemNum");
            pars.Add(new SugarParameter("@ItemNum", $"%{input.ItemNum.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.Descr))
        {
            where.Add("b.Descr LIKE @Descr");
            pars.Add(new SugarParameter("@Descr", $"%{input.Descr.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.RequestDateFrom) && DateTime.TryParse(input.RequestDateFrom, out var reqFrom))
        {
            where.Add("a.requestdate >= @RequestDateFrom");
            pars.Add(new SugarParameter("@RequestDateFrom", reqFrom.Date));
        }

        var fromSql = $"""
            FROM ic_demandschedule a
            LEFT JOIN ItemMaster b ON a.itemnum = b.ItemNum AND b.tenant_id = a.tenant_id
            WHERE {string.Join(" AND ", where)}
            """;

        var total = await _db.Ado.GetIntAsync($"SELECT COUNT(1) {fromSql}", pars);
        var list = await _db.Ado.SqlQueryAsync<DemandScheduleListRow>(
            $"""
            SELECT
                a.Id AS Id,
                a.itemnum AS ItemNum,
                b.Descr AS Descr,
                b.Descr1 AS Descr1,
                a.fversion AS FVersion,
                a.drawing AS Drawing,
                a.requestdate AS RequestDate,
                a.arrivaldate AS ArrivalDate,
                a.shortqty AS ShortQty,
                a.mesqty AS MesQty,
                a.locqty AS LocQty,
                a.sechedqty AS SechedQty,
                a.tosechedqty AS ToSechedQty,
                CASE IFNULL(a.status,'') WHEN 'P' THEN '已发布' ELSE '' END AS StatusText,
                CASE IFNULL(a.status,'') WHEN 'P' THEN DATE_FORMAT(a.update_time,'%Y-%m-%d') ELSE '' END AS PublishDate,
                IFNULL(a.status,'') AS Status,
                a.remarks AS Remarks,
                a.tenant_id AS TenantId,
                a.factory_id AS FactoryId,
                a.company_id AS CompanyId,
                a.wolist AS WoList
            {fromSql}
            ORDER BY a.requestdate DESC, a.Id DESC
            LIMIT {pageSize} OFFSET {offset}
            """,
            pars);

        return new { total, page, pageSize, list };
    }

    [DisplayName("获取物料需求计划详情")]
    [HttpGet("demand-schedule/{id:long}")]
    public async Task<object> GetDetail(long id)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var row = await _rep.GetFirstAsync(x => x.Id == id && (x.IsDeleted == null || x.IsDeleted == 0) && x.TenantId == tenantId);
        if (row == null) throw Oops.Oh("记录不存在");
        return row;
    }

    [DisplayName("保存物料需求计划")]
    [ApiDescriptionSettings(Name = "SaveDemandSchedule"), HttpPost("demand-schedule/save")]
    public async Task<object> Save([FromBody] DemandScheduleSaveInput input)
    {
        if (string.IsNullOrWhiteSpace(input.ItemNum)) throw Oops.Oh("物料编号不能为空");
        if (string.IsNullOrWhiteSpace(input.RequestDate)) throw Oops.Oh("需求日期不能为空");
        if (string.IsNullOrWhiteSpace(input.ArrivalDate)) throw Oops.Oh("建议到货日期不能为空");
        if (input.ToSechedQty is null) throw Oops.Oh("物料净需求数量不能为空");

        if (input.Id is null or 0)
        {
            var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
            var entity = input.Adapt<DemandSchedule>();
            entity.Id = YitIdHelper.NextId();
            entity.ItemNum = input.ItemNum?.Trim();
            entity.IsHistoryVersion = null;
            entity.Status ??= string.Empty;
            entity.IsDeleted ??= 0;
            entity.TenantId = tenantId;
            entity.CompanyId ??= 1000;
            entity.CreateBy = _userManager.UserId;
            entity.CreateByName = _userManager.Account;
            entity.CreateTime = DateTime.Now;
            entity.UpdateBy = _userManager.UserId;
            entity.UpdateByName = _userManager.Account;
            entity.UpdateTime = DateTime.Now;
            entity.RequestDate = ParseDate(input.RequestDate);
            entity.ArrivalDate = ParseDate(input.ArrivalDate);
            await _rep.InsertAsync(entity);
            return new { id = entity.Id, message = "新增成功" };
        }
        else
        {
            var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
            var entity = await _rep.GetFirstAsync(x => x.Id == input.Id.Value && (x.IsDeleted == null || x.IsDeleted == 0) && x.TenantId == tenantId)
                         ?? throw Oops.Oh("记录不存在");

            entity.ItemNum = input.ItemNum?.Trim();
            entity.FVersion = input.FVersion;
            entity.Drawing = input.Drawing;
            entity.RequestDate = ParseDate(input.RequestDate);
            entity.ArrivalDate = ParseDate(input.ArrivalDate);
            entity.ShortQty = input.ShortQty;
            entity.MesQty = input.MesQty;
            entity.LocQty = input.LocQty;
            entity.SechedQty = input.SechedQty;
            entity.ToSechedQty = input.ToSechedQty;
            entity.Remarks = input.Remarks;
            entity.CompanyId = input.CompanyId ?? entity.CompanyId ?? 1000;
            entity.FactoryId = input.FactoryId ?? entity.FactoryId;
            entity.UpdateBy = _userManager.UserId;
            entity.UpdateByName = _userManager.Account;
            entity.UpdateTime = DateTime.Now;
            await _rep.UpdateAsync(entity);
            return new { id = entity.Id, message = "编辑成功" };
        }
    }

    [DisplayName("删除物料需求计划")]
    [HttpPost("demand-schedule/delete/{id:long}")]
    public async Task<object> Delete(long id)
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var entity = await _rep.GetFirstAsync(x => x.Id == id && (x.IsDeleted == null || x.IsDeleted == 0) && x.TenantId == tenantId)
                     ?? throw Oops.Oh("记录不存在");

        entity.IsDeleted = 1;
        entity.UpdateBy = _userManager.UserId;
        entity.UpdateByName = _userManager.Account;
        entity.UpdateTime = DateTime.Now;
        await _rep.UpdateAsync(entity);
        return new { message = "删除成功" };
    }

    [DisplayName("勾选发布")]
    [HttpPost("demand-schedule/publish-selected")]
    public async Task<object> PublishSelected([FromBody] DemandScheduleBatchIdsInput input)
    {
        var ids = ParseIds(input.Ids);
        if (!ids.Any()) throw Oops.Oh("请选择要发布的数据");

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var affected = await _db.Updateable<DemandSchedule>()
            .SetColumns(x => new DemandSchedule
            {
                Status = "P",
                UpdateBy = _userManager.UserId,
                UpdateByName = _userManager.Account,
                UpdateTime = DateTime.Now
            })
            .Where(x => ids.Contains(x.Id) && (x.IsDeleted == null || x.IsDeleted == 0) && (x.Status == null || x.Status == "") && x.TenantId == tenantId)
            .ExecuteCommandAsync();
        return new { affected, message = affected > 0 ? "发布成功" : "无可发布数据" };
    }

    [DisplayName("全部发布")]
    [HttpPost("demand-schedule/publish-all")]
    public async Task<object> PublishAll()
    {
        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var affected = await _db.Updateable<DemandSchedule>()
            .SetColumns(x => new DemandSchedule
            {
                Status = "P",
                UpdateBy = _userManager.UserId,
                UpdateByName = _userManager.Account,
                UpdateTime = DateTime.Now
            })
            .Where(x => (x.IsDeleted == null || x.IsDeleted == 0) && (x.Status == null || x.Status == "") && x.TenantId == tenantId)
            .ExecuteCommandAsync();
        return new { affected, message = affected > 0 ? "全部发布成功" : "无可发布数据" };
    }

    [DisplayName("取消发布")]
    [HttpPost("demand-schedule/unpublish-selected")]
    public async Task<object> UnPublishSelected([FromBody] DemandScheduleBatchIdsInput input)
    {
        var ids = ParseIds(input.Ids);
        if (!ids.Any()) throw Oops.Oh("请选择要取消发布的数据");

        var tenantId = AidopTenantScope.ResolveOrThrow(_userManager);
        var affected = await _db.Updateable<DemandSchedule>()
            .SetColumns(x => new DemandSchedule
            {
                Status = "",
                UpdateBy = _userManager.UserId,
                UpdateByName = _userManager.Account,
                UpdateTime = DateTime.Now
            })
            .Where(x => ids.Contains(x.Id) && (x.IsDeleted == null || x.IsDeleted == 0) && x.Status == "P" && x.TenantId == tenantId)
            .ExecuteCommandAsync();
        return new { affected, message = affected > 0 ? "取消发布成功" : "无可取消发布数据" };
    }

    private static DateTime? ParseDate(string? value)
    {
        return DateTime.TryParse(value, out var dt) ? dt.Date : null;
    }

    private static List<long> ParseIds(string ids)
    {
        return ids.Split(',', StringSplitOptions.RemoveEmptyEntries)
            .Select(x => long.TryParse(x.Trim(), out var id) ? id : 0)
            .Where(x => x > 0)
            .Distinct()
            .ToList();
    }

    private sealed class DemandScheduleListRow
    {
        public long Id { get; set; }
        public string? ItemNum { get; set; }
        public string? Descr { get; set; }
        public string? Descr1 { get; set; }
        public string? FVersion { get; set; }
        public string? Drawing { get; set; }
        public DateTime? RequestDate { get; set; }
        public DateTime? ArrivalDate { get; set; }
        public decimal? ShortQty { get; set; }
        public decimal? MesQty { get; set; }
        public decimal? LocQty { get; set; }
        public decimal? SechedQty { get; set; }
        public decimal? ToSechedQty { get; set; }
        public string? Status { get; set; }
        public string? StatusText { get; set; }
        public string? PublishDate { get; set; }
        public string? Remarks { get; set; }
        public long? TenantId { get; set; }
        public long? FactoryId { get; set; }
        public long? CompanyId { get; set; }
        public string? WoList { get; set; }
    }
}