/**
 * 
 */
package com.ezparking.gprs;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

/**
 * @author qwsun
 * 
 */
public class GPRSService
{
	public Boolean insertGPRS(GPRSModel model)
	{
		Integer row = Integer.valueOf(0);

		Connection conn = GPRSDBUtil.getConn();

		StringBuffer sqlBuffer = new StringBuffer("INSERT INTO \"tbl_ModuleData\" (");
		sqlBuffer.append("\"OriginalData_HEX\", \"CityID_HEX\", \"CountyID_HEX\", \"CommitteeID_HEX\", \"ParkID_HEX\", \"BuildingID_HEX\", \"BuildingAttrID_HEX\", \"BuildingNO_HEX\", ");
		sqlBuffer.append("\"ModuleEntranceType_HEX\", \"ModuleType_HEX\", \"Memo_HEX\", \"RouterID_HEX\", \"ModuleID_HEX\", \"Status_HEX\", \"HorizonValue_HEX\", \"VerticalValue_HEX\", ");		
		sqlBuffer.append("\"Hour_HEX\", \"Minute_HEX\", \"Second_HEX\", \"GPRSSignal_HEX\", \"CityID\", \"CountyID\", \"CommitteeID\", \"ParkID\", \"BuildingID\", \"BuildingAttrID\", \"BuildingNO\", ");		
		sqlBuffer.append("\"ModuleEntranceType\", \"ModuleType\", \"Memo\", \"RouterID\", \"ModuleID\", \"Status\", \"HorizonValue\", \"VerticalValue\", \"Hour\", \"Minute\", \"Second\", \"GPRSSignal\", \"UDT\")");
		sqlBuffer.append("VALUES (?,?,?,?,?, ?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,to_char(now(),'YYYY-MM-dd HH24:MI:SS'))");

		PreparedStatement pstmt = GPRSDBUtil.getPreparedStatement(conn, sqlBuffer.toString());
		try
		{
			pstmt.setString(1, model.getOriginalData_HEX());
			pstmt.setString(2, model.getCityID_HEX());
			pstmt.setString(3, model.getCountyID_HEX());
			pstmt.setString(4, model.getCommitteeID_HEX());
			pstmt.setString(5, model.getParkID_HEX());
			pstmt.setString(6, model.getBuildingID_HEX());
			pstmt.setString(7, model.getBuildingAttrID_HEX());
			pstmt.setString(8, model.getBuildingNO_HEX());
			pstmt.setString(9, model.getModuleEntranceType_HEX());
			pstmt.setString(10, model.getModuleType_HEX());
			pstmt.setString(11, model.getMemo_HEX());
			pstmt.setString(12, model.getRouterID_HEX());
			pstmt.setString(13, model.getModuleID_HEX());
			pstmt.setString(14, model.getStatus_HEX());
			pstmt.setString(15, model.getHorizonValue_HEX());
			pstmt.setString(16, model.getVerticalValue_HEX());
			pstmt.setString(17, model.getHour_HEX());
			pstmt.setString(18, model.getMinute_HEX());
			pstmt.setString(19, model.getSecond_HEX());
			pstmt.setString(20, model.getgPRSSignal_HEX());
			pstmt.setString(21, model.getCityID());
			pstmt.setString(22, model.getCountyID());
			pstmt.setString(23, model.getCommitteeID());
			pstmt.setString(24, model.getParkID());
			pstmt.setString(25, model.getBuildingID());
			pstmt.setString(26, model.getBuildingAttrID());
			pstmt.setString(27, model.getBuildingNO());
			pstmt.setString(28, model.getModuleEntranceType());
			pstmt.setString(29, model.getModuleType());
			pstmt.setString(30, model.getMemo());
			pstmt.setString(31, model.getRouterID());
			pstmt.setString(32, model.getModuleID());
			pstmt.setString(33, model.getStatus());
			pstmt.setString(34, model.getHorizonValue());
			pstmt.setString(35, model.getVerticalValue());
			pstmt.setString(36, model.getHour());
			pstmt.setString(37, model.getMinute());		
			pstmt.setString(38, model.getSecond());
			pstmt.setString(39, model.getGPRSSignal());
			
			row = Integer.valueOf(pstmt.executeUpdate());
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			GPRSDBUtil.close(conn, pstmt, null);
		}
		return Boolean.valueOf(row.intValue() > 0);
	}

