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
Êþº¾4
i
PŸ ¡
¢
£    N¤    N¥¦    N§
¨©
ª
«±²³
´µ²¶·«
±¼²½¾
´¿À±¼±±±±    ±
±±± ±±    NÍ
NÎ
NÏ
NÐÑÒ
ÓÔÕÖ×ØÙÚÛÜÝÞß
àáâ    Nãäåæç
èé    Nêëåì    Ní
îïðñ
òóåô
Põö
)÷
)ø
ùú
)ûü
ýþÿ
log
Lorg/slf4j/Logger;
logger
first

Z
stockFirstFetch
hobiDataService
-Lcom/yami/trading/huobi/hobi/HobiDataService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
itemService
+Lcom/yami/trading/service/item/ItemService;
 spiderService
4Lcom/yami/trading/huobi/hobi/internal/SpiderService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
1Lcom/yami/trading/huobi/data/job/StockGetDataJob;
start
run
list
Ljava/util/List;
 aStockRemarks
Ljava/lang/String;
hkStockRemarks
usStockRemarks
twStockRemarks
jpStockRemarks
indiaStockRemarks
ukStockRemarks
deStockRemarks
bzStockRemarks
cadStockRemarks
frStockRemarks
sgStockRemarks

e
Ljava/lang/Exception;
LocalVariableTypeTable
:Ljava/util/List<Lcom/yami/trading/bean/item/domain/Item;>;
 StackMapTableü·Àâ

getName
()Ljava/lang/String;
realtimeHandleCommon
(Ljava/lang/String;)V
remarks
realtimeList
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
realtimeHandleTW
realtimeHandle
 lambda$run$12
+(Lcom/yami/trading/bean/item/domain/Item;)Z
item
(Lcom/yami/trading/bean/item/domain/Item;
 lambda$run$11
 lambda$run$10
lambda$run$9
lambda$run$8
lambda$run$7
lambda$run$6
lambda$run$5
lambda$run$4
lambda$run$3
lambda$run$2
lambda$run$1
lambda$run$0

i
<clinit>

SourceFile
StockGetDataJob.java
*Lorg/springframework/stereotype/Component;_`
java/lang/Thread
StockGetDataJob_

f`TU


java/util/ArrayList[\
h
_



BootstrapMethods
    


‹

 








java/util/List









,


java/lang/String
 
!
"
#
$
%
&
'
(
)
*
+VU‰„ˆ„ƒ„
&com/yami/trading/bean/item/domain/Item
A-stocks
,
-
.
    HK-stocks
    US-stocks
    TW-stocks
    JP-stocks
INDIA-stocks
    UK-stocks
    DE-stocks
    BZ-stocks

CAD-stocks
    FR-stocks
    SG-stocks
/
0
1
java/lang/ExceptionSR
run fail
2
3
4
股票实时数据采集
5
6
7QR
$当前没有行情数据可以采集
3„]^
8
9
:
%首次采集，采集回数据[{}]个
;
<
=
>
?
@
A
B
C
*台股当前没有行情数据可以采集
D
E
F‚
G
H

0
I‚
/com/yami/trading/huobi/data/job/StockGetDataJob
J
K
L
2com/yami/trading/huobi/data/job/AbstractGetDataJob
java/lang/Throwable
)(Ljava/lang/Runnable;Ljava/lang/String;)V
interval

I
)com/yami/trading/service/item/ItemService
()Ljava/util/List;
(Ljava/util/Collection;)V
stream
()Ljava/util/stream/Stream;

M
N
(Ljava/lang/Object;)Z
N
O
test
 ()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;
