接入 Web 层#

public class BaseConstant {
    public static final String X_REQUEST_ID = "X-Request-Id";
    public static final String SODA_REQUEST_ID = "Soda-Request-Id";
    public static final String X_UID = "X-UID";
    public static final String X_USER_NAME = "X-User-Name";
    public static final String SODA_USER_NAME = "Soda-User-Name";
    public static final String X_AUTHORITIES = "X-Authorities";
    public static final String X_JTI = "X-Jti";
    public static final String X_CALLER_UID = "X-Caller-Uid";
    public static final String SCADA = "scada";
    public static final String X_TENANT_ID = "X-Tenant-Id";
}

PageResult.success(dto.getList(), dto.getTotal(), query.getPageNumberWithDefault(), query.getPageSizeWithDefault());

package com.example.demo.adapter.inbound.web;

import com.example.demo.adapter.inbound.web.dto.ProducerDTO;
import com.example.demo.application.cqrs.command.CreateProducerCommand;
import com.example.demo.application.cqrs.query.GetProducerQuery;
import com.example.demo.application.cqrs.query.ListProducerQuery;
import com.example.demo.application.sample.service.ProducerAppService;
import com.hibuka.soda.foundation.error.BaseException;
import com.hibuka.soda.foundation.io.PageResult;
import com.hibuka.soda.foundation.io.PageVO;
import com.hibuka.soda.foundation.io.Result;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.media.Content;
import io.swagger.v3.oas.annotations.media.Schema;
import io.swagger.v3.oas.annotations.responses.ApiResponse;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.*;

import java.util.List;
import java.util.concurrent.CompletableFuture;

@RestController
@RequestMapping("api")
@RequiredArgsConstructor
public class ProducerController {
    private final ProducerAppService producerAppService;

    @Operation(summary = "聚合跟创建", description = "creatProducer 创建接口描述")
    @ApiResponse(responseCode = "200", description = "返回内容",
            content = @Content(mediaType = "application/json", schema = @Schema(allOf = Result.class)))
    @PostMapping("creatProducer")
    public Result<ProducerDTO> creatProducer(@RequestBody CreateProducerCommand command) throws BaseException {
        ProducerDTO dto = producerAppService.creatProducer(command);
        return Result.success(dto);
    }

    @Operation(summary = "异步聚合跟创建")
    @PostMapping("creatProducerSync")
    public CompletableFuture<Result<ProducerDTO>> creatProducerSync(@RequestBody CreateProducerCommand command) throws BaseException {
        return producerAppService.creatProducerSyn(command).thenApply(Result::success);
    }

    @Operation(summary = "获取聚合跟")
    @PostMapping("getProducer")
    public Result<ProducerDTO> getProducer(@RequestBody GetProducerQuery query) throws BaseException {
        ProducerDTO dto = producerAppService.getProducer(query);
        return Result.success(dto);
    }

    @Operation(summary = "获取聚合跟列表")
    @PostMapping("listProducers")
    public PageResult<List<ProducerDTO>> listProducer(@RequestBody ListProducerQuery query) throws BaseException {
        PageVO<ProducerDTO> dto = producerAppService.listProducer(query);
        return PageResult.success(dto.getList(), dto.getTotal(),
                query.getPageNumberWithDefault(), query.getPageSizeWithDefault());
    }
}

package com.example.demo.adapter.inbound.web.advice;

import com.alibaba.fastjson.JSON;
import com.hibuka.soda.foundation.constant.BaseConstant;
import com.hibuka.soda.foundation.error.BaseErrorCode;
import com.hibuka.soda.foundation.error.BaseException;
import com.hibuka.soda.foundation.io.BaseRequest;
import com.hibuka.soda.foundation.io.PageResult;
import com.hibuka.soda.foundation.io.Result;
import com.hibuka.soda.cqrs.command.BaseCommand;
import com.hibuka.soda.cqrs.query.BaseQuery;
import jakarta.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.ArrayUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;

