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 20 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'] } ret = await operator_get_all_bill(params_kw) return ret