|
|
|
|
|
|
|
|
List<YgzInterfaceLog> logs = logRepo.listBySendStatusLessThen5Times(YgzSendStatus.WAIT_SEND); |
|
|
List<YgzInterfaceLog> logs = logRepo.listBySendStatusLessThen5Times(YgzSendStatus.WAIT_SEND); |
|
|
logger.info("营改增---查询营改增记录条数:{}", logs.size()); |
|
|
logger.info("营改增---查询营改增记录条数:{}", logs.size()); |
|
|
for (YgzInterfaceLog log : logs) { |
|
|
for (YgzInterfaceLog log : logs) { |
|
|
executor.execute(() -> { |
|
|
|
|
|
|
|
|
// executor.execute(() -> { |
|
|
try { |
|
|
try { |
|
|
switch (log.getNioTransferType()) { |
|
|
switch (log.getNioTransferType()) { |
|
|
case USERUPLOAD: |
|
|
case USERUPLOAD: |
|
|
|
|
|
|
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
logger.error("营改增定时器异常:", e); |
|
|
logger.error("营改增定时器异常:", e); |
|
|
} |
|
|
} |
|
|
}); |
|
|
|
|
|
|
|
|
// }); |
|
|
} |
|
|
} |
|
|
} catch (Exception e) { |
|
|
} catch (Exception e) { |
|
|
logger.error("营改增定时器异常:", e); |
|
|
logger.error("营改增定时器异常:", e); |