import java.util.UUID;
import java.util.concurrent.CompletableFuture;

@Aspect
@Component
public class ControllerAroundHandler {
    private static final Logger logger = LoggerFactory.getLogger(ControllerAroundHandler.class);
    private static final String LOG_PATTERN = "requestId:{},method:{}-{}, {}:{}, result:{}, duration:{},username:{}";

    @Around(value = "execution(* com.example.demo.adapter.inbound.web..*.*(..))")
    public Object handleController(ProceedingJoinPoint point) throws Throwable {
        if (!shouldProcess(point)) {
            return point.proceed();
        }

        ServletRequestAttributes requestAttributes =
                (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
        if (requestAttributes == null) {
            return point.proceed();
        }

        return processRequest(point, point.getArgs()[0], requestAttributes);
    }
    ...
}

private boolean shouldProcess(ProceedingJoinPoint point) {
    // 1. 验证返回类型
    MethodSignature signature = (MethodSignature) point.getSignature();
    if (!isValidReturnType(signature.getReturnType())) {
        return false;
    }

    // 2. 验证参数
    Object[] args = point.getArgs();
    if (ArrayUtils.isEmpty(args)) {
        return false;
    }

    // 3. 验证第一个参数类型
    return isValidArg(args[0]);
}

private boolean isValidReturnType(Class<?> returnType) {
    if (Result.class.isAssignableFrom(returnType) || PageResult.class.isAssignableFrom(returnType)) {
        return true;
    }
    // 处理泛型包装类型，如 CompletableFuture<Result<T>>
    if (CompletableFuture.class.isAssignableFrom(returnType)) {
        return true;
    }
    return false;
}

private boolean isValidArg(Object arg) {
    return arg instanceof BaseCommand
            || arg instanceof BaseQuery
            || arg instanceof BaseRequest;
}

private Object processRequest(ProceedingJoinPoint point, Object firstArg,
                              ServletRequestAttributes requestAttributes) throws Throwable {
    MethodSignature signature = (MethodSignature) point.getSignature();
    Class<?> returnType = signature.getReturnType();
    HttpServletRequest request = requestAttributes.getRequest();

    final String requestId;
    String tempRequestId = request.getHeader(BaseConstant.SODA_REQUEST_ID);
    if (tempRequestId == null || tempRequestId.isEmpty()) {
        requestId = UUID.randomUUID().toString();
    } else {
        requestId = tempRequestId;
    }
    String username = request.getHeader(BaseConstant.SODA_USER_NAME);

    // 设置请求信息
    setRequestInfo(firstArg, requestId, username);

    // 处理请求并记录日志
    long startNanos = System.nanoTime();
    Object result = null;

    MDC.put("requestId", requestId);
    MDC.put("username", username);
    try {
        result = point.proceed();
        long durationMs = (System.nanoTime() - startNanos) / 1_000_000L;
        logSuccess(requestId, signature, firstArg, result, durationMs, username);

        // 处理 CompletableFuture 类型
        if (result instanceof CompletableFuture) {
            return ((CompletableFuture<?>) result).thenApply(res -> {
                setRequestId(res, requestId);
                return res;
            });
        }
    } catch (Exception e) {
        result = handleException(e, returnType);
        long durationMs = (System.nanoTime() - startNanos) / 1_000_000L;
        logError(requestId, signature, firstArg, result, durationMs, username, e);
    } finally {
        MDC.remove("requestId");
        MDC.remove("username");
    }

    return setRequestId(result, requestId);
}

private void setRequestInfo(Object firstArg, String requestId, String username) {
    if (firstArg instanceof BaseCommand) {
        BaseCommand cmd = (BaseCommand) firstArg;
        cmd.setRequestId(requestId);
        cmd.setUserName(username);
    } else if (firstArg instanceof BaseQuery) {
        BaseQuery query = (BaseQuery) firstArg;
        query.setRequestId(requestId);
        query.setUserName(username);
    } else if (firstArg instanceof BaseRequest) {
        BaseRequest request = (BaseRequest) firstArg;
        request.setRequestId(requestId);
        request.setUserName(username);
    }
}

private Object handleException(Exception e, Class<?> returnType) {
    String errorCode;
    String message;
    boolean showDetail = true;

    if (e instanceof BaseException) {
        // 业务异常：原样返回
        BaseException baseException = (BaseException) e;
        errorCode = String.valueOf(baseException.getCode());
        message = baseException.getMessage();
    } else {
        // 系统异常：隐藏内部细节
        errorCode = String.valueOf(BaseErrorCode.SYSTEM_ERROR.getCode());
        message = "系统内部错误，请稍后重试";
        showDetail = false;
    }

    if (Result.class.isAssignableFrom(returnType)) {
        return Result.fail(Integer.parseInt(errorCode), message);
    } else if (PageResult.class.isAssignableFrom(returnType)) {
        return PageResult.fail(Integer.parseInt(errorCode), message);
    } else {
        return Result.fail(Integer.parseInt(errorCode), message);
    }
}

private void logSuccess(String requestId, MethodSignature signature, Object firstArg,
                        Object result, long durationMs, String username) {
    String argJson = safeJson(firstArg, true);
    String resultJson = safeJson(result, true);
    logger.info(LOG_PATTERN, requestId, signature.getDeclaringTypeName(), signature.getName(),
            firstArg.getClass().getSimpleName(), argJson, resultJson, durationMs, username);
}

private void logError(String requestId, MethodSignature signature, Object firstArg,
                      Object result, long durationMs, String username, Exception e) {
    String argJson = safeJson(firstArg, false);
    String resultJson = safeJson(result, false);
    logger.error(LOG_PATTERN, requestId, signature.getDeclaringTypeName(), signature.getName(),
            firstArg.getClass().getSimpleName(), argJson, resultJson, durationMs, username, e);
}

private String safeJson(Object obj, boolean forInfo) {
    if (obj == null) {
        return "null";
    }
    boolean enabled = forInfo ? logger.isInfoEnabled() : logger.isErrorEnabled();
    if (!enabled) {
        return "";
    }
    String json = JSON.toJSONString(obj);
    int maxLen = 8192;
    if (json.length() <= maxLen) {
        return json;
    }
    int head = 4096;
    int tail = 256;
    if (json.length() <= head + tail) {
        return json.substring(0, Math.min(json.length(), head));
    }
    return json.substring(0, head) + "...<truncated>..." + json.substring(json.length() - tail);
}

private Object setRequestId(Object result, String requestId) {
    if (result instanceof Result) {
        ((Result) result).setRequestId(requestId);
    } else if (result instanceof PageResult) {
        ((PageResult) result).setRequestId(requestId);
    }
    return result;
}

<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
  <encoder>
    <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - [reqId=%X{requestId}, user=%X{username}] %msg%n</pattern>
  </encoder>
</appender>

package com.example.demo.adapter.inbound.web.advice;

import com.hibuka.soda.foundation.error.BaseErrorCode;
import com.hibuka.soda.foundation.error.BaseException;
import com.hibuka.soda.foundation.io.Result;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.HttpStatus;
import org.springframework.validation.BindException;
import org.springframework.validation.FieldError;
import org.springframework.web.HttpMediaTypeNotSupportedException;
import org.springframework.web.HttpRequestMethodNotSupportedException;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.MissingServletRequestParameterException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.ResponseStatus;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
import org.springframework.web.servlet.NoHandlerFoundException;

import java.util.List;
import java.util.stream.Collectors;

@RestControllerAdvice(basePackages = "com.example.demo.adapter.inbound.web")
public class GlobalExceptionHandler {
    private static final Logger logger = LoggerFactory.getLogger(GlobalExceptionHandler.class);

