| | |
|---|
| | | package com.nq.service.impl; |
|---|
| | | |
|---|
| | | import cn.hutool.core.convert.Convert; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.github.pagehelper.PageHelper; |
|---|
| | |
|---|
| | | import com.nq.vo.position.PositionProfitVO; |
|---|
| | | import com.nq.vo.position.PositionVO; |
|---|
| | | import com.nq.vo.position.UserPositionVO; |
|---|
| | | import com.nq.vo.stock.StockAdminListVO; |
|---|
| | | import com.nq.vo.stock.StockListVO; |
|---|
| | | import com.nq.vo.user.UserInfoVO; |
|---|
| | | |
|---|
| | | import java.math.BigDecimal; |
|---|
| | | import java.math.RoundingMode; |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.Arrays; |
|---|
| | | import java.util.Date; |
|---|
| | | import java.util.List; |
|---|
| | | import java.text.ParseException; |
|---|
| | | import java.text.SimpleDateFormat; |
|---|
| | | import java.util.*; |
|---|
| | | import java.util.stream.Collectors; |
|---|
| | | import javax.annotation.Resource; |
|---|
| | | import javax.servlet.http.HttpServletRequest; |
|---|
| | | |
|---|
| | | import com.nq.vo.user.UserOut; |
|---|
| | | import org.apache.commons.lang3.Conversion; |
|---|
| | | import org.apache.commons.lang3.StringUtils; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | import org.slf4j.LoggerFactory; |
|---|
| | |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | IPriceServices priceServices; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | IUserService iUserService; |
|---|
| | | |
|---|
| | | |
|---|
| | | public ServerResponse reg(String yzmCode, String agentCode, String phone, String userPwd, HttpServletRequest request) { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | public ServerResponse listByAdmin(String realName, String phone, Integer agentId, Integer accountType, int pageNum, int pageSize, HttpServletRequest request) { |
|---|
| | | public ServerResponse listByAdmin(String realName, String phone, Integer agentId, Integer accountType, int pageNum, int pageSize, Integer isLock, Integer isLogin, String regTime, Integer isActive, HttpServletRequest request) throws ParseException { |
|---|
| | | PageHelper.startPage(pageNum, pageSize); |
|---|
| | | SimpleDateFormat inputFormat = new SimpleDateFormat("yyyy-MM-dd"); |
|---|
| | | SimpleDateFormat outputFormat = new SimpleDateFormat("yyyy-MM-dd"); |
|---|
| | | String formattedDateString = null; |
|---|
| | | if (StringUtils.isNotEmpty(regTime)) { |
|---|
| | | formattedDateString = outputFormat.format(inputFormat.parse(regTime)); |
|---|
| | | } |
|---|
| | | List<User> users = this.userMapper.listByAdmin(realName, phone, agentId, accountType, isLock, isLogin, formattedDateString, isActive); |
|---|
| | | List<UserOut> userOuts = new ArrayList<>(); |
|---|
| | | |
|---|
| | | List<User> users = this.userMapper.listByAdmin(realName, phone, agentId, accountType); |
|---|
| | | // 获取用户资产信息并构建返回结果 |
|---|
| | | Map<Integer, UserOut> userOutMap = new HashMap<>(); |
|---|
| | | for (User user : users) { |
|---|
| | | ServerResponse money = iUserService.getMoney(user.getId()); |
|---|
| | | List<RUserAssets> rUserAssetsList = (List<RUserAssets>) money.getData(); |
|---|
| | | RUserAssets rUserAssets = rUserAssetsList.stream() |
|---|
| | | .filter(stock -> "IN".equals(stock.getAccectType())) |
|---|
| | | .findFirst() |
|---|
| | | .orElse(null); |
|---|
| | | |
|---|
| | | PageInfo pageInfo = new PageInfo(users); |
|---|
| | | UserOut userOut = Convert.convert(UserOut.class, user); |
|---|
| | | if (rUserAssets != null) { |
|---|
| | | userOut.setTotalMoney(rUserAssets.getTotalMoney().equals("0E-8") ? "0" : rUserAssets.getTotalMoney()); |
|---|
| | | userOut.setFreezeMoney(rUserAssets.getFreezeMoney().equals("0E-8") ? "0" : rUserAssets.getFreezeMoney()); |
|---|
| | | userOut.setAvailableBalance(rUserAssets.getAvailableBalance().equals("0E-8") ? "0" : rUserAssets.getAvailableBalance()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | userOutMap.put(user.getId(), userOut); |
|---|
| | | userOuts.add(userOut); |
|---|
| | | } |
|---|
| | | |
|---|
| | | PageInfo pageInfo = new PageInfo(userOuts); |
|---|
| | | |
|---|
| | | return ServerResponse.createBySuccess(pageInfo); |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | public ServerResponse findByUserId(Integer userId) { |
|---|
| | |
|---|
| | | BigDecimal futuresForceLine = futuresForcePercent.multiply(futuresPositionVO.getAllFuturesDepositAmt()); |
|---|
| | | |
|---|
| | | agentUserListVO.setFuturesForceLine(futuresForceLine); |
|---|
| | | |
|---|
| | | |
|---|
| | | UserBank userBank = this.iUserBankService.findUserBankByUserId(user.getId()); |
|---|
| | | if (userBank != null) { |
|---|
| | | agentUserListVO.setBankName(userBank.getBankName()); |
|---|
| | | agentUserListVO.setBankNo(userBank.getBankNo()); |
|---|
| | | agentUserListVO.setBankAddress(userBank.getBankAddress()); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return agentUserListVO; |
|---|
| | | } |
|---|
