core/oc-lib
6
0
Fork 0
Code Issues 6 Pull Requests Packages Projects Releases Wiki Activity

workflow execution evolved

Browse Source
This commit is contained in:
mr 2025-02-07 11:41:12 +01:00
parent 31ec352b57
commit 3d13833572
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
models/order/order.go
View File

@ -21,7 +21,7 @@ import (
* Booking is a struct that represents a booking * Booking is a struct that represents a booking
*/ */
type Order{} struct { type Order struct {
utils.AbstractObject utils.AbstractObject
OrderBy string `json:"order_by" bson:"order_by" validate:"required"` OrderBy string `json:"order_by" bson:"order_by" validate:"required"`
WorkflowID string `json:"workflow_id" bson:"workflow_id" validate:"required"` WorkflowID string `json:"workflow_id" bson:"workflow_id" validate:"required"`
@ -98,7 +98,7 @@ func (o *Order) draftStoreFromModel(scheduler *workflow_execution.WorkflowSchedu
o.SetName() o.SetName()
o.WorkflowID = scheduler.Workflow.GetID() o.WorkflowID = scheduler.Workflow.GetID()
o.IsDraft = true o.IsDraft = true
o.OrderBy = request.Username o.OrderBy = request.PeerID
o.WorkflowExecutionIDs = []string{} // create an array of ids o.WorkflowExecutionIDs = []string{} // create an array of ids
for _, exec := range scheduler.WorkflowExecutions { for _, exec := range scheduler.WorkflowExecutions {
o.WorkflowExecutionIDs = append(o.WorkflowExecutionIDs, exec.GetID()) o.WorkflowExecutionIDs = append(o.WorkflowExecutionIDs, exec.GetID())
@ -141,7 +141,7 @@ func (o *Order) draftStoreFromModel(scheduler *workflow_execution.WorkflowSchedu
res, code, err := o.GetAccessor(request).Search(&dbs.Filters{ res, code, err := o.GetAccessor(request).Search(&dbs.Filters{
And: map[string][]dbs.Filter{ And: map[string][]dbs.Filter{
"workflow_id": {{Operator: dbs.EQUAL.String(), Value: o.WorkflowID}}, "workflow_id": {{Operator: dbs.EQUAL.String(), Value: o.WorkflowID}},
"order_by": {{Operator: dbs.EQUAL.String(), Value: request.Username}}, "order_by": {{Operator: dbs.EQUAL.String(), Value: request.PeerID}},
}, },
}, "", o.IsDraft) }, "", o.IsDraft)
if code != 200 || err != nil { if code != 200 || err != nil {