package com.dji.sample.manage.service.impl;
|
|
import com.dji.sample.common.error.CommonErrorEnum;
|
import com.dji.sample.manage.model.dto.DeviceDTO;
|
import com.dji.sample.manage.model.dto.DeviceDictionaryDTO;
|
import com.dji.sample.manage.model.dto.WorkspaceDTO;
|
import com.dji.sample.manage.service.IDeviceDictionaryService;
|
import com.dji.sample.manage.service.IDeviceService;
|
import com.dji.sample.manage.service.IWorkspaceService;
|
import com.dji.sdk.cloudapi.device.DeviceDomainEnum;
|
import com.dji.sdk.cloudapi.device.DeviceEnum;
|
import com.dji.sdk.cloudapi.organization.*;
|
import com.dji.sdk.cloudapi.organization.api.AbstractOrganizationService;
|
import com.dji.sdk.cloudapi.tsa.DeviceIconUrl;
|
import com.dji.sdk.cloudapi.tsa.IconUrlEnum;
|
import com.dji.sdk.mqtt.MqttReply;
|
import com.dji.sdk.mqtt.requests.TopicRequestsRequest;
|
import com.dji.sdk.mqtt.requests.TopicRequestsResponse;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.messaging.MessageHeaders;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.StringUtils;
|
|
import java.time.LocalDateTime;
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Optional;
|
|
/**
|
* @author sean
|
* @version 1.7
|
* @date 2023/7/7
|
*/
|
@Service
|
public class SDKOrganizationService extends AbstractOrganizationService {
|
|
@Autowired
|
private IDeviceService deviceService;
|
|
@Autowired
|
private IDeviceDictionaryService dictionaryService;
|
|
@Autowired
|
private IWorkspaceService workspaceService;
|
|
@Override
|
public TopicRequestsResponse<MqttReply<AirportBindStatusResponse>> airportBindStatus(TopicRequestsRequest<AirportBindStatusRequest> request, MessageHeaders headers) {
|
List<BindStatusResponseDevice> data = request.getData().getDevices();
|
|
List<BindStatusRequestDevice> bindStatusResult = new ArrayList<>();
|
for (BindStatusResponseDevice bindStatus : data) {
|
Optional<DeviceDTO> deviceOpt = deviceService.getDeviceBySn(bindStatus.getSn());
|
bindStatusResult.add(deviceOpt.isPresent() ? dto2BindStatus(deviceOpt.get()) :
|
new BindStatusRequestDevice().setSn(bindStatus.getSn()).setDeviceBindOrganization(false));
|
}
|
return new TopicRequestsResponse<MqttReply<AirportBindStatusResponse>>()
|
.setData(MqttReply.success(new AirportBindStatusResponse().setBindStatus(bindStatusResult)));
|
}
|
|
@Override
|
public TopicRequestsResponse<MqttReply<AirportOrganizationGetResponse>> airportOrganizationGet(TopicRequestsRequest<AirportOrganizationGetRequest> request, MessageHeaders headers) {
|
AirportOrganizationGetRequest organizationGet = request.getData();
|
if (!StringUtils.hasText(organizationGet.getDeviceBindingCode())) {
|
return new TopicRequestsResponse().setData(MqttReply.error(CommonErrorEnum.ILLEGAL_ARGUMENT));
|
}
|
|
Optional<WorkspaceDTO> workspace = workspaceService.getWorkspaceNameByBindCode(organizationGet.getDeviceBindingCode());
|
if (workspace.isEmpty()) {
|
return new TopicRequestsResponse().setData(MqttReply.error(CommonErrorEnum.GET_ORGANIZATION_FAILED));
|
}
|
|
return new TopicRequestsResponse<MqttReply<AirportOrganizationGetResponse>>()
|
.setData(MqttReply.success(new AirportOrganizationGetResponse()
|
.setOrganizationName(workspace.get().getWorkspaceName())));
|
}
|
|
@Override
|
public TopicRequestsResponse<MqttReply<AirportOrganizationBindResponse>> airportOrganizationBind(TopicRequestsRequest<AirportOrganizationBindRequest> request, MessageHeaders headers) {
|
List<OrganizationBindDevice> devices = request.getData().getBindDevices();
|
OrganizationBindDevice dock = null;
|
OrganizationBindDevice drone = null;
|
for (OrganizationBindDevice device : devices) {
|
DeviceDomainEnum val = device.getDeviceModelKey().getDomain();
|
if (val == DeviceDomainEnum.DOCK) {
|
dock = device;
|
}
|
if (val == DeviceDomainEnum.DRONE) {
|
drone = device;
|
}
|
}
|
|
Optional<DeviceDTO> dockOpt = bindDevice2Dto(dock);
|
Optional<DeviceDTO> droneOpt = bindDevice2Dto(drone);
|
List<OrganizationBindInfo> bindResult = new ArrayList<>();
|
|
droneOpt.ifPresent(droneDto -> {
|
dockOpt.get().setChildDeviceSn(droneDto.getDeviceSn());
|
boolean success = deviceService.saveOrUpdateDevice(droneDto);
|
bindResult.add(success ?
|
OrganizationBindInfo.success(droneDto.getDeviceSn()) :
|
new OrganizationBindInfo(droneDto.getDeviceSn(),
|
CommonErrorEnum.DEVICE_BINDING_FAILED.getCode())
|
);
|
});
|
boolean success = deviceService.saveOrUpdateDevice(dockOpt.get());
|
|
bindResult.add(success ?
|
OrganizationBindInfo.success(dock.getSn()) :
|
new OrganizationBindInfo(dock.getSn(),
|
CommonErrorEnum.DEVICE_BINDING_FAILED.getCode()));
|
|
return new TopicRequestsResponse<MqttReply<AirportOrganizationBindResponse>>()
|
.setData(MqttReply.success(new AirportOrganizationBindResponse().setErrInfos(bindResult)));
|
}
|
|
/**
|
* Convert device binding data object into database entity object.
|
*
|
* @param receiver
|
* @return
|
*/
|
public Optional<DeviceDTO> bindDevice2Dto(OrganizationBindDevice receiver) {
|
if (receiver == null) {
|
return Optional.empty();
|
}
|
|
DeviceEnum deviceModelKey = receiver.getDeviceModelKey();
|
Optional<DeviceDictionaryDTO> dictionaryOpt = dictionaryService.getOneDictionaryInfoByTypeSubType(
|
deviceModelKey.getDomain().getDomain(), deviceModelKey.getType().getType(),
|
deviceModelKey.getSubType().getSubType());
|
DeviceDTO.DeviceDTOBuilder builder = DeviceDTO.builder();
|
|
dictionaryOpt.ifPresent(entity ->
|
builder.deviceName(entity.getDeviceName())
|
.nickname(entity.getDeviceName())
|
.deviceDesc(entity.getDeviceDesc()));
|
Optional<WorkspaceDTO> workspace = workspaceService.getWorkspaceNameByBindCode(receiver.getDeviceBindingCode());
|
|
DeviceDTO dto = builder
|
.workspaceId(workspace.map(WorkspaceDTO::getWorkspaceId).orElse(receiver.getOrganizationId()))
|
.domain(deviceModelKey.getDomain())
|
.type(deviceModelKey.getType())
|
.subType(deviceModelKey.getSubType())
|
.deviceSn(receiver.getSn())
|
.boundStatus(true)
|
.loginTime(LocalDateTime.now())
|
.boundTime(LocalDateTime.now())
|
.iconUrl(new DeviceIconUrl()
|
.setSelectIconUrl(IconUrlEnum.SELECT_EQUIPMENT.getUrl())
|
.setNormalIconUrl(IconUrlEnum.NORMAL_EQUIPMENT.getUrl()))
|
.build();
|
if (StringUtils.hasText(receiver.getDeviceCallsign())) {
|
dto.setNickname(receiver.getDeviceCallsign());
|
} else {
|
Optional<DeviceDTO> deviceOpt = deviceService.getDeviceBySn(receiver.getSn());
|
dto.setNickname(deviceOpt.map(DeviceDTO::getNickname).orElse(dto.getNickname()));
|
}
|
return Optional.of(dto);
|
}
|
|
/**
|
* Convert device data transfer object into device binding status data object.
|
* @param device
|
* @return
|
*/
|
private BindStatusRequestDevice dto2BindStatus(DeviceDTO device) {
|
if (device == null) {
|
return null;
|
}
|
return new BindStatusRequestDevice()
|
.setSn(device.getDeviceSn())
|
.setDeviceCallsign(device.getNickname())
|
.setDeviceBindOrganization(device.getBoundStatus())
|
.setOrganizationId(device.getWorkspaceId())
|
.setOrganizationName(device.getWorkspaceName());
|
}
|
}
|
