|
@@ -84,7 +84,7 @@ public class IotDeviceMessageServiceImpl implements IotDeviceMessageService {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
@Async
|
|
@Async
|
|
|
- void createDeviceLogAsync(IotDeviceMessage message) {
|
|
|
|
|
|
|
+ public void createDeviceLogAsync(IotDeviceMessage message) {
|
|
|
IotDeviceMessageDO messageDO = BeanUtils.toBean(message, IotDeviceMessageDO.class)
|
|
IotDeviceMessageDO messageDO = BeanUtils.toBean(message, IotDeviceMessageDO.class)
|
|
|
.setUpstream(IotDeviceMessageUtils.isUpstreamMessage(message))
|
|
.setUpstream(IotDeviceMessageUtils.isUpstreamMessage(message))
|
|
|
.setReply(IotDeviceMessageUtils.isReplyMessage(message))
|
|
.setReply(IotDeviceMessageUtils.isReplyMessage(message))
|
|
@@ -384,8 +384,8 @@ public class IotDeviceMessageServiceImpl implements IotDeviceMessageService {
|
|
|
});
|
|
});
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- private IotDeviceMessageServiceImpl getSelf() {
|
|
|
|
|
- return SpringUtil.getBean(getClass());
|
|
|
|
|
|
|
+ private IotDeviceMessageService getSelf() {
|
|
|
|
|
+ return SpringUtil.getBean(IotDeviceMessageService.class);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|