fix: 修改TCP网关子设备时,验证设备地址码或设备标识是否重复的bug

@@ -4,7 +4,6 @@ import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiModelProperty;
 import io.swagger.annotations.ApiOperation;
 import io.swagger.annotations.ApiParam;
 import lombok.RequiredArgsConstructor;
@@ -78,19 +77,12 @@ public class TkDeviceController extends BaseController {
     DeviceDTO gateWay = null;
     if (StringUtils.isNotEmpty(gatewayId)) {
       gateWay =
-          tkdeviceService.checkDeviceByTenantIdAndDeviceId(
-              getCurrentUser().getCurrentTenantId(), gatewayId);
+          tkdeviceService.checkDeviceByTenantIdAndDeviceId(currentTenantId, gatewayId);
       if (null == gateWay) {
         throw new TkDataValidationException(
             ErrorMessage.DEVICE_NOT_EXISTENCE_IN_TENANT.getMessage());
       }
     }
-    String identifier = StringUtils.isBlank(deviceDTO.getCode())?deviceDTO.getName():deviceDTO.getCode();
-    String markResult =tkdeviceService.markExisted(getCurrentUser().getCurrentTenantId(), gatewayId,deviceDTO.getId(),identifier);
-    if(StringUtils.isNotEmpty(markResult)){
-      throw new TkDataValidationException(markResult);
-    }
-
     /**
      * 子设备编辑业务逻辑： 设备地址码必须同时设置到附加信息字段内。 1、新增或编辑网关和直连设备 2、新增网关子设备 3、编辑网关子设备时，关联关系已存在(未切换网关)
      * 4、编辑网关子设备时，关联关系不存在(切换网关) 5、编辑网关子设备时，修改其它设备信息，例如：设备名称等。
@@ -500,19 +492,6 @@ public class TkDeviceController extends BaseController {
     result.setMessage(str);
     return result;
   }
-  @PreAuthorize("@check.checkPermissions({'TENANT_ADMIN','CUSTOMER_USER'},{})")
-  @GetMapping("exist")
-  @ApiOperation("设备标识符是否已经被使用")
-  public ResponseResult<Boolean> existed(
-          @ApiParam(value = "网关设备主键") @RequestParam(name="gateway",required = false) String gatewayId,
-          @ApiParam(value = "当前设备主键，编辑时使用") @RequestParam(name="devId",required = false) String devId,
-          @ApiParam(value = "设备标识符，例如：设备名称、地址码", required = true)@RequestParam("identifier") String identifier)
-          throws ThingsboardException {
-    String str = tkdeviceService.markExisted(getCurrentUser().getCurrentTenantId(),gatewayId,devId,identifier);
-    ResponseResult result = ResponseResult.success(StringUtils.isEmpty(str) ? true : false);
-    result.setMessage(str);
-    return result;
-  }
   @GetMapping({"/attributes/{deviceProfileId}"})
   @ApiOperation("获取设备的属性")
   public ResponseEntity<JsonNode> getDeviceAttributes(

@@ -100,8 +100,7 @@ public enum ErrorMessage {
   TASK_CENTER_IS_DISABLED(400076,"【%s】任务是禁用状态，不能执行"),
   NAME_OR_IDENTIFIER_IS_EMPTY(400077,"【%s】的名称或标识符不能为空或空字符串"),
   IDENTIFIER_ALREADY_EXISTS(400078,"标识符【%s】已经存在"),
-  DEVICE_GATEWAY_NOT_EXTIED(400079,"网关设备【%s】不存在"),
-  DEVICE_IDENTIFIER_REPEATED(400079,"设备标识【%s】与设备【%s】重复"),
+  DEVICE_IDENTIFIER_REPEATED(400079,"设备地址码或标识码【%s】与设备【%s】重复"),
   HAVE_NO_PERMISSION(500002,"没有修改权限");
   private final int code;
   private String message;

@@ -140,6 +140,23 @@ public class TkDeviceServiceImpl extends AbstractBaseService<DeviceMapper, TkDev
     } else if (!organization.getTenantId().equals(deviceTenantId)) {
       throw new TkDataValidationException(ErrorMessage.TENANT_MISMATCHING.getMessage());
     }
+    //如果是TCP的网关子设备,要验证其Code是否已在网关的其他子设备存在
+    if(Objects.equals(deviceDTO.getDeviceType(),DeviceTypeEnum.SENSOR) && Objects.equals(deviceProfile.getTransportType(),
+            DeviceTransportType.TCP)){
+      String gateWayId = deviceDTO.getGatewayId();
+      List<TkDeviceEntity> entities = baseMapper.selectList(new LambdaQueryWrapper<TkDeviceEntity>()
+              .eq(TkDeviceEntity::getTenantId,currentTenantId)
+              .eq(TkDeviceEntity::getGatewayId,gateWayId)
+              .ne(!insert,TkDeviceEntity::getId,deviceDTO.getId()));
+      if(null != entities && !entities.isEmpty()){
+        for (TkDeviceEntity entity:entities) {
+          if(Objects.equals(deviceDTO.getCode(),entity.getCode())){
+            throw new TkDataValidationException(String.format(ErrorMessage.DEVICE_IDENTIFIER_REPEATED.getMessage(),
+                    deviceDTO.getCode(),StringUtils.isEmpty(entity.getAlias())?entity.getName():entity.getAlias()));
+          }
+        }
+      }
+    }
   }
 
   /**
@@ -758,49 +775,4 @@ public class TkDeviceServiceImpl extends AbstractBaseService<DeviceMapper, TkDev
     }
     return result;
   }
-
-  @Override
-  public String markExisted(String tenantId,String gatewayId,String deviceId,  String identifier) {
-    if(StringUtils.isNotBlank(deviceId)){//编辑设备时，未修改设备标识符
-      TkDeviceEntity self = baseMapper.selectOne(
-              new LambdaQueryWrapper<TkDeviceEntity>()
-                      .eq(TkDeviceEntity::getTenantId, tenantId)
-                      .eq(TkDeviceEntity::getId, deviceId));
-      if(self.getGatewayId().equals(gatewayId)
-              &&( self.getCode().equals(identifier) || self.getName().equals(identifier))){
-        return "";
-      }
-    }
-    TkDeviceEntity gateway =null;
-    if(StringUtils.isNotBlank(gatewayId)){
-      gateway = baseMapper.selectOne(
-              new LambdaQueryWrapper<TkDeviceEntity>()
-                      .eq(TkDeviceEntity::getTenantId, tenantId)
-                      .eq(TkDeviceEntity::getTbDeviceId, gatewayId));
-      if (gateway ==null ) {
-        return String.format(ErrorMessage.DEVICE_GATEWAY_NOT_EXTIED.getMessage(),gatewayId);
-      }
-    }
-    LambdaQueryWrapper<TkDeviceEntity> filter =new LambdaQueryWrapper<>();
-    filter.eq(TkDeviceEntity::getTenantId, tenantId);
-    DeviceProfileDTO profile=null;
-    if(gateway !=null){
-      filter.eq(TkDeviceEntity::getGatewayId, gatewayId);
-      profile =tkProfileMapper.selectDetail(tenantId,gateway.getProfileId());
-    }
-
-    if(profile !=null && TransportTypeEnum.TCP.name().equals(profile.getTransportType())){
-      filter.eq(TkDeviceEntity::getCode, identifier);
-    }else{
-      filter.eq(TkDeviceEntity::getName, identifier);
-    }
-    List<TkDeviceEntity> self = baseMapper.selectList(filter);
-    if(self ==null || self.isEmpty()){
-      return "";
-    }else{
-      String names = String.join(",",self.stream().map(f->f.getName()).collect(Collectors.toList()));
-     return String.format(ErrorMessage.DEVICE_IDENTIFIER_REPEATED.getMessage(),identifier
-             ,names);
-    }
-  }
 }

@@ -109,16 +109,6 @@ public interface TkDeviceService extends BaseService<TkDeviceEntity> {
    */
   String otherUsing(String deviceId, String tenantId);
   /**
-   * 设备标识符是否已经被使用
-   *
-   * @param tenantId 租户ID
-   * @param gatewayId 网关设备主键
-   * @param deviceId 网关设备主键
-   * @param identifier 设备标识符，例如：设备名称、TCP子设备的地址码
-   * @return 场景联动ID
-   */
-  String markExisted(String tenantId,String gatewayId,String deviceId, String identifier);
-  /**
    * 主设备信息
    *
    * @param tenantId 租户ID