[發明專利]支持大屏幕展示的發票監控方法、裝置及系統

在審

• 申請號: 202010000727.5
• 申請日: 2020-01-02
• 公開（公告）號: CN111222930A
• 公開（公告）日: 2020-06-02
• 發明（設計）人: 李凱;李澤然;魏海健;王曉亮;王凱;黨璐一;胡聚平
• 申請（專利權）人: 大象慧云信息技術有限公司
• 主分類號: G06Q30/04
• 分類號: G06Q30/04;G06Q30/02;G06F9/54
• 代理公司: 北京工信聯合知識產權代理有限公司 11266
• 代理人: 白曉晰

1.一種支持大屏幕展示的發票監控方法，其特征在于，包括以下步驟：

提取電子發票數據，所述電子發票的票面信息包括商品名稱、商品數量、銷售額、納稅額、購買方和/或銷售方；

將電子發票數據中的銷售方、商品和購貨方的數據通過拉取的方式寫入消息隊列；

從消息隊列中取出銷售方、商品和購貨方的數據，進行預處理，得到預處理后的數據；

根據預先設計的統計規則，在時間窗口內統計所述預處理后的數據，生成待大屏顯示的展示數據；

通過BI數據可視化工具將生成的待大屏顯示的展示數據展示在大屏上。

2.根據權利要求1所述的支持大屏幕展示的發票監控方法，其特征在于，

所述在時間窗口內統計所述預處理后的數據之后，還包括：

將根據所述預處理后的數據統計得到的歸檔數據，實時地寫入數據存儲系統。

3.根據權利要求1所述的支持大屏幕展示的發票監控方法，其特征在于，

根據預先設計的統計規則，在時間窗口內統計所述預處理后的數據，生成待大屏顯示的展示數據，包括：

在所述時間窗口內，進行數據消費，包括完成所述統計所述預處理后的數據及生成待大屏顯示的展示數據的步驟；

在所述時間窗口內，進行數據生產，包括完成將電子發票數據中的銷售方、商品和購貨方的數據通過拉取的方式寫入消息隊列的步驟，其中，所述銷售方、商品和購貨方的數據的容量，與所述時間窗口的長度相匹配。

4.根據權利要求3所述的支持大屏幕展示的發票監控方法，其特征在于，

所述預先設計的統計規則包括：

分別按照省份維度或時間維度進行統計，得出每個省份每天或每月的開票數量及開票金額；

分別按照公司維度和時間維度進行統計，得出每個公司每天或每月的開票數量及開票金額；

按照時間維度進行統計，得出每天或每月在全國范圍內的開票數量及開票金額。

5.根據權利要求2所述的支持大屏幕展示的發票監控方法，其特征在于，

由flume將數據拉取到kafka消息隊列；

在spark中統計所述預處理后的數據，并生成待大屏顯示的展示數據；

在spark中將根據所述預處理后的數據統計得到的歸檔數據，實時地寫入到由mysql管理的數據存儲系統中。

6.一種支持大屏幕展示的發票監控裝置，其特征在于，包括：

電子發票數據提取單元，用于：

提取電子發票數據，所述電子發票的票面信息包括商品名稱、商品數量、銷售額、納稅額、購買方和/或銷售方；

數據寫入消息隊列單元，用于：

將電子發票數據中的銷售方、商品和購貨方的數據通過拉取的方式寫入消息隊列；

數據預處理單元，用于：

從消息隊列中取出銷售方、商品和購貨方的數據，進行預處理，得到預處理后的數據；

展示數據生成單元，用于：

根據預先設計的統計規則，在時間窗口內統計所述預處理后的數據，生成待大屏顯示的展示數據；

數據展示單元，用于：

通過BI數據可視化工具將生成的待大屏顯示的展示數據展示在大屏上。

7.根據權利要求6所述的支持大屏幕展示的發票監控裝置，其特征在于，還包括：

歸檔數據存儲單元，用于：

所述在時間窗口內統計所述預處理后的數據之后，將根據所述預處理后的數據統計得到的歸檔數據，實時地寫入數據存儲系統。

8.根據權利要求6所述的支持大屏幕展示的發票監控裝置，其特征在于，

所述展示數據生成單元，還用于：

在所述時間窗口內，進行數據消費，包括完成所述統計所述預處理后的數據及生成待大屏顯示的展示數據的步驟；

在所述時間窗口內，進行數據生產，包括完成將電子發票數據中的銷售方、商品和購貨方的數據通過拉取的方式寫入消息隊列的步驟，

其中，所述銷售方、商品和購貨方的數據的容量，與所述時間窗口的長度相匹配。