Browse Source

单元维度

qianyi
shanji 3 years ago
parent
commit
fbdd0463b4
  1. 21
      BBWY.Server.Business/Sync/JD/JDPopularizeReportFormAdGroupLevelSyncBusiness.cs
  2. 4
      BBWY.Test/Program.cs

21
BBWY.Server.Business/Sync/JD/JDPopularizeReportFormAdGroupLevelSyncBusiness.cs

@ -46,7 +46,7 @@ namespace BBWY.Server.Business.Sync
private void DeleteOldData(IList<ShopResponse> shops, DateTime startDate, DateTime endDate) private void DeleteOldData(IList<ShopResponse> shops, DateTime startDate, DateTime endDate)
{ {
var shopIds = shops.Select(s => Convert.ToInt64(s.ShopId)).ToList(); var shopIds = shops.Select(s => Convert.ToInt64(s.ShopId)).ToList();
fsql.Delete<JDPopularizeAdSku>().Where(s => shopIds.Contains(s.ShopId.Value) && fsql.Delete<JDPopularizeAdGroup>().Where(s => shopIds.Contains(s.ShopId.Value) &&
s.Date >= startDate && s.Date <= endDate && s.Date >= startDate && s.Date <= endDate &&
s.BusinessType == 2).ExecuteAffrows(); s.BusinessType == 2).ExecuteAffrows();
} }
@ -111,11 +111,11 @@ namespace BBWY.Server.Business.Sync
Business = 2 Business = 2
}, null, HttpMethod.Post); }, null, HttpMethod.Post);
if (httpResult.StatusCode != System.Net.HttpStatusCode.OK) if (httpResult.StatusCode != System.Net.HttpStatusCode.OK)
throw new Exception($"获取JD推广报表-创意维度失败 {httpResult.Content}"); throw new Exception($"获取JD推广报表-单元维度失败 {httpResult.Content}");
var presponse = JsonConvert.DeserializeObject<ApiResponse<JArray>>(httpResult.Content); var presponse = JsonConvert.DeserializeObject<ApiResponse<JArray>>(httpResult.Content);
if (!presponse.Success) if (!presponse.Success)
throw new Exception($"获取JD推广报表-创意维度失败 {presponse.Msg}"); throw new Exception($"获取JD推广报表-单元维度失败 {presponse.Msg}");
SyncShopPopularizeReportFormAdGroupLevel(long.Parse(shop.ShopId), presponse.Data); SyncShopPopularizeReportFormAdGroupLevel(long.Parse(shop.ShopId), presponse.Data);
currentCount = presponse.Data?.Count() ?? 0; currentCount = presponse.Data?.Count() ?? 0;
@ -131,15 +131,10 @@ namespace BBWY.Server.Business.Sync
{ {
if (jArray == null || !jArray.HasValues) if (jArray == null || !jArray.HasValues)
return; return;
var insertList = new List<JDPopularizeAdSku>(); var insertList = new List<JDPopularizeAdGroup>();
foreach (var j in jArray) foreach (var j in jArray)
{ {
var adName = j.Value<string>("adName"); insertList.Add(new JDPopularizeAdGroup()
var skuMatch = Regex.Match(adName, @"^(.*-)?(\d+)-(.*)$");
if (!skuMatch.Success)
continue;
var sku = skuMatch.Groups[2].Value;
insertList.Add(new JDPopularizeAdSku()
{ {
Id = idGenerator.NewLong(), Id = idGenerator.NewLong(),
BusinessType = 2, BusinessType = 2,
@ -147,15 +142,13 @@ namespace BBWY.Server.Business.Sync
CreateTime = DateTime.Now, CreateTime = DateTime.Now,
CampaignId = j.Value<long>("campaignId"), CampaignId = j.Value<long>("campaignId"),
AdGroupId = j.Value<long>("adGroupId"), AdGroupId = j.Value<long>("adGroupId"),
AdId = j.Value<long>("adId"), AdGroupName = j.Value<string>("adGroupName"),
AdName = adName,
Date = DateTime.ParseExact(j.Value<string>("date"), "yyyyMMdd", System.Globalization.CultureInfo.CurrentCulture), Date = DateTime.ParseExact(j.Value<string>("date"), "yyyyMMdd", System.Globalization.CultureInfo.CurrentCulture),
Cost = j["retrievalType0"].Value<decimal>("cost"), Cost = j["retrievalType0"].Value<decimal>("cost"),
Clicks = j["retrievalType0"].Value<int?>("clicks") ?? 0, Clicks = j["retrievalType0"].Value<int?>("clicks") ?? 0,
Impressions = j["retrievalType0"].Value<int?>("impressions") ?? 0, Impressions = j["retrievalType0"].Value<int?>("impressions") ?? 0,
TotalCartCnt = j["retrievalType0"].Value<int?>("totalCartCnt") ?? 0, TotalCartCnt = j["retrievalType0"].Value<int?>("totalCartCnt") ?? 0,
TotalOrderCnt = j["retrievalType0"].Value<int?>("totalOrderCnt") ?? 0, TotalOrderCnt = j["retrievalType0"].Value<int?>("totalOrderCnt") ?? 0
Sku = sku
}); });
} }
if (insertList.Count > 0) if (insertList.Count > 0)

4
BBWY.Test/Program.cs

@ -30,12 +30,12 @@ namespace BBWY.Test
IJdClient client = GetJdClient(appkey, appSecret); IJdClient client = GetJdClient(appkey, appSecret);
var test1 = new JDBaoBiaoAPITest(); var test1 = new JDBaoBiaoAPITest();
//test1.Test1(client, token); test1.Test(client, token);
Console.WriteLine(); Console.WriteLine();
Console.WriteLine(); Console.WriteLine();
test1.Test2(client, token); //test1.Test2(client, token);
Console.ReadKey(); Console.ReadKey();
} }

Loading…
Cancel
Save