调整打印格式，调整获取startSate位置

Author: xlorne

tx-client/src/main/java/com/codingapi/tx/aop/service/impl/TxStartTransactionServerImpl.java

@@ -108,6 +108,8 @@ public void run0() {
                             if(waitTask.getState()== TaskState.connectionError.getCode()){
                                 //本地执行失败.
                                 executeConnectionError = 1;
+
+                                lastState = 0;
                             }
                         }
 

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/relational/AbstractTransactionThread.java

@@ -27,16 +27,17 @@ public void run0() {
                 try {
                     transaction();
                 } catch (Exception e) {
+                    logger.error(e.getMessage());
                     try {
                         rollbackConnection();
                     } catch (SQLException e1) {
-                        e1.printStackTrace();
+                        logger.error(e1.getMessage());
                     }
                 } finally {
                     try {
                         closeConnection();
                     } catch (SQLException e) {
-                        e.printStackTrace();
+                        logger.error(e.getMessage());
                     }
                 }
             }

tx-plugins-db/src/main/java/com/codingapi/tx/datasource/relational/LCNStartConnection.java

@@ -35,6 +35,8 @@ public class LCNStartConnection extends AbstractTransactionThread implements LCN
 
     private boolean isCompensate = false;
 
+    private int startState = 0;
+
     private ThreadLocal<Boolean> isClose = new ThreadLocal<>();
 
 
@@ -53,6 +55,8 @@ public LCNStartConnection(Connection connection, ICallClose<ILCNResource> subNow
 
             TaskGroup taskGroup = TaskGroupManager.getInstance().createTask(groupId,txCompensateLocal.getType());
             waitTask = taskGroup.getCurrent();
+
+            startState = txCompensateLocal.getStartState();
         }else{
             isCompensate = false;
             logger.info("transaction is start-connection.");
@@ -153,8 +157,8 @@ public void transaction()throws SQLException{
             if (rs == 1) {
                 if(isCompensate) {
                     //补偿时需要根据补偿数据决定提交还是回滚.
-                    int starState = TxCompensateLocal.current().getStartState();
-                    if(starState==1) {
+                    rs = startState;
+                    if(rs==1) {
                         connection.commit();
                     }else{
                         connection.rollback();
@@ -165,7 +169,7 @@ public void transaction()throws SQLException{
             } else {
                 rollbackConnection();
             }
-            System.out.println(" lcn start transaction over, res -> groupId:"+getGroupId()+" and  state is "+rs+", about state (1:commit 0:rollback)");
+            System.out.println(" lcn start transaction over, res -> groupId:"+getGroupId()+" and  state is "+(rs==1?"commit":"rollback"));
 
         }catch (SQLException e){