From af9e8433796a371b70d623c42676c5bf70ccc9cb Mon Sep 17 00:00:00 2001 From: weidong Date: Tue, 31 Dec 2024 13:20:32 +0800 Subject: [PATCH] =?UTF-8?q?1=E3=80=81=E6=9F=A5=E6=89=BE=E6=8E=A8=E9=80=81?= =?UTF-8?q?=E5=8E=86=E5=8F=B2=E6=95=B0=E6=8D=AE=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/imdroid/beidou_fwd/task/Forwarder.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) 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 8d7c00ff..03fae212 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 @@ -71,6 +71,7 @@ public class Forwarder { } QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("name",fwdGroupId); + queryWrapper.last("limit 1"); GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper); if(gnssGroupFwd == null){ gnssGroupFwd = new GnssGroupFwd(); @@ -251,9 +252,12 @@ public class Forwarder { queryWrapper.eq("fwd_group_id",fwdGroupId); queryWrapper.ne("state",ResendRecord.STATE_FWD_OK); List resendRecordsList = resendRecordMapper.selectList(queryWrapper); - // 2.检索这个这个时间段的解算结果，如果有数据则单个终端转发，标志记录为已补传 - for(ResendRecord record:resendRecordsList){ - forwardBatchGnssRecords(record); + if(resendRecordsList!=null){ + logger.info("forward history records: ",resendRecordsList.size()); + // 2.检索这个这个时间段的解算结果，如果有数据则单个终端转发，标志记录为已补传 + for(ResendRecord record:resendRecordsList){ + forwardBatchGnssRecords(record); + } } } @@ -272,6 +276,7 @@ public class Forwarder { void updateFwd(int fwd_num, boolean isFwdOK){ QueryWrapper queryWrapper = new QueryWrapper<>(); queryWrapper.eq("name",fwdGroupId); + queryWrapper.last("limit 1"); GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper); if(gnssGroupFwd != null){ gnssGroupFwd.setFwd_device_num(fwd_num);