[發明專利]一種基于消息總線的電能表數據處理方法、系統和電能表

有效

• 申請號: 202110050403.7
• 申請日: 2021-01-14
• 公開（公告）號: CN112804331B
• 公開（公告）日: 2022-08-16
• 發明（設計）人: 彭中華;汪揚
• 申請（專利權）人: 杭州海興澤科信息技術有限公司;杭州海興電力科技股份有限公司;寧波恒力達科技有限公司;南京海興電網技術有限公司
• 主分類號: H04L67/565
• 分類號: H04L67/565;H04L67/568;H04L67/1097;H04Q9/00;G06F16/22;G06F16/23;G06F16/242;G06F16/2455
• 代理公司: 杭州裕陽聯合專利代理有限公司 33289
• 代理人: 田金霞

1.一種基于消息總線的電能表數據處理方法，其特征在于，所述方法包括如下步驟：

向kafka總線中寫入原始數據，所述原始數據包括HES數據，所述HES數據為HES程序可識別數據，所述HES程序為前置機程序，所述HES程序用于加載電能表檔案、量綱信息；

轉存程序從kafka總線中讀取HES數據，并將所述HES數據轉換成中間數據；

將所述中間數據寫入到所述kafka總線；

批量讀取kafka總線中的中間數據，并將所述中間數據進行轉換、合并；

將轉換合并后的中間數據寫入數據庫中。

2.根據權利要求1所述的一種基于消息總線的電能表數據處理方法，其特征在于，UA程序、HES程序和DP程序定時從數據庫加載檔案和量綱信息，并從kafka總線中查找電能表設備上下文，若查找失敗則新建電能表設備上下文并將新建的電能表設備上下文更新到kakfa總線中。

3.根據權利要求2所述的一種基于消息總線的電能表數據處理方法，其特征在于，UA程序接收來自電能表設備主站和第三方應用請求，并將該請求轉換為HES程序可識別處理數據，并將轉換后的HES程序可識別處理數據發送到kafka總線，將UA程序處理請求時用到的數據和狀態保存于kafka總線中。

4.根據權利要求2所述的一種基于消息總線的電能表數據處理方法，其特征在于，通過DP程序處理定時策略數據，所述DP程序將所述定時策略數據轉換為HES程序可識別處理數據，并將轉換后HES程序可識別處理數據保存于kafka總線中，將DP程序處理定時策略數據中用到的數據和狀態保存于所述kafka總線中。

5.根據權利要求2所述的一種基于消息總線的電能表數據處理方法，其特征在于，通過HES程序采集電能表設備數據，所述HES程序從kafak總線中獲取UA程序或DP程序的請求數據，并將請求數據發送給電能表設備，HES程序解析處理電能表設備數據并保存于kafka總線中，并將解析處理電能表設備數據需要的數據和狀態保存于kafka總線中。

6.根據權利要求1所述的一種基于消息總線的電能表數據處理方法，其特征在于，轉存程序將最后一次批量讀出的中間數據生成實體類，并根據實體類生成sql語句，并將所述實體類批量存入數據庫。

7.根據權利要求1所述的一種基于消息總線的電能表數據處理方法，其特征在于，所述轉存程序計算所有電能表設備狀態信息，并根據所述狀態信息計算單個電能表設備單個時間點單個任務執行數據，并根據所述執行數據統計任務漏點，根據所述任務漏點計算任務成功率。

8.根據權利要求7所述的一種基于消息總線的電能表數據處理方法，其特征在于，將計算獲得的任務執行數據和漏點數據批量保存于數據庫中。

9.一種基于消息總線的電能表數據處理系統，其特征在于，所述系統采用上述權利要求1-8中任意一項所述的基于消息總線的電能表數據處理方法。

10.一種電能表，其特征在于，所述電能表采用上述權利要求8所述的一種基于消息總線的電能表數據處理系統。