package jnpf.elnService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.Wrapper;
|
import jnpf.elnEntity.runtime.ElnRecordVos;
|
import jnpf.elnEntity.runtime.ElnSharedFillOperationEntity;
|
import jnpf.elnMapper.ElnSharedFillOperationMapper;
|
import jnpf.util.JsonUtil;
|
import org.junit.Test;
|
|
import java.util.Collections;
|
|
import static org.junit.Assert.assertEquals;
|
import static org.junit.Assert.assertFalse;
|
import static org.junit.Assert.assertNull;
|
import static org.junit.Assert.assertSame;
|
import static org.junit.Assert.assertTrue;
|
import static org.mockito.ArgumentMatchers.any;
|
import static org.mockito.Mockito.mock;
|
import static org.mockito.Mockito.when;
|
|
public class ElnRecordSourceSyncOperationServiceTest {
|
|
@Test
|
public void persistsPendingDocumentResultAndConfirmsItIdempotently() {
|
ElnSharedFillOperationMapper operations = mock(ElnSharedFillOperationMapper.class);
|
ElnSharedFillOperationEntity open = operation("OPEN", null);
|
when(operations.insertIgnore(any(ElnSharedFillOperationEntity.class))).thenReturn(1);
|
when(operations.selectOne(any(Wrapper.class))).thenReturn(open);
|
when(operations.prepareResult(any(String.class), any(String.class), any(String.class),
|
any(String.class), any(String.class))).thenReturn(1);
|
when(operations.confirmPrepared(any(String.class), any(String.class),
|
any(String.class))).thenReturn(1, 0);
|
ElnRecordSourceSyncOperationService service =
|
new ElnRecordSourceSyncOperationService(operations);
|
ElnRecordVos.SourceSynchronized result = new ElnRecordVos.SourceSynchronized();
|
result.setOperationCode("sync-1");
|
result.setChangedFieldCodes(Collections.singletonList("source"));
|
result.setRecordId("record-1");
|
|
assertNull(service.begin("tenant-1", "user-1", "sync-1", "digest-1"));
|
assertSame(result, service.prepare(
|
"tenant-1", "user-1", "sync-1", "digest-1", result));
|
|
ElnSharedFillOperationEntity pending = operation(
|
"OPEN", JsonUtil.getObjectToString(result));
|
when(operations.insertIgnore(any(ElnSharedFillOperationEntity.class))).thenReturn(0);
|
when(operations.selectOne(any(Wrapper.class))).thenReturn(pending);
|
when(operations.selectList(any(Wrapper.class)))
|
.thenReturn(Collections.singletonList(pending));
|
assertEquals(Collections.singletonList("source"), service.begin(
|
"tenant-1", "user-1", "sync-1", "digest-1").getChangedFieldCodes());
|
assertEquals("sync-1", service.pending(
|
"tenant-1", "user-1", "record-1").getOperationCode());
|
assertTrue(service.hasPendingDocumentConfirmation("tenant-1", "record-1"));
|
assertTrue(service.confirm("tenant-1", "user-1", "sync-1"));
|
|
ElnSharedFillOperationEntity completed = operation(
|
"COMPLETED", JsonUtil.getObjectToString(result));
|
when(operations.selectOne(any(Wrapper.class))).thenReturn(completed);
|
assertFalse(service.confirm("tenant-1", "user-1", "sync-1"));
|
}
|
|
private static ElnSharedFillOperationEntity operation(String status, String resultJson) {
|
ElnSharedFillOperationEntity value = new ElnSharedFillOperationEntity();
|
value.setOperationCode("sync-1");
|
value.setRequestDigest("digest-1");
|
value.setOperationStatus(status);
|
value.setResultJson(resultJson);
|
value.setOperatorUserId("user-1");
|
value.setFTenantId("tenant-1");
|
return value;
|
}
|
}
|
