扩展兼容接口，支持HTTPS接口

648540858

2023-07-20 a39ac45bcc7fbddbb578e0ab39fd109e30d214a4

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

@@ -1,5 +1,6 @@
package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl;

import com.genersoft.iot.vmp.conf.CivilCodeFileConf;
import com.genersoft.iot.vmp.conf.DynamicTask;
import com.genersoft.iot.vmp.conf.UserSetting;
import com.genersoft.iot.vmp.gb28181.bean.Device;
@@ -20,7 +21,10 @@

import javax.sip.RequestEvent;
import javax.sip.header.FromHeader;
import java.util.*;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;

@@ -55,6 +59,9 @@

   @Autowired
   private DynamicTask dynamicTask;

   @Autowired
   private CivilCodeFileConf civilCodeFileConf;

   private final static String talkKey = "notify-request-for-catalog-task";

@@ -96,7 +103,7 @@
               }else {
                  event = eventElement.getText().toUpperCase();
               }
               DeviceChannel channel = XmlUtil.channelContentHander(itemDevice, device, event);
               DeviceChannel channel = XmlUtil.channelContentHandler(itemDevice, device, event, civilCodeFileConf);

               channel.setDeviceId(device.getDeviceId());
               logger.info("[收到目录订阅]：{}/{}", device.getDeviceId(), channel.getChannelId());
@@ -232,7 +239,7 @@
   }

   private void executeSave(){
      System.out.println("定时存储数据");
      executeSaveForAdd();
      executeSaveForUpdate();
      executeSaveForDelete();
      executeSaveForOnline();