package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.dao.ProcessServerDao;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.Process_survey;
|
|
public class Process_surveyImpl implements BaseDAO,CallBack {
|
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public boolean add(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//根据进程名字,将服务是否开启的标识符改为0
|
public boolean update(Object obj) {
|
Process_survey process=(Process_survey) obj;
|
String sql="update web_site.tb_Process_survey set ServerFlag="+ProcessServerDao.PROCESS_OFF+" where ProcessName=? and ServerFlag!="+ProcessServerDao.PROCESS_TEMP;
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{process.getProcessName()});
|
return bl;
|
}
|
//界面修改进程名字和超时时间以及进程版本号
|
public boolean updateAll(Object obj){
|
Process_survey process=(Process_survey) obj;
|
String sql="update web_site.tb_Process_survey set note=?,OutTime=? where num=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{process.getNote(),process.getOutTime(),process.getNum()});
|
return bl;
|
}
|
|
//界面修改进程同服务对应的标识位
|
public boolean updateFlag(Object obj){
|
Process_survey process=(Process_survey) obj;
|
String sql="update web_site.tb_Process_survey set ServerFlag=? where ServerName=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{process.getServerFlag(),process.getServerName()});
|
return bl;
|
}
|
|
|
public boolean del(Object obj) {
|
// TODO Auto-generated method stub
|
return false;
|
}
|
//查询所有进程的运行情况
|
public List searchAll() {
|
String sql="select num,ProcessId,ProcessName,ProcessVersion,ProcessTime,Process_starttime,ServerName,ServerFlag,note,Outtime from web_site.tb_Process_survey order by num";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Process_survey process=new Process_survey();
|
process.setNum(rs.getInt("num"));
|
process.setProcessId(rs.getInt("processId"));
|
process.setProcessVersion(rs.getString("processVersion"));
|
process.setProcessName(rs.getString("processName"));
|
process.setProcessTime(rs.getTimestamp("processTime"));
|
process.setProcess_starttime(rs.getTimestamp("process_starttime"));
|
process.setServerName(rs.getString("serverName"));
|
process.setServerFlag(rs.getInt("serverFlag"));
|
process.setNote(DAOHelper.sdf.format(new Date()));
|
process.setProcessName_CN(rs.getString("note"));
|
process.setOutTime(rs.getInt("outTime"));
|
list.add(process);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
public List serchByCondition(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
}
|