From 4d844992b71109c9c1782ddf46442f785a8a4a1e Mon Sep 17 00:00:00 2001
From: "zhangkun9038@dingtalk.com" <zhangkun9038@dingtalk.com>
Date: Mon, 23 Dec 2024 10:59:59 +0800
Subject: [PATCH] stock rsi
---
modules/extent.go | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/modules/extent.go b/modules/extent.go
index 9012ab8..3a3f496 100644
--- a/modules/extent.go
+++ b/modules/extent.go
@@ -154,7 +154,7 @@ func LoopMakeMaX(cr *core.Core) {
go func(cad *core.Candle) {
//当一个candle的多个时间点的数据几乎同时到达时，顺序无法保证，制作maX会因为中间缺失数据而计算错，因此，等待一秒钟等数据都全了再算
// sz := utils.ShaiziInt(1500) + 500
- time.Sleep(time.Duration(30) * time.Millisecond)
+ time.Sleep(time.Duration(1500) * time.Millisecond)
err, ct := MakeMaX(cr, cad, 7)
logrus.Warn(GetFuncName(), " ma7 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
//TODO 这个思路不错，单行不通，远程redis禁不住这么频繁的请求
@@ -163,23 +163,23 @@ func LoopMakeMaX(cr *core.Core) {
go func(cad *core.Candle) {
//当一个candle的多个时间点的数据几乎同时到达时，顺序无法保证，制作maX会因为中间缺失数据而计算错，因此，等待一秒钟等数据都全了再算
// sz := utils.ShaiziInt(2000) + 500
- time.Sleep(time.Duration(30) * time.Millisecond)
+ time.Sleep(time.Duration(1600) * time.Millisecond)
err, ct := MakeMaX(cr, cad, 30)
logrus.Warn(GetFuncName(), " ma30 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
// cd.InvokeRestQFromRemote(cr, ct)
}(cd)
go func(cad *core.Candle) {
- time.Sleep(time.Duration(300) * time.Millisecond)
+ time.Sleep(time.Duration(1700) * time.Millisecond)
err, ct := MakeRsi(cr, cad, 14, true)
logrus.Warn(GetFuncName(), " rsi14 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
}(cd)
go func(cad *core.Candle) {
- time.Sleep(time.Duration(300) * time.Millisecond)
+ time.Sleep(time.Duration(1700) * time.Millisecond)
err, ct := MakeRsi(cr, cad, 12, false)
logrus.Warn(GetFuncName(), " rsi12 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
}(cd)
go func(cad *core.Candle) {
- time.Sleep(time.Duration(300) * time.Millisecond)
+ time.Sleep(time.Duration(1700) * time.Millisecond)
err, ct := MakeRsi(cr, cad, 24, false)
logrus.Warn(GetFuncName(), " rsi24 err:", err, " ct:", ct, " cd.InstID:", cd.InstID, " cd.Period:", cd.Period)
}(cd)