package com.hollywood.applet.controller;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hollywood.applet.dto.PutVideoDto;
import com.hollywood.applet.dto.ReportDto;
import com.hollywood.applet.service.TVideoReportService;
import com.hollywood.applet.service.TVideoService;
import com.hollywood.applet.utils.LoginInfoUtil;
import com.hollywood.common.basic.ApiResult;
import com.hollywood.common.basic.PageInfo;
import com.hollywood.common.model.TInformation;
import com.hollywood.common.model.TShortPlay;
import com.hollywood.common.model.TVideo;
import com.hollywood.common.model.TVideoReport;
import com.hollywood.common.redis.RedisAutoTemplate;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.models.auth.In;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;

import java.util.List;
import java.util.Set;

/**
 * <p>
 * 短视频管理 前端控制器
 * </p>
 *
 * @author xiaochen
 * @since 2024-02-29
 */
@RestController
@RequestMapping("/tVideo")
@Api(tags = "短视频")
public class TVideoController {
    @Autowired
    private LoginInfoUtil loginInfoUtil;
    @Autowired
    private RedisAutoTemplate redisAutoTemplate;
    @Autowired
    private TVideoService videoService;
    @Autowired
    private TVideoReportService reportService;

    @ApiOperation(value = "观看短视频接口")
    @PutMapping("/watch")
    public ApiResult watch(Long videoId)
    {
        Long userId = loginInfoUtil.getUserId();
//        redisAutoTemplate.addList(userId+":user:history:",videoId);
//        Set<Object> set = redisAutoTemplate.getSet(String.valueOf(userId));

        String str = redisAutoTemplate.getStr(videoId + ":views:");
        if (str ==null) {
            redisAutoTemplate.setStr(videoId + ":views:", "1");
        }else {
            String str1 = redisAutoTemplate.getStr(videoId + ":views:");
            redisAutoTemplate.setStr(videoId + ":views:", String.valueOf(Integer.parseInt(str1)+1));
        }

//        System.err.println(set);
        return ApiResult.success();
    }
    @ApiOperation(value = "短视频点赞")
    @PutMapping("/good")
    public ApiResult good(Long videoId)
    {
        Long userId = loginInfoUtil.getUserId();
        redisAutoTemplate.addSet(userId+":user:good:",videoId);
        redisAutoTemplate.addSet(videoId+":video:good:",userId);
        Set<Object> set = redisAutoTemplate.getSet(String.valueOf(userId));
        System.err.println(set);

        return ApiResult.success();
    }
    @ApiOperation(value = "短视频取消点赞")
    @PutMapping("/cancelgood")
    public ApiResult cancelgood(Long videoId)
    {
        Long userId = loginInfoUtil.getUserId();
//        redisAutoTemplate.removeZSet(userId+":user:good:",videoId);
        redisAutoTemplate.setRemove(userId+":user:good:",videoId);
//        redisAutoTemplate.removeZSet(videoId+":video:good:",userId);
        redisAutoTemplate.setRemove(videoId+":video:good:",userId);
        Set<Object> set = redisAutoTemplate.getSet(String.valueOf(userId));
        System.err.println(set);

        return ApiResult.success();
    }


    @ApiOperation(value = "获取十个推荐视频,刷十次调一次这个接口")
    @PutMapping("/get")
    public ApiResult<List<TVideo>> get()
    {
        Long userId = loginInfoUtil.getUserId();
        Set<Long> userVedio = redisAutoTemplate.getSet(userId+":user:history:");
        QueryWrapper<TVideo> id = new QueryWrapper<TVideo>().eq("status",1).eq("isDelete",0).orderByDesc("createTime").last("limit 10");
        if (!userVedio.isEmpty()){
            id.notIn("id", userVedio);
        }
        List<TVideo> vedios = videoService.list(id);
        if (vedios.size()<10){
            Integer num = 10-vedios.size();
            List<TVideo> list = videoService.list(Wrappers.lambdaQuery(TVideo.class).eq(TVideo::getStatus,1).eq(TVideo::getIsDelete,0).last("ORDER BY RAND() limit " + num));
            vedios.addAll(list);
        }
        //获取用户的点赞记录
        Set<Long> goods = redisAutoTemplate.getSet(userId+":user:good:");
        for (TVideo vedio : vedios) {
            //获取该视频的点赞用户
            Set<Long> goodsUser = redisAutoTemplate.getSet(vedio.getId()+":video:good:");
            vedio.setLikeCount(goodsUser.size());
            //判断当前用户是否点赞该视频
            if (goods!=null&&goods.contains(vedio.getId().intValue())){
                vedio.setIsGood(1);
            }else {
                vedio.setIsGood(0);
            }
            String str = redisAutoTemplate.getStr(vedio.getId() + ":views:");
            if (str != null && str.isEmpty()) {
                vedio.setViews(0);
            }else {
                if (str != null) {
                    vedio.setViews(Integer.valueOf(str));
                }
            }
        }
        return  ApiResult.success(vedios);
    }


    @ApiOperation(value = "获取已发布视频")
    @PutMapping("/get-has")
    public ApiResult<PageInfo<TVideo>> getHas(@RequestParam int pageNum,
                                          @RequestParam int  pageSize)
    {
        Long userId = loginInfoUtil.getUserId();
        PageInfo<TVideo> pageInfo = new PageInfo<>(pageNum, pageSize);
        List<TVideo> vedios = videoService.list(new QueryWrapper<TVideo>().eq("userId",userId).eq("status",1));
        //获取用户的点赞记录
        Set<Long> goods = redisAutoTemplate.getSet(userId+":user:good:");
        for (TVideo vedio : vedios) {
            //获取该视频的点赞用户
            Set<Integer> goodsUser = redisAutoTemplate.getSet(vedio.getId()+":video:good:");
            vedio.setLikeCount(goodsUser.size());
            //判断当前用户是否点赞该视频
            if (goods!=null&&goods.contains(vedio.getId().intValue())){
                vedio.setIsGood(1);
            }else {
                vedio.setIsGood(0);
            }
            String str = redisAutoTemplate.getStr(vedio.getId() + ":views:");
            if (str != null && str.isEmpty()) {
                vedio.setViews(0);
            }else {
                if (str != null) {
                    vedio.setViews(Integer.valueOf(str));
                }
            }
        }
        pageInfo.setRecords(vedios);

        return  ApiResult.success(pageInfo);
    }

    @ApiOperation(value = "发布视频")
    @PutMapping("/put")
    public ApiResult<TVideo> put(@RequestBody PutVideoDto title)
    {
        Long userId = loginInfoUtil.getUserId();
        TVideo tVideo = new TVideo();
            tVideo.setVideoTitle(title.getTitle());
            tVideo.setVideoFile(title.getUrl());
            tVideo.setUserId(userId);
        tVideo.setStatus(1);
            videoService.save(tVideo);
        return  ApiResult.success(tVideo);
    }

    @ApiOperation(value = "删除视频")
    @PostMapping("/delete/{id}")
    public ApiResult delete(@PathVariable Long id)
    {
        videoService.removeById(id);
        return ApiResult.success();
    }


    @ApiOperation(value = "举报视频")
    @PostMapping("/report")
    public ApiResult report(@RequestBody ReportDto reportDto)
    {
        Long userId = loginInfoUtil.getUserId();
        TVideoReport tVideoReport = new TVideoReport();
        BeanUtils.copyProperties(reportDto,tVideoReport);
        tVideoReport.setUserId(userId);


        reportService.save(tVideoReport);
        return ApiResult.success();

    }





}