feat(frontend):添加个股资金流向功能

- 在 App.vue 中添加个股资金流向相关路由和菜单项 - 新增 RankTable 组件用于展示排名数据 - 在 market.vue 中集成 RankTable 组件，实现资金流向排名展示 - 在后端添加 GetIndustryMoneyRankSina 和 GetMoneyRankSina接口 - 更新前端 App.d.ts、App.js 和后端 app.go 以支持新功能
2025-07-19 00:00:09 +08:00 · 2025-05-14 12:04:32 +08:00 · 2025-05-14 12:04:32 +08:00 · 47dbbb8813
commit 47dbbb8813
parent ae9f4073dc
8 changed files with 214 additions and 2 deletions
--- a/app.go
+++ b/app.go
@ -1107,3 +1107,11 @@ func (a *App) GetIndustryRank(sort string, cnt int) []any {
 	res := data.NewMarketNewsApi().GetIndustryRank(sort, cnt)
 	return res["data"].([]any)
 }
+func (a *App) GetIndustryMoneyRankSina(fenlei string) []map[string]any {
+	res := data.NewMarketNewsApi().GetIndustryMoneyRankSina(fenlei)
+	return res
+}
+func (a *App) GetMoneyRankSina(sort string) []map[string]any {
+	res := data.NewMarketNewsApi().GetMoneyRankSina(sort)
+	return res
+}
--- a/backend/data/market_news_api.go
+++ b/backend/data/market_news_api.go
@ -237,3 +237,41 @@ func (m MarketNewsApi) GetIndustryRank(sort string, cnt int) map[string]any {
 	json.Unmarshal([]byte(js), &res)
 	return res
 }
+
+func (m MarketNewsApi) GetIndustryMoneyRankSina(fenlei string) []map[string]any {
+	url := fmt.Sprintf("https://vip.stock.finance.sina.com.cn/quotes_service/api/json_v2.php/MoneyFlow.ssl_bkzj_bk?page=1&num=20&sort=netamount&asc=0&fenlei=%s", fenlei)
+
+	response, _ := resty.New().SetTimeout(time.Duration(5)*time.Second).R().
+		SetHeader("Host", "vip.stock.finance.sina.com.cn").
+		SetHeader("Referer", "https://finance.sina.com.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(url)
+	js := string(response.Body())
+	res := &[]map[string]any{}
+	err := json.Unmarshal([]byte(js), &res)
+	if err != nil {
+		logger.SugaredLogger.Error(err)
+		return *res
+	}
+	return *res
+}
+
+func (m MarketNewsApi) GetMoneyRankSina(sort string) []map[string]any {
+	if sort == "" {
+		sort = "netamount"
+	}
+	url := fmt.Sprintf("https://vip.stock.finance.sina.com.cn/quotes_service/api/json_v2.php/MoneyFlow.ssl_bkzj_ssggzj?page=1&num=20&sort=%s&asc=0&bankuai=&shichang=", sort)
+	response, _ := resty.New().SetTimeout(time.Duration(5)*time.Second).R().
+		SetHeader("Host", "vip.stock.finance.sina.com.cn").
+		SetHeader("Referer", "https://finance.sina.com.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(url)
+	js := string(response.Body())
+	res := &[]map[string]any{}
+	err := json.Unmarshal([]byte(js), &res)
+	if err != nil {
+		logger.SugaredLogger.Error(err)
+		return *res
+	}
+	return *res
+}
--- a/backend/data/market_news_api_test.go
+++ b/backend/data/market_news_api_test.go
@ -35,3 +35,17 @@ func TestGetIndustryRank(t *testing.T) {

 	}
 }
+func TestGetIndustryMoneyRankSina(t *testing.T) {
+	res := NewMarketNewsApi().GetIndustryMoneyRankSina("2")
+	for i, re := range res {
+		logger.SugaredLogger.Debugf("key: %+v, value: %+v", i, re)
+
+	}
+}
+func TestGetMoneyRankSina(t *testing.T) {
+	res := NewMarketNewsApi().GetMoneyRankSina("r3_net")
+	for i, re := range res {
+		logger.SugaredLogger.Debugf("key: %+v, value: %+v", i, re)
+
+	}
+}
--- a/frontend/src/App.vue
+++ b/frontend/src/App.vue
@ -23,7 +23,7 @@ import {
  AlarmOutline,
  SparklesOutline,
  NewspaperOutline,
-  AnalyticsOutline, BarChartSharp, NewspaperSharp, Flame,
+  AnalyticsOutline, BarChartSharp, NewspaperSharp, Flame, BarChartOutline, Wallet,
 } from '@vicons/ionicons5'
 import {GetConfig, GetGroupList} from "../wailsjs/go/main/App";
 import { useRouter } from 'vue-router'
@ -196,6 +196,27 @@ const menuOptions = ref([
            ),
        key: 'market4',
        icon: renderIcon(Flame),
+      },
+      {
+        label: () =>
+            h(
+                RouterLink,
+                {
+                  href: '#',
+                  to: {
+                    name: 'market',
+                    query: {
+                      name:"个股资金流向",
+                    }
+                  },
+                  onClick: ()=>{
+                    EventsEmit("changeMarketTab",  {ID:0,name:'个股资金流向'})
+                  },
+                },
+                { default: () => '个股资金流向',}
+            ),
+        key: 'market5',
+        icon: renderIcon(Wallet),
      }
    ]
  },
