XinYu_LZMES/.svn/pristine/9f/9fe254a30dd4700727e41e4c64cf42e3a67a7d33.svn-base

package UIM;

import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

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

/**
 * 冷轧成品库库存数据查询
 * 
 * @author siy
 * @date 2010-08-19
 */
public class UIM010240 extends CoreIComponent {
	/**
	 * 查询退废出库卷信息
	 * 
	 * @param coilNo
	 *            冷轧卷号
	 * @return CoreReturnObject
	 */
	public CoreReturnObject queryOutCoil(String coilNo) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();

		StringBuffer sqlBuffer = new StringBuffer();
		sqlBuffer.append("select COIL_NO,SPEC_STL_GRD STL_GRD,COIL_THK,\n");
		sqlBuffer
				.append("COIL_WTH,ACT_WGT COIL_WGT,CUR_LOAD_LOC,ORD_NO,ORD_SEQ \n");
		sqlBuffer.append("from c_tbl02_coil_comm where COIL_NO like ?||'%'\n");

		cro = this.getDao("KgDao").ExcuteQuery(sqlBuffer.toString(),
				new Object[] { coilNo });

		return cro;
	}

	/**
	 * 成品库退废出库
	 * 
	 * @param outType
	 *            出库类型
	 * @param coilNo
	 *            钢卷号
	 * @param regId
	 *            操作人
	 * @param trnfShift
	 *            出库班次
	 * @param trnfGroup
	 *            出库班组
	 * @param trnfTime
	 *            出库时间
	 * @return CoreReturnObject
	 */
	public CoreReturnObject saveCoilOut(Integer outType, String coilNo,
			String regId, String trnfShift, String trnfGroup, String trnfTime,
			String trnfRemark) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();

		// 清除原料库垛位表钢卷信息并将原料公共表钢卷垛位信息置为出库
		boolean crs = cleanCoil(outType.intValue(), coilNo, regId, trnfShift,
				trnfGroup, trnfTime, trnfRemark);

		if (crs) {
			// 如果是退回出库，将热轧公共表钢卷数据改为可入库
			if (3 == outType.intValue()) {

			}
			// 修改进程、计划

		}

		return cro;
	}

	/**
	 * 清空钢卷库存信息
	 * 
	 * @param outType
	 *            出库类型
	 * @param coilNo
	 *            钢卷号
	 * @param regId
	 *            出库人
	 * @param trnfShift
	 *            出库班次
	 * @param trnfGroup
	 *            出库班组
	 * @param tranTime
	 *            出库时间
	 * @return boolean
	 */
	private boolean cleanCoil(int outType, String coilNo, String regId,
			String trnfShift, String trnfGroup, String trnfTime,
			String trnfRemark) throws SQLException {
		// 根据钢卷号查询垛位编号
		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());
		} else {
			return false;
		}
		//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 });

		// 修改原料公共表钢卷操作信息
		StringBuffer sql3 = new StringBuffer();
		sql3.append("update c_tbk02_coil_comm set \n");
		sql3.append("coil_stat = '3', --进程状态\n");
		// 如果是上料出库，更新物料进程代码为酸轧卷取待机，如果是退废或退回出库，不处理
		switch (outType) {
		case 1:
			sql3.append("cur_prog_cd = 'PCC', --物料进程代码\n");
			break;
		case 2:
			trnfRemark = "退废";
			break;
		case 3:
			trnfRemark = "退回";
			break;
		}
		sql3.append("trnf_reg = :1, --出库人\n");
		sql3.append("trnf_shift=:2, --出库班次\n");
		sql3.append("trnf_group=:3, --出库班组\n");
		sql3
				.append("trnf_use_time=TO_CHAR(SYSDATE,'YYYYMMDDHH24MIDD'), --出库操作时间\n");
		sql3.append("trnf_dtime=:4,  --出库时间\n");
		sql3.append("trnf_remark=:5 --出库备注\n");
		sql3.append("where coil_no = :6 --钢卷号\n");
		this.getDao("KgDao").ExcuteNonQuery(
				sql3.toString(),
				new Object[] { regId, trnfShift, trnfGroup, trnfTime, coilNo,
						trnfRemark });

		return true;
	}
}