package com.dji.sample.interconnection.service.impl;
|
|
import com.dji.sdk.cloudapi.flightarea.api.AbstractFlightAreaService;
|
import com.dji.sdk.cloudapi.interconnection.CustomDataTransmissionFromEsdk;
|
import com.dji.sdk.cloudapi.interconnection.api.AbstractInterconnectionService;
|
import com.dji.sdk.mqtt.MqttReply;
|
import com.dji.sdk.mqtt.events.TopicEventsRequest;
|
import com.dji.sdk.mqtt.events.TopicEventsResponse;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.messaging.MessageHeaders;
|
import org.springframework.stereotype.Service;
|
|
import com.dji.sample.component.websocketWmm.WebSocketServerPlayBack;
|
/**
|
* @author wmm
|
* @version 0.1
|
* @date 2024/5/8
|
*/
|
@Service
|
public class SDKInterconnectionService extends AbstractInterconnectionService {
|
@Override
|
public TopicEventsResponse<MqttReply> customDataTransmissionFromPsdk(TopicEventsRequest<CustomDataTransmissionFromEsdk> request, MessageHeaders headers) {
|
|
WebSocketServerPlayBack.sendInfo(request.toString());
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
|
}
|
|
@Override
|
public TopicEventsResponse<MqttReply> customDataTransmissionFromEsdk(TopicEventsRequest<CustomDataTransmissionFromEsdk> request, MessageHeaders headers) {
|
|
WebSocketServerPlayBack.sendInfo(request.toString());
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
|
}
|
}
|