jkyjckyjxxblh.java

以前做的一个j2ee的项目

            //构造一行的所有预警事件记录列表(List版本)
//            found_flag = false; //reset
            while (p_yjsj < jkyjsjList.size()) {
                jkyjsjDAO = (JKYJjkyjsjDAO) jkyjsjList.get(p_yjsj);
//                LogWritter.sysDebug("p_yjsj=" + p_yjsj + ",jkyjsjDAO.nsrnbm=" + jkyjsjDAO.getNsrnbm() + ",jl_xh=" + jkyjsjDAO.getJl_xh()); //for debug
                if (jkyjsjDAO.getNsrnbm().equals(nsrnbm)) {
                    zb_dm = jkyjsjDAO.getZb_dm();
                    colIdx = findColIdxByZbdm(zb_dm, headerList);
                    if (colIdx < 0) { //找不到相应的指标列
                        p_yjsj++; //指针移到下一个记录
                        continue;
                    }
                    yjjlVO = (JKYJyjjlVO) yjzbData.get(colIdx); //取出要修改的记录
                    yjlbVO.setHasYjjl(true); //标记为有预警记录

                    //仅存放第一条记录的记录序号、发生时间、任务编号、调用任务管理页面名
                    if (yjjlVO.getJl_xh() == null) {
                        yjjlVO.setJl_xh(jkyjsjDAO.getJl_xh());
                        yjjlVO.setFs_sj(jkyjsjDAO.getFs_sj());
                        yjjlVO.setRw_xh(jkyjsjDAO.getRw_xh());
                        yjjlVO.setOp_jsp(jkyjsjDAO.getOp_jsp());
                    }
                    yjjlVO.setZb_dm(zb_dm);
                    if (yjjlVO.getZtbh() == null) {
                        yjjlVO.setZtbh(jkyjsjDAO.getZtbh());
                    } else {
                        yjjlVO.setZtbh(yjjlVO.getZtbh() + "\n" +
                                       jkyjsjDAO.getZtbh());
                    }
                    if (yjjlVO.getZt_mc() == null) {
                        yjjlVO.setZt_mc(jkyjsjDAO.getZt_mc());
                    } else {
                        yjjlVO.setZt_mc(yjjlVO.getZt_mc() + "\n" +
                                        jkyjsjDAO.getZt_mc());
                    }
                    //在预警和提示同时存在时，按预警来存放状态类型、提示颜色、提示图标名称
                    if (yjjlVO.getZt_lx() == null ||
                        yjjlVO.getZt_lx().equals("02")) {
                        yjjlVO.setZt_lx(jkyjsjDAO.getZt_lx());
                        yjjlVO.setTsys(jkyjsjDAO.getTsys());
                        yjjlVO.setTstb_mc(jkyjsjDAO.getTstb_mc());
                    }
                    if (yjjlVO.getZtms() == null) {
                        yjjlVO.setZtms(jkyjsjDAO.getZtms());
                    } else {
                        yjjlVO.setZtms(yjjlVO.getZtms() + "\n" +
                                       jkyjsjDAO.getZtms());
                    }
                    if (yjjlVO.getXxms() == null) {
                        yjjlVO.setXxms(jkyjsjDAO.getXxms());
                    } else {
                        yjjlVO.setXxms(yjjlVO.getXxms() + "\n" +
                                       jkyjsjDAO.getXxms());
                    }
                    //转换触发源代码为名称，暂时为硬编码
                    if (jkyjsjDAO.getCfy_dm().equals("01")) {
                        cfy_mc = "代理程序生成";
                    } else if (jkyjsjDAO.getCfy_dm().equals("02")) {
                        cfy_mc = "纳税评估生成";
                    } else if (jkyjsjDAO.getCfy_dm().equals("03")) {
                        cfy_mc = "管理员平台生成";
                    } else {
                        cfy_mc = "其他";
                    }
                    if (yjjlVO.getCfy_mc() == null) {
                        yjjlVO.setCfy_mc(cfy_mc);
                    } else {
                        yjjlVO.setCfy_mc(yjjlVO.getCfy_mc() + "\n" + cfy_mc);
                    }
                    if (yjjlVO.getTs_bj() == null) {
                        yjjlVO.setTs_bj(jkyjsjDAO.getTs_bj());
                    } else {
                        yjjlVO.setTs_bj(yjjlVO.getTs_bj() + ";  " +
                                        jkyjsjDAO.getTs_bj());
                    }

                    yjzbData.set(colIdx, yjjlVO); //把修改后的数据存回去
//                    found_flag = true; //已找到监控预警数据
                } else {
//                    if (found_flag) break; //已找到需填入的监控预警数据，跳出while循环
                        break;
                }
                p_yjsj++; //指针移到下一个记录
            }
            yjlbVO.setYjzbData(yjzbData);

