新增拉取旧数据的特性的任务

AutoTurnOver.DB/base_sku_dao.cs

@@ -112,6 +112,39 @@ order by t1.gmt_modified asc
             _connection.Update(new_task_synchro_log);
         }
 
+        /// <summary>
+        /// 同步sku特性
+        /// </summary>
+        public static void SynchroSkuCharacterSupplement()
+        {
+            
+            // 取100条
+            var datas = _connection.Query<string>($@" select bailun_sku from dc_base_sku as t1  
+where t1.character_names is null
+ limit 100  ", commandTimeout: 0).ToList();
+            if (datas.Count <= 0) { return; }
+            var character_list = CharacterAll();
+            // 查询所有sku的特性
+            var characters = ApiUtility.GetSkuCharacterBailun(datas);
+            foreach (var item in datas)
+            {
+                if (!string.IsNullOrWhiteSpace(item))
+                {
+                    var itemCharacters = characters.FirstOrDefault(s => item.Equals(s.sku, StringComparison.InvariantCultureIgnoreCase));
+                    var character_names = ((itemCharacters == null || string.IsNullOrWhiteSpace(itemCharacters.productCharacter)) ? "" : string.Join(",",
+                        itemCharacters.productCharacter.Split(',').Select(s => (character_list.FirstOrDefault(c => c.key == s) ?? new dc_base_sku_character()).name)
+                        ));
+                    _connection.Execute(" update dc_base_sku set character_names=@character_names where bailun_sku=@bailun_sku ", new
+                    {
+                        bailun_sku = item,
+                        character_names = character_names
+                    });
+
+                }
+
+            }
+        }
+
 
         /// <summary>
         /// 抓取所有特性

ResetOutofstock/Program.cs

@@ -38,6 +38,7 @@ namespace ResetOutofstock
                 //daily.ResetGmvExtendSales(now);
                 //report.ResetTransExpectArrivaltime();
                 //base_sku_dao.SynchroSkuCharacter();
+              
             }
             catch (Exception ex)
             {

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -405,6 +405,28 @@ namespace ResetOutofstock
                 }
             });
 
+             Task.Factory.StartNew(() =>
+            {
+                while (true)
+                {
+                    
+                    try
+                    {
+                        Console.WriteLine($"开始 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                        base_sku_dao.SynchroSkuCharacterSupplement();
+                        Console.WriteLine($"结束 拉取sku特性，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
+                        Thread.Sleep( 1 * 1000);
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine("拉取sku特性:" + ex.Message);
+                        Console.WriteLine("拉取sku特性:" + ex.StackTrace);
+                    }
+
+                   
+                }
+            });
+