mirror of
https://gitcode.com/ageerle/ruoyi-ai.git
synced 2026-04-05 15:57:32 +00:00
Merge remote-tracking branch 'origin/main'
This commit is contained in:
@@ -63,6 +63,24 @@ public class ChatConfigController extends BaseController {
|
||||
return R.ok(configService.getConfigValue("sys",configKey));
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询版权信息
|
||||
*
|
||||
*/
|
||||
@GetMapping(value = "/configKey/copyright")
|
||||
public R<String> getConfigKeyCopyright() {
|
||||
return R.ok(configService.getConfigValue("sys","copyright"));
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询logoImage
|
||||
*
|
||||
*/
|
||||
@GetMapping(value = "/configKey/logoImage")
|
||||
public R<String> getConfigKeyLogoImage() {
|
||||
return R.ok(configService.getConfigValue("sys","logoImage"));
|
||||
}
|
||||
|
||||
/**
|
||||
* 查询系统参数
|
||||
*
|
||||
|
||||
@@ -31,7 +31,6 @@ public class SysNoticeController extends BaseController {
|
||||
/**
|
||||
* 获取公告列表
|
||||
*/
|
||||
@SaCheckPermission("system:notice:list")
|
||||
@GetMapping("/list")
|
||||
public TableDataInfo<SysNoticeVo> list(SysNoticeBo notice, PageQuery pageQuery) {
|
||||
//公告类型(1通知 2公告)
|
||||
|
||||
@@ -97,5 +97,15 @@ public class ChatGpts extends BaseEntity {
|
||||
*/
|
||||
private String updateIp;
|
||||
|
||||
/**
|
||||
* 模型名称
|
||||
*/
|
||||
private String modelName;
|
||||
|
||||
|
||||
/**
|
||||
* 模型system
|
||||
*/
|
||||
private String systemPrompt;
|
||||
|
||||
}
|
||||
|
||||
@@ -84,4 +84,14 @@ public class ChatGptsBo extends BaseEntity {
|
||||
*/
|
||||
private String updateIp;
|
||||
|
||||
/**
|
||||
* 模型名称
|
||||
*/
|
||||
private String modelName;
|
||||
|
||||
/**
|
||||
* 模型system
|
||||
*/
|
||||
private String systemPrompt;
|
||||
|
||||
}
|
||||
|
||||
@@ -96,5 +96,16 @@ public class ChatGptsVo implements Serializable {
|
||||
@ExcelProperty(value = "更新IP")
|
||||
private String updateIp;
|
||||
|
||||
/**
|
||||
* 模型名称
|
||||
*/
|
||||
@ExcelProperty(value = "模型名称")
|
||||
private String modelName;
|
||||
|
||||
/**
|
||||
* 模型system
|
||||
*/
|
||||
private String systemPrompt;
|
||||
|
||||
|
||||
}
|
||||
|
||||
@@ -106,7 +106,8 @@ public class SSEEventSourceListener extends EventSourceListener {
|
||||
}
|
||||
Object content = completionResponse.getChoices().get(0).getDelta().getContent();
|
||||
if(content == null){
|
||||
return;
|
||||
content = completionResponse.getChoices().get(0).getDelta().getReasoningContent();
|
||||
if(content == null) return;
|
||||
}
|
||||
if(StringUtils.isEmpty(modelName)){
|
||||
modelName = completionResponse.getModel();
|
||||
|
||||
@@ -228,7 +228,9 @@ public class SysLoginService {
|
||||
TenantHelper.clearDynamic();
|
||||
}
|
||||
StpUtil.logout();
|
||||
recordLogininfor(loginUser.getTenantId(), loginUser.getUsername(), Constants.LOGOUT, MessageUtils.message("user.logout.success"));
|
||||
if (loginUser !=null) {
|
||||
recordLogininfor(loginUser.getTenantId(), loginUser.getUsername(), Constants.LOGOUT, MessageUtils.message("user.logout.success"));
|
||||
}
|
||||
} catch (NotLoginException ignored) {
|
||||
}
|
||||
}
|
||||
|
||||
@@ -44,6 +44,7 @@ import org.ruoyi.common.satoken.utils.LoginHelper;
|
||||
import org.ruoyi.system.domain.SysModel;
|
||||
import org.ruoyi.system.domain.bo.ChatMessageBo;
|
||||
import org.ruoyi.system.domain.request.translation.TranslationRequest;
|
||||
import org.ruoyi.system.domain.vo.ChatGptsVo;
|
||||
import org.ruoyi.system.listener.SSEEventSourceListener;
|
||||
import org.ruoyi.system.service.*;
|
||||
import org.springframework.core.io.InputStreamResource;
|
||||
@@ -88,6 +89,8 @@ public class SseServiceImpl implements ISseService {
|
||||
|
||||
private final ConfigService configService;
|
||||
|
||||
private final IChatGptsService chatGptsService;
|
||||
|
||||
static final OkHttpClient HTTP_CLIENT = new OkHttpClient().newBuilder().build();
|
||||
|
||||
private static final String requestIdTemplate = "mycompany-%d";
|
||||
@@ -132,20 +135,22 @@ public class SseServiceImpl implements ISseService {
|
||||
chatMessageBo.setContent(chatString);
|
||||
|
||||
String model = chatRequest.getModel();
|
||||
// 如果是gpts系列模型
|
||||
if (chatRequest.getModel().startsWith("gpt-4-gizmo")) {
|
||||
model = "gpt-4-gizmo";
|
||||
}
|
||||
SysModel sysModel = sysModelService.selectModelByName(model);
|
||||
if (sysModel == null) {
|
||||
// 如果模型不存在默认使用token扣费方式
|
||||
processByToken(chatRequest.getModel(), chatString, chatMessageBo);
|
||||
} else {
|
||||
openAiStreamClient = chatConfig.createOpenAiStreamClient(sysModel.getApiHost(), sysModel.getApiKey());
|
||||
// 模型设置默认提示词
|
||||
if (StringUtils.isNotEmpty(sysModel.getSystemPrompt())) {
|
||||
Message sysMessage = Message.builder().content(sysModel.getSystemPrompt()).role(Message.Role.SYSTEM).build();
|
||||
messages.add(sysMessage);
|
||||
if (StringUtils.isNotEmpty(chatRequest.getAppId())) { // 设置应用的系统角色为描述
|
||||
ChatGptsVo chatGptsVo = chatGptsService.queryById(Long.valueOf(chatRequest.getAppId()));
|
||||
Message sysMessage = Message.builder().content(chatGptsVo.getSystemPrompt()).role(Message.Role.SYSTEM).build();
|
||||
messages.add(0,sysMessage);
|
||||
} else {
|
||||
// 模型设置默认提示词
|
||||
if (StringUtils.isNotEmpty(sysModel.getSystemPrompt())) {
|
||||
Message sysMessage = Message.builder().content(sysModel.getSystemPrompt()).role(Message.Role.SYSTEM).build();
|
||||
messages.add(0,sysMessage);
|
||||
}
|
||||
}
|
||||
// 计费类型: 1 token扣费 2 次数扣费
|
||||
if ("2".equals(sysModel.getModelType())) {
|
||||
|
||||
@@ -63,6 +63,7 @@ public class SysModelServiceImpl implements ISysModelService {
|
||||
lqw.like(StringUtils.isNotBlank(bo.getModelShow()), SysModel::getModelShow, bo.getModelShow());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getModelDescribe()), SysModel::getModelDescribe, bo.getModelDescribe());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getModelType()), SysModel::getModelType, bo.getModelType());
|
||||
lqw.eq(StringUtils.isNotBlank(bo.getCategory()), SysModel::getCategory, bo.getCategory());
|
||||
return lqw;
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user