Zabbix插件

Author: Frank-svg-dev

Zabbix/Readme.md

@@ -0,0 +1,61 @@
+## GVA Zabbix插件
+
+本插件用于集成Zabbix
+
+### 1. 使用场景
+
+- 当需要集成Zabbix监控时使用
+
+### 2. 配置说明
+
+在`plugin/notify/global/global.go` 文件中配置启用Zabbix插件
+
+```go
+	//  在gin-vue-admin 主程序的initialize中的plugin的InstallPlugin 函数中写入如下代码
+   PluginInit(PublicGroup, Zabbix.CreateZabbixPlugin(
+		global.GVA_CONFIG.Zabbix.Url,
+		global.GVA_CONFIG.Zabbix.Username,
+		global.GVA_CONFIG.Zabbix.Password,
+	))
+}
+```
+
+在config.yaml文件中配置Zabbix插件登录信息
+
+	zabbix:
+	  url: 'http://localhost/zabbix/api_jsonrpc.php'
+	  username: Admin
+	  password: Zabbix
+### 3 参数说明
+
+#### 3-1 全局参数说明
+
+```go
+	Url      string `mapstructure:"url" json:"url" yaml:"url"`  //ZabbixAPI接口地址
+	Username string `mapstructure:"username" json:"username" yaml:"username"` //Zabbix用户名
+	Password string `mapstructure:"password" json:"password" yaml:"password"` //Zabbix密码
+```
+#### 3-2 请求入参说明
+```go
+
+```
+
+### 3方法API（可调用方法）
+```go
+
+//获取所有主机列表
+GetHostAll()
+
+
+```
+
+### 4. 可直接调用接口
+
+    获取主机列表接口： /zabbix/getHostAll [get] 已配置swagger注释
+
+### 添加api SQL语句
+
+```sql
+    INSERT INTO `你的数据库名字`.`sys_apis`(`id`, `created_at`, `updated_at`, `deleted_at`, `path`, `description`, `api_group`, `method`) VALUES (100, '2022-03-28 14:04:19.194', '2022-03-28 14:04:19.194', NULL, '/zabbix/getHostAll', 'Zabbix主机列表', 'Zabbix', 'GET');
+
+```

Zabbix/api/sys_zabbix.go

@@ -0,0 +1,17 @@
+package api
+
+import (
+	"github.com/gin-gonic/gin"
+)
+
+type zabbixAPI struct {
+}
+
+func (s *zabbixAPI) HostItems(c *gin.Context) {
+}
+
+func (s *zabbixAPI) Tiggers(c *gin.Context) {
+}
+
+func (s *zabbixAPI) Graph(c *gin.Context) {
+}

Zabbix/config/zabbix.go

@@ -0,0 +1,7 @@
+package config
+
+type Zabbix struct {
+	url      string `mapstructure:"url" json:"url" yaml:"url"`
+	username string `mapstructure:"username" json:"username" yaml:"username"`
+	password string `mapstructure:"password" json:"password" yaml:"password"`
+}

Zabbix/global/global.go

@@ -0,0 +1,5 @@
+package global
+
+import "github.com/flipped-aurora/gin-vue-admin/server/plugin/Zabbix/config"
+
+var GlobalConfig = new(config.Zabbix)

Zabbix/main.go

@@ -0,0 +1 @@
+package Zabbix

Zabbix/model/response/get_host.go

@@ -0,0 +1,12 @@
+package response
+
+type GetHostModel struct {
+	Jsonrpc string `json:"jsonrpc"`
+	Method  string `json:"method"`
+	Params  struct {
+		Output           []string `json:"output"`
+		SelectInterfaces []string `json:"selectInterfaces"`
+	} `json:"params"`
+	ID   int    `json:"id"`
+	Auth string `json:"auth"`
+}

Zabbix/model/response/login.go

