Add files via upload

Author: Frank-svg-dev

Zabbix/Readme.md

@@ -11,7 +11,7 @@
 在`plugin/notify/global/global.go` 文件中配置启用Zabbix插件
 
 ```go
-	//  在gin-vue-admin 主程序的initialize中的plugin的InstallPlugin 函数中写入如下代码
+//  在gin-vue-admin 主程序的initialize中的plugin的InstallPlugin 函数中写入如下代码
    PluginInit(PublicGroup, Zabbix.CreateZabbixPlugin(
 		global.GVA_CONFIG.Zabbix.Url,
 		global.GVA_CONFIG.Zabbix.Username,
@@ -26,6 +26,17 @@
 	  url: 'http://localhost/zabbix/api_jsonrpc.php'
 	  username: Admin
 	  password: Zabbix
+在全局config目录下增加Zabbix.go及修改config.go文件
+
+	Zabbix.go
+	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"`
+	}
+	config.go
+	Zabbix  Zabbix  `mapstructure:"zabbix" json:"zabbix" yaml:"zabbix"` //增加在结构体后面
+
 ### 3 参数说明
 
 #### 3-1 全局参数说明
@@ -37,25 +48,35 @@
 ```
 #### 3-2 请求入参说明
 ```go
-
+/zabbix/getHostAll //请求为GET无需设置参数
+/zabbix/getTiggerList //请求为GET无需设置参数
+/zabbix/getwebcode //请求为POST入参如下
+{
+    "url":"http://www.baidu.com,http://google.com" //支持批量查询,以英文逗号分割
+}
 ```
 
 ### 3方法API（可调用方法）
 ```go
-
-//获取所有主机列表
-GetHostAll()
-
-
+GetHost() //获取所有主机列表
+GetAlertTiggerList() //获取所有正在告警状态的触发器
+WebMonitor(urls string) //获取url参数中提供的网址StatusCode状态是否为200 OK
 ```
 
 ### 4. 可直接调用接口
 
-    获取主机列表接口： /zabbix/getHostAll [get] 已配置swagger注释
+    //获取所有主机列表
+    /zabbix/getHostAll   [get] 已配置swagger注释
+    //获取所有正在告警状态的触发器 status:0为触发器启用状态,status:1为触发器禁用状态(可忽略的触发器告警)
+    /zabbix/getTiggerList  [get] 已配置swagger注释
+    //获取url参数中提供的网址StatusCode状态是否为200 OK
+    /zabbix/getwebcode  [post] 已配置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');
-
+    INSERT INTO `你的数据库名字`.`sys_apis`(`id`, `created_at`, `updated_at`, `deleted_at`, `path`, `description`, `api_group`, `method`) VALUES (104, '2022-04-12 10:33:05.000', '2022-04-12 10:33:05.000', NULL, '/zabbix/getHostAll', 'Zabbix主机列表', 'Zabbix', 'GET');
+INSERT INTO `你的数据库名字`.`sys_apis`(`id`, `created_at`, `updated_at`, `deleted_at`, `path`, `description`, `api_group`, `method`) VALUES (106, '2022-04-12 15:03:31.302', '2022-04-12 15:03:31.302', NULL, '/zabbix/getwebcode', '监控网页状态组件', 'Zabbix', 'POST');
+INSERT INTO `你的数据库名字`.`sys_apis`(`id`, `created_at`, `updated_at`, `deleted_at`, `path`, `description`, `api_group`, `method`) VALUES (108, '2022-04-13 16:23:07.714', '2022-04-13 16:23:07.714', NULL, '/zabbix/getTiggerList', '获取正在触发的告警列表', 'Zabbix', 'GET');
 ```

Zabbix/api/sys_zabbix.go

@@ -29,3 +29,39 @@ func (s *zabbixAPI) GetHostAll(c *gin.Context) {
 		response.OkWithData(gethostALl, c)
 	}
 }
+
+//@Tags Plugins
+//@Summary 进行Web状态码监控
+//@Security ZabbixWebCodeMonitor
+//@Produce  application/json
+//@Success 200 {string} string "{"code":0,"data":{},"msg":"操作成功"}"
+//@Router /zabbix/getwebcode
+func (s *zabbixAPI) GetWebMonitorStatus(c *gin.Context) {
+	var webStatusUrl Zabbixesult.GetWebCodeStatusModel
+	_ = c.ShouldBindJSON(&webStatusUrl)
+	webStatusUrlCode, err := service.WebMonitor(webStatusUrl.Url)
+	if err != nil {
+		global.GVA_LOG.Error("调用失败!", zap.Error(err))
+		response.FailWithMessage("调用失败", c)
+	} else {
+		response.OkWithData(&webStatusUrlCode, c)
+	}
+}
+
+//@Tags Plugins
+//@Summary 获取主机列表
+//@Security GetTiggerList
+//@Produce  application/json
+//@Success 200 {string} string "{"code":0,"data":{},"msg":"操作成功"}"
+//@Router /zabbix/getHostList
+func (s *zabbixAPI) GetTiggerList(c *gin.Context) {
+	var resultMail Zabbixesult.ResultModel
+	_ = c.ShouldBindJSON(&resultMail)
+	getTiggerList, err := service.GetAlertTiggerList()
+	if err != nil {
+		global.GVA_LOG.Error("调用失败!", zap.Error(err))
+		response.FailWithMessage("调用失败", c)
+	} else {
+		response.OkWithData(getTiggerList, c)
+	}
+}

