Commit b43fe5c2 authored by ZWT's avatar ZWT

feat(零碳): 长庆演示系统新增功能

1.新建油田配置表同时生成相关代码及mapper文件,修改部分第三方数据抽取定时任务,增加针对不同井场开关控制逻辑,同时修改首页页面展示逻辑,通过油田配置功能区分不同首页展示功能;
2.新建定时任务配置表同时生成相关代码及mapper文件,定时任务模块增加mybatis配置,用以操作数据库,修改部分第三方数据抽取定时任务,修改使用方式使其脱离框架方便动态控制;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 7b4d410d
package pps.core.task.module; package pps.core.task.module;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.text.CharSequenceUtil; import cn.hutool.core.text.CharSequenceUtil;
import cn.hutool.core.util.ArrayUtil;
import cn.hutool.core.util.ClassUtil; import cn.hutool.core.util.ClassUtil;
import cn.hutool.cron.CronUtil; import cn.hutool.cron.CronUtil;
import cn.hutool.cron.task.Task; import cn.hutool.cron.task.Task;
...@@ -45,13 +47,16 @@ public class PpsCoreTaskModule extends XModule { ...@@ -45,13 +47,16 @@ public class PpsCoreTaskModule extends XModule {
CronUtil.setMatchSecond(true); CronUtil.setMatchSecond(true);
CronUtil.start(true); CronUtil.start(true);
//控制启动部分定时任务 //控制启动部分定时任务
List<Object> param = CollUtil.list(false, context);
String otherParam;
for (ConfigTimeTaskEnt config : configList) { for (ConfigTimeTaskEnt config : configList) {
otherParam = config.getOtherParam();
if (CharSequenceUtil.isNotBlank(otherParam)) {
CollUtil.addAll(param, CharSequenceUtil.split(otherParam, ','));
}
Object[] array = ArrayUtil.toArray(param, Object.class);
CronUtil.schedule(config.getSchedulingPattern(), (Task) () -> { CronUtil.schedule(config.getSchedulingPattern(), (Task) () -> {
if (CharSequenceUtil.isNotBlank(config.getOtherParam())) { ClassUtil.invoke(config.getClassPath(), config.getMethodName(), false, array);
ClassUtil.invoke(config.getClassPath(), config.getMethodName(), false, context, config.getOtherParam());
} else {
ClassUtil.invoke(config.getClassPath(), config.getMethodName(), false, context);
}
}); });
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment