package foundation.dao;

import java.util.ArrayList;
import java.util.List;

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

import foundation.action.ActionContext;
import foundation.dao.bizlogic.IActionProvider;
import foundation.data.entity.Entity;
import foundation.data.meta.property.MetaType;
import foundation.data.object.DataObject;
import foundation.data.rule.exists.ExistsValidator;
import foundation.json.JSONReader;
import foundation.json.JType;
import foundation.util.Util;


public class DataPipe implements IActionProvider {
	
	protected static Logger logger;
	private static DataPipe instance;

	static {
		logger = LogManager.getLogger(DataPipe.class);
	}

    private DataPipe() {
    	
    }

    public static synchronized DataPipe getInstance() {
        if (instance == null) {
            instance = new DataPipe();
        }

        return instance;
    }
	
	@Override
	public void exec(ActionContext meta, String method) throws Exception {
		OperatorCode code = meta.getOperatorCode();
		
		if (OperatorCode.GetBatch == code) {
			processGetBatch(meta);
		}
		else if (OperatorCode.GetTree == code) {
			processGetTree(meta);
		}		
		else if (OperatorCode.NewOne == code) {
			processNewOne(meta);
		}
		else if (OperatorCode.GetOne == code) {
			processGetOne(meta);
		}
		else if (OperatorCode.Save == code) {
			processSaveOne(meta);
		}
		else if (OperatorCode.UniqueSave == code) {
			processSaveUniqueOne(meta);
		}
		else if (OperatorCode.Clone == code) {
			processClone(meta);
		}
		else if (OperatorCode.Activate == code) {
			processActivateOne(meta);
		}
		else if (OperatorCode.Fallback == code) {
			processFallbackOne(meta);
		}
		else if (OperatorCode.Alter == code) {
			processAlter(meta);
		}
		else if (OperatorCode.Delete == code) {
			processDeleteOne(meta);
		}
		else if (OperatorCode.lockRecord == code) {
			lockRecord(meta);
		}
		else if (OperatorCode.GetTotalCnt == code) {
			processTotalCnt(meta);
		}
		else if (OperatorCode.GetSummary == code) {
			processSummary(meta);
		}
	}

