dotnet/molilian.core/Core/taoke/UnionParseCore.cs

using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc.Controllers;
using Microsoft.AspNetCore.Mvc.Filters;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using dodohold.core;
using Spire.Pdf.Exporting.XPS.Schema;
using System.Xml.Linq;
using System.Net;
using TencentCloud.Mrs.V20200910.Models;
using Microsoft.AspNetCore.Mvc;
using Microsoft.AspNetCore.Authentication;
using Spire.Pdf.Graphics;
using Google.Protobuf.WellKnownTypes;
using TencentCloud.Tcm.V20210413.Models;
using System.Diagnostics;
using System.Threading;
using TencentCloud.Soe.V20180724.Models;


namespace molilian.core
{
    public partial class UnionParseCore
    {

        public static async Task<ActionResult> UnionParseAsync(string content, string channel, string ip, string oaid, int accountid = 0)
        {
            return channel switch
            {
                "wemeet" => await WemeetParseAsync(content, ip, oaid),
                "bdpan" => PanParse(content, ip, oaid),
                "jd" => await JdParseAsync(content, ip, oaid),
                "dy" => await DyParseAsync(content, ip, oaid),
                _ => await TaobaoParseAsync(content, ip, oaid, accountid),
            };
        }


        public static async Task<APIResult> WemeetParseAsync(string content, string ip, string oaid)
        {
            var result = ToolParsePlus.GetFormattedObject(TkChannelEnum.wemeet, content, ip, oaid);
            content = content.UrlDecode();
            result.rawContent = content;
            try
            {
                result = await ToolParsePlus.WemeetParseAsync(content, result);
            }
            catch (Exception ex)
            {
                _ = new LoggerLibrary("unionParse", "wemeet_error")
                    .Info(ip, oaid)
                    .Info(content)
                    .Info(ex.Message, ex.StackTrace)
                    .SaveAsync();
                NotifyCore.Notify(new NifyMessage
                {
                    message = $"【转链异常Wemeet】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                    priority = NifyMessagePriority.high,
                    tags = ["red_circle"]
                });
                result.success = false;
                result.message = "内部错误";
                result.reason = "转链接口异常";
            }
            _ = TkLogCore.ParseLogAsync(result);
            return new APIResult(new
            {
                result.success,
                result.message,
                channel = result?.channel.ToString(),
                result.shortLinkurl,
                result.deeplink_url,
                result.itemName,
            });
        }

        public static APIResult PanParse(string content, string ip, string oaid)
        {
            var result = ToolParsePlus.GetFormattedObject(TkChannelEnum.bdpan, content, ip, oaid);
            content = content.UrlDecode();
            result.rawContent = content;
            try
            {
                ToolParsePlus.PanParse(content, ref result);
            }
            catch (Exception ex)
            {
                _ = new LoggerLibrary("unionParse", "pan_error")
                    .Info(ip, oaid)
                    .Info(content)
                    .Info(ex.Message, ex.StackTrace)
                    .SaveAsync();
                NotifyCore.Notify(new NifyMessage
                {
                    message = $"【转链异常Pan】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                    priority = NifyMessagePriority.high,
                    tags = ["red_circle"]
                });
                result.success = false;
                result.message = "内部错误";
                result.reason = "转链接口异常";
            }
            _ = TkLogCore.ParseLogAsync(result);
            return new APIResult(new
            {
                result.success,
                result.message,
                channel = result?.channel.ToString(),
                result.shortLinkurl,
                result.deeplink_url,
                result.itemName,
            }, result.success ? APIResultCodeEnum.OK : APIResultCodeEnum.NotAcceptable);
        }


        private static APIResult TaobaoParseOutput(TkDataDTO result, Dictionary<string, long> swData, object info, APIResultCodeEnum code = APIResultCodeEnum.OK)
        {
            if (result.elapsedTime > 2000)
            {
                LoggerLibrary log = new("debug", "stopwatch");
                foreach ((var key, var value) in swData)
                {
                    log.Info($"{key}\t{value}");
                }
                log.SaveAsync();
            }
            return new APIResult(info, code);
        }

