htdlzxlogdao.java

以前做的一个j2ee的项目

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

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

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


/**
 * <p>Title: 定时任务执行情况日志DAO</p>
 *
 * <p>Description: 广东地税税收管理员工作平台</p>
 *
 * <p>Copyright: Copyright (c) 2005 广东省地方税务局，广州市地方税务局</p>
 *
 * <p>Company: 广州地税</p>
 *
 * @author 肖雪莲
 * @version 1.0
 */

public class HTDLzxlogDAO extends BaseDataAccessObject {

    private String log_xh; //日志序号
    private String lrry_dm; //录入人员代码
    private String rw_xh; //已部署的调度任务列表中的任务序号
    private String rw_mc; //任务名称
    private String blh_mc; //执行的blh
//    private Date bczx_qssj;  //执行开始时间
//    private Date bczx_zzsj;   //执行结束时间
    private Timestamp bczx_qssj;
    private Timestamp bczx_zzsj;
    private String zxjg; //执行结果
    private String jgms; //结果描述

    public Timestamp getBczx_qssj() {
        return bczx_qssj;
    }

    public Timestamp getBczx_zzsj() {
        return bczx_zzsj;
    }

    public String getBlh_mc() {
        return blh_mc;
    }

    public String getJgms() {
        return jgms;
    }

    public String getLog_xh() {
        return log_xh;
    }

    public String getLrry_dm() {
        return lrry_dm;
    }

    public String getRw_xh() {
        return rw_xh;
    }

    public String getZxjg() {
        return zxjg;
    }

    public String getRw_mc() {
        return rw_mc;
    }

    public void setBczx_qssj(Timestamp bczx_qssj) {
        this.bczx_qssj = bczx_qssj;
    }

    public void setBczx_zzsj(Timestamp bczx_zzsj) {
        this.bczx_zzsj = bczx_zzsj;
    }

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

    public void setJgms(String jgms) {
        this.jgms = jgms;
    }

    public void setLog_xh(String log_xh) {
        this.log_xh = log_xh;
    }

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

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

    public void setZxjg(String zxjg) {
        this.zxjg = zxjg;
    }

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

    //插入一条执行日志
    /* @return Object
     *     RET_FAIL:Integer 执行失败
     *     非RET_FAIL:Object 保存成功
     */
    //需要修改，catch 中需要修改Exception的类型 mod
    public boolean saveZxlog() throws TaxBaseSystemException {
        boolean result = true;
        try {
            save("T_HTDL_DSRWZXLOG.insertZxlog");
        } catch (Exception e) { //mod
            result = false;
            LogWritter.sysError("YCHTDL02221:往任务执行日志表中插入新记录时出现异常！" + e.toString());
            throw new TaxBaseSystemException("YCHTDL02221"); //YCHTDL01***:插执行日志失败 mod
        }
        return result;
    }

    //返回任务执行日志中的所有记录
    public List selectAllZxlog(HTDLcxzxqkVO cxzxqkVO) throws
            TaxBaseSystemException {
        return selectAll("T_HTDL_DSRWZXLOG.selectAllZxlog", cxzxqkVO);
    }


    //返回任务执行日志中的所有符合条件的记录（模糊查询）
    public List selectZxlogFuzzy(HTDLcxzxqkVO cxzxqkVO) throws
            TaxBaseSystemException {
        return selectAll("T_HTDL_DSRWZXLOG.selectZxlogFuzzy", cxzxqkVO);
    }

//插入一条新的日志记录，并返回日志序号
    public String insertNewLog(HTDLzxqkVO zxlogVO) throws
            TaxBaseSystemException {
        String logXh = null;

        this.getSqlMapClient(); //用父类方法获取SqlMap对象

        Connection connection = null;
        boolean defaultCommit = false;
        try {
            connection = JDBCLocator.getInstance().getJDBCConnection();
            sqlMap.setUserConnection(connection);
            defaultCommit = connection.getAutoCommit();
            connection.setAutoCommit(false);

            //获取新的日志序号
            logXh = (String) sqlMap.queryForObject(
                    "T_HTDL_DSRWZXLOG.getNewLogXh", null);
            System.out.println(logXh);
            zxlogVO.setLog_xh(logXh);
            //插入新的日志的记录
            sqlMap.insert("T_HTDL_DSRWZXLOG.insertNewLog", zxlogVO);
            connection.commit();
        } catch (SQLException e) {
            try {
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                LogWritter.sysError("YCHTDL02222:HTDLzxlogDAO.insertNewLog往执行日志表中插入新记录时出现数据库操作异常！" +
                                    e.getMessage()); //mod
                throw new TaxBaseSystemException("YCHTDL02222");
            }
        } finally {
            try {
                if (connection != null) {
                    connection.setAutoCommit(defaultCommit);
                    connection.close();
                }
            } catch (SQLException e) {
                LogWritter.sysError("YCHTDL02222:HTDLzxlogDAO.insertNewLog往执行日志表中插入新记录时出现数据库操作异常！" +
                                    e.getMessage()); //mod
                throw new TaxBaseSystemException("YCHTDL02222");
            }
        }
        return logXh;
    }

    public boolean updateZxlog(HTDLzxqkVO zxlogVO) throws
            TaxBaseSystemException {
        boolean result = true;

        int i = update("T_HTDL_DSRWZXLOG.updateLogByXh", zxlogVO);
        if (i == ApplicationContext.RET_FAIL) {
            result = false;
        }

        return result;
    }

    public static void main(String args[]) {
//        HTDLcxzxqkVO cxzxqkVO = new HTDLcxzxqkVO();
//        cxzxqkVO.setBlh_mc("任务日结");
//        cxzxqkVO.setRw_mc("任务日结");
//        cxzxqkVO.setZxjg("任务日结");
//        System.out.println(cxzxqkVO);

        HTDLzxlogDAO logDAO = new HTDLzxlogDAO();
        try {
            HTDLzxqkVO zxqkVO = new HTDLzxqkVO();
            zxqkVO.setRw_xh("186");
            zxqkVO.setRw_mc("人工调度");
            zxqkVO.setBlh_mc("A07-01");
            zxqkVO.setLrry_dm("24401050209");
            java.sql.Timestamp dtNow = new java.sql.Timestamp(System.
                    currentTimeMillis());
            zxqkVO.setBczx_qssj(dtNow);
            zxqkVO.setZxjg("1");
            zxqkVO.setJgms("执行中");
            String log_xh = logDAO.insertNewLog(zxqkVO);

            System.out.println(log_xh);
            zxqkVO.setLog_xh(log_xh);
            dtNow = new java.sql.Timestamp(System.currentTimeMillis());
            zxqkVO.setBczx_zzsj(dtNow);
            zxqkVO.setZxjg("0");
            zxqkVO.setJgms("执行完毕");
            logDAO.updateZxlog(zxqkVO);
        } catch (Exception e) {
            System.out.println(e.toString());
        }
    }

}