添加大车、大理片笼以及多设备串行/并行执行写入基础逻辑

huang

2025-11-20 366ba040d2447bacd3455299425e3166f1f992bb

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
package com.mes.task.model;
 
import com.mes.task.dto.TaskParameters;
import lombok.Getter;
import lombok.Setter;
import org.springframework.util.CollectionUtils;
 
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
/**
 * 多设备任务执行上下文
 */
@Getter
public class TaskExecutionContext {
 
    private final TaskParameters parameters;
 
    @Setter
    private List<String> loadedGlassIds;
 
    @Setter
    private List<String> processedGlassIds;
 
    private final Map<String, Object> sharedData = new ConcurrentHashMap<>();
 
    public TaskExecutionContext(TaskParameters parameters) {
        if (parameters == null) {
            this.parameters = new TaskParameters();
        } else {
            this.parameters = parameters;
        }
        if (CollectionUtils.isEmpty(this.parameters.getGlassIds())) {
            this.parameters.setGlassIds(new ArrayList<>());
        }
        this.sharedData.put("initialGlassIds", new ArrayList<>(this.parameters.getGlassIds()));
    }
 
    public Map<String, Object> getSharedData() {
        return sharedData;
    }
 
    public List<String> getSafeLoadedGlassIds() {
        return loadedGlassIds == null ? Collections.emptyList() : loadedGlassIds;
    }
 
    public List<String> getSafeProcessedGlassIds() {
        return processedGlassIds == null ? Collections.emptyList() : processedGlassIds;
    }
}