企业OA系统三个核心性能瓶颈的实战解法（附代码与压测数据）

// 解析器接口
public interface ApproverResolver {
    List<String> resolve(Map<String, Object> variables, String expression);
}

// 部门负责人解析器
@Component
public class DeptLeaderResolver implements ApproverResolver {
    @Override
    public List<String> resolve(Map<String, Object> vars, String expr) {
        // 表达式: deptLeader(表单.deptId)
        String deptId = (String) SpelExpressionParser.evaluate(expr, vars);
        return userDao.listDeptManagers(deptId).stream()
                      .map(User::getUserId).collect(Collectors.toList());
    }
}

// 脚本解析器（支持热加载）
@Component
public class ScriptResolver implements ApproverResolver {
    @Override
    public List<String> resolve(Map<String, Object> vars, String expr) {
        // expr: script:approvers.groovy
        String scriptPath = expr.substring("script:".length());
        GroovyScriptEngine engine = new GroovyScriptEngine("/scripts");
        Binding binding = new Binding(vars);
        return (List<String>) engine.run(scriptPath, binding);
    }
}

@EventListener
public void onStart(ProcessStartedEvent event) {
    Map<String, Object> vars = event.getVariables();
    String expr = (String) vars.get("approverExpr");
    List<String> approvers = resolverRegistry.resolve(expr, vars);
    vars.put("assigneeList", approvers); // 供UserTask使用
}

@Service
public class ApprovalSubmitService {
    @Transactional(transactionManager = "bizTxManager")
    public void submit(ApprovalForm form) {
        approvalDao.insert(form);
        // 发布事件，异步处理流程启动
        applicationEventPublisher.publishEvent(new ApprovalCreatedEvent(form));
    }
}

@EventListener
public void handleApprovalCreated(ApprovalCreatedEvent event) {
    // 使用独立事务管理器
    TransactionTemplate flowTmpl = new TransactionTemplate(flowTxManager);
    flowTmpl.execute(status -> {
        try {
            runtimeService.startProcessInstanceByKey(...);
        } catch (StaleObjectException e) {
            // 记录重试消息（发送到CMQ，最多重试3次）
            retryProducer.send(new RetryMessage(event.getFormId(), 3));
        }
        return null;
    });
}

@Component
public class TenantMetaHandler implements MetaObjectHandler {
    @Override
    public void insertFill(MetaObject metaObject) {
        this.strictInsertFill(metaObject, "tenantId", Long.class, 
                              TenantContext.getCurrentTenantId());
    }
}

@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", ...)})
@Component
public class TenantInterceptor implements Interceptor {
    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        StatementHandler handler = (StatementHandler) invocation.getTarget();
        MetaObject meta = SystemMetaObject.forObject(handler);
        MappedStatement ms = (MappedStatement) meta.getValue("delegate.mappedStatement");
        
        // 忽略系统表或标注 @IgnoreTenant 的方法
        if (shouldSkip(ms)) return invocation.proceed();
        
        String sql = (String) meta.getValue("delegate.boundSql.sql");
        String tenantId = TenantContext.getCurrentTenantId().toString();
        
        // 智能插入：只在主表WHERE后追加 AND tenant_id = ?
        String newSql = SqlInjector.injectTenant(sql, tenantId);
        meta.setValue("delegate.boundSql.sql", newSql);
        return invocation.proceed();
    }
}

-- 原始
SELECT * FROM org_user u WHERE u.status = 1
-- 注入后
SELECT * FROM org_user u WHERE u.status = 1 AND u.tenant_id = '1001'

CREATE INDEX idx_tenant_assignee_time ON ACT_RU_TASK(TENANT_ID_, ASSIGNEE_USER_ID_, CREATE_TIME_);

@Cacheable(value = "todo", key = "#userId + '_' + #page")
public PageResult<TodoVO> query(Long userId, int page) {
    return todoSummaryMapper.selectPage(
        new Page<>(page, 20),
        new LambdaQueryWrapper<TodoVO>()
            .eq(TodoVO::getAssigneeUserId, userId)
            .orderByDesc(TodoVO::getCreateTime)
    );
}

@Component
public class TodoCacheManager {
    @CacheEvict(value = "todo", key = "#userId")
    public void evictUser(Long userId) { }
}

FROM openjdk:11-jre-slim
COPY target/oa-flow.jar /app/app.jar
ENTRYPOINT ["java", "-Xmx1g", "-XX:+UseG1GC", "-jar", "/app/app.jar"]