| | |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") |
| | | }) |
| | | public ResultUtil<String> getFleetEngineAuth(HttpServletRequest request){ |
| | | public ResultUtil<Map<String, Object>> getFleetEngineAuth(HttpServletRequest request){ |
| | | try { |
| | | Integer uid = driverService.getUserIdFormRedis(request); |
| | | if(null == uid){ |
| | | return ResultUtil.tokenErr(); |
| | | } |
| | | String s = fleetEngineUtil.fleetEngineAuth(2, uid); |
| | | Map<String, Object> s = fleetEngineUtil.fleetEngineAuth(2, uid); |
| | | return ResultUtil.success(s); |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | |
| | | (select `name` from t_company where 1 = 1 and if(a.companyId is null or a.companyId = 0, id = 1, if(a.franchiseeId is null or a.franchiseeId = 0, id = a.companyId, id = a.franchiseeId))) as company, |
| | | b.carLicensePlate as licensePlate, |
| | | b.carColor as carColor, |
| | | b.vehicleId, |
| | | CONCAT(d.`name`, c.`name`) as brand, |
| | | ( |
| | | (select count(id) from t_order_private_car where driverId = a.id and state in (7, 8, 9)) + |
| | |
| | | CarModel carModel = carModelMapper.selectById(car.getCarModelId()); |
| | | fleetEngineUtil.createVehicles(carModel.getSeat() - 1, car.getCarLicensePlate(), car.getVehicleId()); |
| | | } |
| | | loginWarpper.setVehicleId(car.getVehicleId()); |
| | | return ResultUtil.success(loginWarpper); |
| | | } |
| | | |
| | |
| | | * @param type 0=服务端,1=乘客,2=司机 |
| | | * @return |
| | | */ |
| | | public String fleetEngineAuth(int type, Integer id){ |
| | | public Map<String, Object> fleetEngineAuth(int type, Integer id){ |
| | | try { |
| | | //谷歌云服务器使用这部分代码 |
| | | // AuthTokenMinter minter = AuthTokenMinter.builder() |
| | |
| | | .build(); |
| | | |
| | | String jwt = ""; |
| | | Long expirationTimestamp = 0L; |
| | | if(0 == type){ |
| | | FleetEngineToken serverToken = minter.getServerToken(); |
| | | jwt = serverToken.jwt(); |
| | | expirationTimestamp = serverToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(1 == type){ |
| | | FleetEngineToken consumerToken = minter.getConsumerToken(TripClaims.create("I-GO-USER" + id)); |
| | | jwt = consumerToken.jwt(); |
| | | expirationTimestamp = consumerToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(2 == type){ |
| | | FleetEngineToken driverToken = minter.getDriverToken(VehicleClaims.create("I-GO-CAR" + id)); |
| | | jwt = driverToken.jwt(); |
| | | expirationTimestamp = driverToken.expirationTimestamp().getTime(); |
| | | } |
| | | return jwt; |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("token", jwt); |
| | | map.put("expirationTimestamp", expirationTimestamp); |
| | | return map; |
| | | } catch (SigningTokenException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | public String getToken(){ |
| | | String token_json = redisUtil.getValue("google_token"); |
| | | String google_token = ""; |
| | | if(!StringUtils.hasLength(token_json)){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | }else{ |
| | | JSONObject jsonObject1 = JSON.parseObject(token_json); |
| | | Long expirationTimestamp = jsonObject1.getLong("expirationTimestamp"); |
| | | google_token = jsonObject1.getString("token"); |
| | | if((expirationTimestamp - 10000L) <= System.currentTimeMillis()){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | } |
| | | } |
| | | return google_token; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | |
| | | * @param id 车辆id |
| | | */ |
| | | public String createVehicles(int maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles?vehicleId=" + id; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateVehicles(String vehicleState, Integer maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + id + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleState)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getVehicles(String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + (null != id ? id : ""); |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String createTrip(String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips?tripId=" + tripId; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateTrip(String tripStatus, String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleId)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getTrip(String tripId) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId; |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | private String birthday; |
| | | @ApiModelProperty("居住地") |
| | | private String driverAddress; |
| | | @ApiModelProperty("google车辆id") |
| | | private String vehicleId; |
| | | |
| | | public Integer getId() { |
| | | return id; |
| | |
| | | driverInfoWarpper.setLanguage(null != map.get("language") ? Integer.valueOf(String.valueOf(map.get("language"))) : 2); |
| | | driverInfoWarpper.setBirthday(null != map.get("birthday") ? String.valueOf(map.get("birthday")) : ""); |
| | | driverInfoWarpper.setDriverAddress(null != map.get("driverAddress") ? String.valueOf(map.get("driverAddress")) : ""); |
| | | driverInfoWarpper.setVehicleId(null != map.get("vehicleId") ? String.valueOf(map.get("vehicleId")) : ""); |
| | | } |
| | | return driverInfoWarpper; |
| | | } |
| | | |
| | | |
| | | public String getVehicleId() { |
| | | return vehicleId; |
| | | } |
| | | |
| | | public void setVehicleId(String vehicleId) { |
| | | this.vehicleId = vehicleId; |
| | | } |
| | | } |
| | |
| | | @ApiModelProperty("跳转页面 100000=跳转至【完善个人资料】 200000=跳转至【完善车辆信息】") |
| | | private String jumpCode; |
| | | |
| | | @ApiModelProperty("google车辆id") |
| | | private String vehicleId; |
| | | |
| | | |
| | | public String getJumpCode() { |
| | | return jumpCode; |
| | |
| | | public void setTerminalId(String terminalId) { |
| | | this.terminalId = terminalId; |
| | | } |
| | | |
| | | public String getVehicleId() { |
| | | return vehicleId; |
| | | } |
| | | |
| | | public void setVehicleId(String vehicleId) { |
| | | this.vehicleId = vehicleId; |
| | | } |
| | | } |
| | |
| | | * @param type 0=服务端,1=乘客,2=司机 |
| | | * @return |
| | | */ |
| | | public String fleetEngineAuth(int type, Integer id){ |
| | | public Map<String, Object> fleetEngineAuth(int type, Integer id){ |
| | | try { |
| | | //谷歌云服务器使用这部分代码 |
| | | // AuthTokenMinter minter = AuthTokenMinter.builder() |
| | |
| | | .build(); |
| | | |
| | | String jwt = ""; |
| | | Long expirationTimestamp = 0L; |
| | | if(0 == type){ |
| | | FleetEngineToken serverToken = minter.getServerToken(); |
| | | jwt = serverToken.jwt(); |
| | | expirationTimestamp = serverToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(1 == type){ |
| | | FleetEngineToken consumerToken = minter.getConsumerToken(TripClaims.create("I-GO-USER" + id)); |
| | | jwt = consumerToken.jwt(); |
| | | expirationTimestamp = consumerToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(2 == type){ |
| | | FleetEngineToken driverToken = minter.getDriverToken(VehicleClaims.create("I-GO-CAR" + id)); |
| | | jwt = driverToken.jwt(); |
| | | expirationTimestamp = driverToken.expirationTimestamp().getTime(); |
| | | } |
| | | return jwt; |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("token", jwt); |
| | | map.put("expirationTimestamp", expirationTimestamp); |
| | | return map; |
| | | } catch (SigningTokenException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | public String getToken(){ |
| | | String token_json = redisUtil.getValue("google_token"); |
| | | String google_token = ""; |
| | | if(!StringUtils.hasLength(token_json)){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | }else{ |
| | | JSONObject jsonObject1 = JSON.parseObject(token_json); |
| | | Long expirationTimestamp = jsonObject1.getLong("expirationTimestamp"); |
| | | google_token = jsonObject1.getString("token"); |
| | | if((expirationTimestamp - 10000L) <= System.currentTimeMillis()){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | } |
| | | } |
| | | return google_token; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | |
| | | * @param id 车辆id |
| | | */ |
| | | public String createVehicles(int maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles?vehicleId=" + id; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateVehicles(String vehicleState, Integer maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + id + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleState)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getVehicles(String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles" + (null != id ? "/" + id : ""); |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + (null != id ? id : ""); |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String createTrip(String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips?tripId=" + tripId; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateTrip(String tripStatus, String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleId)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getTrip(String tripId) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId; |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | @ApiImplicitParams({ |
| | | @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9.....") |
| | | }) |
| | | public ResultUtil<String> getFleetEngineAuth(HttpServletRequest request){ |
| | | public ResultUtil<Map<String, Object>> getFleetEngineAuth(HttpServletRequest request){ |
| | | try { |
| | | Integer uid = userInfoService.getUserIdFormRedis(request); |
| | | if(null == uid){ |
| | | return ResultUtil.tokenErr(); |
| | | } |
| | | String s = fleetEngineUtil.fleetEngineAuth(1, uid); |
| | | Map<String, Object> s = fleetEngineUtil.fleetEngineAuth(1, uid); |
| | | return ResultUtil.success(s); |
| | | }catch (Exception e){ |
| | | e.printStackTrace(); |
| | |
| | | trackId as trackId, |
| | | isDelete as isDelete, |
| | | telX as telX, |
| | | bindId as bindId |
| | | bindId as bindId, |
| | | tripId |
| | | from t_order_logistics where isDelete = 1 |
| | | <if test="null != start and null != end"> |
| | | and insertTime between #{start} and #{end} |
| | |
| | | payMoney as payMoney, |
| | | ifnull(discountMoney, 0) as discountMoney, |
| | | (select price from t_order_logistics_spread where orderLogisticsId = a.id) as differenceMoney, |
| | | cancelMidway |
| | | cancelMidway, |
| | | tripId |
| | | from t_order_logistics as a where userId = #{uid} and isDelete = 1 order by insertTime desc limit #{pageNum}, #{size} |
| | | </select> |
| | | |
| | |
| | | isDelete as isDelete, |
| | | oldState as oldState, |
| | | telX as telX, |
| | | bindId as bindId |
| | | bindId as bindId, |
| | | tripId |
| | | from t_order_private_car where isDelete = 1 and userId = #{uid} |
| | | <if test="null != state"> |
| | | and state in |
| | |
| | | state as state, |
| | | oldState as oldState, |
| | | isFrozen, |
| | | cancelMidway |
| | | cancelMidway, |
| | | tripId |
| | | from t_order_private_car where userId = #{uid} and isDelete = 1 order by insertTime desc limit #{pageNum}, #{size} |
| | | </select> |
| | | |
| | |
| | | * @param type 0=服务端,1=乘客,2=司机 |
| | | * @return |
| | | */ |
| | | public String fleetEngineAuth(int type, Integer id){ |
| | | public Map<String, Object> fleetEngineAuth(int type, Integer id){ |
| | | try { |
| | | //谷歌云服务器使用这部分代码 |
| | | // AuthTokenMinter minter = AuthTokenMinter.builder() |
| | |
| | | .build(); |
| | | |
| | | String jwt = ""; |
| | | Long expirationTimestamp = 0L; |
| | | if(0 == type){ |
| | | FleetEngineToken serverToken = minter.getServerToken(); |
| | | jwt = serverToken.jwt(); |
| | | expirationTimestamp = serverToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(1 == type){ |
| | | FleetEngineToken consumerToken = minter.getConsumerToken(TripClaims.create("I-GO-USER" + id)); |
| | | jwt = consumerToken.jwt(); |
| | | expirationTimestamp = consumerToken.expirationTimestamp().getTime(); |
| | | } |
| | | if(2 == type){ |
| | | FleetEngineToken driverToken = minter.getDriverToken(VehicleClaims.create("I-GO-CAR" + id)); |
| | | jwt = driverToken.jwt(); |
| | | expirationTimestamp = driverToken.expirationTimestamp().getTime(); |
| | | } |
| | | return jwt; |
| | | Map<String, Object> map = new HashMap<>(); |
| | | map.put("token", jwt); |
| | | map.put("expirationTimestamp", expirationTimestamp); |
| | | return map; |
| | | } catch (SigningTokenException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | } |
| | | |
| | | |
| | | |
| | | public String getToken(){ |
| | | String token_json = redisUtil.getValue("google_token"); |
| | | String google_token = ""; |
| | | if(!StringUtils.hasLength(token_json)){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | }else{ |
| | | JSONObject jsonObject1 = JSON.parseObject(token_json); |
| | | Long expirationTimestamp = jsonObject1.getLong("expirationTimestamp"); |
| | | google_token = jsonObject1.getString("token"); |
| | | if((expirationTimestamp - 10000L) <= System.currentTimeMillis()){ |
| | | Map<String, Object> map = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", JSON.toJSONString(map)); |
| | | google_token = map.get("token").toString(); |
| | | } |
| | | } |
| | | return google_token; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | |
| | | * @param id 车辆id |
| | | */ |
| | | public String createVehicles(int maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles?vehicleId=" + id; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateVehicles(String vehicleState, Integer maximumCapacity, String licensePlate, String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + id + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleState)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getVehicles(String id) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/vehicles/" + (null != id ? id : ""); |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String createTrip(String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception{ |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips?tripId=" + tripId; |
| | | HttpRequest post = HttpUtil.createPost(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | post.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String updateTrip(String tripStatus, String vehicleId, Integer numberOfPassengers, String tripId, String start_lat, String start_lng, String end_lat, String end_lng) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId + "?updateMask="; |
| | | List<String> sb = new ArrayList<>(); |
| | | if(StringUtils.hasLength(vehicleId)){ |
| | |
| | | |
| | | HttpRequest put = HttpUtil.createRequest(Method.PUT, url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | put.addHeaders(headers); |
| | | |
| | |
| | | * @return |
| | | */ |
| | | public String getTrip(String tripId) throws Exception { |
| | | String google_token = redisUtil.getValue("google_token"); |
| | | if(!StringUtils.hasLength(google_token)){ |
| | | google_token = fleetEngineAuth(0, null); |
| | | redisUtil.setStrValue("google_token", google_token); |
| | | } |
| | | String url = "https://fleetengine.googleapis.com/v1/providers/" + provider + "/trips/" + tripId; |
| | | HttpRequest get = HttpUtil.createGet(url); |
| | | Map<String, String> headers = new HashMap<>(); |
| | | headers.put("Authorization", "Bearer " + google_token); |
| | | headers.put("Authorization", "Bearer " + getToken()); |
| | | headers.put("Content-Type", "application/json"); |
| | | get.addHeaders(headers); |
| | | |
| | |
| | | @ApiModelProperty("中途取消(0=否,1=是)") |
| | | private Integer cancelMidway; |
| | | |
| | | private String tripId; |
| | | |
| | | public Integer getOrderId() { |
| | | return orderId; |
| | | } |
| | |
| | | orderWarpper.setReceipt(null != map.get("receipt") ? String.valueOf(map.get("receipt")) : ""); |
| | | orderWarpper.setIsFrozen(null != map.get("isFrozen") ? Integer.valueOf(String.valueOf(map.get("isFrozen"))) : 1); |
| | | orderWarpper.setCancelMidway(null != map.get("cancelMidway") ? Integer.valueOf(String.valueOf(map.get("cancelMidway"))) : 0); |
| | | orderWarpper.setTripId(null != map.get("tripId") ? String.valueOf(map.get("tripId")) : ""); |
| | | list.add(orderWarpper); |
| | | } |
| | | } |
| | |
| | | this.cancelMidway = cancelMidway; |
| | | } |
| | | |
| | | public String getTripId() { |
| | | return tripId; |
| | | } |
| | | |
| | | public void setTripId(String tripId) { |
| | | this.tripId = tripId; |
| | | } |
| | | |
| | | @Override |
| | | public int compareTo(Object o) { |
| | | if (o instanceof OrderWarpper) { |