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
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
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
Êþº¾4
¨@A
@    ¦BC
D    ¦EF G    ¦HI JK
LM NOP
@    ¦Qí
RS
TU JV WX WY Z[\ Z]    ¦^
_ `ab
@c
d
e Nf
ghi
¡j
k
Qlm
no
p
Qqr
s
t    ¦u vw
x
ny
™z
{
g|?„záG®{
}~

¡e
¦€

}‚
ƒ
¦„…
†
A‡ Jˆ    ¦‰
Š‹Œ Ž    ¦ ‘’È
“”•
¦–—
Q@
¦˜
 
T™
š›
[œ    ¦ žŸ J ¡
}¢    ¦£ ¤¥
¦{ ¤§¨
a@©ß
aª
«¬
a­
a®
a¯°±
a²
a³
[´
aµ¶
a·
a¸    ¦¹ º» ¤¼
½¾
«z
½¿ ¤ÀÁ    ¦ÃÄ
}Å
ÆÇÈ    ¦É ÊËÌ
¡Í    ¦ÎÏ
†Ð ÑÒÓ
ÔÕÖ
Ô¿ Ž×Ø ŽK ŽÙ ÚVÛ ’ÜÝ
Þ
gß
™à Ž×á
™⠎㠎äåæ Nç ’èéêëì Žíî
ïðñò InnerClasseslogLorg/slf4j/Logger; minerService5Lcom/yami/trading/service/miner/service/MinerService;RuntimeVisibleAnnotations8Lorg/springframework/beans/factory/annotation/Autowired; partyService+Lcom/yami/trading/service/user/UserService;userRecomService0Lcom/yami/trading/service/user/UserRecomService; redisTemplate3Lorg/springframework/data/redis/core/RedisTemplate;userDataService/Lcom/yami/trading/service/user/UserDataService;moneyLogService*Lcom/yami/trading/service/MoneyLogService;minerOrderService:Lcom/yami/trading/service/miner/service/MinerOrderService; walletService(Lcom/yami/trading/service/WalletService; jdbcTemplate,Lorg/springframework/jdbc/core/JdbcTemplate;sysparaService1Lcom/yami/trading/service/syspara/SysparaService; dataService+Lcom/yami/trading/service/data/DataService;namedParameterJdbcTemplateGLorg/springframework/jdbc/core/namedparam/NamedParameterJdbcOperations;cacheRecomProfitLjava/util/Map;    Signature5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Double;>;<init>()VCodeLineNumberTableLocalVariableTablethisILcom/yami/trading/service/miner/service/impl/MinerOrderProfitServiceImpl;pagedQueryComputeOrder@(II)Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;pageNoIpageSizepage<Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;saveComputeOrderProfits(Ljava/util/List;Ljava/lang/String;Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;Ljava/util/Date;)V
day_profitDorder(Lcom/yami/trading/bean/miner/MinerOrder;miner#Lcom/yami/trading/bean/miner/Miner;order1Ljava/lang/Object;ordersLjava/util/List;miner_profit_symbolLjava/lang/String;realtime,Lcom/yami/trading/bean/data/domain/Realtime;miner_bonus_parameters
systemTimeLjava/util/Date;saveMinerOrdersminer_test_profitLjava/lang/Double;LocalVariableTypeTableHLjava/util/List<Lcom/yami/trading/service/miner/job/MinerOrderMessage;>; StackMapTableóáôæ\õîé¡—c(Ljava/util/List;Ljava/lang/String;Lcom/yami/trading/bean/data/domain/Realtime;Ljava/lang/String;)VobjupdateProfitToWalletj(Ljava/lang/String;DLcom/yami/trading/bean/data/domain/Realtime;Lcom/yami/trading/bean/miner/MinerOrder;)V realtime_listrealtimeBuySymbolgetSymbolVolume walletExtend*Lcom/yami/trading/bean/model/WalletExtend; amountBeforemoneylog&Lcom/yami/trading/bean/model/MoneyLog;wallet$Lcom/yami/trading/bean/model/Wallet;miner_buy_symbol>Ljava/util/List<Lcom/yami/trading/bean/data/domain/Realtime;>;z(Ljava/lang/String;DLcom/yami/trading/bean/data/domain/Realtime;Lcom/yami/trading/bean/miner/MinerOrder;Ljava/util/Date;)Vget_symbol_volumeupdateBatchMinerOrdersProfit(Ljava/util/List;)V    orderListsql batchUpdate[IK(Ljava/util/List<Lcom/yami/trading/service/miner/job/MinerOrderMessage;>;)VhandleRecomProfitK(Ljava/lang/String;DLcom/yami/trading/bean/miner/Miner;Ljava/lang/String;)VentryEntryLjava/util/Map$Entry;
minerOrder miner_party
pip_amount    get_money recom_profit party_parent"Lcom/yami/trading/bean/model/User;    map_partycycleitLjava/util/Iterator;ipartyIdprofit list_parentsminer_bonus_array[Ljava/lang/String;looploopMaxQLjava/util/Map$Entry<Ljava/lang/String;Lcom/yami/trading/bean/miner/MinerOrder;>;KLjava/util/Map<Ljava/lang/String;Lcom/yami/trading/bean/miner/MinerOrder;>;gLjava/util/Iterator<Ljava/util/Map$Entry<Ljava/lang/String;Lcom/yami/trading/bean/miner/MinerOrder;>;>;9Ljava/util/List<Lcom/yami/trading/bean/model/UserRecom;>;*öØÛsaveRecomProfitmoneyLog;Ljava/util/Map$Entry<Ljava/lang/String;Ljava/lang/Double;>;(Ljava/util/Date;)VcacheRecomProfitClear<clinit>ÔLcom/baomidou/mybatisplus/extension/service/impl/ServiceImpl<Lcom/yami/trading/dao/miner/MinerOrderMapper;Lcom/yami/trading/bean/miner/MinerOrder;>;Lcom/yami/trading/service/miner/service/MinerOrderProfitService;
SourceFile MinerOrderProfitServiceImpl.java(Lorg/springframework/stereotype/Service;:Lorg/springframework/transaction/annotation/Transactional; ËÌ&java/util/concurrent/ConcurrentHashMap ÇÈ:com/baomidou/mybatisplus/extension/plugins/pagination/Page Ë÷ øù+com/yami/trading/dao/miner/MinerOrderMapper Òú «¬start compute order size:{}ó ûüý þÿ java/util/ArrayList Á       
ô     &com/yami/trading/bean/miner/MinerOrder  ­®  java/lang/StringBuilder,该矿机不存在,停止计息,minerId:   õ N   !" #$Y% &' (" )$0 * +8 »¼, -. /" 01 23 43 536 78 9  :3 ;8 <= þ 4com/yami/trading/service/miner/job/MinerOrderMessage > Ë? ;  µ¶@ AB5com/yami/trading/service/miner/service/MinerRedisKeysMINER_ORDER_ORDERNO_C DE ·¸F GHI JK start miner batch update size:{} java/util/Date þÿ LM NO P3 ÃÄQ çR ST*com/yami/trading/bean/data/domain/Realtime U8 ½¾V WXY Z[$com/yami/trading/bean/model/MoneyLog+com/yami/trading/common/constants/Constants \] þ^ _` a` b`矿机收益,订单号[] c d e f miner_profit g h8 ¹ºi j  klm no p qHUSDT@UPDATE T_MINER_ORDER SET PROFIT=?,COMPUTE_DAY=? WHERE ORDER_NO=? ¿ÀIcom/yami/trading/service/miner/service/impl/MinerOrderProfitServiceImpl$1 Ërs tend miner batch update attr:{} ³´u vR, wx ±²%com/yami/trading/bean/model/UserRecom yz {|MEMBERö }MINER_ORDER_PARTY_ID_ S~ java/util/Map €java/util/Map$Entry ‚1 ƒ „ü þ…java/lang/Double þ† ‡ˆ ‰ 4start ------recom user miner profit,date:{},count:{}java/lang/Object Š ‹java/lang/String矿机推荐奖励金miner_recom_profit5finish ------recom user miner profit,date:{},count:{} ŒÌGcom/yami/trading/service/miner/service/impl/MinerOrderProfitServiceImpl Ž;com/baomidou/mybatisplus/extension/service/impl/ServiceImpl>com/yami/trading/service/miner/service/MinerOrderProfitServicejava/util/Listjava/util/Iterator!com/yami/trading/bean/miner/Miner com/yami/trading/bean/model/User(JJ)V
baseMapper1Lcom/baomidou/mybatisplus/core/mapper/BaseMapper;z(Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;)Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;size()Ijava/lang/IntegervalueOf(I)Ljava/lang/Integer;org/slf4j/Loggerinfo'(Ljava/lang/String;Ljava/lang/Object;)V/com/yami/trading/service/syspara/SysparaServicefindB(Ljava/lang/String;)Lcom/yami/trading/bean/syspara/domain/Syspara;,com/yami/trading/bean/syspara/domain/Syspara    getDouble()Ljava/lang/Double;iterator()Ljava/util/Iterator;hasNext()Znext()Ljava/lang/Object;com/alibaba/fastjson2/JSON toJSONString&(Ljava/lang/Object;)Ljava/lang/String; parseObject7(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object; getMiner_id()Ljava/lang/String;3com/yami/trading/service/miner/service/MinerService    cacheById7(Ljava/lang/String;)Lcom/yami/trading/bean/miner/Miner;append-(Ljava/lang/String;)Ljava/lang/StringBuilder;toStringerror(Ljava/lang/String;)VgetTestequals(Ljava/lang/Object;)Z getEarn_time()Ljava/util/Date;before(Ljava/util/Date;)Z&com/yami/trading/common/util/DateUtils getDayStart"(Ljava/util/Date;)Ljava/util/Date; getStop_timeaftersetStatesetCompute_day8com/yami/trading/service/miner/service/MinerOrderService    saveClose+(Lcom/yami/trading/bean/miner/MinerOrder;)VgetCompute_dayaddDate#(Ljava/util/Date;I)Ljava/util/Date; doubleValue()D    getAmount getDaily_rate"com/yami/trading/common/util/Arithmul(DD)D
getPartyId    getProfitadd    setProfit(D)V getOrder_no&(Ljava/lang/String;DLjava/util/Date;)V1org/springframework/data/redis/core/RedisTemplate opsForValue7()Lorg/springframework/data/redis/core/ValueOperations;3org/springframework/data/redis/core/ValueOperationsset'(Ljava/lang/Object;Ljava/lang/Object;)V-com/yami/trading/service/user/UserDataServicesaveMinerProfit(Ljava/lang/String;D)V(com/yami/trading/common/util/ThreadUtilssleep(J)V    getSvalue(com/yami/trading/common/util/StringUtils
isNotEmpty(Ljava/lang/String;)ZgetClose)com/yami/trading/service/data/DataService$(Ljava/lang/String;)Ljava/util/List;get(I)Ljava/lang/Object;div&com/yami/trading/service/WalletServicesaveExtendByParaP(Ljava/lang/String;Ljava/lang/String;)Lcom/yami/trading/bean/model/WalletExtend;(com/yami/trading/bean/model/WalletExtend updateExtend((Ljava/lang/String;Ljava/lang/String;D)V setCategoryjava/math/BigDecimal(D)Ljava/math/BigDecimal;setAmountBefore(Ljava/math/BigDecimal;)V    setAmountsetAmountAftersetLog    setUserId    getSymbol setWalletTypesetContentType setCreateTime(com/yami/trading/service/MoneyLogServicesavesaveWalletByPartyId8(Ljava/lang/String;)Lcom/yami/trading/bean/model/Wallet;"com/yami/trading/bean/model/WalletgetMoney()Ljava/math/BigDecimal;    getUserIdupdate\(Lcom/yami/trading/service/miner/service/impl/MinerOrderProfitServiceImpl;Ljava/util/List;)V*org/springframework/jdbc/core/JdbcTemplateR(Ljava/lang/String;Lorg/springframework/jdbc/core/BatchPreparedStatementSetter;)[I.com/yami/trading/service/user/UserRecomService
getParentssplit'(Ljava/lang/String;)[Ljava/lang/String;getRecomUserId)com/yami/trading/service/user/UserService cacheUserBy6(Ljava/lang/String;)Lcom/yami/trading/bean/model/User; getRoleName&(Ljava/lang/Object;)Ljava/lang/Object;entrySet()Ljava/util/Set; java/util/SetgetValuegetStategetCycle&(Ljava/lang/String;)Ljava/lang/Double;(D)Ljava/lang/Double;put8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;isEmpty((Ljava/lang/String;[Ljava/lang/Object;)VgetKeyclearorg/slf4j/LoggerFactory    getLogger%(Ljava/lang/Class;)Lorg/slf4j/Logger;!¦¨©«¬­®¯°±²¯°³´¯°µ¶¯°·¸¯°¹º¯°»¼¯°½¾¯°¿À¯°Á¯°Ãį°ÅƯ°ÇÈÉÊ ËÌÍ>*·*»Y·µ±Î
1NÏ ÐÑÒÓÍl»Y……·N*´À-¹    W-°ÎY Z[Ï*ÐÑÔÕÖÕ רÙÚÍä7²
 +¹ ¸ ¹»Y·:*´¶¶:+¹:¹™ã¹:        ¸¸À:
*´
¶¹:  ¦%²
»Y· ¶!
¶¶!¶"¹#§ÿ© ¶$%¶&™
¶'¶(™§ÿŒ ¶$)¶&™
¶'¸*¶(™§ÿl
¶+Æ,
¶+¶,™
-¶.
¶/*´0
¹1§"
¶2Æ[
¶2¸3¸*¶(™G9  ¶$)¶&™ ¶49 §
¶5 ¶67¸9¸99 *
¶:¶;  ¶<§þÛ9  ¶$)¶&™ ¶49 §
¶5 ¶67¸9¸99 
¶/
 
¶= ¸>¶?*, -
¶@»AY
¶B
¶=
¶2·C¹DW*´E¶F»Y·H¶!
¶B¶!¶"
¹I*´J
¶:¶; ¹K*
¶:¶;  ¶<L¸N§þ²
O¹ ¸ ¹*¶P±Ϊ*ijk*lEmTqdrjs‰tŒw¦x©{Æ|Éހåì‚ú…†‡ˆ&‰0‹EWŽZ“]”j•t—‰™šŸ¡«£³¤ɦ¬®¯0°6±Ï„ AÛÜ ]¼ÛÜ TÅÝÞ
dµßà EÔáâ    7ÐÑ7ãä7åæ7çè7éæ7êëìä* íîï ìðñO þ2òóôþYõö÷0ü5úüÿ    øòùúùûòóôúÙüÍí M²
 +¹ ¸ ¹»Y·:*´¶¶:+¹:¹™ù¹:¸¸À:    *´    ¶¹:
 
¦%²
»Y· ¶!    ¶¶!¶"¹#§ÿ©
¶$%¶&™»QY·R    ¶'¶(™§ÿ‡
¶$)¶&™»QY·R    ¶'¸*¶(™§ÿb    ¶+Æ6»QY·R    ¶+¶,™$    -¶.    »QY·R¶/*´0    ¹1§$    ¶2Æ`»QY·R    ¶2¸3¸*¶(™G9 
¶$)¶&™ ¶49 §    ¶5
¶67¸9¸99 *    ¶:¶; 
¶<§þÂ9 
¶$)¶&™ ¶49 §    ¶5
¶67¸9¸99     »QY·R¶/        ¶= ¸>¶?*, -    ¶S»AY    ¶B    ¶=    ¶2·C¹DW*´E¶F»Y·H¶!    ¶B¶!¶"    ¹I*´J    ¶: ¹K*    ¶: 
¶<L¸N§þ²
O¹ ¸ ¹*¶P±Ϊ*¾¿À*ÁEÂTÆdÇjȉɌ̫ͮÐÐÑÓÔíÕôÖ×ÚÛ/Ü2Ý?ÞIà^âpãsèvéƒêì¢î®ï½öÇøÏùåû
ýÿ)/2FLÏz 2AÛÜ v¹ÛÜ TÛÝÞ    dËßà
EêýâMÐÑMãäMåæMçèMéæ1ìä*#íîï 1ìðñL þ2òóôþYõö÷!$:ü:úüÿŒøòùúùòóôúþÿÍV Î*´T¶¶U:¸V™J+¶&™(¶W¸9I§4*´X¹Y::¹ ž¹ZÀ[:(¶W¸9I+¸V™Á(¶W¸\9*´]¶:+¹^:        ¶_9
*´]¶:+¹`»aY·b:  d¶e 
¸f¶g ¸f¶h 
¸>¸f¶i »Y·j¶!¶B¶!k¶!¶"¶l ¶:¶m ¶n¶o p¶q »QY·R¶r*´s ¹tW§®*´]¶:¹u:¶v¶w9*´]¶x(¹y»aY·b:
 
d¶e
¸f¶g
(¸f¶h
(¸>¸f¶i
»Y·j¶!¶B¶!k¶!¶"¶l
¶:¶m
z¶o
p¶q
»QY·R¶r*´s
¹tW±Φ),9<FS] d!o#€$‡%˜'¡(¨)²*¼+Ë,ì-ö./012"526<7K9T:[;e<n=|>?§@®AµBÁCÍEϘ9$ä<!èo°Ü€Ÿ    ‡˜Ü
¡~ 2›    <‘ÜTy
ÎÐÑÎåæÎÛÜÎçèÎÝÞÀ
æï 9$ ñü,ùý&òúù    ûÄûªþ ÍVÄ*´T¶¶U:¸V™J+¶&™(¶W¸9I§4*´X¹Y::    ¹ ž¹ZÀ[:    (    ¶W¸9I+¸V™¼(¶W¸\9*´]¶:+¹^:
 
¶_9 *´]¶:+¹`»aY·b:  d¶e  ¸f¶g ¸f¶h  ¸>¸f¶i »Y·j¶!¶B¶!k¶!¶"¶l ¶:¶m ¶n¶o p¶q ¶r*´s ¹tW§©*´]¶:¹u:¶v¶w9    *´]¶x(¹y»aY·b:  d¶e     ¸f¶g (¸f¶h     (¸>¸f¶i »Y·j¶!¶B¶!k¶!¶"¶l ¶:¶m z¶o p¶q ¶r*´s ¹tW±Φ)QRST,V9W<XFYS[]_d`ob€c‡d˜f¡g¨h²i¼jËkìlömnopqt-u7vFxOyVz`{i|w}˜~¢©€°·‚ÄϢ9$ä<!è    o« Ü€š
‡“Ü ¡y -–    7ŒÜ    Ot ÄÐÑÄåæÄÛÜÄçèÄÝÞÄêë¶
æï 9$ ñü,ùý&òúù    û¿û¥͇!{M*´|,»}Y*+·~¶N²
€-¹±ÎŒ™ šÏ*!ÐÑ!äæ ï !ðÉ͆¶$)¶&™±*´+¹‚:¹ š±ƒ¶„:6¾6    6
 
¹ ¢C    ¡§9*´…
¹ZÀ†¶‡¹ˆ: ‰ ¶Š¶&š§    „*´E¶F»Y·‹¶! ¶Œ¶;¶!¶"¹ÀŽ:  ÆÖ ¹š§É6  ¹¹‘:¹™O¹À’:¹“À:”¶•¶&š§ÿÑ*´¶¹: ¶–¢
¶–6 §ÿ­ ¶–¡Xd2¸—¶49(¸99*´ ¶Œ¶;¹˜À™:*´ ¶Œ¶;ǧ¶4¸>¸š¹›W„
§þ·±Ξ' ž ¡$¢%¤.¥1¦6§E¨L©O«i¬v­y¯|°‘±§²¶³¹¸¼¹ÊºÔ»à¼ì½ù¾üÀ ÁÂÅ Ç*Ë9ÌAÎWÏnÐyϧ…ÓÏÊà=ì1Þ à9FÜA>ÜW(îi  §Ø!È ¼Ã"Õ Êµ#$9L%Õ
†Ðц&æ†'܆ßà†éæl(ä.X)*1U+Õ6P,Õ    ï*à=-§Ø!. ʵ#/l(0ñÌüòÿ
øù÷ùò1ü)2ü?3ýôý14öù ÿKøù÷ùò123ôó3ùÿøù÷ùò123ôó3ùÿ
øù÷ùò1ú5ÌÍ J*´¹œ™±²
½žY»QY·RSY*´¹¸ S¹Ÿ*´¹¹‘L+¹™Ù+¹À’M*´],¹ À¡¹uN-¶v¶w9*´]-¶x,¹“À™¶4¹y»aY·b:d¶e¸f¶g,¹“À™¶4¸f¶h,¹“À™¶4¸>¸f¶i¢¶l,¹ À¡¶mz¶o£¶q*´s¹tW*´J,¹ À¡,¹“À™¶4¹K§ÿ$²
¤½žY»QY·RSY*´¹¸ S¹Ÿ±ÎfÚ Û ß&à/ß4áVâiãr䋿”ç›è¥é¹êÒëÙìçíîîõïðñ"ó;ôDóI÷Ï4i¶    r­Ü”‹6VÉJÐÑï VÉ7ñ  ü5ôúÞ58Í7S*´¹œ™±²
½žY»QY·RSY*´¹¸ S¹Ÿ*´¹¹‘M,¹™â,¹À’N*´]-¹ À¡¹u:¶v¶w9*´]¶x-¹“À™¶4¹y»aY·b:d¶e¸f¶g-¹“À™¶4¸f¶h-¹“À™¶4¸>¸f¶i¢¶l-¹ À¡¶mz¶o£¶q+¶r*´s¹tW*´J-¹ À¡-¹“À™¶4¹K§ÿ²
¤½žY»QY·RSY*´¹¸ S¹Ÿ±Îjþ ÿ &/4VjtŽ
— ž ¨ ¼ÕÜêñøþ
(+DMRÏ>j¾    t´Ü—‘6VÒSÐÑSêëï VÒ7ñ  ü5ôúç9ÌÍ8
*´¹¥±Î
     !Ï 
ÐÑ:ÌÍ!    ¦¸§³
±Î0É;<=¯
>?ª}’Ž