1

zj

2024-06-13 66c2ab8a29786a5ee15c649890c5ec3c876c4774

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
Êþº¾4
x
>©
>ª
«¬    Z­®
Z¯
°
±²³´µ´¶·
¸    Z¹
º»
º¼
º½
¾¿ÀÁÂ
¾ÃÄ
Å@@
ÆÇ    ZÈ
ÆÉ
Ê
ËÀÌ
Í
ÎÏ
ÎÐ
ºÑÀÒ
ÓÔ
ÕÖ    ×Ø
ÓÙ
ÓÍ
Ú
ÆÛ
Ü
Ý
Þ
ß
à
á
â
ãäå
æç
Zè
éê    Zëìíî?Ðïðíñòóíôõ
ö÷
ãø
ãù
ú
ûü
æýþ
J©
Jÿ

J


Jü
û

 
ί
 
 
ã

 
ã
    Z
    



    Z
 

log
Lorg/slf4j/Logger;
logger
first

Z
interval

I
sysparaService
1Lcom/yami/trading/service/syspara/SysparaService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
 dataDBService
4Lcom/yami/trading/huobi/data/internal/DataDBService;
hobiDataService
-Lcom/yami/trading/huobi/hobi/HobiDataService;
itemService
+Lcom/yami/trading/service/item/ItemService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
4Lcom/yami/trading/huobi/data/job/AbstractGetDataJob;
start
run
getName
()Ljava/lang/String;
realtimeHandle
(Ljava/lang/String;)V
handleRealTimeList
(Ljava/util/List;)V
currentValueFrequency

D
    frequency
realtimeLast
,Lcom/yami/trading/bean/data/domain/Realtime;
    checkRate
rate

e
Ljava/lang/Exception;
symbol
Ljava/lang/String;
decimal
Ljava/lang/Integer;
item
(Lcom/yami/trading/bean/item/domain/Item;
currentValue
Ljava/lang/Double;

delayValue
3Lcom/yami/trading/huobi/data/model/AdjustmentValue;
realtime
realtimeList
Ljava/util/List;
LocalVariableTypeTable
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
 StackMapTable


·


ÂÄò
    Signature
A(Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;)V
saveData
i(Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;Lcom/yami/trading/bean/item/domain/Item;)V
high
low
<clinit>

SourceFile
AbstractGetDataJob.javano




_^
java/lang/Threadwxn
uo








*com/yami/trading/bean/data/domain/Realtime
 xlm
!
"
#
$
%
&
'
(
)
*
+
,
-
java/lang/Double
.
*
1com/yami/trading/huobi/data/model/AdjustmentValue
/
0
1
2
3bc
4
3
5
0
6
7
8
9
:
0

;
0
<
=
>
?
@
-
A
6
B

C
D
E
F
G
H
I
J
=
K
3
L
=
M
0
N
=
O
0
P
=
Q
0
R
=
S
T
U
虚拟货币

V
W¢£
X
Y
Z]^
2缓存里面没有realtimeLast数据, æ³¨æ„è§‚察
[
\z
P当前{}价格{},上一次价格为{}过25%也不合理,丢弃Realtime,不入库
java/lang/Object
\
]
java/lang/Exception
X---> AbstractGetDataJob.handleRealTimeList debug ä½ç½®4, realtime -> symbol:{}, error: 
\
^
数据采集失败 {}:[]
_
`
-
a
b
c
b
d
e
f
gx
h
D
java/lang/StringBuilder
i
j
000
i
k
6
l
m
n
oz
p
0
q
r
s
0
t
rhi
u
v
w
2com/yami/trading/huobi/data/job/AbstractGetDataJob`a
java/lang/Runnable
java/util/Iterator
java/util/List
java/lang/String
java/lang/Integer
&com/yami/trading/bean/item/domain/Item
getClass
()Ljava/lang/Class;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
)(Ljava/lang/Runnable;Ljava/lang/String;)V
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
    getSymbol
)com/yami/trading/service/item/ItemService
getSymbolByRemarks
&(Ljava/lang/String;)Ljava/lang/String;

getDecimal
'(Ljava/lang/String;)Ljava/lang/Integer;
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
0com/yami/trading/huobi/data/AdjustmentValueCache
getCurrentValue
()Ljava/util/Map;
 java/util/Map
get
&(Ljava/lang/Object;)Ljava/lang/Object;
 getDelayValue
    getSecond
