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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
Êþº¾4
­
@
A

@    w
B
C

@    w
D
w
E
F
    
@
    
G
    
H

I
J
    
K
    
L
    
M
    
N
    
O
P

@    w
Q

R
S

T
U
`
V

I
Wè
`
X

Y
Z    
[
\

Y
]

Y
^
`
_
`
`
`
a    w
b

c
d
e
&
@
f
g
&
h
&
iÝ
j
k

l
m
1
n

l
o
p
1
^
`
q

l
r

T
s

t
u
    
v
wß
`
x
    
_

t
y

t
z
    
{
    
a

|
}
    
~
    
`
    

    
q
j
€
    
xI
I
‚
ƒ

„
…    w
†

|
‡

Ž


‘

’



™


ž
Ÿ
 
¡
¢
W
I
£

c
¤
¥



¦
§
¨
§
‚
©
ª
a
@Ô
a
«
¬

­
®
a
¯
a
°
±
a
²    w
³
´
µ

„
¶
·

¸
¹
º
`
»
`
K
`
¼
½
t
¾    w
¿
À
Á
Â
Ã

Ä
¶
    
X

t
Å
`
M
`
O
`
N
W
‚I
Æ

|
Ç
w
È
É
„
@“à
1
Ê
`
@
`
Ë
`
G
`
L
`
{
`
v

Ì
Í

@

G

K

R
Π   w
Ï
Ð
Ñ
Ò

„
Ó@Y@@

Ô
Õ@øj@$

|
Ö
×
£
@

Ø
Ù
£
Ú
£
Û

Ü

Ý

Ž
à

á
â
ã
log
Lorg/slf4j/Logger;
IXIC
Ljava/lang/String;
 ConstantValue
itemService
+Lcom/yami/trading/service/item/ItemService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
klineConfigService
1Lcom/yami/trading/service/etf/KlineConfigService;
 redisTemplate
3Lorg/springframework/data/redis/core/RedisTemplate;
    Signature
YLorg/springframework/data/redis/core/RedisTemplate<Ljava/lang/String;Ljava/lang/Object;>;
dataService
+Lcom/yami/trading/service/data/DataService;
etfMinuteKLineService
4Lcom/yami/trading/service/etf/EtfMinuteKLineService;

accelerate
Ljava/util/Map;
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Double;>;

cacheKline
wLjava/util/Map<Ljava/lang/String;Ljava/util/LinkedHashMap<Ljava/lang/Long;Lcom/yami/trading/bean/data/domain/Kline;>;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
,Lcom/yami/trading/service/etf/MarketService;
 getAccelerate
()Ljava/util/Map;
7()Ljava/util/Map<Ljava/lang/String;Ljava/lang/Double;>;
 queryRealtime
@(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Realtime;
realtime
,Lcom/yami/trading/bean/data/domain/Realtime;
symbol
kline
)Lcom/yami/trading/bean/data/domain/Kline;
random
Ljava/util/Random;
decimal

I

lastAmount

D
amount

lastVolume
volume
 StackMapTable
©
À
·
P
F
 querySecKline
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Kline;
queryWrapper
=Lcom/baomidou/mybatisplus/core/conditions/query/QueryWrapper;
list
Ljava/util/List;

e
&Ljava/lang/CloneNotSupportedException;
ratio
retKline
    realtimes
    secKlines
collect
Ljava/util/LinkedHashMap;

currentSec

J
LocalVariableTypeTable
pLcom/baomidou/mybatisplus/core/conditions/query/QueryWrapper<Lcom/yami/trading/bean/etf/domain/EtfMinuteKLine;>;
CLjava/util/List<Lcom/yami/trading/bean/etf/domain/EtfMinuteKLine;>;
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
;Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;
ä
¢
å
ã
ª
½
clear
    build5min
$(Ljava/lang/String;)Ljava/util/List;
klines
O(Ljava/lang/String;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;
convertTo5MinKLine
"(Ljava/util/List;)Ljava/util/List;
    nextKLine
currentKLine
currentTimestamp
open
high
low
close
 nextTimestamp
    nextIndex
fiveMinKLine

sKLineList
fiveMinKLineList
currentIndex
dataSize
x(Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;)Ljava/util/List<Lcom/yami/trading/bean/data/domain/Kline;>;

queryDepth
=(Ljava/lang/String;)Lcom/yami/trading/bean/data/domain/Depth;
enlarge
buy
.Lcom/yami/trading/bean/data/domain/DepthEntry;
sell

i
depth
)Lcom/yami/trading/bean/data/domain/Depth;
item
(Lcom/yami/trading/bean/item/domain/Item;
volumeSplit
$Ljava/util/List<Ljava/lang/Double;>;
Í
æ
getItemService
-()Lcom/yami/trading/service/item/ItemService;
getKlineConfigService
3()Lcom/yami/trading/service/etf/KlineConfigService;
getRedisTemplate
5()Lorg/springframework/data/redis/core/RedisTemplate;
[()Lorg/springframework/data/redis/core/RedisTemplate<Ljava/lang/String;Ljava/lang/Object;>;
getDataService
-()Lcom/yami/trading/service/data/DataService;
getEtfMinuteKLineService
6()Lcom/yami/trading/service/etf/EtfMinuteKLineService;
 getCacheKline
y()Ljava/util/Map<Ljava/lang/String;Ljava/util/LinkedHashMap<Ljava/lang/Long;Lcom/yami/trading/bean/data/domain/Kline;>;>;
lambda$querySecKline$2
}(Lcom/yami/trading/bean/data/domain/Kline;Lcom/yami/trading/bean/data/domain/Kline;)Lcom/yami/trading/bean/data/domain/Kline;
k1
k2
lambda$querySecKline$1
T(Lcom/yami/trading/bean/data/domain/Kline;)Lcom/yami/trading/bean/data/domain/Kline;
lambda$querySecKline$0
;(Lcom/yami/trading/bean/data/domain/Kline;)Ljava/lang/Long;

k
<clinit>

SourceFile
MarketService.java
(Lorg/springframework/stereotype/Service;ÆÇ
java/util/HashMapÁÂ
&java/util/concurrent/ConcurrentHashMapÄÂæç
*com/yami/trading/bean/data/domain/Realtime
ç
è
é
è
ê
ë
ì
í
î
ï
ð
ñ
ð
ò
ð
ó
ð
java/util/Random³´
ô
õ
ö
÷
ø
ù
ú
û
ü
ý
þ
ÿ
ë

ÿ
ÿ    
ÿ

ÿ¹º 
java/lang/StringBuilder
+com/yami/trading/common/constants/RedisKeys
SYMBOL_AMOUNT_VOLUME_
ë
java/lang/Double
ÿ
ë !
ð
SYMBOL_VOLUME_"
ÿ# $ %
ð&'()
ð*
ð+,-
ù
 java/util/Map./0·¸1

BootstrapMethods2
:34567
ä89:;<=
8>
43?@ABCDEFGòH
java/util/LinkedHashMap+IJ
 SYMBOL_DEPTH_K
åLM
'com/yami/trading/bean/data/domain/Kline
;com/baomidou/mybatisplus/core/conditions/query/QueryWrapperN
tsOP
ýQR
limit 1ST¿ÀUêVWX
java/lang/StringYZ[
1min\
è]@
$java/lang/CloneNotSupportedException^Ç½¾
*com/yami/trading/service/etf/MarketService
.IXIC_Ò
`ab

Çc



java/util/ArrayListdbef
'com/yami/trading/bean/data/domain/Depthgh®¯
queryDepth {} is nullijk/Xl'bmn
,com/yami/trading/bean/data/domain/DepthEntry
æo
ùpq!qrstsuvwxyz{
java/lang/Object
java/util/List
3org/springframework/data/redis/core/ValueOperations
&com/yami/trading/bean/item/domain/Item
    setSymbol
(Ljava/lang/String;)V
setName
java/lang/Long
valueOf
(J)Ljava/lang/Long;
setTs
(Ljava/lang/Long;)V
setOpen
(D)V
setClose
setHigh
setLow
)com/yami/trading/service/item/ItemService

getDecimal
'(Ljava/lang/String;)Ljava/lang/Integer;
java/lang/Integer
intValue
()I
getTs
()Ljava/lang/Long;
    longValue
()J
getOpen
()D
java/math/BigDecimal
(D)Ljava/math/BigDecimal;
java/math/RoundingMode
HALF_UP
Ljava/math/RoundingMode;
setScale
1(ILjava/math/RoundingMode;)Ljava/math/BigDecimal;
doubleValue
getClose
getHigh
getLow
1org/springframework/data/redis/core/RedisTemplate

opsForHash
6()Lorg/springframework/data/redis/core/HashOperations;
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
2org/springframework/data/redis/core/HashOperations
get
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
java/util/Optional

ofNullable
((Ljava/lang/Object;)Ljava/util/Optional;
(D)Ljava/lang/Double;
orElse
&(Ljava/lang/Object;)Ljava/lang/Object;
    getAmount
of
(I)Ljava/lang/Integer;
"com/yami/trading/common/util/Arith
add
(DDLjava/lang/Integer;)D
    setAmount
    getVolume
sub
mul
    setVolume
/com/yami/trading/service/etf/KlineConfigService
randomDouble
(DDLjava/util/Random;)D
setAsk
setBid
put
9(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;)V
size
(cn/hutool/core/collection/CollectionUtil
isEmpty
(Ljava/util/Map;)Z
querySecKlineBySymbol
|}
apply
()Ljava/util/function/Function;
java/util/Comparator
    comparing
5(Ljava/util/function/Function;)Ljava/util/Comparator;
sort
(Ljava/util/Comparator;)V
stream
()Ljava/util/stream/Stream;
w~
w
w€
%()Ljava/util/function/BinaryOperator;
()Ljava/lang/Object;
W
@
()Ljava/util/LinkedHashMap;
()Ljava/util/function/Supplier;
java/util/stream/Collectors
toMap
˜(Ljava/util/function/Function;Ljava/util/function/Function;Ljava/util/function/BinaryOperator;Ljava/util/function/Supplier;)Ljava/util/stream/Collector;
java/util/stream/Stream
0(Ljava/util/stream/Collector;)Ljava/lang/Object;
opsForValue
7()Lorg/springframework/data/redis/core/ValueOperations;
(I)Ljava/lang/Object;
set
'(Ljava/lang/Object;Ljava/lang/Object;)V
eq
java/lang/System
currentTimeMillis
lt
orderByDesc
last
&(Ljava/lang/String;)Ljava/lang/Object;
2com/yami/trading/service/etf/EtfMinuteKLineService
D(Lcom/baomidou/mybatisplus/core/conditions/Wrapper;)Ljava/util/List;

isNotEmpty
(Ljava/util/Collection;)Z
cn/hutool/core/bean/BeanUtil
copyProperties
J(Ljava/lang/Object;Ljava/lang/Class;[Ljava/lang/String;)Ljava/lang/Object;
    setPeriod
clone
printStackTrace
)com/yami/trading/service/data/DataService
.org/apache/commons/collections/CollectionUtils
div
(DD)D
querySecKlineBySymbolAllData
max
    getSymbol
(Ljava/lang/Object;)Z
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
org/slf4j/Logger
info
'(Ljava/lang/String;Ljava/lang/Object;)V
cn/hutool/core/util/RandomUtil
    splitData
(DID)Ljava/util/List;
getDecimals
setPrice
(Ljava/lang/Double;)V
getAsks
()Ljava/util/List;
getBids
£
B(Lcom/yami/trading/bean/data/domain/DepthEntry;)Ljava/lang/Double;
reversed
()Ljava/util/Comparator;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;‚ƒ‡
9
:
7
8
3
4ˆ‰
"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;
getPrice
()Ljava/lang/Double;Œ
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!w­    ®¯°±
²x³´
µ
¶·¸
µ
¶¹º»¼µ
¶½¾
µ
¶¿À
µ
¶
ÁÂ
»ÃÄÂ
ȁ
ÆÇ
ÈM
*·
*»Y·µ*»Y·µ±É$17Ê
ËÌ
ÍÎÈ/

*´°É
4Ê
ËÌ»Ï
ÐÑ
È‘I*+·M,Ç3»    Y·
N-+¶-+¶-    ¸ ¶-¶-¶-¶-¶-°»Y·N»    Y·
:*´+¶¶6+¶+¶,¶¶m¸ ¶,¶¸²¶¶ ¶,¶!¸²¶¶ ¶,¶"¸²¶¶ ¶,¶#¸²¶¶ ¶*´$¶%»&Y·')¶*+¶*¶+,¹-¸.¸/¶0À1¶29,¶3¸/¸4¸/¶0À1¶29¸5¸6¶7*´$¶%»&Y·'8¶*+¶*¶+9¹-¸.¸/¶0À1¶29
,¶:¸/¸4¸/¶0À1¶29—š¶;—ž¶;¸5¸<9—š¶;¸5¸=9¶7
¸5¸6¶>¶?¶;-¸@¶A¶B¶;-¸@¶C*´$¶%»&Y·')¶*+¶*¶+,¶D¸/¹E*´$¶%»&Y·'8¶*+¶*¶+9¶F¸/¹E°ɖ%:;
<=>?$@)A.B3C8D:FBGKHXI^JdKwMŽN¥O¼PÓR
S
U
0V
cW
|Y
Z
ž]
¥^
¶`
½b
Îc
ád
ôfgFhÊp(ÒÓIËÌIÔ±
CÕÖB×ØK
þÒÓX
ñÙÚ

CÛÜ

*ÝÜ
cæÞÜ

|ÍßÜà$ü:áÿ
c
âãáäå
æç
È
*´¹G
™*´+¹HÀI¸J™
È*´K+¶LM,ºM¸N¹O,¹P
ºQºRºSºT¸U¹VÀWN-¶X™W*´+-¹YW*´$¶Z»&Y·'[¶*+¶*¶+,¹\
[h ,[g¹]§,,¹\
d¹]¹^§
0*´$¶Z»&Y·'[¶*+¶*¶+¹_À`:Çu»aY·b:c+¶dWe¸f¸ ¶gWe¶hWi¶jW*´k¹l:¸m™.¹]`½n¸oÀ`:p¶q¸f¸ ¶r§
°
:¶sÀ`:§ :¶u°¸f¸ ¶r*´vx¹y:¸z™[¹]À    :¶;¶{¸|9¶!¸5¸=¶}¶#¸5¸=¶~¶"¸5¸=¶°¸fmA*´+¹HÇ
°*´+¹HÀW ¸ ¶€À`:°

