Parcourir la source

fix:新增分配并推送

Roc il y a 2 ans
Parent
commit
20dfdde423
2 fichiers modifiés avec 10 ajouts et 0 suppressions
  1. 4 0
      controllers/yb/community_question.go
  2. 6 0
      services/yb/community_question.go

+ 4 - 0
controllers/yb/community_question.go

@@ -107,6 +107,10 @@ func (c *CommunityQuestionController) QuestionDistribute() {
 		c.FailWithMessage(errMsg, "DistributeQuestion,Err:"+err.Error())
 		return
 	}
+
+	// 模板消息提醒研究员
+	go yb.SendMsgToReplier(req.QuestionId)
+
 	c.OkWithMessage(errMsg)
 }
 

+ 6 - 0
services/yb/community_question.go

@@ -11,6 +11,7 @@ import (
 	"hongze/hongze_mobile_admin/models/tables/sys_role_admin"
 	"hongze/hongze_mobile_admin/models/tables/user_record"
 	"hongze/hongze_mobile_admin/models/tables/wx_user"
+	"hongze/hongze_mobile_admin/services/alarm_msg"
 	"hongze/hongze_mobile_admin/utils"
 	"strconv"
 	"strings"
@@ -275,6 +276,11 @@ func SoftDeleteQuestion(questionId int) (err error) {
 
 // SendMsgToReplier 推送消息给回复人
 func SendMsgToReplier(questionId int) (errMsg string, err error) {
+	defer func() {
+		if err != nil {
+			go alarm_msg.SendAlarmMsg(fmt.Sprintf("问答分配给研究员后,推送消息失败,问答id:%d;errMsg:%s;ERR:%s", questionId, errMsg, err.Error()), 3)
+		}
+	}()
 	errMsg = "推送成功"
 	item, e := community_question.GetQuestionById(questionId)
 	if e != nil {