Commit 1a608086 by wutong

处理没有抓取所有账号费用的问题

parent 0890ff47
...@@ -35,7 +35,7 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -35,7 +35,7 @@ public class EbayFinanceSyncJob extends PointJob {
@Override @Override
public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) { public void executeJob(ShardingContext shardingContext, JobPointLog jobPointLog) {
int totalPage = getTotalPage(jobPointLog);//分片即将处理的账号总数 int totalPage = getCount(jobPointLog);//分片即将处理的账号总数
try { try {
JobAccountLogMapper jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class); JobAccountLogMapper jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class);
/* /*
...@@ -69,7 +69,7 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -69,7 +69,7 @@ public class EbayFinanceSyncJob extends PointJob {
} }
} }
private int getTotalPage(JobPointLog jobPointLog) { private int getCount(JobPointLog jobPointLog) {
int i = 0; int i = 0;
try { try {
DcBaseCompanyAccountMapper accountMapper = SessionUtil.getSession().getMapper(DcBaseCompanyAccountMapper.class); DcBaseCompanyAccountMapper accountMapper = SessionUtil.getSession().getMapper(DcBaseCompanyAccountMapper.class);
...@@ -79,7 +79,7 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -79,7 +79,7 @@ public class EbayFinanceSyncJob extends PointJob {
} finally { } finally {
SessionUtil.closeSession(); SessionUtil.closeSession();
} }
return i % jobPointLog.getPageSize() == 0? i / jobPointLog.getPageSize() : i / jobPointLog.getPageSize() + 1; return i;
} }
public void callSaasApi(JobAccountLog job) { public void callSaasApi(JobAccountLog job) {
......
...@@ -13,7 +13,7 @@ public class EbayFinanceSyncJobTest { ...@@ -13,7 +13,7 @@ public class EbayFinanceSyncJobTest {
@Test @Test
public void test3() { public void test3() {
EbayFinanceSyncJob skuSyncJob = new EbayFinanceSyncJob(); EbayFinanceSyncJob skuSyncJob = new EbayFinanceSyncJob();
ShardingContext job = new ShardingContext(new ShardingContexts("1", "job", 3, "", new HashMap<>()), 1); ShardingContext job = new ShardingContext(new ShardingContexts("1", "job", 3, "", new HashMap<>()), 2);
skuSyncJob.executeJob(job, new JobPointLog("",null ,100,1,1, LocalDateTime.now().minusMonths(1),LocalDateTime.now().minusDays(29))); skuSyncJob.executeJob(job, new JobPointLog("",null ,100,1,1, LocalDateTime.now().minusMonths(1),LocalDateTime.now().minusDays(29)));
} }
......
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