|
@@ -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
|
|
@@ -48,9 +49,11 @@ import com.wdkl.ncs.android.middleware.model.vo.InteractionVO
|
|
import com.wdkl.ncs.android.middleware.model.vo.WatchContactVO
|
|
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.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.*
|
|
@@ -178,6 +181,8 @@ class WatchHome2Activity : BaseActivity<WatchHomeActivityPresenter, WatchActivit
|
|
if (SettingConfig.getVoiceCallType(BaseApplication.appContext) == -1) {
|
|
if (SettingConfig.getVoiceCallType(BaseApplication.appContext) == -1) {
|
|
SettingConfig.setVoiceCallType(BaseApplication.appContext, SettingConfig.SIP_CALL)
|
|
SettingConfig.setVoiceCallType(BaseApplication.appContext, SettingConfig.SIP_CALL)
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ tv_server_ip.text = CommonUtils.getUrl(BaseApplication.appContext)
|
|
}
|
|
}
|
|
|
|
|
|
private fun regReceiver() {
|
|
private fun regReceiver() {
|
|
@@ -221,7 +226,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
|
|
@@ -237,6 +242,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.rtcLocalIp + ":" + 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)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
@@ -425,10 +453,10 @@ 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) {
|
|
Thread {
|
|
Thread {
|
|
- for (contactVO in contactVOs) {
|
|
|
|
|
|
+ for (contactVO in contactsVOs) {
|
|
if (!Strings.isNullOrEmpty(contactVO.name) && !Strings.isNullOrEmpty(contactVO.phoneNumber)) {
|
|
if (!Strings.isNullOrEmpty(contactVO.name) && !Strings.isNullOrEmpty(contactVO.phoneNumber)) {
|
|
ContactHelper.setContact(this, contactVO.name, contactVO.phoneNumber)
|
|
ContactHelper.setContact(this, contactVO.name, contactVO.phoneNumber)
|
|
}
|
|
}
|
|
@@ -523,6 +551,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 {
|
|
@@ -531,7 +563,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
|
|
}
|
|
}
|
|
|
|
|
|
@@ -540,7 +573,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(5000)
|
|
Thread.sleep(5000)
|