package org.springblade.xxljob.jobhandler;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob;
import org.apache.logging.log4j.util.Strings;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springblade.modules.resource.service.IAttachDataService;
import org.springblade.modules.system.service.ILogService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

/**
 * 数据处理任务
 * @author zhongrj
 * @date 2024-05-25
 */
@Component
public class DataHandleJob {

	private static Logger logger = LoggerFactory.getLogger(LabelHandleJob.class);

	@Autowired
	private ILogService logService;

	@Autowired
	private IAttachDataService attachDataService;

	/**
	 * 清理时间范围外的日志记录信息
	 */
	@XxlJob("logJobHandler")
	public void logJobHandler (String param){
		XxlJobHelper.log("开始执行任务...清理时间范围外的日志记录信息");
		// 解析参数
		JSONObject jsonParam = JSON.parseObject(param);
//		String dayString = jsonParam.getString("day");
		// 开始执行
		boolean result = logService.removeLogs(param);
		XxlJobHelper.log("任务响应结果..." + result);
		// 结束
		XxlJobHelper.log("结束自动创建任务...");
	}

	/**
	 * 附件临时文件信息清理
	 */
	@XxlJob("attachDataJobHandler")
	public void attachDataJobHandler (String param){
		XxlJobHelper.log("开始执行任务...附件临时文件信息清理");
		// 开始执行
		boolean result = attachDataService.removeBladeAttachDatas(param);
		XxlJobHelper.log("任务响应结果..." + result);
		// 结束
		XxlJobHelper.log("结束自动创建任务...");
	}
}