唐耀东
2022-08-22 83187f51aef5692354bd88ed166a748e32cc78fb
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
package com.ruoyi.oa.service.impl;
 
import cn.hutool.core.bean.BeanUtil;
import cn.hutool.http.HttpStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.StringUtils;
import com.ruoyi.oa.domain.BsSchool;
import com.ruoyi.oa.domain.SgReserveIp;
import com.ruoyi.oa.mapper.BsSchoolMapper;
import com.ruoyi.oa.mapper.SgReserveIpMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.ruoyi.common.core.mybatisplus.core.ServicePlusImpl;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.ruoyi.oa.domain.bo.BsBuildingBo;
import com.ruoyi.oa.domain.vo.BsBuildingVo;
import com.ruoyi.oa.domain.BsBuilding;
import com.ruoyi.oa.mapper.BsBuildingMapper;
import com.ruoyi.oa.service.IBsBuildingService;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.List;
import java.util.Map;
import java.util.Collection;
 
/**
 * 建筑单元Service业务层处理
 *
 * @author ruoyi
 * @date 2022-05-10
 */
@Service
public class BsBuildingServiceImpl extends ServicePlusImpl<BsBuildingMapper, BsBuilding, BsBuildingVo> implements IBsBuildingService {
 
    @Autowired
    private BsSchoolMapper schoolMapper;
 
    @Autowired
    private SgReserveIpMapper reserveIpMapper;
 
    @Override
    public BsBuildingVo queryById(Long id) {
        return getVoById(id);
    }
 
 
    @Override
    public List<BsBuildingVo> queryList(BsBuildingBo bo) {
        return listVo(buildQueryWrapper(bo));
    }
 
    private LambdaQueryWrapper<BsBuilding> buildQueryWrapper(BsBuildingBo bo) {
        Map<String, Object> params = bo.getParams();
        LambdaQueryWrapper<BsBuilding> lqw = Wrappers.lambdaQuery();
        lqw.like(StringUtils.isNotBlank(bo.getCode()), BsBuilding::getCode, bo.getCode());
        lqw.like(StringUtils.isNotBlank(bo.getName()), BsBuilding::getName, bo.getName());
        lqw.eq(BsBuilding::getSchoolId, bo.getSchoolId());
        lqw.orderByAsc(BsBuilding::getOrderNum);
        return lqw;
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean insertByBo(BsBuildingBo bo) {
        List<BsBuilding> list = baseMapper.selectList(new LambdaQueryWrapper<BsBuilding>()
            .eq(BsBuilding::getSchoolId, bo.getSchoolId()).eq(BsBuilding::getCode, bo.getCode()));
        if (list.size() > 0) {
            throw new ServiceException("单元编号重复", HttpStatus.HTTP_PARTIAL);
        }
        BsBuilding add = BeanUtil.toBean(bo, BsBuilding.class);
        if (bo.getParentId() == Long.valueOf(0)) {
            BsSchool school = schoolMapper.selectById(bo.getSchoolId());
            add.setAncestors("0");
            add.setDetailedName(school.getName() + "-" + bo.getName());
        } else {
            BsBuilding info = baseMapper.selectById(bo.getParentId());
            add.setAncestors(info.getAncestors() + "," + bo.getParentId());
            add.setDetailedName(info.getDetailedName() + "-" + bo.getName());
        }
        boolean flag = save(add);
        if (flag) {
            bo.setId(add.getId());
        }
        return flag;
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean updateByBo(BsBuildingBo bo) {
        List<BsBuilding> list = baseMapper.selectList(new LambdaQueryWrapper<BsBuilding>()
            .ne(BsBuilding::getId, bo.getId())
            .eq(BsBuilding::getSchoolId, bo.getSchoolId())
            .eq(BsBuilding::getCode, bo.getCode()));
        if (list.size() > 0) {
            throw new ServiceException("单元编号重复", HttpStatus.HTTP_PARTIAL);
        }
        BsBuilding update = BeanUtil.toBean(bo, BsBuilding.class);
        if (bo.getParentId() == Long.valueOf(0)) {
            BsSchool school = schoolMapper.selectById(bo.getSchoolId());
            update.setAncestors("0");
            update.setDetailedName(school.getName() + "-" + bo.getName());
        } else {
            BsBuilding info = baseMapper.selectById(bo.getParentId());
            update.setAncestors(info.getAncestors() + "," + bo.getParentId());
            update.setDetailedName(info.getDetailedName() + "-" + bo.getName());
        }
        validEntityBeforeSave(update);
        return updateById(update);
    }
 
    /**
     * 保存前的数据校验
     *
     * @param entity 实体类数据
     */
    private void validEntityBeforeSave(BsBuilding entity) {
        //TODO 做一些数据校验,如唯一约束
    }
 
    @Override
    @Transactional(rollbackFor = Exception.class)
    public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
        List<BsBuilding> list = baseMapper.selectList(new LambdaQueryWrapper<BsBuilding>()
            .in(BsBuilding::getParentId, ids));
        if (list.size() > 0) {
            throw new ServiceException("存在子建筑单元,不允许删除", HttpStatus.HTTP_PARTIAL);
        }
        List<SgReserveIp> ipList = reserveIpMapper.selectList(new LambdaQueryWrapper<SgReserveIp>()
            .in(SgReserveIp::getBuildingId, ids));
        if (ipList.size() > 0) {
            throw new ServiceException("建筑单元已被[预留IP模块]使用,不允许删除", HttpStatus.HTTP_PARTIAL);
        }
        return removeByIds(ids);
    }
}