2021与蓝度共同重构项目,服务端
liuhaonan
2022-08-15 5c3a5b7bf75718a003de4b167cf9fc81a27f06ee
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
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
package com.sandu.ximon.admin.service;
 
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.common.util.SpringContextHolder;
import com.sandu.ximon.admin.param.InterphoneHostParam;
import com.sandu.ximon.admin.security.SecurityUtils;
import com.sandu.ximon.admin.utils.StoreOperationRecordsUtils;
import com.sandu.ximon.dao.bo.InterphoneHostBo;
import com.sandu.ximon.dao.domain.InterphoneHost;
import com.sandu.ximon.dao.domain.InterphoneHostSubPole;
import com.sandu.ximon.dao.enums.PoleBindingEnums;
import com.sandu.ximon.dao.mapper.InterphoneHostMapper;
import lombok.AllArgsConstructor;
import org.springframework.beans.BeanUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import java.util.ArrayList;
import java.util.List;
 
@Service
@AllArgsConstructor
public class InterphoneHostService extends BaseServiceImpl<InterphoneHostMapper, InterphoneHost> {
 
    private final InterphoneHostMapper interphoneHostMapper;
 
    private final InterphoneHostSubService interphoneHostSubService;
 
 
    /**
     * 添加主机
     */
    public boolean addHost(InterphoneHostParam interphoneHostParam) {
        List<InterphoneHost> list = list(Wrappers.lambdaQuery(InterphoneHost.class).eq(InterphoneHost::getHostMac, interphoneHostParam.getHostMac()));
        if (list.size() > 0) {
            throw new BusinessException("该设备已存在");
        }
        InterphoneHost interphoneHost = new InterphoneHost();
        BeanUtils.copyProperties(interphoneHostParam, interphoneHost);
        boolean save = save(interphoneHost);
        /**
         * 添加一键求助主机 日志记录开始
         */
        List<String> listCode = new ArrayList<>(1);
        listCode.add(interphoneHost.getHostMac());
        String content = "{ 设备id:" + interphoneHost.getHostId() + "设备code:" + interphoneHost.getHostMac() +
                "}";
 
        StoreOperationRecordsUtils.storeOperationData(listCode, null, "添加一键求助主机", content);
        /**
         * 添加一键求助主机 日志记录结束
         */
 
        return save;
    }
 
    /**
     * 修改主机
     */
    @Transactional(rollbackFor = Exception.class)
    public boolean updateHost(Integer id, InterphoneHostParam interphoneHostParam) {
        InterphoneHost byId = getById(id);
        if (byId == null) {
            return false;
        }
 
        if (SecurityUtils.getClientId() != null) {
            boolean belong = SpringContextHolder.getBean(PoleBindingService.class).isBelong(byId.getHostMac(), PoleBindingEnums.FOR_HELP);
            if (!belong) {
                throw new BusinessException("该设备不属于您,不能修改设备信息");
            }
        }
        InterphoneHost interphoneHost = new InterphoneHost();
        interphoneHost.setHostId(id);
        BeanUtils.copyProperties(interphoneHostParam, interphoneHost);
 
        /**
         * 编辑一键求助主机 日志记录开始
         */
        List<String> listCode = new ArrayList<>(1);
        listCode.add(interphoneHost.getHostMac());
        String content = "{ 设备id:" + interphoneHost.getHostId() + "设备code:" + interphoneHost.getHostMac() +
                "}";
 
        StoreOperationRecordsUtils.storeOperationData(listCode, null, "编辑一键求助主机", content);
        /**
         * 编辑一键求助主机 日志记录结束
         */
        boolean b = updateById(interphoneHost);
        List<InterphoneHost> list = list(Wrappers.lambdaQuery(InterphoneHost.class).eq(InterphoneHost::getHostMac, interphoneHostParam.getHostMac()));
        if (list.size() > 1) {
            throw new BusinessException("请检查设备mac是否重复");
        }
        return b;
    }
 
    /**
     * 删除主机
     *
     * @param id
     * @return
     */
    public boolean deleteHost(Integer id) {
        InterphoneHost byId = getById(id);
 
        if (byId == null) {
            throw new BusinessException("主机不存在!");
        }
 
        InterphoneHostSubPole one = interphoneHostSubService.getOne(Wrappers.lambdaQuery(InterphoneHostSubPole.class).eq(InterphoneHostSubPole::getHostId, id));
        if (one != null) {
            throw new BusinessException("该主机存在绑定关系,不能删除");
        }
 
        /**
         * 删除一键求助主机 日志记录开始
         */
        List<String> listCode = new ArrayList<>(1);
        listCode.add(byId.getHostMac());
        String content = "{ 设备id:" + byId.getHostId() + "设备code:" + byId.getHostMac() +
                "}";
 
        StoreOperationRecordsUtils.storeOperationData(listCode, null, "删除一键求助主机", content);
        /**
         * 删除一键求助主机 日志记录结束
         */
 
        return removeById(id);
    }
 
    /**
     * 查询主机
     *
     * @param id
     * @return
     */
    public InterphoneHost getHost(Integer id) {
        InterphoneHost byId = getById(id);
        if (byId == null) {
            return null;
        }
        return byId;
    }
 
    /**
     * 查询主机列表
     */
    public List<InterphoneHostBo> getInterphoneHostList(BaseConditionVO baseConditionVO, String keyword) {
        if (baseConditionVO != null) {
            PageHelper.startPage(baseConditionVO.getPageNo(), baseConditionVO.getPageSize());
        }
        List<InterphoneHostBo> list;
        if (SecurityUtils.getClientId() == null) {
            list = interphoneHostMapper.getInterphoneHostList(keyword, null);
        } else {
            list = interphoneHostMapper.getInterphoneHostList(keyword, SecurityUtils.getUserId());
        }
        return list;
    }
}