admin/MaxKey
1
0
Fork 0
mirror of https://gitee.com/dromara/MaxKey.git synced 2025-12-06 17:08:29 +08:00
Code Issues Packages Projects Releases Wiki Activity

jobs

Browse Source
This commit is contained in:
MaxKey 2022-04-14 12:17:03 +08:00
parent b9c7210d78
commit db9a90546f
3 changed files with 14 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
maxkey-authentications/maxkey-authentication-core/src/main/java/org/maxkey/authn/online/AbstractOnlineTicketService.java
View File

@ -73,7 +73,7 @@ public class AbstractOnlineTicketService implements OnlineTicketService{
String lastLogoffTime = DateUtils.formatDateTime(new Date());
_logger.trace("{} user {} terminate Ticket {} ." ,lastLogoffTime,username, onlineTicket);
this.profileLastLogoffTime(userId, lastLogoffTime);
this.sessionLogoff(userId, lastLogoffTime);
this.sessionLogoff(onlineTicket, lastLogoffTime);
remove(onlineTicket);
}

6
maxkey-webs/maxkey-web-mgt/src/main/java/org/maxkey/MaxKeyMgtJobs.java
View File

@ -20,7 +20,7 @@ package org.maxkey;
import org.maxkey.authn.online.OnlineTicketService;
import org.maxkey.jobs.AccountsStrategyJob;
import org.maxkey.jobs.DynamicGroupsJob;
import org.maxkey.jobs.OnlineTicketListenerJob;
import org.maxkey.jobs.TicketListenerJob;
import org.maxkey.persistence.service.AccountsService;
import org.maxkey.persistence.service.GroupsService;
import org.quartz.CronScheduleBuilder;
@ -52,10 +52,10 @@ public class MaxKeyMgtJobs implements InitializingBean {
JobDataMap jobDataMap = new JobDataMap();
jobDataMap.put("service", onlineTicketService);
addJobScheduler(
OnlineTicketListenerJob.class,
TicketListenerJob.class,
schedulerFactoryBean,
jobDataMap,
"* 10 * * * ? ",//10 minutes
"0 0/1 * * * ?",//10 minutes
"TicketListener"
);

20
maxkey-webs/maxkey-web-mgt/src/main/java/org/maxkey/jobs/OnlineTicketListenerJob.java → maxkey-webs/maxkey-web-mgt/src/main/java/org/maxkey/jobs/TicketListenerJob.java
View File

@ -25,8 +25,8 @@ import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class OnlineTicketListenerJob extends AbstractScheduleJob implements Job , Serializable {
final static Logger _logger = LoggerFactory.getLogger(OnlineTicketListenerJob.class);
public class TicketListenerJob extends AbstractScheduleJob implements Job , Serializable {
final static Logger _logger = LoggerFactory.getLogger(TicketListenerJob.class);
private static final long serialVersionUID = 4782358765969474833L;
@ -37,7 +37,7 @@ public class OnlineTicketListenerJob extends AbstractScheduleJob implements Jo
if(jobStatus == JOBSTATUS.RUNNING) {return;}
init(context);
_logger.debug("OnlineTicketListener Job is running ... " );
_logger.debug("TicketListener Job is running ... " );
jobStatus = JOBSTATUS.RUNNING;
try {
if(onlineTicketService != null) {
@ -50,7 +50,7 @@ public class OnlineTicketListenerJob extends AbstractScheduleJob implements Jo
}
}
}
_logger.debug("OnlineTicketListener Job finished " );
_logger.debug("TicketListener Job finished " );
jobStatus = JOBSTATUS.FINISHED;
}catch(Exception e) {
jobStatus = JOBSTATUS.ERROR;
@ -60,10 +60,10 @@ public class OnlineTicketListenerJob extends AbstractScheduleJob implements Jo
}
@Override
void init(JobExecutionContext context){
if(onlineTicketService == null) {
onlineTicketService =
(OnlineTicketService) context.getMergedJobDataMap().get("service");
}
}
void init(JobExecutionContext context){
if(onlineTicketService == null) {
onlineTicketService =
(OnlineTicketService) context.getMergedJobDataMap().get("service");
}
}
}