package com.ard.gb28181.transmit.event.request.impl.message.response.cmd;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.ard.gb28181.api.domain.Device;
|
import com.ard.gb28181.service.IDeviceService;
|
import com.ard.gb28181.transmit.event.request.SIPRequestProcessorParent;
|
import com.ard.gb28181.transmit.event.request.impl.message.IMessageHandler;
|
import com.ard.gb28181.transmit.event.request.impl.message.response.ResponseMessageHandler;
|
import com.ard.gb28181.api.utils.XmlUtil;
|
import gov.nist.javax.sip.message.SIPRequest;
|
import lombok.extern.slf4j.Slf4j;
|
import org.dom4j.Element;
|
import org.springframework.beans.factory.InitializingBean;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.sip.InvalidArgumentException;
|
import javax.sip.RequestEvent;
|
import javax.sip.SipException;
|
import javax.sip.message.Response;
|
import java.text.ParseException;
|
|
@Slf4j
|
@Component
|
public class ConfigDownloadResponseMessageHandler extends SIPRequestProcessorParent implements InitializingBean, IMessageHandler {
|
|
private final String cmdType = "ConfigDownload";
|
|
@Autowired
|
private ResponseMessageHandler responseMessageHandler;
|
|
@Autowired
|
private IDeviceService deviceService;
|
|
@Override
|
public void afterPropertiesSet() throws Exception {
|
responseMessageHandler.addHandler(cmdType, this);
|
}
|
|
|
@Override
|
public void handForDevice(RequestEvent evt, Device device, Element element) {
|
try {
|
// 回复200 OK
|
responseAck((SIPRequest) evt.getRequest(), Response.OK);
|
} catch (SipException | InvalidArgumentException | ParseException e) {
|
log.error("[命令发送失败] 设备配置查询: {}", e.getMessage());
|
}
|
// 此处是对本平台发出DeviceControl指令的应答
|
JSONObject json = new JSONObject();
|
XmlUtil.node2Json(element, json);
|
if (log.isDebugEnabled()) {
|
log.debug(json.toJSONString());
|
}
|
JSONObject jsonObject = new JSONObject();
|
if (json.get("BasicParam") != null) {
|
jsonObject.put("BasicParam", json.getJSONObject("BasicParam"));
|
}
|
if (json.get("VideoParamOpt") != null) {
|
jsonObject.put("VideoParamOpt", json.getJSONObject("VideoParamOpt"));
|
}
|
if (json.get("SVACEncodeConfig") != null) {
|
jsonObject.put("SVACEncodeConfig", json.getJSONObject("SVACEncodeConfig"));
|
}
|
if (json.get("SVACDecodeConfig") != null) {
|
jsonObject.put("SVACDecodeConfig", json.getJSONObject("SVACDecodeConfig"));
|
}
|
|
responseMessageHandler.handMessageEvent(element, jsonObject);
|
|
JSONObject basicParam = json.getJSONObject("BasicParam");
|
if (basicParam != null) {
|
Integer heartBeatInterval = basicParam.getInteger("HeartBeatInterval");
|
Integer heartBeatCount = basicParam.getInteger("HeartBeatCount");
|
Integer positionCapability = basicParam.getInteger("PositionCapability");
|
Integer expiration = basicParam.getInteger("Expiration");
|
device.setHeartBeatInterval(heartBeatInterval);
|
device.setHeartBeatCount(heartBeatCount);
|
device.setPositionCapability(positionCapability);
|
device.setExpires(expiration);
|
|
deviceService.updateDeviceHeartInfo(device);
|
}
|
|
}
|
}
|
