feat(market):新增外媒新闻功能并优化展示逻辑

- 在定时任务中增加TradingViewNews新闻抓取
- 增加TradingView新闻详情接口及数据解析逻辑
- 修改Telegraph模型字段索引提升查询性能
- 前端新增"外媒"新闻列表展示模块
- 根据HTTP代理配置动态调整新闻栏布局
- 修复时间转换及去重逻辑提高数据准确性
- 调整新闻列表显示样式增强可读性

app.go

@@ -410,6 +410,10 @@ func (a *App) domReady(ctx context.Context) {
 	//定时更新数据
 	config := data.GetSettingConfig()
 	go func() {
+		go data.NewMarketNewsApi().TelegraphList(30)
+		go data.NewMarketNewsApi().GetSinaNews(30)
+		go data.NewMarketNewsApi().TradingViewNews()
+
 		interval := config.RefreshInterval
 		if interval <= 0 {
 			interval = 1
@@ -453,6 +457,19 @@ func (a *App) domReady(ctx context.Context) {
 		} else {
 			a.cronEntrys["newSinaNews"] = entryIDSina
 		}
+
+		entryIDTradingViewNews, err := a.cron.AddFunc(fmt.Sprintf("@every %ds", interval+60*5), func() {
+			news := data.NewMarketNewsApi().TradingViewNews()
+			if config.EnablePushNews {
+				go a.NewsPush(news)
+			}
+			go runtime.EventsEmit(a.ctx, "tradingViewNews", news)
+		})
+		if err != nil {
+			logger.SugaredLogger.Errorf("AddFunc error:%s", err.Error())
+		} else {
+			a.cronEntrys["tradingViewNews"] = entryIDTradingViewNews
+		}
 	}()
 
 	//刷新基金净值信息
@@ -1360,6 +1377,7 @@ func (a *App) ReFleshTelegraphList(source string) *[]*models.Telegraph {
 	//data.NewMarketNewsApi().GetNewTelegraph(30)
 	data.NewMarketNewsApi().TelegraphList(30)
 	data.NewMarketNewsApi().GetSinaNews(30)
+	data.NewMarketNewsApi().TradingViewNews()
 	telegraphs := data.NewMarketNewsApi().GetTelegraphList(source)
 	return telegraphs
 }

app_common.go

@@ -76,7 +76,7 @@ func (a *App) ChatWithAgent(question string, aiConfigId int, sysPromptId *int) {
 
 func (a *App) AnalyzeSentimentWithFreqWeight(text string) map[string]any {
 	if text == "" {
-		telegraphs := data.NewMarketNewsApi().GetNews24HoursList("财联社电报", 1000)
+		telegraphs := data.NewMarketNewsApi().GetNews24HoursList("", 1000*10)
 		messageText := strings.Builder{}
 		for _, telegraph := range *telegraphs {
 			messageText.WriteString(telegraph.Content + "\n")

backend/data/data/dict/base.txt

@@ -1,6 +1,5 @@
 # 金融股票全场景分词字典（最终去重优化版）
 # 格式：单词 权重 词性 | 权重280-350分，核心术语优先匹配，无重复词汇
-# 覆盖：净买卖、股指、财务指标、交易操作、政策宏观、热点概念、机构媒体、美股中概股、十五五规划等全场景
 
 # 一、净买卖与资金流向（核心交易表述）
 净卖出 340 v
@@ -94,6 +93,8 @@
 信息披露 310 n
 内幕交易 300 n
 操纵市场 300 n
+亏损 100 n
+加工 100 n
 
 # 三、全球主要股指（含中英文缩写）
 # 中国市场
@@ -116,63 +117,43 @@ A股 350 n
 科创50指数 330 n
 上证综指 350 n
 富时中国A50指数 340 n
-FTSE China A50 330 n
 恒生指数 340 n
-HSI 330 n
 恒生科技指数 340 n
 恒生国企指数 330 n
 H股指数 330 n
 # 美洲市场
 道琼斯工业平均指数 350 n
-DJIA 340 n
 标普500指数 350 n
-S&P 500 340 n
 纳斯达克综合指数 340 n
 纳斯达克100指数 340 n
-Nasdaq 100 330 n
 罗素2000指数 320 n
-Russell 2000 310 n
 标普400中型股指数 310 n
 标普600小型股指数 310 n
 纽约证交所综合指数 310 n
-NYSE Composite 300 n
 纳斯达克中国金龙指数 310 n
 # 欧洲市场
 德国DAX指数 330 n
-DAX 30 320 n
 法国CAC40指数 330 n
-CAC 40 320 n
 富时100指数 330 n
-FTSE 100 320 n
 欧元斯托克50指数 320 n
-Euro Stoxx 50 310 n
 英国富时250指数 310 n
-FTSE 250 300 n
 意大利富时MIB指数 310 n
-FTSE MIB 300 n
 西班牙IBEX 35指数 310 n
-IBEX 35 300 n
 # 亚太其他市场
 日经225指数 330 n
-Nikkei 225 320 n
 日经500指数 310 n
 韩国综合股价指数 320 n
 韩国kospi指数 320 n
 KOSPI 310 n
 澳洲标普200指数 310 n
-S&P/ASX 200 300 n
 印度孟买敏感指数 310 n
 Sensex 300 n
 印度Nifty 50指数 310 n
-Nifty 50 300 n
 # 全球综合指数
 MSCI指数 320 n
 MSCI全球指数 330 n
-MSCI World Index 320 n
 MSCI新兴市场指数 330 n
-MSCI Emerging Markets 320 n
 富时罗素全球指数 320 n
-FTSE Russell Global Index 310 n
 摩根大通全球债券指数 310 n
 全球股指 300 n
 发达市场指数 300 n
@@ -197,38 +178,7 @@ G20国家指数 300 n
 指数估值 310 n
 指数市盈率 310 n
 
-# 四、A股龙头公司（资讯高频）
-贵州茅台 310 n
-宁德时代 350 n
-比亚迪 340 n
-隆基绿能 300 n
-长江电力 290 n
-中国平安 300 n
-招商银行 300 n
-五粮液 290 n
-美的集团 290 n
-格力电器 290 n
-海康威视 290 n
-迈瑞医疗 290 n
-恒瑞医药 290 n
-中芯国际 300 n
-中兴通讯 290 n
-东方财富 290 n
-爱尔眼科 290 n
-通威股份 290 n
-药明康德 320 n
-阳光电源 290 n
-天齐锂业 290 n
-赣锋锂业 290 n
-中国中免 290 n
-海螺水泥 280 n
-万科A 280 n
-保利发展 280 n
-招商蛇口 280 n
-上汽集团 280 n
-宝钢股份 280 n
-
-# 五、财务与估值核心指标
+# 四、财务与估值核心指标
 市盈率 350 n
 PE 350 n
 动态市盈率 340 n
@@ -268,7 +218,7 @@ EPS 330 n
 量比 320 n
 振幅 320 n
 
-# 六、政策与宏观经济
+# 五、政策与宏观经济
 货币政策 330 n
 财政政策 330 n
 稳健货币政策 320 n
@@ -306,7 +256,7 @@ PMI 330 n
 黄金价格 310 n
 有色金属价格 300 n
 
-# 七、金融产品与机构
+# 六、金融产品与机构
 股票 320 n
 基金 320 n
 公募基金 310 n
@@ -350,7 +300,7 @@ QFII 300 n
 RQFII 290 n
 北向资金机构 300 n
 
-# 八、热点概念与行业
+# 七、热点概念与行业
 AI 330 n
 人工智能 350 n
 算力 330 n
@@ -394,7 +344,7 @@ CXO 300 n
 5G 300 n
 6G 340 n
 
-# 九、交易操作与行情
+# 八、交易操作与行情
 上涨 310 v
 下跌 310 v
 涨停 310 v
@@ -472,7 +422,7 @@ CXO 300 n
 震荡上行 320 v
 震荡下行 320 v
 
-# 十、委托交易与规则
+# 九、委托交易与规则
 限价委托 340 n
 市价委托 340 n
 止损委托 330 n

backend/data/data/dict/user.txt

@@ -1,26 +1,185 @@
-公司 0.1 n
-国家 0.1 n
-国际 0.1 n
-会议 0.1 n
-市场 0.1 n
-经济 0.1 n
-技术 0.1 n
-记者 0.1 n
-时间 0.1 n
-项目 0.1 n
-问题 0.1 n
-企业 0.1 n
-财联社 0.1 n
-上涨 0.1 v
-下跌 0.1 v
-期货  0.1 n
-跌幅 0.1 n
-跌超 0.1 adj
-股票 0.1 n
+# 补充：热点概念与板块（Jieba/gse兼容格式）
+# 权重说明：核心热点500-700分，事件类400分，负权重词汇按需求保留
+
+# 一、负权重低优先级词汇（减少无差别匹配干扰）
+公司 -0.1 n
+国家 -0.1 n
+国际 -0.1 n
+会议 -0.1 n
+市场 -0.1 n
+经济 -0.1 n
+技术 -0.1 n
+记者 -0.1 n
+时间 -0.1 n
+项目 -0.1 n
+问题 -0.1 n
+企业 -0.1 n
+财联社 -0.1 n
+上涨 -0.1 v
+下跌 -0.1 v
+期货 -0.1 n
+跌幅 -0.1 n
+跌超 -0.1 adj
+股票 -0.1 n
+基金 -0.1 n
+电讯 -0.1 n
+建筑 -0.1 n
+平开 -0.1 n
+保险 -0.1 n
+行业 -0.1 n
+其他 -0.1 n
+
+# 二、核心热点概念（700分，最高优先级）
+比特币 700 n
+摩尔线程 700 n
+摩尔线程概念 700 n
+AI算力 700 n
+生成式AI 700 n
+量子计算 700 n
+脑机接口 700 n
+6G通信 700 n
+人形机器人 700 n
+固态电池 700 n
+ChatGPT概念 700 n
+Web3.0 700 n
+元宇宙 700 n
+数字孪生 700 n
+量子通信 700 n
+
+# 三、重点赛道板块（500分，高优先级）
 冰雪旅游 500 n
 特高压 500 n
 跨境电商 500 n
-俄乌冲突 400 n
 新能源汽车 500 n
 机器人 500 n
-具身智能 500 n
+具身智能 500 n
+油气 500 n
+商业航天 500 n
+光伏储能 500 n
+锂电材料 500 n
+半导体设备 500 n
+集成电路 500 n
+创新药 500 n
+CXO 500 n
+医疗器械 500 n
+数字经济 500 n
+数字货币 500 n
+区块链 500 n
+低空经济 500 n
+工业互联网 500 n
+物联网 500 n
+5G应用 500 n
+充电桩 500 n
+氢能源 500 n
+核聚变 500 n
+工业母机 500 n
+新材料 500 n
+生物制造 500 n
+智能网联汽车 500 n
+乡村振兴 500 n
+国企改革 500 n
+央企重组 500 n
+跨境金融 500 n
+自贸港 500 n
+一带一路 500 n
+绿色低碳 500 n
+碳交易 500 n
+数据要素 500 n
+数字基建 500 n
+东数西算 500 n
+国产替代 500 n
+信创 500 n
+网络安全 500 n
+算力网络 500 n
+边缘计算 500 n
+虚拟现实 500 n
+增强现实 500 n
+智能穿戴 500 n
+智能家居 500 n
+车联网 500 n
+激光雷达 500 n
+氮化镓 500 n
+碳化硅 500 n
+第三代半导体 500 n
+EDA工具 500 n
+光刻胶 500 n
+芯片设计 500 n
+封装测试 500 n
+储能电池 500 n
+钠离子电池 500 n
+氢燃料电池 500 n
+光伏组件 500 n
+风电设备 500 n
+特高压设备 500 n
+电力物联网 500 n
+智能电网 500 n
+轨道交通 500 n
+航空航天 500 n
+海洋工程 500 n
+高端装备 500 n
+军工电子 500 n
+卫星互联网 500 n
+北斗导航 500 n
+国产大飞机 500 n
+生物医药 500 n
+基因测序 500 n
+疫苗 500 n
+医疗美容 500 n
+养老产业 500 n
+教育信息化 500 n
+体育产业 500 n
+文化创意 500 n
+旅游复苏 500 n
+预制菜 500 n
+白酒 500 n
+食品饮料 500 n
+家电下乡 500 n
+房地产复苏 500 n
+基建投资 500 n
+新型城镇化 500 n
+冷链物流 500 n
+快递物流 500 n
+跨境支付 500 n
+金融科技 500 n
+消费电子 500 n
+元宇宙基建 500 n
+数字藏品 500 n
+NFT 500 n
+绿色电力 500 n
+节能降碳 500 n
+抽水蓄能 500 n
+生物质能 500 n
+地热能 500 n
+潮汐能 500 n
+
+# 四、事件驱动型概念（400分，中优先级）
+俄乌冲突 400 n
+中东局势 400 n
+美联储加息 400 n
+降息预期 400 n
+贸易摩擦 400 n
+供应链重构 400 n
+能源危机 400 n
+粮食安全 400 n
+疫情复苏 400 n
+政策利好 400 n
+产业扶持 400 n
+技术突破 400 n
+并购重组 400 n
+IPO提速 400 n
+解禁潮 400 n
+北向资金流入 400 n
+南向资金流入 400 n
+主力资金异动 400 n
+行业景气度 400 n
+业绩预增 400 n
+商誉减值 400 n
+退市风险 400 n
+监管新规 400 n
+税收优惠 400 n
+补贴政策 400 n
+基建刺激 400 n
+消费刺激 400 n
+新能源补贴 400 n
+碳达峰政策 400 n
+碳中和目标 400 n

backend/data/market_news_api.go

@@ -8,6 +8,7 @@ import (
 	"go-stock/backend/logger"
 	"go-stock/backend/models"
 	"go-stock/backend/util"
+	"net/url"
 	"strconv"
 	"strings"
 	"time"
@@ -53,7 +54,7 @@ func (m MarketNewsApi) TelegraphList(crawlTimeOut int64) *[]models.Telegraph {
 		for _, v := range rollData {
 			news := v.(map[string]any)
 			ctime, _ := convertor.ToInt(news["ctime"])
-			dataTime := time.Unix(ctime, 0)
+			dataTime := time.Unix(ctime, 0).Local()
 			logger.SugaredLogger.Debugf("dataTime: %s", dataTime)
 			telegraph := models.Telegraph{
 				Content:         news["content"].(string),
@@ -209,9 +210,9 @@ func (m MarketNewsApi) GetNewsList2(source string, limit int) *[]*models.Telegra
 func (m MarketNewsApi) GetTelegraphList(source string) *[]*models.Telegraph {
 	news := &[]*models.Telegraph{}
 	if source != "" {
-		db.Dao.Model(news).Preload("TelegraphTags").Where("source=?", source).Order("id desc").Limit(20).Find(news)
+		db.Dao.Model(news).Preload("TelegraphTags").Where("source=?", source).Order("data_time desc,time desc").Limit(50).Find(news)
 	} else {
-		db.Dao.Model(news).Preload("TelegraphTags").Order("id desc").Limit(20).Find(news)
+		db.Dao.Model(news).Preload("TelegraphTags").Order("data_time desc,time desc").Limit(50).Find(news)
 	}
 	for _, item := range *news {
 		tags := &[]models.Tags{}
@@ -268,6 +269,10 @@ func (m MarketNewsApi) GetSinaNews(crawlTimeOut uint) *[]models.Telegraph {
 			//logger.SugaredLogger.Infof("%s:%s", data["create_time"], data["rich_text"])
 			telegraph.Content = data["rich_text"].(string)
 			telegraph.Time = strings.Split(data["create_time"].(string), " ")[1]
+			dataTime, _ := time.ParseInLocation("2006-01-02 15:04:05", data["create_time"].(string), time.Local)
+			if &dataTime != nil {
+				telegraph.DataTime = &dataTime
+			}
 			tags := data["tag"].([]any)
 			telegraph.SubjectTags = lo.Map(tags, func(tagItem any, index int) string {
 				name := tagItem.(map[string]any)["name"].(string)
@@ -286,7 +291,7 @@ func (m MarketNewsApi) GetSinaNews(crawlTimeOut uint) *[]models.Telegraph {
 			if telegraph.Content != "" {
 				telegraph.SentimentResult = AnalyzeSentiment(telegraph.Content).Description
 				cnt := int64(0)
-				db.Dao.Model(telegraph).Where("time=? and source=?", telegraph.Time, telegraph.Source).Count(&cnt)
+				db.Dao.Model(telegraph).Where("content=? and source=?", telegraph.Content, telegraph.Source).Count(&cnt)
 				if cnt == 0 {
 					db.Dao.Create(&telegraph)
 					telegraphs = append(telegraphs, telegraph)
@@ -640,14 +645,16 @@ func (m MarketNewsApi) EMDictCode(code string, cache *freecache.Cache) []any {
 	return respMap["data"].([]any)
 }
 
-func (m MarketNewsApi) TradingViewNews() *[]models.TVNews {
+func (m MarketNewsApi) TradingViewNews() *[]models.Telegraph {
 	client := resty.New()
 	config := GetSettingConfig()
 	if config.HttpProxyEnabled && config.HttpProxy != "" {
 		client.SetProxy(config.HttpProxy)
 	}
 	TVNews := &[]models.TVNews{}
-	url := "https://news-mediator.tradingview.com/news-flow/v2/news?filter=lang:zh-Hans&filter=provider:panews,reuters&client=screener&streaming=false"
+	news := &[]models.Telegraph{}
+	//	url := "https://news-mediator.tradingview.com/news-flow/v2/news?filter=lang:zh-Hans&filter=area:WLD&client=screener&streaming=false"
+	url := "https://news-mediator.tradingview.com/news-flow/v2/news?filter=area%3AWLD&filter=lang%3Azh-Hans&client=screener&streaming=false"
 	resp, err := client.SetTimeout(time.Duration(5)*time.Second).R().
 		SetHeader("Host", "news-mediator.tradingview.com").
 		SetHeader("Origin", "https://cn.tradingview.com").
@@ -656,19 +663,78 @@ func (m MarketNewsApi) TradingViewNews() *[]models.TVNews {
 		Get(url)
 	if err != nil {
 		logger.SugaredLogger.Errorf("TradingViewNews err:%s", err.Error())
-		return TVNews
+		return news
 	}
 	respMap := map[string]any{}
 	err = json.Unmarshal(resp.Body(), &respMap)
 	if err != nil {
-		return TVNews
+		return news
 	}
 	items, err := json.Marshal(respMap["items"])
 	if err != nil {
-		return TVNews
+		return news
 	}
 	json.Unmarshal(items, TVNews)
-	return TVNews
+
+	for _, a := range *TVNews {
+		detail := NewMarketNewsApi().TradingViewNewsDetail(a.Id)
+		dataTime := time.Unix(int64(a.Published), 0).Local()
+		description := ""
+		sentimentResult := ""
+		if detail != nil {
+			description = detail.ShortDescription
+			sentimentResult = AnalyzeSentiment(description).Description
+		}
+		if a.Title == "" {
+			continue
+		}
+		telegraph := &models.Telegraph{
+			Title:           a.Title,
+			Content:         description,
+			DataTime:        &dataTime,
+			IsRed:           false,
+			Time:            dataTime.Format("15:04:05"),
+			Source:          "外媒",
+			Url:             fmt.Sprintf("https://cn.tradingview.com/news/%s", a.Id),
+			SentimentResult: sentimentResult,
+		}
+		cnt := int64(0)
+		db.Dao.Model(telegraph).Where("time=? and content=? and source=?", telegraph.Time, telegraph.Content, "外媒").Count(&cnt)
+		if cnt > 0 {
+			continue
+		}
+		db.Dao.Model(&models.Telegraph{}).Where("content=? and source=?", description, "外媒").FirstOrCreate(&telegraph)
+		*news = append(*news, *telegraph)
+	}
+	return news
+}
+func (m MarketNewsApi) TradingViewNewsDetail(id string) *models.TVNewsDetail {
+	//https://news-headlines.tradingview.com/v3/story?id=panews%3A9be7cf057e3f9%3A0&lang=zh-Hans
+	newsDetail := &models.TVNewsDetail{}
+	newsUrl := fmt.Sprintf("https://news-headlines.tradingview.com/v3/story?id=%s&lang=zh-Hans", url.QueryEscape(id))
+
+	client := resty.New()
+	config := GetSettingConfig()
+	if config.HttpProxyEnabled && config.HttpProxy != "" {
+		client.SetProxy(config.HttpProxy)
+	}
+	request := client.SetTimeout(time.Duration(3) * time.Second).R()
+	_, err := request.
+		SetHeader("Host", "news-headlines.tradingview.com").
+		SetHeader("Origin", "https://cn.tradingview.com").
+		SetHeader("Referer", "https://cn.tradingview.com/").
+		SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:146.0) Gecko/20100101 Firefox/146.0").
+		//SetHeader("TE", "trailers").
+		//SetHeader("Priority", "u=4").
+		//SetHeader("Connection", "keep-alive").
+		SetResult(newsDetail).
+		Get(newsUrl)
+	if err != nil {
+		logger.SugaredLogger.Errorf("TradingViewNewsDetail err:%s", err.Error())
+		return newsDetail
+	}
+	logger.SugaredLogger.Infof("resp:%+v", newsDetail)
+	return newsDetail
 }
 
 func (m MarketNewsApi) XUEQIUHotStock(size int, marketType string) *[]models.HotItem {
@@ -1031,9 +1097,9 @@ func (m MarketNewsApi) CailianpressWeb(searchWords string) *models.CailianpressW
 func (m MarketNewsApi) GetNews24HoursList(source string, limit int) *[]*models.Telegraph {
 	news := &[]*models.Telegraph{}
 	if source != "" {
-		db.Dao.Model(news).Preload("TelegraphTags").Where("source=? and created_at>?", source, time.Now().Add(-24*time.Hour)).Order("id desc,is_red desc").Limit(limit).Find(news)
+		db.Dao.Model(news).Preload("TelegraphTags").Where("source=? and created_at>?", source, time.Now().Add(-24*time.Hour)).Order("created_at desc,is_red desc").Limit(limit).Find(news)
 	} else {
-		db.Dao.Model(news).Preload("TelegraphTags").Where("created_at>?", time.Now().Add(-24*time.Hour)).Order("id desc,is_red desc").Limit(limit).Find(news)
+		db.Dao.Model(news).Preload("TelegraphTags").Where("created_at>?", time.Now().Add(-24*time.Hour)).Order("created_at desc,is_red desc").Limit(limit).Find(news)
 	}
 	// 内容去重
 	uniqueNews := make([]*models.Telegraph, 0)

backend/data/market_news_api_test.go

@@ -21,7 +21,12 @@ import (
 
 func TestGetSinaNews(t *testing.T) {
 	db.Init("../../data/stock.db")
-	NewMarketNewsApi().GetSinaNews(30)
+	InitAnalyzeSentiment()
+	news := NewMarketNewsApi().GetSinaNews(30)
+	for i, telegraph := range *news {
+		logger.SugaredLogger.Debugf("key: %+v, value: %+v", i, telegraph)
+
+	}
 	//NewMarketNewsApi().GetNewTelegraph(30)
 
 }
@@ -122,10 +127,8 @@ func TestEMDictCode(t *testing.T) {
 
 func TestTradingViewNews(t *testing.T) {
 	db.Init("../../data/stock.db")
-	resp := NewMarketNewsApi().TradingViewNews()
-	for _, a := range *resp {
-		logger.SugaredLogger.Debugf("value: %+v", a)
-	}
+	InitAnalyzeSentiment()
+	NewMarketNewsApi().TradingViewNews()
 }
 
 func TestXUEQIUHotStock(t *testing.T) {

backend/data/search_stock_api.go

@@ -37,10 +37,10 @@ func (s SearchStockApi) SearchStock(pageSize int) map[string]any {
 				"matchWord": "",
 				"timestamp": "%d",
 				"shareToGuba": false,
-				"requestId": "RMd3Y76AJI98axPvdhdbKvbBDVwLlUK61761559950168",
+				"requestId": "",
 				"needCorrect": true,
 				"removedConditionIdList": [],
-				"xcId": "xc0d61279aad33008260",
+				"xcId": "",
 				"ownSelectAll": false,
 				"dxInfo": [],
 				"extraCondition": ""

backend/data/search_stock_api_test.go

@@ -4,14 +4,22 @@ import (
 	"encoding/json"
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
+	"math"
 	"testing"
 
 	"github.com/duke-git/lancet/v2/convertor"
+	"github.com/duke-git/lancet/v2/random"
 )
 
 func TestSearchStock(t *testing.T) {
 	db.Init("../../data/stock.db")
 
+	e := convertor.ToString(math.Floor(float64(9*random.RandFloat(0, 1, 12) + 1)))
+	for i := 0; i < 19; i++ {
+		e += convertor.ToString(math.Floor(float64(9 * random.RandFloat(0, 1, 12))))
+	}
+	logger.SugaredLogger.Infof("e:%s", e)
+
 	res := NewSearchStockApi("量比大于2，基本面优秀，2025年三季报已披露，主力连续3日净流入，非创业板非科创板非ST").SearchStock(20)
 	logger.SugaredLogger.Infof("res:%+v", res)
 	data := res["data"].(map[string]any)

backend/data/stock_sentiment_analysis.go

@@ -33,18 +33,19 @@ var (
 		"复苏": 2.0, "突破": 2.0, "创新高": 3.0, "回暖": 1.5, "上扬": 1.5,
 		"利好消息": 3.0, "收益增长": 2.5, "利润增长": 2.5, "业绩优异": 2.5,
 		"潜力股": 2.0, "绩优股": 2.0, "强势": 1.5, "走高": 1.5, "攀升": 1.5,
-		"大涨": 2.5, "飙升": 3.0, "井喷": 3.0, "爆发": 2.5, "暴涨": 3.0,
+		"大涨": 2.5, "飙升": 3.0, "井喷": 3.0, "暴涨": 3.0,
 	}
 
 	// 负面金融词汇及其权重
 	negativeFinanceWords = map[string]float64{
-		"跌": 1.0, "下跌": 2.0, "跌停": 3.0, "熊市": 3.0, "回调": 1.5, "新低": 2.5,
+		"跌": 2.0, "下跌": 2.0, "跌停": 3.0, "熊市": 3.0, "回调": 2.5, "新低": 2.5,
 		"利空": 2.5, "减持": 2.0, "卖出": 2.0, "看空": 2.0, "亏损": 2.5,
 		"下滑": 2.0, "萎缩": 2.0, "不及预期": 2.5, "疲软": 1.5, "恶化": 2.0,
-		"衰退": 2.0, "跌破": 2.0, "创新低": 3.0, "走弱": 1.5, "下挫": 1.5,
+		"衰退": 2.0, "跌破": 2.0, "创新低": 3.0, "走弱": 2.5, "下挫": 2.5,
 		"利空消息": 3.0, "收益下降": 2.5, "利润下滑": 2.5, "业绩不佳": 2.5,
-		"垃圾股": 2.0, "风险股": 2.0, "弱势": 1.5, "走低": 1.5, "缩量": 2.5,
-		"大跌": 2.5, "暴跌": 3.0, "崩盘": 3.0, "跳水": 3.0, "重挫": 3.0, "跌超": 2.5, "跌逾": 2.5,
+		"垃圾股": 2.0, "风险股": 2.0, "弱势": 2.5, "走低": 2.5, "缩量": 2.5,
+		"大跌": 2.5, "暴跌": 3.0, "崩盘": 3.0, "跳水": 3.0, "重挫": 3.0, "跌超": 2.5, "跌逾": 2.5, "跌近": 3.0,
+		"被抓": 3.0, "被抓捕": 3.0, "回吐": 3.0, "转跌": 3.0,
 	}
 
 	// 否定词，用于反转情感极性
@@ -56,7 +57,7 @@ var (
 	degreeWords = map[string]float64{
 		"非常": 1.8, "极其": 2.2, "太": 1.8, "很": 1.5,
 		"比较": 0.8, "稍微": 0.6, "有点": 0.7, "显著": 1.5,
-		"大幅": 1.8, "急剧": 2.0, "轻微": 0.6, "小幅": 0.7, "逾": 1.8,
+		"大幅": 1.8, "急剧": 2.0, "轻微": 0.6, "小幅": 0.7, "逾": 1.8, "超": 1.8,
 	}
 
 	// 转折词，用于识别情感转折
@@ -72,6 +73,7 @@ var baseDict string
 var zhDict string
 
 func InitAnalyzeSentiment() {
+	//err := seg.LoadDictEmbed()
 	err := seg.LoadDictEmbed(baseDict)
 	if err != nil {
 		logger.SugaredLogger.Error(err.Error())
@@ -79,15 +81,16 @@ func InitAnalyzeSentiment() {
 		logger.SugaredLogger.Info("加载默认词典成功")
 	}
 	seg.CalcToken()
+
 	stocks := &[]StockBasic{}
 	db.Dao.Model(&StockBasic{}).Find(stocks)
 	for _, stock := range *stocks {
 		if strutil.Trim(stock.Name) == "" {
 			continue
 		}
-		err := seg.AddToken(stock.Name, basefreq+500, "n")
+		err := seg.AddToken(stock.Name, basefreq+100, "n")
 		if strutil.Trim(stock.BKName) != "" {
-			err = seg.AddToken(stock.BKName, basefreq+500, "n")
+			err = seg.AddToken(stock.BKName, basefreq+100, "n")
 		}
 		if err != nil {
 			logger.SugaredLogger.Errorf("添加%s失败:%s", stock.Name, err.Error())
@@ -99,9 +102,9 @@ func InitAnalyzeSentiment() {
 		if strutil.Trim(stock.Name) == "" {
 			continue
 		}
-		err := seg.AddToken(stock.Name, basefreq+500, "n")
+		err := seg.AddToken(stock.Name, basefreq+100, "n")
 		if strutil.Trim(stock.BKName) != "" {
-			err = seg.AddToken(stock.BKName, basefreq+500, "n")
+			err = seg.AddToken(stock.BKName, basefreq+100, "n")
 		}
 		if err != nil {
 			logger.SugaredLogger.Errorf("添加%s失败:%s", stock.Name, err.Error())
@@ -116,9 +119,9 @@ func InitAnalyzeSentiment() {
 	//	}
 	//}
 	tags := &[]models.Tags{}
-	db.Dao.Model(&models.Tags{}).Find(tags)
+	db.Dao.Model(&models.Tags{}).Where("type = ?", "subject").Find(tags)
 	for _, tag := range *tags {
-		err := seg.AddToken(tag.Name, basefreq, "n")
+		err := seg.ReAddToken(tag.Name, basefreq+100, "n")
 		if err != nil {
 			logger.SugaredLogger.Errorf("添加%s失败:%s", tag.Name, err.Error())
 		}
@@ -138,7 +141,7 @@ func InitAnalyzeSentiment() {
 			k := strutil.SplitAndTrim(line, " ")
 			switch len(k) {
 			case 1:
-				err = seg.ReAddToken(k[0], 100)
+				err = seg.ReAddToken(k[0], basefreq)
 			case 2:
 				freq, _ := convertor.ToFloat(k[1])
 				err = seg.ReAddToken(k[0], freq)
@@ -264,7 +267,7 @@ func countWordFrequencyWithWeight(text string) map[string]WordFreqWithWeight {
 	// 构建包含权重的结果
 	for word, frequency := range wordCount {
 		weight := getWordWeight(word)
-		if weight > 200 {
+		if weight > basefreq {
 			freqMap[word] = WordFreqWithWeight{
 				Word:      word,
 				Frequency: frequency,

backend/data/stock_sentiment_analysis_test.go

@@ -27,6 +27,8 @@ func TestAnalyzeSentiment(t *testing.T) {
 	text := messageText.String()
 	//text = " 【周六你需要知道的隔夜全球要闻：美联储鸽声重振 美股走势回稳】 1、纽约联储行长威廉姆斯表示，随着劳动力市场走软，美联储近期内仍有再次降息的空间。 2、美联储理事斯蒂芬·米兰表示，自上次联邦公开市场委员会（FOMC）会议以来的经济数据应“促使人们偏向鸽派立场”。 3、波士顿联邦储备银行行长柯林斯表示，由于通胀可能在一段时间内保持高位，维持利率不变“目前合适”。 4、据CME“美联储观察”，截至北京时间11月22日6时30分，美联储12月降息25个基点的概率为69.4%，维持利率不变的概率为30.6%。 5、美国劳工统计局表示，11月CPI报告将于12月18日发布，同时取消了10月CPI报告发布，表示无法追溯采集政府停摆期间未能收集的部分数据。 6、俄罗斯总统普京表示，已收到美提出解决俄乌冲突的计划，俄罗斯愿意进行和平谈判。美国总统特朗普表示，他认为27日是乌克兰接受美国支持的和平计划的最后期限。 7、美联储高官鸽派言论提振市场情绪，美股三大指数收盘集体上涨，道琼斯指数涨1.08%，标普500指数涨0.98%，纳斯达克综合指数涨0.88%。甲骨文跌超5%，英伟达跌超1%。纳指本周累计跌2.74%，标普500指数累跌1.95%，道指累跌1.91%。英伟达本周累跌5.9%。 8、热门中概股多数上涨，纳斯达克中国金龙指数收涨1.23%。蔚来涨超3%，哔哩哔哩、理想汽车涨超2%，京东、小鹏汽车涨超1%。 9、国际油价下跌，交易员评估乌克兰与俄罗斯可能达成和平协议的前景。WTI 1月期货下跌1.6%，结算价报每桶58.06美元，为过去五个交易日中第四次下跌。布伦特1月期货下跌1.3%，结算价报每桶62.56美元。 10、美联储延长压力测试改进方案征询期，为银行反馈提供更多时间。 11、由于美国人对个人财务状况的看法恶化，美国消费者信心在11月跌至接近纪录最低水平；密歇根大学数据显示，11月消费者信心指数降至51，10月为53.6。 12、日本央行政策委员会委员Kazuyuki Masu表示，日本央行接近作出加息决定。 13、穆迪将意大利信用评级从BAA3上调至BAA2，展望稳定。\n"
 	text = "财联社电：英伟达周五冲高回落，股价涨幅收于1%，市场普遍认为其走势疲软"
+	text = "【本轮巴以冲突已致加沙地带69733人死亡】财联社11月22日电，当地时间22日下午，以军对加沙城西部一辆汽车发动空袭，已造成5人死亡，多人受伤。自2023年10月7日巴以新一轮大规模冲突爆发以来，以色列对加沙地带的袭击已造成69733人死亡、170863人受伤。"
+	//text = "【牛肉加工亏损 美国泰森公司关停缩减相关业务】财联社11月22日电，受牛肉加工业务亏损影响，当地时间21日，美国泰森食品公司发布公告称，将关闭位于内布拉斯加州的一家大型牛肉加工厂，还计划缩小得克萨斯州一家牛肉加工厂的生产规模。根据泰森食品公司的公告，被关闭的这家工厂位于内布拉斯加州列克星敦，日均可宰杀并处理大约5000头牛，约占全美日均牛肉屠宰数量的4.8%。与此同时，公司还计划缩小得克萨斯州一家牛肉加工厂的生产规模，这家工厂每天大约可屠宰6000头牛。据悉，泰森此次业务调整影响两个工厂大约5000个工作岗位。《华尔街日报》报道称，泰森是美国四大肉类加工公司中首家关闭主要牛肉加工厂的公司，其最新财报显示，2025财年牛肉加工是唯一亏损的业务部门，调整后的营业亏损为4.26亿美元。"
 	// 分析情感
 	words := splitWords(text)
 	fmt.Println(strings.Join(words, " "))

backend/models/models.go

@@ -232,15 +232,16 @@ type Prompt struct {
 type Telegraph struct {
 	gorm.Model
 	Time            string          `json:"time"`
-	DataTime        *time.Time      `json:"dataTime"`
-	Content         string          `json:"content"`
+	DataTime        *time.Time      `json:"dataTime" gorm:"index"`
+	Title           string          `json:"title" gorm:"index"`
+	Content         string          `json:"content" gorm:"index"`
 	SubjectTags     []string        `json:"subjects" gorm:"-:all"`
 	StocksTags      []string        `json:"stocks" gorm:"-:all"`
-	IsRed           bool            `json:"isRed"`
+	IsRed           bool            `json:"isRed" gorm:"index"`
 	Url             string          `json:"url"`
-	Source          string          `json:"source"`
+	Source          string          `json:"source" gorm:"index"`
 	TelegraphTags   []TelegraphTags `json:"tags" gorm:"-:migration;foreignKey:TelegraphId"`
-	SentimentResult string          `json:"sentimentResult"`
+	SentimentResult string          `json:"sentimentResult" gorm:"index"`
 }
 type TelegraphTags struct {
 	gorm.Model
@@ -331,6 +332,22 @@ type TVNews struct {
 		LogoId string `json:"logo_id"`
 	} `json:"provider"`
 }
+type TVNewsDetail struct {
+	ShortDescription string `json:"shortDescription"`
+	Tags             []struct {
+		Title string `json:"title"`
+		Args  []struct {
+			Id    string `json:"id"`
+			Value string `json:"value"`
+		} `json:"args"`
+	} `json:"tags"`
+	Copyright string `json:"copyright"`
+	Id        string `json:"id"`
+	Title     string `json:"title"`
+	Published int    `json:"published"`
+	Urgency   int    `json:"urgency"`
+	StoryPath string `json:"storyPath"`
+}
 
 type XUEQIUHot struct {
 	Data struct {

frontend/src/components/AnalyzeMartket.vue

@@ -1,9 +1,308 @@
 <script setup>
 
+import {AnalyzeSentimentWithFreqWeight,GlobalStockIndexes} from "../../wailsjs/go/main/App";
+import * as echarts from "echarts";
+import {onMounted,onUnmounted, ref} from "vue";
+import _ from "lodash";
+const { name,darkTheme,kDays ,chartHeight} = defineProps({
+  name: {
+    type: String,
+    default: ''
+  },
+  kDays: {
+    type: Number,
+    default: 14
+  },
+  chartHeight: {
+    type: Number,
+    default: 500
+  },
+  darkTheme: {
+    type: Boolean,
+    default: false
+  }
+})
+const common = ref([])
+const america = ref([])
+const europe = ref([])
+const asia = ref([])
+const mainIndex = ref([])
+const chinaIndex = ref([])
+const other = ref([])
+const globalStockIndexes = ref(null)
+const chartRef = ref(null);
+const gaugeChartRef = ref(null);
+const triggerAreas=ref(["main","extra","arrow"])
+let handleChartInterval=null
+let handleIndexInterval=null
+onMounted(() => {
+  handleChart()
+  getIndex()
+  handleChartInterval=setInterval(function () {
+    handleChart()
+  }, 1000 * 60)
+
+  handleIndexInterval=setInterval(function () {
+    getIndex()
+  }, 1000 * 2)
+})
+
+onUnmounted(()=>{
+  clearInterval(handleChartInterval)
+  clearInterval(handleIndexInterval)
+})
+
+function getIndex() {
+  GlobalStockIndexes().then((res) => {
+    globalStockIndexes.value = res
+    common.value = res["common"]
+    america.value = res["america"]
+    europe.value = res["europe"]
+    asia.value = res["asia"]
+    other.value = res["other"]
+    mainIndex.value=asia.value.filter(function (item) {
+      return ['上海',"深圳","香港","台湾","北京","东京","首尔","纽约","纳斯达克"].includes(item.location)
+    }).concat(america.value.filter(function (item) {
+      return ['上海',"深圳","香港","台湾","北京","东京","首尔","纽约","纳斯达克"].includes(item.location)
+    }))
+
+    chinaIndex.value=asia.value.filter(function (item) {
+      return ['上海',"深圳","香港","台湾","北京"].includes(item.location)
+    })
+
+  })
+}
+function  handleChart(){
+  const formatUtil = echarts.format;
+  AnalyzeSentimentWithFreqWeight("").then((res) => {
+    //console.log(res)
+    const treemapchart = echarts.init(chartRef.value);
+    const gaugeChart=echarts.init(gaugeChartRef.value);
+    let data = res['frequencies'].map(item => ({
+      name: item.Word,
+      // value: item.Frequency,
+      // value: item.Weight,
+      frequency: item.Frequency,
+      weight: item.Weight,
+      value: item.Score,
+    }));
+
+    let data2 = res['frequencies'].map(item => ({
+      name: item.Word,
+       value: item.Frequency,
+      // value: item.Weight,
+      frequency: item.Frequency,
+      weight: item.Weight,
+      //value: item.Score,
+    }));
+
+    let data3 = res['frequencies'].map(item => ({
+      name: item.Word,
+      //value: item.Frequency,
+       value: item.Weight,
+      frequency: item.Frequency,
+      weight: item.Weight,
+      //value: item.Score,
+    }));
+
+    let option = {
+      darkMode: darkTheme,
+      title: {
+        text:name,
+        left: 'center',
+        textStyle: {
+          color: darkTheme?'#ccc':'#456'
+        }
+      },
+      legend: {
+        show: false
+      },
+      toolbox: {
+        left: '20px',
+        tooltip:{
+          textStyle: {
+            color: darkTheme?'#ccc':'#456'
+          }
+        },
+        feature: {
+          saveAsImage: {title: '保存图片'},
+          restore: {
+            title: '默认',
+          },
+          myTool2: {
+            show: true,
+            title: '按权重',
+            icon:"path://M393.8816 148.1216a29.3376 29.3376 0 0 1-15.2576 38.0928c-43.776 17.152-81.92 43.8272-114.2784 76.2368A345.7536 345.7536 0 0 0 159.5392 512 352.8704 352.8704 0 0 0 512 864.4608a351.744 351.744 0 0 0 249.5488-102.912 353.536 353.536 0 0 0 76.2368-114.2784c5.6832-15.2576 22.8352-20.992 38.0928-15.2576 15.2576 5.7344 20.992 22.8864 15.2576 38.0928a421.2224 421.2224 0 0 1-89.6 133.376A412.6208 412.6208 0 0 1 512 921.6c-226.7136 0-409.6-182.8864-409.6-409.6 0-108.544 41.9328-211.456 120.0128-289.5872A421.2224 421.2224 0 0 1 355.84 132.864a29.3376 29.3376 0 0 1 38.0928 15.2576zM512 102.4c226.7136 0 409.6 182.8864 409.6 409.6 0 15.2576-13.312 28.5696-28.5696 28.5696H512A29.2864 29.2864 0 0 1 483.4304 512V130.9696c0-15.2576 13.312-28.5696 28.5696-28.5696z m28.5696 59.0336v321.9968h321.9968a350.976 350.976 0 0 0-321.9968-321.9968z",
+            onclick: function (){
+              treemapchart.setOption( {series:{
+                  data: data3
+                }})
+            }
+          },
+          myTool1: {
+            show: true,
+            title: '按频次',
+            icon:"path://M895.466667 476.8l-87.424-87.424v-123.626667a49.770667 49.770667 0 0 0-49.770667-49.770666h-123.626667L547.2 128.533333a49.792 49.792 0 0 0-70.4 0l-87.424 87.424h-123.626667a49.770667 49.770667 0 0 0-49.770666 49.770667v123.626667L128.533333 476.8a49.792 49.792 0 0 0 0 70.4l87.424 87.424v123.626667a49.770667 49.770667 0 0 0 49.770667 49.770666h123.626667l87.424 87.424a49.792 49.792 0 0 0 70.4 0l87.424-87.424h123.626666a49.770667 49.770667 0 0 0 49.770667-49.770666v-123.626667l87.424-87.424a49.749333 49.749333 0 0 0 0.042667-70.4z m-137.216 137.194667v144.256h-144.256L512 860.266667l-101.994667-101.994667h-144.256v-144.256L163.733333 512l101.994667-101.994667v-144.256h144.256L512 163.733333l101.994667 101.994667h144.256v144.256L860.266667 512l-102.016 101.994667z M414.378667 514.730667l28.672 10.922666c-18.090667 47.445333-38.229333 92.16-60.757334 133.802667l-30.037333-13.653333a1042.133333 1042.133333 0 0 0 62.122667-131.072zM381.952 367.616L355.669333 384c25.258667 26.282667 45.056 50.176 60.074667 72.021333l25.6-17.749333c-13.994667-20.48-33.792-44.032-59.392-70.656zM537.258667 455.338667c-0.682667 43.690667-6.144 79.189333-16.725334 106.837333-14.336 32.768-44.373333 60.416-89.429333 82.944l21.162667 25.941333c52.224-26.624 85.333333-60.074667 99.328-100.693333 1.706667-5.12 3.413333-10.24 4.778666-15.36 21.504 45.738667 52.906667 83.968 93.866667 115.370667l21.504-24.917334c-51.2-34.474667-86.357333-81.237333-105.813333-140.288 1.706667-15.701333 2.730667-32.085333 2.730666-49.834666h-31.402666z M508.586667 434.858667h115.712c-6.826667 25.258667-15.018667 47.786667-24.917334 66.901333l31.744 8.874667a627.008 627.008 0 0 0 27.989334-85.674667v-21.162667H517.12c3.413333-14.336 6.144-29.354667 8.874667-45.738666l-32.426667-5.12c-7.850667 59.392-25.6 105.813333-52.906667 139.264l26.965334 19.114666c16.725333-19.114667 30.378667-44.373333 40.96-76.458666z",
+            onclick: function (){
+              treemapchart.setOption( {series:{
+                  data: data2
+                }})
+            }
+          }
+        }
+      },
+      tooltip: {
+        formatter: function (info) {
+          var value = info.value.toFixed(2);
+          var frequency = info.data.frequency;
+          var weight = info.data.weight;
+          return [
+            '<div class="tooltip-title">' + info.name+ '</div>',
+            '热度: ' + formatUtil.addCommas(value) + '',
+            '<div class="tooltip-title">频次: ' +  formatUtil.addCommas(frequency)+ '</div>',
+            '<div class="tooltip-title">权重: ' +  formatUtil.addCommas(weight)+ '</div>',
+          ].join('');
+        }
+      },
+      series: [
+        {
+          type: 'treemap',
+          breadcrumb:{show: false},
+          left: '0',
+          top: '40',
+          right: '0',
+          bottom: '0',
+          tooltip: {
+            show: true
+          },
+          data: data
+        }
+      ]
+    };
+    treemapchart.setOption(option);
+
+
+
+    let option2 = {
+      darkMode: darkTheme,
+      series: [
+        {
+          type: 'gauge',
+          startAngle: 180,
+          endAngle: 0,
+          center: ['50%', '75%'],
+          radius: '90%',
+          min: -100,
+          max: 100,
+          splitNumber: 8,
+          axisLine: {
+            lineStyle: {
+              width: 6,
+              color: [
+                // [0.25, '#FF6E76'],
+                // [0.5, '#FDDD60'],
+                // [0.75, '#58D9F9'],
+                // [1, '#7CFFB2'],
+
+                [0.25, '#03fb6a'],
+                [0.5, '#58e1f9'],
+                [0.75, '#ef5922'],
+                [1, '#f11d29'],
+
+              ]
+            }
+          },
+          pointer: {
+            icon: 'path://M12.8,0.7l12,40.1H0.7L12.8,0.7z',
+            length: '12%',
+            width: 20,
+            offsetCenter: [0, '-60%'],
+            itemStyle: {
+              color: 'auto'
+            }
+          },
+          axisTick: {
+            length: 12,
+            lineStyle: {
+              color: 'auto',
+              width: 2
+            }
+          },
+          splitLine: {
+            length: 20,
+            lineStyle: {
+              color: 'auto',
+              width: 5
+            }
+          },
+          axisLabel: {
+            color:  darkTheme?'#ccc':'#456',
+            fontSize: 20,
+            distance: -45,
+            rotate: 'tangential',
+            formatter: function (value) {
+              if (value ===100) {
+                return '极热';
+              } else if (value === 50) {
+                return '乐观';
+              }  else if (value === 0) {
+                return '中性';
+              }else if (value === -50) {
+                return '谨慎';
+              } else if (value === -100) {
+                return '冰点';
+              }
+              return '';
+            }
+          },
+          title: {
+            offsetCenter: [0, '-10%'],
+            fontSize: 20
+          },
+          detail: {
+            fontSize: 30,
+            offsetCenter: [0, '-35%'],
+            valueAnimation: true,
+            formatter: function (value) {
+              return value.toFixed(2) + '';
+            },
+            color: 'inherit'
+          },
+          data: [
+            {
+              value: res.result.Score*0.2,
+              name: '市场情绪强弱'
+            }
+          ]
+        }
+      ]
+    };
+    gaugeChart.setOption(option2);
+  })
+}
 </script>
 
 <template>
-
+  <n-collapse :trigger-areas="triggerAreas" :default-expanded-names="['1']" display-directive="show">
+    <n-collapse-item  name="1" >
+      <template #header>
+          <n-flex>
+              <n-tag  size="small" :bordered="false" v-for="(item, index) in mainIndex" :type="item.zdf>0?'error':'success'">  {{item.name}} {{item.zxj}}   <n-number-animation :precision="2" :from="0" :to="item.zdf"/>%</n-tag>
+          </n-flex>
+      </template>
+      <template #header-extra>
+        主要股指
+      </template>
+      <n-grid :cols="24" :y-gap="0">
+        <n-gi span="6">
+          <div ref="gaugeChartRef" style="width: 100%;height: auto;--wails-draggable:no-drag" :style="{height:chartHeight+'px'}" ></div>
+        </n-gi>
+        <n-gi span="18">
+          <div ref="chartRef" style="width: 100%;height: auto;--wails-draggable:no-drag" :style="{height:chartHeight+'px'}" ></div>
+        </n-gi>
+      </n-grid>
+    </n-collapse-item>
+  </n-collapse>
 </template>
 
 <style scoped>

frontend/src/components/market.vue

@@ -13,7 +13,7 @@ import {
   SaveAsMarkdown,
   ShareAnalysis,
   SummaryStockNews,
-  GetAiConfigs, AnalyzeSentimentWithFreqWeight
+  GetAiConfigs,
 } from "../../wailsjs/go/main/App";
 import {EventsOff, EventsOn} from "../../wailsjs/runtime";
 import NewsList from "./newsList.vue";
@@ -45,6 +45,7 @@ const panelHeight = ref(window.innerHeight - 240)
 
 const telegraphList = ref([])
 const sinaNewsList = ref([])
+const foreignNewsList = ref([])
 const common = ref([])
 const america = ref([])
 const europe = ref([])
@@ -54,6 +55,7 @@ const globalStockIndexes = ref(null)
 const summaryModal = ref(false)
 const summaryBTN = ref(true)
 const darkTheme = ref(false)
+const httpProxyEnabled = ref(false)
 const theme = computed(() => {
   return darkTheme ? 'dark' : 'light'
 })
@@ -96,6 +98,7 @@ onBeforeMount(() => {
   GetConfig().then(result => {
     summaryBTN.value = result.openAiEnable
     darkTheme.value = result.darkTheme
+    httpProxyEnabled.value = result.httpProxyEnabled
   })
   GetPromptTemplates("", "").then(res => {
     promptTemplates.value = res
@@ -107,13 +110,15 @@ onBeforeMount(() => {
     aiConfigs.value = res
     aiConfigId.value = res[0].ID
   })
-
   GetTelegraphList("财联社电报").then((res) => {
     telegraphList.value = res
   })
   GetTelegraphList("新浪财经").then((res) => {
     sinaNewsList.value = res
   })
+  GetTelegraphList("外媒").then((res) => {
+    foreignNewsList.value = res
+  })
   getIndex();
   industryRank();
   indexInterval.value = setInterval(() => {
@@ -127,7 +132,6 @@ onBeforeMount(() => {
 
 })
 onMounted(() => {
-  Analyze() // 页面显示
 })
 
 
@@ -155,7 +159,6 @@ EventsOn("newTelegraph", (data) => {
       telegraphList.value.pop()
     }
     telegraphList.value.unshift(...data)
-    Analyze() // 页面显示
   }
 })
 EventsOn("newSinaNews", (data) => {
@@ -164,7 +167,14 @@ EventsOn("newSinaNews", (data) => {
     sinaNewsList.value.pop()
   }
   sinaNewsList.value.unshift(...data)
-    Analyze() // 页面显示
+  }
+})
+EventsOn("tradingViewNews", (data) => {
+  if (data!=null) {
+    for (let i = 0; i < data.length; i++) {
+      foreignNewsList.value.pop()
+    }
+    foreignNewsList.value.unshift(...data)
   }
 })
 
@@ -173,34 +183,6 @@ window.onresize = () => {
   panelHeight.value = window.innerHeight - 240
 }
 
-function Analyze(){
-  console.log("treemapchart:",treemapchart)
-  console.log("treemapRef:",treemapRef.value)
-  treemapchart = echarts.init(treemapRef.value);
-  treemapchart.showLoading()
-  AnalyzeSentimentWithFreqWeight("").then((res) => {
-    console.log(res)
-    let option = {
-      legend: {
-        show: false
-      },
-      series: [
-        {
-          type: 'treemap',
-          data: res['frequencies'].map(item => ({
-            name: item.Word,
-           // value: item.Frequency,
-           // value: item.Weight,
-            value: item.Score,
-          }))
-        }
-      ]
-    };
-    treemapchart.setOption(option);
-    treemapchart.hideLoading()
-  })
-}
-
 function getAreaName(code) {
   switch (code) {
     case "america":
@@ -275,9 +257,6 @@ function getAiSummary() {
 function updateTab(name) {
   summaryBTN.value = (name === "市场快讯");
   nowTab.value = name
-  if (name === "市场快讯") {
-    Analyze()
-  }
 }
 
 EventsOn("summaryStockNews", async (msg) => {
@@ -358,6 +337,9 @@ function ReFlesh(source) {
     if (source === "新浪财经") {
       sinaNewsList.value = res
     }
+    if (source === "外媒") {
+      foreignNewsList.value = res
+    }
   })
 }
 </script>
@@ -368,16 +350,20 @@ function ReFlesh(source) {
       <n-tab-pane name="市场快讯" tab="市场快讯">
         <n-grid :cols="1" :y-gap="0">
           <n-gi>
-            <div  ref="treemapRef"  style="width: 100%;height: 300px;" ></div>
+            <AnalyzeMartket :dark-theme="darkTheme" :chart-height="300" :kDays="1" :name="'最近24小时热词'" />
           </n-gi>
           <n-gi>
-            <n-grid :cols="2" :y-gap="0">
+            <n-grid :cols="httpProxyEnabled?3:2" :y-gap="0">
               <n-gi>
                 <news-list :newsList="telegraphList" :header-title="'财联社电报'" @update:message="ReFlesh"></news-list>
               </n-gi>
               <n-gi>
                 <news-list :newsList="sinaNewsList" :header-title="'新浪财经'" @update:message="ReFlesh"></news-list>
               </n-gi>
+              <n-gi v-if="httpProxyEnabled">
+                <news-list :newsList="foreignNewsList" :header-title="'外媒'" @update:message="ReFlesh"></news-list>
+              </n-gi>
+
             </n-grid>
           </n-gi>
         </n-grid>

frontend/src/components/newsList.vue

@@ -29,11 +29,19 @@ const updateMessage = () => {
       </n-flex>
     </template>
     <n-list-item v-for="item in newsList">
-      <n-space justify="start">
+      <n-space justify="start" >
         <n-text justify="start" :bordered="false" :type="item.isRed?'error':'info'">
           <n-tag size="small" :type="item.isRed?'error':'warning'" :bordered="false"> {{ item.time }}</n-tag>
-          {{ item.content }}
+          <n-gradient-text :size="14" :type="'warning'" :bordered="false">{{ item.title }}</n-gradient-text> <n-text :type="item.isRed?'error':'info'">{{ item.content }}</n-text>
         </n-text>
+<!--        <n-collapse v-if="item.title">-->
+<!--          <n-collapse-item :title="item.title" :name="item.title">-->
+<!--            <n-text justify="start" :bordered="false" :type="item.isRed?'error':'info'">-->
+<!--              <n-tag size="small" :type="item.isRed?'error':'warning'" :bordered="false"> {{ item.time }}</n-tag>-->
+<!--              {{ item.content }}-->
+<!--            </n-text>-->
+<!--          </n-collapse-item>-->
+<!--        </n-collapse>-->
       </n-space>
       <n-space v-if="item.subjects" style="margin-top: 2px">
         <n-tag :bordered="false" type="success" size="small" v-for="sub in item.subjects">

main.go

@@ -150,7 +150,7 @@ func main() {
 		OnShutdown:               app.shutdown,
 		WindowStartState:         options.Normal,
 		SingleInstanceLock: &options.SingleInstanceLock{
-			UniqueId:               "go-stock-dev",
+			UniqueId:               "go-stock",
 			OnSecondInstanceLaunch: OnSecondInstanceLaunch,
 		},
 		Bind: []interface{}{