oying消息中心message业务1.0

leomon

2025-05-14 3387f6754a07694dda1307849a3ab6fe8a24d7c5

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
Êþº¾4
„    _ÅÆÇ
ÈÉ    _ÊËÇÆÌËÌ
'Í
ÎÏÐÑ
 
Ò
_Ó    _Ô
ÕÖ
'×
ØÙÚ
6Û
ÜÝ
'Þ
%ßàáâ
_ã
Õä
'å
1æ
Õç
1è
'é
Õê
Õëìíîïîðñ
_òó
Õô
_õ
ö÷
%ø
%ù
úû
'ü
_ý    _þÿ



ˆ
 
 
8
àí

;

    
'

 
'


'


'






'


'
à

 
P

 
P

P

P

PÍ

P
 
!
P
"
P
#
$
%
P

`

&
'
(
quartzJobMapper
1Lcom/oying/modules/quartz/mapper/QuartzJobMapper;
quartzLogMapper
1Lcom/oying/modules/quartz/mapper/QuartzLogMapper;
quartzManage
-Lcom/oying/modules/quartz/utils/QuartzManage;

redisUtils
Lcom/oying/utils/RedisUtils;
queryAll
–(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;)Lcom/oying/utils/PageResult;
Code
LineNumberTable
LocalVariableTable
this
<Lcom/oying/modules/quartz/service/impl/QuartzJobServiceImpl;
criteria
<Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;
page
<Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;
LocalVariableTypeTable
PLcom/baomidou/mybatisplus/extension/plugins/pagination/Page<Ljava/lang/Object;>;
MethodParameters
    Signature
×(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page<Ljava/lang/Object;>;)Lcom/oying/utils/PageResult<Lcom/oying/modules/quartz/domain/QuartzJob;>;
queryAllLog
×(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page<Ljava/lang/Object;>;)Lcom/oying/utils/PageResult<Lcom/oying/modules/quartz/domain/QuartzLog;>;
N(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;)Ljava/util/List;
{(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;)Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzJob;>;
{(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;)Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzLog;>;
create
.(Lcom/oying/modules/quartz/domain/QuartzJob;)V
    resources
+Lcom/oying/modules/quartz/domain/QuartzJob;
 StackMapTable
RuntimeVisibleAnnotations
:Lorg/springframework/transaction/annotation/Transactional;
rollbackFor
Ljava/lang/Exception;
update
tasks
Ljava/util/List;
$Ljava/util/List<Ljava/lang/String;>;
 updateIsPause
    quartzJob
    execution
delete
(Ljava/util/Set;)V
id
Ljava/lang/Long;
ids
Ljava/util/Set;
!Ljava/util/Set<Ljava/lang/Long;>;
)
$(Ljava/util/Set<Ljava/lang/Long;>;)V
executionSubJob
([Ljava/lang/String;)V
uuid
Ljava/lang/String;
result
Ljava/lang/Boolean;
[Ljava/lang/String;ž
óÿ
&

Exceptions
*
download
;(Ljava/util/List;Ljavax/servlet/http/HttpServletResponse;)V
map
Ljava/util/Map;

quartzJobs
response
(Ljavax/servlet/http/HttpServletResponse;
list
5Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;
=Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzJob;>;
GLjava/util/List<Ljava/util/Map<Ljava/lang/String;Ljava/lang/Object;>;>;
+
,
-
.
/
h(Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzJob;>;Ljavax/servlet/http/HttpServletResponse;)V
downloadLog
    quartzLog
+Lcom/oying/modules/quartz/domain/QuartzLog;
=Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzLog;>;

h(Ljava/util/List<Lcom/oying/modules/quartz/domain/QuartzLog;>;Ljavax/servlet/http/HttpServletResponse;)V
<init>
®(Lcom/oying/modules/quartz/mapper/QuartzJobMapper;Lcom/oying/modules/quartz/mapper/QuartzLogMapper;Lcom/oying/modules/quartz/utils/QuartzManage;Lcom/oying/utils/RedisUtils;)V
ÎLcom/baomidou/mybatisplus/extension/service/impl/ServiceImpl<Lcom/oying/modules/quartz/mapper/QuartzJobMapper;Lcom/oying/modules/quartz/domain/QuartzJob;>;Lcom/oying/modules/quartz/service/QuartzJobService;

SourceFile
QuartzJobServiceImpl.java
(Lorg/springframework/stereotype/Service;
value
quartzJobServicebc
0
1
2
3
4
5de
6
1|
7
8
9
:
;
'com/oying/exception/BadRequestException
cron表达式格式错误½
<
=
>fg
?
@€
A
8
B
C
D
[,，]
E
F
G
H
I
J
K
L
8
+
M
>
&子任务中不能添加当前任务ID
N
>
O€
P
Q
R
S
T€
U
V
W
X
Y€
Z€
[
\
]
)
^
S
_
`
java/lang/Long
a
b
)com/oying/modules/quartz/domain/QuartzJob
c€
d
>
e
f
D
g
h
U
i
j
k
8
l
<Ž€hi
java/lang/Boolean
m
n
o
p
q
r
java/lang/String
s™
java/util/ArrayList½
t
java/util/LinkedHashMap
任务名称
u
8
-
v
w

