设备异常反馈

Lius

2025-05-21 00ad5059c67d083fddc176603b29ed8aafcf45d9

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
package org.jeecg.modules.mdc.service.impl;
 
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.apache.shiro.SecurityUtils;
import org.jeecg.common.system.vo.LoginUser;
import org.jeecg.modules.mdc.constant.MdcConstant;
import org.jeecg.modules.mdc.entity.MdcMessageApproval;
import org.jeecg.modules.mdc.mapper.MdcMessageApprovalMapper;
import org.jeecg.modules.mdc.service.IMdcMessageApprovalService;
import org.jeecg.modules.system.entity.SysUser;
import org.jeecg.modules.system.service.ISysUserService;
import org.springframework.stereotype.Service;
 
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
import java.util.stream.Collectors;
 
/**
 * @Description: mdc消息确认表
 * @Author: Lius
 * @Date: 2024-03-06
 * @Version: V1.0
 */
@Service
public class MdcMessageApprovalServiceImpl extends ServiceImpl<MdcMessageApprovalMapper, MdcMessageApproval> implements IMdcMessageApprovalService {
 
    @Resource
    private ISysUserService sysUserService;
 
    /**
     * 别表查询
     */
    @Override
    public IPage<MdcMessageApproval> pageList(String userId, Page<MdcMessageApproval> page, MdcMessageApproval mdcMessageApproval, HttpServletRequest req) {
        IPage<MdcMessageApproval> pageList = this.baseMapper.pageList(userId, page, mdcMessageApproval);
        List<MdcMessageApproval> mdcMessageApprovalList = pageList.getRecords();
        if (mdcMessageApprovalList != null && !mdcMessageApprovalList.isEmpty()) {
            pageList.getRecords().forEach(item -> {
                if (item.getSenderIds().contains(userId) && (item.getMsgStatus().equals(MdcConstant.MSG_STATUS_0) || item.getMsgStatus().equals(MdcConstant.MSG_STATUS_3))) {
                    item.setHasProcess(true);
                }
                if (item.getApproverIds().contains(userId) && item.getMsgStatus().equals(MdcConstant.MSG_STATUS_1)) {
                    item.setHasConfirm(true);
                }
            });
        }
        return pageList;
    }
 
    @Override
    public boolean add(MdcMessageApproval mdcMessageApproval) {
        boolean result = false;
        LoginUser user = (LoginUser) SecurityUtils.getSubject().getPrincipal();
        mdcMessageApproval.setSenderIds(user.getId());
        mdcMessageApproval.setSenderNames(user.getRealname());
        // 查询设备超级管理员
        List<SysUser> superList = sysUserService.getEquipmentAdmin(MdcConstant.MDC_EQUIPMENT_SUPER_MANAGER, mdcMessageApproval.getEquipmentId());
        if (superList != null && !superList.isEmpty()) {
            List<String> superIdList = superList.stream().map(SysUser::getId).collect(Collectors.toList());
            mdcMessageApproval.setApproverIds(String.join(",", superIdList));
            List<String> superNameList = superList.stream().map(SysUser::getRealname).collect(Collectors.toList());
            mdcMessageApproval.setApproverNames(String.join(",", superNameList));
        }
        mdcMessageApproval.setMsgStatus(MdcConstant.MSG_STATUS_0);
        return result;
    }
}