From 7fb0bca46a32416722cb40d995e493356d248ebf Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 14 May 2024 17:28:40 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/service/impl/UserServiceImpl.java | 204 ++++++++++++++++++++++++--------------------------
1 files changed, 99 insertions(+), 105 deletions(-)
diff --git a/src/main/java/com/nq/service/impl/UserServiceImpl.java b/src/main/java/com/nq/service/impl/UserServiceImpl.java
index cb51cf3..bc825e9 100644
--- a/src/main/java/com/nq/service/impl/UserServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserServiceImpl.java
@@ -139,39 +139,41 @@
@Autowired
private StringRedisTemplate redisTemplate;
- public ServerResponse reg(String yzmCode, String agentCode, String phone, String userPwd,String email, HttpServletRequest request) {
- if (StringUtils.isAnyBlank(agentCode,phone,userPwd,yzmCode,email)) {
- return ServerResponse.createByErrorMsg("注册失败。该参数不能为空",request);
+ public ServerResponse reg(String yzmCode, String agentCode, String phone, String userPwd, String email, HttpServletRequest request) {
+ if (StringUtils.isAnyBlank(agentCode, phone, userPwd, yzmCode, email)) {
+ return ServerResponse.createByErrorMsg("注册失败。该参数不能为空", request);
}
- Assert.isTrue(userMapper.selectCount(new LambdaQueryWrapper<User>().eq(User::getEmail,email)) == 0,
- "Registration failed, the mobile mail number has been registered");
+ if (userMapper.selectCount(new LambdaQueryWrapper<User>().eq(User::getEmail, email)) == 0) {
+ return ServerResponse.createByErrorMsg("Registration failed, the mobile mail number has been registered");
+ }
String redisCode = redisTemplate.opsForValue().get(codeUtil.KEY_PREFIX + yzmCode);
if (redisCode == null || !yzmCode.equals(redisCode)) {
return ServerResponse.createByErrorMsg("Verification code error");
}
+ /*
String keys = "AliyunSmsCode:" + phone;
String redis_yzm = RedisShardedPoolUtils.get(keys);
log.info("redis_yzm = {},yzmCode = {}", redis_yzm, yzmCode);
if (!yzmCode.equals(redis_yzm) && !"6666".equals(yzmCode)) {
return ServerResponse.createByErrorMsg("由于验证码不正确，注册失败。过程",request);
- }
+ }*/
AgentUser agentUser = this.iAgentUserService.findByCode(agentCode);
if (agentUser == null) {
- return ServerResponse.createByErrorMsg("由于代理不存在，注册失败",request);
+ return ServerResponse.createByErrorMsg("由于代理不存在，注册失败", request);
}
if (agentUser.getIsLock().intValue() == 1) {
- return ServerResponse.createByErrorMsg("注册失败。代理被锁定",request);
+ return ServerResponse.createByErrorMsg("注册失败。代理被锁定", request);
}
- User dbuser = this.userMapper.selectOne(new LambdaQueryWrapper<User>().eq(User::getPhone,phone).last( " limit 1"));
+ User dbuser = this.userMapper.selectOne(new LambdaQueryWrapper<User>().eq(User::getPhone, phone).last(" limit 1"));
if (dbuser != null) {
- return ServerResponse.createByErrorMsg("注册失败，手机号已注册",request);
+ return ServerResponse.createByErrorMsg("注册失败，手机号已注册", request);
}
@@ -200,26 +202,26 @@
log.info("用户注册成功 手机 {} , ip = {} 地址 = {}", new Object[]{phone, uip, uadd});
return ServerResponse.createBySuccessMsg("Registration successful. Please login");
}
- return ServerResponse.createBySuccessMsg("注册错误，请重试",request);
+ return ServerResponse.createBySuccessMsg("注册错误，请重试", request);
}
public ServerResponse login(String phone, String userPwd, HttpServletRequest request) {
if (StringUtils.isBlank(phone) || StringUtils.isBlank(userPwd)) {
- return ServerResponse.createByErrorMsg("手机号码和密码不能为空",request);
+ return ServerResponse.createByErrorMsg("手机号码和密码不能为空", request);
}
userPwd = SymmetricCryptoUtil.encryptPassword(userPwd);
User user = this.userMapper.login(phone, userPwd);
if (user != null) {
if (user.getIsLogin().intValue() == 1) {
- return ServerResponse.createByErrorMsg("登录失败。账户锁定",request);
+ return ServerResponse.createByErrorMsg("登录失败。账户锁定", request);
}
- userAssetsServices.assetsByTypeAndUserId(EStockType.US.getCode(),user.getId());
- userAssetsServices.assetsByTypeAndUserId(EStockType.IN.getCode(),user.getId());
+ userAssetsServices.assetsByTypeAndUserId(EStockType.US.getCode(), user.getId());
+ userAssetsServices.assetsByTypeAndUserId(EStockType.IN.getCode(), user.getId());
this.iSiteLoginLogService.saveLog(user, request);
return ServerResponse.createBySuccess(user);
}
- return ServerResponse.createByErrorMsg("登录失败，用户名和密码错误",request);
+ return ServerResponse.createByErrorMsg("登录失败，用户名和密码错误", request);
}
@@ -256,12 +258,12 @@
String stockcode = code;
StockOption dboption = this.stockOptionMapper.findMyOptionIsExistByCode(user.getId(), stockcode);
if (dboption != null) {
- return ServerResponse.createByErrorMsg("未能添加所选股票，因为它已经存在",request );
+ return ServerResponse.createByErrorMsg("未能添加所选股票，因为它已经存在", request);
}
//期货逻辑
Stock stock = this.stockMapper.findStockByCode(code);
if (stock == null) {
- return ServerResponse.createByErrorMsg("添加失败，库存不存在",request );
+ return ServerResponse.createByErrorMsg("添加失败，库存不存在", request);
}
StockOption stockOption = new StockOption();
stockOption.setUserId(user.getId());
@@ -274,9 +276,9 @@
int insertCount = this.stockOptionMapper.insert(stockOption);
if (insertCount > 0) {
- return ServerResponse.createBySuccessMsg("添加自选股票成功",request );
+ return ServerResponse.createBySuccessMsg("添加自选股票成功", request);
}
- return ServerResponse.createByErrorMsg("添加失败，请重试",request );
+ return ServerResponse.createByErrorMsg("添加失败，请重试", request);
}
@@ -285,13 +287,13 @@
String stockcode = code;
StockOption dboption = this.stockOptionMapper.findMyOptionIsExistByCode(user.getId(), stockcode);
if (dboption == null) {
- return ServerResponse.createByErrorMsg("删除失败，因为自选股票不存在",request);
+ return ServerResponse.createByErrorMsg("删除失败，因为自选股票不存在", request);
}
int delCount = this.stockOptionMapper.deleteByPrimaryKey(dboption.getId());
if (delCount > 0) {
- return ServerResponse.createBySuccessMsg("删除自选成功",request);
+ return ServerResponse.createBySuccessMsg("删除自选成功", request);
}
- return ServerResponse.createByErrorMsg("删除自选失败",request);
+ return ServerResponse.createByErrorMsg("删除自选失败", request);
}
@@ -316,15 +318,15 @@
.eq(ApplyLever::getState, 1)
.orderByDesc(ApplyLever::getCreateTime)
.last(" limit 1"));
- if(null == applyLever || applyLever.getLever().equals("1")){
+ if (null == applyLever || applyLever.getLever().equals("1")) {
userInfoVO.setSiteLever("1");
- }else{
+ } else {
userInfoVO.setSiteLever(leverSplit(applyLever.getLever()));
}
return ServerResponse.createBySuccess(userInfoVO);
}
- public String leverSplit(String lever){
+ public String leverSplit(String lever) {
String levers = "1/2/5/10";
String[] parts = levers.split("/");
int index = Arrays.asList(parts).indexOf(lever);
@@ -337,21 +339,21 @@
public ServerResponse updatePwd(String oldPwd, String newPwd, HttpServletRequest request) {
if (StringUtils.isBlank(oldPwd) || StringUtils.isBlank(newPwd)) {
- return ServerResponse.createByErrorMsg("该参数不能为空",request);
+ return ServerResponse.createByErrorMsg("该参数不能为空", request);
}
User user = getCurrentRefreshUser(request);
oldPwd = SymmetricCryptoUtil.encryptPassword(oldPwd);
if (!oldPwd.equals(user.getUserPwd())) {
- return ServerResponse.createByErrorMsg("密码错误",request);
+ return ServerResponse.createByErrorMsg("密码错误", request);
}
user.setUserPwd(SymmetricCryptoUtil.encryptPassword(newPwd));
int updateCount = this.userMapper.updateById(user);
if (updateCount > 0) {
- return ServerResponse.createBySuccessMsg("修改成功",request);
+ return ServerResponse.createBySuccessMsg("修改成功", request);
}
- return ServerResponse.createByErrorMsg("修改失败",request);
+ return ServerResponse.createByErrorMsg("修改失败", request);
}
@@ -416,13 +418,13 @@
if (StringUtils.isBlank(realName) ||
StringUtils.isBlank(idCard)) {
- return ServerResponse.createByErrorMsg("该参数不能为空",request);
+ return ServerResponse.createByErrorMsg("该参数不能为空", request);
}
User user = getCurrentRefreshUser(request);
if (((0 != user.getIsActive().intValue())) & ((3 != user.getIsActive().intValue()))) {
- return ServerResponse.createByErrorMsg("当前状态无法验证",request);
+ return ServerResponse.createByErrorMsg("当前状态无法验证", request);
}
user.setImg1Key(img1key);
user.setImg2Key(img2key);
@@ -436,9 +438,9 @@
int updateCount = this.userMapper.updateById(user);
if (updateCount > 0) {
- return ServerResponse.createBySuccessMsg("实名认证",request);
+ return ServerResponse.createBySuccessMsg("实名认证", request);
}
- return ServerResponse.createByErrorMsg("实名认证失败",request);
+ return ServerResponse.createByErrorMsg("实名认证失败", request);
}
@@ -477,14 +479,14 @@
@Override
public ServerResponse getMoney(HttpServletRequest request) {
- return getMoney(getCurrentUser(request).getId());
+ return getMoney(getCurrentUser(request).getId());
}
@Override
public ServerResponse getMoney(Integer userId) {
- List<UserAssets> userAssetsList = userAssetsServices.assetsByUserId(userId);
- List<RUserAssets> rUserAssetsList = new ArrayList<>();
- int s= 4;
+ List<UserAssets> userAssetsList = userAssetsServices.assetsByUserId(userId);
+ List<RUserAssets> rUserAssetsList = new ArrayList<>();
+ int s = 4;
/**
* 浮动盈亏
* */
@@ -509,8 +511,8 @@
* 总手续费
* */
BigDecimal allHMoney = BigDecimal.ZERO;
- for (int i = 0; i <userAssetsList.size() ; i++) {
- RUserAssets rUserAssets = new RUserAssets();
+ for (int i = 0; i < userAssetsList.size(); i++) {
+ RUserAssets rUserAssets = new RUserAssets();
UserAssets userAssets = userAssetsList.get(i);
// 浮动盈亏
BigDecimal profitAndLose = userAssets.getProfitAndLoss();
@@ -530,48 +532,47 @@
rUserAssets.setIsZf(userAssets.getIsZf());
rUserAssets.setAmountToBeCovered(userAssets.getAmountToBeCovered().toString());
BigDecimal rate = rateServices.currencyRate(
- EStockType.getEStockTypeByCode(userAssets.getAccectType()),EStockType.US);
+ EStockType.getEStockTypeByCode(userAssets.getAccectType()), EStockType.US);
- BigDecimal availableBalanceUSD = amt;
- if(amt.compareTo(BigDecimal.ZERO)>0){
+ BigDecimal availableBalanceUSD = amt;
+ if (amt.compareTo(BigDecimal.ZERO) > 0) {
availableBalanceUSD = amt.multiply(rate);
}
- BigDecimal freezeMoneyUSD = freeMoney;
- if(freeMoney.compareTo(BigDecimal.ZERO)>0){
- freezeMoneyUSD = freeMoney.multiply(rate);
+ BigDecimal freezeMoneyUSD = freeMoney;
+ if (freeMoney.compareTo(BigDecimal.ZERO) > 0) {
+ freezeMoneyUSD = freeMoney.multiply(rate);
}
- BigDecimal totleMoneyUSD = totalAssets;
- if(totalAssets.compareTo(BigDecimal.ZERO)>0){
- totleMoneyUSD = totleMoneyUSD.multiply(rate);
+ BigDecimal totleMoneyUSD = totalAssets;
+ if (totalAssets.compareTo(BigDecimal.ZERO) > 0) {
+ totleMoneyUSD = totleMoneyUSD.multiply(rate);
}
- BigDecimal cumulativeProfitAndLossUSD = hProfitAndLose;
- if(hProfitAndLose.compareTo(BigDecimal.ZERO)>0){
+ BigDecimal cumulativeProfitAndLossUSD = hProfitAndLose;
+ if (hProfitAndLose.compareTo(BigDecimal.ZERO) > 0) {
cumulativeProfitAndLossUSD = hProfitAndLose.multiply(rate);
}
- BigDecimal handlingChargeUSD = hMoney;
- if(hMoney.compareTo(BigDecimal.ZERO)>0){
- handlingChargeUSD =hMoney.multiply(rate);
+ BigDecimal handlingChargeUSD = hMoney;
+ if (hMoney.compareTo(BigDecimal.ZERO) > 0) {
+ handlingChargeUSD = hMoney.multiply(rate);
}
- BigDecimal profitAndLossUSD = profitAndLose;
- if(profitAndLose.compareTo(BigDecimal.ZERO)>0){
- profitAndLossUSD =profitAndLose.multiply(rate);
+ BigDecimal profitAndLossUSD = profitAndLose;
+ if (profitAndLose.compareTo(BigDecimal.ZERO) > 0) {
+ profitAndLossUSD = profitAndLose.multiply(rate);
}
-
- rUserAssets.setAvailableBalanceUSD(availableBalanceUSD.setScale(s,BigDecimal.ROUND_UP).toString());
- rUserAssets.setFreezeMoneyUSD(freezeMoneyUSD.setScale(s,BigDecimal.ROUND_UP).toString());
- rUserAssets.setTotalMoneyUSD(totleMoneyUSD.setScale(s,BigDecimal.ROUND_UP).toString());
+ rUserAssets.setAvailableBalanceUSD(availableBalanceUSD.setScale(s, BigDecimal.ROUND_UP).toString());
+ rUserAssets.setFreezeMoneyUSD(freezeMoneyUSD.setScale(s, BigDecimal.ROUND_UP).toString());
+ rUserAssets.setTotalMoneyUSD(totleMoneyUSD.setScale(s, BigDecimal.ROUND_UP).toString());
rUserAssets.setSymbol(EStockType.getEStockTypeByCode(userAssets.getAccectType()).getSymbol1());
rUserAssets.setSymbolCode(EStockType.getEStockTypeByCode(userAssets.getAccectType()).getSymbol());
- rUserAssets.setCumulativeProfitAndLossUSD(cumulativeProfitAndLossUSD.setScale(s,BigDecimal.ROUND_UP).toString());
- rUserAssets.setHandlingChargeUSD(handlingChargeUSD.setScale(s,BigDecimal.ROUND_UP).toString());
- rUserAssets.setProfitAndLossUSD(profitAndLossUSD.setScale(s,BigDecimal.ROUND_UP).toString());
- rUserAssets.setProfitAndLoss(getProfitAndLose(userId,userAssets.getAccectType()).toString());
+ rUserAssets.setCumulativeProfitAndLossUSD(cumulativeProfitAndLossUSD.setScale(s, BigDecimal.ROUND_UP).toString());
+ rUserAssets.setHandlingChargeUSD(handlingChargeUSD.setScale(s, BigDecimal.ROUND_UP).toString());
+ rUserAssets.setProfitAndLossUSD(profitAndLossUSD.setScale(s, BigDecimal.ROUND_UP).toString());
+ rUserAssets.setProfitAndLoss(getProfitAndLose(userId, userAssets.getAccectType()).toString());
BigDecimal decimal = new BigDecimal(rUserAssets.getTotalMoney()).add(new BigDecimal(rUserAssets.getProfitAndLoss()));
rUserAssets.setTotalMoney(decimal.toString());
AllProfitAndLose = AllProfitAndLose.add(profitAndLossUSD);
@@ -582,29 +583,24 @@
allHMoney = allHMoney.add(handlingChargeUSD);
-
-
-
rUserAssetsList.add(rUserAssets);
}
-
-
- RUserAssets rUserAssets = new RUserAssets();
+ RUserAssets rUserAssets = new RUserAssets();
rUserAssets.setAccectType("ALL");
- rUserAssets.setProfitAndLoss(AllProfitAndLose.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setProfitAndLossUSD(AllProfitAndLose.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setHandlingCharge(allHMoney.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setHandlingChargeUSD(allHMoney.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setCumulativeProfitAndLoss(AllHProfitAndLose.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setCumulativeProfitAndLossUSD(AllHProfitAndLose.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setTotalMoney(allTotalAssets.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setTotalMoneyUSD(allTotalAssets.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setAvailableBalance(allAmt.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setAvailableBalanceUSD(allAmt.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setFreezeMoney(allFreeMoney.setScale(s,BigDecimal.ROUND_DOWN).toString());
- rUserAssets.setFreezeMoneyUSD(allFreeMoney.setScale(s,BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setProfitAndLoss(AllProfitAndLose.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setProfitAndLossUSD(AllProfitAndLose.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setHandlingCharge(allHMoney.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setHandlingChargeUSD(allHMoney.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setCumulativeProfitAndLoss(AllHProfitAndLose.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setCumulativeProfitAndLossUSD(AllHProfitAndLose.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setTotalMoney(allTotalAssets.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setTotalMoneyUSD(allTotalAssets.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setAvailableBalance(allAmt.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setAvailableBalanceUSD(allAmt.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setFreezeMoney(allFreeMoney.setScale(s, BigDecimal.ROUND_DOWN).toString());
+ rUserAssets.setFreezeMoneyUSD(allFreeMoney.setScale(s, BigDecimal.ROUND_DOWN).toString());
rUserAssets.setSymbol("$");
rUserAssets.setSymbolCode("USD");
rUserAssetsList.add(rUserAssets);
@@ -612,11 +608,11 @@
return ServerResponse.createBySuccess(rUserAssetsList);
}
- public BigDecimal getProfitAndLose(Integer userId,String accectType){
+ public BigDecimal getProfitAndLose(Integer userId, String accectType) {
List<UserPosition> userPositions;
userPositions = userPositionMapper.
findMyPositionByCodeAndSpell(userId,
- "","",
+ "", "",
0, accectType);
@@ -635,20 +631,20 @@
}
@Override
- public ServerResponse transfer(String fromType, String toType, String amt,HttpServletRequest request) {
- User user = userService.getCurrentUser(request);
- UserAssets formAssets = userAssetsServices.assetsByTypeAndUserId(fromType,user.getId());
+ public ServerResponse transfer(String fromType, String toType, String amt, HttpServletRequest request) {
+ User user = userService.getCurrentUser(request);
+ UserAssets formAssets = userAssetsServices.assetsByTypeAndUserId(fromType, user.getId());
BigDecimal amtBig = new BigDecimal(amt);
- if(formAssets.getAvailableBalance().compareTo(amtBig)<0){
- return ServerResponse.createByErrorMsg("余额不足",request);
+ if (formAssets.getAvailableBalance().compareTo(amtBig) < 0) {
+ return ServerResponse.createByErrorMsg("余额不足", request);
}
- userAssetsServices.availablebalanceChange(fromType,user.getId(), EUserAssets.TRANSFER,amtBig.negate(),fromType+"/"+toType,"");
- if(fromType.equals("US")){
+ userAssetsServices.availablebalanceChange(fromType, user.getId(), EUserAssets.TRANSFER, amtBig.negate(), fromType + "/" + toType, "");
+ if (fromType.equals("US")) {
amtBig = (new BigDecimal(83.5)).multiply(amtBig);
- }else{
- amtBig = rateServices.currencyRate(EStockType.getEStockTypeByCode(fromType),EStockType.getEStockTypeByCode(toType)).multiply(amtBig);
+ } else {
+ amtBig = rateServices.currencyRate(EStockType.getEStockTypeByCode(fromType), EStockType.getEStockTypeByCode(toType)).multiply(amtBig);
}
- userAssetsServices.availablebalanceChange(toType,user.getId(),EUserAssets.TRANSFER,amtBig.setScale(5,RoundingMode.HALF_DOWN),fromType+"/"+toType,"");
+ userAssetsServices.availablebalanceChange(toType, user.getId(), EUserAssets.TRANSFER, amtBig.setScale(5, RoundingMode.HALF_DOWN), fromType + "/" + toType, "");
return ServerResponse.createBySuccess();
}
@@ -773,7 +769,7 @@
}
- public ServerResponse addSimulatedAccount(Integer agentId, String phone, String pwd,Integer accountType, HttpServletRequest request) {
+ public ServerResponse addSimulatedAccount(Integer agentId, String phone, String pwd, Integer accountType, HttpServletRequest request) {
if (StringUtils.isBlank(phone) || StringUtils.isBlank(pwd)) {
return ServerResponse.createByErrorMsg("The parameter cannot be null");
}
@@ -972,7 +968,7 @@
user.setAuthMsg(authMsg);
}
- if(state == 2){
+ if (state == 2) {
user.setIsLock(0);
}
user.setIsActive(state);
@@ -1031,9 +1027,6 @@
agentUserListVO.setIsLogin(user.getIsLogin());
agentUserListVO.setRegAddress(user.getRegAddress());
agentUserListVO.setIsActive(user.getIsActive());
-
-
-
PositionVO positionVO = this.iUserPositionService.findUserPositionAllProfitAndLose(user.getId());
@@ -1131,13 +1124,14 @@
}
@Override
- public ServerResponse getMoenyLog(String type,HttpServletRequest request) {
+ public ServerResponse getMoenyLog(String type, HttpServletRequest request) {
User user = getCurrentUser(request);
- QueryWrapper<MoneyLog> queryWrapper = new QueryWrapper<>();
- queryWrapper.eq("type",type);
- queryWrapper.eq("user_id",user.getId());
- return ServerResponse.createBySuccess(mapper.selectList(queryWrapper));
+ QueryWrapper<MoneyLog> queryWrapper = new QueryWrapper<>();
+ queryWrapper.eq("type", type);
+ queryWrapper.eq("user_id", user.getId());
+ return ServerResponse.createBySuccess(mapper.selectList(queryWrapper));
}
+
@Override
public ServerResponse sendMailCode(String MailCode) {
if (MailCode == null || MailCode.equals("")) {
--
Gitblit v1.9.3