package com.boying.controller;

import com.boying.controller.car.ServerMQTT;
import com.google.gson.Gson;
import io.lettuce.core.dynamic.annotation.Param;
import lombok.RequiredArgsConstructor;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttTopic;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.Map;

/**
 * @author kdq
 * @version 1.0.0
 * @ClassName TestController.java
 * @Description TODO
 * @createTime 2025年03月15日 18:10:00
 */
@RestController
@RequestMapping("/mqtt")
@RequiredArgsConstructor
public class TestController {
    //MQTT安装的服务器地址和端口号
    public  final String HOST = "tcp://47.92.115.108:1883";
    //定义一个主题
    public final String TOPIC = "/MXXT";
    //定义MQTT的ID，可以在MQTT服务配置中指定
    private final String clientid = "jzadmin"+System.currentTimeMillis();

    private MqttClient client;
    private MqttTopic topic;
    private String userName = "jzadmin";
    private String passWord = "Sys123456";
    private MqttMessage message;
    @GetMapping("/test")
    public void test() throws MqttException, InterruptedException {
        ServerMQTT server = new ServerMQTT();
        String str1 = "{\n" +
                "  \"compId\":133,\n" +
                "  \"firWeight\": 18,\n" +
                "  \"secWeight\": 48,\n" +
                "  \"ponderationType\": \"外销\",\n" +
                "  \"printTime\": \"2022-07-21 18:29:32\",\n" +
                "  \"createTime\": \"2022-07-21 18:29:32\",\n" +
                "  \"outTime\": \"2022-07-21 18:29:32\",\n" +
                "  \"vehicleNo\": \"冀E12345\",\n" +
                "  \"executive\": 30 ,\n" +
                "  \"orderId\": 88\n" +
                "}";

        Map<String, Object> map = new HashMap<>();
        map.put("t",System.currentTimeMillis());
        map.put("f","control");
        map.put("d","JYGL-MTXX");
        map.put("s","0001");
        map.put("p",str1);
        Gson gson =new Gson();
        String str = gson.toJson(map);
        for (int i = 0; i < 1000; i++) {
            message = new MqttMessage();
            message.setQos(2);
            message.setRetained(true);
            message.setPayload(str.getBytes());
            server.publish(topic , message);
            System.out.println("message的保留状态为："+message.isRetained() + "------ratained状态");
            Thread.sleep(1000);
        }

    }

}