|
@@ -45,7 +45,7 @@ func NotifyNeedAnswerQuestionToResearch(ctx context.Context) (err error) {
|
|
|
startSize := i * pageSize
|
|
|
list, e := yb.GetCommunityQuestionListByCondition(condition, pars, "", startSize, pageSize)
|
|
|
if e != nil {
|
|
|
- err = fmt.Errorf("查询沙盘列表失败 Err:%s", e)
|
|
|
+ err = fmt.Errorf("查询沙盘列表失败 Err:%s\n", e)
|
|
|
errmsg += err.Error()
|
|
|
return
|
|
|
}
|
|
@@ -60,7 +60,7 @@ func NotifyNeedAnswerQuestionToResearch(ctx context.Context) (err error) {
|
|
|
//查询管理员信息列表
|
|
|
adminList, e := models.GetAdminByAdminIds(adminIds)
|
|
|
if e != nil {
|
|
|
- err = fmt.Errorf("查询管理员信息列表失败 Err:%s", e)
|
|
|
+ err = fmt.Errorf("查询管理员信息列表失败 Err:%s\n", e)
|
|
|
errmsg += err.Error()
|
|
|
return
|
|
|
}
|
|
@@ -76,17 +76,17 @@ func NotifyNeedAnswerQuestionToResearch(ctx context.Context) (err error) {
|
|
|
adminInfo, ok := adminInfoMap[item.ReplierAdminId]
|
|
|
if !ok {
|
|
|
err = errors.New("发送失败, 研究员账号查询失败")
|
|
|
- errmsg += fmt.Sprintf("发送失败, 研究员账号查询失败, 研究员id:%d, 提问id:%d", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
+ errmsg += fmt.Sprintf("发送失败, 研究员账号查询失败, 研究员id:%d, 提问id:%d\n", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
continue
|
|
|
}
|
|
|
if adminInfo.OpenId == "" {
|
|
|
err = errors.New("该研究员未关注公众号,无法发送消息通知,回复人openid为空, 不可推送")
|
|
|
- errmsg += fmt.Sprintf("发送失败,该研究员未关注公众号,无法发送消息通知,回复人openid为空, 不可推送 研究员id:%d, 提问id:%d", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
+ errmsg += fmt.Sprintf("发送失败,该研究员未关注公众号,无法发送消息通知,回复人openid为空, 不可推送 研究员id:%d, 提问id:%d\n", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
continue
|
|
|
}
|
|
|
// 发送模版消息给研究员
|
|
|
if e := SendYbQuestionToResearcher(item.CommunityQuestionId, adminInfo.AdminId, adminInfo.OpenId, item.QuestionContent, ""); e != nil {
|
|
|
- errmsg += fmt.Sprintf("发送失败,推送模板消息失败 研究员id:%d, 提问id:%d", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
+ errmsg += fmt.Sprintf("发送失败,推送模板消息失败 研究员id:%d, 提问id:%d\n", item.ReplierAdminId, item.CommunityQuestionId)
|
|
|
return
|
|
|
}
|
|
|
}
|