Compare commits
No commits in common. "dfa1248fe04b0b2895f3fb5fbf8943a4daebe12d" and "814064918ef24f3cf87a43feb4b3067fb6e7ba2e" have entirely different histories.
dfa1248fe0
...
814064918e
|
@ -1,12 +0,0 @@
|
|||
package com.chint.application.commands;
|
||||
|
||||
import com.chint.infrastructure.echo_framework.command.Command;
|
||||
import lombok.Data;
|
||||
|
||||
|
||||
|
||||
//将上月的结算数据生成为财务共享需要的数据
|
||||
@Data
|
||||
public class LYOrderRecordGenerateCommand extends Command {
|
||||
|
||||
}
|
|
@ -1,7 +1,6 @@
|
|||
package com.chint.application.in;
|
||||
|
||||
|
||||
import com.chint.application.commands.LYOrderRecordGenerateCommand;
|
||||
import com.chint.application.dtos.CTripRecordMonthSaveDTO;
|
||||
import com.chint.domain.factoriy.order_record.LyStatementOrder;
|
||||
import com.chint.infrastructure.echo_framework.command.Command;
|
||||
|
@ -70,7 +69,7 @@ public class AutoWorkController {
|
|||
//同步拉取上月数据
|
||||
lyStatementOrder.saveAll();
|
||||
//将上月的结算数据生成为财务共享需要的数据
|
||||
Command.of(LYOrderRecordGenerateCommand.class).sendToQueue();
|
||||
Command.of(OrderRecordGenerateCommand.class).sendToQueue();
|
||||
return Result.Success(SUCCESS);
|
||||
}
|
||||
|
||||
|
|
|
@ -112,10 +112,10 @@ public class OrderEvent implements Serializable {
|
|||
|
||||
public static String mapToHotelOrderDetailStatus(Integer eventType){
|
||||
return switch (eventType) {
|
||||
case ORDER_EVENT_PREPARE -> FSSC_HOTEL_STATUS_SUCCESS; //未下单 改成3
|
||||
case ORDER_EVENT_PREPARE -> FSSC_HOTEL_STATUS_REFUND; //未下单 改成3
|
||||
case ORDER_EVENT_PAYED -> FSSC_HOTEL_STATUS_SUCCESS;
|
||||
case ORDER_EVENT_CHANGE -> FSSC_HOTEL_STATUS_SUCCESS;
|
||||
case ORDER_EVENT_CANCEL -> FSSC_ORDER_STATUS_CANCEL; //e额外生成的单子为3 退票虽然是3 返回为1
|
||||
case ORDER_EVENT_CANCEL -> FSSC_HOTEL_STATUS_SUCCESS; //e额外生成的单子为3 退票虽然是3 返回为1
|
||||
case ORDER_EVENT_ORDERED -> FSSC_HOTEL_STATUS_SUCCESS;
|
||||
case ORDER_EVENT_REFUND -> FSSC_HOTEL_STATUS_SUCCESS;
|
||||
case ORDER_EVENT_UNKNOWN -> FSSC_ORDER_STATUS_CANCEL;
|
||||
|
|
|
@ -70,7 +70,7 @@ public class OrderCarRecord extends OrderBaseRecord {
|
|||
private String offlineCcomyCode; // 成本中心
|
||||
private String orderSource; // 预订来源:线上/线下
|
||||
private String payAmount;//支付总金额
|
||||
private String receiptsNumOrigin;//支付总金额
|
||||
|
||||
|
||||
|
||||
//添加行程信息
|
||||
|
@ -173,17 +173,10 @@ public class OrderCarRecord extends OrderBaseRecord {
|
|||
return this;
|
||||
}
|
||||
|
||||
public OrderCarRecord loadComplianceInfoNot() {
|
||||
this.setOverStandard("否");
|
||||
this.setOverStandardReason("");
|
||||
return this;
|
||||
}
|
||||
|
||||
// 加载关联订单信息
|
||||
public OrderCarRecord loadRelatedOrderInfo(Long orderDetailId,
|
||||
String detailId,
|
||||
String receiptsNum,
|
||||
String receiptsNumOrigin,
|
||||
String parentOrderNo,
|
||||
String originalOrderNo) {
|
||||
this.setOrderDetailId(orderDetailId);
|
||||
|
@ -191,7 +184,6 @@ public class OrderCarRecord extends OrderBaseRecord {
|
|||
this.setReceiptsNum(receiptsNum);
|
||||
this.setParentOrderNo(parentOrderNo);
|
||||
this.setOriginalOrderNo(originalOrderNo);
|
||||
this.setReceiptsNumOrigin(receiptsNumOrigin);
|
||||
return this;
|
||||
}
|
||||
}
|
|
@ -78,8 +78,6 @@ public class OrderFlightRecord extends OrderBaseRecord {
|
|||
private String offlineCcomyCode; // 成本中心
|
||||
private String orderStatus;
|
||||
private String createTime;
|
||||
private String receiptsNumOrigin;//原差旅申请单单号
|
||||
private String payAmount;
|
||||
|
||||
// 加载基础订单信息
|
||||
public OrderFlightRecord loadBasicOrderInfo(String orderNo,
|
||||
|
@ -129,9 +127,9 @@ public class OrderFlightRecord extends OrderBaseRecord {
|
|||
|
||||
// 加载座位细节
|
||||
public OrderFlightRecord loadSeatInfo(String seatPoint,
|
||||
String seatPointName,
|
||||
String seatPointName,
|
||||
|
||||
String seatDiscount) {
|
||||
String seatDiscount) {
|
||||
this.setSeatDiscount(seatDiscount);
|
||||
this.setSeatPoint(seatPoint);
|
||||
this.setSeatPointName(seatPointName);
|
||||
|
@ -154,14 +152,13 @@ public class OrderFlightRecord extends OrderBaseRecord {
|
|||
public OrderFlightRecord loadFinancialAndPricingInfo(String accountPeriod,
|
||||
String billNo,
|
||||
String orderAmount,
|
||||
String payAmount,
|
||||
|
||||
String ycabinFullPrice,
|
||||
String policyLowestPrice,
|
||||
String flightLowestPrice) {
|
||||
this.setAccountPeriod(accountPeriod);
|
||||
this.setBillNo(billNo);
|
||||
this.setOrderAmount(orderAmount);
|
||||
this.setPayAmount(payAmount);
|
||||
this.setYcabinFullPrice(ycabinFullPrice); //经济舱全价
|
||||
this.setPolicyLowestPrice(policyLowestPrice); // 比价范围最低价
|
||||
this.setFlightLowestPrice(flightLowestPrice); // 航班最低价
|
||||
|
@ -213,22 +210,16 @@ public class OrderFlightRecord extends OrderBaseRecord {
|
|||
|
||||
// 加载违规信息
|
||||
public OrderFlightRecord loadComplianceInfo(OrderDetail orderDetail) {
|
||||
orderDetail.getETAEvent().ifPresentOrElse(it -> {
|
||||
orderDetail.getETAEvent().ifPresentOrElse(it->{
|
||||
this.setOverStandard("是");
|
||||
this.setOverStandardReason(it.getExtension());
|
||||
}, () -> {
|
||||
},()->{
|
||||
this.setOverStandard("否");
|
||||
this.setOverStandardReason("");
|
||||
});
|
||||
return this;
|
||||
}
|
||||
|
||||
public OrderFlightRecord loadComplianceInfoNot() {
|
||||
this.setOverStandard("否");
|
||||
this.setOverStandardReason("");
|
||||
return this;
|
||||
}
|
||||
|
||||
|
||||
// 加载未预订最低价原因
|
||||
public OrderFlightRecord loadNotLowReason(String notLowReason) {
|
||||
|
@ -238,17 +229,15 @@ public class OrderFlightRecord extends OrderBaseRecord {
|
|||
|
||||
// 加载关联订单信息
|
||||
public OrderFlightRecord loadRelatedOrderInfo(Long orderDetailId,
|
||||
String detailId,
|
||||
String receiptsNum,
|
||||
String receiptsNumOrigin,
|
||||
String parentOrderNo,
|
||||
String originalOrderNo) {
|
||||
String detailId,
|
||||
String receiptsNum,
|
||||
String parentOrderNo,
|
||||
String originalOrderNo) {
|
||||
this.setOrderDetailId(orderDetailId);
|
||||
this.setDetailId(detailId);
|
||||
this.setReceiptsNum(receiptsNum);
|
||||
this.setParentOrderNo(parentOrderNo);
|
||||
this.setOriginalOrderNo(originalOrderNo);
|
||||
this.setReceiptsNumOrigin(receiptsNumOrigin);
|
||||
return this;
|
||||
}
|
||||
}
|
|
@ -8,8 +8,6 @@ import lombok.experimental.Accessors;
|
|||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
import java.util.Optional;
|
||||
|
||||
@Data
|
||||
@Table("order_hotel_record")
|
||||
@NoArgsConstructor
|
||||
|
@ -32,7 +30,7 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
private String originalOrderNo; // 原始订单号
|
||||
private String brandGroup; // 酒店品牌集团
|
||||
private String brandName; // 酒店品牌
|
||||
private String overStandard; // 是否违规(超标): 0否 1是
|
||||
private int overStandard; // 是否违规(超标): 0否 1是
|
||||
private String overStandardReason; // 违规原因(超标原因)
|
||||
private String receiptsNum; // 关联申请单号
|
||||
private String bookingName; // 预订人姓名
|
||||
|
@ -47,7 +45,7 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
private String hotelAddress; // 酒店地址
|
||||
private String hotelName; // 酒店名称
|
||||
private String includeAmount; // 含早情况:XX份
|
||||
private String isAgreement; // 是否协议酒店:0否1是
|
||||
private int isAgreement; // 是否协议酒店:0否1是
|
||||
private int paymentType; // 付款方式: 0-公司统付 1-个人付 2-混付
|
||||
private String orderAmount; // 订单总额
|
||||
private String companyAmount; // 企业统付总额
|
||||
|
@ -78,7 +76,7 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
private String payAmount; // 支付总金额
|
||||
private String orderStatus;
|
||||
private String createTime;
|
||||
private String receiptsNumOrigin;//支付总金额
|
||||
|
||||
// 加载基础订单信息
|
||||
public OrderHotelRecord loadBasicOrderInfo(String orderNo,
|
||||
String orderStatus,
|
||||
|
@ -143,10 +141,10 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
|
||||
// 加载支付和服务费信息
|
||||
public OrderHotelRecord loadPaymentInfo(Integer paymentType,
|
||||
String unifiedPayAmt,
|
||||
String personalPayAmt,
|
||||
String companyAmount,
|
||||
String personalAmount) {
|
||||
String unifiedPayAmt,
|
||||
String personalPayAmt,
|
||||
String companyAmount,
|
||||
String personalAmount) {
|
||||
this.setCompanyAmount(companyAmount);
|
||||
this.setPersonalAmount(personalAmount);
|
||||
this.setPaymentType(paymentType);
|
||||
|
@ -170,15 +168,12 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
}
|
||||
|
||||
// 加载违规信息
|
||||
public OrderHotelRecord loadComplianceInfo(Optional<OrderDetail> orderDetail) {
|
||||
orderDetail.ifPresentOrElse(it -> it.getETAEvent().ifPresentOrElse(orderEvent -> {
|
||||
this.setOverStandard("是");
|
||||
this.setOverStandardReason(orderEvent.getExtension());
|
||||
public OrderHotelRecord loadComplianceInfo(OrderDetail orderDetail) {
|
||||
orderDetail.getETAEvent().ifPresentOrElse(it -> {
|
||||
this.setOverStandard(1);
|
||||
this.setOverStandardReason(it.getExtension());
|
||||
}, () -> {
|
||||
this.setOverStandard("否");
|
||||
this.setOverStandardReason("");
|
||||
}), () -> {
|
||||
this.setOverStandard("否");
|
||||
this.setOverStandard(0);
|
||||
this.setOverStandardReason("");
|
||||
});
|
||||
return this;
|
||||
|
@ -198,7 +193,6 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
public OrderHotelRecord loadOrderNoInfo(Long orderDetailId,
|
||||
String detailId,
|
||||
String receiptsNum,
|
||||
String receiptsNumOrigin,
|
||||
String parentOrderNo,
|
||||
String originalOrderNo) {
|
||||
this.setOrderDetailId(orderDetailId);
|
||||
|
@ -206,13 +200,12 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
this.setReceiptsNum(receiptsNum);
|
||||
this.setParentOrderNo(parentOrderNo);
|
||||
this.setOriginalOrderNo(originalOrderNo);
|
||||
this.setReceiptsNumOrigin(receiptsNumOrigin);
|
||||
return this;
|
||||
}
|
||||
|
||||
// 加载房间和早餐信息
|
||||
public OrderHotelRecord loadRoomAndBreakfastInfo(String includeAmount,
|
||||
String isAgreement,
|
||||
int isAgreement,
|
||||
int roomNightCount,
|
||||
int nightCount,
|
||||
String roomPrice,
|
||||
|
@ -227,11 +220,8 @@ public class OrderHotelRecord extends OrderBaseRecord {
|
|||
}
|
||||
|
||||
// 加载发票和费用信息
|
||||
public OrderHotelRecord loadInvoiceAndFeeInfo(String invoiceType,
|
||||
String invoiceFee,
|
||||
String custodayFee,
|
||||
String noTaxCusFee,
|
||||
String taxCusFee) {
|
||||
public OrderHotelRecord loadInvoiceAndFeeInfo(String invoiceType, String invoiceFee, String custodayFee,
|
||||
String noTaxCusFee, String taxCusFee) {
|
||||
this.setInvoiceType(invoiceType);
|
||||
this.setInvoiceFee(invoiceFee);
|
||||
this.setCustodayFee(custodayFee);
|
||||
|
|
|
@ -71,7 +71,7 @@ public class OrderTrainRecord extends OrderBaseRecord{
|
|||
private String passportType; // 乘客证件类型
|
||||
private String trainTime; // 发车时间 yyyy-MM-dd HH:mm:ss
|
||||
private String yxId; // 影像比对ID
|
||||
private String receiptsNumOrigin;//原差旅申请单单号
|
||||
|
||||
// 加载基础订单信息
|
||||
public OrderTrainRecord loadBasicOrderInfo(Long id, String orderNo, String orderStatus, String createTime) {
|
||||
this.setId(id);
|
||||
|
|
|
@ -52,7 +52,7 @@ public class LyOrderCarRecord implements Serializable {
|
|||
private String subjectRemark;
|
||||
|
||||
@MappedCollection(idColumn = "ly_record_id", keyColumn = "ly_record_key")
|
||||
private List<TripSubmitItemCarList> tripSubmitItemList;
|
||||
private List<TripSubmitItemList> tripSubmitItemList;
|
||||
|
||||
//出行人职级
|
||||
private String passengerPositionLevelName;
|
||||
|
|
|
@ -92,7 +92,7 @@ public class LyOrderFlightRecord implements Serializable {
|
|||
private String overStandardStatus;
|
||||
|
||||
@MappedCollection(idColumn = "ly_record_id", keyColumn = "ly_record_key")
|
||||
private List<TripSubmitItemFlightList> tripSubmitItemList;
|
||||
private List<TripSubmitItemList> tripSubmitItemList;
|
||||
|
||||
//出行人职级
|
||||
private String passengerPositionLevelName;
|
||||
|
|
|
@ -64,7 +64,7 @@ public class LyOrderHotelRecord implements Serializable {
|
|||
private String overStandardStatus;
|
||||
|
||||
@MappedCollection(idColumn = "ly_record_id", keyColumn = "ly_record_key")
|
||||
private List<TripSubmitItemHotelList> tripSubmitItemList;
|
||||
private List<TripSubmitItemList> tripSubmitItemList;
|
||||
|
||||
//出行人职级
|
||||
private String passengerPositionLevelName;
|
||||
|
|
|
@ -58,7 +58,7 @@ public class LyOrderTrainRecord implements Serializable {
|
|||
private String overStandardStatus;
|
||||
|
||||
@MappedCollection(idColumn = "ly_record_id", keyColumn = "ly_record_key")
|
||||
private List<TripSubmitItemTrainList> tripSubmitItemList;
|
||||
private List<TripSubmitItemList> tripSubmitItemList;
|
||||
|
||||
//出行人职级
|
||||
private String passengerPositionLevelName;
|
||||
|
|
|
@ -1,45 +0,0 @@
|
|||
package com.chint.domain.aggregates.order.order_record.ly_order_record;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 行程提交项目(TripSubmitItem)表实体类
|
||||
*
|
||||
* @author dengweichao
|
||||
* @since 2024-03-27 10:17:58
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Table("trip_submit_item_car_list")
|
||||
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||
public class TripSubmitItemCarList implements Serializable {
|
||||
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
@Id
|
||||
private Integer id;
|
||||
|
||||
//父id
|
||||
private Integer lyRecordId;
|
||||
|
||||
private Integer lyRecordKey;
|
||||
//编码
|
||||
private String code;
|
||||
//名称
|
||||
private String name;
|
||||
//内容
|
||||
private String content;
|
||||
|
||||
}
|
|
@ -1,46 +0,0 @@
|
|||
package com.chint.domain.aggregates.order.order_record.ly_order_record;
|
||||
|
||||
|
||||
import java.io.Serial;
|
||||
import java.io.Serializable;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
/**
|
||||
* 行程提交项目(TripSubmitItem)表实体类
|
||||
*
|
||||
* @author dengweichao
|
||||
* @since 2024-03-27 10:17:58
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Table("trip_submit_item_flight_list")
|
||||
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||
public class TripSubmitItemFlightList implements Serializable {
|
||||
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
@Id
|
||||
private Integer id;
|
||||
|
||||
//父id
|
||||
private Integer lyRecordId;
|
||||
|
||||
private Integer lyRecordKey;
|
||||
//编码
|
||||
private String code;
|
||||
//名称
|
||||
private String name;
|
||||
//内容
|
||||
private String content;
|
||||
|
||||
}
|
|
@ -1,45 +0,0 @@
|
|||
package com.chint.domain.aggregates.order.order_record.ly_order_record;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 行程提交项目(TripSubmitItem)表实体类
|
||||
*
|
||||
* @author dengweichao
|
||||
* @since 2024-03-27 10:17:58
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Table("trip_submit_item_hotel_list")
|
||||
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||
public class TripSubmitItemHotelList implements Serializable {
|
||||
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
@Id
|
||||
private Integer id;
|
||||
|
||||
//父id
|
||||
private Integer lyRecordId;
|
||||
|
||||
private Integer lyRecordKey;
|
||||
//编码
|
||||
private String code;
|
||||
//名称
|
||||
private String name;
|
||||
//内容
|
||||
private String content;
|
||||
|
||||
}
|
|
@ -1,18 +1,19 @@
|
|||
package com.chint.domain.aggregates.order.order_record.ly_order_record;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.io.Serializable;
|
||||
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
/**
|
||||
* 行程提交项目
|
||||
* 行程提交项目(TripSubmitItem)表实体类
|
||||
*
|
||||
* @author dengweichao
|
||||
* @since 2024-03-27 10:17:58
|
||||
|
@ -20,15 +21,20 @@ import java.io.Serializable;
|
|||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Table("trip_submit_item_list")
|
||||
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||
public class TripSubmitItemList implements Serializable {
|
||||
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
@Id
|
||||
private Integer id;
|
||||
|
||||
//父id
|
||||
private Integer lyRecordId;
|
||||
|
||||
|
||||
private Integer lyRecordKey;
|
||||
//编码
|
||||
private String code;
|
||||
|
|
|
@ -1,45 +0,0 @@
|
|||
package com.chint.domain.aggregates.order.order_record.ly_order_record;
|
||||
|
||||
|
||||
import com.fasterxml.jackson.annotation.JsonInclude;
|
||||
import lombok.AllArgsConstructor;
|
||||
import lombok.Data;
|
||||
import lombok.NoArgsConstructor;
|
||||
import org.springframework.data.annotation.Id;
|
||||
import org.springframework.data.relational.core.mapping.Table;
|
||||
|
||||
import java.io.Serial;
|
||||
import java.io.Serializable;
|
||||
|
||||
/**
|
||||
* 行程提交项目(TripSubmitItem)表实体类
|
||||
*
|
||||
* @author dengweichao
|
||||
* @since 2024-03-27 10:17:58
|
||||
*/
|
||||
@Data
|
||||
@AllArgsConstructor
|
||||
@NoArgsConstructor
|
||||
@Table("trip_submit_item_train_list")
|
||||
@JsonInclude(JsonInclude.Include.NON_NULL)
|
||||
public class TripSubmitItemTrainList implements Serializable {
|
||||
|
||||
@Serial
|
||||
private static final long serialVersionUID = 1L;
|
||||
|
||||
|
||||
@Id
|
||||
private Integer id;
|
||||
|
||||
//父id
|
||||
private Integer lyRecordId;
|
||||
|
||||
private Integer lyRecordKey;
|
||||
//编码
|
||||
private String code;
|
||||
//名称
|
||||
private String name;
|
||||
//内容
|
||||
private String content;
|
||||
|
||||
}
|
|
@ -6,7 +6,6 @@ import com.chint.domain.aggregates.system.FsscSystem;
|
|||
import com.chint.domain.value_object.UserLoginParam;
|
||||
import com.chint.infrastructure.constant.AuthMessageConstant;
|
||||
import com.chint.interfaces.rest.base.PostRequest;
|
||||
import com.chint.interfaces.rest.user.PushUser;
|
||||
import com.google.gson.Gson;
|
||||
import com.google.gson.reflect.TypeToken;
|
||||
import lombok.AllArgsConstructor;
|
||||
|
@ -72,7 +71,6 @@ public class User implements Serializable {
|
|||
this.employeeNo = employeeNo;
|
||||
}
|
||||
|
||||
|
||||
// public User addDeptInfo(){
|
||||
//
|
||||
// }
|
||||
|
@ -108,8 +106,6 @@ public class User implements Serializable {
|
|||
this.companyCode = companyCode;
|
||||
}
|
||||
|
||||
|
||||
|
||||
public User addFssc(String CompanyName, String sysCode) {
|
||||
FsscSystem fsscSystem = new FsscSystem(CompanyName, sysCode);
|
||||
this.addFsscSystemToList(fsscSystem);
|
||||
|
@ -188,9 +184,4 @@ public class User implements Serializable {
|
|||
public String generateXNFsscUrlPath() {
|
||||
return XN_FSSC_REDIRECT_PATH_APPROVAL_ONE + employeeNo + FSSC_REDIRECT_PATH_APPROVAL_TWO;
|
||||
}
|
||||
|
||||
// public User startAddDept(){
|
||||
//
|
||||
//
|
||||
// }
|
||||
}
|
|
@ -33,7 +33,4 @@ public class UserDepartmentInfo implements Serializable {
|
|||
private String departmentCodeSeven;
|
||||
private String departmentNameSeven;
|
||||
private Integer ifPrimary;
|
||||
|
||||
// Builder static inner class
|
||||
|
||||
}
|
||||
|
|
|
@ -146,47 +146,29 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
}
|
||||
|
||||
// 加载超标信息, 加载订单关联信息 , 加载订单状态 ,单号,创建时间等信息
|
||||
// 当测试环境没有行程规划单 , 只能去回传的差旅申请单
|
||||
String orderNo = getOrderNoForCTrip(cTripCarRecord.getRouteOrderNo());
|
||||
orderDetail.ifPresentOrElse(it -> {
|
||||
CarOrderDetail carOrderDetail = it.getCarOrderDetail();
|
||||
orderCarRecord.loadComplianceInfo(it)
|
||||
.loadRelatedOrderInfo(it.getOrderId(),
|
||||
cTripCarRecord.getRecordId(),
|
||||
byOrderNo.isPresent() ? byOrderNo.get().getApproveOrderNo().getActualOrderNo() : orderNo, //兼容测试环境和正式环境的数据
|
||||
carOrderDetail.getReceiptsNum(),
|
||||
carOrderDetail.getParentOrderNo(),
|
||||
carOrderDetail.getOriginalOrderNo())
|
||||
.loadBasicOrderInfo(carOrderDetail.getOrderNo(),
|
||||
carOrderDetail.getOrderStatus(),
|
||||
carOrderDetail.getCreateTime());
|
||||
}, () -> orderCarRecord.loadComplianceInfoNot()
|
||||
.loadRelatedOrderInfo(cTripCarRecordBase.getOrderId(),
|
||||
}, () -> orderCarRecord.loadRelatedOrderInfo(cTripCarRecordBase.getOrderId(),
|
||||
cTripCarRecord.getRecordId(),
|
||||
orderNo,
|
||||
cTripCarRecord.getRouteOrderNo(),
|
||||
String.valueOf(cTripCarRecordBase.getOrderId()),
|
||||
String.valueOf(cTripCarRecordBase.getOrderId()))
|
||||
.loadBasicOrderInfo(String.valueOf(cTripCarRecordBase.getOrderId()),
|
||||
.loadBasicOrderInfo( String.valueOf(cTripCarRecordBase.getOrderId()),
|
||||
"",
|
||||
cTripCarRecordBase.getCreateTime()));
|
||||
|
||||
return orderCarRecord;
|
||||
}
|
||||
|
||||
|
||||
private String getOrderNoForCTrip(String inputOrderNo) {
|
||||
// 当测试环境没有行程规划单 , 只能去回传的差旅申请单
|
||||
String orderNo;
|
||||
if (inputOrderNo.contains("-")) {
|
||||
String[] split = inputOrderNo.split("-");
|
||||
orderNo = split[1];
|
||||
} else {
|
||||
orderNo = inputOrderNo;
|
||||
}
|
||||
return orderNo;
|
||||
}
|
||||
|
||||
@Override
|
||||
public OrderTrainRecord createTrainOrderRecord(Object orderTrainRecordData) {
|
||||
|
||||
|
@ -269,8 +251,7 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
String batchNo = cTripFlightRecordBase.getBatchStartDate().substring(0, 6);
|
||||
orderFlightRecord.loadFinancialAndPricingInfo(batchNo,
|
||||
cTripFlightRecordBase.getSubAccCheckBatchNo(),
|
||||
String.valueOf(cTripFlightRecordBase.getAmount()),
|
||||
String.valueOf(cTripFlightRecordBase.getRealAmountWithPostServiceFee()),
|
||||
String.valueOf(cTripFlightRecordBase.getPrice()),
|
||||
String.valueOf(cTripFlightInfo.getEClassStandardPrice()),
|
||||
String.valueOf(cTripFlightInfo.getLowPrice()),
|
||||
String.valueOf(cTripFlightInfo.getLowPrice()));
|
||||
|
@ -286,7 +267,7 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
orderFlightRecord.loadExtraFeeInfo(String.valueOf(cTripFlightRecordBase.getPostServiceFee()),
|
||||
String.valueOf(cTripFlightRecordBase.getRebookQueryFee()),
|
||||
String.valueOf(cTripFlightRecordBase.getRefund()),
|
||||
cTripFlightRecordBase.getOrderDetailType().equals("改签") ? String.valueOf(cTripFlightRecordBase.getAmount()) : KEEP_TWO_DECIMAL_ZERO,
|
||||
String.valueOf(cTripFlightRecordBase.getAmount()),
|
||||
String.valueOf(cTripFlightRecordBase.getSettItineraryFee()));
|
||||
|
||||
// 加载来源
|
||||
|
@ -307,7 +288,6 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
cTripFlightBaseInfo.getDept3());
|
||||
|
||||
// 加载关联票价原因
|
||||
String orderNo = getOrderNoForCTrip(cTripFlightRecord.getRouteOrderNo());
|
||||
orderDetail.ifPresentOrElse(it -> {
|
||||
FlightOrderDetail flightOrderDetail = it.getFlightOrderDetail();
|
||||
orderFlightRecord.loadComplianceInfo(it)
|
||||
|
@ -316,14 +296,11 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
cTripFlightRecordBase.getCreateTime())
|
||||
.loadRelatedOrderInfo(cTripFlightRecordBase.getOrderId(),
|
||||
String.valueOf(cTripFlightRecordBase.getRecordId()),
|
||||
byOrderNo.isPresent() ? byOrderNo.get().getApproveOrderNo().getActualOrderNo() : orderNo, //兼容测试环境和正式环境的数据
|
||||
flightOrderDetail.getReceiptsNum(),
|
||||
flightOrderDetail.getParentOrderNo(),
|
||||
it.getOrderNo());
|
||||
}, () -> orderFlightRecord.loadComplianceInfoNot()
|
||||
.loadRelatedOrderInfo(cTripFlightRecordBase.getOrderId(), //兼容测试环境没有申请单的情况
|
||||
}, () -> orderFlightRecord.loadRelatedOrderInfo(cTripFlightRecordBase.getOrderId(), //兼容测试环境没有申请单的情况
|
||||
String.valueOf(cTripFlightRecordBase.getRecordId()),
|
||||
orderNo,
|
||||
cTripFlightBaseInfo.getJourneyID(),
|
||||
String.valueOf(cTripFlightRecordBase.getOrderId()),
|
||||
String.valueOf(cTripFlightRecordBase.getOrderId()))
|
||||
|
@ -395,12 +372,12 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
// 加载房间和早餐信息 , 含早分数先为空
|
||||
String isAgreement;
|
||||
if (cTripHotelRecordBase.getOrderType().equals(4) || cTripHotelRecordBase.getOrderType().equals(6)) {
|
||||
isAgreement = "是";
|
||||
isAgreement = "1";
|
||||
} else {
|
||||
isAgreement = "否";
|
||||
isAgreement = "0";
|
||||
}
|
||||
orderHotelRecord.loadRoomAndBreakfastInfo("",
|
||||
isAgreement,
|
||||
Integer.parseInt(isAgreement),
|
||||
cTripHotelRecordBase.getQuantity(),
|
||||
cTripHotelRecordBase.getQuantity(),
|
||||
String.valueOf(cTripHotelRecordBase.getPrice()),
|
||||
|
@ -433,23 +410,20 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
}
|
||||
orderHotelRecord.loadSourceInfo(sourceInfo);
|
||||
|
||||
String orderNo = getOrderNoForCTrip(cTripHotelRecord.getRouteOrderNo());
|
||||
|
||||
orderDetailOptional.ifPresentOrElse(it -> {
|
||||
orderHotelRecord.loadComplianceInfo(Optional.of(it)); // 加载违规信息
|
||||
orderHotelRecord.loadComplianceInfo(it); // 加载违规信息
|
||||
HotelOrderDetail hotelOrderDetail = it.getHotelOrderDetail();
|
||||
orderHotelRecord.loadOrderNoInfo(it.getOrderId(), // 加载订单关联号信息
|
||||
cTripHotelRecord.getRecordId(),
|
||||
byOrderNo.isPresent() ? byOrderNo.get().getApproveOrderNo().getActualOrderNo() : orderNo, //兼容测试环境和正式环境的数据
|
||||
hotelOrderDetail.getReceiptsNum(),
|
||||
hotelOrderDetail.getOrderNo(),
|
||||
hotelOrderDetail.getOrderNo());
|
||||
orderHotelRecord.loadBasicOrderInfo(hotelOrderDetail.getOrderNo(), // 加载基础订单信息
|
||||
hotelOrderDetail.getOrderStatus(),
|
||||
cTripHotelRecordBase.getCreateTime());
|
||||
}, () -> orderHotelRecord.loadComplianceInfo(Optional.empty())
|
||||
.loadOrderNoInfo(cTripHotelRecordBase.getOrderId(), //兼容测试环境不存在行程规划单的情况 // 加载订单关联号信息
|
||||
}, () -> orderHotelRecord.loadOrderNoInfo(cTripHotelRecordBase.getOrderId(), //兼容测试环境不存在行程规划单的情况 // 加载订单关联号信息
|
||||
cTripHotelRecord.getRecordId(),
|
||||
orderNo,
|
||||
cTripHotelRecord.getRouteOrderNo(),
|
||||
String.valueOf(cTripHotelRecordBase.getOrderId()),
|
||||
String.valueOf(cTripHotelRecordBase.getOrderId()))
|
||||
|
@ -458,8 +432,8 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
cTripHotelRecordBase.getCreateTime()));
|
||||
|
||||
// 加载财务信息
|
||||
orderHotelRecord.loadFinancialInfo(cTripHotelRecordBase.getBatchStartDate().substring(0, 6),
|
||||
cTripHotelRecordBase.getSubAccCheckBatchNo(),
|
||||
orderHotelRecord.loadFinancialInfo(cTripHotelRecordBase.getSubAccCheckBatchNo(),
|
||||
cTripHotelRecordBase.getBatchStartDate().substring(0, 6),
|
||||
String.valueOf(cTripHotelRecordBase.getAmount()),
|
||||
"",
|
||||
cTripHotelRecordBase.getPaidAmount());
|
||||
|
@ -485,8 +459,8 @@ public class CTripOrderRecordExtensionFactory implements OrderRecordExtensionFac
|
|||
// 加载预订人和入住人信息
|
||||
orderHotelRecord.loadBookerAndGuestInfo(cTripHotelOrderDetail.getEmployeeID(),
|
||||
cTripHotelOrderDetail.getEmployeeName(),
|
||||
cTripHotelOrderDetail.getEmployeeName(),
|
||||
cTripHotelOrderDetail.getEmployeeID());
|
||||
cTripHotelOrderDetail.getEmployeeID(),
|
||||
cTripHotelOrderDetail.getEmployeeName());
|
||||
|
||||
// 加载组织架构
|
||||
orderHotelRecord.loadOrganizationalAndProjectInfo(cTripHotelOrderDetail.getDept1(),
|
||||
|
|
|
@ -1,27 +1,25 @@
|
|||
package com.chint.domain.factoriy.order_record;
|
||||
|
||||
import com.chint.domain.aggregates.order.*;
|
||||
import com.chint.domain.aggregates.order.OrderDetail;
|
||||
import com.chint.domain.aggregates.order.RouteOrder;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderCarRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderFlightRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderHotelRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderTrainRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.*;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.LyOrderCarRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.LyOrderFlightRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.LyOrderHotelRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.LyOrderTrainRecord;
|
||||
import com.chint.domain.repository.UserRepository;
|
||||
import com.chint.domain.service.OrderDetailDomainService;
|
||||
import com.chint.infrastructure.repository.jdbc.*;
|
||||
import com.chint.infrastructure.util.BeanCopyUtils;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.springframework.beans.BeanUtils;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import java.math.BigDecimal;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.concurrent.atomic.AtomicReference;
|
||||
import java.util.function.Consumer;
|
||||
|
||||
import static com.chint.infrastructure.constant.BelongSystemConstant.TRAVAL_SYS_TYPE_LY;
|
||||
import static com.chint.infrastructure.constant.OrderRecordConstant.*;
|
||||
|
||||
/**
|
||||
* 同程数据转换
|
||||
|
@ -39,9 +37,6 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
@Autowired
|
||||
private OrderRecordFactory orderRecordFactory;
|
||||
|
||||
@Autowired
|
||||
private JdbcOrderTravelRepository orderTravelRepository;
|
||||
|
||||
@Override
|
||||
public OrderFlightRecord createFlightOrderRecord(Object orderFlightRecordData) {
|
||||
OrderFlightRecord orderFlightRecord = new OrderFlightRecord();
|
||||
|
@ -82,47 +77,35 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
|
||||
private void createFlightOrder(OrderFlightRecord orderFlightRecord, LyOrderFlightRecord lyOrderFlightRecord) {
|
||||
String orderSerialNo = lyOrderFlightRecord.getOrderSerialNo();//订单号
|
||||
AtomicReference<OrderDetail> orderDetailRef = new AtomicReference<>();
|
||||
AtomicReference<RouteOrder> routeOrderRef = new AtomicReference<>();
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo, orderDetailRef::set, routeOrderRef::set);
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo);
|
||||
BeanUtils.copyProperties(orderRecordBasic, orderFlightRecord);
|
||||
OrderDetail orderDetail = orderDetailRef.get();//获取订单明细
|
||||
RouteOrder routeOrder = routeOrderRef.get();//获取财务共享订单
|
||||
FlightOrderDetail flightOrderDetail = orderDetail.getFlightOrderDetail() == null ? new FlightOrderDetail() : orderDetail.getFlightOrderDetail();//机票订单明细
|
||||
orderFlightRecord.setOrderDetailId(orderDetail.getOrderId() == null ? -1L : orderDetail.getOrderId());
|
||||
//公共字段校验
|
||||
flightFieldCheck(orderFlightRecord, lyOrderFlightRecord);
|
||||
orderFlightRecord.setDetailId(lyOrderFlightRecord.getBillOrderNo())//防重标识
|
||||
.setTicketClerk(lyOrderFlightRecord.getReserveManName())//票务员
|
||||
.setAccountPeriod(lyOrderFlightRecord.getStatementCode())//账期号
|
||||
.setBillNo(lyOrderFlightRecord.getBillOrderNo())//账单号
|
||||
.setOrderNo(lyOrderFlightRecord.getOrderSerialNo())//订单号
|
||||
.setParentOrderNo(flightOrderDetail.getParentOrderNo())//父级订单号
|
||||
.setParentOrderNo("")//父级订单号
|
||||
.setOriginalOrderNo(lyOrderFlightRecord.getOriginOrderSerialNo())//原始订单号
|
||||
.setTicketNo(lyOrderFlightRecord.getTicketNo());//票号
|
||||
//行程单号
|
||||
List<OrderTravel> byOrderNo = orderTravelRepository.findByOrderNo(orderSerialNo);
|
||||
String travelNo = byOrderNo.isEmpty() ? "" : byOrderNo.get(0).getTravelNo();
|
||||
orderFlightRecord.setScheduleNum(travelNo);//行程单号
|
||||
orderFlightRecord.setReceiptsNum(getReceiptsNum(lyOrderFlightRecord.getOutApplayOrderNo(), routeOrder))//关联申请单号
|
||||
.setReceiptsNumOrigin(lyOrderFlightRecord.getOutApplayOrderNo())//原关联申请单号
|
||||
.setTicketNo(lyOrderFlightRecord.getTicketNo())//票号
|
||||
.setScheduleNum("")//行程单号
|
||||
.setReceiptsNum(lyOrderFlightRecord.getOutApplayOrderNo())//关联申请单号
|
||||
.setUserName(lyOrderFlightRecord.getPassengerName())//出行人姓名
|
||||
.setUserCode(lyOrderFlightRecord.getPassengerExternalId())//出行人编码
|
||||
.setOverStandard("是".equals(lyOrderFlightRecord.getOverStandardStatus()) ? "1" : "0")//"是否违规(超标):0否 ,1是"
|
||||
.setOverStandardReason(lyOrderFlightRecord.getViolationReason())//违规原因(超标原因)
|
||||
.setStartAirportName(flightOrderDetail.getStartAirportName())//起飞机场名称
|
||||
.setStartCityCode(flightOrderDetail.getStartCityCode())//起飞城市编码
|
||||
.setStartCityName(flightOrderDetail.getStartCityName())//起飞城市名称
|
||||
.setStartAirportName("")//起飞机场名称
|
||||
.setStartCityCode("")//起飞城市编码
|
||||
.setStartCityName("")//起飞城市名称
|
||||
.setStartTime(lyOrderFlightRecord.getPlanBeginDate())//起飞时间 yyyy-MM-dd HH:mm:ss
|
||||
.setEndAirportCode(flightOrderDetail.getEndAirportCode())//到达机场三字码
|
||||
.setEndAirportName(flightOrderDetail.getEndAirportName())//到达机场名称
|
||||
.setEndCityCode(flightOrderDetail.getEndCityCode())//到达城市编码
|
||||
.setEndCityName(flightOrderDetail.getEndCityName())//到达城市名称
|
||||
.setEndTerminal(flightOrderDetail.getEndTerminal())//到达航站楼
|
||||
.setEndAirportCode("")//到达机场三字码
|
||||
.setEndAirportName("")//到达机场名称
|
||||
.setEndCityCode("")//到达城市编码
|
||||
.setEndCityName("")//到达城市名称
|
||||
.setEndTerminal("")//到达航站楼
|
||||
.setEndTime(lyOrderFlightRecord.getPlanEndDate())//到达时间 yyyy-MM-dd HH:mm:ss
|
||||
.setFlightCompName(lyOrderFlightRecord.getAirlineCompanyName())//航空公司名称
|
||||
.setFlightLowestPrice(String.valueOf(lyOrderFlightRecord.getFligthMinPrice()))//航班最低价
|
||||
.setFlightNum(lyOrderFlightRecord.getFligthNo())//航班号
|
||||
.setFlightNum(lyOrderFlightRecord.getFligthNo())//
|
||||
.setOrderAmount(String.valueOf(lyOrderFlightRecord.getToBePayAmount())) //结算总额
|
||||
.setFacePrice(String.valueOf(lyOrderFlightRecord.getTicketOutAmount())) //票面价
|
||||
.setNoTaxAmt(String.valueOf(BigDecimal.valueOf(lyOrderFlightRecord.getTicketTotalAmount() == null ? 0 : lyOrderFlightRecord.getTicketTotalAmount())
|
||||
|
@ -142,32 +125,24 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setSeatPoint(lyOrderFlightRecord.getSeatClass())//舱位
|
||||
.setSeatPointName(lyOrderFlightRecord.getSeatClass())//舱位名称
|
||||
.setUseStatus(lyOrderFlightRecord.getTicketStatus()) //机票使用情况
|
||||
.setOrderSource(lyOrderFlightRecord.getBookingPlat()) //预订来源:线上/线下
|
||||
.setOrderSource("") //预订来源:线上/线下
|
||||
.setNotLowReason("正泰机票无超标") //未预订最低价原因
|
||||
.setBookOrgCode1(lyOrderFlightRecord.getPassengerDepartment()) //出行人组织架构信息1
|
||||
.setBookOrgCode2(lyOrderFlightRecord.getPassengerDepartment()) //出行人组织架构信息2
|
||||
.setBookOrgCode3(lyOrderFlightRecord.getPassengerDepartment()) //出行人组织架构信息3
|
||||
.setOfflineCcomyCode(lyOrderFlightRecord.getPassengerCostCenter()) //成本中心
|
||||
.setOrderStatus("") //结算状态
|
||||
/* .setExpenseOrderAmount("") //订单金额
|
||||
/* .setOrderStatus() //结算状态
|
||||
.setExpenseOrderAmount() //订单金额
|
||||
.setSettleOrderFlag() //订单对账状态
|
||||
.setPayAmount() //支付金额*/
|
||||
.setPayAmount() //支付金额
|
||||
*/
|
||||
;
|
||||
}
|
||||
|
||||
|
||||
private void createHotelOrder(OrderHotelRecord orderHotelRecord, LyOrderHotelRecord lyOrderHotelRecord) {
|
||||
String orderSerialNo = lyOrderHotelRecord.getOrderSerialNo();//订单号
|
||||
AtomicReference<OrderDetail> orderDetailRef = new AtomicReference<>();
|
||||
AtomicReference<RouteOrder> routeOrderRef = new AtomicReference<>();
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo, orderDetailRef::set, routeOrderRef::set);
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo);
|
||||
BeanUtils.copyProperties(orderRecordBasic, orderHotelRecord);
|
||||
OrderDetail orderDetail = orderDetailRef.get();//订单明细
|
||||
RouteOrder routeOrder = routeOrderRef.get();//财务共享订单数据
|
||||
HotelOrderDetail hotelOrderDetail = orderDetail.getHotelOrderDetail() == null ? new HotelOrderDetail() : orderDetail.getHotelOrderDetail();//酒店订单明细
|
||||
orderHotelRecord.setOrderDetailId(orderDetail.getOrderId() == null ? -1L : orderDetail.getOrderId());//订单明细id
|
||||
//公共字段校验
|
||||
hotelFieldCheck(orderHotelRecord, lyOrderHotelRecord);
|
||||
orderHotelRecord.setDetailId(lyOrderHotelRecord.getBillOrderNo())//防重标识
|
||||
.setTicketClerk(lyOrderHotelRecord.getReserveManName()) //票务员
|
||||
.setAccountPeriod(lyOrderHotelRecord.getStatementCode()) //账期号
|
||||
|
@ -177,11 +152,9 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setOriginalOrderNo(lyOrderHotelRecord.getOriginOrderSerialNo())//原始订单号
|
||||
.setBrandGroup("") //酒店品牌集团
|
||||
.setBrandName("") //酒店品牌
|
||||
.setOverStandard("是".equals(lyOrderHotelRecord.getOverStandardStatus()) ? "1" : "0") //"是否违规(超标) 0否,1是"
|
||||
.setOverStandardReason(lyOrderHotelRecord.getViolationReason());//违规原因(超标原因)
|
||||
|
||||
orderHotelRecord.setReceiptsNum(getReceiptsNum(lyOrderHotelRecord.getOutApplayOrderNo(), routeOrder))//关联申请单号
|
||||
.setReceiptsNumOrigin(lyOrderHotelRecord.getOutApplayOrderNo()) //原关联申请单号
|
||||
.setOverStandard("是".equals(lyOrderHotelRecord.getOverStandardStatus()) ? 1 : 0) //"是否违规(超标) 0否,1是"
|
||||
.setOverStandardReason(lyOrderHotelRecord.getViolationReason()) //违规原因(超标原因)
|
||||
.setReceiptsNum(lyOrderHotelRecord.getOutApplayOrderNo()) //关联申请单号
|
||||
.setUserName(lyOrderHotelRecord.getPassengerName()) //入住人姓名
|
||||
.setUserCode(lyOrderHotelRecord.getPassengerNo()) //入住人编码
|
||||
.setCheckInCity(lyOrderHotelRecord.getCityName()) //入住城市
|
||||
|
@ -189,10 +162,10 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setCountry(lyOrderHotelRecord.getCountryName()) //国家
|
||||
.setCustomerServiceName("") //客服处理人
|
||||
.setDepartureDate(lyOrderHotelRecord.getLeaveTime()) //离店日期yyyy - MM - dd
|
||||
.setHotelAddress(hotelOrderDetail.getHotelAddress()) //酒店地址
|
||||
.setHotelAddress("") //酒店地址
|
||||
.setHotelName(lyOrderHotelRecord.getHotelName()) //酒店名称
|
||||
.setIncludeAmount("") //含早情况:XX份
|
||||
.setIsAgreement("是".equals(hotelOrderDetail.getAgreementHotel()) ? "1" : "0") //是否协议酒店:0否1是
|
||||
.setIsAgreement(0) //是否协议酒店:0否1是
|
||||
.setPaymentType(getPaymentType(lyOrderHotelRecord.getPayType()))//"付款方式:0-公司统付 1-个人付 2-混付"
|
||||
.setOrderAmount(String.valueOf(lyOrderHotelRecord.getToBePayAmount())) //结算总额
|
||||
.setCompanyAmount(String.valueOf(lyOrderHotelRecord.getToBePayAmount())) //企业统付总额
|
||||
|
@ -200,9 +173,9 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setUnifiedPayAmt(String.valueOf(lyOrderHotelRecord.getServiceAmount())) //统付服务费
|
||||
.setPersonalPayAmt("") //个人服务费
|
||||
.setProvince("") //省份
|
||||
.setRoomCount(Integer.parseInt(StringUtils.isBlank(hotelOrderDetail.getRoomCount()) ? "1" : hotelOrderDetail.getRoomCount())) //房间数
|
||||
.setRoomCount(1) //房间数
|
||||
.setRoomNightCount(lyOrderHotelRecord.getHotelNights()) //夜间数
|
||||
.setNightCount(lyOrderHotelRecord.getHotelNights()) //间夜数
|
||||
.setNightCount(1) //间夜数
|
||||
.setRoomPrice("") //房价(房间单价不包含服务费)
|
||||
.setRoomRate(String.valueOf(lyOrderHotelRecord.getTotalRoomPrice())) //房费(订单总额减总服务费)
|
||||
.setNoTaxAmt("") //不含税价
|
||||
|
@ -213,11 +186,11 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setNoTaxCusFee("") //托管费不含税
|
||||
.setTaxCusFee("") //托管费税费
|
||||
.setRoomTypeName(lyOrderHotelRecord.getBedType()) //房型
|
||||
.setStarRate(hotelOrderDetail.getStarRate()) //星级
|
||||
.setStarRate("") //星级
|
||||
.setOrderSource(lyOrderHotelRecord.getBookingPlat()) //预订来源:线上/线下
|
||||
.setBookOrgCode1(lyOrderHotelRecord.getPassengerDepartment()) //入住人组织架构信息1
|
||||
.setBookOrgCode2(hotelOrderDetail.getBOOK_ORG_STRUCT_2()) //入住人组织架构信息2
|
||||
.setBookOrgCode3(hotelOrderDetail.getBOOK_ORG_STRUCT_3()) //入住人组织架构信息3
|
||||
.setBookOrgCode2("") //入住人组织架构信息2
|
||||
.setBookOrgCode3("") //入住人组织架构信息3
|
||||
.setOfflineCcomyCode(lyOrderHotelRecord.getPassengerCostCenter()) //成本中心
|
||||
/* .setOrderStatus() //结算状态
|
||||
.setExpenseOrderAmount() //订单金额
|
||||
|
@ -229,25 +202,16 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
|
||||
private void createTrainOrder(OrderTrainRecord orderTrainRecord, LyOrderTrainRecord lyOrderTrainRecord) {
|
||||
String orderSerialNo = lyOrderTrainRecord.getOrderSerialNo();//订单号
|
||||
AtomicReference<OrderDetail> orderDetailRef = new AtomicReference<>();
|
||||
AtomicReference<RouteOrder> routeOrderRef = new AtomicReference<>();
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo, orderDetailRef::set, routeOrderRef::set);
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo);
|
||||
BeanUtils.copyProperties(orderRecordBasic, orderTrainRecord);
|
||||
OrderDetail orderDetail = orderDetailRef.get();//订单明细
|
||||
RouteOrder routeOrder = routeOrderRef.get();//财务共享订单数据
|
||||
TrainOrderDetail trainOrderDetail = orderDetail.getTrainOrderDetail() == null ? new TrainOrderDetail() : orderDetail.getTrainOrderDetail();//火车订单明细
|
||||
orderTrainRecord.setOrderDetailId(orderDetail.getOrderId() == null ? -1L : orderDetail.getOrderId());//订单明细id
|
||||
//公共字段校验
|
||||
trainFieldCheck(orderTrainRecord, lyOrderTrainRecord);
|
||||
orderTrainRecord.setDetailId(lyOrderTrainRecord.getBillOrderNo())//防重标识
|
||||
.setTicketClerk(lyOrderTrainRecord.getReserveManName()) //票务员
|
||||
.setAccountPeriod(lyOrderTrainRecord.getStatementCode()) //账期号
|
||||
.setBillNo(lyOrderTrainRecord.getBillOrderNo()) //账单号
|
||||
.setOrderNo(lyOrderTrainRecord.getOrderSerialNo()) //订单号
|
||||
.setParentOrderNo(trainOrderDetail.getParentOrderNo()) //父级订单号
|
||||
.setOriginalOrderNo(lyOrderTrainRecord.getOriginOrderSerialNo());//原始订单号
|
||||
orderTrainRecord.setReceiptsNum(getReceiptsNum(lyOrderTrainRecord.getOutApplayOrderNo(), routeOrder))//关联申请单号
|
||||
.setReceiptsNumOrigin(lyOrderTrainRecord.getOutApplayOrderNo()) //原关联申请单号
|
||||
.setParentOrderNo("") //父级订单号
|
||||
.setOriginalOrderNo(lyOrderTrainRecord.getOriginOrderSerialNo()) //原始订单号
|
||||
.setReceiptsNum(lyOrderTrainRecord.getOutApplayOrderNo()) //关联申请单号
|
||||
.setStartDate(lyOrderTrainRecord.getPlanBeginDate()) //出发日期
|
||||
.setArriveDate(lyOrderTrainRecord.getPlanEndDate()) //到达日期
|
||||
.setOverStandard("是".equals(lyOrderTrainRecord.getOverStandardStatus()) ? "1" : "0") //"是否违规(超标):0否 1是"
|
||||
|
@ -270,15 +234,15 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setToCity(lyOrderTrainRecord.getTripName()) //到达城市
|
||||
.setToStationName(lyOrderTrainRecord.getTripName()) //到达站
|
||||
.setIssueTicketTime(lyOrderTrainRecord.getEnterAccount()) //出票时间 yyyy-MM-dd HH:mm:ss
|
||||
.setRunTime(trainOrderDetail.getRunTime()) //时长
|
||||
.setSeatType(trainOrderDetail.getSeatType())// 座位等级
|
||||
.setRunTime("") //时长
|
||||
.setSeatType("")// 座位等级
|
||||
.setTrainNo(lyOrderTrainRecord.getTrainNo()) //车次
|
||||
.setUserCode(lyOrderTrainRecord.getPassengerNo())//出行人编码
|
||||
.setUserName(lyOrderTrainRecord.getPassengerName())//出行人姓名
|
||||
.setOrderSource(lyOrderTrainRecord.getBookingPlat())//预订来源:线上 / 线下
|
||||
.setBookOrgCode1(lyOrderTrainRecord.getPassengerDepartment())//出行人组织架构信息1
|
||||
.setBookOrgCode2(trainOrderDetail.getBOOK_ORG_STRUCT_2())//出行人组织架构信息2
|
||||
.setBookOrgCode3(trainOrderDetail.getBOOK_ORG_STRUCT_3())//出行人组织架构信息3
|
||||
.setBookOrgCode2("")//出行人组织架构信息2
|
||||
.setBookOrgCode3("")//出行人组织架构信息3
|
||||
.setOfflineCcomyCode(lyOrderTrainRecord.getPassengerCostCenter())//成本中心
|
||||
/* .setOrderStatus() //结算状态
|
||||
.setExpenseOrderAmount() //订单金额
|
||||
|
@ -299,38 +263,29 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
|
||||
private void createCarOrder(OrderCarRecord orderCarRecord, LyOrderCarRecord lyOrderCarRecord) {
|
||||
String orderSerialNo = lyOrderCarRecord.getOrderSerialNo();//订单号
|
||||
AtomicReference<OrderDetail> orderDetailRef = new AtomicReference<>();
|
||||
AtomicReference<RouteOrder> routeOrderRef = new AtomicReference<>();
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo, orderDetailRef::set, routeOrderRef::set);
|
||||
OrderRecordBasic orderRecordBasic = getOrderRecordBasic(orderSerialNo);
|
||||
BeanUtils.copyProperties(orderRecordBasic, orderCarRecord);
|
||||
OrderDetail orderDetail = orderDetailRef.get();//订单明细
|
||||
RouteOrder routeOrder = routeOrderRef.get();//财务共享订单数据
|
||||
CarOrderDetail carOrderDetail = orderDetail.getCarOrderDetail() == null ? new CarOrderDetail() : orderDetail.getCarOrderDetail();//用车订单明细
|
||||
orderCarRecord.setOrderDetailId(orderDetail.getOrderId() == null ? -1L : orderDetail.getOrderId());//订单明细id
|
||||
//公共字段校验
|
||||
carFieldCheck(orderCarRecord, lyOrderCarRecord);
|
||||
orderCarRecord.setDetailId(lyOrderCarRecord.getBillOrderNo())//防重标识
|
||||
.setTicketClerk(lyOrderCarRecord.getReserveManName()) //票务员
|
||||
.setAccountPeriod(lyOrderCarRecord.getStatementCode()) //账期号
|
||||
.setBillNo(lyOrderCarRecord.getBillOrderNo()); //账单号
|
||||
orderCarRecord.setReceiptsNum(getReceiptsNum(lyOrderCarRecord.getOutApplayOrderNo(), routeOrder))//关联申请单号
|
||||
.setReceiptsNumOrigin(lyOrderCarRecord.getOutApplayOrderNo()) //原关联申请单号
|
||||
.setBillNo(lyOrderCarRecord.getBillOrderNo()) //账单号
|
||||
.setReceiptsNum(lyOrderCarRecord.getOrderSerialNo()) //关联申请单号
|
||||
.setOverStandard("0") //"是否违规(超标):0否 1是"
|
||||
.setOverStandardReason("无")//违规原因(超标原因)
|
||||
.setOrderNo(lyOrderCarRecord.getOrderSerialNo()) //订单号
|
||||
.setParentOrderNo(carOrderDetail.getParentOrderNo())//父级订单号
|
||||
.setParentOrderNo("")//父级订单号
|
||||
.setOriginalOrderNo(lyOrderCarRecord.getOriginOrderSerialNo())//原始订单号
|
||||
.setOrderStatus("") //"结算状态"
|
||||
.setCreateTime(lyOrderCarRecord.getBookingDate()) //"订单创建时间格式:2023-04-26 13:15:17"
|
||||
.setStartTime(lyOrderCarRecord.getPlanBeginDate()) //"出发时间格式:2023-04-26 13:15:17"
|
||||
.setArriveTime(carOrderDetail.getArriveTime()) //"到达时间格式:2023-04-26 13:15:17"
|
||||
.setArriveTime("") //"到达时间格式:2023-04-26 13:15:17"
|
||||
.setFromStationName(lyOrderCarRecord.getCarStartPlaceActual()) //出发地
|
||||
.setToStationName(lyOrderCarRecord.getCarEndPlaceActual()) //到达地
|
||||
.setCarType(carOrderDetail.getCarModel()) //车型
|
||||
.setCarType("") //车型
|
||||
.setFromCity(lyOrderCarRecord.getStartCityName()) //出发城市
|
||||
.setToCity(carOrderDetail.getToCity()) //到达城市
|
||||
.setRunTime(carOrderDetail.getRunTime()) //运行时长
|
||||
.setMiles(carOrderDetail.getMileage()) //里程数
|
||||
.setToCity("") //到达城市
|
||||
.setRunTime("") //运行时长
|
||||
.setMiles("") //里程数
|
||||
.setNoTaxAmt("") //未税金额
|
||||
.setTaxAmt("") //税费
|
||||
.setOrderAmount(String.valueOf(lyOrderCarRecord.getToBePayAmount())) //结算总额(含前收服务费)
|
||||
|
@ -341,11 +296,11 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
.setCancelCost(String.valueOf(lyOrderCarRecord.getToBePayAmount())) //取消费
|
||||
.setUserName(String.valueOf(lyOrderCarRecord.getPassengerName())) //用车人姓名
|
||||
.setUserCode(lyOrderCarRecord.getPassengerNo()) //用车人code
|
||||
.setOwnPayAmt(carOrderDetail.getPersonalPaymentAmount()) //个人支付金额
|
||||
// .setOwnPayAmt() //个人支付金额
|
||||
.setComyPayAmt(String.valueOf(lyOrderCarRecord.getToBePayAmount())) //公司统付金额
|
||||
.setBookOrgCode1(lyOrderCarRecord.getPassengerDepartment()) //用车人组织架构信息1
|
||||
.setBookOrgCode2(carOrderDetail.getBOOK_ORG_STRUCT_2()) //用车人组织架构信息2
|
||||
.setBookOrgCode3(carOrderDetail.getBOOK_ORG_STRUCT_3()) //用车人组织架构信息3
|
||||
.setBookOrgCode2("") //用车人组织架构信息2
|
||||
.setBookOrgCode3("") //用车人组织架构信息3
|
||||
.setPaymentType(String.valueOf(getPaymentType(lyOrderCarRecord.getPayType()))) //"付款方式0:公司统付 1:个人付 2:混付"
|
||||
.setOfflineCcomyCode(lyOrderCarRecord.getPassengerDepartment()) //成本中心
|
||||
.setOrderSource(lyOrderCarRecord.getBookingPlat()) //预订来源:线上/线下
|
||||
|
@ -357,181 +312,16 @@ public class LyOrderRecordExtensionFactory implements OrderRecordExtensionFactor
|
|||
}
|
||||
|
||||
//获取公共对象
|
||||
public OrderRecordBasic getOrderRecordBasic(String orderSerialNo, Consumer<OrderDetail> consumerOrderDetail, Consumer<RouteOrder> consumerRouteOrder) {
|
||||
public OrderRecordBasic getOrderRecordBasic(String orderSerialNo) {
|
||||
OrderDetail orderDetail = jdbcOrderDetailRepository.findByOrderNo(orderSerialNo);
|
||||
consumerOrderDetail.accept(orderDetail == null ? new OrderDetail() : orderDetail);//设置订单明细数据
|
||||
if (Objects.isNull(orderDetail)) {
|
||||
consumerRouteOrder.accept(new RouteOrder());
|
||||
return new OrderRecordBasic();
|
||||
}
|
||||
Long routeId = orderDetail.getRouteId();
|
||||
Long routeId = orderDetail == null ? 0L : orderDetail.getRouteId();
|
||||
RouteOrder routeOrder = jdbcRouteRepository.findByRouteId(routeId);
|
||||
consumerRouteOrder.accept(routeOrder == null ? new RouteOrder() : routeOrder);
|
||||
if (Objects.isNull(routeOrder)) {
|
||||
return new OrderRecordBasic();
|
||||
}
|
||||
return orderRecordFactory.buildWithRouteOrder(routeOrder);
|
||||
}
|
||||
|
||||
public void flightFieldCheck(OrderFlightRecord orderFlightRecord, LyOrderFlightRecord lyOrderFlightRecord) {
|
||||
orderFlightRecord.setTrvaleSysType(TRAVAL_SYS_TYPE_LY)//数据来源商旅平台 XC:携程 TC:同程
|
||||
.setBookingName(lyOrderFlightRecord.getReserveManName()) //预订人姓名
|
||||
.setBookingUserCode(lyOrderFlightRecord.getReserveManNo()); //预订人编码
|
||||
List<TripSubmitItemFlightList> tripSubmitItemFlightList = lyOrderFlightRecord.getTripSubmitItemList();
|
||||
List<TripSubmitItemList> tripSubmitItemList = BeanCopyUtils.copyBeanList(tripSubmitItemFlightList, TripSubmitItemList.class);
|
||||
if (StringUtils.isBlank(orderFlightRecord.getBelongSysType())) {
|
||||
String belongSysType = findBelongSysType(tripSubmitItemList, lyOrderFlightRecord.getOutApplayOrderNo());
|
||||
orderFlightRecord.setBelongSysType(belongSysType);//对应所属系统
|
||||
}
|
||||
if (StringUtils.isBlank(orderFlightRecord.getAccountCompanyId())) {
|
||||
findAccountCompanyId(tripSubmitItemList).ifPresent(orderFlightRecord::setAccountCompanyId);//核算企业code
|
||||
}
|
||||
if (StringUtils.isBlank(orderFlightRecord.getAccountCompanyName())) {
|
||||
findAccountCompanyName(tripSubmitItemList).ifPresent(orderFlightRecord::setAccountCompanyName);//核算企业名称
|
||||
|
||||
}
|
||||
if (StringUtils.isBlank(orderFlightRecord.getProjectOrderNo())) {
|
||||
findProjectOrderNo(tripSubmitItemList).ifPresent(orderFlightRecord::setProjectOrderNo);//项目订单号
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void hotelFieldCheck(OrderHotelRecord orderHotelRecord, LyOrderHotelRecord lyOrderHotelRecord) {
|
||||
orderHotelRecord.setTrvaleSysType(TRAVAL_SYS_TYPE_LY)//数据来源商旅平台 XC:携程 TC:同程
|
||||
.setBookingName(lyOrderHotelRecord.getReserveManName()) //预订人姓名
|
||||
.setBookingUserCode(lyOrderHotelRecord.getReserveManNo()); //预订人编码
|
||||
List<TripSubmitItemHotelList> tripSubmitItemHotelList = lyOrderHotelRecord.getTripSubmitItemList();
|
||||
List<TripSubmitItemList> tripSubmitItemList = BeanCopyUtils.copyBeanList(tripSubmitItemHotelList, TripSubmitItemList.class);
|
||||
if (StringUtils.isBlank(orderHotelRecord.getBelongSysType())) {
|
||||
String belongSysType = findBelongSysType(tripSubmitItemList, lyOrderHotelRecord.getOutApplayOrderNo());
|
||||
orderHotelRecord.setBelongSysType(belongSysType);//对应所属系统
|
||||
}
|
||||
if (StringUtils.isBlank(orderHotelRecord.getAccountCompanyId())) {
|
||||
findAccountCompanyId(tripSubmitItemList).ifPresent(orderHotelRecord::setAccountCompanyId);//核算企业code
|
||||
}
|
||||
if (StringUtils.isBlank(orderHotelRecord.getAccountCompanyName())) {
|
||||
findAccountCompanyName(tripSubmitItemList).ifPresent(orderHotelRecord::setAccountCompanyName);//核算企业名称
|
||||
|
||||
}
|
||||
if (StringUtils.isBlank(orderHotelRecord.getProjectOrderNo())) {
|
||||
findProjectOrderNo(tripSubmitItemList).ifPresent(orderHotelRecord::setProjectOrderNo);//项目订单号
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void trainFieldCheck(OrderTrainRecord orderTrainRecord, LyOrderTrainRecord lyOrderTrainRecord) {
|
||||
orderTrainRecord.setTrvaleSysType(TRAVAL_SYS_TYPE_LY)//数据来源商旅平台 XC:携程 TC:同程
|
||||
.setBookingName(lyOrderTrainRecord.getReserveManName()) //预订人姓名
|
||||
.setBookingUserCode(lyOrderTrainRecord.getReserveManNo()); //预订人编码
|
||||
List<TripSubmitItemTrainList> tripSubmitItemTrainList = lyOrderTrainRecord.getTripSubmitItemList();
|
||||
List<TripSubmitItemList> tripSubmitItemList = BeanCopyUtils.copyBeanList(tripSubmitItemTrainList, TripSubmitItemList.class);
|
||||
if (StringUtils.isBlank(orderTrainRecord.getBelongSysType())) {
|
||||
String belongSysType = findBelongSysType(tripSubmitItemList, lyOrderTrainRecord.getOutApplayOrderNo());
|
||||
orderTrainRecord.setBelongSysType(belongSysType);//对应所属系统
|
||||
}
|
||||
if (StringUtils.isBlank(orderTrainRecord.getAccountCompanyId())) {
|
||||
findAccountCompanyId(tripSubmitItemList).ifPresent(orderTrainRecord::setAccountCompanyId);//核算企业code
|
||||
}
|
||||
if (StringUtils.isBlank(orderTrainRecord.getAccountCompanyName())) {
|
||||
findAccountCompanyName(tripSubmitItemList).ifPresent(orderTrainRecord::setAccountCompanyName);//核算企业名称
|
||||
|
||||
}
|
||||
if (StringUtils.isBlank(orderTrainRecord.getProjectOrderNo())) {
|
||||
findProjectOrderNo(tripSubmitItemList).ifPresent(orderTrainRecord::setProjectOrderNo);//项目订单号
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
public void carFieldCheck(OrderCarRecord orderCarRecord, LyOrderCarRecord lyOrderCarRecord) {
|
||||
orderCarRecord.setTrvaleSysType(TRAVAL_SYS_TYPE_LY)//数据来源商旅平台 XC:携程 TC:同程
|
||||
.setBookingName(lyOrderCarRecord.getReserveManName()) //预订人姓名
|
||||
.setBookingUserCode(lyOrderCarRecord.getReserveManNo()); //预订人编码
|
||||
List<TripSubmitItemCarList> tripSubmitItemCarList = lyOrderCarRecord.getTripSubmitItemList();
|
||||
List<TripSubmitItemList> tripSubmitItemList = BeanCopyUtils.copyBeanList(tripSubmitItemCarList, TripSubmitItemList.class);
|
||||
if (StringUtils.isBlank(orderCarRecord.getBelongSysType())) {
|
||||
String belongSysType = findBelongSysType(tripSubmitItemList, lyOrderCarRecord.getOutApplayOrderNo());
|
||||
orderCarRecord.setBelongSysType(belongSysType);//对应所属系统
|
||||
}
|
||||
if (StringUtils.isBlank(orderCarRecord.getAccountCompanyId())) {
|
||||
findAccountCompanyId(tripSubmitItemList).ifPresent(orderCarRecord::setAccountCompanyId);//核算企业code
|
||||
}
|
||||
if (StringUtils.isBlank(orderCarRecord.getAccountCompanyName())) {
|
||||
findAccountCompanyName(tripSubmitItemList).ifPresent(orderCarRecord::setAccountCompanyName);//核算企业名称
|
||||
|
||||
}
|
||||
if (StringUtils.isBlank(orderCarRecord.getProjectOrderNo())) {
|
||||
findProjectOrderNo(tripSubmitItemList).ifPresent(orderCarRecord::setProjectOrderNo);//项目订单号
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
//对应所属系统
|
||||
private static String findBelongSysType(List<TripSubmitItemList> itemList, String outApplayOrderNo) {
|
||||
return itemList.stream()
|
||||
.filter(item -> LY_CUSTOM1.equals(item.getCode()))
|
||||
.findFirst()
|
||||
.map(TripSubmitItemList::getContent)
|
||||
.orElseGet(() -> Optional.ofNullable(outApplayOrderNo)
|
||||
.map(no -> no.split("-")[0])
|
||||
.orElse(""));
|
||||
}
|
||||
|
||||
//核算企业code
|
||||
private static Optional<String> findAccountCompanyId(List<TripSubmitItemList> tripSubmitItemList) {
|
||||
return tripSubmitItemList.stream()
|
||||
.filter(item -> LY_CUSTOM2.equals(item.getCode()))
|
||||
.findFirst()
|
||||
.map(TripSubmitItemList::getContent);
|
||||
}
|
||||
|
||||
////核算企业名称
|
||||
private static Optional<String> findAccountCompanyName(List<TripSubmitItemList> tripSubmitItemList) {
|
||||
return tripSubmitItemList.stream()
|
||||
.filter(item -> LY_CUSTOM3.equals(item.getCode()))
|
||||
.findFirst()
|
||||
.map(TripSubmitItemList::getContent);
|
||||
}
|
||||
|
||||
//项目订单号
|
||||
private static Optional<String> findProjectOrderNo(List<TripSubmitItemList> tripSubmitItemList) {
|
||||
return tripSubmitItemList.stream()
|
||||
.filter(item -> LY_CUSTOM4.equals(item.getCode()))
|
||||
.findFirst()
|
||||
.map(TripSubmitItemList::getContent);
|
||||
}
|
||||
|
||||
|
||||
private void flightReceiptsNum(OrderFlightRecord orderFlightRecord, LyOrderFlightRecord lyOrderFlightRecord, RouteOrder routeOrder) {
|
||||
ApproveOrderNo approveOrderNo = routeOrder.getApproveOrderNo();
|
||||
String outApplayOrderNo = lyOrderFlightRecord.getOutApplayOrderNo();
|
||||
String receiptsNum = "";
|
||||
if (Objects.isNull(approveOrderNo) && StringUtils.isNotBlank(outApplayOrderNo)) {
|
||||
String[] receiptsNums = outApplayOrderNo.split("-");
|
||||
if (receiptsNums.length > 1) {
|
||||
receiptsNum = receiptsNums[1];
|
||||
}
|
||||
} else {
|
||||
receiptsNum = approveOrderNo.getActualOrderNo();
|
||||
}
|
||||
orderFlightRecord.setReceiptsNum(receiptsNum);
|
||||
}
|
||||
|
||||
//获取财务共享单号
|
||||
private String getReceiptsNum(String outApplayOrderNo, RouteOrder routeOrder) {
|
||||
ApproveOrderNo approveOrderNo = routeOrder.getApproveOrderNo();
|
||||
if (Objects.isNull(approveOrderNo)) {
|
||||
if (StringUtils.isNotBlank(outApplayOrderNo)) {
|
||||
String[] receiptsNums = outApplayOrderNo.split("-");
|
||||
if (receiptsNums.length > 1) {
|
||||
return receiptsNums[1];
|
||||
}
|
||||
}
|
||||
return "";
|
||||
}
|
||||
return approveOrderNo.getActualOrderNo();
|
||||
}
|
||||
|
||||
|
||||
//映射付款方式
|
||||
//支付类型(1:企业授信 / 2:个人支付 / 3:组合支付)
|
||||
public int getPaymentType(String payType) {
|
||||
|
|
|
@ -1,6 +1,5 @@
|
|||
package com.chint.domain.service.order_record;
|
||||
|
||||
import com.chint.application.commands.LYOrderRecordGenerateCommand;
|
||||
import com.chint.application.commands.OrderRecordGenerateCommand;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderCarRecord;
|
||||
import com.chint.domain.aggregates.order.order_record.OrderFlightRecord;
|
||||
|
@ -13,7 +12,6 @@ import com.chint.domain.aggregates.order.order_record.ly_order_record.LyOrderTra
|
|||
import com.chint.domain.factoriy.order_record.CTripOrderRecordExtensionFactory;
|
||||
import com.chint.domain.factoriy.order_record.LyOrderRecordExtensionFactory;
|
||||
import com.chint.domain.service.OrderDetailDomainService;
|
||||
import com.chint.infrastructure.echo_framework.annotation.ListenTo;
|
||||
import com.chint.infrastructure.repository.jdbc.*;
|
||||
import com.chint.infrastructure.util.PageResult;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
@ -27,7 +25,7 @@ import java.util.ArrayList;
|
|||
import java.util.List;
|
||||
|
||||
@Component
|
||||
public class LYOrderRecordDomainService {
|
||||
public class LYOrderRecordDomainService implements OrderRecordDomainService {
|
||||
|
||||
@Autowired
|
||||
private JdbcLyOrderFlightRecord jdbcLyOrderFlightRecord;
|
||||
|
@ -48,10 +46,9 @@ public class LYOrderRecordDomainService {
|
|||
@Autowired
|
||||
private OrderDetailDomainService orderDetailDomainService;
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@ListenTo(command = "LYOrderRecordGenerateCommand", order = 0)
|
||||
public List<OrderFlightRecord> generateFlightRecord(LYOrderRecordGenerateCommand command) {
|
||||
public List<OrderFlightRecord> generateFlightRecord(OrderRecordGenerateCommand command) {
|
||||
ArrayList<OrderFlightRecord> orderFlightRecordList = new ArrayList<>();
|
||||
int count = 0;//初始化变量
|
||||
int pageSize = 100; // 假设每页大小为10
|
||||
|
@ -78,10 +75,9 @@ public class LYOrderRecordDomainService {
|
|||
return orderFlightRecordList;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@ListenTo(command = "LYOrderRecordGenerateCommand", order = 1)
|
||||
public List<OrderHotelRecord> generateHotelRecord(LYOrderRecordGenerateCommand command) {
|
||||
public List<OrderHotelRecord> generateHotelRecord(OrderRecordGenerateCommand command) {
|
||||
ArrayList<OrderHotelRecord> orderHotelRecordList = new ArrayList<>();
|
||||
int count = 0;//初始化变量
|
||||
int pageSize = 100; // 假设每页大小为10
|
||||
|
@ -108,10 +104,9 @@ public class LYOrderRecordDomainService {
|
|||
return orderHotelRecordList;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@ListenTo(command = "LYOrderRecordGenerateCommand", order = 2)
|
||||
public List<OrderTrainRecord> generateTrainRecord(LYOrderRecordGenerateCommand command) {
|
||||
public List<OrderTrainRecord> generateTrainRecord(OrderRecordGenerateCommand command) {
|
||||
ArrayList<OrderTrainRecord> orderTrainRecordsList = new ArrayList<>();
|
||||
int count = 0;//初始化变量
|
||||
int pageSize = 100; // 假设每页大小为10
|
||||
|
@ -139,10 +134,9 @@ public class LYOrderRecordDomainService {
|
|||
}
|
||||
|
||||
|
||||
|
||||
@Override
|
||||
@Transactional
|
||||
@ListenTo(command = "LYOrderRecordGenerateCommand", order = 3)
|
||||
public List<OrderCarRecord> generateCarRecord(LYOrderRecordGenerateCommand command) {
|
||||
public List<OrderCarRecord> generateCarRecord(OrderRecordGenerateCommand command) {
|
||||
ArrayList<OrderCarRecord> orderCarRecordsList = new ArrayList<>();
|
||||
int count = 0;//初始化变量
|
||||
int pageSize = 100; // 假设每页大小为10
|
||||
|
|
|
@ -1,14 +0,0 @@
|
|||
package com.chint.infrastructure.constant;
|
||||
|
||||
public class OrderRecordConstant {
|
||||
|
||||
// 对应所属系统
|
||||
public static final String LY_CUSTOM1 = "Custom1";
|
||||
//核算企业code
|
||||
public static final String LY_CUSTOM2 = "Custom2";
|
||||
//核算企业名称
|
||||
public static final String LY_CUSTOM3 = "Custom3";
|
||||
//项目订单号
|
||||
public static final String LY_CUSTOM4 = "Custom4";
|
||||
|
||||
}
|
|
@ -48,6 +48,8 @@ public class CTripOrderDetailRequest {
|
|||
private String carOrderUrl;
|
||||
|
||||
|
||||
private DateTimeFormatter formatter =
|
||||
|
||||
@PostConstruct
|
||||
private void init() {
|
||||
this.flightOrderUrl = C_TRIP_BASE_URL + C_TRIP_ORDER_FLIGHT_PATH;
|
||||
|
|
|
@ -1,6 +1,6 @@
|
|||
package com.chint.interfaces.rest.ly.reconciliation.dto.DetailResponse;
|
||||
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemCarList;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemList;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.BaseResponse;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.PageInfo;
|
||||
import lombok.AllArgsConstructor;
|
||||
|
@ -71,7 +71,7 @@ public class CarStatement extends BaseResponse {
|
|||
private Double ticketOutAmount;//票面
|
||||
private Double serviceAmount;//服务费
|
||||
private Double insuranceAmount;//保险
|
||||
private List<TripSubmitItemCarList> tripSubmitItemList;//行程提交项
|
||||
private List<TripSubmitItemList> tripSubmitItemList;//行程提交项
|
||||
private String orderOperType;//类型 预订/变更/退票
|
||||
private String payType;//支付类型(1:企业授信 / 2:个人支付 / 3:组合支付)
|
||||
private Double totalShouldPay;//总计应付
|
||||
|
|
|
@ -1,6 +1,6 @@
|
|||
package com.chint.interfaces.rest.ly.reconciliation.dto.DetailResponse;
|
||||
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemFlightList;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemList;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.BaseResponse;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.PageInfo;
|
||||
import lombok.AllArgsConstructor;
|
||||
|
@ -93,7 +93,7 @@ public class FlightStatement extends BaseResponse {
|
|||
private Double ticketOutAmount;//票面
|
||||
private Double serviceAmount;//服务费
|
||||
private Double insuranceAmount;//保险
|
||||
private List<TripSubmitItemFlightList> tripSubmitItemList;//行程提交项
|
||||
private List<TripSubmitItemList> tripSubmitItemList;//行程提交项
|
||||
private String orderOperType;//类型 预订/变更/退票
|
||||
private String payType;//支付类型(1:企业授信 / 2:个人支付 / 3:组合支付)
|
||||
private Double totalShouldPay;//总计应付
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
package com.chint.interfaces.rest.ly.reconciliation.dto.DetailResponse;
|
||||
|
||||
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemHotelList;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemList;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.BaseResponse;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.PageInfo;
|
||||
import lombok.AllArgsConstructor;
|
||||
|
@ -80,7 +79,7 @@ public class HotelStatement extends BaseResponse {
|
|||
private Double ticketOutAmount;//票面
|
||||
private Double serviceAmount;//服务费
|
||||
private Double insuranceAmount;//保险
|
||||
private List<TripSubmitItemHotelList> tripSubmitItemList;//行程提交项
|
||||
private List<TripSubmitItemList> tripSubmitItemList;//行程提交项
|
||||
private String orderOperType;//类型 预订/变更/退票
|
||||
private String payType;//支付类型(1:企业授信 / 2:个人支付 / 3:组合支付)
|
||||
private Double totalShouldPay;//总计应付
|
||||
|
|
|
@ -1,7 +1,6 @@
|
|||
package com.chint.interfaces.rest.ly.reconciliation.dto.DetailResponse;
|
||||
|
||||
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemTrainList;
|
||||
import com.chint.domain.aggregates.order.order_record.ly_order_record.TripSubmitItemList;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.BaseResponse;
|
||||
import com.chint.interfaces.rest.ly.reconciliation.dto.PageInfo;
|
||||
import lombok.AllArgsConstructor;
|
||||
|
@ -78,7 +77,7 @@ public class TrainStatement extends BaseResponse {
|
|||
private Double ticketOutAmount;//票面
|
||||
private Double serviceAmount;//服务费
|
||||
private Double insuranceAmount;//保险
|
||||
private List<TripSubmitItemTrainList> tripSubmitItemList;//行程提交项
|
||||
private List<TripSubmitItemList> tripSubmitItemList;//行程提交项
|
||||
private String orderOperType;//类型 预订/变更/退票
|
||||
private String payType;//支付类型(1:企业授信 / 2:个人支付 / 3:组合支付)
|
||||
private Double totalShouldPay;//总计应付
|
||||
|
|
|
@ -48,10 +48,10 @@ logging:
|
|||
#正式
|
||||
ly:
|
||||
appId: zhengtai
|
||||
account: ab9fe0c19dd64a99b936fded72c3bb94
|
||||
password: glHRJJ9JMUwNfQ8OwAQi
|
||||
secret: MnghmYJpM1U2RaLx
|
||||
baseUrl: https://api.dttrip.cn/openapi
|
||||
account: 4f9cb1080b564dd0a94aa95f7a19c8b5
|
||||
password: 1fD3SutgzfS48qznYQiq
|
||||
secret: WOHzCMvHd823iHgH
|
||||
baseUrl: https://api.qa.dttrip.cn/openapi
|
||||
ifForwardRequest: false
|
||||
forwardRequestBaseUrl: https://secureqrdev-t.chint.com/llz
|
||||
|
||||
|
|
|
@ -618,4 +618,8 @@ public class CTripTest {
|
|||
}
|
||||
|
||||
|
||||
// @Test
|
||||
void saveFlightRecord(){
|
||||
cTripOrderRecordAutoSave.cTripFlightRecordAutoSave();
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue