|
@@ -6,6 +6,7 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
|
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
|
|
+import com.platform.entity.IotDevice;
|
|
|
import com.platform.entity.IotMod;
|
|
import com.platform.entity.IotMod;
|
|
|
import com.platform.entity.IotModGroup;
|
|
import com.platform.entity.IotModGroup;
|
|
|
import com.platform.enums.ErrorCodeEnum;
|
|
import com.platform.enums.ErrorCodeEnum;
|
|
@@ -16,6 +17,7 @@ import com.platform.request.mod.IotModRequest;
|
|
|
import com.platform.request.mod.IotModSaveRequest;
|
|
import com.platform.request.mod.IotModSaveRequest;
|
|
|
import com.platform.response.mod.IotModDetailResp;
|
|
import com.platform.response.mod.IotModDetailResp;
|
|
|
import com.platform.response.mod.IotModResp;
|
|
import com.platform.response.mod.IotModResp;
|
|
|
|
|
+import com.platform.service.IotDeviceService;
|
|
|
import com.platform.service.IotModGroupService;
|
|
import com.platform.service.IotModGroupService;
|
|
|
import com.platform.service.IotModService;
|
|
import com.platform.service.IotModService;
|
|
|
import lombok.RequiredArgsConstructor;
|
|
import lombok.RequiredArgsConstructor;
|
|
@@ -41,6 +43,8 @@ public class IotModManage {
|
|
|
|
|
|
|
|
private final IotModGroupService iotModGroupService;
|
|
private final IotModGroupService iotModGroupService;
|
|
|
|
|
|
|
|
|
|
+ private final IotDeviceService iotDeviceService;
|
|
|
|
|
+
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 分页查询
|
|
* 分页查询
|
|
@@ -51,8 +55,8 @@ public class IotModManage {
|
|
|
public PageResult<IotModResp> pageModList(IotModRequest request) {
|
|
public PageResult<IotModResp> pageModList(IotModRequest request) {
|
|
|
IPage<IotMod> page = new Page<>(request.getPageNum(), request.getPageSize());
|
|
IPage<IotMod> page = new Page<>(request.getPageNum(), request.getPageSize());
|
|
|
LambdaQueryWrapper<IotMod> queryWrapper = Wrappers.<IotMod>lambdaQuery()
|
|
LambdaQueryWrapper<IotMod> queryWrapper = Wrappers.<IotMod>lambdaQuery()
|
|
|
- .eq(IotMod::getModeGroupCode, request.getModeGroupCode())
|
|
|
|
|
- .eq(StringUtils.isNotBlank(request.getGuid()), IotMod::getGuid, request.getGuid())
|
|
|
|
|
|
|
+ .in(CollectionUtils.isNotEmpty(request.getModeGroupCodes()), IotMod::getModeGroupCode, request.getModeGroupCodes())
|
|
|
|
|
+ .eq(StringUtils.isNotBlank(request.getModCode()), IotMod::getGuid, request.getModCode())
|
|
|
.eq(StringUtils.isNotBlank(request.getName()), IotMod::getName, request.getName());
|
|
.eq(StringUtils.isNotBlank(request.getName()), IotMod::getName, request.getName());
|
|
|
List<IotMod> modList = iotModService.list(page, queryWrapper);
|
|
List<IotMod> modList = iotModService.list(page, queryWrapper);
|
|
|
|
|
|
|
@@ -64,10 +68,15 @@ public class IotModManage {
|
|
|
List<IotModResp> modPageRespList = new ArrayList<>();
|
|
List<IotModResp> modPageRespList = new ArrayList<>();
|
|
|
for (IotMod item : modList) {
|
|
for (IotMod item : modList) {
|
|
|
IotModResp iotPageResp = IotModResp.toIotPageResp(item);
|
|
IotModResp iotPageResp = IotModResp.toIotPageResp(item);
|
|
|
- //查询物理模型分组名称
|
|
|
|
|
|
|
+ //理模型分组名称
|
|
|
IotModGroup iotModGroup = iotModGroupService.getOne(Wrappers.<IotModGroup>lambdaQuery()
|
|
IotModGroup iotModGroup = iotModGroupService.getOne(Wrappers.<IotModGroup>lambdaQuery()
|
|
|
.eq(IotModGroup::getModeGroupCode, item.getModeGroupCode()));
|
|
.eq(IotModGroup::getModeGroupCode, item.getModeGroupCode()));
|
|
|
iotPageResp.setModeGroupName(iotModGroup.getName());
|
|
iotPageResp.setModeGroupName(iotModGroup.getName());
|
|
|
|
|
+
|
|
|
|
|
+ //设备数
|
|
|
|
|
+ List<IotDevice> list = iotDeviceService.list(Wrappers.<IotDevice>lambdaQuery().eq(IotDevice::getModCode, item.getModeGroupCode()));
|
|
|
|
|
+ iotPageResp.setNum(list.size());
|
|
|
|
|
+
|
|
|
modPageRespList.add(iotPageResp);
|
|
modPageRespList.add(iotPageResp);
|
|
|
}
|
|
}
|
|
|
return PageResult.of(modPageRespList.size(), request.getPageNum(), request.getPageSize(), modPageRespList);
|
|
return PageResult.of(modPageRespList.size(), request.getPageNum(), request.getPageSize(), modPageRespList);
|
|
@@ -96,6 +105,9 @@ public class IotModManage {
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
public Boolean updateMod(IotModSaveRequest request) {
|
|
public Boolean updateMod(IotModSaveRequest request) {
|
|
|
|
|
+ if (request.getId() == null) {
|
|
|
|
|
+ throw new IotException(ErrorCodeEnum.DATA_DELETE_FAIL, "物理模型主键id不能为null");
|
|
|
|
|
+ }
|
|
|
IotMod iotMod = IotMod.requestToIotMod(request);
|
|
IotMod iotMod = IotMod.requestToIotMod(request);
|
|
|
iotMod.setId(request.getId());
|
|
iotMod.setId(request.getId());
|
|
|
return iotModService.updateById(iotMod);
|
|
return iotModService.updateById(iotMod);
|
|
@@ -108,6 +120,9 @@ public class IotModManage {
|
|
|
* @return
|
|
* @return
|
|
|
*/
|
|
*/
|
|
|
public Boolean deleteMod(Long id) {
|
|
public Boolean deleteMod(Long id) {
|
|
|
|
|
+ if (id == null) {
|
|
|
|
|
+ throw new IotException(ErrorCodeEnum.DATA_DELETE_FAIL, "物理模型主键id不能为null");
|
|
|
|
|
+ }
|
|
|
return iotModService.removeById(id);
|
|
return iotModService.removeById(id);
|
|
|
|
|
|
|
|
}
|
|
}
|