代码仅供参考，请根据自身业务情况修改
#!/usr/bin/python3
#-*- encoding:utf-8 -*-
'''
pip3 install -r requirements.txt
pip3 install requests_toolbelt
pip3 install pymysql
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple matplotlib
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple numpy
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple openpyxl
pip3 install -i https://pypi.tuna.tsinghua.edu.cn/simple xlsxwriter
'''
import requests
import json
from requests_toolbelt import MultipartEncoder
from PIL import Image
import re
##
import pymysql
import sys
import time
import datetime
#
import os
import numpy as np
import matplotlib.pyplot as plt
import matplotlib
#from matplotlib import font_manager
import random
import shutil
import datetime
import pandas as pd
import xlrd
import openpyxl
# import xlsxwriter
# from openpyxl.workbook import Workbook
# from openpyxl.writer.excel import ExcelWriter
# from openpyxl.drawing.image import Image
class DBUtil(object):
host = "10.8.0.1"
port = 3306
user = "root"
password = "pwd@123456."
db = "mysql"
charset = "utf8"
conn = None
def __init__(self,db='mysql',host='10.8.0.1',port=3306,user='root',password='123456',charset='utf8'):
self.db = db
self.host = host
self.port = port
self.user = user
self.password = password
self.charset = charset
pass
def db_connect(self):
try:
#self.db = db_name
#print(self.db)
self.conn = pymysql.connect(host=self.host,port=self.port,user=self.user,password=self.password,db=self.db,charset=self.charset)
cursor = self.conn.cursor()
except Exception as e:
print(e)
else:
print('Connect Success:%s' % cursor)
def db_sql(self,command,sql):
"""
查询数据库数据
:param command:
:param sql:
:return:
"""
if not self.conn:
print("no connect db")
sys.exit()
cursor = self.conn.cursor()
if command in ('SELECT', 'select'):
# 如果为查询指令
sql = sql.encode('utf-8')
try:
cursor.execute(sql)
result = cursor.fetchall()
return result
except Exception as e:
print(e)
finally:
self.conn.close()
elif command in ('delete', 'DELETE', 'update', 'UPDATE', 'insert', 'INSERT'):
# 如果为增删改
sql = sql.encode('utf-8')
try:
cursor.execute(sql)
self.conn.commit()
except Exception as e:
# 如果失败则回滚
self.conn.rollback()
print(e)
finally:
self.conn.close()
else:
print('Command Error!')
class qywx:
# 部门ID
'''
22 [{"id":14,"name":"总经理办公室","parentid":1,"order":100001000,"department_leader":["XingYe"]},{"id":19,"name":"策划","parentid":18,"order":100000000,"department_leader":[]},{"id":22,"name":"程序","parentid":18,"order":99997000,"department_leader":[]},{"id":24,"name":"商务","parentid":5,"order":99995000,"department_leader":[]},{"id":25,"name":"市场","parentid":5,"order":99994000,"department_leader":[]}]
'''
#
corpid = 'ww953722a35a02111a' #步骤1-3中的企业id
app_list = [
(1000002, '-iKikad01lHeFVaZ_2G01F3sZg5T0TV6l3OUXtf2Xr0') #此处将步骤1-2中的AgentId 和 Secret分别填入，多个应用逗号隔开
]
def __init__(self, app_id): #app_id 按app_list顺序编号
self.agentid, self.corpsecret = qywx.app_list[app_id]
# 上传临时文件素材接口，图片也可使用此接口，20M上限
def post_file(self, filepath, filename):
response = requests.get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={corpsecret}".format(corpid=qywx.corpid, corpsecret=self.corpsecret))
data = json.loads(response.text)
access_token = data['access_token']
post_file_url = "https://qyapi.weixin.qq.com/cgi-bin/media/upload?access_token={access_token}&type=file".format(access_token=access_token)
m = MultipartEncoder(
fields={'file': (filename, open(filepath + filename, 'rb'), 'multipart/form-data')},
)
r = requests.post(url=post_file_url, data=m, headers={'Content-Type': m.content_type})
js = json.loads(r.text)
print("upload " + js['errmsg'])
if js['errmsg'] != 'ok':
return None
return js['media_id']
# 向应用发送图片接口，_message为上传临时素材后返回的media_id
def send_img(self, _message, useridlist = ['name1|name2'],toparty=None):
useridstr = "|".join(useridlist)
response = requests.get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={corpsecret}".format(corpid=qywx.corpid, corpsecret=self.corpsecret))
data = json.loads(response.text)
access_token = data['access_token']
json_dict = {
"touser" : useridstr,
"msgtype" : "image",
"agentid" : self.agentid,
"image" : {
"media_id" : _message,
},
"safe": 0,
"enable_id_trans": 1,
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
if not toparty:
print("use default")
else:
del json_dict['touser']
json_dict['toparty'] = toparty
json_str = json.dumps(json_dict)
response_send = requests.post("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={access_token}".format(access_token=access_token), data=json_str)
print("send to " + useridstr + ' ' + json.loads(response_send.text)['errmsg'])
return json.loads(response_send.text)['errmsg'] == 'ok'
# 向应用发送文字消息接口，_message为字符串
def send_text(self, _message, useridlist = ['name1|name2'],toparty=None):
useridstr = "|".join(useridlist) # userid 在企业微信-通讯录-成员-账号
response = requests.get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={corpsecret}".format(corpid=qywx.corpid, corpsecret=self.corpsecret))
data = json.loads(response.text)
access_token = data['access_token']
json_dict = {
"touser" : useridstr,
"msgtype" : "text",
"agentid" : self.agentid,
"text" : {
"content" : _message
},
"safe": 0,
"enable_id_trans": 1,
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
if not toparty:
print("use default")
else:
del json_dict['touser']
json_dict['toparty'] = toparty
json_str = json.dumps(json_dict)
response_send = requests.post("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={access_token}".format(access_token=access_token), data=json_str)
print("send to " + useridstr + ' ' + json.loads(response_send.text)['errmsg'])
return json.loads(response_send.text)['errmsg'] == 'ok'
# 向应用发送markdown消息接口，_message为字符串
def send_markdown(self, _message, useridlist = ['name1|name2'],toparty=None):
useridstr = "|".join(useridlist) # userid 在企业微信-通讯录-成员-账号
response = requests.get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={corpsecret}".format(corpid=qywx.corpid, corpsecret=self.corpsecret))
data = json.loads(response.text)
access_token = data['access_token']
json_dict = {
"touser" : useridstr,
"msgtype" : "markdown",
"agentid" : self.agentid,
"markdown" : {
"content" : _message
},
"safe": 0,
"enable_id_trans": 1,
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
if not toparty:
print("use default")
else:
del json_dict['touser']
json_dict['toparty'] = toparty
json_str = json.dumps(json_dict)
response_send = requests.post("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={access_token}".format(access_token=access_token), data=json_str)
print("send to " + useridstr + ' ' + json.loads(response_send.text)['errmsg'])
return json.loads(response_send.text)['errmsg'] == 'ok'
# 向应用发送file消息接口，_message为上传临时素材后返回的media_id
def send_file(self, _message, useridlist = ['name1|name2'],toparty=None):
useridstr = "|".join(useridlist) # userid 在企业微信-通讯录-成员-账号
response = requests.get("https://qyapi.weixin.qq.com/cgi-bin/gettoken?corpid={corpid}&corpsecret={corpsecret}".format(corpid=qywx.corpid, corpsecret=self.corpsecret))
data = json.loads(response.text)
access_token = data['access_token']
json_dict = {
"touser" : useridstr,
"msgtype" : "file",
"agentid" : self.agentid,
"file" : {
"media_id" : _message
},
"safe": 0,
"enable_id_trans": 1,
"enable_duplicate_check": 0,
"duplicate_check_interval": 1800
}
if not toparty:
print("use default")
else:
del json_dict['touser']
json_dict['toparty'] = toparty
json_str = json.dumps(json_dict)
response_send = requests.post("https://qyapi.weixin.qq.com/cgi-bin/message/send?access_token={access_token}".format(access_token=access_token), data=json_str)
print("send to " + useridstr + ' ' + json.loads(response_send.text)['errmsg'])
return json.loads(response_send.text)['errmsg'] == 'ok'
def get_login_count():
unit = 3600
cur_time = int(time.time())
hour_stamp = cur_time - ( cur_time % unit )
prev_stamp = hour_stamp - 3600
prev_time_struct = time.localtime(prev_stamp)
print(prev_stamp)
prev_date_string = time.strftime("%Y-%m-%d %H:%M:%S", prev_time_struct)
cur_time_struct = time.localtime(hour_stamp)
cur_date_string = time.strftime("%Y-%m-%d %H:%M:%S", cur_time_struct)
date_int_string = time.strftime("%Y%m%d",prev_time_struct)
db = DBUtil("db_authen_log")
sql = "SELECT COUNT(DISTINCT a_uid) as login FROM tb_authen_log_{} WHERE a_login_time>={} AND a_login_time<{} ;".format(date_int_string, prev_stamp, hour_stamp);
print("{} - {} : sql:{}".format(prev_date_string,cur_date_string, sql))
db.db_connect()
data = db.db_sql('SELECT',sql)
count_login = 0
for i in data:
count_login = i[0]
target = {"key":"login_count","name":"登录人数（全渠道）","value":count_login,"start_time":prev_date_string, "end_time":cur_date_string,"sql":sql}
return target
def get_pay_sum():
unit = 3600
cur_time = int(time.time())
hour_stamp = cur_time - ( cur_time % unit )
prev_stamp = hour_stamp - 3600
prev_time_struct = time.localtime(prev_stamp)
print(prev_stamp)
prev_date_string = time.strftime("%Y-%m-%d %H:%M:%S", prev_time_struct)
cur_time_struct = time.localtime(hour_stamp)
cur_date_string = time.strftime("%Y-%m-%d %H:%M:%S", cur_time_struct)
date_int_string = time.strftime("%Y%m%d",prev_time_struct)
db = DBUtil(db="db_pay_log")
sql = "SELECT SUM(p_price) FROM tb_pay_log_{} WHERE p_status = 0 AND p_finishTime >= {} AND p_finishTime < {} ;".format(date_int_string, prev_stamp, hour_stamp);
print("{} - {} : sql:{}".format(prev_date_string,cur_date_string, sql))
db.db_connect()
data = db.db_sql('SELECT',sql)
sum_data = 0
for i in data:
sum_data = i[0]
target = {"key":"pay_sum","name":"充值金额（全渠道）","value":sum_data,"start_time":prev_date_string, "end_time":cur_date_string,"sql":sql}
return target
def get_login_count_hour():
unit = 3600
cur_time = int(time.time())
hour_stamp = cur_time - ( cur_time % unit )
prev_stamp = hour_stamp - 3600
prev_time_struct = time.localtime(prev_stamp)
print(prev_stamp)
prev_date_string = time.strftime("%Y-%m-%d %H:%M:%S", prev_time_struct)
cur_time_struct = time.localtime(hour_stamp)
cur_date_string = time.strftime("%Y-%m-%d %H:%M:%S", cur_time_struct)
date_int_string = time.strftime("%Y%m%d",prev_time_struct)
db = DBUtil(db="db_authen_log")
sql = "select FROM_UNIXTIME(a_login_time, '%H') AS time, COUNT(1) from tb_authen_log_{} GROUP BY time;".format(date_int_string);
db.db_connect()
data = db.db_sql('SELECT',sql)
target = {"key":"login_count_hour","name":"登录人数（每小时）","value":data,"sql":sql}
return target
def get_pay_sum_hour():
unit = 3600
cur_time = int(time.time())
hour_stamp = cur_time - ( cur_time % unit )
prev_stamp = hour_stamp - 3600
prev_time_struct = time.localtime(prev_stamp)
print(prev_stamp)
prev_date_string = time.strftime("%Y-%m-%d %H:%M:%S", prev_time_struct)
cur_time_struct = time.localtime(hour_stamp)
cur_date_string = time.strftime("%Y-%m-%d %H:%M:%S", cur_time_struct)
date_int_string = time.strftime("%Y%m%d",prev_time_struct)
db = DBUtil(db="db_pay_log")
sql = "select FROM_UNIXTIME(p_finishTime, '%H') AS time, SUM(p_price) from tb_pay_log_{} GROUP BY time;".format(date_int_string);
db.db_connect()
data = db.db_sql('SELECT',sql)
target = {"key":"pay_sum_hour","name":"充值概况(每小时)","value":data,"sql":sql}
return target
def get_pay_order_hour():
unit = 3600
cur_time = int(time.time())
hour_stamp = cur_time - ( cur_time % unit )
cur_time_struct = time.localtime(hour_stamp)
prev_stamp = hour_stamp - 3600
prev_time_struct = time.localtime(prev_stamp)
date_int_string = time.strftime("%Y%m%d",prev_time_struct)
db = DBUtil(db="db_pay_log")
sql = "select FROM_UNIXTIME(p_finishTime, '%H') AS time, COUNT(1) from tb_pay_log_{} GROUP BY time;".format(date_int_string);
db.db_connect()
data = db.db_sql('SELECT',sql)
target = {"key":"pay_sum_hour","name":"充值订单数（每小时）","value":data,"sql":sql}
return target
def create_plt_data(x,y,title,xlabel,ylabel,filename):
# 准备数据
x_data = x #[f"{i}" for i in range(1, 25)]
y_data = y #[random.randint(100, 300) for i in range(24)]
print("titile:{} ,x:{} ,y:{}".format(title,x,y))
# print(matplotlib.matplotlib_fname())
plt.clf()
# 正确显示中文和负号
plt.rcParams["font.sans-serif"] = ["SimHei"]
plt.rcParams["axes.unicode_minus"] = False
# 画图，plt.bar()可以画柱状图
for i in range(len(x_data)):
plt.bar(x_data[i], y_data[i])
# 设置图片名称
plt.title(title)
# 设置x轴标签名
plt.xlabel(xlabel)
# 设置y轴标签名
plt.ylabel(ylabel)
save_dir = "/tmp/"
out = None
if not os.path.exists(save_dir):
print("[warning] file save dir not exists")
else:
filepath = save_dir+filename
print("[info] will save file to:",filepath)
plt.savefig(filepath)
out = filepath
# plt.show()
# plt.savefig(path+'scatter.jpg')#保存图片
# plt.savefig(path+'plot.jpg')#保存图片\n",
return {'out':out,'dir':save_dir,'filename':filename}
def create_plt_duiji_data(x,y1,y2,title,xlabel,ylabel,y2label,filename):
plt.clf()
plt.rcParams["font.sans-serif"] = ["SimHei"]
plt.rcParams["axes.unicode_minus"] = False
plt.bar(x,y2,width=0.4,color='#dddddd',zorder=5,label=y2label)
plt.bar(x,y1,width=0.4,bottom=y2,color='#d62728',zorder=5,label=ylabel)
c=np.mean(y1)
plt.axhline(y=c,color="black",linestyle=':')
plt.title(title)
plt.xlabel(xlabel)
plt.tick_params(axis='x',length=0)
plt.grid(axis='y',alpha=0.5,ls='--')
plt.legend(frameon=False)
plt.tight_layout()
#plt.ylabel(ylabel)
save_dir = "/tmp/"
out = None
if not os.path.exists(save_dir):
print("[warning] file save dir not exists")
else:
filepath = save_dir+filename
print("[info] will save file to:",filepath)
plt.savefig(filepath)
out = filepath
return {'out':out,'dir':save_dir,'filename':filename}
def create_plt_line(x,y,title,xlabel,ylabel,filename):
# 准备数据
x_data = x #[f"{i}" for i in range(1, 25)]
y_data = y #[random.randint(100, 300) for i in range(24)]
print("titile:{} ,x:{} ,y:{}".format(title,x,y))
# print(matplotlib.matplotlib_fname())
plt.clf()
# 正确显示中文和负号
plt.rcParams["font.sans-serif"] = ["SimHei"]
plt.rcParams["axes.unicode_minus"] = False
#x_ticks_label=["{}:00".format(i) for i in x]
#rotation表示旋转角度
#设置x坐标
#plt.xticks(x,x_ticks_label,rotation=45)
#y_ticks_label=['{}'.format(i) for i in range(min(y),max(y)+1)]
#设置y坐标
#plt.yticks(range(min(y),max(y)+1),y_ticks_label)
plt.plot(x,y,color='blue',alpha=0.8,marker='*',linestyle='--',linewidth=1)
#plt.plot(x,y,color='blue',ls='-',lw=1,marker='*',markevery=20)
# 设置图片名称
plt.title(title,color='black')
# 设置x轴标签名
plt.xlabel(xlabel)
# 设置y轴标签名
plt.ylabel(ylabel)
save_dir = "/tmp/"
out = None
if not os.path.exists(save_dir):
print("[warning] file save dir not exists")
else:
filepath = save_dir+filename
print("[info] will save file to:",filepath)
plt.savefig(filepath)
out = filepath
# plt.show()
# plt.savefig(path+'scatter.jpg')#保存图片
# plt.savefig(path+'plot.jpg')#保存图片\n",
return {'out':out,'dir':save_dir,'filename':filename}
def totalGameOnline(urls,filter_keys=None):
data = {}
for url in urls:
response = requests.get(url)
# regex = r'^haproxy_backend_current_sessions\{backend="(.*?)"\} (\d+)$'
lines = response.text.split('\n')
for line in lines:
if not line.startswith('haproxy_backend_current_sessions'):
continue
result = re.match(r'^haproxy_backend_current_sessions\{backend="(.*?)"\} (\d+)$', line)
if result:
service_name = result.group(1)
online_size = int(result.group(2))
if filter_keys and service_name in filter_keys:
continue
if service_name in data:
# data[service_name] += data[service_name]+online_size
# print(online_size)
if online_size > 0:
data[service_name] = (data[service_name]+online_size)
else:
data[service_name] = online_size
return data
online_metrics_urls=[
"http://127.0.0.1:9912/metrics",
"http://127.0.0.1:9913/metrics",
"http://127.0.0.1:9914/metrics",
"http://127.0.0.1:9915/metrics",
"http://127.0.0.1:9916/metrics"
]
game_tag_with_name={
"game-gate" : "游戏大厅",
"game-ddz-bs" : "斗地主比赛场[id 401-450]",
"game-ddz4-pt" : "四斗普通场[id 61-65]",
"game-ddz4-bxp" : "四斗不洗牌场[id 127-180]",
"game-ddz4-hb" : "四斗红包场[id 68]",
"game-ddz3-pt" : "三斗普通场[id 71-74]",
"game-ddz3-bxp" : "三斗不洗牌[id 124-126]",
"game-ddz3-hb" : "三斗红包场[id 76]",
"game-ddz2-pt" : "二斗普通场[id 81-84]",
"game-ddz2-yl" : "二斗娱乐场[id 69]",
"game-ddz2-hf" : "二斗话费场[id 118]",
"game-dyj-pt" : "大赢家(拼三张)[id 77-80]",
"game-jpfc-pt" : "极品飞车（奔驰宝马)[id 100-106]",
"game-brdp-pt" : "百人斗牌（牛牛)[id 90-91]",
"game-sgj-pt" : "水果机[id 107]",
"game-yyl-pt":"摇摇乐[id 105]",
"game-jkby-pt":"杰克捕鱼[id 109|112|113|120]",
"game-shz-pt":"水浒传[id 121-123]",
"game-ermj-pt":"二人麻将[id 130-133]",
"game-xlmj-pt":"血流麻将[id 139-142]",
"game-guandan-pt":"掼蛋[id 143-147]",
"game-xmbd-pt" : "消灭病毒[id 160]",
"game-bdzc-pt" : "病毒战场[id 170]",
"game-sldj-pt" : "首领对决[id 175]",
"game-lzddz4-pt" : "连炸斗地主[id 51-54]"
}
tag_xxyx=["game-lzddz4-pt","game-guandan-pt","game-ermj-pt","game-xlmj-pt","game-ddz-bs","game-ddz4-pt","game-ddz4-bxp","game-ddz4-hb","game-ddz3-pt","game-ddz3-bxp","game-ddz3-hb","game-ddz2-pt","game-ddz2-yl","game-ddz2-hf"]
def getOnlineStr():
data = totalGameOnline(online_metrics_urls,["admin_stats","game-chat"])
gate = data['game-gate']
del data['game-gate']
val = sum(data.values())
online_info = "\n\n## 在线人数(实时) ##\n"
online_info += "\n游戏大厅: {} 人\n".format(gate)
online_info += "\n游戏局内: {} 人\n".format(val)
dict= sorted(data.items(), key=lambda d:d[1], reverse = True)
for index, item in enumerate(dict):
tag = item[0]
name = game_tag_with_name[tag]
online = data[tag]
rate = (round(online/val,4)*100.0)
online_info += "\n{}. {}: {}人({:.2f}%)\n".format((index+1),name,online,rate)
# print(f'{name}:{online} \n')
return online_info
def getOnlineStrSimple():
data = totalGameOnline(online_metrics_urls,["admin_stats","game-chat"])
gate = data['game-gate']
del data['game-gate']
val = sum(data.values())
online_info = "\n\n##在线人数(实时采样)##\n"
online_info += "\n游戏大厅: {} 人\n".format(gate)
online_info += "\n游戏局内: {} 人\n".format(val)
xxyx_online=0
xyx_online=0
print(tag_xxyx)
for tag in data:
print(tag)
if tag in tag_xxyx:
xxyx_online += data[tag]
else:
xyx_online += data[tag]
online_info += "\n休闲游戏: {}人({:.2f}%)\n".format(xxyx_online,(round(xxyx_online/val,4)*100.00))
online_info += "\n小游戏: {}人({:.2f}%)\n".format(xyx_online,(round(xyx_online/val,4)*100.00))
#online_info += "\n小游戏: {}人({:.2f}%)\n".format(xyx_online,(round(xyx_online/val,4)*100.00))
# print(f'{name}:{online} \n')
return online_info
def getOnlineMap():
data = totalGameOnline(online_metrics_urls,["admin_stats","game-chat"])
gate = data['game-gate']
del data['game-gate']
val = sum(data.values())
xxyx_online=0
xyx_online=0
print(tag_xxyx)
for tag in data:
print(tag)
if tag in tag_xxyx:
xxyx_online += data[tag]
else:
xyx_online += data[tag]
online_dict = {}
online_dict["gate"] = gate
online_dict["game"] = val
online_dict['xxyx'] = xxyx_online
online_dict['xxyx_rate'] = "{:.2f}%".format((round(xxyx_online/val,4)*100.00))
online_dict['xyx'] = xyx_online
online_dict['xyx_rate'] = "{:.2f}%".format((round(xyx_online/val,4)*100.00))
return online_dict
def zhibiao():
send_wechat1 = False
send_wechat2 = False
send_wechat3 = True
qy = qywx(0)
m_login = get_login_count()
m_pay = get_pay_sum()
date_time = time.strftime("%Y-%m-%d", time.localtime())
date_time_hour = time.strftime("%Y%m%d%H", time.localtime())
weekList = ["星期一","星期二","星期三","星期四","星期五","星期六","星期日"]
week = weekList[datetime.datetime.now().weekday()]
msg_login = "## 指标统计 ##\n\n起始时间:{} \n\n截止时间:{}\n\n指标名称:{} \n\n指标数值:{}人".format(m_login["start_time"],m_login["end_time"],m_login["name"],m_login["value"]);
msg_pay = "## 指标统计 ##\n\n起始时间:{} \n\n截止时间:{}\n\n指标名称:{} \n\n指标数值:{}元".format(m_pay["start_time"],m_pay["end_time"],m_pay["name"],m_pay["value"]);
# 发送文本消息
msg_wechat = msg_login+"\n\n"+msg_pay
online_map = getOnlineMap()
msg_tongji = "### 业务指标\n>**<font color=\"info\">整点播报</font>**\n >起始: {}\n >截至: {}\n >登陆人数: {} 人\n >充值金额: {} 元\n >\n\n >**<font color=\"warning\">在线人数(实时采样)</font>**\n >大厅在线: {} 人\n >游戏局内: {} 人\n >休闲游戏: {} 人({})\n >小游戏: {} 人({})\n ".format(m_login["start_time"],m_login["end_time"],m_login["value"],m_pay["value"],online_map['gate'],online_map['game'],online_map['xxyx'],online_map['xxyx_rate'],online_map['xyx'],online_map['xyx_rate'])
#print(msg_tongji)
#if msg_tongji:
# sys.exit()
####
d1 = get_login_count_hour()
print(d1)
login_hour_val = d1["value"]
login_title = d1["name"]
login_file_name = "login_hour_{}.jpg".format(int(time.time()))
login_x = []
login_y = []
for i in login_hour_val:
login_x.append(i[0])
login_y.append(i[1])
x_label = "日期:{}({})".format(date_time,week)
login_out = create_plt_line(login_x,login_y,login_title,x_label,"登录人数",login_file_name)
login_save_dir = login_out['dir']
if send_wechat1:
media_id = qy.post_file(login_save_dir, login_file_name)
online_str = getOnlineStrSimple()
msg_login += online_str
qy.send_text(msg_login, ['@all'])
qy.send_img(media_id, ['@all'])
####
d2 = get_pay_sum_hour()
order_detail = get_pay_order_hour()
order_val = order_detail["value"]
print(d2)
pay_hour_val = d2["value"]
pay_title = d2["name"]
pay_file_name = "pay_hour_{}.jpg".format(int(time.time()))
pay_x = []
pay_y = []
for i in pay_hour_val:
pay_x.append(i[0])
pay_y.append(i[1])
orders = []
for order in order_val:
orders.append(order[1])
pay_sum = sum(pay_y)
y_label = "充值额"
y2_label = "订单数"
x_title = "{} ,∑ = {}".format(x_label,pay_sum)
print(y_label)
#pay_out = create_plt_data(pay_x,pay_y,pay_title,x_label,y_label,pay_file_name)
pay_out = create_plt_duiji_data(pay_x,pay_y,orders,pay_title,x_title,y_label,y2_label,pay_file_name)
pay_save_dir = pay_out['dir']
l_filename = login_save_dir+login_file_name
p_filename = pay_save_dir+pay_file_name
onepic_filename = "tongji_hour_{}.jpg".format(int(time.time()))
onepic = image_Splicing(l_filename,p_filename,"y",onepic_filename)
print(msg_wechat)
print(onepic)
if send_wechat3:
media_id = qy.post_file("/tmp/",onepic_filename)
#qy.send_text(msg_wechat,['@all'])
qy.send_markdown(msg_tongji,['@all'])
qy.send_img(media_id,['@all'])
if send_wechat2:
media_id = qy.post_file(pay_save_dir, pay_file_name)
qy.send_text(msg_pay, ['@all'])
qy.send_img(media_id, ['@all'])
def liuyan():
sql = "SELECT COUNT(1) FROM tb_feedback WHERE fb_status = 0 AND DATE_SUB(CURDATE(), INTERVAL 7 DAY) <= FROM_UNIXTIME(`fb_timestamp`);"
db = DBUtil(db="db_common_info",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',sql)
count_message = 0
for i in data:
count_message = i[0]
# target = {"key":"liuyan","name":"用户留言数量（最近一周）","value":data,"sql":sql}
# return target
if count_message > 0:
qy = qywx(0)
#msg_unread = "## 用户反馈 ##\n\n您有新的留言，请注意查收！\n\n未处理数量:{}条 (近一周) \n\n登录后台管理->玩家数据->玩家咨询 进行处理".format(count_message);
#msg_unread = "### 用户反馈 \n\n > 您有的:**{}**条留言未处理, 请注意查收！\n\n > 登录后台管理-玩家数据-玩家咨询 [进行处理](http://o.manage.zhuoyigame.com:9090/)".format(count_message)
#qy.send_text(msg_unread, ['@all'])
msg_unread = '### 用户反馈 \n\n > 您有 {} 条留言未处理, 请注意查收！\n\n > 登录 后台管理-玩家数据-玩家咨询 [进行处理](http://o.manage.zhuoyigame.com:9090/)'.format(count_message)
qy.send_markdown(msg_unread,['@all'])
else:
print("no message need process")
# print("you have a message")
def ribao():
date_time = time.strftime("%Y-%m-%d", time.localtime())
#inotice_msg = '## 每日总结 \n\n > <font color=\"info\">每一天提醒自己,不要忘记理想,不要忘记目标;每一天提醒自己,不要忘记学习,不要忘记看书。每一天提醒自我不要忘记快乐,成为更好的自己</font>\n\n > <font color=\"warning\">今天工作辛苦了，感谢您的付出, 别忘了对今天的自己进行下评价、小结，是否距离小目标更进一步了? </font> \n\n > 明天的你一定会感谢今天努力的自己，加油！'
#notice_msg = '## hello world \n\n > <font color=\"info\"> This is a Test </font>'
notice_msg = '## 每日总结 \n\n > <font color=\"warning\">感谢您的付出，工作一天辛苦了! 别忘了对今天的自己进行下评价、小结，是否距离小目标更近一步了? </font> \n\n > 明天的你一定会感谢今天努力的自己，加油！ \n\n '
target = ["@all"]
#toparty = "22"
file_dir = '/root/'
src_file = "/root/workday.xlsx"
to_file_name = "工作日报"+"-"+date_time+".xlsx"
to_file = file_dir + to_file_name
if os.path.exists(to_file):
print("already exists")
else:
print("copy file ")
#shutil.copyfile(src_file,to_file)
qy = qywx(0)
qy.send_markdown(notice_msg,target)
#media_id = qy.post_file(file_dir,to_file_name)
#qy.send_file(media_id,target)
#############
def plt_pannel_graph_duiji(pannel,x,y1,y2,title,xlabel,ylabel,y2label):
pannel.bar(x,y2,width=0.4,color='#dddddd',zorder=5,label=y2label)
pannel.bar(x,y1,width=0.4,bottom=y2,color='#d62728',zorder=5,label=ylabel)
c=np.mean(y1)
pannel.axhline(y=c,color="black",linestyle=':')
#pannel.title(title)
#pannel.xlabel(xlabel)
pannel.tick_params(axis='x',length=0)
pannel.grid(axis='x',ls='-.')
pannel.grid(axis='y',alpha=0.5,ls='--')
pannel.yaxis.tick_right() # 将y轴的数值显示在右边
pannel.legend(frameon=False)
for label in pannel.xaxis.get_ticklabels(): # 设置x轴标签的字体大小
label.set_fontsize(30)
for label in pannel.yaxis.get_ticklabels(): # 设置y轴标签的字体大小
label.set_fontsize(45)
# pannel.tight_layout()
def plt_pannel_graph_line(pannel,x,y,title,xlabel,ylabel):
pannel.plot(x,y,color='blue',alpha=0.8,marker='*',linestyle='--',linewidth=1)
#plt.plot(x,y,color='blue',ls='-',lw=1,marker='*',markevery=20)
# 设置图片名称
# pannel.title(title,color='black')
# 设置x轴标签名
# pannel.xlabel(xlabel)
# 设置y轴标签名
# pannel.ylabel(ylabel)
pannel.grid(axis='x', linestyle='-.') # 添加x轴方向的网格
pannel.grid(axis='y', linestyle='-.') # 添加y轴方向的网格
pannel.yaxis.tick_right() # 将y轴的数值显示在右边
for label in pannel.xaxis.get_ticklabels(): # 设置x轴标签的字体大小
label.set_fontsize(30)
for label in pannel.yaxis.get_ticklabels(): # 设置y轴标签的字体大小
label.set_fontsize(45)
def plt_pannel_text(pannel,text_content,font_size):
pannel.text(0.01, 0.5, text_content,
ha="left", va='center', fontsize=font_size)
for label in pannel.xaxis.get_ticklabels():
label.set_visible(False)
for label in pannel.yaxis.get_ticklabels():
label.set_visible(False)
def plt_pannel_table(pannel, text_content, table_labels,table_font_size, table_scale):
# yeji_list = ['单季度营收', '03-31', '06-30', '09-30', '12-31', '单季度净利润', '03-31', '06-30', '09-30', '12-31', '12-31']
yeji_table = pannel.table(
cellText=text_content, # 表格中内容
colLabels=table_labels, # 表格的列标签
cellLoc='left', # 单元格对齐方式
loc='center',
fontsize=30) # 表格中字体大小
yeji_table.auto_set_font_size(False)
yeji_table.set_fontsize(table_font_size)
yeji_table.scale(1, table_scale) # 调整表格行高
for label in pannel.xaxis.get_ticklabels():
label.set_visible(False)
for label in pannel.yaxis.get_ticklabels():
label.set_visible(False)
def image_Splicing(img_1, img_2, flag='y',filename=None):
img1 = Image.open(img_1)
img2 = Image.open(img_2)
size1, size2 = img1.size, img2.size
if flag == 'x':
joint = Image.new("RGB", (size1[0] + size2[0], size1[1]))
loc1, loc2 = (0, 0), (size1[0], 0)
else:
joint = Image.new("RGB", (size1[0], size2[1]+size1[1]))
loc1, loc2 = (0, 0), (0, size1[1])
joint.paste(img1, loc1)
joint.paste(img2, loc2)
if filename:
save_path="/tmp/"+filename
joint.save(save_path)
return save_path
return None
def onepice():
plt.clf()
# 正确显示中文和负号
plt.rcParams["font.sans-serif"] = ["SimHei"]
plt.rcParams["axes.unicode_minus"] = False
fig = plt.figure( # 添加fig对象
figsize=(16, 9), # 设置fig大小，长和宽，单位为英寸
dpi=50, # 每英寸的像素点数
facecolor="white")
gs = fig.add_gridspec(
3, 1, # 9行1列的网格
left=0.01, right=0.96, bottom=0.03, top=0.99, # 设置页边距
wspace=0.02, hspace=0.12, # 设置行与行之间的距离，列与列之间的距离
height_ratios=[0.3, 0.45,0.15]) # 这边是9行，设置每行占的高度的比例
# 添加文字说明
pannel1 = fig.add_subplot(gs[0, 0])
plt_pannel_text(pannel1, "title:\n\nhello world", 50)
# 添加表格
pannel2 = fig.add_subplot(gs[1, 0])
plt_pannel_table(pannel2, [["xxx","1%",123],["xxx","2%",423],["xxx","2%",523]],["前十用户充值排名（当日）","占比（当日）","金额（元）"], 46,9.5)
# # 添加登录汇总
# pannel2 = fig.add_subplot(gs[1, 0])
# login_hour_data = get_login_count_hour()
# login_hour_val = login_hour_data["value"]
# login_title = login_hour_data["name"]
# login_x = []
# login_y = []
# for i in login_hour_val:
# login_x.append(i[0])
# login_y.append(i[1])
# x_label = "日期:{}".format("2023-06-06")
# plt_pannel_graph_line(pannel2, login_x,login_y,login_title,x_label,"登录人数")
# # 添加充值汇总
# pannel3 = fig.add_subplot(gs[2, 0])
# order_detail = get_pay_order_hour()
# order_val = order_detail["value"]
# pay_hour_val = order_detail["value"]
# pay_title = order_detail["name"]
# pay_x = []
# pay_y = []
# for i in pay_hour_val:
# pay_x.append(i[0])
# pay_y.append(i[1])
# orders = []
# for order in order_val:
# orders.append(order[1])
# pay_sum = sum(pay_y)
# y_label = "充值额"
# y2_label = "订单数"
# x_title = "{} ,∑ = {}".format(x_label,pay_sum)
# plt_pannel_graph_duiji(pannel3, pay_x,pay_y,orders,pay_title,x_title,y_label,y2_label)
# 8、留白，待后续补充
pannel_empty = fig.add_subplot(gs[1, 0])
pannel_empty.text(0.01, 0.5, '====',
ha="left", va='center', fontsize='100')
filename="huizong.jpg"
save_dir = "/tmp/"
out = None
if not os.path.exists(save_dir):
print("[warning] file save dir not exists")
else:
filepath = save_dir + filename
print("[info] will save file to:",filepath)
plt.savefig(filepath)
out = filepath
plt.close()
return {'out':out,'dir':save_dir,'filename':filename}
def zhoubao():
date_time = time.strftime("%Y-%m-%d", time.localtime())
notice_msg = '## 每周总结 \n\n > 今天是周五,笑容多灿烂。亲人天天盼,相伴周末玩。工作抓紧干,效率翻一番'
#toparty = "22"
file_dir = '/root/'
src_file = "/root/workweek.xlsx"
to_file_name = "工作周报"+"-"+date_time+".xlsx"
to_file = file_dir + to_file_name
if os.path.exists(to_file):
print("already exists")
else:
print("copy file ")
#shutil.copyfile(src_file,to_file)
target = ["@all"]
qy = qywx(0)
qy.send_markdown(notice_msg,target)
#media_id = qy.post_file(file_dir,to_file_name)
#qy.send_file(media_id,target)
'''
查询应用信息
'''
def get_app_info(app_ids):
ids = ','.join(str(i) for i in app_ids)
sql = "SELECT a_appid,a_pn,a_appname,a_channel from tb_app where a_appid in ({});".format(ids)
db = DBUtil(db="db_common_info",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',sql)
return data
'''
5个日新增超过100的渠道，异常情况监测，及时了解渠道下架或不外显
任意渠道2个小时内新增 = 0
'''
def userRegisterException(minNum):
app_ids = [386,413,429,407,365]
app_data_list = get_app_info(app_ids)
exception_list = []
for app_data in app_data_list:
app_id = app_data[0]
app_pn = app_data[1]
app_name = app_data[2]
app_channel = app_data[3]
querySql = "SELECT COUNT(1) as num FROM tb_account WHERE regDate>=UNIX_TIMESTAMP(NOW())-7200 AND channel={};".format(app_channel)
db = DBUtil(db="zhuoyigame",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',querySql)
count_num = 0
for i in data:
count_num = i[0]
if count_num <= minNum :
# 添加到数组异常数组中
notice = "*** 应用ID:{} 应用名称:{} 指标值:{} \n".format(app_id,app_name,count_num)
exception_list.append(notice)
return exception_list
'''
7个日活超过1000的渠道，登录异常情况监测(除维护)，与现有短信提醒机制不同，防止某个渠道长时间无法登录
'''
def userLoginException(minNum):
app_ids = [386,413,429,407,365,385,351]
app_data_list = get_app_info(app_ids)
exception_list = []
for app_data in app_data_list:
app_id = app_data[0]
app_pn = app_data[1]
app_name = app_data[2]
app_channel = app_data[3]
querySql = "SELECT COUNT(1) as num FROM tb_account WHERE lastLogin>=UNIX_TIMESTAMP(NOW())-1800 AND channel={};".format(app_channel)
db = DBUtil(db="zhuoyigame",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',querySql)
count_num = 0
for i in data:
count_num = i[0]
if count_num <= minNum :
# 添加到数组异常数组中
notice = "*** 应用ID:{} 应用名称:{} 指标值:{} \n".format(app_id,app_name,count_num)
exception_list.append(notice)
return exception_list
'''
充值异常情况监测，防止长时间无法充值
30分钟内充值成功金额 = 0
'''
def userPayException():
# pay_notice = ""
querySql = "SELECT COUNT(1) as num FROM tb_account WHERE lastPayTime>=UNIX_TIMESTAMP(NOW())-1800;"
db = DBUtil(db="zhuoyigame",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',querySql)
count_num = 0
for i in data:
count_num = i[0]
# if count_num <=0 :
# pay_notice = "充值异常"
return count_num
'''
获取三人斗地主和四人斗地主的在线人数
'''
def getOnlineDDZ3And4():
data = totalGameOnline(online_metrics_urls,["admin_stats","game-chat"])
target = ["game-lzddz4-pt","game-ddz-bs","game-ddz4-pt","game-ddz4-bxp","game-ddz4-hb","game-ddz3-pt","game-ddz3-bxp","game-ddz3-hb"]
online = 0
for name in data:
if name in target:
online = online + data[name]
return online
'''
后台“平台管理 - 注册权重管理”，包含的全部设备号或IP
2小时内，有新注册账号
'''
def getManageNewUser():
queryIPSQL = "SELECT fb_obj from tb_forbid_weight WHERE fb_type = 1;"
queryIMEISQL = "SELECT fb_obj from tb_forbid_weight WHERE fb_type = 2;"
common_db = DBUtil(db="db_common_info",host="10.8.18.108")
common_db.db_connect()
dataIps = common_db.db_sql('SELECT', queryIPSQL)
common_db.db_connect()
dataImeis = common_db.db_sql('SELECT', queryIMEISQL)
listIps = []
listImeis = []
# count_num = 0
for dataIp in dataIps:
listIps.append(dataIp[0])
for dataImei in dataImeis:
listImeis.append(dataImei[0])
authen_db = DBUtil(db="db_authen_zy",host="10.8.18.108")
newAccountIdsFromLimitIp = []
newAccountidsFromImei = []
if len(listIps) > 0 :
limitData = ",".join("\"{}\"".format(i) for i in listIps)
sql = "SELECT a_uid FROM `db_authen_zy`.`tb_account` WHERE a_login_ip in ({}) AND a_reg_time >= UNIX_TIMESTAMP(NOW())-7200;".format(limitData)
authen_db.db_connect()
res = authen_db.db_sql('SELECT',sql)
for uinfo in res:
newAccountIdsFromLimitIp.append(uinfo[0])
if len(listImeis) > 0 :
limitData = ",".join("\"{}\"".format(i) for i in listImeis)
sql = "SELECT a_uid FROM `db_authen_zy`.`tb_account` WHERE a_imei in ({}) AND a_reg_time >= UNIX_TIMESTAMP(NOW())-2592000;".format(limitData)
authen_db.db_connect()
authen_db.db_sql('SELECT',sql)
for uinfo in res:
newAccountidsFromImei.append(uinfo[0])
return (newAccountIdsFromLimitIp,newAccountidsFromImei)
def bizReg():
target = ["@all"]
val = 1
datalist = userRegisterException(val)
if len(datalist) > 0:
qy = qywx(0)
msg = "## 业务异常 ## \n\n"
msg = msg + "渠道新增异常 <= {} \n\n".format(val)
msg = msg + '\n'.join(datalist)
qy.send_text(msg,target)
def bizLogin():
# print(userLoginException(100))
target = ["@all"]
val = 1
datalist = userLoginException(val)
if len(datalist) > 0:
qy = qywx(0)
msg = "## 业务异常 ## \n\n"
msg = msg + "渠道登陆异常 <={} \n\n".format(val)
msg = msg + '\n'.join(datalist)
qy.send_text(msg,target)
def bizPay():
payuserSize = userPayException()
target = ["@all"]
val = 1
if payuserSize <= val:
qy = qywx(0)
msg = "## 业务异常 ## \n\n"
msg = msg + "平台充值异常 充值人数: {} <= {}".format(payuserSize, val)
qy.send_text(msg,target)
def bizDdz():
gameUserOnlineSize = getOnlineDDZ3And4()
target = ["@all"]
val = 10
if gameUserOnlineSize <= val:
qy = qywx(0)
msg = "## 业务异常 ## \n\n"
msg = msg + "游戏场次异常 人数: {} <= {}".format(gameUserOnlineSize, val)
qy.send_text(msg,target)
def bizGlyh():
manageUsers = getManageNewUser()
manageUserIp = manageUsers[0]
manageUserImei = manageUsers[1]
target = ["@all"]
# target = ["22"]
msg = "## 业务关注 ## \n\n"
ipUsers = len(manageUserIp)
imeiUsers = len(manageUserImei)
if ipUsers > 0:
uids = "\n".join(str(i) for i in manageUserIp)
msg = "{} 后台监控IP有新注册账号:\n {} \n".format(msg, uids)
if imeiUsers > 0:
uids = "\n".join(str(i) for i in manageUserImei)
msg = "{} 后台监控设备号有新注册账号:\n {} \n".format(msg, uids)
if (ipUsers + imeiUsers) > 0:
qy = qywx(0)
qy.send_text(msg,target,"22")
#生成xlsx文件的函数
def retxls(ret,dt,title):
dir="/root/query/"
basename = dt + datetime.datetime.now().strftime("%Y%m%d%H%M")+ ".xlsx"
filename = dir + basename
dret = pd.DataFrame.from_records(list(ret))
dret.style.set_properties(**{'border': '1px solid black'})
###z注意openpyxl这个库可能在生成xls的时候出错，pip install openpyxls==1.8.6，其他版本似乎与pandas有点冲突，安装1.8.6的即可
dret.to_excel(filename,"Sheet1",engine="openpyxl",header=title,index=False)
print ("Ok!!! the file in",filename)
return basename
'''
屏蔽字异常报警
'''
def bizPbz():
#targetKeyWords=["毛泽东","朱德","周恩来","刘少奇","任弼时","陈云","宋庆龄","李济深","张澜","高岗","邓小平","林彪","董必武","陶铸","陈伯达","康生","李富春","王洪文","叶剑英","李德生","张春桥","华国锋","李先念","汪东兴","赵紫阳","胡耀邦","乌兰夫","彭真","邓颖超","乔石","胡启立","姚依林","杨尚昆","万里","李鹏","王震","江泽民","宋平","李瑞环","朱镕基","刘华清","胡锦涛","荣毅仁","尉健行","李岚清","吴邦国","温家宝","贾庆林","曾庆红","黄菊","吴官正","李长春","罗干","贺国强","周永康","习近平","李克强","张德江","俞正声","刘云山","王岐山","张高丽","栗战书","汪洋","王沪宁","赵乐际","韩正"]
sql = "SELECT * FROM tb_pbz_record WHERE timestamp >= UNIX_TIMESTAMP(NOW())-1800 and level>=1;"
db = DBUtil(db="db_common_info",host="10.8.18.108")
db.db_connect()
data = db.db_sql('SELECT',sql)
if len(data)>0:
title = ("序号","应用名称","公司名称","用户昵称","UID","拦截测试样本","场景（评论、昵称等）","发布时间","最近一次登录日志（含源端口号）","应用登录方式");
matrix = list(data)
retsLevel1 = []
retsLevel2 = []
for item in matrix:
# print(item)
dbkey=item[0]
uid=item[1]
#content=item[2]
content="******"
timestamp=item[4]
username=item[5]
sceneType=item[6]
loginSource=item[7]
loginType=item[8]
level=item[9]
scene=sceneType
# print(scene)
if not loginSource:
loginSource = "Unknown"
if not loginType:
loginType = "Unknown"
timeArray = time.localtime(timestamp)
sendTime = time.strftime("%Y-%m-%d %H:%M:%S", timeArray)
if sceneType=="sign":
scene = "修改签名"
if sceneType=="changeName":
scene = "修改昵称"
if loginType == "user":
loginType = "渠道账号"
if loginType == "third":
loginType = "联运账号"
if loginType == "mobile":
loginType = "手机号码"
if loginType == "wechat":
loginType = "微信号"
# print(level)
tupleItem=(dbkey,"卓毅四人斗地主","卓毅（上海）网络技术有限公司",username,uid,content,scene,sendTime,loginSource,loginType)
#target = ["22"]
target = ["@all"]
if level==1 :
retsLevel1.append(tupleItem)
if level==2 :
retsLevel2.append(tupleItem)
ret1=tuple(retsLevel1)
ret2=tuple(retsLevel2)
qy = qywx(0)
if len(ret1) > 0:
print(ret1)
main_file = retxls(ret1,"一级屏蔽字",title);
media_id = qy.post_file("/root/query/",main_file)
qy.send_file(media_id,target)
if len(ret2) > 0:
print(ret2)
main_file = retxls(ret2,"二级屏蔽字",title);
media_id = qy.post_file("/root/query/",main_file)
qy.send_file(media_id,target)
# qy = qywx(0)
# qy.send_text("触发二级屏蔽字",target,"22")
pass
now = datetime.datetime.now()
weekday = now.weekday()
week_val = weekday + 1
# 调用示例
if __name__ == '__main__':
argc = len( sys.argv );
if argc < 2:
print("not exists args")
sys.exit()
command = sys.argv[1];
if command == "zhibiao":
zhibiao()
elif command == "liuyan":
liuyan()
elif command == "online":
print(getOnlineStrSimple())
elif command == "online2":
print(getOnlineStr())
elif command == "one":
print(onepice())
elif command == "hetu":
print(image_Splicing("/tmp/login_hour_1685646002.jpg","/tmp/pay_hour_1685350803.jpg","y","hetu.jpg"))
elif command == "ribao":
if week_val == 5:
zhoubao()
else:
ribao()
elif command == "bizReg" :
bizReg()
elif command == "bizLogin" :
bizLogin()
elif command == "bizPay" :
bizPay()
elif command == "bizDdz" :
bizDdz()
elif command == "bizGlyh" :
bizGlyh()
elif command == "bizPbz" :
bizPbz()
else:
print(f"\n[ Error] 未知参数:{command}，请检查。")
正文完
