Êþº¾ 4V *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
|
plat_model <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; / 1 3 5 7 9
|
; = < java/net/Socket > ? getInetAddress ()Ljava/net/InetAddress;
|
A C B java/net/InetAddress D E getHostAddress ()Ljava/lang/String; G
|
I K J #org/apache/logging/log4j/LogManager L M getLogger 5(Ljava/lang/Object;)Lorg/apache/logging/log4j/Logger; O
|
Q com/dev/modbus/MyModBusRtu
|
P $ T V X !com/dev/lock/data/ElectLock_State
|
W $ [ ] LineNumberTable LocalVariableTable this ,Lcom/dev/lock/comm/Lock_SocketClient_Thread; run
|
d e f checkDevceType ()Z
|
W h i j setLock_online (I)V l
|
n p o com/dev/lock/comm/Lock_Task_SQL q r insertLock_Rt_Table >(Lcom/sql/MysqlConnPool;ILcom/dev/lock/data/ElectLock_State;)V
|
n t u r queryElectLockControlCmd
|
W w x y getOp_cmd ()I
|
{ | } checkControl (I)Z
|
P mkBusRtu (III)V ÿ
|
com/base/ComBase - mkUInt16Buffer
|
|
SocketComm 4(Lcom/dev/modbus/MyModBusRtu;Ljava/nio/ByteBuffer;)Z
|
W j setOp_cmd #com/dev/lock/data/ElectLock_Ctl_Log
|
W E getCtl_uname
|
(IIZILjava/lang/String;)V
|
n insertLock_Ctl_Log_Table ?(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Ctl_Log;)V
|
n insertRemoteOpenFailAlarm (Lcom/sql/MysqlConnPool;I)V
|
W ¡ y getLock_addr_set £ ¥ ¤ java/lang/System ¦ § out Ljava/io/PrintStream; © java/lang/StringBuilder « mLock_param.getId_card_set():
|
¨ ® (Ljava/lang/String;)V
|
W ° ± y getId_card_set
|
¨ ³ ´ µ append (I)Ljava/lang/StringBuilder;
|
¨ · ¸ E toString
|
º ¼ » java/io/PrintStream ½ ® println
|
¿ À - mkInt32Buffer
|
n  à r updateElectLockControlCmd W Å Æ Reg_Count_Real
|
n È É r updateLock_Rt_Table
|
n Ë Ì Í updateLock_Inf_Table ^(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Inf;Lcom/dev/lock/data/ElectLock_State;)V Ï Ñ Ð com/dev/lock/data/ElectLock_Inf Ò Ó lockRecordState )Lcom/dev/lock/data/ElectLock_RecordState;
|
Õ × Ö 'com/dev/lock/data/ElectLock_RecordState Ø Ù setLockState &(Lcom/dev/lock/data/ElectLock_State;)V
|
W Û Ü f isIDOpen
|
W Þ ß y getLast_unlock_id
|
n á â ã queryKeyInfByKeyNumberTable ,(Lcom/sql/MysqlConnPool;I)Ljava/lang/String;
|
W å æ ç setIDOpen (Z)V
|
n é ê ë querySystemLockMode (Lcom/sql/MysqlConnPool;)I í
|
W ï ð y getWorkmodel ò LockID: ô Start change Model :
|
¨ ö ´ ÷ -(Ljava/lang/String;)Ljava/lang/StringBuilder; ù û ú org/apache/logging/log4j/Logger ü ® info è
|
sleep (J)V
|
n queryAuth_Idcard_Table *(Lcom/sql/MysqlConnPool;I)Ljava/util/List;
|
java/util/List y size #å¼å§æ¹éææIDå¡,IDæ°éï¼ get (I)Ljava/lang/Object; &com/dev/lock/data/ElectLock_AuthIdcard
|
key_number
|
java/lang/String E trim
|
java/lang/Integer ! parseInt (Ljava/lang/String;)I # $ state & ' auth_result ) * ctl_uname
|
n, -. moveAuth_Idcard_Table B(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_AuthIdcard;)Võà È
|
354 java/lang/Exception 6 % printStackTrace8 设å¤æå¼è¿æ¥ï¼DevIp:: DevId:
|
W< = y getLockDevId
|
;? @ % close
|
B ·C java/io/IOException ùE FG error *(Ljava/lang/String;Ljava/lang/Throwable;)V runCount tmp_log %Lcom/dev/lock/data/ElectLock_Ctl_Log; k
|
batch_auth Ljava/util/List; 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;>; StackMapTableX java/lang/Throwable op_cmd isCheckOk\ DevIp: ^ Check Lock Type:
|
`ba com/config/AppConfig c E getCommType
|
e f E toUpperCaseh IP
|
j kl equals (Ljava/lang/Object;)Z
|
npo !com/dev/lock/data/ElectLock_Array qr getIteam $(I)Lcom/dev/lock/data/ElectLock_Inf;
|
Ït u E
|
getLock_ip Ïw x lockState
|
Ïz { y
|
getLock_id
|
W} ~ ® setClient_ip
|
n y getIteamCount
|
· java/lang/InterruptedException è¯å«æåï¼LockId: è¯å«å¤±è´¥ ï¼ï¼ï¼ m tmp_lock Ljava/lang/InterruptedException;
|
; f isClosed
|
; getInputStream ()Ljava/io/InputStream;
|
; getOutputStream ()Ljava/io/OutputStream; java/nio/ByteOrder LITTLE_ENDIAN Ljava/nio/ByteOrder;
|
) ¡¢ order +(Ljava/nio/ByteOrder;)Ljava/nio/ByteBuffer;
|
)¤ ¥¦ clear ()Ljava/nio/Buffer;
|
¨ª© java/io/InputStream «¬ read ([B)I
|
W® ¯ y getErr_count± 设å¤ï¼DevIp:³ !éä¿¡è¶
æ¶å³å°æå¼è¿æ¥... 2
|
|
3 ·
|
¨¹ º y 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
|
)Ù Ú y position
|
)Ü Ý y capacity
|
)ß àá put ([BII)Ljava/nio/ByteBuffer;
|
|
)å æ¦ flip
|
)è é y limit
|
)ë ì ([B)Ljava/nio/ByteBuffer;î è¿åæ°æ®ï¼
|
ð ñò getDataFromCommBuf !([BLcom/dev/modbus/MyModBusRtu;)Z
|
Wô õ % addCommCount
|
W÷ ø % clearErrorCount
|
Wú û % 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
|
BIG_ENDIAN
|
) àì
|
P putByteBuffer (Ljava/nio/ByteBuffer;)Z P Cmd P reg_addr
|
W P result" LockId:$ LockIp:& æ¸
空ææææå¡æå( è¿ç¨å¼éæå* è¿ç¨éå¯éå
·æå, 设置éå
·å°åï¼. æå0 设置éå
·æ¨¡å¼ï¼2 æ·»å ææIDå¡ï¼4 åæ¶ææIDå¡ï¼ bbf_rx isSuccess buff
|
P9 :; mkByteBuffer ()Ljava/nio/ByteBuffer;
|
)= Ú> (I)Ljava/nio/Buffer;
|
)@ àA ,(Ljava/nio/ByteBuffer;)Ljava/nio/ByteBuffer;
|
CED com/base/Crc16 FG CalCRC16 (Ljava/nio/ByteBuffer;I)S ÿÿ
|
)J KL putShort (S)Ljava/nio/ByteBuffer;
|
)N OP array ()[B bf buffer crc
|
SourceFile Lock_SocketClient_Thread.java !
|
! " ú p*· #*µ &*:¸ (µ .*µ 0*+µ 2*-µ 4*µ 6*,µ 8**´ 6¶ :¶ @µ F**¸ Hµ N*» PY· Rµ S*» PY· Rµ U*» WY· Yµ Z*» WY· Yµ \± ^ > 6 , 0 2 7 8 " 9 ( : - ; ; = C > N ? Y @ d A o B _ 4 p ` a p p p p b % "
|
ý &**· cµ 0<*´ 0*´ Z¶ g*´ 2*´ k*´ Z¸ m§ú*´ 2*´ k*´ \¸ s**´ \¶ v· zHM*´ \¶ v p*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §å*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §¼*´ \¶ v {*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §l*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ *´ 2*´ k¸ §8*´ \¶ v p*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §è*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §¿*´ \¶ v *´ S¶ ~**´ S*´ \¶ ¸ ¶ 3*´ \¶ » Y*´ k*´ \¶ *´ \¶ · M*´ 2,¸ §c*´ \¶ » Y*´ k*´ \¶ *´ \¶ · M*´ 2,¸ §4*´ \¶ v *´ S¶ ~² ¢» ¨Yª· ¬*´ \¶ ¯¶ ²¶ ¶¶ ¹**´ S*´ \¶ ¯¸ ¾¶ 3*´ \¶ » Y*´ k*´ \¶ ¯*´ \¶ · M*´ 2,¸ § ¼*´ \¶ » Y*´ k*´ \¶ ¯*´ \¶ · M*´ 2,¸ § *´ \¶ v *´ S¶ ~**´ S*´ \¶ ¯¸ ¾¶ 4*´ \!¶ » Y*´ k*´ \¶ ¯*´ \¶ · M*´ 2,¸ § 0*´ \¶ » Y*´ k*´ \¶ ¯*´ \¶ · M*´ 2,¸ *´ 2*´ k*´ \¸ ÁMp*´ S² Ķ ~**´ S¸ (¶ *´ 2*´ k*´ Z¸ Ç*´ 2*´ &*´ Z¸ Ê*´ &´ Î*´ Z¶ Ô*´ Z¶ Ú ;*´ 2*´ Z¶ ݸ àM» Y*´ k*´ Z¶ Ý,· N*´ 2-¸ *´ Z¶ äN**´ 2¸ èµ ì*´ ì *´ ì*´ Z¶ î q*´ N» ¨Yñ· ¬*´ k¶ ²ó¶ õ¶ ¶¹ ø *´ S¶ ~**´ S*´ ì¸ ¶ 3=§ #*´ S¶ ~**´ S¸ ¶ § ¡ÿÞ ý¸ ÿ*´ 2*´ k¸M,¹ P*´ N» ¨Y · ¬,¹ ¶ ²¶ ¶¹ ø >§", ¹ À::´¶¸ 6´" j*´ S¶ ~**´ S¸ ¾¶ ,µ%» Y*´ k´(· :*´ 2¸ § ª» Y*´ k´(· :*´ 2¸ § ´" ~*´ S¶ ~**´ S¸ ¾¶ +µ%» Y*´ k´(· :*´ 2¸ § ;» Y*´ k´(· :*´ 2¸ § :µ%:§ ::¿:*´ 2¸+ ,¹ ¡þÚM/¤ <0¸ ÿ*´ 0ú§ M,¶2*´ N» ¨Y7· ¬*´ F¶ õ9¶ õ*´ Z¶;¶ ²¶ ¶¹ ø *´ Z¶ g*´ 2*´ &*´ Z¸ ʧ :*´ N» ¨Y7· ¬*´ F¶ õ9¶ õ*´ Z¶;¶ ²¶ ¶¹ ø *´ Z¶ g*´ 2*´ &*´ Z¸ Ê¿*´ N» ¨Y7· ¬*´ F¶ õ9¶ õ*´ Z¶;¶ ²¶ ¶¹ ø *´ Z¶ g*´ 2*´ &*´ Z¸ Ê*´ 6Æ *´ 6¶>§ M*´ N,¶A,¹D ± ôÜß3ôçí
|
),3
|
1x B ^ n F H
|
J K L ( N + P : R H S J U V V ` W p X y Y Z [ \ ¢ ] ¸ ^ À ` Ï a Ù b é c ò d e f g h1 i9 lD nS o] pm qv r s t u vµ w½ yÌ z× {ì |õ ~ $ @ H
W b ~ ¸ À Ã Ë ç ï þ ' D L O W t | ¡ ¥ § ¨¯ ©¾ «Í ®Û °å ±ô ² ³ ´ µ ¸( ¹0 º> »_ ½j ¾| À Á Â Ä À¦ Ǭ θ ÏÁ Ðà Ñå Òñ Óô Õ Ö
|
Ø Ù% Ú+ ÛB ÜK ÝN Þe ßn áz ã
ä å æ± çº è½ éÓ êÜ íá îç ðí ïï ðò ñõ ðø ò Ñ ö ø ù ú ü" N) þ- ÿ1^fx z§¯¾Áîö
|
% _ & ` a
|
H JCIJ ô )* IJ ~ (K ¸jLM â,K ñNO ô IJ ÛP á QR - QR QS T ¸jLU V &ü +ü n (û O3û O(û [.û w.û \,ú û ü c ú ý 8þ h "û Kÿ ! 3MWù ú ú I3÷ KWû Hû CPB | } " ¡ E=« > 9 9 9 9 9 9=§ = ¬ ^ < A C _ E ` a EY CZ V ü < e f " Ç <*´ N» ¨Y[· ¬*´ F¶ õ]¶ õ*´ 4¶_¶ õ¶ ¶¹ ø =§ *´ 4¶_¶dg¶i [>§ H*´ 8 ¶m:¶s*´ F¶i ,*µ &**´ &´vµ Z**´ &¶yµ k*´ Z*´ F¶|< *´ 8¶¡ÿ³§ s*´ S² Ķ ~**´ S¸ (¶ X>§ H*´ 8 ¶m:¶y*´ Z¶; ,*µ &**´ &´vµ Z**´ &¶yµ k*´ Z*´ F¶|< *´ 8¶¡ÿ³ § #¸ ÿ§ N*´ N-¶-¹D ¡ÿ 0*´ N» ¨Y[· ¬*´ F¶ õ¶ õ*´ k¶ ²¶ ¶¹ ø § &*´ N» ¨Y[· ¬*´ F¶ õ¶ õ¶ ¶¹ ø ¬ 4
^ $ ( ) /* 4, G. L/ V0 e1 k2 v3 4 5 . 8 : «; º? ¿@ ÉA ØC ÞD éE ôF ÿG?LMP Q R.*6U:VdWgX[ _ R ` a Z 1K I S V 8 ¼ S É 8 Q V ) ý 4ü û Aú ü û Aú
|
H
ú 0" "  Ï>::*´ 6Æè*´ 6¶Þ*´ 6¶:*´ 6¶: ¼:*´ .²¶W*´ .¶£W6§ y¶§6
|
¡ K> 6*´ Z¶¤ 8*´ N» ¨Y°· ¬*´ F¶ õ9¶ õ*´ k¶ ²²¶ õ¶ ¶¹ ø *µ 0¬´¸¶§ : *´ N ¶· ¹D ¶¸ÿ
+,¸»:»¿Y·Á: 6
|
*´ N» ¨Y· ¬¾¶ ²Ä¶ õ¾¸Æ¶ õ¶ ¶¹Ì ¶Ï¶Õ¶¸ 56
|
¶§6 *´ .¶Ø `*´ .¶Ûd¢ +*´ . ¶ÞW§
|
|
d¤ §
|
¤ § ⸠ÿ§ÿ¨*´ .¶äW»¿Y·Á: *´ .¶ç¼: *´ . ¶êW*´ N» ¨Y· ¬ ¾¶ ²í¶ õ ¾¸Æ¶ õ¶ ¶¹Ì ¾¤ * +·ï >*´ Z¶ó*´ Z¶ö§ ¨>*´ Z¶ù§ *µ 0§ :*´ Z¶ù*´ Z¶¤ À*´ N» ¨Y°· ¬*´ F¶ õ9¶ õ*´ k¶ ²²¶ õ¶ ¶¹ ø *µ 0§ : *´ Z¶¤ 8*´ N» ¨Y°· ¬*´ F¶ õ9¶ õ*´ k¶ ²²¶ õ¶ ¶¹ ø *µ 0 ¿*´ Z¶¤ 8*´ N» ¨Y°· ¬*´ F¶ õ9¶ õ*´ k¶ ²²¶ õ¶ ¶¹ ø *µ 0 ¬ ¦ ¬ ¯3 cüB ¦ùüB cü
¦ùü
cH ¦H ^ G d e f i k "l +n 2q =r Ex Hy Kz T{ ^| `} cÎ nÏ Ð £} ¦ ¬ ± Áy É Ð Ù Ü )3?LORY\dg¡mp¤x¦µ¶¹Ã»Õ¼×¾Þ¿åÀèÃêÅñÇôÉùËþÌÎÏ@ÐHÍJÎUÏ
ÐÒÎÏÈÐÍÓ _ ¬ Ï ` a Ïü Ïý Íþ Êÿ Ç ¦ 2¿ H© T m ± QR Ð! Ù Ü
|
) #
|
p e þ QR V Ó ÿ K P )¨Ð ÿ W P )¨Ð ÿ P )¨Ð H3ú þ S ¿9
|
ý w¿ ÿ P )¨Ð G3÷ KWÿ A P )¨Ð W ÿ P )¨Ð ? ñò " Ü Â>+¾¸ (:²¶W+¶W¶äW*´ U¶W*´ U´ ,´*´ Z¶ |>§w*´ U´ æ*´ U´ D*´ U´ V>*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ%¶ õ¶ ¶¹ ø §!*´ U´ D*´ U´
|
>*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ'¶ õ¶ ¶¹ ø §Õ*´ U´ Ê*´ U´ ¾>*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ)¶ õ¶ ¶¹ ø §*´ U´ ¾*´ U´ Y*´ \¶ *´ U´ b>*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ+¶ õ*´ \¶ ¶ ²-¶ õ¶ ¶¹ ø § *´ U´ *´ ì*´ U´ >*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ/¶ õ*´ ì¶ ²-¶ õ¶ ¶¹ ø § Â*´ U´ ¶*´ U´ S*´ U´ >*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ1¶ õ*´ \¶ ¯¶ ²-¶ õ¶ ¶¹ ø § [*´ U´ P*´ U´ E>*´ N» ¨Y!· ¬*´ k¶ ²#¶ õ*´ F¶ õ3¶ õ*´ \¶ ¯¶ ²-¶ õ¶ ¶¹ ø ¬ ^ ª * Ù Ú Û Ü Ý Þ )ß 4à ;â Gã Iæ Wç aé mê oë í ï ¹ð »ñ ëó ùõö÷7úFûPýaþcÿ£±¿Áþ
|
#%es~À _ 4 Â ` a Â5 Âü À6 ¹7 V ý L )û Uû Kû Kû kû Zû fû W
|
½¾ " Ä N*¶8M,¶ç+¶ç``¸ (N-²¶W-¶<W-,¶?W-+¶?W--¶Ø¸BH~6-¶IW-¶äW-¶M° ^ *
|
! "" (# .$ <% D& I' _ 4 Nü Ný IQ :R < S T U
|
