package com.hollywood.applet.controller;


import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.hollywood.applet.dto.PerformanceJoinDto;
import com.hollywood.applet.dto.TrueOrFalse;
import com.hollywood.applet.query.TPerformerActivityQuery;
import com.hollywood.applet.query.TPerformerActivityUserQuery;
import com.hollywood.applet.query.TUserQuery;
import com.hollywood.applet.service.TPerformerActivityService;
import com.hollywood.applet.service.TPerformerActivityUserService;
import com.hollywood.applet.service.TUserService;
import com.hollywood.applet.utils.LoginInfoUtil;
import com.hollywood.common.basic.ApiResult;
import com.hollywood.common.basic.PageInfo;
import com.hollywood.common.exception.ServiceException;
import com.hollywood.common.model.TPerformerActivity;
import com.hollywood.common.model.TPerformerActivityUser;

import com.hollywood.common.model.TPopularActivityUser;
import com.hollywood.common.model.TUser;
import com.hollywood.common.redis.RedisAutoTemplate;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import java.time.LocalDateTime;
import java.time.LocalTime;
import java.time.temporal.ChronoUnit;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

/**
 * <p>
 * 演员活动 前端控制器
 * </p>
 *
 * @author xiaochen
 * @since 2024-02-29
 */
@Api(tags = "演员活动")
@RestController
@RequestMapping("/tPerformerActivity")
public class TPerformerActivityController {

    private final TPerformerActivityService performerActivityService;
    private final TPerformerActivityUserService performerActivityUserService;

    @Autowired
    private LoginInfoUtil loginInfoUtil;
    @Autowired
    private RedisAutoTemplate redisAutoTemplate;
    @Autowired
    private TUserService userService;


    @Autowired
    public TPerformerActivityController(TPerformerActivityService performerActivityService, TPerformerActivityUserService performerActivityUserService) {
        this.performerActivityService = performerActivityService;
        this.performerActivityUserService = performerActivityUserService;
    }

    /**
     * 获取演员活动列表
     */
    @ApiOperation(value = "获取演员活动分页列表")
    @PostMapping(value = "/pageList")
    public ApiResult<PageInfo<TPerformerActivity>> pageList(@RequestBody TPerformerActivityQuery query) {
        Long userId = loginInfoUtil.getUserId();
        List<Long> ids = new ArrayList<>();
        if (query.getMine()!=null&&query.getMine()==1){
            List<TPerformerActivityUser> list = performerActivityUserService.list(Wrappers.lambdaQuery(TPerformerActivityUser.class)
                    .eq(TPerformerActivityUser::getUserId, userId).eq(TPerformerActivityUser::getIsPay,2));

            ids = list.stream()
                    .map(TPerformerActivityUser::getActivityId)
                    .collect(Collectors.toList());
            if (ids.isEmpty()){
                return ApiResult.success(new PageInfo<>());
            }
        }

        return ApiResult.success(performerActivityService.pageList(query,ids));
    }
    @ApiOperation(value = "演员活动-立即投票前获取可投票数")
    @GetMapping(value = "/vote-get/{acId}")
    public ApiResult voteGet(@PathVariable Long acId) {
        Long userId = loginInfoUtil.getUserId();
        TPerformerActivity byId = performerActivityService.getById(acId);
        if (byId.getVoteType()==1){
            String str = redisAutoTemplate.getStr(byId.getId() + ":" + userId + ":vote");
            if (str==null){
                redisAutoTemplate.setStr(byId.getId() + ":" + userId + ":vote", String.valueOf(byId.getVoteCount()));
                str= String.valueOf(byId.getVoteCount());
                return ApiResult.success(str);
            }else {
                return ApiResult.success(redisAutoTemplate.getStr(byId.getId() + ":" + userId + ":vote"));
            }
        }else{
            String str = redisAutoTemplate.getStr(byId.getId() + ":" + userId + ":vote");
            if (str==null){
                LocalTime currentTime = LocalTime.now();
                // 获取凌晨12点时间
                LocalTime midnight = LocalTime.of(0, 0);
                // 计算当前时间到凌晨12点的秒数差
                long secondsUntilMidnight = getSecondsUntilEndOfDay();
                redisAutoTemplate.setStr(byId.getId() + ":" + userId + ":vote", String.valueOf(byId.getVoteCount()),secondsUntilMidnight);
                str= String.valueOf(byId.getVoteCount());
                return ApiResult.success(str);
            }else {
                return ApiResult.success(redisAutoTemplate.getStr(byId.getId() + ":" + userId + ":vote"));
            }
        }

    }


