IOS广告增加区域屏蔽

admin

2025-02-20 f537abe9f3646c739beaf15076246a2f71a347e9

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

@@ -1,6 +1,7 @@
package com.yeshi.buwan.controller.parser;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;
import com.google.gson.reflect.TypeToken;
import com.yeshi.buwan.domain.Collection;
import com.yeshi.buwan.domain.*;
@@ -15,6 +16,7 @@
import com.yeshi.buwan.dto.search.SolrShortVideoSearchFilter;
import com.yeshi.buwan.dto.search.SolrVideoSearchFilter;
import com.yeshi.buwan.dto.user.LoginInfoDto;
import com.yeshi.buwan.dto.user.QQUserInfo;
import com.yeshi.buwan.exception.SMSException;
import com.yeshi.buwan.exception.user.LoginUserException;
import com.yeshi.buwan.exception.user.RegisterUserException;
@@ -22,6 +24,7 @@
import com.yeshi.buwan.service.inter.SMSService;
import com.yeshi.buwan.service.inter.juhe.InternetSearchVideoService;
import com.yeshi.buwan.service.inter.system.SystemConfigService;
import com.yeshi.buwan.service.manager.IPManager;
import com.yeshi.buwan.service.manager.search.SolrAlbumVideoDataManager;
import com.yeshi.buwan.service.manager.search.SolrInternetSearchVideoDataManager;
import com.yeshi.buwan.service.manager.search.SolrShortVideoDataManager;
@@ -32,9 +35,11 @@
import com.yeshi.buwan.util.factory.vo.UserInfoVOFactory;
import com.yeshi.buwan.util.log.LoggerUtil;
import com.yeshi.buwan.util.log.UserActiveLogFactory;
import com.yeshi.buwan.util.login.QQLoginUtil;
import com.yeshi.buwan.util.video.VideoCategoryConstant;
import com.yeshi.buwan.util.video.VideoConstant;
import com.yeshi.buwan.util.video.VideoUtil;
import com.yeshi.buwan.util.wx.MyWXLoginUtil;
import com.yeshi.buwan.videos.pptv.PPTVUtil;
import com.yeshi.buwan.vo.AcceptData;
import com.yeshi.buwan.vo.video.VideoListResultVO;
@@ -43,6 +48,7 @@
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.yeshi.utils.entity.wx.WeiXinUser;
import org.yeshi.utils.exception.MailSendException;
import org.yeshi.utils.mail.EmailApiUtil;
import org.yeshi.utils.mail.EmailInfo;
@@ -62,6 +68,8 @@
    Logger searchKeyLogger = LoggerFactory.getLogger("searchKey");

    Logger logger = LoggerFactory.getLogger(UserParser.class);

    Logger deviceGeoLogger = LoggerFactory.getLogger("deviceGeo");


    @Resource
