全网搜优酷兼容

admin

2021-03-25 f13ed98e1de0ec7b85ed179212cc095f63480eed

 src/main/java/com/yeshi/buwan/controller/parser/UserParser.java

@@ -2,31 +2,51 @@

import com.yeshi.buwan.domain.*;
import com.yeshi.buwan.domain.Collection;
import com.yeshi.buwan.domain.solr.SolrAlbumVideo;
import com.yeshi.buwan.domain.system.DetailSystem;
import com.yeshi.buwan.domain.user.LoginUser;
import com.yeshi.buwan.domain.video.InternetSearchVideo;
import com.yeshi.buwan.dto.log.BaseLog;
import com.yeshi.buwan.dto.search.SolrResultDTO;
import com.yeshi.buwan.dto.search.SolrVideoSearchFilter;
import com.yeshi.buwan.dto.user.LoginInfoDto;
import com.yeshi.buwan.exception.user.LoginUserException;
import com.yeshi.buwan.exception.user.RegisterUserException;
import com.yeshi.buwan.pptv.PPTVUtil;
import com.yeshi.buwan.service.imp.*;
import com.yeshi.buwan.service.manager.SolrAlbumDataManager;
import com.yeshi.buwan.service.inter.juhe.InternetSearchVideoService;
import com.yeshi.buwan.service.manager.SolrAlbumVideoDataManager;
import com.yeshi.buwan.util.*;
import com.yeshi.buwan.util.JuHe.VideoResourceUtil;
import com.yeshi.buwan.util.annotation.RequireUid;
import com.yeshi.buwan.util.email.MailSenderUtil;
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.video.VideoCategoryConstant;
import com.yeshi.buwan.util.video.VideoConstant;
import com.yeshi.buwan.vo.AcceptData;
import com.yeshi.buwan.vo.video.VideoListResultVO;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;
import java.io.File;
import java.io.PrintWriter;
import java.util.*;

@Controller
public class UserParser {

