zhubaomin
2025-04-07 9fb370afff71f4d5659d8904e8751479280d5b48
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
Êþº¾@‚
 java/lang/Object<init>()V        
'com/dy/rtuMw/server/upgrade/UpgradeTask
taskIsOverZ      taskOverTypeLjava/lang/String;     
taskOverDt     curUgRunningRtuTotalI      openNoUpgradeLjava/lang/Boolean;      !lastOpenMaxGoOnLjava/lang/Integer;    # $! failTryTimes    & '!ugMaxRtuSameTime    )*+ ,-com/dy/common/softUpgrade/state/UpgradeTaskVoid
./0 12java/lang/Stringtrim()Ljava/lang/String;
.4 56length()I8java/lang/Exception:升级任务id必须提供
7< =(Ljava/lang/String;)V    )? @ softFileNameB-升级软件(hex)文件名称必须提供    )D E softStoreAddrGR升级程序存放地址不合法,必须是8字符(十六进制)的字符串    )I J softStartAddrLR程序覆盖起始地址不合法,必须是8字符(十六进制)的字符串    )N OsoftFileData64Q升级程序内容必须提供    )S T!softBytesCalculateV6公式计算升级程序有效序字节数必须提供    )X Y! softByteSrc16[5有效升级程序字节数CRC16校验值必须提供    )] ^_ rtuAddrListLjava/util/List; abc d6java/util/Listsizef!升级设备RTU地址必须提供    )h icallbackWebUrl
.k lmequals(Ljava/lang/Object;)Zo回调网址必须提供
qrs t2com/dy/common/util/DateTimeyyyy_MM_dd_HH_mm_ss    v wsetupDt
yz{ |}java/lang/SystemcurrentTimeMillis()J
€ ‚ƒjava/lang/LongvalueOf(J)Ljava/lang/Long;    … †‡ setupDtLongLjava/lang/Long;    ‰ Š‹taskVo/Lcom/dy/common/softUpgrade/state/UpgradeTaskVo;&java/util/concurrent/ConcurrentHashMap
Œ     ‘’ upgradeRtus(Ljava/util/concurrent/ConcurrentHashMap;
”•– —˜java/util/Base64
getDecoder()Ljava/util/Base64$Decoder;
š›œ žjava/util/Base64$Decoderdecode(Ljava/lang/String;)[B    )  ¡¢ softFileData[B¤,com/dy/common/softUpgrade/parse/HexFileParse
£
£§ ¨©splitBytesByUnit512([B)Ljava/util/List;¢ a¬ ­®toArray(([Ljava/lang/Object;)[Ljava/lang/Object;°[[B    ² ³°softFileDataGrp aµ ¶·iterator()Ljava/util/Iterator; ¹º» ¼½java/util/IteratorhasNext()Z ¹¿ ÀÁnext()Ljava/lang/Object;Ã)com/dy/rtuMw/server/upgrade/UpgradeRtuDev
ÂÅ ÆY(Lcom/dy/common/softUpgrade/state/UpgradeTaskVo;Ljava/lang/Integer;Ljava/lang/String;II)V
ŒÈ ÉÊput8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;    Ì ÍÎlog!Lorg/apache/logging/log4j/Logger; ÐÑÒ ÓÔorg/apache/logging/log4j/Loggererror(Ljava/lang/Object;)V
Œb
Œ× ØÙget&(Ljava/lang/Object;)Ljava/lang/Object;Û*com/dy/common/softUpgrade/state/UpgradeRtu aÝ Þmcontains
Âà áX(Lcom/dy/common/softUpgrade/state/UpgradeTaskVo;Ljava/lang/Integer;Ljava/lang/String;I)V    Úã ä isOver
æçè é½java/lang/Boolean booleanValue
ëìí îï*com/dy/rtuMw/server/forTcp/RtuStatusDealer    oneStatusB(Ljava/lang/String;)Lcom/dy/common/mw/protocol/rtuState/RtuStatus;    ñòó ô,com/dy/common/mw/protocol/rtuState/RtuStatusvalveOpenTrueCloseFalse    ñö ÷‡valveStatusLastTimeStamp
ù ú}    longValue
üýþ ÿ6java/lang/IntegerintValue    Ú state     'com/dy/rtuMw/server/upgrade/UpgradeUnitconfVo1Lcom/dy/rtuMw/server/upgrade/UpgradeUnitConfigVo;    
   !/com/dy/rtuMw/server/upgrade/UpgradeUnitConfigVougMaxRtuAtOnce
Ú triggerk(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Short;[[BLcom/dy/common/util/Callback;[Ljava/lang/Object;)V强制,com/dy/common/softUpgrade/state/UpgradeState
     rtuTotal)java/util/concurrent/atomic/AtomicBoolean
 (Z)V
Œ  !"values()Ljava/util/Collection;$ %&acceptx(Lcom/dy/common/softUpgrade/state/UpgradeState;Ljava/util/concurrent/atomic/AtomicBoolean;)Ljava/util/function/Consumer; ()* +,java/util/CollectionforEach (Ljava/util/function/Consumer;)V
. ؽ
æ0 ‚1(Z)Ljava/lang/Boolean;    3 4allOver6java/util/ArrayList
5 a9 :madd (< =>stream()Ljava/util/stream/Stream; @AB CDjava/util/stream/StreamtoList()Ljava/util/List;
ëF GH    allStatus()Ljava/util/Map;J %Kg(Lcom/dy/rtuMw/server/upgrade/UpgradeTask;Ljava/util/Map;Ljava/lang/Long;)Ljava/util/function/Consumer; @)    
N O!noOneRtuUpgradeMaxDuration (µ    ÚR ScurrentPackage    
U V!rtuOffLineWaitDuration    ÚX Y‡ lastDownDtAt    
[ \!runningAndIdleDuration
^ _mcanEqual
a b½ isTaskIsOver
d e6getCurUgRunningRtuTotal
g higetFailTryTimes()Ljava/lang/Integer;
k
l migetUgMaxRtuSameTime
o pqgetOpenNoUpgrade()Ljava/lang/Boolean;
s tigetLastOpenMaxGoOn
v wxgetSetupDtLong()Ljava/lang/Long;
z {2
getSetupDt
} ~    getTaskVo1()Lcom/dy/common/softUpgrade/state/UpgradeTaskVo;
 ‚ƒgetSoftFileDataGrp()[[B
…†‡ ˆ‰java/util/Arrays
deepEquals)([Ljava/lang/Object;[Ljava/lang/Object;)Z
‹ ŒgetUpgradeRtus*()Ljava/util/concurrent/ConcurrentHashMap;
 2getTaskOverType
’ “2 getTaskOverDt
• –6hashCode
…˜ ™š deepHashCode([Ljava/lang/Object;)I
.œ ‚&(Ljava/lang/Object;)Ljava/lang/String;
…Ÿ  ¡ deepToString'([Ljava/lang/Object;)Ljava/lang/String;£ ¤¥makeConcatWithConstantsÞ(Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/String;Ljava/lang/Long;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;ZLjava/lang/String;Ljava/lang/String;I)Ljava/lang/String;    Ú§ ¨rtuAddr ª×« java/util/Map    ­ ® offLineTotal    ° ± unStartTotal    ³ ´ runningTotal    ¶ · successTotal    ¹ º dieOneTotal    ¼ ½    failTotal    ¿ À dieMultiTotal     Ã failOffTotal    Å Æ failOpenTotal    È É    overTotal
Ë Ìset
ÎÏÐ Ñ2java/lang/ClassgetName
ÓÔÕ Ö×#org/apache/logging/log4j/LogManager    getLogger5(Ljava/lang/String;)Lorg/apache/logging/log4j/Logger;TaskOverType_Natural ConstantValueÛ自然TaskOverType_ForceRuntimeVisibleAnnotations,Lcom/alibaba/fastjson2/annotation/JSONField;    serialize    SignaturehLjava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;CodeLineNumberTableLocalVariableTablethis)Lcom/dy/rtuMw/server/upgrade/UpgradeTask;
initOptionO(Ljava/lang/Boolean;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Integer;)VMethodParameterssetTask2(Lcom/dy/common/softUpgrade/state/UpgradeTaskVo;)VugRtu+Lcom/dy/rtuMw/server/upgrade/UpgradeRtuDev;eLjava/lang/Exception;    listBytesLocalVariableTypeTableLjava/util/List<[B>; StackMapTable
Exceptionsz(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Ljava/lang/Short;Lcom/dy/common/util/Callback;[Ljava/lang/Object;)Vnowgap    rtuStatus.Lcom/dy/common/mw/protocol/rtuState/RtuStatus;,Lcom/dy/common/softUpgrade/state/UpgradeRtu;code protocolNameprotocolVersionLjava/lang/Short; callbackComLcom/dy/common/util/Callback;objects[Ljava/lang/Object;    forceOvercurrentUpgradeState0()Lcom/dy/common/softUpgrade/state/UpgradeState;
hasRunning+Ljava/util/concurrent/atomic/AtomicBoolean;.Lcom/dy/common/softUpgrade/state/UpgradeState; upgradeInfos@(Ljava/lang/String;)Lcom/dy/common/softUpgrade/state/UpgradeRtu;"(Ljava/util/List;)Ljava/util/List;infolist$Ljava/util/List<Ljava/lang/String;>;>Ljava/util/List<Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;d(Ljava/util/List<Ljava/lang/String;>;)Ljava/util/List<Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;upgradeInfoAll@()Ljava/util/List<Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;rsAllMapLjava/util/Map;QLjava/util/Map<Ljava/lang/String;Lcom/dy/common/mw/protocol/rtuState/RtuStatus;>;countNoOneRtuUpgradeInDurationcolLjava/util/Collection;DLjava/util/Collection<Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;countRunningRtuCountcountOffRtuAndSetIfOvercountcountRunningIdleRtuAndSetIfOvercountIsAllOverj()Ljava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;setFailTryTimes(Ljava/lang/Integer;)VsetUgMaxRtuSameTimesetOpenNoUpgrade(Ljava/lang/Boolean;)VsetLastOpenMaxGoOn
setSetupDtsetSetupDtLong(Ljava/lang/Long;)V    setTaskVosetSoftFileDataGrp([[B)VsetUpgradeRtus+(Ljava/util/concurrent/ConcurrentHashMap;)Vk(Ljava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lcom/dy/common/softUpgrade/state/UpgradeRtu;>;)V setTaskIsOversetTaskOverType setTaskOverDtsetCurUgRunningRtuTotal(I)VoLjava/lang/Object;otherthis$failTryTimesother$failTryTimesthis$ugMaxRtuSameTimeother$ugMaxRtuSameTimethis$openNoUpgradeother$openNoUpgradethis$lastOpenMaxGoOnother$lastOpenMaxGoOnthis$setupDtLongother$setupDtLong this$setupDt other$setupDt this$taskVo other$taskVothis$upgradeRtusother$upgradeRtusthis$taskOverTypeother$taskOverTypethis$taskOverDtother$taskOverDtPRIMEresult $failTryTimes$ugMaxRtuSameTime$openNoUpgrade$lastOpenMaxGoOn $setupDtLong$setupDt$taskVo $upgradeRtus $taskOverType $taskOverDttoStringlambda$openNoUpgrade$1N(Ljava/util/Map;Ljava/lang/Long;Lcom/dy/common/softUpgrade/state/UpgradeRtu;)Varslambda$currentUpgradeState$0ˆ(Lcom/dy/common/softUpgrade/state/UpgradeState;Ljava/util/concurrent/atomic/AtomicBoolean;Lcom/dy/common/softUpgrade/state/UpgradeRtu;)V<clinit>
SourceFileUpgradeTask.javaBootstrapMethodsd
efg hi"java/lang/invoke/LambdaMetafactory metafactoryÌ(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;Ôl
m ]^o/(Lcom/dy/common/softUpgrade/state/UpgradeRtu;)Vq
r YZt
uvw ¤x$java/lang/invoke/StringConcatFactory˜(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/invoke/CallSite;zÝUpgradeTask(failTryTimes=, ugMaxRtuSameTime=, openNoUpgrade=, lastOpenMaxGoOn=, setupDt=, setupDtLong=, taskVo=, softFileDataGrp=, upgradeRtus=, taskIsOver=, taskOverType=, taskOverDt=, curUgRunningRtuTotal=) InnerClassesDecoder~%java/lang/invoke/MethodHandles$Lookup€java/lang/invoke/MethodHandlesLookup!ÍÎØÙÚÜÙ$!Ý ÞßZà'!Ý ÞßZàÝ ÞßZà !Ý ÞßZàw†‡Ý ÞßZàŠ‹³°Ý ÞßZà‘’áâÝ ÞßZà Ý ÞßZà0ãb *·*µ* µ* µ*µ*µ±ä?6    78<@Aå  æçèéãx*+µ*,µ*-µ"*µ%±äIJ
KLMå4æç !$!'!ê $'ëìãÚµ+´(Æ+´(¶-¶3š »7Y9·;¿+´>Æ+´>¶-¶3š »7YA·;¿+´CÆ+´C¶-¶3Ÿ »7YF·;¿+´HÆ+´H¶-¶3Ÿ »7YK·;¿+´MÆ+´M¶-¶3š »7YP·;¿+´RÇ »7YU·;¿+´WÇ »7YZ·;¿+´\Æ+´\¹` »7Ye·;¿+´gÆ+´g¶- ¶j™ »7Yn·;¿*¸pµu*¸x¸~µ„*+µˆ*»ŒY·Žµ+´MƖ+´M¶- ¶jš‡+¸“+´M¶™µŸ»£Y·¥+´Ÿ¶¦M*,½ª¹«À¯µ±*´ˆ´\¹´N-¹¸™6-¹¾À.:»ÂY*´ˆ*´"*´±¾·Ä:*´¶ÇW§ÿǧ N²Ë-¹Ï±^§ª7äŠ"TUW2X<ZR[\]r^|`ašc¡d«f²g¼iÏjÙlïmùop
qst0u>vMw^y{˜|¤}§€ª~«´‚å>˜ íî%¨«    ïðMgñ_µæçµŠ‹ò Mgñóô%                            ýqa¹ú;B7ú    õ7êЁö㥠|*´Æw*´¶Õžm*´ˆ´\Æc*´ˆ´\¹`žT*´+¶ÖÀÚ:Ç<*´ˆ´\+¹Ü™+»ÂY*´ˆ*´"+*´ˆ´Ÿ¾·ß:*´+¶ÇW§
±´â™±*´¶å™d+¸ê:ÆY´ðÆQ´ð¶å E´õÆ=¸x¸~:        ¶ø´õ¶øe¸~:
 
¶ø*´¶û…”œµâµ±²´    ¶ûžx´ .*´²´    ¶û£,-*´±¶§\µ±´š(*´²´    ¶û£,-*´±¶§)±,-*´±¶§,-*´±¶±ä†!Š"‹*Œ7<L‘f’t•u˜}š~œˆžŽŸ ¡¯¤·¥Ê¦Û¨á©èªé¯õ±þ³µ"¹(º)¼1¾AÀUÃVÇjË{Ðåp ·2÷‡    Êø‡
Ž[ùú7Díû|æç|¨|ü|ý|þÿ||ô
ütÚûj8+úê¨üýþã^*´š*µ*µ*¸pµ±äÕÖ ×ØÜå æçôãðz»Y·L*´ˆ´\Æi*´ˆ´\¹`žZ+*´ˆ´\¹`µ*´ÆC*´¶Õž9»Y·M*´¶+,º#¹',¶-š+¸/µ2§ +¸/µ2+°ä*
äå!æ1çBèKé^    e
p xå K-zæçr    ôýpú
 ã@ *´+¶ÖÀÚ°äå æç ¨ê¨
 ãßD»5Y·7M+¹´N-¹¸™--¹¾À.:*´¶ÖÀÚ:Æ ,¹8W§ÿÐ,°ä"##$1%6&?(B)å41 û#¨DæçD^_<_òD^<ôýa¹/úê^áDã`%*´Æ*´¶Õž*´¶¹;¹?°°ä01#3å %æçô#áãŸ6*´Æ1*´¶Õž'¸EL¸x¸~M*´¶¹;*+,ºI¹L±äABCD5Så  ÷‡6æçò  ô56ã=Š*´Æ *´¶Õš)¸x¸~L+¶ø*´„¶øe²´M¶û…”ž¬§T*´¶L+¹PM,¹¸™,¹¾ÀÚN-´Qž¬§ÿä¸x¸~M,¶ø*´„¶øe²´M¶û…”ž¬¬ä:Y[\2]4_7`?aYb`dbfeglh†iˆlå4÷‡Y     û?Il÷‡Šæçò ?Iô"ý(¹úú"6ãÃ;<*´¶M,¹PN-¹¸™-¹¾ÀÚ:´ „§ÿà*Zµ¬äst
u%v.w1y4zå*%  û;æç9´
1ò 
1ôþ(¹ú6ã8¸x¸~L+¶ø*´„¶øe²´T¶û…”ža=*´ˆ´\ÆS*´ˆ´\¹`žD*´¶N-¹P:¹¸™*¹¾ÀÚ:´ µâµ„§ÿÒ¬¬ä6 ‚ƒ!…#†<‡Dˆb‰kŠq‹wŒzŽ}’å4b ûD9#\æçz÷‡ò D9ôÿL(¹-ùú6ãy´¸x¸~L=+¶ø*´„¶øe²´T¶û…”ž’*´ˆ´\ƈ*´ˆ´\¹`žy*´¶N-¹P:¹¸™_¹¾ÀÚ:´ G´âš?+¶ø´W¶øe²´Z¶û…”ž$´Q£ µ§    µµâ„§ÿ¬ä>›œ    #Ÿ< D¡b¢s¤Ž¥—§ ª¦¬¬­¯°²³å4bM ûDn´æç­÷‡    «ò Dnô#ÿL(¹üSÚúù½ãÆI*´ˆ´\Æ@*´ˆ´\¹`ž1*´¶L+¹PM,¹¸™,¹¾ÀÚN-´âš¬§ÿä¬ä¹º!»;¼B½D¿GÁå ;     û!&Iæçò !&ôý((¹ùhiã/*´"°ä"å æçmiã/*´%°ä$å æçpqã/*´°ä&å æçtiã/*´°ä(å æç{2ã/*´u°ä*å æçwxã/*´„°ä,å æç~ã/*´ˆ°ä.å æç‚ƒã/*´±°ä1å æçŒã/*´°ä4å æçá b½ã/*´¬ä6å æç2ã/*´°ä7å æç“2ã/*´°ä8å æçe6ã/*´¬ä=å æç!"ã:*+µ"±äåæç$!ê$#"ã:*+µ%±äåæç'!ê'$%ã:*+µ±äåæçê&"ã:*+µ±äåæç !ê '=ã:*+µu±äåæçwêw()ã:*+µ„±äåæç†‡ê†*ìã:*+µˆ±äåæçŠ‹êŠ+,ã:*+µ±±äåæç³°ê³-.ãL*+µ±äåæç‘’ò ‘âê‘á/0ã:*µ±äåæç ê 1=ã:*+µ±äåæçê2=ã:*+µ±äåæçê34ã:*µ±äåæçêlmãAº+*¦¬+Áš¬+ÀM,*¶]š¬*¶`,¶`Ÿ¬*¶c,¶cŸ¬*¶fN,¶f:-Ç Æ§ -¶jš¬*¶k:,¶k:Ç Æ§ ¶jš¬*¶n:,¶n:Ç Æ§ ¶jš¬*¶r:    ,¶r:
    Ç 
Ƨ     
¶jš¬*¶u: ,¶u:  Ç  Ƨ   ¶jš¬*¶y: ,¶y: Ç Æ§  ¶jš¬*¶|:,¶|:Ç Æ§ ¶jš¬*¶€,¶€¸„š¬*¶Š:,¶Š:Ç Æ§ ¶jš¬*¶Ž:,¶Ž:Ç Æ§ ¶jš¬*¶‘:,¶‘:Ç Æ§ ¶jš¬¬äåèºæçº56¥7ç>|86Dv96aY:6gS;6†4<6Œ.=6«>6    ±    ?6
Ðê@6 ÖäA6 õÅB6 û¿C6 D6 šE6OkF6UeG6tFH6z@I6™!J6ŸK6ô{$ü ýý    ý    ý    ý    ý    ý    ý    ý    ý    ê5_mã9+Á¬äåæç76ê7–6ãZ =;<=;h*¶`™O§a`=;h*¶c`=*¶fN;h-Ç+§-¶”`=*¶k:;hÇ+§¶”`=*¶n:;hÇ+§¶”`=*¶r:;hÇ+§¶”`=*¶u:;hÇ+§¶”`=*¶y:;hÇ+§¶”`=*¶|:    ;h    Ç+§    ¶”`=;h*¶€¸—`=*¶Š:
;h
Ç+§
¶”`=*¶Ž: ;h Ç+§ ¶”`=*¶‘: ;h Ç+§ ¶”`=¬äå„ =æç:L8M(N6AüO6\áP6wÆQ6’«R6­S6ÈuT6    ðMU6
 2V6 &W6 ôuÿÿÿÿÿÿÿÿÿÿÿÿÿ    ÿ    ÿ
ÿ
ÿ" ÿ ÿ ÿ ÿ ÿ X2ãm C*¶f*¶k*¶n*¶r*¶y*¶u*¶|¸›*¶€¸ž*¶Џ›*¶`*¶Ž*¶‘*¶cº¢°äå CæçYZãå_+-´¦¹©Àñ:ÆM´ðÆE´ð¶å 9´õÆ1,¶ø´õ¶øe¸~:¶ø*´¶û…”œ-µâ-µ±ä"EF!G0JBKSMXN^Qå>Bø‡_æç__÷‡_[ûP\úôü^ñ
]^ã©õ,´ *Y´¬`µ¬§É,´š*Y´¯`µ¯§µ,´ *Y´²`µ²§ ,´ *Y´µ`µµ§‹,´ !*Y´¸`µ¸,´â™r*Y´»`µ»§e,´ !*Y´¾`µ¾,´â™L*Y´»`µ»§?,´ *Y´»`µ»*Y´Á`µÁ§ ,´ *Y´»`µ»*Y´Ä`µÄ,´â™*Y´Ç`µǧ+¶ʱäjêëìí)î1ï>ðFñSò[óeôlõy÷ø‹ù’úŸü§ý±þ¾ÿÇÑÛâïôå õ    õõ ûô
%%_ã$ ¶͸ҳ˱ä`abcjkncjpnsy{š”|    }