#!/usr/bin/python
|
# -*- coding: GBK -*-
|
#
|
##@package
|
#
|
# @todo:
|
#
|
# @author: Alee
|
# @date 2019-1-22 ÉÏÎç11:50:11
|
# @version 1.0
|
#
|
# @note:
|
#
|
#---------------------------------------------------------------------
|
|
from bottle import Bottle, request
|
import md5
|
import urllib2
|
import urllib
|
import json
|
from lib import mylog
|
import DoubleBillDB
|
|
myapp = Bottle()
|
|
DoubleBillColName = 'tagDoubleBill'
|
GMPort = 80
|
|
|
@myapp.route('/DoublieBill.php')
|
def OnDoubleBill():
|
# Íæ¼ÒµÇ¼´Ó·þÎñÆ÷ÇëÇó¶Ò»»·µÀû£¬±ØÐë¼Ç¼¶Ò»»½á¹û£¬ÓÃÓÚ¸´²é;ͨ¹ý·ÃÎÊIP£¬²éÕÒGMͨµÀ·µ»Ø½á¹û30001
|
# ²ÎÊý£ºÍæ¼ÒÕ˺ţ¬²éѯÊÇ·ñÓгäÖµ·µÀû
|
# ·µ»Ø1£ºÎÞ³äÖµ£¬2£ºÒѶһ»£¨Ö»ÄÜÒ»¸ö·þ£©£¬ÆäËû¶î¶ÈΪÏÉÓñ
|
# Êý¾Ý¿â×ֶΠÇþµÀSpID Õ˺ÅAccID ÏÉÓñGold ¶Ò»»ËùÔÚ·þServerID
|
dataDict = request.GET
|
|
gameAccID = dataDict.get("AccID", "") # ÔËÓªÌṩµÄAPPID£¬¼´ÇþµÀ
|
if not gameAccID:
|
print "accID Error", gameAccID
|
return
|
|
try:
|
accID, spID, sid = gameAccID.split("@")
|
except:
|
print "accID Error", gameAccID
|
return
|
|
if not sid:
|
return
|
|
dbController = DoubleBillDB.GetDBEventCon()
|
if not dbController:
|
# ÎÞ·¨»ñÈ¡Êý¾Ý¿â
|
mylog.debug("no dbController")
|
return
|
result, data = dbController.find(DoubleBillColName, {"SpID":spID, "AccID":accID})
|
if not data:
|
# Î޼Ǽ²»ÄÜÁìÈ¡£¬GM·µ»Ø1, ¼õÉÙ·´¸´²éѯ
|
SendGm(gameAccID, 1)
|
return
|
|
rec = data[0]
|
if not rec["Gold"]:
|
# ÎÞÏÉÓñ
|
return
|
|
if rec["ServerID"]:
|
if sid == rec["ServerID"]:
|
#ͬ·þÒÑÁìÈ¡µÄ·µ»ØÏàͬ
|
SendGm(gameAccID, rec["Gold"])
|
return
|
# ²»Í¬·þÒÑÁìÈ¡£¬GM·µ»Ø2, ¼õÉÙ·´¸´²éѯ
|
SendGm(gameAccID, 2)
|
return
|
|
updateDoc = {"SpID":spID, "AccID":accID, "Gold":rec["Gold"], "ServerID":sid}
|
dbController.update(DoubleBillColName, {"SpID":spID, "AccID":accID}, updateDoc)
|
|
mylog.info("OnDoubleBill:%s-%s"%(gameAccID, updateDoc))
|
SendGm(gameAccID, rec["Gold"])
|
return
|
|
def SendGm(gameAccID, dbState):
|
try:
|
serverIP = request.environ.get("REMOTE_ADDR", "0.0.0.0")
|
# GMÍÆË͵ØÖ·
|
#GMToolPage = http://s1.yhlz.09ge.com:30001/Server/Tool.php
|
gmurl = "http://%s:%s/Server/Tool.php"%(serverIP, GMPort)
|
gmkey = "Y25GVFoyOVFjbWtyTDJJckt5OU1OQ3RtUFQxPV"
|
if not gmkey or not gmurl:
|
return
|
|
pack_data = {}
|
pack_data["AccID"] = gameAccID
|
# ·µ»Ø1£ºÎÞ³äÖµ£¬2£ºÒѶһ»£¨Ö»ÄÜÒ»¸ö·þ£©£¬ÆäËû¶î¶ÈΪÏÉÓñ
|
pack_data["GoldState"] = str(dbState)
|
|
pack_data["pack_type"] = "GMT_QDFLDoubleBill"
|
pack_data["key"] = gmkey;
|
pack_data['coding'] = "utf8"
|
|
#ʹÓÃkey¼ÓÃÜ
|
pack_data_dict = json.dumps(pack_data)
|
|
mylog.debug("OnDoubleBill SendGm:%s-%s"%(gmurl, pack_data_dict))
|
sign = md5.md5(pack_data_dict+gmkey).hexdigest()
|
post = {}
|
post['pack'] = pack_data_dict;
|
post['sign'] = sign;
|
result = urllib2.urlopen(gmurl, urllib.urlencode(post), 10)
|
|
content = result.read()
|
result.close()
|
|
mylog.info("ÍÆËͽá¹û GMT_QDFLDoubleBill:%s"%(content))
|
return content
|
except Exception, e:
|
mylog.debug("gm error %s"%e)
|
return
|
|
|
# ²éѯËùÓеÄÊý¾Ý£¬Ö»ÔÚµÚÒ»ÕŵØͼ´¦Àí£¬»º´æ±ÜÃâÇëÇó¹ýÓÚƵ·±
|
@myapp.route('/QueryAllDoubleBill.php')
|
def QueryAllDoubleBill():
|
dataDict = request.GET
|
|
checkInfo = dataDict.get("ccccc", "")
|
if not checkInfo:
|
return
|
if checkInfo != "fanggongji":
|
return
|
|
dbController = DoubleBillDB.GetDBEventCon()
|
if not dbController:
|
# ÎÞ·¨»ñÈ¡Êý¾Ý¿â
|
mylog.debug("no dbController")
|
return
|
# ·µ»ØδÁìÈ¡µÄ
|
result, data = dbController.find(DoubleBillColName, {"ServerID":""})
|
if not data:
|
return
|
|
recDict = {}
|
for rec in data:
|
spID = rec["SpID"]
|
if spID not in recDict:
|
recDict[spID] = [rec["AccID"]]
|
else:
|
recDict[spID].append(rec["AccID"])
|
|
if not recDict:
|
return
|
try:
|
serverIP = request.environ.get("REMOTE_ADDR", "0.0.0.0")
|
# GMÍÆË͵ØÖ·
|
#GMToolPage = http://s1.yhlz.09ge.com:30001/Server/Tool.php
|
gmurl = "http://%s:%s/Server/Tool.php"%(serverIP, GMPort)
|
gmkey = "Y25GVFoyOVFjbWtyTDJJckt5OU1OQ3RtUFQxPV"
|
if not gmkey or not gmurl:
|
return
|
|
mylog.debug("SendGm:%s"%gmurl)
|
pack_data = {}
|
pack_data["tomap"] = json.dumps(recDict)
|
pack_data["pack_type"] = "GMT_AllDoubleBill"
|
pack_data["key"] = gmkey;
|
pack_data['coding'] = "utf8"
|
|
#ʹÓÃkey¼ÓÃÜ
|
pack_data_dict = json.dumps(pack_data)
|
|
mylog.debug("QueryAllDoubleBill SendGm:%s-%s"%(gmurl, pack_data_dict))
|
sign = md5.md5(pack_data_dict+gmkey).hexdigest()
|
post = {}
|
post['pack'] = pack_data_dict;
|
post['sign'] = sign;
|
result = urllib2.urlopen(gmurl, urllib.urlencode(post), 10)
|
|
result.close()
|
|
except Exception, e:
|
mylog.debug("gm error %s"%e)
|
|
|
# 1.²éѯ
|
@myapp.route('/QueryDoubleBill.php')
|
def QueryDoubleBill():
|
# Íæ¼ÒµÇ¼´Ó·þÎñÆ÷ÇëÇó¶Ò»»·µÀû£¬±ØÐë¼Ç¼¶Ò»»½á¹û£¬ÓÃÓÚ¸´²é;ͨ¹ý·ÃÎÊIP£¬²éÕÒGMͨµÀ·µ»Ø½á¹û30001
|
# ²ÎÊý£ºÍæ¼ÒÕ˺ţ¬²éѯÊÇ·ñÓгäÖµ·µÀû
|
# ·µ»Ø1£ºÎÞ³äÖµ£¬2£ºÒѶһ»£¨Ö»ÄÜÒ»¸ö·þ£©£¬ÆäËû¶î¶ÈΪÏÉÓñ
|
# Êý¾Ý¿â×ֶΠÇþµÀSpID Õ˺ÅAccID ÏÉÓñGold ¶Ò»»ËùÔÚ·þServerID
|
dataDict = request.GET
|
|
gameAccID = dataDict.get("AccID", "") # ÔËÓªÌṩµÄAPPID£¬¼´ÇþµÀ
|
if not gameAccID:
|
print "accID Error", gameAccID
|
return
|
|
try:
|
accID, spID, sid = gameAccID.split("@")
|
except:
|
print "accID Error", gameAccID
|
return
|
|
if not sid:
|
return
|
|
dbController = DoubleBillDB.GetDBEventCon()
|
if not dbController:
|
# ÎÞ·¨»ñÈ¡Êý¾Ý¿â
|
mylog.debug("no dbController")
|
return
|
result, data = dbController.find(DoubleBillColName, {"SpID":spID, "AccID":accID})
|
if not data:
|
# Î޼Ǽ²»ÄÜÁìÈ¡£¬GM·µ»Ø1, ¼õÉÙ·´¸´²éѯ
|
return
|
|
return data[0]
|
