1

zj

2025-05-08 4130970dd61791e0a5cb0771a9b707084f1ed464

 src/main/java/com/nq/controller/protol/UserController.java

@@ -6,7 +6,9 @@
import com.google.common.collect.Maps;
import com.nq.common.ServerResponse;
import com.nq.dao.StockConfigMapper;
import com.nq.dao.UserPositionMapper;
import com.nq.enums.EStockType;
import com.nq.enums.EUserAssets;
import com.nq.pojo.*;
import com.nq.service.*;
import com.nq.utils.PropertiesUtil;
@@ -17,6 +19,7 @@
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpSession;

@@ -72,6 +75,12 @@

    @Autowired
    StockConfigMapper stockConfigMapper;

    @Autowired
    UserPositionMapper userPositionMapper;

    @Autowired
    TransactionLogService transactionLogService;

    private static final ThreadLocal<Boolean> orderCreated = ThreadLocal.withInitial(() -> false);
    private final Lock lock = new ReentrantLock();
@@ -178,10 +187,39 @@
    //用户平仓操作
    @RequestMapping({"sell.do"})
    @ResponseBody
    public ServerResponse sell(HttpServletRequest request, @RequestParam("positionSn") String positionSn,@RequestParam("number") Integer number) {
            return this.iUserPositionService.sell(positionSn,1,number,request);
    public ServerResponse sell(HttpServletRequest request, @RequestParam("positionSn") String positionSn,
                               @RequestParam("number") Integer number,
                               @RequestParam(value = "targetPrice", required = false) String targetPrice

    ) {
            return this.iUserPositionService.sell(positionSn,1,number,targetPrice,request);
    }

    //用户仓位查询
    @RequestMapping({"getPosition.do"})
    @ResponseBody
    public ServerResponse getPosition(HttpServletRequest request, @RequestParam("stock") String stock,
                                      @RequestParam("stockType") Integer stockType) {
        User user = this.iUserService.getCurrentRefreshUser(request);
        if (user == null) {
            return ServerResponse.createByErrorMsg("请重新登录",request);
        }
        LambdaQueryWrapper<UserPosition> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(UserPosition::getUserId, user.getId());
        queryWrapper.isNull(UserPosition::getSellOrderId);
        if (stockType == 1) {
            queryWrapper.eq(UserPosition::getStockName, stock);
        } else {
            queryWrapper.eq(UserPosition::getStockCode, stock);
        }
        try {
            UserPosition userPosition = userPositionMapper.selectOne(queryWrapper);
            return ServerResponse.createBySuccess(userPosition);
        }catch (Exception e){
            log.error("用户仓位查询失败",e.getMessage());
        }
        return ServerResponse.createByErrorMsg("当前产品有多个持仓方向，不支持挂单操作！",request);
    }

    //一键用户平仓操作
    @RequestMapping({"allsell.do"})
@@ -249,7 +287,15 @@
                if(ObjectUtil.isNotEmpty(userPendingorder)){
                    userPendingorder.setPositionType(2);
                }
                if(userPendingorder.getHangingOrderType() == 2){
                    userPendingorderService.updateById(userPendingorder);
                    return ServerResponse.createBySuccess("撤销挂单成功",request);
                }
                userPendingorderService.updateById(userPendingorder);
                iUserAssetsServices.availablebalanceChange(userPendingorder.getStockGid().equals("ST") ? userPendingorder.getStockGid() : "USD",
                        userPendingorder.getUserId(),
                        EUserAssets.THE_DEPOSIT_WILL_BE_RETURNED_IF_THE_ORDER_IS_CANCELLED,
                        userPendingorder.getOrderTotalPrice(), "", "");
                return ServerResponse.createBySuccess("撤销挂单成功",request);
            }
        } catch (Exception e) {
@@ -470,5 +516,10 @@
        return iApplyLeverServices.applyLever(applyLever,request);
    }


    @RequestMapping({"flowLog.do"})
    @ResponseBody
    public ServerResponse flowLog(@RequestParam(value = "page", defaultValue = "1") int page,
                                  @RequestParam(value = "pageSize", defaultValue = "100") int pageSize,HttpServletRequest request) {
        return transactionLogService.flowLog(page,pageSize,request);
    }
}