Merge remote-tracking branch 'origin/master'

README.md

@@ -1,7 +1,7 @@
 # JetLinks 物联网基础平台
 
 ![GitHub Workflow Status](https://img.shields.io/github/workflow/status/jetlinks/jetlinks-community/Auto%20Deploy%20Docker?label=docker)
-![Version](https://img.shields.io/badge/Version-1.1--RELEASE-brightgreen)
+![Version](https://img.shields.io/badge/Version-1.3--RELEASE-brightgreen)
 ![QQ群2021514](https://img.shields.io/badge/QQ群-2021514-brightgreen)
 ![jetlinks](https://visitor-badge.glitch.me/badge?page_id=jetlinks)
 
@@ -81,6 +81,7 @@ JetLinks 基于Java8,Spring Boot 2.x,WebFlux,Netty,Vert.x,Reactor等开发,
 | Http,WebSocket(TLS) |  ⭕  |  ✅ |     ✅ |
 | 数据转发:MQTT,HTTP,Kafka... |  ⭕  |  ✅ |     ✅ |
 | Geo地理位置支持     | ⭕   |  ✅ |  ✅    |
+| 规则引擎-可视化设计器     | ⭕   |  ✅ |  ✅    |
 | OpenAPI    |  ⭕  |  ✅ |     ✅     |
 | 多租户(建设中)   |  ⭕  |  ✅ |   ✅   |
 | 集群支持    |  ⭕  |  ✅ |     ✅     |
@@ -93,4 +94,4 @@ JetLinks 基于Java8,Spring Boot 2.x,WebFlux,Netty,Vert.x,Reactor等开发,
 | 商业限制   |  无  |  单个项目 |   无   |
 | 定价   |  免费  | 联系我们  |  联系我们   |
 
-⚠️:所有版本均不可发布为与JetLinks同类的产品进行二次销售. 
+⚠️:所有版本均不可发布为与JetLinks同类的产品进行二次销售. 

jetlinks-manager/rule-engine-manager/src/main/java/org/jetlinks/community/rule/engine/device/DeviceAlarmTaskExecutorProvider.java

@@ -212,8 +212,8 @@ public class DeviceAlarmTaskExecutorProvider implements TaskExecutorProvider {
                         StringUtils.hasText(rule.getDeviceId())
                             ? flux.window(windowTime)//规则已经指定了固定的设备,直接开启时间窗口就行
                             : flux //规则配置在设备产品上,则按设备ID分组后再开窗口
-                            .groupBy(map -> String.valueOf(map.get("deviceId")))
-                            .flatMap(group -> group.window(windowTime)))
+                            .groupBy(map -> String.valueOf(map.get("deviceId")), Integer.MAX_VALUE)
+                            .flatMap(group -> group.window(windowTime),Integer.MAX_VALUE))
                     //处理每一组数据
                     .flatMap(group -> group
                         .index((index, data) -> Tuples.of(index + 1, data)) //给数据打上索引,索引号就是告警次数