dp2dp.cs 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902
  1. using dodohold.core;
  2. using Microsoft.AspNetCore.Mvc;
  3. using System.Diagnostics;
  4. using System.Text.RegularExpressions;
  5. namespace molilian.core
  6. {
  7. public class ParseDeeplinkResust
  8. {
  9. public bool success { get; set; } = false;
  10. public string reason { get; set; } = string.Empty;
  11. public string url { get; set; } = string.Empty;
  12. }
  13. public partial class UnionParseCore
  14. {
  15. public static async Task<APIResult> DeeplinkTaobaoParseAsync(string content, int commerceType,
  16. string ip = "", string oaid = "", string riskStrategy = "", int launchScene = 0,
  17. int accountid = 0)
  18. {
  19. bool other_aff = false;
  20. AlimamaPlus alimama = null;
  21. var result = AlimamaPlus.GetFormattedObject(content, ip, oaid);
  22. result.riskStrategy = riskStrategy;
  23. result.launchScene = launchScene;
  24. result.rawContent = content;
  25. result.parse_type = "dp";
  26. Dictionary<string, long> swData = new();
  27. swData.Add("StartNew", 0);
  28. Stopwatch stopwatch = Stopwatch.StartNew();
  29. try
  30. {
  31. var parseResult = parseTaobaoDeeplinkInput(content);
  32. if (!parseResult.success)
  33. {
  34. result.channel = TkChannelEnum.tb;
  35. result.channel_type = ChannelTypeEnum.tb;
  36. result.link_type = LinkTypeEnum.other_aff;
  37. result.success = false;
  38. result.message = "放弃转链";
  39. result.reason = parseResult.reason;
  40. result.subCode = TkSubCodeEnum.OtherPromo;
  41. result.accountName = string.Empty;
  42. result.content = content;
  43. result.deeplink_url = string.Empty;
  44. _ = TkLogCore.ParseLogAsync(result);
  45. return TaobaoParseOutput(result, swData, new
  46. {
  47. result.success,
  48. result.commercial,
  49. result.message,
  50. result.content,
  51. result.itemName,
  52. other_aff = true,
  53. result.deeplink_url,
  54. });
  55. }
  56. (bool isTaobaUrl, string shortLinkurl) = AlimamaPlus.IsTaobaoUrl(parseResult.url);
  57. if (!isTaobaUrl)
  58. {
  59. result.success = false;
  60. result.channel = TkChannelEnum.tb;
  61. result.link_type = LinkTypeEnum.unknown;
  62. result.success = false;
  63. result.message = "放弃转链";
  64. result.reason = "无效商品id";
  65. if (!result.success)
  66. {
  67. result.deeplink_url = string.Empty;
  68. }
  69. _ = TkLogCore.ParseLogAsync(result);
  70. return TaobaoParseOutput(result, swData, new
  71. {
  72. result.success,
  73. result.commercial,
  74. result.message,
  75. result.content,
  76. result.itemName,
  77. other_aff,
  78. result.deeplink_url,
  79. });
  80. }
  81. result.shortLinkurl = shortLinkurl;
  82. result.deeplink_url = string.Empty;
  83. result.content = shortLinkurl;
  84. content = shortLinkurl;
  85. string reason = string.Empty;
  86. var config = TkConfigCore.Get();
  87. var arr = config.tk_whitelist_regular.Split('\n')
  88. .Where(line => !string.IsNullOrWhiteSpace(line))
  89. .ToList();
  90. var arr2 = config.tk_blacklist_regular.Split('\n')
  91. .Where(line => !string.IsNullOrWhiteSpace(line))
  92. .ToList();
  93. var arr3 = config.multi_token_regular.Split('\n')
  94. .Where(line => !string.IsNullOrWhiteSpace(line))
  95. .ToList();
  96. bool is_tao_url = !string.IsNullOrEmpty(result.shortLinkurl);
  97. bool is_tao_token = AlimamaPlus.MatchRegexes(content, arr);
  98. bool is_other = AlimamaPlus.MatchOtherInfo(content, arr2);
  99. //============================== 放弃转链-初步筛选1 ==============================
  100. if (!is_tao_url && !is_tao_token || is_other)
  101. {
  102. //没有链接都放弃
  103. result.success = false;
  104. result.message = "放弃转链";
  105. result.reason = "初步筛选1";
  106. result.subCode = TkSubCodeEnum.Prelim1;
  107. result.itemName = "";
  108. result.deeplink_url = string.Empty;
  109. _ = TkLogCore.ParseLogAsync(result);
  110. return TaobaoParseOutput(result, swData, new
  111. {
  112. result.success,
  113. result.commercial,
  114. result.message,
  115. result.content,
  116. result.itemName,
  117. other_aff,
  118. result.deeplink_url,
  119. });
  120. }
  121. bool is_multi_token = AlimamaPlus.MatchMultiToken(content, arr3);
  122. //============================== 放弃转链-初步筛选1.5 ==============================
  123. if (is_multi_token)
  124. {
  125. //没有链接都放弃
  126. result.success = false;
  127. result.message = "放弃转链";
  128. result.reason = "初步筛选1.5";
  129. result.subCode = TkSubCodeEnum.Prelim1_5;
  130. result.itemName = "";
  131. result.deeplink_url = string.Empty;
  132. _ = TkLogCore.ParseLogAsync(result);
  133. return TaobaoParseOutput(result, swData, new
  134. {
  135. result.success,
  136. result.commercial,
  137. result.message,
  138. result.content,
  139. result.itemName,
  140. other_aff,
  141. result.deeplink_url,
  142. });
  143. }
  144. //============================== 放弃转链-初步筛选2 ==============================
  145. bool is_aff_link = false;
  146. if (!string.IsNullOrEmpty(result.shortLinkurl)) is_aff_link = AlimamaPlus.IsAffLink(result.shortLinkurl);
  147. if (!is_tao_url && is_tao_token)
  148. {
  149. //淘宝口令
  150. result.success = false;
  151. result.message = "放弃转链";
  152. result.reason = "初步筛选2";
  153. result.subCode = TkSubCodeEnum.Prelim2;
  154. result.itemName = "点击打开淘宝APP";
  155. if (!result.success)
  156. {
  157. result.deeplink_url = string.Empty;
  158. }
  159. _ = TkLogCore.ParseLogAsync(result);
  160. //20241229 特例
  161. //if ("bj".Equals(EndPointCore.CurrentEndPoint))
  162. //{
  163. // string ruleKey = $"tmp_rules2:tb:{DateTime.Now:yyyyMMdd}";
  164. // var count = RedisHelper.Get<int>(ruleKey);
  165. // var now = DateTime.Now;
  166. // if (now > new DateTime(2024, 12, 19) && now <= new DateTime(2024, 12, 22) && now.Hour >= 7 && count < 1000)
  167. // {
  168. // 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";
  169. // RedisHelper.IncrBy(ruleKey);
  170. // RedisHelper.Expire(ruleKey, 86400 * 1);
  171. // }
  172. //}
  173. other_aff = true;
  174. return TaobaoParseOutput(result, swData, new
  175. {
  176. result.success,
  177. result.commercial,
  178. result.message,
  179. result.content,
  180. result.itemName,
  181. other_aff,
  182. result.deeplink_url,
  183. });
  184. }
  185. if ((!is_tao_url && is_tao_token) || is_aff_link)
  186. {
  187. //没有短链接都放弃
  188. result.success = false;
  189. result.message = "放弃转链";
  190. result.reason = "初步筛选2";
  191. result.subCode = TkSubCodeEnum.Prelim2;
  192. result.itemName = "点击打开淘宝APP";
  193. if (!result.success)
  194. {
  195. result.deeplink_url = string.Empty;
  196. }
  197. _ = TkLogCore.ParseLogAsync(result);
  198. //20241229 特例
  199. //if ("bj".Equals(EndPointCore.CurrentEndPoint))
  200. //{
  201. // string ruleKey = $"tmp_rules2:tb:{DateTime.Now:yyyyMMdd}";
  202. // var count = RedisHelper.Get<int>(ruleKey);
  203. // var now = DateTime.Now;
  204. // if (now > new DateTime(2024, 12, 19) && now <= new DateTime(2024, 12, 22) && now.Hour >= 7 && count < 1000)
  205. // {
  206. // 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";
  207. // RedisHelper.IncrBy(ruleKey);
  208. // RedisHelper.Expire(ruleKey, 86400 * 1);
  209. // }
  210. //}
  211. other_aff = true;
  212. return TaobaoParseOutput(result, swData, new
  213. {
  214. result.success,
  215. result.commercial,
  216. result.message,
  217. result.content,
  218. result.itemName,
  219. other_aff,
  220. result.deeplink_url,
  221. });
  222. }
  223. //那就初步筛选3 有tb.cn 并且有 or 手淘发现
  224. string pattern = @"^(?!【淘宝】).*https?:\/\/m\.tb\.cn.*(?:手淘发现|手淘搜索)";
  225. bool isMatch = Regex.IsMatch(content, pattern);
  226. if (isMatch)
  227. {
  228. result.success = false;
  229. result.message = "放弃转链";
  230. result.reason = "初步筛选3";
  231. result.subCode = TkSubCodeEnum.Prelim3;
  232. result.itemName = "点击打开淘宝APP";
  233. if (!result.success)
  234. {
  235. result.deeplink_url = string.Empty;
  236. }
  237. _ = TkLogCore.ParseLogAsync(result);
  238. return TaobaoParseOutput(result, swData, new
  239. {
  240. result.success,
  241. result.commercial,
  242. result.message,
  243. result.content,
  244. result.itemName,
  245. other_aff,
  246. result.deeplink_url,
  247. });
  248. }
  249. //============================== 放弃转链-地区过滤 ==============================
  250. bool is_ignore2 = AlimamaPlus.ShouldIgnoreRequest(ip, oaid, riskStrategy, launchScene, out reason);
  251. if (is_ignore2)
  252. {
  253. result.success = false;
  254. result.message = "放弃转链";
  255. result.itemName = "点击打开淘宝APP";
  256. result.reason = reason;
  257. result.subCode = TkSubCodeEnum.TrafficCtrl;
  258. if (!result.success)
  259. {
  260. result.deeplink_url = string.Empty;
  261. }
  262. _ = TkLogCore.ParseLogAsync(result);
  263. return TaobaoParseOutput(result, swData, new
  264. {
  265. result.success,
  266. result.commercial,
  267. result.message,
  268. result.content,
  269. result.itemName,
  270. other_aff,
  271. result.deeplink_url,
  272. });
  273. }
  274. (bool isTaobaoUrl, string url) = AlimamaPlus.IsTaobaoUrl(content);
  275. //============================== 放弃转链-没有匹配账号 ==============================
  276. TkPoolDTO? account = accountid > 0 ?
  277. await TkPoolCore.GetOneAsync(accountid) :
  278. await TkPoolCore.GetOneAsync(TkPoolCore.TkAction.parse, isTaobaoUrl, riskStrategy, launchScene, "dp");
  279. if (account == null)
  280. {
  281. result.success = false;
  282. result.message = "放弃转链";
  283. result.reason = "没有匹配账号";
  284. result.subCode = TkSubCodeEnum.Other;
  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. result.success,
  294. result.commercial,
  295. result.message,
  296. result.content,
  297. result.couponAmount,
  298. result.taoToken,
  299. result.shortLinkurl,
  300. other_aff,
  301. result.deeplink_url,
  302. });
  303. }
  304. result.accountId = account.id;
  305. result.accountName = account.company;
  306. alimama = new AlimamaPlus(account);
  307. int timeout = alimama._config.rt_max;
  308. #if DEBUG
  309. timeout = 10000;
  310. #endif
  311. using var cts = new CancellationTokenSource();
  312. cts.CancelAfter(timeout);
  313. var requestTask = Task.Run(() => alimama.UnionParseAsync(ip, oaid, content, commerceType, result, isTaobaoUrl, riskStrategy, launchScene, cts.Token, swData), cts.Token);
  314. var delayTask = Task.Delay(timeout, cts.Token);
  315. var completedTask = await Task.WhenAny(requestTask, delayTask);
  316. if (completedTask == requestTask)
  317. {
  318. result = await requestTask;
  319. }
  320. else
  321. {
  322. //============================== 放弃转链-请求超时 ==============================
  323. cts.Cancel();
  324. result.success = false;
  325. result.message = "放弃转链";
  326. result.reason = "请求超时";
  327. result.subCode = TkSubCodeEnum.Other;
  328. result.itemName = "点击打开淘宝APP";
  329. }
  330. result.accountName = account.company;
  331. //result = await alimama.UnionParse2Async(content, result);
  332. }
  333. catch (Exception ex)
  334. {
  335. //============================== 放弃转链-请求超时 ==============================
  336. if (ex.Message.Contains("was canceled"))
  337. {
  338. result.success = false;
  339. result.message = "放弃转链";
  340. result.reason = "请求超时";
  341. result.subCode = TkSubCodeEnum.Other;
  342. result.itemName = "点击打开淘宝APP";
  343. }
  344. else
  345. {
  346. //============================== 转链接口异常 ==============================
  347. _ = new LoggerLibrary("unionParse", "tb_error")
  348. .Info(ip, oaid)
  349. .Info(content)
  350. .Info(ex.Message, ex.StackTrace)
  351. .SaveAsync();
  352. NotifyCore.Notify(new NifyMessage
  353. {
  354. message = $"【转链异常TB】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
  355. priority = NifyMessagePriority.high,
  356. tags = ["red_circle"]
  357. });
  358. result.success = false;
  359. result.subCode = TkSubCodeEnum.Other;
  360. result.message = "转链接口异常";
  361. result.itemName = "点击打开淘宝APP";
  362. }
  363. }
  364. if (!result.success)
  365. {
  366. result.deeplink_url = string.Empty;
  367. }
  368. _ = TkLogCore.ParseLogAsync(result, alimama);
  369. switch (result.reason)
  370. {
  371. case "其他推广链接":
  372. //case "排除淘口令":
  373. case "纯口令 没链接":
  374. other_aff = true;
  375. break;
  376. }
  377. return TaobaoParseOutput(result, swData, new
  378. {
  379. result.success,
  380. result.commercial,
  381. result.message,
  382. link_type = result.link_type.ToString(),
  383. channel = result?.channel.ToString(),
  384. result.channel_type,
  385. result.itemId,
  386. result.itemName,
  387. result.pic,
  388. result.promotionPrice,
  389. result.couponAmount,
  390. result.couponEffectiveStartTime,
  391. result?.couponEffectiveEndTime,
  392. result.shortLinkurl,
  393. result.deeplink_url,
  394. result.riskStrategy,
  395. result.launchScene,
  396. result.content,
  397. result.taoToken,
  398. other_aff,
  399. });
  400. }
  401. public static async Task<APIResult> DeeplinkJdParseAsync(string content, int commerceType, string ip, string oaid,
  402. string riskStrategy = "", int launchScene = 0,
  403. int accountid = 0, string clickId = "", CancellationToken cancellationToken = default)
  404. {
  405. var config = TkConfigCore.Get();
  406. var result = JdUnionPlus.GetFormattedObject(content, ip, oaid, clickId);
  407. result.rawContent = content;
  408. result.parse_type = "dp";
  409. result.riskStrategy = riskStrategy;
  410. result.launchScene = launchScene;
  411. bool IfExceptional = false;
  412. try
  413. {
  414. var parseResult = parseJdDeeplinkInput(content);
  415. if (!parseResult.success)
  416. {
  417. result.channel = TkChannelEnum.jd;
  418. result.channel_type = ChannelTypeEnum.jd;
  419. result.link_type = LinkTypeEnum.other_aff;
  420. result.success = false;
  421. result.message = "放弃转链";
  422. result.reason = parseResult.reason;
  423. result.accountName = string.Empty;
  424. result.content = content;
  425. result.deeplink_url = string.Empty;
  426. _ = TkLogCore.ParseLogAsync(result);
  427. return JdParseOutput(result);
  428. }
  429. result.shortLinkurl = parseResult.url;
  430. result.content = parseResult.url;
  431. result.deeplink_url = string.Empty;
  432. content = parseResult.url;
  433. if (!string.IsNullOrEmpty(config.jd_blacklist_regular))
  434. {
  435. var blacklist = config.jd_blacklist_regular.Split('\n')
  436. .Where(line => !string.IsNullOrWhiteSpace(line))
  437. .ToList();
  438. bool anyMatch = false;
  439. foreach (string pattern in blacklist)
  440. {
  441. if (Regex.IsMatch(content, pattern, RegexOptions.IgnoreCase)) anyMatch = true;
  442. }
  443. if (anyMatch)
  444. {
  445. result.success = false;
  446. result.deeplink_url = string.Empty;
  447. result.message = "放弃转链";
  448. result.reason = "规则排除";
  449. _ = TkLogCore.ParseLogAsync(result);
  450. return JdParseOutput(result);
  451. }
  452. }
  453. string out_url = null;
  454. string itemId = null;
  455. //============================== 放弃转链-地区过滤 ==============================
  456. if (!TestParseCore.InWhitelist(result.ip, result.oaid) && accountid == 0 && JdUnionPlus.ShouldIgnoreRequest(config, ip, oaid, riskStrategy, launchScene, out string reason))
  457. {
  458. result.link_type = JdUnionPlus.GetLinkType(result.shortLinkurl, out out_url, out itemId);
  459. result.deeplink_url = result.link_type switch
  460. {
  461. LinkTypeEnum.other_aff or
  462. LinkTypeEnum.live or
  463. LinkTypeEnum.video or
  464. LinkTypeEnum.profile or
  465. LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  466. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  467. };
  468. result.success = false;
  469. result.message = "放弃转链";
  470. result.reason = reason;
  471. if (!result.success)
  472. {
  473. result.deeplink_url = string.Empty;
  474. }
  475. _ = TkLogCore.ParseLogAsync(result);
  476. return JdParseOutput(result);
  477. }
  478. result.shortLinkurl = JdUnionPlus.GetLink(content);
  479. result.content = result.shortLinkurl;
  480. result.link_type = JdUnionPlus.GetLinkType(result.shortLinkurl, out out_url, out itemId);
  481. bool is_numeric = result.shortLinkurl.Contains(itemId);
  482. var account = accountid > 0 ? await JdPoolCore.GetOneAsync(accountid, JdPoolCore.JdAction.parse) : await JdPoolCore.GetOneAsync(JdPoolCore.JdAction.parse, riskStrategy, launchScene, is_numeric, "dp");
  483. if (account == null)
  484. {
  485. result.success = false;
  486. result.message = "放弃转链";
  487. result.reason = "没有匹配账号";
  488. result.deeplink_url = result.link_type switch
  489. {
  490. LinkTypeEnum.other_aff or LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  491. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  492. };
  493. if (!result.success)
  494. {
  495. result.deeplink_url = string.Empty;
  496. }
  497. _ = TkLogCore.ParseLogAsync(result);
  498. return JdParseOutput(result);
  499. }
  500. result.accountId = account.id;
  501. result.accountName = account.name;
  502. var plus = new JdUnionPlus(account);
  503. result = await plus.JdParseAsync(content, commerceType, clickId, result, cancellationToken);
  504. }
  505. catch (Exception ex)
  506. {
  507. if (ex.Message.Contains("was canceled"))
  508. {
  509. result.success = false;
  510. result.message = "放弃转链";
  511. result.reason = "请求超时";
  512. }
  513. else
  514. {
  515. IfExceptional = true;
  516. _ = new LoggerLibrary("unionParse", "jd_error")
  517. .Info(ip, oaid)
  518. .Info(content)
  519. .Info(ex.Message, ex.StackTrace)
  520. .SaveAsync();
  521. NotifyCore.Notify(new NifyMessage
  522. {
  523. message = $"【转链异常JD】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
  524. priority = NifyMessagePriority.high,
  525. tags = ["red_circle"]
  526. });
  527. result.success = false;
  528. result.message = "内部错误";
  529. result.reason = "转链接口异常";
  530. }
  531. result.deeplink_url = result.link_type switch
  532. {
  533. LinkTypeEnum.other_aff or LinkTypeEnum.goods => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  534. _ => JdUnionPlus.GetDefaultStyleDeeplink(result.shortLinkurl),
  535. };
  536. }
  537. if (!result.success)
  538. {
  539. result.deeplink_url = string.Empty;
  540. }
  541. _ = TkLogCore.ParseLogAsync(result);
  542. return JdParseOutput(result, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK);
  543. }
  544. public static async Task<APIResult> DeeplinkPddParseAsync(string content, int commerceType, string ip, string oaid,
  545. int accountid = 0, CancellationToken cancellationToken = default)
  546. {
  547. var result = PddUnionPlus.GetFormattedObject(content, ip, oaid);
  548. content = content.UrlDecode();
  549. result.rawContent = content;
  550. result.parse_type = "dp";
  551. bool IfExceptional = false;
  552. try
  553. {
  554. var config = TkConfigCore.Get();
  555. if (!string.IsNullOrEmpty(config.pdd_blacklist_regular))
  556. {
  557. var blacklist = config.pdd_blacklist_regular.Split('\n')
  558. .Where(line => !string.IsNullOrWhiteSpace(line))
  559. .ToList();
  560. bool anyMatch = false;
  561. foreach (string pattern in blacklist)
  562. {
  563. if (Regex.IsMatch(content, pattern, RegexOptions.IgnoreCase)) anyMatch = true;
  564. }
  565. if (anyMatch)
  566. {
  567. result.success = false;
  568. result.deeplink_url = string.Empty;
  569. result.message = "放弃转链";
  570. result.reason = "规则排除";
  571. _ = TkLogCore.ParseLogAsync(result);
  572. return PddParseOutput(result);
  573. }
  574. }
  575. //============================== 放弃转链-地区过滤 ==============================
  576. if (accountid == 0 && PddUnionPlus.ShouldIgnoreRequest(config, ip, oaid, out string reason))
  577. {
  578. result.success = false;
  579. result.message = "放弃转链";
  580. result.reason = reason;
  581. result.deeplink_url = PddUnionPlus.GetDeeplink(result.rawContent);
  582. _ = TkLogCore.ParseLogAsync(result);
  583. return PddParseOutput(result);
  584. }
  585. var account = PddPoolCore.GetOne(PddUnionWorkMode.All, accountid, "dp");
  586. if (account == null)
  587. {
  588. result.success = false;
  589. result.message = "放弃转链";
  590. result.reason = "没有匹配账号";
  591. result.deeplink_url = PddUnionPlus.GetDeeplink(result.rawContent);
  592. _ = TkLogCore.ParseLogAsync(result);
  593. return PddParseOutput(result);
  594. }
  595. result.accountId = account.id;
  596. result.accountName = account.name;
  597. var plus = new PddUnionPlus(account);
  598. result = await plus.PddParseAsync(content, commerceType, result, cancellationToken);
  599. }
  600. catch (Exception ex)
  601. {
  602. if (ex.Message.Contains("was canceled"))
  603. {
  604. result.success = false;
  605. result.message = "放弃转链";
  606. result.reason = "请求超时";
  607. }
  608. else
  609. {
  610. IfExceptional = true;
  611. _ = new LoggerLibrary("unionParse", "pdd_error")
  612. .Info(ip, oaid)
  613. .Info(content)
  614. .Info(ex.Message, ex.StackTrace)
  615. .SaveAsync();
  616. NotifyCore.Notify(new NifyMessage
  617. {
  618. message = $"【转链异常PDD】\n{content}\n\n{ex.Message}\n{ex.StackTrace}",
  619. priority = NifyMessagePriority.high,
  620. tags = ["red_circle"]
  621. });
  622. result.success = false;
  623. result.message = "内部错误";
  624. result.reason = "转链接口异常";
  625. }
  626. }
  627. _ = TkLogCore.ParseLogAsync(result);
  628. return PddParseOutput(result, IfExceptional ? APIResultCodeEnum.NotAcceptable : APIResultCodeEnum.OK);
  629. }
  630. private static ParseDeeplinkResust parseJdDeeplinkInput(string content)
  631. {
  632. ParseDeeplinkResust resust = new();
  633. if (!content.StartsWith("openapp.jdmobile://"))
  634. {
  635. resust.success = false;
  636. resust.reason = "不是有效DP";
  637. return resust;
  638. }
  639. try
  640. {
  641. string param = content.GetContentPart("params=", "");
  642. param = param.UrlDecode();
  643. var root = param.Convert2JsonElement();
  644. string category = root.Read("category", string.Empty);
  645. string sourceType = root.Read("sourceType", string.Empty);
  646. string skuId = root.Read("skuId", string.Empty);
  647. string url = root.Read("url", string.Empty);
  648. string des = root.Read("des", string.Empty);
  649. switch (sourceType)
  650. {
  651. case "Item":
  652. resust.url = $"https://item.jd.com/{skuId}.html";
  653. resust.success = true;
  654. return resust;
  655. }
  656. switch (category)
  657. {
  658. case "jump":
  659. switch (des)
  660. {
  661. case "getCoupon":
  662. case "union":
  663. resust.success = false;
  664. resust.reason = "其他推广链接";
  665. return resust;
  666. case "m":
  667. resust.url = url;
  668. break;
  669. case "productDetail":
  670. resust.success = true;
  671. resust.url = $"https://item.jd.com/{skuId}.html";
  672. return resust;
  673. }
  674. break;
  675. }
  676. if (string.IsNullOrEmpty(url))
  677. {
  678. resust.success = false;
  679. resust.reason = "未知链接";
  680. }
  681. string utm_campaign = resust.url.GetContentPart("utm_campaign=", "&");
  682. string utm_term = resust.url.GetContentPart("utm_term=", "&");
  683. if (url.Contains("union-click.jd.com") || url.Contains("union-activity") ||
  684. !string.IsNullOrEmpty(utm_campaign) || !string.IsNullOrEmpty(utm_term))
  685. {
  686. resust.success = false;
  687. resust.reason = "其他推广链接";
  688. return resust;
  689. }
  690. resust.success = true;
  691. return resust;
  692. }
  693. catch (Exception ex)
  694. {
  695. resust.success = false;
  696. resust.reason = "内部错误";
  697. return resust;
  698. }
  699. }
  700. private static ParseDeeplinkResust parseTaobaoDeeplinkInput(string content)
  701. {
  702. ParseDeeplinkResust resust = new();
  703. if (!content.StartsWith("taobao://") && !content.StartsWith("tbopen://") && !content.StartsWith("tmall://"))
  704. {
  705. resust.success = false;
  706. resust.reason = "不是有效DP";
  707. return resust;
  708. }
  709. if (content.Contains("ali_trackid="))
  710. {
  711. resust.success = false;
  712. resust.reason = "其他推广链接";
  713. return resust;
  714. }
  715. string itemid_pattern = "(?:pc_detail\\.itemId\\.\\d+&id=|detail\\.tmall\\.com\\/item\\.htm\\?id=)(\\d+)";
  716. var regex = new Regex(itemid_pattern);
  717. var match = regex.Match(content);
  718. if (match.Success)
  719. {
  720. string itemId = match.Groups[1].Value;
  721. string item_url = $"https://item.taobao.com/item.htm?id={itemId}";
  722. resust.success = true;
  723. resust.url = item_url;
  724. return resust;
  725. }
  726. /*
  727. * 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
  728. * 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
  729. *
  730. 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
  731. 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
  732. */
  733. string url = content.GetContentPart("h5Url=", "&");
  734. if (string.IsNullOrEmpty(url))
  735. {
  736. url = content.GetContentPart("h5Url=", "");
  737. }
  738. url = url.UrlDecode();
  739. if (string.IsNullOrEmpty(url))
  740. {
  741. resust.success = false;
  742. resust.reason = "未知链接";
  743. return resust;
  744. }
  745. if (url.Contains("s.click.taobao.com"))
  746. {
  747. resust.success = false;
  748. resust.reason = "其他推广链接";
  749. return resust;
  750. }
  751. resust.success = false;
  752. resust.reason = "未知链接";
  753. return resust;
  754. }
  755. private static string parseDeeplinkInput(string content)
  756. {
  757. if (content.StartsWith("tbopen://") || content.StartsWith("tmall://"))
  758. {
  759. string url = content.GetContentPart("h5Url=", "&");
  760. if (string.IsNullOrEmpty(url))
  761. {
  762. url = content.GetContentPart("h5Url=", "");
  763. }
  764. if (string.IsNullOrEmpty(url)) return content;
  765. content = url.UrlDecode();
  766. }
  767. if (content.StartsWith("openapp.jdmobile://"))
  768. {
  769. try
  770. {
  771. string param = content.GetContentPart("params=", "");
  772. param = param.UrlDecode();
  773. var root = param.Convert2JsonElement();
  774. string category = root.Read("category", string.Empty);
  775. string sourceType = root.Read("sourceType", string.Empty);
  776. string skuId = root.Read("skuId", string.Empty);
  777. switch (sourceType)
  778. {
  779. case "Item":
  780. string url_content = $"https://item.jd.com/{skuId}.html";
  781. return url_content;
  782. }
  783. switch (category)
  784. {
  785. case "jump":
  786. string url = root.Read("url", string.Empty);
  787. string url_content = url;
  788. return url_content;
  789. }
  790. }
  791. catch (Exception ex)
  792. {
  793. }
  794. }
  795. return content;
  796. }
  797. }
  798. }