日志 + 加密

liujie

2026-05-12 d3d65af98906ccc78652c16be7e8a9fbdc03f258

 xp-robotaxi-account-boot/src/main/java/com/xiaopeng/account/service/impl/XpOperationsUserServiceImpl.java

@@ -4,6 +4,7 @@
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.PhoneUtil;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.Wrapper;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
@@ -31,6 +32,7 @@
import com.xiaopeng.api.vo.account.*;
import com.xiaopeng.common.core.domain.R;
import com.xiaopeng.common.core.exception.ServiceException;
import com.xiaopeng.common.core.utils.SensitiveDataCryptoUtil;
import com.xiaopeng.common.core.utils.poi.ExcelUtil;
import com.xiaopeng.common.core.web.page.PageInfo;
import com.xiaopeng.common.security.utils.SecurityUtils;
@@ -48,6 +50,7 @@

import javax.annotation.Resource;
import javax.servlet.http.HttpServletResponse;
import java.io.Serializable;
import java.io.IOException;
import java.io.InputStream;
import java.io.UnsupportedEncodingException;
@@ -94,17 +97,28 @@
    private AliOssDownloadUtil aliOssDownloadUtil;

    @Override
    public XpOperationsUser getById(Serializable userId) {
        XpOperationsUser user = super.getById(userId);
        decryptPhone(user);
        return user;
    }

    @Override
    public List<XpOperationsUser> listByName(String nickName) {
        if (StringUtils.isBlank(nickName)) {
            return Collections.emptyList();
        }
        return lambdaQuery().like(XpOperationsUser::getNickName, nickName).list();
        List<XpOperationsUser> list = lambdaQuery().like(XpOperationsUser::getNickName, nickName).list();
        decryptPhones(list);
        return list;
    }

    @Override
    public PageInfo<XpOperationsUserWithRoleVO> selectUserPageByConditions(XpOperationsUserPageQuery query) {
        query.setPhoneNumberQueryValues(SensitiveDataCryptoUtil.queryValues(query.getPhoneNumber()));
        PageInfo<XpOperationsUserWithRoleVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
        Page<XpOperationsUserWithRoleVO> page = baseMapper.selectUserPageByConditions(pageInfo, query);
        decryptWithRolePhones(page.getRecords());
        pageInfo.setRecords(page.getRecords());
        return pageInfo;
    }
