| | |
| | | return ServerResponse.createBySuccessMsg("平仓成功!", request); |
| | | } |
| | | |
| | | @Transactional |
| | | @Override |
| | | public ServerResponse allSell(HttpServletRequest request, String stockType) throws Exception { |
| | | //判断股票是否在可交易时间段 |
| | | public ServerResponse allSell(HttpServletRequest request) throws Exception { |
| | | User user = iUserService.getCurrentUser(request); |
| | | QueryWrapper<UserPosition> queryWrapper = new QueryWrapper<>(); |
| | | queryWrapper.eq("user_id", user.getId()); |
| | | queryWrapper.isNull("sell_order_id"); |
| | | |
| | | List<UserPosition> userPositionList = userPositionMapper.selectList(queryWrapper); |
| | | for (int i = 0; i < userPositionList.size(); i++) { |
| | | sell(userPositionList.get(i).getPositionSn(), 0); |
| | | |
| | | // 如果没有需要平仓的持仓 |
| | | if (userPositionList.isEmpty()) { |
| | | return ServerResponse.createBySuccessMsg("没有需要平仓的持仓订单"); |
| | | } |
| | | return ServerResponse.createBySuccessMsg("平仓成功!"); |
| | | |
| | | // 收集所有提示信息 |
| | | List<String> successMessages = new ArrayList<>(); |
| | | List<String> errorMessages = new ArrayList<>(); |
| | | |
| | | for (UserPosition position : userPositionList) { |
| | | ServerResponse response = sell(position.getPositionSn(), 0, position.getOrderNum(), request); |
| | | |
| | | if (response.getStatus() == 0) { |
| | | // 失败的情况 |
| | | errorMessages.add("订单号:" + position.getPositionSn() + " 失败,原因:" + response.getMsg()); |
| | | } |
| | | } |
| | | |
| | | // 根据是否有错误返回不同的状态 |
| | | if (!errorMessages.isEmpty()) { |
| | | return ServerResponse.createByErrorMsg(errorMessages.toString(), request); |
| | | } else { |
| | | return ServerResponse.createBySuccessMsg("平仓成功!", request); |
| | | } |
| | | } |
| | | |
| | | //用户追加保证金操作 |