添加国标级联录像控制功能

mk1990

2022-06-22 4b4afa4ef7d05bea29eff15c171d92228ed82da5

添加国标级联录像控制功能

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

@@ -150,7 +150,7 @@
     * @param streamInfo

     * @param content

     */

    void playbackControlCmd(Device device, StreamInfo streamInfo, String content);

    void playbackControlCmd(Device device, StreamInfo streamInfo, String content,SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent);


    /**

     * 语音广播


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

@@ -1830,7 +1830,7 @@
    }

    

    @Override

    public void playbackControlCmd(Device device, StreamInfo streamInfo, String content) {

    public void playbackControlCmd(Device device, StreamInfo streamInfo, String content,SipSubscribe.Event errorEvent, SipSubscribe.Event okEvent) {
        try {

            Request request = headerProvider.createInfoRequest(device, streamInfo, content);

            if (request == null) {

@@ -1843,7 +1843,22 @@
            } else if ("UDP".equals(device.getTransport())) {

                clientTransaction = udpSipProvider.getNewClientTransaction(request);

            }

            CallIdHeader callIdHeader = (CallIdHeader)request.getHeader(CallIdHeader.NAME);
            if(errorEvent != null) {
                sipSubscribe.addErrorSubscribe(callIdHeader.getCallId(), (eventResult -> {
                    errorEvent.response(eventResult);
                    sipSubscribe.removeErrorSubscribe(eventResult.callId);
                    sipSubscribe.removeOkSubscribe(eventResult.callId);
                }));
            }
            

            if(okEvent != null) {
                sipSubscribe.addOkSubscribe(callIdHeader.getCallId(), eventResult -> {
                    okEvent.response(eventResult);
                    sipSubscribe.removeOkSubscribe(eventResult.callId);
                    sipSubscribe.removeErrorSubscribe(eventResult.callId);
                });
            }
            clientTransaction.sendRequest();

            

        } catch (SipException | ParseException | InvalidArgumentException e) {


 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/info/InfoRequestProcessor.java

@@ -105,7 +105,29 @@
                        return;

                    }

                    Device device1 = storager.queryVideoDevice(streamInfo.getDeviceID());

                    cmder.playbackControlCmd(device1,streamInfo,new String(evt.getRequest().getRawContent()));

                    cmder.playbackControlCmd(device1,streamInfo,new String(evt.getRequest().getRawContent()),eventResult -> {
                        // 失败的回复
                        try {
                            responseAck(evt, eventResult.statusCode, eventResult.msg);
                        } catch (SipException e) {
                            e.printStackTrace();
                        } catch (InvalidArgumentException e) {
                            e.printStackTrace();
                        } catch (ParseException e) {
                            e.printStackTrace();
                        }
                    }, eventResult -> {
                        // 成功的回复
                        try {
                            responseAck(evt, eventResult.statusCode);
                        } catch (SipException e) {
                            e.printStackTrace();
                        } catch (InvalidArgumentException e) {
                            e.printStackTrace();
                        } catch (ParseException e) {
                            e.printStackTrace();
                        }
                    });
                }

            }

        } catch (SipException e) {