package UIM;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;

import UIB.COM.XmlSqlParsersFactory;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;

public class UIM010320 extends CoreIComponent{
	
	public CoreReturnObject query(String coilNo,String fromTime,String toTime) throws SQLException{
		CoreReturnObject cro = new CoreReturnObject();
		String sql = XmlSqlParsersFactory.getSql("UIM010320_01.SELECT");
		cro = this.getDao("KgDao").ExcuteQuery(sql,new Object[]{coilNo,fromTime,toTime});
		return cro;
		}
	public CoreReturnObject out(String coilNo, String regId,
			String trnfShift, String trnfGroup, String trnfTime) throws SQLException{
		
		CoreReturnObject cro = new CoreReturnObject();
	    
		// 根据钢卷号查询垛位编号
		String sql1 = "select clf_no from c_tbk08_coil_yard where coil_no = '"
				+ coilNo + "'";
		ResultSet rs = this.getDao("KgDao").ExceuteQueryForResultSet(sql1);
		
		long yardNo = 0;
		// 如果钢卷在原料库中，查询出相应的垛位编号
		if (rs.next()) {
			yardNo = Long.parseLong(rs.getObject("clf_no").toString());
		} 
		//20131014系统连接异常优化
    	this.getDao("KgDao").closeRs(rs);
		// 根据垛位编号清除钢卷信息
		String sql2 = "update c_tbk08_coil_yard set coil_no = '' where clf_no= ?";
		this.getDao("KgDao").ExcuteNonQuery(sql2, new Object[] { yardNo });
		// 修改公共表钢卷操作信息
		String sql3 = XmlSqlParsersFactory.getSql("UIM010320_01.UPDATE");
		this.getDao("KgDao").ExcuteNonQuery(
				sql3,
				new Object[] { regId, trnfShift, trnfGroup, trnfTime,
						coilNo });
		return cro;
		}
	public CoreReturnObject outCJ(String coilNo, String regId,
			String trnfShift, String trnfGroup, String trnfTime) throws SQLException{
		
		CoreReturnObject cro = new CoreReturnObject();
	    
		// 根据钢卷号查询垛位编号
		String sql1 = "select clf_no from c_tbk08_coil_yard where coil_no = '"
				+ coilNo + "'";
		ResultSet rs = this.getDao("KgDao").ExceuteQueryForResultSet(sql1);
		
		long yardNo = 0;
		// 如果钢卷在原料库中，查询出相应的垛位编号
		if (rs.next()) {
			yardNo = Long.parseLong(rs.getObject("clf_no").toString());
		} 
		//20131014系统连接异常优化
    	this.getDao("KgDao").closeRs(rs);
		// 根据垛位编号清除钢卷信息
		String sql2 = "update c_tbk08_coil_yard set coil_no = '' where clf_no= ?";
		this.getDao("KgDao").ExcuteNonQuery(sql2, new Object[] { yardNo });
		// 修改公共表钢卷操作信息
		String sql3 = XmlSqlParsersFactory.getSql("UIM010320_01.UPDATE");
		this.getDao("KgDao").ExcuteNonQuery(
				sql3,
				new Object[] { regId, trnfShift, trnfGroup, trnfTime,
						coilNo });
		return cro;
		}
}