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