#!/usr/bin/python
# -*- coding: GBK -*-
#-------------------------------------------------------------------------------
#
#-------------------------------------------------------------------------------
#
##@package GameWorldShopItem
#
# @todo:×Ô¶¨ÒåÉ̵ê
# @author hxp
# @date 2014-06-21
# @version 1.3
#
# @change: "2015-02-04 14:30" hxp ÉñÃØÉ̵ê
# @change: "2015-02-09 18:00" ljd Ð޸ĵǽδÍê³ÉʱÊÕ²»µ½µ¹¼ÆʱˢаüÎÊÌâ
# @change: "2015-04-28 17:00" hxp ¶¨Ê±Ë¢ÐÂÉ̵꿪Æôʱ֪ͨÀ뿪ʱ¼ä
#
# ÏêϸÃèÊö: ×Ô¶¨ÒåÉ̵ê
#
#---------------------------------------------------------------------
"""Version = 2015-04-28 17:00"""

import GameWorld
import ChPyNetSendPack
import NetPackCommon
import ReadChConfig
import ShareDefine
import ChConfig

import time

## ³äÖµÉ̵êÈ«·þÏÞ¹ºÊý¾Ý
#  @param shopID É̵êid
#  @return
def DoShopItemClearBuyCnt(shopID):
    
    recTypeListData = __GetShopItemRecData()
    
    # ±éÀúÇå¿ÕÈ«·þÏÞ¹º´ÎÊý
    for index in range(recTypeListData.Count()):
        recData = recTypeListData.At(index)
        curShopID = recData.GetValue1()
        if curShopID == shopID:
            recData.SetValue3(0)
    
    resultName = "%s" % [ShareDefine.Def_ShopItem_ClearBuyCnt, shopID]
    
    # ֪ͨȫ·þÍæ¼Ò
    playerManager = GameWorld.GetPlayerManager()
    for i in range(0, playerManager.GetPlayerCount()):
        curPlayer = playerManager.GetPlayerByIndex(i)
        if curPlayer == None or not curPlayer.GetInitOK():
            continue
        
        curPlayer.MapServer_QueryPlayerResult(0, 0, "ShopItem", resultName, len(resultName))
        
    return


## ×Ô¶¨ÒåÉ̵êÎïÆ·²éѯ½á¹û
#  @param curPlayer Íæ¼ÒʵÀý
#  @param msgList ÐÅÏ¢Áбí
#  @return [queryType, À©Õ¹Êý¾Ý]
def DoShopItemQueryResult(curPlayer, msgList):
    queryType = msgList[0]
    result = []
    
    # ͬ²½¹ºÂò´ÎÊý[queryType, shopID, serverBuyLimitIndexList]
    if queryType == ShareDefine.Def_ShopItem_QueryServerBuyCnt:
        shopID = msgList[1]
        limitIndexList = msgList[2]
        buyCntDict = __GetShopItemServerBuyCntDict(shopID, limitIndexList)
        result = [queryType, shopID, buyCntDict]
    
    # ¹ºÂòÎïÆ·[queryType, shopID, itemShopIndex, buyCount, serverMaxBuyCnt]
    elif queryType == ShareDefine.Def_ShopItem_BuyItem:
        shopID = msgList[1]
        itemShopIndex = msgList[2]
        buyCount = msgList[3]
        serverMaxBuyCnt = msgList[4]
        buyCntDict = __GetShopItemServerBuyCntDict(shopID, [itemShopIndex])
        serverBuyCnt = buyCntDict.get(itemShopIndex, 0)
        # ÒѹºÂòµÄ + Òª¹ºÂòµÄ ²»³¬¹ý£¬ÔòÔÊÐí¹ºÂò
        canBuy = 0 if (serverBuyCnt + buyCount) > serverMaxBuyCnt else 1
        GameWorld.DebugLog("¹ºÂòÈ«·þÏÞ¹ºÎïÆ·£ºÈ«·þÒѹºÂò=%s,Óû¹ºÂò=%s,×î´ó¹ºÂò=%s,canBuy=%s" 
                           % (serverBuyCnt, buyCount, serverMaxBuyCnt, canBuy))
        if canBuy:
            serverBuyCnt = __AddShopItemServerBuyCnt(shopID, itemShopIndex, buyCount)
            
            # ֪ͨȫ·þÔÚÏßÍæ¼Ò¸ÃÎïÆ·ÏÞ¹º´ÎÊý±ä¸ü
            syncInfo = "%s" % [ShareDefine.Def_ShopItem_SyncServerBuyCnt, shopID,
                                 itemShopIndex, serverBuyCnt]
            playerManager = GameWorld.GetPlayerManager()
            for i in range(0, playerManager.GetPlayerCount()):
                player = playerManager.GetPlayerByIndex(i)
                # ×Ô¼ºÓÉMapServer¹ºÂòºóͬ²½
                # ÒòΪÓпÉÄܸÄÎïÆ·Ò²ÓиöÈËÏÞ¹º£¬ÐèMapServer´¦ÀíÍêºóÔÙͬ²½
                if player == None or not player.GetInitOK():
                    continue
                
                if player.GetPlayerID() == curPlayer.GetPlayerID():
                    #GameWorld.DebugLog("        ×Ô¼ºÏȲ»Í¬²½")
                    continue
                
                player.MapServer_QueryPlayerResult(0, 0, "ShopItem", syncInfo, len(syncInfo))
        
        result = [queryType, shopID, itemShopIndex, buyCount, canBuy, serverBuyCnt]
    
    
    return result


