GZ/nwyj/.svn/pristine/be/befb7860c2396dc11d7d5b33f022f110a749c61d.svn-base

package com.sinosoft.em.response.equipment.records.service;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import javax.ws.rs.POST;
import javax.ws.rs.Path;
import javax.ws.rs.ProduceMime;

import com.persistence.DbConnection;
import com.sinosoft.lz.system.Utils;

@Path("EquipAllotUpdateEquipState")
public class EquipAllotUpdateEquipState {
	
	@POST
	@ProduceMime("application/json")
	@Path("/updateEquipStateToBusy/")
	public String updateEquipStateToBusy(String param){//修改应急装备的状态
		//param = param.toString().split("=")[1];
		//String sql="update EMC_AM_GENERATOR_CAR set IS_USED='2' , USED_STAT='2' where FD_OBJECTID='"+param+"' and is_del='0'";
		
		String equipId = Utils.getParameter("FD_OBJECTID", param) == null ? "" : Utils.getParameter("FD_OBJECTID", param);//装备ID
		String equipType = Utils.getParameter("EQUIPMENT_TYPE", param) == null ? "" : Utils.getParameter("EQUIPMENT_TYPE", param);//装备类型，用于判断sql从哪张表里面查
		String sql = "";
		if("265".equals(equipType)){
			//sql = "select CAR_NUM,IS_USED from EMC_AM_GENERATOR_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_GENERATOR_CAR set IS_USED = '2' , USED_STAT = '2' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//IS_USED = '2'  不可调用
		} else if("266".equals(equipType)){
			//sql = "select NUM,USED_STAT from EMC_AM_GENERATOR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_GENERATOR set USED_STAT = '2' , IS_USED = '2' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//USED_STAT = '2'  调拨中
		} else if("270".equals(equipType)){
			//sql = "select CAR_NUM,USED_STAT from EMC_AM_DINING_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_DINING_CAR set IS_USED = '2' , USED_STAT = '2' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//IS_USED = '2'  不可调用
		} else if("269".equals(equipType)){
			//sql = "select CAR_NUM,USED_STAT from EMC_AM_EMERGENCY_COMMAND_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_EMERGENCY_COMMAND_CAR set USED_STAT = '2' , IS_USED = '2' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//USED_STAT = '2'  调拨中
		}
		
		//System.out.println("******//////////***********"+sql);
		
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		int n = 0;
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			n = pstm.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return "";
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/getEquipRealName/")
	public String getEquipRealName(String param){//修改应急装备的状态
		String equipName = Utils.getParameter("EQUIPMENT_NAME", param) == null ? "" : Utils.getParameter("EQUIPMENT_NAME", param);//装备名称
		String equipType1 = Utils.getParameter("EQUIPMENT_TYPE", param) == null ? "" : Utils.getParameter("EQUIPMENT_TYPE", param);//装备类型，用于判断sql从哪张表里面查
		String sql = "";
		if("265".equals(equipType1)){
			sql = "select CAR_NAME from EMC_AM_GENERATOR_CAR where FD_OBJECTID='"+equipName+"'";
		} else if("266".equals(equipType1)){
			sql = "select NAME from EMC_AM_GENERATOR where FD_OBJECTID='"+equipName+"'";
		} else if("270".equals(equipType1)){
			sql = "select CAR_NAME from EMC_AM_DINING_CAR where FD_OBJECTID='"+equipName+"'";
		} else if("269".equals(equipType1)){
			sql = "select CAR_NAME from EMC_AM_EMERGENCY_COMMAND_CAR where FD_OBJECTID='"+equipName+"'";
		}
		System.out.println("**************"+sql);
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
//		sb.append("{\"result\":[");
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			rs = pstm.executeQuery();
			while(rs.next()){
				if("265".equals(equipType1)){
					sb.append(rs.getString("CAR_NAME"));
				} else if("266".equals(equipType1)){
					sb.append(rs.getString("NAME"));
				} else if("270".equals(equipType1)){
					sb.append(rs.getString("CAR_NAME"));
				} else if("269".equals(equipType1)){
					sb.append( rs.getString("CAR_NAME"));
				}
			}
//			sb.append("]}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return sb.toString();
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/updateEquipStateToFree/")
	public String updateEquipStateToFree(String param){//修改应急装备的状态
		//param = param.toString().split("=")[1];
		//String sql="update EMC_AM_GENERATOR_CAR set IS_USED='2' , USED_STAT='2' where FD_OBJECTID='"+param+"' and is_del='0'";
		
		String equipId = Utils.getParameter("FD_OBJECTID", param) == null ? "" : Utils.getParameter("FD_OBJECTID", param);//装备ID
		String equipType = Utils.getParameter("EQUIPMENT_TYPE", param) == null ? "" : Utils.getParameter("EQUIPMENT_TYPE", param);//装备类型，用于判断sql从哪张表里面查
		String sql = "";
		if("265".equals(equipType)){
			//sql = "select CAR_NUM,IS_USED from EMC_AM_GENERATOR_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_GENERATOR_CAR set IS_USED = '1' , USED_STAT = '1' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//IS_USED = '2'  不可调用
		} else if("266".equals(equipType)){
			//sql = "select NUM,USED_STAT from EMC_AM_GENERATOR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_GENERATOR set USED_STAT = '1' , IS_USED = '1' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//USED_STAT = '2'  调拨中
		} else if("270".equals(equipType)){
			//sql = "select CAR_NUM,USED_STAT from EMC_AM_DINING_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_DINING_CAR set IS_USED = '1' , USED_STAT = '1' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//IS_USED = '2'  不可调用
		} else if("269".equals(equipType)){
			//sql = "select CAR_NUM,USED_STAT from EMC_AM_EMERGENCY_COMMAND_CAR where FD_OBJECTID='"+equipId+"'";
			sql = "update EMC_AM_EMERGENCY_COMMAND_CAR set USED_STAT = '1' , IS_USED = '1' where FD_OBJECTID = '"+equipId+"' and is_del='0'";//USED_STAT = '2'  调拨中
		}
		
		//System.out.println("******//////////***********"+sql);
		
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		int n = 0;
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			n = pstm.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return "";
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/updateEquipDemandStateTo56/")
	public String updateEquipDemandStateTo56(String param){//修改应急装备的状态
		String taskName = Utils.getParameter("FD_OBJECTID", param) == null ? "" : Utils.getParameter("FD_OBJECTID", param);//装备ID
		String sql = "update ECM_EM_EQUIPMENT_DEMAND set AUDIT_STATE = '56' where FD_OBJECTID = '"+taskName+"' and is_del='0'";
		
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		int n = 0;
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			n = pstm.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return "";
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/updateEquipDemandStateTo57/")
	public String updateEquipDemandStateTo57(String param){//修改应急装备的状态
		String taskName = Utils.getParameter("FD_OBJECTID", param) == null ? "" : Utils.getParameter("FD_OBJECTID", param);//装备ID
		String sql = "update ECM_EM_EQUIPMENT_DEMAND set AUDIT_STATE = '57' where FD_OBJECTID = '"+taskName+"' and is_del='0'";
		
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		int n = 0;
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			n = pstm.executeUpdate();
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		
		return "";
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/getDeptName/")
	public String getDeptName(String params){			//装备需求详细信息页面用到
		params = Utils.getParameter("DEPT_ID", params) == null ? "" : Utils.getParameter("DEPT_ID", params);
		String sql = "select DEPT_NAME from SYS_DEPARTMENT where DEPT_ID=?";
		//System.out.println("-------------------------------------------------"+sql);
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
		/*List userList = new ArrayList();*/
		sb.append("{\"result\":\"");
		
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, params); 
			rs = pstm.executeQuery();
			
			while(rs.next()){
//				sb.append("{\"TEAM_TYPE\":\""+rs.getString("TEAM_TYPE")+"\"},");
				sb.append( rs.getString("DEPT_NAME") );
			}
			sb.append("\"}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		/*String usersJson = JsonPluginsUtil.listToJson(userList);
		Log.info(usersJson);
		return usersJson;*/
//		System.out.println("-------------------------------------------------"+sb.toString());
		return sb.toString();
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/getEquipAmount/")
	public String getEquipAmount(String params){			//装备需求详细信息页面用到
		String equipId = Utils.getParameter("FD_OBJECTID", params) == null ? "" : Utils.getParameter("FD_OBJECTID", params);//装备ID
		String equipType = Utils.getParameter("EQUIPMENT_TYPE", params) == null ? "" : Utils.getParameter("EQUIPMENT_TYPE", params);//装备类型，用于判断sql从哪张表里面查
		String sql = "";
		if("265".equals(equipType)){
			sql = "select CAR_NUM,IS_USED from EMC_AM_GENERATOR_CAR where FD_OBJECTID='"+equipId+"'";
		} else if("266".equals(equipType)){
			sql = "select NUM,USED_STAT from EMC_AM_GENERATOR where FD_OBJECTID='"+equipId+"'";
		} else if("270".equals(equipType)){
			sql = "select CAR_NUM,USED_STAT from EMC_AM_DINING_CAR where FD_OBJECTID='"+equipId+"'";
		} else if("269".equals(equipType)){
			sql = "select CAR_NUM,USED_STAT from EMC_AM_EMERGENCY_COMMAND_CAR where FD_OBJECTID='"+equipId+"'";
		}
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
		/*List userList = new ArrayList();*/
		sb.append("{\"result\":[");
		
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			//pstm.setString(1, params); 
			rs = pstm.executeQuery();
			
			while(rs.next()){
				if("265".equals(equipType)){
					sb.append(rs.getString("CAR_NUM") +","+rs.getString("IS_USED"));
				} else if("266".equals(equipType)){
					sb.append(rs.getString("NUM") +","+rs.getString("USED_STAT"));
				} else if("270".equals(equipType)){
					sb.append(rs.getString("CAR_NUM") +","+rs.getString("USED_STAT"));
				} else if("269".equals(equipType)){
					sb.append( rs.getString("CAR_NUM") +","+rs.getString("USED_STAT"));
				}
			}
			sb.append("]}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		/*String usersJson = JsonPluginsUtil.listToJson(userList);
		Log.info(usersJson);
		return usersJson;*/
		return sb.toString();
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/getSubDeptIds/")
	public String getSubDeptIds(String params){			//装备需求详细信息页面用到
		params = Utils.getParameter("PARENT_ID", params) == null ? "" : Utils.getParameter("PARENT_ID", params);
		String sql = "select DEPT_ID from SYS_DEPARTMENT where PARENT_ID=?";
		//System.out.println("-------------------------------------------------"+sql);
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
		/*List userList = new ArrayList();*/
//		sb.append("{\"result\":\"");
		
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, params); 
			rs = pstm.executeQuery();
			
			while(rs.next()){
				sb.append("'" + rs.getString("DEPT_ID") + "'," );
			}
			sb.deleteCharAt(sb.length()-1);
//			sb.append("\"}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		/*String usersJson = JsonPluginsUtil.listToJson(userList);
		Log.info(usersJson);
		return usersJson;*/
//		System.out.println("-------------------------------------------------"+sb.toString());
		return sb.toString();
	}
	
	@POST
	@ProduceMime("application/json")
	@Path("/getPersonId/")
	public String getPersonId(String params){			//装备需求详细信息页面用到
		String businessId = Utils.getParameter("BUSINESS_ID", params) == null ? "" : Utils.getParameter("BUSINESS_ID", params);
		String state = Utils.getParameter("state", params) == null ? "" : Utils.getParameter("state", params);
		String sql = "select distinct PERSON_ID from ECM_EM_TREATED_HUMAN where BUSINESS_ID=? and STATUES=?";
		//System.out.println("-------------------------------------------------"+sql);
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
		/*List userList = new ArrayList();*/
//		sb.append("{\"result\":\"");
		
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, businessId);
			pstm.setString(2, state);
			rs = pstm.executeQuery();
			
			while(rs.next()){
//				sb.append("{\"TEAM_TYPE\":\""+rs.getString("TEAM_TYPE")+"\"},");
				sb.append(rs.getString("PERSON_ID"));
			}
//			sb.append("\"}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		/*String usersJson = JsonPluginsUtil.listToJson(userList);
		Log.info(usersJson);
		return usersJson;*/
		return sb.toString();
	}
	
	@POST 
	@ProduceMime("application/json")
	@Path("/getNeedUnit/")
	public String getNeedUnit(String params){			//装备需求详细信息页面用到
		params = Utils.getParameter("FD_OBJECTID", params) == null ? "" : Utils.getParameter("FD_OBJECTID", params);
		String sql = "select DEPT_NAME from SYS_DEPARTMENT where DEPT_ID=(select RECIPIENT_DEPARTMENT from ECM_EM_EQUIPMENT_DEMAND where FD_OBJECTID=?)";
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
//		List userList = new ArrayList();
//		sb.append("{\"result\":\"");
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, params); 
			rs = pstm.executeQuery();
			while(rs.next()){
				sb.append( rs.getString("DEPT_NAME") );
			}
//			sb.append("\"}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
		return sb.toString();
	}
	
	@POST 
	@ProduceMime("application/text")
	@Path("/getNextHandlerFrom378/")
	public String getNextHandlerFrom378(String params){			//装备需求详细信息页面用到
		String businessId = Utils.getParameter("BUSINESS_ID", params) == null ? "" : Utils.getParameter("BUSINESS_ID", params);
		String statues = Utils.getParameter("STATUES", params) == null ? "" : Utils.getParameter("STATUES", params);
		String sql = "select top 1 PERSON_ID,PERSON_NAME from ECM_EM_TREATED_HUMAN where BUSINESS_ID=? and STATUES=? order by updatedate desc";
		DbConnection dbConn = new DbConnection();//数据库连接
		Connection conn = null;
		PreparedStatement pstm = null;//sql语句的执行者
		ResultSet rs = null;//结果集
		StringBuffer sb = new StringBuffer();
//		List userList = new ArrayList();
//		sb.append("{\"result\":\"");
		try {
			conn = dbConn.getConnection();
			pstm = conn.prepareStatement(sql);
			pstm.setString(1, businessId); 
			pstm.setString(2, statues);
			rs = pstm.executeQuery();
			while(rs.next()){
				sb.append( rs.getString("PERSON_ID") );
			}
//			sb.append("\"}");
		} catch (SQLException e) {
			e.printStackTrace();
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}finally{
			try {
				if(rs!=null){
					rs.close();}
				if(pstm!=null)
				pstm.close();
				if(conn!=null)
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
//		System.out.println("**************************"+sb.toString());
		return sb.toString();
	}
	
}