ZF/weiyu
1
0
Fork 0
mirror of https://gitee.com/270580156/weiyu.git synced 2025-12-30 10:52:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

update

Browse Source
This commit is contained in:
jack ning
2025-11-21 16:54:27 +08:00
parent f37ef582be
commit 38c19f359a
2 changed files with 2 additions and 43 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
modules/core/src/main/java/com/bytedesk/core/utils/ConvertUtils.java
View File

@@ -251,52 +251,10 @@ public class ConvertUtils {
}
}
// 手动设置状态判断字段
// threadResponse.setNewStatus(thread.isNew());
// threadResponse.setRobotingStatus(thread.isRoboting());
// threadResponse.setQueuingStatus(thread.isQueuing());
// threadResponse.setOfflineStatus(thread.isOffline());
// threadResponse.setChattingStatus(thread.isChatting());
// threadResponse.setTimeoutStatus(thread.isTimeout());
// threadResponse.setClosedStatus(thread.isClosed());
// // 手动设置类型判断字段
// threadResponse.setCustomerServiceType(thread.isCustomerService());
// threadResponse.setRobotType(thread.isRobotType());
// threadResponse.setWorkgroupType(thread.isWorkgroupType());
// threadResponse.setAgentType(thread.isAgentType());
// threadResponse.setUnifiedType(thread.isUnifiedType());
// // 手动设置渠道判断字段
// threadResponse.setWeChatMpChannel(thread.isWeChatMp());
// threadResponse.setWeChatMiniChannel(thread.isWeChatMini());
// 手动设置业务逻辑字段
threadResponse.setRobotToAgent(thread.isRobotToAgent());
// 关闭来源类型
threadResponse.setCloseType(thread.getCloseType());
// boolean messagesInitialized = thread.getMessages() != null && Hibernate.isInitialized(thread.getMessages());
// if (messagesInitialized) {
// // Only touch lazy collection when it is fully initialized
// threadResponse.setValid(thread.isValid());
// threadResponse.setUnreadCount(thread.getUnreadCount());
// threadResponse.setVisitorUnreadCount(thread.getVisitorUnreadCount());
// threadResponse.setAllMessageCount(thread.getAllMessageCount());
// threadResponse.setVisitorMessageCount(thread.getVisitorMessageCount());
// threadResponse.setAgentMessageCount(thread.getAgentMessageCount());
// threadResponse.setSystemMessageCount(thread.getSystemMessageCount());
// threadResponse.setRobotMessageCount(thread.getRobotMessageCount());
// } else {
// threadResponse.setValid(null);
// threadResponse.setUnreadCount(null);
// threadResponse.setVisitorUnreadCount(null);
// threadResponse.setAllMessageCount(null);
// threadResponse.setVisitorMessageCount(null);
// threadResponse.setAgentMessageCount(null);
// threadResponse.setSystemMessageCount(null);
// threadResponse.setRobotMessageCount(null);
// }
//
return threadResponse;
}

3
modules/service/src/main/java/com/bytedesk/service/agent/AgentRestService.java
View File

@@ -251,6 +251,7 @@ public class AgentRestService extends BaseRestService<AgentEntity, AgentRequest,
@Transactional
public ThreadResponseSimple acceptByAgent(ThreadRequest threadRequest) {
//
UserEntity user = authService.getUser();
Optional<AgentEntity> agentOptional = agentRepository.findByUserUid(user.getUid());
if (!agentOptional.isPresent()) {
@@ -279,7 +280,7 @@ public class AgentRestService extends BaseRestService<AgentEntity, AgentRequest,
// 通知queue更新，queue member更新, 增加agent接待数量
bytedeskEventPublisher.publishEvent(new ThreadAddTopicEvent(this, updateThread));
bytedeskEventPublisher.publishEvent(new ThreadAcceptEvent(this, updateThread));
//
return ConvertUtils.convertToThreadResponseSimple(updateThread);
}