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

state execution

Browse Source
This commit is contained in:
mr 2024-11-12 14:44:41 +01:00
parent 6497e7dbdd
commit 8a21a7c803
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
models/booking/booking_mongo_accessor.go
View File

@ -1,9 +1,12 @@
package booking package booking
import ( import (
"time"
"cloud.o-forge.io/core/oc-lib/dbs" "cloud.o-forge.io/core/oc-lib/dbs"
"cloud.o-forge.io/core/oc-lib/dbs/mongo" "cloud.o-forge.io/core/oc-lib/dbs/mongo"
"cloud.o-forge.io/core/oc-lib/models/utils" "cloud.o-forge.io/core/oc-lib/models/utils"
"cloud.o-forge.io/core/oc-lib/models/workflow_execution"
) )
type bookingMongoAccessor struct { type bookingMongoAccessor struct {
@ -42,6 +45,10 @@ func (wfa *bookingMongoAccessor) LoadOne(id string) (utils.DBObject, int, error)
return nil, code, err return nil, code, err
} }
res_mongo.Decode(&workflow) res_mongo.Decode(&workflow)
if workflow.State == workflow_execution.SCHEDULED && time.Now().UTC().After(*workflow.ExecDate) {
workflow.State = workflow_execution.FORGOTTEN
wfa.GenericRawUpdateOne(&workflow, id, wfa)
}
return &workflow, 200, nil return &workflow, 200, nil
} }

2
models/workflow_execution/workflow_execution_mongo_accessor.go
View File

@ -1,7 +1,6 @@
package workflow_execution package workflow_execution
import ( import (
"fmt"
"time" "time"
"cloud.o-forge.io/core/oc-lib/dbs" "cloud.o-forge.io/core/oc-lib/dbs"
@ -41,7 +40,6 @@ func (wfa *workflowExecutionMongoAccessor) LoadOne(id string) (utils.DBObject, i
return nil, code, err return nil, code, err
} }
res_mongo.Decode(&workflow) res_mongo.Decode(&workflow)
fmt.Println("workflow: ", workflow.State, time.Now().UTC().After(*workflow.ExecDate))
if workflow.State == SCHEDULED && time.Now().UTC().After(*workflow.ExecDate) { if workflow.State == SCHEDULED && time.Now().UTC().After(*workflow.ExecDate) {
workflow.State = FORGOTTEN workflow.State = FORGOTTEN
wfa.GenericRawUpdateOne(&workflow, id, wfa) wfa.GenericRawUpdateOne(&workflow, id, wfa)