JdUnionPlus.cs 9.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239
  1. using Microsoft.AspNetCore.Http;
  2. using Microsoft.AspNetCore.Mvc.Controllers;
  3. using Microsoft.AspNetCore.Mvc.Filters;
  4. using System;
  5. using System.Collections.Generic;
  6. using System.Linq;
  7. using System.Text;
  8. using dodohold.core;
  9. using Dataoke;
  10. using System.Text.RegularExpressions;
  11. using Org.BouncyCastle.Ocsp;
  12. using System.Diagnostics;
  13. using TencentCloud.Fmu.V20191213.Models;
  14. using Microsoft.VisualBasic;
  15. using System.Text.Json;
  16. using static System.Runtime.InteropServices.JavaScript.JSType;
  17. using System.Security.Cryptography;
  18. using Google.Protobuf.WellKnownTypes;
  19. using Microsoft.Extensions.FileSystemGlobbing.Internal;
  20. namespace molilian.core
  21. {
  22. public partial class JdUnionPlus
  23. {
  24. public static string GetLink(string content)
  25. {
  26. if (string.IsNullOrEmpty(content)) return content;
  27. string result = content;
  28. string pattern = @"https?:\/\/?([\da-z\.-]+)\.([a-z]{2,6})(:\d{1,5})?([\/\w\.-]*)*\/?(#[\S]+)?(\?[\S]+)?";
  29. Regex regex = new(pattern);
  30. MatchCollection matches = regex.Matches(content);
  31. foreach (Match m in matches.Cast<Match>())
  32. {
  33. string url = m.Value;
  34. return url;
  35. }
  36. return string.Empty;
  37. }
  38. public static string GetItemId(string url)
  39. {
  40. if (string.IsNullOrEmpty(url)) return string.Empty;
  41. // 定义正则表达式模式,使用捕获组提取数字ID
  42. string pattern = @"https://item(?:\.m)?\.jd\.com/(?:product/)?(\d+)\.html(?:\?.*)?";
  43. // 使用正则表达式进行匹配
  44. Match match = Regex.Match(url, pattern);
  45. if (match.Success)
  46. {
  47. string idNumber = match.Groups[1].Value; // 捕获组1包含数字ID
  48. return idNumber;
  49. }
  50. return string.Empty;
  51. }
  52. public static string GetDeeplink(string url)
  53. {
  54. if (string.IsNullOrEmpty(url)) return "openapp.jdmobile://virtual?params=";
  55. string virtual_params = $"{{\"category\":\"jump\",\"des\":\"m\",\"sourceValue\":\"babel-act\",\"sourceType\":\"babel\",\"url\":\"{url}\",\"M_sourceFrom\":\"h5auto\",\"msf_type\":\"auto\"}}";
  56. string result = $"openapp.jdmobile://virtual?params={virtual_params.UrlEncode()}";
  57. return result;
  58. }
  59. public static JdDataDTO GetFormattedObject(string content, string ip = "", string oaid = "")
  60. {
  61. string shortLinkurl = GetLink(content);
  62. string deeplink_url = GetDeeplink(shortLinkurl);
  63. return new JdDataDTO()
  64. {
  65. message = string.Empty,
  66. link_type = LinkTypeEnum.unknown,
  67. channel = TkChannelEnum.jd,
  68. accountName = string.Empty,
  69. success = false,
  70. content = content,
  71. ip = ip,
  72. oaid = oaid,
  73. elapsedTime = 0,
  74. shortLinkurl = shortLinkurl,
  75. deeplink_url = deeplink_url,
  76. create_time = DateTime.Now,
  77. };
  78. }
  79. public static bool IsAffLlink(string url)
  80. {
  81. Uri uri = new(url);
  82. if (uri.Host.Equals("u.jd.com", StringComparison.OrdinalIgnoreCase))
  83. {
  84. return true;
  85. }
  86. return false;
  87. }
  88. public static string? GetDesiredUrl(string url)
  89. {
  90. try
  91. {
  92. WebClientUtility client = new()
  93. {
  94. AllowAutoRedirect = false
  95. };
  96. var response = client.Request(url);
  97. if (!response.Successed) return null;
  98. var target_url = response.ResponseMessage?.Headers?.Location?.ToString();
  99. if (!url.StartsWith("https://3.cn")) return null;
  100. return target_url;
  101. }
  102. catch (Exception ex)
  103. {
  104. }
  105. return null;
  106. }
  107. public static LinkTypeEnum GetLinkType(string url, out string desiredUrl, out string itemId)
  108. {
  109. desiredUrl = url;
  110. itemId = string.Empty;
  111. if (string.IsNullOrEmpty(url)) return LinkTypeEnum.unknown;
  112. if (url.StartsWith("https://u.jd.com")) return LinkTypeEnum.other_aff;
  113. if (url.StartsWith("https://lives.jd.com/")) return LinkTypeEnum.live;
  114. if (url.StartsWith("https://h5.m.jd.com/active/faxian/video/index.html")) return LinkTypeEnum.video;
  115. if (url.StartsWith("https://eco.m.jd.com/content/dr_home/index.html")) return LinkTypeEnum.profile;
  116. if (url.StartsWith("https://3.cn"))
  117. {
  118. var target_url = GetDesiredUrl(url);
  119. return GetLinkType(target_url, out desiredUrl, out itemId);
  120. }
  121. if (url.Contains("jd.com"))
  122. {
  123. itemId = GetItemId(url);
  124. if (!string.IsNullOrEmpty(itemId)) return LinkTypeEnum.goods;
  125. return LinkTypeEnum.baseDomain;
  126. }
  127. return LinkTypeEnum.unknown;
  128. }
  129. static bool ContainsSpecialFormat(string content)
  130. {
  131. // 使用正则表达式匹配内容中是否含有特定格式的字符串
  132. string pattern = @"[!$¥%]+[a-zA-Z0-9]+[!$¥%]]*";
  133. return Regex.IsMatch(content, pattern);
  134. }
  135. //public static JdDataDTO JdParse(JdPoolDTO account, string content, ref JdDataDTO result)
  136. //{
  137. // string message = "OK";
  138. // string url = GetLink(content);
  139. // var plus = new JdUnionPlus(account.app_key, account.app_secret);
  140. // if (ContainsSpecialFormat(content))
  141. // {
  142. // result.link_type = LinkTypeEnum.other_aff;
  143. // result.success = false;
  144. // result.link_type = LinkTypeEnum.unknown;
  145. // result.channel_type = ChannelTypeEnum.jd;
  146. // result.message = "其他推广链接";
  147. // result.accountName = string.Empty;
  148. // result.content = content;
  149. // result.shortLinkurl = url;
  150. // result.deeplink_url = GetDeeplink(null);
  151. // return result;
  152. // }
  153. // //result.link_type = plus.IsAffLlink(url) ? LinkTypeEnum.other_aff : LinkTypeEnum.goods;
  154. // if (!string.IsNullOrEmpty(url))
  155. // {
  156. // (result.link_type, result.content) = GetLinkType(url);
  157. // if (result.link_type == LinkTypeEnum.other_aff)
  158. // {
  159. // result.success = false;
  160. // result.link_type = LinkTypeEnum.unknown;
  161. // result.channel_type = ChannelTypeEnum.jd;
  162. // result.message = "其他推广链接";
  163. // result.accountName = string.Empty;
  164. // result.content = content;
  165. // result.shortLinkurl = url;
  166. // result.deeplink_url = GetDeeplink(null);
  167. // return result;
  168. // }
  169. // }
  170. // string shortLinkurl = plus.promotion_get(account.site_id, string.IsNullOrEmpty(url) ? content : url);
  171. // var success = !string.IsNullOrEmpty(shortLinkurl);
  172. // if (!success) message = "转链失败";
  173. // result.content = shortLinkurl;
  174. // result.shortLinkurl = shortLinkurl;
  175. // result.success = success;
  176. // result.message = message;
  177. // result.deeplink_url = GetDeeplink(url);
  178. // return result;
  179. //}
  180. public static async Task<JdDataDTO> JdParseAsync(JdPoolDTO account, string content, JdDataDTO result)
  181. {
  182. string message = "OK";
  183. string url = GetLink(content);
  184. var plus = new JdUnionPlus(account.app_key, account.app_secret);
  185. //result.link_type = plus.IsAffLlink(url) ? LinkTypeEnum.other_aff : LinkTypeEnum.goods;
  186. result.link_type = GetLinkType(url, out string out_url, out string itemId);
  187. url = out_url;
  188. result.itemId = itemId;
  189. if (result.link_type == LinkTypeEnum.other_aff)
  190. {
  191. result.success = false;
  192. result.link_type = LinkTypeEnum.unknown;
  193. result.channel_type = ChannelTypeEnum.jd;
  194. result.message = "其他推广链接";
  195. result.accountName = string.Empty;
  196. result.content = content;
  197. result.shortLinkurl = url;
  198. result.deeplink_url = GetDeeplink(url);
  199. return result;
  200. }
  201. string shortLinkurl = await plus.GetPromotionAsync(account.site_id, url);
  202. var success = !string.IsNullOrEmpty(shortLinkurl);
  203. if (!success) message = "转链失败";
  204. result.content = shortLinkurl;
  205. result.shortLinkurl = shortLinkurl;
  206. result.success = success;
  207. result.message = message;
  208. result.deeplink_url = GetDeeplink(shortLinkurl);
  209. return result;
  210. }
  211. }
  212. }