From d3b5fbde186a47c0dc8b0b58d5688ae5691ed9e6 Mon Sep 17 00:00:00 2001
From: peter <14100000001@qq.com>
Date: Sat, 10 Jan 2026 23:46:21 +0800
Subject: [PATCH] 签章

---
 src/main/java/com/nq/service/impl/UserServiceImpl.java |   81 ++++++++++++++++++++++++++++++++++++----
 1 files changed, 73 insertions(+), 8 deletions(-)

diff --git a/src/main/java/com/nq/service/impl/UserServiceImpl.java b/src/main/java/com/nq/service/impl/UserServiceImpl.java
index 64b4d6c..8130840 100644
--- a/src/main/java/com/nq/service/impl/UserServiceImpl.java
+++ b/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();
             }

--
Gitblit v1.9.3