import org.dbflute.hook.AccessContext; //导入依赖的package包/类
@Override
public Statement apply(final Statement base, final Description description) {
    return new Statement() {
        @Override
        public void evaluate() throws Throwable {
            accessContext = new AccessContext();
            accessContext.setAccessUser(user);
            accessContext.setAccessProcess(process);
            accessContext.setAccessModule(module);
            timestamp = defaultTimestamp;
            accessContext.setAccessDateProvider(new AccessDateProvider());
            accessContext.setAccessTimestampProvider(new AccessTimestampProvider());
            accessContext.setAccessLocalDateProvider(new AccessLocalDateProvider());
            accessContext.setAccessLocalDateTimeProvider(new AccessLocalDateTimeProvider());
            AccessContext.setAccessContextOnThread(accessContext);

            base.evaluate();
        }
    };
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
protected Runnable createRunnable(ConcurrentAsyncCall call, String keyword) { // in caller thread
    final Map<String, Object> threadCacheMap = inheritThreadCacheContext(call);
    final AccessContext accessContext = inheritAccessContext(call);
    final CallbackContext callbackContext = inheritCallbackContext(call);
    final Map<String, Object> variousContextMap = findCallerVariousContextMap();
    return () -> { // in new thread
        prepareThreadCacheContext(call, threadCacheMap);
        preparePreparedAccessContext(call, accessContext);
        prepareCallbackContext(call, callbackContext);
        final Object variousPreparedObj = prepareVariousContext(call, variousContextMap);
        final long before = showRunning(keyword);
        Throwable cause = null;
        try {
            call.callback();
        } catch (Throwable e) {
            handleAsyncCallbackException(call, before, e);
            cause = e;
        } finally {
            showFinishing(keyword, before, cause); // should be before clearing because of using them
            clearVariousContext(call, variousContextMap, variousPreparedObj);
            clearCallbackContext(call);
            clearPreparedAccessContext(call);
            clearThreadCacheContext(call);
        }
    };
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Clear various contexts that might be initialized in action just in case
 */
public void clearContextJustInCase() {
    TransactionTimeContext.clear();
    PreparedAccessContext.clearAccessContextOnThread();
    AccessContext.clearAccessContextOnThread();
    CallbackContext.clearCallbackContextOnThread();
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Set prepared access-context on thread.
 * @param accessContext The context of DB access. (NotNull)
 */
public static void setAccessContextOnThread(AccessContext accessContext) {
    if (accessContext == null) {
        String msg = "The argument[accessContext] must not be null.";
        throw new IllegalArgumentException(msg);
    }
    Stack<AccessContext> stack = threadLocal.get();
    if (stack == null) {
        stack = new Stack<AccessContext>();
        threadLocal.set(stack);
    }
    stack.add(accessContext);
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Clear prepared access-context on thread.
 */
public static void clearAccessContextOnThread() {
    final Stack<AccessContext> stack = threadLocal.get();
    if (stack != null) {
        stack.pop(); // remove latest
        if (stack.isEmpty()) {
            perfectlyClear();
        }
    }
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Begin access-context use for DBFlute. <br>
 * You can update entities after calling this.
 */
public static void beginAccessContext() {
    if (AccessContext.isExistAccessContextOnThread()) { // suspend
        SuspendedAccessContext.setAccessContextOnThread(AccessContext.getAccessContextOnThread());
    }
    AccessContext.setAccessContextOnThread(getAccessContextOnThread());
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * End access-context use for DBFlute.
 */
public static void endAccessContext() {
    AccessContext.clearAccessContextOnThread();
    final AccessContext accessContext = SuspendedAccessContext.getAccessContextOnThread();
    if (accessContext != null) { // resume
        AccessContext.setAccessContextOnThread(accessContext);
        SuspendedAccessContext.clearAccessContextOnThread();
    }
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Clear prepared access-context on thread.
 */
public static void clearAccessContextOnThread() {
    final Stack<AccessContext> stack = threadLocal.get();
    if (stack != null) {
        stack.pop();
        if (stack.isEmpty()) {
            perfectlyClear();
        }
    }
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
public AccessContext create(AccessContextResource resource, UserTypeSupplier userTypeSupplier, UserInfoSupplier userInfoSupplier,
        AppTypeSupplier appTypeSupplier) {
    final AccessContext context = new AccessContext();
    context.setAccessLocalDateTimeProvider(() -> timeManager.currentDateTime());
    context.setAccessUserProvider(() -> buildAccessUserTrace(resource, userTypeSupplier, userInfoSupplier, appTypeSupplier));
    return context;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
protected AccessContext createAccessContext() {
    AccessContext accessContext = new AccessContext();
    accessContext.setAccessLocalDateTimeProvider(LocalDateTime::now);
    accessContext.setAccessUserProvider(() -> {
        return getAccessUser(Http.Context.current.get());
    });
    return accessContext;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
@Override
public void save(AccessContext accessContext) {
    if (Http.Context.current.get() == null) {
        final Application application = applicationProvider.get();
        if (application.isTest()) {
            threadLocalAccessContext.set(accessContext);
            return;
        }
    }
    Http.Context.current().args.put(Constants.CTX_ARGS_KEY_ACCESS_CONTEXT, accessContext);
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
@Override
public AccessContext provide() {
    if (Http.Context.current.get() == null) {
        final Application application = applicationProvider.get();
        if (application.isTest()) {
            return threadLocalAccessContext.get();
        }
    }
    return (AccessContext)Http.Context.current().args.get(Constants.CTX_ARGS_KEY_ACCESS_CONTEXT);
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
public static void setAccessContextInTest() {
    // DBFlute AccessContextの設定
    AccessContext accessContext = new AccessContext();
    accessContext.setAccessLocalDateTimeProvider(LocalDateTime::now);
    accessContext.setAccessUser("TESTUSER");
    AccessContext.setAccessContextOnThread(accessContext);
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Arrange prepared access context for DBFlute, which is used for common columns setup. <br>
 * This is called by callback process so you should NOT call this directly in your action.
 * @param runtime The runtime meta of action execute. (NotNull)
 */
protected void arrangePreparedAccessContext(ActionRuntime runtime) { // called by callback
    final AccessContextResource resource = createAccessContextResource(runtime);
    final AccessContext accessContext = accessContextArranger.arrangePreparedAccessContext(resource);
    PreparedAccessContext.setAccessContextOnThread(accessContext);
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Get prepared access-context on thread.
 * @return The context of DB access. (NullAllowed)
 */
public static AccessContext getAccessContextOnThread() {
    final Stack<AccessContext> stack = threadLocal.get();
    return stack != null ? stack.peek() : null;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Is existing prepared access-context on thread?
 * @return The determination, true or false.
 */
public static boolean existsAccessContextOnThread() {
    final Stack<AccessContext> stack = threadLocal.get();
    return stack != null ? !stack.isEmpty() : false;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
/**
 * Is existing prepared access-context on thread?
 * @return The determination, true or false.
 */
public static boolean isExistAccessContextOnThread() {
    final Stack<AccessContext> stack = threadLocal.get();
    return stack != null ? !stack.isEmpty() : false;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
protected AccessContext inheritAccessContext(ConcurrentAsyncCall call) { // null allowed
    return doInheritAccessContext();
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
protected AccessContext doInheritAccessContext() { // null allowed
    final AccessContext src = PreparedAccessContext.getAccessContextOnThread(); // null allowed
    if (src == null) {
        return null;
    }
    final AccessContext dest = newAccessContext();
    dest.setAccessDate(src.getAccessDate());
    dest.setAccessDateProvider(src.getAccessDateProvider());
    dest.setAccessTimestamp(src.getAccessTimestamp());
    dest.setAccessTimestampProvider(src.getAccessTimestampProvider());
    dest.setAccessLocalDate(src.getAccessLocalDate());
    dest.setAccessLocalDateProvider(src.getAccessLocalDateProvider());
    dest.setAccessLocalDateTime(src.getAccessLocalDateTime());
    dest.setAccessLocalDateTimeProvider(src.getAccessLocalDateTimeProvider());
    final String accessUser = src.getAccessUser();
    if (accessUser != null) {
        dest.setAccessUser(accessUser);
    } else {
        final AccessUserProvider accessUserProvider = src.getAccessUserProvider();
        if (accessUserProvider != null) {
            dest.setAccessUser(accessUserProvider.provideUser()); // fixed
        }
    }
    final String accessProcess = src.getAccessProcess();
    if (accessProcess != null) {
        dest.setAccessProcess(accessProcess);
    } else {
        final AccessProcessProvider accessProcessProvider = src.getAccessProcessProvider();
        if (accessProcessProvider != null) {
            dest.setAccessProcess(accessProcessProvider.provideProcess()); // fixed
        }
    }
    final String accessModule = src.getAccessModule();
    if (accessModule != null) {
        dest.setAccessModule(accessModule);
    } else {
        final AccessModuleProvider accessModuleProvider = src.getAccessModuleProvider();
        if (accessModuleProvider != null) {
            dest.setAccessModule(accessModuleProvider.provideModule()); // fixed
        }
    }
    final Map<String, Object> accessValueMap = src.getAccessValueMap();
    if (accessValueMap != null) {
        for (Entry<String, Object> entry : accessValueMap.entrySet()) {
            dest.registerAccessValue(entry.getKey(), entry.getValue());
        }
    }
    return dest;
}
 

import org.dbflute.hook.AccessContext; //导入依赖的package包/类
protected AccessContext newAccessContext() {
    return new AccessContext();
}