admin
2019-04-03 8981ab050bbc9937f13d2711bf0a20e2019e1283
fanli/src/main/java/com/yeshi/fanli/controller/AuthCallBackController.java
@@ -6,6 +6,7 @@
import java.util.Date;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.springframework.stereotype.Controller;
@@ -13,11 +14,13 @@
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionAuthRecord;
import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionAuthRecordService;
import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.util.AESUtil;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TaoBaoConstant;
import com.yeshi.fanli.util.taobao.TaoKeApiUtil;
import net.sf.json.JSONObject;
@@ -39,9 +42,10 @@
   private TaoBaoUnionAuthRecordService taoBaoUnionAuthRecordService;
   @RequestMapping(value = "tb")
   public void tb(String code, String state, HttpServletResponse response) {
      if (StringUtil.isNullOrEmpty(code) || StringUtil.isNullOrEmpty(state))
      {
   public void tb(String code, String state, HttpServletRequest request, HttpServletResponse response) {
      LogHelper.test("淘宝授权回调:" + code + ":" + state);
      if (StringUtil.isNullOrEmpty(code) || StringUtil.isNullOrEmpty(state)) {
         LogHelper.error("淘宝授权回调出错");
         try {
            response.sendRedirect("http://apph5.yeshitv.com/apppage/flq_bonusState.html?code=1");
         } catch (IOException e1) {
@@ -66,39 +70,32 @@
      if (uid == null || uid.longValue() == 0L)
         errCode = 3;
      if (uid == 911382L) {
         try {
            if ("share".equalsIgnoreCase(source))
               response.sendRedirect("http://apph5.yeshitv.com/apppage/flq_bonusState.html?code=1");
            else
               response.sendRedirect("http://apph5.yeshitv.com/apppage/flq_rebateState.html?code=1");
         } catch (IOException e) {
         }
         return;
      }
      // 计入记录
      try {
         String result = TaoKeApiUtil.getAccessToken(code, Constant.TAOBAO_AUTH_APPKEY,
               Constant.TAOBAO_AUTH_APPSECRET);
         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");
         // LogHelper.test("uid:" + uid + "\n accessToken:" + accessToken);
         // 获取渠道ID与会员ID
         if ("share".equalsIgnoreCase(source)) {
            String relationId = TaoKeApiUtil.getRelationId(accessToken, Constant.TAOBAO_AUTH_APPKEY,
                  Constant.TAOBAO_AUTH_APPSECRET);// 渠道ID
            String relationId = TaoKeApiUtil.getRelationId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
                  TaoBaoConstant.TAOBAO_AUTH_APPSECRET);// 渠道ID
            if (StringUtil.isNullOrEmpty(relationId))
               LogHelper.test(uid + "渠道备案失败");
            userExtraTaoBaoInfoService.addRelationId(uid, relationId, taoBaoUid, true);
         } else {
            String specialId = TaoKeApiUtil.getSpecialId(accessToken, Constant.TAOBAO_AUTH_APPKEY,
                  Constant.TAOBAO_AUTH_APPSECRET);
            String specialId = TaoKeApiUtil.getSpecialId(accessToken, TaoBaoConstant.TAOBAO_AUTH_APPKEY,
                  TaoBaoConstant.TAOBAO_AUTH_APPSECRET);
            if (StringUtil.isNullOrEmpty(specialId))
               LogHelper.test(uid + "会员备案失败");
            userExtraTaoBaoInfoService.addSpecialId(uid, specialId, taoBaoUid, true);
         }
@@ -117,6 +114,11 @@
         taoBaoUnionAuthRecordService.addAuthRecord(record);
      } catch (Exception e) {
         errCode = 4;
         try {
            LogHelper.errorDetailInfo(e);
         } catch (Exception e1) {
            e1.printStackTrace();
         }
      }
      try {