| | |
| | | /** 载荷类别:存活心跳,只刷新"取数程序还在推"这一条事实。 */ |
| | | public static final String KIND_HEARTBEAT = "HEARTBEAT"; |
| | | |
| | | /** 落地行主键。 */ |
| | | private Long ingestId; |
| | | /** 推送来源所属的适配器实例编码。 */ |
| | | private String adapterCode; |
| | | /** 载荷类别:TOPOLOGY 拓扑上报、SAMPLE 逐点数据行、HEARTBEAT 存活心跳。 */ |
| | | private String payloadKind; |
| | | /** 厂商设备类型。 */ |
| | | private Integer devtype; |
| | | /** 厂商设备号。 */ |
| | | private Integer devid; |
| | | /** 厂商单元号。 */ |
| | | private Integer subdevid; |
| | | /** 厂商通道号。 */ |
| | | private Integer chlid; |
| | | /** 来源协议序号,工步切换点可在同一绝对秒内出现多条。 */ |
| | | private Long recordSequence; |
| | | /** 来源行身份,重复推送由它幂等忽略。 */ |
| | | private String recordKey; |
| | | /** 来源侧引用标识,如测试或来源记录编号,用于现场核对。 */ |
| | | private String sourceRef; |
| | | /** 设备时间,按来源时区解释后以 UTC 保存。 */ |
| | | private Date deviceTimeUtc; |
| | | /** 设备时间原始文本,保留厂商原值。 */ |
| | | private String deviceTimeRaw; |
| | | /** 解释设备时间所用的时区标识。 */ |
| | | private String timezoneId; |
| | | /** 设备实际循环号。 */ |
| | | private Integer cycleNo; |
| | | /** 设备实际工步号。 */ |
| | | private Integer stepNo; |
| | | /** 工步内相对时长,单位秒;由成功观测提供,不以接收时间推算。 */ |
| | | private BigDecimal relativeTimeSeconds; |
| | | /** 电压,业务单位 V。 */ |
| | | private BigDecimal voltageV; |
| | | /** 电流,业务单位 A。 */ |
| | | private BigDecimal currentA; |
| | | /** 充电容量,业务单位 Ah。 */ |
| | | private BigDecimal chargeCapacityAh; |
| | | /** 放电容量,业务单位 Ah。 */ |
| | | private BigDecimal dischargeCapacityAh; |
| | | /** 充电能量,业务单位 Wh。 */ |
| | | private BigDecimal chargeEnergyWh; |
| | | /** 放电能量,业务单位 Wh。 */ |
| | | private BigDecimal dischargeEnergyWh; |
| | | /** 厂商原始行内容,按收到的键值原样保存,便于回溯来源事实。 */ |
| | | private String payloadJson; |
| | | /** 记录内容摘要,用于重复推送的幂等与冲突判定。 */ |
| | | private byte[] contentSha256; |
| | | /** 服务器收到该行的时间,以 UTC 保存。 */ |
| | | private Date receivedAtUtc; |
| | | |
| | | public Long getIngestId() { return ingestId; } public void setIngestId(Long v) { ingestId = v; } |