|
@@ -39,6 +39,7 @@ import com.wdkl.ncs.android.lib.vo.MessageEvent
|
|
import com.wdkl.ncs.android.middleware.common.Constants
|
|
import com.wdkl.ncs.android.middleware.common.Constants
|
|
import com.wdkl.ncs.android.middleware.logic.contract.home.WatchHomeActivityContract
|
|
import com.wdkl.ncs.android.middleware.logic.contract.home.WatchHomeActivityContract
|
|
import com.wdkl.ncs.android.middleware.logic.presenter.home.WatchHomeActivityPresenter
|
|
import com.wdkl.ncs.android.middleware.logic.presenter.home.WatchHomeActivityPresenter
|
|
|
|
+import com.wdkl.ncs.android.middleware.model.ServerIpInfo
|
|
import com.wdkl.ncs.android.middleware.model.dos.AppVersionDO
|
|
import com.wdkl.ncs.android.middleware.model.dos.AppVersionDO
|
|
import com.wdkl.ncs.android.middleware.model.dos.ChannelDO
|
|
import com.wdkl.ncs.android.middleware.model.dos.ChannelDO
|
|
import com.wdkl.ncs.android.middleware.model.dos.PartSettingDO
|
|
import com.wdkl.ncs.android.middleware.model.dos.PartSettingDO
|
|
@@ -49,9 +50,11 @@ import com.wdkl.ncs.android.middleware.model.vo.WatchContactVO
|
|
import com.wdkl.ncs.android.middleware.tcp.NettyClient
|
|
import com.wdkl.ncs.android.middleware.tcp.NettyClient
|
|
import com.wdkl.ncs.android.middleware.tcp.TcpClientHandler
|
|
import com.wdkl.ncs.android.middleware.tcp.TcpClientHandler
|
|
import com.wdkl.ncs.android.middleware.tcp.enums.CommunicationEnum
|
|
import com.wdkl.ncs.android.middleware.tcp.enums.CommunicationEnum
|
|
|
|
+import com.wdkl.ncs.android.middleware.utils.CommonUtils
|
|
import com.wdkl.ncs.android.middleware.utils.ContactHelper
|
|
import com.wdkl.ncs.android.middleware.utils.ContactHelper
|
|
import com.wdkl.ncs.keepbackground.utils.SpManager
|
|
import com.wdkl.ncs.keepbackground.utils.SpManager
|
|
import com.wdkl.ncs.keepbackground.work.DaemonEnv
|
|
import com.wdkl.ncs.keepbackground.work.DaemonEnv
|
|
|
|
+import com.wdkl.rtc.util.JanusConstant
|
|
import io.reactivex.Observable
|
|
import io.reactivex.Observable
|
|
import kotlinx.android.synthetic.main.watch_activity_home2.*
|
|
import kotlinx.android.synthetic.main.watch_activity_home2.*
|
|
import kotlinx.android.synthetic.main.watch_activity_register.*
|
|
import kotlinx.android.synthetic.main.watch_activity_register.*
|
|
@@ -179,6 +182,8 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
if (SettingConfig.getVoiceCallType(BaseApplication.appContext) == SettingConfig.PHONE_CALL) {
|
|
if (SettingConfig.getVoiceCallType(BaseApplication.appContext) == SettingConfig.PHONE_CALL) {
|
|
Constants.phoneType = CommunicationEnum.MOBILE_PHONE.value()
|
|
Constants.phoneType = CommunicationEnum.MOBILE_PHONE.value()
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ tv_server_ip.text = CommonUtils.getUrl(BaseApplication.appContext)
|
|
}
|
|
}
|
|
|
|
|
|
private fun regReceiver() {
|
|
private fun regReceiver() {
|
|
@@ -222,7 +227,7 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
* 返回的tcp信息
|
|
* 返回的tcp信息
|
|
*/
|
|
*/
|
|
override fun setTcpServerHost(tcpSeverDTO: TcpSeverDTO) {
|
|
override fun setTcpServerHost(tcpSeverDTO: TcpSeverDTO) {
|
|
- Log.d(TAG, "获取服务器IP完成")
|
|
|
|
|
|
+ /*Log.d(TAG, "获取服务器IP完成")
|
|
if (tcpSeverDTO.publicIp != null && tcpSeverDTO.tcpPort != null && tcpSeverDTO.readerIdleTime != null) {
|
|
if (tcpSeverDTO.publicIp != null && tcpSeverDTO.tcpPort != null && tcpSeverDTO.readerIdleTime != null) {
|
|
Constants.tcpServer = tcpSeverDTO.publicIp
|
|
Constants.tcpServer = tcpSeverDTO.publicIp
|
|
Constants.tcpPort = tcpSeverDTO.tcpPort
|
|
Constants.tcpPort = tcpSeverDTO.tcpPort
|
|
@@ -238,6 +243,29 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
}
|
|
}
|
|
|
|
|
|
presenter.getDeviceVO(Constants.imei)
|
|
presenter.getDeviceVO(Constants.imei)
|
|
|
|
+ }*/
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ override fun setServerInfo(serverIpInfo: ServerIpInfo) {
|
|
|
|
+ if (serverIpInfo.tcpPublicIp != null && serverIpInfo.tcpPort != null && serverIpInfo.tcpIdleSeconds != null) {
|
|
|
|
+ Constants.tcpServer = serverIpInfo.tcpPublicIp
|
|
|
|
+ Constants.tcpPort = serverIpInfo.tcpPort
|
|
|
|
+ Constants.heartBeat = serverIpInfo.tcpIdleSeconds
|
|
|
|
+ tv_server_ip.text = serverIpInfo.tcpPublicIp
|
|
|
|
+
|
|
|
|
+ JanusConstant.JANUS_URL = "ws://" + serverIpInfo.rtcPublicIp + ":" + serverIpInfo.rtcPort
|
|
|
|
+ JanusConstant.STUN_SERVER = arrayOf<String>(serverIpInfo.stunServer)
|
|
|
|
+ //JanusConstant.TURN_SERVER = data.turnServer
|
|
|
|
+
|
|
|
|
+ //成功获取到数据后再启动keepService并连接tcp服务器
|
|
|
|
+ if (DaemonEnv.app == null && !Strings.isNullOrEmpty(Constants.tcpServer) && !WdKeepAliveService.instanceCreated) {
|
|
|
|
+ Log.d(TAG, "开始 WdKeepAliveService")
|
|
|
|
+ //保活守护进程
|
|
|
|
+ DaemonEnv.init(this)
|
|
|
|
+ DaemonEnv.startServiceSafely(this, WdKeepAliveService::class.java)
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ presenter.getDeviceVO(Constants.imei)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -426,8 +454,8 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
}
|
|
}
|
|
|
|
|
|
//写手机通讯录
|
|
//写手机通讯录
|
|
- override fun setContact(contactVOs: List<WatchContactVO>) {
|
|
|
|
- if (contactVOs != null && contactVOs.size > 0) {
|
|
|
|
|
|
+ override fun setContact(contactsVOs: List<WatchContactVO>) {
|
|
|
|
+ if (contactsVOs != null && contactsVOs.size > 0) {
|
|
if (!contactUpdating) {
|
|
if (!contactUpdating) {
|
|
contactUpdating = true
|
|
contactUpdating = true
|
|
Thread {
|
|
Thread {
|
|
@@ -438,7 +466,7 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
ContactHelper.setContact(BaseApplication.appContext, contactVO.name, contactVO.phoneNumber)
|
|
ContactHelper.setContact(BaseApplication.appContext, contactVO.name, contactVO.phoneNumber)
|
|
}
|
|
}
|
|
}*/
|
|
}*/
|
|
- ContactHelper.setContact2(BaseApplication.appContext, contactVOs)
|
|
|
|
|
|
+ ContactHelper.setContact2(BaseApplication.appContext, contactsVOs)
|
|
Log.e(TAG, "111 update contacts end...")
|
|
Log.e(TAG, "111 update contacts end...")
|
|
contactUpdating = false
|
|
contactUpdating = false
|
|
} catch (ex: Exception) {
|
|
} catch (ex: Exception) {
|
|
@@ -544,6 +572,10 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
tv_restart_app.setOnClickListener {
|
|
tv_restart_app.setOnClickListener {
|
|
AppUtils.restartApp()
|
|
AppUtils.restartApp()
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ tv_config_server.setOnClickListener {
|
|
|
|
+ ServerConfigDialogHelper.showPasswordDialog(activity)
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
override fun enableHeadsetVoiceMsg(): Boolean {
|
|
override fun enableHeadsetVoiceMsg(): Boolean {
|
|
@@ -552,7 +584,8 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
|
|
|
|
fun initTcp() {
|
|
fun initTcp() {
|
|
if (!Strings.isNullOrEmpty(Constants.tcpServer)) { //有网且得到了服务器IP
|
|
if (!Strings.isNullOrEmpty(Constants.tcpServer)) { //有网且得到了服务器IP
|
|
- presenter.getTcpServerHost()
|
|
|
|
|
|
+ //presenter.getTcpServerHost()
|
|
|
|
+ presenter.getServerInfo()
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
@@ -561,7 +594,8 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
while (isUnRegister && count > 0 && Strings.isNullOrEmpty(Constants.tcpServer)) {
|
|
while (isUnRegister && count > 0 && Strings.isNullOrEmpty(Constants.tcpServer)) {
|
|
//DaemonEnv.sendStopWorkBroadcast(this)
|
|
//DaemonEnv.sendStopWorkBroadcast(this)
|
|
Log.i(TAG, "获取TCP服务器IP和端口")
|
|
Log.i(TAG, "获取TCP服务器IP和端口")
|
|
- presenter.getTcpServerHost()
|
|
|
|
|
|
+ //presenter.getTcpServerHost()
|
|
|
|
+ presenter.getServerInfo()
|
|
|
|
|
|
try {
|
|
try {
|
|
Thread.sleep(10000)
|
|
Thread.sleep(10000)
|