登录修改

韩亚云
1 parent 184007b8
Showing 100 changed files with 415 additions and 10 deletions
cloud/share/.gitignore → cloud/third_tool/.gitignore
cloud/share/build.gradle → cloud/third_tool/build.gradle
cloud/share/libs/open_sdk_r6008_lite.jar → cloud/third_tool/libs/open_sdk_r6008_lite.jar
cloud/share/proguard-rules.pro → cloud/third_tool/proguard-rules.pro
cloud/share/src/debug/AndroidManifest.xml → cloud/third_tool/src/debug/AndroidManifest.xml
cloud/share/src/debug/java/com/cnlive/strike/debug/wxapi/WXEntryActivity.java → cloud/third_tool/src/debug/java/com/cnlive/strike/debug/wxapi/WXEntryActivity.java
cloud/share/src/main/AndroidManifest.xml → cloud/third_tool/src/main/AndroidManifest.xml
cloud/third_tool/src/main/java/com/cnlive/login/action/UserThirdAction.java
cloud/third_tool/src/main/java/com/cnlive/login/action/UserThirdUtilAction.java
cloud/user/src/main/java/com/cnlive/strike/user/frame/data/OtherUserInfo.java → cloud/third_tool/src/main/java/com/cnlive/login/model/OtherUserInfo.java
cloud/third_tool/src/main/java/com/cnlive/login/model/ThirdLoginInfo.java
cloud/third_tool/src/main/java/com/cnlive/login/observer/ThirdLoginObservable.java
cloud/share/src/main/java/com/cnlive/share/observable/WechatLoginObservable.java → cloud/third_tool/src/main/java/com/cnlive/login/observer/WechatLoginObservable.java
cloud/third_tool/src/main/java/com/cnlive/login/utils/ThirdLoginUtil.java
cloud/share/src/main/java/com/cnlive/share/QQListener.java → cloud/third_tool/src/main/java/com/cnlive/share/QQListener.java
cloud/share/src/main/java/com/cnlive/share/adapter/DataBindingAdapter.java → cloud/third_tool/src/main/java/com/cnlive/share/adapter/DataBindingAdapter.java
cloud/share/src/main/java/com/cnlive/share/api/ApiShareService.java → cloud/third_tool/src/main/java/com/cnlive/share/api/ApiShareService.java
cloud/share/src/main/java/com/cnlive/share/arouter/ARouterUtil.java → cloud/third_tool/src/main/java/com/cnlive/share/arouter/ARouterUtil.java
cloud/share/src/main/java/com/cnlive/share/data/FullVideoShareItemData.java → cloud/third_tool/src/main/java/com/cnlive/share/data/FullVideoShareItemData.java
cloud/share/src/main/java/com/cnlive/share/data/IconInfo.java → cloud/third_tool/src/main/java/com/cnlive/share/data/IconInfo.java
 package com.cnlive.strike.debug.wxapi;
  
 import android.app.Activity;
-import android.content.ComponentName;
 import android.content.Intent;
 import android.content.SharedPreferences;
 import android.os.Bundle;
-import android.os.Handler;
-import android.os.Message;
 import android.text.TextUtils;
-import android.util.Log;
 import android.widget.Toast;
  
 import com.cnlive.core.libs.base.application.AppConfig;
@@ -17,13 +13,12 @@ import com.cnlive.share.BuildConfig;
 import com.cnlive.share.arouter.ARouterUtil;
 import com.cnlive.share.data.ShareIntegralTypeInfo;
 import com.cnlive.share.data.WeChatInfo;
-import com.cnlive.share.observable.WechatLoginObservable;
+import com.cnlive.login.observer.WechatLoginObservable;
 import com.cnlive.share.observable.WechatShareObservable;
 import com.cnlive.share.util.DateTimeUtil;
 import com.cnlive.share.util.OkHttpUtils;
 import com.cnlive.strike.user.auth.UserService;
 import com.google.gson.Gson;
