package cn.iocoder.yudao.module.mes.service.trace.consumer;

import cn.iocoder.yudao.framework.test.core.ut.BaseDbUnitTest;
import cn.iocoder.yudao.module.mes.dal.dataobject.trace.consumer.MesTraceConsumerScanEventDO;
import cn.iocoder.yudao.module.mes.dal.mysql.trace.consumer.MesTraceConsumerScanEventMapper;
import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test;
import org.springframework.context.annotation.Import;

import java.util.List;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;

/**
 * {@link MesTraceConsumerScanEventServiceImpl} 的单元测试
 *
 * @author 超级管理员
 */
@Import(MesTraceConsumerScanEventServiceImpl.class)
public class MesTraceConsumerScanEventServiceImplTest extends BaseDbUnitTest {

    @Resource
    private MesTraceConsumerScanEventService eventService;

    @Resource
    private MesTraceConsumerScanEventMapper eventMapper;

    /**
     * 查询刚插入的第一条事件（id 由序列/雪花算法生成，不固定为 1）
     */
    private MesTraceConsumerScanEventDO getFirstEvent() {
        List<MesTraceConsumerScanEventDO> list = eventMapper.selectList(null);
        return list.isEmpty() ? null : list.get(0);
    }

    @Test
    public void testRecordScan_成功事件落库() {
        // 无请求上下文时 IP/UA/渠道为空，但事件仍应落库且不抛异常
        eventService.recordScan("PC-RAW-CODE", "PC-CODE-001", "BAG", 100L, true, null);

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        assertEquals("PC-RAW-CODE", event.getTraceCode());
        assertEquals("PC-CODE-001", event.getNormalizedCode());
        assertEquals("BAG", event.getSourceType());
        assertEquals(100L, event.getBatchId());
        assertTrue(Boolean.TRUE.equals(event.getSuccess()));
        assertNull(event.getErrorCode());
        assertNull(event.getIpHash()); // 无请求上下文无明文 IP，也不应保存
        assertNull(event.getChannel());
        assertNotNull(event.getEventTime());
    }

    @Test
    public void testRecordScan_失败事件落库() {
        eventService.recordScan("NOT-EXIST", null, null, null, false, "MES_TRACE_CODE_NOT_FOUND");

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        assertFalse(Boolean.TRUE.equals(event.getSuccess()));
        assertEquals("MES_TRACE_CODE_NOT_FOUND", event.getErrorCode());
        assertNull(event.getSourceType());
        assertNull(event.getBatchId());
    }

    @Test
    public void testRecordScan_超长码截断() {
        String longCode = "X".repeat(500);
        eventService.recordScan(longCode, longCode, "BATCH", null, true, null);

        MesTraceConsumerScanEventDO event = getFirstEvent();
        assertNotNull(event);
        // traceCode 截断到 255、normalizedCode 截断到 128
        assertEquals(255, event.getTraceCode().length());
        assertEquals(128, event.getNormalizedCode().length());
    }

    @Test
    public void testRecordScan_记录异常不影响接口() {
        // recordScan 内部吞掉异常，事件仍应正常落库
        eventService.recordScan("CODE", "CODE", "BATCH", null, true, null);
        assertNotNull(getFirstEvent());
    }

}