修复sop未回复转发问题

crontask/send_wx.go

@@ -173,6 +173,10 @@ func containsPlaceholder(s string) bool {
 }
 
 func varReplace(s string, contactInfo *ent.Contact) string {
-	s = strings.Replace(s, "${nickname}", contactInfo.Nickname, -1)
+	nickname := ""
+	if contactInfo != nil {
+		nickname = contactInfo.Nickname
+	}
+	s = strings.Replace(s, "${nickname}", nickname, -1)
 	return s
 }

crontask/send_wx_on_timeout.go

@@ -5,6 +5,7 @@ import (
 	"regexp"
 	"time"
 	"wechat-api/ent"
+	"wechat-api/ent/contact"
 	"wechat-api/ent/custom_types"
 	"wechat-api/ent/labelrelationship"
 	"wechat-api/ent/messagerecords"
@@ -140,13 +141,15 @@ func (l *CronTask) sendWxOnTimeout() {
 								if message.Meta != nil {
 									meta.Filename = message.Meta.Filename
 								}
+								contactInfo, _ := l.svcCtx.DB.Contact.Query().Where(contact.WxWxidEQ(s.BotWxid), contact.WxidEQ(s.ContactWxid)).First(l.ctx)
+								content := varReplace(message.Content, contactInfo)
 								_, _ = l.svcCtx.DB.MessageRecords.Create().
 									SetBotWxid(s.BotWxid).
 									SetContactID(0).
 									SetContactType(0).
 									SetContactWxid(forwardWxid).
 									SetContentType(message.Type).
-									SetContent(message.Content).
+									SetContent(content).
 									SetMeta(meta).
 									SetSourceType(4).
 									SetSourceID(node.ID).