Skip to content

G
gf_back
Commit 7aa5f644 authored by ZWT's avatar ZWT
Browse files
Options

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

1.修改第三方日累计数据推送表表结构,增加日累计储能放电量字段,同时修改代码对应实体及mapper文件,修改相关接口增加储能日累计放电量接收逻辑;
2.修改首页井场收益分析模块接口,修改获取储能累计放电量逻辑;
3.设计并创建井口日用电趋势表,生成对应实体类及mapper文件;
4.统计分析模块,新增本月累计节电经济效益查询接口,添加线上接口文档并完成接口冒烟测试;
5.统计分析模块,新增本月累计减碳量查询接口,添加线上接口文档并完成接口冒烟测试;
6.统计分析模块,新增光伏发电趋势查询接口,添加线上接口文档并完成接口冒烟测试;
7.统计分析模块,新增月度总览查询接口,添加线上接口文档并完成接口冒烟测试;

BREAKING CHANGE: 无

Closes 无

[skip ci]
parent 7c58540f
Hide whitespace changes
Inline Side-by-side
Showing with 232 additions and 102 deletions
C10-task/pps-core-task/src/main/java/pps/core/task/entity/ConfigTimeTaskEnt.java 0 → 100644
View file @ 7aa5f644
package pps.core.task.entity;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import xstartup.annotation.XText;
import java.io.Serializable;
/**
* 动态定时任务配置
*
* @author ZWT
* @date 2024/07/04
*/
@Data
@TableName("config_time_task")
public class ConfigTimeTaskEnt implements Serializable {
@XText("ID")
@TableId(type = IdType.AUTO)
private Long id;
@XText("类路径")
@TableField
private String classPath;
@XText("方法名")
@TableField
private String methodName;
@XText("cron表达式")
@TableField
private String schedulingPattern;
@XText("描述")
@TableField
private String taskDescribe;
@XText("是否启用(0_是,1_否)")
@TableField
private Integer isEnable;
@XText("来源系统")
@TableField
private String systemSource;
}
C10-task/pps-core-task/src/main/java/pps/core/task/entity/ConfigTimeTaskView.java 0 → 100644
View file @ 7aa5f644
package pps.core.task.entity;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import xstartup.annotation.XText;
import java.io.Serializable;
/**
* 动态定时任务配置
*
* @author ZWT
* @date 2024/07/04
*/
@Data
public class ConfigTimeTaskView implements Serializable {
@XText("ID")
@TableField
private Long id;
@XText("类路径")
@TableField
private String classPath;
@XText("方法名")
@TableField
private String methodName;
@XText("cron表达式")
@TableField
private String schedulingPattern;
@XText("描述")
@TableField
private String taskDescribe;
@XText("是否启用(0_是,1_否)")
@TableField
private Integer isEnable;
@XText("来源系统")
@TableField
private String systemSource;
}
C10-task/pps-core-task/src/main/java/pps/core/task/job/ThirdActivePowerJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 第三方有功功率定时任务
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/03/19 10:06
*/
@XText("第三方有功功率定时任务")
@XService
public class ThirdActivePowerJob extends JobCommonService implements XJob {
public class ThirdActivePowerJob extends JobCommonService {
/**
* 十分钟一次
......@@ -27,14 +24,8 @@ public class ThirdActivePowerJob extends JobCommonService implements XJob {
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.TEN_MINUTES)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ ThirdActivePowerJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ ThirdActivePowerJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdActivePowerJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "ThirdActivePowerJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +37,7 @@ public class ThirdActivePowerJob extends JobCommonService implements XJob {
} catch (Exception e) {
xContext.getLogger().error("------ ThirdActivePowerJob Exception: ", e);
} finally {
xContext.getLogger().info("------ ThirdActivePowerJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdActivePowerJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/job/ThirdCurrentWellConditionJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 第三方当日油井状态定时任务
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/03/19 10:07
*/
@XText("第三方当日油井状态定时任务")
@XService
public class ThirdCurrentWellConditionJob extends JobCommonService implements XJob {
public class ThirdCurrentWellConditionJob extends JobCommonService {
/**
* 十分钟一次,隔9分钟
......@@ -27,14 +24,8 @@ public class ThirdCurrentWellConditionJob extends JobCommonService implements XJ
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.TEN_MINUTES_9)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ ThirdCurrentWellConditionJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ ThirdCurrentWellConditionJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdCurrentWellConditionJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "ThirdCurrentWellConditionJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +37,7 @@ public class ThirdCurrentWellConditionJob extends JobCommonService implements XJ
} catch (Exception e) {
xContext.getLogger().error("------ ThirdCurrentWellConditionJob Exception: ", e);
} finally {
xContext.getLogger().info("------ ThirdCurrentWellConditionJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdCurrentWellConditionJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/job/ThirdDailyAccumulationJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 第三方井场日累计数据定时任务
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/04/01 14:58
*/
@XText("第三方井场日累计数据定时任务")
@XService
public class ThirdDailyAccumulationJob extends JobCommonService implements XJob {
public class ThirdDailyAccumulationJob extends JobCommonService {
/**
* 十分钟一次,隔7分钟
......@@ -27,14 +24,9 @@ public class ThirdDailyAccumulationJob extends JobCommonService implements XJob
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.TEN_MINUTES_7)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ ThirdDailyAccumulationJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ ThirdDailyAccumulationJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdDailyAccumulationJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "ThirdDailyAccumulationJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +38,7 @@ public class ThirdDailyAccumulationJob extends JobCommonService implements XJob
} catch (Exception e) {
xContext.getLogger().error("------ ThirdDailyAccumulationJob Exception: ", e);
} finally {
xContext.getLogger().info("------ ThirdDailyAccumulationJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdDailyAccumulationJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/job/ThirdPhotovoltaicPowerJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 第三方光伏日发电量定时任务
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/03/19 10:07
*/
@XText("第三方光伏日发电量定时任务")
@XService
public class ThirdPhotovoltaicPowerJob extends JobCommonService implements XJob {
public class ThirdPhotovoltaicPowerJob extends JobCommonService {
/**
* 每天00:05
......@@ -27,14 +24,8 @@ public class ThirdPhotovoltaicPowerJob extends JobCommonService implements XJob
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.EVERY_DAY_5)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ ThirdPhotovoltaicPowerJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ ThirdPhotovoltaicPowerJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdPhotovoltaicPowerJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "ThirdPhotovoltaicPowerJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +37,7 @@ public class ThirdPhotovoltaicPowerJob extends JobCommonService implements XJob
} catch (Exception e) {
xContext.getLogger().error("------ ThirdPhotovoltaicPowerJob Exception: ", e);
} finally {
xContext.getLogger().info("------ ThirdPhotovoltaicPowerJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdPhotovoltaicPowerJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/job/ThirdWellAvgActivePowerJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IThirdDataAccessCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 第三方单井平均有功功率定时任务
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/04/01 17:01
*/
@XText("第三方单井平均有功功率定时任务")
@XService
public class ThirdWellAvgActivePowerJob extends JobCommonService implements XJob {
public class ThirdWellAvgActivePowerJob extends JobCommonService {
/**
* 十分钟一次隔3分钟
......@@ -27,14 +24,8 @@ public class ThirdWellAvgActivePowerJob extends JobCommonService implements XJob
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.TEN_MINUTES_3)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ ThirdWellAvgActivePowerJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ ThirdWellAvgActivePowerJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdWellAvgActivePowerJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "ThirdWellAvgActivePowerJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +37,7 @@ public class ThirdWellAvgActivePowerJob extends JobCommonService implements XJob
} catch (Exception e) {
xContext.getLogger().error("------ ThirdWellAvgActivePowerJob Exception: ", e);
} finally {
xContext.getLogger().info("------ ThirdWellAvgActivePowerJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ ThirdWellAvgActivePowerJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/job/WellTechDailyJob.java
View file @ 7aa5f644
package pps.core.task.job;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.util.ObjectUtil;
import pps.cloud.prediction.service.IPlantPredictedPowerCloudService;
import pps.core.common.cache.TaskLockCache;
import pps.core.task.constant.TaskConstant;
import xstartup.annotation.XService;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.data.XServiceResult;
import xstartup.service.job.XJob;
import xstartup.service.job.annotation.XCronTrigger;
/**
* 日耗电日产液信息
......@@ -18,8 +16,7 @@ import xstartup.service.job.annotation.XCronTrigger;
* @date 2024/03/18 14:52
*/
@XText("日耗电日产液信息定时任务")
@XService
public class WellTechDailyJob extends JobCommonService implements XJob {
public class WellTechDailyJob extends JobCommonService {
/**
* 每天0点执行
......@@ -27,14 +24,8 @@ public class WellTechDailyJob extends JobCommonService implements XJob {
* @param xContext x上下文
* @return {@link XServiceResult}
*/
@XCronTrigger(value = TaskConstant.EVERY_DAY_0)
@Override
public XServiceResult execute(XContext xContext) {
if (this.isClosed(this.getCurrentConfig(xContext))) {
xContext.getLogger().info("------ WellTechDailyJob not enabled");
return XServiceResult.OK;
}
xContext.getLogger().info("------ WellTechDailyJob start:{}", System.currentTimeMillis());
xContext.getLogger().info("------ WellTechDailyJob start:{}", DateUtil.date());
String key = TaskConstant.TASK_LOCK_KEY + "WellTechDailyJob";
TaskLockCache exist = TaskLockCache.exist(xContext, key);
if (ObjectUtil.isNull(exist)) {
......@@ -46,7 +37,7 @@ public class WellTechDailyJob extends JobCommonService implements XJob {
} catch (Exception e) {
xContext.getLogger().error("------ WellTechDailyJob Exception: ", e);
} finally {
xContext.getLogger().info("------ WellTechDailyJob end:{}", System.currentTimeMillis());
xContext.getLogger().info("------ WellTechDailyJob end:{}", DateUtil.date());
TaskLockCache.delete(xContext, key);
}
}
......
C10-task/pps-core-task/src/main/java/pps/core/task/mapper/ConfigTimeTaskMapper.java 0 → 100644
View file @ 7aa5f644
package pps.core.task.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springframework.stereotype.Repository;
import pps.core.task.entity.ConfigTimeTaskEnt;
/**
* 动态定时任务配置
*
* @author ZWT
* @date 2024/07/04
*/
@Repository(value = "pps.core.task.mapper.ConfigTimeTaskMapper")
public interface ConfigTimeTaskMapper extends BaseMapper<ConfigTimeTaskEnt> {
}
C10-task/pps-core-task/src/main/java/pps/core/task/mapper/ConfigTimeTaskViewMapper.java 0 → 100644
View file @ 7aa5f644
package pps.core.task.mapper;
import org.springframework.stereotype.Repository;
import pps.core.task.entity.ConfigTimeTaskView;
import java.util.List;
/**
* 动态定时任务配置
*
* @author ZWT
* @date 2024/07/04
*/
@Repository(value = "pps.core.task.mapper.ConfigTimeTaskViewMapper")
public interface ConfigTimeTaskViewMapper {
ConfigTimeTaskView selectOne(ConfigTimeTaskView record);
List<ConfigTimeTaskView> selectList(ConfigTimeTaskView record);
}
C10-task/pps-core-task/src/main/java/pps/core/task/module/PpsCoreTaskModule.java
View file @ 7aa5f644
package pps.core.task.module;
import cn.hutool.core.util.ClassUtil;
import cn.hutool.cron.CronUtil;
import cn.hutool.cron.task.Task;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import pps.core.common.constant.BusinessConstant;
import pps.core.common.provider.impl.PpsConfigProviderCommonImpl;
import pps.core.common.utils.ManifestComponentInfoHelper;
import pps.core.task.entity.ConfigTimeTaskEnt;
import pps.core.task.mapper.ConfigTimeTaskMapper;
import xstartup.annotation.XText;
import xstartup.base.XContext;
import xstartup.base.XModule;
import xstartup.base.pattern.XProviderManager;
import xstartup.kernel.system.provider.spec.XConfigProvider;
import java.util.List;
@XText("任务模块")
public class PpsCoreTaskModule extends XModule {
protected PpsCoreTaskModule() {
......@@ -19,5 +28,17 @@ public class PpsCoreTaskModule extends XModule {
//配置信息 自定义实现类
XProviderManager.setDefaultImplement(context, XConfigProvider.class, PpsConfigProviderCommonImpl.class);
ManifestComponentInfoHelper.init(this.getClass().getClassLoader());
// 启动 Cron 线程
CronUtil.setMatchSecond(true);
CronUtil.start(true);
ConfigTimeTaskMapper taskMapper = context.getBean(ConfigTimeTaskMapper.class);
List<ConfigTimeTaskEnt> configList = taskMapper.selectList(new LambdaQueryWrapper<ConfigTimeTaskEnt>()
.eq(ConfigTimeTaskEnt::getIsEnable, BusinessConstant.ZERO)
);
for (ConfigTimeTaskEnt config : configList) {
CronUtil.schedule(config.getSchedulingPattern(), (Task) () -> {
ClassUtil.invoke(config.getClassPath(), config.getMethodName(), false, context);
});
}
}
}
C10-task/pps-core-task/src/main/java/pps/core/task/mybatis/PpsCoreBaseMybatis.java 0 → 100644
View file @ 7aa5f644
package pps.core.task.mybatis;
import com.baomidou.mybatisplus.core.config.GlobalConfig;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import pps.core.common.mybatis.MybaitisGlobalConfigSuppiler;
import xstartup.service.mybatis.XMybatis;
/**
* mybatis 配置类
*/
@Component
@EnableTransactionManagement
@MapperScan(sqlSessionTemplateRef = "sqlSessionTemplateRef.pps.core.task",
sqlSessionFactoryRef = "sqlSessionFactoryRef.pps.core.task",
basePackages = {"pps.core.task.mapper"})
public class PpsCoreBaseMybatis extends XMybatis {
@Override
public GlobalConfig getGlobalConfig() {
return MybaitisGlobalConfigSuppiler.INSTANCE.get();
}
}
C10-task/pps-core-task/src/main/resources/mybatis/mapper/pps/core/task/ConfigTimeTaskViewMapper.xml 0 → 100644
View file @ 7aa5f644
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="pps.core.task.mapper.ConfigTimeTaskViewMapper">
<resultMap id="BaseResultMap" type="pps.core.task.entity.ConfigTimeTaskView">
<id column="id" property="id" jdbcType="BIGINT" />
<result column="class_path" property="classPath" jdbcType="VARCHAR" />
<result column="method_name" property="methodName" jdbcType="VARCHAR" />
<result column="scheduling_pattern" property="schedulingPattern" jdbcType="VARCHAR" />
<result column="task_describe" property="taskDescribe" jdbcType="VARCHAR" />
<result column="is_enable" property="isEnable" jdbcType="TINYINT" />
<result column="system_source" property="systemSource" jdbcType="VARCHAR" />
</resultMap>
<sql id="Base_Column_List">
id
,
class_path,
method_name,
scheduling_pattern,
task_describe,
is_enable,
system_source
</sql>
<select id="selectOne" parameterType="pps.core.task.entity.ConfigTimeTaskView" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from config_time_task
where
id=#{id}
</select>
<select id="selectList" parameterType="pps.core.task.entity.ConfigTimeTaskView" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from config_time_task
where
id=#{id}
</select>
</mapper>
\ No newline at end of file
D03-deploy/deploy-pps-all/src/main/java/app/DeployPpsAllApplication.java
View file @ 7aa5f644
......@@ -34,12 +34,6 @@ public class DeployPpsAllApplication {
startup.enable(XJobFeature.class).config(new XJobServiceConf(DailyElectricityTrendJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherReceiveJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherApiReceiveJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WellTechDailyJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdActivePowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdCurrentWellConditionJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdPhotovoltaicPowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdWellAvgActivePowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdDailyAccumulationJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(EnergyConsumptionAnalysisJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(PlantPredictedPowerLongTermDataJob.class));
startup.run(args);
......
D03-deploy/deploy-pps-all/src/main/resources/deploy-pps-all.app.properties
View file @ 7aa5f644
......@@ -20,12 +20,6 @@ x.job.service=pps.core.task.job.SpaceOptimizeLongJob,\
pps.core.task.job.DailyElectricityTrendJob,\
pps.core.task.job.WeatherReceiveJob,\
pps.core.task.job.WeatherApiReceiveJob,\
pps.core.task.job.WellTechDailyJob,\
pps.core.task.job.ThirdActivePowerJob,\
pps.core.task.job.ThirdCurrentWellConditionJob,\
pps.core.task.job.ThirdPhotovoltaicPowerJob,\
pps.core.task.job.ThirdWellAvgActivePowerJob,\
pps.core.task.job.ThirdDailyAccumulationJob,\
pps.core.task.job.EnergyConsumptionAnalysisJob,\
pps.core.task.job.PlantPredictedPowerLongTermDataJob
# redis
......
D03-deploy/deploy-pps-task/src/main/java/app/DeployPpsTaskApplication.java
View file @ 7aa5f644
......@@ -32,12 +32,6 @@ public class DeployPpsTaskApplication {
startup.enable(XJobFeature.class).config(new XJobServiceConf(DailyElectricityTrendJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherReceiveJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WeatherApiReceiveJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(WellTechDailyJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdActivePowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdCurrentWellConditionJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdPhotovoltaicPowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdWellAvgActivePowerJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(ThirdDailyAccumulationJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(EnergyConsumptionAnalysisJob.class));
startup.enable(XJobFeature.class).config(new XJobServiceConf(PlantPredictedPowerLongTermDataJob.class));
startup.enable(XRpcFeature.class);
......
D03-deploy/deploy-pps-task/src/main/resources/deploy-pps-task.app.properties
View file @ 7aa5f644
......@@ -8,12 +8,6 @@ x.job.service=pps.core.task.job.SpaceOptimizeLongJob,\
pps.core.task.job.DailyElectricityTrendJob,\
pps.core.task.job.WeatherReceiveJob,\
pps.core.task.job.WeatherApiReceiveJob,\
pps.core.task.job.WellTechDailyJob,\
pps.core.task.job.ThirdActivePowerJob,\
pps.core.task.job.ThirdCurrentWellConditionJob,\
pps.core.task.job.ThirdPhotovoltaicPowerJob,\
pps.core.task.job.ThirdWellAvgActivePowerJob,\
pps.core.task.job.ThirdDailyAccumulationJob,\
pps.core.task.job.EnergyConsumptionAnalysisJob,\
pps.core.task.job.PlantPredictedPowerLongTermDataJob
x.log.level=@x.log.level@
......
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