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.conditions.AbstractWrapper;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
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.ArgumentCaptor;
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.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

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.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.verify;
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 getChargingDetailsUsesPaidAmountAsUsedCostWhenRealTimeDataPresent() {
        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);
        // 设备上报已充金额为 4 位小数，展示口径统一保留 2 位
        data.setPaid_amount(new BigDecimal("12.3456"));
        when(uploadRealTimeMonitoringDataService.getLastDataById("VD20261013001")).thenReturn(data);

        ChargingDetails details = service.getChargingDetails(5);

        assertEquals(0, new BigDecimal("12.35").compareTo(details.getChargingCost()));
    }

    @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());
    }

    @Test
    void getChargingDetailsReturnsFinishedNormalOrderAndQueriesStatus5() {
        // 小程序主动结束充电后订单已结束(5)，充电中页面仍需拿到该笔订单，
        // 用于关闭「请勿拔枪，正在结束充电」并展示「充电完成，可拔枪」
        LoginUserApplet loginUser = new LoginUserApplet();
        loginUser.setUserId(88L);
        when(tokenService.getLoginUserApplet()).thenReturn(loginUser);
        TChargingOrder order = new TChargingOrder();
        order.setId(3003L);
        order.setAppUserId(88L);
        order.setChargingGunId(5);
        order.setStatus(5);
        order.setCode("CH20261014001");
        order.setResidualAmount(new BigDecimal("20.00"));
        when(mapper.selectOne(any())).thenReturn(order);
        stubGunPileAndSite();
        when(uploadRealTimeMonitoringDataService.getLastDataById("CH20261014001")).thenReturn(null);

        ChargingDetails details = service.getChargingDetails(5);

        assertNotNull(details, "订单已结束时应返回完成态而非 null");
        assertEquals("3003", details.getId());
        assertEquals(Integer.valueOf(5), details.getStatus());
        assertEquals("CH20261014001", details.getCode());
        assertEquals(0, new BigDecimal("20.00").compareTo(details.getChargingCost()));

        @SuppressWarnings("unchecked")
        ArgumentCaptor<Wrapper<TChargingOrder>> captor = ArgumentCaptor.forClass(Wrapper.class);
        verify(mapper).selectOne(captor.capture());
        assertStatusFilterCoversFinished(captor.getValue());
    }

    @Test
    void getChargingDetailsReturnsFinishedVinOrderAndQueriesStatus5() {
        // VIN 码订单结束后同样需要返回完成态，兜底查询的状态过滤必须与主查询一致
        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(5);
        vinOrder.setCode("VD20261014001");
        vinOrder.setResidualAmount(new BigDecimal("66.60"));
        when(vinChargingOrderMapper.selectOne(any())).thenReturn(vinOrder);
        stubGunPileAndSite();
        when(uploadRealTimeMonitoringDataService.getLastDataById("VD20261014001")).thenReturn(null);

        ChargingDetails details = service.getChargingDetails(5);

        assertNotNull(details, "VIN 订单已结束时应返回完成态而非 null");
        assertEquals(Integer.valueOf(5), details.getStatus());
        assertEquals("VD20261014001", details.getCode());

        @SuppressWarnings("unchecked")
        ArgumentCaptor<Wrapper<TVinChargingOrder>> captor = ArgumentCaptor.forClass(Wrapper.class);
        verify(vinChargingOrderMapper).selectOne(captor.capture());
        assertStatusFilterCoversFinished(captor.getValue());
    }

    /** getChargingDetails 组装链路依赖的充电枪/充电桩/站点远程调用 stub */
    private void stubGunPileAndSite() {
        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)));
    }

    /**
     * 断言订单查询条件中的 status 过滤覆盖 2、3、4、5。
     * 已结束(5) 必须在过滤范围内，否则小程序结束充电后拿不到订单，会一直停留在「正在结束充电」提示。
     */
    private void assertStatusFilterCoversFinished(Wrapper<?> wrapper) {
        AbstractWrapper<?, ?, ?> queryWrapper = (AbstractWrapper<?, ?, ?>) wrapper;
        Matcher inMatcher = Pattern.compile("status\\s+in\\s*\\(([^)]*)\\)", Pattern.CASE_INSENSITIVE)
                .matcher(queryWrapper.getSqlSegment());
        assertTrue(inMatcher.find(), "查询条件中应存在 status IN 过滤");
        List<Object> statusValues = new ArrayList<>();
        Matcher placeholderMatcher = Pattern.compile("MPGENVAL\\d+").matcher(inMatcher.group(1));
        while (placeholderMatcher.find()) {
            statusValues.add(queryWrapper.getParamNameValuePairs().get(placeholderMatcher.group()));
        }
        assertTrue(statusValues.containsAll(Arrays.asList(2, 3, 4, 5)),
                "status 过滤应包含 2,3,4,5，实际为：" + statusValues);
    }
}