Commit 5ca388968f06e39c31058c1e48d57f7a8937ce56
1 parent
7efe8a9d
update...
Showing
1 changed file
with
13 additions
and
1 deletions
src/main/java/com/bsth/data/gpsdata_v2/rfid/handle/RfidSignalHandle.java
| ... | ... | @@ -30,6 +30,8 @@ public class RfidSignalHandle { |
| 30 | 30 | @Autowired |
| 31 | 31 | GpsStatusManager gpsStatusManager; |
| 32 | 32 | |
| 33 | + private final static int MAX_TIME_DIFF = 1000 * 60 * 60 * 2; | |
| 34 | + | |
| 33 | 35 | Logger logger = LoggerFactory.getLogger(this.getClass()); |
| 34 | 36 | |
| 35 | 37 | public void handle(List<RfidInoutStation> list){ |
| ... | ... | @@ -53,6 +55,10 @@ public class RfidSignalHandle { |
| 53 | 55 | if(null == sch) |
| 54 | 56 | return; |
| 55 | 57 | |
| 58 | + //最大时间差 | |
| 59 | + if(Math.abs(sch.getDfsjT() - signal.getT()) > MAX_TIME_DIFF) | |
| 60 | + return; | |
| 61 | + | |
| 56 | 62 | if(sch.getQdzCode().equals(signal.getStation()) |
| 57 | 63 | && StringUtils.isEmpty(sch.getFcsjActual())){ |
| 58 | 64 | |
| ... | ... | @@ -81,12 +87,18 @@ public class RfidSignalHandle { |
| 81 | 87 | String nbbm = signal.getNbbm(); |
| 82 | 88 | ScheduleRealInfo sch = dayOfSchedule.executeCurr(nbbm); |
| 83 | 89 | |
| 90 | + if(null == sch) | |
| 91 | + return; | |
| 92 | + | |
| 93 | + //最大时间差 | |
| 94 | + if(Math.abs(sch.getDfsjT() - signal.getT()) > MAX_TIME_DIFF) | |
| 95 | + return; | |
| 96 | + | |
| 84 | 97 | if(sch.getZdzCode().equals(signal.getStation()) |
| 85 | 98 | && StringUtils.isEmpty(sch.getZdsjActual())){ |
| 86 | 99 | |
| 87 | 100 | sch.setZdsjActualAll(signal.getT()); |
| 88 | 101 | |
| 89 | - | |
| 90 | 102 | //持久化 |
| 91 | 103 | dayOfSchedule.save(sch); |
| 92 | 104 | ... | ... |