bonus
/
devicesmgt
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'dev-nx' of http://192.168.0.56:3000/bonus/devicesmgt into dev-nx

This commit is contained in:
sxu 2024-08-05 13:33:05 +08:00
parent 93a46f8842 0f670f7ac5
commit 1666b6fafb
12 changed files with 1049 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/config/ExceptionEnum.java
View File

@ -12,8 +12,14 @@ import lombok.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, "修改失败，请联系管理员！！！");
private Integer code;

2
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/config/FieldGenerator.java
View File

@ -14,7 +14,7 @@ public class FieldGenerator {
public static String generateField() {
LocalDate today = LocalDate.now();
String currentDate = today.format(DateTimeFormatter.ofPattern("yyyyMMdd"));
// 生成UUID并取后4位，转换为纯数字类型
// 生成UUID并取后7位，转换为纯数字类型
String uuid = UUID.randomUUID().toString().replaceAll("-", "");
String uuidLast4Digits = uuid.substring(uuid.length() - 7);
int uuidLast4DigitsNumeric = Integer.parseInt(uuidLast4Digits, 16);

149
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/controller/IotMachineController.java Normal file
View File

@ -0,0 +1,149 @@
package com.bonus.sgzb.material.controller;
import com.bonus.sgzb.common.core.web.controller.BaseController;
import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.common.core.web.page.TableDataInfo;
import com.bonus.sgzb.material.domain.IotDto;
import com.bonus.sgzb.material.domain.IotRecordVo;
import com.bonus.sgzb.material.domain.IotVo;
import com.bonus.sgzb.material.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 java.util.List;
/**
* @Author
* @create 2024/8/5
* 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<IotVo> 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);
}
/**
* 根据类型id查询设备绑定列表
* @param iotDto
* @return
*/
@ApiOperation("根据类型id查询设备绑定列表")
@GetMapping("/getTypeList")
public TableDataInfo getTypeList(IotDto iotDto) {
startPage();
log.info("根据类型id查询设备绑定列表传参：{}", iotDto);
List<IotVo> typeList = iotMachineService.getTypeList(iotDto);
return getDataTable(typeList);
}
/**
* 根据iot设备类型查询设备编码
* @param iotDto
* @return
*/
@ApiOperation("根据iot设备类型查询设备编码")
@GetMapping("/selectList")
public AjaxResult selectList(IotDto iotDto) {
log.info("根据iot设备类型查询设备编码：{}", iotDto);
return iotMachineService.selectList(iotDto);
}
/**
* 根据iot设备获取绑定记录（分页）
* @param iotDto
* @return
*/
@ApiOperation("根据iot设备获取绑定记录（分页）")
@GetMapping("/getRecordList")
public TableDataInfo getRecordList(IotDto iotDto) {
startPage();
log.info("根据iot设备获取绑定记录（分页）：{}", iotDto);
List<IotRecordVo> list = iotMachineService.getRecordList(iotDto);
return getDataTable(list);
}
/**
* 根据iot设备获取绑定记录（全量不分页，供前端数据使用）
* @param iotDto
* @return
*/
@ApiOperation("根据iot设备获取绑定记录（全量不分页，供前端数据使用）")
@GetMapping("/getRecordListAll")
public AjaxResult getRecordListAll(IotDto iotDto) {
List<IotRecordVo> list = iotMachineService.getRecordList(iotDto);
return AjaxResult.success(list);
}
}

20
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/domain/IotCodeVo.java Normal file
View File

@ -0,0 +1,20 @@
package com.bonus.sgzb.material.domain;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @Author ma_sh
* @create 2024/7/11 15:21
*/
@Data
public class IotCodeVo {
/** iot设备ID */
@ApiModelProperty(value = "iot设备ID")
private Long iotId;
/** iot设备编码 */
@ApiModelProperty(value = "iot设备编码")
private String iotCode;
}

79
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/domain/IotDto.java Normal file
View File

@ -0,0 +1,79 @@
package com.bonus.sgzb.material.domain;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
import java.util.Date;
/**
* @Author ma_sh
* @create 2024/7/4 17:10
* 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 maCode;
/** iot设备类型 */
@ApiModelProperty(value = "iot设备类型")
private String iotType;
@ApiModelProperty(value = "iot设备类型id")
private String iotTypeId;
/** iot设备编码 */
@ApiModelProperty(value = "iot设备编码")
private String iotCode;
/** iot设备状态 (0 在线， 1 下线)*/
@ApiModelProperty(value = "iot设备状态 (0 在线， 1 下线)")
private int iotStatus;
/** iot设备二维码 */
@ApiModelProperty(value = "iot设备二维码")
private String qrCode;
/** 创建人 */
@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;
}

