package com.yeshi.buwan.controller.parser; import com.google.gson.Gson; import com.yeshi.buwan.domain.*; import com.yeshi.buwan.domain.entity.PlayUrl; import com.yeshi.buwan.domain.recommend.HomeRecommendSpecial; import com.yeshi.buwan.domain.solr.SolrShortVideo; import com.yeshi.buwan.domain.special.SearchSpecialPositionMap; import com.yeshi.buwan.domain.system.DetailSystem; import com.yeshi.buwan.domain.system.DetailSystemConfig; import com.yeshi.buwan.domain.video.InternetSearchVideo; import com.yeshi.buwan.domain.video.VideoWatchHistory; import com.yeshi.buwan.dto.log.BaseLog; import com.yeshi.buwan.dto.statistic.video.VideoDetailStatisticData; import com.yeshi.buwan.exception.video.VideoPlayException; import com.yeshi.buwan.videos.mogotv.MogoTVUtil; import com.yeshi.buwan.videos.pptv.PPTVApiUtil; import com.yeshi.buwan.videos.pptv.PPTVUtil; import com.yeshi.buwan.videos.pptv.entity.PPTVProgram; import com.yeshi.buwan.videos.pptv.entity.PPTVSeries; import com.yeshi.buwan.videos.pptv.entity.VideoPPTVMap; import com.yeshi.buwan.service.imp.*; import com.yeshi.buwan.service.inter.ad.DeviceAdStrategyService; import com.yeshi.buwan.service.inter.juhe.InternetSearchVideoService; import com.yeshi.buwan.service.inter.juhe.PPTVService; import com.yeshi.buwan.service.inter.recommend.HomeRecommendSpecialService; import com.yeshi.buwan.service.inter.recommend.HomeVideoService; import com.yeshi.buwan.service.inter.search.SearchSpecialPositionMapService; import com.yeshi.buwan.service.inter.video.VideoWatchHistoryService; import com.yeshi.buwan.service.manager.VideoPlayStatisticManager; import com.yeshi.buwan.service.manager.search.SolrShortVideoDataManager; import com.yeshi.buwan.videos.tencent.TencentVideoUtil; import com.yeshi.buwan.util.*; import com.yeshi.buwan.util.JuHe.VideoResourceUtil; import com.yeshi.buwan.util.annotation.RequireUid; import com.yeshi.buwan.util.factory.VideoInfoFactory; import com.yeshi.buwan.util.log.LoggerUtil; import com.yeshi.buwan.util.log.UserActiveLogFactory; import com.yeshi.buwan.util.log.VideoLogFactory; import com.yeshi.buwan.util.mq.CMQManager; import com.yeshi.buwan.util.video.VideoDetailUtil; import com.yeshi.buwan.util.video.VideoUtil; import com.yeshi.buwan.util.zhibo.MeiNvZhiBoUtil; import com.yeshi.buwan.videos.bilibili.BilibiliUtil; import com.yeshi.buwan.vo.AcceptData; import com.yeshi.buwan.vo.video.VideoDetailVO; import com.yeshi.buwan.videos.youku.YouKuUtil; import net.sf.json.JSONArray; import net.sf.json.JSONObject; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.HttpException; import org.apache.commons.httpclient.methods.GetMethod; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Controller; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.io.IOException; import java.io.PrintWriter; import java.util.*; @Controller public class HomeParser { private Logger logger = LoggerFactory.getLogger(HomeParser.class); @Resource private SystemService systemService; @Resource private HomeAdService homeAdService; @Resource private HomeTypeService homeTypeService; @Resource private HomeVideoService homeVideoService; @Resource private DetailSystemConfigService configService; @Resource private AdService adService; @Resource private VideoDetailUtil videoDeailUtil; @Resource private CommentService commentService; @Resource private CollectionService collectionService; @Resource private UserService userService; @Resource private VideoResourceUtil videoResouceUtil; @Resource private MeiNvZhiBoUtil meiNvZhiBoUtil; @Resource private AttentionService attentionService; @Resource private ClassService classService; @Resource private ClassParser classParser; @Resource private VideoDetailUtil videoDetailUtil; @Resource private ResourceVideoService resourceVideoService; @Resource private PPTVService pptvService; @Resource private VideoWatchHistoryService videoWatchHistoryService; @Resource private HomeRecommendSpecialService homeRecommendSpecialService; @Resource private DeviceAdStrategyService deviceAdStrategyService; private final Logger userPlayLogger = LoggerFactory.getLogger("videoPlayUser"); @RequireUid public void getHomeAd(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String vtid = request.getParameter("Vtid"); HomeRecommendSpecial special = homeRecommendSpecialService.getSpecial(vtid); //兼容新版本 if (special != null) { JSONObject object = new JSONObject(); DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); List list = homeAdService.getHomeAdList(detailSystem, special != null ? special.getDataKey() : null); if (acceptData.getPlatform().equalsIgnoreCase("ios"))// IOS测试 { if (acceptData.getVersion() > 1)// 高版本 { for (HomeAd ad : list) { if (!StringUtil.isNullOrEmpty(ad.getParams())) { ad.setParams(ad.getParams().replace("\"", "\\" + "\"")); } } } else// 低版本 { for (int i = 0; i < list.size() && i > -1; i++) if (list.get(i).getLinkType() != 1) { list.remove(i); i--; } } object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); JSONArray array = new JSONArray(); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); } else { for (HomeAd ad : list) { if (ad.getVideo() != null) { ad.getVideo().setIntroduction(""); ad.getVideo().setMainActor(""); } if (!StringUtil.isNullOrEmpty(ad.getParams())) { ad.setParams(ad.getParams().replace("\"", "\\" + "\"")); } } object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); JSONArray array = new JSONArray(); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); } object.put("bannerSizeRate", special.getBannerSizeRate()); out.print(JsonUtil.loadTrueJson(object.toString())); } else { classParser.getRecommendCategoryVideoBanner(acceptData, request, out); } } // 首页类型获取 public void getHomeType(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { System.out.println("getHomeType开始请求"); String channel = request.getParameter("Channel"); // 20170914 一级视频分类ID String vtid = request.getParameter("Vtid"); if (StringUtil.isNullOrEmpty(vtid)) { vtid = "309"; // 为了兼容以前的推荐 } HomeRecommendSpecial special = homeRecommendSpecialService.getSpecial(vtid); DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); JSONObject object = new JSONObject(); List resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); List list1 = homeTypeService.getHomeType(detailSystem.getId(), acceptData.getPlatform(), acceptData.getVersion(), resourceList, CacheUtil.getMD5Long(resourceList), -1, special != null ? special.getDataKey() : null); List list = new ArrayList<>(); for (HomeType ht : list1) list.add(ht); if ("309" .equals(vtid)) { if (!"ios" .equalsIgnoreCase(acceptData.getPlatform())) { Map confMap = configService.getConfigAsMap(acceptData.getChildDetailSystem(), acceptData.getVersion()); String mm = confMap.get("meinv_mm_count"); int count = Integer.parseInt(mm); if (count > 0) { try { HomeType zhibo = new HomeType(); zhibo.setId("1111"); zhibo.setName("美女"); zhibo.setHasMore(true); zhibo.setColumns(2); zhibo.setHomeVideoList(meiNvZhiBoUtil.getMeiNvZhiBo(MeiNvZhiBoUtil.MEINV_KK, detailSystem, acceptData.getVersion())); List zhiboVideo = new ArrayList(); for (HomeVideo v : zhibo.getHomeVideoList()) zhiboVideo.add(v.getVideo()); zhibo.setVideoList(zhiboVideo); if (zhibo.getHomeVideoList() != null && zhibo.getHomeVideoList().size() > 0) { int po = Integer.parseInt(confMap.get("zhibo_position"));// 直播数量 if (po < 0) po = 0; if (po > list.size()) po = list.size(); list.add(po, zhibo); } } catch (Exception e) { e.printStackTrace(); } } if (VersionUtil.isGraterThan387(acceptData.getPlatform(), acceptData.getVersion())) { DetailSystemConfig adContent = configService.getConfigByKey("home_banner_ad_content", acceptData.getChildDetailSystem(), acceptData.getVersion()); DetailSystemConfig adPosition = configService.getConfigByKey("home_banner_ad_position", acceptData.getChildDetailSystem(), acceptData.getVersion()); if (adContent != null && adPosition != null) { HomeType.HomeTypeAd ad = new Gson().fromJson(adContent.getValue(), HomeType.HomeTypeAd.class); int adP = Integer.parseInt(adPosition.getValue()); if (adP < list.size() && adP > -1) { HomeType homeType = new HomeType(); homeType.setAd(ad); list.add(adP, homeType); } } } } if (acceptData.getPlatform().equalsIgnoreCase("ios")) { for (HomeType ht : list) { if (ht.getName().contains("福利")) { ht.setActivity("MoreAndMoreViewController"); } else { ht.setActivity("ClassDetailsViewController"); } } JSONArray array = new JSONArray(); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); object.put("count", list.size() + ""); } } if ("huawei" .equalsIgnoreCase(channel)) { for (int i = 0; i < list.size(); i++) { if (list.get(i).getName().equalsIgnoreCase("美女")) { list.remove(i); break; } } } object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); JSONArray array = new JSONArray(); for (HomeType ht : list) { if (ht.getHomeVideoList() != null) for (int i = 0; i < ht.getHomeVideoList().size(); i++) { //改变图片 if (JuheVideoUtil.isNeedDelete(ht.getHomeVideoList().get(i).getVideo(), detailSystem.getId())) { ht.getHomeVideoList().remove(i); i--; } } } for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); out.print(JsonUtil.loadTrueJson(object.toString())); } // 首页类型获取 public void getHomeTypeNew(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { // 20170914 一级视频分类ID String page = request.getParameter("Page"); String pageSize = request.getParameter("PageSize"); String dataKey = request.getParameter("DataKey"); long count = homeTypeService.countHomeType(acceptData.getDetailSystem().getId(), acceptData.getVersion(), dataKey); List resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); List homeTypeList = homeTypeService.getHomeTypeList(acceptData.getDetailSystem().getId(), acceptData.getVersion(), dataKey, Integer.parseInt(page), Integer.parseInt(pageSize)); if (homeTypeList != null) for (HomeType homeType : homeTypeList) { String resourceKey = StringUtil.Md5(org.yeshi.utils.StringUtil.concat(resourceList, ",")); long bigPictureCount = homeType.isBigPicture() ? 1 : 0;// homeTypeService.getHomeVideoListCount(homeType.getId(), resourceKey, resourceList, true); List homeVideoList = homeVideoService.getHomeVideoList(homeType.getId(), resourceKey, resourceList, null, 1, homeType.getNumber() + (int) bigPictureCount); if (bigPictureCount > 0 && homeVideoList.size() > 0) { homeVideoList.get(0).setBigPicture(true); } long videoCount = homeVideoService.getHomeVideoListCount(homeType.getId(), resourceKey, resourceList, null); if (videoCount - bigPictureCount > homeType.getNumber()) { while ((videoCount - bigPictureCount) % homeType.getNumber() != 0) { videoCount--; } } homeType.setCount((int) videoCount); List tempHomeVideoList = new ArrayList<>(); tempHomeVideoList.addAll(homeVideoList); while (tempHomeVideoList != null && tempHomeVideoList.size() > 0 && (tempHomeVideoList.size() - bigPictureCount) % homeType.getColumns() != 0 && homeType.getColumns() < 4) tempHomeVideoList.remove(tempHomeVideoList.size() - 1); homeType.setHomeVideoList(tempHomeVideoList); } try { if (VersionUtil.isGraterThan387(acceptData.getPlatform(), acceptData.getVersion()) && dataKey.equalsIgnoreCase("recommend")) { DetailSystemConfig adContent = configService.getConfigByKey("home_banner_ad_content", acceptData.getChildDetailSystem(), acceptData.getVersion()); DetailSystemConfig adPosition = configService.getConfigByKey("home_banner_ad_position", acceptData.getChildDetailSystem(), acceptData.getVersion()); if (adContent != null && adPosition != null) { HomeType.HomeTypeAd ad = new Gson().fromJson(adContent.getValue(), HomeType.HomeTypeAd.class); int adP = Integer.parseInt(adPosition.getValue()); if (adP < homeTypeList.size() && adP > -1) { HomeType homeType = new HomeType(); homeType.setAd(ad); if ("1" .equalsIgnoreCase(page)) { homeTypeList.add(adP, homeType); } count++; } } } } catch (Exception e) { } JSONObject object = new JSONObject(); JSONArray array = new JSONArray(); for (int i = 0; i < homeTypeList.size(); i++) array.add(StringUtil.outPutResultJson(homeTypeList.get(i))); object.put("data", array); object.put("count", count + ""); out.print(JsonUtil.loadTrueJson(object.toString())); } public HomeType convertHomeVideoList(HomeType type) { List vlist = new ArrayList(); List list = type.getHomeVideoList(); if (list != null) for (HomeVideo hv : list) { vlist.add(hv.getVideo()); } type.setVideoList(vlist); return type; } // 首页类型获取 public void getHomeVideoList(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { // 20170914 一级视频分类ID String homeTypeId = request.getParameter("Id"); int page = Integer.parseInt(request.getParameter("Page")); if (StringUtil.isNullOrEmpty(homeTypeId)) { out.print(JsonUtil.loadFalseJson("")); return; } HomeType homeType = homeTypeService.getHomeTypeById(homeTypeId); if (homeType == null) { out.print(JsonUtil.loadFalseJson("")); return; } List resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); //查询大图 List bigPictureVideos = new ArrayList<>(); if (homeType.isBigPicture()) { bigPictureVideos = homeVideoService.getHomeVideoList(homeTypeId, org.yeshi.utils.StringUtil.concat(resourceList, ","), resourceList, null, 1, 1); if (bigPictureVideos != null && bigPictureVideos.size() > 0) bigPictureVideos.get(0).setBigPicture(true); } //大图需要每次都返回 JSONObject object = new JSONObject(); String resourceKey = StringUtil.Md5(org.yeshi.utils.StringUtil.concat(resourceList, ",")); Long count = homeVideoService.getHomeVideoListCount(homeTypeId, resourceKey, resourceList, null); if (count - bigPictureVideos.size() > homeType.getNumber()) { while ((count - bigPictureVideos.size()) % homeType.getNumber() != 0) { count--; } } List list1 = homeVideoService.getHomeVideoList(homeTypeId, resourceKey, resourceList, homeType.isBigPicture(), page, homeType.getNumber()); List list = new ArrayList<>(); list.addAll(bigPictureVideos); list.addAll(list1); JSONObject data = new JSONObject(); object.put("count", count); JSONArray array = new JSONArray(); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("list", array); //判断是否还有下一页 int totalPage = (int) ((count - bigPictureVideos.size()) % homeType.getNumber() == 0 ? (count - bigPictureVideos.size()) / homeType.getNumber() : (count - bigPictureVideos.size()) / homeType.getNumber() + 1); if (page >= totalPage) { page = 0; } object.put("page", page); out.print(JsonUtil.loadTrueJson(object.toString())); } @RequireUid public void getMoreVideo(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String type = request.getParameter("Type"); String page = request.getParameter("Page"); if (StringUtil.isNullOrEmpty(page)) { out.print(JsonUtil.loadFalseJson("请上传Page")); return; } int pageIndex = 0; try { pageIndex = Integer.parseInt(page); } catch (Exception e) { out.print(JsonUtil.loadFalseJson("Page\u683C\u5F0F\u6709\u8BEF")); return; } DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); UserInfo user = userService.getUserInfo(acceptData.getUid()); if (Utils.isTest(request, user, detailSystem.getId())) detailSystem = systemService.getDetailSystemById(40 + ""); List homeVideoList = homeTypeService.getVideoByTypes(type, pageIndex, detailSystem); List list = new ArrayList<>(); for (int i = 0; i < homeVideoList.size(); i++) { HomeVideo hv = (HomeVideo) homeVideoList.get(i); if (acceptData.getPackageName().contains("doudou")) { if (!StringUtil.isNullOrEmpty(hv.getPicture())) hv.getVideo().setPicture(hv.getPicture()); } list.add(hv.getVideo()); } JSONObject object = new JSONObject(); object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); JSONArray array = new JSONArray(); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); object.put("Column", 2); out.print(JsonUtil.loadTrueJson(object.toString())); } public void getAdList(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); List list = adService.getRecommendAdList(detailSystem.getId()); if (list == null) list = new ArrayList(); JSONObject object = new JSONObject(); JSONArray array = new JSONArray(); object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); for (int i = 0; i < list.size(); i++) array.add(StringUtil.outPutResultJson(list.get(i))); object.put("data", array); out.print(JsonUtil.loadTrueJson(object.toString())); } @Resource private InternetSearchVideoService internetSearchVideoService; @Resource private YouKuUtil youKuUtil; @Resource private MogoTVUtil mogoTVUtil; @Resource private TencentVideoUtil tencentVideoUtil; @Resource private BilibiliUtil bilibiliUtil; @Resource private VideoPlayStatisticManager videoPlayStatisticManager; @Resource private VideoResourceService videoResourceService; private String createVideoDetailSessionId(AcceptData acceptData, String uid, String videoName, String videoId, String resourceId) { try { VideoDetailStatisticData data = new VideoDetailStatisticData(); data.setDetailSystemId(acceptData.getDetailSystem().getId()); data.setLoginUid(uid); data.setResourceId(Integer.parseInt(resourceId)); data.setUtdId(acceptData.getUtdId()); data.setVersion(acceptData.getVersion()); data.setVideoId(videoId); data.setVideoName(videoName); return videoPlayStatisticManager.createVideoDetailSessionId(data); } catch (Exception e) { } return null; } @Resource private SolrShortVideoDataManager solrShortVideoDataManager; public void getVideoDetailForShortVideo(AcceptData acceptData, String videoId, HttpServletRequest request, PrintWriter out) { String loginUid = request.getParameter("LoginUid"); SolrShortVideo solrShortVideo = solrShortVideoDataManager.findOne(videoId); String resourceId = solrShortVideo.getResourceId() + ""; VideoResource videoResource = videoResourceService.getResource(resourceId); videoResource.setChecked(true); VideoInfo info = VideoInfoFactory.create(solrShortVideo); info.setResourceList(Arrays.asList(new VideoResource[]{videoResource})); if (info != null) info.setPageSize(1); info.setWatchCount("" + (int) (Math.random() * 1000)); info.setPlayPicture(info.getPicture()); JSONArray array = new JSONArray(); JSONObject obj = new JSONObject(); out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(Utils.convertVideo(info)), array.toString(), obj.toString())); // out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(new VideoDetailVO(Utils.convertVideo(info), deviceAdStrategyService.getVideoDetailAdStrategy(acceptData.getUtdId(), acceptData.getDetailSystem().getId(), loginUid), null, createVideoDetailSessionId(acceptData, loginUid, info.getName(), videoId, resourceId))), array.toString(), // obj.toString())); } public void getVideoDetailForInternetSearch(AcceptData acceptData, String videoId, HttpServletRequest request, PrintWriter out) { String loginUid = request.getParameter("LoginUid"); String from = request.getParameter("From"); InternetSearchVideo internetSearchVideo = internetSearchVideoService.selectByPrimaryKey(videoId); String resourceId = request.getParameter("ResourceId"); String position = request.getParameter("Position"); int pageSize = 100; if (!StringUtil.isNullOrEmpty(position)) { if (VersionUtil.isGraterThan391(acceptData.getPlatform(), acceptData.getVersion())) pageSize = (Integer.parseInt(position) / 100 + 1) * 100; } if (StringUtil.isNullOrEmpty(resourceId)) { resourceId = internetSearchVideo.getResourceIds().split(",")[0]; } List resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); if (resourceList != null) { if (!resourceList.contains(Long.parseLong(resourceId))) { out.print(JsonUtil.loadFalseAdmin("")); return; } } VideoInfo info = null; if (Integer.parseInt(resourceId) == YouKuUtil.RESOURCE_ID) { try { info = youKuUtil.getVideoInfo(internetSearchVideo, pageSize); } catch (Exception e) { logger.error("全网搜视频详情出错:" + videoId); e.printStackTrace(); out.print(JsonUtil.loadFalseAdmin(e.getMessage())); return; } } else if (Integer.parseInt(resourceId) == MogoTVUtil.RESOURCE_ID) { try { info = mogoTVUtil.getVideoInfo(internetSearchVideo, pageSize); } catch (Exception e) { logger.error("全网搜视频详情出错:" + videoId); out.print(JsonUtil.loadFalseAdmin(e.getMessage())); return; } } else if (Integer.parseInt(resourceId) == TencentVideoUtil.RESOURCE_ID) { try { info = tencentVideoUtil.getVideoInfo(internetSearchVideo, pageSize); } catch (Exception e) { logger.error("全网搜视频详情出错:" + videoId); out.print(JsonUtil.loadFalseAdmin(e.getMessage())); return; } } else if (Integer.parseInt(resourceId) == BilibiliUtil.RESOURCE_ID) { try { info = bilibiliUtil.getVideoInfo(internetSearchVideo, pageSize); } catch (Exception e) { logger.error("全网搜视频详情出错:" + videoId); out.print(JsonUtil.loadFalseAdmin(e.getMessage())); return; } } if (info != null) info.setPageSize(pageSize); LoggerUtil.getUserActiveLogger().info(UserActiveLogFactory.createVideoDetail(new BaseLog(acceptData, loginUid), videoId, info.getName(), from)); info.setWatchCount("" + (int) (Math.random() * 1000)); JSONArray array = new JSONArray(); JSONObject obj = new JSONObject(); if (VersionUtil.isGraterThan390(acceptData.getPlatform(), acceptData.getVersion())) { out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(new VideoDetailVO(Utils.convertVideo(info), deviceAdStrategyService.getVideoDetailAdStrategy(acceptData.getUtdId(), acceptData.getDetailSystem().getId(), acceptData.getVersion(), acceptData.getChannel(), loginUid), null, createVideoDetailSessionId(acceptData, loginUid, info.getName(), videoId, resourceId))), array.toString(), obj.toString())); } else { out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(Utils.convertVideo(info)), array.toString(), obj.toString())); } } @RequireUid public void getVideoDetail(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String videoId = request.getParameter("VideoId"); if (!NumberUtil.isNumeric(videoId)) { String[] cidVid = PPTVUtil.parseCidAndVidFromVisualVideoId(videoId); if (cidVid == null) { int fromType = VideoUtil.getVideoFromType(videoId); //短视频 if (fromType == HomeVideo.FROM_TYPE_SHORT) { getVideoDetailForShortVideo(acceptData, videoId, request, out); return; } else if (fromType == HomeVideo.FROM_TYPE_INTERNET) { getVideoDetailForInternetSearch(acceptData, videoId, request, out); return; } } String cid = cidVid[0]; String vid = cidVid[1]; PPTVSeries series = pptvService.getSeriesDetail(cid); if (series == null) { series = PPTVApiUtil.getDetail(cid); } if (series != null) { JSONObject data = new JSONObject(); String playUrl = PPTVUtil.getPlayUrl(series, pptvService.selectProgramById(vid)); data.put("videoId", videoId); data.put("playUrl", playUrl); data.put("name", series.getName()); data.put("pptv", true); data.put("vip", PPTVUtil.isVIPVideo(series.getFree())); out.print(JsonUtil.loadTrueJson(data.toString())); } else { out.print(JsonUtil.loadFalseJson("已下线")); } return; } String resourceId = request.getParameter("ResourceId"); String thirdType = request.getParameter("Type"); String loginUid = request.getParameter("LoginUid"); String position = request.getParameter("Position"); String from = request.getParameter("From"); if (StringUtil.isNullOrEmpty(videoId)) { out.print(JsonUtil.loadFalseJson("请上传VideoId")); return; } if (StringUtil.isNullOrEmpty(thirdType)) { out.print(JsonUtil.loadFalseJson("请上传Type")); return; } DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); List resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); //获取优先展示的渠道 if (StringUtil.isNullOrEmpty(resourceId)) { Set rids = new HashSet<>(); rids.addAll(resourceList); VideoResource defaultVideoResource = resourceVideoService.getDefaultVideoResource(videoId, rids); if (defaultVideoResource != null) { resourceId = defaultVideoResource.getId(); } //视频没有来源 if (StringUtil.isNullOrEmpty(resourceId)) { CMQManager.getInstance().addVideoResourceDeleteMsg(videoId); out.print(JsonUtil.loadFalseJson("视频已下线")); return; } } ThreadUtil.run(new Runnable() { @Override public void run() { int p = 0; if (!StringUtil.isNullOrEmpty(position)) { p = Integer.parseInt(position); } VideoWatchHistory history = new VideoWatchHistory(); history.setDevice(acceptData.getDevice()); history.setVideoId(videoId); history.setUid(loginUid); history.setPosition(p); videoWatchHistoryService.add(history); } }); userPlayLogger.info(VideoLogFactory.createUserVideoDetailLog(acceptData.getDevice(), acceptData.getUtdId(), loginUid, acceptData.getDetailSystem().getId(), videoId, resourceId, from)); //PPTV网页播放 if (!StringUtil.isNullOrEmpty(resourceId) && Integer.parseInt(resourceId) == PPTVUtil.RESOURCE_ID) { JSONObject data = new JSONObject(); VideoPPTVMap map = pptvService.getVideoPPTVMapByVideoId(videoId); int p = 0; if (!StringUtil.isNullOrEmpty(position)) { p = Integer.parseInt(position); } else { //取播放记录 VideoWatchHistory history = videoWatchHistoryService.getWatchHistory(acceptData.getDevice(), videoId); if (history != null && history.getPosition() != null) { p = history.getPosition(); } } String videoName = ""; String playUrl = null; PPTVSeries series = pptvService.getSeriesDetail(map.getInfoId()); if (map.getProgramCode() != null) { PPTVProgram program = pptvService.selectProgramById(map.getProgramCode()); videoName = program.getProgramSetTiltle(); playUrl = PPTVUtil.getPlayUrl(series, program); } else { videoName = series.getName(); p = p >= series.getSeries().size() ? 0 : p; playUrl = PPTVUtil.getPlayUrl(series, series.getSeries().get(p)); } String sessionId = createVideoDetailSessionId(acceptData, loginUid, videoName, videoId, resourceId); data.put("videoId", videoId); data.put("playUrl", playUrl); data.put("name", videoName); data.put("pptv", true); data.put("vip", "1" .equalsIgnoreCase(series.getFree())); data.put("sessionId", sessionId); out.print(JsonUtil.loadTrueJson(data.toString())); LoggerUtil.getUserActiveLogger().info(UserActiveLogFactory.createVideoDetail(new BaseLog(acceptData, loginUid), videoId, series.getName(), from)); ThreadUtil.run(new Runnable() { @Override public void run() { //看PP视频 deviceAdStrategyService.watchPPTVVideo(acceptData.getUtdId(), acceptData.getDetailSystem().getId()); } }); return; } VideoInfo info = videoDeailUtil.getVideoInfo(detailSystem.getId(), videoId, resourceId, resourceList, CacheUtil.getMD5Long(resourceList)); LoggerUtil.getUserActiveLogger().info(UserActiveLogFactory.createVideoDetail(new BaseLog(acceptData, loginUid), videoId, info != null ? info.getName() : "", from)); List typeList = classService.getVideoTypeList(info.getId()); if (typeList != null && typeList.size() > 0) { VideoType type = typeList.get(0); while (type.getParent() != null) type = type.getParent(); info.setVideoType(type); } info.setPlayPicture(VideoPictureUtil.getShowPicture(info, acceptData.getPlatform(), acceptData.getVersion() + "")); if (info.getVideoDetailList() != null) for (VideoDetailInfo vd : info.getVideoDetailList()) { if (StringUtil.isNullOrEmpty(vd.getExtraId())) vd.setExtraId(vd.getId() + ""); } JSONArray array = new JSONArray(); long count = commentService.getComment2ListCount(videoId, thirdType); if (info != null) info.setCommentCount((int) count); JSONObject obj = new JSONObject(); VideoDetailVO.AttentionInfo attention = null; if (info.getVideoDetailList() != null) if (info.getVideoDetailList().size() > 1) {// 多集,可关注 boolean isAttention = false; if (!StringUtil.isNullOrEmpty(loginUid)) { isAttention = attentionService.isAddAttention(loginUid, info.getId()); } attention = new VideoDetailVO.AttentionInfo(); attention.setName(info.getName()); attention.setPicture(info.getPicture()); if (StringUtil.isNullOrEmpty(info.getUpdatetime())) { attention.setUpdateInfo("更新:" + TimeUtil.getCommentTime(info.getCreatetime())); } else { attention.setUpdateInfo("更新:" + TimeUtil.getCommentTime(Long.parseLong(info.getUpdatetime()))); } attention.setAttention(isAttention); //兼容老版本 JSONObject attentionInfo = new JSONObject(); attentionInfo.put("Picture", attention.getPicture()); attentionInfo.put("Name", attention.getName()); attentionInfo.put("UpdateInfo", attention.getUpdateInfo()); attentionInfo.put("IsAttention", attention.isAttention()); obj.put("Attention", attentionInfo); } UserInfo user = userService.getUserInfo(acceptData.getUid()); if (VersionUtil.isGraterThan390(acceptData.getPlatform(), acceptData.getVersion())) { String sessionId = createVideoDetailSessionId(acceptData, loginUid, info.getName(), videoId, resourceId); out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(new VideoDetailVO(Utils.convertVideo(info), deviceAdStrategyService.getVideoDetailAdStrategy(acceptData.getUtdId(), acceptData.getDetailSystem().getId(), acceptData.getVersion(), acceptData.getChannel(), loginUid, videoId, from), attention, sessionId)), array.toString(), obj.toString())); } else { out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(Utils.convertVideo(info)), array.toString(), obj.toString())); } ThreadUtil.run(new Runnable() { @Override public void run() { long showTime = TimeUtil.convertGernalTime(TimeUtil.getGernalTime(System.currentTimeMillis() + 1000 * 60 * 60 * 24L, "yyyy-MM-dd"), "yyyy-MM-dd"); deviceAdStrategyService.setShortVideoAdStrategy(acceptData.getUtdId(), acceptData.getDetailSystem().getId(), videoId, from, showTime, null); } }); } /** * 获取视频的剧集列表 * * @param acceptData * @param request * @param out */ @RequireUid public void getVideoEpisodeList(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String videoId = request.getParameter("VideoId"); String resourceId = request.getParameter("ResourceId"); String page = request.getParameter("Page");//页码 String pageSize = request.getParameter("PageSize");//页 if (StringUtil.isNullOrEmpty(videoId)) { out.print(JsonUtil.loadFalseJson("请上传VideoId")); return; } if (StringUtil.isNullOrEmpty(resourceId)) { out.print(JsonUtil.loadFalseJson("请上传ResourceId")); return; } if (StringUtil.isNullOrEmpty(page)) { out.print(JsonUtil.loadFalseJson("请上传Page")); return; } int pagesize = 100; if (!StringUtil.isNullOrEmpty(pageSize)) { pagesize = Integer.parseInt(pageSize); } List list = videoDetailUtil.getVideoDetailList(videoId, new VideoResource(resourceId), Integer.parseInt(page), pagesize); if (list == null) list = new ArrayList<>(); JSONObject data = new JSONObject(); String listStr = StringUtil.outPutResultJson(list); boolean hasMore = list != null && list.size() > 0; data.put("list", listStr); data.put("hasMore", hasMore); out.print(JsonUtil.loadTrueJson(data.toString())); } @RequireUid public void getNewVideoDetail(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { getVideoDetail(acceptData, request, out); } @RequireUid public void isCollected(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String detailId = request.getParameter("Id"); String thirdType = request.getParameter("ThirdType"); if (StringUtil.isNullOrEmpty(detailId)) { out.print(JsonUtil.loadFalseJson("请上传Id")); return; } if (!NumberUtil.isNumeric(detailId)) { out.print(JsonUtil.loadFalseJson("")); return; } boolean collect = collectionService.isCollect(acceptData.getUid(), detailId, thirdType); if (collect) out.print(JsonUtil.loadTrueJson("")); else out.print(JsonUtil.loadFalseJson("")); } public void getPlayUrl(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { String resourceId = request.getParameter("ResourceId"); String id = request.getParameter("Id"); String eid = request.getParameter("EId"); String type = request.getParameter("Type"); String videoId = request.getParameter("VideoId"); if (StringUtil.isNullOrEmpty(resourceId)) { out.print(JsonUtil.loadFalseJson("请上传ResourceId")); return; } if (StringUtil.isNullOrEmpty(id) && StringUtil.isNullOrEmpty(eid)) { out.print(JsonUtil.loadFalseJson("请上传id")); return; } // if (StringUtil.isNullOrEmpty(type)) { // out.print(JsonUtil.loadFalseJson("请上传type")); // return; // } if (StringUtil.isNullOrEmpty(id)) id = eid; DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); PlayUrl pu = null; try { pu = videoDeailUtil.getPlayUrl(acceptData, detailSystem.getId(), id, type, Integer.parseInt(resourceId), videoId); } catch (VideoPlayException e) { e.printStackTrace(); } if (pu != null) { if (!StringUtil.isNullOrEmpty(pu.getUrl())) pu.setUrl(pu.getUrl()); JSONObject object = JSONObject.fromObject(StringUtil.outPutResultJson(pu)); out.print(JsonUtil.loadTrueJson(object.toString())); } else { out.print(JsonUtil.loadFalseJson("找不到该视频")); } } public List getZhiBoVideoList() throws Exception { List list = new ArrayList(); String result = get("http://www.kktv1.com/CDN/output/M/3/I/10002002/P/start-0_offset-6_platform-2/json.js"); JSONObject object = JSONObject.fromObject(result); JSONArray array = object.optJSONArray("roomList"); for (int i = 0; i < array.size(); i++) { VideoInfo info = new VideoInfo(); JSONObject obj = array.optJSONObject(i); info.setId(obj.optString("roomId")); info.setName(obj.optString("nickname")); info.setTag("在线:" + obj.optString("onlineCount")); info.setPicture(obj.optString("poster_path_272")); HomeVideo hv = new HomeVideo(); hv.setPicture(info.getPicture()); hv.setVideo(info); list.add(hv); } return list; } public String get(String url) { HttpClient client = new HttpClient(); GetMethod method = new GetMethod(url); method.getParams().setContentCharset("UTF-8"); try { client.executeMethod(method); String responseBodyAsString = method.getResponseBodyAsString(); // LogUtil.i(responseBodyAsString); return responseBodyAsString; } catch (HttpException e) { e.printStackTrace(); } catch (IOException e) { e.printStackTrace(); } return ""; } public void isPraise(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); DetailSystemConfig config = configService.getConfigByKey("banner_praise", acceptData.getChildDetailSystem(), acceptData.getVersion()); if ("是" .equals(config.getValue())) { out.print(JsonUtil.loadTrueJson("1")); } else { out.print(JsonUtil.loadTrueJson("0")); } } @Resource private SearchSpecialPositionMapService searchSpecialPositionMapService; /** * 获取推荐的搜索专题 * * @param acceptData * @param request * @param out */ public void getRecommendSearchSpecial(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); //推荐搜索专题 DetailSystemConfig config = configService.getConfigByKey("recommend_search_special_position", acceptData.getChildDetailSystem(), acceptData.getVersion()); if (config == null) { out.print(JsonUtil.loadFalseAdmin("位置为空")); return; } String key = config.getValue(); List mapList = searchSpecialPositionMapService.listDetailByPosition(key, 1, 20); JSONArray array = new JSONArray(); for (SearchSpecialPositionMap map : mapList) { JSONObject item = new JSONObject(); item.put("icon", map.getIcon()); item.put("name", map.getShowName() == null ? map.getSpecial().getName() : map.getShowName()); item.put("id", map.getSpecialId()); array.add(item); } out.print(JsonUtil.loadTrueJson(array.toString())); } }