|
@@ -5,6 +5,7 @@ import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
import com.zksy.common.core.domain.Result;
|
|
import com.zksy.common.core.domain.Result;
|
|
|
import com.zksy.visualization.config.IccConfigProperty;
|
|
import com.zksy.visualization.config.IccConfigProperty;
|
|
|
import com.zksy.visualization.domain.request.ParkingListRequest;
|
|
import com.zksy.visualization.domain.request.ParkingListRequest;
|
|
|
|
|
+import com.zksy.visualization.domain.request.QueryVehicleListRequest;
|
|
|
import com.zksy.visualization.domain.response.*;
|
|
import com.zksy.visualization.domain.response.*;
|
|
|
import io.swagger.annotations.Api;
|
|
import io.swagger.annotations.Api;
|
|
|
import io.swagger.annotations.ApiOperation;
|
|
import io.swagger.annotations.ApiOperation;
|
|
@@ -249,5 +250,56 @@ public class ParkingManageController {
|
|
|
}
|
|
}
|
|
|
return Result.error("车场余位信息失败");
|
|
return Result.error("车场余位信息失败");
|
|
|
}
|
|
}
|
|
|
|
|
+ @ApiOperation(value = "车辆列表查询")
|
|
|
|
|
+ @GetMapping("/queryVehicleList")
|
|
|
|
|
+ public Result queryVehicleList(QueryVehicleListRequest queryVehicleListRequest){
|
|
|
|
|
+ String authorization = redisTemplate
|
|
|
|
|
+ .opsForValue()
|
|
|
|
|
+ .get("Authorization:" + iccConfigProperty.getUsername());
|
|
|
|
|
+ HttpUrl url = new HttpUrl.Builder()
|
|
|
|
|
+ .scheme("https")
|
|
|
|
|
+ .host(iccConfigProperty.getHost())
|
|
|
|
|
+ .addPathSegments("/evo-apigw/ipms/car/list")
|
|
|
|
|
+ .addQueryParameter("pageNum", String.valueOf(queryVehicleListRequest.getPageNum()))
|
|
|
|
|
+ .addQueryParameter("pageSize",String.valueOf(queryVehicleListRequest.getPageSize()))
|
|
|
|
|
+ .addQueryParameter("parkinglotCode",String.valueOf(queryVehicleListRequest.getParkinglotCode()))
|
|
|
|
|
+ .addQueryParameter("ownerNameLikeStr",queryVehicleListRequest.getOwnerNameLikeStr())
|
|
|
|
|
+ .addQueryParameter("carNumLikeStr", queryVehicleListRequest.getCarNumLikeStr())
|
|
|
|
|
+ .addQueryParameter("listType",String.valueOf(queryVehicleListRequest.getListType()))
|
|
|
|
|
+ .build();
|
|
|
|
|
|
|
|
|
|
+ Request request = new Request.Builder()
|
|
|
|
|
+ .url(url)
|
|
|
|
|
+ .addHeader("Authorization", authorization)
|
|
|
|
|
+ .build();
|
|
|
|
|
+ try {
|
|
|
|
|
+ Response response = httpClient.newCall(request).execute();
|
|
|
|
|
+ if(!response.isSuccessful()){
|
|
|
|
|
+ return Result.error("车辆列表查询失败");
|
|
|
|
|
+ }
|
|
|
|
|
+ ResponseBody responseBody = response.body();
|
|
|
|
|
+ if (responseBody != null) {
|
|
|
|
|
+ String responseString = responseBody.string();
|
|
|
|
|
+ ObjectMapper objectMapper = new ObjectMapper();
|
|
|
|
|
+ JsonNode rootNode = objectMapper.readTree(responseString);
|
|
|
|
|
+ JsonNode success = rootNode.path("success");
|
|
|
|
|
+ if(success.isBoolean() && success.asBoolean()) {
|
|
|
|
|
+ JsonNode dataNode = rootNode.path("data");
|
|
|
|
|
+ if (dataNode.isObject()) {
|
|
|
|
|
+ QueryVehicleListResponse queryVehicleListResponse = objectMapper.treeToValue(dataNode, QueryVehicleListResponse.class);
|
|
|
|
|
+ return Result.ok(queryVehicleListResponse);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ return Result.ok(null);
|
|
|
|
|
+ }
|
|
|
|
|
+ }else{
|
|
|
|
|
+ JsonNode errMsgNode = rootNode.path("errMsg");
|
|
|
|
|
+ String errMsg = errMsgNode.isTextual() ? errMsgNode.asText() : "未知错误";
|
|
|
|
|
+ return Result.error(errMsg);
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ log.error("车辆列表查询失败:{}", e);
|
|
|
|
|
+ }
|
|
|
|
|
+ return Result.error("车辆列表查询失败");
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|