8896 【BT2】【主干】【后端】特权令(同步冲突；及修改B209 B210 封包 为B211 B212)

hxp

2021-04-13 84d41bd256d53ebafab1ca79b35a9f91d459366a

 Tool/WebCenter/CouponCode/webapp.py

@@ -24,6 +24,7 @@
from lib import mylog, CommFunc

import os.path

import zipfile

import time



# get: request.query.username request.GET.get('username','')

# post: request.forms.get('username')  request.POST.get('username')

@@ -49,15 +50,26 @@
        

Def_CardMsg = {

               0:"CodeRewardSys2", #  兑换码无效

               1: "CodeRewardSys1", #   兑换卡奖励已发至邮件

               1:"CodeRewardSys1", #   兑换卡奖励已发至邮件

               2:"CodeRewardSys3", #  兑换码已使用过

               3:"CodeRewardSys4",  # 同类型兑换码只能使用一次

               4:"LvErr", # 等级不足

               5:"VipLevel", # VIP等级不足

         }

                

                

                

myapp = Bottle()



# 防止短时间内的多次无效访问 accid：time

AccID_Cache_Dict = {}



def CleanAccID():

    global AccID_Cache_Dict

    
    if len(AccID_Cache_Dict) < 100:

        return 
    AccID_Cache_Dict = {}





#/api/Coupon/index.php?couponBatchId=%s&agentName=%s"

@@ -98,11 +110,25 @@
    return static_file("%s.zip"%couponid, r".\download", download=True)





# 卡类型 开头字母做标识如 g1~999代表此卡只能使用一次 h1~999卡可以重复使用 z开头代表固定码

#================客户端请求参数===============================================================

# channel    是    string    Appid 如jsgameios

# code    是    string    兑换码

# accid    是    string    账号

# spid    是    string    运营商ID，研发自己配置的，如jisu代表极速平台

# sid    是    int    服务器ID 数字

# pushurl    是    string    域名链接s222.xxx.com

# roleid    是    string    玩家游戏名

# level    是    int    玩家等级

# viplevel    是    Int    玩家VIP等级

#===============================================================================



#2018.10.10 混服支持导致账号拼接逻辑变更需要spid

# 卡类型 开头字母做标识如 g1~999代表此卡只能使用一次 h1~999卡可以重复使用 z开头代表固定码 wx开头代表微信商店

# 玩家使用卡号 参数 平台 区服 账号 区服链接（GM用）卡号

# http://center.xxx.com:53003/Coupon/CouponCode.php?channel=appid&code=XXX&accid=YYY&sid=222&pushurl=s222.xxx.com

# http://center.xxx.com:53003/Coupon/CouponCode.php

@myapp.route('/Coupon/CouponCode.php')

def CouponCode():

    global AccID_Cache_Dict

    dataDict = request.GET

    

    for key, value in dataDict.items():

@@ -115,7 +141,10 @@
    codeStr = dataDict.get("code", "")

    if not codeStr:

        return

    
    codeStr = codeStr.strip()

    #只是用来拼接账号

    spID = dataDict.get("spid", "")

        
    accid = dataDict.get("accid", "")

    if not accid:

        return

@@ -128,7 +157,21 @@
        return

    

    # 转化为游戏账号 

    accid = "%s@%s@s%s"%(accid, agentName, sid)

    accid = "%s@%s@s%s"%(accid.lower(), spID, sid)

    
    try:

        CleanAccID()

        #mylog.debug("AccID_Cache_Dict : %s"%str(AccID_Cache_Dict))

        if accid not in AccID_Cache_Dict:

            AccID_Cache_Dict[accid] = int(time.time())

        elif time.time() - AccID_Cache_Dict[accid] < 2:

            mylog.debug("==========bad: fast click  %s"%accid)

            return  
            
        AccID_Cache_Dict[accid] = int(time.time())

    except:

        pass

    
    

    dbController = CouponDB.GetDBEventCon()

    if not dbController:

@@ -140,13 +183,19 @@
    gmresult = {'accID':accid, 'sid':sid, 'channel':agentName}



    #-----------统一固定码处理----------------------

    if codeStr in CommonCards:

    CommonCardsList = CommonCards.get(agentName, [])

    if codeStr in CommonCardsList:

        # 不同固定码各自只能领一次

        result, commondata = dbController.find_one(CouponDB.CouponCodeColName + "_Common", {"code":codeStr, "accid":accid})

        if commondata:

            # 已使用

            gmresult['status'] = 2

            mylog.debug("common status=2")

            return SendGm(gmresult, pushurl)

        
        commCheckStatus = CommCheck(dataDict, codeStr)

        if commCheckStatus != None:

            gmresult['status'] = commCheckStatus

            return SendGm(gmresult, pushurl)

        

        gmresult['status'] = 1

