package controllers

import (
	"encoding/json"
	"gitee.com/aywc_1/aywc_judge/src/lib"
	"gitee.com/aywc_1/aywc_judge/src/mqtt2/service"
	"gitee.com/aywc_1/aywc_judge/src/services"
	"gitee.com/aywc_1/aywc_judge/src/utils"
	"github.com/astaxie/beego/logs"
	"github.com/gin-gonic/gin"
	"github.com/shenyisyn/goft-gin/goft"
)

type DeviceWarmMQTTController struct {
	DeviceWarmMQTTService *services.DeviceWarmMQTTService `inject:"-"`
	SysConfig             *goft.SysConfig                 `inject:"-"`
}

func NewDeviceWarmMQTTController() *DeviceWarmMQTTController {
	return &DeviceWarmMQTTController{}
}

func (this *DeviceWarmMQTTController) Name() string {
	return "DeviceWarmMQTTController"
}

func (this *DeviceWarmMQTTController) deviceMQTTTest(ctx *gin.Context) goft.Json {
	const (
		clientId = "pub-001"
		// topic规则：设备编号/接口名
		topicName      = "device001/user"
		actionNameUser = "user/detail"
	)
	client := lib.NewClient(clientId)
	err := client.Connect()
	if err != nil {
		logs.Error(err.Error())
	}

	// 发布一个 user 消息
	body := service.User{1, "小宝", 2}

	msg := &lib.Message{
		ClientID: clientId,
		Action:   actionNameUser,
		Type:     "json",
		Time:     utils.GetNowTime().Unix(),
		Body:     body,
	}
	data, _ := json.Marshal(msg)
	err = client.Publish(topicName, 0, false, data)
	if err != nil {
		panic(err)
	}

	return gin.H{"result": "success", "code": 200}
}

func (this *DeviceWarmMQTTController) Build(goft *goft.Goft) {
	goft.Handle("GET", "/deviceMQTTTest", this.deviceMQTTTest)
}