Merge remote-tracking branch 'origin/leng_dev' into leng_dev

2026-11-08 20:49:00 +08:00 · 2019-03-24 12:55:15 +08:00
commit 3832226a8c
@@ -28,11 +28,10 @@ import java.time.LocalDateTime;
 /**
 * 字典表
 *
- * @author pigx code generator
- * @date 2019-03-19 09:52:47
+ * @author lengleng
+ * @date 2019/03/19
 */
@Data
-@TableName("sys_dict")
@EqualsAndHashCode(callSuper = true)
 public class SysDict extends Model<SysDict> {
 private static final long serialVersionUID = 1L;
@@ -28,11 +28,10 @@ import java.time.LocalDateTime;
 /**
 * 字典项
 *
- * @author pigx code generator
- * @date 2019-03-19 09:46:46
+ * @author lengleng
+ * @date 2019/03/19
 */
@Data
-@TableName("sys_dict_item")
@EqualsAndHashCode(callSuper = true)
 public class SysDictItem extends Model<SysDictItem> {
 	private static final long serialVersionUID = 1L;
@@ -29,7 +29,7 @@ import java.time.LocalDateTime;
 /**
 * 系统社交登录账号表
 *
- * @author pigx code generator
+ * @author lengleng
 * @date 2018-08-16 21:30:41
 */
@Data
@@ -34,7 +34,7 @@ import javax.validation.Valid;
 /**
 * 系统社交登录账号表
 *
- * @author pigx code generator
+ * @author lengleng
 * @date 2018-08-16 21:30:41
 */
@RestController
@@ -22,8 +22,8 @@ import com.pig4cloud.pigx.admin.api.entity.SysDictItem;
 /**
 * 字典项
 *
- * @author pigx code generator
- * @date 2019-03-19 09:46:46
+ * @author lengleng
+ * @date 2019/03/19
 */
 public interface SysDictItemMapper extends BaseMapper<SysDictItem> {

@@ -24,7 +24,7 @@ import org.apache.ibatis.annotations.Mapper;
 /**
 * 系统社交登录账号表
 *
- * @author pigx code generator
+ * @author lengleng
 * @date 2018-08-16 21:30:41
 */
@Mapper
@@ -22,8 +22,8 @@ import com.pig4cloud.pigx.admin.api.entity.SysDictItem;
 /**
 * 字典项
 *
- * @author pigx code generator
- * @date 2019-03-19 09:46:46
+ * @author lengleng
+ * @date 2019/03/19
 */
 public interface SysDictItemService extends IService<SysDictItem> {

@@ -22,8 +22,8 @@ import com.pig4cloud.pigx.admin.api.entity.SysDict;
 /**
 * 字典表
 *
- * @author pigx code generator
- * @date 2019-03-19 09:52:47
+ * @author lengleng
+ * @date 2019/03/19
 */
 public interface SysDictService extends IService<SysDict> {

@@ -24,7 +24,7 @@ import com.pig4cloud.pigx.admin.api.entity.SysSocialDetails;
 /**
 * 系统社交登录账号表
 *
- * @author pigx code generator
+ * @author lengleng
 * @date 2018-08-16 21:30:41
 */
 public interface SysSocialDetailsService extends IService<SysSocialDetails> {
@@ -25,8 +25,8 @@ import org.springframework.stereotype.Service;
 /**
 * 字典项
 *
- * @author pigx code generator
- * @date 2019-03-19 09:46:46
+ * @author lengleng
+ * @date 2019/03/19
 */
@Service
 public class SysDictItemServiceImpl extends ServiceImpl<SysDictItemMapper, SysDictItem> implements SysDictItemService {
@@ -31,8 +31,8 @@ import org.springframework.transaction.annotation.Transactional;
 /**
 * 字典表
 *
- * @author pigx code generator
- * @date 2019-03-19 09:52:47
+ * @author lengleng
+ * @date 2019/03/19
 */
@Service
@AllArgsConstructor
@@ -44,11 +44,11 @@ public class PigxInitQuartzJob {
 	@Bean
 	public void customize() {
 		sysJobService.list().forEach(sysjob -> {
-			if (PigxQuartzEnum.JOBSTATUSRELEASE.getType().equals(sysjob.getJobStatus())) {
+			if (PigxQuartzEnum.JOB_STATUS_RELEASE.getType().equals(sysjob.getJobStatus())) {
 				taskUtil.removeJob(sysjob, scheduler);
-			} else if (PigxQuartzEnum.JOBSTATUSRUNNING.getType().equals(sysjob.getJobStatus())) {
+			} else if (PigxQuartzEnum.JOB_STATUS_RUNNING.getType().equals(sysjob.getJobStatus())) {
 				taskUtil.resumeJob(sysjob, scheduler);
-			} else if (PigxQuartzEnum.JOBSTATUSNOTRUNNING.getType().equals(sysjob.getJobStatus())) {
+			} else if (PigxQuartzEnum.JOB_STATUS_NOT_RUNNING.getType().equals(sysjob.getJobStatus())) {
 				taskUtil.pauseJob(sysjob, scheduler);
 			} else {
 				taskUtil.removeJob(sysjob, scheduler);
@@ -43,7 +43,7 @@ public class PigxQuartzFactory implements Job {
 	@Override
 	@SneakyThrows
 	public void execute(JobExecutionContext jobExecutionContext) {
-		SysJob sysJob = (SysJob) jobExecutionContext.getMergedJobDataMap().get(PigxQuartzEnum.SCHEDULEJOBKEY.getType());
+		SysJob sysJob = (SysJob) jobExecutionContext.getMergedJobDataMap().get(PigxQuartzEnum.SCHEDULE_JOB_KEY.getType());
 		pigxQuartzInvokeFactory.init(sysJob, jobExecutionContext.getTrigger());
 	}
 }
@@ -52,34 +52,33 @@ public enum PigxQuartzEnum {
 	/**
 	 * 任务详细信息的key
 	 */
-	SCHEDULEJOBKEY("scheduleJob", "获取任务详细信息的key"),
+	SCHEDULE_JOB_KEY("scheduleJob", "获取任务详细信息的key"),

 	/**
 	 * JOB执行状态：0执行成功
 	 */
-	JOBLOGSTATUSSUCCESS("0", "执行成功"),
+	JOB_LOG_STATUS_SUCCESS("0", "执行成功"),
 	/**
 	 * JOB执行状态：1执行失败
 	 */
-	JOBLOGSTATUFAIL("1", "执行失败"),
+	JOB_LOG_STATUS_FAIL("1", "执行失败"),

 	/**
 	 * JOB状态：1已发布
 	 */
-	JOBSTATUSRELEASE("1", "未发布"),
+	JOB_STATUS_RELEASE("1", "已发布"),
 	/**
 	 * JOB状态：2运行中
 	 */
-	JOBSTATUSRUNNING("2", "运行中"),
+	JOB_STATUS_RUNNING("2", "运行中"),
 	/**
 	 * JOB状态：3暂停
 	 */
-	JOBSTATUSNOTRUNNING("3", "暂停"),
+	JOB_STATUS_NOT_RUNNING("3", "暂停"),
 	/**
 	 * JOB状态：4删除
 	 */
-	JOBSTATUSDEL("4", "删除");
-
+	JOB_STATUS_DEL("4", "删除");

 	/**
 	 * 类型
@@ -95,7 +95,7 @@ public class SysJobController {
 	@PreAuthorize("@pms.hasPermission('job_sysjob_add')")
 	@ApiOperation(value = "新增定时任务")
 	public R save(@RequestBody SysJob sysJob) {
-		sysJob.setJobStatus(JOBSTATUSRELEASE.getType());
+		sysJob.setJobStatus(JOB_STATUS_RELEASE.getType());
 		sysJob.setCreateBy(SecurityUtils.getUser().getUsername());
 		sysJob.setTenantId(TenantContextHolder.getTenantId());
 		return R.builder().data(sysJobService.save(sysJob)).build();
@@ -114,10 +114,10 @@ public class SysJobController {
 	public R updateById(@RequestBody SysJob sysJob) {
 		sysJob.setUpdateBy(SecurityUtils.getUser().getUsername());
 		SysJob querySysJob = this.sysJobService.getById(sysJob.getJobId());
-		if (JOBSTATUSNOTRUNNING.getType().equals(querySysJob.getJobStatus())) {
+		if (JOB_STATUS_NOT_RUNNING.getType().equals(querySysJob.getJobStatus())) {
 			this.taskUtil.addOrUpateJob(sysJob, scheduler);
 			sysJobService.updateById(sysJob);
-		} else if (JOBSTATUSRELEASE.getType().equals(querySysJob.getJobStatus())) {
+		} else if (JOB_STATUS_RELEASE.getType().equals(querySysJob.getJobStatus())) {
 			sysJobService.updateById(sysJob);
 		}
 		return R.builder().build();
@@ -135,10 +135,10 @@ public class SysJobController {
 	@ApiOperation(value = "唯一标识查询定时任务，暂停任务才能删除")
 	public R removeById(@PathVariable Integer jobId) {
 		SysJob querySysJob = this.sysJobService.getById(jobId);
-		if (JOBSTATUSNOTRUNNING.getType().equals(querySysJob.getJobStatus())) {
+		if (JOB_STATUS_NOT_RUNNING.getType().equals(querySysJob.getJobStatus())) {
 			this.taskUtil.removeJob(querySysJob, scheduler);
 			this.sysJobService.removeById(jobId);
-		} else if (JOBSTATUSRELEASE.getType().equals(querySysJob.getJobStatus())) {
+		} else if (JOB_STATUS_RELEASE.getType().equals(querySysJob.getJobStatus())) {
 			this.sysJobService.removeById(jobId);
 		}
 		return R.builder().build();
@@ -156,14 +156,14 @@ public class SysJobController {
 	public R shutdownJobs() {
 		taskUtil.pauseJobs(scheduler);
 		int count = this.sysJobService.count(new LambdaQueryWrapper<SysJob>()
-				.eq(SysJob::getJobStatus, JOBSTATUSRUNNING.getType()));
+				.eq(SysJob::getJobStatus, JOB_STATUS_RUNNING.getType()));
 		if (count <= 0) {
 			return R.builder().msg("无正在运行定时任务").build();
 		} else {
 			//更新定时任务状态条件，运行状态2更新为暂停状态2
 			this.sysJobService.update(SysJob.builder()
-					.jobStatus(JOBSTATUSNOTRUNNING.getType()).build(), new UpdateWrapper<SysJob>()
-					.lambda().eq(SysJob::getJobStatus, JOBSTATUSRUNNING.getType()));
+					.jobStatus(JOB_STATUS_NOT_RUNNING.getType()).build(), new UpdateWrapper<SysJob>()
+					.lambda().eq(SysJob::getJobStatus, JOB_STATUS_RUNNING.getType()));
 			return R.builder().msg("暂停成功").build();
 		}
 	}
@@ -179,9 +179,9 @@ public class SysJobController {
 	@ApiOperation(value = "启动全部定时任务")
 	public R startJobs() {
 		//更新定时任务状态条件，暂停状态3更新为运行状态2
-		this.sysJobService.update(SysJob.builder().jobStatus(JOBSTATUSRUNNING
+		this.sysJobService.update(SysJob.builder().jobStatus(JOB_STATUS_RUNNING
 				.getType()).build(), new UpdateWrapper<SysJob>().lambda()
-				.eq(SysJob::getJobStatus, JOBSTATUSNOTRUNNING.getType()));
+				.eq(SysJob::getJobStatus, JOB_STATUS_NOT_RUNNING.getType()));
 		taskUtil.startJobs(scheduler);
 		return R.builder().build();
 	}
@@ -197,11 +197,11 @@ public class SysJobController {
 	@ApiOperation(value = "刷新全部定时任务")
 	public R refreshJobs() {
 		sysJobService.list().forEach((sysjob) -> {
-			if (JOBSTATUSRELEASE.getType().equals(sysjob.getJobStatus())
-					|| JOBSTATUSDEL.getType().equals(sysjob.getJobStatus())) {
+			if (JOB_STATUS_RELEASE.getType().equals(sysjob.getJobStatus())
+					|| JOB_STATUS_DEL.getType().equals(sysjob.getJobStatus())) {
 				taskUtil.removeJob(sysjob, scheduler);
-			} else if (JOBSTATUSRUNNING.getType().equals(sysjob.getJobStatus())
-					|| JOBSTATUSNOTRUNNING.getType().equals(sysjob.getJobStatus())) {
+			} else if (JOB_STATUS_RUNNING.getType().equals(sysjob.getJobStatus())
+					|| JOB_STATUS_NOT_RUNNING.getType().equals(sysjob.getJobStatus())) {
 				taskUtil.addOrUpateJob(sysjob, scheduler);
 			} else {
 				taskUtil.removeJob(sysjob, scheduler);
@@ -222,7 +222,7 @@ public class SysJobController {
 	@ApiOperation(value = "启动定时任务")
 	public R startJob(@PathVariable("jobId") Integer jobId) {
 		SysJob querySysJob = this.sysJobService.getById(jobId);
-		if (querySysJob != null && JOBLOGSTATUFAIL.getType()
+		if (querySysJob != null && JOB_LOG_STATUS_FAIL.getType()
 				.equals(querySysJob.getJobStatus())) {
 			taskUtil.addOrUpateJob(querySysJob, scheduler);
 		} else {
@@ -230,7 +230,7 @@ public class SysJobController {
 		}
 		//更新定时任务状态条件，暂停状态3更新为运行状态2
 		this.sysJobService.updateById(SysJob.builder().jobId(jobId)
-				.jobStatus(JOBSTATUSRUNNING.getType()).build());
+				.jobStatus(JOB_STATUS_RUNNING.getType()).build());
 		return R.builder().build();
 	}

@@ -247,7 +247,7 @@ public class SysJobController {
 		SysJob querySysJob = this.sysJobService.getById(jobId);
 		//更新定时任务状态条件，运行状态2更新为暂停状态3
 		this.sysJobService.updateById(SysJob.builder().jobId(querySysJob.getJobId())
-				.jobStatus(JOBSTATUSNOTRUNNING.getType()).build());
+				.jobStatus(JOB_STATUS_NOT_RUNNING.getType()).build());
 		taskUtil.pauseJob(querySysJob, scheduler);
 		return R.builder().build();
 	}
@@ -48,7 +48,7 @@ public class EventAutoConfiguration {
 	}

 	@Bean
-	public PigxQuartzInvokeFactory frwcloudQuartzInvokeFactory(ApplicationEventPublisher publisher) {
+	public PigxQuartzInvokeFactory pigxQuartzInvokeFactory(ApplicationEventPublisher publisher) {
 		return new PigxQuartzInvokeFactory(publisher);
 	}

@@ -35,6 +35,6 @@ public class Demo {
 	@SneakyThrows
 	public String demoMethod(String para) {
 		log.info("郑健楠测试于:{}，输入参数L{}", DateUtil.now(), para);
-		return PigxQuartzEnum.JOBLOGSTATUSSUCCESS.getType();
+		return PigxQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
 	}
 }
@@ -34,6 +34,6 @@ public class Demo1 {
 	@SneakyThrows
 	public String demoMethod(String para) {
 		log.info("demo1测试于:{}，输入参数L{}", new Date(), para);
-		return PigxQuartzEnum.JOBLOGSTATUSSUCCESS.getType();
+		return PigxQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType();
 	}
 }
@@ -53,7 +53,7 @@ public class JavaClassTaskInvok implements ITaskInvok {
 				method = clazz.getDeclaredMethod(sysJob.getMethodName());
 				returnValue = method.invoke(obj);
 			}
-			if (StrUtil.isEmpty(returnValue.toString()) || PigxQuartzEnum.JOBLOGSTATUFAIL.getType().equals(returnValue.toString())) {
+			if (StrUtil.isEmpty(returnValue.toString()) || PigxQuartzEnum.JOB_LOG_STATUS_FAIL.getType().equals(returnValue.toString())) {
 				log.error("定时任务javaClassTaskInvok异常,执行任务：{}", sysJob.getClassName());
 				throw new TaskException("定时任务javaClassTaskInvok业务执行失败,任务：" + sysJob.getClassName());
 			}
@@ -55,7 +55,7 @@ public class SpringBeanTaskInvok implements ITaskInvok {
 				ReflectionUtils.makeAccessible(method);
 				returnValue = method.invoke(target);
 			}
-			if (StrUtil.isEmpty(returnValue.toString()) || PigxQuartzEnum.JOBLOGSTATUFAIL.getType()
+			if (StrUtil.isEmpty(returnValue.toString()) || PigxQuartzEnum.JOB_LOG_STATUS_FAIL.getType()
 					.equals(returnValue.toString())) {
 				log.error("定时任务springBeanTaskInvok异常,执行任务：{}", sysJob.getClassName());
 				throw new TaskException("定时任务springBeanTaskInvok业务执行失败,任务：" + sysJob.getClassName());
@@ -105,11 +105,11 @@ public class TaskInvokUtil {
 			}
 			//获取执行结束时间
 			endTime = System.currentTimeMillis();
-			sysJobLog.setJobMessage(PigxQuartzEnum.JOBLOGSTATUSSUCCESS.getDescription());
-			sysJobLog.setJobLogStatus(PigxQuartzEnum.JOBLOGSTATUSSUCCESS.getType());
+			sysJobLog.setJobMessage(PigxQuartzEnum.JOB_LOG_STATUS_SUCCESS.getDescription());
+			sysJobLog.setJobLogStatus(PigxQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType());
 			sysJobLog.setExecuteTime(String.valueOf(endTime - startTime));
 			//任务表信息更新
-			updateSysjob.setJobExecuteStatus(PigxQuartzEnum.JOBLOGSTATUSSUCCESS.getType());
+			updateSysjob.setJobExecuteStatus(PigxQuartzEnum.JOB_LOG_STATUS_SUCCESS.getType());
 			updateSysjob.setStarttime(trigger.getStartTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
 			updateSysjob.setPrevioustime(trigger.getPreviousFireTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
 			updateSysjob.setNexttime(trigger.getNextFireTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
@@ -117,12 +117,12 @@ public class TaskInvokUtil {
 			//获取执行结束时间
 			endTime = System.currentTimeMillis();
 			log.error("定时任务执行失败，任务名称：{}；任务组名：{}，cron执行表达式：{}，执行时间：{}", sysJob.getJobName(), sysJob.getJobGroup(), sysJob.getCronExpression(), new Date());
-			sysJobLog.setJobMessage(PigxQuartzEnum.JOBLOGSTATUFAIL.getDescription());
-			sysJobLog.setJobLogStatus(PigxQuartzEnum.JOBLOGSTATUFAIL.getType());
+			sysJobLog.setJobMessage(PigxQuartzEnum.JOB_LOG_STATUS_FAIL.getDescription());
+			sysJobLog.setJobLogStatus(PigxQuartzEnum.JOB_LOG_STATUS_FAIL.getType());
 			sysJobLog.setExecuteTime(String.valueOf(endTime - startTime));
 			sysJobLog.setExceptionInfo(StrUtil.sub(e.getMessage(), 0, 2000));
 			//任务表信息更新
-			updateSysjob.setJobExecuteStatus(PigxQuartzEnum.JOBLOGSTATUFAIL.getType());
+			updateSysjob.setJobExecuteStatus(PigxQuartzEnum.JOB_LOG_STATUS_FAIL.getType());
 			updateSysjob.setStarttime(trigger.getStartTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
 			updateSysjob.setPrevioustime(trigger.getPreviousFireTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
 			updateSysjob.setNexttime(trigger.getNextFireTime().toInstant().atZone(ZoneId.systemDefault()).toLocalDateTime());
@@ -72,7 +72,7 @@ public class TaskUtil {
 				//新建一个工作任务 指定任务类型为串接进行的
 				JobDetail jobDetail = JobBuilder.newJob(PigxQuartzFactory.class).withIdentity(jobKey).build();
 				//将任务信息添加到任务信息中
-				jobDetail.getJobDataMap().put(SCHEDULEJOBKEY.getType(), sysjob);
+				jobDetail.getJobDataMap().put(SCHEDULE_JOB_KEY.getType(), sysjob);
 				//将cron表达式进行转换
 				CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(sysjob.getCronExpression());
 				cronScheduleBuilder = this.handleCronScheduleMisfirePolicy(sysjob, cronScheduleBuilder);
@@ -86,12 +86,12 @@ public class TaskUtil {
 				//按照新的规则进行
 				trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(cronScheduleBuilder).build();
 				//将任务信息更新到任务信息中
-				trigger.getJobDataMap().put(SCHEDULEJOBKEY.getType(), sysjob);
+				trigger.getJobDataMap().put(SCHEDULE_JOB_KEY.getType(), sysjob);
 				//重启
 				scheduler.rescheduleJob(triggerKey, trigger);
 			}
 			// 如任务状态为暂停
-			if (sysjob.getJobStatus().equals(JOBSTATUSNOTRUNNING.getType())) {
+			if (sysjob.getJobStatus().equals(JOB_STATUS_NOT_RUNNING.getType())) {
 				this.pauseJob(sysjob, scheduler);
 			}
 		} catch (SchedulerException e) {