package com.yeshi.buwan.job.video;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.buwan.videos.acFun.AcFunUtil;
|
import com.yeshi.buwan.videos.acFun.AcfunVideoNew;
|
import com.yeshi.buwan.videos.acFun.AcfunVideoResult;
|
import com.yeshi.buwan.service.imp.juhe.AcfunVideoNewService;
|
import com.yeshi.buwan.util.video.AcfunApiUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
|
@Component
|
public class AcfunVideoUpdate {
|
|
private final static Logger logger = LoggerFactory.getLogger(AcfunVideoUpdate.class);
|
|
@Resource
|
private AcfunVideoNewService acfunVideoNewService;
|
|
@Resource
|
private AcFunUtil acFunUtil;
|
|
|
/**
|
* 更新最近几天的视频
|
*
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@XxlJob("video-update-acfun-updateLatestVideo")
|
public ReturnT<String> updateLatestVideo(String param) throws Exception {
|
AcfunVideoResult result = AcfunApiUtil.videoList("");
|
while (result != null && result.pcursor != null && !result.pcursor.equalsIgnoreCase("no_more")) {
|
if (result.videoList != null) {
|
acfunVideoNewService.save(result.videoList);
|
for (AcfunVideoNew video : result.videoList)
|
try {
|
acFunUtil.addVideo(video);
|
} catch (Exception e) {
|
}
|
}
|
result = AcfunApiUtil.videoList(result.pcursor);
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
|
}
|
