完成向上级联->通道推送 修复选择通道是查询的bug

panlinlin

2021-01-14 6c4da7bebe8040f1d8dea551863eae7bbd4c65a6

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

@@ -7,10 +7,14 @@
import javax.sip.InvalidArgumentException;

import javax.sip.RequestEvent;

import javax.sip.SipException;

import javax.sip.header.FromHeader;

import javax.sip.message.Request;

import javax.sip.message.Response;



import com.genersoft.iot.vmp.gb28181.bean.*;

import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommanderFroPlatform;

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

import com.genersoft.iot.vmp.vmanager.platform.bean.ChannelReduce;

import org.dom4j.Document;

import org.dom4j.DocumentException;

import org.dom4j.Element;

@@ -20,10 +24,6 @@
import org.springframework.beans.factory.annotation.Autowired;



import com.genersoft.iot.vmp.common.VideoManagerConstants;

import com.genersoft.iot.vmp.gb28181.bean.Device;

import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;

import com.genersoft.iot.vmp.gb28181.bean.RecordInfo;

import com.genersoft.iot.vmp.gb28181.bean.RecordItem;

import com.genersoft.iot.vmp.gb28181.event.DeviceOffLineDetector;

import com.genersoft.iot.vmp.gb28181.event.EventPublisher;

import com.genersoft.iot.vmp.gb28181.transmit.callback.DeferredResultHolder;

@@ -46,6 +46,8 @@
   private final static Logger logger = LoggerFactory.getLogger(MessageRequestProcessor.class);



   private SIPCommander cmder;



   private SIPCommanderFroPlatform cmderFroPlatform;



   private IVideoManagerStorager storager;



@@ -163,9 +165,32 @@
         Element deviceIdElement = rootElement.element("DeviceID");

         String deviceId = deviceIdElement.getText();

         Element deviceListElement = rootElement.element("DeviceList");

         if (deviceListElement == null) {

         if (deviceListElement == null) { // 存在DeviceList则为响应 catalog， 不存在DeviceList则为查询请求

            // TODO 后续将代码拆分

            ParentPlatform parentPlatform = storager.queryParentPlatById(deviceId);

            if (parentPlatform == null) {

               response404Ack(evt);

            return;

            }else {

               // 回复200 OK

               responseAck(evt);



               Element snElement = rootElement.element("SN");

               String sn = snElement.getText();

               FromHeader fromHeader = (FromHeader)evt.getRequest().getHeader(FromHeader.NAME);

               // 准备回复通道信息

               List<ChannelReduce> channelReduces = storager.queryChannelListInParentPlatform(parentPlatform.getDeviceGBId());

               if (channelReduces.size() >0 ) {

                  for (ChannelReduce channelReduce : channelReduces) {

                     DeviceChannel deviceChannel = storager.queryChannel(channelReduce.getDeviceId(), channelReduce.getChannelId());

                     cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), channelReduces.size());

         }

               }



            }





         }else {

         Iterator<Element> deviceListIterator = deviceListElement.elementIterator();

         if (deviceListIterator != null) {

            Device device = storager.queryVideoDevice(deviceId);

@@ -267,6 +292,8 @@
               publisher.onlineEventPublish(deviceId, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);

            }

         }

         }



      } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) {

         e.printStackTrace();

      }

@@ -469,6 +496,18 @@
      getServerTransaction(evt).sendResponse(response);

   }



   /***

    * 回复200 OK

    * @param evt

    * @throws SipException

    * @throws InvalidArgumentException

    * @throws ParseException

    */

   private void response404Ack(RequestEvent evt) throws SipException, InvalidArgumentException, ParseException {

      Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());

      getServerTransaction(evt).sendResponse(response);

   }



   private Element getRootElement(RequestEvent evt) throws DocumentException {

      Request request = evt.getRequest();

      SAXReader reader = new SAXReader();

@@ -508,4 +547,12 @@
   public void setRedisCatchStorage(IRedisCatchStorage redisCatchStorage) {

      this.redisCatchStorage = redisCatchStorage;

   }



   public SIPCommanderFroPlatform getCmderFroPlatform() {

      return cmderFroPlatform;

   }



   public void setCmderFroPlatform(SIPCommanderFroPlatform cmderFroPlatform) {

      this.cmderFroPlatform = cmderFroPlatform;

   }

}