package com.product.data.center.entity; import com.product.core.entity.DataTableEntity; import com.product.core.entity.FieldSetEntity; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; /** * @Author cheng * @Date 2023/5/22 11:08 * @Desc 历史数据 */ public class HistoryEntity { /** * 归档数据 */ private DataTableEntity archivedDataTable; /** * MES主库数据 */ private DataTableEntity masterDataTable; /** * MES子库数据 */ private DataTableEntity subDataTable; /** * 目标表名 */ private String tableName; /** * 时间字段 */ private String timeField; /** * 主键字段 */ private String primaryField; /** * 指令单号字段 */ private String moNumberField; public DataTableEntity getArchivedDataTable() { return archivedDataTable; } public void setArchivedDataTable(DataTableEntity archivedDataTable) { this.archivedDataTable = archivedDataTable; } public DataTableEntity getMasterDataTable() { return masterDataTable; } public void setMasterDataTable(DataTableEntity masterDataTable) { this.masterDataTable = masterDataTable; } public DataTableEntity getSubDataTable() { return subDataTable; } public void setSubDataTable(DataTableEntity subDataTable) { this.subDataTable = subDataTable; } public String getTableName() { return tableName; } public void setTableName(String tableName) { this.tableName = tableName; } public String getTimeField() { return timeField; } public void setTimeField(String timeField) { this.timeField = timeField; } public String getPrimaryField() { return primaryField; } public void setPrimaryField(String primaryField) { this.primaryField = primaryField; } public String getMoNumberField() { return moNumberField; } public void setMoNumberField(String moNumberField) { this.moNumberField = moNumberField; } public Map> getGroupData() { if (!DataTableEntity.isEmpty(this.subDataTable)) { return this.subDataTable.getData().stream().collect(Collectors.groupingBy((item -> item.getString("source_info")))); } return null; } }