parse.cs 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676
  1. using System.Text;
  2. using dodohold.core;
  3. using System.Text.RegularExpressions;
  4. using System.Net;
  5. using System.Linq;
  6. using System.Security.Cryptography;
  7. using TencentCloud.Ecm.V20190719.Models;
  8. using System.Diagnostics;
  9. using static dodohold.core.ZTOExpress.CreateOrderArgs;
  10. using System.Text.Json;
  11. using TencentCloud.Tcm.V20210413.Models;
  12. using TencentCloud.Tione.V20211111.Models;
  13. using System.Runtime.InteropServices.Marshalling;
  14. namespace molilian.core
  15. {
  16. public partial class AlimamaPlus
  17. {
  18. private string _accountName;
  19. private int _accountId;
  20. private string _company;
  21. private string _tb_token;
  22. private string _floorId;
  23. private string _refpid;
  24. private string _user_agent;
  25. private string _cookies;
  26. private WebProxy? _proxy = null;
  27. private string _api;
  28. private int _api_id = 0;
  29. public TkConfigDTO _config;
  30. private static string _end_point;
  31. private TkPoolDTO _account;
  32. static Random _random = new Random();
  33. public static string _url_pattern = @"https?://[-A-Za-z0-9+&@#/%?=~_|!:,.;]+[-A-Za-z0-9+&@#/%=~_|]";
  34. static AlimamaPlus()
  35. {
  36. _end_point = Environment.GetEnvironmentVariable("EndPoint");
  37. }
  38. public AlimamaPlus(TkPoolDTO account)
  39. {
  40. // string accountName, string tb_token, string floorId, string refpid,
  41. // string cookies, string user_agent, string nodeName
  42. _config = TkConfigCore.Get();
  43. _account = account;
  44. _accountId = account.id;
  45. _accountName = account.name;
  46. _company = account.company;
  47. _tb_token = account.tb_token;
  48. _floorId = account.floorId;
  49. _refpid = account.refpid;
  50. _cookies = account.cookies;
  51. _user_agent = account.user_agent?.Trim();
  52. if (!string.IsNullOrEmpty(account.nodeName))
  53. {
  54. _proxy = ProxyNodesCore.GetOne(account.nodeName);
  55. }
  56. _api = account.api;
  57. _api_id = account.api_id;
  58. }
  59. public bool ShouldIgnoreOtherAff(string content)
  60. {
  61. TkDataDTO result = new();
  62. //(_, _, var link_type, _) = InternalTextProcessing(content, ref result);
  63. InternalTextProcessing(content, ref result);
  64. return result.link_type == LinkTypeEnum.other_aff;
  65. }
  66. public async Task<TkDataDTO> UnionParseAsync(string ip, string oaid, string content, int commerceType, TkDataDTO result,
  67. bool isTaobaoUrl, string riskStrategy, int launchScene,
  68. CancellationToken cancellationToken = default,
  69. Dictionary<string, long> swData = null)
  70. {
  71. result.itemName = "点击打开淘宝APP";
  72. result = await InternalTextProcessingAsync(content, result, cancellationToken, swData);
  73. if (result.link_type == LinkTypeEnum.other_aff)
  74. {
  75. //============================== 其他推广链接 ==============================
  76. result.channel = TkChannelEnum.tb;
  77. result.channel_type = ChannelTypeEnum.tb;
  78. result.link_type = LinkTypeEnum.other_aff;
  79. result.success = false;
  80. result.message = "放弃转链";
  81. result.reason = "其他推广链接";
  82. result.subCode = TkSubCodeEnum.OtherPromo;
  83. result.accountName = string.Empty;
  84. result.content = content;
  85. //result.deeplink_url = GetDeeplink(null);
  86. //result.itemName = GetTitle(content);
  87. //if (!content.Contains("助我领红包") && !content.Contains("双11超级红包主会场"))
  88. //{
  89. // //20241108 特例
  90. // string ruleKey = $"tmp_rules:{DateTime.Now:yyyyMMdd}_2";
  91. // var count = RedisHelper.IncrBy(ruleKey);
  92. // if (DateTime.Now < DateTime.Parse("2024-11-11") && count < 1000)
  93. // {
  94. // string hb_url = "https://s.click.taobao.com/t?union_lens=lensId%3APUB%401730991020%400bbb0a39_0e75_193071ad936_c566%4001%40eyJmbG9vcklkIjozODg1Miiwiic3BtQiiI6Il9wb3J0YWxfdjJfcGFnZXNfYWN0aXZpdHlfb2ZmaWNpYWxfaW5kZXhfaHRtIn0ie%3BeventPageId%3A20150318020007201&e=m%3D2%26s%3DipuVKjYImbNw4vFB6t2Z2iperVdZeJviU%2F9%2F0taeK29yINtkUhsv0KWvzu%2FHMi3%2BFPhC4MirEWStw6LBB4w3HYXT%2BqQ2P5OIQVNSryTmvs7YddWYbxmvGTMNfihJN%2FGnAGIx0oe2X2hZfJ7ZQxC1%2FU3rpAhWgptfEBnEBk3xaGylLmcSHKfaX1CIFRJhZoJ2keMqUwSQcLRC0TzsMy8kp7Hfv3%2BBYcPW3eHn14rW1PB5SunYCHQHRbw6LwQYf%2F1JuyhJem%2BM5OoR2cbDLktPLiIOenYkFIXa2HzNl%2Bm1VXoil%2F2L3b1aA6a%2FoVHlY%2BqZ2kyLuBX5NHCAQVYCmAmuozC39JfnbJNrE%2FSR3F9BSjOYe76q6w0hyfybhwAASyyp5XMWEyz25ulHMwkL2n%2F7nNBiFmadXyjFDPu12TgSnbZtfjDbrVTLHb6MowVEq7z9LgOFRSuRLesvlLykGd2CaRk8ezhE61zXa8yR1eex6ip3KqbOh7CEmgCLaFxcnT%2BrGuviRFaBil8Mlu5kMKse3g%3D%3D";
  95. // result.deeplink_url = GetDeeplink(hb_url);
  96. // RedisHelper.Expire(ruleKey, 86400 * 10);
  97. // }
  98. //}
  99. return result;
  100. }
  101. //处理过后的正文 用于转链
  102. if (!result.success)
  103. {
  104. switch (result.link_type)
  105. {
  106. case LinkTypeEnum.profile:
  107. case LinkTypeEnum.live:
  108. case LinkTypeEnum.video:
  109. case LinkTypeEnum.note:
  110. case LinkTypeEnum.goods:
  111. case LinkTypeEnum.baseDomain:
  112. result.reason = string.Empty;
  113. break;
  114. default:
  115. result.reason = "非标准链接";
  116. result.subCode = TkSubCodeEnum.NonStdLink;
  117. return result;
  118. }
  119. }
  120. //============================== 放弃转链-地区过滤 ==============================
  121. bool is_ignore2 = FlowControlIgnoreRequest(ip, oaid, riskStrategy, launchScene, out string reason);
  122. if (is_ignore2)
  123. {
  124. result.success = false;
  125. result.message = "放弃转链";
  126. result.reason = reason;
  127. result.subCode = TkSubCodeEnum.TrafficCtrl;
  128. return result;
  129. }
  130. switch (commerceType)
  131. {
  132. case 1:
  133. case 2:
  134. result.success = false;
  135. result.message = "放弃转链";
  136. result.reason = $"厂商放弃{commerceType}";
  137. result.subCode = TkSubCodeEnum.PartnersDrop;
  138. return result;
  139. }
  140. //2025-02-06 增加重试机制
  141. int try_count = 0;
  142. #if DEBUG
  143. _config.tk_parse_retry_count = 3;
  144. #endif
  145. while (try_count == 0 || try_count <= _config.tk_parse_retry_count)
  146. {
  147. if (try_count >= 3) break;
  148. (int ep_id, string tkEndpoint) = await TkEndpointManager.GetConvertApiAsync(_accountId, isTaobaoUrl, _account.parseEndpoint);
  149. result.tkEndpoint = ep_id;
  150. switch (tkEndpoint)
  151. {
  152. case "moose_share":
  153. result = await endpoint_moose_share(result.content, result, cancellationToken);
  154. break;
  155. case "promo_goods":
  156. result = await endpoint_promo_goods(result.content, result, cancellationToken);
  157. break;
  158. case "tool_links":
  159. result = await endpoint_tool_links(result.content, result, cancellationToken);
  160. break;
  161. case "aliyun":
  162. result = await endpoint_aliyun(result.content, result, cancellationToken);
  163. break;
  164. case "veapi":
  165. case "ddx":
  166. case "other_api":
  167. if (!string.IsNullOrEmpty(_api) && _api_id > 0)
  168. {
  169. var account = OtherApiPoolCore.Get(_api_id);
  170. if (account != null)
  171. {
  172. var core = new OtherApiPlus(account.name, account.key, account.sessionKey, tkEndpoint, account.api_url);
  173. string refpid = string.IsNullOrEmpty(account.refpid) ? _refpid : account.refpid;
  174. result = await core.UnionParseAsync(result.content, refpid, result, cancellationToken);
  175. return result;
  176. }
  177. }
  178. else
  179. {
  180. result.link_type = LinkTypeEnum.unknown;
  181. result.subCode = TkSubCodeEnum.Other;
  182. result.success = false;
  183. result.message = "放弃转链";
  184. result.reason = "接口配置失败";
  185. return result;
  186. }
  187. break;
  188. //case "ALL":
  189. // //没有可以用的接口了
  190. // result.link_type = LinkTypeEnum.unknown;
  191. // result.subCode = TkSubCodeEnum.ParseDeny;
  192. // result.success = false;
  193. // result.message = "放弃转链";
  194. // result.reason = "接口风控ALL";
  195. // return result;
  196. default:
  197. result.link_type = LinkTypeEnum.unknown;
  198. result.subCode = TkSubCodeEnum.ParseDeny;
  199. result.success = false;
  200. result.message = "放弃转链";
  201. result.reason = $"接口风控{tkEndpoint}";
  202. break;
  203. }
  204. if (!"该链接不支持转化,请更换链接尝试".Equals(result.message)) break;
  205. try_count++;
  206. }
  207. result.retry_count = try_count;
  208. result.commercial = result.success;
  209. if (!result.success)
  210. {
  211. result.itemName = "点击打开淘宝APP";
  212. }
  213. if (string.IsNullOrEmpty(result.itemName) || result.link_type == LinkTypeEnum.profile)
  214. {
  215. result.itemName = "点击打开淘宝APP";
  216. }
  217. return result;
  218. }
  219. public static bool ContainsTaobaoId(string content, string rawContent)
  220. {
  221. var match = Regex.Match(content, @"(?<=[?&]id=)\d+(?=&|$)");
  222. if (!match.Success) return false;
  223. string id = match.Value;
  224. return Regex.IsMatch(rawContent, $@"(^|\D){id}($|\D)");
  225. }
  226. public static string ReplaceUrls(string content, string shortLink)
  227. {
  228. if (string.IsNullOrEmpty(content) || string.IsNullOrEmpty(shortLink)) return content;
  229. string result = content;
  230. Regex regex = new(_url_pattern);
  231. MatchCollection matches = regex.Matches(content);
  232. foreach (Match m in matches.Cast<Match>())
  233. {
  234. string url = m.Value;
  235. if (url.Contains("https://s.tb.cn/") ||
  236. url.Contains("http://s.tb.cn/") ||
  237. url.Contains("http://m.tb.cn/") ||
  238. url.Contains("http://m.tb.cn/") ||
  239. url.Contains("http://e.tb.cn/") ||
  240. url.Contains("https://e.tb.cn/"))
  241. {
  242. result = result.Replace(url, shortLink);
  243. }
  244. }
  245. return result;
  246. }
  247. public static string RemoveUrls(string content)
  248. {
  249. if (string.IsNullOrEmpty(content)) return content;
  250. string result = content;
  251. Regex regex = new(_url_pattern);
  252. MatchCollection matches = regex.Matches(content);
  253. foreach (Match m in matches.Cast<Match>())
  254. {
  255. string url = m.Value;
  256. result = result.Replace(url, string.Empty);
  257. }
  258. return result;
  259. }
  260. public static string GetLink(string content)
  261. {
  262. if (string.IsNullOrEmpty(content)) return content;
  263. //string pattern = @"https?:\/\/?([\da-z\.-]+)\.([a-z]{2,6})(:\d{1,5})?([\/\w\.-]*)*\/?(#[\S]+)?(\?[\S]+)?";
  264. Regex regex = new(_url_pattern);
  265. MatchCollection matches = regex.Matches(content);
  266. string result = string.Empty;
  267. if (matches.Count > 0)
  268. {
  269. result = Regex.Replace(matches[^1].Value, @"\++$", "");
  270. }
  271. result = result.Replace("&nbsp;", "");
  272. if (result.StartsWith("http://e.tb.cn/")) result = result.Replace("http://", "https://");
  273. return result;
  274. }
  275. public static string GetTaobaoLink(string content)
  276. {
  277. if (string.IsNullOrEmpty(content)) return content;
  278. string pattern = @"(https?://(?:[\w-]+\.)*(?:tb\.cn|taobao\.com|juhuasuan\.com|tmall\.com|tmall\.hk)(?:/[a-zA-Z0-9\-\._~:/?#[\]@!$&'()*+,;=%]*)?)";
  279. Regex regex = new(pattern, RegexOptions.IgnoreCase);
  280. MatchCollection matches = regex.Matches(content);
  281. if (matches.Count > 0)
  282. {
  283. string result = Regex.Replace(matches[^1].Value, @"\++$", "");
  284. return result;
  285. }
  286. return string.Empty;
  287. }
  288. public static string GetDeeplink(string url)
  289. {
  290. if (string.IsNullOrEmpty(url)) return "tbopen://m.taobao.com/tbopen/index.html";
  291. string result = $"tbopen://m.taobao.com/tbopen/index.html?action=ali.open.nav&module=h5&h5Url={url.UrlEncode()}";
  292. //string result = $"tbopen://m.taobao.com/tbopen/index.html?action=ali.open.nav&module=h5&bootImage=0&afcPromotionOpen=false&bc_fl_src=h5_huanduan&source=slk_dp&h5Url={url.UrlEncode()}";
  293. return result;
  294. }
  295. public static string GetTitle(string content)
  296. {
  297. if (string.IsNullOrEmpty(content)) return string.Empty;
  298. string url = GetLink(content);
  299. if (!string.IsNullOrEmpty(url)) content = content.Replace(url, string.Empty);
  300. content = content.Replace("点击链接直接打开 或者 淘宝搜索直接打开", string.Empty).Trim();
  301. string[] words = Regex.Split(content, @"\s+");
  302. string word = words[^1];
  303. word = word.TrimStart('「').TrimEnd('」');
  304. return word;
  305. }
  306. public static bool IgnoreRegionIncluded(string _ignoreRegions, string? ipInfo, out string regionInfo)
  307. {
  308. regionInfo = string.Empty;
  309. if (string.IsNullOrEmpty(_ignoreRegions) || string.IsNullOrEmpty(ipInfo)) return false;
  310. string[] parts = ipInfo.Split('|');
  311. string countryInfo = null;
  312. if (parts.Length >= 4)
  313. {
  314. countryInfo = parts[0];
  315. regionInfo = parts[3];
  316. }
  317. if (string.IsNullOrEmpty(regionInfo)) return false;
  318. if (string.IsNullOrEmpty(countryInfo)) return false;
  319. string[] ignoreRegions = _ignoreRegions.Split('|');
  320. if (ignoreRegions.Contains(regionInfo)) return true;
  321. if (ignoreRegions.Contains(countryInfo))
  322. {
  323. regionInfo = countryInfo;
  324. return true;
  325. }
  326. foreach (var region in ignoreRegions)
  327. {
  328. if ("海外".Equals(region) && !"中国".Equals(countryInfo) && !"0".Equals(countryInfo))
  329. {
  330. regionInfo = "海外";
  331. return true;
  332. }
  333. }
  334. return false;
  335. }
  336. public static async Task<bool> OtherPlatformAsync(string content)
  337. {
  338. try
  339. {
  340. //腾讯会议
  341. string wemeetId = await ToolParsePlus.GetWemeetIdAsync(content);
  342. if (!string.IsNullOrEmpty(wemeetId)) return true;
  343. //百度网盘
  344. string surl = string.Empty, pwd = string.Empty;
  345. _ = ToolParsePlus.GetPanLink(content, ref surl, ref pwd);
  346. if (!string.IsNullOrEmpty(surl)) return true;
  347. //JD
  348. string url = JdUnionPlus.GetLink(content);
  349. var urlType = JdUnionPlus.GetLinkType(url, out _, out _);
  350. if (urlType != LinkTypeEnum.unknown) return true;
  351. //DY
  352. url = DyUnionPlus.GetLink(content);
  353. urlType = DyUnionPlus.GetLinkType(content, url);
  354. if (urlType != LinkTypeEnum.unknown) return true;
  355. }
  356. catch { }
  357. return false;
  358. }
  359. public static bool MatchRegexes(string text, List<string> extended)
  360. {
  361. text = RemoveUrls(text);
  362. string special_symbols = $"\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲";
  363. string[] base_patterns =
  364. [
  365. $@"(.*?\d{{2}}\s[a-zA-Z]{{2}}\d{{4}}\s.*?[{special_symbols}]+[a-zA-Z0-9\s]+[{special_symbols}]).*",
  366. $@"[{special_symbols}]+\s*([a-zA-Z]{{1,2}}\d{{2,4}}\s[a-zA-Z0-9]{{11}}|[a-zA-Z0-9]{{11}}[a-zA-Z]{{1,2}}\d{{2,4}}\s|[a-zA-Z0-9]{{11}})\s*[{special_symbols}]+",
  367. @"🍑♭ɑ◑下单|Tao宝"
  368. ];
  369. List<string> mergedArray = extended.Union(base_patterns).ToList();
  370. /*
  371. (.*?\\d{2}\\s[a-zA-Z]{2}\\d{4}\\s.*?[\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲]+[a-zA-Z0-9\\s]+[\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲])).*\n[\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲]+\\s*([a-zA-Z]{1,2}\\d{2,4}\\s[a-zA-Z0-9]{11}|[a-zA-Z0-9]{11}[a-zA-Z]{1,2}\\d{2,4}\\s|[a-zA-Z0-9]{11})\\s*[\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲]+\n🍑♭ɑ◑下单|Tao宝
  372. 【3瓶】恩威万蓝莓叶黄素酯软糖儿童成人上班族如酸涩肿胀可服用,<z5TYWAblvTw >:// HU7709,打開/
  373. 置顶小助手,方便下次查询\r\n1★【劵】无\r\n2★【返.佣】 0.29圆 \r\n3★【付款.价】24.9 圆\r\n \r\n 1 ¢HZv5WAboi0D¢(/:/ HU8866\r\
  374. n长按覆制本内容,打开TaoBao/\r\n-\r\n返佣是指商家的推广佣.金\r\n通过我回复的口令下単收货后,我
  375. 会微信红.苞返给你!!\r\n\r\n有疑问可回复“人工”咨询客服*/
  376. //🍑🔗上 水和肌精华水& CZ0 VWdCWC2gj97&,
  377. //6฿04ZDWzrwxjN)/ CA97
  378. //1😘 腹制这条(CZ00 iHvtWzrXa7O(:/
  379. //¥EC8DG4Zj0dhd8DOw¥MF6563 oIo0WzOF1Cp##X-PyVpHiPlyj1OP##
  380. //6.6₵vU2jWzIW3Qx₲/ CZ5224
  381. //$F56nWzIDSFZ$
  382. //0復製这条口令( CZ00 D0M4WzI0jFJ¢,📱咑開[Tao宝]就可下单:/
  383. //8fuzhi本条消息:¤ CZ3458 JSR1WzrPCBU¤,打开🍑♭ɑ◑下单/
  384. //5€Lz6SWzrkLDw¥:// CZ13
  385. //3₲Igq3Wzkc5np₳:// CZ15
  386. //9.9🎈【康师傅易拉罐6罐】口伶:6₰TnxKWzr0wff₪:// CZ69
  387. //4₲99Y0WzJdK6S₳:// CZ46
  388. //4fuzhi本条消息:¤ CZ0002 WVCSWzrk6Ix¤,打开🍑♭ɑ◑下单/
  389. bool anyMatch = false;
  390. foreach (string pattern in mergedArray)
  391. {
  392. if (Regex.IsMatch(text, pattern, RegexOptions.IgnoreCase))
  393. {
  394. anyMatch = true;
  395. }
  396. }
  397. return anyMatch;
  398. }
  399. public static bool MatchOtherInfo(string text, List<string> extended)
  400. {
  401. string[] base_patterns =
  402. [
  403. "[ďȌƯƔɪƝɖƟɏƖԂȎȗϓɫɧơȲǏđǫƲƳɨǹƊȮǚƴɬɲƿȖȳɳɗʮϔӢǙɦɒɎƥʘưΊƞǪȈʠΌǓϒίȠƠƱƗǸþŌŬÿĩŅÞÓũŸÎŎûįŇĎÖÙŷÏňÜÝÍñĎÒüŶľńĎ0ųŷÏŇdǒǔyí℡抖yí℡ÞŐûŷÌñ]{6}",
  404. @"(?:.+)极速版(?:口令|搜索)",
  405. @"##[a-zA-Z0-9]+##\[抖音(?:极速版)?(?:口令|搜索)\]",
  406. @"岽|亰|菄|京东|婛",
  407. "打开【剪映】",
  408. "weishi://|baiduhaokan://",
  409. "复制打开「UC浏览器」|UC瀏覽器",
  410. "番茄免费小说",
  411. @"\?chanTag=[^&\s]*口令",
  412. @"(https?://pan\.baidu\.com/s/[A-Za-z0-9?\-_=]+)",
  413. @"https?:\/\/meeting\.tencent\.com[^\s]*",
  414. @"#腾讯会议:(\d{3}-\d{3}-\d{3})"
  415. ];
  416. List<string> mergedArray = extended.Union(base_patterns).ToList();
  417. bool anyMatch = false;
  418. foreach (string pattern in mergedArray)
  419. {
  420. if (Regex.IsMatch(text, pattern, RegexOptions.IgnoreCase))
  421. {
  422. anyMatch = true;
  423. }
  424. }
  425. return anyMatch;
  426. }
  427. public static bool MatchMultiToken(string text, List<string> extended)
  428. {
  429. text = RemoveUrls(text);
  430. string special_symbols = $"\\$\\(\\)\\/\\#\\&\\<\\>฿¢¥¥$🗝₰₵₲¤₪₴€₤£₳《¢💰🔑🎵✔💲🔐📲";
  431. string[] base_patterns =
  432. [
  433. @"[!$¥%]+([a-zA-Z0-9]{16})[!$¥%]+",
  434. @"\^v(\d+#[a-zA-Z0-9]+)(?:\?.*)?\^",
  435. "##([a-zA-Z0-9\\-]+)##",
  436. $@"(.*?\d{{2}}\s[a-zA-Z]{{2}}\d{{4}}\s.*?[{special_symbols}]+[a-zA-Z0-9\s]+[{special_symbols}]).*",
  437. $@"[{special_symbols}]+\s*([a-zA-Z]{{1,2}}\d{{2,4}}\s[a-zA-Z0-9]{{11}}|[a-zA-Z0-9]{{11}}[a-zA-Z]{{1,2}}\d{{2,4}}\s|[a-zA-Z0-9]{{11}})\s*[{special_symbols}]+",
  438. ];
  439. // PAGE6:/^v130091#P2J6EDxN8p8?chanTag=d9dc522bdea27437514052ea50f6a787^
  440. List<string> mergedArray = extended.Union(base_patterns).ToList();
  441. int matchCount = 0;
  442. foreach (string pattern in mergedArray)
  443. {
  444. Match match = Regex.Match(text, pattern, RegexOptions.IgnoreCase);
  445. if (match.Success)
  446. {
  447. matchCount++;
  448. text = text.Replace(match.Groups[^1].Value, ""); // 移除匹配的部分文本
  449. }
  450. }
  451. return matchCount >= 2;
  452. }
  453. public static bool FilterRiskLink(string ip, string oaid, string content, out string reason)
  454. {
  455. reason = string.Empty;
  456. string itemId = ExtractItemId(content);
  457. if (string.IsNullOrEmpty(itemId)) return false;
  458. string cacheKey = $":cache:parse:{ip}_{oaid}_{itemId}";
  459. int flag = RedisHelper.Get<int>(cacheKey);
  460. if (flag > 0)
  461. {
  462. reason = $"口令用户";
  463. return true;
  464. }
  465. return false;
  466. }
  467. public static bool ShouldIgnoreRequest(string ip, string oaid, string riskStrategy, int launchScene, out string reason)
  468. {
  469. reason = string.Empty;
  470. //2025-05-11 brw不做风控
  471. if ("brw".Equals(riskStrategy) && launchScene != 0) return false;
  472. try
  473. {
  474. // IP和流量控制
  475. var config = TkConfigCore.Get();
  476. string ignorePercentageCity = config.ignorePercentageCity;
  477. string? ipInfo = IP2RegionPlus.Search(ip);
  478. if (IgnoreRegionIncluded(ignorePercentageCity, ipInfo, out string regionInfo))
  479. {
  480. reason = $"地区控制:{regionInfo}";
  481. return true;
  482. }
  483. if (TkLogCore.InBlacklist(config.blacklist_oaid, oaid))
  484. {
  485. reason = "OAID黑名单";
  486. return true;
  487. }
  488. int limit_num = config.tk_limit_per_ip_24h;
  489. if (!TestParseCore.InWhitelist(ip, oaid) && limit_num > 0)
  490. {
  491. int num = TkLogCore.getClientRequestTotalByIp(TkChannelEnum.tb, ip);
  492. if (num >= limit_num)
  493. {
  494. reason = "IP控制";
  495. return true;
  496. }
  497. }
  498. limit_num = config.tk_limit_per_oaid_24h;
  499. if (!TestParseCore.InWhitelist(ip, oaid) && limit_num > 0)
  500. {
  501. int num = TkLogCore.getClientRequestTotalByOAID(TkChannelEnum.tb, oaid);
  502. if (num >= limit_num)
  503. {
  504. reason = "OAID控制";
  505. return true;
  506. }
  507. }
  508. }
  509. catch (Exception ex)
  510. {
  511. reason = "配置异常";
  512. }
  513. return false;
  514. }
  515. public static bool FlowControlIgnoreRequest(string ip, string oaid, string riskStrategy, int launchScene, out string reason)
  516. {
  517. reason = string.Empty;
  518. //2025-05-11 brw不做风控
  519. if ("brw".Equals(riskStrategy) && launchScene != 0) return false;
  520. if (!TestParseCore.InWhitelist(ip, oaid)) return false;
  521. try
  522. {
  523. // IP和流量控制
  524. var config = TkConfigCore.Get();
  525. int ignorePercentage = config.ignorePercentage;
  526. if (ignorePercentage == 0) return false;
  527. var randomValue = (decimal)_random.Next(0, 100);
  528. bool result = randomValue <= ignorePercentage; // 如果生成的随机数小于忽略百分比,则返回 true,表示需要忽略请求
  529. if (result)
  530. {
  531. reason = "流量控制";
  532. return true;
  533. }
  534. }
  535. catch (Exception ex)
  536. {
  537. reason = $"配置异常";
  538. }
  539. return false;
  540. }
  541. public static TkDataDTO GetFormattedObject(string content, string ip, string oaid)
  542. {
  543. string shortLinkurl = GetTaobaoLink(content);
  544. string deeplink_url = GetDeeplink(shortLinkurl);
  545. return new TkDataDTO()
  546. {
  547. message = string.Empty,
  548. subCode = TkSubCodeEnum.Other,
  549. channel = TkChannelEnum.tb,
  550. accountName = string.Empty,
  551. success = false,
  552. content = content,
  553. link_type = LinkTypeEnum.unknown,
  554. ip = ip,
  555. oaid = oaid,
  556. couponAmount = 0,
  557. taoToken = string.Empty,
  558. elapsedTime = 0,
  559. itemName = "点击打开淘宝APP",
  560. shortLinkurl = shortLinkurl,
  561. deeplink_url = deeplink_url,
  562. create_time = DateTime.Now,
  563. end_point = _end_point,
  564. };
  565. }
  566. public static string OppoDecode(string content)
  567. {
  568. try
  569. {
  570. string secretKey = "BwFeIvOEDZy9MFGi0JLZBO4yEhR44DGV";
  571. byte[] keyBytes = Encoding.UTF8.GetBytes(secretKey);
  572. if (!content.Contains("%IV%")) return content;
  573. string cipherText = content.GetContentPart("", "%IV%");
  574. string ivText = content.GetContentPart("%IV%", "");
  575. byte[] cipherBytes = Convert.FromBase64String(cipherText);
  576. byte[] ivBytes = Convert.FromBase64String(ivText);
  577. using RijndaelManaged aes = new();
  578. aes.Key = keyBytes;
  579. aes.IV = ivBytes;
  580. aes.Mode = CipherMode.CFB;
  581. aes.Padding = PaddingMode.PKCS7;
  582. ICryptoTransform decryptor = aes.CreateDecryptor(aes.Key, aes.IV);
  583. var outBytes = decryptor.TransformFinalBlock(cipherBytes, 0, cipherBytes.Length);
  584. content = outBytes.ConvertToString();
  585. }
  586. catch (Exception e) { }
  587. return content;
  588. }
  589. }
  590. }