(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202211059494.1 (22)申请日 2022.09.01 (65)同一申请的已公布的文献号 申请公布号 CN 115146217 A (43)申请公布日 2022.10.04 (73)专利权人 国网信息通信产业 集团有限公司 地址 102211 北京市昌平区未来科技城北 区国网智能电网研究院内C座 4层 (72)发明人 焦心愿　王孟强　张治志　利润霖　 蔡振聪　王颖　邢晓林　 (74)专利代理 机构 济南舜源专利事务所有限公 司 37205 专利代理师 张营磊 (51)Int.Cl. G06F 17/10(2006.01)G06F 9/54(2006.01) G06Q 50/06(2012.01) (56)对比文件 CN 113783773 A,2021.12.10 CN 113722127 A,2021.1 1.30 US 11169847 B1,2021.1 1.09 审查员 周晓童 (54)发明名称 一种解决综合能源系统数据循环计算的方 法、 系统及设备 (57)摘要 本申请公开了一种解决综合能源系统数据 循环计算的方法、 系统及设备， 主要涉及数据循 环计算技术领域， 用以解决现有的消息中间件容 易出现数据重复循环 计算等问题。 包括： S1、 通过 预设消息中间件发送消息数据至预设大数据服 务方法； S2、 预设大数据服务方法确定对应的计 算结果或缓存结果； 将计算结果返回至预设消息 中间件， 且主题设置为第二消息主题； S3、 当存在 缓存结果或若干计算数据中的最小循环次数等 于预设最大循环次数时， 跳 出循环； 否则， 将最小 循环次数+1， 并将计算结果回写至预设消息中间 件， 且主题设置为第一消息主题； S4、 重复S2 ‑S3， 直至跳出循环。 本申请通过上述方法设置了循环 终止条件， 避免重复数据进 入循环。 权利要求书2页 说明书4页 附图2页 CN 115146217 B 2022.12.13 CN 115146217 B 1.一种解决综合能源系统数据循环计算的方法， 其特 征在于， 所述方法包括： S1、 通过预设消息中间件发送消息数据至预设大数据服务flink； 其中， 所述消息数据 至少包括： 若干计算数据、 第一消息主题、 循环次数和公式编号； S2、 根据消息数据中的所述计算数据和所述公式编号， 所述预设大数据服务flink确定 对应的计算结果 或缓存结果； 具体地， 根据所述计算数据和所述 公式编号， 所述预设大数据 服务flink确定缓存中是否存在 对应的缓存 结果； 直接获得缓存结果， 或经过时间窗口处理 消息数据， 计算 获得计算结果； 将所述计算结果返回至预设消息中间件， 且主题设置为第二 消息主题； S3、 当存在缓存结果或若干计算数据中的最小循环次数等于预设最大循环次数时， 跳 出循环； 否则， 将最小循环 次数+1， 并将计算结果回写至预设消息中间件， 且主题设置为所 述第一消息主题； S4、 重复S2 ‑S3， 直至跳出循环。 2.根据权利要求1所述的解决综合能源系统数据循环计算的方法， 其特征在于， 所述方 法还包括： 通过预设大数据服务flink将所述计算数据和公式编号与所述计算结果之间的对应关 系缓存至双序列数据集 合， 以便于集合中的计算结果作为缓存结果 直接调用。 3.根据权利要求1所述的解决综合能源系统数据循环计算的方法， 其特征在于， 所述方 法还包括： 通过预设大数据服务flink创建双序列数据集合； 其中， 所述双序列数据集合包含公式 编号和计算 集合， 且所述计算 集合由计算数据和计算结果组成。 4.一种解决综合能源系统数据循环计算的系统， 其特 征在于， 所述系统包括： 发送模块， 用于通过预设消息中间件发送消息数据至预设大数据服务flink； 其中， 所 述消息数据至少包括： 若干计算数据、 第一消息主题、 循环次数和公式编号； 返回模块， 用于根据消息数据中的所述计算数据和所述公式编号， 所述预设大数据服 务flink确定对应的计算结果 或缓存结果； 将所述计算结果返回至预设消息中间件， 且主题 设置为第二消息主题； 还用于 当存在缓存结果或若干计算数据中的最小循环次数等于预设 最大循环 次数时， 跳出循环； 否则， 将最小循环次数+1， 并将计算结果回写至预设消息中间 件， 且主题设置为所述第一消息主题； 所述返回模块还包括计算单元； 所述计算单元， 用于根据所述计算数据和所述公式编 号， 所述预设大数据服务flink确定缓存中是否存在对应的缓存结果； 直接获得缓存结果， 或经过时间窗口处 理消息数据， 计算获得计算结果； 重复模块， 用于 重复运行返回模块， 直至全部计算数据跳出循环。 5.根据权利要求4所述的解决综合能源系统数据循环计算的系统， 其特征在于， 所述返 回模块还 包括缓存单 元； 所述缓存单元， 用于通过预设大数据服务flink将所述计算数据和 公式编号与所述计 算结果之 间的对应关系缓存至双序列数据集合， 以便于集合中的计算结果作为缓存结果直 接调用。 6.一种解决综合能源系统数据循环计算的设备， 其特 征在于， 所述设备包括： 处理器；权　利　要　求　书 1/2 页 2 CN 115146217 B 2以及存储器， 其上存储有可执行代码， 当所述可执行代码被执行时， 使得所述处理器执 行如权利要求1 ‑3任一项所述的一种解决综合能源系统数据循环计算的方法。权　利　要　求　书 2/2 页 3 CN 115146217 B 3