Commit 552e8ad0 authored by 舒皓月's avatar 舒皓月

20191220_2

parent 6b9a3ffe
......@@ -290,10 +290,10 @@ class AUCMonitor:
# 获取MongoDB数据.
if self.if_read:
condition = {'lam_loan_start_date': {'$gte': '%s 00:00:00' % self.date_list[0],
condition = {'wf_created_at': {'$gte': '%s 00:00:00' % self.date_list[0],
'$lte': '%s 00:00:00' % self.date_list[-1]},
'passdue_day': {'$ne': None}}
fields = {'wf_biz_no': 1, 'lam_loan_start_date': 1, 'wf_loan_type': 1,
fields = {'wf_biz_no': 1, 'wf_created_at': 1, 'wf_loan_type': 1,
'passdue_day': 1, 'wf_biz_channel': 1, 'applied_channel_cn': 1,
'lam_transaction_status': 1,
'repayment_status': 1,
......@@ -307,12 +307,12 @@ class AUCMonitor:
self.mongo_df = pd.read_csv(self.save_path + 'data/mongo_data.csv')
self.mongo_df['applied_type'] = self.mongo_df['wf_loan_type'].apply(func_0)
self.mongo_df['applied_at'] = self.mongo_df['lam_loan_start_date']
self.mongo_df['applied_at'] = self.mongo_df['wf_created_at']
self.mongo_df['applied_from'] = self.mongo_df['wf_biz_channel']
self.mongo_df['applied_channel'] = self.mongo_df['applied_channel_cn']
del self.mongo_df['wf_loan_type']
del self.mongo_df['lam_loan_start_date']
del self.mongo_df['wf_created_at']
del self.mongo_df['wf_biz_channel']
del self.mongo_df['applied_channel_cn']
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment