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);
	}
}