Browse Source

修改消息推送

tuoling805 1 year ago
parent
commit
64a92cadf1
2 changed files with 5 additions and 3 deletions
  1. 2 0
      controller/voice_broadcast/voice_broadcast.go
  2. 3 3
      services/voice_broadcast.go

+ 2 - 0
controller/voice_broadcast/voice_broadcast.go

@@ -1,6 +1,7 @@
 package voice_broadcast
 
 import (
+	"fmt"
 	"github.com/gin-gonic/gin"
 	"hongze/hongze_yb/controller/response"
 	"hongze/hongze_yb/models/request"
@@ -426,6 +427,7 @@ func MsgSend(c *gin.Context) {
 	errMsg, err := services.SendBroadcastMsg(req.BroadcastId, int(userInfo.UserID))
 	if err != nil {
 		response.FailMsg(errMsg, "MsgSend ErrMsg:"+err.Error(), c)
+		fmt.Println("SendBroadcastMsg Err:"+err.Error())
 		return
 	}
 	response.Ok("操作成功", c)

+ 3 - 3
services/voice_broadcast.go

@@ -215,9 +215,9 @@ func SendBroadcastMsg(broadcastId, userId int) (errMsg string, err error) {
 		_ = wechat.SendVoiceBroadcastWxMsg(broadcast.BroadcastId,broadcast.VarietyId, broadcast.SectionName, broadcast.BroadcastName)
 	}()
 	// 推送客群消息
-	go func() {
-		_ = SendVoiceBroadcastToThs(broadcast)
-	}()
+	//go func() {
+	//	_ = SendVoiceBroadcastToThs(broadcast)
+	//}()
 	return
 }