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
Êþº¾4
¡
uÙÚÛ
Ü
Ý    sÞßàá
sâ
ô
ãäåæàçè
Ùé
ٝ
êë
ì
í    îï
ðñò
Ù
ðó
ôõö÷öøù
ðúû
"üýþýõ—
ÿ




    s

 
,



 
    
s


ì

 
 



ñ
"

ú
î


9

 
<Ù





@


BÙ
B


 

 ¹
@

!
@
"
@
#

$
%
s
&
@
'

(
)
,
*¿

$
+À
,
-
.
/
XÙ
X
0
X
1
2
\
3    
4
5
\
6
\
7
þ?„záG®{?ɖR½<6

8
9?¹™™™™™š?ã2a|ÚQ@ÿ˒:)Ç@ÿ˒:)Ç@ÿåÉä?Ó1Åo
:

;
<
=
>
log
Lorg/slf4j/Logger;
itemService
+Lcom/yami/trading/service/item/ItemService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
*Lcom/yami/trading/huobi/task/TradePushJob;
start
run

e
Ljava/lang/Exception;
 StackMapTableå

realtimeHandle
webSocketSession
3Lcom/yami/trading/huobi/websocket/WebSocketSession;
    symbolKey
Ljava/lang/String;
    socketKey
result
Ljava/util/Map;
    tradeData
)Lcom/yami/trading/bean/data/domain/Trade;
trade
6Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
symbol
type
    symbolSet
Ljava/util/Set;
tradeResult
*Lcom/yami/trading/common/web/ResultObject;
data
Ljava/util/HashMap;
tradeResultMap
Ljava/lang/Throwable;
LocalVariableTypeTable
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
#Ljava/util/Set<Ljava/lang/String;>;
9Ljava/util/HashMap<Ljava/lang/Object;Ljava/lang/Object;>;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/String;>;
:èé
?
@
Aù
B
C
tradeRevise
L(Lcom/yami/trading/bean/data/domain/Trade;Ljava/lang/String;)Ljava/util/Map;

j

I
format
df
Ljava/text/DecimalFormat;

tradeEntry
.Lcom/yami/trading/bean/data/domain/TradeEntry;
tradeEntry_map
    direction
random
Ljava/util/Random;
 addPriceValue

D
addAmountValue
price
amount

