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

namespace Admin.NET.Plugin.AiDOP.Order;

/// <summary>
/// 出货计划服务 📦
/// 路由前缀：/api/Order/shippingplan/...
/// </summary>
[ApiDescriptionSettings(Order = 290, Description = "出货计划")]
[Route("api/Order")]
[AllowAnonymous]
[NonUnify]
public class ShippingPlanService : IDynamicApiController, ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly SqlSugarRepository<ShippingPlan> _planRep;
    private readonly SqlSugarRepository<ShippingPlanDetail> _detailRep;
    private readonly SqlSugarRepository<AsnShipperMaster> _asnMasterRep;
    private readonly SqlSugarRepository<AsnShipperDetail> _asnDetailRep;
    private readonly UserManager _userManager;

    public ShippingPlanService(
        ISqlSugarClient db,
        SqlSugarRepository<ShippingPlan> planRep,
        SqlSugarRepository<ShippingPlanDetail> detailRep,
        SqlSugarRepository<AsnShipperMaster> asnMasterRep,
        SqlSugarRepository<AsnShipperDetail> asnDetailRep,
        UserManager userManager)
    {
        _db = db;
        _planRep = planRep;
        _detailRep = detailRep;
        _asnMasterRep = asnMasterRep;
        _asnDetailRep = asnDetailRep;
        _userManager = userManager;
    }

    // ══════════════════════════════════════════════════════════════
    // 列表 GET /api/Order/shippingplan/list
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取出货计划分页列表 📦</summary>
    [DisplayName("获取出货计划列表")]
    [HttpGet("shippingplan/list")]
    public async Task<object> GetShippingPlanList([FromQuery] ShippingPlanListInput input)
    {
        var pars = new List<SugarParameter>();
        var conditions = new List<string>();

        if (!string.IsNullOrWhiteSpace(input.OrdNbr))
        {
            conditions.Add("b.OrdNbr LIKE @OrdNbr");
            pars.Add(new SugarParameter("@OrdNbr", $"%{input.OrdNbr.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.BillNo))
        {
            conditions.Add("b.bill_no LIKE @BillNo");
            pars.Add(new SugarParameter("@BillNo", $"%{input.BillNo.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.Country))
        {
            conditions.Add("b.Country = @Country");
            pars.Add(new SugarParameter("@Country", input.Country.Trim()));
        }
        if (!string.IsNullOrWhiteSpace(input.ShippingDateFrom))
        {
            conditions.Add("a.ShippingDate >= @ShippingDateFrom");
            pars.Add(new SugarParameter("@ShippingDateFrom", input.ShippingDateFrom.Trim()));
        }
        if (!string.IsNullOrWhiteSpace(input.CustomNo))
        {
            conditions.Add("b.CustomNo LIKE @CustomNo");
            pars.Add(new SugarParameter("@CustomNo", $"%{input.CustomNo.Trim()}%"));
        }
        if (!string.IsNullOrWhiteSpace(input.ItemNum))
        {
            conditions.Add("b.ItemNum LIKE @ItemNum");
            pars.Add(new SugarParameter("@ItemNum", $"%{input.ItemNum.Trim()}%"));
        }

        var whereClause = conditions.Count > 0 ? "WHERE " + string.Join(" AND ", conditions) : "";

        var baseSql = $"""
            SELECT
                a.ShippingSite,
                a.LotSerial,
                a.ShippingDate,
                a.ShippingAddress,
                a.Consignee,
                a.Telephone,
                a.RecID     AS Id,
                b.OrdNbr,
                b.bill_no   AS BillNo,
                b.OrdDate,
                b.Country,
                b.CustomNo,
                b.CustomName,
                b.ItemNum,
                b.ItemName,
                b.Specification,
                b.Qty,
                b.Packaging,
                CAST(c.RecID AS CHAR)     AS AsnRecID,
                CAST(b.RecID AS CHAR)     AS Sid,
                b.Volume,
                b.Weight
            FROM ShippingPlan a
            LEFT JOIN ShippingPlanDetail b ON a.RecID = b.plan_id
            LEFT JOIN ASNBOLShipperDetail c ON b.ItemNum = c.ContainerItem
                AND b.bill_no = c.ordnbr
                AND c.shtype = 'SH'
                AND c.Typed <> 'S'
                AND c.IsActive = 1
            {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<ShippingPlanListRow>(
            $"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/shippingplan/{id}
    // ══════════════════════════════════════════════════════════════
    /// <summary>获取出货计划详情（含明细）📦</summary>
    [DisplayName("获取出货计划详情")]
    [HttpGet("shippingplan/{id}")]
    public async Task<object> GetShippingPlanDetail(int id)
    {
        var plan = await _planRep.GetFirstAsync(u => u.RecID == id)
                   ?? throw Oops.Oh("出货计划不存在");

        var details = await _detailRep.GetListAsync(u => u.PlanId == id);

        return new
        {
            recID = plan.RecID,
            lotSerial = plan.LotSerial,
            shippingDate = plan.ShippingDate?.ToString("yyyy-MM-dd"),
            shippingSite = plan.ShippingSite,
            consignee = plan.Consignee,
            shippingAddress = plan.ShippingAddress,
            telephone = plan.Telephone,
            remark = plan.Remark,
            details = details.Select(d => new
            {
                recID = d.RecID,
                ordNbr = d.OrdNbr,
                billNo = d.BillNo,
                customNo = d.CustomNo,
                customName = d.CustomName,
                ordDate = d.OrdDate?.ToString("yyyy-MM-dd"),
                country = d.Country,
                itemNum = d.ItemNum,
                itemName = d.ItemName,
                specification = d.Specification,
                qty = d.Qty,
                weight = d.Weight,
                volume = d.Volume,
                packaging = d.Packaging,
                remark = d.Remark,
            })
        };
    }

    // ══════════════════════════════════════════════════════════════
    // 保存（新增/编辑）POST /api/Order/shippingplan/save
    // ══════════════════════════════════════════════════════════════
    /// <summary>保存出货计划（新增或编辑）📦</summary>
    [DisplayName("保存出货计划")]
    [ApiDescriptionSettings(Name = "SaveShippingPlan"), HttpPost("shippingplan/save")]
    public async Task<object> SaveShippingPlan([FromBody] ShippingPlanSaveInput input)
    {
        var now = DateTime.Now;
        var user = _userManager.Account ?? "system";

        if (input.RecID is null or 0)
        {
            // ── 新增：参照 SysJobService.AddJobDetail ──
            var nextPlanId = await _db.Ado.GetIntAsync("SELECT IFNULL(MAX(RecID), 0) FROM ShippingPlan") + 1;
            var entity = new ShippingPlan
            {
                RecID = nextPlanId,
                Domain = "8010",
                Priority = 0,
                LotSerial = input.LotSerial,
                ShippingDate = string.IsNullOrWhiteSpace(input.ShippingDate) ? null : DateTime.Parse(input.ShippingDate),
                ShippingSite = input.ShippingSite,
                Consignee = input.Consignee,
                ShippingAddress = input.ShippingAddress,
                Telephone = input.Telephone,
                Remark = input.Remark,
                IsActive = 1,
                IsConfirm = 1,
                CreateUser = user,
                CreateTime = now,
            };
            await _planRep.InsertAsync(entity);
            await SaveDetailsAsync(nextPlanId, input.Details, user, now, isNew: true);
            return new { id = nextPlanId, message = "新增成功" };
        }
        else
        {
            // ── 编辑：参照 SysJobService.UpdateJobDetail ──
            var entity = await _planRep.GetFirstAsync(u => u.RecID == input.RecID.Value)
                         ?? throw Oops.Oh("出货计划不存在");

            entity.LotSerial = input.LotSerial;
            entity.ShippingDate = string.IsNullOrWhiteSpace(input.ShippingDate) ? null : DateTime.Parse(input.ShippingDate);
            entity.ShippingSite = input.ShippingSite;
            entity.Consignee = input.Consignee;
            entity.ShippingAddress = input.ShippingAddress;
            entity.Telephone = input.Telephone;
            entity.Remark = input.Remark;
            entity.UpdateUser = user;
            entity.UpdateTime = now;
            await _planRep.UpdateAsync(entity);

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

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

        // RecID 列无 AUTO_INCREMENT，手动取当前最大值后顺序递增
        var nextId = await _db.Ado.GetIntAsync("SELECT IFNULL(MAX(RecID), 0) FROM ShippingPlanDetail") + 1;

        foreach (var d in details)
        {
            if (d.RecID > 0 && dbById.TryGetValue(d.RecID!.Value, out var existing))
            {
                // ① 更新
                existing.OrdNbr = d.OrdNbr;
                existing.BillNo = d.BillNo;
                existing.CustomNo = d.CustomNo;
                existing.CustomName = d.CustomName;
                existing.OrdDate = string.IsNullOrWhiteSpace(d.OrdDate) ? null : DateTime.Parse(d.OrdDate);
                existing.Country = d.Country;
                existing.ItemNum = d.ItemNum;
                existing.ItemName = d.ItemName;
                existing.Specification = d.Specification;
                existing.Qty = d.Qty;
                existing.Weight = d.Weight;
                existing.Volume = d.Volume;
                existing.Packaging = d.Packaging;
                existing.Remark = d.Remark;
                existing.UpdateUser = user;
                existing.UpdateTime = now;
                await _detailRep.UpdateAsync(existing);
            }
            else
            {
                // ② 新增
                var detail = new ShippingPlanDetail
                {
                    RecID = nextId++,
                    PlanId = planId,
                    Domain = "8010",
                    SentryId = long.TryParse(d.SentryId, out var sid) ? sid : null,
                    OrdNbr = d.OrdNbr,
                    BillNo = d.BillNo,
                    CustomNo = d.CustomNo,
                    CustomName = d.CustomName,
                    OrdDate = string.IsNullOrWhiteSpace(d.OrdDate) ? null : DateTime.Parse(d.OrdDate),
                    Country = d.Country,
                    ItemNum = d.ItemNum,
                    ItemName = d.ItemName,
                    Specification = d.Specification,
                    Qty = d.Qty,
                    Weight = d.Weight,
                    Volume = d.Volume,
                    Packaging = d.Packaging,
                    Remark = d.Remark,
                    IsActive = 1,
                    IsConfirm = 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/shippingplan/ship
    // ══════════════════════════════════════════════════════════════
    /// <summary>销售出库（按出货计划生成 ASN 发货单）📦</summary>
    [DisplayName("销售出库")]
    [ApiDescriptionSettings(Name = "ShipShippingPlan"), HttpPost("shippingplan/ship")]
    public async Task<object> ShipShippingPlan([FromBody] ShippingPlanShipInput input)
    {
        var ids = ParseIds(input.Ids);
        if (ids.Count == 0)
            throw Oops.Oh("ids 不能为空");

        var tenantId = _userManager.TenantId;
        var account = _userManager.Account ?? "system";
        var now = DateTime.Now;

        var plans = await _planRep.GetListAsync(u => ids.Contains(u.RecID) && u.TenantId == tenantId);
        var planIds = plans.Select(u => u.RecID).ToHashSet();
        var details = await _detailRep.GetListAsync(u =>
            u.TenantId == tenantId &&
            ((u.PlanId.HasValue && planIds.Contains(u.PlanId.Value)) || ids.Contains(u.RecID)));

        if (details.Count == 0)
            throw Oops.Oh("未找到可出库的出货计划明细");

        var missingPlanIds = details
            .Where(u => u.PlanId.HasValue && !planIds.Contains(u.PlanId.Value))
            .Select(u => u.PlanId!.Value)
            .Distinct()
            .ToList();
        if (missingPlanIds.Count > 0)
        {
            var extraPlans = await _planRep.GetListAsync(u => missingPlanIds.Contains(u.RecID) && u.TenantId == tenantId);
            plans.AddRange(extraPlans);
            planIds = plans.Select(u => u.RecID).ToHashSet();
        }

        var planById = plans.ToDictionary(u => u.RecID);
        var shippableRows = details
            .Where(u => u.PlanId.HasValue && planById.ContainsKey(u.PlanId.Value))
            .Where(u => !string.IsNullOrWhiteSpace(u.BillNo) && !string.IsNullOrWhiteSpace(u.ItemNum))
            .ToList();
        if (shippableRows.Count == 0)
            throw Oops.Oh("出货计划明细缺少订单号或物料编号，不能出库");

        var skipped = 0;
        var createdMasters = 0;
        var createdDetails = 0;
        var createdShipIds = new List<string>();

        _db.Ado.BeginTran();
        try
        {
            foreach (var group in shippableRows.GroupBy(u => u.BillNo!.Trim()))
            {
                var rows = new List<ShippingPlanDetail>();
                foreach (var row in group)
                {
                    var exists = await _asnDetailRep.IsAnyAsync(u =>
                        u.TenantId == tenantId &&
                        u.ShType == "SH" &&
                        u.Typed != "S" &&
                        u.IsActive == 1 &&
                        u.OrdNbr == row.BillNo &&
                        u.ContainerItem == row.ItemNum);
                    if (exists)
                    {
                        skipped++;
                        continue;
                    }

                    rows.Add(row);
                }

                if (rows.Count == 0)
                    continue;

                var first = rows[0];
                var firstPlan = planById[first.PlanId!.Value];
                var shipId = await GenerateShipIdAsync(tenantId);
                var master = new AsnShipperMaster
                {
                    Domain = firstPlan.Domain,
                    Id = shipId,
                    OrdNbr = group.Key,
                    SoldTo = first.CustomNo,
                    ShipDate = firstPlan.ShippingDate,
                    Status = string.Empty,
                    Remark = $"由出货计划生成：{string.Join(",", rows.Select(u => u.RecID))}",
                    ShType = "SH",
                    Typed = string.Empty,
                    IsActive = 1,
                    IsConfirm = 0,
                    Site = firstPlan.ShippingSite,
                    GrossWeight = rows.Sum(u => u.Weight ?? 0),
                    NetWeight = rows.Sum(u => u.Weight ?? 0),
                    Volume = rows.Sum(u => u.Volume ?? 0),
                    CreateUser = account,
                    CreateTime = now,
                    TenantId = tenantId
                };

                var inserted = await _asnMasterRep.AsInsertable(master).ExecuteReturnEntityAsync();
                createdMasters++;
                createdShipIds.Add(shipId);

                for (var i = 0; i < rows.Count; i++)
                {
                    var row = rows[i];
                    var plan = planById[row.PlanId!.Value];
                    var detail = new AsnShipperDetail
                    {
                        Domain = row.Domain ?? plan.Domain,
                        Id = shipId,
                        AsnShipperRecID = inserted.RecID,
                        Line = i + 1,
                        OrdNbr = row.BillNo,
                        ContainerItem = row.ItemNum,
                        Descr = row.ItemName,
                        LotSerial = plan.LotSerial,
                        QtyToShip = row.Qty,
                        PickingQty = null,
                        RealQty = null,
                        Status = string.Empty,
                        Remark = BuildShipDetailRemark(row),
                        ShType = "SH",
                        Typed = string.Empty,
                        IsActive = 1,
                        IsConfirm = 0,
                        ShipDate = plan.ShippingDate,
                        Site = plan.ShippingSite,
                        CreateUser = account,
                        CreateTime = now,
                        TenantId = tenantId
                    };

                    await _asnDetailRep.InsertAsync(detail);
                    createdDetails++;
                }
            }

            _db.Ado.CommitTran();
        }
        catch
        {
            _db.Ado.RollbackTran();
            throw;
        }

        if (createdDetails == 0)
            return new { message = "勾选明细已生成过销售出库单", createdMasters, createdDetails, skipped };

        return new { message = "销售出库执行成功", createdMasters, createdDetails, skipped, shipIds = createdShipIds };
    }

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

    private static string BuildShipDetailRemark(ShippingPlanDetail row)
    {
        var source = $"来源出货计划明细:{row.RecID}";
        return string.IsNullOrWhiteSpace(row.Remark) ? source : $"{row.Remark}; {source}";
    }

    /// <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.TenantId == tenantId && u.Id != null && u.Id.StartsWith(prefix))
            .MaxAsync(u => u.Id);

        var next = 1;
        if (!string.IsNullOrWhiteSpace(maxId) &&
            maxId.Length >= prefix.Length + 4 &&
            int.TryParse(maxId[^4..], out var current))
        {
            next = current + 1;
        }

        return $"{prefix}{next:D4}";
    }

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

    private sealed class ShippingPlanListRow
    {
        public int Id { get; set; }
        public string? LotSerial { get; set; }
        public string? OrdNbr { get; set; }
        public string? BillNo { get; set; }
        public DateTime? OrdDate { get; set; }
        public string? Country { get; set; }
        public string? CustomNo { get; set; }
        public string? CustomName { get; set; }
        public string? ItemNum { get; set; }
        public string? ItemName { get; set; }
        public string? Specification { get; set; }
        public decimal? Qty { get; set; }
        public decimal? Weight { get; set; }
        public decimal? Volume { get; set; }
        public string? Packaging { get; set; }
        public string? ShippingSite { get; set; }
        public DateTime? ShippingDate { get; set; }
        public string? ShippingAddress { get; set; }
        public string? Consignee { get; set; }
        public string? Telephone { get; set; }
        public string? AsnRecID { get; set; }
        public string? Sid { get; set; }
    }
}