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