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 method 执行的方法类的全路径 取数据字典{MissionName}
	 * @param status 执行状态 success,notexecute,error
	 * @param Message 异常信息 ：成功,不执行或方法不存在,失败
	 */
	public static void insertLog(String method, String status, String Message) {
		Transaction tran = Transaction.createTransaction("als");
		try {
			String sql = "insert into qrtz_serial_log(id,method_name,status,close_date,inputtime,message) select '"+UUIDUtil.getUUID()+"','"
					+ method + "','" + status + "','"+StringFunction.getTodayNow().replaceAll(":", "△")+"','"
					+ StringFunction.getTodayNow().replaceAll(":", "△") + "','" + Message
					+ "' 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();
			}
		}
	}
}