1hotfix-128G-dsx

src/main/java/com/fdkankan/contro/mq/service/impl/BuildSceneServiceImpl.java

@@ -95,6 +95,9 @@ public class BuildSceneServiceImpl implements IBuildSceneService {
 
     @Value("${4dkk.laserService.dir}")
     private String laserDir;
+    @Value("${scaling.rule.extend.ari:#{null}}")
+    private String scalingExtendAri;
+
 
     @Autowired
     private RabbitMqProducer mqProducer;
@@ -146,6 +149,8 @@ public class BuildSceneServiceImpl implements IBuildSceneService {
     private ISceneColdStorageService sceneColdStorageService;
     @Autowired
     private ScalingService scalingService;
+    @Autowired
+    private RabbitMqProducer rabbitMqProducer;
 
     @Override
     public void buildScenePre(BuildSceneCallMessage message){
@@ -203,11 +208,13 @@ public class BuildSceneServiceImpl implements IBuildSceneService {
             message.getBuildContext().put("cameraType",message.getCameraType());
 
             //查询是否超过比例50%，如果超过，则启动128G服务器弹性伸缩
-            Integer scale = fdageJson.getInteger("");
-            if(scale > 50){
-
-                if("是否马上启动弹性伸缩"){
-                    String result = scalingService.createEcs("查库中查出来的id");
+            Float maxRate = fdageJson.getFloat("maxRate");
+            if(Objects.nonNull(maxRate) && maxRate > 50){
+                //发送mq，就进行计算
+                mqProducer.sendByWorkQueue(queueModelingCall.concat("-128G"), message);
+                int mqNum = rabbitMqProducer.getMessageCount(queueModelingCall.concat("-128G"));
+                if(mqNum > 0){
+                    String result = scalingService.createEcs(scalingExtendAri);
                     log.info("createEcs-result:{}", result);
                 }
             }else{