admin
2019-01-23 7f86c7148acab0c32f5f7f966e10aca079c21171
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
package com.yeshi.fanli.controller;
 
import java.io.PrintWriter;
import java.io.UnsupportedEncodingException;
import java.net.URLDecoder;
import java.util.Date;
 
import javax.annotation.Resource;
 
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
 
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.taobao.TaoBaoUnionAuthRecord;
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.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;
 
    @RequestMapping(value = "tb")
    public void tb(String code, String state, PrintWriter out) {
        if (StringUtil.isNullOrEmpty(code) || StringUtil.isNullOrEmpty(state))
            return;
        String stateStr = AESUtil.decrypt(state, Constant.UIDAESKEY);
        int errCode = 0;
        if (StringUtil.isNullOrEmpty(stateStr)) {
            // 解密错误
            errCode = 1;
        }
        JSONObject json = JSONObject.fromObject(stateStr);
        Long time = json.optLong("t");
        Long uid = json.optLong("u");
        if (System.currentTimeMillis() - time > 1000 * 60 * 10L) {
            // 过时
            errCode = 2;
        }
        if (uid == null || uid.longValue() == 0L)
            errCode = 3;
 
        // 计入记录
 
        try {
            String result = TaoKeApiUtil.getAccessToken(code, Constant.TAOBAO_AUTH_APPKEY,
                    Constant.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");
            if (!StringUtil.isNullOrEmpty(nickName))
                try {
                    nickName = URLDecoder.decode(nickName, "UTF-8");
                } catch (UnsupportedEncodingException e) {
                    e.printStackTrace();
                }
 
            // userExtraTaoBaoInfoService.addRelationId(uid, relationId);
            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;
        }
 
        out.print("<html><body>绑定错误:错误码(" + errCode + ")</body></html>");
    }
 
}