htdlmanualmbean.java

以前做的一个j2ee的项目

        }
        return "success";
    }

    //停止后台调度
    public String pauseScheduler() throws Exception {
        HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
        req.setDealMethod("stopSchedule"); //
        try {
            ISsglyService service = new SsglyDelegate();
            ResponseEvent resp = service.invokeTask(req);

            HTDLglddrwResEvent res = (HTDLglddrwResEvent) resp;
            this.tips = "alert(\"" + res.getRetMsg() + "\")";
        } catch (Exception e) {
            LogWritter.sysDebug("my Exception:" + e.toString());
            this.tips = "alert(\"" + e.toString() + "\")";
            throw e;
        }
        return "success";
    }

//启动调度
    public String startScheduler() throws Exception {
        HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
        req.setDealMethod("startSchedule"); //
        try {
            ISsglyService service = new SsglyDelegate();
            ResponseEvent resp = service.invokeTask(req);

            HTDLglddrwResEvent res = (HTDLglddrwResEvent) resp;
            this.tips = "alert(\"" + res.getRetMsg() + "\")";
        } catch (Exception e) {
            LogWritter.sysDebug(e.toString());
            this.tips = "alert(\"" + e.toString() + "\")";
            throw e;
        }
        return "success";
    }

    //删除选定的当天任务
    public String delDtrw() throws Exception {
        //获取所有已选择的任务的任务序号
        ArrayList tmpList = new ArrayList();
        if (manualDdrwVOList != null) {
            for (int i = 0; i < manualDdrwVOList.size(); i++) {
                HTDLybsdsrwVO tmpVO = (HTDLybsdsrwVO) manualDdrwVOList.get(i);
                if (tmpVO.isSel()) {
                    tmpList.add(tmpVO.getRw_xh());
                }
            }
        }
        if ((tmpList != null)&&(tmpList.size() != 0)) {
//与后台交互，进行删除操作
            System.out.println(tmpList + "------");
            HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();

            req.setDealMethod("countDtrwbyZt");
            req.setListRwxh(tmpList);
            System.out.println("get-------" + req.getListRwxh());
            ISsglyService service = new SsglyDelegate();
            ResponseEvent resp = service.invokeTask(req);
            HTDLglddrwResEvent res = (HTDLglddrwResEvent) resp;

            int result = ((Integer) res.getDtrwVOList().get(0)).intValue();
            if (result != 0) {
                tips = "alert(\"XXHTDL-019:选定的任务中，还有任务没有执行完毕，不允许执行删除操作！\")";
            } else {
                req.setDealMethod("deleteDtrw");
                req.setListRwxh(tmpList);
                try {
                    resp = service.invokeTask(req);
                    HTDLglddrwResEvent getDsrwResp = (HTDLglddrwResEvent) resp;
                    StringBuffer output = new StringBuffer();
//                    output.append(
//                            "<script language=\"javascript\" type=\"text/javascript\">");
                    output.append("alert(\"");
                    output.append(getDsrwResp.getRetMsg());
                    output.append("\")");
//                    output.append("</script>");
                    this.tips = new String(output);
//                ybsrwVOList = (ArrayList) getSplitData();
                    getTotalPage();
//                    objectList = Collections.synchronizedList(new ArrayList());
                    objectList = null;
                    manualDdrwVOList = (ArrayList) getContentList();
                } catch (Exception e) {
                    this.tips = e.toString();
                    LogWritter.sysDebug(e.toString());
                    throw e;
                }
            }
        }
        return "success";
    }

    public String executeRw() throws Exception {
        String t2 = WebUtil.getParameterFromContextMap("manual:start_time");
//        System.out.println("+++++start_time:"+t2+"+++++++");

        SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm");
        if (t2==null) t2="0000-00-00 00:00";
        Date start = df.parse(t2);
//        System.out.println("+++++start:"+start+"+++++++");

        HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
        req.setDealMethod("executeRw");
        req.setStart_time(start);
        HTDLybsdsrwVO ybsdsrwVO = new HTDLybsdsrwVO();
        ybsdsrwVO.setBlh_mc(blh);
        ybsdsrwVO.setCsl(csl);
        ybsdsrwVO.setRw_xh(rw_xh);
        ybsdsrwVO.setRw_mc(rw_mc);
//        ybsdsrwVO.setLrry_dm(lrry_dm);
        req.setHtdlYbsdsrwVO(ybsdsrwVO);
//        req.setRw_xh(rw_xh);
//        req.setCsl(csl);
//        req.setBlh(blh);
        this.rw_xh = "";
        this.blh = "";
        this.rw_mc = "";
        this.csl = "";
        try {
            ISsglyService service = new SsglyDelegate();
            ResponseEvent resp = service.invokeTask(req);

            Calendar currentDate = Calendar.getInstance();
            //SimpleDateFormat(dateFormat[0]).format(date.getTime());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String sb = sdf.format(currentDate.getTime());
            StringBuffer output = new StringBuffer();
            output.append("alert(\"XXHTDL-016:任务已经提交，执行时间为");
            output.append(sb);
            output.append("。执行完毕之后可在查看情况窗口查看执行结果！");
            output.append("\")");
            this.tips = new String(output);
//            System.out.println(tips);

//            this.tips=    alert("XXHTDL-016:任务已经提交，执行时间为"+document.all('DS_start_date').value+"。\n执行完毕之后可在查看情况窗口查看执行结果！");
            //重新读数据库表
//            objectList = Collections.synchronizedList(new ArrayList());
            objectList = null;
            manualDdrwVOList = (ArrayList)this.getContentList();
        } catch (Exception e) {
            throw e;
        }
        return null;
    }

