|
|
|
@ -476,7 +476,7 @@ public class ExportImportServiceSqlTest extends BaseExportImportServiceTest { |
|
|
|
Customer updatedCustomer = importEntity(tenantAdmin2, updatedCustomerEntity).getSavedEntity(); |
|
|
|
verify(entityActionService).logEntityAction(any(), eq(importedCustomer.getId()), eq(updatedCustomer), |
|
|
|
any(), eq(ActionType.UPDATED), isNull()); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdgeService(any(), any(), eq(importedCustomer.getId()), any(), any(), eq(EdgeEventActionType.UPDATED)); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdge(any(), any(), eq(importedCustomer.getId()), any(), any(), eq(EdgeEventActionType.UPDATED)); |
|
|
|
|
|
|
|
Mockito.reset(entityActionService); |
|
|
|
|
|
|
|
@ -494,7 +494,7 @@ public class ExportImportServiceSqlTest extends BaseExportImportServiceTest { |
|
|
|
|
|
|
|
verify(entityActionService).logEntityAction(any(), eq(importedAsset.getId()), eq(updatedAsset), |
|
|
|
any(), eq(ActionType.UPDATED), isNull()); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdgeService(any(), any(), eq(importedAsset.getId()), any(), any(), eq(EdgeEventActionType.UPDATED)); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdge(any(), any(), eq(importedAsset.getId()), any(), any(), eq(EdgeEventActionType.UPDATED)); |
|
|
|
|
|
|
|
RuleChain importedRuleChain = (RuleChain) importEntity(tenantAdmin2, getAndClone(entitiesExportData, EntityType.RULE_CHAIN)).getSavedEntity(); |
|
|
|
verify(entityActionService).logEntityAction(any(), eq(importedRuleChain.getId()), eq(importedRuleChain), |
|
|
|
@ -510,7 +510,7 @@ public class ExportImportServiceSqlTest extends BaseExportImportServiceTest { |
|
|
|
any(), eq(ActionType.ADDED), isNull()); |
|
|
|
verify(tbClusterService).onDeviceProfileChange(eq(importedDeviceProfile), any()); |
|
|
|
verify(tbClusterService).broadcastEntityStateChangeEvent(any(), eq(importedDeviceProfile.getId()), eq(ComponentLifecycleEvent.CREATED)); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdgeService(any(), any(), eq(importedDeviceProfile.getId()), any(), any(), eq(EdgeEventActionType.ADDED)); |
|
|
|
verify(tbClusterService).sendNotificationMsgToEdge(any(), any(), eq(importedDeviceProfile.getId()), any(), any(), eq(EdgeEventActionType.ADDED)); |
|
|
|
verify(otaPackageStateService).update(eq(importedDeviceProfile), eq(false), eq(false)); |
|
|
|
|
|
|
|
Device importedDevice = (Device) importEntity(tenantAdmin2, getAndClone(entitiesExportData, EntityType.DEVICE)).getSavedEntity(); |
|
|
|
|