非去哪儿白条人工控制实还

白条/人工控制核对/白条还款表-按实还及放款时间提取V2.py

@@ -14,7 +14,6 @@ sys.stdout = stdout
 # 引入数据库连接，并使修改生效
 pd.options.mode.chained_assignment = None
 pd.set_option('display.float_format', lambda x: '%.5f' % x)
-#mysql_engine = db_connect.sql_engine(db_connect.audit, 'new_transaction', False).get_engine()
 mysql_engine = create_engine( 'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/new_transaction?charset=utf8', echo=True)
 # 获取当前时间，用于创建文件路径，分类存储文件
 today = datetime.datetime.now()
@@ -31,6 +30,8 @@ if not os.path.exists(tmp_path):
     os.makedirs(tmp_path)
 
 
+
+
 start_time='2017-10-01'
 end_time='2017-11-01'
 out_file_path=u'/vpants/shaun/jupyter/shiyao/baitiao/out_file/'
@@ -89,6 +90,7 @@ SELECT
 FROM baitiao_repay_plan_repay_record_ref brprrr
 JOIN test_mzh.repay_record_amount rr ON rr.record_id = brprrr.record_id AND rr.repay_channel = brprrr.repay_channel AND rr.repaid_at >= '%s' AND rr.repaid_at < '%s'
 JOIN user_bt_repayment_plan ubrp ON ubrp.id = brprrr.plan_id
+join bt_funding_repayment_plan bfrp on ubrp.repayment_plan_id =bfrp.repay_plan_id and ubrp.sys_tag='XYQB_BILL_BT'
 JOIN baitiao_audit.baitiao_order bo ON bo.ref_id = ubrp.ref_id and bo.funding_corp_id=5   and bo.is_active in(1,-2)
 JOIN baitiao_audit.merchant m ON m.merchant_id = bo.merchantId
 JOIN baitiao_audit.fund_corp fc ON fc.id = bo.funding_corp_id
@@ -123,6 +125,8 @@ JOIN baitiao_audit.merchant m ON m.merchant_id = bo.merchantId
 JOIN baitiao_audit.fund_corp fc ON fc.id = bo.funding_corp_id and bo.funding_corp_id=5
 JOIN new_transaction.repay_channel rc ON rc.id = brprrr.repay_channel
 """
+
+
 df_bl = pd.read_sql(sql_baoli % (start_time,end_time), con=mysql_engine)
 df_zt = pd.read_sql(sql_zhitou % (start_time,end_time), con=mysql_engine)
 #直投白条线下退款
@@ -163,6 +167,8 @@ tmp.loc[tmp[u'唯一编号'].duplicated(), [u'应还本金', u'应还利息']] =
 tmp.loc[tmp[[u'流水号', u'还款账户']].duplicated(), [u'账单金额']] = 0
 tmp[u'应还本息-实还本息'] = np.round(tmp[u'应还本金'] - tmp[u'实还本金'] + tmp[u'应还利息'] - tmp[u'实还利息'], 2)
 tmp[u'还款总额-账单金额'] = np.round(tmp[u'还款总额'] - tmp[u'账单金额'], 2)
+
+
 date_range = pd.date_range(start=start_time, end=end_time, freq='MS')
 cnt = 0
 for i in xrange(0, len(date_range) - 1):
@@ -181,6 +187,7 @@ for i in xrange(0, len(date_range) - 1):
 #     tmp.to_excel(os.path.join(file_path, '客户实还表（实还时间%s-%02d）.xlsx' % (date_range[i].year, date_range[i].month)), index=None)
 print cnt, len(df)
 
+
 loan_baoli = """
 SELECT
   concat(bo.order_no, ubrp.term_no)                 唯一编号,
@@ -335,8 +342,6 @@ FROM baitiao_repay_plan_repay_record_ref brprrr
   JOIN baitiao_audit.fund_corp fc ON fc.id = bo.funding_corp_id
   JOIN new_transaction.repay_channel rc ON rc.id = brprrr.repay_channel
 """
-
-
 df_bl = pd.read_sql(loan_baoli % (start_time,end_time,start_time,end_time), con=mysql_engine)
 df_zt = pd.read_sql(loan_zhitou % (start_time,end_time,start_time,end_time), con=mysql_engine)
 df_zt_apli=pd.read_sql(loan_zhitou_apli % (start_time,end_time), con=mysql_engine)