package jnpf.dmsService;
|
|
import jnpf.dmsEntity.center.DmsCenterActivation;
|
import jnpf.dmsEntity.permission.entity.DmsDocumentEntity;
|
import jnpf.dmsEntity.permission.entity.DmsFileVersionEntity;
|
import jnpf.dmsMapper.*;
|
import jnpf.dmsService.center.DmsCenterActivationService;
|
import jnpf.dmsService.search.DmsSearchIndexJobService;
|
import jnpf.exception.DataException;
|
import org.junit.jupiter.api.Test;
|
import java.util.*;
|
import static org.junit.jupiter.api.Assertions.*;
|
import static org.mockito.Mockito.*;
|
|
class DmsCenterActivationServiceTest {
|
final DmsDocumentMapper documents = mock(DmsDocumentMapper.class);
|
final DmsFileVersionMapper versions = mock(DmsFileVersionMapper.class);
|
final DmsVersionStateMapper states = mock(DmsVersionStateMapper.class);
|
final DmsSearchIndexJobService search = mock(DmsSearchIndexJobService.class);
|
final jnpf.dmsIntegration.audit.DmsBusinessChangeAudit businessAudit = mock(jnpf.dmsIntegration.audit.DmsBusinessChangeAudit.class);
|
final DmsCenterActivationService service = new DmsCenterActivationService(businessAudit, documents, versions, states, search);
|
final UUID main = UUID.randomUUID(), record = UUID.randomUUID(), mainVersion = UUID.randomUUID(), recordVersion = UUID.randomUUID();
|
final DmsDocumentEntity recordDocument = new DmsDocumentEntity();
|
final DmsCenterActivation reuse = new DmsCenterActivation(main, mainVersion, mainVersion, "REUSE", null);
|
final DmsCenterActivation retire = new DmsCenterActivation(record, recordVersion, recordVersion, "RETIRE", null);
|
void arrange() {
|
when(documents.selectByTenantAndIdForUpdate("tenant", main)).thenReturn(new DmsDocumentEntity());
|
recordDocument.setMainDocumentId(main);
|
when(documents.selectByTenantAndIdForUpdate("tenant", record)).thenReturn(recordDocument);
|
DmsFileVersionEntity m = new DmsFileVersionEntity(); m.setId(mainVersion);
|
DmsFileVersionEntity r = new DmsFileVersionEntity(); r.setId(recordVersion);
|
when(versions.selectCurrentEffective("tenant", main)).thenReturn(m);
|
when(versions.selectCurrentEffective("tenant", record)).thenReturn(r);
|
}
|
@Test void removesOnlyApprovedRecordFromCurrentAndKeepsMainAndPhysicalContent() {
|
arrange(); when(states.retireCurrent("tenant", record, recordVersion, "actor")).thenReturn(1);
|
var before = new jnpf.dmsIntegration.audit.DmsVersionStateAuditRow(); before.setLifecycleStatus("EFFECTIVE");
|
var after = new jnpf.dmsIntegration.audit.DmsVersionStateAuditRow(); after.setLifecycleStatus("SUPERSEDED");
|
after.setStatusReason("修订移除记录，保留历史");
|
when(states.selectAuditState("tenant", recordVersion)).thenReturn(before, after);
|
service.activate("tenant", "actor", List.of(reuse, retire));
|
verify(states).retireCurrent("tenant", record, recordVersion, "actor");
|
verify(states, times(2)).selectAuditState("tenant", recordVersion);
|
verify(businessAudit).record(eq("tenant"), eq("DMS_VERSION_STATE_CHANGED"), anyString(), eq("dms_version_states"),
|
eq(recordVersion.toString()), argThat(m -> "EFFECTIVE".equals(m.get("lifecycle_status"))),
|
argThat(m -> "SUPERSEDED".equals(m.get("lifecycle_status"))), anyString(),
|
argThat(m -> record.equals(m.get("document_id"))));
|
verifyNoMoreInteractions(states, businessAudit);
|
verifyNoInteractions(search);
|
verify(documents, never()).bindMainDocument(any(), any(), any());
|
}
|
@Test void cannotRetireMainOrRecordFromDifferentDirectory() {
|
arrange(); recordDocument.setMainDocumentId(null);
|
assertThrows(DataException.class, () -> service.activate("tenant", "actor", List.of(reuse, retire)));
|
recordDocument.setMainDocumentId(UUID.randomUUID());
|
assertThrows(DataException.class, () -> service.activate("tenant", "actor", List.of(reuse, retire)));
|
verifyNoInteractions(states, search);
|
}
|
@Test void staleRecordVersionCannotBeRetired() {
|
arrange();
|
DmsFileVersionEntity changed = new DmsFileVersionEntity(); changed.setId(UUID.randomUUID());
|
when(versions.selectCurrentEffective("tenant", record)).thenReturn(changed);
|
assertThrows(DataException.class, () -> service.activate("tenant", "actor", List.of(reuse, retire)));
|
verifyNoInteractions(states, search);
|
}
|
}
|
