From e23f5a89e7d4fd57e2719e6ceaeeb72a74dc6dcc Mon Sep 17 00:00:00 2001 From: jack ning Date: Mon, 28 Apr 2025 13:51:33 +0800 Subject: [PATCH] Update VisitorThreadService.java --- .../service/visitor_thread/VisitorThreadService.java | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/modules/service/src/main/java/com/bytedesk/service/visitor_thread/VisitorThreadService.java b/modules/service/src/main/java/com/bytedesk/service/visitor_thread/VisitorThreadService.java index 68727705c4..3477175b86 100644 --- a/modules/service/src/main/java/com/bytedesk/service/visitor_thread/VisitorThreadService.java +++ b/modules/service/src/main/java/com/bytedesk/service/visitor_thread/VisitorThreadService.java @@ -2,7 +2,7 @@ * @Author: jackning 270580156@qq.com * @Date: 2024-06-29 13:08:52 * @LastEditors: jackning 270580156@qq.com - * @LastEditTime: 2025-04-28 12:13:24 + * @LastEditTime: 2025-04-28 13:50:50 * @Description: bytedesk.com https://github.com/Bytedesk/bytedesk * Please be aware of the BSL license restrictions before installing Bytedesk IM – * selling, reselling, or hosting Bytedesk IM as a service is a breach of the terms and automatically terminates your rights under the license. @@ -38,6 +38,8 @@ import com.bytedesk.core.thread.ThreadTypeEnum; import com.bytedesk.core.uid.UidUtils; import com.bytedesk.kbase.settings.ServiceSettingsResponseVisitor; import com.bytedesk.service.agent.AgentEntity; +import com.bytedesk.service.queue_member.QueueMemberEntity; +import com.bytedesk.service.queue_member.QueueMemberRestService; import com.bytedesk.service.utils.ServiceConvertUtils; import com.bytedesk.service.visitor.VisitorRequest; import com.bytedesk.service.workgroup.WorkgroupEntity; @@ -59,6 +61,8 @@ public class VisitorThreadService private final UidUtils uidUtils; + private final QueueMemberRestService queueMemberRestService; + @Override public Page queryByOrg(VisitorThreadRequest request) { Pageable pageable = request.getPageable(); @@ -281,6 +285,10 @@ public class VisitorThreadService } // TODO: 查询超时未回复会话, 发送会话超时提醒 + Optional queueMemberOpt = queueMemberRestService.findByThreadUid(thread.getUid()); + if (queueMemberOpt.isPresent()) { + + } });