@@ -157,8 +206,40 @@
        mylog.debug("common ok")

        return SendGm(gmresult, pushurl)



    #-----------微信商城----------------------

    if codeStr.startswith('wx'):

        operateID = GetOperateID(agentName)

        if not operateID:

            mylog.debug("wx no appid  = %s"%agentName)

            return

        result, wxdata = dbController.find_one(CouponDB.CouponWXColName, {"code":codeStr, "operateid":operateID})

        if not wxdata:

            return

        
        if int(wxdata['status']) == 1:

            gmresult['status'] = 2

            mylog.debug("wxcard used!")

            return SendGm(gmresult, pushurl)

        
        wxdata['status'] = 1

        wxdata['accid'] = dataDict.get("accid", "")     # 此处用原始账号

        wxdata['usetime'] = str(datetime.datetime.today()).split(".")[0]

        
        wxdata['appid'] = agentName

        wxdata['serverid'] = 's%s'%sid

        wxdata['roleid'] = dataDict.get("roleid", "")

        wxdata['level'] = dataDict.get("level", "")

        wxdata['viplevel'] = dataDict.get("viplevel", "")

        if SendWXBill(wxdata, pushurl):

            # 充值成功

            dbController.update(CouponDB.CouponWXColName, {"code":codeStr, "operateid":operateID}, wxdata)

            # 通知后台记录

            SendDataCollectorBillInfo(wxdata, pushurl, operateID)

        return

    
    #-----------批量兑换码处理，同类型只领取一次----------------------

    result, data = dbController.find_one(CouponDB.CouponCodeColName + "_" + agentName, {"code":codeStr, "channel":agentName})



    
    if not data:

        #无此卡

        gmresult['status'] = 0

@@ -168,6 +249,11 @@
        #已使用，同卡号记录默认可用，避免断线发送失败的情况（未返回结果验证情况下）

        gmresult['status'] = 2

        mylog.debug("card used!")

        return SendGm(gmresult, pushurl)

    
    commCheckStatus = CommCheck(dataDict, data["coupontype"])

    if commCheckStatus != None:

        gmresult['status'] = commCheckStatus

        return SendGm(gmresult, pushurl)

    

    result, data2 = dbController.find_one(CouponDB.CouponBatchColName, {"couponid":data["couponid"]})

@@ -192,17 +278,20 @@
        gmresult['status'] = 0

        mylog.debug("time pass")

        return SendGm(gmresult, pushurl)

    #再查一次是否用过此批次的其他卡, 
    result, data3 = dbController.find_one(CouponDB.CouponCodeColName + "_" + agentName, \

                                          {"couponid":data["couponid"], "accid":accid})

    if data3:

        #用过同类卡，已记录过不再做新记录

        gmresult['status'] = 3

        gmresult['coupontype'] = data["coupontype"]

        gmresult['code'] = codeStr

        mylog.debug("use again")

        return SendGm(gmresult, pushurl)

    

    # h 开头的卡类型可重复使用

    if not codeStr.startswith('h'):

        #再查一次是否用过此批次的其他卡, 
        result, data3 = dbController.find_one(CouponDB.CouponCodeColName + "_" + agentName, \

                                              {"coupontype":data["coupontype"], "accid":accid})

        if data3:

            #用过同类卡，已记录过不再做新记录

            gmresult['status'] = 3

            gmresult['coupontype'] = data["coupontype"]

            gmresult['code'] = codeStr

            mylog.debug("use again")

            return SendGm(gmresult, pushurl)

        
    data['status'] = 1

    data['accid'] = accid

    data['usetime'] = str(datetime.datetime.today())

@@ -216,7 +305,24 @@
    mylog.debug("card ok!")

    return SendGm(gmresult, pushurl)





def CommCheck(dataDict, coupontype):

    ## 通用常规检查

    
    # 使用等级

    lvLimit = ConfigIO.GetInt(coupontype, "LV")

    playerLV = CommFunc.ToIntDef(dataDict.get("level", 0))

    if lvLimit > 0 and playerLV < lvLimit:

        mylog.debug("playerLV(%s) < lvLimit(%s)" % (playerLV, lvLimit))

        return 4

    
    # vip等级相关

    vipLVLimit = ConfigIO.GetInt(coupontype, "VIPLV")

    playerVIPLV = CommFunc.ToIntDef(dataDict.get("viplevel", 0))

    if vipLVLimit > 0 and playerVIPLV < vipLVLimit:

        mylog.debug("playerVIPLV(%s) < vipLVLimit(%s)" % (playerVIPLV, vipLVLimit))

        return 5

    
    return



