@@ -808,25 +808,25 @@ func (o *OpenAi) NewChatStream(stock, stockCode, userQuestion string, sysPromptI
808808 return
809809 }
810810
811- messages := SearchGuShiTongStockInfo (stockCode , o .CrawlTimeOut )
812- if messages == nil || len (* messages ) == 0 {
813- logger .SugaredLogger .Error ("获取股势通资讯失败" )
814- //ch <- "***❗获取股势通资讯失败,分析结果可能不准确***<hr>"
815- //go runtime.EventsEmit(o.ctx, "warnMsg", "❗获取股势通资讯失败,分析结果可能不准确")
816- return
817- }
818- var newsText strings.Builder
819- for _ , message := range * messages {
820- newsText .WriteString (message + "\n " )
821- }
822- msg = append (msg , map [string ]interface {}{
823- "role" : "user" ,
824- "content" : stock + "相关新闻资讯" ,
825- })
826- msg = append (msg , map [string ]interface {}{
827- "role" : "assistant" ,
828- "content" : newsText .String (),
829- })
811+ // messages := SearchGuShiTongStockInfo(stockCode, o.CrawlTimeOut)
812+ // if messages == nil || len(*messages) == 0 {
813+ // logger.SugaredLogger.Error("获取股势通资讯失败")
814+ // //ch <- "***❗获取股势通资讯失败,分析结果可能不准确***<hr>"
815+ // //go runtime.EventsEmit(o.ctx, "warnMsg", "❗获取股势通资讯失败,分析结果可能不准确")
816+ // return
817+ // }
818+ // var newsText strings.Builder
819+ // for _, message := range *messages {
820+ // newsText.WriteString(message + "\n")
821+ // }
822+ // msg = append(msg, map[string]interface{}{
823+ // "role": "user",
824+ // "content": stock + "相关新闻资讯",
825+ // })
826+ // msg = append(msg, map[string]interface{}{
827+ // "role": "assistant",
828+ // "content": newsText.String(),
829+ // })
830830 }()
831831
832832 go func () {
0 commit comments