审查接口修改，装备字段新增，指令查询接口修改

Administrator

2021-08-13 6038dbee0781f023397d36c3f27d92a0ac9b8bc7

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
package org.springblade.modules.directive.service.impl;
 
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import lombok.AllArgsConstructor;
import org.springblade.modules.directive.entity.Directive;
import org.springblade.modules.directive.entity.DirectiveFile;
import org.springblade.modules.directive.mapper.DirectiveMapper;
import org.springblade.modules.directive.service.DirectiveService;
import org.springblade.modules.directive.vo.DirectiveVo;
import org.springblade.modules.system.entity.User;
import org.springblade.modules.system.service.IUserService;
import org.springframework.stereotype.Service;
 
import java.util.List;
 
/**
 * 指令服务实现类
 * @author zhongrj
 */
@Service
@AllArgsConstructor
public class DirectiveServiceImpl extends ServiceImpl<DirectiveMapper, Directive> implements DirectiveService {
 
    private final IUserService userService;
 
 
 
    /**
     * 指令分页信息
     * @param page
     * @param directive 指令信息对象
     * @return
     */
    @Override
    public IPage<DirectiveVo> selectDirectivePage(IPage<DirectiveVo> page, DirectiveVo directive) {
        IPage<DirectiveVo> directiveVoIPage = page.setRecords(baseMapper.selectDirectivePage(page, directive));
        //去除接收人ids,查询出接收人名字
        List<DirectiveVo> records = directiveVoIPage.getRecords();
        System.out.println("records = " + records);
        if (records.size()>0) {
            for (DirectiveVo record : records) {
                String[] receiveDirectiveIds = record.getReceiveDirectiveIds().toString().split(",");
                StringBuilder builder = new StringBuilder();
                for (String receiveDirectiveId : receiveDirectiveIds) {
                    User user = userService.getById(receiveDirectiveId);
                    builder.append(user.getRealName()).append(",");
                }
                //查询图片
                List<DirectiveFile> directiveFiles = baseMapper.getDirectiveFileList(record.getId());
                if (directiveFiles.size() > 0) {
                    StringBuilder builderFile = new StringBuilder();
                    for (DirectiveFile directiveFile : directiveFiles) {
                        builderFile.append(directiveFile.getUrl()).append(",");
                    }
                    String urls = builderFile.toString();
                    record.setUrl(urls.substring(0, urls.length() - 1));
                }
                record.setReceiveName(builder.toString().substring(0, builder.toString().length() - 1));
            }
        }
        return directiveVoIPage;
    }
 
    /**
     * 详情
     * @param directive 指令信息对象
     */
    @Override
    public DirectiveVo selectDirectiveInfo(Directive directive) {
        return baseMapper.selectDirectiveInfo(directive);
    }
 
 
    /**
     * 插入图片
     * @param directiveFile
     * @return
     */
    @Override
    public boolean saveDirectiveFile(DirectiveFile directiveFile) {
        int i = baseMapper.saveDirectiveFile(directiveFile);
        if (i>0){
            return true;
        }
        return false;
    }
 
    /**
     * 删除图片
     * @param id 指令id
     * @return
     */
    @Override
    public int deleleByDirectiveId(Long id) {
        return baseMapper.deleteByDirectiveId(id);
    }
 
    /**
     * 自定义分页--接收到的指令
     * @param page,size
     * @param directive 指令对象
     */
    @Override
    public IPage<DirectiveVo> selectDirectiveReplyPage(IPage<DirectiveVo> page, DirectiveVo directive) {
        IPage<DirectiveVo> directiveVoIPage = page.setRecords(baseMapper.selectDirectiveReplyPage(page, directive));
        List<DirectiveVo> records = directiveVoIPage.getRecords();
        for (DirectiveVo record : records) {
//            String[] receiveDirectiveIds = record.getReceiveDirectiveIds().toString().split(",");
//            StringBuilder builder = new StringBuilder();
//            for (String receiveDirectiveId : receiveDirectiveIds) {
//                User user = userService.getById(receiveDirectiveId);
//                builder.append(user.getRealName()).append(",");
//            }
            //查询图片
            List<DirectiveFile> directiveFiles = baseMapper.getDirectiveFileList(record.getId());
            if (directiveFiles.size()>0){
                StringBuilder builderFile = new StringBuilder();
                for (DirectiveFile directiveFile : directiveFiles) {
                    builderFile.append(directiveFile.getUrl()).append(",");
                }
                String urls = builderFile.toString();
                record.setUrl(urls.substring(0, urls.length() - 1));
            }
//            record.setReceiveName(builder.toString().substring(0, builder.toString().length() - 1));
        }
        return directiveVoIPage;
    }
}