| | |
| | | import cc.mrbird.febs.ai.entity.AiMemberTalkItem; |
| | | import cc.mrbird.febs.ai.mapper.AiMemberTalkItemMapper; |
| | | import cc.mrbird.febs.ai.service.AiMemberTalkItemService; |
| | | import cc.mrbird.febs.ai.utils.UUID; |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; |
| | | import lombok.RequiredArgsConstructor; |
| | |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.transaction.annotation.Transactional; |
| | | |
| | | import java.util.Date; |
| | | import java.util.List; |
| | | |
| | | /** |
| | |
| | | |
| | | private final AiMemberTalkItemMapper aiMemberTalkItemMapper; |
| | | |
| | | |
| | | @Override |
| | | public AiMemberTalkItem getById(String id) { |
| | | return this.getById(id); |
| | | public void add(String memberUuid, String id, int type, String resContext,Date createdTime) { |
| | | AiMemberTalkItem aiMemberTalkItem = new AiMemberTalkItem(); |
| | | aiMemberTalkItem.setId(UUID.getSimpleUUIDString()); |
| | | aiMemberTalkItem.setCreatedTime(createdTime); |
| | | aiMemberTalkItem.setMemberId(memberUuid); |
| | | aiMemberTalkItem.setMemberTalkId(id); |
| | | aiMemberTalkItem.setType(type); |
| | | aiMemberTalkItem.setContext(resContext); |
| | | aiMemberTalkItemMapper.insert(aiMemberTalkItem); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalkItem> getByMemberTalkId(String memberTalkId) { |
| | | LambdaQueryWrapper<AiMemberTalkItem> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalkItem::getMemberTalkId, memberTalkId); |
| | | queryWrapper.orderByAsc(AiMemberTalkItem::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalkItem> getByMemberId(String memberId) { |
| | | LambdaQueryWrapper<AiMemberTalkItem> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalkItem::getMemberId, memberId); |
| | | queryWrapper.orderByAsc(AiMemberTalkItem::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalkItem> getByType(Integer type) { |
| | | LambdaQueryWrapper<AiMemberTalkItem> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalkItem::getType, type); |
| | | queryWrapper.orderByAsc(AiMemberTalkItem::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean saveTalkItem(AiMemberTalkItem aiMemberTalkItem) { |
| | | try { |
| | | return this.save(aiMemberTalkItem); |
| | | } catch (Exception e) { |
| | | log.error("保存对话项失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean saveBatchTalkItems(List<AiMemberTalkItem> talkItems) { |
| | | try { |
| | | return this.saveBatch(talkItems); |
| | | } catch (Exception e) { |
| | | log.error("批量保存对话项失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean updateTalkItem(AiMemberTalkItem aiMemberTalkItem) { |
| | | try { |
| | | return this.updateById(aiMemberTalkItem); |
| | | } catch (Exception e) { |
| | | log.error("更新对话项失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean deleteById(String id) { |
| | | try { |
| | | return this.removeById(id); |
| | | } catch (Exception e) { |
| | | log.error("删除对话项失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean deleteByMemberTalkId(String memberTalkId) { |
| | | try { |
| | | LambdaQueryWrapper<AiMemberTalkItem> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalkItem::getMemberTalkId, memberTalkId); |
| | | return this.remove(queryWrapper); |
| | | } catch (Exception e) { |
| | | log.error("根据对话ID删除对话项失败: ", e); |
| | | return false; |
| | | } |
| | | public AiMemberTalkItem getByQuery(LambdaQueryWrapper<AiMemberTalkItem> memberTalkItemQuery) { |
| | | return aiMemberTalkItemMapper.selectOne(memberTalkItemQuery); |
| | | } |
| | | } |