Êþº¾ 4& *com/dev/lock/comm/Lock_SocketClient_Thread java/lang/Thread pool Lcom/sql/MysqlConnPool;
|
tmp_socket Ljava/net/Socket; logger !Lorg/apache/logging/log4j/Logger; config Lcom/config/AppConfig; mLock_State #Lcom/dev/lock/data/ElectLock_State; mLock_param client_ip Ljava/lang/String; client_id I mRtu_Tx Lcom/dev/modbus/MyModBusRtu; mRtu_Rx ele_lock !Lcom/dev/lock/data/ElectLock_Inf; GB_Lock_Array #Lcom/dev/lock/data/ElectLock_Array; bytebuffer_for_socket_RX Ljava/nio/ByteBuffer; S_thread_run_flag Z <init> d(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Array;Lcom/config/AppConfig;Ljava/net/Socket;)V Code
|
# $ ()V &
|
( * ) java/nio/ByteBuffer + , allocate (I)Ljava/nio/ByteBuffer; . 0 2 4 6 8
|
: < ; java/net/Socket = > getInetAddress ()Ljava/net/InetAddress;
|
@ B A java/net/InetAddress C D getHostAddress ()Ljava/lang/String; F
|
H J I #org/apache/logging/log4j/LogManager K L getLogger 5(Ljava/lang/Object;)Lorg/apache/logging/log4j/Logger; N
|
P com/dev/modbus/MyModBusRtu
|
O # S U W !com/dev/lock/data/ElectLock_State
|
V # Z \ LineNumberTable LocalVariableTable this ,Lcom/dev/lock/comm/Lock_SocketClient_Thread; run
|
c d e checkDevceType ()Z
|
V g h i setLock_online (I)V k
|
m o n com/dev/lock/comm/Lock_Task_SQL p q insertLock_Rt_Table >(Lcom/sql/MysqlConnPool;ILcom/dev/lock/data/ElectLock_State;)V
|
m s t q queryElectLockControlCmd
|
V v w x getOp_cmd ()I
|
z { | checkControl (I)Z
|
O ~ mkBusRtu (III)V ÿ
|
com/base/ComBase , mkUInt16Buffer
|
|
SocketComm 4(Lcom/dev/modbus/MyModBusRtu;Ljava/nio/ByteBuffer;)Z
|
V i setOp_cmd #com/dev/lock/data/ElectLock_Ctl_Log
|
(IIZ)V
|
m insertLock_Ctl_Log_Table ?(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Ctl_Log;)V
|
V x getLock_addr_set java/lang/System out Ljava/io/PrintStream; ¡ java/lang/StringBuilder £ mLock_param.getId_card_set():
|
¥ ¦ (Ljava/lang/String;)V
|
V ¨ © x getId_card_set
|
« ¬ append (I)Ljava/lang/StringBuilder;
|
¯ ° D toString
|
² ´ ³ java/io/PrintStream µ ¦ println
|
· ¸ , mkInt32Buffer
|
º » (IIZI)V
|
m ½ ¾ q updateElectLockControlCmd V À Á Reg_Count_Real
|
m Ã Ä q updateLock_Rt_Table
|
m Æ Ç q updateLock_Inf_Table
|
m É Ê Ë queryAuth_Idcard_Table *(Lcom/sql/MysqlConnPool;I)Ljava/util/List; Í Ï Î java/util/List Ð x size Ò #å¼å§æ¹éææIDå¡,IDæ°éï¼ Ô Ö Õ org/apache/logging/log4j/Logger × ¦ info Í Ù Ú Û get (I)Ljava/lang/Object; Ý &com/dev/lock/data/ElectLock_AuthIdcard Ü ß à
|
key_number
|
â ä ã java/lang/String å D trim
|
ç é è java/lang/Integer ê ë parseInt (Ljava/lang/String;)I Ü í î state Ü ð ñ auth_result
|
m ó ô õ moveAuth_Idcard_Table B(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_AuthIdcard;)Võà È
|
ú û ü sleep (J)V
|
þ ÿ java/lang/Exception $ printStackTrace 设å¤æå¼è¿æ¥ï¼DevIp:
|
¬ -(Ljava/lang/String;)Ljava/lang/StringBuilder; DevId:
|
V
|
x getLockDevId
|
: $ close
|
¯ java/io/IOException Ô error *(Ljava/lang/String;Ljava/lang/Throwable;)V runCount tmp_log %Lcom/dev/lock/data/ElectLock_Ctl_Log;
|
batch_auth Ljava/util/List; k tmp_auth (Lcom/dev/lock/data/ElectLock_AuthIdcard; keyNumber e Ljava/lang/Exception; Ljava/io/IOException; LocalVariableTypeTable :Ljava/util/List<Lcom/dev/lock/data/ElectLock_AuthIdcard;>; StackMapTable& java/lang/Throwable op_cmd isCheckOk* DevIp: , Check Lock Type:
|
.0/ com/config/AppConfig 1 D getCommType
|
â3 4 D toUpperCase6 IP
|
â8 9: equals (Ljava/lang/Object;)Z
|
<>= !com/dev/lock/data/ElectLock_Array ?@ getIteam $(I)Lcom/dev/lock/data/ElectLock_Inf;
|
BDC com/dev/lock/data/ElectLock_Inf E D
|
getLock_ip BG H lockState
|
BJ K x
|
getLock_id
|
VM N ¦ setClient_ip
|
<P Q x getIteamCountS mLock_State.getLockDevId():
|
W ¯X java/lang/InterruptedExceptionZ è¯å«æåï¼LockId:\ è¯å«å¤±è´¥ ï¼ï¼ï¼ m tmp_lock Ljava/lang/InterruptedException;
|
:a b e isClosed
|
:d ef getInputStream ()Ljava/io/InputStream;
|
:h ij getOutputStream ()Ljava/io/OutputStream; lnm java/nio/ByteOrder op LITTLE_ENDIAN Ljava/nio/ByteOrder;
|
(r st order +(Ljava/nio/ByteOrder;)Ljava/nio/ByteBuffer;
|
(v wx clear ()Ljava/nio/Buffer;
|
z|{ java/io/InputStream }~ read ([B)I
|
V x getErr_count 设å¤ï¼DevIp:
!éä¿¡è¶
æ¶å³å°æå¼è¿æ¥... 2
|
ú
|
þ ¯
|
z x available
|
makeCommBuf 5(Lcom/dev/modbus/MyModBusRtu;Ljava/nio/ByteBuffer;)[B java/util/Date
|
# æ°æ®é¿åº¦ åéæ°æ®:
|
com/base/ComFn bytesToHexString ([BI)Ljava/lang/String; Ô ¦ debug
|
¢¤£ java/io/OutputStream ¥¦ write ([B)V
|
¢¨ © $ flush
|
(« ¬ x position
|
(® ¯ x capacity
|
(± ²³ put ([BII)Ljava/nio/ByteBuffer;
|
|
(· ¸x flip
|
(º » x limit
|
(½ Ú¾ ([B)Ljava/nio/ByteBuffer;À è¿åæ°æ®ï¼
|
 ÃÄ getDataFromCommBuf !([BLcom/dev/modbus/MyModBusRtu;)Z
|
VÆ Ç $ addCommCount
|
VÉ Ê $ clearErrorCount
|
VÌ Í $ addErrorCount rtu
|
byteBuffer res_t in Ljava/io/InputStream; Ljava/io/OutputStream; rx_buf_t [B buf_clr_read_count len
|
plain_tx_t d1 Ljava/util/Date; rx_read_time_out rx_len_t d2
|
cipher_bufÕ lá âp
|
BIG_ENDIAN
|
(ä ²¾
|
Oæ çè putByteBuffer (Ljava/nio/ByteBuffer;)Z Oê ë Cmd Oí î reg_addr
|
Væ Oñ ò resultô LockId:ö LockIp:ø æ¸
空ææææå¡æåú è¿ç¨å¼éæåü è¿ç¨éå¯éå
·æåþ 设置éå
·å°åï¼ æå æ·»å ææIDå¡ï¼ åæ¶ææIDå¡ï¼ bbf_rx isSuccess buff
|
O
|
mkByteBuffer ()Ljava/nio/ByteBuffer;
|
( ¬ (I)Ljava/nio/Buffer;
|
( ² ,(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
|
com/base/Crc16 CalCRC16 (Ljava/nio/ByteBuffer;I)S ÿÿ
|
( putShort (S)Ljava/nio/ByteBuffer;
|
( array ()[B bf buffer crc
|
SourceFile Lock_SocketClient_Thread.java !
|
! ú p*· "*µ %*:¸ 'µ -*µ /*+µ 1*-µ 3*µ 5*,µ 7**´ 5¶ 9¶ ?µ E**¸ Gµ M*» OY· Qµ R*» OY· Qµ T*» VY· Xµ Y*» VY· Xµ [± ] > 5 , 0 2 6 7 " 8 ( 9 - : ; < C = N > Y ? d @ o A ^ 4 p _ ` p p p p a $ ! ¾**· bµ /<*´ /¬*´ Y¶ f*´ 1*´ j*´ Y¸ l§*´ 1*´ j*´ [¸ r**´ [¶ u· yÕM*´ [¶ u `*´ R¶ }**´ R¸ ¶ %*´ [¶ » Y*´ j· M*´ 1,¸ §z*´ [¶ » Y*´ j· M*´ 1,¸ §Y*´ [¶ u `*´ R¶ }**´ R¸ ¶ %*´ [¶ » Y*´ j· M*´ 1,¸ §*´ [¶ » Y*´ j· M*´ 1,¸ §ð*´ [¶ u `*´ R¶ }**´ R¸ ¶ %*´ [¶ » Y*´ j· M*´ 1,¸ §¨*´ [¶ » Y*´ j· M*´ 1,¸ §*´ [¶ u f*´ R¶ }**´ R*´ [¶ ¸ ¶ %*´ [¶ » Y*´ j· M*´ 1,¸ §9*´ [¶ » Y*´ j· M*´ 1,¸ §*´ [¶ u *´ R¶ }² » Y¢· ¤*´ [¶ §¶ ª¶ ®¶ ±**´ R*´ [¶ §¸ ¶¶ ,*´ [¶ » Y*´ j*´ [¶ §· ¹M*´ 1,¸ § §*´ [¶ » Y*´ j*´ [¶ §· ¹M*´ 1,¸ § *´ [¶ u s*´ R¶ }**´ R*´ [¶ §¸ ¶¶ -*´ [!¶ » Y*´ j*´ [¶ §· ¹M*´ 1,¸ § )*´ [¶ » Y*´ j*´ [¶ §· ¹M*´ 1,¸ *´ 1*´ j*´ [¸ ¼Mp <*´ R² ¿¶ }**´ R¸ '¶ !*´ 1*´ j*´ Y¸ Â*´ 1*´ j*´ Y¸ Å*´ 1*´ j¸ ÈM,¹ Ì ;*´ M» YÑ· ¤,¹ Ì ¶ ª¶ ®¹ Ó >§, ¹ Ø À Ü::´ Þ¶ Ḡæ6´ ì `*´ R¶ }**´ R¸ ¶¶ 'µ ï» Y*´ j· ¹:*´ 1¸ § » Y*´ j· ¹:*´ 1¸ § }´ ì t*´ R¶ }**´ R¸ ¶¶ &µ ï» Y*´ j· ¹:*´ 1¸ § 6» Y*´ j· ¹:*´ 1¸ § :µ ï:§ ::¿:*´ 1¸ ò ,¹ Ì ¡þîMö¤ < ÷¸ ù*´ /ûm§ M,¶ ý*´ M» Y· ¤*´ E¶¶*´ Y¶ ¶ ª¶ ®¹ Ó *´ Y¶ f*´ 1*´ j*´ Y¸ ŧ :*´ M» Y· ¤*´ E¶¶*´ Y¶ ¶ ª¶ ®¹ Ó *´ Y¶ f*´ 1*´ j*´ Y¸ Å¿*´ M» Y· ¤*´ E¶¶*´ Y¶ ¶ ª¶ ®¹ Ó *´ Y¶ f*´ 1*´ j*´ Y¸ Å*´ 5Æ *´ 5¶ § M*´ M,¶,¹ ± ¡ux þ¡
|
ÁÄ þ
|
É ¤«® ] E G
|
I J K ( M + O : Q H R J T V U ` V p W y X Y Z [ \ ¨ ] ° _ ¿ ` É a Ù b â c ð d ø e û f g h j( k2 lB mK nY oa pd ql rz s u v w± xº zÈ {Ð |Ó }Û ~é ñ '
< E Z b e m ¤ ¹ Â Ø à ã ë ¡! £- ¤< ¥K §Z «f ¬o ® ¯ °¡ ²® ³· µÂ ¶Ò ·Ø ¸ê ¹ó ºö » ¼ ¾ À( Á8 Â> ÃO ÄX Å[ Æl Çu Êz Ë Í Ì Í Î Í Ï ®§ Ó© Õ¬ Ö² ×´ Ùº MÁ ÛÅ ÜÉ Þö ßþ à Ý Þ? ßG àV áY Þ ß à ã¤ å« æ¯ ç½ ê ^ p ¾ _ `
|
´ JÐ fT ü ¡ ù ® Ç z Å ¯ ! " fT# $ w !ü +ü f û G û G û M û p'û U%ú ?ý 7 Íþ c Ü û Fÿ Í Ü þM%ù ú ú I þ÷ K%û Hû CP { | ! ¡ E=« > 9 9 9 9 9 9=§ = ¬ ] ñ ò < ù A û C ý ^ E _ ` E' C( $ ü < d e ! è ©<*´ M» Y)· ¤*´ E¶+¶*´ 3¶-¶¶ ®¹ Ó =§ *´ 3¶-¶25¶7 [>§ H*´ 7 ¶;:¶A*´ E¶7 ,*µ %**´ %´Fµ Y**´ %¶Iµ j*´ Y*´ E¶L< *´ 7¶O¡ÿ³§ *´ R² ¿¶ }**´ R¸ '¶ u² » YR· ¤*´ Y¶ ¶ ª¶ ®¶ ±>§ H*´ 7 ¶;:¶I*´ Y¶ ,*µ %**´ %´Fµ Y**´ %¶Iµ j*´ Y*´ E¶L< *´ 7¶O¡ÿ³ § #T¸ ù§ N*´ M-¶V-¹ ¡þä 0*´ M» Y)· ¤*´ E¶Y¶*´ j¶ ª¶ ®¹ Ó § &*´ M» Y)· ¤*´ E¶[¶¶ ®¹ Ó ¬ 40<W39<W ] % / 4 G L V e k v « º × Ü æ õ û!"# $ ,)0*3-9.=/KS2W345§8 ^ R © _ ` §( 1" I S] V 8^ Ù S] æ 8^ = _ $ ) ý 4ü û Aú ü <û Aú
|
HWú 0" ! Â Ï>::*´ 5Æè*´ 5¶`Þ*´ 5¶c:*´ 5¶g: ¼:*´ -²k¶qW*´ -¶uW6§ y¶y6
|
¡ K> 6*´ Y¶¤ 8*´ M» Y· ¤*´ E¶¶*´ j¶ ª¶¶ ®¹ Ó *µ /¬¸§ : *´ M ¶ ¹ ¶ÿ
+,¸:»Y·: 6
|
*´ M» Y· ¤¾¶ ª¶¾¸¶¶ ®¹ ¶¡¶§¶ 56
|
¶y6 *´ -¶ª `*´ -¶d¢ +*´ - ¶°W§
|
|
d¤ §
|
¤ § ´¸ ù§ÿ¨*´ -¶¶W»Y·: *´ -¶¹¼: *´ - ¶¼W*´ M» Y· ¤ ¾¶ ª¿¶ ¾¸¶¶ ®¹ ¾¤ * +·Á >*´ Y¶Å*´ Y¶È§ ¨>*´ Y¶Ë§ *µ /§ :*´ Y¶Ë*´ Y¶¤ À*´ M» Y· ¤*´ E¶¶*´ j¶ ª¶¶ ®¹ Ó *µ /§ : *´ Y¶¤ 8*´ M» Y· ¤*´ E¶¶*´ j¶ ª¶¶ ®¹ Ó *µ / ¿*´ Y¶¤ 8*´ M» Y· ¤*´ E¶¶*´ j¶ ª¶¶ ®¹ Ó *µ / ¬ ¦ ¬ ¯ þ cü ¦ùü cüW ¦ùüW cH ¦H ] G A B C F H "I +K 2N =O EU HV KW TX ^Y `Z c« n¬ £Z ¦] ¬^ ±_ ÁV Éc Ðd Ùe Üg hil m n)o3p?qLtOuRvYx\zd{g~mkpxÃÕ×Þåè ê¢ñ¤ô¦ù¨þ©«¬@HªJ«U¬
¯«¬ÈÍ° ^ ¬ Ï _ ` ÏÎ ÏÏ ÍÐ ÊÑÒ Ç Ó 2¿ÔÕ H©Ö T m× ± Ð!ØÕ ÙÙÚ ÜÛ
|
) #Ü pÝÚ eÞÕ þ $ Ó ÿ K O (z¢ß ÿ W O (z¢ß ÿ O (z¢ß H þú þ Sß9
|
ý wßÿ O (z¢ G þ÷ K%ÿ A O (z¢ % ÿ O (z¢ ? ÃÄ ! n g>+¾¸ ':²à¶qW+¶ãW¶¶W*´ T¶åW*´ T´é ,´ì-*´ Y¶ï!>§ *´ T´é æ*´ T´ì D*´ T´ð û>*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶÷¶¶ ®¹ Ó §Æ*´ T´ì D*´ T´ð ¯>*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶ù¶¶ ®¹ Ó §z*´ T´ì o*´ T´ð c>*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶û¶¶ ®¹ Ó §.*´ T´é c*´ T´ì*´ [¶ *´ T´ð >*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶ý¶*´ [¶ ¶ ªÿ¶¶ ®¹ Ó § Â*´ T´é ¶*´ T´ì S*´ T´ð >*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶¶*´ [¶ §¶ ªÿ¶¶ ®¹ Ó § [*´ T´ì P*´ T´ð E>*´ M» Yó· ¤*´ j¶ ªõ¶*´ E¶¶*´ [¶ §¶ ªÿ¶¶ ®¹ Ó ¬ ] & ¶ · ¸ ¹ º » )¼ 4½ ;¿ GÀ Ià WÄ aÆ mÇ oÈ Ê Ì ¹Í »Î ëÐ ùÒÓÔ7×FØPÚaÛcܣ߲à½âÈãÊä
|
æè#é%êeî ^ 4 g _ ` gÕ gÎ e ^ $ ý L (û Uû Kû Kû kû fû W
|
! Ä N*¶M,¶¹+¶¹``¸ 'N-²à¶qW-¶ W-,¶W-+¶W--¶ª¸~6-¶W-¶¶W-¶ ° ] *
|
ó ô õ ö "÷ (ø .ù <ú Dû Iü ^ 4 NÎ NÏ I! :" < # $ %
|
