diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/handler/ConfirmStartChargingRequestHandler.java b/jsowell-netty/src/main/java/com/jsowell/netty/handler/ConfirmStartChargingRequestHandler.java index 8068d2ba8..b053443c7 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/handler/ConfirmStartChargingRequestHandler.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/handler/ConfirmStartChargingRequestHandler.java @@ -5,6 +5,7 @@ import com.google.common.primitives.Bytes; import com.jsowell.common.constant.Constants; import com.jsowell.common.core.domain.ykc.YKCDataProtocol; import com.jsowell.common.core.domain.ykc.YKCFrameTypeCode; +import com.jsowell.common.enums.ykc.OrderStatusEnum; import com.jsowell.common.enums.ykc.ReturnCodeEnum; import com.jsowell.common.exception.BusinessException; import com.jsowell.common.util.BytesUtil; @@ -12,12 +13,13 @@ import com.jsowell.common.util.StringUtils; import com.jsowell.common.util.YKCUtils; import com.jsowell.common.util.id.IdUtils; import com.jsowell.netty.factory.YKCOperateFactory; +import com.jsowell.pile.domain.OrderBasicInfo; +import com.jsowell.pile.domain.OrderDetail; import com.jsowell.pile.domain.PileAuthCard; -import com.jsowell.pile.service.IMemberBasicInfoService; -import com.jsowell.pile.service.IMemberWalletInfoService; import com.jsowell.pile.service.IPileAuthCardService; import com.jsowell.pile.service.impl.MemberBasicInfoServiceImpl; -import com.jsowell.pile.service.impl.PileAuthCardServiceImpl; +import com.jsowell.pile.transaction.dto.OrderTransactionDTO; +import com.jsowell.pile.transaction.service.TransactionService; import com.jsowell.pile.vo.uniapp.MemberVO; import io.netty.channel.Channel; import lombok.extern.slf4j.Slf4j; @@ -44,6 +46,9 @@ public class ConfirmStartChargingRequestHandler extends AbstractHandler{ @Autowired private IPileAuthCardService pileAuthCardService; + @Autowired + private TransactionService pileTransactionService; + @Override public void afterPropertiesSet() throws Exception { YKCOperateFactory.register(type, this); @@ -136,6 +141,43 @@ public class ConfirmStartChargingRequestHandler extends AbstractHandler{ // TODO 将此订单信息存入订单表 + String orderCode = IdUtils.getOrderCode(); + String transactionCode = IdUtils.generateTransactionCode(dto.getPileSn(), dto.getConnectorCode()); + // 订单基本信息 + OrderBasicInfo orderBasicInfo = OrderBasicInfo.builder() + .orderCode(orderCode) + .transactionCode(transactionCode) + .orderStatus(OrderStatusEnum.NOT_START.getValue()) + .memberId(memberVO.getMemberId()) + .stationId(dto.getPileConnector().getStationId()) + .pileSn(dto.getPileSn()) + .connectorCode(dto.getConnectorCode()) + .pileConnectorCode(dto.getPileSn() + dto.getConnectorCode()) + .startMode(dto.getStartMode()) + .payStatus(Constants.ZERO) + .payAmount(dto.getChargeAmount()) + .payMode(dto.getPayMode()) + .orderAmount(BigDecimal.ZERO) + .build(); + + // 订单详情 + OrderDetail orderDetail = OrderDetail.builder() + .orderCode(orderCode) + .sharpElectricityPrice(dto.getBillingTemplate().getSharpElectricityPrice()) + .sharpServicePrice(dto.getBillingTemplate().getSharpServicePrice()) + .peakElectricityPrice(dto.getBillingTemplate().getPeakElectricityPrice()) + .peakServicePrice(dto.getBillingTemplate().getPeakServicePrice()) + .flatElectricityPrice(dto.getBillingTemplate().getFlatElectricityPrice()) + .flatServicePrice(dto.getBillingTemplate().getFlatServicePrice()) + .valleyElectricityPrice(dto.getBillingTemplate().getValleyElectricityPrice()) + .valleyServicePrice(dto.getBillingTemplate().getValleyServicePrice()) + .build(); + + OrderTransactionDTO createOrderTransactionDTO = OrderTransactionDTO.builder() + .orderBasicInfo(orderBasicInfo) + .orderDetail(orderDetail) + .build(); + pileTransactionService.doCreateOrder(createOrderTransactionDTO); }