old mode 100644
new mode 100755
 |  |  | 
 |  |  | package com.genersoft.iot.vmp.service.impl; | 
 |  |  |  | 
 |  |  | import com.baomidou.dynamic.datasource.annotation.DS; | 
 |  |  | import com.genersoft.iot.vmp.common.CommonCallback; | 
 |  |  | import com.genersoft.iot.vmp.common.VideoManagerConstants; | 
 |  |  | import com.genersoft.iot.vmp.conf.DynamicTask; | 
 |  |  | import com.genersoft.iot.vmp.conf.UserSetting; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.bean.*; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.session.AudioBroadcastManager; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.task.ISubscribeTask; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd.CatalogResponseMessageHandler; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.utils.Coordtransform; | 
 |  |  | import com.genersoft.iot.vmp.service.IDeviceChannelService; | 
 |  |  | import com.genersoft.iot.vmp.service.IDeviceService; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.task.impl.CatalogSubscribeTask; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.task.impl.MobilePositionSubscribeTask; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander; | 
 |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd.CatalogResponseMessageHandler; | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.ZLMRESTfulUtils; | 
 |  |  | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; | 
 |  |  | import com.genersoft.iot.vmp.service.IDeviceChannelService; | 
 |  |  | import com.genersoft.iot.vmp.service.IDeviceService; | 
 |  |  | import com.genersoft.iot.vmp.service.IInviteStreamService; | 
 |  |  | import com.genersoft.iot.vmp.service.IMediaServerService; | 
 |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; | 
 |  |  | import com.genersoft.iot.vmp.storager.IVideoManagerStorage; | 
 |  |  | import com.genersoft.iot.vmp.storager.dao.DeviceChannelMapper; | 
 |  |  | import com.genersoft.iot.vmp.storager.dao.DeviceMapper; | 
 |  |  | import com.genersoft.iot.vmp.storager.dao.PlatformChannelMapper; | 
 |  |  | import com.genersoft.iot.vmp.utils.DateUtil; | 
 |  |  | import com.genersoft.iot.vmp.vmanager.bean.BaseTree; | 
 |  |  | import com.genersoft.iot.vmp.vmanager.bean.ResourceBaseInfo; | 
 |  |  | import org.slf4j.Logger; | 
 |  |  | import org.slf4j.LoggerFactory; | 
 |  |  | import org.springframework.beans.factory.annotation.Autowired; | 
 |  |  | import org.springframework.jdbc.support.incrementer.AbstractIdentityColumnMaxValueIncrementer; | 
 |  |  | import org.springframework.jdbc.datasource.DataSourceTransactionManager; | 
 |  |  | import org.springframework.stereotype.Service; | 
 |  |  | import org.springframework.util.StringUtils; | 
 |  |  | import org.springframework.transaction.TransactionDefinition; | 
 |  |  | import org.springframework.transaction.TransactionStatus; | 
 |  |  | import org.springframework.util.ObjectUtils; | 
 |  |  |  | 
 |  |  | import javax.sip.InvalidArgumentException; | 
 |  |  | import javax.sip.SipException; | 
 |  |  | import java.text.ParseException; | 
 |  |  | import java.time.Instant; | 
 |  |  | import java.util.ArrayList; | 
 |  |  | import java.util.Collections; | 
 |  |  | import java.util.List; | 
 |  |  | import java.util.*; | 
 |  |  | import java.util.concurrent.TimeUnit; | 
 |  |  |  | 
 |  |  | /** | 
 |  |  |  * 设备业务(目录订阅) | 
 |  |  |  */ | 
 |  |  | @Service | 
 |  |  | @DS("master") | 
 |  |  | public class DeviceServiceImpl implements IDeviceService { | 
 |  |  |  | 
 |  |  |     private final static Logger logger = LoggerFactory.getLogger(DeviceServiceImpl.class); | 
 |  |  |  | 
 |  |  |     private final String  registerExpireTaskKeyPrefix = "device-register-expire-"; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private SIPCommander cmder; | 
 |  |  |     @Autowired | 
 |  |  |     private DynamicTask dynamicTask; | 
 |  |  |  | 
 |  |  | 
 |  |  |     private IRedisCatchStorage redisCatchStorage; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private IInviteStreamService inviteStreamService; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private DeviceMapper deviceMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private PlatformChannelMapper platformChannelMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private IDeviceChannelService deviceChannelService; | 
 |  |  | 
 |  |  |     private DeviceChannelMapper deviceChannelMapper; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private IVideoManagerStorage storage; | 
 |  |  |     DataSourceTransactionManager dataSourceTransactionManager; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     TransactionDefinition transactionDefinition; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private UserSetting userSetting; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ISIPCommander commander; | 
 |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private IMediaServerService mediaServerService; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private AudioBroadcastManager audioBroadcastManager; | 
 |  |  |  | 
 |  |  |     @Autowired | 
 |  |  |     private ZLMRESTfulUtils zlmresTfulUtils; | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void online(Device device) { | 
 |  |  |     public void online(Device device, SipTransactionInfo sipTransactionInfo) { | 
 |  |  |         logger.info("[设备上线] deviceId:{}->{}:{}", device.getDeviceId(), device.getIp(), device.getPort()); | 
 |  |  |         Device deviceInRedis = redisCatchStorage.getDevice(device.getDeviceId()); | 
 |  |  |         Device deviceInDb = deviceMapper.getDeviceByDeviceId(device.getDeviceId()); | 
 |  |  | 
 |  |  |         String now = DateUtil.getNow(); | 
 |  |  |         if (deviceInRedis != null && deviceInDb == null) { | 
 |  |  |             // redis 存在脏数据 | 
 |  |  |             redisCatchStorage.clearCatchByDeviceId(device.getDeviceId()); | 
 |  |  |             inviteStreamService.clearInviteInfo(device.getDeviceId()); | 
 |  |  |         } | 
 |  |  |         device.setUpdateTime(now); | 
 |  |  |         device.setOnline(1); | 
 |  |  |         device.setKeepaliveTime(now); | 
 |  |  |         if (device.getKeepaliveIntervalTime() == 0) { | 
 |  |  |             // 默认心跳间隔60 | 
 |  |  |             device.setKeepaliveIntervalTime(60); | 
 |  |  |         } | 
 |  |  |         if (sipTransactionInfo != null) { | 
 |  |  |             device.setSipTransactionInfo(sipTransactionInfo); | 
 |  |  |         }else { | 
 |  |  |             if (deviceInRedis != null) { | 
 |  |  |                 device.setSipTransactionInfo(deviceInRedis.getSipTransactionInfo()); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         // 第一次上线 | 
 |  |  |         if (device.getCreateTime() == null) { | 
 |  |  |         // 第一次上线 或则设备之前是离线状态--进行通道同步和设备信息查询 | 
 |  |  |         if (deviceInDb == null) { | 
 |  |  |             device.setOnLine(true); | 
 |  |  |             device.setCreateTime(now); | 
 |  |  |             device.setUpdateTime(now); | 
 |  |  |             logger.info("[设备上线,首次注册]: {},查询设备信息以及通道信息", device.getDeviceId()); | 
 |  |  |             deviceMapper.add(device); | 
 |  |  |             redisCatchStorage.updateDevice(device); | 
 |  |  |             commander.deviceInfoQuery(device); | 
 |  |  |             try { | 
 |  |  |                 commander.deviceInfoQuery(device); | 
 |  |  |             } catch (InvalidArgumentException | SipException | ParseException e) { | 
 |  |  |                 logger.error("[命令发送失败] 查询设备信息: {}", e.getMessage()); | 
 |  |  |             } | 
 |  |  |             sync(device); | 
 |  |  |         }else { | 
 |  |  |             deviceMapper.update(device); | 
 |  |  |             redisCatchStorage.updateDevice(device); | 
 |  |  |             if(!device.isOnLine()){ | 
 |  |  |                 device.setOnLine(true); | 
 |  |  |                 device.setCreateTime(now); | 
 |  |  |                 deviceMapper.update(device); | 
 |  |  |                 redisCatchStorage.updateDevice(device); | 
 |  |  |                 if (userSetting.getSyncChannelOnDeviceOnline()) { | 
 |  |  |                     logger.info("[设备上线,离线状态下重新注册]: {},查询设备信息以及通道信息", device.getDeviceId()); | 
 |  |  |                     try { | 
 |  |  |                         commander.deviceInfoQuery(device); | 
 |  |  |                     } catch (InvalidArgumentException | SipException | ParseException e) { | 
 |  |  |                         logger.error("[命令发送失败] 查询设备信息: {}", e.getMessage()); | 
 |  |  |                     } | 
 |  |  |                     sync(device); | 
 |  |  |                     // TODO 如果设备下的通道级联到了其他平台,那么需要发送事件或者notify给上级平台 | 
 |  |  |                 } | 
 |  |  |                 // 上线添加订阅 | 
 |  |  |                 if (device.getSubscribeCycleForCatalog() > 0) { | 
 |  |  |                     // 查询在线设备那些开启了订阅,为设备开启定时的目录订阅 | 
 |  |  |                     addCatalogSubscribe(device); | 
 |  |  |                 } | 
 |  |  |                 if (device.getSubscribeCycleForMobilePosition() > 0) { | 
 |  |  |                     addMobilePositionSubscribe(device); | 
 |  |  |                 } | 
 |  |  |                 if (userSetting.getDeviceStatusNotify()) { | 
 |  |  |                     // 发送redis消息 | 
 |  |  |                     redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), null, true); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |             }else { | 
 |  |  |                 if (deviceChannelMapper.queryAllChannels(device.getDeviceId()).size() == 0) { | 
 |  |  |                     logger.info("[设备上线]: {},通道数为0,查询通道信息", device.getDeviceId()); | 
 |  |  |                     sync(device); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 deviceMapper.update(device); | 
 |  |  |                 redisCatchStorage.updateDevice(device); | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         // 上线添加订阅 | 
 |  |  |         if (device.getSubscribeCycleForCatalog() > 0) { | 
 |  |  |             // 查询在线设备那些开启了订阅,为设备开启定时的目录订阅 | 
 |  |  |             addCatalogSubscribe(device); | 
 |  |  |         } | 
 |  |  |         if (device.getSubscribeCycleForMobilePosition() > 0) { | 
 |  |  |             addMobilePositionSubscribe(device); | 
 |  |  |         } | 
 |  |  |         // 刷新过期任务 | 
 |  |  |         String registerExpireTaskKey = registerExpireTaskKeyPrefix + device.getDeviceId(); | 
 |  |  |         dynamicTask.startDelay(registerExpireTaskKey, ()-> offline(device.getDeviceId()), device.getExpires() * 1000); | 
 |  |  |         String registerExpireTaskKey = VideoManagerConstants.REGISTER_EXPIRE_TASK_KEY_PREFIX + device.getDeviceId(); | 
 |  |  |         // 如果第一次注册那么必须在60 * 3时间内收到一个心跳,否则设备离线 | 
 |  |  |         dynamicTask.startDelay(registerExpireTaskKey, ()-> offline(device.getDeviceId(), "首次注册后未能收到心跳"), device.getKeepaliveIntervalTime() * 1000 * 3); | 
 |  |  |  | 
 |  |  | // | 
 |  |  | //        try { | 
 |  |  | //            cmder.alarmSubscribe(device, 600, "0", "4", "0", "2023-7-27T00:00:00", "2023-7-28T00:00:00"); | 
 |  |  | //        } catch (InvalidArgumentException e) { | 
 |  |  | //            throw new RuntimeException(e); | 
 |  |  | //        } catch (SipException e) { | 
 |  |  | //            throw new RuntimeException(e); | 
 |  |  | //        } catch (ParseException e) { | 
 |  |  | //            throw new RuntimeException(e); | 
 |  |  | //        } | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void offline(String deviceId) { | 
 |  |  |     public void offline(String deviceId, String reason) { | 
 |  |  |         logger.warn("[设备离线],{}, device:{}", reason, deviceId); | 
 |  |  |         Device device = deviceMapper.getDeviceByDeviceId(deviceId); | 
 |  |  |         if (device == null) { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         String registerExpireTaskKey = registerExpireTaskKeyPrefix + deviceId; | 
 |  |  |         String registerExpireTaskKey = VideoManagerConstants.REGISTER_EXPIRE_TASK_KEY_PREFIX + deviceId; | 
 |  |  |         dynamicTask.stop(registerExpireTaskKey); | 
 |  |  |         device.setOnline(0); | 
 |  |  |         if (device.isOnLine()) { | 
 |  |  |             if (userSetting.getDeviceStatusNotify()) { | 
 |  |  |                 // 发送redis消息 | 
 |  |  |                 redisCatchStorage.sendDeviceOrChannelStatus(device.getDeviceId(), null, false); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         device.setOnLine(false); | 
 |  |  |         redisCatchStorage.updateDevice(device); | 
 |  |  |         deviceMapper.update(device); | 
 |  |  |         //进行通道离线 | 
 |  |  | //        deviceChannelMapper.offlineByDeviceId(deviceId); | 
 |  |  |         // 离线释放所有ssrc | 
 |  |  |         List<SsrcTransaction> ssrcTransactions = streamSession.getSsrcTransactionForAll(deviceId, null, null, null); | 
 |  |  |         if (ssrcTransactions != null && ssrcTransactions.size() > 0) { | 
 |  |  |             for (SsrcTransaction ssrcTransaction : ssrcTransactions) { | 
 |  |  |                 mediaServerService.releaseSsrc(ssrcTransaction.getMediaServerId(), ssrcTransaction.getSsrc()); | 
 |  |  |                 mediaServerService.closeRTPServer(deviceId, ssrcTransaction.getChannelId(), ssrcTransaction.getStream()); | 
 |  |  |                 streamSession.remove(deviceId, ssrcTransaction.getChannelId(), ssrcTransaction.getStream()); | 
 |  |  |                 mediaServerService.closeRTPServer(ssrcTransaction.getMediaServerId(), ssrcTransaction.getStream()); | 
 |  |  |                 streamSession.removeByCallId(deviceId, ssrcTransaction.getChannelId(), ssrcTransaction.getCallId()); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         // 移除订阅 | 
 |  |  |         removeCatalogSubscribe(device); | 
 |  |  |         removeMobilePositionSubscribe(device); | 
 |  |  |         removeCatalogSubscribe(device, null); | 
 |  |  |         removeMobilePositionSubscribe(device, null); | 
 |  |  |  | 
 |  |  |         List<AudioBroadcastCatch> audioBroadcastCatches = audioBroadcastManager.get(deviceId); | 
 |  |  |         if (audioBroadcastCatches.size() > 0) { | 
 |  |  |             for (AudioBroadcastCatch audioBroadcastCatch : audioBroadcastCatches) { | 
 |  |  |  | 
 |  |  |                 SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(deviceId, audioBroadcastCatch.getChannelId(), null, null); | 
 |  |  |                 if (sendRtpItem != null) { | 
 |  |  |                     redisCatchStorage.deleteSendRTPServer(deviceId, sendRtpItem.getChannelId(), null, null); | 
 |  |  |                     MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId()); | 
 |  |  |                     Map<String, Object> param = new HashMap<>(); | 
 |  |  |                     param.put("vhost", "__defaultVhost__"); | 
 |  |  |                     param.put("app", sendRtpItem.getApp()); | 
 |  |  |                     param.put("stream", sendRtpItem.getStream()); | 
 |  |  |                     zlmresTfulUtils.stopSendRtp(mediaInfo, param); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 audioBroadcastManager.del(deviceId, audioBroadcastCatch.getChannelId()); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  | 
 |  |  |         logger.info("[添加目录订阅] 设备{}", device.getDeviceId()); | 
 |  |  |         // 添加目录订阅 | 
 |  |  |         CatalogSubscribeTask catalogSubscribeTask = new CatalogSubscribeTask(device, sipCommander, dynamicTask); | 
 |  |  |         // 提前开始刷新订阅 | 
 |  |  |         // 刷新订阅 | 
 |  |  |         int subscribeCycleForCatalog = Math.max(device.getSubscribeCycleForCatalog(),30); | 
 |  |  |         // 设置最小值为30 | 
 |  |  |         dynamicTask.startCron(device.getDeviceId() + "catalog", catalogSubscribeTask, (subscribeCycleForCatalog -1) * 1000); | 
 |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public boolean removeCatalogSubscribe(Device device) { | 
 |  |  |     public boolean removeCatalogSubscribe(Device device, CommonCallback<Boolean> callback) { | 
 |  |  |         if (device == null || device.getSubscribeCycleForCatalog() < 0) { | 
 |  |  |             return false; | 
 |  |  |         } | 
 |  |  |         logger.info("[移除目录订阅]: {}", device.getDeviceId()); | 
 |  |  |         String taskKey = device.getDeviceId() + "catalog"; | 
 |  |  |         if (device.getOnline() == 1) { | 
 |  |  |         if (device.isOnLine()) { | 
 |  |  |             Runnable runnable = dynamicTask.get(taskKey); | 
 |  |  |             if (runnable instanceof ISubscribeTask) { | 
 |  |  |                 ISubscribeTask subscribeTask = (ISubscribeTask) runnable; | 
 |  |  |                 subscribeTask.stop(); | 
 |  |  |                 subscribeTask.stop(callback); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         dynamicTask.stop(taskKey); | 
 |  |  | 
 |  |  |         MobilePositionSubscribeTask mobilePositionSubscribeTask = new MobilePositionSubscribeTask(device, sipCommander, dynamicTask); | 
 |  |  |         // 设置最小值为30 | 
 |  |  |         int subscribeCycleForCatalog = Math.max(device.getSubscribeCycleForMobilePosition(),30); | 
 |  |  |         // 提前开始刷新订阅 | 
 |  |  |         dynamicTask.startCron(device.getDeviceId() + "mobile_position" , mobilePositionSubscribeTask, (subscribeCycleForCatalog -1 ) * 1000); | 
 |  |  |         // 刷新订阅 | 
 |  |  |         dynamicTask.startCron(device.getDeviceId() + "mobile_position" , mobilePositionSubscribeTask, subscribeCycleForCatalog * 1000); | 
 |  |  |         return true; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public boolean removeMobilePositionSubscribe(Device device) { | 
 |  |  |     public boolean removeMobilePositionSubscribe(Device device, CommonCallback<Boolean> callback) { | 
 |  |  |         if (device == null || device.getSubscribeCycleForCatalog() < 0) { | 
 |  |  |             return false; | 
 |  |  |         } | 
 |  |  |         logger.info("[移除移动位置订阅]: {}", device.getDeviceId()); | 
 |  |  |         String taskKey = device.getDeviceId() + "mobile_position"; | 
 |  |  |         if (device.getOnline() == 1) { | 
 |  |  |         if (device.isOnLine()) { | 
 |  |  |             Runnable runnable = dynamicTask.get(taskKey); | 
 |  |  |             if (runnable instanceof ISubscribeTask) { | 
 |  |  |                 ISubscribeTask subscribeTask = (ISubscribeTask) runnable; | 
 |  |  |                 subscribeTask.stop(); | 
 |  |  |                 subscribeTask.stop(callback); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         dynamicTask.stop(taskKey); | 
 |  |  | 
 |  |  |         } | 
 |  |  |         int sn = (int)((Math.random()*9+1)*100000); | 
 |  |  |         catalogResponseMessageHandler.setChannelSyncReady(device, sn); | 
 |  |  |         sipCommander.catalogQuery(device, sn, event -> { | 
 |  |  |             String errorMsg = String.format("同步通道失败,错误码: %s, %s", event.statusCode, event.msg); | 
 |  |  |         try { | 
 |  |  |             sipCommander.catalogQuery(device, sn, event -> { | 
 |  |  |                 String errorMsg = String.format("同步通道失败,错误码: %s, %s", event.statusCode, event.msg); | 
 |  |  |                 catalogResponseMessageHandler.setChannelSyncEnd(device.getDeviceId(), errorMsg); | 
 |  |  |             }); | 
 |  |  |         } catch (SipException | InvalidArgumentException | ParseException e) { | 
 |  |  |             logger.error("[同步通道], 信令发送失败:{}", e.getMessage() ); | 
 |  |  |             String errorMsg = String.format("同步通道失败,信令发送失败: %s", e.getMessage()); | 
 |  |  |             catalogResponseMessageHandler.setChannelSyncEnd(device.getDeviceId(), errorMsg); | 
 |  |  |         }); | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public Device queryDevice(String deviceId) { | 
 |  |  |         return deviceMapper.getDeviceByDeviceId(deviceId); | 
 |  |  |     public Device getDevice(String deviceId) { | 
 |  |  |         Device device = redisCatchStorage.getDevice(deviceId); | 
 |  |  |         if (device == null) { | 
 |  |  |             device = deviceMapper.getDeviceByDeviceId(deviceId); | 
 |  |  |             if (device != null) { | 
 |  |  |                 redisCatchStorage.updateDevice(device); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         return device; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void checkDeviceStatus(Device device) { | 
 |  |  |         if (device == null || device.getOnline() == 0) { | 
 |  |  |         if (device == null || !device.isOnLine()) { | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         sipCommander.deviceStatusQuery(device, null); | 
 |  |  |         try { | 
 |  |  |             sipCommander.deviceStatusQuery(device, null); | 
 |  |  |         } catch (InvalidArgumentException | SipException | ParseException e) { | 
 |  |  |             logger.error("[命令发送失败] 设备状态查询: {}", e.getMessage()); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |     @Override | 
 |  |  |     public void updateDevice(Device device) { | 
 |  |  |  | 
 |  |  |         Device deviceInStore = deviceMapper.getDeviceByDeviceId(device.getDeviceId()); | 
 |  |  |         if (deviceInStore == null) { | 
 |  |  |             logger.warn("更新设备时未找到设备信息"); | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         if (!StringUtils.isEmpty(device.getName())) { | 
 |  |  |             deviceInStore.setName(device.getName()); | 
 |  |  |         } | 
 |  |  |         if (!StringUtils.isEmpty(device.getCharset())) { | 
 |  |  |             deviceInStore.setCharset(device.getCharset()); | 
 |  |  |         } | 
 |  |  |         if (!StringUtils.isEmpty(device.getMediaServerId())) { | 
 |  |  |             deviceInStore.setMediaServerId(device.getMediaServerId()); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         //  目录订阅相关的信息 | 
 |  |  |         if (device.getSubscribeCycleForCatalog() > 0) { | 
 |  |  |             if (deviceInStore.getSubscribeCycleForCatalog() == 0 || deviceInStore.getSubscribeCycleForCatalog() != device.getSubscribeCycleForCatalog()) { | 
 |  |  |                 deviceInStore.setSubscribeCycleForCatalog(device.getSubscribeCycleForCatalog()); | 
 |  |  |                 // 开启订阅 | 
 |  |  |                 addCatalogSubscribe(deviceInStore); | 
 |  |  |             } | 
 |  |  |         }else if (device.getSubscribeCycleForCatalog() == 0) { | 
 |  |  |             if (deviceInStore.getSubscribeCycleForCatalog() != 0) { | 
 |  |  |                 deviceInStore.setSubscribeCycleForCatalog(device.getSubscribeCycleForCatalog()); | 
 |  |  |                 // 取消订阅 | 
 |  |  |                 removeCatalogSubscribe(deviceInStore); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         // 移动位置订阅相关的信息 | 
 |  |  |         if (device.getSubscribeCycleForMobilePosition() > 0) { | 
 |  |  |             if (deviceInStore.getSubscribeCycleForMobilePosition() == 0 || deviceInStore.getSubscribeCycleForMobilePosition() != device.getSubscribeCycleForMobilePosition()) { | 
 |  |  |                 deviceInStore.setMobilePositionSubmissionInterval(device.getMobilePositionSubmissionInterval()); | 
 |  |  |                 deviceInStore.setSubscribeCycleForMobilePosition(device.getSubscribeCycleForMobilePosition()); | 
 |  |  |                 // 开启订阅 | 
 |  |  |                 addMobilePositionSubscribe(deviceInStore); | 
 |  |  |             } | 
 |  |  |         }else if (device.getSubscribeCycleForMobilePosition() == 0) { | 
 |  |  |             if (deviceInStore.getSubscribeCycleForMobilePosition() != 0) { | 
 |  |  |                 // 取消订阅 | 
 |  |  |                 removeMobilePositionSubscribe(deviceInStore); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         // 坐标系变化,需要重新计算GCJ02坐标和WGS84坐标 | 
 |  |  |         if (!deviceInStore.getGeoCoordSys().equals(device.getGeoCoordSys())) { | 
 |  |  |             updateDeviceChannelGeoCoordSys(device); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         String now = DateUtil.getNow(); | 
 |  |  |         device.setUpdateTime(now); | 
 |  |  |         device.setCharset(device.getCharset().toUpperCase()); | 
 |  |  |         device.setUpdateTime(DateUtil.getNow()); | 
 |  |  |         if (deviceMapper.update(device) > 0) { | 
 |  |  |             redisCatchStorage.updateDevice(device); | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |     } | 
 |  |  |  | 
 |  |  | 
 |  |  |         if (device == null) { | 
 |  |  |             return null; | 
 |  |  |         } | 
 |  |  |         if (parentId == null || parentId.equals(deviceId)) { | 
 |  |  |             // 字根节点开始查询 | 
 |  |  |             List<DeviceChannel> rootNodes = getRootNodes(deviceId, TreeType.CIVIL_CODE.equals(device.getTreeType()), true, !onlyCatalog); | 
 |  |  |             return transportChannelsToTree(rootNodes, ""); | 
 |  |  |         if (ObjectUtils.isEmpty(parentId) ) { | 
 |  |  |             parentId = deviceId; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (TreeType.CIVIL_CODE.equals(device.getTreeType())) { | 
 |  |  |             if (parentId.length()%2 != 0) { | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             // 使用行政区划展示树 | 
 |  |  |             if (parentId.length() > 10) { | 
 |  |  |                 // TODO 可能是行政区划与业务分组混杂的情形 | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             if (parentId.length() == 10 ) { | 
 |  |  |                 if (onlyCatalog) { | 
 |  |  |                     return null; | 
 |  |  |                 } | 
 |  |  |                 // parentId为行业编码, 其下不会再有行政区划 | 
 |  |  |                 List<DeviceChannel> channels = deviceChannelMapper.getChannelsByCivilCode(deviceId, parentId); | 
 |  |  |                 List<BaseTree<DeviceChannel>> trees = transportChannelsToTree(channels, parentId); | 
 |  |  |                 return trees; | 
 |  |  |             } | 
 |  |  |             // 查询其下的行政区划和摄像机 | 
 |  |  |             List<DeviceChannel> channelsForCivilCode = deviceChannelMapper.getChannelsWithCivilCodeAndLength(deviceId, parentId, parentId.length() + 2); | 
 |  |  |             if (!onlyCatalog) { | 
 |  |  |                 List<DeviceChannel> channels = deviceChannelMapper.getChannelsByCivilCode(deviceId, parentId); | 
 |  |  |                 channelsForCivilCode.addAll(channels); | 
 |  |  |             } | 
 |  |  |             List<BaseTree<DeviceChannel>> trees = transportChannelsToTree(channelsForCivilCode, parentId); | 
 |  |  |             return trees; | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |         // 使用业务分组展示树 | 
 |  |  |         if (TreeType.BUSINESS_GROUP.equals(device.getTreeType())) { | 
 |  |  |             if (parentId.length() < 14 ) { | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             List<DeviceChannel> deviceChannels = deviceChannelMapper.queryChannels(deviceId, parentId, null, null, null); | 
 |  |  |             List<BaseTree<DeviceChannel>> trees = transportChannelsToTree(deviceChannels, parentId); | 
 |  |  |             return trees; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         return null; | 
 |  |  |         List<DeviceChannel> rootNodes = deviceChannelMapper.getSubChannelsByDeviceId(deviceId, parentId, onlyCatalog); | 
 |  |  |         return transportChannelsToTree(rootNodes, ""); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  | 
 |  |  |         if (device == null) { | 
 |  |  |             return null; | 
 |  |  |         } | 
 |  |  |         if (parentId == null || parentId.equals(deviceId)) { | 
 |  |  |             // 字根节点开始查询 | 
 |  |  |             List<DeviceChannel> rootNodes = getRootNodes(deviceId, TreeType.CIVIL_CODE.equals(device.getTreeType()), false, true); | 
 |  |  |             return rootNodes; | 
 |  |  |         if (ObjectUtils.isEmpty(parentId) || parentId.equals(deviceId)) { | 
 |  |  |             return deviceChannelMapper.getSubChannelsByDeviceId(deviceId, null, false); | 
 |  |  |         }else { | 
 |  |  |             return deviceChannelMapper.getSubChannelsByDeviceId(deviceId, parentId, false); | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         if (TreeType.CIVIL_CODE.equals(device.getTreeType())) { | 
 |  |  |             if (parentId.length()%2 != 0) { | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             // 使用行政区划展示树 | 
 |  |  |             if (parentId.length() > 10) { | 
 |  |  |                 // TODO 可能是行政区划与业务分组混杂的情形 | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |  | 
 |  |  |             if (parentId.length() == 10 ) { | 
 |  |  |                 // parentId为行业编码, 其下不会再有行政区划 | 
 |  |  |                 List<DeviceChannel> channels = deviceChannelMapper.getChannelsByCivilCode(deviceId, parentId); | 
 |  |  |                 return channels; | 
 |  |  |             } | 
 |  |  |             // 查询其下的行政区划和摄像机 | 
 |  |  |             List<DeviceChannel> channels = deviceChannelMapper.getChannelsByCivilCode(deviceId, parentId); | 
 |  |  |             return channels; | 
 |  |  |  | 
 |  |  |         } | 
 |  |  |         // 使用业务分组展示树 | 
 |  |  |         if (TreeType.BUSINESS_GROUP.equals(device.getTreeType())) { | 
 |  |  |             if (parentId.length() < 14 ) { | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             List<DeviceChannel> deviceChannels = deviceChannelMapper.queryChannels(deviceId, parentId, null, null, null); | 
 |  |  |             return deviceChannels; | 
 |  |  |         } | 
 |  |  |  | 
 |  |  |         return null; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private List<BaseTree<DeviceChannel>> transportChannelsToTree(List<DeviceChannel> channels, String parentId) { | 
 |  |  | 
 |  |  |             node.setPid(parentId); | 
 |  |  |             node.setBasicData(channel); | 
 |  |  |             node.setParent(false); | 
 |  |  |             if (channel.getChannelId().length() > 8) { | 
 |  |  |                 String gbCodeType = channel.getChannelId().substring(10, 13); | 
 |  |  |                 node.setParent(gbCodeType.equals(ChannelIdType.BUSINESS_GROUP) || gbCodeType.equals(ChannelIdType.VIRTUAL_ORGANIZATION) ); | 
 |  |  |             }else { | 
 |  |  |             if (channel.getChannelId().length() <= 8) { | 
 |  |  |                 node.setParent(true); | 
 |  |  |             }else { | 
 |  |  |                 if (channel.getChannelId().length() != 20) { | 
 |  |  |                     node.setParent(channel.getParental() == 1); | 
 |  |  |                 }else { | 
 |  |  |                     try { | 
 |  |  |                         int type = Integer.parseInt(channel.getChannelId().substring(10, 13)); | 
 |  |  |                         if (type == 215 || type == 216 || type == 200) { | 
 |  |  |                             node.setParent(true); | 
 |  |  |                         } | 
 |  |  |                     }catch (NumberFormatException e) { | 
 |  |  |                         node.setParent(false); | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |             treeNotes.add(node); | 
 |  |  |         } | 
 |  |  | 
 |  |  |         return treeNotes; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     private List<DeviceChannel> getRootNodes(String deviceId, boolean isCivilCode, boolean haveCatalog, boolean haveChannel) { | 
 |  |  |         if (!haveCatalog && !haveChannel) { | 
 |  |  |             return null; | 
 |  |  |     @Override | 
 |  |  |     public boolean isExist(String deviceId) { | 
 |  |  |         return deviceMapper.getDeviceByDeviceId(deviceId) != null; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void addDevice(Device device) { | 
 |  |  |         device.setOnLine(false); | 
 |  |  |         device.setCreateTime(DateUtil.getNow()); | 
 |  |  |         device.setUpdateTime(DateUtil.getNow()); | 
 |  |  |         deviceMapper.addCustomDevice(device); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public void updateCustomDevice(Device device) { | 
 |  |  |         Device deviceInStore = deviceMapper.getDeviceByDeviceId(device.getDeviceId()); | 
 |  |  |         if (deviceInStore == null) { | 
 |  |  |             logger.warn("更新设备时未找到设备信息"); | 
 |  |  |             return; | 
 |  |  |         } | 
 |  |  |         List<DeviceChannel> result = new ArrayList<>(); | 
 |  |  |         if (isCivilCode) { | 
 |  |  |             // 使用行政区划 | 
 |  |  |             Integer length= deviceChannelMapper.getChannelMinLength(deviceId); | 
 |  |  |             if (length == null) { | 
 |  |  |                 return null; | 
 |  |  |             } | 
 |  |  |             if (length <= 10) { | 
 |  |  |                 if (haveCatalog) { | 
 |  |  |                     List<DeviceChannel> provinceNode = deviceChannelMapper.getChannelsWithCivilCodeAndLength(deviceId, null, length); | 
 |  |  |                     if (provinceNode != null && provinceNode.size() > 0) { | 
 |  |  |                         result.addAll(provinceNode); | 
 |  |  |                     } | 
 |  |  |  | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getName())) { | 
 |  |  |             deviceInStore.setName(device.getName()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getCharset())) { | 
 |  |  |             deviceInStore.setCharset(device.getCharset()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getMediaServerId())) { | 
 |  |  |             deviceInStore.setMediaServerId(device.getMediaServerId()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getCharset())) { | 
 |  |  |             deviceInStore.setCharset(device.getCharset()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getSdpIp())) { | 
 |  |  |             deviceInStore.setSdpIp(device.getSdpIp()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getPassword())) { | 
 |  |  |             deviceInStore.setPassword(device.getPassword()); | 
 |  |  |         } | 
 |  |  |         if (!ObjectUtils.isEmpty(device.getStreamMode())) { | 
 |  |  |             deviceInStore.setStreamMode(device.getStreamMode()); | 
 |  |  |         } | 
 |  |  |         //  目录订阅相关的信息 | 
 |  |  |         if (deviceInStore.getSubscribeCycleForCatalog() != device.getSubscribeCycleForCatalog()) { | 
 |  |  |             if (device.getSubscribeCycleForCatalog() > 0) { | 
 |  |  |                 // 若已开启订阅,但订阅周期不同,则先取消 | 
 |  |  |                 if (deviceInStore.getSubscribeCycleForCatalog() != 0) { | 
 |  |  |                     removeCatalogSubscribe(deviceInStore, result->{ | 
 |  |  |                         // 开启订阅 | 
 |  |  |                         deviceInStore.setSubscribeCycleForCatalog(device.getSubscribeCycleForCatalog()); | 
 |  |  |                         addCatalogSubscribe(deviceInStore); | 
 |  |  |                         // 因为是异步执行,需要在这里更新下数据 | 
 |  |  |                         deviceMapper.updateCustom(deviceInStore); | 
 |  |  |                         redisCatchStorage.updateDevice(deviceInStore); | 
 |  |  |                     }); | 
 |  |  |                 }else { | 
 |  |  |                     // 开启订阅 | 
 |  |  |                     deviceInStore.setSubscribeCycleForCatalog(device.getSubscribeCycleForCatalog()); | 
 |  |  |                     addCatalogSubscribe(deviceInStore); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |                 if (haveChannel) { | 
 |  |  |                     // 查询那些civilCode不在通道中的不规范通道,放置在根目录 | 
 |  |  |                     List<DeviceChannel> nonstandardNode = deviceChannelMapper.getChannelWithoutCiviCode(deviceId); | 
 |  |  |                     if (nonstandardNode != null && nonstandardNode.size() > 0) { | 
 |  |  |                         result.addAll(nonstandardNode); | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             }else { | 
 |  |  |                 if (haveChannel) { | 
 |  |  |                     List<DeviceChannel> deviceChannels = deviceChannelMapper.queryChannels(deviceId, null, null, null, null); | 
 |  |  |                     if (deviceChannels != null && deviceChannels.size() > 0) { | 
 |  |  |                         result.addAll(deviceChannels); | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             }else if (device.getSubscribeCycleForCatalog() == 0) { | 
 |  |  |                 // 取消订阅 | 
 |  |  |                 deviceInStore.setSubscribeCycleForCatalog(0); | 
 |  |  |                 removeCatalogSubscribe(deviceInStore, null); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         // 移动位置订阅相关的信息 | 
 |  |  |         if (deviceInStore.getSubscribeCycleForMobilePosition() != device.getSubscribeCycleForMobilePosition()) { | 
 |  |  |             if (device.getSubscribeCycleForMobilePosition() > 0) { | 
 |  |  |                 // 若已开启订阅,但订阅周期不同,则先取消 | 
 |  |  |                 if (deviceInStore.getSubscribeCycleForMobilePosition() != 0) { | 
 |  |  |                     removeMobilePositionSubscribe(deviceInStore, result->{ | 
 |  |  |                         // 开启订阅 | 
 |  |  |                         deviceInStore.setSubscribeCycleForMobilePosition(device.getSubscribeCycleForMobilePosition()); | 
 |  |  |                         addMobilePositionSubscribe(deviceInStore); | 
 |  |  |                         // 因为是异步执行,需要在这里更新下数据 | 
 |  |  |                         deviceMapper.updateCustom(deviceInStore); | 
 |  |  |                         redisCatchStorage.updateDevice(deviceInStore); | 
 |  |  |                     }); | 
 |  |  |                 }else { | 
 |  |  |                     // 开启订阅 | 
 |  |  |                     deviceInStore.setSubscribeCycleForMobilePosition(device.getSubscribeCycleForMobilePosition()); | 
 |  |  |                     addMobilePositionSubscribe(deviceInStore); | 
 |  |  |                 } | 
 |  |  |  | 
 |  |  |             }else if (device.getSubscribeCycleForMobilePosition() == 0) { | 
 |  |  |                 // 取消订阅 | 
 |  |  |                 deviceInStore.setSubscribeCycleForCatalog(0); | 
 |  |  |                 removeCatalogSubscribe(deviceInStore, null); | 
 |  |  |             } | 
 |  |  |         } | 
 |  |  |         if (deviceInStore.getGeoCoordSys() != null) { | 
 |  |  |             // 坐标系变化,需要重新计算GCJ02坐标和WGS84坐标 | 
 |  |  |             if (!deviceInStore.getGeoCoordSys().equals(device.getGeoCoordSys())) { | 
 |  |  |                 deviceInStore.setGeoCoordSys(device.getGeoCoordSys()); | 
 |  |  |                 updateDeviceChannelGeoCoordSys(deviceInStore); | 
 |  |  |             } | 
 |  |  |         }else { | 
 |  |  |             // 使用业务分组+虚拟组织 | 
 |  |  |             deviceInStore.setGeoCoordSys("WGS84"); | 
 |  |  |         } | 
 |  |  |         if (device.getCharset() == null) { | 
 |  |  |             deviceInStore.setCharset("GB2312"); | 
 |  |  |         } | 
 |  |  |         //SSRC校验 | 
 |  |  |         deviceInStore.setSsrcCheck(device.isSsrcCheck()); | 
 |  |  |         //作为消息通道 | 
 |  |  |         deviceInStore.setAsMessageChannel(device.isAsMessageChannel()); | 
 |  |  |  | 
 |  |  |             // 只获取业务分组 | 
 |  |  |             List<DeviceChannel> deviceChannels = deviceChannelMapper.getBusinessGroups(deviceId, ChannelIdType.BUSINESS_GROUP); | 
 |  |  |             if (deviceChannels != null && deviceChannels.size() > 0) { | 
 |  |  |                 result.addAll(deviceChannels); | 
 |  |  |         deviceMapper.updateCustom(deviceInStore); | 
 |  |  |         redisCatchStorage.updateDevice(deviceInStore); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public boolean delete(String deviceId) { | 
 |  |  |         TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(transactionDefinition); | 
 |  |  |         boolean result = false; | 
 |  |  |         try { | 
 |  |  |             platformChannelMapper.delChannelForDeviceId(deviceId); | 
 |  |  |             deviceChannelMapper.cleanChannelsByDeviceId(deviceId); | 
 |  |  |             if ( deviceMapper.del(deviceId) < 0 ) { | 
 |  |  |                 //事务回滚 | 
 |  |  |                 dataSourceTransactionManager.rollback(transactionStatus); | 
 |  |  |             } | 
 |  |  |             result = true; | 
 |  |  |             dataSourceTransactionManager.commit(transactionStatus);     //手动提交 | 
 |  |  |         }catch (Exception e) { | 
 |  |  |             dataSourceTransactionManager.rollback(transactionStatus); | 
 |  |  |         } | 
 |  |  |         if (result) { | 
 |  |  |             redisCatchStorage.removeDevice(deviceId); | 
 |  |  |         } | 
 |  |  |         return result; | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public ResourceBaseInfo getOverview() { | 
 |  |  |         List<Device> onlineDevices = deviceMapper.getOnlineDevices(); | 
 |  |  |         List<Device> all = deviceMapper.getAll(); | 
 |  |  |         return new ResourceBaseInfo(all.size(), onlineDevices.size()); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |     @Override | 
 |  |  |     public List<Device> getAll() { | 
 |  |  |         return deviceMapper.getAll(); | 
 |  |  |     } | 
 |  |  |  | 
 |  |  |  | 
 |  |  | } |