签章

peter

2026-01-10 d3b5fbde186a47c0dc8b0b58d5688ae5691ed9e6

 src/main/java/com/nq/service/impl/UserServiceImpl.java

@@ -11,6 +11,7 @@
import com.nq.pojo.*;
import com.nq.service.*;
import com.nq.utils.DateTimeUtil;
import com.nq.utils.KeyUtils;
import com.nq.utils.PropertiesUtil;
import com.nq.utils.SymmetricCryptoUtil;
import com.nq.utils.ip.IpUtils;
@@ -111,7 +112,7 @@

    public ServerResponse reg(String yzmCode, String agentCode, String phone, String userPwd, HttpServletRequest request) {
        if (StringUtils.isBlank(agentCode) || StringUtils.isBlank(phone) ||
                StringUtils.isBlank(userPwd) || StringUtils.isBlank(yzmCode))
                StringUtils.isBlank(userPwd))
        {
            return ServerResponse.createByErrorMsg("注册失败, 参数不能为空");
        }
@@ -156,7 +157,7 @@
        String uip = IpUtils.getIp(request);
        user.setRegIp(uip);
        String uadd = JuheIpApi.ip2Add(uip);
        user.setRegAddress(uadd);
//        user.setRegAddress(uadd);

        user.setIsLogin(Integer.valueOf(0));

@@ -178,12 +179,28 @@
        int insertCount = this.userMapper.insert(user);

        if (insertCount > 0) {
            //用户注册成功重新代理机构码重新生成
            String newAgentCode = generateUniqueAgentCode();
            agentUser.setAgentCode(newAgentCode);
            iAgentUserService.updateAgentCode(agentUser);
            log.info("用户注册成功 手机 {} , ip = {} 地址 = {}", new Object[] { phone, uip, uadd });
            return ServerResponse.createBySuccessMsg("注册成功.请登录");
        }
        return ServerResponse.createBySuccessMsg("注册出错, 请重试");
    }

    public String generateUniqueAgentCode() {
        // 生成新的 agent code
        String newAgentCode = KeyUtils.getAgentUniqueKey();

        // 如果找到重复的 agent code，则递归重新生成
        if (iAgentUserService.findByCode(newAgentCode) != null) {
            return generateUniqueAgentCode();  // 递归调用
        }

        // 返回唯一的 agent code
        return newAgentCode;
    }


    public ServerResponse login(String phone, String userPwd, HttpServletRequest request) {
@@ -212,6 +229,25 @@
        String property = PropertiesUtil.getProperty("user.cookie.name");
//        System.out.println(property);
        String loginToken = request.getHeader(property);
        
        // 如果header中没有token，尝试从cookie获取
        if (loginToken == null) {
            javax.servlet.http.Cookie[] cookies = request.getCookies();
            if (cookies != null) {
                for (javax.servlet.http.Cookie cookie : cookies) {
                    if (property != null && property.equals(cookie.getName())) {
                        loginToken = cookie.getValue();
                        break;
                    }
                }
            }
        }
        
        // 如果cookie中也没有token，尝试从URL参数获取（用于iframe等场景）
        if (loginToken == null) {
            loginToken = request.getParameter("token");
        }
        
        if (loginToken == null) {
            return null;
        }
@@ -445,6 +481,16 @@
            return ServerResponse.createByErrorMsg("修改失败");
        }

    @Override
    public void updateSignedContract(Integer userId, String signedContract) {
        this.userMapper.updateSignedContract(userId,signedContract);
    }
    @Override
    public void updateSignedAgreement(Integer userId, String signedAgreement) {
        this.userMapper.updateSignedAgreement(userId,signedAgreement);
    }


    @Transactional
    @Override
    public ServerResponse exchangeOp(BigDecimal amt, Integer type, HttpServletRequest request) throws Exception {
@@ -545,8 +591,8 @@
    }


    public ServerResponse auth(String realName, String idCard, String img1key, String img2key, String img3key, HttpServletRequest request) {
        if (StringUtils.isBlank(realName) || StringUtils.isBlank(idCard)){
    public ServerResponse auth(String realName, String idCard, String address, String img1key, String img2key, String img3key, HttpServletRequest request) {
        if (StringUtils.isBlank(realName) || StringUtils.isBlank(idCard) || StringUtils.isBlank(address)){
//                StringUtils.isBlank(img1key) ||
//                StringUtils.isBlank(img2key))
            return ServerResponse.createByErrorMsg("参数不能为空");
@@ -565,6 +611,7 @@
        user.setNickName(realName);
        user.setRealName(realName);
        user.setIdCard(idCard);
        user.setRegAddress(address);

        user.setImg1Key(img1key);
        user.setImg2Key(img2key);
@@ -1820,14 +1867,30 @@
//        BigDecimal userAllAmt = user.getUserAmt();
        BigDecimal userAllAmt = user.getEnableAmt();
        userAllAmt = userAllAmt.add(allProfitAndLose);
        userInfoVO.setUserAmt(userAllAmt);


        userInfoVO.setEnableIndexAmt(user.getEnableIndexAmt());
        userInfoVO.setEnaleWithdrawAmt(user.getEnaleWithdrawAmt());
        userInfoVO.setIsSignedContract(user.getIsSignedContract());
        userInfoVO.setIsSignedAgreement(user.getIsSignedAgreement());
        userInfoVO.setHkAmt(user.getHkAmt());

        BigDecimal historyProfitLoss = new BigDecimal(0);
        List<UserPosition> userPositions = this.userPositionMapper.findMyPositionByCodeAndSpell(user.getId(), "", "", 1);
        BigDecimal buyAmtAutual = new BigDecimal(0);
        List<UserPosition> userPositionscc = this.userPositionMapper.findMyPositionByCodeAndSpell(user.getId(), "", "", 1);

        if (userPositionscc.size() > 0) {
            for (UserPosition position : userPositionscc) {
                buyAmtAutual = buyAmtAutual.add(position.getBuyOrderPrice()
                        .multiply(new BigDecimal(position.getOrderNum()))
                        .divide(new BigDecimal(position.getOrderLever()), 2, RoundingMode.HALF_UP));
            }
        }
        userInfoVO.setBuyAmtAutual(buyAmtAutual);
        userAllAmt = userAllAmt.add(buyAmtAutual);
        userInfoVO.setUserAmt(userAllAmt);

        List<UserPosition> userPositions = this.userPositionMapper.findMyPositionByCodeAndSpell(user.getId(), "", "", 2);

        if (userPositions.size() > 0) {
            for (UserPosition position : userPositions) {
@@ -1916,7 +1979,8 @@
        if (position.getSellOrderId() != null) {

            BigDecimal subPrice = position.getSellOrderPrice().subtract(position.getBuyOrderPrice());
            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).multiply(new BigDecimal(position.getOrderLever())).setScale(2,4);
//            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).multiply(new BigDecimal(position.getOrderLever())).setScale(2,4);
            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).setScale(2,4);
            if ("买跌".equals(position.getOrderDirection())) {
                profitAndLose = profitAndLose.negate();
            }
@@ -1937,7 +2001,8 @@
            }

            BigDecimal subPrice = (new BigDecimal(nowPrice)).subtract(position.getBuyOrderPrice());
            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).multiply(new BigDecimal(position.getOrderLever())).setScale(2,4);
//            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).multiply(new BigDecimal(position.getOrderLever())).setScale(2,4);
            profitAndLose = subPrice.multiply(new BigDecimal(position.getOrderNum().intValue())).setScale(2,4);
            if ("买跌".equals(position.getOrderDirection())) {
                profitAndLose = profitAndLose.negate();
            }