Browse Source

数据中台-总体设计文档修改

wangcunwen 4 years ago
parent
commit
c20a65f333

BIN
Data_db_sheet_excel/字典-0914.xlsx


+ 122 - 101
Data_middle_platform_framework/data_middle_platform_framework_design.md

@@ -392,98 +392,98 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 ##### 1、字段约定
 
-| 字段      | 说明                          | 备注 |
-| --------- | ----------------------------- | ---- |
-| class     | 类型                          |      |
-| funcid    | 信息点                        |      |
-| classCode | 类型定义的code: class.code    |      |
-| className | 类型定义的name: class.name    |      |
-| infoCode  | 信息点定义的code: funcid.code |      |
-| infoName  | 信息点定义的name: funcid.name |      |
-| groupCode | 集团编码                      |      |
-| projectId | 项目ID                        |      |
-| schemeId  | 集团方案ID                    |      |
-| graph     | 图类型                        |      |
-| graphId   | 关系数据字段,图实例id         |      |
-| rel       | 关系数据字段,边类型           |      |
-|           |                               |      |
+| 字段       | 说明                          | 备注 |
+| ---------- | ----------------------------- | ---- |
+| class      | 类型                          |      |
+| funcid     | 信息点                        |      |
+| class_code | 类型定义的code: class.code    |      |
+| class_name | 类型定义的name: class.name    |      |
+| info_code  | 信息点定义的code: funcid.code |      |
+| info_name  | 信息点定义的name: funcid.name |      |
+| group_code | 集团编码                      |      |
+| project_id | 项目ID                        |      |
+| scheme_id  | 集团方案ID                    |      |
+| graph      | 图类型                        |      |
+| graph_id   | 关系数据字段,图实例id         |      |
+| rel        | 关系数据字段,边类型           |      |
+|            |                               |      |
 
 ##### 2、数据结构
 
 类型 class
 
-| 字段       | 数据类型 | 说明                                                   |
-| ---------- | -------- | ------------------------------------------------------ |
-| code       | String   | 全局唯一                                               |
-| name       | String   | 类型名称                                               |
-| aliasCode  | String   | 类型别名编码, 集团下唯一                               |
-| aliasName  | String   | 类型别名名称                                           |
-| majorCode  | String   | 专业编码, 上级类型是系统or设备时该字段有值             |
-| systemCode | String   | 系统编码,上级类型是设备时该字段有值,值为系统类型的code |
-| parentCode | String   | 上级类型code                                           |
+| 字段        | 数据类型 | 说明                                                   |
+| ----------- | -------- | ------------------------------------------------------ |
+| code        | String   | 全局唯一                                               |
+| name        | String   | 类型名称                                               |
+| alias_code  | String   | 类型别名编码, 集团下唯一                               |
+| alias_came  | String   | 类型别名名称                                           |
+| major_code  | String   | 专业编码, 上级类型是系统or设备时该字段有值             |
+| system_code | String   | 系统编码,上级类型是设备时该字段有值,值为系统类型的code |
+| parent_code | String   | 上级类型code                                           |
 
 别名 class
 
-| 字段      | 数据类型 | 说明                     |
-| --------- | -------- | ------------------------ |
-| code      | String   | 全局唯一                 |
-| name      | String   | 类型名称                 |
-| aliasCode | String   | 类型别名编码, 集团下唯一 |
-| aliasName | String   | 类型别名名称             |
-| group_id  | String   | 集团id                   |
+| 字段       | 数据类型 | 说明                     |
+| ---------- | -------- | ------------------------ |
+| code       | String   | 全局唯一                 |
+| name       | String   | 类型名称                 |
+| alias_code | String   | 类型别名编码, 集团下唯一 |
+| alias_name | String   | 类型别名名称             |
+| group_id   | String   | 集团id                   |
 
 ##### 3、信息点 infopoint
 
