Merge branch 'wvp-28181-2.0' into wvp-28181-2.0

mrjackwang

2022-03-07 21506440d22a2f77d4bbeb4bb646a27b03bb9022

 src/main/java/com/genersoft/iot/vmp/vmanager/gb28181/platform/PlatformController.java

@@ -2,8 +2,9 @@

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.genersoft.iot.vmp.gb28181.bean.CatalogData;
import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;
import com.genersoft.iot.vmp.common.VideoManagerConstants;
import com.genersoft.iot.vmp.conf.DynamicTask;
import com.genersoft.iot.vmp.conf.UserSetup;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
import com.genersoft.iot.vmp.gb28181.bean.PlatformCatalog;
import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
@@ -40,6 +41,9 @@
    private final static Logger logger = LoggerFactory.getLogger(PlatformController.class);

    @Autowired
    private UserSetup userSetup;

    @Autowired
    private IVideoManagerStorager storager;

    @Autowired
@@ -51,8 +55,12 @@
   @Autowired
   private SipConfig sipConfig;

   @Autowired
   private DynamicTask dynamicTask;

    /**
     * 获取国标服务的配置
     *
     * @return
     */
    @ApiOperation("获取国标服务的配置")
@@ -65,8 +73,10 @@
        result.put("password", sipConfig.getPassword());
        return new ResponseEntity<>(result, HttpStatus.OK);
    }

    /**
     * 获取级联服务器信息
     *
     * @return
     */
    @ApiOperation("获取国标服务的配置")
@@ -87,6 +97,7 @@

    /**
     * 分页查询级联平台
     *
     * @param page 当前页
     * @param count 每页条数
     * @return
@@ -107,6 +118,7 @@

    /**
     * 添加上级平台信息
     *
     * @param parentPlatform
     * @return
     */
@@ -154,7 +166,7 @@
        if (updateResult) {
            // 保存时启用就发送注册
            if (parentPlatform.isEnable()) {
                if (parentPlatformOld.isStatus()) {
                if (parentPlatformOld != null && parentPlatformOld.isStatus()) {
                    commanderForPlatform.unregister(parentPlatformOld, null, eventResult -> {
                        //  只要保存就发送注册
                        commanderForPlatform.register(parentPlatform, null, null);
@@ -179,6 +191,7 @@

    /**
     * 保存上级平台信息
     *
     * @param parentPlatform
     * @return
     */
@@ -216,7 +229,7 @@
        if (updateResult) {
            // 保存时启用就发送注册
            if (parentPlatform.isEnable()) {
                if (parentPlatformOld.isStatus()) {
                if (parentPlatformOld != null && parentPlatformOld.isStatus()) {
                    commanderForPlatform.unregister(parentPlatformOld, null, null);
                    try {
                        Thread.sleep(500);
@@ -244,6 +257,7 @@

    /**
     * 删除上级平台
     *
      * @param serverGBId 上级平台国标ID
     * @return
     */
@@ -280,8 +294,9 @@
        boolean deleteResult = storager.deleteParentPlatform(parentPlatform);
        storager.delCatalogByPlatformId(parentPlatform.getServerGBId());
        storager.delRelationByPlatformId(parentPlatform.getServerGBId());


        // 停止发送位置订阅定时任务
        String key = VideoManagerConstants.SIP_SUBSCRIBE_PREFIX + userSetup.getServerId() +  "_MobilePosition_" + parentPlatform.getServerGBId();
        dynamicTask.stop(key);
        if (deleteResult) {
            return new ResponseEntity<>("success", HttpStatus.OK);
        }else {
@@ -291,6 +306,7 @@

    /**
     * 查询上级平台是否存在
     *
     * @param serverGBId 上级平台国标ID
     * @return
     */
@@ -311,6 +327,7 @@

    /**
     * 分页查询级联平台的所有所有通道
     *
     * @param page 当前页
     * @param count 每页条数
     * @param platformId 上级平台ID
@@ -358,6 +375,7 @@

    /**
     * 向上级平台添加国标通道
     *
     * @param param 通道关联参数
     * @return
     */
@@ -379,6 +397,7 @@

    /**
     * 从上级平台移除国标通道
     *
     * @param param 通道关联参数
     * @return
     */
@@ -400,6 +419,7 @@

    /**
     * 获取目录
     *
     * @param platformId 平台ID
     * @param parentId 目录父ID
     * @return
@@ -432,6 +452,7 @@

    /**
     * 添加目录
     *
     * @param platformCatalog 目录
     * @return
     */
@@ -469,6 +490,7 @@

    /**
     * 编辑目录
     *
     * @param platformCatalog 目录
     * @return
     */
@@ -503,6 +525,7 @@

    /**
     * 删除目录
     *
     * @param id 目录Id
     * @return
     */
@@ -548,6 +571,7 @@

    /**
     * 删除关联
     *
     * @param platformCatalog 关联的信息
     * @return
     */
@@ -578,6 +602,7 @@

    /**
     * 修改默认目录
     *
     * @param platformId 平台Id
     * @param catalogId 目录Id
     * @return