(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210340719.4 (22)申请日 2022.03.31 (71)申请人 浙江正泰物联技 术有限公司 地址 325600 浙江省温州市乐清市北白象 镇温州大桥工业园区 申请人 浙江正泰仪 器仪表有限责任公司 (72)发明人 毕鲁君　丁振　王滨　黄林弟　 (74)专利代理 机构 北京三聚阳光知识产权代理 有限公司 1 1250 专利代理师 王娜 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/2458(2019.01) G01R 21/00(2006.01) (54)发明名称 一种实时数据统计方法及系统 (57)摘要 本发明公开了一种实时数据统计方法及系 统， 包括： 获取预先存储到消息队列中设备上报 数据和对应的采集时间， 并根据上报数据和对应 的采集时间至少形成第一上报数据、 第二上报数 据； 从消息队列中获取第二上报数据及对应采集 时间并从缓存区获取第一上报数据及对应采集 时间； 当第一上报数据对应采集时间与第二上报 数据对应采集时间属于同一统计时段， 将第二上 报数据存储到数据库第一存储统计时段中， 并将 第二上报数据及对应采集时间写入缓存区； 当第 一上报数据对应采集时间与第二上报数据对应 采集时间不属于同一统计时段， 将设备数据存储 到数据库第二存储统计时段中， 并将第二上报数 据及对应采集时间写 入缓存区。 权利要求书2页 说明书8页 附图4页 CN 114722059 A 2022.07.08 CN 114722059 A 1.一种实时数据统计方法， 其特 征在于， 包括如下步骤： 获取预先存储到消息队列中设备上报数据和对应的采集 时间， 并根据 上报数据和对应 的采集时间至少形成第一上报数据、 第二上报数据； 从所述消息队列中获取所述第二上报数据及对应采集时间并从缓存区获取第一上报 数据及对应采集时间； 将所述第一上报数据对应采集时间与所述第二上报数据对应采集时间进行比对； 当所述第一上报数据对应采集时间与所述第二上报数据对应采集时间属于同一统计 时段， 将所述第二上报数据存储到数据库第一存储统计时段中， 并将第二上报数据及对应 采集时间写入缓存区； 当所述第一上报数据对应采集时间与所述第二上报数据对应采集时间不属于同一统 计时段， 将所述设备数据存储到数据库第二存储统计时段中， 并将第二上报数据及对应采 集时间写入缓存区。 2.根据权利要求1所述的方法， 其特征在于， 所述存储统计时段数据包括： 设备唯一号、 日期、 统计时段、 起始值、 末值、 起始值采集时间、 末值采集时间。 3.根据权利要求2所述的方法， 其特征在于， 当所述第 一上报数据对应采集 时间与所述 第二上报数据对应采集时间属于同一统计时段， 将所述第二上报数据存储到所述数据库第 一存储统计时段中， 包括： 利用获取到的第二上报数据存储至第一存储统计时段的末值替换当前统计时段内第 一上报数据统计的末值， 起始 值保留不变， 并将第二上报数据和对应采集时间写入缓存区， 对缓存区数据更新。 4.根据权利要求1所述的方法， 其特征在于， 当所述第 一上报数据对应采集 时间与所述 第二上报数据对应采集时间不属于同一统计时段， 将所述第二上报数据存储到所述数据库 第二存储统计时段中， 包括： 利用获取到的第一上报数据存储至第一存储统计时段的末值作为第二存储统计时段 的起始值， 第二上报数据存储至第二存储统计时段 的末值作为第二存储统计时段的末值， 第一存储统计时段的起始值、 末值保持不变， 并将第二上报数据和对应采集时间对写入缓 存区， 对缓存区数据更新。 5.根据权利要求1所述的方法， 其特征在于， 所述获取预先存储到消息队列中设备上报 数据和对应的采集时间， 并根据上报数据和对应的采集时间至少形成第一上报数据、 第二 上报数据之前， 所述方法还 包括： 从所述消息队列中第 一次获取所述第 一上报数据和对应采集 时间， 在数据库至少形成 一个第一存 储统计时段， 并将第一次获取 所述第一上报数据和采集时间写入缓存区。 6.根据权利要求1所述的方法， 其特征在于， 存储统计时段的类型包括： 存储统计小时 时段、 存储统计日时段、 存 储统计周时段、 存 储统计月时段、 存 储统计年时段。 7.据权利要求6所述的方法， 其特征在于， 所述获取预先存储到消息队列中设备上报数 据和对应的采集时间， 并根据上报数据和对应的采集时间至少形成第一上报数据、 第二上 报数据之前， 所述方法还 包括： 从所述消息队列中第 一次获取所述第 一上报数据和对应采集 时间， 在数据库 形成存储 统计小时时段、 存储统计日时段、 存储统计周时段、 存储统计月时段、 存储统计年时段类型权　利　要　求　书 1/2 页 2 CN 114722059 A 2中至少两种， 并分别在不同类型存储统计时段形成对应第一存储统计时段， 并将第一次获 取所述第一上报数据和采集时间写入缓存区。 8.根据权利要求1所述的方法， 其特征在于， 所述设备上报数据包括： 设备唯一号、 表码 值。 9.根据权利要求1所述的方法， 其特征在于， 所述上报数据包括： 水量计量设备及用水 量、 气量计量设备及用气量和电量计量设备及用电量中的任意 一种。 10.一种实时数据统计系统， 执行如权利要求1 ‑9所述的实时数据统计方法， 所述系统 包括： 消息队列模块、 实时统计服务程序模块、 数据库模块和缓存模块， 其中实时统计服务 程序模块从所述消息队列模块获取设备上报数据及 对应采集时间， 并与缓存中上报数据及 对应采集时间进行时段对比判断， 将判断处理结果按数据库统计规则进行数据 统计更新， 并将最新上报数据及对应采集时间在缓存 模块中更新。权　利　要　求　书 2/2 页 3 CN 114722059 A 3