m

cmd/stock/main.go

@@ -175,7 +175,7 @@ func main() {
 					continue
 				}
 
-				msg_ := st.Msg()
+				msg_ := st.Msg(false)
 				if msg_ != "" {
 					err = msg.Send(msg_)
 					if err != nil {

stock/stock.go

@@ -272,12 +272,12 @@ func (sk *stocks) FinishSendAll() {
 	}
 }
 
-func (sk *stocks) Msg() string {
+func (sk *stocks) Msg(all bool) string {
 	sk.mx.RLock()
 	defer sk.mx.RUnlock()
 	var resp string
 	for _, s := range sk.stkMap {
-		if s.needSend {
+		if all || s.needSend {
 			msg := s.Msg()
 			resp = resp + msg + "\n"
 		}
@@ -286,7 +286,7 @@ func (sk *stocks) Msg() string {
 }
 
 func (sk *stocks) Arg(openid string) map[string]interface{} {
-	msg := sk.Msg()
+	msg := sk.Msg(false)
 	if msg == "" {
 		return nil
 	}

stock/stock_test.go

@@ -11,5 +11,5 @@ func Test_newStocks(t *testing.T) {
 		fmt.Println(err)
 		return
 	}
-	fmt.Println(ss.Msg())
+	fmt.Println(ss.Msg(true))
 }

wxgzh/wxgzh.go

@@ -192,7 +192,7 @@ func Handle(c *gin.Context) {
 			if err != nil {
 				wMsg.Content = "查询错误：\n" + err.Error()
 			} else {
-				msg := stks.Msg()
+				msg := stks.Msg(true)
 				if msg == "" {
 					wMsg.Content = "您未订阅任何股票！"
 				} else {