local skynet = require "skynet"
local oo = require "Class"
local log = require "Log"
local pb = require "pb"
local redisKeyUrl = require "RedisKeyUrl"
local sqlUrl = require "SqlUrl"
local mailManage = require "MailManage"
local dataType = require "DataType"
local errorInfo = require "ErrorInfo"
local json = require "json"
local Mail = oo.class()

Mail.MailOpType_1 = 1    --获取邮件列表
Mail.MailOpType_2 = 2    --查阅/领取奖品

Mail.MailOpStatus_Suc = 1                   --操作状态成功
Mail.MailOpStatus_NoMailID = 2          --不存在该邮件ID
Mail.MailOpStatus_AlreadyGet = 3          --已经领取了

Mail.MailType_AllServer = 1     --全服邮件
Mail.MailType_User = 2            --用户邮件

Mail.MaxSendCount = 100   --一次发送最大数量

function Mail:Init()
    self.mailList = {}
end

--每5秒调一次
function Mail:On5SecTimer()
    self:BatchAddMail()
end

--从后台刷新邮件列表
function Mail:RefreshMailList()
    --向后端请求
    local param = {}
    local web = skynet.server.gameConfig.WebConfig.host .. ":" .. skynet.server.gameConfig.WebConfig.port
    local url = skynet.server.common.getMailUrl
    local status, body = skynet.server.httpClient:PostJson(web, url, json:encode(param), "http")

    if 200 == status then
        local newbody = json:decode(body)
        if 200 == newbody.code then
            --判断旧的邮件是否还能继续使用
            if next(self.mailList)~=nil then
                for k ,v in pairs(self.mailList) do
                    local isCanGet = false
                    for k1, v1 in pairs(newbody.data) do
                        if k==v1.mailModel.mailId then
                            isCanGet = true
                            break
                        end
                    end
                    v.isCanGet = isCanGet
                end
            end 

            --添加新的邮件
            for k, v in pairs(newbody.data) do
                local mailId = v.mailModel.mailId
                if not self.mailList[mailId] then
                    self.mailList[mailId] = {}
                    local curMail = self.mailList[mailId]
                    curMail.mailInfo = v.mailModel
                    curMail.award = v.giftArticlesModels
                    curMail.isCanGet = true
                    curMail.isSendAllOnlineUser = false   --是否发送所有在线玩家

                    if "全服" == curMail.mailInfo.mailCondition then
                        curMail.mailType = self.MailType_AllServer
                    elseif "ID" == curMail.mailInfo.mailCondition then
                        curMail.mailType = self.MailType_User
                        local t1 = skynet.GetTime()
                        local count = 0
                        local playerList = skynet.server.playerCenter:GetPlayerList()
                        --给指定在线玩家发送新邮件
                        local uidList = skynet.server.common:Split( curMail.mailInfo.uidlist, ",")
                        for k, v in pairs(uidList) do
                            for userId, value in pairs(playerList) do
                                if value.player.account == v and skynet.server.playerCenter.Status_Playing == value.status then
                                    self:AddMail(value.player, mailId , curMail.mailInfo , curMail.award , true )
                                    count = count + 1
                                end
                            end
                        end
                        log.info(string.format("邮箱 部分玩家发送邮件 发送数量 %d 时间花费 %d ", count, skynet.GetTime() - t1))
                    end
                end
            end
        elseif 702 == newbody.code then
            --s2cData.code = errorInfo.ErrorCode.AlreadyGet
            if next(self.mailList)~=nil then
                for k ,v in pairs(self.mailList) do
                    v.isCanGet = false
                end
            end
        end
    else
        log.info("邮箱刷新 获取数据失败 status ", status)
    end
end

--邮件历史
function Mail:History(player, c2sData, s2cData)
    c2sData.data = assert(pb.decode("C2SMailHistory", c2sData.data))
    local data = {}
    data.mailInfo = {}
    for k, v in pairs(player.gameData.mail.mailList) do
        for k1, v1 in pairs(player.gameData.mail.historyMail) do
            if v1 == v.mailId then
                table.insert(data.mailInfo, v)
            end
        end
    end
    s2cData.cmd = pb.enum("MsgType", "CMD_S2C_MailHistory")
    s2cData.data = assert(pb.encode("S2CMailHistory", data))
end

