gitee
/
snowy
mirror of https://gitee.com/xiaonuobase/snowy
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

update DevJobServiceImpl.java. 

修改原因：当CommonTimerTaskRunner为代理对象时，获取到代理对象的名称，导致启动异常。 修改方式：添加判断

Signed-off-by: lrp <9143508+mrlrp@user.noreply.gitee.com>
pull/193/head v2.5.1
lrp 2024-01-15 09:28:22 +00:00 committed by 小诺
parent ad5582bb62
commit 8c413dbd53
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
snowy-plugin/snowy-plugin-dev/src/main/java/vip/xiaonuo/dev/modular/job/service/impl/DevJobServiceImpl.java
View File

@ -26,6 +26,7 @@ import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.aop.support.AopUtils;
import org.springframework.scheduling.support.CronExpression;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
@ -242,7 +243,15 @@ public class DevJobServiceImpl extends ServiceImpl<DevJobMapper, DevJob> impleme
Map<String, CommonTimerTaskRunner> commonTimerTaskRunnerMap = SpringUtil.getBeansOfType(CommonTimerTaskRunner.class);
if (ObjectUtil.isNotEmpty(commonTimerTaskRunnerMap)) {
Collection<CommonTimerTaskRunner> values = commonTimerTaskRunnerMap.values();
return values.stream().map(commonTimerTaskRunner -> commonTimerTaskRunner.getClass().getName()).collect(Collectors.toList());
return values.stream().map(commonTimerTaskRunner -> {
Class<?> clazz = null;
if(AopUtils.isAopProxy(commonTimerTaskRunner)) {
clazz = AopUtils.getTargetClass(commonTimerTaskRunner);
} else {
clazz = commonTimerTaskRunner.getClass();
}
return clazz.getName();
}).collect(Collectors.toList());
} else {
return CollectionUtil.newArrayList();
}