[1.1_dev][Taier-all] fix tenantIdentity

Author: vainhope

sql/init.sql

@@ -1709,7 +1709,7 @@ CREATE TABLE `tenant` (
 -- Records of tenant
 -- ----------------------------
 BEGIN;
-INSERT INTO `tenant` VALUES (1, 'taier', NULL, '2021-08-13 16:39:40', '2021-08-13 16:39:40', 1, 0, '');
+INSERT INTO `tenant` VALUES (1, 'taier', NULL, '2021-08-13 16:39:40', '2021-08-13 16:39:40', 1, 0, 'taier');
 COMMIT;
 
 -- ----------------------------

taier-data-develop/pom.xml

@@ -98,10 +98,6 @@
             <artifactId>dt-insight-hive-shade</artifactId>
             <version>4.1.3</version>
         </dependency>
-        <dependency>
-            <groupId>org.projectlombok</groupId>
-            <artifactId>lombok</artifactId>
-        </dependency>
     </dependencies>
 
     <build>

taier-data-develop/src/main/java/com/dtstack/taier/develop/controller/console/TenantController.java

@@ -23,6 +23,7 @@
 import com.dtstack.taier.common.exception.ErrorCode;
 import com.dtstack.taier.common.exception.RdosDefineException;
 import com.dtstack.taier.common.lang.web.R;
+import com.dtstack.taier.common.util.RegexUtils;
 import com.dtstack.taier.dao.domain.Cluster;
 import com.dtstack.taier.dao.domain.Tenant;
 import com.dtstack.taier.dao.pager.PageResult;
@@ -102,6 +103,10 @@ public R<Void> addTenant(@RequestParam("tenantName") String tenantName,@RequestP
         if(StringUtils.isBlank(tenantName)){
             throw new RdosDefineException(ErrorCode.INVALID_PARAMETERS);
         }
+        if(StringUtils.isBlank(tenantIdentity)){
+            throw new RdosDefineException(ErrorCode.INVALID_PARAMETERS);
+        }
+        if (!RegexUtils.tenantName(tenantIdentity)) throw new RdosDefineException(ErrorCode.TENANT_NAME_VERIFICATION_ERROR);
         Tenant tenant = tenantService.findByName(tenantName.trim());
         if(null != tenant){
             throw new RdosDefineException("tenant has exist");

taier-data-develop/src/main/java/com/dtstack/taier/develop/service/console/TenantService.java

@@ -25,12 +25,6 @@
 import com.dtstack.taier.common.exception.ErrorCode;
 import com.dtstack.taier.common.exception.RdosDefineException;
 import com.dtstack.taier.dao.domain.*;
-import com.dtstack.taier.common.util.RegexUtils;
-import com.dtstack.taier.dao.domain.ClusterTenant;
-import com.dtstack.taier.dao.domain.Component;
-import com.dtstack.taier.dao.domain.Queue;
-import com.dtstack.taier.dao.domain.Tenant;
-import com.dtstack.taier.dao.domain.TenantComponent;
 import com.dtstack.taier.dao.mapper.ClusterTenantMapper;
 import com.dtstack.taier.dao.mapper.ConsoleQueueMapper;
 import com.dtstack.taier.dao.mapper.TenantMapper;
@@ -53,7 +47,6 @@
 import com.dtstack.taier.scheduler.service.ComponentService;
 import com.dtstack.taier.scheduler.vo.ComponentVO;
 import org.apache.commons.lang3.BooleanUtils;
-import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -256,8 +249,6 @@ public Tenant findByName(String tenantName) {
 
 
     public void addTenant(String tenantName, Long createUserId,String tenantIdentity) {
-        // pre check
-        preCheckForAddTenant(tenantName);
         Tenant tenant = new Tenant();
         tenant.setTenantName(tenantName);
         tenant.setCreateUserId(createUserId);
@@ -266,16 +257,6 @@ public void addTenant(String tenantName, Long createUserId,String tenantIdentity
         tenantMapper.insert(tenant);
     }
 
-    private void preCheckForAddTenant(String tenantName) {
-        if(StringUtils.isBlank(tenantName)){
-            throw new RdosDefineException(ErrorCode.INVALID_PARAMETERS);
-        }
-        if (!RegexUtils.tenantName(tenantName)) throw new RdosDefineException(ErrorCode.TENANT_NAME_VERIFICATION_ERROR);
-        Tenant tenant = findByName(tenantName.trim());
-        if(null != tenant){
-            throw new RdosDefineException("tenant has exist");
-        }
-    }
 
     @Transactional(rollbackFor = Exception.class)
     public void initDataDevelop(Long clusterId, Long tenantId, Long userId, String tenantName, String tenantDesc, List<ComponentBindDBDTO> bindDBDTOList) throws Exception {