soc/soc-modules/soc-modules-job/src/main/java/com/xunmei/job/task/WeatherTask.java

package com.xunmei.job.task;


import cn.hutool.core.lang.UUID;
import com.alibaba.fastjson.JSON;
import com.xunmei.common.core.constant.SecurityConstants;
import com.xunmei.common.core.web.domain.AjaxResult;
import com.xunmei.system.api.RemoteRetrievalTaskService;
import com.xunmei.system.api.RemoteWeatherTaskService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.time.LocalDate;
import java.util.Date;

/**
 * 监控调阅定时任务
 *
 * @author xunmei
 */
@Slf4j
@Component("WeatherTask")
public class WeatherTask {
    @Resource
    private RemoteWeatherTaskService remoteWeatherTaskService;

    /**
     * 每天定时获取天气预警数据
     */
    public void getDataFromApi()
    {   String id = UUID.fastUUID().toString();
        log.info("开始执行获取天气预警数据的任务，当前任务 id:{},当前时间:{}", id, new Date());
        AjaxResult result = remoteWeatherTaskService.getDataFromApi( SecurityConstants.INNER);
        log.info("获取天气预警数据的任务执行结束，当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
    }

    /**
     * 每天定时获取天气预警数据
     */
    public void getDataFromAliyun()
    {   String id = UUID.fastUUID().toString();
        log.info("开始执行获取天气预警数据的任务，当前任务 id:{},当前时间:{}", id, new Date());
        AjaxResult result = remoteWeatherTaskService.getDataFromAliyun( SecurityConstants.INNER);
        log.info("获取天气预警数据的任务执行结束，当前任务 id:{},当前时间:{},结果:{}", id, new Date(), JSON.toJSONString(result));
    }
}