    @Resource
    private SystemService systemService;
    @Resource
    private ConfigService configService;
    private DetailSystemConfigService configService;
    @Resource
    private UserService userService;
    @Resource
@@ -46,7 +66,7 @@
    @Resource
    private VideoInfoService videoInfoService;
    @Resource
    private SolrAlbumDataManager solrDataManager;
    private SolrAlbumVideoDataManager solrDataManager;
    @Resource
    private ConfigParser configParser;

@@ -143,7 +163,8 @@
            }


            String type = configParser.getAdShowType("ad_video_detail_full_video", acceptData.getChannel(), acceptData.getVersion(), map);
            ConfigParser.ADConfig adConfig = configParser.getAdShowType("ad_video_detail_full_video", acceptData.getChannel(), acceptData.getVersion(), map);
            String type = adConfig == null ? "" : adConfig.getType();

            if (!StringUtil.isNullOrEmpty(type)) {// 是否屏蔽详情页全屏广告
                JSONObject adType = JSONObject.fromObject(map.get("ad_type"));
@@ -172,7 +193,7 @@
        if (acceptData.getPlatform().equalsIgnoreCase("ios")) {
            if (Constant.IOSTest) {
                if (acceptData.getVersion() == 1) {
                    list = new ArrayList<String>();
                    list = new ArrayList<>();
                }
            }
        }
@@ -191,7 +212,7 @@
    private List<VideoDetailInfo> createSearchVideoDetailsVO(VideoInfo video) {
        List<VideoDetailInfo> detailList = new ArrayList<>();
        if (video.getVideoType() != null && (Integer.parseInt(video.getVideoType().getId() + "") == VideoCategoryConstant.CATEGORY_DIANSHIJU || Integer.parseInt(video.getVideoType().getId() + "") == VideoCategoryConstant.CATEGORY_DONGMAN)) {
            if (video.getVideocount() <= 5) {
            if (video.getVideocount() != null && video.getVideocount() <= 5) {
                for (int i = 0; i < video.getVideocount(); i++) {
                    VideoDetailInfo detail = new VideoDetailInfo();
                    detail.setTag((i + 1) + "");
@@ -256,7 +277,7 @@
            object.put("data", array);
            out.print(JsonUtil.loadTrueJson(object.toString()));
        } else {
            List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion());
            List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(detailSystem, acceptData.getVersion());
            String cacheMD5 = "0";
            if (resourceList != null && resourceList.size() > 0)
                for (Long l : resourceList)
@@ -343,121 +364,163 @@
            return;
        }

        LoggerUtil.getUserActiveLogger().info(UserActiveLogFactory.createSearch(new BaseLog(acceptData, ""), key, type));

        int pageIndex = StringUtil.getPage(page);
        if (pageIndex <= 0) {
            pageIndex = 1;
        }

        DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName());
        UserInfo user1 = userService.getUserInfo(acceptData.getUid());
        if (Utils.isTest(request, user1, detailSystem.getId())) {
            detailSystem = systemService.getDetailSystemById(40 + "");
            JSONObject object = new JSONObject();
            object.put("count", 0);
            JSONArray array = new JSONArray();
            object.put("data", array);
            out.print(JsonUtil.loadTrueJson(object.toString()));
        } else {
            List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion());
            String cacheMD5 = "0";
            if (resourceList != null && resourceList.size() > 0)
                for (Long l : resourceList)
                    cacheMD5 += "#" + l;
            cacheMD5 = StringUtil.Md5(cacheMD5);
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion());

            List<VideoInfo> list = searchService.searchNew(detailSystem.getId(), request.getRemoteAddr(),
                    acceptData.getUid(), key, pageIndex, Integer.parseInt(type),
                    acceptData.getSystem(), resourceList, cacheMD5);
            //组织数据
            for (VideoInfo video : list) {
                //如果是正片，且为5大分类 就采用竖条展示
                if (video.getShowType() == 1) {
                    video.setVideoDetailList(createSearchVideoDetailsVO(video));
                }

        String cacheMD5 = "0";
        if (resourceList != null && resourceList.size() > 0)
            for (Long l : resourceList)
                cacheMD5 += "#" + l;
        cacheMD5 = StringUtil.Md5(cacheMD5);


        VideoListResultVO videoListResultVO = searchService.searchNew(acceptData.getDetailSystem().getId(), request.getRemoteAddr(),
                acceptData.getUid(), key, pageIndex, Integer.parseInt(type),
                acceptData.getSystem(), resourceList, cacheMD5);
        //组织数据
        for (VideoInfo video : videoListResultVO.getVideoList()) {
            //如果是正片，且为5大分类 就采用竖条展示
            if (video.getShowType() == 1) {
                video.setVideoDetailList(createSearchVideoDetailsVO(video));
            }
            cacheMD5 = "0";
            if (list != null) {
                for (VideoInfo info : list) {
                    cacheMD5 += info.getId() + "#";
                }
            }
            list = banQuanService.getBanQuanVideo(list, detailSystem.getId(), cacheMD5);

            JSONObject object = new JSONObject();
            object.put("count", Constant.isUpdate ? 19 + "" : list.size());
            JSONArray array = new JSONArray();
            for (int i = 0; i < list.size(); i++) {
                if (JuheVideoUtil.isNeedDelete((VideoInfo) list.get(i), detailSystem.getId())) {
                    list.remove(i);
                    i--;
                }
            }

            List<String> keyList = banQuanService.getBanQuanKeyListAll(Integer.parseInt(detailSystem.getId()));
            for (int i = 0; i < list.size(); i++) {

                boolean delete = false;
                for (int j = 0; j < keyList.size(); j++) {
                    if (list.get(i).getName().contains(keyList.get(j))) {
                        delete = true;
                        break;
                    }
                }
                if (delete) {
                    list.remove(i);
                    i--;
                }

            }

            for (int i = 0; i < list.size(); i++) {
                ((VideoInfo) list.get(i))
                        .setPicture(VideoPictureUtil.getShowPicture((VideoInfo) list.get(i), acceptData.getPlatform(), acceptData.getVersion() + ""));
                array.add(StringUtil.outPutResultJson(list.get(i)));
            }
            object.put("data", array);
            if (pageIndex == 1) {//返回导航栏
                List<VideoType> typeList = new ArrayList<>();
                VideoType vt = new VideoType();
                vt.setId(0);
                vt.setName("全部");
                typeList.add(vt);
                Set<Long> set = new HashSet<>();
                for (VideoInfo videoInfo : list) {
                    if (videoInfo.getShowType() == 1 && videoInfo.getVideoType() != null)
                        set.add(videoInfo.getVideoType().getId());
                }

                for (Iterator<Long> its = set.iterator(); its.hasNext(); ) {
                    Long typeId = its.next();
                    String typeName = VideoConstant.getMainCategoryName(typeId);
                    if (!StringUtil.isNullOrEmpty(typeName)) {
                        vt = new VideoType();
                        vt.setId(typeId);
                        vt.setName(typeName);
                        typeList.add(vt);
                    }
                }
                JSONArray array1 = new JSONArray();
                for (VideoType vt1 : typeList)
                    array1.add(StringUtil.outPutResultJson(vt1));
                object.put("typeList", array1);
            }

            out.print(JsonUtil.loadTrueJson(object.toString()));
        }
        cacheMD5 = "0";
        if (videoListResultVO.getVideoList() != null) {
            for (VideoInfo info : videoListResultVO.getVideoList()) {
                cacheMD5 += info.getId() + "#";
            }
        }
        List<VideoInfo> list = banQuanService.getBanQuanVideo(videoListResultVO.getVideoList(), acceptData.getDetailSystem().getId(), cacheMD5);

        JSONObject object = new JSONObject();
        object.put("count", Constant.isUpdate ? 19 + "" : videoListResultVO.getCount());
        JSONArray array = new JSONArray();
        for (int i = 0; i < list.size(); i++) {
            if (JuheVideoUtil.isNeedDelete((VideoInfo) list.get(i), acceptData.getDetailSystem().getId())) {
                list.remove(i);
                i--;
            }
        }

        for (int i = 0; i < list.size(); i++) {
            ((VideoInfo) list.get(i))
                    .setPicture(VideoPictureUtil.getShowPicture((VideoInfo) list.get(i), acceptData.getPlatform(), acceptData.getVersion() + ""));
            array.add(StringUtil.outPutResultJson(list.get(i)));
        }
        object.put("data", array);
        if (pageIndex == 1) {//返回导航栏
            List<VideoType> typeList = new ArrayList<>();
            VideoType vt = new VideoType();
            vt.setId(0);
            vt.setName("全部");
            typeList.add(vt);
            Set<Long> set = new HashSet<>();
            for (VideoInfo videoInfo : list) {
                if (videoInfo.getShowType() == 1 && videoInfo.getVideoType() != null)
                    set.add(videoInfo.getVideoType().getId());
            }

            for (Iterator<Long> its = set.iterator(); its.hasNext(); ) {
                Long typeId = its.next();
                String typeName = VideoConstant.getMainCategoryName(typeId);
                if (!StringUtil.isNullOrEmpty(typeName)) {
                    vt = new VideoType();
                    vt.setId(typeId);
                    vt.setName(typeName);
                    typeList.add(vt);
                }
            }

            vt = new VideoType();
            vt.setId(Constant.SEARCH_RESULT_TYPE_HIGH_DEFINITION);
            vt.setName("高清");
            typeList.add(vt);


            JSONArray array1 = new JSONArray();
            for (VideoType vt1 : typeList)
                array1.add(StringUtil.outPutResultJson(vt1));
            object.put("typeList", array1);
        }

        out.print(JsonUtil.loadTrueJson(object.toString()));

    }


    @Resource
    private InternetSearchVideoService internetSearchVideoService;

    private void guessLikeForInternetSearch(AcceptData acceptData, String videoId, PrintWriter out) {
        InternetSearchVideo internetSearchVideo = internetSearchVideoService.selectByPrimaryKey(videoId);
        if (internetSearchVideo != null) {
            int rootType = internetSearchVideo.getRootType();
            SolrVideoSearchFilter filter = new SolrVideoSearchFilter();
            filter.setVideoType(rootType);
            filter.setResourceIds(new String[]{PPTVUtil.RESOURCE_ID + ""});
            filter.setSortKey("watchcount");
            SolrResultDTO dto = solrDataManager.find(filter, 1, 20);
            List<SolrAlbumVideo> solrAlbumVideoList = new ArrayList<>();
            solrAlbumVideoList.addAll(dto.getVideoList());
            List<VideoInfo> list = new ArrayList<>();
            for (int i = 0; i < 4; i++) {
                if (solrAlbumVideoList.size() > 0) {
                    int p = (int) (Math.random() * solrAlbumVideoList.size());
                    SolrAlbumVideo solrAlbumVideo = solrAlbumVideoList.get(p);
                    list.add(VideoInfoFactory.create(solrAlbumVideo));
                    solrAlbumVideoList.remove(p);
                }
            }

            if (list.size() < 4) {
                filter.setResourceIds(null);
                dto = solrDataManager.find(filter, 1, 20);
                solrAlbumVideoList.clear();
                solrAlbumVideoList.addAll(dto.getVideoList());
                for (int i = list.size(); i < 4; i++) {
                    if (solrAlbumVideoList.size() > 0) {
                        int p = (int) (Math.random() * solrAlbumVideoList.size());
                        SolrAlbumVideo solrAlbumVideo = solrAlbumVideoList.get(p);
                        list.add(VideoInfoFactory.create(solrAlbumVideo));
                        solrAlbumVideoList.remove(p);
                    }
                }
            }


            JSONObject object = new JSONObject();
            object.put("count", list.size() + "");
            JSONArray array = new JSONArray();

            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 guessLike(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {

        String videoId = request.getParameter("VideoId");
        if (!NumberUtil.isNumeric(videoId)) {
            guessLikeForInternetSearch(acceptData, videoId, out);
            return;
        }

        DetailSystem ds = systemService.getDetailSystemByPackage(acceptData.getPackageName());

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion());
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion());
        List<VideoInfo> list1 = StringUtil.isNullOrEmpty(videoId)
                ? recommendService.guessLikeList(ds.getId(), 4, resourceList, CacheUtil.getMD5Long(resourceList))
                : recommendService.guessLikeList(ds.getId(), 4, videoId, resourceList,
@@ -467,7 +530,7 @@
            list1 = videoInfoService.simpleRandomVideoList(4);
        }

        List<VideoInfo> list = new ArrayList<VideoInfo>();
        List<VideoInfo> list = new ArrayList<>();
        list.addAll(list1);

        if ("android".equalsIgnoreCase(acceptData.getPlatform()) && acceptData.getVersion() < 35) {
@@ -626,6 +689,39 @@

    }


    private void getRelativeVideosForInternetSearch(AcceptData acceptData, String videoId, PrintWriter out) {
        InternetSearchVideo internetSearchVideo = internetSearchVideoService.selectByPrimaryKey(videoId);
        if (internetSearchVideo != null) {
            SolrVideoSearchFilter filter = new SolrVideoSearchFilter();
            filter.setKey(internetSearchVideo.getName());
            filter.setFuzzy(true);
            SolrResultDTO dto = solrDataManager.find(filter, 1, 20);
            List<SolrAlbumVideo> solrAlbumVideoList = new ArrayList<>();
            solrAlbumVideoList.addAll(dto.getVideoList());
            List<VideoInfo> list = new ArrayList<>();
            for (int i = 0; i < 4; i++) {
                if (i < solrAlbumVideoList.size()) {
                    SolrAlbumVideo solrAlbumVideo = solrAlbumVideoList.get(i);
                    list.add(VideoInfoFactory.create(solrAlbumVideo));
                }
            }


            JSONObject object = new JSONObject();
            object.put("count", list.size() + "");
            JSONArray array = new JSONArray();

            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()));
        }

    }

    /**
     * 相关视频
     *
@@ -639,7 +735,12 @@
            return;
        }

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion());
        if (!NumberUtil.isNumeric(videoId)) {
            getRelativeVideosForInternetSearch(acceptData, videoId, out);
            return;
        }

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion());

        DetailSystem ds = systemService.getDetailSystemByPackage(acceptData.getPackageName());
        List<VideoInfo> list = recommendService.getRelativeVideoList(ds.getId(), 4, videoId, resourceList,
@@ -678,7 +779,7 @@
            return;
        }

        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getPlatform(), acceptData.getVersion());
        List<Long> resourceList = videoResouceUtil.getAvailableResourceIds(acceptData.getDetailSystem(), acceptData.getVersion());

        DetailSystem ds = systemService.getDetailSystemByPackage(acceptData.getPackageName());
        List<VideoInfo> list1 = recommendService.peopleSee(ds.getId(), 4, videoId, resourceList,
@@ -687,7 +788,7 @@
            list1 = videoInfoService.simpleRandomVideoList(4);
        }

        List<VideoInfo> list = new ArrayList<VideoInfo>();
        List<VideoInfo> list = new ArrayList<>();
        list.addAll(list1);

        if ("android".equalsIgnoreCase(acceptData.getPlatform()) && acceptData.getVersion() < 35) {
@@ -721,6 +822,7 @@
        String pwd = request.getParameter("Pwd");// 密码
        String nickName = request.getParameter("NickName");// 昵称
        String code = request.getParameter("VerifyCode");// 验证码
        String portrait = request.getParameter("Portrait");// 验证码


        if (StringUtil.isNullOrEmpty(account)) {
@@ -753,24 +855,22 @@
        if (StringUtil.isNullOrEmpty(nickName))
            nickName = "无名氏";

        DetailSystem ds = systemService.getDetailSystemByPackage(acceptData.getPackageName());
        // 注册 --用户名,昵称,密码
        LoginUser user = new LoginUser();
        user.setCreatetime(System.currentTimeMillis() + "");
        user.setDetailsystem(ds.getId());
        user.setDevice(acceptData.getDevice());
        user.setLoginType(3);
        user.setName(nickName);
        user.setOpenid(account);
        user.setPwd(StringUtil.Md5(pwd));
        user.setPortrait(savePortrait(request));
        user.setIpinfo(ip + ":" + port);

        String result = userService.registerByEmail(user);
        if (result.contains("成功"))
        LoginInfoDto loginInfoDto = new LoginInfoDto();
        loginInfoDto.setEmail(account);
        loginInfoDto.setSystemId(acceptData.getDetailSystem().getSystem().getId());
        loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_EMAIL);
        loginInfoDto.setPwd(StringUtil.Md5(pwd));
        loginInfoDto.setIpInfo(ip + ":" + port);
        loginInfoDto.setNickName(nickName);


        try {
            userService.register(loginInfoDto);
            out.print(JsonUtil.loadTrueJson("注册成功"));
        else
            out.print(JsonUtil.loadFalseJson(result));
        } catch (RegisterUserException e) {
            out.print(JsonUtil.loadFalseJson(e.getMessage()));
        }
    }

    /**
@@ -827,17 +927,17 @@
        // systemService.getDetailSystemByPackage(packageName);
        // 注册 --用户名,昵称,密码

        LoginUser user = new LoginUser();
        user.setDevice(acceptData.getDevice());
        user.setLoginType(3);
        user.setOpenid(account);
        user.setPwd(StringUtil.Md5(pwd));
        user.setPortrait("http://buwan-1255749512.file.myqcloud.com/resource/ic_portrait_default.png");
        user = userService.loginByEmail(user);
        if (user == null || user.getState() != LoginUser.STATE_NORMAL)
            out.print(JsonUtil.loadFalseJson("账号或密码错误"));
        else
        LoginInfoDto loginInfoDto = new LoginInfoDto();
        loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_EMAIL);
        loginInfoDto.setSystemId(acceptData.getDetailSystem().getSystem().getId());
        loginInfoDto.setEmail(account);
        loginInfoDto.setPwd(StringUtil.Md5(pwd));
        try {
            LoginUser user = userService.login(loginInfoDto);
            out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(user)));
        } catch (LoginUserException e) {
            out.print(JsonUtil.loadFalseJson(e.getMessage()));
        }
    }

    /**
@@ -852,6 +952,7 @@
        String birthDay = request.getParameter("BirthDay");// 生日
        String personalSign = request.getParameter("PersonalSign");// 个性签名
        String loginUid = request.getParameter("LoginUid");// 个性签名
        String portrait = request.getParameter("Portrait");
        if (StringUtil.isNullOrEmpty(loginUid)) {
            out.print(JsonUtil.loadFalseJson("请上传LoginUid"));
            return;
@@ -862,7 +963,7 @@
        if (user != null) {
            if (!StringUtil.isNullOrEmpty(nickName))
                user.setName(nickName);
            String potrait = savePortrait(request);
            String potrait = savePortrait(portrait, request.getSession());
            if (!StringUtil.isNullOrEmpty(potrait))
                user.setPortrait(potrait);
            if (!StringUtil.isNullOrEmpty(sex))
@@ -972,16 +1073,15 @@

    }

    private String savePortrait(HttpServletRequest request) {
        String base64 = request.getParameter("Portrait");
    public static String savePortrait(String base64, HttpSession session) {
        if (StringUtil.isNullOrEmpty(base64))
            return "";

        String fileName = "portrait_" + System.currentTimeMillis() + ".jpg";
        // 定义上传路径
        String path = request.getSession().getServletContext().getRealPath("upload") + "/" + fileName;
        if (!new File(request.getSession().getServletContext().getRealPath("upload") + "/").exists())
            new File(request.getSession().getServletContext().getRealPath("upload") + "/").mkdirs();
        String path = session.getServletContext().getRealPath("upload") + "/" + fileName;
        if (!new File(session.getServletContext().getRealPath("upload") + "/").exists())
            new File(session.getServletContext().getRealPath("upload") + "/").mkdirs();
        boolean isS = StringUtil.generateImageFromBase64(base64, path);
        if (!isS)
            return "";