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
package cn.iocoder.yudao.module.research.controller.admin.guideline;
 
import cn.hutool.core.collection.CollUtil;
import cn.iocoder.yudao.framework.common.pojo.CommonResult;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.number.NumberUtils;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.research.controller.admin.guideline.vo.ResearchGuidelinePageReqVO;
import cn.iocoder.yudao.module.research.controller.admin.guideline.vo.ResearchGuidelineRespVO;
import cn.iocoder.yudao.module.research.controller.admin.guideline.vo.ResearchGuidelineSaveReqVO;
import cn.iocoder.yudao.module.research.dal.dataobject.guideline.ResearchGuidelineDO;
import cn.iocoder.yudao.module.research.service.guideline.ResearchGuidelineService;
import cn.iocoder.yudao.module.research.service.guideline.ResearchGuidelineServiceImpl;
import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
import cn.iocoder.yudao.module.system.api.storage.dto.StorageBlobRespDTO;
import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.annotation.Resource;
import jakarta.validation.Valid;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
 
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
 
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
import static cn.iocoder.yudao.framework.common.util.collection.MapUtils.findAndThen;
 
@Tag(name = "管理后台 - 课题指南")
@RestController
@RequestMapping("/research/guideline")
@Validated
public class ResearchGuidelineController {
 
    public static final String GUIDELINE_RECORD_TYPE =
            ResearchGuidelineServiceImpl.GUIDELINE_RECORD_TYPE;
 
    @Resource
    private ResearchGuidelineService guidelineService;
 
    @Resource
    private AdminUserApi adminUserApi;
 
    @Resource
    private StorageAttachmentApi storageAttachmentApi;
 
    @PostMapping("/create")
    @Operation(summary = "创建课题指南")
    @PreAuthorize("@ss.hasPermission('research:guideline:create')")
    public CommonResult<Long> createGuideline(@Valid @RequestBody ResearchGuidelineSaveReqVO createReqVO) {
        return success(guidelineService.createGuideline(createReqVO));
    }
 
    @PutMapping("/update")
    @Operation(summary = "更新课题指南")
    @PreAuthorize("@ss.hasPermission('research:guideline:update')")
    public CommonResult<Boolean> updateGuideline(@Valid @RequestBody ResearchGuidelineSaveReqVO updateReqVO) {
        guidelineService.updateGuideline(updateReqVO);
        return success(true);
    }
 
    @DeleteMapping("/delete")
    @Operation(summary = "删除课题指南")
    @Parameter(name = "id", description = "编号", required = true)
    @PreAuthorize("@ss.hasPermission('research:guideline:delete')")
    public CommonResult<Boolean> deleteGuideline(@RequestParam("id") Long id) {
        guidelineService.deleteGuideline(id);
        return success(true);
    }
 
    @GetMapping("/get")
    @Operation(summary = "获得课题指南")
    @Parameter(name = "id", description = "编号", required = true, example = "1024")
    @PreAuthorize("@ss.hasPermission('research:guideline:query')")
    public CommonResult<ResearchGuidelineRespVO> getGuideline(@RequestParam("id") Long id) {
        return success(buildGuidelineDetail(guidelineService.getGuideline(id)));
    }
 
    @GetMapping("/page")
    @Operation(summary = "获得课题指南分页")
    @PreAuthorize("@ss.hasPermission('research:guideline:query')")
    public CommonResult<PageResult<ResearchGuidelineRespVO>> getGuidelinePage(
            @Valid ResearchGuidelinePageReqVO pageReqVO) {
        PageResult<ResearchGuidelineDO> pageResult = guidelineService.getGuidelinePage(pageReqVO);
        return success(new PageResult<>(buildGuidelineDetailList(pageResult.getList()), pageResult.getTotal()));
    }
 
    @GetMapping("/published-list")
    @Operation(summary = "获得已发布的课题指南列表(供申报选指南)")
    @PreAuthorize("@ss.hasPermission('research:guideline:query')")
    public CommonResult<List<ResearchGuidelineRespVO>> getPublishedGuidelineList() {
        return success(buildGuidelineDetailList(guidelineService.getPublishedGuidelineList()));
    }
 
    @PutMapping("/publish")
    @Operation(summary = "发布课题指南")
    @Parameter(name = "id", description = "编号", required = true)
    @PreAuthorize("@ss.hasPermission('research:guideline:publish')")
    public CommonResult<Boolean> publishGuideline(@RequestParam("id") Long id) {
        guidelineService.publishGuideline(id);
        return success(true);
    }
 
    @PutMapping("/close")
    @Operation(summary = "截止课题指南")
    @Parameter(name = "id", description = "编号", required = true)
    @PreAuthorize("@ss.hasPermission('research:guideline:publish')")
    public CommonResult<Boolean> closeGuideline(@RequestParam("id") Long id) {
        guidelineService.closeGuideline(id);
        return success(true);
    }
 
    // ==================== 内部方法 ====================
 
    private ResearchGuidelineRespVO buildGuidelineDetail(ResearchGuidelineDO guideline) {
        if (guideline == null) {
            return null;
        }
        return buildGuidelineDetailList(Collections.singletonList(guideline)).get(0);
    }
 
    private List<ResearchGuidelineRespVO> buildGuidelineDetailList(List<ResearchGuidelineDO> list) {
        if (CollUtil.isEmpty(list)) {
            return Collections.emptyList();
        }
 
        // 1.1 获取创建人
        Set<Long> creatorIds = convertSet(list, guideline -> NumberUtils.parseLong(guideline.getCreator()));
        Map<Long, AdminUserRespDTO> creatorMap = adminUserApi.getUserMap(creatorIds);
        // 1.2 获取附件
        Map<Long, List<StorageBlobRespDTO>> attachmentMap = list.stream()
                .collect(Collectors.toMap(ResearchGuidelineDO::getId,
                        r -> storageAttachmentApi.listAttachments(GUIDELINE_RECORD_TYPE, r.getId())));
 
        // 2. 拼接结果
        return BeanUtils.toBean(list, ResearchGuidelineRespVO.class, (vo) -> {
            findAndThen(creatorMap, NumberUtils.parseLong(vo.getCreator()),
                    user -> vo.setCreatorName(user.getNickname()));
            List<StorageBlobRespDTO> attachments = attachmentMap.getOrDefault(vo.getId(), Collections.emptyList());
            vo.setAttachmentList(attachments);
            vo.setHasAttachment(CollUtil.isNotEmpty(attachments));
        });
    }
 
}