htdldtrwlbdao.java

以前做的一个j2ee的项目

package gov.gdlt.ssgly.taxcore.taxdao.htdl;

import java.sql.Timestamp;
import java.util.*;
import java.text.SimpleDateFormat;

import gov.gdlt.ssgly.taxcore.comm.config.ApplicationContext;
import gov.gdlt.ssgly.taxcore.comm.dao.BaseDataAccessObject;
import gov.gdlt.ssgly.taxcore.comm.exception.TaxBaseSystemException;
import gov.gdlt.ssgly.taxcore.comm.log.LogWritter;
import gov.gdlt.ssgly.taxcore.taxevent.htdl.HTDLreturnVO;
import java.sql.Connection;
import java.sql.SQLException;
import gov.gdlt.ssgly.taxcore.comm.servicelocator.JDBCLocator;
import gov.gdlt.ssgly.taxcore.taxevent.htdl.HTDLdtrwVO;

/**
 *
 * <p>Title:当天任务列表DAO </p>
 *
 * <p>Description: 广东地税税收管理员工作平台</p>
 *
 * <p>Copyright: Copyright (c) 2005 广东省地方税务局，广州市地方税务局</p>
 *
 * <p>Company: 广州地税</p>
 *
 * @author 肖雪莲
 * @version 1.0
 */


public class HTDLdtrwlbDAO extends BaseDataAccessObject {
    private String rw_xh;
    private String rw_mc;
    private String blh_mc;
    private String lrry_dm;
    private String zb;
    private int zxyxj; //执行优先级
    private String dyjk;
    private String sx_lx; //实现类型
    private String zt; //当前状态
    private Timestamp lr_sj; //生成时间
    private String csl; //参数值


    public String getDyjk() {
        return dyjk;
    }

    public String getRw_xh() {
        return rw_xh;
    }

    public String getSx_lx() {
        return sx_lx;
    }

    public int getZxyxj() {
        return zxyxj;
    }

    public String getBlh_mc() {
        return blh_mc;
    }

    public String getLrry_dm() {
        return lrry_dm;
    }

    public String getRw_mc() {
        return rw_mc;
    }

    public String getZb() {
        return zb;
    }

    public Timestamp getLr_sj() {
        return lr_sj;
    }

    public String getZt() {
        return zt;
    }

    public String getCsl() {
        return csl;
    }

    public void setDyjk(String dyjk) {
        this.dyjk = dyjk;
    }

    public void setRw_xh(String rw_xh) {
        this.rw_xh = rw_xh;
    }

    public void setSx_lx(String sx_lx) {
        this.sx_lx = sx_lx;
    }

    public void setZxyxj(int zxyxj) {
        this.zxyxj = zxyxj;
    }

    public void setBlh_mc(String blh_mc) {
        this.blh_mc = blh_mc;
    }

    public void setLrry_dm(String lrry_dm) {
        this.lrry_dm = lrry_dm;
    }

    public void setRw_mc(String rw_mc) {
        this.rw_mc = rw_mc;
    }

    public void setZb(String zb) {
        this.zb = zb;
    }

    public void setLr_sj(Timestamp lr_sj) {
        this.lr_sj = lr_sj;
    }

    public void setZt(String zt) {
        this.zt = zt;
    }

    public void setCsl(String csl) {
        this.csl = csl;
    }

    //删除当天任务列表中的指定任务
    //* @return int <br>
//*     >=0 被删除的记录数<br>
//*     RET_FAIL 执行失败
       public int deleteDtrwlb(String rw_xh) throws TaxBaseSystemException {
           int result;
           try {
               result = delete("T_HTDL_DTDDRW.deleteAlldtrw", rw_xh);
           } catch (Exception e) {
               result = ApplicationContext.RET_FAIL;
               LogWritter.sysError(
                       "YCHTDL02202：删除当天任务列表中指定任务时出现异常！\u2014\u2014" +
                       e.getMessage());
               throw new TaxBaseSystemException(
                       "YCHTDL02202");
           }
           return result;
       }

    //往当天任务列表中插入一条记录,
    public boolean saveDtrw() throws TaxBaseSystemException {
        boolean result = true;
        try {
            save("T_HTDL_DTDDRW.insertDtrw");
        } catch (Exception e) { //mod
            result = false;
            LogWritter.sysError("YCHTDL02201：往当天任务列表中插入新记录时出现异常！\u2014\u2014" +
                                e.getMessage());
            throw new TaxBaseSystemException(
                    "YCHTDL02201");
        }
        return result;
    }

