Merge pull request #1 from lawrencehj/master

648540858

2020-11-16 f20682cc6fa84b96c1ecac294dd2283032924699

Merge pull request #1 from lawrencehj/master

修正处理Catalog信息时遇到空字段的错误

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/request/impl/MessageRequestProcessor.java

@@ -215,12 +215,27 @@
                    deviceChannel.setPort(itemDevice.element("Port") == null ? 0

                            : Integer.parseInt(XmlUtil.getText(itemDevice, "Port")));

                    deviceChannel.setPassword(XmlUtil.getText(itemDevice, "Password"));

                    deviceChannel.setLongitude(itemDevice.element("Longitude") == null ? 0.00

                            : Double.parseDouble(XmlUtil.getText(itemDevice, "Longitude")));

                    deviceChannel.setLatitude(itemDevice.element("Latitude") == null ? 0.00

                            : Double.parseDouble(XmlUtil.getText(itemDevice, "Latitude")));

                    deviceChannel.setPTZType(itemDevice.element("PTZType") == null ? 0

                            : Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));

                    if (itemDevice.element("Longitute")==null) {

                        deviceChannel.setLongitude(0.00);

                    } else {

                        deviceChannel.setLongitude(Double.parseDouble(XmlUtil.getText(itemDevice, "Longitude")));

                    }

                    if (itemDevice.element("Latitute") == null) {

                        deviceChannel.setLatitude(0.00);

                    } else {

                        deviceChannel.setLatitude(Double.parseDouble(XmlUtil.getText(itemDevice, "Latitude")));

                    }

                    if (itemDevice.element("PTZType") == null) {

                        deviceChannel.setPTZType(0);

                    } else {

                        deviceChannel.setPTZType(Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));

                    }

                    // deviceChannel.setLongitude(itemDevice.element("Longitude") == null ? 0.00

                    //         : Double.parseDouble(XmlUtil.getText(itemDevice, "Longitude")));

                    // deviceChannel.setLatitude(itemDevice.element("Latitude") == null ? 0.00

                    //         : Double.parseDouble(XmlUtil.getText(itemDevice, "Latitude")));

                    // deviceChannel.setPTZType(itemDevice.element("PTZType") == null ? 0

                    //         : Integer.parseInt(XmlUtil.getText(itemDevice, "PTZType")));

                    deviceChannel.setHasAudio(true); // 默认含有音频，播放时再检查是否有音频及是否AAC

                    storager.updateChannel(device.getDeviceId(), deviceChannel);

                }


 src/main/java/com/genersoft/iot/vmp/vmanager/playback/PlaybackController.java

@@ -7,6 +7,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.util.StringUtils;
@@ -38,8 +39,12 @@
    @Autowired
    private ZLMRESTfulUtils zlmresTfulUtils;

    @Value("${media.closeWaitRTPInfo}")
    private boolean closeWaitRTPInfo;

    @GetMapping("/playback/{deviceId}/{channelId}")
    public ResponseEntity<String> play(@PathVariable String deviceId,@PathVariable String channelId, String startTime,  String endTime){
    public ResponseEntity<String> play(@PathVariable String deviceId, @PathVariable String channelId, String startTime,
            String endTime) {
        
        if (logger.isDebugEnabled()) {
            logger.debug(String.format("设备回放 API调用，deviceId：%s ，channelId：%s",deviceId, channelId));
@@ -59,10 +64,12 @@
        }

//        }else {
//            String streamId = String.format("%08x", Integer.parseInt(streamInfo.getSsrc())).toUpperCase();
        // String streamId = String.format("%08x",
        // Integer.parseInt(streamInfo.getSsrc())).toUpperCase();
//            JSONObject rtpInfo = zlmresTfulUtils.getRtpInfo(streamId);
//            if (rtpInfo.getBoolean("exist")) {
//                return new ResponseEntity<String>(JSON.toJSONString(streamInfo),HttpStatus.OK);
        // return new
        // ResponseEntity<String>(JSON.toJSONString(streamInfo),HttpStatus.OK);
//            }else {
//                storager.stopPlayback(streamInfo);
//                streamInfo = cmder.playbackStreamCmd(device, channelId, startTime, endTime);
@@ -81,6 +88,13 @@
        long lockStartTime = System.currentTimeMillis();
        JSONObject rtpInfo = null;

        if (closeWaitRTPInfo) {
            String flv = storager.getMediaInfo().getWanIp() + ":" + storager.getMediaInfo().getHttpPort() + "/rtp/"
                    + streamId + ".flv";
            streamInfo.setFlv("http://" + flv);
            streamInfo.setWs_flv("ws://" + flv);
            storager.startPlayback(streamInfo);
        } else {
        while (lockFlag) {
            try {
                if (System.currentTimeMillis() - lockStartTime > 75 * 1000) {
@@ -93,7 +107,8 @@
                        logger.info("查询RTP推流信息...");
                        rtpInfo = zlmresTfulUtils.getRtpInfo(streamId);
                    }
                    if (rtpInfo != null && rtpInfo.getBoolean("exist") && streamInfo != null && streamInfo.getFlv() != null){
                        if (rtpInfo != null && rtpInfo.getBoolean("exist") && streamInfo != null
                                && streamInfo.getFlv() != null) {
                        logger.info("查询流编码信息："+streamInfo.getFlv());
                        rtpPushed = true;
                        Thread.sleep(2000);
@@ -116,6 +131,7 @@
                e.printStackTrace();
            }
        }
        }
        if(streamInfo!=null) {
            return new ResponseEntity<String>(JSON.toJSONString(streamInfo),HttpStatus.OK);
        } else {