package foundation.dao;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.json.JSONObject;

import foundation.dao.version.PackageChange;
import foundation.data.entity.Entity;
import foundation.data.entity.EntityNode;
import foundation.data.entity.EntitySet;
import foundation.data.entity.EntityTree;
import foundation.data.entity.LineOperator;
import foundation.data.object.DataObject;
import foundation.data.object.IParamProvider;
import foundation.handler.IMessageReporter;
import foundation.json.IJSONProvider;
import foundation.json.IJSONWriter;
import foundation.json.JArrayReader;
import foundation.json.JObjectReader;
import foundation.json.JSONBuilder;
import foundation.json.JSONReader;
import foundation.json.JType;
import foundation.translator.ValueType;
import foundation.util.ContentBuilder;
import foundation.util.ID;
import foundation.util.Util;
import foundation.variant.provider.DataEvent;

public class PackageItem implements IJSONProvider {
	
	protected static Logger logger;
	protected DataPackage parent;
	protected PackageItem master;
	protected PackageItem owner;
	protected PackageItemMeta meta;
	protected String lineId;
	protected DataCells dataCells;
	
	static {
		logger = LogManager.getLogger(PackageItem.class);
	}
		
	public PackageItem(DataPackage parent, PackageItemMeta meta) {
		this.parent = parent;
		this.meta = meta;
		this.dataCells = new DataCells();
	}
	
	public PackageItem(DataObject dataObject) {
		meta = new PackageItemMeta();
		meta.load(dataObject);
		this.dataCells = new DataCells();
	}

	public void loadOneDataFromJSON(JObjectReader packageReader, DataSource dataSource) throws Exception {
		String name = getName();
		
		JType valueType = packageReader.getType(name);
		
		//1. 如果JSON中是Object，加载Entity
		if (JType.Object == valueType) {
			JObjectReader itemReader = packageReader.getReader(name, JType.Object);
			loadEntityFromJSON(itemReader, dataSource);
			return;
		}
		
		//1. 如果JSON中是Array，加载EntitySet
		if (JType.Array == valueType) {
			JArrayReader itemReader = packageReader.getReader(name, JType.Array);
			loadEntitySetFromJSON(itemReader, dataSource);
			return;
		}
	}

	public Entity createDefaultOneData() throws Exception {
		DataObject dataObject = meta.getDataObject();
		
		//1. 创建Entity， 添加默认值
		Entity entity = dataObject.createBrowseEntity(true);
		dataObject.setEntityDefaultValues(DataEvent.New, entity);
		entity.setId(ID.newValue());
		
		//2. 如果不是Master，设置ParentID
		if (PackageItemType.Master != getType()) {
			String masterId = master.getId();
			entity.set(meta.getParentField(), masterId);
		}
		
		//3. 加载数据并返回
		dataCells.load(DataSource.New, entity);
		return entity;
	}
	
	public void cloneDataTo(PackageItem target, DataSource... dataSource) throws Exception {
		for (DataSource source: dataSource) {
			Object data = dataCells.getData(source);
			
			if (data == null) {
				continue;
			}
			
			DataObject dataObject = meta.getDataObject();
			
			//1. 如果是 Entity 就 clone 一条
			if (data instanceof Entity) {
				Entity entity = dataObject.cloneEntity((Entity)data);
				target.dataCells.setData(entity, DataSource.New);
				return;
			}
			
			//2. 如果是 EntitySet 就 clone 多条
			if (data instanceof EntitySet) {
				EntitySet entitySet = dataObject.cloneEntitySet((EntitySet)data);
				target.dataCells.setData(entitySet, DataSource.New);
				return;
			}
		}
	}
	
	public void loadBatchDataFromDB(Filter filter, Page page, OrderBy orderBy) throws Exception {
		DataObject dataObject = meta.getDataObject();
		
		//1. 如果没有OrderBy，使用DataPackage配置中的默认OrderBy
		if (orderBy == null || orderBy.isEmpty()) {
			orderBy = dataObject.getDefaultOrderBy();
		}
		
		//2. 加载EntitySet
		EntitySet entitySet = dataObject.getBrowseEntitySet(filter, page, orderBy);
		dataCells.load(DataSource.DB, entitySet);
	}

