package com.yeshi.fanli.controller;
|
|
import java.io.IOException;
|
import java.io.PrintWriter;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.util.Date;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
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.util.AESUtil;
|
import com.yeshi.fanli.util.Constant;
|
import com.yeshi.fanli.util.RedisKeyEnum;
|
import com.yeshi.fanli.util.RedisManager;
|
import com.yeshi.fanli.util.StringUtil;
|
import com.yeshi.fanli.util.TaoBaoConstant;
|
import com.yeshi.fanli.util.ThreadUtil;
|
import com.yeshi.fanli.util.VersionUtil;
|
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
|
|
import net.sf.json.JSONObject;
|
|
/**
|
* 授权回调
|
*
|
* @author Administrator
|
*
|
*/
|
@Controller
|
@RequestMapping("client/v1/auth/callback")
|
public class AuthCallBackController {
|
|
@Resource
|
private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;
|
|
@Resource
|
private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;
|
|
@Resource
|
private UserAccountMsgNotificationService userAccountMsgNotificationService;
|
|
@Resource
|
private UserInfoModifyRecordService userInfoModifyRecordService;
|
|
@Resource
|
private RedisManager redisManager;
|
|
@Resource
|
private UserActiveLogService userActiveLogService;
|
|
@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) {
|
|
}
|
|
String stateStr = null;
|
Long time = null;
|
Long uid = null;
|
String source = null;
|
try {
|
stateStr = AESUtil.decrypt(state, Constant.UIDAESKEY);
|
JSONObject json = JSONObject.fromObject(stateStr);
|
time = json.optLong("t");
|
uid = json.optLong("u");
|
source = json.optString("s");
|
} catch (Exception e) {
|
try {
|
state = URLDecoder.decode(state, "UTF-8");
|
} catch (UnsupportedEncodingException e1) {
|
e1.printStackTrace();
|
}
|
stateStr = AESUtil.decrypt(state, Constant.UIDAESKEY);
|
JSONObject json = JSONObject.fromObject(stateStr);
|
time = json.optLong("t");
|
uid = json.optLong("u");
|
source = json.optString("s");
|
}
|
|
LogManager.getLogger(LogType.taobaoAuth).info("淘宝授权回调state:" + state);
|
|
LogManager.getLogger(LogType.taobaoAuth).info("淘宝授权回调解密:" + stateStr);
|
|
int errCode = 0;
|
if (StringUtil.isNullOrEmpty(stateStr)) {
|
// 解密错误
|
errCode = 1;
|
}
|
|
if (System.currentTimeMillis() - time > 1000 * 60 * 10L) {
|
// 过时
|
errCode = 2;
|
}
|
if (uid == null || uid.longValue() == 0L)
|
errCode = 3;
|
|
// 计入记录
|
|
try {
|
String result = TaoKeApiUtil.getAccessToken(code, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
JSONObject data = JSONObject.fromObject(result);
|
data = data.optJSONObject("top_auth_token_create_response").optJSONObject("token_result");
|
String accessToken = data.optString("access_token");
|
String openUid = data.optString("taobao_open_uid");
|
String taoBaoUid = data.optString("taobao_user_id");
|
String nickName = data.optString("taobao_user_nick");
|
try {
|
nickName = URLDecoder.decode(nickName, "UTF-8");
|
} catch (Exception e) {
|
}
|
final String name = nickName;
|
LogManager.getLogger(LogType.taobaoAuth).info("uid:" + uid + "\n accessToken:" + accessToken);
|
|
// 获取渠道ID与会员ID
|
if ("share".equalsIgnoreCase(source)) {
|
String relationId = null;
|
|
try {
|
relationId = TaoKeApiUtil.getRelationId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);// 渠道ID
|
} catch (TaoBaoAuthException e) {
|
LogManager.getLogger(LogType.taobaoAuth).error(uid + "渠道备案失败:" + e.getMessage());
|
if (e.getCode() == TaoBaoAuthException.CODE_NOT_REAL_NAME)
|
userAccountMsgNotificationService.taoBaoAuthFail(uid, name, "淘宝账号未实名");
|
}
|
|
try {
|
userExtraTaoBaoInfoService.addRelationId(uid, relationId, taoBaoUid, nickName, true);
|
} catch (UserExtraTaoBaoInfoException e) {
|
LogHelper.test(e.getMsg());
|
errCode = 5;
|
}
|
|
final String relationId2 = relationId;
|
// 异步申请会员ID
|
final Long fuid = uid;
|
ThreadUtil.run(new Runnable() {
|
|
@Override
|
public void run() {
|
String specialId = null;
|
try {
|
specialId = TaoKeApiUtil.getSpecialId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
} catch (TaoBaoAuthException e1) {
|
LogManager.getLogger(LogType.taobaoAuth).error(fuid + "会员备案失败:" + e1.getMessage());
|
}
|
|
try {
|
userExtraTaoBaoInfoService.addSpecialId(fuid, specialId, taoBaoUid, name, true);
|
|
if (!StringUtil.isNullOrEmpty(specialId) && !StringUtil.isNullOrEmpty(relationId2))
|
userInfoModifyRecordService.addModifyRecord(fuid, ModifyTypeEnum.bindTaoBao, taoBaoUid);
|
} catch (UserExtraTaoBaoInfoException e) {
|
LogHelper.test(e.getMsg());
|
}
|
}
|
});
|
|
// 稍作延迟
|
Thread.sleep(50);
|
} else if ("zigou".equalsIgnoreCase(source)) {
|
String specialId = null;
|
|
try {
|
specialId = TaoKeApiUtil.getSpecialId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
} catch (TaoBaoAuthException e) {
|
if (e.getCode() == TaoBaoAuthException.CODE_NOT_REAL_NAME)
|
userAccountMsgNotificationService.taoBaoAuthFail(uid, name, "淘宝账号未实名");
|
LogManager.getLogger(LogType.taobaoAuth).error(uid + "会员备案失败:" + e.getMessage());
|
}
|
|
try {
|
userExtraTaoBaoInfoService.addSpecialId(uid, specialId, taoBaoUid, nickName, true);
|
} catch (UserExtraTaoBaoInfoException e) {
|
LogHelper.test(e.getMsg());
|
errCode = 5;
|
}
|
final Long fuid = uid;
|
|
final String specialId2 = specialId;
|
// 异步申请渠道ID
|
ThreadUtil.run(new Runnable() {
|
|
@Override
|
public void run() {
|
String relationId = null;
|
try {
|
relationId = TaoKeApiUtil.getRelationId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
} catch (TaoBaoAuthException e1) {
|
LogManager.getLogger(LogType.taobaoAuth).error(fuid + "渠道备案失败:" + e1.getMessage());
|
}
|
try {
|
userExtraTaoBaoInfoService.addRelationId(fuid, relationId, taoBaoUid, name, true);
|
|
if (!StringUtil.isNullOrEmpty(specialId2) && !StringUtil.isNullOrEmpty(relationId))
|
userInfoModifyRecordService.addModifyRecord(fuid, ModifyTypeEnum.bindTaoBao, taoBaoUid);
|
} catch (UserExtraTaoBaoInfoException e) {
|
LogHelper.test(e.getMsg());
|
}
|
}
|
});
|
// 稍作延迟
|
Thread.sleep(50);
|
|
} else if ("bind".equalsIgnoreCase(source)) {
|
|
boolean bindInfo = true;
|
// 绑定淘宝：V1.5.3
|
String relationId = null;
|
|
int tbErrorCode = 0;
|
try {
|
relationId = TaoKeApiUtil.getRelationId(accessToken, Constant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);// 渠道ID
|
} catch (TaoBaoAuthException e) {
|
LogManager.getLogger(LogType.taobaoAuth).error(uid + "渠道备案失败");
|
tbErrorCode = e.getCode();
|
}
|
|
if (StringUtil.isNullOrEmpty(relationId)) {
|
bindInfo = false;
|
}
|
|
String specialId = null;
|
if (bindInfo) {
|
try {
|
specialId = TaoKeApiUtil.getSpecialId(accessToken, Constant.TAOBAO_AUTH_APPKEY,
|
TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
|
} catch (TaoBaoAuthException e) {
|
tbErrorCode = e.getCode();
|
LogManager.getLogger(LogType.taobaoAuth).error(uid + "会员备案失败");
|
}
|
if (StringUtil.isNullOrEmpty(specialId)) {
|
bindInfo = false;
|
}
|
}
|
|
if (!bindInfo) {
|
if (tbErrorCode == TaoBaoAuthException.CODE_NOT_REAL_NAME) {
|
userAccountMsgNotificationService.taoBaoAuthFail(uid, name, "淘宝账号未实名");
|
}
|
errCode = 5;// 信息获取不全
|
} else {
|
try {
|
userExtraTaoBaoInfoService.saveUserTaoBaoInfo(uid, relationId, specialId, taoBaoUid, nickName,
|
true);
|
|
if (!StringUtil.isNullOrEmpty(specialId) && !StringUtil.isNullOrEmpty(relationId))
|
userInfoModifyRecordService.addModifyRecord(uid, ModifyTypeEnum.bindTaoBao, taoBaoUid);
|
} catch (UserExtraTaoBaoInfoException e) {
|
LogHelper.test(e.getMsg());
|
errCode = 6;
|
}
|
}
|
|
}
|
|
if (!StringUtil.isNullOrEmpty(nickName))
|
try {
|
nickName = URLDecoder.decode(nickName, "UTF-8");
|
} catch (UnsupportedEncodingException e) {
|
e.printStackTrace();
|
}
|
TaoBaoUnionAuthRecord record = new TaoBaoUnionAuthRecord();
|
record.setUser(new UserInfo(uid));
|
record.setTaoBaoOpenUid(openUid);
|
record.setTaoBaoUserId(taoBaoUid);
|
record.setTaoBaoUserNick(nickName);
|
record.setCreateTime(new Date());
|
taoBaoUnionAuthRecordService.addAuthRecord(record);
|
|
} catch (Exception e) {
|
errCode = 4;
|
LogHelper.errorDetailInfo(e);
|
}
|
|
UserActiveLog activeLog = userActiveLogService.getUserLatestActiveInfo(uid);
|
|
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(source)) {
|
if (isNewJump)
|
response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/success.html");
|
else
|
closeWebPage(response.getWriter());
|
} else if ("zigou".equalsIgnoreCase(source)) {
|
if (isNewJump)
|
response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/success.html");
|
else
|
closeWebPage(response.getWriter());
|
} else if ("bind".equalsIgnoreCase(source)) {
|
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(source)) {
|
if (isNewJump)
|
response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html");
|
else
|
closeWebPage(response.getWriter());
|
} else if ("zigou".equalsIgnoreCase(source)) {
|
if (isNewJump)
|
response.sendRedirect("http://apph5.banliapp.com/flqWeb/h5/tbauth/fail.html");
|
else
|
closeWebPage(response.getWriter());
|
} else if ("bind".equalsIgnoreCase(source)) {
|
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) {
|
|
}
|
|
}
|
