使用阿里代码规范。规范代码写法

648540858

2022-05-06 5d901b5e3f033e8b04e53420d68626cbd87431c8

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

@@ -2,11 +2,12 @@

import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch;
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.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -32,13 +33,16 @@
   private ISIPCommanderForPlatform sipCommanderForPlatform;

   @Autowired
   private IVideoManagerStorager storager;
   private IVideoManagerStorage storager;

   @Autowired
   private IRedisCatchStorage redisCatchStorage;

   @Autowired
   private SIPProcessorObserver sipProcessorObserver;

   @Autowired
   private SubscribeHolder subscribeHolder;

   @Override
   public void afterPropertiesSet() throws Exception {
@@ -83,21 +87,21 @@
         // 注册/注销成功
         logger.info(String.format("%s %s成功", platformGBId, action));
         redisCatchStorage.delPlatformRegisterInfo(callId);
         parentPlatform.setStatus("注册".equals(action));
         redisCatchStorage.delPlatformCatchInfo(platformGBId);
         // 取回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);

         if (parentPlatformTmp != null) {
            parentPlatformTmp.setStatus("注册".equals(action));
            redisCatchStorage.updatePlatformRegister(parentPlatformTmp);
            redisCatchStorage.updatePlatformKeepalive(parentPlatformTmp);
            parentPlatformCatch.setParentPlatform(parentPlatformTmp);
         }
         redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch);
         storager.updateParentPlatformStatus(platformGBId, "注册".equals(action));
         if ("注销".equals(action)) {
            subscribeHolder.removeCatalogSubscribe(platformGBId);
            subscribeHolder.removeMobilePositionSubscribe(platformGBId);
         }
      }
   }