Commit 376beae5 authored by 郝彦辉's avatar 郝彦辉

检测transaction_log重复工具

parent a8b2d23c
......@@ -573,7 +573,7 @@ public class CleanningTransactionLogService {
String endTime = now.minusDays(i).format(DateTimeFormatter.ISO_DATE);
Stopwatch callRStopwatch = Stopwatch.createStarted();
String CALL_SQL = "select transaction_id, uuid, url_type, code, created_at " +
String CALL_SQL = "select transaction_id, uuid, url_type, code, time_created " +
" from transaction_log t where t.time_created >= '" + startTime + "' and t.time_created < '" + endTime + "'";
List<TransactionLogPO> queryResult = riskDatasourceJdbcTemplate.query(CALL_SQL, new BeanPropertyRowMapper<>(TransactionLogPO.class));
log.info("checkTransactionLogCF检测重复transaction_log查询数据结束, startTime: {} , endTime: {} , size: {} , sql: {} , 耗时: {} ", startTime, endTime, CollectionUtils.isEmpty(queryResult) ? 0 : queryResult.size(), CALL_SQL, callRStopwatch.stop().elapsed(TimeUnit.MILLISECONDS));
......
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