CronScheduleLogDao.java
3.97 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
package com.sitech.ibnms.config.sync.db.dao;
import com.sitech.ibnms.util.BaseDao;
import com.sitech.ismp.messageObject.AgentSyncObject;
import com.sitech.ismp.messageObject.ScheduleLog;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class CronScheduleLogDao extends BaseDao {
public void insertTbLogSchedule(Map<String,String> schLog){
try{
String beginTime = schLog.get("BEGIN_TIME");
String endTime = schLog.get("END_TIME");
String nextFireTime = schLog.get("NEXT_FIRE_TIME");
StringBuffer sql = new StringBuffer();
sql.append("insert into tb_log_schedule(guid,sch_id,seq,trigger_type,");
String beginDate = "";
String endDate = "";
if(null!=beginTime && !"".equals(beginTime.trim())){
sql.append("begin_time,");
beginDate = "to_date('"+schLog.get("BEGIN_TIME")+"','yyyy-mm-dd hh24:mi:ss'),";
}
if(null!=endTime && !"".equals(endTime.trim())){
sql.append("end_time,");
endDate = "to_date('"+schLog.get("END_TIME")+"','yyyy-mm-dd hh24:mi:ss'),";
}
sql.append("db_time,operate_type,next_fire_time) ");
sql.append(" values('"+schLog.get("REQ_ID")+"','"+schLog.get("SCH_ID")+"',"+schLog.get("SEQ")+",'"+schLog.get("TRIGGER_TYPE")+"',");
sql.append(beginDate).append(endDate);
sql.append("SYSDATE,'"+schLog.get("OPR_TYPE")+"'");
if(null==nextFireTime || "".equals(nextFireTime)){
nextFireTime = "sysdate";
}else{
nextFireTime = " to_date('"+nextFireTime+"','yyyy-mm-dd hh24:mi:ss') ";
}
sql.append(","+nextFireTime);
sql.append(")");
sqlmapClient.insert("insertTbLogSchedule",sql.toString());
}catch (Exception e){
error.error("Exception while insertTbLogSchedule", e);
}
}
public void insertTbLogScheduleDetail(Map<String,String> schLog){
try{
sqlmapClient.insert("insertTbLogScheduleDetail",schLog);
}catch (Exception e){
error.error("Exception while insertTbLogScheduleDetail", e);
}
}
public void updateTbLogScheduleEndTimeAndScrStatus(Map<String,String> schLog){
try{
sqlmapClient.update("updateTbLogScheduleEndTimeAndScrStatus",schLog);
}catch (Exception e){
error.error("Exception while updateTbLogSchedule", e);
}
}
public void updateTbLogScheduleNextFireTime(Map<String,String> schLog){
try{
sqlmapClient.update("updateTbLogScheduleNextFireTime",schLog);
}catch (Exception e){
error.error("Exception while updateTbLogScheduleNextFireTime", e);
}
}
public void updateTbCCCrontabTaskHostStatus(Map<String,String> schLog){
try{
sqlmapClient.update("updateTbCCCrontabTaskHostStatus",schLog);
}catch (Exception e){
error.error("Exception while updateTbCCCrontabTaskHostStatus", e);
}
}
public void updateTbCCCrontabTaskHostDelFlag(Map<String,String> schLog){
try{
sqlmapClient.update("updateTbCCCrontabTaskHostDelFlag",schLog);
}catch (Exception e){
error.error("Exception while updateTbCCCrontabTaskHostDelFlag", e);
}
}
public void updateTbCCCrontabTaskHostScriptSyncStatus(Map<String,String> schLog){
try{
sqlmapClient.update("updateTbCCCrontabTaskHostScriptSyncStatus",schLog);
}catch (Exception e){
error.error("Exception while updateTbCCCrontabTaskHostScriptSyncStatus", e);
}
}
public void updateCronAttachHostStatus(Map<String,String> schLog){
try{
sqlmapClient.update("updateCronAttachHostStatus",schLog);
}catch (Exception e){
error.error("Exception while updateCronAttachHostStatus", e);
}
}
}