Merge pull request #84 from ArvinLovegood/dev

合并

.github/workflows/main.yml

@@ -9,7 +9,6 @@ on:
 env:
   # Necessary for most environments as build failure can occur due to OOM issues
   NODE_OPTIONS: "--max-old-space-size=4096"
-  OFFICIAL_STATEMENT: ${{ vars.OFFICIAL_STATEMENT }}
 
 jobs:
   build:
@@ -21,16 +20,9 @@ jobs:
           - name: 'go-stock-windows-amd64.exe'
             platform:  'windows/amd64'
             os: 'windows-latest'
-          - name: 'go-stock-windows-arm64.exe'
-            platform: 'windows/arm64'
-            os: 'windows-latest'
-            arch: arm64
 #          - name: 'go-stock-linux-amd64'
 #            platform: 'linux/amd64'
 #            os: 'ubuntu-latest'
-          - name: 'go-stock-darwin-universal'
-            platform: 'darwin/universal'
-            os: 'macos-latest'
 
     runs-on: ${{ matrix.build.os }}
     steps:
@@ -46,7 +38,7 @@ jobs:
           echo "::set-output name=commit_message::$commit_message"
 
       - name: Build wails x go-stock
-        uses: ArvinLovegood/wails-build-action@v3.6
+        uses: ArvinLovegood/wails-build-action@v3.4
         id: build
         with:
           build-name: ${{ matrix.build.name }}
@@ -55,5 +47,4 @@ jobs:
           go-version: '1.24'
           build-tags: ${{ github.ref_name }}
           build-commit-message: ${{ steps.get_commit_message.outputs.commit_message }}
-          build-statement: ${{ env.OFFICIAL_STATEMENT }}
           node-version: '20.x'

README.md

