package jnpf.dmsService;
|
|
import jnpf.dmsEntity.kanwu.DmsXiudingKanwuRow;
|
import jnpf.dmsMapper.DmsXiudingKanwuMapper;
|
import jnpf.dmsIntegration.audit.DmsBusinessChangeAudit;
|
import jnpf.exception.DataException;
|
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.extension.ExtendWith;
|
import org.junit.jupiter.params.ParameterizedTest;
|
import org.junit.jupiter.params.provider.ValueSource;
|
import org.mockito.*;
|
import org.mockito.junit.jupiter.MockitoExtension;
|
import java.util.*;
|
import static org.junit.jupiter.api.Assertions.*;
|
import static org.mockito.Mockito.*;
|
|
@ExtendWith(MockitoExtension.class)
|
class DmsXiudingKanwuServiceTest {
|
@Mock DmsXiudingKanwuMapper mapper;
|
@Mock DmsBusinessChangeAudit audit;
|
@InjectMocks DmsXiudingKanwuService service;
|
DmsXiudingKanwuRow row(String id) {
|
DmsXiudingKanwuRow row = new DmsXiudingKanwuRow();
|
row.setKanwuZixiangId(id); row.setKanwuShenqingId("request");
|
row.setWenjianId("file"); row.setBanbenId("base"); row.setKanwuNeirong("content");
|
row.setChuliJielun("yixiugai_queren"); row.setChuliYuanyin("已核对并修订");
|
row.setChuliRenId("drafter"); row.setChuliShijian(new Date(1000));
|
return row;
|
}
|
void arrange(List<DmsXiudingKanwuRow> handled, List<DmsXiudingKanwuRow> approved) {
|
when(mapper.selectHandlingForUpdate("tenant", "audit")).thenReturn(handled);
|
when(mapper.selectApprovedForUpdate("tenant", "file", "base")).thenReturn(approved);
|
}
|
List<DmsXiudingKanwuRow> load() { return service.loadAndValidate("tenant", "audit", "file", "base"); }
|
@Test void acceptsEmptyScope() { arrange(List.of(), List.of()); assertTrue(load().isEmpty()); }
|
@Test void sortsWithoutMutatingMapperListAndNormalizesFiles() {
|
DmsXiudingKanwuRow handled = row("a"), source = row("a");
|
handled.setFujian("[{\"url\":\"x\",\"name\":\"n\"}]");
|
source.setFujian("[{\"name\":\"n\",\"url\":\"x\"}]");
|
DmsXiudingKanwuRow empty = row("b"); empty.setFujian("[]");
|
arrange(List.of(empty, handled), List.of(source, row("b")));
|
assertEquals(List.of("a", "b"), load().stream().map(DmsXiudingKanwuRow::getKanwuZixiangId).toList());
|
}
|
@ParameterizedTest @ValueSource(strings={"yixiugai_queren", "bucaina"})
|
void bothOutcomesRequireReasonAndAuditFields(String outcome) {
|
DmsXiudingKanwuRow handled = row("a"); handled.setChuliJielun(outcome);
|
arrange(List.of(handled), List.of(row("a"))); assertEquals(outcome, load().get(0).getChuliJielun());
|
handled.setChuliYuanyin(" "); assertThrows(DataException.class, this::load);
|
handled.setChuliYuanyin("reason"); handled.setChuliRenId(null); assertThrows(DataException.class, this::load);
|
handled.setChuliRenId("drafter"); handled.setChuliShijian(null); assertThrows(DataException.class, this::load);
|
}
|
@Test void rejectsMissingNewApprovedNote() { arrange(List.of(row("a")), List.of(row("a"), row("b"))); assertThrows(DataException.class, this::load); }
|
@Test void rejectsUnapprovedOrOutOfScopeNote() { arrange(List.of(row("other")), List.of(row("a"))); assertThrows(DataException.class, this::load); }
|
@Test void rejectsDuplicateHandling() { arrange(List.of(row("a"), row("a")), List.of(row("a"), row("b"))); assertThrows(DataException.class, this::load); }
|
@Test void rejectsChangedContentOrFiles() {
|
DmsXiudingKanwuRow handled = row("a"); arrange(List.of(handled), List.of(row("a")));
|
handled.setKanwuNeirong("changed"); assertThrows(DataException.class, this::load);
|
handled.setKanwuNeirong("content"); handled.setFujian("[{}]"); assertThrows(DataException.class, this::load);
|
handled.setFujian("{}"); assertThrows(DataException.class, this::load);
|
handled.setFujian("invalid"); assertThrows(DataException.class, this::load);
|
}
|
@Test void rejectsUnknownOutcome() { DmsXiudingKanwuRow handled=row("a");handled.setChuliJielun("yes");arrange(List.of(handled),List.of(row("a")));assertThrows(DataException.class,this::load); }
|
@Test void preservesFirstProcessingAuditAndOnlyClosesUnprocessedRows() {
|
DmsXiudingKanwuRow processed = row("a"); processed.setShifouYichuli("yes");
|
arrange(List.of(row("a"), row("b")), List.of(processed, row("b")));
|
List<DmsXiudingKanwuRow> verified = load();
|
when(mapper.markProcessed("tenant", verified.get(1))).thenReturn(1);
|
Date writtenAt = new Date(9000);
|
Map<String, Object> before = DmsBusinessChangeAudit.values("shifou_yichuli", null,
|
"chuliren", "previous", "chuli_shijian", null);
|
Map<String, Object> after = DmsBusinessChangeAudit.values("shifou_yichuli", "yes",
|
"chuliren", "drafter", "chuli_shijian", writtenAt);
|
when(mapper.selectProcessingState("tenant", "b")).thenReturn(before, after);
|
service.complete("tenant", "audit", verified);
|
verify(mapper, never()).markProcessed("tenant", verified.get(0));
|
verify(mapper).markProcessed("tenant", verified.get(1));
|
verify(mapper, never()).selectProcessingState("tenant", "a");
|
verify(audit).record(eq("tenant"), eq("DMS_REVISION_ERRATA_PROCESSED"),
|
eq("修订生效后回写勘误处理状态"), eq("dms_wenjian_kanwu_shenqing_zixiang"), eq("b"),
|
eq(before), eq(after), eq("已核对并修订"), argThat(context ->
|
"audit".equals(context.get("xiuding_shenhe_id"))
|
&& "request".equals(context.get("kanwu_shenqing_id"))
|
&& "yixiugai_queren".equals(context.get("chuli_jielun"))
|
&& new Date(1000).equals(context.get("chuli_shijian"))));
|
verifyNoMoreInteractions(audit);
|
}
|
@Test void emptyOrAlreadyProcessedRowsDoNotCreateAuditEvents() {
|
service.complete("tenant", "audit", List.of());
|
DmsXiudingKanwuRow processed = row("a");
|
processed.setAlreadyProcessed(true);
|
service.complete("tenant", "audit", List.of(processed));
|
verifyNoInteractions(mapper, audit);
|
}
|
@Test void updateFailurePropagatesToEffectiveTransaction() {
|
when(mapper.selectProcessingState("tenant", "a")).thenReturn(Map.of("id", "a"));
|
assertThrows(DataException.class, () -> service.complete("tenant", "audit", List.of(row("a"))));
|
verify(mapper).markProcessed(eq("tenant"), any());
|
verifyNoInteractions(audit);
|
}
|
@Test void missingSnapshotDoesNotFabricateAuditValues() {
|
when(mapper.selectProcessingState("tenant", "a")).thenReturn(null);
|
assertThrows(DataException.class, () -> service.complete("tenant", "audit", List.of(row("a"))));
|
verify(mapper, never()).markProcessed(anyString(), any());
|
verifyNoInteractions(audit);
|
}
|
}
|
