out_text_sql_ssmd = """ select id, 咨询师, 组别, round(业绩金额) as yeji, created_at from sales_performance_record where 状态 = 1 and created_at between %(start_date)s and %(end_date)s order by id desc limit 1 """

部门-组别

department = ''' select 工作台组别, dd_manager, 端口, 城市, start_date, end_date from group_mapping '''

def last_sale(): # 最大的id max_id = sql_data(max_id_sql)[0][0] # print('max_id: ', max_id)

# 最新一单业绩
new_sale = sql_data(out_text_sql_ssmd,{"start_date": start_date, "end_date": end_date})
new_sale_df = pd.DataFrame(data=new_sale, index=None, columns=['id', '咨询师', '组别', '业绩', 'created_at'])
# print('new_sale: ', new_sale)
# print('new_sale_df: ', new_sale_df)

# 部门-组别表
de_gr = read_pg_sql(department)
de_gr_df = pd.DataFrame(data=de_gr, index=None, columns=['组别', '部门', '端口', '城市', 'start_date', 'end_date'])

# 合并业绩与部门表
sa_dp = pd.merge(left=new_sale_df, right=de_gr_df, on=['组别', 'start_date', 'end_date'], how='inner'