安全隐患基础功能

龚焕茏

2024-03-01 d17e1cf11d255c68e0bd8c455badb776d64f346b

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
package org.dromara.demo.service.impl;
 
import org.dromara.common.core.utils.MapstructUtils;
import org.dromara.common.core.utils.StringUtils;
import org.dromara.common.mybatis.core.page.TableDataInfo;
import org.dromara.common.mybatis.core.page.PageQuery;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import org.dromara.demo.domain.bo.RsDangerInfoBo;
import org.dromara.demo.domain.vo.RsDangerInfoVo;
import org.dromara.demo.domain.RsDangerInfo;
import org.dromara.demo.mapper.RsDangerInfoMapper;
import org.dromara.demo.service.IRsDangerInfoService;
 
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.Collection;
import java.util.stream.Collectors;
 
/**
 * 安全隐患信息Service业务层处理
 *
 * @author gonghl
 * @date 2024-02-27
 */
@RequiredArgsConstructor
@Service
public class RsDangerInfoServiceImpl implements IRsDangerInfoService {
 
    private final RsDangerInfoMapper baseMapper;
 
    /**
     * 查询安全隐患信息
     */
    @Override
    public RsDangerInfoVo queryById(Long id){
        return baseMapper.selectVoById(id);
    }
 
    /**
     * 查询安全隐患信息列表
     */
    @Override
    public TableDataInfo<RsDangerInfoVo> queryPageList(RsDangerInfoBo bo, PageQuery pageQuery) {
        LambdaQueryWrapper<RsDangerInfo> lqw = buildQueryWrapper(bo);
        Page<RsDangerInfoVo> result = baseMapper.selectVoPage(pageQuery.build(), lqw);
        return TableDataInfo.build(result);
    }
 
    /**
     * 查询安全隐患信息列表
     */
    @Override
    public List<RsDangerInfoVo> queryList(RsDangerInfoBo bo) {
        LambdaQueryWrapper<RsDangerInfo> lqw = buildQueryWrapper(bo);
        return baseMapper.selectVoList(lqw);
    }
 
    private LambdaQueryWrapper<RsDangerInfo> buildQueryWrapper(RsDangerInfoBo bo) {
        Map<String, Object> params = bo.getParams();
        LambdaQueryWrapper<RsDangerInfo> lqw = Wrappers.lambdaQuery();
        lqw.eq(StringUtils.isNotBlank(bo.getNotificationTime()), RsDangerInfo::getNotificationTime, bo.getNotificationTime());
        lqw.eq(StringUtils.isNotBlank(bo.getDangerType()), RsDangerInfo::getDangerType, bo.getDangerType());
        lqw.eq(StringUtils.isNotBlank(bo.getAccountabilityUnit()), RsDangerInfo::getAccountabilityUnit, bo.getAccountabilityUnit());
        lqw.eq(StringUtils.isNotBlank(bo.getRectificationTimeLimit()), RsDangerInfo::getRectificationTimeLimit, bo.getRectificationTimeLimit());
        lqw.eq(StringUtils.isNotBlank(bo.getPerformance()), RsDangerInfo::getPerformance, bo.getPerformance());
        lqw.eq(bo.getStatus() != null, RsDangerInfo::getStatus, bo.getStatus());
        lqw.orderByDesc(RsDangerInfo::getCreateTime);
        return lqw;
    }
 
    /**
     * 新增安全隐患信息
     */
    @Override
    public Boolean insertByBo(RsDangerInfoBo bo) {
        RsDangerInfo add = MapstructUtils.convert(bo, RsDangerInfo.class);
        validEntityBeforeSave(add);
        boolean flag = baseMapper.insert(add) > 0;
        if (flag) {
            bo.setId(add.getId());
        }
        return flag;
    }
 
    /**
     * 修改安全隐患信息
     */
    @Override
    public Boolean updateByBo(RsDangerInfoBo bo) {
        RsDangerInfo update = MapstructUtils.convert(bo, RsDangerInfo.class);
        validEntityBeforeSave(update);
        return baseMapper.updateById(update) > 0;
    }
 
    /**
     * 保存前的数据校验
     */
    private void validEntityBeforeSave(RsDangerInfo entity){
        // 创建时间
        if (entity.getCreateTime() == null) {
            entity.setCreateTime(new Date());
        }
    }
 
    /**
     * 批量删除安全隐患信息
     */
    @Override
    public Boolean deleteWithValidByIds(Collection<Long> ids, Boolean isValid) {
        if(isValid){
            //TODO 做一些业务上的校验,判断是否需要校验
        }
        return baseMapper.deleteBatchIds(ids) > 0;
    }
 
    /**
     * 获取隐患类型
     * @return 隐患类型查询条件
     */
    @Override
    public List<RsDangerInfoVo> getDangerType() {
        LambdaQueryWrapper<RsDangerInfo> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.groupBy(RsDangerInfo::getDangerType).select(RsDangerInfo::getDangerType).orderByAsc(RsDangerInfo::getCreateTime);
        return baseMapper.selectVoList(queryWrapper);
    }
}