请求历史媒体下载增加回复事件处理ssrc与下级不一致情况

wangyimeng

2023-03-04 c662a530989706b705142743e0095d5b7f331751

请求历史媒体下载增加回复事件处理ssrc与下级不一致情况

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/ISIPCommander.java

@@ -15,26 +15,26 @@
import javax.sip.SipException;

import java.text.ParseException;



/**

 * @description:设备能力接口，用于定义设备的控制、查询能力

/**    
 * @description:设备能力接口，用于定义设备的控制、查询能力   
 * @author: swwheihei

 * @date:   2020年5月3日 下午9:16:34

 * @date:   2020年5月3日 下午9:16:34     
 */

public interface ISIPCommander {



    /**

     * 云台方向放控制，使用配置文件中的默认镜头移动速度

     *

     * 
     * @param device  控制设备

     * @param channelId  预览通道

     * @param leftRight  镜头左移右移 0:停止 1:左移 2:右移

     * @param upDown     镜头上移下移 0:停止 1:上移 2:下移

     */

    void ptzdirectCmd(Device device,String channelId,int leftRight, int upDown) throws InvalidArgumentException, ParseException, SipException;



	
    /**

     * 云台方向放控制

     *

     * 
     * @param device  控制设备

     * @param channelId  预览通道

     * @param leftRight  镜头左移右移 0:停止 1:左移 2:右移

@@ -42,28 +42,28 @@
     * @param moveSpeed  镜头移动速度

     */

    void ptzdirectCmd(Device device,String channelId,int leftRight, int upDown, int moveSpeed) throws InvalidArgumentException, ParseException, SipException;



	
    /**

     * 云台缩放控制，使用配置文件中的默认镜头缩放速度

     *

     * 
     * @param device  控制设备

     * @param channelId  预览通道

     * @param inOut      镜头放大缩小 0:停止 1:缩小 2:放大

     */

    void ptzZoomCmd(Device device,String channelId,int inOut) throws InvalidArgumentException, ParseException, SipException;



	
    /**

     * 云台缩放控制

     *

     * 
     * @param device  控制设备

     * @param channelId  预览通道

     * @param inOut      镜头放大缩小 0:停止 1:缩小 2:放大

     */

    void ptzZoomCmd(Device device,String channelId,int inOut, int moveSpeed) throws InvalidArgumentException, ParseException, SipException;



	
    /**

     * 云台控制，支持方向与缩放控制

     *

     * 
     * @param device  控制设备

     * @param channelId  预览通道

     * @param leftRight  镜头左移右移 0:停止 1:左移 2:右移

@@ -73,10 +73,10 @@
     * @param zoomSpeed  镜头缩放速度

     */

    void ptzCmd(Device device,String channelId,int leftRight, int upDown, int inOut, int moveSpeed, int zoomSpeed) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 前端控制，包括PTZ指令、FI指令、预置位指令、巡航指令、扫描指令和辅助开关指令

     *

     * 
     * @param device          控制设备

     * @param channelId        预览通道

     * @param cmdCode        指令码

@@ -85,7 +85,7 @@
     * @param combineCode2    组合码2

     */

    void frontEndCmd(Device device, String channelId, int cmdCode, int parameter1, int parameter2, int combineCode2) throws SipException, InvalidArgumentException, ParseException;



	
    /**

     * 前端控制指令（用于转发上级指令）

     * @param device        控制设备

@@ -103,7 +103,7 @@


    /**

     * 请求回放视频流

     *

     * 
     * @param device  视频设备

     * @param channelId  预览通道

     * @param startTime 开始时间,格式要求：yyyy-MM-dd HH:mm:ss

@@ -113,13 +113,13 @@


    /**

     * 请求历史媒体下载

     *

     * 
     * @param device  视频设备

     * @param channelId  预览通道

     * @param startTime 开始时间,格式要求：yyyy-MM-dd HH:mm:ss

     * @param endTime 结束时间,格式要求：yyyy-MM-dd HH:mm:ss

     * @param downloadSpeed 下载倍速参数

     */

