| | |
|---|
| | | import com.ruoyi.dataInterchange.util.jtt809.packet.common.OuterPacket; |
|---|
| | | import io.netty.channel.ChannelHandlerContext; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.springframework.data.redis.core.RedisTemplate; |
|---|
| | | import org.springframework.stereotype.Component; |
|---|
| | | |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @author zhibing.pu |
|---|
| | |
|---|
| | | @Component |
|---|
| | | public class BaseMsgService { |
|---|
| | | |
|---|
| | | @Resource |
|---|
| | | private RedisTemplate redisTemplate; |
|---|
| | | |
|---|
| | | |
|---|
| | | public void up_base_msg(ChannelHandlerContext ctx, OuterPacket out){ |
|---|
| | | if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) { |
|---|
| | | log.error("链路还未登录校验，拒绝连接"); |
|---|
| | | ctx.close(); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | DataType dataType = DataType.getDataType(out.getId()); |
|---|
| | | switch (dataType){ |
|---|
| | | case UP_BASE_MSG_VEHICLE_ADDED_ACK: |
|---|