def SendGm(gmresult, pushurl):

    try:

@@ -268,7 +374,7 @@
        for itemList in Items:

            pack_data["ItemID%s"%i] = str(itemList[0])

            pack_data["ItemCnt%s"%i] = str(itemList[1])

            pack_data["IsBind%s"%i] = '1'

            pack_data["IsBind%s"%i] = str(itemList[2] if len(itemList) > 2 else 0)

            i += 1

            

        pack_data["pack_type"] = "GMT_AddPersonalCompensation"

@@ -283,9 +389,9 @@
        post = {}

        post['pack'] = pack_data_dict;

        post['sign'] = sign;

        result = urllib2.urlopen(gmurl, urllib.urlencode(post), 10)

        result = urllib2.urlopen(gmurl, urllib.urlencode(post), 3)



        content = result.read()

        #content = result.read()

        result.close()

        

        # 成功提示

@@ -306,7 +412,7 @@
        post['sign'] = sign;

        urllib2.urlopen(gmurl, urllib.urlencode(post), 3)

        

        return content

        return 0

    except Exception, e:

        mylog.debug("gm error %s"%e)

    return

@@ -321,3 +427,78 @@
    

    return

    



# 通过appid找到运营商

def GetOperateID(appid):

    appidDict = eval(ConfigIO.GetValue("Coupon", "appid_dict"))

    for key, value in appidDict.items():

        if appid in value:

            return key

    return ""







# 微信入口充值

def SendWXBill(wxdata, pushurl):

    try:

        billurl = "http://%s/api/exchange/index.php"%pushurl



        post = {}

        post['AccountID'] = wxdata['accid']

        post['RegionName'] = wxdata['serverid'] 
        post['OrderAmount'] = wxdata['money'] 
        post['BillNO'] = wxdata['orderid'] 
        post['OrderInfo'] = wxdata['orderinfo'] 
        post['OperatorID'] = wxdata['appid'] 
        
        key = ConfigIO.GetValue("Coupon", "key_%s"%post['OperatorID'])

        # $sign=md5($AccountID.$OrderAmount.$BillNO.$RegionName.$key)

        mylog.debug("appid = %s  key = %s"%(post['OperatorID'], key))

        
        sign = md5.md5(post['AccountID'] + str(post['OrderAmount']) + post['BillNO'] + post['RegionName'] + key).hexdigest()

        
        post['Sign'] = sign

        result = urllib2.urlopen(billurl, urllib.urlencode(post), 3)

        resultDict = json.loads(result.read())

        
        mylog.debug("resultDict = %s "%(resultDict))



        if int(resultDict["errorcode"]) > 0:

            return True

    except Exception, e:

        mylog.info("SendWXBill error %s"%e)

    return False



# 通知后台数据中心记录

def SendDataCollectorBillInfo(wxdata, pushurl, operateID):

    try:

        billurl = "http://recharge.game.2460web.com:12000/api/notify/swwx"

    
        post = {}

        post['appid'] = wxdata['appid']

        post['regionid'] = wxdata['serverid'] 
        post['orderid'] = wxdata['orderid'] 
        post['passport'] = wxdata['accid'] 
        post['roleid'] =  wxdata['roleid']

        post['ordertitle'] = wxdata['ordertitle'].encode("UTF8")

        post['orderinfo'] = wxdata['orderinfo']

        post['money'] = wxdata['money'] 
        post['ip'] = wxdata['ip'] 
        post['level'] = wxdata['level'] 
        post['viplevel'] = wxdata['viplevel'] 
        post['time'] = int(time.time())

        
        key = ConfigIO.GetValue("Coupon", "key_%s"%post['appid'])

        #md5(appid=$appid&regionid=$regionid&passport=$passport&&money=$money&time=$time$app_secret) 
        signStr = "appid=%s&regionid=%s&passport=%s&money=%s&time=%s%s"%(\

                    post['appid'], post['regionid'], post['passport'], post['money'], post['time'], key)

        sign = md5.md5(signStr).hexdigest()

        #mylog.debug("SendDataCollectorBillInfo  %s-%s-%s-%s"%(signStr, sign, key, post))

        post['sign'] = sign

        result = urllib2.urlopen(billurl +"?" + urllib.urlencode(post), timeout =3)

        #mylog.debug("SendDataCollectorBillInfo result %s"%result.read())



    except Exception, e:

        mylog.debug("SendDataCollectorBillInfo error %s"%e)