        public static async Task<APIResult> TaobaoParseAsync(string content,
            string ip = "", string oaid = "",
            int accountid = 0)
        {
            AlimamaPlus alimama = null;
            content = content.UrlDecode();
            content = content[..Math.Min(1000, content.Length)];
            var result = AlimamaPlus.GetFormattedObject(content, ip, oaid);

            Dictionary<string, long> swData = new();
            swData.Add("StartNew", 0);
            Stopwatch stopwatch = Stopwatch.StartNew();

            result.rawContent = content;
            try
            {
                bool is_other = await AlimamaPlus.OtherPlatformAsync(content);
                stopwatch.Stop();
                swData.Add("OtherPlatform", stopwatch.ElapsedMilliseconds);

                if (is_other)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "平台错误";

                    _ = TkLogCore.ParseLogAsync(result);
                    return TaobaoParseOutput(result, swData, new
                    {
                        channel = result?.channel.ToString(),
                        result.success,
                        result.message,
                        result.shortLinkurl,
                        result.deeplink_url,
                    }, APIResultCodeEnum.NotAcceptable);
                }

                stopwatch.Reset();
                stopwatch.Start();
                string reason = string.Empty;
                bool is_ignore = AlimamaPlus.FirstFilterIgnoreRequest(content, out reason);
                stopwatch.Stop();
                swData.Add("FirstFilterIgnoreRequest", stopwatch.ElapsedMilliseconds);

                if (string.IsNullOrEmpty(result.shortLinkurl) && is_ignore)
                {
                    //没有短链接都放弃
                    result.success = false;
                    result.message = "放弃转链";
                    result.itemName = "点击打开淘宝APP";
                    result.reason = "初步筛选";
                    _ = TkLogCore.ParseLogAsync(result);
                    return TaobaoParseOutput(result, swData, new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.itemName,
                        result.deeplink_url,
                    });
                }


                stopwatch.Reset();
                stopwatch.Start();
                bool is_ignore2 = AlimamaPlus.ShouldIgnoreRequest(ip, oaid, out reason);
                stopwatch.Stop();
                swData.Add("ShouldIgnoreRequest", stopwatch.ElapsedMilliseconds);

#if DEBUG
#else
                if (is_ignore2)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.itemName = "点击打开淘宝APP";
                    result.reason = reason;
                    _ = TkLogCore.ParseLogAsync(result);
                    return TaobaoParseOutput(result, swData, new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.itemName,
                        result.deeplink_url,
                    });
                }
