1

zj

2024-06-13 8eea5be3b36875bd4ffe70e6c3a5bb07b1d829bf

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
Êþº¾4
ë
uãä    så
æç
è
éïðñ
òóðôõ
ã
ùú
ûüý
þÿ
 
 
þ
        s

 
æ


 
þ

s

 
 
&


(





    s

 
!
"
 
#
$
 
%
&
 
'
(
 
)
*
 
+
,
 
-
.
 
/
0
 
1
2
 
3
4
5

6
7


8
s
9
[
:


;
J
<
L
=
>
Jã
?
Lã
J
@


A


B
R
C
D
Rã


E
Q€


F
s
G
s
H
I
s
J
K
[ã
[
L


M
N
_ã
Y

_
=
Y
O
_
P
Y
Q

R
S
_
T
Y
U
_
V
Y
W
_
X
Y
lã
l
Z
[
l
\


]
 
^
_

`
a
b
c
log
Lorg/slf4j/Logger;
sysparaService
1Lcom/yami/trading/service/syspara/SysparaService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
itemService
+Lcom/yami/trading/service/item/ItemService;
klineService
3Lcom/yami/trading/huobi/data/internal/KlineService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
6Lcom/yami/trading/huobi/data/internal/DataServiceImpl;
realtimeByType
$(Ljava/lang/String;)Ljava/util/List;

symbolType
Ljava/lang/String;
items
Ljava/util/List;
list
LocalVariableTypeTable
:Ljava/util/List<Lcom/yami/trading/bean/item/domain/Item;>;
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
    Signature
R(Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
realtime
,Lcom/yami/trading/bean/data/domain/Realtime;
item
(Lcom/yami/trading/bean/item/domain/Item;
    oneSymbol
    symbolArr
[Ljava/lang/String;
symbols
 StackMapTableõ
d
_
eš
I
kline
6(Ljava/lang/String;Ljava/lang/String;)Ljava/util/List;
)Lcom/yami/trading/bean/data/domain/Kline;

i

I

e
&Ljava/lang/CloneNotSupportedException;
symbol
line
bySymbol

timeObject
6Lcom/yami/trading/huobi/data/internal/KlineTimeObject;

list_clone
;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;

f


a(Ljava/lang/String;Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;
trend
trendTimeObject
6Lcom/yami/trading/huobi/data/internal/TrendTimeObject;
K
O(Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Trend;>;
depth
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Depth;
)Lcom/yami/trading/bean/data/domain/Depth;
6Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
>
trade
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Trade;
6Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
D
    loadTrend
€(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/TrendTimeObject;)Lcom/yami/trading/huobi/data/internal/TrendTimeObject;
history_500
)Lcom/yami/trading/bean/data/domain/Trend;
interval
num
history
 realtime_last
;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Trend;>;
bulidNum
#(Ljava/util/List;I)Ljava/util/List;
    cacheList
(Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;I)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
take500
"(Ljava/util/List;)Ljava/util/List;
~(Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;

bulidTrend
W(Lcom/yami/trading/bean/data/domain/Realtime;)Lcom/yami/trading/bean/data/domain/Trend;
klineCryptos
hobiOne
lastOne
lambda$realtimeByType$1
;(Ljava/util/List;Lcom/yami/trading/bean/item/domain/Item;)V
lambda$realtimeByType$0
=(Ljava/lang/String;Lcom/yami/trading/bean/item/domain/Item;)Z
<clinit>

SourceFile
DataServiceImpl.java
(Lorg/springframework/stereotype/Service;
value
dataService‚
java/util/ArrayList}~
gŽ
h
i
j
k
BootstrapMethods
l
m
n
o
p
q
r
s
t
u
v
w
x
y
java/util/List
z
{
|
}
~

€

‚
ƒ

,
e
„
ƒ
…
†
‡
ˆ
m
‰
Š
d
‹
Œ

Ž
&com/yami/trading/bean/item/domain/Item


‘
’wx
realtime is null; å¸ç§->{}
“
”
•
–
—
cryptos
˜

™
mÖ¤
š
›
f
š
h
œ

ž
Ÿ
'com/yami/trading/bean/data/domain/Kline
 
Ž
$java/lang/CloneNotSupportedException
¡‚
¢
‡
2com/yami/trading/huobi/data/internal/KlineConstant
1min€
£
¤
¥
5min
¦
¥
15min
§
¥
30min
¨
¥
60min
©
¥
4hour
ª
¥
1day
«
¥
5day
¬
¥
1week
­
¥
1mon
®
¥
quarter
year
¯
°
±
²
³ÄÅ
²
h
´
µ
´
¶
·
¸
4com/yami/trading/huobi/data/internal/DepthTimeObject
'com/yami/trading/bean/data/domain/Depth
¹
º
»
¼
½
¾
½
¿
4com/yami/trading/huobi/data/internal/TradeTimeObject
À
Á
‰ÍÎÑÒ
*com/yami/trading/bean/data/domain/RealtimeÔÕ
4com/yami/trading/huobi/data/internal/TrendTimeObject
Ã
±
Ä
Å
'com/yami/trading/bean/data/domain/Trend
Æ
Ç
È
É
Ê
Ë
Ì
Í
Î
Ã
Ï
Ð
Ë
Ñ
Ï
Ò
Ë
Ó
Ï
java/lang/StringBuilder
Ô
Õ

_
Ö

×
Ø
Ù
Ú
4com/yami/trading/huobi/data/internal/DataServiceImpl
Û
Ü
Ý
java/lang/Object
)com/yami/trading/service/data/DataService
java/util/Iterator
java/lang/String
4com/yami/trading/huobi/data/internal/KlineTimeObject
)com/yami/trading/service/item/ItemService
()Ljava/util/List;
(Ljava/util/Collection;)V
stream
()Ljava/util/stream/Stream;

Þ
ß
(Ljava/lang/Object;)Z
s
à
+(Lcom/yami/trading/bean/item/domain/Item;)Z
test
2(Ljava/lang/String;)Ljava/util/function/Predicate;
java/util/stream/Stream
filter
9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
java/util/stream/Collectors
toList
()Ljava/util/stream/Collector;
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
(Ljava/lang/Object;)V
s
á
+(Lcom/yami/trading/bean/item/domain/Item;)V
accept
/(Ljava/util/List;)Ljava/util/function/Consumer;
forEach
 (Ljava/util/function/Consumer;)V
cn/hutool/core/util/StrUtil
isEmpty
(Ljava/lang/CharSequence;)Z
contains
%com/yami/trading/huobi/data/DataCache
getRealtime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
add
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
    getSymbol
()Ljava/lang/String;
split
'(Ljava/lang/String;)[Ljava/lang/String;
org/slf4j/Logger
error
'(Ljava/lang/String;Ljava/lang/Object;)V
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
getType
equals
getKline
\(Ljava/lang/String;Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/KlineTimeObject;
size
()I
get
(I)Ljava/lang/Object;
clone
printStackTrace
getLatestRealTime
1com/yami/trading/huobi/data/internal/KlineService
bulidKline1Minute
i(Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Kline;
bulidKline5Minute
bulidKline15Minute
bulidKline30Minute
bulidKline60Minute
bulidKline4Hour
bulidKline1Day
bulidKline5Day
bulidKline1Week
bulidKline1Mon
java/util/Collections
sort
(Ljava/util/List;)V
getTrend
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/TrendTimeObject;
getDepth
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
+()Lcom/yami/trading/bean/data/domain/Depth;
    setSymbol
(Ljava/lang/String;)V
setDepth
,(Lcom/yami/trading/bean/data/domain/Depth;)V
putDepth
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/DepthTimeObject;)V
getTrade
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
+()Lcom/yami/trading/bean/data/domain/Trade;
putTrade
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/TradeTimeObject;)V
getCryptosRealtimeHistory
setTrend
putTrend
K(Ljava/lang/String;Lcom/yami/trading/huobi/data/internal/TrendTimeObject;)V
getTs
()Ljava/lang/Long;
setTs
(Ljava/lang/Long;)V
getClose
()D
java/lang/Double
valueOf
(D)Ljava/lang/Double;
(Ljava/lang/Double;)V
    getVolume
    setVolume
    getAmount
    setAmount
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
getKlineHoBi
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Kline;

bulidKline
»(Lcom/yami/trading/bean/data/domain/Realtime;Lcom/yami/trading/bean/data/domain/Kline;Lcom/yami/trading/bean/data/domain/Kline;Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Kline;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
â
ã
çÛÜÙÚ
"java/lang/invoke/LambdaMetafactory
metafactory
é
Lookup
InnerClasses
Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;
ê
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!su
vwxyz
{
|}~
{
|€
{
|
‚
ƒ/

*·
±„
…
†‡
ˆ‰ƒ®>»Y*´¶·¶+º¹¸    ¹
ÀM»Y·N,-º ¹-°„"(#0$<*…*>†‡>Š‹
(Œ0Ž(Œ0Ž‘’“
”‰ƒ#    Ú»Y·M+¸š +¶š+¸N-Æ,-¹W§¯+¸™N»Y*´¶·N-¹
:¹
™*¹
À:¶¸:Æ,¹W§ÿÒ§]+¸šV+¶™M+¶N-:¾66¢42:¸:Æ,¹W§²¹„
§ÿË,°„^2456!7)9,;3<B=`>j?o@xB{C~EŽF•G®HµIºJÆLÒGØP…f
”•j”•`–—B9Œµ”•®$˜‹•C™šچ‡Ú›‹
ҎB9ŒҎ‘œK
ü)ýž-ùÿ!Ÿ ¡¡

ý% ¢ùÿŸ ’“
£¤ƒ«    
ô*´+¶N-¶¶ ™
*+,¶!°+,¸":»Y·:Æ
¶#:»Y·:6¹$
¢6¹%ǧ!¹%À&¶'À&:¹W„
§ÿħ
:¶)+¸*:Æ
W
:,,¶ ™*´-,¹.:§
)/,¶ ™*´-/¹0:§
1,¶ ™*´-1¹2:§ó3,¶ ™*´-3¹4:§Ø5,¶ ™*´-5¹6:§½7,¶ ™*´-7¹8:§¢9,¶ ™*´-9¹::§‡;,¶ ™*´-;¹<:§l=,¶ ™*´-=¹>:§Q?,¶ ™*´-?¹@:§6A,¶ ™*´-A¹@:§B,¶ ™*´-B¹@:
¥ ¹W¸C°
Aƒ†(„Â0X    YZ\#],^1_8aAcPd\e_gsh}cƒl†jˆkn“o˜p›q¤r¶s¿tÑuÚvìwõx
y
z
"{
+|
=}
F~
X
a€
s
|‚
Žƒ
—„
©…
²†
ć
͈
܊
â‹
ì
ñ…zs
£¥D?¦§ˆ¨©›
Q£¥
ô†‡
ôª‹

ô«‹    
묗#
Ñ­®,
ȎA
³¯“
a”•,
Ȏ°A
³¯°œ9ü±ý²ý
úB³ý(¢´ú’µ
¶‰ƒy+¸DM*+,·EM,Æ,¶F°»Y·°„˜™š›… †‡ª‹
·¸œ
ü¹’º
»¼
ƒ¾6+¸GM,Æ,¶HN-+¶I-°»JY·KM»LY·MN-+¶I,-¶N+,¸O-°„.¤¥    ¦§¨ª«%¬*­/®4¯…4»½6†‡6ª‹
1­¾%»½œ
ü¿
ÀÁ
ƒ€ +¸PM,Æ,¶Q°»RY·SM+,¸T,¶Q°„·¹    º¼½¾…  †‡ ª‹
­Âœ
üÃÄÅ
ƒ>
Ï,ÇÌ>Ul6»Y·:*+¸V·W:*·X:¹$

ô¤7¸C»Y·:6
ô¢¹%¹W„
§ÿä:6¹$
¢)¹%ÀY:*·Z:        ¹W„
§ÿÑ+¸:Æ*+¸·Z¹W»[Y·\M,¶]+,¸^,°„fÂÄÅÆÈ!É)Ê6Ì;ÍDÎOÏ`ÎfÑjÓyԇՏ֙ӟإ٪ںÜÂÝÈÞÍà…„ G¦§D&ƍ‡”•
¶Ç    m2¦§ÇȧÁɧ¸Ž!¬Ê¥(˕φ‡Ïª‹
Ï·¸ D&Ƒ¸ŽÌ!¬Ê‘œAÿG    Ÿ ¹


úúü
ú1ü¢ÿŸ ¹Í΃ïK»Y·N+Ç-°+¹$
¤
+¹$
=+¹$
d6+¹$
¢-+¹%¹W„
§ÿã-°„&    äåæèéë4ìCëIî…4) ¦§K†‡Kύ
KɧCŽKϑ
CŽ‘œüü    
ú’ÐÑÒƒ
^»Y·M+¹$

ôl>+°6‡—›pš$,+¹%¹W§,+¹%¹W„
+¹$
¡ÿƧ,°„6 õö÷øúü#ý*þ<

K
N
Y
\
…4^†‡^ʍ
VŽKɧB¦§^ʑ
VŽ‘œý
ü
’ÓÔÕ
ƒ‘;»_Y·`M,+¶a¶b,+¶c¶d,+¶e¸f¶g,+¶h¸f¶i,+¶j¸f¶k,°„

 

#
.
9
… ;†‡;”•
3¶Ç
Ö¤ƒ    Ò+,¸"N»Y·:-Æ    -¶#:»Y·:6¹$
¢'¹%À&¶'À&:¹W„
§ÿÓ§
:¶)+¸:»lY·m+¶no¶n,¶n¶p¸q:
:¹$
ž¹$
d¹%À&:Æ%Æ Æ*´-,¹r¹W¸C°
"UX(„V




"
1
E
O
U
#X
!Z
"_
$e
%
'„
(Ž
)£
+²
,Ê
/Ï
0…zE
£¥%0¦§Z¨©҆‡Òª‹
Ò«‹Ì­®΍"°¯em”•Q×¥„NØ¥ΰ"°¯°œ'ý²ý
ú/B³þC¢´´&’µ
ÙÚ
ƒn+¶¸M
,¥*,¹W±„%& ')… Ž–—
”•œ
ü¢
ÛÜ
ƒ=    +¶*¶ ¬„
"…    Š‹    –—
݂
ƒ!
    s¸t³±
„
Þß{
à
ásâ
æ


ä
è
åêëìíîëö÷ø