SpringMVC精品资源--将kettle集成值web应用中，不再需打开kettle窗口运行，采用springmv.zip

package com.leadingsoft.web.service; import java.io.IOException; import java.sql.SQLException; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.commons.lang.StringUtils; import org.beetl.sql.core.DSTransactionManager; import org.beetl.sql.core.db.KeyHolder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; import org.springframework.web.multipart.MultipartFile; import com.leadingsoft.common.toolkit.Constant; import com.leadingsoft.core.dto.BootTablePage; import com.leadingsoft.core.mapper.KQuartzDao; import com.leadingsoft.core.mapper.KRepositoryDao; import com.leadingsoft.core.mapper.KTransDao; import com.leadingsoft.core.mapper.KTransMonitorDao; import com.leadingsoft.core.model.KQuartz; import com.leadingsoft.core.model.KRepository; import com.leadingsoft.core.model.KTrans; import com.leadingsoft.core.model.KTransMonitor; import com.leadingsoft.web.quartz.QuartzManager; import com.leadingsoft.web.quartz.TransQuartz; import com.leadingsoft.web.quartz.model.DBConnectionModel; import com.leadingsoft.web.utils.CommonUtils; @Service public class TransService { @Autowired private KTransDao kTransDao; @Autowired private KQuartzDao kQuartzDao; @Autowired private KRepositoryDao KRepositoryDao; @Autowired private KTransMonitorDao kTransMonitorDao; @Value("${kettle.log.file.path}") private String kettleLogFilePath; @Value("${kettle.file.repository}") private String kettleFileRepository; @Value("${jdbc.driver}") private String jdbcDriver; @Value("${jdbc.url}") private String jdbcUrl; @Value("${jdbc.username}") private String jdbcUsername; @Value("${jdbc.password}") private String jdbcPassword; /** * @Title getList * @Description 获取列表 * @param uId 用户ID * @return * @return List<KTrans> */ public List<KTrans> getList(Integer uId){ KTrans template = new KTrans(); template.setAddUser(uId); template.setDelFlag(1); return kTransDao.template(template); } /** * @Title getList * @Description 获取列表 * @param start 其实行数 * @param size 获取数据的条数 * @param uId 用户ID * @return * @return BootTablePage */ public BootTablePage getList(Integer start, Integer size, Integer uId){ KTrans template = new KTrans(); template.setAddUser(uId); template.setDelFlag(1); List<KTrans> kTransList = kTransDao.template(template, start, size); Long allCount = kTransDao.templateCount(template); BootTablePage bootTablePage = new BootTablePage(); bootTablePage.setRows(kTransList); bootTablePage.setTotal(allCount); return bootTablePage; } /** * @Title delete * @Description 删除转换 * @param kTransId 转换ID * @return void */ public void delete(Integer kTransId){ KTrans kTrans = kTransDao.unique(kTransId); kTrans.setDelFlag(0); kTransDao.updateById(kTrans); } /** * @Title check * @Description 检查转换是否添加过 * @param repositoryId 资源库ID * @param kTransPath 转换路径信息 * @param uId 用户ID * @return * @return boolean */ public boolean check(Integer repositoryId, String kTransPath, Integer uId){ KTrans template = new KTrans(); template.setDelFlag(1); template.setAddUser(uId); template.setTransRepositoryId(repositoryId); template.setTransPath(kTransPath); List<KTrans> kTransList = kTransDao.template(template); if (null != kTransList && kTransList.size() > 0){ return false; }else{ return true; } } /** * @Title saveFile * @Description 保存上传的转换文件 * @param uId 用户ID * @param transFile 需要保存的转换文件 * @return * @throws IOException * @return String */ public String saveFile(Integer uId, MultipartFile transFile) throws IOException{ return CommonUtils.saveFile(uId, kettleFileRepository, transFile); } /** * @Title insert * @Description 添加转换到数据库 * @param kTrans 转换对象 * @param uId 用户ID * @param customerQuarz 用户自定义的定时策略 * @throws SQLException * @return void */ public void insert(KTrans kTrans, Integer uId, String customerQuarz) throws SQLException{ DSTransactionManager.start(); //补充添加作业信息 //作业基础信息 kTrans.setAddUser(uId); kTrans.setAddTime(new Date()); kTrans.setEditUser(uId); kTrans.setEditTime(new Date()); //作业是否被删除 kTrans.setDelFlag(1); //作业是否启动 kTrans.setTransStatus(2); if (StringUtils.isNotBlank(customerQuarz)){ //添加任务执行的调度策略 KQuartz kQuartz = new KQuartz(); kQuartz.setAddUser(uId); kQuartz.setAddTime(new Date()); kQuartz.setEditUser(uId); kQuartz.setEditTime(new Date()); kQuartz.setDelFlag(1); kQuartz.setQuartzCron(customerQuarz); kQuartz.setQuartzDescription(kTrans.getTransName() + "的定时策略"); KeyHolder kQuartzKey = kQuartzDao.insertReturnKey(kQuartz); //插入调度策略 kTrans.setTransQuartz(kQuartzKey.getInt()); }else if (StringUtils.isBlank(customerQuarz) && new Integer(0).equals(kTrans.getTransQuartz())){ kTrans.setTransQuartz(1); }else if (StringUtils.isBlank(customerQuarz) && kTrans.getTransQuartz() == null){ kTrans.setTransQuartz(1); } kTransDao.insert(kTrans); DSTransactionManager.commit(); } /** * @Title getTrans * @Description 获取转换对象 * @param transId 转换ID * @return * @return KTrans */ public KTrans getTrans(Integer transId){ return kTransDao.single(transId); } /** * @Title update * @Description 更新转换信息 * @param kTrans 转换对象 * @param customerQuarz 用户自定义的定时策略 * @param uId 用户ID * @return void */ public void update(KTrans kTrans, String customerQuarz, Integer uId){ if (StringUtils.isNotBlank(customerQuarz)){ Integer transQuartzId = kTrans.getTransQuartz(); KQuartz kQuartz = kQuartzDao.single(transQuartzId); if (kQuartz.getAddUser() == uId){// 如果更新前选择的是自定义的，这一步要更新 kQuartz.setQuartzCron(customerQuarz); kQuartzDao.updateTemplateById(kQuartz); }else {// 如果更新前选择的是默认的定时策略，这一步要新增一个定时策略 KQuartz kQuartzTemeplate = new KQuartz(); kQuartzTemeplate.setAddUser(uId); kQuartzTemeplate.setAddTime(new Date()); kQuartzTemeplate.setEditUser(uId); kQuartzTemeplate.setEditTime(new Date()); kQuartzTemeplate.setDelFlag(1); kQuartzTemeplate.setQuartzCron(customerQuarz); kQuartzTemeplate.setQuartzDescription(kTrans.getTransName() + "的定时策略"); KeyHolder kQuartzKey = kQuartzDao.insertReturnKey(kQuartzTemeplate); //插入调度策略 kTrans.setTransQuartz(kQuartzKey.getInt()); } } kTransDao.updateTemplateById(kTrans); } /** * @Title start * @Description 启动转换 * @param transId 转换ID * @return void */ public void start(Integer transId){ // 获取到转换对象 KTrans kTrans = kTransDao.unique(transId); // 获取到定时策略对象 KQuartz kQuartz = kQuartzDao.unique(kTrans.getTransQuartz()); // 定时策略 String quartzCron = kQuartz.getQuartzCron(); // 用户ID Integer userId = kTrans.getAddUser(); // 获取Quartz执行的基础信息 Map<String, String> quartzBasic = getQuartzBasic(kTrans); // 获取Quartz的参数 Map<String, Object> quartzParameter = getQuartzParameter(kTrans); // 添加监控 addMonitor(userId, transId); // 添加任务 // 判断转换执行类型 try { if (new Integer(1).equals(kTrans.getTransQuartz())){//如果是只执行一次 QuartzManager.addOnceJob(quartzBasic.get("jobName"), quartzBasic.get("jobGroupName"), quartzBasic.get("triggerName"), quartzBasic.get("triggerGroupName"), TransQuartz.class, quartzParameter); }else {// 如果