package com.genersoft.iot.vmp.gb28181.transmit.event.request.impl;

import com.genersoft.iot.vmp.conf.CivilCodeFileConf;
import com.genersoft.iot.vmp.conf.DynamicTask;
import com.genersoft.iot.vmp.conf.SipConfig;
import com.genersoft.iot.vmp.conf.UserSetting;
import com.genersoft.iot.vmp.gb28181.bean.Device;
import com.genersoft.iot.vmp.gb28181.bean.DeviceChannel;
import com.genersoft.iot.vmp.gb28181.bean.MobilePosition;
import com.genersoft.iot.vmp.gb28181.event.EventPublisher;
import com.genersoft.iot.vmp.gb28181.transmit.event.request.SIPRequestProcessorParent;
import com.genersoft.iot.vmp.gb28181.utils.NumericUtil;
import com.genersoft.iot.vmp.gb28181.utils.SipUtils;
import com.genersoft.iot.vmp.gb28181.utils.XmlUtil;
import com.genersoft.iot.vmp.service.IDeviceChannelService;
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
import com.genersoft.iot.vmp.utils.DateUtil;
import org.dom4j.DocumentException;
import org.dom4j.Element;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.util.ObjectUtils;

import javax.sip.RequestEvent;
import javax.sip.header.FromHeader;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CopyOnWriteArrayList;

/**
 * SIP命令类型： NOTIFY请求中的移动位置请求处理
 */
@Component
public class NotifyRequestForMobilePositionProcessor extends SIPRequestProcessorParent {


    private final static Logger logger = LoggerFactory.getLogger(NotifyRequestForMobilePositionProcessor.class);

	private final Map<String, DeviceChannel> updateChannelMap = new ConcurrentHashMap<>();

	private final List<MobilePosition> addMobilePositionList = new CopyOnWriteArrayList();


	@Autowired
	private UserSetting userSetting;

	@Autowired
	private EventPublisher eventPublisher;

	@Autowired
	private IRedisCatchStorage redisCatchStorage;

	@Autowired
	private IDeviceChannelService deviceChannelService;

	@Autowired
	private DynamicTask dynamicTask;

	@Autowired
	private CivilCodeFileConf civilCodeFileConf;

	@Autowired
	private SipConfig sipConfig;

	private final static String talkKey = "notify-request-for-mobile-position-task";

