sjwhcjsjblh.java

以前做的一个j2ee的项目

            resEvent.setRepCode("-1");
            throw new TaxBaseBizException("YCSJWH01030:强制更新指标数据异常！");
        }
        return resEvent;
    }

//读取采集指标
    private List getZbList(String st_dm) {
        SJWHcjsjDAO cjsjdao = new SJWHcjsjDAO();
        List zbList = new ArrayList();
        try {
            zbList = cjsjdao.findZbList(st_dm);
        } catch (SQLException e) {
            throw new TaxBaseBizException("YCSJWH01007：读取所有采集指标异常!");
        } finally {
            return zbList;
        }
    }

//根据代码表名称读取指标的值和代码列表
    private List getZlb(SJWHcjzbVO cjzb) {
        SJWHcjsjDAO cjsjdao = new SJWHcjsjDAO();
        List zlb = new ArrayList();
        try {
            zlb = cjsjdao.getZlb(cjzb);
        } catch (SQLException e) {
            throw new TaxBaseBizException("YCSJWH01008:读取指标代码标异常！");
        } finally {
            return zlb;
        }
    }


    /**
     * 获取采集指标列表
     * @throws TaxBaseBizException
     * @param req SJWHcjsjReqEvent 传入视图代码"FHCJ"
     * @return ResponseEvent       返回采集指标列表，包括指标代码和指标名称，以及指标可选的值列表
     */
    private ResponseEvent getCjzb(SJWHcjsjReqEvent req) throws
            TaxBaseBizException {

        String st_dm = req.getSt_dm();
        List zbList = getZbList(st_dm);
        StringBuffer sb = new StringBuffer();
        HashMap zbhm = new HashMap();
        HashMap zlbhm = new HashMap();
        for (int count = 0; count < zbList.size(); count++) {
            SJWHcjzbVO cjzb = new SJWHcjzbVO();
            cjzb = (SJWHcjzbVO) zbList.get(count);
            sb.append("指标代码: ")
                    .append(cjzb.getZb_dm())
                    .append("------指标名称:")
                    .append(cjzb.getMc())
                    .append("\r\n");
            zbhm.put(cjzb.getZb_dm(), cjzb.getMc());
            if (cjzb.getDmb_mc() != null) {
                List zlb = getZlb(cjzb); //调用getZlb（）方法读取值列表
                zlbhm.put(cjzb.getZb_dm(), zlb); //将所有指标的值列表放到hashMap中
                for (int j = 0; j < zlb.size(); j++) {
                    SJWHzbzVO zbzvo = (SJWHzbzVO) zlb.get(j);
                    sb.append("---值列表：")
                            .append(zbzvo.getMc())
                            .append("\r\n");
                }
            }
        }

        SJWHcjsjResEvent resEvent = new SJWHcjsjResEvent();
        resEvent.setZbMap(zbhm); //指标Hashtable（zb_dm,mc）
        resEvent.setZlbMap(zlbhm); //指标可选的值列表HashMap（zb_dm,zList）
        sb.append("-------test zlbtable & zbtable ---\r\n");
        for (int count = 0; count < zbList.size(); count++) {
            SJWHcjzbVO cjzb = (SJWHcjzbVO) zbList.get(count);
            sb.append("指标名称：")
                    .append(zbhm.get(cjzb.getZb_dm()));
            if (cjzb.getDmb_mc() != null) {
                List zlb = (List) zlbhm.get(cjzb.getZb_dm());

                for (int l = 0; l < zlb.size(); l++) {
                    SJWHzbzVO zbzvo = (SJWHzbzVO) zlb.get(l);
                    sb.append(zbzvo.getMc())
                            .append("\r\n");
                }
            }
        }
        resEvent.setMsg(sb.toString());
        resEvent.setCjzb(zbList); //指标代码和名称列表（zb_dm,zb_mc）
        resEvent.setRepCode("0");
        return resEvent;
    }


    private List getNsrnbm(XXSXnsrxxVO nsrxxvo) throws TaxBaseBizException {
        XXSXcxnsrDAO cxdao = new XXSXcxnsrDAO();
        List nsrnbmList = null;
        try {
            nsrnbmList = cxdao.findNsrnbmByNsrflxx(nsrxxvo);
        } catch (SQLException ex) {
            throw new TaxBaseBizException("YCSJWH01022:读取纳税人内部码异常！");
        }
        return nsrnbmList;
    }

    //
    private HashMap getNsrbm(XXSXnsrxxVO nsrxx) throws TaxBaseBizException {
        XXSXcxnsrDAO cxdao = new XXSXcxnsrDAO();
        List nsrbmList = new ArrayList();
        HashMap hp = new HashMap();
        if (nsrxx.getNsrnbmList().length() > 0) {
            try {
                nsrbmList = cxdao.findNsrxxByNsrnbm(nsrxx);
                for (int i = 0; i < nsrbmList.size(); i++) {
                    XXSXnsrxxVO nsrvo = (XXSXnsrxxVO) nsrbmList.get(i);
                    if (nsrvo.getZbz() != null) {
                        hp.put(nsrvo.getNsrnbm(), nsrvo.getZbz());
                    }
                }
            } catch (SQLException ex) {
                throw new TaxBaseBizException("YCSJWH01021:读取纳税人信息异常！");
            }
        }
        return hp;
    }

    //批量读取纳税人编码/名称
    private List getNsrbm_mcList(XXSXnsrxxVO nsrxx) throws TaxBaseBizException {
        XXSXcxnsrDAO cxdao = new XXSXcxnsrDAO();
        List nsrbmList = new ArrayList();
        if (nsrxx.getNsrnbmList().length() > 0) {
            try {
                nsrbmList = cxdao.findNsrxxByNsrnbm(nsrxx);
            } catch (SQLException ex) {
                throw new TaxBaseBizException("YCSJWH01021:读取纳税人信息异常！");
            }
        }
        return nsrbmList;
    }

    //构造纳税人编码-内部码HashMap
    private HashMap constructNbm(XXSXnsrxxVO nsrxx, List nsrbmList) {
        HashMap hp = new HashMap();
        for (int i = 0; i < nsrbmList.size(); i++) {
            XXSXnsrxxVO nsrvo = (XXSXnsrxxVO) nsrbmList.get(i);
            if (nsrvo.getZbz() != null) {
                if (nsrxx.getZb_dm().equals("NSRBM")) {
                    hp.put(nsrvo.getZbz(), nsrvo.getNsrnbm());
                } else {
                    hp.put(nsrvo.getNsrnbm(), nsrvo.getZbz());
                }
            }
        }
        return hp;
    }

    /**
     * 获取纳税人名称编码
     * @param req SJWHcjsjReqEvent
     * @return ResponseEvent
     * @throws TaxBaseBizException
     */
    private ResponseEvent getNsrxx(SJWHcjsjReqEvent req) throws
            TaxBaseBizException {
        List nsrnbmList = null;
        List nsrbmList = null;
        ArrayList nsrList = new ArrayList();
        StringBuffer sb = new StringBuffer();
        String nsrString = null;
        XXSXnsrxxVO nsrxxvo = new XXSXnsrxxVO();
        SJWHcjsjResEvent resEvent = new SJWHcjsjResEvent();
        try {
            nsrxxvo.setLrry_dm(req.getLrry_dm());
            nsrxxvo.setZbz(req.getZbz());
            nsrnbmList = getNsrnbm(nsrxxvo);
            if (nsrnbmList != null) {
                for (int count = 0; count < nsrnbmList.size(); count++) {
                    sb.append(nsrnbmList.get(count));
                    if (count < nsrnbmList.size() - 1) {
                        sb.append(",");
                    }
                }
                nsrString = sb.toString();
                resEvent.setNsrnbmList(nsrString);
                XXSXnsrxxVO nsrvo = new XXSXnsrxxVO();
                nsrvo.setNsrnbmList(nsrString);
                nsrvo.setZb_dm("NSRBM");
                nsrbmList = getNsrbm_mcList(nsrvo);
                HashMap nsrbmhp = constructNbm(nsrvo, nsrbmList); //获取纳税人编码列表
                nsrvo.setZb_dm("NSR_MC");
                HashMap nsrmchp = getNsrbm(nsrvo); //获取纳税人名称列表
                HashMap nsrTips = getTips(nsrString); //获取提示信息列表
                for (int k = 0; k < nsrbmList.size(); k++) {
                    FLGLnsrflxxVO nsrflxxvo = new FLGLnsrflxxVO();
                    XXSXnsrxxVO nsr = (XXSXnsrxxVO) nsrbmList.get(k);
                    String nsrbm = nsr.getZbz();
                    nsrflxxvo.setNsrnbm((BigDecimal) nsrbmhp.get(nsrbm));
                    nsrflxxvo.setNsrbm(nsrbm);
                    nsrflxxvo.setNsr_mc((String) nsrmchp.get(nsrflxxvo.
                            getNsrnbm()));
                    HashMap tips = (HashMap) nsrTips.get((BigDecimal) nsrbmhp.
                            get(nsrbm));
                    nsrflxxvo.setTips_bm((String) tips.get("NSRBM"));
                    nsrflxxvo.setTips_mc((String) tips.get("NSR_MC"));
                    nsrList.add(nsrflxxvo);
                }
                resEvent.setCjsj(nsrList);
                resEvent.setRepCode("0");
            }
        } catch (TaxBaseBizException ex) {
            resEvent.setRepCode("-1");
            throw new TaxBaseBizException("YCSJWH01023:读取纳税人信息异常！");
        }
        return resEvent;
    }

    /**
     * 插入一条记录
     * @throws TaxBaseBizException
     * @param req SJWHcjsjReqEvent 传入采集数据vo，其中序号和数据库时间由数据库产生
     * @return ResponseEvent       返回是否插入成功标志
     */
    private ResponseEvent insertOne(SJWHcjsjReqEvent req) throws
            TaxBaseBizException {
        SJWHcjsjDAO cjsjdao = new SJWHcjsjDAO();
        SJWHcjsjVO cjsj = req.getCjsjvo();
        cjsjdao.setLrry_dm(cjsj.getLrry_dm());
        cjsjdao.setNsrnbm(cjsj.getNsrnbm());
        cjsjdao.setSjly(cjsj.getSjly());
        cjsjdao.setZb_dm(cjsj.getZb_dm());
        cjsjdao.setZbz(cjsj.getZbz());
        boolean flag = false;
        SJWHcjsjResEvent resEvent = new SJWHcjsjResEvent();
        try {
            List cjsjList = cjsjdao.findCjsj(cjsj); //查找行号（hh）>0的数据
            for (int count = 0; count < cjsjList.size(); count++) {
                SJWHcjsjVO tempvo = (SJWHcjsjVO) cjsjList.get(count);
                cjsjdao.setZbsj_xh(tempvo.getZbsj_xh());
                int i = cjsjdao.updateCjsj();
            }
            cjsjdao.setHh(cjsj.getHh());
            flag = cjsjdao.saveCjsj();
            resEvent.setFlag(1);
            resEvent.setRepCode("0");
        } catch (SQLException e) {
            resEvent.setFlag(0);
            resEvent.setRepCode("-1");
            throw new TaxBaseBizException("YCSJWH01009:插入一条指标数据异常！");
        }
        return resEvent;
    }

    /**
     * 查询纳税人相应指标的最新记录
     * @throws TaxBaseBizException
     * @param req SJWHcjsjReqEvent  req中传入纳税人内部码和指标代码
     * @return ResponseEvent        返回最新记录
     */
    private ResponseEvent getLastCjsj(SJWHcjsjReqEvent req) throws
            TaxBaseBizException {

        StringBuffer sb = new StringBuffer();
        SJWHcjsjVO cjsj = req.getCjsjvo();
        SJWHcjsjDAO cjsjdao = new SJWHcjsjDAO();
        //    System.out.println("----SJWHBLH : ---call findCjsjDao----   ---\r\n");
        SJWHcjsjResEvent resEvent = new SJWHcjsjResEvent();
        List cjsjList = new ArrayList();
        try {
            cjsjList = cjsjdao.findCjsj(cjsj);
            resEvent.setRepCode("0");
        } catch (SQLException e) {
            resEvent.setRepCode("-1");
            throw new TaxBaseBizException("YCSJWH01003：读取最新指标数据异常！");
        }
        resEvent.setCjsj(cjsjList);
        return resEvent;
    }

}