XinYu_LZMES/.svn/pristine/60/6088e893d870c8296527ad6d5ec25f70517c38e4.svn-base

package UIM.UIM06;

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 UIM.Tools;

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

/**
 * 冷轧中间库钢卷入库管理
 * 
 * @author zsx
 * @date 2017-07-31
 */
public class UIM060030 extends CoreIComponent {
	
	public CoreReturnObject queryCoilsInStock(String productTime,String toproductTime,String coilNo,String flag) throws SQLException
	{
		String sql = XmlSqlParsersFactory.getSql("UIM060030_11.SELECT");
		return this.getDao("KgDao").ExcuteQuery(sql, new Object[]{productTime,toproductTime,coilNo});
	}
	

	public CoreReturnObject saveCoilYardN(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 CLF_NO from c_tbk08_coil_yard "
			+ "where CLF_NAME = substr(?,0,1) "
			+ "and CLF_ROW = substr(?,3,2) "
			+ "and CLF_COL = substr(?,7,2) "
			+ "and CLF_FL = DECODE(substr(?,5,1),'A','1','B','2','C','3','1')";
		List yardList = this.getDao("KgDao")
			.ExcuteQueryReturnList(
					sqlYard,
					new Object[] { yardAddr, yardAddr, yardAddr,
							yardAddr });
		if(yardList.size() > 0){
			
			String chkcoil = "select COIL_NO from c_tbk08_coil_yard "
				+ "where CLF_NAME = substr(?,0,1) "
				+ "and CLF_ROW = substr(?,3,2) "
				+ "and CLF_COL = substr(?,7,2) "
				+ "and CLF_FL = DECODE(substr(?,5,1),'A','1','B','2','C','3','1') AND COIL_NO IS NOT NULL";
			List coilList = this.getDao("KgDao")
				.ExcuteQueryReturnList(
						chkcoil,
						new Object[] { yardAddr, yardAddr, yardAddr,
								yardAddr });
			String chkcoil2 = "select COIL_NO from C_TBL02_COIL_COMM where CUR_LOAD_LOC = ?";
			List coilList2 = this.getDao("KgDao")
				.ExcuteQueryReturnList(
						chkcoil2,
						new Object[] { yardAddr });
			if(coilList.size() > 0||coilList2.size()>0)
			{
				cro.setV_errCode(new Integer(-1));
				cro.setV_errMsg("垛位被占用！");
			}
			else
			{
			//查询钢卷入库信息
			String sqlEntry = "select COIL_NO from c_tbL02_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_tbL02_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_tbL02_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_TBL02_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;
	}
}