@@ -104,6 +112,12 @@

    @Resource
    private SMSService smsService;

    @Resource
    DetailSystemConfigService detailSystemConfigService;

    @Resource
    private IPManager ipManager;

    public void getUid(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {
        DetailSystem detailSystem = systemService.getDetailSystemByPackage(acceptData.getPackageName());
@@ -841,7 +855,18 @@
    public void getUserInfo(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {
        UserData data = userService.getUserData(acceptData.getUid());
        out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(data)));

        // 记录日志
        try {
//            if(!"appstore".equalsIgnoreCase(acceptData.getChannel())) {
                String ip = IPUtil.getRemotIP(request);
                IPUtil.IPInfo ipInfo = ipManager.getIPInfo(ip);
                if (ipInfo != null) {
                    deviceGeoLogger.info("用户信息(uid-{})-IP归属地 IP-{},版本-{}, 渠道-{}，省-{}， 市-{}",acceptData.getUid(), ip, acceptData.getVersion(), acceptData.getChannel(), ipInfo.getProvince(), ipInfo.getCity());
                }
//            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @RequireUid
@@ -1146,13 +1171,13 @@
            return;
        }

        if (!StringUtil.isNullOrEmpty(account) && !account.trim().endsWith("@qq.com")) {
        if (!StringUtil.isNullOrEmpty(account) && !account.trim().endsWith("@qq.com") && !acceptData.getPackage().equalsIgnoreCase("com.yeshi.buwanshequ.ios")) {
            out.print(JsonUtil.loadFalseJson("只支持QQ邮箱注册"));
            return;
        }

        int port = request.getRemotePort();
        String ip = getIp(request);
        String ip = IPUtil.getRemotIP(request);

        if (StringUtil.isNullOrEmpty(nickName))
            nickName = "无名氏";
@@ -1188,7 +1213,7 @@
            out.print(JsonUtil.loadFalseJson("请上传Email"));
            return;
        }
        if (!StringUtil.isNullOrEmpty(account) && !account.trim().endsWith("@qq.com")) {
        if (!StringUtil.isNullOrEmpty(account) && !account.trim().endsWith("@qq.com") && !acceptData.getPackage().equalsIgnoreCase("com.yeshi.buwanshequ.ios")) {
            out.print(JsonUtil.loadFalseJson("只支持QQ邮箱注册"));
            return;
        }
@@ -1265,33 +1290,121 @@
     * @param out
     */
    public void login(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {
        String account = request.getParameter("Email");// 邮箱
        String pwd = request.getParameter("Pwd");// 密码
        if (StringUtil.isNullOrEmpty(account)) {
            out.print(JsonUtil.loadFalseJson("请上传Email"));
            return;
        String loginType = request.getParameter("LoginType");
        int logintTypeInt = LoginUser.LOGIN_TYPE_EMAIL;
        if (!StringUtil.isNullOrEmpty(loginType)) {
            logintTypeInt = Integer.parseInt(loginType);
        }

        if (StringUtil.isNullOrEmpty(pwd)) {
            out.print(JsonUtil.loadFalseJson("请上传Pwd"));
            return;
        }

        // DetailSystem ds =
        // systemService.getDetailSystemByPackage(packageName);
        // 注册 --用户名,昵称,密码

        LoginInfoDto loginInfoDto = new LoginInfoDto();
        loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_EMAIL);
        loginInfoDto.setSystemId(acceptData.getDetailSystem().getSystem().getId());
        loginInfoDto.setEmail(account);
        loginInfoDto.setPwd(StringUtil.Md5(pwd));
        loginInfoDto.setIpInfo(IPUtil.getRemotIP(request) + ":" + request.getRemotePort());
        switch (logintTypeInt) {
            case LoginUser.LOGIN_TYPE_EMAIL: {
                String account = request.getParameter("Email");// 邮箱
                String pwd = request.getParameter("Pwd");// 密码
                if (StringUtil.isNullOrEmpty(account)) {
                    out.print(JsonUtil.loadFalseJson("请上传Email"));
                    return;
                }

                if (StringUtil.isNullOrEmpty(pwd)) {
                    out.print(JsonUtil.loadFalseJson("请上传Pwd"));
                    return;
                }
                loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_EMAIL);
                loginInfoDto.setSystemId(acceptData.getDetailSystem().getSystem().getId());
                loginInfoDto.setEmail(account);
                loginInfoDto.setPwd(StringUtil.Md5(pwd));
            }
            break;
            case LoginUser.LOGIN_TYPE_PHONE: {
                String account = request.getParameter("Phone");// 邮箱
                String pwd = request.getParameter("Pwd");// 密码
                if (StringUtil.isNullOrEmpty(account)) {
                    out.print(JsonUtil.loadFalseJson("请上传电话号码"));
                    return;
                }

                if (StringUtil.isNullOrEmpty(pwd)) {
                    out.print(JsonUtil.loadFalseJson("请上传密码"));
                    return;
                }
                loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_PHONE);
                loginInfoDto.setPhone(account);
                loginInfoDto.setPwd(StringUtil.Md5(pwd));

            }
            break;
            case LoginUser.LOGIN_TYPE_QQ: {
                String accessToken = request.getParameter("AccessToken");
                String openId = request.getParameter("OpenId");
                if (StringUtil.isNullOrEmpty(accessToken) || StringUtil.isNullOrEmpty(openId)) {
                    out.print(JsonUtil.loadFalseJson("请上传QQ授权信息"));
                    return;
                }

                String qqAppId = detailSystemConfigService.getConfigValueByKey("qq_app_id", acceptData.getDetailSystem().getId(), acceptData.getVersion());
                if (StringUtil.isNullOrEmpty(qqAppId)) {
                    out.print(JsonUtil.loadFalseJson("QQ APPID获取出错"));
                    return;
                }
                QQLoginUtil.QQUserInfoEntity userEntity = QQLoginUtil.getUserInfo(qqAppId.trim(), accessToken, openId);
                if (userEntity == null) {
                    out.print(JsonUtil.loadFalseJson("QQ用户信息解析出错"));
                    return;
                }

                QQUserInfo userInfo = new QQUserInfo();
                userInfo.setSex(userEntity.getGender());
                userInfo.setPortrait(userEntity.getFigureurl());
                userInfo.setOpenId(openId);
                userInfo.setName(userEntity.getNickname());
                loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_QQ);
                loginInfoDto.setQqUserInfo(userInfo);
            }
            break;
            case LoginUser.LOGIN_TYPE_WX: {
                String code = request.getParameter("Code");
                if (StringUtil.isNullOrEmpty(code)) {
                    out.print(JsonUtil.loadFalseJson("请上传微信授权码"));
                    return;
                }

                WeiXinUser weiXinUser = MyWXLoginUtil.getUserInfo(code, MyWXLoginUtil.WEIXIN_APPID, MyWXLoginUtil.WEIXIN_SECRET);
                if (weiXinUser == null) {
                    out.print(JsonUtil.loadFalseJson("获取授权信息失败,请稍后再试"));
                    return;
                }
                loginInfoDto.setLoginType(LoginUser.LOGIN_TYPE_WX);
                loginInfoDto.setWeiXinUser(weiXinUser);
            }
            break;
            default:
                out.print(JsonUtil.loadFalseJson("登录方式错误"));
                return;
        }

        try {
            LoginUser user = userService.login(loginInfoDto);
            out.print(JsonUtil.loadTrueJson(StringUtil.outPutResultJson(user)));
        } catch (LoginUserException e) {
            out.print(JsonUtil.loadFalseJson(e.getMessage()));
            if ((logintTypeInt == LoginUser.LOGIN_TYPE_WX || logintTypeInt == LoginUser.LOGIN_TYPE_QQ) && e.getCode() == LoginUserException.CODE_NO_USER) {
                //注册
                try {
                    LoginUser lu = userService.register(loginInfoDto);
                    if (lu != null) {
                        JSONObject object = new JSONObject();
                        object.put("user", new GsonBuilder().excludeFieldsWithoutExposeAnnotation().create().toJson(lu));
                        out.print(JsonUtil.loadTrueJson(object.toString()));
                    } else {
                        out.print(JsonUtil.loadFalseJson("登录失败"));
                    }
                } catch (RegisterUserException e1) {
                    out.print(JsonUtil.loadFalseJson("登录失败"));
                }
            } else {
                out.print(JsonUtil.loadFalseJson(e.getMessage()));
            }
        }
    }

@@ -1381,7 +1494,7 @@
                user.setPortrait(potrait);
            if (!StringUtil.isNullOrEmpty(sex))
                user.setSex(sex);
            if (!StringUtil.isNullOrEmpty(acceptData.getSign()))
            if (!StringUtil.isNullOrEmpty(personalSign))
                user.setSign(personalSign);
            if (!StringUtil.isNullOrEmpty(birthDay))
                user.setBirthday(birthDay);
@@ -1426,6 +1539,8 @@
     * @param out
     */
    public void setPwd(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {


        String email = request.getParameter("Email");// 个性签名
        String pwd = request.getParameter("Pwd");// 密码
        String verifyCode = request.getParameter("VerifyCode");// 验证码
@@ -1451,7 +1566,7 @@
        }

        // 注册 --用户名,昵称,密码
        LoginUser user = userService.getLoginUserByOpenId(email);
        LoginUser user = userService.getValidLoginUserByEmail(email, acceptData.getDetailSystem().getSystem().getId());
        if (user == null) {
            out.print(JsonUtil.loadFalseJson("该用户不存在"));
        } else {
@@ -1495,6 +1610,7 @@
    public static String savePortrait(String base64, HttpSession session) {
        if (StringUtil.isNullOrEmpty(base64))
            return "";
        base64 = base64.replace("\r\n", "");

        String fileName = "portrait_" + System.currentTimeMillis() + ".jpg";
        // 定义上传路径
@@ -1516,47 +1632,12 @@
    }

    public void getIPInfo(AcceptData acceptData, HttpServletRequest request, PrintWriter out) {

        String ip = request.getHeader("x-forwarded-for");
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("WL-Proxy-Client-IP");
        }

        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("X-Real-IP");
        }

        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getRemoteAddr();
        }
        String ip = IPUtil.getRemotIP(request);
        try {
            out.print(ip + "-----" + new Gson().toJson(IPUtil.getLocalIPInfo(request.getRemoteAddr())));
        } catch (Exception e) {
            e.printStackTrace();
        }

    }

    public static String getIp(HttpServletRequest request) {
        String ip = request.getHeader("x-forwarded-for");
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("WL-Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("HTTP_CLIENT_IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("HTTP_X_FORWARDED_FOR");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getRemoteAddr();
        }
        return ip;
    }
}