From 84a0dba286de5072174d41bd9e779d524719db16 Mon Sep 17 00:00:00 2001
From: mlogclub <mlog1@qq.com>
Date: Sat, 2 May 2026 11:36:32 +0800
Subject: [PATCH] fix(customer): sync conversation name callback

---
 internal/services/customer_service.go | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/internal/services/customer_service.go b/internal/services/customer_service.go
index b6f0590..3362ccf 100644
--- a/internal/services/customer_service.go
+++ b/internal/services/customer_service.go
@@ -136,17 +136,15 @@ func (s *customerService) EnsureExternalCustomer(ctx *sqls.TxContext, externalUs
 		}
 
 		ctx.RegisterCallback(func() {
-			go func() {
-				if strs.IsNotBlank(externalUser.ExternalName) {
-					if err := s.syncConversationCustomerName(sqls.DB(), identity.CustomerID, externalUser.ExternalName, nil, now); err != nil {
-						slog.Error("sync conversation customer name failed",
-							"customerId", identity.CustomerID,
-							"customerName", externalUser.ExternalName,
-							"error", err,
-						)
-					}
+			if strs.IsNotBlank(externalUser.ExternalName) {
+				if err := s.syncConversationCustomerName(sqls.DB(), identity.CustomerID, externalUser.ExternalName, nil, now); err != nil {
+					slog.Error("sync conversation customer name failed",
+						"customerId", identity.CustomerID,
+						"customerName", externalUser.ExternalName,
+						"error", err,
+					)
 				}
-			}()
+			}
 		})
 		return identity.CustomerID, nil
 	}