优雅的实现符合开闭原则的流水日志抽取demo

public class SaveOrder {
    private Long id;
}

public class UpdateOrder {
    private Long orderId;
}

public class OperateLogDo {
    private Long orderId;
    private String desc;
    private String result;
}

public interface Convert<PARAM> {
    OperateLogDo convert(PARAM param);
}

public class SaveOrderConvert implements Convert<SaveOrder> {
    @Override
    public OperateLogDo convert(SaveOrder saveOrder) {
        OperateLogDo operateLogDo = new OperateLogDo();
        operateLogDo.setOrderId(saveOrder.getId());
        return operateLogDo;
    }
}

public class UpdateOrderConvert implements Convert<UpdateOrder> {
    @Override
    public OperateLogDo convert(UpdateOrder updateOrder) {
        OperateLogDo operateLogDo = new OperateLogDo();
        operateLogDo.setOrderId(updateOrder.getOrderId());
        return operateLogDo;
    }
}

@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
@Documented
public @interface  RecordOperate {
    //日志描述
    String desc() default "";
    Class<? extends Convert> convert();
}

@Component
@Aspect
public class OperateAspect {
    //根据需求来定义需要多少线程 编写测试demo需求并不高
    private ThreadPoolExecutor executor = new ThreadPoolExecutor(1,1,1, TimeUnit.SECONDS,new LinkedBlockingDeque<>(100));

    @Around("@annotation(com.hyc.annotation.RecordOperate)")
    public Object around(ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
        Object result  = proceedingJoinPoint.proceed();
        executor.execute(()->{
            try {
                MethodSignature signature = (MethodSignature)proceedingJoinPoint.getSignature();
                RecordOperate recordOperate = signature.getMethod().getAnnotation(RecordOperate.class);
                Class<? extends Convert> convert = recordOperate.convert();
                Convert LogConvert = convert.newInstance();
                OperateLogDo operateLogDo = LogConvert.convert(proceedingJoinPoint.getArgs()[0]);
                operateLogDo.setDesc(recordOperate.desc());
                operateLogDo.setResult(result.toString());
                System.out.println("insert opreateLog"+ JSON.toJSONString(operateLogDo));
            } catch (InstantiationException e) {
                throw new RuntimeException(e);
            } catch (IllegalAccessException e) {
                throw new RuntimeException(e);
            }
        });
        return result;
    }
}

@SpringBootApplication
public class AopPublicLogApplication implements CommandLineRunner  {

    @Autowired
    OrderService orderService;

    public static void main(String[] args) {
        SpringApplication.run(AopPublicLogApplication.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        SaveOrder saveOrder = new SaveOrder();
        saveOrder.setId(1L);
        orderService.saveOrder(saveOrder);
        UpdateOrder updateOrder = new UpdateOrder();
        updateOrder.setOrderId(2L);
        orderService.updateOrder(updateOrder);
    }
}