dotnet/molilian.core/Plus/JDUnion/JdUnionPlus.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 Dataoke;
using System.Text.RegularExpressions;
using Org.BouncyCastle.Ocsp;
using System.Diagnostics;
using TencentCloud.Fmu.V20191213.Models;
using Microsoft.VisualBasic;
using System.Text.Json;
using static System.Runtime.InteropServices.JavaScript.JSType;
using System.Security.Cryptography;
using Google.Protobuf.WellKnownTypes;
using Microsoft.Extensions.FileSystemGlobbing.Internal;


namespace molilian.core
{
    public partial class JdUnionPlus
    {
        public static string GetLink(string content)
        {
            if (string.IsNullOrEmpty(content)) return content;
            string result = content;
            //string pattern = @"https?:\/\/?([\da-z\.-]+)\.([a-z]{2,6})(:\d{1,5})?([\/\w\.-]*)*\/?(#[\S]+)?(\?[\S]+)?";
            Regex regex = new(AlimamaPlus._url_pattern);
            MatchCollection matches = regex.Matches(content);

            foreach (Match m in matches.Cast<Match>())
            {
                string url = m.Value;
                return url;
            }
            return string.Empty;
        }

        public static string GetItemId(string url)
        {
            if (string.IsNullOrEmpty(url)) return string.Empty;

            // 定义正则表达式模式，使用捕获组提取数字ID
            string pattern = @"https?://item(?:\.m)?\.jd\.com/(?:product/)?(\d+)\.html(?:\?.*)?";

            // 使用正则表达式进行匹配
            Match match = Regex.Match(url, pattern);

            if (match.Success)
            {
                string idNumber = match.Groups[1].Value;  // 捕获组1包含数字ID
                return idNumber;
            }
            return string.Empty;
        }

        public static string GetDeeplink(string url)
        {
            if (string.IsNullOrEmpty(url)) return "openapp.jdmobile://virtual?params=";
            string virtual_params = $"{{\"category\":\"jump\",\"des\":\"m\",\"sourceValue\":\"babel-act\",\"sourceType\":\"babel\",\"url\":\"{url}\",\"M_sourceFrom\":\"h5auto\",\"msf_type\":\"auto\"}}";
            string result = $"openapp.jdmobile://virtual?params={virtual_params.UrlEncode()}";
            return result;
        }

        public static JdDataDTO GetFormattedObject(string content, string ip = "", string oaid = "")
        {
            string shortLinkurl = GetLink(content);
            string deeplink_url = GetDeeplink(shortLinkurl);
            return new JdDataDTO()
            {
                message = string.Empty,
                link_type = LinkTypeEnum.unknown,
                channel = TkChannelEnum.jd,
                accountName = string.Empty,
                success = false,
                content = content,
                ip = ip,
                oaid = oaid,
                elapsedTime = 0,
                itemName = "点击打开京东APP",
                shortLinkurl = shortLinkurl,
                deeplink_url = deeplink_url,
                create_time = DateTime.Now,
                end_point = _end_point,
            };
        }

        public static bool IsAffLlink(string url)
        {
            Uri uri = new(url);
            if (uri.Host.Equals("u.jd.com", StringComparison.OrdinalIgnoreCase))
            {
                return true;
            }
            return false;
        }
        public static string? GetDesiredUrl(string url)
        {
            try
            {
                WebClientUtility client = new()
                {
                    AllowAutoRedirect = false
                };
                var response = client.Request(url);
                if (!response.Successed) return null;

                var target_url = response.ResponseMessage?.Headers?.Location?.ToString();

                if (!url.StartsWith("https://3.cn")) return null;
                return target_url;
            }
            catch (Exception ex)
            {
            }
            return null;
        }

        public static LinkTypeEnum GetLinkType(string url, out string desiredUrl, out string itemId)
        {
            desiredUrl = url;
            itemId = string.Empty;

            if (string.IsNullOrEmpty(url)) return LinkTypeEnum.unknown;
            if (url.StartsWith("https://u.jd.com") ||
                url.StartsWith("http://u.jd.com"))
                return LinkTypeEnum.other_aff;

            if (url.StartsWith("https://lives.jd.com/") ||
                url.StartsWith("http://lives.jd.com/"))
                return LinkTypeEnum.live;

            if (url.StartsWith("https://h5.m.jd.com/active/faxian/video/index.html") ||
                url.StartsWith("http://h5.m.jd.com/active/faxian/video/index.html"))
                return LinkTypeEnum.video;

            if (url.StartsWith("https://eco.m.jd.com/content/dr_home/index.html") ||
                url.StartsWith("http://eco.m.jd.com/content/dr_home/index.html")) return LinkTypeEnum.profile;

            if (url.StartsWith("https://3.cn") ||
                url.StartsWith("http://3.cn"))
            {
                var target_url = GetDesiredUrl(url);
                return GetLinkType(target_url, out desiredUrl, out itemId);
            }
            if (url.Contains("jd.com"))
            {
                itemId = GetItemId(url);
                if (!string.IsNullOrEmpty(itemId)) return LinkTypeEnum.goods;
                return LinkTypeEnum.baseDomain;
            }
            return LinkTypeEnum.unknown;
        }

