package com.gs.xiaomi;
|
|
import cn.hutool.crypto.digest.DigestUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
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.dto.SnListItemDto;
|
import com.gs.xiaomi.entity.DeliveryMain;
|
import com.gs.xiaomi.entity.SnListItem;
|
import com.gs.xiaomi.service.BCS101ApiService;
|
import com.gs.xiaomi.service.BCS101Service;
|
import com.gs.xiaomi.service.DeliveryMainService;
|
import com.gs.xiaomi.service.SnListItemService;
|
import com.gs.xiaomi.service.Xm104Service;
|
import com.gs.xiaomi.util.SnListItemConverter;
|
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;
|
|
@Autowired
|
private SnListItemService snListItemService;
|
|
@Autowired
|
private BCS101Service bcs101Service;
|
|
@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());
|
|
list.forEach(s -> {
|
System.out.println(String.valueOf(Integer.parseInt(s.getLifnr())) + ":" + s.getZzasn());
|
// 创建测试请求参数
|
BCS101Request request = new BCS101Request();
|
request.setSupplierId(String.valueOf(Integer.parseInt(s.getHubLifnr())));
|
request.setDocNo(s.getZzasn());
|
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);
|
|
// 检查响应是否成功
|
if (response.isSuccess()) {
|
// 获取snList数据
|
List<SnListItemDto> snList = response.getBody().getSnList();
|
|
if (snList != null && !snList.isEmpty()) {
|
System.out.println("获取到 " + snList.size() + " 条SN数据，开始持久化...");
|
|
// 转换DTO为Entity，并设置关联信息
|
List<SnListItem> entityList = SnListItemConverter.toEntityList(
|
snList,
|
s.getId(), // deliveryMainId - 送货单主表ID
|
s.getZzasn() // zzasn - 送货单号
|
);
|
|
// 先删除该送货单已有的SN数据（避免重复）
|
snListItemService.lambdaUpdate()
|
.eq(SnListItem::getZzasn, s.getZzasn())
|
.remove();
|
|
// 批量保存到数据库
|
boolean saved = snListItemService.saveBatch(entityList);
|
|
if (saved) {
|
System.out.println("成功保存 " + entityList.size() + " 条SN数据到数据库");
|
} else {
|
System.err.println("保存SN数据失败！");
|
}
|
} else {
|
System.out.println("响应中没有SN数据");
|
}
|
} else {
|
System.err.println("BCS101接口调用失败: " + response.getErrorDesc());
|
}
|
|
} catch (JsonProcessingException e) {
|
throw new RuntimeException(e);
|
}
|
});
|
}
|
|
|
/**
|
* 测试BCS101数据同步 - 使用BCS101Service
|
* @param asn 送货单号
|
* @throws Exception 异常
|
*/
|
@Test
|
void testGetBCS101() throws Exception {
|
// 直接调用BCS101Service进行数据同步
|
bcs101Service.syncBCS101DataByAsn("9316702418");
|
}
|
}
|