U
_
btÉ¢(lm(o6r\tcuow·zÛ{à|é}ò~

€

‚
%ƒ
;„
B…
P‡
RŠ
UŒ
_
b
dŽ
i
l‘
w’
„“
Œ”
™™
¨š
»›
Μ
á
ä£
ì¥
ù¦
û¨©ÊŽéièé
5êë
dìí
™KÒÓ
¨<îÜÛ
    ÕÖ
UïÖ
„`ðë(
¼ñë\
ˆòóËÌÔ±

ì+ôõÕÖö*éiè÷
5êø
„`ðù(
¼ñúàv
ÿâãûüýãÿ âãûüýãþþ˜áÿûù
ÿâãûüáá

    ÿwâãü


Ç
È8


*´¹
±É
®    ¯Ê

ËÌ


Èb*´K+¶‚M,¸ƒ°É
µ    ·Ê ËÌÔ±
    
ëö
    
ú»
    

ÈÃ
»„Y·…L=*¹\
>¢
    *¹]À`:¶¶7¶9¶"9    ¶#9¶!9 ¶:9¶39†a7`6¢`*¹]À`¶¶”œI*¹]À`:    ¶"¸ˆ9    ¶#¸ˆ9¶:c9¶3c9¶!9 „
§ÿ »`Y·‰:¶Š¶‹¸ ¶r¶Œ    ¶¶~ ¶}¶¶Ž+¹W=§þø+°ɒ$»¼
½¾¿"À,Á3Â:ÃAÄHÅOÆVÈ^Ëc͍̀ΙϥЯѹÒÀÓÃÔÆ×ÏØÙÙãÚêÛñÜøÝÿÞ
ß
 à
