新增隐矩sku的拉取服务

AutoTurnOver.DB/report_invest_return_dao.cs

@@ -93,6 +93,41 @@ namespace AutoTurnOver.DB
                 //}
             }
         }
+
+        public class yinjusku_dto
+        {
+            public string bailun_sku { get; set; }
+            public string sku_title_cn { get; set; }
+        }
+        // 同步隐矩的sku
+        public static void SynchYinjuSku()
+        {
+            var skus = _connection.Query<yinjusku_dto>($@" select bailun_sku,sku_title_cn from dc_base_stock where usable_stock>0  and warehouse_code in ('GZBLWH','BLGZ03') and bailun_sku not in (
+select sku from dc_report_invest_return_sku 
+) ").ToList() ;
+            foreach (var item in skus)
+            {
+                var dbSku = new dc_report_invest_return_sku
+                {
+                    create_user = "aims",
+                    gmt_create_time = DateTime.Now,
+                    gmt_update_time = DateTime.Now,
+                    project = "隐矩",
+                    sku = item.bailun_sku,
+                    sku_name = item.sku_title_cn,
+                    warehouse_type = "国内仓"
+                };
+                if(item.sku_title_cn!=null && (item.sku_title_cn.IndexOf("DE-")==0 || item.sku_title_cn.IndexOf("DE ")==0))
+                {
+                    dbSku.project = "DE";
+                }
+                dbSku.id = _connection.QueryFirstOrDefault<int?>(" select id from dc_report_invest_return_sku where sku=@sku and project=@project limit 1  ", new { sku = item.bailun_sku, project = dbSku.project }) ?? 0;
+                if (dbSku.id <= 0)
+                {
+                    _connection.Insert(dbSku);
+                }
+            }
+        }
         public static void SynchBtmAdFees()
         {
             var fees = ApiUtility.GetBtmAdFees(DateTime.Now.AddDays(-60), DateTime.Now);

ResetOutofstock/Program.cs

@@ -45,6 +45,7 @@ namespace ResetOutofstock
 
 
                 //report_invest_return_dao.SynchPpsSku();
+                //report_invest_return_dao.SynchYinjuSku();
                 // report_invest_return_dao.SynchBtmAdFees();
                 //report_invest_return_dao.ShareAdFee();
                 //report_invest_return_dao.SynchBtmOrderRefund();

ResetOutofstock/ResetOutofstockBackgrounService.cs

@@ -528,7 +528,7 @@ namespace ResetOutofstock
                    {
                        Console.WriteLine($"开始 拉取pps sku，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                        report_invest_return_dao.SynchPpsSku();
-
+                       report_invest_return_dao.SynchYinjuSku();
                        Console.WriteLine($"结束 拉取pps sku，线程Id：{Thread.CurrentThread.ManagedThreadId}，{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}");
                        Thread.Sleep(10 * 60 * 1000);
                    }