|
@@ -10,40 +10,32 @@
|
|
|
* 5.不可二次分发开源参与同类竞品,如有想法可联系团队xiaonuobase@qq.com商议合作。
|
|
|
* 6.若您的项目无法满足以上几点,需要更多功能代码,获取Snowy商业授权许可,请在官网购买授权,地址为 https://www.xiaonuo.vip
|
|
|
*/
|
|
|
-package vip.xiaonuo.modular.env.envdevice.service.impl;
|
|
|
+package vip.xiaonuo.modular.env.envDevice.service.impl;
|
|
|
|
|
|
import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.collection.CollStreamUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
|
|
-import cn.hutool.core.util.StrUtil;
|
|
|
-import cn.hutool.json.JSONUtil;
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.stereotype.Service;
|
|
|
import org.springframework.transaction.annotation.Transactional;
|
|
|
-import vip.xiaonuo.auth.core.util.StpLoginUserUtil;
|
|
|
-import vip.xiaonuo.common.enums.CommonSortOrderEnum;
|
|
|
import vip.xiaonuo.common.exception.CommonException;
|
|
|
-import vip.xiaonuo.common.listener.CommonDataChangeEventCenter;
|
|
|
import vip.xiaonuo.common.page.CommonPageRequest;
|
|
|
import vip.xiaonuo.common.pojo.CommonResult;
|
|
|
-import vip.xiaonuo.core.enums.EnvDataTypeEnum;
|
|
|
import vip.xiaonuo.modular.base.baseConfig.entity.BaseConfig;
|
|
|
import vip.xiaonuo.modular.base.baseConfig.mapper.BaseConfigMapper;
|
|
|
import vip.xiaonuo.modular.base.pigpen.entity.BasePigpen;
|
|
|
import vip.xiaonuo.modular.base.pigpen.mapper.BasePigpenMapper;
|
|
|
-import vip.xiaonuo.modular.energy.energyDevice.entity.EnergyDevice;
|
|
|
import vip.xiaonuo.modular.env.entity.EnvDeviceEquipment;
|
|
|
-import vip.xiaonuo.modular.env.envdevice.entity.EnvDevice;
|
|
|
-import vip.xiaonuo.modular.env.envdevice.entity.vo.EnvDeviceCountVo;
|
|
|
-import vip.xiaonuo.modular.env.envdevice.mapper.EnvDeviceMapper;
|
|
|
-import vip.xiaonuo.modular.env.envdevice.param.*;
|
|
|
-import vip.xiaonuo.modular.env.envdevice.service.EnvDeviceService;
|
|
|
+import vip.xiaonuo.modular.env.envDevice.entity.EnvDevice;
|
|
|
+import vip.xiaonuo.modular.env.envDevice.entity.vo.EnvDeviceCountVo;
|
|
|
+import vip.xiaonuo.modular.env.envDevice.mapper.EnvDeviceMapper;
|
|
|
+import vip.xiaonuo.modular.env.envDevice.param.*;
|
|
|
+import vip.xiaonuo.modular.env.envDevice.service.EnvDeviceService;
|
|
|
import vip.xiaonuo.modular.env.mapper.EnvDeviceEquipmentMapper;
|
|
|
|
|
|
-import javax.validation.constraints.NotBlank;
|
|
|
import java.text.NumberFormat;
|
|
|
import java.util.*;
|
|
|
import java.util.stream.Collectors;
|
|
@@ -117,20 +109,28 @@ public class EnvDeviceServiceImpl extends ServiceImpl<EnvDeviceMapper, EnvDevice
|
|
|
.eq("device_code", envDeviceAddParam.getDeviceCode())
|
|
|
.or().eq("install_position", envDeviceAddParam.getInstallPosition());
|
|
|
if (ObjectUtil.isEmpty(envDeviceMapper.selectOne(queryWrapper))) {
|
|
|
- for (int i = 0; i < envDeviceAddParam.getFanNum(); i++) {
|
|
|
+ for (int i = 1; i <= envDeviceAddParam.getFanNum(); i++) {
|
|
|
EnvDeviceEquipment equipment = new EnvDeviceEquipment();
|
|
|
equipment.setDeviceCode(envDeviceAddParam.getDeviceCode());
|
|
|
- equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "01");
|
|
|
+ if (i < 10){
|
|
|
+ equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "010"+i);
|
|
|
+ }else {
|
|
|
+ equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "01"+i);
|
|
|
+ }
|
|
|
equipment.setDeviceName(envDeviceAddParam.getDeviceName());
|
|
|
equipment.setCreateTime(new Date());
|
|
|
equipment.setOrgId(envDeviceAddParam.getOrgId());
|
|
|
equipment.setDeviceType(0);
|
|
|
equipmentMapper.insert(equipment);
|
|
|
}
|
|
|
- for (int i = 0; i < envDeviceAddParam.getCurtainNum(); i++) {
|
|
|
+ for (int i = 1; i <= envDeviceAddParam.getCurtainNum(); i++) {
|
|
|
EnvDeviceEquipment equipment = new EnvDeviceEquipment();
|
|
|
equipment.setDeviceCode(envDeviceAddParam.getDeviceCode());
|
|
|
- equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "01");
|
|
|
+ if (i < 10){
|
|
|
+ equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "020"+i);
|
|
|
+ }else {
|
|
|
+ equipment.setChipCode(envDeviceAddParam.getDeviceCode() + "02"+i);
|
|
|
+ }
|
|
|
equipment.setDeviceName(envDeviceAddParam.getDeviceName());
|
|
|
equipment.setCreateTime(new Date());
|
|
|
equipment.setOrgId(envDeviceAddParam.getOrgId());
|
|
@@ -169,6 +169,37 @@ public class EnvDeviceServiceImpl extends ServiceImpl<EnvDeviceMapper, EnvDevice
|
|
|
.ne(EnvDevice::getId,envDevice.getId())) > 0) {
|
|
|
throw new CommonException("该位置已存在设备!");
|
|
|
}
|
|
|
+ equipmentMapper.delete(new QueryWrapper<EnvDeviceEquipment>().lambda()
|
|
|
+ .eq(EnvDeviceEquipment::getDeviceCode,envDeviceEditParam.getDeviceCode())
|
|
|
+ .eq(EnvDeviceEquipment::getOrgId,envDeviceEditParam.getOrgId()));
|
|
|
+ for (int i = 1; i <= envDeviceEditParam.getFanNum(); i++) {
|
|
|
+ EnvDeviceEquipment equipment = new EnvDeviceEquipment();
|
|
|
+ equipment.setDeviceCode(envDeviceEditParam.getDeviceCode());
|
|
|
+ if (i < 10){
|
|
|
+ equipment.setChipCode(envDeviceEditParam.getDeviceCode() + "010"+i);
|
|
|
+ }else {
|
|
|
+ equipment.setChipCode(envDeviceEditParam.getDeviceCode() + "01"+i);
|
|
|
+ }
|
|
|
+ equipment.setDeviceName(envDeviceEditParam.getDeviceName());
|
|
|
+ equipment.setCreateTime(new Date());
|
|
|
+ equipment.setOrgId(envDeviceEditParam.getOrgId());
|
|
|
+ equipment.setDeviceType(0);
|
|
|
+ equipmentMapper.insert(equipment);
|
|
|
+ }
|
|
|
+ for (int i = 1; i <= envDeviceEditParam.getCurtainNum(); i++) {
|
|
|
+ EnvDeviceEquipment equipment = new EnvDeviceEquipment();
|
|
|
+ equipment.setDeviceCode(envDeviceEditParam.getDeviceCode());
|
|
|
+ if (i < 10){
|
|
|
+ equipment.setChipCode(envDeviceEditParam.getDeviceCode() + "020"+i);
|
|
|
+ }else {
|
|
|
+ equipment.setChipCode(envDeviceEditParam.getDeviceCode() + "02"+i);
|
|
|
+ }
|
|
|
+ equipment.setDeviceName(envDeviceEditParam.getDeviceName());
|
|
|
+ equipment.setCreateTime(new Date());
|
|
|
+ equipment.setOrgId(envDeviceEditParam.getOrgId());
|
|
|
+ equipment.setDeviceType(1);
|
|
|
+ equipmentMapper.insert(equipment);
|
|
|
+ }
|
|
|
this.updateById(envDevice);
|
|
|
}
|
|
|
|
|
@@ -227,4 +258,11 @@ public class EnvDeviceServiceImpl extends ServiceImpl<EnvDeviceMapper, EnvDevice
|
|
|
List<BaseConfig> baseConfigs = baseConfigMapper.selectList(new QueryWrapper<BaseConfig>().lambda().eq(BaseConfig::getParentId, parentId).eq(BaseConfig::getOrgId, orgId));
|
|
|
return baseConfigs;
|
|
|
}
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<EnvDeviceEquipment> getEquipmentByUnitId(unitIdParam unitIdParam) {
|
|
|
+ EnvDevice envDevice = this.getOne(new QueryWrapper<EnvDevice>().lambda().eq(EnvDevice::getInstallPosition, unitIdParam.getUnitId()));
|
|
|
+
|
|
|
+ return null;
|
|
|
+ }
|
|
|
}
|