From 65f3318f7383fd9fce27d2b1a90a0398f678132e Mon Sep 17 00:00:00 2001 From: mr Date: Thu, 22 Aug 2024 16:53:31 +0200 Subject: [PATCH] Discovery Nats automate --- models/workflow/workflow_mongo_accessor.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 08d7416..385594d 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -180,11 +180,15 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet } func (wfa *workflowMongoAccessor) UpdateOne(set utils.DBObject, id string) (utils.DBObject, int, error) { - res, code, err := wfa.GenericUpdateOne(set, id, wfa, &Workflow{}) + res, code, err := wfa.LoadOne(id) + if code != 200 { + return nil, 409, err + } + avoid := set.(*Workflow).Schedule == nil || (res.(*Workflow).Schedule != nil && res.(*Workflow).Schedule.Start == set.(*Workflow).Schedule.Start && res.(*Workflow).Schedule.End == set.(*Workflow).Schedule.End && res.(*Workflow).Schedule.Cron == set.(*Workflow).Schedule.Cron) + res, code, err = wfa.GenericUpdateOne(set, id, wfa, &Workflow{}) if code != 200 { return nil, code, err } - avoid := set.(*Workflow).Schedule == nil || (res.(*Workflow).Schedule != nil && res.(*Workflow).Schedule.Start == set.(*Workflow).Schedule.Start && res.(*Workflow).Schedule.End == set.(*Workflow).Schedule.End && res.(*Workflow).Schedule.Cron == set.(*Workflow).Schedule.Cron) if !avoid { if code, err := wfa.execution(id, res.(*Workflow), true); err != nil { return nil, code, err