切换listingv2

 /// <summary>
 /// 自动fba审核销量数据源切换为listingv2
 /// </summary>
 /// <param name="cancellation"></param>
 /// <returns></returns>
 public async Task SyncSaleNumListingV2(int Type, CancellationToken cancellation)
 {
     int customerId = (int)EnumMaster.Customer.CustomerId;
     int pageSize = 100;
     var typeName = $"SyncSaleNumListingV2_{nameof(SyncSaleNumListingV2)}";
     var maxValue = _hotColdDictionaryService.GetDictionaryValue<string>(typeName);
     while (!cancellation.IsCancellationRequested)
     {
         //获取数据
         var checkStatus = new List<int>() { (int)EnumAmazon.AutoFbaCheckStatus.未审核, (int)EnumAmazon.AutoFbaCheckStatus.暂不处理 };
         var where = new Expressionable<RB_Amazon_AutoFba_Check>();
         where.And(p => p.CustomerID == customerId);
         where.And(p => p.IsDelete == false);
         if (Type == 1)
         {
             where.And(p => checkStatus.Contains(p.CheckStatus));
         }
         else
         {
             where.And(p => !checkStatus.Contains(p.CheckStatus));
         }
         // 生成表达式
         var whereExpression = where.ToExpression();
         var list = await _amazon_AutoFba_Check_Repository.GetQueryable(whereExpression).With(SqlWith.NoLock).Where(p => p.Id > maxValue.ToLong()).OrderBy(p => p.Id).ToPageListAsync(1, pageSize);
         //数据为空重置同步记录，跳出循环
         if (!list.Any())
         {
             _hotColdDictionaryService.Save(new HotColdDictionary()
             {
                 TypeName = typeName,
                 Value = string.Empty,
                 UpdateTime = DateTime.Now
             });
             break;
         }

         //获取下次查询的最大id
         maxValue = list.Max(p => p.Id).ToString();

         //获取listingV2的明细
         var listingV2Result = GetListingResult(list);

         //循环获取销量数据
         List<RB_Amazon_AutoFba_Check> AutoFbaCheckList = new List<RB_Amazon_AutoFba_Check>();
         foreach (var item in list)
         {
             var currentListingV2Result = listingV2Result.FirstOrDefault(o => o.SourceId == item.OrderSourceID && o.MSKU == item.OrderSourceSKU);
             if (currentListingV2Result == null)
             {
                 _logger.LogInformation($"来源渠道:{item.OrderSourceID},渠道sku:{item.OrderSourceSKU},获取不到listingV2数据");
                 continue;
             }

             if (currentListingV2Result.Sale is { SaleDay7: null, SaleDay14: null, SaleDay30: null, SaleDay90: null })
             {
                 _logger.LogInformation($"来源渠道:{item.OrderSourceID},渠道sku:{item.OrderSourceSKU},销量数据为空");
                 continue;
             }
             item.SaleNumWeek1 = currentListingV2Result.Sale.SaleDay7 ?? 0;
             item.SaleNumWeek2 = currentListingV2Result.Sale.SaleDay14 ?? 0;
             item.SaleNumDay30 = currentListingV2Result.Sale.SaleDay30 ?? 0;
             item.SaleNumDay90 = currentListingV2Result.Sale.SaleDay90 ?? 0;
             AutoFbaCheckList.Add(item);
         }


         //更新数据
         if (AutoFbaCheckList.Count > 0)
         {
             await _amazon_AutoFba_Check_Repository.UpdateAsync(AutoFbaCheckList, a => new { a.Id }, a => new
             {
                 a.SaleNumWeek1,
                 a.SaleNumWeek2,
                 a.SaleNumDay30,
                 a.SaleNumDay90,
             });
         }

         //获取下次查询的最大id
         _hotColdDictionaryService.Save(new HotColdDictionary()
         {
             TypeName = typeName,
             Value = maxValue,
             UpdateTime = DateTime.Now
         });
     }
 }

2 取消原来同步得代码