Commit 6092dd18 by wjg

1.0.9

parent 02260f0d
...@@ -18,8 +18,8 @@ android { ...@@ -18,8 +18,8 @@ android {
applicationId "com.ihaoin.hooloo.device" applicationId "com.ihaoin.hooloo.device"
minSdkVersion 26 minSdkVersion 26
targetSdkVersion 30 targetSdkVersion 30
versionCode 8 versionCode 9
versionName "1.0.8" versionName "1.0.9"
ndk { ndk {
//选择要添加的对应 cpu 类型的 .so 库。 //选择要添加的对应 cpu 类型的 .so 库。
......
package com.ihaoin.hooloo.device.base; package com.ihaoin.hooloo.device.base;
import android.content.Context; import android.content.Context;
import android.os.Handler;
import com.ihaoin.hooloo.device.data.vo.MachineInfoMsg; import com.ihaoin.hooloo.device.data.vo.MachineInfoMsg;
import com.ihaoin.hooloo.device.util.CollectionUtils; import com.ihaoin.hooloo.device.util.CollectionUtils;
...@@ -41,6 +42,7 @@ public class MachineInfoSocket extends Thread { ...@@ -41,6 +42,7 @@ public class MachineInfoSocket extends Thread {
} }
private void reconnect() { private void reconnect() {
new Handler().postDelayed(() -> {
try { try {
mSocket = IO.socket(Base.NSP_MACHINE); mSocket = IO.socket(Base.NSP_MACHINE);
mSocket.connect(); mSocket.connect();
...@@ -48,6 +50,7 @@ public class MachineInfoSocket extends Thread { ...@@ -48,6 +50,7 @@ public class MachineInfoSocket extends Thread {
Utils.i("连接server失败,错误原因:" + e.getMessage()); Utils.i("连接server失败,错误原因:" + e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
}, 1000 * 10);
} }
private Emitter.Listener onConnect = args -> Utils.i("machine socket connected"); private Emitter.Listener onConnect = args -> Utils.i("machine socket connected");
......
package com.ihaoin.hooloo.device.interaction; package com.ihaoin.hooloo.device.interaction;
import android.content.Context; import android.content.Context;
import android.os.Handler;
import com.ihaoin.hooloo.device.base.Base; import com.ihaoin.hooloo.device.base.Base;
import com.ihaoin.hooloo.device.data.vo.InteractionMsg; import com.ihaoin.hooloo.device.data.vo.InteractionMsg;
...@@ -42,6 +43,7 @@ public class InteractionSocket extends Thread { ...@@ -42,6 +43,7 @@ public class InteractionSocket extends Thread {
} }
private void reconnect() { private void reconnect() {
new Handler().postDelayed(() -> {
try { try {
mSocket = IO.socket(Base.NSP_INTERACTION); mSocket = IO.socket(Base.NSP_INTERACTION);
mSocket.connect(); mSocket.connect();
...@@ -49,7 +51,7 @@ public class InteractionSocket extends Thread { ...@@ -49,7 +51,7 @@ public class InteractionSocket extends Thread {
Utils.i("连接server失败,错误原因:" + e.getMessage()); Utils.i("连接server失败,错误原因:" + e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
}, 1000 * 10);
} }
private Emitter.Listener onConnect = args -> { private Emitter.Listener onConnect = args -> {
......
package com.ihaoin.hooloo.device.kds; package com.ihaoin.hooloo.device.kds;
import android.content.Context; import android.content.Context;
import android.os.Handler;
import com.ihaoin.hooloo.device.base.Base; import com.ihaoin.hooloo.device.base.Base;
import com.ihaoin.hooloo.device.data.vo.KDSMsg; import com.ihaoin.hooloo.device.data.vo.KDSMsg;
...@@ -42,6 +43,7 @@ public class KDSSocket extends Thread { ...@@ -42,6 +43,7 @@ public class KDSSocket extends Thread {
} }
private void reconnect() { private void reconnect() {
new Handler().postDelayed(() -> {
try { try {
mSocket = IO.socket(Base.NSP_KDS); mSocket = IO.socket(Base.NSP_KDS);
mSocket.connect(); mSocket.connect();
...@@ -49,6 +51,7 @@ public class KDSSocket extends Thread { ...@@ -49,6 +51,7 @@ public class KDSSocket extends Thread {
Utils.i("连接server失败,错误原因:" + e.getMessage()); Utils.i("连接server失败,错误原因:" + e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
}, 1000 * 10);
} }
private Emitter.Listener onConnect = args -> { private Emitter.Listener onConnect = args -> {
......
...@@ -54,6 +54,7 @@ public class UpdateSocket extends Thread { ...@@ -54,6 +54,7 @@ public class UpdateSocket extends Thread {
} }
private void reconnect() { private void reconnect() {
new Handler().postDelayed(() -> {
try { try {
mSocket = IO.socket(Base.NSP_UPGRADE); mSocket = IO.socket(Base.NSP_UPGRADE);
mSocket.connect(); mSocket.connect();
...@@ -64,6 +65,7 @@ public class UpdateSocket extends Thread { ...@@ -64,6 +65,7 @@ public class UpdateSocket extends Thread {
} }
e.printStackTrace(); e.printStackTrace();
} }
}, 1000 * 10);
} }
private Emitter.Listener onConnect = args -> { private Emitter.Listener onConnect = args -> {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment