From f06a592dd1a7e995bf313ccb5efe7dff73ccfc4e Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 12 四月 2023 18:25:52 +0800 Subject: [PATCH] 增加本地获取IP归属地/广告优化 --- src/main/java/com/yeshi/buwan/controller/parser/HomeParser.java | 277 +++++++++++++++++++++++++++++++++++++++++++++++++++++-- 1 files changed, 266 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/yeshi/buwan/controller/parser/HomeParser.java b/src/main/java/com/yeshi/buwan/controller/parser/HomeParser.java index cc8d534..846e715 100644 --- a/src/main/java/com/yeshi/buwan/controller/parser/HomeParser.java +++ b/src/main/java/com/yeshi/buwan/controller/parser/HomeParser.java @@ -13,6 +13,8 @@ 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.service.inter.video.VideoResourceInfoMapService; +import com.yeshi.buwan.service.manager.APPManager; import com.yeshi.buwan.videos.mogotv.MogoTVUtil; import com.yeshi.buwan.videos.pptv.PPTVApiUtil; import com.yeshi.buwan.videos.pptv.PPTVUtil; @@ -117,6 +119,12 @@ @Resource private DeviceAdStrategyService deviceAdStrategyService; + @Resource + private APPManager appManager; + + @Resource + private VideoResourceInfoMapService videoResourceInfoMapService; + private final Logger userPlayLogger = LoggerFactory.getLogger("videoPlayUser"); @RequireUid @@ -204,8 +212,8 @@ List<HomeType> list = new ArrayList<>(); for (HomeType ht : list1) list.add(ht); - if ("309" .equals(vtid)) { - if (!"ios" .equalsIgnoreCase(acceptData.getPlatform())) { + 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); @@ -235,7 +243,7 @@ } if (VersionUtil.isGraterThan387(acceptData.getPlatform(), acceptData.getVersion())) { - DetailSystemConfig adContent = configService.getConfigByKey("home_banner_ad_content", acceptData.getChildDetailSystem(), 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); @@ -265,7 +273,7 @@ } } - 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); @@ -336,7 +344,7 @@ try { if (VersionUtil.isGraterThan387(acceptData.getPlatform(), acceptData.getVersion()) && dataKey.equalsIgnoreCase("recommend")) { - DetailSystemConfig adContent = configService.getConfigByKey("home_banner_ad_content", acceptData.getChildDetailSystem(), 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); @@ -344,7 +352,7 @@ if (adP < homeTypeList.size() && adP > -1) { HomeType homeType = new HomeType(); homeType.setAd(ad); - if ("1" .equalsIgnoreCase(page)) { + if ("1".equalsIgnoreCase(page)) { homeTypeList.add(adP, homeType); } count++; @@ -647,6 +655,9 @@ info.setWatchCount("" + (int) (Math.random() * 1000)); + //瑙嗛杩囨护 + filterVideo(acceptData, info); + JSONArray array = new JSONArray(); JSONObject obj = new JSONObject(); @@ -657,6 +668,36 @@ out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(Utils.convertVideo(info)), array.toString(), obj.toString())); } + } + + //瑙嗛杩囨护 + private void filterVideo(AcceptData acceptData, VideoInfo video) { + //杩囨护瑙嗛璧勬簮 + List<VideoResource> resourceList = videoResourceInfoMapService.filter(acceptData.getDetailSystem().getId(), video.getResourceList()); + video.setResourceList(resourceList); + //鎺у埗鍓嶇鍒楄〃涓殑鏉ユ簮鏄剧ず闂 + if ("48".equalsIgnoreCase(acceptData.getDetailSystem().getId())) { + if (video.getArea() != null && video.getArea().contains("闊╁浗")) { + //鍒ゆ柇褰撳墠鐗堟湰鏄惁姝e湪涓婄嚎 + if (appManager.isOnline(acceptData.getDetailSystem().getId(), acceptData.getVersion(), acceptData.getChannel())) { + //濡傛灉鍦ㄤ笂绾垮氨鍒犻櫎鏈�変腑鐨勮祫婧愶紝骞朵笖灏嗗綋鍓嶈祫婧愬彉涓洪煩杩稵V + for (int i = 0; i < video.getResourceList().size(); i++) { + if (!video.getResourceList().get(i).isChecked()) { + video.getResourceList().remove(i--); + } + } + if (video.getResourceList().size() > 0) { + video.getResourceList().get(0).setName("PP瑙嗛"); + //鍦↖D鍓嶉潰娣诲姞native鏍囪瘑 + for (VideoDetailInfo videoDetailInfo : video.getVideoDetailList()) { + videoDetailInfo.setExtraId("native_" + videoDetailInfo.getExtraId()); + } + } + } + } + + } + } @RequireUid @@ -672,6 +713,11 @@ return; } else if (fromType == HomeVideo.FROM_TYPE_INTERNET) { getVideoDetailForInternetSearch(acceptData, videoId, request, out); + + //VIVO 娓犻亾姣忔棩骞垮憡鏈�澶氬睍绀轰竴娆� + if ("vivo".equalsIgnoreCase(acceptData.getChannel())) { + deviceAdStrategyService.setFSAShowTomorrow(acceptData.getUtdId(), acceptData.getDetailSystem().getId()); + } return; } } @@ -789,7 +835,7 @@ data.put("playUrl", playUrl); data.put("name", videoName); data.put("pptv", true); - data.put("vip", "1" .equalsIgnoreCase(series.getFree())); + 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)); @@ -856,16 +902,225 @@ attentionInfo.put("IsAttention", attention.isAttention()); obj.put("Attention", attentionInfo); } - UserInfo user = userService.getUserInfo(acceptData.getUid()); + + //瑙嗛杩囨护 + filterVideo(acceptData, info); + 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())); + //VIVO 娓犻亾姣忔棩骞垮憡鏈�澶氬睍绀轰竴娆� + if ("vivo".equalsIgnoreCase(acceptData.getChannel())) { + deviceAdStrategyService.setFSAShowTomorrow(acceptData.getUtdId(), acceptData.getDetailSystem().getId()); + } } 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); + } + }); + } + + + @RequireUid + public void getVideoDetailNew(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("vip", PPTVUtil.isVIPVideo(series.getFree())); + JSONObject pptv = new JSONObject(); + pptv.put("pptv", data); + out.print(JsonUtil.loadTrueJson(pptv.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("璇蜂笂浼燰ideoId")); + return; + } + if (StringUtil.isNullOrEmpty(thirdType)) { + out.print(JsonUtil.loadFalseJson("璇蜂笂浼燭ype")); + return; + } + + DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName()); + + List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion(), acceptData.getChannel()); + + //鑾峰彇浼樺厛灞曠ず鐨勬笭閬� + if (StringUtil.isNullOrEmpty(resourceId)) { + Set<Long> 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() { + //鐪婸P瑙嗛 + 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) { + 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() + ""); + } + info.setCommentCount(0); + + + 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); + } + + //瑙嗛杩囨护 + filterVideo(acceptData, info); + 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)))); ThreadUtil.run(new Runnable() { @Override @@ -1036,8 +1291,8 @@ 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())) { + 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")); @@ -1058,7 +1313,7 @@ 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()); + DetailSystemConfig config = configService.getConfigByKey("recommend_search_special_position", acceptData.getChildDetailSystem(), acceptData.getVersion()); if (config == null) { out.print(JsonUtil.loadFalseAdmin("浣嶇疆涓虹┖")); return; -- Gitblit v1.8.0