jobunitdb.java

来自「cwbbs 云网论坛源码」· Java 代码 · 共 64 行

package cn.js.fan.module.cms.kernel;

import com.cloudwebsoft.framework.base.*;
import com.cloudwebsoft.framework.db.JdbcTemplate;
import java.util.Vector;
import cn.js.fan.util.StrUtil;
import java.util.Iterator;
import cn.js.fan.util.ResKeyException;
import com.cloudwebsoft.framework.util.LogUtil;
import cn.js.fan.db.ResultIterator;
import java.sql.SQLException;
import cn.js.fan.db.ResultRecord;
import cn.js.fan.util.ParamChecker;
import cn.js.fan.util.ErrMsgException;


public class JobUnitDb extends QObjectDb {

    public JobUnitDb() {
    }

    public boolean create(ParamChecker pck) throws ResKeyException,ErrMsgException {
        boolean re = super.create(pck);

        
        SchedulerManager.getInstance().scheduleJob("" + getInt("id"), pck.getString("job_class"), pck.getString("cron"), pck.getString("data_map"));
        return re;
    }

    public boolean save(JdbcTemplate jt) throws ResKeyException {
        boolean re = super.save(jt);
        

        if (re)
            SchedulerManager.getInstance().rescheduleJob("" + getInt("id"), getString("cron"));
        return re;
    }

    public int getJobId(String jobClass, String dataMap) {
        String sql = "select id from " + table.getName() + " where job_class=? and data_map=?";
        JdbcTemplate jt = new JdbcTemplate();
        ResultIterator ri = null;
        try {
            ri = jt.executeQuery(sql, new Object[] {jobClass, dataMap});
        }
        catch (SQLException e) {
            LogUtil.getLog(getClass()).error("getJobId:" + e.getMessage());
        }
        if (ri.hasNext()) {
            ResultRecord rr = (ResultRecord)ri.next();
            return rr.getInt(1);
        }
        else
            return -1;
    }

    public boolean del() throws ResKeyException {
        boolean re = false;
        SchedulerManager.getInstance().delJob("" + getInt("id"));
        re = super.del();
        return re;
    }
}