| | |
| | | package com.gs.xiaomi; |
| | | |
| | | import com.gs.xiaomi.service.XM104Service; |
| | | 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; |
| | | 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<DeliveryMain> list = deliveryMainService.list(); |
| | | |
| | | 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); |
| | | } |
| | | }); |
| | | } |
| | | } |