package neu.integration.ctic.util;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class GeneralStatUtil {
		public static Map<String,String> getProtocolProgress(){
			String sql = "SELECT (SUM(ip_num_done)/sum(ip_num_total)) as protocolPrograss,rounds  FROM protocol_progress WHERE rounds = (SELECT rounds FROM protocol_progress ORDER BY rounds DESC LIMIT 1)";
			Statement stmt = null;
			String protocolPrograss = null;
			String rounds = null;
			//ResultSet rs_protocol,rs_s7_country,rs_modbus_country = null;
			ResultSet rs = null; 
			PreparedStatement pstmt = null;
			Map<String,String> result= new HashMap<String,String>();
			try{
				Connection conn = DBUtil.getConn("219.216.65.127:3306/scan_progress","root","narata");
				if(conn == null){
					System.out.println("扫描器可视化数据库连接失败！");
				}
				stmt = conn.createStatement();
				rs = DBUtil.executeQuery(stmt, sql);
				while(rs.next()){
					protocolPrograss = rs.getString("protocolPrograss");
					rounds = rs.getString("rounds");
					result.put("protocolPrograss", protocolPrograss);
					result.put("rounds",rounds);
				}
				
				
				DBUtil.close(conn, stmt, pstmt, rs);
				/*	rs_modbus_country.close();*/
				}
				catch(SQLException se){
				      //Handle errors for JDBC
				      se.printStackTrace();
				   }catch(Exception e){
				      //Handle errors for Class.forName
				      e.printStackTrace();
				   }
				return result;
			
		}
}