From f421dda67458e4d6aaf281387a232087a07258d7 Mon Sep 17 00:00:00 2001
From: junleea <354425203@qq.com>
Date: Sun, 15 Dec 2024 17:24:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=83=A8=E5=88=86=E7=94=A8?=
 =?UTF-8?q?=E6=88=B7=E5=90=8C=E6=AD=A5=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/userService.go | 27 ++++++++++++++++-----------
 worker/req.go          |  1 +
 2 files changed, 17 insertions(+), 11 deletions(-)

diff --git a/service/userService.go b/service/userService.go
index 41cfb00..b670b83 100644
--- a/service/userService.go
+++ b/service/userService.go
@@ -112,7 +112,10 @@ func UserSyncDataFromMaster() {
 	req.Token = tokens[0]
 	req.Device = proto.Config.SERVER_NAME
 	all := worker.GetRedis("user_sync_all")
+	var is_all bool //是否全量同步
 	if all == "" || all == "1" {
+		is_all = true
+		worker.SetRedis("user_sync_all", "1")
 		req.Types = 1
 	} else {
 		worker.SetRedis("user_sync_all", "2")
@@ -158,17 +161,19 @@ func UserSyncDataFromMaster() {
 	}
 
 	//确认同步数据
-	var data proto.UserSyncConfirm
-	data.Add = add_confirm
-	data.Update = update_confirm
-	data.Delete = delete_confirm
-	//确认同步数据请求
-	var confirm_req proto.SyncUserReq
-	confirm_req.Token = tokens[0]
-	confirm_req.Device = proto.Config.SERVER_NAME
-	confirm_req.Types = 3
-	confirm_req.Confirm = data
-	worker.SyncDataFromMasterReq2(url, confirm_req)
+	if is_all == false {
+		var data proto.UserSyncConfirm
+		data.Add = add_confirm
+		data.Update = update_confirm
+		data.Delete = delete_confirm
+		//确认同步数据请求
+		var confirm_req proto.SyncUserReq
+		confirm_req.Token = tokens[0]
+		confirm_req.Device = proto.Config.SERVER_NAME
+		confirm_req.Types = 3
+		confirm_req.Confirm = data
+		worker.SyncDataFromMasterReq2(url, confirm_req)
+	}
 }
 
 // 同步数据到主服务器-增删改数据
diff --git a/worker/req.go b/worker/req.go
index fcbefd4..8dc93ef 100644
--- a/worker/req.go
+++ b/worker/req.go
@@ -166,5 +166,6 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) proto.UserSync {
 		fmt.Println("SyncDataFromMasterReq2 error decode data:", err)
 		return res
 	}
+	fmt.Println("SyncDataFromMasterReq2 result add data:", len(res.Add), "update data:", len(res.Update), "delete data:", len(res.Delete))
 	return res
 }