lcfns/api/v1/isapi/system.go

package isapi

import (
	"errors"
	"github.com/gin-gonic/gin"
	"github.com/sirupsen/logrus"
	"io/ioutil"
	"lcfns/gatewayServer"
	"lcfns/isapi"
	"strings"
)

type SystemApi struct {
}

func (i SystemApi) GetInfo(c *gin.Context) {
	host, err := GetHost(c)
	if err != nil {
		logrus.Errorf("获取host失败:%e\n", err)
		return
	}
	isapi.TouChuan(host, isapi.GetDeviceInfo, nil, c)
}

func (i SystemApi) GetCap(c *gin.Context) {
	host, err := GetHost(c)
	if err != nil {
		logrus.Errorf("获取host失败:%e\n", err)
		return
	}
	isapi.TouChuan(host, isapi.GetSystemCap, nil, c)
}

func (i SystemApi) PutEmail(c *gin.Context) {
	defer c.Request.Body.Close()
	data, err := ioutil.ReadAll(c.Request.Body)
	if err != nil {
		logrus.Errorf("读取数据失败:%e\n", err)
	}
	host, err := GetHost(c)
	if err != nil {
		logrus.Errorf("获取host失败:%e\n", err)
		return
	}
	isapi.TouChuan(host, isapi.PutEmail, data, c)
}

func GetHost(c *gin.Context) (string, error) {
	devId := c.Query("devId")
	if devId == "" {
		return "", errors.New("设备Id为空")
	}
	conn, ok := gatewayServer.ConnMap[devId]
	if !ok {
		return "", errors.New("获取设备Id对应连接失败")
	}
	return strings.Split(conn.RemoteAddr().String(), ":")[0] + ":8848", nil
}