package com.qianwen.smartman.modules.dmpLog.jobHandler;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.xxl.job.core.log.XxlJobLogger;
|
import java.time.LocalDate;
|
import java.time.format.DateTimeFormatter;
|
import java.util.List;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import com.qianwen.core.tool.utils.Func;
|
import com.qianwen.smartman.modules.cps.mapper.TdengineMapper;
|
import com.qianwen.smartman.modules.dmpLog.constant.DmpLogSyncConstant;
|
import com.qianwen.smartman.modules.dmpLog.mapper.DmpLogSignalMapper;
|
import org.springframework.stereotype.Component;
|
|
@Component
|
/* loaded from: blade-api.jar:BOOT-INF/classes/org/springblade/modules/dmpLog/jobHandler/DmpLogRegularCleanJob.class */
|
public class DmpLogRegularCleanJob {
|
private static final Logger log = LoggerFactory.getLogger(DmpLogRegularCleanJob.class);
|
private final TdengineMapper tdengineMapper;
|
private final DmpLogSignalMapper dmpLogSignalMapper;
|
|
public DmpLogRegularCleanJob(final TdengineMapper tdengineMapper, final DmpLogSignalMapper dmpLogSignalMapper) {
|
this.tdengineMapper = tdengineMapper;
|
this.dmpLogSignalMapper = dmpLogSignalMapper;
|
}
|
|
@XxlJob("dmpLogRegularCleanJobHandler")
|
public ReturnT<String> dmpLogRegularCleanJobHandler(String param) throws Exception {
|
XxlJobLogger.log("XXL-JOB, DMP日志定期清除任务.....开始", new Object[0]);
|
int delTableRange = 3;
|
if (Func.isNotEmpty(param)) {
|
delTableRange = Integer.valueOf(param).intValue();
|
}
|
LocalDate localDate = LocalDate.now().minusMonths(delTableRange);
|
DateTimeFormatter fmt = DateTimeFormatter.ofPattern("yyyyMM");
|
Integer rangeParam = Integer.valueOf(localDate.format(fmt));
|
List<String> allDeleteTables = this.dmpLogSignalMapper.getTableNamesByMonth(rangeParam);
|
if (Func.isNotEmpty(allDeleteTables)) {
|
allDeleteTables.forEach(tableName -> {
|
if (tableName.startsWith(DmpLogSyncConstant.DMP_TD_TABLE_PREFIX)) {
|
this.tdengineMapper.dropTable(tableName);
|
}
|
});
|
}
|
XxlJobLogger.log("XXL-JOB, DMP日志定期清除任务.....结束", new Object[0]);
|
return ReturnT.SUCCESS;
|
}
|
}
|
