package com.tievd.jyz.handler;

import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.tievd.jyz.cache.DeviceCache;
import com.tievd.jyz.constants.SystemConstant;
import com.tievd.jyz.entity.Device;
import com.tievd.jyz.mapper.DeviceMapper;
import com.tievd.jyz.mqtt.dto.CameraDTO;
import com.tievd.jyz.mqtt.dto.HeartbeatStatusDTO;
import com.tievd.jyz.mqtt.dto.MqttParamDTO;
import com.tievd.jyz.mqtt.dto.SystemStatusDTO;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 网关状态处理类
 * @author timi
 */
@Slf4j
@Component
public class DeviceStatusHandler {
    /** 设备序列号：状态信息 */
    private final static Map<String,SystemStatusDTO> SYSTEM_STATUS_INFO_CACHE_MAP = new ConcurrentHashMap<>();
    /** 终端状态 设备序列号_终端编号：在线状态：0：未知；1：在线；2：离线 */
    private final static Map<String,String> CAMERA_STATUS_INFO_CACHE_MAP = new ConcurrentHashMap<>();
    /** 设备序列号：最近更新时间 */
    private final static Map<String,Long> STATUS_TIME_CACHE_MAP = new ConcurrentHashMap<>();
    /** 心跳超时时间 */
    private static Long heartbeatTimeout;
    @Autowired
    private DeviceMapper deviceMapper;

    @Value("${init.heartbeatThresholdTime:70000}")
    public void setHeartbeatTimeout(Long heartbeatTimeout){
        DeviceStatusHandler.heartbeatTimeout = heartbeatTimeout;
    }

    /**
     * 状态心跳处理流程
     * @param mqttParamDTO
     * @return
     */
    public static void heartbeat(MqttParamDTO<JSON> mqttParamDTO){
        String deviceSn = mqttParamDTO.getSn();
        Long updateTime = Long.parseLong(mqttParamDTO.getTime());
        HeartbeatStatusDTO heartbeatStatusDTO = JSONObject.toJavaObject(mqttParamDTO.getData(), HeartbeatStatusDTO.class);
        SYSTEM_STATUS_INFO_CACHE_MAP.put(deviceSn, heartbeatStatusDTO.getSystem());
        STATUS_TIME_CACHE_MAP.put(deviceSn,updateTime);
        List<CameraDTO> cameras  = heartbeatStatusDTO.getCamera();
        if(ObjectUtil.isNotNull(cameras)){
            for(CameraDTO cameraDTO :cameras){
                CAMERA_STATUS_INFO_CACHE_MAP.put(deviceSn+"_"+cameraDTO.getCode(),cameraDTO.getStatus());
            }
        }
    }



    /**
     * 获取设备心跳最近上报时间
     * @param deviceSn 设备序列号
     * @return 最近上报时间
     */
    public static Long getLastReportTime(String deviceSn){
        return STATUS_TIME_CACHE_MAP.get(deviceSn);
    }

    /**
     * 获取设备最近上报系统状态
     * @param deviceSn 设备序列号
     * @return 状态数据
     */
    public static SystemStatusDTO getStatusInfo(String deviceSn){
        return SYSTEM_STATUS_INFO_CACHE_MAP.get(deviceSn);
    }


    /**
     * 获取设备最近上报系统状态
     * @param deviceSn 设备序列号
     * @return 状态数据
     */
    public static String getCameraStatus(String deviceSn,String code){
        return CAMERA_STATUS_INFO_CACHE_MAP.get(deviceSn+"_"+code);
    }
    
    /**
     * 获取设备最近上报系统状态
     */
    public static Map<String, String> getCameraStatusMap(){
        return CAMERA_STATUS_INFO_CACHE_MAP;
    }

    /**
     * 获取设备是否在线
     * @param deviceSn 设备序列号
     * @return
     */
    private static byte onlineStatus(String deviceSn){
         Long lastUpdateTime = STATUS_TIME_CACHE_MAP.get(deviceSn);
         if(ObjectUtil.isNotNull(lastUpdateTime)){
            if((System.currentTimeMillis() - lastUpdateTime) < heartbeatTimeout){
                //小于超时时间
                return SystemConstant.DEVICE_ONLINE;
            }
         }
        return SystemConstant.DEVICE_OFFLINE;
    }

    /**
     * 网关状态定时更新
     */
    @Scheduled(fixedDelay = 60000L)
    public void deviceStatusUpdate(){
        List<Device> devices = DeviceCache.getDeviceList();
        for(Device device : devices){
            Byte status = onlineStatus(device.getSn());
            if(!status.equals(device.getStatus())){
                log.info("网关 {} 在线状态变化，当前状态:{}",device.getName(),status);
                device.setStatus(status);
                Device updateDevice = new Device();
                updateDevice.setId(device.getId());
                updateDevice.setStatus(status);
                deviceMapper.updateById(updateDevice);
            }
        }
    }

}