AI编程Augment生成与DeepSeek交互对话

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
    <groupId>org.springframework.ai</groupId>
    <artifactId>spring-ai-starter-model-deepseek</artifactId>
</dependency>

server:
  port: 10001

spring:
  application:
    name: spring-ai-deepseek-chat-model

  ai:
    deepseek:
      api-key: xxx_xxxx_xxxx
      base-url: "https://xxxx/v3/openai"
      chat:
        options:
#          model: deepseek/deepseek-v3-0324
          model: deepseek/deepseek-v3.1
      embedding:
        enabled: false

@RestController
@RequestMapping("/client")
@Slf4j
public class DeepSeekChatClientController {
    private final ChatClient DeepSeekChatClient;

    public DeepSeekChatClientController(DeepSeekChatModel chatModel) {
        log.info("Using model: {}", chatModel.getDefaultOptions().getModel());

        this.DeepSeekChatClient = ChatClient.builder(chatModel).defaultAdvisors(
                    MessageChatMemoryAdvisor.builder(MessageWindowChatMemory.builder().build()).build()
                ).defaultAdvisors(new SimpleLoggerAdvisor())
                .defaultOptions(DeepSeekChatOptions.builder().temperature(0.75).build()).build();
    }

    @GetMapping(value = "/ai/response")
    public ChatResponse customOption(String message) {
        return this.DeepSeekChatClient.prompt(
                new Prompt(message, DeepSeekChatOptions.builder().temperature(0.75).build()))
                .call()
                .chatResponse();
    }

    @GetMapping(value = "/ai/chat")
    public String chat(String message) {
        return this.DeepSeekChatClient.prompt(
                        message)
                .call()
                .content();
    }


    @GetMapping(value = "/ai/stream", produces = "text/plain;charset=UTF-8")
    public Flux<String> stream(HttpServletResponse response, String message) {
        response.setCharacterEncoding("UTF-8");
        response.setContentType("text/plain;charset=UTF-8");
        Flux<String> content = this.DeepSeekChatClient.prompt(message)
                .stream()
                .content()
                .doOnNext(chunk -> log.debug("Stream chunk received: {}", chunk))
                .doOnComplete(() -> log.info("Stream completed for message: {}", message))
                .doOnError(error -> log.error("Stream error for message: {}", message, error));
        return content;
    }

}