    @ApiOperation(value = "演员推荐-立即投票前获取可投票数")
    @GetMapping(value = "/vote")
    public ApiResult vote() {
        Long userId = loginInfoUtil.getUserId();
            String str = redisAutoTemplate.getStr( userId + ":vote");
        if (str==null) {
            LocalTime currentTime = LocalTime.now();
            // 获取凌晨12点时间
            LocalTime midnight = LocalTime.of(0, 0);
            // 计算当前时间到凌晨12点的秒数差
            long secondsUntilMidnight = getSecondsUntilEndOfDay();
            redisAutoTemplate.setStr( userId + ":vote","10" , secondsUntilMidnight);
            str = String.valueOf(10);
        }
            return ApiResult.success(str);
    }
    public static long getSecondsUntilEndOfDay() {
        LocalDateTime currentTime = LocalDateTime.now();
        LocalDateTime endOfDay = LocalDateTime.of(currentTime.toLocalDate(), LocalTime.MAX);

        long remainingSeconds = currentTime.until(endOfDay, ChronoUnit.SECONDS);

        return remainingSeconds;
    }

    @ApiOperation(value = "演员推荐-投票操作")
    @GetMapping(value = "/vote-num")
    public ApiResult voteUser(Integer num,Long acId) {
        Long userId = loginInfoUtil.getUserId();
        TUser byId = userService.getById(userId);
        TrueOrFalse trueOrFalse = new TrueOrFalse();
        LocalDateTime currentTime = LocalDateTime.now();
        Date date = new Date();
        if (byId.getVipType()==3|| byId.getEndTime().isBefore(currentTime)){
           throw new ServiceException("当前活动仅限会员参与");
        }



//
//        Long userId = loginInfoUtil.getUserId();
//
//        TUser byId = userService.getById(acId);

        String str = redisAutoTemplate.getStr(userId + ":vote");
        Integer i = Integer.valueOf(str);
        int i1 = i - num;
        // 计算当前时间到凌晨12点的秒数差
        long secondsUntilMidnight = getSecondsUntilEndOfDay();
        redisAutoTemplate.setStr( userId + ":vote", String.valueOf(i1),secondsUntilMidnight);
        //改变演员的投票数量
        TUser byId1 = userService.getById(acId);
        Integer voteCount1 = byId1.getHot();
        if (voteCount1==null){
            voteCount1=1;
        }else {
            voteCount1 = voteCount1+num;
        }
        byId1.setHot(voteCount1);
        userService.updateById(byId1);
        return ApiResult.success();
    }





    @ApiOperation(value = "活动列表-投票操作")
    @GetMapping(value = "/vote-list")
    public ApiResult vote( Long peId, Integer num) {
        Long userId = loginInfoUtil.getUserId();
        TUser byId2 = userService.getById(userId);
        TrueOrFalse trueOrFalse = new TrueOrFalse();
        LocalDateTime currentTime = LocalDateTime.now();
        Date date = new Date();
        if (byId2.getVipType()==3|| byId2.getEndTime().isBefore(currentTime)){
            throw new ServiceException("当前活动仅限会员参与");
        }








//        Long userId = loginInfoUtil.getUserId();
        TPerformerActivityUser byId1 = performerActivityUserService.getById(peId);

        TPerformerActivity byId = performerActivityService.getById(byId1.getActivityId());
        redisAutoTemplate.addSet("performer:hot:"+byId.getId(), userId);
//        LocalDateTime currentTime = LocalDateTime.now();
        if (byId.getStatus()==2){
            throw new ServiceException("当前活动已下架");
        }
        if (byId.getEndTime().isBefore(currentTime)){
            throw new ServiceException("当前活动已结束");
        }

        long secondsUntilMidnight = getSecondsUntilEndOfDay();

        String str = redisAutoTemplate.getStr(byId.getId() + ":" + userId + ":vote");
        Integer i = Integer.valueOf(str);
        int i1 = i - num;
        if (i1<0){
            return ApiResult.failed("票数不足,请重试");
        }
        if (byId.getVoteType()==1) {
            redisAutoTemplate.setStr(byId.getId() + ":" + userId + ":vote", String.valueOf(i1));
        }else {
            redisAutoTemplate.setStr(byId.getId() + ":" + userId + ":vote", String.valueOf(i1),secondsUntilMidnight);

        }
        //改变活动投票数量
//        Integer voteCount = byId.getVoteCount();
//        if (voteCount==null){
//            voteCount=num;
//        }else {
//            voteCount = voteCount+num;
//        }
//        byId.setVoteCount(voteCount);
//        performerActivityService.updateById(byId);
        //改变演员的投票数量
        Integer voteCount1 = byId1.getGainVotesCount();
        if (voteCount1==null){
            voteCount1=num;
        }else {
            voteCount1 = voteCount1+num;
        }
        byId1.setGainVotesCount(voteCount1);
        performerActivityUserService.updateById(byId1);
        return ApiResult.success();
    }




