package jnpf.onlinedev.util.onlineDevUtil;
|
|
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSONArray;
|
import jnpf.base.util.FormPublicUtils;
|
import jnpf.database.model.dbfield.JdbcColumnModel;
|
import jnpf.database.model.dto.PrepSqlDTO;
|
import jnpf.database.model.entity.DbLinkEntity;
|
import jnpf.database.util.JdbcUtil;
|
import jnpf.onlinedev.model.OnlineDevListModel.OnlineColumnFieldModel;
|
import jnpf.onlinedev.model.OnlineDevListModel.OnlineDevListDataVO;
|
import jnpf.onlinedev.model.OnlineDevListModel.VisualColumnSearchVO;
|
import jnpf.util.StringUtil;
|
import jnpf.util.visiual.JnpfKeyConsts;
|
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
*
|
*
|
* @author JNPF开发平台组
|
* @version V3.2.0
|
* @copyright 引迈信息技术有限公司（https://www.jnpfsoft.com）
|
* @date 2021/7/28
|
*/
|
public class OnlineDatabaseUtils {
|
public static List<OnlineDevListDataVO> getTableDataList(DbLinkEntity dbLinkEntity, String sql, String pKeyName, List<OnlineColumnFieldModel> childFieldList) {
|
List<OnlineDevListDataVO> list = new ArrayList<>();
|
try {
|
List<List<JdbcColumnModel>> fieldMods = JdbcUtil.queryJdbcColumns(new PrepSqlDTO(sql).withConn(dbLinkEntity)).setIsValue(true).get();
|
List<Map<String,Object>> dataList = new ArrayList<>();
|
|
for (List<JdbcColumnModel> dblist : fieldMods){
|
Map<String,Object> dataMap =new HashMap<>();
|
HashMap<String, Object> collect = dblist.stream().collect(Collectors.toMap(s -> Optional.ofNullable(s.getField()).orElse(""), s -> Optional.ofNullable(s.getValue()).orElse(""), (a, b) -> b, HashMap::new));
|
dataMap.putAll(collect);
|
for (OnlineColumnFieldModel on : childFieldList){
|
//需要替换的子表字段
|
JdbcColumnModel fieldMod = dblist.stream()
|
.filter(dbMod -> dbMod.getTable().equalsIgnoreCase(on.getTableName())
|
&& dbMod.getField().equalsIgnoreCase(on.getField())).findFirst().orElse(null);
|
//将数据转成map格式
|
if (ObjectUtil.isNotEmpty(fieldMod)){
|
dataMap.remove(fieldMod.getField());
|
dataMap.put(on.getOriginallyField(),fieldMod.getValue());
|
}
|
}
|
dataList.add(dataMap);
|
}
|
|
for (Map<String, Object> dataMap : dataList) {
|
OnlineDevListDataVO dataVo = new OnlineDevListDataVO();
|
dataMap = toLowerKey(dataMap);
|
dataVo.setData(dataMap);
|
if (dataMap.containsKey(pKeyName.toUpperCase())) {
|
dataVo.setId(String.valueOf(dataMap.get(pKeyName.toUpperCase())));
|
}
|
list.add(dataVo);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
public static Map<String, Object> toLowerKey(Map<String, Object> map) {
|
Map<String, Object> resultMap = new HashMap<>(16);
|
Set<String> sets = map.keySet();
|
for (String key : sets) {
|
resultMap.put(key.toLowerCase(), map.get(key));
|
}
|
return resultMap;
|
}
|
|
public static Boolean existKey(List<String> feilds, String pKeyName) {
|
if (feilds.size() > 0) {
|
for (String feild : feilds) {
|
if (feild.equals(pKeyName)) {
|
return true;
|
}
|
}
|
}
|
return false;
|
}
|
|
public static List<OnlineDevListDataVO> setDataId(String keyName, List<OnlineDevListDataVO> DevList) {
|
keyName = keyName.toLowerCase();
|
for (OnlineDevListDataVO dataVo : DevList) {
|
Map<String, Object> dataMap = dataVo.getData();
|
if (dataMap.get(keyName) != null) {
|
dataVo.setId(String.valueOf(dataMap.get(keyName)));
|
}
|
}
|
return DevList;
|
}
|
|
public static List<Object> getValueList(List<VisualColumnSearchVO> searchVOList){
|
List<Object> valueList = new LinkedList<>();
|
for (VisualColumnSearchVO vo : searchVOList){
|
String jnpfKey = vo.getConfig().getJnpfKey();
|
String format;
|
switch (jnpfKey){
|
case JnpfKeyConsts.MODIFYTIME:
|
case JnpfKeyConsts.CREATETIME:
|
case JnpfKeyConsts.DATE:
|
case JnpfKeyConsts.DATE_CALCULATE:
|
JSONArray timeStampArray = (JSONArray) vo.getValue();
|
Long o1 =(Long) timeStampArray.get(0);
|
Long o2 = (Long) timeStampArray.get(1);
|
format = StringUtil.isEmpty(vo.getFormat()) ? "yyyy-MM-dd HH:mm:ss" : vo.getFormat();
|
//时间戳转string格式
|
String startTime = OnlinePublicUtils.getDateByFormat(o1,format);
|
String endTime = OnlinePublicUtils.getDateByFormat(o2,format);
|
//处理时间查询条件范围
|
endTime=endTime.substring(0,10);
|
String firstTimeDate = OnlineDatabaseUtils.getTimeFormat(startTime);
|
String lastTimeDate = OnlineDatabaseUtils.getLastTimeFormat(endTime);
|
valueList.add(firstTimeDate);
|
valueList.add(lastTimeDate);
|
break;
|
case JnpfKeyConsts.TIME:
|
JSONArray timeArray =(JSONArray)vo.getValue();
|
String start = String.valueOf(timeArray.get(0));
|
String end =String.valueOf(timeArray.get(1));
|
valueList.add(start);
|
valueList.add(end);
|
break;
|
case JnpfKeyConsts.NUM_INPUT:
|
case JnpfKeyConsts.CALCULATE:
|
List<String> searchArray = (List<String>)vo.getValue();
|
Integer firstValue = null;
|
Integer secondValue = null;
|
for(int i=0;i<searchArray.size();i++){
|
String name = searchArray.get(i);
|
if(StringUtil.isNotEmpty(name)) {
|
if (i == 0) {
|
firstValue =Integer.valueOf(name);
|
} else {
|
secondValue =Integer.valueOf(name);
|
}
|
}
|
}
|
if (firstValue != null){
|
valueList.add(firstValue);
|
}
|
if (secondValue != null){
|
valueList.add(secondValue);
|
}
|
break;
|
default:
|
valueList.add(vo.getValue());
|
break;
|
}
|
}
|
return valueList;
|
}
|
|
/**
|
* 转换时间格式
|
* @param time
|
* @return
|
*/
|
public static String getTimeFormat(String time){
|
return FormPublicUtils.getTimeFormat(time);
|
}
|
|
public static String getLastTimeFormat(String time){
|
return FormPublicUtils.getLastTimeFormat(time);
|
}
|
|
}
|
