package com.yeshi.buwan.job;
|
|
import com.google.gson.Gson;
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.buwan.service.inter.system.SystemConfigService;
|
import com.yeshi.buwan.util.rank.IqiyiRankUtil;
|
import com.yeshi.buwan.util.rank.TencentRankUtil;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.Map;
|
|
//10409568
|
@Component
|
public class RankJob {
|
|
|
@Resource
|
private SystemConfigService systemConfigService;
|
|
|
//爱奇艺排行
|
@XxlJob("rank-iqiyi-update")
|
public ReturnT<String> updateIqiyiRank(String params) throws Exception {
|
Map<String, List<String>> map = IqiyiRankUtil.getRank(10);
|
Map<String, List<String>> tencentMap = TencentRankUtil.getRank(10);
|
if(tencentMap.get("总榜单")!=null) {
|
map.put("热搜", tencentMap.get("总榜单"));
|
}
|
map.put("动漫", tencentMap.get("动漫"));
|
if (map != null && map.size() > 0) {
|
String json = new Gson().toJson(map);
|
systemConfigService.setValue("searchRank", json);
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
|
//爱奇艺排行
|
@XxlJob("rank-tencent-update")
|
public ReturnT<String> updateTencentRank(String params) throws Exception {
|
Map<String, List<String>> map = TencentRankUtil.getRank(10);
|
if (map != null && map.size() > 0) {
|
String json = new Gson().toJson(map);
|
systemConfigService.setValue("searchRank", json);
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
|
}
|
