|
@@ -208,6 +208,7 @@ public class SubMessageSendManager {
|
|
|
// subFunction.setFunctionStatuses(newFunctionStatuses);
|
|
// subFunction.setFunctionStatuses(newFunctionStatuses);
|
|
|
//todo 到这里结束
|
|
//todo 到这里结束
|
|
|
//发送事件
|
|
//发送事件
|
|
|
|
|
+ logger.info("采集器数据接收={}",JSON.toJSONString(subFunction));
|
|
|
//本来使用mqtt接收,因为mqtt 每个客户端接受到都会处理,
|
|
//本来使用mqtt接收,因为mqtt 每个客户端接受到都会处理,
|
|
|
List<LabMessageEvent> labMessageEvents = mqttConfig.getLabMessMap().get(MqttConstants.TOPIC_LAB_FUNCTION_DATA);
|
|
List<LabMessageEvent> labMessageEvents = mqttConfig.getLabMessMap().get(MqttConstants.TOPIC_LAB_FUNCTION_DATA);
|
|
|
if (CollUtil.isNotEmpty(labMessageEvents)) {
|
|
if (CollUtil.isNotEmpty(labMessageEvents)) {
|