diff --git a/core/.gitignore b/core/.gitignore
new file mode 100644
index 0000000..36af493
--- /dev/null
+++ b/core/.gitignore
@@ -0,0 +1,3 @@
+/build
+*.iml
+*.DS_Store
\ No newline at end of file
diff --git a/core/build.gradle b/core/build.gradle
new file mode 100644
index 0000000..4dccc86
--- /dev/null
+++ b/core/build.gradle
@@ -0,0 +1,107 @@
+apply plugin: 'com.android.library'
+apply plugin: 'realm-android'
+apply plugin: 'kotlin-android'
+apply plugin: 'kotlin-parcelize'
+
+android {
+ compileSdkVersion COMPILE_SDK_VERSION.toInteger()
+ defaultConfig {
+ minSdkVersion MIN_SDK_VERSION.toInteger()
+ targetSdkVersion TARGET_SDK_VERSION.toInteger()
+ }
+
+ buildTypes {
+ release {
+ minifyEnabled true
+ proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
+ }
+ }
+
+ compileOptions {
+ sourceCompatibility JavaVersion.VERSION_11
+ targetCompatibility JavaVersion.VERSION_11
+ }
+
+ kotlinOptions {
+ jvmTarget = '11'
+ }
+
+ sourceSets {
+ main {
+ java.srcDirs = [
+ 'src/main/java',
+ 'src/model_smscode/java',
+ 'src/model_public_chat_hall/java',
+ 'src/model_pay/java',
+ 'src/model_upgrade_app/java',
+ 'src/model_labour_union/java',
+ 'src/model_mentoring_relationship/java',
+ 'src/model_music/java',
+ 'src/model_database_room/java',
+ 'src/model_mini_world/java',
+ 'src/model_bank_card/java',
+ 'src/model_super_admin/java',
+ 'src/model_treasure_box/java',
+ 'src/model_community/java',
+ 'src/model_channel_page/java',
+ 'src/model_treasure_box/java',
+ 'src/model_sud_wrapper/java'
+ ]
+// jniLibs.srcDirs = ['libs', 'umeng-app-libs/jniLibs']
+ }
+ }
+
+ buildToolsVersion = '30.0.3'
+
+}
+
+def Lombok = "1.18.24"
+
+dependencies {
+ api fileTree(dir: 'libs', include: ['*.jar'])
+
+ api "com.orhanobut:logger:2.2.0"
+
+ compileOnly "org.projectlombok:lombok:${Lombok}"
+ annotationProcessor "org.projectlombok:lombok:${Lombok}"
+
+ api fileTree(dir: 'share-sdk-libs', include: ['*.jar'])
+
+ // 声网
+ api 'io.agora.rtc:voice-sdk:4.2.2'
+
+ // core
+// implementation 'com.liulishuo.okdownload:okdownload:1.0.4'
+ // provide sqlite to store breakpoints
+// implementation 'com.liulishuo.okdownload:sqlite:1.0.4'
+ // provide okhttp to connect to backend
+// implementation 'com.liulishuo.okdownload:okhttp:1.0.4'
+ // Room
+ api 'androidx.room:room-runtime:2.5.1'
+ annotationProcessor 'androidx.room:room-compiler:2.5.1'
+ // RxJava support for Room
+ api 'androidx.room:room-rxjava2:2.5.1'
+
+ //firebase推送、统计
+// implementation 'com.google.firebase:firebase-messaging:23.1.1'
+// implementation 'com.google.android.gms:play-services-base:18.1.0'
+// implementation 'com.google.firebase:firebase-core:19.0.0'
+// implementation 'com.google.android.gms:play-services-ads-identifier:18.0.1'
+
+ api 'org.jetbrains.kotlin:kotlin-reflect:1.7.10'
+
+ api project(':nim_uikit')
+ api project(':library')
+
+// implementation 'com.liulishuo.okdownload:okdownload:1.0.7'
+// implementation 'com.liulishuo.okdownload:okhttp:1.0.7'
+
+ implementation 'com.tencent.liteav:LiteAVSDK_TRTC:11.7.0.13946'
+
+ api project(':modules:module_base')
+
+ api 'tech.sud.mgp:SudMGP-static:1.5.2.1238'
+}
+repositories {
+ mavenCentral()
+}
diff --git a/core/proguard-rules.pro b/core/proguard-rules.pro
new file mode 100644
index 0000000..f1b4245
--- /dev/null
+++ b/core/proguard-rules.pro
@@ -0,0 +1,21 @@
+# Add project specific ProGuard rules here.
+# You can control the set of applied configuration files using the
+# proguardFiles setting in build.gradle.
+#
+# For more details, see
+# http://developer.android.com/guide/developing/tools/proguard.html
+
+# If your project uses WebView with JS, uncomment the following
+# and specify the fully qualified class name to the JavaScript interface
+# class:
+#-keepclassmembers class fqcn.of.javascript.interface.for.webview {
+# public *;
+#}
+
+# Uncomment this to preserve the line number information for
+# debugging stack traces.
+#-keepattributes SourceFile,LineNumberTable
+
+# If you keep the line number information, uncomment this to
+# hide the original source file name.
+#-renamesourcefileattribute SourceFile
diff --git a/core/src/main/AndroidManifest.xml b/core/src/main/AndroidManifest.xml
new file mode 100644
index 0000000..331e38e
--- /dev/null
+++ b/core/src/main/AndroidManifest.xml
@@ -0,0 +1,3 @@
+
+
+
diff --git a/core/src/main/java/com/chwl/core/Constants.java b/core/src/main/java/com/chwl/core/Constants.java
new file mode 100644
index 0000000..20d8a89
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/Constants.java
@@ -0,0 +1,120 @@
+package com.chwl.core;
+
+import com.chwl.library.common.application.Env;
+import com.chwl.library.utils.config.BasicConfig;
+import com.chwl.library.utils.pref.CommonPref;
+
+import java.io.File;
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * 常量集合
+ * Created by Administrator on 2017/11/9.
+ */
+public class Constants {
+ public static final String ERBAN_DIR_NAME = XConstants.XCHAT_DIR_NAME;
+ public static final String nimAppKey = Env.isDebug() ?
+ SdkConfig.INSTANCE.getNimKeyDebug() : SdkConfig.INSTANCE.getNimKeyRelease();
+// public static final String nimAppSecret = "da03b83af84a";
+ /**
+ * 百度统计
+ */
+
+ public static final String LOG_DIR = ERBAN_DIR_NAME + File.separator + "logs";
+ public static final String CONFIG_DIR = ERBAN_DIR_NAME + File.separator + "config";
+ public static final String VOICE_DIR = ERBAN_DIR_NAME + File.separator + "voice";
+ public static final String CACHE_DIR = ERBAN_DIR_NAME + File.separator + "cache";
+ public static final String HTTP_CACHE_DIR = ERBAN_DIR_NAME + File.separator + "http";
+ public static final String IMAGE_CACHE_DIR = ERBAN_DIR_NAME + File.separator + "image";
+ public static final String DYNAMIC_CACHE_DIR = ERBAN_DIR_NAME + File.separator + "dynamic";
+
+
+ public static final String KEY_MAIN_POSITION = "key_main_position";
+
+ public static final int RESULT_OK = 200;
+
+ public static final int PAGE_START = 1;
+ public static final int PAGE_SIZE = 20;
+ public static final int PAGE_HOME_HOT_SIZE = 12;
+ public static final int BILL_PAGE_SIZE = 50;
+
+ public static final int DEBUG_MAX_UID = 100000;
+
+
+ public static final String HOME_TAB_INFO = "home_tab_info";
+ public static final String KEY_USER_INFO = "key_user_info";
+
+ public static final String KEY_HOME_LIST = "key_home_list";
+ public static final String KEY_HOME_HOT_LIST = "key_home_hot_list";
+ public static final String KEY_HOME_NO_HOT_LIST = "key_home_no_hot_list";
+
+ public static final int FAN_MAIN_PAGE_TYPE = 100;
+ public static final int FAN_NO_MAIN_PAGE_TYPE = 101;
+ public static final String KEY_PAGE_TYPE = "page_type";
+ public static final String KEY_MAIN_TAB_LIST = "main_tab_list";
+
+ public static final String KEY_POSITION = "position";
+
+
+ public static final String CHARGE_UNION_PAY = "fastpay";
+
+ public static final int PAGE_TYPE_MAIN_FRAGMENT = 102;
+
+ /**
+ * 房间相关Key设置
+ */
+ public static final String ROOM_UPDATE_KEY_POSTION = "micPosition";
+ public static final String ROOM_UPDATE_KEY_UID = "micUid";
+ public static final String ROOM_UPDATE_KEY_GENDER = "gender";
+
+ public static final String KEY_CHAT_ROOM_INFO_ROOM = "roomInfo";
+ public static final String KEY_CHAT_ROOM_INFO_MIC = "micQueue";
+
+ public static final String ROOM_UID = "ROOM_UID";
+ public static final String ROOM_TYPE = "ROOM_TYPE";
+ public static final String ROOM_INFO = "ROOM_INFO";
+ public static final String IS_ROOM_MIN = "is_room_min";
+ public static final String IS_PARTY = "is_party";
+
+ /**
+ * 座驾版本第一次显示控制key
+ */
+ public static final String SHOW_CAR_GUIDE = "show_car_guide";
+
+ public static final String NEW_USER_ICON = "https://image.zhongjialx.com/newUserIcon.png";
+
+ public static final String IS_SEND = "isSend";
+ public static final String TOP_TITLE = "top_title";
+
+ public static final int CLIENT_ROLE_BROADCASTER = 1;
+ public static final int CLIENT_ROLE_AUDIENCE = 2;
+
+ public static final int DRAGON_BAR_ID = XConstants.DRAGON_BALL_ID;
+
+ public static final byte TYPE_JOINED = 1;
+ public static final byte TYPE_RECOMMEND = 2;
+ public static final byte TYPE_ALL = 0;
+
+ public static final String WXPAY_REFERER = (BuildConfig.DEBUG && CommonPref.instance(BasicConfig.INSTANCE.getAppContext()).getInt(Env.KEY_ENVIRONMENT) == Env.EnvType.Debug.code) ?
+ XConstants.KEY_REFERER_DEBUG : XConstants.KEY_REFERER_RELEASE;
+
+ //相亲模式男神坑位下标
+ public static final List maleIndex = Arrays.asList(0, 1, 4, 5);
+
+ public static final String GOOGLE = com.chwl.library.common.Constants.GOOGLE;
+
+ public static final String ANDROID = "android";
+
+ //上传的图片 默认大小不能超过大小 640KB
+ public static final int UPLOAD_IMAGE_MAX_FILE_LENGTH = 640;
+ //上传的图片 默认宽高最大值 2340
+ public static final int UPLOAD_IMAGE_MAX_SIZE = 2340;
+ //上传的gif 默认大小不能超过 1MB
+ public static final int UPLOAD_GIF_MAX_SIZE = 1 << 20;
+
+ public static final String PHONE_LOGIN = "phone_login";
+
+ public static final String IS_SHOW_FREE_GIFT = "is_show_free_gift";
+
+}
diff --git a/core/src/main/java/com/chwl/core/DemoCache.java b/core/src/main/java/com/chwl/core/DemoCache.java
new file mode 100644
index 0000000..6983050
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/DemoCache.java
@@ -0,0 +1,346 @@
+package com.chwl.core;
+
+import android.text.TextUtils;
+
+import androidx.annotation.Nullable;
+
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import com.netease.nimlib.sdk.StatusBarNotificationConfig;
+import com.chwl.core.auth.AuthModel;
+import com.chwl.core.auth.entity.AccountInfo;
+import com.chwl.core.auth.entity.TicketInfo;
+import com.chwl.core.home.bean.MainTabInfo;
+import com.chwl.core.initial.bean.SplashComponent;
+import com.chwl.core.initial.bean.InitInfo;
+import com.chwl.core.noble.bean.NobleConfig;
+import com.chwl.core.noble.bean.NobleRight;
+import com.chwl.core.utils.CurrentTimeUtils;
+import com.chwl.core.utils.SharedPreferenceUtils;
+import com.chwl.library.utils.pref.ObjectPref;
+import com.chwl.library.utils.pref.SettingsPref;
+
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+
+
+/**
+ * Created by zhouxiangfeng on 2017/5/6.
+ */
+
+public class DemoCache {
+ public static final String KEY_IS_FIRST_HOME_HIGH_PARTY_DIALOG = "IsFirstHomeHighPartyDialog";
+ private static final String KEY_BOX_MESSAGE = "key_box_message";
+ private static final String KEY_TICKET_INFO = "TicketInfo";
+ private static final String KEY_ACCOUNT_INFO = "AccountInfo";
+ private static final String KEY_FACE_LIST_INFO = "FaceListInfo";
+ private static final String KEY_INIT_DATA = "InitInfo";
+ private static final String KEY_INIT_DATA_SAVE_TIME = "InitInfoSavingTime";
+ private static final String KEY_INIT_DATA_SPLASH_PICTURE = "InitInfoSplashPicture";
+ private static final String KEY_INIT_DATA_SPLASH_DATA = "InitInfoSplashData";
+ private static final String KEY_INIT_DATA_NOBLE_VERSION = "InitInfoNobleVersion";
+ private static final String KEY_INIT_DATA_NOBLE_RIGHTS = "InitInfoNobleRights";
+ private static final String KEY_INIT_DATA_NOBLE_CONFIGS = "InitInfoNobleConfigs";
+ private static final String KEY_RED_PACKAGE = "RedPackage";
+ private static final String KEY_AT_MSG_UUID = "AtMsgUuid";
+ private static final String KEY_BGM_SINGLE_CYCLE = "key_bgm_single_cycle";
+ private static final String KEY_SINGLE_ROOM_TIP = "key_single_room_tip";
+ private static final String KEY_NEW_USER_GIFT = "key_new_user_gift";
+ private static final String KEY_NEW_USER_CHARGE_GIFT = "key_new_user_charge_gift";
+ private static final String KEY_MAIN_TAB_DATA = "key_main_tab_data";
+ private static final String KEY_SPEEDY_MESSAGE_GONE_TIME = "SpeedyMessageGoneTime";
+ private static final String KEY_ANCHOR_CARD_VIEW = "key_anchor_card_view";
+ private static final String KEY_ANCHOR_CARD_VIEW_TIME = "key_anchor_card_view_time";
+ private static final String KEY_LAUNCH_COUNT = "key_launch_count";
+ private static final String KEY_RADISH_TIPS = "key_radish_tips";
+ private static final String KEY_KICK_OUT_ROOM = "kick_out_room";
+ private static final String KEY_BOUND_AUTH_CODE = "key_bound_auth_code";
+ private static final String KEY_MY_FAIRY_INDEX = "key_my_fairy_index";
+
+ private static StatusBarNotificationConfig notificationConfig;
+
+ public static Long readSpeedyMessageGoneTime() {
+ return (Long) ObjectPref.instance().get(KEY_SPEEDY_MESSAGE_GONE_TIME, 0L);
+ }
+
+ public static void saveSpeedyMessageGoneTime(Long savingTime) {
+ ObjectPref.instance().put(KEY_SPEEDY_MESSAGE_GONE_TIME, savingTime);
+ }
+
+ public static Map readNobleRights() {
+ String string = SettingsPref.instance().getString(KEY_INIT_DATA_NOBLE_RIGHTS, null);
+ if (TextUtils.isEmpty(string)) return null;
+ return new Gson().fromJson(string,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ public static void saveNobleRights(String json) {
+ SettingsPref.instance().putString(KEY_INIT_DATA_NOBLE_RIGHTS, json);
+ }
+
+ public static void saveNobleConfigs(String json) {
+ SettingsPref.instance().putString(KEY_INIT_DATA_NOBLE_CONFIGS, json);
+ }
+
+ public static Map readNobleConfigs() {
+ String string = SettingsPref.instance().getString(KEY_INIT_DATA_NOBLE_CONFIGS, null);
+ if (TextUtils.isEmpty(string)) return null;
+ return new Gson().fromJson(string,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ public static Map readRedPackage() {
+ String string = SettingsPref.instance().getString(KEY_RED_PACKAGE, null);
+ if (TextUtils.isEmpty(string)) return null;
+ return new Gson().fromJson(string,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ public static void saveRedPackage(String id) {
+ Map map = readRedPackage();
+ if (map == null) map = new HashMap<>();
+ for (Iterator> it = map.entrySet().iterator(); it.hasNext(); ) {
+ if (CurrentTimeUtils.getCurrentTime() - it.next().getValue() > 60 * 60 * 24 * 7 * 1000) {
+ it.remove();
+ }
+ }
+ map.put(id, CurrentTimeUtils.getCurrentTime());
+ SettingsPref.instance().putString(KEY_RED_PACKAGE, new Gson().toJson(map));
+ }
+
+ public static Map readAtMsgUuid() {
+ String string = SettingsPref.instance().getString(KEY_AT_MSG_UUID, null);
+ if (TextUtils.isEmpty(string)) return null;
+ return new Gson().fromJson(string,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ //云信聊天室云端历史消息最长保存10天,这里保存30天的应该够用了
+ public static void saveAtMsgUuid(String id) {
+ Map map = readAtMsgUuid();
+ if (map == null) map = new HashMap<>();
+ for (Iterator> it = map.entrySet().iterator(); it.hasNext(); ) {
+ if (CurrentTimeUtils.getCurrentTime() - it.next().getValue() > 60 * 60 * 24 * 30 * 1000L) {
+ it.remove();
+ }
+ }
+ map.put(id, CurrentTimeUtils.getCurrentTime());
+ SettingsPref.instance().putString(KEY_AT_MSG_UUID, new Gson().toJson(map));
+ }
+
+
+ public static void saveBoolean(String key, boolean value) {
+ SettingsPref.instance().putBoolean(key, value);
+ }
+
+ public static Boolean readBoolean(String key, boolean defult) {
+ return SettingsPref.instance().getBoolean(key, defult);
+ }
+
+ public static String readNobleVersion() {
+ return SettingsPref.instance().getString(KEY_INIT_DATA_NOBLE_VERSION);
+ }
+
+ public static void saveNobleVersion(String version) {
+ SettingsPref.instance().putString(KEY_INIT_DATA_NOBLE_VERSION, version);
+ }
+
+ public static String readSplashPicture() {
+ return SettingsPref.instance().getString(KEY_INIT_DATA_SPLASH_PICTURE);
+ }
+
+ public static void saveSplashPicture(String path) {
+ SettingsPref.instance().putString(KEY_INIT_DATA_SPLASH_PICTURE, path);
+ }
+
+ public static Long readInitInfoSavingTime() {
+ return (Long) ObjectPref.instance().get(KEY_INIT_DATA_SAVE_TIME, System.currentTimeMillis());
+ }
+
+ public static void saveInitInfoSavingTime(Long savingTime) {
+ ObjectPref.instance().put(KEY_INIT_DATA_SAVE_TIME, savingTime);
+ }
+
+ public static SplashComponent readSplashInfo() {
+ return (SplashComponent) ObjectPref.instance().readObject(KEY_INIT_DATA_SPLASH_DATA);
+ }
+
+ public static void saveSplashInfo(SplashComponent splashComponent) {
+ ObjectPref.instance().saveObject(KEY_INIT_DATA_SPLASH_DATA, splashComponent);
+ }
+
+ public static InitInfo readInitInfo() {
+ return (InitInfo) ObjectPref.instance().readObject(KEY_INIT_DATA);
+ }
+
+ public static void saveInitInfo(InitInfo initInfo) {
+ ObjectPref.instance().saveObject(KEY_INIT_DATA, initInfo);
+ }
+
+ @Nullable
+ public static List readMainTabInfoList() {
+ String jsonString = String.valueOf(SharedPreferenceUtils.get(KEY_MAIN_TAB_DATA, ""));
+ if (TextUtils.isEmpty(jsonString)) return null;
+ return new Gson().fromJson(jsonString,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ public static void saveMainTabInfoList(List tabInfoList) {
+ SharedPreferenceUtils.put(KEY_MAIN_TAB_DATA, new Gson().toJson(tabInfoList));
+ }
+
+ @Nullable
+ public static String readFaceList() {
+ return (String) ObjectPref.instance().get(KEY_FACE_LIST_INFO, null);
+ }
+
+ public static void saveFaceList(String encrypt) {
+ ObjectPref.instance().put(KEY_FACE_LIST_INFO, encrypt);
+ }
+
+ public static void saveCurrentAccountInfo(AccountInfo accountInfo) {
+ ObjectPref.instance().saveObject(KEY_ACCOUNT_INFO, accountInfo);
+ }
+
+ public static AccountInfo readCurrentAccountInfo() {
+ return (AccountInfo) ObjectPref.instance().readObject(KEY_ACCOUNT_INFO);
+ }
+
+ public static void saveTicketInfo(TicketInfo ticketInfo) {
+ ObjectPref.instance().saveObject(KEY_TICKET_INFO, ticketInfo);
+ }
+
+ public static TicketInfo readTicketInfo() {
+ return (TicketInfo) ObjectPref.instance().readObject(KEY_TICKET_INFO);
+ }
+
+ public static StatusBarNotificationConfig getNotificationConfig() {
+ return notificationConfig;
+ }
+
+ public static void setNotificationConfig(StatusBarNotificationConfig notificationConfig) {
+ DemoCache.notificationConfig = notificationConfig;
+ }
+
+ public static void saveNeedBoxMsg(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_BOX_MESSAGE + AuthModel.get().getCurrentUid(), value);
+ }
+
+ public static Boolean readNeedBoxMsg() {
+ return SettingsPref.instance().getBoolean(KEY_BOX_MESSAGE + AuthModel.get().getCurrentUid(), true);
+ }
+
+ public static void saveBgmSingleCycle(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_BGM_SINGLE_CYCLE, value);
+ }
+
+ public static Boolean readBgmSingleCycle() {
+ return SettingsPref.instance().getBoolean(KEY_BGM_SINGLE_CYCLE, false);
+ }
+
+ public static void saveSingleRoomTip(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_SINGLE_ROOM_TIP, value);
+ }
+
+ public static Boolean readSingleRoomTip() {
+ return SettingsPref.instance().getBoolean(KEY_SINGLE_ROOM_TIP, true);
+ }
+
+ public static void saveNewUserGift(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_NEW_USER_GIFT, value);
+ }
+
+ public static boolean readNewUserGift() {
+ return SettingsPref.instance().getBoolean(KEY_NEW_USER_GIFT, true);
+ }
+
+ /**
+ * @param value 0初始值 1 需要弹窗 2 不需要弹窗
+ */
+ public static void saveNewUserChargeGift(int value) {
+ SettingsPref.instance().putInt(KEY_NEW_USER_CHARGE_GIFT, value);
+ }
+
+ public static int readNewUserChargeGift() {
+ return SettingsPref.instance().getInt(KEY_NEW_USER_CHARGE_GIFT, 0);
+ }
+
+ /**
+ * @param value 0初始值 1 显示首次弹窗 2 非首次弹窗,需要判断时间再显示
+ */
+ public static void saveAnchorCardView(int value) {
+ SettingsPref.instance().putInt(KEY_ANCHOR_CARD_VIEW, value);
+ if (value == 2) {
+ SettingsPref.instance().putLong(KEY_ANCHOR_CARD_VIEW_TIME, CurrentTimeUtils.getCurrentTime());
+ }
+ }
+
+ public static int readAnchorCardView() {
+ return SettingsPref.instance().getInt(KEY_ANCHOR_CARD_VIEW, 0);
+ }
+
+ public static long readAnchorCardViewTime() {
+ return SettingsPref.instance().getLong(KEY_ANCHOR_CARD_VIEW_TIME, 0);
+ }
+
+ public static void saveLaunchCount() {
+ SettingsPref.instance().putInt(KEY_LAUNCH_COUNT, readLaunchCount() + 1);
+ }
+
+ public static int readLaunchCount() {
+ return SettingsPref.instance().getInt(KEY_LAUNCH_COUNT, -1);
+ }
+
+ public static void saveRadishTips(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_RADISH_TIPS, value);
+ }
+
+ public static boolean readRadishTips() {
+ return SettingsPref.instance().getBoolean(KEY_RADISH_TIPS, true);
+ }
+
+ @Nullable
+ public static Map readKickOutRoom() {
+ String string = SettingsPref.instance().getString(KEY_KICK_OUT_ROOM + AuthModel.get().getCurrentUid(), null);
+ if (TextUtils.isEmpty(string)) return null;
+ return new Gson().fromJson(string,
+ new TypeToken>() {
+ }.getType());
+ }
+
+ public static void saveKickOutRoom(String roomUid) {
+ Map map = readKickOutRoom();
+ if (map == null) map = new HashMap<>();
+ for (Iterator> it = map.entrySet().iterator(); it.hasNext(); ) {
+ if (CurrentTimeUtils.getCurrentTime() - it.next().getValue() > XConstants.KICK_OUT_ROOM_LIMIT_ENTER_TIME) {
+ it.remove();
+ }
+ }
+ map.put(roomUid, CurrentTimeUtils.getCurrentTime());
+ SettingsPref.instance().putString(KEY_KICK_OUT_ROOM + AuthModel.get().getCurrentUid(), new Gson().toJson(map));
+ }
+
+ public static void saveBoundAuthCode(boolean value) {
+ SettingsPref.instance().putBoolean(KEY_BOUND_AUTH_CODE, value);
+ }
+
+ public static boolean readBoundAuthCode() {
+ return SettingsPref.instance().getBoolean(KEY_BOUND_AUTH_CODE, false);
+ }
+
+ public static void saveMyFairyIndex(int index) {
+ SettingsPref.instance().putInt(KEY_MY_FAIRY_INDEX, index);
+ }
+
+ public static int readMyFairyIndex() {
+ return SettingsPref.instance().getInt(KEY_MY_FAIRY_INDEX, 0);
+ }
+
+}
diff --git a/core/src/main/java/com/chwl/core/OldHttpObserver.java b/core/src/main/java/com/chwl/core/OldHttpObserver.java
new file mode 100644
index 0000000..bd05839
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/OldHttpObserver.java
@@ -0,0 +1,49 @@
+package com.chwl.core;
+
+import com.chwl.core.bean.response.RequestError;
+import com.chwl.core.bean.response.ResponseData;
+
+import io.reactivex.SingleObserver;
+import io.reactivex.disposables.Disposable;
+import retrofit2.HttpException;
+
+/**
+ * @author jack
+ * @Description
+ * @Date 2018/5/7
+ */
+
+public abstract class OldHttpObserver implements SingleObserver {
+
+ @Override
+ public void onSubscribe(Disposable d) {
+
+ }
+
+
+ @Override
+ public void onError(Throwable throwable) {
+ try {
+ if (throwable instanceof HttpException){
+ retrofit2.Response response = ((HttpException) throwable).response();
+ if (response.errorBody() == null){
+ onFail(new RequestError(throwable.getMessage()));
+ return;
+ }
+ byte[] bodyByte = response.errorBody().bytes();
+ if (bodyByte.length <= 0){
+ onFail(new RequestError(throwable.getMessage()));
+ return;
+ }
+ ResponseData error = new ResponseData(bodyByte);
+ onFail(new RequestError(error));
+ }else {
+ onFail(new RequestError(throwable.getMessage()));
+ }
+ } catch (Exception e) {
+ onFail(new RequestError(e.getMessage()));
+ }
+ }
+
+ public abstract void onFail(RequestError error);
+}
diff --git a/core/src/main/java/com/chwl/core/PreferencesUtils.java b/core/src/main/java/com/chwl/core/PreferencesUtils.java
new file mode 100644
index 0000000..d45f181
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/PreferencesUtils.java
@@ -0,0 +1,113 @@
+package com.chwl.core;
+
+import android.content.Context;
+
+import com.netease.nimlib.sdk.StatusBarNotificationConfig;
+import com.netease.nimlib.sdk.auth.LoginInfo;
+import com.chwl.core.auth.entity.AccountInfo;
+import com.chwl.core.auth.entity.TicketInfo;
+import com.chwl.library.utils.config.BasicConfig;
+import com.chwl.library.utils.pref.ObjectPref;
+import com.chwl.library.utils.pref.SettingsPref;
+
+/**
+ * Created by zhouxiangfeng on 2017/5/19.
+ */
+
+public class PreferencesUtils {
+
+ private static AccountInfo accountInfo;
+ private static TicketInfo ticketInfo;
+
+ private static final String KEY_TICKET_INFO = "TicketInfo";
+ private static final String KEY_FRIST_SEED_GOLD = "FristSendGold";
+ private static final String KEY_FRIST_USER = "FristUser";
+ private static final String KEY_LOGIN_INFO = "LoginInfo";
+ private static final String KEY_ACCOUNT_INFO = "AccountInfo";
+ private static final String KEY_NOTI_TOGGLE = "NotiToggle";
+ private static final String KEY_NOTI_CONFIG = "StatusBarNotificationConfig";
+ private static final String KEY_AGREE_PRIVACY = "key_agree_privacy";
+
+
+ public static void saveTicketInfo(TicketInfo ticketInfo) {
+ ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).saveObject(KEY_TICKET_INFO, ticketInfo);
+ }
+
+
+ public static void saveCurrentAccountInfo(AccountInfo accountInfo) {
+ ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).saveObject(KEY_ACCOUNT_INFO, accountInfo);
+ }
+
+
+ public static void saveLoginInfo(LoginInfo loginInfo) {
+ ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).saveObject(KEY_LOGIN_INFO, loginInfo);
+ }
+
+ public static AccountInfo readCurrentAccountInfo() {
+ if (null == accountInfo) {
+ accountInfo = (AccountInfo) ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).readObject(KEY_ACCOUNT_INFO);
+ }
+ return accountInfo;
+ }
+
+ public static TicketInfo readTicketInfo() {
+ if (null == ticketInfo) {
+ return (TicketInfo) ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).readObject(KEY_TICKET_INFO);
+ }
+ return ticketInfo;
+ }
+
+ public static LoginInfo readLoginInfo(Context context) {
+ return (LoginInfo) ObjectPref.instance(context).readObject(KEY_LOGIN_INFO);
+ }
+
+
+ public static boolean readNotificationToggle() {
+ return SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).getBoolean(KEY_NOTI_TOGGLE, true);
+ }
+
+ public static void setNotificationToggle(boolean isOpen) {
+ SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).putBoolean(KEY_NOTI_TOGGLE, isOpen);
+ }
+
+ public static boolean readFristSendGold() {
+ return SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).getBoolean(KEY_FRIST_SEED_GOLD, true);
+ }
+
+ public static void setFristSendGold(boolean isOpen) {
+ SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).putBoolean(KEY_FRIST_SEED_GOLD, isOpen);
+ }
+
+ public static boolean readFristUser() {
+ return SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).getBoolean(KEY_FRIST_USER, true);
+ }
+
+ public static void setFristUser(boolean isOpen) {
+ SettingsPref.instance(BasicConfig.INSTANCE.getAppContext()).putBoolean(KEY_FRIST_USER, isOpen);
+ }
+
+
+ public static void saveStatusBarNotificationConfig(StatusBarNotificationConfig notificationConfig) {
+ ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).put(KEY_NOTI_CONFIG, notificationConfig);
+ }
+
+ public static StatusBarNotificationConfig readStatusBarNotificationConfig() {
+ return (StatusBarNotificationConfig) ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).readObject(KEY_NOTI_CONFIG);
+ }
+
+ public static void clear() {
+ accountInfo = null;
+ ticketInfo = null;
+ saveCurrentAccountInfo(new AccountInfo());
+ saveTicketInfo(new TicketInfo());
+ saveLoginInfo(new LoginInfo("", ""));
+ }
+
+ public static void savePrivacyState(boolean privacy) {
+ ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).put(KEY_AGREE_PRIVACY, privacy);
+ }
+
+ public static boolean readPrivacyState() {
+ return (boolean) ObjectPref.instance(BasicConfig.INSTANCE.getAppContext()).get(KEY_AGREE_PRIVACY, false);
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/RegionHelper.kt b/core/src/main/java/com/chwl/core/RegionHelper.kt
new file mode 100644
index 0000000..b9247e8
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/RegionHelper.kt
@@ -0,0 +1,118 @@
+package com.chwl.core
+
+import android.widget.TextView
+import androidx.lifecycle.Lifecycle
+import androidx.lifecycle.coroutineScope
+import com.example.lib_utils.AppUtils
+import com.example.lib_utils.TelephonyUtils
+import com.google.gson.Gson
+import com.google.gson.reflect.TypeToken
+import com.chwl.core.bean.RegionBean
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.withContext
+import java.io.InputStream
+
+/**
+ * Created by Max on 2023/12/7 18:23
+ * Desc:地区
+ **/
+class RegionHelper {
+
+ fun loadRecommendRegion(lifecycle: Lifecycle, textView: TextView){
+ lifecycle.coroutineScope.launch {
+ RegionHelper().getCurrentOrDefRegion().let {
+ textView.text = it.fullCode
+ }
+ }
+ }
+
+ private fun getDefaultRegion(): RegionBean {
+ return RegionBean(name = "Taiwan", abbr = "TW", mcc = "466", code = "886")
+ }
+
+ /**
+ * 获取当前地区或默认
+ */
+ private suspend fun getCurrentOrDefRegion(): RegionBean {
+ return withContext(Dispatchers.IO) {
+ var operator = TelephonyUtils.getNetWorkOperator()
+ if (operator.isNullOrEmpty()) {
+ operator = TelephonyUtils.getSimOperator()
+ }
+ val mcc = operator?.take(3)
+ val region = getAllRegionList().firstOrNull {
+ it.mcc == mcc
+ }
+ region ?: getDefaultRegion()
+ }
+ }
+
+ /**
+ * 获取地区选择器列表
+ */
+ suspend fun getRegionSelectorList(groupItemType: Int): List {
+ return withContext(Dispatchers.IO) {
+ val list = ArrayList()
+ list.addAll(getHotRegionList())
+ var lastGroup: Char? = null
+ list.addAll(getAllRegionList()
+ .map {
+ val firstName = it.name?.firstOrNull()?.uppercaseChar() ?: '#'
+ if (firstName in 'A'..'Z') {
+ it.groupName = firstName
+ it.sortedBy = "$firstName${it.name?.uppercase()}"
+ } else {
+ it.groupName = '#'
+ it.sortedBy = "${'Z' + 1}${it.name?.uppercase()}"
+ }
+ it
+ }
+ .sortedBy {
+ it.sortedBy
+ }.map {
+ val groupName = it.groupName ?: '#'
+ if (groupName != lastGroup) {
+ it.itemType = groupItemType
+ }
+ lastGroup = groupName
+ it
+ }
+ )
+ list
+ }
+ }
+
+ /**
+ * 获取热门地区
+ */
+ suspend fun getHotRegionList(): List {
+ return getRegionListFromAssets("hot_region.json")
+ }
+
+ /**
+ * 获取全部地区
+ */
+ suspend fun getAllRegionList(): List {
+ return getRegionListFromAssets("region.json")
+ }
+
+ /**
+ * 从资源文件中获取地区列表
+ */
+ private fun getRegionListFromAssets(fileName: String): MutableList {
+ //获取IO流
+ try {
+ val inputStream: InputStream =
+ AppUtils.getApp().applicationContext.assets.open(fileName)
+ val json: String
+ inputStream.use {
+ json = it.bufferedReader().readText()
+ }
+ return Gson().fromJson(json, object : TypeToken>() {}.type)
+ } catch (e: Exception) {
+ e.printStackTrace()
+ }
+ return mutableListOf()
+ }
+}
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/SdkConfig.kt b/core/src/main/java/com/chwl/core/SdkConfig.kt
new file mode 100644
index 0000000..c4c5c41
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/SdkConfig.kt
@@ -0,0 +1,28 @@
+package com.chwl.core
+
+import com.chwl.library.utils.codec.DESUtils
+
+object SdkConfig {
+ // 1400823228
+ fun getTXAppId() = decrypt("cTkOfnb3r7vaFs4wfq3Aog==")
+
+ // 3da88e33bc4f45019cc867ec51d7b465
+ fun getAgoraKey() = decrypt("k9xONsWAgzCkXtzm5Wu+4U8sxtf9XKwlXXAl3l9BE6ppYKlmIfzkBA==")
+
+ // 3da88e33bc4f45019cc867ec51d7b465
+ fun getAgoraKeyDebug() = decrypt("k9xONsWAgzCkXtzm5Wu+4U8sxtf9XKwlXXAl3l9BE6ppYKlmIfzkBA==")
+
+ // 79bc37000f4018a2a24ea9dc6ca08d32
+ fun getNimKeyDebug() = decrypt("/1KxSXOF+PIET/9E3Aq3uBF7eesBfAABUy05XDWBl+JpYKlmIfzkBA==")
+
+ // 7371d729710cd6ce3a50163b956b5eb6
+ fun getNimKeyRelease() = decrypt("g3J0oqC++xZPMO7VrKdr+eXlAnxFhWFvdpD0Bm9sR01pYKlmIfzkBA==")
+
+ private fun decrypt(value: String): String {
+ return try {
+ DESUtils.decryptDef2(value)
+ } catch (e: Exception) {
+ ""
+ }
+ }
+}
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/UriHelper.java b/core/src/main/java/com/chwl/core/UriHelper.java
new file mode 100644
index 0000000..5dda9b1
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/UriHelper.java
@@ -0,0 +1,74 @@
+package com.chwl.core;
+
+import android.net.Uri;
+import android.text.TextUtils;
+
+public class UriHelper {
+
+ /**
+ * @param url 访问链接
+ * @return 返回增加时间戳，避免重复链接访问缓存内容
+ */
+ public static String applyTimestampForUrl(String url) {
+ if (TextUtils.isEmpty(url)) {
+ return "";
+ }
+ url = appendUri(url, "t", String.valueOf(System.currentTimeMillis()));
+ return url;
+ }
+
+ /**
+ * URL增加参数
+ *
+ * @param uri 原始链接
+ * @param appendQueryKey 增加参数，key
+ * @param appendQueryValue 增加参数，value
+ * @return 拼接后的完整链接
+ */
+ public static String appendUri(String uri, String appendQueryKey, String appendQueryValue) {
+ if (TextUtils.isEmpty(uri)) {
+ return "";
+ }
+ if (TextUtils.isEmpty(appendQueryKey) || TextUtils.isEmpty(appendQueryValue)) {
+ return uri;
+ }
+ Uri oldUri = Uri.parse(uri);
+
+ String value = oldUri.getQueryParameter(appendQueryKey);
+ if (!TextUtils.isEmpty(value)) {
+ return uri;
+ }
+ Uri.Builder builder = Uri.parse(uri).buildUpon();
+ builder.appendQueryParameter(appendQueryKey, appendQueryValue);
+ return builder.toString();
+ }
+ /**
+ * URL增加参数 值允许为空字符串
+ *
+ * @param uri 原始链接
+ * @param appendQueryKey 增加参数，key
+ * @param appendQueryValue 增加参数，value
+ * @return 拼接后的完整链接
+ */
+ public static String appendUriAllowEmpty(String uri, String appendQueryKey, String appendQueryValue) {
+ if (TextUtils.isEmpty(uri)) {
+ return "";
+ }
+ if (TextUtils.isEmpty(appendQueryKey)) {
+ return uri;
+ }
+ Uri oldUri = Uri.parse(uri);
+
+ String value = oldUri.getQueryParameter(appendQueryKey);
+ if (!TextUtils.isEmpty(value)) {
+ return uri;
+ }
+ Uri.Builder builder = Uri.parse(uri).buildUpon();
+ if (TextUtils.isEmpty(appendQueryValue)) {
+ builder.appendQueryParameter(appendQueryKey, "");
+ } else {
+ builder.appendQueryParameter(appendQueryKey, appendQueryValue);
+ }
+ return builder.toString();
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/UriProvider.java b/core/src/main/java/com/chwl/core/UriProvider.java
new file mode 100644
index 0000000..cfb371c
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/UriProvider.java
@@ -0,0 +1,386 @@
+package com.chwl.core;
+
+import android.text.TextUtils;
+
+import com.chwl.core.manager.AvRoomDataManager;
+import com.chwl.library.common.application.Env;
+/**
+ * 请求接口接口地址
+ */
+public class UriProvider {
+
+ /**
+ * 默认以下生产环境地址
+ */
+ public static String JAVA_WEB_URL = "https://";
+ public static String IM_SERVER_URL = "https://";
+ public static String AAPP = "/molistar";
+
+ /**
+ * 初始化URL
+ *
+ * @param serverDebug
+ * @param serverStaging
+ * @param serverRelease
+ */
+ public static void initUri(String serverDebug, String serverStaging, String serverRelease) {
+ Env.EnvType envType = Env.getCurrentEnv();
+ if (envType == Env.EnvType.Debug) {
+ initUrl(serverDebug);
+ } else if (envType == Env.EnvType.Staging) {
+ initUrl(serverStaging);
+ } else if (envType == Env.EnvType.Release) {
+ initUrl(serverRelease);
+ } else {
+ initUrl(serverDebug);
+ }
+
+ }
+
+ private static void initUrl(String url) {
+ JAVA_WEB_URL = url;
+ IM_SERVER_URL = url;
+ }
+
+ /**
+ * 获取房间背景(有动效)
+ *
+ * @return -
+ */
+ public static String getRoomBg() {
+ return IM_SERVER_URL.concat(AAPP+"/modules/noble/roomBgList.html");
+ }
+
+ /**
+ * 贵族介绍页
+ */
+ public static String getNobleIntro() {
+ return IM_SERVER_URL.concat(AAPP+"/modules/nobles/intro.html");
+ }
+
+ /**
+ * 帮助页
+ */
+ public static String getHelp() {
+ return IM_SERVER_URL.concat(AAPP+"/modules/rule/guide.html");
+ }
+
+ /**
+ * 等级界面
+ */
+ public static String getUserLevelUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/level/index.html");
+ }
+
+ /**
+ * 用户协议H5
+ *
+ * @return
+ */
+ public static String getUserProtocolUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/protocol.html");
+ }
+
+ /**
+ * 举报H5
+ *
+ * @return
+ */
+ public static String getUserReportUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/inform/index.html");
+ }
+
+ /**
+ * MoliParty专属，实名认证页面
+ *
+ * @return
+ */
+ public static String getTutuRealNamePage() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/identity/new.html");
+ }
+
+ public static String getCommnunityNorms() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/community-norms.html");
+ }
+
+ /**
+ * 隐私协议
+ *
+ * @return
+ */
+ public static String getPrivacyAgreement() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/privacy-wap.html");
+ }
+
+ public static String getLinkUrl(String linkUrl) {
+ if (TextUtils.isEmpty(linkUrl)) {
+ return JAVA_WEB_URL;
+ }
+ return JAVA_WEB_URL.concat(linkUrl);
+ }
+
+ /**
+ * 个人魅力榜
+ */
+ public static String getPersonalCharismaRank() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/charm/index.html");
+ }
+
+ /**
+ * 相亲规则
+ *
+ * @return
+ */
+ public static String getDatingRule() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/dating.html");
+ }
+
+ /**
+ * 第三方SDK协议
+ *
+ * @return
+ */
+ public static String getSDKPermissionUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/sdk.html");
+ }
+
+ /**
+ * 隐私指引
+ */
+ public static String getPrivacyUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/privacy-wap.html");
+ }
+
+ /**
+ * 用户充值协议
+ */
+ public static String getChargeAgreementUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/rechargeAgreement.html");
+ }
+
+ /**
+ * 用户注册服务协议
+ */
+ public static String getRegistrationAgreementUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/protocol.html");
+ }
+
+ /**
+ * 账号注销协议
+ */
+ public static String getCancellationAgreementUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/logout-agreement.html");
+ }
+
+ /**
+ * 直播乱象
+ *
+ * @return
+ */
+ public static String getLiveAgreement() {
+ return JAVA_WEB_URL.concat(AAPP+"/activity/activemodel/index.html?code=ZBGG");
+ }
+
+ /**
+ * 贵族中心帮助页
+ */
+ public static String getVipHelpUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/introduction-patrician.html");
+ }
+
+ /**
+ * 贵族榜
+ */
+ public static String getRankListUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/noble/index.html");
+ }
+
+ /**
+ * 获取宝箱钥匙
+ */
+ public static String getBoxKey() {
+ return JAVA_WEB_URL.concat(AAPP+"/activity/explore/index.html");
+ }
+
+
+ /**
+ * 宝箱记录
+ */
+ public static String getBoxHistory() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rank/index.html#/newWishingWellRecord");
+ }
+
+ /**
+ * 宝箱帮助
+ */
+ public static String getBoxHelp() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/newWishingWellRule.html");
+ }
+
+ public static String getRanking() {
+ return IM_SERVER_URL.concat(AAPP+"/modules/rank/index.html#/rank");
+ }
+
+ /**
+ * 钻石明细
+ */
+ public static String getDiamondDetail() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/myincome/index.html#/DiamondLog");
+ }
+
+ /**
+ * 金币明细
+ */
+ public static String getGoldDetail() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/myincome/index.html#/GoldLog");
+ }
+
+ /**
+ * 邀请好友
+ */
+ public static String getInviteFan() {
+ return JAVA_WEB_URL.concat(AAPP+"/activity/2024-invitationFission/index.html");
+ }
+
+ /**
+ * 房间排行榜
+ */
+ public static String getRoomRanking() {
+ return IM_SERVER_URL.concat(AAPP+"/modules/room_rank/index.html?roomUid=" + AvRoomDataManager.get().getRoomUid());
+ }
+
+ /**
+ * 个播小时榜
+ */
+ public static String getSingleRoomHourRankUrl(long roomUid) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/room_rank/hourRank.html?roomUid=" + roomUid);
+ }
+
+ /**
+ * 牌照房小时榜
+ */
+ public static String getRoomHourRankUrl(long roomUid) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/room_rank/hourRankLicense.html?roomUid=" + roomUid);
+ }
+ /**
+ * 粉丝团规则
+ */
+ public static String getFansTeamRuleUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/fans_club/rule.html");
+ }
+
+ /**
+ * 粉丝团排行
+ */
+ public static String getFansTeamRankUrl(long roomUid) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/fans_club/fans_rank.html?roomUid=" + roomUid);
+ }
+
+ /**
+ * 我的粉丝团
+ */
+ public static String getFansTeamMyFansUrl(long roomUid) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/fans_club/myfans.html?roomUid=" + roomUid);
+ }
+
+ /**
+ * 开通粉丝团
+ */
+ public static String getFansTeamOpenUrl(long roomUid) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/fans_club/nameplate.html?roomUid=" + roomUid);
+ }
+ /**
+ * 周星榜
+ */
+ public static String getWeekStarUrl() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/weekStar/newWeekStar.html");
+ }
+
+ /**
+ * 幸运礼物说明
+ */
+ public static String getLuckyGiftRule(int giftID) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/luckyGiftRule.html?giftID=" + giftID);
+ }
+
+
+ /**
+ * 游戏排行榜
+ */
+ public static String getGameRank() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/gameRank/index.html");
+ }
+
+ /**
+ * cp规则
+ */
+ public static String getCpRule() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/cpRule.html");
+ }
+ /**
+ * boom规则
+ */
+ public static String getBoomRule(long partitionId) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rule/boom.html?partitionId="+partitionId);
+ }
+
+ /**
+ * 房间等级 规则
+ */
+ public static String getRoomLevelRule() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/roomLevel/index.html");
+ }
+
+ /**
+ * 幸运红包 规则
+ */
+ public static String getLuckyBagRule() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/luckyBagRules/index.html");
+ }
+
+ /**
+ * 人机验证h5
+ */
+ public static String getHumanMachineVerification() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/humanMachineVerification/index.html");
+ }
+
+ /**
+ * 活动详情-h5
+ * http://api.moliparty.com/eparty/modules/eventDetails/index.html?eventId=21
+ */
+ public static String getEventDetail(long id) {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/eventDetails/index.html?eventId="+id);
+ }
+ //vip中心
+ public static String getVipCenter() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/vip_Center/index.html");
+ }
+
+ //金币转赠,我的转赠
+ public static String getMyTransfer() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/rechargeAgent/index.html#/myTransfer");
+ }
+
+ //首充- 首页弹窗
+ public static String getFirstRechargeIndex() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/firstRechargeBonus/index.html ");
+ }
+
+ //首充- 钱币banner跳转
+ public static String getFirstRechargeBonus() {
+ return JAVA_WEB_URL.concat(AAPP+"/modules/firstRechargeBonus/First_Bonus.html ");
+ }
+
+
+ public static String toFullUrl(String shortUrl) {
+ if (shortUrl == null) {
+ return null;
+ }
+ if (shortUrl.startsWith("http")) {
+ return shortUrl;
+ } else {
+ return JAVA_WEB_URL.concat(shortUrl);
+ }
+ }
+}
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/XConstants.java b/core/src/main/java/com/chwl/core/XConstants.java
new file mode 100644
index 0000000..85c1c6c
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/XConstants.java
@@ -0,0 +1,86 @@
+package com.chwl.core;
+
+
+/**
+ * Created by MadisonRong on 09/08/2018.
+ */
+
+public class XConstants {
+
+ /**
+ * 包名(各種緩存目錄的根目錄)
+ */
+ public static final String XCHAT_DIR_NAME = "com.hhchu.molistar";
+
+ /**
+ * sp名字
+ */
+ public static final String XCHAT_SHARE_PREFERENCE_NAME = "accompany_share_data";
+
+ /**
+ * 加密接口參數
+ */
+ public static final String DES_ENCRYPT_KEY_SMS_PARAMS = "rpbs6us1m8r2j9g6u06ff2bo18orwaya";
+
+ /**
+ * 加密接口簽名
+ */
+ public static final String DES_ENCRYPT_KEY_SMS_SIGN = "c8d514b3cdc44e898e027940e84f036c";
+
+ /**
+ * 本地數據庫的名字(目前是用 realm 數據庫)
+ */
+ public static final String XCHAT_DATABASE_NAME = "accompany.db";
+
+ /**
+ * 龍珠表情 ID
+ */
+ public static final int DRAGON_BALL_ID = 40;
+
+ /**
+ * 系統消息那個用戶的UID
+ */
+ public static final String SYSTEM_MESSAGE_UID = BuildConfig.DEBUG ? "935008" : "904770";
+
+
+ /**
+ * 小秘書那個用戶的UID
+ */
+ public static final String SECRETARY_UID = BuildConfig.DEBUG ? "935001" : "904769";
+
+ /**
+ * 賽事消息UID
+ */
+ public static final String MATCH_UID = BuildConfig.DEBUG ? "1296314" : "904772";
+ public static final String SHOW = "show";
+ public static final String HIDE = "hide";
+
+ // 舉報入口標識
+ public static final String REPORT_TYPE_CHAT = "chat"; // 私聊
+ public static final String REPORT_TYPE_PERSONAL = "personal"; // 個人中心
+ public static final String REPORT_TYPE_ROOM = "room"; // 房間
+ public static final String REPORT_TYPE_VOICE = "voice"; // 聲音瓶子
+ public static final String REPORT_TYPE_USERCARD = "USERCARD"; // 資料卡片
+ public static final String REPORT_TYPE_WORLDDYNAMIC = "WORLDDYNAMIC"; // 世界動態
+ public static final String REPORT_TYPE_DYNAMICCOMMENT = "DYNAMICCOMMENT"; // 世界動態
+ public static final String REPORT_TYPE_PERSONAL_DYNAMIC = "PERSONAL_DYNAMIC"; // 個人頁動態
+ public static final String REPORT_TYPE_DYNAMIC_SQUARE = "DYNAMIC_SQUARE";//廣場動態
+ /**
+ * Referer (DEBUG)
+ */
+ public static final String KEY_REFERER_DEBUG = "http://api.molistar.xyz/";
+
+ /**
+ * Referer (RELEASE)
+ */
+ public static final String KEY_REFERER_RELEASE = "https://api.molistar.xyz/";
+ public static final String APP_MARK = "molistar";
+ /**
+ * 聊天室文本消息易盾反垃圾業務id
+ */
+ public static final String CHAT_ROOM_ANTI_SPAM_CONFIG_ID = BuildConfig.DEBUG ? "3611b99d0457202a7f69151288183236" : "bddbbb617e9da4fcd08c6baf6686ad01";
+
+ public static final int KICK_OUT_ROOM_LIMIT_ENTER_TIME = 5 * 60 * 1000;
+ public static final int CODE_IGNORE_TOAST = 5263;
+ public static int SELECT_ANIM_DURATION = 2500;
+}
diff --git a/core/src/main/java/com/chwl/core/activity/bean/LotteryInfo.java b/core/src/main/java/com/chwl/core/activity/bean/LotteryInfo.java
new file mode 100644
index 0000000..3882111
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/activity/bean/LotteryInfo.java
@@ -0,0 +1,46 @@
+package com.chwl.core.activity.bean;
+
+import java.io.Serializable;
+
+/**
+ * Created by chenran on 2017/12/26.
+ */
+
+public class LotteryInfo implements Serializable{
+ private long uid;
+ private int leftDrawNum;
+ private int totalDrawNum;
+ private int totalWinDrawNum;
+
+ public long getUid() {
+ return uid;
+ }
+
+ public void setUid(long uid) {
+ this.uid = uid;
+ }
+
+ public int getLeftDrawNum() {
+ return leftDrawNum;
+ }
+
+ public void setLeftDrawNum(int leftDrawNum) {
+ this.leftDrawNum = leftDrawNum;
+ }
+
+ public int getTotalDrawNum() {
+ return totalDrawNum;
+ }
+
+ public void setTotalDrawNum(int totalDrawNum) {
+ this.totalDrawNum = totalDrawNum;
+ }
+
+ public int getTotalWinDrawNum() {
+ return totalWinDrawNum;
+ }
+
+ public void setTotalWinDrawNum(int totalWinDrawNum) {
+ this.totalWinDrawNum = totalWinDrawNum;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/activity/event/ActivityEvent.java b/core/src/main/java/com/chwl/core/activity/event/ActivityEvent.java
new file mode 100644
index 0000000..46c3a1e
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/activity/event/ActivityEvent.java
@@ -0,0 +1,13 @@
+package com.chwl.core.activity.event;
+
+import com.chwl.core.activity.bean.LotteryInfo;
+
+public class ActivityEvent {
+
+ private LotteryInfo lotteryInfo;
+
+ public LotteryInfo setLotteryInfo(LotteryInfo lotteryInfo) {
+ this.lotteryInfo = lotteryInfo;
+ return this.lotteryInfo;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/activity/model/ActivityModel.java b/core/src/main/java/com/chwl/core/activity/model/ActivityModel.java
new file mode 100644
index 0000000..9dbd915
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/activity/model/ActivityModel.java
@@ -0,0 +1,6 @@
+package com.chwl.core.activity.model;
+
+import com.chwl.core.base.BaseModel;
+
+public class ActivityModel extends BaseModel implements IActivityModel {
+}
diff --git a/core/src/main/java/com/chwl/core/activity/model/IActivityModel.java b/core/src/main/java/com/chwl/core/activity/model/IActivityModel.java
new file mode 100644
index 0000000..090b30b
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/activity/model/IActivityModel.java
@@ -0,0 +1,6 @@
+package com.chwl.core.activity.model;
+
+import com.chwl.core.base.IModel;
+
+public interface IActivityModel extends IModel {
+}
diff --git a/core/src/main/java/com/chwl/core/association/bean/ClanListInfo.kt b/core/src/main/java/com/chwl/core/association/bean/ClanListInfo.kt
new file mode 100644
index 0000000..c1480da
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/association/bean/ClanListInfo.kt
@@ -0,0 +1,12 @@
+package com.chwl.core.association.bean
+
+data class ClanListInfo(
+ val clanId: Int = 0,
+ val clanElderUid: Long = 0,
+ val avatar: String = "",
+ val name: String = "",
+ val levelIcon: String = "",
+ val income: Double = 0.0,
+ val level: Int = 0,
+ var applyBtnStatus: Int = 0//0=不显示 1=可申请 2=已申请
+)
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/association/bean/HallListInfo.java b/core/src/main/java/com/chwl/core/association/bean/HallListInfo.java
new file mode 100644
index 0000000..3dcb19d
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/association/bean/HallListInfo.java
@@ -0,0 +1,20 @@
+package com.chwl.core.association.bean;
+
+import lombok.Data;
+
+@Data
+public class HallListInfo {
+ private long hallId;
+ private String hallName;
+ private long clanId;
+ private int roleType;
+ private long ownerUid;
+ private String ownerNick;
+ private String ownerAvatar;
+ private Integer memberCount;
+ private long ownerErbanNo;
+ private Double roomIncome;
+ private int hallBtnStatus;//0=不显示 1=可申请 2=待审核 3通过邀请
+ private int hallRecordId;//通过邀请时的邀请记录id
+ private long hallMessageUid;//联系人id
+}
diff --git a/core/src/main/java/com/chwl/core/association/bean/MemberExchangeInfo.kt b/core/src/main/java/com/chwl/core/association/bean/MemberExchangeInfo.kt
new file mode 100644
index 0000000..48a87fb
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/association/bean/MemberExchangeInfo.kt
@@ -0,0 +1,20 @@
+package com.chwl.core.association.bean
+
+import lombok.Data
+
+@Data
+data class MemberExchangeInfo(
+ val avatar: String = "",
+ val erbanNo: Int = 0,
+ val exchangeAuthStatus: Int = 0,
+ val gender: Int = 0,
+ val golds: Int = 0,
+ val hallName: String = "",
+ val hallRoleType: Int = 0,
+ val isClanElder: Boolean = false,
+ val manageHall: Boolean = false,
+ val nick: String = "",
+ val roleType: Int = 0,
+ val uid: Long = 0L,
+ val userLevelVo: UserLevelInfo? = null
+)
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/association/bean/UserLevelInfo.kt b/core/src/main/java/com/chwl/core/association/bean/UserLevelInfo.kt
new file mode 100644
index 0000000..73fe41c
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/association/bean/UserLevelInfo.kt
@@ -0,0 +1,17 @@
+package com.chwl.core.association.bean
+
+import lombok.Data
+
+@Data
+data class UserLevelInfo(
+ val charmAmount: Int = 0,
+ val charmLevelGrp: String = "",
+ val charmLevelName: String = "",
+ val charmLevelSeq: Int = 0,
+ val charmUrl: String = "",
+ val experAmount: Int = 0,
+ val experLevelGrp: String = "",
+ val experLevelName: String = "",
+ val experLevelSeq: Int = 0,
+ val experUrl: String = ""
+)
diff --git a/core/src/main/java/com/chwl/core/association/model/AssociationModel.kt b/core/src/main/java/com/chwl/core/association/model/AssociationModel.kt
new file mode 100644
index 0000000..8d8b53b
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/association/model/AssociationModel.kt
@@ -0,0 +1,68 @@
+package com.chwl.core.association.model
+
+import com.chwl.core.association.bean.ClanListInfo
+import com.chwl.core.association.bean.HallListInfo
+import com.chwl.core.association.bean.MemberExchangeInfo
+import com.chwl.core.base.BaseModel
+import com.chwl.core.bean.response.ServiceResult
+import com.chwl.core.utils.net.launchRequest
+import com.chwl.library.net.rxnet.RxNet
+import retrofit2.http.*
+
+object AssociationModel : BaseModel() {
+
+ private val api = RxNet.create(Api::class.java)
+
+ suspend fun getClanList(): List? =
+ launchRequest {
+ api.getClanList()
+ }
+
+ suspend fun getHallList(): List? =
+ launchRequest {
+ api.getHallList()
+ }
+
+ suspend fun getMemberExchangeList(): List? =
+ launchRequest {
+ api.getMemberExchangeList()
+ }
+
+ suspend fun operateMemberExchange(status: Int, targetUid: Long): String? =
+ launchRequest {
+ api.operateMemberExchange(status, targetUid)
+ }
+
+ private interface Api {
+
+ /**
+ * 获取公會周榜
+ */
+ @GET("/clan/list")
+ suspend fun getClanList(): ServiceResult>
+
+ /**
+ * 获取牌照房
+ */
+ @GET("/hall/list")
+ suspend fun getHallList(): ServiceResult>
+
+ /**
+ * 获取家族下的兑换权限管理的成员列表
+ */
+ @GET("/clan/memberExchangeAuth/list")
+ suspend fun getMemberExchangeList(): ServiceResult>
+
+ /**
+ * 修改兑换权限管理
+ */
+ @FormUrlEncoded
+ @POST("/clan/memberExchangeAuth/operate")
+ suspend fun operateMemberExchange(
+ @Field("status") status: Int,
+ @Field("targetUid") targetUid: Long
+ ): ServiceResult
+
+ }
+
+}
\ No newline at end of file
diff --git a/core/src/main/java/com/chwl/core/audio/AudioModel.java b/core/src/main/java/com/chwl/core/audio/AudioModel.java
new file mode 100644
index 0000000..54003d8
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/AudioModel.java
@@ -0,0 +1,159 @@
+package com.chwl.core.audio;
+
+import com.google.gson.JsonElement;
+import com.chwl.core.audio.bean.HistoryVoiceInfo;
+import com.chwl.core.audio.bean.SaveVoiceSuccessResultInfo;
+import com.chwl.core.audio.bean.UserVoiceInfo;
+import com.chwl.core.audio.bean.VoiceCardInfo;
+import com.chwl.core.audio.bean.VoiceMatchInfo;
+import com.chwl.core.auth.AuthModel;
+import com.chwl.core.base.BaseModel;
+import com.chwl.core.bean.response.ServiceResult;
+import com.chwl.core.utils.net.RxHelper;
+import com.chwl.library.net.rxnet.RxNet;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import io.reactivex.Single;
+import retrofit2.http.GET;
+import retrofit2.http.POST;
+import retrofit2.http.Query;
+
+public class AudioModel extends BaseModel implements IAudioModel {
+
+ private volatile static IAudioModel instance;
+
+ private Api api;
+
+ public static IAudioModel get() {
+ if (instance == null) {
+ synchronized (AudioModel.class) {
+ if (instance == null) {
+ instance = new AudioModel();
+ }
+ }
+ }
+ return instance;
+ }
+
+ private AudioModel() {
+ api = RxNet.create(Api.class);
+ }
+
+ @Override
+ public Single> getMyVoiceInfoList(long uid) {
+ return api.getMyVoiceInfoList(uid)
+ .compose(RxHelper.handleCommon(ArrayList::new));
+ }
+
+ @Override
+ public Single> getVoiceCardInfoList(long uid, Integer type, int pageSize) {
+ return api.getVoiceCardInfoList(uid, type, pageSize)
+ .compose(RxHelper.handleCommon(ArrayList::new));
+ }
+
+ @Override
+ public Single saveVoice(long uid, String voiceUrl, int voiceLength,
+ Long voiceId, Long piaId, int type) {
+ return api.saveVoice(uid, voiceUrl, voiceLength, voiceId, piaId, type)
+ .compose(RxHelper.handleCommon(SaveVoiceSuccessResultInfo::new));
+ }
+
+ @Override
+ public Single> getVoiceMatchList(int gender, int pageSize) {
+ return api.apiVoiceMatchList(AuthModel.get().getCurrentUid(), gender, pageSize)
+ .compose(RxHelper.handleCommon(ArrayList::new));
+ }
+
+ @Override
+ public Single likeOrUnlikeVoice(long uid, long voiceId, int type) {
+ return api.likeOrUnlikeVoice(uid, voiceId, type)
+ .compose(RxHelper.handleIgnoreData());
+ }
+
+ @Override
+ public Single syncHistoryVoice(long uid, long voiceId) {
+ return api.syncHistoryVoice(uid, voiceId)
+ .compose(RxHelper.handleIgnoreData());
+ }
+
+ @Override
+ public Single queryHistoryVoice(long uid) {
+ return api.queryHistoryVoice(uid)
+ .compose(RxHelper.handleCommon(HistoryVoiceInfo::new));
+ }
+
+ @Override
+ public Single addPlayCount(long uid, Long voiceId, long voiceUid) {
+ return api.addPlayCount(uid, voiceId, voiceUid)
+ .compose(RxHelper.handleIgnoreData());
+ }
+
+
+ private interface Api {
+
+ /**
+ * 我的声音列表
+ */
+ @POST("/voice/my")
+ Single>> getMyVoiceInfoList(@Query("uid") long uid);
+
+ /**
+ * 随机获取pia剧本
+ */
+ @GET("/voice/pia/get")
+ Single>> getVoiceCardInfoList(@Query("uid") long uid,
+ @Query("type") Integer type,
+ @Query("pageSize") int pageSize);
+
+ /**
+ * 保存声音
+ */
+ @POST("/voice/save")
+ Single> saveVoice(@Query("uid") long uid,
+ @Query("voiceUrl") String voiceUrl,
+ @Query("voiceLength") long voiceLength,
+ @Query("voiceId") Long voiceId,
+ @Query("piaId") Long piaId,
+ @Query("type") int type);
+
+ /**
+ * 声音匹配列表
+ */
+ @POST("/voice/list")
+ Single>> apiVoiceMatchList(@Query("uid") long uid,
+ @Query("gender") int gender,
+ @Query("pageSize") int pageSize);
+
+ /**
+ * 喜欢/不喜欢 声音
+ */
+ @POST("/voice/like")
+ Single> likeOrUnlikeVoice(@Query("uid") long uid,
+ @Query("voiceId") long voiceId,
+ @Query("type") int type);
+
+ /**
+ * 同步旧版本个人介绍声音到声音瓶子
+ */
+ @POST("/voice/history/sync")
+ Single> syncHistoryVoice(@Query("uid") long uid,
+ @Query("voiceId") long voiceId);
+
+ /**
+ * 查询旧版本个人介绍声音
+ */
+ @POST("/voice/history/query")
+ Single> queryHistoryVoice(@Query("uid") long uid);
+
+ /**
+ * 增加播放次数
+ */
+ @POST("/voice/add/play/count")
+ Single> addPlayCount(@Query("uid") long uid,
+ @Query("voiceId") Long voiceId,
+ @Query("voiceUid") long voiceUid);
+ }
+
+}
diff --git a/core/src/main/java/com/chwl/core/audio/AudioPlayAndRecordManager.java b/core/src/main/java/com/chwl/core/audio/AudioPlayAndRecordManager.java
new file mode 100644
index 0000000..70675be
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/AudioPlayAndRecordManager.java
@@ -0,0 +1,118 @@
+package com.chwl.core.audio;
+
+import android.content.Context;
+import android.media.AudioManager;
+
+import com.netease.nimlib.sdk.media.player.AudioPlayer;
+import com.netease.nimlib.sdk.media.player.OnPlayListener;
+import com.netease.nimlib.sdk.media.record.AudioRecorder;
+import com.netease.nimlib.sdk.media.record.IAudioRecordCallback;
+import com.netease.nimlib.sdk.media.record.RecordType;
+import com.chwl.library.utils.config.BasicConfig;
+
+/**
+ * @author zhouxiangfeng
+ * @date 2017/5/20
+ */
+
+public class AudioPlayAndRecordManager {
+
+ private static AudioPlayAndRecordManager audioPlayManager;
+ private AudioPlayer player;
+ private AudioRecorder recorder;
+ private IAudioRecordCallback mCallback;
+
+ private AudioPlayAndRecordManager() {
+
+ }
+
+
+ public static AudioPlayAndRecordManager getInstance() {
+ if (audioPlayManager == null)
+ audioPlayManager = new AudioPlayAndRecordManager();
+ return audioPlayManager;
+ }
+
+ public AudioPlayer getAudioPlayer(String filePath, OnPlayListener listener) {
+ // 构造播放器对象
+ player = new AudioPlayer(BasicConfig.INSTANCE.getAppContext(), filePath, listener);
+ return player;
+ }
+
+ public void play() {
+ // 开始播放。需要传入一个 Stream Type 参数，表示是用听筒播放还是扬声器。取值可参见
+ // android.media.AudioManager#STREAM_***
+ // AudioManager.STREAM_VOICE_CALL 表示使用听筒模式
+ // AudioManager.STREAM_MUSIC 表示使用扬声器模式
+ player.start(AudioManager.STREAM_MUSIC);
+ }
+
+
+ public void seekTo(int pausedPostion) {
+ // 如果中途切换播放设备，重新调用 start，传入指定的 streamType 即可。player 会自动停止播放，然后再以新的 streamType 重新开始播放。
+ // 如果需要从中断的地方继续播放，需要外面自己记住已经播放过的位置，然后在 onPrepared 回调中调用 seekTo
+ player.seekTo(pausedPostion);
+ }
+
+ public void stopPlay() {
+ // 主动停止播放
+ player.stop();
+ }
+
+
+ public AudioRecorder getAudioRecorder(Context context, IAudioRecordCallback callback) {
+ // 初始化recorder
+ recorder = new AudioRecorder(
+ BasicConfig.INSTANCE.getAppContext(),
+ // 录制音频类型（aac/amr)
+ RecordType.AAC,
+ // 最长录音时长，到该长度后，会自动停止录音, 默认120s
+ 0,
+ callback);
+ mCallback = callback;
+ return recorder;
+ }
+
+ public boolean isPlaying() {
+ return player != null && player.isPlaying();
+ }
+
+ public void startRecord() {
+
+ if (null != recorder) {
+ if (recorder.isRecording()) {
+ recorder.completeRecord(true);
+ recorder.destroyAudioRecorder();
+ }
+ recorder.startRecord();
+ }
+ }
+
+ public void stopRecord(boolean cancel) {
+ if (null != recorder && recorder.isRecording()) {
+ recorder.completeRecord(cancel);
+ }
+ }
+
+ /** 释放资源 */
+ public void release() {
+ if (isPlaying())
+ stopPlay();
+ stopRecord(true);
+ mCallback = null;
+ recorder = null;
+ if(player != null) {
+ player.setOnPlayListener(null);
+ }
+ }
+
+ // play每个页面都会新建对象，此方法可用于设置当前页面的player对象
+ public void setPlayer(AudioPlayer player) {
+ this.player = player;
+ }
+
+ // play每个页面都会新建对象，此方法可用于判断对象是被覆盖
+ public AudioPlayer getPlayer() {
+ return player;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/audio/IAudioModel.java b/core/src/main/java/com/chwl/core/audio/IAudioModel.java
new file mode 100644
index 0000000..8586294
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/IAudioModel.java
@@ -0,0 +1,87 @@
+package com.chwl.core.audio;
+
+import com.chwl.core.audio.bean.HistoryVoiceInfo;
+import com.chwl.core.audio.bean.SaveVoiceSuccessResultInfo;
+import com.chwl.core.audio.bean.UserVoiceInfo;
+import com.chwl.core.audio.bean.VoiceCardInfo;
+import com.chwl.core.audio.bean.VoiceMatchInfo;
+import com.chwl.core.base.IModel;
+
+import java.util.List;
+
+import io.reactivex.Single;
+
+public interface IAudioModel extends IModel {
+
+ /**
+ * 我的声音列表
+ *
+ * @param uid 用户Uid
+ */
+ Single> getMyVoiceInfoList(long uid);
+
+ /**
+ * 随机获取pia剧本(声音卡片)
+ *
+ * @param uid 用户Uid
+ * @param type 1.歌词 2.情话 （不传则全部）
+ * @param pageSize 一页大小（默认10）
+ */
+ Single> getVoiceCardInfoList(long uid, Integer type, int pageSize);
+
+
+ /**
+ * 保存声音
+ *
+ * @param uid 用户Uid
+ * @param voiceUrl 声音链接
+ * @param voiceLength 声音时长
+ * @param voiceId [声音id]
+ * @param piaId [pia剧本id]
+ * @param type 声音类型: 0=pia戏
+ */
+ Single saveVoice(long uid, String voiceUrl, int voiceLength,
+ Long voiceId, Long piaId, int type);
+
+ /**
+ * 声音匹配列表
+ *
+ * @param gender 性别
+ */
+ Single> getVoiceMatchList(int gender, int pageSize);
+
+ /**
+ * 喜欢/不喜欢 声音
+ *
+ * @param uid 听者Uid
+ * @param voiceId 声音id
+ * @param type 0.不喜欢 1.喜欢
+ */
+ Single likeOrUnlikeVoice(long uid, long voiceId, int type);
+
+
+ /**
+ * 同步旧版本个人介绍声音到声音瓶子
+ *
+ * @param uid 用户Uid
+ * @param voiceId 声音id
+ */
+ Single syncHistoryVoice(long uid, long voiceId);
+
+ /**
+ * 查询旧版本个人介绍声音
+ *
+ * @param uid 用户Uid
+ */
+ Single queryHistoryVoice(long uid);
+
+ /**
+ * 增加播放次数
+ *
+ * @param uid 听者Uid
+ * @param voiceId 声音id（不传时为voiceUid对应的默认声音）
+ * @param voiceUid 声音所属用户Uid
+ */
+ Single addPlayCount(long uid, Long voiceId, long voiceUid);
+
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/HistoryVoiceInfo.java b/core/src/main/java/com/chwl/core/audio/bean/HistoryVoiceInfo.java
new file mode 100644
index 0000000..651b967
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/HistoryVoiceInfo.java
@@ -0,0 +1,137 @@
+package com.chwl.core.audio.bean;
+
+/**
+ * 查询旧版本个人介绍声音
+ */
+public class HistoryVoiceInfo {
+
+ /**
+ * historyVoice : {"id":14,"uid":900005,"defFlag":true,"status":2,"playCount":0,"likeCount":0,"gender":1,"voiceUrl":"https://image.zhongjialx.com/40531ccb-70f8-4981-9b47-281626c4d0621.aac?imageslim","voiceLength":3,"piaId":1}
+ * hasVoice : true
+ */
+
+ private HistoryVoiceBean historyVoice;// 如存在旧版本个人介绍声音则historyVoice不为空，不存在则为空
+ private boolean hasVoice;// 是否已录制声音，包括待审核、审核通过（true.有，false 没有）
+
+ public HistoryVoiceBean getHistoryVoice() {
+ return historyVoice;
+ }
+
+ public void setHistoryVoice(HistoryVoiceBean historyVoice) {
+ this.historyVoice = historyVoice;
+ }
+
+ public boolean isHasVoice() {
+ return hasVoice;
+ }
+
+ public void setHasVoice(boolean hasVoice) {
+ this.hasVoice = hasVoice;
+ }
+
+ public static class HistoryVoiceBean {
+ /**
+ * id : 14
+ * uid : 900005
+ * defFlag : true
+ * status : 2
+ * playCount : 0
+ * likeCount : 0
+ * gender : 1
+ * voiceUrl : https://image.zhongjialx.com/40531ccb-70f8-4981-9b47-281626c4d0621.aac?imageslim
+ * voiceLength : 3
+ * piaId : 1
+ */
+
+ private long id;// 声音id
+ private long uid;// 声音所属用户uid
+ private boolean defFlag;// 是否默认声音
+ private int status;// 0,待审核 1 审核通过 2.无提交审核
+ private int playCount;// 播放次数
+ private int likeCount;// 喜欢次数
+ private int gender;// 性别（1.男，2.女）
+ private String voiceUrl;// 声音链接
+ private int voiceLength;// 声音时长
+ private long piaId;// pia剧本id
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public long getUid() {
+ return uid;
+ }
+
+ public void setUid(long uid) {
+ this.uid = uid;
+ }
+
+ public boolean isDefFlag() {
+ return defFlag;
+ }
+
+ public void setDefFlag(boolean defFlag) {
+ this.defFlag = defFlag;
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+
+ public int getPlayCount() {
+ return playCount;
+ }
+
+ public void setPlayCount(int playCount) {
+ this.playCount = playCount;
+ }
+
+ public int getLikeCount() {
+ return likeCount;
+ }
+
+ public void setLikeCount(int likeCount) {
+ this.likeCount = likeCount;
+ }
+
+ public int getGender() {
+ return gender;
+ }
+
+ public void setGender(int gender) {
+ this.gender = gender;
+ }
+
+ public String getVoiceUrl() {
+ return voiceUrl;
+ }
+
+ public void setVoiceUrl(String voiceUrl) {
+ this.voiceUrl = voiceUrl;
+ }
+
+ public int getVoiceLength() {
+ return voiceLength;
+ }
+
+ public void setVoiceLength(int voiceLength) {
+ this.voiceLength = voiceLength;
+ }
+
+ public long getPiaId() {
+ return piaId;
+ }
+
+ public void setPiaId(long piaId) {
+ this.piaId = piaId;
+ }
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/SaveVoiceSuccessResultInfo.java b/core/src/main/java/com/chwl/core/audio/bean/SaveVoiceSuccessResultInfo.java
new file mode 100644
index 0000000..d7bceb7
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/SaveVoiceSuccessResultInfo.java
@@ -0,0 +1,110 @@
+package com.chwl.core.audio.bean;
+
+/**
+ * 保存声音成功时 接口返回的声音信息
+ */
+public class SaveVoiceSuccessResultInfo {
+
+ /**
+ * id : 42
+ * uid : 902385
+ * defFlag : true
+ * status : 1
+ * likeCount : 0
+ * gender : 2
+ * voiceUrl : https://nim.nosdn.127.net/NTMwMjgzNA==/bmltYV81ODcxNTc1MjI2XzE1NTUzOTY0MzU0NzlfODdiNjhjMjItNWU4ZS00NTI3LWIxMzItNzhmNjU4ODZjMWRi
+ * voiceLength : 4
+ * piaId : 1
+ */
+
+ private long id; // 声音id
+ private long uid; // 声音所属用户uid
+ private boolean defFlag; // 是否默认声音
+ private int status; // 0,待审核 1 审核通过 2.无提交审核
+ private int likeCount; // 喜欢次数
+ private int gender; // 性别（1.男，2.女）
+ private String voiceUrl; // 声音地址
+ private int voiceLength; // 声音时长
+ private long piaId; // Pia剧本Id
+ private int playCount; // 播放次数
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public long getUid() {
+ return uid;
+ }
+
+ public void setUid(long uid) {
+ this.uid = uid;
+ }
+
+ public boolean isDefFlag() {
+ return defFlag;
+ }
+
+ public void setDefFlag(boolean defFlag) {
+ this.defFlag = defFlag;
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+
+ public int getLikeCount() {
+ return likeCount;
+ }
+
+ public void setLikeCount(int likeCount) {
+ this.likeCount = likeCount;
+ }
+
+ public int getGender() {
+ return gender;
+ }
+
+ public void setGender(int gender) {
+ this.gender = gender;
+ }
+
+ public String getVoiceUrl() {
+ return voiceUrl;
+ }
+
+ public void setVoiceUrl(String voiceUrl) {
+ this.voiceUrl = voiceUrl;
+ }
+
+ public int getVoiceLength() {
+ return voiceLength;
+ }
+
+ public void setVoiceLength(int voiceLength) {
+ this.voiceLength = voiceLength;
+ }
+
+ public long getPiaId() {
+ return piaId;
+ }
+
+ public void setPiaId(long piaId) {
+ this.piaId = piaId;
+ }
+
+ public int getPlayCount() {
+ return playCount;
+ }
+
+ public void setPlayCount(int playCount) {
+ this.playCount = playCount;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/SysMsgVoiceInfo.java b/core/src/main/java/com/chwl/core/audio/bean/SysMsgVoiceInfo.java
new file mode 100644
index 0000000..c7a8ced
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/SysMsgVoiceInfo.java
@@ -0,0 +1,13 @@
+package com.chwl.core.audio.bean;
+
+import java.io.Serializable;
+
+import lombok.Data;
+
+@Data
+public class SysMsgVoiceInfo implements Serializable {
+ public int status;// 状态：1 审核通过 4 审核不通过
+ public String reason;// 原因
+ public int routerType;
+ public String routerValue;
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/UserVoiceInfo.java b/core/src/main/java/com/chwl/core/audio/bean/UserVoiceInfo.java
new file mode 100644
index 0000000..be2d3b0
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/UserVoiceInfo.java
@@ -0,0 +1,109 @@
+package com.chwl.core.audio.bean;
+
+/**
+ * 我的声音列表
+ */
+public class UserVoiceInfo {
+ /**
+ * id : 42
+ * uid : 902385
+ * defFlag : true
+ * status : 1
+ * likeCount : 0
+ * gender : 2
+ * voiceUrl : https://nim.nosdn.127.net/NTMwMjgzNA==/bmltYV81ODcxNTc1MjI2XzE1NTUzOTY0MzU0NzlfODdiNjhjMjItNWU4ZS00NTI3LWIxMzItNzhmNjU4ODZjMWRi
+ * voiceLength : 4
+ * piaId : 1
+ */
+
+ private long id;// 声音id
+ private long uid;// 声音所属用户uid
+ private boolean defFlag;// 是否默认声音
+ private int status;// 0,待审核 1 审核通过 2.无提交审核
+ private int likeCount;// 喜欢次数
+ private int gender;// 性别（1.男，2.女）
+ private String voiceUrl;// 声音地址
+ private int voiceLength;// 声音时长
+ private long piaId;// Pia剧本Id
+ private int playCount;// 播放次数
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public long getUid() {
+ return uid;
+ }
+
+ public void setUid(long uid) {
+ this.uid = uid;
+ }
+
+ public boolean isDefFlag() {
+ return defFlag;
+ }
+
+ public void setDefFlag(boolean defFlag) {
+ this.defFlag = defFlag;
+ }
+
+ public int getStatus() {
+ return status;
+ }
+
+ public void setStatus(int status) {
+ this.status = status;
+ }
+
+ public int getLikeCount() {
+ return likeCount;
+ }
+
+ public void setLikeCount(int likeCount) {
+ this.likeCount = likeCount;
+ }
+
+ public int getGender() {
+ return gender;
+ }
+
+ public void setGender(int gender) {
+ this.gender = gender;
+ }
+
+ public String getVoiceUrl() {
+ return voiceUrl;
+ }
+
+ public void setVoiceUrl(String voiceUrl) {
+ this.voiceUrl = voiceUrl;
+ }
+
+ public int getVoiceLength() {
+ return voiceLength;
+ }
+
+ public void setVoiceLength(int voiceLength) {
+ this.voiceLength = voiceLength;
+ }
+
+ public long getPiaId() {
+ return piaId;
+ }
+
+ public void setPiaId(long piaId) {
+ this.piaId = piaId;
+ }
+
+ public int getPlayCount() {
+ return playCount;
+ }
+
+ public void setPlayCount(int playCount) {
+ this.playCount = playCount;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/VoiceBottleSayHiInfo.java b/core/src/main/java/com/chwl/core/audio/bean/VoiceBottleSayHiInfo.java
new file mode 100644
index 0000000..a0bd90d
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/VoiceBottleSayHiInfo.java
@@ -0,0 +1,11 @@
+package com.chwl.core.audio.bean;
+
+import java.io.Serializable;
+
+import lombok.Data;
+
+@Data
+public class VoiceBottleSayHiInfo implements Serializable {
+ private String voiceUid;
+ private String message;
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/VoiceCardInfo.java b/core/src/main/java/com/chwl/core/audio/bean/VoiceCardInfo.java
new file mode 100644
index 0000000..a0b8400
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/VoiceCardInfo.java
@@ -0,0 +1,54 @@
+package com.chwl.core.audio.bean;
+
+/**
+ * 声音卡片的信息
+ */
+public class VoiceCardInfo {
+
+ private long id;// pia剧本id
+ private int type;// 类型 ：1.歌词 2.情话
+ private int gender;// 0.不限 1.男 2.女
+ private String playBook;// 剧本内部
+ private String title;// 剧本标题
+
+ public long getId() {
+ return id;
+ }
+
+ public void setId(long id) {
+ this.id = id;
+ }
+
+ public int getType() {
+ return type;
+ }
+
+ public void setType(int type) {
+ this.type = type;
+ }
+
+ public int getGender() {
+ return gender;
+ }
+
+ public void setGender(int gender) {
+ this.gender = gender;
+ }
+
+ public String getPlayBook() {
+ return playBook.replace("\\n", "\n")
+ .replace("\\r","\r");
+ }
+
+ public void setPlayBook(String playBook) {
+ this.playBook = playBook;
+ }
+
+ public String getTitle() {
+ return title;
+ }
+
+ public void setTitle(String title) {
+ this.title = title;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/audio/bean/VoiceMatchInfo.java b/core/src/main/java/com/chwl/core/audio/bean/VoiceMatchInfo.java
new file mode 100644
index 0000000..2b2e968
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/bean/VoiceMatchInfo.java
@@ -0,0 +1,41 @@
+package com.chwl.core.audio.bean;
+
+import lombok.Data;
+
+/**
+ * create by lvzebiao @2019/6/10
+ */
+@Data
+public class VoiceMatchInfo {
+
+ /**
+ * id : 42
+ * uid : 902385
+ * defFlag : true
+ * status : 1
+ * likeCount : 0
+ * gender : 2
+ * voiceUrl : https://nim.nosdn.127.net/NTMwMjgzNA==/bmltYV81ODcxNTc1MjI2XzE1NTUzOTY0MzU0NzlfODdiNjhjMjItNWU4ZS00NTI3LWIxMzItNzhmNjU4ODZjMWRi
+ * voiceLength : 4
+ * piaId : 1
+ * nick : 二娃
+ * birth : 631123200000
+ * avatar : https://image.zhongjialx.com/picture_1557127983672.jpg?imageslim
+ * location : 广州市
+ */
+
+ private int id;
+ private int uid;
+ private boolean defFlag;
+ private int status;
+ private int likeCount;
+ private int gender;
+ private String voiceUrl;
+ private int voiceLength;
+ private int piaId;
+ private String nick;
+ private long birth;
+ private String avatar;
+ private String location;
+
+}
diff --git a/core/src/main/java/com/chwl/core/audio/event/VoiceShakeHeartEvent.java b/core/src/main/java/com/chwl/core/audio/event/VoiceShakeHeartEvent.java
new file mode 100644
index 0000000..6b0438c
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/audio/event/VoiceShakeHeartEvent.java
@@ -0,0 +1,9 @@
+package com.chwl.core.audio.event;
+
+public class VoiceShakeHeartEvent {
+ public String showTextHint;
+
+ public VoiceShakeHeartEvent(String showTextHint) {
+ this.showTextHint = showTextHint;
+ }
+}
diff --git a/core/src/main/java/com/chwl/core/auth/AuthModel.java b/core/src/main/java/com/chwl/core/auth/AuthModel.java
new file mode 100644
index 0000000..47054eb
--- /dev/null
+++ b/core/src/main/java/com/chwl/core/auth/AuthModel.java
@@ -0,0 +1,1334 @@
+package com.chwl.core.auth;
+
+import android.app.Activity;
+import android.text.TextUtils;
+import android.util.Log;
+
+import androidx.annotation.NonNull;
+
+import com.chwl.core.DemoCache;
+import com.chwl.core.R;
+import com.chwl.core.auth.entity.AccountInfo;
+import com.chwl.core.auth.entity.ThirdUserInfo;
+import com.chwl.core.auth.entity.TicketInfo;
+import com.chwl.core.auth.event.GetCurrentUidEvent;
+import com.chwl.core.auth.event.KickOutEvent;
+import com.chwl.core.auth.event.LoginEvent;
+import com.chwl.core.auth.event.LoginReportEvent;
+import com.chwl.core.auth.event.LogoutEvent;
+import com.chwl.core.auth.exception.AccountCancelException;
+import com.chwl.core.auth.exception.BanAccountException;
+import com.chwl.core.auth.exception.IsSuperAdminException;
+import com.chwl.core.base.BaseModel;
+import com.chwl.core.bean.response.ServiceResult;
+import com.chwl.core.bean.response.result.LoginResult;
+import com.chwl.core.bean.response.result.RegisterResult;
+import com.chwl.core.bean.response.result.TicketResult;
+import com.chwl.core.exception.FailReasonException;
+import com.chwl.core.im.custom.bean.CustomAttachParser;
+import com.chwl.core.linked.LinkedModel;
+import com.chwl.core.linked.bean.LinkedInfo;
+import com.chwl.core.utils.CheckUtils;
+import com.chwl.core.utils.LogUtils;
+import com.chwl.core.utils.OldHttpErrorHandleUtil;
+import com.chwl.core.utils.net.RxHelper;
+import com.chwl.library.common.util.OtherExtKt;
+import com.chwl.library.net.rxnet.RxNet;
+import com.chwl.library.utils.DeviceUtils;
+import com.chwl.library.utils.ResUtil;
+import com.chwl.library.utils.SingleToastUtil;
+import com.chwl.library.utils.VersionUtil;
+import com.chwl.library.utils.codec.DESUtils;
+import com.chwl.library.utils.config.BasicConfig;
+import com.chwl.library.utils.constant.PackageNameConstants;
+import com.chwl.library.utils.json.JsonUtils;
+import com.example.module_base.support.google.IGoogleService;
+import com.example.module_base.support.login.ILoginService;
+import com.example.module_base.support.login.LoginSDKException;
+import com.example.module_base.support.login.PlatformInfo;
+import com.netease.nim.uikit.api.NimUIKit;
+import com.netease.nim.uikit.common.util.log.LogUtil;
+import com.netease.nim.uikit.common.util.string.StringUtil;
+import com.netease.nim.uikit.impl.cache.DataCacheManager;
+import com.netease.nimlib.sdk.NIMClient;
+import com.netease.nimlib.sdk.Observer;
+import com.netease.nimlib.sdk.RequestCallback;
+import com.netease.nimlib.sdk.RequestCallbackWrapper;
+import com.netease.nimlib.sdk.StatusCode;
+import com.netease.nimlib.sdk.auth.AuthService;
+import com.netease.nimlib.sdk.auth.AuthServiceObserver;
+import com.netease.nimlib.sdk.auth.LoginInfo;
+import com.netease.nimlib.sdk.mixpush.MixPushService;
+import com.netease.nimlib.sdk.msg.MsgService;
+import com.orhanobut.logger.Logger;
+
+import org.greenrobot.eventbus.EventBus;
+
+import io.reactivex.Single;
+import io.reactivex.SingleEmitter;
+import io.reactivex.SingleOnSubscribe;
+import io.reactivex.SingleSource;
+import io.reactivex.android.schedulers.AndroidSchedulers;
+import io.reactivex.functions.Consumer;
+import io.reactivex.functions.Function;
+import io.reactivex.schedulers.Schedulers;
+import lombok.Getter;
+import okhttp3.ResponseBody;
+import retrofit2.http.Field;
+import retrofit2.http.FormUrlEncoded;
+import retrofit2.http.GET;
+import retrofit2.http.POST;
+import retrofit2.http.Query;
+
+public class AuthModel extends BaseModel implements IAuthModel {
+
+ /**
+ * 封禁账号
+ */
+ public static final int CODE_BAN_ACCOUNT = 407;
+ /**
+ * 封禁设备
+ */
+ public static final int CODE_BAN_DEVICE = 408;
+ /**
+ * 验证码结果不正确
+ */
+ public static final int VERIFY_CODE_ERROR = 3002; // 图片验证码？
+ /**
+ * 账号已注销
+ */
+ public static final int CODE_ACCOUNT_CANCEL = 3009;
+ /**
+ * 注册异常,请稍后再试
+ */
+ public static final int CODE_HIT_YI_DUN = 24000;
+ /**
+ * 一个手机绑定多个账号（大头账号）
+ */
+ public static final int CODE_BIG_HEAD_NUM = 25002;
+ private static final String TAG = "AuthModel";
+ /**
+ * 类型（1、手机号/耳伴号登陆，2、手机号/耳伴号登陆并绑定QQ）
+ */
+ public static final int TYPE_GOOGLE_LOGIN = 8;
+ public static final int TYPE_LINE_LOGIN = 9;
+ public static final int TYPE_FACEBOOK_LOGIN = 10;
+ /**
+ * 校验验证码
+ */
+ private static final int CODE_SHOW_CODE = 107;
+ /**
+ * 超管登录校验验证码
+ */
+ private static final int SUPER_CODE_SHOW_CODE = 136;
+ private volatile static AuthModel instance = null;
+
+ boolean isInit = false;
+ private Api api;
+ @Getter
+ private AccountInfo currentAccountInfo;
+ private TicketInfo ticketInfo;
+ private ThirdUserInfo thirdUserInfo;
+ private ILoginService googleLoginService;
+
+ public static String PASSWORD = "password";
+ public static final String EMAIL = "email";
+ /****************************************************** IM *************************************************************/
+
+ private StatusCode statusCode;
+
+ private AuthModel() {
+ api = RxNet.create(Api.class);
+ currentAccountInfo = DemoCache.readCurrentAccountInfo();
+ ticketInfo = DemoCache.readTicketInfo();
+ if (currentAccountInfo == null) {
+ currentAccountInfo = new AccountInfo();
+ }
+ if (ticketInfo == null) {
+ ticketInfo = new TicketInfo();
+ }
+
+ isInit = true;
+ NIMClient.getService(MsgService.class).registerCustomAttachmentParser(new CustomAttachParser()); //注册自定义Im消息解析器
+ registerAuthServiceObserver();
+
+ }
+
+ public void refreshApi() {
+ api = RxNet.create(Api.class);
+ }
+
+ public static AuthModel get() {
+ if (instance == null) {
+ synchronized (AuthModel.class) {
+ if (instance == null) {
+ instance = new AuthModel();
+ }
+ }
+ }
+ return instance;
+ }
+
+ @Override
+ public ILoginService getGoogleLoginService() {
+ if (googleLoginService == null) {
+ googleLoginService = IGoogleService.Companion.newLoginService();
+ }
+ return googleLoginService;
+ }
+
+ @Override
+ public ThirdUserInfo getThirdUserInfo() {
+ return thirdUserInfo;
+ }
+
+ @Override
+ public void setThirdUserInfo(ThirdUserInfo thirdUserInfo) {
+ this.thirdUserInfo = thirdUserInfo;
+ }
+
+ /**
+ * 获取当前登录的uid,登录成功后就有值了
+ *
+ * @return
+ */
+ @Override
+ public long getCurrentUid() {
+ return currentAccountInfo == null ? 0 : currentAccountInfo.getUid();
+ }
+
+ @Override
+ public boolean isMy(long uid) {
+ return getCurrentUid() == uid;
+ }
+
+ /**
+ * 获取ticket,登录成功后就有真实值
+ *
+ * @return
+ */
+ @Override
+ public String getTicket() {
+ if (ticketInfo != null && ticketInfo.getTickets() != null && ticketInfo.getTickets().size() > 0) {
+ return ticketInfo.getTickets().get(0).getTicket();
+ }
+ return "";
+ }
+
+ /**
+ * 判断是否已登录
+ *
+ * @return
+ */
+ @Override
+ public boolean isLogin() {
+ return currentAccountInfo != null && !TextUtils.isEmpty(currentAccountInfo.getAccess_token());
+ }
+
+ /**
+ * 自动登录
+ *
+ * @return
+ */
+ @Override
+ public Single autoLogin() {
+ if (currentAccountInfo == null || TextUtils.isEmpty(currentAccountInfo.getAccess_token())) {
+ return Single.error(new Throwable(""));//没有账号信息
+ }
+ return imLogin(currentAccountInfo)
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .doOnSuccess(s -> {
+ EventBus.getDefault().post(new LoginEvent());
+ });
+ }
+
+ /**
+ * 账号密码登录
+ *
+ * @param account
+ * @param password
+ * @return
+ */
+ @Override
+ public Single login(String account,String email, String password, String yiDunToken, String shuMeiDeviceId,String type) {
+ return login(null, account,email, password, null, yiDunToken, shuMeiDeviceId,type);
+ }
+
+ @Override
+ public Single login(String phoneAreaCode, String account,String email, String password, String code, String yiDunToken, String shuMeiDeviceId,String type) {
+ return Single.create((SingleOnSubscribe) emitter -> {
+ //获取登录信息
+ try {
+ LoginResult loginResult = api.login(
+ phoneAreaCode,
+ DESUtils.DESAndBase64(account),
+ DESUtils.DESAndBase64(email),
+ VersionUtil.getLocalName(BasicConfig.INSTANCE.getAppContext()),
+ "erban-client",
+ DESUtils.DESAndBase64(account),
+ DESAndBase64(password),
+ type,
+ "uyzjdhds",
+ code,
+ yiDunToken,
+ shuMeiDeviceId
+ ).blockingGet();
+ if (!loginResult.isSuccess()) {
+ if (loginResult.getCode() == CODE_BAN_ACCOUNT || loginResult.getCode() == CODE_BAN_DEVICE) {
+ emitter.onError(new BanAccountException(loginResult.getReason(), loginResult.getDate()));
+ } else if (loginResult.getCode() == CODE_ACCOUNT_CANCEL) {
+ emitter.onError(new AccountCancelException(loginResult.getMessage(), loginResult.getErbanNo(), loginResult.getCancelDate()));
+ } else if (loginResult.getCode() == SUPER_CODE_SHOW_CODE) {
+ //是否是超管
+ if (loginResult.getSuperCodeVerify() == 1) {
+ emitter.onError(new IsSuperAdminException(loginResult.getMessage()));
+ } else {
+ emitter.onError(new Throwable(loginResult.getMessage()));
+ }
+ } else {
+ emitter.onError(new Throwable(loginResult.getMessage()));
+ }
+ return;
+ }
+ currentAccountInfo = loginResult.getData();
+ DemoCache.saveCurrentAccountInfo(currentAccountInfo);
+ //成功获取到uid后，就通知首页刷新审核中状态的数据
+ EventBus.getDefault().post(new GetCurrentUidEvent(true));
+ } catch (Exception e) {
+ emitter.onError(new Throwable(OldHttpErrorHandleUtil.handle(e)));
+ return;
+ }
+ //获取tick
+ try {
+ TicketResult ticketResult = requestTicket().blockingGet();
+ if (!ticketResult.isSuccess()) {
+ emitter.onError(new Throwable(ticketResult.getMessage()));
+ return;
+ }
+ ticketInfo = ticketResult.getData();
+ DemoCache.saveTicketInfo(ticketInfo);
+
+ } catch (Exception e) {
+ emitter.onError(new Throwable(OldHttpErrorHandleUtil.handle(e)));
+ return;
+ }
+ emitter.onSuccess(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_02));
+ })
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .flatMap(new Function>() {
+ @Override
+ public SingleSource apply(String s) throws Exception {
+ return imLogin(currentAccountInfo);
+ }
+ })
+ .doOnSuccess(new Consumer() {
+ @Override
+ public void accept(String s) throws Exception {
+ //登录成功后发出登录事件
+ EventBus.getDefault().post(new LoginEvent());
+ }
+ });
+ }
+
+
+ @Override
+ public Single googleLogin(Activity activity) {
+ return Single.create((SingleOnSubscribe) e -> {
+ ILoginService loginService = getGoogleLoginService();
+ if (loginService == null) {
+ e.onError(new Throwable(ResUtil.getString(R.string.bean_response_serviceresult_015)));
+ return;
+ }
+ //是否安装客户端
+ if (!DeviceUtils.isAppInstalled(getContext(), PackageNameConstants.GOOGLE_NAME)) {
+ e.onError(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_09)));
+ return;
+ }
+ loginService.login(activity, new ILoginService.Listener() {
+ @Override
+ public void onSuccess(@NonNull PlatformInfo platformInfo) {
+ thirdUserInfo = new ThirdUserInfo();
+ thirdUserInfo.setType(ThirdUserInfo.TYPE_GOOGLE);
+ thirdUserInfo.setPlatform("Google");
+ thirdUserInfo.setUserName(platformInfo.getName());
+ thirdUserInfo.setUserIcon(platformInfo.getAvatar());
+ e.onSuccess(platformInfo);
+ }
+
+ @Override
+ public void onFailure(@NonNull LoginSDKException exception) {
+ exception.printStackTrace();
+ LogUtils.d("googleLogin" + exception);
+ e.onError(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_010) + exception.getCode()));
+ }
+ });
+ })
+ .flatMap(platform -> {
+ String openid = platform.getId();
+ String unionid = platform.getId();
+ String avatar = thirdUserInfo.getUserIcon();
+ if (avatar != null && avatar.equals("null")) {
+ avatar = null;
+ }
+ thirdUserInfo.setUserIcon(avatar);
+ String gender = thirdUserInfo.getUserGender();
+ if (gender != null && !gender.trim().isEmpty()) {
+ gender = gender.replace("m", "1").replace("f", "2");
+ }
+ thirdUserInfo.setUserGender(gender);
+ EventBus.getDefault().post(new LoginReportEvent(3));
+ return thirdLogin(openid, unionid, TYPE_GOOGLE_LOGIN, "", "");
+ })
+ .flatMap(s -> imLogin(currentAccountInfo))
+ .subscribeOn(AndroidSchedulers.mainThread())
+ .observeOn(AndroidSchedulers.mainThread())
+ .compose(RxHelper.handleException())
+ .doOnSuccess(s -> EventBus.getDefault().post(new LoginEvent()));
+ }
+
+ /**
+ * 第三方信息登录
+ *
+ * @param openid
+ * @param unionid
+ * @param type
+ * @return
+ */
+ private Single thirdLogin(String openid, String unionid, int type, String yiDunToken, String shuMeiDeviceId) {
+ LinkedInfo linkedInfo = LinkedModel.get().getLinkedInfo();
+ String linkedmeChannel = null;
+ if (linkedInfo != null && !StringUtil.isEmpty(linkedInfo.getChannel())) {
+ linkedmeChannel = linkedInfo.getChannel();
+ }
+
+ String finalLinkedmeChannel = linkedmeChannel;
+ return Single.create(new SingleOnSubscribe() {
+ @Override
+ public void subscribe(SingleEmitter e) throws Exception {
+ try {
+ LoginResult loginResult = api.thirdLogin(
+ openid,
+ unionid,
+ String.valueOf(type),
+ finalLinkedmeChannel,
+ yiDunToken,
+ shuMeiDeviceId
+ ).blockingGet();
+ if (!loginResult.isSuccess()) {
+ if (loginResult.getCode() == CODE_BAN_ACCOUNT || loginResult.getCode() == CODE_BAN_DEVICE) {
+ e.onError(new BanAccountException(loginResult.getReason(), loginResult.getDate()));
+ } else if (loginResult.getCode() == CODE_ACCOUNT_CANCEL) {
+ e.onError(new AccountCancelException(loginResult.getMessage(), loginResult.getErbanNo(), loginResult.getCancelDate()));
+ } else {
+ e.onError(new Throwable(loginResult.getMessage()));
+ }
+ return;
+ }
+ currentAccountInfo = loginResult.getData();
+ DemoCache.saveCurrentAccountInfo(currentAccountInfo);
+ //成功获取到uid后，就通知首页刷新审核中状态的数据
+ EventBus.getDefault().post(new GetCurrentUidEvent(true));
+ } catch (Exception e1) {
+ e.onError(new Throwable(OldHttpErrorHandleUtil.handle(e1)));
+ return;
+ }
+ //获取tick
+ try {
+ TicketResult ticketResult = requestTicket().blockingGet();
+ if (!ticketResult.isSuccess()) {
+ e.onError(new Throwable(ticketResult.getMessage()));
+ return;
+ }
+ ticketInfo = ticketResult.getData();
+ DemoCache.saveTicketInfo(ticketInfo);
+
+ } catch (Exception e1) {
+ e.onError(new Throwable(OldHttpErrorHandleUtil.handle(e1)));
+ return;
+ }
+ e.onSuccess(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_012));
+ }
+ }).subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread());
+
+ }
+
+ public Single refreshTicket() {
+ return requestTicket()
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread())
+ .map(ticketResult -> {
+ if (ticketResult.isSuccess()) {
+ ticketInfo = ticketResult.getData();
+ DemoCache.saveTicketInfo(ticketInfo);
+ }
+ return ticketResult;
+ });
+ }
+
+ /**
+ * 获取tick
+ *
+ * @return
+ */
+ private Single requestTicket() {
+ return api.requestTicket(
+ "multi",
+ currentAccountInfo.getAccess_token()
+ );
+ }
+
+ /**
+ * 重置
+ */
+ @Override
+ public void reset() {
+ currentAccountInfo = new AccountInfo();
+ ticketInfo = new TicketInfo();
+ thirdUserInfo = null;
+ DemoCache.saveCurrentAccountInfo(new AccountInfo());
+ DemoCache.saveTicketInfo(new TicketInfo());
+ DemoCache.saveBoundAuthCode(false);
+ }
+
+ private String DESAndBase64(String psw) {
+ String pwd = "";
+ try {
+ pwd = DESUtils.DESAndBase64Encrypt(psw);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return pwd;
+ }
+
+ /**
+ * 重置密码
+ *
+ * @param phone
+ * @param sms_code
+ * @param newPsw
+ * @return
+ */
+ @Override
+ public Single requestResetPsw(String phoneAreaCode, String phone, String sms_code, String newPsw) {
+ return Single.create(new SingleOnSubscribe() {
+ @Override
+ public void subscribe(SingleEmitter e) throws Exception {
+ try {
+ ServiceResult serviceResult = api.requestResetPsw(
+ phoneAreaCode,
+ DESUtils.DESAndBase64(phone),
+ sms_code,
+ DESAndBase64(newPsw)
+ ).blockingGet();
+ if (!serviceResult.isSuccess()) {
+ e.onError(new Throwable(serviceResult.getMessage()));
+ return;
+ }
+ e.onSuccess(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_013));
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ e.onError(new Throwable(OldHttpErrorHandleUtil.handle(e1)));
+ }
+
+ }
+ })
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread());
+
+ }
+ /**
+ * 重置密码-邮箱
+ */
+ @Override
+ public Single requestResetPswByEmail(String email, String code, String newPsw) {
+ return Single.create(new SingleOnSubscribe() {
+ @Override
+ public void subscribe(SingleEmitter e) throws Exception {
+ try {
+ ServiceResult serviceResult = api.requestResetPswByEmail(
+ DESUtils.DESAndBase64(email),
+ code,
+ DESAndBase64(newPsw)
+ ).blockingGet();
+ if (!serviceResult.isSuccess()) {
+ e.onError(new Throwable(serviceResult.getMessage()));
+ return;
+ }
+ e.onSuccess(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_013));
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ e.onError(new Throwable(OldHttpErrorHandleUtil.handle(e1)));
+ }
+
+ }
+ })
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread());
+
+ }
+
+ /**
+ * 当前用户是否绑定手机
+ *
+ * @return
+ */
+ @Override
+ public Single isBindPhone() {
+ if (currentAccountInfo == null || currentAccountInfo.getUid() == 0) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_014)));
+ }
+
+ return api.isBindPhone(
+ String.valueOf(currentAccountInfo.getUid())
+ )
+ .flatMap(new Function>() {
+ @Override
+ public SingleSource apply(ServiceResult serviceResult) throws Exception {
+ if (!serviceResult.isSuccess()) {
+ return Single.error(new Throwable(serviceResult.getMessage()));
+ }
+ return Single.just(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_015));
+ }
+ })
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread());
+ }
+
+ /**
+ * 绑定手机
+ *
+ * @param phone
+ * @param code
+ * @return
+ */
+ @Override
+ public Single bindPhone(String phoneAreaCode, String phone, String code) {
+ if (currentAccountInfo == null || currentAccountInfo.getUid() == 0) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_016)));
+ }
+ return api.bindPhone(
+ phoneAreaCode,
+ DESUtils.DESAndBase64(phone),
+ code
+ )
+ .flatMap(serviceResult -> {
+ if (!serviceResult.isSuccess()) {
+ return Single.error(new Throwable(serviceResult.getMessage()));
+ }
+ return Single.just(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_017));
+ })
+ .compose(RxHelper.handleSchedulers());
+ }
+
+
+ /**
+ * 绑定邮箱
+ */
+ @Override
+ public Single bindEmail(String email, String code) {
+ if (currentAccountInfo == null || currentAccountInfo.getUid() == 0) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_016)));
+ }
+ return api.bindEmail(
+ DESUtils.DESAndBase64(email),
+ code
+ )
+ .flatMap(serviceResult -> {
+ if (!serviceResult.isSuccess()) {
+ return Single.error(new Throwable(serviceResult.getMessage()));
+ }
+ return Single.just(ResUtil.getString(R.string._ver_24_text_bind_email_ok));
+ })
+ .compose(RxHelper.handleSchedulers());
+ }
+
+
+
+ /**
+ * 注册
+ *
+ * @param phone
+ * @param sms_code
+ * @param password
+ * @return
+ */
+ @Override
+ public Single register(String phone, String sms_code, String verifyCode, String password,
+ String yiDunToken, String shuMeiDeviceId) {
+ LinkedInfo linkedInfo = LinkedModel.get().getLinkedInfo();
+ String linkedmeChannel = null;
+ if (linkedInfo != null && !StringUtil.isEmpty(linkedInfo.getChannel())) {
+ linkedmeChannel = linkedInfo.getChannel();
+ }
+ return api.register(
+ DESUtils.DESAndBase64(phone),
+ sms_code,
+ verifyCode,
+ DESAndBase64(password),
+ linkedmeChannel,
+ yiDunToken,
+ shuMeiDeviceId
+ )
+ .flatMap(new Function>() {
+ @Override
+ public SingleSource apply(RegisterResult registerResult) throws Exception {
+ if (!registerResult.isSuccess()) {
+ switch (registerResult.getCode()) {
+ case CODE_HIT_YI_DUN:
+ case VERIFY_CODE_ERROR:
+ return Single.error(new FailReasonException(
+ registerResult.getMessage(), registerResult.getCode()));
+ }
+ return Single.error(new Throwable(registerResult.getMessage()));
+ }
+ return Single.just(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_018));
+ }
+ })
+ .subscribeOn(Schedulers.io())
+ .observeOn(AndroidSchedulers.mainThread());
+
+ }
+
+ /**
+ * 退出登录
+ *
+ * @return
+ */
+ @Override
+ public Single logout() {
+ Logger.i("logout ~~ ");
+ ILoginService loginService = getGoogleLoginService();
+ if (loginService != null) {
+ loginService.logout();
+ }
+ return api.logout(currentAccountInfo.getAccess_token())
+ .compose(RxHelper.handleSchedulers())
+ .flatMap(stringServiceResult -> {
+ if (stringServiceResult != null && stringServiceResult.isSuccess()) {
+ LogUtil.e(TAG, ResUtil.getString(R.string.xchat_android_core_auth_authmodel_019));
+ cleanLogInfo();
+ return Single.just(stringServiceResult.getData() != null ?
+ stringServiceResult.getData() : "");
+ } else {
+ return Single.error(new Throwable(stringServiceResult != null ? stringServiceResult.getMessage() :
+ ResUtil.getString(R.string.xchat_android_core_auth_authmodel_020)));
+ }
+ });
+ }
+
+ public void cleanLogInfo() {
+ reset();//这里先重置状态，后调用IM登出，因为这里观察了IM的在线状态
+ NIMClient.getService(AuthService.class).logout();
+ EventBus.getDefault().post(new LogoutEvent());
+ }
+
+ /**
+ * 修改登录密码
+ *
+ * @param phone
+ * @param oldPwd
+ * @param newPwd
+ * @return
+ */
+ @Override
+ public Single modifyLoginPwd(String phone,
+ String oldPwd,
+ String newPwd) {
+
+ if (TextUtils.isEmpty(getTicket())) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_021)));
+ }
+ return api.changeLoginPwd(
+ DESUtils.DESAndBase64(phone),
+ oldPwd,
+ newPwd,
+ getTicket()
+
+ )
+ .flatMap(new Function, SingleSource>() {
+ @Override
+ public SingleSource apply(ServiceResult stringServiceResult) throws Exception {
+ if (stringServiceResult.isSuccess()) {
+ return Single.just(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_022));
+ } else {
+ return Single.error(new Throwable(stringServiceResult.getMessage()));
+ }
+ }
+ })
+ .compose(new Transformer<>());
+ }
+
+ /**
+ * 设置登录密码，在第三方登录的情况下是没有登录密码的，这里接口可以设置登录密码，账号为耳伴号
+ *
+ * @param phone
+ * @param newPwd
+ * @return
+ */
+ @Override
+ public Single setLoginPwd(String phone,
+ String newPwd) {
+ if (getCurrentUid() == 0) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_023)));
+ }
+
+ if (TextUtils.isEmpty(getTicket())) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_024)));
+ }
+
+ return api.setLoginPwd(
+ DESUtils.DESAndBase64(phone),
+ newPwd,
+ String.valueOf(getCurrentUid()),
+ getTicket()
+ )
+ .flatMap(new Function, SingleSource>() {
+ @Override
+ public SingleSource apply(ServiceResult stringServiceResult) throws Exception {
+ if (stringServiceResult.isSuccess()) {
+ return Single.just(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_025));
+ } else {
+ return Single.error(new Throwable(stringServiceResult.getMessage()));
+ }
+ }
+ })
+ .compose(new Transformer<>());
+ }
+
+ /**
+ * 判断IM 登录状态
+ *
+ * @return
+ */
+ @Override
+ public boolean isImLogin() {
+ return statusCode == StatusCode.LOGINED;
+ }
+
+ /**
+ * 观察Im连接状态
+ */
+ private void registerAuthServiceObserver() {
+ NIMClient.getService(AuthServiceObserver.class).observeOnlineStatus(
+ new Observer() {
+ public void onEvent(StatusCode status) {
+ statusCode = status;
+ Logger.i("User status changed to: " + status);
+ if (status.wontAutoLogin()) {
+ switch (status) {
+ case KICKOUT:
+ case KICK_BY_OTHER_CLIENT:
+ EventBus.getDefault().post(new KickOutEvent());
+ break;
+ case FORBIDDEN:
+ SingleToastUtil.showToast(status.getDesc());
+ AuthModel.get().logout().subscribe();
+ Logger.e(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_026));
+ break;
+ case PWD_ERROR:
+ Logger.e(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_027));
+ break;
+ }
+ LogUtil.e(TAG, ResUtil.getString(R.string.xchat_android_core_auth_authmodel_028));
+ cleanLogInfo();
+ } else if (status.shouldReLogin()) {
+ if (currentAccountInfo.getUid() != 0 && !isInit) {
+ //IM掉线，但是用户并没有做退出登录，这里只进行IM的重新登录
+ Log.i("IMLogin", "shouldReLogin");
+ imLogin(currentAccountInfo).subscribe();
+ }
+ }
+
+ isInit = false;
+ }
+ }, true);
+ }
+
+ public Single textIMLogin() {
+ return imLogin(currentAccountInfo);
+ }
+
+ /**
+ * IM登录, 订阅与观察都在Main线程
+ *
+ * @param account
+ * @return
+ */
+ private Single imLogin(AccountInfo account) {
+ if (account == null) {
+ return Single.error(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_029)));
+ }
+ Logger.i("account:" + account.getUid() + " token:" + account.getNetEaseToken());
+ final LoginInfo info = new LoginInfo(String.valueOf(account.getUid()), account.getNetEaseToken());
+ Log.i("IMLogin", "account:" + account.getUid() + " token:" + account.getNetEaseToken() + " appkey:" + info.getAppKey());
+ LogUtil.e(TAG, ResUtil.getString(R.string.xchat_android_core_auth_authmodel_030));
+ return Single.create(new SingleOnSubscribe() {
+ @Override
+ public void subscribe(SingleEmitter emitter) throws Exception {
+ NIMClient.getService(AuthService.class).login(info).setCallback(new RequestCallback() {
+ @Override
+ public void onSuccess(LoginInfo loginInfo) {
+ if (loginInfo == null) {
+ OtherExtKt.doLog("网易云信 登录 -> 失败 code = 登录信息为空");
+ onException(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_031)));
+ return;
+ }
+
+ NimUIKit.setAccount(loginInfo.getAccount());
+ DataCacheManager.buildDataCacheAsync();
+ NimUIKit.getImageLoaderKit().buildImageCache();
+
+ //更新消息提醒配置
+ initNotificationConfig();
+
+ NIMClient.getService(MixPushService.class).enable(true).setCallback(new RequestCallbackWrapper() {
+ @Override
+ public void onResult(int code, Void result, Throwable exception) {
+ Log.e(TAG, "onResult() called with: code = [" + code + "], result = [" + result + "], exception = [" + exception + "]");
+ }
+ });
+
+
+ Log.i("IMLogin", ResUtil.getString(R.string.xchat_android_core_auth_authmodel_032));
+ emitter.onSuccess(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_033));
+ OtherExtKt.doLog("网易云信 登录 -> 成功");
+ }
+
+ @Override
+ public void onFailed(int code) {
+ OtherExtKt.doLog("网易云信 登录 -> 失败 code = "+code);
+ LogUtil.e(TAG, ResUtil.getString(R.string.xchat_android_core_auth_authmodel_034) + code);
+ emitter.onError(new Throwable(ResUtil.getString(R.string.xchat_android_core_auth_authmodel_035) + code));
+ }
+
+ @Override
+ public void onException(Throwable exception) {
+ OtherExtKt.doLog("网易云信 登录 -> 错误 msg = "+exception.getMessage());
+ //如果云信登录出现异常，将info打印到埋点
+ String infoJson = JsonUtils.toJson(info);
+ String error = ResUtil.getString(R.string.xchat_android_core_auth_authmodel_036) + exception.toString()
+ + ", LoginInfo:" + infoJson;
+ LogUtil.e(TAG, error);
+ emitter.onError(new Throwable(error));
+ }
+ });
+ }
+ })
+ .subscribeOn(AndroidSchedulers.mainThread())
+ .observeOn(AndroidSchedulers.mainThread());
+
+ }
+
+
+ private void initNotificationConfig() {
+ // 初始化消息提醒,如果是审核账号,不开启推送
+ NIMClient.toggleNotification(!CheckUtils.isCheckUser());
+// // 加载状态栏配置
+// StatusBarNotificationConfig statusBarNotificationConfig = new StatusBarNotificationConfig();
+//// 更新配置
+// NIMClient.updateStatusBarNotificationConfig(statusBarNotificationConfig);
+ }
+
+ /**
+ * 用户绑定的手机号是否输入过授权码
+ *
+ * @return
+ */
+ public Single isBoundPhoneAuthCode() {
+ return api.isBoundPhoneAuthCode()
+ .compose(RxHelper.handleBeanData())
+ .compose(RxHelper.handleSchedulers());
+ }
+
+ /**
+ * 绑定授权码
+ *
+ * @return
+ */
+ public Single boundAuthCode(String authCode) {
+ return api.boundAuthCode(authCode)
+ .compose(RxHelper.handleStringData())
+ .compose(RxHelper.handleSchedulers());
+ }
+
+ /**
+ * 发送验证码
+ *
+ * @param areaCode 地区码
+ * @param phone 手机
+ * @param type
+ * @return
+ */
+ public Single getSmsCode(String areaCode, String phone, int type) {
+ return api.getCode(areaCode, DESUtils.DESAndBase64(phone), String.valueOf(type))
+ .subscribeOn(Schedulers.io())
+ .map(objectServiceResult -> {
+ if (!objectServiceResult.isSuccess()) {
+ throw new RuntimeException(objectServiceResult.getMessage());
+ }
+ return objectServiceResult.getMessage();
+ }).observeOn(AndroidSchedulers.mainThread());
+ }
+
+ /**
+ * 邮箱验证码
+ */
+ public Single getEmailCode(String emailAddress, int type) {
+ OtherExtKt.doLog("邮箱 = "+emailAddress);
+ return api.getEmailCode(DESUtils.DESAndBase64(emailAddress), String.valueOf(type))
+ .subscribeOn(Schedulers.io())
+ .map(objectServiceResult -> {
+ if (!objectServiceResult.isSuccess()) {
+ throw new RuntimeException(objectServiceResult.getMessage());
+ }
+ return objectServiceResult.getMessage();
+ }).observeOn(AndroidSchedulers.mainThread());
+ }
+
+ /**
+ * 在账号被禁止的情况下发送验证码
+ *
+ * @param phone
+ * @return
+ */
+ public Single sendLoginCode(String phone, int type) {
+ return api.sendCode(DESUtils.DESAndBase64(phone), String.valueOf(type))
+ .subscribeOn(Schedulers.io())
+ .map(objectServiceResult -> {
+ if (!objectServiceResult.isSuccess()) {
+ throw new RuntimeException(objectServiceResult.getMessage());
+ }
+ return objectServiceResult.getMessage();
+ }).observeOn(AndroidSchedulers.mainThread());
+ }
+
+ /**
+ * 校验登录验证码
+ *
+ * @param account
+ * @param code
+ * @return
+ */
+ public Single checkLoginCode(String phoneAreaCode, String account, String code) {
+ return api.check(phoneAreaCode, account, code)
+ .map(new Function, String>() {
+
+ @Override
+ public String apply(ServiceResult