1.修改判断发送AI消息队列逻辑

src/main/java/com/yupi/springbootinit/service/impl/HostInfoServiceImpl.java

@@ -19,6 +19,7 @@ import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.Set;
 import java.util.concurrent.CompletableFuture;
 
 
@@ -70,8 +71,9 @@ public class HostInfoServiceImpl extends ServiceImpl<NewHostsMapper, NewHosts> i
                 });
             }
 
-            Boolean o = (Boolean) redisTemplate.opsForValue().get("ai_login:"+newHosts.get(0).getTenantId());
-            if (Boolean.TRUE.equals(o)) {
+//            Boolean o = (Boolean) redisTemplate.opsForValue().get("ai_login:"+newHosts.get(0).getTenantId());
+            Set<String> keys = redisTemplate.keys("ai_login:"+newHosts.get(0).getTenantId()+":*");
+            if (!keys.isEmpty()) {
                 newHosts.forEach(newHost -> {
                     mqSender.send(newHost.getTenantId(),newHost);
                 });