|
@@ -1,5 +1,6 @@
|
|
|
package cn.iocoder.yudao.module.mp.service.message;
|
|
|
|
|
|
+import cn.hutool.core.bean.BeanUtil;
|
|
|
import cn.hutool.core.lang.Assert;
|
|
|
import cn.hutool.core.util.ObjUtil;
|
|
|
import cn.hutool.core.util.StrUtil;
|
|
@@ -105,7 +106,15 @@ public class MpMessageServiceImpl implements MpMessageService {
|
|
|
setSendFrom(MpMessageSendFromEnum.MP_TO_USER.getFrom());
|
|
|
downloadMessageMedia(message);
|
|
|
mpMessageMapper.insert(message);
|
|
|
-
|
|
|
+ // 发送客服消息
|
|
|
+ MpMessageSendReqVO sendReqVO = BeanUtil.copyProperties(sendReqBO, MpMessageSendReqVO.class);
|
|
|
+ WxMpKefuMessage wxMessage = MpMessageConvert.INSTANCE.convert(sendReqVO, user);
|
|
|
+ WxMpService mpService = mpServiceFactory.getRequiredMpService(user.getAppId());
|
|
|
+ try {
|
|
|
+ mpService.getKefuService().sendKefuMessageWithResponse(wxMessage);
|
|
|
+ } catch (WxErrorException e) {
|
|
|
+ throw exception(MESSAGE_SEND_FAIL, e.getError().getErrorMsg());
|
|
|
+ }
|
|
|
// 转换返回 WxMpXmlOutMessage 对象
|
|
|
return MpMessageConvert.INSTANCE.convert02(message, account);
|
|
|
}
|