package cc.mrbird.febs.ai.service;
|
|
import cc.mrbird.febs.ai.entity.AiMemberTalk;
|
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkAnswerDto;
|
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkDto;
|
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkItemPageDto;
|
import cc.mrbird.febs.ai.req.memberTalk.ApiMemberTalkStreamDto;
|
import cc.mrbird.febs.ai.res.ai.AiResponse;
|
import cc.mrbird.febs.common.entity.FebsResponse;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.IService;
|
import reactor.core.publisher.Flux;
|
|
import java.util.Date;
|
import java.util.function.Consumer;
|
|
/**
|
* AI用户对话训练记录 Service接口
|
*
|
* @author yourname
|
* @date 2025-07-29
|
*/
|
public interface AiMemberTalkService extends IService<AiMemberTalk> {
|
|
|
AiMemberTalk getById(String id);
|
|
FebsResponse start(ApiMemberTalkDto dto);
|
|
void startStream(ApiMemberTalkDto dto, Consumer<AiResponse> callback);
|
|
AiMemberTalk getByQuery(LambdaQueryWrapper<AiMemberTalk> query);
|
|
void updateTimeUpdate(Date nowTime, String id);
|
|
FebsResponse answer(ApiMemberTalkAnswerDto dto);
|
|
AiMemberTalk add(String memberUuid, String productId, Date nowTime);
|
|
FebsResponse historyPage(ApiMemberTalkItemPageDto dto);
|
|
Flux<FebsResponse> answerStream(String question);
|
}
|
