Êþº¾ 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 ¢ ¡ 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õà È
|
021 java/lang/Exception 3 % printStackTrace5 设å¤æå¼è¿æ¥ï¼DevIp:7 DevId:
|
W9 : y getLockDevId
|
;< = % close
|
? ´@ java/io/IOException öB CD 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;>; StackMapTableU java/lang/Throwable op_cmd isCheckOkY DevIp: [ Check Lock Type:
|
]_^ com/config/AppConfig ` E getCommType
|
b c E toUpperCasee IP
|
g hi equals (Ljava/lang/Object;)Z
|
kml !com/dev/lock/data/ElectLock_Array no getIteam $(I)Lcom/dev/lock/data/ElectLock_Inf;
|
Ìq r E
|
getLock_ip Ìt u lockState
|
Ìw x y
|
getLock_id
|
Wz { « setClient_ip
|
k} ~ 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
|
ý
|
0 ´
|
¥¶ · 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:# æ¸
空ææææå¡æå% è¿ç¨å¼éæå' è¿ç¨éå¯éå
·æå
|
W) * y getLock_addr_set, 设置éå
·å°åï¼. æå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 % "
|
V §**· cµ 0<*´ 0*´ Z¶ g*´ 2*´ k*´ Z¸ m§{*´ 2*´ k*´ \¸ s**´ \¶ v· zÉM*´ \¶ v p*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §f*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §=*´ \¶ v {*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §í*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ *´ 2*´ k¸ §¹*´ \¶ v p*´ S¶ ~**´ S¸ ¶ -*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §i*´ \¶ » Y*´ k*´ \¶ · M*´ 2,¸ §@*´ \¶ v4*´ \¶ 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ú§ M,¶/*´ N» ¥Y4· ©*´ F¶ ò6¶ ò*´ Z¶8¶ ¯¶ ³¹ õ *´ Z¶ g*´ 2*´ &*´ Z¸ ǧ :*´ N» ¥Y4· ©*´ F¶ ò6¶ ò*´ Z¶8¶ ¯¶ ³¹ õ *´ Z¶ g*´ 2*´ &*´ Z¸ Ç¿*´ N» ¥Y4· ©*´ F¶ ò6¶ ò*´ Z¶8¶ ¯¶ ³¹ õ *´ Z¶ g*´ 2*´ &*´ Z¸ Ç*´ 6Æ *´ 6¶;§ M*´ N,¶>,¹A ± u]`0uhn
|
ª0
|
²ù ? ^ J 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Ì
Ø ã ÿ 9 A D L h p ¨ Å Í Ð Ø õ ý ¡ ¥ §! ¨0 ©? «N ®\ °f ±u ² ³ ´ µ ¸© ¹± º¿ »à ½ë ¾ý À Á Â Ä À' Ç- Î9 ÏB Ða Ñf Òr Óu Õ Ö Ø Ù¦ Ú¬ Ûà ÜÌ ÝÏ Þæ ßï áû ã ä å æ2 ç; è> éT ê] íb îh ðn ïp ðs ñv ðy ò Ñ ö ø ù ú ü£ Nª þ® ÿ²ßçù û(0?Bow
|
¦ _ § ` a
|
E JÄFG u )' FG ÿ (H 9jIJ c,H rKL u FG ÛM b NO ® NO NP Q 9jIR S $ü +ü n (û O3û O(û .û \,ú û ü c ú ý 8þ h "û Kÿ ! 0MTù ú ú I0÷ KTû Hû CP? | } " ¡ E=« > 9 9 9 9 9 9=§ = ¬ ^ < A C" _ E ` a EV CW S ü < e f " Ç <*´ N» ¥YX· ©*´ F¶ òZ¶ ò*´ 4¶\¶ ò¶ ³¹ õ =§ *´ 4¶\¶ad¶f [>§ H*´ 8 ¶j:¶p*´ F¶f ,*µ &**´ &´sµ Z**´ &¶vµ k*´ Z*´ F¶y< *´ 8¶|¡ÿ³§ s*´ S² Á¶ ~**´ S¸ (¶ X>§ H*´ 8 ¶j:¶v*´ Z¶8 ,*µ &**´ &´sµ Z**´ &¶vµ k*´ Z*´ F¶y< *´ 8¶|¡ÿ³ § #¸ ü§ N*´ N-¶-¹A ¡ÿ 0*´ N» ¥YX· ©*´ F¶ ò¶ ò*´ k¶ ¯¶ ³¹ õ § &*´ N» ¥YX· ©*´ F¶ ò¶ ò¶ ³¹ õ ¬ 4 ^ $ * + /, 4. G0 L1 V2 e3 k4 v5 6 7 0 : < «= ºA ¿B ÉC ØE ÞF éG ôH ÿIANOR S T.,6W:XdYgZ] _ R ` a W 1H I S V 8 ¼ S É 8 N S ) ý 4ü û Aú ü û Aú
|
Hú 0" "  Ï>::*´ 6Æè*´ 6¶Þ*´ 6¶:*´ 6¶: ¼:*´ .²¶W*´ .¶ W6§ y¶¤6
|
¡ K> 6*´ Z¶ª¤ 8*´ N» ¥Y· ©*´ F¶ ò6¶ ò*´ k¶ ¯¯¶ ò¶ ³¹ õ *µ 0¬±¸³§ : *´ N ¶´ ¹A ¶µÿ
+,¸¸:»¼Y·¾: 6
|
*´ N» ¥Y¿· ©¾¶ ¯Á¶ ò¾¸Ã¶ ò¶ ³¹É ¶Ì¶Ò¶µ 56
|
¶¤6 *´ .¶Õ `*´ .¶Ød¢ +*´ . ¶ÛW§
|
|
d¤ §
|
¤ § ߸ ü§ÿ¨*´ .¶áW»¼Y·¾: *´ .¶ä¼: *´ . ¶çW*´ N» ¥Y¿· © ¾¶ ¯ê¶ ò ¾¸Ã¶ ò¶ ³¹É ¾¤ * +·ì >*´ Z¶ð*´ Z¶ó§ ¨>*´ Z¶ö§ *µ 0§ :*´ Z¶ö*´ Z¶ª¤ À*´ N» ¥Y· ©*´ F¶ ò6¶ ò*´ k¶ ¯¯¶ ò¶ ³¹ õ *µ 0§ : *´ Z¶ª¤ 8*´ N» ¥Y· ©*´ F¶ ò6¶ ò*´ k¶ ¯¯¶ ò¶ ³¹ õ *µ 0 ¿*´ Z¶ª¤ 8*´ N» ¥Y· ©*´ F¶ ò6¶ ò*´ k¶ ¯¯¶ ò¶ ³¹ õ *µ 0 ¬ ¦ ¬ ¯0 cü? ¦ùü? cü ¦ùü cH ¦H ^ G f g h k m "n +p 2s =t Ez H{ K| T} ^~ ` cÐ nÑ Ò £ ¦ ¬ ± Á{ É Ð Ù Ü )3?LORY\d g£mp¦x¨·¸»Ã½Õ¾×ÀÞÁåÂèÅêÇñÉôËùÍþÎÐÑ@ÒHÏJÐUÑ
ÒÔÐÑÈÒÍÕ _ ¬ Ï ` a Ïù Ïú Íû Êüý Ç £þ 2¿ÿ H© T m ± NO Ð! Ù Ü
|
) # p e þ NO S Ó ÿ K P )¥Í
|
ÿ W P )¥Í
|
ÿ P )¥Í
|
H0ú þ S
|
¼9
|
ý w¼
|
ÿ P )¥Í G0÷ KTÿ A P )¥Í T ÿ 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 S ý 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
|
