package com.example.api.V105;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;

import static org.junit.jupiter.api.Assertions.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.io.*;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.*;
import java.util.stream.Collectors;
import java.util.Base64;

public class ApiTest1026 {

    // 签名相关的常量
    private static final String SIGN_KEY = "XXXXXX"; // 替换为实际的签名密钥
    private static final String USER_ID = "XXXXXXX"; // 替换为实际的用户编号

    public static void main(String[] args) throws Exception {
        String apiUrl = "https://api.slsj.com/api/mobile/port-check/query";
        String orderId = "1026001";
        String mobile = "+2347016801869";
   
        // 准备请求参数
        Map<String, Object> params = new HashMap<>();
        params.put("orderId", orderId);
        params.put("mobile", mobile);

        testVerification(apiUrl, params);
    }

    // 获取Auth_Token的方法
    private static String getAuthToken() throws Exception {
        // 获取当前时间戳
        long timestamp = System.currentTimeMillis();

        // 按照文档拼接待加密字符串
        String toEncrypt = "memberId=" + USER_ID + "dateTime=" + timestamp + "version=v1" + "key=" + SIGN_KEY;

        // MD5加密
        MessageDigest md = MessageDigest.getInstance("MD5");
        byte[] digest = md.digest(toEncrypt.getBytes(StandardCharsets.UTF_8));
        String md5Result = bytesToHex(digest).toLowerCase();

        // 创建鉴权Token的JSON对象
        JSONObject authTokenObj = new JSONObject();
        authTokenObj.set("memberId", USER_ID);
        authTokenObj.set("dateTime", timestamp);
        authTokenObj.set("version", "v1");
        authTokenObj.set("signMd5", md5Result);
        
        String authToken = authTokenObj.toString();
        return authToken;
    }

    // 辅助方法：将字节数组转换为十六进制字符串
    private static String bytesToHex(byte[] bytes) {
        StringBuilder result = new StringBuilder();
        for (byte b : bytes) {
            result.append(String.format("%02x", b));
        }
        return result.toString();
    }

    public static void testVerification(String apiUrl,Map<String, Object> params) throws Exception {        
        // 获取鉴权Token
        String authToken = getAuthToken();
        
        // 发送请求
        HttpResponse response = HttpRequest.post(apiUrl)
            .header("Content-Type", "application/x-www-form-urlencoded")
            .header("Auth_Token", authToken)
            .header("Sign_Type", "md5")
            .form(params)
            .execute();
        
        // 输出响应结果
        int status = response.getStatus();
        String responseBody = response.body();
        
        System.out.println("响应状态码: " + status);
        System.out.println("响应内容: " + responseBody);
        
        // 验证响应码
        assertEquals(HttpURLConnection.HTTP_OK, status, "Response code should be 200");
        
        // 解析响应内容（假设响应是JSON格式）
        // JSONObject responseJson = JSONUtil.parseObj(responseBody);
    }
} 

import hashlib
import json
import time
import requests

# 用户ID和密钥
user_id = "xxxxxx"  # 替换为实际的用户编号
signature_key = "xxxxxxxxxxxxxxx"   # 替换为实际的签名密钥

# 版本号
version = "v1"


# 生成加密签名
def generate_auth_token():
    query_time = int(time.time() * 1000)
    original_string = f'memberId={user_id}dateTime={query_time}version={version}key={signature_key}'
    md5_result = hashlib.md5(original_string.encode('utf-8')).hexdigest()
    auth_token = {
        "memberId": user_id,
        "dateTime": query_time,
        "version": version,
        "signMd5": md5_result

    }
    return auth_token


# 请求接口并打印响应结果
request_url = 'https://api.slsj.com/api/mobile/port-check/query'
params = {
    "orderId": "20250416094659001",
    "mobile": "+2347016801869"
}

headers = {'Content-Type': 'application/x-www-form-urlencoded', 'Auth_Token': json.dumps(generate_auth_token()),
           'Sign_Type': 'md5'}
response = requests.post(headers=headers, url=request_url, data=params)
if response.status_code == 200:
    print(response.json())
else:
    print(response.text)