package com.ruoyi.dataInterchange.server;
|
|
import com.ruoyi.dataInterchange.dao.UPRealvideoMsgEndAckDao;
|
import com.ruoyi.dataInterchange.dao.UPRealvideoMsgStartupAckDao;
|
import com.ruoyi.dataInterchange.model.RealVideoMsg;
|
import com.ruoyi.dataInterchange.model.UPRealvideoMsgEndAck;
|
import com.ruoyi.dataInterchange.model.UPRealvideoMsgStartupAck;
|
import com.ruoyi.dataInterchange.model.enu.DataType;
|
import com.ruoyi.dataInterchange.util.jtt809.common.Jtt809Util;
|
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 11:58
|
*/
|
@Slf4j
|
@Service
|
public class RealvideoMsgService {
|
|
@Resource
|
private RedisTemplate redisTemplate;
|
|
@Resource
|
private UPRealvideoMsgStartupAckDao upRealvideoMsgStartupAckDao;
|
|
@Resource
|
private UPRealvideoMsgEndAckDao upRealvideoMsgEndAckDao;
|
|
|
public void up_realvideo_msg(ChannelHandlerContext ctx, OuterPacket out) {
|
if (!redisTemplate.hasKey("login:" + out.getGnsscenterId())) {
|
log.error("链路还未登录校验，拒绝连接");
|
ctx.close();
|
return;
|
}
|
RealVideoMsg realVideoMsg = getRealVideoMsg(out);
|
DataType dataType = DataType.getDataType(realVideoMsg.getDataType());
|
switch (dataType) {
|
case UP_REALVIDEO_MSG_STARTUP_ACK:
|
log.info("实时音视频请求应答({})：{}", DataType.UP_REALVIDEO_MSG_STARTUP_ACK.getCode(), out);
|
up_realvideo_msg_startup_ack(ctx, out.getGnsscenterId(), realVideoMsg);
|
break;
|
case UP_REALVIDEO_MSG_END_ACK:
|
log.info("主动请求停止实时音视频应答({})：{}", DataType.UP_REALVIDEO_MSG_END_ACK.getCode(), out);
|
up_realvideo_msg_end_ack(ctx, out.getGnsscenterId(), realVideoMsg);
|
break;
|
default:
|
break;
|
}
|
|
|
}
|
|
|
public RealVideoMsg getRealVideoMsg(OuterPacket out) {
|
byte[] body = out.getBody();
|
ByteBuf byteBuf = Unpooled.wrappedBuffer(body);
|
//车牌号
|
String vehicleNo = Jtt809Util.readGBKString(byteBuf, 21);
|
//车牌颜色
|
byte vehicleColor = byteBuf.readByte();
|
//子业务类型标识
|
int dataType = byteBuf.readUnsignedShort();
|
//后续数据长度
|
int dataLength = byteBuf.readInt();
|
//子业务数据包
|
byte[] data = new byte[byteBuf.readableBytes()];
|
byteBuf.readBytes(data);
|
RealVideoMsg realVideoMsg = new RealVideoMsg();
|
realVideoMsg.setVehicleNo(vehicleNo);
|
realVideoMsg.setVehicleColor(vehicleColor);
|
realVideoMsg.setDataType(dataType);
|
realVideoMsg.setDataLength(dataLength);
|
realVideoMsg.setData(data);
|
return realVideoMsg;
|
}
|
|
|
/**
|
* 实时音视频请求应答
|
*
|
* @param ctx
|
* @param inferiorPlatformId
|
* @param realVideoMsg
|
*/
|
public void up_realvideo_msg_startup_ack(ChannelHandlerContext ctx, Integer inferiorPlatformId, RealVideoMsg realVideoMsg) {
|
UPRealvideoMsgStartupAck upRealvideoMsgStartupAck = new UPRealvideoMsgStartupAck().decode(realVideoMsg);
|
upRealvideoMsgStartupAck.setInferiorPlatformId(inferiorPlatformId);
|
upRealvideoMsgStartupAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
|
upRealvideoMsgStartupAckDao.save(upRealvideoMsgStartupAck);
|
}
|
|
|
/**
|
* 主动停止实时音视频应答
|
*
|
* @param ctx
|
* @param inferiorPlatformId
|
* @param realVideoMsg
|
*/
|
public void up_realvideo_msg_end_ack(ChannelHandlerContext ctx, Integer inferiorPlatformId, RealVideoMsg realVideoMsg) {
|
UPRealvideoMsgEndAck upRealvideoMsgEndAck = new UPRealvideoMsgEndAck().decode(realVideoMsg);
|
upRealvideoMsgEndAck.setInferiorPlatformId(inferiorPlatformId);
|
upRealvideoMsgEndAck.setCreateTime(LocalDateTime.now().toEpochSecond(ZoneOffset.ofHours(8)));
|
upRealvideoMsgEndAckDao.save(upRealvideoMsgEndAck);
|
}
|
}
|
