From 4d7fd2c157292999fe0910f00c470ed0ab2963ec Mon Sep 17 00:00:00 2001 From: wule Date: Wed, 21 Oct 2026 11:59:12 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8B=BC=E5=A4=9A=E5=A4=9A=E4=B9=B0=E6=89=8B?= =?UTF-8?q?=E8=AF=BB=E5=8D=95=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../BuyerCtrls/PDDBuyerOrderReadCtrl.xaml.cs | 359 +++++++++--------- 1 file changed, 172 insertions(+), 187 deletions(-) diff --git a/29WxOrderWpf/Ctrls/BuyerCtrls/PDDBuyerOrderReadCtrl.xaml.cs b/29WxOrderWpf/Ctrls/BuyerCtrls/PDDBuyerOrderReadCtrl.xaml.cs index 21055a9..cd2a8a2 100644 --- a/29WxOrderWpf/Ctrls/BuyerCtrls/PDDBuyerOrderReadCtrl.xaml.cs +++ b/29WxOrderWpf/Ctrls/BuyerCtrls/PDDBuyerOrderReadCtrl.xaml.cs @@ -86,6 +86,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls } Dictionary dicPddAftersaleNextQueryCreatedAt = new Dictionary(); + Dictionary dicPddOrderOffset = new Dictionary(); Dictionary dicPddPickInfo = new Dictionary(); ConcurrentList lstSyncLogistics = new ConcurrentList(); @@ -753,8 +754,11 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls var list = JsonHelper.DeserializeJsonToList(JsonHelper.JObjectParse(data)["orders"].ParseToString()); - // 提取拼多多外采订单列表 - var out_order_nos = string.Join(",", list.Select(bo => bo.order_sn)); + if (list.Count > 0) + dicPddOrderOffset[buyer] = list.LastOrDefault().order_sn; + + // 提取拼多多外采订单列表 + var out_order_nos = string.Join(",", list.Select(bo => bo.order_sn)); if (out_order_nos.Contains("260817-535832839751006")) { @@ -1502,8 +1506,12 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls async Task GetOrderAndAfterSale() { - await JsGetPddOrder(); - //ScrollGetPddOrder(); + bool isScroll = false; + if (isScroll == false) + await JsGetPddOrder(); + else + ScrollGetPddOrder(); + //MakeWxToPddAfterSales(); nextGetOrderTime = DateTime.Now.AddMinutes(25); @@ -1528,7 +1536,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls { if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(null, "已取消读取"); + ShowBuyerOrderReadInfo(null, "已取消读取"); break; } Thread.Sleep(500); @@ -1588,181 +1596,43 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls buyer.wpf_browser.Load("https://mobile.yangkeduo.com/psnl_goods_help.html?_t_module_name=assistant_search&refer_scene=no_pickup_package_express&refer_page_name=goods_express"); Thread.Sleep(Randomx.GetId(2000, 3000)); - string readBuyer = ""; - int top = 0; - int times = 0; - #region 售后 if (1 == 1) { - await JsGetPddAftersaleOrder(buyer, tokenSource); - if (tokenSource.IsCancellationRequested) - { - BindBuyerOrderReadInfo(buyer, "已取消读取"); - break; - } + await JsGetPddAftersale(buyer, tokenSource); + + if (buyer.status != "在线") { continue; } + if (isSkipNext) { isSkipNext = false; continue; } + if (tokenSource.IsCancellationRequested) { ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } + Thread.Sleep(Randomx.GetId(2000, 3000)); } #endregion #region 待发货 - readBuyer = buyer.buyer_id; - currentReadBuyer = buyer.buyer_id; - buyer.wpf_browser.Load("https://mobile.yangkeduo.com/orders.html?type=2"); - - BindBuyerOrderReadInfo(buyer, "正在读取待发货"); - - Dispatcher.Invoke(new Action(() => + if (2 == 2) { - Panel.SetZIndex(buyer.wpf_browser, maxZIndex++); - if (buyer.IsSelect != true) - { - foreach (var b in GlobalConfig.PDDBuyerLoginList) - { - b.IsSelect = false; - } - buyer.IsSelect = true; - } - })); - Thread.Sleep(Randomx.GetId(2000, 3000)); + await JsGetPddOrder(buyer, 2, tokenSource); - top = 0; - lastCefReadOrderTime = DateTime.Now; - while (currentReadBuyer == readBuyer) - { - if (isSkipNext) - break; + if (buyer.status != "在线") { continue; } + if (isSkipNext) { isSkipNext = false; continue; } + if (tokenSource.IsCancellationRequested) { ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } - if (tokenSource.IsCancellationRequested) - { - BindBuyerOrderReadInfo(buyer, "已取消读取"); - break; - } - - if (lastCefReadOrderTime < DateTime.Now.AddSeconds(-30)) - { - PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); - if (buyer.status != "在线") - { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); - break; - } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); - break; - } - - if (times % 100 == 0) - { - PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); - } - if (buyer.status != "在线") - break; - times++; - - top += Randomx.GetId(450, 600); - Thread.Sleep(Randomx.GetId(100, 300)); - - var jsStr = @"window.scroll({ - top: " + top + @", - left: 0, - behavior: 'smooth' // 可选，使滚动平滑 - });"; - //var t1 = cefWebBrowser.GetMainFrame().EvaluateScriptAsync(jsStr); - //t1.Wait(1000); - var client = buyer.wpf_browser.GetDevToolsClient(); - if (client != null) - { - var result = client.Runtime.EvaluateAsync(jsStr, null, true, null, null, true, null, true); - result.Wait(5000); - } + Thread.Sleep(Randomx.GetId(2000, 3000)); } - if (isSkipNext) - { - isSkipNext = false; - continue; - } - if (tokenSource.IsCancellationRequested) - { - BindBuyerOrderReadInfo(buyer, "已取消读取"); - break; - } - Thread.Sleep(Randomx.GetId(2000, 3000)); #endregion #region 已发货 - readBuyer = buyer.buyer_id; - currentReadBuyer = buyer.buyer_id; - buyer.wpf_browser.Load("https://mobile.yangkeduo.com/orders.html?type=3"); - - BindBuyerOrderReadInfo(buyer, "正在读取已发货"); - - Dispatcher.Invoke(new Action(() => + if (3 == 3) { - Panel.SetZIndex(buyer.wpf_browser, maxZIndex++); - if (buyer.IsSelect != true) - { - foreach (var b in GlobalConfig.PDDBuyerLoginList) - { - b.IsSelect = false; - } - buyer.IsSelect = true; - } - })); - Thread.Sleep(Randomx.GetId(2000, 3000)); + await JsGetPddOrder(buyer, 3, tokenSource); - top = 0; - lastCefReadOrderTime = DateTime.Now; - while (currentReadBuyer == readBuyer) - { - if (isSkipNext) - break; + if (buyer.status != "在线") { continue; } + if (isSkipNext) { isSkipNext = false; continue; } + if (tokenSource.IsCancellationRequested) { ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } - if (tokenSource.IsCancellationRequested) - { - BindBuyerOrderReadInfo(buyer, "已取消读取"); - break; - } - - if (lastCefReadOrderTime < DateTime.Now.AddSeconds(-30)) - { - PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); - if (buyer.status != "在线") - { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); - break; - } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); - break; - } - - top += Randomx.GetId(450, 600); - Thread.Sleep(Randomx.GetId(100, 300)); - - var jsStr = @"window.scroll({ - top: " + top + @", - left: 0, - behavior: 'smooth' // 可选，使滚动平滑 - });"; - //var t1 = cefWebBrowser.GetMainFrame().EvaluateScriptAsync(jsStr); - //t1.Wait(1000); - var client = buyer.wpf_browser.GetDevToolsClient(); - if (client != null) - { - var result = client.Runtime.EvaluateAsync(jsStr, null, true, null, null, true, null, true); - result.Wait(5000); - } + Thread.Sleep(Randomx.GetId(2000, 3000)); } - if (isSkipNext) - { - isSkipNext = false; - continue; - } - if (tokenSource.IsCancellationRequested) - { - BindBuyerOrderReadInfo(buyer, "已取消读取"); - break; - } - Thread.Sleep(Randomx.GetId(2000, 3000)); #endregion } catch (Exception ex) @@ -1777,9 +1647,21 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls } isReadBuyerOrder = false; - BindBuyerOrderReadInfo(null, "订单读取已结束，等待下次读取"); + ShowBuyerOrderReadInfo(null, "订单读取已结束，等待下次读取"); }, cancellationTokenSource.Token); } + public async Task IsInstalledAsync(IFrame frame, int timeoutMs = 3000) + { + var deadline = DateTime.Now.AddMilliseconds(timeoutMs); + while (DateTime.Now < deadline) + { + var r = await frame.EvaluateScriptAsync("!!(window.PDDOrders && window.PDDOrders.__installed)") + .ConfigureAwait(false); + if (r != null && r.Success && r.Result is bool && (bool)r.Result) return true; + await Task.Delay(100).ConfigureAwait(false); + } + return false; + } public static async Task IsAftersaleJsInstalledAsync(IFrame frame, int timeoutMs = 3000) { @@ -1794,13 +1676,113 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls return false; } - async Task JsGetPddAftersaleOrder(BuyerLoginInfo buyer, CancellationTokenSource tokenSource) + /// + /// + /// + /// 2待发货 3已发货 + /// + async Task JsGetPddOrder(BuyerLoginInfo buyer, int type, CancellationTokenSource tokenSource) + { + var readBuyer = buyer.buyer_id; + currentReadBuyer = buyer.buyer_id; + buyer.wpf_browser.Load("https://mobile.yangkeduo.com/orders.html?type=" + type); + + if (type == 2) + ShowBuyerOrderReadInfo(buyer, "正在读取待发货"); + else if (type == 3) + ShowBuyerOrderReadInfo(buyer, "正在读取已发货"); + else + ShowBuyerOrderReadInfo(buyer, "正在读取订单"); + + Dispatcher.Invoke(new Action(() => + { + Panel.SetZIndex(buyer.wpf_browser, maxZIndex++); + if (buyer.IsSelect != true) + { + foreach (var b in GlobalConfig.PDDBuyerLoginList.ToList()) + { + b.IsSelect = false; + } + buyer.IsSelect = true; + } + })); + Thread.Sleep(Randomx.GetId(2000, 3000)); + + var client = buyer.wpf_browser.GetDevToolsClient(); + if (client == null) + return; + + // 注入触发翻滚的js事件 + string address = ""; + Dispatcher.Invoke(() => { address = buyer.wpf_browser.Address; }); + if (address.StartsWith("https://mobile.yangkeduo.com/orders.html?type=")) + { + string content = ResourceHelper.GetResourceText("/Ctrls/PDDInvoice/Resources/order.js", "29WxFindOrder"); + if (string.IsNullOrEmpty(content)) + return; + await client.Runtime.EvaluateAsync(content, null, true, null, null, true, null, true); + + var frame = cefWebBrowser.GetMainFrame(); + if (await IsInstalledAsync(frame) != true) + { + ShowBuyerOrderReadInfo(buyer, "订单读取预加载失败！"); + return; + } + } + + lastCefReadOrderTime = DateTime.Now; + string tempOffset = ""; + while (currentReadBuyer == readBuyer) + { + if (isSkipNext) + { + ShowBuyerOrderReadInfo(buyer, "已跳过当前买手订单读取"); + break; + } + + if (tokenSource.IsCancellationRequested) + { + ShowBuyerOrderReadInfo(buyer, "已取消读取"); + break; + } + + if (lastCefReadOrderTime < DateTime.Now.AddSeconds(-30)) + { + PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); + if (buyer.status != "在线") + { + ShowBuyerOrderReadInfo(buyer, "店铺掉线"); + break; + } + ShowBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); + break; + } + + if (!dicPddOrderOffset.ContainsKey(buyer)) + dicPddOrderOffset[buyer] = "0"; + if (dicPddOrderOffset[buyer] == tempOffset) + { + await Task.Delay(500); + continue; + } + else + { + } + tempOffset = dicPddOrderOffset[buyer]; + + string jsStr = $"PDDOrders.trigger({{offset:'MO-01-{dicPddOrderOffset[buyer]}',type:{type},size:10,mode:'store'}})"; + await client.Runtime.EvaluateAsync(jsStr, null, true, null, null, true, null, true); + await Task.Delay(Randomx.GetId(2000, 4000)); + } + } + + async Task JsGetPddAftersale(BuyerLoginInfo buyer, CancellationTokenSource tokenSource) { var readBuyer = buyer.buyer_id; currentReadBuyer = buyer.buyer_id; buyer.wpf_browser.Load("https://mobile.yangkeduo.com/complaint_list.html?refer_page_name=personal&refer_page_sn=10001&tab=all"); - BindBuyerOrderReadInfo(buyer, "正在读取售后"); + ShowBuyerOrderReadInfo(buyer, "正在读取售后"); Dispatcher.Invoke(new Action(() => { @@ -1833,7 +1815,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls var frame = cefWebBrowser.GetMainFrame(); if (await IsAftersaleJsInstalledAsync(frame) != true) { - BindBuyerOrderReadInfo(buyer, "售后单读取预加载失败！"); + ShowBuyerOrderReadInfo(buyer, "售后单读取预加载失败！"); return; } } @@ -1843,11 +1825,14 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls while (currentReadBuyer == readBuyer) { if (isSkipNext) + { + ShowBuyerOrderReadInfo(buyer, "已跳过当前买手售后读取"); break; + } if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } @@ -1856,10 +1841,10 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); if (buyer.status != "在线") { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); + ShowBuyerOrderReadInfo(buyer, "店铺掉线"); break; } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); + ShowBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); break; } @@ -1879,7 +1864,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls //string jsStr = $"PDDOrders.trigger({{offset:'MO-01-{lastOrderSN}',type:0,size:10,mode:'store'}})"; string jsStr = "PDAfterSale.trigger({cursor:'" + dicPddAftersaleNextQueryCreatedAt[buyer] + "',tab:'all'})"; await client.Runtime.EvaluateAsync(jsStr, null, true, null, null, true, null, true); - await Task.Delay(Randomx.GetId(1000, 3000)); + await Task.Delay(Randomx.GetId(2000, 4000)); } } @@ -1899,7 +1884,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls { if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(null, "已取消读取"); + ShowBuyerOrderReadInfo(null, "已取消读取"); break; } Thread.Sleep(500); @@ -1984,7 +1969,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls Thread.Sleep(Randomx.GetId(2000, 3000)); Dispatcher.Invoke(new Action(() => { MainWindow.Instance.Title = buyer.buyer_nick + " 售后读取中"; })); - BindBuyerOrderReadInfo(buyer, "正在读取售后"); + ShowBuyerOrderReadInfo(buyer, "正在读取售后"); top = 0; times = 0; @@ -1996,7 +1981,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } @@ -2005,10 +1990,10 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); if (buyer.status != "在线") { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); + ShowBuyerOrderReadInfo(buyer, "店铺掉线"); break; } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); + ShowBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); break; } @@ -2036,7 +2021,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls } if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } Thread.Sleep(Randomx.GetId(2000, 3000)); @@ -2064,7 +2049,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls Thread.Sleep(Randomx.GetId(2000, 3000)); Dispatcher.Invoke(new Action(() => { MainWindow.Instance.Title = buyer.buyer_nick + " 待发货读取中"; })); - BindBuyerOrderReadInfo(buyer, "正在读取待发货"); + ShowBuyerOrderReadInfo(buyer, "正在读取待发货"); top = 0; lastCefReadOrderTime = DateTime.Now; @@ -2075,7 +2060,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } @@ -2084,10 +2069,10 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); if (buyer.status != "在线") { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); + ShowBuyerOrderReadInfo(buyer, "店铺掉线"); break; } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); + ShowBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); break; } @@ -2128,13 +2113,13 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls } if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } Thread.Sleep(Randomx.GetId(2000, 3000)); Dispatcher.Invoke(new Action(() => { MainWindow.Instance.Title = buyer.buyer_nick + " 已发货读取中"; })); - BindBuyerOrderReadInfo(buyer, "正在读取已发货"); + ShowBuyerOrderReadInfo(buyer, "正在读取已发货"); // 已发货 readBuyer = buyer.buyer_id; @@ -2165,7 +2150,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } @@ -2174,10 +2159,10 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls PddMobileLoginViewModel.CheckBuyerLogin(new List() { buyer }); if (buyer.status != "在线") { - BindBuyerOrderReadInfo(buyer, "店铺掉线"); + ShowBuyerOrderReadInfo(buyer, "店铺掉线"); break; } - BindBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); + ShowBuyerOrderReadInfo(buyer, "停滞时间超过30秒，跳过"); break; } @@ -2210,7 +2195,7 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls } if (tokenSource.IsCancellationRequested) { - BindBuyerOrderReadInfo(buyer, "已取消读取"); + ShowBuyerOrderReadInfo(buyer, "已取消读取"); break; } } @@ -2227,11 +2212,11 @@ namespace _29WxOrderWpf.Ctrls.BuyerCtrls isReadBuyerOrder = false; Dispatcher.Invoke(new Action(() => { MainWindow.Instance.Title = "订单读取已结束，等待下次读取"; })); - BindBuyerOrderReadInfo(null, "订单读取已结束，等待下次读取"); + ShowBuyerOrderReadInfo(null, "订单读取已结束，等待下次读取"); }, cancellationTokenSource.Token); } - private void BindBuyerOrderReadInfo(BuyerLoginInfo buyer, string msg = "", List selectIds = null) + private void ShowBuyerOrderReadInfo(BuyerLoginInfo buyer, string msg = "", List selectIds = null) { this.LblMsgStr = buyer?.buyer_name + " " + msg + " " + DateTime.Now.ToString("yyMMdd HH:mm:ss"); }