blame | history | patch | commit | commitdiff | ignore whitespace
1
zj
2024-10-08 e64cc04da1568aff094c687fa18682b8d435f0b1 
 src/main/java/com/nq/service/impl/UserServiceImpl.java


@@ -1,5 +1,7 @@


package com.nq.service.impl;




import cn.hutool.core.convert.Convert;


import cn.hutool.core.date.DateUtil;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.github.pagehelper.PageHelper;


@@ -13,6 +15,7 @@


import com.nq.pojo.*;


import com.nq.pojo.reponse.RUserAssets;


import com.nq.service.*;


import com.nq.utils.UserPointUtil;


import com.nq.utils.timeutil.DateTimeUtil;


import com.nq.utils.PropertiesUtil;


import com.nq.utils.SymmetricCryptoUtil;


@@ -27,18 +30,22 @@


import com.nq.vo.indexposition.IndexPositionVO;


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;


@@ -99,6 +106,8 @@


    @Autowired


    StockPoll stockPoll;




    @Autowired


    StockSubscribeMapper stockSubscribeMapper;




    @Resource


    MoneyLogMapper mapper;


@@ -117,9 +126,17 @@


    @Autowired


    ISiteMessageService iSiteMessageService;




    @Autowired


    private ApplyLeverMapper applyLeverMapper;




    @Autowired


    private UserPositionMapper userPositionMapper;




    @Autowired


    IPriceServices priceServices;




    @Autowired


    IUserService iUserService;






    public ServerResponse reg(String yzmCode, String agentCode, String phone, String userPwd, HttpServletRequest request) {


@@ -285,9 +302,30 @@


        String userJson = RedisShardedPoolUtils.get(loginToken);


        User user = (User) JsonUtil.string2Obj(userJson, User.class);


        User dbuser = this.userMapper.selectById(user.getId());




        SiteSetting siteSetting = iSiteSettingService.getSiteSetting();


        UserInfoVO userInfoVO = assembleUserInfoVO(dbuser, siteSetting);


        ApplyLever applyLever = applyLeverMapper.selectOne(new LambdaQueryWrapper<ApplyLever>()


                .eq(ApplyLever::getUserId, user.getId())


                .eq(ApplyLever::getState, 1)


                .orderByDesc(ApplyLever::getCreateTime)


                .last(" limit 1"));


        if(null == applyLever || applyLever.getLever().equals("1")){


            userInfoVO.setSiteLever("1");


        }else{


            userInfoVO.setSiteLever(leverSplit(applyLever.getLever()));


        }


        return ServerResponse.createBySuccess(userInfoVO);


    }




    public String leverSplit(String lever){


        String levers = "1/2/5/10";


        String[] parts = levers.split("/");


        int index = Arrays.asList(parts).indexOf(lever);


        if (index != -1) {


            return String.join("/", Arrays.copyOfRange(parts, 0, index + 1));


        }


        return null;


    }






@@ -483,7 +521,8 @@


            rUserAssets.setCumulativeProfitAndLoss(hProfitAndLose.toString());


            rUserAssets.setHandlingCharge(hMoney.toString());


            rUserAssets.setProfitAndLoss(profitAndLose.toString());




            rUserAssets.setIsZf(userAssets.getIsZf());


            rUserAssets.setAmountToBeCovered((userAssets.getAmountToBeCovered().add(userAssets.getHandlingChargeWritten()).toString()));


            BigDecimal rate = rateServices.currencyRate(


                    EStockType.getEStockTypeByCode(userAssets.getAccectType()),EStockType.US);




@@ -499,7 +538,7 @@




            BigDecimal  totleMoneyUSD = totalAssets;


            if(totalAssets.compareTo(BigDecimal.ZERO)>0){


                totleMoneyUSD  = totleMoneyUSD.multiply(rate);


                totleMoneyUSD  = totleMoneyUSD.multiply(rate).subtract(new BigDecimal(rUserAssets.getHandlingCharge()));


            }




            BigDecimal  cumulativeProfitAndLossUSD = hProfitAndLose;


