[1078] 修复mediaServer入库错误

This commit is contained in:
lin 2025-07-17 07:03:11 +08:00
parent ca07935232
commit e730bf2d15
3 changed files with 5 additions and 2 deletions

View File

@ -83,7 +83,7 @@ public class JTPassengerNum implements JTDeviceSubConfig {
@Override @Override
public String toString() { public String toString() {
return "终端上传乘客流量:" + return "终端上传乘客流量:" +
" 时间: " + startTime + '到' + endTime + " 时间: " + startTime + "" + endTime +
", 上车:" + getIn + ", 上车:" + getIn +
", 下车:" + getOut ", 下车:" + getOut
; ;

View File

@ -10,12 +10,14 @@ import com.genersoft.iot.vmp.jt1078.service.Ijt1078Service;
import com.genersoft.iot.vmp.jt1078.session.Session; import com.genersoft.iot.vmp.jt1078.session.Session;
import com.genersoft.iot.vmp.jt1078.session.SessionManager; import com.genersoft.iot.vmp.jt1078.session.SessionManager;
import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBuf;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEvent; import org.springframework.context.ApplicationEvent;
/** /**
* 终端上传乘客流量 * 终端上传乘客流量
* *
*/ */
@Slf4j
@MsgId(id = "1005") @MsgId(id = "1005")
public class J1005 extends Re { public class J1005 extends Re {
@ -24,7 +26,7 @@ public class J1005 extends Re {
@Override @Override
protected Rs decode0(ByteBuf buf, Header header, Session session) { protected Rs decode0(ByteBuf buf, Header header, Session session) {
passengerNum = JTPassengerNum.decode(buf); passengerNum = JTPassengerNum.decode(buf);
System.out.println(passengerNum); log.info("[终端上传乘客流量] {}", passengerNum);
return null; return null;
} }

View File

@ -57,6 +57,7 @@ public interface MediaServerMapper {
"#{rtmpPort}, " + "#{rtmpPort}, " +
"#{rtmpSSlPort}, " + "#{rtmpSSlPort}, " +
"#{rtpProxyPort}, " + "#{rtpProxyPort}, " +
"#{jttProxyPort}, " +
"#{rtspPort}, " + "#{rtspPort}, " +
"#{flvPort}, " + "#{flvPort}, " +
"#{flvSSLPort}, " + "#{flvSSLPort}, " +