Commit 9e5181d5 by jianshuqin

新增功能:新开了3个站点shopify的广告费

parent 6e5a61a6
......@@ -13,7 +13,12 @@ namespace Bailun.DC.SyncShopifyFee
public class Services : BackgroundService
{
string url = "http://scrm.bailuntec.com/ScrmApi/api/ApiGetAdFeeLog"; //?btime=2021-10-01&etime=2021-10-03&page=1&rows=100
IList<string> listUrl = new string[] {
"http://scrm.bailuntec.com/ScrmApi/api/ApiGetAdFeeLog", //?btime=2021-10-01&etime=2021-10-03&page=1&rows=100
"http://us.btm.bailuntec.com/ScrmApi/api/ApiGetAdFeeLog", //?btime=2021-10-01&etime=2021-10-03&page=1&rows=100
"http://us2.btm.bailuntec.com/ScrmApi/api/ApiGetAdFeeLog", //?btime=2021-10-01&etime=2021-10-03&page=1&rows=100
"http://au.btm.bailuntec.com/ScrmApi/api/ApiGetAdFeeLog" //?btime=2021-10-01&etime=2021-10-03&page=1&rows=100
};
private Timer _timer;
......@@ -46,40 +51,43 @@ namespace Bailun.DC.SyncShopifyFee
public void Init(DateTime? btime = null, DateTime? etime = null)
{
var page = 1;
var pagesize = 1000;
var count = 0;
if (!btime.HasValue)
{
btime = DateTime.Now.AddHours(-2);
}
if (!etime.HasValue)
foreach (string url in listUrl)
{
etime = DateTime.Today.AddDays(1);
}
var page = 1;
var pagesize = 1000;
var count = 0;
while (page == 1 || (page > 1 && count > 0))
{
try
if (!btime.HasValue)
{
btime = DateTime.Now.AddHours(-2);
}
if (!etime.HasValue)
{
var result = Common.HttpHelper.NetHelper.Request($"{url}?btime={btime.Value.ToString("yyyy-MM-dd HH:00:00")}&etime={etime.Value.ToString("yyyy-MM-dd")}&page={page}&rows={pagesize}");
if (!string.IsNullOrEmpty(result))
etime = DateTime.Today.AddDays(1);
}
while (page == 1 || (page > 1 && count > 0))
{
try
{
var json = JsonConvert.DeserializeObject<response_result>(result);
count = json.data.Count;
if (json.success && count > 0)
var result = Common.HttpHelper.NetHelper.Request($"{url}?btime={btime.Value.ToString("yyyy-MM-dd HH:00:00")}&etime={etime.Value.ToString("yyyy-MM-dd")}&page={page}&rows={pagesize}");
if (!string.IsNullOrEmpty(result))
{
//保存数据
Save(json.data);
var json = JsonConvert.DeserializeObject<response_result>(result);
count = json.data.Count;
if (json.success && count > 0)
{
//保存数据
Save(json.data);
}
page++;
}
page++;
}
}
catch (Exception ex)
{
Console.WriteLine(ex.Message);
Thread.Sleep(60 * 1000);
catch (Exception ex)
{
Console.WriteLine(ex.Message);
Thread.Sleep(60 * 1000);
}
}
}
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment