package com.gs.xiaomi;
|
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.crypto.SmUtil;
|
import cn.hutool.crypto.digest.DigestUtil;
|
import com.fasterxml.jackson.core.JsonProcessingException;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import com.gs.xiaomi.config.DataAcquisitionConfiguration;
|
import com.gs.xiaomi.dto.BCS101Request;
|
import com.gs.xiaomi.service.BCS101ApiService;
|
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.UnsupportedEncodingException;
|
import java.net.URLEncoder;
|
import java.util.Base64;
|
import java.util.Date;
|
|
@SpringBootTest
|
class XiaomiApplicationTests {
|
|
@Autowired
|
private XM104Service xm104Service;
|
|
@Autowired
|
private BCS101ApiService bcs101ApiService;
|
|
@Test
|
void contextLoads() throws Exception {
|
xm104Service.getDb();
|
}
|
|
@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 {
|
// 创建测试请求参数
|
BCS101Request request = new BCS101Request();
|
request.setSupplierId("177301");
|
request.setDocNo("9311036039");
|
request.setDocType("ASNGR");
|
request.setPageNo(1);
|
request.setPageSize(1000);
|
|
//Error: ERROR_IN_MODULECHAIN;ERROR_IN_MODULECHAIN, Sender Channel 'CC_MI_OEM_HTTP_OUT' (ID: a58369adbaa03aafb76d2c02c2ae7cd7): Catching exception calling messaging system
|
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();
|
}
|
|
//Error: ERROR_IN_MODULECHAIN;ERROR_IN_MODULECHAIN, Sender Channel 'CC_MI_OEM_HTTP_OUT' (ID: a58369adbaa03aafb76d2c02c2ae7cd7): Catching exception calling messaging system
|
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();
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（调试版本） ===");
|
try {
|
// 调用调试版本API服务
|
String debugResponse = bcs101ApiService.getBCS101DataDebug(request);
|
System.out.println("BCS101 API Debug Response: " + debugResponse);
|
} catch (Exception e) {
|
System.out.println("BCS101 API 调试版本调用异常: " + e.getMessage());
|
e.printStackTrace();
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（简化版本） ===");
|
try {
|
// 调用简化版本API服务
|
String simpleResponse = bcs101ApiService.getBCS101DataSimple(request);
|
System.out.println("BCS101 API Simple Response: " + simpleResponse);
|
} catch (Exception e) {
|
System.out.println("BCS101 API 简化版本调用异常: " + e.getMessage());
|
e.printStackTrace();
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（X5协议标准版本） ===");
|
try {
|
// 调用X5协议标准版本
|
String x5StandardResponse = bcs101ApiService.getBCS101DataX5Standard(request);
|
System.out.println("BCS101 API X5Standard Response: " + x5StandardResponse);
|
} catch (Exception e) {
|
System.out.println("BCS101 API X5标准版本调用异常: " + e.getMessage());
|
e.printStackTrace();
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（X5协议变体版本） ===");
|
try {
|
// 调用X5协议变体版本
|
String x5VariantResponse = bcs101ApiService.getBCS101DataX5Variant(request);
|
System.out.println("BCS101 API X5Variant Response: " + x5VariantResponse);
|
} catch (Exception e) {
|
System.out.println("BCS101 API X5变体版本调用异常: " + e.getMessage());
|
e.printStackTrace();
|
}
|
}
|
|
@Test
|
void test1() throws UnsupportedEncodingException, JsonProcessingException {
|
// 创建测试请求对象
|
BCS101Request request = new BCS101Request();
|
request.setSupplierId("177301");
|
request.setDocNo("9311036039");
|
request.setDocType("ASNGR");
|
request.setPageNo(1);
|
request.setPageSize(1000);
|
|
|
ObjectMapper objectMapper = new ObjectMapper();
|
|
System.out.println("=== BCS101 API 实际请求参数详情 ===\n");
|
|
//时间
|
String yyyyMMddHHmmss = DateUtil.format(new Date(), "yyyyMMddHHmmss");
|
System.out.println(yyyyMMddHHmmss);
|
|
// 1. 原始JSON数据
|
String jsonData = objectMapper.writeValueAsString(request);
|
System.out.println("1. 原始JSON数据:");
|
System.out.println(jsonData);
|
System.out.println();
|
|
// 2. Base64编码
|
String base64Data = Base64.getEncoder().encodeToString(jsonData.getBytes("UTF-8"));
|
System.out.println("2. Base64编码后:");
|
System.out.println(base64Data);
|
System.out.println();
|
|
// 3. URL编码
|
String urlEncodedData = URLEncoder.encode(base64Data, "UTF-8");
|
System.out.println("3. URL编码后:");
|
System.out.println(urlEncodedData);
|
System.out.println();
|
|
// 4. Form数据
|
String formData = "data=" + urlEncodedData;
|
System.out.println("4. Form数据 (请求Body):");
|
System.out.println(formData);
|
System.out.println();
|
|
// 5. 请求URL
|
System.out.println("5. 请求URL:");
|
System.out.println(DataAcquisitionConfiguration.BCS_101_URL);
|
System.out.println();
|
|
// 6. Basic Auth
|
String credentials = DataAcquisitionConfiguration.BCS_USER_NAME + ":" + DataAcquisitionConfiguration.BCS_PWD;
|
String auth = Base64.getEncoder().encodeToString(credentials.getBytes("UTF-8"));
|
System.out.println("6. Basic Auth信息:");
|
System.out.println("用户名: " + DataAcquisitionConfiguration.BCS_USER_NAME);
|
System.out.println("密码: " + DataAcquisitionConfiguration.BCS_PWD);
|
System.out.println("Base64编码: " + auth);
|
System.out.println();
|
|
// 7. X5协议参数
|
String appId = DataAcquisitionConfiguration.BCS_APP_ID;
|
String appKey = DataAcquisitionConfiguration.BCS_APP_Key;
|
long timestamp = System.currentTimeMillis() / 1000;
|
|
System.out.println("7. X5协议参数:");
|
System.out.println("App ID: " + appId);
|
System.out.println("App Key: " + appKey);
|
System.out.println("Timestamp: " + timestamp);
|
System.out.println();
|
|
// 8. X5签名计算
|
String signString = appId + appKey + timestamp + formData;
|
String signature;
|
try {
|
signature = SmUtil.sm3(signString).toUpperCase();
|
System.out.println("8. X5签名 (使用SM3):");
|
} catch (Exception e) {
|
signature = DigestUtil.md5Hex(signString).toUpperCase();
|
System.out.println("8. X5签名 (使用MD5):");
|
}
|
System.out.println("签名字符串: " + signString);
|
System.out.println("签名值: " + signature);
|
System.out.println();
|
|
// 9. 完整的HTTP请求头
|
System.out.println("9. 完整的HTTP请求头:");
|
System.out.println("Content-Type: application/x-www-form-urlencoded");
|
System.out.println("Authorization: Basic " + auth);
|
System.out.println("X-App-Id: " + appId);
|
System.out.println("X-Timestamp: " + timestamp);
|
System.out.println("X-Signature: " + signature);
|
System.out.println();
|
|
// 10. 完整的cURL命令示例
|
System.out.println("10. 完整的cURL命令示例:");
|
System.out.println("curl -X POST \\");
|
System.out.println(" '" + DataAcquisitionConfiguration.BCS_101_URL + "' \\");
|
System.out.println(" -H 'Content-Type: application/x-www-form-urlencoded' \\");
|
System.out.println(" -H 'Authorization: Basic " + auth + "' \\");
|
System.out.println(" -H 'X-App-Id: " + appId + "' \\");
|
System.out.println(" -H 'X-Timestamp: " + timestamp + "' \\");
|
System.out.println(" -H 'X-Signature: " + signature + "' \\");
|
System.out.println(" -d '" + formData + "'");
|
System.out.println();
|
|
// 11. Postman格式
|
System.out.println("11. Postman测试格式:");
|
System.out.println("Method: POST");
|
System.out.println("URL: " + DataAcquisitionConfiguration.BCS_101_URL);
|
System.out.println("Headers:");
|
System.out.println(" Content-Type: application/x-www-form-urlencoded");
|
System.out.println(" Authorization: Basic " + auth);
|
System.out.println(" X-App-Id: " + appId);
|
System.out.println(" X-Timestamp: " + timestamp);
|
System.out.println(" X-Signature: " + signature);
|
System.out.println("Body (x-www-form-urlencoded):");
|
System.out.println(" data: " + urlEncodedData);
|
System.out.println();
|
|
// 12. 实际调用API并获取响应
|
System.out.println("12. === 实际API调用和响应 ===");
|
StringBuilder responseResult = new StringBuilder();
|
|
System.out.println("\n=== 测试BCS101 API服务（Basic Auth版本） ===");
|
try {
|
String response = bcs101ApiService.getBCS101Data(request);
|
System.out.println("BCS101 API Response: " + response);
|
responseResult.append("Basic Auth响应: ").append(response.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API调用异常: " + e.getMessage());
|
responseResult.append("Basic Auth异常: ").append(e.getMessage()).append("; ");
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（带X5协议版本） ===");
|
try {
|
String responseWithX5 = bcs101ApiService.getBCS101DataWithX5(request, true);
|
System.out.println("BCS101 API Response (X5): " + responseWithX5);
|
responseResult.append("X5协议响应: ").append(responseWithX5.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API X5调用异常: " + e.getMessage());
|
responseResult.append("X5协议异常: ").append(e.getMessage()).append("; ");
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（调试版本） ===");
|
try {
|
String debugResponse = bcs101ApiService.getBCS101DataDebug(request);
|
System.out.println("BCS101 API Debug Response: " + debugResponse);
|
responseResult.append("调试版本响应: ").append(debugResponse.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API 调试版本调用异常: " + e.getMessage());
|
responseResult.append("调试版本异常: ").append(e.getMessage()).append("; ");
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（简化版本） ===");
|
try {
|
String simpleResponse = bcs101ApiService.getBCS101DataSimple(request);
|
System.out.println("BCS101 API Simple Response: " + simpleResponse);
|
responseResult.append("简化版本响应: ").append(simpleResponse.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API 简化版本调用异常: " + e.getMessage());
|
responseResult.append("简化版本异常: ").append(e.getMessage()).append("; ");
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（X5协议标准版本） ===");
|
try {
|
String x5StandardResponse = bcs101ApiService.getBCS101DataX5Standard(request);
|
System.out.println("BCS101 API X5Standard Response: " + x5StandardResponse);
|
responseResult.append("X5标准版本响应: ").append(x5StandardResponse.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API X5标准版本调用异常: " + e.getMessage());
|
responseResult.append("X5标准版本异常: ").append(e.getMessage()).append("; ");
|
}
|
|
System.out.println("\n=== 测试BCS101 API服务（X5协议变体版本） ===");
|
try {
|
String x5VariantResponse = bcs101ApiService.getBCS101DataX5Variant(request);
|
System.out.println("BCS101 API X5Variant Response: " + x5VariantResponse);
|
responseResult.append("X5变体版本响应: ").append(x5VariantResponse.length()).append("字符; ");
|
} catch (Exception e) {
|
System.out.println("BCS101 API X5变体版本调用异常: " + e.getMessage());
|
responseResult.append("X5变体版本异常: ").append(e.getMessage()).append("; ");
|
}
|
|
// 返回汇总信息
|
String summary = String.format("请求参数[供应商ID: %s, 单据号: %s, 签名: %s, 时间戳: %d] | 响应汇总[%s]",
|
request.getSupplierId(), request.getDocNo(), signature, timestamp, responseResult.toString());
|
System.out.println("\n=== 测试汇总 ===");
|
System.out.println(summary);
|
}
|
}
|
