操作日志5

yd-csf-service/src/main/java/com/yd/csf/service/audit/AuditService.java

@@ -9,9 +9,12 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.RequestContextHolder;
 import org.springframework.web.context.request.ServletRequestAttributes;
 import org.springframework.web.context.request.ServletRequestAttributes;
+import org.springframework.web.util.ContentCachingRequestWrapper;
 
 
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletRequest;
 import java.io.IOException;
 import java.io.IOException;
+import java.io.UnsupportedEncodingException;
+import java.nio.charset.StandardCharsets;
 import java.util.Date;
 import java.util.Date;
 import java.util.UUID;
 import java.util.UUID;
 import java.util.stream.Collectors;
 import java.util.stream.Collectors;
@@ -107,12 +110,13 @@ public class AuditService {
     }
     }
 
 
     private String getRequestBody(HttpServletRequest request) {
     private String getRequestBody(HttpServletRequest request) {
-        try {
-            return request.getReader().lines().collect(Collectors.joining("\n"));
-        } catch (IOException e) {
-            log.debug("获取请求体失败: {}", e.getMessage());
+        if (!(request instanceof ContentCachingRequestWrapper)) {
             return null;
             return null;
         }
         }
+        ContentCachingRequestWrapper wrapper = (ContentCachingRequestWrapper) request;
+        byte[] body = wrapper.getContentAsByteArray();
+        if (body.length == 0) return null;
+        return new String(body, StandardCharsets.UTF_8);
     }
     }
 
 
     private void fillOperatorInfo(AuditContext ctx) {
     private void fillOperatorInfo(AuditContext ctx) {

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/CommissionServiceImpl.java

@@ -618,7 +618,7 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     @Override
     @Override
     @Transactional(rollbackFor = Exception.class)
     @Transactional(rollbackFor = Exception.class)
     public Boolean generateFortune(GenerateFortuneRequest generateFortuneRequest) {
     public Boolean generateFortune(GenerateFortuneRequest generateFortuneRequest) {
-        return auditTemplate.execute("应付款管理", 2, "生成可出账记录", ctx -> {
+        return auditTemplate.execute("入账检核", 0, "生成可出账记录", ctx -> {
             List<String> commissionBizIdList = generateFortuneRequest.getCommissionBizIdList();
             List<String> commissionBizIdList = generateFortuneRequest.getCommissionBizIdList();
             List<Commission> commissions = this.lambdaQuery().in(Commission::getCommissionBizId, commissionBizIdList).list();
             List<Commission> commissions = this.lambdaQuery().in(Commission::getCommissionBizId, commissionBizIdList).list();