htdltjrwmbean.java

以前做的一个j2ee的项目

//            flag = -1; //任务名称为空
//            System.out.println("任务名称为空");
//        }
//        if ((this.fz == null) || (EMPTY_STRING.equals(fz))) {
//            flag = -1; //分组名称为空
//            System.out.println("分组名称为空");
//        }
//        if ((this.blh_mc == null) || (EMPTY_STRING.equals(blh_mc))) {
//            flag = -1; //blh为空
//            System.out.println("blh为空");
//        }
//        if ((this.fz==null)||(EMPTY_STRING.equals(fz))) flag=-1;  //分组名称为空

        if (flag == -1) { //输入检查不通过
            StringBuffer output = new StringBuffer();
            output.append(
                    "<script language=\"javascript\" type=\"text/javascript\">");
            output.append("alert(\"XXHTDL-020:输入的内容不完整，请检查输入，包括任务名称、所属分组和执行功能！\")");
            output.append("</script>");
            this.addTips = new String(output);
        } else {
            //构造新加任务的相关参数
            HTDLybsdsrwVO newRwVO = new HTDLybsdsrwVO();
            newRwVO.setBlh_mc(this.getBlh_mc()); //blh
            newRwVO.setRw_mc(this.getRw_mc().trim()); //任务名称
            newRwVO.setZb(this.getFz().trim()); //所属分组
            newRwVO.setZxyxj(this.getZxyxj()); //执行优先级
            newRwVO.setZxpl(this.getZxpl()); //执行频率
            newRwVO.setZlsj(this.getFormatZlsj()); //增量时间
            newRwVO.setDq_zt("0"); //当前状态缺省为“调度中”
            newRwVO.setCsl(this.csl.trim()); //参数值
//            newRwVO.setLrry_dm("2440100");
            String userID = (String) WebUtil.eval("#{user.userID}");
            newRwVO.setLrry_dm(userID);

//构造请求
            HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
            req.setDealMethod("addDdrw");
            req.setHtdlYbsdsrwVO(newRwVO);

//调用后台程序
            try {
//            SsglyDelegateRemote service = new SsglyDelegateRemote();
                ISsglyService service = new SsglyDelegate();
                ResponseEvent resp = service.invokeTask(req);
//处理结果
                HTDLglddrwResEvent getDsrwResp = (HTDLglddrwResEvent) resp;
                if (getDsrwResp.getRepCode().equals("0")) { //添加成功
                    StringBuffer output = new StringBuffer();
                    output.append(
                            "<script language=\"javascript\" type=\"text/javascript\">");
                    output.append("alert(\"XXHTDL-021:任务添加成功！\")");
                    output.append("</script>");
                    this.addTips = new String(output);
                    getTotalPage();
//                    ybsrwVOList = (ArrayList) getSplitData();  //version 2
//                    objectList = Collections.synchronizedList(new ArrayList());
                    objectList = null;
                    ybsrwVOList = (ArrayList) getContentList(); //version 3
//                    totalPage = getMyTotalPage(); //重新计算totalPage
                }
            } catch (Exception e) {
                LogWritter.sysDebug(e.toString());
                throw e;
            }

        }
        return "success";
    }

    public String updateDqzt() throws Exception {
        //获取所有已选择的任务的任务序号
        ArrayList tmpList = new ArrayList();
        if (ybsrwVOList != null) {
            for (int i = 0; i < ybsrwVOList.size(); i++) {
                HTDLybsdsrwVO tmpVO = (HTDLybsdsrwVO) ybsrwVOList.get(i);
                if (tmpVO.isSel()) {
//                    LogWritter.sysDebug(tmpVO.getRw_xh());
                    tmpList.add(tmpVO.getRw_xh());
                }
            }
        }
        if (tmpList.size() != 0) {
//与后台交互，进行操作
            HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
            req.setDealMethod("modRwzt");
            req.setListRwxh(tmpList);
            try {
                ISsglyService service = new SsglyDelegate();
                ResponseEvent resp = service.invokeTask(req);
                HTDLglddrwResEvent getDsrwResp = (HTDLglddrwResEvent) resp;
                if (getDsrwResp.getRepCode().equals("0")) { //更新状态成功
                    StringBuffer output = new StringBuffer();
                    output.append(
                            "<script language=\"javascript\" type=\"text/javascript\">");
                    output.append("alert(\"XXHTDL-022:更改当前状态成功！\")");
                    output.append("</script>");
                    this.updateTips = new String(output);
//                    ybsrwVOList = (ArrayList) getSplitData();
//                    objectList = Collections.synchronizedList(new ArrayList());
                    objectList = null;
                    ybsrwVOList = (ArrayList) getContentList();
//                    LogWritter.sysDebug("已部署任务记录数in updateDqzt " +
//                                        ybsrwVOList.size());
                }
            } catch (Exception e) {
                LogWritter.sysDebug(e.toString());
                throw e;
            }
        }
        return "success";
    }

