非去哪儿每日赔付

每日赔付/非去哪儿白条直投赔付/白条每日赔付以loan_id维度展开（在用）.py

@@ -24,10 +24,15 @@ end_date = datetime.date(end_y, end_m, 1)
 
 path = u'E:/数据汇总/白条/每日赔付/2017-10/'
 
+loan_info = """
+    SELECT r.order_no,r.term_no,date(o.loan_paid_at) loan_paid_at
+    FROM baitiao_audit.baitiao_order o
+    JOIN new_transaction.bt_funding_repayment_record r ON o.ref_id=r.ref_id
+"""
+
 loan_plan_hk = '''
-  SELECT t.order_no,t.term_no,t.day_hk,t.loan_paid_at,SUM(t.plan_all) plan_all from(
-    SELECT plan.order_no,plan.term_no,DATE(t2.loan_paid_at)loan_paid_at,
-    DATE(plan.deadline) day_hk,SUM(plan.principal+plan.interest) plan_all 
+  SELECT t.order_no,t.term_no,t.day_hk,SUM(t.plan_all) plan_all from(
+    SELECT plan.order_no,plan.term_no, DATE(plan.deadline) day_hk,SUM(plan.principal+plan.interest) plan_all 
     FROM  bt_funding_repayment_plan plan
     JOIN user_bt_repayment_plan t1 on plan.repay_plan_id=t1.repayment_plan_id AND t1.sys_tag='XYQB_BILL_BT'
     JOIN baitiao_audit.baitiao_order t2 ON t1.ref_id=t2.ref_id
@@ -36,8 +41,7 @@ loan_plan_hk = '''
       and plan.deadline >= '%s' AND plan.deadline < '%s'  
     GROUP BY 1,2,3
     UNION ALL 
-    SELECT plan.order_no,plan.term_no,DATE(t2.loan_paid_at)loan_paid_at,
-    DATE(plan.deadline) day_hk,SUM(plan.interest) plan_all 
+    SELECT plan.order_no,plan.term_no, DATE(plan.deadline) day_hk,SUM(plan.interest) plan_all 
     FROM  bt_funding_repayment_plan plan
     JOIN user_bt_repayment_plan t1 on plan.repay_plan_id=t1.repayment_plan_id AND t1.sys_tag='XYQB_BILL_BT'
     JOIN baitiao_audit.baitiao_order t2 ON t1.ref_id=t2.ref_id
@@ -174,7 +178,11 @@ def split_repay(df_repay, df_plan):
     if len(df_repay) > 0:
         df_hk_new = pd.merge(df_zc, df_yq, how='outer', on=['order_no', 'term_no', 'day_hk'])
         df_hk_new = pd.merge(df_hk_new, df_tq, how='outer', on=['order_no', 'term_no', 'day_hk'])
-        df_hk_new = pd.merge(df_plan, df_hk_new, how='outer', on=['order_no', 'term_no', 'day_hk'])
+        df_hk_new.fillna(0, inplace=True)
+        df_h = df_hk_new.groupby(by=['order_no', 'term_no', 'day_hk'])[
+            'zc_prin_inst_total', 'yq_prin_inst_total', 'tq_prin_inst_total'].sum().reset_index()
+        # df_plan.drop('day_hk', axis=1, inplace=True)
+        df_hk_new = pd.merge(df_plan, df_h, how='outer', on=['order_no', 'term_no','day_hk'])
     else:
         df_hk_new = df_plan
         df_hk_new['zc_prin_inst_total'] = 0
@@ -224,11 +232,18 @@ def spread_loan_id():
     df_hk_new.fillna(0, inplace=True)
     df_hk_new['real_all'] = df_hk_new['zc_prin_inst_total'] + df_hk_new['yq_prin_inst_total'] + df_hk_new[
         'tq_prin_inst_total']
+    df_info = pd.read_sql(loan_info, engine_new_transaction)
+    df_info.order_no = df_info.order_no.astype(str)
+    df_info.term_no = df_info.term_no.astype(int)
+    df_hk_new.order_no = df_hk_new.order_no.astype(str)
+    df_hk_new.term_no = df_hk_new.term_no.astype(int)
+    df_hk_new = pd.merge(df_hk_new, df_info, on=['order_no', 'term_no'], how='left')
     df_hk_new = df_hk_new[
-        ['order_no', 'term_no', 'loan_paid_at', 'day_hk', 'plan_all', 'zc_prin_inst_total', 'yq_prin_inst_total',
+        ['order_no', 'term_no', 'loan_paid_at','day_hk', 'plan_all', 'zc_prin_inst_total', 'yq_prin_inst_total',
          'tq_prin_inst_total', 'tx_plan_all', 'tx_zc_principle', 'tx_yq_principle', 'tx_tq_principle',
          'sr_plan_all', 'sr_zc_principle', 'sr_yq_principle', 'sr_tq_principle', 'zbj_plan_all', 'zbj_zc_principle',
          'zbj_yq_principle', 'zbj_tq_principle', 'real_all']]
+
     df_hk_new.rename(columns={'day_hk': '还款日期', 'plan_all': '应还资金方本息', 'real_all': '客户实还可用',
                               'zc_prin_total': '客户正常还款本金', 'yq_prin_total': '客户逾期还款本金',
                               'zc_prin_inst_total': '客户正常还款本金', 'yq_prin_inst_total': '客户逾期还款本金',
@@ -240,12 +255,12 @@ def spread_loan_id():
                               'tx_plan_all': '提现账户应还资方本息', 'sr_plan_all': '收入账户应还资方本息',
                               'zbj_plan_all': '质保金账户应还资方本息', 'zbj_yq_principle': '质保金账户客户逾期还款本金',
                               'zbj_tq_principle': '质保金账户客户提前可用本金'}, inplace=True)
-    data_list = df_hk_new.values.tolist()
-    data_list.insert(0, df_hk_new.columns.tolist())
-    wb = pe.Workbook()
-    wb.new_sheet(u'明细', data=data_list)
-    wb.save(path + u'5_loan_id维度展开2017-10.xlsx')
-    # df_hk_new.to_excel(path + u'5_loan_id维度展开2017-10.xlsx', index=None, columns=df_hk_new.columns, encoding='utf8')
+    # data_list = df_hk_new.values.tolist()
+    # data_list.insert(0, df_hk_new.columns.tolist())
+    # wb = pe.Workbook()
+    # wb.new_sheet(u'明细', data=data_list)
+    # wb.save(path + u'5_loan_id维度展开2017-10_2.xlsx')
+    df_hk_new.to_excel(path + u'5_loan_id维度展开2017-10_3.xlsx', index=None, columns=df_hk_new.columns, encoding='utf8')
 
 
-spread_loan_id()
+spread_loan_id()
\ No newline at end of file