package org.sxkj.job.processor.odm;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.TypeReference;
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.sxkj.odm.feign.IOdmTaskInfoClient;
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
import tech.powerjob.worker.core.processor.TaskContext;
|
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
|
|
import java.util.Map;
|
|
/**
|
* 定时删除odm拼图任务（保留一个月内的30天）
|
*/
|
@Slf4j
|
@Component
|
public class DelRepOdmTaskByBefOneMon implements BasicProcessor {
|
|
@Autowired
|
private IOdmTaskInfoClient odmTaskInfoClient;
|
|
/**
|
* 定时删除odm拼图任务（保留一个月内的30天）
|
* @param taskContext
|
* @return
|
*/
|
@Override
|
public ProcessResult process(TaskContext taskContext){
|
String jobParams = taskContext.getJobParams();
|
log.info("收到任务信息：{}",jobParams);
|
// 解析为 Map 或自定义对象 使用 FastJSON（PowerJob 内置）
|
Map<String, Object> params = JSON.parseObject(jobParams, new TypeReference<Map<String, Object>>() {});
|
// 获取参数
|
Integer day = Integer.parseInt(params.get("day").toString());
|
// 开始发送请求
|
log.info("收到任务参数 day: {}，开始执行请求...",day);
|
boolean flag = odmTaskInfoClient.delRepOdmTaskByBefOneMon(day);
|
// 返回结果
|
return new ProcessResult(true,"本次定时定时删除odm拼图任务（保留一个月内的30天）按天来" + flag);
|
}
|
}
|