á
â
ãÊ¢6
Ö"÷
    Ö,í

õ3æ
Ü:ß
Ü    AØ
 ÜHÑ
Ü OÊßÜVÃÝÜ^»
õc¶
ÚÏJ
Ö

ë

ë



Ú
 
Úö

ú

ú
à7þû

ÿQûû

á
ûbÿUûû

»




È"Z»Y·‘M,+¶’,¸f¸ ¶“*+·N*´+¶”:-Æ-¶:—š&*´$¶Z»&Y·'[¶*+¶*¶+¹_À`N-Æ-¶:—š“²•–+¹—*´v+¹y:¸˜™
°¹]À    :¸m™]»`Y·‰N-¶?¶~-¶B¶-¶;¶}-¶{¶Œ¶F—š-™›¸¶¶D—š-›ž¸¶Ž-¶:9—š™›¸9
 ¸¢:»Y·:
6¢

9*´+¹HÆ*´+¹HÀ1¶29»£Y·¤:-¶#-¶!
¸@¸¶¥²¶¶ X-¶#-¶!
¸@¸¶¥²¶¶ ¸/¶¦¹]À1¶2¶¥¸5¸=¸/¶§»£Y·¤:        -¶"-¶!
¸@¸¶¥²¶¶ ¸/¶¦    `¹]À1¶2¶¥¸5¸=¸/¶§,¶¨    ¹W,¶©¹W„
§þö,¶©ºª¸N¹«
¹O,¶¨ºª¸N¹O,°ɶ-èé êëì'î4ïWñdòoó{ôƒõ…÷’øšù¢ú«û´ü½ýÆþÐÿÝ