    @ExceptionHandler(BaseException.class)
    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
    public Result<Object> handleBaseException(BaseException e) {
        logger.error("Business Exception: {}", e.getMessage(), e);
        return Result.fail(e.getCode(), e.getMessage());
    }

    @ExceptionHandler(MethodArgumentNotValidException.class)
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public Result<Object> handleMethodArgumentNotValidException(MethodArgumentNotValidException e) {
        List<String> errors = e.getBindingResult().getFieldErrors().stream()
                .map(FieldError::getDefaultMessage).collect(Collectors.toList());
        String message = String.join(", ", errors);
        logger.warn("Method Argument Not Valid: {}", message);
        return Result.fail(HttpStatus.BAD_REQUEST.value(), message);
    }

    @ExceptionHandler(BindException.class)
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public Result<Object> handleBindException(BindException e) { ... }

    @ExceptionHandler(MissingServletRequestParameterException.class)
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public Result<Object> handleMissingServletRequestParameterException(MissingServletRequestParameterException e) { ... }

    @ExceptionHandler(MethodArgumentTypeMismatchException.class)
    @ResponseStatus(HttpStatus.BAD_REQUEST)
    public Result<Object> handleMethodArgumentTypeMismatchException(MethodArgumentTypeMismatchException e) { ... }

