From 4d3ac3836dde687d1eaa01b68982f01c8fb877f2 Mon Sep 17 00:00:00 2001
From: yanweidong <david.yan@qq.com>
Date: Wed, 8 Apr 2026 11:21:40 +0800
Subject: [PATCH] fix bug

---
 models/models.go   | 1 +
 storage/storage.go | 8 ++++++++
 types/req.go       | 6 ++++++
 3 files changed, 15 insertions(+)

diff --git a/models/models.go b/models/models.go
index e313a06..afaf87a 100644
--- a/models/models.go
+++ b/models/models.go
@@ -31,6 +31,7 @@ type CollectorOrder struct {
 	Ymd          int            `json:"ymd" gorm:"not null;index;comment:采集日期（年月日数字格式，如20260407）"`
 	Price        float64        `json:"price" gorm:"type:decimal(10,4);not null;default:0;comment:委托价格"`
 	Volume       int            `json:"volume" gorm:"not null;default:0;comment:委托数量"`
+	OpenPrice    float64        `json:"open_price" gorm:"type:decimal(10,4);not null;default:0;column:open_price;comment:开仓价格"`
 	TradedPrice  float64        `json:"traded_price" gorm:"type:decimal(10,4);not null;default:0;column:traded_price;comment:成交均价"`
 	TradedVolume int            `json:"traded_volume" gorm:"not null;default:0;column:traded_volume;comment:成交数量"`
 	OrderStatus  int            `json:"order_status" gorm:"not null;default:0;column:order_status;comment:订单状态"`
diff --git a/storage/storage.go b/storage/storage.go
index 1d83c5d..a77fa78 100644
--- a/storage/storage.go
+++ b/storage/storage.go
@@ -1,6 +1,7 @@
 package storage
 
 import (
+	"encoding/json"
 	"fmt"
 	"log"
 	"time"
@@ -138,6 +139,12 @@ func (s *Storage) SaveStatus(status *types.Status, dataHash string) error {
 				if order.StockCode == "" {
 					continue
 				}
+				var open_price float64
+				var info types.OrderInfo
+				err = json.Unmarshal([]byte(order.OrderRemark), &info)
+				if err == nil {
+					open_price = info.Op
+				}
 
 				// 查询是否存在
 				var existingOrder models.CollectorOrder
@@ -151,6 +158,7 @@ func (s *Storage) SaveStatus(status *types.Status, dataHash string) error {
 					Ymd:          ymd,
 					Price:        order.Price,
 					Volume:       order.Volume,
+					OpenPrice:    open_price,
 					TradedPrice:  order.TradedPrice,
 					TradedVolume: order.TradedVolume,
 					OrderStatus:  order.OrderStatus,
diff --git a/types/req.go b/types/req.go
index d07c7f6..3145668 100644
--- a/types/req.go
+++ b/types/req.go
@@ -82,3 +82,9 @@ type Config struct {
 	QmtStatus   string `json:"qmt_status"`
 	StartTime   int64  `json:"start_time"`
 }
+
+type OrderInfo struct {
+	Op  float64 `json:"op"`
+	Pnl float64 `json:"pnl"`
+	Ac  int     `json:"ac"`
+}