	public void loadTreeDataFromDB(Filter filter, OrderBy customOrderBy) throws Exception {
		DataObject dataObject = meta.getDataObject();
		
		//1. Order By
		OrderBy orderBy = new OrderBy("parent_id");
		
		if (customOrderBy == null || customOrderBy.isEmpty()) {
			customOrderBy = dataObject.getDefaultOrderBy();
		}
		
		orderBy.addAll(customOrderBy);
		
		//2.1 如果没有过滤条件，加载包含所有数据的EntityTree
		if (filter == null || filter.isEmpty()) {
			EntityTree tree = dataObject.getBrowseEntityTree(filter, orderBy);
			dataCells.load(DataSource.DB, tree);
			return;
		}
		
		//2.2 如果有过滤条件，加载包含所有数据的EntityTree，然后进行过滤
		EntitySet entitySet = dataObject.getTableEntitySet(filter);
		
		EntityTree tree = dataObject.getBrowseEntityTree(orderBy);
		tree.setSelectActive(true);
		
		for (Entity entity: entitySet) { 
			Entity selected = tree.getEntity("id", entity.getId());
			((EntityNode)selected).setSelected();
		}
			
		dataCells.load(DataSource.DB, tree);
		return;
	}
	
	public void loadOneDataFromDB() throws Exception {
		loadOneDataFromDB(null);
	}
	
	public boolean loadOneDataFromDB(Filter filter) throws Exception {
		DataObject dataObject = meta.getDataObject();
		PackageItemType type = meta.getType();
		
		//1. 在页面原有filter的基础上，增加过滤条件，如果是 master用id，如果不是master用parentID 
		String fieldName = (PackageItemType.Master == getType()) ? "id" : meta.getParentField();
		String masterId = master.getId();
		
		if (Util.isEmpty(masterId) && (filter == null || filter.isEmpty())) {
			logger.error("id or filter is null, dataPackage skip load");
			return false;
		}
		
		if (filter == null) {
			filter = new Filter();
		}
		
		if (!Util.isEmpty(masterId)) {
			fieldName = dataObject.getTableName() + "." + fieldName;
			filter.add(fieldName, masterId);
		}
		
		//2. 从数据库中加载Entity
		if (type.isEntity()) {
			Entity entity = dataObject.getBrowseEntity(filter);
			
			if (entity != null) {
				lineId = entity.getId();
			}
			
			dataCells.load(DataSource.DB, entity);
			return entity != null;
		}
		
		//3. 从数据库中加载EntitySet
		if (type.isEntitySet()) {
			EntitySet entityset = dataObject.getBrowseEntitySet(filter);
			dataCells.load(DataSource.DB, entityset);
			return !entityset.isEmpty();
		}
		
		return false;
	}
	
	public int saveOneDataToDB(DataSource dataSource) throws Exception {
		return saveOneDataToDB(dataSource, null, null);
	}
	
	public int saveOneDataToDB(DataSource dataSource, IParamProvider paramProvider, IMessageReporter reporter) throws Exception {
		DataObject dataObject = meta.getDataObject();
		
		//1. 如果是Entity，就单条保存
		if (isEntity(dataSource)) {
			Entity entity = getEntity(dataSource);
			dataObject.saveEntity(entity, paramProvider, reporter);
			
			if (Util.isEmpty(lineId)) {
				lineId = entity.getId();
			}
			
			return 1;
		}
		
		//2. 如果是EntitySet，就多条保存
		int result = 0;
		
		if (isEntitySet(dataSource)) {
			EntitySet entitySet = getEntitySet(dataSource);
			
			//2.1 判断明细中哪些记录需要删除
			deleteEntitys(dataObject, entitySet);
			
			for (Entity entity: entitySet) {
				 dataObject.saveEntity(entity, paramProvider, reporter);
				 result++;
			}
		}
		
		return result;
	}
	
