Skip to content

D
duizhang_tools
Commit be6fb1dd authored by Data-韩正辉's avatar Data-韩正辉
Browse files
Options

这部分代码是目前在用的部分代码的正确版本，包括人工控制、给审计、赔付、在贷等，目的是集合所有正确版本的代码，方便其他人使用

parent cfbe724a
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 2039 additions and 0 deletions
现金贷&去哪儿&白条--在用代码维护/ReadMe.txt 0 → 100644
View file @ be6fb1dd
#@han
这是现金贷&白条&去哪儿在用的一部分代码，主要包括给审计、人工控制、在贷、赔付和到期应还等几个方面。
欢迎大家补充！
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/去哪儿白条/去哪儿-每月到期本金利息.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
#
# 表名称：
# 现金贷-每月到期本金利息
#表字段：
# 资金方 放款年 放款月 到期年 到期月 客户应还本金 客户应还利息
# 数据库：
# new_transaction，loan_manifest，fund_corp,loan_class_contract_1002
# 注意事项：
# 出来的表为汇总表
#
file_path = u'E:/审计出表/去哪儿/'
engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/audit?charset=utf8',
echo=False).connect()
def xjd_principle_interest():
sql_quaer_2016 = '''
SELECT
fc.fund_name 资金方,
YEAR (t2.loan_time) 放款年,
MONTH (t2.loan_time) 放款月,
YEAR (t1.deadline) 到期年,
MONTH (t1.deadline) 到期月,
sum(t1.principle) 客户应还本金,
sum(t1.fee_amount) 客户应还利息
FROM
qunaer_new.repayment_plan_2016 t1
JOIN qunaer_new.pay_detail t2 ON t1.product_no = t2.product_no
JOIN qunaer_new.fund_corp fc ON fc.fund_code = t2.fund_code
where t1.status in (1,2)
GROUP BY
1,2,3,4,5;
'''
sql_quaer_2017 = '''
SELECT
fc.fund_name 资金方,
YEAR (t2.loan_time) 放款年,
MONTH (t2.loan_time) 放款月,
YEAR (t1.deadline) 到期年,
MONTH (t1.deadline) 到期月,
sum(t1.principle) 客户应还本金,
sum(t1.fee_amount) 客户应还利息
FROM
qunaer_new.repayment_plan_2017 t1
JOIN qunaer_new.pay_detail t2 ON t1.product_no = t2.product_no
JOIN qunaer_new.fund_corp fc ON fc.fund_code = t2.fund_code
where t1.status in (1,2) and t2.status = 1
GROUP BY
1,2,3,4,5;
'''
sql_quaer_baoli = '''
SELECT
'保理' 资金方,
YEAR (t2.loan_time) 放款年,
MONTH (t2.loan_time) 放款月,
YEAR (t1.deadline) 到期年,
MONTH (t1.deadline) 到期月,
sum(t1.principle) 客户应还本金,
sum(t1.fee_amount) 客户应还利息
FROM
qunaer_new.repayment_plan_2017 t1
JOIN qunaer_new.baoli_pay_detail t2 ON t1.product_no = t2.product_no and t1.fund_code = 1
JOIN qunaer_new.fund_corp fc ON fc.fund_code = t2.fund_code
WHERE t1.status IN (1,2) AND t2.status = 1
GROUP BY
1,2,3,4,5;
'''
df_quaer_2016 = pd.read_sql(sql_quaer_2016,engine_xjd)
df_quaer_2017 = pd.read_sql(sql_quaer_2017,engine_xjd)
df_quaer_baoli = pd.read_sql(sql_quaer_baoli,engine_xjd)
df_quaer_all = pd.concat([df_quaer_2016,df_quaer_baoli,df_quaer_2017],ignore_index=True)
df_quaer_all.loc[df_quaer_all[u'资金方']==u'保理',u'客户应还利息'] = 0
df_quaer_all.to_excel(file_path+u'去哪儿-每月到期本金利息-11月份V2.xlsx',index=False)
if __name__ == '__main__':
print '--------main begin'
xjd_principle_interest()
print '________main done'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/去哪儿白条/去哪儿净放款.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
import multiprocessing as mtp
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
file_path = u'E:/量化派/去哪儿/常规出账/'
file_name = u'去哪儿净放款_%s_%s.xlsx'
engine_qunaer = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/qunaer_new?charset=utf8',
echo=False).connect()
year=2017
month=10
start_time=datetime.date(year,month,1)
end_time=start_time + relativedelta(months=+1)
sql_pay='''
select fund.fund_name 资金方,product_no 产品编号,pay.stages 期数,date(trans_time) 放款时间,loan_amount 放款金额
from qunaer_new.pay_detail pay
JOIN qunaer_new.fund_corp fund on pay.fund_code = fund.fund_code
where status=1 and pay.fund_code != 1 AND trans_time >= '%s' AND trans_time <'%s'
''' % (start_time,end_time)
sql_refund='''
select fund.fund_name 资金方,t1.product_no 产品编号,t2.stages 期数,DATE(refund_time) 放款时间,refund_principle 放款金额
from qunaer_new.refund_detail t1
JOIN qunaer_new.pay_detail t2 on t1.product_no = t2.product_no
JOIN qunaer_new.fund_corp fund on t2.fund_code = fund.fund_code
WHERE t1.fund_code != 1 AND t2.status=1 AND t1.refund_status=1 AND refund_time >= '%s' AND refund_time < '%s'
''' % (start_time,end_time)
df_pay=pd.read_sql(sql_pay,engine_qunaer)
df_refund=pd.read_sql(sql_refund,engine_qunaer)
df_pay=pd.concat([df_pay,df_refund],ignore_index=True)
df_pay.to_excel(file_path+file_name % (year,month))
现金贷&去哪儿&白条--在用代码维护/去哪儿白条/坏账.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import calendar
import pandas as pd
from sqlalchemy import create_engine
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
'''
@author linfang
1、去哪儿坏账
'''
year=2017
month=10
path = u'E:/量化派/去哪儿/常规出账/'
a,b=calendar.monthrange(year,month)
#本月最后一天
last_day=datetime.date(year,month,b)
#17年放款的还款计划表
table_2017_name='repayment_plan_2017'
#16年放款的还款计划表
table_2016_name='repayment_plan_2016'
engine_qunaer = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/qunaer_new?charset=utf8',
echo=False).connect()
#未还款
sql_2017_unrepay='''
select product_no,current_stage_no,deadline,principle
from %s
where status = 1 and datediff('%s',date(deadline)) >= 90 AND fund_code = 1
''' % (table_2017_name,last_day)
#还款1半的
sql_2017_repay='''
select product_no,current_stage_no,deadline,(principle-repay_principle) principle
from %s
where status = 2 and repay_amount > 0 and principle > repay_principle and datediff('%s',date(deadline)) >= 90 AND fund_code = 1
''' % (table_2017_name,last_day)
#未还款
sql_2016_unrepay='''
select product_no,current_stage_no,deadline,principle
from %s
where status = 1 and principle > 0 and datediff('%s',date(deadline)) >= 90
''' % (table_2016_name,last_day)
#已还款
sql_2016_repay='''
select product_no,current_stage_no,deadline,(principle-repay_principle) principle
from %s
where status = 2 and repay_amount > 0 and principle > repay_principle and principle > 0 and datediff('%s',date(deadline)) >= 90
''' % (table_2016_name,last_day)
df_2017_unrepay=pd.read_sql(sql_2017_unrepay,engine_qunaer)
df_2017_repay=pd.read_sql(sql_2017_repay,engine_qunaer)
df_2016_unrepay=pd.read_sql(sql_2016_unrepay,engine_qunaer)
df_2016_repay=pd.read_sql(sql_2016_repay,engine_qunaer)
df=pd.concat([df_2017_unrepay,df_2017_repay,df_2016_unrepay,df_2016_repay],ignore_index=True,axis=0)
df.rename(columns={'product_no':'产品编号','current_stage_no':'期数','deadline':'应还日期','principle':'未还本金'},inplace=True)
df.to_excel(path+u'坏账_%s_%s.xlsx' %(year,month),columns=df.columns,index=None, encoding='utf8')
现金贷&去哪儿&白条--在用代码维护/去哪儿白条/给审计/白条-去哪儿-核算-放款表-最终版.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
import multiprocessing as mtp
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
#
# 表名称：
# 白条-去哪儿-核算-放款表：分多种类型，转让保理后的放款表，资金方的放款表，针对用户角度的放款表
file_path = u'E:/量化派/去哪儿/常规出账/'
file_name = u'核算放款表_%s_%s.xlsx'
engine_qunaer = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/qunaer_new?charset=utf8',
echo=False).connect()
# 债权转让后的保理放款表
def baoli_pay(year, month,plan_table='repayment_plan_2017'):
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
sql_pay = '''
select '保理' AS '资金方',
pay.product_no '产品编号',
date(pay.trans_time) '债转时间',
date(pay.loan_time) '放款时间',
pay.loan_amount '合同放款金额',
pay.new_stages AS '贷款总期数',
'FALSE' AS '是否退款',
'FALSE' AS '是否转分期后订单',
'FALSE' AS '是否资金方直投',
plan.current_stage_no '当期期数',
date(plan.deadline) '每期应还款日',
plan.principle+plan.fee_amount '每期应还金额',
plan.principle '每期应还本金',
plan.fee_amount AS '每期应还服务费',
0 AS '每期应还服务费-QG承担'
from qunaer_new.baoli_pay_detail pay
join %s plan on pay.product_no = plan.product_no AND plan.fund_code = 1
where trans_time >='%s' and trans_time < '%s'
''' % (plan_table,start_time, end_time)
# # 属于保理的退款--flow_id 提取空的
# sql_refund='''
# select '保理' AS '资金方',
# refund.product_no '产品编号',
# date(pay.trans_time) '债转时间',
# date(pay.loan_time) '放款时间',
# refund.refund_amount '合同放款金额',
# pay.new_stages '贷款总期数',
# 'TRUE' AS '是否退款',
# date(refund.refund_time) AS '退款时间',
# month(refund.refund_time) AS '退款月份',
# 'FALSE' AS '是否转分期后订单',
# 'FALSE' AS '是否资金方直投'
# from qunaer_new.refund_detail refund
# JOIN qunaer_new.baoli_pay_detail pay on refund.product_no = pay.product_no and refund.fund_code = 1
# WHERE refund_time >='%s' and refund_time < '%s' and refund.flow_id IS NULL
# ''' % (start_time,end_time)
# 读取sql语句，2分钟左右
df_pay = pd.read_sql(sql_pay, engine_qunaer)
# 含有 flow_id 的退款，在还款表中体现。
# df_refund = pd.read_sql(sql_refund, engine_qunaer)
# 合并退款记录和放款记录
# df = pd.concat([df_pay, df_refund], ignore_index=True)
# df = df.fillna(0)
df_pay.ix[df_pay[[u'产品编号']].duplicated(),u'合同放款金额'] = 0
return df_pay[[u'资金方',u'产品编号',u'债转时间',u'放款时间',u'合同放款金额',u'贷款总期数',u'是否退款',u'是否转分期后订单',
u'是否资金方直投',u'当期期数',u'每期应还款日',u'每期应还金额',u'每期应还本金',u'每期应还服务费',u'每期应还服务费-QG承担']]
# 资金方放款表
def fund_pay(year,month,plan_table='fund_repayment_plan'):
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
# 资金方的放款表
sql_pay = '''
select fc.fund_name '资金方',
pay.product_no '产品编号',
date(pay.trans_time) '订单时间',
date(pay.loan_time) '放款时间',
pay.loan_amount '合同放款金额',
pay.stages '贷款总期数',
'FALSE' AS '是否退款',
'FALSE' AS '是否转分期后订单',
'TRUE' AS '是否资金方直投',
plan.current_stage_no '当期期数',
date(plan.deadline) '每期应还款日',
plan.principle+plan.fee_amount '每期应还金额',
plan.principle '每期应还本金',
plan.fee_amount '每期应还服务费',
if(pay.stages=1,plan.fee_amount,0) '每期应还服务费-QG承担'
from qunaer_new.pay_detail pay
join %s plan on pay.product_no = plan.product_no
join qunaer_new.fund_corp fc on pay.fund_code = fc.fund_code
where trans_time >='%s' and trans_time < '%s' and pay.fund_code !=1 AND pay.status=1
''' % (plan_table,start_time, end_time)
# # 属于资金方的退款
# sql_refund = '''
# select fc.fund_name '资金方',
# refund.product_no '产品编号',
# date(pay.trans_time) '订单时间',
# date(pay.loan_time) '放款时间',
# refund.refund_amount '合同放款金额',
# pay.stages '贷款总期数',
# 'TRUE' AS '是否退款',
# DATE(refund.refund_time) AS '退款时间',
# MONTH(refund.refund_time) AS '退款月份',
# 'FALSE' AS '是否转分期后订单',
# 'TRUE' AS '是否资金方直投'
# from qunaer_new.refund_detail refund
# JOIN qunaer_new.fund_pay_detail pay on refund.product_no = pay.product_no and refund.fund_code = pay.fund_code
# JOIN qunaer_new.fund_corp fc on refund.fund_code = fc.fund_code
# WHERE refund_time >='%s' and refund_time < '%s' AND refund.flow_id is NULL
# ''' % (start_time, end_time)
# 读取sql语句，2分钟左右
df_pay = pd.read_sql(sql_pay, engine_qunaer)
# 含有 flow_id 的退款，在还款表中体现。
# df_refund = pd.read_sql(sql_refund, engine_qunaer)
# 合并退款记录和放款记录
# df = pd.concat([df_pay, df_refund], ignore_index=True)
# df = df.fillna(0)
df_pay.ix[df_pay[[u'产品编号']].duplicated(), u'合同放款金额'] = 0
return df_pay[[u'资金方',u'产品编号',u'订单时间',u'放款时间',u'合同放款金额',u'贷款总期数',u'是否退款',u'是否转分期后订单',
u'是否资金方直投',u'当期期数',u'每期应还款日',u'每期应还金额',u'每期应还本金',u'每期应还服务费',u'每期应还服务费-QG承担']]
#保理的放款表，注意，非债权转让后的放款表
def user_pay(year,month,plan_table='repayment_plan_2017'):
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
# 用户的放款表
sql_pay = '''
select '保理' AS '资金方',
pay.product_no '产品编号',
date(pay.trans_time) '订单时间',
date(pay.loan_time) '放款时间',
pay.loan_amount '合同放款金额',
pay.stages '贷款总期数',
'FALSE' AS '是否退款',
if(pay.is_ptf = 0,'FALSE','TRUE') '是否转分期后订单',
'FALSE' AS '是否资金方直投',
plan.current_stage_no '当期期数',
date(plan.deadline) '每期应还款日',
plan.principle+plan.fee_amount '每期应还金额',
plan.principle '每期应还本金',
plan.fee_amount '每期应还服务费',
0 '每期应还服务费-QG承担'
from qunaer_new.pay_detail pay
join %s plan on pay.product_no = plan.product_no
where pay.fund_code = 1 and trans_time >='%s' and trans_time < '%s'
''' % (plan_table,start_time, end_time)
# 属于保理的退款
sql_refund = '''
select '保理' AS '资金方',
refund.product_no '产品编号',
date(pay.trans_time) '订单时间',
date(pay.loan_time) '放款时间',
refund.refund_amount '合同放款金额',
pay.stages '贷款总期数',
'TRUE' AS '是否退款',
date(refund.refund_time) '退款时间',
MONTH(refund.refund_time) '退款月份',
refund.refund_principle '退款本金',
refund.refund_fee_amount '退款服务费',
refund.refund_due_amount '退款罚息',
if(pay.is_ptf = 0,'FALSE','TRUE') '是否转分期后订单'
from qunaer_new.refund_detail refund
JOIN qunaer_new.pay_detail pay on refund.product_no = pay.product_no and refund.fund_code = pay.fund_code
WHERE pay.fund_code = 1 and refund_time >='%s' and refund_time < '%s' AND refund.flow_id is NULL
''' % (start_time, end_time)
# 读取sql语句，2分钟左右
df_pay = pd.read_sql(sql_pay, engine_qunaer)
# 如果期数 > 1 的，放款为0
df_pay.ix[df_pay[[u'产品编号']].duplicated(),u'合同放款金额'] = 0
# 含有 flow_id 的退款，在还款表中体现。
df_refund = pd.read_sql(sql_refund, engine_qunaer)
# 合并退款记录和放款记录
df = pd.concat([df_pay, df_refund], ignore_index=True)
df = df.fillna(0)
return df[[u'资金方',u'产品编号',u'订单时间',u'放款时间',u'合同放款金额',u'贷款总期数',u'是否退款',u'退款时间',u'退款月份',u'退款本金',u'退款服务费',u'退款罚息',u'是否转分期后订单',
u'是否资金方直投',u'当期期数',u'每期应还款日',u'每期应还金额',u'每期应还本金',u'每期应还服务费',u'每期应还服务费-QG承担']]
if __name__ == '__main__':
years = [2017]
months = range(10,11)
for year, month in product(years, months):
df_baoli=baoli_pay(year,month,plan_table='repayment_plan_2017')
df_fund=fund_pay(year,month,plan_table='fund_repayment_plan')
df_user=user_pay(year,month,plan_table='repayment_plan_2017')
writer=pd.ExcelWriter(file_path+file_name%(year,month))
# 后续就没有内保了，只有债转后的内保。
if len(df_user) > 0:
df_user.to_excel(writer,sheet_name=u'保理放款表',encoding='UTF-8',index=None)
df_fund.to_excel(writer,sheet_name=u'资金方放款表',encoding='UTF-8',index=None)
df_baoli.to_excel(writer, sheet_name=u'债转后的保理放款表', encoding='UTF-8', index=None)
writer.save()
writer.close()
print '-----------------------main done---------------------------------------'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/去哪儿白条/给审计/白条-去哪儿-核算-还资金方表-最终版.py 0 → 100644
View file @ be6fb1dd
# -- coding: UTF-8 --
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
import multiprocessing as mtp
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
file_path = u'E:/量化派/去哪儿/常规出账/'
engine_qunaer = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/qunaer_new?charset=utf8',
echo=False).connect()
def pay(year, month,fund_plan='fund_repayment_plan'):
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
sql_pay = '''
SELECT
IF(t1.account_id = 0,'',t6.account_name) AS '账户',
t5.fund_name as '资金方',
t1.product_no as '产品编号',
date(t2.interest_time) as '放款日期',
t2.loan_amount as '放款金额',
t2.loan_amount AS '本金债权',
t2.stages as '贷款总期数',
t3.current_stage_no as '应还款期数',
date(t3.deadline) as '应还资金方日期',
t3.principle as '应还本金',
t3.interest as '应还利息',
date(t1.repay_time) as '实还资金方日期',
t1.repay_amount AS '还款金额',
t1.repay_principle as '实还本金',
t1.repay_interest as '实还利息',
t1.qg_interest as 'QG实际贴息金额',
t1.repay_fee_amount as '资金方服务费',
t1.repay_due_amount as '资金方逾期服务费',
t1.flow_id as '流水号',
case t1.type WHEN 4 THEN '正常还款' WHEN 5 THEN '提前结清' WHEN 6 THEN '提前还款' WHEN 7 THEN '退款' END AS '类型'
FROM
fund_repay_detail t1
join pay_detail t2 on t2.product_no = t1.product_no AND t2.fund_code != 1
join %s t3 on t1.product_no=t3.product_no and t1.fund_code=t3.fund_code AND t1.current_stage_no = t3.current_stage_no
join fund_corp t5 on t5.fund_code=t1.fund_code
LEFT JOIN qunaer_new.account t6 on t6.id=t1.account_id
WHERE
t1.repay_time >= '%s' AND t1.repay_time < '%s'
'''%(fund_plan,start_time,end_time)
df_sql_pay = pd.read_sql(sql_pay,engine_qunaer)
# 保存导出的结果表
df_sql_pay.to_excel(file_path + u'核算还资金方表_%s_%s.xlsx' % (year,month), encoding='UTF-8', index=False)
if __name__ == '__main__':
year,month = 2017,10
pay(year,month)
print '-----------------------main done---------------------------------------'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/普通白条/人工控制/人工控制-普通白条-直投还资金方表.py 0 → 100644
View file @ be6fb1dd
# -*- coding:utf-8 -*-
# Author: Perry_Zhu
import sys
import pandas as pd
from sqlalchemy import create_engine
import pyexcelerate
reload(sys)
sys.setdefaultencoding('utf8')
max_limit = 800000
# 注意修改数据源
engine_new_transaction = create_engine(
'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/new_transaction?charset=utf8',
echo=True)
path = u'E:/审计出表/11月份开始使用表数据/11月份白条出表/'
query_loan = """
SELECT tt.order_no 产品编号,tt.term_no 期数,tt.fund_name 资金方,max(tt.loan_paid_at) 放款时间,
max(tt.repaid_at)实还时间,tt.flow_id 流水号,tt.total_amount 账单金额 FROM (
SELECT
t4.order_no,
r.term_no,
t2.fund_name,
DATE(t4.loan_paid_at) loan_paid_at,
date(r.repaid_at) repaid_at,
r.flow_id ,
b.total_amount
FROM
baitiao_audit.baitiao_order t4
JOIN baitiao_audit.fund_corp t2 ON t4.funding_corp_id = t2.id AND t4.is_active = 1 AND t4.funding_corp_id = 5
JOIN new_transaction.bt_funding_repayment_record r ON r.ref_id = t4.ref_id
JOIN baitiao_audit.account_type t3 ON r.principal_account = t3.account_type
JOIN baitiao_audit.baitiao_finance_record b ON r.finance_record_id = b.batch_no AND b.type = 1
WHERE
t4.loan_paid_at>='%s'
AND t4.loan_paid_at<'%s'
UNION all
SELECT
t4.order_no,
r.term_no,
t2.fund_name,
DATE(t4.train_cancel_at) loan_paid_at,
date(r.repaid_at) repaid_at,
r.flow_id ,
b.total_amount
FROM
baitiao_audit.baitiao_order t4
JOIN baitiao_audit.fund_corp t2 ON t4.funding_corp_id = t2.id AND t4.is_active = -2 AND t4.funding_corp_id = 5
JOIN new_transaction.bt_funding_repayment_record r ON r.ref_id = t4.ref_id
JOIN baitiao_audit.account_type t3 ON r.principal_account = t3.account_type
JOIN baitiao_audit.baitiao_finance_record b ON r.finance_record_id = b.batch_no AND b.type = 1
WHERE
t4.loan_paid_at>='%s'
AND t4.loan_paid_at<'%s'
)tt
GROUP BY 1,2
"""
query_repay_principal = """
SELECT
r.order_no 产品编号,
r.term_no 期数,
sum(r.principal) 实还本金
FROM
bt_funding_repayment_record r
WHERE
r.repaid_at >='%s'
AND r.repaid_at <'%s'
AND r.refund_status!=3
and r.order_no is not null
GROUP BY 1,2
"""
query_repay_interest = """
select tt.order_no 产品编号,tt.term_no 期数,sum(tt.interest) 实还利息 from(
SELECT
r.order_no,
r.term_no,
r.interest
FROM
bt_funding_repayment_record r
WHERE
r.refund_status!=3
and r.order_no is not null
AND r.repaid_at >='%s'
AND r.repaid_at <'%s'
UNION ALL
SELECT
r.order_no,
r.term_no,
r.interest
FROM
bt_funding_repayment_record r
WHERE
r.refund_status=3
AND r.interest_account!=3
and r.order_no is not null
AND r.repaid_at >='%s'
AND r.repaid_at <'%s'
)tt
GROUP BY 1,2
"""
# query_repay_discount = """
# SELECT
# r.order_no 产品编号,
# r.term_no 期数,
# sum(r.discount) 实还贴息
# FROM
# bt_funding_repayment_record r
# WHERE
# r.refund_status!=3
# and r.order_no is not null
# AND r.repaid_at >='%s'
# AND r.repaid_at <'%s'
# GROUP BY 1,2
# """
query_repay_discount = """
SELECT
r.order_no 产品编号,
r.term_no 期数,
sum(r.discount) 实还贴息
FROM
bt_funding_repayment_record r
WHERE
r.refund_status!=3
and r.order_no is not null
AND r.discount_repaid_at >='%s'
AND r.discount_repaid_at <'%s'
GROUP BY 1,2
"""
start_time = '2017-08-01'
end_time = '2017-11-01'
def tj():
df_loan_all = pd.read_sql(query_loan % (start_time, end_time, start_time, end_time), engine_new_transaction)
df_loan_all[u'产品编号'] = df_loan_all[u'产品编号'].astype(str)
df_loan_all[u'期数'] = df_loan_all[u'期数'].astype(int)
df_p = pd.read_sql(query_repay_principal % (start_time, end_time), engine_new_transaction)
df_p[u'产品编号'] = df_p[u'产品编号'].astype(str)
df_p[u'期数'] = df_p[u'期数'].astype(int)
print df_p[u'实还本金'].sum()
# 实还本金
df_i = pd.read_sql(query_repay_interest % (start_time, end_time, start_time, end_time), engine_new_transaction)
df_i[u'产品编号'] = df_i[u'产品编号'].astype(str)
df_i[u'期数'] = df_i[u'期数'].astype(int)
# 实还利息
df_i = df_i[[u'产品编号', u'期数', u'实还利息']]
df_d = pd.read_sql(query_repay_discount % (start_time, end_time), engine_new_transaction)
df_d[u'产品编号'] = df_d[u'产品编号'].astype(str)
df_d[u'期数'] = df_d[u'期数'].astype(int)
# 实还贴息
df_d = df_d[[u'产品编号', u'期数', u'实还贴息']]
df = pd.concat([df_p, df_i, df_d], ignore_index=True, axis=0)
df.fillna(0, inplace=True)
# df_t1 = df.groupby([u'产品编号', u'期数'])[u'实还本金'].sum().reset_index()
# df_t2 = df.groupby([u'产品编号', u'期数'])[u'实还利息'].sum().reset_index()
# df_t3 = df.groupby([u'产品编号', u'期数'])[u'实还贴息'].sum().reset_index()
# df_1 = pd.merge(df_t1, df_t2, on=[u'产品编号', u'期数'], how='outer')
# df_t = pd.merge(df_1, df_t3, on=[u'产品编号', u'期数'], how='outer')
df_t = df.groupby([u'产品编号', u'期数'])[u'实还本金', u'实还利息', u'实还贴息'].agg('sum').reset_index()
df = pd.merge(df_loan_all, df_t, on=[u'产品编号', u'期数'])
df.loc[df[u'流水号'].duplicated(), [u'账单金额']] = 0
df[u'实还总额'] = df[u'实还本金'] + df[u'实还利息']
df = df[[u'资金方', u'产品编号', u'放款时间', u'期数', u'实还时间', u'实还总额', u'实还本金', u'实还利息', u'流水号', u'账单金额']]
# df.to_excel(path + u'直投白条还资金方明细-2017-10.xlsx', index=None)
df.to_excel(path + u'人工控制-直投白条还资金方（按实还时间）-2017-10.xlsx', index=None)
all_wb = pyexcelerate.Workbook()
for i in xrange(0, len(df), max_limit):
temp = df[i:i + max_limit]
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'人工控制-普通白条-直投还资金方表(2017-10).xlsx')
tj()
现金贷&去哪儿&白条--在用代码维护/普通白条/人工控制/人工控制-普通白条-直投退资金方表.py 0 → 100644
View file @ be6fb1dd
# -*- coding:utf-8 -*-
# Author: Perry_Zhu
import sys
import pandas as pd
from sqlalchemy import create_engine
import pyexcelerate
max_limit = 800000
reload(sys)
sys.setdefaultencoding('utf8')
# 注意修改数据源
engine_new_transaction = create_engine(
'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/new_transaction?charset=utf8',
echo=True)
path = u'E:/审计出表/11月份开始使用表数据/11月份白条出表/'
query_repay_principal = """
SELECT
t2.fund_name 资金方,
r.order_no 产品编号,
r.term_no,
t4.loan_paid_at 放款时间,
t4.funding_loan_amount 放款金额,
DATE(r.refund_time) 客户退单日,
DATE(r.repaid_at) 退还给资金方日,
sum(r.principal) 退款本金,
r.flow_id 流水号,
b.total_amount 账单金额
FROM
bt_funding_repayment_record r
JOIN baitiao_audit.fund_corp t2 ON r.funding_code = t2.id
JOIN baitiao_audit.account_type t3 ON r.principal_account = t3.account_type AND r.refund_status=3
JOIN baitiao_audit.baitiao_order t4 ON r.ref_id=t4.ref_id
JOIN baitiao_audit.baitiao_finance_record b ON r.finance_record_id=b.batch_no AND b.type=1
WHERE r.repaid_at >='%s'
AND r.repaid_at <'%s'
GROUP BY 2,3
"""
query_repay_interest = """
SELECT
r.order_no 产品编号,
r.term_no,
sum(ifnull(r.interest,0)) 退款利息
FROM
bt_funding_repayment_record r
WHERE
r.refund_status=3
AND r.interest_account=3
AND r.repaid_at >='%s'
AND r.repaid_at <'%s'
GROUP BY 1,2
"""
# query_repay_discount = """
# SELECT
# r.order_no 产品编号,
# r.term_no,
# sum(ifnull(r.discount,0)) 退款贴息
# FROM
# bt_funding_repayment_record r
# WHERE
# r.refund_status=3
# AND r.repaid_at >='%s'
# AND r.repaid_at <'%s'
# GROUP BY 1,2
# """
query_repay_discount = """
SELECT
r.order_no 产品编号,
r.term_no,
sum(ifnull(r.discount,0)) 退款贴息
FROM
bt_funding_repayment_record r
WHERE
r.refund_status=3
AND r.discount_repaid_at >='%s'
AND r.discount_repaid_at <'%s'
GROUP BY 1,2
"""
start_time = '2017-08-01'
end_time = '2017-11-01'
def tj():
df_p = pd.read_sql(query_repay_principal % (start_time, end_time), engine_new_transaction)
df_i = pd.read_sql(query_repay_interest % (start_time, end_time), engine_new_transaction)
df_d = pd.read_sql(query_repay_discount % (start_time, end_time), engine_new_transaction)
df_p[u'产品编号'] = df_p[u'产品编号'].astype(str)
df_p.term_no = df_p.term_no.astype(int)
df_i[u'产品编号'] = df_i[u'产品编号'].astype(str)
df_i.term_no = df_i.term_no.astype(int)
df_d[u'产品编号'] = df_d[u'产品编号'].astype(str)
df_d.term_no = df_d.term_no.astype(int)
df_t = pd.merge(df_p, df_i, on=[u'产品编号', 'term_no'], how='left')
df = pd.merge(df_t, df_d, on=[u'产品编号', 'term_no'], how='left')
df.loc[df[u'流水号'].duplicated(), [u'账单金额']] = 0
df.fillna(0, inplace=True)
df[u'退款总额'] = df[u'退款本金'] + df[u'退款利息']
df = df[
[u'资金方', u'产品编号', u'放款时间', u'放款金额', u'客户退单日', u'退还给资金方日', u'退款总额', u'退款本金', u'退款利息', u'流水号', u'账单金额']]
# df.to_excel(path + u'直投白条退资金方款明细-2017-10.xlsx', index=None)
# df.to_excel(path + u'人工控制-直投白条退资金方款明细-2017-10.xlsx', index=None)
all_wb = pyexcelerate.Workbook()
for i in xrange(0, len(df), max_limit):
temp = df[i:i + max_limit]
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'人工控制-普通白条-直投退资金方表(2017-10).xlsx')
tj()
现金贷&去哪儿&白条--在用代码维护/普通白条/白条-每月到期本金利息.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
#
# 表名称：
# 白条-每月到期本金利息
#表字段：
# 资金方 放款年 放款月 到期年 到期月 客户应还本金 客户应还利息
# 数据库：
# user_bt_repayment_plan，baitiao_order，fund_corp
# 注意事项：
# 出来的表为汇总表
# 笑脸直投应还本金会有140的差距，是由于下单后使用红包金额导致。查询代码：
# SELECT SUM(funding_loan_amount),SUM(real_loan_amount) FROM baitiao_order WHERE funding_corp_id=5 AND funding_loan_amount!=real_loan_amount;
file_path = u'E:/审计出表/非去哪儿白条-放款表（1月份-6月份）/'
engine_bt = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/audit?charset=utf8',
echo=False).connect()
def bt_principle_interest():
sql_bt = '''
SELECT
fc.fund_name 资金方,
YEAR (bo.loan_paid_at) 放款年,
MONTH (bo.loan_paid_at) 放款月,
YEAR (plan.deadline) 到期年,
MONTH (plan.deadline) 到期月,
sum(plan.principle) 客户应还本金,
0 客户应还利息
FROM
new_transaction.user_bt_repayment_plan plan
JOIN baitiao_audit.baitiao_order bo ON bo.ref_id = plan.ref_id
JOIN baitiao_audit.fund_corp fc ON fc.id = bo.funding_corp_id
WHERE
bo.is_active IN (1)
GROUP BY
1,2,3,4,5;
'''
sql_bt_refund = '''
SELECT
fc.fund_name 资金方,
YEAR (bo.loan_paid_at) 放款年,
MONTH (bo.loan_paid_at) 放款月,
YEAR (plan.deadline) 到期年,
MONTH (plan.deadline) 到期月,
sum(plan.principle) 客户应还本金,
0 客户应还利息
FROM
new_transaction.user_bt_repayment_plan plan
JOIN baitiao_audit.baitiao_order bo ON bo.ref_id = plan.ref_id
JOIN baitiao_audit.fund_corp fc ON fc.id = bo.funding_corp_id
WHERE
bo.is_active IN (-2) AND bo.funding_corp_id in (1,5) AND bo.train_cancel_at<'2017-11-01'
GROUP BY
1,2,3,4,5;
'''
sql_cash_bt = '''
select
fc.fund_name 资金方,
YEAR (t1.loan_paid_at) 放款年,
MONTH (t1.loan_paid_at) 放款月,
YEAR (t1.loan_paid_at) 到期年,
MONTH (t1.loan_paid_at) 到期月,
sum(t1.real_loan_amount) 客户应还本金,
0 客户应还利息
from baitiao_audit.baitiao_order t1
join baitiao_audit.fund_corp fc ON fc.id = t1.funding_corp_id
where t1.baitiao_type=1
GROUP BY 1,2,3,4,5;
'''
df_bt = pd.read_sql(sql_bt,engine_bt)
df_bt_refund = pd.read_sql(sql_bt_refund,engine_bt)
df_cash = pd.read_sql(sql_cash_bt,engine_bt)
df = pd.concat([df_bt,df_bt_refund,df_cash],ignore_index=True)
df.fillna(0,inplace=True)
result = df.groupby([u'资金方',u'放款年',u'放款月',u'到期年',u'到期月'])[u'客户应还本金',u'客户应还利息'].sum().reset_index()
result.to_excel(file_path+u'非去哪儿白条每月到期本金利息_2017_10.xlsx',index=False)
# df.to_excel(file_path+u'非去哪儿白条每月到期本金利息明细版本-V7.xlsx',index=False)
if __name__ == '__main__':
print '--------main begin'
bt_principle_interest()
print '________main done'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/普通白条/白条在贷明细&汇总（所有月份可用）.py 0 → 100644
View file @ be6fb1dd
# coding: utf-8
# Author: Perry_Zhu
"""
说明：由于白条现金支付不存在在贷所以在做白条在贷的时候可以忽略白条现金支付
本代码用于出截止2017-09-30和截止2017-10-31的在贷
"""
import datetime
import sys
import pandas as pd
import pyexcelerate as pe
from sqlalchemy import create_engine
reload(sys)
sys.setdefaultencoding('utf8')
engine_new_transaction = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/baitiao_audit?charset=utf8', echo=True)
end_point = '2017-11-01'
watch_point = datetime.date(2017, 10, 31)
out_file_path = u'E:/数据汇总/白条/在贷/'
query_loan = """
SELECT
tt.order_no,tt.term_no,
min(tt.deadline)deadline,SUM(tt.principle)principle
FROM(
SELECT
plan.order_no,
plan.term_no,
date(plan.deadline)deadline,
sum(plan.principle)principle
FROM baitiao_order bo
JOIN new_transaction.user_bt_repayment_plan plan ON bo.ref_id=plan.ref_id
WHERE
bo.loan_paid_at >= '2015-01-01'
AND bo.loan_paid_at < '%s'
AND bo.is_active =1
and bo.baitiao_type=0
AND bo.funding_corp_id = 1
GROUP BY 1,2
UNION ALL
SELECT
plan.order_no,
plan.term_no,
date(plan.deadline)deadline,
sum(plan.principle)principle
FROM
baitiao_order bo
JOIN new_transaction.user_bt_repayment_plan plan ON bo.ref_id=plan.ref_id and bo.baitiao_type=0
WHERE
bo.train_cancel_at >= '2015-01-01'
AND bo.train_cancel_at < '%s'
AND bo.is_active =- 2
AND bo.funding_corp_id = 1
GROUP BY 1,2
)tt
GROUP BY 1,2
"""
loan_info = """
SELECT tt.order_no,SUM(tt.real_loan_amount) 订单金额,max(tt.contract_term)合同期数,
tt.merchant_name 商户,min(tt.loan_paid_at)放款时间
FROM(
SELECT
o.order_no,
SUM(o.real_loan_amount) real_loan_amount,
o.contract_term,
m.merchant_name,
date(o.loan_paid_at) loan_paid_at
FROM
baitiao_order o
JOIN merchant m ON o.merchantId = m.merchant_id AND o.is_active=1 AND o.funding_corp_id = 1 and o.baitiao_type=0
GROUP BY 1
UNION ALL
SELECT
o.order_no,
SUM(o.train_cancel_at) real_loan_amount,
o.contract_term,
m.merchant_name,
date(o.train_cancel_at) loan_paid_at
FROM
baitiao_order o
JOIN merchant m ON o.merchantId = m.merchant_id AND o.is_active=1 AND o.funding_corp_id = -2 and o.baitiao_type=0
GROUP BY 1
)tt
GROUP BY 1
"""
repay_online = """
SELECT
t2.order_no,
t2.term_no,
SUM(ifnull(t1.principle, 0) - IFNULL(t1.mitigate_principle, 0)) paid_principle
FROM
new_transaction.baitiao_repay_plan_repay_record_ref t1
JOIN new_transaction.repay_record_online t3 ON t1.repay_channel in(1,2,3,4,5,6,7,8,9,10,11,12,22,23,24) AND t3.id = t1.record_id
AND t3.bill_time >= '2015-01-01' AND t3.bill_time < '%s'
and t1.id not in(14164355,14164357,14164359,13818155,13818157,13818159,13533131,13996965,13996971,13996967,
13996957,13996959,13996961,13996963,13996973,13996975,13996977,16774675,14471253)
JOIN new_transaction.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN baitiao_order t5 ON t2.ref_id = t5.ref_id AND t5.funding_corp_id =1
GROUP BY 1,2
"""
repay_ali = """
SELECT
t2.order_no,
t2.term_no,
SUM(ifnull(t1.principle,0)-ifnull(t1.mitigate_principle,0)) paid_principle
FROM
new_transaction.baitiao_repay_plan_repay_record_ref t1
JOIN new_transaction.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN new_transaction.offline_alipay_record t3 ON t1.repay_channel = 13 AND t3.id = t1.record_id AND t3.is_ref=1
AND t3.transfer_time>='2015-01-01' AND t3.transfer_time<'%s'
JOIN baitiao_order t5 ON t2.ref_id = t5.ref_id AND t5.funding_corp_id = 1
GROUP BY 1,2
"""
repay_bank = """
SELECT
t2.order_no,
t2.term_no,
SUM(ifnull(t1.principle,0)-ifnull(t1.mitigate_principle,0)) paid_principle
FROM
new_transaction.baitiao_repay_plan_repay_record_ref t1
JOIN new_transaction.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN new_transaction.offline_bank_repay_record t3 ON t1.repay_channel IN (14, 15, 16) AND t3.id = t1.record_id
AND t3.transfer_time>='2015-01-01' AND t3.transfer_time<'%s'
JOIN baitiao_order t5 ON t2.ref_id = t5.ref_id
GROUP BY 1,2
"""
df_info = pd.read_sql(loan_info, engine_new_transaction)
df_loan_all = pd.read_sql(query_loan % (end_point, end_point), engine_new_transaction)
df_online = pd.read_sql(repay_online % end_point, engine_new_transaction)
df_ali = pd.read_sql(repay_ali % end_point, engine_new_transaction)
df_bank = pd.read_sql(repay_bank % end_point, engine_new_transaction)
df_repay = pd.concat([df_online, df_ali, df_bank], axis=0, ignore_index=True)
df_repay.dropna(axis=0, inplace=True)
df_loan_all.order_no = df_loan_all.order_no.astype(str)
df_loan_all.term_no = df_loan_all.term_no.astype(int)
df_info.order_no = df_info.order_no.astype(str)
df_repay.order_no = df_repay.order_no.astype(str)
df_repay.term_no = df_repay.term_no.astype(int)
#去除无效放款
df_loan = df_loan_all.loc[df_loan_all['principle'] > 0]
df_repay = df_repay.groupby(['order_no', 'term_no'])['paid_principle'].agg(['sum']).reset_index().rename(columns={'sum': 'paid_principle'})
df_out = pd.merge(df_loan, df_repay, on=['order_no', 'term_no'], how='left')
df_out['deadline'] = pd.to_datetime(df_out.deadline)
df_out['flag'] = (watch_point-df_out['deadline']).dt.days
df_out.fillna(0, inplace=True)
df_out['zaidai'] = df_out['principle'] - df_out['paid_principle']
#用于将在贷为负值的置0，建议使用 df_out = df_out.loc[df_out['zaidai']>0]
df_out.loc[df_out['order_no'].isin(
['trainmall1483695024282', 'trainmall1484301600672', 'trainmall1486362269554', 'trainmall1487920296689',
'trainmall1491536200793', 'trainmall1483695024282',
'trainmall1484301600672', 'trainmall1486362269554', 'grabtrainmall1484650405321', 'trainmall1495785791995',
'trainmall1499935282194', 'trainmall16008368458050561', 'trainmall16008408858634241',
'trainmall16112348780571649', 'trainmall16112552463312897']), 'zaidai'] = 0
df_out = df_out.loc[df_out['zaidai']>0]
df_out.loc[(df_out['flag']<=0),'0'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=1) &(df_out['flag']<=30),'01-30'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=31) &(df_out['flag']<=60),'31-60'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=61) &(df_out['flag']<=90),'61-90'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=91) &(df_out['flag']<=120),'91-120'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=121) &(df_out['flag']<=150),'121-150'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=151) &(df_out['flag']<=180),'151-180'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=181) &(df_out['flag']<=360),'181-360'] = df_out['zaidai']
df_out.loc[(df_out['flag']>=361),'361+'] = df_out['zaidai']
#在贷按order_no展开明细
df = df_out.groupby(['order_no'])['0','01-30','31-60','61-90','91-120','121-150','151-180','181-360','361+'].sum().reset_index()
df.fillna(0,inplace=True)
df_loan.order_no = df_loan.order_no.astype(str)
df = pd.merge(df, df_info, on='order_no', how='left')
df.rename(columns={'order_no': u'订单号'}, inplace=True)
df = df[[u'商户', u'订单号', u'订单金额', u'合同期数', u'放款时间','0','01-30','31-60','61-90','91-120','121-150','151-180','181-360','361+']]
data_list = df.values.tolist()
data_list.insert(0, df.columns.tolist())
wb = pe.Workbook()
wb.new_sheet(u'明细', data=data_list)
wb.save(out_file_path + u'非去哪儿白条2017-10-31在贷明细.xlsx')
#按月汇总在贷
df = df_out.groupby(['order_no','deadline'])['0','01-30','31-60','61-90','91-120','121-150','151-180','181-360','361+'].sum().reset_index()
df.fillna(0,inplace=True)
df_loan.order_no = df_loan.order_no.astype(str)
df = pd.merge(df, df_info, on='order_no', how='left',copy=False)
df.rename(columns={'order_no': u'订单号','deadline':u'应还时间'}, inplace=True)
df[u'放款年'] = pd.to_datetime(df[u'放款时间']).dt.year
df[u'放款月'] = pd.to_datetime(df[u'放款时间']).dt.month
df[u'应还年'] = df[u'应还时间'].dt.year
df[u'应还月'] = df[u'应还时间'].dt.month
df_result = df.groupby([u'放款年',u'放款月',u'合同期数',u'应还年',u'应还月'])['0','01-30','31-60','61-90','91-120','121-150','151-180','181-360','361+'].sum().reset_index()
df_result.to_excel(out_file_path + u'白条在贷汇总_%s.xlsx' % end_point, index=None)
现金贷&去哪儿&白条--在用代码维护/普通白条/给审计/给审计-白条-放款表（1-7月份）.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
#
# 表名称：
# 白条-非去哪儿-放款表（1-6月份）
#表字段：
# 资金方 产品编号 放款日期 总期数 白条商家 放款金额 本金债权
# 数据库：
# baitiao_order，fund_corp，merchant
# 注意事项：
# baitiao_order.is_active = 1、资金方统一为“保理”
#
file_path = u'E:/审计出表/非去哪儿白条-放款表（1月份-6月份）/'
engine_bt = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/audit?charset=utf8',
echo=False).connect()
def baitiao_pay(year, month):
#year,month = 2017,8
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
#收款表，获取数据
sql_bt_pay = '''
SELECT
bo.order_no as '产品编号',
date(bo.loan_paid_at) as '放款日期',
bo.contract_term as '总期数',
mc.merchant_name as '商户名称',
bo.real_loan_amount as '放款金额',
bo.contract_loan_amount as '本金债权'
FROM
all_back_0831.baitiao_order bo
JOIN baitiao_audit.merchant mc ON mc.merchant_id = bo.merchantId
WHERE
bo.loan_paid_at >= '%s'
AND bo.loan_paid_at < '%s'
AND bo.is_active = 1
''' %(start_time,end_time)
sql_bt_refund = '''
SELECT
bo.order_no as '产品编号',
date(bo.loan_paid_at) as '放款日期',
bo.contract_term as '总期数',
mc.merchant_name as '商户名称',
bo.real_loan_amount as '放款金额',
bo.contract_loan_amount as '本金债权'
FROM
all_back_0831.baitiao_order bo
JOIN baitiao_audit.merchant mc ON mc.merchant_id = bo.merchantId
WHERE
bo.train_cancel_at >= '%s'
AND bo.train_cancel_at < '%s'
AND bo.is_active = -2
''' %(start_time,end_time)
df_bt_pay = pd.read_sql(sql_bt_pay,engine_bt)
df_bt_refund = pd.read_sql(sql_bt_refund,engine_bt)
df = pd.concat([df_bt_pay,df_bt_refund])
print('----%s-%s'%(year,month))
print(sum(df[u'放款金额']))
df[u'资金方'] = u'保理'
df.to_excel(file_path+u'白条放款表_%s_%s_.xlsx' %(year,month),index=False)
#df.to_csv(file_path + u'白条放款表_%s_%s_0925补录.csv' %(year,month), encoding='gb18030', index=False)
if __name__ == '__main__':
# 还款明细
years = [2017]
months = range(8,9,1)
for year, month in product(years, months):
print('-----%s--%s') %(year,month)
baitiao_pay(year, month)
print '-----------------------main done---------------------------------------'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/普通白条/给审计/给审计-白条-放款表（8月份开始）.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
#
# 表名称：
# 白条-非去哪儿-放款表（1-6月份）
#表字段：
# 资金方 产品编号 放款日期 总期数 白条商家 放款金额 本金债权
# 数据库：
# baitiao_order，fund_corp，merchant
# 注意事项：
# baitiao_order.is_active = 1、资金方统一为“保理”
# 8月份分为内保和直投模式，内保模式可以直接用,直投模式直接统计放款即可
file_path = u'E:/审计出表/非去哪儿白条-放款表（1月份-6月份）/'
engine_bt = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8',
echo=False).connect()
def baitiao_pay(year, month):
#year,month = 2017,8
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
#收款表，获取数据
sql_bt_neibao_pay = '''
SELECT
bo.order_no as '产品编号',
date(bo.loan_paid_at) as '放款日期',
bo.contract_term as '总期数',
mc.merchant_name as '白条商家',
bo.real_loan_amount as '放款金额',
bo.contract_loan_amount as '本金债权'
FROM
all_back_0930.baitiao_order bo
JOIN baitiao_audit.merchant mc ON mc.merchant_id = bo.merchantId
WHERE
bo.loan_paid_at >= '%s'
AND bo.loan_paid_at < '%s'
AND bo.is_active = 1
AND bo.funding_corp_id = 1
''' %(start_time,end_time)
sql_bt_neibao_refund = '''
SELECT
bo.order_no as '产品编号',
date(bo.train_cancel_at) as '放款日期',
bo.contract_term as '总期数',
mc.merchant_name as '白条商家',
bo.real_loan_amount as '放款金额',
bo.contract_loan_amount as '本金债权'
FROM
all_back_0930.baitiao_order bo
JOIN baitiao_audit.merchant mc ON mc.merchant_id = bo.merchantId
WHERE
bo.train_cancel_at >= '%s'
AND bo.train_cancel_at < '%s'
AND bo.is_active = -2
AND bo.funding_corp_id = 1
''' %(start_time,end_time)
df_bt_pay = pd.read_sql(sql_bt_neibao_pay,engine_bt)
df_bt_refund = pd.read_sql(sql_bt_neibao_refund,engine_bt)
df = pd.concat([df_bt_pay,df_bt_refund])
# 收款表，获取数据
sql_bt_zhitou_pay = '''
SELECT
bo.order_no as '产品编号',
date(bo.loan_paid_at) as '放款日期',
bo.contract_term as '总期数',
mc.merchant_name as '白条商家',
bo.funding_loan_amount as '放款金额',
bo.contract_loan_amount as '本金债权',
bfr.serial_number as '流水号-直投'
FROM
all_back_0930.baitiao_order bo
JOIN baitiao_audit.merchant mc ON mc.merchant_id = bo.merchantId
join all_back_0930.baitiao_finance_record bfr on bfr.batch_no = bo.batch_no_id
WHERE
bo.loan_paid_at >= '%s'
AND bo.loan_paid_at < '%s'
AND bo.is_active = 1
AND bo.funding_corp_id = 5
''' % (start_time, end_time)
df_bt_zhitou_pay = pd.read_sql(sql_bt_zhitou_pay, engine_bt)
print('----%s-%s'%(year,month))
print(sum(df[u'放款金额']))
df[u'资金方'] = u'保理'
df_bt_zhitou_pay[u'资金方'] = u'笑脸'
writer = pd.ExcelWriter(file_path+u'白条放款表_%s_%s_.xlsx' %(year,month))
df.to_excel(writer,sheet_name = u'保理放款表',index=False)
df_bt_zhitou_pay.to_excel(writer,sheet_name = u'直投放款表',index=False)
writer.save()
#df.to_csv(file_path + u'白条放款表_%s_%s_0925补录.csv' %(year,month), encoding='gb18030', index=False)
if __name__ == '__main__':
# 还款明细
years = [2017]
months = range(9,10,1)
for year, month in product(years, months):
print('-----%s--%s') %(year,month)
baitiao_pay(year, month)
print '-----------------------main done---------------------------------------'
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/普通白条/给审计/给审计-白条-还款表（1-6月份）.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
import pyexcelerate
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
max_limit = 800000
#
# 表名称：
# 白条-非去哪儿-放款表（1-6月份）
# 表字段
# 资金方 产品编号 放款期数 当前期数 白条商家 实还金额 本金 利息 服务费 罚息 其他收益 收款账户 渠道流水号
# 数据库：
# baitiao_repay_plan_repay_record_ref，user_bt_repayment_plan，baitiao_order，merchant，repay_channel
# 注意事项：
# baitiao_order.is_active = 1
#其他：
# 数据分为三部分：支付宝还款（offline_alipay_record）、银行还款（offline_bank_repay_record）、线上还款（repay_record_online）
# 还款渠道的划分根据baitiao_repay_plan_repay_record_ref中repay_channel：
# 13（支付宝线下）[14,15,16]（银行还款）小于13（线上还款）
# （本、利、服、罚）需要：t1.principle-t1.mitigate_principle 本金
#
file_path = u'E:/审计出表/非去哪儿白条-客户实还表-1023版/'
# 注意修改数据源
engine_all_back_0831 = create_engine(
'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/?charset=utf8',
echo=False)
read_merchant_sql = '''SELECT merchant_id,merchant_name FROM all_back_0831.merchant'''
df_merchant = pd.read_sql(read_merchant_sql, con=engine_all_back_0831)
df_merchant['merchant_id'] = df_merchant['merchant_id'].astype(int)
read_repay_sql = '''
SELECT id,`approach_name` FROM new_transaction.`repay_channel`
'''
df_approach = pd.read_sql(read_repay_sql, engine_all_back_0831)
df_approach['id'] = df_approach['id'].astype(int)
read_fund_sql = '''
SELECT id,fund_name FROM all_back_0831.`fund_corp`
'''
df_fund = pd.read_sql(read_fund_sql, engine_all_back_0831)
df_fund['id'] = df_fund['id'].astype(int)
def hk_hz(year, month):
# 支付宝还款
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
sql_alipay = """
SELECT t5.funding_corp_id,t5.order_no 产品编号,t6.merchant_name,t5.contract_term 放款期数,t2.term_no 当前期数,date(t3.transfer_time) 客户实还时间,
t1.ref_amount 总额, t1.principle-t1.mitigate_principle 本金, t1.interest-t1.mitigate_interest 利息, t1.service_fee-t1.mitigate_service_fee 服务费,
t1.red_package_fee 红包减免,
t1.punish-t1.mitigate_collection_relief 逾期罚款收益,
t1.remain_income 其他收益,
t7.approach_name,
t3.business_flow 流水号
FROM all_back_0831.baitiao_repay_plan_repay_record_ref t1
JOIN all_back_0831.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN all_back_0831.offline_alipay_record t3 ON t1.repay_channel =13 AND t3.id = t1.record_id
JOIN all_back_0831.baitiao_order t5 ON t2.ref_id=t5.ref_id
JOIN all_back_0831.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.`repay_channel` t7 ON t1.repay_channel = t7.id
where t3.transfer_time >='%s' and t3.transfer_time<'%s'
""" % (start_time, end_time)
df_alipay = pd.read_sql(sql=sql_alipay, con=engine_all_back_0831)
# 银行还款
sql_bank = """
SELECT t5.funding_corp_id,t5.order_no 产品编号,t6.merchant_name,t5.contract_term 放款期数, t2.term_no 当前期数,date(t3.transfer_time) 客户实还时间,
t1.ref_amount 总额, t1.principle-t1.mitigate_principle 本金, t1.interest-t1.mitigate_interest 利息, t1.service_fee-t1.mitigate_service_fee 服务费,
t1.punish-t1.mitigate_collection_relief 逾期罚款收益,
t1.remain_income 其他收益,
t7.approach_name,
t3.serial_number 流水号
FROM all_back_0831.baitiao_repay_plan_repay_record_ref t1
JOIN all_back_0831.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN all_back_0831.offline_bank_repay_record t3 ON t1.repay_channel in (14,15,16) AND t3.id = t1.record_id
JOIN all_back_0831.baitiao_order t5 ON t2.ref_id=t5.ref_id
JOIN all_back_0831.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.`repay_channel` t7 ON t1.repay_channel = t7.id
where t3.transfer_time>= '%s' and t3.transfer_time<'%s'
""" % (start_time, end_time)
df_bank = pd.read_sql(sql=sql_bank, con=engine_all_back_0831)
# 线上还款
sql_online = """
SELECT t5.funding_corp_id,t5.order_no 产品编号,t6.merchant_name,t5.contract_term 放款期数,t2.term_no 当前期数,date(t3.bill_time) 客户实还时间,
t1.ref_amount 总额, t1.principle-t1.mitigate_principle 本金, t1.interest-t1.mitigate_interest 利息, t1.service_fee-t1.mitigate_service_fee 服务费,
t1.punish-t1.mitigate_collection_relief 逾期罚款收益,
t1.remain_income 其他收益,
t7.approach_name,
t3.order_id 流水号
FROM all_back_0831.baitiao_repay_plan_repay_record_ref t1
JOIN all_back_0831.user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN all_back_0831.repay_record_online t3 ON t1.repay_channel < 13 AND t3.id = t1.record_id
JOIN all_back_0831.baitiao_order t5 ON t2.ref_id=t5.ref_id
JOIN all_back_0831.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.`repay_channel` t7 ON t1.repay_channel = t7.id
where t3.bill_time>='%s' and t3.bill_time<'%s'
""" % (start_time, end_time)
df_online = pd.read_sql(sql=sql_online, con=engine_all_back_0831)
df = pd.concat([df_alipay, df_bank, df_online], ignore_index=True)
df[u'资金方'] = u'保理'
# df.sort_values(['r_year', 'r_month', 'merchant_name', 'approach_name', u'总额', u'本金', u'利息', u'服务费', u'逾期罚款收益', u'其他收益',u'总减免',u'红包减免', u'减免本金', u'减免利息', u'减免服务费', u'减免罚息'], inplace=True)
df = df[
[u'资金方', u'产品编号', u'放款期数',u'当前期数', 'merchant_name', 'approach_name', u'客户实还时间',u'总额', u'本金', u'利息', u'服务费', u'逾期罚款收益',
u'其他收益', u'流水号']]
df.rename(columns={'merchant_name': '白条商家', 'approach_name': '收款账户'}, inplace=True)
# columns = ['年', '月', '商户', '收款账户', '总额', '本金', '利息', '服务费', '红包减免金额', '逾期罚款收益', '其他收益']
print(sum(df[u'总额']))
# df.to_excel(file_path+u'白条还款明细表_%s_%s.xlsx' %(year,month), index=None)
all_wb = pyexcelerate.Workbook()
for i in xrange(0, len(df), max_limit):
temp = df[i:i + max_limit]
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(file_path + u'白条还款明细表_%s_%s.xlsx' %(year,month))
df.to_csv(file_path + u'白条还款明细表_%s_%s.csv' %(year,month), index=None, encoding='gb18030')
if __name__ == '__main__':
# 还款明细
years = [2017]
months = range(1, 7, 1)
for year, month in product(years, months):
print('-----%s--%s') % (year, month)
hk_hz(year, month)
print '-----------------------main done---------------------------------------'
现金贷&去哪儿&白条--在用代码维护/普通白条/给审计/给审计-白条-还款表（7月份开始）.py 0 → 100644
View file @ be6fb1dd
# -*- coding:utf-8 -*-
#Author: Perry_Zhu
import datetime
import multiprocessing as mtp
import sys
from itertools import product
import pandas as pd
from dateutil.relativedelta import relativedelta
from sqlalchemy import create_engine
import pyexcelerate
reload(sys)
sys.setdefaultencoding('utf8')
file_path = u'E:/审计出表/非去哪儿白条-客户实还表-1023版/'
# 注意修改数据源
max_limit = 800000
engine_all_back_0930 = create_engine(
'mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.3.201:3306/all_back_0930?charset=utf8',
echo=True)
read_merchant_sql = '''SELECT merchant_id,merchant_name FROM all_back_0930.merchant'''
df_merchant = pd.read_sql(read_merchant_sql, con=engine_all_back_0930)
df_merchant['merchant_id'] = df_merchant['merchant_id'].astype(int)
read_repay_sql = '''
SELECT id,`approach_name` FROM all_back_0930.`repay_channel`
'''
df_approach = pd.read_sql(read_repay_sql, engine_all_back_0930)
df_approach['id'] = df_approach['id'].astype(int)
read_fund_sql = '''
SELECT id,fund_name FROM all_back_0930.`fund_corp`
'''
df_fund = pd.read_sql(read_fund_sql, engine_all_back_0930)
df_fund['id'] = df_fund['id'].astype(int)
'''
白条还款汇总
'''
################################################
# 收客户还款汇总
def hk_hz(year,month):
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
sql_alipay = """
SELECT
t8.fund_name 资金方,
t5.order_no 产品编号,
t5.contract_term 放款期数,
t2.term_no 当前期数,
t6.merchant_name 白条商家,
date(t3.transfer_time) 客户实还时间,
ifnull(t1.ref_amount,0) 总额,
ifnull(t1.principle,0) - ifnull(t1.mitigate_principle,0)本金,
ifnull(t1.interest,0)-ifnull(t1.mitigate_interest,0)利息,
ifnull(t1.service_fee,0) - ifnull(t1.mitigate_service_fee,0) 服务费,
ifnull(t1.punish,0) - ifnull(t1.mitigate_collection_relief,0) 逾期罚款收益,
ifnull(t1.remain_income,0) 其他收益,
t7.approach_name 收款账户,
t3.business_flow 流水号
FROM
baitiao_repay_plan_repay_record_ref t1
JOIN user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN offline_alipay_record t3 ON t1.repay_channel = 13 AND t3.id = t1.record_id AND t3.is_ref=1 AND t3.enable=1
JOIN all_back_0930.baitiao_order t5 ON t2.ref_id = t5.ref_id
JOIN all_back_0930.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.repay_channel t7 ON t1.repay_channel = t7.id
JOIN all_back_0930.fund_corp t8 ON t5.funding_corp_id=t8.id
where t3.transfer_time>='%s' and t3.transfer_time <'%s'
""" %(start_time,end_time)
df_alipay = pd.read_sql(sql=sql_alipay, con=engine_all_back_0930)
sql_bank = """
SELECT
t8.fund_name 资金方,
t5.order_no 产品编号,
t5.contract_term 放款期数,
t2.term_no 当前期数,
t6.merchant_name 白条商家,
date(t3.transfer_time) 客户实还时间,
ifnull(t1.ref_amount,0) 总额,
ifnull(t1.principle,0) - ifnull(t1.mitigate_principle,0) 本金,
ifnull(t1.interest,0) - ifnull(t1.mitigate_interest,0) 利息,
ifnull(t1.service_fee,0) - ifnull(t1.mitigate_service_fee,0) 服务费,
ifnull(t1.punish,0) - ifnull(t1.mitigate_collection_relief,0) 逾期罚款收益,
ifnull(t1.remain_income,0) 其他收益,
t7.approach_name 收款账户,
t3.serial_number 流水号
FROM
baitiao_repay_plan_repay_record_ref t1
JOIN user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN offline_bank_repay_record t3 ON t1.repay_channel IN (14, 15, 16) AND t3.id = t1.record_id
JOIN all_back_0930.baitiao_order t5 ON t2.ref_id = t5.ref_id
JOIN all_back_0930.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.repay_channel t7 ON t1.repay_channel = t7.id
JOIN all_back_0930.fund_corp t8 ON t5.funding_corp_id=t8.id
where t3.transfer_time>='%s' and t3.transfer_time <'%s'
"""%(start_time,end_time)
df_bank = pd.read_sql(sql=sql_bank, con=engine_all_back_0930)
sql_online = """
SELECT
t8.fund_name 资金方,
t5.order_no 产品编号,
t5.contract_term 放款期数,
t2.term_no 当前期数,
t6.merchant_name 白条商家,
date(t3.bill_time) 客户实还时间,
ifnull(t1.ref_amount,0) 总额,
ifnull(t1.principle,0) - ifnull(t1.mitigate_principle,0) 本金,
ifnull(t1.interest,0) - ifnull(t1.mitigate_interest,0) 利息,
ifnull(t1.service_fee,0) - ifnull(t1.mitigate_service_fee,0) 服务费,
ifnull(t1.punish,0) - ifnull(t1.mitigate_collection_relief,0) 逾期罚款收益,
ifnull(t1.remain_income,0) 其他收益,
t7.approach_name 收款账户,
t3.order_id 流水号
FROM
baitiao_repay_plan_repay_record_ref t1
JOIN repay_record_online t3 ON t1.repay_channel in(1,2,3,4,5,6,7,8,9,10,11,12,22,23,24) AND t3.id = t1.record_id
JOIN user_bt_repayment_plan t2 ON t2.id = t1.plan_id
JOIN all_back_0930.baitiao_order t5 ON t2.ref_id = t5.ref_id
JOIN all_back_0930.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.repay_channel t7 ON t1.repay_channel = t7.id
JOIN all_back_0930.fund_corp t8 ON t5.funding_corp_id=t8.id
WHERE t3.bill_time is not NULL
and t3.bill_time>='%s' and t3.bill_time<'%s'
"""%(start_time,end_time)
df_online = pd.read_sql(sql=sql_online, con=engine_all_back_0930)
sql_cash_online = """
SELECT
t8.fund_name 资金方,
t5.order_no 产品编号,
t5.contract_term 放款期数,
t5.contract_term 当前期数,
t6.merchant_name 白条商家,
date(t3.bill_time) 客户实还时间,
ifnull(t1.ref_amount,0) 总额,
ifnull(t5.real_loan_amount,0) 本金,
0.0 利息,
0.0 服务费,
0.0 逾期罚款收益,
0.0 其他收益,
'白条现金支付' 收款账户,
0 流水号
FROM
(SELECT repay_id,record_id,repay_channel,SUM(ifnull(ref_amount,0))ref_amount FROM
baitiao_cash_record_ref WHERE repay_channel !=13 GROUP BY 1) t1
JOIN baitiao_cash_repay t2 ON t2.id = t1.repay_id
JOIN repay_record_online t3 ON t3.id = t1.record_id
JOIN all_back_0930.baitiao_order t5 ON t2.order_no = t5.order_no AND t2.real_order_amount=t5.real_loan_amount
JOIN all_back_0930.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN all_back_0930.fund_corp t8 ON t5.funding_corp_id=t8.id
WHERE t3.bill_time is not NULL
and t3.bill_time>='%s' and t3.bill_time<'%s'
"""%(start_time,end_time)
sql_cash_alipay = """
SELECT
t8.fund_name 资金方,
t5.order_no 产品编号,
t5.contract_term 放款期数,
t5.contract_term 当前期数,
t6.merchant_name 白条商家,
date(t3.transfer_time) 客户实还时间,
ifnull(t1.ref_amount,0) 总额,
ifnull(t5.real_loan_amount,0) 本金,
0.0 利息,
0.0 服务费,
0.0 逾期罚款收益,
0.0 其他收益,
'支付宝线下还款' 收款账户,
t3.business_flow 流水号
FROM
(SELECT repay_id,record_id,repay_channel,SUM(ifnull(ref_amount,0))ref_amount
FROM
baitiao_cash_record_ref
GROUP BY 1) t1
JOIN baitiao_cash_repay t2 ON t2.id = t1.repay_id
JOIN offline_alipay_record t3 ON t3.id = t1.record_id AND t1.repay_channel=13
JOIN all_back_0930.baitiao_order t5 ON t2.order_no = t5.order_no AND t2.real_order_amount=t5.real_loan_amount
JOIN all_back_0930.merchant t6 ON t6.`merchant_id` = t5.`merchantId`
JOIN new_transaction.repay_channel t7 ON t1.repay_channel = t7.id
JOIN all_back_0930.fund_corp t8 ON t5.funding_corp_id=t8.id
where t3.transfer_time>='%s' and t3.transfer_time <'%s'
"""%(start_time,end_time)
df_cash_onlie = pd.read_sql(sql=sql_cash_online, con=engine_all_back_0930)
df_cash_alipay = pd.read_sql(sql=sql_cash_alipay, con=engine_all_back_0930)
df = pd.concat([df_alipay, df_bank, df_online, df_cash_onlie, df_cash_alipay], ignore_index=True)
df = df[
[u'资金方',u'产品编号',u'放款期数',u'当前期数',u'白条商家',u'客户实还时间', u'总额', u'本金', u'利息', u'服务费', u'逾期罚款收益',
u'其他收益',u'收款账户',u'流水号']]
# all_wb = pyexcelerate.Workbook()
# for i in xrange(0, len(df), max_limit):
# temp = df[i:i + max_limit]
# 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(file_path + u'白条还款明细表_%s_%s.xlsx' % (year, month))
df.to_csv(file_path + u'白条还款汇总表_%s_%s.csv' %(year,month), index=None,encoding='gb18030')
if __name__ == '__main__':
# 还款汇总
years = [2017]
months = [7,8,9]
for year, month in product(years, months):
print('-----%s--%s') % (year, month)
hk_hz(year, month)
\ No newline at end of file
现金贷&去哪儿&白条--在用代码维护/现金贷/人工控制/人工控制-现金贷-客户实还表-加速测试版.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
import pyexcelerate
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
max_limit = 800000
import os
path = u'E:/审计出表/11月份开始使用表数据/11月份现金贷出表/'
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.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',' ')
os.system(exe_sql)
try:
df = pd.read_csv(path_file, sep='\t',encoding='utf-8')
except:
return pd.DataFrame()
return df
'''
# 注意事项：非常重要 2017年4月份客户实还表中Loan_id = 52532760 的地方要特别地注意一下 ，1月份中loan_id = 39722219 也需要特别注意
'''
# 这5个资金方的还款计划来自于用户还款计划
# group by 是由于还资金方计划中有0.01的情况
sql_repay_frr_2 = '''
SELECT
urp.ref_id,
urp.term_no 'term_no',
date(urp.deadline) 'deadline',
sum(urp.principle) 'principle',
sum(urp.interest) 'interest'
FROM new_transaction.user_repayment_plan urp
JOIN audit.loan_manifest lm ON lm.ref_id = urp.ref_id
WHERE lm.loan_paid_at>='%s' AND loan_paid_at<'%s'
AND urp.fund_code IN (210,270,310,320,410,430)
GROUP BY 1,2
'''
# test_shiyao.funding_repayment_plan中还资金方计划的数据是最全的
# group by 是由于还资金方计划中有0.01的情况
sql_repay_frr_3 = '''
SELECT
frp.ref_id,
frp.term_no 'term_no',
date(frp.deadline) 'deadline',
sum(frp.principle) 'principle',
sum(frp.interest) 'interest'
FROM audit.funding_repayment_plan frp
JOIN audit.loan_manifest lm ON lm.ref_id = frp.ref_id
WHERE lm.loan_paid_at>='%s' AND loan_paid_at<'%s'
AND lm.funding_code NOT IN (210,270,310,320,410,430)
GROUP BY 1,2
'''
# 在线还款部分
read_detail_online_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) 'loan_paid_at',t1.ref_id,t1.fund_code funding_code,t1.term_no 'term_no',date(t6.bill_time) 'bill_time',t2.ref_amount 'ref_amount',
t2.principle-t2.mitigate_principle 'repay_prin',t2.interest-t2.mitigate_interest 'repay_intes',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) 'repay_fee',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) 'repay_due',
t2.remain_income 'remain',t2.repay_channel,t6.order_id AS 'flow_no',t6.amount 'bank_amount',t1.service_fee 'service_fee',t1.required_repayment 'required_repayment'
FROM new_transaction.xjd_repay_plan_repay_record_ref t2
JOIN new_transaction.user_repayment_plan t1 ON t1.id=t2.plan_id
JOIN new_transaction.repay_record_online t6 ON t2.record_id=t6.id AND t2.repay_channel = t6.pay_approach
JOIN audit.loan_manifest lm ON lm.ref_id = t1.ref_id
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
# 支付宝线下还款
read_detail_alipay_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) 'loan_paid_at',t1.ref_id,t1.fund_code funding_code,t1.term_no 'term_no',date(t6.transfer_time) 'bill_time',t2.ref_amount 'ref_amount',
t2.principle-t2.mitigate_principle 'repay_prin',t2.interest-t2.mitigate_interest 'repay_intes',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) 'repay_fee',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) 'repay_due',
t2.remain_income 'remain',t2.repay_channel,t6.business_flow 'flow_no',t6.income 'bank_amount',t1.service_fee 'service_fee',t1.required_repayment 'required_repayment'
FROM new_transaction.xjd_repay_plan_repay_record_ref t2
JOIN new_transaction.`user_repayment_plan` t1 ON t1.id=t2.plan_id
JOIN new_transaction.`offline_alipay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel = 13
JOIN audit.loan_manifest lm ON lm.ref_id = t1.ref_id
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
# 银行线下还款部分，无对应流水号
read_detail_bank_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) 'loan_paid_at',t1.ref_id,t1.fund_code funding_code,t1.term_no 'term_no',date(t6.transfer_time) 'bill_time',t2.ref_amount 'ref_amount',
t2.principle-t2.mitigate_principle 'repay_prin',t2.interest-t2.mitigate_interest 'repay_intes',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) 'repay_fee',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) 'repay_due',
t2.remain_income 'remain',t2.repay_channel,t6.transfer_amount 'bank_amount',t1.service_fee 'service_fee',t1.required_repayment 'required_repayment'
FROM new_transaction.xjd_repay_plan_repay_record_ref t2
JOIN new_transaction.`user_repayment_plan` t1 ON t1.id=t2.plan_id
JOIN audit.loan_manifest lm ON lm.ref_id = t1.ref_id
JOIN new_transaction.`offline_bank_repay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel IN (14,15,16)
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
sql_fund_name = '''
select funding_code,name '资金方'
from basic.funding_corp
'''
df_fund_name = pd.read_sql(sql_fund_name,engine_xjd)
sql_repay_channel = '''
select id 'repay_channel',approach_name '还款渠道'
from new_transaction.repay_channel
'''
df_approach_name = pd.read_sql(sql_repay_channel,engine_xjd)
# 获取还款数据
def handle_hk(year, month):
# year, month = 2017, 1
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
# 获取全部还款计划
# df_repay_frr_1 = pd.read_sql(sql_repay_frr_1 % (start_time, end_time), con=engine_xjd)
df_repay_frr_2 = faster_sql_reader(sql_repay_frr_2 % (start_time, end_time))
df_repay_frr_3 = faster_sql_reader(sql_repay_frr_3 % (start_time, end_time))
df_repay_frr = pd.concat([df_repay_frr_2, df_repay_frr_3])
df_repay_frr.rename(columns={'term_no': u'应还期数', 'deadline': u'应还资金方时间', 'principle': u'应还资金方本金', 'interest': u'应还资金方利息'},
inplace=True)
df_repay_frr = df_repay_frr.drop_duplicates([u'ref_id', u'应还期数', u'应还资金方时间', u'应还资金方本金', u'应还资金方利息']).dropna()
df_repay_frr['ref_id'] = df_repay_frr['ref_id'].astype('int64')
df_repay_frr[u'应还期数'] = df_repay_frr[u'应还期数'].astype('int64')
# 获取全部实还信息
df_online_detail = faster_sql_reader(read_detail_online_sql % (start_time, end_time))
df_alipay_detail = faster_sql_reader(read_detail_alipay_sql % (start_time, end_time))
df_bank_detail = faster_sql_reader(read_detail_bank_sql % (start_time, end_time))
df = pd.concat([df_online_detail, df_alipay_detail, df_bank_detail], axis=0)
df.rename(columns={'loan_paid_at': u'放款时间', 'term_no': u'应还期数', 'bill_time': u'实还时间', 'ref_amount': u'实还总额', \
'repay_prin': u'实还本金', 'repay_intes': u'实还利息', 'repay_fee': u'实还服务费', 'repay_due': u'实还罚息', \
'remain': u'其他收益', 'flow_no': u'流水号', 'bank_amount': u'账单实还金额', 'service_fee': u'应收服务费',
'required_repayment': u'应还总额'}, inplace=True)
df[u'应还期数'] = df[u'应还期数'].astype('int64')
df['ref_id'] = df['ref_id'].astype('int64')
# 还款和实还进行合并
df = pd.merge(df, df_repay_frr, on=['ref_id', u'应还期数'], how='left')
df.loc[df[u'流水号'].duplicated(), u'账单实还金额'] = 0
df = pd.merge(df,df_fund_name,on='funding_code',how='left')
df = pd.merge(df,df_approach_name,on='repay_channel',how='left')
if len(df) > 0:
df[u'唯一编号'] = df['loan_id'].astype('str') + df[u'应还期数'].fillna(0).astype('int').astype('str')
df[u'实还总额-账单实还总额'] = df[u'实还总额'].fillna(0) - df[u'账单实还金额'].fillna(0)
df[u'应还资金方本息-客户实还本息'] = df[u'应还资金方本金'].fillna(0) + df[u'应还资金方利息'].fillna(0) - df[u'实还本金'].fillna(0) - df[
u'实还利息'].fillna(0)
df[u'应收服务费-实还服务费'] = df[u'应收服务费'] - df[u'实还服务费']
df = df.drop([u'ref_id'], axis=1)
df = df.fillna(0)
columns = [u'放款时间', u'唯一编号', u'资金方', 'loan_id', u'实还时间', u'实还总额', u'应还期数', u'实还本金', u'实还利息', u'实还服务费',
u'实还罚息', u'其他收益', u'流水号', u'还款渠道', u'账单实还金额', u'应还资金方时间', u'应还资金方本金', u'应还资金方利息',
u'应收服务费', u'实还总额-账单实还总额', u'应还资金方本息-客户实还本息', u'应收服务费-实还服务费']
print(u'客户实还本息:' + str(sum(df[u'实还本金']) + sum(df[u'实还利息'])) + u' 应还资金方本金:' + str(
sum(df[u'应还资金方本金'])) + u' 应还资金方利息' + str(sum(df[u'应还资金方利息'])))
# if len(df) > max_limit:
# for i in xrange(0, len(df), max_limit):
# df[i:i + max_limit].to_excel(os.path.join(path, u'人工控制-现金贷-客户实还表-(%s-%02d)-%d.xlsx' % (
# year, month, i / max_limit + 1)), index=None, columns=columns)
# else:
# df.to_excel(path + u'人工控制-现金贷-客户实还表-(%d-%d).xlsx' % (year, month), index=None, columns=columns)
all_wb = pyexcelerate.Workbook()
for i in xrange(0, len(df), max_limit):
temp = df[i:i + max_limit][columns]
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))
if __name__ == '__main__':
year = [2017]
month = range(10, 11, 1)
for year, month in product(year, month):
print '____%d__%d' % (year, month)
handle_hk(year, month)
现金贷&去哪儿&白条--在用代码维护/现金贷/人工控制/人工控制-现金贷-客户实还表.py 0 → 100644
View file @ be6fb1dd
# -*- encoding: utf8 -*-
import sys
import datetime
import pandas as pd
from sqlalchemy import create_engine
from dateutil.relativedelta import relativedelta
from itertools import product
reload(sys)
sys.setdefaultencoding("utf-8")
pd.options.mode.chained_assignment = None
max_limit = 800000
import os
path = u'E:/审计出表/人工控制/现金贷-还款表-1010版本/'
engine_xjd = create_engine('mysql+mysqldb://internal_r:ArbNgtvlJzZHXsEu@172.16.4.60:3306/?charset=utf8',
echo=False).connect()
'''
# 注意事项：非常重要 2017年4月份客户实还表中Loan_id = 52532760 的地方要特别地注意一下 ，1月份中loan_id = 39722219 也需要特别注意
'''
#这四个资金方的还款计划来自于实际还资金方表
#group by 是由于还资金方计划中有0.01的情况
# sql_repay_frr_1 = '''
# SELECT
# frr.ref_id,
# frr.term_no '应还期数',
# date(frr.deadline) '应还资金方时间',
# sum(frr.principle) '应还资金方本金',
# sum(frr.interest) '应还资金方利息'
# FROM
# audit.funding_repayment_record frr
# join audit.loan_manifest lm on lm.ref_id = frr.ref_id
# WHERE
# lm.loan_paid_at>='%s' and lm.loan_paid_at<'%s'
# and frr.funding_code in (380,420,290,330)
# GROUP BY 1,2
# '''
#这5个资金方的还款计划来自于用户还款计划
#group by 是由于还资金方计划中有0.01的情况
sql_repay_frr_2 = '''
select
urp.ref_id,
urp.term_no '应还期数',
date(urp.deadline) '应还资金方时间',
sum(urp.principle) '应还资金方本金',
sum(urp.interest) '应还资金方利息'
from all_back_0930.user_repayment_plan urp
join all_back_0930.loan_manifest lm on lm.ref_id = urp.ref_id
where lm.loan_paid_at>='%s' and loan_paid_at<'%s'
and urp.fund_code in (210,270,310,320,410,430)
GROUP BY 1,2
'''
#test_shiyao.funding_repayment_plan中还资金方计划的数据是最全的
#group by 是由于还资金方计划中有0.01的情况
sql_repay_frr_3 = '''
select
frp.ref_id,
frp.term_no '应还期数',
date(frp.deadline) '应还资金方时间',
sum(frp.principle) '应还资金方本金',
sum(frp.interest) '应还资金方利息'
from audit.funding_repayment_plan frp
join all_back_0930.loan_manifest lm on lm.ref_id = frp.ref_id
WHERE lm.loan_paid_at>='%s' and loan_paid_at<'%s'
and lm.funding_code not in (210,270,310,320,410,430)
GROUP BY 1,2
'''
# 在线还款部分
read_detail_online_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) '放款时间',t1.ref_id,fc.name '资金方',t1.term_no '应还期数',date(t6.bill_time) '实还时间',t2.ref_amount '实还总额',
t2.principle-t2.mitigate_principle '实还本金',t2.interest-t2.mitigate_interest '实还利息',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) '实还服务费',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) '实还罚息',
t2.remain_income '其他收益',rch.approach_name '还款渠道',t6.order_id AS '流水号',t6.amount '账单实还金额',t1.service_fee '应收服务费',t1.required_repayment '应还总额'
FROM all_back_0930.`xjd_repay_plan_repay_record_ref` t2
JOIN all_back_0930.`user_repayment_plan` t1 ON t1.id=t2.plan_id
JOIN all_back_0930.repay_record_online t6 ON t2.record_id=t6.id AND t2.repay_channel = t6.pay_approach
join basic.funding_corp fc on fc.funding_code = t1.fund_code
join all_back_0930.loan_manifest lm on lm.ref_id = t1.ref_id
# LEFT JOIN xjd_dunjiao_plan xdp ON xdp.loan_id = t1.real_loan_id
join new_transaction.repay_channel rch on rch.id = t2.repay_channel
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
# 支付宝线下还款
read_detail_alipay_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) '放款时间',t1.ref_id,fc.name '资金方',t1.term_no '应还期数',date(t6.transfer_time) '实还时间',t2.ref_amount '实还总额',
t2.principle-t2.mitigate_principle '实还本金',t2.interest-t2.mitigate_interest '实还利息',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) '实还服务费',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) '实还罚息',
t2.remain_income '其他收益',rch.approach_name '还款渠道',t6.business_flow '流水号',t6.income '账单实还金额',t1.service_fee '应收服务费',t1.required_repayment '应还总额'
FROM all_back_0930.`xjd_repay_plan_repay_record_ref` t2
JOIN all_back_0930.`user_repayment_plan` t1 ON t1.id=t2.plan_id
JOIN all_back_0930.`offline_alipay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel = 13
join basic.funding_corp fc on fc.funding_code = t1.fund_code
join all_back_0930.loan_manifest lm on lm.ref_id = t1.ref_id
join new_transaction.repay_channel rch on rch.id = t2.repay_channel
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
# 银行线下还款部分，无对应流水号
read_detail_bank_sql = '''
SELECT t1.real_loan_id loan_id,date(lm.loan_paid_at) '放款时间',t1.ref_id,fc.name '资金方',t1.term_no '应还期数',date(t6.transfer_time) '实还时间',t2.ref_amount '实还总额',
t2.principle-t2.mitigate_principle '实还本金',t2.interest-t2.mitigate_interest '实还利息',
ifnull(t2.`service_fee`-t2.mitigate_service_fee,0) '实还服务费',IFNULL(t2.`punish`-t2.mitigate_collection_relief, 0) '实还罚息',
t2.remain_income '其他收益',rch.approach_name '还款渠道',t6.transfer_amount '账单实还金额',t1.service_fee '应收服务费',t1.required_repayment '应还总额'
FROM all_back_0930.`xjd_repay_plan_repay_record_ref` t2
JOIN all_back_0930.`user_repayment_plan` t1 ON t1.id=t2.plan_id
join all_back_0930.loan_manifest lm on lm.ref_id = t1.ref_id
JOIN all_back_0930.`offline_bank_repay_record` t6 ON t2.record_id=t6.id AND t2.repay_channel IN (14,15,16)
join basic.funding_corp fc on fc.funding_code = t1.fund_code
join new_transaction.repay_channel rch on rch.id = t2.repay_channel
WHERE lm.loan_paid_at >= '%s' AND lm.loan_paid_at < '%s'
'''
#获取还款数据
def handle_hk(year, month):
#year, month = 2017, 1
start_time = datetime.datetime(year, month, 1, 0, 0, 0)
end_time = start_time + relativedelta(months=+1)
#获取全部还款计划
# df_repay_frr_1 = pd.read_sql(sql_repay_frr_1 % (start_time, end_time), con=engine_xjd)
df_repay_frr_2 = pd.read_sql(sql_repay_frr_2 % (start_time, end_time), con=engine_xjd)
df_repay_frr_3 = pd.read_sql(sql_repay_frr_3 % (start_time, end_time), con=engine_xjd)
df_repay_frr = pd.concat([df_repay_frr_2,df_repay_frr_3])
df_repay_frr = df_repay_frr.drop_duplicates([u'ref_id', u'应还期数', u'应还资金方时间', u'应还资金方本金', u'应还资金方利息']).dropna()
df_repay_frr['ref_id'] = df_repay_frr['ref_id'].astype('int64')
df_repay_frr[u'应还期数'] = df_repay_frr[u'应还期数'].astype('int64')
#获取全部实还信息
df_online_detail = pd.read_sql(read_detail_online_sql % (start_time, end_time), con=engine_xjd)
df_alipay_detail = pd.read_sql(read_detail_alipay_sql % (start_time, end_time), con=engine_xjd)
df_bank_detail = pd.read_sql(read_detail_bank_sql % (start_time, end_time), con=engine_xjd)
df = pd.concat([df_online_detail, df_alipay_detail, df_bank_detail], axis=0)
df[u'应还期数'] = df[u'应还期数'].astype('int64')
df['ref_id'] = df['ref_id'].astype('int64')
#还款和实还进行合并
df = pd.merge(df,df_repay_frr,on=['ref_id', u'应还期数'],how='left')
df.loc[df[u'流水号'].duplicated(), u'账单实还金额'] = 0
if len(df) > 0:
df[u'唯一编号'] = df['loan_id'].astype('str') + df[u'应还期数'].fillna(0).astype('int').astype('str')
df[u'实还总额-账单实还总额'] = df[u'实还总额'].fillna(0)-df[u'账单实还金额'].fillna(0)
df[u'应还资金方本息-客户实还本息'] = df[u'应还资金方本金'].fillna(0)+df[u'应还资金方利息'].fillna(0)-df[u'实还本金'].fillna(0)-df[u'实还利息'].fillna(0)
df[u'应收服务费-实还服务费'] = df[u'应收服务费'] - df[u'实还服务费']
df = df.drop([u'ref_id'], axis=1)
df = df.fillna(0)
columns = [u'放款时间',u'唯一编号',u'资金方','loan_id',u'实还时间',u'实还总额',u'应还期数',u'实还本金',u'实还利息',u'实还服务费',
u'实还罚息',u'其他收益',u'流水号',u'还款渠道',u'账单实还金额',u'应还资金方时间',u'应还资金方本金',u'应还资金方利息',
u'应收服务费',u'实还总额-账单实还总额',u'应还资金方本息-客户实还本息',u'应收服务费-实还服务费']
print(u'客户实还本息:' + str(sum(df[u'实还本金'])+sum(df[u'实还利息'])) + u' 应还资金方本金:' + str(
sum(df[u'应还资金方本金'])) + u' 应还资金方利息' + str(sum(df[u'应还资金方利息'])))
if len(df) > max_limit:
for i in xrange(0, len(df), max_limit):
df[i:i + max_limit].to_excel(os.path.join(path, u'人工控制-现金贷-客户实还表-(%s-%02d)-%d.xlsx' % (
year, month, i / max_limit + 1)), index=None, columns=columns)
else:
df.to_excel(path + u'人工控制-现金贷-客户实还表-(%d-%d).xlsx' % (year, month), index=None, columns=columns)
if __name__ == '__main__':
year = [2017]
month = range(9, 10, 1)
for year, month in product(year, month):
print '____%d__%d'%(year,month)
handle_hk(year, month)
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment