using dodohold.core; using System.Diagnostics; using System.Text.Json; namespace molilian.core { public partial class AlimamaPlus { public async Task endpoint_tool_links(string content, TkDataDTO result, CancellationToken cancellationToken = default) { string t = $"{DateTime.Now.Convert2UnixTimestamp(true)}"; Random random = new(); double randomNumber = random.NextDouble(); string randomString = randomNumber.ToString()[2..]; string cna = _cookies.GetContentPart("cna=", ";"); string firstFiveCharacters = cna[..Math.Min(5, cna.Length)]; var variableMap = new { url = content, union_lens = $"b_pvid:a219t._portal_v2_home_plus_index_htm_{t}_{randomString}_{firstFiveCharacters}_mmWuH", lensScene = "PUB", spmB = "_portal_v2_tool_links_page_home_index_htm" }.Convert2Json(true).UrlEncode(); variableMap = variableMap.Replace(" ", "%20"); _floorId = "61446"; string url = "https://pub.alimama.com/openapi/param2/1/gateway.unionpub/xt.entry.json?" + $"t={t}&_tb_token_={_tb_token}&floorId={_floorId}&refpid={_refpid}&variableMap={variableMap}"; Stopwatch stopwatch = Stopwatch.StartNew(); stopwatch.Start(); var client = new WebClientUtility().SetContentType("application/json;charset=utf-8") .AddHeaders("X-Requested-With", "XMLHttpRequest") .AddHeaders("Cookie", _cookies); client.Proxy = _proxy; #if DEBUG client.Proxy = null; #endif if (!string.IsNullOrEmpty(_user_agent)) client.UserAgent = _user_agent; client.Timeout = GetRequestTimeout2(result.elapsedTime2); //var response = client.Request(url); #if DEBUG var response = await client.RequestAsync(url, "GET"); #else var response = await client.RequestAsync(url, "GET", cancellationToken); #endif stopwatch.Stop(); result.elapsedTime3 = (int)stopwatch.ElapsedMilliseconds; var body = string.Empty; try { if (!response.Successed) { result.channel = TkChannelEnum.tb; result.link_type = LinkTypeEnum.unknown; result.success = false; result.message = "fail"; if (response.ResponseException != null) { _ = new LoggerLibrary("api_error", "fail") .Info(response.ResponseException.Message, response.ResponseException.StackTrace) .SaveAsync(); throw response.ResponseException; } return result; } if (response.ResponseMessage.StatusCode == System.Net.HttpStatusCode.Found) { _ = new LoggerLibrary("api_error", "fail") .Info($"302:{response.ResponseMessage.Headers.Location}") .SaveAsync(); throw new Exception("302 Found, was canceled"); } JsonElement root; try { body = response.Body(); root = body.Convert2JsonElement(); } catch (Exception ex) { _ = new LoggerLibrary("api_error", "fail") .Info(ex.Message, ex.StackTrace) .SaveAsync(); if (body.Contains("https://g.alicdn.com/sd/punish/waf_block.html")) { await TkEndpointManager.SuspendAsync(_accountId, "tool_links", TkEndpointManager.SuspendReason.Passive); result.channel = TkChannelEnum.tb; result.link_type = LinkTypeEnum.unknown; result.success = false; result.message = "waf_block"; return result; } if (body.Contains("https://bixi.alicdn.com") && body.Contains("\"action\": \"deny\"")) { await TkEndpointManager.SuspendAsync(_accountId, "tool_links", TkEndpointManager.SuspendReason.Passive); result.channel = TkChannelEnum.tb; result.link_type = LinkTypeEnum.unknown; result.subCode = TkSubCodeEnum.ParseDeny; result.success = false; result.message = "waf_block"; result.reason = "接口风控"; return result; } throw new Exception(body); } if (body.Contains("https://bixi.alicdn.com") && body.Contains("\"action\": \"deny\"")) { await TkEndpointManager.SuspendAsync(_accountId, "tool_links", TkEndpointManager.SuspendReason.Passive); result.channel = TkChannelEnum.tb; result.link_type = LinkTypeEnum.unknown; result.subCode = TkSubCodeEnum.ParseDeny; result.success = false; result.message = "waf_block"; result.reason = "接口风控"; return result; } bool success = root.Read("success", false); string message = root.Read("message", string.Empty); string info_message = root.PathRead("info.message", string.Empty); if (!string.IsNullOrEmpty(info_message)) message = info_message; string taoToken = root.PathRead("data.taoToken", string.Empty); string shortLinkurl = root.PathRead("data.shortLinkurl", string.Empty); string couponLinkTaoToken = root.PathRead("data.couponLinkTaoToken", string.Empty); string couponShortLinkUrl = root.PathRead("data.couponShortLinkUrl", string.Empty); decimal couponAmount = root.PathRead("data.couponAmount", 0); string couponEffectiveEndTime = root.PathRead("data.couponEffectiveEndTime", string.Empty); string couponEffectiveStartTime = root.PathRead("data.couponEffectiveStartTime", string.Empty); string itemId = root.PathRead("data.itemId", string.Empty); string mktId = root.PathRead("data.outputMktId", string.Empty); string itemName = root.PathRead("data.itemName", string.Empty); decimal promotionPrice = root.PathRead("data.promotionPrice", 0); string sellerNickName = root.PathRead("data.sellerNickName", string.Empty); string shopTitle = root.PathRead("data.shopTitle", string.Empty); string pic = root.PathRead("data.pic", string.Empty); if (pic.StartsWith("//")) pic = "https:" + pic; string qrCodeUrl = root.PathRead("data.qrCodeUrl", string.Empty); if (response.ResponseMessage != null) { switch (response.ResponseMessage.StatusCode) { case System.Net.HttpStatusCode.OK: { if (couponAmount > 0 && !string.IsNullOrEmpty(couponLinkTaoToken) && !string.IsNullOrEmpty(couponShortLinkUrl)) { taoToken = couponLinkTaoToken; shortLinkurl = couponShortLinkUrl; } string shortLink = GetLink(taoToken); content = ReplaceUrls(content, shortLink); } break; case System.Net.HttpStatusCode.Found: string location = response.ResponseMessage.Headers.Location.OriginalString; if (!string.IsNullOrEmpty(location) && location.Contains("www.alimama.com/member/login.htm")) { success = false; message = "nologin"; } break; default: { success = false; message = "other"; } break; } } if (!success) { shortLinkurl = GetLink(content); switch (message) { case "该商品已经下架或未加入淘宝客": case "该链接不支持转化，请更换链接尝试": result.subCode = TkSubCodeEnum.NoConvert; break; case "网络错误": result.subCode = TkSubCodeEnum.NetError; break; default: var _headers = response.ResponseMessage.Headers; var headers = ""; foreach (var h in _headers) { foreach (var Value in h.Value) { headers += $"{h.Key}: {Value}\n"; } } _ = new LoggerLibrary("api_error", "fail") .Info(message, content) .Info(headers, body) .SaveAsync(); break; } } shortLinkurl = GetLink(taoToken); string deeplink_url = GetDeeplink(shortLinkurl); result.channel = TkChannelEnum.tb; if (success) { result.subCode = TkSubCodeEnum.Success; switch (result.link_type) { case LinkTypeEnum.profile: case LinkTypeEnum.goods: case LinkTypeEnum.video: case LinkTypeEnum.live: break; default: result.link_type = LinkTypeEnum.goods; break; } } result.success = success; result.message = message; result.reason = string.Empty; result.content = content; result.couponAmount = couponAmount; result.couponEffectiveEndTime = couponEffectiveEndTime; result.couponEffectiveStartTime = couponEffectiveStartTime; result.taoToken = taoToken; if (!string.IsNullOrEmpty(shortLinkurl)) { result.shortLinkurl = shortLinkurl; result.deeplink_url = deeplink_url; } result.mktId = mktId; result.itemId = itemId; result.itemName = itemName; result.promotionPrice = promotionPrice; result.sellerNickName = sellerNickName; result.shopTitle = shopTitle; result.pic = pic; result.qrCodeUrl = qrCodeUrl; } catch (Exception ex) { if (response.ResponseMessage?.StatusCode == System.Net.HttpStatusCode.OK) { if (body.Contains("

抱歉！页面无法访问……

")) { throw new APIException("抱歉！页面无法访问……"); } } throw; } return result; } } }