diff --git a/core/function-impl/mogo-core-function-devatools/build/tmp/kapt3/incApCache/debug/classpath-structure.bin b/core/function-impl/mogo-core-function-devatools/build/tmp/kapt3/incApCache/debug/classpath-structure.bin index 507055d899..6bb7595bb0 100644 Binary files a/core/function-impl/mogo-core-function-devatools/build/tmp/kapt3/incApCache/debug/classpath-structure.bin and b/core/function-impl/mogo-core-function-devatools/build/tmp/kapt3/incApCache/debug/classpath-structure.bin differ diff --git a/core/function-impl/mogo-core-function-hmi/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java b/core/function-impl/mogo-core-function-hmi/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java index 02b2b20b25..26b4aa6fb3 100644 --- a/core/function-impl/mogo-core-function-hmi/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java +++ b/core/function-impl/mogo-core-function-hmi/src/main/java/com/mogo/eagle/core/function/main/MainMoGoApplication.java @@ -43,7 +43,7 @@ import java.util.Date; import java.util.List; /** - * 默认初始化一些基础服务配置 + * 默认初始化一些基础服务配置 todo 分离 overView业务 和 msgBox去各自模块中 --- 扶风 */ public abstract class MainMoGoApplication extends AbsMogoApplication { @@ -66,8 +66,6 @@ public abstract class MainMoGoApplication extends AbsMogoApplication { if (DebugConfig.isDebug()) { initKoom(); } - //查询是否有版本的更新 - queryAppUpgrade(); clearMessageBoxTable(); checkMonitorDb(); upgradeProgressListener(); @@ -80,10 +78,6 @@ public abstract class MainMoGoApplication extends AbsMogoApplication { return true; } - private void queryAppUpgrade() { - - } - @SuppressLint("SimpleDateFormat") private void clearMessageBoxTable() { new Thread(() -> { @@ -203,10 +197,6 @@ public abstract class MainMoGoApplication extends AbsMogoApplication { private void initModules() { CallerLogger.INSTANCE.d(M_HMI + TAG, "initModules"); - //och模块 -// MogoModulePaths.addModuleFunction(new MogoModule("/driver/api", "IMoGoFunctionProvider")); -// MogoModulePaths.addModuleFunction(new MogoModule("/passenger/api", "IMoGoFunctionProvider")); - // OBU 模块 MogoModulePaths.addModuleFunctionServer(new MogoModule(MogoServicePaths.PATH_V2X_OBU_MOGO, "IMoGoObuProvider")); // BIZ @@ -215,13 +205,11 @@ public abstract class MainMoGoApplication extends AbsMogoApplication { MogoModulePaths.addModuleFunctionServer(new MogoModule(ChatConsts.CHAT_PROVIDER_PATH, ChatConsts.CHAT_MODULE_NAME)); // V2X 模块 MogoModulePaths.addBaseModule(new MogoModule(MogoServicePaths.PATH_V2X_MODULE, "V2XProvider")); - // 司机身份专属模块 if (AppIdentityModeUtils.isDriver(FunctionBuildConfig.appIdentityMode)) { // 地图数据收集模块 MogoModulePaths.addModuleFunctionServer(new MogoModule(MogoServicePaths.PATH_MAP_DATA_COLLECT_PROVIDER, "MoGoMapDataCollector")); } - CallerLogger.INSTANCE.i(M_HMI + TAG, "App launch timer cost " + (System.currentTimeMillis() - start) + "ms"); } diff --git a/core/function-impl/mogo-core-function-map/src/main/java/com/mogo/eagle/core/function/map/MapFragment.kt b/core/function-impl/mogo-core-function-map/src/main/java/com/mogo/eagle/core/function/map/MapFragment.kt index ff18af63ac..4f2890603b 100644 --- a/core/function-impl/mogo-core-function-map/src/main/java/com/mogo/eagle/core/function/map/MapFragment.kt +++ b/core/function-impl/mogo-core-function-map/src/main/java/com/mogo/eagle/core/function/map/MapFragment.kt @@ -47,9 +47,7 @@ import mogo.telematics.pad.MessagePad * @author donghongyu * @since 2021-11-09 * 高精度地图层UI - * - * - * 地图图层,地图操作都在这个图层完成 + * 地图图层,地图操作都在这个图层完成 //todo 以view方式进行提供 */ @Route(path = MoGoFragmentPaths.PATH_FRAGMENT_MAP) class MapFragment : MvpFragment(), @@ -65,7 +63,7 @@ class MapFragment : MvpFragment(), private val mIsControllerByOthersStatus = false companion object { - val functionName = "MapFragment" + const val functionName = "MapFragment" /** * sight mode @@ -128,7 +126,7 @@ class MapFragment : MvpFragment(), override fun onViewCreated(view: View, savedInstanceState: Bundle?) { super.onViewCreated(view, savedInstanceState) initMapView() - queryInfStructure() + initMapBiz() } override fun onSaveInstanceState(outState: Bundle) { @@ -201,31 +199,20 @@ class MapFragment : MvpFragment(), //设置双指缩放手势是否可用。 uiSettings.setZoomGesturesEnabled(true) } + } + private fun initMapBiz() { // TODO 临时初始化地图监听工控机、OBU等数据监听器,用于感知元素绘制 MapIdentifySubscriber.instance MogoRouteOverlayManager.getInstance().init() MapPointCloudSubscriber.instance + // TODO GD地图业务需要与高精地图业务拆开 --- 扶风 + queryInfStructure() } private fun queryInfStructure() { val viewModel = this.obtainViewModel(OverViewModel::class.java) - // viewModel.getInfStructures().observe(this.getViewLifecycleOwner(), infrastructures -> { -// if (isFirst) { -// for (Infrastructure entity : infrastructures) { -// Double lat = Double.parseDouble(entity.getLat()); -// Double lon = Double.parseDouble(entity.getLon()); -// if (lat < 0 || lat > 90 || lon < 0 || lon > 180) { -// continue; -// } -// String geoHash = GeoHash.withCharacterPrecision(lat, lon, 7).toBase32(); -// viewModel.updateGeoHash(entity.getId(), geoHash); -// } -// isFirst = false; -// } -// }); viewModel.infStructuresMap.observe(this.viewLifecycleOwner) { t -> InfStructureManager.saveData(t) } - viewModel.fetchInfStructures() } @@ -352,6 +339,7 @@ class MapFragment : MvpFragment(), override val functionName: String get() = functionName + // TODO 全览模式需要自己监听 --- 扶风 override fun onAutopilotRotting(globalPathResp: MessagePad.GlobalPathResp?) { UiThreadHandler.post { savePlanningData(globalPathResp!!.wayPointsList) } } diff --git a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/receiver/TestPanelBroadcastReceiver.java b/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/receiver/TestPanelBroadcastReceiver.java index 641abd35ef..59d5471e0f 100644 --- a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/receiver/TestPanelBroadcastReceiver.java +++ b/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/receiver/TestPanelBroadcastReceiver.java @@ -6,18 +6,13 @@ import android.content.Intent; import androidx.localbroadcastmanager.content.LocalBroadcastManager; -import com.mogo.commons.module.status.MogoStatusManager; import com.mogo.eagle.core.data.map.MogoLatLng; -import com.mogo.eagle.core.data.map.entity.MarkerExploreWay; import com.mogo.eagle.core.data.map.entity.V2XMessageEntity; import com.mogo.eagle.core.data.map.entity.V2XRoadEventEntity; import com.mogo.eagle.core.data.v2x.V2XOptimalRouteDataRes; -import com.mogo.eagle.core.function.call.chat.CallerChatManager; import com.mogo.eagle.core.function.call.map.CallerSmpManager; import com.mogo.eagle.core.function.v2x.events.consts.V2XConst; import com.mogo.eagle.core.function.v2x.events.utils.TestOnLineCarUtils; -import com.mogo.eagle.core.function.v2x.events.utils.V2XSQLiteUtils; -import com.mogo.eagle.core.utilcode.util.Utils; import java.util.List; @@ -57,10 +52,6 @@ public class TestPanelBroadcastReceiver extends BroadcastReceiver { Intent intent = new Intent(V2XConst.BROADCAST_SCENE_HANDLER_ACTION); intent.putExtra(V2XConst.BROADCAST_SCENE_EXTRA_KEY, v2XMessageEntity); LocalBroadcastManager.getInstance(mContext).sendBroadcast(intent); - - // 存储本地,出行动态作展示 - saveLocalStory(V2XMessageEntity.V2XTypeEnum.ALERT_ROAD_WARNING, - v2XMessageEntity.getContent().getNoveltyInfo()); } else if (sceneType == 10) {//触发事件UGC V2XMessageEntity v2XMessageEntity = TestOnLineCarUtils.getV2XScenarioRoadEventUGCData(); @@ -102,17 +93,4 @@ public class TestPanelBroadcastReceiver extends BroadcastReceiver { } } - - /** - * 存储本地数据 - * - * @param v2XRoadEventEntity 要存储的场景 - */ - public void saveLocalStory(int scenarioType, MarkerExploreWay v2XRoadEventEntity) { - try { - V2XSQLiteUtils.saveLocalStory(scenarioType, v2XRoadEventEntity, v2XRoadEventEntity.hashCode()); - } catch (Exception e) { - e.printStackTrace(); - } - } } diff --git a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/utils/V2XSQLiteUtils.java b/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/utils/V2XSQLiteUtils.java deleted file mode 100644 index 19e697b0e1..0000000000 --- a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/events/utils/V2XSQLiteUtils.java +++ /dev/null @@ -1,185 +0,0 @@ -package com.mogo.eagle.core.function.v2x.events.utils; - -import static com.mogo.eagle.core.utilcode.mogo.logger.scene.SceneConstant.M_V2X; - -import com.mogo.eagle.core.data.map.entity.V2XEventZanData; -import com.mogo.eagle.core.data.map.entity.V2XHistoryScenarioData; -import com.mogo.eagle.core.utilcode.mogo.logger.CallerLogger; -import com.mogo.eagle.core.network.utils.GsonUtil; -import com.mogo.eagle.core.utilcode.mogo.sqlite.SQLIDao; -import com.mogo.eagle.core.utilcode.util.TimeUtils; -import com.mogo.eagle.core.utilcode.util.Utils; -import com.mogo.utils.sqlite.SQLDaoFactory; - -import java.util.List; - -/** - * 数据库操作工具类 - * - * @author donghongyu - */ -public class V2XSQLiteUtils { - - /** - * 场景数据管理 - */ - private static SQLIDao mScenarioHistoryDao; - - /** - * 点赞数据管理 - */ - private static SQLIDao mV2XEventZanDao; - - /** - * 点赞数据管理 - */ - public static SQLIDao getV2XEventZanDao() { - if (mV2XEventZanDao == null) { - synchronized (V2XSQLiteUtils.class) { - if (mV2XEventZanDao == null) { - mV2XEventZanDao = SQLDaoFactory.Companion.getInstance() - .getBaseDao(Utils.getApp(), V2XEventZanData.class); - } - } - } - return mV2XEventZanDao; - } - - /** - * 存储本地数据 - * - * @param v2XEventZanData 要存储的场景 - */ - public static void saveEventZanLocalStory(V2XEventZanData v2XEventZanData) { - try { - if (!isZanEvent(v2XEventZanData.eventId)) { - // 进行数据库存储 - V2XSQLiteUtils.getV2XEventZanDao().insert(v2XEventZanData); - } - } catch (Exception e) { - e.printStackTrace(); - } - } - - /** - * 判断是否已经存在 - * - * @param eventId 要判断的事件ID - * @return true-已存在,false-没存在 - */ - public static boolean isZanEvent(String eventId) { - try { - // 查询数据库,判断是否存在 - for (V2XEventZanData eventZanDatum : getEventZanData()) { - if (eventZanDatum.eventId.equals(eventId)) { - return true; - } - } - } catch (Exception e) { - e.printStackTrace(); - } - return false; - } - - /** - * 查询当天的V2X数据 - */ - public static List getEventZanData() { - return getV2XEventZanDao().query(new V2XEventZanData()); - } - - /** - * 修改指定的数据 - */ - public static void updateScenarioHistoryData(V2XHistoryScenarioData oldScenarioData, V2XHistoryScenarioData newScenarioData) { - try { - int result = getScenarioHistoryDao().update(oldScenarioData, newScenarioData); - //V2XEventPanelFragment.Companion.getInstance().changeEventCount(); - } catch (Exception e) { - e.printStackTrace(); - } - } - - /** - * 场景数据管理 - */ - public static SQLIDao getScenarioHistoryDao() { - if (mScenarioHistoryDao == null) { - synchronized (V2XSQLiteUtils.class) { - if (mScenarioHistoryDao == null) { - mScenarioHistoryDao = SQLDaoFactory.Companion.getInstance() - .getBaseDao(Utils.getApp(), V2XHistoryScenarioData.class); - } - } - } - return mScenarioHistoryDao; - } - - /** - * 查询当天的V2X数据 - */ - public static List getScenarioHistoryData() { - return getScenarioHistoryDao().query(new V2XHistoryScenarioData(), "triggerTime", true); - } - - /** - * 删除数据库中存储的昨天的数据 - */ - public static void clearYesterdayScenarioHistoryData() { - try { - List historyScenarioData = getScenarioHistoryDao().query(new V2XHistoryScenarioData()); - for (V2XHistoryScenarioData historyScenarioDatum : historyScenarioData) { - Long triggerTime = historyScenarioDatum.getTriggerTime(); - if (!TimeUtils.isToday(triggerTime)) { - int result = getScenarioHistoryDao().delete(historyScenarioDatum); - if (result > 0) { - CallerLogger.INSTANCE.d(M_V2X + "V2XSQLiteUtils", "删除过期数据成功"); - } - } - } - } catch (Exception e) { - e.printStackTrace(); - } - } - - /** - * 存储本地数据,每个数据只能存在一次,所以存储之前先查询数据库如果已经存在则修改触碰时间 - * - * @param markerExploreWay 要存储的场景 - */ - public static void saveLocalStory(int scenarioType, Object markerExploreWay, int hashCode) { - try { - - CallerLogger.INSTANCE.d(M_V2X + "V2XSQLiteUtils", "saveLocalStory:" + markerExploreWay); - - // 进行数据库存储 - V2XHistoryScenarioData v2XHistoryScenarioData = new V2XHistoryScenarioData(); - v2XHistoryScenarioData.setScenarioType(scenarioType); - v2XHistoryScenarioData.setEventJsonDataHashCode(hashCode); - - List historyScenarioData = getTargetScenarioHistoryData(v2XHistoryScenarioData); - - v2XHistoryScenarioData.setEventJsonData(GsonUtil.jsonFromObject(markerExploreWay)); - v2XHistoryScenarioData.setTriggerTime(TimeUtils.getNowMills()); - v2XHistoryScenarioData.setDispose(false); - - if (historyScenarioData != null && historyScenarioData.size() > 0) { - // 更新数据 - V2XSQLiteUtils.getScenarioHistoryDao().update(historyScenarioData.get(0), v2XHistoryScenarioData); - } else { - // 存储新数据 - V2XSQLiteUtils.getScenarioHistoryDao().insert(v2XHistoryScenarioData); - } - //V2XEventPanelFragment.Companion.getInstance().changeEventCount(); - } catch (Exception e) { - e.printStackTrace(); - } - } - - /** - * 查询当天的指定的V2X数据 - */ - public static List getTargetScenarioHistoryData(V2XHistoryScenarioData scenarioData) { - return getScenarioHistoryDao().query(scenarioData, "triggerTime", true); - } -} diff --git a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/socket.txt b/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/socket.txt deleted file mode 100644 index fd90c72dab..0000000000 --- a/core/function-impl/mogo-core-function-v2x/src/main/java/com/mogo/eagle/core/function/v2x/socket.txt +++ /dev/null @@ -1,70 +0,0 @@ -2023-01-14 12:03:02.263 24403-24598/com.mogo.launcher.f D/com.zhidao.socket--->: start socket -2023-01-14 12:03:02.754 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: requestSocketAddress onGetSocketAddressSuccess 0:OK -2023-01-14 12:03:02.754 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: internalStart-->host: 119.45.249.167 & port: 11000 -2023-01-14 12:03:02.773 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: start connect 119.45.249.167:11000 -2023-01-14 12:03:02.773 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: doConnection -2023-01-14 12:03:03.934 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client---connecting server succeeds -2023-01-14 12:03:03.937 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: call login -2023-01-14 12:03:03.938 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:03:03.938 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:03:03.944 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 531 -2023-01-14 12:03:03.960 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: login -2023-01-14 12:03:03.960 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: ---onConnectSuccess -2023-01-14 12:03:03.962 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: channel is active -2023-01-14 12:03:03.994 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=270, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 270, widx: 270, cap: 1024)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 259, cap: 259/259, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 270, widx: 270, cap: 1024))} -2023-01-14 12:03:03.995 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAuthMidRsp -2023-01-14 12:03:04.001 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: call checkAuth -2023-01-14 12:03:04.001 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:03:04.001 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:03:04.002 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 533 -2023-01-14 12:03:04.004 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: checkAuth -2023-01-14 12:03:04.038 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=11, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 11, widx: 11, cap: 1024)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 0, cap: 0/0, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 11, widx: 11, cap: 1024))} -2023-01-14 12:03:04.038 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAuthRsp -2023-01-14 12:03:04.040 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client authority check succeeded -2023-01-14 12:03:04.044 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: setExact(...) -2023-01-14 12:03:04.044 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: call send user info -2023-01-14 12:03:04.044 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:03:04.044 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:03:04.048 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 529 -2023-01-14 12:03:04.050 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: send user info -2023-01-14 12:03:04.082 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=13, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 13, widx: 13, cap: 512)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 2, cap: 2/2, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 13, widx: 13, cap: 512))} -2023-01-14 12:03:04.082 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAgentInfoRsp -2023-01-14 12:03:04.084 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: Client receives server's user info response, result is true. -2023-01-14 12:04:44.088 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: channel is inactive, it depends on client's choice whether to reconnect or not. -2023-01-14 12:04:44.089 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: close allowReconnect=true -2023-01-14 12:04:44.089 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: channel is null -2023-01-14 12:04:44.090 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: heartbeat alarm is cancelled -2023-01-14 12:04:44.090 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: ---onConnectLost -2023-01-14 12:04:44.092 24403-24641/com.mogo.launcher.f D/com.zhidao.socket--->: retryGetAddress 1000 -2023-01-14 12:04:45.092 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: get socket address -2023-01-14 12:04:50.321 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: requestSocketAddress onGetSocketAddressSuccess 0:OK -2023-01-14 12:04:50.321 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: internalStart-->host: 119.45.249.167 & port: 11000 -2023-01-14 12:04:50.324 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: start connect 119.45.249.167:11000 -2023-01-14 12:04:50.324 24403-24403/com.mogo.launcher.f D/com.zhidao.socket--->: doConnection -2023-01-14 12:04:51.413 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client---connecting server succeeds -2023-01-14 12:04:51.414 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: call login -2023-01-14 12:04:51.416 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:04:51.416 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:04:51.416 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 531 -2023-01-14 12:04:51.419 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: login -2023-01-14 12:04:51.419 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: ---onConnectSuccess -2023-01-14 12:04:51.420 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: channel is active -2023-01-14 12:04:51.443 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=270, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 270, widx: 270, cap: 1024)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 259, cap: 259/259, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 270, widx: 270, cap: 1024))} -2023-01-14 12:04:51.443 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAuthMidRsp -2023-01-14 12:04:51.445 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: call checkAuth -2023-01-14 12:04:51.445 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:04:51.445 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:04:51.446 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 533 -2023-01-14 12:04:51.451 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: checkAuth -2023-01-14 12:04:51.477 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=11, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 11, widx: 11, cap: 1024)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 0, cap: 0/0, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 11, widx: 11, cap: 1024))} -2023-01-14 12:04:51.477 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAuthRsp -2023-01-14 12:04:51.477 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client authority check succeeded -2023-01-14 12:04:51.480 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: setExact(...) -2023-01-14 12:04:51.480 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: call send user info -2023-01-14 12:04:51.480 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: checkNotNull(channel), channel is not null. -2023-01-14 12:04:51.480 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket connected is :false -2023-01-14 12:04:51.481 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: socket app id is dataCrawler, msg type is 529 -2023-01-14 12:04:51.482 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: send user info -2023-01-14 12:04:51.509 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client---client receive server---MogoConnsvrPacket{magicCode=28007, payloadOffset=11, packetLength=13, header=UnpooledSlicedByteBuf(ridx: 0, widx: 3, cap: 3/3, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 13, widx: 13, cap: 512)), payload=UnpooledSlicedByteBuf(ridx: 0, widx: 2, cap: 2/2, unwrapped: UnpooledByteBufAllocator$InstrumentedUnpooledHeapByteBuf(ridx: 13, widx: 13, cap: 512))} -2023-01-14 12:04:51.509 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: receive server---msgTypemogoMsgTypeConnSvrAgentInfoRsp -2023-01-14 12:04:51.509 24403-24852/com.mogo.launcher.f D/com.zhidao.socket--->: Client receives server's user info response, result is true.