优化访客通知

controller/shout.go

@@ -5,25 +5,38 @@ import (
 	"fmt"
 	"github.com/taoshihan1991/imaptool/models"
 	"github.com/taoshihan1991/imaptool/tools"
+	"github.com/taoshihan1991/imaptool/ws"
 	"log"
 	"strconv"
 	"time"
 )
 
-func SendServerJiang(content string) string {
+func SendServerJiang(title string, content string, domain string) string {
 	noticeServerJiang, err := strconv.ParseBool(models.FindConfig("NoticeServerJiang"))
 	serverJiangAPI := models.FindConfig("ServerJiangAPI")
 	if err != nil || !noticeServerJiang || serverJiangAPI == "" {
 		log.Println("do not notice serverjiang:", serverJiangAPI, noticeServerJiang)
 		return ""
 	}
-	sendStr := fmt.Sprintf("%s,访客来了", content)
-	desp := "[登录](https://gofly.sopans.com/main)"
+	sendStr := fmt.Sprintf("%s%s", title, content)
+	desp := title + ":" + content + "[登录](http://" + domain + "/main)"
 	url := serverJiangAPI + "?text=" + sendStr + "&desp=" + desp
 	//log.Println(url)
 	res := tools.Get(url)
 	return res
 }
+func SendVisitorLoginNotice(kefuName, visitorName, avator, content string) {
+	userInfo := make(map[string]string)
+	userInfo["username"] = visitorName
+	userInfo["avator"] = avator
+	userInfo["content"] = content
+	msg := TypeMessage{
+		Type: "notice",
+		Data: userInfo,
+	}
+	str, _ := json.Marshal(msg)
+	ws.OneKefuMessage(kefuName, str)
+}
 func SendNoticeEmail(username, msg string) {
 	smtp := models.FindConfig("NoticeEmailSmtp")
 	email := models.FindConfig("NoticeEmailAddress")

controller/visitor.go

@@ -101,6 +101,8 @@ func PostVisitorLogin(c *gin.Context) {
 	//各种通知
 	go SendNoticeEmail(visitor.Name, "来了")
 	go SendAppGetuiPush(kefuInfo.Name, visitor.Name, visitor.Name+"来了")
+	go SendVisitorLoginNotice(kefuInfo.Name, visitor.Name, visitor.Avator, visitor.Name+"来了")
+	go SendServerJiang(visitor.Name, "来了", c.Request.Host)
 
 	c.JSON(200, gin.H{
 		"code":   200,

static/js/chat-main.js

@@ -97,14 +97,6 @@ var app=new Vue({
                     break;
                 case "userOnline":
                     this.addOnlineUser(redata.data);
-                    //发送通知
-                    let _this=this;
-                    window.parent.postMessage({
-                        name:redata.data.username,
-                        body: "来了",
-                        icon: redata.data.avator
-                    });
-                    _this.alertSound();
 
                     break;
                 case "userOffline":
@@ -112,7 +104,14 @@ var app=new Vue({
                     //this.sendKefuOnline();
                     break;
                 case "notice":
-                    this.sendKefuOnline();
+                    //发送通知
+                    var _this=this;
+                    window.parent.postMessage({
+                        name:redata.data.username,
+                        body: redata.data.content,
+                        icon: redata.data.avator
+                    });
+                    _this.alertSound();
                     break;
             }
 

ws/visitor.go

@@ -32,7 +32,7 @@ func NewVisitorServer(c *gin.Context) {
 		To_id:  vistorInfo.ToId,
 	}
 	go models.UpdateVisitorStatus(vistorInfo.VisitorId, 1)
-	go SendServerJiang(vistorInfo.Name, "来了", c.Request.Host)
+	//go SendServerJiang(vistorInfo.Name, "来了", c.Request.Host)
 
 	AddVisitorToList(user)