package controllers
|
|
import (
|
"basic.com/valib/bhomeclient.git"
|
"basic.com/valib/logger.git"
|
"github.com/satori/go.uuid"
|
|
"os"
|
"path"
|
"vamicro/extend/util"
|
"vamicro/projection-service/zconf"
|
)
|
|
type ReportServiceController struct {
|
bk bhomeclient.Broker
|
}
|
|
func (ac ReportServiceController) GetConfigInfo(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
// 加载配置文件
|
zconf.LoadConfig()
|
|
if zconf.Options == nil {
|
return &bhomeclient.Reply{Success: false, Data: nil}
|
}
|
|
return &bhomeclient.Reply{Success: true, Data: zconf.Options}
|
}
|
|
func (ac ReportServiceController) SetConfigInfo(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
var config zconf.ZConfig
|
if err := c.BindJSON(&config); err != nil {
|
return &bhomeclient.Reply{Success: false, Msg: "参数格式错误,非法的json格式"}
|
}
|
|
zconf.SaveConfig(&config)
|
|
return &bhomeclient.Reply{Success: true, Data: nil}
|
}
|
|
func (ac ReportServiceController) UploadFile(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
|
file := c.File
|
|
if file.Name == "" || file.Bytes == nil || len(file.Bytes) == 0 {
|
logger.Debug("upload panorama file is nil")
|
return &bhomeclient.Reply{Msg: "参数有误"}
|
}
|
|
ext := path.Ext(file.Name)
|
|
fileName := "/opt/vasystem/files/" + uuid.NewV4().String() + ext
|
if util.Exists(fileName) {
|
os.Remove(fileName)
|
}
|
|
f, err := os.Create(fileName)
|
if err != nil {
|
return &bhomeclient.Reply{Msg: err.Error()}
|
}
|
|
defer f.Close()
|
n, err := f.Write(file.Bytes)
|
logger.Debug("write panorama file n:", n)
|
if err != nil {
|
return &bhomeclient.Reply{Msg: err.Error()}
|
}
|
|
return &bhomeclient.Reply{Success: true, Data: map[string]string{
|
"filePath": fileName,
|
}}
|
}
|
