(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111615128.5 (22)申请日 2021.12.27 (71)申请人 大连海心信息 工程有限公司 地址 116023 辽宁省大连市高新区黄浦路 541号网络产业大厦1层 (72)发明人 孙圣斌　 (74)专利代理 机构 大连智高专利事务所(特殊 普通合伙) 2123 5 代理人 李猛 (51)Int.Cl. G06Q 40/00(2012.01) G06Q 10/10(2012.01) G06Q 50/06(2012.01) G06F 9/54(2006.01) (54)发明名称 一种基于消息队列的热费数据汇总和异常 报警系统及方法 (57)摘要 一种基于消息队列的热费数据汇总和异常 报警系统及方法， 包括经营收费管理系统、 消息 队列中间件、 日志处理系统和定时任务处理系 统， 经营收费管理系统产生日志并发送消息给消 息队列中间件； 消息队列中间件 再将消息发送给 日志处理系统； 日志处理系统对汇总台账和异常 台账进行处理； 定时任务处理系统对遗漏处理的 业务日志重新发送给消息队列中间件； S1、 建立 汇总台账和异常台账， 作为实时数据汇总和异常 报警功能的数据来源； S2、 建立业务明细数据日 志表； S3、 业务功能处理中留存业务日志； S4、 日 志处理系统对业务日志的处理； S5、 定时任务对 遗漏业务日志的处理； S6、 建立汇总数据查询和 异常数据推送功能。 保证数据的准实时性， 满足 业务的统计要求。 权利要求书3页 说明书5页 附图2页 CN 114418720 A 2022.04.29 CN 114418720 A 1.一种基于消息队列的热费数据汇总和异常报警系统， 其特征在于， 包括经营收费管 理系统、 消息队列中间件、 日志处理系统和定时任务处理系统， 在前端业务处理时， 经营收 费管理系统产生日志， 并发送消息给消息队列中间件； 消息队列中间件再将消息发送给日 志处理系统； 日志处理系统根据业务日志， 对汇总台账和异常台账进 行处理； 定时任务处理 系统， 将遗漏处 理的业务日志重新发送给消息队列中间件， 直到业 务日志全部处 理完成； 总体分为三个阶段： 静态期一次性处理阶段、 动态期实时处理阶段和动态期定时处理 阶段； 静态期一次性处理阶段： 前端业务处理工作停止， 业务明细数据不发生变化， 保证业 务明细数据与汇总台账数据一致， 工作内容是建立汇总台账、 异常台账和业务日志表， 并根 据业务明细数据实现汇总台账数据的初始化； 动态期实时处理阶段和动态期定时处理阶 段： 前端业务处理工作正常执行， 业务明细数据在实时发生变化， 工作内容是进 行业务的实 时处理， 包括业务日志的产生， 消息发送给消息队列中间件， 再转发给日志处理系统， 日志 处理系统处理业务日志； 动态期 定时处理阶段于每天晚上0点之前执行， 工作内容是查询遗 漏的业务日志并发送给消息队列中间件。 2.一种基于消息队列的热费数据汇总和异常报警方法， 其特 征在于， 包括如下步骤： S1、 建立汇总台账和异常台账， 作为实时数据汇总和异常报警功能的数据来源； S2、 建立业务明细数据日志 表； S3、 业务功能处 理中留存业务日志； S4、 日志处 理系统对业 务日志的处 理； S5、 定时任务对遗漏业 务日志的处 理； S6、 建立汇总数据查询和异常数据推送 功能。 3.如权利要求2所述的基于消息队列的热 费数据汇总和异常报 警方法， 其特征在于， 所 述步骤S1中： 根据面积台账、 应收/欠费台账、 收费台账的业务明细数据， 分别建立三个业务 汇总台账， 作为汇总数据的初始值， 汇总台账的数据结构满足业务统计的要求， 数据值同当 前静态数据保持一致， 分别建立三个业务异常台账， 异常台账的数据结构同业务明细数据 一致， 数据值 直接提取当前静态数据中符合异常规则部分； 汇总台账设计原则如下： 汇总台账包括： 组织机构、 热网、 换热站、 机组、 小区、 大楼、 单 元、 用户类型， 并在此基础上增加 业务属性， 面积汇总台账 的业务属性包括并网面积、 并网 户数、 供热面积、 供热户数； 应收/欠费汇总台账需要增加供热季维度， 业务属性包括应收、 减免、 违约金应收、 收回、 违约金收回、 欠费、 收回户数、 欠费户数； 收费台账需要增加供热 季、 交款方式、 本季累计/当日累计维度， 业 务属性包括收回本金、 违约金、 预收款； 汇总台账留存每日数据以满足历史数据的对比， 增加数据日期字段； 日志处理系统向 汇总台账更新数据时， 只更新数据日期为当天的数据； 在定时任务处理中， 所有遗漏日志处 理完成之后， 留存当日数据， 并生成下一日数据； 为保证汇总台账 的查询性能， 采取按数据 日期属性进行 数据分区的策略， 数据日期在一个自然年范围内的为 一个分区； 异常台账设计原则如下： 异常台账为实时动态更新的数据， 所有属性字段同业务明细 台账字段一致， 为识别异常台账的异常类型， 增加异常类型字段； 在日志处理系统中根据预 先设定的异常判断规则赋值； 面积异常台账的异常判断规则包括： 并网面积小于0； 供热面 积小于0； 并网面积小于供热面积； 应收/欠费台账的异常判断规则包括： 应收金额小于0； 减 免金额小于0； 收回金额小于0； 违约金应收小于0； 违约金收回小于0； 应收金额不等于收回权　利　要　求　书 1/3 页 2 CN 114418720 A 2金额加欠费金额； 收费台账 的异常判断规则包括： 收费业务收回金额小于0； 退费业务退费 金额大于 0。 4.如权利要求2所述的基于消息队列的热 费数据汇总和异常报 警方法， 其特征在于， 所 述步骤S2中： 根据面积台账、 应收/欠费台账、 收费台账的业务明细数据 表， 建立业务明细数 据日志表， 业务明细数据日志表中包括日志 ID、 业务名称、 业务时间和所有业务属性的新值 和旧值。 5.如权利要求2所述的基于消息队列的热 费数据汇总和异常报 警方法， 其特征在于， 所 述步骤S3中： 在前端业务功能处理中， 完成业务处理后， 留存变更信息到业务明细数据日志 表中， 业务日志中留存本次变更的日志ID、 业务功能名称、 操作时间， 日志的处理状态初始 化为“未处理”， 处理完成后发送消息给消息队列中间件， 业务日志设计原则 如下： 业务日志 的核心字段包括日志ID、 业务名称、 业务时间和业务明细表的主键ID， 日志ID取 随机值， 为 该表的主键， 业务名称是前端业务处理的功能名称， 业务时间是前端业务处理的操作时间， 业务明细表的主键ID取面积台账、 应收/欠费台账、 收费台账的主键ID， 业务日志包括业务 明细表的所有属性字段的新值、 旧值， 所有属性字段包括用户编号、 用户名称、 并网面积、 供 热面积、 用户类型、 单价、 应收金额、 收回金额和欠费金额， 如果是新增业务， 所有业务属性 的旧值为空， 新值为变更后的值； 如果是修改业务， 旧值为修改前的值， 新值为修改后的值； 如果是删除业务， 旧值为删除前的值， 新值为空， 业务日志表的数据量比较庞大， 为保证系 统的运行性能， 对该表采用分表分区的策略， 分成历史表和当前表， 当前表只保存处理状态 为“未处理”和“处理中”的数据； 日志处理完成之后， 将数据 移动到历史表， 历史表按业务时 间字段进行 数据分区， 业 务时间在一个自然年范围内的为 一个分区。 6.如权利要求2所述的基于消息队列的热 费数据汇总和异常报 警方法， 其特征在于， 所 述步骤S4中： 消息队列中间件接收到消息之后， 转 发给日志处理系统， 由日志处理系统对业 务日志进 行处理， 日志处理系统首先在同步状态下， 将日志处理状态更新为 “处理中”， 根据 业务类型和业务属性的旧值、 新值， 分别更新汇总台账的数据， 判断业务日志的新值是否符 合异常规则， 如果符合则将新值添加到异常台账中， 处理完成后， 将日志处理状态更新为 “处理完成 ”； 如果数据处理发生异常， 将日志处理状态重置回 “未处理”， 日志处理机制步骤 如下： 消息队列中间件的消息来源有两个， 一个是经营收费管理系统的业务功能处理中实 时发送的； 第二个是定时任务处理系统中定时发送的， 首先判断处理状态， 如果状态不是 “未处理”， 则直接结束本次任务， 在同步状态下将日志处理状态更新为 “处理中”， 在进行汇 总台账和异常台账业务处理 时， 如果数据处理发生异常， 将日志处理状态重置回 “未处理”， 结束本次工作， 如果 正常处理完成， 将日志处 理状态更新 为“处理完成”。 7.如权利要求2所述的基于消息队列的热 费数据汇总和异常报 警方法， 其特征在于， 所 述步骤S5中： 每天发起定时任务， 对遗漏处理的日志进 行重新处理， 运行策略为扫描业务日 志中处理状态为 “未处理”的数据， 并根据日志ID重新发送消息给消息队列中间件， 由日志 处理系统重新对 日志进行处理， 定时任务处理机制如下： 遗漏日志处理的运行策略为扫描 业务日志中处理状态为 “未处理”的数据， 并根据日志ID重新发送消息给消息队列中间件， 保存汇总台账当日数据的策略是： 复制所有 “数据日期 ”为当日的数据， 其中 “数据日期 ”变 更为下一日， 本季累计属性的数据保持原值 不变， 当日累计属性的数据清零。 8.如权利要求2所述的基于消息队列的热 费数据