hengsheng 数据 增加 LGZONE 回复

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

@@ -56,7 +56,7 @@ public class WatchHenShengServerHandler extends HexBinaryAcceptanceHandlerAdapte
 				//setUpload(advice, channel);
 				break;
 			case "LK": // 连接
-				sendMsg2Kafka((msg+DateUtil.formatDate2String(new Date())).getBytes(), advice.getDeviceId(), channel);
+				sendMsg2Kafka((msg + DateUtil.formatDate2String(new Date())).getBytes(), advice.getDeviceId(), channel);
 				normalReply(advice, channel, getLinkTime());
 				break;
 			case "UD": // 位置信息
@@ -72,6 +72,10 @@ public class WatchHenShengServerHandler extends HexBinaryAcceptanceHandlerAdapte
 			case "UPLOAD": // 位置信息
 				logger.info("修改上报频率成功!");
 				break;
+			case "LGZONE": // 终端获取时间
+				logger.info("终端获取时间[LGZONE]：" + advice.toString());
+				normalReply(advice, channel, getlgZoneTime());
+				break;
 			default: // 其他
 				logger.info("client send data without handle type ...");
 				//normalReply(advice, channel, advice.getAdviceType());
@@ -89,6 +93,18 @@ public class WatchHenShengServerHandler extends HexBinaryAcceptanceHandlerAdapte
 		return sb.toString();
 	}
 
+//	public static void main(String[] args) {
+//	   getlgZoneTime();
+//	}
+
+	protected static String getlgZoneTime() {
+		DateFormat dateFormatter = new SimpleDateFormat("HH:mm:ss,yyyy-MM-dd");
+		Date date = new Date();
+		String lk_time = dateFormatter.format(date);
+		StringBuilder sb = new StringBuilder("LGZONE,+8,").append(lk_time);
+		return sb.toString();
+	}
+
 	protected void printAcceptanceData(ByteBuf dataByteBuf, ChannelHandlerContext ctx) {
 		ByteBuf dataByteBufCopy = dataByteBuf.copy();
 		byte[] dataByteArray = new byte[dataByteBufCopy.readableBytes()];