Zabbix/config/config.go

@@ -0,0 +1,5 @@
+package config
+
+type Server struct {
+	Zabbix Zabbix `mapstructure:"zabbix" json:"zabbix" yaml:"zabbix"`
+}

Zabbix/model/response/get_host.go

@@ -14,18 +14,24 @@ type ZabbixLoginModel struct {
 type GetHostModel struct {
 	Jsonrpc string `json:"jsonrpc"`
 	Method  string `json:"method"`
-	Params  struct {
+
+	Params struct {
 		Output                []string `json:"output"`
 		SelectInterfaces      []string `json:"selectInterfaces"`
 		SelectGroups          []string `json:"selectGroups"`
 		SelectParentTemplates []string `json:"selectParentTemplates"`
 	} `json:"params"`
-	ID   int    `json:"id"`
-	Auth string `json:"auth"`
+	ID   int         `json:"id"`
+	Auth interface{} `json:"auth"`
 }
 
 type ResultModel struct {
 	Jsonrpc string `json:"jsonrpc"`
 	Result  string `json:"result"`
 	ID      int    `json:"id"`
 }
+
+type WebMonitorModel struct {
+	Url  string `json:"url"`
+	Code int    `json:"status_code"`
+}

Zabbix/model/response/get_tigger.go

@@ -0,0 +1,19 @@
+package response
+
+type AlertTiggerModel struct {
+	Jsonrpc string      `json:"jsonrpc"`
+	Method  string      `json:"method"`
+	Params  Params      `json:"params"`
+	Auth    interface{} `json:"auth"`
+	ID      int         `json:"id"`
+}
+type Filter struct {
+	Value int `json:"value"`
+}
+type Params struct {
+	Output      []string `json:"output"`
+	Filter      Filter   `json:"filter"`
+	Sortfield   string   `json:"sortfield"`
+	Sortorder   string   `json:"sortorder"`
+	SelectHosts string   `json:"selectHosts"`
+}

Zabbix/model/response/get_webstatus.go

@@ -0,0 +1,6 @@
+package response
+
+type GetWebCodeStatusModel struct {
+	Url    string `json:"url"`
+	Status string `json:"status"`
+}

Zabbix/router/sys_zabbix.go

@@ -11,7 +11,11 @@ type ZabbixRouter struct{}
 func (s *ZabbixRouter) InitZabbixRouter(Router *gin.RouterGroup) {
 	zabbixRouter := Router.Use(middleware.OperationRecord())
 	GetHostAll := api.ApiGroupApp.GetHostAll
+	GetWebStatusCode := api.ApiGroupApp.GetWebMonitorStatus
+	GetTiggerList := api.ApiGroupApp.GetTiggerList
 	{
-		zabbixRouter.GET("getHostAll", GetHostAll) // 获取主机列表
+		zabbixRouter.GET("getHostAll", GetHostAll)        // 获取主机列表
+		zabbixRouter.GET("getTiggerList", GetTiggerList)  //获取正在告警列表
+		zabbixRouter.POST("getwebcode", GetWebStatusCode) // 监控Web网页状态
 	}
 }

Zabbix/service/sys_zabbix.go

@@ -1,13 +1,30 @@
 package service
 
 import (
+	"fmt"
 	"github.com/flipped-aurora/gin-vue-admin/server/plugin/Zabbix/utils"
+	"strings"
 )
 
 type ZabbixService struct{}
 
-func GetHost() (err error, HostAll string) {
+func GetHost() (err error, HostAll interface{}) {
 	r1, r2 := utils.ZabbixLogin()
 	HostAll = utils.GetHostList(r1, r2)
 	return
 }
+
+func GetAlertTiggerList() (TiggersAll interface{}, err error) {
+	r1, r2 := utils.ZabbixLogin()
+	TiggersAll, err = utils.GetAlertTiggerList(r1, r2)
+	return TiggersAll, err
+}
+
+func WebMonitor(urls string) (Code interface{}, err error) {
+	urlsList := strings.Split(urls, ",")
+	Code123, err := utils.WebMonitor(urlsList)
+	if err != nil {
+		fmt.Println(err)
+	}
+	return Code123, err
+}

Zabbix/utils/get_AlertTiggers.go

@@ -0,0 +1,35 @@
+package utils
+
+import (
+	"fmt"
+	"github.com/flipped-aurora/gin-vue-admin/server/plugin/Zabbix/model/response"
+)
+
+func GetAlertTiggerList(resultToken interface{}, zabbixurl string) (r1 interface{}, err error) {
+	//指定Zabbix返回值参数
+	paramsOutput := make([]string, 0)
+	paramsOutput = append(paramsOutput, "triggerid")
+	paramsOutput = append(paramsOutput, "description")
+	paramsOutput = append(paramsOutput, "priority")
+	paramsOutput = append(paramsOutput, "status")
+	paramsOutput = append(paramsOutput, "selectHosts")
+	var AlertParams = response.Params{
+		Output:      paramsOutput,
+		Filter:      response.Filter(struct{ Value int }{Value: 1}),
+		Sortfield:   "priority",
+		Sortorder:   "DESC",
+		SelectHosts: "extend",
+	}
+
+	var getTiggerStruct = response.AlertTiggerModel{
+		Jsonrpc: "2.0",
+		Method:  "trigger.get",
+		Params:  AlertParams,
+		Auth:    resultToken,
+	}
+	r1, err = PostProcessingJSON(getTiggerStruct, zabbixurl)
+	if err != nil {
+		fmt.Println(err)
+	}
+	return r1, err
+}

Zabbix/utils/zabbix.go

@@ -10,8 +10,8 @@ import (
 	"strings"
 )
 
-//请求操作+byte转Json
-func PostProcessingJSON(ProcessStruct interface{}, url string) (Jsonstr string) {
+//请求操作+byte转map
+func PostProcessingJSON(ProcessStruct interface{}, url string) (ResultMap interface{}, err error) {
 	jsonBytes, _ := json.Marshal(ProcessStruct)
 	body := string(jsonBytes)
 	response, err := http.Post(url, "application/json-rpc; charset=utf-8", strings.NewReader(body))
@@ -23,17 +23,22 @@ func PostProcessingJSON(ProcessStruct interface{}, url string) (Jsonstr string)
 	if err != nil {
 		fmt.Println(err)
 	}
-	JsonStr := string(content)
-	return JsonStr
+	result := make(map[string]interface{})
+	err = json.Unmarshal(content, &result)
+	if err != nil {
+		fmt.Println(err)
+	}
+	//JsonStr := string(content)
+	return result["result"], err
 }
 
 //Zabbix API登录
-func ZabbixLogin() (resultToken string, resulturl string) {
+func ZabbixLogin() (resultToken interface{}, resulturl string) {
 	//获取本地Config.yaml配置的Zabbix参数
 	username := global.GlobalConfig.Username
 	password := global.GlobalConfig.Password
 	url := global.GlobalConfig.Url
-	var resultModel response.ResultModel
+	//var resultModel response.ResultModel
 	var loginstrcut = response.ZabbixLoginModel{
 		Jsonrpc: "2.0",
 		Method:  "user.login",
@@ -46,15 +51,16 @@ func ZabbixLogin() (resultToken string, resulturl string) {
 		}{User: username, Password: password}),
 	}
 	//进行POST请求及Json转换
-	json.Unmarshal([]byte(PostProcessingJSON(loginstrcut, url)), &resultModel)
-	resultToken = resultModel.Result
+	resultToken, err := PostProcessingJSON(loginstrcut, url)
+	if err != nil {
+		return err, resulturl
+	}
 	resulturl = url
-	fmt.Println(resulturl, resultToken)
 	return resultToken, resulturl
 }
 
 //获取所有主机列表
-func GetHostList(resultToken string, zabbixurl string) (r1 string) {
+func GetHostList(resultToken interface{}, zabbixurl string) (r1 interface{}) {
 	//指定Zabbix返回值参数
 	var outPutList []string
 	var interfaceList []string
@@ -63,6 +69,7 @@ func GetHostList(resultToken string, zabbixurl string) (r1 string) {
 	outPutList = append(outPutList, "name")
 	outPutList = append(outPutList, "host")
 	outPutList = append(outPutList, "proxy_hostid")
+	outPutList = append(outPutList, "status")
 	interfaceList = append(interfaceList, "interfaceid")
 	interfaceList = append(interfaceList, "ip")
 	groupsList = append(groupsList, "name")
@@ -85,10 +92,28 @@ func GetHostList(resultToken string, zabbixurl string) (r1 string) {
 		Auth: resultToken,
 	}
 
-	r1 = PostProcessingJSON(getHostStruct, zabbixurl)
+	r1, err := PostProcessingJSON(getHostStruct, zabbixurl)
+	if err != nil {
+		fmt.Println(err)
+	}
 	return r1
 }
 
-func GetItemsAll(resultToken string, zabbixurl string) {
+//根据web状态码进行监控网页状态
+func WebMonitor(urls []string) (webCodeStatusList []response.GetWebCodeStatusModel, err error) {
+	var getWebCodeStatus response.GetWebCodeStatusModel
+	getWebCodeStatusList := make([]response.GetWebCodeStatusModel, 0)
+	for _, v := range urls {
+		responseGet, _ := http.Get(v)
+		getWebCodeStatus.Url = v
+		if responseGet.StatusCode != 200 {
+			getWebCodeStatus.Status = "该web网址有异常"
+			getWebCodeStatusList = append(getWebCodeStatusList, getWebCodeStatus)
+		} else {
+			getWebCodeStatus.Status = "该web网址运行正常"
+			getWebCodeStatusList = append(getWebCodeStatusList, getWebCodeStatus)
+		}
+	}
 
-}
+	return getWebCodeStatusList, nil
+}