bugfix 分组创建时会自动更新期望执行时间

mylxsw · Jul 23, 2020 · ed4b527 · ed4b527
1 parent 7784b04
commit ed4b527
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 9 deletions.
diff --git a/api/static.go b/api/static.go
diff --git a/internal/repository/impl/message_group.go b/internal/repository/impl/message_group.go
@@ -136,7 +136,7 @@ func (m MessageGroupRepo) CollectingGroup(rule repository.MessageGroupRule) (gro
 	err = m.col.FindOneAndUpdate(
 		context.TODO(),
 		bson.M{"rule._id": rule.ID, "status": repository.MessageGroupStatusCollecting},
-		bson.M{"$set": bson.M{"rule": rule}},
+		bson.M{"$set": bson.M{"status": repository.MessageGroupStatusCollecting}},
 		options.FindOneAndUpdate().SetUpsert(true).SetReturnDocument(options.After),
 	).Decode(&group)
 
@@ -149,6 +149,7 @@ func (m MessageGroupRepo) CollectingGroup(rule repository.MessageGroupRule) (gro
 			group.SeqNum = seq.Value
 		}
 
+		group.Rule = rule
 		_ = m.UpdateID(group.ID, group)
 	}