#!/usr/bin/python
|
# -*- coding: utf-8 -*-
|
#
|
##@package
|
#
|
# @todo: 受理HTTP请求
|
#
|
# @author: Alee
|
# @date 2018-5-4 22:10:51
|
# @version 1.0
|
#
|
# @note: 中文必须传utf8，收到的为urlencode内容 .decode('gbk').encode('utf8')
|
#
|
#---------------------------------------------------------------------
|
|
from bottle import Bottle, request
|
import logging
|
import jpush
|
import requests
|
import urllib
|
from lib import ConfigIniReader
|
import json
|
|
#app_key = u'22186239fee975f883198cf4'
|
#master_secret = u'cb2b72ba143a3f3fb13a6f45'
|
|
#_jpush = jpush.JPush(app_key, master_secret)
|
#_jpush.set_logging("DEBUG")
|
|
requests.packages.urllib3.disable_warnings()
|
|
# get: request.query.username request.GET.get('username','')
|
# post: request.forms.get('username') request.POST.get('username')
|
#===============================================================================
|
# @myapp.route('/cool/kk/:name3/:count#\\d+#')
|
# def maybe(name3, count):
|
#===============================================================================
|
|
myapp = Bottle()
|
|
Def_Split_Mark = "|"
|
|
# 文本格式GBK取出出来转unicode，服务器发过来也是unicode 推送统一unicode
|
Def_NoName = ConfigIniReader.GetConfig().GetValue('Def_NoName').decode("gbk")
|
NotifyFormat = ConfigIniReader.GetConfig().GetValue('NotifyFormat').decode("gbk")
|
|
|
# 推送消息
|
# 混服使用对应不同key {平台ID：[[玩家个推ID， 玩家名],[玩家个推ID2， 玩家名2]。。。]}
|
# {u'822055139': [[u'160a3797c8504368d60', u'\u76f8\u601d\u59ff\u6653']]}-1234567
|
|
@myapp.route('/getui/index.php', method='POST')
|
def JGGeTui():
|
getDict = request.POST
|
notifyMsg = urllib.unquote(getDict.get("NotifyMsg","")).decode("utf8")
|
playerDict = json.loads(urllib.unquote_plus(getDict.get("PlayerInfo", "")))
|
|
logging.info("%s-%s"%(playerDict, notifyMsg))
|
if not playerDict:
|
# 只能单\多推，不能全部推
|
return
|
|
osName = jpush.all_
|
|
#logging.info("%s-%s-%s"%(getDict.get("RegID",""), playrNames, notifyMsg))
|
#return "账号：" + getDict.get("AccountID",""), "充值", getDict.get("money","")
|
|
# 约定 {appID:[推送ID1， 推送ID2...]} 为群推
|
# 约定 {appID:[[推送ID1, 玩家名称1]， [推送ID2, 玩家名称2]...]} 为一一个推
|
for appID in playerDict:
|
# 找到对应KEY
|
try:
|
app_key = ConfigIniReader.GetConfig().GetValue('app_key_%s'%appID)
|
master_secret = ConfigIniReader.GetConfig().GetValue('master_secret_%s'%appID)
|
except:
|
logging.warn("no key = %s"%appID)
|
continue
|
jpushObj = jpush.JPush(app_key, master_secret)
|
|
if type(playerDict[appID][0]) != list: # 列表中的元素不是列表说明是群推
|
PushOne(jpushObj, playerDict[appID], notifyMsg, osName)
|
else:
|
# 不支持notifymsg内容不一样的多推，只能一一对应推送
|
for regID, playerName in playerDict[appID]:
|
playerName = playerName if playerName else Def_NoName
|
#playerName = urllib.unquote(playerName)
|
#playerName = playerName.encode('utf-8')
|
geTuiMsg = NotifyFormat%(playerName, notifyMsg)
|
#logging.info("PushOne%s-%s-%s"%([regID], geTuiMsg, osName))
|
PushOne(jpushObj, [regID], geTuiMsg, osName)
|
|
|
def PushOne(jpushObj, regIDList, notifyMsg, osName=jpush.all_):
|
# 1.推送对象 单推（多推）； 群推只能提交中心推
|
# 2.平台 ios 安卓 默认全平台
|
# 3.通知消息
|
|
push = jpushObj.create_push()
|
push.audience = {"registration_id" : regIDList}
|
push.notification = jpush.notification(alert=notifyMsg)
|
push.platform = osName
|
push.options = {"time_to_live":300}
|
#push.options = {"apns_production": False,}
|
|
try:
|
response=push.send()
|
except:
|
pass
|
|
|
|
