Commit 6e7ed9fd by jianshuqin

增加同步物流账单时间服务

parent 206701a3
...@@ -5,21 +5,21 @@ ...@@ -5,21 +5,21 @@
/// <summary> /// <summary>
/// 页码 /// 页码
/// </summary> /// </summary>
public int PageIndex { get; set; } public int pageIndex { get; set; }
/// <summary> /// <summary>
/// 分页大小 /// 分页大小
/// </summary> /// </summary>
public int PageCount { get; set; } public int pageCount { get; set; }
/// <summary> /// <summary>
/// 配货单号 /// 配货单号
/// </summary> /// </summary>
public string AllocatecargoOrderCode { get; set; } public string allocatecargoOrderCode { get; set; }
/// <summary> /// <summary>
/// 差异状态 未对账 = 0, 存在差异 = 1 , 验证通过 = 2 /// 差异状态 未对账 = 0, 存在差异 = 1 , 验证通过 = 2
/// </summary> /// </summary>
public int[] DiffStateTypes { get; set; } public int[] diffStateTypes { get; set; }
} }
} }
...@@ -70,20 +70,21 @@ namespace Bailun.DC.SyncPickBillTime ...@@ -70,20 +70,21 @@ namespace Bailun.DC.SyncPickBillTime
Console.WriteLine($"需要同步{list.Count}条数据"); Console.WriteLine($"需要同步{list.Count}条数据");
RequestDto request = new RequestDto RequestDto request = new RequestDto
{ {
PageCount = 1000, pageCount = 1000,
PageIndex = 1, pageIndex = 1,
AllocatecargoOrderCode = string.Join(",", list.Select(l => l.pick_order_id)) allocatecargoOrderCode = string.Join(",", list.Select(l => l.pick_order_id)),
diffStateTypes = new int[] { 1, 2 }
}; };
ResponseDto response = default(ResponseDto); ResponseDto response = default(ResponseDto);
while (request.PageIndex == 1 || (response != null && response.result != null && (response.result.totalPages > response.result.pageIndex))) while (request.pageIndex == 1 || (response != null && response.result != null && (response.result.totalPages > response.result.pageIndex)))
{ {
string data = JsonConvert.SerializeObject(request); string data = JsonConvert.SerializeObject(request);
var result = Common.HttpHelper.NetHelper.HttpPostJson(url, data); var result = Common.HttpHelper.NetHelper.HttpPostJson(url, data);
request.PageIndex++; request.pageIndex++;
if (!string.IsNullOrEmpty(result)) if (!string.IsNullOrEmpty(result))
{ {
response = JsonConvert.DeserializeObject<ResponseDto>(result); response = JsonConvert.DeserializeObject<ResponseDto>(result);
if (request.PageIndex == 1) if (request.pageIndex == 1)
{ {
Console.WriteLine($"总共同步{response?.result?.total ?? 0}条数据"); Console.WriteLine($"总共同步{response?.result?.total ?? 0}条数据");
} }
...@@ -91,7 +92,7 @@ namespace Bailun.DC.SyncPickBillTime ...@@ -91,7 +92,7 @@ namespace Bailun.DC.SyncPickBillTime
{ {
//保存数据 //保存数据
Save(response.result.result); Save(response.result.result);
Console.WriteLine($"已同步{((response.result.pageIndex - 1) * request.PageCount) + response.result.result.Count}条数据"); Console.WriteLine($"已同步{((response.result.pageIndex - 1) * request.pageCount) + response.result.result.Count}条数据");
} }
} }
} }
......
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