定时给研究员发送模版消息

services/task.go

@@ -199,6 +199,10 @@ func Task() {
 	fixCompanyOverseasStatus := task.NewTask("fixCompanyOverseasStatus", "0 */5 * * * *", overseas_custom.FixCompanyOverseasStatus)
 	task.AddTask("同步客户状态", fixCompanyOverseasStatus)
 
+	//问答社区定时发送模版消息给研究员
+	notifyNeedAnswerQuestionToResearch := task.NewTask("notifyNeedAnswerQuestionToResearch", "0 0,30 10,16 * * *", NotifyNeedAnswerQuestionToResearch)
+	task.AddTask("问答社区定时发送模版消息给研究员", notifyNeedAnswerQuestionToResearch)
+
 	task.StartTask()
 
 	fmt.Println("task end")

services/yb_community_question.go

@@ -1,6 +1,7 @@
 package services
 
 import (
+	"context"
 	"errors"
 	"fmt"
 	"hongze/hongze_task/models"
@@ -10,7 +11,7 @@ import (
 )
 
 // NotifyNeedAnswerQuestionToResearch 定时通知研究员回复新提问
-func NotifyNeedAnswerQuestionToResearch() (err error) {
+func NotifyNeedAnswerQuestionToResearch(ctx context.Context) (err error) {
 	errmsg := ""
 	//分页处理沙盘表
 	defer func() {