-import com.tencent.mm.opensdk.constants.ConstantsAPI;
 import com.tencent.mm.opensdk.modelbase.BaseReq;
 import com.tencent.mm.opensdk.modelbase.BaseResp;
 import com.tencent.mm.opensdk.modelmsg.SendAuth;
@@ -34,8 +29,6 @@ import com.tencent.mm.opensdk.openapi.WXAPIFactory;
 import org.json.JSONException;
 import org.json.JSONObject;
  
-import java.lang.ref.WeakReference;
-
 /**
  * 作者: 吴奎庆
  * <p>
+package com.cnlive.login.action;
+
+import android.content.Context;
+
+import com.cnlive.strike.user.model.CNLiveUserInfo;
+
+/**
+ * created by hanyayun
+ * on 2019/12/4
+ */
+public class UserThirdAction {
+
+
+    public static void otherLogin(Context context, String thirdPartyPlat, String thirdPartyId, Event<CNLiveUserInfo> event) {
+        Logic.create()
+                .action(UserThirdUtilAction.otherLogin(context, thirdPartyPlat, thirdPartyId))
+                .action(loginAppAction(context, "", "", true))
+                .action(loginIMAction())
+                .start(event);
+    }
+
+
+    public static void otherLoginBindMobile(Context context, String phone, String countryCode, String ems,
+                                            String thirdPartyPlat, String thirdPartyId, String nickName, String gender,
+                                            String location, String faceUrl, Event<CNLiveUserInfo> event) {
+        Logic.create()
+                .action(UserThirdUtilAction.otherLoginBindMobile(context, phone, countryCode, ems,
+                        thirdPartyPlat, thirdPartyId, nickName, gender, location, faceUrl))
+                .action(loginAppAction(context, "", "", true))
+                .action(loginIMAction())
+                .start(event);
+    }
+}
+package com.cnlive.login.action;
+
+import android.content.Context;
+
+import com.cnlive.core.libs.base.application.AppConfig;
+import com.cnlive.core.network.model.UserData;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * created by hanyayun
+ * on 2019/12/4
+ */
+public class UserThirdUtilAction {
+
+    /**
+     * 其他平台账户登录
+     *
+     * @param context
+     * @param thirdPartyPlat 平台类型  1:sina 2:qq 3:weixin 4:renren
+     * @param thirdPartyId   第三方用户ID
+     *                       [qq: 建议使用openid, wx: 建议使用unionid, sina: 建议使用idstr]；
+     *                       注意：同一用户在登录Sp下不同app时，thirdPartyId必须相同
+     */
+    public static Logic.Action<Object, BaseInfo<UserData>> otherLogin(Context context, String thirdPartyPlat, String thirdPartyId) {
+        return (data, callback) -> {
+            Map<String, String> requestMap = new HashMap<>();
+
+            requestMap.put("appId", AppConfig.getAppId());
+            requestMap.put("thirdPartyPlat", thirdPartyPlat);
+            requestMap.put("thirdPartyId", thirdPartyId);
+            requestMap.put("frmId", AppConfig.getAppChannel());
+            requestMap.put("clientPlat", "a");
+
+            return ApiRequest.service(ApiServiceOpen.class, service -> service.loginIn3rdForWJJ(requestMap)).subscribe(context, callback);
+        };
+    }
+
+    /**
+     * 其他平台账户版定手机号并登录
+     *
+     * @param context
+     * @param thirdPartyPlat 平台类型  1:sina 2:qq 3:weixin 4:renren
+     * @param thirdPartyId   第三方用户ID
+     *                       [qq: 建议使用openid, wx: 建议使用unionid, sina: 建议使用idstr]；
+     *                       注意：同一用户在登录Sp下不同app时，thirdPartyId必须相同
+     */
+
+
+    public static Logic.Action<Object, BaseInfo<UserData>> otherLoginBindMobile(Context context,
+                                                                                String phone,
+                                                                                String countryCode,
+                                                                                String ems,
+                                                                                String thirdPartyPlat,
+                                                                                String thirdPartyId,
+                                                                                String nickName,
+                                                                                String gender,
+                                                                                String location,
+                                                                                String faceUrl) {
+        return (data, callback) -> {
+            Map<String, String> requestMap = new HashMap<>();
+
+            requestMap.put("frmId", AppConfig.getAppChannel());
+            requestMap.put("clientPlat", "a");
+            requestMap.put("uuid", AppConfig.getAppUUID());
+
+            requestMap.put("appId", AppConfig.getAppId());
+            requestMap.put("mobile", phone);
+            requestMap.put("countryCode", countryCode);
+            requestMap.put("verificationCode", ems);
+
+            requestMap.put("thirdPartyPlat", thirdPartyPlat);
+            requestMap.put("thirdPartyId", thirdPartyId);
+            requestMap.put("nickName", nickName);
+            requestMap.put("gender", gender);
+            requestMap.put("location", location);
+            requestMap.put("faceUrl", faceUrl);
+
+
+            return ApiRequest.service(ApiServiceOpen.class, service -> service.loginIn3rdAndMobileForWJJ(requestMap)).subscribe(context, callback);
+        };
+    }
+}
-package com.cnlive.strike.user.frame.data;
+package com.cnlive.login.model;
  
 import java.io.Serializable;
  
