diff --git a/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/utils/IDUtils.java b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/utils/IDUtils.java new file mode 100644 index 0000000..490354d --- /dev/null +++ b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/utils/IDUtils.java @@ -0,0 +1,39 @@ +package com.bonus.common.core.utils; + +/** + * @author 黑子 + */ +public class IDUtils { + private static final byte[] LOCK = new byte[0]; + + // 位数,默认是8位 + private final static long W = 100000000; + + /** + * 传入文件 名称 + * @param fileName + * @return + */ + public static String getSuffix(String fileName){ + return fileName.substring(fileName.lastIndexOf('.')); + } + + public static void main(String[] args) { + System.err.println(createId()); + } + + /** + * 获取id + * @return + */ + public static String createId() { + long r = 0; + synchronized (LOCK) { + r = (long) ((Math.random() + 1) * W); + } + + return System.currentTimeMillis() + String.valueOf(r).substring(1); + } + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/ConstInfoController.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/ConstInfoController.java new file mode 100644 index 0000000..72a7c05 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/ConstInfoController.java @@ -0,0 +1,22 @@ +package com.bonus.base.basic.controller; + +import com.bonus.common.core.web.controller.BaseController; +import io.swagger.annotations.Api; +import lombok.Data; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author 黑子 + */ +@Api(tags = "施工信息管理") +@RestController +@RequestMapping("/constInfo") +public class ConstInfoController extends BaseController { + + + + + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DevController.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DevController.java deleted file mode 100644 index 264a781..0000000 --- a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DevController.java +++ /dev/null @@ -1,7 +0,0 @@ -package com.bonus.base.basic.controller; - -/** - * @author 黑子 - */ -public class DevController { -} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceController.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceController.java new file mode 100644 index 0000000..db08a13 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceController.java @@ -0,0 +1,77 @@ +package com.bonus.base.basic.controller; + +import com.bonus.base.basic.domain.BmProjectWorksite; +import com.bonus.base.basic.domain.DeviceAttrVo; +import com.bonus.base.basic.domain.DeviceVo; +import com.bonus.base.basic.service.DeviceService; +import com.bonus.base.common.annotation.PreventRepeatSubmit; +import com.bonus.common.core.web.controller.BaseController; +import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.common.core.web.page.TableDataInfo; +import com.bonus.common.log.annotation.SysLog; +import com.bonus.common.log.enums.OperaType; +import com.bonus.common.security.annotation.RequiresPermissions; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * @author 黑子 + */ +@Api(tags = "工程项目管理接口") +@RestController +@RequestMapping("/bm_project") +public class DeviceController extends BaseController { + + @Autowired + private DeviceService service; + + /** + * 查询作业现场列表 + */ + @ApiOperation(value = "查询感知设备信息列表") + @RequiresPermissions("tb:device:list") + @GetMapping("/list") + @SysLog(title = "设备管理", businessType = OperaType.INSERT, logType = 1,module = "设备管理->查询感知设备信息列表") + public TableDataInfo getPageList(DeviceVo deviceVo) { + startPage(); + List list = service.getPageList(deviceVo); + return getDataTable(list); + } + + + + /** + * 查询作业现场列表 + */ + @ApiOperation(value = "查询感知设备属性信息") + @RequiresPermissions("tb:device:attr") + @GetMapping("/list") + @SysLog(title = "设备管理", businessType = OperaType.INSERT, logType = 1,module = "设备管理->查询设备属性") + public TableDataInfo getAttrPageList(DeviceAttrVo vo) { + startPage(); + List list = service.getAttrPageList(vo); + return getDataTable(list); + } + @ApiOperation(value = "新增设备管理") + @PreventRepeatSubmit + @RequiresPermissions("tb:device:add") + @SysLog(title = "设备管理", businessType = OperaType.INSERT, logType = 1,module = "设备管理->新增感知设备") + @PostMapping + public AjaxResult addDevice(@RequestBody DeviceVo deviceVo) { + return service.addDevice(deviceVo); + } + + @ApiOperation(value = "新增设备管理") + @PreventRepeatSubmit + @RequiresPermissions("tb:attr:add") + @SysLog(title = "设备管理", businessType = OperaType.INSERT, logType = 1,module = "设备管理->新增设备属性") + @PostMapping + public AjaxResult addDeviceAttr(@RequestBody DeviceAttrVo vo) { + return service.addDeviceAttr(vo); + } + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceTypeController.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceTypeController.java new file mode 100644 index 0000000..e97c7dc --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/controller/DeviceTypeController.java @@ -0,0 +1,79 @@ +package com.bonus.base.basic.controller; + +import com.bonus.base.basic.domain.DeviceTypeVo; +import com.bonus.base.basic.domain.DeviceVo; +import com.bonus.base.basic.service.DeviceTypeService; +import com.bonus.base.common.annotation.PreventRepeatSubmit; +import com.bonus.common.core.web.controller.BaseController; +import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.common.core.web.page.TableDataInfo; +import com.bonus.common.log.annotation.SysLog; +import com.bonus.common.log.enums.OperaType; +import com.bonus.common.security.annotation.RequiresPermissions; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.List; + +/** + * @author 黑子 + */ +@Api(tags = "设备类型控制层管理") +@RestController +@RequestMapping("/devType") +public class DeviceTypeController extends BaseController { + + + @Autowired + private DeviceTypeService service; + /** + * 查询作业现场列表 + */ + @ApiOperation(value = "查询设备类型") + @RequiresPermissions("tb:type:list") + @GetMapping("/list") + @SysLog(title = "设备类型管理", businessType = OperaType.QUERY, logType = 1,module = "设备类型管理->查询设备类型") + public TableDataInfo getPageList(DeviceTypeVo vo) { + startPage(); + List list = service.getPageList(vo); + return getDataTable(list); + } + + + @ApiOperation(value = "新增设备类型") + @PreventRepeatSubmit + @RequiresPermissions("tb:type:add") + @SysLog(title = "设备类型管理", businessType = OperaType.INSERT, logType = 1,module = "设备类型管理->新增设备类型") + @PostMapping + public AjaxResult insertData(@RequestBody DeviceTypeVo vo) { + return service.insertData(vo); + } + + + + @ApiOperation(value = "修改设备类型") + @PreventRepeatSubmit + @RequiresPermissions("tb:type:update") + @SysLog(title = "设备类型管理", businessType = OperaType.UPDATE, logType = 1,module = "设备类型管理->修改设备类型") + @PostMapping + public AjaxResult updateData(@RequestBody DeviceTypeVo vo) { + return service.updateData(vo); + } + + + @ApiOperation(value = "删除设备类型") + @PreventRepeatSubmit + @RequiresPermissions("tb:type:del") + @SysLog(title = "设备类型管理", businessType = OperaType.UPDATE, logType = 1,module = "设备类型管理->删除设备类型") + @PostMapping + public AjaxResult deleteData(@RequestBody DeviceTypeVo vo) { + return service.deleteData(vo); + } + + + + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceAttrVo.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceAttrVo.java new file mode 100644 index 0000000..ffbca21 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceAttrVo.java @@ -0,0 +1,71 @@ +package com.bonus.base.basic.domain; + +import lombok.Data; + +import javax.naming.ldap.PagedResultsControl; + +/** + * 设备属性信息集合 + * @author 黑子 + */ +@Data +public class DeviceAttrVo { + /** + * 主键 + */ + private String id; + /** + * 设备id + */ + private String devId; + /** + * 设备名称 + */ + private String devName; + /** + * 属性id + */ + private String attrName; + /** + * 单位 + */ + private String attrUnit; + /** + * 值 + */ + private String attrValue; + /** + * 阈值max + */ + private String maxValue; + /** + * 阈值max + */ + private String minValue; + /** + * 变化值 + */ + private String changeVal; + /** + * 是否告警 + */ + private String isWarn; + /** + * 创建时间 + */ + private String createTime; + /** + * 采集时间 + */ + private String updateTime; + /** + * 级联编码 + */ + private String relCode; + /** + * 数据了下 + */ + private String dataType; + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceTypeVo.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceTypeVo.java new file mode 100644 index 0000000..cee2070 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceTypeVo.java @@ -0,0 +1,20 @@ +package com.bonus.base.basic.domain; + +import lombok.Data; + +/** + * @author 黑子 + */ +@Data +public class DeviceTypeVo { + + private String id; + + private String typeCode; + + private String typeName; + + private String remark; + + private String createTime; +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceVo.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceVo.java new file mode 100644 index 0000000..feaf564 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/domain/DeviceVo.java @@ -0,0 +1,62 @@ +package com.bonus.base.basic.domain; + +import lombok.Data; + +/** + * @author 黑子 + */ +@Data +public class DeviceVo { + + /** + * 主键 + */ + private String id; + /** + * 设备名称 + */ + private String devName; + /** + * 设备编码 + */ + private String devCode; + /** + * 设备类型 + */ + private String devType; + /** + * 设备编码 + */ + private String typeCode; + /** + * 级联编码 + */ + private String relCode; + /** + * 设备状态 + */ + private String status; + /** + * 边带id + */ + private String bdId; + /** + * 区域id + */ + private String areaId; + /** + * 创建时间 + */ + private String createTime; + + private String updateTime; + /** + * 删除状态 + */ + private String delFlag; + /** + * 关键字 + */ + private String keyWord; + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/ConstInfoMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/ConstInfoMapper.java new file mode 100644 index 0000000..a82e859 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/ConstInfoMapper.java @@ -0,0 +1,19 @@ +package com.bonus.base.basic.mapper; + +import org.apache.ibatis.annotations.Mapper; + +/** + * @author 黑子 + */ +@Mapper +public interface ConstInfoMapper { + + + + + + + + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceMapper.java new file mode 100644 index 0000000..6ae0d74 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceMapper.java @@ -0,0 +1,55 @@ +package com.bonus.base.basic.mapper; + +import com.bonus.base.basic.domain.DeviceAttrVo; +import com.bonus.base.basic.domain.DeviceVo; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * @author 黑子 + */ +@Mapper +public interface DeviceMapper { + + /** + * 分页查询 感知设备 + * @param deviceVo + * @return + */ + List getPageList(DeviceVo deviceVo); + + /** + * 查询设备属性值数据 + * @param vo + * @return + */ + List getAttrPageList(DeviceAttrVo vo); + + int getDevNumByRelCode(@Param("param") DeviceVo deviceVo,@Param("type") String number); + + /** + * 新增设备信息 + * @param deviceVo + * @return + */ + int insertDevice(DeviceVo deviceVo); + + /** + * 查询 属性编码是否重复 + * @param vo + * @param number + * @return + */ + int getDevAttrNumByRelCode(@Param("param")DeviceAttrVo vo,@Param("type") String number); + + /** + * 新增设备属性成功 + * @param vo + * @return + */ + int insertDeviceAttr(DeviceAttrVo vo); + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceTypeMapper.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceTypeMapper.java new file mode 100644 index 0000000..31caecd --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/mapper/DeviceTypeMapper.java @@ -0,0 +1,51 @@ +package com.bonus.base.basic.mapper; + +import com.bonus.base.basic.domain.DeviceTypeVo; +import org.apache.ibatis.annotations.Mapper; +import org.apache.ibatis.annotations.Param; + +import java.util.List; + +/** + * @author 黑子 + * 设备类型 数据层 + */ +@Mapper +public interface DeviceTypeMapper { + /** + * 分页查询 设备类型 管理 + * @param vo + * @return + */ + List getPageList(DeviceTypeVo vo); + + int getDataInfo(@Param("param") DeviceTypeVo vo,@Param("type") String number); + + /** + * 新增数据 + * @param vo + * @return + */ + int insertData(DeviceTypeVo vo); + + /** + * 修改数据 + * @param vo + * @return + */ + int updateData(DeviceTypeVo vo); + + /** + * 查询设备类型是否被使用 + * @param vo + * @return + */ + int getTypeUsed(DeviceTypeVo vo); + + /** + * 删除设备类型 + * @param vo + * @return + */ + int deleteData(DeviceTypeVo vo); +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/ConstInfoService.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/ConstInfoService.java new file mode 100644 index 0000000..851ab82 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/ConstInfoService.java @@ -0,0 +1,7 @@ +package com.bonus.base.basic.service; + +/** + * @author 黑子 + */ +public interface ConstInfoService { +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceService.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceService.java new file mode 100644 index 0000000..e3a0cc6 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceService.java @@ -0,0 +1,41 @@ +package com.bonus.base.basic.service; + +import com.bonus.base.basic.domain.DeviceAttrVo; +import com.bonus.base.basic.domain.DeviceVo; +import com.bonus.common.core.web.domain.AjaxResult; + +import java.util.List; + +/** + * @author 黑子 + */ +public interface DeviceService { + + /** + * 设备管理查询 + * @param deviceVo + * @return + */ + List getPageList(DeviceVo deviceVo); + + /** + * 设备属性分页查询 + * @param vo + * @return + */ + List getAttrPageList(DeviceAttrVo vo); + + /** + * 新增设备 + * @param deviceVo + * @return + */ + AjaxResult addDevice(DeviceVo deviceVo); + + /** + * 新增感知设备属性 + * @param vo + * @return + */ + AjaxResult addDeviceAttr(DeviceAttrVo vo); +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceTypeService.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceTypeService.java new file mode 100644 index 0000000..72db8fe --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/DeviceTypeService.java @@ -0,0 +1,41 @@ +package com.bonus.base.basic.service; + +import com.bonus.base.basic.domain.DeviceTypeVo; +import com.bonus.common.core.web.domain.AjaxResult; + +import java.util.List; + +/** + * @author 黑子 + * 设备类型管理业务层 + */ +public interface DeviceTypeService { + + /** + * + * @param deviceVo + * @return + */ + List getPageList(DeviceTypeVo deviceVo); + + /** + * 新增设备类型 + * @param vo + * @return + */ + AjaxResult insertData(DeviceTypeVo vo); + + /** + * 修改设备类型 + * @param vo + * @return + */ + AjaxResult updateData(DeviceTypeVo vo); + + /** + * 删除设备类型 + * @param vo + * @return + */ + AjaxResult deleteData(DeviceTypeVo vo); +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/ConstInfoServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/ConstInfoServiceImpl.java new file mode 100644 index 0000000..fb6712c --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/ConstInfoServiceImpl.java @@ -0,0 +1,18 @@ +package com.bonus.base.basic.service.impl; + +import com.bonus.base.basic.service.ConstInfoService; +import lombok.Data; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; + +/** + * @author 黑子 + */ +@Service +@Slf4j +public class ConstInfoServiceImpl implements ConstInfoService { + + + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceServiceImpl.java new file mode 100644 index 0000000..59dbe7a --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceServiceImpl.java @@ -0,0 +1,137 @@ +package com.bonus.base.basic.service.impl; + +import com.bonus.base.basic.domain.DeviceAttrVo; +import com.bonus.base.basic.domain.DeviceVo; +import com.bonus.base.basic.mapper.DeviceMapper; +import com.bonus.base.basic.service.DeviceService; +import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.common.log.annotation.SysLog; +import lombok.extern.slf4j.Slf4j; +import org.checkerframework.checker.units.qual.A; +import org.hibernate.validator.internal.util.StringHelper; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.ArrayList; +import java.util.List; +import java.util.Queue; + +/** + * @author 黑子 + * + */ +@Service +@Slf4j +public class DeviceServiceImpl implements DeviceService { + + @Autowired + private DeviceMapper mapper; + + /** + * + * @param deviceVo + * @return + */ + @Override + public List getPageList(DeviceVo deviceVo) { + List list=new ArrayList<>(); + try{ + list= mapper.getPageList(deviceVo); + }catch (Exception e){ + log.error(e.toString(),e); + } + return list; + } + + @Override + public List getAttrPageList(DeviceAttrVo vo) { + List list=new ArrayList<>(); + try{ + list= mapper.getAttrPageList(vo); + }catch (Exception e){ + log.error(e.toString(),e); + } + return list; + } + + /** + * 新增设备 + * @param deviceVo + * @return + */ + @Override + public AjaxResult addDevice(DeviceVo deviceVo) { + try{ + if(StringHelper.isNullOrEmptyString(deviceVo.getDevName())){ + return AjaxResult.error("请填写设备名称"); + } + if(StringHelper.isNullOrEmptyString(deviceVo.getDevType())){ + return AjaxResult.error("请选择设备类型"); + } + + if(StringHelper.isNullOrEmptyString(deviceVo.getDevCode())){ + return AjaxResult.error("请填写设备编码"); + } + if(!StringHelper.isNullOrEmptyString(deviceVo.getRelCode())){ + int num =mapper.getDevNumByRelCode(deviceVo,"1"); + if(num>0){ + return AjaxResult.error("级联编码已存在"); + } + } + int num =mapper.getDevNumByRelCode(deviceVo,"2"); + if(num>0){ + return AjaxResult.error("设备编码已存在"); + } + + num =mapper.getDevNumByRelCode(deviceVo,"3"); + if(num>0){ + return AjaxResult.error("设备名称已存在"); + } + int success=mapper.insertDevice(deviceVo); + if(success>0 ){ + return AjaxResult.success("新增成功"); + } + }catch (Exception e){ + log.error(e.toString(),e); + } + return AjaxResult.error("系统异常,新增失败"); + } + + /** + * 新增设备属性 + * @param vo + * @return + */ + @Override + public AjaxResult addDeviceAttr(DeviceAttrVo vo) { + try{ + if(StringHelper.isNullOrEmptyString(vo.getDevId())){ + return AjaxResult.error("请选择设备"); + } + if(StringHelper.isNullOrEmptyString(vo.getAttrName())){ + return AjaxResult.error("请填写属性名称"); + } + if(!StringHelper.isNullOrEmptyString(vo.getRelCode())){ + int num =mapper.getDevAttrNumByRelCode(vo,"1"); + if(num>0){ + return AjaxResult.error("级联编码已存在"); + } + } + int num =mapper.getDevAttrNumByRelCode(vo,"2"); + if(num>0){ + return AjaxResult.error("属性名称已存在"); + } + int success=mapper.insertDeviceAttr(vo); + if(success>0 ){ + return AjaxResult.success("新增成功"); + } + + }catch (Exception e){ + log.error(e.toString(),e); + } + + return AjaxResult.error("系统异常,新增失败"); + } + + +} diff --git a/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceTypeServiceImpl.java b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceTypeServiceImpl.java new file mode 100644 index 0000000..a925305 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/java/com/bonus/base/basic/service/impl/DeviceTypeServiceImpl.java @@ -0,0 +1,108 @@ +package com.bonus.base.basic.service.impl; + +import com.bonus.base.basic.domain.DeviceTypeVo; +import com.bonus.base.basic.mapper.DeviceTypeMapper; +import com.bonus.base.basic.service.DeviceTypeService; +import com.bonus.common.core.utils.DateUtils; +import com.bonus.common.core.utils.IDUtils; +import com.bonus.common.core.web.domain.AjaxResult; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.ArrayList; +import java.util.List; + +/** + * 设备类型管理 接口层 + * @author 黑子 + */ +@Service +@Slf4j +public class DeviceTypeServiceImpl implements DeviceTypeService { + + @Autowired + private DeviceTypeMapper mapper; + + @Override + public List getPageList(DeviceTypeVo vo) { + List list=new ArrayList<>(); + try{ + list=mapper.getPageList(vo); + }catch (Exception e){ + log.error(e.toString(),e); + } + return list; + } + + /** + * 新增设备类型 + * @param vo + * @return + */ + @Override + public AjaxResult insertData(DeviceTypeVo vo) { + try{ + int num=mapper.getDataInfo(vo,"1"); + if(num>0){ + return AjaxResult.error("设备类型已存在"); + } + num=mapper.getDataInfo(vo,"2"); + if(num>0){ + return AjaxResult.error("设备类型编码已存在"); + } + vo.setId(IDUtils.createId()); + vo.setCreateTime(DateUtils.getTime()); + num=mapper.insertData(vo); + if(num>0){ + return AjaxResult.success("添加成功"); + } + + }catch (Exception e){ + log.error(e.toString(),e); + } + return AjaxResult.error("添加失败,系统异常"); + } + + @Override + public AjaxResult updateData(DeviceTypeVo vo) { + try{ + int num=mapper.getDataInfo(vo,"1"); + if(num>0){ + return AjaxResult.error("设备类型已存在"); + } + num=mapper.getDataInfo(vo,"2"); + if(num>0){ + return AjaxResult.error("设备类型编码已存在"); + } + num=mapper.updateData(vo); + if(num>0){ + return AjaxResult.success("修改成功"); + } + + }catch (Exception e){ + log.error(e.toString(),e); + } + return AjaxResult.error("修改失败,系统异常"); + } + + @Override + public AjaxResult deleteData(DeviceTypeVo vo) { + try{ + int num=mapper.getTypeUsed(vo); + if(num>0){ + return AjaxResult.error("该设备类型下存在设备不允许删除"); + } + num=mapper.deleteData(vo); + if(num>0){ + return AjaxResult.success("修改成功"); + } + }catch (Exception e){ + log.error(e.toString(),e); + } + return AjaxResult.error("删除失败,系统异常"); + + } + + +} diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/ConstINfoMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/ConstINfoMapper.xml new file mode 100644 index 0000000..008c8ca --- /dev/null +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/ConstINfoMapper.xml @@ -0,0 +1,7 @@ + + + + + \ No newline at end of file diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceMapper.xml new file mode 100644 index 0000000..3745ce4 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceMapper.xml @@ -0,0 +1,82 @@ + + + + + insert into tb_device( + dev_name,dev_code, dev_type,type_code, rel_code, + status, bd_id,area_id,create_time,update_time,del_flag + )values (#{devName},#{devCode},#{devType},#{typeCode},#{relCode},#{status},#{bdId} + #{areaId},now(),now(),0) + + + insert into tb_device_attr( + id, dev_id, att_name, att_value, att_unit,create_time,update_time, rel_code, change_val, + is_warn, max_value,min_value, data_type + )values (#{devId},#{attrName},#{attrValue},#{attrUnit},now(),now(),#{relCode},#{changeVal}, + #{isWarn},#{maxValue},#{minValue},#{dataType} + ) + + + + + + + \ No newline at end of file diff --git a/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceTypeMapper.xml b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceTypeMapper.xml new file mode 100644 index 0000000..1d5d786 --- /dev/null +++ b/bonus-modules/bonus-base/src/main/resources/mapper/base/basic/DeviceTypeMapper.xml @@ -0,0 +1,61 @@ + + + + + + insert into tb_dev_type (id, type_name, type_code, remark,create_time, + update_time, del_flag)values (#{id},#{typeName},#{typeCode},#{remark},#{createTime},now(),0) + + + update tb_dev_type set + type_name=#{typeName}, + type_code=#{typeCode}, + remark=#{remark} + where id=#{id} + + + update tb_dev_type set del_flag=1 + where id=#{id} + + + + + \ No newline at end of file