在大数据风控业务实践过程中，目前业内主要还是采用规则叠加的办法做策略，但是会遇到一些问题：
1.我们有10条规则，我上了前7条后，后面3条的绝对风险增益是多少？
2.我的规则之间应该做排序吗，最重要的放在前面？
3.规则重合了怎么办，我又想收风险又想保留较高批核怎么办？
4.我应用完所有的规则后，金额逾期风险能下降到什么水平？
因此，我们按规则的重要性（lift高且抓坏规模大）将规则封装，再按照循环做逐个碰撞，计算由先到后每个规则的绝对增益。

本篇代码的优点是：就能充分确保后面的规则不因为前面的规则而丧失效率，批核能全部用在刀刃上，规则不重合，计算不同口径Y指标下的风险情况，风险目标更清晰准确的预算。
本文是代码交流，里面的策略阈值都为虚构。

定义规则并应用

rules = [  
    ('1_rhzx_nnm_over_acct>11', lambda row: row['rhzx_nnm_over_acct'] > 11),  
    ('2_rhzx_nnm_over_cnt>=22', lambda row: row['rhzx_nnm_over_cnt'] >= 22), 
    ('3_multi_final_level>=33', lambda row: row['multi_final_level'] >=33),  
    # 可以添加更多规则...  
]  

定义一个计算金额逾期风险的函数

def cal_risk2(df2):  
    total_fm7_amt = df2['fpd_fm7_amt'].sum()  
    total_fz7_amt = df2['fpd_fz7_amt'].sum()  
    total_mob4m2fenmu_amt = df2['mob4m2fenmu_amt'].sum()  
    total_mob4m2fenzi_amt = df2['mob4m2fenzi_amt'].sum() 
    return total_fz7_amt / total_fm7_amt if total_fm7_amt > 0 else 0,total_mob4m2fenzi_amt / total_mob4m2fenmu_amt if total_mob4m2fenmu_amt > 0 else 0   

应用规则并计算边际风险压降效果

def cal_risk_lift(current_df):  
	results2=[]
	results2 = [  
		{  
			'Rule': 'Baseline',  
			'Touched_Count': len(current_df),  
			'Due_FPD7_Amt': round(float(current_df['fpd_fm7_amt'].sum()),2),  
			'FPD_Fz7_Amt': current_df['fpd_fz7_amt'].sum(), 
			'命中_$FPD7': current_df['fpd_fz7_amt'].sum()/ current_df['fpd_fm7_amt'].sum(),         
			'命中_$MOB4M2': current_df['mob4m2fenzi_amt'].sum()/ current_df['mob4m2fenmu_amt'].sum(),    
			'应用规则后_$FPD7': cal_risk2(current_df)[0],
			'应用规则后_$MOB4M2': cal_risk2(current_df)[1] 
		}  
	] 
	for i, (rule_name, rule_func) in enumerate(rules, start=1):  
		touched_loans = current_df[current_df.apply(rule_func, axis=1)]  
		touched_loan_ids = set(touched_loans['loan_id'].unique())  	
		# 计算被规则触碰的贷款数据的到期金额和逾期金额  
		new_fm7_amount = round(touched_loans['fpd_fm7_amt'].sum() ,2) 
		new_fz7_amount = touched_loans['fpd_fz7_amt'].sum()  
		new_mob4m2fm_amt = touched_loans['mob4m2fenmu_amt'].sum()  
		new_mob4m2fz_amt = touched_loans['mob4m2fenzi_amt'].sum()    
	
		# 计算剩余贷款的风险情况（在应用当前规则之后，以借据为唯一主键）  
		remaining_df = current_df[~current_df['loan_id'].isin(touched_loan_ids)]  
		new_df_risk = cal_risk2(remaining_df) if not remaining_df.empty else 0  
		# 记录结果  
		results2.append({  
			'Rule': rule_name,  
			'Touched_Count': len(touched_loan_ids),  
			'Due_FPD7_Amt': new_fm7_amount,  
			'FPD_Fz7_Amt': new_fz7_amount,  
			'命中_$FPD7': new_fz7_amount/new_fm7_amount, 
			'命中_$MOB4M2': new_mob4m2fz_amt/new_mob4m2fm_amt,### 展示纯新增命中
		# '命中_$MOB4M2': df['mob4m2fenzi_amt'].sum()/df['mob4m2fenmu_amt'].sum(),## 展示总命中
			'应用规则后_$FPD7': new_df_risk[0],
			'应用规则后_$MOB4M2': new_df_risk[1] 
		})  
		# 更新current_df以反映应用规则后的效果
		current_df = remaining_df  
	# 将结果转换为DataFrame  
	results_df = pd.DataFrame(results2)
	return results_df

于是我们可以按分组group来统计规则的累计lift了

data6.groupby(['xj_sxdurseg']).apply(cal_risk_lift)