//删除用户选择的任务
    public String deleteRwlist() throws Exception {
        //获取所有已选择的任务的任务序号
        ArrayList tmpList = new ArrayList();
        if (ybsrwVOList != null) {
            for (int i = 0; i < ybsrwVOList.size(); i++) {
                HTDLybsdsrwVO tmpVO = (HTDLybsdsrwVO) ybsrwVOList.get(i);
                if (tmpVO.isSel()) {
                    tmpList.add(tmpVO.getRw_xh());
                }
            }
        }
        if ((tmpList!=null) && (tmpList.size() != 0)) {
//与后台交互，进行删除操作
            HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
            req.setDealMethod("delDdrw");
            req.setListRwxh(tmpList);
            try {
                ISsglyService service = new SsglyDelegate();
                ResponseEvent 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.delTips = new String(output);
//                ybsrwVOList = (ArrayList) getSplitData();
                getTotalPage();
                objectList = null;
                ybsrwVOList = (ArrayList) getContentList();
//                totalPage = getMyTotalPage(); //重新计算totalPage
            } catch (Exception e) {
                LogWritter.sysDebug(e.toString());
                throw e;
            }
        }

//        this.totalPage = 0; //重新计算totalPage
        return "success";
    }


//验证页面选择的blh是否合法
    public void validatorBLH(FacesContext context, UIComponent component,
                             Object value) throws ValidatorException {
        /*       if ((context == null) || (component == null)) {
                   throw new NullPointerException();
               } */
        System.out.println("****************in validator:*****************");
        System.out.println("****************value:*****************" + value);
        if ((value == null) || (EMPTY_STRING.equals(value))) {
            throw new ValidatorException(new FacesMessage("请选择要执行的功能"));
        }
    }


    public String removeSel() throws Exception {
        if (ybsrwVOList != null) {
            for (int i = 0; i < ybsrwVOList.size(); i++) {
                HTDLybsdsrwVO tmpVO = (HTDLybsdsrwVO) ybsrwVOList.get(i);
                if (tmpVO.isSel()) {
                    ((HTDLybsdsrwVO) ybsrwVOList.get(i)).setSel(false);
                }
            }
        }
        return null;
    }

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

//生成每个blh对应的参数提示信息
    public String getRemarkArray() throws Exception {
        StringBuffer sb = new StringBuffer();

        //根据remarkList的值构造javaScript的数组
        sb.append("var remarkArray=new Array();\n");
        if (remarkList != null) {
            for (int i = 0; i < remarkList.size(); i++) {
                HTDLdsrwlbVO dsrwVO = (HTDLdsrwlbVO) remarkList.get(i);
                sb.append("remarkArray['");
                sb.append(dsrwVO.getBlh_mc());
                sb.append("']='");
                if (dsrwVO.getRemark() != null) {
                    sb.append(dsrwVO.getRemark());
                }
                sb.append("';\n");
            }
        }
        return sb.toString();
    }

//修改指定的任务的属性
    public String editYbsrw() throws Exception {
        //构造新加任务的相关参数
        String xh = WebUtil.getParameterFromContextMap("update:selectedRw");
//        System.out.println("=============rw_xh:" + xh);
        if ((xh != null) && (!"".equals(xh))) {
            HTDLybsdsrwVO newRwVO = new HTDLybsdsrwVO();
            newRwVO.setRw_xh(xh);
            newRwVO.setBlh_mc(this.getBlh_mc()); //blh
            newRwVO.setRw_mc(this.getRw_mc().trim()); //任务名称
            newRwVO.setZb(this.getFz().trim()); //所属分组
            newRwVO.setZxyxj(this.getZxyxj()); //执行优先级
            newRwVO.setZxpl(this.getZxpl()); //执行频率
            newRwVO.setZlsj(this.getFormatZlsj()); //增量时间
            newRwVO.setCsl(this.csl.trim()); //参数值

            //构造请求
            HTDLglddrwReqEvent req = new HTDLglddrwReqEvent();
            req.setDealMethod("editDdrw");
            req.setHtdlYbsdsrwVO(newRwVO);

            //调用后台程序
            try {
                ISsglyService service = new SsglyDelegate();
                ResponseEvent resp = service.invokeTask(req);
//处理结果
                HTDLglddrwResEvent getDsrwResp = (HTDLglddrwResEvent) resp;
                if (getDsrwResp.getRepCode().equals("0")) { //添加成功
                    StringBuffer output = new StringBuffer();
                    output.append(
                            "<script language=\"javascript\" type=\"text/javascript\">");
                    output.append("alert(\"XXHTDL-023:任务修改成功！\")");
                    output.append("</script>");
                    this.addTips = new String(output);
                    getTotalPage();
//                    ybsrwVOList = (ArrayList) getSplitData();  //version 2
//                    objectList = Collections.synchronizedList(new ArrayList());
                    objectList = null;
                    ybsrwVOList = (ArrayList) getContentList(); //version 3
//                    totalPage = getMyTotalPage(); //重新计算totalPage
                }
                this.selectedRw = "";
                resetData();
            } catch (Exception e) {
                LogWritter.sysDebug(e.toString());
                throw e;
            }

        }

        return "success";
    }

    private void resetData(){
        this.rw_mc=null;
        this.zxyxj = 0;
        this.csl = null;
        this.blh_mc = null;
        this.fz = null;
        this.zxpl = null;
    }

//测试：启动定时自动调度进程

    public static void main(String args[]) {
        System.out.println("before start!");
        try {
            HTDLtjrwMBean tjrw = new HTDLtjrwMBean();
            System.out.println("before start!");
            //           tjrw.startScheduler();
//            ArrayList blhList = tjrw.getBlhList();
//            System.out.println(blhList.size());
//
////            ArrayList ybsrwVOList = tjrw.getYbsrwVOList();
//            System.out.println("before print!");
////            System.out.println("ybsrw:" + ybsrwVOList.size());
////            System.out.println(((HTDLybsdsrwVO) ybsrwVOList.get(1)).getFormatZt());
        } catch (Exception e) {
            LogWritter.sysDebug(e.toString());
        }
    }

}