From d3d65af98906ccc78652c16be7e8a9fbdc03f258 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期二, 12 五月 2026 19:13:27 +0800
Subject: [PATCH] 日志 + 加密

---
 xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/controller/XpInvitationCodeController.java |   54 +++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 43 insertions(+), 11 deletions(-)

diff --git a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/controller/XpInvitationCodeController.java b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/controller/XpInvitationCodeController.java
index 9a53ade..d394562 100644
--- a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/controller/XpInvitationCodeController.java
+++ b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/controller/XpInvitationCodeController.java
@@ -27,6 +27,8 @@
 import io.swagger.annotations.*;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.poi.ss.usermodel.Workbook;
+import org.apache.shardingsphere.transaction.annotation.ShardingSphereTransactionType;
+import org.apache.shardingsphere.transaction.core.TransactionType;
 import org.springframework.context.MessageSource;
 import org.springframework.context.i18n.LocaleContextHolder;
 import org.springframework.transaction.annotation.Transactional;
@@ -46,6 +48,9 @@
 import java.util.*;
 import java.util.stream.Collectors;
 import java.util.regex.Pattern;
+import com.xiaopeng.common.log.annotation.AdminOperationLog;
+import com.xiaopeng.common.log.enums.AdminBusinessType;
+import com.xiaopeng.common.log.enums.AdminOperationType;
 
 /**
  * <p>
@@ -82,7 +87,12 @@
     @PostMapping("/api/v1/invitation/add")
     @ResponseBody
     @ApiOperation(value = "生成邀请码")
-    @Transactional
+    @AdminOperationLog(
+            businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT,
+            operationType = AdminOperationType.ADD,
+            content = "生成邀请码",
+            appendRequestData = true
+    )
     public R add(@RequestBody InvitationAddDto dto){
         long existing = xpInvitationCodeService.count();
         long incoming = Arrays.stream(Optional.ofNullable(dto.getPhones()).orElse("").split(","))
@@ -107,6 +117,12 @@
     @ApiImplicitParams({
             @ApiImplicitParam(value = "id", name = "id", dataType = "Long", required = true)
     })
+    @AdminOperationLog(
+            businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT,
+            operationType = AdminOperationType.EDIT,
+            contentExpression = "'解绑邀请码,id=' + #p0",
+            appendRequestData = false
+    )
     public R unbind(@RequestParam("id") Long id){
         UpdateWrapper<XpInvitationCode> xpInvitationCodeUpdateWrapper = new UpdateWrapper<>();
         xpInvitationCodeUpdateWrapper.eq("id",id);
@@ -148,6 +164,12 @@
     }
     @ApiOperation(value = "邀请码导入")
     @PostMapping("/base/v1/invitation/importExcel")
+    @AdminOperationLog(
+            businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT,
+            operationType = AdminOperationType.IMPORT,
+            content = "导入邀请码",
+            appendRequestData = false
+    )
     public R<String> importExcel(@RequestParam("file") MultipartFile file) {
         ImportParams params = new ImportParams();
         params.setHeadRows(1); //表头行数
@@ -207,7 +229,7 @@
 
             if (!StringUtils.hasLength(bindAccount)) {
                 errors.add(messageSource.getMessage(I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_EMPTY, new Object[]{rowNum}, I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_EMPTY, LocaleContextHolder.getLocale()));
-            } else if (!PhoneUtil.isPhone(bindAccount)) {
+            } else if (!PhoneUtil.isMobile(bindAccount)) {
                 errors.add(messageSource.getMessage(I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_INVALID, new Object[]{rowNum, bindAccount}, I18nKeyConstant.INVITATION_IMPORT_ACCOUNT_INVALID, LocaleContextHolder.getLocale()));
             }
 
@@ -295,6 +317,12 @@
     }
     @ApiOperation(value = "邀请码导出")
     @PostMapping(value = "/api/v1/invitation/exportExcel")
+    @AdminOperationLog(
+            businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT,
+            operationType = AdminOperationType.EXPORT,
+            content = "导出邀请码",
+            appendRequestData = true
+    )
     public void exportExcel(@RequestBody InvitationPageListQuery query) {
         List<XpInvitationCode> list = xpInvitationCodeService.exportList(query);
         List<XpInvitationCodeExportExcel> xpWhitelistExportExcels = new ArrayList<>();
@@ -338,6 +366,12 @@
     @GetMapping("/api/v1/invitation/deleteByIds")
     @ResponseBody
     @ApiOperation(value = "批量删除")
+    @AdminOperationLog(
+            businessType = AdminBusinessType.INVITATION_CODE_MANAGEMENT,
+            operationType = AdminOperationType.DELETE,
+            contentExpression = "'批量删除邀请码,ids=' + #p0",
+            appendRequestData = false
+    )
     public R deleteByIds(String ids){
         // 再转化为Long类型
         List<Long> longs = Arrays.stream(ids.split(",")).map(Long::parseLong).collect(Collectors.toList());
@@ -346,14 +380,12 @@
     }
 
     @ApiOperation(value = "校验生成邀请码的手机号是否合法")
-    @PostMapping("/api/v1/invitation/validateCode")
-    public R<Boolean> validateCode(@RequestParam String phone){
-        if (!PhoneUtil.isMobile(phone)){
-            return R.ok(false);
-        }
-        List<XpInvitationCode> existsList = xpInvitationCodeService.lambdaQuery()
-                .in(XpInvitationCode::getBindAccount, phone)
-                .list();
-        return R.ok(CollUtil.isEmpty(existsList));
+    @GetMapping("/api/v1/invitation/validateCode")
+    public R<List<String>> validateCode(@RequestParam String phone){
+        List<String> phoneList = Arrays.asList(phone.split(","));
+        List<String> existPhones = phoneList.stream().filter(item -> xpInvitationCodeService.lambdaQuery()
+                .in(XpInvitationCode::getBindAccount, item)
+                .count() > 0).collect(Collectors.toList());
+        return R.ok(existPhones);
     }
 }

--
Gitblit v1.7.1