获取并行度

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/consumer/ProjectConsumer.java

@@ -110,7 +110,7 @@ public class ProjectConsumer {
             clusterPO = clusterMapper.selectByUserId(userId);
             log.info("ProjectConsumer--cacheManualProject 项目 " + projectId + " 的创建人 " + userId + " 为普通账户（包括独占或共享都在自己的集群），集群为：" + clusterPO);
         } else if (DictConstants.ROLE_CODE_SUBUESR.equals(roleCode)) {
-            if (DictConstants.USE_TYPE_EXCLUSIVE.equals(useType)) {   //3-3 普通子账户，根据自己的独占节点排队
+            if (DictConstants.USER_TYPE_EXCLUSIVE.equals(useType)) {   //3-3 普通子账户，根据自己的独占节点排队
                 clusterPO = clusterMapper.selectByUserId(userId);
                 log.info("ProjectConsumer--cacheManualProject 项目 " + projectId + " 的创建人 " + userId + " 为普通独占子账户（自己的集群），集群为：" + clusterPO);
             } else {    //3-4 共享子账户，根据父账户的共享节点排队

simulation-resource-scheduler/src/main/java/com/css/simulation/resource/scheduler/scheduler/ProjectScheduler.java

@@ -100,7 +100,7 @@ public class ProjectScheduler {
                 }
                 clusterId = clusterPO.getId();
             } else if (DictConstants.ROLE_CODE_SUBUESR.equals(roleCode)) {
-                if (DictConstants.USE_TYPE_EXCLUSIVE.equals(useType)) {   //3-3 普通子账户，根据自己的独占节点排队
+                if (DictConstants.USER_TYPE_EXCLUSIVE.equals(useType)) {   //3-3 普通子账户，根据自己的独占节点排队
                     clusterPO = clusterMapper.selectByUserId(userId);
                 } else {    //3-4 共享子账户，根据父账户的共享节点排队
                     String parentUserId = userPO.getCreateUserId();