提交 1c9341c9 authored 作者: hzh's avatar hzh

云上接口改造

上级 74177ab6
...@@ -137,8 +137,8 @@ public class AirportController extends BaseController { ...@@ -137,8 +137,8 @@ public class AirportController extends BaseController {
@PostMapping("/bookOrder") @PostMapping("/bookOrder")
public R<List<org.dromara.common.ys.model.res.airport.BookOrderModel>> bookOrder(@RequestBody BookOrderModel model) { public R<List<org.dromara.common.ys.model.res.airport.BookOrderModel>> bookOrder(@RequestBody BookOrderModel model) {
model.setTripType(TripType.PUBLIC.getCode()); model.setTripType(TripType.PUBLIC.getCode());
String travelNo = model.getTravelNo(); String travelNo = model.getSubjectCode();
model.setTravelNo(null); model.setSubjectCode(null);
List<org.dromara.common.ys.model.res.airport.BookOrderModel> orderList = airPortService.bookOrder(getUserId(), model); List<org.dromara.common.ys.model.res.airport.BookOrderModel> orderList = airPortService.bookOrder(getUserId(), model);
//添加到订单表 //添加到订单表
orderAirportService.batchSaveOrder(getUserId(), travelNo, StreamUtils.toList(orderList, org.dromara.common.ys.model.res.airport.BookOrderModel::getOrderNo)); orderAirportService.batchSaveOrder(getUserId(), travelNo, StreamUtils.toList(orderList, org.dromara.common.ys.model.res.airport.BookOrderModel::getOrderNo));
......
...@@ -68,8 +68,10 @@ public class HotelController extends BaseController { ...@@ -68,8 +68,10 @@ public class HotelController extends BaseController {
@GlobalTransactional(rollbackFor = Exception.class) @GlobalTransactional(rollbackFor = Exception.class)
@PostMapping("/order/book") @PostMapping("/order/book")
public R<HotelOrderBookModel> orderBook(@RequestBody org.dromara.common.ys.model.req.hotel.HotelOrderBookModel model) { public R<HotelOrderBookModel> orderBook(@RequestBody org.dromara.common.ys.model.req.hotel.HotelOrderBookModel model) {
String subjectCode = model.getSubjectCode();
model.setSubjectCode(null);
HotelOrderBookModel book = hotelService.orderBook(getUserId(), model); HotelOrderBookModel book = hotelService.orderBook(getUserId(), model);
orderHotelService.batchSaveOrder(getUserId(), List.of(book.getOrderId())); orderHotelService.batchSaveOrder(getUserId(), subjectCode, List.of(book.getOrderId()));
return R.ok(book); return R.ok(book);
} }
......
...@@ -209,8 +209,10 @@ public class TrainController extends BaseController { ...@@ -209,8 +209,10 @@ public class TrainController extends BaseController {
@GlobalTransactional(rollbackFor = Exception.class) @GlobalTransactional(rollbackFor = Exception.class)
@PostMapping("bookOrder") @PostMapping("bookOrder")
public R<OrderBookResModel> bookOrder(@RequestBody OrderBookReqModel model) { public R<OrderBookResModel> bookOrder(@RequestBody OrderBookReqModel model) {
String subjectCode = model.getSubjectCode();
model.setSubjectCode(null);
OrderBookResModel res = trainService.bookOrder(getUserId(), model); OrderBookResModel res = trainService.bookOrder(getUserId(), model);
orderTrainService.batchSaveOrder(getUserId(), List.of(res.getOrderId())); orderTrainService.batchSaveOrder(getUserId(),subjectCode, List.of(res.getOrderId()));
return R.ok(res); return R.ok(res);
} }
......
...@@ -83,8 +83,10 @@ public class VehiclesController extends BaseController { ...@@ -83,8 +83,10 @@ public class VehiclesController extends BaseController {
@PostMapping("/order/bookJsyc") @PostMapping("/order/bookJsyc")
public R<OrderBookJsycModel> bookOrderJsyc(@RequestBody org.dromara.common.ys.model.req.vehicles.OrderBookJsycModel model) { public R<OrderBookJsycModel> bookOrderJsyc(@RequestBody org.dromara.common.ys.model.req.vehicles.OrderBookJsycModel model) {
model.setTripType(Integer.parseInt(TripType.PUBLIC.getCode())); model.setTripType(Integer.parseInt(TripType.PUBLIC.getCode()));
String subjectCode = model.getSubjectCode();
model.setSubjectCode(null);
OrderBookJsycModel order = vehiclesService.bookJsyc(getUserId(), model); OrderBookJsycModel order = vehiclesService.bookJsyc(getUserId(), model);
orderVehiclesService.saveOrder(getUserId(), order.getOrderId(), order.getOrderNo()); orderVehiclesService.saveOrder(getUserId(), subjectCode, order.getOrderId(), order.getOrderNo());
return R.ok(order); return R.ok(order);
} }
...@@ -95,8 +97,10 @@ public class VehiclesController extends BaseController { ...@@ -95,8 +97,10 @@ public class VehiclesController extends BaseController {
@PostMapping("/order/bookYyyc") @PostMapping("/order/bookYyyc")
public R<OrderBookYyycModel> bookOrderYyyc(@RequestBody org.dromara.common.ys.model.req.vehicles.OrderBookYyycModel model) { public R<OrderBookYyycModel> bookOrderYyyc(@RequestBody org.dromara.common.ys.model.req.vehicles.OrderBookYyycModel model) {
model.setTripType(Integer.parseInt(TripType.PUBLIC.getCode())); model.setTripType(Integer.parseInt(TripType.PUBLIC.getCode()));
String subjectCode = model.getSubjectCode();
model.setSubjectCode(null);
OrderBookYyycModel order = vehiclesService.bookYyyc(getUserId(), model); OrderBookYyycModel order = vehiclesService.bookYyyc(getUserId(), model);
orderVehiclesService.saveOrder(getUserId(), order.getOrderId(), order.getOrderNo()); orderVehiclesService.saveOrder(getUserId(), subjectCode, order.getOrderId(), order.getOrderNo());
return R.ok(order); return R.ok(order);
} }
......
...@@ -19,9 +19,10 @@ public interface IOrderHotelService extends IBaseService<OrderHotelVo, OrderHote ...@@ -19,9 +19,10 @@ public interface IOrderHotelService extends IBaseService<OrderHotelVo, OrderHote
* 批量保存订单 * 批量保存订单
* *
* @param userId 用户id * @param userId 用户id
* @param applyCode 申请单编码
* @param orderNoList 订单号列表 * @param orderNoList 订单号列表
*/ */
void batchSaveOrder(String userId, List<String> orderNoList); void batchSaveOrder(String userId, String applyCode, List<String> orderNoList);
/** /**
* 更新机票信息 * 更新机票信息
......
...@@ -19,9 +19,10 @@ public interface IOrderTrainService extends IBaseService<OrderTrainVo, OrderTrai ...@@ -19,9 +19,10 @@ public interface IOrderTrainService extends IBaseService<OrderTrainVo, OrderTrai
* 批量保存订单 * 批量保存订单
* *
* @param userId 用户id * @param userId 用户id
* @param applyCode 申请单编码
* @param orderNoList 订单号列表 * @param orderNoList 订单号列表
*/ */
void batchSaveOrder(String userId, List<String> orderNoList); void batchSaveOrder(String userId, String applyCode, List<String> orderNoList);
/** /**
* 更新火车票信息 * 更新火车票信息
......
...@@ -18,11 +18,12 @@ public interface IOrderVehiclesService extends IBaseService<OrderVehiclesVo, Ord ...@@ -18,11 +18,12 @@ public interface IOrderVehiclesService extends IBaseService<OrderVehiclesVo, Ord
/** /**
* 批量保存订单 * 批量保存订单
* *
* @param userId 用户id * @param userId 用户id
* @param orderId 订单id * @param applyCode 申请单编码
* @param orderNo 订单编码 * @param orderId 订单id
* @param orderNo 订单编码
*/ */
void saveOrder(String userId, String orderId, String orderNo); void saveOrder(String userId, String applyCode, String orderId, String orderNo);
/** /**
* 更新火车票信息 * 更新火车票信息
......
...@@ -87,13 +87,14 @@ public class OrderHotelServiceImpl extends AbstractBaseService<OrderHotelVo, Ord ...@@ -87,13 +87,14 @@ public class OrderHotelServiceImpl extends AbstractBaseService<OrderHotelVo, Ord
} }
@Override @Override
public void batchSaveOrder(String userId, List<String> orderNoList) { public void batchSaveOrder(String userId, String applyCode, List<String> orderNoList) {
BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId)); BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId));
if (Objects.isNull(user)) { if (Objects.isNull(user)) {
throw new RuntimeException("用户不存在"); throw new RuntimeException("用户不存在");
} }
List<OrderHotel> orderList = orderNoList.stream().map(orderNo -> { List<OrderHotel> orderList = orderNoList.stream().map(orderNo -> {
OrderHotel order = new OrderHotel(); OrderHotel order = new OrderHotel();
order.setApplyCode(applyCode);
order.setPersonCode(userId); order.setPersonCode(userId);
order.setOrderNo(orderNo); order.setOrderNo(orderNo);
order.setTenantId(user.getTenantId()); order.setTenantId(user.getTenantId());
...@@ -124,7 +125,7 @@ public class OrderHotelServiceImpl extends AbstractBaseService<OrderHotelVo, Ord ...@@ -124,7 +125,7 @@ public class OrderHotelServiceImpl extends AbstractBaseService<OrderHotelVo, Ord
scheduledExecutorService.execute(() -> { scheduledExecutorService.execute(() -> {
HotelOrderQueryDetailModel orderModel = hotelService.hotelOrderDetail(order.getPersonCode(), new org.dromara.common.ys.model.req.hotel.HotelOrderQueryDetailModel().setOrderNo(order.getOrderNo())); HotelOrderQueryDetailModel orderModel = hotelService.hotelOrderDetail(order.getPersonCode(), new org.dromara.common.ys.model.req.hotel.HotelOrderQueryDetailModel().setOrderNo(order.getOrderNo()));
//跟新订单数据 //跟新订单数据
BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId"); BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId", "applyCode");
baseMapper.updateById(order); baseMapper.updateById(order);
//跟新入住人信息集合 //跟新入住人信息集合
List<HotelOrderPsgInfoBean> psgList = orderModel.getHtOrderPsgList(); List<HotelOrderPsgInfoBean> psgList = orderModel.getHtOrderPsgList();
......
...@@ -105,13 +105,14 @@ public class OrderTrainServiceImpl extends AbstractBaseService<OrderTrainVo, Ord ...@@ -105,13 +105,14 @@ public class OrderTrainServiceImpl extends AbstractBaseService<OrderTrainVo, Ord
} }
@Override @Override
public void batchSaveOrder(String userId, List<String> orderNoList) { public void batchSaveOrder(String userId, String applyCode, List<String> orderNoList) {
BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId)); BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId));
if (Objects.isNull(user)) { if (Objects.isNull(user)) {
throw new RuntimeException("用户不存在"); throw new RuntimeException("用户不存在");
} }
List<OrderTrain> orderList = orderNoList.stream().map(orderNo -> { List<OrderTrain> orderList = orderNoList.stream().map(orderNo -> {
OrderTrain order = new OrderTrain(); OrderTrain order = new OrderTrain();
order.setApplyCode(applyCode);
order.setPersonCode(userId); order.setPersonCode(userId);
order.setOrderNo(orderNo); order.setOrderNo(orderNo);
order.setTenantId(user.getTenantId()); order.setTenantId(user.getTenantId());
...@@ -143,7 +144,7 @@ public class OrderTrainServiceImpl extends AbstractBaseService<OrderTrainVo, Ord ...@@ -143,7 +144,7 @@ public class OrderTrainServiceImpl extends AbstractBaseService<OrderTrainVo, Ord
scheduledExecutorService.execute(() -> { scheduledExecutorService.execute(() -> {
OrderInfoModel orderModel = trainService.detail(order.getPersonCode(), new OrderQueryModel().setOrderNO(order.getOrderNo())); OrderInfoModel orderModel = trainService.detail(order.getPersonCode(), new OrderQueryModel().setOrderNO(order.getOrderNo()));
//跟新订单数据 //跟新订单数据
BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId"); BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId", "applyCode");
order.setOrderStatusName(orderModel.getOrderStatuName()); order.setOrderStatusName(orderModel.getOrderStatuName());
order.setIsByIdCard(orderModel.getIsByidcard()); order.setIsByIdCard(orderModel.getIsByidcard());
order.setIsNoSeat(orderModel.getIsNoseat()); order.setIsNoSeat(orderModel.getIsNoseat());
......
...@@ -148,12 +148,13 @@ public class OrderVehiclesServiceImpl extends AbstractBaseService<OrderVehiclesV ...@@ -148,12 +148,13 @@ public class OrderVehiclesServiceImpl extends AbstractBaseService<OrderVehiclesV
} }
@Override @Override
public void saveOrder(String userId, String orderId, String orderNo) { public void saveOrder(String userId, String applyCode, String orderId, String orderNo) {
BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId)); BizUser user = userMapper.selectOne(new LambdaQueryWrapper<BizUser>().eq(BizUser::getUserNo, userId));
if (Objects.isNull(user)) { if (Objects.isNull(user)) {
throw new RuntimeException("用户不存在"); throw new RuntimeException("用户不存在");
} }
OrderVehicles order = new OrderVehicles(); OrderVehicles order = new OrderVehicles();
order.setApplyCode(applyCode);
order.setPersonCode(userId); order.setPersonCode(userId);
order.setOrderNo(orderNo); order.setOrderNo(orderNo);
order.setOrderId(orderId); order.setOrderId(orderId);
...@@ -179,7 +180,7 @@ public class OrderVehiclesServiceImpl extends AbstractBaseService<OrderVehiclesV ...@@ -179,7 +180,7 @@ public class OrderVehiclesServiceImpl extends AbstractBaseService<OrderVehiclesV
scheduledExecutorService.execute(() -> { scheduledExecutorService.execute(() -> {
OrderDetailModel orderModel = vehiclesService.detail(order.getPersonCode(), new org.dromara.common.ys.model.req.vehicles.OrderDetailModel().setOrderNo(order.getOrderNo())); OrderDetailModel orderModel = vehiclesService.detail(order.getPersonCode(), new org.dromara.common.ys.model.req.vehicles.OrderDetailModel().setOrderNo(order.getOrderNo()));
//跟新订单数据 //跟新订单数据
BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId", "orderNo"); BeanUtil.copyProperties(orderModel, order, "id", "personCode", "tenantId", "orderNo", "applyCode");
order.setIsCancel(orderModel.getIscancel()); order.setIsCancel(orderModel.getIscancel());
order.setDdCityId(orderModel.getDdcityId()); order.setDdCityId(orderModel.getDdcityId());
order.setDdCityName(orderModel.getDdcityName()); order.setDdCityName(orderModel.getDdcityName());
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论