package com.dji.sample.control.service.impl;
|
|
import com.dji.sample.component.mqtt.model.EventsReceiver;
|
import com.dji.sample.component.websocket.model.BizCodeEnum;
|
import com.dji.sample.component.websocket.service.IWebSocketMessageService;
|
import com.dji.sample.component.websocketWmm.WebSocketServerPlayBack;
|
import com.dji.sample.manage.model.dto.DeviceDTO;
|
import com.dji.sample.manage.model.enums.UserTypeEnum;
|
import com.dji.sample.manage.service.IDeviceRedisService;
|
import com.dji.sdk.cloudapi.debug.RemoteDebugProgress;
|
import com.dji.sdk.cloudapi.debug.api.AbstractDebugService;
|
import com.dji.sdk.mqtt.MqttReply;
|
import com.dji.sdk.mqtt.events.EventsDataRequest;
|
import com.dji.sdk.mqtt.events.TopicEventsRequest;
|
import com.dji.sdk.mqtt.events.TopicEventsResponse;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.messaging.MessageHeaders;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Optional;
|
|
/**
|
* @author sean
|
* @version 1.7
|
* @date 2023/7/4
|
*/
|
@Service
|
@Slf4j
|
public class SDKRemoteDebug extends AbstractDebugService {
|
|
@Autowired
|
private IWebSocketMessageService webSocketMessageService;
|
|
@Autowired
|
private IDeviceRedisService deviceRedisService;
|
|
@Override
|
public TopicEventsResponse<MqttReply> remoteDebugProgress(TopicEventsRequest<EventsDataRequest<RemoteDebugProgress>> request, MessageHeaders headers) {
|
String sn = request.getGateway();
|
BizCodeEnum bizCode = BizCodeEnum.NO_BIZ_CODE;
|
String method = request.getMethod();
|
|
// EventsReceiver<RemoteDebugProgress> eventsReceiver = new EventsReceiver<RemoteDebugProgress>()
|
// .setOutput(request.getData().getOutput()).setResult(request.getData().getResult());
|
// eventsReceiver.setBid(request.getBid());
|
// eventsReceiver.setSn(sn);
|
//
|
// log.info("SN: {}, {} ===> Control progress: {}", sn, request.getMethod(), eventsReceiver.getOutput().getProgress());
|
//
|
// if (!eventsReceiver.getResult().isSuccess()) {
|
// log.error("SN: {}, {} ===> Error: {}", sn, request.getMethod(), eventsReceiver.getResult());
|
// }
|
|
Optional<DeviceDTO> deviceOpt = deviceRedisService.getDeviceOnline(sn);
|
|
if (deviceOpt.isEmpty()) {
|
throw new RuntimeException("The device is offline.");
|
}
|
switch (method) {
|
case "device_reboot":
|
bizCode = BizCodeEnum.DEVICE_REBOOT;
|
break;
|
case "drone_open":
|
bizCode = BizCodeEnum.DRONE_OPEN;
|
break;
|
case "drone_close":
|
bizCode = BizCodeEnum.DRONE_CLOSE;
|
break;
|
case "drone_format":
|
bizCode = BizCodeEnum.DRONE_FORMAT;
|
break;
|
case "device_format":
|
bizCode = BizCodeEnum.DEVICE_FORMAT;
|
break;
|
case "cover_open":
|
bizCode = BizCodeEnum.COVER_OPEN;
|
break;
|
case "cover_close":
|
bizCode = BizCodeEnum.COVER_CLOSE;
|
break;
|
case "putter_open":
|
bizCode = BizCodeEnum.PUTTER_OPEN;
|
break;
|
case "putter_close":
|
bizCode = BizCodeEnum.PUTTER_CLOSE;
|
break;
|
case "charge_open":
|
bizCode = BizCodeEnum.CHARGE_OPEN;
|
break;
|
case "charge_close":
|
bizCode = BizCodeEnum.CHARGE_CLOSE;
|
break;
|
// case "esim_activate":
|
// bizCode = BizCodeEnum.NO_BIZ_CODE;
|
// break;
|
// case "esim_operator_switch":
|
// bizCode = BizCodeEnum.NO_BIZ_CODE;
|
// break;
|
}
|
// DeviceDTO device = deviceOpt.get();
|
// webSocketMessageService.sendBatch(device.getWorkspaceId(), UserTypeEnum.WEB.getVal(),
|
// request.getMethod(), eventsReceiver);
|
|
// WebSocketServerPlayBack.sendInfo(request.toString());
|
|
ObjectMapper mapper = new ObjectMapper();
|
// mapper.configure(SerializationFeature.WRITE_NULL_MAP_VALUES, false);
|
String dockOsd = "";
|
try {
|
|
dockOsd = mapper.writeValueAsString(request.getData());
|
} catch (JsonProcessingException e) {
|
throw new RuntimeException("trans json failed.");
|
}
|
WebSocketServerPlayBack.sendInfo(bizCode, dockOsd);
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
|
}
|
}
|
