service/userService.go

@@ -112,10 +112,7 @@ 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")
@@ -161,19 +158,17 @@ func UserSyncDataFromMaster() {
 	}
 
 	//确认同步数据
-	if is_all == false {
+	var data proto.UserSyncConfirm
-		var data proto.UserSyncConfirm
+	data.Add = add_confirm
-		data.Add = add_confirm
+	data.Update = update_confirm
-		data.Update = update_confirm
+	data.Delete = delete_confirm
-		data.Delete = delete_confirm
+	//确认同步数据请求
-		//确认同步数据请求
+	var confirm_req proto.SyncUserReq
-		var confirm_req proto.SyncUserReq
+	confirm_req.Token = tokens[0]
-		confirm_req.Token = tokens[0]
+	confirm_req.Device = proto.Config.SERVER_NAME
-		confirm_req.Device = proto.Config.SERVER_NAME
+	confirm_req.Types = 3
-		confirm_req.Types = 3
+	confirm_req.Confirm = data
-		confirm_req.Confirm = data
+	worker.SyncDataFromMasterReq2(url, confirm_req)
-		worker.SyncDataFromMasterReq2(url, confirm_req)
-	}
 }
 
 // 同步数据到主服务器-增删改数据

worker/req.go

@@ -166,6 +166,5 @@ 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
 }