904118851 1 gadu atpakaļ
vecāks
revīzija
f7bdda8496
4 mainītis faili ar 83 papildinājumiem un 4 dzēšanām
  1. 1 0
      .gitignore
  2. 2 2
      etc/run_config.lua
  3. 56 0
      service/agentmgr/init.lua
  4. 24 2
      service/dbmgr/init.lua

+ 1 - 0
.gitignore

@@ -0,0 +1 @@
+etc/run_config.lua

+ 2 - 2
etc/run_config.lua

@@ -39,6 +39,6 @@ return {
     db_pw = "p0LTZh&CjMl2023",
     db_name = "video_tools_user_db",
     testHttpProt = 9910;
-    -- tools_api = "http://clipvideoup.hainanmlwl.com"; --测试
-    tools_api = "http://clipvideoup.s6kuwan.com"; --正式
+    tools_api = "http://clipvideoup.hainanmlwl.com"; --测试
+    -- tools_api = "http://clipvideoup.s6kuwan.com"; --正式
 }

+ 56 - 0
service/agentmgr/init.lua

@@ -5,6 +5,11 @@ local cjson = require "cjson"
 --玩家列表
 local players = {}
 
+--用户详情列表
+local playersInfo = {
+    user_folder_nums = {},
+    user_file_type_nums = {}
+}
 --玩家类
 function mgrplayer()
     local m = {
@@ -810,6 +815,57 @@ s.resp.update_generate_video_custom = function(fd,msg_body,user_data)
     end
     return tools.response(fd,200,cjson.encode({code=10000,msg = "更新成功!"}))
 end
+
+
+--更新用户所有的文件数
+s.resp.update_user_folder_list_nums = function(user_id)
+    skynet.fork(function()
+        local count  = skynet.call("dbmgr","lua","on_recv","get_user_folder_list_nums",{
+            user_id = user_id}
+        )
+        playersInfo.user_folder_nums[user_id] = count  
+    end)
+end
+
+--更新用户指定类型的数量
+s.resp.update_user_file_count_by_type  = function(user_id,file_type)
+    skynet.fork(function()
+        local key = user_id.."_"..file_type
+        local count  = skynet.call("dbmgr","lua","on_recv","get_user_file_count_by_type",{
+            user_id = user_id,
+            file_type = file_type}
+        )
+        playersInfo.user_file_type_nums[key] = count
+    end)
+end
+
+--获取用户所有的文件数
+s.resp.get_user_folder_list_nums = function(user_id)
+    if playersInfo.user_folder_nums[user_id]~=nil then
+        return playersInfo.user_folder_nums[user_id]
+    else
+        local count  = skynet.call("dbmgr","lua","on_recv","get_user_folder_list_nums",{
+            user_id = user_id}
+        )
+        playersInfo.user_folder_nums[user_id] = count
+        return count
+    end
+end
+
+--获取用户指定类型的数量
+s.resp.get_user_file_count_by_type  = function(user_id,file_type)
+    local key = user_id.."_"..file_type
+    if playersInfo.user_file_type_nums[key]~=nil then
+        return playersInfo.user_file_type_nums[key]
+    else
+        local count  = skynet.call("dbmgr","lua","on_recv","get_user_file_count_by_type",{
+            user_id = user_id,
+            file_type = file_type}
+        )
+        playersInfo.user_file_type_nums[key] = count
+        return count
+    end
+end
 --踢掉
 s.resp.kick = function(fd,msg_body,user_data)
     

+ 24 - 2
service/dbmgr/init.lua

@@ -1361,8 +1361,8 @@ s.resp.recv_ref_folder_list_del_info = function(msg_body)
         end
         s.resp.recv_ref_file_list_del_info({file_id_list=listToDelete})
     end
-    skynet.error("接收到删除引用的文件夹列表信息")
-    tools.dump(msg_body)
+    -- skynet.error("接收到删除引用的文件夹列表信息")
+    -- tools.dump(msg_body)
     for i = 1, #msg_body.folder_id_list, 1 do
         local folder_id = msg_body.folder_id_list[i]
         local  list =  s.resp.check_ref_folder_have_self_file({folder_id=folder_id})
@@ -1422,6 +1422,28 @@ s.resp.recv_ref_folder_modify_info = function(msg_body)
     return true
 end
 
+--获取用户所有的文件数
+s.resp.get_user_folder_list_nums = function(msg_body)
+    local sql = string.format("select COUNT(user_id) AS nums from folder_list_tab where  user_id = %d ",msg_body.user_id)
+    local res = db:query(sql)
+    local count = 0
+    if res and #res > 0 then
+        count = res.nums
+    end
+    return count
+end
+
+--获取用户指定类型的数量
+s.resp.get_user_file_count_by_type = function(msg_body)
+    local sql = string.format("select COUNT(user_id) AS nums from res_list_tab where  user_id = %d  AND file_type = %d",msg_body.user_id,msg_body.file_type)
+    local res = db:query(sql)
+    local count = 0
+    if res and #res > 0 then
+        count = res.nums
+    end
+    return count
+end
+
 s.init = function()
     db=mysql.connect({
 		host=runconfig.db_tost,