记录操作记录
外部处理（1）
判断是否是订单场景
遍历文本，匹配异常关键字，匹配白名单，进行异常判断
风控系统
信息订单（创新业务订单）（5）
用户注册（4）
发送消息
根据场景id和需要评估的规则进行评估
根据场景、请求参数、以及配置和白名单等进行判断
bigdata_event_name：guardian_start_event
为空
是否需要风控
风险评估
师傅完工照、商品图片
需要
用户注册场景
数据集成-外部输入
判断消息tag
无风险
根据不同的分数计算规则：max、sum、avg、count等计算出最终的分数
是
kafka
wshifu_bigdata_collector_external_input
推单拉黑（2）
bigdata_env_name：当前env
循环调用阿里云检测接口
获取成功
处理风控结果
判断是否订单场景，且orderId不为空
bigdata_data_bus_topic
根据环境和eventName过滤
组装评估结果
否，参数即规则列表
不为空
师傅服务完工照（3）
组装用户信息和未处理的有风险的客户端集合
获取师傅发送的消息
设置评分为：0
guardian_check_complete_event
组装请求参数和请求url集合
打印log
bigdata_data_bus_topicenv_bigdata_guardian_group
判断是否是carrier的数据，如果是还需要补充师傅订单id和scene_id
非订单场景
根据不同的分数，组装通知上下文的检测异常信息
商品图片库（2）
内部员工账号标记（3）
不需要，白名单、场景关闭等
无异常
订单场景
guardian_start_event、guardian_start_event|expired
上下文
调用钉钉通知接口
内部处理（0）
根据检测结果分别对确定异常和疑似异常进行参数异常信息、分数以及等级进行组装
客户姓名、客户详细地址、物流单号、提货地址、备注、联系人姓名等文本异常以及其他异常
图片场景
图片异常
判断分数是否异常
通过分数和等级，筛选出分数异常的规则id集合
内外部通知
获取当前场景id需要评估的规则列表
wanshifu_bigdata_outer_topic
移除redis中订单规则引擎和订单场景缓存的数据
规则引擎
调用平台回调接口
保存规则检验详情
根据用户的信息和客户端进行匹配，判断是否有风险
bigdata_event_name：guardian_start_prepare_event
有异常
异常处理
评估结果不为空
build回调url
获取user_order_id
按照风控等级进行落库
风控准入
根据场景ID获取处理的通知方式
师傅端业务RocketMQ
保存风险异常信息到参数中
判断评估结果是否为空
处理通知
判断规则
异常订单（1）
guardian_check_event
标记账号风控note信息
有风险
订单
判断图片url集合为空
拉黑账号到下单黑名单
