package foundation.dao;
|
|
import java.util.List;
|
|
import foundation.dao.version.PackageChange;
|
import foundation.data.entity.Entity;
|
import foundation.data.entity.EntitySet;
|
import foundation.data.entity.EntityTree;
|
import foundation.data.meta.property.MetaCode;
|
import foundation.data.meta.property.MetaType;
|
import foundation.data.meta.property.PropertysRuntime;
|
import foundation.handler.IMessageReporter;
|
import foundation.handler.LetterWriter;
|
import foundation.handler.ResultPool;
|
import foundation.json.IJSONProvider;
|
import foundation.json.JSONWriter;
|
import foundation.token.IOnlineUser;
|
|
public class DataWriter extends LetterWriter implements IMessageReporter {
|
|
protected static ThreadLocal<DataWriter> localInstance;
|
private Domain domain;
|
private DataPackage dataPackage;
|
private ResultPool resultPool;
|
|
|
public DataWriter(ResultPool resultPool, Domain domain) {
|
this.resultPool = resultPool;
|
this.domain = domain;
|
|
resultPool.setLetterWriter(this);
|
}
|
|
public synchronized void reportOneAlertValidation(String message) {
|
resultPool.reportOneAlertValidation(message);
|
}
|
|
public synchronized void reportOneRejectValidation(String message) {
|
resultPool.reportOneRejectValidation(message);
|
}
|
|
public synchronized void reportOneMessage(String step, String message) {
|
resultPool.reportOneMessage(step, message);
|
}
|
|
public synchronized void reportOneError(String step, String error) {
|
resultPool.reportOneError(step, error);
|
}
|
|
@Override
|
public synchronized void reportExistsError(String step, String dataTitle, IJSONProvider errorSet) {
|
resultPool.reportExistsError(step, dataTitle, errorSet);
|
}
|
|
@Override
|
public void write(JSONWriter writer) {
|
//1. write meta
|
writeMeta(writer);
|
|
//2. write data
|
writeData(writer);
|
|
//3. write host
|
writeHostMeta(writer);
|
|
//4. write host
|
writeHost(writer);
|
|
//5. write change
|
writeChange(writer);
|
}
|
|
private void writeMeta(JSONWriter writer) {
|
if (dataPackage == null) {
|
return;
|
}
|
|
if ((domain == null) || (MetaType.None == domain.getMetaType())) {
|
return;
|
}
|
|
//1. 创建 meta code
|
MetaCode metaCode = new MetaCode();
|
metaCode.setScene(domain.getScene());
|
metaCode.setType(domain.getMetaType());
|
|
IOnlineUser user = IOnlineUser.getInstance();
|
metaCode.setUser(user);
|
|
//2. 打印
|
writer.beginObject("meta");
|
writeDataPackageMetas(writer, metaCode);
|
writer.endObject();
|
}
|
|
private void writeDataPackageMetas(JSONWriter writer, MetaCode metaCode) {
|
if (dataPackage == null) {
|
return;
|
}
|
|
//1. 如果是带点操作符的Partial类型，需要根据原始PackageMeta打印
|
if (domain.isPartial()) {
|
PackageItem packageItem = dataPackage.getMaster();
|
writeOneItemMeta(writer, packageItem, metaCode);
|
return;
|
}
|
|
//2. 打印 Master
|
PackageItem master = dataPackage.getMaster();
|
writeOneItemMeta(writer, master, metaCode);
|
|
//3. 打印 Slaves
|
metaCode.setType(MetaType.Unknow);
|
|
List<PackageItem> slaves = dataPackage.getSlaveItems();
|
for (PackageItem packageItem: slaves) {
|
writeOneItemMeta(writer, packageItem, metaCode);
|
}
|
}
|
|
private void writeData(JSONWriter writer) {
|
if (dataPackage == null && isContainsDataItem()) {
|
return;
|
}
|
|
writer.beginObject("data");
|
|
if (dataPackage == null) {
|
writer.endObject();
|
return;
|
}
|
|
PackagePrintType printType = dataPackage.getResultPrintType();
|
|
//1. 如果需要批量输出Master
|
if (PackagePrintType.BatchMaster == printType) {
|
PackageItem master = dataPackage.getMaster();
|
|
//1.1 输出数据
|
EntitySet entitySet = master.getEntitySet(DataSource.Result);
|
writeEntitySet(writer, "entitySet", entitySet);
|
|
//1.2 输出Page
|
Page page = dataPackage.getPage();
|
|
if (page != null) {
|
writePage(writer, "page", page);
|
}
|
|
writer.endObject();
|
return;
|
}
|
|
//2. 如果需要输出完整的Package
|
if (PackagePrintType.Package == printType) {
|
//2.1 输出Master
|
PackageItem master = dataPackage.getMaster();
|
|
if (master != null) {
|
Entity entity = master.getEntity(DataSource.Result);
|
if (entity != null && !entity.isEmpty()) {
|
writeEntity(writer, master.getName(), entity);
|
}
|
}
|
|
//2.2 输出Slaves
|
List<PackageItem> slaves = dataPackage.getSlaveItems();
|
|
for (PackageItem packageItem: slaves) {
|
writeOnePackageItem(writer, packageItem);
|
}
|
|
writer.endObject();
|
return;
|
}
|
}
|
|
private void writeHostMeta(JSONWriter writer) {
|
if ((domain == null) || (MetaType.None == domain.getMetaType()) || (dataPackage == null)) {
|
return;
|
}
|
|
//1. 如果是批量输出，不输出 Host meta
|
PackagePrintType printType = dataPackage.getResultPrintType();
|
|
if (PackagePrintType.BatchMaster == printType) {
|
return;
|
}
|
|
//2. 如果Host为空，输出Null
|
DataPackage host = dataPackage.getHost();
|
|
if (host == null) {
|
writer.writeNull("host_meta");
|
return;
|
}
|
|
//3. 打印 host meta
|
MetaCode metaCode = new MetaCode();
|
metaCode.setScene(domain.getScene());
|
|
writer.beginObject("host_meta");
|
|
PackageItem master = host.getMaster();
|
writeOneItemMeta(writer, master, metaCode);
|
|
List<PackageItem> slaves = host.getSlaveItems();
|
metaCode.setType(MetaType.Unknow);
|
for (PackageItem packageItem: slaves) {
|
writeOneItemMeta(writer, packageItem, metaCode);
|
}
|
|
writer.endObject();
|
}
|
|
private void writeHost(JSONWriter writer) {
|
if (dataPackage == null) {
|
return;
|
}
|
|
//1. 如果是批量输出，不输出Host
|
PackagePrintType printType = dataPackage.getResultPrintType();
|
|
if (PackagePrintType.BatchMaster == printType) {
|
return;
|
}
|
|
//2. 如果Host为空，输出Null
|
DataPackage host = dataPackage.getHost();
|
|
if (host == null) {
|
writer.writeNull("host");
|
return;
|
}
|
|
//3. 输出完整的Host
|
writer.beginObject("host");
|
|
//3.1 输出Host.Master
|
PackageItem master = host.getMaster();
|
|
if (master != null) {
|
Entity entity = master.getEntity(DataSource.Result);
|
|
if (entity == null || entity.isEmpty()) {
|
writer.writeNull(master.getName());
|
}
|
else {
|
writeEntity(writer, master.getName(), entity);
|
}
|
}
|
|
//3.2 输出Host.Slaves
|
List<PackageItem> slaves = host.getSlaveItems();
|
|
for (PackageItem packageItem: slaves) {
|
writeOnePackageItem(writer, packageItem);
|
}
|
|
writer.endObject();
|
}
|
|
private void writeChange(JSONWriter writer) {
|
if (dataPackage == null) {
|
return;
|
}
|
|
//1. 如果是批量输出，不输出Host
|
PackagePrintType printType = dataPackage.getResultPrintType();
|
|
if (PackagePrintType.BatchMaster == printType) {
|
return;
|
}
|
|
//2. 如果change为空，输出Null
|
PackageChange change = dataPackage.getChange();
|
|
if (change == null) {
|
DataPackage host = dataPackage.getHost();
|
|
if (host == null) {
|
return;
|
}
|
|
change = host.getChange();
|
}
|
|
if (change == null) {
|
writer.writeNull("change");
|
return;
|
}
|
|
//3. 输出完整的change
|
change.writeJSON(writer);
|
}
|
|
private void writeOnePackageItem(JSONWriter writer, PackageItem packageItem) {
|
PackageItemType type = packageItem.getType();
|
|
if (PackageItemType.Master == type) {
|
Entity entity = packageItem.getEntity(DataSource.Result);
|
writeEntity(writer, packageItem.getName(), entity);
|
}
|
else if (PackageItemType.Branch == type && !packageItem.isLasyLoad()) {
|
Entity entity = packageItem.getEntity(DataSource.Result);
|
writeEntity(writer, packageItem.getName(), entity);
|
}
|
else if (PackageItemType.Detail == type && !packageItem.isLasyLoad()) {
|
EntitySet entitySet = packageItem.getEntitySet(DataSource.Result);
|
writeEntitySet(writer, packageItem.getName(), entitySet);
|
}
|
}
|
|
private void writeEntity(JSONWriter writer, String name, Entity entity) {
|
//1.
|
if (entity == null) {
|
writer.writeNull(name);
|
return;
|
}
|
|
//2.
|
writer.beginObject(name);
|
entity.writeJSONBody(writer);
|
writer.endObject();
|
}
|
|
private void writeEntitySet(JSONWriter writer, String name, EntitySet entitySet) {
|
//1.
|
if (entitySet == null) {
|
writer.writeNull(name);
|
return;
|
}
|
|
//2.
|
writer.beginArray(name);
|
|
if (entitySet instanceof EntityTree) {
|
((EntityTree)entitySet).writeJSONBody(writer);
|
}
|
else {
|
entitySet.writeJSONBody(writer);
|
}
|
|
writer.endArray();
|
}
|
|
private void writePage(JSONWriter writer, String name, Page page) {
|
//1.
|
if (page == null) {
|
writer.writeNull(name);
|
}
|
|
//2.
|
writer.beginObject(name);
|
page.writeJSONBody(writer);
|
writer.endObject();
|
}
|
|
private void writeOneItemMeta(JSONWriter writer, PackageItem packageItem, MetaCode metaCode) {
|
//1. 检查MetaCode
|
MetaType metaType = metaCode.getType();
|
|
if (MetaType.Unknow == metaType) {
|
PackageItemType type = packageItem.getType();
|
metaType = (PackageItemType.Detail == type) ? MetaType.List : MetaType.Form;
|
|
metaCode.setType(metaType);
|
}
|
|
metaCode.setDataObject(packageItem.getDataObject());
|
|
//2.
|
PropertysRuntime propertyMetas = PropertysRuntime.getInstance(metaCode);
|
writer.beginObject(packageItem.getName());
|
|
//2. ObjectName、TableName
|
writer.write("objectname", packageItem.getDataObject().getDataName());
|
writer.write("tablename", packageItem.getDataObject().getTableName());
|
|
//3. 打印package item 自身信息
|
packageItem.writeJSONBody(writer);
|
|
//4. 打印字段数据
|
writer.beginArray("fields");
|
|
if (propertyMetas != null) {
|
propertyMetas.writeJSON(writer);
|
}
|
|
writer.endArray();
|
writer.endObject();
|
}
|
|
@Override
|
public void free() {
|
|
}
|
|
public void setDataPackage(DataPackage dataPackage) {
|
this.dataPackage = dataPackage;
|
}
|
|
public DataPackage getDataPackage() {
|
return dataPackage;
|
}
|
|
public ResultPool getResultPool() {
|
return resultPool;
|
}
|
|
public boolean isSuccess() {
|
return resultPool.isSuccess();
|
}
|
|
public void setSuccess(boolean success) {
|
resultPool.setSuccess(success);
|
}
|
}
|
