package com.yeshi.fanli.controller;

import com.yeshi.fanli.entity.bus.user.UserActiveLog;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoModifyRecord.ModifyTypeEnum;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionAuthRecord;
import com.yeshi.fanli.exception.taobao.TaoBaoAuthException;
import com.yeshi.fanli.exception.user.UserExtraTaoBaoInfoException;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.log.LogManager;
import com.yeshi.fanli.log.LogType;
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;
import com.yeshi.fanli.service.inter.user.msg.UserAccountMsgNotificationService;
import com.yeshi.fanli.service.inter.user.tb.TaoBaoUnionAuthRecordService;
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.service.manger.user.TBAuthManager;
import com.yeshi.fanli.util.*;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import net.sf.json.JSONObject;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.Date;

/**
 * 授权回调
 *
 * @author Administrator
 */
@Controller
@RequestMapping("client/v1/auth/callback")
public class AuthCallBackController {

    @Resource
    private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;

    @Resource
    private UserAccountMsgNotificationService userAccountMsgNotificationService;

    @Resource
    private RedisManager redisManager;

    @Resource
    private UserActiveLogService userActiveLogService;

    @Resource
    private TBAuthManager tbAuthManager;


    private int processAuth(TBAuthManager.TaoBaoAuthOriginInfo taoBaoAuthOriginInfo, String code) {
        int errCode = 0;
        //判断用户ID
        if (taoBaoAuthOriginInfo.getUid() == null || taoBaoAuthOriginInfo.getUid().longValue() == 0L)
            return 3;
        //解析淘宝用户信息
        TBAuthManager.TaoBaoUserInfo taoBaoUserInfo = null;
        try {
            taoBaoUserInfo = TBAuthManager.parseTaoBaoUser(code);
        } catch (Exception e) {
            e.printStackTrace();
            LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
        }
        if (taoBaoUserInfo == null) {
            return 4;
        }

        //添加淘宝授权记录
        TaoBaoUnionAuthRecord record = new TaoBaoUnionAuthRecord();
        record.setUser(new UserInfo(taoBaoAuthOriginInfo.getUid()));
        record.setTaoBaoOpenUid(taoBaoUserInfo.getOpenUid());
        record.setTaoBaoUserId(taoBaoUserInfo.getTaoBaoUid());
        record.setTaoBaoUserNick(taoBaoUserInfo.getNickName());
        record.setCreateTime(new Date());
        taoBaoUnionAuthRecordService.addAuthRecord(record);


        switch (taoBaoAuthOriginInfo.getSource()) {
            case "zigou":
                try {
                    tbAuthManager.authSpecialId(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo);
                    return 0;
                } catch (TaoBaoAuthException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
                    if (e.getCode() == TaoBaoAuthException.CODE_NOT_REAL_NAME)
                        userAccountMsgNotificationService.taoBaoAuthFail(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo.getNickName(), "淘宝账号未实名");
                } catch (UserExtraTaoBaoInfoException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
                    e.printStackTrace();
                    return 5;
                }
                break;
            case "share":
                try {
                    tbAuthManager.authRelationId(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo);
                    return 0;
                } catch (TaoBaoAuthException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
                    if (e.getCode() == TaoBaoAuthException.CODE_NOT_REAL_NAME)
                        userAccountMsgNotificationService.taoBaoAuthFail(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo.getNickName(), "淘宝账号未实名");
                } catch (UserExtraTaoBaoInfoException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
                    e.printStackTrace();
                    return 5;
                }

                break;
            case "bind":
                try {
                    tbAuthManager.authSpecialId(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo);
                    tbAuthManager.authRelationId(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo);
                    return 0;
                } catch (TaoBaoAuthException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
//                    if (e.getCode() == TaoBaoAuthException.CODE_NOT_REAL_NAME)
                    userAccountMsgNotificationService.taoBaoAuthFail(taoBaoAuthOriginInfo.getUid(), taoBaoUserInfo.getNickName(), e.getMessage());
                } catch (UserExtraTaoBaoInfoException e) {
                    LogHelper.userInfo("淘宝授权出错：" + e.getMessage());
                    return 5;
                }
                break;
        }
        return errCode;
    }


