package com.gear.customer.swx.controller;
|
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.gear.common.config.GearConfig;
|
import com.gear.common.core.domain.AjaxResult;
|
import com.gear.common.exception.CustomerException;
|
import com.gear.common.utils.file.FileUploadUtils;
|
import com.gear.common.utils.file.FileUtils;
|
import com.gear.common.utils.oss.AliyunOssUtil;
|
import com.gear.common.vo.Result;
|
import com.gear.customer.swx.biz.SwxBizUser;
|
import com.gear.customer.swx.vo.request.*;
|
import com.gear.customer.swx.vo.response.SwxUserInfoVo;
|
import com.gear.framework.config.ServerConfig;
|
import com.gear.swx.domain.SwxLoanRecord;
|
import com.gear.swx.domain.SwxNft;
|
import com.gear.swx.domain.SwxRechargeRecord;
|
import com.gear.swx.domain.SwxWithdrawalRecord;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.UUID;
|
|
@RestController
|
@RequestMapping("/swx/customer/user")
|
public class SwxUserOperateController {
|
@Autowired
|
private SwxBizUser swxBizUser;
|
|
@Autowired
|
private ServerConfig serverConfig;
|
|
|
@Value("${aliyun.oss.endpoint}")
|
public String endpoint;
|
/**
|
* 用户认证
|
* @param request
|
* @param
|
* @return
|
*/
|
@PostMapping("/identification")
|
public Result<String> identification(HttpServletRequest request, @RequestBody SwxUserIdentificationVo swxUserIdentificationVo){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.identification(userId,swxUserIdentificationVo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
|
@PostMapping("/getUserInfo")
|
public Result<SwxUserInfoVo> getUserInfo(HttpServletRequest request){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.getUserInfo(userId));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
|
@PostMapping("/recharge")
|
public Result<String> recharge(HttpServletRequest request, @RequestBody SwxUserRechargeVo vo){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.recharge(userId,vo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
|
/**提现*/
|
@PostMapping("/withdrawal")
|
public Result<String> withdrawal(HttpServletRequest request,@RequestBody SwxUserWithdrawalVo vo){
|
if (vo.getWithdrawalType() == null)
|
throw new CustomerException("10025");
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.withdrawal(userId,vo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
|
@GetMapping("/listRecharge")
|
public Result<IPage<SwxRechargeRecord>> listRecharge(HttpServletRequest request,@RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
|
@RequestParam(name="pageSize", defaultValue="10") Integer pageSize){
|
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.listRecharge(userId,pageNo,pageSize));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
|
@GetMapping("/listWithdrwal")
|
public Result<IPage<SwxWithdrawalRecord>> listWithdrwal(HttpServletRequest request,@RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
|
@RequestParam(name="pageSize", defaultValue="10") Integer pageSize){
|
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.listWithdrwal(userId,pageNo,pageSize));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
|
}
|
@GetMapping("/listNft")
|
public Result<List<SwxNft>> listNft(HttpServletRequest request){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.listNft(userId));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
}
|
|
@PostMapping("/buyNft")
|
public Result<String> buyNft(HttpServletRequest request, @RequestBody SwxUserBuyNftVo swxUserBuyNftVo){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.buyNft(userId,swxUserBuyNftVo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
}
|
|
@PostMapping("/loan")
|
public Result<String> loan(HttpServletRequest request, @RequestBody SwxUserLoanVo swxUserLoanVo){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.loan(userId,swxUserLoanVo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
}
|
|
@GetMapping("/listLoanRecord")
|
public Result<IPage<SwxLoanRecord>> listLoanRecord(HttpServletRequest request,@RequestParam(name="pageNo", defaultValue="1") Integer pageNo,
|
@RequestParam(name="pageSize", defaultValue="10") Integer pageSize){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.listLoanRecord(userId,pageNo,pageSize));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
}
|
|
@PostMapping("/upload")
|
public AjaxResult uploadFile(MultipartFile file) throws Exception
|
{
|
try
|
{
|
// 上传文件路径
|
String filePath = GearConfig.getUploadPath();
|
// 上传并返回新文件名称
|
String fileName = FileUploadUtils.upload(filePath, file);
|
String url = serverConfig.getUrl() + fileName;
|
// url = url.replace("http://www.saxtrader.net/", "https://www.saxtrader.net/");
|
url = url.replace("http://www.saxtrader.net/", "https://www.galaxydigitalgold.xyz/");
|
url = url.replace("http://www.galaxytrader.cloud/", "https://www.galaxydigitalgold.xyz/");
|
url = url.replace("http://www.galaxydigitalgold.xyz/", "https://www.galaxydigitalgold.xyz/");
|
/*String fileName = "image/"+ UUID.randomUUID()+new SimpleDateFormat("yyyy-mm-dd").format(new Date())+"."+file.getOriginalFilename();
|
String url = "https://"+"sax-bucket-1."+endpoint+"/" + fileName;
|
AliyunOssUtil.uploadMultipartFile(fileName,file);*/
|
AjaxResult ajax = AjaxResult.success();
|
ajax.put("url", url);
|
return ajax;
|
}
|
catch (Exception e)
|
{
|
return AjaxResult.error(e.getMessage());
|
}
|
}
|
|
@PostMapping("/repassword")
|
public Result<String> repassword(HttpServletRequest request,@RequestBody SwxUserRegisterVo vo){
|
try {
|
String userId = (String)request.getAttribute("userId");
|
return Result.OK(swxBizUser.repassword(userId,vo));
|
}catch (CustomerException e){
|
return Result.error(e.getMessage());
|
}
|
}
|
}
|
