package com.ruoyi.dataInterchange.server;
|
|
import com.alibaba.fastjson.JSON;
|
import com.ruoyi.common.core.utils.StringUtils;
|
import com.ruoyi.dataInterchange.dao.UPAuthorizeMsgStartupDao;
|
import com.ruoyi.dataInterchange.model.UPAuthorizeMsgStartup;
|
import com.ruoyi.dataInterchange.util.jtt809.packet.common.OuterPacket;
|
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.Unpooled;
|
import io.netty.channel.ChannelHandlerContext;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.data.redis.core.RedisTemplate;
|
import org.springframework.stereotype.Service;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.ZoneOffset;
|
|
/**
|
* 主链路视频时效口令交互
|
*
|
* @author zhibing.pu
|
* @Date 2025/3/21 10:45
|
*/
|
@Slf4j
|
@Service
|
public class AuthorizeMsgService {
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
@Resource
|
private UPAuthorizeMsgStartupDao upAuthorizeMsgStartupDao;
|
|
public void up_authorize_msg(ChannelHandlerContext ctx, OuterPacket out) {
|
if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) {
|
log.error("链路还未登录校验，拒绝连接");
|
ctx.close();
|
return;
|
}
|
byte[] body = out.getBody();
|
ByteBuf byteBuf = Unpooled.wrappedBuffer(body);
|
UPAuthorizeMsgStartup startup = new UPAuthorizeMsgStartup().decode(byteBuf);
|
log.info("视频时效口令上报：" + JSON.toJSONString(startup));
|
startup.setInferiorPlatformId(out.getGnsscenterId());
|
startup.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
|
if(StringUtils.isNotEmpty(startup.getAuthorizeCode1())){
|
upAuthorizeMsgStartupDao.save(startup);
|
}
|
}
|
}
|