Bean名称
x
8
执行方法
y
8
参数
z
8
    è¡¨è¾¾å¼
状态
    æš‚停中
    è¿è¡Œä¸­
描述
{
8
创建日期
|
}
~
>

ۤ
)com/oying/modules/quartz/domain/QuartzLog
异常详情

8
 耗时/毫秒
‚
K
ƒ
Q
成功
失败
:com/oying/modules/quartz/service/impl/QuartzJobServiceImpl
;com/baomidou/mybatisplus/extension/service/impl/ServiceImpl
1com/oying/modules/quartz/service/QuartzJobService
java/util/Iterator
java/lang/InterruptedException
java/util/List
&javax/servlet/http/HttpServletResponse
 java/util/Map
java/lang/Object
java/io/IOException
/com/oying/modules/quartz/mapper/QuartzJobMapper
findAll
¨(Lcom/oying/modules/quartz/domain/dto/QuartzJobQueryCriteria;Lcom/baomidou/mybatisplus/extension/plugins/pagination/Page;)Lcom/baomidou/mybatisplus/core/metadata/IPage;
com/oying/utils/PageUtil
toPage
L(Lcom/baomidou/mybatisplus/core/metadata/IPage;)Lcom/oying/utils/PageResult;
/com/oying/modules/quartz/mapper/QuartzLogMapper
getCronExpression
()Ljava/lang/String;
org/quartz/CronExpression
isValidExpression
(Ljava/lang/String;)Z
(Ljava/lang/String;)V
save
(Ljava/lang/Object;)Z
+com/oying/modules/quartz/utils/QuartzManage
addJob

getSubTask
com/oying/utils/StringUtils

