@Service
public class OrderServiceImpl implements OrderService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private ProductMapper productMapper;
    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private KafkaTemplate kafkaTemplate;

    /**
     *  购买商品，提交订单
     * @param userId      用户ID
     * @param productId   商品ID
     * @return
     */
    public Result submit(Long userId, Long productId) throws BizException {
        // 验证账号
        UserDO userDO = userMapper.findById(userId);
        if (userDO == null) {
            throw BizException(USER_NOT_EXISTS);
        }
        // 查看商品信息及打折信息
        ProductDO productDO = productMapper.findById(productId);
        Double delta = HttpUtils.getDiscount(productId);
        double actualPayment = productDO.getPrice() - delta;
        Money money = userDO.getMoney();
        if (actualPayment > money.getRemain()) {
            // 如果商品价格 - 优惠价格 > 用户钱包，则说明不够付
            return Result.fail("余额不足");
        }
        // 钱包够付，扣除金额
        double remain = money.getRemain() - actualPayment;
        money.setRemain(remain);
        // 更新账号钱包余额
        userMapper.update(userDO);
        // 生成订单信息
        OrderDO orderDO = new OrderDO();
        orderDO.setUserId(userId);
        orderDO.setProductId(productId);
        orderMapper.save(orderDO);
        // 通知用户订单已生成，等待收货
        kafkaTemplate.send("orderTopic", orderDO);
        return Result.ok();
    }
}

public interface UserRepository {
    User findById(Long userId);
}

public class Money {
    private double remain;
    public double getRemain() {
        return remain;
    }
    public void setRemain(double remain) {
        this.remain = remain;
    }
    /**
     * 扣费
     * @param delta
     * @return
     */
    public boolean charge(double delta) {
        if (remain < delta) {
            return false;
        }
        this.remain -= delta;
        return true;
    }
}

/**
 * 防腐层/适配层
 */
@Service
public class PayServiceImpl implements PayService {

    @Autowired
    private DiscountFacade discountFacade;

    /**
     *  支付
     * @param money
     * @param product
     * @return
     */
    public boolean pay(Money money, Product product) {
        // 获取优惠
        Double delta = discountFacade.getDiscount(product.getId());
        // 扣除费用
        return money.charge(product.getPrice() - delta);
    }
}

public interface MessageProducer<T, R> {
    Result<R> send(T message);
}

@Autowired
private UserRepository userRepository;
@Autowired
private ProductRepository productRepository;
@Autowired
private OrderRepository orderRepository;
@Autowired
private MessageProducer<Order,Result> messageProducer;
@Autowired
private PayService payService;

/**
 * 购买商品，提交订单
 * @param userId      用户ID
 * @param productId   商品ID
 * @return
 */
public Result submit(Long userId, Long productId) throws BizException {
    // 验证
    User user = userRepository.findByUserId(userId);
    if (user == null) {
        throw BizException(USER_NOT_EXISTS);
    }
    // 支付
    Product product = productRepository.findById(productId);
    boolean f = payService.pay(user.getMoney(), product);
    if (!f) {
        return Result.fail("费用扣除失败");
    }
    // 更新账户
    userRepository.update(user);
    // 生成订单信息
    Order order = OrderFactory.create(user, product);
    orderRepository.add(order);
    // 通知用户订单已生成，等待收货
    messageProducer.send(order);
    return Result.ok();
}