package com.ruoyi.order.service.impl; import com.ruoyi.account.api.feignClient.AppUserIntegralChangeClient; import com.ruoyi.chargingPile.api.feignClient.ChargingGunClient; import com.ruoyi.chargingPile.api.feignClient.ChargingPileClient; import com.ruoyi.chargingPile.api.feignClient.SiteClient; import com.ruoyi.chargingPile.api.model.Site; import com.ruoyi.chargingPile.api.model.TChargingGun; import com.ruoyi.chargingPile.api.model.TChargingPile; import com.ruoyi.common.core.domain.R; import com.ruoyi.common.security.service.TokenService; import com.ruoyi.integration.api.model.UploadRealTimeMonitoringData; import com.ruoyi.order.api.model.TChargingOrder; import com.ruoyi.order.api.model.TVinChargingOrder; import com.ruoyi.order.dto.ChargingDetails; import com.ruoyi.order.mapper.TChargingOrderMapper; import com.ruoyi.order.mapper.TVinChargingOrderMapper; import com.ruoyi.order.util.mongodb.service.UploadRealTimeMonitoringDataService; import com.ruoyi.order.vo.EndOfChargePageInfo; import com.baomidou.mybatisplus.core.MybatisConfiguration; import com.baomidou.mybatisplus.core.metadata.TableInfoHelper; import com.ruoyi.system.api.model.LoginUserApplet; import org.apache.ibatis.builder.MapperBuilderAssistant; import org.junit.jupiter.api.BeforeAll; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.junit.jupiter.api.extension.ExtendWith; import org.mockito.InjectMocks; import org.mockito.Mock; import org.mockito.junit.jupiter.MockitoExtension; import org.springframework.test.util.ReflectionTestUtils; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.Arrays; import java.util.Collections; import static org.junit.jupiter.api.Assertions.assertEquals; import static org.junit.jupiter.api.Assertions.assertNotNull; import static org.junit.jupiter.api.Assertions.assertNull; import static org.mockito.ArgumentMatchers.any; import static org.mockito.Mockito.when; /** * TChargingOrderServiceImpl 小程序接口对 VIN 码充电订单（t_vin_charging_order）的兜底逻辑测试： * getChargingDetails（正在充电详情）、getEndOfChargePageInfo（结束页详情）。 */ @ExtendWith(MockitoExtension.class) class TChargingOrderServiceImplVinFallbackTest { @InjectMocks private TChargingOrderServiceImpl service; @Mock private TChargingOrderMapper mapper; @Mock private TVinChargingOrderMapper vinChargingOrderMapper; @Mock private TokenService tokenService; @Mock private ChargingGunClient chargingGunClient; @Mock private ChargingPileClient chargingPileClient; @Mock private SiteClient siteClient; @Mock private UploadRealTimeMonitoringDataService uploadRealTimeMonitoringDataService; @Mock private AppUserIntegralChangeClient appUserIntegralChangeClient; /** * 纯单测无 Spring 容器，MyBatis-Plus 的 lambda 列缓存需手工初始化， * 否则 LambdaQueryWrapper 解析 getter 引用时抛 "can not find lambda cache" */ @BeforeAll static void initMybatisPlusTableInfo() { MapperBuilderAssistant assistant = new MapperBuilderAssistant(new MybatisConfiguration(), ""); TableInfoHelper.initTableInfo(assistant, TChargingOrder.class); TableInfoHelper.initTableInfo(assistant, TVinChargingOrder.class); } @BeforeEach void setUp() { ReflectionTestUtils.setField(service, "baseMapper", mapper); } @Test void getChargingDetailsFallsBackToVinOrderAndAssemblesRealTimeData() { LoginUserApplet loginUser = new LoginUserApplet(); loginUser.setUserId(88L); when(tokenService.getLoginUserApplet()).thenReturn(loginUser); // 普通订单表查不到 when(mapper.selectOne(any())).thenReturn(null); TVinChargingOrder vinOrder = new TVinChargingOrder(); vinOrder.setId(1001L); vinOrder.setAppUserId(88L); vinOrder.setChargingGunId(5); vinOrder.setStatus(3); vinOrder.setCode("VD20261013001"); vinOrder.setResidualAmount(new BigDecimal("66.60")); when(vinChargingOrderMapper.selectOne(any())).thenReturn(vinOrder); TChargingGun gun = new TChargingGun(); gun.setChargingPileId(7); when(chargingGunClient.getChargingGunById(5)).thenReturn(R.ok(gun)); TChargingPile pile = new TChargingPile(); pile.setName("1号桩"); pile.setSiteId(9); when(chargingPileClient.getChargingPileById(7)).thenReturn(R.ok(pile)); Site site = new Site(); site.setName("城东站"); when(siteClient.getSiteByIds(Arrays.asList(9))).thenReturn(R.ok(Collections.singletonList(site))); UploadRealTimeMonitoringData data = new UploadRealTimeMonitoringData(); data.setOutput_current(new BigDecimal("10")); data.setOutput_voltage(new BigDecimal("220")); data.setSoc(50); data.setTime_remaining(30); data.setCharging_degree(new BigDecimal("5.5")); data.setCumulative_charging_time(75); when(uploadRealTimeMonitoringDataService.getLastDataById("VD20261013001")).thenReturn(data); ChargingDetails details = service.getChargingDetails(5); assertEquals("1001", details.getId()); assertEquals("城东站-1号桩", details.getName()); assertEquals("VD20261013001", details.getCode()); assertEquals(Integer.valueOf(3), details.getStatus()); assertEquals(0, new BigDecimal("66.60").compareTo(details.getChargingCost())); assertEquals(0, new BigDecimal("10").compareTo(details.getChargeCurrent())); assertEquals(0, new BigDecimal("220").compareTo(details.getChargeVoltage())); assertEquals(0, new BigDecimal("2.200").compareTo(details.getChargePower())); assertEquals(Integer.valueOf(50), details.getCompletionRatio()); assertEquals(Integer.valueOf(30), details.getRemainingChargeTime()); assertEquals(0, new BigDecimal("5.5").compareTo(details.getChargedDegrees())); assertEquals("01:15", details.getChargedTime()); } @Test void getChargingDetailsReturnsNullWhenNeitherNormalNorVinOrderExists() { LoginUserApplet loginUser = new LoginUserApplet(); loginUser.setUserId(88L); when(tokenService.getLoginUserApplet()).thenReturn(loginUser); when(mapper.selectOne(any())).thenReturn(null); when(vinChargingOrderMapper.selectOne(any())).thenReturn(null); assertNull(service.getChargingDetails(5)); } @Test void getEndOfChargePageInfoFallsBackToVinOrder() { LoginUserApplet loginUser = new LoginUserApplet(); loginUser.setUserId(88L); when(tokenService.getLoginUserApplet()).thenReturn(loginUser); when(mapper.selectById("1001")).thenReturn(null); TVinChargingOrder vinOrder = new TVinChargingOrder(); vinOrder.setId(1001L); vinOrder.setAppUserId(88L); vinOrder.setCode("VD20261013001"); vinOrder.setPaymentAmount(new BigDecimal("18.50")); vinOrder.setRechargeAmount(new BigDecimal("50.00")); vinOrder.setRefundAmount(new BigDecimal("31.50")); vinOrder.setStartTime(LocalDateTime.of(2026, 10, 13, 10, 0)); vinOrder.setEndTime(LocalDateTime.of(2026, 10, 13, 11, 30)); when(vinChargingOrderMapper.selectById("1001")).thenReturn(vinOrder); when(appUserIntegralChangeClient.getTAppUserIntegralChangeByOrderCode("VD20261013001")) .thenReturn(R.ok(null)); EndOfChargePageInfo info = service.getEndOfChargePageInfo("1001"); assertEquals("1001", info.getId()); assertEquals("VD20261013001", info.getCode()); assertEquals(0, new BigDecimal("18.50").compareTo(info.getPaymentAmount())); assertEquals(0, new BigDecimal("50.00").compareTo(info.getRechargeAmount())); assertEquals(0, new BigDecimal("31.50").compareTo(info.getRefundAmount())); assertEquals(Integer.valueOf(0), info.getIntegral()); assertEquals("10:00", info.getStartHour()); assertEquals("11:30", info.getEndHour()); assertEquals("1小时30分钟", info.getDuration()); } @Test void getEndOfChargePageInfoThrowsWhenOrderMissingInBothTables() { // 两表均查不到订单时在获取登录用户之前即抛异常，tokenService 无需 stub when(mapper.selectById("1001")).thenReturn(null); when(vinChargingOrderMapper.selectById("1001")).thenReturn(null); RuntimeException exception = null; try { service.getEndOfChargePageInfo("1001"); } catch (RuntimeException ex) { exception = ex; } assertNotNull(exception); assertEquals("充电订单不存在", exception.getMessage()); } }