//重置任务的状态为“空闲中”
    public String resetRwZt() throws Exception {
        HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
        req.setDealMethod("resetRwZt");

        req.setRw_xh(rw_xh);
        this.rw_xh = "";
        this.blh = "";
        this.rw_mc = "";
        this.csl = "";
        try {
            ISsglyService service = new SsglyDelegate();
            service.invokeTask(req);
            //重新读数据库表
//            objectList = Collections.synchronizedList(new ArrayList());
            objectList = null;
            manualDdrwVOList = (ArrayList)this.getContentList();
        } catch (Exception e) {
            throw e;
        }
        return null;
    }

    private HashMap getCondition() throws Exception {
//        String input = searchBLH;
        HashMap para = new HashMap();
        try {
//            String selected = WebUtil.getParameterFromContextMap("update:searchBLH");
//            if (("0".equals(selected)) || (EMPTY_STRING.equals(selected)) || (selected==null)) {
//                input = null;
//            } else {
//                input.put("blh_mc",new String(selected));
//            }
            keyWords = WebUtil.getParameterFromContextMap("manual:keyword");
            if ((keyWords != null) && (!EMPTY_STRING.equals(keyWords))) {
                String input = keyWords.trim();

                if ("人工调度".equals(input)) {
                    para.put("zxpl", new String("6"));
                }
                if ("每天".equals(input)) {
                    para.put("zxpl", new String("1"));
                }
                if ("调度中".equals(input)) {
                    para.put("dq_zt", new String("0"));
                }
                if ("暂停调度".equals(input)) {
                    para.put("dq_zt", new String("1"));
                }
                if ("执行中".equals(input)) {
                    para.put("dq_zt", new String("3"));
                }
                para.put("rw_mc", new String(input));
                para.put("blh_mc", new String(input));
                para.put("zb", new String(input));
                para.put("rw_xh", new String(input));
            }

        } catch (Exception e) {
            throw new Exception("YCHTDL02002:MBean中获取查询条件时异常\u2014\u2014" +
                                e.getMessage());
        }
        return para;
    }

//获得任务代码表中的任务的参数提示信息
    private String getRemarkList() throws Exception {
        StringBuffer sb = new StringBuffer();

        //根据dsrwVOList的值构造javaScript的数组
        sb.append("var remarkArray=new Array();\n");

        HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
        req.setDealMethod("getDsrwlb");
        try {
            ISsglyService service = new SsglyDelegate();
            ResponseEvent resp = service.invokeTask(req);

            HTDLglddrwResEvent getDsrwResp = (HTDLglddrwResEvent) resp;
//            System.out.println("++++++++++in getRemarkArray+++++++");
            ArrayList dsrwVOList = getDsrwResp.getDsrwlbVOList();
            if (dsrwVOList != null ) {
                for (int i = 0; i < dsrwVOList.size(); i++) {
                    HTDLdsrwlbVO dsrwVO = (HTDLdsrwlbVO) dsrwVOList.get(i);
                    sb.append("remarkArray['");
                    sb.append(dsrwVO.getBlh_mc());
                    sb.append("']='");
                    if (dsrwVO.getRemark() != null) {
                        sb.append(dsrwVO.getRemark());
                    }
                    sb.append("';\n");
                }
            }
        } catch (Exception e) {
            throw new Exception(e.getMessage());
        }
        return sb.toString();
    }

    public void resetData() throws Exception {
        this.rw_xh = null;
        this.rw_mc = null;
        this.blh = null;
        this.csl = null;
    }

    public String searchManualDdrw() throws Exception {
//        System.out.println("+++++++++in search++++++++");
        refreshObjectList(1); //重新
        return null;
    }

}