|
@@ -1,6 +1,7 @@
|
|
|
package cn.iocoder.yudao.module.pms.service;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
|
|
|
import cn.iocoder.yudao.framework.common.exception.ServiceException;
|
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
|
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
|
|
@@ -8,12 +9,17 @@ import cn.iocoder.yudao.module.pms.controller.admin.vo.IotDevicePageReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.controller.admin.vo.IotDeviceSaveReqVO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.IotDeviceDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.IotInfoClassifyDO;
|
|
|
+import cn.iocoder.yudao.module.pms.dal.dataobject.iotmodel.IotModelDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.IotDeviceMapper;
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.IotInfoClassifyMapper;
|
|
|
import cn.iocoder.yudao.module.pms.dal.dataobject.IotTreeDO;
|
|
|
import cn.iocoder.yudao.module.pms.dal.mysql.IotTreeMapper;
|
|
|
+import cn.iocoder.yudao.module.pms.dal.mysql.iotmodel.IotModelMapper;
|
|
|
+import cn.iocoder.yudao.module.pms.service.iotmodel.IotModelService;
|
|
|
+import cn.iocoder.yudao.module.system.dal.dataobject.dict.DictDataDO;
|
|
|
import cn.iocoder.yudao.module.system.enums.ErrorCodeConstants;
|
|
|
import cn.iocoder.yudao.module.system.service.dept.DeptService;
|
|
|
+import cn.iocoder.yudao.module.system.service.dict.DictDataService;
|
|
|
import com.google.common.collect.ImmutableMap;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.springframework.stereotype.Service;
|
|
@@ -47,6 +53,10 @@ public class IotDeviceServiceImpl implements IotDeviceService {
|
|
|
private IotTreeMapper iotTreeMapper;
|
|
|
@Resource
|
|
|
private DeptService deptService;
|
|
|
+ @Resource
|
|
|
+ private IotModelMapper iotModelMapper;
|
|
|
+ @Resource
|
|
|
+ private DictDataService dictDataService;
|
|
|
|
|
|
@Override
|
|
|
@Transactional(rollbackFor = Exception.class)
|
|
@@ -73,6 +83,17 @@ public class IotDeviceServiceImpl implements IotDeviceService {
|
|
|
iotTreeDO.setParentId(Objects.nonNull(iotTreeDOS.get(0)) ? iotTreeDOS.get(0).getId() : 0);
|
|
|
iotTreeMapper.insert(iotTreeDO);
|
|
|
}
|
|
|
+ //维护品牌
|
|
|
+ List<IotModelDO> iotModelDOS = iotModelMapper.selectByMap(ImmutableMap.of("brand", createReqVO.getBrand(), "name", createReqVO.getModel()));
|
|
|
+ if (CollUtil.isEmpty(iotModelDOS)) {
|
|
|
+ IotModelDO iotModelDO = new IotModelDO();
|
|
|
+ iotModelDO.setBrand(createReqVO.getBrand());
|
|
|
+ DictDataDO dictData = dictDataService.getDictData(createReqVO.getBrand());
|
|
|
+ iotModelDO.setBrandName(Objects.nonNull(dictData)?dictData.getLabel():"");
|
|
|
+ iotModelDO.setName(createReqVO.getModel());
|
|
|
+ iotModelDO.setStatus(CommonStatusEnum.ENABLE.getStatus());
|
|
|
+ iotModelMapper.insert(iotModelDO);
|
|
|
+ }
|
|
|
// 返回
|
|
|
return iotDevice.getId();
|
|
|
}
|