Êþº¾ 4´ chat/module/ModuleLoader java/lang/Object logger Lorg/apache/log4j/Logger; privateFriendBucket !Lchat/module/PrivateFriendBucket; cachedSpaceId Ljava/lang/String; cachedContainer %Lchat/module/entity/MessageContainer; cachedUserId
|
cachedUser Lchat/user/User; connDB Ljava/sql/Connection; imBusinessScheduler Lchat/message/MessageRunner; messagePublisher Lchat/message/MessagesPublisher; <clinit> ()V Code
|
org/apache/log4j/Logger getLogger ,(Ljava/lang/Class;)Lorg/apache/log4j/Logger;
|
" $ # chat/module/PrivateFriendBucket % & getInstance #()Lchat/module/PrivateFriendBucket; ( LineNumberTable LocalVariableTable <init>
|
- + this Lchat/module/ModuleLoader; getPrivateFriendBucket setPrivateFriendBucket $(Lchat/module/PrivateFriendBucket;)V load
|
Exceptions 6 java/lang/Exception
|
8 9 loadUser
|
; <
|
loadClient
|
> ?
|
loadNotify
|
A B loadChatSpace
|
D E
|
loadMember
|
G H loadMessage
|
J K loadMessageRelation
|
M N LoadFriendShip
|
P Q LoadFriendCircle
|
S T U
|
LoadDBConn ()Ljava/sql/Connection; W
|
Y [ Z java/lang/Runtime \ ]
|
getRuntime ()Ljava/lang/Runtime;
|
Y _ ` a availableProcessors ()I c chat/message/MessageRunner
|
e g f java/util/concurrent/Executors h i newScheduledThreadPool 2(I)Ljava/util/concurrent/ScheduledExecutorService;
|
b k + l 2(Ljava/util/concurrent/ScheduledExecutorService;)V n p chat/message/MessagesPublisher
|
o - s threadNum I w chat/util/DBUtil
|
v -
|
v z { U getConnection dbUtil Lchat/util/DBUtil; conn getEntitySet
|
frame/persist/NamedSQL %
,(Ljava/lang/String;)Lframe/persist/NamedSQL; usr
|
setTableName
|
frame/persist/SQLRunner 7(Lframe/persist/NamedSQL;)Lframe/object/data/EntitySet;
|
frame/object/data/EntitySet iterator ()Ljava/util/Iterator; java/util/Iterator next ()Ljava/lang/Object; frame/object/data/Entity
|
¡ chat/user/UserStore ¢ £ loadOne (Lframe/object/data/Entity;)V ¥ ¦ § hasNext ()Z
|
© ª § isDebugEnabled ¬ java/lang/StringBuilder ® load user:
|
« ° + ± (Ljava/lang/String;)V
|
« ³ ´ µ append (I)Ljava/lang/StringBuilder;
|
« · ¸ ¹ toString ()Ljava/lang/String;
|
» ¼ ½ debug (Ljava/lang/Object;)V namedSQL Lframe/persist/NamedSQL; entitySet Lframe/object/data/EntitySet; cnt entity Lframe/object/data/Entity; StackMapTable Ç client
|
É ¡ Ê chat/user/ClientStore Ì load client: Î notify Ð isread = 'F'
|
Ò Ó
setFilter
|
Õ ¡ Ö chat/user/NotifyStore Ø chatSpace Ú typeCode
|
Ü Ý Þ getString &(Ljava/lang/String;)Ljava/lang/String;
|
à â á chat/module/entity/ChatSpaceType ã ä pase 6(Ljava/lang/String;)Lchat/module/entity/ChatSpaceType; à æ ç è Private "Lchat/module/entity/ChatSpaceType;
|
" ê 3 £ à ì í è GroupDoctor ï ñ ð chat/module/entity/GroupType ò ó Doctor Lchat/module/entity/GroupType;
|
õ ÷ ö chat/module/GroupBucket 3 ø ;(Lchat/module/entity/GroupType;Lframe/object/data/Entity;)V à ú û è GroupPatient ï ý þ ó Patient à è GroupFriend ï ó Friend à è Assistant à
|
è Channel à è ChatRoom à è FriendCircle load chat space: spaceType
|
doLoadMember 9(Lchat/module/entity/ChatSpaceType;Lchat/module/Bucket;)V
|
õ % 9(Lchat/module/entity/GroupType;)Lchat/module/GroupBucket; Signature <(Lchat/module/entity/ChatSpaceType;Lchat/module/Bucket<*>;)V member spaceid
|
" #
|
setOrderBy% spacecode = '
|
«' ´( -(Ljava/lang/Object;)Ljava/lang/StringBuilder;* '
|
«, ´- -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
/ 01 getMessageContainer M(Lchat/module/Bucket;Ljava/lang/String;)Lchat/module/entity/MessageContainer;
|
354 #chat/module/entity/MessageContainer 6 £ loadOneMember spaceBucket Lchat/module/Bucket; spaceId messageContainer LocalVariableTypeTable Lchat/module/Bucket<*>;> chat/module/Bucket
|
@ A doLoadMessageC messageE spaceid, createtime ascG ;TO_DAYS(NOW()) - TO_DAYS(createtime) >= 0 and spacecode = '
|
3I J £ loadOneMessage
|
L M doLoadMessageRelationO messagerelationQ spaceid, receivetime ascS ;TO_DAYS(NOW()) - TO_DAYS(receivetime) >=0 and spacecode = '
|
3U V £ loadOneMessageRelationX java/lang/StringZ getActiveFriendship\ userId
|
^ _` getUser $(Ljava/lang/String;)Lchat/user/User;b friendIdd applyf
|
statuscode
|
Wh ij equals (Ljava/lang/Object;)Zl chat/module/entity/FriendShip
|
k -
|
k ê
|
prq chat/user/User s ¹ getId
|
pu vw addOnePushFriendShip 4(Ljava/lang/String;Lchat/module/entity/FriendShip;)V
|
py zw addOneFrieldShip
|
k| }~ getReverseInstance !()Lchat/module/entity/FriendShip;
|
k ¹ getUserid user friend
|
friendShip Lchat/module/entity/FriendShip; friendcircle senderid, createtime asc senderid
|
` getCachedById
|
p getFriendCircle )()Lchat/module/friendcircle/FriendCircle;
|
%chat/module/friendcircle/FriendCircle £ loadOneCricleObject friendCircle 'Lchat/module/friendcircle/FriendCircle; P(Lchat/module/Bucket<*>;Ljava/lang/String;)Lchat/module/entity/MessageContainer;
|
|
= ¡¢ getOne 9(Ljava/lang/String;)Lchat/module/entity/MessageContainer; ¤
|
¦
|
¨ ©` getById getImBusinessScheduler ()Lchat/message/MessageRunner; setImBusinessScheduler (Lchat/message/MessageRunner;)V getMessagePublisher "()Lchat/message/MessagesPublisher; setMessagePublisher #(Lchat/message/MessagesPublisher;)V
|
SourceFile ModuleLoader.java !
|
|
|
|
|
|
|
|
|
|
7 ¸ ³ ¸ !³ '± ) & ( ) * + / *· ,± ) * . / 0 & $ ² '° ) , * 1 2 3 *³ '± )
|
0 1 * 3 4 5 ¡ C¸ 7¸ :¸ =¸ @¸ C¸ F¸ I¸ L¸ O¸ R³ V¸ X¶ ^h;» bY¸ d· j³ m» oY· q³ r± ) : 5 6 7 : = @ C F I L ! O * P 8 S B T * * t u
|
T U 4 5 K » vY· xK*¶ yL+° ) W X Y * | } ~
|
9 4 5 ò Y¸ K*¶ W*¸ L=+¶ :§ ¹ À N-¸ ¹ ¤ ÿç² ¶ ¨ ² » «Y· ¯ ¶ ²¶ ¶¶ º± ) . ] ^ _ a b ( c , d / b 9 g B h X j * * S ¾ ¿ G À Á E  u ( Ã Ä Å # ÿ ÿ (
|
< 4 5 ò Y¸ K*ƶ W*¸ L=+¶ :§ ¹ À N-¸ ȹ ¤ ÿç² ¶ ¨ ² » «YË· ¯ ¶ ²¶ ¶¶ º± ) . m n o q r ( s , t / r 9 w B x X z * * S ¾ ¿ G À Á E  u ( Ã Ä Å # ÿ ÿ (
|
? 4 5 ý `¸ K*Ͷ W*϶ ÑW*¸ L=+¶ :§ ¹ À N-¸ Ô¹ ¤ ÿç² ¶ ¨ ² » «YË· ¯ ¶ ²¶ ¶¶ º± ) 2 } ~ /
3 6 @ I _ * * Z ¾ ¿ G À Á E Â u / Ã Ä Å # ÿ $ ÿ (
|
B 4 5 Õ Ã;¸ M,׶ W,¸ N-¶ :§ ~¹ À :Ù¶ Û¸ ßL² å+¦ ² '¶ é§ R² ë+¦ ² î¸ ô§ @² ù+¦ ² ü¸ ô§ .² ÿ+¦ ²¸ ô§ ²+¥ ²+¥ ² +¥ ²W ¹ ¤ ÿ~² ¶ ¨ ² » «Y· ¯¶ ²¶ ¶¶ º± ) n ) 4 ; C F M U X _ g ¡ j ¢ q £ y ¤ | ¥ ¨ « ® ² ¢ µ « ¶  ¸ * 4 Á  u 4 d è » ¾ ¿ ¯ À Á ) o Ã Ä Å R ÿ ÿ ( à ÿ ÿ )
|
E 4 5 ^ .² å² '¸² ë² î¸¸² ù² ü¸¸² ÿ²¸¸± ) ¼ ¾ À !  - à *
|
4 5 . p¸ : ¶ ¶!W» «Y$· ¯*¶&)¶+¶ ¶¶ ÑW¸ :¶ :§ $¹ À : ¶ ÛM+,¸.N-¶2¹ ¤ ÿر ) *
|
É Ê Ë 3 Ì : Î P Ï Y Ð _ Ñ e Î o Ó * H p è p78 Y 9
|
_ : i ¾ ¿ : 6 À Á P Ã Ä ; p7< Å ÿ D à=
|
H 4 5 ^ .² å² '¸?² ë² î¸¸?² ù² ü¸¸?² ÿ²¸¸?± ) Ö × Ø ! Ù - Ú *
|
A 4 5 . p¸ :B¶ D¶!W» «YF· ¯*¶&)¶+¶ ¶¶ ÑW¸ :¶ :§ $¹ À : ¶ ÛM+,¸.N-¶H¹ ¤ ÿر ) *
|
à á â 3 ã : å P æ Y ç _ è e å o ê * H p è p78 Y 9
|
_ : i ¾ ¿ : 6 À Á P Ã Ä ; p7< Å ÿ D à=
|
K 4 5 ^ .² å² '¸K² ë² î¸¸K² ù² ü¸¸K² ÿ²¸¸K± ) ï ñ ó ! õ - ö *
|
M 4 5 r w¸ :N¶ P¶!W» «YR· ¯*¶&)¶+¶ ¶¶ ÑW¸ :¶ :§ +¹ À : ¶ ÛM,Ç § +,¸.N-¶T¹ ¤ ÿѱ ) 2 ü ý þ 3 ÿ : P Y ] ` f l v * H w è w78 Y 9
|
f : p ¾ ¿ : = À Á P Ã Ä ; w7< Å Q ÿ D à= ÿ à=W ÿ à=
|
N 4 5 ¢ ©Y¸ K*¸ L+¶ :§ ¹ À :[¶ Û¸]Ma¶ Û¸]N,Æ d-Ç § ]ce¶ Û¶g »kY·m:¶n,,¶o¶t§ /»kY·m:¶n,,¶o¶x¶{:-¶¶x¹ ¤ ÿp± ) N ! - 9 A D U ^! e" o# r& {' ) + , ¨. * H ¢ ¾ ¿ À Á - q 9 e ^
{ #
! } Ã Ä Å E ÿ ÿ . pp -ÿ +
|
Q 4 5 - [¸ K*¶ ¶!W*¸ L+¶ :§ 1¹ À :¶ ÛM,¸N-Ç § -¶:¶¹ ¤ ÿ˱ ) 2 1 2 3 8 .9 7: << @= C@ IA P8 ZC * > U ¾ ¿ B À Á 7 \
|
< I . " Ã Ä Å D ÿ " ÿ Wp ÿ
|
01 +²¶g ²°+³*²¶³²° ) F
|
G J K L * 78 9
|
; 7< Å
|
_` b *²£¶g ²¥°*³£²£¸§³¥²¥° ) P
|
Q T U V * \
|
Å ª« $ ² m° ) Z * ¬ 3 *³ m± )
|
^ _ * ®¯ $ ² r° ) b * °± 3 *³ r± )
|
f g * ² ³
|