+package com.cnlive.login.model;
+
+
+/**
+ * 作者: 吴奎庆
+ * <p>
+ * 时间: 2019/9/19
+ * <p>
+ * 简介:
+ */
+public class ThirdLoginInfo {
+    //类型  1 成功   2失败
+    private int type;
+    //错误信息
+    private String message;
+    //登陆信息
+    OtherUserInfo otherUserInfo;
+
+    public ThirdLoginInfo() {
+    }
+
+    public ThirdLoginInfo(int type, String message, OtherUserInfo otherUserInfo) {
+        this.type = type;
+        this.message = message;
+        this.otherUserInfo = otherUserInfo;
+    }
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+    public String getMessage() {
+        return message;
+    }
+
+    public void setMessage(String message) {
+        this.message = message;
+    }
+
+    public OtherUserInfo getOtherUserInfo() {
+        return otherUserInfo;
+    }
+
+    public void setOtherUserInfo(OtherUserInfo otherUserInfo) {
+        this.otherUserInfo = otherUserInfo;
+    }
+}
+package com.cnlive.login.observer;
+
+
+import com.cnlive.login.model.ThirdLoginInfo;
+
+import java.util.Observable;
+
+/**
+ * 作者: 吴奎庆
+ * <p>
+ * 时间: 2019/9/19
+ * <p>
+ * 简介:
+ */
+public class ThirdLoginObservable extends Observable {
+
+   private  static ThirdLoginObservable instance;
+
+    public static ThirdLoginObservable getInstance() {
+        synchronized (ThirdLoginObservable.class) {
+            if (instance == null) {
+                instance = new ThirdLoginObservable();
+            }
+        }
+        return instance;
+    }
+
+    public  void  update(ThirdLoginInfo userInfo){
+        setChanged();
+        notifyObservers(userInfo);
+    }
+}
-package com.cnlive.share.observable;
+package com.cnlive.login.observer;
  
 import com.cnlive.share.data.WeChatInfo;
  
