clusterNodeOperation.jsp
3.5 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
<%@ page language="java" contentType="text/html; charset=UTF-8" %>
<%@ page import="weaver.conn.*" %>
<%@ page import="weaver.general.BaseBean" %>
<%@ page import="weaver.hrm.User" %>
<%@ page import="weaver.hrm.HrmUserVarify" %>
<%@ page import="weaver.security.file.FileType" %>
<%@ page import="java.net.*" %>
<%@ page import="java.io.*" %>
<%@ page import="java.util.ArrayList" %>
<%
String clusterupgradelogid = request.getParameter("clusterupgradelogid");
String success = request.getParameter("success");
String reset = request.getParameter("reset");
String uploadtype = request.getParameter("uploadtype");
String filename = request.getParameter("filename");
String freshnode = request.getParameter("freshnode");
User user = HrmUserVarify.getUser (request , response) ;
if(user == null) return ;
RecordSet rs = new RecordSet();
//重置节点升级状态
if("1".equals(reset)) {
rs.executeUpdate("update clusterupgradelog set status='0' where id = ?", clusterupgradelogid);
//rs.execute("update clustersetting set doupgrade = '0' where EXISTS(SELECT 1 from clustersetting t1 left join clusterupgradelog t2 on t2.settingid = t1.id where t2.settingid ='"+clusterupgradelogid+"') and id='"+clusterupgradelogid+"'");
rs.executeQuery("SELECT 1 from clustersetting t1 left join clusterupgradelog t2 on t2.settingid = t1.id where t2.settingid = ?", clusterupgradelogid);
if(rs.next()) {
rs.executeUpdate("update clustersetting set doupgrade = '0' where id = ?", clusterupgradelogid);
}
return;
}
if("1".equals(freshnode)) {
RecordSet rs2 = new RecordSet();
rs2.executeSql("select * from clustersetting where (ismainnode='0' and type='ecology') or (type='emessage') or (type='emobile')");
String clusterid = "";
String clusterids = "";
boolean hassubnode = false;
while(rs2.next()) {
clusterid = rs2.getString("id");
clusterids = clusterids + clusterid + ",";
}
rs2.execute("select 1 from clustersetting t1 left join clusterupgradelog t2 on t1.id=t2.settingid where ((t1.ismainnode='0' and t1.type='ecology') or (t1.type='emessage') or (t1.type='emobile')) and t2.status='0' order by t1.type");
if(rs2.next()){
hassubnode = true;
}
out.print("{\"clusterids\":\""+clusterids+"\",\"hassubnode\":\""+hassubnode+"\"}");
return;
}
if("1".equals(success)) {
rs.executeUpdate("update clusterupgradelog set status='1' where id= ?", clusterupgradelogid);
} else {
rs.executeUpdate("update clusterupgradelog set status='2' where id= ?", clusterupgradelogid);
}
//rs.execute("update clustersetting set doupgrade = '0' where EXISTS(SELECT 1 from clustersetting t1 left join clusterupgradelog t2 on t2.settingid = t1.id where t2.settingid ='"+clusterupgradelogid+"') and id='"+clusterupgradelogid+"'");
rs.executeQuery("SELECT 1 from clustersetting t1 left join clusterupgradelog t2 on t2.settingid = t1.id where t2.settingid = ?", clusterupgradelogid);
if(rs.next()) {
rs.executeUpdate("update clustersetting set doupgrade = '0' where id= ?", clusterupgradelogid);
}
//子节点升级完毕之后删除附件
rs.execute("select * from clusterupgradelog where status='0'");
if(!rs.next()) {
if("upload".equals(uploadtype)) {
String fname = java.net.URLDecoder.decode(filename,"UTF-8");
ArrayList<String> types = new ArrayList<String>();
types.add(".zip");
if(!FileType.validateFileExt(fname,types)) {
return;
}
File file = new File(fname);
if(file.exists()) {
file.delete();
new BaseBean().writeLog("delete file "+fname);
}
}
//升级完成更新时间戳
rs.executeSql("update distribute_info set distributedatetime = ''");
}
%>