package com.ql.util.express;

import com.ql.util.express.instruction.OperateDataCacheManager;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import java.util.List;

public class InstructionSetRunner {
    private static final Log log = LogFactory.getLog(InstructionSetRunner.class);

    public static Object executeOuter(ExpressRunner runner, InstructionSet[] sets, ExpressLoader loader,
                                      IExpressContext<String, Object> aContext, List<String> errorList,
                                      boolean isTrace, boolean isCatchException,
                                      Log aLog, boolean isSupportDynamicFieldName) throws Exception {
        try {
            //OperateDataCacheManager.resetCache();
            return execute(runner, sets, loader, aContext, errorList, isTrace, isCatchException, true, aLog, isSupportDynamicFieldName);
        } finally {
            OperateDataCacheManager.resetCache();
        }
    }

    /**
     * 批量执行指令集合，指令集间可以共享 变量和函数
     *
     * @param sets
     * @param aOperatorManager
     * @param aContext
     * @param errorList
     * @param aFunctionCacheMananger
     * @param isTrace
     * @return
     * @throws Exception
     */
    public static Object execute(ExpressRunner runner, InstructionSet[] sets, ExpressLoader loader,
                                 IExpressContext<String, Object> aContext, List<String> errorList,
                                 boolean isTrace, boolean isCatchException,
                                 boolean isReturnLastData, Log aLog, boolean isSupportDynamicFieldName)
            throws Exception {
        InstructionSetContext context = OperateDataCacheManager.fetchInstructionSetContext(
                true, runner, aContext, loader, isSupportDynamicFieldName);
        Object result = execute(sets, context, errorList, isTrace, isCatchException, isReturnLastData, aLog);
        return result;
    }

    public static Object execute(InstructionSet[] sets,
                                 InstructionSetContext context, List<String> errorList, boolean isTrace, boolean isCatchException,
                                 boolean isReturnLastData, Log aLog) throws Exception {
        RunEnvironment environmen = null;
        Object result = null;
        for (int i = 0; i < sets.length; i++) {
            InstructionSet tmpSet = sets[i];
            environmen = OperateDataCacheManager.fetRunEnvironment(tmpSet,
                    (InstructionSetContext) context, isTrace);
            try {
                CallResult tempResult = tmpSet.excute(environmen, context,
                        errorList, i == sets.length - 1, isReturnLastData, aLog);
                if (tempResult.isExit() == true) {
                    result = tempResult.getReturnValue();
                    break;
                }
            } catch (Exception e) {
                if (isCatchException == true) {
                    if (aLog != null) {
                        aLog.error(e.getMessage(), e);
                    } else {
                        log.error(e.getMessage(), e);
                    }
                } else {
                    throw e;
                }
            }
        }
        return result;

    }
}