package com.battery.business.web;
|
|
import static org.junit.jupiter.api.Assertions.*;
|
import static org.mockito.Mockito.*;
|
import java.util.List;
|
import java.util.Map;
|
import java.util.ArrayList;
|
import java.util.LinkedHashMap;
|
import com.alibaba.fastjson2.JSON;
|
import com.battery.business.domain.TTest;
|
import com.battery.business.mapper.TTestMapper;
|
import com.battery.business.service.impl.TestConsoleDataServiceImpl;
|
import org.junit.jupiter.api.Test;
|
import org.junit.jupiter.api.BeforeEach;
|
import com.ruoyi.common.exception.ServiceException;
|
import org.springframework.test.util.ReflectionTestUtils;
|
|
/** 从控制台提交入口验证单页导入，数据库使用边界替身。 */
|
class ConsoleSingleSheetImportTest
|
{
|
private TTestMapper mapper;
|
private TTestController controller;
|
private final List<Map<String, Object>> saved = new ArrayList<>();
|
|
@BeforeEach void setUp()
|
{
|
mapper = mock(TTestMapper.class);
|
TTest test = new TTest(); test.setTestStatus("COMPLETED");
|
when(mapper.selectTestByIdForUpdate(1L)).thenReturn(test);
|
when(mapper.selectImportBinding(1L, "BAT-1")).thenReturn(Map.of(
|
"test_battery_id", 4L, "binding_id", 5L, "adapter_code", "adapter-a",
|
"devtype", 27, "devid", 1, "subdevid", 1, "chlid", 1));
|
when(mapper.selectImportBinding(1L, "BAT-2")).thenReturn(Map.of(
|
"test_battery_id", 6L, "binding_id", 7L, "adapter_code", "adapter-a",
|
"devtype", 27, "devid", 1, "subdevid", 1, "chlid", 2));
|
when(mapper.selectImportDataRecords(eq(1L), anyString())).thenAnswer(call -> new ArrayList<>(saved));
|
when(mapper.insertImportedDataRecord(anyString(), anyMap())).thenAnswer(call -> {
|
saved.add(new LinkedHashMap<>(call.getArgument(1))); return 1;
|
});
|
controller = new TTestController() {
|
@Override public Long getUserId() { return 1L; }
|
@Override public String getUsername() { return "tester"; }
|
};
|
ReflectionTestUtils.setField(controller, "consoleDataService", new TestConsoleDataServiceImpl(mapper));
|
}
|
|
@Test void identicalRowsInOneSheetAreSkipped()
|
{
|
var response = submit("REALTIME", List.of(row(), row()));
|
assertEquals(1, response.get("importedCount"));
|
assertEquals(1, response.get("skippedCount"));
|
}
|
|
@Test void allThreeTypesSkipRetryButRejectChangedContent()
|
{
|
for (String type : List.of("REALTIME", "STEP", "CYCLE"))
|
{
|
saved.clear();
|
var row = row();
|
row.put("deviceTimeRaw", "2023-05-08 11:42:11"); row.put("adapterTimezoneId", "Asia/Hong_Kong");
|
row.put("capacity", 8.5122); row.put("dischargeCapacity", 8.5122);
|
assertEquals(1, submit(type, List.of(row)).get("importedCount"));
|
row.put("sourceRow", 19);
|
row.put("capacity", new java.math.BigDecimal("8.512200"));
|
var repeated = submit(type, List.of(row));
|
assertEquals(0, repeated.get("importedCount"));
|
assertEquals(1, repeated.get("skippedCount"));
|
assertNull(repeated.get("actionId"));
|
row.put("cycleNo", 2);
|
var failure = assertThrows(ServiceException.class, () -> submit(type, List.of(row)));
|
assertTrue(failure.getMessage().contains("第19行，列「记录编号」"));
|
assertEquals(1, saved.size());
|
}
|
}
|
|
@Test void sameRecordNumberForDifferentBatteriesHasIndependentIdentity()
|
{
|
var other = row(); other.put("batteryNo", "BAT-2");
|
assertEquals(2, submit("REALTIME", List.of(row(), other)).get("importedCount"));
|
assertEquals("adapter-a:27:1:1:1", saved.get(0).get("source_identity"));
|
assertEquals("adapter-a:27:1:1:2", saved.get(1).get("source_identity"));
|
}
|
|
@Test void pollingSlotIsNotPartOfImportedDeviceContent()
|
{
|
submit("REALTIME", List.of(row()));
|
saved.get(0).put("capture_slot_utc", new java.util.Date(1683517380000L));
|
assertEquals(1, submit("REALTIME", List.of(row())).get("skippedCount"));
|
}
|
|
@Test void anyInvalidRowLeavesWholeSheetAndRevisionsUnwritten()
|
{
|
for (Map.Entry<String, Object> invalid : Map.<String, Object>of("cycleNo", 0, "recordedAt", "2023-05-08",
|
"voltage", "NaN", "batteryNo", "OTHER").entrySet())
|
{
|
var bad = row(); bad.put(invalid.getKey(), invalid.getValue()); bad.put("sourceRow", 23);
|
var failure = assertThrows(ServiceException.class, () -> submit("REALTIME", List.of(row(), bad)));
|
assertTrue(failure.getMessage().contains("第23行，列「"));
|
assertTrue(saved.isEmpty());
|
}
|
verify(mapper, never()).insertDataRevisionAction(any());
|
}
|
|
@Test void conflictAfterValidRowDoesNotWriteValidPrefixOrAudit()
|
{
|
submit("REALTIME", List.of(row()));
|
clearInvocations(mapper);
|
var next = row(); next.put("recordNo", "18"); next.put("recordedAt", 1683517391000L);
|
var conflict = row(); conflict.put("voltage", 9);
|
assertThrows(ServiceException.class, () -> submit("REALTIME", List.of(next, conflict)));
|
assertEquals(1, saved.size());
|
verify(mapper, never()).insertDataRevisionAction(any());
|
var sameSecond = row(); sameSecond.put("recordNo", "19"); sameSecond.put("sequenceId", 19);
|
assertEquals(1, submit("REALTIME", List.of(sameSecond)).get("importedCount"));
|
}
|
|
private Map<String, Object> row()
|
{
|
return new LinkedHashMap<>(Map.of("recordNo", "17", "batteryNo", "BAT-1", "recordedAt", 1683517331000L,
|
"cycleNo", 1, "stepNo", 1, "stepName", "恒流放电", "sequenceId", 17, "voltage", 1.3349));
|
}
|
|
private com.ruoyi.common.core.domain.AjaxResult submit(String type, List<Map<String, Object>> rows)
|
{
|
return controller.dataAction(1L, new TTestController.ConsoleDataActionRequest(type, "IMPORT",
|
"单页导入", "[]", JSON.toJSONString(rows), "开发测试", List.of()));
|
}
|
}
|
