| | |
| | |
|
| | | import java.io.ByteArrayInputStream;
|
| | | import java.text.ParseException;
|
| | | import java.text.SimpleDateFormat;
|
| | | import java.util.*;
|
| | |
|
| | | import javax.sip.*;
|
| | | import javax.sip.address.Address;
|
| | | import javax.sip.address.SipURI;
|
| | |
|
| | | import javax.sip.header.FromHeader;
|
| | | import javax.sip.header.Header;
|
| | | import javax.sip.header.HeaderAddress;
|
| | | import javax.sip.header.ToHeader;
|
| | | import javax.sip.InvalidArgumentException;
|
| | | import javax.sip.ListeningPoint;
|
| | | import javax.sip.ObjectInUseException;
|
| | | import javax.sip.RequestEvent;
|
| | | import javax.sip.SipException;
|
| | | import javax.sip.SipProvider;
|
| | | import javax.sip.message.Request;
|
| | | import javax.sip.message.Response;
|
| | |
|
| | |
| | | import com.genersoft.iot.vmp.gb28181.utils.DateUtil;
|
| | | import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
|
| | | import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;
|
| | | import com.genersoft.iot.vmp.service.IDeviceAlarmService;
|
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
|
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
|
| | | import com.genersoft.iot.vmp.utils.GpsUtil;
|
| | | import com.genersoft.iot.vmp.utils.SipUtils;
|
| | | import com.genersoft.iot.vmp.utils.SpringBeanFactory;
|
| | | import com.genersoft.iot.vmp.utils.redis.RedisUtil;
|
| | | import com.genersoft.iot.vmp.vmanager.gb28181.platform.bean.ChannelReduce;
|
| | |
| | | private DeferredResultHolder deferredResultHolder;
|
| | |
|
| | | private DeviceOffLineDetector offLineDetector;
|
| | |
|
| | | private IDeviceAlarmService deviceAlarmService;
|
| | |
|
| | | private final static String CACHE_RECORDINFO_KEY = "CACHE_RECORDINFO_";
|
| | |
|
| | |
| | | */
|
| | | private void processMessageMobilePosition(RequestEvent evt) {
|
| | | try {
|
| | | Element rootElement = getRootElement(evt);
|
| | | MobilePosition mobilePosition = new MobilePosition();
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getTextTrim().toString();
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device != null) {
|
| | | if (!StringUtils.isEmpty(device.getName())) {
|
| | | mobilePosition.setDeviceName(device.getName());
|
| | | }
|
| | | if (device == null) {
|
| | | logger.warn("处理MobilePosition移动位置消息时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | mobilePosition.setDeviceId(XmlUtil.getText(rootElement, "DeviceID"));
|
| | | Element rootElement = getRootElement(evt, device.getCharset());
|
| | |
|
| | | MobilePosition mobilePosition = new MobilePosition();
|
| | | if (!StringUtils.isEmpty(device.getName())) {
|
| | | mobilePosition.setDeviceName(device.getName());
|
| | | }
|
| | | mobilePosition.setDeviceId(deviceId);
|
| | | mobilePosition.setChannelId(XmlUtil.getText(rootElement, "DeviceID"));
|
| | | mobilePosition.setTime(XmlUtil.getText(rootElement, "Time"));
|
| | | mobilePosition.setLongitude(Double.parseDouble(XmlUtil.getText(rootElement, "Longitude")));
|
| | | mobilePosition.setLatitude(Double.parseDouble(XmlUtil.getText(rootElement, "Latitude")));
|
| | |
| | | */
|
| | | private void processMessageDeviceStatus(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceStatus设备状态Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String name = rootElement.getName();
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getText();
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | String channelId = deviceIdElement.getText();
|
| | | if (name.equalsIgnoreCase("Query")) { // 区分是Response——查询响应,还是Query——查询请求
|
| | | logger.info("接收到DeviceStatus查询消息");
|
| | | FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS);
|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_DEVICESTATUS + deviceId + channelId);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | |
|
| | | if (offLineDetector.isOnline(deviceId)) {
|
| | | publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_MESSAGE);
|
| | |
| | | */
|
| | | private void processMessageDeviceControl(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceControl设备状态Message未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | //String result = XmlUtil.getText(rootElement, "Result");
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (rootElement.getName().equals("Response")) {//} !XmlUtil.isEmpty(result)) {
|
| | | if (rootElement.getName().equals("Response")) {//} !StringUtils.isEmpty(result)) {
|
| | | // 此处是对本平台发出DeviceControl指令的应答
|
| | | JSONObject json = new JSONObject();
|
| | | XmlUtil.node2Json(rootElement, json);
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL);
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONTROL + deviceId + channelId;
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | // 此处是上级发出的DeviceControl指令
|
| | | String platformId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(FromHeader.NAME)).getAddress().getURI()).getUser();
|
| | | String targetGBId = ((SipURI) ((HeaderAddress) evt.getRequest().getHeader(ToHeader.NAME)).getAddress().getURI()).getUser();
|
| | | // 远程启动功能
|
| | | if (!XmlUtil.isEmpty(XmlUtil.getText(rootElement, "TeleBoot"))) {
|
| | | if (!StringUtils.isEmpty(XmlUtil.getText(rootElement, "TeleBoot"))) {
|
| | | if (deviceId.equals(targetGBId)) {
|
| | | // 远程启动本平台:需要在重新启动程序后先对SipStack解绑
|
| | | logger.info("执行远程启动本平台命令");
|
| | |
| | | }
|
| | | }
|
| | | // 云台/前端控制命令
|
| | | if (!XmlUtil.isEmpty(XmlUtil.getText(rootElement,"PTZCmd")) && !deviceId.equals(targetGBId)) {
|
| | | if (!StringUtils.isEmpty(XmlUtil.getText(rootElement,"PTZCmd")) && !deviceId.equals(targetGBId)) {
|
| | | String cmdString = XmlUtil.getText(rootElement,"PTZCmd");
|
| | | Device device = storager.queryVideoDeviceByPlatformIdAndChannelId(platformId, deviceId);
|
| | | cmder.fronEndCmd(device, deviceId, cmdString);
|
| | | Device deviceForPlatform = storager.queryVideoDeviceByPlatformIdAndChannelId(platformId, deviceId);
|
| | | cmder.fronEndCmd(deviceForPlatform, deviceId, cmdString);
|
| | | }
|
| | | }
|
| | | } catch (ParseException | SipException | InvalidArgumentException | DocumentException e) {
|
| | |
| | | */
|
| | | private void processMessageDeviceConfig(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceConfig设备状态Message消息时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (rootElement.getName().equals("Response")) {
|
| | |
| | | if (logger.isDebugEnabled()) {
|
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_DEVICECONFIG + deviceId + channelId;
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICECONFIG);
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | // 此处是上级发出的DeviceConfig指令
|
| | | }
|
| | |
| | | */
|
| | | private void processMessageConfigDownload(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理ConfigDownload设备状态Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_CONFIGDOWNLOAD + deviceId + channelId;
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (rootElement.getName().equals("Response")) {
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_CONFIGDOWNLOAD);
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | // 此处是上级发出的DeviceConfig指令
|
| | | }
|
| | |
| | | */
|
| | | private void processMessagePresetQuery(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理PresetQuery预置位列表Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_PRESETQUERY + deviceId + channelId;
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (rootElement.getName().equals("Response")) {// !XmlUtil.isEmpty(result)) {
|
| | | if (rootElement.getName().equals("Response")) {// !StringUtils.isEmpty(result)) {
|
| | | // 此处是对本平台发出DeviceControl指令的应答
|
| | | JSONObject json = new JSONObject();
|
| | | XmlUtil.node2Json(rootElement, json);
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_PRESETQUERY);
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | // 此处是上级发出的DeviceControl指令
|
| | | }
|
| | |
| | | */
|
| | | private void processMessageDeviceInfo(RequestEvent evt) {
|
| | | try {
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt);
|
| | | String requestName = rootElement.getName();
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getTextTrim().toString();
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | String channelId = deviceIdElement.getTextTrim();
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_DEVICEINFO + deviceId + channelId;
|
| | | if (device != null ) {
|
| | | rootElement = getRootElement(evt, device.getCharset());
|
| | | }
|
| | | if (requestName.equals("Query")) {
|
| | | logger.info("接收到DeviceInfo查询消息");
|
| | | FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
|
| | |
| | | if (device == null) {
|
| | | return;
|
| | | }
|
| | |
|
| | | device.setName(XmlUtil.getText(rootElement, "DeviceName"));
|
| | |
|
| | | device.setManufacturer(XmlUtil.getText(rootElement, "Manufacturer"));
|
| | | device.setModel(XmlUtil.getText(rootElement, "Model"));
|
| | | device.setFirmware(XmlUtil.getText(rootElement, "Firmware"));
|
| | |
| | | storager.updateDevice(device);
|
| | |
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_DEVICEINFO);
|
| | | msg.setKey(key);
|
| | | msg.setData(device);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (offLineDetector.isOnline(deviceId)) {
|
| | |
| | | */
|
| | | private void processMessageCatalogList(RequestEvent evt) {
|
| | | try {
|
| | |
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | |
|
| | | Element rootElement = getRootElement(evt);
|
| | | String name = rootElement.getName();
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getText();
|
| | | String channelId = deviceIdElement.getText();
|
| | | Element deviceListElement = rootElement.element("DeviceList");
|
| | |
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_CATALOG + deviceId;
|
| | | FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
|
| | | AddressImpl address = (AddressImpl) fromHeader.getAddress();
|
| | | SipUri uri = (SipUri) address.getURI();
|
| | |
| | | deviceChannel.setStatus(gbStream.isStatus()?1:0);
|
| | | // deviceChannel.setParentId(parentPlatform.getDeviceGBId());
|
| | | deviceChannel.setRegisterWay(1);
|
| | | deviceChannel.setCivilCode(cmder.getSipConfig().getSipDomain());
|
| | | deviceChannel.setCivilCode(cmder.getSipConfig().getDomain());
|
| | | deviceChannel.setModel("live");
|
| | | deviceChannel.setOwner("wvp-pro");
|
| | | // deviceChannel.setAddress("test");
|
| | |
| | |
|
| | |
|
| | | } else {
|
| | | deviceListElement = getRootElement(evt, device.getCharset()).element("DeviceList");
|
| | | Iterator<Element> deviceListIterator = deviceListElement.elementIterator();
|
| | | if (deviceListIterator != null) {
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | return;
|
| | | }
|
| | |
|
| | | // 遍历DeviceList
|
| | | while (deviceListIterator.hasNext()) {
|
| | | Element itemDevice = deviceListIterator.next();
|
| | |
| | | }
|
| | |
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_CATALOG);
|
| | | msg.setKey(key);
|
| | | msg.setData(device);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (offLineDetector.isOnline(deviceId)) {
|
| | |
| | | */
|
| | | private void processMessageAlarm(RequestEvent evt) {
|
| | | try {
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理alarm设备报警信息未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | | Element rootElement = getRootElement(evt, device.getCharset());
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getText().toString();
|
| | | String channelId = deviceIdElement.getText().toString();
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_ALARM + deviceId + channelId;
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | |
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | return;
|
| | | if (device.getCharset() != null) {
|
| | | rootElement = getRootElement(evt, device.getCharset());
|
| | | }
|
| | |
|
| | | if (rootElement.getName().equals("Notify")) { // 处理报警通知
|
| | | DeviceAlarm deviceAlarm = new DeviceAlarm();
|
| | | deviceAlarm.setDeviceId(deviceId);
|
| | | deviceAlarm.setChannelId(channelId);
|
| | | deviceAlarm.setAlarmPriority(XmlUtil.getText(rootElement, "AlarmPriority"));
|
| | | deviceAlarm.setAlarmMethod(XmlUtil.getText(rootElement, "AlarmMethod"));
|
| | | deviceAlarm.setAlarmTime(XmlUtil.getText(rootElement, "AlarmTime"));
|
| | |
| | | deviceAlarm.setLatitude(0.00);
|
| | | }
|
| | |
|
| | | if (!XmlUtil.isEmpty(deviceAlarm.getAlarmMethod())) {
|
| | | if (!StringUtils.isEmpty(deviceAlarm.getAlarmMethod())) {
|
| | | if ( deviceAlarm.getAlarmMethod().equals("4")) {
|
| | | MobilePosition mobilePosition = new MobilePosition();
|
| | | mobilePosition.setDeviceId(deviceAlarm.getDeviceId());
|
| | |
| | | storager.insertMobilePosition(mobilePosition);
|
| | | }
|
| | | }
|
| | | // TODO: 需要实现存储报警信息、报警分类
|
| | | System.out.println("存储报警信息、报警分类");
|
| | | // 存储报警信息、报警分类
|
| | | deviceAlarmService.add(deviceAlarm);
|
| | |
|
| | | if (offLineDetector.isOnline(deviceId)) {
|
| | | publisher.deviceAlarmEventPublish(deviceAlarm);
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_ALARM);
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | }
|
| | | } catch (DocumentException | SipException | InvalidArgumentException | ParseException e) {
|
| | | // } catch (DocumentException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | | }
|
| | |
| | | */
|
| | | private void processMessageKeepAlive(RequestEvent evt) {
|
| | | try {
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | |
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | // 检查设备是否存在并在线, 不存在则不回复
|
| | | if (device != null && device.getOnline() == 1) {
|
| | |
|
| | | Element rootElement = getRootElement(evt);
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | |
|
| | | // 检查设备是否存在并在线, 不在线则设置为在线
|
| | | if (device != null ) {
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (offLineDetector.isOnline(deviceId)) {
|
| | | publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);
|
| | | } else {
|
| | | publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);
|
| | | }else{
|
| | | logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备不存在, 回复404");
|
| | | Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());
|
| | | ServerTransaction serverTransaction = getServerTransaction(evt);
|
| | | serverTransaction.sendResponse(response);
|
| | | if (serverTransaction.getDialog() != null) {
|
| | | serverTransaction.getDialog().delete();
|
| | | }
|
| | | }else {
|
| | | logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备" + (device == null? "不存在":"离线") + ", 回复401");
|
| | | Response response = getMessageFactory().createResponse(Response.UNAUTHORIZED, evt.getRequest());
|
| | | getServerTransaction(evt).sendResponse(response);
|
| | | }
|
| | |
|
| | | // if (device != null && device.getOnline() == 1) {
|
| | | //
|
| | | // if (offLineDetector.isOnline(deviceId)) {
|
| | | // publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);
|
| | | // } else {
|
| | | // }
|
| | | // }else {
|
| | | //// logger.warn("收到[ "+deviceId+" ]心跳信息, 但是设备" + (device == null? "不存在":"离线") + ", 回复401");
|
| | | //// Response response = getMessageFactory().createResponse(Response.UNAUTHORIZED, evt.getRequest());
|
| | | //// getServerTransaction(evt).sendResponse(response);
|
| | | // publisher.onlineEventPublish(device, VideoManagerConstants.EVENT_ONLINE_KEEPLIVE);
|
| | | //
|
| | | // }
|
| | | } catch (ParseException | SipException | InvalidArgumentException | DocumentException e) {
|
| | | e.printStackTrace();
|
| | | }
|
| | |
| | | */
|
| | | private void processMessageRecordInfo(RequestEvent evt) {
|
| | | try {
|
| | |
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | |
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | String uuid = UUID.randomUUID().toString().replace("-", "");
|
| | | RecordInfo recordInfo = new RecordInfo();
|
| | | Element rootElement = getRootElement(evt);
|
| | | Element deviceIdElement = rootElement.element("DeviceID");
|
| | | String deviceId = deviceIdElement.getText().toString();
|
| | | String channelId = deviceIdElement.getText().toString();
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_RECORDINFO + deviceId + channelId;
|
| | | if (device != null ) {
|
| | | rootElement = getRootElement(evt, device.getCharset());
|
| | | }
|
| | | recordInfo.setDeviceId(deviceId);
|
| | | recordInfo.setChannelId(channelId);
|
| | | recordInfo.setName(XmlUtil.getText(rootElement, "Name"));
|
| | | if (XmlUtil.getText(rootElement, "SumNum")== null || XmlUtil.getText(rootElement, "SumNum") =="") {
|
| | | recordInfo.setSumNum(0);
|
| | |
| | | if (recordListElement == null || recordInfo.getSumNum() == 0) {
|
| | | logger.info("无录像数据");
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_RECORDINFO);
|
| | | msg.setKey(key);
|
| | | msg.setData(recordInfo);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | Iterator<Element> recordListIterator = recordListElement.elementIterator();
|
| | | List<RecordItem> recordList = new ArrayList<RecordItem>();
|
| | |
| | | */
|
| | | private void processMessageMediaStatus(RequestEvent evt){
|
| | | try {
|
| | |
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | |
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String NotifyType =XmlUtil.getText(rootElement, "NotifyType");
|
| | | if (NotifyType.equals("121")){
|
| | | logger.info("媒体播放完毕,通知关流");
|
| | |
| | | */
|
| | | private void processMessageBroadcast(RequestEvent evt) {
|
| | | try {
|
| | |
|
| | | String deviceId = SipUtils.getUserIdFromFromHeader(evt.getRequest());
|
| | | // 查询设备是否存在
|
| | | Device device = storager.queryVideoDevice(deviceId);
|
| | | if (device == null) {
|
| | | logger.warn("处理DeviceInfo设备信息Message时未找到设备信息");
|
| | | response404Ack(evt);
|
| | | return;
|
| | | }
|
| | |
|
| | | Element rootElement = getRootElement(evt);
|
| | | String deviceId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String channelId = XmlUtil.getText(rootElement, "DeviceID");
|
| | | String key = DeferredResultHolder.CALLBACK_CMD_BROADCAST + deviceId + channelId;
|
| | | // 回复200 OK
|
| | | responseAck(evt);
|
| | | if (rootElement.getName().equals("Response")) {
|
| | |
| | | logger.debug(json.toJSONString());
|
| | | }
|
| | | RequestMessage msg = new RequestMessage();
|
| | | msg.setDeviceId(deviceId);
|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_BROADCAST);
|
| | | msg.setKey(key);
|
| | | msg.setData(json);
|
| | | deferredResultHolder.invokeResult(msg);
|
| | | deferredResultHolder.invokeAllResult(msg);
|
| | | } else {
|
| | | // 此处是上级发出的Broadcast指令
|
| | | }
|
| | |
| | | */
|
| | | private void responseAck(RequestEvent evt) throws SipException, InvalidArgumentException, ParseException {
|
| | | Response response = getMessageFactory().createResponse(Response.OK, evt.getRequest());
|
| | | getServerTransaction(evt).sendResponse(response);
|
| | | ServerTransaction serverTransaction = getServerTransaction(evt);
|
| | | serverTransaction.sendResponse(response);
|
| | | if (serverTransaction.getDialog() != null) {
|
| | | serverTransaction.getDialog().delete();
|
| | | }
|
| | | }
|
| | |
|
| | | /***
|
| | |
| | | */
|
| | | private void response404Ack(RequestEvent evt) throws SipException, InvalidArgumentException, ParseException {
|
| | | Response response = getMessageFactory().createResponse(Response.NOT_FOUND, evt.getRequest());
|
| | | getServerTransaction(evt).sendResponse(response);
|
| | | ServerTransaction serverTransaction = getServerTransaction(evt);
|
| | | serverTransaction.sendResponse(response);
|
| | | if (serverTransaction.getDialog() != null) {
|
| | | serverTransaction.getDialog().delete();
|
| | | }
|
| | | }
|
| | |
|
| | | private Element getRootElement(RequestEvent evt) throws DocumentException {
|
| | |
|
| | | return getRootElement(evt, "gb2312");
|
| | | }
|
| | |
|
| | | private Element getRootElement(RequestEvent evt, String charset) throws DocumentException {
|
| | | if (charset == null) {
|
| | | charset = "gb2312";
|
| | | }
|
| | | Request request = evt.getRequest();
|
| | | SAXReader reader = new SAXReader();
|
| | | reader.setEncoding("gbk");
|
| | | reader.setEncoding(charset);
|
| | | Document xml = reader.read(new ByteArrayInputStream(request.getRawContent()));
|
| | | return xml.getRootElement();
|
| | | }
|
| | |
| | | public void setCmderFroPlatform(SIPCommanderFroPlatform cmderFroPlatform) {
|
| | | this.cmderFroPlatform = cmderFroPlatform;
|
| | | }
|
| | |
|
| | | public void setDeviceAlarmService(IDeviceAlarmService deviceAlarmService) {
|
| | | this.deviceAlarmService = deviceAlarmService;
|
| | | }
|
| | | }
|