平仓

zyy

2026-02-09 30e592bd0975b41e0b4b4140c4b794c2e1e121de

 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"})
@@ -145,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);
    }


@@ -402,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);
//    }
}