XinYu_LZMES/.svn/pristine/12/12af71dc06c5479ddba8d7f3094de4001ced9758.svn-base

package UIM;

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

import UIB.COM.XmlSqlParsersFactory;
import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;

public class UIM010340 extends CoreIComponent{
	
	public CoreReturnObject query(String productTime,String coilNo,String flag) throws SQLException
	{
		String sql = XmlSqlParsersFactory.getSql("UIM010340_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,coilNo});
	}
	
	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;
		//判断垛位是否存在
		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});
				//查询垛位是否存在钢卷
				String sqlOut1 = "select OLD_SAMPL_NO  from c_tbc02_coil_comm where CUR_LOAD_LOC = ?";
				List listOut1 = this.getDao("KgDao").ExcuteQueryReturnList(sqlOut1, new Object[]{yardAddr});
				if(listOut.size() > 0 && !Tools.isEmpty(((Map)(listOut.get(0))).get("CUR_LOAD_LOC")))
				{
					cro.setV_errCode(new Integer(2));
					cro.setV_errMsg("此钢卷已在垛位中存在！");
				}
				if(listOut1.size() > 0 && !Tools.isEmpty(((Map)(listOut1.get(0))).get("OLD_SAMPL_NO")))
				{
					cro.setV_errCode(new Integer(1));
					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});
					//将钢卷信息加入垛位表
					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;
	}

}