带看默认时长

src/main/java/com/fdkankan/fusion/common/util/DateUtils.java

@@ -0,0 +1,21 @@
+package com.fdkankan.fusion.common.util;
+
+import cn.hutool.core.date.DateUtil;
+
+import java.util.Calendar;
+import java.util.Date;
+
+public class DateUtils {
+
+
+    public static Date getHoursTime(Date date){
+        Calendar calendar = Calendar.getInstance();
+        calendar.setTime(date);
+        calendar.add(Calendar.HOUR, 1);
+        return calendar.getTime();
+    }
+
+    public static void main(String[] args) {
+        System.out.println("今天是：" + DateUtil.format(getHoursTime(), "yyyy-MM-dd HH:mm:ss"));
+    }
+}

src/main/java/com/fdkankan/fusion/httpClient/FdService.java

@@ -4,6 +4,7 @@ import cn.dev33.satoken.stp.StpUtil;
 import cn.hutool.core.date.DateUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.fdkankan.fusion.common.ResultCode;
+import com.fdkankan.fusion.common.util.DateUtils;
 import com.fdkankan.fusion.common.util.RedisKeyUtil;
 import com.fdkankan.fusion.entity.TmCamera;
 import com.fdkankan.fusion.exception.BusinessException;
@@ -96,7 +97,7 @@ public class FdService {
         param.setRoomId(roomId);
         param.setMaxMan(30);
         param.setUseStartTime(new Date());
-        param.setUseEndTime(DateUtil.parse("2038-01-19 03:14:07","yyyy-MM-dd HH:mm:ss"));
+        param.setUseEndTime(DateUtils.getHoursTime(new Date()));
         param.setPlatform("fd");
         return takeLookClient.roomAddOrUpdate(param,getFdToken());
     }

src/main/java/com/fdkankan/fusion/task/TaskService.java

@@ -0,0 +1,29 @@
+package com.fdkankan.fusion.task;
+
+import com.fdkankan.fusion.common.util.DateUtils;
+import com.fdkankan.fusion.entity.CaseLive;
+import com.fdkankan.fusion.service.ICaseLiveService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
+
+@Service
+public class TaskService {
+
+    @Autowired
+    ICaseLiveService caseLiveService;
+
+    @Scheduled(initialDelay = 2000, fixedDelay = 1000 * 60)
+    public void run() {
+        List<CaseLive> list = caseLiveService.list();
+        for (CaseLive caseLive : list) {
+            Date hoursTime = DateUtils.getHoursTime(caseLive.getCreateTime());
+            if(hoursTime.getTime() <= new Date().getTime()){
+                caseLiveService.removeById(caseLive);
+            }
+        }
+    }
+}