恒申增加手表 心跳电量接入

src/main/java/com/tidecloud/dataacceptance/service/impl/WatchHenShengServerHandler.java

@@ -1,5 +1,6 @@
 package com.tidecloud.dataacceptance.service.impl;
 
+import com.tidecloud.dataacceptance.common.DateUtil;
 import com.tidecloud.dataacceptance.entity.Advice;
 import com.tidecloud.dataacceptance.service.HexBinaryAcceptanceHandlerAdapter;
 import io.netty.bootstrap.ServerBootstrap;
@@ -55,6 +56,7 @@ public class WatchHenShengServerHandler extends HexBinaryAcceptanceHandlerAdapte
 				setUpload(advice, channel);
 				break;
 			case "LK": // 连接
+				sendMsg2Kafka((msg+DateUtil.formatDate2String(new Date())).getBytes(), advice.getDeviceId(), channel);
 				normalReply(advice, channel, getLinkTime());
 				break;
 			case "UD": // 位置信息