🎨 更改类名

master
linhaojun 3 years ago
parent dc58f81710
commit bef4423ffa

@ -7,7 +7,7 @@ import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import static com.aurora.constant.MQPrefixConst.*;
import static com.aurora.constant.MQPrefixConstant.*;
/**
* @author

@ -5,7 +5,7 @@ package com.aurora.constant;
* @author
*
*/
public class CommonConst {
public class CommonConstant {
/**
* 1

@ -4,7 +4,7 @@ package com.aurora.constant;
* @author
* mq
*/
public class MQPrefixConst {
public class MQPrefixConstant {
/**
* maxwell

@ -4,7 +4,7 @@ package com.aurora.constant;
* @author
*
*/
public class OptTypeConst {
public class OptTypeConstant {
/**
*

@ -4,7 +4,7 @@ package com.aurora.constant;
* @author
* redis
*/
public class RedisPrefixConst {
public class RedisPrefixConstant {
/**
*

@ -4,7 +4,8 @@ package com.aurora.constant;
* @author
*
*/
public class ScheduleConst {
public class ScheduleConstant {
public static final String TASK_CLASS_NAME = "TASK_CLASS_NAME";
/**
@ -44,7 +45,7 @@ public class ScheduleConst {
private final Integer value;
private Status(Integer value) {
Status(Integer value) {
this.value = value;
}

@ -1,54 +0,0 @@
package com.aurora.constant;
/**
* @author
*
**/
public class SocialLoginConst {
/**
* oauth2
*/
public static final String GRANT_TYPE = "grant_type";
/**
* uid
*/
public static final String UID = "uid";
/**
* oauth2id
*/
public static final String CLIENT_ID = "client_id";
/**
* oauth2
*/
public static final String CLIENT_SECRET = "client_secret";
/**
* code
*/
public static final String CODE = "code";
/**
* oauth2
*/
public static final String REDIRECT_URI = "redirect_uri";
/**
* QQ openId
*/
public static final String QQ_OPEN_ID = "openid";
/**
* 访
*/
public static final String ACCESS_TOKEN = "access_token";
/**
* QQ AppId
*/
public static final String OAUTH_CONSUMER_KEY = "oauth_consumer_key";
}

@ -0,0 +1,24 @@
package com.aurora.constant;
/**
* @author
*
**/
public class SocialLoginConstant {
/**
* QQ openId
*/
public static final String QQ_OPEN_ID = "openid";
/**
* 访
*/
public static final String ACCESS_TOKEN = "access_token";
/**
* QQ AppId
*/
public static final String OAUTH_CONSUMER_KEY = "oauth_consumer_key";
}

@ -9,8 +9,8 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.MQPrefixConst.EMAIL_QUEUE;
import static com.aurora.constant.CommonConstant.*;
import static com.aurora.constant.MQPrefixConstant.EMAIL_QUEUE;
/**
* @author

@ -11,7 +11,7 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import static com.aurora.constant.MQPrefixConst.MAXWELL_QUEUE;
import static com.aurora.constant.MQPrefixConstant.MAXWELL_QUEUE;
/**

@ -18,8 +18,8 @@ import org.springframework.stereotype.Component;
import java.util.List;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.TRUE;
import static com.aurora.constant.MQPrefixConst.SUBSCRIBE_QUEUE;
import static com.aurora.constant.CommonConstant.TRUE;
import static com.aurora.constant.MQPrefixConstant.SUBSCRIBE_QUEUE;
@Component
@RabbitListener(queues = SUBSCRIBE_QUEUE)

@ -18,7 +18,7 @@ import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "文章模块")
@RestController

@ -20,8 +20,8 @@ import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
import static com.aurora.constant.OptTypeConst.UPDATE;
import static com.aurora.constant.OptTypeConst.UPLOAD;
import static com.aurora.constant.OptTypeConstant.UPDATE;
import static com.aurora.constant.OptTypeConstant.UPLOAD;
@Api(tags = "aurora信息")
@RestController

@ -17,7 +17,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "分类模块")
@RestController

@ -15,7 +15,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "评论模块")
@RestController

@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import static com.aurora.constant.OptTypeConst.DELETE;
import static com.aurora.constant.OptTypeConstant.DELETE;
@Api(tags = "异常日志模块")
@RestController

@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "友链模块")
@RestController

@ -11,7 +11,7 @@ import org.springframework.web.bind.annotation.*;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "定时任务模块")
@RestController

@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import static com.aurora.constant.OptTypeConst.DELETE;
import static com.aurora.constant.OptTypeConstant.DELETE;
@Api(tags = "定时任务日志模块")
@RestController

@ -17,7 +17,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "菜单模块")
@RestController

@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
import static com.aurora.constant.OptTypeConst.DELETE;
import static com.aurora.constant.OptTypeConstant.DELETE;
@Api(tags = "操作日志模块")
@RestController

@ -21,7 +21,7 @@ import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
/**
* @author

@ -17,7 +17,7 @@ import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
/**

@ -15,7 +15,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "资源模块")
@RestController

@ -16,7 +16,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "角色模块")
@RestController

@ -17,7 +17,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "标签模块")
@RestController

@ -20,7 +20,7 @@ import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.*;
import static com.aurora.constant.OptTypeConstant.*;
@Api(tags = "说说模块")
@RestController

@ -18,8 +18,7 @@ import org.springframework.web.bind.annotation.*;
import javax.validation.Valid;
import java.util.List;
import static com.aurora.constant.OptTypeConst.SAVE;
import static com.aurora.constant.OptTypeConst.UPDATE;
import static com.aurora.constant.OptTypeConstant.UPDATE;
@Api(tags = "用户账号模块")
@RestController

@ -14,8 +14,8 @@ import org.springframework.web.multipart.MultipartFile;
import javax.validation.Valid;
import static com.aurora.constant.OptTypeConst.DELETE;
import static com.aurora.constant.OptTypeConst.UPDATE;
import static com.aurora.constant.OptTypeConstant.DELETE;
import static com.aurora.constant.OptTypeConstant.UPDATE;
@Api(tags = "用户信息模块")
@RestController

@ -1,7 +1,7 @@
package com.aurora.handler;
import com.alibaba.fastjson.JSON;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.aurora.model.vo.Result;
import org.springframework.security.access.AccessDeniedException;
import org.springframework.security.web.access.AccessDeniedHandler;
@ -15,7 +15,7 @@ import java.io.IOException;
public class AccessDeniedHandlerImpl implements AccessDeniedHandler {
@Override
public void handle(HttpServletRequest request, HttpServletResponse response, AccessDeniedException accessDeniedException) throws IOException {
response.setContentType(CommonConst.APPLICATION_JSON);
response.setContentType(CommonConstant.APPLICATION_JSON);
response.getWriter().write(JSON.toJSONString(Result.fail("权限不足")));
}
}

@ -1,7 +1,7 @@
package com.aurora.handler;
import com.alibaba.fastjson.JSON;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.aurora.model.vo.Result;
import org.springframework.security.core.AuthenticationException;
import org.springframework.security.web.AuthenticationEntryPoint;
@ -16,7 +16,7 @@ import java.io.IOException;
public class AuthenticationEntryPointImpl implements AuthenticationEntryPoint {
@Override
public void commence(HttpServletRequest request, HttpServletResponse response, AuthenticationException authException) throws IOException, ServletException {
response.setContentType(CommonConst.APPLICATION_JSON);
response.setContentType(CommonConstant.APPLICATION_JSON);
response.getWriter().write(JSON.toJSONString(Result.fail(40001, "用户未登录")));
}
}

@ -1,7 +1,7 @@
package com.aurora.handler;
import com.alibaba.fastjson.JSON;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.aurora.model.dto.UserDetailsDTO;
import com.aurora.model.dto.UserInfoDTO;
import com.aurora.entity.UserAuth;
@ -40,7 +40,7 @@ public class AuthenticationSuccessHandlerImpl implements AuthenticationSuccessHa
String token = tokenService.createToken(userDetailsDTO);
userLoginDTO.setToken(token);
}
response.setContentType(CommonConst.APPLICATION_JSON);
response.setContentType(CommonConstant.APPLICATION_JSON);
response.getWriter().write(JSON.toJSONString(Result.ok(userLoginDTO)));
updateUserInfo();
}

@ -18,7 +18,7 @@ import javax.servlet.http.HttpServletResponse;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import static com.aurora.constant.CommonConst.APPLICATION_JSON;
import static com.aurora.constant.CommonConstant.APPLICATION_JSON;
/**

@ -11,7 +11,7 @@ import javax.servlet.http.HttpServletResponse;
import java.util.Objects;
import java.util.Optional;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.CommonConstant.*;
/**
* @author

@ -1,6 +1,6 @@
package com.aurora.model.dto;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.datatype.jsr310.deser.LocalDateTimeDeserializer;
@ -156,7 +156,7 @@ public class UserDetailsDTO implements UserDetails {
@Override
@Transient
public boolean isAccountNonLocked() {
return this.isDisable.equals(CommonConst.FALSE);
return this.isDisable.equals(CommonConstant.FALSE);
}
@Override

@ -1,6 +1,6 @@
package com.aurora.quartz;
import com.aurora.constant.ScheduleConst;
import com.aurora.constant.ScheduleConstant;
import com.aurora.entity.Job;
import com.aurora.entity.JobLog;
import com.aurora.mapper.JobLogMapper;
@ -14,8 +14,8 @@ import org.springframework.beans.BeanUtils;
import java.util.Date;
import static com.aurora.constant.CommonConst.ONE;
import static com.aurora.constant.CommonConst.ZERO;
import static com.aurora.constant.CommonConstant.ONE;
import static com.aurora.constant.CommonConstant.ZERO;
/**
@ -33,7 +33,7 @@ public abstract class AbstractQuartzJob implements org.quartz.Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
Job job = new Job();
BeanUtils.copyProperties(context.getMergedJobDataMap().get(ScheduleConst.TASK_PROPERTIES), job);
BeanUtils.copyProperties(context.getMergedJobDataMap().get(ScheduleConstant.TASK_PROPERTIES), job);
try {
before(context, job);
doExecute(context, job);

@ -26,8 +26,8 @@ import java.time.temporal.ChronoUnit;
import java.util.*;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.UNKNOWN;
import static com.aurora.constant.RedisPrefixConst.*;
import static com.aurora.constant.CommonConstant.UNKNOWN;
import static com.aurora.constant.RedisPrefixConstant.*;
@Slf4j
@Component("auroraQuartz")

@ -39,8 +39,8 @@ import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
import static com.aurora.constant.MQPrefixConst.SUBSCRIBE_EXCHANGE;
import static com.aurora.constant.RedisPrefixConst.*;
import static com.aurora.constant.MQPrefixConstant.SUBSCRIBE_EXCHANGE;
import static com.aurora.constant.RedisPrefixConstant.*;
import static com.aurora.enums.ArticleStatusEnum.*;
import static com.aurora.enums.StatusCodeEnum.ARTICLE_ACCESS_FAIL;

@ -28,8 +28,8 @@ import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.RedisPrefixConst.*;
import static com.aurora.constant.CommonConstant.*;
import static com.aurora.constant.RedisPrefixConstant.*;
@Service
public class AuroraInfoServiceImpl implements AuroraInfoService {

@ -39,8 +39,8 @@ import java.util.*;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.MQPrefixConst.EMAIL_EXCHANGE;
import static com.aurora.constant.CommonConstant.*;
import static com.aurora.constant.MQPrefixConstant.EMAIL_EXCHANGE;
import static com.aurora.enums.CommentTypeEnum.*;
@Service

@ -1,6 +1,6 @@
package com.aurora.service.impl;
import com.aurora.constant.ScheduleConst;
import com.aurora.constant.ScheduleConstant;
import com.aurora.model.dto.JobDTO;
import com.aurora.entity.Job;
import com.aurora.mapper.JobMapper;
@ -114,9 +114,9 @@ public class JobServiceImpl extends ServiceImpl<JobMapper, Job> implements JobSe
updateWrapper.eq(Job::getId, jobStatusVO.getId()).set(Job::getStatus, status);
int row = jobMapper.update(null, updateWrapper);
if (row > 0) {
if (ScheduleConst.Status.NORMAL.getValue().equals(status)) {
if (ScheduleConstant.Status.NORMAL.getValue().equals(status)) {
scheduler.resumeJob(ScheduleUtils.getJobKey(jobId, jobGroup));
} else if (ScheduleConst.Status.PAUSE.getValue().equals(status)) {
} else if (ScheduleConstant.Status.PAUSE.getValue().equals(status)) {
scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
}
}

@ -25,8 +25,8 @@ import org.springframework.transaction.annotation.Transactional;
import java.util.*;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.COMPONENT;
import static com.aurora.constant.CommonConst.TRUE;
import static com.aurora.constant.CommonConstant.COMPONENT;
import static com.aurora.constant.CommonConstant.TRUE;
@Service
public class MenuServiceImpl extends ServiceImpl<MenuMapper, Menu> implements MenuService {

@ -24,8 +24,8 @@ import org.springframework.transaction.annotation.Transactional;
import java.util.List;
import java.util.Objects;
import static com.aurora.constant.CommonConst.FALSE;
import static com.aurora.constant.CommonConst.TRUE;
import static com.aurora.constant.CommonConstant.FALSE;
import static com.aurora.constant.CommonConstant.TRUE;
import static com.aurora.enums.PhotoAlbumStatusEnum.PUBLIC;
@Service

@ -27,7 +27,7 @@ import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.FALSE;
import static com.aurora.constant.CommonConstant.FALSE;
import static com.aurora.enums.PhotoAlbumStatusEnum.PUBLIC;
@Service

@ -28,7 +28,7 @@ import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.FALSE;
import static com.aurora.constant.CommonConstant.FALSE;
@Service
public class ResourceServiceImpl extends ServiceImpl<ResourceMapper, Resource> implements ResourceService {

@ -1,6 +1,6 @@
package com.aurora.service.impl;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.aurora.model.dto.RoleDTO;
import com.aurora.model.dto.UserRoleDTO;
import com.aurora.entity.Role;
@ -80,7 +80,7 @@ public class RoleServiceImpl extends ServiceImpl<RoleMapper, Role> implements Ro
Role role = Role.builder()
.id(roleVO.getId())
.roleName(roleVO.getRoleName())
.isDisable(CommonConst.FALSE)
.isDisable(CommonConstant.FALSE)
.build();
this.saveOrUpdate(role);
// 更新角色资源关系

@ -18,8 +18,8 @@ import java.time.LocalDateTime;
import java.util.Base64;
import java.util.UUID;
import static com.aurora.constant.CommonConst.TWENTY_MINUTES;
import static com.aurora.constant.RedisPrefixConst.LOGIN_USER;
import static com.aurora.constant.CommonConstant.TWENTY_MINUTES;
import static com.aurora.constant.RedisPrefixConstant.LOGIN_USER;
@Service

@ -1,7 +1,7 @@
package com.aurora.service.impl;
import com.alibaba.fastjson.JSON;
import com.aurora.constant.CommonConst;
import com.aurora.constant.CommonConstant;
import com.aurora.model.dto.*;
import com.aurora.entity.UserAuth;
import com.aurora.entity.UserInfo;
@ -38,8 +38,8 @@ import java.util.Map;
import java.util.Objects;
import java.util.stream.Collectors;
import static com.aurora.constant.MQPrefixConst.EMAIL_EXCHANGE;
import static com.aurora.constant.RedisPrefixConst.*;
import static com.aurora.constant.MQPrefixConstant.EMAIL_EXCHANGE;
import static com.aurora.constant.RedisPrefixConstant.*;
import static com.aurora.enums.UserAreaTypeEnum.getUserAreaType;
import static com.aurora.utils.CommonUtils.checkEmail;
import static com.aurora.utils.CommonUtils.getRandomCode;
@ -132,7 +132,7 @@ public class UserAuthServiceImpl implements UserAuthService {
// 新增用户信息
UserInfo userInfo = UserInfo.builder()
.email(userVO.getUsername())
.nickname(CommonConst.DEFAULT_NICKNAME + IdWorker.getId())
.nickname(CommonConstant.DEFAULT_NICKNAME + IdWorker.getId())
.avatar(auroraInfoService.getWebsiteConfig().getUserAvatar())
.build();
userInfoMapper.insert(userInfo);

@ -29,7 +29,7 @@ import org.springframework.web.multipart.MultipartFile;
import java.util.*;
import java.util.stream.Collectors;
import static com.aurora.constant.RedisPrefixConst.USER_CODE_KEY;
import static com.aurora.constant.RedisPrefixConstant.USER_CODE_KEY;
import static com.aurora.utils.PageUtils.getLimitCurrent;
import static com.aurora.utils.PageUtils.getSize;

@ -29,7 +29,7 @@ import javax.servlet.http.HttpServletRequest;
import java.time.LocalDateTime;
import java.util.Objects;
import static com.aurora.constant.CommonConst.TRUE;
import static com.aurora.constant.CommonConstant.TRUE;
/**

@ -18,7 +18,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.CommonConstant.*;
import static com.aurora.enums.ArticleStatusEnum.PUBLIC;

@ -14,7 +14,7 @@ import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;
import static com.aurora.constant.CommonConst.*;
import static com.aurora.constant.CommonConstant.*;
import static com.aurora.enums.ArticleStatusEnum.PUBLIC;

@ -2,7 +2,7 @@ package com.aurora.strategy.impl;
import com.alibaba.fastjson.JSON;
import com.aurora.config.properties.QQConfigProperties;
import com.aurora.constant.SocialLoginConst;
import com.aurora.constant.SocialLoginConstant;
import com.aurora.model.dto.QQTokenDTO;
import com.aurora.model.dto.QQUserInfoDTO;
import com.aurora.model.dto.SocialTokenDTO;
@ -19,7 +19,7 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Objects;
import static com.aurora.constant.SocialLoginConst.*;
import static com.aurora.constant.SocialLoginConstant.*;
import static com.aurora.enums.StatusCodeEnum.QQ_LOGIN_ERROR;
@ -73,7 +73,7 @@ public class QQLoginStrategyImpl extends AbstractSocialLoginStrategyImpl {
private void checkQQToken(QQLoginVO qqLoginVO) {
// 根据token获取qq openId信息
Map<String, String> qqData = new HashMap<>(1);
qqData.put(SocialLoginConst.ACCESS_TOKEN, qqLoginVO.getAccessToken());
qqData.put(SocialLoginConstant.ACCESS_TOKEN, qqLoginVO.getAccessToken());
try {
String result = restTemplate.getForObject(qqConfigProperties.getCheckTokenUrl(), String.class, qqData);
QQTokenDTO qqTokenDTO = JSON.parseObject(CommonUtils.getBracketsContent(Objects.requireNonNull(result)), QQTokenDTO.class);

@ -1,6 +1,6 @@
package com.aurora.utils;
import com.aurora.constant.ScheduleConst;
import com.aurora.constant.ScheduleConstant;
import com.aurora.entity.Job;
import com.aurora.exception.TaskException;
import com.aurora.quartz.QuartzDisallowConcurrentExecution;
@ -27,14 +27,14 @@ public class ScheduleUtils {
*
*/
public static TriggerKey getTriggerKey(Integer jobId, String jobGroup) {
return TriggerKey.triggerKey(ScheduleConst.TASK_CLASS_NAME + jobId, jobGroup);
return TriggerKey.triggerKey(ScheduleConstant.TASK_CLASS_NAME + jobId, jobGroup);
}
/**
*
*/
public static JobKey getJobKey(Integer jobId, String jobGroup) {
return JobKey.jobKey(ScheduleConst.TASK_CLASS_NAME + jobId, jobGroup);
return JobKey.jobKey(ScheduleConstant.TASK_CLASS_NAME + jobId, jobGroup);
}
/**
@ -56,7 +56,7 @@ public class ScheduleUtils {
.withSchedule(cronScheduleBuilder).build();
// 放入参数,运行时的方法可以获取
jobDetail.getJobDataMap().put(ScheduleConst.TASK_PROPERTIES, job);
jobDetail.getJobDataMap().put(ScheduleConstant.TASK_PROPERTIES, job);
// 判断是否存在
if (scheduler.checkExists(getJobKey(jobId, jobGroup))) {
@ -67,7 +67,7 @@ public class ScheduleUtils {
scheduler.scheduleJob(jobDetail, trigger);
// 暂停任务
if (job.getStatus().equals(ScheduleConst.Status.PAUSE.getValue())) {
if (job.getStatus().equals(ScheduleConstant.Status.PAUSE.getValue())) {
scheduler.pauseJob(ScheduleUtils.getJobKey(jobId, jobGroup));
}
}
@ -78,13 +78,13 @@ public class ScheduleUtils {
public static CronScheduleBuilder handleCronScheduleMisfirePolicy(Job job, CronScheduleBuilder cb)
throws TaskException {
switch (job.getMisfirePolicy()) {
case ScheduleConst.MISFIRE_DEFAULT:
case ScheduleConstant.MISFIRE_DEFAULT:
return cb;
case ScheduleConst.MISFIRE_IGNORE_MISFIRES:
case ScheduleConstant.MISFIRE_IGNORE_MISFIRES:
return cb.withMisfireHandlingInstructionIgnoreMisfires();
case ScheduleConst.MISFIRE_FIRE_AND_PROCEED:
case ScheduleConstant.MISFIRE_FIRE_AND_PROCEED:
return cb.withMisfireHandlingInstructionFireAndProceed();
case ScheduleConst.MISFIRE_DO_NOTHING:
case ScheduleConstant.MISFIRE_DO_NOTHING:
return cb.withMisfireHandlingInstructionDoNothing();
default:
throw new TaskException("The task misfire policy '" + job.getMisfirePolicy()

Loading…
Cancel
Save