	//将不在 EntitySet 中的记录删除掉
	private void deleteEntitys(DataObject dataObject, EntitySet entitySet) throws Exception {
		String parentId = master.getId();
		
		if (Util.isEmpty(parentId)) {
			return;
		}
		
		//1. 根据 parent.id 删除不在entitySet中的数据
		Filter filter = new Filter();
		filter.add(meta.getParentField(), parentId);
		
		ContentBuilder builder = new ContentBuilder(", ");
		boolean empty = true;
		
		for (Entity entity : entitySet) {
			String id = entity.getString("id");
			
			if (Util.isEmpty(id)) {
				continue;
			}
			
			builder.append(Util.quotedStr(id));
			empty = false;
		}
		
		if (entitySet != null && !entitySet.isEmpty()) {
			filter.add("id", " not in ", "(" + builder.toString() + ")");
		}
		
		//2. 如果都是没有 ID 的数据（都是需要插入的数据），就直接退出
		if (empty) {
			return;
		}
		
		//3. 删除数据
		dataObject.deleteEntitySet(filter);
	}
	
	public void saveOneDataToString(DataSource dataSource, JSONBuilder result) {
		if(isEmpty(dataSource)) {
			return;
		}
		
		//1. 如果是Entity，就单条保存
		if (isEntity(dataSource)) {
			Entity entity = getEntity(dataSource);
			
			result.beginObject(getName());
			entity.writeJSONBody(result);
			result.endObject();
			
			return;
		}
		
		//2. 如果是EntitySet，就多条保存
		if (isEntitySet(dataSource)) {
			EntitySet entitySet = getEntitySet(dataSource);
			
			result.beginArray(getName());
			
			for (Entity entity: entitySet) {
				if (Util.isEmpty(entity.getId())) {
					entity.set("id", ID.newValue());
				}
				
				result.beginObject();
				entity.writeJSONBody(result);
				result.endObject();
			}
			
			result.endArray();
		}
	}
	
	public void deleteOneDataFromDB() throws Exception {
		DataObject dataObject = meta.getDataObject();
		
		String fieldName = (PackageItemType.Master == getType()) ? "id" : meta.getParentField();
		String masterId = master.getId();
		
		Filter filter = new Filter(fieldName, masterId);
		dataObject.deleteEntity(filter);
	}

	public void compare(PackageChange changes, DataSource oneSource, DataSource anotherSource) throws Exception {
		if (oneSource == anotherSource) {
			return;
		}
		
		if (oneSource == null || anotherSource == null) {
			return;
		}
		
		//1. 如果是Entity，就单条保存
		if (isEntity(oneSource)) {
			Entity one = getEntity(oneSource);
			Entity another = getEntity(anotherSource);
			
			changes.compareEntity(getName(), one, another);
			return;
		}
		
		//2. 如果是EntitySet，就多条保存
		if (isEntitySet(oneSource)) {
			EntitySet one = getEntitySet(oneSource);
			EntitySet another = getEntitySet(anotherSource);
			
			changes.compareEntitySet(getName(), one, another);			
		}
	}
	
	protected Entity loadEntityFromJSON(JObjectReader itemReader, DataSource dataSource) throws Exception {
		if (itemReader == null) {
			return null;
		}
		
		//1. 创建空记录
		DataObject dataObject = meta.getDataObject();
		Entity entity = dataObject.createEmptyBrowseEntity();
		
		//2. 从JSON读取数据
		doLoadEntityFromJSON(itemReader, entity);
		
		if (entity.isEmpty()) {
			return null;
		}
		
		//3. 如果ID为空，设置ID
		if (entity.isEmptyValue("id")) {
			String dataId = ID.newValue();
			entity.set("id", dataId);
		}

		//4. 设置ParentID
		if (PackageItemType.Master != getType()) {
			String masterId = master.getId(), parentField = meta.getParentField();
			if (entity.isEmptyValue(parentField)) {
				entity.set(parentField, masterId);
			}
		}
		
		//5. 设置行ID和data
		lineId = entity.getId();
		dataCells.load(dataSource, entity);
		
		return entity;
	}

