1

zj

2024-06-13 a4662cc65a02f258062bf6cc392ceb1017db9292

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
Êþº¾4
D
    G‘’“    G”
•–
    —˜™š›
œž
•Ÿ 
¡¢§¨©
3ª«¬­    G®¯
°±²³    G´
µ¶
·¸&¹º»º¼½¾¿"ÀÁ
·Â&Ã
#Ä    GÅÆÇ
ÈÉÊ"Ë
ÌÍ’ÎÏÐÑ
°ÒÓ
5Ô
ÕÖ×
5Ø
5Ù    ÚÛ
ÜÝ    GÞ
5ßà
Gáâ
ãä
·åÆæçè
éê
log
Lorg/slf4j/Logger;
jdbcTemplate
,Lorg/springframework/jdbc/core/JdbcTemplate;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
itemService
+Lcom/yami/trading/service/item/ItemService;
xueQiuDataService
<Lcom/yami/trading/huobi/hobi/internal/XueQiuDataServiceImpl;
klineService
3Lcom/yami/trading/huobi/data/internal/KlineService;
 spiderService
4Lcom/yami/trading/huobi/hobi/internal/SpiderService;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
/Lcom/yami/trading/admin/facade/ItemVisitFacade;
updateOrInsertVisit
(Ljava/lang/String;)V
symbol
Ljava/lang/String;
item
(Lcom/yami/trading/bean/item/domain/Item;
 defaultActive
sql
 StackMapTable™Ñ
:Lorg/springframework/transaction/annotation/Transactional;
saveInitSelfData
(Ljava/lang/String;)Z
klines5P
Ljava/util/List;
map
Ljava/util/Map;
symbols
klines
LocalVariableTypeTable
;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;
^Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;>;
pLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;>;>;Áë
getSymbolsOlderThanNDay
(I)Ljava/util/List;
days

I
query
    Signature
'(I)Ljava/util/List<Ljava/lang/String;>;
main
([Ljava/lang/String;)V
args
[Ljava/lang/String;
cookie
dailyWeekMonthHistoryMap
hourlyAndMinuteHistoryMap
lambda$updateOrInsertVisit$0
selfDataInitSuccess

Zè½
<clinit>

SourceFile
ItemVisitFacade.java
*Lorg/springframework/stereotype/Component;WXIJ
ItemVisitFacade æ­£åœ¨è®¿é—® {}ìíîOPïðñòó
java/lang/CharSequence
&com/yami/trading/bean/item/domain/Item
active
default_activeôõö
ItemVisitFacade æ­£åœ¨æ¿€æ´» {}÷_
)ItemVisitFacade æ•°æ®åº“激活 {} å®Œæˆøùú
BootstrapMethodsûXüýþÿ



k

1

0
¶INSERT INTO t_item_visit (symbol, visit_count, last_visit_time, default_active) VALUES (?, 1, NOW(), ?) ON DUPLICATE KEY UPDATE visit_count = visit_count + 1, last_visit_time = NOW()KL
java/lang/Object



(ItemVisitFacade è®¿é—®æ¬¡æ•°+1 {} å®Œæˆ
/正在通过自己数据源 åˆå§‹åŒ–k綫圖:{}UV



    




 ë




 java/util/Map
'com/yami/trading/bean/data/domain/Kline
5min


java/util/List




óST




_
初始化k线图{} æ•°é‡ä¸º{}




 í
!
)完成自己数据源 åˆå§‹åŒ–k綫圖:{}
oSELECT symbol FROM t_item_visit WHERE default_active = 0 and last_visit_time <= DATE_SUB(NOW(), INTERVAL ? DAY)
java/lang/String
"
#
:com/yami/trading/huobi/hobi/internal/XueQiuDataServiceImpl
https://xueqiu.com/
$
%
&
SZ300066
'
(
)
(
*
+
,
-
.
/QR
0_
)ItemVisitFacade å¼€å§‹åˆå§‹åŒ–k线图 {}jk
HItemVisitFacade ä»Žè‡ªå·±æ•°æ®æºåˆå§‹åŒ–k线图获取 {} çŠ¶æ€ä¸º {}
1

2

3

4
*ItemVisitFacade åˆå§‹åŒ–k线图 {} å®Œæˆ
-com/yami/trading/admin/facade/ItemVisitFacade
5
6
7
java/util/Iterator
org/slf4j/Logger
info
'(Ljava/lang/String;Ljava/lang/Object;)V
)com/yami/trading/service/item/ItemService
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
getCrawlStatus
()Ljava/lang/String;
cn/hutool/core/util/StrUtil
    equalsAny
4(Ljava/lang/CharSequence;[Ljava/lang/CharSequence;)Z
crawlActive
)com/yami/trading/common/config/ThreadPool
getApplicationThreadPool
!()Ljava/util/concurrent/Executor;

8
9
G
:
run
W(Lcom/yami/trading/admin/facade/ItemVisitFacade;Ljava/lang/String;)Ljava/lang/Runnable;
java/util/concurrent/Executor
execute
(Ljava/lang/Runnable;)V
equalsIgnoreCase
*org/springframework/jdbc/core/JdbcTemplate
update
((Ljava/lang/String;[Ljava/lang/Object;)I
2com/yami/trading/huobi/hobi/internal/SpiderService
    getKlines
$(Ljava/lang/String;)Ljava/util/List;
(cn/hutool/core/collection/CollectionUtil
isEmpty
(Ljava/util/Collection;)Z
iterator
()Ljava/util/Iterator;
hasNext
()Z
next
()Ljava/lang/Object;
get
&(Ljava/lang/Object;)Ljava/lang/Object;

isNotEmpty
(I)Ljava/lang/Object;
    getSymbol
1com/yami/trading/huobi/data/internal/KlineService
saveInit
$(Ljava/lang/String;Ljava/util/Map;)V
%com/yami/trading/huobi/data/DataCache
clearLatestRealTime60s
size
()I
java/lang/Integer
valueOf
(I)Ljava/lang/Integer;
9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
queryForList
H(Ljava/lang/String;[Ljava/lang/Object;Ljava/lang/Class;)Ljava/util/List;
+com/yami/trading/huobi/hobi/http/HttpHelper
    getCookie
&(Ljava/lang/String;)Ljava/lang/String;
getDailyWeekMonthHistory
5(Ljava/lang/String;Ljava/lang/String;)Ljava/util/Map;
getHourlyAndMinuteHistory
java/lang/System
out
Ljava/io/PrintStream;
java/io/PrintStream
println
(Ljava/lang/Object;)V
lease
java/lang/Boolean
(Z)Ljava/lang/Boolean;
(Ljava/util/Map;)Z
3(Ljava/lang/String;Ljava/util/Map;Ljava/util/Map;)V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
;
<
@†_
"java/lang/invoke/LambdaMetafactory
metafactory
B
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;
C
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!GIJKL
M
NOP
M
NQR
M
NST
M
NUV
M
N
WX
Y/

*·
±Z
[
\]
^_Y
$“²+¹*´+¶M,¶½Y
SYS¸š0² +¹*´+¶²+¹¸*+º¹,¶¶™§N:*´½Y+SY-S¶W²+¹±Z2124,576?7J9YImKqQ‡R’T[4“\]“`a
bcm&daq"eaf üYgAhM
ijk
Y
l˜²+¹*´+¶M,¸™¬,¹
N-¹ 
™a-¹!
À":$¹%À&:¸'™=¹(À#¶):*´*¹+¸,²-¹.
¸/¹0¬§ÿœ²1+¹¬Z>WXYZ\8]F^N_^`kapc†dˆf‹g–h[>^*`aFBlm8Pno˜\]˜pa
„qmr FBls8Pnt„qufüvüwûcú
xyY[2M*´,½Y¸/S3¶4°Z
mn[ \]z{
|a}~    €
Yº*»5Y·6L7¸8M9N+-,¶::+-,¶;:²<¶=±Zstuvw!x)y[>*‚"QR
ƒa`a„o!    …or„t!    …t†_
Y
-n*´>+¶?²@+¹*+·A=²B+¸C¹07¸8N*´>+-¶::*´>+-¶;:¸D™¸D™*´*+¹E²F+¹±Z.:;<=(>.?9@DATBbDmE[>n\]n`a
U‡ˆ.@ƒa95„oD*…or95„tD*…tf
ÿb‰h
hŠŠ‹X
Y!
    G¸H³±
Z
ŒM
Ž
?


=
A
>£
¤¥¦¥