package com.dji.sample.airsense.service.impl;
|
|
import com.dji.sample.component.websocketWmm.WebSocketServerPlayBack;
|
import com.dji.sdk.cloudapi.airsense.AirsenseWarning;
|
import com.dji.sdk.cloudapi.airsense.api.AbstractAirsenseService;
|
import com.dji.sdk.mqtt.MqttReply;
|
import com.dji.sdk.mqtt.events.TopicEventsRequest;
|
import com.dji.sdk.mqtt.events.TopicEventsResponse;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.messaging.MessageHeaders;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* @author wmm
|
* @version 0.1
|
* @date 2024/5/8
|
*/
|
@Service
|
@Slf4j
|
public class SDKAirsenseService extends AbstractAirsenseService {
|
|
//
|
// @Autowired
|
// private AbstractLivestreamService livestreamService;
|
//
|
// @Autowired
|
// private ObjectMapper mapper;
|
|
|
|
|
@Override
|
public TopicEventsResponse<MqttReply> airsenseWarning(TopicEventsRequest<List<AirsenseWarning>> request, MessageHeaders headers){
|
|
WebSocketServerPlayBack.sendInfo(request.toString());
|
return new TopicEventsResponse<MqttReply>().setData(MqttReply.success());
|
}
|
}
|
