109 lines
3.6 KiB
Java
109 lines
3.6 KiB
Java
package de.ph87.homeautomation.device;
|
|
|
|
import de.ph87.homeautomation.device.devices.Device;
|
|
import de.ph87.homeautomation.device.devices.DeviceDto;
|
|
import de.ph87.homeautomation.device.devices.DeviceShutter;
|
|
import de.ph87.homeautomation.device.devices.DeviceSwitch;
|
|
import de.ph87.homeautomation.property.Property;
|
|
import de.ph87.homeautomation.schedule.ScheduleWriteService;
|
|
import de.ph87.homeautomation.web.BadRequestException;
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import org.springframework.stereotype.Service;
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
|
import java.util.function.BiConsumer;
|
|
|
|
@Slf4j
|
|
@Service
|
|
@Transactional
|
|
@RequiredArgsConstructor
|
|
public class DeviceWriteService {
|
|
|
|
private final DeviceRepository deviceRepository;
|
|
|
|
private final DeviceReadService deviceReadService;
|
|
|
|
public DeviceDto createDeviceSwitch(final Property stateProperty) {
|
|
return createDeviceSwitch(null, stateProperty);
|
|
}
|
|
|
|
public DeviceDto createDeviceSwitch(final String title, final Property stateProperty) {
|
|
final DeviceSwitch deviceSwitch = new DeviceSwitch();
|
|
deviceSwitch.setTitle(getTitle(title, stateProperty));
|
|
deviceSwitch.setStateProperty(stateProperty);
|
|
deviceRepository.save(deviceSwitch);
|
|
return deviceReadService.toDto(deviceSwitch);
|
|
}
|
|
|
|
public DeviceDto createDeviceShutter(final Property positionProperty) {
|
|
return createDeviceShutter(null, positionProperty);
|
|
}
|
|
|
|
public DeviceDto createDeviceShutter(final String title, final Property positionProperty) {
|
|
final DeviceShutter deviceShutter = new DeviceShutter();
|
|
deviceShutter.setTitle(getTitle(title, positionProperty));
|
|
deviceShutter.setPositionProperty(positionProperty);
|
|
deviceRepository.save(deviceShutter);
|
|
return deviceReadService.toDto(deviceShutter);
|
|
}
|
|
|
|
public <T> DeviceDto set(final long id, final BiConsumer<Device, T> setter, final T value) {
|
|
final Device device = deviceReadService.getById(id);
|
|
setter.accept(device, value);
|
|
return deviceReadService.toDto(device);
|
|
}
|
|
|
|
public <T> DeviceDto setDeviceSwitch(final long id, final BiConsumer<DeviceSwitch, T> setter, final T value) {
|
|
final Device device = deviceReadService.getById(id);
|
|
if (!(device instanceof DeviceSwitch)) {
|
|
throw new BadRequestException("Not a DeviceSwitch: %s", device);
|
|
}
|
|
setter.accept((DeviceSwitch) device, value);
|
|
return deviceReadService.toDto(device);
|
|
}
|
|
|
|
public <T> DeviceDto setDeviceShutter(final long id, final BiConsumer<DeviceShutter, T> setter, final T value) {
|
|
final Device device = deviceReadService.getById(id);
|
|
if (!(device instanceof DeviceShutter)) {
|
|
throw new BadRequestException("Not a DeviceShutter: %s", device);
|
|
}
|
|
setter.accept((DeviceShutter) device, value);
|
|
return deviceReadService.toDto(device);
|
|
}
|
|
|
|
public void delete(final long id) {
|
|
deviceRepository.deleteById(id);
|
|
}
|
|
|
|
public DeviceDto create(final String type) {
|
|
switch (type) {
|
|
case "DeviceSwitch":
|
|
return createDeviceSwitch(null, null);
|
|
case "DeviceShutter":
|
|
return createDeviceShutter(null, null);
|
|
}
|
|
throw new RuntimeException("Not implemented type: " + type);
|
|
}
|
|
|
|
private String getTitle(final String title, final Property property) {
|
|
if (title != null) {
|
|
return title;
|
|
} else if (property != null) {
|
|
return property.getTitle();
|
|
} else {
|
|
return generateUnusedTitle();
|
|
}
|
|
}
|
|
|
|
private String generateUnusedTitle() {
|
|
int index = 0;
|
|
String title = null;
|
|
while (title == null || deviceRepository.existsByTitle(title)) {
|
|
title = ScheduleWriteService.NAME_PREFIX + ++index;
|
|
}
|
|
return title;
|
|
}
|
|
|
|
}
|