Commit 8dc25197 by yinyong

Executor was closed01

parent 63f28de7
...@@ -54,10 +54,11 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -54,10 +54,11 @@ public class EbayFinanceSyncJob extends PointJob {
jobAccountLog.setId(null); jobAccountLog.setId(null);
} }
callSaasApi(jobAccountLog); callSaasApi(jobAccountLog);
jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class);
if (jobAccountLog.getId() == null) { //在任务表无记录 if (jobAccountLog.getId() == null) { //在任务表无记录
jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class);
jobAccountLogMapper.insertSelective(jobAccountLog); jobAccountLogMapper.insertSelective(jobAccountLog);
} else { } else {
jobAccountLogMapper = SessionUtil.getSession().getMapper(JobAccountLogMapper.class);
jobAccountLog.setBjModified(LocalDateTime.now()); jobAccountLog.setBjModified(LocalDateTime.now());
jobAccountLogMapper.updateByExampleSelective(jobAccountLog,JobAccountLogExample.newAndCreateCriteria().andAccountIdEqualTo(jobAccountLog.getAccountId()).andJobNameEqualTo(jobAccountLog.getJobName()).example()); jobAccountLogMapper.updateByExampleSelective(jobAccountLog,JobAccountLogExample.newAndCreateCriteria().andAccountIdEqualTo(jobAccountLog.getAccountId()).andJobNameEqualTo(jobAccountLog.getJobName()).example());
} }
...@@ -113,7 +114,6 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -113,7 +114,6 @@ public class EbayFinanceSyncJob extends PointJob {
List<AccountEntry> accountEntryList = accountEntries.getAccountEntry(); List<AccountEntry> accountEntryList = accountEntries.getAccountEntry();
if (accountEntryList != null && accountEntryList.size() > 0) { if (accountEntryList != null && accountEntryList.size() > 0) {
for (AccountEntry accountEntry : accountEntryList) { for (AccountEntry accountEntry : accountEntryList) {
DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper = SessionUtil.getSession().getMapper(DcBaseFinanceEbayMapper.class);
LocalDateTime gmt = LocalDateTime.from(DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").parse(accountEntry.getGmtDate_())); LocalDateTime gmt = LocalDateTime.from(DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'").parse(accountEntry.getGmtDate_()));
dcBaseFinanceEbay.setGmtDate(gmt); dcBaseFinanceEbay.setGmtDate(gmt);
dcBaseFinanceEbay.setBjDate(dcBaseFinanceEbay.getGmtDate().plusHours(8)); dcBaseFinanceEbay.setBjDate(dcBaseFinanceEbay.getGmtDate().plusHours(8));
...@@ -130,6 +130,7 @@ public class EbayFinanceSyncJob extends PointJob { ...@@ -130,6 +130,7 @@ public class EbayFinanceSyncJob extends PointJob {
dcBaseFinanceEbay.setAccountId(job.getAccountId()); dcBaseFinanceEbay.setAccountId(job.getAccountId());
dcBaseFinanceEbay.setCompanyId(job.getCompanyId()); dcBaseFinanceEbay.setCompanyId(job.getCompanyId());
dcBaseFinanceEbay.setBjModified(LocalDateTime.now()); dcBaseFinanceEbay.setBjModified(LocalDateTime.now());
DcBaseFinanceEbayMapper dcBaseFinanceEbayMapper = SessionUtil.getSession().getMapper(DcBaseFinanceEbayMapper.class);
int i = dcBaseFinanceEbayMapper.updateByExampleSelective(dcBaseFinanceEbay, DcBaseFinanceEbayExample.newAndCreateCriteria().andAccountIdEqualTo(dcBaseFinanceEbay.getAccountId()).andRefNumberEqualTo(dcBaseFinanceEbay.getRefNumber()).example()); int i = dcBaseFinanceEbayMapper.updateByExampleSelective(dcBaseFinanceEbay, DcBaseFinanceEbayExample.newAndCreateCriteria().andAccountIdEqualTo(dcBaseFinanceEbay.getAccountId()).andRefNumberEqualTo(dcBaseFinanceEbay.getRefNumber()).example());
if (i == 0) { if (i == 0) {
dcBaseFinanceEbayMapper.insertSelective(dcBaseFinanceEbay); dcBaseFinanceEbayMapper.insertSelective(dcBaseFinanceEbay);
......
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