()D
"com/yami/trading/common/util/Arith
mul
(DD)D
div
getValue
valueOf
(D)Ljava/lang/Double;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
doubleValue
getAdjustmentValue
setAdjustmentValue
(D)V
saveOrUpdate
+(Lcom/yami/trading/bean/item/domain/Item;)Z
remove
java/math/BigDecimal
(D)Ljava/math/BigDecimal;
intValue
()I
java/math/RoundingMode
HALF_UP
Ljava/math/RoundingMode;
setScale
1(ILjava/math/RoundingMode;)Ljava/math/BigDecimal;
setValue
sub
    setSecond
getClose
setClose
getAsk
setAsk
getBid
setBid
%com/yami/trading/huobi/data/DataCache
getRealtime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
contains
(Ljava/lang/CharSequence;)Z
java/lang/Math
abs
(D)D
org/slf4j/Logger
error
((Ljava/lang/String;[Ljava/lang/Object;)V
9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
com/alibaba/fastjson/JSONObject
toJSON
getRealtimeHigh
&(Ljava/lang/String;)Ljava/lang/Double;
getRealtimeLow
getTs
()Ljava/lang/Long;
java/lang/Long
toString
length
append
-(Ljava/lang/Object;)Ljava/lang/StringBuilder;
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
$(Ljava/lang/String;)Ljava/lang/Long;
setTs
(Ljava/lang/Long;)V
setName
getHigh
putRealtimeHigh
'(Ljava/lang/String;Ljava/lang/Double;)V
getLow
putRealtimeLow
2com/yami/trading/huobi/data/internal/DataDBService
saveAsyn
/(Lcom/yami/trading/bean/data/domain/Realtime;)V!Z>
\]^_^I`abcde
f
ghi
f
gjk
f
glm
f
g
no
p>
*·
**¶¸µ±q
r
st
uo
p>
»Y**¶·¶±q
+,r
st
vo
wx
yz
{|pX !+¹    
M,¹

™,¹
ÀN-¶ :*´¶:*´¶:*´¶:¸¹À:¸¹À:Æ
M¶¸*´‡¸Ž6        £}Ǹ¶¸¹W§¸¶¶ c¸¹W¶!¸¹À¶ —™"¸¹À¶ ¶"*´¶#W¸¹$W§·¶    ‡o¸%¶&²'¶(¶)9
Ǹ
¸¹W§¸¶ 
c¸¹W¶
g¶*¶*´‡¸¸+¶,¸¹W¶!¸¹À¶ —™"¸¹À¶ ¶"*´¶#W¸-¶ ¹À:Æj¶ —™`--¶-¶ c¸%¶&²'¶(¶)¶.--¶/¶ c¸%¶&²'¶(¶)¶0--¶1¶ c¸%¶&²'¶(¶)¶2¸3:    *¶4¶56
9
š*-·6§    Æ-¶-    ¶-¸+¸79
    ¦²89¹:*-·6±    ¶-—š*-·6§J    ¶-¸;˜œ*-·6§-²8=½>Y-¶ SY-¶-¸SY    ¶-¸S¹?§:    *´A-¶     ¹B    ¿§&:²8C½>Y-¶ SY-¸DSYS¹?§üê±+€á@Þá@€ú@÷ú@qæ979 :+;6<A=P>_@dBzD€E…F›H´KÍLâMìOúS
U
V
.X
D[
Q\
i]
v_
`
¤a
®f
¿h
Îi
íjk+p2r=s@tEuQwVxgzm{w|€}‹€—¨‚´„ފá‡ãˆô‰÷ú‹üŒŽ r˜
˜}~
z
4c    2¬€    =¡‚a
@žƒ~ã„…     ׆‡6Áˆ‰A¶Š‹P§Œ_˜Žü!„…!st!‘’
“
!‘”
•iü–ÿ“
—˜–™š›œž
7 ü3ùiû|þ%™
ø)BŸÿ—˜–™BŸú"ú ¡¢£
p
'Ž,¸E:,¸F:+¶G¶H¶I
£ +»JY·K+¶G¶LM¶N¶O¸P¶Q+-¶R¶SÆ+¶T¶ —ž,+¶T¸¸UÆ+¶V¶ ˜œ+¶V—ž,+¶V¸¸W*´X+¹Y±q.’“”•8—@˜Rš]œxžƒ ¡r>ŽstŽ
Ž†‡ŽŠ‹ˆ¤‚¥•ý8
¦o
p)
 Z¸³8³[±
q

§¨