人工介入接口

ch-admin-api/src/main/java/com/wwdz/ch/admin/controller/SysIMController.java

@@ -73,4 +73,25 @@ public class SysIMController {
         return sysIMService.setChatUserRemark(dto);
     }
 
+
+    @ApiOperation(value = "人工介入")
+    @PostMapping("/humanIntervene")
+    public Result humanIntervene(@RequestBody ConversationRequestDto dto) {
+        logger.info("【请求开始】人工介入,请求参数:{}", JSON.toJSONString(dto));
+        if (StringUtils.isEmpty(dto.getFromAccount()) || StringUtils.isEmpty(dto.getToAccount())) {
+            return Result.failed(ResultCode.PARAM_ERROR);
+        }
+        return sysIMService.humanIntervene(dto);
+    }
+
+
+    @ApiOperation(value = "结束人工介入")
+    @PostMapping("/stopHumanIntervene")
+    public Result stopHumanIntervene(@RequestBody ConversationRequestDto dto) {
+        logger.info("【请求开始】结束人工介入,请求参数:{}", JSON.toJSONString(dto));
+        if (StringUtils.isEmpty(dto.getFromAccount()) || StringUtils.isEmpty(dto.getToAccount())) {
+            return Result.failed(ResultCode.PARAM_ERROR);
+        }
+        return sysIMService.stopHumanIntervene(dto);
+    }
 }

ch-admin-api/src/main/java/com/wwdz/ch/admin/impl/SysIMServiceImpl.java

@@ -7,12 +7,12 @@ import com.wwdz.ch.core.im.api.ConversationApi;
 import com.wwdz.ch.core.im.api.TLSSigApi;
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.core.util.IMUtil;
+import com.wwdz.ch.core.util.RedisUtils;
 import com.wwdz.ch.db.dao.AiAssistantDao;
 import com.wwdz.ch.db.dao.UserDao;
 import com.wwdz.ch.db.domain.AiAssistant;
 import com.wwdz.ch.db.domain.User;
 import com.wwdz.ch.db.dto.request.ConversationRequestDto;
-import com.wwdz.ch.db.dto.request.ImRecordRequestDto;
 import com.wwdz.ch.db.dto.request.UserRequestDto;
 import com.xxdxxs.utils.JsonUtils;
 import org.slf4j.Logger;
@@ -43,6 +43,9 @@ public class SysIMServiceImpl implements SysIMService {
     @Autowired
     AiAssistantDao aiAssistantDao;
 
+    @Autowired
+    RedisUtils redisUtils;
+
     @Override
     public Result sendChatMsg(SendChatMsgRequestDto dto) {
         try {
@@ -50,6 +53,8 @@ public class SysIMServiceImpl implements SysIMService {
             if (dto.getIsRealPersonAnswer() != null && dto.getIsRealPersonAnswer() == 1) {
                 dto.setCloudCustomData(JsonUtils.fromMap(new HashMap<String, Object>(){{put("realPersonId", dto.getRealPersonId());}}));
             }
+            String key = imUtil.getHumanInterveneKey(dto.getToAccount(), dto.getFromAccount());
+            redisUtils.set(key, System.currentTimeMillis(), 60 * 3);
             Result result = conversationApi.sendChatMsg(dto);
             return result;
         } catch (Exception e) {
@@ -80,6 +85,12 @@ public class SysIMServiceImpl implements SysIMService {
             Map<String, Object> map = new HashMap<>();
             map.put("user", user);
             map.put("aiAssistant", aiAssistant);
+            //判断该会话是否有人工介入
+            if (redisUtils.hasKey(imUtil.getHumanInterveneKey(dto.getFromAccount(), dto.getToAccount()))) {
+                map.put("intervened", true);
+            } else {
+                map.put("intervened", false);
+            }
             return Result.success(map);
         } catch (Exception e) {
             logger.error("获取用户信息失败:{}", e);
@@ -100,4 +111,28 @@ public class SysIMServiceImpl implements SysIMService {
         }
         return Result.failed();
     }
+
+
+    /**
+     * fromAccount为用户账号
+     * toAccount为机器人账号
+     * @param dto
+     * @return
+     */
+    @Override
+    public Result humanIntervene(ConversationRequestDto dto) {
+        String key = imUtil.getHumanInterveneKey(dto.getFromAccount(), dto.getToAccount());
+        redisUtils.set(key, System.currentTimeMillis(), 60 * 3);
+        return Result.success();
+    }
+
+    @Override
+    public Result stopHumanIntervene(ConversationRequestDto dto) {
+        String key = imUtil.getHumanInterveneKey(dto.getFromAccount(), dto.getToAccount());
+        boolean flag = redisUtils.delete(key);
+        if (flag) {
+            return Result.success();
+        }
+        return Result.failed();
+    }
 }

ch-admin-api/src/main/java/com/wwdz/ch/admin/service/SysIMService.java

@@ -38,4 +38,18 @@ public interface SysIMService {
      * @return
      */
     Result setChatUserRemark(UserRequestDto dto);
+
+    /**
+     * 人工介入
+     * @param dto
+     * @return
+     */
+    Result humanIntervene(ConversationRequestDto dto);
+
+    /**
+     * 结束人工介入
+     * @param dto
+     * @return
+     */
+    Result stopHumanIntervene(ConversationRequestDto dto);
 }

ch-core/src/main/java/com/wwdz/ch/core/util/IMUtil.java

@@ -90,4 +90,15 @@ public class IMUtil {
         return url + stringBuffer.toString();
     }
 
+    /**
+     * 人工介入在redis中的标识
+     * @param fromAccount
+     * @param toAccount
+     * @return
+     */
+    public String getHumanInterveneKey(String fromAccount, String toAccount) {
+        String key = "C2C:INTERVENE:" + formatUserId(fromAccount) + "_to_" + formatUserId(toAccount);
+        return key;
+
+    }
 }

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/ImServiceImpl.java

@@ -140,6 +140,11 @@ public class ImServiceImpl implements IMService {
             }
 
             logger.info("=========== userid:{},  提问ai的消息发送成功 ==========", dto.getFromAccount());
+            if (redisUtils.hasKey(imUtil.getHumanInterveneKey(dto.getFromAccount(), dto.getToAccount()))) {
+                logger.info(">>>> 会话: {} to {}, 已有人工介入, 无需机器人回答 <<<<", dto.getFromAccount(), dto.getToAccount());
+                return Result.success();
+            }
+
             if (dto.getMsgType() == IMEnum.MsgTypeEnum.TIMTextElem.getCode()) {
                 String question = (String) dto.getMsgContent();
                 question = question + "，请回答钱币相关的内容";