1

ltrq-api/src/main/java/api/controller/dify/DifyAssistantController.java

@@ -86,6 +86,13 @@ public class DifyAssistantController extends BaseController {
                                    HttpServletResponse response) throws IOException {
         return difyassistantService.chatMessages(input,CurrentUser(), response);
     }
+    @ApiOperation("工作流")
+    @PostMapping(value = "/workflows", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
+    public SseEmitter workflows(@RequestBody WorkflowsInput input,
+                                   HttpServletResponse response) throws IOException {
+        return difyassistantService.workflows(input,CurrentUser(), response);
+    }
+
     @ApiOperation("消息反馈")
     @Log(title = "消息反馈",businessType = BusinessType.QUERY)
     @PostMapping("/feedbacks")
@@ -136,6 +143,10 @@ public class DifyAssistantController extends BaseController {
     public AjaxResult rename(@RequestBody DifyRenameInput input) throws Exception {
         return Success("成功", difyassistantService.Rename(input,CurrentUser() ));
     }
+
+
+
+
     @ApiOperation("删除")
     @Log(title = "删除dify_assistant",businessType = BusinessType.DELETE)
     @DeleteMapping("/{ids}")

ltrq-api/src/main/java/api/controller/order/OrderBaseController.java

@@ -4,6 +4,7 @@ import api.entity.database.call.CallLog;
 import api.entity.database.order.*;
 import api.entity.database.patient.Patient;
 import api.entity.database.system.*;
+import api.entity.input.order.SimilarOrdersInput;
 import api.entity.input.order.TransOrderInput;
 import api.entity.view.order.*;
 import api.entity.view.system.DeptView;
@@ -33,6 +34,7 @@ import api.service.order.IOrderBaseService;
 import api.util.annotation.Log;
 import api.util.enums.BusinessType;
 import api.util.helper.StringHelper;
+import io.milvus.response.SearchResultsWrapper;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.var;
@@ -41,6 +43,7 @@ import org.springframework.web.bind.annotation.*;
 
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.CompletableFuture;
 import java.util.stream.Collectors;
 
 @Api(value = "新加的controller，蓝天燃气工单用这个",tags = "新加的controller，蓝天燃气工单用这个")
@@ -410,6 +413,7 @@ public class OrderBaseController extends BaseController {
                     }
                 } catch (Exception e) {
                 }
+
                 boolean customerresult = patientService.insert(pt);
             }
             //添加操作日志
@@ -428,6 +432,14 @@ public class OrderBaseController extends BaseController {
 
                 }
             }