isNotBlank
(Ljava/lang/CharSequence;)Z
split
'(Ljava/lang/String;)[Ljava/lang/String;
java/util/Arrays
asList
%([Ljava/lang/Object;)Ljava/util/List;
getId
()Ljava/lang/Long;
toString
contains
saveOrUpdate
 updateJobCron

getIsPause
()Ljava/lang/Boolean;
booleanValue
()Z
    resumeJob
valueOf
(Z)Ljava/lang/Boolean;

setIsPause
(Ljava/lang/Boolean;)V
pauseJob
    runJobNow
 java/util/Set
iterator
()Ljava/util/Iterator;
hasNext
next
()Ljava/lang/Object;
getById
*(Ljava/io/Serializable;)Ljava/lang/Object;
    deleteJob

removeById
cn/hutool/core/util/StrUtil
isBlank
    parseLong
(Ljava/lang/String;)J
(J)Ljava/lang/Long;
cn/hutool/core/util/IdUtil

simpleUUID
setUuid
com/oying/utils/RedisUtils
get
7(Ljava/lang/String;Ljava/lang/Class;)Ljava/lang/Object;
java/lang/Thread
sleep
(J)V
del
()V

getJobName
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
getBeanName
 getMethodName
    getParams
getDescription
 getCreateTime
()Ljava/sql/Timestamp;
add
com/oying/utils/FileUtil
 downloadExcel
getExceptionDetail
getTime
getIsSuccess!_`
abcdefghi 
jkl_*´
+,¹¸°m
'n opqr
stu
svw    qsxy
zkl_*´+,¹¸°m
,n opqr
stu
svw    qsx{
j|l?*´
+¹°m
1nopqr
w
qx}
z|l?*´+¹°m
6nopqr
w
qx~
€lp#+¶¸    š »
Y·¿*+¶ W*´+¶±m<
=?@"An#op#‚
ƒ
w
„
…
†[
c‡
ˆ€lÎT+¶¸    š »
Y·¿+¶¸™*+¶¶¸M,+¶¶¹™ »
Y·¿*+¶W*´+¶±m&    F
GIJ+K;LEOKPSQn +‰ŠTopT‚
u
+‰‹ƒ0w
„
…
†[
c‡
Œ€lŠ4+¶¶™*´+¶+¸¶§*´+¶ +¸¶*+¶W±mW
XY[%\-^3_n4op4‚
ƒw
„
…
†[
c‡
Ž€lA    *´+¶!±m
cdn    op    ‚
w

l·8+¹"
M,¹#
™*,¹$
À%N*-¶&À':*´¶(*¶)W§ÿÓ±mij$k-l4m7nn*$‚‘’8op8“”
u
8“•
ğМ/w
“x—„
…
†[
c‡
˜™l
b    ’+M,¾>6¢†,2:¸*™§o*¸+¸,¶&À':¸-:¶.*¶/*´01¶2À1:Ç3¸5*´01¶2À1:§ÿ嶚*´0½6YS¶7§    „
§ÿz±mBstvx0z5{<}BR€W‚]ƒp…x†ˆ‡‹s‘Šn>0[‚5Vš›R9œw‘›’op’‰ž
ƒ2þŸ

ü þ2¡ ¢ÿ£ŸŸ

ø¤
¥w
‰„
…
†[
c‡
¦§l
ÛÆ»8Y·9N+¹:
:¹#
™©¹$
À':»;Y·<:=¶>¹?W@¶A¹?WB¶C¹?WD¶E¹?WF¶¹?WG¶¶™H§I¹?WJ¶K¹?WL¶M¹?W-¹NW§ÿS-,¸O±m>Ž&/‘>’M“\”k•z––—¥˜´™½šÀ›Åœn>/Ž¨©&—‚ÆopƪŠ
Æ«¬¾­Šu /Ž¨®ƪ¯
¾­°ƒUý±–ÿ}£±²±–¡³³ ÿ
£±²±–¡³³ ´ø/¤
µw    ª«x¶
·§l
îÕ»8Y·9N+¹:
:¹#
™¸¹$
ÀP:»;Y·<:=¶Q¹?W@¶R¹?WB¶S¹?WD¶T¹?WF¶U¹?WV¶W¹?WX¶Y¹?WG¶Z¶™[§\¹?WL¶]¹?W-¹NW§ÿD-,¸O±mB ¡&¢/£>¤M¥\¦k§z¨‰©˜ª´«Ã¬Ì­Ï®Ô¯n>/¨©&¦¸¹ÕopÕzŠ
Õ«¬Í­Šu /¨®Õzº
Í­°ƒUý±–ÿ›£±²±–»³³ ÿ
£±²±–»³³ ´ø ¤
µw    z«x¼
½¾ll*·^*+µ
*,µ*-µ*µ0±m
n4opbc
defghiwbdfhx¿ÀÁ„
Â
ÃsÄ