同步k线、最新价、人民币美元汇率、homesymbols接口

Helius

2020-05-28 d775bb5dacca4c6ff33c65a0cb891f5992cc1bed

 src/main/java/com/xcong/excoin/modules/home/controller/MemberQuickBuySaleController.java

@@ -1,64 +1,117 @@
package com.xcong.excoin.modules.home.controller;



import javax.validation.Valid;



import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.web.bind.annotation.GetMapping;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.PostMapping;

import org.springframework.web.bind.annotation.RequestBody;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.RequestMethod;

import org.springframework.web.bind.annotation.RequestParam;

import org.springframework.web.bind.annotation.RestController;



import com.alibaba.druid.util.StringUtils;

import com.xcong.excoin.common.LoginUserUtils;

import com.xcong.excoin.common.response.Result;

import com.xcong.excoin.modules.home.dto.MemberQuickBuySaleCommitDto;

import com.xcong.excoin.modules.home.dto.MemberQuickBuySaleDto;

import com.xcong.excoin.modules.home.service.MemberQuickBuySaleService;

import com.xcong.excoin.modules.member.entity.MemberEntity;



import cn.hutool.crypto.SecureUtil;

import io.swagger.annotations.Api;

import io.swagger.annotations.ApiOperation;

import lombok.extern.slf4j.Slf4j;



@RestController

@Slf4j

@RequestMapping(value = "/api/quick")

@Api(value = "USDT快捷买卖类", tags = "USDT快捷买卖类")

@Api(value = "MemberQuickBuySaleController", tags = "USDT快捷买卖类")

public class MemberQuickBuySaleController {



   @Autowired

   MemberQuickBuySaleService memberQuickBuySaleService;



   @ApiOperation(value = "USDT快速充值", notes = "USDT快速充值")

   @ApiOperation(value = "recharge", notes = "USDT快速充值")

   @RequestMapping(value = "/recharge", method = RequestMethod.POST)

   public Result recharge(@RequestBody MemberQuickBuySaleDto memberQuickBuySaleDto) {

      return memberQuickBuySaleService.recharge(memberQuickBuySaleDto);

   public Result recharge(@RequestBody @Valid MemberQuickBuySaleDto memberQuickBuySaleDto) {

      log.info("入参----->{}", memberQuickBuySaleDto);

      //获取用户ID

      MemberEntity member = LoginUserUtils.getAppLoginUser();

      log.info("查询到的会员----->{}", member);

      // 验证是否实名认证

      if (MemberEntity.CERTIFY_STATUS_Y.equals(member.getCertifyStatus())) {

         return Result.fail("请先实名认证");

      }

      String tradePasswordWeb = memberQuickBuySaleDto.getTradePassword();

		
      // 验证支付密码

      String tradePassword = member.getTradePassword();

		
      log.info("入参交易密码{},用户设置的交易密码{}", tradePasswordWeb,tradePassword);

      if (StringUtils.isEmpty(tradePassword)) {

         return Result.fail("请先配置交易密码");

      }

      if (StringUtils.isEmpty(tradePasswordWeb)) {

         return Result.fail("请输入交易密码");

      }

      // 验证交易密码

      if (!tradePassword.equals(SecureUtil.md5(tradePasswordWeb))) {

         return Result.fail("请输入正确的交易密码");

      }

      return memberQuickBuySaleService.recharge(member, memberQuickBuySaleDto);

   }

   

   

   @ApiOperation(value = "USDT充值支付确认", notes = "USDT充值支付确认")

   @ApiOperation(value = "commitPay", notes = "USDT充值支付确认")

   @RequestMapping(value = "/commitPay", method = RequestMethod.POST)

   public Result commitPay(@RequestBody MemberQuickBuySaleCommitDto memberQuickBuySaleCommitDto) {

   public Result commitPay(@RequestBody @Valid MemberQuickBuySaleCommitDto memberQuickBuySaleCommitDto) {

      return memberQuickBuySaleService.commitPay(memberQuickBuySaleCommitDto);

   }

   

   @ApiOperation(value = "查询单个买卖记录", notes = "查询单个买卖记录")

   @ApiOperation(value = "selectById", notes = "查询单个买卖记录")

   @GetMapping(value = "/selectById/{id}")

   public Result selectById(@PathVariable(value = "id") Long id) {

      return memberQuickBuySaleService.selectById(id);

   }

   

   @ApiOperation(value = "selectAll", notes = "查询用户所有的买卖记录")

   @GetMapping(value = "/selectAll")

   public Result selectAll(@RequestParam(value = "type") String type) {

      return memberQuickBuySaleService.selectAll(type);

   }

   

	
   /**

    * 充值撤销

    * 
    * @param memberChargeUsdt

    * @param page

    * @param rows

    * @return

    */

   @ApiOperation(value = "充值撤销", notes = "充值撤销")

   @GetMapping(value = "/cancel/{id}")

   public Result cancel(@PathVariable(value = "id") Long id) {

   @ApiOperation(value = "cancel", notes = "充值撤销")

   @GetMapping(value = "/cancel")

   public Result cancel(@RequestParam(value = "id") Long id) {

      return memberQuickBuySaleService.cancelRecharge(id);

   }

   

	
	
   @ApiOperation(value = "sell", notes = "USDT快速卖出")

   @RequestMapping(value = "/sell", method = RequestMethod.POST)

   public Result sell(@RequestBody @Valid MemberQuickBuySaleDto memberQuickBuySaleDto) {

      // 获取当前登录用户

      MemberEntity member = LoginUserUtils.getAppLoginUser();

      if (MemberEntity.CERTIFY_STATUS_Y.equals(member.getCertifyStatus())) {

         return Result.fail("请先实名认证");

      }

      String tradePasswordWeb = memberQuickBuySaleDto.getTradePassword();

      // 验证支付密码

      String tradePassword = member.getTradePassword();

		
      log.info("入参交易密码{},用户设置的交易密码{}", tradePasswordWeb,tradePassword);

      if (StringUtils.isEmpty(tradePassword)) {

         return Result.fail("请先配置交易密码");

      }

      if (StringUtils.isEmpty(tradePasswordWeb)) {

         return Result.fail("请输入交易密码");

      }

      // 验证交易密码

      if (!tradePassword.equals(SecureUtil.md5(tradePasswordWeb))) {

         return Result.fail("请输入正确的交易密码");

      }

      return memberQuickBuySaleService.sell(member,memberQuickBuySaleDto);

   }

}