+            CompletableFuture.supplyAsync(() -> {
+                try {
+                    orderbaseService.historicalOrders(input);
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+                return null;
+            }).thenAccept(results -> System.out.println("Result: " + results));
             return Success("成功", input.getWorkOrderCode());
         } else {
             return Error("新增失败");
@@ -660,6 +672,10 @@ public class OrderBaseController extends BaseController {
     public AjaxResult end(@RequestBody HashMap<String,String> map) {
         String code= map.get("code");
 
+
+
+
+
         Date currentDate = new Date(System.currentTimeMillis());
 
         LambdaUpdateWrapper< OrderBase> qw = new LambdaUpdateWrapper<>();
@@ -678,6 +694,23 @@ public class OrderBaseController extends BaseController {
         }
 
         if (result) {
+            CompletableFuture.supplyAsync(() -> {
+                try {
+                    LambdaQueryWrapper<OrderBase> queryWrapper = new LambdaQueryWrapper<>();
+                    queryWrapper.eq(OrderBase::getWorkOrderCode, code);
+                    queryWrapper.last("limit 1");
+                    queryWrapper.orderByDesc(OrderBase::getWorkOrderId);
+                    OrderBase  orderBase    = orderbaseService.getEntity(queryWrapper);
+                    if (orderBase!=null&&StringHelper.isNotEmpty(orderBase.getCorrelation()))
+                    {
+                        overOrder(orderBase);
+                    }
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+                return null;
+            }).thenAccept(results -> System.out.println("Result: " + results));
+
             boolean logresult = addlog("完结了工单" + reason, "完结", CurrentUser().getUserName(), code, CurrentUser().getNickName(), "");
             return Success("完结成功");
         } else {
@@ -713,9 +746,90 @@ public class OrderBaseController extends BaseController {
         }
     }
 
+    @ApiOperation("关联工单")
+    @Log(title = "关联工单", businessType = BusinessType.UPDATE)
+    @PutMapping("/correlation/{ids}")
+    public AjaxResult correlation(@PathVariable List<Long> ids) {
+      LambdaQueryWrapper<OrderBase> qw=new LambdaQueryWrapper<>();
+      qw.eq(OrderBase::getIsDelete,0);
+      qw.in(OrderBase::getWorkOrderId,ids);
+      var list=orderbaseService.getList(qw);
+      if (list!=null&&list.size()>0)
+      {
+         var overList=list.stream().filter(x->x.getIsEnd()==1).collect(Collectors.toList());
+         var unfinished=list.stream().filter(x->x.getIsEnd()!=1).collect(Collectors.toList());
+         var mainWorkOrder=new OrderBase();
+         if (overList.size()>0)
+         {
+             mainWorkOrder=overList.get(0);
+         }
+         else
+         {
+             mainWorkOrder=list.get(0);
+         }
+         List<Long>unfinishedIds=new ArrayList<>();
+         if (unfinished.size()>0)
+         {
+             unfinishedIds=unfinished.stream() .map(OrderBase::getWorkOrderId)
+                     .collect(Collectors.toList());
+         }
+          LambdaUpdateWrapper<OrderBase> qu=new LambdaUpdateWrapper<>();
+          qu.eq(OrderBase::getIsDelete,0);
+          qu.in(OrderBase::getWorkOrderId,ids);
+          qu.set(OrderBase::getCorrelation,mainWorkOrder.getWorkOrderId());
+          boolean n=orderbaseService.updateBatch(qu);
+          if (n )
+          {
+              if (overList.size()>0&&unfinishedIds.size()>0)
+              {
+                  LambdaUpdateWrapper<OrderBase> qu1=new LambdaUpdateWrapper<>();
+                  qu1.eq(OrderBase::getIsDelete,0);
+                  qu1.eq(OrderBase::getCorrelation,mainWorkOrder.getWorkOrderId());
+                  qu1.eq(OrderBase::getIsEnd,0);
+                  qu1.set(OrderBase::getWorkOrderState,  EnumOrderStatus.end.getValue());
+                  qu1.set(OrderBase::getIsEnd, 1);
+                  qu1.set(OrderBase::getEndTime, new Date());
+                  qu1.set(OrderBase::getDealUserCode, mainWorkOrder.getDealUserCode());
+                  qu1.set(OrderBase::getDealDept, mainWorkOrder.getDealDept());
+                  qu1.set(OrderBase::getDealUserName, mainWorkOrder.getDealUserName());
+                  qu1.set(OrderBase::getFile,mainWorkOrder.getFile());
+                  qu1.set(OrderBase::getDealContent,mainWorkOrder.getDealContent());
+                  boolean n1=orderbaseService.updateBatch(qu1);
+                  if (!n1)
+                  {
+                      return Error("结案失败");
+                  }
+              }
+              return  Success("关联成功");
+          }
+          else
+          {
+              return Error("关联失败");
+          }
+      }
+      else
+      {
+          return Error("工单不存在");
+      }
 
+    }
 
-
+    private  void overOrder(OrderBase orderBase)
+    {
+        LambdaUpdateWrapper<OrderBase> qu=new LambdaUpdateWrapper<>();
+        qu.eq(OrderBase::getIsDelete,0);
+        qu.eq(OrderBase::getCorrelation,orderBase.getCorrelation());
+        qu.eq(OrderBase::getIsEnd,0);
+        qu.set(OrderBase::getWorkOrderState,  EnumOrderStatus.end.getValue());
+        qu.set(OrderBase::getIsEnd, 1);
+        qu.set(OrderBase::getEndTime, new Date());
+        qu.set(OrderBase::getDealUserCode, orderBase.getDealUserCode());
+        qu.set(OrderBase::getDealDept, orderBase.getDealDept());
+        qu.set(OrderBase::getDealUserName, orderBase.getDealUserName());
+        qu.set(OrderBase::getFile,orderBase.getFile());
+        qu.set(OrderBase::getDealContent,orderBase.getDealContent());
+        boolean n1=orderbaseService.updateBatch(qu);
+    }
     @ApiOperation(" 接单 code")
     @Log(title = "接单,参数是code，以后都用code", businessType = BusinessType.OTHER)
     @PutMapping("/receive")
@@ -807,7 +921,7 @@ public class OrderBaseController extends BaseController {
         String dealContent="";
         if(map.get("result")!=null && !StringHelper.isEmpty(map.get("result").toString())){
             dealContent="，回复内容："+map.get("result").toString();
-
+            qw .set(OrderBase::getDealContent,map.get("result").toString());
         }
         boolean result =   orderbaseService.updateBatch(qw);
         if (result) {
@@ -874,6 +988,22 @@ public class OrderBaseController extends BaseController {
         visitLogService.insert(visitLog);
 
         if (result) {
+            CompletableFuture.supplyAsync(() -> {
+                try {
+                    LambdaQueryWrapper<OrderBase> queryWrapper = new LambdaQueryWrapper<>();
+                    queryWrapper.eq(OrderBase::getWorkOrderCode, code);
+                    queryWrapper.last("limit 1");
+                    queryWrapper.orderByDesc(OrderBase::getWorkOrderId);
+                    OrderBase  orderBase    = orderbaseService.getEntity(queryWrapper);
+                    if (orderBase!=null&&StringHelper.isNotEmpty(orderBase.getCorrelation()))
+                    {
+                        overOrder(orderBase);
+                    }
+                } catch (Exception e) {
+                    throw new RuntimeException(e);
+                }
+                return null;
+            }).thenAccept(results -> System.out.println("Result: " + results));
             boolean logresult = addlog("回访了工单" , "回访", CurrentUser().getUserName(),
                     code , CurrentUser().getNickName(), "");
             return Success("回访成功");
@@ -882,6 +1012,25 @@ public class OrderBaseController extends BaseController {
         }
     }
 
-
+    @ApiOperation("查找相似工单")
+    @Log(title = "查找相似工单",businessType = BusinessType.QUERY)
+    @PostMapping("/detection")
+    @Anonymous
+    public AjaxResult detection(@RequestBody SimilarOrdersInput input ) {
+        var result = orderbaseService.findSimilarOrders(input.getContent(),input.getTopK());
+        return Success("成功",result);
+    }
+    @ApiOperation("添加历史工单")
+    @Log(title = "添加历史工单",businessType = BusinessType.INSERT)
+    @GetMapping("/addHistorical")
+    @Anonymous
+    public AjaxResult addHistorical() {
+        var list=orderbaseService.getList();
+        for (OrderBase item :list)
+        {
+            orderbaseService.historicalOrders(item);
+        }
+        return  Success("添加工单");
+    }
 
 }

ltrq-api/src/main/resources/application-dev.yml

@@ -80,3 +80,4 @@ spring:
   milvusclient:
     host: 192.168.1.89
     port: 19530
+

ltrq-entity/src/main/java/api/entity/database/order/OrderBase.java

@@ -132,4 +132,13 @@ public class OrderBase {
     /** 回访人 */
     @ApiModelProperty("回访人 ")
     private String visitUser ;
+
+    /** 关联工单 */
+    @ApiModelProperty("关联工单 ")
+    private String correlation ;
+
+    /** 处理结果 */
+    @ApiModelProperty("处理结果 ")
+    private String dealContent ;
+
 }

ltrq-entity/src/main/java/api/entity/input/dify/WorkflowsInput.java

@@ -0,0 +1,14 @@
+package api.entity.input.dify;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+import java.util.Map;
+
+@Data
+public class WorkflowsInput {
+    @ApiModelProperty("允许传入 App 定义的各变量值。 inputs 参数包含了多组键值对")
+    private Map<String,Object> inputs;
+    @ApiModelProperty("选用助手id")
+    private Long id;
+}

ltrq-entity/src/main/java/api/entity/input/order/SimilarOrdersInput.java

@@ -0,0 +1,12 @@
+package api.entity.input.order;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class SimilarOrdersInput {
+    @ApiModelProperty("内容")
+    private  String  content;
+    @ApiModelProperty("条数")
+    private  Integer topK ;
+}

ltrq-entity/src/main/java/api/entity/view/order/SimilarOrdersView.java

@@ -0,0 +1,12 @@
+package api.entity.view.order;
+
+
+import api.entity.database.order.OrderBase;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class SimilarOrdersView extends OrderBase {
+    @ApiModelProperty("相似度")
+    private Float similarity;
+}

ltrq-entity/src/main/java/api/entity/view/order/SimilarityView.java

@@ -0,0 +1,12 @@
+package api.entity.view.order;
+
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+
+@Data
+public class SimilarityView {
+    @ApiModelProperty("工单id")
+    private Long id;
+    @ApiModelProperty("相似度")
+    private Float similarity;
+}

ltrq-service/src/main/java/api/service/dify/IDifyAssistantService.java

@@ -14,6 +14,10 @@ public interface IDifyAssistantService extends IBaseService<DifyAssistant> {
     //发送对话消息
     SseEmitter chatMessages(DifyChatMessagesInput input, UserView userView, HttpServletResponse response) throws IOException;
 
+    //发送工作流
+    SseEmitter workflows(WorkflowsInput difyInput,
+                         UserView userView, HttpServletResponse response) throws IOException;
+
     //消息反馈
     String feedbacks(DifyFeedbacksInput input,
                      UserView userView) throws IOException;

ltrq-service/src/main/java/api/service/dify/impl/DifyAssistantServiceImpl.java

@@ -9,6 +9,7 @@ import api.service.dify.IDifyAssistantService;
 import api.service.BaseServiceImpl;
 import api.util.helper.HttpHelper;
 import api.util.helper.StringHelper;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.gson.Gson;
 import lombok.var;
 import org.springframework.stereotype.Service;
@@ -65,10 +66,15 @@ public class DifyAssistantServiceImpl extends BaseServiceImpl<DifyAssistantMappe
                 builder.append("]");
                 files=builder.toString();
             }
-
+            String jsonString="";
+            if (difyInput.getInputs()!=null)
+            {
+                ObjectMapper objectMapper = new ObjectMapper();
+                jsonString= objectMapper.writeValueAsString(difyInput.getInputs());
+            }
             // 2. 创建JSON请求体
             String jsonBody = "{"
-                    + "\"inputs\": {},"
+                    + "\"inputs\": "+jsonString+","
                     + "\"query\": \""+difyInput.getQuery()+"\","
                     + "\"response_mode\": \"streaming\","
                     + "\"conversation_id\": \""+difyInput.getConversation_id()+"\","
@@ -98,8 +104,9 @@ public class DifyAssistantServiceImpl extends BaseServiceImpl<DifyAssistantMappe
                 try {
                     while ((line = reader.readLine()) != null) {
                         if (line.startsWith("data: {\"event\": \"message\"") ||line.startsWith("data: {\"event\": \"message_end\"")) {
-                            writer.write(line);
-                            System.out.println(line);
+                            writer.write(unicodeToString(line)+"\n");
+                            // sseEmitter.send(unicodeToString(line)); // 实时发送单条结果
+                            System.out.println(unicodeToString(line));
                             writer.flush();
                         }
                     }
@@ -117,6 +124,97 @@ public class DifyAssistantServiceImpl extends BaseServiceImpl<DifyAssistantMappe
         return sseEmitter;
     }
 
+    //发送工作流
+    @Override
+    public SseEmitter workflows(WorkflowsInput difyInput,
+                                UserView userView, HttpServletResponse response) throws IOException {
+        SseEmitter sseEmitter = new SseEmitter();
+        // 设置MIME类型为text/event-stream以符合SSE要求
+        response.setContentType("text/event-stream");
+        response.setCharacterEncoding("UTF-8");
+        PrintWriter writer = response.getWriter();
+        try {
+            var dify=this .getEntity(difyInput.getId());
+            // 1. 设置URL和API密钥
+            String apiUrl = dify.getUrl()+"/workflows/run";
+            String apiKey = dify.getSecretKey(); // 替换为实际API密钥
+            String jsonString="";
+            if (difyInput.getInputs()!=null)
+            {
+                ObjectMapper objectMapper = new ObjectMapper();
+                jsonString= objectMapper.writeValueAsString(difyInput.getInputs());
+            }
+
+            // 2. 创建JSON请求体
+            String jsonBody = "{"
+                    + "\"inputs\": "+jsonString+","
+                    + "\"response_mode\": \"streaming\","
+                    + "\"user\": \""+userView.getUserName()+"\""
+                    + "}";
+            // 3. 创建HTTP连接
+            URL url = new URL(apiUrl);
+            HttpURLConnection conn = (HttpURLConnection) url.openConnection();
+            conn.setRequestMethod("POST");
+            conn.setRequestProperty("Authorization", "Bearer " + apiKey);
+            conn.setRequestProperty("Content-Type", "application/json");
+            conn.setDoOutput(true);
+            // 4. 发送请求体
+            try (OutputStream os = conn.getOutputStream()) {
+                byte[] input = jsonBody.getBytes(StandardCharsets.UTF_8);
+                os.write(input, 0, input.length);
+            }
+            // 获取响应码
+            int responseCode = conn.getResponseCode();
+            if (responseCode == HttpURLConnection.HTTP_OK) {
+                // 获取响应输入流
+                InputStream inputStream = conn.getInputStream();
+                BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));
+                String line;
+                try {
+                    while ((line = reader.readLine()) != null) {
+                        writer.write(unicodeToString(line)+"\n");
+                        // sseEmitter.send(unicodeToString(line)); // 实时发送单条结果
+                        System.out.println(unicodeToString(line));
+                        writer.flush();
+                    }
+                } catch (IOException e) {
+                    e.printStackTrace();
+                }
+            } else {
+                System.out.println("POST Request is not successful");
+            }
+            conn.disconnect();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        sseEmitter.complete();
+        return sseEmitter;
+    }
+
+    private static String unicodeToString(String unicode) {
+        StringBuilder sb = new StringBuilder();
+        int i = -1;
+        int pos = 0;
+
+        while ((i = unicode.indexOf("\\u", pos)) != -1) {
+            sb.append(unicode.substring(pos, i));
+            if (i + 5 > unicode.length()) {
+                pos = i + 2;
+                continue;
+            }
+            String hex = unicode.substring(i + 2, i + 6);
+            try {
+                sb.append((char) Integer.parseInt(hex, 16));
+                pos = i + 6;
+            } catch (NumberFormatException e) {
+                sb.append(unicode.substring(i, i + 2));
+                pos = i + 2;
+            }
+        }
+
+        sb.append(unicode.substring(pos));
+        return sb.toString();
+    }
     //消息反馈
     @Override
     public  String feedbacks(DifyFeedbacksInput input,
@@ -135,7 +233,7 @@ public class DifyAssistantServiceImpl extends BaseServiceImpl<DifyAssistantMappe
     //获取APP的消息点赞和反馈
     @Override
     public  String appFeedbacks(PageInput pageInput,long  id
-                               ) throws Exception {
+    ) throws Exception {
         var dify=this .getEntity(id);
         String apiUrl = dify.getUrl()+"/app/feedbacks?page="+pageInput.getPageNum()+"&limit="+pageInput.getPageSize();
         return   HttpHelper.DifyHttpGet(apiUrl,dify.getSecretKey());

ltrq-service/src/main/java/api/service/order/IOrderBaseService.java

@@ -1,6 +1,7 @@
 package api.service.order;
 
 import api.entity.database.order.OrderBase;
+import api.entity.view.order.SimilarOrdersView;
 import api.service.IBaseService;
 
 import java.util.List;
@@ -12,5 +13,7 @@ public interface IOrderBaseService extends IBaseService<OrderBase> {
     // 添加历史工单
     void historicalOrders(OrderBase order);
 
-    List<OrderBase> GetOrderSimilarity(OrderBase workOrder);
+
+    // 查找相似工单
+    List<SimilarOrdersView> findSimilarOrders(String content, Integer topK);
 }

ltrq-service/src/main/java/api/service/order/impl/OrderBaseServiceImpl.java

@@ -1,16 +1,21 @@
 package api.service.order.impl;
 
 import api.entity.database.order.OrderBase;
+import api.entity.view.call.CallLogView;
 import api.entity.view.order.CustomSorterStream;
+import api.entity.view.order.SimilarOrdersView;
+import api.entity.view.order.SimilarityView;
 import api.mapper.order.OrderBaseMapper;
 import api.service.order.IOrderBaseService;
 import api.service.BaseServiceImpl;
 import api.util.helper.MilvusClientHelper;
+import com.alibaba.fastjson2.JSON;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.google.common.hash.Hashing;
 import com.hankcs.hanlp.HanLP;
 import com.hankcs.hanlp.seg.common.Term;
+import lombok.var;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -73,24 +78,54 @@ public class OrderBaseServiceImpl extends BaseServiceImpl<OrderBaseMapper, Order
     }
 
     // 查找相似工单
-    public List<OrderBase> findSimilarOrders(OrderBase newOrder, int topK) {
-        // 预处理文本
-        List<String> terms = preprocess(  newOrder.getContent());
-
-        String text =newOrder.getContent();
+    @Override
+    public List<SimilarOrdersView> findSimilarOrders(String content, Integer topK) {
+        String text =content;
         List<String> words = preprocess(text);
         float[] vector = vectorize(words);
-
+        if (topK==null)
+        {
+            topK=5;
+        }
         // 在Milvus中搜索相似工单
-        List<Long> similarOrderIds = milvusClient.searchSimilarOrders(vector, topK);
-
-        if (similarOrderIds.size()>0)
+        List<Map<String,Object>>   similarOrder = milvusClient.searchSimilarOrders(vector, topK);
+        if (similarOrder.size()>0)
         {
             LambdaQueryWrapper<OrderBase> qw = new LambdaQueryWrapper<>();
-            qw.in( OrderBase::getWorkOrderId, similarOrderIds);
+
+            List<Long> ids = similarOrder.stream()
+                    .map(map -> map.get("Id"))
+                    .filter(Objects::nonNull)
+                    .map(value -> {
+                        try {
+                            return Long.valueOf(value.toString());
+                        } catch (NumberFormatException e) {
+                            return null; // 或者使用Optional处理异常
+                        }
+                    })
+                    .filter(Objects::nonNull)
+                    .collect(Collectors.toList());
+            qw.in( OrderBase::getWorkOrderId, ids);
             qw.orderByDesc(OrderBase::getWorkOrderId);
             List<OrderBase> list=this.getList(qw);
-            return CustomSorterStream.sortByTargetOrder(list, similarOrderIds, OrderBase::getWorkOrderId);
+            List<SimilarOrdersView>  similarOrdersViews=  JSON.parseArray(JSON.toJSONString(list),SimilarOrdersView.class);
+            for(SimilarOrdersView view :similarOrdersViews)
+            {
+                Float Similarity = similarOrder.stream()
+                        .filter(map -> {
+                            Object idValue = map.get("Id");
+                            return idValue != null && idValue.toString().equals(view.getWorkOrderId().toString());
+                        })
+                        .map(map -> (Float) map.get("Similarity"))
+                        .findFirst()
+                        .orElse(null);
+                if (Similarity!=null)
+                {
+                    view.setSimilarity(Similarity);
+                }
+
+            }
+            return CustomSorterStream.sortByTargetOrder(similarOrdersViews, ids, SimilarOrdersView::getWorkOrderId);
         }
         else
         {
@@ -108,8 +143,6 @@ public class OrderBaseServiceImpl extends BaseServiceImpl<OrderBaseMapper, Order
                 .filter(word -> word.length() > 1 && !STOP_WORDS.contains(word))
                 .collect(Collectors.toList());
     }
-    @Override
-    public List<OrderBase> GetOrderSimilarity(OrderBase workOrder) {
-        return  findSimilarOrders(workOrder,5);
-    }
+
+
 }

ltrq-util/pom.xml

@@ -131,6 +131,16 @@
                 </exclusion>
             </exclusions>
         </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java</artifactId>
+            <version>3.21.12</version>  <!-- 使用兼容版本 -->
+        </dependency>
+        <dependency>
+            <groupId>com.google.protobuf</groupId>
+            <artifactId>protobuf-java-util</artifactId>
+            <version>3.21.12</version>
+        </dependency>
 
     </dependencies>
 

ltrq-util/src/main/java/api/util/helper/MilvusClientHelper.java

@@ -1,22 +1,23 @@
 package api.util.helper;
 import io.milvus.client.MilvusServiceClient;
 import io.milvus.grpc.DataType;
+import io.milvus.grpc.MutationResult;
 import io.milvus.param.ConnectParam;
 import io.milvus.param.IndexType;
 import io.milvus.param.MetricType;
 import io.milvus.param.R;
 import io.milvus.param.RpcStatus;
 import io.milvus.param.collection.*;
+import io.milvus.param.dml.DeleteParam;
 import io.milvus.param.dml.InsertParam;
 import io.milvus.param.dml.SearchParam;
+import io.milvus.param.highlevel.dml.DeleteIdsParam;
 import io.milvus.param.index.CreateIndexParam;
 import io.milvus.response.SearchResultsWrapper;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
+import java.util.*;
 import java.util.stream.Collectors;
 @Slf4j
 public class MilvusClientHelper {
@@ -27,6 +28,7 @@ public class MilvusClientHelper {
     public static final String VECTOR_FIELD = "vector";
     private static final String ID_FIELD = "order_id";
     public static final int VECTOR_DIM = 1024; // 向量维度
+    public static final float score = 0.6F; // 向量维度
     private final MilvusServiceClient client;
 
     public MilvusClientHelper() {
@@ -38,7 +40,7 @@ public class MilvusClientHelper {
         client = new MilvusServiceClient(connectParam);
 
         // 初始化集合
-    //    initCollection();
+        initCollection();
     }
 
     private void initCollection() {
@@ -82,7 +84,7 @@ public class MilvusClientHelper {
             client.createIndex(createIndexParam);
             System.out.println("Milvus集合创建成功: " + COLLECTION_NAME);
         }
-        loadCollection();
+     //   loadCollection();
     }
 
     // 插入工单向量
@@ -106,6 +108,29 @@ public class MilvusClientHelper {
                 .addCollectionName(COLLECTION_NAME)
                 .build());
     }
+
+    public void deleteTickets(List<Long> ticketIds) {
+        if (ticketIds == null || ticketIds.isEmpty()) return;
+
+        // 构建删除表达式
+        String expr = ID_FIELD+" in [" + StringUtils.join(ticketIds, ",") + "]";
+
+        DeleteParam deleteParam = DeleteParam.newBuilder()
+                .withCollectionName(COLLECTION_NAME)
+                .withExpr(expr)
+                .build();
+
+        R<MutationResult> deleteRes = client.delete(deleteParam);
+        if (deleteRes.getStatus() != R.Status.Success.getCode()) {
+            throw new RuntimeException("删除失败: " + deleteRes.getMessage());
+        }
+
+        // 刷新删除操作
+        client.flush(FlushParam.newBuilder()
+                .addCollectionName(COLLECTION_NAME)
+                .build());
+    }
+
     // 加载集合到内存
     public void loadCollection() {
         try {
@@ -145,7 +170,7 @@ public class MilvusClientHelper {
     }
 
     // 搜索相似工单
-    public List<Long> searchSimilarOrders(float [] vector, int topK) {
+    public List<Map<String,Object>>  searchSimilarOrders(float [] vector, int topK) {
 
         List<Float> vectorList = new ArrayList<>(vector.length);
         for (float v : vector) {
@@ -161,6 +186,7 @@ public class MilvusClientHelper {
         // 构建搜索参数
         List<String> outputFields = Arrays.asList(ID_FIELD);
         List<List<Float>> searchVectors = Arrays.asList(vectorList);
+        List<Map<String,Object>> maps=new ArrayList<>();
 
         SearchParam searchParam = SearchParam.newBuilder()
                 .withCollectionName(COLLECTION_NAME)
@@ -176,10 +202,19 @@ public class MilvusClientHelper {
         R<io.milvus.grpc.SearchResults> response = client.search(searchParam);
         // 处理结果
         SearchResultsWrapper wrapper = new SearchResultsWrapper(response.getData().getResults());
-        return wrapper.getIDScore(0).stream()
-                .filter(x->x .getScore()>0.6)
-                .map(SearchResultsWrapper.IDScore::getLongID)
-                .collect(Collectors.toList());
+
+        for ( SearchResultsWrapper.IDScore item: wrapper.getIDScore(0))
+        {
+            if (item.getScore()>score)
+            {
+                Map<String,Object> map=new HashMap<>();
+                map.put("Similarity",item.getScore());
+                map.put("Id",item.getLongID());
+                maps.add(map);
+            }
+        }
+
+        return maps;
     }
 
     // 归一化向量（用于余弦相似度计算）