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.framework.web.service.AsyncService;
import com.zhongzheng.framework.web.service.WxLoginService;
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 com.zhongzheng.modules.user.bo.UserWxFollowQueryBo;
import com.zhongzheng.modules.user.service.IUserWxFollowService;
import com.zhongzheng.modules.wx.bo.WxLoginBody;
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;

    private final AsyncService asyncService;

    private final WxLoginService wxLoginService;

    /**
     * 商品购买发送消息
     * @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();
    }

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

    /**
     * 模考开始提醒
     * @return
     */
    @ApiOperation("模考开始前60分钟提醒")
    @GetMapping("/mockTimeSend")
    public AjaxResult mockTimeSend(UserQueryBo bo) {
        iScheduleService.mockTimeSend(bo);
        return AjaxResult.success();
    }

    /**
     * 模考直播提醒
     * @return
     */
    @ApiOperation("模考直播开始前60分钟提醒")
    @GetMapping("/mockLiveSend")
    public AjaxResult mockLiveSend(UserQueryBo bo) {
        iScheduleService.mockLiveSend(bo);
        return AjaxResult.success();
    }

    @ApiOperation("获取关注列表")
    @GetMapping("/syncFollowList")
    public AjaxResult syncFollowList(){
        WxLoginBody loginBody = new WxLoginBody();
        wxLoginService.getWxGzhUserList(loginBody.getNextOpenid());
        return AjaxResult.success();
    }

    @ApiOperation("同步union")
    @GetMapping("/syncUnion")
    public AjaxResult syncUnion(){
        UserWxFollowQueryBo bo = new UserWxFollowQueryBo();
        asyncService.executeAsync(bo,0);
        return AjaxResult.success();
    }

    @ApiOperation("学生购买2天未学习提醒")
    @GetMapping("/buyNotReadToStudentTwo")
    public AjaxResult buyNotReadToStudentTwo(UserQueryBo bo){
        iScheduleService.buyNotReadToStudentTwo(bo);
        return AjaxResult.success();
    }

    @ApiOperation("学生购买5天未学习提醒")
    @GetMapping("/buyNotReadToStudentFive")
    public AjaxResult buyNotReadToStudentFive(UserQueryBo bo){
        iScheduleService.buyNotReadToStudentFive(bo);
        return AjaxResult.success();
    }

    @ApiOperation("学生购买7天未学习教务提醒")
    @GetMapping("/buyNotReadToTeacher")
    public AjaxResult buyNotReadToTeacher(UserQueryBo bo){
        iScheduleService.buyNotReadToTeacher(bo);
        return AjaxResult.success();
    }

    @ApiOperation("学生长时间3天未学习提醒")
    @GetMapping("/longNotReadToStudentThree")
    public AjaxResult longNotReadToStudentThree(UserQueryBo bo){
        iScheduleService.longNotReadToStudentThree(bo);
        return AjaxResult.success();
    }

    @ApiOperation("学生长时间5天未学习提醒")
    @GetMapping("/longNotReadToStudentFive")
    public AjaxResult longNotReadToStudentFive(UserQueryBo bo){
        iScheduleService.longNotReadToStudentFive(bo);
        return AjaxResult.success();
    }

    @ApiOperation("学生长时间7天未学习教务提醒")
    @GetMapping("/longNotReadToTeacher")
    public AjaxResult longNotReadToTeacher(UserQueryBo bo){
        iScheduleService.longNotReadToTeacher(bo);
        return AjaxResult.success();
    }

    @ApiOperation("同步智慧考场")
    @GetMapping("/syncExamSite")
    public AjaxResult syncExamSite(UserQueryBo bo){
        iScheduleService.wisdomExamSite(bo);
        return AjaxResult.success();
    }
}