--邮件领取奖励
function Mail:Award(player, c2sData, s2cData)
    c2sData.data = assert(pb.decode("C2SMailAward", c2sData.data))
    local mailId = c2sData.data.mailId
    local data = {}
    data.mailInfo = {}
    if not mailId then
        s2cData.code = errorInfo.ErrorCode.ErrRequestParams
    else
        local isExist = false
        local nowTime = skynet.GetTime()
        for k, v in pairs(player.gameData.mail.mailList) do
            if mailId == v.mailId and dataType.MailStatus_NoGet == v.status and nowTime<v.failureTime then
                --未获取，可以正常领取
                isExist = true
                self:Bonus(player, mailId, v.award)
                v.status = dataType.MailStatus_AlreadyGet
                --告诉后台该玩家领取了邮件
                local param = { mailId = mailId, playerId = player.account }
                local web = skynet.server.gameConfig.WebConfig.host .. ":" .. skynet.server.gameConfig.WebConfig.port
                local url = skynet.server.common.useMailUrl
                local status, body = skynet.server.httpClient:PostJson(web, url, json:encode(param), "http")
                local newbody = json:decode(body)
                skynet.server.msgTips:Reduce(player , 23)
                data.mailInfo = v
                break
            elseif mailId == v.mailId and dataType.MailStatus_AlreadyGet == v.Status then
                --已经领取了,无法再次领取
                isExist = true
                s2cData.code = errorInfo.ErrorCode.AlreadyGet
                data.mailInfo = v
                break
            elseif mailId == v.mailId and nowTime >= v.failureTime then
                --已经领取了,无法再次领取
                isExist = true
                s2cData.code = errorInfo.ErrorCode.AlreadyGet
                data.mailInfo = v
                break
            end
        end

        if not isExist then
            s2cData.code = errorInfo.ErrorCode.NoExistMailID
        end
    end
    s2cData.cmd = pb.enum("MsgType", "CMD_S2C_MailAward")
    s2cData.data = assert(pb.encode("S2CMailAward", data))
end

--邮件读取
function Mail:Read(player, c2sData, s2cData)
    c2sData.data = assert(pb.decode("C2SReadMail", c2sData.data))
    local mailId = c2sData.data.mailId
    local data = {}
    data.mailInfo = {}
    if not mailId then
        s2cData.code = errorInfo.ErrorCode.ErrRequestParams
    else
        for k, v in pairs(player.gameData.mail.mailList) do
            if mailId == v.mailId then
                -- 修改邮件的读取状态
                v.status = dataType.MailStatus_AlreadyGet
                skynet.server.msgTips:Reduce(player , 23)
                data.mailInfo = v
            end
        end
    end
    s2cData.cmd = pb.enum("MsgType", "CMD_S2C_ReadMail")
    s2cData.data = assert(pb.encode("S2CReadMail", data))
    log.info(string.format("玩家 %d 读取邮件 ID", player.userId, mailId))
end

--删除已读邮件
function Mail:DeleteRead(player, c2sData, s2cData)
    c2sData.data = assert(pb.decode("C2SReadMail", c2sData.data))
    local data = {}
    data.mailInfo = {}
    if player.gameData.mail.mailList then
        -- 当玩家有邮件才进行以下逻辑
        for k, v in pairs(player.gameData.mail.mailList) do
            -- 领取或者读取过的邮件就删除 否则返回给客户端1
            if dataType.MailStatus_AlreadyGet == v.status then
                player.gameData.mail.mailList[k] = nil
            else
                table.insert(data.mailInfo, v)
            end
        end
    end
    s2cData.cmd = pb.enum("MsgType", "CMD_S2C_DeleteReadMail")
    s2cData.data = assert(pb.encode("S2CDeleteReadMail", data))
    log.info(string.format("删除 玩家 %d 读取过的邮件", player.userId))
end

--一键领取邮件奖励
function Mail:AllAward(player, c2sData, s2cData)
    c2sData.data = assert(pb.decode("C2SMailAllAward", c2sData.data))
    local data = {}
    data.mailInfo = {}
    local nowTime = skynet.GetTime()
    for k, v in pairs(player.gameData.mail.mailList) do
        if dataType.MailStatus_NoGet == v.status and pb.enum("PBMailInfo.MailType", "Award") == v.mailType and nowTime<v.failureTime then
            --未获取，可以正常领取
            self:Bonus(player, v.mailId, v.award)
            v.status = dataType.MailStatus_AlreadyGet
            --告诉后台该玩家领取了邮件
            local param = { mailId = v.mailId, playerId = player.account }
            local web = skynet.server.gameConfig.WebConfig.host .. ":" .. skynet.server.gameConfig.WebConfig.port
            local url = skynet.server.common.useMailUrl
            local status, body = skynet.server.httpClient:PostJson(web, url, json:encode(param), "http")
            local newbody = json:decode(body)

            -- 将邮件信息返回
            table.insert(data.mailInfo, v)
            --消除红点
            skynet.server.msgTips:Reduce(player , 23)
        elseif dataType.MailStatus_AlreadyGet == v.Status then
            --已经领取了,无法再次领取
            s2cData.code = errorInfo.ErrorCode.AlreadyGet
        elseif nowTime>=v.failureTime then
            --邮件已经过期，无法进行领取 删除对应邮件
            player.gameData.mail.mailList[k] = nil
            s2cData.code = errorInfo.ErrorCode.AlreadyGet
        end
    end
    s2cData.cmd = pb.enum("MsgType", "CMD_S2C_MailAllAward")
    s2cData.data = assert(pb.encode("S2CMailAllAward", data))
