(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211052970.7 (22)申请日 2022.08.31 (71)申请人 北京达佳互联信息技 术有限公司 地址 100085 北京市海淀区上地西路6号1 幢1层101D1-7 (72)发明人 陈俊成　 (74)专利代理 机构 北京清亦华知识产权代理事 务所(普通 合伙) 11201 专利代理师 孟洋 (51)Int.Cl. G06F 9/54(2006.01) G06F 16/27(2019.01) G06F 16/28(2019.01) (54)发明名称 任务处理方法及装置 (57)摘要 本公开是关于一种任务处理方法及装置， 涉 及信息技术领域， 该方法包括： 获取用户针对新 增业务线进行短视频浏览时触发的目标事件消 息； 若基于所述目标事件消息， 确定目标事件满 足预设累计条件， 则基于所述用户针对所述新增 业务线的参与度反馈因子注册信息和所述目标 事件消息， 对 所述目标事件对应的参与度反馈因 子进行数量累计， 得到所述参与度反馈因子的累 计结果； 若根据所述累计结果确定所述参与度反 馈因子已达标， 则向任务系统推送 参与度反馈因 子达标消息， 其中， 所述任务系统用于根据所述 参与度反馈因子达标消息， 对已达标的参与度反 馈因子进行累计。 本发明能够将参与度反馈因子 驱动系统中的处理逻辑进行解耦， 从而能够提高 业务线的开发效率。 权利要求书3页 说明书19页 附图17页 CN 115454668 A 2022.12.09 CN 115454668 A 1.一种任务处 理方法， 其特 征在于， 应用于参与度反馈因子驱动系统， 包括： 获取用户针对新增业 务线进行短视频浏览时触发的目标事 件消息； 若基于所述目标事件消息， 确定目标事件满足预设累计条件， 则基于所述用户针对所 述新增业务线的参与度反馈因子注册信息和所述目标事件消息， 对所述目标事件对应的参 与度反馈因子进行 数量累计， 得到所述 参与度反馈因子的累计结果； 若根据所述累计结果确定所述参与度反馈因子已达标， 则向任务系统推送参与度反馈 因子达标消息， 其中， 所述任务系统用于根据所述参与度反馈因子达标消息， 对已达标的参 与度反馈因子进行累计。 2.根据权利要求1所述的方法， 其特征在于， 所述获取用户针对新增业务线进行短视频 浏览时触发的目标事 件消息， 包括： 当所述目标事件对应的参与度反馈因子类型为累加型参与度反馈因子时， 实时获取所 述目标事 件消息； 当所述目标事件对应的参与度反馈因子类型为轮刷型参与度反馈因子时， 对所述目标 事件进行定时统计， 并根据统计结果， 确定所述目标事 件消息。 3.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 基于所述目标事 件消息查询预设参与度反馈因子注 册信息库， 得到注 册查询结果； 若根据所述注册查询结果， 确定所述用户在所述新增业务线中未针对所述目标事件进 行参与度反馈因子注 册， 则确定所述目标事 件不满足预设累计条件。 4.根据权利要求3所述的方法， 其特 征在于， 所述方法还 包括： 若根据所述注册查询结果， 确定所述用户在所述新增业务线中针对所述目标事件进行 了参与度反馈因子注册， 则获取所述用户的参与度反馈因子注册信息， 以及所述参与度反 馈因子注 册信息对应的参与度反馈因子进度信息； 若根据所述参与度反馈因子进度信息， 确定所述参与度反馈因子已达标， 则确定所述 目标事件不满足预设累计条件； 若根据所述参与度反馈因子进度信息， 确定所述参与度反馈因子未达标， 则确定所述 目标事件满足预设累计条件。 5.根据权利要求3所述的方法， 其特征在于， 所述基于所述目标事件消息查询预设参与 度反馈因子注 册信息库， 得到注 册查询结果， 包括： 根据所述目标事 件消息中的事 件标识， 确定所述目标事 件对应的参与度反馈因子； 根据所述参与度反馈因子和所述目标事件消息 中的用户信 息， 查询预设参与度反馈因 子注册信息库； 若所述预设参与度反馈因子注册信 息库中存在相应的参与度反馈因子注册信 息， 则确 定所述用户在所述 新增业务线中针对所述目标事 件进行了参与度反馈因子注 册； 若所述预设参与度反馈因子注册信 息库中不存在相应的参与度反馈因子注册信 息， 则 确定所述用户在所述 新增业务线中未针对所述目标事 件进行参与度反馈因子注 册。 6.根据权利要求1所述的方法， 其特征在于， 所述基于所述用户针对所述新增业务线的 参与度反馈因子注册信息和所述目标事件消息， 对所述目标事件对应的参与度反馈因子进 行数量累计， 得到所述 参与度反馈因子的累计结果， 包括： 若所述参与度反馈因子注册信 息中的累计类型为普通累计， 则根据所述目标事件消息权　利　要　求　书 1/3 页 2 CN 115454668 A 2中的数量信息， 对所述目标事 件对应的参与度反馈因子进行普通累计， 得到所述累计结果； 若所述参与度反馈因子注册信 息中的累计类型为普通周期累计， 则根据 所述目标事件 消息中的数量信息， 对所述 目标事件对应的参与度反馈因子进行普通周期累计， 得到所述 累计结果； 若所述参与度反馈因子注册信 息中的累计类型为连续周期累计， 则根据 所述目标事件 消息中的数量信息， 对所述 目标事件对应的参与度反馈因子进行连续周期累计， 得到所述 累计结果。 7.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 根据所述累计结果更新所述参与度反馈因子注册信息对应的参与度反馈因子进度信 息。 8.根据权利要求7所述的方法， 其特征在于， 所述参与度反馈因子进度信 息包括参与度 反馈因子是否达成标签和参与度反馈因子进度， 所述根据所述累计结果更新所述参与度反 馈因子注 册信息对应的参与度反馈因子进度信息， 包括： 根据所述累计结果， 增 加所述参与度反馈因子进度； 当增加后的参与度反馈因子进度达标时， 更新所述参与度反馈因子是否达成标签， 并 生成参与度反馈因子 达成标识； 当增加后的参与度反馈因子进度未达标时， 结束消费。 9.根据权利要求8所述的方法， 其特征在于， 所述向任务系统推送参与度反馈因子达标 消息， 包括： 确定所述 参与度反馈因子的达成时间； 根据所述达成时间、 所述参与度反馈因子达成标识、 所述增加后的参与度反馈因子进 度、 所述目标事件消息中的用户信息和所述参与度反馈因子注册信息中的唯一标识， 生成 所述参与度反馈因子 达标消息； 将所述参与度反馈因子达标消息发送至参与度反馈因子达标消息队列， 其中， 所述任 务系统在所述 参与度反馈因子 达标消息队列中订阅所述 参与度反馈因子 达标消息 。 10.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 响应于所述任务系统发送的参与度反馈因子注册请求， 基于预设参与度反馈因子注册 协议， 获取参与度反馈因子注 册信息； 将所述参与度反馈因子注册信 息按用户信 息和参与度反馈因子的种类进行聚类， 并存 储至Redis数据库的hash结构中。 11.根据权利要求10所述的方法， 其特 征在于， 所述方法还 包括： 对所述Redis数据库进行集群分片， 得到多个Redis子集群。 12.根据权利要求1 1所述的方法， 其特 征在于， 所述方法还 包括： 当同一时间针对特定类型相对人的目标事件数量超过预设数量 时， 按照用户信 息和所 述目标事件所涉及的参与度反馈因子的种类对所述目标事件进行聚类， 得到聚类后的事件 集合； 将所述聚类后的事 件集合均匀分配至所述多个Redis子集群。 13.一种任务处 理装置， 其特 征在于， 包括： 获取单元， 用于获取用户针对新增业 务线进行短视频浏览时触发的目标事 件消息；权　利　要　求　书 2/3 页 3 CN 115454668 A 3