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

Booking trace API

Browse Source
This commit is contained in:
mr 2024-08-21 14:12:28 +02:00
parent ddb4f76af7
commit c14e067449
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
models/workflow/workflow_mongo_accessor.go
View File

@ -80,7 +80,7 @@ func (wfa *workflowMongoAccessor) getExecutions(id string, data *Workflow) ([]*w
func (wfa *workflowMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) { func (wfa *workflowMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) {
wfa.execution(id, &Workflow{ wfa.execution(id, &Workflow{
AbstractWorkflow: AbstractWorkflow{ScheduleActive: true}, AbstractWorkflow: AbstractWorkflow{ScheduleActive: false},
}, true) }, true)
return wfa.GenericDeleteOne(id, wfa) return wfa.GenericDeleteOne(id, wfa)
} }
@ -138,16 +138,14 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w
} }
func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delete bool) (int, error) { func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delete bool) (int, error) {
if !realData.ScheduleActive {
return 200, nil
}
var err error var err error
nats := tools.NewNATSCaller() nats := tools.NewNATSCaller()
res, code, _ := wfa.LoadOne(id) res, code, _ := wfa.LoadOne(id)
if code != 200 { if code != 200 {
return 404, errors.New("could not load workflow") return 404, errors.New("could not load workflow")
} }
if realData.Schedule == nil && realData.ScheduleActive { r := res.(*Workflow)
if r.Schedule != nil && !realData.ScheduleActive {
mongo.MONGOService.DeleteMultiple(map[string]interface{}{ mongo.MONGOService.DeleteMultiple(map[string]interface{}{
"state": 1, "state": 1,
"workflow_id": id, "workflow_id": id,
@ -157,7 +155,6 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
return 200, err return 200, err
} }
r := res.(*Workflow)
if r.Schedule != nil && r.Schedule.Start == realData.Schedule.Start && r.Schedule.End == realData.Schedule.End && r.Schedule.Cron == realData.Schedule.Cron { if r.Schedule != nil && r.Schedule.Start == realData.Schedule.Start && r.Schedule.End == realData.Schedule.End && r.Schedule.Cron == realData.Schedule.Cron {
return 200, nil return 200, nil
} }