| | |
| | | |
| | | import com.xxl.job.core.biz.model.ReturnT; |
| | | import com.xxl.job.core.handler.annotation.XxlJob; |
| | | import com.yeshi.buwan.funtv.FunTVNewApi; |
| | | import com.yeshi.buwan.funtv.entity.FunTVAlbum2; |
| | | import com.yeshi.buwan.funtv.entity.FunTVShortVideo2; |
| | | import com.yeshi.buwan.funtv.entity.FunTVVideo2; |
| | | import com.yeshi.buwan.pptv.PPTVApiUtil; |
| | | import com.yeshi.buwan.pptv.entity.PPTVSeries; |
| | | import com.yeshi.buwan.service.inter.juhe.FunTV2Service; |
| | | import com.yeshi.buwan.dao.juhe.pptv.PPTVSeriesDao; |
| | | import com.yeshi.buwan.dao.juhe.pptv.VideoPPTVMapDao; |
| | | import com.yeshi.buwan.videos.pptv.PPTVApiUtil; |
| | | import com.yeshi.buwan.videos.pptv.entity.PPTVSeries; |
| | | import com.yeshi.buwan.videos.pptv.entity.VideoPPTVMap; |
| | | import com.yeshi.buwan.service.inter.juhe.PPTVService; |
| | | import com.yeshi.buwan.util.StringUtil; |
| | | import com.yeshi.buwan.util.mq.CMQManager; |
| | | import com.yeshi.buwan.vo.video.funtv.Funtv2ResultVO; |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.annotation.Resource; |
| | | import java.io.Serializable; |
| | | import java.util.ArrayList; |
| | | import java.util.List; |
| | | |
| | | @Component |
| | |
| | | |
| | | @Resource |
| | | private PPTVService pptvService; |
| | | |
| | | @Resource |
| | | private PPTVSeriesDao pptvSeriesDao; |
| | | |
| | | @Resource |
| | | private VideoPPTVMapDao videoPPTVMapDao; |
| | | |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | |
| | | @XxlJob("video-update-pptv-syncVideo") |
| | | public ReturnT<String> syncVideo(String param) throws Exception { |
| | | List<PPTVSeries> list = pptvSeriesDao.list(0, 10000); |
| | | for (PPTVSeries s : list) { |
| | | if (s != null) { |
| | | switch (s.getStatus()) { |
| | | case "add": |
| | | case "update": |
| | | List<VideoPPTVMap> mapList = videoPPTVMapDao.listByInfoId(s.getInfoID()); |
| | | if (mapList == null || mapList.size() == 0) { |
| | | PPTVSeries series = PPTVApiUtil.getDetail(s.getSeriesCode()); |
| | | pptvService.save(series); |
| | | Thread.sleep(1000); |
| | | System.out.println(s.getName()); |
| | | series = pptvService.getSeriesDetail(s.getInfoID()); |
| | | if (series != null) |
| | | pptvService.addToVideoInfo(series); |
| | | } |
| | | break; |
| | | } |
| | | } |
| | | } |
| | | return ReturnT.SUCCESS; |
| | | } |
| | | |
| | | } |