DCDController.java 2.06 KB
package cn.fw.freya.controller;

import cn.fw.freya.model.data.pool.LivePool;
import cn.fw.freya.model.data.pool.VideoPool;
import cn.fw.freya.model.dto.rpc.ReportAccountDto;
import cn.fw.freya.service.crawl.impl.DongCheDiCrawl;
import lombok.RequiredArgsConstructor;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

/**
 * @author unknown
 * @version 1.0
 * @date 2022/2/14 23:41
 * @Description
 */
@Validated
@RequestMapping("/dongchedi")
@RestController
@RequiredArgsConstructor
public class DCDController {

    private final DongCheDiCrawl dongCheDiCrawl;

    /**
     * 获取所有'作品'信息, 并存库
     *
     * @param accountNo 账户号
     */
    @GetMapping("/getVideoInfo")
    public List<VideoPool> getVideoInfo(String accountNo) {
        return dongCheDiCrawl.getAllVideoMsg(accountNo);
    }

    /**
     * 获取昨天所有'直播'数据总览, 并存库
     *
     * @param accountNo 账户号
     */
    /*@GetMapping("/getLiveInfo")
    public LiveOverview getLiveInfo(String accountNo) {
        return dongCheDiCrawl.getYesterdayLiveOverview(accountNo);
    }*/

    /**
     * 获取昨天所有'直播'信息, 并存库
     *
     * @param accountNo 账户号
     */
    @GetMapping("/getYesterdayLiveMsg")
    public List<LivePool> getYesterdayLiveMsg(String accountNo) {
        return dongCheDiCrawl.getYesterdayLiveMsg(accountNo);
    }

    /**
     * 更新账户粉丝信息
     *
     * @param accountNo 账户号
     */
    @GetMapping("/updateAccountFans")
    public ReportAccountDto updateAccountFans(String accountNo) {
        return dongCheDiCrawl.updateAccountMsg(accountNo);
    }

    /**
     * 进入指定账户号的创作者平台首页
     *
     * @param accountNo 账户号
     */
    @GetMapping("/loginIndex")
    public void loginIndex(String accountNo) {
        dongCheDiCrawl.loginIndex(accountNo);
    }
}