package com.yami.trading.huobi.data.job;
|
|
import com.yami.trading.bean.data.domain.Kline;
|
import com.yami.trading.bean.data.domain.Realtime;
|
import com.yami.trading.bean.item.domain.Item;
|
import com.yami.trading.common.util.MarketOpenChecker;
|
import com.yami.trading.common.util.ThreadUtils;
|
import com.yami.trading.common.util.UTCDateUtils;
|
import com.yami.trading.huobi.data.DataCache;
|
import com.yami.trading.huobi.data.internal.DataDBService;
|
import com.yami.trading.huobi.data.internal.KlineService;
|
import com.yami.trading.service.data.KlineDBService;
|
import com.yami.trading.service.item.ItemService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.TimeZone;
|
|
@Component
|
public class CleanDataJob {
|
|
private static Logger logger = LoggerFactory.getLogger(CleanDataJob.class);
|
@Autowired
|
private DataDBService dataDBService;
|
@Autowired
|
private ItemService itemService;
|
@Autowired
|
private KlineService klineService;
|
|
@Scheduled(cron = "0 0 4 * * ?")
|
public void taskJob() {
|
klineService.clean();
|
}
|
|
}
|
