| | |
| | | return this.iUserService.getMoney(request); |
| | | } |
| | | |
| | | @RequestMapping("getWeeklyProfit.do") |
| | | @ResponseBody |
| | | public ServerResponse getWeeklyProfit( HttpServletRequest request) { |
| | | return this.iUserService.getWeeklyProfit(request); |
| | | } |
| | | |
| | | //查询用户自选股 |
| | | @RequestMapping({"queryMyOption.do"}) |
| | | @ResponseBody |
| | |
| | | @RequestParam("buyType") Integer buyType, |
| | | @RequestParam("lever") Integer lever, |
| | | @RequestParam(value = "profitTarget",required = false) |
| | | BigDecimal profitTarget,@RequestParam(value = "stopLoss",required = false) BigDecimal stopLoss, HttpServletRequest request) { |
| | | BigDecimal profitTarget,@RequestParam(value = "stopLoss",required = false) BigDecimal stopLoss, |
| | | @RequestParam(value = "preMarketPrice",required = false) BigDecimal preMarketPrice,HttpServletRequest request) { |
| | | buyLock.lock(); |
| | | try { |
| | | if (buyOrderCreated.get()) { |
| | | return ServerResponse.createByErrorMsg("当前下单人数过多,请稍后重试", request); |
| | | } |
| | | buyOrderCreated.set(true); |
| | | return this.iUserPositionService.buy(stockId, buyNum, buyType, lever,profitTarget,stopLoss, request); |
| | | return this.iUserPositionService.buy(stockId, buyNum, buyType, lever,profitTarget,stopLoss,preMarketPrice, request); |
| | | } catch (Exception e) { |
| | | e.printStackTrace(); |
| | | return ServerResponse.createByErrorMsg("订单异常,请稍后重试", request); |
| | |
| | | @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); |
| | | synchronized (positionSn) { |
| | | return this.iUserPositionService.sell(positionSn, 1, number, request); |
| | | } |
| | | } |
| | | |
| | | |
| | | //一键用户平仓操作 |
| | | @RequestMapping({"allsell.do"}) |
| | | @ResponseBody |
| | | public ServerResponse allsell(@RequestParam("stockType") String positionSn,HttpServletRequest request) { |
| | | public ServerResponse allsell(HttpServletRequest request) { |
| | | try { |
| | | return this.iUserPositionService.allSell(request,positionSn); |
| | | return this.iUserPositionService.allSell(request); |
| | | } catch (Exception e) { |
| | | return ServerResponse.createByErrorMsg("Sell Fail",request); |
| | | } |
| | |
| | | } |
| | | return serverResponse; |
| | | } |
| | | |
| | | //挂单操作-撤销 |
| | | @RequestMapping({"revocationOrder.do"}) |
| | | @ResponseBody |
| | | public ServerResponse revocationOrder(HttpServletRequest request,@RequestParam("id") Integer id) { |
| | | ServerResponse serverResponse = null; |
| | | try { |
| | | serverResponse = this.userPendingorderService.cancelPendingOrder(request,id); |
| | | } catch (Exception e) { |
| | | log.error("挂单操作-撤销 = {}", e); |
| | | } |
| | | return serverResponse; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | //挂单操作-删除 |
| | | @RequestMapping({"delOrder.do"}) |
| | | @ResponseBody |
| | |
| | | * 充值2异步接收地址 |
| | | */ |
| | | @PostMapping({"rechargeCallbackTwo.do"}) |
| | | public void rechargeCallbackTwo(TransactionStatusVo vo, HttpServletResponse response) throws IOException { |
| | | public void rechargeCallbackTwo(@RequestParam("status") String status, |
| | | @RequestParam("merchantid") String merchantid, |
| | | @RequestParam("out_trade_no") String outTradeNo, |
| | | @RequestParam("total_fee") String totalFee, |
| | | @RequestParam("poundage") String poundage, |
| | | @RequestParam("account_fee") String accountFee, |
| | | @RequestParam("sign") String sign, HttpServletResponse response) throws IOException { |
| | | TransactionStatusVo vo = new TransactionStatusVo(); |
| | | vo.setStatus(status); |
| | | vo.setMerchantid(merchantid); |
| | | vo.setOut_trade_no(outTradeNo); |
| | | vo.setTotal_fee(totalFee); |
| | | vo.setPoundage(poundage); |
| | | vo.setAccount_fee(accountFee); |
| | | vo.setSign(sign); |
| | | payService.rechargeCallbackTwo(vo,response); |
| | | } |
| | | |
| | | /** |
| | | * 代付回调通知 |
| | | */ |
| | | @PostMapping({"noticePayment.do"}) |
| | | public void noticePayment(TradeResultVO vo,HttpServletResponse response) throws IOException { |
| | | iUserWithdrawService.noticePayment(vo,response); |
| | | } |
| | | |
| | | /** |
| | | * 代付2回调通知 |
| | | */ |
| | | @PostMapping({"noticePaymentTwo.do"}) |
| | | public void noticePaymentTwo(PaymentCallbackTwo vo,HttpServletResponse response) throws IOException { |
| | | iUserWithdrawService.noticePaymentTwo(vo,response); |
| | | } |
| | | } |