SpringBoot事务异步调用引发的bug解决

@Service
public class TaskService {
    @Transactional(rollbackFor = Exception.class)
    public String saveExportTask() {
        // 1. save export task
        // 2. save export task history 
        // 3. execute xxl-job
    }
}

@RestController
public class TaskController {
    @Resource TaskService taskService;
    @PostMapping
    public String save() {
        taskService.saveExportTask();
    }
}

@RestController
public class TaskController {
    @Resource TaskService taskService;
    @PostMapping
    public String save() {
        taskService.saveExportTask();
        // 3. execute xxl-job
    }
}

@Service
public class TaskService {
    @Transactional(rollbackFor = Exception.class)
    public String saveExportTask() {
        // 1. save export task
        // 2. save export task history 
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter(){
            public void afterCommit(){
                System.out.println("commit!!!");
                // 3. execute xxl-job
            }
        });
    }
}

@Component
public class TaskEventListener {
   @Autowired
   private TaskService taskService;
   @TransactionalEventListener
   public void handleOrderCreatedEvent(TaskCreatedEvent event) {
      Task task = event.getTask();
      // 处理订单创建事件
      try {
         taskService.processOrder(task);
      } catch (Exception e) {
         // 处理失败，抛出异常，事务回滚
         throw new RuntimeException(e);
      }
   }
   @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
   public void handleOrderCompletedEvent(TaskCompletedEvent event) {
      Task task = event.getTask();
      // 处理订单完成事件
      try {
         taskService.sendOrderConfirmationEmail(task);
      } catch (Exception e) {
         // 处理失败，不影响事务
         e.printStackTrace();
      }
   }
}

public class TaskCompletedEvent {
   private Task task;
   public TaskCompletedEvent(Task task) {
      this.task = task;
   }
   public Task getTask() {
      return task;
   }
}