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
Êþº¾4
?
C}~
€
    A‚    Aƒ„    A…
†‡
ˆ
‰‘
•–—
˜™š›œ
žŸ
A 
¡¢
¡£
¡¤¨,©
ª«¬    A­®¯°±
²³    A´µ¯¶,‰¹
˜¼½
C¾
¿À
Á    AÃ
ÄÅ    AÆ
ÇÈÉ
4}ÊË
4Ì
4ÍÎÏÐÑÒÓ
Ô
ÕÖ
×ØÙ
log
Lorg/slf4j/Logger;
first

Z
logger
 marketService
,Lcom/yami/trading/service/etf/MarketService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
itemService
+Lcom/yami/trading/service/item/ItemService;
 redisTemplate
3Lorg/springframework/data/redis/core/RedisTemplate;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
6Lcom/yami/trading/huobi/data/job/FakeSymbolGetDataJob;
start
run
symbols
Ljava/lang/String;

e
Ljava/lang/Exception;
 StackMapTable›¬Ú
getName
()Ljava/lang/String;
realtimeHandle
(Ljava/lang/String;)V

symbolList
Ljava/util/List;
realtimeList
LocalVariableTypeTable
$Ljava/util/List<Ljava/lang/String;>;
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;½
lambda$realtimeHandle$3
/(Lcom/yami/trading/bean/data/domain/Realtime;)Z

s
,Lcom/yami/trading/bean/data/domain/Realtime;
lambda$realtimeHandle$2
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
lambda$run$1
symbol
lambda$run$0
+(Lcom/yami/trading/bean/item/domain/Item;)Z

i
(Lcom/yami/trading/bean/item/domain/Item;
<clinit>

SourceFile
FakeSymbolGetDataJob.java
*Lorg/springframework/stereotype/Component;QR
java/lang/Thread
!自定义币对实时数据采集QÛXRFGÜÝ
java/util/ArrayListMNÞßàQáâã
BootstrapMethodsäåævçèéêëìíîïðñò

,óôõö÷
java/lang/String
&com/yami/trading/bean/item/domain/Item
    US-stocksøùúdeûüýþÿ




e





    


java/lang/ExceptionHE
run fail


 
机器人实时数据采集


DE
$当前没有行情数据可以采集
e
rï

n


java/util/List







IJ

rOP
 
!
"
java/lang/StringBuilder
+com/yami/trading/common/constants/RedisKeys
SYMBOL_AMOUNT_VOLUME_
#
$
%c
java/lang/Object
amount
&
'
(
volume

1
)c
*ú
4com/yami/trading/huobi/data/job/FakeSymbolGetDataJob
+
,
-
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
list
()Ljava/util/List;
(Ljava/util/Collection;)V
stream
()Ljava/util/stream/Stream;

.
/
(Ljava/lang/Object;)Z
A
0
test
 ()Ljava/util/function/Predicate;
java/util/stream/Stream
filter
9(Ljava/util/function/Predicate;)Ljava/util/stream/Stream;
&(Ljava/lang/Object;)Ljava/lang/Object;

1
<(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;
java/util/stream/Collectors
joining
6(Ljava/lang/CharSequence;)Ljava/util/stream/Collector;
collect
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
*com/yami/trading/service/MarketOpenChecker
isMarketOpen
(Ljava/lang/String;)Z
com/google/common/base/Splitter
on
5(Ljava/lang/String;)Lcom/google/common/base/Splitter;
trimResults
#()Lcom/google/common/base/Splitter;
splitToList
*(Ljava/lang/CharSequence;)Ljava/util/List;
(Ljava/lang/Object;)V
A
2
accept
U(Lcom/yami/trading/huobi/data/job/FakeSymbolGetDataJob;)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/collection/CollectionUtil
isEmpty
(Ljava/util/Collection;)Z
A
3
U(Lcom/yami/trading/huobi/data/job/FakeSymbolGetDataJob;)Ljava/util/function/Function;
A
4
toList
()Ljava/util/stream/Collector;
handleRealTimeList
(Ljava/util/List;)V
*com/yami/trading/bean/data/domain/Realtime
getTs
()Ljava/lang/Long;
java/lang/Long
    longValue
()J
*com/yami/trading/service/etf/MarketService
 queryRealtime
1org/springframework/data/redis/core/RedisTemplate

opsForHash
6()Lorg/springframework/data/redis/core/HashOperations;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
2org/springframework/data/redis/core/HashOperations
delete
7(Ljava/lang/Object;[Ljava/lang/Object;)Ljava/lang/Long;
getFake
equalsIgnoreCase
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
5
6
:uv
;cseqrmn
"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;
    getSymbol
>
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!ACDEIFG
HEIJ
K
LMN
K
LOP
K
L

QR
S/

*·
±T
U
VW
XR
S<
»Y*·¶±T
% &U
VW
YR
S
D›²™*¸µ³»Y*´    ¶
·¶º ¹º¹¸¹ÀL¸™*+¶§¸¶+¶*º¹*´…¸§%L² !+¹"*´…¸§M*´…¸,¿§ÿykvkv‚T>+- .3D4L5T7k?s@v<w=‚?Š@?–@U D'Z[
w\]
›VW^üB_úJ`Va

bc
S-

#°T
GU
VW
de
SÖL¸¶+¶M,¸$™²%&¹'±,¹(
*º)¹º*¹¸+¹À,N*-·-±TM NOPRFSKTU*LVWLZ[
 ?fgFhgi ?fjFhk^
ül
mn
SG
*¶.¶/    ”™§¬T
RU
op^@
qr
S=    *´0+¶1°T
RU    VW    o[
se
SS*´2¶3»4Y·57¶8+¶8¶9½:Y;S¹<W*´2¶3»4Y·57¶8+¶8¶9½:Y=S¹<W±T8)9R:USVWSt[

uv
S4

>*¶?¶@¬T
3U

wxyR
S5
A¸B³%³A¸B³ ±
Tz{K
|
9


7
<
8Š4‹ŒŽ‹’“”‹¥¦§‹’·¸‹Œº»