dp2dp.cs 58 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189
  1. using dodohold.core;
  2. using Microsoft.AspNetCore.Mvc;
  3. using Microsoft.AspNetCore.SignalR.Protocol;
  4. using System.Diagnostics;
  5. using System.Text.RegularExpressions;
  6. namespace molilian.core
  7. {
  8. public class ParseDeeplinkResust
  9. {
  10. public bool success { get; set; } = false;
  11. public string reason { get; set; } = string.Empty;
  12. public string url { get; set; } = string.Empty;
  13. }
  14. public partial class UnionParseCore
  15. {
  16. public static async Task<APIResult> DeeplinkTaobaoParseAsync(UnionParseRequest request)
  17. {
  18. bool other_aff = false;
  19. AlimamaPlus alimama = null;
  20. TkDataDTO? hiddenAccountFailure = null;
  21. HiddenLimitTicket? hiddenLimitTicket = null;
  22. var result = AlimamaPlus.GetFormattedObject(request);
  23. result.riskStrategy = request.RiskStrategy;
  24. result.launchScene = request.LaunchScene;
  25. result.rawContent = request.Content;
  26. result.parse_type = "dp";
  27. Dictionary<string, long> swData = new();
  28. swData.Add("StartNew", 0);
  29. Stopwatch stopwatch = Stopwatch.StartNew();
  30. string content = request.Content;
  31. try
  32. {
  33. var parseResult = parseTaobaoDeeplinkInput(request.Content);
  34. var overrideContent = await OverrideRuleCore.ProcessAsync(request);
  35. if (overrideContent != null)
  36. {
  37. result.success = overrideContent.response_success;
  38. result.message = overrideContent.ResolveMessage(result.message);
  39. result.reason = overrideContent.ResolveReason(result.reason);
  40. result.deeplink_url = overrideContent.output_text;
  41. _ = TkLogCore.ParseLogAsync(result);
  42. return TaobaoParseOutput(result, swData, new
  43. {
  44. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  45. result.commercial,
  46. exposeTracks = TracksCore.BuildPath(TrackType.Expose, result),
  47. clickTracks = TracksCore.BuildPath(TrackType.Click, result),
  48. result.with_middle_page,
  49. result.message,
  50. sub_message = result.reason,
  51. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  52. result.content,
  53. result.itemName,
  54. other_aff,
  55. result.deeplink_url,
  56. });
  57. }
  58. if (!parseResult.success)
  59. {
  60. result.channel = TkChannelEnum.tb;
  61. result.channel_type = ChannelTypeEnum.tb;
  62. result.link_type = LinkTypeEnum.other_aff;
  63. result.success = false;
  64. result.message = "放弃转链";
  65. result.reason = parseResult.reason;
  66. result.subCode = TkSubCodeEnum.OtherPromo;
  67. result.accountName = string.Empty;
  68. result.content = content;
  69. result.deeplink_url = string.Empty;
  70. _ = TkLogCore.ParseLogAsync(result);
  71. return TaobaoParseOutput(result, swData, new
  72. {
  73. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  74. result.commercial,
  75. result.with_middle_page,
  76. result.message,
  77. sub_message = result.reason,
  78. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  79. result.content,
  80. result.itemName,
  81. other_aff = true,
  82. result.deeplink_url,
  83. });
  84. }
  85. if (!AlimamaPlus.IsShortLink(parseResult.url))
  86. {
  87. (bool isTaobaUrl, string shortLinkurl) = AlimamaPlus.IsTaobaoUrl(parseResult.url);
  88. if (!isTaobaUrl)
  89. {
  90. result.success = false;
  91. result.channel = TkChannelEnum.tb;
  92. result.link_type = LinkTypeEnum.unknown;
  93. result.success = false;
  94. result.message = "放弃转链";
  95. result.reason = "无效商品id";
  96. if (!result.success)
  97. {
  98. result.deeplink_url = string.Empty;
  99. }
  100. _ = TkLogCore.ParseLogAsync(result);
  101. return TaobaoParseOutput(result, swData, new
  102. {
  103. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  104. result.commercial,
  105. result.with_middle_page,
  106. result.message,
  107. sub_message = result.reason,
  108. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  109. result.content,
  110. result.itemName,
  111. other_aff,
  112. result.deeplink_url,
  113. });
  114. }
  115. result.shortLinkurl = shortLinkurl;
  116. result.content = shortLinkurl;
  117. content = shortLinkurl;
  118. }
  119. else
  120. {
  121. result.content = parseResult.url;
  122. result.shortLinkurl = parseResult.url;
  123. content = parseResult.url;
  124. }
  125. result.deeplink_url = string.Empty;
  126. string reason = string.Empty;
  127. var config = TkConfigCore.Get();
  128. var arr = config.tk_whitelist_regular.Split('\n')
  129. .Where(line => !string.IsNullOrWhiteSpace(line))
  130. .ToList();
  131. var arr2 = config.tk_blacklist_regular.Split('\n')
  132. .Where(line => !string.IsNullOrWhiteSpace(line))
  133. .ToList();
  134. var arr3 = config.multi_token_regular.Split('\n')
  135. .Where(line => !string.IsNullOrWhiteSpace(line))
  136. .ToList();
  137. bool is_tao_url = !string.IsNullOrEmpty(result.shortLinkurl);
  138. bool is_tao_token = AlimamaPlus.MatchRegexes(content, arr);
  139. bool is_other = AlimamaPlus.MatchOtherInfo(content, arr2);
  140. //============================== 放弃转链-初步筛选1 ==============================
  141. if (!is_tao_url && !is_tao_token || is_other)
  142. {
  143. //没有链接都放弃
  144. result.success = false;
  145. result.message = "放弃转链";
  146. result.reason = "初步筛选1";
  147. result.subCode = TkSubCodeEnum.Prelim1;
  148. result.itemName = "";
  149. result.deeplink_url = string.Empty;
  150. _ = TkLogCore.ParseLogAsync(result);
  151. return TaobaoParseOutput(result, swData, new
  152. {
  153. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  154. result.commercial,
  155. result.with_middle_page,
  156. result.message,
  157. sub_message = result.reason,
  158. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  159. result.content,
  160. result.itemName,
  161. other_aff,
  162. result.deeplink_url,
  163. });
  164. }
  165. bool is_multi_token = AlimamaPlus.MatchMultiToken(content, arr3);
  166. //============================== 放弃转链-初步筛选1.5 ==============================
  167. if (is_multi_token)
  168. {
  169. //没有链接都放弃
  170. result.success = false;
  171. result.message = "放弃转链";
  172. result.reason = "初步筛选1.5";
  173. result.subCode = TkSubCodeEnum.Prelim1_5;
  174. result.itemName = "";
  175. result.deeplink_url = string.Empty;
  176. _ = TkLogCore.ParseLogAsync(result);
  177. return TaobaoParseOutput(result, swData, new
  178. {
  179. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  180. result.commercial,
  181. result.with_middle_page,
  182. result.message,
  183. sub_message = result.reason,
  184. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  185. result.content,
  186. result.itemName,
  187. other_aff,
  188. result.deeplink_url,
  189. });
  190. }
  191. //============================== 放弃转链-初步筛选2 ==============================
  192. bool is_aff_link = false;
  193. if (!string.IsNullOrEmpty(result.shortLinkurl)) is_aff_link = AlimamaPlus.IsAffLink(result.shortLinkurl);
  194. if (!is_tao_url && is_tao_token)
  195. {
  196. //淘宝口令
  197. result.success = false;
  198. result.message = "放弃转链";
  199. result.reason = "初步筛选2";
  200. result.subCode = TkSubCodeEnum.Prelim2;
  201. result.itemName = "点击打开淘宝APP";
  202. if (!result.success)
  203. {
  204. result.deeplink_url = string.Empty;
  205. }
  206. _ = TkLogCore.ParseLogAsync(result);
  207. //20241229 特例
  208. //if ("bj".Equals(EndPointCore.CurrentEndPoint))
  209. //{
  210. // string ruleKey = $"tmp_rules2:tb:{DateTime.Now:yyyyMMdd}";
  211. // var count = RedisHelper.Get<int>(ruleKey);
  212. // var now = DateTime.Now;
  213. // if (now > new DateTime(2024, 12, 19) && now <= new DateTime(2024, 12, 22) && now.Hour >= 7 && count < 1000)
  214. // {
  215. // result.deeplink_url = "tbopen://m.taobao.com/tbopen/index.html?source=auto&action=ali.open.nav&module=h5&bootImage=0&afc_route=1&bc_fl_src=growth_dhh_2200803434968_100-1930985-1595034112&dpa_Inid=159503411212096&dpa_material_id=530637422585&dpa_material_type=1&dpa_source_code=12096&force_no_smb=true&h5Url=https%3A%2F%2Fs.m.taobao.com%2Fh5%3Ffrom%3Dcustoms%26g_channelSrp%3Ddhhdpa_1232552832%26dpa_material_type%3D1%26ut_sk%3Dsearch%26spm%3Da2141.mb819t211c7%26sLaunch%3D0%26sKeep%3D1%26sModuleName%3Dsearch%26spm_back_up%3Da2141.mb819t211c7%26bc_fl_src%3Dgrowth_dhh_2200803434968_100-1930985-1595034112%26dpa_Inid%3D159503411212096%26dpa_material_id%3D530637422585%26dpa_material_type%3D1%26dpa_source_code%3D12096%26force_no_smb%3Dtrue%26itemIds%3D530637422585%26slk_actid%3D100000000207%26spm%3D2014.ugdhh.2200803434968.100-1930985-1595034112%26wh_biz%3Dtm&itemIds=530637422585&slk_actid=100000000207&spm=2014.ugdhh.2200803434968.100-1930985-1595034112&wh_biz=tm";
  216. // RedisHelper.IncrBy(ruleKey);
  217. // RedisHelper.Expire(ruleKey, 86400 * 1);
  218. // }
  219. //}
  220. other_aff = true;
  221. return TaobaoParseOutput(result, swData, new
  222. {
  223. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  224. result.commercial,
  225. result.with_middle_page,
  226. result.message,
  227. sub_message = result.reason,
  228. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  229. result.content,
  230. result.itemName,
  231. other_aff,
  232. result.deeplink_url,
  233. });
  234. }
  235. if ((!is_tao_url && is_tao_token) || is_aff_link)
  236. {
  237. //没有短链接都放弃
  238. result.success = false;
  239. result.message = "放弃转链";
  240. result.reason = "初步筛选2";
  241. result.subCode = TkSubCodeEnum.Prelim2;
  242. result.itemName = "点击打开淘宝APP";
  243. if (!result.success)
  244. {
  245. result.deeplink_url = string.Empty;
  246. }
  247. _ = TkLogCore.ParseLogAsync(result);
  248. //20241229 特例
  249. //if ("bj".Equals(EndPointCore.CurrentEndPoint))
  250. //{
  251. // string ruleKey = $"tmp_rules2:tb:{DateTime.Now:yyyyMMdd}";
  252. // var count = RedisHelper.Get<int>(ruleKey);
  253. // var now = DateTime.Now;
  254. // if (now > new DateTime(2024, 12, 19) && now <= new DateTime(2024, 12, 22) && now.Hour >= 7 && count < 1000)
  255. // {
  256. // result.deeplink_url = "tbopen://m.taobao.com/tbopen/index.html?source=auto&action=ali.open.nav&module=h5&bootImage=0&afc_route=1&bc_fl_src=growth_dhh_2200803434968_100-1930985-1595034112&dpa_Inid=159503411212096&dpa_material_id=530637422585&dpa_material_type=1&dpa_source_code=12096&force_no_smb=true&h5Url=https%3A%2F%2Fs.m.taobao.com%2Fh5%3Ffrom%3Dcustoms%26g_channelSrp%3Ddhhdpa_1232552832%26dpa_material_type%3D1%26ut_sk%3Dsearch%26spm%3Da2141.mb819t211c7%26sLaunch%3D0%26sKeep%3D1%26sModuleName%3Dsearch%26spm_back_up%3Da2141.mb819t211c7%26bc_fl_src%3Dgrowth_dhh_2200803434968_100-1930985-1595034112%26dpa_Inid%3D159503411212096%26dpa_material_id%3D530637422585%26dpa_material_type%3D1%26dpa_source_code%3D12096%26force_no_smb%3Dtrue%26itemIds%3D530637422585%26slk_actid%3D100000000207%26spm%3D2014.ugdhh.2200803434968.100-1930985-1595034112%26wh_biz%3Dtm&itemIds=530637422585&slk_actid=100000000207&spm=2014.ugdhh.2200803434968.100-1930985-1595034112&wh_biz=tm";
  257. // RedisHelper.IncrBy(ruleKey);
  258. // RedisHelper.Expire(ruleKey, 86400 * 1);
  259. // }
  260. //}
  261. other_aff = true;
  262. return TaobaoParseOutput(result, swData, new
  263. {
  264. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  265. result.commercial,
  266. result.with_middle_page,
  267. result.message,
  268. sub_message = result.reason,
  269. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  270. result.content,
  271. result.itemName,
  272. other_aff,
  273. result.deeplink_url,
  274. });
  275. }
  276. //那就初步筛选3 有tb.cn 并且有 or 手淘发现
  277. string pattern = @"^(?!【淘宝】).*https?:\/\/m\.tb\.cn.*(?:手淘发现|手淘搜索)";
  278. bool isMatch = Regex.IsMatch(content, pattern);
  279. if (isMatch)
  280. {
  281. result.success = false;
  282. result.message = "放弃转链";
  283. result.reason = "初步筛选3";
  284. result.subCode = TkSubCodeEnum.Prelim3;
  285. result.itemName = "点击打开淘宝APP";
  286. if (!result.success)
  287. {
  288. result.deeplink_url = string.Empty;
  289. }
  290. _ = TkLogCore.ParseLogAsync(result);
  291. return TaobaoParseOutput(result, swData, new
  292. {
  293. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  294. result.commercial,
  295. result.with_middle_page,
  296. result.message,
  297. sub_message = result.reason,
  298. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  299. result.content,
  300. result.itemName,
  301. other_aff,
  302. result.deeplink_url,
  303. });
  304. }
  305. //============================== 放弃转链-地区过滤 ==============================
  306. bool is_ignore2 = AlimamaPlus.ShouldIgnoreRequest(request, out reason);
  307. if (is_ignore2)
  308. {
  309. result.success = false;
  310. result.message = "放弃转链";
  311. result.itemName = "点击打开淘宝APP";
  312. result.reason = reason;
  313. result.subCode = TkSubCodeEnum.TrafficCtrl;
  314. if (!result.success)
  315. {
  316. result.deeplink_url = string.Empty;
  317. }
  318. _ = TkLogCore.ParseLogAsync(result);
  319. return TaobaoParseOutput(result, swData, new
  320. {
  321. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  322. result.commercial,
  323. result.with_middle_page,
  324. result.message,
  325. sub_message = result.reason,
  326. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  327. result.content,
  328. result.itemName,
  329. other_aff,
  330. result.deeplink_url,
  331. });
  332. }
  333. (bool isTaobaoUrl, string url) = AlimamaPlus.IsTaobaoUrl(content);
  334. //============================== 放弃转链-没有匹配账号 ==============================
  335. long qpsAcquiredSinceTicks = DateTime.UtcNow.Ticks;
  336. TkPoolDTO? account = request.AccountId > 0 ?
  337. await TkPoolCore.GetOneAsync(request.AccountId) :
  338. await TkPoolCore.GetOneAsync(TkPoolCore.TkAction.parse, isTaobaoUrl, request.RiskStrategy, request.LaunchScene, "dp");
  339. if (account == null)
  340. {
  341. result.success = false;
  342. result.message = "放弃转链";
  343. result.reason = "没有匹配账号";
  344. result.subCode = TkSubCodeEnum.Other;
  345. result.itemName = "点击打开淘宝APP";
  346. if (!result.success)
  347. {
  348. result.deeplink_url = string.Empty;
  349. }
  350. _ = TkLogCore.ParseLogAsync(result);
  351. return TaobaoParseOutput(result, swData, new
  352. {
  353. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  354. result.commercial,
  355. result.with_middle_page,
  356. result.message,
  357. sub_message = result.reason,
  358. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  359. result.content,
  360. result.couponAmount,
  361. result.taoToken,
  362. result.shortLinkurl,
  363. other_aff,
  364. result.deeplink_url,
  365. });
  366. }
  367. result.accountId = account.id;
  368. result.accountName = account.company;
  369. if (account.is_hide) _ = TracksCore.RevertParseRequestAsync(request);
  370. result.hidden_account = account.is_hide;
  371. //============================== 放弃转链-隐藏号专用限制(城市、IP/OAID 每日次数,所有隐藏号共用) ==============================
  372. if (account.is_hide)
  373. {
  374. if (!HiddenAccountCore.TryReserveLimit(TkChannelEnum.tb, request.Ip, request.Oaid, out hiddenLimitTicket, out string hiddenLimitReason))
  375. {
  376. if (request.AccountId <= 0) TkPoolCore.ReleaseQps(account, qpsAcquiredSinceTicks);
  377. result.success = false;
  378. result.message = "放弃转链";
  379. result.reason = hiddenLimitReason;
  380. result.subCode = TkSubCodeEnum.TrafficCtrl;
  381. result.itemName = "点击打开淘宝APP";
  382. result.deeplink_url = string.Empty;
  383. _ = TkLogCore.ParseLogAsync(result);
  384. return TaobaoParseOutput(result, swData, new
  385. {
  386. success = ValidateDeeplinkIfRequired(result.success, result.deeplink_url),
  387. result.commercial,
  388. result.with_middle_page,
  389. result.message,
  390. sub_message = result.reason,
  391. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(result.deeplink_url),
  392. result.content,
  393. result.couponAmount,
  394. result.taoToken,
  395. result.shortLinkurl,
  396. other_aff,
  397. result.deeplink_url,
  398. });
  399. }
  400. }
  401. alimama = new AlimamaPlus(account);
  402. hiddenAccountFailure = account.is_hide ? CreateTaobaoFailureResult(result) : null;
  403. int timeout = alimama._config.rt_max;
  404. #if DEBUG
  405. timeout = 10000;
  406. #endif
  407. using var cts = new CancellationTokenSource();
  408. cts.CancelAfter(timeout);
  409. var requestTask = Task.Run(() => alimama.UnionParseAsync(request, content, result, isTaobaoUrl, cts.Token, swData), cts.Token);
  410. var delayTask = Task.Delay(timeout, cts.Token);
  411. var completedTask = await Task.WhenAny(requestTask, delayTask);
  412. if (completedTask == requestTask)
  413. {
  414. result = await requestTask;
  415. // 隐藏号的 QPS 只给真正提交到 endpoint 的请求使用,前置放弃的归还名额
  416. if (account.is_hide && request.AccountId <= 0 && !result.endpoint_called)
  417. {
  418. TkPoolCore.ReleaseQps(account, qpsAcquiredSinceTicks);
  419. }
  420. }
  421. else
  422. {
  423. //============================== 放弃转链-请求超时 ==============================
  424. cts.Cancel();
  425. result.success = false;
  426. result.message = "放弃转链";
  427. result.reason = "请求超时";
  428. result.subCode = TkSubCodeEnum.Other;
  429. result.itemName = "点击打开淘宝APP";
  430. }
  431. result.accountName = account.company;
  432. //result = await alimama.UnionParse2Async(content, result);
  433. }
  434. catch (Exception ex)
  435. {
  436. //============================== 放弃转链-请求超时 ==============================
  437. if (ex.Message.Contains("was canceled"))
  438. {
  439. result.success = false;
  440. result.message = "放弃转链";
  441. result.reason = "请求超时";
  442. result.subCode = TkSubCodeEnum.Other;
  443. result.itemName = "点击打开淘宝APP";
  444. }
  445. else
  446. {
  447. //============================== 转链接口异常 ==============================
  448. _ = new LoggerLibrary("unionParse", "tb_error")
  449. .Info(request.Ip, request.Oaid)
  450. .Info(content)
  451. .Info(ex.Message, ex.StackTrace)
  452. .SaveAsync();
  453. NotifyCore.Notify(new NifyMessage
  454. {
  455. message = $"【转链异常TB】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
  456. priority = NifyMessagePriority.high,
  457. tags = ["red_circle"]
  458. });
  459. result.success = false;
  460. result.subCode = TkSubCodeEnum.Other;
  461. result.message = "转链接口异常";
  462. result.itemName = "点击打开淘宝APP";
  463. }
  464. }
  465. // 隐藏号:转链成功计入当天 ip/oaid 次数,失败则归还占用的名额
  466. if (hiddenLimitTicket != null)
  467. {
  468. _ = HiddenAccountCore.CompleteLimitAsync(hiddenLimitTicket, result.success);
  469. }
  470. if (!result.success)
  471. {
  472. result.deeplink_url = string.Empty;
  473. }
  474. _ = TkLogCore.ParseLogAsync(result, alimama);
  475. switch (result.reason)
  476. {
  477. case "其他推广链接":
  478. //case "排除淘口令":
  479. case "纯口令 没链接":
  480. other_aff = true;
  481. break;
  482. }
  483. var output = ResolveTaobaoOutputResult(result, hiddenAccountFailure);
  484. // 隐藏号不输出埋点
  485. bool hiddenAccount = hiddenAccountFailure != null;
  486. return TaobaoParseOutput(result, swData, new
  487. {
  488. //result.success,
  489. success = ValidateDeeplinkIfRequired(output.success, output.deeplink_url),
  490. output.commercial,
  491. exposeTracks = hiddenAccount ? string.Empty : TracksCore.BuildPath(TrackType.Expose, output),
  492. clickTracks = hiddenAccount ? string.Empty : TracksCore.BuildPath(TrackType.Click, output),
  493. output.with_middle_page,
  494. output.message,
  495. sub_message = output.reason,
  496. home_page = "tbopen://m.taobao.com/tbopen/index.html".Equals(output.deeplink_url),
  497. link_type = output.link_type.ToString(),
  498. channel = output?.channel.ToString(),
  499. output.channel_type,
  500. output.itemId,
  501. output.itemName,
  502. output.pic,
  503. output.zkFinalPrice,
  504. price = output.reservePrice,
  505. output.promotionPrice,
  506. output.couponAmount,
  507. output.couponEffectiveStartTime,
  508. output?.couponEffectiveEndTime,
  509. output.shortLinkurl,
  510. output.deeplink_url,
  511. output.riskStrategy,
  512. output.launchScene,
  513. output.content,
  514. output.taoToken,
  515. other_aff,
  516. });
  517. }
  518. public static async Task<APIResult> DeeplinkJdParseAsync(UnionParseRequest request, CancellationToken cancellationToken = default)
  519. {
  520. var config = TkConfigCore.Get();
  521. var result = JdUnionPlus.GetFormattedObject(request);
  522. result.rawContent = request.Content;
  523. result.parse_type = "dp";
  524. result.riskStrategy = request.RiskStrategy;
  525. result.launchScene = request.LaunchScene;
  526. bool IfExceptional = false;
  527. try
  528. {
  529. var overrideContent = await OverrideRuleCore.ProcessAsync(request);
  530. if (overrideContent != null)
  531. {
  532. result.success = overrideContent.response_success;
  533. result.message = overrideContent.ResolveMessage("OK");
  534. result.reason = overrideContent.ResolveReason(result.reason);
  535. result.commercial = true;
  536. result.deeplink_url = overrideContent.output_text;
  537. _ = TkLogCore.ParseLogAsync(result, false);
  538. return JdParseOutput(result);
  539. }
  540. var parseResult = parseJdDeeplinkInput(request.Content);
  541. if (!parseResult.success)
  542. {
  543. result.channel = TkChannelEnum.jd;
  544. result.channel_type = ChannelTypeEnum.jd;
  545. result.link_type = LinkTypeEnum.other_aff;
  546. result.success = false;
  547. result.message = "放弃转链";
  548. result.reason = parseResult.reason;
  549. result.accountName = string.Empty;
  550. result.content = request.Content;
  551. result.deeplink_url = string.Empty;
  552. _ = TkLogCore.ParseLogAsync(result, false);
  553. return JdParseOutput(result);
  554. }
  555. result.shortLinkurl = parseResult.url;
  556. result.content = parseResult.url;
  557. result.deeplink_url = string.Empty;
  558. var content = parseResult.url;
  559. if (!string.IsNullOrEmpty(config.jd_blacklist_regular))
  560. {
  561. var blacklist = config.jd_blacklist_regular.Split('\n')
  562. .Where(line => !string.IsNullOrWhiteSpace(line))
  563. .ToList();
  564. bool anyMatch = false;
  565. foreach (string pattern in blacklist)
  566. {
  567. if (Regex.IsMatch(content, pattern, RegexOptions.IgnoreCase)) anyMatch = true;
  568. }
  569. if (anyMatch)
  570. {
  571. result.success = false;
  572. result.deeplink_url = string.Empty;
  573. result.message = "放弃转链";
  574. result.reason = "规则排除";
  575. _ = TkLogCore.ParseLogAsync(result, false);
  576. return JdParseOutput(result);
  577. }
  578. }
  579. string out_url = null;
  580. string itemId = null;
  581. //============================== 放弃转链-地区过滤 ==============================
  582. if (!TestParseCore.InWhitelist(result.ip, result.oaid) && request.AccountId == 0 && JdUnionPlus.ShouldIgnoreRequest(config, request, out string reason))
  583. {
  584. result.link_type = JdUnionPlus.GetLinkType(result.shortLinkurl, out out_url, out itemId);
  585. result.deeplink_url = result.link_type switch
  586. {
  587. LinkTypeEnum.other_aff or
  588. LinkTypeEnum.live or
  589. LinkTypeEnum.video or
  590. LinkTypeEnum.profile or
  591. LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  592. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  593. };
  594. result.success = false;
  595. result.message = "放弃转链";
  596. result.reason = reason;
  597. if (!result.success)
  598. {
  599. result.deeplink_url = string.Empty;
  600. }
  601. _ = TkLogCore.ParseLogAsync(result, false);
  602. return JdParseOutput(result);
  603. }
  604. result.shortLinkurl = JdUnionPlus.GetLink(content);
  605. result.content = result.shortLinkurl;
  606. result.link_type = JdUnionPlus.GetLinkType(result.shortLinkurl, out out_url, out itemId);
  607. bool is_numeric = result.shortLinkurl.Contains(itemId);
  608. var account = request.AccountId > 0 ?
  609. await JdPoolCore.GetOneAsync(request.AccountId, JdPoolCore.JdAction.parse) :
  610. await JdPoolCore.GetOneAsync(JdPoolCore.JdAction.parse, is_numeric, request);
  611. if (account == null)
  612. {
  613. result.success = false;
  614. result.message = "放弃转链";
  615. result.reason = "没有匹配账号";
  616. result.deeplink_url = result.link_type switch
  617. {
  618. LinkTypeEnum.other_aff or LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  619. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  620. };
  621. if (!result.success)
  622. {
  623. result.deeplink_url = string.Empty;
  624. }
  625. _ = TkLogCore.ParseLogAsync(result, false);
  626. return JdParseOutput(result);
  627. }
  628. result.accountId = account.id;
  629. result.accountName = account.name;
  630. var plus = new JdUnionPlus(account);
  631. result.proxy_name = plus._proxyName;
  632. result.proxy_node = plus._proxy?.Address?.Host;
  633. result = await plus.JdParseAsync(content, request, result, cancellationToken);
  634. }
  635. catch (Exception ex)
  636. {
  637. if (ex.Message.Contains("was canceled"))
  638. {
  639. result.success = false;
  640. result.message = "放弃转链";
  641. result.reason = "请求超时";
  642. }
  643. else
  644. {
  645. IfExceptional = true;
  646. _ = new LoggerLibrary("unionParse", "jd_error")
  647. .Info(request.Ip, request.Oaid)
  648. .Info(request.Content)
  649. .Info(ex.Message, ex.StackTrace)
  650. .SaveAsync();
  651. NotifyCore.Notify(new NifyMessage
  652. {
  653. message = $"【转链异常JD】\n{request.Content}\n\n{ex.Message}\n{ex.StackTrace}",
  654. priority = NifyMessagePriority.high,
  655. tags = ["red_circle"]
  656. });
  657. result.success = false;
  658. result.message = "内部错误";
  659. result.reason = "转链接口异常";
  660. }
  661. result.deeplink_url = result.link_type switch
  662. {
  663. LinkTypeEnum.other_aff or LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  664. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  665. };
  666. }
  667. if (!result.success)
  668. {
  669. result.deeplink_url = string.Empty;
  670. }
  671. _ = TkLogCore.ParseLogAsync(result, false);
  672. return JdParseOutput(result, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK);
  673. }
  674. public static async Task<APIResult> DeeplinkPddParseAsync(UnionParseRequest request, CancellationToken cancellationToken = default)
  675. {
  676. var result = PddUnionPlus.GetFormattedObject(request);
  677. PddDataDTO? hiddenAccountFailure = null;
  678. HiddenLimitTicket? hiddenLimitTicket = null;
  679. var content = request.Content.UrlDecode();
  680. result.rawContent = content;
  681. result.parse_type = "dp";
  682. bool IfExceptional = false;
  683. try
  684. {
  685. var config = TkConfigCore.Get();
  686. var overrideContent = await OverrideRuleCore.ProcessAsync(request);
  687. if (overrideContent != null)
  688. {
  689. result.success = overrideContent.response_success;
  690. result.message = overrideContent.ResolveMessage("OK");
  691. result.reason = overrideContent.ResolveReason(result.reason);
  692. result.commercial = true;
  693. result.deeplink_url = overrideContent.output_text;
  694. _ = TkLogCore.ParseLogAsync(result);
  695. return PddParseOutput(result);
  696. }
  697. if (!string.IsNullOrEmpty(config.pdd_blacklist_regular))
  698. {
  699. var blacklist = config.pdd_blacklist_regular.Split('\n')
  700. .Where(line => !string.IsNullOrWhiteSpace(line))
  701. .ToList();
  702. bool anyMatch = false;
  703. foreach (string pattern in blacklist)
  704. {
  705. if (Regex.IsMatch(content, pattern, RegexOptions.IgnoreCase)) anyMatch = true;
  706. }
  707. if (anyMatch)
  708. {
  709. result.success = false;
  710. result.deeplink_url = string.Empty;
  711. result.message = "放弃转链";
  712. result.reason = "规则排除";
  713. _ = TkLogCore.ParseLogAsync(result);
  714. return PddParseOutput(result);
  715. }
  716. }
  717. //============================== 放弃转链-地区过滤 ==============================
  718. if (request.AccountId == 0 && PddUnionPlus.ShouldIgnoreRequest(config, request, out string reason))
  719. {
  720. result.success = false;
  721. result.message = "放弃转链";
  722. result.reason = reason;
  723. result.deeplink_url = PddUnionPlus.GetDeeplink(result.shortLinkurl);
  724. _ = TkLogCore.ParseLogAsync(result);
  725. return PddParseOutput(result);
  726. }
  727. if (!TestParseCore.InWhitelist(result.ip, result.oaid) && PddUnionPlus.FlowControlIgnoreRequest(config, request, out reason))
  728. {
  729. result.success = false;
  730. result.link_type = LinkTypeEnum.unknown;
  731. result.channel_type = ChannelTypeEnum.pdd;
  732. result.message = "放弃转链";
  733. result.reason = reason;
  734. result.accountId = 0;
  735. result.accountName = string.Empty;
  736. result.content = content;
  737. result.deeplink_url = PddUnionPlus.GetDeeplink(result.shortLinkurl);
  738. _ = TkLogCore.ParseLogAsync(result);
  739. return PddParseOutput(result);
  740. }
  741. var precheck = await PddUnionPlus.PrecheckGoodsIdAsync(result.shortLinkurl, cancellationToken);
  742. switch (precheck)
  743. {
  744. case RrecheckGoodsIdResult.InvalidLink:
  745. result.message = "放弃转链";
  746. result.reason = "无效链接";
  747. break;
  748. case RrecheckGoodsIdResult.Empty:
  749. result.message = "放弃转链";
  750. result.reason = $"无效的商品precheck";
  751. break;
  752. case RrecheckGoodsIdResult.Exception:
  753. result.message = "转链失败";
  754. result.reason = $"商品预检异常";
  755. break;
  756. }
  757. if (precheck != RrecheckGoodsIdResult.Success)
  758. {
  759. result.success = false;
  760. result.link_type = LinkTypeEnum.unknown;
  761. result.channel_type = ChannelTypeEnum.pdd;
  762. result.accountId = 0;
  763. result.accountName = string.Empty;
  764. result.content = content;
  765. result.deeplink_url = PddUnionPlus.GetDeeplink(result.shortLinkurl);
  766. _ = TkLogCore.ParseLogAsync(result);
  767. return PddParseOutput(result);
  768. }
  769. PddPoolDTO account = null;
  770. // 直接调用GetOne获取账号(parse_type="dp")
  771. // 新的调度策略已经在内部处理了:
  772. // 1. 基于时间间隔的账号选择
  773. // 2. 并发安全的账号预留(Redis SETNX)
  774. // 3. 依次尝试多个候选账号
  775. // 因此不需要外层重试逻辑
  776. account = PddPoolCore.GetOne(PddUnionWorkMode.All, request, "dp");
  777. if (account == null)
  778. {
  779. result.success = false;
  780. result.message = "放弃转链";
  781. result.reason = "没有匹配账号";
  782. result.deeplink_url = PddUnionPlus.GetDeeplink(result.shortLinkurl);
  783. _ = TkLogCore.ParseLogAsync(result);
  784. return PddParseOutput(result);
  785. }
  786. result.accountId = account.id;
  787. result.accountName = account.name;
  788. result.proxy_node = account.nodeName;
  789. if (account.is_hide) _ = TracksCore.RevertParseRequestAsync(request);
  790. result.hidden_account = account.is_hide;
  791. //============================== 放弃转链-隐藏号专用限制(城市、IP/OAID 每日次数,所有隐藏号共用) ==============================
  792. if (account.is_hide)
  793. {
  794. if (!HiddenAccountCore.TryReserveLimit(TkChannelEnum.pdd, request.Ip, request.Oaid, out hiddenLimitTicket, out string hiddenLimitReason))
  795. {
  796. result.success = false;
  797. result.message = "放弃转链";
  798. result.reason = hiddenLimitReason;
  799. result.subCode = (int)TkSubCodeEnum.TrafficCtrl;
  800. result.deeplink_url = PddUnionPlus.GetDeeplink(result.shortLinkurl);
  801. _ = TkLogCore.ParseLogAsync(result);
  802. // 传入隐藏号失败对象仅用于不输出埋点
  803. return PddParseOutput(result, APIResultCodeEnum.OK, CreatePddFailureResult(result));
  804. }
  805. }
  806. // 更新当前日使用统计
  807. PddPoolCore.UpdateAccountUsage(account.id);
  808. var plus = new PddUnionPlus(account);
  809. hiddenAccountFailure = account.is_hide ? CreatePddFailureResult(result) : null;
  810. result = await plus.PddParseAsync(content, request.CommerceType, result, cancellationToken);
  811. }
  812. catch (Exception ex)
  813. {
  814. if (ex.Message.Contains("was canceled"))
  815. {
  816. result.success = false;
  817. result.message = "放弃转链";
  818. result.reason = "请求超时";
  819. }
  820. else
  821. {
  822. IfExceptional = true;
  823. _ = new LoggerLibrary("unionParse", "pdd_error")
  824. .Info(request.Ip, request.Oaid)
  825. .Info(content)
  826. .Info(ex.Message, ex.StackTrace)
  827. .SaveAsync();
  828. NotifyCore.Notify(new NifyMessage
  829. {
  830. message = $"【转链异常PDD】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
  831. priority = NifyMessagePriority.high,
  832. tags = ["red_circle"]
  833. });
  834. result.success = false;
  835. result.message = "内部错误";
  836. result.reason = "转链接口异常";
  837. }
  838. }
  839. // 隐藏号:转链成功计入当天 ip/oaid 次数,失败则归还占用的名额
  840. if (hiddenLimitTicket != null)
  841. {
  842. _ = HiddenAccountCore.CompleteLimitAsync(hiddenLimitTicket, result.success);
  843. }
  844. _ = TkLogCore.ParseLogAsync(result);
  845. return PddParseOutput(result, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK, hiddenAccountFailure);
  846. }
  847. private static ParseDeeplinkResust parseJdDeeplinkInput(string content)
  848. {
  849. ParseDeeplinkResust resust = new();
  850. if (!content.StartsWith("openapp.jdmobile://") && !content.StartsWith("openjd://"))
  851. {
  852. resust.success = false;
  853. resust.reason = "不是有效DP";
  854. return resust;
  855. }
  856. try
  857. {
  858. string param = content.GetContentPart("params=", "&");
  859. if (string.IsNullOrEmpty(param))
  860. {
  861. param = content.GetContentPart("params=", "");
  862. }
  863. param = param.UrlDecode();
  864. var root = param.Convert2JsonElement();
  865. string category = root.Read("category", string.Empty);
  866. string sourceType = root.Read("sourceType", string.Empty);
  867. string skuId = root.Read("skuId", string.Empty);
  868. string url = root.Read("url", string.Empty);
  869. string des = root.Read("des", string.Empty);
  870. switch (sourceType)
  871. {
  872. case "Item":
  873. resust.url = $"https://item.jd.com/{skuId}.html";
  874. resust.success = true;
  875. return resust;
  876. }
  877. switch (category)
  878. {
  879. case "jump":
  880. switch (des)
  881. {
  882. case "getCoupon":
  883. case "union":
  884. resust.success = false;
  885. resust.reason = "其他推广链接";
  886. return resust;
  887. case "m":
  888. resust.url = url;
  889. break;
  890. case "productDetail":
  891. resust.success = true;
  892. resust.url = $"https://item.jd.com/{skuId}.html";
  893. return resust;
  894. }
  895. break;
  896. }
  897. if (string.IsNullOrEmpty(url))
  898. {
  899. resust.success = false;
  900. resust.reason = "未知链接";
  901. }
  902. string utm_campaign = resust.url.GetContentPart("utm_campaign=", "&");
  903. string utm_term = resust.url.GetContentPart("utm_term=", "&");
  904. if (url.Contains("union-click.jd.com") || url.Contains("union-activity") ||
  905. !string.IsNullOrEmpty(utm_campaign) || !string.IsNullOrEmpty(utm_term))
  906. {
  907. resust.success = false;
  908. resust.reason = "其他推广链接";
  909. return resust;
  910. }
  911. resust.success = true;
  912. return resust;
  913. }
  914. catch (Exception ex)
  915. {
  916. resust.success = false;
  917. resust.reason = "内部错误";
  918. return resust;
  919. }
  920. }
  921. private static ParseDeeplinkResust parseTaobaoDeeplinkInput(string content)
  922. {
  923. ParseDeeplinkResust resust = new();
  924. if (!content.StartsWith("taobao://") && !content.StartsWith("tbopen://") && !content.StartsWith("tmall://"))
  925. {
  926. resust.success = false;
  927. resust.reason = "不是有效DP";
  928. return resust;
  929. }
  930. if (content.Contains("ali_trackid="))
  931. {
  932. resust.success = false;
  933. resust.reason = "其他推广链接";
  934. return resust;
  935. }
  936. string itemid_pattern = "(?:pc_detail\\.itemId\\.\\d+&id=|(?:detail|item).*?[?&]id=)(\\d+)";
  937. //https://h5.m.taobao.com/awp/core/detail.htm?id=951950415328
  938. //taobao://item.taobao.com/item.htm?id=950190032209
  939. //https://main.m.taobao.com/detail/index.html?id=908945171430&price=148.9&sourceType=item&suid=9a9921f6-5610-497c-9bb3-94427da5fbc0&ut_sk=1.aFUBza6VAN8DAOC0tQdyzNek_21646297_1753594384153.Copy.ShareGlobalNavigation_1&un=8ad28c612754fb28d9e5b32ae03d1ada&share_crt_v=1&un_site=0&spm=a2159r.13376460.0.0&tbSocialPopKey=shareItem&sp_tk=MnluVjQ0N2tDUXU%3D&cpp=1&shareurl=true&short_name=h.hOFywxY0R9ZuBR4&bxsign=scduUbJTmvx63UiuFdNYy6FDvPx0iaKQu9uyc1zfURgLpCZqHIO1Aqj8fgZ6_ZUy-rJeS1ZH3PiAGcemxyFqpeN5BTKnDbDuU77d6sqWD2TVok-8K3nspP6YVfAZBvzfx7WLVAMu3X6119Ru_1ooSt9ug&tk=2ynV447kCQu&app=chrome&x-ssr=true&slk_gid=gid_er_sidebar_0&action=ali.open.nav&module=h5&bootImage=0&slk_sid=2nf7IO8XhWICAd9KM5hOtK8k_1753783603680&slk_t=1753783605292&slk_gid=gid_er_sidebar_0&afcPromotionOpen=false&bc_fl_src=h5_huanduan&source=slk_dp
  940. //https://main.m.taobao.com/detail/index.html?id=937709627060&price=208.9&sourceType=item&suid=48a4d791-127c-45d7-b580-a63097897697&ut_sk=1.aFUBza6VAN8DAOC0tQdyzNek_21646297_1753594384153.Copy.ShareGlobalNavigation_1&un=8ad28c612754fb28d9e5b32ae03d1ada&share_crt_v=1&un_site=0&spm=a2159r.13376460.0.0&tbSocialPopKey=shareItem&sp_tk=SG42aTQ0NzFMc3Y%3D&cpp=1&shareurl=true&short_name=h.hOCuiAd32dv9wBK&bxsign=scd0KcwU22FkrzJ77bVvMLnP0u4_5wpLz1ERfC-eCQE1wk21BYNMuT-w0I07gisSMdabKmlWh9F6DwW5DXLagikYvHjSD7Eh5n2n6kmyw1aF-dZWuqzGkI9Z-AHw-rffwjrPx1cXEsQ35HqOwmmkMEiYw&tk=Hn6i4471Lsv&app=chrome&x-ssr=true&slk_gid=gid_er_sidebar_0&action=ali.open.nav&module=h5&bootImage=0&slk_sid=580NIcIpZVQBASQOANYD2H43_1753783601070&slk_t=1753783605251&slk_gid=gid_er_sidebar_0&afcPromotionOpen=false&bc_fl_src=h5_huanduan&source=slk_dp
  941. //https://main.m.taobao.com/detail/index.html?spm=a224e.7913437.1.1849716&id=672205270263&sku_properties=210158085%3A170720673&_bind=true&bc_fl_src=tmall_market_llb_1_1849716&llbPlatform=pc&agentId=1685089&llbIsd=1&bxsign=llbirWpI8yJlJLibTbWOXuYbuykv0WCTORO2Hj7JqVtdGau62UJiz2xO%2FZSIjdwbOudIUUsdN51H41YisrOLI53ZMhblPS9ZMyVhFDisOySHmk%3D&ntfMsId=65df6cbb682a0779f23141a7efd9c391&llbOsd=1&mm_unid=1_11192113_560501015e6d5754040c0255026f5353086656040b075e&jlogid=0718172753b3bfbd&x-ssr=true&slk_gid=gid_er_sidebar_0&bc_fl_src=tmall_market_llb_1_1849716&action=ali.open.nav&module=h5&bootImage=0&slk_sid=rnd07d9b9_1753784332640&slk_t=1753784332860&slk_gid=gid_er_sidebar_0&afcPromotionOpen=false&source=slk_dp
  942. var regex = new Regex(itemid_pattern);
  943. var match = regex.Match(content);
  944. if (match.Success)
  945. {
  946. string itemId = match.Groups[1].Value;
  947. string item_url = $"https://item.taobao.com/item.htm?id={itemId}";
  948. resust.success = true;
  949. resust.url = item_url;
  950. return resust;
  951. }
  952. /*
  953. * tbopen://m.taobao.com/tbopen/index.html?action=ali.open.nav&module=h5&source=alimama&bc_fl_src=tunion_vipmedia_sy&h5Url=https%3A%2F%2Fs.click.taobao.com%2Ff8sLf2s
  954. * tbopen://m.taobao.com/tbopen/index.html?h5Url=https%3A%2F%2Fmain.m.taobao.com%2Fsearch%2Findex.html%3Fspm%3Da215s.7406091.topbar.1.560c6770snz1OF%26pageType%3D3%26q%3D%25E6%2598%259F%25E8%25BF%2590%25E5%258D%25A1
  955. *
  956. tbopen://m.taobao.com/tbopen/index.html?h5Url=https%3A%2F%2Fmain.m.taobao.com%2Fsearch%2Findex.html%3Fspm%3Da215s.7406091.topbar.1.560c6770snz1OF%26pageType%3D3%26q%3D%25E9%25A1%25BA%25E6%2597%25BA%25E5%258D%25A1
  957. tbopen://m.taobao.com/tbopen/index.html?h5Url=https%3A%2F%2Fku.m.taobao.com%2Fmix.htm%3Fdf_sid%3D215f61a7f2d0d7006883872e0fa2df3d%26_oneId%3DBD00ECC981654638911F62B6CCF30F30C261E65C5A593BD4E4C78E7F0B05AA0B%26kn%3D521909AA62D8712AA77BD65C878A07BF59834B3D18D1D24D2C0E947EC545D6EA%26package_name%3D2%2FYVzIkqDv9cGePpY%2FRKjGIB7bMMF5twBLhjEiOCk9g%26refpid%3Dmm_26632268_153800213_74441300498%26itemid%3D646763119270%26adgroupid%3D74846357352%26catid%3D1801%26adsrc%3D2%26tk%3D1.1_rUEipiu4lQnCUAcGljdHYD4C6l8ikkERn4TzMch3-OXcoJ3I2L9ZMNENrcyuEA6d%26bc_fl_src%3Dtanx_df_74441300498_215f61a7f2d0d7006883872e0fa2df3d_0_646763119270_74846357352_74867406695_0_1_0_2_0_0_2211829026650_0_646763119270_0_0_0_0_1%26mip%3DXmhaREh7ZFVhSH13Xg%26pdiv%3Dqt3%26project_id%3D1%26ali_trackid%3D158_471853809d7b199af8af80e276b7edb9%26bxsign%3DtanTcJ_vnwBjiXMx6dXdbwNtN0NYe4Dxw8jdMFUfthOcBEBDMKekKKeyFJVBC1HN90EhBu4bnt877-6MRM7VMJfXPrwh_1B7nUf6olHer4TLXU%26slk_gid%3Dgid_er_sidebar_0%26tkSid%3D1752753038137_556550289_0.0%26tk_cps_ut%3D12%26e%3DEb2ey4TKM3Zwv7nGTZ2_-rX3DTSVrV-TdPW7X9DGPerTBdT1uMUzpLB4tW1Ia-SYSzILWu-4Ylw1xiku1Ij7RdZ9rtbmhnxUlYC60BGXgC5f6ehAkwDioKUmn1Ujh2ntIbOKDm8SGGXFqv6GieJi2KXc4rofFFSJZ6rS0GtzoCFGKDxAFeCMxblh5_iK7tdUOCg-a4qwrTN2_AL2y2LOy60-b68KW7cRvO7dXGStqJAigOjjYrz2j5MUyWjCKPHVoZD9rN1I0mU8VGta6ZddcKfRgMu9M8FAVWx6XRy23oSLkoMYS_fbzlZlGzzVHt-JtOrywR95lxHccBzKc7kLgBvZbuLTRODDNWlsmyjpbuya2Ddv0ls-v1Y0FiUPJBa3VjcpA4WsRFam6zFndQ3HZaZPpBJnnE487qeUylWc6TSX3cwyLTlAhlg4CzRoOGUPfG2M1DxYVhIM-7XZOBKdtm1-MNutVMsdVL5FrN2D3QFIHauVi2R1R4T_8p273pSzV1XCG8Ub_zp6czCzvmBAnuTHBUPfjEfH31tdnUQbdFwwPrn00QwN2w%26type%3D2%26tkFlag%3D1&bc_fl_src=tanx_df_74441300498_215f61a7f2d0d7006883872e0fa2df3d_0_646763119270_74846357352_74867406695_0_1_0_2_0_0_2211829026650_0_646763119270_0_0_0_0_1&action=ali.open.nav&module=h5&bootImage=0&slk_sid=j9H/IH/fa3kBASQJiigVFV2u_1753450292601&slk_t=1753450293764&slk_gid=gid_er_sidebar_0&afcPromotionOpen=false&ali_trackid=158_471853809d7b199af8af80e276b7edb9&source=slk_dp
  958. */
  959. string url = content.GetContentPart("h5Url=", "&");
  960. if (string.IsNullOrEmpty(url))
  961. {
  962. url = content.GetContentPart("h5Url=", "");
  963. }
  964. if (url.ToLower().StartsWith("https%253a") || url.ToLower().StartsWith("http%253a"))
  965. {
  966. url = url.UrlDecode().UrlDecode();
  967. }
  968. if (url.ToLower().StartsWith("https%3a") || url.ToLower().StartsWith("http%3a"))
  969. {
  970. url = url.UrlDecode();
  971. }
  972. if (string.IsNullOrEmpty(url))
  973. {
  974. resust.success = false;
  975. resust.reason = "未知链接";
  976. return resust;
  977. }
  978. if (AlimamaPlus.IsAffLink(url))
  979. {
  980. resust.success = false;
  981. resust.reason = "其他推广链接";
  982. return resust;
  983. }
  984. if (url.Contains("ali_trackid="))
  985. {
  986. resust.success = false;
  987. resust.reason = "其他推广链接";
  988. return resust;
  989. }
  990. if (AlimamaPlus.IsShortLink(url))
  991. {
  992. resust.success = true;
  993. resust.url = url;
  994. return resust;
  995. }
  996. regex = new Regex(itemid_pattern);
  997. match = regex.Match(url);
  998. if (match.Success)
  999. {
  1000. string itemId = match.Groups[1].Value;
  1001. string item_url = $"https://item.taobao.com/item.htm?id={itemId}";
  1002. resust.success = true;
  1003. resust.url = item_url;
  1004. return resust;
  1005. }
  1006. resust.success = false;
  1007. resust.reason = "未知链接";
  1008. return resust;
  1009. }
  1010. private static string parseDeeplinkInput(string content)
  1011. {
  1012. if (content.StartsWith("tbopen://") || content.StartsWith("tmall://"))
  1013. {
  1014. string url = content.GetContentPart("h5Url=", "&");
  1015. if (string.IsNullOrEmpty(url))
  1016. {
  1017. url = content.GetContentPart("h5Url=", "");
  1018. }
  1019. if (string.IsNullOrEmpty(url)) return content;
  1020. content = url.UrlDecode();
  1021. }
  1022. if (content.StartsWith("openapp.jdmobile://"))
  1023. {
  1024. try
  1025. {
  1026. string param = content.GetContentPart("params=", "");
  1027. param = param.UrlDecode();
  1028. var root = param.Convert2JsonElement();
  1029. string category = root.Read("category", string.Empty);
  1030. string sourceType = root.Read("sourceType", string.Empty);
  1031. string skuId = root.Read("skuId", string.Empty);
  1032. switch (sourceType)
  1033. {
  1034. case "Item":
  1035. string url_content = $"https://item.jd.com/{skuId}.html";
  1036. return url_content;
  1037. }
  1038. switch (category)
  1039. {
  1040. case "jump":
  1041. string url = root.Read("url", string.Empty);
  1042. string url_content = url;
  1043. return url_content;
  1044. }
  1045. }
  1046. catch (Exception ex)
  1047. {
  1048. }
  1049. }
  1050. return content;
  1051. }
  1052. }
  1053. }