修改数据库地址

审计第二阶段/现金贷/更新还资金方还款计划.py

@@ -9,7 +9,7 @@ from sqlalchemy import create_engine
 
 reload(sys)
 sys.setdefaultencoding('utf8')
-engine_audit = create_engine('mysql+mysqldb://yulong:ohVU1nPITynSZwR2@172.16.3.201:3306/audit?charset=utf8',
+engine_audit = create_engine('mysql+mysqldb://yulong:ohVU1nPITynSZwR2@172.16.4.60:3306/audit?charset=utf8',
                              echo=True)
 
 query_repay = """

审计第二阶段/现金贷/现金贷-每月到期本金利息.py

@@ -22,7 +22,7 @@ pd.options.mode.chained_assignment = None
 #
 
 file_path = u'E:/审计出表/现金贷-放款表（1月份-6月份）-当前库/'
-engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/audit?charset=utf8',
+engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/audit?charset=utf8',
 							  echo=False).connect()
 
 def xjd_principle_interest():

审计第二阶段/现金贷/给审计-现金贷-放款表-所有月份可用-新马上.py

@@ -27,7 +27,7 @@ sys.setdefaultencoding('utf8')
 path = u'E:/审计出表/现金贷-放款表（1月份-6月份）-当前库/'
 
 engine_new_transaction = create_engine(
-	'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/new_mashang?charset=utf8',
+	'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/new_mashang?charset=utf8',
 	echo=True)
 
 sql_query_detail = '''

审计第二阶段/现金贷/给审计-现金贷-放款表-所有月份可用.py

@@ -25,10 +25,10 @@ pd.options.mode.chained_assignment = None
 #
 
 path = u'E:/审计出表/11月份开始使用表数据/11月份现金贷出表/'
-engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8',
+engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/?charset=utf8',
 							  echo=False).connect()
 def faster_sql_reader(sql):
-	cmdstr = 'mysql -h172.16.3.201 -uinternal_r -pArbNgtvlJzZHXsEu -P3306 -e "%s" > %s'
+	cmdstr = 'mysql -h172.16.4.60 -uinternal_r -pArbNgtvlJzZHXsEu -P3306 -e "%s" > %s'
 	file_name = 'test.txt'
 	path_file = os.path.join(os.getcwd(), file_name)
 	exe_sql = cmdstr % (sql.replace('`',''), path_file)

审计第二阶段/现金贷/给审计-现金贷-趸交相关-所有月份可用.py

@@ -26,7 +26,7 @@ pd.options.mode.chained_assignment = None
 
 
 file_path = u'E:/审计出表/现金贷-放款表（1月份-6月份）-当前库/'
-engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8',
+engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/?charset=utf8',
 						   echo=False).connect()
 
 def dunjiao(year,month):

审计第二阶段/现金贷/给审计-现金贷-还款表-所有月份可用-阳光徽商.py

@@ -27,7 +27,7 @@ sys.setdefaultencoding('utf8')
 path = u'E:/审计出表/现金贷-还款表（1月份-6月份）/'
 
 engine_new_transaction = create_engine(
-	'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8',
+	'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/?charset=utf8',
 	echo=True)
 
 sql_query_detail = '''

审计第二阶段/现金贷/给审计-现金贷-还款表-所有月份可用.py

@@ -14,12 +14,11 @@ sys.setdefaultencoding("utf-8")
 pd.options.mode.chained_assignment = None
 
 def faster_sql_reader(sql):
-	cmdstr = 'mysql -h172.16.3.201 -uinternal_r -pArbNgtvlJzZHXsEu -P3306 -e "%s" > %s'
+	cmdstr = 'mysql -h172.16.4.60 -uinternal_r -pArbNgtvlJzZHXsEu -P3306 -e "%s" > %s'
 	file_name = 'test.txt'
 	path_file = os.path.join(os.getcwd(), file_name)
 	exe_sql = cmdstr % (sql.replace('`',''), path_file)
 	exe_sql = exe_sql.replace('\t','').replace('\n',' ')
-	print exe_sql
 	os.system(exe_sql)
 	try:
 		df = pd.read_csv(path_file, sep='\t',encoding='utf-8')
@@ -40,7 +39,7 @@ def faster_sql_reader(sql):
 #	趸交服务费需要添加到这个表里
 #
 file_path = u'E:/审计出表/11月份开始使用表数据/11月份现金贷出表/'
-engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/audit?charset=utf8',
+engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/audit?charset=utf8',
 						   echo=False).connect()
 read_fund_sql = '''  
 SELECT funding_code fund_corp_id,name fund_name FROM basic.funding_corp
@@ -59,10 +58,10 @@ SELECT t1.fund_code,t2.repay_channel,t1.real_loan_id loan_id,t3.contract_term,da
 t6.bill_time repaid_at,
 t2.ref_amount,t2.principle-t2.mitigate_principle real_principle,t2.interest-t2.mitigate_interest real_interest,
 ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) real_service_fee,IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) real_punish,t2.remain_income,t6.order_id AS 'business_flow'
-FROM audit_temp.`xjd_repay_plan_repay_record_ref` t2
-JOIN audit_temp.`user_repayment_plan` t1 ON t1.id=t2.plan_id
+FROM all_back_0731.`xjd_repay_plan_repay_record_ref_0731` t2
+JOIN all_back_0731.`user_repayment_plan` t1 ON t1.id=t2.plan_id
 JOIN all_back_0731.`loan_manifest` t3 ON t1.ref_id=t3.ref_id
-JOIN audit_temp.repay_record_online t6 ON t2.record_id=t6.id AND t2.repay_channel  = t6.pay_approach
+JOIN all_back_0731.repay_record_online t6 ON t2.record_id=t6.id AND t2.repay_channel  = t6.pay_approach
 LEFT JOIN new_transaction.xjd_dunjiao_plan xdp ON xdp.loan_id = t1.real_loan_id
 WHERE  t6.bill_time >= '%s' AND t6.bill_time < '%s'
 '''
@@ -73,8 +72,8 @@ SELECT t1.fund_code,t2.repay_channel,t1.real_loan_id loan_id,t3.contract_term,da
 t6.transfer_time repaid_at,
 t2.ref_amount,t2.principle-t2.mitigate_principle real_principle,t2.interest-t2.mitigate_interest real_interest,
 ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) real_service_fee,ifnull(t2.`punish`-t2.mitigate_collection_relief,0) real_punish,t2.remain_income,t6.business_flow
-FROM audit_temp.`xjd_repay_plan_repay_record_ref_0731` t2
-JOIN audit_temp.`user_repayment_plan` t1 ON t1.id=t2.plan_id
+FROM all_back_0731.`xjd_repay_plan_repay_record_ref_0731` t2
+JOIN all_back_0731.`user_repayment_plan` t1 ON t1.id=t2.plan_id
 JOIN all_back_0731.`loan_manifest` t3 ON t1.ref_id=t3.ref_id
 JOIN all_back_0731.`offline_alipay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel = 13
 WHERE  t6.transfer_time >= '%s' AND  t6.transfer_time < '%s'
@@ -86,8 +85,8 @@ SELECT t1.fund_code,t2.repay_channel,t1.real_loan_id loan_id,t3.contract_term,da
 t6.transfer_time repaid_at,
 t2.ref_amount,t2.principle-t2.mitigate_principle real_principle,t2.interest-t2.mitigate_interest real_interest,
 ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) real_service_fee,ifnull(t2.`punish`-t2.mitigate_collection_relief,0) real_punish,t2.remain_income
-FROM audit_temp.`xjd_repay_plan_repay_record_ref` t2
-JOIN audit_temp.`user_repayment_plan` t1 ON t1.id=t2.plan_id
+FROM all_back_0731.`xjd_repay_plan_repay_record_ref_0731` t2
+JOIN all_back_0731.`user_repayment_plan` t1 ON t1.id=t2.plan_id
 JOIN all_back_0731.`loan_manifest` t3 ON t1.ref_id=t3.ref_id
 JOIN all_back_0731.`offline_bank_repay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel IN (14,15,16)
 WHERE  t6.transfer_time >=  '%s' AND  t6.transfer_time <  '%s'
@@ -109,11 +108,11 @@ def dunjiao(year, month):
 		rech.approach_name '还款渠道'
 	FROM
 		new_transaction.xjd_dunjiao_plan dj
-		join all_back_0930.loan_manifest lm on lm.loan_id = dj.loan_id
+		join all_back_0731.loan_manifest lm on lm.loan_id = dj.loan_id
 		join basic.funding_corp fc on fc.funding_code = lm.funding_code
 		join new_transaction.xjd_dunjiao_plan_ref xdpr on xdpr.plan_id = dj.id
 		join new_transaction.repay_channel rech on rech.id = xdpr.repay_channel
-		join all_back_0930.repay_record_online rro on rro.id = xdpr.record_id
+		join all_back_0731.repay_record_online rro on rro.id = xdpr.record_id
 
 	WHERE
 		dj.xyqb_repaid_at >= '%s'
@@ -178,7 +177,7 @@ def handle_hk(year, month):
 
 if __name__ == '__main__':
 	year = [2017]
-	month = range(9, 10, 1)
+	month = range(1, 5, 1)
 
 	for year, month in product(year, month):
 		handle_hk(year, month)

审计第二阶段/现金贷/给审计-现金贷-还款表-支付宝差异-所有月份可用.py

@@ -6,7 +6,7 @@ import numpy as np
 
 
 con_all_back = create_engine(
-    'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8', echo=False)
+    'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/?charset=utf8', echo=False)
 
 sql_query_xjd = """SELECT
 	oar.id "支付宝id",