|
@@ -154,7 +154,13 @@ public class MqttServiceImpl extends ServiceImpl<MqttCommandMapper, MqttCommand>
|
|
}
|
|
}
|
|
map.get(cmdType).add(mqttDto);
|
|
map.get(cmdType).add(mqttDto);
|
|
});
|
|
});
|
|
- map.forEach((k, v) -> SpringBeanUtils.getBean(CmdTypeEnum.getEnum(k).getCmdServiceClass()).senCommand(v));
|
|
|
|
|
|
+ map.forEach((k, v) -> {
|
|
|
|
+ CmdTypeEnum anEnum = CmdTypeEnum.getEnum(k);
|
|
|
|
+ if (anEnum == null) {
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ SpringBeanUtils.getBean(anEnum.getCmdServiceClass()).senCommand(v);
|
|
|
|
+ });
|
|
return R.ok(list);
|
|
return R.ok(list);
|
|
}
|
|
}
|
|
|
|
|