修改提交

DELL

2025-04-21 41bf76509e409a3df14c323ba3ac00fac73a6e9f

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
Êþº¾4
W
-com/dev/lock/alarm/ElectLock_Alarm_Thread_SQL
java/lang/Object
<init>
()V
Code
    
LineNumberTable
LocalVariableTable
this
/Lcom/dev/lock/alarm/ElectLock_Alarm_Thread_SQL;
updateProcess_StartTime
(Lcom/sql/MysqlConnPool;D)V
java/lang/StringBuilder
oUPDATE `plus_user`.tb_process_survey Set Process_starttime = NOW()   ,ProcessTime = NOW()  ,ProcessVersion = 'V

(Ljava/lang/String;)V

append
(D)Ljava/lang/StringBuilder;

'

-(Ljava/lang/String;)Ljava/lang/StringBuilder;!
 WHERE ProcessId = 11002
#$%
toString
()Ljava/lang/String;'
com/sql/Sql_Mysql
)+*
com/sql/MysqlConnPool,-
getConn
()Ljava/sql/Connection;
&/0
(Ljava/sql/Connection;)V
&23
sqlMysqlExecute    &567
logger
!Lorg/apache/logging/log4j/Logger;
9#:
java/sql/SQLException<>=
org/apache/logging/log4j/Logger?@
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
&BC
    close_con
pool
Lcom/sql/MysqlConnPool;
mVersionnum

D
sql_str
Ljava/lang/String;
sql
Lcom/sql/Sql_Mysql;

e
Ljava/sql/SQLException;
 StackMapTableP
java/lang/StringR
java/lang/Throwable
updateProcess_ProcessTime
(Lcom/sql/MysqlConnPool;)VV
UUPDATE `plus_user`.tb_process_survey Set ProcessTime = NOW()  WHERE ProcessId = 11002
queryElectLockState
;(Lcom/sql/MysqlConnPool;Lcom/dev/lock/data/ElectLock_Inf;)VZ
`SELECT record_time,lock_state,now() as now_time FROM `plus_lock_ram`.tb_lock_rt WHERE lock_id = 
\^]
com/dev/lock/data/ElectLock_Inf_`

getLock_id
()I
bc
(I)Ljava/lang/StringBuilder;
&efg
 sqlMysqlQuery
((Ljava/lang/String;)Ljava/sql/ResultSet;    \ijk
    lockState
#Lcom/dev/lock/data/ElectLock_State;mon
java/sql/ResultSetpq
next
()Zs
record_timemuvw
getTimestamp
((Ljava/lang/String;)Ljava/sql/Timestamp;
y{z
!com/dev/lock/data/ElectLock_State|}
setRecord_time
(Ljava/util/Date;)V

lock_statem‚ƒ
getInt
(Ljava/lang/String;)I
y…†‡
 setLock_state
(I)V‰
now_time
y‹Œ}
setNow_timeŽ
java/util/Date
    m‘’
close
inf
!Lcom/dev/lock/data/ElectLock_Inf;
sql_str_sql
res
Ljava/sql/ResultSet;
state
queryElectLockAlarmByAlmId
H(Lcom/sql/MysqlConnPool;II)Lcom/dev/lock/alarm/data/ElectLock_AlarmData;œ
— SELECT lock_id,alm_id,alm_source,alm_start_time,alm_is_confirmed,alm_confirmed_time,alm_end_time FROM `plus_lock_alarm`.tb_lock_alarm WHERE lock_id = ž
 AND alm_id =  
+com/dev/lock/alarm/data/ElectLock_AlarmData
Ÿ    £
lock_id
Ÿ¥¦‡

setLock_id¨
alm_id
Ÿª«‡
    setAlm_id­

alm_source
Ÿ¯°‡
 setAlm_source²
alm_start_time
Ÿ´µ}
setAlm_start_time·
alm_is_confirmed
Ÿ¹º‡
setAlm_is_confirmed¼
alm_confirmed_time
Ÿ¾¿}
setAlm_confirmed_timeÁ
alm_end_time
ŸÃÄ}
setAlm_end_time

I
almId
almData
-Lcom/dev/lock/alarm/data/ElectLock_AlarmData;
insertElectLockAlarm
(Lcom/sql/MysqlConnPool;III)VÌ
kINSERT INTO `plus_lock_alarm`.tb_lock_alarm(lock_id,alm_id,alm_source,alm_start_time,alm_end_time)  VALUES(Î

,Ð
,Now(),Now());
    almSource