ç
ô
ú



    




!

*

-

:

L

U

t

š
 
¾
#
Ç
$
í
%
&
'+
1
*G
+X
,ʎ{yðë’bÒÓ
-þ
Ü
UÜ


Çj

    
$
 
ÚZËÌZÔ±
R

=ÕÖ'3
 
!ú
`ßÜ

B
"ë
!
9×Ø
ö{yðù

B
"
#àJ
þ4
$á
%"ü ûüWåùüÿâã
$á
%ûä
ü'ùä

&
'
È/

*´°É
'Ê
ËÌ

(
)
È/

*´K°É
)Ê
ËÌ

*
+È/

*´$°É
+Ê
ËÌ»
,

-
.
È/

*´v°É
-Ê
ËÌ

/
0
È/

*´k°É
/Ê
ËÌ

1ÎÈ/

*´°É
7Ê
ËÌ»
2

3
4
È6
*°É
rÊ
5Ö
6Ö


7
8
È,

*°É
rÊ
ÕÖ

9
:
È9
*¶¶m¸ °É
rÊ

;Ö
<Ç
È!
    w¸¬³•±
É
"
=
>µ

?†

„Š…
ˆ>
‰
Š
‹
Œ
‰
Š
“
Œ
‰
Š
”
•
‰
–
—
˜
‰
š
›
œ
‰
Š
Þ
ß