ecs30分钟未启动，删除信息

README.md

@@ -5,4 +5,8 @@
 4.可以自由调配未计算中的场景计算优先级，默认是B
 5.B每五分钟检测排队中的场景是否大于3个。是-开启一台新机器加入计算，否不进行操作。
 6.B,C每分钟进行一次检测，将（常驻机器数量-A待计算场景数量数量） 放置A中计算
-7.D为特殊队列，当app设置为128G场景时，和手动设置进入，无其他方式
+7.D为特殊队列，当app设置为128G场景时，和手动设置进入，无其他方式
+
+
+ALTER TABLE `4dkankan_v4`.`mq_ecs`
+ADD COLUMN `rec_status` varchar(255) NULL DEFAULT 'A' AFTER `is_scaling`;

src/main/java/com/fdkankan/mqcontroller/entity/MqEcs.java

@@ -1,9 +1,7 @@
 package com.fdkankan.mqcontroller.entity;
 
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableField;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
+
 import java.io.Serializable;
 import java.util.Date;
 import lombok.Getter;
@@ -54,5 +52,7 @@ public class MqEcs implements Serializable {
     @TableField("is_scaling")
     private Integer isScaling;
 
-
+    @TableField("rec_status")
+    @TableLogic(value = "A",delval = "I")
+    private String recStatus;
 }

src/main/java/com/fdkankan/mqcontroller/service/impl/MqEcsServiceImpl.java

@@ -1,5 +1,6 @@
 package com.fdkankan.mqcontroller.service.impl;
 
+import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
@@ -15,6 +16,7 @@ import org.springframework.stereotype.Service;
 import rx.internal.util.unsafe.MessagePassingQueue;
 
 import java.util.ArrayList;
+import java.util.Date;
 import java.util.List;
 
 /**
@@ -82,6 +84,19 @@ public class MqEcsServiceImpl extends ServiceImpl<IMqEcsMapper, MqEcs> implement
         LambdaQueryWrapper<MqEcs> wrapper = new LambdaQueryWrapper<>();
         wrapper.eq(MqEcs::getIsScaling,1);
         wrapper.isNull(MqEcs::getEcsName);
-        return this.list(wrapper);
+        List<MqEcs> list = this.list(wrapper);
+
+        if(!list.isEmpty()){
+            for (MqEcs mqEcs : list) {
+                Date createTime = mqEcs.getCreateTime();
+                long between = DateUtil.between(createTime, new Date(), DateUnit.MINUTE);
+                //30分钟未启动。启动失败，删除并通知
+                if(between >=30){
+                    this.removeById(mqEcs.getId());
+                }
+            }
+        }
+
+        return list;
     }
 }