From da9192d3561dde083b33307cbc3967de611fe08e Mon Sep 17 00:00:00 2001
From: liwei1dao <liwei1dao@gmail.com>
Date: Thu, 8 Jun 2023 14:36:48 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=89=E5=85=A8=E9=94=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 modules/buried/module.go | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/modules/buried/module.go b/modules/buried/module.go
index 5aa9d6603..46e54f983 100644
--- a/modules/buried/module.go
+++ b/modules/buried/module.go
@@ -197,8 +197,17 @@ func (this *Buried) FinishConditionAndCheck(uid string, finishcondiIds []int32,
 	if bdatas, err = this.modelBuried.getUserBurieds(uid); err != nil {
 		return
 	}
-	condis = make([]*pb.ConIProgress, 0)
 
+	this.Debug("完成埋点!", log.Field{Key: "finishcondiIds", Value: finishcondiIds})
+	lock, _ := this.modelBuried.userlock(uid)
+	err = lock.Lock()
+	if err != nil {
+		this.Error("埋点分布式锁失效 err!", log.Field{Key: "uid", Value: uid}, log.Field{Key: "err", Value: err.Error()})
+		return
+	}
+	defer lock.Unlock()
+
+	condis = make([]*pb.ConIProgress, 0)
 	for _, v := range finishcondiIds {
 		if conf, err = this.configure.getburiedcondidata(v); err != nil {
 			return