XinYu_LZMES/.svn/pristine/08/08d67b4dfa3d1dfc15971753578eb066043001fd.svn-base

package UIK.UIK08;

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

import UIB.COM.XmlSqlParsersFactory;

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

public class UIK080020 extends CoreIComponent {                 //查询
	public CoreReturnObject doQuery(ArrayList<Object> 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 smpSendTime = queryParams[14];//送样时间
		String prodnmCd = queryParams[15];//产品类型
		//System.out.println(startTime+"===="+endTime+"===="+coilThkMin+"==="+coilThkMax);
		String sql = XmlSqlParsersFactory.getSql("UIKO80020_01.SELECT");
		
		cro = this.getDao("KgDao").ExcuteQuery(sql,new Object[]{coilNo,specStlGrd,curLoadLoc,
				coilThkMin,coilThkMax,coilWthMin,coilWthMax,startTime,endTime,ordNo,progCd,
				devlmtDate,smpSendTime,prodnmCd,ordFl});

		return cro;
	}
	
	//出库
	public CoreReturnObject doOut(String oldsamplno,String curloadloc,
			String regID, String trnfShift, String trnfGroup) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();	

		String str="update c_tbc02_coil_comm t " +
				"set t.BEF_LOAD_LOC='"+curloadloc+"',"+
				"t.CUR_LOAD_LOC = ''," +
				"t.COIL_STAT = '3'," +
				"t.TRNF_DTIME = to_char(sysdate,'yyyymmddhh24miss')," +
				"t.TRNF_REG  = '"+regID+"'," +
				"t.TRNF_SHIFT  = '"+trnfShift+"'," +
				"t.TRNF_GROUP = '"+trnfGroup+"'" +
				" WHERE t.OLD_SAMPL_NO = '"+oldsamplno+"'";
		cro = this.getDao("KgDao").ExcuteNonQuery(str);
		//this.ExecuteNonQuery(ccp, CoreInvokeType.Internal);

		String str2="update c_tbk08_coil_yard t set t.COIL_NO  = '' WHERE t.COIL_NO  ='"+oldsamplno+"'";
		cro = this.getDao("KgDao").ExcuteNonQuery(str2);
		
		String str3="insert into c_tbk08_coil_move t "+
       "select (select max(roll_seq) from c_tbk08_coil_move)+1,cur_load_loc  ,''"+
       ",old_sampl_no,'','"+regID+"',to_char(sysdate,'yyyymmddhh24miss') ,'"+trnfShift+"' ,'"+trnfGroup+"'"+
       " ,'"+regID+"' ,to_char(sysdate,'yyyymmddhh24miss') ,''from c_tbc02_coil_comm t1 WHERE t1.OLD_SAMPL_NO ='"+oldsamplno+"'";
				cro = this.getDao("KgDao").ExcuteNonQuery(str3);  
				
		return cro;
	}
	
	//回退
	public CoreReturnObject doBack(String oldsamplno,String curloadloc,
			String regID, String trnfShift, String trnfGroup) throws SQLException {
		CoreReturnObject cro = new CoreReturnObject();
		
		String str="update c_tbc02_coil_comm t " +
		"set t.CUR_LOAD_LOC = '"+curloadloc+"'," +
		"t.COIL_STAT = '2'," +
		"t.TRNF_DTIME = to_char(sysdate,'yyyymmddhh24miss')," +
		"t.TRNF_REG  = '"+regID+"'," +
		"t.TRNF_SHIFT  = '"+trnfShift+"'," +
		"t.TRNF_GROUP = '"+trnfGroup+"'" +" WHERE t.OLD_SAMPL_NO = '"+oldsamplno+"'";
        cro = this.getDao("KgDao").ExcuteNonQuery(str);

        String str2="update c_tbk08_coil_yard t set t.COIL_NO  = '"+oldsamplno+"' WHERE t.COIL_NO  =''";
		cro = this.getDao("KgDao").ExcuteNonQuery(str2);
		
		String str3="insert into c_tbk08_coil_move t "+
	       "select (select max(roll_seq) from c_tbk08_coil_move)+1,cur_load_loc  ,''"+
	       ",old_sampl_no,'','"+regID+"',to_char(sysdate,'yyyymmddhh24miss') ,'"+trnfShift+"' ,'"+trnfGroup+"'"+
	      " ,'"+regID+"' ,to_char(sysdate,'yyyymmddhh24miss') ,''from c_tbc02_coil_comm t1 WHERE t1.OLD_SAMPL_NO ='"+oldsamplno+"'";
		cro = this.getDao("KgDao").ExcuteNonQuery(str3); 
					
		return cro;
	}

	//修改
	public CoreReturnObject DoUpdate(String oldsamplno,String curloadloc,String coilstat) throws SQLException
{
	CoreReturnObject cro = new CoreReturnObject();					

	String sqlQuery	="update c_tbc02_coil_comm t  set t.CUR_LOAD_LOC = '"+curloadloc+"',"+
	        " t.COIL_STAT = '"+coilstat+"'" +
			" where t.OLD_SAMPL_NO = '"+oldsamplno+"'";
	
	//Object[] obj = new Object[]{oldsamplno,curloadloc,coilstat};
	
	cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery);	
	
	return cro;
}
}