--- a/frontend/src/components/market.vue
+++ b/frontend/src/components/market.vue
@ -16,6 +16,7 @@ import {NAvatar, NButton, NFlex, NText, useMessage, useNotification} from "naive
 import {ExportPDF} from "@vavt/v3-extension";
 import {MdEditor, MdPreview} from "md-editor-v3";
 import { useRoute } from 'vue-router'
+import RankTable from "./rankTable.vue";
 const route = useRoute()
 const icon = ref('https://raw.githubusercontent.com/ArvinLovegood/go-stock/master/build/appicon.png');

@ -400,13 +401,44 @@ function ReFlesh(source){
              <n-td><n-text :type="item.bd_zdf>0?'error':'success'">{{item.bd_zdf}}%</n-text></n-td>
              <n-td><n-text :type="item.bd_zdf5>0?'error':'success'">{{item.bd_zdf5}}%</n-text></n-td>
              <n-td><n-text :type="item.bd_zdf20>0?'error':'success'">{{item.bd_zdf20}}%</n-text></n-td>
-              <n-td><n-text :type="item.nzg_zdf>0?'error':'success'">{{item.nzg_name}}</n-text></n-td>
+              <n-td><n-text :type="item.nzg_zdf>0?'error':'success'"> {{item.nzg_name}} <n-text  type="info">{{item.nzg_code}}</n-text></n-text></n-td>
              <n-td><n-text :type="item.nzg_zdf>0?'error':'success'"> {{item.nzg_zdf}}%</n-text></n-td>
              <n-td> <n-text :type="item.nzg_zdf>0?'error':'success'">{{item.nzg_zxj}}</n-text></n-td>
            </n-tr>
          </n-tbody>
        </n-table>
      </n-tab-pane>
+      <n-tab-pane name="个股资金流向" tab="个股资金流向">
+        <n-tabs type="card" animated>
+          <n-tab-pane name="netamount" tab="净流入额排名">
+            <RankTable :header-title="'净流入额排名'" :sort="'netamount'"/>
+          </n-tab-pane>
+          <n-tab-pane name="outamount" tab="流出资金排名">
+            <RankTable :header-title="'流出资金排名'" :sort="'outamount'"/>
+          </n-tab-pane>
+          <n-tab-pane name="ratioamount" tab="净流入率排名">
+            <RankTable :header-title="'净流入率排名'" :sort="'ratioamount'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r0_net" tab="主力净流入额排名">
+            <RankTable :header-title="'主力净流入额排名'" :sort="'r0_net'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r0_out" tab="主力流出排名">
+            <RankTable :header-title="'主力流出排名'" :sort="'r0_out'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r0_ratio" tab="主力净流入率排名">
+            <RankTable :header-title="'主力净流入率排名'" :sort="'r0_ratio'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r3_net" tab="散户净流入额排名">
+            <RankTable :header-title="'散户净流入额排名'" :sort="'r3_net'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r3_out" tab="散户流出排名">
+            <RankTable :header-title="'散户流出排名'" :sort="'r3_out'"/>
+          </n-tab-pane>
+          <n-tab-pane name="r3_ratio" tab="散户净流入率排名">
+            <RankTable :header-title="'散户净流入率排名'" :sort="'r3_ratio'"/>
+          </n-tab-pane>
+        </n-tabs>
+      </n-tab-pane>
    </n-tabs>
  </n-card>
  <n-modal transform-origin="center" v-model:show="summaryModal"  preset="card" style="width: 800px;" :title="'AI市场资讯总结'" >
--- a/frontend/src/components/rankTable.vue
+++ b/frontend/src/components/rankTable.vue
@ -0,0 +1,87 @@
+<script setup>
+
+import {CaretDown, CaretUp} from "@vicons/ionicons5";
+import {NText} from "naive-ui";
+import {onMounted, ref} from "vue";
+import {GetMoneyRankSina} from "../../wailsjs/go/main/App";
+
+const props = defineProps({
+  headerTitle: {
+    type: String,
+    default: '净流入额排名'
+  },
+  sort: {
+    type: String,
+    default: 'netamount'
+  },
+})
+const dataList= ref([])
+const sort = ref(props.sort)
+onMounted(()=>{
+  sort.value=props.sort
+  GetMoneyRankSinaData()
+  setInterval(()=>{
+    GetMoneyRankSinaData()
+  },1000*60)
+})
+function GetMoneyRankSinaData(){
+  GetMoneyRankSina(sort.value).then(result => {
+    if(result.length>0){
+      dataList.value = result
+    }
+  })
+}
+</script>
+
+<template>
+  <n-table striped size="small">
+    <n-thead>
+      <n-tr>
+        <n-th>代码</n-th>
+        <n-th>名称</n-th>
+        <n-th>最新价</n-th>
+        <n-th>涨跌幅</n-th>
+        <n-th>换手率</n-th>
+        <n-th>成交额/万</n-th>
+        <n-th>流出资金/万</n-th>
+        <n-th>流入资金/万</n-th>
+        <n-th>净流入/万</n-th>
+        <n-th>净流入率</n-th>
+        <n-th v-if="sort === 'r0_net'||sort==='r0_out'">主力流出/万</n-th>
+        <n-th v-if="sort === 'r0_net'">主力流入/万</n-th>
+        <n-th v-if="sort === 'r0_net'">主力净流入/万</n-th>
+        <n-th >主力净流入率</n-th>
+        <n-th v-if="sort === 'r3_net'||sort==='r3_out'">散户流出/万</n-th>
+        <n-th v-if="sort === 'r3_net'">散户流入/万</n-th>
+        <n-th v-if="sort === 'r3_net'">散户净流入/万</n-th>
+        <n-th >散户净流入率</n-th>
+      </n-tr>
+    </n-thead>
+    <n-tbody>
+      <n-tr v-for="item in dataList" :key="item.symbol">
+        <n-td><n-tag :bordered=false type="info">{{ item.symbol }}</n-tag></n-td>
+        <n-td><n-tag :bordered=false type="info">{{ item.name }}</n-tag></n-td>
+        <n-td><n-text :type="item.trade>0?'error':'success'">{{item.trade}}</n-text></n-td>
+        <n-td><n-text :type="item.changeratio>0?'error':'success'">{{(item.changeratio*100).toFixed(2)}}%</n-text></n-td>
+        <n-td><n-text :type="item.turnover>500?'error':'info'">{{(item.turnover/100).toFixed(2)}}%</n-text></n-td>
+        <n-td><n-text type="info">{{(item.amount/10000).toFixed(2)}}</n-text></n-td>
+        <n-td><n-text type="info"> {{(item.outamount/10000).toFixed(2)}}</n-text></n-td>
+        <n-td><n-text type="info"> {{(item.inamount/10000).toFixed(2)}}</n-text></n-td>
+        <n-td><n-text type="info"> {{(item.netamount/10000).toFixed(2)}}</n-text></n-td>
+        <n-td><n-text :type="item.ratioamount>0?'error':'success'"> {{(item.ratioamount*100).toFixed(2)}}%</n-text></n-td>
+        <n-td v-if="sort === 'r0_net'||sort==='r0_out'"><n-text  type="success"> {{(item.r0_out/10000).toFixed(2)}}</n-text></n-td>
+        <n-td v-if="sort === 'r0_net'"><n-text  type="error"> {{(item.r0_in/10000).toFixed(2)}}</n-text></n-td>
+        <n-td v-if="sort === 'r0_net'"><n-text :type="item.r0_net>0?'error':'success'"> {{(item.r0_net/10000).toFixed(2)}}</n-text></n-td>
+        <n-td ><n-text :type="item.r0_ratio>0?'error':'success'"> {{(item.r0_ratio*100).toFixed(2)}}%</n-text></n-td>
+        <n-td v-if="sort === 'r3_net'||sort==='r3_out'"><n-text  type="success"> {{(item.r3_out/10000).toFixed(2)}}</n-text></n-td>
+        <n-td v-if="sort === 'r3_net'"><n-text  type="error"> {{(item.r3_in/10000).toFixed(2)}}</n-text></n-td>
+        <n-td v-if="sort === 'r3_net'"><n-text :type="item.r3_net>0?'error':'success'"> {{(item.r3_net/10000).toFixed(2)}}</n-text></n-td>
+        <n-td ><n-text :type="item.r3_ratio>0?'error':'success'"> {{(item.r3_ratio*100).toFixed(2)}}%</n-text></n-td>
+      </n-tr>
+    </n-tbody>
+  </n-table>
+</template>
+
+<style scoped>
+
+</style>
--- a/frontend/wailsjs/go/main/App.d.ts
+++ b/frontend/wailsjs/go/main/App.d.ts
@ -33,8 +33,12 @@ export function GetGroupList():Promise<Array<data.Group>>;

 export function GetGroupStockList(arg1:number):Promise<Array<data.GroupStock>>;

+export function GetIndustryMoneyRankSina(arg1:string):Promise<Array<Record<string, any>>>;
+
 export function GetIndustryRank(arg1:string,arg2:number):Promise<Array<any>>;

+export function GetMoneyRankSina(arg1:string):Promise<Array<Record<string, any>>>;
+
 export function GetPromptTemplates(arg1:string,arg2:string):Promise<any>;

 export function GetStockCommonKLine(arg1:string,arg2:string,arg3:number):Promise<any>;
--- a/frontend/wailsjs/go/main/App.js
+++ b/frontend/wailsjs/go/main/App.js
@ -62,10 +62,18 @@ export function GetGroupStockList(arg1) {
  return window['go']['main']['App']['GetGroupStockList'](arg1);
 }

+export function GetIndustryMoneyRankSina(arg1) {
+  return window['go']['main']['App']['GetIndustryMoneyRankSina'](arg1);
+}
+
 export function GetIndustryRank(arg1, arg2) {
  return window['go']['main']['App']['GetIndustryRank'](arg1, arg2);
 }

+export function GetMoneyRankSina(arg1) {
+  return window['go']['main']['App']['GetMoneyRankSina'](arg1);
+}
+
 export function GetPromptTemplates(arg1, arg2) {
  return window['go']['main']['App']['GetPromptTemplates'](arg1, arg2);
 }