        static bool ContainsSpecialFormat(string content)
        {
            // 使用正则表达式匹配内容中是否含有特定格式的字符串
            string pattern = @"[！$￥%]+[a-zA-Z0-9]+[！$￥%]]*";
            return Regex.IsMatch(content, pattern);
        }

        //public static JdDataDTO JdParse(JdPoolDTO account, string content, ref JdDataDTO result)
        //{
        //    string message = "OK";
        //    string url = GetLink(content);

        //    var plus = new JdUnionPlus(account.app_key, account.app_secret);

        //    if (ContainsSpecialFormat(content))
        //    {
        //        result.link_type = LinkTypeEnum.other_aff;
        //        result.success = false;
        //        result.link_type = LinkTypeEnum.unknown;
        //        result.channel_type = ChannelTypeEnum.jd;
        //        result.message = "其他推广链接";
        //        result.accountName = string.Empty;
        //        result.content = content;
        //        result.shortLinkurl = url;
        //        result.deeplink_url = GetDeeplink(null);
        //        return result;
        //    }

        //    //result.link_type = plus.IsAffLlink(url) ? LinkTypeEnum.other_aff : LinkTypeEnum.goods;
        //    if (!string.IsNullOrEmpty(url))
        //    {
        //        (result.link_type, result.content) = GetLinkType(url);
        //        if (result.link_type == LinkTypeEnum.other_aff)
        //        {
        //            result.success = false;
        //            result.link_type = LinkTypeEnum.unknown;
        //            result.channel_type = ChannelTypeEnum.jd;
        //            result.message = "其他推广链接";
        //            result.accountName = string.Empty;
        //            result.content = content;
        //            result.shortLinkurl = url;
        //            result.deeplink_url = GetDeeplink(null);
        //            return result;
        //        }
        //    }
        //    string shortLinkurl = plus.promotion_get(account.site_id, string.IsNullOrEmpty(url) ? content : url);
        //    var success = !string.IsNullOrEmpty(shortLinkurl);
        //    if (!success) message = "转链失败";

        //    result.content = shortLinkurl;
        //    result.shortLinkurl = shortLinkurl;
        //    result.success = success;
        //    result.message = message;
        //    result.deeplink_url = GetDeeplink(url);
        //    return result;
        //}

        public async Task<JdDataDTO> JdParseAsync(string content, JdDataDTO result, CancellationToken cancellationToken = default)
        {
            string message = "OK";
            string url = GetLink(content);
            if (string.IsNullOrEmpty(url))
            {
                result.success = false;
                result.link_type = LinkTypeEnum.unknown;
                result.channel_type = ChannelTypeEnum.jd;
                result.message = "放弃转链";
                result.reason = "纯口令";
                result.accountId = 0;
                result.accountName = string.Empty;
                result.content = content;
                result.shortLinkurl = url;
                result.deeplink_url = GetDeeplink(url);
                return result;
            }
            string shortLinkurl = url;

            //result.link_type = plus.IsAffLlink(url) ? LinkTypeEnum.other_aff : LinkTypeEnum.goods;
            result.link_type = GetLinkType(url, out string out_url, out string itemId);
            url = out_url;
            result.itemId = itemId;

            if (result.link_type == LinkTypeEnum.other_aff)
            {
                result.success = false;
                result.link_type = LinkTypeEnum.unknown;
                result.channel_type = ChannelTypeEnum.jd;
                result.message = "放弃转链";
                result.reason = "其他推广链接";
                result.accountId = 0;
                result.accountName = string.Empty;
                result.content = content;
                result.shortLinkurl = url;
                result.deeplink_url = GetDeeplink(url);
                return result;
            }

            if (string.IsNullOrEmpty(url) || string.IsNullOrEmpty(result.itemId) ||
                (!url.StartsWith("https://item.jd.com/") &&
                !url.StartsWith("https://item.m.jd.com/product/") &&
                !url.StartsWith("http://item.m.jd.com/product/") &&
                !url.StartsWith("http://item.m.jd.com/product/")))
            {
                result.success = false;
                result.link_type = LinkTypeEnum.unknown;
                result.channel_type = ChannelTypeEnum.jd;
                result.message = "放弃转链";
                result.reason = "非标链接";
                result.accountId = 0;
                result.accountName = string.Empty;
                result.content = content;
                result.shortLinkurl = url;
                result.deeplink_url = GetDeeplink(url);
                return result;
            }

            if (!result.ip.StartsWith("127.0.0") && FlowControlIgnoreRequest(_config, out string reason))
            {
                result.success = false;
                result.link_type = LinkTypeEnum.unknown;
                result.channel_type = ChannelTypeEnum.jd;
                result.message = "放弃转链";
                result.reason = reason;
                result.accountId = 0;
                result.accountName = string.Empty;
                result.content = content;
                result.shortLinkurl = url;
                result.deeplink_url = GetDeeplink(url);
                return result;
            }

            switch (_account.work_mode)
            {
                case JdUnionWorkMode.SiteApi:
                    result = await GetPromotionBySiteAsync(result, url, cancellationToken);
                    break;
                case JdUnionWorkMode.AffApi:
                    result = await GetPromotionByAffAsync(result, url, cancellationToken);
                    break;
                case JdUnionWorkMode.Crawler:
                default:
                    result = await GetPromotionByCrawlerAsync(result, url, cancellationToken);
                    break;
            }
            return result;
        }
    }
}