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
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
Êþº¾4=
¡
$
%

$    
&
'

(
)    
*
+
,

-

.
/
0
1
/
2

3
ô

4
5
6
7
/
8
9

$
:

$    
;
<

=
>

$

?

@
A
B
C
B
D
E

F
G
$
H
I
J
I
A

K
L    
M

N
O
P
/
Q    
R
S
T

U
V

K
W

X
Y

Z
[

\

]

^
_

`
a

b
c
d
e

e

f
d
=
$
g
d
F

;
h
i    
j
kÏ

l
m
n
D
$

l
o
p
q
r
H
$@$@Y

s
t
H
u
H
v
p
J

l
w
p
x
H
y
"
z

^
{

|
H
}

Z
~



€
ëì
‚
ƒ
„
…
a
$
a
†
a
‡
ˆ
e
‰    
Š
‹
e
Œ
e

I
Ž    



‘


’
“
”
"
•
–
/
—
˜
p
™
Ÿ
 
¡

¢
£
 
¤
¥
y
‰
y
¦
§

Ÿ?„záG®{?ɖR½<6?¹™™™™™š?ã2a|ÚQ@ÿ˒:)Ç@ÿ˒:)Ç@ÿåÉä?Ó1Åo

Z
©?6âëC-?žžšu>°Æ÷ µí?h~|ᛑ>EyŽâ0Œ:>ÿZ8Zº`¹=¥ýáyd•>` l¹·}M

Z
ª

Z
«
¬
­
log
Lorg/slf4j/Logger;
lastData
(Ljava/util/concurrent/ConcurrentHashMap;
    Signature
NLjava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Ljava/lang/String;>;
logger
itemService
+Lcom/yami/trading/service/item/ItemService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
timeZoneConverterService
6Lcom/yami/trading/huobi/data/TimeZoneConverterService;
dataService
+Lcom/yami/trading/service/data/DataService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
*Lcom/yami/trading/huobi/task/DepthPushJob;
start
 StackMapTable
run

e
Ljava/lang/Exception;
6
i
depthHandle
webSocketSession
3Lcom/yami/trading/huobi/websocket/WebSocketSession;
    symbolKey
Ljava/lang/String;
    socketKey
    depthData
)Lcom/yami/trading/bean/data/domain/Depth;
realtime
,Lcom/yami/trading/bean/data/domain/Realtime;

jsonString
depth
6Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
bySymbol
(Lcom/yami/trading/bean/item/domain/Item;
symbol
type
    symbolSet
Ljava/util/Set;
depthResult
*Lcom/yami/trading/common/web/ResultObject;
depthResultMap
Ljava/util/Map;
Ljava/lang/Throwable;
LocalVariableTypeTable
#Ljava/util/Set<Ljava/lang/String;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
'
9
®
¯
°
E
±
²
depthRevise
_(Lcom/yami/trading/bean/data/domain/Depth;Ljava/lang/String;Ljava/lang/Double;Z)Ljava/util/Map;
.Lcom/yami/trading/bean/data/domain/DepthEntry;

i

I
 addPriceValue

D
addAmountValue
price
amount

j
timeZone
dateStr
format
df
Ljava/text/DecimalFormat;

depthEntry
asks_map
    priceTemp
bids_map
data
close
Ljava/lang/Double;
random

Z
map
item
    asks_list
Ljava/util/List;
asksSize
bidsSize

asksPrices
bidPriceSet
    bids_list
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
GLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
³
´
µ
r
ˆ
…(Lcom/yami/trading/bean/data/domain/Depth;Ljava/lang/String;Ljava/lang/Double;Z)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
getRandomValue
(I)D
addValue
count
value
(Ljava/lang/String;I)D
valueLength
decimal

d
val
setItemService
.(Lcom/yami/trading/service/item/ItemService;)V
lambda$depthRevise$1
!(Ljava/util/Map;Ljava/util/Map;)I

a

b
priceA
priceB
lambda$depthRevise$0
<clinit>

SourceFile
DepthPushJob.java
*Lorg/springframework/stereotype/Component;²³
&java/util/concurrent/ConcurrentHashMap¥¦
(com/yami/trading/huobi/task/DepthPushJob
¶
·
¸©¤
java/lang/Thread
depthPushJob²
¹¹³
º
»
¼
启动depthPushJob！
½
¾À³
¿
À
Á
java/lang/Exception
run fail
Â
Ã
(com/yami/trading/common/web/ResultObject
java/util/HashMap
Ä
Ŧ
Æ
¼
java/util/HashSet
Ç
Ê
Ë
Ì
Í
°
Î
¼
Ï
Ð
java/lang/String
Ñ
Ò
1com/yami/trading/huobi/websocket/WebSocketSession
Ó
Ô
¯
Õ
Ö
×
Ø
Ùª«
Ú
Û
Ü
M---> DepthPushJob.depthHandle å½“前 symbol:{} æ²¡æœ‰å¯¹åº”的数据库记录
Ý
Þ°±
ßË
à
±
Ø
á
â
ã
ä
å
æ
´
ç
èãä
é
ê
²
ë
Ô
ì
í
î
ï
ð
ñ
®
ò
ó
ô
Ö
õ
Ô
ö
÷
java/lang/Throwable£¤
depthHandle error
³
ø
Ô
java/util/ArrayList
ù
ú
µ
û
ü
,com/yami/trading/bean/data/domain/DepthEntry
ý
þ
ÿ


ú
Ñ
ç
ñ
ü
 
    
æ
 


Õ


#
#.
java/lang/StringBuilder 
Ô
java/text/DecimalFormat²
¾ð
Ö®¯
current_time

 
"深度图设置 current_time失败
Â
¾
asks
BootstrapMethods 
!"#$%&'()*
java/math/BigDecimal+
Ô
bids,
ç-./!0
java/lang/Object
java/lang/Runnable
 java/util/Map
 java/util/Set
java/util/Iterator
4com/yami/trading/huobi/data/internal/DepthTimeObject
&com/yami/trading/bean/item/domain/Item
'com/yami/trading/bean/data/domain/Depth
java/lang/Double
java/util/List
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
)(Ljava/lang/Runnable;Ljava/lang/String;)V
org/slf4j/Logger
 isInfoEnabled
()Z
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
depthMap
isEmpty
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
getDepth
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/DepthTimeObject;
)com/yami/trading/service/item/ItemService
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
warn
'(Ljava/lang/String;Ljava/lang/Object;)V
)com/yami/trading/service/data/DataService
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Depth;
+()Lcom/yami/trading/bean/data/domain/Depth;
getRealtime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
*com/yami/trading/bean/data/domain/Realtime
getClose
()D
valueOf
(D)Ljava/lang/Double;
setData
>(Ljava/lang/Object;)Lcom/yami/trading/common/web/ResultObject;
getOpenCloseType
*com/yami/trading/service/MarketOpenChecker
isMarketOpenByItemCloseType
(Ljava/lang/String;)Z
com/alibaba/fastjson/JSONObject
toJSONString
&(Ljava/lang/Object;)Ljava/lang/String;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
containsKey
getType
sendToMessageById
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
    getSymbol
getAsks
()Ljava/util/List;
size
()I
'com/yami/trading/common/util/RandomUtil
randomFloat
(DDI)D
    setAmount
(Ljava/lang/Double;)V
setPrice
getBids
(I)Ljava/lang/Object;
getPrice
()Ljava/lang/Double;
getDecimals
    getAmount
doubleValue
"com/yami/trading/common/util/Arith
(DD)D
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
java/math/RoundingMode
FLOOR
Ljava/math/RoundingMode;
setRoundingMode
(Ljava/math/RoundingMode;)V
(D)Ljava/lang/String;
contains
4com/yami/trading/huobi/data/TimeZoneConverterService
getTimeZoneByItemCloseType
&(Ljava/lang/String;)Ljava/lang/String;
convertTimeZone
split
'(Ljava/lang/String;)[Ljava/lang/String;
stream
()Ljava/util/stream/Stream;
12
'(Ljava/lang/Object;Ljava/lang/Object;)I
3
compare
()Ljava/util/Comparator;
java/util/stream/Stream
sorted
1(Ljava/util/Comparator;)Ljava/util/stream/Stream;
java/util/stream/Collectors
toList
()Ljava/util/stream/Collector;
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
 toPlainString
4
&(Ljava/lang/String;)Ljava/lang/Double;
parseDouble
(Ljava/lang/String;)D
(DD)I569




"java/lang/invoke/LambdaMetafactory
metafactory;
Lookup
Ì(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!¡
¢£¤¥¦
§¨©¤ª«
¬
­®¯
¬
­°±
¬
­
²³
´K
*·
*»Y·µ*¸µ±µ#%'¶
·¸
¹³
´d
%»Y*    ·
¶*´¹
™*´ ¹±µ2 34$5¶
%·¸º
$
»³
´­/*·¸§"L*´+¹¸§M¸,¿§ÿÔ # #µ&    ;?
@ <=? @#?*@¶¼½
/·¸ºL¾U¿À³
´Ä

¿»Y·L»Y·M²¶š
™»Y·N²¶¶:¹ 
™/¹!
À":²¶#À$:¶%:-¹&W§ÿÍ-¹'
:¹ 
™ã¹!
À":¸(:*´)¶*:Ç*´+¹,Ç*´-¹.W
¥0
¶/¥'¶/:¸0:    +*    ¶1¸2¶3¶4W¶5¸6™#+¸7:,¹8W*´¶9W§A*´¶:™,*´¶#¹8W§ +¸7:,¹8W*´¶9W§ÿ,¹;
™±²¶¶:¹ 
™?¹!
À":²¶#À$:¶<:¶%:,¹=À"¸>§ÿ½§L²@A+¹±
]
²?
^
¯
²?µ®+HJLO!PBQORVS_TbV€W‡X’Y—Z¤\©]µ_Ä`ËaÒbèeófùg
h
j
l
m
4p
:q
Er
Qu
Tw
]x
^{
|
Œ}
“~
š
¬€
¯„
²‚
³ƒ
¾…¶ÀOÁÂV    ÃÄBÅÄËÆÇÒÈÉ    ùÊÄ
:ÊćÊËÌ’¿Í΀ÑÏÄ
Œ ÁÂ
“ÐÄ
šÃÄ
-ÅÄ!
ŽÑÒ
§ÓÔ

