|
@@ -48,7 +48,18 @@ import com.yc.ship.module.otc.api.store.StoreApi;
|
|
|
import com.yc.ship.module.otc.api.store.dto.StoreInfoRespDTO;
|
|
import com.yc.ship.module.otc.api.store.dto.StoreInfoRespDTO;
|
|
|
import com.yc.ship.module.product.api.ProductApi;
|
|
import com.yc.ship.module.product.api.ProductApi;
|
|
|
import com.yc.ship.module.product.api.VoyageApi;
|
|
import com.yc.ship.module.product.api.VoyageApi;
|
|
|
-import com.yc.ship.module.product.api.dto.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.CategoryRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.OrderRoomUseDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductBasicRuleRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductGroupRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductOtherRuleRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductRefundRuleRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductSaleRuleRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductSkuRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductSpuRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ProductTakeRuleRespDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.ReduceStockReqDTO;
|
|
|
|
|
+import com.yc.ship.module.product.api.dto.VoyageRespDTO;
|
|
|
import com.yc.ship.module.product.controller.admin.voyage.vo.VoyageRespVO;
|
|
import com.yc.ship.module.product.controller.admin.voyage.vo.VoyageRespVO;
|
|
|
import com.yc.ship.module.product.dal.dataobject.priceroommodeltype.PriceRoomModelTypeDO;
|
|
import com.yc.ship.module.product.dal.dataobject.priceroommodeltype.PriceRoomModelTypeDO;
|
|
|
import com.yc.ship.module.product.dal.dataobject.voyage.VoyageDO;
|
|
import com.yc.ship.module.product.dal.dataobject.voyage.VoyageDO;
|
|
@@ -73,40 +84,99 @@ import com.yc.ship.module.system.api.user.AdminUserApi;
|
|
|
import com.yc.ship.module.system.api.user.dto.AdminUserRespDTO;
|
|
import com.yc.ship.module.system.api.user.dto.AdminUserRespDTO;
|
|
|
import com.yc.ship.module.trade.api.dto.TradeOrderPayDTO;
|
|
import com.yc.ship.module.trade.api.dto.TradeOrderPayDTO;
|
|
|
import com.yc.ship.module.trade.api.dto.TradeOrderRespDTO;
|
|
import com.yc.ship.module.trade.api.dto.TradeOrderRespDTO;
|
|
|
-import com.yc.ship.module.trade.controller.admin.order.vo.order.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.OrderPayAmountRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.OtcTradeOrderCreateRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.PayOrderReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.PayOrderRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.ShipTradeOrderCreateReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeDetailPageReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeDetailRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeHotelBookingRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderConfirmationCountryRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderConfirmationVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderDetailCountRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderLogRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderOtcCreateVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderPageReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderPdaRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderPolicyReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderRespNewVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderRoomModelVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderTotalVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeOrderVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeSpuReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeStaticReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.order.TradeVistorReqVO;
|
|
|
import com.yc.ship.module.trade.controller.admin.order.vo.otc.PrintRespVO;
|
|
import com.yc.ship.module.trade.controller.admin.order.vo.otc.PrintRespVO;
|
|
|
-import com.yc.ship.module.trade.controller.admin.order.vo.refund.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.refund.RefundDetailRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.refund.RefundPageReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.refund.RefundRecordPageReqVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.refund.RefundRecordRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.controller.admin.order.vo.refund.RefundRespVO;
|
|
|
import com.yc.ship.module.trade.convert.order.TradeOrderConvert;
|
|
import com.yc.ship.module.trade.convert.order.TradeOrderConvert;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.audituser.AuditUserDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.audituser.AuditUserDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.contract.ContractDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.contract.ContractDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.insurance.InsuranceDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.insurance.InsuranceDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.invoice.InvoiceDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.invoice.InvoiceDO;
|
|
|
-import com.yc.ship.module.trade.dal.dataobject.order.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.CategoryRespVO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeDetailBaseDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderBindDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderCountryDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderDeliveryDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderDeliveryVO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderHotelDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderLogDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderPayDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderRoomModelDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeOrderTotalDO;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.dataobject.order.TradeVisitorDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.orderjz.OrderJzDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.orderjz.OrderJzDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.orderpolicy.OrderPolicyDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.orderpolicy.OrderPolicyDO;
|
|
|
import com.yc.ship.module.trade.dal.dataobject.tradeOrderaudit.TradeOrderAuditDO;
|
|
import com.yc.ship.module.trade.dal.dataobject.tradeOrderaudit.TradeOrderAuditDO;
|
|
|
import com.yc.ship.module.trade.dal.mysql.audituser.AuditUserMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.audituser.AuditUserMapper;
|
|
|
import com.yc.ship.module.trade.dal.mysql.contract.ContractMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.contract.ContractMapper;
|
|
|
import com.yc.ship.module.trade.dal.mysql.insurance.InsuranceMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.insurance.InsuranceMapper;
|
|
|
-import com.yc.ship.module.trade.dal.mysql.order.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeDetailBaseMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeDetailMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderCountryMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderDeliveryMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderFloorMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderLogMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderRoomModelMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderTotalMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeOrderUserMapper;
|
|
|
|
|
+import com.yc.ship.module.trade.dal.mysql.order.TradeVisitorMapper;
|
|
|
import com.yc.ship.module.trade.dal.mysql.orderjz.OrderJzMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.orderjz.OrderJzMapper;
|
|
|
import com.yc.ship.module.trade.dal.mysql.orderpolicy.OrderPolicyMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.orderpolicy.OrderPolicyMapper;
|
|
|
import com.yc.ship.module.trade.dal.mysql.tradeOrderaudit.TradeOrderAuditMapper;
|
|
import com.yc.ship.module.trade.dal.mysql.tradeOrderaudit.TradeOrderAuditMapper;
|
|
|
-import com.yc.ship.module.trade.enums.*;
|
|
|
|
|
|
|
+import com.yc.ship.module.trade.enums.ErrorCodeConstants;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.PayAccountTypeEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.PayTypeEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.SellMethodEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.TradeOrderBindEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.TradeOrderOperateTypeEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.TradeOrderStatusEnum;
|
|
|
|
|
+import com.yc.ship.module.trade.enums.VoucherStatusEnum;
|
|
|
import com.yc.ship.module.trade.framework.annotation.TradeOrderLog;
|
|
import com.yc.ship.module.trade.framework.annotation.TradeOrderLog;
|
|
|
import com.yc.ship.module.trade.framework.common.ThreadLocalUtil;
|
|
import com.yc.ship.module.trade.framework.common.ThreadLocalUtil;
|
|
|
import com.yc.ship.module.trade.framework.common.TradeOrderLogUtils;
|
|
import com.yc.ship.module.trade.framework.common.TradeOrderLogUtils;
|
|
|
import com.yc.ship.module.trade.service.invoice.InvoiceService;
|
|
import com.yc.ship.module.trade.service.invoice.InvoiceService;
|
|
|
import com.yc.ship.module.trade.service.order.TradeOrderRepositoryService;
|
|
import com.yc.ship.module.trade.service.order.TradeOrderRepositoryService;
|
|
|
import com.yc.ship.module.trade.service.order.TradeOrderService;
|
|
import com.yc.ship.module.trade.service.order.TradeOrderService;
|
|
|
-import com.yc.ship.module.trade.service.orderpolicy.OrderPolicyService;
|
|
|
|
|
import com.yc.ship.module.trade.service.otc.OtcTradeOrderService;
|
|
import com.yc.ship.module.trade.service.otc.OtcTradeOrderService;
|
|
|
import com.yc.ship.module.trade.service.pay.TradeOrderPayService;
|
|
import com.yc.ship.module.trade.service.pay.TradeOrderPayService;
|
|
|
import com.yc.ship.module.trade.service.refund.TradeRefundRepositoryService;
|
|
import com.yc.ship.module.trade.service.refund.TradeRefundRepositoryService;
|
|
|
import com.yc.ship.module.trade.utils.AgencyAuthUtils;
|
|
import com.yc.ship.module.trade.utils.AgencyAuthUtils;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
-import org.apache.poi.ss.usermodel.*;
|
|
|
|
|
|
|
+import org.apache.poi.ss.usermodel.BorderStyle;
|
|
|
|
|
+import org.apache.poi.ss.usermodel.Cell;
|
|
|
|
|
+import org.apache.poi.ss.usermodel.CellStyle;
|
|
|
|
|
+import org.apache.poi.ss.usermodel.Row;
|
|
|
|
|
+import org.apache.poi.ss.usermodel.Sheet;
|
|
|
import org.apache.poi.ss.util.CellRangeAddress;
|
|
import org.apache.poi.ss.util.CellRangeAddress;
|
|
|
import org.apache.poi.ss.util.RegionUtil;
|
|
import org.apache.poi.ss.util.RegionUtil;
|
|
|
import org.jetbrains.annotations.NotNull;
|
|
import org.jetbrains.annotations.NotNull;
|
|
@@ -121,15 +191,30 @@ import java.io.InputStream;
|
|
|
import java.math.BigDecimal;
|
|
import java.math.BigDecimal;
|
|
|
import java.time.LocalDateTime;
|
|
import java.time.LocalDateTime;
|
|
|
import java.time.ZoneOffset;
|
|
import java.time.ZoneOffset;
|
|
|
-import java.util.*;
|
|
|
|
|
|
|
+import java.util.ArrayList;
|
|
|
|
|
+import java.util.Arrays;
|
|
|
|
|
+import java.util.Collections;
|
|
|
|
|
+import java.util.Comparator;
|
|
|
|
|
+import java.util.Date;
|
|
|
|
|
+import java.util.HashMap;
|
|
|
|
|
+import java.util.HashSet;
|
|
|
|
|
+import java.util.List;
|
|
|
|
|
+import java.util.Map;
|
|
|
|
|
+import java.util.Objects;
|
|
|
|
|
+import java.util.Set;
|
|
|
|
|
+import java.util.StringJoiner;
|
|
|
import java.util.concurrent.TimeUnit;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
import java.util.concurrent.atomic.AtomicReference;
|
|
|
import java.util.stream.Collectors;
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
|
|
import static com.yc.ship.framework.common.util.collection.CollectionUtils.convertList;
|
|
import static com.yc.ship.framework.common.util.collection.CollectionUtils.convertList;
|
|
|
-import static com.yc.ship.framework.security.core.util.SecurityFrameworkUtils.*;
|
|
|
|
|
|
|
+import static com.yc.ship.framework.security.core.util.SecurityFrameworkUtils.getLoginUser;
|
|
|
|
|
+import static com.yc.ship.framework.security.core.util.SecurityFrameworkUtils.getLoginUserId;
|
|
|
|
|
+import static com.yc.ship.framework.security.core.util.SecurityFrameworkUtils.getLoginUserNickname;
|
|
|
import static com.yc.ship.module.trade.enums.ApiConstants.ORDER_CHANGE_TYPE_NEW;
|
|
import static com.yc.ship.module.trade.enums.ApiConstants.ORDER_CHANGE_TYPE_NEW;
|
|
|
-import static com.yc.ship.module.trade.enums.ErrorCodeConstants.*;
|
|
|
|
|
|
|
+import static com.yc.ship.module.trade.enums.ErrorCodeConstants.ORDER_NOT_EXIST;
|
|
|
|
|
+import static com.yc.ship.module.trade.enums.ErrorCodeConstants.ORDER_OTC_FAIL;
|
|
|
|
|
+import static com.yc.ship.module.trade.enums.ErrorCodeConstants.ORDER_OTC_NONE;
|
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -1506,24 +1591,26 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
|
|
|
orderPolicyMapper.deleteByOrderId(orderId);
|
|
orderPolicyMapper.deleteByOrderId(orderId);
|
|
|
List<OrderPolicyDO> orderPolicyDOList = new ArrayList<>();
|
|
List<OrderPolicyDO> orderPolicyDOList = new ArrayList<>();
|
|
|
List<TradeOrderPolicyReqVO> policyList = createVO.getPolicyList();
|
|
List<TradeOrderPolicyReqVO> policyList = createVO.getPolicyList();
|
|
|
- policyList.stream().forEach(policy -> {
|
|
|
|
|
- OrderPolicyDO orderPolicyDO = new OrderPolicyDO();
|
|
|
|
|
- orderPolicyDO.setOrderId(orderId);
|
|
|
|
|
- orderPolicyDO.setOrderNo(orderNo);
|
|
|
|
|
- orderPolicyDO.setPolicyId(policy.getPolicyId());
|
|
|
|
|
- if(createVO.getIsYd() != null && createVO.getIsYd() == 1) {
|
|
|
|
|
- orderPolicyDO.setPreUseNum(policy.getUseNum());
|
|
|
|
|
- orderPolicyDO.setRealUseNum(BigDecimal.ZERO);
|
|
|
|
|
- }else {
|
|
|
|
|
- //TODO: 需要修改订单金额,参考文档
|
|
|
|
|
- orderPolicyDO.setPreUseNum(BigDecimal.ZERO);
|
|
|
|
|
- orderPolicyDO.setRealUseNum(policy.getUseNum());
|
|
|
|
|
- policyApi.updatePolicySurplusNum(policy.getPolicyId(), policy.getUseNum());
|
|
|
|
|
- }
|
|
|
|
|
- orderPolicyDO.setAmount(policy.getAmount());
|
|
|
|
|
- orderPolicyDO.setRooms(policy.getRooms());
|
|
|
|
|
- orderPolicyDOList.add(orderPolicyDO);
|
|
|
|
|
- });
|
|
|
|
|
|
|
+ if(policyList != null) {
|
|
|
|
|
+ policyList.stream().forEach(policy -> {
|
|
|
|
|
+ OrderPolicyDO orderPolicyDO = new OrderPolicyDO();
|
|
|
|
|
+ orderPolicyDO.setOrderId(orderId);
|
|
|
|
|
+ orderPolicyDO.setOrderNo(orderNo);
|
|
|
|
|
+ orderPolicyDO.setPolicyId(policy.getPolicyId());
|
|
|
|
|
+ if (createVO.getIsYd() != null && createVO.getIsYd() == 1) {
|
|
|
|
|
+ orderPolicyDO.setPreUseNum(policy.getUseNum());
|
|
|
|
|
+ orderPolicyDO.setRealUseNum(BigDecimal.ZERO);
|
|
|
|
|
+ } else {
|
|
|
|
|
+ //TODO: 需要修改订单金额,参考文档
|
|
|
|
|
+ orderPolicyDO.setPreUseNum(BigDecimal.ZERO);
|
|
|
|
|
+ orderPolicyDO.setRealUseNum(policy.getUseNum());
|
|
|
|
|
+ policyApi.updatePolicySurplusNum(policy.getPolicyId(), policy.getUseNum());
|
|
|
|
|
+ }
|
|
|
|
|
+ orderPolicyDO.setAmount(policy.getAmount());
|
|
|
|
|
+ orderPolicyDO.setRooms(policy.getRooms());
|
|
|
|
|
+ orderPolicyDOList.add(orderPolicyDO);
|
|
|
|
|
+ });
|
|
|
|
|
+ }
|
|
|
if(orderPolicyDOList.size() > 0) {
|
|
if(orderPolicyDOList.size() > 0) {
|
|
|
//TODO: 判断优惠政策是否需要审核
|
|
//TODO: 判断优惠政策是否需要审核
|
|
|
orderPolicyMapper.insertBatch(orderPolicyDOList);
|
|
orderPolicyMapper.insertBatch(orderPolicyDOList);
|
|
@@ -1809,24 +1896,26 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
|
|
|
orderPolicyMapper.deleteByOrderId(orderId);
|
|
orderPolicyMapper.deleteByOrderId(orderId);
|
|
|
List<OrderPolicyDO> orderPolicyDOList = new ArrayList<>();
|
|
List<OrderPolicyDO> orderPolicyDOList = new ArrayList<>();
|
|
|
List<TradeOrderPolicyReqVO> policyList = createVO.getPolicyList();
|
|
List<TradeOrderPolicyReqVO> policyList = createVO.getPolicyList();
|
|
|
- policyList.stream().forEach(policy -> {
|
|
|
|
|
|
|
+ if(policyList != null) {
|
|
|
|
|
+ policyList.stream().forEach(policy -> {
|
|
|
OrderPolicyDO orderPolicyDO = new OrderPolicyDO();
|
|
OrderPolicyDO orderPolicyDO = new OrderPolicyDO();
|
|
|
orderPolicyDO.setOrderId(orderId);
|
|
orderPolicyDO.setOrderId(orderId);
|
|
|
orderPolicyDO.setOrderNo(orderNo);
|
|
orderPolicyDO.setOrderNo(orderNo);
|
|
|
orderPolicyDO.setPolicyId(policy.getPolicyId());
|
|
orderPolicyDO.setPolicyId(policy.getPolicyId());
|
|
|
- if(tradeOrderDO.getOrderStatus() == TradeOrderStatusEnum.UNPAID.getStatus() || tradeOrderDO.getOrderStatus() == TradeOrderStatusEnum.UNPAID.getStatus()) {
|
|
|
|
|
- orderPolicyDO.setRealUseNum(policy.getUseNum());
|
|
|
|
|
- orderPolicyDO.setPreUseNum(BigDecimal.ZERO);
|
|
|
|
|
- policyApi.updatePolicySurplusNum(policy.getPolicyId(), policy.getUseNum());
|
|
|
|
|
- //TODO: 需要修改订单金额,参考文档
|
|
|
|
|
- }else {
|
|
|
|
|
- orderPolicyDO.setRealUseNum(BigDecimal.ZERO);
|
|
|
|
|
- orderPolicyDO.setPreUseNum(policy.getUseNum());
|
|
|
|
|
|
|
+ if (tradeOrderDO.getOrderStatus() == TradeOrderStatusEnum.UNPAID.getStatus() || tradeOrderDO.getOrderStatus() == TradeOrderStatusEnum.UNPAID.getStatus()) {
|
|
|
|
|
+ orderPolicyDO.setRealUseNum(policy.getUseNum());
|
|
|
|
|
+ orderPolicyDO.setPreUseNum(BigDecimal.ZERO);
|
|
|
|
|
+ policyApi.updatePolicySurplusNum(policy.getPolicyId(), policy.getUseNum());
|
|
|
|
|
+ //TODO: 需要修改订单金额,参考文档
|
|
|
|
|
+ } else {
|
|
|
|
|
+ orderPolicyDO.setRealUseNum(BigDecimal.ZERO);
|
|
|
|
|
+ orderPolicyDO.setPreUseNum(policy.getUseNum());
|
|
|
}
|
|
}
|
|
|
orderPolicyDO.setAmount(policy.getAmount());
|
|
orderPolicyDO.setAmount(policy.getAmount());
|
|
|
orderPolicyDO.setRooms(policy.getRooms());
|
|
orderPolicyDO.setRooms(policy.getRooms());
|
|
|
orderPolicyDOList.add(orderPolicyDO);
|
|
orderPolicyDOList.add(orderPolicyDO);
|
|
|
- });
|
|
|
|
|
|
|
+ });
|
|
|
|
|
+ }
|
|
|
if(orderPolicyDOList.size() > 0) {
|
|
if(orderPolicyDOList.size() > 0) {
|
|
|
//TODO: 判断优惠政策是否需要审核
|
|
//TODO: 判断优惠政策是否需要审核
|
|
|
orderPolicyMapper.insertBatch(orderPolicyDOList);
|
|
orderPolicyMapper.insertBatch(orderPolicyDOList);
|
|
@@ -2237,4 +2326,18 @@ public class OtcTradeOrderServiceImpl implements OtcTradeOrderService {
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ @Override
|
|
|
|
|
+ public CommonResult<?> updateStatus(Long orderId, Integer status) {
|
|
|
|
|
+ TradeOrderDO tradeOrderDO = tradeOrderMapper.selectById(orderId);
|
|
|
|
|
+ if (tradeOrderDO == null) {
|
|
|
|
|
+ return CommonResult.error(ORDER_NOT_EXIST);
|
|
|
|
|
+ }
|
|
|
|
|
+ tradeOrderMapper.update(Wrappers.<TradeOrderDO>lambdaUpdate()
|
|
|
|
|
+ .set(TradeOrderDO::getOrderStatus, status)
|
|
|
|
|
+ .set(TradeOrderDO::getUpdateTime, LocalDateTime.now())
|
|
|
|
|
+ .eq(TradeOrderDO::getId, orderId)
|
|
|
|
|
+ );
|
|
|
|
|
+ return CommonResult.success("修改成功");
|
|
|
|
|
+ }
|
|
|
}
|
|
}
|