## Ôö¼ÓÏÞ¹ºÎïÆ·¹ºÂò´ÎÊý
#  @param shopID É̵êid
#  @param itemShopIndex ÎïÆ·Ë÷Òý
#  @param addBuyCount Ôö¼Ó´ÎÊý
#  @return ¸üкóµÄÒѹºÂò´ÎÊý
def __AddShopItemServerBuyCnt(shopID, itemShopIndex, addBuyCount):
    recTypeListData = __GetShopItemRecData()
    
    shopItemRec = None
    for index in range(recTypeListData.Count()):
        recData = recTypeListData.At(index)
        curShopID = recData.GetValue1()
        curItemShopIndex = recData.GetValue2()
        if curShopID == shopID and curItemShopIndex == itemShopIndex:
            shopItemRec = recData
        
    if shopItemRec == None:
        #»¹Î´¼Ç¼£¬ÔòÌí¼ÓÒ»¸ö¼Ç¼¶ÔÏó
        shopItemRec = recTypeListData.AddRec() 
        shopItemRec.SetValue1(shopID)
        shopItemRec.SetValue2(itemShopIndex)
        shopItemRec.SetValue3(0)
        
    buyCnt = shopItemRec.GetValue3()
    buyCnt += addBuyCount
    shopItemRec.SetValue3(buyCnt)
    return buyCnt


## »ñÈ¡É̵êÈ«·þÏÞ¹ºÎïÆ·¶ÔÓ¦ÒѹºÂò¸öÊý
#  @param shopID
#  @param indexList
#  @return {index:buyCnt, ...}
def __GetShopItemServerBuyCntDict(shopID, indexList):
    findCnt = 0
    buyCntDict = {}
    recTypeListData = __GetShopItemRecData()
    
    for index in range(recTypeListData.Count()):
        recData = recTypeListData.At(index)
        curShopID = recData.GetValue1()
        itemShopIndex = recData.GetValue2()
        buyCnt = recData.GetValue3()
        if curShopID == shopID and itemShopIndex in indexList:
            buyCntDict[itemShopIndex] = buyCnt
            findCnt += 1
            if findCnt >= len(indexList):
                break
        
    return buyCntDict


## »ñÈ¡É̵êRecÊý¾Ý
#  @param None
#  @return recTypeListData
def __GetShopItemRecData():
    recType = ShareDefine.Def_UniversalGameRecType_ShopItem
    universalRecMgr = GameWorld.GetUniversalRecMgr()
    recTypeListData = universalRecMgr.GetTypeList(recType)
    return recTypeListData

## µØͼÆô¶¯Í¨Öª
#  @param None
#  @return
def OnMapServerInitOK():

    TimeShopRefreshDict = ReadChConfig.GetEvalChConfig("TimeShopRefresh")
    
    gameWorld = GameWorld.GetGameWorld()
    
    for shopID in TimeShopRefreshDict.keys():
        
        isOpen = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_ShopState % shopID)
    
        if not isOpen:
            continue
        
        lastRefreshTime = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID)
        
        GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_ShopState % shopID, isOpen)
        GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID, lastRefreshTime)
        
    return

## Íæ¼ÒµÇ¼
#  @param curPlayer
#  @return
def OnPlayerLogin(curPlayer):
    Sync_TimeShopRefreshTime(curPlayer)
    return

## É̵ê״̬±ä¸ü´¦Àí
#  @param curPlayer
#  @param isOpen
#  @return
def OnShopStateChange(dictName, isOpen):
    shopID = dictName[len(ShareDefine.Def_Notify_WorldKey_ShopState) - 2:]
    try:
        shopID = int(shopID)            
    except BaseException:
        GameWorld.ErrLog("É̵êIDÅäÖÃkey´íÎó, key=%s" % dictName)
        return
    
    TimeShopRefreshDict = ReadChConfig.GetEvalChConfig("TimeShopRefresh")
    
    if shopID in TimeShopRefreshDict:
        __DoTimeShopStateChange(shopID, isOpen)
    
    return

## Ö´ÐÐÉ̵ê״̬±ä¸ü´¦Àí
#  @param shopID
#  @param isOpen
#  @return
def __DoTimeShopStateChange(shopID, isOpen):
    
    if not isOpen:
        return
    
    curTime = int(time.time())
    
    gameWorld = GameWorld.GetGameWorld()
    gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID, curTime)
    GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID, curTime)
    Sync_TimeShopRefreshTime()
    return


## ¶¨Ê±É̵êÎïÆ·Ë¢ÐÂ
#  @param tick
#  @return
def Dispose_ShopItemRefresh(tick):
    
    if not GameWorld.SetWorldDictKey(ChConfig.TYPE_TimeShopProcessTick, tick):
        return
    
    TimeShopRefreshDict = ReadChConfig.GetEvalChConfig("TimeShopRefresh")
        
    isNeedSyncTime = False
    curTime = int(time.time())
    gameWorld = GameWorld.GetGameWorld()
    
    for shopID, refreshInterval in TimeShopRefreshDict.items():
        
        isOpen = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_ShopState % shopID)
    
        if not isOpen:
            continue
        
        lastRefreshTime = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID)
        
        if not lastRefreshTime:
            continue
        
        pastTime = max(0, curTime - lastRefreshTime)
        
        if pastTime >= refreshInterval:
            gameWorld.SetDict(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID, curTime)
            GameWorld.SendMapServerMsgEx(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID, curTime)
            isNeedSyncTime = True
    
    if isNeedSyncTime:
        Sync_TimeShopRefreshTime()
        
    return


## ͬ²½¶¨Ê±É̵êˢе¹¼Æʱ
#  @param curPlayer
#  @return
def Sync_TimeShopRefreshTime(curPlayer=None):
    
    refreshTimeListPack = ChPyNetSendPack.tagGCShopRefreshTimeList()
    
    refreshTimeListPack.Clear()
    refreshTimeListPack.ShopTimeInfoList = []

    TimeShopRefreshDict = ReadChConfig.GetEvalChConfig("TimeShopRefresh")
    gameWorld = GameWorld.GetGameWorld()
    curTime = int(time.time())
    
    for shopID, refreshInterval in TimeShopRefreshDict.items():
        
        isOpen = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_ShopState % shopID)
    
        if not isOpen:
            continue
        
        lastRefreshTime = gameWorld.GetDictByKey(ShareDefine.Def_Notify_WorldKey_TimeShopRefreshTime % shopID)
        
        if not lastRefreshTime:
            continue
        
        passTime = max(0, curTime - lastRefreshTime)
        
        refreshShopTime = ChPyNetSendPack.tagGCShopRefreshTime()
        refreshShopTime.Clear()
        refreshShopTime.ShopID = shopID
        refreshShopTime.RemainSecond = max(0, refreshInterval - passTime)
        
        refreshTimeListPack.ShopTimeInfoList.append(refreshShopTime)
    
    refreshTimeListPack.ShopCnt = len(refreshTimeListPack.ShopTimeInfoList)
    
    if refreshTimeListPack.ShopCnt <= 0:
        return
    
    # ֪ͨ¿Í»§¶Ëͬ²½Ê±¼ä        
    if not curPlayer:
        # È«·þ¹ã²¥ÔÚÏßÍæ¼Ò
        playerManager = GameWorld.GetPlayerManager()
        for i in range(0, playerManager.GetPlayerCount()):
            curPlayer = playerManager.GetPlayerByIndex(i)
            if curPlayer == None or curPlayer.GetPlayerID() <= 0:
                continue
            
            NetPackCommon.SendFakePack(curPlayer, refreshTimeListPack)
    else:
        NetPackCommon.SendFakePack(curPlayer, refreshTimeListPack)
    return