Merge branch 'master' of bj.gitlab.cnlive.com:cnlive-team/newModuleStrike

YangShuai
2 parents 182c6c1a bcd995f5
Showing 100 changed files with 533 additions and 4 deletions
.idea/misc.xml
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/cloud/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/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
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="NullableNotNullManager">
+    <option name="myDefaultNullable" value="org.jetbrains.annotations.Nullable" />
+    <option name="myDefaultNotNull" value="androidx.annotation.NonNull" />
+    <option name="myNullables">
+      <value>
+        <list size="12">
+          <item index="0" class="java.lang.String" itemvalue="org.jetbrains.annotations.Nullable" />
+          <item index="1" class="java.lang.String" itemvalue="javax.annotation.Nullable" />
+          <item index="2" class="java.lang.String" itemvalue="javax.annotation.CheckForNull" />
+          <item index="3" class="java.lang.String" itemvalue="edu.umd.cs.findbugs.annotations.Nullable" />
+          <item index="4" class="java.lang.String" itemvalue="android.support.annotation.Nullable" />
+          <item index="5" class="java.lang.String" itemvalue="androidx.annotation.Nullable" />
+          <item index="6" class="java.lang.String" itemvalue="android.annotation.Nullable" />
+          <item index="7" class="java.lang.String" itemvalue="androidx.annotation.RecentlyNullable" />
+          <item index="8" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.qual.Nullable" />
+          <item index="9" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NullableDecl" />
+          <item index="10" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NullableType" />
+          <item index="11" class="java.lang.String" itemvalue="com.android.annotations.Nullable" />
+        </list>
+      </value>
+    </option>
+    <option name="myNotNulls">
+      <value>
+        <list size="11">
+          <item index="0" class="java.lang.String" itemvalue="org.jetbrains.annotations.NotNull" />
+          <item index="1" class="java.lang.String" itemvalue="javax.annotation.Nonnull" />
+          <item index="2" class="java.lang.String" itemvalue="edu.umd.cs.findbugs.annotations.NonNull" />
+          <item index="3" class="java.lang.String" itemvalue="android.support.annotation.NonNull" />
+          <item index="4" class="java.lang.String" itemvalue="androidx.annotation.NonNull" />
+          <item index="5" class="java.lang.String" itemvalue="android.annotation.NonNull" />
+          <item index="6" class="java.lang.String" itemvalue="androidx.annotation.RecentlyNonNull" />
+          <item index="7" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.qual.NonNull" />
+          <item index="8" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NonNullDecl" />
+          <item index="9" class="java.lang.String" itemvalue="org.checkerframework.checker.nullness.compatqual.NonNullType" />
+          <item index="10" class="java.lang.String" itemvalue="com.android.annotations.NonNull" />
+        </list>
+      </value>
+    </option>
+  </component>
   <component name="ProjectRootManager" version="2" languageLevel="JDK_1_8" project-jdk-name="1.8" project-jdk-type="JavaSDK">
     <output url="file://$PROJECT_DIR$/build/classes" />
   </component>
-package com.cnlive.cloud.debug.wxapi;
+package com.cnlive.strike.debug.wxapi;
  
 import android.app.Activity;
 import android.content.Intent;
@@ -7,17 +7,17 @@ import android.os.Bundle;
 import android.text.TextUtils;
 import android.widget.Toast;
  
+import com.cnlive.cloud.user.auth.UserService;
 import com.cnlive.core.libs.base.application.AppConfig;
 import com.cnlive.core.libs.base.util.AlertUtil;
 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.cloud.user.auth.UserService;
 import com.google.gson.Gson;
 import com.tencent.mm.opensdk.modelbase.BaseReq;
 import com.tencent.mm.opensdk.modelbase.BaseResp;
