Documentation
¶
Index ¶
- Variables
- type FindAdminActionLogsHandler
- type FindAdminActionLogsQuery
- type FindAdminInstancesHandler
- type FindAdminInstancesQuery
- type FindAdminTasksHandler
- type FindAdminTasksQuery
- type FindAvailableFlowsHandler
- type FindAvailableFlowsQuery
- type FindFlowVersionsHandler
- type FindFlowVersionsQuery
- type FindFlowsHandler
- type FindFlowsQuery
- type FindMyCCRecordsHandler
- type FindMyCCRecordsQuery
- type FindMyCompletedTasksHandler
- type FindMyCompletedTasksQuery
- type FindMyInitiatedHandler
- type FindMyInitiatedQuery
- type FindMyPendingTasksHandler
- type FindMyPendingTasksQuery
- type GetAdminInstanceDetailHandler
- type GetAdminInstanceDetailQuery
- type GetFlowGraphHandler
- type GetFlowGraphQuery
- type GetMyInstanceDetailHandler
- type GetMyInstanceDetailQuery
- type GetMyPendingCountsHandler
- type GetMyPendingCountsQuery
Constants ¶
This section is empty.
Variables ¶
var Module = fx.Module( "vef:approval:query", fx.Provide( fx.Private, NewGetFlowGraphHandler, NewFindMyInitiatedHandler, NewFindMyPendingTasksHandler, NewFindMyCompletedTasksHandler, NewFindMyCCRecordsHandler, NewGetMyPendingCountsHandler, NewGetMyInstanceDetailHandler, NewFindAvailableFlowsHandler, NewFindAdminInstancesHandler, NewFindAdminTasksHandler, NewGetAdminInstanceDetailHandler, NewFindAdminActionLogsHandler, NewFindFlowsHandler, NewFindFlowVersionsHandler, ), fx.Invoke(registerHandlers), )
Module provides all query handlers and registers them with the Bus.
Functions ¶
This section is empty.
Types ¶
type FindAdminActionLogsHandler ¶
type FindAdminActionLogsHandler struct {
// contains filtered or unexported fields
}
FindAdminActionLogsHandler handles the FindAdminActionLogsQuery.
func NewFindAdminActionLogsHandler ¶
func NewFindAdminActionLogsHandler(db orm.DB) *FindAdminActionLogsHandler
NewFindAdminActionLogsHandler creates a new FindAdminActionLogsHandler.
type FindAdminActionLogsQuery ¶
type FindAdminActionLogsQuery struct {
cqrs.BaseQuery
page.Pageable
InstanceID string
TenantID string
}
FindAdminActionLogsQuery queries action logs for an instance with pagination.
type FindAdminInstancesHandler ¶
type FindAdminInstancesHandler struct {
// contains filtered or unexported fields
}
FindAdminInstancesHandler handles the FindAdminInstancesQuery.
func NewFindAdminInstancesHandler ¶
func NewFindAdminInstancesHandler(db orm.DB) *FindAdminInstancesHandler
NewFindAdminInstancesHandler creates a new FindAdminInstancesHandler.
type FindAdminInstancesQuery ¶
type FindAdminInstancesQuery struct {
cqrs.BaseQuery
page.Pageable
TenantID string
ApplicantID string
Status string
FlowID string
Keyword string
}
FindAdminInstancesQuery queries instances for admin management.
type FindAdminTasksHandler ¶
type FindAdminTasksHandler struct {
// contains filtered or unexported fields
}
FindAdminTasksHandler handles the FindAdminTasksQuery.
func NewFindAdminTasksHandler ¶
func NewFindAdminTasksHandler(db orm.DB) *FindAdminTasksHandler
NewFindAdminTasksHandler creates a new FindAdminTasksHandler.
type FindAdminTasksQuery ¶
type FindAdminTasksQuery struct {
cqrs.BaseQuery
page.Pageable
TenantID string
AssigneeID string
InstanceID string
Status string
}
FindAdminTasksQuery queries tasks for admin management.
type FindAvailableFlowsHandler ¶
type FindAvailableFlowsHandler struct {
// contains filtered or unexported fields
}
FindAvailableFlowsHandler handles the FindAvailableFlowsQuery.
func NewFindAvailableFlowsHandler ¶
func NewFindAvailableFlowsHandler(db orm.DB, assigneeService approval.AssigneeService) *FindAvailableFlowsHandler
NewFindAvailableFlowsHandler creates a new FindAvailableFlowsHandler.
func (*FindAvailableFlowsHandler) Handle ¶
func (h *FindAvailableFlowsHandler) Handle(ctx context.Context, query FindAvailableFlowsQuery) (*page.Page[my.AvailableFlow], error)
type FindAvailableFlowsQuery ¶
type FindAvailableFlowsQuery struct {
cqrs.BaseQuery
page.Pageable
UserID string
TenantID string
ApplicantDeptID *string
Keyword string
}
FindAvailableFlowsQuery queries flows the current user is allowed to initiate.
type FindFlowVersionsHandler ¶
type FindFlowVersionsHandler struct {
// contains filtered or unexported fields
}
FindFlowVersionsHandler handles the FindFlowVersionsQuery.
func NewFindFlowVersionsHandler ¶
func NewFindFlowVersionsHandler(db orm.DB) *FindFlowVersionsHandler
NewFindFlowVersionsHandler creates a new FindFlowVersionsHandler.
func (*FindFlowVersionsHandler) Handle ¶
func (h *FindFlowVersionsHandler) Handle(ctx context.Context, query FindFlowVersionsQuery) ([]approval.FlowVersion, error)
type FindFlowVersionsQuery ¶
FindFlowVersionsQuery queries flow versions for a specific flow.
type FindFlowsHandler ¶
type FindFlowsHandler struct {
// contains filtered or unexported fields
}
FindFlowsHandler handles the FindFlowsQuery.
func NewFindFlowsHandler ¶
func NewFindFlowsHandler(db orm.DB) *FindFlowsHandler
NewFindFlowsHandler creates a new FindFlowsHandler.
type FindFlowsQuery ¶
type FindFlowsQuery struct {
cqrs.BaseQuery
page.Pageable
TenantID string
CategoryID string
Keyword string
IsActive *bool
}
FindFlowsQuery queries flows for admin management.
type FindMyCCRecordsHandler ¶
type FindMyCCRecordsHandler struct {
// contains filtered or unexported fields
}
FindMyCCRecordsHandler handles the FindMyCCRecordsQuery.
func NewFindMyCCRecordsHandler ¶
func NewFindMyCCRecordsHandler(db orm.DB) *FindMyCCRecordsHandler
NewFindMyCCRecordsHandler creates a new FindMyCCRecordsHandler.
type FindMyCCRecordsQuery ¶
type FindMyCCRecordsQuery struct {
cqrs.BaseQuery
page.Pageable
UserID string
TenantID string
IsRead *bool
}
FindMyCCRecordsQuery queries CC records addressed to the current user.
type FindMyCompletedTasksHandler ¶
type FindMyCompletedTasksHandler struct {
// contains filtered or unexported fields
}
FindMyCompletedTasksHandler handles the FindMyCompletedTasksQuery.
func NewFindMyCompletedTasksHandler ¶
func NewFindMyCompletedTasksHandler(db orm.DB) *FindMyCompletedTasksHandler
NewFindMyCompletedTasksHandler creates a new FindMyCompletedTasksHandler.
func (*FindMyCompletedTasksHandler) Handle ¶
func (h *FindMyCompletedTasksHandler) Handle(ctx context.Context, query FindMyCompletedTasksQuery) (*page.Page[my.CompletedTask], error)
type FindMyCompletedTasksQuery ¶
type FindMyCompletedTasksQuery struct {
cqrs.BaseQuery
page.Pageable
UserID string
TenantID string
}
FindMyCompletedTasksQuery queries tasks already processed by the current user.
type FindMyInitiatedHandler ¶
type FindMyInitiatedHandler struct {
// contains filtered or unexported fields
}
FindMyInitiatedHandler handles the FindMyInitiatedQuery.
func NewFindMyInitiatedHandler ¶
func NewFindMyInitiatedHandler(db orm.DB) *FindMyInitiatedHandler
NewFindMyInitiatedHandler creates a new FindMyInitiatedHandler.
func (*FindMyInitiatedHandler) Handle ¶
func (h *FindMyInitiatedHandler) Handle(ctx context.Context, query FindMyInitiatedQuery) (*page.Page[my.InitiatedInstance], error)
type FindMyInitiatedQuery ¶
type FindMyInitiatedQuery struct {
cqrs.BaseQuery
page.Pageable
UserID string
TenantID string
Status string
Keyword string
}
FindMyInitiatedQuery queries instances initiated by the current user.
type FindMyPendingTasksHandler ¶
type FindMyPendingTasksHandler struct {
// contains filtered or unexported fields
}
FindMyPendingTasksHandler handles the FindMyPendingTasksQuery.
func NewFindMyPendingTasksHandler ¶
func NewFindMyPendingTasksHandler(db orm.DB) *FindMyPendingTasksHandler
NewFindMyPendingTasksHandler creates a new FindMyPendingTasksHandler.
func (*FindMyPendingTasksHandler) Handle ¶
func (h *FindMyPendingTasksHandler) Handle(ctx context.Context, query FindMyPendingTasksQuery) (*page.Page[my.PendingTask], error)
type FindMyPendingTasksQuery ¶
FindMyPendingTasksQuery queries pending tasks assigned to the current user.
type GetAdminInstanceDetailHandler ¶
type GetAdminInstanceDetailHandler struct {
// contains filtered or unexported fields
}
GetAdminInstanceDetailHandler handles the GetAdminInstanceDetailQuery.
func NewGetAdminInstanceDetailHandler ¶
func NewGetAdminInstanceDetailHandler(db orm.DB) *GetAdminInstanceDetailHandler
NewGetAdminInstanceDetailHandler creates a new GetAdminInstanceDetailHandler.
func (*GetAdminInstanceDetailHandler) Handle ¶
func (h *GetAdminInstanceDetailHandler) Handle(ctx context.Context, query GetAdminInstanceDetailQuery) (*admin.InstanceDetail, error)
type GetAdminInstanceDetailQuery ¶
GetAdminInstanceDetailQuery retrieves the full admin detail of an instance (no participant check).
type GetFlowGraphHandler ¶
type GetFlowGraphHandler struct {
// contains filtered or unexported fields
}
GetFlowGraphHandler handles the GetFlowGraphQuery.
func NewGetFlowGraphHandler ¶
func NewGetFlowGraphHandler(db orm.DB) *GetFlowGraphHandler
NewGetFlowGraphHandler creates a new GetFlowGraphHandler.
func (*GetFlowGraphHandler) Handle ¶
func (h *GetFlowGraphHandler) Handle(ctx context.Context, query GetFlowGraphQuery) (*shared.FlowGraph, error)
type GetFlowGraphQuery ¶
GetFlowGraphQuery retrieves the flow graph for a published flow.
type GetMyInstanceDetailHandler ¶
type GetMyInstanceDetailHandler struct {
// contains filtered or unexported fields
}
GetMyInstanceDetailHandler handles the GetMyInstanceDetailQuery.
func NewGetMyInstanceDetailHandler ¶
func NewGetMyInstanceDetailHandler(db orm.DB, taskSvc *service.TaskService) *GetMyInstanceDetailHandler
NewGetMyInstanceDetailHandler creates a new GetMyInstanceDetailHandler.
func (*GetMyInstanceDetailHandler) Handle ¶
func (h *GetMyInstanceDetailHandler) Handle(ctx context.Context, query GetMyInstanceDetailQuery) (*my.InstanceDetail, error)
type GetMyInstanceDetailQuery ¶
GetMyInstanceDetailQuery retrieves instance detail with access control for the current user.
type GetMyPendingCountsHandler ¶
type GetMyPendingCountsHandler struct {
// contains filtered or unexported fields
}
GetMyPendingCountsHandler handles the GetMyPendingCountsQuery.
func NewGetMyPendingCountsHandler ¶
func NewGetMyPendingCountsHandler(db orm.DB) *GetMyPendingCountsHandler
NewGetMyPendingCountsHandler creates a new GetMyPendingCountsHandler.
func (*GetMyPendingCountsHandler) Handle ¶
func (h *GetMyPendingCountsHandler) Handle(ctx context.Context, query GetMyPendingCountsQuery) (*my.PendingCounts, error)
type GetMyPendingCountsQuery ¶
GetMyPendingCountsQuery retrieves pending task and unread CC counts for the current user.
Source Files
¶
- find_admin_action_logs.go
- find_admin_instances.go
- find_admin_tasks.go
- find_available_flows.go
- find_flow_versions.go
- find_flows.go
- find_my_cc_records.go
- find_my_completed_tasks.go
- find_my_initiated.go
- find_my_pending_tasks.go
- get_admin_instance_detail.go
- get_flow_graph.go
- get_my_instance_detail.go
- get_my_pending_counts.go
- module.go