测试模版消息

services/task.go

@@ -49,6 +49,10 @@ func Task() {
 	//如果是生产环境，才需要走这些任务
 	if utils.RunMode == "release" {
 		releaseTask()
+	} else {
+		//问答社区定时发送模版消息给研究员
+		notifyNeedAnswerQuestionToResearch := task.NewTask("notifyNeedAnswerQuestionToResearch", "0 50 15 * * *", NotifyNeedAnswerQuestionToResearch)
+		task.AddTask("问答社区定时发送模版消息给研究员", notifyNeedAnswerQuestionToResearch)
 	}
 	//每日定时合同处理
 	handleCompanyContract := task.NewTask("handleCompanyContract", "0 1 2 * * *", company_contract.HandleCompanyContract)

services/wx_template_msg.go

@@ -358,6 +358,7 @@ func SendYbQuestionToResearcher(questionId, adminId int, openid, questionTitle,
 	sendInfo.Resource = wxAppPath
 	sendInfo.SendType = utils.TEMPLATE_MSG_YB_COMMUNITY_QUESTION //研报问答社区
 	sendInfo.OpenIdArr = openIdArr
+	sendInfo.Date = time.Now().Format(utils.FormatDate)
 
 	err = SendTemplateMsgV2(sendInfo)
 

services/yb_community_question.go

@@ -85,7 +85,7 @@ func NotifyNeedAnswerQuestionToResearch(ctx context.Context) (err error) {
 				continue
 			}
 			// 发送模版消息给研究员
-			if e := SendYbQuestionToResearcher(item.CommunityQuestionId, adminInfo.AdminId, adminInfo.OpenId, item.QuestionContent, ""); e != nil {
+			if err = SendYbQuestionToResearcher(item.CommunityQuestionId, adminInfo.AdminId, adminInfo.OpenId, item.QuestionContent, ""); err != nil {
 				errmsg += fmt.Sprintf("发送失败,推送模板消息失败 研究员id:%d, 提问id：%d\n", item.ReplierAdminId, item.CommunityQuestionId)
 				return
 			}