-| 字段       | 数据类型          | 说明                                                         |
-| ---------- | ----------------- | ------------------------------------------------------------ |
-| code       | String            | 信息点编码,同类型下唯一                                      |
-| name       | String            | 信息点名称                                                   |
-| classCode  | String            | 类型编码                                                     |
-| category   | String            | 信息点分类:静态,脉冲,阶段,时序                               |
-| firstTag   | String            | 一级标签                                                     |
-| secondTag  | String            | 二级标签                                                     |
-| priority   | String            | 优先级                                                       |
-| inputMode  | String            | 输入方式                                                     |
-| unit       | String            | 单位                                                         |
-| dataType   | String            | 数据类型                                                     |
-| isMultiple | int               | 是否复数                                                     |
-| isRegion   | int               | 是否区间                                                     |
-| formater   | String            | 数据格式                                                     |
-| dataSource | String / Object[] | 数据源取值范围/枚举值清单等,根据dataType有不同的内容         |
-| note       | String            | 备注                                                         |
-| subFlag    | String            | 子分类标记:是否可以按此信息点进行子分类替换,同一类型下目前只支持一个子分类信息点 |
-| weak_point | int               | 虚点                                                         |
+| 字段        | 数据类型          | 说明                                                         |
+| ----------- | ----------------- | ------------------------------------------------------------ |
+| code        | String            | 信息点编码,同类型下唯一                                      |
+| name        | String            | 信息点名称                                                   |
+| class_code  | String            | 类型编码                                                     |
+| category    | String            | 信息点分类:静态,脉冲,阶段,时序                               |
+| first_tag   | String            | 一级标签                                                     |
+| second_tag  | String            | 二级标签                                                     |
+| priority    | String            | 优先级                                                       |
+| input_mode  | String            | 输入方式                                                     |
+| unit        | String            | 单位                                                         |
+| data_type   | String            | 数据类型                                                     |
+| is_multiple | int               | 是否复数                                                     |
+| is_region   | int               | 是否区间                                                     |
+| formater    | String            | 数据格式                                                     |
+| data_source | String / Object[] | 数据源取值范围/枚举值清单等,根据dataType有不同的内容         |
+| note        | String            | 备注                                                         |
+| sub_flag    | String            | 子分类标记:是否可以按此信息点进行子分类替换,同一类型下目前只支持一个子分类信息点 |
+| weak_point  | int               | 虚点                                                         |
 
 信息点映射表
 
-| 字段      | 数据类型 | 说明                     |
-| --------- | -------- | ------------------------ |
-| code      | String   | 信息点编码,同类型下唯一  |
-| name      | String   | 信息点名称               |
-| classCode | String   | 类型编码                 |
-| aliasCode | String   | 类型别名编码, 集团下唯一 |
-| aliasName | String   | 类型别名名称             |
-| group_id  | String   | 集团id                   |
+| 字段       | 数据类型 | 说明                     |
+| ---------- | -------- | ------------------------ |
+| code       | String   | 信息点编码,同类型下唯一  |
+| name       | String   | 信息点名称               |
+| class_code | String   | 类型编码                 |
+| alias_code | String   | 类型别名编码, 集团下唯一 |
+| alias_name | String   | 类型别名名称             |
+| group_id   | String   | 集团id                   |
 
 ##### 4、对象 object
 
 | 字段           | 数据类型       | 说明               |
 | -------------- | -------------- | ------------------ |
 | id             | String         | id,全局唯一       |
-| projectId      | String         | 项目id,不可为空   |
-| classCode      | String         | 类型code,不可为空 |
+| project_id     | String         | 项目id,不可为空   |
+| class_code     | String         | 类型code,不可为空 |
 | 其他信息点编码 | 根据信息点定义 |                    |
 |                |                |                    |
 
 ##### 5、关系 relation
 
-| 字段    | 数据类型 | 说明                   |
-| ------- | -------- | ---------------------- |
-| graphId | String   | 图实例id               |
-| rel     | String   | 边类型(图实例的分组) |
-| from    | String   | 对象id                 |
-| to      | String   | 对象id                 |
-| infos   | Object   | 关系附加信息           |
+| 字段     | 数据类型 | 说明                   |
+| -------- | -------- | ---------------------- |
+| graph_id | String   | 图实例id               |
+| rel      | String   | 边类型(图实例的分组) |
+| from     | String   | 对象id                 |
+| to       | String   | 对象id                 |
+| infos    | Object   | 关系附加信息           |
 
 ##### 6、信息点数值类型
 
@@ -531,7 +531,9 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 4、填报数据设计
 
-1)填报原始数据originalreport_data<br />存储仪表原始数据的填报值,不区分低频、高频,
+1)填报原始数据originalreport_data
+
+存储仪表原始数据的填报值,不区分低频、高频,
 
 5、数据表逻辑结构设计:
 
@@ -543,7 +545,7 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | receivetime | 数据时间       | String | 否     | 是   | yyyyMMddHHmmss |
 | data        | 数据值         | Double | 否     |      |                |
 
-##### 2、分精度计算fjd_0_near、fjd_1_near、fjd_2_near、fjd_3_near、fjd_0_rate
+##### 2、分精度计算fjd_0_near、fjd_1_near、fjd_2_near、fjd_3_near、fjd_0_rate、fjd_statinst
 
 对采集数据和人工填报数据进行分精度处理,对IOT数据进行分精度处理,取1min、5min、15min、1h、1d分精度临近值和枚举量。
 
@@ -585,9 +587,28 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | repair_data_type | 分精度数据修复类型       | String | 否     |      | 0、原始,1、人工智能算法修复,2、人工修复,3、专家修复 |
 | status_value     | 枚举值                   | Double | 否     |      |                                                        |
 | status_ratio     | 此枚举值时间比例         | Double |        |      |                                                        |
