package jiekou;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import java.io.*;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
|
/**
|
* 取卡成功通知工具类
|
* 使用Slf4j日志输出，仅支持同步处理
|
*/
|
public class TakeCardSuccessUtil {
|
|
private static final Logger logger = LoggerFactory.getLogger(TakeCardSuccessUtil.class);
|
|
// 连接超时和读取超时时间
|
private static final int CONNECT_TIMEOUT = 5000;
|
private static final int READ_TIMEOUT = 10000;
|
|
/**
|
* 调用取卡成功通知接口
|
*
|
* @param apiUrl 接口的URL地址
|
* @param doorNo 门号(十六进制)
|
* @param deviceId 设备ID
|
* @param cardId 卡号(15字节工作卡卡号)
|
* @param faceId 人脸ID
|
* @param userId 用户ID
|
* @param apiKey API密钥
|
* @return 响应结果JSON字符串
|
*/
|
@SuppressWarnings("deprecation")
|
public static String callTakeSuccess(
|
String apiUrl,
|
String apiKey,
|
String doorNo,
|
String deviceId,
|
String cardId,
|
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(doorNo, deviceId, cardId, faceId, userId);
|
logger.info("取卡成功通知接口请求URL: {}", apiUrl);
|
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 doorNo 门号
|
* @param deviceId 设备ID
|
* @param cardId 卡号
|
* @param faceId 人脸ID
|
* @param userId 用户ID
|
* @return JSON格式的请求体
|
*/
|
private static String buildRequestBody(String doorNo, String deviceId, String cardId, String faceId, String userId) {
|
return "{\"doorNo\":\"" + doorNo +
|
"\",\"deviceId\":\"" + deviceId +
|
"\",\"cardId\":\"" + cardId +
|
"\",\"faceId\":\"" + faceId +
|
"\",\"userId\":\"" + userId + "\"}";
|
}
|
|
/**
|
* 构建错误响应
|
*
|
* @param errorMsg 错误信息
|
* @return JSON格式的错误响应
|
*/
|
private static String buildErrorResponse(String errorMsg) {
|
return "{\"status\":\"0\",\"error\":\"" + errorMsg + "\"}";
|
}
|
|
/**
|
* 判断响应是否成功
|
*
|
* @param responseJson 响应JSON字符串
|
* @return true=成功, false=失败
|
*/
|
public static boolean isTakeSuccess(String responseJson) {
|
try {
|
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;
|
}
|
}
|
