Source/UBCS/ubcs-service-api/ubcs-util-api/src/main/java/com/vci/ubcs/starter/web/util/VciBaseUtil.java

@@ -5,8 +5,11 @@
// (powered by FernFlower decompiler)
//

import cn.hutool.core.lang.Snowflake;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.vci.ubcs.starter.exception.VciBaseException;
import com.vci.ubcs.starter.web.enumpck.BooleanEnum;
@@ -19,7 +22,9 @@
import org.springframework.util.CollectionUtils;
import org.springframework.util.ResourceUtils;

import java.beans.BeanInfo;
import java.beans.IntrospectionException;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.io.File;
import java.io.IOException;
@@ -47,7 +52,12 @@
   }

   public static String getPk() {
      return UUID.randomUUID().toString();
      return String.valueOf(getPKLong(1,1));
   }

   public static  Long getPKLong(long workerId,long dataCenterId){
      Snowflake snowflake = IdUtil.getSnowflake(workerId,dataCenterId);
      return snowflake.nextId();
   }

   public static int getIntForBoolean(boolean b) {
@@ -86,6 +96,13 @@
      } else {
         return si;
      }
   }
   /**
    * 设置当前线程中的用户对象
    * @param sessionInfo 用户对象
    */
   public static void setCurrentUserSessionInfo(SessionInfo sessionInfo){
      WebThreadLocalUtil.getCurrentUserSessionInfoInThread().set(sessionInfo);
   }
   public static long getLong(String s) {
      long l = 0L;
@@ -850,7 +867,7 @@
   }

   public static String getTableName(String btmname) {
      return (VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY ? "pl_code_" : "vcibt_") + btmname.trim().toLowerCase();
      return (VciQueryWrapperForDO.USER_TABLE_COMPATIBILITY ? "vcibt_" : "pl_code_") + btmname.trim().toLowerCase();
   }

   public static Field getTsField(Class c) {
@@ -1124,7 +1141,38 @@
   public static <T> Collection<Collection<T>> switchCollectionForOracleIn(Collection<T> list) {
      return switchCollectionForOracleIn(list, 500);
   }

   /**
    * oracle in 查询不能超过1000，转换一下集合
    * 由于SQL语句1000个可能很长，超过oracle10g，所以牺牲性能分配为500个数组
    * @param list 需要转换的列表内容
    * @return 分组后的list
    */
   public static <T> List<List<T>> switchListForOracleIn(List<T> list) {
      List<List<T>> listHasList = new ArrayList<List<T>>();
      if(list == null){
         return listHasList;
      }
      List<T> newList = new ArrayList<T>();
      for(Object obj : list){
         //为了让list还可以添加内容，因为使用sublist后，list不能再Add了
         newList.add((T)obj);
      }
      int muti = 1;
      if(newList.size() >500){
         int balance = newList.size()%500;
         muti = (newList.size() - balance)/500 + (balance == 0?0:1);
      }
      for(int i = 0 ; i < muti; i ++){
         int start = i*500;
         int end = start + 500;
         if(i == muti-1 || end >newList.size() ){
            end = newList.size();
         }
         List subList = newList.subList(start,end);
         listHasList.add(subList);
      }
      return listHasList;
   }
   public static <T> Collection<Collection<T>> switchCollectionForOracleIn(Collection<T> collection, int preSize) {
      Collection<Collection<T>> listHasList = new ArrayList();
      if (collection == null) {
@@ -1237,5 +1285,138 @@

   }

   /**
    * 将 JavaBean对象转化为 Map
    * @author wyply115
    * @param bean 要转化的类型
    * @return Map对象
    * @version 2016年3月20日 11:03:01
    */
   public static Map convertBean2Map(Object bean,Set<String> existFild) throws Exception {
      Class type = bean.getClass();
      Map returnMap = new HashMap();
      BeanInfo beanInfo = Introspector.getBeanInfo(type);
      PropertyDescriptor[] propertyDescriptors = beanInfo
         .getPropertyDescriptors();
      Field[] declaredFields = type.getDeclaredFields();
      Map<String, String> fieldMap = new HashMap();
      String existField = "";
      for (Field declaredField : declaredFields) {
         declaredField.setAccessible(true);

         // 获取字段的值
         boolean isTableField = declaredField.isAnnotationPresent(TableField.class);
         if (isTableField) {
            TableField tableField = declaredField.getAnnotation(TableField.class);
            Boolean fieldValue = tableField.exist();
            if(fieldValue == false){
               existField += declaredField.getName().toLowerCase()+",";
            }
            String value = tableField.value();
            if(net.logstash.logback.encoder.org.apache.commons.lang3.StringUtils.isNotBlank(value)){
               fieldMap.put(declaredField.getName(), value);
            }
         }
      }

      for (int i = 0, n = propertyDescriptors.length; i <n ; i++) {
         PropertyDescriptor descriptor = propertyDescriptors[i];
         String propertyName = descriptor.getName();

         if (!propertyName.equals("class") &&
            ((!"".equals(existField) && !existField.contains(propertyName.toLowerCase()+","))||"data".equals(propertyName))) {
            Method readMethod = descriptor.getReadMethod();
            Object result = readMethod.invoke(bean, new Object[0]);

            if (result != null) {
               if ("data".equals(propertyName)){
                  if(existFild == null){
                     returnMap.putAll((Map) result);
                  }else{
                     Map resulMap = (Map) result;
                     for (Object o : resulMap.keySet()) {
                        if(existFild.contains(o)){
                           returnMap.put(o,resulMap.get(o));
                        }
                     }
                  }
               }else if(existFild.contains((fieldMap.containsKey(propertyName)?fieldMap.get(propertyName):propertyName).toLowerCase())){
                  returnMap.put(fieldMap.containsKey(propertyName)?fieldMap.get(propertyName):propertyName, result);
               }
            } else if(existFild.contains((fieldMap.containsKey(propertyName)?fieldMap.get(propertyName):propertyName).toLowerCase())){
               returnMap.put(fieldMap.containsKey(propertyName)?fieldMap.get(propertyName):propertyName, "");
            }
         }
      }
      return returnMap;
   }

   public static <T> List<T> mapToBean(List<Map> maps, Class<T> tClass) {
      List<T> beanList = new ArrayList<>();
      try {
         for (Map map : maps) {
               T t = tClass.newInstance();
               BeanInfo beanInfo = Introspector.getBeanInfo(tClass);
               PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();

               for (PropertyDescriptor property : propertyDescriptors) {

                  String key = property.getName();
                  if ("class".equals(key)) {
                     continue;
                  }

//                  String sqlField = camelToUnderscore(key);


                  if (map.containsKey(key.toUpperCase(Locale.ROOT))||map.containsKey(key.toLowerCase(Locale.ROOT))) {
                     try {
                        Object value="";
                        if (map.containsKey(key.toUpperCase(Locale.ROOT))) {
                           value = map.get(key.toUpperCase());
                        }else if(map.containsKey(key.toLowerCase(Locale.ROOT))){
                           value = map.get(key.toLowerCase());
                        }
                        // 得到property对应的setter方法
                        Method setter = property.getWriteMethod();
                        Class<?> type = property.getPropertyType();
                        // 强转为字段的类型，不需要时可以去除，依赖commons-beanutilss-beanutils
                        //Object convert = ConvertUtils.convert(String.valueOf(value), type);
                        //setter.invoke(t, convert);
                        setter.invoke(t, value);
                     } catch (Exception e) {
                        throw new RuntimeException("【赋值异常】", e);
                     }
                  }

               }
               beanList.add(t);
         }
      } catch (Exception e) {
         throw new RuntimeException("【Map转换实体异常】", e);
      }
      return beanList;
}


   public static String camelToUnderscore(String name) {
      if (name == null && name.length() <= 0) {
         return name;
      }
      StringBuilder sb = new StringBuilder();
      String lowerName = name.toLowerCase();
      for (int i = 0; i < lowerName.length(); i++) {
         String nameChar = name.substring(i, i + 1);
         String lowerChar = lowerName.substring(i, i + 1);
         if (!nameChar.equals(lowerChar)) {
            sb.append("_").append(lowerChar);
         } else {
            sb.append(nameChar);
         }
      }

      return sb.toString();
   }

}