From 42eafa33d216028abeef95ceaa5af1c5d74cb2cc Mon Sep 17 00:00:00 2001 From: dengwc Date: Fri, 29 Mar 2024 12:59:27 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=81=E7=A8=8B=E4=B8=8D=E9=87=8D=E5=A4=8D?= =?UTF-8?q?=E5=8F=91=E8=B5=B7=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../domain/service/BPMOrderDomainService.java | 356 ++++++++++++++++++ .../domain/service/OrderDomainService.java | 279 +------------- 2 files changed, 359 insertions(+), 276 deletions(-) create mode 100644 src/main/java/com/chint/domain/service/BPMOrderDomainService.java diff --git a/src/main/java/com/chint/domain/service/BPMOrderDomainService.java b/src/main/java/com/chint/domain/service/BPMOrderDomainService.java new file mode 100644 index 00000000..fef11cf0 --- /dev/null +++ b/src/main/java/com/chint/domain/service/BPMOrderDomainService.java @@ -0,0 +1,356 @@ +package com.chint.domain.service; + +import com.chint.application.commands.BPMAuditCommand; +import com.chint.domain.aggregates.order.Leg; +import com.chint.domain.aggregates.order.OrderDetail; +import com.chint.domain.aggregates.order.RouteOrder; +import com.chint.domain.aggregates.system.ProcessInitiationControl; +import com.chint.domain.exceptions.NotFoundException; +import com.chint.domain.factoriy.leg_event.LegEventFactory; +import com.chint.domain.factoriy.order.RouteOrderFactory; +import com.chint.domain.factoriy.order_detail.OrderDetailFactory; +import com.chint.domain.repository.*; +import com.chint.infrastructure.constant.CommonMessageConstant; +import com.chint.infrastructure.repository.jdbc.JdbcLegRepository; +import com.chint.infrastructure.repository.jdbc.JdbcOrderDetailRepository; +import com.chint.infrastructure.repository.jdbc.JdbcProcessInitiationControlRepository; +import com.chint.infrastructure.util.DelayDispatch; +import com.chint.interfaces.rest.bpm.BPMParamFactory; +import com.chint.interfaces.rest.bpm.BPMRequest; +import com.chint.interfaces.rest.bpm.dto.ANExceedStandardDto; +import com.chint.interfaces.rest.bpm.dto.ExceedStandardDto; +import com.chint.interfaces.rest.bpm.dto.RescheduleDto; +import com.chint.interfaces.rest.ctrip.CTripOrderSearchRequest; +import com.chint.interfaces.rest.ctrip.dto.search.ItineraryEntity; +import com.chint.interfaces.rest.ctrip.dto.search.SearchOrderResponse; +import com.chint.interfaces.rest.ctrip.dto.search.flight.ChangeInfo; +import com.chint.interfaces.rest.ctrip.dto.search.flight.FlightOrderInfoEntity; +import com.chint.interfaces.rest.ly.LYSearchRequest; +import com.chint.interfaces.rest.ly.dto.search.response.filght.FlightOrderResponse; +import com.chint.interfaces.rest.ly.dto.search.response.train.TrainDetailResponse; +import com.chint.interfaces.rest.user.UserHttpRequest; +import org.apache.commons.lang3.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; + +import java.math.BigDecimal; +import java.time.format.DateTimeFormatter; +import java.util.List; +import java.util.Objects; + +import static com.chint.infrastructure.constant.BPMConstant.*; +import static com.chint.infrastructure.constant.BPMConstant.REFUND_TYPE_FLIGHT; +import static com.chint.infrastructure.constant.BelongSystemConstant.BELONG_SYS_CODE_ANFSSC; +import static com.chint.infrastructure.constant.LegConstant.*; +import static com.chint.infrastructure.constant.LegConstant.LEG_TYPE_OTHER; +import static com.chint.infrastructure.constant.OrderConstant.ORDER_EVENT_CHANGE; +import static com.chint.infrastructure.constant.OrderConstant.ORDER_EVENT_REFUND; +import static com.chint.infrastructure.constant.SupplierNameConstant.*; +import static com.chint.infrastructure.constant.SupplierNameConstant.SUPPLIER_L_Y_BPM_NAME; + +@Service +public class BPMOrderDomainService { + + @Autowired + private RouteRepository routeRepository; + + + @Autowired + private BPMParamFactory bpmParamFactory; + + @Autowired + private BPMRequest bpmRequest; + + + @Autowired + private CTripOrderSearchRequest cTripOrderSearchRequest; + + @Autowired + private LYSearchRequest lySearchRequest; + + @Autowired + private JdbcOrderDetailRepository jdbcOrderDetailRepository; + + @Autowired + private JdbcLegRepository jdbcLegRepository; + + @Autowired + private JdbcProcessInitiationControlRepository jdbcProcessInitiationControlRepository; + + //超标 + @Transactional + public void toBpmAuditETA(BPMAuditCommand command) { + OrderDetail orderDetail = command.getExtensionData(); + List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 1); + //不为空表示已推动过超标，直接返回结果 + if (!byOrderNoAndTag.isEmpty()) { + return; + } + RouteOrder routeOrder = routeRepository.queryById(orderDetail.getRouteId()); + String sysCode = routeOrder.getApproveOrderNo().getSysCode(); + String employeeNo = orderDetail.getEmployeeNo();//用户id + String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany();//用户编号 + //获取公司编号 + //安能超标 + if (BELONG_SYS_CODE_ANFSSC.equals(sysCode)) { + ANExceedStandardDto anExceedStandardDto = switch (command.getProductType()) { + case LEG_TYPE_TRAIN -> bpmParamFactory.ANCreatAuditParamByTrain(orderDetail); + case LEG_TYPE_AIRPLANE -> bpmParamFactory.ANCreatAuditParamByFlight(orderDetail); + case LEG_TYPE_HOTEL -> bpmParamFactory.ANCreatAuditParamByHotel(orderDetail); + case LEG_TYPE_TAXI -> bpmParamFactory.ANCreatAuditParamByCar(orderDetail); + case LEG_TYPE_OTHER -> bpmParamFactory.ANCreatAuditParamByOther(orderDetail); + default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND); + }; + Long legId = orderDetail.getLegId();//节点id + Leg leg = jdbcLegRepository.findByLegId(legId); + anExceedStandardDto.setApplyNo(routeOrder.getApproveOrderNo().getFakeOrderNo())//申请单号 + .setLegNo(leg == null ? "" : leg.getLegNo());//行程编号 + DelayDispatch.attemptToSend(() -> bpmRequest.ANExceedStandard(anExceedStandardDto).getSuccess(), + 0); + } else { + //其它 + ExceedStandardDto exceedStandardDto = switch (command.getProductType()) { + case LEG_TYPE_TRAIN -> bpmParamFactory.creatAuditParamByTrain(orderDetail); + case LEG_TYPE_AIRPLANE -> bpmParamFactory.creatAuditParamByFlight(orderDetail); + case LEG_TYPE_HOTEL -> bpmParamFactory.creatAuditParamByHotel(orderDetail); + case LEG_TYPE_TAXI -> bpmParamFactory.creatAuditParamByCar(orderDetail); + case LEG_TYPE_OTHER -> bpmParamFactory.creatAuditParamByOther(orderDetail); + default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND); + }; + exceedStandardDto.setReason(command.getReason()); + DelayDispatch.attemptToSend(() -> bpmRequest.exceedStandard(exceedStandardDto, sysCode, employeeNo, accountCompany).getSuccess(), + 0); + } + //结束保存推送信息 + ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); + processInitiationControl.setOrderNo(orderDetail.getOrderNo()) + .setTag(1); + jdbcProcessInitiationControlRepository.save(processInitiationControl); + } + + //改签 + @Transactional + public void toBpmReschedule(BPMAuditCommand command) { + OrderDetail orderDetail = command.getExtensionData(); + RouteOrder routeOrder = routeRepository.queryById(orderDetail.getRouteId()); + String sysCode = routeOrder.getApproveOrderNo().getSysCode(); + String reason = command.getReason(); + //创建改签对象 + RescheduleDto rescheduleDto = new RescheduleDto(); + rescheduleDto.setFee(orderDetail.getPrice() == null ? new BigDecimal(0) : new BigDecimal(orderDetail.getPrice()))//费用 + .setOrderNo(orderDetail.getOrderNo())//订单号 + .setReason(reason);//原因 + //携程 + if (orderDetail.getSupplierName().equals(SUPPLIER_C_TRIP)) { + //退票 + if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { + List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 3); + //不为空表示已推动过退票，直接返回结果 + if (!byOrderNoAndTag.isEmpty()) { + return; + } + } + Integer rebookId = null;//默认为空 + rescheduleDto.setOrderSource(SUPPLIER_C_TRIP_BPM_NAME);//携程商旅 + //查询订单明细 + SearchOrderResponse searchOrderResponse = cTripOrderSearchRequest.searchOrderResponseByOrderId(orderDetail.getOrderNo()); + //机票改签 + if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + //设置改签原时间、改签后时间、改签原因 + rebookId = setCTripChangeFlight(rescheduleDto, searchOrderResponse); + rescheduleDto.setOrderType(RESCHEDULE_TYPE_FLIGHT); + //改签 + List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo() + "-" + rebookId, 2); + //不为空表示已推动过改签，直接返回结果 + if (!byOrderNoAndTag.isEmpty()) { + return; + } + } + //机票退票 + if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { + String refundResonDesc = ""; + try { + FlightOrderInfoEntity flightOrderInfoList = searchOrderResponse.getItineraryList().get(0).getFlightOrderInfoList().get(0); + refundResonDesc = flightOrderInfoList.getRefundInfo().get(0).getRefundResonDesc(); + rescheduleDto.setReason(StringUtils.isNotBlank(refundResonDesc) ? refundResonDesc : "计划有变，更改行程"); + } catch (Exception e) { + //如果越界标识没有值 + rescheduleDto.setReason("计划有变，更改行程"); + } + rescheduleDto.setOrderType(REFUND_TYPE_FLIGHT); + } + + String employeeNo = orderDetail.getEmployeeNo(); + String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany(); + //发送 + DelayDispatch.attemptToSend(() -> bpmRequest.reschedule(rescheduleDto, sysCode, employeeNo, accountCompany).getSuccess(), + 0); + + //结束保存推送信息 + ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); + if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + processInitiationControl.setOrderNo(orderDetail.getOrderNo() + "-" + rebookId); + processInitiationControl.setTag(2); + } + if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { + processInitiationControl.setOrderNo(orderDetail.getOrderNo()); + processInitiationControl.setTag(3); + } + jdbcProcessInitiationControlRepository.save(processInitiationControl); + } + + //同程 + if (orderDetail.getSupplierName().equals(SUPPLIER_L_Y)) { + //改签 + if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 2); + //不为空表示已推动过改签，直接返回结果 + if (!byOrderNoAndTag.isEmpty()) { + return; + } + } + //退票 + if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { + List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 3); + //不为空表示已推动过退票，直接返回结果 + if (!byOrderNoAndTag.isEmpty()) { + return; + } + } + rescheduleDto.setOrderSource(SUPPLIER_L_Y_BPM_NAME);//同程商旅 + //火车票改签 + if (orderDetail.getProductType().equals(LEG_TYPE_TRAIN) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + TrainDetailResponse trainDetailResponse = lySearchRequest.getTrainOrderDetail(orderDetail.getOrderNo()); + setLYChangeTrain(rescheduleDto, trainDetailResponse);//火车票只支持一次改签 + rescheduleDto.setOrderType(RESCHEDULE_TYPE_TRAIN); + } + + //火车票退票 + if (orderDetail.getProductType().equals(LEG_TYPE_TRAIN) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { + rescheduleDto.setOrderType(REFUND_TYPE_TRAIN); + rescheduleDto.setReason("计划有变，更改行程");//目前没有原因 + } + //机票改签 + if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + // 将LocalDateTime对象格式化成字符串 + String rebookStartTime = orderDetail.getStartTime().format(formatter); + rescheduleDto.setRebookStartTime(rebookStartTime);//变更后时间 + + FlightOrderResponse flightOrderResponse = lySearchRequest.getFlightOrderDetail(orderDetail.getOrderNo()); + //原订单 + String parentOrderSerialNo = flightOrderResponse.getData().getOrderDetails().getParentOrderSerialNo(); + OrderDetail orderDetailOld = jdbcOrderDetailRepository.findFirstByOrderNo(parentOrderSerialNo); + String startTime = orderDetailOld.getStartTime().format(formatter); + rescheduleDto.setStartTime(startTime); + rescheduleDto.setOrderType(RESCHEDULE_TYPE_FLIGHT); + rescheduleDto.setReason("计划有变，更改行程");//目前没有原因 + } + + //机票退票 + if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { + rescheduleDto.setOrderType(REFUND_TYPE_FLIGHT); + rescheduleDto.setReason("计划有变，更改行程"); + } + + String employeeNo = orderDetail.getEmployeeNo(); + String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany(); + //发送 + DelayDispatch.attemptToSend(() -> bpmRequest.reschedule(rescheduleDto, sysCode, employeeNo, accountCompany).getSuccess(), + 0); + + //结束保存推送信息 + ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); + processInitiationControl.setOrderNo(orderDetail.getOrderNo()); + if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { + processInitiationControl.setTag(2); + } + if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { + processInitiationControl.setTag(3); + } + jdbcProcessInitiationControlRepository.save(processInitiationControl); + } + + } + + + //携程机票改签 + private Integer setCTripChangeFlight(RescheduleDto rescheduleDto, SearchOrderResponse searchOrderResponse) { + List itineraryList = searchOrderResponse.getItineraryList(); + try { + ItineraryEntity itineraryEntity = itineraryList.get(0); + FlightOrderInfoEntity flightOrderInfoList = itineraryEntity.getFlightOrderInfoList().get(0); + //改签前时间 + String createTime = flightOrderInfoList.getFlightInfo().get(0).getTakeoffTime(); + List changeInfoList = flightOrderInfoList.getPassengerInfo().get(0).getSequenceInfo().get(0).getChangeInfo(); + //多次改签 + if (changeInfoList.size() >= 2) { + ChangeInfo changeInfoOld = changeInfoList.get(changeInfoList.size() - 2); + String cTakeOffTimeOld = changeInfoOld.getCTakeOffTime();//前一次改签时间 + ChangeInfo changeInfoNew = changeInfoList.get(changeInfoList.size() - 1); + String cTakeOffTimeNew = changeInfoNew.getCTakeOffTime();//最后一次改签时间 + String rebookReasonDescNew = changeInfoNew.getRebookReasonDesc();//最后一次改签原因 + //设置值 + rescheduleDto.setStartTime(cTakeOffTimeOld) + .setRebookStartTime(cTakeOffTimeNew) + .setReason(rebookReasonDescNew); + return changeInfoNew.getRebookId(); + } else { + ChangeInfo changeInfo = changeInfoList.get(changeInfoList.size() - 1); + //改签后时间 + String cTakeOffTime = changeInfo.getCTakeOffTime(); + //改签原因 + String RebookReasonDesc = changeInfo.getRebookReasonDesc(); + rescheduleDto.setStartTime(createTime) + .setRebookStartTime(cTakeOffTime) + .setReason(RebookReasonDesc); + return changeInfo.getRebookId(); + } + } catch (Exception e) { + rescheduleDto.setStartTime("") + .setRebookStartTime("") + .setReason("计划有变，更改行程"); + return null; + } + } + + //火车票改签 + private void setLYChangeTrain(RescheduleDto rescheduleDto, TrainDetailResponse trainDetailResponse) { + TrainDetailResponse.TrainDetailData data = trainDetailResponse.getData(); + String trainNoOld = data.getTrainNo();//原车次 + String planBeginDateOld = data.getPlanBeginDate();//原时间 + rescheduleDto.setStartTime(planBeginDateOld) + .setTrainNumber(trainNoOld);//原车次 + if (!data.getItems().isEmpty()) { + TrainDetailResponse.Item item = data.getItems().get(0); + String seatClassOld = item.getSeatClass();//原席别 + TrainDetailResponse.ChangeInfo changeInfo = item.getChangeInfo(); + //如果是空表示是改签后订单 + if (Objects.isNull(changeInfo)) { + //获取原订单的changeInfo + String parentOrderSerialNo = data.getParentOrderSerialNo(); + TrainDetailResponse parentTrainDetailResponse = lySearchRequest.getTrainOrderDetail(parentOrderSerialNo); + if (parentTrainDetailResponse != null) { + changeInfo = parentTrainDetailResponse.getData().getItems().get(0).getChangeInfo(); + } + + } + String planBeginDateNew = ""; + String trainNoNew = ""; + String seatClassNew = ""; + //不为空 + if (!Objects.isNull(changeInfo)) { + planBeginDateNew = changeInfo.getPlanBeginDate();//改签后时间 + trainNoNew = changeInfo.getTrainNo();//改签后车次 + seatClassNew = changeInfo.getChangeItem().getSeatClass();//改签后席别 + } + //设置值 + rescheduleDto.setRebookStartTime(planBeginDateNew) + .setSeatingStandard(seatClassOld)//原席别 + .setRebookTrainNumber(trainNoNew)//改签后车次 + .setRebookSeatingStandard(seatClassNew)//改签后席别 + .setReason("计划有变，更改行程"); + } + } +} diff --git a/src/main/java/com/chint/domain/service/OrderDomainService.java b/src/main/java/com/chint/domain/service/OrderDomainService.java index 6b514b22..ccaa5caf 100644 --- a/src/main/java/com/chint/domain/service/OrderDomainService.java +++ b/src/main/java/com/chint/domain/service/OrderDomainService.java @@ -114,7 +114,7 @@ public class OrderDomainService { private JdbcLegRepository jdbcLegRepository; @Autowired - private JdbcProcessInitiationControlRepository jdbcProcessInitiationControlRepository; + private BPMOrderDomainService bpmOrderDomainService; private Set companyBlackList = new HashSet<>(); @@ -272,287 +272,14 @@ public class OrderDomainService { } @ListenTo(command = "BPMAuditCommand", order = 0) - @Transactional public void toBpmAudit(BPMAuditCommand command) { if (command.getOperationType().equals(ORDER_EVENT_ETA)) { - toBpmAuditETA(command); + bpmOrderDomainService.toBpmAuditETA(command); } else if ( (command.getOperationType().equals(ORDER_EVENT_CHANGE) || command.getOperationType().equals(ORDER_EVENT_REFUND)) && (command.getProductType().equals(LEG_TYPE_TRAIN) || command.getProductType().equals(LEG_TYPE_AIRPLANE)) ) { - toBpmReschedule(command); - } - } - - @Transactional - public void toBpmAuditETA(BPMAuditCommand command) { - OrderDetail orderDetail = command.getExtensionData(); - List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 1); - //不为空表示已推动过超标，直接返回结果 - if (!byOrderNoAndTag.isEmpty()) { - return; - } - RouteOrder routeOrder = routeRepository.queryById(orderDetail.getRouteId()); - String sysCode = routeOrder.getApproveOrderNo().getSysCode(); - String employeeNo = orderDetail.getEmployeeNo();//用户id - String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany();//用户编号 - //获取公司编号 - //安能超标 - if (BELONG_SYS_CODE_ANFSSC.equals(sysCode)) { - ANExceedStandardDto anExceedStandardDto = switch (command.getProductType()) { - case LEG_TYPE_TRAIN -> bpmParamFactory.ANCreatAuditParamByTrain(orderDetail); - case LEG_TYPE_AIRPLANE -> bpmParamFactory.ANCreatAuditParamByFlight(orderDetail); - case LEG_TYPE_HOTEL -> bpmParamFactory.ANCreatAuditParamByHotel(orderDetail); - case LEG_TYPE_TAXI -> bpmParamFactory.ANCreatAuditParamByCar(orderDetail); - case LEG_TYPE_OTHER -> bpmParamFactory.ANCreatAuditParamByOther(orderDetail); - default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND); - }; - Long legId = orderDetail.getLegId();//节点id - Leg leg = jdbcLegRepository.findByLegId(legId); - anExceedStandardDto.setApplyNo(routeOrder.getApproveOrderNo().getFakeOrderNo())//申请单号 - .setLegNo(leg == null ? "" : leg.getLegNo());//行程编号 - DelayDispatch.attemptToSend(() -> bpmRequest.ANExceedStandard(anExceedStandardDto).getSuccess(), - 0); - } else { - //其它 - ExceedStandardDto exceedStandardDto = switch (command.getProductType()) { - case LEG_TYPE_TRAIN -> bpmParamFactory.creatAuditParamByTrain(orderDetail); - case LEG_TYPE_AIRPLANE -> bpmParamFactory.creatAuditParamByFlight(orderDetail); - case LEG_TYPE_HOTEL -> bpmParamFactory.creatAuditParamByHotel(orderDetail); - case LEG_TYPE_TAXI -> bpmParamFactory.creatAuditParamByCar(orderDetail); - case LEG_TYPE_OTHER -> bpmParamFactory.creatAuditParamByOther(orderDetail); - default -> throw new NotFoundException(CommonMessageConstant.NOT_FOUND); - }; - exceedStandardDto.setReason(command.getReason()); - DelayDispatch.attemptToSend(() -> bpmRequest.exceedStandard(exceedStandardDto, sysCode, employeeNo, accountCompany).getSuccess(), - 0); - } - //结束保存推送信息 - ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); - processInitiationControl.setOrderNo(orderDetail.getOrderNo()) - .setTag(1); - jdbcProcessInitiationControlRepository.save(processInitiationControl); - } - @Transactional - public void toBpmReschedule(BPMAuditCommand command) { - OrderDetail orderDetail = command.getExtensionData(); - RouteOrder routeOrder = routeRepository.queryById(orderDetail.getRouteId()); - String sysCode = routeOrder.getApproveOrderNo().getSysCode(); - String reason = command.getReason(); - //创建改签对象 - RescheduleDto rescheduleDto = new RescheduleDto(); - rescheduleDto.setFee(orderDetail.getPrice() == null ? new BigDecimal(0) : new BigDecimal(orderDetail.getPrice()))//费用 - .setOrderNo(orderDetail.getOrderNo())//订单号 - .setReason(reason);//原因 - //携程 - if (orderDetail.getSupplierName().equals(SUPPLIER_C_TRIP)) { - //退票 - if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { - List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 3); - //不为空表示已推动过退票，直接返回结果 - if (!byOrderNoAndTag.isEmpty()) { - return; - } - } - Integer rebookId = null;//默认为空 - rescheduleDto.setOrderSource(SUPPLIER_C_TRIP_BPM_NAME);//携程商旅 - //查询订单明细 - SearchOrderResponse searchOrderResponse = cTripOrderSearchRequest.searchOrderResponseByOrderId(orderDetail.getOrderNo()); - //机票改签 - if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - //设置改签原时间、改签后时间、改签原因 - rebookId = setCTripChangeFlight(rescheduleDto, searchOrderResponse); - rescheduleDto.setOrderType(RESCHEDULE_TYPE_FLIGHT); - //改签 - List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo() + "-" + rebookId, 2); - //不为空表示已推动过改签，直接返回结果 - if (!byOrderNoAndTag.isEmpty()) { - return; - } - } - //机票退票 - if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { - String refundResonDesc = ""; - try { - FlightOrderInfoEntity flightOrderInfoList = searchOrderResponse.getItineraryList().get(0).getFlightOrderInfoList().get(0); - refundResonDesc = flightOrderInfoList.getRefundInfo().get(0).getRefundResonDesc(); - rescheduleDto.setReason(StringUtils.isNotBlank(refundResonDesc) ? refundResonDesc : "计划有变，更改行程"); - } catch (Exception e) { - //如果越界标识没有值 - rescheduleDto.setReason("计划有变，更改行程"); - } - rescheduleDto.setOrderType(REFUND_TYPE_FLIGHT); - } - - String employeeNo = orderDetail.getEmployeeNo(); - String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany(); - //发送 - DelayDispatch.attemptToSend(() -> bpmRequest.reschedule(rescheduleDto, sysCode, employeeNo, accountCompany).getSuccess(), - 0); - - //结束保存推送信息 - ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); - if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - processInitiationControl.setOrderNo(orderDetail.getOrderNo() + "-" + rebookId); - processInitiationControl.setTag(2); - } - if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { - processInitiationControl.setOrderNo(orderDetail.getOrderNo()); - processInitiationControl.setTag(3); - } - jdbcProcessInitiationControlRepository.save(processInitiationControl); - } - - //同程 - if (orderDetail.getSupplierName().equals(SUPPLIER_L_Y)) { - //改签 - if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 2); - //不为空表示已推动过改签，直接返回结果 - if (!byOrderNoAndTag.isEmpty()) { - return; - } - } - //退票 - if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { - List byOrderNoAndTag = jdbcProcessInitiationControlRepository.findByOrderNoAndTag(orderDetail.getOrderNo(), 3); - //不为空表示已推动过退票，直接返回结果 - if (!byOrderNoAndTag.isEmpty()) { - return; - } - } - rescheduleDto.setOrderSource(SUPPLIER_L_Y_BPM_NAME);//同程商旅 - //火车票改签 - if (orderDetail.getProductType().equals(LEG_TYPE_TRAIN) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - TrainDetailResponse trainDetailResponse = lySearchRequest.getTrainOrderDetail(orderDetail.getOrderNo()); - setLYChangeTrain(rescheduleDto, trainDetailResponse);//火车票只支持一次改签 - rescheduleDto.setOrderType(RESCHEDULE_TYPE_TRAIN); - } - - //火车票退票 - if (orderDetail.getProductType().equals(LEG_TYPE_TRAIN) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { - rescheduleDto.setOrderType(REFUND_TYPE_TRAIN); - rescheduleDto.setReason("计划有变，更改行程");//目前没有原因 - } - //机票改签 - if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); - // 将LocalDateTime对象格式化成字符串 - String rebookStartTime = orderDetail.getStartTime().format(formatter); - rescheduleDto.setRebookStartTime(rebookStartTime);//变更后时间 - - FlightOrderResponse flightOrderResponse = lySearchRequest.getFlightOrderDetail(orderDetail.getOrderNo()); - //原订单 - String parentOrderSerialNo = flightOrderResponse.getData().getOrderDetails().getParentOrderSerialNo(); - OrderDetail orderDetailOld = jdbcOrderDetailRepository.findFirstByOrderNo(parentOrderSerialNo); - String startTime = orderDetailOld.getStartTime().format(formatter); - rescheduleDto.setStartTime(startTime); - rescheduleDto.setOrderType(RESCHEDULE_TYPE_FLIGHT); - rescheduleDto.setReason("计划有变，更改行程");//目前没有原因 - } - - //机票退票 - if (orderDetail.getProductType().equals(LEG_TYPE_AIRPLANE) && command.getOperationType().equals(ORDER_EVENT_REFUND)) { - rescheduleDto.setOrderType(REFUND_TYPE_FLIGHT); - rescheduleDto.setReason("计划有变，更改行程"); - } - - String employeeNo = orderDetail.getEmployeeNo(); - String accountCompany = routeOrder.getApproveOrderNo().getAccountCompany(); - //发送 - DelayDispatch.attemptToSend(() -> bpmRequest.reschedule(rescheduleDto, sysCode, employeeNo, accountCompany).getSuccess(), - 0); - - //结束保存推送信息 - ProcessInitiationControl processInitiationControl = new ProcessInitiationControl(); - processInitiationControl.setOrderNo(orderDetail.getOrderNo()); - if (command.getOperationType().equals(ORDER_EVENT_CHANGE)) { - processInitiationControl.setTag(2); - } - if (command.getOperationType().equals(ORDER_EVENT_REFUND)) { - processInitiationControl.setTag(3); - } - jdbcProcessInitiationControlRepository.save(processInitiationControl); - } - - } - - //携程机票改签 - private Integer setCTripChangeFlight(RescheduleDto rescheduleDto, SearchOrderResponse searchOrderResponse) { - List itineraryList = searchOrderResponse.getItineraryList(); - try { - ItineraryEntity itineraryEntity = itineraryList.get(0); - FlightOrderInfoEntity flightOrderInfoList = itineraryEntity.getFlightOrderInfoList().get(0); - //改签前时间 - String createTime = flightOrderInfoList.getFlightInfo().get(0).getTakeoffTime(); - List changeInfoList = flightOrderInfoList.getPassengerInfo().get(0).getSequenceInfo().get(0).getChangeInfo(); - //多次改签 - if (changeInfoList.size() >= 2) { - ChangeInfo changeInfoOld = changeInfoList.get(changeInfoList.size() - 2); - String cTakeOffTimeOld = changeInfoOld.getCTakeOffTime();//前一次改签时间 - ChangeInfo changeInfoNew = changeInfoList.get(changeInfoList.size() - 1); - String cTakeOffTimeNew = changeInfoNew.getCTakeOffTime();//最后一次改签时间 - String rebookReasonDescNew = changeInfoNew.getRebookReasonDesc();//最后一次改签原因 - //设置值 - rescheduleDto.setStartTime(cTakeOffTimeOld) - .setRebookStartTime(cTakeOffTimeNew) - .setReason(rebookReasonDescNew); - return changeInfoNew.getRebookId(); - } else { - ChangeInfo changeInfo = changeInfoList.get(changeInfoList.size() - 1); - //改签后时间 - String cTakeOffTime = changeInfo.getCTakeOffTime(); - //改签原因 - String RebookReasonDesc = changeInfo.getRebookReasonDesc(); - rescheduleDto.setStartTime(createTime) - .setRebookStartTime(cTakeOffTime) - .setReason(RebookReasonDesc); - return changeInfo.getRebookId(); - } - } catch (Exception e) { - rescheduleDto.setStartTime("") - .setRebookStartTime("") - .setReason("计划有变，更改行程"); - return null; - } - } - - //火车票改签 - private void setLYChangeTrain(RescheduleDto rescheduleDto, TrainDetailResponse trainDetailResponse) { - TrainDetailResponse.TrainDetailData data = trainDetailResponse.getData(); - String trainNoOld = data.getTrainNo();//原车次 - String planBeginDateOld = data.getPlanBeginDate();//原时间 - rescheduleDto.setStartTime(planBeginDateOld) - .setTrainNumber(trainNoOld);//原车次 - if (!data.getItems().isEmpty()) { - TrainDetailResponse.Item item = data.getItems().get(0); - String seatClassOld = item.getSeatClass();//原席别 - TrainDetailResponse.ChangeInfo changeInfo = item.getChangeInfo(); - //如果是空表示是改签后订单 - if (Objects.isNull(changeInfo)) { - //获取原订单的changeInfo - String parentOrderSerialNo = data.getParentOrderSerialNo(); - TrainDetailResponse parentTrainDetailResponse = lySearchRequest.getTrainOrderDetail(parentOrderSerialNo); - if (parentTrainDetailResponse != null) { - changeInfo = parentTrainDetailResponse.getData().getItems().get(0).getChangeInfo(); - } - - } - String planBeginDateNew = ""; - String trainNoNew = ""; - String seatClassNew = ""; - //不为空 - if (!Objects.isNull(changeInfo)) { - planBeginDateNew = changeInfo.getPlanBeginDate();//改签后时间 - trainNoNew = changeInfo.getTrainNo();//改签后车次 - seatClassNew = changeInfo.getChangeItem().getSeatClass();//改签后席别 - } - //设置值 - rescheduleDto.setRebookStartTime(planBeginDateNew) - .setSeatingStandard(seatClassOld)//原席别 - .setRebookTrainNumber(trainNoNew)//改签后车次 - .setRebookSeatingStandard(seatClassNew)//改签后席别 - .setReason("计划有变，更改行程"); + bpmOrderDomainService.toBpmReschedule(command); } }