//预警指标和异常记录分别存放版本，适用于一个指标可对应多条预警记录且预警记录不合并的做法，暂时屏蔽（zyh modify at 2005.8.15)
//            //构造一行的预警指标数据
//            yjzbData = new HashMap();
//            ////初始化所有指标值为"0"
//            for (int j = 0; j < zbxxList.size(); j++) {
//                yjzbData.put(new StringBuffer("col").append(j + 1).toString(),
//                             "0");
//            }
//            ////把有数据的指标填入相应的列
//            while (p_zbsj < zbsjList.size()) {
//                zbsjDAO = (ZBGLzbsjDAO) zbsjList.get(p_zbsj);
//                if (zbsjDAO.getNsrnbm().equals(nsrnbm)) {
//                    zb_dm = zbsjDAO.getZb_dm();
//                    colName = findColNameByZbdm(zb_dm, headerMap);
//                    if (colName != null) {
//                        yjzbData.put(colName, zbsjDAO.getZbz());
//                    }
//                } else {
//                    break; //跳出while循环
//                }
//                p_zbsj++; //指针移到下一个记录
//            }
//            yjlbVO.setYjzbData(yjzbData);
//            //构造一行的所有预警事件记录列表(List版本)
//            yjjlList = new ArrayList();
//            //LogWritter.sysDebug("start building 预警记录列表 " + (i + 1) + "......"); //for debug
//            while (p_yjsj < jkyjsjList.size()) {
//                jkyjsjDAO = (JKYJjkyjsjDAO) jkyjsjList.get(p_yjsj);
//                //LogWritter.sysDebug("DAO.nsrnbm=" + jkyjsjDAO.getNsrnbm() + ", nsrnbm=" + nsrnbm);
//                if (jkyjsjDAO.getNsrnbm().equals(nsrnbm)) {
//                    //LogWritter.sysDebug("go into if statement now.....");
//                    yjjlVO = new JKYJyjjlVO();
//                    yjjlVO.setJl_xh(jkyjsjDAO.getJl_xh());
//                    yjjlVO.setZb_dm(jkyjsjDAO.getZb_dm());
//                    yjjlVO.setColName(findColNameByZbdm(yjjlVO.getZb_dm(),
//                            headerMap));
//                    yjjlVO.setZtbh(jkyjsjDAO.getZtbh());
//                    yjjlVO.setZt_mc(jkyjsjDAO.getZt_mc());
//                    yjjlVO.setZt_lx(jkyjsjDAO.getZt_lx());
//                    yjjlVO.setZtms(jkyjsjDAO.getZtms());
//                    yjjlVO.setTsys(jkyjsjDAO.getTsys());
//                    yjjlVO.setTstb_mc(jkyjsjDAO.getTstb_mc());
//                    yjjlVO.setXxms(jkyjsjDAO.getXxms());
//                    yjjlVO.setFs_sj(jkyjsjDAO.getFs_sj());
//                    //转换触发源代码为名称，暂时为硬编码
//                    if (jkyjsjDAO.getCfy_dm().equals("01")) {
//                        yjjlVO.setCfy_mc("代理程序生成");
//                    } else if (jkyjsjDAO.getCfy_dm().equals("02")) {
//                        yjjlVO.setCfy_mc("纳税评估生成");
//                    }
//                    yjjlVO.setTs_bj(jkyjsjDAO.getTs_bj());
//                    yjjlVO.setRw_xh(jkyjsjDAO.getRw_xh());
//
//                    yjjlList.add(yjjlVO);
//                } else {
//                    break; //跳出while循环
//                }
//                p_yjsj++; //指针移到下一个记录
//            }
////            LogWritter.sysDebug("yjjlList.size=" + yjjlList.size() +
////                                ", p_yjsj=" + p_yjsj + ",jkyjsjList.size=" +
////                                jkyjsjList.size()); //for debug
//            yjlbVO.setYjjlList(yjjlList);
            //加一个纳税人的信息
            yjlbList.add(yjlbVO);
        }

        //使用构造器将构造好的数据封装到ResponseEvent里
        JKYJckyjxxResEvent res = new JKYJckyjxxResEvent();
        res.setYjlbList(yjlbList);
        res.setYjlbHeader(headerList);
        res.setRepCode("0");

        return res;

    }

    private ResponseEvent getYjlbByQuers(JKYJckyjxxReqEvent req) {
//        String sessionID = req.getSessionID(); //获取用户ID
//        String channelType = req.getChannelType(); //获取请求来源

       ArrayList jkyjsjList = null;
       ArrayList zbsjList = null;
       ArrayList zbxxList = null;
       ArrayList tsxxList = null;

       //LogWritter.sysDebug("test get userID=" + (String)WebUtil.eval("#{user.userID}")); //just for test
       BigDecimal fl_xh = req.getFl_xh();
       String st_dm = req.getSt_dm();
       //与DAO交互，得到监控预警事件的List和指标数据的List
       JKYJjkyjsjDAO jkyjsjDAO = new JKYJjkyjsjDAO();
       ArrayList nsrflxxList = jkyjsjDAO.findAllNsrByFlxhQuery(fl_xh,req.getCxtj()); //找到某个分类下的纳税人列表
       String nsrfl="";

           for(int i=0;i<nsrflxxList.size();i++){
           if(i==0){
               nsrfl=((FLGLnsrflxxVO) nsrflxxList.get(i)).getNsrnbm().toString();
           }
           else{
            nsrfl=nsrfl+","+((FLGLnsrflxxVO) nsrflxxList.get(i)).getNsrnbm().toString();
           }
           }
           if(nsrfl==null || "".equals(nsrfl)){
           nsrfl="0";
           }

       jkyjsjList = jkyjsjDAO.findAllByFlxhStdmQuery(fl_xh, st_dm,nsrfl);
       ZBGLzbsjDAO zbsjDAO = new ZBGLzbsjDAO();
       zbsjList = zbsjDAO.findAllByFlxhStdmQuery(fl_xh, st_dm,nsrfl);
       zbxxList = zbsjDAO.findZbxxByStdm(st_dm);
       tsxxList = zbsjDAO.findTsxxByFlxhStdmQuery(fl_xh, st_dm,nsrfl);

       JKYJtsxxVO tsxxVO = null;
       //转换监控台预警指标列头
       ArrayList headerList = new ArrayList();
       JKYJzbxxVO zbxxVO = null;
       for (int i = 0; i < zbxxList.size(); i++) {
           zbxxVO = (JKYJzbxxVO) zbxxList.get(i);
           headerList.add(zbxxVO);
       }
       //转换监控台预警指标数据列表
       //必须之前已按照纳税人内部码、指标代码等对预警事件、指标数据等进行了排序
       ArrayList yjlbList = new ArrayList(); //按纳税人来排列的预警列表数据
       FLGLnsrflxxVO nsrflxxVO = null;
       JKYJyjlbVO yjlbVO = null; //预警列表VO
       JKYJyjjlVO yjjlVO = null; //预警记录VO
       ArrayList yjzbData = null; //预警指标数据Map

       int p_zbsj = 0; //用于遍历预警指标数据的指针