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.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; @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 void test() { // String str = ",,"; // String[] parts = str.split(","); // for (String part : parts) { // System.out.println(part); // } System.out.println(DigestUtil.md5Hex("VDATA.XM104/177301/c5Kl}xN&i(").toUpperCase()); } @Test void testBCS101ApiService() throws Exception { List list = deliveryMainService.list(); List 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); } }); } }