#!/usr/bin/python
|
# -*- coding: utf-8 -*-
|
#
|
##@package
|
#
|
# @todo: 受理HTTP请求
|
#
|
# @author: xdh
|
# @date 2018-6-8 17:10:51
|
# @version 1.0
|
#
|
# @note: 中文必须传utf8，收到的为urlencode内容 .decode('gbk').encode('utf8')
|
#
|
#---------------------------------------------------------------------
|
|
from bottle import Bottle, request
|
import logging
|
import requests
|
import urllib
|
import shelve
|
import time
|
from lib import ConfigIniReader
|
import threading
|
|
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()
|
|
voiceInfoDict = shelve.open('voice.db', writeback=False)
|
g_lastCheckTick = 0
|
delCD = int(ConfigIniReader.GetConfig().GetValue('delCD'))
|
outTime = int(ConfigIniReader.GetConfig().GetValue('outTime'))
|
|
#存储内容 {'playerID_语音唯一ID':[time,Content],..}
|
#post内容 playerID=玩家ID voiceID=语音唯一ID content=语音内容 appid
|
#dotype upload、download
|
|
@myapp.route('/voice/:dotype', method=['POST'])
|
def VoiceSave(dotype):
|
global voiceInfoDict
|
|
getDict = request.POST
|
|
#logging.info("request.POST=%s"%(str(dict(getDict))))
|
|
playerID = getDict.get("playerID",'')
|
voiceID = getDict.get("voiceID",'')
|
content = getDict.get("content","")
|
#content = urllib.unquote(getDict.get("content",""))
|
|
if not playerID or not voiceID:
|
logging.error("POST未找到参数 playerID=%s，voiceID=%s"%(playerID, voiceID))
|
return
|
|
keyStr = '%s_%s'%(playerID, voiceID)
|
curTime = int(time.time())
|
|
if dotype == 'upload': #存储
|
saveData = [curTime, content]
|
voiceInfoDict[keyStr] = saveData
|
voiceInfoDict.sync()
|
|
#logging.info("upload %s-%s-%s"%(playerID, voiceID, saveData))
|
returnVoiceData= None
|
|
elif dotype == 'download':#下载
|
voiceData=voiceInfoDict.get(keyStr, [])
|
if not voiceData:
|
logging.info("download not find voice %s-%s-%s"%(playerID, voiceID, voiceData))
|
returnVoiceData = {"playerID":playerID, "voiceID":voiceID}
|
else:
|
#logging.info("download %s-%s-%s"%(playerID, voiceID, voiceData))
|
returnVoiceData = {"playerID":playerID, "voiceID":voiceID, "content":voiceData[1]}
|
|
else:
|
logging.error("dotype not in [download, upload] %s-%s-%s"%(playerID, voiceID, dotype))
|
return
|
|
#voiceInfoDict.close()
|
#触发一次处理旧数据(放最后)
|
DelOldVoice(curTime)
|
return returnVoiceData
|
t1 = None
|
def DelOldVoice(tick):
|
#处理旧数据
|
global g_lastCheckTick
|
global t1
|
if g_lastCheckTick and tick - g_lastCheckTick < delCD:
|
#半小时处理一次
|
return
|
g_lastCheckTick = tick
|
#新开线程处理删除逻辑，防止数据过大导致回复慢
|
if t1 and t1.isAlive():
|
return
|
#print threading.activeCount()
|
t1 = threading.Thread(target=__DelOldVoice)
|
t1.start()
|
return
|
|
def __DelOldVoice():
|
global voiceInfoDict
|
|
tick = int(time.time())
|
for voiceKey, voiceData in voiceInfoDict.items():
|
saveTime = voiceData[0]
|
if tick - saveTime > outTime: #删除超过半小时的数据
|
if voiceInfoDict.pop(voiceKey, 0):
|
voiceInfoDict.sync()
|
#logging.info("del old record voiceKey=%s"%voiceKey)
|
#voiceInfoDict.close()
|
|
return
|
