/*
    * Copyright 2004-2006 the Seasar Foundation and the Others.
    *
    * Licensed under the Apache License, Version 2.0 (the "License");
    * you may not use this file except in compliance with the License.
    * You may obtain a copy of the License at
    *
    *     http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
   * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, 
   * either express or implied. See the License for the specific language
   * governing permissions and limitations under the License.
   */
  package org.seasar.tuigwaa.controller;
  
  import java.util.ArrayList;
  import java.util.HashMap;
  import java.util.Iterator;
  import java.util.List;
  import java.util.Map;
  
  import org.apache.struts.validator.ValidatorForm;
  import org.seasar.tuigwaa.cms.ContentsStoreService;
  import org.seasar.tuigwaa.logic.TgwEvent;
  import org.seasar.tuigwaa.logic.TgwFunction;
  import org.seasar.tuigwaa.logic.TgwLogic;
  import org.seasar.tuigwaa.logic.functor.AggregationValuePredicate;
  import org.seasar.tuigwaa.logic.functor.EmailSendProcedure;
  import org.seasar.tuigwaa.logic.functor.PageJumpProcedure;
  import org.seasar.tuigwaa.logic.functor.RowDeleteProcedure;
  import org.seasar.tuigwaa.logic.functor.RowUpdateProcedure;
  import org.seasar.tuigwaa.model.DAOService;
  import org.seasar.tuigwaa.model.ModelService;
  import org.seasar.tuigwaa.model.common.EntityInfo;
  import org.seasar.tuigwaa.model.common.EntityUtils;
  import org.seasar.tuigwaa.model.core.TgwAttribute;
  import org.seasar.tuigwaa.model.core.TgwEntity;
  import org.seasar.tuigwaa.util.functor.TestProcedure;
  import org.seasar.tuigwaa.util.functor.TruePredicate;
  
  import com.isenshi.util.functor.UnaryPredicate;
  import com.isenshi.util.functor.UnaryProcedure;
  
  public class LogicForm extends ValidatorForm{
  
  	private static final long serialVersionUID = 5944162789716916L;
  
  	private static final String PROC_PAGEJUMP = "pageJump";
  
  	private static final String PROC_ROWUPDATE = "rowUpdate";
  
  	private static final String PROC_ROWDELETE = "rowDelete";
  
  	private static final String PROC_EMAILSEND = "mailSend";
  
  	private static final String PREDICATE_ANYTIME = "anytime";
  
  	private static final String PREDICATE_VALUEFUNC = "valueFunc";
  
  	private String siteName;
  
  	private ModelService entityService;
  
  	private ContentsStoreService slideService;
  
  	private DAOService daoService;
  
  	private String name;
  
  	private EventForm event = new EventForm();
  
  	private ProcedureForm procedure = new ProcedureForm();
  
  	private String predicateType = PREDICATE_ANYTIME;
  
  	private String procedureType = PROC_PAGEJUMP;
  
  	private ValueFuncPredicateForm valueFuncPredicate = new ValueFuncPredicateForm();
  
  	private boolean saved = false;
  
  	public LogicForm(String siteName, ModelService entityService,
  			ContentsStoreService slideService, DAOService daoService) {
  		this(siteName, null, entityService, slideService, daoService);
  	}
  
  	public LogicForm(String siteName, TgwLogic logic,
  			ModelService entityService, ContentsStoreService slideService,
  			DAOService daoService) {
  
  		this.siteName = siteName;
  		this.entityService = entityService;
  		this.slideService = slideService;
  		this.daoService = daoService;
  
  		if (logic != null) {
  			init(logic);
 		}
 	}
 
 	public boolean isSaved() {
 		return saved;
 	}
 
 	private void init(TgwLogic logic) {
 		this.saved = true;
 		this.name = logic.getName();
 
 		TgwEvent tgwevent = logic.getEvent();
 		TgwFunction function = logic.getFunction();
 
 		event.setEvent(tgwevent);
 
 		UnaryPredicate predi = function.getPredicate();
 		if (predi instanceof TruePredicate) {
 			predicateType = PREDICATE_ANYTIME;
 		} else if (predi instanceof AggregationValuePredicate) {
 			predicateType = PREDICATE_VALUEFUNC;
 			valueFuncPredicate.setPredicate((AggregationValuePredicate) predi);
 		}
 
 		UnaryProcedure proc = function.getProcedure();
 		setProcedure(proc);
 	}
 
 	public List getPageList() {
 		try {
 			return slideService.getRecursivePageList(siteName, "");
 		} catch (Exception e) {
 			e.printStackTrace();
 			return null;
 		}
 	}
 
 	public Iterator getEntityList() {
 		return entityService.getEntityIterator(siteName);
 	}
 
 	public List getUpdateRuleList() {
 		List infoList = entityService.createEntityInfoList(siteName);
 		if (infoList == null) {
 			return null;
 		}
 		List list = new ArrayList();
 		for (Iterator i = infoList.iterator(); i.hasNext();) {
 			EntityInfo info = (EntityInfo) i.next();
 			list.addAll(info.getUpdateRuleList());
 		}
 		return list;
 	}
 
 	public Map getCustomFormMap() {
 		Iterator itr = entityService.getEntityIterator(siteName);
 		if (itr == null) {
 			return null;
 		}
 
 		Map map = new HashMap();
 		while (itr.hasNext()) {
 			TgwEntity entity = (TgwEntity) itr.next();
 			Map customFormMap = daoService.getCustomFormFunctionMap(entity);
 			if (customFormMap != null && customFormMap.size() > 0) {
 				map.put(entity, customFormMap.values());
 			}
 		}
 		return map;
 	}
 
 	public Map getAggregationValueMap() {
 		Iterator itr = entityService.getEntityIterator(siteName);
 		if (itr == null) {
 			return null;
 		}
 		Map map = new HashMap();
 		while (itr.hasNext()) {
 			TgwEntity entity = (TgwEntity) itr.next();
 			Map valueFuncMap = daoService.getValueFunctionMap(entity);
 			if (valueFuncMap != null && valueFuncMap.size() > 0) {
 				map.put(entity, valueFuncMap.values());
 			}
 		}
 		return map;
 	}
 
 	public void setName(String name) {
 		this.name = name;
 	}
 
 	public String getName() {
 		return name;
 	}
 
 	public EventForm getEvent() {
 		return event;
 	}
 
 	public void setEvent(EventForm event) {
 		this.event = event;
 	}
 
 	public String getPredicateType() {
 		return predicateType;
 	}
 
 	public void setPredicateType(String predicateType) {
 		this.predicateType = predicateType;
 	}
 
 	public TgwLogic getLogic() {
 		String name = getName();
 		TgwEvent tevent = getEvent().getEvent();
 
 		UnaryPredicate predicate = createPredicate();
 		UnaryProcedure procedure = createProcedure(tevent);
 		TgwFunction tfunction = new TgwFunction(predicate, procedure);
 
 		TgwLogic tlogic = new TgwLogic(name, tevent, tfunction);
 		return tlogic;
 	}
 
 	private UnaryPredicate createPredicate() {
 		if (getPredicateType().equals(PREDICATE_ANYTIME)) {
 			return TruePredicate.INSTANCE;
 		} else if (getPredicateType().equals(PREDICATE_VALUEFUNC)) {
 			return getValueFuncPredicate().getPredicate();
 		} else {
 			return null;
 		}
 	}
 
 	public void setProcedure(UnaryProcedure proc) {
 		if (proc instanceof PageJumpProcedure) {
 			PageJumpProcedure pageJumpProc = (PageJumpProcedure) proc;
 			procedureType = PROC_PAGEJUMP;
 			procedure.setPageName(pageJumpProc.getPageName());
 		} else if (proc instanceof RowUpdateProcedure) {
 			RowUpdateProcedure rowUpdateProc = (RowUpdateProcedure) proc;
 			procedureType = PROC_ROWUPDATE;
 			procedure.setUpdateRuleName(rowUpdateProc.getEntityName() + "."
 					+ rowUpdateProc.getUpdateDaoName());
 		} else if (proc instanceof RowDeleteProcedure) {
 			RowDeleteProcedure rowDleteProc = (RowDeleteProcedure) proc;
 			procedure.setDeleteEntityName(rowDleteProc.getEntityName());
 			procedureType = PROC_ROWDELETE;
 		} else if (proc instanceof EmailSendProcedure) {
 			EmailSendProcedure emailSendProc = (EmailSendProcedure) proc;
 			procedureType = PROC_EMAILSEND;
 			procedure.setMailPageName(emailSendProc.getPageName());
 			procedure.setMailType(emailSendProc.getType());
 		}
 	}
 
 	public UnaryProcedure createProcedure(TgwEvent tevent) {
 		if (getProcedureType().equals(PROC_PAGEJUMP)) {
 			return new PageJumpProcedure(getProcedure().getPageName());
 		} else if (getProcedureType().equals(PROC_ROWDELETE)) {
 			String entityName = getProcedure().getDeleteEntityName();
 			return new RowDeleteProcedure(entityName);
 		} else if (getProcedureType().equals(PROC_ROWUPDATE)) {
 			String updateRuleName = getProcedure().getUpdateRuleName();
 			String[] array = updateRuleName.split("//.");
 			String entityName = array[0];
 			String daoName = array[1];
 			return new RowUpdateProcedure(entityName, daoName);
 		} else if (getProcedureType().equals(PROC_EMAILSEND)) {
 			String entityName = tevent.getOption();
 			TgwEntity entity = entityService.getEntity(siteName, entityName);
 			if (entity == null) {
 				return null;
 			}
 			String emailField = null;
 			for (Iterator i = entity.getFieldIterator(); i.hasNext();) {
 				TgwAttribute field = (TgwAttribute) i.next();
 				if (EntityUtils.isEmail(field)) {
 					emailField = field.getName();
 				}
 			}
 			return new EmailSendProcedure(emailField, getProcedure()
 					.getMailPageName(), getProcedure().getMailType());
 		} else {
 			return new TestProcedure();
 		}
 	}
 
 	public String getProcedureType() {
 		return procedureType;
 	}
 
 	public void setProcedureType(String procedureType) {
 		this.procedureType = procedureType;
 	}
 
 	public ValueFuncPredicateForm getValueFuncPredicate() {
 		return valueFuncPredicate;
 	}
 
 	public void setValueFuncPredicate(ValueFuncPredicateForm valueFuncPredicate) {
 		this.valueFuncPredicate = valueFuncPredicate;
 	}
 
 	public ProcedureForm getProcedure() {
 		return procedure;
 	}
 
 	public void setProcedure(ProcedureForm procedure) {
 		this.procedure = procedure;
 	}
 
 	public class EventForm {
 
 		private String type = TgwEvent.PAGE_VIEW;
 
 		private String pageName;
 
 		private String afterEntityName;
 
 		private String beforeEntityName;
 
 		private String afterCustomFormName;
 
 		private String beforeCustomFormName;
 
 		public void setType(String type) {
 			this.type = type;
 		}
 
 		public String getType() {
 			return type;
 		}
 
 		public String getAfterEntityName() {
 			return afterEntityName;
 		}
 
 		public void setAfterEntityName(String afterEntityName) {
 			this.afterEntityName = afterEntityName;
 		}
 
 		public String getBeforeEntityName() {
 			return beforeEntityName;
 		}
 
 		public void setBeforeEntityName(String beforeEntityName) {
 			this.beforeEntityName = beforeEntityName;
 		}
 
 		public String getPageName() {
 			return pageName;
 		}
 
 		public void setPageName(String pageName) {
 			this.pageName = pageName;
 		}
 
 		public String getAfterCustomFormName() {
 			return afterCustomFormName;
 		}
 
 		public void setAfterCustomFormName(String afterCustomFormName) {
 			this.afterCustomFormName = afterCustomFormName;
 		}
 
 		public String getBeforeCustomFormName() {
 			return beforeCustomFormName;
 		}
 
 		public void setBeforeCustomFormName(String beforeCustomFormName) {
 			this.beforeCustomFormName = beforeCustomFormName;
 		}
 
 		public void setEvent(TgwEvent event) {
 			setType(event.getType());
 			String option = event.getOption();
 			if (TgwEvent.PAGE_VIEW.equals(getType())) {
 				setPageName(option);
 			} else if (TgwEvent.BEFORE_DATA_SAVE.equals(getType())) {
 				setBeforeEntityName(option);
 			} else if (TgwEvent.AFTER_DATA_SAVE.equals(getType())) {
 				setAfterEntityName(option);
 			} else if (TgwEvent.BEFORE_CUSTOMFORM_SAVE.equals(getType())) {
 				setBeforeCustomFormName(option);
 			} else if (TgwEvent.AFTER_CUSTOMFORM_SAVE.equals(getType())) {
 				setAfterCustomFormName(option);
 			}
 		}
 
 		public TgwEvent getEvent() {
 			String option = null;
 			if (TgwEvent.PAGE_VIEW.equals(getType())) {
 				option = getPageName();
 			} else if (TgwEvent.BEFORE_DATA_SAVE.equals(getType())) {
 				option = getBeforeEntityName();
 			} else if (TgwEvent.AFTER_DATA_SAVE.equals(getType())) {
 				option = getAfterEntityName();
 			} else if (TgwEvent.BEFORE_CUSTOMFORM_SAVE.equals(getType())) {
 				option = getBeforeCustomFormName();
 			} else if (TgwEvent.AFTER_CUSTOMFORM_SAVE.equals(getType())) {
 				option = getAfterCustomFormName();
 			}
 			return new TgwEvent(getType(), option);
 		}
 	}
 
 	public class ValueFuncPredicateForm {
 
 		private String funcName;
 
 		private String condition;
 
 		private Double value;
 
 		public void setFuncName(String funcName) {
 			this.funcName = funcName;
 		}
 
 		public String getFuncName() {
 			return funcName;
 		}
 
 		public void setCondition(String condition) {
 			this.condition = condition;
 		}
 
 		public String getCondition() {
 			return condition;
 		}
 
 		public void setValue(Double value) {
 			this.value = value;
 		}
 
 		public Double getValue() {
 			return value;
 		}
 
 		public UnaryPredicate getPredicate() {
 			String[] array = funcName.split("//.");
 			String entityName = array[0];
 			String aggFuncName = array[1];
 
 			return new AggregationValuePredicate(siteName, entityName,
 					aggFuncName, value, condition);
 		}
 
 		public void setPredicate(AggregationValuePredicate aggPredi) {
 			this.funcName = aggPredi.getEntityName() + "."
 					+ aggPredi.getAggregationFuncName();
 			this.value = aggPredi.getValue();
 			this.condition = aggPredi.getOpcode();
 		}
 	}
 
 	public class ProcedureForm {
 
 		private String pageName;
 
 		private String mailPageName;
 
 		private String mailType;
 		
 		private String updateRuleName;
 
 		private String deleteEntityName;
 
 		public String getPageName() {
 			return pageName;
 		}
 
 		public void setPageName(String pageName) {
 			this.pageName = pageName;
 		}
 
 		public void setMailPageName(String mailPageName) {
 			this.mailPageName = mailPageName;
 		}
 
 		public String getMailPageName() {
 			return mailPageName;
 		}
 
 		public void setUpdateRuleName(String updateRuleName) {
 			this.updateRuleName = updateRuleName;
 		}
 
 		public String getUpdateRuleName() {
 			return updateRuleName;
 		}
 
 		public String getDeleteEntityName() {
 			return deleteEntityName;
 		}
 
 		public void setDeleteEntityName(String deleteEntityName) {
 			this.deleteEntityName = deleteEntityName;
 		}
 		
 		public String getMailType() {
 			return mailType;
 		}
 		
 		public void setMailType(String mailType) {
 			this.mailType = mailType;
 		}
 	}
 }