package com.topdraw.business.process.rest;

import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.druid.support.json.JSONUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.topdraw.annotation.AnonymousAccess;
import com.topdraw.annotation.Log;
import com.topdraw.business.module.member.profile.domain.MemberProfile;
import com.topdraw.business.module.member.service.dto.MemberDTO;
import com.topdraw.business.module.user.iptv.domain.UserTv;
import com.topdraw.business.module.user.iptv.service.dto.UserTvDTO;
import com.topdraw.business.module.user.weixin.domain.UserWeixin;
import com.topdraw.business.module.user.weixin.service.dto.UserWeixinDTO;
import com.topdraw.business.process.domian.TempIptvUser;
import com.topdraw.business.process.domian.UnbindGroup;
import com.topdraw.business.process.domian.weixin.SubscribeBean;
import com.topdraw.business.process.domian.weixin.SubscribeBeanEvent;
import com.topdraw.business.process.domian.weixin.WeiXinUserBean;
import com.topdraw.business.process.service.UserOperationService;
import com.topdraw.common.ResultInfo;
import com.topdraw.config.RedisKeyUtil;
import com.topdraw.exception.BadRequestException;
import com.topdraw.module.mq.DataSyncMsg;
import com.topdraw.util.JSONUtil;
import com.topdraw.utils.RedisUtils;
import com.topdraw.utils.StringUtils;
import com.topdraw.weixin.util.WeChatConstants;
import com.topdraw.weixin.util.WeiXinRequestUtil;
import com.topdraw.weixin.util.WeixinUtil;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;

import java.io.IOException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;

@Api("账户处理")
@RestController
@RequestMapping(value = "/ucEngine/api/userOperation")
@Slf4j
public class UserOperationController {

    @Autowired
    private UserOperationService userTvOperationService;
    @Autowired
    private WeiXinRequestUtil weixinRequestUtil;
    @Autowired
    private RedisUtils redisUtils;

    @Log("获取大屏绑定的小屏会员列表")
    @GetMapping(value = "/findBindByPlatformAccount/{platformAccount}")
    @AnonymousAccess
    public ResultInfo findBindByPlatformAccount(@PathVariable("platformAccount") String platformAccount) {
        log.info("resources :[{}]",platformAccount);
        List<MemberDTO> result = this.userTvOperationService.findBindByPlatformAccount(platformAccount);
        return ResultInfo.success(result);
    }

    @Log("带参二维码")
    @PostMapping(value = "/sendQrCodeMessage")
    @ApiOperation("带参二维码")
    @AnonymousAccess
    public ResultInfo sendQrCodeMessage(@RequestBody String content) {
        log.info("resources :[{}]",content);
        boolean result = this.userTvOperationService.sendQrCodeMessage(content);
        return ResultInfo.success(result);
    }

    @Log("删除全部收藏")
    @PostMapping(value = "/deleteAllCollection")
    @ApiOperation("删除全部收藏")
    @AnonymousAccess
    public ResultInfo deleteAllCollection(@RequestBody String content) {
        log.info("resources :[{}]",content);
        boolean result = this.userTvOperationService.deleteAllCollection(content);
        return ResultInfo.success(result);
    }

    @Log("删除收藏")
    @PostMapping(value = "/deleteCollection")
    @ApiOperation("删除收藏")
    @AnonymousAccess
    public ResultInfo deleteCollection(@RequestBody String content) {
        log.info("resources :[{}]",content);
        boolean result = this.userTvOperationService.deleteCollection(content);
        return ResultInfo.success(result);
    }

    @Log("添加收藏")
    @PostMapping(value = "/addCollection")
    @ApiOperation("添加收藏")
    @AnonymousAccess
    public ResultInfo addCollection(@RequestBody String content) {
        log.info("resources :[{}]",content);
        boolean result = this.userTvOperationService.addCollection(content);
        return ResultInfo.success(result);
    }

    @Log("新增大屏账户同时创建会员信息")
    @PostMapping(value = "/createUserAndCreateMember")
    @ApiOperation("新增大屏账户同时创建会员信息")
    @AnonymousAccess
    public ResultInfo createUserAndCreateMember(@Validated @RequestBody TempIptvUser resources) {
        UserTv userTv = new UserTv();
        BeanUtils.copyProperties(resources,userTv);
        this.userTvOperationService.createMemberByUserTv(userTv);
        return ResultInfo.success();
    }

    @Log("大屏用户解绑")
    @PutMapping(value = "/unbind")
    @ApiOperation("大屏用户解绑")
    public ResultInfo unbind(@Validated(value = {UnbindGroup.class}) @RequestBody TempIptvUser resources) {
        UserTv userTv = new UserTv();
        BeanUtils.copyProperties(resources,userTv);
        this.userTvOperationService.unbind(userTv);
        return ResultInfo.success();
    }

    @Log("大屏更换主账号")
    @PutMapping(value = "/changeMainAccount")
    @ApiOperation("大屏更换主账号")
    public ResultInfo changeMainAccount(@Validated(value = {UnbindGroup.class}) @RequestBody TempIptvUser resources) {
        UserTv userTv = new UserTv();
        BeanUtils.copyProperties(resources,userTv);
        this.userTvOperationService.changeMainAccount(userTv);
        return ResultInfo.success("update success");
    }

