|
|
@ -167,12 +167,14 @@ namespace TaskManager.Controllers |
|
|
|
{ |
|
|
|
foreach (var sub in sublist) |
|
|
|
{ |
|
|
|
|
|
|
|
string querystr = $"select * from {sub.TableName} where TaskId='{sub.TaskId}' and WriteState=0 and ReadState=1 order by uid";//任务表
|
|
|
|
|
|
|
|
var entites = _jobDbContext.Database.GetDbConnection().Query<T>(querystr);//明细表
|
|
|
|
if (entites.Any()) |
|
|
|
{ |
|
|
|
var total = entites.Count(); |
|
|
|
sub.DataCount = total; |
|
|
|
int totalPages = (int)Math.Ceiling((double)total / pageSize); |
|
|
|
|
|
|
|
for (int i = sub.SyncedPageCount; i <= totalPages; i++) |
|
|
@ -202,12 +204,14 @@ namespace TaskManager.Controllers |
|
|
|
itm.WriteState = true; |
|
|
|
} |
|
|
|
var result = await PostPageAsync(pagedRequest,sub.TaskId, DateTime.Now.ToString("yyyyMMdd")); |
|
|
|
if(result.code == "200") |
|
|
|
if(result.code == 200) |
|
|
|
{ |
|
|
|
|
|
|
|
_jobDbContext.BulkUpdate(records); |
|
|
|
sub.SyncedPageCount = i; |
|
|
|
if (i == total) |
|
|
|
if (i == totalPages) |
|
|
|
{ |
|
|
|
|
|
|
|
sub.WriteState = true; |
|
|
|
_jobDbContext.Set<TaskSub>().Update(sub); |
|
|
|
_jobDbContext.SaveChanges(); |
|
|
@ -215,7 +219,9 @@ namespace TaskManager.Controllers |
|
|
|
} |
|
|
|
else |
|
|
|
{ |
|
|
|
await _logger.AddError($"第 {i} 页数据保存失败,请检查数据。", TaskName,sub.TaskId, DateTime.Now.ToString("yyyyMMdd")); |
|
|
|
sub.FailedCount = i*pageSize; |
|
|
|
|
|
|
|
await _logger.AddError($"第 {i} 页奇瑞数据保存失败 {result.message}。", TaskName,sub.TaskId, DateTime.Now.ToString("yyyyMMdd")); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|