package foundation.dao;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Set;
|
|
import org.apache.logging.log4j.LogManager;
|
import org.apache.logging.log4j.Logger;
|
|
import foundation.dao.bizlogic.IStateProvider;
|
import foundation.dao.bizlogic.IVersionProvider;
|
import foundation.dao.version.PackageChange;
|
import foundation.dao.version.VersionBrowseType;
|
import foundation.dao.version.VersionCompareType;
|
import foundation.dao.version.VersionRequest;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.object.DataObject;
|
import foundation.data.object.EntitySaver;
|
import foundation.data.object.IParamProvider;
|
import foundation.handler.IMessageReporter;
|
import foundation.json.JObjectReader;
|
import foundation.json.JSONBuilder;
|
import foundation.json.JType;
|
import foundation.token.IOnlineUser;
|
import foundation.util.MapList;
|
import foundation.util.Util;
|
import foundation.variant.provider.DataEvent;
|
|
|
public class DataPackage implements Iterable<PackageItem> {
|
|
protected static Logger logger;
|
protected static IVersionProvider versionProvider;
|
protected static IStateProvider stateProvider;
|
protected DataPackageMeta meta;
|
protected DataPackageMeta sourceMeta;
|
protected PackageItem master;
|
protected MapList<String, PackageItem> allItems;
|
protected List<PackageItem> slaveItems;
|
protected DataPackage applyer;
|
protected DataPackage host;
|
protected PackageChange change;
|
protected DataReader dataReader;
|
protected VersionRequest versionRequest;
|
protected Filter filter;
|
protected Page page;
|
protected OrderBy orderBy;
|
protected PackageState state;
|
|
static {
|
logger = LogManager.getLogger(DataPackage.class);
|
versionProvider = new IVersionProvider();
|
}
|
|
public static DataPackage getInstance(String dataName) throws Exception {
|
//1. get package meta
|
DataPackageMetaContainer metaContainer = DataPackageMetaContainer.getInstance();
|
DataPackageMeta packageMeta = metaContainer.get(dataName);
|
|
if (packageMeta == null) {
|
return null;
|
}
|
|
DataPackage result = new DataPackage();
|
result.init(packageMeta);
|
return result;
|
}
|
|
public static DataPackage getInstance(String dataName, String itemName) throws Exception {
|
//1. get package meta
|
DataPackageMetaContainer metaContainer = DataPackageMetaContainer.getInstance();
|
DataPackageMeta packageMeta = metaContainer.get(dataName);
|
|
if (packageMeta == null) {
|
return null;
|
}
|
|
DataPackage result = null;
|
|
//2. 正常DataPackage创建
|
if (Util.isEmpty(itemName)) {
|
result = new DataPackage();
|
result.init(packageMeta);
|
|
return result;
|
}
|
|
//3. Partial DataPackage创建
|
PackageItemMeta itemMeta = packageMeta.getItem(itemName);
|
DataPackageMeta partialMeta = new DataPackageMeta(itemMeta);
|
|
result = new DataPackage();
|
result.sourceMeta = packageMeta;
|
result.init(partialMeta);
|
|
return result;
|
}
|
|
public static DataPackage refresh(String dataName) throws Exception {
|
DataPackageMetaContainer metaContainer = DataPackageMetaContainer.getInstance();
|
DataPackageMeta packageMeta = metaContainer.refresh(dataName);
|
|
if (packageMeta == null) {
|
return null;
|
}
|
|
DataPackage result = new DataPackage();
|
result.init(packageMeta);
|
|
return result;
|
}
|
|
protected DataPackage() {
|
allItems = new MapList<String, PackageItem>();
|
slaveItems = new ArrayList<PackageItem>();
|
state = new PackageState();
|
filter = new Filter();
|
page = new Page();
|
orderBy = new OrderBy();
|
}
|
|
protected void init(DataPackageMeta packageMeta) throws Exception {
|
//1. meta
|
this.meta = packageMeta;
|
|
//2. create items
|
createItems();
|
}
|
|
public void rebuildItems() {
|
//1. clear
|
clearItems();
|
|
//2. create
|
createItems();
|
}
|
|
public void loadDataFromRequest() throws Exception {
|
loadDataFromRequest("data");
|
}
|
|
public void loadDataFromRequest(String name) throws Exception {
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isDataLoaded()) {
|
return;
|
}
|
|
JObjectReader packageReader = dataReader.getReader(name, JType.Object);
|
if (packageReader == null) {
|
return;
|
}
|
|
//1. master --> load JSON
|
master.loadOneDataFromJSON(packageReader, DataSource.Request);
|
|
//2. slaves --> load JSON
|
for (PackageItem packageItem: slaveItems) {
|
packageItem.loadOneDataFromJSON(packageReader, DataSource.Request);
|
}
|
|
//3. set state
|
jsonState.setDataLoaded(true);
|
}
|
|
public void loadDataIdFromRequest() throws Exception {
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isIdLoaded()) {
|
return;
|
}
|
|
String id = master.getId();
|
if (!Util.isEmpty(id)) {
|
jsonState.setIdLoaded(true);
|
return;
|
}
|
|
Domain domain = dataReader.getDomain();
|
id = domain.getId();
|
|
//1. 为master设置ID
|
if (master != null && !Util.isEmpty(id)) {
|
master.setId(id);
|
}
|
|
//2. set state
|
jsonState.setIdLoaded(!Util.isEmpty(id));
|
}
|
|
public void loadFilterFromJSON() throws Exception {
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isFilterLoaded() || (master == null)) {
|
return;
|
}
|
|
DataObject dataObject = master.getDataObject();
|
|
//如果不是host才需要从请求里面加载参数
|
if (applyer == null) {
|
//1. 默认加载ID
|
loadDataIdFromRequest();
|
|
//2. 加载过滤条件
|
if (dataReader != null) {
|
dataReader.loadFilterFromJSON(dataObject, filter);
|
}
|
|
}
|
|
//3. 如果过滤条件为空，但是id不为空
|
String id = master.getId();
|
|
if (!Util.isEmpty(id)) {
|
if (filter == null) {
|
filter = new Filter();
|
}
|
|
String tableName = dataObject.getTableOrViewName();
|
filter.add(DataReader.getFullFieldName(tableName, "id"), id);
|
}
|
|
//4. set state
|
jsonState.setFilterLoaded(true);
|
}
|
|
public void loadPageOrderByFromJSON() throws Exception {
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isPageOrderLoaded() || (master == null)) {
|
return;
|
}
|
|
//1. load page order by
|
DataObject dataObject = master.getDataObject();
|
dataReader.loadPageOrderByFromJSON(dataObject, page, orderBy);
|
|
//2. set state
|
jsonState.setPageOrderLoaded(true);
|
}
|
|
public void loadOrderByFromJSON() throws Exception {
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isPageOrderLoaded() || (master == null)) {
|
return;
|
}
|
|
//1. load page order by
|
DataObject dataObject = master.getDataObject();
|
dataReader.loadOrderByFromJSON(dataObject, orderBy);
|
|
//2. set state
|
jsonState.setPageOrderLoaded(true);
|
}
|
|
private void loadVersionRequest() {
|
this.versionRequest = dataReader.loadVersionRequest();
|
}
|
|
public void loadFilterPageOrderByFromJSON() throws Exception {
|
loadFilterFromJSON();
|
loadPageOrderByFromJSON();
|
}
|
|
public void loadUserLineFilter() throws Exception {
|
if (state.isUserFilterLoaded() || master == null) {
|
return;
|
}
|
|
//1. load user line filter
|
IOnlineUser user = IOnlineUser.getInstance();
|
DataObject dataObject = getMasterDataObject();
|
dataObject.loadUserLineFilter(user, filter);
|
|
//2. set state
|
state.setUserFilterLoaded(true);
|
}
|
|
public void loadBatchDataFromDB() throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isBatchDataLoaded() || master == null) {
|
return;
|
}
|
|
//1. 从请求中获取版本要求
|
loadVersionRequest();
|
|
//2. 从请求中加载过滤条件、分页、OrderBy
|
loadFilterPageOrderByFromJSON();
|
|
//3. load user line limit
|
loadUserLineFilter();
|
|
//4. 计算分页
|
calculatePage();
|
|
//5. load entitySet
|
master.loadBatchDataFromDB(filter, page, orderBy);
|
|
//6. set state
|
dbState.setBatchDataLoaded(true);
|
}
|
|
public void loadTreeDataFromDB() throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isBatchDataLoaded() || master == null) {
|
return;
|
}
|
|
//1. 从请求中获取版本要求
|
loadVersionRequest();
|
|
//2. 从请求中加载过滤条件、分页、OrderBy
|
loadFilterFromJSON();
|
loadOrderByFromJSON();
|
|
//3. load user line limit
|
loadUserLineFilter();
|
|
//5. load entitySet
|
master.loadTreeDataFromDB(filter, orderBy);
|
|
//6. set state
|
dbState.setBatchDataLoaded(true);
|
}
|
|
public boolean isDBExists() throws Exception {
|
String masterId = getMasterId();
|
|
if (Util.isEmpty(masterId)) {
|
return true;
|
}
|
|
DataObject dataObject = getMasterDataObject();
|
return dataObject.existsEntity(masterId);
|
}
|
|
public void loadOneDataFromPersist() throws Exception {
|
String dataName = getName();
|
boolean versionActive = versionProvider.isVersionActive(dataName);
|
|
//1. 如果没有版本管理
|
if (!versionActive) {
|
loadOneDataFromDB();
|
}
|
//2. 如果有版本管理
|
else {
|
VersionRequest versionRequest = dataReader.getVersionRequest();
|
VersionBrowseType browseType = versionRequest.getBrowseType();
|
|
//2.1 如果要看最新数据，
|
if (VersionBrowseType.Latest == browseType) {
|
loadOneDataFromFile();
|
return;
|
}
|
|
//2.2 其他情况都从数据库取数据
|
loadOneDataFromDB();
|
|
//2.3 如果需要对比，获取指定数据对比
|
Domain domain = dataReader.getDomain();
|
VersionCompareType compareType = domain.getVersionCompareType();
|
|
if (VersionCompareType.DoNothing != compareType) {
|
compare(DataSource.DB, DataSource.File);
|
}
|
}
|
}
|
|
public void loadOneDataFromDB() throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isOneDataLoaded() || master == null) {
|
return;
|
}
|
|
//1. load master entity
|
master.loadOneDataFromDB(filter);
|
dbState.setMasterLoaded(true);
|
|
//2. slaves --> load persist
|
for (PackageItem packageItem: slaveItems) {
|
if (packageItem.isLasyLoad()) {
|
continue;
|
}
|
|
packageItem.loadOneDataFromDB();
|
dbState.setItemLoaded(packageItem.getName(), true);
|
}
|
|
//3. set state
|
dbState.setOneDataLoaded(true);
|
}
|
|
public void loadOneDataFromFile() throws Exception {
|
FileState fileState = state.getFileState();
|
if (fileState.isOneDataLoaded() || master == null) {
|
return;
|
}
|
|
//1. file reader
|
String dataName = getName(), masterId = getMasterId();
|
String applyId = applyer.getMasterId();
|
|
IVersionIndex versionIndex = versionProvider.getIndex(dataName, masterId, applyId);
|
IFileReader fileReader = versionIndex.getFileReader();
|
JObjectReader packageReader = fileReader.getJSONObjectReader();
|
|
//2. master --> load JSON
|
master.loadOneDataFromJSON(packageReader, DataSource.File);
|
|
//3. slaves --> load JSON
|
for (PackageItem packageItem: slaveItems) {
|
packageItem.loadOneDataFromJSON(packageReader, DataSource.File);
|
}
|
|
//4. set state
|
fileState.setOneDataLoaded(true);
|
}
|
|
public void loadMasterFromDB() throws Exception {
|
DBState dbState = state.getDbState();
|
|
if (dbState.isMasterLoaded() || master == null) {
|
return;
|
}
|
else {
|
String masterId = master.getId();
|
if (!Util.isEmpty(masterId)) {
|
onSetMasterId(masterId);
|
}
|
}
|
|
//1. 获取 master id
|
loadFilterFromJSON();
|
|
if (filter == null || filter.isEmpty()) {
|
return;
|
}
|
|
//2. load entitySet
|
boolean loaded = master.loadOneDataFromDB(filter);
|
|
//3. set state
|
dbState.setMasterLoaded(loaded);
|
}
|
|
public void loadHostIdFromDB() throws Exception {
|
if (host == null) {
|
return;
|
}
|
|
String hostId = host.getMasterId();
|
if (!Util.isEmpty(hostId)) {
|
return;
|
}
|
|
//1. 加载master
|
loadMasterFromDB();
|
|
//2. 加载hostID
|
Entity entity = getMasterEntity();
|
hostId = entity.getString("host_id");
|
host.setMasterId(hostId);
|
}
|
|
public void loadItemFromDB(String itemName) throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isItemLoaded(itemName)) {
|
return;
|
}
|
|
PackageItem item = getItem(itemName);
|
|
if (item == null) {
|
return;
|
}
|
|
//1. load item
|
item.loadOneDataFromDB();
|
|
//2. set state
|
dbState.setItemLoaded(itemName, true);
|
}
|
|
public Set<String> loadItemLimits() throws Exception {
|
return loadItemLimits(true);
|
}
|
|
public Set<String> loadItemLimits(boolean includeReadOnly) throws Exception {
|
if (!meta.containsHostItemLimits()) {
|
return null;
|
}
|
|
//1. 获取 Type Code
|
String typeCode = dataReader.getString(IDataLetter.TypeCode);
|
|
if (Util.isEmpty(typeCode)) {
|
Entity entity = getMasterEntity();
|
|
if (entity != null) {
|
typeCode = entity.getString(IDataLetter.TypeCode);
|
}
|
}
|
|
//2. 获取配置表里面定义的limits
|
Set<String> result = meta.getHostItemLimits(typeCode, includeReadOnly);
|
|
//3. 返回结果
|
return result;
|
}
|
|
public void createDefaultOneData() throws Exception {
|
CreateState createState = state.getCreateState();
|
if (createState.isDataCreated() || master == null) {
|
return;
|
}
|
|
//1. master --> create default data
|
master.createDefaultOneData();
|
|
//2. branch slaves --> create default data
|
String masterId = master.getId();
|
|
for (PackageItem item: slaveItems) {
|
if (PackageItemType.Branch != item.getType()) {
|
continue;
|
}
|
|
Entity entity = item.createDefaultOneData();
|
entity.set(item.getParentField(), masterId);
|
|
createState.setItemCreated(item.getName(), true);
|
}
|
|
//3. 加载页面传过来的值（例如type_code等）
|
loadDataFromRequest();
|
|
//4.加载宿主
|
if (host != null) {
|
Set<String> itemLimits = loadItemLimits();
|
host.execItemLimits(itemLimits);
|
|
host.loadOneDataFromDB();
|
host.setResultData(DataSource.DB);
|
}
|
|
//5. set state
|
createState.setDataCreated(true);
|
}
|
|
public int saveOneDataToPersist() throws Exception {
|
return saveOneDataToPersist(null, null);
|
}
|
|
public int saveOneDataToPersist(IParamProvider paramProvider, IMessageReporter reporter) throws Exception {
|
//1. 如果有宿主，保存宿主到文件中
|
if (host != null) {
|
//1.1 加载 host limit，重新构建items
|
Set<String> itemLimits = loadItemLimits();
|
host.execItemLimits(itemLimits);
|
|
//1.2 加载host，保存到文件
|
host.loadDataFromRequest(IDataLetter.Host);
|
|
if (!host.isEmpty(DataSource.Request)) {
|
host.saveOneDataToFile(DataSource.Request);
|
}
|
}
|
|
//2. 保存当前数据到数据库中
|
return saveOneDataToDB(DataSource.Request, paramProvider, reporter);
|
}
|
|
public void activateOneData() throws Exception {
|
activateOneData(null, null);
|
}
|
|
public void activateOneData(IParamProvider iParamProvider, IMessageReporter reporter) throws Exception {
|
String dataName = getName();
|
String masterId = getMasterId();
|
|
boolean versionActive = versionProvider.isVersionActive(dataName);
|
|
//1. 如果没有版本管理，不需要操作
|
if (!versionActive) {
|
logger.error("{} has no version managent, activate skip", dataName);
|
return;
|
}
|
|
//2. 加载 host limit，重新构建items
|
Set<String> itemLimits = applyer.loadItemLimits(false);
|
execItemLimits(itemLimits);
|
|
//3. 如果版本管理，将最新的文件数据保存到数据库，并为当前生效数据设置正式版本号
|
loadOneDataFromFile();
|
saveOneDataToDB(DataSource.File, iParamProvider, reporter);
|
|
String applyId = applyer.getMasterId();
|
versionProvider.activateVersion(dataName, masterId, applyId);
|
}
|
|
public void fallbackOneData() throws Exception {
|
String dataName = getName();
|
String masterId = getMasterId();
|
boolean versionActive = versionProvider.isVersionActive(dataName);
|
|
//1. 如果没有版本管理，不需要操作
|
if (!versionActive) {
|
logger.error("{} has no version managent, fallback skip", dataName);
|
return;
|
}
|
|
//2. 加载 host limit，重新构建items
|
Set<String> itemLimits = applyer.loadItemLimits();
|
execItemLimits(itemLimits);
|
|
//3. 如果版本管理，删除文件数据，删除失效数据临时版本
|
deleteOneDataFromFile();
|
|
String applyId = applyer.getMasterId();
|
versionProvider.deleteVersion(dataName, masterId, applyId);
|
}
|
|
public int saveOneDataToDB(DataSource dataSource) throws Exception {
|
return saveOneDataToDB(dataSource, null, null);
|
}
|
|
public int saveOneDataToDB(DataSource dataSource, IParamProvider paramProvider, IMessageReporter reporter) throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isOneDataSaved() || master == null) {
|
return 0;
|
}
|
|
int result = 0;
|
|
//1. save to persist
|
result = master.saveOneDataToDB(dataSource, paramProvider, reporter) + result;
|
|
//2. save to persist
|
for (PackageItem item: slaveItems) {
|
result = item.saveOneDataToDB(dataSource, paramProvider, reporter) + result;
|
}
|
|
//3. set state
|
dbState.setOneDataSaved(true);
|
return result;
|
}
|
|
public DataPackage cloneOneData(DataSource... dataSource) throws Exception {
|
DataPackage result = DataPackage.getInstance(meta.getName());
|
|
//1. clone master
|
master.cloneDataTo(result.master, dataSource);
|
|
//2. clone items
|
for (PackageItem item: slaveItems) {
|
String itemName = item.getName();
|
PackageItem targetItem = result.getItem(itemName);
|
|
item.cloneDataTo(targetItem, dataSource);
|
}
|
|
return result;
|
}
|
|
private void compare(DataSource one, DataSource another) throws Exception {
|
change = new PackageChange();
|
|
//1. compare master
|
master.compare(change, one, another);
|
|
//2. save to persist
|
for (PackageItem item: slaveItems) {
|
item.compare(change, one, another);
|
}
|
}
|
|
public void saveOneDataToFile(DataSource dataSource) throws Exception {
|
String dataName = getName();
|
String masterId = getMasterId();
|
String applyId = applyer.getMasterId();
|
|
//1. 创建版本索引（如果索引存在，就不再创建）
|
IVersionIndex index = versionProvider.getIndex(dataName, masterId, applyId);
|
|
if (index == null) {
|
logger.error("{} can not get version index, save to file skip", dataName);
|
return;
|
}
|
|
//2. 保存文件
|
IFileWriter fileWriter = index.getFileWriter();
|
JSONBuilder content = saveOneDataToString(dataSource);
|
fileWriter.write(content);
|
}
|
|
public JSONBuilder saveOneDataToString(DataSource dataSource) throws Exception {
|
JSONBuilder result = new JSONBuilder();
|
|
result.beginObject();
|
|
//1. save to string
|
master.saveOneDataToString(dataSource, result);
|
|
//2. save to persist
|
for (PackageItem item: slaveItems) {
|
item.saveOneDataToString(dataSource, result);
|
}
|
|
result.endObject();
|
|
//3. return
|
return result;
|
}
|
|
public void deleteOneDataFromDB() throws Exception {
|
DBState dbState = state.getDbState();
|
if (dbState.isOneDataDeleted() || master == null) {
|
return;
|
}
|
|
//1. delete slave from persist
|
for (PackageItem packageItem: slaveItems) {
|
packageItem.deleteOneDataFromDB();
|
}
|
|
//2. delete master from persist
|
master.deleteOneDataFromDB();
|
|
//3. set state
|
dbState.setOneDataDeleted(true);
|
}
|
|
public void deleteOneDataFromFile() throws Exception {
|
String dataName = getName();
|
String masterId = getMasterId();
|
String applyId = applyer.getMasterId();
|
|
//1. 创建版本索引（如果索引存在，就不再创建）
|
IVersionIndex index = versionProvider.getIndex(dataName, masterId, applyId);
|
|
if (index == null) {
|
logger.error("{} can not get version index, save to file skip", dataName);
|
return;
|
}
|
|
//2. 保存文件
|
IFileWriter fileWriter = index.getFileWriter();
|
fileWriter.delete();
|
}
|
|
protected void calculatePage() throws Exception {
|
if (master == null || page == null) {
|
return;
|
}
|
|
DataObject dataObject = master.getDataObject();
|
|
int count = dataObject.getCount(filter, dataReader.getUser());
|
page.setRecordCount(count);
|
|
if (page.isEmpty()) {
|
page = null;
|
}
|
}
|
|
protected void addOneItem(PackageItem packageItem) {
|
String name = packageItem.getName();
|
allItems.add(name, packageItem);
|
}
|
|
private void deleteOneItem(PackageItem packageItem) {
|
slaveItems.remove(packageItem);
|
allItems.remove(packageItem.getName());
|
}
|
|
private void clearItems() {
|
allItems.clear();
|
slaveItems.clear();
|
master = null;
|
}
|
|
private void createItems() {
|
//1. create items
|
for (PackageItemMeta itemMeta: meta) {
|
PackageItem item = new PackageItem(this, itemMeta);
|
addOneItem(item);
|
}
|
|
//2. 计算Master、Slave
|
calculateMaster();
|
|
//3. set master relation
|
for (PackageItem item: allItems) {
|
item.setMaster(master);
|
}
|
}
|
|
public void execItemLimits(Set<String> itemNames) {
|
if (itemNames == null || itemNames.isEmpty()) {
|
return;
|
}
|
|
int max = slaveItems.size() - 1;
|
for (int i = max; i >= 0; i--) {
|
PackageItem item = slaveItems.get(i);
|
|
String slaveName = item.getName();
|
slaveName = slaveName.toLowerCase();
|
|
if (!itemNames.contains(slaveName)) {
|
deleteOneItem(item);
|
}
|
}
|
}
|
|
private void calculateMaster() {
|
int size = allItems.size();
|
|
//1. 如果只有一个Item，直接就设置为Master
|
if (size == 1) {
|
master = allItems.get(0);
|
return;
|
}
|
|
//2. 否则遍历所有，进行分类
|
for (PackageItem item: allItems) {
|
PackageItemType type = item.getType();
|
|
if (PackageItemType.Master == type) {
|
master = item;
|
}
|
else {
|
slaveItems.add(item);
|
}
|
}
|
}
|
|
public boolean execValidateRules(IMessageReporter reporter) {
|
boolean success = true;
|
|
for (PackageItem packageItem: allItems) {
|
Object value = packageItem.getData(DataSource.Request);
|
|
if (value == null) {
|
return true;
|
}
|
|
DataObject dataObject = packageItem.getDataObject();
|
|
if (value instanceof EntitySet) {
|
EntitySet entitySet = (EntitySet)value;
|
|
for (Entity entity: entitySet) {
|
success = success && dataObject.validateEntity(entity, reporter);
|
}
|
}
|
else if (value instanceof Entity) {
|
Entity entity = (Entity)value;
|
success = success && dataObject.validateEntity(entity, reporter);
|
}
|
}
|
|
return success;
|
}
|
|
public void execDefaultValueRules(DataEvent dataEvent) {
|
//1. 如果是New的数据
|
if (DataEvent.New == dataEvent) {
|
for (PackageItem item: allItems) {
|
Entity entity = item.getEntity(DataSource.New);
|
|
if (entity == null) {
|
return;
|
}
|
|
DataObject dataObject = item.getDataObject();
|
dataObject.setEntityDefaultValues(dataEvent, entity);
|
return;
|
}
|
}
|
|
//2. 如果是页面传过来要保存的数据
|
for (PackageItem item: allItems) {
|
Entity entity = item.getEntity(DataSource.Request);
|
|
if (entity == null) {
|
return;
|
}
|
|
DataObject dataObject = item.getDataObject();
|
dataObject.setEntityDefaultValues(dataEvent, entity);
|
return;
|
}
|
}
|
|
public void lockMasterRecord() throws Exception {
|
DataObject dataObject = getMasterDataObject();
|
Entity entity = dataObject.createTableEmptyEntity();
|
|
entity.set("id", getMasterId());
|
entity.set("update_time", new Date());
|
|
dataObject.updateEntity(entity);
|
}
|
|
@Override
|
public Iterator<PackageItem> iterator() {
|
return allItems.iterator();
|
}
|
|
public PackageItem getItem(String name) {
|
if (Util.isEmpty(name)) {
|
return master;
|
}
|
|
return allItems.get(name);
|
}
|
|
public List<PackageItem> getSlaveItems() {
|
return slaveItems;
|
}
|
|
public String getItemValue(String path) {
|
//1. 获取package里面某个item的字段值（master.code/so_implant.code）
|
int pos = path.indexOf(".");
|
|
if (pos < 0) {
|
return null;
|
}
|
|
|
String itemName = path.substring(0, pos);
|
String fieldName = path.substring(pos + 1);
|
|
PackageItem item = getItem(itemName);
|
|
if (item == null) {
|
return null;
|
}
|
|
return item.getValueString(fieldName);
|
}
|
|
public PackageItem getMaster() {
|
return master;
|
}
|
|
public String getMasterId() {
|
return master.getId();
|
}
|
|
public void setMasterId(String masterId) throws Exception {
|
master.setId(masterId);
|
}
|
|
public boolean existsMaster() {
|
return master != null;
|
}
|
|
public DataObject getMasterDataObject() {
|
return meta.getMasterDataObject();
|
}
|
|
public DataObject getDetailDataObject() {
|
PackageItem detailItem = getDetailItem();
|
return detailItem.getDataObject();
|
}
|
|
public PackageItem getDetailItem() {
|
//1. 尝试根据名字来获取
|
String detailName = master.getName() + "_detail";
|
PackageItem detail = getItem(detailName);
|
|
if (detail != null) {
|
return detail;
|
}
|
|
//2. 根据类型来获取
|
for (PackageItem item : slaveItems) {
|
PackageItemType type = item.getType();
|
|
if (PackageItemType.Detail.equals(type)) {
|
return item;
|
}
|
}
|
|
return null;
|
}
|
|
public Entity getMasterEntity() {
|
return getMasterEntity(DataSource.DB);
|
}
|
|
public Entity getMasterEntity(DataSource... dataSource) {
|
PackageItem master = getMaster();
|
return master.getEntity(dataSource);
|
}
|
|
public EntitySaver createMasterEntitySaver() throws Exception {
|
PackageItem master = getMaster();
|
EntitySaver saver = new EntitySaver(master.getDataObject(), master.getEntity(DataSource.DB, DataSource.Request));
|
return saver;
|
}
|
|
public EntitySaver createEntitySaver(String itemName) throws Exception {
|
PackageItem item = getItem(itemName);
|
EntitySaver saver = new EntitySaver(item.getDataObject(), item.getEntity(DataSource.DB, DataSource.Request));
|
return saver;
|
}
|
|
public Entity getItemEntity(String itemName) {
|
PackageItem item = getItem(itemName);
|
return item.getEntity(DataSource.DB);
|
}
|
|
public Entity getItemEntity(String itemName, DataSource dataSource) {
|
PackageItem item = getItem(itemName);
|
return item.getEntity(dataSource);
|
}
|
|
public EntitySet getItemEntitySet() {
|
PackageItem item = slaveItems.get(0);
|
return item.getEntitySet(DataSource.DB);
|
}
|
|
public EntitySet getItemEntitySet(String itemName) {
|
PackageItem item = getItem(itemName);
|
return item.getEntitySet(DataSource.DB);
|
}
|
|
public EntitySet getItemEntitySet(String itemName, DataSource... dataSource) {
|
PackageItem item = getItem(itemName);
|
return item.getEntitySet(dataSource);
|
}
|
|
public DataObject getDataObject(String itemName) {
|
PackageItem item = allItems.get(itemName);
|
DataObject result = item != null ? item.getDataObject() : null;
|
return result;
|
}
|
|
public void setResultData(DataSource dataSource) {
|
for (PackageItem item: allItems) {
|
item.setResultData(dataSource);
|
}
|
}
|
|
public boolean isEmpty(DataSource... dataSource) {
|
if (allItems.isEmpty()) {
|
return true;
|
}
|
|
for (PackageItem item: allItems) {
|
if (!item.isEmpty(dataSource)) {
|
return false;
|
}
|
}
|
|
return true;
|
}
|
|
public void onSetMasterId(String masterId) {
|
if (Util.isEmpty(masterId)) {
|
return;
|
}
|
|
JSONState jsonState = state.getJSONState();
|
if (jsonState.isIdLoaded()) {
|
return;
|
}
|
|
if (filter == null) {
|
filter = new Filter();
|
}
|
|
DataObject dataObject = master.getDataObject();
|
String tableName = dataObject.getTableOrViewName();
|
filter.add(DataReader.getFullFieldName(tableName, "id"), masterId);
|
}
|
|
public String getName() {
|
return meta.getName();
|
}
|
|
public Page getPage() {
|
return page;
|
}
|
|
public void setPage(Page page) {
|
this.page = page;
|
}
|
|
public OrderBy getOrderBy() {
|
return orderBy;
|
}
|
|
public void setOrderBy(OrderBy orderBy) {
|
this.orderBy = orderBy;
|
}
|
|
public PackagePrintType getResultPrintType() {
|
if (master.isEntitySet(DataSource.Result)) {
|
return PackagePrintType.BatchMaster;
|
}
|
|
return PackagePrintType.Package;
|
}
|
|
public void setDataReader(DataReader dataReader) throws Exception {
|
this.dataReader = dataReader;
|
}
|
|
public DataReader getDataReader() {
|
return dataReader;
|
}
|
|
public String getHostName() {
|
return meta.getHostName();
|
}
|
|
public void setHost(DataPackage host) {
|
this.host = host;
|
|
host.dataReader = dataReader;
|
host.applyer = this;
|
}
|
|
public DataPackage getHost() {
|
return host;
|
}
|
|
public DataPackage getApplyer() {
|
return applyer;
|
}
|
|
public PackageChange getChange() {
|
return change;
|
}
|
|
public static void registerVersionProvider(IVersionProvider provider) {
|
versionProvider = provider;
|
}
|
|
public PackageState getState() {
|
return state;
|
}
|
|
public void setState(PackageState state) {
|
this.state = state;
|
}
|
|
public PackageStringMap toStringMap() {
|
PackageStringMap result = new PackageStringMap(this);
|
return result;
|
}
|
|
public String getHostID() {
|
if (host == null) {
|
return null;
|
}
|
|
return host.getMasterId();
|
}
|
|
public String getString(String name, String defaultValue) {
|
FieldName fieldName = new FieldName(name);
|
if (fieldName.isEmpty()) {
|
return defaultValue;
|
}
|
|
PackageItem item = getItem(fieldName.getTableName());
|
if (item == null) {
|
item = master;
|
}
|
|
Entity entity = item.getEntity(DataSource.DB);
|
if (entity == null) {
|
return defaultValue;
|
}
|
|
return entity.getString(fieldName.getFieldName());
|
}
|
|
public String getString(String name) {
|
return getString(name, null);
|
}
|
|
public Filter getFilter() {
|
return filter;
|
}
|
|
public void setFilter(Filter filter) {
|
this.filter = filter;
|
}
|
|
}
|
