并行生成
mysql该策略是否存在
业务事件BusinessEvent3
规则引擎执行
对应属性不存在于excel
List<VariateContext>关联变量上下文
获取特征变量依赖的动态变量
开始
并行
获取执行起点id
获取该数据源下全部事件
参数校验、前置操作
Thread 1
获取该数据源下的特征事件
risk:platform:data:source:bean:name:
portal原有接口返回敏感词命中情况
参数
内存
状态
1.数据源add - hive
0.hive数据源限流执行规则引擎
Redis
动态变量 4
规则3
MIS端策略上下线操作
redis更改策略状态为当前策略的状态
营销
0.原有流程正常，下线后更改配置【done】1.事件上线状态下，无法更改事件字段、动态变量【done】2.策略增减系列2.1 事件上线状态下，增加新策略，新策略状态为待运行，需手动启用【done】2.2 事件上线状态下，删除一个策略，正常运行【done】3.原有策略修改系列3.1 事件上线状态下，修改原有策略原有规则，原有策略状态保留，且能正常运行新策略3.2 事件上线状态下，修改原有策略新增规则，原有策略状态保留，且能正常运行新策略3.3 事件上线状态下，修改原有策略删除规则，原有策略状态保留，且能正常运行新策略
结束
计算敏感词得分
风控任务
原始字段
record
(成功)
参数完整性检查
uuid
config:{一级标签、二级标签}
token
step 3更改策略
3.插入新数据or更新时间
识别file中的二维码
否
context获取bean
得分是否触发阈值
规则引擎执行、处置执行
是
step 2更改动态变量字段
BuisnessEvent规则引擎
redis重设过期时间
根据tableName绑定对应的dataCode
2.数据源detail - hive
BusinessEventCode
将动态变量的配置保存到该事件Mysql、Redis中
策略状态是否为【上线】
2.更新过期时间
to_ucid
加密手机号
参数校验
业务事件
依赖1
更新对应记录status = 1
记录日志toCK
找到该事件对应数据源的特征事件
执行结果持久化到Mysql中
过滤出该特征变量使用到的动态变量
会话是否符合规则
获取redis中识别的文本信息
redis删除策略处置信息
执行策略并保存结果
将依赖与不依赖特征事件的业务事件分组
构建特征变量
发送至kafka数据源专用topic
生成内部唯一标识
conv_id
是否命中
策略上线or未上线执行流程
特征事件FeatureEvent
原有策略删除
kafka数据源records
tag是否为敏感图片缓存
特征变量的redis会记录依赖事件
错误信息
message
context不包含
计算update_time小于当前时间 - 过期天数的数据
删除对应记录redis
请求参数requestData（原始字段）eventSceneIdbusinessType
规则2
tag是否有二维码信息缓存
IM C2B经OCR+二维码会话流
生成特征（因子）
1-4补充参数
处理流程从datasource转ruleengine
BuisnessEventC规则引擎
（redis存在该记录）
策略相关配置记录到mysql中
二级缓存
SceduleTask-1
ES
拉取
获取
获取返回结果（只有一个业务事件）
更新风控任务请求体
mysql中写入或更新对应记录
获取名单变量
添加结果集
是否包含特殊字符
将可执行的变量并行执行
策略配置修改时广播通知所有机器清除缓存
发送该记录操作日志到doris中
策略启用规则
Thread 2
遍历ucid
（redis不存在该记录）
获取该数据源下所有上线事件的变量配置
根据variateCode+param的组合去重
???
更新redis城市字段
Doris-Strategy
Mysql
...
未命中风控
BuisnessEventD规则引擎
超出阈值结束任务
策略B
if（eventType = 0 && 该事件有映射特征）{ //生成特征 generateFeature();}if（eventType = 1）{ //规则引擎 ruleEngine();}
2.获取对应标签是否存在
不存在
BusinessEventCodeB
构建请求体
动态变量补充到RequestData中
索引字段
依赖特征事件的业务事件BusinessEvent1
返回
通过
List动态变量4
FeatureEvent特征生成
100条
根据图片URL在S3获取tag
实时特征变量
计算预计解封时间
计算变量间依赖关系，标记变量为可执行
是否所有变量都生成完毕
规则1
初始化该任务EventContext
Doris-Log
OCR接口获取图片中的文本信息
多个业务事件 BusinessEvent
创建策略bean
记录数据源基本信息
删除本地文件
熔断判断
MySQLIM封禁库
redis维护事件、策略、城市信息
更新redis中字段信息
图片tag是否位于缓存
List<RiskResult>
补充关联变量结果
HTTP场景
业务是否依赖特征事件
网关
构建变量
命中风控
特征生成GenerateFeature
策略A_规则配置及其执行结果
BusinessEventCodeD
事件是否已下线
生成dataCode
任务结束
处置异常
excel数据大小超出阈值
传参List<EventSceneId>
下线 or 待上线
根据tag查询Redis缓存
旧：
已存在数据源请直接使用
特征因子1
innerUuid
获取该事件数据源下所有事件
Thread 4
（若更改数据源后续将全部清空）
动态变量HTTP调两次的问题需要解决！！
分组执行风控任务，1.不依赖组并行执行2.执行特征事件3.依赖组并行执行
策略A_处置配置及其执行结果
Redis记录该tag为敏感图片
保存图片Url到本地
RiskResult
redis中删除该事件原有策略
SceduleTask-2
BusinessEvent 业务事件
构建动态变量
2.写入
事件组分类并判断事件依赖关系
IM会话流
构建失败
编排事件组
今日数据是否为零
获取结果集
redis删除事件、策略、城市信息
试运行
BuisnessEventA规则引擎
获取特征事件下所有动态变量
获取HTTP风控结果
每日12点定时任务
一个特征事件 FeatureEvent
更新敏感词【原始账号】
编排执行事件组
5.数据源detail - excel
风控请求
apollo中获取过期天数
HTTP动态变量2
IAM鉴权
Thread 3
1.C2B对话2.msy_type=2（图片会话）
动态变量字段及其配置明细
参数不符合规则
无策略异常
http接口
获取敏感字段，数据记录需要加密
2021.10.11 hive数据源 excel数据源添加
编排事件组执行顺序
step 1更改事件字段
策略配置
二维码信息补充流程
MySQL敏感词表【过滤特殊字符账号】
获取该图片二维码信息
特征记录
输出名单处置
栏板
特征因子2
串行
eventType = 0 && 该事件有映射特征
eventType = 0
与数据库中记录比较，更新较长时间作为解封时间
(成功) 下一步
3.返回
动态变量 1
写入Kafka
更新黑名单
phone
5获取城市字段
运行
portal接口调用OCR+敏感词命中情况
更新redis中动态变量配置
黑名单表是否包含过滤后的账号
FeatureEventCode
Redis中写入对应记录，设置过期时间
一级缓存
请求
BusinessEventCodeC
记录操作日志
图片是否符合规则
二级缓存有配置时读取二级缓存配置
IM
新：
修改Redis中配置
ES索引检查
修正MySQL中策略状态
清除缓存
记录/更新数据记录
获取Hive配置信息（阈值、限流）
更新配置
修改后状态
动态变量
risk:platform:rule:bean:status:
Redis锁封禁账号Ucid
基本参数校验（uuid，业务类型）
该策略是否已上线并且context是否包含
规则引擎
datasourceCode
get手机号
目标：策略运行中即可修改事件配置
保存每条数据的dataCode\\uuid
BusinessEventCodeA
BuisnessEvent3规则引擎
调用IM封禁接口
记录到缓存
tag是否有文本识别缓存
redis更改策略状态为预上线
是否超出阈值
获取该数据源处理的数据
Redis动态变量3
MIS端策略修改操作
from_ucid
长度翻倍
处置执行
我也有自己的查询需求！！
批量查询Mysql数据
BuisnessEvent2规则引擎
实时风控请求
MySQL黑名单操作记录表
串行改为并行
BuisnessEvent1规则引擎
4.数据源add - excel
MySQL敏感词表【原始账号】
记录该图片的文本信息到redis缓存
Hive
ucid
记录黑名单操作日志
策略A
mysql中获取
启动定时线程增加令牌
3.数据源edit - hive
默认值补充
判断该事件执行类别
策略赋予新的code
判断对应tableName的数据源是否存在
不通过
MySQL黑名单表
根据依赖关系依次并行生成变量
定时添加
动态变量 3
是否位于封禁名单中
判断是否超出阈值
策略A_id
特征计算
规则引擎RuleEngine
特征因子3
启用规则
同步
自定义时间封禁
BuisnessEvent4规则引擎
redis删除策略状态信息
是否lock成功
(失败) sleep(1)
3.更新时间
过程省略.....
记录到缓存过期时间 1天
特征因子
eventCode清除缓存
执行处置
特征因子4
尝试获取token
FeatureEvent 特征事件
是否有对应策略
二级缓存无配置时读取Redis缓存并同步到二级缓存中
activity_id
兼容逻辑
BuisnessEventB规则引擎
redis增加策略处置信息
更新动态变量配置
redis
set手机号
记录该tag为敏感图片
策略禁用规则
记录二维码信息到redis缓存
判断业务事件是否依赖特征事件
1.图片大小
riskManagerImBanAddDTO{...\"phone\":\"\"...}
DorisIM封禁操作日志
记录对象是否在名单库redis
MYSQL数据库
敏感词识别流程
线程池
Doris-Feedback
动态变量 2
（防止重复封禁）
1.获取名单变量
Doris-Event
构建事件组全部动态变量
执行规则引擎
mysql更新该记录时间
1.命中风控，输出名单
上线
限流
redis更改策略状态为上线
获取该图片文本识别信息
Kafka场景
存在
(失败) 自旋三次
context包含策略状态未更改
根据tdataCode绑定对应的Config（阈值、限流等）
数据反馈
请求参数校验（requestData）补全参数
TODO
争抢
依赖3
tag是否记录到redis缓存
识别file中的二维码，更新字段
更新敏感词【过滤特殊字符账号】
portal新接口获取图片中二维码信息
或
Redis数据库
依赖特征事件的业务事件BusinessEvent2
业务事件BusinessEvent4
是否熔断
获取策略集合
一个业务事件 BusinessEvent
更新 黑名单账号（添加、删除）
eventType = 1
判断excel首行是否与对应eventCode参数匹配
HTTP动态变量1
6.规则引擎执行
