老版本提交

DELL

2024-04-28 e0af0782788d6297664cbd602c65210eead79f40

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
Êþº¾4

 com/battalarm/DeviceAlarm_Thread
java/lang/Thread
DeviceAlarmTableName
Ljava/lang/String;
 ConstantValue    
tb_devalarm_data
 Fbs9100_State
tb_fbs9100_state
ALM_TYPE_FBS9100_CommError_ID

I
Ðì
ALM_TYPE_FBS9600_CommError_ID
Ðí
ALM_TYPE_BPM7100_CommError_ID
Ðî
 ALM_TYPE_CInterface_CommError_ID
Ð÷
 time_interval<
m_Conn_Pool
Lcom/sql/MysqlConnPool;
m_AppCfg
Lcom/config/AppConfig;
<init>
0(Lcom/config/AppConfig;Lcom/sql/MysqlConnPool;)V
Code
 !
()V    
#    
%

'()
createDevAlarmTable_IfNotExist
(Lcom/sql/MysqlConnPool;)V
LineNumberTable
LocalVariableTable
this
"Lcom/battalarm/DeviceAlarm_Thread;
cfg
con_pool1
com/sql/Sql_Mysql
354
com/sql/MysqlConnPool67
getConn
()Ljava/sql/Connection;
09:
(Ljava/sql/Connection;)V<

`db_alarm`
0>?@
 sqlMysqlUseDB
(Ljava/lang/String;)V
0BCD
sqlMysqlCheckIfTableExist
(Ljava/lang/String;)Z    FHG
java/lang/SystemIJ
out
Ljava/io/PrintStream;L
/tb_devalarm_data is not exist, create it now...
NPO
java/io/PrintStreamQ@
printlnS
/CREATE TABLE `tb_devalarm_data` ( `num` BIGINT NOT NULL AUTO_INCREMENT, `record_id` BIGINT NOT NULL DEFAULT 0, `dev_id` INT NOT NULL DEFAULT 0, `dev_ip` VARCHAR(24) NOT NULL DEFAULT '127.0.0.1', `alm_type` INT NOT NULL DEFAULT 0, `alm_level` INT NOT NULL DEFAULT 0, `alm_start_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', `alm_end_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', `alm_is_confirmed` BOOLEAN NOT NULL DEFAULT false, `alm_confirmed_time` DATETIME NOT NULL DEFAULT '1982-01-01 00:00:00', `alm_cleared_type` INT NOT NULL DEFAULT 0, `usr_Id` INT NOT NULL DEFAULT 0, INDEX index_record_id (`record_id`), INDEX index_dev_id (`dev_id`), INDEX index_alm_type (`alm_type`), INDEX index_alm_start_time (`alm_start_time`), INDEX index_alm_cleared_type (`alm_cleared_type`), PRIMARY KEY (`num`));
0UV@
sqlMysqlExecuteX
‘SELECT DATA_TYPE FROM information_schema.columns WHERE table_schema='db_alarm' AND table_name='tb_devalarm_data' AND column_name='alm_is_cleared'
0Z[\
 sqlMysqlQuery
((Ljava/lang/String;)Ljava/sql/ResultSet;^`_
java/sql/ResultSetab
next
()Zd
intf
    DATA_TYPE^hij
    getString
&(Ljava/lang/String;)Ljava/lang/String;
lnm
java/lang/Stringop
toLowerCase
()Ljava/lang/String;
lrst
equals
(Ljava/lang/Object;)Zv
[ALTER TABLE tb_devalarm_data CHANGE alm_is_cleared alm_cleared_type INT NOT NULL DEFAULT 0;
xzy
java/sql/SQLException{!
printStackTrace
0}~!
    close_con
    conn_pool
sql
Lcom/sql/Sql_Mysql;
sql_str
res
Ljava/sql/ResultSet;

e
Ljava/sql/SQLException;
 StackMapTable‰
java/lang/Throwable
insertOrUpdateDevAlarmToTable
0(Lcom/sql/MysqlConnPool;JILjava/lang/String;IZ)V

java/lang/StringBuilder‘
¬INSERT INTO tb_devalarm_data (record_id,dev_id, dev_ip, alm_type, alm_level, alm_start_time, alm_end_time, alm_is_confirmed, alm_confirmed_time, alm_cleared_type)  VALUES (
Ž“@
Ž•–—
append
(J)Ljava/lang/StringBuilder;™
, 
Ž›–œ
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
Žž–Ÿ
(I)Ljava/lang/StringBuilder;¡

'£
', ¥
java/util/Date
¤ ¨
yyyy-MM-dd HH:mm:ss
ª¬«
com/base/Com­®
getDateTimeFormat
6(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String;
Ž°–±
(Z)Ljava/lang/StringBuilder;³

 µ

)
Ž·¸p
toStringº
+UPDATE tb_devalarm_data SET  alm_end_time='¼
 alm_cleared_type=¾
 WHERE record_id=
record_id_t

J
dev_id
dev_ip
alm_type_id
is_new_alarm

Z
selectAllDev
)(Lcom/sql/MysqlConnPool;)Ljava/util/List;
    Signature
J(Lcom/sql/MysqlConnPool;)Ljava/util/List<Lcom/battalarm/FBS9100_DevData;>;Ë
java/util/ArrayList
Ê Î
`db_ram_db`Ð
:SELECT dev_id,dev_ip,record_datetime FROM tb_fbs9100_stateÒ
com/battalarm/FBS9100_DevData
Ñ Á^Ö×Ø
getInt
(Ljava/lang/String;)I
ÑÚÛÜ
    setDev_id
(I)VÂ
Ñßà@
    setDev_ipâ
record_datetime^äåæ
getTimestamp
((Ljava/lang/String;)Ljava/sql/Timestamp;
Ñèéê
setRecord_time
(Ljava/sql/Timestamp;)Vìîí
java/util/Listït
add
list
Ljava/util/List;
rs
fbs9100_devdata
Lcom/battalarm/FBS9100_DevData;
LocalVariableTypeTable
1Ljava/util/List<Lcom/battalarm/FBS9100_DevData;>;
judgedevidInorNo
(Lcom/sql/MysqlConnPool;I)Jú
4SELECT record_id FROM tb_devalarm_data WHERE dev_id=ü
, AND record_id != 0 AND alm_cleared_type = 0þ
    record_id^




getLong
(Ljava/lang/String;)J
recid
updateDeviceAlarm_Time

web_site

,UPDATE tb_process_survey SET ProcessTime = '


-' WHERE ProcessName = 'BMS_FBSDEV_ALARM_DEV' 

!AND ServerName='BMS_FBSDEV_ALARM'
clearHistoryAlarm_DEV

KUPDATE tb_devalarm_data SET alm_cleared_type =1 WHERE alm_cleared_type = 0 
run

V2.203





updateDeviceAlarm_StartTime
,(Lcom/sql/MysqlConnPool;Ljava/lang/String;)V



p
getName
l



valueOf
&(Ljava/lang/Object;)Ljava/lang/String;

 - DevAlarm_Thread Started at 


!
"Ç
searchLoseConnDeviceì
$
%
&
size
()Iì
(
)
*
get
(I)Ljava/lang/Object;
Ñ
,
-
&
    getDev_id


/÷ø

1
3
2
java/util/UUID
4
5

randomUUID
()Ljava/util/UUID;

1
7
8
9
getLeastSignificantBits
()J    Ñ
;Â


=Š‹

?z
@
java/lang/Exception


B
)


DÆÇ
Ñ
F
G
H
getRecord_time
()Ljava/sql/Timestamp;
Ñ
J
Kp
    getDev_ip
¤
M
N
9
getTime

P
M
Q
java/sql/Timestamp

S
U
T
java/lang/Math
V
W
abs
(J)Jê`è


]
^
_
sleep
(J)V

az
b
java/lang/InterruptedException
lose

i
RecId
e1
Ljava/lang/Exception;
record_time
Ljava/sql/Timestamp;
interval
 Ljava/lang/InterruptedException;
m
2UPDATE tb_process_survey SET Process_starttime = '
o
,ProcessVersion = '
q
, WHERE ProcessName = 'BMS_FBSDEV_ALARM_DEV' 
version
t
`db_battinf`
v
ÚSELECT DISTINCT(FBSDeviceId),FBSDeviceIp FROM db_battinf.tb_battinf WHERE FBSDeviceId NOT IN(SELECT dev_id FROM `db_ram_db`.`tb_fbs9100_state`) And  FBSDeviceId NOT IN(SELECT dev_id FROM `db_ram_db`.`tb_fbs9600_state`)
x
FBSDeviceId
z
FBSDeviceIp^
|
}!
close
data

SourceFile
DeviceAlarm_Thread.java!
    

 


n*·*
µ"*+µ"*,µ$**´$·&±*     !#$+ ,-.
/()

<t»0Y*´$¶2·8M,;¶=,¶Aš²EK¶MRN,-¶T,W¶YN-¹]
™4c-e¹g¶k¶qš!,u¶T§N-¶w,¶|§:,¶|¿,¶|±WZx_f*J,./1&2)E.I5M>NQOWT[U_WfVhWlYoWsZ+>t,-t
e€)‚5"ƒ„[…†‡ü.0kxKˆ    Š‹
d

+»0Y*¶2·8:;¶=Œ:¶A™
™ª»ŽY·’¶”˜¶š¶˜¶š ¶š¶š¢¶š¶˜¶š¶˜¶š ¶š»¤Y·¦§¸©¶š¢¶š ¶š»¤Y·¦§¸©¶š¢¶š¶¯˜¶š ¶š»¤Y·¦§¸©¶š¢¶š¶²¶š´¶š¶¶:§7»ŽY¹·’»¤Y·¦§¸©¶š¢¶š»¶š¶½¶š¶”¶¶:¶T§:¶w¶|§:    ¶|    ¿¶|± 
    
x 

*†!h jkl"n'p0~9B€Q[‚dƒ}„–…Ÿ†¸‡ÁˆÆpˉΊ׌ëôŽýŠ
‘
    “
”
–
•
–
"˜
%–
*™+\    
+
+¿À

