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 UIM020060 extends CoreIComponent {

	/**
	 * 查询待包装钢卷
	 * 
	 * @param ordNo
	 * @param ordSeq
	 * @param coilNo
	 * @return
	 * @throws SQLException
	 */
	public CoreReturnObject queryPkgCoil(String ordNo, String ordSeq,
			String coilNo, Integer hasPackaged,String diiver,String startTime,String endTime,String prog) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		if (0 == hasPackaged.intValue()) {
			sql = XmlSqlParsersFactory.getSql("UIM020060_01.SELECT");
		} else {
			sql = XmlSqlParsersFactory.getSql("UIM020060_02.SELECT");
			;
		}
		cro = this.getDao("KgDao").ExcuteQuery(sql,
				new Object[] { ordNo, ordSeq, coilNo,diiver ,startTime,endTime,prog});
		return cro;
	}

	/**
	 * 查询包装钢卷卷数、重量
	 * 
	 * @param packageTime
	 * @return CoreReturnObject
	 * @throws SQLException
	 */
	public CoreReturnObject queryPackageCoil(String packageTime)
			throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String sql = "";
		sql = XmlSqlParsersFactory.getSql("UIM020060_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 = "";
		
		String sql2 = XmlSqlParsersFactory.getSql("UIM020060_03.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];
					
					if(pkgLevel.equals("0")){
						pkgLevel = "";
					}
					//修改包装实绩
					if (0 == hasPackaged.intValue()) {
						sql = XmlSqlParsersFactory.getSql("UIM020060_01.UPDATE");//界面上查出为包装作业待机情况下的数据
					} else if("".equals(pkgLevel)){
						sql = XmlSqlParsersFactory.getSql("UIM020060_04.UPDATE");
					}else{
						sql = XmlSqlParsersFactory.getSql("UIM020060_02.UPDATE");
					}
					this.getDao("KgDao").ExcuteNonQuery(
							sql,
							new Object[] { pkgLevel, pkgShift, pkgGroup,
									pkgReg, coilNo });//包装时间改为系统时间 20180730
					//修改计划状态
//					this.getDao("KgDao").ExcuteNonQuery(sql2,
//							new Object[] { coilNo, 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("UIM020060_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_TBC02_COIL_COMM T SET T.PRINT_TP='YN' WHERE T.OLD_SAMPL_NO='"+coilNo+"'";
			cro = this.getDao("KgDao").ExcuteQuery(sql);
		} catch (Exception e) {
			
		}
		return cro;
	}
}