feature : SAGA annotation mode

common/src/main/java/io/seata/common/Constants.java

@@ -160,5 +160,10 @@ public interface Constants {
      * The constant SKIP_CHECK_LOCK
      */
     String SKIP_CHECK_LOCK = "skipCheckLock";
+
+    /**
+     * The constant MODE_TYPE
+     */
+    String MODE_TYPE = "modeType";
 
 }

tcc/src/main/java/io/seata/rm/tcc/TCCResourceManager.java

@@ -32,6 +32,7 @@
 import io.seata.core.model.Resource;
 import io.seata.rm.AbstractResourceManager;
 import io.seata.rm.tcc.api.BusinessActionContext;
+import io.seata.rm.tcc.api.ModeType;
 
 /**
  * TCC resource manager
@@ -97,6 +98,14 @@ public BranchStatus branchCommit(BranchType branchType, String xid, long branchI
             //BusinessActionContext
             BusinessActionContext businessActionContext = getBusinessActionContext(xid, branchId, resourceId,
                 applicationData);
+
+            // if the TwoPhaseBusinessAction annotation's mode is SAGA, cancel the commit
+            ModeType modeType = (ModeType) businessActionContext.getActionContext(Constants.MODE_TYPE);
+            if(modeType != null && modeType.equals( ModeType.SAGA)) {
+                LOGGER.info("TwoPhaseBusinessAction's ModeType is SAGA, cancel the commit, xid: {}, branchId: {}, resourceId: {}", xid, branchId, resourceId);
+                return BranchStatus.PhaseTwo_Committed;
+            }
+
             Object[] args = this.getTwoPhaseCommitArgs(tccResource, businessActionContext);
             Object ret;
             boolean result;

tcc/src/main/java/io/seata/rm/tcc/api/ModeType.java

@@ -0,0 +1,18 @@
+package io.seata.rm.tcc.api;
+
+/**
+ * The enum ModeType
+ *
+ * @author ruishan
+ */
+public enum ModeType {
+
+    /**
+     * TCC Mode
+     */
+    TCC,
+    /**
+     * SAGA Mode
+     */
+    SAGA;
+}

tcc/src/main/java/io/seata/rm/tcc/api/TwoPhaseBusinessAction.java

@@ -87,4 +87,11 @@
      * @return the Class[]
      */
     Class<?>[] rollbackArgsClasses() default {BusinessActionContext.class};
+
+    /**
+     * Define TCC or SAGA mode
+     * 
+     * @return the mode
+     */
+    ModeType modeType() default ModeType.TCC;
 }

tcc/src/main/java/io/seata/rm/tcc/interceptor/ActionInterceptorHandler.java

@@ -237,6 +237,7 @@ protected void initBusinessContext(Map<String, Object> context, Method method,
             context.put(Constants.ROLLBACK_METHOD, businessAction.rollbackMethod());
             context.put(Constants.ACTION_NAME, businessAction.name());
             context.put(Constants.USE_TCC_FENCE, businessAction.useTCCFence());
+            context.put(Constants.MODE_TYPE, businessAction.modeType());
         }
     }