package foundation.data.loader;
|
|
import foundation.dao.DataPackageMeta;
|
import foundation.dao.DataPackageMetaContainer;
|
import foundation.dao.Filter;
|
import foundation.dao.HostLimit;
|
import foundation.dao.ItemLimit;
|
import foundation.dao.OrderBy;
|
import foundation.dao.PackageItemMeta;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.object.DataObject;
|
import foundation.persist.NamedSQL;
|
import foundation.server.Initializer;
|
|
|
public class DataPackageMetaLoader extends Initializer {
|
|
@Override
|
public void startUp() throws Exception {
|
//1. load data package
|
loadDataPackages();
|
|
//2. load data package detail
|
loadDataPackageDetails();
|
|
//3. 加载被省略的 package detail（只有一个detail的时候，可以省略定义detail）
|
loadDefaultPackageDetails();
|
|
//4. load package limit
|
loadPackageLimit();
|
}
|
|
@Override
|
public void shutDown() throws Exception {
|
|
}
|
|
private void loadDataPackages() throws Exception {
|
DataPackageMetaContainer packageMetaContainer = DataPackageMetaContainer.getInstance();
|
|
//1. 从主表的配置里面加载
|
DataObject dataObject = DataObject.getInstance("sys_data_package");
|
OrderBy orderBy = new OrderBy("group_code, name");
|
EntitySet entitySet = dataObject.getTableEntitySet(orderBy);
|
|
for (Entity entity: entitySet) {
|
DataPackageMeta packageMeta = new DataPackageMeta();
|
packageMeta.load(entity);
|
|
packageMetaContainer.add(packageMeta.getName(), packageMeta);
|
}
|
|
//2. 从明细表里面加载主表里面没有的（没有主记录的）
|
NamedSQL namedSQL = NamedSQL.getInstance("getAutoDataPackage");
|
entitySet = namedSQL.getEntitySet();
|
|
for (Entity entity: entitySet) {
|
DataPackageMeta packageMeta = new DataPackageMeta();
|
packageMeta.load(entity);
|
|
packageMetaContainer.add(packageMeta.getName(), packageMeta);
|
}
|
}
|
|
private void loadDataPackageDetails() throws Exception {
|
//1. get entity set
|
DataObject dataObject = DataObject.getInstance("sys_data_package_detail");
|
OrderBy orderBy = new OrderBy("parent_dataname");
|
EntitySet entitySet = dataObject.getTableEntitySet(orderBy);
|
|
//2. add to data package
|
DataPackageMetaContainer packageMetaContainer = DataPackageMetaContainer.getInstance();
|
String parentName; DataPackageMeta packageMeta; PackageItemMeta itemMeta;
|
|
for (Entity entity: entitySet) {
|
parentName = entity.getString("parent_dataname");
|
packageMeta = packageMetaContainer.getCached(parentName);
|
|
if (packageMeta == null) {
|
logger.error("data package not exists: {}", parentName);
|
continue;
|
}
|
|
itemMeta = new PackageItemMeta();
|
itemMeta.load(entity);
|
itemMeta.setDataObject();
|
packageMeta.loadOneDetail(itemMeta);
|
}
|
}
|
|
private void loadDefaultPackageDetails() throws Exception {
|
DataPackageMetaContainer metaContainer = DataPackageMetaContainer.getInstance();
|
|
for (DataPackageMeta packageMeta: metaContainer) {
|
int count = packageMeta.getItemCount();
|
|
if (count > 0) {
|
continue;
|
}
|
|
String dataName = packageMeta.getName();
|
|
DataObject dataObject = DataObject.getInstance(dataName);
|
if (dataObject == null) {
|
continue;
|
}
|
|
PackageItemMeta itemMeta = new PackageItemMeta();
|
itemMeta.load(dataObject);
|
packageMeta.loadOneDetail(itemMeta);
|
}
|
}
|
|
private void loadPackageLimit() throws Exception {
|
DataPackageMetaContainer container = DataPackageMetaContainer.getInstance();
|
|
//1. get entity set
|
DataObject dataObject = DataObject.getInstance("sys_data_package_limit");
|
OrderBy orderBy = new OrderBy("data_name, type_code");
|
EntitySet entitySet = dataObject.getTableEntitySet(orderBy);
|
|
for (Entity entity: entitySet) {
|
ItemLimit itemLimit = new ItemLimit();
|
itemLimit.load(entity);
|
|
DataPackageMeta packageMeta = container.get(itemLimit.getDataName());
|
|
if (packageMeta == null) {
|
continue;
|
}
|
|
HostLimit hostLimit = packageMeta.getHostLimit();
|
|
if (hostLimit == null) {
|
hostLimit = new HostLimit();
|
packageMeta.setHostLimit(hostLimit);
|
}
|
|
hostLimit.loadOneItemLimit(itemLimit);
|
}
|
}
|
|
public static DataPackageMeta loadOneDataPackage(String dataName) throws Exception {
|
//1. 加载主表
|
DataObject dataObject = DataObject.getInstance("sys_data_package");
|
Entity entity = dataObject.getTableEntity(new Filter("name", dataName));
|
|
if (entity == null) {
|
return null;
|
}
|
|
DataPackageMeta packageMeta = new DataPackageMeta();
|
packageMeta.load(entity);
|
|
//2. 加载明细表
|
dataObject = DataObject.getInstance("sys_data_package_detail");
|
EntitySet detailSet = dataObject.getTableEntitySet(new Filter("parent_id", packageMeta.getId()));
|
|
for (Entity detailEntity: detailSet) {
|
PackageItemMeta itemMeta = new PackageItemMeta();
|
itemMeta.load(detailEntity);
|
|
DataObject itemObject = DataObject.refresh(itemMeta.getName());
|
|
if (itemObject == null) {
|
logger.error("can not find data object: {}", itemMeta.getName());
|
continue;
|
}
|
|
itemMeta.setDataObject(itemObject);
|
packageMeta.loadOneDetail(itemMeta);
|
}
|
|
return packageMeta;
|
}
|
|
|
}
|
