基于springcloud的分布式电商系统源码.zip

package quick.pager.shop.service.impl; import com.alibaba.fastjson.JSON; import com.google.common.collect.Lists; import io.seata.spring.annotation.GlobalTransactional; import java.math.BigDecimal; import java.time.LocalDateTime; import java.util.List; import java.util.Objects; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import java.util.stream.Stream; import lombok.extern.slf4j.Slf4j; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import quick.pager.shop.activity.client.DiscountCouponClient; import quick.pager.shop.activity.response.coupon.DiscountCouponResponse; import quick.pager.shop.cart.client.CartClient; import quick.pager.shop.cart.client.OrderCartClient; import quick.pager.shop.cart.request.CartOtherRequest; import quick.pager.shop.cart.request.OrderCartRequest; import quick.pager.shop.cart.request.OrderCartSaveRequest; import quick.pager.shop.cart.response.GoodsCartResponse; import quick.pager.shop.constants.IConsts; import quick.pager.shop.constants.SConsts; import quick.pager.shop.constants.SettlementConstants; import quick.pager.shop.goods.client.GoodsSkuClient; import quick.pager.shop.goods.response.sku.GoodsSkuResponse; import quick.pager.shop.order.client.OrderTradeClient; import quick.pager.shop.order.enums.OrderStatusEnums; import quick.pager.shop.order.enums.OrderTypeEnums; import quick.pager.shop.order.enums.PayTypeEnums; import quick.pager.shop.order.enums.TradeTypeEnums; import quick.pager.shop.order.request.OrderTradeSaveRequest; import quick.pager.shop.platform.dto.SystemConfigDTO; import quick.pager.shop.service.SettlementOrderService; import quick.pager.shop.constants.ResponseStatus; import quick.pager.shop.order.client.SellerOrderClient; import quick.pager.shop.order.client.UserOrderClient; import quick.pager.shop.order.request.SellerOrderSaveRequest; import quick.pager.shop.order.request.UserOrderSaveRequest; import quick.pager.shop.settlement.dto.DiscountCouponDTO; import quick.pager.shop.settlement.dto.SettlementDeliveryTimeDTO; import quick.pager.shop.settlement.dto.SettlementPayTypeDTO; import quick.pager.shop.settlement.dto.SettlementSkuDTO; import quick.pager.shop.settlement.request.SettlementCheckRequest; import quick.pager.shop.settlement.request.SettlementRequest; import quick.pager.shop.settlement.request.SettlementSkuRequest; import quick.pager.shop.settlement.request.SettlementSubmitRequest; import quick.pager.shop.settlement.dto.SettlementAddrDTO; import quick.pager.shop.settlement.response.SettlementSkuResponse; import quick.pager.shop.user.client.AddressClient; import quick.pager.shop.user.client.UserAccountClient; import quick.pager.shop.user.response.AddressResponse; import quick.pager.shop.user.response.Response; import quick.pager.shop.settlement.constants.SettlementRedisKeys; import quick.pager.shop.user.response.UserAccountResponse; import quick.pager.shop.utils.Assert; import quick.pager.shop.utils.DateUtils; /** * SettlementOrderServiceImpl * * @author siguiyang */ @Service @Slf4j public class SettlementOrderServiceImpl implements SettlementOrderService { @Autowired private DiscountCouponClient discountCouponClient; @Autowired private UserOrderClient userOrderClient; @Autowired private SellerOrderClient sellerOrderClient; @Autowired private CartClient cartClient; @Autowired private OrderCartClient orderCartClient; @Autowired private OrderTradeClient orderTradeClient; @Autowired private AddressClient addressClient; @Autowired private UserAccountClient userAccountClient; @Autowired private GoodsSkuClient goodsSkuClient; @Autowired private RedissonClient redissonClient; @Autowired private RedisTemplate<String, Object> redisTemplate; @Value(("${spring.profiles.active}")) private String env; @Override public Response<SettlementSkuResponse> check(final SettlementCheckRequest request) { final Long userId = request.getUserId(); final List<Long> goodsCartIds = request.getGoodsCartIds(); final BigDecimal settlementAmount = request.getSettlementAmount(); CartOtherRequest cartOtherReq = new CartOtherRequest(); cartOtherReq.setGoodsCartIds(goodsCartIds); Response<List<GoodsCartResponse>> cartOtherRes = cartClient.list(cartOtherReq); if (!cartOtherRes.check()) { return Response.toError(cartOtherRes.getCode(), cartOtherRes.getMsg()); } List<GoodsCartResponse> cartOtherResData = cartOtherRes.getData(); cartOtherResData.stream().map(item -> item.getDiscountAmount().multiply(BigDecimal.valueOf(item.getQuantity()))).reduce(BigDecimal::add).ifPresent(amount -> Assert.isTrue(amount.compareTo(settlementAmount) == 0, () -> "结算金额与清结算金额不一致")); // 组装数据，并返回 SettlementSkuResponse settlementSkuRes = new SettlementSkuResponse(); // 1. 组装配送地址 Response<AddressResponse> addressRes = addressClient.address(userId); AddressResponse addressResData = addressRes.getData(); if (addressRes.check() && Objects.nonNull(addressResData)) { SettlementAddrDTO addr = new SettlementAddrDTO(); addr.setId(addressResData.getId()); addr.setAddrName(addressResData.getDeliveryAddress().concat(addressResData.getHouseNumber())); addr.setDefaultAddress(addressResData.getDefaultAddress()); addr.setLabel(addressResData.getLabel()); settlementSkuRes.setAddr(addr); } // 2. 设置配送时间 settlementSkuRes.setDeliveryTime(this.getDeliveryTime()); // 3. 购买商品 settlementSkuRes.setSkus(this.doSkus(cartOtherResData)); // 4. 支付方式 settlementSkuRes.setPayTypes(this.doPayType()); // 5. 优惠券 settlementSkuRes.setCoupons(this.doDiscountCoupon(userId)); // 6. 商品总金额 BigDecimal orderAmount = cartOtherResData.stream().map(GoodsCartResponse::getDiscountAmount).reduce(BigDecimal.ZERO, BigDecimal::add); settlementSkuRes.setOrderAmount(orderAmount); // 7. 配送费 BigDecimal deliveryAmount = this.getDeliveryAmount(); settlementSkuRes.setDeliveryAmount(deliveryAmount); // 8. 是否免配送费 settlementSkuRes.setFreeDeliveryAmount(this.getFreeDeliveryAmount(orderAmount)); // 9. 用户积分 settlementSkuRes.setIntegral(this.getIntegral(userId)); return Response.toResponse(settlementSkuRes); } @Override @GlobalTransactional public Response<Long> createOrder(final SettlementRequest request) { final Long userId = request.getUserId(); final Long sellerId = request.getSellerId(); final List<SettlementSkuRequest> skus = request.getSkus(); final Integer integral = request.getIntegral(); // 1. 幂等性验证 RLock lock = redissonClient.getLock(env.concat(SettlementRedisKeys.APP_SUBMIT_ORDER) + userId); // 用户订单主键 Long userOrderId = null; // 商户订单主键 Long sellerOrderId; try { if (lock.tryLock(3, TimeUnit.SECONDS)) { // 2. 生成用户订单 UserOrderSaveRequest userOrderSaveReq = new UserOrderSaveRequest(); userOrderSaveReq.setAddrId(request.getAddrId()); userOrderSaveReq.setCouponId(request.getCouponId()); userOrderSaveReq.setOrderStatus(OrderStatusEnums.BS001); userOrderSaveReq.setOrderType(OrderTypeEnums.parse(request.getOrderType())); userOrderSaveReq.setPayType(PayTypeEnums.par