Êþº¾ 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 g
|
i k j com/dev/lock/comm/Lock_Task_SQL l m insertLock_Rt_Table >(Lcom/sql/MysqlConnPool;ILcom/dev/lock/data/ElectLock_State;)V
|
i o p m queryElectLockControlCmd
|
V r s t getOp_cmd ()I
|
v w x checkControl (I)Z
|
O z { | mkBusRtu (III)V ÿ
|
com/base/ComBase , mkUInt16Buffer
|
|
SocketComm 4(Lcom/dev/modbus/MyModBusRtu;Ljava/nio/ByteBuffer;)Z
|
V setOp_cmd (I)V #com/dev/lock/data/ElectLock_Ctl_Log
|
(IIZ)V
|
i insertLock_Ctl_Log_Table ?(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Ctl_Log;)V
|
V t getLock_addr_set java/lang/System out Ljava/io/PrintStream; java/lang/StringBuilder mLock_param.getId_card_set():
|
¢ £ (Ljava/lang/String;)V
|
V ¥ ¦ t getId_card_set
|
¨ © ª append (I)Ljava/lang/StringBuilder;
|
¬ D toString
|
¯ ± ° java/io/PrintStream ² £ println
|
´ µ , mkInt32Buffer
|
· ¸ (IIZI)V
|
i º » m updateElectLockControlCmd V ½ ¾ Reg_Count_Real
|
i À Á m updateLock_Rt_Table
|
i Ã Ä m updateLock_Inf_Tableõà È
|
É Ê Ë sleep (J)V
|
Í Ï Î java/lang/Exception Ð $ printStackTrace Ò è®¾å¤æå¼è¿æ¥ï¼DevIp:
|
Ô © Õ -(Ljava/lang/String;)Ljava/lang/StringBuilder; × DevId:
|
V Ù Ú t getLockDevId Ü Þ Ý org/apache/logging/log4j/Logger ß £ info
|
: á â $ close
|
ä ¬ å java/io/IOException Ü ç è é error *(Ljava/lang/String;Ljava/lang/Throwable;)V runCount tmp_log %Lcom/dev/lock/data/ElectLock_Ctl_Log; e Ljava/lang/Exception; Ljava/io/IOException; StackMapTable ò java/lang/Throwable op_cmd isCheckOk ö DevIp: ø Check Lock Type:
|
ú ü û com/config/AppConfig ý D getCommType
|
ÿ java/lang/String D toUpperCase IP
|
ÿ equals (Ljava/lang/Object;)Z
|
|
!com/dev/lock/data/ElectLock_Array getIteam $(I)Lcom/dev/lock/data/ElectLock_Inf;
|
com/dev/lock/data/ElectLock_Inf D
|
getLock_ip lockState
|
t
|
getLock_id
|
V £ setClient_ip
|
|
t getIteamCount! mLock_State.getLockDevId():
|
% ¬& java/lang/InterruptedException( è¯å«æåï¼LockId:* è¯å«å¤±è´¥ ï¼ï¼ï¼ k m tmp_lock Ljava/lang/InterruptedException;
|
:0 1 e isClosed
|
:3 45 getInputStream ()Ljava/io/InputStream;
|
:7 89 getOutputStream ()Ljava/io/OutputStream; ;=< java/nio/ByteOrder >? LITTLE_ENDIAN Ljava/nio/ByteOrder;
|
(A BC order +(Ljava/nio/ByteOrder;)Ljava/nio/ByteBuffer;
|
(E FG clear ()Ljava/nio/Buffer;
|
IKJ java/io/InputStream LM read ([B)I
|
VO P t getErr_countR 设å¤ï¼DevIp:T !éä¿¡è¶
æ¶å³å°æå¼è¿æ¥... 2
|
É
|
Í ¬
|
IZ [ t available
|
] ^_ makeCommBuf 5(Lcom/dev/modbus/MyModBusRtu;Ljava/nio/ByteBuffer;)[Ba java/util/Date
|
` #d æ°æ®é¿åº¦f åéæ°æ®:
|
hji com/base/ComFn kl bytesToHexString ([BI)Ljava/lang/String; Ün o £ debug
|
qsr java/io/OutputStream tu write ([B)V
|
qw x $ flush
|
(z { t position
|
(} ~ t capacity
|
( put ([BII)Ljava/nio/ByteBuffer;
|
|
( G flip
|
( t limit
|
( get ([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¥ ;± ²?
|
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µ [± ] > 2 * . 0 3 4 " 5 ( 6 - 7 ; 9 C : N ; Y < d = o > ^ 4 p _ ` p p p p a $ ! 0 **· bµ /<*´ /U*´ 1*´ f*´ Y¸ h§C*´ 1*´ f*´ [¸ n**´ [¶ q· uÕM*´ [¶ q `*´ R¶ y**´ R}¸ ~¶ %*´ [¶ » Y*´ f· M*´ 1,¸ §z*´ [¶ » Y*´ f· M*´ 1,¸ §Y*´ [¶ q `*´ R¶ y**´ R}¸ ~¶ %*´ [¶ » Y*´ f· M*´ 1,¸ §*´ [¶ » Y*´ f· M*´ 1,¸ §ð*´ [¶ q `*´ R¶ y**´ R}¸ ~¶ %*´ [¶ » Y*´ f· M*´ 1,¸ §¨*´ [¶ » Y*´ f· M*´ 1,¸ §*´ [¶ q f*´ R¶ y**´ R*´ [¶ ¸ ~¶ %*´ [¶ » Y*´ f· M*´ 1,¸ §9*´ [¶ » Y*´ f· M*´ 1,¸ §*´ [¶ q *´ R¶ y² » Y· ¡*´ [¶ ¤¶ §¶ «¶ ®**´ R*´ [¶ ¤¸ ³¶ ,*´ [¶ » Y*´ f*´ [¶ ¤· ¶M*´ 1,¸ § §*´ [¶ » Y*´ f*´ [¶ ¤· ¶M*´ 1,¸ § *´ [¶ q s*´ R¶ y**´ R*´ [¶ ¤¸ ³¶ -*´ [!¶ » Y*´ f*´ [¶ ¤· ¶M*´ 1,¸ § )*´ [¶ » Y*´ f*´ [¶ ¤· ¶M*´ 1,¸ *´ 1*´ f*´ [¸ ¹Mp <*´ R² ¼¶ y**´ R¸ '¶ !*´ 1*´ f*´ Y¸ ¿*´ 1*´ f*´ Y¸ ÂŤ < Ƹ È*´ /ü¼§ dM,¶ Ì*´ M» YÑ· ¡*´ E¶ ÓÖ¶ Ó*´ Y¶ ض §¶ «¹ Û § \N*´ M» YÑ· ¡*´ E¶ ÓÖ¶ Ó*´ Y¶ ض §¶ «¹ Û -¿*´ M» YÑ· ¡*´ E¶ ÓÖ¶ Ó*´ Y¶ ض §¶ «¹ Û *´ 5Æ *´ 5¶ ৠM*´ M,¶ ã,¹ æ ±
|
jm Í
|
r
|
ä ] v ] B D
|
F G I # K 2 M @ N B P N Q X R h S q T U V W X Y ¨ [ · \ Á ] Ñ ^ Ú _ è ` ð a ó b û c d f g* h: iC jQ kY l\ md nr oz q r s© t² vÀ wÈ xË yÓ zá {é }ø 4 = R Z
] e z ± º Ð Ø Û ã ù % 4 ¡C £R §U ¨[ ©] «c Ij n ®r ° ¯¡ °Ì ±Î °ù ³ µ ¶ · º ^ 4 _ `
|
ê BÐ ë ì n í î í ï ð 6 ü #ü f û G û G û M û p'û U%ú ?
|
I Ír ñ-*P ä w x ! ¡ E=« > 9 9 9 9 9 9=§ = ¬ ] Á  < É A Ë C Í ^ E _ ` E ó C ô ð ü < d e ! ä ¥<*´ M» Yõ· ¡*´ E¶ Ó÷¶ Ó*´ 3¶ ù¶ Ó¶ «¹ Û =§ *´ 3¶ ù¶ þ¶ [>§ H*´ 7 ¶ :¶*´ E¶ ,*µ %**´ %´µ Y**´ %¶µ f*´ Y*´ E¶< *´ 7¶ ¡ÿ³§ *´ R² ¼¶ y**´ R¸ '¶ u² » Y · ¡*´ Y¶ ض §¶ «¶ ®>§ H*´ 7 ¶ :¶*´ Y¶ Ø ,*µ %**´ %´µ Y**´ %¶µ f*´ Y*´ E¶< *´ 7¶ ¡ÿ³ § #"¸ ȧ N*´ M-¶$-¹ æ ¡þä /*´ M» Yõ· ¡*´ E¶ Ó'¶ Ó*´ f¶ §¶ «¹ Û § %*´ M» Yõ· ¡*´ E¶ Ó)¶ Ó¶ «¹ Û ¬ 2.:%17:% ] % Õ Ö - × 2 Ù E Û J Ü T Ý c Þ i ß t à á â Û å ç © è ¸ ê Õ ì Ú í ä î ó ð ù ñ ò ó ô ì* ù. ú1 ý7 þ; ÿI ×QU~£ ^ R ¥ _ ` £ ô /"+ G S, T 8- × S, ä 8- ; í. ð ) ý 2ü û Aú ü <û Aú
|
H%ú /!
! ¾ Ë>::*´ 5Æç*´ 5¶/Ý*´ 5¶2:*´ 5¶6: ¼:*´ -²:¶@W*´ -¶DW6§ x¶H6
|
¡ J> 6*´ Y¶N¤ 7*´ M» YQ· ¡*´ E¶ ÓÖ¶ Ó*´ f¶ §S¶ Ó¶ «¹ Û *µ /¬U¸W§ : *´ M ¶X ¹ æ ¶Yÿ+,¸\:»`Y·b: 6
|
*´ M» Yc· ¡¾¶ §e¶ Ó¾¸g¶ Ó¶ «¹m ¶p¶v¶Y 56
|
¶H6 *´ -¶y `*´ -¶|d¢ +*´ - ¶W§
|
|
d¤ §
|
¤ § ¸ ȧÿ¨*´ -¶
W»`Y·b: *´ -¶¼: *´ - ¶W*´ M» Yc· ¡ ¾¶ §¶ Ó ¾¸g¶ Ó¶ «¹m ¾¤ * +· >*´ Y¶*´ Y¶§ ¦>*´ Y¶§ *µ /§ :*´ Y¶*´ Y¶N¤ ½*´ M» YQ· ¡*´ E¶ ÓÖ¶ Ó*´ f¶ §S¶ Ó¶ «¹ Û *µ /§ : *´ Y¶N¤ 7*´ M» YQ· ¡*´ E¶ ÓÖ¶ Ó*´ f¶ §S¶ Ó¶ «¹ Û *µ / ¿*´ Y¶N¤ 7*´ M» YQ· ¡*´ E¶ ÓÖ¶ Ó*´ f¶ §S¶ Ó¶ «¹ Û *µ / ¬ ¥ « ® Í cû ä ¥øû ä cû% ¥øû% cF ¥F ] G " + 2 = E% H& K' T( ^) `* c{ n| } ¢* ¥- «. °/ À& È3 Ï4 Ø5 Û789< = >(?2@>AKDNEQFXH[JcKfNl;oQwSbcfÂhÔiÖkÝlämçpérðtóvøxýy{|>}FzH{S|}{|Ä}É ^ ¬ Ë _ ` Ë Ë É Æ¡¢ à £ 2¾¤¥ H¨¦ T l§ ° í î Ï!¨¥ Ø©ª Û«
|
( #¬ pª e®¥ ý í î ð Ó ÿ K O (Iq¯ ÿ V O (Iq¯ ÿ O (Iq¯ H Íú þ S¯`9
|
ý w`¯ÿ O (Iq G Í÷ J ñÿ @ O (Iq ñ ÿ O (Iq > ! n g>+¾¸ ':²°¶@W+¶³W¶
W*´ T¶µW*´ T´¹ ,´¼-*´ Y¶¿!>§ *´ T´¹ æ*´ T´¼ D}*´ T´À û>*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ E¶ ÓǶ Ó¶ «¹ Û §Æ*´ T´¼ D}*´ T´À ¯>*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ E¶ Óɶ Ó¶ «¹ Û §z*´ T´¼ o}*´ T´À c>*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ E¶ Ó˶ Ó¶ «¹ Û §.*´ T´¹ c*´ T´¼*´ [¶ *´ T´À >*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ E¶ ÓͶ Ó*´ [¶ ¶ §Ï¶ Ó¶ «¹ Û § Â*´ T´¹ ¶*´ T´¼ S*´ T´À >*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ E¶ ÓѶ Ó*´ [¶ ¤¶ §Ï¶ Ó¶ «¹ Û § [*´ T´¼ P*´ T´À E>*´ M» Y÷ ¡*´ f¶ §Å¶ Ó*´ 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-²°¶@W-¶ÜW-,¶ßW-+¶ßW--¶y¸âè~6-¶éW-¶
W-¶í° ] *
|
Ã Ä Å Æ "Ç (È .É <Ê DË IÌ ^ 4 N N Iñ :ò < ó ô õ
|
