package com.ruoyi.cwgl.service.impl;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.ruoyi.cwgl.domain.ApiResponse;
|
import com.ruoyi.cwgl.domain.VehicleDailyData;
|
import com.ruoyi.common.utils.SignUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Component;
|
|
import java.util.*;
|
|
/**
|
* 车辆数据API客户端服务
|
* 用于调用外部车辆数据API获取车辆每日数据
|
*
|
* @author ruoyi
|
*/
|
@Component
|
public class VehicleDataApiClient {
|
|
private static final Logger logger = LoggerFactory.getLogger(VehicleDataApiClient.class);
|
|
@Value("${custom.vehicle-api.baseUrl}")
|
private String baseUrl;
|
|
@Value("${custom.vehicle-api.appid}")
|
private String appid;
|
|
@Value("${custom.vehicle-api.secret}")
|
private String secret;
|
|
@Value("${custom.vehicle-api.timeout:30000}")
|
private int timeout;
|
|
/**
|
* 查询某日车辆数据
|
*
|
* @param date 查询日期，格式为yyyy-MM-dd
|
* @return API响应结果
|
*/
|
public ApiResponse<List<VehicleDailyData>> getDailyVehicleData(String date) {
|
logger.info("开始查询日期[{}]的车辆数据", date);
|
|
// 准备参数
|
String nonce = SignUtil.generate16CharRandomString();
|
String timestamp = String.valueOf(System.currentTimeMillis());
|
|
Map<String, Object> params = new HashMap<>();
|
params.put("date", date);
|
|
// 生成签名
|
String signature = SignUtil.signParamsSha256(params, appid, nonce, timestamp, secret);
|
logger.debug("生成签名参数: appid={}, nonce={}, timestamp={}", appid, nonce, timestamp);
|
|
// 构建请求URL
|
String url = baseUrl + "/open/api/v1/dailyData?date=" + date;
|
|
try {
|
// 使用Hutool发送GET请求
|
HttpResponse response = HttpRequest.get(url)
|
.header("appid", appid)
|
.header("nonce", nonce)
|
.header("timestamp", timestamp)
|
.header("signature", signature)
|
.header("Content-Type", "application/json")
|
.header("Accept", "application/json")
|
.timeout(timeout)
|
.execute();
|
|
logger.debug("请求URL: {}", url);
|
logger.debug("响应状态码: {}", response.getStatus());
|
|
if (response.isOk()) {
|
String body = response.body();
|
logger.info("响应内容: {}", body);
|
|
// 解析JSON响应
|
return parseResponse(body);
|
} else {
|
String errorBody = response.body();
|
logger.error("HTTP请求失败，状态码: {}, 错误响应: {}", response.getStatus(), errorBody);
|
return createErrorResponse("HTTP请求失败: " + response.getStatus() + ", " + errorBody);
|
}
|
|
} catch (Exception e) {
|
logger.error("API调用异常: {}", e.getMessage(), e);
|
return createErrorResponse("API调用异常: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 解析响应内容
|
*
|
* @param body 响应体JSON字符串
|
* @return 解析后的API响应对象
|
*/
|
private ApiResponse<List<VehicleDailyData>> parseResponse(String body) {
|
try {
|
// 使用Hutool的JSONUtil解析响应
|
JSONObject jsonObject = JSONUtil.parseObj(body);
|
|
ApiResponse<List<VehicleDailyData>> response = new ApiResponse<>();
|
response.setCode(jsonObject.getInt("code"));
|
response.setMsg(jsonObject.getStr("msg"));
|
|
// 解析data数组
|
if (jsonObject.containsKey("data") && jsonObject.get("data") != null) {
|
String dataJson = JSONUtil.toJsonStr(jsonObject.get("data"));
|
List<VehicleDailyData> dataList = JSONUtil.toList(dataJson, VehicleDailyData.class);
|
response.setData(dataList);
|
logger.debug("成功解析到{}条车辆数据", dataList.size());
|
} else {
|
response.setData(new ArrayList<>());
|
logger.debug("响应中无数据");
|
}
|
|
return response;
|
|
} catch (Exception e) {
|
logger.error("JSON解析异常: {}", e.getMessage(), e);
|
logger.debug("响应内容: {}", body);
|
return createErrorResponse("JSON解析异常: " + e.getMessage());
|
}
|
}
|
|
/**
|
* 创建错误响应
|
*
|
* @param message 错误消息
|
* @return 错误响应对象
|
*/
|
private ApiResponse<List<VehicleDailyData>> createErrorResponse(String message) {
|
ApiResponse<List<VehicleDailyData>> response = new ApiResponse<>();
|
response.setCode(500);
|
response.setMsg(message);
|
response.setData(new ArrayList<>());
|
return response;
|
}
|
}
|
