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;
	}

}