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
Êþº¾4
Í
€ÔÕÖ
×
Ø    ~ÙÚÛÜ
~Ýè
ÞßàáÛâã
Ô    äå
æçè
Ô
æé
êëìíìîï
æðñ
òóôóë
õö÷Ûø
~ùúç
ûúð
äüý
(þÿ
*Ô

,Ô    ~


 


 ú





    
 
 
 
 
 
 


±


³


´


µ
 
 
 



 


!
"


#
$


%
&


'
(


)
*


+
,


-
.


/
0


1
õ
2
3


4

5
6
7
eÔ    ~
8


9

:
;
e
<

=
>
?
e
@
A
e
BÁ

C
Dú
Eú
F

G
H

I
J    
K
L

G
M¡

û
Nô
*
O


P

Q
R
S

T
U
V
W
log
Lorg/slf4j/Logger;
itemService
+Lcom/yami/trading/service/item/ItemService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
timeZoneConverterService
6Lcom/yami/trading/huobi/data/TimeZoneConverterService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
-Lcom/yami/trading/huobi/task/RealtimePushJob;
start
run

e
Ljava/lang/Exception;
 StackMapTableàý
realtimeHandle
webSocketSession
3Lcom/yami/trading/huobi/websocket/WebSocketSession;
    symbolKey
Ljava/lang/String;
    socketKey
realtimeData
,Lcom/yami/trading/bean/data/domain/Realtime;
symbol
type
    symbolSet
Ljava/util/Set;
realtimeResultMap
Ljava/util/Map;
Ljava/lang/Throwable;
LocalVariableTypeTable
#Ljava/util/Set<Ljava/lang/String;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
X
Y
Zï
[
realtimeRevise
P(Ljava/util/Map;Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;)V
open
Ljava/math/BigDecimal;
close
high
low
key
realtime
realtimeResult
*Lcom/yami/trading/common/web/ResultObject;
list
Ljava/util/List;
map
bySymbol
(Lcom/yami/trading/bean/item/domain/Item;
decimal
Ljava/lang/Integer;
market
/Lcom/yami/trading/bean/data/domain/StockMarket;
stringObjectMap
GLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;ÿ
\
S
]
^
7
_
V
    Signature
v(Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;)V
<clinit>

SourceFile
RealtimePushJob.java
*Lorg/springframework/stereotype/Component;Š‹
java/lang/Thread
realtimePushJobŠ
`‘‹‚ƒ
启动realtimePushJob！
a
b
c˜‹
d
e
f
java/lang/Exception
run fail
g
h
java/util/HashMap
i
j
k
l
m
n
java/util/HashSet
o
r
s
t
u
Z
v
n
w
x
java/lang/String
y
z
1com/yami/trading/huobi/websocket/WebSocketSession
{
|
Y
}
~

€

$realtimeHandle èŽ·å–{} æ•°æ®ä¸ºç©º
g
‚¯°
X
ƒ
|
„
…
java/lang/Throwable
†‹
(com/yami/trading/common/web/ResultObject
java/util/ArrayList„…
‡
ˆ
‰
Š
‹
Œ

    timestamp
[
Ž

current_time

|
name
]
‘
|
enName
’
|
change_ratio
“
”
•
–
—
    netChange
˜
”
™
”
š
”
›
”
œ
”
volume

”
amount
ž
”
chg
Ÿ
”
percent
 
”
pb
¡
”
navps
¢
”
turnoverRate
£
”
    amplitude
¤
”
eps
¥
”
 marketCapital
¦

ask
§
”
bid
¨
”
©
ª

1
«
|
¬
~
AAPL
-com/yami/trading/bean/data/domain/StockMarketˆ‰
­
|
®
¯
°
±
c
²
³
´
    äº¤æ˜“中
µ
c
    æœªå¼€ç›˜
¶‹
·
¸
¹
o
º
»
~
_
–
¼
^
½
¾
¿
À
Á
Â
Ã
\
Ä
Å
Æ
|
Ç
È
É
+com/yami/trading/huobi/task/RealtimePushJob
Ê
Ë
Ì
java/lang/Object
java/lang/Runnable
 java/util/Map
 java/util/Set
java/util/Iterator
*com/yami/trading/bean/data/domain/Realtime
java/util/List
&com/yami/trading/bean/item/domain/Item
java/lang/Integer
java/math/BigDecimal
)(Ljava/lang/Runnable;Ljava/lang/String;)V
org/slf4j/Logger
info
(Ljava/lang/String;)V
(com/yami/trading/common/util/ThreadUtils
sleep
(J)V
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
0com/yami/trading/huobi/websocket/WebSocketServer
realtimeMap
(Ljava/util/concurrent/ConcurrentHashMap;
&java/util/concurrent/ConcurrentHashMap
isEmpty
()Z
keySet

KeySetView
InnerClasses
5()Ljava/util/concurrent/ConcurrentHashMap$KeySetView;
1java/util/concurrent/ConcurrentHashMap$KeySetView
iterator
()Ljava/util/Iterator;
hasNext
next
()Ljava/lang/Object;
get
&(Ljava/lang/Object;)Ljava/lang/Object;
getParam
()Ljava/lang/String;
add
(Ljava/lang/Object;)Z
%com/yami/trading/huobi/data/DataCache
getRealtime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
'(Ljava/lang/String;Ljava/lang/Object;)V
getType
sendToMessageById
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
printStackTrace
)com/yami/trading/service/item/ItemService
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;

getDecimal
'(Ljava/lang/String;)Ljava/lang/Integer;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
getTs
()Ljava/lang/Long;
getCurrentTime
 getSourceName
    getEnName
getChangeRatio
()D
java/lang/Double
valueOf
(D)Ljava/lang/Double;
getNetChange
getOpen
getClose
getHigh
getLow
    getVolume
    getAmount
getChg

getPercent
getPb
getNavps
getTurnoverRate
getAmplitude
getEps
getMarketCapital
getAsk
getBid
    getMarket
C(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/StockMarket;
getFake
equals
getOpenCloseType
4com/yami/trading/huobi/data/TimeZoneConverterService
getTimeZoneByItemCloseType
&(Ljava/lang/String;)Ljava/lang/String;
setTime_zone
*com/yami/trading/service/MarketOpenChecker
isMarketOpenByItemCloseType
(Ljava/lang/String;)Z
    setStatus
    calculate
cn/hutool/core/bean/BeanUtil
    beanToMap
#(Ljava/lang/Object;)Ljava/util/Map;
()Ljava/util/Set;
containsKey
(D)Ljava/math/BigDecimal;
intValue
()I
java/math/RoundingMode
HALF_UP
Ljava/math/RoundingMode;
setScale
1(ILjava/math/RoundingMode;)Ljava/math/BigDecimal;
setData
>(Ljava/lang/Object;)Lcom/yami/trading/common/web/ResultObject;
    getSymbol
com/alibaba/fastjson/JSONObject
toJSONString
&(Ljava/lang/Object;)Ljava/lang/String;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!~€
‚ƒ„…
†
‡ˆ‰
†
‡
Š‹
Œ/

*·
±
"Ž

‘‹
ŒJ
»Y*·¶²¹±* +,Ž

’‹
Œ¬.*·    
¸§!L²+¹
¸§M
¸,¿§ÿÕ  " "&    37
8 4578"7)8Ž“”
.•L–T—˜‹
Œa÷»Y·L²¶šà»Y·M²¶¶N-¹
™.-¹
À:²¶À:¶:,¹W§ÿÏ,¹
N-¹
™2-¹
À:¸ :Dz!¹"*+·#§ÿË+¹$
™±²¶¶N-¹
™>-¹
À:²¶À:¶%:¶:+¹&À¸'§ÿ¿§L+¶)±Ÿñ( îñ(j>ADE7FDGKHTIWKrLyM~NŠP“Q–SŸT W¾^Ë`ÒaÙbëcîhñfògöjŽ„ D™šK    ›œ7œyžŸr! œË ™šÒ¡œÙ›œ¾-œÕ¢£椥
ò“¦
÷§Õ¢¨椩
•2
þ#ª«¬ú3ü¬ý+­®ø    ü    ¬øCB—¯°Œ}D»*Y·+:»,Y·-:,DZ»Y·:*´.-¶/:*´.-¶0:1-¹2W3,¶4¹2W5,¶6¹2W7¶8¹2W9¶:¹2W;,¶<¸=¹2W>,¶?¸=¹2W@,¶A¸=¹2WB,¶C¸=¹2WD,¶E¸=¹2WF,¶G¸=¹2WH,¶I¸=¹2WJ,¶K¸=¹2WL,¶M¸=¹2WN,¶O¸=¹2WP,¶Q¸=¹2WR,¶S¸=¹2WT,¶U¸=¹2WV,¶W¸=¹2WX,¶Y¸=¹2WZ,¶[¹2W\,¶]¸=¹2W^,¶_¸=¹2W-¸`:    a¶b¶c™
d¸`:        ÇM»eY·f:        *´g¶h¶i¶j¶h¸k™     l¶m§
    n¶m    ¶op    ¹2W§    ¶op    ¹2W,¸q:
 
¹r
¹
:¹
™Õ¹
À:¹sšº
¹&¹2W,¶A¸t: @ Æ ¶u²v¶w§
¹2W,¶C¸t:Bƶu²v¶w§
¹2W,¶E¸t:Dƶu²v¶w§
¹2W,¶G¸t:Fƶu²v¶w§
¹2W§ÿ'x¶y¹2W¹zW¶{W+,¶|¸}¹2W±ö=q    rstv w*y4{?}M~[j€y‚Šƒ›„¬…½†Î‡ßˆð‰

Š
‹
#Œ
4
EŽ
V
g
x‘
†À
—Á
¨Â
®Ã
ȁ
ÂÇ
ÇÈ
ÐÉ
áÊ
ìË
öÍ
ýÏÐÒÓ"Õ(ÖL×XØkÙtڔ۝ܽÝÆÞæßïàâã!å+æ3çC莢t›±² r³²ÆI´²ï µ²LöœDD¤¥
D·ŸD œ    ;¸¹2º» $¼¥*½¾4¿À
®
–Á    (
å
§*D¤©
2ºÄ $¼Å(
ÃÅ
•SýÆÇÿ
ª
Ȫ®­ÆǪÉÊË3ýª¬ÿVȪ®­ÆǪÉÊ˪¬­Ìª­ÿȪ®­ÆǪÉÊ˪¬­Ìª­Íÿ'Ȫ®­ÆǪÉÊ˪¬­Ì̪­ÿȪ®­ÆǪÉÊ˪¬­Ì̪­Íÿ'Ȫ®­ÆǪÉÊ˪¬­ÌÌ̪­ÿȪ®­ÆǪÉÊ˪¬­ÌÌ̪­Íÿ'Ȫ®­ÆǪÉÊ˪¬­ÌÌÌ̪­ÿȪ®­ÆǪÉÊ˪¬­ÌÌÌ̪­ÍÿȪ®­ÆǪÉÊ˪¬úÎÏЋ
Œ!
    ~¸³±

!Ñ҆
Ó
q

êæ
p