saas_entrepot/zhongzheng-admin/src/main/java/com/zhongzheng/controller/schedule/ScheduleController.java

package com.zhongzheng.controller.schedule;

import com.zhongzheng.common.core.controller.BaseController;
import com.zhongzheng.common.core.domain.AjaxResult;
import com.zhongzheng.modules.polyv.bo.PolyvLiveQueryBo;
import com.zhongzheng.modules.polyv.service.IPolyvLiveService;
import com.zhongzheng.modules.schedule.service.IScheduleService;
import com.zhongzheng.modules.user.bo.UserQueryBo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.web.bind.annotation.*;

import java.text.ParseException;

/**
 * 定时任务
 *
 * @author ruoyi
 * @date 2021-11-10
 */
@Api(value = "定时任务", tags = {"定时任务管理"})
@RequiredArgsConstructor(onConstructor_ = @Autowired)
@RestController
@RequestMapping("/app/common")
public class ScheduleController extends BaseController {

    private final IScheduleService iScheduleService;

    private final IPolyvLiveService iPolyvLiveService;



    /**
     * 商品购买发送消息
     * @return
     */
    @ApiOperation("商品购买发送消息")
    @GetMapping("/updateGoodsSend")
    public AjaxResult updateGoodsSend(UserQueryBo bo) {
        iScheduleService.updateGoodsSend(bo);
        return AjaxResult.success();
    }


    /**
     * 考试提醒
     * @return
     */
    @ApiOperation("考试预约提醒")
    @GetMapping("/updateExamSend")
    public AjaxResult updateExamSend(UserQueryBo bo) {
        iScheduleService.updateExamSend(bo);
        return AjaxResult.success();
    }


    /**
     * 考试提醒
     * @return
     */
    @ApiOperation("每天10点请求的考试提醒")
    @GetMapping("/timeSend")
    public AjaxResult timeSend(UserQueryBo bo) {
        iScheduleService.timeSend(bo);
        return AjaxResult.success();
    }


    /**
     * 订单超时关闭
     * @return
     */
    @ApiOperation("订单超时关闭")
    @GetMapping("/outTimeOrder")
    public AjaxResult outTimeOrder() {
        iScheduleService.closeTimeOutOrder();
        return AjaxResult.success();
    }

    /**
     * 考试提醒
     * @return
     */
    @ApiOperation("考试预约提醒")
    @GetMapping("/issue")
    public AjaxResult updateIssue(UserQueryBo bo) throws ParseException {
        iScheduleService.updateIssue(bo);
        return AjaxResult.success();
    }

    /**
     * 计划更新每晚0点更新
     * @return
     */
    @ApiOperation("计划更新每晚0点更新")
    @GetMapping("/UpPlan")
    public AjaxResult UpPlan(UserQueryBo bo){
        iScheduleService.UpPlan(bo);
        return AjaxResult.success();
    }

    /**
     * 计划更新每晚0点更新
     * @return
     */
    @ApiOperation("更新过期时间")
    @GetMapping("/UpExam")
    public AjaxResult UpExam(UserQueryBo bo){
        iScheduleService.UpExam(bo);
        return AjaxResult.success();
    }

    /**
     * 商品下架状态更新
     * @return
     */
    @ApiOperation("更新商品下架状态")
    @GetMapping("/UpGoods")
    public AjaxResult UpGoods(UserQueryBo bo){
        iScheduleService.UpGoods(bo);
        return AjaxResult.success();
    }

    /**
     * 商品下架状态更新
     * @return
     */
    @ApiOperation("更新考次次数")
    @GetMapping("/UpExamNum")
    public AjaxResult UpExamNum(UserQueryBo bo){
        iScheduleService.UpExamNum(bo);
        return AjaxResult.success();
    }

    /**
     * 报考数据绑定前培
     * @return
     */
    @ApiOperation("报考数据绑定前培")
    @GetMapping("/bindBefore")
    public AjaxResult bindBefore(UserQueryBo bo){
        iScheduleService.bindBefore(bo);
        return AjaxResult.success();
    }

    /**
     * 官方信息推送
     * @return
     */
    @ApiOperation("定时官方信息推送")
    @GetMapping("/officialInfoPush")
    public AjaxResult officialInfoPush(UserQueryBo bo){
        iScheduleService.officialInfoPush(bo);
        return AjaxResult.success();
    }

    /**
     * 官方学时推送
     * @return
     */
    @ApiOperation("定时官方学时推送")
    @GetMapping("/officialPeriodPush")
    public AjaxResult officialPeriodPush(UserQueryBo bo){
        iScheduleService.officialPeriodPush(bo);
        return AjaxResult.success();
    }

    @ApiOperation("直播结束更新学时")
    @GetMapping("/overLive")
    public AjaxResult overLive(UserQueryBo bo){
        iScheduleService.overLive(bo);
        return AjaxResult.success();
    }

    @ApiOperation("保利威直播结束更新回放")
    @GetMapping("/liveToReplay")
    public AjaxResult liveToReplay(UserQueryBo bo) throws Exception {
        iScheduleService.liveToReplay(bo);
        return AjaxResult.success();
    }

    @ApiOperation("同步保利威场次vid")
    @GetMapping("/syncToReplay")
    public AjaxResult syncToReplay(UserQueryBo bo) throws Exception {
        iScheduleService.syncToReplay(bo);
        return AjaxResult.success();
    }

    @ApiOperation("测试")
    @GetMapping("/getChannelVideo")
    public AjaxResult getChannelVideo(PolyvLiveQueryBo bo) throws Exception {
        iPolyvLiveService.getChannelVideo(bo);
        return AjaxResult.success();
    }

    @ApiOperation("测试1")
    @GetMapping("/ListChannelVideoLibrary")
    public AjaxResult ListChannelVideoLibrary(PolyvLiveQueryBo bo) throws Exception {
        iPolyvLiveService.ListChannelVideoLibrary(bo);
        return AjaxResult.success();
    }
}