修复在ORACLE,达梦等数据库下的用户查询BUG

linshunhua

2024-08-06 402ffa0b1e6b0453338a57469e00903564ac53f5

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java

@@ -24,6 +24,7 @@
import com.genersoft.iot.vmp.service.redisMsg.IRedisRpcService;

import com.genersoft.iot.vmp.storager.IRedisCatchStorage;

import com.genersoft.iot.vmp.storager.IVideoManagerStorage;

import com.genersoft.iot.vmp.utils.MediaServerUtils;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.beans.factory.annotation.Autowired;

@@ -35,7 +36,6 @@
import org.springframework.web.bind.annotation.*;



import javax.servlet.http.HttpServletRequest;

import java.util.HashMap;

import java.util.Map;



/**

@@ -149,7 +149,7 @@
    @PostMapping(value = "/on_play", produces = "application/json;charset=UTF-8")

    public HookResult onPlay(@RequestBody OnPlayHookParam param) {



        Map<String, String> paramMap = urlParamToMap(param.getParams());

        Map<String, String> paramMap = MediaServerUtils.urlParamToMap(param.getParams());

        // 对于播放流进行鉴权

        boolean authenticateResult = mediaService.authenticatePlay(param.getApp(), param.getStream(), paramMap.get("callId"));

        if (!authenticateResult) {

@@ -190,7 +190,15 @@
        }

    }





    /**

     * rtsp/rtmp流注册或注销时触发此事件；此事件对回复不敏感。

     */

//    @ResponseBody

//    @PostMapping(value = "/on_stream_changed", produces = "application/json;charset=UTF-8")

//    public HookResult onStreamChanged(@RequestBody JSONObject param) {

//        System.out.println(11);

//        return HookResult.SUCCESS();

//    }

    /**

     * rtsp/rtmp流注册或注销时触发此事件；此事件对回复不敏感。

     */

@@ -200,6 +208,11 @@


        MediaServer mediaServer = mediaServerService.getOne(param.getMediaServerId());

        if (mediaServer == null) {

            return HookResult.SUCCESS();

        }

        if (!ObjectUtils.isEmpty(mediaServer.getTranscodeSuffix())

                && !"null".equalsIgnoreCase(mediaServer.getTranscodeSuffix())

                && param.getStream().endsWith(mediaServer.getTranscodeSuffix())  ) {

            return HookResult.SUCCESS();

        }

        if (param.getSchema().equalsIgnoreCase("rtsp")) {

@@ -226,6 +239,19 @@


        logger.info("[ZLM HOOK]流无人观看：{}->{}->{}/{}", param.getMediaServerId(), param.getSchema(),

                param.getApp(), param.getStream());



        MediaServer mediaInfo = mediaServerService.getOne(param.getMediaServerId());

        if (mediaInfo == null) {

            JSONObject ret = new JSONObject();

            ret.put("code", 0);

            return ret;

        }

        if (!ObjectUtils.isEmpty(mediaInfo.getTranscodeSuffix())

                && !"null".equalsIgnoreCase(mediaInfo.getTranscodeSuffix())

                && param.getStream().endsWith(mediaInfo.getTranscodeSuffix())  ) {

            param.setStream(param.getStream().substring(0, param.getStream().lastIndexOf(mediaInfo.getTranscodeSuffix()) -1 ));

        }



        JSONObject ret = new JSONObject();

        boolean close = mediaService.closeStreamOnNoneReader(param.getMediaServerId(), param.getApp(), param.getStream(), param.getSchema());

        ret.put("code", 0);

@@ -347,23 +373,5 @@
        }



        return HookResult.SUCCESS();

    }



    private Map<String, String> urlParamToMap(String params) {

        HashMap<String, String> map = new HashMap<>();

        if (ObjectUtils.isEmpty(params)) {

            return map;

        }

        String[] paramsArray = params.split("&");

        if (paramsArray.length == 0) {

            return map;

        }

        for (String param : paramsArray) {

            String[] paramArray = param.split("=");

            if (paramArray.length == 2) {

                map.put(paramArray[0], paramArray[1]);

            }

        }

        return map;

    }

}