提交 c08727c2 authored 作者: hzh's avatar hzh

Merge branch 'dev'

...@@ -189,42 +189,46 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService { ...@@ -189,42 +189,46 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService {
@Override @Override
public void payed(String orderType, String orderNo) { public void payed(String orderType, String orderNo) {
log.info("支付成功后确认出票,orderType:{},orderNo:{}", orderType, orderNo); log.info("支付成功后确认出票,orderType:{},orderNo:{}", orderType, orderNo);
pay(orderType, orderNo); pay(orderType, orderNo, true);
} }
private void pay(String orderType, String orderNo) { private void pay(String orderType, String orderNo, Boolean isPerson) {
if (StringUtils.equals(orderType, OrderType.AIRPORT.getType())) { if (StringUtils.equals(orderType, OrderType.AIRPORT.getType())) {
//飞机票 //飞机票
Optional.ofNullable(orderAirportService.getOne(new OrderAirportBo().setOrderNo(orderNo))).ifPresent(vo -> { Optional.ofNullable(orderAirportService.getOne(new OrderAirportBo().setOrderNo(orderNo))).ifPresent(vo -> {
try {
//确认出票
airportService.confirmOrder(vo.getPersonCode(), new OrderConfirmModel().setOrderNo(orderNo).setAutoDraw(1));
} catch (Exception e) {
log.error("飞机票确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
}
try { try {
//飞机票支付 //飞机票支付
airportService.payOrder(vo.getPersonCode(), new OrderPayModel().setOrderNo(orderNo)); airportService.payOrder(vo.getPersonCode(), new OrderPayModel().setOrderNo(orderNo));
} catch (Exception e) { } catch (Exception e) {
log.error("飞机票支付失败,orderNo:{},失败原因:{}", orderNo, e.getMessage()); log.error("飞机票支付失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
} }
if (isPerson) {
try {
//确认出票
airportService.confirmOrder(vo.getPersonCode(), new OrderConfirmModel().setOrderNo(orderNo).setAutoDraw(1));
} catch (Exception e) {
log.error("飞机票确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
}
}
orderAirportService.updateOrderInfo(List.of(orderNo)); orderAirportService.updateOrderInfo(List.of(orderNo));
}); });
} else if (StringUtils.equals(orderType, OrderType.TRAIN.getType())) { } else if (StringUtils.equals(orderType, OrderType.TRAIN.getType())) {
//火车票 //火车票
Optional.ofNullable(orderTrainService.getOne(new OrderTrainBo().setOrderNo(orderNo))).ifPresent(vo -> { Optional.ofNullable(orderTrainService.getOne(new OrderTrainBo().setOrderNo(orderNo))).ifPresent(vo -> {
try {
//确认出票
trainService.confirmOrder(vo.getPersonCode(), new ConfirmOrderModel().setOrderNo(orderNo));
} catch (Exception e) {
log.error("火车票确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
}
try { try {
//火车票支付 //火车票支付
trainService.payOrder(vo.getPersonCode(), new org.dromara.common.ys.model.req.train.PayOrderModel().setOrderNo(orderNo)); trainService.payOrder(vo.getPersonCode(), new org.dromara.common.ys.model.req.train.PayOrderModel().setOrderNo(orderNo));
} catch (Exception e) { } catch (Exception e) {
log.error("火车票支付失败,orderNo:{},失败原因:{}", orderNo, e.getMessage()); log.error("火车票支付失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
} }
if (isPerson) {
try {
//确认出票
trainService.confirmOrder(vo.getPersonCode(), new ConfirmOrderModel().setOrderNo(orderNo));
} catch (Exception e) {
log.error("火车票确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
}
}
orderTrainService.updateOrderInfo(List.of(orderNo)); orderTrainService.updateOrderInfo(List.of(orderNo));
}); });
} else if (StringUtils.equals(orderType, OrderType.CAR.getType())) { } else if (StringUtils.equals(orderType, OrderType.CAR.getType())) {
...@@ -232,11 +236,13 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService { ...@@ -232,11 +236,13 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService {
} else if (StringUtils.equals(orderType, OrderType.HOTEL.getType())) { } else if (StringUtils.equals(orderType, OrderType.HOTEL.getType())) {
//酒店 //酒店
Optional.ofNullable(orderHotelService.getOne(new OrderHotelBo().setOrderNo(orderNo))).ifPresent(vo -> { Optional.ofNullable(orderHotelService.getOne(new OrderHotelBo().setOrderNo(orderNo))).ifPresent(vo -> {
try { if (isPerson) {
//确认出票 try {
hotelService.orderPay(vo.getPersonCode(), new PayOrderModel().setOrderNo(orderNo)); //确认出票
} catch (Exception e) { hotelService.orderPay(vo.getPersonCode(), new PayOrderModel().setOrderNo(orderNo));
log.error("酒店确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage()); } catch (Exception e) {
log.error("酒店确认出票失败,orderNo:{},失败原因:{}", orderNo, e.getMessage());
}
} }
orderHotelService.updateOrderInfo(List.of(orderNo)); orderHotelService.updateOrderInfo(List.of(orderNo));
}); });
...@@ -246,7 +252,7 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService { ...@@ -246,7 +252,7 @@ public class RemoteYsOrderServiceImpl implements RemoteYsOrderService {
@Override @Override
public void orderApprove(RemoteOrderApprove orderApprove) { public void orderApprove(RemoteOrderApprove orderApprove) {
log.info("审批同意后,订单修改:{}", orderApprove); log.info("审批同意后,订单修改:{}", orderApprove);
pay(orderApprove.getOrderType(), orderApprove.getOrderNo()); pay(orderApprove.getOrderType(), orderApprove.getOrderNo(), false);
orderInvoicingService.save( orderInvoicingService.save(
new OrderInvoicingBo() new OrderInvoicingBo()
.setType(orderApprove.getOrderType()) .setType(orderApprove.getOrderType())
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论