first commit

许鹏程

2023-06-30 3bbfaa3d7d416afbd154576453c8ee9e7e2f8899

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
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<String, List<FieldSetEntity>> getGroupData() {
        if (!DataTableEntity.isEmpty(this.subDataTable)) {
            return this.subDataTable.getData().stream().collect(Collectors.groupingBy((item -> item.getString("source_info"))));
        }
        return null;
    }
}