rule2
保留计算
判定是否要执行保留
接收保留消息hotel.review.reduce.rule.choose{\"uid\": \"abc\
对A加保留标记let find=true
End
rule15
rules包含13?
T
接收降权表otter消息
点评库
F
根据uid和hotelid查降权ES按质量分降序分页取20条拿到N条
分页++
RDF计算
用这N条去查降权表
对于牵扯的点评发送重算消息hotel.review.reduce.compute{\"writingId\
rule1（无保留逻辑）
change_weight
遍历点评是否存在点评B有保留标记
点评库change_weight
结束
降权表
let find = false
rules包含<=0?
check find=true
pull消息，聚合去重
fold |= result_foldreduce_weight |= result_change_weightdecend_order |= result_decend_order
对B移除保留标记
发送保留消息hotel.review.reduce.rule.choose
触发对客ES更新消息
规则分发，并行处理
N
消费 hotel.review.reduce.compute{\"writingId\
若N = 20
rules变化?
遍历rules
结果merge到rules字段，落库
当前点评继续走下一步
...
let fold=falselet reduce_weight=falselet decend_order=false
消息牵扯到其他点评且重发缓存中没有
降权计算
按质量分降序遍历N的降权情况若找到只因1降权的点评A
qconfig配置