     */ 
    void downloadStreamCmd(MediaServerItem mediaServerItem, SSRCInfo ssrcInfo, Device device, String channelId,

                           String startTime, String endTime, int downloadSpeed, InviteStreamCallback inviteStreamCallback, InviteStreamCallback hookEvent,

                           SipSubscribe.Event errorEvent,SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException;

@@ -150,7 +150,7 @@
     * 回放倍速播放

     */

    void playSpeedCmd(Device device, StreamInfo streamInfo, Double speed) throws InvalidArgumentException, ParseException, SipException;



	
    /**

     * 回放控制

     * @param device

@@ -162,55 +162,55 @@


    /**

     * 语音广播

     *

     * 
     * @param device  视频设备

     * @param channelId  预览通道

     */

    void audioBroadcastCmd(Device device,String channelId);



	
    /**

     * 语音广播

     *

     * 
     * @param device  视频设备

     */

    void audioBroadcastCmd(Device device, SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException;

    void audioBroadcastCmd(Device device) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 音视频录像控制

     *

     * 
     * @param device          视频设备

     * @param channelId      预览通道

     * @param recordCmdStr    录像命令：Record / StopRecord

     */

    void recordCmd(Device device, String channelId, String recordCmdStr, SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 远程启动控制命令

     *

     * 
     * @param device    视频设备

     */

    void teleBootCmd(Device device) throws InvalidArgumentException, SipException, ParseException;



    /**

     * 报警布防/撤防命令

     *

     * 
     * @param device      视频设备

     */

    void guardCmd(Device device, String guardCmdStr, SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 报警复位命令

     *

     * 
     * @param device        视频设备

     * @param alarmMethod    报警方式（可选）

     * @param alarmType        报警类型（可选）

     */

    void alarmCmd(Device device, String alarmMethod, String alarmType, SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 强制关键帧命令,设备收到此命令应立刻发送一个IDR帧

     *

     * 
     * @param device  视频设备

     * @param channelId  预览通道

     */

@@ -221,7 +221,6 @@
     *

     * @param device      视频设备

     * @param channelId      通道id，非通道则是设备本身

     * @param frontCmd     上级平台的指令，如果存在则直接下发

     * @param enabled     看守位使能：1 = 开启，0 = 关闭

     * @param resetTime   自动归位时间间隔，开启看守位时使用，单位:秒(s)

     * @param presetIndex 调用预置位编号，开启看守位时使用，取值范围0~255

@@ -230,58 +229,58 @@


    /**

     * 设备配置命令

     *

     * 
     * @param device  视频设备

     */

    void deviceConfigCmd(Device device);



	
    /**

     * 设备配置命令：basicParam

     *

     * 
     * @param device              视频设备

     * @param channelId            通道编码（可选）

     * @param name                设备/通道名称（可选）

     * @param expiration        注册过期时间（可选）

     * @param heartBeatInterval    心跳间隔时间（可选）

     * @param heartBeatCount    心跳超时次数（可选）

     */

     */  
    void deviceBasicConfigCmd(Device device, String channelId, String name, String expiration, String heartBeatInterval, String heartBeatCount, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



    /**

     * 查询设备状态

     *

     * 
     * @param device 视频设备

     */

    void deviceStatusQuery(Device device, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询设备信息

     *

     * 
     * @param device 视频设备

     * @return

     * @return 
     */

    void deviceInfoQuery(Device device) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询目录列表

     *

     * 
     * @param device 视频设备

     */

    void catalogQuery(Device device, int sn, SipSubscribe.Event errorEvent) throws SipException, InvalidArgumentException, ParseException;



	
    /**

     * 查询录像信息

     *

     * 
     * @param device 视频设备

     * @param startTime 开始时间,格式要求：yyyy-MM-dd HH:mm:ss

     * @param endTime 结束时间,格式要求：yyyy-MM-dd HH:mm:ss

     * @param sn

     */

    void recordInfoQuery(Device device, String channelId, String startTime, String endTime, int sn,  Integer Secrecy, String type, SipSubscribe.Event okEvent, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询报警信息

     *

     * 
     * @param device        视频设备

     * @param startPriority    报警起始级别（可选）

     * @param endPriority    报警终止级别（可选）

@@ -293,33 +292,33 @@
     */

    void alarmInfoQuery(Device device, String startPriority, String endPriority, String alarmMethod,

                            String alarmType, String startTime, String endTime, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询设备配置

     *

     * 
     * @param device         视频设备

     * @param channelId        通道编码（可选）

     * @param configType    配置类型：

     */

    void deviceConfigQuery(Device device, String channelId, String configType,  SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询设备预置位置

     *

     * 
     * @param device 视频设备

     */

    void presetQuery(Device device, String channelId, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



	
    /**

     * 查询移动设备位置数据

     *

     * 
     * @param device 视频设备

     */

    void mobilePostitionQuery(Device device, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException;



    /**

     * 订阅、取消订阅移动位置

     *

     * 
     * @param device    视频设备

     * @return            true = 命令发送成功

     */


 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java

@@ -56,7 +56,7 @@


    @Autowired

    private SIPSender sipSender;



    
    @Autowired

    private SIPRequestHeaderProvider headerProvider;



@@ -180,7 +180,7 @@
        ptzXml.append("<ControlPriority>5</ControlPriority>\r\n");

        ptzXml.append("</Info>\r\n");

        ptzXml.append("</Control>\r\n");



        
        Request request = headerProvider.createMessageRequest(device, ptzXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null, sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));



        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()),request);

@@ -243,8 +243,8 @@
        ptzXml.append("<ControlPriority>5</ControlPriority>\r\n");

        ptzXml.append("</Info>\r\n");

        ptzXml.append("</Control>\r\n");





        
        
        Request request = headerProvider.createMessageRequest(device, ptzXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()),request, errorEvent, okEvent);



@@ -364,8 +364,7 @@
     */

    @Override

    public void playbackStreamCmd(MediaServerItem mediaServerItem, SSRCInfo ssrcInfo, Device device, String channelId,

                                  String startTime, String endTime,

                                  InviteStreamCallback inviteStreamCallback, InviteStreamCallback hookEvent,

                                  String startTime, String endTime, InviteStreamCallback inviteStreamCallback, InviteStreamCallback hookEvent,

                                  SipSubscribe.Event okEvent, SipSubscribe.Event errorEvent) throws InvalidArgumentException, SipException, ParseException {





@@ -411,8 +410,7 @@
                content.append("a=setup:active\r\n");

                content.append("a=connection:new\r\n");

            }

        } else

            {

        } else {

            if ("TCP-PASSIVE".equalsIgnoreCase(streamMode)) {

                content.append("m=video " + ssrcInfo.getPort() + " TCP/RTP/AVP 96 97 98 99\r\n");

            } else if ("TCP-ACTIVE".equalsIgnoreCase(streamMode)) {

@@ -543,11 +541,10 @@
        content.append("a=downloadspeed:" + downloadSpeed + "\r\n");



        content.append("y=" + ssrcInfo.getSsrc() + "\r\n");//ssrc



        
        HookSubscribeForStreamChange hookSubscribe = HookSubscribeFactory.on_stream_changed("rtp", ssrcInfo.getStream(), true, null, mediaServerItem.getId());

        // 添加订阅

        subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json) ->

        {

        subscribe.addSubscribe(hookSubscribe, (MediaServerItem mediaServerItemInUse, JSONObject json) -> {

            hookEvent.call(new InviteStreamInfo(mediaServerItem, json,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()).getCallId(), "rtp", ssrcInfo.getStream()));

            subscribe.removeSubscribe(hookSubscribe);

            hookSubscribe.getContent().put("regist", false);

@@ -632,7 +629,7 @@
        broadcastXml.append("<TargetID>" + device.getDeviceId() + "</TargetID>\r\n");

        broadcastXml.append("</Notify>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, broadcastXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request);

@@ -652,7 +649,7 @@
        broadcastXml.append("<TargetID>" + device.getDeviceId() + "</TargetID>\r\n");

        broadcastXml.append("</Notify>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, broadcastXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent);

@@ -683,7 +680,7 @@
        cmdXml.append("<RecordCmd>" + recordCmdStr + "</RecordCmd>\r\n");

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent,okEvent);

@@ -707,7 +704,7 @@
        cmdXml.append("<TeleBoot>Boot</TeleBoot>\r\n");

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request);

@@ -766,7 +763,7 @@
        }

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent,okEvent);

@@ -795,7 +792,7 @@
        cmdXml.append("<IFameCmd>Send</IFameCmd>\r\n");

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request);

@@ -843,7 +840,7 @@
        cmdXml.append("</HomePosition>\r\n");

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent,okEvent);

@@ -906,7 +903,7 @@
        cmdXml.append("</BasicParam>\r\n");

        cmdXml.append("</Control>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent);

@@ -929,7 +926,7 @@
        catalogXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

        catalogXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, catalogXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));



@@ -953,7 +950,7 @@
        catalogXml.append("<DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

        catalogXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, catalogXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));



@@ -978,7 +975,7 @@
        catalogXml.append("  <DeviceID>" + device.getDeviceId() + "</DeviceID>\r\n");

        catalogXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, catalogXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));



@@ -1023,7 +1020,7 @@
        }

        recordInfoXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, recordInfoXml.toString(),

                SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

@@ -1074,7 +1071,7 @@
        }

        cmdXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent);

@@ -1104,7 +1101,7 @@
        cmdXml.append("<ConfigType>" + configType + "</ConfigType>\r\n");

        cmdXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent);

@@ -1131,7 +1128,7 @@
        }

        cmdXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, cmdXml.toString(), null, SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request, errorEvent);

@@ -1155,7 +1152,7 @@
        mobilePostitionXml.append("<Interval>60</Interval>\r\n");

        mobilePostitionXml.append("</Query>\r\n");





        


        Request request = headerProvider.createMessageRequest(device, mobilePostitionXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));



@@ -1240,7 +1237,7 @@
        }

        cmdXml.append("</Query>\r\n");





        


        Request request = headerProvider.createSubscribeRequest(device, cmdXml.toString(), null, expires, "presence",sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()), request);

@@ -1290,14 +1287,14 @@
        }

        dragXml.append(cmdString);

        dragXml.append("</Control>\r\n");



        
        Request request = headerProvider.createMessageRequest(device, dragXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        logger.debug("拉框信令： " + request.toString());

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()),request);

    }







    




    /**

@@ -1401,7 +1398,7 @@
        deviceStatusXml.append("</info>\r\n");

        deviceStatusXml.append("</Notify>\r\n");





        
        Request request = headerProvider.createMessageRequest(device, deviceStatusXml.toString(), SipUtils.getNewViaTag(), SipUtils.getNewFromTag(), null,sipSender.getNewCallIdHeader(sipLayer.getLocalIp(device.getLocalIp()),device.getTransport()));

        sipSender.transmitRequest(sipLayer.getLocalIp(device.getLocalIp()),request);




 src/main/java/com/genersoft/iot/vmp/service/impl/PlayServiceImpl.java

@@ -258,8 +258,7 @@
            return;
        }
        try {
            cmder.playStreamCmd(mediaServerItem, ssrcInfo, device, channelId, (MediaServerItem mediaServerItemInuse, JSONObject response) ->
            {
            cmder.playStreamCmd(mediaServerItem, ssrcInfo, device, channelId, (MediaServerItem mediaServerItemInuse, JSONObject response) -> {
                logger.info("收到订阅消息： " + response.toJSONString());
                dynamicTask.stop(timeOutTaskKey);

@@ -274,8 +273,7 @@
                logger.info("[请求截图]: " + fileName);
                zlmresTfulUtils.getSnap(mediaServerItemInuse, streamUrl, 15, 1, path, fileName);

            }, (event) ->
            {
            }, (event) -> {
                ResponseEvent responseEvent = (ResponseEvent) event.event;
                String contentString = new String(responseEvent.getResponse().getRawContent());
                // 获取ssrc
@@ -324,8 +322,7 @@

                    }
                }
            }, (event) ->
            {
            }, (event) -> {
                dynamicTask.stop(timeOutTaskKey);
                mediaServerService.closeRTPServer(mediaServerItem, ssrcInfo.getStream());
                // 释放ssrc
@@ -516,8 +513,7 @@

        try {
            cmder.playbackStreamCmd(mediaServerItem, ssrcInfo, device, channelId, startTime, endTime, infoCallBack,
                    hookEvent, eventResult ->
                    {
                    hookEvent, eventResult -> {
                        if (eventResult.type == SipSubscribe.EventResultType.response) {
                            ResponseEvent responseEvent = (ResponseEvent) eventResult.event;
                            String contentString = new String(responseEvent.getResponse().getRawContent());
@@ -586,7 +582,6 @@
        if (device == null) {
            return;
        }
        //获取录像下载的服务，配置文件中的record-assist-port不为0
        MediaServerItem newMediaServerItem = getNewMediaServerItemHasAssist(device);
        if (newMediaServerItem == null) {
            PlayBackResult<StreamInfo> downloadResult = new PlayBackResult<>();