package com.newvideo.job;

import java.util.List;

import javax.annotation.Resource;

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import com.newvideo.iqiyi.entity.IqiyiUpdateQueue;
import com.newvideo.iqiyi.util.IqiyiUtil;
import com.newvideo.service.imp.juhe.IqiyiQueueService;
import com.newvideo.util.Constant;
import com.newvideo.util.StringUtil;

/**
 * 
 * 
 * @author Administrator
 *
 */
@Component
public class VideoUpdateJob {
	@Resource
	private IqiyiUtil iqiyiUtil;

	@Resource
	private IqiyiQueueService iqiyiQueueService;

	@Scheduled(cron = "0 0 0,9,14,20 * * ?")
	public void doJob() {
		if (!Constant.JobTasker)
			return;
		System.out.println("VideoUpdateJob-doJob");
		new Thread(new Runnable() {

			public void run() {
				iqiyiUtil.updateAll("");
			}
		}).start();
	}

	@Scheduled(cron = "0 5 0,12,20 * * ? ")
	public void updateIqiyiQueue() {
		if (!Constant.JobTasker)
			return;
		synchronized (iqiyiQueueService) {
			List<IqiyiUpdateQueue> queueList = iqiyiQueueService.listUpdateQueue();
			for (IqiyiUpdateQueue queue : queueList) {
				String aid = null;
				int count = 0;
				while (StringUtil.isNullOrEmpty(aid) && count < 3) {
					if (StringUtil.isNullOrEmpty(queue.getAid())) {
						aid = IqiyiUtil.getAlbumIdFromPlayUrl(queue.getUrl());
						count++;
						try {
							Thread.sleep(1000 * 2);
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					} else
						aid = queue.getAid();
				}
				if (!StringUtil.isNullOrEmpty(aid)) {
					queue.setAid(aid);
					iqiyiQueueService.updateUpdateQueue(queue);
					iqiyiUtil.updateAlbum(aid);
				}
			}
		}
	}
}