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);
        }

    }
}