    /**
     * 获取演员活动参与人员列表
     */
    @ApiOperation(value = "获取演员活动参与人员列表")
    @PostMapping(value = "/userJoin")
    public ApiResult<PageInfo<TPerformerActivityUser>> userPageList(@Validated @RequestBody TPerformerActivityUserQuery query) {
        return ApiResult.success(performerActivityUserService.userPageList(query));
    }


    /**
     * 查看演员活动详情
     */
    @ApiOperation(value = "查看演员活动详情")
    @GetMapping(value = "/getDetailById")
    public ApiResult<TPerformerActivity> getDetailById(@RequestParam Long id) {
        Long userId = loginInfoUtil.getUserId();
        TPerformerActivity byId = performerActivityService.getById(id);
        List<TPerformerActivityUser> list = performerActivityUserService.list(Wrappers.lambdaQuery(TPerformerActivityUser.class).eq(TPerformerActivityUser::getIsPay,2).eq(TPerformerActivityUser::getUserId, userId).eq(TPerformerActivityUser::getActivityId,byId.getId()));
        if (!list.isEmpty()){
            byId.setIsJoin(1);
        }
        List<TPerformerActivityUser> count = performerActivityUserService.list(Wrappers.lambdaQuery(TPerformerActivityUser.class).eq(TPerformerActivityUser::getActivityId,byId.getId()));
        byId.setHot(redisAutoTemplate.getSet("performer:hot:"+byId.getId()).size());
        return ApiResult.success(byId);
    }
    @ApiOperation(value = "查看演员详情")
    @GetMapping(value = "/getPerformById")
    public ApiResult<TPerformerActivityUser> getPerformById(@RequestParam Long id) {
        return ApiResult.success(performerActivityUserService.getById(id));
    }

    @ApiOperation(value = "参加演员活动")
    @PostMapping(value = "/join")
    public ApiResult join(@RequestBody PerformanceJoinDto performanceJoinDto) throws Exception {

        Long userId = loginInfoUtil.getUserId();
        TUser byId = userService.getById(userId);
        TrueOrFalse trueOrFalse = new TrueOrFalse();
        LocalDateTime currentTime = LocalDateTime.now();
        Date date = new Date();
        if (byId.getVipType() == 3 || byId.getEndTime().isBefore(currentTime)) {
            return ApiResult.failed("仅限会员报名");
        }

        TPerformerActivity byId1 = performerActivityService.getById(performanceJoinDto.getAcId());

        if (byId1.getStatus() == 2) {
            return ApiResult.failed("当前活动已下架");
        }
        if (byId1.getRegistrationDeadlineTime() != null && byId1.getRegistrationDeadlineTime().isBefore(currentTime)) {
            return ApiResult.failed("当前活动已到截至报名时间");
//                throw new ServiceException("当前活动已到截至报名时间");
        }
        if (byId1.getEndTime().isBefore(currentTime)) {
            return ApiResult.failed("当前活动已结束");
//                throw new ServiceException("当前活动已结束");
        }


        List<TPerformerActivityUser> list = performerActivityUserService.list(Wrappers.lambdaQuery(TPerformerActivityUser.class).eq(TPerformerActivityUser::getIsPay, 2).eq(TPerformerActivityUser::getUserId, userId).eq(TPerformerActivityUser::getActivityId, performanceJoinDto.getAcId()));
        if (!list.isEmpty()) {
            return ApiResult.failed("当前用户已报名");
        }
      return   performerActivityService.join(performanceJoinDto, userId);


}

    @ApiOperation(value = "获取演员推荐列表")
    @PostMapping(value = "/userPageList")
    public ApiResult<PageInfo<TUser>> userPageList(@RequestBody TUserQuery query) {
        return ApiResult.success(userService.userPageList(query));
    }
    @ApiOperation(value = "成为演员")
    @PostMapping(value = "/toBeAC")
    public ApiResult toBeAC(@RequestBody TUser user) {
        user.setId(loginInfoUtil.getUserId());
        user.setAuditStatus(1);
        userService.updateById(user);
        return ApiResult.success();
    }

    @ApiOperation(value = "编辑演员")
    @PostMapping(value = "/editAC")
    public ApiResult editAC(@RequestBody TUser user) {
        userService.updateById(user);
        return ApiResult.success();
    }


    @ApiOperation(value = "获取用户详情（演员管理详情，演员审核详情通用）")
    @GetMapping(value = "/getUserDetailById")
    public ApiResult<TUser> getUserDetailById(@RequestParam Long id) {
        TUser byId = userService.getById(id);

        return ApiResult.success(byId);

    }




}