package com.xly.milvus.service;

import com.xly.tts.bean.TTSResponseDTO;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 向量化服务接口
 */
public interface MilvusService {

    /***
     * @Author 钱豹
     * @Date 22:17 2026/3/24
     * @Param
     * @return
     * @Description 初始化数据
     **/

    TTSResponseDTO initDataToMilvus(Map<String, Object> reqMap);


    /**
     * 创建集合（如果不存在）
     */
    void createCollectionIfNotExists(String collectionName, String sVectorfiled, String sVectorjson, Boolean bRset);


    /***
     * @Author 钱豹
     * @Date 21:39 2026/3/24
     * @Param [collectionName, sVectorfiled, sVectorjson, data]
     * @return long
     * @Description 批量插入数据
     **/
    long addDataToCollection(String collectionName, String sVectorfiled, String sVectorjson, List<Map<String, Object>> data);

    /***
     * @Author 钱豹
     * @Date 10:39 2026/3/25
     * @Param
     * @return
     * @Description 向量库查询
     **/
    List<Map<String, Object>> getDataToCollection(String collectionName, String milvusFilter,String searchText,Integer size,List<String> fields);

    /***
     * @Author 钱豹
     * @Date 10:56 2026/3/25
     * @Param [sVectorfiled]
     * @return java.util.Map<java.lang.String,java.lang.Object>
     * @Description 获取配置
     **/
    Map<String,Object> getMilvusFiled(String sVectorfiled,String sVectorfiledAll,String sVectorfiledShow);

    boolean isValidMilvusFilter(String milvusFilter);
}