mirror of
https://github.com/SyncrowIOT/backend.git
synced 2025-11-27 13:24:53 +00:00
finished get status for batch devices endpoint
This commit is contained in:
@ -21,6 +21,7 @@ import {
|
|||||||
import {
|
import {
|
||||||
ControlDeviceDto,
|
ControlDeviceDto,
|
||||||
BatchControlDevicesDto,
|
BatchControlDevicesDto,
|
||||||
|
BatchStatusDevicesDto,
|
||||||
} from '../dtos/control.device.dto';
|
} from '../dtos/control.device.dto';
|
||||||
import { CheckRoomGuard } from 'src/guards/room.guard';
|
import { CheckRoomGuard } from 'src/guards/room.guard';
|
||||||
import { CheckUserHavePermission } from 'src/guards/user.device.permission.guard';
|
import { CheckUserHavePermission } from 'src/guards/user.device.permission.guard';
|
||||||
@ -275,4 +276,19 @@ export class DeviceController {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ApiBearerAuth()
|
||||||
|
@UseGuards(JwtAuthGuard)
|
||||||
|
@Get('status/batch')
|
||||||
|
async batchStatusDevices(
|
||||||
|
@Query() batchStatusDevicesDto: BatchStatusDevicesDto,
|
||||||
|
) {
|
||||||
|
try {
|
||||||
|
return await this.deviceService.batchStatusDevices(batchStatusDevicesDto);
|
||||||
|
} catch (error) {
|
||||||
|
throw new HttpException(
|
||||||
|
error.message || 'Internal server error',
|
||||||
|
error.status || HttpStatus.INTERNAL_SERVER_ERROR,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@ -38,3 +38,10 @@ export class BatchControlDevicesDto {
|
|||||||
@IsNotEmpty()
|
@IsNotEmpty()
|
||||||
public value: any;
|
public value: any;
|
||||||
}
|
}
|
||||||
|
export class BatchStatusDevicesDto {
|
||||||
|
@ApiProperty({
|
||||||
|
example: 'uuid1,uuid2,uuid3',
|
||||||
|
description: 'Comma-separated list of device UUIDs',
|
||||||
|
})
|
||||||
|
devicesUuid: string;
|
||||||
|
}
|
||||||
|
|||||||
@ -24,6 +24,7 @@ import {
|
|||||||
} from '../dtos/get.device.dto';
|
} from '../dtos/get.device.dto';
|
||||||
import {
|
import {
|
||||||
BatchControlDevicesDto,
|
BatchControlDevicesDto,
|
||||||
|
BatchStatusDevicesDto,
|
||||||
ControlDeviceDto,
|
ControlDeviceDto,
|
||||||
} from '../dtos/control.device.dto';
|
} from '../dtos/control.device.dto';
|
||||||
import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
|
import { convertKeysToCamelCase } from '@app/common/helper/camelCaseConverter';
|
||||||
@ -362,7 +363,29 @@ export class DeviceService {
|
|||||||
);
|
);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
async batchStatusDevices(batchStatusDevicesDto: BatchStatusDevicesDto) {
|
||||||
|
const { devicesUuid } = batchStatusDevicesDto;
|
||||||
|
const devicesUuidArray = devicesUuid.split(',');
|
||||||
|
|
||||||
|
try {
|
||||||
|
await this.checkAllDevicesHaveSameProductUuid(devicesUuidArray);
|
||||||
|
const statuses = await Promise.all(
|
||||||
|
devicesUuidArray.map(async (deviceUuid) => {
|
||||||
|
const result = await this.getDevicesInstructionStatus(deviceUuid);
|
||||||
|
return { deviceUuid, result };
|
||||||
|
}),
|
||||||
|
);
|
||||||
|
return {
|
||||||
|
status: statuses[0].result,
|
||||||
|
devices: statuses,
|
||||||
|
};
|
||||||
|
} catch (error) {
|
||||||
|
throw new HttpException(
|
||||||
|
error.message || 'Device Not Found',
|
||||||
|
error.status || HttpStatus.NOT_FOUND,
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
async checkAllDevicesHaveSameProductUuid(deviceUuids: string[]) {
|
async checkAllDevicesHaveSameProductUuid(deviceUuids: string[]) {
|
||||||
const firstDevice = await this.deviceRepository.findOne({
|
const firstDevice = await this.deviceRepository.findOne({
|
||||||
where: { uuid: deviceUuids[0] },
|
where: { uuid: deviceUuids[0] },
|
||||||
|
|||||||
Reference in New Issue
Block a user