| | |
| | | |
| | | private final AiMemberTalkMapper aiMemberTalkMapper; |
| | | |
| | | @Override |
| | | public AiMemberTalk getById(String id) { |
| | | return this.getById(id); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalk> getByMemberId(String memberId) { |
| | | LambdaQueryWrapper<AiMemberTalk> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalk::getMemberId, memberId); |
| | | queryWrapper.orderByDesc(AiMemberTalk::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalk> getByProductId(String productId) { |
| | | LambdaQueryWrapper<AiMemberTalk> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalk::getProductId, productId); |
| | | queryWrapper.orderByDesc(AiMemberTalk::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalk> getByProductRoleId(String productRoleId) { |
| | | LambdaQueryWrapper<AiMemberTalk> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalk::getProductRoleId, productRoleId); |
| | | queryWrapper.orderByDesc(AiMemberTalk::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | public List<AiMemberTalk> getByCompanyId(String companyId) { |
| | | LambdaQueryWrapper<AiMemberTalk> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalk::getCompanyId, companyId); |
| | | queryWrapper.orderByDesc(AiMemberTalk::getCreatedTime); |
| | | return this.list(queryWrapper); |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean saveTalk(AiMemberTalk aiMemberTalk) { |
| | | try { |
| | | return this.save(aiMemberTalk); |
| | | } catch (Exception e) { |
| | | log.error("保存对话记录失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean saveBatchTalks(List<AiMemberTalk> talks) { |
| | | try { |
| | | return this.saveBatch(talks); |
| | | } catch (Exception e) { |
| | | log.error("批量保存对话记录失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | |
| | | @Override |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public boolean updateTalk(AiMemberTalk aiMemberTalk) { |
| | | try { |
| | | return this.updateById(aiMemberTalk); |
| | | } 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 deleteByMemberId(String memberId) { |
| | | try { |
| | | LambdaQueryWrapper<AiMemberTalk> queryWrapper = new LambdaQueryWrapper<>(); |
| | | queryWrapper.eq(AiMemberTalk::getMemberId, memberId); |
| | | return this.remove(queryWrapper); |
| | | } catch (Exception e) { |
| | | log.error("根据用户ID删除对话记录失败: ", e); |
| | | return false; |
| | | } |
| | | } |
| | | } |