@@ -37,8 +37,8 @@
 
 ### <span style="color: #568DF4;">各位亲爱的朋友们，如果您对这个项目感兴趣，请先给我一个<i style="color: #EA2626;">star</i>吧，谢谢！</span>💕
 - 优云智算（by UCloud）：万卡规模4090免费用10小时，新人注册另增50万tokens，海量热门源项目镜像一键部署，[注册链接](https://www.compshare.cn/image-community?ytag=GPU_YY-gh_gostock)
-- 火山方舟：新用户每个模型注册即送50万tokens，[注册链接](https://www.volcengine.com/experience/ark?utm_term=202502dsinvite&ac=DSASUQY5&rc=IJSE43PZ)
-- 硅基流动(siliconflow)，注册即送2000万Tokens，[注册链接](https://cloud.siliconflow.cn/i/foufCerk)
+- 经测试目前硅基流动(siliconflow)提供的deepSeek api 服务比较稳定，注册即送2000万Tokens，[注册链接](https://cloud.siliconflow.cn/i/foufCerk)
+- 火山方舟：每个模型注册即送50万tokens，[注册链接](https://www.volcengine.com/experience/ark?utm_term=202502dsinvite&ac=DSASUQY5&rc=IJSE43PZ)
 - Tushare大数据开放社区,免费提供各类金融数据,助力行业和量化研究(注意：Tushare只需要120积分即可，注册完成个人资料补充即可得120积分！！！)，[注册链接](https://tushare.pro/register?reg=701944)
 - 软件快速迭代开发中,请大家优先测试和使用最新发布的版本。
 - 欢迎大家提出宝贵的建议，欢迎提issue,PR。当然更欢迎[赞助我](#都划到这了如果我的项目对您有帮助请赞助我吧)。💕
@@ -57,7 +57,6 @@
 | 不再强制依赖Chrome浏览器 | ✅  | 默认使用edge浏览器抓取新闻资讯                                                                                        |
 
 ## 👀 更新日志
-### 2025.07.01 AI分析集成工具函数，AI分析将更加智能
 ### 2025.06.30 添加指标选股功能
 ### 2025.06.27 添加财经日历和重大事件时间轴功能
 ### 2025.06.25 添加热门股票、事件和话题功能

app.go

@@ -1,8 +1,11 @@
+//go:build windows
+
 package main
 
 import (
 	"context"
 	"encoding/base64"
+	"encoding/json"
 	"fmt"
 	"go-stock/backend/data"
 	"go-stock/backend/db"
@@ -18,9 +21,13 @@ import (
 	"github.com/duke-git/lancet/v2/mathutil"
 	"github.com/duke-git/lancet/v2/slice"
 	"github.com/duke-git/lancet/v2/strutil"
+	"github.com/energye/systray"
 	"github.com/go-resty/resty/v2"
+	"github.com/go-toast/toast"
 	"github.com/robfig/cron/v3"
+	"github.com/wailsapp/wails/v2/pkg/options"
 	"github.com/wailsapp/wails/v2/pkg/runtime"
+	"golang.org/x/sys/windows/registry"
 )
 
 // App struct
@@ -29,7 +36,6 @@ type App struct {
 	cache      *freecache.Cache
 	cron       *cron.Cron
 	cronEntrys map[string]cron.EntryID
-	AiTools    []data.Tool
 }
 
 // NewApp creates a new App application struct
@@ -38,66 +44,65 @@ func NewApp() *App {
 	cache := freecache.NewCache(cacheSize)
 	c := cron.New(cron.WithSeconds())
 	c.Start()
-	var tools []data.Tool
-	tools = AddTools(tools)
 	return &App{
 		cache:      cache,
 		cron:       c,
 		cronEntrys: make(map[string]cron.EntryID),
-		AiTools:    tools,
 	}
 }
 
-func AddTools(tools []data.Tool) []data.Tool {
-	tools = append(tools, data.Tool{
-		Type: "function",
-		Function: data.ToolFunction{
-			Name:        "SearchStockByIndicators",
-			Description: "根据自然语言筛选股票，返回自然语言选股条件要求的股票所有相关数据。输入股票名称可以获取当前股票最新的股价交易数据和基础财务指标信息，多个股票名称使用,分隔。",
-			Parameters: data.FunctionParameters{
-				Type: "object",
-				Properties: map[string]any{
-					"words": map[string]any{
-						"type": "string",
-						"description": "选股自然语言。" +
-							"例1：创新药,半导体;PE<30;净利润增长率>50%。 " +
-							"例2：上证指数,科创50。 " +
-							"例3：长电科技,上海贝岭。" +
-							"例4：长电科技,上海贝岭;KDJ,MACD,RSI,BOLL,主力净流入/流出" +
-							"例5：换手率大于3%小于25%.量比1以上. 10日内有过涨停.股价处于峰值的二分之一以下.流通股本<100亿.当日和连续四日净流入;股价在20日均线以上.分时图股价在均线之上.热门板块下涨幅领先的A股. 当日量能20000手以上.沪深个股.近一年市盈率波动小于150%.MACD金叉;不要ST股及不要退市股，非北交所，每股收益>0。" +
-							"例6：沪深主板.流通市值小于100亿.市值大于10亿.60分钟dif大于dea.60分钟skdj指标k值大于d值.skdj指标k值小于90.换手率大于3%.成交额大于1亿元.量比大于2.涨幅大于2%小于7%.股价大于5小于50.创业板.10日均线大于20日均线;不要ST股及不要退市股;不要北交所;不要科创板;不要创业板。" +
-							"例7：股价在20日线上，一月之内涨停次数>=1，量比大于1，换手率大于3%，流通市值大于 50亿小于200亿。" +
-							"例8：基本条件：前期有爆量，回调到 10 日线，当日是缩量阴线，均线趋势向上。;优选条件：一月之内涨停次数>=1",
-					},
-				},
-				Required: []string{"words"},
-			},
-		},
+// startup is called at application startup
+func (a *App) startup(ctx context.Context) {
+	defer PanicHandler()
+	runtime.EventsOn(ctx, "frontendError", func(optionalData ...interface{}) {
+		logger.SugaredLogger.Errorf("Frontend error: %v\n", optionalData)
+	})
+	logger.SugaredLogger.Infof("Version:%s", Version)
+	// Perform your setup here
+	a.ctx = ctx
+
+	// 创建系统托盘
+	//systray.RunWithExternalLoop(func() {
+	//	onReady(a)
+	//}, func() {
+	//	onExit(a)
+	//})
+	runtime.EventsOn(ctx, "updateSettings", func(optionalData ...interface{}) {
+		logger.SugaredLogger.Infof("updateSettings : %v\n", optionalData)
+		config := &data.Settings{}
+		setMap := optionalData[0].(map[string]interface{})
+
+		// 将 map 转换为 JSON 字节切片
+		jsonData, err := json.Marshal(setMap)
+		if err != nil {
+			logger.SugaredLogger.Errorf("Marshal error:%s", err.Error())
+			return
+		}
+		// 将 JSON 字节切片解析到结构体中
+		err = json.Unmarshal(jsonData, config)
+		if err != nil {
+			logger.SugaredLogger.Errorf("Unmarshal error:%s", err.Error())
+			return
+		}
+
+		logger.SugaredLogger.Infof("updateSettings config:%+v", config)
+		if config.DarkTheme {
+			runtime.WindowSetBackgroundColour(ctx, 27, 38, 54, 1)
+			runtime.WindowSetDarkTheme(ctx)
+		} else {
+			runtime.WindowSetBackgroundColour(ctx, 255, 255, 255, 1)
+			runtime.WindowSetLightTheme(ctx)
+		}
+		runtime.WindowReloadApp(ctx)
+
+	})
+	go systray.Run(func() {
+		onReady(a)
+	}, func() {
+		onExit(a)
 	})
 
-	tools = append(tools, data.Tool{
-		Type: "function",
-		Function: data.ToolFunction{
-			Name:        "GetStockKLine",
-			Description: "获取股票日K线数据。",
-			Parameters: data.FunctionParameters{
-				Type: "object",
-				Properties: map[string]any{
-					"days": map[string]any{
-						"type":        "string",
-						"description": "日K数据条数",
-					},
-					"stockCode": map[string]any{
-						"type":        "string",
-						"description": "股票代码（A股：sh,sz开头;港股hk开头,美股：us开头）",
-					},
-				},
-				Required: []string{"days", "stockCode"},
-			},
-		},
-	})
-
-	return tools
+	logger.SugaredLogger.Infof(" application startup Version:%s", Version)
 }
 
 func (a *App) CheckUpdate() {
@@ -306,7 +311,7 @@ func (a *App) AddCronTask(follow data.FollowedStock) func() {
 	return func() {
 		go runtime.EventsEmit(a.ctx, "warnMsg", "开始自动分析"+follow.Name+"_"+follow.StockCode)
 		ai := data.NewDeepSeekOpenAi(a.ctx)
-		msgs := ai.NewChatStream(follow.Name, follow.StockCode, "", nil, a.AiTools)
+		msgs := ai.NewChatStream(follow.Name, follow.StockCode, "", nil)
 		var res strings.Builder
 
 		chatId := ""
@@ -464,6 +469,49 @@ func MonitorFundPrices(a *App) {
 	}
 }
 
+func MonitorStockPrices(a *App) {
+	dest := &[]data.FollowedStock{}
+	db.Dao.Model(&data.FollowedStock{}).Find(dest)
+	total := float64(0)
+	//for _, follow := range *dest {
+	//	stockData := getStockInfo(follow)
+	//	total += stockData.ProfitAmountToday
+	//	price, _ := convertor.ToFloat(stockData.Price)
+	//	if stockData.PrePrice != price {
+	//		go runtime.EventsEmit(a.ctx, "stock_price", stockData)
+	//	}
+	//}
+
+	stockInfos := GetStockInfos(*dest...)
+	for _, stockInfo := range *stockInfos {
+		if strutil.HasPrefixAny(stockInfo.Code, []string{"SZ", "SH", "sh", "sz"}) && (!isTradingTime(time.Now())) {
+			continue
+		}
+		if strutil.HasPrefixAny(stockInfo.Code, []string{"hk", "HK"}) && (!IsHKTradingTime(time.Now())) {
+			continue
+		}
+		if strutil.HasPrefixAny(stockInfo.Code, []string{"us", "US", "gb_"}) && (!IsUSTradingTime(time.Now())) {
+			continue
+		}
+
+		total += stockInfo.ProfitAmountToday
+		price, _ := convertor.ToFloat(stockInfo.Price)
+
+		if stockInfo.PrePrice != price {
+			//logger.SugaredLogger.Infof("-----------sz------------股票代码: %s, 股票名称: %s, 股票价格: %s,盘前盘后:%s", stockInfo.Code, stockInfo.Name, stockInfo.Price, stockInfo.BA)
+			go runtime.EventsEmit(a.ctx, "stock_price", stockInfo)
+		}
+
+	}
+	if total != 0 {
+		title := "go-stock " + time.Now().Format(time.DateTime) + fmt.Sprintf("  %.2f¥", total)
+		systray.SetTooltip(title)
+	}
+
+	go runtime.EventsEmit(a.ctx, "realtime_profit", fmt.Sprintf("  %.2f", total))
+	//runtime.WindowSetTitle(a.ctx, title)
+
+}
 func GetStockInfos(follows ...data.FollowedStock) *[]data.StockInfo {
 	stockInfos := make([]data.StockInfo, 0)
 	stockCodes := make([]string, 0)
@@ -581,6 +629,35 @@ func addStockFollowData(follow data.FollowedStock, stockData *data.StockInfo) {
 	}
 }
 
+// beforeClose is called when the application is about to quit,
+// either by clicking the window close button or calling runtime.Quit.
+// Returning true will cause the application to continue, false will continue shutdown as normal.
+func (a *App) beforeClose(ctx context.Context) (prevent bool) {
+	defer PanicHandler()
+
+	dialog, err := runtime.MessageDialog(ctx, runtime.MessageDialogOptions{
+		Type:         runtime.QuestionDialog,
+		Title:        "go-stock",
+		Message:      "确定关闭吗？",
+		Buttons:      []string{"确定"},
+		Icon:         icon,
+		CancelButton: "取消",
+	})
+
+	if err != nil {
+		logger.SugaredLogger.Errorf("dialog error:%s", err.Error())
+		return false
+	}
+	logger.SugaredLogger.Debugf("dialog:%s", dialog)
+	if dialog == "No" {
+		return true
+	} else {
+		systray.Quit()
+		a.cron.Stop()
+		return false
+	}
+}
+
 // shutdown is called at application termination
 func (a *App) shutdown(ctx context.Context) {
 	defer PanicHandler()
@@ -670,13 +747,8 @@ func (a *App) SendDingDingMessageByType(message string, stockCode string, msgTyp
 	return data.NewDingDingAPI().SendDingDingMessage(message)
 }
 
-func (a *App) NewChatStream(stock, stockCode, question string, sysPromptId *int, enableTools bool) {
-	var msgs <-chan map[string]any
-	if enableTools {
-		msgs = data.NewDeepSeekOpenAi(a.ctx).NewChatStream(stock, stockCode, question, sysPromptId, a.AiTools)
-	} else {
-		msgs = data.NewDeepSeekOpenAi(a.ctx).NewChatStream(stock, stockCode, question, sysPromptId, []data.Tool{})
-	}
+func (a *App) NewChatStream(stock, stockCode, question string, sysPromptId *int) {
+	msgs := data.NewDeepSeekOpenAi(a.ctx).NewChatStream(stock, stockCode, question, sysPromptId)
 	for msg := range msgs {
 		runtime.EventsEmit(a.ctx, "newChatStream", msg)
 	}
@@ -692,49 +764,48 @@ func (a *App) GetAIResponseResult(stock string) *models.AIResponseResult {
 
 func (a *App) GetVersionInfo() *models.VersionInfo {
 	return &models.VersionInfo{
-		Version:           Version,
-		Icon:              GetImageBase(icon),
-		Alipay:            GetImageBase(alipay),
-		Wxpay:             GetImageBase(wxpay),
-		Content:           VersionCommit,
-		OfficialStatement: OFFICIAL_STATEMENT,
+		Version: Version,
+		Icon:    GetImageBase(icon),
+		Alipay:  GetImageBase(alipay),
+		Wxpay:   GetImageBase(wxpay),
+		Content: VersionCommit,
 	}
 }
 
-//// checkChromeOnWindows 在 Windows 系统上检查谷歌浏览器是否安装
-//func checkChromeOnWindows() bool {
-//	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
-//	if err != nil {
-//		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
-//		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
-//		if err != nil {
-//			return false
-//		}
-//		defer key.Close()
-//	}
-//	defer key.Close()
-//	_, _, err = key.GetValue("Path", nil)
-//	return err == nil
-//}
-//
-//// checkEdgeOnWindows 在 Windows 系统上检查Edge浏览器是否安装，并返回安装路径
-//func checkEdgeOnWindows() (string, bool) {
-//	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
-//	if err != nil {
-//		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
-//		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
-//		if err != nil {
-//			return "", false
-//		}
-//		defer key.Close()
-//	}
-//	defer key.Close()
-//	path, _, err := key.GetStringValue("Path")
-//	if err != nil {
-//		return "", false
-//	}
-//	return path, true
-//}
+// checkChromeOnWindows 在 Windows 系统上检查谷歌浏览器是否安装
+func checkChromeOnWindows() bool {
+	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
+	if err != nil {
+		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
+		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
+		if err != nil {
+			return false
+		}
+		defer key.Close()
+	}
+	defer key.Close()
+	_, _, err = key.GetValue("Path", nil)
+	return err == nil
+}
+
+// checkEdgeOnWindows 在 Windows 系统上检查Edge浏览器是否安装，并返回安装路径
+func checkEdgeOnWindows() (string, bool) {
+	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
+	if err != nil {
+		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
+		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
+		if err != nil {
+			return "", false
+		}
+		defer key.Close()
+	}
+	defer key.Close()
+	path, _, err := key.GetStringValue("Path")
+	if err != nil {
+		return "", false
+	}
+	return path, true
+}
 
 func GetImageBase(bytes []byte) string {
 	return "data:image/jpeg;base64," + base64.StdEncoding.EncodeToString(bytes)
@@ -791,6 +862,44 @@ func onExit(a *App) {
 	//runtime.Quit(a.ctx)
 }
 
+func onReady(a *App) {
+
+	// 初始化操作
+	logger.SugaredLogger.Infof("systray onReady")
+	systray.SetIcon(icon2)
+	systray.SetTitle("go-stock")
+	systray.SetTooltip("go-stock 股票行情实时获取")
+	// 创建菜单项
+	show := systray.AddMenuItem("显示", "显示应用程序")
+	show.Click(func() {
+		//logger.SugaredLogger.Infof("显示应用程序")
+		runtime.WindowShow(a.ctx)
+	})
+	hide := systray.AddMenuItem("隐藏", "隐藏应用程序")
+	hide.Click(func() {
+		//logger.SugaredLogger.Infof("隐藏应用程序")
+		runtime.WindowHide(a.ctx)
+	})
+	systray.AddSeparator()
+	mQuitOrig := systray.AddMenuItem("退出", "退出应用程序")
+	mQuitOrig.Click(func() {
+		//logger.SugaredLogger.Infof("退出应用程序")
+		runtime.Quit(a.ctx)
+	})
+	systray.SetOnRClick(func(menu systray.IMenu) {
+		menu.ShowMenu()
+		//logger.SugaredLogger.Infof("SetOnRClick")
+	})
+	systray.SetOnClick(func(menu systray.IMenu) {
+		//logger.SugaredLogger.Infof("SetOnClick")
+		menu.ShowMenu()
+	})
+	systray.SetOnDClick(func(menu systray.IMenu) {
+		menu.ShowMenu()
+		//logger.SugaredLogger.Infof("SetOnDClick")
+	})
+}
+
 func (a *App) UpdateConfig(settings *data.Settings) string {
 	//logger.SugaredLogger.Infof("UpdateConfig:%+v", settings)
 	if settings.RefreshInterval > 0 {
@@ -925,6 +1034,22 @@ func (a *App) SetStockAICron(cronText, stockCode string) {
 	a.cronEntrys[stockCode] = id
 
 }
+func OnSecondInstanceLaunch(secondInstanceData options.SecondInstanceData) {
+	notification := toast.Notification{
+		AppID:    "go-stock",
+		Title:    "go-stock",
+		Message:  "程序已经在运行了",
+		Icon:     "",
+		Duration: "short",
+		Audio:    toast.Default,
+	}
+	err := notification.Push()
+	if err != nil {
+		logger.SugaredLogger.Error(err)
+	}
+	time.Sleep(time.Second * 3)
+}
+
 func (a *App) AddGroup(group data.Group) string {
 	ok := data.NewStockGroupApi(db.Dao).AddGroup(group)
 	if ok {
@@ -1002,14 +1127,8 @@ func (a *App) GlobalStockIndexes() map[string]any {
 	return data.NewMarketNewsApi().GlobalStockIndexes(30)
 }
 
-func (a *App) SummaryStockNews(question string, sysPromptId *int, enableTools bool) {
-	var msgs <-chan map[string]any
-	if enableTools {
-		msgs = data.NewDeepSeekOpenAi(a.ctx).NewSummaryStockNewsStreamWithTools(question, sysPromptId, a.AiTools)
-	} else {
-		msgs = data.NewDeepSeekOpenAi(a.ctx).NewSummaryStockNewsStream(question, sysPromptId)
-	}
-
+func (a *App) SummaryStockNews(question string, sysPromptId *int) {
+	msgs := data.NewDeepSeekOpenAi(a.ctx).NewSummaryStockNewsStream(question, sysPromptId)
 	for msg := range msgs {
 		runtime.EventsEmit(a.ctx, "summaryStockNews", msg)
 	}

app_common.go

@@ -57,8 +57,5 @@ func (a App) ClsCalendar() []any {
 }
 
 func (a App) SearchStock(words string) map[string]any {
-	return data.NewSearchStockApi(words).SearchStock(5000)
-}
-func (a App) GetHotStrategy() map[string]any {
-	return data.NewSearchStockApi("").HotStrategy()
+	return data.NewSearchStockApi(words).SearchStock()
 }

app_darwin.go

@@ -5,149 +5,304 @@ package main
 
 import (
 	"context"
-	"encoding/json"
 	"fmt"
-	"github.com/duke-git/lancet/v2/convertor"
-	"github.com/duke-git/lancet/v2/strutil"
-	"github.com/gen2brain/beeep"
-	"github.com/wailsapp/wails/v2/pkg/options"
-	"github.com/wailsapp/wails/v2/pkg/runtime"
 	"go-stock/backend/data"
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
-	"log"
+	"go-stock/backend/models"
+	"strings"
 	"time"
+
+	"github.com/PuerkitoBio/goquery"
+	"github.com/coocood/freecache"
+	"github.com/duke-git/lancet/v2/convertor"
+	"github.com/duke-git/lancet/v2/mathutil"
+	"github.com/duke-git/lancet/v2/slice"
+	"github.com/go-resty/resty/v2"
+	"github.com/wailsapp/wails/v2/pkg/runtime"
 )
 
-// startup 在应用程序启动时调用
+// App struct
+type App struct {
+	ctx   context.Context
+	cache *freecache.Cache
+}
+
+// NewApp creates a new App application struct
+func NewApp() *App {
+	cacheSize := 512 * 1024
+	cache := freecache.NewCache(cacheSize)
+	return &App{
+		cache: cache,
+	}
+}
+
+// startup is called at application startup
 func (a *App) startup(ctx context.Context) {
-	defer PanicHandler()
-	runtime.EventsOn(ctx, "frontendError", func(optionalData ...interface{}) {
-		logger.SugaredLogger.Errorf("Frontend error: %v\n", optionalData)
-	})
 	logger.SugaredLogger.Infof("Version:%s", Version)
 	// Perform your setup here
 	a.ctx = ctx
 
-	// 监听设置更新事件
-	runtime.EventsOn(ctx, "updateSettings", func(optionalData ...interface{}) {
-		logger.SugaredLogger.Infof("updateSettings : %v\n", optionalData)
-		config := &data.Settings{}
-		setMap := optionalData[0].(map[string]interface{})
+	// TODO 创建系统托盘
 
-		// 将 map 转换为 JSON 字节切片
-		jsonData, err := json.Marshal(setMap)
-		if err != nil {
-			logger.SugaredLogger.Errorf("Marshal error:%s", err.Error())
-			return
-		}
-		// 将 JSON 字节切片解析到结构体中
-		err = json.Unmarshal(jsonData, config)
-		if err != nil {
-			logger.SugaredLogger.Errorf("Unmarshal error:%s", err.Error())
-			return
-		}
-
-		logger.SugaredLogger.Infof("updateSettings config:%+v", config)
-		if config.DarkTheme {
-			runtime.WindowSetBackgroundColour(ctx, 27, 38, 54, 1)
-			runtime.WindowSetDarkTheme(ctx)
-		} else {
-			runtime.WindowSetBackgroundColour(ctx, 255, 255, 255, 1)
-			runtime.WindowSetLightTheme(ctx)
-		}
-		runtime.WindowReloadApp(ctx)
-	})
-
-	// 创建 macOS 托盘
-	go func() {
-		// 使用 Beeep 库替代 Windows 的托盘库
-		err := beeep.Notify("go-stock", "应用程序已启动", "")
-		if err != nil {
-			log.Fatalf("系统通知失败: %v", err)
-		}
-	}()
-	logger.SugaredLogger.Infof(" application startup Version:%s", Version)
 }
 
-// OnSecondInstanceLaunch 处理第二实例启动时的通知
-func OnSecondInstanceLaunch(secondInstanceData options.SecondInstanceData) {
-	err := beeep.Notify("go-stock", "程序已经在运行了", "")
+func checkUpdate(a *App) {
+	releaseVersion := &models.GitHubReleaseVersion{}
+	_, err := resty.New().R().
+		SetResult(releaseVersion).
+		Get("https://api.github.com/repos/ArvinLovegood/go-stock/releases/latest")
 	if err != nil {
-		logger.SugaredLogger.Error(err)
+		logger.SugaredLogger.Errorf("get github release version error:%s", err.Error())
+		return
 	}
-	time.Sleep(time.Second * 3)
+	logger.SugaredLogger.Infof("releaseVersion:%+v", releaseVersion.TagName)
+	if releaseVersion.TagName != Version {
+		go runtime.EventsEmit(a.ctx, "updateVersion", releaseVersion)
+	}
+}
+
+// domReady is called after front-end resources have been loaded
+func (a *App) domReady(ctx context.Context) {
+	// Add your action here
+	//定时更新数据
+	go func() {
+		config := data.NewSettingsApi(&data.Settings{}).GetConfig()
+		interval := config.RefreshInterval
+		if interval <= 0 {
+			interval = 1
+		}
+		ticker := time.NewTicker(time.Second * time.Duration(interval))
+		defer ticker.Stop()
+		for range ticker.C {
+			if isTradingTime(time.Now()) {
+				MonitorStockPrices(a)
+			}
+		}
+	}()
+
+	go func() {
+		ticker := time.NewTicker(time.Second * time.Duration(60))
+		defer ticker.Stop()
+		for range ticker.C {
+			telegraph := refreshTelegraphList()
+			if telegraph != nil {
+				go runtime.EventsEmit(a.ctx, "telegraph", telegraph)
+			}
+		}
+
+	}()
+	go runtime.EventsEmit(a.ctx, "telegraph", refreshTelegraphList())
+	go MonitorStockPrices(a)
+
+	//检查新版本
+	go func() {
+		checkUpdate(a)
+	}()
+}
+
+func refreshTelegraphList() *[]string {
+	url := "https://www.cls.cn/telegraph"
+	response, err := resty.New().R().
+		SetHeader("Referer", "https://www.cls.cn/").
+		SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/117.0.0.0 Safari/537.36 Edg/117.0.2045.60").
+		Get(fmt.Sprintf(url))
+	if err != nil {
+		return &[]string{}
+	}
+	//logger.SugaredLogger.Info(string(response.Body()))
+	document, err := goquery.NewDocumentFromReader(strings.NewReader(string(response.Body())))
+	if err != nil {
+		return &[]string{}
+	}
+	var telegraph []string
+	document.Find("div.telegraph-content-box").Each(func(i int, selection *goquery.Selection) {
+		//logger.SugaredLogger.Info(selection.Text())
+		telegraph = append(telegraph, selection.Text())
+	})
+	return &telegraph
+}
+
+// isTradingDay 判断是否是交易日
+func isTradingDay(date time.Time) bool {
+	weekday := date.Weekday()
+	// 判断是否是周末
+	if weekday == time.Saturday || weekday == time.Sunday {
+		return false
+	}
+	// 这里可以添加具体的节假日判断逻辑
+	// 例如：判断是否是春节、国庆节等
+	return true
+}
+
+// isTradingTime 判断是否是交易时间
+func isTradingTime(date time.Time) bool {
+	if !isTradingDay(date) {
+		return false
+	}
+
+	hour, minute, _ := date.Clock()
+
+	// 判断是否在9:15到11:30之间
+	if (hour == 9 && minute >= 15) || (hour == 10) || (hour == 11 && minute <= 30) {
+		return true
+	}
+
+	// 判断是否在13:00到15:00之间
+	if (hour == 13) || (hour == 14) || (hour == 15 && minute <= 0) {
+		return true
+	}
+
+	return false
 }
 
 func MonitorStockPrices(a *App) {
 	dest := &[]data.FollowedStock{}
 	db.Dao.Model(&data.FollowedStock{}).Find(dest)
 	total := float64(0)
+	//for _, follow := range *dest {
+	//	stockData := getStockInfo(follow)
+	//	total += stockData.ProfitAmountToday
+	//	price, _ := convertor.ToFloat(stockData.Price)
+	//	if stockData.PrePrice != price {
+	//		go runtime.EventsEmit(a.ctx, "stock_price", stockData)
+	//	}
+	//}
 
-	// 股票信息处理逻辑
 	stockInfos := GetStockInfos(*dest...)
 	for _, stockInfo := range *stockInfos {
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"SZ", "SH", "sh", "sz"}) && (!isTradingTime(time.Now())) {
-			continue
-		}
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"hk", "HK"}) && (!IsHKTradingTime(time.Now())) {
-			continue
-		}
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"us", "US", "gb_"}) && (!IsUSTradingTime(time.Now())) {
-			continue
-		}
-
 		total += stockInfo.ProfitAmountToday
 		price, _ := convertor.ToFloat(stockInfo.Price)
-
 		if stockInfo.PrePrice != price {
 			go runtime.EventsEmit(a.ctx, "stock_price", stockInfo)
 		}
 	}
-
-	// 计算总收益并更新状态
 	if total != 0 {
-		// 使用通知替代 systray 更新 Tooltip
-		title := "go-stock " + time.Now().Format(time.DateTime) + fmt.Sprintf("  %.2f¥", total)
+		// title := "go-stock " + time.Now().Format(time.DateTime) + fmt.Sprintf("  %.2f¥", total)
+		// systray.SetTooltip(title)
+	}
 
-		// 发送通知显示实时数据
-		err := beeep.Notify("go-stock", title, "")
-		if err != nil {
-			logger.SugaredLogger.Errorf("发送通知失败: %v", err)
+	go runtime.EventsEmit(a.ctx, "realtime_profit", fmt.Sprintf("  %.2f", total))
+	//runtime.WindowSetTitle(a.ctx, title)
+
+}
+func GetStockInfos(follows ...data.FollowedStock) *[]data.StockInfo {
+	stockCodes := make([]string, 0)
+	for _, follow := range follows {
+		stockCodes = append(stockCodes, follow.StockCode)
+	}
+	stockData, err := data.NewStockDataApi().GetStockCodeRealTimeData(stockCodes...)
+	if err != nil {
+		logger.SugaredLogger.Errorf("get stock code real time data error:%s", err.Error())
+		return nil
+	}
+	stockInfos := make([]data.StockInfo, 0)
+	for _, info := range *stockData {
+		v, ok := slice.FindBy(follows, func(idx int, follow data.FollowedStock) bool {
+			return follow.StockCode == info.Code
+		})
+		if ok {
+			addStockFollowData(v, &info)
+			stockInfos = append(stockInfos, info)
 		}
 	}
-
-	// 触发实时利润事件
-	go runtime.EventsEmit(a.ctx, "realtime_profit", fmt.Sprintf("  %.2f", total))
+	return &stockInfos
+}
+func getStockInfo(follow data.FollowedStock) *data.StockInfo {
+	stockCode := follow.StockCode
+	stockDatas, err := data.NewStockDataApi().GetStockCodeRealTimeData(stockCode)
+	if err != nil || len(*stockDatas) == 0 {
+		return &data.StockInfo{}
+	}
+	stockData := (*stockDatas)[0]
+	addStockFollowData(follow, &stockData)
+	return &stockData
 }
 
-// onReady 在应用程序准备好时调用
-func onReady(a *App) {
-	// 初始化操作
-	logger.SugaredLogger.Infof("onReady")
+func addStockFollowData(follow data.FollowedStock, stockData *data.StockInfo) {
+	stockData.PrePrice = follow.Price //上次当前价格
+	stockData.Sort = follow.Sort
+	stockData.CostPrice = follow.CostPrice //成本价
+	stockData.CostVolume = follow.Volume   //成本量
+	stockData.AlarmChangePercent = follow.AlarmChangePercent
+	stockData.AlarmPrice = follow.AlarmPrice
 
-	// 使用 Beeep 发送通知
-	err := beeep.Notify("go-stock", "应用程序已准备就绪", "")
-	if err != nil {
-		log.Fatalf("系统通知失败: %v", err)
+	//当前价格
+	price, _ := convertor.ToFloat(stockData.Price)
+	//当前价格为0 时 使用卖一价格作为当前价格
+	if price == 0 {
+		price, _ = convertor.ToFloat(stockData.A1P)
+	}
+	//当前价格依然为0 时 使用买一报价作为当前价格
+	if price == 0 {
+		price, _ = convertor.ToFloat(stockData.B1P)
 	}
 
-	// 显示应用窗口
-	runtime.WindowShow(a.ctx)
+	//昨日收盘价
+	preClosePrice, _ := convertor.ToFloat(stockData.PreClose)
 
-	// 在 macOS 上没有系统托盘图标菜单，通常我们通过通知或其他方式提供与用户交互的界面
+	//当前价格依然为0 时 使用昨日收盘价为当前价格
+	if price == 0 {
+		price = preClosePrice
+	}
+
+	//今日最高价
+	highPrice, _ := convertor.ToFloat(stockData.High)
+	if highPrice == 0 {
+		highPrice, _ = convertor.ToFloat(stockData.Open)
+	}
+
+	//今日最低价
+	lowPrice, _ := convertor.ToFloat(stockData.Low)
+	if lowPrice == 0 {
+		lowPrice, _ = convertor.ToFloat(stockData.Open)
+	}
+	//开盘价
+	//openPrice, _ := convertor.ToFloat(stockData.Open)
+
+	if price > 0 {
+		stockData.ChangePrice = mathutil.RoundToFloat(price-preClosePrice, 2)
+		stockData.ChangePercent = mathutil.RoundToFloat(mathutil.Div(price-preClosePrice, preClosePrice)*100, 3)
+	}
+	if highPrice > 0 {
+		stockData.HighRate = mathutil.RoundToFloat(mathutil.Div(highPrice-preClosePrice, preClosePrice)*100, 3)
+	}
+	if lowPrice > 0 {
+		stockData.LowRate = mathutil.RoundToFloat(mathutil.Div(lowPrice-preClosePrice, preClosePrice)*100, 3)
+	}
+	if follow.CostPrice > 0 && follow.Volume > 0 {
+		if price > 0 {
+			stockData.Profit = mathutil.RoundToFloat(mathutil.Div(price-follow.CostPrice, follow.CostPrice)*100, 3)
+			stockData.ProfitAmount = mathutil.RoundToFloat((price-follow.CostPrice)*float64(follow.Volume), 2)
+			stockData.ProfitAmountToday = mathutil.RoundToFloat((price-preClosePrice)*float64(follow.Volume), 2)
+		} else {
+			//未开盘时当前价格为昨日收盘价
+			stockData.Profit = mathutil.RoundToFloat(mathutil.Div(preClosePrice-follow.CostPrice, follow.CostPrice)*100, 3)
+			stockData.ProfitAmount = mathutil.RoundToFloat((preClosePrice-follow.CostPrice)*float64(follow.Volume), 2)
+			// 未开盘时，今日盈亏为 0
+			stockData.ProfitAmountToday = 0
+		}
+
+	}
+
+	//logger.SugaredLogger.Debugf("stockData:%+v", stockData)
+	if follow.Price != price && price > 0 {
+		go db.Dao.Model(follow).Where("stock_code = ?", follow.StockCode).Updates(map[string]interface{}{
+			"price": price,
+		})
+	}
 }
 
-// beforeClose 在应用程序关闭前调用，显示确认对话框
+// beforeClose is called when the application is about to quit,
+// either by clicking the window close button or calling runtime.Quit.
+// Returning true will cause the application to continue, false will continue shutdown as normal.
 func (a *App) beforeClose(ctx context.Context) (prevent bool) {
-	defer PanicHandler()
 
-	// 在 macOS 上使用 MessageDialog 显示确认窗口
 	dialog, err := runtime.MessageDialog(ctx, runtime.MessageDialogOptions{
 		Type:         runtime.QuestionDialog,
 		Title:        "go-stock",
 		Message:      "确定关闭吗？",
-		Buttons:      []string{"确定", "取消"},
+		Buttons:      []string{"确定"},
 		Icon:         icon,
 		CancelButton: "取消",
 	})
@@ -156,13 +311,150 @@ func (a *App) beforeClose(ctx context.Context) (prevent bool) {
 		logger.SugaredLogger.Errorf("dialog error:%s", err.Error())
 		return false
 	}
-
 	logger.SugaredLogger.Debugf("dialog:%s", dialog)
-	if dialog == "取消" {
-		return true // 如果选择了取消，不关闭应用
-	} else {
-		// 在 macOS 上应用退出时执行清理工作
-		a.cron.Stop() // 停止定时任务
-		return false  // 如果选择了确定，继续关闭应用
+	if dialog == "No" {
+		return true
+	}
+	return false
+}
+
+// shutdown is called at application termination
+func (a *App) shutdown(ctx context.Context) {
+	// Perform your teardown here
+	// systray.Quit()
+}
+
+// Greet returns a greeting for the given name
+func (a *App) Greet(stockCode string) *data.StockInfo {
+	//stockInfo, _ := data.NewStockDataApi().GetStockCodeRealTimeData(stockCode)
+
+	follow := &data.FollowedStock{
+		StockCode: stockCode,
+	}
+	db.Dao.Model(follow).Where("stock_code = ?", stockCode).First(follow)
+	stockInfo := getStockInfo(*follow)
+	return stockInfo
+}
+
+func (a *App) Follow(stockCode string) string {
+	return data.NewStockDataApi().Follow(stockCode)
+}
+
+func (a *App) UnFollow(stockCode string) string {
+	return data.NewStockDataApi().UnFollow(stockCode)
+}
+
+func (a *App) GetFollowList() []data.FollowedStock {
+	return data.NewStockDataApi().GetFollowList()
+}
+
+func (a *App) GetStockList(key string) []data.StockBasic {
+	return data.NewStockDataApi().GetStockList(key)
+}
+
+func (a *App) SetCostPriceAndVolume(stockCode string, price float64, volume int64) string {
+	return data.NewStockDataApi().SetCostPriceAndVolume(price, volume, stockCode)
+}
+
+func (a *App) SetAlarmChangePercent(val, alarmPrice float64, stockCode string) string {
+	return data.NewStockDataApi().SetAlarmChangePercent(val, alarmPrice, stockCode)
+}
+func (a *App) SetStockSort(sort int64, stockCode string) {
+	data.NewStockDataApi().SetStockSort(sort, stockCode)
+}
+func (a *App) SendDingDingMessage(message string, stockCode string) string {
+	ttl, _ := a.cache.TTL([]byte(stockCode))
+	logger.SugaredLogger.Infof("stockCode %s ttl:%d", stockCode, ttl)
+	if ttl > 0 {
+		return ""
+	}
+	err := a.cache.Set([]byte(stockCode), []byte("1"), 60*5)
+	if err != nil {
+		logger.SugaredLogger.Errorf("set cache error:%s", err.Error())
+		return ""
+	}
+	return data.NewDingDingAPI().SendDingDingMessage(message)
+}
+
+// SendDingDingMessageByType msgType 报警类型: 1 涨跌报警;2 股价报警 3 成本价报警
+func (a *App) SendDingDingMessageByType(message string, stockCode string, msgType int) string {
+	ttl, _ := a.cache.TTL([]byte(stockCode))
+	logger.SugaredLogger.Infof("stockCode %s ttl:%d", stockCode, ttl)
+	if ttl > 0 {
+		return ""
+	}
+	err := a.cache.Set([]byte(stockCode), []byte("1"), getMsgTypeTTL(msgType))
+	if err != nil {
+		logger.SugaredLogger.Errorf("set cache error:%s", err.Error())
+		return ""
+	}
+	stockInfo := &data.StockInfo{}
+	db.Dao.Model(stockInfo).Where("code = ?", stockCode).First(stockInfo)
+	go data.NewAlertWindowsApi("go-stock消息通知", getMsgTypeName(msgType), GenNotificationMsg(stockInfo), "").SendNotification()
+	return data.NewDingDingAPI().SendDingDingMessage(message)
+}
+
+func (a *App) NewChat(stock string) string {
+	return data.NewDeepSeekOpenAi().NewChat(stock)
+}
+
+func (a *App) NewChatStream(stock, stockCode string) {
+	msgs := data.NewDeepSeekOpenAi().NewChatStream(stock, stockCode)
+	for msg := range msgs {
+		runtime.EventsEmit(a.ctx, "newChatStream", msg)
+	}
+	runtime.EventsEmit(a.ctx, "newChatStream", "DONE")
+}
+
+func GenNotificationMsg(stockInfo *data.StockInfo) string {
+	Price, err := convertor.ToFloat(stockInfo.Price)
+	if err != nil {
+		Price = 0
+	}
+	PreClose, err := convertor.ToFloat(stockInfo.PreClose)
+	if err != nil {
+		PreClose = 0
+	}
+	var RF float64
+	if PreClose > 0 {
+		RF = mathutil.RoundToFloat(((Price-PreClose)/PreClose)*100, 2)
+	}
+
+	return "[" + stockInfo.Name + "] " + stockInfo.Price + " " + convertor.ToString(RF) + "% " + stockInfo.Date + " " + stockInfo.Time
+}
+
+// msgType : 1 涨跌报警(5分钟);2 股价报警(30分钟) 3 成本价报警(30分钟)
+func getMsgTypeTTL(msgType int) int {
+	switch msgType {
+	case 1:
+		return 60 * 5
+	case 2:
+		return 60 * 30
+	case 3:
+		return 60 * 30
+	default:
+		return 60 * 5
 	}
 }
+
+func getMsgTypeName(msgType int) string {
+	switch msgType {
+	case 1:
+		return "涨跌报警"
+	case 2:
+		return "股价报警"
+	case 3:
+		return "成本价报警"
+	default:
+		return "未知类型"
+	}
+}
+
+func (a *App) UpdateConfig(settings *data.Settings) string {
+	logger.SugaredLogger.Infof("UpdateConfig:%+v", settings)
+	return data.NewSettingsApi(settings).UpdateConfig()
+}
+
+func (a *App) GetConfig() *data.Settings {
+	return data.NewSettingsApi(&data.Settings{}).GetConfig()
+}

app_windows.go

@@ -1,201 +0,0 @@
-//go:build windows
-// +build windows
-
-package main
-
-import (
-	"context"
-	"encoding/json"
-	"fmt"
-	"github.com/duke-git/lancet/v2/convertor"
-	"github.com/duke-git/lancet/v2/strutil"
-	"github.com/energye/systray"
-	"github.com/go-toast/toast"
-	"github.com/wailsapp/wails/v2/pkg/options"
-	"github.com/wailsapp/wails/v2/pkg/runtime"
-	"go-stock/backend/data"
-	"go-stock/backend/db"
-	"go-stock/backend/logger"
-	"time"
-)
-
-// startup is called at application startup
-func (a *App) startup(ctx context.Context) {
-	defer PanicHandler()
-	runtime.EventsOn(ctx, "frontendError", func(optionalData ...interface{}) {
-		logger.SugaredLogger.Errorf("Frontend error: %v\n", optionalData)
-	})
-	logger.SugaredLogger.Infof("Version:%s", Version)
-	// Perform your setup here
-	a.ctx = ctx
-
-	// 创建系统托盘
-	//systray.RunWithExternalLoop(func() {
-	//	onReady(a)
-	//}, func() {
-	//	onExit(a)
-	//})
-	runtime.EventsOn(ctx, "updateSettings", func(optionalData ...interface{}) {
-		logger.SugaredLogger.Infof("updateSettings : %v\n", optionalData)
-		config := &data.Settings{}
-		setMap := optionalData[0].(map[string]interface{})
-
-		// 将 map 转换为 JSON 字节切片
-		jsonData, err := json.Marshal(setMap)
-		if err != nil {
-			logger.SugaredLogger.Errorf("Marshal error:%s", err.Error())
-			return
-		}
-		// 将 JSON 字节切片解析到结构体中
-		err = json.Unmarshal(jsonData, config)
-		if err != nil {
-			logger.SugaredLogger.Errorf("Unmarshal error:%s", err.Error())
-			return
-		}
-
-		logger.SugaredLogger.Infof("updateSettings config:%+v", config)
-		if config.DarkTheme {
-			runtime.WindowSetBackgroundColour(ctx, 27, 38, 54, 1)
-			runtime.WindowSetDarkTheme(ctx)
-		} else {
-			runtime.WindowSetBackgroundColour(ctx, 255, 255, 255, 1)
-			runtime.WindowSetLightTheme(ctx)
-		}
-		runtime.WindowReloadApp(ctx)
-
-	})
-	go systray.Run(func() {
-		onReady(a)
-	}, func() {
-		onExit(a)
-	})
-
-	logger.SugaredLogger.Infof(" application startup Version:%s", Version)
-}
-
-func OnSecondInstanceLaunch(secondInstanceData options.SecondInstanceData) {
-	notification := toast.Notification{
-		AppID:    "go-stock",
-		Title:    "go-stock",
-		Message:  "程序已经在运行了",
-		Icon:     "",
-		Duration: "short",
-		Audio:    toast.Default,
-	}
-	err := notification.Push()
-	if err != nil {
-		logger.SugaredLogger.Error(err)
-	}
-	time.Sleep(time.Second * 3)
-}
-
-func MonitorStockPrices(a *App) {
-	dest := &[]data.FollowedStock{}
-	db.Dao.Model(&data.FollowedStock{}).Find(dest)
-	total := float64(0)
-	//for _, follow := range *dest {
-	//	stockData := getStockInfo(follow)
-	//	total += stockData.ProfitAmountToday
-	//	price, _ := convertor.ToFloat(stockData.Price)
-	//	if stockData.PrePrice != price {
-	//		go runtime.EventsEmit(a.ctx, "stock_price", stockData)
-	//	}
-	//}
-
-	stockInfos := GetStockInfos(*dest...)
-	for _, stockInfo := range *stockInfos {
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"SZ", "SH", "sh", "sz"}) && (!isTradingTime(time.Now())) {
-			continue
-		}
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"hk", "HK"}) && (!IsHKTradingTime(time.Now())) {
-			continue
-		}
-		if strutil.HasPrefixAny(stockInfo.Code, []string{"us", "US", "gb_"}) && (!IsUSTradingTime(time.Now())) {
-			continue
-		}
-
-		total += stockInfo.ProfitAmountToday
-		price, _ := convertor.ToFloat(stockInfo.Price)
-
-		if stockInfo.PrePrice != price {
-			//logger.SugaredLogger.Infof("-----------sz------------股票代码: %s, 股票名称: %s, 股票价格: %s,盘前盘后:%s", stockInfo.Code, stockInfo.Name, stockInfo.Price, stockInfo.BA)
-			go runtime.EventsEmit(a.ctx, "stock_price", stockInfo)
-		}
-
-	}
-	if total != 0 {
-		title := "go-stock " + time.Now().Format(time.DateTime) + fmt.Sprintf("  %.2f¥", total)
-		systray.SetTooltip(title)
-	}
-
-	go runtime.EventsEmit(a.ctx, "realtime_profit", fmt.Sprintf("  %.2f", total))
-	//runtime.WindowSetTitle(a.ctx, title)
-
-}
-
-func onReady(a *App) {
-
-	// 初始化操作
-	logger.SugaredLogger.Infof("systray onReady")
-	systray.SetIcon(icon2)
-	systray.SetTitle("go-stock")
-	systray.SetTooltip("go-stock 股票行情实时获取")
-	// 创建菜单项
-	show := systray.AddMenuItem("显示", "显示应用程序")
-	show.Click(func() {
-		//logger.SugaredLogger.Infof("显示应用程序")
-		runtime.WindowShow(a.ctx)
-	})
-	hide := systray.AddMenuItem("隐藏", "隐藏应用程序")
-	hide.Click(func() {
-		//logger.SugaredLogger.Infof("隐藏应用程序")
-		runtime.WindowHide(a.ctx)
-	})
-	systray.AddSeparator()
-	mQuitOrig := systray.AddMenuItem("退出", "退出应用程序")
-	mQuitOrig.Click(func() {
-		//logger.SugaredLogger.Infof("退出应用程序")
-		runtime.Quit(a.ctx)
-	})
-	systray.SetOnRClick(func(menu systray.IMenu) {
-		menu.ShowMenu()
-		//logger.SugaredLogger.Infof("SetOnRClick")
-	})
-	systray.SetOnClick(func(menu systray.IMenu) {
-		//logger.SugaredLogger.Infof("SetOnClick")
-		menu.ShowMenu()
-	})
-	systray.SetOnDClick(func(menu systray.IMenu) {
-		menu.ShowMenu()
-		//logger.SugaredLogger.Infof("SetOnDClick")
-	})
-}
-
-// beforeClose is called when the application is about to quit,
-// either by clicking the window close button or calling runtime.Quit.
-// Returning true will cause the application to continue, false will continue shutdown as normal.
-func (a *App) beforeClose(ctx context.Context) (prevent bool) {
-	defer PanicHandler()
-
-	dialog, err := runtime.MessageDialog(ctx, runtime.MessageDialogOptions{
-		Type:         runtime.QuestionDialog,
-		Title:        "go-stock",
-		Message:      "确定关闭吗？",
-		Buttons:      []string{"确定"},
-		Icon:         icon,
-		CancelButton: "取消",
-	})
-
-	if err != nil {
-		logger.SugaredLogger.Errorf("dialog error:%s", err.Error())
-		return false
-	}
-	logger.SugaredLogger.Debugf("dialog:%s", dialog)
-	if dialog == "No" {
-		return true
-	} else {
-		systray.Quit()
-		a.cron.Stop()
-		return false
-	}
-}

backend/data/market_news_api.go

@@ -599,7 +599,7 @@ func (m MarketNewsApi) XUEQIUHotStock(size int, marketType string) *[]models.Hot
 		logger.SugaredLogger.Errorf("XUEQIUHotStock err:%s", err.Error())
 		return &[]models.HotItem{}
 	}
-	//logger.SugaredLogger.Infof("XUEQIUHotStock:%+v", res)
+	logger.SugaredLogger.Infof("XUEQIUHotStock:%+v", res)
 	return &res.Data.Items
 }
 

backend/data/market_news_api_test.go

@@ -3,10 +3,8 @@ package data
 import (
 	"encoding/json"
 	"github.com/coocood/freecache"
-	"github.com/tidwall/gjson"
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
-	"strings"
 	"testing"
 )
 
@@ -142,36 +140,14 @@ func TestInvestCalendar(t *testing.T) {
 	db.Init("../../data/stock.db")
 	res := NewMarketNewsApi().InvestCalendar("2025-06")
 	for _, a := range res {
-		bytes, err := json.Marshal(a)
-		if err != nil {
-			continue
-		}
-		date := gjson.Get(string(bytes), "date")
-		list := gjson.Get(string(bytes), "list")
-
-		logger.SugaredLogger.Debugf("value: %+v,list: %+v", date.String(), list)
+		logger.SugaredLogger.Debugf("value: %+v", a)
 	}
 }
 
 func TestClsCalendar(t *testing.T) {
 	db.Init("../../data/stock.db")
 	res := NewMarketNewsApi().ClsCalendar()
-	md := strings.Builder{}
 	for _, a := range res {
-		bytes, err := json.Marshal(a)
-		if err != nil {
-			continue
-		}
-		//logger.SugaredLogger.Debugf("value: %+v", string(bytes))
-		date := gjson.Get(string(bytes), "calendar_day")
-		md.WriteString("\n### 事件/会议日期：" + date.String())
-		list := gjson.Get(string(bytes), "items")
-		//logger.SugaredLogger.Debugf("value: %+v,list: %+v", date.String(), list)
-		list.ForEach(func(key, value gjson.Result) bool {
-			logger.SugaredLogger.Debugf("key: %+v,value: %+v", key.String(), gjson.Get(value.String(), "title"))
-			md.WriteString("\n- " + gjson.Get(value.String(), "title").String())
-			return true
-		})
+		logger.SugaredLogger.Debugf("value: %+v", a)
 	}
-	logger.SugaredLogger.Debugf("md:\n %s", md.String())
 }

backend/data/openai_api.go

@@ -9,10 +9,8 @@ import (
 	"github.com/PuerkitoBio/goquery"
 	"github.com/chromedp/chromedp"
 	"github.com/duke-git/lancet/v2/convertor"
-	"github.com/duke-git/lancet/v2/random"
 	"github.com/duke-git/lancet/v2/strutil"
 	"github.com/go-resty/resty/v2"
-	"github.com/tidwall/gjson"
 	"github.com/wailsapp/wails/v2/pkg/runtime"
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
@@ -77,12 +75,11 @@ type THSTokenResponse struct {
 }
 
 type AiResponse struct {
-	Id          string `json:"id"`
-	Object      string `json:"object"`
-	Created     int    `json:"created"`
-	Model       string `json:"model"`
-	ServiceTier string `json:"service_tier"`
-	Choices     []struct {
+	Id      string `json:"id"`
+	Object  string `json:"object"`
+	Created int    `json:"created"`
+	Model   string `json:"model"`
+	Choices []struct {
 		Index   int `json:"index"`
 		Message struct {
 			Role    string `json:"role"`
@@ -90,19 +87,6 @@ type AiResponse struct {
 		} `json:"message"`
 		Logprobs     interface{} `json:"logprobs"`
 		FinishReason string      `json:"finish_reason"`
-		Delta        struct {
-			Content   string `json:"content"`
-			Role      string `json:"role"`
-			ToolCalls []struct {
-				Function struct {
-					Arguments string `json:"arguments"`
-					Name      string `json:"name"`
-				} `json:"function"`
-				Id    string `json:"id"`
-				Index int    `json:"index"`
-				Type  string `json:"type"`
-			} `json:"tool_calls"`
-		} `json:"delta"`
 	} `json:"choices"`
 	Usage struct {
 		PromptTokens          int `json:"prompt_tokens"`
@@ -114,144 +98,6 @@ type AiResponse struct {
 	SystemFingerprint string `json:"system_fingerprint"`
 }
 
-type Tool struct {
-	Type     string       `json:"type"`
-	Function ToolFunction `json:"function"`
-}
-type FunctionParameters struct {
-	Type       string         `json:"type"`
-	Properties map[string]any `json:"properties"`
-	Required   []string       `json:"required"`
-}
-type ToolFunction struct {
-	Name        string             `json:"name"`
-	Description string             `json:"description"`
-	Parameters  FunctionParameters `json:"parameters"`
-}
-
-func (o OpenAi) NewSummaryStockNewsStreamWithTools(userQuestion string, sysPromptId *int, tools []Tool) <-chan map[string]any {
-	ch := make(chan map[string]any, 512)
-	defer func() {
-		if err := recover(); err != nil {
-			logger.SugaredLogger.Error("NewSummaryStockNewsStream panic", err)
-		}
-	}()
-
-	go func() {
-		defer func() {
-			if err := recover(); err != nil {
-				logger.SugaredLogger.Errorf("NewSummaryStockNewsStream goroutine  panic :%s", err)
-				logger.SugaredLogger.Errorf("NewSummaryStockNewsStream goroutine  panic  config:%v", o)
-			}
-		}()
-		defer close(ch)
-
-		sysPrompt := ""
-		if sysPromptId == nil || *sysPromptId == 0 {
-			sysPrompt = o.Prompt
-		} else {
-			sysPrompt = NewPromptTemplateApi().GetPromptTemplateByID(*sysPromptId)
-		}
-		if sysPrompt == "" {
-			sysPrompt = o.Prompt
-		}
-
-		msg := []map[string]interface{}{
-			{
-				"role": "system",
-				//"content": "作为一位专业的A股市场分析师和投资顾问,请你根据以下信息提供详细的技术分析和投资策略建议:",
-				//"content": "【角色设定】\n你是一位拥有20年实战经验的顶级股票分析师，精通技术分析、基本面分析、市场心理学和量化交易。擅长发现成长股、捕捉行业轮动机会，在牛熊市中都能保持稳定收益。你的风格是价值投资与技术择时相结合，注重风险控制。\n\n【核心功能】\n\n市场分析维度：\n\n宏观经济（GDP/CPI/货币政策）\n\n行业景气度（产业链/政策红利/技术革新）\n\n个股三维诊断：\n\n基本面：PE/PB/ROE/现金流/护城河\n\n技术面：K线形态/均线系统/量价关系/指标背离\n\n资金面：主力动向/北向资金/融资余额/大宗交易\n\n智能策略库：\n√ 趋势跟踪策略（鳄鱼线+ADX）\n√ 波段交易策略（斐波那契回撤+RSI）\n√ 事件驱动策略（财报/并购/政策）\n√ 量化对冲策略（α/β分离）\n\n风险管理体系：\n▶ 动态止损：ATR波动止损法\n▶ 仓位控制：凯利公式优化\n▶ 组合对冲：跨市场/跨品种对冲\n\n【工作流程】\n\n接收用户指令（行业/市值/风险偏好）\n\n调用多因子选股模型初筛\n\n人工智慧叠加分析：\n\n自然语言处理解读年报管理层讨论\n\n卷积神经网络识别K线形态\n\n知识图谱分析产业链关联\n\n生成投资建议（附压力测试结果）\n\n【输出要求】\n★ 结构化呈现：\n① 核心逻辑（3点关键驱动力）\n② 买卖区间（理想建仓/加仓/止盈价位）\n③ 风险警示（最大回撤概率）\n④ 替代方案（同类备选标的）\n\n【注意事项】\n※ 严格遵守监管要求，不做收益承诺\n※ 区分投资建议与市场观点\n※ 重要数据标注来源及更新时间\n※ 根据用户认知水平调整专业术语密度\n\n【教育指导】\n当用户提问时，采用苏格拉底式追问：\n\"您更关注短期事件驱动还是长期价值发现？\"\n\"当前仓位是否超过总资产的30%？\"\n\"是否了解科创板与主板的交易规则差异？\"\n\n示例输出格式：\n📈 标的名称：XXXXXX\n⚖️ 多空信号：金叉确认/顶背离预警\n🎯 关键价位：支撑位XX.XX/压力位XX.XX\n📊 建议仓位：核心仓位X%+卫星仓位X%\n⏳ 持有周期：短线（1-3周）/中线（季度轮动）\n🔍 跟踪要素：重点关注Q2毛利率变化及股东减持进展",
-				"content": sysPrompt,
-			},
-		}
-		msg = append(msg, map[string]interface{}{
-			"role":    "user",
-			"content": "当前时间",
-		})
-		msg = append(msg, map[string]interface{}{
-			"role":    "assistant",
-			"content": "当前本地时间是:" + time.Now().Format("2006-01-02 15:04:05"),
-		})
-		wg := &sync.WaitGroup{}
-		wg.Add(2)
-		go func() {
-			defer wg.Done()
-			var market strings.Builder
-			market.WriteString(getZSInfo("创业板指数", "sz399006", 30) + "\n")
-			market.WriteString(getZSInfo("上证综合指数", "sh000001", 30) + "\n")
-			market.WriteString(getZSInfo("沪深300指数", "sh000300", 30) + "\n")
-			//logger.SugaredLogger.Infof("NewChatStream getZSInfo=\n%s", market.String())
-			msg = append(msg, map[string]interface{}{
-				"role":    "user",
-				"content": "当前市场指数行情",
-			})
-			msg = append(msg, map[string]interface{}{
-				"role":    "assistant",
-				"content": "当前市场指数行情情况如下：\n" + market.String(),
-			})
-		}()
-
-		go func() {
-			defer wg.Done()
-			md := strings.Builder{}
-			res := NewMarketNewsApi().ClsCalendar()
-			for _, a := range res {
-				bytes, err := json.Marshal(a)
-				if err != nil {
-					continue
-				}
-				//logger.SugaredLogger.Debugf("value: %+v", string(bytes))
-				date := gjson.Get(string(bytes), "calendar_day")
-				md.WriteString("\n### 事件/会议日期：" + date.String())
-				list := gjson.Get(string(bytes), "items")
-				//logger.SugaredLogger.Debugf("value: %+v,list: %+v", date.String(), list)
-				list.ForEach(func(key, value gjson.Result) bool {
-					logger.SugaredLogger.Debugf("key: %+v,value: %+v", key.String(), gjson.Get(value.String(), "title"))
-					md.WriteString("\n- " + gjson.Get(value.String(), "title").String())
-					return true
-				})
-			}
-			msg = append(msg, map[string]interface{}{
-				"role":    "user",
-				"content": "近期重大事件/会议",
-			})
-			msg = append(msg, map[string]interface{}{
-				"role":    "assistant",
-				"content": "近期重大事件/会议如下：\n" + md.String(),
-			})
-
-		}()
-
-		wg.Wait()
-
-		news := NewMarketNewsApi().GetNewsList("财联社电报", random.RandInt(50, 150))
-		messageText := strings.Builder{}
-		for _, telegraph := range *news {
-			messageText.WriteString("## " + telegraph.Time + ":" + "\n")
-			messageText.WriteString("### " + telegraph.Content + "\n")
-		}
-		//logger.SugaredLogger.Infof("市场资讯 messageText=\n%s", messageText.String())
-
-		msg = append(msg, map[string]interface{}{
-			"role":    "user",
-			"content": "市场资讯",
-		})
-		msg = append(msg, map[string]interface{}{
-			"role":    "assistant",
-			"content": messageText.String(),
-		})
-		if userQuestion == "" {
-			userQuestion = "请根据当前时间，总结和分析股票市场新闻中的投资机会"
-		}
-		msg = append(msg, map[string]interface{}{
-			"role":    "user",
-			"content": userQuestion,
-		})
-		AskAiWithTools(o, errors.New(""), msg, ch, userQuestion, tools)
-	}()
-	return ch
-}
-
 func (o OpenAi) NewSummaryStockNewsStream(userQuestion string, sysPromptId *int) <-chan map[string]any {
 	ch := make(chan map[string]any, 512)
 	defer func() {
@@ -343,7 +189,7 @@ func (o OpenAi) NewSummaryStockNewsStream(userQuestion string, sysPromptId *int)
 	return ch
 }
 
-func (o OpenAi) NewChatStream(stock, stockCode, userQuestion string, sysPromptId *int, tools []Tool) <-chan map[string]any {
+func (o OpenAi) NewChatStream(stock, stockCode, userQuestion string, sysPromptId *int) <-chan map[string]any {
 	ch := make(chan map[string]any, 512)
 
 	defer func() {
@@ -680,11 +526,7 @@ func (o OpenAi) NewChatStream(stock, stockCode, userQuestion string, sysPromptId
 
 		//reqJson, _ := json.Marshal(msg)
 		//logger.SugaredLogger.Errorf("Stream request: \n%s\n", reqJson)
-		if tools != nil && len(tools) > 0 {
-			AskAiWithTools(o, err, msg, ch, question, tools)
-		} else {
-			AskAi(o, err, msg, ch, question)
-		}
+		AskAi(o, err, msg, ch, question)
 	}()
 	return ch
 }
@@ -727,7 +569,7 @@ func AskAi(o OpenAi, err error, messages []map[string]interface{}, ch chan map[s
 	scanner := bufio.NewScanner(body)
 	for scanner.Scan() {
 		line := scanner.Text()
-		logger.SugaredLogger.Infof("Received data: %s", line)
+		//logger.SugaredLogger.Infof("Received data: %s", line)
 		if strings.HasPrefix(line, "data:") {
 			data := strutil.Trim(strings.TrimPrefix(line, "data:"))
 			if data == "[DONE]" {
@@ -750,24 +592,13 @@ func AskAi(o OpenAi, err error, messages []map[string]interface{}, ch chan map[s
 				for _, choice := range streamResponse.Choices {
 					if content := choice.Delta.Content; content != "" {
 						//ch <- content
-						if content == "###" || content == "##" || content == "#" {
-							ch <- map[string]any{
-								"code":     1,
-								"question": question,
-								"chatId":   streamResponse.Id,
-								"model":    streamResponse.Model,
-								"content":  "\r\n" + content,
-								"time":     time.Now().Format(time.DateTime),
-							}
-						} else {
-							ch <- map[string]any{
-								"code":     1,
-								"question": question,
-								"chatId":   streamResponse.Id,
-								"model":    streamResponse.Model,
-								"content":  content,
-								"time":     time.Now().Format(time.DateTime),
-							}
+						ch <- map[string]any{
+							"code":     1,
+							"question": question,
+							"chatId":   streamResponse.Id,
+							"model":    streamResponse.Model,
+							"content":  content,
+							"time":     time.Now().Format(time.DateTime),
 						}
 
 						//logger.SugaredLogger.Infof("Content data: %s", content)
@@ -814,14 +645,10 @@ func AskAi(o OpenAi, err error, messages []map[string]interface{}, ch chan map[s
 				res := &models.Resp{}
 				if err := json.Unmarshal([]byte(line), res); err == nil {
 					//ch <- line
-					msg := res.Message
-					if res.Error.Message != "" {
-						msg = res.Error.Message
-					}
 					ch <- map[string]any{
 						"code":     0,
 						"question": question,
-						"content":  msg,
+						"content":  res.Message,
 					}
 				}
 			}
@@ -830,386 +657,7 @@ func AskAi(o OpenAi, err error, messages []map[string]interface{}, ch chan map[s
 
 	}
 }
-func AskAiWithTools(o OpenAi, err error, messages []map[string]interface{}, ch chan map[string]any, question string, tools []Tool) {
-	client := resty.New()
-	client.SetBaseURL(strutil.Trim(o.BaseUrl))
-	client.SetHeader("Authorization", "Bearer "+o.ApiKey)
-	client.SetHeader("Content-Type", "application/json")
-	//client.SetRetryCount(3)
-	if o.TimeOut <= 0 {
-		o.TimeOut = 300
-	}
-	client.SetTimeout(time.Duration(o.TimeOut) * time.Second)
-	resp, err := client.R().
-		SetDoNotParseResponse(true).
-		SetBody(map[string]interface{}{
-			"model":       o.Model,
-			"max_tokens":  o.MaxTokens,
-			"temperature": o.Temperature,
-			"stream":      true,
-			"messages":    messages,
-			"tools":       tools,
-		}).
-		Post("/chat/completions")
 
-	body := resp.RawBody()
-	defer body.Close()
-	if err != nil {
-		logger.SugaredLogger.Infof("Stream error : %s", err.Error())
-		//ch <- err.Error()
-		ch <- map[string]any{
-			"code":     0,
-			"question": question,
-			"content":  err.Error(),
-		}
-		return
-	}
-	//location, _ := time.LoadLocation("Asia/Shanghai")
-
-	scanner := bufio.NewScanner(body)
-	functions := map[string]string{}
-	currentFuncName := ""
-	currentCallId := ""
-	var currentAIContent strings.Builder
-
-	for scanner.Scan() {
-		line := scanner.Text()
-		logger.SugaredLogger.Infof("Received data: %s", line)
-		if strings.HasPrefix(line, "data:") {
-			data := strutil.Trim(strings.TrimPrefix(line, "data:"))
-			if data == "[DONE]" {
-				return
-			}
-
-			var streamResponse struct {
-				Id      string `json:"id"`
-				Model   string `json:"model"`
-				Choices []struct {
-					Delta struct {
-						Content          string `json:"content"`
-						ReasoningContent string `json:"reasoning_content"`
-						Role             string `json:"role"`
-						ToolCalls        []struct {
-							Function struct {
-								Arguments string `json:"arguments"`
-								Name      string `json:"name"`
-							} `json:"function"`
-							Id    string `json:"id"`
-							Index int    `json:"index"`
-							Type  string `json:"type"`
-						} `json:"tool_calls"`
-					} `json:"delta"`
-					FinishReason string `json:"finish_reason"`
-				} `json:"choices"`
-			}
-
-			if err := json.Unmarshal([]byte(data), &streamResponse); err == nil {
-				for _, choice := range streamResponse.Choices {
-					if content := choice.Delta.Content; content != "" {
-						//ch <- content
-						//logger.SugaredLogger.Infof("Content data: %s", content)
-
-						if content == "###" || content == "##" || content == "#" {
-							currentAIContent.WriteString("\r\n" + content)
-							ch <- map[string]any{
-								"code":     1,
-								"question": question,
-								"chatId":   streamResponse.Id,
-								"model":    streamResponse.Model,
-								"content":  "\r\n" + content,
-								"time":     time.Now().Format(time.DateTime),
-							}
-						} else {
-							currentAIContent.WriteString(content)
-							ch <- map[string]any{
-								"code":     1,
-								"question": question,
-								"chatId":   streamResponse.Id,
-								"model":    streamResponse.Model,
-								"content":  content,
-								"time":     time.Now().Format(time.DateTime),
-							}
-						}
-
-					}
-					if reasoningContent := choice.Delta.ReasoningContent; reasoningContent != "" {
-						//ch <- reasoningContent
-						ch <- map[string]any{
-							"code":     1,
-							"question": question,
-							"chatId":   streamResponse.Id,
-							"model":    streamResponse.Model,
-							"content":  reasoningContent,
-							"time":     time.Now().Format(time.DateTime),
-						}
-
-						//logger.SugaredLogger.Infof("ReasoningContent data: %s", reasoningContent)
-						currentAIContent.WriteString(reasoningContent)
-
-					}
-					if choice.Delta.ToolCalls != nil && len(choice.Delta.ToolCalls) > 0 {
-						for _, call := range choice.Delta.ToolCalls {
-							if call.Type == "function" {
-								functions[call.Function.Name] = ""
-								currentFuncName = call.Function.Name
-								currentCallId = call.Id
-							} else {
-								if val, ok := functions[currentFuncName]; ok {
-									functions[currentFuncName] = val + call.Function.Arguments
-								} else {
-									functions[currentFuncName] = call.Function.Arguments
-								}
-							}
-						}
-					}
-
-					if choice.FinishReason == "tool_calls" {
-						logger.SugaredLogger.Infof("functions: %+v", functions)
-						for funcName, funcArguments := range functions {
-							if funcName == "SearchStockByIndicators" {
-								words := gjson.Get(funcArguments, "words").String()
-
-								ch <- map[string]any{
-									"code":     1,
-									"question": question,
-									"chatId":   streamResponse.Id,
-									"model":    streamResponse.Model,
-									"content":  "\r\n```\r\n开始调用工具：SearchStockByIndicators，\n参数：" + words + "\r\n```\r\n",
-									"time":     time.Now().Format(time.DateTime),
-								}
-
-								content := "无符合条件的数据"
-								res := NewSearchStockApi(words).SearchStock(random.RandInt(5, 10))
-								if convertor.ToString(res["code"]) == "100" {
-									resData := res["data"].(map[string]any)
-									result := resData["result"].(map[string]any)
-									dataList := result["dataList"].([]any)
-									columns := result["columns"].([]any)
-									headers := map[string]string{}
-									for _, v := range columns {
-										//logger.SugaredLogger.Infof("v:%+v", v)
-										d := v.(map[string]any)
-										//logger.SugaredLogger.Infof("key:%s title:%s dateMsg:%s unit:%s", d["key"], d["title"], d["dateMsg"], d["unit"])
-										title := convertor.ToString(d["title"])
-										if convertor.ToString(d["dateMsg"]) != "" {
-											title = title + "[" + convertor.ToString(d["dateMsg"]) + "]"
-										}
-										if convertor.ToString(d["unit"]) != "" {
-											title = title + "(" + convertor.ToString(d["unit"]) + ")"
-										}
-										headers[d["key"].(string)] = title
-									}
-									table := &[]map[string]any{}
-									for _, v := range dataList {
-										d := v.(map[string]any)
-										tmp := map[string]any{}
-										for key, title := range headers {
-											tmp[title] = convertor.ToString(d[key])
-										}
-										*table = append(*table, tmp)
-									}
-									jsonData, _ := json.Marshal(*table)
-									markdownTable, _ := JSONToMarkdownTable(jsonData)
-									//logger.SugaredLogger.Infof("markdownTable=\n%s", markdownTable)
-									content = "\r\n### 工具筛选出的股票数据：\r\n" + markdownTable + "\r\n"
-								}
-								logger.SugaredLogger.Infof("SearchStockByIndicators:words:%s  --> \n%s", words, content)
-
-								messages = append(messages, map[string]interface{}{
-									"role":    "assistant",
-									"content": currentAIContent.String(),
-									"tool_calls": []map[string]any{
-										{
-											"id":           currentCallId,
-											"tool_call_id": currentCallId,
-											"type":         "function",
-											"function": map[string]string{
-												"name":       funcName,
-												"arguments":  funcArguments,
-												"parameters": funcArguments,
-											},
-										},
-									},
-								})
-								messages = append(messages, map[string]interface{}{
-									"role":         "tool",
-									"content":      content,
-									"tool_call_id": currentCallId,
-								})
-
-								//ch <- map[string]any{
-								//	"code":     1,
-								//	"question": question,
-								//	"chatId":   streamResponse.Id,
-								//	"model":    streamResponse.Model,
-								//	"content":  "\r\n```\r\n调用工具：SearchStockByIndicators，\n结果：" + content + "\r\n```\r\n",
-								//	"time":     time.Now().Format(time.DateTime),
-								//}
-
-							}
-
-							if funcName == "GetStockKLine" {
-								stockCode := gjson.Get(funcArguments, "stockCode").String()
-								days := gjson.Get(funcArguments, "days").String()
-								ch <- map[string]any{
-									"code":     1,
-									"question": question,
-									"chatId":   streamResponse.Id,
-									"model":    streamResponse.Model,
-									"content":  "\r\n```\r\n开始调用工具：GetStockKLine，\n参数：" + stockCode + "," + days + "\r\n```\r\n",
-									"time":     time.Now().Format(time.DateTime),
-								}
-								toIntDay, err := convertor.ToInt(days)
-								if err != nil {
-									toIntDay = 90
-								}
-
-								if strutil.HasPrefixAny(stockCode, []string{"sz", "sh", "hk", "us", "gb_"}) {
-									K := &[]KLineData{}
-									if strutil.HasPrefixAny(stockCode, []string{"sz", "sh"}) {
-										K = NewStockDataApi().GetKLineData(stockCode, "240", o.KDays)
-									}
-									if strutil.HasPrefixAny(stockCode, []string{"hk", "us", "gb_"}) {
-										K = NewStockDataApi().GetHK_KLineData(stockCode, "day", o.KDays)
-									}
-									Kmap := &[]map[string]any{}
-									for _, kline := range *K {
-										mapk := make(map[string]any, 6)
-										mapk["日期"] = kline.Day
-										mapk["开盘价"] = kline.Open
-										mapk["最高价"] = kline.High
-										mapk["最低价"] = kline.Low
-										mapk["收盘价"] = kline.Close
-										Volume, _ := convertor.ToFloat(kline.Volume)
-										mapk["成交量(万手)"] = Volume / 10000.00 / 100.00
-										*Kmap = append(*Kmap, mapk)
-									}
-									jsonData, _ := json.Marshal(Kmap)
-									markdownTable, _ := JSONToMarkdownTable(jsonData)
-									logger.SugaredLogger.Infof("getKLineData=\n%s", markdownTable)
-
-									messages = append(messages, map[string]interface{}{
-										"role":    "assistant",
-										"content": currentAIContent.String(),
-										"tool_calls": []map[string]any{
-											{
-												"id":           currentCallId,
-												"tool_call_id": currentCallId,
-												"type":         "function",
-												"function": map[string]string{
-													"name":       funcName,
-													"arguments":  funcArguments,
-													"parameters": funcArguments,
-												},
-											},
-										},
-									})
-									res := "\r\n ### " + stockCode + convertor.ToString(toIntDay) + "日K线数据：\r\n" + markdownTable + "\r\n"
-									messages = append(messages, map[string]interface{}{
-										"role":         "tool",
-										"content":      res,
-										"tool_call_id": currentCallId,
-									})
-									logger.SugaredLogger.Infof("GetStockKLine:stockCode:%s days:%s --> \n%s", stockCode, days, res)
-
-									//ch <- map[string]any{
-									//	"code":     1,
-									//	"question": question,
-									//	"chatId":   streamResponse.Id,
-									//	"model":    streamResponse.Model,
-									//	"content":  "\r\n```\r\n调用工具：GetStockKLine，\n结果：" + res + "\r\n```\r\n",
-									//	"time":     time.Now().Format(time.DateTime),
-									//}
-								} else {
-									messages = append(messages, map[string]interface{}{
-										"role":    "assistant",
-										"content": currentAIContent.String(),
-										"tool_calls": []map[string]any{
-											{
-												"id":           currentCallId,
-												"tool_call_id": currentCallId,
-												"type":         "function",
-												"function": map[string]string{
-													"name":       funcName,
-													"arguments":  funcArguments,
-													"parameters": funcArguments,
-												},
-											},
-										},
-									})
-									messages = append(messages, map[string]interface{}{
-										"role":         "tool",
-										"content":      "无数据，可能股票代码错误。（A股：sh,sz开头;港股hk开头,美股：us开头）",
-										"tool_call_id": currentCallId,
-									})
-								}
-							}
-
-						}
-						AskAiWithTools(o, err, messages, ch, question, tools)
-					}
-
-					if choice.FinishReason == "stop" {
-						return
-					}
-				}
-			} else {
-				if err != nil {
-					logger.SugaredLogger.Infof("Stream data error : %s", err.Error())
-					//ch <- err.Error()
-					ch <- map[string]any{
-						"code":     0,
-						"question": question,
-						"content":  err.Error(),
-					}
-				} else {
-					logger.SugaredLogger.Infof("Stream data error : %s", data)
-					//ch <- data
-					ch <- map[string]any{
-						"code":     0,
-						"question": question,
-						"content":  data,
-					}
-				}
-			}
-		} else {
-			if strutil.RemoveNonPrintable(line) != "" {
-				logger.SugaredLogger.Infof("Stream data error : %s", line)
-				res := &models.Resp{}
-				if err := json.Unmarshal([]byte(line), res); err == nil {
-					//ch <- line
-					msg := res.Message
-					if res.Error.Message != "" {
-						msg = res.Error.Message
-					}
-
-					if msg == "Function call is not supported for this model." {
-						var newMessages []map[string]any
-						for _, message := range messages {
-							if message["role"] == "tool" {
-								continue
-							}
-							if _, ok := message["tool_calls"]; ok {
-								continue
-							}
-							newMessages = append(newMessages, message)
-						}
-						AskAi(o, err, newMessages, ch, question)
-					} else {
-						ch <- map[string]any{
-							"code":     0,
-							"question": question,
-							"content":  msg,
-						}
-					}
-
-				}
-			}
-
-		}
-
-	}
-}
 func checkIsIndexBasic(stock string) bool {
 	count := int64(0)
 	db.Dao.Model(&IndexBasic{}).Where("name =  ?", stock).Count(&count)

backend/data/openai_api_test.go

@@ -8,39 +8,12 @@ import (
 
 func TestNewDeepSeekOpenAiConfig(t *testing.T) {
 	db.Init("../../data/stock.db")
-
-	var tools []Tool
-	tools = append(tools, Tool{
-		Type: "function",
-		Function: ToolFunction{
-			Name:        "SearchStockByIndicators",
-			Description: "根据自然语言筛选股票，返回自然语言选股条件要求的股票所有相关数据",
-			Parameters: FunctionParameters{
-				Type: "object",
-				Properties: map[string]any{
-					"words": map[string]any{
-						"type":        "string",
-						"description": "选股自然语言,并且条件使用;分隔，或者条件使用,分隔。例如：创新药;PE<30;净利润增长率>50%;",
-					},
-				},
-				Required: []string{"words"},
-			},
-		},
-	})
-
 	ai := NewDeepSeekOpenAi(context.TODO())
-	//res := ai.NewChatStream("长电科技", "sh600584", "长电科技分析和总结", nil)
-	res := ai.NewSummaryStockNewsStreamWithTools("总结市场资讯，发掘潜力标的/行业/板块/概念，控制风险。调用工具函数验证", nil, tools)
-
+	res := ai.NewChatStream("长电科技", "sh600584", "长电科技分析和总结", nil)
 	for {
 		select {
 		case msg := <-res:
-			if len(msg) > 0 {
-				t.Log(msg)
-				if msg["content"] == "DONE" {
-					return
-				}
-			}
+			t.Log(msg)
 		}
 	}
 }

backend/data/search_stock_api.go

@@ -19,7 +19,7 @@ type SearchStockApi struct {
 func NewSearchStockApi(words string) *SearchStockApi {
 	return &SearchStockApi{words: words}
 }
-func (s SearchStockApi) SearchStock(pageSize int) map[string]any {
+func (s SearchStockApi) SearchStock() map[string]any {
 	url := "https://np-tjxg-g.eastmoney.com/api/smart-tag/stock/v3/pw/search-code"
 	resp, err := resty.New().SetTimeout(time.Duration(30)*time.Second).R().
 		SetHeader("Host", "np-tjxg-g.eastmoney.com").
@@ -29,7 +29,7 @@ func (s SearchStockApi) SearchStock(pageSize int) map[string]any {
 		SetHeader("Content-Type", "application/json").
 		SetBody(fmt.Sprintf(`{
 				"keyWord": "%s",
-				"pageSize": %d,
+				"pageSize": 50000,
 				"pageNo": 1,
 				"fingerprint": "e38b5faabf9378c8238e57219f0ebc9b",
 				"gids": [],
@@ -43,7 +43,7 @@ func (s SearchStockApi) SearchStock(pageSize int) map[string]any {
 				"ownSelectAll": false,
 				"dxInfo": [],
 				"extraCondition": ""
-				}`, s.words, pageSize)).Post(url)
+				}`, s.words)).Post(url)
 	if err != nil {
 		logger.SugaredLogger.Errorf("SearchStock-err:%+v", err)
 		return map[string]any{}
@@ -53,20 +53,3 @@ func (s SearchStockApi) SearchStock(pageSize int) map[string]any {
 	//logger.SugaredLogger.Infof("resp:%+v", respMap["data"])
 	return respMap
 }
-
-func (s SearchStockApi) HotStrategy() map[string]any {
-	url := fmt.Sprintf("https://np-ipick.eastmoney.com/recommend/stock/heat/ranking?count=20&trace=%d&client=web&biz=web_smart_tag", time.Now().Unix())
-	resp, err := resty.New().SetTimeout(time.Duration(30)*time.Second).R().
-		SetHeader("Host", "np-ipick.eastmoney.com").
-		SetHeader("Origin", "https://xuangu.eastmoney.com").
-		SetHeader("Referer", "https://xuangu.eastmoney.com/").
-		SetHeader("User-Agent", "Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:140.0) Gecko/20100101 Firefox/140.0").
-		Get(url)
-	if err != nil {
-		logger.SugaredLogger.Errorf("HotStrategy-err:%+v", err)
-		return map[string]any{}
-	}
-	respMap := map[string]any{}
-	json.Unmarshal(resp.Body(), &respMap)
-	return respMap
-}

backend/data/search_stock_api_test.go

@@ -1,8 +1,6 @@
 package data
 
 import (
-	"encoding/json"
-	"github.com/duke-git/lancet/v2/convertor"
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
 	"testing"
@@ -11,49 +9,17 @@ import (
 func TestSearchStock(t *testing.T) {
 	db.Init("../../data/stock.db")
 
-	res := NewSearchStockApi("算力股;净利润连续3年增长").SearchStock(10)
+	res := NewSearchStockApi("算力股;净利润连续3年增长").SearchStock()
 	data := res["data"].(map[string]any)
 	result := data["result"].(map[string]any)
 	dataList := result["dataList"].([]any)
-	columns := result["columns"].([]any)
-	headers := map[string]string{}
-	for _, v := range columns {
-		//logger.SugaredLogger.Infof("v:%+v", v)
-		d := v.(map[string]any)
-		//logger.SugaredLogger.Infof("key:%s title:%s dateMsg:%s unit:%s", d["key"], d["title"], d["dateMsg"], d["unit"])
-		title := convertor.ToString(d["title"])
-		if convertor.ToString(d["dateMsg"]) != "" {
-			title = title + "[" + convertor.ToString(d["dateMsg"]) + "]"
-		}
-		if convertor.ToString(d["unit"]) != "" {
-			title = title + "(" + convertor.ToString(d["unit"]) + ")"
-		}
-		headers[d["key"].(string)] = title
-	}
-	table := &[]map[string]any{}
 	for _, v := range dataList {
-		//logger.SugaredLogger.Infof("v:%+v", v)
 		d := v.(map[string]any)
-		tmp := map[string]any{}
-		for key, title := range headers {
-			//logger.SugaredLogger.Infof("%s:%s", title, convertor.ToString(d[key]))
-			tmp[title] = convertor.ToString(d[key])
-		}
-		*table = append(*table, tmp)
-		//logger.SugaredLogger.Infof("--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------")
+		logger.SugaredLogger.Infof("%s:%s", d["INDUSTRY"], d["SECURITY_SHORT_NAME"])
 	}
-	jsonData, _ := json.Marshal(*table)
-	markdownTable, _ := JSONToMarkdownTable(jsonData)
-	logger.SugaredLogger.Infof("markdownTable=\n%s", markdownTable)
-}
+	//columns := result["columns"].([]any)
+	//for _, v := range columns {
+	//	logger.SugaredLogger.Infof("v:%+v", v)
+	//}
 
-func TestSearchStockApi_HotStrategy(t *testing.T) {
-	db.Init("../../data/stock.db")
-	res := NewSearchStockApi("").HotStrategy()
-	logger.SugaredLogger.Infof("res:%+v", res)
-	dataList := res["data"].([]any)
-	for _, v := range dataList {
-		d := v.(map[string]any)
-		logger.SugaredLogger.Infof("v:%+v", d)
-	}
 }

backend/data/settings_api.go

@@ -128,7 +128,7 @@ func (s SettingsApi) GetConfig() *Settings {
 		}
 	}
 	if settings.BrowserPath == "" {
-		settings.BrowserPath, _ = CheckBrowser()
+		settings.BrowserPath, _ = CheckBrowserOnWindows()
 	}
 	if settings.BrowserPoolSize <= 0 {
 		settings.BrowserPoolSize = 1

backend/data/stock_data_api.go

@@ -20,6 +20,7 @@ import (
 	"go-stock/backend/db"
 	"go-stock/backend/logger"
 	"go-stock/backend/models"
+	"golang.org/x/sys/windows/registry"
 	"golang.org/x/text/encoding/simplifiedchinese"
 	"golang.org/x/text/transform"
 	"gorm.io/gorm"
@@ -1297,6 +1298,50 @@ func SearchStockInfoByCode(stock string) *[]string {
 	return &messages
 }
 
+// checkChromeOnWindows 在 Windows 系统上检查谷歌浏览器是否安装
+func checkChromeOnWindows() (string, bool) {
+	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
+	if err != nil {
+		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
+		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
+		if err != nil {
+			return "", false
+		}
+		defer key.Close()
+	}
+	defer key.Close()
+	path, _, err := key.GetStringValue("Path")
+	//logger.SugaredLogger.Infof("Chrome安装路径：%s", path)
+	if err != nil {
+		return "", false
+	}
+	return path + "\\chrome.exe", true
+}
+
+// CheckBrowserOnWindows 在 Windows 系统上检查Edge浏览器是否安装，并返回安装路径
+func CheckBrowserOnWindows() (string, bool) {
+	if path, ok := checkChromeOnWindows(); ok {
+		return path, true
+	}
+
+	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
+	if err != nil {
+		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
+		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
+		if err != nil {
+			return "", false
+		}
+		defer key.Close()
+	}
+	defer key.Close()
+	path, _, err := key.GetStringValue("Path")
+	//logger.SugaredLogger.Infof("Edge安装路径：%s", path)
+	if err != nil {
+		return "", false
+	}
+	return path + "\\msedge.exe", true
+}
+
 // 分时数据
 func (receiver StockDataApi) GetStockMinutePriceData(stockCode string) (*[]MinuteData, string) {
 	url := fmt.Sprintf("https://web.ifzq.gtimg.cn/appstock/app/minute/query?code=%s", stockCode)

backend/data/stock_data_api_darwin.go

@@ -1,37 +0,0 @@
-//go:build darwin
-// +build darwin
-
-package data
-
-import "os"
-
-// CheckChrome 检查 macOS 是否安装了 Chrome 浏览器
-func CheckChrome() (string, bool) {
-	// 检查 /Applications 目录下是否存在 Chrome
-	locations := []string{
-		// Mac
-		"/Applications/Chromium.app/Contents/MacOS/Chromium",
-		"/Applications/Google Chrome.app/Contents/MacOS/Google Chrome",
-	}
-	path := ""
-	for _, location := range locations {
-		_, err := os.Stat(location)
-		if err != nil {
-			continue
-		}
-		path = location
-	}
-	if path == "" {
-		return "", false
-	}
-
-	return path, true
-}
-
-// CheckBrowser 检查 macOS 是否安装了浏览器，并返回安装路径
-func CheckBrowser() (string, bool) {
-	if path, ok := CheckChrome(); ok {
-		return path, ok
-	}
-	return "", false
-}

backend/data/stock_data_api_windows.go

@@ -1,50 +0,0 @@
-//go:build windows
-// +build windows
-
-package data
-
-import "golang.org/x/sys/windows/registry"
-
-// CheckChrome 在 Windows 系统上检查谷歌浏览器是否安装
-func CheckChrome() (string, bool) {
-	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
-	if err != nil {
-		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
-		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\chrome.exe`, registry.QUERY_VALUE)
-		if err != nil {
-			return "", false
-		}
-		defer key.Close()
-	}
-	defer key.Close()
-	path, _, err := key.GetStringValue("Path")
-	//logger.SugaredLogger.Infof("Chrome安装路径：%s", path)
-	if err != nil {
-		return "", false
-	}
-	return path + "\\chrome.exe", true
-}
-
-// CheckBrowser 在 Windows 系统上检查Edge浏览器是否安装，并返回安装路径
-func CheckBrowser() (string, bool) {
-	if path, ok := CheckChrome(); ok {
-		return path, true
-	}
-
-	key, err := registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
-	if err != nil {
-		// 尝试在 WOW6432Node 中查找（适用于 64 位系统上的 32 位程序）
-		key, err = registry.OpenKey(registry.LOCAL_MACHINE, `SOFTWARE\WOW6432Node\Microsoft\Windows\CurrentVersion\App Paths\msedge.exe`, registry.QUERY_VALUE)
-		if err != nil {
-			return "", false
-		}
-		defer key.Close()
-	}
-	defer key.Close()
-	path, _, err := key.GetStringValue("Path")
-	//logger.SugaredLogger.Infof("Edge安装路径：%s", path)
-	if err != nil {
-		return "", false
-	}
-	return path + "\\msedge.exe", true
-}

backend/models/models.go

@@ -150,14 +150,13 @@ func (receiver AIResponseResult) TableName() string {
 
 type VersionInfo struct {
 	gorm.Model
-	Version           string                `json:"version"`
-	Content           string                `json:"content"`
-	Icon              string                `json:"icon"`
-	Alipay            string                `json:"alipay"`
-	Wxpay             string                `json:"wxpay"`
-	BuildTimeStamp    int64                 `json:"buildTimeStamp"`
-	OfficialStatement string                `json:"officialStatement"`
-	IsDel             soft_delete.DeletedAt `gorm:"softDelete:flag"`
+	Version        string                `json:"version"`
+	Content        string                `json:"content"`
+	Icon           string                `json:"icon"`
+	Alipay         string                `json:"alipay"`
+	Wxpay          string                `json:"wxpay"`
+	BuildTimeStamp int64                 `json:"buildTimeStamp"`
+	IsDel          soft_delete.DeletedAt `gorm:"softDelete:flag"`
 }
 
 func (receiver VersionInfo) TableName() string {
@@ -195,12 +194,6 @@ func (receiver StockInfoUS) TableName() string {
 type Resp struct {
 	Code    int    `json:"code"`
 	Message string `json:"message"`
-	Error   struct {
-		Code    string `json:"code"`
-		Message string `json:"message"`
-		Param   string `json:"param"`
-		Type    string `json:"type"`
-	} `json:"error"`
 }
 
 type PromptTemplate struct {

frontend/src/App.vue

@@ -27,7 +27,7 @@ import {
   StarOutline,
   Wallet, WarningOutline,
 } from '@vicons/ionicons5'
-import {AnalyzeSentiment, GetConfig, GetGroupList,GetVersionInfo} from "../wailsjs/go/main/App";
+import {AnalyzeSentiment, GetConfig, GetGroupList} from "../wailsjs/go/main/App";
 import {Dragon, Fire, Gripfire} from "@vicons/fa";
 import {ReportSearch} from "@vicons/tabler";
 import {LocalFireDepartmentRound} from "@vicons/material";
@@ -518,12 +518,6 @@ window.onerror = function (msg, source, lineno, colno, error) {
 };
 
 onBeforeMount(() => {
-  GetVersionInfo().then(result => {
-    if(result.officialStatement){
-      content.value = result.officialStatement+"\n\n"+content.value
-    }
-  })
-
   GetGroupList().then(result => {
     groupList.value = result
     menuOptions.value.map((item) => {

frontend/src/components/EmbeddedUrl.vue

@@ -1,133 +0,0 @@
-<template>
-  <div class="embed-container">
-    <h3 v-if="title">{{ title }}</h3>
-    <div class="iframe-wrapper">
-      <iframe
-          :src="url"
-          :title="iframeTitle"
-          frameborder="0"
-          scrolling="auto"
-          class="embedded-iframe"
-          @load="onLoad"
-          @error="onError"
-          :style="iframeStyle"
-      ></iframe>
-    </div>
-    <div v-if="loading" class="loading-indicator">
-      <div class="spinner"></div>
-      <p>加载中...</p>
-    </div>
-    <p v-if="error" class="error-message">{{ error }}</p>
-  </div>
-</template>
-
-<script setup>
-import { ref, onMounted, watch } from 'vue'
-
-const props = defineProps({
-  url: {
-    type: String,
-    required: true
-  },
-  title: {
-    type: String,
-    default: ''
-  },
-  iframeTitle: {
-    type: String,
-    default: '外部内容'
-  },
-  width: {
-    type: String,
-    default: '100%'
-  },
-  height: {
-    type: String,
-    default: '100%'
-  }
-})
-
-const loading = ref(true)
-const error = ref(null)
-
-const onLoad = () => {
-  loading.value = false
-  error.value = null
-}
-
-const onError = (event) => {
-  loading.value = false
-  error.value = `加载失败: ${event.message || '无法加载该 URL'}`
-}
-
-// 监听 URL 变化，重新加载
-watch(() => props.url, () => {
-  loading.value = true
-  error.value = null
-})
-
-// 设置 iframe 样式
-const iframeStyle = {
-  width: props.width,
-  height: props.height
-}
-</script>
-
-<style scoped>
-.embed-container {
-  margin: 1rem 0;
-  border: 0 solid #e5e7eb;
-  border-radius: 0.5rem;
-  overflow: hidden;
-}
-
-.iframe-wrapper {
-  position: relative;
-  width: 100%;
-}
-
-.embedded-iframe {
-  display: block;
-  width: 100%;
-  min-height: 400px;
-  transition: opacity 0.3s ease;
-}
-
-.loading-indicator {
-  position: absolute;
-  top: 0;
-  left: 0;
-  right: 0;
-  bottom: 0;
-  background-color: rgba(255, 255, 255, 0.8);
-  display: flex;
-  flex-direction: column;
-  align-items: center;
-  justify-content: center;
-  z-index: 10;
-}
-
-.spinner {
-  width: 2rem;
-  height: 2rem;
-  border: 3px solid #f3f4f6;
-  border-radius: 50%;
-  border-top-color: #3b82f6;
-  animation: spin 1s linear infinite;
-  margin-bottom: 0.5rem;
-}
-
-@keyframes spin {
-  to {
-    transform: rotate(360deg);
-  }
-}
-
-.error-message {
-  color: #ef4444;
-  padding: 1rem;
-  margin: 0;
-  background-color: #fee2e2;
-  text-align: center;
-}
-</style>

frontend/src/components/SelectStock.vue

@@ -1,28 +1,21 @@
 <script setup lang="ts">
 import {h, onBeforeMount, onMounted, onUnmounted, ref} from 'vue'
-import {SearchStock,GetHotStrategy} from "../../wailsjs/go/main/App";
-import {useMessage, NText, NTag,NButton} from 'naive-ui'
-import {RefreshCircleSharp} from "@vicons/ionicons5";
+import {SearchStock} from "../../wailsjs/go/main/App";
+import {useMessage, NText, NTag} from 'naive-ui'
 const message = useMessage()
-const search = ref('')
+const search = ref('科技股;换手率连续3日大于2')
 const columns = ref([])
 const dataList = ref([])
-const hotStrategy = ref([])
-const traceInfo = ref('')
-function Search() {
-  if(!search.value){
-    message.warning('请输入选股指标或者要求')
-    return
-  }
 
+function Search() {
   const loading = message.loading("正在获取选股数据...", {duration: 0});
   SearchStock(search.value).then(res => {
     loading.destroy()
-   // console.log(res)
+    //console.log(res)
     if(res.code==100){
-      traceInfo.value=res.data.traceInfo.showText
-     // message.success(res.msg)
+      message.success(res.msg)
       columns.value=res.data.result.columns.filter(item=>!item.hiddenNeed&&(item.title!="市场码"&&item.title!="市场简称")).map(item=>{
+
         if(item.children){
           return {
             title:item.title+(item.unit?'['+item.unit+']':''),
@@ -40,14 +33,7 @@ function Search() {
                 resizable: true,
                 ellipsis: {
                   tooltip: true
-                },
-                sorter: (row1, row2) => {
-                  if(isNumeric(row1[item.key])&&isNumeric(row2[item.key])){
-                    return row1[item.key] - row2[item.key];
-                  }else{
-                    return 'default'
-                  }
-                },
+                }
               }
             })
           }
@@ -56,21 +42,11 @@ function Search() {
             title:item.title+(item.unit?'['+item.unit+']':''),
             key:item.key,
             resizable: true,
-            minWidth:120,
+            minWidth:100,
             ellipsis: {
               tooltip: true
-            },
-            sorter: (row1, row2) => {
-              if(isNumeric(row1[item.key])&&isNumeric(row2[item.key])){
-                return row1[item.key] - row2[item.key];
-              }else{
-                return 'default'
-              }
-            },
+            }
           }
-
-
-
         }
       })
      dataList.value=res.data.result.dataList
@@ -86,96 +62,38 @@ function isNumeric(value) {
 }
 
 onBeforeMount(() => {
-  GetHotStrategy().then(res => {
-    console.log(res)
-    if(res.code==1){
-      hotStrategy.value=res.data
-      search.value=hotStrategy.value[0].question
-      Search()
-    }
-  }).catch(err => {
-    message.error(err)
-  })
-
-})
-function DoSearch(question){
-  search.value= question
   Search()
-}
+})
 
-function openCenteredWindow(url, width, height) {
-  const left = (window.screen.width - width) / 2;
-  const top = (window.screen.height - height) / 2;
-
-  return window.open(
-      url,
-      'centeredWindow',
-      `width=${width},height=${height},left=${left},top=${top},location=no,menubar=no,toolbar=no,display=standalone`
-  );
-}
 </script>
 
 <template>
-  <n-grid :cols="24" style="max-height: calc(100vh - 170px)">
-    <n-gi :span="4" >
-      <n-list bordered   style="text-align: left;" hoverable clickable>
-        <n-scrollbar style="max-height: calc(100vh - 170px);" >
-                  <n-list-item v-for="item in hotStrategy" :key="item.rank" @click="DoSearch(item.question)">
-                    <n-ellipsis  line-clamp="1" :tooltip="true" >
-                      <n-tag size="small"  :bordered="false" type="info">#{{item.rank}}</n-tag><n-text type="warning">{{item.question	}}</n-text>
-                      <template #tooltip>
-                        <div style="text-align: center;max-width: 180px">
-                          <n-text type="warning">{{item.question	}}</n-text>
-                        </div>
-                      </template>
-                    </n-ellipsis>
-                  </n-list-item>
-        </n-scrollbar>
-      </n-list>
-
-<!--        <n-virtual-list :items="hotStrategy" :item-size="hotStrategy.length">-->
-<!--          <template #default="{ item, index }">-->
-<!--                      <n-card :title="''" size="small">-->
-<!--                        <template #header-extra>-->
-<!--                          {{item.rank}}-->
-<!--                        </template>-->
-<!--                        <n-ellipsis expand-trigger="click" line-clamp="3" :tooltip="false" >-->
-<!--                          <n-text type="warning">{{item.question	}}</n-text>-->
-<!--                        </n-ellipsis>-->
-<!--                      </n-card>-->
-
-<!--          </template>-->
-<!--      </n-virtual-list>-->
-    </n-gi>
-    <n-gi :span="20" >
-      <n-flex>
-        <n-input-group style="text-align: left">
-          <n-input :rows="1" clearable v-model:value="search" placeholder="请输入选股指标或者要求" />
-          <n-button type="primary" @click="Search">搜索A股</n-button>
-        </n-input-group>
-      </n-flex>
-      <n-flex justify="start" v-if="traceInfo" style="margin: 5px 0">
-
-        <n-ellipsis  line-clamp="1" :tooltip="true" >
-          <n-text type="info" :bordered="false">选股条件：</n-text><n-text type="warning" :bordered="true">{{traceInfo}}</n-text>
-          <template #tooltip>
-            <div style="text-align: center;max-width: 580px">
-              <n-text type="warning">{{traceInfo}}</n-text>
-            </div>
-          </template>
-        </n-ellipsis>
-
-        <!--    <n-button type="primary" size="small">保存策略</n-button>-->
-      </n-flex>
-      <n-data-table
-          :striped="true"
-          :max-height="'calc(100vh - 250px)'"
-          size="medium"
-          :columns="columns"
-          :data="dataList"
-          :pagination="{pageSize: 9}"
-          :scroll-x="1800"
-          :render-cell="(value, rowData, column) => {
+  <n-flex>
+    <n-input-group>
+      <n-input v-model:value="search" placeholder="请输入选股指标或者要求" />
+      <n-button type="success" @click="Search">搜索A股</n-button>
+    </n-input-group>
+  </n-flex>
+<!--  <n-table striped size="small">-->
+<!--    <n-thead>-->
+<!--      <n-tr>-->
+<!--        <n-th v-for="item in columns">{{item.title}}</n-th>-->
+<!--      </n-tr>-->
+<!--    </n-thead>-->
+<!--    <n-tbody>-->
+<!--      <n-tr v-for="(item,index) in dataList">-->
+<!--        <n-td v-for="d in columns">{{item[d.key]}}</n-td>-->
+<!--      </n-tr>-->
+<!--    </n-tbody>-->
+<!--  </n-table>-->
+  <n-data-table
+      :max-height="'calc(100vh - 285px)'"
+      size="small"
+      :columns="columns"
+      :data="dataList"
+      :pagination="false"
+      :scroll-x="1800"
+      :render-cell="(value, rowData, column) => {
 
         if(column.key=='SECURITY_CODE'||column.key=='SERIAL'){
           return h(NText, { type: 'info',border: false }, { default: () => `${value}` })
@@ -194,21 +112,13 @@ function openCenteredWindow(url, width, height) {
             return h(NText, { type: type }, { default: () => `${value}` })
         }else{
             if(column.key=='SECURITY_SHORT_NAME'){
-              return h(NButton, { type: 'info',bordered: false ,size:'small',onClick:()=>{
-               //https://quote.eastmoney.com/sz300558.html#fullScreenChart
-               openCenteredWindow(`https://quote.eastmoney.com/${rowData.MARKET_SHORT_NAME}${rowData.SECURITY_CODE}.html#fullScreenChart`,1240,700)
-              }}, { default: () => `${value}` })
+              return h(NTag, { type: 'info',bordered: false }, { default: () => `${value}` })
             }else{
               return h(NText, { type: 'info' }, { default: () => `${value}` })
             }
           }
       }"
-      />
-      <n-text>共找到<n-tag type="info" :bordered="false">{{dataList.length}}</n-tag>只股</n-text>
-    </n-gi>
-  </n-grid>
-
-
+  />
 </template>
 
 <style scoped>

frontend/src/components/about.vue

@@ -135,7 +135,6 @@ EventsOn("updateVersion",async (msg) => {
             </p>
             <p>
               感谢以下开发者：
-              <a href="https://github.com/GiCo001" target="_blank">@Gico</a><n-divider vertical />
               <a href="https://github.com/CodeNoobLH" target="_blank">浓睡不消残酒</a><n-divider vertical />
               <a href="https://github.com/gnim2600" target="_blank">@gnim2600</a><n-divider vertical />
               <a href="https://github.com/XXXiaohuayanGGG" target="_blank">@XXXiaohuayanGGG</a><n-divider vertical />

frontend/src/components/market.vue

@@ -32,7 +32,6 @@ import HotTopics from "./HotTopics.vue";
 import InvestCalendarTimeLine from "./InvestCalendarTimeLine.vue";
 import ClsCalendarTimeLine from "./ClsCalendarTimeLine.vue";
 import SelectStock from "./SelectStock.vue";
-import Stockhotmap from "./stockhotmap.vue";
 
 const route = useRoute()
 const icon = ref('https://raw.githubusercontent.com/ArvinLovegood/go-stock/master/build/appicon.png');
@@ -71,7 +70,6 @@ const nowTab = ref("市场快讯")
 const indexInterval = ref(null)
 const indexIndustryRank = ref(null)
 const stockCode= ref('')
-const enableTools= ref(true)
 
 function getIndex() {
   GlobalStockIndexes().then((res) => {
@@ -131,20 +129,16 @@ EventsOn("changeMarketTab", async (msg) => {
 })
 
 EventsOn("newTelegraph", (data) => {
-  if (data!=null) {
-    for (let i = 0; i < data.length; i++) {
-      telegraphList.value.pop()
-    }
-    telegraphList.value.unshift(...data)
+  for (let i = 0; i < data.length; i++) {
+    telegraphList.value.pop()
   }
+  telegraphList.value.unshift(...data)
 })
 EventsOn("newSinaNews", (data) => {
-  if (data!=null) {
   for (let i = 0; i < data.length; i++) {
     sinaNewsList.value.pop()
   }
   sinaNewsList.value.unshift(...data)
-  }
 })
 
 //获取页面高度
@@ -192,7 +186,7 @@ function reAiSummary() {
   aiSummary.value = ""
   summaryModal.value = true
   loading.value = true
-  SummaryStockNews(question.value, sysPromptId.value,enableTools.value)
+  SummaryStockNews(question.value, sysPromptId.value)
 }
 
 function getAiSummary() {
@@ -217,7 +211,7 @@ function getAiSummary() {
       aiSummaryTime.value = ""
       aiSummary.value = ""
       modelName.value = ""
-      //SummaryStockNews(question.value, sysPromptId.value,enableTools.value)
+      SummaryStockNews(question.value, sysPromptId.value)
     }
   })
 }
@@ -604,9 +598,6 @@ function ReFlesh(source) {
       <n-tab-pane name="指标选股" tab="指标选股">
         <select-stock />
       </n-tab-pane>
-      <n-tab-pane name="名站优选" tab="名站优选">
-        <Stockhotmap />
-      </n-tab-pane>
     </n-tabs>
   </n-card>
   <n-modal transform-origin="center" v-model:show="summaryModal" preset="card" style="width: 800px;"
@@ -624,17 +615,6 @@ function ReFlesh(source) {
       </n-flex>
     </template>
     <template #action>
-      <n-flex justify="left" style="margin-bottom: 10px">
-        <n-switch v-model:value="enableTools" :round="false">
-          <template #checked>
-            启用AI函数工具调用
-          </template>
-          <template #unchecked>
-            不启用AI函数工具调用
-          </template>
-        </n-switch>
-        <n-gradient-text type="error" style="margin-left: 10px">*AI函数工具调用可以增强AI获取数据的能力,但会消耗更多tokens。</n-gradient-text>
-      </n-flex>
       <n-flex justify="space-between" style="margin-bottom: 10px">
         <n-select style="width: 49%" v-model:value="sysPromptId" label-field="name" value-field="ID"
                   :options="sysPromptOptions" placeholder="请选择系统提示词"/>

frontend/src/components/stock.vue

@@ -63,7 +63,6 @@ import vueDanmaku from 'vue3-danmaku'
 import {keys, padStart} from "lodash";
 import {useRoute, useRouter} from 'vue-router'
 import MoneyTrend from "./moneyTrend.vue";
-import {TaskTools} from "@vicons/carbon";
 
 const route = useRoute()
 const router = useRouter()
@@ -102,7 +101,6 @@ const modalShow3 = ref(false)
 const modalShow4 = ref(false)
 const modalShow5 = ref(false)
 const addBTN = ref(true)
-const enableTools= ref(false)
 const formModel = ref({
   name: "",
   code: "",
@@ -225,11 +223,8 @@ onMounted(() => {
       if (!stocks.value.includes(followedStock.StockCode)) {
         stocks.value.push(followedStock.StockCode)
       }
-      Greet(followedStock.StockCode).then(result => {
-        updateData(result)
-      })
     }
-    //monitor()
+    monitor()
     message.destroyAll()
   })
 
@@ -469,7 +464,6 @@ function removeMonitor(code, name, key) {
 
   UnFollow(code).then(result => {
     message.success(result)
-    monitor()
   })
 }
 
@@ -587,6 +581,7 @@ async function monitor() {
     showPopover.value = true
   }
   for (let code of stocks.value) {
+
     Greet(code).then(result => {
       updateData(result)
     })
@@ -595,7 +590,8 @@ async function monitor() {
 
 
 function GetSortKey(sort, code) {
-  return padStart(sort, 8, '0') + "_" + code
+  let sortKey = padStart(sort, 8, '0') + "_" + code
+  return sortKey
 }
 
 function onSelect(item) {
@@ -1358,7 +1354,7 @@ function aiReCheckStock(stock, stockCode) {
   //
 
   //message.info("sysPromptId:"+data.sysPromptId)
-  NewChatStream(stock, stockCode, data.question, data.sysPromptId,enableTools.value)
+  NewChatStream(stock, stockCode, data.question, data.sysPromptId)
 }
 
 function aiCheckStock(stock, stockCode) {
@@ -1387,12 +1383,12 @@ function aiCheckStock(stock, stockCode) {
       data.time = ""
       data.name = stock
       data.code = stockCode
-      data.loading = false
+      data.loading = true
       modalShow4.value = true
-      // message.loading("ai检测中...", {
-      //   duration: 0,
-      // })
-      // NewChatStream(stock, stockCode, "", data.sysPromptId)
+      message.loading("ai检测中...", {
+        duration: 0,
+      })
+      NewChatStream(stock, stockCode, "", data.sysPromptId)
     }
   })
 }
@@ -1577,20 +1573,18 @@ function AddStockGroupInfo(groupId, code, name) {
 }
 
 function updateTab(name) {
-  stocks.value = []
   currentGroupId.value = Number(name)
   GetFollowList(currentGroupId.value).then(result => {
+    stocks.value = []
     followList.value = result
     for (const followedStock of result) {
       if (followedStock.StockCode.startsWith("us")) {
         followedStock.StockCode = "gb_" + followedStock.StockCode.replace("us", "").toLowerCase()
       }
+      ////console.log("followList",followedStock.StockCode)
       stocks.value.push(followedStock.StockCode)
-      Greet(followedStock.StockCode).then(result => {
-        updateData(result)
-      })
     }
-    //monitor()
+    monitor()
     message.destroyAll()
   })
 }
@@ -1745,10 +1739,11 @@ function searchStockReport(stockCode) {
                         @click="removeMonitor(result['股票代码'],result['股票名称'],result.key)">
                 取消关注
               </n-button>&nbsp;
-
-              <n-button size="tiny" v-if="data.openAiEnable" secondary type="warning"  @click="aiCheckStock(result['股票名称'],result['股票代码'])">
+              <n-button size="tiny" v-if="data.openAiEnable" secondary type="warning"
+                        @click="aiCheckStock(result['股票名称'],result['股票代码'])">
                 AI分析
               </n-button>
+
             </template>
             <template #footer>
               <n-flex justify="center">
@@ -1881,10 +1876,10 @@ function searchStockReport(stockCode) {
                         @click="removeMonitor(result['股票代码'],result['股票名称'],result.key)">
                 取消关注
               </n-button>&nbsp;
-
-                <n-button size="tiny" v-if="data.openAiEnable" secondary type="warning"  @click="aiCheckStock(result['股票名称'],result['股票代码'])">
-                  AI分析
-                </n-button>
+              <n-button size="tiny" v-if="data.openAiEnable" secondary type="warning"
+                        @click="aiCheckStock(result['股票名称'],result['股票代码'])">
+                AI分析
+              </n-button>&nbsp;
               <n-button secondary type="error" size="tiny"
                         @click="delStockGroup(result['股票代码'],result['股票名称'],group.ID)">移出分组
               </n-button>
@@ -2050,7 +2045,7 @@ function searchStockReport(stockCode) {
   </n-modal>
 
   <n-modal transform-origin="center" v-model:show="modalShow4" preset="card" style="width: 800px;"
-           :title="'['+data.name+']AI分析'">
+           :title="'['+data.name+']AI分析结果'">
     <n-spin size="small" :show="data.loading">
       <MdEditor v-if="enableEditor" :toolbars="toolbars" ref="mdEditorRef" style="height: 440px;text-align: left"
                 :modelValue="data.airesult" :theme="theme">
@@ -2074,17 +2069,7 @@ function searchStockReport(stockCode) {
       </n-flex>
     </template>
     <template #action>
-      <n-flex justify="left" style="margin-bottom: 10px">
-        <n-switch v-model:value="enableTools" :round="false">
-          <template #checked>
-            启用AI函数工具调用
-          </template>
-          <template #unchecked>
-            不启用AI函数工具调用
-          </template>
-        </n-switch>
-        <n-gradient-text type="error" style="margin-left: 10px">*AI函数工具调用可以增强AI获取数据的能力,但会消耗更多tokens。</n-gradient-text>
-      </n-flex>
+
       <n-flex justify="space-between" style="margin-bottom: 10px">
         <n-select style="width: 49%" v-model:value="data.sysPromptId" label-field="name" value-field="ID"
                   :options="sysPromptOptions" placeholder="请选择系统提示词"/>
@@ -2102,7 +2087,7 @@ function searchStockReport(stockCode) {
             }"
         />
         <!--        <n-button size="tiny" type="error" @click="enableEditor=!enableEditor">编辑/预览</n-button>-->
-        <n-button size="tiny" type="warning" @click="aiReCheckStock(data.name,data.code)">开始AI分析</n-button>
+        <n-button size="tiny" type="warning" @click="aiReCheckStock(data.name,data.code)">再次分析</n-button>
         <n-button size="tiny" type="info" @click="saveAsImage(data.name,data.code)">保存为图片</n-button>
         <n-button size="tiny" type="success" @click="copyToClipboard">复制到剪切板</n-button>
         <n-button size="tiny" type="primary" @click="saveAsMarkdown">保存为Markdown文件</n-button>

frontend/src/components/stockhotmap.vue

@@ -1,35 +0,0 @@
-<script setup lang="ts">
-
-import EmbeddedUrl from "./EmbeddedUrl.vue";
-</script>
-
-<template>
-  <n-tabs  type="line" animated>
-    <n-tab-pane name="百度股市通" tab="百度股市通">
-      <embedded-url url="https://gushitong.baidu.com"  :height="'calc(100vh - 252px)'"/>
-    </n-tab-pane>
-    <n-tab-pane name="东财大盘星图" tab="东财大盘星图">
-      <embedded-url url="https://quote.eastmoney.com/stockhotmap/"  :height="'calc(100vh - 252px)'"/>
-    </n-tab-pane>
-    <n-tab-pane name="TopHub" tab="TopHub(今日热榜)">
-      <embedded-url url="https://tophub.today/c/finance"  :height="'calc(100vh - 252px)'"/>
-    </n-tab-pane>
-    <n-tab-pane name="选股通" tab="选股通">
-      <embedded-url url="https://xuangutong.com.cn"  :height="'calc(100vh - 252px)'"/>
-    </n-tab-pane>
-    <n-tab-pane name="摸鱼" tab="摸鱼">
-      <embedded-url url="https://996.ninja/"  :height="'calc(100vh - 252px)'"/>
-    </n-tab-pane>
-
-
-    <n-tab-pane name="欢迎推荐更多有趣的财经网页" tab="欢迎推荐更多有趣的财经网页">
-    </n-tab-pane>
-<!--    <n-tab-pane name="自在量化" tab="自在量化">-->
-<!--      <embedded-url url="https://quant.zizizaizai.com/home"/>-->
-<!--    </n-tab-pane>-->
-  </n-tabs>
-</template>
-
-<style scoped>
-
-</style>

frontend/wailsjs/go/main/App.d.ts

@@ -39,8 +39,6 @@ export function GetGroupList():Promise<Array<data.Group>>;
 
 export function GetGroupStockList(arg1:number):Promise<Array<data.GroupStock>>;
 
-export function GetHotStrategy():Promise<Record<string, any>>;
-
 export function GetIndustryMoneyRankSina(arg1:string,arg2:string):Promise<Array<Record<string, any>>>;
 
 export function GetIndustryRank(arg1:string,arg2:number):Promise<Array<any>>;
@@ -81,7 +79,7 @@ export function InvestCalendarTimeLine(arg1:string):Promise<Array<any>>;
 
 export function LongTigerRank(arg1:string):Promise<any>;
 
-export function NewChatStream(arg1:string,arg2:string,arg3:string,arg4:any,arg5:boolean):Promise<void>;
+export function NewChatStream(arg1:string,arg2:string,arg3:string,arg4:any):Promise<void>;
 
 export function NewsPush(arg1:any):Promise<void>;
 
@@ -115,7 +113,7 @@ export function StockNotice(arg1:string):Promise<Array<any>>;
 
 export function StockResearchReport(arg1:string):Promise<Array<any>>;
 
-export function SummaryStockNews(arg1:string,arg2:any,arg3:boolean):Promise<void>;
+export function SummaryStockNews(arg1:string,arg2:any):Promise<void>;
 
 export function UnFollow(arg1:string):Promise<string>;
 

frontend/wailsjs/go/main/App.js

@@ -74,10 +74,6 @@ export function GetGroupStockList(arg1) {
   return window['go']['main']['App']['GetGroupStockList'](arg1);
 }
 
-export function GetHotStrategy() {
-  return window['go']['main']['App']['GetHotStrategy']();
-}
-
 export function GetIndustryMoneyRankSina(arg1, arg2) {
   return window['go']['main']['App']['GetIndustryMoneyRankSina'](arg1, arg2);
 }
@@ -158,8 +154,8 @@ export function LongTigerRank(arg1) {
   return window['go']['main']['App']['LongTigerRank'](arg1);
 }
 
-export function NewChatStream(arg1, arg2, arg3, arg4, arg5) {
-  return window['go']['main']['App']['NewChatStream'](arg1, arg2, arg3, arg4, arg5);
+export function NewChatStream(arg1, arg2, arg3, arg4) {
+  return window['go']['main']['App']['NewChatStream'](arg1, arg2, arg3, arg4);
 }
 
 export function NewsPush(arg1) {
@@ -226,8 +222,8 @@ export function StockResearchReport(arg1) {
   return window['go']['main']['App']['StockResearchReport'](arg1);
 }
 
-export function SummaryStockNews(arg1, arg2, arg3) {
-  return window['go']['main']['App']['SummaryStockNews'](arg1, arg2, arg3);
+export function SummaryStockNews(arg1, arg2) {
+  return window['go']['main']['App']['SummaryStockNews'](arg1, arg2);
 }
 
 export function UnFollow(arg1) {

frontend/wailsjs/go/models.ts

@@ -701,7 +701,6 @@ export namespace models {
 	    alipay: string;
 	    wxpay: string;
 	    buildTimeStamp: number;
-	    officialStatement: string;
 	    IsDel: number;
 	
 	    static createFrom(source: any = {}) {
@@ -720,7 +719,6 @@ export namespace models {
 	        this.alipay = source["alipay"];
 	        this.wxpay = source["wxpay"];
 	        this.buildTimeStamp = source["buildTimeStamp"];
-	        this.officialStatement = source["officialStatement"];
 	        this.IsDel = source["IsDel"];
 	    }
 	

go.mod

@@ -8,7 +8,6 @@ require (
 	github.com/coocood/freecache v1.2.4
 	github.com/duke-git/lancet/v2 v2.3.4
 	github.com/energye/systray v1.0.2
-	github.com/gen2brain/beeep v0.11.1
 	github.com/glebarez/sqlite v1.11.0
 	github.com/go-ego/gse v0.80.3
 	github.com/go-resty/resty/v2 v2.16.2
@@ -29,7 +28,6 @@ require (
 )
 
 require (
-	git.sr.ht/~jackmordaunt/go-toast v1.1.2 // indirect
 	github.com/andybalholm/cascadia v1.3.3 // indirect
 	github.com/bep/debounce v1.2.1 // indirect
 	github.com/cespare/xxhash/v2 v2.1.2 // indirect
@@ -37,7 +35,6 @@ require (
 	github.com/chromedp/sysutil v1.1.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/dustin/go-humanize v1.0.1 // indirect
-	github.com/esiqveland/notify v0.13.3 // indirect
 	github.com/glebarez/go-sqlite v1.21.2 // indirect
 	github.com/go-ole/go-ole v1.3.0 // indirect
 	github.com/gobwas/httphead v0.1.0 // indirect
@@ -45,7 +42,6 @@ require (
 	github.com/gobwas/ws v1.4.0 // indirect
 	github.com/godbus/dbus/v5 v5.1.0 // indirect
 	github.com/google/uuid v1.6.0 // indirect
-	github.com/jackmordaunt/icns/v3 v3.0.1 // indirect
 	github.com/jchv/go-winloader v0.0.0-20210711035445-715c2860da7e // indirect
 	github.com/jinzhu/inflection v1.0.0 // indirect
 	github.com/jinzhu/now v1.1.5 // indirect
@@ -59,16 +55,12 @@ require (
 	github.com/mailru/easyjson v0.7.7 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/mattn/go-isatty v0.0.20 // indirect
-	github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 // indirect
 	github.com/nu7hatch/gouuid v0.0.0-20131221200532-179d4d0c4d8d // indirect
 	github.com/pkg/browser v0.0.0-20240102092130-5ac0b6a4141c // indirect
 	github.com/pkg/errors v0.9.1 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect
 	github.com/rivo/uniseg v0.4.7 // indirect
-	github.com/sergeymakinen/go-bmp v1.0.0 // indirect
-	github.com/sergeymakinen/go-ico v1.0.0-beta.0 // indirect
-	github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af // indirect
 	github.com/tevino/abool v0.0.0-20220530134649-2bfc934cb23c // indirect
 	github.com/tidwall/match v1.1.1 // indirect
 	github.com/tidwall/pretty v1.2.0 // indirect

go.sum

@@ -1,5 +1,3 @@
-git.sr.ht/~jackmordaunt/go-toast v1.1.2 h1:/yrfI55LRt1M7H1vkaw+NaH1+L1CDxrqDltwm5euVuE=
-git.sr.ht/~jackmordaunt/go-toast v1.1.2/go.mod h1:jA4OqHKTQ4AFBdwrSnwnskUIIS3HYzlJSgdzCKqfavo=
 github.com/PuerkitoBio/goquery v1.10.1 h1:Y8JGYUkXWTGRB6Ars3+j3kN0xg1YqqlwvdTV8WTFQcU=
 github.com/PuerkitoBio/goquery v1.10.1/go.mod h1:IYiHrOMps66ag56LEH7QYDDupKXyo5A8qrjIx3ZtujY=
 github.com/andybalholm/cascadia v1.3.3 h1:AG2YHrzJIm4BZ19iwJ/DAua6Btl3IwJX+VI4kktS1LM=
@@ -16,7 +14,6 @@ github.com/chromedp/sysutil v1.1.0 h1:PUFNv5EcprjqXZD9nJb9b/c9ibAbxiYo4exNWZyipw
 github.com/chromedp/sysutil v1.1.0/go.mod h1:WiThHUdltqCNKGc4gaU50XgYjwjYIhKWoHGPTUfWTJ8=
 github.com/coocood/freecache v1.2.4 h1:UdR6Yz/X1HW4fZOuH0Z94KwG851GWOSknua5VUbb/5M=
 github.com/coocood/freecache v1.2.4/go.mod h1:RBUWa/Cy+OHdfTGFEhEuE1pMCMX51Ncizj7rthiQ3vk=
-github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/duke-git/lancet/v2 v2.3.4 h1:8XGI7P9w+/GqmEBEXYaH/XuNiM0f4/90Ioti0IvYJls=
@@ -25,10 +22,6 @@ github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkp
 github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=
 github.com/energye/systray v1.0.2 h1:63R4prQkANtpM2CIA4UrDCuwZFt+FiygG77JYCsNmXc=
 github.com/energye/systray v1.0.2/go.mod h1:sp7Q/q/I4/w5ebvpSuJVep71s9Bg7L9ZVp69gBASehM=
-github.com/esiqveland/notify v0.13.3 h1:QCMw6o1n+6rl+oLUfg8P1IIDSFsDEb2WlXvVvIJbI/o=
-github.com/esiqveland/notify v0.13.3/go.mod h1:hesw/IRYTO0x99u1JPweAl4+5mwXJibQVUcP0Iu5ORE=
-github.com/gen2brain/beeep v0.11.1 h1:EbSIhrQZFDj1K2fzlMpAYlFOzV8YuNe721A58XcCTYI=
-github.com/gen2brain/beeep v0.11.1/go.mod h1:jQVvuwnLuwOcdctHn/uyh8horSBNJ8uGb9Cn2W4tvoc=
 github.com/glebarez/go-sqlite v1.21.2 h1:3a6LFC4sKahUunAmynQKLZceZCOzUthkRkEAl9gAXWo=
 github.com/glebarez/go-sqlite v1.21.2/go.mod h1:sfxdZyhQjTM2Wry3gVYWaW072Ri1WMdWJi0k6+3382k=
 github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw=
@@ -57,8 +50,6 @@ github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbu
 github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo=
 github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
 github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
-github.com/jackmordaunt/icns/v3 v3.0.1 h1:xxot6aNuGrU+lNgxz5I5H0qSeCjNKp8uTXB1j8D4S3o=
-github.com/jackmordaunt/icns/v3 v3.0.1/go.mod h1:5sHL59nqTd2ynTnowxB/MDQFhKNqkK8X687uKNygaSQ=
 github.com/jchv/go-winloader v0.0.0-20210711035445-715c2860da7e h1:Q3+PugElBCf4PFpxhErSzU3/PY5sFL5Z6rfv4AbGAck=
 github.com/jchv/go-winloader v0.0.0-20210711035445-715c2860da7e/go.mod h1:alcuEEnZsY1WQsagKhZDsoPCRoOijYqhZvPwLG0kzVs=
 github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E=
@@ -100,8 +91,6 @@ github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D
 github.com/mattn/go-sqlite3 v1.14.3/go.mod h1:WVKg1VTActs4Qso6iwGbiFih2UIHo0ENGwNd0Lj+XmI=
 github.com/mattn/go-sqlite3 v1.14.16 h1:yOQRA0RpS5PFz/oikGwBEqvAWhWg5ufRz4ETLjwpU1Y=
 github.com/mattn/go-sqlite3 v1.14.16/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
-github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 h1:zYyBkD/k9seD2A7fsi6Oo2LfFZAehjjQMERAvZLEDnQ=
-github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S/RLdc7JQKbRpFeM1dOBd8T9ki5s+AY8=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs=
 github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno=
 github.com/nu7hatch/gouuid v0.0.0-20131221200532-179d4d0c4d8d h1:VhgPp6v9qf9Agr/56bj7Y/xa04UccTW04VP0Qed4vnQ=
@@ -126,20 +115,8 @@ github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
 github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
 github.com/samber/lo v1.49.1 h1:4BIFyVfuQSEpluc7Fua+j1NolZHiEHEpaSEKdsH0tew=
 github.com/samber/lo v1.49.1/go.mod h1:dO6KHFzUKXgP8LDhU0oI8d2hekjXnGOu0DB8Jecxd6o=
-github.com/sergeymakinen/go-bmp v1.0.0 h1:SdGTzp9WvCV0A1V0mBeaS7kQAwNLdVJbmHlqNWq0R+M=
-github.com/sergeymakinen/go-bmp v1.0.0/go.mod h1:/mxlAQZRLxSvJFNIEGGLBE/m40f3ZnUifpgVDlcUIEY=
-github.com/sergeymakinen/go-ico v1.0.0-beta.0 h1:m5qKH7uPKLdrygMWxbamVn+tl2HfiA3K6MFJw4GfZvQ=
-github.com/sergeymakinen/go-ico v1.0.0-beta.0/go.mod h1:wQ47mTczswBO5F0NoDt7O0IXgnV4Xy3ojrroMQzyhUk=
-github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
-github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
-github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
-github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
-github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
 github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
 github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
-github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af h1:6yITBqGTE2lEeTPG04SN9W+iWHCRyHqlVYILiSXziwk=
-github.com/tadvi/systray v0.0.0-20190226123456-11a2b8fa57af/go.mod h1:4F09kP5F+am0jAwlQLddpoMDM+iewkxxt6nxUQ5nq5o=
 github.com/tevino/abool v0.0.0-20220530134649-2bfc934cb23c h1:coVla7zpsycc+kA9NXpcvv2E4I7+ii6L5hZO2S6C3kw=
 github.com/tevino/abool v0.0.0-20220530134649-2bfc934cb23c/go.mod h1:qc66Pna1RiIsPa7O4Egxxs9OqkuxDX55zznh9K07Tzg=
 github.com/tidwall/gjson v1.14.2 h1:6BBkirS0rAHjumnjHF6qgy5d2YAJ1TLIaFE2lzfOLqo=
@@ -261,7 +238,6 @@ gopkg.in/natefinch/lumberjack.v2 v2.2.1 h1:bBRl1b0OH9s/DuPhuXpNl+VtCaJXFZ5/uEFST
 gopkg.in/natefinch/lumberjack.v2 v2.2.1/go.mod h1:YD8tP3GAjkrDg1eZH7EGmyESg/lsYskCTPBJVb9jqSc=
 gopkg.in/sourcemap.v1 v1.0.5 h1:inv58fC9f9J3TK2Y2R1NPntXEn3/wjWHkonhIUODNTI=
 gopkg.in/sourcemap.v1 v1.0.5/go.mod h1:2RlvNNSMglmRrcvhfuzp4hQHwOtjxlbjX7UPY/GXb78=
-gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gorm.io/driver/mysql v1.5.7 h1:MndhOPYOfEp2rHKgkZIhJ16eVUIRf2HmzgoPmh7FCWo=

main.go

@@ -53,7 +53,6 @@ var stocksBinUS []byte
 
 var Version string
 var VersionCommit string
-var OFFICIAL_STATEMENT string
 
 func main() {
 	checkDir("data")