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

修复循环引用问题

This commit is contained in:
junleea 2024-12-15 15:08:20 +08:00
parent 64069034db
commit f720eb509b
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
service/userService.go
View File

@ -6,6 +6,7 @@ import (
"strconv" "strconv"
"time" "time"
"videoplayer/dao" "videoplayer/dao"
"videoplayer/handler"
"videoplayer/proto" "videoplayer/proto"
"videoplayer/worker" "videoplayer/worker"
) )
@ -129,7 +130,7 @@ func UserSyncDataFromMaster() {
} }
// 同步数据到主服务器-增删改数据 // 同步数据到主服务器-增删改数据
func GetUserSyncData(device string) proto.UserSyncResp { func GetUserSyncData(device string) handler.UserSyncResp {
key := device + "_sync_user_ids" key := device + "_sync_user_ids"
add_temp_key := device + "_sync_user_ids_add_confirm_temp" add_temp_key := device + "_sync_user_ids_add_confirm_temp"
update_temp_key := device + "_sync_user_ids_update_confirm_temp" update_temp_key := device + "_sync_user_ids_update_confirm_temp"
@ -164,7 +165,7 @@ func GetUserSyncData(device string) proto.UserSyncResp {
worker.ClearRedisSet(key + "_update") worker.ClearRedisSet(key + "_update")
worker.SetRedisSetUnionAndStore(delete_temp_key, key+"_delete") worker.SetRedisSetUnionAndStore(delete_temp_key, key+"_delete")
worker.ClearRedisSet(key + "_delete") worker.ClearRedisSet(key + "_delete")
return proto.UserSyncResp{Add: add_users, Update: update_users, Delete: delete_users} return handler.UserSyncResp{Add: add_users, Update: update_users, Delete: delete_users}
} }
func setSyncUserDataSet(t string, id int) error { func setSyncUserDataSet(t string, id int) error {