package com.dji.sample.component;

import com.dji.sample.component.ntp.NTPClient;
import com.dji.sample.component.redis.RedisConst;
import com.dji.sample.component.redis.RedisOpsUtils;
import com.dji.sample.component.websocketWmm.WebSocketServerPlayBack;
import com.dji.sample.control.model.param.DroneControlParam;
import com.dji.sample.control.model.param.HeartBeatParam;
import com.dji.sample.control.service.IDrcService;
import com.dji.sample.manage.model.common.NtpServerProperties;
import com.dji.sample.manage.model.dto.DeviceDTO;
import com.dji.sample.manage.service.IDeviceService;
import com.dji.sample.storage.service.IStorageService;
import com.dji.sdk.cloudapi.device.DeviceDomainEnum;
import com.dji.sdk.cloudapi.storage.StsCredentialsResponse;
import com.dji.sdk.mqtt.IMqttTopicService;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.Arrays;
import java.util.Calendar;
import java.util.concurrent.TimeUnit;

/**
 * @author sean.zhou
 * @version 0.1
 * @date 2021/11/24
 */
@Component
@Slf4j
public class GlobalScheduleService {

    @Autowired
    private IDeviceService deviceService;

    @Autowired
    private IMqttTopicService topicService;

    @Autowired
    private IDrcService drcService;

    @Autowired
    private ObjectMapper mapper;

    @Autowired
    private IStorageService storageService;


    /**
     * Check the status of the devices every 30 seconds. It is recommended to use cache.
     */
    @Scheduled(initialDelay = 10, fixedRate = 30, timeUnit = TimeUnit.SECONDS)
    private void deviceStatusListen() {

        HeartBeatParam param = new HeartBeatParam();
        param.setSeq(new Long(1));
        Calendar calendar = Calendar.getInstance();
        param.setTimestamp(calendar.getTimeInMillis());
//        drcService.heartBeat("7CTDLCE00A1UPE", param);
        System.out.println("drc-heart-beat");

        int start = RedisConst.DEVICE_ONLINE_PREFIX.length();

        RedisOpsUtils.getAllKeys(RedisConst.DEVICE_ONLINE_PREFIX + "*").forEach(key -> {
            long expire = RedisOpsUtils.getExpire(key);
            if (expire <= 30) {
                DeviceDTO device = (DeviceDTO) RedisOpsUtils.get(key);
                if (null == device) {
                    return;
                }
                if (DeviceDomainEnum.DRONE == device.getDomain()) {
                    deviceService.subDeviceOffline(key.substring(start));
                } else {
                    deviceService.gatewayOffline(key.substring(start));
                }
                RedisOpsUtils.del(key);
            }
        });

        log.info("Subscriptions: {}", Arrays.toString(topicService.getSubscribedTopic()));
    }

    /**
     * Check the status of the devices every 30 seconds. It is recommended to use cache.
     */
    @Scheduled(initialDelay = 10, fixedRate = 10, timeUnit = TimeUnit.SECONDS)
    private void checkNTP() {

        System.out.println("ntp port: " + NtpServerProperties.port);
        System.out.println("ntp host: " + NtpServerProperties.host);
//        WebSocketServerPlayBack.sendInfo("{\"bizCode\":\"DOCK_OSD1\", \"timestamp\":1719885046382, \"data\":{\"flighttaskStepCode\":5,\"flighttaskPrepareCapacity\":1,\"mediaFileDetail\":{\"remainUpload\":0},\"wirelessLink\":{\"dongleNumber\":0,\"linkWorkmode\":0,\"sdrFreqBand\":2.4,\"sdrLinkState\":false,\"sdrQuality\":0,\"4g_freq_band\":2.4,\"4g_gnd_quality\":0,\"4g_link_state\":false,\"4g_quality\":0,\"4g_uav_quality\":0},\"drcState\":0,\"userExperienceImprovement\":1}}");
//        WebSocketServerPlayBack.sendInfo("{\"bizCode\":\"DOCK_OSD2\", \"timestamp\":1719885047654, \"data\":{\"networkState\":{\"type\":2,\"quality\":0,\"rate\":13.546},\"droneInDock\":false,\"droneChargeState\":{\"state\":false,\"capacityPercent\":0},\"rainfall\":0,\"windSpeed\":0.0,\"environmentTemperature\":33.6,\"temperature\":34.5,\"humidity\":26,\"latitude\":0.0,\"longitude\":0.0,\"height\":0.0,\"alternateLandPoint\":{\"latitude\":46.55827,\"longitude\":125.1475,\"safeLandHeight\":30.0,\"is_configured\":true},\"firstPowerOn\":1631945855969,\"positionState\":{\"gpsNumber\":1,\"isFixed\":1,\"quality\":1,\"rtkNumber\":2,\"is_calibration\":true},\"storage\":{\"total\":79981124,\"used\":61860},\"modeCode\":0,\"coverState\":0,\"emergencyStopState\":false,\"supplementLightState\":false,\"silentMode\":false,\"airConditioner\":{\"airConditionerState\":0,\"switchTime\":0},\"batteryStoreMode\":2,\"alarmState\":false,\"putterState\":0,\"subDevice\":{\"deviceSn\":\"1581F6Q8D23CT00A40YQ\",\"deviceOnlineStatus\":false,\"devicePaired\":true,\"deviceModelKey\":null}}}");
//        WebSocketServerPlayBack.sendInfo("{\"bizCode\":\"DOCK_OSD3\", \"timestamp\":1719885047688, \"data\":{\"jobNumber\":33,\"accTime\":1429074,\"activationTime\":1706653536,\"maintainStatus\":{\"maintainStatusArray\":[{\"lastMaintainFlightSorties\":null,\"lastMaintainTime\":0,\"lastMaintainType\":17,\"state\":false},{\"lastMaintainFlightSorties\":null,\"lastMaintainTime\":0,\"lastMaintainType\":18,\"state\":false}]},\"electricSupplyVoltage\":32767,\"workingVoltage\":27357,\"workingCurrent\":0,\"backupBattery\":{\"voltage\":13250,\"temperature\":34.4,\"switch\":true},\"droneBatteryMaintenanceInfo\":{\"batteries\":[{\"index\":0,\"capacityPercent\":0,\"voltage\":0,\"temperature\":0.0}],\"maintenanceState\":0,\"maintenanceTimeLeft\":0,\"heatState\":0}}}");
//        StsCredentialsResponse s =  storageService.getSTSCredentials();
        NTPClient.check();
    }

}