提交 6a9744b8 authored 作者: hzh's avatar hzh

代码优化

上级 176c8aff
package org.dromara.resource.controller.airport; package org.dromara.resource.controller.airport;
import com.alibaba.fastjson.JSON;
import io.seata.spring.annotation.GlobalTransactional; import io.seata.spring.annotation.GlobalTransactional;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.dromara.common.core.domain.R; import org.dromara.common.core.domain.R;
import org.dromara.common.redis.utils.RedisUtils;
import org.dromara.common.ys.common.PageInfo; import org.dromara.common.ys.common.PageInfo;
import org.dromara.common.ys.constant.Cplx; import org.dromara.common.ys.constant.Cplx;
import org.dromara.common.ys.constant.TripType; import org.dromara.common.ys.constant.TripType;
...@@ -21,10 +24,12 @@ import org.dromara.resource.base.BaseController; ...@@ -21,10 +24,12 @@ import org.dromara.resource.base.BaseController;
import org.springframework.validation.annotation.Validated; import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import java.time.Duration;
import java.util.List; import java.util.List;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* 国内机票
* @author hzh * @author hzh
* @date 2024-10-28 * @date 2024-10-28
**/ **/
...@@ -55,12 +60,12 @@ public class AirportController extends BaseController { ...@@ -55,12 +60,12 @@ public class AirportController extends BaseController {
} }
private List<AirportModel> getAirPortList() { private List<AirportModel> getAirPortList() {
// List<AirportModel> airPortList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheList(AIRPORT)), AirportModel.class); List<AirportModel> airPortList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheObject(AIRPORT)), AirportModel.class);
// if (CollectionUtils.isEmpty(airPortList)) { if (CollectionUtils.isEmpty(airPortList)) {
// airPortList = CommonResourceService.getAirportList(getUserId()); airPortList = CommonResourceService.getAirportList(getUserId());
// RedisUtils.setCacheObject(AIRPORT, airPortList, Duration.ofMinutes(60 * 60 * 24L)); RedisUtils.setCacheObject(AIRPORT, airPortList, Duration.ofMinutes(60 * 60 * 24L));
// } }
return CommonResourceService.getAirportList(getUserId()); return airPortList;
} }
/** /**
......
package org.dromara.resource.controller.train; package org.dromara.resource.controller.train;
import com.alibaba.fastjson.JSON;
import io.seata.spring.annotation.GlobalTransactional; import io.seata.spring.annotation.GlobalTransactional;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.dromara.common.core.domain.R; import org.dromara.common.core.domain.R;
import org.dromara.common.redis.utils.RedisUtils;
import org.dromara.common.ys.constant.TripType; import org.dromara.common.ys.constant.TripType;
import org.dromara.common.ys.model.req.train.QueryModel; import org.dromara.common.ys.model.req.train.QueryModel;
import org.dromara.common.ys.model.res.comomResource.CityModel; import org.dromara.common.ys.model.res.comomResource.CityModel;
...@@ -17,6 +20,7 @@ import org.springframework.web.bind.annotation.RequestMapping; ...@@ -17,6 +20,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.time.Duration;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.List; import java.util.List;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
...@@ -26,6 +30,8 @@ import java.util.concurrent.Future; ...@@ -26,6 +30,8 @@ import java.util.concurrent.Future;
import java.util.stream.Collectors; import java.util.stream.Collectors;
/** /**
* 火车票相关
*
* @author hzh * @author hzh
* @date 2024-10-29 * @date 2024-10-29
**/ **/
...@@ -38,6 +44,9 @@ public class TrainController extends BaseController { ...@@ -38,6 +44,9 @@ public class TrainController extends BaseController {
private static final String TRAIN = "train:ys" ; private static final String TRAIN = "train:ys" ;
private static final String CITY = "city:ys" ; private static final String CITY = "city:ys" ;
/**
* 火车站列表
*/
@GlobalTransactional(timeoutMills = 600000) @GlobalTransactional(timeoutMills = 600000)
@GetMapping("/stationList") @GetMapping("/stationList")
public R<List<AllStationModel>> stationList(@RequestParam("keyword") String keyword) { public R<List<AllStationModel>> stationList(@RequestParam("keyword") String keyword) {
...@@ -62,12 +71,12 @@ public class TrainController extends BaseController { ...@@ -62,12 +71,12 @@ public class TrainController extends BaseController {
} }
private List<AllStationModel> getStationList() { private List<AllStationModel> getStationList() {
// List<AllStationModel> stationList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheList(TRAIN)), AllStationModel.class); List<AllStationModel> stationList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheObject(TRAIN)), AllStationModel.class);
// if (CollectionUtils.isEmpty(stationList)) { if (CollectionUtils.isEmpty(stationList)) {
// stationList = TrainService.getAllStation(getUserId()); stationList = TrainService.getAllStation(getUserId());
// RedisUtils.setCacheObject(TRAIN, stationList, Duration.ofMinutes(60 * 60 * 24L)); RedisUtils.setCacheObject(TRAIN, stationList, Duration.ofMinutes(60 * 60 * 24L));
// } }
return TrainService.getAllStation(getUserId()); return stationList;
} }
/** /**
...@@ -75,6 +84,9 @@ public class TrainController extends BaseController { ...@@ -75,6 +84,9 @@ public class TrainController extends BaseController {
*/ */
private static final int NUM_THREADS = 100; private static final int NUM_THREADS = 100;
/**
* 火车票查询列表
*/
@GlobalTransactional(timeoutMills = 600000) @GlobalTransactional(timeoutMills = 600000)
@GetMapping("/list") @GetMapping("/list")
public R<List<org.dromara.common.ys.model.res.train.QueryModel>> list( public R<List<org.dromara.common.ys.model.res.train.QueryModel>> list(
...@@ -136,6 +148,9 @@ public class TrainController extends BaseController { ...@@ -136,6 +148,9 @@ public class TrainController extends BaseController {
} }
/**
* 城市列表
*/
@GlobalTransactional(timeoutMills = 600000) @GlobalTransactional(timeoutMills = 600000)
@GetMapping("/cityList") @GetMapping("/cityList")
public R<List<CityModel>> list(@RequestParam("keyword") String keyword) { public R<List<CityModel>> list(@RequestParam("keyword") String keyword) {
...@@ -144,12 +159,12 @@ public class TrainController extends BaseController { ...@@ -144,12 +159,12 @@ public class TrainController extends BaseController {
} }
private List<CityModel> getCityList() { private List<CityModel> getCityList() {
// List<CityModel> cityList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheList(CITY)), CityModel.class); List<CityModel> cityList = JSON.parseArray(JSON.toJSONString(RedisUtils.getCacheObject(CITY)), CityModel.class);
// if (CollectionUtils.isEmpty(cityList)) { if (CollectionUtils.isEmpty(cityList)) {
// cityList = CommonResourceService.getCityList(getUserId()); cityList = CommonResourceService.getCityList(getUserId());
// RedisUtils.setCacheObject(CITY, cityList, Duration.ofMinutes(60 * 60 * 24L)); RedisUtils.setCacheObject(CITY, cityList, Duration.ofMinutes(60 * 60 * 24L));
// } }
return CommonResourceService.getCityList(getUserId()); return cityList;
} }
} }
...@@ -13,6 +13,7 @@ import org.springframework.web.bind.annotation.RequestMapping; ...@@ -13,6 +13,7 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
/** /**
* 用车相关
* @author hzh * @author hzh
* @date 2024-10-29 * @date 2024-10-29
**/ **/
...@@ -21,6 +22,9 @@ import org.springframework.web.bind.annotation.RestController; ...@@ -21,6 +22,9 @@ import org.springframework.web.bind.annotation.RestController;
@RequestMapping("/vehicle/ys") @RequestMapping("/vehicle/ys")
public class VehiclesController extends BaseController { public class VehiclesController extends BaseController {
/**
* 即时用车查询
*/
@GlobalTransactional(timeoutMills = 600000) @GlobalTransactional(timeoutMills = 600000)
@RequestMapping("/immediate") @RequestMapping("/immediate")
public R<org.dromara.common.ys.model.res.vehicles.EstimateJsycPriceModel> immediate(EstimateJsycPriceModel model) { public R<org.dromara.common.ys.model.res.vehicles.EstimateJsycPriceModel> immediate(EstimateJsycPriceModel model) {
...@@ -28,6 +32,9 @@ public class VehiclesController extends BaseController { ...@@ -28,6 +32,9 @@ public class VehiclesController extends BaseController {
return R.ok(VehiclesService.estimateJsycPrice(getUserId(), model)); return R.ok(VehiclesService.estimateJsycPrice(getUserId(), model));
} }
/**
* 预约用车查询
*/
@GlobalTransactional(timeoutMills = 600000) @GlobalTransactional(timeoutMills = 600000)
@RequestMapping("/prebook") @RequestMapping("/prebook")
public R<org.dromara.common.ys.model.res.vehicles.EstimateYyycPriceModel> prebook(EstimateYyycPriceModel model) { public R<org.dromara.common.ys.model.res.vehicles.EstimateYyycPriceModel> prebook(EstimateYyycPriceModel model) {
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论