rwglckrwblh.java

以前做的一个j2ee的项目

package gov.gdlt.ssgly.taxcore.taxblh.rwgl;

import gov.gdlt.ssgly.taxcore.comm.blh.*;
import gov.gdlt.ssgly.taxcore.comm.event.*;
import java.sql.*;


import gov.gdlt.ssgly.taxcore.comm.blh.BaseBizLogicHandler;
import gov.gdlt.ssgly.taxcore.comm.event.RequestEvent;
import gov.gdlt.ssgly.taxcore.comm.event.ResponseEvent;
import gov.gdlt.ssgly.taxcore.comm.exception.TaxBaseBizException;
import gov.gdlt.ssgly.taxcore.comm.exception.TaxBaseSystemException;
import gov.gdlt.ssgly.taxcore.taxevent.rwgl.*;
import gov.gdlt.ssgly.taxcore.comm.log.LogWritter;
import java.math.BigDecimal;
import java.util.ArrayList;
import gov.gdlt.ssgly.taxcore.taxdao.rwgl.workflow.SsglyWorkFlow;
import gov.gdlt.ssgly.taxcore.taxdao.rwgl.RWGLrwlzxxDAO;

/**
 * <p>Title: </p>
 * <p>Description: 广东地税大集中项目税收管理员平台</p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: 广东省地方税务局, 广州市地方税务局</p>
 * @author Bruce Wang
 * @version 1.0
 */

public class RWGLckrwBLH extends BaseBizLogicHandler {

    public RWGLckrwBLH() {
    }

    //////////////////    抽象方法实现    /////////////////////
    /**
     * validateData 实现具体的业务数据规则校验
     * req : RequestEvent,   客户端请求数具
     * conn : Connection   数据库连结
     * 返回：boolean   true:数据校验成功   false:数据校验不成功
     */
    protected ResponseEvent validateData(RequestEvent req) throws
            Exception {
        LogWritter.sysDebug("got session");
        ResponseEvent res = new ResponseEvent();
        return res;
   }

    /**
     * 此方法实现了业务逻辑的处理过程，处理具体业务逻辑的过程中，
     * 在出现异常的时侯, 必须向上抛出异常，异常的处理在
     * BaseBizLogicHandler实现异常的处理，事务处理和日志的记录；具体要的异常的定义根据
     * 具体的业务来确定。返回的参数的对象类型必须是ResponseEvent类型的对象实例，
     * 如果捕捉到业务上的异常，并对具体的业务的异常进行处理，如根据TaxBaseBizException
     * 以及它的扩展类的异常，写应用日志信息，异常捕获后，相应地要向上抛以下几种异常
     *  1.TaxBaseSystemException
     *  2.TaxBaseBizException
     *  3.Throwable
     *  输入参数:
     *  req : RequestEvent,  客户端请求的数据对象实例
     *  conn : Connection   数据库的连接句柄
     *  返回：ResponseEvent  返回给客户端的数据对象实例
     */
    protected ResponseEvent performTask(RequestEvent req) throws
            TaxBaseSystemException, TaxBaseBizException {
        String dealMethod = req.getDealMethod(); //业务处理标志
        ResponseEvent resEvn = new ResponseEvent(); //创建ResponseEvent对象resEvn
        //强制造型转换
        RWGLckrwReqEvent reqEvent = (RWGLckrwReqEvent) req;
        if ("getRwlb".equals(dealMethod)) {
            resEvn = this.getRwlb(reqEvent);
        } else
        if ("getRwlbmx".equals(dealMethod)) {
            resEvn = this.getRwlbmx(reqEvent);
        } else
        if ("sign".equals(dealMethod)){
            resEvn=this.sign(reqEvent);
        } else
        if ("unsign".equals(dealMethod)){
            resEvn=this.unsign(reqEvent);
        } else
        if ("pullBack".equals(dealMethod)){
            resEvn=this.pullBack(reqEvent);
        }
        return resEvn;
    }

    /**
     * 获取任务列表
     * @param req：RWGLckrwReqEvent
     * @return ResponseEvent
     */
    private ResponseEvent getRwlb(RWGLckrwReqEvent req) {
        ArrayList rwlbVO = new ArrayList();

        String lb_lx = req.getLb_lx();
        String swry_dm = req.getSwry_dm();
        //与DAO交互，得到任务列表的VO
        //RWGLrwjlDAO rwjlDAO = new RWGLrwjlDAO();
        LogWritter.sysDebug("performing "+lb_lx+" of "+swry_dm);
        rwlbVO = SsglyWorkFlow.getWorkList(swry_dm,lb_lx);

        //使用构造器将取得的VO封装到ResponseEvent里
        RWGLckrwResEvent res = new RWGLckrwResEvent();
        res.setRwlbVO(rwlbVO);
        res.setRepCode("0");
        LogWritter.sysDebug("got list of "+res.getRwlbVO().size()+" rows");
        return res;
    }

    private ResponseEvent getRwlbmx(RWGLckrwReqEvent req) {

        ArrayList rwmxVOList = new ArrayList();

        BigDecimal rw_xh = req.getRw_xh();

        /*
         与PO交互，得到任务明细的VO
         此处略去程序段
         */

        //使用构造器将取得的VO封装到ResponseEvent里
        RWGLckrwResEvent res = new RWGLckrwResEvent();
        res.setRepCode("0");

        return res;
    }

    /**
     * 签收任务
     * @param req RWGLckrwReqEvent
     * @return ResponseEvent
     */
    private ResponseEvent sign(RWGLckrwReqEvent req){
        LogWritter.sysDebug("begin sign");
        int rows=SsglyWorkFlow.sign(req.getSwry_dm(),req.getRw_xh(),req.getBz_xh());
        LogWritter.sysDebug(""+rows+" rows updated");
        RWGLckrwResEvent res = new RWGLckrwResEvent();
        if (rows==1) res.setRepCode("0") ;else res.setRepCode("-1");
        return res;
    }

    /**
     * 撤销签收
     * @param req RWGLckrwReqEvent
     * @return ResponseEvent
     */
    private ResponseEvent unsign(RWGLckrwReqEvent req){
        LogWritter.sysDebug("begin unsign");
        int rows=SsglyWorkFlow.unsign(req.getSwry_dm(),req.getRw_xh(),req.getBz_xh(),req.getBlfs_dm());
        LogWritter.sysDebug(""+rows+" rows updated");
        RWGLckrwResEvent res = new RWGLckrwResEvent();
        if (rows==1) res.setRepCode("0") ;else res.setRepCode("-1");
        return res;
    }

    /**
     * 收回已发送的任务
     * @param req RWGLckrwReqEvent
     * @return ResponseEvent
     */
    private ResponseEvent pullBack(RWGLckrwReqEvent req){
        LogWritter.sysDebug("begin pullback");
        int rows=SsglyWorkFlow.pullBack(req.getRw_xh(),req.getSwry_dm());
        LogWritter.sysDebug(""+rows+" rows updated");
        RWGLckrwResEvent res=new RWGLckrwResEvent();
        if (rows==1) res.setRepCode("0");else res.setRepCode("-1");
        return res;
    }

}