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

namespace Admin.NET.Plugin.AiDOP.Order;

using Admin.NET.Plugin.AiDOP.Entity.S0.Warehouse;
using Admin.NET.Plugin.AiDOP.Universal;

/// <summary>
/// 订单发货服务 🚚
/// 路由前缀：/api/Order/asnshipper/...
/// </summary>
[ApiDescriptionSettings(Order = 280, Description = "订单发货")]
[Route("api/Order")]
[AllowAnonymous]
[NonUnify]
public class AsnShipperService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly SqlSugarRepository<AsnShipperMaster> _masterRep;
    private readonly SqlSugarRepository<AsnShipperDetail> _detailRep;
    private readonly UserManager _userManager;

    public AsnShipperService(
        ISqlSugarClient db,
        SqlSugarRepository<AsnShipperMaster> masterRep,
        SqlSugarRepository<AsnShipperDetail> detailRep,
        UserManager userManager)
    {
        _db = db;
        _masterRep = masterRep;
        _detailRep = detailRep;
        _userManager = userManager;
    }

    // ══════════════════════════════════════════════════════════════
    // 列表 GET /api/Order/asnshipper/list
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取订单发货分页列表 🚚</summary>
    [DisplayName("获取订单发货列表")]
    [HttpGet("asnshipper/list")]
    public async Task<object> GetAsnShipperList([FromQuery] AsnShipperListInput input)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var conditions = new List<string>
        {
            "a.shtype = 'SH'",
            "a.Typed <> 'S'",
            "a.IsActive = 1",
            "a.tenant_id = @TenantId"
        };

        if (!string.IsNullOrWhiteSpace(input.Id))
        {
            conditions.Add("a.Id LIKE @Id");
            pars.Add(new SugarParameter("@Id", $"%{input.Id.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.OrdNbr))
        {
            conditions.Add("a.OrdNbr LIKE @OrdNbr");
            pars.Add(new SugarParameter("@OrdNbr", $"%{input.OrdNbr.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.Department))
        {
            conditions.Add("(b.Department LIKE @Dept OR b.Descr LIKE @Dept)");
            pars.Add(new SugarParameter("@Dept", $"%{input.Department.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.ShipDateFrom))
        {
            conditions.Add("a.ShipDate >= @ShipDateFrom");
            pars.Add(new SugarParameter("@ShipDateFrom", input.ShipDateFrom.Trim()));
        }

        var whereClause = "WHERE " + string.Join(" AND ", conditions);

        var baseSql = $"""
            SELECT
                a.RecID     AS Id,
                a.Id        AS Id1,
                a.OrdNbr,
                TRIM(CONCAT(IFNULL(b.Department,''), ' ', IFNULL(b.Descr,''))) AS DepartmentName,
                a.ShipDate,
                a.Status,
                a.Remark,
                CASE WHEN EXISTS (
                    SELECT 1 FROM ASNBOLShipperDetail d
                    WHERE d.ASNBOLShipperRecID = a.RecID
                      AND d.tenant_id = a.tenant_id
                      AND IFNULL(d.RealQty, 0) > 0
                ) THEN 1 ELSE 0 END AS HasShipped
            FROM ASNBOLShipperMaster a
            LEFT JOIN DepartmentMaster b
                ON a.Department = b.Department
            {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<AsnShipperListRow>(
            $"SELECT * FROM ({baseSql}) AS t ORDER BY t.Id DESC LIMIT {input.PageSize} OFFSET {offset}",
            pars);

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

    // ══════════════════════════════════════════════════════════════
    // 详情 GET /api/Order/asnshipper/{id}
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取订单发货详情（含明细）🚚</summary>
    [DisplayName("获取订单发货详情")]
    [HttpGet("asnshipper/{id}")]
    public async Task<object> GetAsnShipperDetail(int id)
    {
        var tenantId = _userManager.TenantId;
        var master = await _masterRep.GetFirstAsync(u => u.RecID == id && u.TenantId == tenantId)
                     ?? throw Oops.Oh("发货单不存在");

        // 查询客户名称，用于前端下拉回显"编号+名称"
        var soldToName = (await _db.Queryable<CustMaster>()
            .Where(u => u.Cust == master.SoldTo && u.TenantId == tenantId)
            .Select(u => u.SortName)
            .FirstAsync()) ?? string.Empty;

        // 查询销售单客户名称，用于前端下拉回显"编号_客户名称"
        var ordNbrName = string.IsNullOrWhiteSpace(master.OrdNbr) ? string.Empty
            : ((await _db.Queryable<SeOrder>()
                .Where(u => u.BillNo == master.OrdNbr && u.TenantId == tenantId)
                .Select(u => u.CustomName)
                .FirstAsync()) ?? string.Empty);

        // 查询部门描述，用于前端下拉回显"编号+描述"
        var deptName = string.IsNullOrWhiteSpace(master.Department) ? string.Empty
            : ((await _db.Queryable<AdoS0DepartmentMaster>()
                .Where(u => u.Department == master.Department && u.TenantId == tenantId)
                .Select(u => u.Descr)
                .FirstAsync()) ?? string.Empty);

        // 主键关联：ASNBOLShipperDetail.ASNBOLShipperRecID = 主表 RecID
        var details = await _detailRep.GetListAsync(u => u.AsnShipperRecID == id && u.TenantId == tenantId);
        // 兼容历史数据：若外键未写入或曾用错误方式取 RecID，则按业务单号 Id + 销售单号 OrdNbr 兜底
        if (details.Count == 0 && !string.IsNullOrWhiteSpace(master.Id) && !string.IsNullOrWhiteSpace(master.OrdNbr))
        {
            details = await _detailRep.GetListAsync(u =>
                u.Id == master.Id && u.OrdNbr == master.OrdNbr && u.TenantId == tenantId);
        }

        return new
        {
            recID = master.RecID,
            id = master.Id,
            ordNbr = master.OrdNbr,
            ordNbrName = ordNbrName,
            soldTo = master.SoldTo,
            soldToName = soldToName,
            department = master.Department,
            departmentName = deptName,
            shipDate = master.ShipDate?.ToString("yyyy-MM-dd"),
            status = master.Status ?? string.Empty,
            remark = master.Remark,
            details = details.OrderBy(d => d.Line).Select(d => new
            {
                recID = d.RecID,
                line = d.Line,
                ordNbr = d.OrdNbr,
                ordLine = d.OrdLine,
                containerItem = d.ContainerItem,
                descr = d.Descr,
                um = d.UM,
                location = d.Location,
                lotSerial = d.LotSerial,
                qtyToShip = d.QtyToShip,
                pickingQty = d.PickingQty,
                realQty = d.RealQty,
                status = d.Status,
                remark = d.Remark,
            })
        };
    }

    // ══════════════════════════════════════════════════════════════
    // 保存（新增/编辑）POST /api/Order/asnshipper/save
    // ══════════════════════════════════════════════════════════════
    /// <summary>保存订单发货（新增或编辑）🚚</summary>
    [DisplayName("保存订单发货")]
    [ApiDescriptionSettings(Name = "SaveAsnShipper"), HttpPost("asnshipper/save")]
    public async Task<object> SaveAsnShipper([FromBody] AsnShipperSaveInput input)
    {
        var now = DateTime.Now;
        var user = _userManager.Account ?? "system";

        // 验证明细行至少有一行数据
        if (input.Details == null || input.Details.Count == 0)
        {
            throw Oops.Oh("发货单明细行不能为空，请至少添加一行明细");
        }

        if (input.RecID is null or 0)
        {
            // ── 新增：参照 SysJobService.AddJobDetail ──
            // 若发货单号为空则自动生成 SH+当前日期+四位流水号
            var shipId = input.Id;
            if (string.IsNullOrWhiteSpace(shipId))
            {
                shipId = await GenerateShipIdAsync(_userManager.TenantId);
            }

            var entity = new AsnShipperMaster
            {
                Id = shipId,
                OrdNbr = input.OrdNbr,
                SoldTo = input.SoldTo,
                Department = input.Department,
                ShipDate = string.IsNullOrWhiteSpace(input.ShipDate) ? null : DateTime.Parse(input.ShipDate),
                Status = input.Status,
                Remark = input.Remark,
                ShType = "SH",
                Typed = string.Empty,
                IsActive = 1,
                IsConfirm = 0,
                CreateUser = user,
                CreateTime = now,
            };
            var inserted = await _masterRep.AsInsertable(entity).ExecuteReturnEntityAsync();
            var newId = inserted.RecID;

            await SaveDetailsAsync(newId, input.Id ?? string.Empty, input.Details, user, now, isNew: true);
            return new { id = newId, message = "新增成功" };
        }
        else
        {
            // ── 编辑：参照 SysJobService.UpdateJobDetail ──
            var tenantId = _userManager.TenantId;
            var entity = await _masterRep.GetFirstAsync(u => u.RecID == input.RecID.Value && u.TenantId == tenantId)
                         ?? throw Oops.Oh("发货单不存在");

            entity.Id = input.Id;
            entity.OrdNbr = input.OrdNbr;
            entity.SoldTo = input.SoldTo;
            entity.Department = input.Department;
            entity.ShipDate = string.IsNullOrWhiteSpace(input.ShipDate) ? null : DateTime.Parse(input.ShipDate);
            entity.Status = input.Status;
            entity.Remark = input.Remark;
            entity.UpdateUser = user;
            entity.UpdateTime = now;
            await _masterRep.UpdateAsync(entity);

            await SaveDetailsAsync(input.RecID.Value, input.Id ?? string.Empty, input.Details, user, now, isNew: false);
            return new { id = input.RecID, message = "编辑成功" };
        }
    }

    /// <summary>
    /// 明细三路合并（参照 SeOrderService.SaveEntriesAsync）：
    /// ① DB有且入参有 → 更新
    /// ② DB无入参有   → 新增
    /// ③ DB有入参无   → 删除
    /// </summary>
    private async Task SaveDetailsAsync(int masterRecId, string shipperId,
        List<AsnShipperDetailInput> details, string user, DateTime now, bool isNew)
    {
        var dbDetails = isNew ? new List<AsnShipperDetail>()
            : await _detailRep.GetListAsync(u => u.AsnShipperRecID == masterRecId && u.TenantId == _userManager.TenantId);
        var dbById = dbDetails.ToDictionary(u => u.RecID);
        var inputIds = new HashSet<int>(details.Where(d => d.RecID is > 0).Select(d => d.RecID!.Value));

        for (var i = 0; i < details.Count; i++)
        {
            var d = details[i];
            var lineNo = d.Line ?? (i + 1);

            if (d.RecID > 0 && dbById.TryGetValue(d.RecID!.Value, out var existing))
            {
                // ① 更新
                existing.Line = lineNo;
                existing.OrdNbr = d.OrdNbr;
                existing.OrdLine = d.OrdLine;
                existing.ContainerItem = d.ContainerItem;
                existing.Descr = d.Descr;
                existing.UM = d.UM;
                existing.Location = d.Location;
                existing.LotSerial = d.LotSerial;
                existing.QtyToShip = d.QtyToShip;
                existing.PickingQty = d.PickingQty;
                existing.RealQty = d.RealQty;
                existing.Status = d.Status;
                existing.Remark = d.Remark;
                existing.UpdateUser = user;
                existing.UpdateTime = now;
                await _detailRep.UpdateAsync(existing);
            }
            else
            {
                // ② 新增
                var detail = new AsnShipperDetail
                {
                    Id = shipperId,
                    AsnShipperRecID = masterRecId,
                    Line = lineNo,
                    OrdNbr = d.OrdNbr,
                    OrdLine = d.OrdLine,
                    ContainerItem = d.ContainerItem,
                    Descr = d.Descr,
                    UM = d.UM,
                    Location = d.Location,
                    LotSerial = d.LotSerial,
                    QtyToShip = d.QtyToShip,
                    PickingQty = d.PickingQty,
                    RealQty = d.RealQty,
                    Status = d.Status,
                    Remark = d.Remark,
                    ShType = "SH",
                    IsActive = 1,
                    CreateUser = user,
                    CreateTime = now,
                };
                await _detailRep.InsertAsync(detail);
            }
        }

        // ③ 删除：DB有、入参无
        foreach (var toDelete in dbDetails.Where(u => !inputIds.Contains(u.RecID)))
        {
            await _detailRep.DeleteAsync(u => u.RecID == toDelete.RecID);
        }
    }

    // ══════════════════════════════════════════════════════════════
    // 删除 POST /api/Order/asnshipper/delete
    // ══════════════════════════════════════════════════════════════
    /// <summary>删除发货单（状态非关闭才可删除）🚚</summary>
    [DisplayName("删除订单发货")]
    [ApiDescriptionSettings(Name = "DeleteAsnShipper"), HttpPost("asnshipper/delete")]
    public async Task<object> DeleteAsnShipper([FromBody] AsnShipperDeleteInput input)
    {
        // 参照 SysJobService.DeleteJobDetail：先查再删
        var tenantId = _userManager.TenantId;
        var entity = await _masterRep.GetFirstAsync(u => u.RecID == input.RecID && u.TenantId == tenantId)
                     ?? throw Oops.Oh("发货单不存在");

        if (entity.Status == "C")
            throw Oops.Oh("已关闭的发货单不允许删除");

        await _detailRep.DeleteAsync(u => u.AsnShipperRecID == input.RecID);
        await _masterRep.DeleteAsync(u => u.RecID == input.RecID);

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

    // ══════════════════════════════════════════════════════════════
    // 销售单明细行 GET /api/Order/asnshipper/salesord/{ordNbr}/entries
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取销售单明细行（用于发货单新建时自动填入）🚚</summary>
    [DisplayName("获取销售单明细行")]
    [HttpGet("asnshipper/salesord/{ordNbr}/entries")]
    public async Task<object> GetSalesOrdEntries(string ordNbr)
    {
        var tenantId = _userManager.TenantId;

        // 查询销售单主表，获取客户信息
        var order = await _db.Queryable<SeOrder>()
            .Where(u => u.BillNo == ordNbr && u.TenantId == tenantId && u.IsDeleted == 0)
            .Select(u => new { u.CustomNo, u.CustomName })
            .FirstAsync();

        // 查询销售单明细行（物料信息）
        var entries = await _db.Queryable<SeOrderEntry>()
            .Where(u => u.BillNo == ordNbr && u.TenantId == tenantId && u.IsDeleted == 0)
            .OrderBy(u => u.EntrySeq)
            .Select(u => new
            {
                entrySeq = u.EntrySeq,
                itemNumber = u.ItemNumber,
                itemName = u.ItemName,
                specification = u.Specification,
                unit = u.Unit,
                qty = u.Qty,
            })
            .ToListAsync();

        return new
        {
            ordNbr,
            customNo = order?.CustomNo,
            customName = order?.CustomName,
            entries,
        };
    }

    // ══════════════════════════════════════════════════════════════
    // 下拉数据源 GET /api/Order/asnshipper/options/salesords
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取销售单下拉列表 🚚</summary>
    [DisplayName("获取销售单下拉")]
    [HttpGet("asnshipper/options/salesords")]
    public async Task<object> GetSalesOrdOptions([FromQuery] string? keyword)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = "s.IsDeleted = 0 AND s.tenant_id = @TenantId";
        if (!string.IsNullOrWhiteSpace(keyword))
        {
            where += " AND (s.bill_no LIKE @kw OR s.custom_name LIKE @kw)";
            pars.Add(new SugarParameter("@kw", $"%{keyword.Trim()}%"));
        }

        // MySQL：字符串拼接用 CONCAT（对应 SQL Server 的 bill_no+'_'+custom_name）
        var sql = $"""
            SELECT s.bill_no AS Value,
                CONCAT(s.bill_no, '_', IFNULL(s.custom_name, '')) AS Label
            FROM crm_seorder s
            WHERE {where}
            ORDER BY s.bill_no DESC
            LIMIT 100
            """;

        var list = await _db.Ado.SqlQueryAsync<SimpleKvRow>(sql, pars);
        return list;
    }

    // ══════════════════════════════════════════════════════════════
    // 下拉数据源 GET /api/Order/asnshipper/options/customers
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取客户下拉列表 🚚</summary>
    [DisplayName("获取客户下拉")]
    [HttpGet("asnshipper/options/customers")]
    public async Task<object> GetCustomerOptions([FromQuery] string? keyword)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = "tenant_id = @TenantId";
        if (!string.IsNullOrWhiteSpace(keyword))
        {
            where += " AND (Cust LIKE @kw OR SortName LIKE @kw)";
            pars.Add(new SugarParameter("@kw", $"%{keyword.Trim()}%"));
        }

        var sql = $"""
            SELECT Cust AS Value,
                TRIM(CONCAT(Cust, ' ', IFNULL(SortName,''))) AS Label
            FROM CustMaster
            WHERE {where}
            ORDER BY Cust
            LIMIT 100
            """;

        var list = await _db.Ado.SqlQueryAsync<SimpleKvRow>(sql, pars);
        return list;
    }

    // ══════════════════════════════════════════════════════════════
    // 下拉数据源 GET /api/Order/asnshipper/options/departments
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取部门下拉列表 🚚</summary>
    [DisplayName("获取部门下拉")]
    [HttpGet("asnshipper/options/departments")]
    public async Task<object> GetDepartmentOptions([FromQuery] string? keyword)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = "tenant_id = @TenantId";
        if (!string.IsNullOrWhiteSpace(keyword))
        {
            where += " AND (Department LIKE @kw OR Descr LIKE @kw)";
            pars.Add(new SugarParameter("@kw", $"%{keyword.Trim()}%"));
        }

        var sql = $"""
            SELECT Department AS Value,
                TRIM(CONCAT(Department, ' ', IFNULL(Descr,''))) AS Label
            FROM DepartmentMaster
            WHERE {where}
            ORDER BY Department
            LIMIT 100
            """;

        var list = await _db.Ado.SqlQueryAsync<SimpleKvRow>(sql, pars);
        return list;
    }

    // ══════════════════════════════════════════════════════════════
    // 下拉数据源 GET /api/Order/asnshipper/options/locations
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取库位下拉列表 🚚</summary>
    [DisplayName("获取库位下拉")]
    [HttpGet("asnshipper/options/locations")]
    public async Task<object> GetLocationOptions([FromQuery] string? keyword)
    {
        var tenantId = _userManager.TenantId;
        var pars = new List<SugarParameter> { new("@TenantId", tenantId) };
        var where = "tenant_id = @TenantId AND is_active = 1";
        if (!string.IsNullOrWhiteSpace(keyword))
        {
            where += " AND (location LIKE @kw OR descr LIKE @kw)";
            pars.Add(new SugarParameter("@kw", $"%{keyword.Trim()}%"));
        }

        var sql = $"""
            SELECT location AS Value,
                TRIM(CONCAT(location, ' ', IFNULL(descr, ''))) AS Label
            FROM LocationMaster
            WHERE {where}
            ORDER BY location
            LIMIT 100
            """;

        var list = await _db.Ado.SqlQueryAsync<SimpleKvRow>(sql, pars);
        return list;
    }

    // ──────────────── 号生成 ────────────────

    /// <summary>
    /// 生成发货单号：SH + yyyyMMdd + 4位流水号，例如 SH202605210001
    /// </summary>
    private async Task<string> GenerateShipIdAsync(long tenantId)
    {
        var today = DateTime.Now.ToString("yyyyMMdd");
        var prefix = $"SH{today}";

        // 查询当天已有的最大发货单号
        var maxId = await _db.Queryable<AsnShipperMaster>()
            .Where(u => u.Id!.StartsWith(prefix) && u.IsActive == 1 && u.TenantId == tenantId)
            .OrderBy(u => u.Id, OrderByType.Desc)
            .Select(u => u.Id)
            .FirstAsync();

        if (string.IsNullOrEmpty(maxId))
            return $"{prefix}0001";

        // 取后4位转为数字并加1，不足4位补零
        var last4 = maxId.Length >= 4 ? maxId[^4..] : maxId;
        if (int.TryParse(last4, out var serial))
            return $"{prefix}{(serial + 1).ToString().PadLeft(4, '0')}";

        return $"{prefix}0001";
    }

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

    private sealed class AsnShipperListRow
    {
        public int Id { get; set; }
        public string? Id1 { get; set; }
        public string? OrdNbr { get; set; }
        public string? DepartmentName { get; set; }
        public DateTime? ShipDate { get; set; }
        public string? Status { get; set; }
        public string? Remark { get; set; }
        public bool HasShipped { get; set; }
    }

    private sealed class SimpleKvRow
    {
        public string? Value { get; set; }
        public string? Label { get; set; }
    }
}