ŸÕÖ
³¼×

¿·¸Ø!
ŽÑÙ
ŸÕÚºMÿ,ÛÜÝÞßú5üßþ9àáâ2* øú    ü
ßÿE
ÛB¿
ãä´
?»»Y·:B,¹8W*´)+¶C¶*:»DY·E:+¶F¹G
66        d¢6»HY·I:
 
JL¸N¸2¶O
-¶P+¶F
¹QW„    
§ÿÆ+¶R¹G
6    6
 
    d¢6»HY·I:JL¸N¸2¶O-¶P+¶R¹QW„

§ÿÆ»Y·:
+¶F¹G
6+¶R¹G
6    6¢
µ+¶F¹SÀH:»Y·: ™m*¶T¸U¶V·W9*¶X¶YŽ·Z9¶T¶Y¸[9-¶Y˜œ-¶Y¸[9§-¶YJo¸[9¶X¶Y¸[9§¶T¶Y9¶X¶Y9˜§
    ¶Vœ$ \¸2¹8W ]¸2¹8W§Ö^:¶Vš
_:§0`:6¶V¢»aY·b¶c_¶c¶d:„
§ÿÝ»eY·f:²g¶h \¶i¹8W
¶i¹j™§h
¶i¹&W ]¶i¹8W*´k¶5¶l:*´k¶m: no¶p2¹8W§:²@q¹r ¹QW„
§þJs¹t
ºu¹v¸w¹x¹8W»Y·:»DY·E:6      ¢
¾+¶R ¹SÀH:»yY¶T¸U·z¶{:*¶V·W9*¶X¶YŽ·Z9™N¶T¶Yw¸[9-¶Y—›-¶Yw¸[9§-¶YwJo¸[9¶X¶Y¸[9§¶T¶Y9¶X¶Y9˜§

»Y·:¶Vœ$\¸2¹8W]¸2¹8W§Î^:¶Vš
_:§0`:6¶V¢»aY·b¶c_¶c¶d:„
§ÿÝ»eY·f:\¶i¹8W¶i¹j™§h¶i¹&W]¶i¹8W*´k¶5¶l:*´k¶m:no¶p2¹8W§:²@q¹r¹QW„ 
§þA|¹t
º}¹v¸w¹x¹8W°P|Jvyµ
¾o‹    Œ!Ž*5B‘K’]“c”ou—€˜™–š¨›®œº˜ÀŸÉ Ô¡ß¢é£ù¤
§
¨
©
)«
8¬
B­
P¯
_³
n´
qµ
{¶
…¹
μ
½
—¾
¦¿
¸Á
¼Â
ÄÃ
ËÅ
ÏÆ
ÜÇ
òÆ
øËÌÎÏ-Ð0Ò?ÔPÖ^×iØ|Ûفڋݕ¢›á°å¸á¾æÇçÐéÚêêëþíîñò/ó9ôHöXùjûtü~ÿ…
ˆ
‘
™
¨
º
¾
Æ
    Í
Ñ
Þ
 ô
ú


'
*
9
J
X
c
v
y
{
…
"é•
&ª
*²
&¸
+¶
â0K$¼å
8=æç    –$¼åƒ=æç

Tèé
)Eêé
89ëé
nìé
Ò&íç^îÄiïā
¼½
¼ÏðĈñòù
œóå

“ôÖ 
{
ëé
…
ìéâ
¹æç/;ëégìéÔ&íçXîÄcïÄ{
¼½¾ÇðÄ€ñòê
¥óåþ
‘õÄ
„èé
uêét
ëé~
ìé‘þöÖÓ
Âæç »·¸»÷Ç
»ÏÄ»øù»úû    ²üÖ!šýÎ*‘þÿ5†
ç€;

ç    Éò
Ò
Ç
ô
ÒÐ
ë
ÿØH

“ô
 ‘þö
    ²ü
*‘þ
Éò
Ù
Ç
ô
ÙÐ
ë

º
h"ÿ8
Û
à

Ýâ
    

ú<ý 

ú<ý!Þ
ÿmÛ
à

Ýâ
    

Þ


ÝÿÛ
à

Ýâ
    

Þ


Ýý    (üàü
ú%ü7
÷N¾ùÿ    Û
à

Ýâ
    

Þ
úþ7Þ
    
ÿtÛ
à

Ýâ
    

ÞÞ
    


àúý    ü1Ýüàü
ú%ü/
÷N¾ùÿ    Û
à

Ýâ
    

ÞÞ
    
ú§

 

´
€‰ž{6ž
l<„
§ÿô ~€¸NI(¯ ‚„¸NI(¯ ‚†¸NI(¯ ˆ¸NI(¯ Š¸NI(¯Š¸NI(¯~Œ¸NI(¯µb
0
1
2
3
4
7
8'
9)
</
=:
><
AB
BM
CO
FU
G^
H`
Kf
Lo
Mq
Qz
R|
U‡
V¶f
'
é:
éM
é^
éo
éu
çz
鉷¸‰
ç
‡
éºþ
ø

 

´œ    
+¸Ž¶Y9Ž6ž~6ž
l6„
§ÿñ ~€¸NJ)¯ ‚„¸NJ)¯ ‚†¸NJ)¯ ˆ¸NJ)¯ Š¸NJ)¯Š¸NJ)¯6£‘¸NJ)¯¢£“•¸NJ)¯¢£—™¸NJ)¯¢
£—™
¸NJ)¯›¸NJ)¯µž'
\    
]
_
`
a
b"
c(
f.
g9
h;
kA
lL
mN
pT
q_
ra
ug
vp
wr
zx
{
|ƒ
€Œ
Ž
ˆ‘
‰—
Š¢
‹¤
Ž±
½
¿
“Í
”Ù
•Û
˜é
™õ
š÷
œ

¶¶9
éL
é_
ép
é
éx
çŒ
é¢
é½
éÙ
éõ
é‘t
ç
·¸

Ä


ç

é    ü
é÷
çº%ÿÛà


ú
ü




´>*+µ)±µ

£
¤¶·¸ª«




´t$*\¹=À"M+\¹=À"N,¸Ÿ-¸Ÿ¸ ¬µ
'
(
)¶*$
Ö$
Ö

Ä
Ä



´t$*\¹=À"M+\¹=À"N,¸Ÿ-¸Ÿ¸ ¬µâãä¶*$
Ö$
Ö

Ä
Ä
 ³
´!
    ¸³@±
µ
"
!
"¬

#
É
@
È    7:8
š
›
œ

ž
›
œ
¨
ž