package com.example.springboot.controller;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import com.example.springboot.common.MessageSender;
import com.example.springboot.component.RabbitMQUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import com.example.springboot.common.MessageSender.Person;

@RestController
public class MessageController {

    @Autowired
    private MessageSender messageSender;

    @GetMapping("/send/{message}")
    public String sendMessage(@PathVariable("message") String message) {
        messageSender.sendMessage(message);
        return "Message sent: " + message;
    }

    @GetMapping("/sendPerson/{name}/{age}")
    public String sendPersonMessage(@PathVariable("name") String name, @PathVariable("age") int age) {
        Person person = new Person(name, age);
        messageSender.sendMessage2(person);
        return "Person message sent: " + person;
    }

    @GetMapping("/sendJson")
    public String sendJsonMessage() {
        // 创建要发送的对象
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("key1", "value1");
        jsonObject.put("key2", 123);
        JSONArray jsonArray = new JSONArray();
        jsonArray.add("item1");
        jsonArray.add("item2");
        jsonObject.put("key3", jsonArray);


        try {
            // 调用 RabbitMQUtils 发送 JSON 消息的方法
            RabbitMQUtils.sendJsonMessage(jsonObject, "yourQueueName");
            return "JSON message sent: " + jsonObject;
        } catch (Exception e) {
            return "Failed to send JSON message: " + e.getMessage();
        }

    }

}