mirror of
https://gitcode.com/ageerle/ruoyi-ai.git
synced 2026-04-14 12:23:39 +00:00
feat:修复缺少的微信逻辑部分
This commit is contained in:
@@ -8,6 +8,7 @@ import me.chanjar.weixin.cp.bean.message.WxCpXmlMessage;
|
|||||||
import me.chanjar.weixin.cp.bean.message.WxCpXmlOutMessage;
|
import me.chanjar.weixin.cp.bean.message.WxCpXmlOutMessage;
|
||||||
|
|
||||||
import org.ruoyi.builder.TextBuilder;
|
import org.ruoyi.builder.TextBuilder;
|
||||||
|
|
||||||
import org.ruoyi.service.IChatVxService;
|
import org.ruoyi.service.IChatVxService;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,19 @@
|
|||||||
|
package org.ruoyi.service;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 企业微信聊天管理Service接口
|
||||||
|
*
|
||||||
|
* @author ageerle
|
||||||
|
* @date 2025-04-08
|
||||||
|
*/
|
||||||
|
public interface IChatVxService {
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 企业微信应用回复
|
||||||
|
* @param prompt 提示词
|
||||||
|
* @return 回复内容
|
||||||
|
*/
|
||||||
|
String chat(String prompt);
|
||||||
|
|
||||||
|
}
|
||||||
@@ -0,0 +1,38 @@
|
|||||||
|
package org.ruoyi.service.impl;
|
||||||
|
|
||||||
|
import lombok.RequiredArgsConstructor;
|
||||||
|
import lombok.extern.slf4j.Slf4j;
|
||||||
|
|
||||||
|
import org.ruoyi.common.chat.entity.chat.ChatCompletion;
|
||||||
|
import org.ruoyi.common.chat.entity.chat.ChatCompletionResponse;
|
||||||
|
import org.ruoyi.common.chat.entity.chat.Message;
|
||||||
|
import org.ruoyi.common.chat.openai.OpenAiStreamClient;
|
||||||
|
import org.ruoyi.service.IChatVxService;
|
||||||
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import java.util.ArrayList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
|
@Service
|
||||||
|
@Slf4j
|
||||||
|
@RequiredArgsConstructor
|
||||||
|
public class ChatVxServiceImpl implements IChatVxService {
|
||||||
|
|
||||||
|
private final OpenAiStreamClient openAiStreamClient;
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String chat(String prompt) {
|
||||||
|
List<Message> messageList = new ArrayList<>();
|
||||||
|
Message message = Message.builder().role(Message.Role.USER).content(prompt).build();
|
||||||
|
messageList.add(message);
|
||||||
|
ChatCompletion chatCompletion = ChatCompletion
|
||||||
|
.builder()
|
||||||
|
.messages(messageList)
|
||||||
|
.model("gpt-4o-mini")
|
||||||
|
.stream(false)
|
||||||
|
.build();
|
||||||
|
ChatCompletionResponse chatCompletionResponse = openAiStreamClient.chatCompletion(chatCompletion);
|
||||||
|
return chatCompletionResponse.getChoices().get(0).getMessage().getContent().toString();
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user