#endif

                stopwatch.Reset();
                stopwatch.Start();
                TkPoolDTO? account = accountid > 0 ?
                    TkPoolCore.GetOne(accountid) :
                    TkPoolCore.GetOne(TkPoolCore.TkAction.parse);

                stopwatch.Stop();
                swData.Add("GetOne", stopwatch.ElapsedMilliseconds);

                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    result.itemName = "点击打开淘宝APP";
                    _ = TkLogCore.ParseLogAsync(result);
                    return TaobaoParseOutput(result, swData, new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.couponAmount,
                        result.taoToken,
                        result.shortLinkurl,
                        result.deeplink_url,
                    });
                }
                result.accountId = account.id;

                stopwatch.Reset();
                stopwatch.Start();
                alimama = new AlimamaPlus(account);
                result.accountName = account.company;

                stopwatch.Stop();
                swData.Add("AlimamaPlus", stopwatch.ElapsedMilliseconds);

                int timeout = alimama._config.rt_max;
                using var cts = new CancellationTokenSource();
                cts.CancelAfter(timeout);

                stopwatch.Reset();
                stopwatch.Start();

                var requestTask = Task.Run(() => alimama.UnionParse2Async(content, result, cts.Token, swData), cts.Token);
                var delayTask = Task.Delay(timeout, cts.Token);
                var completedTask = await Task.WhenAny(requestTask, delayTask);
                if (completedTask == requestTask)
                {
                    result = await requestTask;
                }
                else
                {
                    cts.Cancel();
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                    result.itemName = "点击打开淘宝APP";
                }

                stopwatch.Stop();
                swData.Add("UnionParse2Async", stopwatch.ElapsedMilliseconds);
                result.accountName = account.company;
                //result = await alimama.UnionParse2Async(content, result);
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                    result.itemName = "点击打开淘宝APP";
                }
                else
                {
                    _ = new LoggerLibrary("unionParse", "tb_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();

                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常TB】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "转链接口异常";
                    result.itemName = "点击打开淘宝APP";
                }
            }
            _ = TkLogCore.ParseLogAsync(result, alimama);

            return TaobaoParseOutput(result, swData, new
            {
                result.success,
                result.message,
                link_type = result.link_type.ToString(),
                channel = result?.channel.ToString(),
                result.channel_type,
                result.itemId,
                result.itemName,
                result.pic,
                result.promotionPrice,
                result.couponAmount,
                result.couponEffectiveStartTime,
                result?.couponEffectiveEndTime,
                result.shortLinkurl,
                result.deeplink_url,
                result.content,
                result.taoToken,
            });
        }

        public static async Task<APIResult> TaobaoParseAsync222(string content,
            string ip = "", string oaid = "")
        {
            AlimamaPlus alimama = null;
            content = content.UrlDecode();
            content = content[..Math.Min(1000, content.Length)];
            var result = AlimamaPlus.GetFormattedObject(content, ip, oaid);

            LoggerLibrary log = new("debug", "stopwatch");
            log.Info($"StartNew", content);
            Stopwatch stopwatch = Stopwatch.StartNew();

            result.rawContent = content;
            try
            {
                bool is_other = await AlimamaPlus.OtherPlatformAsync(content);
                stopwatch.Stop();
                log.Info($"AlimamaPlus.OtherPlatform\t{stopwatch.ElapsedMilliseconds}");

                if (is_other)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "平台错误";

                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(new
                    {
                        channel = result?.channel.ToString(),
                        result.success,
                        result.message,
                        result.shortLinkurl,
                        result.deeplink_url,
                    }, APIResultCodeEnum.NotAcceptable);
                }
                string reason = string.Empty;
                if (string.IsNullOrEmpty(result.shortLinkurl) && AlimamaPlus.FirstFilterIgnoreRequest(content, out reason))
                {
                    //没有短链接都放弃
                    result.success = false;
                    result.message = "放弃转链";
                    result.itemName = "点击打开淘宝APP";
                    result.reason = "初步筛选";
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.itemName,
                        result.deeplink_url,
                    });
                }

                if (AlimamaPlus.ShouldIgnoreRequest(ip, oaid, out reason))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.itemName = "点击打开淘宝APP";
                    result.reason = reason;
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.itemName,
                        result.deeplink_url,
                    });
                }
                var account = TkPoolCore.GetOne(TkPoolCore.TkAction.parse);
                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    result.itemName = "点击打开淘宝APP";
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(new
                    {
                        result.success,
                        result.message,
                        result.content,
                        result.couponAmount,
                        result.taoToken,
                        result.shortLinkurl,
                        result.deeplink_url,
                    });
                }
                result.accountId = account.id;
                alimama = new AlimamaPlus(account);
                int timeout = alimama._config.rt_max;

                using var cts = new CancellationTokenSource();
                cts.CancelAfter(timeout);
                var requestTask = Task.Run(() => alimama.UnionParse2Async(content, result, cts.Token), cts.Token);
                var delayTask = Task.Delay(timeout, cts.Token);
                var completedTask = await Task.WhenAny(requestTask, delayTask);
                if (completedTask == requestTask)
                {
                    result = await requestTask;
                }
                else
                {
                    cts.Cancel();
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                    result.itemName = "点击打开淘宝APP";
                }
                //result = await alimama.UnionParse2Async(content, result);
                result.accountName = account.company;
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                    result.itemName = "点击打开淘宝APP";
                }
                else
                {
                    _ = new LoggerLibrary("unionParse", "tb_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();

                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常TB】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "转链接口异常";
                    result.itemName = "点击打开淘宝APP";
                }
            }
            _ = TkLogCore.ParseLogAsync(result, alimama);

            return new APIResult(new
            {
                result.success,
                result.message,
                link_type = result.link_type.ToString(),
                channel = result?.channel.ToString(),
                result.channel_type,
                result.itemId,
                result.itemName,
                result.pic,
                result.promotionPrice,
                result.couponAmount,
                result.couponEffectiveStartTime,
                result?.couponEffectiveEndTime,
                result.shortLinkurl,
                result.deeplink_url,
                result.content,
                result.taoToken,
            });
        }

        //public static TkDataDTO testTaobaoParseAsync(string content, string ip = "", string oaid = "")
        //{
        //    var result = AlimamaPlus.GetFormattedObject(content, ip, oaid);
        //    content = content.UrlDecode();
        //    content = content[..Math.Min(1000, content.Length)];
        //    result.rawContent = content;
        //    try
        //    {
        //        if (AlimamaPlus.OtherPlatform(content))
        //        {
        //            result.success = false;
        //            result.message = "放弃转链";
        //            result.reason = "平台错误";
        //            return result;
        //        }
        //        string reason = string.Empty;
        //        if (string.IsNullOrEmpty(result.shortLinkurl) && AlimamaPlus.FirstFilterIgnoreRequest(content, out reason))
        //        {
        //            //没有短链接都放弃
        //            result.success = false;
        //            result.message = "放弃转链";
        //            result.itemName = "点击打开淘宝APP";
        //            result.reason = "初步筛选";
        //            return result;
        //        }

        //        if (AlimamaPlus.ShouldIgnoreRequest(ip, oaid, out reason))
        //        {
        //            result.success = false;
        //            result.message = "放弃转链";
        //            result.itemName = "点击打开淘宝APP";
        //            result.reason = reason;
        //            return result;
        //        }
        //        result.success = true;
        //        return result;
        //    }
        //    catch (Exception ex)
        //    {
        //        result.success = false;
        //        return result;
        //    }
        //}

        public static async Task<APIResult> JdParseAsync(string content, string ip, string oaid, CancellationToken cancellationToken = default)
        {
            var result = JdUnionPlus.GetFormattedObject(content, ip, oaid);
            content = content.UrlDecode();
            result.rawContent = content;
            bool IfExceptional = false;
            try
            {
                if (JdUnionPlus.ShouldIgnoreRequest(ip, oaid, out string reason))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = reason;
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(result);
                }

                var account = JdPoolCore.GetOne();
                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(result);
                }
                result = await JdUnionPlus.JdParseAsync(account, content, result, cancellationToken);
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                }
                else
                {
                    IfExceptional = true;
                    _ = new LoggerLibrary("unionParse", "jd_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常JD】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "内部错误";
                    result.reason = "转链接口异常";
                }
            }
            _ = TkLogCore.ParseLogAsync(result);
            return new APIResult(new
            {
                result.success,
                result.message,
                link_type = result.link_type.ToString(),
                channel = result?.channel.ToString(),
                result.channel_type,
                result.itemId,
                result.itemName,
                result.shortLinkurl,
                result.deeplink_url,
            }, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK);
        }

        public static async Task<APIResult> DyParseAsync(string content, string ip, string oaid, CancellationToken cancellationToken = default)
        {
            var result = DyUnionPlus.GetFormattedObject(content, ip, oaid);
            content = content.UrlDecode();
            result.rawContent = content;
            bool IfExceptional = false;
            try
            {
                // 2024-06-19 联盟业务下线
                result.success = false;
                result.message = "放弃转链";
                result.reason = "联盟下线";
                _ = TkLogCore.ParseLogAsync(result);
                return new APIResult(result);


                if (DyUnionPlus.ShouldIgnoreRequest(ip, oaid, out string reason))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = reason;
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(result);
                }

                var account = PangolinPoolCore.GetOne();
                if (account == null)
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "没有匹配账号";
                    _ = TkLogCore.ParseLogAsync(result);
                    return new APIResult(result);
                }
                result = await DyUnionPlus.DyParseAsync(account, content, result, cancellationToken);
            }
            catch (Exception ex)
            {
                if (ex.Message.Contains("was canceled"))
                {
                    result.success = false;
                    result.message = "放弃转链";
                    result.reason = "请求超时";
                }
                else
                {
                    IfExceptional = true;
                    _ = new LoggerLibrary("unionParse", "dy_error")
                        .Info(ip, oaid)
                        .Info(content)
                        .Info(ex.Message, ex.StackTrace)
                        .SaveAsync();
                    NotifyCore.Notify(new NifyMessage
                    {
                        message = $"【转链异常DY】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
                        priority = NifyMessagePriority.high,
                        tags = ["red_circle"]
                    });
                    result.success = false;
                    result.message = "内部错误";
                    result.reason = "转链接口异常";
                }
            }
            _ = TkLogCore.ParseLogAsync(result);
            return new APIResult(new
            {
                result.success,
                result.message,
                link_type = result.link_type.ToString(),
                channel = result?.channel.ToString(),
                content = result?.rawContent.ToString(),
                taoToken = result?.taoToken.ToString(),
                result.channel_type,
                result.itemName,
                result.shortLinkurl,
                result.deeplink_url,
            }, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK);
        }

    }

}