end

--发放邮件奖励
function Mail:Bonus(player, mailId, award)
    for k, v in pairs(award) do
        if v.type >= dataType.GoodsType_Furniture and v.type <= dataType.GoodsType_PetClothes then
            skynet.server.bag:AddGoods(player, v.type, v.id, v.count)
        end
        --货币直接发放相应数量就行
        if  v.type <10 then
            if dataType.GoodsType_Coin == v.type then
                player:MoneyChange(pb.enum("EnumGoodsType", "Coin"), v.count)
            elseif dataType.GoodsType_Clovers == v.type then
                player:MoneyChange(pb.enum("EnumGoodsType", "Clovers"), v.count)
            elseif dataType.GoodsType_Volute == v.type then
                player:MoneyChange(pb.enum("EnumGoodsType", "VoluteCoin"), v.count)
            end
        end
        if not v.id then
            log.info(string.format("玩家 %d 邮件 ID %s 领取奖励 类型 %d  数量 %d", player.userId, mailId, v.type, v.count))
        else
            log.info(string.format("玩家 %d 邮件 ID %s 领取奖励 类型 %d ID %d 数量 %d", player.userId, mailId, v.type, v.id, v.count))
        end
    end
end

--发送新邮件给在线玩家
function Mail:SendMailToOnlineUser( mailId )
    local mailInfo = self.mailList[mailId].mailInfo
    local award = self.mailList[mailId].award
    if not mailInfo or not award then
        return
    end

    local t1 = skynet.GetTime()
    local playerList = skynet.server.playerCenter:GetPlayerList()
    local count = 0
    if "全服" == mailInfo.mailCondition then
        --给在线玩家发送新邮件
        for userId, value in pairs(playerList) do
            if skynet.server.playerCenter.Status_Playing == value.status then
                --self:AddMail(value.player, mailId, mailInfo, award)
                count = count + 1
            end
        end
        log.info(string.format("邮箱 全玩家发送邮件 发送数量 %d 时间花费 %d ", count, skynet.GetTime() - t1))
    elseif "ID" == mailInfo.mailCondition then
        --给指定在线玩家发送新邮件
        local uidList = skynet.server.common:Split(mailInfo.uidlist, ",")
        for k, v in pairs(uidList) do
            for userId, value in pairs(playerList) do
                if value.player.account == v and skynet.server.playerCenter.Status_Playing == value.status then
                    --self:AddMail(value.player, mailId, mailInfo, award)
                    count = count + 1
                end
            end
        end
        log.info(string.format("邮箱 部分玩家发送邮件 发送数量 %d 时间花费 %d ", count, skynet.GetTime() - t1))
    end
end

--批量发送邮件
function Mail:BatchAddMail()
    local t1 = skynet.GetTime()
    local playerList = skynet.server.playerCenter:GetPlayerList()
    local sendCount = 0             --此次发送邮件数量
    local isSendMail = true         --是否继续发送邮件
    for mailId, v1 in pairs( self.mailList ) do
        local count = 0
        if self.MailType_AllServer == v1.mailType and v1.isCanGet and not v1.isSendAllOnlineUser then           --全服邮件 能发送 并且未发送完
            for userId, value in pairs(playerList) do
                if skynet.server.playerCenter.Status_Playing == value.status and not value.onlineMailList[ mailId ] then        --在线玩家并且未接收该邮件
                    self:AddMail( value.player , mailId , v1.mailInfo , v1.award , true  )
                    value.onlineMailList[ mailId ] = true
                    count = count + 1
                    sendCount = sendCount + 1

                    if sendCount >= self.MaxSendCount then
                        isSendMail = false
                        break
                    end
                end
            end
            
            if 0 == count then
                v1.isSendAllOnlineUser =  true
                log.info(string.format("邮箱 全服邮件 %s 在线已发送结束 ", mailId ))
            else
                log.info(string.format("邮箱 全服邮件 %s 发送 发送数量 %d 时间花费 %d ", mailId , count, skynet.GetTime() - t1))
            end
        end

        if not isSendMail then
            break
        end
    end   
end

--添加邮件
function Mail:AddMail(player , mailId , mailInfo , award , isWebSend)
    --玩家已经存在该邮件了，不再发送
    if self:IsExist(player, mailId) then
        return true
    end

    local nowTime = os.time()
    --过了或者未到有效时间，不再发送
    if isWebSend then
        if nowTime>skynet.server.common:GetTime(mailInfo.playerFailureTime) or nowTime < skynet.server.common:GetTime(mailInfo.playerEffectiveTime) then
            return true
        end
    end

    --[[
    --玩家的APP版本是否符合
    if self.basicInfo.appVersion < mailInfo.appVersion then
        return
    end

    --玩家的渠道是否符合
    if self.basicInfo.channel ~= mailInfo.channel and "all" ~= mailInfo.channel then
        return
    end

    --玩家的系统不符也不发
    if self.basicInfo.platform ~= mailInfo.system and "all" ~= mailInfo.system then
        return
    end
    ]] 
    local mail = player.gameData.mail
    local mailType = nil
    if "信息" == mailInfo.mailType then
        mailType = pb.enum("PBMailInfo.MailType", "Message")
    elseif "奖励" == mailInfo.mailType then
        mailType = pb.enum("PBMailInfo.MailType", "Award")
    end

    local curIndex = mail.curIndex
    mail.mailList[curIndex] = {}
    mail.mailList[curIndex].mailId = mailId
    mail.mailList[curIndex].status = dataType.MailStatus_NoGet
    mail.mailList[curIndex].mailType = mailType
    mail.mailList[curIndex].mailSubType = 1
    mail.mailList[curIndex].title = mailInfo.mailTitle
    mail.mailList[curIndex].content = mailInfo.mailText
    mail.mailList[curIndex].award = {}                                                      --奖励

    if award then
        if not isWebSend then
            --不是来自后台的邮件
            for k, v in pairs(award) do
                if v.type == 0 then
                    table.insert(mail.mailList[curIndex].award, { type = v.id, count = v.count })
                else
                    table.insert(mail.mailList[curIndex].award, { type = v.type, id = v.id, count = v.count })
                end
            end
        else
            --来自后台的邮件
            for k, v in pairs(award) do
                local goodsType = skynet.server.common:AwardTypeStrToInt(v.articlesType)
                if goodsType == dataType.GoodsType_Init then
                    table.insert(mail.mailList[curIndex].award, { type = v.articlesId, count = v.articlesNumber })
                else
                    table.insert(mail.mailList[curIndex].award, { type = goodsType, id = v.articlesId, count = v.articlesNumber })
                end
            end
        end
    end

    mail.mailList[curIndex].receiveTime = skynet.GetTime()
    mail.mailList[curIndex].failureTime = skynet.server.common:GetAfterSomeHour(mailInfo.mailEffectiveTime * 24)  --邮件的失效时间就是玩家获取到邮件之后的多少天

    --插入玩家领取过的邮件ID
    table.insert(mail.historyMail, mailId)

    --增加邮件红点
    skynet.server.msgTips:Add(player , 23)

    --玩家最多30条最近的邮件记录
    mail.curIndex = mail.curIndex + 1
    if mail.curIndex >= 30 then
        mail.curIndex = 1
    end
    --skynet.server.gameServer:SendMsgToUser(self.userId, "CMD_S2C_Mail", data)
    log.info(string.format("玩家 %d 邮箱 新增邮件 ID %s ", player.userId, mailId))
end

--检查玩家是否有新邮件
function Mail:CheckNewMail(player)
    for mailId, value in pairs(self.mailList) do
        if not self:IsExist(player, mailId) and value.isCanGet then
            if "全服" == value.mailInfo.mailCondition then
                self:AddMail(player, mailId, value.mailInfo , value.award , true )
            elseif "ID" == value.mailInfo.mailCondition then
                local uidList = skynet.server.common:Split(value.mailInfo.uidlist, ",")
                for k, v in pairs(uidList) do
                    --如果存在本人邮件就发送
                    if player.account == v then
                        self:AddMail(player, mailId , value.mailInfo , value.award , true )
                        break
                    end
                end
            end
        end
    end
end

--是否存在邮件
function Mail:IsExist(player, mailId)
    for k, v in pairs(player.gameData.mail.historyMail) do
        if mailId == v then
            return true
        end
    end
    return false
end

skynet.server.mail = Mail
return Mail