changeRealAlmToHisAlm
G(Lcom/sql/MysqlConnPool;Lcom/dev/lock/alarm/data/ElectLock_AlarmData;)VÕ
;CREATE TABLE IF NOT EXISTS `plus_lock_alarm`.tb_lock_alarm_
Ÿ×ØÙ
getAlm_start_time
()Ljava/util/Date;Û
yyyy
ÝßÞ
com/base/Comàá
getDateTimeFormat
6(Ljava/util/Date;Ljava/lang/String;)Ljava/lang/String;ã
 (å
B  `num` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '自增主键',ç
<  `lock_id` int(11) NOT NULL DEFAULT '1' COMMENT '锁具ID',é
D  `alm_id` int(11) NOT NULL DEFAULT '119001' COMMENT '告警类型',ë
v  `alm_source` int(11) NOT NULL DEFAULT '1' COMMENT '告警来源[1-平台触发  2-手机APP触发  3-锁具触发]',í
`  `alm_start_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警开始时间',ï
R  `alm_is_confirmed` tinyint(4) NOT NULL DEFAULT '0' COMMENT '告警是否确认',ñ
d  `alm_confirmed_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警确认时间',ó
^  `alm_end_time` datetime NOT NULL DEFAULT '2000-01-01 00:00:00' COMMENT '告警结束时间',õ
  PRIMARY KEY (`num`)÷
.) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='ù
 å¹´ç”µå­é”å…·åŽ†å²å‘Šè­¦è¡¨';û
- INSERT INTO `plus_lock_alarm`.tb_lock_alarm_ý
\(lock_id,alm_id,alm_source,alm_start_time,alm_is_confirmed,alm_confirmed_time,alm_end_time) ÿ
`(SELECT lock_id,alm_id,alm_source,alm_start_time,alm_is_confirmed,alm_confirmed_time,Now() from 


`plus_lock_alarm`.tb_lock_alarm

 WHERE lock_id = 
Ÿ^
Ÿ

`
    getAlm_id
    

 


)
 
= DELETE FROM `plus_lock_alarm`.tb_lock_alarm WHERE  lock_id =

  AND alm_id =

java/util/ArrayList

    





add
(Ljava/lang/Object;)Z
&



makeManualCommit
(Ljava/util/ArrayList;)Z

#

java/lang/Exception
sql_str1
sql_str2
sql_str3
sql_strs
Ljava/util/ArrayList;
Ljava/lang/Exception;
LocalVariableTypeTable
)Ljava/util/ArrayList<Ljava/lang/String;>;
changeTempAlmToRealAlm
(
E SELECT COUNT(*) as alm_count FROM `plus_lock_alarm`.tb_lock_alm_temp
*
Ì INSERT INTO `plus_lock_alarm`.tb_lock_alarm (lock_id,alm_id,alm_source,alm_start_time,alm_end_time)  (SELECT lock_id,alm_id,alm_source,alm_start_time,alm_end_time from `plus_lock_alarm`.tb_lock_alm_temp)
,
/ DELETE FROM `plus_lock_alarm`.tb_lock_alm_temp
.
    alm_count
sql_str_sel
delLockAlarmData
*(Lcom/sql/MysqlConnPool;Ljava/util/Date;)V
3
Ÿ select TABLE_NAME,CREATE_TIME  FROM information_schema.tables  where table_schema='db_lock_alarm'  AND TABLE_NAME like 'tb_lock_alarm_%'  AND CREATE_TIME <= '
5
yyyy-MM-dd HH:mm:ss
7
';
9
java/lang/StringBuffer
;
 DROP TABLE IF EXISTS 

8

8
>
?
,(Ljava/lang/String;)Ljava/lang/StringBuffer;
A
db_lock_alarm.
C

TABLE_NAMEm
E
F
G
    getString
&(Ljava/lang/String;)Ljava/lang/String;
I
3自动删除超过5年的告警表 : db_lock_alarm.
K
     at <
M
N
info

8#
deldate
Ljava/util/Date;
count
sql_delete_strs
Ljava/lang/StringBuffer;

SourceFile
ElectLock_Alarm_Thread_SQL.java!
    

/

*·±


     

\»Y·'¶¶ ¶¶"N»&Y*¶(·.:-¶1§(:´4¶8¹;¶A§:¶A¿¶A±(.19(DL
:    (.3DLNSV[4\DE\FG
AHI(4JK3LMNÿ1)O&
9ZQ        ST
Ü;UL»&Y*¶(·.M,+¶1§"N,´4-¶8-¹;,¶A§:,¶A¿,¶A±9&-
."%'()&+-*/+3,6+:-*;DE8HI
,JKLMNÿ)O&
9UQ    WX
žý»YY·+¶[¶a¶"M
N»&Y*¶(·.:,¶dN+´h:-¹l
™--r¹t¶x-~¹€¶„-ˆ¹t¶Š§w»Y·¶Š§h:´4¶8¹;-Æ-¹
§:´4¶8¹;¶A§R:-Æ-¹
§:´4¶8¹;¶A¿-Æ-¹
§:´4¶8¹;¶A±*or9‰’9*…­³¹¼9Ûáä9
~567#8*:0;9>F?S@`AcBoDtE…G‰IJ”K¥N­F¯G³I¹J¾KÏNÔO×GÛIáJæK÷NüPf
ýDEý“”
é•I疗#ÚJK0?˜ktLM”LM¾LMæLMNwÿc)\Om&yÿ)\Om&
9_9GQÿ)\Om&Q
9ÿ)\Om&L9    ™š
ä

