Merge pull request #1219 from xiaoQQya/develop

648540858

2023-12-26 33fba05a381db591a7f5874eb242f90065e3458d

 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/RegisterResponseProcessor.java

old mode 100644
new mode 100755
@@ -2,20 +2,27 @@

import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
import com.genersoft.iot.vmp.gb28181.bean.SipTransactionInfo;
import com.genersoft.iot.vmp.gb28181.bean.SubscribeHolder;
import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver;
import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
import com.genersoft.iot.vmp.gb28181.transmit.event.response.SIPResponseProcessorAbstract;
import com.genersoft.iot.vmp.service.IPlatformService;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
import com.genersoft.iot.vmp.storager.dao.dto.PlatformRegisterInfo;
import gov.nist.javax.sip.message.SIPResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.sip.InvalidArgumentException;
import javax.sip.ResponseEvent;
import javax.sip.header.CallIdHeader;
import javax.sip.SipException;
import javax.sip.header.WWWAuthenticateHeader;
import javax.sip.message.Response;
import java.text.ParseException;

/**    
 * @description:Register响应处理器
@@ -25,20 +32,26 @@
@Component
public class RegisterResponseProcessor extends SIPResponseProcessorAbstract {

   private Logger logger = LoggerFactory.getLogger(RegisterResponseProcessor.class);
   private String method = "REGISTER";
   private final Logger logger = LoggerFactory.getLogger(RegisterResponseProcessor.class);
   private final String method = "REGISTER";

   @Autowired
   private ISIPCommanderForPlatform sipCommanderForPlatform;

   @Autowired
   private IVideoManagerStorager storager;
   private IVideoManagerStorage storager;

   @Autowired
   private IRedisCatchStorage redisCatchStorage;

   @Autowired
   private SIPProcessorObserver sipProcessorObserver;

   @Autowired
   private SubscribeHolder subscribeHolder;

   @Autowired
   private IPlatformService platformService;

   @Override
   public void afterPropertiesSet() throws Exception {
@@ -53,51 +66,47 @@
    */
   @Override
   public void process(ResponseEvent evt) {
      Response response = evt.getResponse();
      CallIdHeader callIdHeader = (CallIdHeader) response.getHeader(CallIdHeader.NAME);
      String callId = callIdHeader.getCallId();

      String platformGBId = redisCatchStorage.queryPlatformRegisterInfo(callId);
      if (platformGBId == null) {
         logger.info(String.format("未找到callId： %s 的注册/注销平台id", callId ));
      SIPResponse response = (SIPResponse)evt.getResponse();
      String callId = response.getCallIdHeader().getCallId();
      PlatformRegisterInfo platformRegisterInfo = redisCatchStorage.queryPlatformRegisterInfo(callId);
      if (platformRegisterInfo == null) {
         logger.info(String.format("[国标级联]未找到callId： %s 的注册/注销平台id", callId ));
         return;
      }

      ParentPlatformCatch parentPlatformCatch = redisCatchStorage.queryPlatformCatchInfo(platformGBId);
      ParentPlatformCatch parentPlatformCatch = redisCatchStorage.queryPlatformCatchInfo(platformRegisterInfo.getPlatformId());
      if (parentPlatformCatch == null) {
         logger.warn(String.format("收到 %s 的注册/注销%S请求, 但是平台缓存信息未查询到!!!", platformGBId, response.getStatusCode()));
         logger.warn(String.format("[国标级联]收到注册/注销%S请求，平台：%s，但是平台缓存信息未查询到!!!", response.getStatusCode(),platformRegisterInfo.getPlatformId()));
         return;
      }
      String action = parentPlatformCatch.getParentPlatform().getExpires().equals("0") ? "注销" : "注册";
      logger.info(String.format("收到 %s %s的%S响应", platformGBId, action, response.getStatusCode() ));

      String action = platformRegisterInfo.isRegister() ? "注册" : "注销";
      logger.info(String.format("[国标级联]%s %S响应,%s ", action, response.getStatusCode(), platformRegisterInfo.getPlatformId() ));
      ParentPlatform parentPlatform = parentPlatformCatch.getParentPlatform();
      if (parentPlatform == null) {
         logger.warn(String.format("收到 %s %s的%S请求, 但是平台信息未查询到!!!", platformGBId, action, response.getStatusCode()));
         logger.warn(String.format("[国标级联]收到 %s %s的%S请求, 但是平台信息未查询到!!!", platformRegisterInfo.getPlatformId(), action, response.getStatusCode()));
         return;
      }

      if (response.getStatusCode() == 401) {
      if (response.getStatusCode() == Response.UNAUTHORIZED) {
         WWWAuthenticateHeader www = (WWWAuthenticateHeader)response.getHeader(WWWAuthenticateHeader.NAME);
         sipCommanderForPlatform.register(parentPlatform, callId, www, null, null);
      }else if (response.getStatusCode() == 200){
         // 注册/注销成功
         logger.info(String.format("%s %s成功", platformGBId, action));
         SipTransactionInfo sipTransactionInfo = new SipTransactionInfo(response);
         try {
            sipCommanderForPlatform.register(parentPlatform, sipTransactionInfo, www, null, null, platformRegisterInfo.isRegister());
         } catch (SipException | InvalidArgumentException | ParseException e) {
            logger.error("[命令发送失败] 国标级联 再次注册: {}", e.getMessage());
         }
      }else if (response.getStatusCode() == Response.OK){

         if (platformRegisterInfo.isRegister()) {
            SipTransactionInfo sipTransactionInfo = new SipTransactionInfo(response);
            platformService.online(parentPlatform, sipTransactionInfo);
         }else {
            platformService.offline(parentPlatform, true);
         }

         // 注册/注销成功移除缓存的信息
         redisCatchStorage.delPlatformRegisterInfo(callId);
         parentPlatform.setStatus("注册".equals(action));
         // 取回Expires设置，避免注销过程中被置为0
         ParentPlatform parentPlatformTmp = storager.queryParentPlatByServerGBId(platformGBId);
         String expires = parentPlatformTmp.getExpires();
         parentPlatform.setExpires(expires);
         parentPlatform.setId(parentPlatformTmp.getId());
         storager.updateParentPlatformStatus(platformGBId, "注册".equals(action));

         redisCatchStorage.updatePlatformRegister(parentPlatform);

         redisCatchStorage.updatePlatformKeepalive(parentPlatform);

         parentPlatformCatch.setParentPlatform(parentPlatform);

         redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch);
      }
   }