大家都一样的《计谋模式》

来自云龙湖轮廓分明的月亮  金牌会员 | 2024-12-17 16:46:40 | 显示全部楼层 | 阅读模式
打印 上一主题 下一主题
楼主

主题 838|帖子 838|积分 2524

不同类型的消息处理

这里抽象层用的是接口
MessageProcess  ⬇︎⬇︎⬇︎
点击查看代码
  1. /**
  2. * 消息处理
  3. *
  4. * @author haiyang
  5. */
  6. public interface MessageProcess<K,V> {
  9.     /**
  10.      * 处理消息
  11.      *
  12.      * @param messageInfo 消息相关信息
  13.      * @return {@link V}
  14.      */
  15.     V dealWithMessage(final K messageInfo);
  17. }
复制代码
客户的消息 CustomerMessageProcess ⬇︎⬇︎⬇︎
点击查看代码
  1. /**
  2. * 客户消息
  3. * <pre>
  4. *     客户回复的消息如果是数字，需要将数字对应的detail和可选项回复关联起来。
  5. * </pre>
  6. *
  7. * @author haiyang
  8. */
  9. public class CustomerMessageProcess implements MessageProcess<MessageFullInfoDto, MessageProcessFinalResultDto> {
  10.     @Override
  11.     public MessageProcessFinalResultDto dealWithMessage(final MessageFullInfoDto messageFullInfoDto) {
  12.         // 判断是否处于禁止发言期间
  13.         Object disableReplay = redisUtils.get(RedisKeyUtil.getDisableReplayKey(messageFullInfoDto.getRoomId()));
  14.         if (!Objects.isNull(disableReplay)) {
  15.             log.info("群:{}正处于禁止机器人发言期", messageFullInfoDto.getRoomId());
  16.             return new MessageProcessFinalResultDto(false, "正处于禁止机器人发言期", null);
  17.         }
  18.         // 判断文本是否属于数字类型
  19.         String messageContents = messageFullInfoDto.getMessageContents();
  20.         boolean numeric = StringUtils.isNumeric(messageContents);
  21.         Long groupId = messageFullInfoDto.getGroupId();
  22.         if (numeric) {
  23.             // 走数字逻辑
  24.             int parseInt = Integer.parseInt(messageContents);
  25.             if (parseInt > 0 && parseInt <= 10) {
  26.                 LambdaQueryWrapper<MsgDetail> lastDetail = new LambdaQueryWrapper<MsgDetail>().eq(MsgDetail::getGroupId, groupId).eq(MsgDetail::getType, MsgDetailEnum.Type.REPLY.getCode()).orderByDesc(MsgDetail::getCreateTime).last("limit 1");
  27.                 MsgDetail replyMsgDetail = msgDetailService.getOne(lastDetail);
  28.                 MessageProcessFinalResultDto messageProcessFinalResultDto = noOptionReplyHandler(messageFullInfoDto, messageContents, groupId, replyMsgDetail);
  29.                 if (messageProcessFinalResultDto != null) {
  30.                     return messageProcessFinalResultDto;
  31.                 }
  32.                 MsgAnswers groupLastAnswer = msgAnswersService.getGroupLastAnswer(groupId, parseInt);
  33.                 messageProcessFinalResultDto = missedReplyHandler(messageFullInfoDto, messageContents, groupId, groupLastAnswer);
  34.                 if (messageProcessFinalResultDto != null) {
  35.                     return messageProcessFinalResultDto;
  36.                 }
  37.                 messageProcessFinalResultDto = handlerInvalidate(messageFullInfoDto, messageContents, groupId, groupLastAnswer);
  38.                 if (messageProcessFinalResultDto != null) {
  39.                     return messageProcessFinalResultDto;
  40.                 }
  41.                 messageProcessFinalResultDto = hitHandler(messageFullInfoDto, messageContents, groupId, groupLastAnswer);
  42.                 String replyDetailId = replyMsgDetail.getReplyDetailId();
  43.                 if (StringUtils.isNotEmpty(replyDetailId)) {
  44.                     replyDetailId += "," + messageProcessFinalResultDto.getExtendData();
  45.                 } else {
  46.                     replyDetailId = "" + messageProcessFinalResultDto.getExtendData();
  47.                 }
  48.                 replyMsgDetail.setReplyDetailId(replyDetailId);
  49.                 msgDetailService.updateById(replyMsgDetail);
  50.                 return messageProcessFinalResultDto;
  51.             }
  52.         }
  53.         // 普通文本处理
  54.         saveDetail(messageFullInfoDto, messageContents, groupId, null, true);
  55.         LambdaQueryWrapper<MsgWaitTask> queryWrapper = new LambdaQueryWrapper<MsgWaitTask>().eq(MsgWaitTask::getGroupId, groupId).eq(MsgWaitTask::getMergeStatus, MergeStatusEnum.WAIT_MERGE.getStatus()).orderByDesc(MsgWaitTask::getWaitMergeTime).last("limit 1");
  56.         MsgWaitTask msgWaitTask = msgWaitTaskService.getOne(queryWrapper);
  57.         if (Objects.isNull(msgWaitTask)) {
  58.             saveMsgWaitTask(messageFullInfoDto, groupId);
  59.             return new MessageProcessFinalResultDto(true, null, null);
  60.         }
  61.         LocalDateTime waitMergeTime = msgWaitTask.getWaitMergeTime();
  62.         LocalDateTime now = LocalDateTime.now();
  63.         if (now.isAfter(waitMergeTime)) {
  64.             saveMsgWaitTask(messageFullInfoDto, groupId);
  65.         } else {
  66.             // 更新整合时间和最后一次微信时间
  67.             msgWaitTask.setLastTxMsgTime(messageFullInfoDto.getMsgTime());
  68.             msgWaitTask.setWaitMergeTime(LocalDateTime.now().plusSeconds(15));
  69.             msgWaitTaskService.updateById(msgWaitTask);
  70.         }
  71.         return new MessageProcessFinalResultDto(true, null, null);
  72.     }
  74.     private void saveMsgWaitTask(MessageFullInfoDto messageFullInfoDto, Long groupId) {
  75.         MsgWaitTask msgWaitTask;
  76.         // 说明已经过了整合时间, 重新插入一条数据
  77.         msgWaitTask = new MsgWaitTask();
  78.         msgWaitTask.setGroupId(groupId);
  79.         msgWaitTask.setRoomId(messageFullInfoDto.getRoomId());
  80.         Long msgTime = messageFullInfoDto.getMsgTime();
  81.         msgWaitTask.setWaitMergeTime(LocalDateTime.now().plusSeconds(15));
  82.         msgWaitTask.setLastTxMsgTime(msgTime);
  83.         msgWaitTask.setMergeStatus(MergeStatusEnum.WAIT_MERGE.getStatus());
  84.         msgWaitTaskService.save(msgWaitTask);
  85.     }
  87.     /**
  88.      * 命中处理
  89.      */
  90.     private MessageProcessFinalResultDto hitHandler(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId, MsgAnswers groupLastAnswer) {
  91.         String answerContext = groupLastAnswer.getAnswerContext();
  92.         Long rpaMsgDetailId = saveRpaMsgDetail(messageFullInfoDto, groupId, answerContext);
  93.         // 保存客户detail
  94.         Long detailId = saveDetail(messageFullInfoDto, messageContents, groupId, rpaMsgDetailId, false);
  95.         // 发送rpa任务
  96.         sendRpaTask(messageFullInfoDto, answerContext, rpaMsgDetailId,TaskSubTypeEnum.ACCURATE.getType());
  97.         return new MessageProcessFinalResultDto(true, null, detailId);
  98.     }
  100.     /**
  101.      * 无可选项回复处理
  102.      */
  103.     private MessageProcessFinalResultDto noOptionReplyHandler(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId, MsgDetail replyMsgDetail) {
  104.         if (Objects.isNull(replyMsgDetail) || DateUtil.isAfterMinus(replyMsgDetail.getCreateTime(), 20)) {
  105.             // 没有可选项回复 存入detail 不执行回复
  106.             saveDetail(messageFullInfoDto, messageContents, groupId, null, false);
  107.             log.info("客服发言的数字文本无需回复, fromAccount:{}, textContext:{}", messageFullInfoDto.getFromAccount(), messageContents);
  108.             noWorkAutoReply(messageFullInfoDto, messageContents, groupId);
  109.             return new MessageProcessFinalResultDto(true, null, null);
  110.         }
  111. /*       // 判断可选项时间是否在20min有效期
  112.         LocalDateTime createTime = replyMsgDetail.getCreateTime();
  113.         if (DateUtil.isAfterMinus(createTime, 20)) {
  114.             // 超过了有效期, 回复默认文本
  115.             // 没有可选项回复 存入detail 不执行回复
  116.             saveDetail(messageFullInfoDto, messageContents, groupId, null, false);
  117.             log.info("客服发言的数字文本无需回复, fromAccount:{}, textContext:{}", messageFullInfoDto.getFromAccount(), messageContents);
  118.             return new MessageProcessFinalResultDto(true, null, null);
  119.         }*/
  120.         return null;
  121.     }
  123.     private void noWorkAutoReply(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId) {
  124.         // 非工自动回复处理
  125.         boolean workTime = DateUtil.workTime(new Date());
  126.         if (!workTime) {
  127.             Object noWorkReplay = redisUtils.get(RedisKeyUtil.getNoWorkReplayKey(messageFullInfoDto.getRoomId()));
  128.             if (Objects.isNull(noWorkReplay)) {
  129.                 // 发送rpa任务 推送非工时间的默认回复
  130.                 String noWorkAutoReply = ianswerProperties.getNoWorkAutoReply();
  131.                 Long rpaMsgDetailId = saveRpaMsgDetail(messageFullInfoDto, groupId, noWorkAutoReply);
  132.                 // 保存客户detail
  133.                 saveDetail(messageFullInfoDto, messageContents, groupId, rpaMsgDetailId, false);
  134.                 // 发送rpa任务
  135.                 sendRpaTask(messageFullInfoDto, noWorkAutoReply, rpaMsgDetailId,TaskSubTypeEnum.ACCURATE.getType());
  136.                 // 计算非工回复周期
  137.                 int tomorrowSeconds = DateUtil.getTomorrowSeconds(new Date());
  138.                 redisUtils.setWithExpireSeconds(RedisKeyUtil.getNoWorkReplayKey(messageFullInfoDto.getRoomId()),  true, tomorrowSeconds);
  139.             }
  140.         }
  141.     }
  143.     /**
  144.      * 未命中处理
  145.      */
  146.     private MessageProcessFinalResultDto missedReplyHandler(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId, MsgAnswers groupLastAnswer) {
  147.         if (Objects.isNull(groupLastAnswer)) {
  148.             // 保存机器人默认回复文本
  149.             String missedReply = ianswerProperties.getMissedReply();
  150.             Long rpaMsgDetailId = saveRpaMsgDetail(messageFullInfoDto, groupId, missedReply);
  151.             // 保存客户detail
  152.             saveDetail(messageFullInfoDto, messageContents, groupId, rpaMsgDetailId, false);
  153.             // 发送rpa任务
  154.             sendRpaTask(messageFullInfoDto, missedReply, rpaMsgDetailId,TaskSubTypeEnum.FIXED.getType());
  155.             return new MessageProcessFinalResultDto(true, null, null);
  156.         }
  157.         return null;
  158.     }
  160.     /**
  161.      * 以上都不是处理
  162.      */
  163.     private MessageProcessFinalResultDto handlerInvalidate(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId, MsgAnswers groupLastAnswer) {
  164.         if (MsgAnswerEnum.Type.INVALIDATE.getCode().equals(groupLastAnswer.getType())) {
  165.             // 以上都不是, 需要回复固定话术
  166.             boolean workTime = DateUtil.workTime(new Date());
  167.             String textContext = null;
  168.             if (workTime) {
  169.                 textContext = ianswerProperties.getExitWork();
  170.             } else {
  171.                 textContext = ianswerProperties.getExitNonWork();
  172.             }
  173.             Long rpaMsgDetailId = saveRpaMsgDetail(messageFullInfoDto, groupId, textContext);
  174.             // 保存客户detail
  175.             saveDetail(messageFullInfoDto, messageContents, groupId, rpaMsgDetailId, false);
  176.             // 发送rpa任务
  177.             sendRpaTask(messageFullInfoDto, textContext, rpaMsgDetailId,TaskSubTypeEnum.FIXED.getType());
  178.             return new MessageProcessFinalResultDto(true, null, null);
  179.         }
  180.         return null;
  181.     }
  183.     private void sendRpaTask(MessageFullInfoDto messageFullInfoDto, String missedReply, Long rpaMsgDetailId,String taskSubType) {
  184.         SendTaskDto sendTaskDto = new SendTaskDto();
  185.         sendTaskDto.setRoomId(messageFullInfoDto.getRoomId());
  186.         sendTaskDto.setDetailId(rpaMsgDetailId);
  187.         sendTaskDto.setContentSign(messageContextUtil.getSHAStr(missedReply));
  188.         sendTaskDto.setGroupId(messageFullInfoDto.getGroupId());
  189.         SendTaskRequest sendTaskRequest = new SendTaskRequest();
  190.         sendTaskRequest.setContent(missedReply);
  191.         sendTaskRequest.setResourceName(messageFullInfoDto.getOrderNo());
  192.         sendTaskRequest.setWaitingRobotAccounts(messageFullInfoDto.getRobotAccount());
  193.         sendTaskRequest.setWaitingRobotNames(messageFullInfoDto.getRobotName());
  194.         sendTaskRequest.setTaskOverTime(DateUtil.addTimeToString(LocalDateTime.now(), 30));
  195.         sendTaskRequest.setCustomer(messageFullInfoDto.getCustomName());
  196.         sendTaskRequest.setSubResourceName(messageFullInfoDto.getGrowthMember());
  197.         sendTaskRequest.setOrderId(messageFullInfoDto.getOrderNo());
  198.         sendTaskRequest.setTaskSubType(taskSubType);
  199.         sendTaskDto.setSendTaskRequest(sendTaskRequest);
  200.         rpaTaskService.sendTask(sendTaskDto);
  201.     }
  203.     private Long saveRpaMsgDetail(MessageFullInfoDto messageFullInfoDto, Long groupId, String missedReply) {
  204.         MsgDetail msgDetail = new MsgDetail();
  205.         msgDetail.setType(MsgDetailEnum.Type.COMMON.getCode());
  206.         msgDetail.setGroupId(groupId);
  207.         msgDetail.setRoomId(messageFullInfoDto.getRoomId());
  208.         msgDetail.setMsgStatus(MsgDetailEnum.MsgStatus.TO_BE_RECEIVE.getCode());
  209.         msgDetail.setTextContext(missedReply);
  210.         msgDetail.setTextContextSign(messageContextUtil.getSHAStr(missedReply));
  211.         msgDetail.setMergeStatus(MsgDetailEnum.MergeStatus.NONE.getCode());
  212.         msgDetail.setReplyStatus(MsgDetailEnum.ReplyStatus.WAIT_REPLY.getCode());
  213.         msgDetail.setSendAccountType(MsgDetailEnum.SendAccountType.RPA.getCode());
  214.         msgDetail.setSendQwName(messageFullInfoDto.getRobotName());
  215.         msgDetail.setSendQwAccount(messageFullInfoDto.getRobotAccount());
  216.         msgDetailService.save(msgDetail);
  217.         return msgDetail.getId();
  218.     }
  220.     private Long saveDetail(MessageFullInfoDto messageFullInfoDto, String messageContents, Long groupId, Long rpaMsgDetailId, boolean isTextMessage) {
  221.         MsgDetail msgDetail = new MsgDetail();
  222.         msgDetail.setType(MsgDetailEnum.Type.COMMON.getCode());
  223.         msgDetail.setGroupId(groupId);
  224.         msgDetail.setRoomId(messageFullInfoDto.getRoomId());
  225.         msgDetail.setMsgId(messageFullInfoDto.getMsgId());
  226.         msgDetail.setMsgTime(messageFullInfoDto.getMsgTime());
  227.         msgDetail.setMsgFrom(messageFullInfoDto.getFromAccount());
  228.         msgDetail.setMsgStatus(MsgDetailEnum.MsgStatus.RECEIVED.getCode());
  229.         msgDetail.setTextContext(messageContents);
  230.         msgDetail.setTextContextSign(messageContextUtil.getSHAStr(messageContents));
  231.         if (isTextMessage) {
  232.             msgDetail.setMergeStatus(MsgDetailEnum.MergeStatus.WAIT_MERGE.getCode());
  233.             msgDetail.setReplyStatus(MsgDetailEnum.ReplyStatus.WAIT_REPLY.getCode());
  234.         } else {
  235.             msgDetail.setReplyStatus(MsgDetailEnum.ReplyStatus.NONE.getCode());
  236.             msgDetail.setMergeStatus(MsgDetailEnum.MergeStatus.NONE.getCode());
  237.         }
  238.         if (Objects.nonNull(rpaMsgDetailId)) {
  239.             msgDetail.setReplyDetailId(rpaMsgDetailId.toString());
  240.         }
  241.         msgDetailService.save(msgDetail);
  242.         return msgDetail.getId();
  243.     }
  244. }
