| | |
| | | package cc.mrbird.febs.ai.service; |
| | | |
| | | import cc.mrbird.febs.ai.entity.AiMemberTalk; |
| | | import cc.mrbird.febs.ai.req.memberTalk.*; |
| | | 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 java.util.List; |
| | | import reactor.core.publisher.Flux; |
| | | |
| | | import java.util.Date; |
| | | import java.util.function.Consumer; |
| | | |
| | | /** |
| | | * AI用户对话训练记录 Service接口 |
| | |
| | | public interface AiMemberTalkService extends IService<AiMemberTalk> { |
| | | |
| | | |
| | | AiMemberTalk getById(String id); |
| | | |
| | | FebsResponse start(ApiMemberTalkDto dto); |
| | | |
| | | FebsResponse reload(ApiMemberTalkReloadDto 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); |
| | | } |