|
|
@@ -80,11 +80,14 @@ public class IotProjectDeviceService extends ServiceImpl<IotProjectDeviceMapper,
|
|
|
}
|
|
|
//校验项目
|
|
|
iotProjectService.check(iotProjectDevicePara.getProjectId());
|
|
|
- //设备校验
|
|
|
- for (Long deviceId : iotProjectDevicePara.getDeviceIds()) {
|
|
|
- check(deviceId);
|
|
|
- }
|
|
|
+
|
|
|
iotProjectDevicePara.getDeviceIds().forEach(e -> {
|
|
|
+ //设备校验
|
|
|
+ IotDevice iotDevice = iotDeviceMapper.selectById(e);
|
|
|
+ if (Objects.isNull(iotDevice) || Global.DEL == iotDevice.getDelFlag()) {
|
|
|
+ throw new BusinessException(iotDevice.getId() + ":设备不存在");
|
|
|
+ }
|
|
|
+ //绑定校验
|
|
|
IotProjectDevice iotProjectDevice = iotProjectDeviceMapper.selectOne(new LambdaQueryWrapper<IotProjectDevice>()
|
|
|
.eq(IotProjectDevice::getDeviceId, e)
|
|
|
.eq(IotProjectDevice::getDelFlag, Global.UN_DEL)
|
|
|
@@ -95,6 +98,7 @@ public class IotProjectDeviceService extends ServiceImpl<IotProjectDeviceMapper,
|
|
|
} else {
|
|
|
//没有则新增
|
|
|
IotProjectDevice iotProjectDeviceA = new IotProjectDevice();
|
|
|
+ iotProjectDeviceA.setProductId(iotDevice.getProductId());
|
|
|
iotProjectDeviceA.setProjectId(iotProjectDevicePara.getProjectId());
|
|
|
iotProjectDeviceA.setDeviceId(e);
|
|
|
iotProjectDeviceMapper.insert(iotProjectDeviceA);
|