|
|
@@ -70,7 +70,7 @@ public class DeviceDirectiveSendInterceptor implements DeviceMessageSenderInterc
|
|
|
.set(DeviceDirectivesEntity::getLastError,null)
|
|
|
.execute())
|
|
|
.onErrorResume(DeviceOperationException.class,e->deviceDirectivesService.createUpdate()
|
|
|
- .where(DeviceDirectivesEntity::getDeviceId,message.getDeviceId())
|
|
|
+// .where(DeviceDirectivesEntity::getDeviceId,message.getDeviceId())
|
|
|
.where(DeviceDirectivesEntity::getMessageId,message.getMessageId())
|
|
|
.set(DeviceDirectivesEntity::getLastError,e.getMessage())
|
|
|
.set(DeviceDirectivesEntity::getState,DirectiveState.sendError)
|