ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修复部分用户同步逻辑

This commit is contained in:
junleea 2024-12-15 17:24:00 +08:00
parent 067c4ccfe2
commit f421dda674
2 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
service/userService.go
View File

@ -112,7 +112,10 @@ func UserSyncDataFromMaster() {
req.Token = tokens[0] req.Token = tokens[0]
req.Device = proto.Config.SERVER_NAME req.Device = proto.Config.SERVER_NAME
all := worker.GetRedis("user_sync_all") all := worker.GetRedis("user_sync_all")
var is_all bool //是否全量同步
if all == "" || all == "1" { if all == "" || all == "1" {
is_all = true
worker.SetRedis("user_sync_all", "1")
req.Types = 1 req.Types = 1
} else { } else {
worker.SetRedis("user_sync_all", "2") worker.SetRedis("user_sync_all", "2")
@ -158,17 +161,19 @@ func UserSyncDataFromMaster() {
} }
//确认同步数据 //确认同步数据
var data proto.UserSyncConfirm if is_all == false {
data.Add = add_confirm var data proto.UserSyncConfirm
data.Update = update_confirm data.Add = add_confirm
data.Delete = delete_confirm data.Update = update_confirm
//确认同步数据请求 data.Delete = delete_confirm
var confirm_req proto.SyncUserReq //确认同步数据请求
confirm_req.Token = tokens[0] var confirm_req proto.SyncUserReq
confirm_req.Device = proto.Config.SERVER_NAME confirm_req.Token = tokens[0]
confirm_req.Types = 3 confirm_req.Device = proto.Config.SERVER_NAME
confirm_req.Confirm = data confirm_req.Types = 3
worker.SyncDataFromMasterReq2(url, confirm_req) confirm_req.Confirm = data
worker.SyncDataFromMasterReq2(url, confirm_req)
}
} }
// 同步数据到主服务器-增删改数据 // 同步数据到主服务器-增删改数据

1
worker/req.go
View File

@ -166,5 +166,6 @@ func SyncDataFromMasterReq2(url string, data proto.SyncUserReq) proto.UserSync {
fmt.Println("SyncDataFromMasterReq2 error decode data:", err) fmt.Println("SyncDataFromMasterReq2 error decode data:", err)
return res return res
} }
fmt.Println("SyncDataFromMasterReq2 result add data:", len(res.Add), "update data:", len(res.Update), "delete data:", len(res.Delete))
return res return res
} }