BeanCopier BeanCopy工具类

package com.xzst.kafka.util;

import com.alibaba.dubbo.common.utils.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cglib.beans.BeanCopier;

import java.util.*;

/**

• Bean Copier 实用程序

• @author liukexin

• @date 2024/06/12
  */
  public class BeanCopierUtil {

  private static final Logger LOGGER = LoggerFactory.getLogger(BeanCopierUtil.class);

  /**

  • BeanCopier的缓存
    */
    protected final static Map<String,BeanCopier> BEAN_COPIER_MAP = new HashMap<>();

  /**

  • BeanCopier的copy
  • @param source 源文件的
  • @param target 目标文件
  • @return T
    */
    public static T convertTo(Object source, T target) {
    if (source == null) {
    return null;
    }
    String name = getClassName(source.getClass(), target.getClass());
    BeanCopier beanCopier;
    if (BEAN_COPIER_MAP.containsKey(name)) {
    beanCopier = BEAN_COPIER_MAP.get(name);
    } else {
    beanCopier = BeanCopier.create(source.getClass(), target.getClass(), false);
    BEAN_COPIER_MAP.put(name, beanCopier);
    }
    beanCopier.copy(source, target, null);
    return target;
    }

  /**

  • 转换为
  • @param sourceList 源列表
  • @param targetClass 目标类
  • @return {@link List}<{@link T}>
    */
    public static List convertTo(Collection<?> sourceList, Class targetClass) {
    if (CollectionUtils.isEmpty(sourceList)) {
    return new ArrayList<>();
    }
    List resultList = new LinkedList<>();
    for (Object source : sourceList) {
    try {
    T target = targetClass.newInstance();
    resultList.add(convertTo(source, target));
    } catch (InstantiationException | IllegalAccessException e) {
    e.printStackTrace();
    LOGGER.error(“General Converter convertTo error”, e);
    }
    }
    return resultList;
    }

  /**

  • 生成key
  • @param srcClazz 源文件的class
  • @param tgtClazz 目标文件的class
  • @return string
    */
    private static String getClassName(Class<?> srcClazz, Class<?> tgtClazz) {
    return srcClazz.getName() + tgtClazz.getName();
    }

}

package com.xzst.kafka.service.impl;

import com.alibaba.fastjson.JSON;
import com.xzst.kafka.KafkaApplication;
import com.xzst.kafka.model.UserDo;
import com.xzst.kafka.model.UserDto;
import com.xzst.kafka.util.BeanCopierUtil;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

import java.util.Arrays;
import java.util.List;

@SpringBootTest(classes = KafkaApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)

@RunWith(SpringRunner.class)

public class ExecutorTest {
static List list = null;

static {
UserDo lll = UserDo.builder().id(“1”).name(“lll”).build();
UserDo kkk = UserDo.builder().id(“2”).name(“kkk”).build();
list = Arrays.asList(lll, kkk);
System.out.println(list);
}

@Test
public void testDoDto() throws InstantiationException, IllegalAccessException {
   for (UserDo userDo: list) {
       UserDto userDto = new UserDto();
       BeanCopierUtil.convertTo(userDo, userDto);
       System.out.println(JSON.toJSON(userDto));
   }
    List<UserDto> dtoList = BeanCopierUtil.convertTo(list, UserDto.class);
    System.out.println(JSON.toJSONString(dtoList));
}

}