Page History

package com.fr.schedule.extension.report.result;

import com.fr.schedule.extension.report.ScheduleShowType;
import com.fr.stable.web.Weblet;

import javax.servlet.http.HttpServletRequest;

/**
 * 声明自定义结果类型访问方法的接口.
 *
 * <p>
 * 通过实现该接口自定义结果的访问逻辑，注册进ScheduleResultBox从而自定义结果的访问逻辑
 * </p>
 *
 * Created by Zed on 2018/4/16.
 */
public interface ScheduleResultProvider {

    String getResultSuffix();

    Weblet accessResult(HttpServletRequest req, String path, String fileName, ScheduleShowType showType) throws Exception;
}

<extra-decision>
        <ReportScheduleResultProvider class="your class name"/>
</extra-decision>

package com.fr.schedule.extension.report.result;

...

/**
 * Created by Zed on 2018/03/26.
 * 定时任务报表结果访问
 */
public class ReportletResult extends TaskResult {

    ...

    @Override
    public void accessResult(HttpServletRequest req,
                             HttpServletResponse res,
                             Map<String, Object> param) throws Exception {

        String username = (String) param.get(ScheduleConstants.USERNAME);
        String taskName = (String) param.get(ScheduleConstants.TASK_NAME);
        String resultPath = (String) param.get(ScheduleConstants.TASK_RESULT_PATH);
        String showType = (String) param.get(ScheduleConstants.SHOW_TYPE);
        // 包含有cpr、frr的目录
        String path;
        ...

        String[] files = ResourceIOUtils.list(path);
        req.setAttribute(ScheduleConstants.USERNAME, username);
        req.setAttribute(ScheduleConstants.TASK_NAME, taskName);
        req.setAttribute(ScheduleConstants.SHOW_TYPE, showType);
        req.setAttribute(ScheduleConstants.TASK_RESULT_PATH, path);
        addTaskPara(req, path);

        WebletDealWith.dealWithWeblet(req, res, this.getResultFile(req, files, path, showType));
    }

    private Weblet getResultFile(HttpServletRequest req, String[] files, String path, String showType) throws Exception {
        for (String file : files) {
            ScheduleResultProvider provider = ScheduleResultBox.formSuffix(this.getFileSuffix(file));
            if (provider != null) {
                return provider.accessResult(req, StableUtils.pathJoin(path, file), file, this.getShowType(showType));
            }
        }
        // 没有cpr、frr
        throw new ResultFileNotExistException("Fine-Schedule_Result_File_Not_Exist");
    }

    ...
}