XinYu_LZMES/.svn/pristine/55/55dde7a4926636dc2518e640af8b2b0d084f9552.svn-base

package UIM;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Map;
import java.util.List;
import UIM.Tools;

import UIB.COM.XmlSqlParsersFactory;

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

/**
 * 冷轧成品库钢卷入库管理
 * @author siy
 * @date 2011-08-03
 */
public class UIM010200 extends CoreIComponent {
	/**
	 * 查询待入库钢卷
	 * @param productTime 生产时间 yyyymmdd
	 * @param coilNo 钢卷号
	 * @return CoreReturnObject
	 * @throws SQLException
	 */
	public CoreReturnObject queryCoilsInStock(String productTime,String toproductTime,String coilNo,String flag) throws SQLException
	{
		String sql = XmlSqlParsersFactory.getSql("UIM010200_01.SELECT");
		if(flag.equals("1")){
			sql += " AND LINE_TP = 'L'";
		}
		else if(flag.equals("2")){
			sql += " AND LINE_TP = 'C'";
		}
		return this.getDao("KgDao").ExcuteQuery(sql, new Object[]{productTime,toproductTime,coilNo});
	}
	
	/**
	 * 成品库钢卷入库
	 * @param coilNo 钢卷号
	 * @param yardAddr 垛位
	 * @param entryShift 入库班次
	 * @param entryGroup 入库班组
	 * @param entryDtime 入库时间
	 * @param reg_id 操作人
	 * @return CoreReturnObject
	 * @throws SQLException
	 */
	public CoreReturnObject saveCoilYard(String coilNo,String yardAddr,String entryShift,
			String entryGroup,String entryDtime,String reg_id) throws SQLException
	{
		CoreReturnObject cro = new CoreReturnObject();
		Connection con = null;//pSta.getConnection();
		//判断垛位是否存在
		String sqlYard = "select 1 from c_tbk08_coil_yard t where t.clf_no = C_PKG_UIM.GET_FINALYARDNO_BYYARDFLAG(?)";
		List yardList = this.getDao("KgDao").ExcuteQueryReturnList(sqlYard, new Object[]{yardAddr});
		if(yardList.size() > 0){
			//查询钢卷入库信息
			String sqlEntry = "select COIL_NO from c_tbc02_coil_comm where OLD_SAMPL_NO = ? AND COIL_STAT = '2'";
			
			List listEntry = this.getDao("KgDao").ExcuteQueryReturnList(sqlEntry,new Object[]{coilNo});
			
			if(listEntry.size() == 0){
				cro.setV_errCode(new Integer(1));
				cro.setV_errMsg("此钢卷没有轧制完成,或者已经出库！");
			}
			else{
				//查询钢卷出库信息
				String sqlOut = "select CUR_LOAD_LOC from c_tbc02_coil_comm where OLD_SAMPL_NO = ?";
				List listOut = this.getDao("KgDao").ExcuteQueryReturnList(sqlOut, new Object[]{coilNo});
				
				if(listOut.size() > 0 && !Tools.isEmpty(((Map)(listOut.get(0))).get("CUR_LOAD_LOC"))){
					cro.setV_errCode(new Integer(2));
					cro.setV_errMsg("此钢卷已在垛位中存在！");
				}
				else{
					//将入库操作信息和垛位信息加入冷轧成品公共表
					String sqlucomm = "update c_tbc02_coil_comm set CUR_LOAD_LOC = ?," +
							" CUR_LOAD_LOC_DTIME = TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS')," +
							" YARD_ENTRY_SHIFT = ?, YARD_ENTRY_GROUP = ?, YARD_ENTRY_REG  = ?," +
							" YARD_ENTRY_DTIME = ?, " +
							" YARD_ENTRY_USE_TIME = TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS')" +
							" where OLD_SAMPL_NO = ?";
					this.getDao("KgDao").ExcuteNonQuery(sqlucomm, 
							new Object[]{yardAddr,entryShift,entryGroup,reg_id,entryDtime,coilNo});
					
					//将钢卷信息加入垛位表
//					String sqluyard = "update c_tbk08_coil_yard set COIL_NO = ?, " +
//							"MOD_ID  = ?, MOD_TIME = TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS')" +
//							" where CLF_NO = C_PKG_UIM.GET_YARDNO_BYYARDFLAG(?)";
//					this.getDao("KgDao").ExcuteNonQuery(sqluyard, 
//							new Object[]{coilNo,reg_id,yardAddr});
					
					//入库完成后将入库记录加入移垛记录，便于跟踪钢卷移动记录
					long seq = 0;//移垛记录表主键
					
					String sqlqmaxseq  = "select max(ROLL_SEQ) ROLL_SEQ from c_tbk08_coil_move";
					PreparedStatement pSta =  this.getDao("KgDao").getPreparedStatement(sqlqmaxseq);
					ResultSet rs = pSta.executeQuery();
					con=pSta.getConnection();
					if(rs.next()){
						seq = rs.getLong("ROLL_SEQ")+1;
					}
					rs.close();
					pSta.close();
					con.close();
					
					// 入库类型
					String inType = "";
					String sqlType = "select T.IN_YARD_KIND from C_TBC02_COIL_COMM T where T.OLD_SAMPL_NO = ?";
					pSta = this.getDao("KgDao").getPreparedStatement(
							sqlType);
					pSta.setString(1, coilNo);
					rs = pSta.executeQuery();
					con=pSta.getConnection();
					if (rs.next()) {
						inType = rs.getString("IN_YARD_KIND");
					}
					rs.close();
					pSta.close();
					con.close();
					String sqlimove = "insert into c_tbk08_coil_move T(T.ROLL_SEQ,T.CUR_LOAD_LOC_F,T.CUR_LOAD_LOC_T,T.COIL_NO,T.REG_ID,T.REG_SHIFT,T.REG_GROUP,T.REG_DTIME,T.REG_USE_ID,T.REG_USE_DTIME,MOVE_TYPE)" +
							"VALUES(?,?,?,?,?,?,?,?,?,TO_CHAR(SYSDATE,'YYYYMMDDHH24MISS'),decode(?,'1','02','2','02','3','05','4','05','5','04','6','04','7','04'))";
					this.getDao("KgDao").ExcuteNonQuery(sqlimove, new Object[]{seq,"",yardAddr,coilNo,reg_id,entryShift,entryGroup,entryDtime,reg_id,inType});
				}
			}
		}
		else{
			cro.setV_errCode(new Integer(3));
			cro.setV_errMsg("垛位不存在！");
		}
		
		return cro;
	}
	//select coil_no from c_tbk08_coil_yard where clf_name || clf_row || clf_col || clf_fl = '?'
}