|
@@ -21,6 +21,9 @@ import org.springframework.stereotype.Component;
|
|
|
import javax.xml.bind.DatatypeConverter;
|
|
|
import java.text.SimpleDateFormat;
|
|
|
import java.util.Date;
|
|
|
+import java.util.concurrent.ExecutorService;
|
|
|
+import java.util.concurrent.Executors;
|
|
|
+import java.util.concurrent.TimeUnit;
|
|
|
|
|
|
/**
|
|
|
* Created by jhw on 2018/7/20.
|
|
@@ -34,6 +37,8 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(WatchJWServerHandler.class);
|
|
|
|
|
|
+ private static ExecutorService executorService = Executors.newSingleThreadExecutor();
|
|
|
+
|
|
|
@Override
|
|
|
protected void handle(ByteBuf in, Channel channel) throws Exception {
|
|
|
String msg = byteBufferToString(in.nioBuffer());
|
|
@@ -86,7 +91,18 @@ public class WatchJWServerHandler extends HexBinaryAcceptanceHandlerAdapter {
|
|
|
}
|
|
|
String date =DateUtil.getForamtDateUtc0();// DateUtil.formatDate2String(new Date(), "yyyyMMddHHmmss");
|
|
|
normalReply(factory, channel, "BP00," + date + ",8");
|
|
|
- // normalReplyModel(factory,deviceId,channel); TODO (无效)
|
|
|
+ executorService.execute(new Runnable() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ try {
|
|
|
+ TimeUnit.SECONDS.sleep(5);
|
|
|
+ normalReplyModel(factory,deviceId,channel);
|
|
|
+ } catch (InterruptedException e) {
|
|
|
+ logger.error(e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ });
|
|
|
+
|
|
|
}
|
|
|
|
|
|
|