Spring Cloud + Seata(TCC) + JPA/MyBatis

package com.saint.order.service.impl; import com.alibaba.fastjson.JSONObject; import com.saint.order.entity.Order; import com.saint.order.feign.StockFeignClient; import com.saint.order.repository.OrderDAO; import com.saint.order.repository.OrderMapper; import com.saint.order.service.OrderService; import io.seata.core.context.RootContext; import io.seata.rm.tcc.api.BusinessActionContext; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; /** * @author Saint */ @Service @Slf4j @RequiredArgsConstructor(onConstructor = @_(@Autowired)) public class OrderServiceImpl implements OrderService { private final StockFeignClient stockFeignClient; private final OrderDAO orderDAO; private final OrderMapper orderMapper; @Autowired private RedisTemplate<String, String> redisTemplate; @Transactional public void create(String userId, String commodityCode, Integer orderCount) { log.info("start TCC, xid = " + RootContext.getXID()); BigDecimal orderMoney = new BigDecimal(orderCount).multiply(new BigDecimal(5)); Order order = new Order(); order.setUserId(userId); order.setCommodityCode(commodityCode); order.setCount(orderCount); order.setMoney(orderMoney); Order savedOrder = orderDAO.save(order); stockFeignClient.deduct(commodityCode, orderCount); // 在redis中保存订单详情！ redisTemplate.opsForValue().set("order::", JSONObject.toJSONString(savedOrder)); } @Override @Transactional public boolean commitCreate(BusinessActionContext context) { log.info("start commit, xid = " + context.getXid()); // todo 如果一阶段是资源预留，这里则要提交资源 return true; } @Override @Transactional public boolean rollbackCreate(BusinessActionContext context) { log.info("start rollback, xid = {}, context = {}", context.getXid(), JSONObject.toJSONString(context)); // todo 如果一阶段是资源预留，这里则要释放资源、做非关系型数据库的回滚操作； // 对于MQ等中间件的回滚 要依赖try执行之前的BusinessActionContext数据（方法的入参），因为无法直接获取到try执行时产生的数据 String commodityCode = context.getActionContext("commodityCode").toString(); String userId = context.getActionContext("userId").toString(); log.info("commodityCode = {}, userId = {}", commodityCode, userId); // orderDAO.deleteByUserIdAndCommodityCode(userId, commodityCode); Integer deleteRows = orderMapper.deleteOrderByCodeAndUserId(commodityCode, Integer.valueOf(userId)); log.info("delete rows: {}", deleteRows); redisTemplate.delete("order::"); return true; } }