在addAlarmLog接口中添加判断，当告警时间戳大于当前时间则使用当前时间。

src/main/java/com/example/tdl/domain/vo/AlarmNoVo.java

 package com.example.tdl.domain.vo;
 
 public class AlarmNoVo {
-
+    /**
+     * 使用场景: 1 = 运输线路, 2 = 仓库
+     */
     private Integer  mode;
 
     private String transportationNo;

src/main/java/com/example/tdl/web/AlarmLogController.java

@@ -220,6 +220,20 @@ public class AlarmLogController {
         return  gson.toJson(new MqttUser(userName,password,userRedisVo.getCompanyNo()));
     }
 
+    private Long checkTimestamp(Long ts) {
+        long currentTs = System.currentTimeMillis();
+        if (ts == null) {
+            return currentTs;
+        }
+        if(ts.toString().length() == 10){
+            ts *= 1000; // 转换成毫秒单位
+        }
+        // 如果时间戳大于当前时间则使用当前时间
+        if (ts > currentTs) {
+            return currentTs;
+        }
+        return ts;
+    }
 
     //新增报警消息
     @ApiOperation(value = "增加报警",notes = "增加报警")
@@ -248,10 +262,8 @@ public class AlarmLogController {
                 //网关离线报警
                 String desp ="Gateway("+addAlarmLogVo.getGsn() +")"+ AlarmLogUtil.getDescription(addAlarmLogVo.getAlarmno());
                 String classify ="6";
-                Long  time  = addAlarmLogVo.getTs();
-                if(time.toString().length() == 10){
-                    time=time*1000;
-                }
+                Long time = addAlarmLogVo.getTs();
+                time = checkTimestamp(time);
                 AlarmLog alarmLog = new AlarmLog(alarmNoVo.getTransportationNo(),resultCircuitVo.getStartCity(),resultCircuitVo.getEndCity(),null,desp,null,time,classify,"offline",addAlarmLogVo.getAlarmno());
                 alarmLogServcie.addAlarmLog(alarmLog);
             }
@@ -299,16 +311,16 @@ public class AlarmLogController {
                 String desp = "Gateway("+addAlarmLogVo.getGsn() +")"+ AlarmLogUtil.getDescription(addAlarmLogVo.getAlarmno());
                 String classify ="6";
                 Long  time  = addAlarmLogVo.getTs();
-                if(time.toString().length() == 10){
-                    time=time*1000;
-                }
+                time = checkTimestamp(time);
                 //发送短信邮件
-                Integer delState = 0;
+                int delState = 0;
                 if(alarmTime == null  || (time -alarmTime) >alarmIntervalTime){
                     sendMessage(alarmNoVo.getWarehouseName(),desp,userList);
                     delState = 1;
                 }
-                WarehouseAlarmLog alarmLog = new  WarehouseAlarmLog(alarmNoVo.getWarehouseNo(),addAlarmLogVo.getGsn(),addAlarmLogVo.getGtype(),null,desp,null,time,"offline",addAlarmLogVo.getAlarmno(),classify,delState);
+                WarehouseAlarmLog alarmLog = new WarehouseAlarmLog(alarmNoVo.getWarehouseNo(),
+                        addAlarmLogVo.getGsn(),addAlarmLogVo.getGtype(),null,desp,null,time,
+                        "offline",addAlarmLogVo.getAlarmno(),classify,delState);
                 warehouseAlarmLogService.add(alarmLog);
             }
             if(addAlarmLogVo.getAlarm() !=null &&  addAlarmLogVo.getAlarm().size()>0){