upd: 编码规范
This commit is contained in:
@@ -26,7 +26,7 @@ public class JobRunner implements ApplicationRunner {
|
|||||||
*/
|
*/
|
||||||
@Override
|
@Override
|
||||||
public void run(ApplicationArguments applicationArguments) {
|
public void run(ApplicationArguments applicationArguments) {
|
||||||
List<QuartzJob> quartzJobs = quartzJobMapper.findActiveQuartzJobs();
|
List<QuartzJob> quartzJobs = quartzJobMapper.findActiveQuartzJob();
|
||||||
quartzJobs.forEach(quartzManage::addJob);
|
quartzJobs.forEach(quartzManage::addJob);
|
||||||
log.info("Timing task injection complete");
|
log.info("Timing task injection complete");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,5 +14,5 @@ import java.util.List;
|
|||||||
public interface QuartzJobMapper extends BaseMapper<QuartzJob> {
|
public interface QuartzJobMapper extends BaseMapper<QuartzJob> {
|
||||||
IPage<QuartzJob> findQuartzJob(@Param("criteria") QuartzJobQueryCriteria criteria, Page<Object> page);
|
IPage<QuartzJob> findQuartzJob(@Param("criteria") QuartzJobQueryCriteria criteria, Page<Object> page);
|
||||||
List<QuartzJob> findQuartzJob(@Param("criteria") QuartzJobQueryCriteria criteria);
|
List<QuartzJob> findQuartzJob(@Param("criteria") QuartzJobQueryCriteria criteria);
|
||||||
List<QuartzJob> findActiveQuartzJobs();
|
List<QuartzJob> findActiveQuartzJob();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -15,7 +15,7 @@
|
|||||||
</where>
|
</where>
|
||||||
ORDER BY id DESC
|
ORDER BY id DESC
|
||||||
</select>
|
</select>
|
||||||
<select id="findActiveQuartzJobs" resultType="cn.odboy.model.job.domain.QuartzJob">
|
<select id="findActiveQuartzJob" resultType="cn.odboy.model.job.domain.QuartzJob">
|
||||||
SELECT * FROM sys_quartz_job WHERE is_pause = 0
|
SELECT * FROM sys_quartz_job WHERE is_pause = 0
|
||||||
</select>
|
</select>
|
||||||
</mapper>
|
</mapper>
|
||||||
Reference in New Issue
Block a user