2018-08-27 11:59:21 +08:00

54 lines
1.8 KiB
Java

package com.base.util;
import com.amarsoft.are.ARE;
import com.amarsoft.are.jbo.JBOException;
import com.amarsoft.are.log.Log;
import com.amarsoft.are.util.StringFunction;
import com.amarsoft.awe.util.SqlObject;
import com.amarsoft.awe.util.Transaction;
import com.tenwa.reckon.util.UUIDUtil;
public class QuartzUtil {
private static Log logger=ARE.getLog();
/**
* 新增串行任务日志
* @param startime开始执行时间
* @param method 执行的方法类的全路径 取数据字典{MissionName}
* @param status 执行状态 success,notexecute,error
* @param Message 异常信息 :成功,不执行或方法不存在,失败
*/
public static void insertLog(String startime,String method, String status, String Message, String username) {
Transaction tran = Transaction.createTransaction("als");
try {
String sql = "insert into qrtz_serial_log(id,method_name,status,close_date,inputtime,message,user_name) select '"+UUIDUtil.getUUID()+"','"
+ method + "','" + status + "','"+startime.replaceAll(":", "")+"','"
+ StringFunction.getTodayNow().replaceAll(":", "") + "','" + Message + "','" + username
+ "' from dual";
SqlObject so = new SqlObject(sql);
so.setDebugSql(so.getDebugSql().replaceAll("", ":"));
so.setOriginalSql(so.getOriginalSql().replaceAll("", ":"));
so.setRunSql(so.getRunSql().replaceAll("", ":"));
tran.executeSQL(so);
tran.commit();
} catch (Exception e) {
logger.info(e.getMessage());
logger.info("新增任务日志失败");
e.printStackTrace();
try {
if(tran != null)
tran.rollback();
} catch (JBOException e1) {
e1.printStackTrace();
}
}finally{
try {
if(tran != null){
tran.disConnect();
}
} catch (JBOException e) {
e.printStackTrace();
}
}
}
}