bugfix: fix log in participant transaction role (#5594)

Author: Bughue

changes/en-us/2.0.0.md

@@ -57,6 +57,7 @@ The version is updated as follows:
 - [[#5558](https://github.com/seata/seata/pull/5558)] fix mariadb rollback failed
 - [[#5556](https://github.com/seata/seata/pull/5556)] fix oracle insert undolog failed
 - [[#5577](https://github.com/seata/seata/pull/5577)] fix grpc interceptor xid unbinding problem
+- [[#5594](https://github.com/seata/seata/pull/5594)] fix log in participant transaction role
 
 ### optimize：
 - [[#5208](https://github.com/seata/seata/pull/5208)] optimize throwable getCause once more

changes/zh-cn/2.0.0.md

@@ -55,6 +55,7 @@ Seata 是一款开源的分布式事务解决方案，提供高性能和简单
 - [[#5558](https://github.com/seata/seata/pull/5558)] 修复mariadb回滚失败的问题
 - [[#5556](https://github.com/seata/seata/pull/5556)] 修复 oracle 插入 undolog 失败问题
 - [[#5577](https://github.com/seata/seata/pull/5577)] 修复 grpc拦截器解绑xid失败问题
+- [[#5594](https://github.com/seata/seata/pull/5594)] 修复participant情况下的重复日志
 
 ### optimize：
 - [[#5208](https://github.com/seata/seata/pull/5208)] 优化多次重复获取Throwable#getCause问题

tm/src/main/java/io/seata/tm/api/DefaultGlobalTransaction.java

@@ -129,6 +129,9 @@ public void commit() throws TransactionException {
             return;
         }
         assertXIDNotNull();
+        if (LOGGER.isInfoEnabled()) {
+            LOGGER.info("transaction {} will be commit", xid);
+        }
         int retry = COMMIT_RETRY_COUNT <= 0 ? DEFAULT_TM_COMMIT_RETRY_COUNT : COMMIT_RETRY_COUNT;
         try {
             while (retry > 0) {
@@ -164,6 +167,9 @@ public void rollback() throws TransactionException {
             return;
         }
         assertXIDNotNull();
+        if (LOGGER.isInfoEnabled()) {
+            LOGGER.info("transaction {} will be rollback", xid);
+        }
 
         int retry = ROLLBACK_RETRY_COUNT <= 0 ? DEFAULT_TM_ROLLBACK_RETRY_COUNT : ROLLBACK_RETRY_COUNT;
         try {

tm/src/main/java/io/seata/tm/api/TransactionalTemplate.java

@@ -74,8 +74,8 @@ public Object execute(TransactionalExecutor business) throws Throwable {
                     // If transaction is existing, suspend it, and then begin new transaction.
                     if (existingTransaction(tx)) {
                         suspendedResourcesHolder = tx.suspend(false);
-                        tx = GlobalTransactionContext.createNew();
                     }
+                    tx = GlobalTransactionContext.createNew();
                     // Continue and execute with new transaction
                     break;
                 case SUPPORTS:
@@ -86,8 +86,8 @@ public Object execute(TransactionalExecutor business) throws Throwable {
                     // Continue and execute with new transaction
                     break;
                 case REQUIRED:
-                    // If current transaction is existing, execute with current transaction,
-                    // else continue and execute with new transaction.
+                    // If current transaction is existing, execute with current transaction,else create
+                    tx = GlobalTransactionContext.getCurrentOrCreate();
                     break;
                 case NEVER:
                     // If transaction is existing, throw exception.
@@ -110,13 +110,12 @@ public Object execute(TransactionalExecutor business) throws Throwable {
                     throw new TransactionException("Not Supported Propagation:" + propagation);
             }
 
-            // 1.3 If null, create new transaction with role 'GlobalTransactionRole.Launcher'.
-            if (tx == null) {
-                tx = GlobalTransactionContext.createNew();
-            }
-
             // set current tx config to holder
             GlobalLockConfig previousConfig = replaceGlobalLockConfig(txInfo);
+            
+            if (tx.getGlobalTransactionRole() == GlobalTransactionRole.Participant) {
+                LOGGER.info("join into a existing global transaction,xid={}", tx.getXid());
+            }
 
             try {
                 // 2. If the tx role is 'GlobalTransactionRole.Launcher', send the request of beginTransaction to TC,
@@ -211,9 +210,6 @@ private void commitTransaction(GlobalTransaction tx, TransactionInfo txInfo)
 
         try {
             triggerBeforeCommit();
-            if (LOGGER.isInfoEnabled()) {
-                LOGGER.info("transaction {} will be commit", tx.getXid());
-            }
             tx.commit();
             GlobalStatus afterCommitStatus = tx.getLocalStatus();
             TransactionalExecutor.Code code = TransactionalExecutor.Code.Unknown;
@@ -252,10 +248,6 @@ private void rollbackTransaction(GlobalTransaction tx, Throwable originalExcepti
 
         try {
             triggerBeforeRollback();
-            if (LOGGER.isInfoEnabled()) {
-                LOGGER.info("transaction {} will be rollback, cause by:{}", tx.getXid(),
-                    originalException.getMessage());
-            }
             tx.rollback();
             triggerAfterRollback();
         } catch (TransactionException txe) {