package com.xiaopeng.itinerary.controller;
|
|
import com.xiaopeng.api.feignClient.order.XpOrderClient;
|
import com.xiaopeng.api.model.order.XpOrder;
|
import com.xiaopeng.common.core.domain.R;
|
import io.seata.spring.annotation.GlobalTransactional;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.shardingsphere.transaction.annotation.ShardingSphereTransactionType;
|
import org.apache.shardingsphere.transaction.core.TransactionType;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.time.LocalDateTime;
|
|
/**
|
* Seata 分布式事务测试接口
|
*/
|
@Slf4j
|
@RestController
|
@RequestMapping("/test/seata")
|
@Api(tags = "Seata分布式事务测试")
|
public class SeataTestController {
|
|
@Resource
|
private XpOrderClient xpOrderClient;
|
|
/**
|
* 测试分布式事务 - 正常提交
|
* 调用order服务创建订单，正常返回，事务提交
|
*/
|
@GetMapping("/commit")
|
@ApiOperation("测试分布式事务-正常提交")
|
@GlobalTransactional(name = "seata-test-commit", rollbackFor = Exception.class)
|
public R<Long> testCommit() {
|
XpOrder order = buildTestOrder();
|
log.info("[Seata测试] 开始创建测试订单，事务正常提交场景");
|
R<Long> result = xpOrderClient.addOrder(order);
|
log.info("[Seata测试] 订单创建结果: code={}, orderId={}", result.getCode(), result.getData());
|
return R.ok(result.getData(), "分布式事务正常提交成功，订单ID: " + result.getData());
|
}
|
|
/**
|
* 测试分布式事务 - 回滚
|
* 调用order服务创建订单后，手动抛异常触发全局回滚
|
* 验证：调用后去数据库查，订单应该不存在
|
*/
|
@GetMapping("/rollback")
|
@ApiOperation("测试分布式事务-回滚")
|
@Transactional
|
@ShardingSphereTransactionType(TransactionType.BASE)
|
public R<String> testRollback() {
|
XpOrder order = buildTestOrder();
|
log.info("[Seata测试] 开始创建测试订单，事务回滚场景");
|
R<Long> result = xpOrderClient.addOrder(order);
|
log.info("[Seata测试] 订单已创建 orderId={}，即将抛出异常触发回滚...", result.getData());
|
// 故意抛异常，触发Seata全局事务回滚
|
throw new RuntimeException("[Seata测试] 模拟业务异常，触发分布式事务回滚");
|
}
|
|
private XpOrder buildTestOrder() {
|
LocalDateTime now = LocalDateTime.now();
|
XpOrder order = new XpOrder();
|
// 主键由数据库或框架生成，不设置
|
order.setAppUserId(99999L);
|
order.setCityId(1L);
|
order.setVehicleId(1001L);
|
order.setFleetId(1L);
|
order.setOrderNumber("SEATA_TEST_" + System.currentTimeMillis());
|
order.setTransactionId("TXN_SEATA_TEST_" + System.currentTimeMillis());
|
order.setOrderSource(1);
|
order.setRideTime(now);
|
|
// 下单地点（深圳南山）
|
order.setPlacementLon(113.934528);
|
order.setPlacementLat(22.530381);
|
order.setPlacementAddress("Seata分布式事务测试-下单地点");
|
|
// 出发地
|
order.setStartLon(113.934528);
|
order.setStartLat(22.530381);
|
order.setStartAddress("测试起点-科技园");
|
|
// 目的地
|
order.setEndLon(113.944528);
|
order.setEndLat(22.540381);
|
order.setEndAddress("测试终点-深圳湾");
|
|
// 上车点
|
order.setBoardingLon(113.934528);
|
order.setBoardingLat(22.530381);
|
order.setBoardingAddress("测试上车点-科技园地铁站");
|
order.setBoardingTime(now);
|
|
// 下车点
|
order.setGetoffLon(113.944528);
|
order.setGetoffLat(22.540381);
|
order.setGetoffAddress("测试下车点-深圳湾公园");
|
order.setGetoffTime(now.plusMinutes(15));
|
|
// 支付信息
|
order.setPayType(1);
|
order.setOrderMoney(new BigDecimal("25.00"));
|
order.setPayMoney(new BigDecimal("20.00"));
|
order.setPrepayMoney(new BigDecimal("25.00"));
|
|
// 后备箱
|
order.setOpenTrunk(0);
|
|
// 里程费用
|
order.setStartMileage(3.0);
|
order.setStartMoney(new BigDecimal("10.00"));
|
order.setMileageKilometers(5.5);
|
order.setMileageMoney(new BigDecimal("8.00"));
|
|
// 时长费用
|
order.setDuration(15.0);
|
order.setDurationType(1);
|
order.setDurationMoney(new BigDecimal("5.00"));
|
|
// 等待费用
|
order.setWait(2.0);
|
order.setWaitMoney(new BigDecimal("2.00"));
|
|
// 远途费用
|
order.setLongDistance(0.0);
|
order.setLongDistanceType(1);
|
order.setLongDistancemoney(new BigDecimal("0.00"));
|
|
// 优惠
|
order.setRedPacketMoney(new BigDecimal("3.00"));
|
order.setCouponMoney(new BigDecimal("2.00"));
|
order.setRedPacketId(0L);
|
order.setCouponId(0L);
|
|
// 订单状态：待接单
|
order.setStatus(1);
|
|
// 城市信息
|
order.setCityName("深圳市");
|
order.setCityCode("440300");
|
|
// 站点信息
|
order.setStartPointId(1L);
|
order.setEndPointId(2L);
|
order.setStartPointName("科技园站");
|
order.setEndPointName("深圳湾站");
|
|
// 预估时间
|
order.setEstimatedTime(now.plusMinutes(20));
|
|
// 区域与时段
|
order.setXpElectronicFenceAreaId(1L);
|
order.setTimeSlot("08:00-10:00");
|
|
// 车辆到达、接单、行程时间
|
order.setArrivalTime(now.plusMinutes(5));
|
order.setAcceptanceTime(now);
|
order.setTripBegin(now.plusMinutes(5));
|
order.setTripEnd(now.plusMinutes(20));
|
|
// 队列名称
|
order.setQueueName("default_queue");
|
|
// BaseModel 字段（通常自动填充，这里显式设置避免null）
|
order.setCreateBy("seata-test");
|
order.setCreateTime(now);
|
order.setUpdateBy("seata-test");
|
order.setUpdateTime(now);
|
order.setDeleted(false);
|
|
return order;
|
}
|
|
}
|
