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
Êþº¾4
W
VŸ ¡
¢
£    T¤¥¦§œ@
¨©ª«
¬­
®¯
¬°è    T±
²³´
µ¶
·¸    T¹
º»¼½¾½¿ÀÁ¦Â    TÃ
ÄÅ
ÆÇ
ÈÉÊ
ËÌ
Í
Î
ÏÐ
Ñ
ÏÒ
TÓÔÕ¦Ö
×
ØÙd
ØÚÛ
ÜÝ
8ŸÞß
8à
á
8â    Tãäåæçæè    Té
êëì
í
êî    Ïï
ðñ
ò
²óô
M×
êõö÷¦øùú
ûüýþ
log
Lorg/slf4j/Logger;
contractOrderService
8Lcom/yami/trading/service/contract/ContractOrderService;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
contractApplyOrderService
=Lcom/yami/trading/service/contract/ContractApplyOrderService;
dataService
+Lcom/yami/trading/service/data/DataService;
8Lorg/springframework/beans/factory/annotation/Qualifier;
value
itemService
+Lcom/yami/trading/service/item/ItemService;
redissonClient
!Lorg/redisson/api/RedissonClient;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
BLcom/yami/trading/huobi/task/contract/ContractApplyOrderHandleJob;
start
run
order
:Lcom/yami/trading/bean/contract/domain/ContractApplyOrder;
 realtime_list
Ljava/util/List;
realtime
,Lcom/yami/trading/bean/data/domain/Realtime;
bySymbol
(Lcom/yami/trading/bean/item/domain/Item;
isOpen

Z

e
Ljava/lang/Exception;
processSuccess
oneContractApplyOrderId
Ljava/lang/String;
LocalVariableTypeTable
>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;
 StackMapTableÿ´
À

úÔ

handle
i(Lcom/yami/trading/bean/contract/domain/ContractApplyOrder;Lcom/yami/trading/bean/data/domain/Realtime;)Z
lockKey
rLock
Lorg/redisson/api/RLock;
5Lcom/yami/trading/bean/contract/domain/ContractOrder;

lock_order

i

I
list
allProcessOk

applyOrder
lock
GLjava/util/List<Lcom/yami/trading/bean/contract/domain/ContractOrder;>;
ô
<clinit>

SourceFile
 ContractApplyOrderHandleJob.java
*Lorg/springframework/stereotype/Component;hi
java/lang/Thread
ContractApplyOrderHandleJobh
oiXY
委托单处理线程启动！




    


+com/yami/trading/common/constants/RedisKeys
new_contract_apply_orders


 




^_



8com/yami/trading/bean/contract/domain/ContractApplyOrder


    submittedÿ

`a


u





 
*com/yami/trading/bean/data/domain/Realtime
E---> ContractApplyOrderHandleJob.run symbol:{} çš„ realTime å€¼ä¸ºç©º
!
"de
#
$
%


&

'
(
)
limit
*

buy
+

,
-
.
/
0
1
2
3
4‹Œ
java/lang/Exception
合约订单:{} å¤„理失败
5
6
7

8
9
)
:

open
;

java/lang/StringBuilder
7com/yami/trading/common/constants/RedisLockKeyConstants
lock_contract_apply_to_order_
<
=
>

?
fg
@
A
B

C
D
EiZ[
F
G
H
close
I

J
K
L
M
N
O
created
P

Q

3com/yami/trading/bean/contract/domain/ContractOrder
R
S
>---> ContractApplyOrderHandleJob.handle å¤„理合约:{} æŠ¥é”™
J---> ContractApplyOrderHandleJob.handle å½“前合约:{} è®°å½•æ— æ³•å¤„理
5
"
?---> ContractApplyOrderHandleJob.handle å¤„理合约:{} æŠ¥é”™:
@com/yami/trading/huobi/task/contract/ContractApplyOrderHandleJob
T
U
V
java/lang/Object
java/lang/Runnable
java/lang/String
java/util/List
&com/yami/trading/bean/item/domain/Item
java/lang/Throwable
org/redisson/api/RLock
)(Ljava/lang/Runnable;Ljava/lang/String;)V
org/slf4j/Logger
info
(Ljava/lang/String;)V
(com/yami/trading/common/util/ThreadUtils
sleep
(J)V
&com/yami/trading/common/util/RedisUtil
spop
&(Ljava/lang/String;)Ljava/lang/String;
cn/hutool/core/util/StrUtil
isBlank
(Ljava/lang/CharSequence;)Z
sadd
'(Ljava/lang/String;Ljava/lang/String;)V
;com/yami/trading/service/contract/ContractApplyOrderService
getById
*(Ljava/io/Serializable;)Ljava/lang/Object;
getState
()Ljava/lang/String;
equals
(Ljava/lang/Object;)Z
    getSymbol
)com/yami/trading/service/data/DataService
$(Ljava/lang/String;)Ljava/util/List;
size
()I
get
(I)Ljava/lang/Object;
warn
'(Ljava/lang/String;Ljava/lang/Object;)V
)com/yami/trading/service/item/ItemService
findBySymbol
<(Ljava/lang/String;)Lcom/yami/trading/bean/item/domain/Item;
getOpenCloseType
*com/yami/trading/service/MarketOpenChecker
isMarketOpenByItemCloseType
(Ljava/lang/String;)Z
getOrderPriceType
getDirection
getClose
()D
java/math/BigDecimal
valueOf
(D)Ljava/math/BigDecimal;
getPrice
()Ljava/math/BigDecimal;
    compareTo
(Ljava/math/BigDecimal;)I
error
9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V

getOrderNo
.com/yami/trading/service/contract/ContractLock
add
remove
    getOffset
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
getUuid
toString
org/redisson/api/RedissonClient
getLock
,(Ljava/lang/String;)Lorg/redisson/api/RLock;
tryLock
()Z
unlock
6com/yami/trading/service/contract/ContractOrderService
saveOpen
i(Lcom/yami/trading/bean/contract/domain/ContractApplyOrder;Lcom/yami/trading/bean/data/domain/Realtime;)V

getPartyId
 findSubmitted
H(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Ljava/util/List;
ZERO
Ljava/math/BigDecimal;
    setVolume
(Ljava/math/BigDecimal;)V
setState

updateById
    saveClose
´(Lcom/yami/trading/bean/contract/domain/ContractApplyOrder;Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;)Lcom/yami/trading/bean/contract/domain/ContractApplyOrder;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!TV
WXYZ[
\
]^_
\
]`a
\]b
cs`de
\
]fg
\
]
hi
j/

*·
±k
"l
mn
oi
jJ
»Y*·¶²¹±k4 56l
mn
pi
jÔ    
–    ¸<
M ¸M,¸™<š     ,¸¸§ÿÝ*´,¶ÀN-Æ-¶¶š<š     ,¸¸§ÿ¬*´-¶¹:
:¹
ž¹À:§$²-¶¹ š     ,¸¸§ÿ_*´!-¶¶":Çš     ,¸¸§ÿ:¶#¸$6šš     ,¸¸§ÿ%-¶&¶™I'-¶(¶™ ¶)¸*-¶+¶,3*-¶-<§(¶)¸*-¶+¶,›*-¶-<§*-¶-<š     ,¸¸§8N²/,-¹0š     ,¸¸§:š     ,¸¸¿§þs

^.,J
^.]—
^.ª¼
^.ÏÞ
^.ñ
K
^.

~,J
~]—
~ª¼
~ÏÞ
~ñ
K
~
^
k
~
~
€
~kÞ7=?@
BCE‚…#ˆ,K8LHMJ‚N…Tˆ]QlRoSyT‰W—‚›…¡ˆª\·]¼‚À…ƈÏ`Ùaނâ…èˆñfýj
    n
