package UIM;

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

import UIB.COM.XmlSqlParsersFactory;

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

/**
 * 冷轧原料库库存数据查询
 * 
 * @author siy
 * @date 2010-08-14
 */
public class UIM010080 extends CoreIComponent {
	/**
	 * 查询原料库库存数据
	 * 
	 * @param list
	 *            参数集
	 * @return CoreReturnObject
	 * @throws SQLException
	 */
	public CoreReturnObject queryYardList(ArrayList list) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String[] queryParams = (String[]) list.get(0);
		String startTime = queryParams[0];// 入库开始时间
		String endTime = queryParams[1];// 入库结束时间
		String specStlGrd = queryParams[2];// 牌号
		String coilWthMin = queryParams[3];// 宽度最小值
		String coilWthMax = queryParams[4];// 宽度最大值
		String coilThkMin = queryParams[5];// 厚度最小值
		String coilThkMax = queryParams[6];// 厚度最大值
		String curLoadLoc = queryParams[7];// 垛位
		String coilNo = queryParams[8];// 钢卷号
		String ordNo = queryParams[9];// 订单号
		String ordFl = queryParams[11];// 订单区分
		String devlmtDate = queryParams[12];// 交货期
		String progCd = queryParams[13];// 进程状态

		if (ordFl.equals("8")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010080_01.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate });
			return cro;
		}

		if (ordFl.equals("1")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010080_02.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate, coilNo,
							specStlGrd, curLoadLoc, coilThkMin, coilThkMax,
							coilWthMin, coilWthMax, startTime, endTime, ordNo,
							progCd, devlmtDate
					});

			return cro;
		}

		if (ordFl.equals("2")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010080_03.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate, coilNo,
							specStlGrd, curLoadLoc, coilThkMin, coilThkMax,
							coilWthMin, coilWthMax, startTime, endTime, ordNo,
							progCd, devlmtDate, coilNo, specStlGrd, curLoadLoc,
							coilThkMin, coilThkMax, coilWthMin, coilWthMax,
							startTime, endTime, ordNo, progCd, devlmtDate
					});

			return cro;
		}

		if (ordFl.equals("3")) {
			String sql = XmlSqlParsersFactory.getSql("UIM010080_04.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate
					});

			return cro;
		}
		return cro;
	}
	public CoreReturnObject querySxYardList(ArrayList list) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		String[] queryParams = (String[]) list.get(0);
		String startTime = queryParams[0];// 入库开始时间
		String endTime = queryParams[1];// 入库结束时间
		String specStlGrd = queryParams[2];// 牌号
		String coilWthMin = queryParams[3];// 宽度最小值
		String coilWthMax = queryParams[4];// 宽度最大值
		String coilThkMin = queryParams[5];// 厚度最小值
		String coilThkMax = queryParams[6];// 厚度最大值
		String curLoadLoc = queryParams[7];// 垛位
		String coilNo = queryParams[8];// 钢卷号
		String ordNo = queryParams[9];// 订单号
		String ordFl = queryParams[11];// 订单区分
		String devlmtDate = queryParams[12];// 交货期
		String progCd = queryParams[13];// 进程状态
		String coiltype = queryParams[14];// 进程状态
		if (ordFl.equals("8")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010081_01.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate,coiltype });
			return cro;
		}

		if (ordFl.equals("1")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010081_02.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate,coiltype, coilNo,
							specStlGrd, curLoadLoc, coilThkMin, coilThkMax,
							coilWthMin, coilWthMax, startTime, endTime, ordNo,
							progCd, devlmtDate,coiltype
					});

			return cro;
		}

		if (ordFl.equals("2")) {

			String sql = XmlSqlParsersFactory.getSql("UIM010081_03.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate,coiltype, coilNo,
							specStlGrd, curLoadLoc, coilThkMin, coilThkMax,
							coilWthMin, coilWthMax, startTime, endTime, ordNo,
							progCd, devlmtDate,coiltype, coilNo, specStlGrd, curLoadLoc,
							coilThkMin, coilThkMax, coilWthMin, coilWthMax,
							startTime, endTime, ordNo, progCd, devlmtDate,coiltype
					});

			return cro;
		}

		if (ordFl.equals("3")) {
			String sql = XmlSqlParsersFactory.getSql("UIM010081_04.SELECT");
			cro = this.getDao("KgDao").ExcuteQuery(
					sql,
					new Object[] { coilNo, specStlGrd, curLoadLoc, coilThkMin,
							coilThkMax, coilWthMin, coilWthMax, startTime,
							endTime, ordNo, progCd, devlmtDate,coiltype
					});

			return cro;
		}
		return cro;
	}
public CoreReturnObject addLzbz(ArrayList<String[]> list)
    throws SQLException {
  CoreReturnObject cro = new CoreReturnObject();
  StringBuffer sqlBuffer = null;
  Map result = this.getDao("KgDao").CoreBeginTranscation();
  try {
    for (int i = 0; i < list.size(); i++) {
      // 判断是否全部选择的标志位
      boolean flag = true;
      String[] param = list.get(i);
      // 查询钢卷公共表中的SHIP_PROG_CD状态
      sqlBuffer = new StringBuffer();
     
   
        // 更新钢卷公共表中的车辆号，排车顺序号
        sqlBuffer = new StringBuffer();
        sqlBuffer.append(" UPDATE C_TBK02_COIL_COMM\n");
          sqlBuffer.append(" SET  \n");
          sqlBuffer.append(" LZREMARK = ?\n");
          sqlBuffer.append(" WHERE OLD_SAMPL_NO =?\n");
        this.getDao("KgDao").ExcuteNonQuery(sqlBuffer.toString(),
            new Object[] { param[0], param[1]});
     
      
    }
    this.getDao("KgDao").CoreCommit(result);
  } catch (Exception ex) {
    this.getDao("KgDao").CoreRollBack(result);
    cro.setV_errCode(-1);
    cro.setV_errMsg("火车排车失败！");
  }
  return cro;
}
}