    @Log("微信小程序登录")
    @PostMapping("/appletLogin")
    @ApiOperation("微信小程序登录")
    @AnonymousAccess
    public ResultInfo appletLogin(@Validated @RequestBody WeiXinUserBean resources) {
        UserWeixinDTO result = this.userTvOperationService.appletLogin(resources);
        return ResultInfo.success(result);
    }

    @Log("微信公众号关注")
    @PostMapping("/subscribe")
    @ApiOperation("微信公众号关注")
    @AnonymousAccess
    public ResultInfo subscribe(@Validated @RequestBody SubscribeBeanEvent data) throws IOException {
        String content = data.getContent();
        SubscribeBean subscribeBean = JSONUtil.parseMsg2Object(content, SubscribeBean.class);

        this.parseSubscribe(subscribeBean);

        boolean result = this.userTvOperationService.subscribe(subscribeBean);
        return ResultInfo.success(result);
    }


    private void parseSubscribe(SubscribeBean subscribeBean) throws IOException {
        if (Objects.nonNull(subscribeBean)) {

            String appId = subscribeBean.getAppId();
            // appId不得为空
            if (StringUtils.isBlank(appId))
                throw new BadRequestException("appId 不存在!");

            // openId
            String openId = subscribeBean.getOpenId();
            if (StringUtils.isBlank(openId))
                throw new BadRequestException("openId 不存在!");

            // unionId
            String unionId = null;

            // 匹配配置文件中的微信列表信息
            Map<String, String> wxInfoMap = WeixinUtil.getWeixinInfoByAppid(appId);

            if (Objects.nonNull(wxInfoMap)) {
                // 程序类型
                String appType = wxInfoMap.get("appType");
                // 非订阅号，暂不处理。返回暂不支持
                if (ObjectUtil.notEqual(appType, WeChatConstants.WX_SUBSCRIPTION))
                    throw new BadRequestException("非订阅号");

                // 用户类型
                JSONObject userInfo = weixinRequestUtil.getUserInfo(wxInfoMap, openId);
                log.info("userInfo is : {}", userInfo.toJSONString());
                unionId = userInfo.get("unionid").toString();

                if (StringUtils.isBlank(unionId))
                    throw new BadRequestException("unionid 不存在!");
            }

            // unionId不得为空
            if (StringUtils.isBlank(unionId))
                throw new BadRequestException("unionId 不存在!");

            subscribeBean.setUnionId(unionId);

            // 大屏账户信息
            JSONObject iptvUserInfo = null;
            // 缓存的大屏信息，使用unionid即可
            String content = (String) this.redisUtils.get(RedisKeyUtil.genSeSuSubscribeKey(unionId));
            if (StringUtils.isNotBlank(content)) {
                // 大屏信息
               iptvUserInfo = JSONObject.parseObject(content);

            } else {

                String eventKey = subscribeBean.getEventKey();
                // 用户扫描带参二维码关注。发消息
                // 去除固定前缀，获取二维码参数
                eventKey = eventKey.substring(8);
                iptvUserInfo = com.alibaba.fastjson.JSONObject.parseObject(eventKey);

            }

            // 用户自己搜索关注就没有大屏信息的话，否则表示扫码关注
            if (Objects.nonNull(iptvUserInfo)) {
                subscribeBean.setIptvUserInfo(iptvUserInfo);
            }


            // 之后删除缓存信息
            this.redisUtils.del(RedisKeyUtil.genSeSuSubscribeKey(unionId));

        }
    }

    @Log("微信公众号取关")
    @PostMapping("/unsubscribe")
    @ApiOperation("微信公众号取关")
    @AnonymousAccess
    public ResultInfo unsubscribe(@Validated @RequestBody SubscribeBeanEvent data) {
        String content = data.getContent();
        SubscribeBean subscribeBean = JSONUtil.parseMsg2Object(content, SubscribeBean.class);
        boolean result = this.userTvOperationService.unsubscribe(subscribeBean);
        return ResultInfo.success(result);
    }

    /**
     * @param data
     * @description 通过大屏关注的订阅号，因为订阅号不支持带参二维码，
     * 所以需要先跳到H5（带大屏参数），
     * 再做服务号授权（订阅号只能按钮触发获取信息），
     * 再将服务号信息和大屏参数缓存下来（该接口的功能）
     * 然后跳转到订阅号关注页
     * 关注后回调处理时，根据unionid进行相关逻辑
     * @author Hongyan Wang
     * @date 2021/8/24 4:54 下午
     */
    @Log("保存大屏侧信息")
    @PostMapping(value = "/saveUserInfo")
    @ApiOperation("保存大屏侧信息")
    @AnonymousAccess
    public ResultInfo saveUserInfo(@RequestBody String data) {
        log.info("resources :[{}]",data);
        String s = this.userTvOperationService.saveUserInfo(data);
        return ResultInfo.success(s);
    }

    @Log("保存用户手机号信息")
    @PostMapping(value = "/saveUserWeixinPhone")
    @ApiOperation("保存用户手机号信息")
    public ResultInfo saveUserWeixinPhone(@RequestBody WeiXinUserBean resources) {
        log.info("resources :[{}]",resources);
        MemberProfile s = this.userTvOperationService.saveUserWeixinPhone(resources);
        return ResultInfo.success(s);
    }



}