20191220_0

AUC_time.py

@@ -294,7 +294,8 @@ class AUCMonitor:
             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
+                      'repayment_status': 1,
+                      'deadline': 1
                       }
             for f in self.field_query_list:  # 加入Excel中预置的模型分名称
                 fields[f] = 1
@@ -302,6 +303,7 @@ class AUCMonitor:
             print('MongoDB数据获取成功.')
             self.mongo_df.to_csv(self.save_path + 'data/mongo_data.csv', index=False)
             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['wf_created_at']
             self.mongo_df['applied_from'] = self.mongo_df['wf_biz_channel']
@@ -315,7 +317,11 @@ class AUCMonitor:
         else:
             self.mongo_df = pd.read_csv(self.save_path + 'data/mongo_data.csv')
         self.mongo_df = self.mongo_df.loc[self.mongo_df['applied_type'].notna()]
+        last_day = datetime.datetime.today()
 
+        self.mongo_df['deadline'] = self.mongo_df['deadline'].apply(lambda x: pd.datetime.strptime(x, '%Y-%m-%d %H:%M:%S'))
+        self.mongo_df['is_behave'] = self.mongo_df['deadline'].apply(lambda x: int((last_day - x).days > 15))
+        self.mongo_df = self.mongo_df.loc[self.mongo_df['is_behave'] == 1]
 
         # 定义逾期用户.
         def overdue(data):