diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/common/enums/ExceptionEnum.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/common/enums/ExceptionEnum.java new file mode 100644 index 0000000..bb646ac --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/common/enums/ExceptionEnum.java @@ -0,0 +1,38 @@ +package com.bonus.material.common.enums; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +/** + * 返回异常枚举类 + * @Author ma_sh + * @create 2025/01/24 + */ +@Getter +@AllArgsConstructor +public enum ExceptionEnum { + + PARAM_NULL(1001, "参数为空"), + IOT_CODE_DUPLICATE(1002, "设备编号重复"), + IOT_TO_DELETE(1003, "该iot设备绑定相关类型设备，无法删除"), + SUCCESS(200, "操作成功"), + SAVE_TO_DATABASE(500, "新增保存失败，请联系管理员！！！"), + DELETE_TO_DATABASE(500, "删除失败，请联系管理员！！！"), + BIND_TO_DATABASE(500, "绑定失败，请联系管理员！！！"), + UN_BIND_TO_DATABASE(500, "解绑失败，请联系管理员！！！"), + UPDATE_TO_DATABASE(500, "修改失败，请联系管理员！！！"), + + RETURN_DATA_IS_EMPTY(501, "返回数据为空！！"), + IOT_ENCODING_ERROR(502, "输入的IOT编码有误，请输入正确的编码！！！"); + private Integer code; + + private String msg; + + public Integer getCode() { + return code; + } + + public String getMsg() { + return msg; + } +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/controller/IotMachineController.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/controller/IotMachineController.java new file mode 100644 index 0000000..d90f1d7 --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/controller/IotMachineController.java @@ -0,0 +1,156 @@ +package com.bonus.material.device.controller; + +import com.bonus.common.core.utils.poi.ExcelUtil; +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.material.device.domain.IotDto; +import com.bonus.material.device.domain.vo.IotRecordVo; +import com.bonus.material.device.domain.vo.IotVo; +import com.bonus.material.device.service.IotMachineService; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.extern.slf4j.Slf4j; +import org.springframework.validation.annotation.Validated; +import org.springframework.web.bind.annotation.*; + +import javax.annotation.Resource; +import javax.servlet.http.HttpServletResponse; +import java.util.List; + +/** + * @Author ma_sh + * @create 2024/01/24 16:23 + * iot设备管理控制层 + */ +@Api(tags = " iot设备管理控制层") +@RestController +@RequestMapping("/iotMachine") +@Slf4j +public class IotMachineController extends BaseController { + + + @Resource + private IotMachineService iotMachineService; + + /** + * 获取设备管理列表 + */ + @ApiOperation(value = "获取设备管理列表") + @GetMapping("/getIotList") + public TableDataInfo getIotList(IotDto iotDto) { + log.info("获取设备管理列表传参：{}", iotDto); + startPage(); + List list = iotMachineService.getIotList(iotDto); + return getDataTable(list); + } + + /** + * 添加或者修改设备 + * @param iotDto + * @return + */ + @ApiOperation("添加或者修改设备") + @PostMapping("/addOrUpdate") + public AjaxResult addOrUpdate(@Validated @RequestBody IotDto iotDto) { + log.info("添加或者修改设备传参：{}", iotDto); + if (iotDto.getIotId() != null) { + return iotMachineService.update(iotDto); + } + return iotMachineService.add(iotDto); + } + + /** + * 删除设备 + * @param iotId + * @return + */ + @ApiOperation(value = "删除设备") + @DeleteMapping("/deleteById/{iotId}") + public AjaxResult deleteByIds(@PathVariable("iotId") Long iotId) { + log.info("删除设备传参：{}", iotId); + return iotMachineService.deleteById(iotId); + } + + /** + * 绑定设备 + * @param iotDto + * @return + */ + @ApiOperation("绑定设备") + @PostMapping("/bind") + public AjaxResult bind(@Validated @RequestBody IotDto iotDto) { + log.info("绑定设备传参：{}", iotDto); + return iotMachineService.bind(iotDto); + } + + /** + * 解绑设备 + * @param iotDto + * @return + */ + @ApiOperation("解绑设备") + @PostMapping("/unbind") + public AjaxResult unbind(@Validated @RequestBody IotDto iotDto) { + log.info("解绑设备传参：{}", iotDto); + return iotMachineService.unbind(iotDto); + } + + /** + * 根据iot设备获取绑定记录（分页） + * @param iotDto + * @return + */ + @ApiOperation("根据iot设备获取绑定记录（分页）") + @GetMapping("/getRecordList") + public TableDataInfo getRecordList(IotDto iotDto) { + startPage(); + log.info("根据iot设备获取绑定记录（分页）：{}", iotDto); + List list = iotMachineService.getRecordList(iotDto); + return getDataTable(list); + } + + /** + * 导出绑定记录 + * @param response + * @param iotDto + */ + @PostMapping("/export") + public void export(HttpServletResponse response, IotDto iotDto) { + try { + List list = iotMachineService.getRecordList(iotDto); + ExcelUtil util = new ExcelUtil<>(IotRecordVo.class); + util.exportExcel(response, list, "绑定明细数据"); + } catch (Exception e) { + logger.error(e.toString(), e); + } + } + + @ApiOperation("获取定位") + @PostMapping("/getLocation") + public AjaxResult getLocation(@Validated @RequestBody IotDto iotDto) { + log.info("获取定位接口：{}", iotDto); + return AjaxResult.success(); + } + + @ApiOperation("查询行程") + @PostMapping("/searchItinerary") + public AjaxResult searchItinerary(@Validated @RequestBody IotDto iotDto) { + log.info("查询行程接口：{}", iotDto); + return AjaxResult.success(); + } + + @ApiOperation("查询停留点") + @PostMapping("/reportParkDetailByTime") + public AjaxResult reportParkDetailByTime(@Validated @RequestBody IotDto iotDto) { + log.info("查询停留点接口：{}", iotDto); + return AjaxResult.success(); + } + + @ApiOperation("报警记录") + @PostMapping("/reportAlarm") + public AjaxResult reportAlarm(@Validated @RequestBody IotDto iotDto) { + log.info("报警记录接口：{}", iotDto); + return AjaxResult.success(); + } +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/IotDto.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/IotDto.java new file mode 100644 index 0000000..df1f458 --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/IotDto.java @@ -0,0 +1,87 @@ +package com.bonus.material.device.domain; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +import java.util.Date; + +/** + * @Author ma_sh + * @create 2025/01/24 + * iot设备管理传参dto + */ +@Data +public class IotDto { + + /** iot设备ID */ + @ApiModelProperty(value = "iot设备ID") + private Long id; + + /** iot设备ID */ + @ApiModelProperty(value = "iot设备ID") + private Long iotId; + + /** 类型id */ + @ApiModelProperty(value = "类型id") + private Long typeId; + + @ApiModelProperty(value = "被绑定机具名称") + private String typeName; + + /** 被绑定机具编号 */ + @ApiModelProperty(value = "被绑定机具编号") + private String maCode; + + /** iot设备类型 */ + @ApiModelProperty(value = "iot设备类型") + private String iotType; + + @ApiModelProperty(value = "iot设备名称") + private String iotName; + + /** iot设备编码 */ + @ApiModelProperty(value = "iot设备编码") + private String iotCode; + + /** iot设备状态 (0 在线， 1 下线)*/ + @ApiModelProperty(value = "iot设备状态 (0 在线， 1 下线)") + private int iotStatus; + + @ApiModelProperty(value = "iot设备负责人") + private String iotManager; + + @ApiModelProperty(value = "地址") + private String address; + + @ApiModelProperty(value = "备注") + private String remark; + + /** 创建人 */ + @ApiModelProperty(value = "创建人") + private String createBy; + + /** 创建时间 */ + @ApiModelProperty(value = "创建时间") + private Date createTime; + + /** 更新人 */ + @ApiModelProperty(value = "更新人") + private String updateBy; + + /** 更新时间 */ + @ApiModelProperty(value = "更新时间") + private Date updateTime; + + /** 绑定人 */ + @ApiModelProperty(value = "绑定人") + private String binder; + + /** 解绑人 */ + @ApiModelProperty(value = "解绑人") + private String unBinder; + + /** 关键字 */ + @ApiModelProperty(value = "关键字") + private String keyWord; + +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotRecordVo.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotRecordVo.java new file mode 100644 index 0000000..9f1c20f --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotRecordVo.java @@ -0,0 +1,57 @@ +package com.bonus.material.device.domain.vo; + +import com.bonus.common.core.annotation.Excel; +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @Author ma_sh + * @create 2025/01/24 + * @Description iot绑定记录返回vo + */ +@Data +public class IotRecordVo { + + /** iot设备ID */ + @ApiModelProperty(value = "iot设备ID") + private Long id; + + @ApiModelProperty(value = "iot设备id") + private Long iotId; + + @ApiModelProperty(value = "绑定的装备名称") + @Excel(name = "装备名称") + private String typeName; + + @ApiModelProperty(value = "装备编码") + @Excel(name = "装备编码") + private String maCode; + + @ApiModelProperty(value = "是否解绑") + @Excel(name = "是否解绑", readConverterExp = "0=否,1=是") + private String bindStatus; + + @ApiModelProperty(value = "地址") + @Excel(name = "地址", width = 30) + private String address; + + @ApiModelProperty(value = "备注") + @Excel(name = "备注", width = 30) + private String remark; + + @ApiModelProperty(value = "iot设备负责人") + @Excel(name = "设备负责人") + private String iotManager; + + @ApiModelProperty(value = "绑定时间") + @Excel(name = "绑定时间") + private String bindTime; + + @ApiModelProperty(value = "解绑时间") + @Excel(name = "解绑时间") + private String unBindTime; + + @ApiModelProperty(value = "绑定天数") + @Excel(name = "绑定天数", cellType = Excel.ColumnType.NUMERIC) + private String bindDays; +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotVo.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotVo.java new file mode 100644 index 0000000..63023a0 --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/domain/vo/IotVo.java @@ -0,0 +1,71 @@ +package com.bonus.material.device.domain.vo; + +import io.swagger.annotations.ApiModelProperty; +import lombok.Data; + +/** + * @Author ma_sh + * @create 2025/01/24 + * iot设备管理返回vo + */ +@Data +public class IotVo { + + @ApiModelProperty(value = "绑定明细id") + private Long id; + + /** iot设备ID */ + @ApiModelProperty(value = "iot设备ID") + private Long iotId; + + /** iot设备类型 */ + @ApiModelProperty(value = "iot设备类型") + private String iotType; + + @ApiModelProperty(value = "iot设备名称") + private String iotName; + + /** iot设备编码 */ + @ApiModelProperty(value = "iot设备编码") + private String iotCode; + + @ApiModelProperty(value = "装备名称") + private String typeName; + + @ApiModelProperty(value = "装备编码") + private String maCode; + + /** iot设备状态 (0 在线， 1 下线)*/ + @ApiModelProperty(value = "iot设备状态 (0 在线， 1 下线)") + private int iotStatus; + + @ApiModelProperty(value = "iot设备负责人") + private String iotManager; + + @ApiModelProperty(value = "地址") + private String address; + + /** iot设备绑定状态 （0 已绑定、1 未绑定）*/ + @ApiModelProperty(value = "iot设备绑定状态 (0 已绑定、1 未绑定)") + private int bindStatus; + + /** 绑定人 */ + @ApiModelProperty(value = "绑定人") + private String binder; + + /** 绑定时间 */ + @ApiModelProperty(value = "绑定时间") + private String bindTime; + + /** 解绑人 */ + @ApiModelProperty(value = "解绑人") + private String unBinder; + + /** 解绑时间 */ + @ApiModelProperty(value = "解绑时间") + private String unBindTime; + + @ApiModelProperty(value = "备注") + private String remark; + +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/mapper/IotMachineMapper.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/mapper/IotMachineMapper.java new file mode 100644 index 0000000..33cac48 --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/mapper/IotMachineMapper.java @@ -0,0 +1,109 @@ +package com.bonus.material.device.mapper; + +import com.bonus.material.device.domain.IotDto; +import com.bonus.material.device.domain.vo.IotRecordVo; +import com.bonus.material.device.domain.vo.IotVo; +import org.apache.ibatis.annotations.Mapper; + +import java.util.List; + + +/** + * @Author ma_sh + * @create 2025/01/24 16:28 + * iot设备管理mapper层 + */ +@Mapper +public interface IotMachineMapper { + + /** + * 根据iotCode查询iotCode是否存在 + * @param iotDto + * @return + */ + IotVo selectIotCode(IotDto iotDto); + + /** + * 添加iot设备 + * @param iotDto + * @return + */ + int add(IotDto iotDto); + + /** + * 修改iot设备 + * @param iotDto + * @return + */ + int update(IotDto iotDto); + + /** + * 根据iotCode查询iotCode是否存在 + * @param iotDto + * @return + */ + List getIotList(IotDto iotDto); + + /** + * 根据iotId查询iotId是否存在 + * @param iotId + * @return + */ + IotVo selectById(Long iotId); + + /** + * 根据iotId删除iot设备 + * @param iotId + * @return + */ + int deleteById(Long iotId); + + /** + * 绑定iot设备 + * @param iotDto + * @return + */ + int bind(IotDto iotDto); + + /** + * 更新绑定状态 + * @param iotDto + * @return + */ + int updateBindStatus(IotDto iotDto); + + /** + * 解绑iot设备 + * @param iotDto + * @return + */ + int unbind(IotDto iotDto); + + /** + * 更新解绑状态 + * @param iotDto + * @return + */ + int updateUnBindStatus(IotDto iotDto); + + /** + * 根据iotTypeId查询设备编码 + * @param iotDto + * @return + */ + List getRecordList(IotDto iotDto); + + /** + * 保证设备名称不重复 + * @param iotDto + * @return + */ + IotVo selectByName(IotDto iotDto); + + /** + * 判断该装备是否已经绑定 + * @param maCode + * @return + */ + List getInfoList(String maCode); +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/IotMachineService.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/IotMachineService.java new file mode 100644 index 0000000..997dd9a --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/IotMachineService.java @@ -0,0 +1,66 @@ +package com.bonus.material.device.service; + +import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.material.device.domain.IotDto; +import com.bonus.material.device.domain.vo.IotRecordVo; +import com.bonus.material.device.domain.vo.IotVo; + +import java.util.List; + +/** + * @Author ma_sh + * @create 2025/01/24 16:25 + * iot设备管理服务层 + */ +public interface IotMachineService { + + /** + * 添加设备 + * @param iotDto + * @return + */ + AjaxResult add(IotDto iotDto); + + /** + * 修改设备 + * @param iotDto + * @return + */ + AjaxResult update(IotDto iotDto); + + /** + * 获取设备列表 + * @param iotDto + * @return + */ + List getIotList(IotDto iotDto); + + /** + * 删除设备 + * @param iotId + * @return + */ + AjaxResult deleteById(Long iotId); + + /** + * 绑定设备 + * @param iotDto + * @return + */ + AjaxResult bind(IotDto iotDto); + + /** + * 解绑设备 + * @param iotDto + * @return + */ + AjaxResult unbind(IotDto iotDto); + + /** + * 获取设备记录列表 + * @param iotDto + * @return + */ + List getRecordList(IotDto iotDto); + +} diff --git a/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/impl/IotMachineServiceImpl.java b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/impl/IotMachineServiceImpl.java new file mode 100644 index 0000000..2546fae --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/java/com/bonus/material/device/service/impl/IotMachineServiceImpl.java @@ -0,0 +1,234 @@ +package com.bonus.material.device.service.impl; + +import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.common.security.utils.SecurityUtils; +import com.bonus.material.common.enums.ExceptionEnum; +import com.bonus.material.device.domain.IotDto; +import com.bonus.material.device.domain.vo.IotRecordVo; +import com.bonus.material.device.domain.vo.IotVo; +import com.bonus.material.device.mapper.IotMachineMapper; +import com.bonus.material.device.service.IotMachineService; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.CollectionUtils; + +import javax.annotation.Resource; +import java.util.List; + +/** + * iot设备管理实现层 + * + * @author ma_sh + */ +@Service +@Slf4j +public class IotMachineServiceImpl implements IotMachineService { + + @Resource + private IotMachineMapper iotMachineMapper; + + /** + * 添加设备-保存 + * + * @param iotDto + * @return + */ + @Override + public AjaxResult add(IotDto iotDto) { + if (iotDto == null || iotDto.getIotCode() == null || iotDto.getIotName() == null) { + return AjaxResult.error(ExceptionEnum.PARAM_NULL.getCode(), ExceptionEnum.PARAM_NULL.getMsg()); + } + //保证设备名称不重复 + IotVo nameInfo = iotMachineMapper.selectByName(iotDto); + if (nameInfo != null) { + return AjaxResult.error("iot设备名称不能重复"); + } + IotVo iotVo = iotMachineMapper.selectIotCode(iotDto); + if (iotVo != null) { + return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getMsg()); + } + iotDto.setCreateBy(SecurityUtils.getLoginUser().getUserid().toString()); + try { + // 进行设备添加 + int res = iotMachineMapper.add(iotDto); + if (res == 0) { + // 如果添加失败，返回保存到数据库异常的错误信息 + throw new RuntimeException(ExceptionEnum.SAVE_TO_DATABASE.getMsg()); + } else { + // 添加成功，返回成功的消息和新增的记录数 + return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), res); + } + } catch (Exception e) { + log.error("Error saving to database: " + e.getMessage()); + // 捕获所有异常，返回通用的数据库操作异常信息 + return AjaxResult.error(ExceptionEnum.SAVE_TO_DATABASE.getCode(), ExceptionEnum.SAVE_TO_DATABASE.getMsg()); + } + } + + /** + * 设备管理-修改 + * + * @param iotDto + * @return + */ + @Override + public AjaxResult update(IotDto iotDto) { + if (iotDto == null || iotDto.getIotId() == null) { + return AjaxResult.error(ExceptionEnum.PARAM_NULL.getCode(), ExceptionEnum.PARAM_NULL.getMsg()); + } + IotVo nameInfo = iotMachineMapper.selectByName(iotDto); + if (nameInfo != null && !nameInfo.getIotId().equals(iotDto.getIotId())) { + return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getCode(),"设备名称不能重复"); + } + IotVo iotVo = iotMachineMapper.selectIotCode(iotDto); + if (iotVo != null && !iotVo.getIotId().equals(iotDto.getIotId())) { + return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getCode(), ExceptionEnum.IOT_CODE_DUPLICATE.getMsg()); + } + iotDto.setUpdateBy(SecurityUtils.getLoginUser().getUserid().toString()); + try { + //设备修改 + int res = iotMachineMapper.update(iotDto); + if (res == 0) { + // 如果修改失败，返回修改到数据库异常的错误信息 + throw new RuntimeException(ExceptionEnum.UPDATE_TO_DATABASE.getMsg()); + } else { + // 修改成功，返回成功的消息和修改的记录数 + return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), res); + } + } catch (Exception e) { + log.error("Error updating to database: " + e.getMessage()); + //捕获异常 + return AjaxResult.error(ExceptionEnum.UPDATE_TO_DATABASE.getCode(), ExceptionEnum.UPDATE_TO_DATABASE.getMsg()); + } + } + + /** + * 获取设备列表 + * + * @param iotDto + * @return + */ + @Override + public List getIotList(IotDto iotDto) { + return iotMachineMapper.getIotList(iotDto); + } + + /** + * 删除设备 + * + * @param iotId + * @return + */ + @Override + public AjaxResult deleteById(Long iotId) { + //先进行判断，绑定设备的iot设备无法删除 + IotVo iotVo = iotMachineMapper.selectById(iotId); + if (iotVo.getBindStatus() == 0) { + return AjaxResult.error(ExceptionEnum.IOT_TO_DELETE.getCode(), ExceptionEnum.IOT_TO_DELETE.getMsg()); + } + try { + // 执行设备删除操作 + int res = iotMachineMapper.deleteById(iotId); + if (res == 0) { + // 如果删除操作未成功，返回删除数据库异常的错误信息 + return AjaxResult.error(ExceptionEnum.DELETE_TO_DATABASE.getCode(), ExceptionEnum.DELETE_TO_DATABASE.getMsg()); + } else { + // 删除成功，返回成功的消息和受影响的记录数 + return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), res); + } + } catch (Exception e) { + log.error("Error deleting from database: " + e.getMessage()); + // 捕获所有异常，返回通用的数据库操作异常信息 + return AjaxResult.error(ExceptionEnum.DELETE_TO_DATABASE.getCode(), ExceptionEnum.DELETE_TO_DATABASE.getMsg()); + } + } + + /** + * 绑定设备 + * + * @param iotDto + * @return + */ + @Override + @Transactional(rollbackFor = Exception.class) + public AjaxResult bind(IotDto iotDto) { + if (iotDto == null || iotDto.getIotId() == null || iotDto.getMaCode() == null) { + return AjaxResult.error(ExceptionEnum.PARAM_NULL.getCode(), ExceptionEnum.PARAM_NULL.getMsg()); + } + // 先判断该iot设备是否已经绑定 + IotVo iotVo = iotMachineMapper.selectById(iotDto.getIotId()); + if (iotVo.getBindStatus() == 0) { + return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getCode(),"该iot设备已绑定相关设备，无法再次进行绑定"); + } + // 判断该装备是否已经绑定iot设备 + List list = iotMachineMapper.getInfoList(iotDto.getMaCode()); + if (!CollectionUtils.isEmpty(list)) { + return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getCode(),"该装备已绑定其他iot设备，请勿重复绑定"); + } + iotDto.setBinder(SecurityUtils.getLoginUser().getUserid().toString()); + int res; + try { + //绑定设备 + res = iotMachineMapper.bind(iotDto); + if (res == 0) { + throw new RuntimeException(ExceptionEnum.BIND_TO_DATABASE.getMsg()); + } + //更新绑定状态 + res = iotMachineMapper.updateBindStatus(iotDto); + if (res == 0) { + throw new RuntimeException(ExceptionEnum.UPDATE_TO_DATABASE.getMsg()); + } + } catch (Exception e) { + log.error("设备绑定异常:{}", e.getMessage()); + throw new RuntimeException(ExceptionEnum.BIND_TO_DATABASE.getMsg()); + } + return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg()); + } + + /** + * 解绑设备 + * + * @param iotDto + * @return + */ + @Override + @Transactional(rollbackFor = Exception.class) + public AjaxResult unbind(IotDto iotDto) { + if (iotDto == null || iotDto.getIotId() == null || iotDto.getMaCode() == null) { + return AjaxResult.error(ExceptionEnum.PARAM_NULL.getCode(), ExceptionEnum.PARAM_NULL.getMsg()); + } + iotDto.setUnBinder(SecurityUtils.getLoginUser().getUserid().toString()); + int res; + try { + //解绑设备 + res = iotMachineMapper.unbind(iotDto); + if (res == 0) { + throw new RuntimeException(ExceptionEnum.UN_BIND_TO_DATABASE.getMsg()); + } + //更新绑定状态 + res = iotMachineMapper.updateUnBindStatus(iotDto); + if (res == 0) { + throw new RuntimeException(ExceptionEnum.UPDATE_TO_DATABASE.getMsg()); + } + } catch (Exception e) { + log.error("设备解绑异常:{}", e.getMessage()); + throw new RuntimeException(ExceptionEnum.UN_BIND_TO_DATABASE.getMsg()); + } + return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg()); + } + + /** + * 查询iot绑定记录 + * + * @param iotDto + * @return + */ + @Override + public List getRecordList(IotDto iotDto) { + if (iotDto == null || iotDto.getIotId() == null) { + throw new RuntimeException(ExceptionEnum.PARAM_NULL.getMsg()); + } + return iotMachineMapper.getRecordList(iotDto); + } +} diff --git a/bonus-modules/bonus-material-mall/src/main/resources/mapper/material/device/IotMachineMapper.xml b/bonus-modules/bonus-material-mall/src/main/resources/mapper/material/device/IotMachineMapper.xml new file mode 100644 index 0000000..f2dc950 --- /dev/null +++ b/bonus-modules/bonus-material-mall/src/main/resources/mapper/material/device/IotMachineMapper.xml @@ -0,0 +1,226 @@ + + + + + insert into iot_machine + + iot_name, + iot_code, + iot_status, + iot_manager, + bind_status, + del_flag, + create_by, + remark, + address, + create_time + + + #{iotName}, + #{iotCode}, + #{iotStatus}, + #{iotManager}, + 1, + 0, + #{createBy}, + #{remark}, + #{address}, + NOW() + + + + + insert into iot_machine_bind + + iot_id, + type_name, + ma_code, + binder, + bind_time + + + #{iotId}, + #{typeName}, + #{maCode}, + #{binder}, + NOW() + + + + + UPDATE iot_machine + + iot_name = #{iotName}, + iot_code = #{iotCode}, + iot_status = #{iotStatus}, + update_by = #{updateBy}, + remark = #{remark}, + iot_manager = #{iotManager}, + address = #{address}, + update_time = NOW() + + WHERE id = #{iotId} + + + + UPDATE iot_machine SET del_flag = '2' WHERE id = #{iotId} + + + + UPDATE iot_machine SET bind_status = '0', update_time = NOW() WHERE id = #{iotId} + + + + UPDATE iot_machine_bind SET unbinder = #{unBinder}, unbind_time = NOW() WHERE id = #{id} + + + + UPDATE iot_machine SET bind_status = '1', update_time = NOW() WHERE id = #{iotId} + + + + + + + + + + + + + + +