	public void processGetBatch(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load filter page order from JSON
		dataPackage.loadFilterPageOrderByFromJSON();
		
		//2. load data package from persist
		dataPackage.loadBatchDataFromDB();
		dataPackage.setResultData(DataSource.DB);
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	private void processGetTree(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load filter page order from JSON
		dataPackage.loadFilterPageOrderByFromJSON();
		
		//2. load data package from persist
		dataPackage.loadTreeDataFromDB();
		dataPackage.setResultData(DataSource.DB);
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}

	public void processNewOne(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. 默认返回 meta
		Domain domain = meta.getDataReader().getDomain();
		domain.setMetaType(MetaType.Form);
		
		//2. create default data
		dataPackage.createDefaultOneData();
		dataPackage.setResultData(DataSource.New);
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}

	public void processGetOne(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load id from JSON
		dataPackage.loadFilterFromJSON();
		
		//2. load data package from DB or cached
		dataPackage.loadOneDataFromPersist();
		dataPackage.setResultData(DataSource.DB);
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void processSaveOne(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		DataPackage dataPackage = context.getDataPackage();
		
		//1. load data from JSON
		dataPackage.loadDataFromRequest();
		
		//2. validate 
		dataPackage.execValidateRules(dataWriter);
		
		//3. save data to persist（包含数据本身和 Host）
		dataPackage.saveOneDataToPersist(dataReader, dataWriter);
		
		//4. 如果是insert，要将master id 回写到domain里面
		writeBackMasterId(dataReader, dataPackage.getMasterId());
		
		//5. set data to letter
		dataWriter.setDataPackage(dataPackage);
	}

	public void processSaveUniqueOne(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		DataPackage dataPackage = context.getDataPackage();
		
		//1. load data from JSON
		dataPackage.loadDataFromRequest();
		
		//2. validate 
		dataPackage.execValidateRules(dataWriter);

		ExistsValidator existsValidator = new ExistsValidator();
		boolean existsEntity = existsValidator.checkExists(dataPackage, context);
		
		if (existsEntity) {
			return;
		}
		
		//3. save data to persist（包含数据本身和 Host）
		dataPackage.saveOneDataToPersist(dataReader, dataWriter);
		
		//4. 如果是insert，要将master id 回写到domain里面
		writeBackMasterId(dataReader, dataPackage.getMasterId());
		
		//5. set data to letter
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void processClone(ActionContext context) throws Exception {
		DataReader dataReader = context.getDataReader();
		DataWriter dataWriter = context.getDataWriter();
		
		DataPackage dataPackage = context.getDataPackage();
		dataPackage.loadOneDataFromDB();
		
		//1. 如果是单条克隆
		if (!dataPackage.isEmpty(DataSource.DB)) {
			DataPackage target = dataPackage.cloneOneData(DataSource.DB);
			target.saveOneDataToDB(DataSource.New, dataReader, dataWriter);
			target.setResultData(DataSource.New);
			
			dataWriter.setDataPackage(target);
			return;
		}
		
		//2. 如果是多条克隆
		JSONReader reader = dataReader.getReader("id", JType.Array);
		
		if (reader != null) {
			List<String> ids = reader.getStringList();
			List<String> result = new ArrayList<String>();
			
			for (String id: ids) {
				dataPackage.setMasterId(id);
				dataPackage.loadOneDataFromDB();
				
				DataPackage target = dataPackage.cloneOneData(DataSource.DB);
				target.saveOneDataToDB(DataSource.New);
				
				result.add(target.getMasterId());
			}
			
			dataWriter.addValue(result);
			return;
		}
	}
	
	public void processActivateOne(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load id from JSON
		dataPackage.loadDataIdFromRequest();
		
		//2. activate data from persist
		dataPackage.loadHostIdFromDB();
		
		//3. activate data from persist
		DataPackage host = dataPackage.getHost();
		
		if (host == null) {
			host = dataPackage;
		}
		
		host.activateOneData();
		
		//4. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void processFallbackOne(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load id from JSON
		dataPackage.loadDataIdFromRequest();
		
		//2. fallback data from persist
		DataPackage host = dataPackage.getHost();
		
		if (host == null) {
			host = dataPackage;
		}
		
		host.fallbackOneData();
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void processAlter(ActionContext meta) throws Exception {
		String dataName = meta.getDataName();
		DataPackage dataPackage = meta.getDataPackage();
		//1. load id from JSON
		dataPackage.loadDataFromRequest();
		dataPackage.loadFilterPageOrderByFromJSON();
		
		Entity entity = dataPackage.getItemEntity(dataName, DataSource.Request);
		Filter filter = dataPackage.getFilter();
		DataObject dataObject = dataPackage.getDataObject(dataName);
		
		//2. udpate data from persist
		dataObject.updateByEntity(entity, filter);
		
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	public void processDeleteOne(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load id from JSON
		dataPackage.loadDataIdFromRequest();
		
		//2. delete data from persist
		dataPackage.deleteOneDataFromDB();
		
		//3. set data to letter
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.setDataPackage(dataPackage);
	}
	
	private void lockRecord(ActionContext meta) throws Exception {
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load id from JSON
		dataPackage.loadDataIdFromRequest();
		
		//2. delete data from persist
		dataPackage.lockMasterRecord();
	}

	public void processTotalCnt(ActionContext meta) throws Exception {
		DataReader dataReader = meta.getDataReader();
		DataPackage dataPackage = meta.getDataPackage();
		
		//1. load filter page order from JSON
		dataPackage.loadFilterFromJSON();
		
		//2. load data package from persist
		String dataName = dataReader.getDecodeString("dataName", "");
		if (Util.isEmpty(dataName)) {
			logger.error("dataName为空，无法执行processTotalCnt");
			return;
		}
		
		DataObject dataObject = dataPackage.getDataObject(dataName);
		Filter filter = dataPackage.filter;
		int count = dataObject.getCount(filter, dataReader.getUser());
		
		//3. set data 
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.addValue(count);
	}
	
	private void processSummary(ActionContext meta) throws Exception {
		DataReader dataReader = meta.getDataReader();
		DataPackage dataPackage = meta.getDataPackage();
		
		List<String> fields = dataReader.getStringList("sum");
		SummaryFields sum = SummaryFields.getInstance(fields);
		
		//1. load filter page order from JSON
		dataPackage.loadFilterFromJSON();
		dataPackage.loadUserLineFilter();
		
		//2. load data package from persist
		String dataName = dataReader.getDecodeString("dataName", "");
		if (Util.isEmpty(dataName)) {
			logger.error("dataName为空，无法执行processSummary");
			return;
		}
		
		DataObject dataObject = dataPackage.getDataObject(dataName);
		Filter filter = dataPackage.filter;
		Entity entity = dataObject.getSummary(sum.getValue(), filter, dataReader.getUser());
		
		//3. set data 
		DataWriter dataWriter = meta.getDataWriter();
		dataWriter.addValue(entity);		
	}

	private void writeBackMasterId(DataReader dataReader, String masterId) throws Exception {
		Domain domain = dataReader.getDomain();
		
		if (domain == null) {
			return;
		}
		
		if (domain.isEmptyId()) {
			domain.setId(masterId);
		}
	}

	@Override
	public void test(ActionContext context, String method) throws Exception {
	}

}