package org.sxkj.odm.service.impl;


import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
import org.sxkj.odm.service.IOdmTaskInfoService;

import javax.annotation.PostConstruct;

/**
 * odm 异步调用服务
 * @author zhongrj
 */
@Slf4j
@Component
public class AsyncOdmTaskService {

	@Autowired
	private IOdmTaskInfoService odmTaskInfoService;

	@PostConstruct
	public void init() {
		log.info("依赖注入检查: odmTaskInfoService={}", odmTaskInfoService.getClass());
	}

	/**
	 * 异步调用 补漏 odm 任务生成
	 */
	@Async("odmTaskExecutor")
    public void leakRepairOdmTask(){
		odmTaskInfoService.leakRepairOdmTask();
	}

	/**
	 * 保存 odm 任务信息
	 * @param jobId  航测任务job_id
	 * @return
	 */
	@Async("odmTaskExecutor")
	public void saveOdmTaskInfo(String jobId) {
		odmTaskInfoService.saveOdmTaskInfo(jobId);
	}
}