Browse Source

Оповещения в битрикс 24

portowyi 1 year ago
parent
commit
6803ac4595
1 changed files with 25 additions and 0 deletions
  1. 25 0
      controller/cdn.go

+ 25 - 0
controller/cdn.go

@@ -1,6 +1,8 @@
 package controller
 package controller
 
 
 import (
 import (
+	"bytes"
+	"fmt"
 	"kng_feed_api/helper"
 	"kng_feed_api/helper"
 	"net/http"
 	"net/http"
 	"os"
 	"os"
@@ -10,6 +12,13 @@ import (
 )
 )
 
 
 func SendXmlFeedToClient(context *gin.Context) {
 func SendXmlFeedToClient(context *gin.Context) {
+	var ra = context.Request.RemoteAddr
+	var reqUrl = context.Request.RequestURI
+
+	var preString = fmt.Sprintf(`"DIALOG_ID":%s, "MESSAGE":"Запрошен %s c ip адреса [%s]"`, "", reqUrl, ra)
+	var jsonStr = []byte(preString)
+	sendBitrix24Log(jsonStr)
+
 	sendFile(context, "feed.xml")
 	sendFile(context, "feed.xml")
 }
 }
 
 
@@ -17,6 +26,22 @@ func SendCsvDeltaToClient(context *gin.Context) {
 	sendFile(context, "delta.csv")
 	sendFile(context, "delta.csv")
 }
 }
 
 
+func sendBitrix24Log(jsonStr []byte) {
+	url := "https://kng.bitrix24.ru/rest/1/vu5dqvx5sifh1334/im.message.add"
+
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonStr))
+	req.Header.Set("Content-Type", "application/json")
+
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	defer resp.Body.Close()
+
+	if err != nil {
+		fmt.Println(err)
+	}
+
+}
+
 func sendFile(context *gin.Context, fileMark string) {
 func sendFile(context *gin.Context, fileMark string) {
 	var fileName = filepath.Join(helper.RootDir(), fileMark)
 	var fileName = filepath.Join(helper.RootDir(), fileMark)
 	_, err := os.Stat(fileName)
 	_, err := os.Stat(fileName)