538 lines
23 KiB
Plaintext
538 lines
23 KiB
Plaintext
async def user_get_bill(nss={}, extra_info={}):
|
||
ns = {
|
||
'user_orgids': list(nss.keys()),
|
||
'current_page': extra_info.get('current_page') or 1,
|
||
'start_time': extra_info.get('start_time'),
|
||
'end_time': extra_info.get('end_time'),
|
||
'page_size': extra_info.get('page_size')
|
||
}
|
||
start_time = ns['start_time'] if ns.get('start_time') else '2010-10-01'
|
||
end_time = ns['end_time'] if ns.get('end_time') else '2099-12-01'
|
||
page_size = int(ns['page_size']) if ns.get('page_size') else 20000
|
||
offset = page_size * (int(ns['current_page']) - 1)
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
try:
|
||
# 根据userid获取用户orgid
|
||
# user_orgid_li = await sor.R('users', {'id': ns['userid']})
|
||
# user_orgid = user_orgid_li[0]['orgid']
|
||
user_orgids = ns['user_orgids']
|
||
# 计算总量
|
||
user_tuple = tuple(user_orgids)
|
||
all_user_set = ', '.join(list(map(lambda x: "'%s'", user_orgids)))
|
||
bill_count_sql = """select count(*) as total from bill where customerid in (%s) and bill_date >= '%s' and bill_date <= '%s';""" % \
|
||
(all_user_set, start_time, end_time)
|
||
bill_sum_sql = """select sum(amount) as bill_sum from bill where customerid in (%s) and business_op = 'BUY' and bill_date >= '%s' and bill_date <= '%s';""" % \
|
||
(all_user_set, start_time, end_time)
|
||
bill_count_li = await sor.sqlExe(bill_count_sql % user_tuple, {})
|
||
bill_sum = (await sor.sqlExe(bill_sum_sql % user_tuple, {}))[0]['bill_sum']
|
||
if bill_count_li:
|
||
total_num = bill_count_li[0]['total']
|
||
total_page = total_num / page_size if total_num % page_size == 0 else int(total_num / page_size) + 1
|
||
bill_sql = """select * from bill where customerid in (%s) and bill_date >= '%s' and bill_date <= '%s' order by bill_date desc limit %s OFFSET %s;""" % \
|
||
(all_user_set, start_time, end_time, page_size, offset)
|
||
bill_li = await sor.sqlExe(bill_sql % user_tuple, {})
|
||
|
||
new_bill_li = []
|
||
for bill_detail in bill_li:
|
||
product_info = await sor.R('product', {'id': bill_detail['productid']})
|
||
bill_detail['productname'] = product_info[0]['name'] if product_info else ''
|
||
bill_detail.update(nss[bill_detail['customerid']])
|
||
if bill_detail.get('business_op') == 'RECHARGE':
|
||
bill_detail['productname'] = '线下充值'
|
||
bill_detail['bill_state'] = 1
|
||
else:
|
||
if bill_detail.get('resource_type'):
|
||
type_parts = bill_detail['resource_type'].split('-')
|
||
bill_detail['type_one'] = type_parts[0]
|
||
bill_detail['type_two'] = type_parts[1] if len(type_parts) > 1 else None
|
||
bill_detail['type_three'] = type_parts[2] if len(type_parts) > 2 else None
|
||
else:
|
||
bill_detail['type_one'] = None
|
||
bill_detail['type_two'] = None
|
||
bill_detail['type_three'] = None
|
||
|
||
new_bill_li.append(bill_detail)
|
||
|
||
return {
|
||
'status': True,
|
||
'msg': '获取账单成功',
|
||
'data': {
|
||
'total_page': total_page,
|
||
'total_num': total_num,
|
||
'bill_sum': bill_sum,
|
||
'page_size': page_size,
|
||
'current_page': ns['current_page'],
|
||
'bill_list': new_bill_li
|
||
}
|
||
}
|
||
except Exception as e:
|
||
return {
|
||
'status': False,
|
||
'msg': '获取账单报错, %s' % e
|
||
}
|
||
async def getUserInfo(ns={}):
|
||
# ns = {
|
||
# # 'userid': 'user_abcd',
|
||
# 'orgid': 'APPbNUfV5Im_KlZNnBRjd'
|
||
# }
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
try:
|
||
if not ns.get('orgid'):
|
||
# find orgid info from users
|
||
org_info = await sor.R('users', {'id': ns.get('userid'), 'del_flg': '0'})
|
||
if org_info:
|
||
orgid = org_info[0].get('orgid')
|
||
else:
|
||
return {
|
||
'status': False,
|
||
'msg': 'can not find orgid from users'
|
||
}
|
||
else:
|
||
orgid = ns.get('orgid')
|
||
|
||
orgs = await sor.R('organization', {'id': orgid, 'del_flg': '0'})
|
||
org = orgs[0] if orgs else {}
|
||
nss = {}
|
||
nss['orgid'] = orgid
|
||
nss['fullName'] = org.get('orgname') or ''
|
||
nss['name'] = org.get('orgname') or ''
|
||
nss['identityCode'] = org.get('orgcode') or ''
|
||
nss['address'] = org.get('address') or ''
|
||
nss['contact'] = org.get('contactor') or ''
|
||
nss['tel'] = org.get('contactor_phone') or ''
|
||
nss['email'] = org.get('emailaddress') or ''
|
||
|
||
# find salemanid info from customers
|
||
|
||
cust = await sor.R('customer', {'customerid': orgid, 'del_flg': '0'})
|
||
customer = cust[0] if cust else {}
|
||
salemanid = customer.get('salemanid')
|
||
org_name = ''
|
||
if salemanid:
|
||
saleman = await sor.R('users', {'id': salemanid, 'del_flg': '0'})
|
||
saleman_user = saleman[0] if saleman else {}
|
||
salemanorgid = saleman_user.get('orgid')
|
||
if salemanorgid:
|
||
org_name_li = await sor.R('organization', {'id': salemanorgid, 'del_flg': '0'})
|
||
if org_name_li:
|
||
org_name = org_name_li[0].get('orgname') or ''
|
||
else:
|
||
saleman_user = {}
|
||
nss['saleMgrName'] = saleman_user.get('username') or ''
|
||
nss['saleMgrEmail'] = saleman_user.get('email') or ''
|
||
nss['saleMgrTel'] = saleman_user.get('mobile') or ''
|
||
# add saleman org name
|
||
nss['saleorgname'] = org_name
|
||
|
||
# find invoice attr from orgid
|
||
invoice_attr = await sor.R('invoice_attr', {'customerid': orgid, 'del_flg': '0'})
|
||
invoice = invoice_attr[0] if invoice_attr else {}
|
||
nss['bankName'] = invoice.get('bank_name') or ''
|
||
nss['bankAcc'] = invoice.get('bank_account') or ''
|
||
nss['identityName'] = invoice.get('invoice_title') or ''
|
||
nss['taxTel'] = invoice.get('phone') or ''
|
||
nss['taxpayerIdentity'] = invoice.get('tax_no') or ''
|
||
nss['taxAddress'] = invoice.get('address') or ''
|
||
|
||
# find zj_users from orgid
|
||
zj_attr = await sor.R('zj_users', {'orgid': orgid, 'del_flg': '0'})
|
||
zj = zj_attr[0] if zj_attr else {}
|
||
nss['userAc'] = zj.get('userac') or ('kboss_' + orgid)
|
||
nss['userPhone'] = zj.get('userphone') or nss['tel']
|
||
nss['remark'] = zj.get('remark') or ''
|
||
nss['ak'] = zj.get('ak') or ''
|
||
nss['sk'] = zj.get('sk') or ''
|
||
nss['thirdId'] = zj.get('thirdid') or ''
|
||
nss['appId'] = zj.get('appid') or ''
|
||
nss['supId'] = zj.get('supid') or ''
|
||
nss['sync_status'] = zj.get('sync_status')
|
||
return {
|
||
'status': True,
|
||
'msg': 'get user info success',
|
||
'data': nss
|
||
}
|
||
|
||
except Exception as e:
|
||
raise e
|
||
return {
|
||
'status': False,
|
||
'msg': 'get user info failed',
|
||
'data': ''
|
||
}
|
||
async def saleGetUsers(ns={}):
|
||
"""
|
||
get users
|
||
id *
|
||
:param ns:
|
||
:return:
|
||
"""
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
# if not await get_user():
|
||
# return {
|
||
# "status": False,
|
||
# "msg": "user id is empty, please check",
|
||
# }
|
||
try:
|
||
org_list = []
|
||
lizhi_list = await sor.R('transfer_record', {'change_id': ns.get('userid')})
|
||
ids = list(map(lambda x: x['customer_id'], lizhi_list))
|
||
|
||
cus_list = await sor.R('customer', {'salemanid': ns.get('userid')})
|
||
for cus in cus_list:
|
||
customerid = cus.get('customerid')
|
||
if ns.get('kv') == 'zj':
|
||
# 判断中金users是否存在，存在就查询
|
||
exists_zj_users = await sor.R('zj_users', {'orgid': customerid})
|
||
if exists_zj_users:
|
||
res_dict = await getUserInfo({'orgid': customerid})
|
||
if res_dict.get('status') and res_dict.get('data'):
|
||
org_list.append(res_dict.get('data'))
|
||
elif ns.get('kv') == 'jncs':
|
||
# 获取济南超算id
|
||
jncs_li = await sor.R('organization', {'orgname': '济南超算', 'del_flg': '0'})
|
||
jscs_id = jncs_li[0].get('id')
|
||
# 获取购买过济南超算产品的用户 产品持有表
|
||
ress = await sor.R('customer_goods', {'customerid': customerid, 'providerrid': jscs_id})
|
||
if ress:
|
||
org_list.append(ress)
|
||
else:
|
||
org_content_li = await sor.R('organization', {'id': customerid})
|
||
org_content = org_content_li[0] if org_content_li else []
|
||
|
||
if org_content:
|
||
if customerid in ids:
|
||
org_content["type"] = '转接客户'
|
||
transfer_info = sorted(await sor.R('transfer_record', {'customer_id': customerid}),
|
||
key=lambda x: x['create_at'], reverse=True)
|
||
transfer_time = transfer_info[0]['create_at'] if transfer_info else None
|
||
previous_sales = None
|
||
for transfer in transfer_info:
|
||
# print('111111137219047923042141', transfer_info)
|
||
|
||
if transfer['change_id'] == ns.get('userid'):
|
||
previous_sales = transfer['dimission_id']
|
||
previous_id = await sor.R('users', {'id': previous_sales})
|
||
previous_name = await sor.R('users', {'username': previous_id[0]['username']})
|
||
if previous_name:
|
||
previous_sales_name = previous_name[0]['username']
|
||
else:
|
||
previous_sales_name = None
|
||
break
|
||
|
||
org_content["transfer_time"] = transfer_time
|
||
org_content["previous_sales"] = previous_sales_name
|
||
org_list.append(org_content)
|
||
else:
|
||
org_content["type"] = '直接客户'
|
||
org_content["transfer_time"] = None
|
||
org_content["previous_sales"] = None
|
||
org_list.append(org_content)
|
||
# for org_ in org_list:
|
||
# org_['bill'] = await user_get_bill({'user_orgid': org_['id'], 'current_page': 1})
|
||
# org_['salemanid'] = ns.get('salemanid')
|
||
# org_['salemanname'] = ns.get('salemanname')
|
||
return {
|
||
"status": True,
|
||
"msg": "get user success",
|
||
"data": org_list
|
||
}
|
||
except Exception as e:
|
||
return {
|
||
"status": False,
|
||
"msg": "get user failed",
|
||
"data": str(e)
|
||
}
|
||
|
||
# 查看所有销售
|
||
async def operator_get_all_bill(ns={}):
|
||
"""
|
||
获取所有销售人员id 名称
|
||
:param ns:
|
||
:return:
|
||
"""
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
if ns.get('sor'):
|
||
sor = ns.get('sor')
|
||
users_li_sql = """select u.id, u.username, u.orgid, ur.userid, ur.roleid, r.id, r.role from users u, userrole ur, role r
|
||
where u.orgid = '%s' and u.id = ur.userid and ur.roleid = r.id and
|
||
r.role = '销售';""" % ns.get('orgid')
|
||
users_li = await sor.sqlExe(users_li_sql, {})
|
||
saleman_all_list = [{'label': item['username'], 'value': item['userid']} for item in users_li]
|
||
users = [(item['userid'], item['username']) for item in users_li]
|
||
# 查询指定销售
|
||
# 忽略销售 查询所有客户
|
||
target_users = users
|
||
if ns.get('salemanid'):
|
||
users = [user for user in users if user[0]==ns['salemanid']]
|
||
user_dic = {}
|
||
customer_all_list = []
|
||
# 获取所有客户
|
||
for user in target_users:
|
||
res_user = await saleGetUsers({'userid': user[0]})
|
||
for k_user in res_user['data']:
|
||
customer_all_list.append({'label': k_user['orgname'], 'value': k_user['id']})
|
||
|
||
if ns.get('user_orgid'):
|
||
users=target_users
|
||
for user in users:
|
||
res = await saleGetUsers({'userid': user[0]})
|
||
for u_user in res['data']:
|
||
additional_info = {
|
||
'orgname': u_user['orgname'],
|
||
'orgcode': u_user['orgcode'],
|
||
'address': u_user['address'],
|
||
'salemanid': user[0],
|
||
'salemanname': user[1],
|
||
}
|
||
user_dic[u_user['id']] = additional_info
|
||
|
||
target_user_dic = None
|
||
# 查询指定的客户
|
||
new_user_dic = {}
|
||
if ns.get('user_orgid'):
|
||
new_user_dic[ns['user_orgid']] = user_dic.pop(ns['user_orgid'])
|
||
# 如果没有找到对应的销售或者客户
|
||
if not user_dic:
|
||
return {
|
||
'status': True,
|
||
'msg': '获取账单成功',
|
||
'saleman_all_list': saleman_all_list,
|
||
'customer_all_list': customer_all_list,
|
||
'data': {
|
||
'total_page': 0,
|
||
'total_num': 0,
|
||
'bill_sum': 0,
|
||
'page_size': 20,
|
||
'current_page': 1,
|
||
'bill_list': []
|
||
}
|
||
}
|
||
elif new_user_dic:
|
||
target_user_dic = new_user_dic
|
||
else:
|
||
target_user_dic = user_dic
|
||
|
||
res_bill = await user_get_bill(nss=target_user_dic, extra_info=ns)
|
||
return {
|
||
'status': True,
|
||
'msg': '获取账单成功',
|
||
'saleman_all_list': saleman_all_list,
|
||
'customer_all_list': customer_all_list,
|
||
'data': res_bill['data']
|
||
}
|
||
|
||
|
||
async def get_product_volume_rank(ns={}):
|
||
# ns = {
|
||
# 'target': 'month'
|
||
# }
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
if not ns.get('target'):
|
||
count_sql = """
|
||
SELECT p.id,
|
||
p.name AS product_name,
|
||
SUM(b.amount) AS total_sales
|
||
FROM
|
||
bill b
|
||
JOIN
|
||
product p ON b.productid = p.id
|
||
WHERE
|
||
b.business_op = 'BUY'
|
||
GROUP BY
|
||
p.id, p.name
|
||
ORDER BY
|
||
total_sales DESC
|
||
LIMIT 20;"""
|
||
else:
|
||
count_sql = """
|
||
SELECT p.id,
|
||
p.name AS product_name,
|
||
DATE_FORMAT(b.bill_date, '%%Y-%%m') AS month,
|
||
SUM(b.amount) AS total_sales
|
||
FROM
|
||
bill b
|
||
JOIN
|
||
product p ON b.productid = p.id
|
||
WHERE
|
||
b.business_op = 'BUY'
|
||
GROUP BY
|
||
p.id, month
|
||
ORDER BY
|
||
month, total_sales; -- 可根据需求调整排序
|
||
"""
|
||
count_li = await sor.sqlExe(count_sql, {})
|
||
# for index, sale in enumerate(count_li):
|
||
# sale['total_sales'] = round(sale['total_sales'] + 4 * 10000 + (index + 1) * 10024, 2)
|
||
return {
|
||
'status': True,
|
||
'msg': '获取产品销售额成功',
|
||
'data': count_li
|
||
}
|
||
|
||
|
||
async def large_screen_first_page(ns={}):
|
||
orgid = ns.get('orgid') if ns.get('orgid') else 'mIWUHBeeDM8mwAFPIQ8pS'
|
||
n = 9
|
||
# 获取当前时间戳
|
||
now = time.time()
|
||
|
||
# 获取当前年月
|
||
current_time = time.localtime(now)
|
||
current_year = current_time.tm_year
|
||
current_month = current_time.tm_mon
|
||
x = []
|
||
y = []
|
||
for i in range(0, n + 1):
|
||
# 计算之前的月份
|
||
month = current_month - i
|
||
year = current_year
|
||
|
||
if month <= 0:
|
||
# 处理年份的变更
|
||
year -= (abs(month) // 12) + 1
|
||
if month % 12 == 0:
|
||
month = 12
|
||
else:
|
||
month = (month % 12)
|
||
x.append(f"{year}-{month:02d}")
|
||
y.append(int(f"{year}{month}") * 16 + 78390)
|
||
|
||
# 统计销售额
|
||
res_bill = await operator_get_all_bill({'orgid': orgid})
|
||
# 销售额按月
|
||
# 使用 defaultdict 来存储每个月的金额总和
|
||
amount_by_month = defaultdict(int)
|
||
# 处理数据
|
||
for entry in res_bill['data']['bill_list']:
|
||
# 提取年月
|
||
year_month = datetime.datetime.strptime(entry["bill_date"], "%Y-%m-%d").strftime("%Y-%m")
|
||
amount_by_month[year_month] += entry["amount"]
|
||
# 将年月按升序排序
|
||
sorted_data = sorted(amount_by_month.items(), key=lambda x: x[0])
|
||
# 输出结果
|
||
year_month_li = []
|
||
total_amount_li = []
|
||
for year_month, total_amount in sorted_data:
|
||
year_month_li.append(year_month)
|
||
total_amount_li.append(total_amount)
|
||
# print(f"Year-Month: {year_month}, Total Amount: {total_amount}")
|
||
if ns.get('flag') == '1':
|
||
LeftUp = {
|
||
'configname': '供应商销售额',
|
||
'x': year_month_li[-10:],
|
||
'y': total_amount_li[-10:]
|
||
}
|
||
else:
|
||
LeftUp = {
|
||
'configname': '供应商销售额',
|
||
'x': x[::-1],
|
||
'y': [1502350, 1701232, 1602326, 1902310, 1802294, 4802278, 2262262, 2302246, 3115382, 3315366, 3631550]
|
||
}
|
||
|
||
# 统计用户量
|
||
user_count_sql = f"""
|
||
SELECT
|
||
DATE_FORMAT(create_at, '%%Y-%%m') AS month,
|
||
COUNT(*) AS new_users_count
|
||
FROM
|
||
organization
|
||
WHERE
|
||
parentid = '{orgid}'
|
||
GROUP BY
|
||
month
|
||
ORDER BY
|
||
month ASC;
|
||
"""
|
||
user_count_time_li = []
|
||
user_count_li = []
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
user_count = await sor.sqlExe(user_count_sql, {})
|
||
for i in user_count:
|
||
user_count_time_li.append(i['month'])
|
||
user_count_li.append(i['new_users_count'])
|
||
if ns.get('flag') == '1':
|
||
LeftDown = {
|
||
'configname': '用户量',
|
||
'x': user_count_time_li[-10:],
|
||
'y': user_count_li[-10:]
|
||
}
|
||
else:
|
||
LeftDown = {
|
||
'configname': '用户量',
|
||
'x': x[::-1],
|
||
'y': [502, 701, 602, 702, 1002, 3102, 1602, 1302, 1511, 1791, 1331]
|
||
}
|
||
|
||
# 分销商销售额
|
||
reseller_sum_sql = """
|
||
SELECT
|
||
SUM(b.amount) AS total_sales_amount,
|
||
o1.orgname AS distributor_name
|
||
FROM
|
||
bill b
|
||
JOIN
|
||
organization o2 ON b.customerid = o2.id -- 连接bill表和普通用户
|
||
JOIN
|
||
organization o1 ON o2.parentid = o1.id -- 连接组织表，获取分销商
|
||
WHERE
|
||
o1.parentid = '%s' -- 当前用户
|
||
AND o1.org_type = 1 -- 分销商
|
||
AND o1.del_flg = '0' -- 有效的分销商
|
||
AND o2.org_type = 2 -- 普通用户
|
||
AND b.business_op = 'BUY' -- 只统计购买操作
|
||
GROUP BY
|
||
o1.orgname
|
||
ORDER BY
|
||
total_sales_amount; -- 按月份升序排列
|
||
""" % orgid
|
||
reseller_name_li = []
|
||
reseller_sale_li = []
|
||
db = DBPools()
|
||
async with db.sqlorContext('kboss') as sor:
|
||
reseller_sum_li = await sor.sqlExe(reseller_sum_sql, {})
|
||
for i in reseller_sum_li:
|
||
reseller_name_li.append(i['distributor_name'])
|
||
reseller_sale_li.append(i['total_sales_amount'])
|
||
# print(reseller_sum_li)
|
||
if ns.get('flag') == '1':
|
||
RightUp = {
|
||
'configname': '分销商销售额',
|
||
'x': reseller_name_li,
|
||
'y': reseller_sale_li
|
||
}
|
||
else:
|
||
RightUp = {
|
||
'configname': '分销商销售额',
|
||
'x': ['叮*科技', '科行*科技', '深圳梵*科技', '广州高*科技*', '郑州白*科技'],
|
||
'y': [102232, 301057, 100407, 1315366, 231550]
|
||
}
|
||
|
||
# 产品销售额排名
|
||
product_rank_dic = await get_product_volume_rank()
|
||
product_rank = [{"name": item['product_name'], "value": item['total_sales'], "children":[]} for item in product_rank_dic['data']]
|
||
if ns.get('flag') == '1':
|
||
RightDown = {
|
||
'configname': '产品排名',
|
||
'data': product_rank
|
||
}
|
||
else:
|
||
RightDown = {
|
||
'configname': '产品排名',
|
||
'data': [{"name":"IDC","value":"220000","children":[]},{"name":"MSP","value":"540004","children":[]},{"name":"集团项目","value":"73375104.22","children":[{"name":"云平台","value":"56822324.22","children":[]},{"name":"技术服务","value":"16552780","children":[]}]},{"name":"算力","value":"49383708.31","children":[{"name":"公有云","value":"28295520.99","children":[{"name":"agency","value":"5734428.4","children":[]},{"name":"融合云","value":"16279947.35","children":[]},{"name":"reseller","value":"6180593.54","children":[]},{"name":"返佣","value":"74214.5974","children":[]},{"name":"短信","value":"26337.1","children":[]}]},{"name":"超算","value":"62560","children":[]},{"name":"智算","value":"21025627.32","children":[{"name":"A800","value":"20309100.84","children":[]},{"name":"A100","value":"716526.48","children":[]}]}]},{"name":"网业务","value":"2328264.29","children":[{"name":"互联网接入","value":"1743835.83","children":[]},{"name":"DCI","value":"584428.46","children":[]}]},{"name":"系统集成","value":"109880","children":[]}]
|
||
}
|
||
|
||
return {
|
||
'LeftUp': LeftUp,
|
||
'LeftDown': LeftDown,
|
||
'RightUp': RightUp,
|
||
'RightDown': RightDown
|
||
}
|
||
|
||
ret = await large_screen_first_page(params_kw)
|
||
return ret |