分布式事务资料提供的微服务

package cn.itcast.order.service.impl; import cn.itcast.order.client.AccountClient; import cn.itcast.order.client.StorageClient; import cn.itcast.order.entity.Order; import cn.itcast.order.mapper.OrderMapper; import cn.itcast.order.service.OrderService; import feign.FeignException; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; /** * @author 虎哥 */ @Slf4j @Service public class OrderServiceImpl implements OrderService { private final AccountClient accountClient; private final StorageClient storageClient; private final OrderMapper orderMapper; public OrderServiceImpl(AccountClient accountClient, StorageClient storageClient, OrderMapper orderMapper) { this.accountClient = accountClient; this.storageClient = storageClient; this.orderMapper = orderMapper; } @Override @Transactional public Long create(Order order) { // 创建订单 orderMapper.insert(order); try { // 扣用户余额 accountClient.deduct(order.getUserId(), order.getMoney()); // 扣库存 storageClient.deduct(order.getCommodityCode(), order.getCount()); } catch (FeignException e) { log.error("下单失败，原因:{}", e.contentUTF8(), e); throw new RuntimeException(e.contentUTF8(), e); } return order.getId(); } }