	public List<GPRSModel> listModel()
	{
		Connection conn = GPRSDBUtil.getConn();
		StringBuffer sqlBuffer = new StringBuffer(
				"SELECT * FROM \"tbl_ModuleData\" ORDER BY \"UDT\" desc");

		List<GPRSModel> modelList = new ArrayList<GPRSModel>();
		PreparedStatement pstmt = GPRSDBUtil.getPreparedStatement(conn, sqlBuffer.toString());
		try
		{
			ResultSet result = pstmt.executeQuery();
			while (result.next())
			{
				GPRSModel model = new GPRSModel();
				model.setOriginalData_HEX(result.getString("OriginalData_HEX"));
				model.setCityID_HEX(result.getString("CityID_HEX"));
				model.setCountyID_HEX(result.getString("CountyID_HEX"));
				model.setCommitteeID_HEX(result.getString("CommitteeID_HEX"));
				model.setParkID_HEX(result.getString("ParkID_HEX"));
				model.setBuildingID_HEX(result.getString("BuildingID_HEX"));
				model.setBuildingAttrID_HEX(result.getString("BuildingAttrID_HEX"));
				model.setBuildingNO_HEX(result.getString("BuildingNO_HEX"));
				model.setModuleEntranceType_HEX(result.getString("ModuleEntranceType_HEX"));
				model.setModuleType_HEX(result.getString("ModuleType_HEX"));
				model.setMemo_HEX(result.getString("Memo_HEX"));
				model.setRouterID_HEX(result.getString("RouterID_HEX"));
				model.setModuleID_HEX(result.getString("ModuleID_HEX"));
				model.setStatus_HEX(result.getString("Status_HEX"));
				model.setHorizonValue_HEX(result.getString("HorizonValue_HEX"));
				model.setVerticalValue_HEX(result.getString("VerticalValue_HEX"));
				model.setHour_HEX(result.getString("Hour_HEX"));
				model.setMinute_HEX(result.getString("Minute_HEX"));
				model.setSecond_HEX(result.getString("Second_HEX"));
				model.setgPRSSignal_HEX(result.getString("GPRSSignal_HEX"));
				model.setUDT(result.getString("UDT"));
				modelList.add(model);
			}
			return modelList;
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			GPRSDBUtil.close(conn, pstmt, null);
		}
		return modelList;
	}
	
	public List<TblModule> listTblModule()
	{
		Connection conn = GPRSDBUtil.getConn();
		
		StringBuffer sqlBuffer = new StringBuffer(
				"SELECT * FROM \"tbl_Module\" ORDER BY \"UDT\" desc");		
		
		List<TblModule> moduleList = new ArrayList<TblModule>();
		PreparedStatement pstmt = GPRSDBUtil.getPreparedStatement(conn, sqlBuffer.toString());
		try
		{
			ResultSet result = pstmt.executeQuery();
			while (result.next())
			{
				TblModule model = new TblModule();
				model.setId(result.getInt("ID"));
				model.setCityID(result.getString("CityID"));			
				model.setCountyID(result.getString("CountyID"));			
				model.setCommitteeID(result.getString("CommitteeID"));			
				model.setParkID("ParkID");			
				model.setBuildingID("BuildingID");			
				model.setBuildingAttrID("BuildingAttrID");			
				model.setBuildingNO("BuildingNO");			
				model.setModuleEntranceType("ModuleEntranceType");			
				model.setModuleType("ModuleType");			
				model.setMemo("Memo");			
				model.setRouterID("RouterID");			
				model.setModuleID("ModuleID");			
				model.setRemark("Remark");			
				model.setStatus(result.getInt("Status"));			
				model.setUdt(result.getString("UDT"));
				
				moduleList.add(model);
			}
			return moduleList;
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			GPRSDBUtil.close(conn, pstmt, null);
		}
		return moduleList;		
	}
	
	public Boolean updateTblModuleByModuleID(String moduleID, Integer status)
	{
		Integer row = Integer.valueOf(0);
		Connection conn = GPRSDBUtil.getConn();
		StringBuffer sqlBuffer = new StringBuffer("UPDATE \"tbl_Module\" SET \"Status\"=?,\"UDT\"=now() WHERE \"ModuleID\"=?");
		PreparedStatement pstmt = GPRSDBUtil.getPreparedStatement(conn, sqlBuffer.toString());
		try
		{
			pstmt.setInt(1, status);
			pstmt.setString(2, moduleID);
			
			pstmt.executeUpdate();
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			GPRSDBUtil.close(conn, pstmt, null);
		}
		return Boolean.valueOf(row.intValue() > 0);					
	}
	
	public Boolean updateTblModule(GPRSModel model)
	{
		Integer row = Integer.valueOf(0);
		
		Connection conn = GPRSDBUtil.getConn();

		StringBuffer sqlBuffer = new StringBuffer("UPDATE \"tbl_Module\" SET \"Status\"=?, \"UDT\"=now() ");
		sqlBuffer.append("WHERE \"CityID\"=? AND \"CountyID\"=? AND \"CommitteeID\"=? AND \"ParkID\"=? AND \"BuildingID\"=? AND \"BuildingAttrID\"=? AND \"BuildingNO\"=? AND \"ModuleEntranceType\"=? ");		
		sqlBuffer.append("AND \"ModuleType\"=? AND \"Memo\"=? AND \"RouterID\"=? AND \"ModuleID\"=?");	
	
		PreparedStatement pstmt = GPRSDBUtil.getPreparedStatement(conn, sqlBuffer.toString());
		try
		{
			pstmt.setInt(1, Integer.valueOf(model.getStatus()));
			pstmt.setString(2, model.getCityID());
			pstmt.setString(3, model.getCountyID());
			pstmt.setString(4, model.getCommitteeID());
			pstmt.setString(5, model.getParkID());
			pstmt.setString(6, model.getBuildingID());
			pstmt.setString(7, model.getBuildingAttrID());
			pstmt.setString(8, model.getBuildingNO());
			pstmt.setString(9, model.getModuleEntranceType());
			pstmt.setString(10, model.getModuleType());
			pstmt.setString(11, model.getMemo());
			pstmt.setString(12, model.getRouterID());
			pstmt.setString(13, model.getModuleID());			
			
			row = Integer.valueOf(pstmt.executeUpdate());
		}
		catch (Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			GPRSDBUtil.close(conn, pstmt, null);
		}
		return Boolean.valueOf(row.intValue() > 0);		
	}
}