120 lines
5.2 KiB
Java
120 lines
5.2 KiB
Java
package io.dataease.service.dataset;
|
||
|
||
import io.dataease.commons.exception.DEException;
|
||
import io.dataease.commons.utils.TableUtils;
|
||
import io.dataease.i18n.Translator;
|
||
import io.dataease.plugins.common.base.domain.DatasetTableField;
|
||
import io.dataease.plugins.common.base.domain.DatasetTableFieldExample;
|
||
import io.dataease.plugins.common.base.mapper.DatasetTableFieldMapper;
|
||
import org.apache.commons.collections4.CollectionUtils;
|
||
import org.apache.commons.lang3.ObjectUtils;
|
||
import org.apache.commons.lang3.StringUtils;
|
||
import org.springframework.stereotype.Service;
|
||
|
||
import javax.annotation.Resource;
|
||
import java.util.ArrayList;
|
||
import java.util.List;
|
||
import java.util.UUID;
|
||
|
||
/**
|
||
* @Author gin
|
||
* @Date 2021/2/24 2:03 下午
|
||
*/
|
||
@Service
|
||
public class DataSetTableFieldsService {
|
||
@Resource
|
||
private DatasetTableFieldMapper datasetTableFieldMapper;
|
||
|
||
public void batchEdit(List<DatasetTableField> list) {
|
||
for (DatasetTableField field : list) {
|
||
save(field);
|
||
}
|
||
}
|
||
|
||
public DatasetTableField save(DatasetTableField datasetTableField) {
|
||
if (StringUtils.isEmpty(datasetTableField.getId())) {
|
||
datasetTableField.setId(UUID.randomUUID().toString());
|
||
// 若dataeasename为空，则用MD5(id)作为dataeasename
|
||
if (StringUtils.isEmpty(datasetTableField.getDataeaseName())) {
|
||
datasetTableField.setDataeaseName(TableUtils.columnName(datasetTableField.getId()));
|
||
}
|
||
if (ObjectUtils.isEmpty(datasetTableField.getLastSyncTime())) {
|
||
datasetTableField.setLastSyncTime(System.currentTimeMillis());
|
||
}
|
||
datasetTableFieldMapper.insert(datasetTableField);
|
||
} else {
|
||
datasetTableFieldMapper.updateByPrimaryKeySelective(datasetTableField);
|
||
}
|
||
return datasetTableField;
|
||
}
|
||
|
||
public void checkFieldName(DatasetTableField datasetTableField) {
|
||
if (StringUtils.isNotEmpty(datasetTableField.getName()) && StringUtils.isNotEmpty(datasetTableField.getTableId())) {
|
||
DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
|
||
DatasetTableFieldExample.Criteria criteria = datasetTableFieldExample.createCriteria();
|
||
criteria.andNameEqualTo(datasetTableField.getName()).andTableIdEqualTo(datasetTableField.getTableId());
|
||
if (StringUtils.isNotEmpty(datasetTableField.getId())) {
|
||
criteria.andIdNotEqualTo(datasetTableField.getId());
|
||
}
|
||
List<DatasetTableField> datasetTableFields = datasetTableFieldMapper.selectByExample(datasetTableFieldExample);
|
||
if (CollectionUtils.isNotEmpty(datasetTableFields)) {
|
||
DEException.throwException(Translator.get("i18n_field_name_repeat"));
|
||
}
|
||
}
|
||
}
|
||
|
||
public List<DatasetTableField> list(DatasetTableField datasetTableField) {
|
||
DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
|
||
DatasetTableFieldExample.Criteria criteria = datasetTableFieldExample.createCriteria();
|
||
if (StringUtils.isNotEmpty(datasetTableField.getTableId())) {
|
||
criteria.andTableIdEqualTo(datasetTableField.getTableId());
|
||
}
|
||
if (ObjectUtils.isNotEmpty(datasetTableField.getChecked())) {
|
||
criteria.andCheckedEqualTo(datasetTableField.getChecked());
|
||
}
|
||
if (ObjectUtils.isNotEmpty(datasetTableField.getGroupType())) {
|
||
criteria.andGroupTypeEqualTo(datasetTableField.getGroupType());
|
||
}
|
||
datasetTableFieldExample.setOrderByClause("column_index asc");
|
||
return datasetTableFieldMapper.selectByExample(datasetTableFieldExample);
|
||
}
|
||
|
||
public void deleteByTableId(String tableId) {
|
||
DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
|
||
datasetTableFieldExample.createCriteria().andTableIdEqualTo(tableId);
|
||
datasetTableFieldMapper.deleteByExample(datasetTableFieldExample);
|
||
}
|
||
|
||
public List<DatasetTableField> getListByIds(List<String> ids) {
|
||
DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
|
||
datasetTableFieldExample.createCriteria().andIdIn(ids);
|
||
return datasetTableFieldMapper.selectByExample(datasetTableFieldExample);
|
||
}
|
||
|
||
public DatasetTableField selectByPrimaryKey(String id) {
|
||
return datasetTableFieldMapper.selectByPrimaryKey(id);
|
||
}
|
||
|
||
public List<DatasetTableField> getListByIdsEach(List<String> ids) {
|
||
List<DatasetTableField> list = new ArrayList<>();
|
||
if (CollectionUtils.isNotEmpty(ids)) {
|
||
ids.forEach(id -> list.add(datasetTableFieldMapper.selectByPrimaryKey(id)));
|
||
}
|
||
return list;
|
||
}
|
||
|
||
public List<DatasetTableField> getFieldsByTableId(String id) {
|
||
DatasetTableFieldExample datasetTableFieldExample = new DatasetTableFieldExample();
|
||
datasetTableFieldExample.createCriteria().andTableIdEqualTo(id);
|
||
return datasetTableFieldMapper.selectByExample(datasetTableFieldExample);
|
||
}
|
||
|
||
public DatasetTableField get(String id) {
|
||
return datasetTableFieldMapper.selectByPrimaryKey(id);
|
||
}
|
||
|
||
public void delete(String id) {
|
||
datasetTableFieldMapper.deleteByPrimaryKey(id);
|
||
}
|
||
}
|