8
N»Y›·¶a¶¶a¶":
:»&Y*¶(·.:¶d:¹l
™Ò»ŸY·¡N-¢¹€¶¤-§¹€¶©-¬¹€¶®-±¹t¶³-¶¹€¶¸-»¹t¶½-À¹t¶Â§l:´4¶8¹;Æ ¹
§:    ´4    ¶8    ¹;¶A§V:Æ ¹
§:    ´4    ¶8    ¹;¶A¿Æ ¹
§:    ´4    ¶8    ¹;¶A-°-£¦9¾ÅÈ9-¹ãêñô9


9
’$Z[][^ _-b6c@dHfUgbhoi|j‰k–l£o¨p¹r¾tÅuÊvÛyãqårêtñuöv
y
z
r
t
u
 v
1y
6{p
8DE
8£Å

8ÆÅ
6ÇÈ
HI 
–—-
JK¨LMÊLM    öLM    
 LM    Nd
ÿ¦)

ŸOm&
9a9GQÿ    )

ŸOm&Q
9ÿ)

ŸOm&N9    ÉÊ

5k»YË·¶aͶ¶aͶ¶a϶¶":»&Y*¶(·.:¶1§(:´4¶8¹;¶A§:¶A¿¶A±6=@96S[
6 †    ˆ$†)‰6‹=ŒBS[Ž]bej‘HkDEk£Å
kÆÅkÑÅ)BHI65JKBLMNÿ@)


O&
9ZQ        ÒÓ
|
4»YÔ·+¶Öڸܶâ¶ä¶æ¶è¶ê¶ì¶î¶ð¶ò¶ô¶ö¶+¶Öڸܶø¶¶"M»Yú·+¶Öڸܶü¶þ¶
¶
¶+¶
¶a¶+¶
¶a
¶

¶¶"N»Y
·+¶
¶a
¶+¶
¶a¶":»&Y*¶(·.:»
Y·
:,¶
W-¶
W¶
W¶
W§(:´4¶
¹;¶A§:¶A¿¶A±ß

    
ß

$
’$š›œ$)ž.Ÿ3 8¡=¢B£G¤]ša¦v§{¨†©¥ª«¦¯¬¹®À¯Í¬Ò°ß²è´ïµö¶þ·
¸
¹
»
$º
&»
+¼
.»
3½R
4DE
4ÇÈ
aÓ
I¯…
IÒb
 IßUJKè
!
"
L
#
$
è
!
%N$ÿ
    )ŸOOO&

ZQ        
&T
²
ò
'L
)M
+N»&Y*¶(·.:
:+¶d:¹l
™Ÿ
-¹€6žŽ»
Y·
:,¶
W-¶
W¶
W§l:´4¶
¹;Æ ¹
§:    ´4    ¶8    ¹;¶A§V:Æ ¹
§:    ´4    ¶8    ¹;¶A¿Æ ¹
§:    ´4    ¶8    ¹;¶A±^a
y€ƒ9tž¥¬¯9ÏÖÙ9
†!ÅÇËÌÍÏ$Ð.Ñ:Ó?ÔHÖO×VÙ^ÜcÝtßyá€â…ã–æžÞ ß¥á¬â±ãÂæÇçÊßÏáÖâÛãìæñèzòDEî
/I
ê
Iæ
 IÙJK֖—:$
.ÅH
!
"cL
#…LM    ±LM    ÛLM    
$
H
!
%Nh
ÿa)OOO&m

a9GQÿ    )OOO&mQ
9ÿ)OOO&mN9    
0
1


T»Y
2·+
4¸Ü¶
6¶¶"M
N»&Y*¶(·.:,¶dN6»
8Y
:·
<:§kžͶ
=W»Y
@·-
B¹
D¶¶"¶
=W´4»Y
H·-
B¹
D¶
J¶»Y·
4¸Ü¶¶"¹
L„
-¹l
šÿ’žu¶
O¶1§h:´4¶8¹;-Æ-¹
§:    ´4    ¶8    ¹;¶A§R:-Æ-¹
§:    ´4    ¶8    ¹;¶A¿-Æ-¹
§:    ´4    ¶8    ¹;¶A±CÆÉ9àæé9CÜ




9
2
8
;9
–%ë
ïëñ ò-ó4ô7õC÷FøKùSürý«þ®÷·
¼
Æ
Ë
Ü
à
    æ

ë
ü







    





&

+

.

2
    
8


=

N

S
p
TDE
T
P
Q

6
/I 
4–—-
'JK7

RÅC

S
TËLMëLM    
LM    
=LM    No ÿF)Om&

8ûZZ9_9GQÿ    )Om&

8Q
9ÿ)Om&

8L9

U
V