Commit 6e549dff by yinyong@bailuntec.com

Executor was closed

parent 56ecef57
...@@ -68,7 +68,6 @@ public class CrmRefundSyncJob extends PointJob { ...@@ -68,7 +68,6 @@ public class CrmRefundSyncJob extends PointJob {
totalPage = refundDetails.getTotalPages(); totalPage = refundDetails.getTotalPages();
if (refundDetails.getItems() != null && refundDetails.getItems().size() > 0) { if (refundDetails.getItems() != null && refundDetails.getItems().size() > 0) {
try { try {
DcBaseCrmRefundMapper mapper = SessionUtil.getSession().getMapper(DcBaseCrmRefundMapper.class);
for (RefundItem refundItem : refundDetails.getItems()) { for (RefundItem refundItem : refundDetails.getItems()) {
DcBaseCrmRefund dcBaseCrmRefund = new DcBaseCrmRefund(); DcBaseCrmRefund dcBaseCrmRefund = new DcBaseCrmRefund();
try { try {
...@@ -81,6 +80,7 @@ public class CrmRefundSyncJob extends PointJob { ...@@ -81,6 +80,7 @@ public class CrmRefundSyncJob extends PointJob {
e.printStackTrace(); e.printStackTrace();
throw new RuntimeException("CRM退款BeanUtils.copyProperties失败", e); throw new RuntimeException("CRM退款BeanUtils.copyProperties失败", e);
} }
DcBaseCrmRefundMapper mapper = SessionUtil.getSession().getMapper(DcBaseCrmRefundMapper.class);
int i = mapper.updateByExampleSelective(dcBaseCrmRefund, DcBaseCrmRefundExample.newAndCreateCriteria().andCrmIdEqualTo(dcBaseCrmRefund.getCrmId()).example()); int i = mapper.updateByExampleSelective(dcBaseCrmRefund, DcBaseCrmRefundExample.newAndCreateCriteria().andCrmIdEqualTo(dcBaseCrmRefund.getCrmId()).example());
if (i == 0) { if (i == 0) {
mapper.insertSelective(dcBaseCrmRefund); mapper.insertSelective(dcBaseCrmRefund);
......
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