GongFuServer/script/module/mail/MailManager.lua

--邮件管理
local LuaMongo = _G.lua_mongo
local Log = require("common.Log")
local DB = require("common.DB")
local Util = require("common.Util")
local Msg = require("core.Msg")
local ObjHuman = require("core.ObjHuman")
local RoleSystemLogic = require("roleSystem.RoleSystemLogic") 
local RoleSystemDefine = require("roleSystem.RoleSystemDefine") 
local RoleDBLogic = require("role.RoleDBLogic")
local MailExcel = require("excel.mail")

SYSTEM = 1 				-- 系统邮件
GONGGAO = 2 				-- 公告

MAIL_MAX_CNT = 100			-- 邮件最大值

local FIELD_ID = {_id = nil}
local FIELD_RECEIVER = {uuid = nil,type = nil}

--后面如果fbAccount有值应该把区服id一起
function add(type,receiverUuid,title,content,items,senderName,sender,time,fbTime,fbContent,fbAccount,expireTime) 
	if _G.is_middle == true or type == GONGGAO then
		return
	end
	
	local mail = {}
	mail.type = type
	mail.receiverUuid = receiverUuid
	mail.title = title
	mail.content = content
	mail.read = nil
	mail.senderName = title
    mail.head = 0
    mail.fbTime = fbTime
    mail.fbContent = fbContent
    
	--后面用到
    local fields = {head = 1,lv = 1}
    if fbAccount ~= nil then
        local db = RoleDBLogic.getDbByAccount(fbAccount,fields)
        mail.fbHead = db.head
        mail.fbLv = db.lv
	end
	
	if sender and sender.db and sender.db.identity then
		mail.identity = sender.db.identity
	end

	if sender and sender.db and sender.db.head then
		mail.head = sender.db.head
	end

    if time == nil then 
		mail.time = os.time()
    else
		mail.time = time
    end
	
    if expireTime then
        mail.expireTime = expireTime
    end	
	
	if items then
		mail.items = {}
		for _,item in ipairs(items) do 
			mail.items[#mail.items + 1] = {item[1],item[2]}
		end
	end
    if items == nil then
        mail.get = 1
        mail.flag = nil
    else
        mail.get = nil
        mail.flag = 1
    end
	LuaMongo.insert(DB.db_mail, mail)
	RoleSystemLogic.onDotByUuid(receiverUuid, RoleSystemDefine.ROLE_SYS_ID_204)
	return mail

end

-- condition = {startLv = 1, endLv = 100, lastLoginTime = xxx}
local MailLvQuery = {lv = {["$gte"] = 0, ["$lte"] = 0}}
local MailLvField = {lastLoginTime = 1, lastLogoutTime = 1}
function sendMailByCondition(condition, title, content, gridList,fbTime,fbContent,fbAccount,expireTime)
	local startLv = condition.startLv and tonumber(condition.startLv)
	local endLv = condition.endLv and tonumber(condition.endLv)		
	local lastLoginTime = condition.lastLoginTime and tonumber(condition.lastLoginTime) or 0
	if startLv == nil or endLv == nil or lastLoginTime == nil then
		return 
	end
    
    local successCount = 0
    local failCount = 0

    --Log.write(Log.LOGID_ERR_PCALL, "mail sendMailByCondition" , "")
	-- 在线的只要等级符合直接发
	for uuid, oHuman in pairs(ObjHuman.onlineUuid) do
		if oHuman.db.lv >= startLv and 
			oHuman.db.lv <= endLv then
			p_ret, err = pcall(add, SYSTEM, oHuman.db._id, title, content, gridList, condition.senderName, nil, nil,fbTime,fbContent,fbAccount,expireTime)
			if p_ret then
				successCount = successCount + 1
                --Log.write(Log.LOGID_ERR_PCALL, "mail rolename=" .. oHuman.db.name, err)
			else 
				failCount = failCount + 1
				--Log.write(Log.LOGID_ERR_PCALL, "mail rolename=" .. oHuman.db.name, err)
			end					
		end 
	end

	-- 不在线的，还需要验证x天内登录
	MailLvQuery.lv["$gte"] = startLv
	MailLvQuery.lv["$lte"] = endLv
	LuaMongo.find(DB.db_char, MailLvQuery, MailLvField)
    while true do
        local data = {}
        if not LuaMongo.next(data) then
        	break
        end
        if not ObjHuman.onlineUuid[data._id] and 
        	(lastLoginTime == 0 or 
        		(data.lastLoginTime and data.lastLoginTime >= lastLoginTime) or
        		(data.lastLogoutTime and data.lastLogoutTime >= lastLoginTime)
        	) then
			p_ret, err = pcall(add, SYSTEM, data._id, title, content, gridList, condition.senderName, nil, nil,fbTime,fbContent,fbAccount)
			if p_ret then	
				successCount = successCount + 1
			else 
				failCount = failCount + 1
				Log.write(Log.LOGID_ERR_PCALL, "mail role uuid=" .. data._id, err)
			end	
        end
    end
    return successCount, failCount
end

function del(mailUuid)
	FIELD_ID._id = mailUuid
	LuaMongo.remove(DB.db_mail, FIELD_ID)
end

function getMail(mailUuid)
	FIELD_ID._id = mailUuid
	LuaMongo.find(DB.db_mail,FIELD_ID)
	local mail = {}
	if not LuaMongo.next(mail) then
		return nil
	end
	return mail
end

local function cmpMail(a, b)
	return a.time > b.time
end

local mails = {}
function getMails(receiverUuid,mailType)
	for key in ipairs(mails) do 
		mails[key] = nil
	end

	FIELD_RECEIVER.receiverUuid = receiverUuid
	FIELD_RECEIVER.type = mailType

    LuaMongo.find(DB.db_mail,{["$query"]=FIELD_RECEIVER})
    
	local lastTime = os.time() - 7 * 86400
    local mailCnt = 0
	while true do
		local mail = {}
		-- if not LuaMongo.next(mail) then
		-- 	break
		-- end

		local res, err = pcall(function ()
			return LuaMongo.next(mail)
		end)

		if not res then
			Log.write(Log.LOGID_DEBUG, "MailManager.getMails err = ".. err)
			break
		end

		if not err then
			break
		end

       if mail.expireTime then  -- 有指定过期时间
            if mail.time > os.time() - mail.expireTime then
			    mailCnt = mailCnt + 1
			    mails[mailCnt] = mail
            end
       elseif mail.time > lastTime then -- 没有就用默认过期时间
            mailCnt = mailCnt + 1
			mails[mailCnt] = mail
       end
	end
    
    if mailCnt > MAIL_MAX_CNT then
		table.sort(mails, cmpMail)
		for i = MAIL_MAX_CNT + 1, mailCnt do
			mails[i] = nil
		end
	end    
	return mails
end


function saveMail(mail)
    FIELD_ID._id = mail._id
    LuaMongo.update(DB.db_mail, FIELD_ID, mail)
end

function delAll(uuid,mailType)
    local QueryMailByUuid = {get = {["$exists"] = 0},  read = {["$exists"] = 1}}
    QueryMailByUuid.receiverUuid = uuid
    QueryMailByUuid.type = mailType
    QueryMailByUuid.get["$exists"] = 1
	LuaMongo.remove(DB.db_mail, QueryMailByUuid)
end