+| data_type        | 数据类型                 | String | 否     | 是   | Acc累计量,Inst瞬时量,EnumV状态变量,Boolv通断变量... |
 | data_flag        | 数据标记                 | Long   | 否     |      | 0正常,其他正整数为异常                                |
 | collect_cycle    | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d                              |
 
+6、瞬时量分精度统计值fjd_statinst
+
+stat_Inst,瞬时量最大值、最小值、平均值的统计,数据表逻辑结构设计如下
+
+| 字段       | 字段名称       | 类型     | 可为空 | 主键 | 备注                    |
+| ---------- | -------------- | -------- | ------ | ---- | ----------------------- |
+| building   | 项目10位数编码 | String   | 否     | 是   |                         |
+| meter      | 仪表编号       | String   | 否     | 是   |                         |
+| funcid     | 功能号         | String   | 否     | 是   |                         |
+| data_time  | 数据时间       | String   | 否     | 是   | yyyyMMddHHmmss          |
+| data_flag  | 数据标记       | int      | 否     |      | 0正常,其他正整数为异常 |
+| data_count | 数据条数       | Long     | 否     | 是   |                         |
+| data_avg   | 平均值         | Double   | 否     |      |                         |
+| data_max   | 最大值         | Double   | 否     |      |                         |
+| time_max   | 最大值时间     | Datetime |        |      |                         |
+| data_min   | 最小值         | Double   | 否     |      |                         |
+| time_min   | 最小值时间     | Datetime | 否     |      |                         |
+
 ##### 3、仪表能耗计算data_servicedata、data_servicedata_max
 
 1、根据分精度数据计算出的仪表能耗值,并按1min、5min、15min、1h、1d等时间维度对仪表能耗数据进行存储入库。
@@ -598,9 +619,9 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 根据分精度数据计算出的仪表能耗值,存储维度:1min、5min、15min、1h、1d,
 
-2)仪表能耗最大值data_servicedata_max_1h(1h代表小时,还有1d、1m、1y)
+2)仪表能耗最大功率值data_servicedata_max_1h(1h代表小时,还有1d、1m、1y)
 
-存储1h、1d、1m、1y等时间维度的仪表能耗最大值,1m和1y需要开启servicedata_max计算任务,
+存储1h、1d、1m、1y等时间维度的仪表能耗最大功率值,1m和1y需要开启servicedata_max计算任务,
 
 3)数据表逻辑结构设计
 
@@ -612,7 +633,7 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | data_time     | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss            |
 | data_value    | 差分值                   | Double | 否     |      |                           |
 | collect_cycle | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d |
-| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、最大值      |
+| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、最大功率值  |
 
 
 
@@ -626,9 +647,9 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 根据上述“5”中的仪表能耗以及能耗调研,计算出支路&计算单元的能耗值,存储维度:1min、5min、15min、1h、1d,
 
-2)支路&计算单元能耗最大值data_objectdata_max_1h(1h代表小时,还有1d、1m、1y)
+2)支路&计算单元能耗最大功率值data_objectdata_max_1h(1h代表小时,还有1d、1m、1y)
 
-存储1h、1d、1m、1y等时间维度的支路&计算单元能耗最大值,
+存储1h、1d、1m、1y等时间维度的支路&计算单元能耗最大功率值,
 
 3)数据表逻辑结构设计
 
@@ -639,7 +660,7 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | data_time     | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss            |
 | data_value    | 数据值                   | Double | 否     |      |                           |
 | collect_cycle | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d |
-| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、最大值      |
+| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、最大功率值  |
 
 
 
@@ -653,21 +674,21 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 根据分项模型、分项编码、支路&计算单元能耗计算分项能耗值,存储维度:1min、5min、15min、1h、1d,
 
-2)分项能耗最大值data_energydata_max_1h(1h代表小时,还有1d、1m、1y)
+2)分项能耗最大功率值data_energydata_max_1h(1h代表小时,还有1d、1m、1y)
 
-存储1h、1d、1m、1y等时间维度的分项能耗最大值,
+存储1h、1d、1m、1y等时间维度的分项能耗最大功率值,
 
 3)数据表逻辑结构设计
 
