跑分新流程
2016-11-22 10:50:37 0 举报ppdai
作者其他创作
大纲/内容
返回费率结果
发起调用
等待（跑数据采集/再跑一次业务）模块 PATA-deng @陈建
返回 drools（决策）结果审核结论拒绝理由额度额度理由
计算公式：A1 = A - A2(A1可能 0)
改表 pata-status计算状态表对应行的状态改为计算中
quechao-master接口
【双写老表+新表】写对应额度字段值 = A1
statusid = -11（超时失败）
结束
Y
组装成一个大JSON（可以是多个key下面）
改老的
兼容老的
PATA-pei接口
接口需对外开放
输入有listingid？
调用 PATA-e（写）
11
1
flow_count 加 1
5
计算当前的一系列变量
调用 PATA-deng-gei
PATA-cha接口
改表 job-status任务状态表对应行的状态改为计算完成
赋值缺省值 = -1
休眠到下一次定时
收到的参数是？
PATA-lun程序
update表 pata-info改 statusid = -11（超时失败）
循环
statusid = 2（成功）
要（分配）模块 PATA-yao @袁超
10
【读老表】*查询【所有】e_id的：A1额度A2签到额度
必须要有bizid和dingid否则返回报错
statusid = -99根据条件，找不到
调用 PATA-ding获得 dingid
轮询模块 PATA-lun @陈建
传了 dingid？
PATA-e接口
auditid其他？
statusid = 1?
返回【所有】e_id：A总额度（=A1+A2）A1额度A2签到额度B进行中额度C待还额度D可用额度（=A-B-C）3个额度来源
读取所需数据（接口 或 读表）
6
PATA-deng-gei接口
计算公式：A = A1 + A2
PATA-diao接口
7
计算该类变量
调度中心模块 PATA-diao @袁超
计算模块 PATA-suan @道钰+陈建
调用 PATA-shen
计算回溯的一系列变量
日志系统 PATA-ri @道钰
配置模块 PATA-pei @袁超
去 pata-info 表里搜根据 flowid 取最后一条（flow_count最大的行）
13
输入有dingid？
flag_typeid != []或flag_bizid != []?
modeid = 3diao-写模式？
写额度日志表
statusid = 0未开始
根据dingid条件，发给对应的drools
参数有 flowid？
flag_e = 1?
进行解析找到满足条件的行1. list_typeid = []2. list_typeid 所有状态都是13. inserttime 距今超过 max(list_typeid的超时时长)4. inserttime 距今超过 list_bizid的超时时长5. flow_count 56. inserttime 距今超过 XX秒
满足条件1~4？
statusid = -1?
如果bizid在参考表存在？
查询模块 PATA-ping @跃腾
调用 PATA-ding获得定义编号 dingid
必须要有bizid否则返回报错
PATA-shen接口
PATA-dan定时任务
收到参数：count_userid即希望要多少个userid（可选，默认=100）
N
轮询 job-status任务状态表找到满足条件所有 typeid 的 statusid 都跑完的 flowid
满足条件5~6？
调用 PATA-diao发送 JSON
将所有信息发给 PATA-ri
PATA-deng程序
*费率模块 PATA-fei @陈建
必须要有A2增量
调用 PATA-ding获取 dingid
2
modeid = 2读所有模式？
dingid = 101?即app新客？
inserttime距今 30m
PATA-fei接口
读接口/表计算得【指定】e_id的：B进行中额度*C待还额度*e_id_max 最大额度来源e_id_min 最小额度来源e_id_first 最早额度来源
PATA-yao接口
PATA-gei接口
3
去 老状态表表里搜根据 flowtype 取最后一条
调用 PATA-e（读）
根据 bizid + dingid去配置表里搜索typeid 需要哪些变量类别flagid 是否需要重新计算
15
根据不同的 statusid
传入的额度是 A1
数据源跑完了的回调
返回费率结果feelist
有？
14
生成定义（不会经常变，不进drools也无妨）
PATA-suan程序
12
*额度统一模块 PATA-e @道钰
查询模块 PATA-cha @袁超
要新的
双写老表mobilemodelvariable只写需要的字段+将 bizid 写入字段 realname_renren_match将 dingid 写入字段 gender_renren_match写 写 months 字段时，参考下面的 bizid 换算 months 参考表（见Conf的 PATA-diao）
返回【指定】e_id：A总额度（=A1+A2）A1额度A2签到额度B进行中额度C待还额度D可用额度（=A-B-C）3个额度来源
返回定义编号dingid
需要存的内容包括但不限于：1. 每次跑分的使用的所有变量2. 额度日志（或者在PATA-e中实现？）
收到dingid？
16
modeid = 1读指定模式？
17
给模块 PATA-gei @袁超
调用 PATA-yao将本次跑完的名单更改对应的pata-status 和 job-status
轮询 deng-status等待状态表抽出 isactive = 1 的行
定义模块 PATA-ding @陈建
预审模块 PATA-shen @天王
调用 PATA-gei
modeid = 4写签到模式？
传入的额度是 A
根据 typeid读取需要的参数（可能有）
调用人工审核API
【双写老表+新表】写对应app的签到额度字段值 = A2 + A2增量
读出 HBase 表这个 flowid 的所有 typeid 的 JSON
9
如果搜不到？
计算一系列变量
返回结果
改表 deng-status等待状态表对应行的状态改为 isactive = 0
评估额度/发标 PATA-master @袁超
根据 status 转 statusid （参考Conf）
PATA-master接口
statusid = -2（失败）
auditid拒绝？
flag_shen = 1?
读接口/表计算得【所有】e_id的：B进行中额度*C待还额度*e_id_max 最大额度来源e_id_min 最小额度来源e_id_first 最早额度来源
statusid = 1（进行中）
根据 bizid 转flowtype （参考Conf）
8
statusid = 0?
需要有慢慢跑的功能！简单粗暴可以是写死每秒发送 = 总量/(n个小时*3600)
更新日期：2017/06/01 15:00:00
定时生成名单模块 PATA-dan @一鸣
statusid = 2?
PATA-ding接口
4
auditid通过？
调用 quechao-master（鹊巢内部决定跑哪个模型）收到返回 JSON
改表 job-status任务状态表删除 或 标记是已取出状态
鹊巢大入口 quechao-master @袁超
改表 pata-status计算状态表对应行的状态改为计算完成
listingtime = ''?
查询 Redis1个Master+n个Slave
检查 Redis全局锁 = 放开？或超时？
【读老表】*根据 dingid查询【指定】e_id的：A1额度A2签到额度
如果 listingid 没有，则 listingid = -1如果 listingtime 没有，则 listingtime = 当前时间
0 条评论
下一页