    /**
     * @param paramObj：Object 传入的参数对象
     * @return List <br>
     *    非空 执行成功，找到记录<br>
     *    NULL 执行失败
     * 返回结果按照blh_mc排列
     */
    public List selectAllDtrw() throws TaxBaseSystemException {
        List result;
        try {
            result = selectAll("T_HTDL_DTDDRW.selectAllDtrw", null);
        } catch (Exception e) {
            result = null;
            LogWritter.sysError("YCHTDL02203：查询当天任务列表时出现异常！\u2014\u2014" +
                                e.getMessage());
            throw new TaxBaseSystemException(
                    "YCHTDL02203");
        }
        return result;
    }

    //调用存储过程，生成当天的调度任务
    public int createDtrw(HTDLreturnVO returnVO) throws TaxBaseSystemException {
        return select("T_HTDL_DTDDRW.createDtrw", returnVO);
//                  return select("T_HTDL_DTDDRW.createDtrw",null);
    }

    //调用存储过程，生成当天的调度任务
    public boolean createDtrw_synchronize(HTDLreturnVO returnVO) throws TaxBaseSystemException {
        boolean result = false;
        this.getSqlMapClient(); //用父类方法获取sqlMap对象
        Connection connection = null;
        boolean defaultCommit = false;
        try {
            System.out.println("==============before get connection in createDtrw=========================");
            connection = JDBCLocator.getInstance().getJDBCConnection();
            sqlMap.setUserConnection(connection);

            defaultCommit = connection.getAutoCommit();
            connection.setAutoCommit(false);

            //lock table t_htdl_dtddrw
            System.out.println("===============before lock the table T_HTDL_DTDDRW!===================================");
            sqlMap.queryForObject("T_HTDL_DTDDRW.lockDtrwTable", null);  //lock table

            /*  检查是否已经生成了当天的任务  */
            //任务表的任务的生成时间  'yyyy-dd-mm'
            String createTime = (String) sqlMap.queryForObject("T_HTDL_DTDDRW.getCreateTime",null);
            System.out.println("==============createTime in table:"+createTime+"=======================");
            Calendar currentDate = Calendar.getInstance();
            //SimpleDateFormat(dateFormat[0]).format(date.getTime());
            SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd");
            String sb = df.format(currentDate.getTime());
            System.out.println("================currentDate:"+sb+"===============================");
            //需要重新生成当天任务
//            if ((createTime == null)||(!sb.equals(createTime))) {
            if (sb.equals(createTime)) {
                System.out.println("==============keep the old dtrw===========================");
            } else {
                System.out.println("==============create dtrw===========================");
                sqlMap.queryForObject("T_HTDL_DTDDRW.createDtrw", returnVO);
            }

            connection.commit();
            System.out.println("===============unlock the table T_HTDL_DTDDRW after commit!===================================");
        } catch (SQLException e) {
            LogWritter.sysError("Exception in createDtrw_synchronize!" + e.getMessage());
            try {
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                LogWritter.sysError("YCHTDL:Exception in createDtrw_synchronize!！" +
                                    e.getMessage()); //mod
            }
        } finally {
            try {
                if (connection != null) {
                    connection.commit();
                    connection.setAutoCommit(defaultCommit);
                    connection.close();
                }
            } catch (SQLException e) {
                LogWritter.sysError("YCHTDL:Exception in createDtrw_synchronize!！" +
                                    e.getMessage()); //mod
            }
        }

//        select("T_HTDL_DTDDRW.createDtrw", returnVO);
        return result;
//                  return select("T_HTDL_DTDDRW.createDtrw",null);
    }


    //调用存储过程，执行指定名称的存储过程，存储过程的名字和返回值放在参数中
    /* @return int <br>
     *    ROWS_FOUND or ROWS_NOT_FOUND 执行成功
     *    RET_FAIL 执行失败
     */
    public int execDtrw(HTDLreturnVO returnVO) throws TaxBaseSystemException {
        return select("T_HTDL_DTDDRW.execDtrw", returnVO);
//                  return select("T_HTDL_DTDDRW.createDtrw",null);
    }

    //根据分组信息取得属于该分组的所有当天任务记录
    //参数fz如果为null,则取回全部的当天任务记录，按照优先级从高到低排列
    public List selectDtrwByFz(String fz) throws TaxBaseSystemException {
        HashMap zb = new HashMap();
        zb.put("zb", new String(fz));
        return selectAll("T_HTDL_DTDDRW.selectDtrwbyZb", zb);
    }

    //取得当天任务列表中所有的分组信息