package com.example.service;

import cn.com.digitalhainan.common.core.annotation.AppI18n;
import cn.com.digitalhainan.common.core.response.BaseResponse;
import org.springframework.stereotype.Service;

/**
 * i18n 国际化使用示例
 * 在方法上使用 @AppI18n 注解，自动翻译 BaseResponse 中标注了 @AppI18n 的字段
 */
@Service
public class I18nDemoService {

    @AppI18n
    public BaseResponse<Object, Object> getBusinessData() {
        // 抛出业务异常，异常消息会自动通过 i18n 翻译
        return BaseResponse.success("操作成功");
    }
}

package com.example.config;

import cn.com.digitalhainan.common.core.exception.IBusinessExceptionCodeConfiguration;
import cn.com.digitalhainan.ms.common.core.i18n.IBusinessExceptionI18nMessage;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.List;

/**
 * 自定义 i18n 消息实现（如从 Redis 读取）
 */
@Configuration
public class CustomI18nConfig {

    @Bean
    public IBusinessExceptionI18nMessage customI18nMessage() {
        return new IBusinessExceptionI18nMessage() {
            @Override
            public String getMessage(IBusinessExceptionCodeConfiguration exceptionCodeEnum, List<Object> args) {
                // 自定义逻辑：从 Redis/数据库获取国际化消息
                return exceptionCodeEnum.defaultMsg();
            }

            @Override
            public String getMessage(String code) {
                return code;
            }

            @Override
            public String getMessage(String code, List<Object> args) {
                return code;
            }
        };
    }
}

package com.example.config;

import cn.com.digitalhainan.common.core.exception.IBusinessExceptionCodeConfiguration;
import cn.com.digitalhainan.common.core.response.BaseResponse;
import cn.com.digitalhainan.ms.common.web.exception.IExceptionInfoResolver;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * 自定义异常信息解析器
 */
@Configuration
public class CustomExceptionResolverConfig {

    @Bean
    public IExceptionInfoResolver customExceptionInfoResolver() {
        return new IExceptionInfoResolver() {
            @Override
            public IBusinessExceptionCodeConfiguration resolverUnrecognizedThrowable(Throwable throwable) {
                // 自定义未识别异常的编码映射
                return null;
            }

            @Override
            public void tryExtractDebugMsg(BaseResponse baseResponse, Throwable throwable, boolean includeStackTrace) {
                // 自定义调试信息提取
            }
        };
    }
}

package com.example.service;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.util.concurrent.CompletableFuture;

/**
 * 异步任务使用示例
 * 框架自动配置线程池 taskAsyncParallelExecutor，并传递 MDC 上下文
 */
@Service
public class AsyncDemoService {

    @Async
    public CompletableFuture<String> asyncTask() {
        // 此方法在线程池中异步执行
        // MDC 中的 traceId 会自动传递到子线程
        return CompletableFuture.completedFuture("done");
    }
}

package com.example.job;

import cn.com.digitalhainan.ms.common.core.schedule.DynamicScheduled;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * 动态定时任务示例
 * 使用 @DynamicScheduled 注解标记，支持运行时通过 Nacos 配置中心动态修改 Cron 表达式
 */
@Slf4j
@Component
public class DynamicJobDemo {

    @DynamicScheduled("dataSyncJob")
    @Scheduled(cron = "${job.data-sync.cron:0 0/5 * * * ?}")
    public void execute() {
        log.info("执行数据同步任务");
    }
}

package com.example.service;

import cn.com.digitalhainan.ms.common.core.rest.RestTemplateService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * RestTemplate 使用示例
 * 框架自动配置 RestTemplate（连接池 + UTF-8 + Header 透传）
 */
@Service
public class RestDemoService {

    @Autowired
    private RestTemplateService restTemplateService;

    public void callExternalApi() {
        // GET 请求
        String result = restTemplateService.getForObject(
            "http://external-api/users/{id}", String.class, "123");

        // POST 请求
        // restTemplateService.postForObject(url, requestBody, responseType);
    }
}

package com.example.util;

import cn.com.digitalhainan.ms.common.core.trace.TraceContext;

/**
 * 链路追踪使用示例
 */
public class TraceDemo {

    public void demo() {
        // 获取当前请求的 TraceId（来自 SkyWalking / MDC）
        String traceId = TraceContext.getTraceId();

        // 手动设置 TraceId
        TraceContext.setTraceId("custom-trace-id");

        // 标记当前 Span 为错误
        TraceContext.setError("Something went wrong");

        // 清除 TraceId
        TraceContext.clearTraceId();
    }
}