加入问卷 标题

java110

2021-02-05 35700e8cd5f2b25b672a9d62c170bc3f49a6ef1d

 java110-core/src/main/java/com/java110/core/factory/Java110TransactionalFactory.java

@@ -8,7 +8,11 @@
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.*;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpMethod;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.HttpStatusCodeException;
import org.springframework.web.client.RestTemplate;

@@ -97,6 +101,21 @@
    }

    /**
     * 清理事务
     */
    public static void clearOId() {
        //清理事务
        if(!StringUtil.isEmpty(getOId())) {
            remove(O_ID);
        }
        //清理角色
        if(!StringUtil.isEmpty(getServiceRole())) {
            remove(SERVICE_ROLE);
        }

    }

    /**
     * 获取事务ID
     *
     * @return
@@ -153,6 +172,7 @@
     * 处理失败，回退事务
     */
    public static void fallbackOId() {

        String oId = getOId();
        if (StringUtil.isEmpty(oId) || ROLE_OBSERVER.equals(getServiceRole())) {
            //当前没有开启事务无需回退