@@ -526,7 +565,9 @@


            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).toString());


            BigDecimal decimal = new BigDecimal(rUserAssets.getTotalMoney()).add(new BigDecimal(rUserAssets.getProfitAndLoss()));


            rUserAssets.setTotalMoney(decimal.toString());


            AllProfitAndLose = AllProfitAndLose.add(profitAndLossUSD);


            allTotalAssets = allTotalAssets.add(totleMoneyUSD);


            allAmt = allAmt.add(availableBalanceUSD);


@@ -563,6 +604,42 @@


        rUserAssetsList.add(rUserAssets);




        return ServerResponse.createBySuccess(rUserAssetsList);


    }




    public BigDecimal getProfitAndLose(Integer userId){


        List<UserPosition> userPositions;


        userPositions = userPositionMapper.


                findMyPositionByCodeAndSpell(userId,


                        "","",


                        0, "IN");






        List<UserPositionVO> userPositionVOS = Lists.newArrayList();


        if (userPositions.size() > 0) {


            for (UserPosition position : userPositions) {


                UserPositionVO userPositionVO = UserPointUtil.assembleUserPositionVO(position, priceServices.getNowPrice(position.getStockCode()));




                StockSubscribe stockSubscribe = stockSubscribeMapper.selectOne(new LambdaQueryWrapper<StockSubscribe>()


                        .eq(StockSubscribe::getCode, userPositionVO.getStockCode()));


                if(position.getSellOrderId() == null){


                    if (null != stockSubscribe && DateUtil.date().before(stockSubscribe.getListDate())) {


                        userPositionVO.setProfitAndLose(BigDecimal.ZERO);


                    }else{


                        userPositionVO.setProfitAndLose(userPositionVO.getProfitAndLose().multiply(new BigDecimal(userPositionVO.getOrderLever())));


                    }


                }else{


                    userPositionVO.setProfitAndLose(userPositionVO.getProfitAndLose().multiply(new BigDecimal(userPositionVO.getOrderLever())));


                }




                userPositionVOS.add(userPositionVO);




            }


        }


        BigDecimal profitAndLose = BigDecimal.ZERO;


        for (UserPositionVO f : userPositionVOS) {


            profitAndLose = profitAndLose.add(f.getProfitAndLose());


        }


        return profitAndLose;


    }




    @Override


@@ -686,10 +763,24 @@


        List<User> users = this.userMapper.listByAgent(realName, phone, searchId, accountType);




        List<AgentUserListVO> agentUserListVOS = Lists.newArrayList();




        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);




            AgentUserListVO agentUserListVO = assembleAgentUserListVO(user, siteSetting


                    .getForceStopPercent(), siteIndexSetting


                    .getForceSellPercent(), siteFuturesSetting.getForceSellPercent());


            if (rUserAssets != null) {


                agentUserListVO.setUserAmt(rUserAssets.getTotalMoney().equals("0E-8") ? new BigDecimal("0") : new BigDecimal(rUserAssets.getTotalMoney()));


                agentUserListVO.setFreezeMoney(rUserAssets.getFreezeMoney().equals("0E-8") ? "0" : rUserAssets.getFreezeMoney());


                agentUserListVO.setAvailableBalance(rUserAssets.getAvailableBalance().equals("0E-8") ? "0" : rUserAssets.getAvailableBalance());


            }


            agentUserListVOS.add(agentUserListVO);


        }




@@ -745,15 +836,45 @@


    }






    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);




            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());


                userOut.setAmountToBeCovered(rUserAssets.getAmountToBeCovered());


            }




            userOutMap.put(user.getId(), userOut);


            userOuts.add(userOut);


        }




        PageInfo pageInfo = new PageInfo(users);




        pageInfo.setList(userOuts);


        return ServerResponse.createBySuccess(pageInfo);


    }










    public ServerResponse findByUserId(Integer userId) {


@@ -964,7 +1085,9 @@


        agentUserListVO.setIsLogin(user.getIsLogin());


        agentUserListVO.setRegAddress(user.getRegAddress());


        agentUserListVO.setIsActive(user.getIsActive());




        agentUserListVO.setImg1Key(user.getImg1Key());


        agentUserListVO.setImg2Key(user.getImg2Key());


        agentUserListVO.setImg3Key(user.getImg3Key());








@@ -995,14 +1118,6 @@


        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;


    }