hula/HuLa-Server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.优化ai消息的校验

Browse Source
This commit is contained in:
乾乾
2025-05-15 21:08:28 +08:00
parent 66fc22df6a
commit f04c7fb7a4
6 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hula-im-service/src/main/java/com/hula/ai/gpt/service/impl/GptServiceImpl.java
View File

@@ -21,6 +21,7 @@ import com.hula.ai.gpt.pojo.entity.Assistant;
import com.hula.ai.gpt.pojo.vo.ChatVO;
import com.hula.ai.gpt.service.IChatMessageService;
import com.hula.ai.gpt.service.IChatService;
import com.hula.core.user.domain.entity.User;
import com.hula.core.user.domain.vo.resp.user.UserInfoResp;
import com.hula.core.user.service.ConfigService;
import com.hula.core.user.service.UserService;
@@ -160,7 +161,7 @@ public class GptServiceImpl implements GptService {
* @param command
*/
private void validateUser(ChatCommand command) {
UserInfoResp user = userService.getUserInfo(command.getUid());
User user = userService.getUserById(command.getUid());
if (ObjectUtil.isNull(user)) {
throw new BizException("用户不存在!");
}

4
hula-im-service/src/main/java/com/hula/ai/llm/base/service/impl/TongYiServiceImpl.java
View File

@@ -90,9 +90,7 @@ public class TongYiServiceImpl implements ModelService {
throw new BizException("未加载到密钥信息");
}
MessageManager msgManager = new MessageManager(20);
chatMessages.stream().forEach(v -> {
msgManager.add(Message.builder().role(v.getRole()).content(v.getContent()).build());
});
chatMessages.stream().forEach(v -> msgManager.add(Message.builder().role(v.getRole()).content(v.getContent()).build()));
Generation gen = new Generation();
QwenParam param = QwenParam.builder().apiKey(tongYiClient.getAppKey())
.model(ObjectUtil.isNotNull(version) ? version : Generation.Models.QWEN_TURBO)

2
hula-im-service/src/main/java/com/hula/core/user/domain/vo/req/user/SummeryInfoReq.java
View File

@@ -21,7 +21,7 @@ import java.util.List;
@NoArgsConstructor
public class SummeryInfoReq extends BaseEntity {
@ApiModelProperty(value = "用户信息入参")
@Size(max = 50)
@Size(max = 50, message = "一次最多查询50个用户数据")
private List<infoReq> reqList;
@Data

8
hula-im-service/src/main/java/com/hula/core/user/service/UserService.java
View File

@@ -2,6 +2,7 @@ package com.hula.core.user.service;
import com.hula.core.user.domain.dto.ItemInfoDTO;
import com.hula.core.user.domain.dto.SummeryInfoDTO;
import com.hula.core.user.domain.entity.User;
import com.hula.core.user.domain.vo.req.user.*;
import com.hula.core.user.domain.vo.resp.user.BadgeResp;
import com.hula.core.user.domain.vo.resp.user.UserInfoResp;
@@ -17,6 +18,13 @@ import java.util.List;
*/
public interface UserService {
/**
* 获取用户基础信息 [DB]
*
* @param uid
*
*/
User getUserById(Long uid);
/**
* 获取前端展示信息

2
hula-im-service/src/main/java/com/hula/core/user/service/impl/FriendServiceImpl.java
View File

@@ -215,7 +215,7 @@ public class FriendServiceImpl implements FriendService {
AssertUtil.equal(userApply.getStatus(), WAIT_APPROVAL.getCode(), "已同意好友申请");
// 同意申请
userApplyDao.agree(request.getApplyId());
//创建双方好友关系
// 创建双方好友关系
createFriend(uid, userApply.getUid());
// 创建一个聊天房间
RoomFriend roomFriend = roomService.createFriendRoom(Arrays.asList(uid, userApply.getUid()));

5
hula-im-service/src/main/java/com/hula/core/user/service/impl/UserServiceImpl.java
View File

@@ -58,6 +58,11 @@ public class UserServiceImpl implements UserService {
private UserSummaryCache userSummaryCache;
private SensitiveWordBs sensitiveWordBs;
@Override
public User getUserById(Long uid) {
return userDao.getById(uid);
}
@Override
public UserInfoResp getUserInfo(Long uid) {
User userInfo = userCache.getUserInfo(uid);