/
MpFreePublishController.java
119 lines (106 loc) · 5.66 KB
/
MpFreePublishController.java
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
package cn.iocoder.yudao.module.mp.controller.admin.news;
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.collection.CollectionUtils;
import cn.iocoder.yudao.framework.common.util.object.PageUtils;
import cn.iocoder.yudao.module.mp.controller.admin.news.vo.MpFreePublishPageReqVO;
import cn.iocoder.yudao.module.mp.dal.dataobject.material.MpMaterialDO;
import cn.iocoder.yudao.module.mp.framework.mp.core.MpServiceFactory;
import cn.iocoder.yudao.module.mp.service.material.MpMaterialService;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
import io.swagger.v3.oas.annotations.Parameters;
import io.swagger.v3.oas.annotations.tags.Tag;
import me.chanjar.weixin.common.error.WxErrorException;
import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.bean.freepublish.WxMpFreePublishItem;
import me.chanjar.weixin.mp.bean.freepublish.WxMpFreePublishList;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
import static cn.iocoder.yudao.framework.common.util.collection.MapUtils.findAndThen;
import static cn.iocoder.yudao.module.mp.enums.ErrorCodeConstants.*;
@Tag(name = "管理后台 - 公众号发布能力")
@RestController
@RequestMapping("/mp/free-publish")
@Validated
public class MpFreePublishController {
@Resource
private MpServiceFactory mpServiceFactory;
@Resource
private MpMaterialService mpMaterialService;
@GetMapping("/page")
@Operation(summary = "获得已发布的图文分页")
@PreAuthorize("@ss.hasPermission('mp:free-publish:query')")
public CommonResult<PageResult<WxMpFreePublishItem>> getFreePublishPage(MpFreePublishPageReqVO reqVO) {
// 从公众号查询已发布的图文列表
WxMpService mpService = mpServiceFactory.getRequiredMpService(reqVO.getAccountId());
WxMpFreePublishList publicationRecords;
try {
publicationRecords = mpService.getFreePublishService().getPublicationRecords(
PageUtils.getStart(reqVO), reqVO.getPageSize());
} catch (WxErrorException e) {
throw exception(FREE_PUBLISH_LIST_FAIL, e.getError().getErrorMsg());
}
// 查询对应的图片地址。目的:解决公众号的图片链接无法在我们后台展示
setFreePublishThumbUrl(publicationRecords.getItems());
// 返回分页
return success(new PageResult<>(publicationRecords.getItems(), publicationRecords.getTotalCount().longValue()));
}
private void setFreePublishThumbUrl(List<WxMpFreePublishItem> items) {
// 1.1 获得 mediaId 数组
Set<String> mediaIds = new HashSet<>();
items.forEach(item -> item.getContent().getNewsItem().forEach(newsItem -> mediaIds.add(newsItem.getThumbMediaId())));
if (CollUtil.isEmpty(mediaIds)) {
return;
}
// 1.2 批量查询对应的 Media 素材
Map<String, MpMaterialDO> materials = CollectionUtils.convertMap(mpMaterialService.getMaterialListByMediaId(mediaIds),
MpMaterialDO::getMediaId);
// 2. 设置回 WxMpFreePublishItem 记录
items.forEach(item -> item.getContent().getNewsItem().forEach(newsItem ->
findAndThen(materials, newsItem.getThumbMediaId(), material -> newsItem.setThumbUrl(material.getUrl()))));
}
@PostMapping("/submit")
@Operation(summary = "发布草稿")
@Parameters({
@Parameter(name = "accountId", description = "公众号账号的编号", required = true, example = "1024"),
@Parameter(name = "mediaId", description = "要发布的草稿的 media_id", required = true, example = "2048")
})
@PreAuthorize("@ss.hasPermission('mp:free-publish:submit')")
public CommonResult<String> submitFreePublish(@RequestParam("accountId") Long accountId,
@RequestParam("mediaId") String mediaId) {
WxMpService mpService = mpServiceFactory.getRequiredMpService(accountId);
try {
String publishId = mpService.getFreePublishService().submit(mediaId);
return success(publishId);
} catch (WxErrorException e) {
throw exception(FREE_PUBLISH_SUBMIT_FAIL, e.getError().getErrorMsg());
}
}
@DeleteMapping("/delete")
@Operation(summary = "删除草稿")
@Parameters({
@Parameter(name = "accountId", description = "公众号账号的编号", required = true, example = "1024"),
@Parameter(name = "articleId", description = "发布记录的编号", required = true, example = "2048")
})
@PreAuthorize("@ss.hasPermission('mp:free-publish:delete')")
public CommonResult<Boolean> deleteFreePublish(@RequestParam("accountId") Long accountId,
@RequestParam("articleId") String articleId) {
WxMpService mpService = mpServiceFactory.getRequiredMpService(accountId);
try {
mpService.getFreePublishService().deletePushAllArticle(articleId);
return success(true);
} catch (WxErrorException e) {
throw exception(FREE_PUBLISH_DELETE_FAIL, e.getError().getErrorMsg());
}
}
}