Changes14

Fixiaobai

2023-11-16 d8d129a2e41f7099968cb4f4dc1b028ab985135f

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
package com.chinaztt.mes.basic.service.impl;
 
import cn.hutool.core.collection.CollectionUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.chinaztt.mes.basic.dto.CrewDTO;
import com.chinaztt.mes.basic.entity.Crew;
import com.chinaztt.mes.basic.entity.JoinCrewStaff;
import com.chinaztt.mes.basic.entity.Staff;
import com.chinaztt.mes.basic.excel.CrewData;
import com.chinaztt.mes.basic.mapper.CrewMapper;
import com.chinaztt.mes.basic.mapper.JoinCrewStaffMapper;
import com.chinaztt.mes.basic.mapper.StaffMapper;
import com.chinaztt.mes.basic.service.CrewService;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.List;
import java.util.Objects;
 
/**
 * 人员班组维护表
 *
 * @author cxf
 * @date 2020-12-01 09:58:28
 */
@Service
@AllArgsConstructor
@Transactional(rollbackFor = Exception.class)
public class CrewServiceImpl extends ServiceImpl<CrewMapper, Crew> implements CrewService {
 
    private JoinCrewStaffMapper joinCrewStaffMapper;
    private StaffMapper staffMapper;
 
 
    @Override
    public boolean updateDtoById(CrewDTO crewDTO) {
        try {
            baseMapper.updateById(crewDTO);
        } catch (Exception e) {
            throw new RuntimeException("班组修改失败");
        }
        return true;
    }
 
    @Override
    public boolean deleteById(Long id) {
        try {
            baseMapper.deleteById(id);
            joinCrewStaffMapper.delete(Wrappers.<JoinCrewStaff>lambdaQuery().eq(JoinCrewStaff::getCrewId, id));
        } catch (Exception e) {
            throw new RuntimeException("班组删除失败");
        }
        return true;
    }
 
    @Override
    public IPage<List<Staff>> getStaffByCrewId(Page page, QueryWrapper<Staff> ew) {
        return staffMapper.selectStaffByCrewId(page, ew);
    }
 
    @Override
    public boolean saveDto(CrewDTO crewDTO) {
        saveJoin(crewDTO);
        return false;
    }
 
    @Override
    public boolean deleteStaff(CrewDTO crewDTO) {
        crewDTO.getStaffList().forEach(staff -> {
            joinCrewStaffMapper.delete(Wrappers.<JoinCrewStaff>lambdaQuery().eq(JoinCrewStaff::getCrewId, crewDTO.getId()).eq(JoinCrewStaff::getStaffId, staff.getId()));
        });
        return false;
    }
 
    @Override
    public List<Staff> getStaff(CrewDTO crewDTO) {
        return staffMapper.selectStaffById(crewDTO.getId());
    }
 
    //导入excel数据
    @Override
    public void importWorkstationExcel(List<CrewData> list) {
        if (CollectionUtil.isEmpty(list)) {
            return;
        }
        List<Staff> staff = staffMapper.selectList(null);
        Crew crew = new Crew();
        for (CrewData data : list) {
            QueryWrapper<Crew>QueryWrapper = new QueryWrapper<>();
            QueryWrapper.lambda().eq(Crew::getCrewName,data.getCrewName());
            Crew crew1 = baseMapper.selectOne(QueryWrapper);
            if(!Objects.isNull(crew1)){
                log.error("班组名重复====》"+crew1.getCrewName());
                continue;
            }
            //新增班组表
            if (ObjectUtils.isNotEmpty(data.getCrewName())) {
                crew.setCrewName(data.getCrewName());
                crew.setWorkShop(data.getWorkShop());
                baseMapper.insert(crew);
            }
            JoinCrewStaff joinCrewStaff = new JoinCrewStaff();
            joinCrewStaff.setCrewId(crew.getId());
            for (int i = 0; i < staff.size(); i++) {
                if (staff.get(i).getStaffNo().equals(data.getStaffNo())) {
                    joinCrewStaff.setStaffId(staff.get(i).getId());
                }
            }
            if (joinCrewStaff.getStaffId() == null) {
                log.error("人员:" + data.getStaffNo() + "不存在");
                continue;
            }
            //新增人员班组维护表
            joinCrewStaffMapper.insert(joinCrewStaff);
        }
    }
 
    public void saveJoin(CrewDTO crewDTO) {
        if (CollectionUtil.isNotEmpty(crewDTO.getStaffList())) {
            List<Staff> staffList = joinCrewStaffMapper.selectStaffByCrewId(crewDTO.getId());
            crewDTO.getStaffList().stream()
                    .filter(newStaff -> {
                        for (int i = 0; i < staffList.size(); i++) {
                            if (staffList.get(i).getId().equals(newStaff.getId())) {
                                return false;
                            }
                        }
                        return true;
                    }).forEach(newStaff -> {
                JoinCrewStaff joinCrewStaff = new JoinCrewStaff();
                joinCrewStaff.setCrewId(crewDTO.getId());
                joinCrewStaff.setStaffId(newStaff.getId());
                joinCrewStaffMapper.insert(joinCrewStaff);
            });
        }
    }
}