From d097cca97b1ab6717b37bce5cd48cca1c5ab69a1 Mon Sep 17 00:00:00 2001 From: guyue <1721849008@qq.com> Date: 星期三, 09 七月 2025 19:36:05 +0800 Subject: [PATCH] 提问词excel,获取客户列表, --- src/main/java/com/linghu/service/impl/OrderServiceImpl.java | 91 +++++++++++++++++++++++++++++++++++++++++---- 1 files changed, 83 insertions(+), 8 deletions(-) diff --git a/src/main/java/com/linghu/service/impl/OrderServiceImpl.java b/src/main/java/com/linghu/service/impl/OrderServiceImpl.java index e8fa8ba..c3b8602 100644 --- a/src/main/java/com/linghu/service/impl/OrderServiceImpl.java +++ b/src/main/java/com/linghu/service/impl/OrderServiceImpl.java @@ -1,12 +1,26 @@ package com.linghu.service.impl; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; +import com.linghu.model.dto.KeywordDto; import com.linghu.model.dto.OrderDto; import com.linghu.model.entity.Keyword; -import com.linghu.model.entity.Order; +import com.linghu.model.entity.Orders; +import com.linghu.model.entity.Question; import com.linghu.service.KeywordService; import com.linghu.service.OrderService; import com.linghu.mapper.OrderMapper; + +import java.time.LocalDateTime; +import java.util.ArrayList; +import java.util.List; +import java.util.stream.Collectors; + +import com.linghu.service.QuestionService; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -18,19 +32,19 @@ * @createDate 2025-07-04 20:17:33 */ @Service -public class OrderServiceImpl extends ServiceImpl<OrderMapper, Order> +public class OrderServiceImpl extends ServiceImpl<OrderMapper, Orders> implements OrderService { @Autowired private KeywordService keywordService; + @Autowired + private QuestionService questionService; + @Autowired + private OrderMapper orderMapper; @Override @Transactional(rollbackFor = Exception.class) - public boolean saveOrderWithKeywords(OrderDto orderDto) { - // 保存订单 - if (!this.save(orderDto)) { - return false; - } + public boolean saveOrderWithKeywords(OrderDto orderDto, String order_id) { // 如果有关键词,则保存关键词 if (StringUtils.hasText(orderDto.getKeywords())) { @@ -38,13 +52,14 @@ for (String keywordName : keywordArray) { if (StringUtils.hasText(keywordName)) { Keyword keyword = new Keyword(); - keyword.setOrder_id(orderDto.getOrder_id()); + keyword.setOrder_id(order_id); keyword.setKeyword_name(keywordName.trim()); keyword.setStatus("notSubmitted"); // keyword.setNum(1); // 默认采集轮数为1 keywordService.save(keyword); } } + } return true; @@ -85,4 +100,64 @@ return true; } + + @Override + public List<KeywordDto> getKeywordListByOrderId(String orderId) { + List<Keyword> keywords = keywordService.lambdaQuery() + .eq(Keyword::getOrder_id, orderId) + .list(); + + // 遍历关键词,获取每个关键词对应的提问词 + List<KeywordDto> keywordDtos = new ArrayList<>(); + for (Keyword keyword : keywords) { + KeywordDto dto = new KeywordDto(); + BeanUtils.copyProperties(keyword, dto); + + // 查询该关键词下的所有提问词 + List<Question> questions = questionService.lambdaQuery() + .eq(Question::getKeyword_id, keyword.getKeyword_id()) + .list(); + dto.setQuestionList(questions); + keywordDtos.add(dto); + } + return keywordDtos; + } + + @Override + public Page<String> getClientList(String clientName, Integer pageNum, Integer pageSize) { + Page<Orders> page = new Page<>(pageNum, pageSize); + + // 构建查询条件(根据客户名称模糊搜索) + LambdaQueryWrapper<Orders> queryWrapper = new LambdaQueryWrapper<>(); + queryWrapper.select(Orders::getClient_name) // 只查询客户名称字段 + .eq(Orders::getDel_flag, 0) // 只查询未删除的订单 + .groupBy(Orders::getClient_name); // 按客户名称分组去重 + + if (clientName != null && !clientName.isEmpty()) { + queryWrapper.like(Orders::getClient_name, clientName); + } + + // 执行分页查询 + IPage<Orders> orderPage = orderMapper.selectPage(page, queryWrapper); + + // 转换为客户选项列表(统计每个客户的订单数量) + List<String> clientOptions = orderPage.getRecords().stream() + .map(order -> { + + + return order.getClient_name(); + }) + .collect(Collectors.toList()); + + // 构建结果分页对象 + Page<String> resultPage = new Page<>(); + resultPage.setCurrent(orderPage.getCurrent()); + resultPage.setSize(orderPage.getSize()); + resultPage.setTotal(orderPage.getTotal()); + resultPage.setRecords(clientOptions); + + return resultPage; + + + } } -- Gitblit v1.7.1