@@ -205,6 +219,7 @@

    @Override
    public PageInfo<XpOperationsUserVO> pageList(XpOperationsUserQuery query) {
        query.setPhoneNumberQueryValues(SensitiveDataCryptoUtil.queryValues(query.getPhoneNumber()));
        PageInfo<XpOperationsUserVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
        List<XpOperationsUserVO> list = this.baseMapper.pageList(pageInfo, query);

@@ -243,6 +258,7 @@
            }
        }

        decryptVoPhones(list);
        for (XpOperationsUserVO xpOperationsUserVO : list) {
            String avatar = xpOperationsUserVO.getAvatar();
            // 处理空的情况
@@ -269,8 +285,8 @@

    @Override
    public R<String> addOperationsUser(XpOperationsUserAddDTO dto) {
        long userCount = this.count(Wrappers.lambdaQuery(XpOperationsUser.class)
                .eq(XpOperationsUser::getPhoneNumber, dto.getPhoneNumber()));
        long userCount = StringUtils.isBlank(dto.getPhoneNumber()) ? 0 : this.count(Wrappers.lambdaQuery(XpOperationsUser.class)
                .in(XpOperationsUser::getPhoneNumber, SensitiveDataCryptoUtil.queryValues(dto.getPhoneNumber())));
        if (StringUtils.isNotBlank(dto.getPhoneNumber()) && userCount>0) {
            throw new ServiceException("登录账号重复", I18nKeyConstant.ACCOUNT_DUPLICATE);
        }
@@ -300,8 +316,8 @@

    @Override
    public R<String> editOperationsUser(XpOperationsUserAddDTO dto) {
        XpOperationsUser operationsUser = this.getOne(Wrappers.lambdaQuery(XpOperationsUser.class)
                .eq(XpOperationsUser::getPhoneNumber, dto.getPhoneNumber())
        XpOperationsUser operationsUser = StringUtils.isBlank(dto.getPhoneNumber()) ? null : this.getOne(Wrappers.lambdaQuery(XpOperationsUser.class)
                .in(XpOperationsUser::getPhoneNumber, SensitiveDataCryptoUtil.queryValues(dto.getPhoneNumber()))
                .last("LIMIT 1"));

        if (StringUtils.isNotBlank(dto.getPhoneNumber()) && (Objects.nonNull(operationsUser) && !dto.getId().equals(operationsUser.getId()) )) {
@@ -368,7 +384,11 @@
     */
    @Override
    public void exportOperationsUser(XpOperationsUserQuery query, HttpServletResponse response) {
        query.setPhoneNumberQueryValues(SensitiveDataCryptoUtil.queryValues(query.getPhoneNumber()));
        List<ExportOperationsUserVo> list = this.baseMapper.exportOperationsUser(query);
        for (ExportOperationsUserVo item : list) {
            item.setPhoneNumber(SensitiveDataCryptoUtil.decryptIfPossible(item.getPhoneNumber()));
        }
        ExcelUtil<ExportOperationsUserVo> util = new ExcelUtil<ExportOperationsUserVo>(ExportOperationsUserVo.class);
        util.exportExcel(response, list, "运维人员管理列表");
    }
@@ -398,7 +418,7 @@
            }
            // 判断账号是否已存在
            long count = this.count(Wrappers.lambdaQuery(XpOperationsUser.class)
                    .eq(XpOperationsUser::getPhoneNumber, exportOperationsUserVo.getPhoneNumber()));
                    .in(XpOperationsUser::getPhoneNumber, SensitiveDataCryptoUtil.queryValues(exportOperationsUserVo.getPhoneNumber())));
            if (count > 0) {
                throw new ServiceException("以下帐号已存在：", I18nKeyConstant.ACCOUNT_EXIST,new Object[]{exportOperationsUserVo.getPhoneNumber()});
            }
@@ -510,6 +530,7 @@

            // 根据你的 VO 字段调整
            XpOperationsUserWithRoleVO vo = BeanUtil.copyProperties(u, XpOperationsUserWithRoleVO.class);
            vo.setPhoneNumber(SensitiveDataCryptoUtil.decryptIfPossible(vo.getPhoneNumber()));
            vo.setRoles(roles);

            return vo;
@@ -521,6 +542,88 @@
        if (StringUtils.isBlank(phoneNumber)) {
            return Collections.emptyList();
        }
        return lambdaQuery().like(XpOperationsUser::getPhoneNumber, phoneNumber).list();
        List<XpOperationsUser> list = lambdaQuery()
                .in(XpOperationsUser::getPhoneNumber, SensitiveDataCryptoUtil.queryValues(phoneNumber))
                .list();
        decryptPhones(list);
        return list;
    }

    @Override
    public boolean save(XpOperationsUser entity) {
        encryptPhone(entity);
        try {
            return super.save(entity);
        } finally {
            decryptPhone(entity);
        }
    }

    @Override
    public boolean updateById(XpOperationsUser entity) {
        encryptPhone(entity);
        try {
            return super.updateById(entity);
        } finally {
            decryptPhone(entity);
        }
    }

    @Override
    public List<XpOperationsUser> list() {
        List<XpOperationsUser> list = super.list();
        decryptPhones(list);
        return list;
    }

    @Override
    public List<XpOperationsUser> list(Wrapper<XpOperationsUser> queryWrapper) {
        List<XpOperationsUser> list = super.list(queryWrapper);
        decryptPhones(list);
        return list;
    }

    @Override
    public List<XpOperationsUser> listByIds(Collection<? extends Serializable> idList) {
        List<XpOperationsUser> list = super.listByIds(idList);
        decryptPhones(list);
        return list;
    }

    @Override
    public XpOperationsUser getOne(Wrapper<XpOperationsUser> queryWrapper) {
        XpOperationsUser user = super.getOne(queryWrapper);
        decryptPhone(user);
        return user;
    }

    private void encryptPhone(XpOperationsUser user) {
        if (user != null) {
            user.setPhoneNumber(SensitiveDataCryptoUtil.encrypt(user.getPhoneNumber()));
        }
    }

    private void decryptPhone(XpOperationsUser user) {
        if (user != null) {
            user.setPhoneNumber(SensitiveDataCryptoUtil.decryptIfPossible(user.getPhoneNumber()));
        }
    }

    private void decryptPhones(Collection<XpOperationsUser> users) {
        if (users != null) {
            users.forEach(this::decryptPhone);
        }
    }

    private void decryptVoPhones(Collection<XpOperationsUserVO> users) {
        if (users != null) {
            users.forEach(user -> user.setPhoneNumber(SensitiveDataCryptoUtil.decryptIfPossible(user.getPhoneNumber())));
        }
    }

    private void decryptWithRolePhones(Collection<XpOperationsUserWithRoleVO> users) {
        if (users != null) {
            users.forEach(user -> user.setPhoneNumber(SensitiveDataCryptoUtil.decryptIfPossible(user.getPhoneNumber())));
        }
    }
}