@@ -0,0 +1,12 @@
+package response
+
+type ZabbixLoginModel struct {
+	Jsonrpc string `json:"jsonrpc"`
+	Method  string `json:"method"`
+	Params  struct {
+		User     string `json:"user"`
+		Password string `json:"password"`
+	} `json:"params"`
+	ID   int         `json:"id"`
+	Auth interface{} `json:"auth"`
+}

Zabbix/service/sys_zabbix.go

@@ -0,0 +1,3 @@
+package service
+
+ZabbixLogin("Admin", "zabbix@ngcc", "http://192.168.128.181/zabbix/api_jsonrpc.php")

Zabbix/utils/zabbix.go

@@ -0,0 +1,96 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/flipped-aurora/gin-vue-admin/server/plugin/Zabbix/model/response"
+	"io/ioutil"
+	"net/http"
+	"strings"
+)
+
+//type getHostModel struct {
+//	Jsonrpc string `json:"jsonrpc"`
+//	Method  string `json:"method"`
+//	Params  struct {
+//		Output           []string `json:"output"`
+//		SelectInterfaces []string `json:"selectInterfaces"`
+//	} `json:"params"`
+//	ID   int    `json:"id"`
+//	Auth string `json:"auth"`
+//}
+
+type ResultModel struct {
+	Jsonrpc string `json:"jsonrpc"`
+	Result  string `json:"result"`
+	ID      int    `json:"id"`
+}
+
+func PostProcessingJSON(ProcessStruct interface{}, url string) (Jsonstr string) {
+	jsonBytes, _ := json.Marshal(ProcessStruct)
+	body := string(jsonBytes)
+	response, err := http.Post(url, "application/json-rpc; charset=utf-8", strings.NewReader(body))
+	if err != nil {
+		fmt.Println(err)
+	}
+
+	content, err := ioutil.ReadAll(response.Body)
+	if err != nil {
+		fmt.Println(err)
+	}
+	JsonStr := string(content)
+	return JsonStr
+}
+
+func ZabbixLogin(username string, password string, url string) (resultToken string) {
+	var resultModel ResultModel
+	var loginstrcut = response.ZabbixLoginModel{
+		Jsonrpc: "2.0",
+		Method:  "user.login",
+		Params: struct {
+			User     string `json:"user"`
+			Password string `json:"password"`
+		}(struct {
+			User     string
+			Password string
+		}{User: username, Password: password}),
+	}
+	json.Unmarshal([]byte(PostProcessingJSON(loginstrcut, url)), &resultModel)
+	resultToken = resultModel.Result
+	return resultToken
+}
+
+func GetHostList() (r1 string) {
+	//var resultModel ResultModel
+	var outPutList []string
+	var interfaceList []string
+	outPutList = append(outPutList, "hostid")
+	outPutList = append(outPutList, "host")
+	interfaceList = append(interfaceList, "interfaceid")
+	interfaceList = append(interfaceList, "ip")
+
+	result := ZabbixLogin("Admin", "zabbix@ngcc", "http://192.168.128.181/zabbix/api_jsonrpc.php")
+	fmt.Println(result)
+	var getHostStruct = response.GetHostModel{
+		Jsonrpc: "2.0",
+		Method:  "host.get",
+		Params: struct {
+			Output           []string `json:"output"`
+			SelectInterfaces []string `json:"selectInterfaces"`
+		}(struct {
+			Output           []string
+			SelectInterfaces []string
+		}{Output: outPutList, SelectInterfaces: interfaceList}),
+		Auth: result,
+	}
+	fmt.Println(getHostStruct)
+	r1 = PostProcessingJSON(getHostStruct, "http://192.168.128.181/zabbix/api_jsonrpc.php")
+	return r1
+}
+
+func main() {
+	//ZabbixLogin("Admin", "zabbix@ngcc", "http://192.168.128.181/zabbix/api_jsonrpc.php")
+	r1 := GetHostList()
+	fmt.Println(r1)
+	10099
+}