Initial commit: bositao cloud (jnpf-java-cloud-v6x)

刘光辉

4 小时以前 06f314545ac3514d7ce28939920866ae8188d31c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
package jnpf.flowable.model.util;
 
/** Server-only, single-operator attribution for the development approval tool. */
public final class DevApprovalActor implements AutoCloseable {
    private static final ThreadLocal<DevApprovalActor> CURRENT = new ThreadLocal<>();
    private final String operatorId;
    private final String actorId;
    private final String taskId;
 
    private DevApprovalActor(String operatorId, String actorId, String taskId) {
        this.operatorId = operatorId;
        this.actorId = actorId;
        this.taskId = taskId;
    }
 
    public static DevApprovalActor open(String operatorId, String actorId) {
        return open(operatorId, actorId, null);
    }
 
    public static DevApprovalActor open(String operatorId, String actorId, String taskId) {
        if (CURRENT.get() != null) throw new IllegalStateException("Nested development approval");
        DevApprovalActor scope = new DevApprovalActor(operatorId, actorId, taskId);
        CURRENT.set(scope);
        return scope;
    }
 
    public static String resolve(String operatorId, String assignedActor) {
        DevApprovalActor scope = CURRENT.get();
        return scope != null && scope.operatorId.equals(operatorId) ? scope.actorId : assignedActor;
    }
 
    /** Candidate override is confined to the workflow validated by the development service. */
    public static String candidateForTask(String taskId) {
        DevApprovalActor scope = CURRENT.get();
        return scope != null && taskId != null && taskId.equals(scope.taskId) ? scope.actorId : null;
    }
 
    public static boolean active() { return CURRENT.get() != null; }
 
    public static boolean isActing(String operatorId, String callerId) {
        DevApprovalActor scope = CURRENT.get();
        return scope != null && scope.operatorId.equals(operatorId) && scope.actorId.equals(callerId);
    }
 
    @Override
    public void close() {
        CURRENT.remove();
    }
}