diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java index 277d8c5c..e37d9d6f 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java @@ -251,6 +251,7 @@ public class Forwarder { QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("fwd_group_id",fwdGroupId); queryWrapper.ne("state",ResendRecord.STATE_FWD_OK); + queryWrapper.ge("createtime", LocalDateTime.now().minusDays(30)); List resendRecordsList = resendRecordMapper.selectList(queryWrapper); if(resendRecordsList!=null){ logger.info("{} forward history records: {}",fwdGroupId, resendRecordsList.size());