package cn.iocoder.yudao.module.mp.convert.message;
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
import cn.iocoder.yudao.module.mp.controller.admin.message.vo.message.MpMessageRespVO;
|
import cn.iocoder.yudao.module.mp.controller.admin.message.vo.message.MpMessageSendReqVO;
|
import cn.iocoder.yudao.module.mp.dal.dataobject.account.MpAccountDO;
|
import cn.iocoder.yudao.module.mp.dal.dataobject.message.MpMessageDO;
|
import cn.iocoder.yudao.module.mp.dal.dataobject.user.MpUserDO;
|
import cn.iocoder.yudao.module.mp.service.message.bo.MpMessageSendOutReqBO;
|
import me.chanjar.weixin.common.api.WxConsts;
|
import me.chanjar.weixin.mp.bean.kefu.WxMpKefuMessage;
|
import me.chanjar.weixin.mp.bean.message.WxMpXmlMessage;
|
import me.chanjar.weixin.mp.bean.message.WxMpXmlOutMessage;
|
import me.chanjar.weixin.mp.bean.message.WxMpXmlOutNewsMessage;
|
import me.chanjar.weixin.mp.builder.outxml.BaseBuilder;
|
import org.mapstruct.Mapper;
|
import org.mapstruct.Mapping;
|
import org.mapstruct.Mappings;
|
import org.mapstruct.factory.Mappers;
|
|
import java.util.List;
|
|
@Mapper
|
public interface MpMessageConvert {
|
|
MpMessageConvert INSTANCE = Mappers.getMapper(MpMessageConvert.class);
|
|
MpMessageRespVO convert(MpMessageDO bean);
|
|
List<MpMessageRespVO> convertList(List<MpMessageDO> list);
|
|
PageResult<MpMessageRespVO> convertPage(PageResult<MpMessageDO> page);
|
|
default MpMessageDO convert(WxMpXmlMessage wxMessage, MpAccountDO account, MpUserDO user) {
|
MpMessageDO message = convert(wxMessage);
|
if (account != null) {
|
message.setAccountId(account.getId()).setAppId(account.getAppId());
|
}
|
if (user != null) {
|
message.setUserId(user.getId()).setOpenid(user.getOpenid());
|
}
|
return message;
|
}
|
@Mappings(value = {
|
@Mapping(source = "msgType", target = "type"),
|
@Mapping(target = "createTime", ignore = true),
|
})
|
MpMessageDO convert(WxMpXmlMessage bean);
|
|
default MpMessageDO convert(MpMessageSendOutReqBO sendReqBO, MpAccountDO account, MpUserDO user) {
|
// 构建消息
|
MpMessageDO message = new MpMessageDO();
|
message.setType(sendReqBO.getType());
|
switch (sendReqBO.getType()) {
|
case WxConsts.XmlMsgType.TEXT: // 1. 文本
|
message.setContent(sendReqBO.getContent());
|
break;
|
case WxConsts.XmlMsgType.IMAGE: // 2. 图片
|
case WxConsts.XmlMsgType.VOICE: // 3. 语音
|
message.setMediaId(sendReqBO.getMediaId());
|
break;
|
case WxConsts.XmlMsgType.VIDEO: // 4. 视频
|
message.setMediaId(sendReqBO.getMediaId())
|
.setTitle(sendReqBO.getTitle()).setDescription(sendReqBO.getDescription());
|
break;
|
case WxConsts.XmlMsgType.NEWS: // 5. 图文
|
message.setArticles(sendReqBO.getArticles());
|
case WxConsts.XmlMsgType.MUSIC: // 6. 音乐
|
message.setTitle(sendReqBO.getTitle()).setDescription(sendReqBO.getDescription())
|
.setMusicUrl(sendReqBO.getMusicUrl()).setHqMusicUrl(sendReqBO.getHqMusicUrl())
|
.setThumbMediaId(sendReqBO.getThumbMediaId());
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的消息类型：" + message.getType());
|
}
|
|
// 其它字段
|
if (account != null) {
|
message.setAccountId(account.getId()).setAppId(account.getAppId());
|
}
|
if (user != null) {
|
message.setUserId(user.getId()).setOpenid(user.getOpenid());
|
}
|
return message;
|
}
|
|
default WxMpXmlOutMessage convert02(MpMessageDO message, MpAccountDO account) {
|
BaseBuilder<?, ? extends WxMpXmlOutMessage> builder;
|
// 个性化字段
|
switch (message.getType()) {
|
case WxConsts.XmlMsgType.TEXT:
|
builder = WxMpXmlOutMessage.TEXT().content(message.getContent());
|
break;
|
case WxConsts.XmlMsgType.IMAGE:
|
builder = WxMpXmlOutMessage.IMAGE().mediaId(message.getMediaId());
|
break;
|
case WxConsts.XmlMsgType.VOICE:
|
builder = WxMpXmlOutMessage.VOICE().mediaId(message.getMediaId());
|
break;
|
case WxConsts.XmlMsgType.VIDEO:
|
builder = WxMpXmlOutMessage.VIDEO().mediaId(message.getMediaId())
|
.title(message.getTitle()).description(message.getDescription());
|
break;
|
case WxConsts.XmlMsgType.NEWS:
|
builder = WxMpXmlOutMessage.NEWS().articles(convertList02(message.getArticles()));
|
break;
|
case WxConsts.XmlMsgType.MUSIC:
|
builder = WxMpXmlOutMessage.MUSIC().title(message.getTitle()).description(message.getDescription())
|
.musicUrl(message.getMusicUrl()).hqMusicUrl(message.getHqMusicUrl())
|
.thumbMediaId(message.getThumbMediaId());
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的消息类型：" + message.getType());
|
}
|
// 通用字段
|
builder.fromUser(account.getAccount());
|
builder.toUser(message.getOpenid());
|
return builder.build();
|
}
|
List<WxMpXmlOutNewsMessage.Item> convertList02(List<MpMessageDO.Article> list);
|
|
default WxMpKefuMessage convert(MpMessageSendReqVO sendReqVO, MpUserDO user) {
|
me.chanjar.weixin.mp.builder.kefu.BaseBuilder<?> builder;
|
// 个性化字段
|
switch (sendReqVO.getType()) {
|
case WxConsts.KefuMsgType.TEXT:
|
builder = WxMpKefuMessage.TEXT().content(sendReqVO.getContent());
|
break;
|
case WxConsts.KefuMsgType.IMAGE:
|
builder = WxMpKefuMessage.IMAGE().mediaId(sendReqVO.getMediaId());
|
break;
|
case WxConsts.KefuMsgType.VOICE:
|
builder = WxMpKefuMessage.VOICE().mediaId(sendReqVO.getMediaId());
|
break;
|
case WxConsts.KefuMsgType.VIDEO:
|
builder = WxMpKefuMessage.VIDEO().mediaId(sendReqVO.getMediaId())
|
.title(sendReqVO.getTitle()).description(sendReqVO.getDescription());
|
break;
|
case WxConsts.KefuMsgType.NEWS:
|
builder = WxMpKefuMessage.NEWS().articles(convertList03(sendReqVO.getArticles()));
|
break;
|
case WxConsts.KefuMsgType.MUSIC:
|
builder = WxMpKefuMessage.MUSIC().title(sendReqVO.getTitle()).description(sendReqVO.getDescription())
|
.thumbMediaId(sendReqVO.getThumbMediaId())
|
.musicUrl(sendReqVO.getMusicUrl()).hqMusicUrl(sendReqVO.getHqMusicUrl());
|
break;
|
default:
|
throw new IllegalArgumentException("不支持的消息类型：" + sendReqVO.getType());
|
}
|
// 通用字段
|
builder.toUser(user.getOpenid());
|
return builder.build();
|
}
|
List<WxMpKefuMessage.WxArticle> convertList03(List<MpMessageDO.Article> list);
|
|
default MpMessageDO convert(WxMpKefuMessage wxMessage, MpAccountDO account, MpUserDO user) {
|
MpMessageDO message = convert(wxMessage);
|
if (account != null) {
|
message.setAccountId(account.getId()).setAppId(account.getAppId());
|
}
|
if (user != null) {
|
message.setUserId(user.getId()).setOpenid(user.getOpenid());
|
}
|
return message;
|
}
|
@Mappings(value = {
|
@Mapping(source = "msgType", target = "type"),
|
@Mapping(target = "createTime", ignore = true),
|
})
|
MpMessageDO convert(WxMpKefuMessage bean);
|
|
}
|
