Approval WorkflowApproval Workflow

yêu cầu mới mỗi ngàynew requests a day

5k

yêu cầu mới mỗi ngàynew requests a day

cấp duyệt mỗi yêu cầuapproval levels per request

1–4

cấp duyệt mỗi yêu cầuapproval levels per request

SLA mỗi cấp trước khi escalateSLA per level before escalation

48h

SLA mỗi cấp trước khi escalateSLA per level before escalation

lưu audit logaudit log retention

7 năm

lưu audit logaudit log retention

Approval API nhận command, kiểm tra version rồi ghi trạng thái, audit và outbox trong một transaction. Rule Engine dựng chuỗi duyệt khi gửi. SLA Scheduler quét các bước quá hạn. Bật “Cấp 2 từ chối” hoặc “Quá SLA” để xem các nhánh còn lại.The Approval API takes commands, checks the version, then writes the state, the audit entry and the outbox row in one transaction. The Rule Engine builds the chain on submit. The SLA Scheduler scans overdue steps. Turn on “Level 2 rejects” or “SLA breach” to see the other paths.

1. 1

   Chuyển trạng thái không hợp lệIllegal transitions

   Mỗi trạng thái chỉ cho phép một số hành động: không thể duyệt yêu cầu đã REJECTED hay sửa yêu cầu đang IN_REVIEW. Bảng chuyển trạng thái nằm ở một chỗ, không rải if khắp service.Each state allows only certain actions: you cannot approve a REJECTED request or edit one that is IN_REVIEW. Keep the transition table in one place, not as if statements scattered across services.

   State
2. 2

   Chuỗi duyệt thay đổi theo luậtThe chain depends on rules

   Mỗi luật (số tiền, phòng ban, loại chi phí) là một mắt xích quyết định có thêm cấp duyệt hay không. Chuỗi được chụp lại vào bảng approval_step lúc gửi, nên đổi luật sau đó không ảnh hưởng yêu cầu đang chạy.Each rule (amount, department, cost type) is a link that decides whether to add a level. The chain is frozen into approval_step on submit, so later rule changes leave in-flight requests alone.

   Chain of Responsibility
3. 3

   Hai người duyệt cùng lúcTwo approvers at once

   Client gửi kèm version đã thấy. UPDATE … WHERE version = ? trả 0 dòng nghĩa là trạng thái đã đổi; API trả 409 và client tải lại.The client sends the version it saw. UPDATE … WHERE version = ? returning 0 rows means the state has moved on; the API answers 409 and the client reloads.

   Command
4. 4

   Duyệt song songParallel approval

   Các bước cùng cấp có mode ANY_OF hoặc ALL_OF. ANY_OF: một người duyệt là đủ, các bước còn lại thành SKIPPED. ALL_OF: chờ đủ, một người từ chối là dừng.Steps on the same level carry a mode, ANY_OF or ALL_OF. ANY_OF: one approval is enough and the rest become SKIPPED. ALL_OF: wait for everyone; one rejection stops it.

   State
5. 5

   Uỷ quyền và nghỉ phépDelegation and out of office

   Bảng delegation có khoảng thời gian hiệu lực. Khi kiểm quyền, người được uỷ quyền cũng được duyệt, nhưng audit ghi rõ “u09 thay mặt u05”.A delegation table holds a validity window. The permission check accepts the delegate too, but the audit entry says “u09 on behalf of u05”.

   Chain of Responsibility
6. 6

   Thông báo gắn chặt vào luồng duyệtNotifications coupled to the flow

   Mỗi lần chuyển trạng thái phát một sự kiện qua outbox; email, chat, webhook là các subscriber độc lập. Gửi mail lỗi không làm rollback quyết định duyệt.Every transition emits an event through the outbox; email, chat and webhooks are independent subscribers. A failed email never rolls back a decision.

   Observer

Một command Decide: tải yêu cầu, kiểm version và quyền, áp dụng chuyển trạng thái, ghi audit và phát sự kiện trong cùng transaction.One Decide command: load the request, check the version and the permission, apply the transition, write the audit entry and publish an event in the same transaction.

@Entity
public class ApprovalRequest {
    @Id private Long id;
    @Enumerated(EnumType.STRING) private RequestState state;
    private int currentLevel;
    @Version private long version;1
    // approveCurrentStep(), reject(), returnForChanges() check the state table
}

@Service
@RequiredArgsConstructor
public class ApprovalService {
    private final ApprovalRequestRepository requests;
    private final AuditLogRepository audit;
    private final DelegationService delegation;
    private final ApplicationEventPublisher events;

    @Transactional
    public void decide(DecideCommand cmd) {
        ApprovalRequest r = requests.findById(cmd.requestId()).orElseThrow();
        if (r.getVersion() != cmd.expectedVersion()) {2
            throw new StaleStateException(r.getVersion());     // 409 Conflict
        }
        ApprovalStep step = r.currentStep();
        if (!delegation.canAct(cmd.actorId(), step.assigneeId())) {
            throw new AccessDeniedException("not assigned to this step");
        }
        RequestState from = r.getState();
        switch (cmd.action()) {
            case APPROVE -> r.approveCurrentStep(cmd.actorId()); // next level or APPROVED3
            case REJECT -> r.reject(cmd.actorId());
            case RETURN -> r.returnForChanges(cmd.actorId());
        }
        audit.save(AuditEntry.of(r.getId(), cmd.actorId(), step.assigneeId(),
                cmd.action(), from, r.getState(), cmd.comment()));
        events.publishEvent(new RequestTransitioned(r.getId(), from, r.getState()));4
    }
}

var allowed = map[State]map[Action]bool{1
	InReview: {Approve: true, Reject: true, Return: true},
	Returned: {Submit: true},
	Draft:    {Submit: true},
}

var ErrStale = errors.New("request changed, reload")

func (s *Service) Decide(ctx context.Context, cmd DecideCmd) error {
	return s.tx.Do(ctx, func(tx Tx) error {
		r, err := tx.GetRequest(ctx, cmd.RequestID)
		if err != nil {
			return err
		}
		if !allowed[r.State][cmd.Action] {
			return fmt.Errorf("%s not allowed in %s", cmd.Action, r.State)
		}
		step := r.CurrentStep()
		if !s.delegation.CanAct(ctx, cmd.ActorID, step.AssigneeID) {
			return ErrForbidden
		}
		from := r.State
		r.Apply(cmd.Action, cmd.ActorID) // next level, APPROVED, REJECTED or RETURNED

		res, err := tx.Exec(ctx, `UPDATE approval_request
			SET state = $1, current_level = $2, version = version + 1
			WHERE id = $3 AND version = $4`,2
			r.State, r.CurrentLevel, r.ID, cmd.ExpectedVersion)
		if err != nil {
			return err
		}
		if n, _ := res.RowsAffected(); n == 0 {3
			return ErrStale // mapped to 409 by the handler
		}
		if err := tx.InsertAudit(ctx, Audit{RequestID: r.ID, Actor: cmd.ActorID,
			Action: cmd.Action, From: from, To: r.State, Comment: cmd.Comment}); err != nil {
			return err
		}
		return tx.InsertOutbox(ctx, "approval.events", Transitioned{r.ID, from, r.State})4
	})
}

Mỗi pattern mở bài học tương ứng trong menu Pattern.Each one opens its lesson in the Patterns menu.