|
|
@@ -2,13 +2,18 @@ package cn.iocoder.yudao.module.mp.service.message;
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil;
|
|
|
import cn.hutool.core.lang.Assert;
|
|
|
+import cn.hutool.core.util.ObjUtil;
|
|
|
+import cn.iocoder.yudao.framework.common.exception.ErrorCode;
|
|
|
import cn.iocoder.yudao.framework.common.pojo.PageResult;
|
|
|
+import cn.iocoder.yudao.module.mp.controller.admin.message.vo.autoreply.MpAutoReplyCreateReqVO;
|
|
|
+import cn.iocoder.yudao.module.mp.controller.admin.message.vo.autoreply.MpAutoReplyUpdateReqVO;
|
|
|
import cn.iocoder.yudao.module.mp.controller.admin.message.vo.message.MpMessagePageReqVO;
|
|
|
import cn.iocoder.yudao.module.mp.convert.message.MpAutoReplyConvert;
|
|
|
import cn.iocoder.yudao.module.mp.dal.dataobject.account.MpAccountDO;
|
|
|
import cn.iocoder.yudao.module.mp.dal.dataobject.message.MpAutoReplyDO;
|
|
|
import cn.iocoder.yudao.module.mp.dal.mysql.message.MpAutoReplyMapper;
|
|
|
import cn.iocoder.yudao.module.mp.enums.message.MpAutoReplyTypeEnum;
|
|
|
+import cn.iocoder.yudao.module.mp.framework.mp.core.util.MpUtils;
|
|
|
import cn.iocoder.yudao.module.mp.service.account.MpAccountService;
|
|
|
import cn.iocoder.yudao.module.mp.service.message.bo.MpMessageSendOutReqBO;
|
|
|
import me.chanjar.weixin.common.api.WxConsts;
|
|
|
@@ -19,8 +24,12 @@ import org.springframework.stereotype.Service;
|
|
|
import org.springframework.validation.annotation.Validated;
|
|
|
|
|
|
import javax.annotation.Resource;
|
|
|
+import javax.validation.Validator;
|
|
|
import java.util.List;
|
|
|
|
|
|
+import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
|
|
|
+import static cn.iocoder.yudao.module.mp.enums.ErrorCodeConstants.*;
|
|
|
+
|
|
|
/**
|
|
|
* 公众号的自动回复 Service 实现类
|
|
|
*
|
|
|
@@ -36,6 +45,9 @@ public class MpAutoReplyServiceImpl implements MpAutoReplyService {
|
|
|
@Lazy // 延迟加载，避免循环依赖
|
|
|
private MpAccountService mpAccountService;
|
|
|
|
|
|
+ @Resource
|
|
|
+ private Validator validator;
|
|
|
+
|
|
|
@Resource
|
|
|
private MpAutoReplyMapper mpAutoReplyMapper;
|
|
|
|
|
|
@@ -49,6 +61,96 @@ public class MpAutoReplyServiceImpl implements MpAutoReplyService {
|
|
|
return mpAutoReplyMapper.selectById(id);
|
|
|
}
|
|
|
|
|
|
+ @Override
|
|
|
+ public Long createAutoReply(MpAutoReplyCreateReqVO createReqVO) {
|
|
|
+ // 第一步，校验数据
|
|
|
+ if (createReqVO.getResponseMessageType() != null) {
|
|
|
+ MpUtils.validateMessage(validator, createReqVO.getResponseMessageType(), createReqVO);
|
|
|
+ }
|
|
|
+ validateAutoReplyConflict(null, createReqVO.getAccountId(), createReqVO.getType(),
|
|
|
+ createReqVO.getRequestKeyword(), createReqVO.getRequestMessageType());
|
|
|
+
|
|
|
+ // 第二步，插入数据
|
|
|
+ MpAccountDO account = mpAccountService.getRequiredAccount(createReqVO.getAccountId());
|
|
|
+ MpAutoReplyDO autoReply = MpAutoReplyConvert.INSTANCE.convert(createReqVO)
|
|
|
+ .setAppId(account.getAppId());
|
|
|
+ mpAutoReplyMapper.insert(autoReply);
|
|
|
+ return autoReply.getId();
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void updateAutoReply(MpAutoReplyUpdateReqVO updateReqVO) {
|
|
|
+ // 第一步，校验数据
|
|
|
+ if (updateReqVO.getResponseMessageType() != null) {
|
|
|
+ MpUtils.validateMessage(validator, updateReqVO.getResponseMessageType(), updateReqVO);
|
|
|
+ }
|
|
|
+ MpAutoReplyDO autoReply = validateAutoReplyExists(updateReqVO.getId());
|
|
|
+ validateAutoReplyConflict(updateReqVO.getId(), autoReply.getAccountId(), updateReqVO.getType(),
|
|
|
+ updateReqVO.getRequestKeyword(), updateReqVO.getRequestMessageType());
|
|
|
+
|
|
|
+ // 第二步，更新数据
|
|
|
+ MpAutoReplyDO updateObj = MpAutoReplyConvert.INSTANCE.convert(updateReqVO)
|
|
|
+ .setAccountId(null).setAppId(null); // 避免前端传递，更新着两个字段
|
|
|
+ mpAutoReplyMapper.updateById(updateObj);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 校验自动回复是否冲突
|
|
|
+ *
|
|
|
+ * 不同的 type，会有不同的逻辑：
|
|
|
+ * 1. type = SUBSCRIBE 时，不允许有其他的自动回复
|
|
|
+ * 2. type = MESSAGE 时，校验 requestMessageType 已经存在自动回复
|
|
|
+ * 3. type = KEYWORD 时，校验 keyword 已经存在自动回复
|
|
|
+ *
|
|
|
+ * @param id 自动回复编号
|
|
|
+ * @param accountId 公众号账号的编号
|
|
|
+ * @param type 类型
|
|
|
+ * @param requestKeyword 请求关键词
|
|
|
+ * @param requestMessageType 请求消息类型
|
|
|
+ */
|
|
|
+ private void validateAutoReplyConflict(Long id, Long accountId, Integer type,
|
|
|
+ String requestKeyword, String requestMessageType) {
|
|
|
+ // 获得已经存在的自动回复
|
|
|
+ MpAutoReplyDO autoReply = null;
|
|
|
+ ErrorCode errorCode = null;
|
|
|
+ if (MpAutoReplyTypeEnum.SUBSCRIBE.getType().equals(type)) {
|
|
|
+ autoReply = mpAutoReplyMapper.selectByAccountIdAndSubscribe(accountId);
|
|
|
+ errorCode = AUTO_REPLY_ADD_SUBSCRIBE_FAIL_EXISTS;
|
|
|
+ } else if (MpAutoReplyTypeEnum.MESSAGE.getType().equals(type)) {
|
|
|
+ autoReply = mpAutoReplyMapper.selectByAccountIdAndMessage(accountId, requestMessageType);
|
|
|
+ errorCode = AUTO_REPLY_ADD_MESSAGE_FAIL_EXISTS;
|
|
|
+ } else if (MpAutoReplyTypeEnum.KEYWORD.getType().equals(type)) {
|
|
|
+ autoReply = mpAutoReplyMapper.selectByAccountIdAndKeyword(accountId, requestKeyword);
|
|
|
+ errorCode = AUTO_REPLY_ADD_KEYWORD_FAIL_EXISTS;
|
|
|
+ }
|
|
|
+ if (autoReply == null) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+
|
|
|
+ // 存在冲突，抛出业务异常
|
|
|
+ if (id == null // 情况一，新增（id == null），存在记录，说明冲突
|
|
|
+ || ObjUtil.notEqual(id, autoReply.getId())) { // 情况二，修改（id != null），id 不匹配，说明冲突
|
|
|
+ throw exception(errorCode);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public void deleteAutoReply(Long id) {
|
|
|
+ // 校验用户存在
|
|
|
+ validateAutoReplyExists(id);
|
|
|
+
|
|
|
+ // 删除自动回复
|
|
|
+ mpAutoReplyMapper.deleteById(id);
|
|
|
+ }
|
|
|
+
|
|
|
+ private MpAutoReplyDO validateAutoReplyExists(Long id) {
|
|
|
+ MpAutoReplyDO autoReply = mpAutoReplyMapper.selectById(id);
|
|
|
+ if (autoReply == null) {
|
|
|
+ throw exception(AUTO_REPLY_NOT_EXISTS);
|
|
|
+ }
|
|
|
+ return autoReply;
|
|
|
+ }
|
|
|
+
|
|
|
@Override
|
|
|
public WxMpXmlOutMessage replyForMessage(String appId, WxMpXmlMessage wxMessage) {
|
|
|
// 第一步，匹配自动回复
|
YunaiV