N
P
&(Ljava/lang/Object;)Ljava/lang/Object;
)
Q
<(Lcom/yami/trading/bean/item/domain/Item;)Ljava/lang/String;
apply
()Ljava/util/function/Function;
map
8(Ljava/util/function/Function;)Ljava/util/stream/Stream;
joining
6(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
N
R
)
S
N
T
N
U
N
V
N
W
N
X
N
Y
N
Z
N
[
N
\
N
]
*com/yami/trading/service/MarketOpenChecker
isMarketOpen
(Ljava/lang/String;I)Z
(com/yami/trading/common/util/ThreadUtils
sleep
(J)V
org/slf4j/Logger
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
cn/hutool/core/util/StrUtil
isEmpty
(Ljava/lang/CharSequence;)Z
2com/yami/trading/huobi/hobi/internal/SpiderService
fetchRealtimeList
$(Ljava/lang/String;)Ljava/util/List;
size
()I
java/lang/Integer
valueOf
(I)Ljava/lang/Integer;
info
'(Ljava/lang/String;Ljava/lang/Object;)V
handleRealTimeList
(Ljava/util/List;)V
isActive
()Z
getOpenCloseType
equalsIgnoreCase
(Ljava/lang/String;)Z
getFake
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
^
_
c™‹˜‹
d‚—‹
e‚–‹•‹”‹“‹’‹‘‹‹‹Ž‹Š‹
"java/lang/invoke/LambdaMetafactory
metafactory
g
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;
    getSymbol

getRemarks
h
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!NPQR
SRITUIVUWX
Y
Z[\
Y
Z]^
Y
Z
_`
a/

*·
±b
c
de
f`
a<
»Y*·¶±b
& 'c
de
g`
ašb²™*¸µ³»Y*´    ¶
·¶º ¹¸¹ÀL+¹
º¹º¹¸¹ÀM+¹
º¹º¹¸¹ÀN+¹
º¹º¹¸¹À:+¹
º¹º¹¸¹À:+¹
º¹º¹¸¹À:+¹
º¹º¹¸¹À:+¹
º¹º¹¸¹À:+¹
º ¹º¹¸¹À:    +¹
º!¹º¹¸¹À:
+¹
º"¹º¹¸¹À:+¹
º#¹º¹¸¹À:+¹
º$¹º¹¸¹À: ²%™M*,¶&*-¶&*¶&*¶'*¶(*¶(*¶(*    ¶(*
¶(*¶(*¶(* ¶(³%*¸+™*,¶&,¸+™*-¶&-¸+™    *¶&.¸+™    *¶'/¸+™    *¶(0¸+™    *¶(1¸+™    *¶(2¸+™    *    ¶(3¸+™    *
¶(4¸+™    *¶(5¸+™    *¶(6¸+™    *¶(*´…¸7§'L²9:+¹;*´…¸7§:*´…¸7¿§ü²0;80R;GRRTRbþ?,. /385M6`7ˆ8±9Ú:
;
,<
U=
~>
§?
Ð@
ùA"F(G-H2I8J>KDLJMPNVO\PbQhRnTrV|WY‹Z\š] _ª`°bºcÀeÊfÐhÚiàkêlðnúoq
rtu w*x08‚;~<GO‚R\‚c˜8øhi
`Ðjkˆ¨lk±mkÚVnk
-ok
,pk
U
Ûqk
~
²rk    
§
‰sk

Ð
`tk
ù
7uk"
vk <wx
bdey
8øhz
{Rÿ`|}~~~~~~~~~~~~ÿ
|JV€
‚
a-

<°b
‰c
de
ƒ„
aµ:+¸=™²>?¹@±*´A+¶BM²%™²>C,¹D
¸E¹F*,·G±b"Ž‘’!“4•9—c :de:…k
†iy
†‡{    ü!}
ˆ„
aŽ!+¸=™²>H¹@±*´A+¶BM*,·G±bš›œžŸ ¡c !de!…k
†iy
†‡{

‰„
aŽ!+¸=™²>?¹@±*´A+¶BM*,·G±b¤¥¦¨© ªc !de!…k
†iy
†‡{

Š‹
aU
 *¶I™*¶JÆ*¶J6¶K™§¬b
Ac
 Œ{@

Ž‹
aU
 *¶I™*¶JÆ*¶J5¶K™§¬b
@c
 Œ{@

‹
aU
 *¶I™*¶JÆ*¶J4¶K™§¬b
?c
 Œ{@

‹
aU
 *¶I™*¶JÆ*¶J3¶K™§¬b
>c
 Œ{@

‘‹
aU
 *¶I™*¶JÆ*¶J2¶K™§¬b
=c
 Œ{@

’‹
aU
 *¶I™*¶JÆ*¶J1¶K™§¬b
<c
 Œ{@

“‹
aU
 *¶I™*¶JÆ*¶J0¶K™§¬b
;c
 Œ{@

”‹
aU
 *¶I™*¶JÆ*¶J/¶K™§¬b
:c
 Œ{@

•‹
aU
 *¶I™*¶JÆ*¶J.¶K™§¬b
9c
 Œ{@

–‹
aU
 *¶I™*¶JÆ*¶J-¶K™§¬b
8c
 Œ{@

—‹
aU
 *¶I™*¶JÆ*¶J,¶K™§¬b
7c
 Œ{@

˜‹
aU
 *¶I™*¶JÆ*¶J*¶K™§¬b
5c
 Œ{@

™‹
a4

L*¶M¶K¬b
3c

š›`
a=
N¸O³>N¸O³9³³%±
bœY
ž
b


`
f
a¬˜­®¯°­®¸°­¹º»­®Á°­¹Â»­®Ã°­®Ä°­®Å°­®Æ°­®Ç°­®È°­®É°­®Ê°­®Ë°­®Ì°