|
|
@@ -48,19 +48,19 @@ public class TransactionHandleManagerImpl extends AbstractCommManager implements |
|
|
|
public void execute() { |
|
|
|
for (TransactionBizType bizType : TransactionBizType.values()) { |
|
|
|
List<TransactionStatus> lists = transactionStatusRepo.findByBusinessType(bizType); |
|
|
|
logger.info("处理事务...本次查询待处理数据{}条", lists.size()); |
|
|
|
logger.info("处理事务...本次处理{},查询待处理数据{}条", bizType.getName(), lists.size()); |
|
|
|
if (isEmpty(lists)) { |
|
|
|
continue; |
|
|
|
} |
|
|
|
try { |
|
|
|
toHandle(lists, bizType); |
|
|
|
} catch (Exception e) { |
|
|
|
logger.error("处理事务状态异常",e); |
|
|
|
logger.error("处理事务状态异常", e); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
private void toHandle(List<TransactionStatus> lists,TransactionBizType type) throws ManagerException { |
|
|
|
private void toHandle(List<TransactionStatus> lists, TransactionBizType type) throws ManagerException { |
|
|
|
switch (type) { |
|
|
|
case ISSUE_USER_SYNC: |
|
|
|
for (TransactionStatus list : lists) { |