1. package com.eip.common.util;
    3. import cn.hutool.core.util.ReflectUtil;
    5. import com.beust.jcommander.internal.Lists;
    6. import com.eip.common.annotation.FieldName;
    7. import com.google.common.collect.Maps;
    8. import com.google.gson.Gson;
    10. import lombok.extern.slf4j.Slf4j;
    11. import org.apache.commons.lang.StringUtils;
    12. import org.springframework.jdbc.core.JdbcTemplate;
    14. import javax.persistence.Column;
    15. import java.lang.reflect.Field;
    16. import java.lang.reflect.InvocationTargetException;
    17. import java.lang.reflect.Method;
    18. import java.math.BigDecimal;
    19. import java.text.DecimalFormat;
    20. import java.text.SimpleDateFormat;
    21. import java.util.Arrays;
    22. import java.util.HashMap;
    23. import java.util.List;
    24. import java.util.Map;
    25. import java.util.Objects;
    27. /**
    28.  * 反射工具类
    29.  *
    30.  */
    31. @Slf4j
    32. public class ReflectionUtils extends ReflectUtil {
    33.     /**
    34.      * 获取Object对象，所有成员变量属性值
    35.      */
    36.     public static HashMap<String, Object> getObjAttr(Object obj) {
    37.         return getObjAttr(null, obj);
    38.     }
    40.     /**
    41.      * 获取Object对象，所有成员变量属性值
    42.      */
    43.     public static HashMap<String, Object> getObjAttr(String prefix, Object obj) {
    44.         if (obj == null) return Maps.newHashMap();
    45.         Field[] fields = obj.getClass().getDeclaredFields();
    46.         HashMap<String, Object> map = Maps.newHashMap();
    47.         int count = 0;
    48.         for (Field field : fields) {
    49.             // 对于每个属性，获取属性名
    50.             String varName = field.getName();
    51.             try {
    52.                 boolean access = field.isAccessible();
    53.                 if (!access) {
    54.                     field.setAccessible(true);
    55.                 }
    56.                 //反射获取所有成员变量值
    57.                 Object o = field.get(obj);
    58.                 if (PublicUtil.isNotEmpty(o)) count++;
    59.                 if (StringUtils.isNotBlank(prefix)) map.put(prefix + "_" + varName, o);
    60.                 if (StringUtils.isBlank(prefix)) map.put(varName, o);
    61.                 if (!access) {
    62.                     field.setAccessible(false);
    63.                 }
    64.             } catch (Exception ex) {
    65.                 ex.printStackTrace();
    66.             }
    67.         }
    68.         return count > 0 ? map : null;
    69.     }
    71.     /**
    72.      * 判断该对象是否
    73.      * @param obj 返回ture表示所有属性为null返回false表示不是所有属性都是null
    74.      * @return
    75.      */
    76.     public static boolean isAllFieldNull(Object obj) {
    77.         boolean flag = true;
    78.         try {
    79.             Class stuCla = (Class) obj.getClass();//得到类对象
    80.             Field[] fs = stuCla.getDeclaredFields();//得到属性集合
    81.             for (Field f : fs) {//遍历属性
    82.                 f.setAccessible(true);//设置属性是可以访问的(私有的也可以)
    83.                 Object val = f.get(obj);
    84.                 if (val != null) {//只要有1个属性不为空,那么就不是所有的属性值都为空
    85.                     flag = false;
    86.                     break;
    87.                 }
    88.             }
    89.         } catch (IllegalAccessException e) {
    90.             e.printStackTrace();
    91.         }
    92.         return flag;
    93.     }
    95.     /**
    96.      * 比较两个类型一样的对象中的值变更返回字符串
    97.      *
    98.      * @param pre     变化前的对象
    99.      * @param last    变化后的对象
    100.      * @param fileIds 需要比对的字段 all为全部
    101.      * @param orgNum  查询需要机构号时传入
    102.      * @return
    103.      * @apiNote 配合@FieldName注解一起使用
    104.      */
    105.     public static String compareObjectDifferentAttributes(Object pre, Object last, String fileIds, Integer orgNum) {
    106.         if (StringUtils.isBlank(fileIds)) fileIds = "all";
    107.         List<String> fileIdList = Arrays.asList(fileIds.split(","));
    108.         StringBuilder result = new StringBuilder();
    109.         Class<?> preClass = pre.getClass();
    110.         Class<?> lastClass = last.getClass();
    111.         if (!preClass.equals(lastClass)) throw new RuntimeException("两个对象类型不一致");
    112.         Field[] declaredFields = preClass.getDeclaredFields();
    113.         for (Field field : declaredFields) {
    114.             //获取方法名
    115.             String fieldName = field.getName();
    116.             if (!"all".equalsIgnoreCase(fileIds) && !fileIdList.contains(fieldName)) continue;
    117.             try {
    118.                 //没有注解跳过比较
    119.                 if (!field.isAnnotationPresent(FieldName.class)) continue;
    120.                 FieldName fieldAnno = field.getAnnotation(FieldName.class);
    121.                 boolean access = field.isAccessible();
    122.                 String type = field.getType().getName();
    123.                 if (!access) field.setAccessible(true);
    124.                 Object preValue = field.get(pre);
    125.                 Object lastValue = field.get(last);
    126.                 if ("".equals(preValue)) preValue = null;
    127.                 if ("".equals(lastValue)) lastValue = null;
    128.                 //BigDecimal 类型的数据要去掉小数点后尾部的0不一致造成数据比对差异
    129.                 if ("java.math.BigDecimal".equals(type) && preValue != null && lastValue != null) {
    130.                     BigDecimal valOldBig = new BigDecimal(String.valueOf(preValue));
    131.                     BigDecimal valNewBig = new BigDecimal(String.valueOf(lastValue));
    132.                     //由于无法获取精度值，只能对所有带小数点的数据进行处理
    133.                     if (String.valueOf(valOldBig).contains(".") || String.valueOf(valNewBig).contains(".")) {
    134.                         DecimalFormat formatter1 = new DecimalFormat("0.00");
    135.                         preValue = formatter1.format(valOldBig);
    136.                         lastValue = formatter1.format(valNewBig);
    137.                     }
    138.                 }
    139.                 //DATE 类型的数据要格式化
    140.                 if ("java.util.Date".equals(type)) {
    141.                     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    142.                     if (preValue != null) preValue = sdf.format(preValue);
    143.                     if (lastValue != null) lastValue = sdf.format(lastValue);
    144.                 }
    145.                 //如果前后两个值都是空,那么无需比较
    146.                 if (Objects.isNull(preValue) && Objects.isNull(lastValue)) {
    147.                     continue;
    148.                 } else if (Objects.isNull(preValue) && Objects.nonNull(lastValue)) { //前值为空,后值不为空
    149.                     if (fieldAnno.isForeignKey()) {
    150.                         lastValue = getForeignKeyName(fieldAnno.sql(), lastValue, fieldAnno.isOrgNum(), orgNum,fieldAnno.isStringParam());
    151.                     }else if(fieldAnno.isSysKey()){
    152.                         lastValue = getSysKeyValue(fieldAnno.sysKey() ,lastValue);
    153.                     }
    154.                     result.append("'").append(fieldAnno.name()).append("'").append("由'空'变为").append("'").append(lastValue).append("'").append("\r\n");
    155.                 } else if (Objects.nonNull(preValue) && Objects.isNull(lastValue)) {//前值不为空,后值为空
    156.                     if (fieldAnno.isForeignKey()) {
    157.                         preValue = getForeignKeyName(fieldAnno.sql(), preValue, fieldAnno.isOrgNum(), orgNum,fieldAnno.isStringParam());
    158.                     }else if(fieldAnno.isSysKey()){
    159.                         preValue = getSysKeyValue(fieldAnno.sysKey() ,preValue);
    160.                     }
    161.                     result.append("'").append(fieldAnno.name()).append("'").append("由").append("'").append(preValue).append("'").append("变为'空'").append("\r\n");
    162.                 } else if (Objects.nonNull(preValue) && Objects.nonNull(lastValue)) {  //两个都不为空
    163.                     if (preValue.equals(lastValue)) continue;
    164.                     //是否外键
    165.                     if (fieldAnno.isForeignKey()) {
    166.                         preValue = getForeignKeyName(fieldAnno.sql(), preValue, fieldAnno.isOrgNum(), orgNum,fieldAnno.isStringParam());
    167.                         lastValue = getForeignKeyName(fieldAnno.sql(), lastValue, fieldAnno.isOrgNum(), orgNum,fieldAnno.isStringParam());
    168.                     }else if(fieldAnno.isSysKey()){
    169.                         preValue = getSysKeyValue(fieldAnno.sysKey() ,preValue);
    170.                         lastValue = getSysKeyValue(fieldAnno.sysKey() ,lastValue);
    171.                     }                    
    172.                     result.append("'").append(fieldAnno.name()).append("'").append("由").append("'")
    173.                             .append(preValue).append("'").append("变为").append("'").append(lastValue).append("'").append("\r\n");
    174.                 }
    175.                 if (!access) field.setAccessible(false);
    176.             } catch (IllegalAccessException e) {
    177.                 e.printStackTrace();
    178.             }
    179.         }
    180.         return result.toString();
    181.     }
    183.     /**
    184.      * 查询系统定义的值
    185.      * @param sysKey
    186.      * @param value
    187.      * @return
    188.      */
    189.     @SuppressWarnings("unchecked")
    190.     public static String getSysKeyValue(String sysKey ,Object value) {
    191.       if(StringUtils.isBlank(sysKey))return value.toString();
    192.       try {
    193.           Map<String, String> map = Maps.newHashMap();
    194.           map = new Gson().fromJson(sysKey, map.getClass());
    195.           return  map.get(value.toString())==null?value.toString():map.get(value.toString());
    196.       } catch (Exception e) {
    197.           return value.toString();
    198.       }
    200.   }
    202.     /**
    203.      * 查询外键所对应的名称
    204.      *
    205.      * @param sql
    206.      * @param value
    207.      * @param isOrgNum
    208.      * @return
    209.      */
    210.     public static String getForeignKeyName(String sql, Object value, boolean isOrgNum, Integer orgNum,boolean isStringParam) {
    211. //        Preconditions.checkArgument(StringUtils.isNotBlank(sql), "sql不能为空!");
    212.         if (StringUtils.isBlank(sql)) return "";
    213.         try {
    214.             JdbcTemplate bean = ApplicationContextHolder.getBean(JdbcTemplate.class);
    215.             Object[] args ;
    216.             if(isStringParam){
    217.                 args = new Object[]{value.toString()};
    218.             }else{
    219.                 args = new Object[]{Integer.valueOf(value.toString())};
    220.             }
    221.             if (isOrgNum) {
    222.                 sql += " and f_org_num = ?";
    223.                 if(isStringParam){
    224.                     args = new Object[]{value.toString(), orgNum};
    225.                 }else{
    226.                     args = new Object[]{Integer.valueOf(value.toString()), orgNum};
    227.                 }
    229.             }
    230.             return bean.queryForObject(sql, args, String.class);
    231.         } catch (Exception e) {
    232.             return "空";
    233.         }
    235.     }
    237.     /**
    238.      * 解析方法注解
    239.      *
    240.      * @param clazz
    241.      */
    242.     public static String getAnnotationAttribute(Class<?> clazz, String attributeField) {
    243.         for (Field field : clazz.getDeclaredFields()) {
    244.             if (field.getName().equalsIgnoreCase(attributeField) && field.isAnnotationPresent(Column.class)) {
    245.                 Column column = field.getAnnotation(Column.class);
    246. //                System.out.println(column.name());
    247.                 return column.name();
    248.             }
    249.         }
    250.         return null;
    251.     }
    253.     /**
    254.      * 获取字段属性
    255.      *
    256.      * @param clazz
    257.      * @param attributeField
    258.      * @return
    259.      */
    260.     public static String getFieldType(Class<?> clazz, String attributeField) {
    261.         for (Field field : clazz.getDeclaredFields()) {
    262.             if (field.getName().equalsIgnoreCase(attributeField)) {
    263.                 return field.getType().toString();
    264.             }
    265.         }
    266.         return null;
    267.     }
    269.    /**
    270.     * 获取字段名称
    271.     * @param clazz
    272.     * @param ignoreFields
    273.     * @return
    274.     */
    275.     public static String[] getFieldName(Class<?> clazz, String ignoreFields) {
    276.         if(ignoreFields==null)ignoreFields="";
    277.         List<String> list = Lists.newArrayList();
    278.         for (Field field : clazz.getDeclaredFields()) {
    279.             if (!ignoreFields.contains(field.getName())) {
    280.                 list.add(field.getName());
    281.             }
    282.         }        
    283.         return list.stream().toArray(String[]::new);
    284.     }
    287.     /**
    288.      * 通过反射实现get方法
    289.      * @param o 要操作类的对象
    290.      * @param args 属性名
    291.      * @param <T>
    292.      * @return
    293.      * @throws NoSuchFieldException
    294.      */
    295.     public static <T> T getMethod(T o,String args) throws NoSuchFieldException {
    296.         Class cls = o.getClass();
    297.         //判断该属性是否存在
    298.         Field field = cls.getDeclaredField(args);
    299.         if(field == null){
    300.             field = cls.getField(args);
    301.         }
    302.         if(field == null){
    303.             return (T)"";
    304.         }
    306.         String fieldName = "get"+args.substring(0,1).toUpperCase()+(args.length()>1?args.substring(1):"");
    307.         Method method;
    308.         try {
    309.             method = cls.getMethod(fieldName);
    310.             //Boolean返回 true是 false否
    311.             if(getFieldType(cls,args).equals("class java.lang.Boolean")){
    312.                 Boolean invoke = (Boolean)method.invoke(o);
    313.                 return invoke.equals(true) ?(T)"是" :(T)"否";
    314.             }
    315.             //Date返回 yyyy-MM-dd
    316.             else if (getFieldType(cls,args).equals("class java.util.Date")){
    317.                 if(method.invoke(o)!=null){
    318.                     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
    319.                     String date = sdf.format(method.invoke(o));
    320.                     return (T)date;
    321.                 }
    322.             }
    323.             return (T)method.invoke(o);
    324.         } catch (NoSuchMethodException e) {
    325.             log.error(e.getMessage());
    326.         } catch (IllegalAccessException e) {
    327.             log.error(e.getMessage());
    328.         } catch (InvocationTargetException e) {
    329.             log.error(e.getMessage());
    330.         }
    331.         return (T)"";
    332.     }
    333. }