37
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/domain/IotRecordVo.java Normal file
View File

@ -0,0 +1,37 @@
package com.bonus.sgzb.material.domain;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @Author ma_sh
* @create 2024/7/11 15:55
* @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 = "绑定类型id")
private Long typeId;
@ApiModelProperty(value = "绑定类型名称")
private String typeName;
@ApiModelProperty(value = "设备编码")
private String maCode;
@ApiModelProperty(value = "绑定时间")
private String bindTime;
/** 解绑时间 */
@ApiModelProperty(value = "解绑时间")
private String unBindTime;
}

21
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/domain/IotTypeVo.java Normal file
View File

@ -0,0 +1,21 @@
package com.bonus.sgzb.material.domain;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @Author ma_sh
* @create 2024/7/11 14:57
*/
@Data
public class IotTypeVo {
@ApiModelProperty(value = "iot设备类型id")
private String iotTypeId;
@ApiModelProperty(value = "父级id")
private String pId;
@ApiModelProperty(value = "iot设备类型名称")
private String iotTypeName;
}

62
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/domain/IotVo.java Normal file
View File

@ -0,0 +1,62 @@
package com.bonus.sgzb.material.domain;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @Author ma_sh
* @create 2024/7/4 17:00
* iot设备管理返回vo
*/
@Data
public class IotVo {
/** iot设备ID */
@ApiModelProperty(value = "iot设备ID")
private Long id;
/** iot设备ID */
@ApiModelProperty(value = "iot设备ID")
private Long iotId;
/** iot设备类型 */
@ApiModelProperty(value = "iot设备类型")
private String iotType;
/** iot设备类型名称 */
@ApiModelProperty(value = "iot设备类型名称")
private String iotTypeName;
/** iot设备编码 */
@ApiModelProperty(value = "iot设备编码")
private String iotCode;
/** iot设备状态 (0 在线， 1 下线)*/
@ApiModelProperty(value = "iot设备状态 (0 在线， 1 下线)")
private int iotStatus;
/** iot设备二维码 */
@ApiModelProperty(value = "iot设备二维码")
private String qrCode;
/** 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;
}

120
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/mapper/IotMachineMapper.java Normal file
View File

@ -0,0 +1,120 @@
package com.bonus.sgzb.material.mapper;
import com.bonus.sgzb.material.domain.*;
import org.apache.ibatis.annotations.Mapper;
import java.util.List;
/**
* @Author ma_sh
* @create 2024/7/4 16:28
* iot设备管理mapper层
*/
@Mapper
public interface IotMachineMapper {
/**
* 根据iotCode查询iotCode是否存在
* @param iotDto
* @return
*/
IotVo selectIotCode(IotDto iotDto);
/**
* 根据qrCode查询qrCode是否存在
* @param qrCode
* @return
*/
int selectQrCode(String qrCode);
/**
* 添加iot设备
* @param iotDto
* @return
*/
int add(IotDto iotDto);
/**
* 修改iot设备
* @param iotDto
* @return
*/
int update(IotDto iotDto);
/**
* 根据iotCode查询iotCode是否存在
* @param iotDto
* @return
*/
List<IotVo> 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);
/**
* 根据类型id查询设备绑定列表
* @param iotDto
* @return
*/
List<IotVo> getTypeList(IotDto iotDto);
/**
* 查询设备类型
* @return
*/
List<IotTypeVo> selectList();
/**
* 根据iotTypeId查询设备编码
* @param iotTypeId
* @return
*/
List<IotCodeVo> selectCodeList(String iotTypeId);
/**
* 根据iotTypeId查询设备编码
* @param iotDto
* @return
*/
List<IotRecordVo> getRecordList(IotDto iotDto);
}