+package com.cnlive.login.action;
+
+import android.accounts.Account;
+import android.content.Context;
+import android.text.TextUtils;
+
+import com.cnlive.cloud.user.auth.UserService;
+import com.cnlive.cloud.user.model.CNLiveUserInfo;
+import com.cnlive.core.network.HttpConn;
+import com.cnlive.core.network.NetCallBack;
+import com.cnlive.core.network.model.BaseResult;
+import com.cnlive.core.network.model.UserData;
+
+import io.reactivex.Observable;
+
+//import com.cnlive.strike.user.model.CNLiveUserInfo;
+
+/**
+ * created by hanyayun
+ * on 2019/12/4
+ */
+public class UserThirdAction {
+
+
+    private static final int MAX_USER_COUNT = 1;
+
+    public static void otherLogin(Context context, String thirdPartyPlat, String thirdPartyId, CallBack callBack) {
+
+        HttpConn.action(UserThirdUtilAction.otherLogin(context, thirdPartyPlat, thirdPartyId), new NetCallBack<BaseResult<UserData>>() {
+            @Override
+            public void onRequestState(int state) {
+                if (null != callBack) {
+                    callBack.callback(state, "", null);
+                }
+            }
+
+            @Override
+            public void onSuccess(BaseResult<UserData> data) {
+                loginAppAction(data, context, "", "", true, callBack);
+            }
+
+            @Override
+            public void onFailure(String errCode, String errMsg, Exception e) {
+                if (null != callBack) {
+                    callBack.callback(Integer.parseInt(errCode), errMsg, null);
+                }
+            }
+        });
+    }
+
+
+    public static void otherLoginBindMobile(Context context, String phone, String countryCode, String ems,
+                                            String thirdPartyPlat, String thirdPartyId, String nickName, String gender,
+                                            String location, String faceUrl, CallBack callBack) {
+
+        HttpConn.action(UserThirdUtilAction.otherLoginBindMobile(context, phone, countryCode, ems,
+                thirdPartyPlat, thirdPartyId, nickName, gender, location, faceUrl), new NetCallBack<BaseResult<UserData>>() {
+            @Override
+            public void onRequestState(int state) {
+                if (null != callBack) {
+                    callBack.callback(state, "", null);
+                }
+            }
+
+            @Override
+            public void onSuccess(BaseResult<UserData> data) {
+                loginAppAction(data,context, "", "", true, callBack);
+            }
+
+            @Override
+            public void onFailure(String errCode, String errMsg, Exception e) {
+
+            }
+        });
+    }
+
+
+    private static Observable<CNLiveUserInfo> loginAppAction(BaseResult<UserData> data, Context context, String userName, String userPassword, boolean otherLogin, CallBack callBack) {
+        CNLiveUserInfo userinfo = null;
+        if (null == data || null == data.getData()) {
+            if (null != callBack) {
+                callBack.callback(-5, "获取账户信息失败 请重试.", null);
+            }
+        } else if (TextUtils.isEmpty(data.getData().getMobile())) {
+            callBack.callback(-5, "绑定手机号已失效..", null);
+        } else {
+            //更新登录用户信息
+            UserService userService = UserService.getInstance(context);
+            userService.loginAppAccount(
+                    otherLogin ? data.getData().getMobile() : userName,
+                    otherLogin ? data.getData().getMobile() : userPassword,
+                    data.getData());
+            //保留近期登录用户
+            Account[] accounts = userService.getUserList();
+            userinfo = userService.getAppAccount();
+            if (accounts.length <= MAX_USER_COUNT) {
+                callBack.callback(0, "", userinfo);
+            } else {
+                CNLiveUserInfo finalUserinfo = userinfo;
+                userService.removeUser(accounts[0], future -> callBack.callback(0, "", finalUserinfo));
+            }
+        }
+        return Observable.just(userinfo);
+    }
+
+
+    public interface CallBack {
+        void callback(int state, String msg, Object object);
+    }
+}
+package com.cnlive.login.action;
+
+import android.content.Context;
+
+import com.cnlive.core.libs.base.application.AppConfig;
+import com.cnlive.core.network.api.ApiBaseServiceOpen;
+import com.cnlive.core.network.model.BaseResult;
+import com.cnlive.core.network.model.UserData;
+import com.cnlive.core.network.request.BaseRequest;
+
+import java.util.HashMap;
+import java.util.Map;
+
+import io.reactivex.Observable;
+
+/**
+ * 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 Observable<BaseResult<UserData>> otherLogin(Context context, String thirdPartyPlat, String thirdPartyId) {
+
+            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 BaseRequest.init().service(ApiBaseServiceOpen.class).loginIn3rdForWJJ(requestMap);
+    }
+
+    /**
+     * 其他平台账户版定手机号并登录
+     *
+     * @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 Observable<BaseResult<UserData>> otherLoginBindMobile(Context context,
+                                                                                String phone,
+                                                                                String countryCode,
+                                                                                String ems,
+                                                                                String thirdPartyPlat,
+                                                                                String thirdPartyId,
+                                                                                String nickName,
+                                                                                String gender,
+                                                                                String location,
+                                                                                String faceUrl) {
+            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 BaseRequest.init().service(ApiBaseServiceOpen.class).loginIn3rdAndMobileForWJJ(requestMap);
+    }
+}
+package com.cnlive.login.model;
+
+
+import com.cnlive.cloud.user.frame.data.OtherUserInfo;
+
+/**
+ * 作者: 吴奎庆
+ * <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.cloud.user.frame.data.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;
  
 /**
@@ -127,6 +127,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);