package com.yami.trading.admin.controller.dapp;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
|
import javax.annotation.Resource;
|
import javax.servlet.http.HttpServletRequest;
|
|
import com.yami.trading.bean.model.User;
|
import com.yami.trading.bean.syspara.domain.Syspara;
|
import com.yami.trading.common.exception.BusinessException;
|
import com.yami.trading.common.util.*;
|
import com.yami.trading.common.web.ResultObject;
|
import com.yami.trading.security.common.bo.UserInfoInTokenBO;
|
import com.yami.trading.security.common.enums.SysTypeEnum;
|
import com.yami.trading.security.common.manager.TokenStore;
|
import com.yami.trading.security.common.vo.TokenInfoVO;
|
import com.yami.trading.service.SessionTokenService;
|
import com.yami.trading.service.WalletService;
|
import com.yami.trading.service.data.DataService;
|
import com.yami.trading.service.syspara.SysparaService;
|
import com.yami.trading.service.user.UserDataService;
|
import com.yami.trading.service.user.UserService;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.CrossOrigin;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.RestController;
|
import org.springframework.web.context.request.RequestContextHolder;
|
import org.springframework.web.context.request.ServletRequestAttributes;
|
|
/**
|
* dapp api
|
*
|
*/
|
@RestController
|
@CrossOrigin
|
public class DappController {
|
|
private static final Logger logger = LoggerFactory.getLogger(DappController.class);
|
|
@Resource
|
private DAppService dAppService;
|
// @Resource
|
// private AutoMonitorAddressConfigService autoMonitorAddressConfigService;
|
@Resource
|
private UserService UserService;
|
// todo
|
// @Resource
|
// private PledgeOrderService pledgeOrderService;
|
@Resource
|
private WalletService walletService;
|
@Resource
|
private SysparaService sysparaService;
|
@Resource
|
private DataService dataService;
|
@Resource
|
private SessionTokenService tokenService;
|
// todo
|
// @Resource
|
// private PledgeConfigService pledgeConfigService;
|
@Autowired
|
private TokenStore tokenStore;
|
@Autowired
|
private UserService userService;
|
@Autowired
|
private UserDataService userDataService;
|
|
public final String action = "/api/dapp!";
|
|
|
|
/**
|
* Dapp登录注册:备注 Snowball 盘 定制接口，等他下盘了，就删掉。
|
*/
|
@RequestMapping(action + "login.action")
|
public Object login(String from, String code){
|
ResultObject resultObject = new ResultObject();
|
boolean lock = false;
|
from = from.trim().toLowerCase();
|
try {
|
|
if (StringUtils.isNullOrEmpty(from)) {
|
throw new BusinessException("address is empty");
|
}
|
|
Syspara syspara = sysparaService.find("project_type");
|
if (null == syspara) {
|
throw new BusinessException("projectType is not found");
|
}
|
|
// if (!syspara.getSvalue().contains("DAPP_EXCHANGE")) {
|
// throw new BusinessException("Bad Request");
|
// }
|
|
String ip = this.getIp();
|
if (!IpUtil.isCorrectIpRegular(ip)) {
|
logger.error("校验IP不合法,参数{}", ip);
|
throw new BusinessException("校验IP不合法");
|
}
|
|
if (!LockFilter.add(from)) {
|
resultObject.setCode("0");
|
return resultObject;
|
}
|
lock = true;
|
|
User user = dAppService.saveLogin(from, code, ip);
|
if (null == user) {
|
throw new BusinessException("User is null");
|
}
|
if (user.getAccountType() != null && user.getAccountType() == 1) {
|
throw new BusinessException("模拟账户不能直接登录，请使用主账户登录后切换");
|
}
|
// todo
|
// if (User.getLogin_authority()==false) {
|
// throw new BusinessException("登录失败");
|
// }
|
UserInfoInTokenBO userInfoInToken = new UserInfoInTokenBO();
|
userInfoInToken.setUserId(user.getUserId());
|
userService.online(user.getUserId());
|
userInfoInToken.setSysType(SysTypeEnum.ORDINARY.value());
|
userInfoInToken.setEnabled(user.getStatus() == 1);
|
userDataService.saveRegister(user.getUserId());
|
tokenStore.deleteAllToken(String.valueOf(SysTypeEnum.ORDINARY.value()), String.valueOf(user.getUserId()));
|
// 存储token返回vo
|
TokenInfoVO tokenInfoVO = tokenStore.storeAndGetVo(userInfoInToken);
|
tokenInfoVO.setToken(tokenInfoVO.getAccessToken());
|
user.setUserLastip(IPHelper.getIpAddr());
|
user.setUserLasttime(new Date());
|
userService.updateById(user);
|
|
|
// String token = tokenService.savePut(String.valueOf(user.getUserId()));
|
|
Map<String, Object> data = new HashMap<String, Object>();
|
|
// 收益率 和usdt汇率
|
// data.putAll(dAppService.getProfit(from));
|
// 是否弹出加入挖矿的提示(0不弹出 1弹出)
|
// Syspara dapp_approve_auto = sysparaService.find("dapp_approve_auto");
|
// data.put("pop_up", dapp_approve_auto == null ? 0 : dapp_approve_auto.getInteger());
|
data.put("token", tokenInfoVO.getAccessToken());
|
data.put("username", from);
|
// data.put("identityverif", User.getKyc_authority());
|
data.put("uid", user.getUserCode());
|
data.put("obj", tokenInfoVO);
|
resultObject.setData(data);
|
logger.info("登录成功，用户{}", from);
|
|
} catch (BusinessException e) {
|
resultObject.setCode("1");
|
resultObject.setMsg(e.getMessage());
|
} catch (Exception e) {
|
resultObject.setCode("1");
|
resultObject.setMsg("程序错误");
|
logger.error("error:", e);
|
} finally {
|
if (lock) {
|
ThreadUtils.sleep(50);
|
LockFilter.remove(from);
|
}
|
}
|
return resultObject;
|
}
|
|
public String getIp() {
|
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getRequest();
|
String ip = request.getHeader("X-Forwarded-For");
|
if (StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)) {
|
// 多次反向代理后会有多个ip值，第一个ip才是真实ip
|
int index = ip.indexOf(",");
|
if (index != -1) {
|
return ip.substring(0, index);
|
} else {
|
return ip;
|
}
|
}
|
ip = request.getHeader("X-Real-IP");
|
if (StringUtils.isNotEmpty(ip) && !"unKnown".equalsIgnoreCase(ip)) {
|
return ip;
|
}
|
return request.getRemoteAddr();
|
}
|
|
}
|
