SHZHJCYJPTYWXT/src/main/java/org/springblade/etl/EtlRegionDataTask.java

/**
 * Copyright
 * All right reserved.
 * 项目名称:
 * 创建日期:2022/5/22
 */
package org.springblade.etl;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.tool.utils.ConcurrentDateFormat;
import org.springblade.core.tool.utils.Func;
import org.springblade.etl.dto.EtlGroundDataDTO;
import org.springblade.etl.entity.EtlAdCdEntity;
import org.springblade.etl.entity.EtlGroundDataEntity;
import org.springblade.etl.service.IEtlAdCdService;
import org.springblade.modules.baseinfo.region.entity.RegionInfoEntity;
import org.springblade.modules.baseinfo.region.service.IBaseInfoRegionService;
import org.springblade.modules.business.data.entity.RtuDataGroundEntity;
import org.springblade.modules.system.service.IRegionService;
import org.springframework.data.redis.core.HashOperations;
import org.springframework.data.redis.core.RedisTemplate;

import java.util.Calendar;
import java.util.Date;
import java.util.List;
import java.util.concurrent.Callable;

/***
 * Date:2022/5/22
 * Title: 行政区划数据抽取
 * Description：
 * @author swp
 * @version 1.0
 * Remark：认为有必要的其他信息
 */
@Slf4j
public class EtlRegionDataTask implements Callable<Integer> {

	private RedisTemplate redisTemplate;
	private IEtlAdCdService etlAdCdService;
	private IBaseInfoRegionService regionService;


	EtlRegionDataTask(RedisTemplate redisTemplate, IEtlAdCdService etlAdCdService, IBaseInfoRegionService regionService) {
		this.redisTemplate = redisTemplate;
		this.etlAdCdService = etlAdCdService;
		this.regionService = regionService;
	}

	@Override
	public Integer call() {
		try {
			log.info("行政区划数据抽取开始**************");



		} catch (Exception e) {
			log.error("实时数据统计任务异常 {}", e.getMessage());
		}
		return 0;
	}
}