    @RequestMapping(value = "tb")
    public void tb(String code, String state, HttpServletRequest request, HttpServletResponse response) {
        LogManager.getLogger(LogType.taobaoAuth).info("淘宝授权回调:" + code + "：" + state);
        if (StringUtil.isNullOrEmpty(code) || StringUtil.isNullOrEmpty(state)) {
            LogHelper.error("淘宝授权回调出错");
            try {
                response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html?code=1");
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            return;
        }

        try {
            String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.taobaoCode, code);
            if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key)))
                return;
            redisManager.cacheCommonString(key, 1 + "", 5);
        } catch (Exception e) {
        }

        int errCode = 0;
        //解密原始授权信息
        TBAuthManager.TaoBaoAuthOriginInfo taoBaoAuthOriginInfo = null;
        try {
            taoBaoAuthOriginInfo = TBAuthManager.decryptAuthOriginInfo(state);
        } catch (Exception e) {
        }
        if (taoBaoAuthOriginInfo == null) {
            errCode = 1;
        } else {
            if (System.currentTimeMillis() - taoBaoAuthOriginInfo.getTime() > 1000 * 60 * 10L) {
                // 过时
                errCode = 2;
            }
        }

        if (errCode == 0) {
            errCode = processAuth(taoBaoAuthOriginInfo, code);
        } else {
            //基础信息解析失败
            try {
                response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html?code=1");
            } catch (IOException e1) {
                e1.printStackTrace();
            }
            return;
        }
        // 计入记录
        UserActiveLog activeLog = userActiveLogService.getUserLatestActiveInfo(taoBaoAuthOriginInfo.getUid());

        boolean isNewJump = false;
        if (activeLog != null) {
            String platform = null;
            String version = activeLog.getVersionCode();
            if (activeLog.getChannel().equalsIgnoreCase("appstore")) {
                platform = "ios";
            } else {
                platform = "android";
            }
            if (VersionUtil.greaterThan_2_0(platform, version)) {
                isNewJump = true;
            }
        }

        try {
            if (errCode == 0)// 成功
            {
                if ("share".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/success.html");
                    else
                        closeWebPage(response.getWriter());
                } else if ("zigou".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/success.html");
                    else
                        closeWebPage(response.getWriter());
                } else if ("bind".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/success.html");
                    else {
                        String script = String.format(
                                "<script>if(/(iPhone|iPad|iPod|iOS)/i.test(navigator.userAgent)) {window.location.href = 'yestv://toast#%s';setTimeout(function(){window.location.href = 'yestv://finishPage';},100);} else {yestv.toast(\"恭喜你，淘宝绑定成功\");yestv.finishPage();}</script>",
                                StringUtil.getBase64String("恭喜你，淘宝绑定成功"));
                        response.getWriter().print(script);
                    }
                }
            } else {// 失败
                if ("share".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html");
                    else
                        closeWebPage(response.getWriter());
                } else if ("zigou".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html");
                    else
                        closeWebPage(response.getWriter());
                } else if ("bind".equalsIgnoreCase(taoBaoAuthOriginInfo.getSource())) {
                    if (isNewJump)
                        response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html");
                    else {
                        String script = String.format(
                                "<script>if(/(iPhone|iPad|iPod|iOS)/i.test(navigator.userAgent)) {window.location.href = 'yestv://toast#%s';setTimeout(function(){window.location.href = 'yestv://finishPage';},100);} else {yestv.toast(\"抱歉，淘宝绑定失败\");yestv.finishPage();}</script>",
                                StringUtil.getBase64String("抱歉，淘宝绑定失败"));
                        response.getWriter().print(script);
                    }
                }
            }
        } catch (Exception e) {
            LogHelper.errorDetailInfo(e);
        }
    }

    private void closeWebPage(PrintWriter out) {
        String script = "<script>if(/(iPhone|iPad|iPod|iOS)/i.test(navigator.userAgent)) {setTimeout(function(){window.location.href = 'yestv://finishPage';},100);} else {yestv.finishPage();}</script>";
        out.print(script);
    }

    @RequestMapping(value = "pinduoduo")
    public void pinDuoDuo(HttpServletResponse response) {

    }

}