package org.sxkj.job.processor.attach;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.sxkj.resource.feign.IAttachClient;
import tech.powerjob.worker.core.processor.ProcessResult;
import tech.powerjob.worker.core.processor.TaskContext;
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
import tech.powerjob.worker.log.OmsLogger;

/**
 * @Description TODO 附件表相关定时器
 * @Author AIX
 * @Date 2025/7/5 16:25
 * @Version 1.0
 */
@Slf4j
@Component
public class AttachProcessor implements BasicProcessor {

	@Autowired
	private IAttachClient attachClient;

	@Override
	public ProcessResult process(TaskContext context) throws Exception {
		// 在线日志功能，可以直接在控制台查看任务日志，非常便捷
		OmsLogger omsLogger = context.getOmsLogger();
		omsLogger.info("定时器压缩昨日视频, 当前参数是：{}", context.getJobParams());

		JSONObject jsonObject = JSON.parseObject(context.getJobParams());

		// TaskContext为任务的上下文信息，包含了在控制台录入的任务元数据，常用字段为
		// jobParams（任务参数，在控制台录入），instanceParams（任务实例参数，通过 OpenAPI 触发的任务实例才可能存在该参数）

		// 进行实际处理...
		log.info("============== ProcessorDemo#process ==============");
		log.info("执行中...");
		// 异步调用
		attachClient.processingYesterdayVideo(jsonObject.getDate("startTime"), jsonObject.getDate("endTime"));

		log.info("============== ProcessorDemo#process ==============");

		// 返回结果，该结果会被持久化到数据库，在前端页面直接查看，极为方便
		return new ProcessResult(true, "执行成功");
	}

}