Êþº¾ 3?
|
|
|
|
!"#
|
|
$%
|
&
|
'
|
( !)
|
*
|
+,-
|
.
|
/
|
0 12 3 456
|
7 89
|
:;<
|
=>
|
?@
|
ABC
|
DEF
|
(G 4HIJ
|
+K 1LM
|
/NO
|
/P ÆQ
|
RS
|
=TU
|
/V
|
WXY 4Z[
|
= \] ^_ ^`a
|
Bb
|
Bc de dfg
|
Gh
|
Gi djk
|
K dl m]n
|
O
|
Oo
|
Op \q 4r 4s
|
+tu
|
W ì
|
/v
|
wxy
|
\z{|
|
^}
|
W~
|
/
|
W
|
W
|
/
|
W
|
B
|
|
W
|
W
|
W
|
W
|
r
|
4 4
|
|
|
\
|
|
K]
|
}
|
B
|
}
|
}
|
} ^¡¢ 4£ µ
|
+¤ 4¥¦§
|
¨ ç
|
©ª
|
©«¬
|
|
®¯ °±²³ 1´µ¶· InnerClasses logger Lorg/slf4j/Logger; compensateDao /Lcom/codingapi/tm/compensate/dao/CompensateDao; RuntimeVisibleAnnotations 8Lorg/springframework/beans/factory/annotation/Autowired; configReader &Lcom/codingapi/tm/config/ConfigReader; managerSenderService 9Lcom/codingapi/tm/manager/service/TxManagerSenderService; managerService 3Lcom/codingapi/tm/manager/service/TxManagerService;
|
threadPool Ljava/util/concurrent/Executor; <init> ()V Code LineNumberTable LocalVariableTable this @Lcom/codingapi/tm/compensate/service/impl/CompensateServiceImpl; saveCompensateMsg ?(Lcom/codingapi/tm/compensate/model/TransactionCompensateMsg;)Z transactionCompensateMsg <Lcom/codingapi/tm/compensate/model/TransactionCompensateMsg; txGroup &Lcom/codingapi/tm/netty/model/TxGroup; json Ljava/lang/String; compensateKey StackMapTable# autoCompensate Q(Ljava/lang/String;Lcom/codingapi/tm/compensate/model/TransactionCompensateMsg;)V e Ljava/lang/InterruptedException; executeCount I Ljava/lang/Exception; tryTime autoExecuteRes Z groupId requestJson !Lcom/alibaba/fastjson/JSONObject; url resa¸FI loadModelList ()Ljava/util/List; name v key modelName "Lcom/codingapi/tm/model/ModelName; keys Ljava/util/List; models Ljava/util/Map; names LocalVariableTypeTable $Ljava/util/List<Ljava/lang/String;>; 6Ljava/util/Map<Ljava/lang/String;Ljava/lang/Integer;>; 4Ljava/util/List<Lcom/codingapi/tm/model/ModelName;>;¹º» Signature 6()Ljava/util/List<Lcom/codingapi/tm/model/ModelName;>; loadCompensateTimes $(Ljava/lang/String;)Ljava/util/List; model 8(Ljava/lang/String;)Ljava/util/List<Ljava/lang/String;>; loadCompensateByModelAndTime
|
jsonObject +Lcom/codingapi/tm/compensate/model/TxModel; currentTime J path logs =Ljava/util/List<Lcom/codingapi/tm/compensate/model/TxModel;>; Q(Ljava/lang/String;)Ljava/util/List<Lcom/codingapi/tm/compensate/model/TxModel;>; hasCompensate ()Z delCompensate (Ljava/lang/String;)Z reloadCompensate )(Lcom/codingapi/tm/netty/model/TxGroup;)V oldNotify cinfo %Lcom/codingapi/tm/netty/model/TxInfo; txInfo iterator Ljava/util/Iterator; compensateGroup ;Ljava/util/Iterator<Lcom/codingapi/tm/netty/model/TxInfo;>; getCompensateByGroupId :(Ljava/lang/String;)Lcom/codingapi/tm/netty/model/TxGroup; executeCompensate hasOk
|
Exceptions _executeCompensate
|
startError modelInfo "Lcom/codingapi/tm/model/ModelInfo; dataM¼
|
access$000 h(Lcom/codingapi/tm/compensate/service/impl/CompensateServiceImpl;)Lcom/codingapi/tm/config/ConfigReader; x0
|
access$100 T(Lcom/codingapi/tm/compensate/service/impl/CompensateServiceImpl;)Lorg/slf4j/Logger;
|
SourceFile CompensateServiceImpl.java (Lorg/springframework/stereotype/Service; ¢ £ ª « >com/codingapi/tm/compensate/service/impl/CompensateServiceImpl½ ¾¿À Á ¨ © ¦ §¸ ÃÄÅ Æ $com/codingapi/tm/netty/model/TxGroupÇ ÈÉ ÊË ÌÍ ÎÏ Ð ÷ Ñ ÷Ò ÓÔ java/lang/StringBuilder Compensate-> ÕÖ ×ÄØ ÙÍ Ú ±Û @com/codingapi/tm/compensate/service/impl/CompensateServiceImpl$1 ªÜÝ Þßà á õ Auto Compensate->â ãä õ Automatic Compensate Result-> Õå ,json-> /Compensate Failure, Entering Compensate Queue->æ çË java/lang/InterruptedException è « éÍ java/lang/Exception Auto Compensate Fails,msg: êÄ ëÍ com/alibaba/fastjson/JSONObject action notify ìí resStateî ïð ñÄ $Compensate Result Callback Address-> ÓÄò óô #Compensate Result Callback Result-> õ Ñ java/util/HashMap¹ üö» ÷ ó øù java/lang/String úä ûüº ýþ ÿ java/lang/Integer ä ï ì java/util/ArrayList com/codingapi/tm/model/ModelName Í Ï þ å æ é æ
|
)com/codingapi/tm/compensate/model/TxModel É java/util/Date ªË 'com/lorne/core/framework/utils/DateUtil yyyy-MM-dd HH:mm:ss Í className Í methodStr Í time Ï Í state Ï !Ë : "Í @com/codingapi/tm/compensate/service/impl/CompensateServiceImpl$2 ª#$ %& ò ó 'Í ( Ñ ) ó* +, #com/codingapi/tm/netty/model/TxInfo -Ä .þ /Ä 0ä 1Ï 2 « Compensate Loaded->
|
3 4 3com/lorne/core/framework/exception/ServiceException no data existing ªÍ5 67 89 current model offline. ¤ ¥¼ :Ä; <= executeCompensate-> ,@@-> >Í 1 java/lang/Object 5com/codingapi/tm/compensate/service/CompensateService :com/codingapi/tm/compensate/model/TransactionCompensateMsg java/util/List java/util/Map java/util/Iterator com/codingapi/tm/model/ModelInfo org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; java/util/concurrent/Executors newFixedThreadPool )(I)Ljava/util/concurrent/ExecutorService;
|
getGroupId ()Ljava/lang/String; 1com/codingapi/tm/manager/service/TxManagerService
|
getTxGroup java/lang/System currentTimeMillis ()J
|
setNowTime (J)V
|
setGroupId (Ljava/lang/String;)V setIsCompensate (I)V deleteTxGroup
|
setTxGroup com/alibaba/fastjson/JSON toJSONString &(Ljava/lang/Object;)Ljava/lang/String; append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString org/slf4j/Logger info -com/codingapi/tm/compensate/dao/CompensateDao P(Lcom/codingapi/tm/compensate/model/TransactionCompensateMsg;)Ljava/lang/String; £(Lcom/codingapi/tm/compensate/service/impl/CompensateServiceImpl;Lcom/codingapi/tm/compensate/model/TransactionCompensateMsg;Ljava/lang/String;Ljava/lang/String;)V java/util/concurrent/Executor execute (Ljava/lang/Runnable;)V #org/apache/commons/lang/StringUtils
|
isNotEmpty $com/codingapi/tm/config/ConfigReader getCompensateTryTime ()I (Z)Ljava/lang/StringBuilder; java/lang/Thread sleep printStackTrace deleteCompensateByKey getLocalizedMessage error put 8(Ljava/lang/String;Ljava/lang/Object;)Ljava/lang/Object; java/lang/Boolean valueOf (Z)Ljava/lang/Boolean; getCompensateNotifyUrl -com/lorne/core/framework/utils/http/HttpUtils postJson 8(Ljava/lang/String;Ljava/lang/String;)Ljava/lang/String; loadCompensateKeys ()Ljava/util/Iterator; hasNext next ()Ljava/lang/Object; length substring (II)Ljava/lang/String; containsKey (Ljava/lang/Object;)Z get &(Ljava/lang/Object;)Ljava/lang/Object; intValue (I)Ljava/lang/Integer; 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object; keySet ()Ljava/util/Set; java/util/Set setName setCount add parseObject 5(Ljava/lang/String;)Lcom/alibaba/fastjson/JSONObject; getLong $(Ljava/lang/String;)Ljava/lang/Long; java/lang/Long longValue
|
formatDate 6(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String; setTime getString &(Ljava/lang/String;)Ljava/lang/String; setClassName setMethod
|
getInteger '(Ljava/lang/String;)Ljava/lang/Integer; setExecuteTime getBytes ()[B 1com/lorne/core/framework/utils/encode/Base64Utils encode ([B)Ljava/lang/String; setBase64 setState setOrder setKey C(Lcom/codingapi/tm/compensate/service/impl/CompensateServiceImpl;)V java/util/Collections sort )(Ljava/util/List;Ljava/util/Comparator;)V deleteCompensateByPath getList isEmpty com/google/common/collect/Lists newArrayList +(Ljava/lang/Iterable;)Ljava/util/ArrayList; getModel equals getMethodStr getNotify setIsCommit remove 7(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object; getCompensate )com/codingapi/tm/manager/ModelInfoManager getInstance -()Lcom/codingapi/tm/manager/ModelInfoManager; getModelByModel 6(Ljava/lang/String;)Lcom/codingapi/tm/model/ModelInfo; getChannelName 7com/codingapi/tm/manager/service/TxManagerSenderService sendCompensateMsg K(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;I)Ljava/lang/String; debug ! ¡ ¢ £ ¡ ¤ ¥ ¡ ¦ § ¡ ¨ © ª « ¬ I *· *¸ µ *¸ µ ± $ ' 6 ® ¯ ° ± ² ¬ *´ +¶ ¹
|
M,Ç "» Y· M,¸ ¶ ,+¶ ¶ ,¶ § *´ ,¹ +,¶ +¸ N*´ » Y· ¶ -¶ ¶ ¹ *´ +¹ :*´ » Y*+-· ¹ ¸ ¬ 6 ; < > ? ! @ ) A 1 C ; F @ H E J a L m O j ® 4 ¯ ° ³ ´ z µ ¶ E C · ¸ m ¹ ¸ º ü 1 » ¼ ½ ¬ Ï
|
l,¸ N*´ » Y· ¶ -¶ ¶ ¹ *´ ¶ !666*-· "6*´ » Y· #¶ ¶ $%¶ -¶ ¶ ¹ V*´ » Y· &¶ ¶ $%¶ -¶ ¶ ¹ 6§ !èh
¸ '§
|
:¶ )*-· "6§ÿ« *´ +¹ * § (:*´ » Y· ,¶ ¶ -¶ ¶ ¹ . 6,¶ :» /Y· 0:12¶ 3W4¶ 3W5¸ 6¶ 3W*´ ¶ 7:*´ » Y· 8¶ ¶ ¶ ¹ . ¶ 9¸ :: *´ » Y· ;¶ ¶ ¶ ¹ . ± ¡ ¤ ( - Ä Ç + " r s ! u * v - x 0 y 7 z ] { b | } ~ ¡ ¤ ¦
« µ º Ä Ç É é ì ò û % B N k ¡ ® ¦ ¾ ¿ 0 À Á É # ¾ Â l ¯ ° l ¹ ¸ l ³ ´ g · ¸ *B Ã Á -? Ä Å ò z Æ ¸ û q Ç È % G É ¸ N Ê ¸ º ' ÿ ] Ë Ì Í Ì 9L Î ú B Ï$ Ð Ñ ¬ û Ù*´ ¹ < L» =Y· >M+¹ ? N-¹ @ Z-¹ A À B:¶ C$¤ B ¶ Cd¶ D:6,¹ E ,¹ F À G¶ H`6,¸ I¹ J W§ÿ£» KY· LN,¹ M ¹ N :¹ @ B¹ A À B:,¹ F À G¶ H6» OY· P:¶ Q¶ R-¹ S W§ÿº-° N §
|
© « - ¬ 7 H ® K ¯ V ° h ² v ´ y µ · ¤ ¸ ´ ¹ ½ º Ä » Ë ¼ Ô ½ × ¾ ® f
|
H . Ò ¸ K + Ó Á - I Ô ¸ ´ Ó Á ½ Õ Ö ¤ 0 Ô ¸ Ù ¯ °
|
Ï × Ø Ç Ù Ú X Û Ø Ü
|
Ï × Ý Ç Ù Þ X Û ß º * þ à á âþ N Ì Ìø ú ý à âú H ã ä å æ ¬ ? *´ +¹ T ° Ã ® ¯ ° ç ¸ ã è é æ ¬ ñ î*´ +¹ U M» KY· LN,¹ ? :¹ @ ¾¹ A À B:¸ V:» WY· X:Y¶ Z¶ [7» \Y· ]_¸ `¶ ab¶ c¶ de¶ c¶ fg¶ h¶ H¶ i¶ j¸ k¶ lm¶ h¶ H¶ n¶ o4¶ c:
|
» Y· +¶ p¶
|
¶ ¶ : ¶ q-¹ S W§ÿ>-» rY*· s¸ t-° R È Ê Ë 1 Ì 8 Í A Î M Ï ` Ð l Ñ x Ò Ó Ô £ Õ ª × ³ Ù Í Ú Ô Ü Ý Ý à Þ ì è ® f
|
8 ¥ ê È A ç ë M ì í ³ * Æ ¸
|
Í Ô ¸ 1 ¬ · ¸ î ¯ ° î î ¸ ã ï Ø Û Ù Ø Ü ã ï Ý Û Ù ð º þ à à âú Ä ã ñ ò ó ¬ 4
|
*´ ¹ u ¬ í ®
|
¯ ° ô õ ¬ D *´ +¹ v ¬
|
ò
|
ó ® ¯ ° î ¸ ö ÷ ¬ õ*+¶ w¶ xM,Æ Ë,¶ yÆ ,¶ y¹ z ,¶ y¸ {¶ |N+¶ y¹ ? :¹ @ n¹ A À }:-¹ @ V-¹ A À }:¶ ~¶ ~¶ 8¶ ¶ ¶ (¶ 6 ¶ § ¶ -¹ § §ÿ§§ÿ§ *+¶ y¹ ? N-¹ @ -¹ A À }:¶ §ÿæ*´ » Y· ¶ +¸ ¶ ¶ ¹ ± Z ø ù û ý + þ L ÿ U `
|
¢ ¥ ¨ « ® Ì Ò Õ ô ® R ø Á ` E ù ú L \ û ú + ü ý Ì û ú õ ¯ ° õ µ ¶ ì þ ¶ Ü + ü ÿ º /
|
þ 6 » â âü ý I ù ú ù ü âú ¬ )*´ +¹
M,Ç °,¸ VN-¶ c: ¸ À ° ! " # ® 4 ) ¯ ° ) Æ ¸ · ¸ ê È µ ¸ º ü Ì õ ¬ § 1*´ +¹ M,Ç » Y· ¿*,· "> *´ +¹ v ¬¬ " * + , / 0 #2 -4 /6 ® * 1 ¯ ° 1 î ¸ & · ¸ Å º ü Ìü õ ¬ D +¸ VM,¶ cN,¶ h¶ H6¸ -¶ :Ç » Y· ¿,¶ c:,4¶ c:*´ ¶ ¹ :*´ » Y· ¶ +¶ ¶ ¶ ¶ ¹ ¶ ¬ . ; = ? A B %C /F 7H ?J UL {N ® \ ¯ ° · ¸ ~ ê È w ç ¸ l Á c 7 L
|
¸ ? D Æ ¸ U . Ê ¸ º ÿ / Ë Ì Ì ¬ / *´ ° $ ® ° ¬ / *´ ° $ ® ° r
|
