opt

modules/mogo-module-push/src/main/java/com/mogo/module/push/repository/PushRepository.kt

@@ -62,37 +62,37 @@ class PushRepository(mContext: Context) {
         }
 
     init {
-        // 注册push通道监听 type 100时为push消息
-        getApis(mContext).getSocketManagerApi(mContext)
-            .registerOnMessageListener(Config.PUSH_TYPE, object : IMogoOnMessageListener<PushBean> {
-                override fun target(): Class<PushBean> {
-                    return PushBean::class.java
-                }
-
-                override fun onMsgReceived(bean: PushBean?) {
-                    Log.d("PushRepository", "pushBean = $bean")
-                    if (bean != null) {
-                        AnalyticsUtils.track(Config.NEWS_ARRIVE, "title", bean.title)
-                        if (bean.mainSchema.isBlank()) {
-                            bean.mainSchema = ""
-                        }
-                        if (bean.imageUrl.isBlank()) {
-                            bean.imageUrl = ""
-                        }
-                        if (bean.appIcon.isBlank()) {
-                            bean.appIcon = ""
-                        }
-                        pushBeanQueue.offer(bean)
-                    }
-                    if ( bean != null) {
-                        HandlerUtils.mBgHandler.post {
-                            pushBeanDao.insertAll(bean)
-                            updateMsgNum()
-                        }
-                    }
-                    startIterate()
-                }
-            })
+        // 注册push通道监听 type 100时为push消息 lixp TODO
+//        getApis(mContext).getSocketManagerApi(mContext)
+//            .registerOnMessageListener(Config.PUSH_TYPE, object : IMogoOnMessageListener<PushBean> {
+//                override fun target(): Class<PushBean> {
+//                    return PushBean::class.java
+//                }
+//
+//                override fun onMsgReceived(bean: PushBean?) {
+//                    Log.d("PushRepository", "pushBean = $bean")
+//                    if (bean != null) {
+//                        AnalyticsUtils.track(Config.NEWS_ARRIVE, "title", bean.title)
+//                        if (bean.mainSchema.isBlank()) {
+//                            bean.mainSchema = ""
+//                        }
+//                        if (bean.imageUrl.isBlank()) {
+//                            bean.imageUrl = ""
+//                        }
+//                        if (bean.appIcon.isBlank()) {
+//                            bean.appIcon = ""
+//                        }
+//                        pushBeanQueue.offer(bean)
+//                    }
+//                    if ( bean != null) {
+//                        HandlerUtils.mBgHandler.post {
+//                            pushBeanDao.insertAll(bean)
+//                            updateMsgNum()
+//                        }
+//                    }
+//                    startIterate()
+//                }
+//            })
         HandlerUtils.mBgHandler.postDelayed({
             updateMsgNum()
         }, 5000)