定时任务

cooleshow-app/src/main/java/com/yonge/cooleshow/admin/task/TaskController.java

@@ -1,20 +1,7 @@
 package com.yonge.cooleshow.admin.task;
 
 import com.alibaba.fastjson.JSONObject;
-import com.yonge.cooleshow.biz.dal.service.ActivityPlanEvaluationService;
-import com.yonge.cooleshow.biz.dal.service.ActivityPlanService;
-import com.yonge.cooleshow.biz.dal.service.CourseScheduleService;
-import com.yonge.cooleshow.biz.dal.service.CustomerServiceBatchSendingService;
-import com.yonge.cooleshow.biz.dal.service.ImGroupService;
-import com.yonge.cooleshow.biz.dal.service.MusicAlbumService;
-import com.yonge.cooleshow.biz.dal.service.MusicSheetService;
-import com.yonge.cooleshow.biz.dal.service.PlatformCashAccountRecordService;
-import com.yonge.cooleshow.biz.dal.service.TeacherStyleVideoService;
-import com.yonge.cooleshow.biz.dal.service.TenantUnbindRecordService;
-import com.yonge.cooleshow.biz.dal.service.UserAccountRecordService;
-import com.yonge.cooleshow.biz.dal.service.UserBindingTeacherService;
-import com.yonge.cooleshow.biz.dal.service.UserOrderService;
-import com.yonge.cooleshow.biz.dal.service.UserPaymentCoreService;
+import com.yonge.cooleshow.biz.dal.service.*;
 import com.yonge.cooleshow.common.constant.SysConfigConstant;
 import com.yonge.cooleshow.common.controller.BaseController;
 import com.yonge.cooleshow.common.entity.HttpResponseResult;
@@ -80,6 +67,9 @@ public class TaskController extends BaseController {
     private UserPaymentCoreService userPaymentCoreService;
 
     @Autowired
+    private LiveRoomService liveRoomService;
+
+    @Autowired
     private TenantUnbindRecordService tenantUnbindRecordService;
 
     @Autowired
@@ -198,24 +188,23 @@ public class TaskController extends BaseController {
         return HttpResponseResult.succeed();
     }
 
+
     /**
-     * 定时发送平台审核短信 下午5点
+     * 直播间销毁
      */
-    @GetMapping("/sendPlatformAuditMessage")
-    public HttpResponseResult<Object> sendPlatformAuditMessage() {
+    @GetMapping("/destroyLiveRoom")
+    public HttpResponseResult<Object> destroyLiveRoom() {
 
         // 群发消息定时
-        tenantUnbindRecordService.sendPlatformAuditMessage();
+        liveRoomService.destroyLiveRoom();
 
         return HttpResponseResult.succeed();
     }
 
 
-
-
     @GetMapping("/rongyunImport")
     public void rongyunImport() throws Exception {
-         String currentDate = DateUtil.format(DateUtil.addHours(new Date(),-2), DateUtil.YEAR_MONTH_DAY_HOUR);
+        String currentDate = DateUtil.format(DateUtil.addHours(new Date(),-2), DateUtil.YEAR_MONTH_DAY_HOUR);
         Object o = imGroupService.historyGet(currentDate);
         JSONObject jsonObject = JSONObject.parseObject(JSONObject.toJSONString(o));
         if (jsonObject.get("code").equals(200)) {
@@ -229,4 +218,17 @@ public class TaskController extends BaseController {
 
         }
     }
+    /**
+     * 定时发送平台审核短信 下午5点
+     */
+    @GetMapping("/sendPlatformAuditMessage")
+    public HttpResponseResult<Object> sendPlatformAuditMessage() {
+
+        // 群发消息定时
+        tenantUnbindRecordService.sendPlatformAuditMessage();
+
+        return HttpResponseResult.succeed();
+    }
+
+
 }