+package com.cnlive.login.utils;
+
+import android.content.Context;
+import android.text.TextUtils;
+
+import com.cnlive.login.model.OtherUserInfo;
+import com.cnlive.login.model.ThirdLoginInfo;
+import com.cnlive.login.observer.ThirdLoginObservable;
+import com.sina.weibo.sdk.auth.Oauth2AccessToken;
+import com.sina.weibo.sdk.net.HttpManager;
+import com.sina.weibo.sdk.net.WeiboParameters;
+import com.tencent.connect.UserInfo;
+import com.tencent.tauth.IUiListener;
+import com.tencent.tauth.Tencent;
+import com.tencent.tauth.UiError;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+import io.reactivex.Observable;
+import io.reactivex.ObservableEmitter;
+import io.reactivex.ObservableOnSubscribe;
+import io.reactivex.Observer;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.disposables.Disposable;
+import io.reactivex.schedulers.Schedulers;
+
+import static com.tencent.connect.common.Constants.PARAM_ACCESS_TOKEN;
+import static com.tencent.connect.common.Constants.PARAM_EXPIRES_IN;
+import static com.tencent.open.SocialConstants.PARAM_OPEN_ID;
+
+/**
+ * 作者: 吴奎庆
+ * <p>
+ * 时间: 2019/9/19
+ * <p>
+ * 简介:  三方登陆的工具类
+ */
+public class ThirdLoginUtil {
+    /**
+     * 获取微博信息
+     *
+     * @param context
+     * @param oauth2AccessToken
+     */
+    public static void getWeiBoInfo(Context context, Oauth2AccessToken oauth2AccessToken) {
+
+        Oauth2AccessToken mAccessToken = oauth2AccessToken;
+        //从这里获取用户输入的 电话号码信息
+        if (mAccessToken.isSessionValid()) {
+            // 显示 Token
+            Observable.create(new ObservableOnSubscribe<String>() {
+                @Override
+                public void subscribe(ObservableEmitter<String> emitter) throws Exception {
+
+                    WeiboParameters parameters = new WeiboParameters("3884700821");
+                    parameters.put("access_token", oauth2AccessToken.getToken());
+                    parameters.put("uid", oauth2AccessToken.getUid());
+                    String message = HttpManager.openUrl(context, "https://api.weibo.com/2/users/show.json", "GET", parameters);
+                    emitter.onNext(message);
+                }
+            }).subscribeOn(Schedulers.io())
+                    .observeOn(AndroidSchedulers.mainThread())
+                    .subscribe(new Observer<String>() {
+                        @Override
+                        public void onSubscribe(Disposable d) {
+
+                        }
+
+                        @Override
+                        public void onNext(String message) {
+                            try {
+
+                                JSONObject jsonObject = new JSONObject(message);
+                                if (jsonObject == null) return;
+                                String id = jsonObject.getString("idstr");
+                                String name = jsonObject.getString("name");
+                                String urlface = jsonObject.getString("avatar_large");
+                                String location = jsonObject.getString("location");
+                                String gender = jsonObject.getString("gender");
+                                if (TextUtils.isEmpty(id)) return;
+
+                                OtherUserInfo userInfo = new OtherUserInfo();
+                                userInfo.setFaceUrl(urlface);
+                                userInfo.setGender(gender);
+                                userInfo.setNickName(name);
+                                userInfo.setLocation(location);
+                                userInfo.setThirdPartyId(id);
+                                userInfo.setLoginType("1");
+
+                                ThirdLoginInfo thirdLoginInfo = new ThirdLoginInfo();
+                                thirdLoginInfo.setType(1);
+                                thirdLoginInfo.setOtherUserInfo(userInfo);
+                                ThirdLoginObservable.getInstance().update(thirdLoginInfo);
+
+                            } catch (Exception e) {
+                                ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+                            }
+                        }
+
+                        @Override
+                        public void onError(Throwable e) {
+                            ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+                        }
+
+                        @Override
+                        public void onComplete() {
+
+                        }
+                    });
+        } else {
+            // 以下几种情况，您会收到 Code：
+            // 1. 当您未在平台上注册的应用程序的包名与签名时；
+            // 2. 当您注册的应用程序包名与签名不正确时；
+            // 3. 当您在平台上注册的包名和签名与您当前测试的应用的包名和签名不匹配时。
+            String code = oauth2AccessToken.getBundle().getString("code");
+            String message = "null";
+            if (!TextUtils.isEmpty(code)) {
+                message = message + "\nObtained the code: " + code;
+            }
+            ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+        }
+
+    }
+
+
+    public static  void getQQInfo(Context context, Tencent mTencent, Object obj) {
+        JSONObject jsonObject = (JSONObject) obj;
+        if (jsonObject != null) {
+            try {
+                int ret = jsonObject.getInt("ret");
+                if (ret == 0) {
+                    //此处登录授权成功
+                    String openId = jsonObject.getString(PARAM_OPEN_ID);
+                    String access_token = jsonObject.getString(PARAM_ACCESS_TOKEN);
+                    String expires = jsonObject.getString(PARAM_EXPIRES_IN);
+                    mTencent.setOpenId(openId);
+                    mTencent.setAccessToken(access_token, expires);
+                    //获取用户信息
+                    getUserInfo(context, mTencent, openId);
+                } else {
+                    ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+                }
+            } catch (JSONException e) {
+                e.printStackTrace();
+            }
+        }
+    }
+
+
+    private static void getUserInfo(Context context, Tencent mTencent, String openId) {
+        UserInfo info = new UserInfo(context, mTencent.getQQToken());
+        info.getUserInfo(new IUiListener() {
+            @Override
+            public void onComplete(Object value) {
+                JSONObject jsonObject = (JSONObject) value;
+                if (jsonObject == null) return;
+
+                try {
+                    String name = jsonObject.getString("nickname");
+                    String urlface = jsonObject.getString("figureurl_qq");
+                    String gender = jsonObject.getString("gender");
+                    String province = jsonObject.getString("province");
+                    String city = jsonObject.getString("city");
+
+                    if (TextUtils.isEmpty(openId)) return;
+
+                    OtherUserInfo otherUserInfo = new OtherUserInfo();
+                    otherUserInfo.setFaceUrl(urlface);
+
+                    otherUserInfo.setNickName(name);
+                    if (TextUtils.isEmpty(city)) {
+                        otherUserInfo.setLocation(province);
+                    } else {
+                        otherUserInfo.setLocation(city);
+                    }
+
+                    if ("男".equals(gender)) {
+                        otherUserInfo.setGender("m");
+                    } else if ("女".equals(gender)) {
+                        otherUserInfo.setGender("f");
+                    } else {
+                        otherUserInfo.setGender("n");
+                    }
+
+                    otherUserInfo.setThirdPartyId(openId);
+                    otherUserInfo.setLoginType("2");
+                    ThirdLoginInfo thirdLoginInfo = new ThirdLoginInfo();
+                    thirdLoginInfo.setType(1);
+                    thirdLoginInfo.setOtherUserInfo(otherUserInfo);
+                    ThirdLoginObservable.getInstance().update(thirdLoginInfo);
+
+                } catch (JSONException e) {
+                    ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+                }
+            }
+
+            @Override
+            public void onError(UiError uiError) {
+                ThirdLoginObservable.getInstance().update(new ThirdLoginInfo(2, "登陆失败", null));
+            }
+
+            @Override
+            public void onCancel() {
+            }
+        });
+    }
+
+}
 package com.cnlive.share.observable;
  
+import com.cnlive.login.observer.WechatLoginObservable;
+
 import java.util.Observable;
  
 /**
@@ -128,6 +128,7 @@ public class ShareUtils {
         }
         String url = Util.processUrlData(shareInfo.getUrl(), mContext, false);
         WXWebpageObject webpage = new WXWebpageObject();
+        //TODO 上传maven考虑正式版测试版
         IWXAPI api = WXAPIFactory.createWXAPI(mContext, AppConfig.getWechatAppid());
         webpage.webpageUrl = url;
         WXMediaMessage msg = new WXMediaMessage(webpage);