Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、查找推送历史数据的bug

Browse Source
This commit is contained in:
weidong 2024-12-31 13:20:32 +08:00
parent dcec4ec084
commit af9e843379
1 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java
View File

@ -71,6 +71,7 @@ public class Forwarder {
} }
QueryWrapper<GnssGroupFwd> queryWrapper = new QueryWrapper<>(); QueryWrapper<GnssGroupFwd> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("name",fwdGroupId); queryWrapper.eq("name",fwdGroupId);
queryWrapper.last("limit 1");
GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper); GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper);
if(gnssGroupFwd == null){ if(gnssGroupFwd == null){
gnssGroupFwd = new GnssGroupFwd(); gnssGroupFwd = new GnssGroupFwd();
@ -251,11 +252,14 @@ public class Forwarder {
queryWrapper.eq("fwd_group_id",fwdGroupId); queryWrapper.eq("fwd_group_id",fwdGroupId);
queryWrapper.ne("state",ResendRecord.STATE_FWD_OK); queryWrapper.ne("state",ResendRecord.STATE_FWD_OK);
List<ResendRecord> resendRecordsList = resendRecordMapper.selectList(queryWrapper); List<ResendRecord> resendRecordsList = resendRecordMapper.selectList(queryWrapper);
if(resendRecordsList!=null){
logger.info("forward history records: ",resendRecordsList.size());
// 2.检索这个这个时间段的解算结果，如果有数据则单个终端转发，标志记录为已补传 // 2.检索这个这个时间段的解算结果，如果有数据则单个终端转发，标志记录为已补传
for(ResendRecord record:resendRecordsList){ for(ResendRecord record:resendRecordsList){
forwardBatchGnssRecords(record); forwardBatchGnssRecords(record);
} }
} }
}
void forwardBatchGnssRecords(ResendRecord record) { void forwardBatchGnssRecords(ResendRecord record) {
LocalDateTime sendTime = record.getStarttime(); LocalDateTime sendTime = record.getStarttime();
@ -272,6 +276,7 @@ public class Forwarder {
void updateFwd(int fwd_num, boolean isFwdOK){ void updateFwd(int fwd_num, boolean isFwdOK){
QueryWrapper<GnssGroupFwd> queryWrapper = new QueryWrapper<>(); QueryWrapper<GnssGroupFwd> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("name",fwdGroupId); queryWrapper.eq("name",fwdGroupId);
queryWrapper.last("limit 1");
GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper); GnssGroupFwd gnssGroupFwd = fwdMapper.selectOne(queryWrapper);
if(gnssGroupFwd != null){ if(gnssGroupFwd != null){
gnssGroupFwd.setFwd_device_num(fwd_num); gnssGroupFwd.setFwd_device_num(fwd_num);