o
&u
8v
C}
K‚
O…
Uˆ
[‰
^
_€
k‚
o…
uˆ
{‰
~‚
„…
Šˆ
‰
“Šl\    8
qrlßstoÜuv·”wxÙryz
_{|
‹}z


‰~
–mn€
lßs‚dý
ƒü„ý+…†ü‡ü
4ÿˆ
ƒ    H‰HŠÿ    ˆ
ƒŠÿ
ˆ
‹Œ
jž>+¶1¸2š6™3¸+¶1¸5¬>6+¶7¶™¿»8Y·9;¶<+¶=¶<¶>:*´?¹@:¹A
š6™3¸+¶1¸5¬*´+¶=¶À:ƶ¶š!6¹B
™3¸+¶1¸5¬*´C+,¶D¹B
§:¹B
¿6™3¸+¶1¸5¬E+¶7¶™
D*´C+¶F+¶+¶(¶G:¹
š0+²H¶I+J¶K*´+¶LW6™3¸+¶1¸5¬66¹
¢Î¹ÀM:6¶N¸2š6™¤3¸¶N¸5§“6*´C+,¶N¶OLJ+¶¶™6™s3¸¶N¸5§b™W3¸¶N¸5§F:    6²P+¶=    ¹0™,3¸¶N¸5§:
™3¸¶N¸5
¿„
§ÿ,6™3¸+¶1¸5¬²Q+¶=¹R6™3¸+¶1¸5¬:²S+¶=¹06™3¸+¶1¸5¬:™3¸+¶1¸5¿wœÊ·ÀÊÊÌÊ
h
v
Ù.
Œ
­
Ù.
h
v
Œ
­
Ù
î_.#c_.w£_.·Ù_.í
1_.
E&_.:K_.ˆ#cˆw£ˆ·Ùˆí
1ˆ
E&ˆ:Kˆ_tˆˆŠˆk
’dŽ‘ÛÜÝ ‘#“%”1–I—V˜`™cÛgÜmÝt™w‡ž™ œ¥£Û§Ü­Ý´ ·£À¥Ç¦Ê¥Ó¦Ö¨ÙÛÝÜãÝê¨í©ù­
®
    ­
¯
°
±
%²
.³
1Û
5Ü
;Ý
B³
E¶
H·
W¸
e¹
h»
s¼
vÊ
{Ë
Ì
Œ¿
À
žÂ
ªÃ
­Ê
²Ë
¸Ì
ÃÊ
ÈË
ÎÌ
ÙÆ
ÛÇ
ÞÈ
îÊ
óË
ùÌÊËÌη"Ñ&Û*Ü0Ý7Ñ:ÔHÕKÛOÜUÝ\Õ_Öa×qÙtÛxÜ~݅وێܔݛßlŽ‡9qrI¤V—Ž
Û{|    
e·q
h´‘z
Kג“

,”t
Hò•za'{|žmnž–r
žuvœ—z€


,”˜‚Úý 

úþPƒ™
úü!„ü
úÿˆ„†
Ī
Šü
øýT…
úý

ý@š
6U‰jŠýŠÿˆ„†
…

úü
øü!
ÿˆ„†

‰ý%‰
ÿˆ„†

Šÿˆ„†
Š›i
j!
    T¸U³±
k
 œ\
ž