| | |
| | | |
| | | @Override |
| | | public AiMemberTalkItem getById(String id) { |
| | | return this.getById(id); |
| | | return aiMemberTalkItemMapper.selectById(id); |
| | | } |
| | | |
| | | @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; |
| | | } |
| | | } |
| | | } |