i
map
item
(Lcom/yami/trading/bean/item/domain/Item;
tradeEntry_list
Ljava/util/List;
GLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;

D


    Signature
r(Lcom/yami/trading/bean/data/domain/Trade;Ljava/lang/String;)Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
getRandomValue
(I)D
addValue
count
value
setItemService
.(Lcom/yami/trading/service/item/ItemService;)V
<clinit>

SourceFile
TradePushJob.java
*Lorg/springframework/stereotype/Component;}~
java/lang/Thread
tradePushJob}
E„~wx
启动tradePushJob！
F
G
H‹~
I
J
K
java/lang/Exception
run fail
L
M
(com/yami/trading/common/web/ResultObject
java/util/HashMap
N
O
P
Q
R
S
T
U
V
W
X
Y
Z
java/util/HashSet
[
^
_
`
a
A
b
Z
c
d
java/lang/String
e
f
1com/yami/trading/huobi/websocket/WebSocketSession
g
h
@
i
j
k
l
m
B
l
nyz
o
p
q
r
h
&com/yami/trading/bean/item/domain/Item
cryptos
s
t¯°
?
ts
C
u
v
w
x
y
z
{
|
}
java/lang/Throwable
~~

h
java/util/ArrayList
D
€

e
‚
,com/yami/trading/bean/data/domain/TradeEntry
ƒ
h
java/util/Random
„
Z
buy
…
j
sell
current_time
†
h
‡
ˆ
‰
Š
‹ÎÏ
Œ
ˆ

i
Ž



‘


#
#.
java/lang/StringBuilder
’
“
”
h
java/text/DecimalFormat}
H
•
–
—
˜
™³
š
›
œ

(com/yami/trading/huobi/task/TradePushJob
ž
Ÿ
 
java/lang/Object
java/lang/Runnable
 java/util/Map
 java/util/Set
java/util/Iterator
4com/yami/trading/huobi/data/internal/TradeTimeObject
'com/yami/trading/bean/data/domain/Trade
java/util/List
)(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
com/google/common/collect/Lists
newArrayList
()Ljava/util/ArrayList;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
setData
>(Ljava/lang/Object;)Lcom/yami/trading/common/web/ResultObject;
0com/yami/trading/huobi/websocket/WebSocketServer
tradeMap
(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
getTrade
J(Ljava/lang/String;)Lcom/yami/trading/huobi/data/internal/TradeTimeObject;
+()Lcom/yami/trading/bean/data/domain/Trade;
)com/yami/trading/service/item/ItemService
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
getType
equalsIgnoreCase
(Ljava/lang/String;)Z
getTs
()Ljava/lang/Long;
getData
()Ljava/util/List;
com/alibaba/fastjson/JSONObject
toJSONString
&(Ljava/lang/Object;)Ljava/lang/String;
sendToMessageById
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
printStackTrace
    getSymbol
size
()I
(I)Ljava/lang/Object;
getDirection
nextBoolean
equals
getCurrent_time
getPrice
()Ljava/lang/Double;
java/lang/Double
doubleValue
()D
    getAmount
"com/yami/trading/common/util/Arith
(DD)D
getDecimals
valueOf
(D)Ljava/lang/Double;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
java/math/RoundingMode
FLOOR
Ljava/math/RoundingMode;
setRoundingMode
(Ljava/math/RoundingMode;)V
(D)Ljava/lang/String;
'com/yami/trading/common/util/RandomUtil
randomFloat
(DDI)D
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!su
vwxyz
{
|
}~
/

*·
±€
!
‚ƒ
„~
J
»Y*·¶²¹±€% &'
‚ƒ
…~
¬.*·    
¸§!L²+¹
¸§M
¸,¿§ÿÕ  " "€&    -1
2 ./12"1)2†‡
.‚ƒˆL‰TŠ‹~
ƒ

“»Y·L»Y·M,¸¶W+,¶W»Y·N²¶š
\»Y·:²¶¶:¹
™0¹
À :²¶!À":¶#:¹$W§ÿ̹%
:¹
™£¹
À :,&¶W¸':
¥q
¶(¥h¶(:*´)¶*¶+-¶.™+*·/¶W§=»Y·:        &¹0W    1¶2¹0W    ¶3¹0W+    ¶W-+¸4¹0W§ÿY-¹5
™±²¶¶:¹
™?¹
À :²¶!À":¶6:¶#:    -    ¹7À ¸8§ÿ½§L+¶:±
8
9
9
Š
9€š&9:;< =(?1B:C[DhEoFyG|I›J¤K«LºMÁNÕOåQîRúS
    T
U
X
,Z
/\
8]
9`
Zg
gi
nj
uk
‡l
Šp
n
Žo
’q¬hŒo
Ž[î1‘’    Á^“”«•–›‘—
g Œ
n˜
uŽ    
Z-:
P™š
‚›œ

zž(
bŸ’
Ž† 

“‚ƒ¡*î1‘¢    :
P™£
z¤(
bŸ¥ˆLÿE¦§¨©ª«ú6ü«þ_¬­®ú9ø    ü
«ÿE
¦BŠ¯°Û
­»Y·N-&,¹0W-1+¶2¹0W*´)+¶;¶*:»<Y·=:6+¶3¹>
¢
]+¶3¹?À@:»Y·:¶A:    »BY·C:
 
¶D™E    ¶F™
G:    §E:    H    ¹0W1¶I¹0WJ¶K¹0W*¶L¶MŽ·N9*¶O¶MŽ·N9 ¶L¶M¸P9¶O¶M ¸P9¶Qœ$R¸S¹0WT¸S¹0W§xU:¶Qš
V:§0W:6¶Q¢»XY·Y¶ZV¶Z¶[:„
§ÿÝ»\Y·]:²^¶_R¶`¹0WT¶`¹0W¹aW„
§þ›-¹0W-°€ž'wxyz,{5}F~V_€fo‚wƒ„ˆ†Œ‰˜Š§‹¶ÅŽÔã‘ò“ú”
    •
—
˜
'™
.›
2œ
?
Uœ
[¡
f¢
n¤
¥
§
š}
 ª
««¶
5&±²
q³
f*´µV
D¶·_
;¸’f
4¹    o
+º»
ÅÕ¼½Ôƾ½ ã·¿½ò¨À½8
hÁ²
­‚ƒ
­”

­—
¥Â’,
ÃÄ5
xÅÆ¡ _
;¸¢
¥Â¢5
xÅLj–    ÿ8¦®¬©ÈÉ
ÿO¦®¬©ÈÉ
Ê©¬ËÿŽ¦®¬©ÈÉ
Ê©¬Ëü¬ü
ú%ú4ÿ¦®¬©ÈÉÌÍÎÏ

€‰ž{6ž
l<„
§ÿô bd¸fI(¯ gi¸fI(¯ gk¸fI(¯ m¸fI(¯ o¸fI(¯o¸fI(¯bq¸fI(¯€b°±²³´·¸'¹)¼/½:¾<ÁBÂMÃOÆUÇ^È`ËfÌoÍqÑzÒ|Շցf
'н:нMн^нoнuѲz퉂ƒ‰Ò²
‡нˆþ
ø

ÓÔ
>*+µ)±€
Û܁‚ƒyz
Õ~
!
    s¸t³±
€
 Ö×{
Ø
]

ôð
\