-| 字段                | 字段名称                 | 类型   | 可为空 | 主键 | 备注                      |
-| ------------------- | ------------------------ | ------ | ------ | ---- | ------------------------- |
-| building            | 项目10位数编码           | String | 否     | 是   |                           |
-| energyModelSign     | 模型编码                 | String | 否     | 是   |                           |
-| energyModelNodeSign | 分项编码                 | String | 否     | 是   |                           |
-| data_time           | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss            |
-| data_value          | 数据值                   | Double | 否     |      |                           |
-| collect_cycle       | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d |
-| data_type           | 数据类型                 | String | 否     |      | 0、能耗值,1、最大值      |
+| 字段                   | 字段名称                 | 类型   | 可为空 | 主键 | 备注                      |
+| ---------------------- | ------------------------ | ------ | ------ | ---- | ------------------------- |
+| building               | 项目10位数编码           | String | 否     | 是   |                           |
+| energy_model_sign      | 模型编码                 | String | 否     | 是   |                           |
+| energy_model_node_sign | 分项编码                 | String | 否     | 是   |                           |
+| data_time              | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss            |
+| data_value             | 数据值                   | Double | 否     |      |                           |
+| collect_cycle          | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d |
+| data_type              | 数据类型                 | String | 否     |      | 0、能耗值,1、最大功率值  |
 
 
 
@@ -683,9 +704,9 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 存储租户各时间维度的租户能耗值,若仪表编号、功能号有值时为租户仪表能耗,若租户仪表编号、功能号没有值时为租户能耗。
 
-2)租户能耗最大值data_tenantdata_1h(1h代表小时,还有1d、1m、1y)
+2)租户能耗最大功率值data_tenantdata_1h(1h代表小时,还有1d、1m、1y)
 
-取1h、1d、1m、1y租户能耗的最大值存储到表中,若仪表编号、功能号值则为租户仪表的1h、1d、1m、1y能耗最大值。
+取1h、1d、1m、1y租户能耗的最大值存储到表中,若仪表编号、功能号值则为租户仪表的1h、1d、1m、1y能耗最大功率值。
 
 3)租户费用data_tenantdata_15min(15min代表15分钟,还有1min、5min、1h、1d)
 
@@ -693,17 +714,17 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 
 4)数据表逻辑结构设计
 
-| 字段          | 字段名称                 | 类型   | 可为空 | 主键 | 备注                                    |
-| ------------- | ------------------------ | ------ | ------ | ---- | --------------------------------------- |
-| building      | 项目10位数编码           | String | 否     | 是   |                                         |
-| tenant        | 租户编码                 | String | 否     | 是   |                                         |
-| energy_type   | 能耗类型                 | String | 否     | 是   |                                         |
-| meter         | 仪表编号                 | String | 是     | 是   |                                         |
-| funcid        | 功能号                   | Long   | 是     | 是   |                                         |
-| data_time     | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss                          |
-| data_value    | 数据值                   | Double | 否     |      |                                         |
-| collect_cycle | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d               |
-| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、能耗最大值,2、租户费用值 |
+| 字段          | 字段名称                 | 类型   | 可为空 | 主键 | 备注                                        |
+| ------------- | ------------------------ | ------ | ------ | ---- | ------------------------------------------- |
+| building      | 项目10位数编码           | String | 否     | 是   |                                             |
+| tenant        | 租户编码                 | String | 否     | 是   |                                             |
+| energy_type   | 能耗类型                 | String | 否     | 是   |                                             |
+| meter         | 仪表编号                 | String | 是     | 是   |                                             |
+| funcid        | 功能号                   | Long   | 是     | 是   |                                             |
+| data_time     | 数据时间                 | String | 否     | 是   | yyyyMMddHHmmss                              |
+| data_value    | 数据值                   | Double | 否     |      |                                             |
+| collect_cycle | 分精度计算的最小时间粒度 | String | 否     |      | 1min、5min、15min、1h、1d                   |
+| data_type     | 数据类型                 | String | 否     |      | 0、能耗值,1、能耗最大功率值,2、租户费用值 |
 
 4、租户余额数据结构设计
 
@@ -1389,7 +1410,7 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | create_type   | 创建类型   | int         | 否     |      | 0、数字化交付;1、用户自定义 |
 | has_delete    | 是否删除   | int         | 否     | 是   | 0、未删除;1、已删除;默认0  |
 
-###### 13、 群控设备组对象表equip_group_object
+##### 13、 群控设备组对象表equip_group_object
 
 | 群控设备组对象表 |              |             |        |      |                              |
 | ---------------- | ------------ | ----------- | ------ | ---- | ---------------------------- |
@@ -1413,7 +1434,7 @@ b、产品数据不随着产品版本变化的产品 “产品ID”+ “DB schem
 | 日志数据log_data |              |                                                 |      |
 | ---------------- | ------------ | ----------------------------------------------- | ---- |
 | 字段             | 字段说明     | 数据类型                                        | 备注 |
-| rowKey           | hbase索引    | 全局唯一,“20200905114410+belong_sys+type_code” |      |
+| row_key          | hbase索引    | 全局唯一,“20200905114410+belong_sys+type_code” |      |
 | name             | 日志名称     | varchar(40)                                     |      |
 | type_name        | 日志类型名称 | varchar(40)                                     |      |
 | type_code        | 日志类型编码 | varchar(40)                                     |      |