优化微信授权处理

userCenter_service/src/main/java/com/bjtdba/userCenter/service/impl/WechatLogOnServiceImpl.java

@@ -32,35 +32,97 @@ public class WechatLogOnServiceImpl implements WechatLogOnService {
     @Override
     public Object wechatBindPhone(String code) {
         Map<String, Object> data = new HashMap<>();
-        String url1 = SystemConfig.WECHAT_URL.replace("APPID",SystemConfig.WECHAT_APPID).replace("SECRET",SystemConfig.WECHAT_SECRET).replace("CODE",code);
-        String a = HttpURLConnectionUtils.doGet(url1);
-        System.out.println("微信返回数据"+a);
-        String openid =(String)JSONObject.parseObject(a).get("openid");
-        String unionid =(String)JSONObject.parseObject(a).get("unionid");
-        String access_token =(String)JSONObject.parseObject(a).get("access_token");
-        String url2 = SystemConfig.WECHAT_USER_INFO_URL.replace("ACCESS_TOKEN", access_token).replace("OPENID", openid);
-        String b = HttpURLConnectionUtils.doGet(url2);
-        System.out.println("微信返回数据"+b);
-        String nickname =(String)JSONObject.parseObject(b).get("nickname");
-        String headimgurl =(String)JSONObject.parseObject(b).get("headimgurl");
-        /**
-         * 拿openid 查询数据库   判断用户是否绑定    绑定成功直接登录进入系统，绑定不成功返回标示 提示用户进行绑定
-         */
-//        User user = userDao.selectUserByOpenid(openid);
-        User user = userDao.selectUserByOpenid(unionid);
-        data.put("nickname",nickname);
-        data.put("headimgurl",headimgurl);
-        data.put("openid",openid);
-        data.put("unionid",unionid);
-        if(user==null){
-            data.put("code",SystemConfig.WECHAT_CODE);
-            data.put("msg",SystemConfig.WECHAT_MSG);
 
-        }else{
-            data.put("user",user);
-            data.put("code",SystemConfig.WECHAT_SUCCESS_CODE);
+        try {
+            // 1. 获取微信access_token和openid
+            String url1 = SystemConfig.WECHAT_URL
+                    .replace("APPID", SystemConfig.WECHAT_APPID)
+                    .replace("SECRET", SystemConfig.WECHAT_SECRET)
+                    .replace("CODE", code);
+
+            System.out.println("请求微信API URL1: " + url1);
+            String response1 = HttpURLConnectionUtils.doGet(url1);
+            System.out.println("微信返回access_token数据: " + response1);
+
+            JSONObject tokenJson = JSONObject.parseObject(response1);
+
+            // 检查微信返回的错误信息
+            if (tokenJson.containsKey("errcode")) {
+                Integer errcode = tokenJson.getInteger("errcode");
+                String errmsg = tokenJson.getString("errmsg");
+                System.out.println("微信接口调用失败，errcode: " + errcode + ", errmsg: " + errmsg);
+                return ResponseUtil.fail("微信授权失败: " + errmsg + "(" + errcode + ")");
+            }
+
+            String openid = tokenJson.getString("openid");
+            String unionid = tokenJson.getString("unionid");
+            String accessToken = tokenJson.getString("access_token");
+
+            // 验证必要字段是否存在
+            if (openid == null || openid.isEmpty()) {
+                System.out.println("微信返回数据缺少openid字段，response: " + response1);
+                return ResponseUtil.fail("微信授权失败：无法获取用户标识");
+            }
+
+            if (accessToken == null || accessToken.isEmpty()) {
+                System.out.println("微信返回数据缺少access_token字段，response: " + response1);
+                return ResponseUtil.fail("微信授权失败：无法获取访问令牌");
+            }
+
+            // 2. 获取用户信息
+            String url2 = SystemConfig.WECHAT_USER_INFO_URL
+                    .replace("ACCESS_TOKEN", accessToken)
+                    .replace("OPENID", openid);
+
+            System.out.println("请求微信API URL2: " + url2);
+            String response2 = HttpURLConnectionUtils.doGet(url2);
+            System.out.println("微信返回用户信息数据: " + response2);
+
+            JSONObject userJson = JSONObject.parseObject(response2);
+
+            // 检查错误
+            if (userJson.containsKey("errcode")) {
+                Integer errcode = userJson.getInteger("errcode");
+                String errmsg = userJson.getString("errmsg");
+                System.out.println("获取微信用户信息失败，errcode: " + errcode + ", errmsg: " + errmsg);
+                return ResponseUtil.fail("获取用户信息失败: " + errmsg + "(" + errcode + ")");
+            }
+
+            String nickname = userJson.getString("nickname");
+            String headimgurl = userJson.getString("headimgurl");
+
+            // 3. 查询数据库
+            // 这里使用unionid查询，如果unionid为空则使用openid
+            User user = null;
+            if (unionid != null && !unionid.isEmpty()) {
+                user = userDao.selectUserByOpenid(unionid);
+            } else {
+                user = userDao.selectUserByOpenid(openid);
+            }
+
+            // 4. 构建返回数据
+            data.put("nickname", nickname);
+            data.put("headimgurl", headimgurl);
+            data.put("openid", openid);
+            data.put("unionid", unionid);
+
+            if (user == null) {
+                data.put("code", SystemConfig.WECHAT_CODE);
+                data.put("msg", SystemConfig.WECHAT_MSG);
+                System.out.println("用户未绑定，需要绑定手机号，openid: " + openid);
+            } else {
+                data.put("user", user);
+                data.put("code", SystemConfig.WECHAT_SUCCESS_CODE);
+                System.out.println("用户已绑定，直接登录，用户ID: " + user.getUid());
+            }
+
+            return ResponseUtil.ok(data);
+
+        } catch (Exception e) {
+            System.err.println("微信绑定手机号处理失败，code: " + code + ", 异常: " + e.getMessage());
+            e.printStackTrace();
+            return ResponseUtil.fail("系统处理异常: " + e.getMessage());
         }
-        return ResponseUtil.ok(data);
     }
 
     @Override