79
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/service/IotMachineService.java Normal file
View File

@ -0,0 +1,79 @@
package com.bonus.sgzb.material.service;
import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.material.domain.IotDto;
import com.bonus.sgzb.material.domain.IotRecordVo;
import com.bonus.sgzb.material.domain.IotVo;
import java.util.List;
/**
* @Author ma_sh
* @create 2024/7/4 16:25
* iot设备管理服务层
*/
public interface IotMachineService {
/**
* 添加设备
* @param iotDto
* @return
*/
AjaxResult add(IotDto iotDto);
/**
* 修改设备
* @param iotDto
* @return
*/
AjaxResult update(IotDto iotDto);
/**
* 获取设备列表
* @param iotDto
* @return
*/
List<IotVo> getIotList(IotDto iotDto);
/**
* 删除设备
* @param iotId
* @return
*/
AjaxResult deleteById(Long iotId);
/**
* 绑定设备
* @param iotDto
* @return
*/
AjaxResult bind(IotDto iotDto);
/**
* 解绑设备
* @param iotDto
* @return
*/
AjaxResult unbind(IotDto iotDto);
/**
* 根据类型id查询设备绑定列表
* @param iotDto
* @return
*/
List<IotVo> getTypeList(IotDto iotDto);
/**
* 根据iot设备类型查询设备编码
* @param iotDto
* @return
*/
AjaxResult selectList(IotDto iotDto);
/**
* 获取设备记录列表
* @param iotDto
* @return
*/
List<IotRecordVo> getRecordList(IotDto iotDto);
}

268
sgzb-modules/sgzb-material/src/main/java/com/bonus/sgzb/material/service/impl/IotMachineServiceImpl.java Normal file
View File

@ -0,0 +1,268 @@
package com.bonus.sgzb.material.service.impl;
import com.bonus.sgzb.common.core.web.domain.AjaxResult;
import com.bonus.sgzb.common.security.utils.SecurityUtils;
import com.bonus.sgzb.material.config.ExceptionEnum;
import com.bonus.sgzb.material.config.FieldGenerator;
import com.bonus.sgzb.material.domain.*;
import com.bonus.sgzb.material.mapper.IotMachineMapper;
import com.bonus.sgzb.material.service.IotMachineService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;
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.getIotType() == null) {
return AjaxResult.error(ExceptionEnum.PARAM_NULL.getCode(), ExceptionEnum.PARAM_NULL.getMsg());
}
//根据前端传入设备编号判重
IotVo iotVo = iotMachineMapper.selectIotCode(iotDto);
if (iotVo != null) {
return AjaxResult.error(ExceptionEnum.IOT_CODE_DUPLICATE.getCode(), ExceptionEnum.IOT_CODE_DUPLICATE.getMsg());
}
//后端生成二维码编号，需判重，确保表中数据唯一性
String qrCode = FieldGenerator.generateField();
// 设置最大尝试次数10，避免无限循环
int maxAttempts = 10;
for (int attempt = 0; attempt < maxAttempts; attempt++) {
if (iotMachineMapper.selectQrCode(qrCode) == 0) {
iotDto.setQrCode(qrCode);
// 找到唯一的qrCode，退出循环
break;
} else {
// 生成新的qrCode
qrCode = FieldGenerator.generateField();
}
}
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 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<IotVo> 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());
}
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());
// 添加事务回滚逻辑，保证全部成功或者全部失败
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return AjaxResult.error(ExceptionEnum.UPDATE_TO_DATABASE.getCode(), ExceptionEnum.UPDATE_TO_DATABASE.getMsg());
}
return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), res);
}
/**
* 解绑设备
*
* @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());
// 添加事务回滚逻辑，保证入库全部成功或者全部失败
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return AjaxResult.error(ExceptionEnum.UPDATE_TO_DATABASE.getCode(), ExceptionEnum.UPDATE_TO_DATABASE.getMsg());
}
return AjaxResult.success(ExceptionEnum.SUCCESS.getMsg(), res);
}
/**
* 根据类型id查询设备绑定列表
*
* @param iotDto
* @return
*/
@Override
public List<IotVo> getTypeList(IotDto iotDto) {
if (iotDto == null || iotDto.getMaCode() == null) {
throw new RuntimeException(ExceptionEnum.PARAM_NULL.getMsg());
}
List<IotVo> iotVoList = iotMachineMapper.getTypeList(iotDto);
return iotVoList;
}
/**
* 根据iot设备类型查询设备编码
*
* @param iotDto
* @return
*/
@Override
public AjaxResult selectList(IotDto iotDto) {
if (iotDto != null && iotDto.getIotTypeId() != null) {
// 如果传入了iot设备类型，根据iot设备类型查询设备编码
List<IotCodeVo> iotCodeList = iotMachineMapper.selectCodeList(iotDto.getIotTypeId());
return AjaxResult.success(iotCodeList);
} else {
// 如果iotDto为null或者iotDto的iotType为null，单独查询iot设备类型列表
List<IotTypeVo> iotTypeList = iotMachineMapper.selectList();
return AjaxResult.success(iotTypeList);
}
}
/**
* 查询iot绑定记录
*
* @param iotDto
* @return
*/
@Override
public List<IotRecordVo> getRecordList(IotDto iotDto) {
if (iotDto == null || iotDto.getIotId() == null) {
throw new RuntimeException(ExceptionEnum.PARAM_NULL.getMsg());
}
List<IotRecordVo> iotRecordList = iotMachineMapper.getRecordList(iotDto);
return iotRecordList;
}
}

