|  |  |  | 
|---|
|  |  |  | package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.notify.cmd; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import com.alibaba.fastjson.JSONObject; | 
|---|
|  |  |  | import com.alibaba.fastjson2.JSONObject; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.conf.UserSetting; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.bean.*; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent; | 
|---|
|  |  |  | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.storager.IVideoManagerStorage; | 
|---|
|  |  |  | import com.genersoft.iot.vmp.utils.DateUtil; | 
|---|
|  |  |  | import gov.nist.javax.sip.message.SIPRequest; | 
|---|
|  |  |  | import org.dom4j.DocumentException; | 
|---|
|  |  |  | import org.dom4j.Element; | 
|---|
|  |  |  | import org.slf4j.Logger; | 
|---|
|  |  |  | 
|---|
|  |  |  | import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; | 
|---|
|  |  |  | import org.springframework.stereotype.Component; | 
|---|
|  |  |  | import org.springframework.util.ObjectUtils; | 
|---|
|  |  |  | import org.springframework.util.StringUtils; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | import javax.sip.InvalidArgumentException; | 
|---|
|  |  |  | import javax.sip.RequestEvent; | 
|---|
|  |  |  | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | private IDeviceChannelService deviceChannelService; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private boolean taskQueueHandlerRun = false; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private final ConcurrentLinkedQueue<SipMsgInfo> taskQueue = new ConcurrentLinkedQueue<>(); | 
|---|
|  |  |  | private ConcurrentLinkedQueue<SipMsgInfo> taskQueue = new ConcurrentLinkedQueue<>(); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Qualifier("taskExecutor") | 
|---|
|  |  |  | @Autowired | 
|---|
|  |  |  | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void handForDevice(RequestEvent evt, Device device, Element rootElement) { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | boolean isEmpty = taskQueue.isEmpty(); | 
|---|
|  |  |  | taskQueue.offer(new SipMsgInfo(evt, device, rootElement)); | 
|---|
|  |  |  | if (!taskQueueHandlerRun) { | 
|---|
|  |  |  | taskQueueHandlerRun = true; | 
|---|
|  |  |  | // 回复200 OK | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | responseAck((SIPRequest) evt.getRequest(), Response.OK); | 
|---|
|  |  |  | } catch (SipException | InvalidArgumentException | ParseException e) { | 
|---|
|  |  |  | logger.error("[命令发送失败] 移动位置通知回复: {}", e.getMessage()); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if (isEmpty) { | 
|---|
|  |  |  | taskExecutor.execute(() -> { | 
|---|
|  |  |  | while (!taskQueue.isEmpty()) { | 
|---|
|  |  |  | SipMsgInfo sipMsgInfo = taskQueue.poll(); | 
|---|
|  |  |  | try { | 
|---|
|  |  |  | Element rootElementAfterCharset = getRootElement(sipMsgInfo.getEvt(), sipMsgInfo.getDevice().getCharset()); | 
|---|
|  |  |  | if (rootElementAfterCharset == null) { | 
|---|
|  |  |  | logger.warn("[ 移动设备位置数据通知 ] content cannot be null, {}", sipMsgInfo.getEvt().getRequest()); | 
|---|
|  |  |  | responseAck(getServerTransaction(sipMsgInfo.getEvt()), Response.BAD_REQUEST); | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | logger.warn("[移动位置通知] {}处理失败,未识别到信息体", device.getDeviceId()); | 
|---|
|  |  |  | continue; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | MobilePosition mobilePosition = new MobilePosition(); | 
|---|
|  |  |  | mobilePosition.setCreateTime(DateUtil.getNow()); | 
|---|
|  |  |  | 
|---|
|  |  |  | storager.insertMobilePosition(mobilePosition); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | storager.updateChannelPosition(deviceChannel); | 
|---|
|  |  |  | //回复 200 OK | 
|---|
|  |  |  | responseAck(getServerTransaction(sipMsgInfo.getEvt()), Response.OK); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | // 发送redis消息。 通知位置信息的变化 | 
|---|
|  |  |  | JSONObject jsonObject = new JSONObject(); | 
|---|
|  |  |  | 
|---|
|  |  |  | jsonObject.put("speed", mobilePosition.getSpeed()); | 
|---|
|  |  |  | redisCatchStorage.sendMobilePositionMsg(jsonObject); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) { | 
|---|
|  |  |  | e.printStackTrace(); | 
|---|
|  |  |  | } catch (DocumentException e) { | 
|---|
|  |  |  | logger.error("未处理的异常 ", e); | 
|---|
|  |  |  | } catch (Exception e) { | 
|---|
|  |  |  | logger.warn("[移动位置通知] 发现未处理的异常, \r\n{}", evt.getRequest()); | 
|---|
|  |  |  | logger.error("[移动位置通知] 异常内容: ", e); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | taskQueueHandlerRun = false; | 
|---|
|  |  |  | }); | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @Override | 
|---|