| | |
| | | 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.*; |
| | | |
| | | import javax.annotation.Resource; |
| | | import javax.servlet.http.HttpServletRequest; |
| | | |
| | | import com.yeshi.buwan.domain.*; |
| | | import com.yeshi.buwan.pptv.PPTVUtil; |
| | | import com.yeshi.buwan.pptv.entity.PPTVSeries; |
| | | import com.yeshi.buwan.service.imp.*; |
| | | import com.yeshi.buwan.service.inter.juhe.PPTVService; |
| | | import com.yeshi.buwan.util.annotation.RequireUid; |
| | | import com.yeshi.buwan.vo.AcceptData; |
| | | import org.apache.commons.httpclient.HttpClient; |
| | | import org.apache.commons.httpclient.HttpException; |
| | | import org.apache.commons.httpclient.methods.GetMethod; |
| | | import org.springframework.stereotype.Controller; |
| | | |
| | | import com.yeshi.buwan.domain.entity.PlayUrl; |
| | | import com.yeshi.buwan.util.CacheUtil; |
| | | import com.yeshi.buwan.util.Constant; |
| | | import com.yeshi.buwan.util.JsonUtil; |
| | | import com.yeshi.buwan.util.JuheVideoUtil; |
| | | import com.yeshi.buwan.util.StringUtil; |
| | | import com.yeshi.buwan.util.TimeUtil; |
| | | import com.yeshi.buwan.util.Utils; |
| | | import com.yeshi.buwan.util.VideoPictureUtil; |
| | | import com.yeshi.buwan.util.JuHe.VideoResourceUtil; |
| | | import com.yeshi.buwan.util.video.VideoDetailUtil; |
| | | import com.yeshi.buwan.util.zhibo.MeiNvZhiBoUtil; |
| | | |
| | | import net.sf.json.JSONArray; |
| | | import net.sf.json.JSONObject; |
| | | |
| | | @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 ConfigService configService; |
| | | private HomeVideoService homeVideoService; |
| | | |
| | | @Resource |
| | | private DetailSystemConfigService configService; |
| | | @Resource |
| | | private AdService adService; |
| | | @Resource |
| | |
| | | @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"); |
| | | if (!"310".equals(vtid)) { |
| | | HomeRecommendSpecial special = homeRecommendSpecialService.getSpecial(vtid); |
| | | //兼容新版本 |
| | | if (special != null) { |
| | | |
| | | JSONObject object = new JSONObject(); |
| | | |
| | | DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); |
| | | |
| | | List<HomeAd> list = homeAdService.getHomeAdList(detailSystem); |
| | | List<HomeAd> list = homeAdService.getHomeAdList(detailSystem, special != null ? special.getDataKey() : null); |
| | | |
| | | if (acceptData.getPlatform().equalsIgnoreCase("ios"))// IOS测试 |
| | | { |
| | |
| | | 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) { |
| | |
| | | if (!StringUtil.isNullOrEmpty(ad.getParams())) { |
| | | ad.setParams(ad.getParams().replace("\"", "\\" + "\"")); |
| | | } |
| | | |
| | | // 3.4.7以上的版本才可以用 |
| | | // com.weikou.beibeivideo.ui.mine.FXBrowserActivity |
| | | if ("com.weikou.beibeivideo.ui.mine.FXBrowserActivity".equalsIgnoreCase(ad.getClazz()) |
| | | && acceptData.getVersion() < 71) |
| | | ad.setClazz("com.weikou.beibeivideo.ui.mine.BrowserActivity"); |
| | | else |
| | | ad.setClazz("com.weikou.beibeivideo.ui.mine.FXBrowserActivity"); |
| | | } |
| | | object.put("count", (new StringBuilder(String.valueOf(list.size()))).toString()); |
| | | JSONArray array = new JSONArray(); |
| | |
| | | |
| | | object.put("data", array); |
| | | } |
| | | object.put("bannerSizeRate", special.getBannerSizeRate()); |
| | | out.print(JsonUtil.loadTrueJson(object.toString())); |
| | | } else { |
| | | classParser.getRecommendCategoryVideoBanner(acceptData, request, out); |
| | |
| | | if (StringUtil.isNullOrEmpty(vtid)) { |
| | | vtid = "309"; // 为了兼容以前的推荐 |
| | | } |
| | | |
| | | HomeRecommendSpecial special = homeRecommendSpecialService.getSpecial(vtid); |
| | | |
| | | DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); |
| | | JSONObject object = new JSONObject(); |
| | | |
| | | List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion()); |
| | | List<HomeType> list1 = homeTypeService.getHomeType(detailSystem.getId(), resourceList, |
| | | CacheUtil.getMD5Long(resourceList), -1, Long.parseLong(vtid)); |
| | | List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); |
| | | List<HomeType> list1 = homeTypeService.getHomeType(detailSystem.getId(), acceptData.getPlatform(), acceptData.getVersion(), resourceList, |
| | | CacheUtil.getMD5Long(resourceList), -1, special != null ? special.getDataKey() : null); |
| | | List<HomeType> list = new ArrayList<>(); |
| | | for (HomeType ht : list1) |
| | | list.add(ht); |
| | | if ("309".equals(vtid)) { |
| | | if (!"ios".equalsIgnoreCase(acceptData.getPlatform())) { |
| | | Map<String, String> confMap = configService.getConfigAsMap(detailSystem, acceptData.getVersion()); |
| | | if ("309" .equals(vtid)) { |
| | | if (!"ios" .equalsIgnoreCase(acceptData.getPlatform())) { |
| | | Map<String, String> confMap = configService.getConfigAsMap(acceptData.getChildDetailSystem(), acceptData.getVersion()); |
| | | String mm = confMap.get("meinv_mm_count"); |
| | | int count = Integer.parseInt(mm); |
| | | if (count > 0) { |
| | |
| | | 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")) { |
| | |
| | | } |
| | | } |
| | | |
| | | if ("huawei".equalsIgnoreCase(channel)) { |
| | | if ("huawei" .equalsIgnoreCase(channel)) { |
| | | for (int i = 0; i < list.size(); i++) { |
| | | if (list.get(i).getName().equalsIgnoreCase("美女")) { |
| | | list.remove(i); |
| | |
| | | JSONArray array = new JSONArray(); |
| | | |
| | | for (HomeType ht : list) { |
| | | for (int i = 0; i < ht.getHomeVideoList().size(); i++) { |
| | | //改变图片 |
| | | if (JuheVideoUtil.isNeedDelete(ht.getHomeVideoList().get(i).getVideo(), detailSystem.getId())) { |
| | | ht.getHomeVideoList().remove(i); |
| | | i--; |
| | | 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<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); |
| | | List<HomeType> 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<HomeVideo> 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<HomeVideo> 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())); |
| | | } |
| | | |
| | |
| | | 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<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); |
| | | //查询大图 |
| | | List<HomeVideo> 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<HomeVideo> list1 = homeVideoService.getHomeVideoList(homeTypeId, resourceKey, resourceList, homeType.isBigPicture(), page, homeType.getNumber()); |
| | | List<HomeVideo> 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) { |
| | |
| | | |
| | | List<HomeVideo> homeVideoList = homeTypeService.getVideoByTypes(type, pageIndex, detailSystem); |
| | | |
| | | List<VideoInfo> list = new ArrayList<VideoInfo>(); |
| | | List<VideoInfo> list = new ArrayList<>(); |
| | | for (int i = 0; i < homeVideoList.size(); i++) { |
| | | HomeVideo hv = (HomeVideo) homeVideoList.get(i); |
| | | if (acceptData.getPackageName().contains("doudou")) { |
| | |
| | | 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<Long> 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")); |
| | |
| | | |
| | | DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); |
| | | |
| | | List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion()); |
| | | List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); |
| | | |
| | | //获取优先展示的渠道 |
| | | if (StringUtil.isNullOrEmpty(resourceId)) { |
| | |
| | | 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 (resourceId != null && Integer.parseInt(resourceId) == PPTVUtil.RESOURCE_ID) { |
| | | if (!StringUtil.isNullOrEmpty(resourceId) && Integer.parseInt(resourceId) == PPTVUtil.RESOURCE_ID) { |
| | | JSONObject data = new JSONObject(); |
| | | PPTVSeries series = pptvService.getSeriesDetailByVideoId(videoId); |
| | | String playUrl = PPTVUtil.getPlayUrl(series, series.getSeries().get(0)); |
| | | 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<VideoType> typeList = classService.getVideoTypeList(info.getId()); |
| | | if (typeList != null && typeList.size() > 0) { |
| | |
| | | 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("Name", info.getName()); |
| | | attentionInfo.put("Picture", info.getPicture()); |
| | | if (StringUtil.isNullOrEmpty(info.getUpdatetime())) |
| | | attentionInfo.put("UpdateInfo", "更新:" + TimeUtil.getCommentTime(info.getCreatetime())); |
| | | else |
| | | attentionInfo.put("UpdateInfo", "更新:" + TimeUtil.getCommentTime(Long.parseLong(info.getUpdatetime()))); |
| | | attentionInfo.put("IsAttention", isAttention); |
| | | 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 (Utils.isTest(request, user, detailSystem.getId())) |
| | | out.print(JsonUtil.loadTrueJson("")); |
| | | else |
| | | 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); |
| | | } |
| | | }); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * 获取视频的剧集列表 |
| | |
| | | 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")); |
| | |
| | | out.print(JsonUtil.loadFalseJson("请上传Page")); |
| | | return; |
| | | } |
| | | int pagesize = 100; |
| | | if (!StringUtil.isNullOrEmpty(pageSize)) { |
| | | pagesize = Integer.parseInt(pageSize); |
| | | } |
| | | |
| | | |
| | | List<VideoDetailInfo> list = videoDetailUtil.getVideoDetailList(videoId, new VideoResource(resourceId), Integer.parseInt(page), 100); |
| | | List<VideoDetailInfo> list = videoDetailUtil.getVideoDetailList(videoId, new VideoResource(resourceId), Integer.parseInt(page), pagesize); |
| | | if (list == null) |
| | | list = new ArrayList<>(); |
| | | JSONObject data = new JSONObject(); |
| | |
| | | return; |
| | | } |
| | | |
| | | if (!NumberUtil.isNumeric(detailId)) { |
| | | out.print(JsonUtil.loadFalseJson("")); |
| | | return; |
| | | } |
| | | |
| | | |
| | | boolean collect = collectionService.isCollect(acceptData.getUid(), detailId, thirdType); |
| | | if (collect) |
| | | out.print(JsonUtil.loadTrueJson("")); |
| | |
| | | return; |
| | | } |
| | | |
| | | if (StringUtil.isNullOrEmpty(type)) { |
| | | out.print(JsonUtil.loadFalseJson("请上传type")); |
| | | 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 = videoDeailUtil.getPlayUrl(acceptData, detailSystem.getId(), id, type, Integer.parseInt(resourceId), videoId); |
| | | 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())) |
| | |
| | | |
| | | public void isPraise(AcceptData acceptData, HttpServletRequest request, PrintWriter out) { |
| | | DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); |
| | | Config config = configService.getConfigByKey("banner_praise", detailSystem, acceptData.getVersion()); |
| | | if ("是".equals(config.getValue())) { |
| | | 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<SearchSpecialPositionMap> 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())); |
| | | } |
| | | |
| | | } |