添加，组织表中create_user_org_code 字段

zhaoxiaohao

2020-08-08 7453cd00dd42f60bb3406137ae88fa28daf40e67

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
Êþº¾3
¼
WÈ    bÉÊ
ËÌ
bÍ
ÎÏ
ÎÐ
ÑÒ
ÑÐ
bÓ    bÔÕÖ×
ØÙ
ÎÙ
ÑÙ
bÚ
ÛÜÝ
ÛÞ
ßà
áâ
Ûãä
È    åæ    çè
çé
êë
êì
íî
ïð
êñ
òó
$ô    bõ
ö÷
öøù
)ú
$û
ßü
ßý    bþ
dÿ


    

    

'
1

1

d


    

 
ß


    

 
>


    



›Þ

    


D
Ö


G



 
 


 


!


"


#
$
%

&
'

&
(

&
)

*
+
,Ö
-

.
/Ö
0P

ß
1P
2

3
4Ö
5
6

7
8
9
dÈ
logger
Lorg/slf4j/Logger;
    scheduler
Lorg/quartz/Scheduler;
jettyServerHandler
?Lcom/xxl/rpc/remoting/net/impl/jetty/server/JettyServerHandler;
executorBizRepository
(Ljava/util/concurrent/ConcurrentHashMap;
    Signature
^Ljava/util/concurrent/ConcurrentHashMap<Ljava/lang/String;Lcom/xxl/job/core/biz/ExecutorBiz;>;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
8Lcom/xxl/job/admin/core/schedule/XxlJobDynamicScheduler;
setScheduler
(Lorg/quartz/Scheduler;)V
start

Exceptions
:
destroy
initI18n
item
2Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum;
 StackMapTable
;
initRpcProvider
xxlRpcProviderFactory
5Lcom/xxl/rpc/remoting/provider/XxlRpcProviderFactory;
stopRpcProvider
invokeAdminService
R(Ljavax/servlet/http/HttpServletRequest;Ljavax/servlet/http/HttpServletResponse;)V
request
'Ljavax/servlet/http/HttpServletRequest;
response
(Ljavax/servlet/http/HttpServletResponse;
<
=
getExecutorBiz
6(Ljava/lang/String;)Lcom/xxl/job/core/biz/ExecutorBiz;
address
Ljava/lang/String;
executorBiz
"Lcom/xxl/job/core/biz/ExecutorBiz;

fillJobInfo
,(Lcom/xxl/job/admin/core/model/XxlJobInfo;)V
cronExpression
trigger
Lorg/quartz/Trigger;
triggerState
?
TriggerState
InnerClasses
!Lorg/quartz/Trigger$TriggerState;

e
Lorg/quartz/SchedulerException;
jobInfo
)Lcom/xxl/job/admin/core/model/XxlJobInfo;
group
name

triggerKey
Lorg/quartz/TriggerKey;
@
A
B
C

addJob
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)Z
jobName
jobGroup
jobKey
Lorg/quartz/JobKey;
cronScheduleBuilder
 Lorg/quartz/CronScheduleBuilder;
cronTrigger
Lorg/quartz/CronTrigger;
    jobClass_
Ljava/lang/Class;
    jobDetail
Lorg/quartz/JobDetail;
date
Ljava/util/Date;
LocalVariableTypeTable
$Ljava/lang/Class<+Lorg/quartz/Job;>;

    removeJob
'(Ljava/lang/String;Ljava/lang/String;)Z
 updateJobCron

oldTrigger
oldCron
$
<clinit>

