diff --git a/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/RemoteTcpService.java b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/RemoteTcpService.java new file mode 100644 index 0000000..e6aa376 --- /dev/null +++ b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/RemoteTcpService.java @@ -0,0 +1,27 @@ +package com.bonus.system.api; + +import com.bonus.common.core.constant.SecurityConstants; +import com.bonus.common.core.constant.ServiceNameConstants; +import com.bonus.common.core.domain.R; +import com.bonus.system.api.domain.SysFile; +import com.bonus.system.api.domain.SysTcpMessage; +import com.bonus.system.api.factory.RemoteFileFallbackFactory; +import com.bonus.system.api.factory.RemoteTcpFallbackFactory; +import org.springframework.cloud.openfeign.FeignClient; +import org.springframework.http.MediaType; +import org.springframework.web.bind.annotation.*; +import org.springframework.web.multipart.MultipartFile; + +/** + * TCP服务 + * + * @author bonus + */ +@FeignClient(contextId = "RemoteTcpService", value = ServiceNameConstants.TCP_SERVICE, fallbackFactory = RemoteTcpFallbackFactory.class) +public interface RemoteTcpService { + + @GetMapping(value = "/netty/setMessage") + public R setMessage(@RequestBody SysTcpMessage sysTcpMessage, @RequestHeader(SecurityConstants.FROM_SOURCE) String source); + + +} diff --git a/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/domain/SysTcpMessage.java b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/domain/SysTcpMessage.java new file mode 100644 index 0000000..2f87e1f --- /dev/null +++ b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/domain/SysTcpMessage.java @@ -0,0 +1,14 @@ +package com.bonus.system.api.domain; + +import lombok.Data; + +/** + * 消息通知 + */ +@Data +public class SysTcpMessage { + + private String devCode; + + private float distance; +} diff --git a/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/factory/RemoteTcpFallbackFactory.java b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/factory/RemoteTcpFallbackFactory.java new file mode 100644 index 0000000..350d403 --- /dev/null +++ b/bonus-api/bonus-api-system/src/main/java/com/bonus/system/api/factory/RemoteTcpFallbackFactory.java @@ -0,0 +1,30 @@ +package com.bonus.system.api.factory; + +import com.bonus.common.core.domain.R; +import com.bonus.system.api.RemoteTcpService; +import com.bonus.system.api.domain.SysTcpMessage; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.cloud.openfeign.FallbackFactory; +import org.springframework.stereotype.Component; + +/** + * tcp服务降级处理 + * + * @author bonus + */ +@Component +public class RemoteTcpFallbackFactory implements FallbackFactory { + private static final Logger log = LoggerFactory.getLogger(RemoteTcpFallbackFactory.class); + + @Override + public RemoteTcpService create(Throwable throwable) { + log.error("tcp服务调用失败:{}", throwable.getMessage()); + return new RemoteTcpService() { + @Override + public R setMessage(SysTcpMessage sysTcpMessage, String source) { + return R.fail("近电感应设备设置失败:" + throwable.getMessage()); + } + }; + } +} diff --git a/bonus-api/bonus-api-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/bonus-api/bonus-api-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports index ac97f94..d18c35d 100644 --- a/bonus-api/bonus-api-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports +++ b/bonus-api/bonus-api-system/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports @@ -2,3 +2,4 @@ com.bonus.system.api.factory.RemoteUserFallbackFactory com.bonus.system.api.factory.RemoteLogFallbackFactory com.bonus.system.api.factory.RemoteFileFallbackFactory com.bonus.system.api.factory.RemoteSourceFallbackFactory +com.bonus.system.api.factory.RemoteTcpFallbackFactory diff --git a/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/BusinessConstants.java b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/BusinessConstants.java index f2e304f..675abce 100644 --- a/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/BusinessConstants.java +++ b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/BusinessConstants.java @@ -78,6 +78,10 @@ public class BusinessConstants { */ public final static String JD = "elec_induction"; public final static String DL = "电量"; + /** + * 近电感应设备电量编码 + */ + public final static String JD_DL = "dl_code"; /** * 管理员角色 @@ -142,7 +146,7 @@ public class BusinessConstants { public static final String PNG = "image/png"; public static final String JPG = "image/jpg"; - + public final static String SET_MSG = "配置成功"; public final static Integer CELL_1 = 1; public final static Integer CELL_2 = 2; diff --git a/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/ServiceNameConstants.java b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/ServiceNameConstants.java index 3430c7d..49615c1 100644 --- a/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/ServiceNameConstants.java +++ b/bonus-common/bonus-common-core/src/main/java/com/bonus/common/core/constant/ServiceNameConstants.java @@ -22,4 +22,9 @@ public class ServiceNameConstants */ public static final String FILE_SERVICE = "bonus-file"; + /** + * tcp服务的serviceid + */ + public static final String TCP_SERVICE = "bonus-tcp"; + } diff --git a/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/app/vo/JdConfigVo.java b/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/app/vo/JdConfigVo.java index 2b7c17b..a00f5b5 100644 --- a/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/app/vo/JdConfigVo.java +++ b/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/app/vo/JdConfigVo.java @@ -23,18 +23,19 @@ public class JdConfigVo { @NotNull(message = "设备ID不能为空") private Long devId; + @NotBlank(message = "设备编码不能为空") + private String devCode; + @NotEmpty(message = "配置属性不能为空") private List configItems; @Data public static class ConfigItems { /**线路属性*/ - @NotBlank(message = "线路属性不能为空", groups = {Query.class}) private String configType; /**线路属性名称*/ private String configTypeName; /**电压等级*/ - @NotBlank(message = "电压等级不能为空", groups = {Query.class}) private String voltageLevel; /**电压等级名称*/ private String voltageLevelName; diff --git a/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/bracelet/exportVo/DeviceExportVo.java b/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/bracelet/exportVo/DeviceExportVo.java index f35fa54..2d238e0 100644 --- a/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/bracelet/exportVo/DeviceExportVo.java +++ b/bonus-common/bonus-common-entity/src/main/java/com/bonus/common/entity/bracelet/exportVo/DeviceExportVo.java @@ -27,7 +27,7 @@ public class DeviceExportVo { @Excel(name = "设备状态", width = 20.0,height = 15.0,orderNum = "4") private String deviceStatus; - @Excel(name = "领用人", width = 20.0,height = 15.0,orderNum = "5") + @Excel(name = "设备使用人", width = 20.0,height = 15.0,orderNum = "5") private String lyName; } diff --git a/bonus-modules/bonus-app/src/main/java/com/bonus/app/service/impl/CraneMonitorServiceImpl.java b/bonus-modules/bonus-app/src/main/java/com/bonus/app/service/impl/CraneMonitorServiceImpl.java index 2a7f68b..70f6938 100644 --- a/bonus-modules/bonus-app/src/main/java/com/bonus/app/service/impl/CraneMonitorServiceImpl.java +++ b/bonus-modules/bonus-app/src/main/java/com/bonus/app/service/impl/CraneMonitorServiceImpl.java @@ -3,6 +3,9 @@ package com.bonus.app.service.impl; import com.bonus.app.mapper.CraneMonitorMapper; import com.bonus.app.service.ICraneMonitorService; import com.bonus.common.core.constant.BusinessConstants; +import com.bonus.common.core.constant.HttpStatus; +import com.bonus.common.core.constant.SecurityConstants; +import com.bonus.common.core.domain.R; import com.bonus.common.core.utils.encryption.Sm4Utils; import com.bonus.common.core.web.domain.AjaxResult; import com.bonus.common.entity.app.AppParamsDto; @@ -10,6 +13,8 @@ import com.bonus.common.entity.app.vo.DevInfoVo; import com.bonus.common.entity.app.vo.DevWarnVo; import com.bonus.common.entity.app.vo.JdConfigVo; import com.bonus.common.security.utils.ValidatorsUtils; +import com.bonus.system.api.RemoteTcpService; +import com.bonus.system.api.domain.SysTcpMessage; import com.github.pagehelper.PageInfo; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; @@ -18,10 +23,7 @@ import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.HashSet; -import java.util.List; -import java.util.Set; +import java.util.*; /** * @className:CraneMonitorServiceImpl @@ -40,6 +42,9 @@ public class CraneMonitorServiceImpl implements ICraneMonitorService { @Resource(name = "ValidatorsUtils") private ValidatorsUtils validatorsUtils; + @Resource + private RemoteTcpService remoteTcpService; + @Override public AjaxResult getDzWarnList(AppParamsDto dto) { List list = new ArrayList<>(); @@ -105,8 +110,18 @@ public class CraneMonitorServiceImpl implements ICraneMonitorService { return AjaxResult.error(validResult); } } - mapper.delJdConfig(vo); - mapper.addJdConfigData(vo); + SysTcpMessage sysTcpMessage = new SysTcpMessage(); + sysTcpMessage.setDevCode(vo.getDevCode()); + sysTcpMessage.setDistance(Float.parseFloat(configItems.get(0).getDistance())); + R result = remoteTcpService.setMessage(sysTcpMessage, SecurityConstants.INNER); + log.info("调用结果：code:{},msg:{}", result.getCode(),result.getMsg()); + if (result != null && result.getCode() == HttpStatus.SUCCESS && Objects.equals(result.getMsg(), BusinessConstants.SET_MSG)) { + mapper.delJdConfig(vo); + mapper.addJdConfigData(vo); + return AjaxResult.success(result.getMsg()); + } else { + return AjaxResult.error(result.getMsg()); + } } catch (Exception e) { log.error(e.toString(), e); } diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/controller/ConsControlController.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/controller/ConsControlController.java index adc557f..ff122a3 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/controller/ConsControlController.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/controller/ConsControlController.java @@ -6,11 +6,10 @@ import com.bonus.common.core.text.Convert; import com.bonus.common.core.utils.ServletUtils; 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.entity.app.vo.DevWarnVo; import com.bonus.common.entity.app.vo.JdConfigVo; import com.bonus.common.entity.bracelet.BraceletParamsDto; import com.bonus.common.entity.bracelet.vo.CheckConfigVo; -import com.bonus.common.entity.bracelet.vo.EquipmentReqVo; import com.bonus.common.entity.bracelet.vo.WarnInfoVo; import com.bonus.common.log.annotation.SysLog; import com.bonus.common.log.enums.OperaType; @@ -21,7 +20,6 @@ import org.springframework.validation.annotation.Validated; import org.springframework.web.bind.annotation.*; import javax.annotation.Resource; -import java.util.List; /** * @className:ConsControlController @@ -184,7 +182,11 @@ public class ConsControlController extends BaseController { */ @GetMapping("getJdWarnList") public AjaxResult getJdWarnList(BraceletParamsDto dto){ - return service.getJdWarnList(dto); + Integer pageNum = Convert.toInt(ServletUtils.getParameter(BusinessConstants.PAGE_NUM), 1); + Integer pageSize = Convert.toInt(ServletUtils.getParameter(BusinessConstants.PAGE_SIZE), 10); + PageHelper.startPage(pageNum, pageSize); + PageInfo pageInfo = service.getJdWarnList(dto); + return AjaxResult.success(pageInfo.getList()); } /** diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/mapper/DeviceMapper.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/mapper/DeviceMapper.java index 05f62ee..fb2072d 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/mapper/DeviceMapper.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/mapper/DeviceMapper.java @@ -52,6 +52,16 @@ public interface DeviceMapper { */ DeviceVo isExist(DeviceVo vo); + /** + * 判断设备编码是否存在 + * + * @param vo + * @return int + * @author cwchen + * @date 2024/7/17 14:41 + */ + DeviceVo isExistCode(DeviceVo vo); + /** * 新增时设备名称是否重复 * @param vo @@ -59,6 +69,13 @@ public interface DeviceMapper { */ DeviceVo isNameExist(DeviceVo vo); + /** + * 新增时设备编码是否重复 + * @param vo + * @return + */ + DeviceVo isCodeExist(DeviceVo vo); + /** * 新增时级联编码是否重复 * @param vo diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/IConsControlService.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/IConsControlService.java index 3d92e90..4da73e2 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/IConsControlService.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/IConsControlService.java @@ -1,6 +1,7 @@ package com.bonus.bracelet.service; import com.bonus.common.core.web.domain.AjaxResult; +import com.bonus.common.entity.app.vo.DevWarnVo; import com.bonus.common.entity.app.vo.JdConfigVo; import com.bonus.common.entity.bracelet.BraceletParamsDto; import com.bonus.common.entity.bracelet.vo.CheckConfigVo; @@ -141,7 +142,7 @@ public interface IConsControlService { * @author cwchen * @date 2024/8/16 17:57 */ - AjaxResult getJdWarnList(BraceletParamsDto dto); + PageInfo getJdWarnList(BraceletParamsDto dto); /** * 查询近电感应设备 diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/BraceletServiceImpl.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/BraceletServiceImpl.java index 3c76c22..f55581c 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/BraceletServiceImpl.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/BraceletServiceImpl.java @@ -48,25 +48,12 @@ public class BraceletServiceImpl implements IBraceletService { @Override public List getBraceletLists(BraceletVo data) { List list = new ArrayList<>(); - List listFilter = new ArrayList<>(); try { list = braceletMapper.getBraceletLists(data); - for (int i = 0; i < list.size(); i++) { - if(list.get(i).getShPersonName()==null || list.get(i).getShPersonName().equals("")){ - list.get(i).setShStatus(1); - }else{ - list.get(i).setShStatus(0); - } - } - if(data.getShStatus()!=null){ - listFilter = list.stream().filter(bracelet -> data.getShStatus()==(bracelet.getShStatus())).collect(Collectors.toList()); - }else{ - listFilter = list; - } } catch (Exception e) { log.error(e.toString(), e); } - return listFilter; + return list; } @Override @@ -120,27 +107,12 @@ public class BraceletServiceImpl implements IBraceletService { @Override public List getShboxallLists(ShboxVo data) { List list = new ArrayList<>(); - List listFilter = new ArrayList<>(); try { list = braceletMapper.getShboxallLists(data); - if(data.getShboxStatus()==null){ - listFilter = list; - }else if(data.getShboxStatus()==0){ - listFilter = list.stream().filter(bracelet -> (bracelet.getLyName()!=null && (!bracelet.getLyName().equals("")))).collect(Collectors.toList()); - }else { - listFilter = list.stream().filter(bracelet -> (bracelet.getLyName()==null || bracelet.getLyName().equals(""))).collect(Collectors.toList()); - } - for (int i = 0; i < listFilter.size(); i++) { - if(listFilter.get(i).getLyName()==null || listFilter.get(i).getLyName().equals("")){ - listFilter.get(i).setShboxStatus(1); - }else{ - listFilter.get(i).setShboxStatus(0); - } - } } catch (Exception e) { log.error(e.toString(), e); } - return listFilter; + return list; } @Override diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/ConsControlServiceImpl.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/ConsControlServiceImpl.java index 7d99699..2e61ce0 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/ConsControlServiceImpl.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/ConsControlServiceImpl.java @@ -22,7 +22,9 @@ import com.bonus.common.core.utils.BuildTreeUtil; import com.bonus.common.entity.bracelet.vo.*; import com.bonus.common.security.utils.ValidatorsUtils; import com.bonus.system.api.RemoteFileService; +import com.bonus.system.api.RemoteTcpService; import com.bonus.system.api.domain.SysFile; +import com.bonus.system.api.domain.SysTcpMessage; import com.github.pagehelper.PageInfo; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections4.CollectionUtils; @@ -56,6 +58,9 @@ public class ConsControlServiceImpl implements IConsControlService { @Resource(name = "ValidatorsUtils") private ValidatorsUtils validatorsUtils; + @Resource + private RemoteTcpService remoteTcpService; + @Override public AjaxResult getBallDeviceLists(BraceletParamsDto dto) { JSONArray resultTree = new JSONArray(); @@ -206,22 +211,6 @@ public class ConsControlServiceImpl implements IConsControlService { return AjaxResult.success(resultTree); } - public PersonTreeVo pruneTree(PersonTreeVo root) { - if (root == null) { - return null; - } - List nonEmptyChildren = new ArrayList<>(); - for (PersonTreeVo child : root.getChildren()) { - PersonTreeVo prunedChild = pruneTree(child); - if (prunedChild != null) { - nonEmptyChildren.add(prunedChild); - } - } - root.setChildren(nonEmptyChildren); - - return root.getChildren().isEmpty() ? null : root; - } - @Override public AjaxResult getWorkInfo(BraceletParamsDto dto) { Map mapData = new HashMap<>(); @@ -537,7 +526,7 @@ public class ConsControlServiceImpl implements IConsControlService { } @Override - public AjaxResult getJdWarnList(BraceletParamsDto dto) { + public PageInfo getJdWarnList(BraceletParamsDto dto) { List list = new ArrayList<>(); try { dto.setDevType(BusinessConstants.JD); @@ -548,7 +537,8 @@ public class ConsControlServiceImpl implements IConsControlService { } catch (Exception e) { log.error(e.toString(), e); } - return AjaxResult.success(list); + PageInfo pageInfo = new PageInfo<>(list); + return pageInfo; } @Override @@ -558,7 +548,7 @@ public class ConsControlServiceImpl implements IConsControlService { dto.setDevType(BusinessConstants.JD); list = mapper.getJdList(dto); for (DevInfoVo vo : list) { - String electricQuantity = mapper.getElectricQuantity(vo.getDevId(), BusinessConstants.DL); + String electricQuantity = mapper.getElectricQuantity(vo.getDevId(), BusinessConstants.JD_DL); if (StringUtils.isNotBlank(electricQuantity) && isNumeric(electricQuantity)) { vo.setElectricQuantity(electricQuantity); } else { @@ -591,8 +581,18 @@ public class ConsControlServiceImpl implements IConsControlService { return AjaxResult.error(validResult); } } - mapper.delJdConfig(vo); - mapper.addJdConfigData(vo); + SysTcpMessage sysTcpMessage = new SysTcpMessage(); + sysTcpMessage.setDevCode(vo.getDevCode()); + sysTcpMessage.setDistance(Float.parseFloat(configItems.get(0).getDistance())); + R result = remoteTcpService.setMessage(sysTcpMessage, SecurityConstants.INNER); + log.info("调用结果：code:{},msg:{}", result.getCode(),result.getMsg()); + if (result != null && result.getCode() == HttpStatus.SUCCESS && Objects.equals(result.getMsg(), BusinessConstants.SET_MSG)) { + mapper.delJdConfig(vo); + mapper.addJdConfigData(vo); + return AjaxResult.success(result.getMsg()); + } else { + return AjaxResult.error(result.getMsg()); + } } catch (Exception e) { log.error(e.toString(), e); } diff --git a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/DeviceServiceImpl.java b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/DeviceServiceImpl.java index ba87fa0..fac646f 100644 --- a/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/DeviceServiceImpl.java +++ b/bonus-modules/bonus-bracelet/src/main/java/com/bonus/bracelet/service/impl/DeviceServiceImpl.java @@ -51,25 +51,13 @@ public class DeviceServiceImpl implements IDeviceService { @Override public List getDeviceLists(DeviceVo data) { List list = new ArrayList<>(); - List listFilter = new ArrayList<>(); try { list = deviceMapper.getDeviceLists(data); - for (int i = 0; i < list.size(); i++) { - if(list.get(i).getLyName()==null || list.get(i).getLyName().equals("")){ - list.get(i).setDeviceStatus(1); - }else{ - list.get(i).setDeviceStatus(0); - } - } - if(data.getDeviceStatus()!=null){ - listFilter = list.stream().filter(device -> data.getDeviceStatus()==(device.getDeviceStatus())).collect(Collectors.toList()); - }else{ - listFilter = list; - } + } catch (Exception e) { log.error(e.toString(), e); } - return listFilter; + return list; } /** @@ -102,6 +90,10 @@ public class DeviceServiceImpl implements IDeviceService { if (result != null) { return AjaxResult.error("设备名称已存在"); } + DeviceVo resultTwo = deviceMapper.isCodeExist(vo); + if (resultTwo != null) { + return AjaxResult.error("设备编码已存在"); + } int num = deviceMapper.addDevice(vo); int numly = deviceMapper.getDeviceLy(vo.getDeviceId()); if(numly==0){ @@ -224,6 +216,11 @@ public class DeviceServiceImpl implements IDeviceService { return AjaxResult.error("设备名称已存在"); } + DeviceVo resultTwo = deviceMapper.isExistCode(vo); + if (resultTwo != null) { + return AjaxResult.error("设备编码已存在"); + } + int num = deviceMapper.updateDevice(vo); if(num==1){ return AjaxResult.success(); diff --git a/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/BraceletMapper.xml b/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/BraceletMapper.xml index 163fe24..310699a 100644 --- a/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/BraceletMapper.xml +++ b/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/BraceletMapper.xml @@ -5,6 +5,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" @@ -95,20 +107,31 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" diff --git a/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/DeviceMapper.xml b/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/DeviceMapper.xml index 95b57dd..2a59356 100644 --- a/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/DeviceMapper.xml +++ b/bonus-modules/bonus-bracelet/src/main/resources/mapper/bracelet/DeviceMapper.xml @@ -5,29 +5,41 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" @@ -60,6 +72,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" where td.dev_name = #{deviceName} and td.id != #{deviceId} and del_flag = 0 + + + UPDATE tb_device td SET dev_type = #{deviceType},dev_name = #{deviceName},dev_code = #{deviceCode},dev_index = #{deviceIndex},update_time = #{updateTime},update_user = #{updateUser} @@ -73,6 +92,13 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" where td.dev_name = #{deviceName} and del_flag = 0 + + +