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

@@ -5,18 +5,26 @@
// (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;
import com.vci.ubcs.starter.web.enumpck.UserSecretEnum;
import com.vci.ubcs.starter.web.pagemodel.SessionInfo;
import com.vci.ubcs.starter.web.toolmodel.DateConverter;
import com.vci.ubcs.starter.web.wrapper.VciQueryWrapperForDO;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
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;
@@ -44,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) {
@@ -76,7 +89,21 @@
         return 0;
      }
   }

   public static SessionInfo getCurrentUserSessionInfo() throws VciBaseException {
      SessionInfo si = getCurrentUserSessionInfoNotException();
      if (si == null) {
         throw new VciBaseException("noLogin", new String[]{"没有当前用户信息"});
      } else {
         return si;
      }
   }
   /**
    * 设置当前线程中的用户对象
    * @param sessionInfo 用户对象
    */
   public static void setCurrentUserSessionInfo(SessionInfo sessionInfo){
      WebThreadLocalUtil.getCurrentUserSessionInfoInThread().set(sessionInfo);
   }
   public static long getLong(String s) {
      long l = 0L;
      if (s == null) {
@@ -89,6 +116,11 @@
            return 0L;
         }
      }
   }

   public static Integer getCurrentUserSecret() {
      SessionInfo currentUserSession = getCurrentUserSessionInfoNotException();
      return currentUserSession != null ? getInt(currentUserSession.getUserSecret()) : UserSecretEnum.NONE.getValue();
   }

   public static float getFloat(String s) {
@@ -135,6 +167,11 @@
            return 0.0D;
         }
      }
   }


   public static boolean getBoolean(String s) {
      return BooleanEnum.TRUE.getValue().equals(s);
   }

   public static String removeComma(String s) {
@@ -829,6 +866,10 @@
      return allField;
   }

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

   public static Field getTsField(Class c) {
      List<Field> allField = getAllFieldForObj(c);
      if (allField != null && allField.size() > 0) {
@@ -1100,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) {
@@ -1199,5 +1271,152 @@

   }

   public static void setValueForField(String fieldName, Object obj, String value) {
      try {
         Field field = getFieldForObject(fieldName, obj);
         if (field != null) {
            setValueForField(field, obj, value);
         }
      } catch (Exception var4) {
         if (log.isErrorEnabled()) {
            log.error("设置属性的值出错了错误", var4);
         }
      }

   }

   /**
    * 将 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();
   }

}