package controllers
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"encoding/json"
|
"io/ioutil"
|
"os"
|
"vamicro/extend/util"
|
"vamicro/system-service/sys"
|
"vamicro/system-service/vo"
|
)
|
|
type MqttController struct {
|
|
}
|
|
//获取mqtt配置
|
func (mc *MqttController) GetConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
r := &bhomeclient.Reply{ Success:true }
|
mqttf := util.GetVamicroPath()+"/mqtt.config"
|
if util.FileExists(mqttf) {
|
b, err := ioutil.ReadFile(mqttf)
|
if err == nil {
|
var set vo.MqttConf
|
if err = json.Unmarshal(b, &set);err == nil {
|
r.Data = set
|
}
|
}
|
}
|
|
return r
|
}
|
|
//保存mqtt配置
|
func (mc *MqttController) SaveConfig(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
|
var reqBody vo.MqttConf
|
if err :=c.BindJSON(&reqBody);err !=nil {
|
return &bhomeclient.Reply{Msg:err.Error()}
|
}
|
if !reqBody.AnonymousEnable && (reqBody.Username == "" || reqBody.Password == "") {
|
return &bhomeclient.Reply{ Msg:"用户名和密码不能为空" }
|
}
|
|
b, err := json.Marshal(reqBody)
|
if err != nil {
|
return &bhomeclient.Reply{Msg:err.Error()}
|
}
|
|
mqttf := util.GetVamicroPath()+"/mqtt.config"
|
err = ioutil.WriteFile(mqttf, b, os.ModePerm)
|
if err != nil {
|
return &bhomeclient.Reply{Msg:err.Error()}
|
}
|
//1.检查mosquitto 是否安装 (apt安装,配置文件在/etc/mosquitto目录下)
|
if ex :=sys.ExistService("mosquitto");ex == "" {
|
return &bhomeclient.Reply{ Msg:"mqtt server 尚未安装，请先安装服务" }
|
}
|
err = sys.SetMqttConf(&reqBody)
|
if err != nil {
|
logger.Error("SetMqttConf err:", err)
|
return &bhomeclient.Reply{Msg:err.Error()}
|
}
|
|
return &bhomeclient.Reply{Success:true, Msg:"保存成功"}
|
}
|
