新增listing 刷新任务

AutoTurnOver.DB/report.cs

@@ -1600,6 +1600,54 @@ truncate table dc_view_stock_monitor_sku_temp; ", commandTimeout: 0);
         }
 
         /// <summary>
+        /// 刷新数据 （高频）
+        /// </summary>
+        public static void ResetDataHighFrequency()
+        {
+            _connection.Execute(@" -- 刷新 订单 listing_status 映射表
+set session transaction isolation level read uncommitted;
+start transaction;
+
+-- 清空视图表的数据
+Truncate table dc_base_listing_status_sum_view_temp;
+
+INSERT into dc_base_listing_status_sum_view_temp(`bailun_sku`,`ebay_uk_china`,`ebay_uk_abroad`,`ebay_us_china`,`ebay_us_abroad`,`wish_us_china`,`wish_us_abroad`,`amazon_uk_china`,`amazon_uk_abroad`,`amazon_us_china`,`amazon_us_abroad`,`aliexpress_uk_china`,`aliexpress_uk_abroad`,`aliexpress_us_china`,`aliexpress_us_abroad`,`walmart_us_china`,`walmart_us_abroad`,`sears_us_china`,`sears_us_abroad`) (
+	select 
+t1.bailun_sku,
+count(case when t1.platform='ebay' and t1.localtion='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null end ) as 'ebay_uk_china',
+count(case when t1.platform='ebay' and t1.localtion!='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null  end) as 'ebay_uk_abroad',
+count(case when t1.platform='ebay' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'ebay_us_china',
+count(case when t1.platform='ebay' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'ebay_us_abroad',
+
+count(case when t1.platform='wish' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'wish_us_china',
+count(case when t1.platform='wish' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'wish_us_abroad',
+
+count(case when t1.platform='amazon' and t1.localtion='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null  end) as 'amazon_uk_china',
+count(case when t1.platform='amazon' and t1.localtion!='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null  end) as 'amazon_uk_abroad',
+count(case when t1.platform='amazon' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'amazon_us_china',
+count(case when t1.platform='amazon' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'amazon_us_abroad',
+
+count(case when t1.platform='aliexpress' and t1.localtion='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null  end) as 'aliexpress_uk_china',
+count(case when t1.platform='aliexpress' and t1.localtion!='国内' and t1.web_site='uk' and t1.`status`=1 then 1 else null  end) as 'aliexpress_uk_abroad',
+count(case when t1.platform='aliexpress' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'aliexpress_us_china',
+count(case when t1.platform='aliexpress' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'aliexpress_us_abroad',
+
+count(case when t1.platform='walmart' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'walmart_us_china',
+count(case when t1.platform='walmart' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'walmart_us_abroad',
+
+count(case when t1.platform='sears' and t1.localtion='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'sears_us_china',
+count(case when t1.platform='sears' and t1.localtion!='国内' and t1.web_site='us' and t1.`status`=1 then 1 else null  end) as 'sears_us_abroad'
+from dc_base_listing_status as t1
+GROUP BY t1.bailun_sku
+);
+
+alter table dc_base_listing_status_sum_view rename dc_base_listing_status_sum_viewTemp; 
+alter table dc_base_listing_status_sum_view_temp rename dc_base_listing_status_sum_view; 
+alter table dc_base_listing_status_sum_viewTemp rename dc_base_listing_status_sum_view_temp; 
+truncate table dc_base_listing_status_sum_view_temp;    ", commandTimeout: 0);
+        }
+
+        /// <summary>
         /// 刷新库存监控数据
         /// </summary>
         public static void ResetStockMonitorData()

AutoTurnOver.Models/dc_base_listing_status.cs

+using System;
+using System.Collections.Generic;
+using System.Text;
+
+namespace AutoTurnOver.Models
+{
+    public class dc_base_listing_status
+    {
+        public int id { get; set; }
+        public string bailun_sku { get; set; }
+        public string platform_sku { get; set; }
+        public DateTime update_date { get; set; }
+        public string platform { get; set; }
+        public string web_site { get; set; }
+        public string localtion { get; set; }
+        public int status { get; set; }
+        public DateTime sys_update_date { get; set; }
+    }
+}

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -54,6 +54,24 @@ namespace ResetOutofstock
                 }
             });
             
+            Task.Factory.StartNew(() => {
+                while (true)
+                {
+                    try
+                    {
+                        Console.WriteLine($"开始刷新 listing 数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                        report.ResetDataHighFrequency();
+                        Console.WriteLine($"结束刷新 listing 数据，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine(ex.Message);
+                    }
+
+                    Thread.Sleep(30 * 60 * 1000);
+                }
+            });
+            
             return Task.CompletedTask;
         }