	protected void loadEntitySetFromJSON(JSONReader arrayReader, DataSource dataSource) throws Exception {
		DataObject dataObject = meta.getDataObject();

		String masterField = meta.getParentField();
		String masterId = master.getId(); 
		
		EntitySet entitySet = dataObject.createBrowseEntitySet();
		
		for (JSONReader detailReader: arrayReader) {
			Entity entity = entitySet.newEntity();
			doLoadEntityFromJSON(detailReader, entity);
			
			if (entity.isEmpty()) {
				continue;
			}
			
			if (entity.isEmptyValue(masterField)) {
				entity.set(masterField, masterId);
			}
			
			entitySet.append(entity);
		}	
		
		dataCells.load(dataSource, entitySet);
	}

	protected void doLoadEntityFromJSON(JSONReader objectReader, Entity entity) {
		//1. load operator
		LineOperator operator = LineOperator.parse(objectReader.getString(LineOperator.Code));
		entity.setOperator(operator);
		
		//2. load field value
		for (JSONReader item: objectReader) {
			String name = item.getName();
			Object value = item.getValue(null);
			
			if (!entity.contains(name) ||  (value == null)) {
				continue;
			}
			
			if (JSONObject.NULL == value) {
				entity.set(name, ValueType.Null);
				continue;
			}
			
			value = Util.decodeValue(value);
			entity.set(name, value);
		}
	}
	
	public String getId() {
		return lineId;
	}

	public void setId(String id) throws Exception {
		lineId = id;
	}
	
	public String getName() {
		return meta.getName();
	}
	
	public String getFullName() {
		String result = parent.getName() + "." + meta.getName();
		return result;
	}

	public PackageItemType getType() {
		return meta.getType();
	}

	public PackageItemMeta getMeta() {
		return meta;
	}

	public Object getData(DataSource... dataSource) {
		return dataCells.getData(dataSource);
	}

	public Entity getEntity(DataSource... dataSource) {
		return dataCells.getEntity(dataSource);
	}
	
	public EntitySet getEntitySet(DataSource... dataSource) {
		return dataCells.getEntitySet(dataSource);
	}

	public String getValueString(String fieldName) {
		return getValueString(fieldName, DataSource.DB);
	}
	
	public String getValueString(String fieldName, DataSource... dataSource) {
		Entity entity = getEntity(dataSource);
		return entity.getString(fieldName);
	}
	
	public void setMaster(PackageItem master) {
		this.master = master;
	}

	public DataObject getDataObject() {
		return meta.getDataObject();
	}

	public boolean isTree() {
		return meta.isTree();
	}

	public boolean isEntitySet(DataSource... dataSource) {
		return dataCells.isEntitySet(dataSource);
	}
	
	public boolean isEntity(DataSource... dataSource) {
		return dataCells.isEntity(dataSource);
	}
	
	public boolean isEmpty(DataSource... dataSource) {
		return dataCells.isEmpty(dataSource);
	}

	public String getParentField() {
		return meta.getParentField();
	}
	
	public boolean isLasyLoad() {
		return meta.isLasyLoad();
	}
	
	public void setResultData(DataSource dataSource) {
		dataCells.setResult(dataSource);
	}
	
	public Page getPage() {
		return null;
	}
	
	@Override
	public void writeJSON(IJSONWriter writer) {
		writer.beginObject(getName());
		writeJSONBody(writer);
		writer.endObject();
	}
	
	public void writeJSONBody(IJSONWriter writer) {
		writer.write("lasyLoad", meta.isLasyLoad());
	}

	@Override
	public String toString() {
		return parent.getName() + "." + meta.getName();
	}

}