cuijian
2023-08-19 bdd0875d4b13a3f1ef472f64d4b6a95e0ef64b22
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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
package org.jeecg.modules.base.service.impl;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.CollectionUtils;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import org.jeecg.modules.base.entity.FactoryModel;
import org.jeecg.modules.base.entity.FactoryModelDetail;
import org.jeecg.modules.base.entity.WorkCenter;
import org.jeecg.modules.base.entity.WorkCenterDetail;
import org.jeecg.modules.base.mapper.FactoryModelMapper;
import org.jeecg.modules.base.mapper.WorkCenterMapper;
import org.jeecg.modules.base.service.IWorkCenterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
 
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.*;
import java.util.function.Predicate;
import java.util.stream.Collectors;
 
/**
 * @Description: mom_base_work_center
 * @Author: jeecg-boot
 * @Date:   2022-11-17
 * @Version: V1.0
 */
@Service
@Transactional
public class WorkCenterServiceImpl extends ServiceImpl<WorkCenterMapper, WorkCenter> implements IWorkCenterService {
    @Autowired
    private FactoryModelMapper factoryModelMapper;
    @Autowired
    private WorkCenterMapper workCenterMapper;
    @Override//根据工厂建模id寻找该工厂所有工作中心
    public Page<WorkCenterDetail> getAllWorkCenterByPMFId(Page<WorkCenterDetail> page,String parentFactoryModelId,Integer factoryModelVersion,Integer version) {
       return page.setRecords(workCenterMapper.selectWorkCenterByPMFIds(page,trueGetLeaves(factoryModelVersion,parentFactoryModelId),version));
    }
 
    @Override//递归寻找工作中心的root节点
    public FactoryModelDetail getTop(String eid, String fid) {
        FactoryModelDetail factoryModelDetail = factoryModelMapper.getFatherIdById(fid);
        if(!factoryModelDetail.getParentId().equals(eid)){
            return getTop(eid,factoryModelDetail.getParentId());
        }
        else{
            return factoryModelDetail;
        }
    }
 
    @Override
    public Set<Integer> getVersionList(){
        Set<Integer> set = new TreeSet(Comparator.reverseOrder());
        set.addAll(workCenterMapper.getVersionList());
        return set;
    }
    @Override
    public List<WorkCenter> getUpdateVersionlist(Integer version) {
        return workCenterMapper.getUpdateVersionlist(version);
    }
 
    @Override
    public List<WorkCenter> getUsableList() {
        return workCenterMapper.getUsableList();
    }
 
    @Override
    public Map<String,Object> getNowAndLastUsableVersion() {
        List<WorkCenter> usableList = workCenterMapper.getUsableList();
        List<WorkCenter> lastUsableList=workCenterMapper.getLastUsableList();
        Map<String,Object> map = new HashMap<>(2);
        if(CollectionUtils.isNotEmpty(usableList)){
            map.put("usableVersion",usableList.get(0).getVersion());
        }
        if(CollectionUtils.isNotEmpty(lastUsableList)){
            map.put("lastUsableVersion",lastUsableList.get(0).getVersion());
        }
        return map;
    }
 
    @Override
    public List<WorkCenter> getLastUsableVersion() {
        return workCenterMapper.getLastUsableList();
    }
 
    @Override
    public Integer getInitVersion() {
        List<WorkCenter> usableVersionList = baseMapper.getUsableList();
        Set<Integer> versionList = getVersionList();
        if(CollectionUtils.isNotEmpty(usableVersionList)){
            return usableVersionList.get(0).getVersion();
        }else if(CollectionUtils.isNotEmpty(versionList)){
            return versionList.stream().findFirst().get();
        }
        return null;
    }
    @Override
    public List<String> getVersionStatusByVersion(Integer version) {
        return baseMapper.getVersionStatusByVersion(version);
    }
 
    @Override
    public List<Map<String, Object>> getFactoryVersionList() {
        return baseMapper.getFactoryVersionList();
    }
 
    @Override
    public List<Map<String, Object>> getEquipmentCategoryListByEnterpriseId(String enterpriseId) {
        return workCenterMapper.getEquipmentCategoryListByEnterpriseId(enterpriseId);
    }
    /**
     * 获取叶子节点
     * @param
     * @return
     */
    public List<String> trueGetLeaves(Integer version,String parentId){
        List<FactoryModel> children = factoryModelMapper.selectList(
                new QueryWrapper<FactoryModel>()
                        .eq("parent_id",parentId)
                        .eq("version",version)
                        .eq("del_flag",0)
        );
        List<String> leaves = new ArrayList<>();
        if(CollectionUtils.isNotEmpty(children)){
            children.forEach(factoryModel -> {
                String id = factoryModel.getId();
                if(
                        CollectionUtils.isEmpty(
                               factoryModelMapper.selectList(new QueryWrapper<FactoryModel>()
                                        .eq("parent_id",id)
                                        .eq("version",version)
                                        .eq("del_flag",0)))
                ){
                    leaves.add(id);
                }
                else {
                    leaves.addAll(trueGetLeaves(version,id));
                }
            });
        }
        else {
            leaves.add(parentId);
        }
        return leaves;
    }
 
 
}