复制代码
人工客服消息 StaffServiceMessageProcess ⬇︎⬇︎⬇︎
点击查看代码
  1. /**
  2. * 机器人消息
  3. * <pre>
  4. *     整体处理逻辑：
  5. *     1.根据群id和机器人的账号+内容签名，确定一条最新的有效的明细和任务
  6. *     2.更新机器人发言的那条明细记录
  7. *     3.更新rpa任务相应的状态
  8. *     4.更新前面整合提问的那些明细
  9. * </pre>
  10. *
  11. * @author haiyang
  12. */
  13. @Component
  14. @Slf4j
  15. public class RobotMessageProcess implements MessageProcess<MessageFullInfoDto, MessageProcessFinalResultDto> {
  17.     @Override
  18.     public MessageProcessFinalResultDto dealWithMessage(final MessageFullInfoDto messageInfo) {
  19.         log.info("RobotMessageProcess params:{}",JSON.toJSONString(messageInfo));
  20.         // 1.查到对应的rpa task 和 msg detail(这个消息是机器人发送的消息)
  21.         TaskMsgDetailDto taskDetailInfo = rpaTaskService.getTaskDetailInfo(messageInfo.getRoomId(),
  22.                 messageInfo.getFromAccount(),
  23.                 getShaContentsOfTrimAt(messageInfo.getMessageContents())
  24.         );
  25.         log.info("getTaskDetailInfo result:{}", JSON.toJSONString(taskDetailInfo));
  26.         if (Objects.isNull(taskDetailInfo)) {
  27.             return new MessageProcessFinalResultDto(false,"没有找到对应的task detail",null);
  28.         }
  29.         // 2.更新 rpa task 中的 rpa_msg_status
  30.         rpaTaskService.updateRpaMsgStatus(taskDetailInfo.getTaskId(), RpaTaskEnum.RpaMsgStatus.RECEIVE_SUCCESS.getCode());
  31.         log.info("更新rpa task的状态--完成");
  34.         // 3.更新机器人消息的detail的中的 msg_status 状态 ，
  35.         // 同时需要更新对应的 send_qw_name 和 send_qw_account 为实际发送消息的robot账号信息（实际回复消息的只有一个机器人）
  36.         msgDetailService.updateMsgStatus(taskDetailInfo.getDetailId(),
  37.                 MsgDetailEnum.MsgStatus.RECEIVED.getCode(),
  38.                 messageInfo.getFromAccountName(),
  39.                 messageInfo.getFromAccount(),
  40.                 messageInfo.getMsgId(),
  41.                 messageInfo.getMsgTime(),
  42.                 messageInfo.getFromAccount());
  43.         log.info("更新robot消息detail的状态--完成");
  46.         // 4.更新对应的整合消息的 reply_status
  47.         msgDetailService.refreshReplyStatus(taskDetailInfo.getDetailId(),taskDetailInfo.getMsgId(),taskDetailInfo.getMsgTime());
  48.         log.info("更新对应的整合消息--完成");
  50.         syncNotifyListener(taskDetailInfo);
  51.         log.info("通知操作--完成");
  52.         return new MessageProcessFinalResultDto(true,null,null);
  53.     }
  56.     /**
  57.      * 将机器人消息去除@符号进行签名
  58.      * <pre>
  59.      *     <b>下发rpa任务时，at的对象没有直接跟在内容里面</b>
  60.      * </pre>
  61.      *
  62.      * @param msgContent 味精内容
  63.      * @return {@link String}
  64.      */
  65.     private String getShaContentsOfTrimAt(final String msgContent){
  66.         if (msgContent.contains(CommonConstant.SYMBOL_OF_AT)) {
  67.             int i = msgContent.indexOf(CommonConstant.SYMBOL_OF_AT);
  68.             if (i>0) {
  69.                 String trimAtString = msgContent.substring(0, i);
  70.                 return messageContextUtil.getSHAStr(trimAtString);
  71.             }
  72.         }
  73.         String sign =  messageContextUtil.getSHAStr(msgContent);
  74.         log.info("msgContent:{},sign:{}",msgContent,sign);
  75.         return sign;
  76.     }
  79.     /**
  80.      * 通知操作
  81.      *
  82.      * @param taskDetailInfo 任务详细信息
  83.      */
  84.     private void syncNotifyListener(TaskMsgDetailDto taskDetailInfo){
  85.         log.info("通知rpa消息接收结果");
  86.         NotifyTaskRequest request = new NotifyTaskRequest();
  87.         request.setTaskId(String.valueOf(taskDetailInfo.getTaskId()));
  88.         request.setMsgStatus(RpaTaskEnum.RpaMsgStatus.RECEIVE_SUCCESS.getStatus());
  89.         request.setReceivedMsgTime(DateUtil.formatYmdHms(DateUtil.secondToLocalDate(taskDetailInfo.getMsgTime())));
  90.         sendTaskClient.notifyReceivedMessageResult(Arrays.asList(request));
  91.     }
  93. }
复制代码
调用的地方是这样的：⟱⟱⟱

不同状态的处理逻辑

这里抽象层用的是抽象类

使用的时候是通过枚举指定的类型从IOC容器中获取对应的处理实例的，如下⬇︎⬇︎⬇︎

选择使用

使用很灵活，理念很简单。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。

本帖子中包含更多资源

您需要 登录 才可以下载或查看，没有账号？立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览
返回列表

快速回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

来自云龙湖轮廓分明的月亮

金牌会员
这个人很懒什么都没写!

楼主热帖

标签云

挺好的 服务器
微信订阅号
微信服务号
微信客服
小程序
H5
关于我们 商务合作 网站地图
©Copyright 2022-2024 杭州祥升科技有限公司 版权所有 浙ICP备20004199号
快速回复 返回顶部 返回列表