SourceFile
XxlJobDynamicScheduler.javapqhi
quartz scheduler is null
D
E
F}q
G
H
Iyq
J
H
K‚qfg
%>>>>>>>>> init xxl-job admin success.
L
M
N
O
Pq…q
Q
R
S
jobconf_block_¤
T
A
U
V
W
X
V
Y
N
3com/xxl/rpc/remoting/provider/XxlRpcProviderFactory
Z
[
\
^
`
a
b
c
d
e
f
g
T
h
i
com/xxl/job/core/biz/AdminBiz
j
k
T
l
m
n
o
=com/xxl/rpc/remoting/net/impl/jetty/server/JettyServerHandlerp
pjk
q
H
r
sq
 org/eclipse/jetty/server/Requestp
t
u
v
w
T
x
ylm
z
{
 com/xxl/job/core/biz/ExecutorBiz
:com/xxl/rpc/remoting/invoker/reference/XxlRpcReferenceBean
|
}
~

€
p
‚
ƒ
„
…
†
@
‡
y
ˆ
‰
Š
y
B¥
‹
Œ

Ž
(org/quartz/impl/triggers/CronTriggerImpl

T

N
‘
’
“
N
org/quartz/SchedulerException
”
T
•
–
org/quartz/JobKeyp
—
˜
™
š
›
œ

ž
Ÿ
 
¡
¢
£
¤
¥
¦
§
org/quartz/CronTrigger
0com/xxl/job/admin/core/jobbean/RemoteHttpJobBean
¨
©
ª
¢
«
¦
¬
­
®
A>>>>>>>>>>> addJob success, jobDetail:{}, cronTrigger:{}, date:{}
java/lang/Object
M
¯
°
™
,>>>>>>>>>>> removeJob success, triggerKey:{}
M
±
²
³
´
¡
µ
¶
6>>>>>>>>>>> resumeJob success, JobGroup:{}, JobName:{}
M
·
6com/xxl/job/admin/core/schedule/XxlJobDynamicScheduler
¸
¹
º
&java/util/concurrent/ConcurrentHashMap
java/lang/Exception
3[Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum;
java/io/IOException
javax/servlet/ServletException
C
org/quartz/Trigger$TriggerState
'com/xxl/job/admin/core/model/XxlJobInfo
java/lang/String
org/quartz/TriggerKey
org/quartz/Trigger
org/springframework/util/Assert
notNull
'(Ljava/lang/Object;Ljava/lang/String;)V
6com/xxl/job/admin/core/thread/JobRegistryMonitorHelper
getInstance
:()Lcom/xxl/job/admin/core/thread/JobRegistryMonitorHelper;
2com/xxl/job/admin/core/thread/JobFailMonitorHelper
6()Lcom/xxl/job/admin/core/thread/JobFailMonitorHelper;
org/slf4j/Logger
info
(Ljava/lang/String;)V
2com/xxl/job/admin/core/thread/JobTriggerPoolHelper
toStop
0com/xxl/job/core/enums/ExecutorBlockStrategyEnum
values
5()[Lcom/xxl/job/core/enums/ExecutorBlockStrategyEnum;
()Ljava/lang/String;
concat
&(Ljava/lang/String;)Ljava/lang/String;
$com/xxl/job/admin/core/util/I18nUtil
    getString
setTitle
 com/xxl/rpc/remoting/net/NetEnum
JETTY
"Lcom/xxl/rpc/remoting/net/NetEnum;
»
.com/xxl/rpc/serialize/Serializer$SerializeEnum
 SerializeEnum
HESSIAN
0Lcom/xxl/rpc/serialize/Serializer$SerializeEnum;
 getSerializer
$()Lcom/xxl/rpc/serialize/Serializer;
-com/xxl/job/admin/core/conf/XxlJobAdminConfig
getAdminConfig
1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig;
getAccessToken

initConfig
Œ(Lcom/xxl/rpc/remoting/net/NetEnum;Lcom/xxl/rpc/serialize/Serializer;Ljava/lang/String;ILjava/lang/String;Ljava/lang/Class;Ljava/util/Map;)V
java/lang/Class
getName
getAdminBiz
!()Lcom/xxl/job/core/biz/AdminBiz;

addService
9(Ljava/lang/String;Ljava/lang/String;Ljava/lang/Object;)V
8(Lcom/xxl/rpc/remoting/provider/XxlRpcProviderFactory;)V
1com/xxl/rpc/remoting/invoker/XxlRpcInvokerFactory
5()Lcom/xxl/rpc/remoting/invoker/XxlRpcInvokerFactory;
stop
M(Lorg/eclipse/jetty/server/HttpChannel;Lorg/eclipse/jetty/server/HttpInput;)V
handle
†(Ljava/lang/String;Lorg/eclipse/jetty/server/Request;Ljavax/servlet/http/HttpServletRequest;Ljavax/servlet/http/HttpServletResponse;)V
trim
length
()I
get
&(Ljava/lang/Object;)Ljava/lang/Object;
*com/xxl/rpc/remoting/invoker/call/CallType
SYNC
,Lcom/xxl/rpc/remoting/invoker/call/CallType;
.com/xxl/rpc/remoting/invoker/route/LoadBalance
ROUND
0Lcom/xxl/rpc/remoting/invoker/route/LoadBalance;

V(Lcom/xxl/rpc/remoting/net/NetEnum;Lcom/xxl/rpc/serialize/Serializer;Lcom/xxl/rpc/remoting/invoker/call/CallType;Lcom/xxl/rpc/remoting/invoker/route/LoadBalance;Ljava/lang/Class;Ljava/lang/String;JLjava/lang/String;Ljava/lang/String;Lcom/xxl/rpc/remoting/invoker/call/XxlRpcInvokeCallback;Lcom/xxl/rpc/remoting/invoker/XxlRpcInvokerFactory;)V
    getObject
()Ljava/lang/Object;
put
8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
getJobGroup
valueOf
(I)Ljava/lang/String;
getId
=(Ljava/lang/String;Ljava/lang/String;)Lorg/quartz/TriggerKey;
org/quartz/Scheduler

getTrigger
-(Lorg/quartz/TriggerKey;)Lorg/quartz/Trigger;
getCronExpression

setJobCron
getTriggerState
:(Lorg/quartz/TriggerKey;)Lorg/quartz/Trigger$TriggerState;
setJobStatus

getMessage
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
'(Ljava/lang/String;Ljava/lang/String;)V
checkExists
(Lorg/quartz/TriggerKey;)Z
org/quartz/CronScheduleBuilder
cronSchedule
4(Ljava/lang/String;)Lorg/quartz/CronScheduleBuilder;
'withMisfireHandlingInstructionDoNothing
"()Lorg/quartz/CronScheduleBuilder;
org/quartz/TriggerBuilder

newTrigger
()Lorg/quartz/TriggerBuilder;
withIdentity
4(Lorg/quartz/TriggerKey;)Lorg/quartz/TriggerBuilder;
withSchedule
9(Lorg/quartz/ScheduleBuilder;)Lorg/quartz/TriggerBuilder;
build
()Lorg/quartz/Trigger;
org/quartz/JobBuilder
newJob
*(Ljava/lang/Class;)Lorg/quartz/JobBuilder;
,(Lorg/quartz/JobKey;)Lorg/quartz/JobBuilder;
()Lorg/quartz/JobDetail;
scheduleJob
<(Lorg/quartz/JobDetail;Lorg/quartz/Trigger;)Ljava/util/Date;
((Ljava/lang/String;[Ljava/lang/Object;)V
 unscheduleJob
'(Ljava/lang/String;Ljava/lang/Object;)V
equals
(Ljava/lang/Object;)Z
getTriggerBuilder
 rescheduleJob
=(Lorg/quartz/TriggerKey;Lorg/quartz/Trigger;)Ljava/util/Date;
9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;
 com/xxl/rpc/serialize/Serializer1bWfg
hi
jk
lm
no
pq
r/

*·
±s
(t
uv
wx
r=
+³±s
01tuvhi

yqri
'²¸*·¸¶¸¶    *·
²¹ ±s7:=@CE&Ft
'uvz
{
|qrN

¸¸¶¸¶*·±sKN    QTUt
uvz
{}q
r,¸L+¾=>¢ +2:¶¶¸¶„
§ÿá±s[\%[+^t~,uv€ þ    

ø!‚q
r‹;»Y·L+²²¶
¸¶

¶+ ¶!
¸¶"¶#»$Y+·%³&±s"efhkfp/s:tt;uv3ƒ„
…qr5

¸'¶(±s
vwt
uvz
{    †‡rK²&
»)Y

·**+¶+±s
yztˆ‰Š‹
zŒ    ŽrÍ]*Æ *¶,¶-š
°*¶,K².*¶/À0L+Æ+°»1Y²²¶²2²30
4*¸¶

·6¶7À0L².*+¶8W+°s2‚†‡ ˆ$‰&0@–K˜Rš[›t]‘ =’“
€

ü”z
{    •–
r
>l*¶9¸:L*¶;¸:M,+¸<N²-¹=:ÆÁ>™À>¶?:*¶@²-¹A:Æ*¶B¶C§:²¶E¹F±
WZDs:¨©¬°!±.²8³>·I¸N¹WÂZÀ\ÁkÃtR8—‘!6˜™Išž\Ÿ l¡¢d£‘
\¤‘V¥¦€ ÿ>§¨¨©ªúB«    ¬­r
K
|*+¸<N»GY*+·H:²-¹I™¬,¸J¶K:¸L-¶M¶N¶OÀP:Q:¸R¶S¶T:²¹U:    ²V½WYSYSY    S¹X¬s.ÑÒÕÖÚ(Û<Þ@ßOè]êzëtf
|®‘|¯‘
|—‘v¥¦k°±(T²³<@´µ@<¶·O-¸¹]º»    ¼
@<¶½€
ý©¾z
D    ¿Àr…)*+¸<M²,¹I™ ²,¹YW²Z,¹[¬sùûüÿ'
t )®‘)¯‘
#¥¦€
ü©z
D    Á­r
q+*¸<N²-¹Iš¬²-¹=ÀP:¹\
:,¶]™¬,¸J¶K:¹^
-¶M¶N¶OÀP:²-¹_W²`*+¹a¬s2



"
+
4
6
 ?
!W
$c
2o
3tHq¯‘q®‘
q—‘k¥¦"Oµ+FÑ?2²³€ü©ý!Ĩz
DÅq
r/b¸c³»dY·e³.±
s
)~Æǝ›
>œ@ç
]
_@