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
Êþº¾4
-
?|}~

€    =    =‚ƒ    =„
…†
‡
ˆŽ
‘’“”ˆ
Ž™š›
‘œŽŽ™¡
|
¢
£    =¤
¥¦ª«
¬­®    =¯°±²³
´µ    =¶·±¸    =¹º»
?¼
½¾
…¿
ÀÁ
5ÂÃÄ
ÅÆÇ
5ÈÉ
5ÊË
ÌÍÎ
log
Lorg/slf4j/Logger;
logger
first

Z
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
3Lcom/yami/trading/huobi/data/job/StockGetMarketJob;
start
run
list
Ljava/util/List;
aStocSymbols
Ljava/lang/String;
 hkStocSymbols
 usStocSymbols
symbols
markets

e
Ljava/lang/Exception;
LocalVariableTypeTable
:Ljava/util/List<Lcom/yami/trading/bean/item/domain/Item;>;
ALjava/util/List<Lcom/yami/trading/bean/data/domain/StockMarket;>;
 StackMapTable®Ï
getName
()Ljava/lang/String;
realtimeHandle
(Ljava/lang/String;)V
realtimeList
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
lambda$run$4
2(Lcom/yami/trading/bean/data/domain/StockMarket;)V

m
/Lcom/yami/trading/bean/data/domain/StockMarket;
lambda$run$3
+(Lcom/yami/trading/bean/item/domain/Item;)Z
item
(Lcom/yami/trading/bean/item/domain/Item;
lambda$run$2
lambda$run$1
lambda$run$0

i
<clinit>

SourceFile
StockGetMarketJob.java
*Lorg/springframework/stereotype/Component;MN
java/lang/Thread
StockGetMarketJobMÐTNCDÑÒ
java/util/ArrayListIJÓVÔMÕÖ×
BootstrapMethodsØÙÚqÛÜÝÞßàáâãä
java/util/Liståæçèéêëì

,íî
java/lang/Stringïðñ
java/lang/StringBuilderòóôgKLõö÷øùmúûüýþÿ

java/lang/ExceptionBA
run fail




股票实时数据采集


@A
$当前没有行情数据可以采集
iEF

÷
    



g
 




g
&com/yami/trading/bean/item/domain/Item
    US-stocks


    HK-stocks
A-stocks



0
g
1com/yami/trading/huobi/data/job/StockGetMarketJob



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;



(Ljava/lang/Object;)Z
=

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;
=

&(Ljava/lang/Object;)Ljava/lang/Object;
5¾
<(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;
=

=
 
5
!
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
2com/yami/trading/huobi/hobi/internal/SpiderService

getMarkets
$(Ljava/lang/String;)Ljava/util/List;
(Ljava/lang/Object;)V
=
"
accept
R(Lcom/yami/trading/huobi/data/job/StockGetMarketJob;)Ljava/util/function/Consumer;
forEach
 (Ljava/util/function/Consumer;)V
(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
+com/yami/trading/huobi/hobi/HobiDataService
realtime
handleRealTimeList
(Ljava/util/List;)V
-com/yami/trading/bean/data/domain/StockMarket
    getSymbol
getSymbolByRemarks
&(Ljava/lang/String;)Ljava/lang/String;
%com/yami/trading/huobi/data/DataCache
    putMarket
D(Ljava/lang/String;Lcom/yami/trading/bean/data/domain/StockMarket;)V
getOpenCloseType
equalsIgnoreCase
(Ljava/lang/String;)Z
isActive
()Z
getFake
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
#
$
(vquqtqpq
)glm
"java/lang/invoke/LambdaMetafactory
metafactory
+
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;

getRemarks
,
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!=?@A
BAICDEF
G
HIJ
G
HKL
G
H
MN
O/

*·
±P
Q
RS
TN
O<
»Y*·¶±P
' (Q
RS
UN
O"
²™*¸µ³»Y*´    ¶
·¶º ¹¸¹ÀL+¹
º¹º¹¸¹ÀM+¹
º¹º¹¸¹ÀN+¹
º¹º¹¸¹À:»Y·,¶¶-¶¶¶¶:*´ ¶!:*º"¹#*´…¸$§'L²&'+¹(*´…¸$§:*´…¸$¿§þöì÷%ì
÷




PJ-/ 0486`7ˆ8±9Ô:ß;ì@ôA÷=ø>
@
A
@
AQR8´VW
`ŒXYˆdZY±;[YÔ\Yß ]Wø^_

RS`8´Va
ß ]bc÷ådVe
fg
O-

)°P
HQ
RS
hi
O#+¸*™²+,¹-±*´.+¹/M*,·0±PNOPRS"TQ #RS#\Y
jW`
jkc
lm
OD*´    +¶1¶2+¸3±P
;QRSno

pq
ON
*¶4Æ*¶46¶7™§¬P
8Q
rsc@

tq
ON
*¶4Æ*¶48¶7™§¬P
7Q
rsc@

uq
ON
*¶4Æ*¶49¶7™§¬P
6Q
rsc@

vq
ON
*¶:™;*¶<¶7™§¬P
4Q
wsc@
xN
O5
=¸>³+=¸>³&³±
PyzG
{
'


%
*
&‰HŠ‹ŒŠ‹•Š–—˜Š‹žŠ‹ŸŠ– ˜Š§¨©