rwglclrwbaseblh.java

以前做的一个j2ee的项目

                else LogWritter.sysDebug("启动任务成功，任务序号："+newRwxh);
            }else if (rwxl.equals("0103")){
                if (!from.substring(0,4).equals("WDGH")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":40");
                int rows=flDAO.UpdateZBSJ("40",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0104")){
                if (!from.substring(0,4).equals("WDGH")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":50");
                int rows=flDAO.UpdateZBSJ("50",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0105")){
                if (!from.substring(0,4).equals("FZCH")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":20");
                int rows=flDAO.UpdateZBSJ("20",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0106")){
                if (!from.substring(0,4).equals("ZXHL")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":20");
                int rows=flDAO.UpdateZBSJ("20",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0107")){
                if (!from.substring(0,4).equals("WDGH")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_YCXSY:"+nsrnbm+":1");
                int rows=flDAO.UpdateZBSJ("1",nsrnbm,"USER_YCXSY");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0108")){
                if (!from.substring(0,4).equals("YCXL")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_YCXSY:"+nsrnbm+":0");
                int rows=flDAO.UpdateZBSJ("0",nsrnbm,"USER_YCXSY");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0109")){
                if (!from.substring(0,4).equals("WDGH")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":30");
                int rows=flDAO.UpdateZBSJ("30",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }else if (rwxl.equals("0110")){
                if (!from.substring(0,4).equals("TYHL")) return -1;
                XTFLflDAO flDAO=new XTFLflDAO();
                LogWritter.sysDebug("调用分类管理接口调整指标："+"USER_DJ_ZT:"+nsrnbm+":20");
                int rows=flDAO.UpdateZBSJ("20",nsrnbm,"USER_DJ_ZT");
                if (rows==1) LogWritter.sysDebug("调整指标成功！");
                else LogWritter.sysDebug("调整指标失败，返回码："+rows);
            }
        } else if (rwmx.getRwlx_dm().equals("05")) { //任务是预警提示
        }
            //清除提示标记，不再提示
            String yjjlxh=rwmx.getProperty("yjjlxh");
            if (yjjlxh==null || yjjlxh.equals("")) return 1;
            JKYJckyjxxReqEvent req = new JKYJckyjxxReqEvent();
            req.setTs_bj("0");
            req.setJl_xh(new BigDecimal(rwmx.getProperty("yjjlxh")));
            req.setNsrnbm(new BigDecimal(rwmx.getProperty("nsrnbm")));
            req.setDealMethod("setTsbj");
            JKYJckyjxxBLH ckyjxxBLH = new JKYJckyjxxBLH();
            try {
                ckyjxxBLH.execute(req);
            } catch (TaxBaseSystemException e) {
                throw e;
            } catch (TaxBaseBizException e) {
                throw e;
            }
            catch (Exception ex) {
                ex.printStackTrace();
            }


        return 1;
    }

    /**
     * 获取任务的明细信息及任务流转信息以便显示任务的具体内容
     * @param req RWGLclrwReqEvent
     * @return RWGLclrwResEvent
     */
    protected RWGLclrwResEvent getRwmxxx(RWGLclrwReqEvent req){
        BigDecimal rw_xh=req.getRw_xh();
        //获取任务明细信息
        RWGLrwmxVO rwmx=SsglyWorkFlow.getRwmx(rw_xh);
        LogWritter.sysDebug("成功获取任务明细信息，任务序号："+rwmx.getRw_xh()+" 办理方式代码："+rwmx.getClfs_dm()+" 任务明细信息："+rwmx.getRwmxxx());
        RWGLclrwResEvent res = new RWGLclrwResEvent();
        //获取任务流转信息
        ArrayList lzxx=SsglyWorkFlow.getLzxx(rw_xh);
        LogWritter.sysDebug("共获取"+lzxx.size()+"条流转信息");
        res.setLzxxVO(lzxx);
        //在获取任务附件信息之前，先检查是否需要生成文档
        String swry_dm=req.getSwry_dm();
        rwmx=this.callWdsc(rw_xh,swry_dm,rwmx);
        //获取任务附件信息
        ArrayList fjList=new ArrayList();
        RWGLrwfjVO rwfj;
        ArrayList fjUrl=rwmx.getFileList();
        String fileUrl;
        RWGLrwjlDAO rwDAO=new RWGLrwjlDAO();
        for (int i=0;i<fjUrl.size();i++){
            fileUrl=(String)fjUrl.get(i);
            rwfj=rwDAO.getFjxx(fileUrl);
            if (rwfj!=null) {
                rwfj.setFj_xh(i+1);
                fjList.add(rwfj);
            }
        }
        res.setRwfjVO(fjList);
        //获取当前人员意见及处理方式
        RWGLrwlzxxDAO lzdao=new RWGLrwlzxxDAO(rw_xh);
        lzdao.setSwry_dm(swry_dm);
        lzdao.query4view();
        BigDecimal bz_xh=lzdao.getBz_xh();
        String blry_dm=lzdao.getBlry_dm();
        String lzfs_dm=lzdao.getLzfs_dm();
        String blyj=lzdao.getBlyj();
        //如果已经指定是否只读方式，则直接返回结果
        if (req.getReadOnly()!=null) {
            res.setReadOnly(req.getReadOnly().booleanValue());
        }else if (bz_xh == null) { //对于未指定只读方式的，进行判断
            LogWritter.sysDebug("任务不是发送给用户" + swry_dm + "的，只能以只读方式打开");
            res.setReadOnly(true);
        }else if (blry_dm == null || blry_dm.equals("")) {
            LogWritter.sysDebug("任务未签收，现在自动签收");
            int rows = SsglyWorkFlow.sign(swry_dm, rwmx.getRw_xh(),bz_xh);
            if (rows == 1) {
                LogWritter.sysDebug("任务自动签收成功，可以办理");
                res.setReadOnly(false);
            } else {
                LogWritter.sysDebug("任务自动签收失败，将以只读方式打开");
                res.setReadOnly(true);
            }
        }else if (!blry_dm.equals(swry_dm)) {
            LogWritter.sysDebug("任务已被" + blry_dm + "签收，" + swry_dm + "只能以只读方式打开");
            res.setReadOnly(true);
        }else{
            LogWritter.sysDebug("任务已签收，可以进行处理");
            res.setReadOnly(false);
        }
        if (!res.isReadOnly()){
            //非只读方式的，将当前的流转方式和办理意见填写到任务明细
            rwmx.setClfs_dm(lzfs_dm);
            rwmx.setBlyj(blyj);
            rwmx.setBz_xh(bz_xh);
        }
        res.setRwmxVO(rwmx);
        return res;
    }

    /**
     * 获取所有明细信息，包括任务明细信息及发送对象列表
     * @param req RWGLclrwReqEvent
     * @return RWGLclrwResEvent
     */
    protected RWGLclrwResEvent getRwmxAll(RWGLclrwReqEvent req){
        //获取任务明细信息
        RWGLclrwResEvent res=this.getRwmxxx(req);
//        //获取发送对象列表，已停用
//        String blfs_dm=req.getBlfs_dm();
//        BigDecimal rw_xh=req.getRw_xh();
//        String swry_dm=req.getSwry_dm();
//        res.setFsdxVO(SsglyWorkFlow.getFsdx(swry_dm,rw_xh,blfs_dm));
        return res;
    }

//    protected RWGLclrwResEvent cfrw2Swry(RWGLclrwReqEvent req){
//        RWGLrwmxVO rwmxVO=req.getRwmxVO();
//        BigDecimal fl_xh=rwmxVO.getFl_xh();
//        ArrayList nsrList=rwmxVO.getNsrList();
//        BigDecimal jh_xh=SsglyWorkFlow.newJhap(null,true);
//        RWGLclrwResEvent res = new RWGLclrwResEvent(); //创建ResponseEvent对象resEvn
//        return res;
//    }

    /**
     * 检查任务明细中是否存在需要生成的文档，如有，则调用文档生成的接口
     * @param rw_xh BigDecimal --任务序号
     * @param swry_dm String --当前税务人员
     * @param rwmx RWGLrwmxVO --装载任务明细信息的VO
     * @return RWGLrwmxVO --返回调整之后的任务明细VO
     */
    private RWGLrwmxVO callWdsc(BigDecimal rw_xh, String swry_dm,RWGLrwmxVO rwmx) {
        LogWritter.sysDebug("开始进行文档生成的检查");
        //先判断是否只有一个纳税人，如果不只一个或没有纳税人，则不生成文档
        ArrayList wdList =(ArrayList) rwmx.getList("wdbh").clone();
        if ((rwmx.getFl_xh() == null || rwmx.getFl_xh().equals("")) &&
            rwmx.getNsrList() != null && rwmx.getNsrList().size() == 1 &&
            wdList != null &&
            wdList.size() > 0) {
            rwmx.removeProperty("wdbh");
            ArrayList fileList=rwmx.getFileList();
            //准备调用接口
            String nsrnbm = (String) rwmx.getNsrList().get(0);
            WDSCqtwdscBLH wdBLH = new WDSCqtwdscBLH();
            String mbbh, wdnr, url;
            ArrayList tempList;
            for (int i = 0; i < wdList.size(); i++) {
                //取文档编号
                mbbh = (String) wdList.get(i);
                LogWritter.sysDebug(mbbh);
                if (mbbh == null || mbbh.equals("")) continue;
                tempList=StringUtils.convertStrToArrayList(mbbh,",");
                mbbh=(String)tempList.get(0);
                if (mbbh == null || mbbh.equals("")) continue;
                LogWritter.sysDebug("准备调用文档生成接口，文档模板编号："+mbbh+" 纳税人内部码："+nsrnbm);
                //调用文档生成接口
                try {
                    wdnr=StringUtils.gbkToISO(wdBLH.makeQtWd(mbbh,nsrnbm));
                } catch (Exception ex) {
                    LogWritter.sysDebug("文档生成接口调用失败，模板编号："+mbbh+" 纳税人内部码："+nsrnbm);
                    ex.printStackTrace();
                    wdnr = null;
                }
                if (wdnr == null || wdnr.equals("")) {
                    LogWritter.sysDebug("生成的文档无内容，生成失败，模板编号："+mbbh+" 纳税人内部码："+nsrnbm);
                    continue;
                }
                LogWritter.sysDebug("文档生成成功，准备调用文档管理接口以保存内容");
                try {
                    TaskManagerImpl taskmanagerimpl = new
                            TaskManagerImpl();
                    url = taskmanagerimpl.currencySaveFile("HTM",
                            "FG", "过程文档", "税收管理员平台系统", swry_dm,
                            nsrnbm.toString(), "系统附加信息", "", "", "文档生成",
                            wdnr.getBytes());
                } catch (Exception ex) {
                    LogWritter.sysDebug("调用文档管理接口失败，无法保存!");
                    ex.printStackTrace();
                    url=null;
                }
                if (url==null || url.equals("")) {
                    LogWritter.sysDebug("文档保存返回码为空，保存失败!");
                    continue;
                }
                fileList.add(url);
                LogWritter.sysDebug("生成的文档保存成功，URL="+url);
            }
            rwmx.setFileList(fileList);
            //重用特殊数据处理的方法保存任务明细信息
            RWGLspecialDAO dao=new RWGLspecialDAO();
            RWGLspecialDataVO data=new RWGLspecialDataVO();
            data.setSpecialString2(rwmx.getRwmxxx());
            data.setSpecialNumber2(rw_xh);
            data.setSqlOperation("update");
            data.setSqlName("setRwmxxx");
            data=dao.dealSpecialOperation(data);
            if (data.getSpecialNumber1().equals(new BigDecimal(1))) LogWritter.sysDebug("任务模板生成的文档已添加到任务明细信息中");
        } else {
            LogWritter.sysDebug(
                    "本任务包含超过一个纳税人，不调用文档生成接口");
        }
        return rwmx;
    }

    /**
     * 处理任务的特殊信息
     * @param req RWGLclrwReqEvent
     * @return RWGLclrwResEvent
     */
    protected RWGLclrwResEvent getSpecial(RWGLclrwReqEvent req){
    RWGLspecialDataVO special=req.getSpecialData();
        RWGLspecialDAO dao=new RWGLspecialDAO();
        special=dao.dealSpecialOperation(special);
        RWGLclrwResEvent res = new RWGLclrwResEvent(); //创建ResponseEvent对象resEvn
        if (special==null){
            res.setRepCode("-1");
        }else{
            res.setRepCode("0");
            res.setSpecialData(special);
        }
        return res;
    }
}