更新为正式环境配置

tjx

2025-10-29 b93dbb8f077b5415a0002c66973b716f874f1953

 src/test/java/com/gs/xiaomi/XiaomiApplicationTests.java

@@ -1,25 +1,46 @@
package com.gs.xiaomi;

import cn.hutool.crypto.digest.DigestUtil;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.gs.xiaomi.dto.BCS101Request;
import com.gs.xiaomi.dto.BCS101Response;
import com.gs.xiaomi.dto.NumbericalDto;
import com.gs.xiaomi.entity.DeliveryMain;
import com.gs.xiaomi.service.BCS101ApiService;
import com.gs.xiaomi.service.XM104Service;
import com.gs.xiaomi.service.DeliveryMainService;
import com.gs.xiaomi.service.Xm104Service;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

import java.io.IOException;
import java.util.List;
import java.util.stream.Collectors;

@SpringBootTest
class XiaomiApplicationTests {

    @Autowired
    private XM104Service xm104Service;
    private Xm104Service xm104Service;

    @Autowired
    private BCS101ApiService bcs101ApiService;

    @Autowired
    private DeliveryMainService deliveryMainService;

    @Test
    void contextLoads() throws Exception {
        xm104Service.getDb();
    }

    //manualSynchronization
    @Test
    void contextLoads1() throws Exception {
        NumbericalDto barcode = new NumbericalDto();
        barcode.setAsn("9316702418");
        xm104Service.manualSynchronization(barcode);
    }

    @Test
@@ -34,32 +55,36 @@

    @Test
    void testBCS101ApiService() throws Exception {
        // 创建测试请求参数
        BCS101Request request = new BCS101Request();
        request.setSupplierId("100071");
        request.setDocNo("9311991542");
        request.setDocType("ASNGR");
        request.setPageNo(1);
        request.setPageSize(1000);

        System.out.println("=== 测试BCS101 API服务（Basic Auth版本） ===");
        try {
            // 调用标准BCS101 API服务（只使用Basic Auth）
            String response = bcs101ApiService.getBCS101Data(request);
            System.out.println("BCS101 API Response: " + response);
        } catch (Exception e) {
            System.out.println("BCS101 API调用异常: " + e.getMessage());
            e.printStackTrace();
        }
        List<DeliveryMain> list = deliveryMainService.list();

        System.out.println("\n=== 测试BCS101 API服务（带X5协议版本） ===");
        try {
            // 调用带X5协议的BCS101 API服务
            String responseWithX5 = bcs101ApiService.getBCS101DataWithX5(request, true);
            System.out.println("BCS101 API Response (X5): " + responseWithX5);
        } catch (Exception e) {
            System.out.println("BCS101 API X5调用异常: " + e.getMessage());
            e.printStackTrace();
        }
        List<String> collect = list.stream().map(DeliveryMain::getZzasn).collect(Collectors.toList());

        collect.forEach(s->{
            // 创建测试请求参数
            BCS101Request request = new BCS101Request();
            request.setSupplierId("177301");
            request.setDocNo("9316692708");
            request.setDocType("ASNGR");
            request.setPageNo(1);
            request.setPageSize(1000);

            // 调用API获取原始JSON字符串
            String bcs101Data = null;
            try {
                bcs101Data = bcs101ApiService.getBCS101Data(request);
            } catch (IOException e) {
                throw new RuntimeException(e);
            }
            System.out.println("原始响应: " + bcs101Data);

            // 解析JSON为BCS101Response对象
            ObjectMapper objectMapper = new ObjectMapper();
            try {
                BCS101Response response = objectMapper.readValue(bcs101Data, BCS101Response.class);
            } catch (JsonProcessingException e) {
                throw new RuntimeException(e);
            }
        });
    }
}