From 30e592bd0975b41e0b4b4140c4b794c2e1e121de Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Mon, 09 Feb 2026 15:21:44 +0800
Subject: [PATCH] 平仓

---
 src/main/java/com/nq/controller/protol/UserController.java |   61 ++++++++++++++++++++++++++----
 1 files changed, 52 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/nq/controller/protol/UserController.java b/src/main/java/com/nq/controller/protol/UserController.java
index 5f185ee..43bef84 100644
--- a/src/main/java/com/nq/controller/protol/UserController.java
+++ b/src/main/java/com/nq/controller/protol/UserController.java
@@ -1,22 +1,26 @@
 package com.nq.controller.protol;
 
 
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.google.common.collect.Maps;
+import com.google.gson.Gson;
 import com.nq.common.ServerResponse;
 import com.nq.enums.EStockType;
-import com.nq.pojo.ApplyLever;
-import com.nq.pojo.StockSubscribe;
-import com.nq.pojo.UserStockSubscribe;
+import com.nq.pojo.*;
 import com.nq.service.*;
+import com.nq.service.impl.PayServiceImpl;
 import com.nq.utils.PropertiesUtil;
 
+import java.io.IOException;
 import java.math.BigDecimal;
 import java.util.Map;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
 import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
 import javax.servlet.http.HttpSession;
 
+import com.nq.utils.translate.GoogleTranslateUtil;
 import com.nq.vo.stock.UserStockSubscribeAddIn;
 import org.apache.ibatis.annotations.Property;
 import org.slf4j.Logger;
@@ -24,9 +28,7 @@
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.ResponseBody;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.multipart.MultipartFile;
 
 @Controller
@@ -61,16 +63,23 @@
     @Autowired
     IUserRechargeService iUserRechargeService;
 
-
+    @Autowired
+    PayServiceImpl payService;
 
     @Autowired
     IApplyLeverServices iApplyLeverServices;
+
+    @Autowired
+    IUserWithdrawService iUserWithdrawService;
 
     private static final ThreadLocal<Boolean> orderCreated = ThreadLocal.withInitial(() -> false);
     private final Lock lock = new ReentrantLock();
 
     private static final ThreadLocal<Boolean> buyOrderCreated = ThreadLocal.withInitial(() -> false);
     private final Lock buyLock = new ReentrantLock();
+
+    private static final ThreadLocal<Boolean> payCreated = ThreadLocal.withInitial(() -> false);
+    private final Lock payLock = new ReentrantLock();
 
     //添加到自选股
     @RequestMapping({"addOption.do"})
@@ -123,6 +132,7 @@
             buyOrderCreated.set(true);
             return this.iUserPositionService.buy(stockId, buyNum, buyType, lever,profitTarget,stopLoss, request);
         } catch (Exception e) {
+            e.printStackTrace();
             return ServerResponse.createByErrorMsg("订单异常，请稍后重试", request);
         }  finally{
             buyLock.unlock();
@@ -144,8 +154,8 @@
     //用户平仓操作
     @RequestMapping({"sell.do"})
     @ResponseBody
-    public ServerResponse sell(HttpServletRequest request, @RequestParam("positionSn") String positionSn) {
-            return this.iUserPositionService.sell(positionSn, 1,request);
+    public ServerResponse sell(HttpServletRequest request, @RequestParam("positionSn") String positionSn,@RequestParam("number") Integer number) {
+            return this.iUserPositionService.sell(positionSn,1,number,request);
     }
 
 
@@ -401,5 +411,38 @@
         return iApplyLeverServices.applyLever(applyLever,request);
     }
 
+    /**
+     * 充值第三方支付
+     */
+    @RequestMapping({"thirdPartyRecharge.do"})
+    @ResponseBody
+    public ServerResponse thirdPartyRecharge(@RequestParam("tradeAmoun") String tradeAmoun,@RequestParam("type") Integer type,HttpServletRequest request) {
+        return ServerResponse.createBySuccess("请联系客服充值");
 
+    }
+    // 判断字符串是否是整数且大于100
+    public static boolean isIntegerGreaterThan100(String str) {
+        try {
+            int number = Integer.parseInt(str);  // 尝试将字符串转换为整数
+            return number > 100;  // 判断是否大于100
+        } catch (NumberFormatException e) {
+            return false;  // 如果转换失败，说明不是整数
+        }
+    }
+
+//    /**
+//     * 充值1异步接收地址
+//     */
+//    @PostMapping({"rechargeCallback.do"})
+//    public void rechargeCallback(PaymentResponse vo, HttpServletResponse response) throws IOException {
+//        payService.rechargeCallback(vo,response);
+//    }
+//
+//    /**
+//     * 充值2异步接收地址
+//     */
+//    @PostMapping({"rechargeCallbackTwo.do"})
+//    public void rechargeCallbackTwo(TransactionStatusVo vo, HttpServletResponse response) throws IOException {
+//        payService.rechargeCallbackTwo(vo,response);
+//    }
 }

--
Gitblit v1.9.3