package UIM.UIM02;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import UIB.COM.XmlSqlParsersFactory;

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

/**
 * 包装作业管理
 * 
 * @author siy
 * @date 2010-12-22
 */
public class UIM020020 extends CoreIComponent {

	/**
	 * 查询待包装钢卷
	 * 
	 * @param ordNo
	 * @param ordSeq
	 * @param coilNo
	 * @return
	 * @throws SQLException
	 */
	public CoreReturnObject queryPkgCoil(String ordNo, String ordSeq,
			String coilNo, Integer hasPackaged,String ispack) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		if(0 == hasPackaged.intValue()){
			sql = XmlSqlParsersFactory.getSql("UIM020020_01.SELECT");
		}
		else{
			sql = XmlSqlParsersFactory.getSql("UIM020020_02.SELECT");;
		}
		cro = this.getDao("KgDao").ExcuteQuery(sql,
				new Object[] { ordNo, ordSeq, coilNo });
		return cro;
	}
	public CoreReturnObject queryPkgCoilSx(String ordNo, String ordSeq,
			String coilNo, Integer hasPackaged,String ispack) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		if(ispack.equals("1"))
		{
			sql = XmlSqlParsersFactory.getSql("UIM020020_06.SELECT");
		}
		else{
		if(0 == hasPackaged.intValue()){
			sql = XmlSqlParsersFactory.getSql("UIM020020_04.SELECT");
		}
		else{
			sql = XmlSqlParsersFactory.getSql("UIM020020_05.SELECT");;
		}
		}
		cro = this.getDao("KgDao").ExcuteQuery(sql,
				new Object[] { ordNo, ordSeq, coilNo });
		return cro;
	}
	
	/**
	 * 查询包装钢卷卷数、重量
	 * create by 张正  2011-02-18 15:30
	 * @param packageTime
	 * @return CoreReturnObject
	 * @throws SQLException
	 */
	public CoreReturnObject queryPackageCoil(String packageTime) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		sql = XmlSqlParsersFactory.getSql("UIM020020_03.SELECT");		
		cro = this.getDao("KgDao").ExcuteQuery(sql,
				new Object[] { packageTime });
		return cro;
	}
	
	
	/**
	 * 包装作业
	 * 
	 * @param pkgCoils
	 * @param pkgShift
	 * @param pkgGroup
	 * @param pkgReg
	 * @param pkgDtime
	 * @return
	 * @throws SQLException
	 */
	public CoreReturnObject savePkgCoil(ArrayList pkgCoils, String pkgShift,
			String pkgGroup, String pkgReg, String pkgDtime, Integer hasPackaged)
			throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		if(0 == hasPackaged.intValue()){
			sql = XmlSqlParsersFactory.getSql("UIM020020_01.UPDATE");
		}
		else{
			sql = XmlSqlParsersFactory.getSql("UIM020020_02.UPDATE");
		}
		Map result = this.getDao("KgDao").CoreBeginTranscation();
		try {
			if (pkgCoils != null) {
				for (int i = 0; i < pkgCoils.size(); i++) {
					String[] pkgCoil = (String[]) pkgCoils.get(i);
					String coilNo = pkgCoil[0];
					String pkgLevel = pkgCoil[1];
					this.getDao("KgDao").ExcuteNonQuery(
							sql,
							new Object[] { pkgLevel, pkgShift, pkgGroup,
									pkgReg, coilNo });
				}
			}
			this.getDao("KgDao").CoreCommit(result);
		} catch (Exception ex) {
			System.out.println(ex);
			this.getDao("KgDao").CoreRollBack(result);
			cro.setV_errCode(-1);
			cro.setV_errMsg("包装作业保存失败！");
		}

		return cro;
	}

	/**
	 * 查询包装方法
	 * 
	 * @return
	 * @throws SQLException
	 */
	public CoreReturnObject queryPkgType() throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = XmlSqlParsersFactory.getSql("UIM020020_11.SELECT");
		List list = this.getDao("KgDao").ExcuteQueryReturnList(sql,
				new Object[] {});

		cro.setResult(list);
		return cro;
	}
	public CoreReturnObject updateColor(String coilNo) throws SQLException{
		CoreReturnObject cro = new CoreReturnObject();
		String sql="";
		try {
			//20131011
			sql ="UPDATE C_TBL02_COIL_COMM T SET T.PRINT_TP='YN' WHERE T.COIL_NO='"+coilNo+"'";
			cro = this.getDao("KgDao").ExcuteQuery(sql);
		} catch (Exception e) {
			
		}
		return cro;
	}
}