	public void process(RequestEvent evt) {
		try {
			FromHeader fromHeader = (FromHeader) evt.getRequest().getHeader(FromHeader.NAME);
			String deviceId = SipUtils.getUserIdFromFromHeader(fromHeader);

			// 回复 200 OK
			Element rootElement = getRootElement(evt);
			if (rootElement == null) {
				logger.error("处理MobilePosition移动位置Notify时未获取到消息体,{}", evt.getRequest());
				return;
			}

			MobilePosition mobilePosition = new MobilePosition();
			mobilePosition.setCreateTime(DateUtil.getNow());

			Element deviceIdElement = rootElement.element("DeviceID");
			String channelId = deviceIdElement.getTextTrim().toString();
			Device device = redisCatchStorage.getDevice(deviceId);

			if (device == null) {
				device = redisCatchStorage.getDevice(channelId);
				if (device == null) {
					// 根据通道id查询设备Id
					List<Device> deviceList = deviceChannelService.getDeviceByChannelId(channelId);
					if (deviceList.size() > 0) {
						device = deviceList.get(0);
					}
				}
			}
			if (device == null) {
				logger.warn("[mobilePosition移动位置Notify] 未找到通道{}所属的设备", channelId);
				return;
			}
			// 兼容设备部分设备上报是通道编号与设备编号一致的情况
			if (deviceId.equals(channelId)) {
				List<DeviceChannel> deviceChannels = deviceChannelService.queryChaneListByDeviceId(deviceId);
				if (deviceChannels.size() == 1) {
					channelId = deviceChannels.get(0).getChannelId();
				}
			}
			if (!ObjectUtils.isEmpty(device.getName())) {
				mobilePosition.setDeviceName(device.getName());
			}
			mobilePosition.setDeviceName(device.getName());
			mobilePosition.setDeviceId(device.getDeviceId());
			mobilePosition.setChannelId(channelId);
			String time = XmlUtil.getText(rootElement, "Time");
			if (ObjectUtils.isEmpty(time)) {
				mobilePosition.setTime(DateUtil.getNow());
			} else {
				mobilePosition.setTime(SipUtils.parseTime(time));
			}

			mobilePosition.setLongitude(Double.parseDouble(XmlUtil.getText(rootElement, "Longitude")));
			mobilePosition.setLatitude(Double.parseDouble(XmlUtil.getText(rootElement, "Latitude")));
			if (NumericUtil.isDouble(XmlUtil.getText(rootElement, "Speed"))) {
				mobilePosition.setSpeed(Double.parseDouble(XmlUtil.getText(rootElement, "Speed")));
			} else {
				mobilePosition.setSpeed(0.0);
			}
			if (NumericUtil.isDouble(XmlUtil.getText(rootElement, "Direction"))) {
				mobilePosition.setDirection(Double.parseDouble(XmlUtil.getText(rootElement, "Direction")));
			} else {
				mobilePosition.setDirection(0.0);
			}
			if (NumericUtil.isDouble(XmlUtil.getText(rootElement, "Altitude"))) {
				mobilePosition.setAltitude(Double.parseDouble(XmlUtil.getText(rootElement, "Altitude")));
			} else {
				mobilePosition.setAltitude(0.0);
			}
			logger.info("[收到移动位置订阅通知]：{}/{}->{}.{}", mobilePosition.getDeviceId(), mobilePosition.getChannelId(),
					mobilePosition.getLongitude(), mobilePosition.getLatitude());
			mobilePosition.setReportSource("Mobile Position");

			// 更新device channel 的经纬度
			DeviceChannel deviceChannel = new DeviceChannel();
			deviceChannel.setDeviceId(device.getDeviceId());
			deviceChannel.setChannelId(channelId);
			deviceChannel.setLongitude(mobilePosition.getLongitude());
			deviceChannel.setLatitude(mobilePosition.getLatitude());
			deviceChannel.setGpsTime(mobilePosition.getTime());
			updateChannelMap.put(channelId, deviceChannel);
			addMobilePositionList.add(mobilePosition);
			if(updateChannelMap.size() > 300) {
				executeSaveChannel();
			}
			if (userSetting.isSavePositionHistory()) {
				if(addMobilePositionList.size() > 300) {
					executeSaveMobilePosition();
				}
			}

//			deviceChannel = deviceChannelService.updateGps(deviceChannel, device);
//
//			mobilePosition.setLongitudeWgs84(deviceChannel.getLongitudeWgs84());
//			mobilePosition.setLatitudeWgs84(deviceChannel.getLatitudeWgs84());
//			mobilePosition.setLongitudeGcj02(deviceChannel.getLongitudeGcj02());
//			mobilePosition.setLatitudeGcj02(deviceChannel.getLatitudeGcj02());

//			deviceChannelService.updateChannelGPS(device, deviceChannel, mobilePosition);

			if (!dynamicTask.contains(talkKey)) {
				dynamicTask.startDelay(talkKey, this::executeSave, 1000);
			}

		} catch (DocumentException e) {
			logger.error("未处理的异常 ", e);
		}


	}

	private void executeSave(){
		executeSaveChannel();
		executeSaveMobilePosition();
		dynamicTask.stop(talkKey);
	}

	private void executeSaveChannel(){
		try {
			logger.info("[移动位置订阅]更新通道位置： {}", updateChannelMap.size());
			ArrayList<DeviceChannel> deviceChannels = new ArrayList<>(updateChannelMap.values());
			deviceChannelService.batchUpdateChannelGPS(deviceChannels);
			updateChannelMap.clear();
		}catch (Exception e) {

		}
	}

	private void executeSaveMobilePosition(){
		if (userSetting.isSavePositionHistory()) {
			try {
				logger.info("[移动位置订阅] 添加通道轨迹点位： {}", addMobilePositionList.size());
				deviceChannelService.batchAddMobilePosition(addMobilePositionList);
				addMobilePositionList.clear();
			}catch (Exception e) {
				logger.info("[移动位置订阅] b添加通道轨迹点位保存失败： {}", addMobilePositionList.size());
			}
		}
	}



}