|
|
|
@ -31,20 +31,10 @@ import java.util.*; |
|
|
|
import java.util.function.Function; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
/** |
|
|
|
* 批量设备消息处理器 |
|
|
|
* <p> |
|
|
|
* 核心优化: |
|
|
|
* 1. 批量获取基础数据(租户信息、设备信息、报警规则) |
|
|
|
* 2. 内存中完成所有业务逻辑计算 |
|
|
|
* 3. 批量执行所有数据库写操作 |
|
|
|
*/ |
|
|
|
@Slf4j |
|
|
|
@Component |
|
|
|
public class BatchDeviceMessageProcessor { |
|
|
|
|
|
|
|
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); |
|
|
|
|
|
|
|
@Resource |
|
|
|
private RedisUtil redisUtil; |
|
|
|
@Resource |
|
|
|
|