|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.bean.ParentPlatformCatch; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.event.EventPublisher; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.service.IPlatformService; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; | 
|---|
|  |  |  | 
|---|
|  |  |  | * @author lin | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Component | 
|---|
|  |  |  | @Order(value=3) | 
|---|
|  |  |  | @Order(value=13) | 
|---|
|  |  |  | public class SipPlatformRunner implements CommandLineRunner { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | 
|---|
|  |  |  | List<ParentPlatform> parentPlatforms = storager.queryEnableParentPlatformList(true); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | for (ParentPlatform parentPlatform : parentPlatforms) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | ParentPlatformCatch parentPlatformCatchOld = redisCatchStorage.queryPlatformCatchInfo(parentPlatform.getServerGBId()); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 更新缓存 | 
|---|
|  |  |  | ParentPlatformCatch parentPlatformCatch = new ParentPlatformCatch(); | 
|---|
|  |  |  | parentPlatformCatch.setParentPlatform(parentPlatform); | 
|---|
|  |  |  | parentPlatformCatch.setId(parentPlatform.getServerGBId()); | 
|---|
|  |  |  | redisCatchStorage.updatePlatformCatchInfo(parentPlatformCatch); | 
|---|
|  |  |  | if (parentPlatformCatchOld != null) { | 
|---|
|  |  |  | // 取消订阅 | 
|---|
|  |  |  | sipCommanderForPlatform.unregister(parentPlatform, parentPlatformCatchOld.getSipTransactionInfo(), null, (eventResult)->{ | 
|---|
|  |  |  | platformService.login(parentPlatform); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 设置所有平台离线 | 
|---|
|  |  |  | platformService.offline(parentPlatform); | 
|---|
|  |  |  | // 取消订阅 | 
|---|
|  |  |  | sipCommanderForPlatform.unregister(parentPlatform, null, (eventResult)->{ | 
|---|
|  |  |  | platformService.login(parentPlatform); | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | platformService.offline(parentPlatform, true); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|