    @ExceptionHandler(HttpRequestMethodNotSupportedException.class)
    @ResponseStatus(HttpStatus.METHOD_NOT_ALLOWED)
    public Result<Object> handleHttpRequestMethodNotSupportedException(HttpRequestMethodNotSupportedException e) { ... }

    @ExceptionHandler(HttpMediaTypeNotSupportedException.class)
    @ResponseStatus(HttpStatus.UNSUPPORTED_MEDIA_TYPE)
    public Result<Object> handleHttpMediaTypeNotSupportedException(HttpMediaTypeNotSupportedException e) { ... }

    @ExceptionHandler(NoHandlerFoundException.class)
    @ResponseStatus(HttpStatus.NOT_FOUND)
    public Result<Object> handleNoHandlerFoundException(NoHandlerFoundException e) { ... }

    @ExceptionHandler(Exception.class)
    @ResponseStatus(HttpStatus.INTERNAL_SERVER_ERROR)
    public Result<Object> handleException(Exception e) {
        logger.error("Unexpected Exception: {}", e.getMessage(), e);
        // 系统异常不向客户端展示详细错误信息
        return Result.fail(BaseErrorCode.SYSTEM_ERROR.getCode(), "系统内部错误，请稍后重试");
    }
}

HTTP POST /api/creatProducer
  Header: Soda-Request-Id: abc-123
          Soda-User-Name: alice
  Body:   {"name": "生产车间"}
  │
  ├─ ControllerAroundHandler
  │    ├─ 读 Soda-Request-Id → requestId = "abc-123"
  │    ├─ 读 Soda-User-Name → username = "alice"
  │    ├─ cmd.setRequestId("abc-123") / cmd.setUserName("alice")
  │    ├─ MDC.put("requestId", ...) / MDC.put("username", ...)
  │    └─ proceed()
  │
  ├─ Controller：绑定 CreateProducerCommand，调应用服务
  │
  ├─ AppService：busFacade.sendTransactCommand(command)
  │
  ├─ CqrsAroundHandler（拦截 CommandBus.send）
  │    ├─ 把 requestId / userName / jti / authorities 搬进 DomainEventContext
  │    └─ proceed()
  │
  ├─ CommandHandler.handle(command)
  │    ├─ ParamChecker 校验
  │    ├─ Producer.create(name) → addPendingEvent(ProducerEvent)  ← 自动注入上下文
  │    └─ writeRepository.save(domain)
  │          └─ RepositoryEventAspect
  │               ├─ 执行真正的 insert
  │               ├─ 取走 domainEvents 并清空
  │               └─ 事务提交后 publish(event)
  │
  ├─ ProducerEventHandler.handle(event)  ← 收到事件
  │
  └─ Controller 返回 Result.success(dto)
       ControllerAroundHandler 补上 requestId，清理 MDC