207
sgzb-modules/sgzb-material/src/main/resources/mapper/material/IotMachineMapper.xml Normal file
View File

@ -0,0 +1,207 @@
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.bonus.sgzb.material.mapper.IotMachineMapper">
<insert id="add">
insert into iot_machine
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="iotType != null">iot_type,</if>
<if test="iotCode != null and iotCode != ''">iot_code,</if>
iot_status,
<if test="qrCode != null">qr_code,</if>
bind_status,
del_flag,
<if test="createBy != null">create_by,</if>
create_time
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="iotType != null">#{iotType},</if>
<if test="iotCode != null and iotCode != ''">#{iotCode},</if>
0,
<if test="qrCode != null">#{qrCode},</if>
1,
0,
<if test="createBy != null">#{createBy},</if>
NOW()
</trim>
</insert>
<insert id="bind">
insert into iot_machine_bind
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="iotId != null">iot_id,</if>
<if test="typeId != null and typeId != ''">type_id,</if>
<if test="maCode != null">ma_code,</if>
<if test="binder != null">binder,</if>
bind_time
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
<if test="iotId != null">#{iotId},</if>
<if test="typeId != null and typeId != ''">#{typeId},</if>
<if test="maCode != null">#{maCode},</if>
<if test="binder != null">#{binder},</if>
NOW()
</trim>
</insert>
<update id="update">
UPDATE iot_machine
<trim prefix="SET" suffixOverrides=",">
<if test="iotType != null ">iot_type = #{iotType},</if>
<if test="iotCode != null">iot_code = #{iotCode},</if>
<if test="iotStatus != null">iot_status = #{iotStatus},</if>
<if test="updateBy != null">update_by = #{updateBy},</if>
update_time = NOW()
</trim>
WHERE id = #{iotId}
</update>
<update id="deleteById">
UPDATE iot_machine SET del_flag = '2' WHERE id = #{iotId}
</update>
<update id="updateBindStatus">
UPDATE iot_machine SET bind_status = '0', update_time = NOW() WHERE id = #{iotId}
</update>
<update id="unbind">
UPDATE iot_machine_bind SET unbinder = #{unBinder}, unbind_time = NOW() WHERE id = #{id}
</update>
<update id="updateUnBindStatus">
UPDATE iot_machine SET bind_status = '1', update_time = NOW() WHERE id = #{iotId}
</update>
<select id="selectQrCode" resultType="java.lang.Integer">
SELECT
COUNT(*)
FROM
iot_machine
WHERE
del_flag = '0'
AND qr_code = #{qrCode}
</select>
<select id="selectIotCode" resultType="com.bonus.sgzb.material.domain.IotVo">
SELECT
id AS iotId,
iot_code AS iotCode,
iot_type AS iotType,
iot_status AS iotStatus,
qr_code AS qrCode
FROM
iot_machine
WHERE
del_flag = '0'
AND iot_type = #{iotType}
AND iot_code = #{iotCode}
</select>
<select id="getIotList" resultType="com.bonus.sgzb.material.domain.IotVo">
SELECT
im.id AS iotId,
im.iot_code AS iotCode,
im.iot_type AS iotType,
im.iot_status AS iotStatus,
sd.name AS iotTypeName,
im.qr_code AS qrCode,
im.bind_status AS bindStatus
FROM
iot_machine im
LEFT JOIN sys_dic sd on im.iot_type = sd.id
WHERE
del_flag = '0'
<if test="keyWord != null and keyWord != ''">
AND (iot_type like concat('%', #{keyWord}, '%') or
iot_code like concat('%', #{keyWord}, '%')
)
</if>
</select>
<select id="selectById" resultType="com.bonus.sgzb.material.domain.IotVo">
SELECT
id AS iotId,
iot_code AS iotCode,
iot_type AS iotType,
iot_status AS iotStatus,
qr_code AS qrCode,
bind_status AS bindStatus
FROM
iot_machine
WHERE
del_flag = '0'
AND id = #{iotId}
</select>
<select id="getTypeList" resultType="com.bonus.sgzb.material.domain.IotVo">
SELECT
imb.id AS id,
im.iot_type AS iotType,
sd.name AS iotTypeName,
im.iot_code AS iotCode,
im.iot_status AS iotStatus,
imb.iot_id AS iotId,
imb.bind_time AS bindTime,
im.bind_status AS bindStatus
FROM
iot_machine im
LEFT JOIN sys_dic sd on im.iot_type = sd.id
LEFT JOIN iot_machine_bind imb ON im.id = imb.iot_id
WHERE
im.del_flag = '0'
AND im.bind_status = '0'
AND imb.unbind_time IS NULL
AND imb.ma_code = #{maCode}
<if test="keyWord != null and keyWord != ''">
AND (
im.iot_type like concat('%', #{keyWord}, '%') or
im.iot_code like concat('%', #{keyWord}, '%')
)
</if>
</select>
<select id="selectList" resultType="com.bonus.sgzb.material.domain.IotTypeVo">
SELECT
id AS iotTypeId,
p_id AS pId,
name AS iotTypeName
FROM
sys_dic
WHERE
status = '0'
AND p_id = '124'
</select>
<select id="selectCodeList" resultType="com.bonus.sgzb.material.domain.IotCodeVo">
SELECT
id AS iotId,
iot_code AS iotCode
FROM
iot_machine
WHERE
del_flag = '0'
AND iot_status = '0'
AND bind_status = '1'
AND iot_type = #{iotType}
</select>
<select id="getRecordList" resultType="com.bonus.sgzb.material.domain.IotRecordVo">
SELECT
imb.id AS id,
mt1.type_name AS typeName,
imb.ma_code AS maCode,
imb.type_id AS typeId,
imb.bind_time AS bindTime,
imb.unbind_time AS unBindTime
FROM
iot_machine_bind imb
LEFT JOIN ma_type mt ON imb.type_id = mt.type_id
LEFT JOIN ma_type mt1 ON mt.parent_id = mt1.type_id
LEFT JOIN ma_type mt2 ON mt1.parent_id = mt2.type_id
LEFT JOIN ma_type mt3 ON mt2.parent_id = mt3.type_id
LEFT JOIN iot_machine im ON imb.iot_id = im.id
WHERE
im.del_flag = '0'
AND im.id = #{iotId}
<if test="keyWord != null and keyWord != ''">
AND (
mt1.type_name like concat('%', #{keyWord}, '%') or
imb.ma_code like concat('%', #{keyWord}, '%')
)
</if>
</select>
</mapper>