|
|
@@ -1,19 +1,16 @@
|
|
|
package com.zksy.pole.MQTTServer.callBack;
|
|
|
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
|
|
|
import com.zksy.pole.MQTTServer.config.MQTTServerProperties;
|
|
|
import com.zksy.pole.MQTTServer.server.MQTTServer;
|
|
|
import com.zksy.pole.factory.HandleCmdFactory;
|
|
|
-import com.zksy.pole.mapper.DgGatewayRegistrationMapper;
|
|
|
import io.netty.buffer.ByteBuf;
|
|
|
import io.netty.buffer.Unpooled;
|
|
|
import io.netty.channel.Channel;
|
|
|
import io.netty.handler.codec.mqtt.*;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
|
-import org.redisson.api.RedissonClient;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|