调整 jd_spread_report 默认查询时间

molilian.api/Controllers/public/TaskController.cs

@@ -10,6 +10,7 @@ using TencentCloud.Cdwch.V20200915.Models;
 using COSXML.Network;
 using System.Security.Cryptography;
 using System.Threading;
+using TencentCloud.Batch.V20170312.Models;
 
 namespace molilian.api.Controllers
 {
@@ -565,6 +566,8 @@ namespace molilian.api.Controllers
             var jd_list = new DBContext.Table("jd_pool").Where("", null).Select<JdPoolDTO>();
             if (jd_list != null)
             {
+                DateTime startDate = DateTime.Now.AddDays(-1);
+                DateTime endDate = DateTime.Now;
                 foreach (var account in jd_list)
                 {
                     if (!account.status) continue;
@@ -578,7 +581,7 @@ namespace molilian.api.Controllers
                         try
                         {
                             var plus = new JdUnionPlus(account);
-                            _ = await plus.querySpreadEffectData(DateTime.Now.AddDays(-1));
+                            _ = await plus.querySpreadEffectData(startDate, endDate);
                             _ = await plus.queryEstimateCommList();
                         }
                         catch (Exception ex)

molilian.core/Core/taoke/TkPoolCore.cs

@@ -224,7 +224,7 @@ namespace molilian.core
                    .Add("cookies", cookies)
                    .Add("user_agent", user_agent)
                    .Add("status", status)
-                   .Add("supend_endpoint", string.Empty)
+                   .Add("suspended_endpoint", string.Empty)
                    .Add("last_time", DateTime.Now)
                    .Add("login_time", DateTime.Now)
                    .Where("id=@id", new { exist.id })

molilian.core/Plus/JDUnion/EstimateComm.cs

@@ -77,13 +77,17 @@ namespace molilian.core
                 client.UserAgent = useragent;
                 client.AddHeaders("Cookie", cookies);
                 client.Post($"body={data}");
+                DateTime stime = DateTime.Now;
                 var response = await client.RequestAsync(url, "POST", cancellationToken);
+                TimeSpan ts2 = DateTime.Now - stime;
+                string xx = ts2.TotalSeconds.ToString();
 
                 string body = response.Body();
                 var root = body.Convert2JsonElement();
                 int code = root.Read<int>("code");
                 string message = root.Read<string>("message");
                 hasNext = root.Read<bool>("hasNext", false);
+                pageNo++;
                 if (code == 200 && "success".Equals(message))
                 {
                     var list = root.ElementRead("result");
@@ -101,7 +105,14 @@ namespace molilian.core
                             var exist = new DBContext.Table("jd_estimate_comm")
                                 .Fields("id")
                                 .Get<dynamic>(filter,
-                                    new { report_date = report_date.Date, accountId = _account.id, report.unionType, report.feeType, report.platform }
+                                    new
+                                    {
+                                        report_date = report_date.Date,
+                                        accountId = _account.id,
+                                        report.unionType,
+                                        report.feeType,
+                                        report.platform
+                                    }
                                     );
 
 
@@ -122,7 +133,7 @@ namespace molilian.core
                             {
                                 update.Add("report_date", report_date.Date)
                                 .Add("create_time", DateTime.Now)
-                                .Create();
+                                .Create(DBContext.InsertType.REPLACE);
                             }
                             else
                             {
@@ -130,6 +141,7 @@ namespace molilian.core
                             }
                         }
                     }
+
                 }
                 else
                 {

molilian.core/Plus/JDUnion/SpreadEffect.cs

@@ -6,7 +6,7 @@ namespace molilian.core
 {
     public partial class JdUnionPlus
     {
-        public async Task<List<DateTime>> querySpreadEffectData(DateTime query_date, CancellationToken cancellationToken = default)
+        public async Task<List<DateTime>> querySpreadEffectData(DateTime startDate, DateTime endDate, CancellationToken cancellationToken = default)
         {
             List<DateTime> changed_dates = new List<DateTime>();
 
@@ -25,8 +25,8 @@ namespace molilian.core
                     funName = "querySpreadEffectData",
                     param = new
                     {
-                        startDate = query_date.AddMonths(-1).ToString("yyyy-MM-dd"),
-                        endDate = query_date.ToString("yyyy-MM-dd"),
+                        startDate = startDate.ToString("yyyy-MM-dd"),
+                        endDate = endDate.ToString("yyyy-MM-dd"),
                         mediaId = "",
                         proCont = "",
                         promotionId = "",
@@ -52,13 +52,19 @@ namespace molilian.core
                 client.UserAgent = useragent;
                 client.AddHeaders("Cookie", cookies);
                 client.Post($"body={data}");
+                DateTime stime = DateTime.Now;
                 var response = await client.RequestAsync(url, "POST", cancellationToken);
+                TimeSpan ts2 = stime - DateTime.Now;
+                string xx = ts2.TotalSeconds.ToString();
 
                 string body = response.Body();
                 var root = body.Convert2JsonElement();
                 int code = root.Read<int>("code");
                 string message = root.Read<string>("message");
                 hasNext = root.Read<bool>("hasNext", false);
+                pageNo++;
+
+
                 if (code == 200 && "success".Equals(message))
                 {
                     var list = root.ElementRead("result").ElementRead("spreadReportInfoChatList");
@@ -94,7 +100,7 @@ namespace molilian.core
                             {
                                 update.Add("report_date", report_date.Date)
                                 .Add("create_time", DateTime.Now)
-                                .Create();
+                                .Create(DBContext.InsertType.REPLACE);
                             }
                             else
                             {