Êþº¾ 4Ä chushihua/lunxun java/lang/Object isRunning Z isPaused
|
shouldStop +Ljava/util/concurrent/atomic/AtomicBoolean; pollingThread Ljava/lang/Thread; pollingInterval I sendChaxunzhiling MIN_SLOT ConstantValue MAX_SLOT < SERIAL_CHECK_INTERVAL lastSerialCheckTime J serialConnected queryCommandCache Ljava/util/Map; Signature 6Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/String;>; DEBUG_ENABLED NO_CARD_QUERY_INTERVAL d HAS_CARD_QUERY_INTERVAL ' lastQueryTimeMap 4Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/Long;>; <clinit> ()V Code ( * , )java/util/concurrent/atomic/AtomicBoolean
|
+ . / 0 <init> (Z)V 2 4 6 8 : < &java/util/concurrent/ConcurrentHashMap
|
; > / % @ B D " LineNumberTable LocalVariableTable
|
> this Lchushihua/lunxun; isSendChaxunzhiling ()Z setSendChaxunzhiling checkSerialConnection
|
O Q P java/lang/System R S currentTimeMillis ()J
|
W Y X chuankou/Sendmsg Z K
|
isPortOpen \ $串å£è¿æ¥å¤±è´¥ - 串å£æªæå¼
|
^ ` _ dialog/Errlog a b logOperation (Ljava/lang/String;)V d java/lang/StringBuilder f 串å£è¿æ¥æ£æ¥å¼å¸¸:
|
c h / b
|
j l k java/lang/Exception m n
|
getMessage ()Ljava/lang/String;
|
c p q r append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
c t u n toString currentTime result e Ljava/lang/Exception; StackMapTable checkSerialConnectionWithRetry
|
} M K è
|
java/lang/Thread
sleep (J)V
|
currentThread ()Ljava/lang/Thread;
|
% interrupt java/lang/InterruptedException i Ljava/lang/InterruptedException; startPolling
|
{ K *串å£æªè¿æ¥ï¼æ æ³å¯å¨è½®è¯¢æ¥è¯¢
|
% loadPollingIntervalFromConfig
|
% initializeLastQueryTimes
|
+ 0 set chushihua/lunxun$PollingTask
|
¢ / £ !(Lchushihua/lunxun$PollingTask;)V ¥ CardSlot-Polling-Thread
|
§ / ¨ )(Ljava/lang/Runnable;Ljava/lang/String;)V ª
|
|
¬ 0 setDaemon
|
¯ ° % start ² )å¯å¨è½®è¯¢æ¥è¯¢çº¿ç¨æ¶åçå¼å¸¸: ´ ¶ µ java/util/Map · % clear
|
¹ » º java/lang/Integer ¼ ½ valueOf (I)Ljava/lang/Integer;
|
¿ Á À java/lang/Long ¼ Â (J)Ljava/lang/Long; ´ Ä Å Æ put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; stopPolling ¸
|
Ë Ì
join
|
Î Ï K isAlive Ñ @轮询线ç¨æªå¨3ç§å
åæ¢ï¼æ 记为å®æ¤çº¿ç¨å¹¶å¿½ç¥ Ó åæ¢è½®è¯¢æ¥è¯¢æ¶è¢«ä¸æ:
|
l Ö #åæ¢è½®è¯¢çº¿ç¨æ¶åçå¼å¸¸: Ø java/lang/Throwable pausePolling resumePolling Ü *串å£æªè¿æ¥ï¼æ æ³æ¢å¤è½®è¯¢æ¥è¯¢
|
Þ ß % notifyAll á java/lang/Class isPolling isSerialConnected setPollingInterval (I)V ç 轮询é´éä¸è½å°äº10ms
|
é ê K restartPolling interval getPollingInterval ()I
|
ï Ç K È
|
ó K
|
õ ÷ ö chushihua/Chushihua ø ù getInstance ()Lchushihua/Chushihua;
|
õ û ü K isInitialized
|
õ þ ÿ getMachineConfig ()Lhome/MachineConfig;
|
home/MachineConfig ì í å 载轮询é´éé
置失败: configSystem Lchushihua/Chushihua; machineConfig Lhome/MachineConfig; getCachedQueryCommand (I)Ljava/lang/String; apply ()Ljava/util/function/Function; ´ computeIfAbsent C(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object; java/lang/String
|
slotNumber clearQueryCache sendImmediateQuery (I)Z å¡æ§½ç¼å·å¿
é¡»å¨1-60ä¹é´ *串å£æªè¿æ¥ï¼æ æ³åéæ¥è¯¢æ令
|
|
" # n trim
|
% & K isEmpty
|
W( )* sendMessage (Ljava/lang/String;)Z, +ç«å³æ¥è¯¢å¤±è´¥ - åéæ令å°å¡æ§½
|
c. q/ (I)Ljava/lang/StringBuilder;1 失败3 ;ç«å³æ¥è¯¢å¤±è´¥ - çæçæ¥è¯¢æ令为空ï¼å¡æ§½: 5 ç«å³æ¥è¯¢å¡æ§½ 7 æ¶åçå¼å¸¸: queryCommand Ljava/lang/String;
|
sendResult sendImmediateQueryToAll= 0串å£æªè¿æ¥ï¼æ æ³åéæ¹éæ¥è¯¢æ令
|
+? @ K get
|
BDC java/lang/Math EF min (II)I
|
H 2 successCount batchSize
|
totalSlots
|
batchStart batchEnd slot setSerialConnectedS )串å£è¿æ¥ç¶æ已设置为: æªè¿æ¥
|
U Ù K connected getPollingStatusY å·²åæ¢[ å·²æå] è¿è¡ä¸_ å·²è¿æ¥a æªè¿æ¥ ´c d í size
|
fhg chushihua/SlotManager ij getSlotArray ()[Lhome/Fkj;l 1
|
npo home/Fkj q n
|
getHasCard
|
s tu equals (Ljava/lang/Object;)Zw u轮询ç¶æ: %s, 串å£: %s, é´é: %dms, æ令ç¼å: %d, å¡æ§½èå´: %d-%d, æ å¡: %d(100ms), æå¡: %d(10s)
|
y z{ format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; status serialStatus cacheSize noCardCount hasCardCount slotArray [Lhome/Fkj;
|
Lhome/Fkj; setPollingPaused (Z)Z paused getPerformanceStats ´ @ &(Ljava/lang/Object;)Ljava/lang/Object;
|
¿ S longValue Tæ¥è¯¢æ令ç¼å大å°: %d, 轮询é´é: %dms, è¶
æ¶æ å¡: %d, è¶
æ¶æå¡: %d overdueNoCard overdueHasCard lastQueryTime Ljava/lang/Long; hasCard queryInterval setNoCardQueryInterval (æ å¡å¡æ§½æ¥è¯¢é´éä¸è½å°äº10ms setHasCardQueryInterval *æå¡å¡æ§½æ¥è¯¢é´éä¸è½å°äº1000ms isDEBUG_ENABLED setDEBUG_ENABLED dEBUG_ENABLED access$0 access$1 -()Ljava/util/concurrent/atomic/AtomicBoolean; access$2 access$3 access$4 access$5 ()Ljava/util/Map; access$6 access$7
|
SourceFile lunxun.java BootstrapMethods
|
®°¯ "java/lang/invoke/LambdaMetafactory ±² metafactory Ì(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;
|
¶¸· publicway/QueryData ¹ queryDataµ '(Ljava/lang/Integer;)Ljava/lang/String;» InnerClasses PollingTaskÀ %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles Lookup ! J J
|
|
|
|
|
! " # & $ % & =³ '³ )» +Y· -³ 1d³ 3³ 5 ³ 7³ 9» ;Y· =³ ?³ A» ;Y· =³ C± E *
|
* + $ . . 1 2 6 F / % & / *· G± E F H I J K & $ ² 5¬ E F L 0 & 3 ³ 5± E
|
! " F M K & è R¸ N? ² 7e T ² 9¬ ³ 7¸ V=
|
³ 9§ *[¸ ]³ 9§ M» cYe· g,¶ i¶ o¶ s¸ ]³ 9² 9¬ 0 3 j E : > ? @ C G I M $ N ' O , P 0 R 4 S J T N W F N v w 4 x y z ü ü ÿ j
|
{ K & );§ ¸ | ¬ ~¸ § L¸ ¶ ¬ ¡ÿᬠE & ^ _ ` c d e f ^ ' i F % x z ü H K & ù q² ' ¬¸
|
¸ ]¬¸ ¸ ³ '³ )² 1¶ » Y» Y· ¡¤· ¦³ ©² ©¶ «² ©¶ ®¬K» cY±· g*¶ i¶ o¶ s¸ ]³ '² 1¶ ¬ * K M j E N q s w x y } # * > E K M N d h o F N # x y z w j
|
% & o (² C¹ ³ ;§ ² C¸ ¸ ¸ ¾¹ Ã W <¤ÿé± E ' F
|
z ü Ç K & a ² ' ¬² 1¶ ³ '³ )² ©Æ w² ©¶ ² © ȶ ʲ ©¶ Í [и ]² ©¶ «§ LK» cYÒ· g*¶ Ô¶ o¶ s¸ ]¸ ¶ ³ ©§ ,K» cYÕ· g*¶ i¶ o¶ s¸ ]³ ©§ L³ ©+¿³ ©² 1¶ ¬ # A D # A h j # a h E b ¢ ¤ § ¨ © « ¬ # ® , ° 5 ± : ³ A µ E ¶ [ · a » h ¸ i ¹ » º » ¼ » ¿ Á F E x i x y z { c j] × Ù K & T ² ' ¬² ) ¬³ )¬ E É Í Ð Ô × Ù F z Ú K & ¬ 5² ' ¬² ) ¬¸
|
Û¸ ]¬³ )YK¶ Ý*ç *ÿ¬ & - 0 0 2 0 E 2 á ã æ è ì í î ñ ! ò & ó + ò 3 ö F z ÿ à ×ú â K & $ ² '¬ E þ F K & $ ² )¬ E F ã K & $ ² 9¬ E F ä å & g
|
¢ æ¸ ]±³ 3² ' ¸ èW± E " F ë z ì í & $ ² 3¬ E ) F ê K & g ¸ îW 𸠧
|
K¸ ¶ ¸ ò¬
|
E 1 5
|
6 7 : F x z M
|
% & 3¸ ôK*¶ ú **¶ ýL+¶³ 3§ K» cY· g*¶ i¶ o¶ s¸ ]± j E B C D E J K 2N F
|
x y z Z j
|
& ? ² ?¸ ¸º ¹ À° E T F % & - ² ?¹ ³ ± E
|
[ ] F & p ¨¡ <¤ ¸ ]¬¸ ¸ ]¬¸ L+Æ G+¶!¶$ =+¸'= ² C¸ ¸¸ N¸ ¾¹ à W¬» cY+· g¶-0¶ o¶ s¸ ]¬» cY2· g¶-¶ s¸ ]¬L» cY4· g¶-6¶ o+¶ i¶ o¶ s¸ ]¬ ! P j R l j n j E N ! & 4 9! =# P( R* l+ n. / 2
3 ¦4 F * ¨ & ^89 9 5:
# x y z ý 0ú ÿ j ; í & ¸ <¸ ]¬;<<=¸ NB6§ k² 1¶> § f`d<¸A66§ #¸G ² C¸ ¸!¸ ¾¹ Ã W¤ÿÜ<¢ I¸ § :¸ ¶ § `6<¤ÿ¬ m s v E ^ > ? @ C D E F J K (L +O 8R ?S GT JV \R f[ m] s^ x_ ~` J f F R K ~L {M w v rN 8 IO < *P x x z .
|
ÿ ý ÿ ú
|
ú Q 0 & p %³ 9¸ N³ 7 R¸ ]² ' ² ) ¸TW± E n o
|
q t v w $z F %V z $ W n &
|
Ų '
|
XK§ ² )
|
ZK§ \K² 9 ^§ `L² ?¹b =>6¸e:Æ >Y: ¾66§ ) 2:Æ k¶m¶r § ¡ÿÖv½ Y*SY+SY² 3¸ ¸SY ¸ ¸SY¸ ¸SY<¸ ¸SY ¸ ¸SY¸ ¸S¸x° E Z
|
. 7 9 < A F [ n q t w ³ Á F \
|
|9 |9 §|9 . }9 7 ~ 9 < A [ P z p
|
ü Bÿ &
|
ÿ
|
n ÿ
|
ÿ
& ß G² ' ¬ ² ) ³ )¬¬² ) (¸
|
Û¸ ]¬³ )YL¶ Ý+ç +ÿ¬¬ 6 = @ @ B @ E F ¦ ¨ « ® ° ³ · ¹ &º +» -¾ 1¿ 6À ;¿ Cà EÆ F G z ÿ à ×ú n & Ø º¸ N?=>¸e:Æ {6§ m2:Æ ^`6² C¸ ¸¹ À ¿:Æ A¶m: k ¶r '§ d6
|
¶e
|
k ¶r § ¾¡ÿ½ Y² ?¹b ¸ ¸SY² 3¸ ¸SY ¸ ¸SY ¸ ¸S¸x° E Z Ï Ð Ñ Ó Ô Õ Ö × $Ø *Ù <Ú AÛ HÜ ]Ý kÞ vß yà |á Õ é ê ¶é F f
|
¶ v ´ ² u `P * U < C H 79 ] "
|
z @ ÿ ÿ @ n ¿ Aü ÿ ú å & M
|
¢
|
¸ ]±± E ò ó ô ø F ë z å & N è¢
|
¸ ]±± E ÿ F ë z K & $ ² A¬ E F 0 & 3 ³ A± E
|
F K & $ ² '¬ E F ¡¢ & $ ² 1° E F £ K & $ ² )¬ E F ¤ K & $ ¸ ¬ E ] F ¥ í & $ ² 3¬ E F ¦§ & $ ² C° E 6 F ¨ & % ¸ ° E S F © 0 & % ³ 9± E + F ª «¬ ³ ´º¼½ ¾
|
¿ÁÃ
|