+Á
+Â
+Ã
+ÄÅ 
€ñ‚
…†‡)ýÎ0l3ÿ    3
l

0
xNˆ        ÆÇÈÉ
—‹»0Y*¶2·8L»ÊY·ÌM+Ͷ=ÏN+-¶Y:§?»ÑY·Ó:Ô¹Õ¶Ùݹg¶Þá¹ã¶ç,¹ëW¹]
šÿ½§N-¶w+¶|§:+¶|¿+¶|,°mpxu|*RœŸ ¢$£'¤0¥>¦L§Z¨c£mªq¬u®|­~®‚¯…®‰°+H‹€
wðñP‚$Iò„03óôq…†õ
wðö‡2ÿ'30ìl^;ÿ30ì
xKˆ    ÷ø

=g»0Y*¶2·8M    B,;¶=»ŽYù·’¶û¶š¶¶:,¶Y:¹]
™'ý¹ÿB§:¶w,¶|§:,¶|¿,¶|!­GJxQX*F·¸º»¼&»+¾3¿=ÀGÂLÃQÅXÄZÅ^ÆaÅeÇ+HggÁ
[€Y
À+‚3ò„L…†‡ÿJ3
0
xMˆ    
)


\»0Y*¶2·8L+
¶=»ŽY
·’»¤Y·¦§¸©¶š
    ¶š
¶š¶¶M+,¶T§M,¶w+¶|§N+¶|-¿+¶|±ADxIP*>ÌÎÏ,Ð2Ñ8Ï<ÒAÓEÔIÖPÕQÖU×WÖ[Ø+*\P€
<‚E…†‡ÿD30
xKˆ    
 )
Ø6»0Y*¶2·8L+;¶=
M+,¶T§M,¶w+¶|§N+¶|-¿+¶|±x#**2ÜÞßâãä#æ*å+æ/ç1æ5è+*6*€
‚…†‡ÿ30
xKˆ

!
x

›*´$
¸
²E»ŽY*¶
¸
·’
¶š»¤Y·¦§¸©¶š¶¶¶M*´$¸
 L+Æz+¹
#
žq=§Z*´$+¹
'ÀѶ
+¸
.B!    ”š<¸
0¶
6B    !”š
¸
0¶
6B*´$!+¹
'ÀѶ
++¹
'ÀÑ´
:¸
<„
+¹
#
¡ÿ¢§L+¶
>*´$¸
A*´$¸
CL+ÆÁ+¹
#
ž¸=§©+¹
'ÀѶ
+>+¹
'ÀѶ
E:+¹
'ÀѶ
I:»¤Y·¦¶
L¶
Oe¸
R7*´$¸
.7    ”š5
X”›,¸
0¶
67    ”š¸
0¶
67*´$¸
<§"    ”™
X”œ*´$¸
<„
+¹
#
¡ÿS
Z¸
\§ÿ)L+¶
`§ÿ!6±´
?¹

“
a*²,í
î!ï3î6ô>öK÷Pøeùkúrûxüÿž
¡ÿ¤÷±
µ
¹
À
!È
"Õ
#Ú
$è
%÷
&

'

)
%
*
5
+
=
,
D
-
L
0
U
1
X
0
[
2
^
3
n
4
w
5
z
4
}
#
Š
;

<
”
=
˜
+„ 
›,->s
cñ
Md
de?
e˵
f
g
ÈÈðñ
׳
dè•Á÷†
h
i
wÂ
b
jÀ
%X
eÀ
”…
k
õ>s
cö
ÈÈðö
‡] ýPì
ü.ú$ÿ



?ý ì
ÿq
ì


Plÿ
ì
ú    ÿ



a    



5r»0Y*¶2·8M,
¶=»ŽY
l·’»¤Y·¦§¸©¶š ¶š
n¶š+¶š ¶š
p¶š
¶š¶¶N,-¶T§N-¶w,¶|§:,¶|¿,¶|±UXx]d*F
D
F
G
H1
I@
JF
KL
GP
MU
NY
O]
Qd
Pf
Qj
Rm
Qq
S+4rr
r
f€P‚Y…†‡ÿX3l0
xKˆ    
"ÇÈÉl¿»ÊY·ÌL»0Y*¶2·8M
N,
s¶=
u:,¶YN§1»ÑY·Ó:-
w¹Õ¶Ù-
y¹g¶Þ+¹ëW-¹]
šÿ̧B:¶w-Æ-¹
{
§
:¶w,¶|§8:-Æ-¹
{
§
:¶w,¶|¿-Æ-¹
{
§
:¶w,¶|+°cfxqwzxmˆŽ”—x©¯²x*‚ 
Z
[
\
^
_"
h)
i,
j5
kC
lQ
mZ
ic
oh
pm
rq
tw
u|
v
yˆ
qŠ
rŽ
t”
u™
vž
y¢
z¥
r©
t¯
u´
v¹
y½
{+f
¿·ðñ
«€©ò„"A‚5%
~ôh…†|…†™…†´…†õ
·ðö
‡mÿ,3ì0^l-ÿ3ì0^
xSxFˆÿ3ì0^ˆ
xÿ3ì0^Lx


€