| | |
| | | import com.yami.trading.service.contract.ContractApplyOrderService; |
| | | import com.yami.trading.service.contract.ContractLockService; |
| | | import com.yami.trading.service.contract.ContractOrderService; |
| | | import com.yami.trading.service.contract.ContractPositionModeService; |
| | | import com.yami.trading.service.data.DataService; |
| | | import com.yami.trading.service.item.ItemLeverageService; |
| | | import com.yami.trading.service.item.ItemService; |
| | |
| | | private ContractOrderService contractOrderService; |
| | | |
| | | @Autowired |
| | | private ContractPositionModeService contractPositionModeService; |
| | | |
| | | @Autowired |
| | | private ContractLockService contractLockService; |
| | | @Autowired |
| | | private SessionTokenService sessionTokenService; |
| | |
| | | data.put("contract_open_limit_min", contractOpenLimitMin); |
| | | BigDecimal contractOpenLimitMax = new BigDecimal(sysparaService.find("contract_open_limit_max").getSvalue()); |
| | | data.put("contract_open_limit_max", contractOpenLimitMax); |
| | | data.put("contract_position_mode", contractPositionModeService.getMode()); |
| | | |
| | | |
| | | return Result.succeed(data); |
| | | |
| | |
| | | lockAcquired = rLock.tryLock(5, TimeUnit.SECONDS); |
| | | if (!lockAcquired) { |
| | | log.warn("无法获取锁: contract_open_{}", partyId); |
| | | throw new YamiShopBindException("请稍后再试"); |
| | | throw new YamiShopBindException("Please try again later"); |
| | | } |
| | | //判断下单金额是否符合最低金额 最低下单张数:0.01 |
| | | //合约张数 张数=保证金*杠杆倍数/(面值*最新成交价) |
| | |
| | | if (amount.compareTo(new BigDecimal(faceValue)) < 0) { |
| | | double minimumAmount = minAmount * faceValue * openAction.getPrice().doubleValue() / openAction.getLever_rate().doubleValue(); |
| | | double roundedAmount = Math.ceil(minimumAmount * 10000) / 10000; |
| | | throw new YamiShopBindException("最低下单金额:"+roundedAmount); |
| | | throw new YamiShopBindException("Minimum order amount: " + roundedAmount); |
| | | } |
| | | |
| | | // 校验当前用户订单状态 |
| | |
| | | throw e; // 重新抛出自定义异常 |
| | | } catch (Exception e) { |
| | | log.error("系统异常: {}", e.getMessage(), e); |
| | | throw new YamiShopBindException("操作失败,请稍后再试"); |
| | | throw new YamiShopBindException("Operation failed, please try again later"); |
| | | } finally { |
| | | // 确保释放锁 |
| | | if (lockAcquired && rLock.isHeldByCurrentThread()) { |
| | |
| | | String[] stopUsers = stopUserInternet.split(","); |
| | | User user = userService.getById(partyId); |
| | | if (Arrays.asList(stopUsers).contains(user.getUserName())) { |
| | | throw new YamiShopBindException("无网络"); |
| | | throw new YamiShopBindException("No network connection"); |
| | | } |
| | | } |
| | | } |
| | |
| | | RLock rLock = redissonClient.getLock("contract_close_" + partyId); |
| | | boolean lockResult = rLock.tryLock(5, TimeUnit.SECONDS); |
| | | if (!lockResult) { |
| | | throw new YamiShopBindException("请稍后再试"); |
| | | throw new YamiShopBindException("Please try again later"); |
| | | } |
| | | try { |
| | | User user = userService.getById(partyId); |
| | |
| | | System.out.println("stopUserInternet = " + stopUserInternet); |
| | | |
| | | if(Arrays.asList(stopUsers).contains(user.getUserName())){ |
| | | throw new YamiShopBindException("无网络"); |
| | | throw new YamiShopBindException("No network connection"); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | ContractApplyOrder order = this.contractApplyOrderService.findByOrderNo(order_no); |
| | | if (order == null) { |
| | | throw new YamiShopBindException("委托单不存在"); |
| | | throw new YamiShopBindException("Order does not exist"); |
| | | } |
| | | Map<String, Object> map = new HashMap<String, Object>(); |
| | | map.put("order_no", order.getOrderNo()); |
| | |
| | | |
| | | } catch (Exception e) { |
| | | log.error("执行撤单异常", e); |
| | | throw new YamiShopBindException("执行撤单异常"); |
| | | throw new YamiShopBindException("Failed to cancel order"); |
| | | } |
| | | |
| | | return Result.succeed(null,"success"); |
| | |
| | | |
| | | } catch (Exception e) { |
| | | log.error("执行撤单异常", e); |
| | | throw new YamiShopBindException("执行撤单异常"); |
| | | throw new YamiShopBindException("Failed to cancel order"); |
| | | } |
| | | |
| | | return Result.succeed(null,"success"); |
| | |
| | | Page<ContractApplyOrder> result = contractApplyOrderService.findList(page, SecurityUtils.getUser().getUserId(), type, symbolType); |
| | | List<ContractApplyOrder> datas = result.getRecords(); |
| | | if (!StringUtils.isInteger(page_no)) { |
| | | throw new YamiShopBindException("页码不是整数"); |
| | | throw new YamiShopBindException("Page number must be an integer"); |
| | | } |
| | | if (Integer.valueOf(page_no).intValue() <= 0) { |
| | | throw new YamiShopBindException("页码不能小于等于0"); |
| | | throw new YamiShopBindException("Page number must be greater than 0"); |
| | | } |
| | | Long count = 0L; |
| | | |