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

using System.Globalization;
using System.Text.Json;
using Admin.NET.Plugin.AiDOP.Entity.DataPlatform;
using Microsoft.Extensions.Options;
using Yitter.IdGenerator;

namespace Admin.NET.Plugin.AiDOP.Supply;

/// <summary>
/// 采购申请外部事务推送服务。对齐旧 PrSendSAP：写 QadTracking；真实 SAP/QAD 默认关闭。
/// 同步写 mdp_outbox（S3_PR_PUSH）占位，供配置真实源后由 MdpOutboxPushJob 推送；不替代审批流白名单。
/// </summary>
public class PurchaseRequestExternalPushService : ITransient
{
    private readonly ISqlSugarClient _db;
    private readonly AidopProcurementOptions _options;

    public PurchaseRequestExternalPushService(ISqlSugarClient db, IOptions<AidopProcurementOptions> options)
    {
        _db = db;
        _options = options.Value ?? new AidopProcurementOptions();
    }

    public async Task<PurchaseRequestExternalPushResult> CreateQadTrackingForGeneratedRequestsAsync(List<PurchaseRequestMain> requests, string account)
    {
        var result = new PurchaseRequestExternalPushResult();
        var candidates = SelectPushCandidates(requests);
        if (candidates.Count == 0) return result;

        if (_options.EnableRealSapPush)
            result.Warnings.Add("EnableRealSapPush=true，但真实 SAP/QAD 接口未接入，仍仅写 QadTracking 事务记录。");

        if (!await QadTrackingTableExistsAsync())
        {
            result.Warnings.Add("QadTracking 表不存在，已跳过外部事务写入（主事务不回滚）。");
            result.SkippedCandidateCount = candidates.Count;
            return result;
        }

        var pushedIds = new List<long>();
        foreach (var group in candidates.GroupBy(x => x.TenantId.ToString()))
        {
            var seqId = GenerateSeqId();
            foreach (var pr in group)
            {
                await _db.Ado.ExecuteCommandAsync(
                    """
                    INSERT INTO QadTracking
                    (Ufld1, Domain, SeqID, TransType, Subject, `Order`, `Int1`, CreateTime, CreateUser, UpdateTime, UpdateUser)
                    VALUES
                    ('C', @Domain, @SeqID, 'nbr-pr-mes', '请购单', @Order, @Int1, @Now, @User, @Now, @User)
                    """,
                    new SugarParameter("@Domain", "8010"),
                    new SugarParameter("@SeqID", seqId),
                    new SugarParameter("@Order", pr.PrBillNo),
                    new SugarParameter("@Int1", pr.Id),
                    new SugarParameter("@Now", DateTime.Now),
                    new SugarParameter("@User", account ?? string.Empty));

                pr.State = 2;
                pr.UpdateByName = account;
                pr.UpdateTime = DateTime.Now;
                pushedIds.Add(pr.Id);
                await TryEnqueuePrPushOutboxAsync(pr);
                seqId++;
            }
        }

        result.TrackingCount = pushedIds.Count;
        result.PushedPrIds = pushedIds;
        return result;
    }

    /// <summary>写 mdp_outbox（幂等）；失败不阻断 QadTracking。真实 SAP 仍受 EnableRealSapPush/审批白名单约束。</summary>
    private async Task TryEnqueuePrPushOutboxAsync(PurchaseRequestMain pr)
    {
        try
        {
            var tenantId = pr.TenantId > 0 ? pr.TenantId : 0;
            var idem = string.IsNullOrWhiteSpace(pr.PrBillNo) ? pr.Id.ToString() : pr.PrBillNo!;
            var exists = await _db.Ado.GetIntAsync(
                "SELECT COUNT(1) FROM mdp_outbox WHERE tenant_id=@tid AND target_source_code='WMS_API' AND action_code='S3_PR_PUSH' AND idem_key=@idem",
                new List<SugarParameter> { new("@tid", tenantId), new("@idem", idem) }) > 0;
            if (exists) return;

            var payload = JsonSerializer.Serialize(new
            {
                path = "/pr/push",
                method = "POST",
                body = new
                {
                    prId = pr.Id,
                    prBillNo = pr.PrBillNo,
                    action = "S3_PR_PUSH",
                    note = "placeholder; real SAP/QAD requires EnableRealSapPush + approval whitelist"
                }
            });
            await _db.Insertable(new MdpOutbox
            {
                TenantId = tenantId,
                TargetSourceCode = "WMS_API",
                ActionCode = "S3_PR_PUSH",
                IdemKey = idem,
                PayloadJson = payload,
                Status = 0,
                RetryCount = 0,
                CreateTime = DateTime.Now,
                UpdateTime = DateTime.Now
            }).ExecuteCommandAsync();
        }
        catch
        {
            /* Outbox 失败不影响主流程 */
        }
    }

    public static List<PurchaseRequestMain> SelectPushCandidates(IEnumerable<PurchaseRequestMain> requests)
    {
        return requests
            .Where(x => x.IsRequireGoods == 0
                        && (x.State ?? 0) == 1
                        && !string.IsNullOrWhiteSpace(x.PrBillNo))
            .ToList();
    }

    private async Task<bool> QadTrackingTableExistsAsync()
    {
        var cnt = await _db.Ado.GetIntAsync(
            """
            SELECT COUNT(*) FROM information_schema.tables
            WHERE table_schema = DATABASE() AND table_name = 'QadTracking'
            """);
        return cnt > 0;
    }

    private static long GenerateSeqId()
    {
        var now = DateTime.Now;
        var value = string.Concat(
            now.ToString("yyMMddHHmmss", CultureInfo.InvariantCulture),
            now.Millisecond.ToString("D3", CultureInfo.InvariantCulture),
            Random.Shared.Next(0, 1000).ToString("D3", CultureInfo.InvariantCulture));
        return long.TryParse(value, System.Globalization.NumberStyles.Integer, CultureInfo.InvariantCulture, out var seqId)
            ? seqId + 1
            : YitIdHelper.NextId();
    }
}

public sealed class PurchaseRequestExternalPushResult
{
    public int TrackingCount { get; set; }
    public int SkippedCandidateCount { get; set; }
    public List<long> PushedPrIds { get; set; } = new();
    public List<string> Warnings { get; set; } = new();
}