loan_contract需要时时进行修改

人工控制/现金贷/人工控制-现金贷-放款表-加速测试版.py

@@ -25,9 +25,10 @@ import os
 #	loan_manifest.is_active in （1，-2）
 
 # 	需要先进行数据的获取，需要时间较长，sql_repay_all中xrd.repaid_at同样需要修改
+#   sql_contract_no需要每月进行修改
 
 path = u'1020_files/'
-path = u'E:/审计出表/非去哪儿白条-客户实还表-1023版/'
+path = u'E:/审计出表/11月份开始使用表数据/11月份现金贷出表/'
 engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/audit?charset=utf8',
 						   echo=False).connect()
 
@@ -48,7 +49,7 @@ def faster_sql_reader(sql):
 sql_fund = '''
 	select frp.ref_id,frp.term_no 'term_no',date(frp.deadline) 'deadline',frp.principle+ifnull(frp.interest,0) 'prin_interes'
 	from audit.funding_repayment_plan frp
-	where frp.deadline >= '2017-01-01'
+	where frp.deadline >= '2017-10-01'
 '''
 df_fund = faster_sql_reader(sql_fund)
 df_fund.rename(columns={'term_no':u'应还期数','deadline':u'应还资金方时间','prin_interes':u'应还资金方本息'},inplace=True)
@@ -58,13 +59,13 @@ df_fund.rename(columns={'term_no':u'应还期数','deadline':u'应还资金方
 #此部分不需要进行修改
 sql_contract_no = '''
 select ref_id,contract_no
-from basic.loan_class_contract_1002 lco
+from basic.loan_class_contract_201711 lco
 '''
 #10月05日修改为basic.loan_class_contract_1002
 
 df_contract_no = faster_sql_reader(sql_contract_no)
 
-sql_fund_name = '''
+sql_fund_name = ''' 
 select funding_code,name '资金方' 
 from basic.funding_corp
 '''
@@ -81,9 +82,9 @@ def mc_pay(year, month):
 	urp.term_no 'term_no',
 	sum(xrprrr.principle-IFNULL(xrprrr.mitigate_principle,0)+xrprrr.interest-IFNULL(xrprrr.mitigate_interest,0)) 'principle_interes',
 	sum(xrprrr.service_fee-IFNULL(xrprrr.mitigate_service_fee,0)) 'service_fee'
-	from audit_temp.xjd_repay_plan_repay_record_ref_0831 xrprrr
-	join all_back_0831.user_repayment_plan urp on xrprrr.plan_id = urp.id
-	join all_back_0831.loan_manifest lm on lm.ref_id = urp.ref_id
+	from new_transaction.xjd_repay_plan_repay_record_ref xrprrr
+	join new_transaction.user_repayment_plan urp on xrprrr.plan_id = urp.id
+	join audit.loan_manifest lm on lm.ref_id = urp.ref_id
 	where lm.loan_paid_at>='%s' and lm.loan_paid_at<'%s'
 	group by 1,2
 	''' %(start_time,end_time)
@@ -168,7 +169,7 @@ def mc_pay(year, month):
 		temp_list = temp.values.tolist()
 		temp_list.insert(0,temp.columns.tolist())
 		all_wb.new_sheet(str(int(i/max_limit + 1)),data=temp_list)
-	all_wb.save(path+u'人工控制-现金贷-放款表_测试(%d-%02d).xlsx' %(start_time.year,start_time.month))
+	all_wb.save(path+u'人工控制-现金贷-放款表(%d-%02d).xlsx' %(start_time.year,start_time.month))
 
 
 	# if len(df_pay) > max_limit:
@@ -180,7 +181,7 @@ def mc_pay(year, month):
 
 if __name__ == '__main__':
 	year = [2017]
-	month = range(1, 2, 1)
+	month = range(10, 11, 1)
 
 	for year, month in product(year, month):
 		mc_pay(year, month)