package jiekou;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * 取卡接口工具类 - 简化版本
 * 不使用外部JSON库，不包含重试逻辑
 */
public class TakeCardUtil {

    // 配置属性
    private static final Logger logger = LoggerFactory.getLogger(TakeCardUtil.class);
    private static final int CONNECT_TIMEOUT = 5000;
    private static final int READ_TIMEOUT = 10000;

    /**
     * 调用取卡接口
     * @param deviceId 设备ID
     * @param faceId 人脸ID
     * @param userId 用户ID
     * @return 响应结果JSON字符串
     */
    protected static String callTakeCardApi(
            String apiUrl,String apiKey,
            String deviceId, String faceId, String userId) {
        HttpURLConnection connection = null;
        BufferedReader reader = null;

        try {
            // 创建URL连接
            URL url = new URL(apiUrl);
            connection = (HttpURLConnection) url.openConnection();

            // 设置连接参数
            connection.setRequestMethod("POST");
            connection.setRequestProperty("Content-Type", "application/json");
            connection.setRequestProperty("apiKey", apiKey);
            connection.setConnectTimeout(CONNECT_TIMEOUT);
            connection.setReadTimeout(READ_TIMEOUT);
            connection.setDoOutput(true);

            // 构建请求体
            String requestBody = buildRequestBody(deviceId, faceId, userId);
            logger.info("取卡接口请求参数: {}", requestBody);

            // 发送请求体
            try (OutputStream os = connection.getOutputStream()) {
                byte[] input = requestBody.getBytes("utf-8");
                os.write(input, 0, input.length);
            }

            // 获取响应码
            int responseCode = connection.getResponseCode();
            logger.info("取卡接口响应码: {}", responseCode);

            // 读取响应内容
            StringBuilder response = new StringBuilder();
            if (responseCode == HttpURLConnection.HTTP_OK) {
                reader = new BufferedReader(new InputStreamReader(connection.getInputStream(), "utf-8"));
            } else {
                reader = new BufferedReader(new InputStreamReader(connection.getErrorStream(), "utf-8"));
            }

            String line;
            while ((line = reader.readLine()) != null) {
                response.append(line);
            }

            String responseBody = response.toString();
            logger.info("取卡接口响应: {}", responseBody);

            return responseBody;

        } catch (Exception e) {
            logger.error("调用取卡接口发生异常", e);
            return buildErrorResponse("接口调用异常: " + e.getMessage());
        } finally {
            // 关闭资源
            if (reader != null) {
                try {
                    reader.close();
                } catch (Exception e) {
                    logger.error("关闭BufferedReader失败", e);
                }
            }
            if (connection != null) {
                connection.disconnect();
            }
        }
    }

    /**
     * 构建请求体JSON
     * @param deviceId 设备ID
     * @param faceId 人脸ID
     * @param userId 用户ID
     * @return JSON格式的请求体
     */
    private static String buildRequestBody(String deviceId, String faceId, String userId) {
        return "{\"deviceId\":\"" + deviceId +
                "\",\"faceId\":\"" + faceId +
                "\",\"userId\":\"" + userId + "\"}";
    }

    /**
     * 构建错误响应
     * @param errorMsg 错误信息
     * @return JSON格式的错误响应
     */
    private static String buildErrorResponse(String errorMsg) {
        return "{\"code\":\"500\",\"status\":\"2\",\"msg\":\"" + errorMsg + "\"}";
    }

    /**
     * 判断响应是否允许取卡
     * @param responseJson 响应JSON字符串
     * @return true=允许取卡, false=不允许
     */
    public static boolean isTakeCardAllowed(String responseJson) {
        try {
            // 简单解析status字段
            if (responseJson != null && responseJson.contains("\"status\"")) {
                int statusIndex = responseJson.indexOf("\"status\"");
                if (statusIndex != -1) {
                    // 查找status值
                    int colonIndex = responseJson.indexOf(":", statusIndex);
                    int commaIndex = responseJson.indexOf(",", colonIndex);
                    int endIndex = responseJson.indexOf("}", colonIndex);
                    if (commaIndex == -1 || commaIndex > endIndex) {
                        commaIndex = endIndex;
                    }

                    if (colonIndex != -1 && commaIndex != -1) {
                        String statusValue = responseJson.substring(colonIndex + 1, commaIndex).trim();
                        statusValue = statusValue.replace("\"", "").replace("'", "");
                        return "1".equals(statusValue);
                    }
                }
            }
        } catch (Exception e) {
            logger.error("解析响应状态失败", e);
        }
        return false;
    }

    /**
     * 从JSON字符串中提取指定字段的值
     * @param json JSON字符串
     * @param fieldName 字段名
     * @return 字段值，如果不存在则返回null
     */
    protected static String extractJsonField(String json, String fieldName) {
        try {
            if (json != null && json.contains("\"" + fieldName + "\"")) {
                int fieldIndex = json.indexOf("\"" + fieldName + "\"");
                if (fieldIndex != -1) {
                    // 查找字段值
                    int colonIndex = json.indexOf(":", fieldIndex);
                    int commaIndex = json.indexOf(",", colonIndex);
                    int endIndex = json.indexOf("}", colonIndex);
                    if (commaIndex == -1 || commaIndex > endIndex) {
                        commaIndex = endIndex;
                    }

                    if (colonIndex != -1 && commaIndex != -1) {
                        String fieldValue = json.substring(colonIndex + 1, commaIndex).trim();
                        // 去除引号
                        if (fieldValue.startsWith("\"") && fieldValue.endsWith("\"")) {
                            fieldValue = fieldValue.substring(1, fieldValue.length() - 1);
                        }
                        return fieldValue.isEmpty() ? null : fieldValue;
                    }
                }
            }
        } catch (Exception e) {
            logger.error("提取字段 {} 失败", fieldName, e);
        }
        return null;
    }
}