package com.xly.milvus.web;

import com.xly.milvus.service.MilvusService;
import com.xly.runner.AppStartupRunner;
import com.xly.service.DynamicExeDbService;
import com.xly.service.UserSceneSessionService;
import com.xly.tool.DynamicToolProvider;
import com.xly.tts.bean.*;
import com.xly.tts.service.LocalAudioCache;
import com.xly.tts.service.PythonTtsProxyService;
import jakarta.validation.Valid;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.core.io.InputStreamResource;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

import javax.annotation.PostConstruct;
import javax.annotation.PreDestroy;
import java.util.List;
import java.util.Map;
import java.util.concurrent.CompletableFuture;

@Slf4j
@RestController
@RequestMapping("/api/milvus")
@RequiredArgsConstructor
public class MilvusController {

    private final MilvusService milvusService;

    /***
     * @Author 钱豹
     * @Date 14:32 2026/2/10
     * @Param [request]
     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
     * @Description 初始化AI所有变量 热启动
     **/
    @PostMapping("/init")
    public ResponseEntity<TTSResponseDTO> init(@RequestBody Map<String,Object> reqMap) {
         TTSResponseDTO responseDTO =  milvusService.initDataToMilvus(reqMap);
         return ResponseEntity.ok(responseDTO);
    }

    /***
     * @Author 钱豹
     * @Date 14:32 2026/2/10
     * @Param [request]
     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
     * @Description 初始化AI所有变量 热启动
     **/
    @PostMapping("/addGlobalAgentQuestion")
    public ResponseEntity<TTSResponseDTO> addGlobalAgentQuestion(@RequestBody Map<String,Object> reqMap) {
        TTSResponseDTO responseDTO =  milvusService.addGlobalAgentQuestion(reqMap);
        return ResponseEntity.ok(responseDTO);
    }

    /***
     * @Author 钱豹
     * @Date 14:32 2026/2/10
     * @Param [request]
     * @return org.springframework.http.ResponseEntity<com.xly.tts.bean.TTSResponseDTO>
     * @Description 初始化全局SQL
     **/
    @PostMapping("/initGlobalAgentQuestion")
    public ResponseEntity<TTSResponseDTO> initGlobalAgentQuestion(@RequestBody Map<String,Object> reqMap) {
        TTSResponseDTO responseDTO =  milvusService.initGlobalAgentQuestion(reqMap);
        return ResponseEntity.ok(responseDTO);
    }


}