package UIJ.UIJ05;

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

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

public class UIJ070010 extends CoreIComponent{
	
	CoreReturnObject cro = null;
	StringBuffer sqlucomm=null;
	int max=0;
	ResultSet rs=null;
	
	//查询 供方名称、产线
	public CoreReturnObject Query(String name,String line) {
		sqlucomm = new StringBuffer();
		cro=new CoreReturnObject();
		sqlucomm.append("select " +
				"EGIS_ID,FOR_NAME,PRODUCTION_LINE,NORM,UNIT_PRICE," +
				"TO_CHAR(CREATE_DATE,'YYYY-MM-DD HH24:MI:SS') CREATE_DATE," +
				"TO_CHAR(REVISE_DATE,'YYYY-MM-DD HH24:MI:SS') REVISE_DATE"+
				" from QCM_EGIS where FETTLE=1");
		if(!"".equals(name)){
			sqlucomm.append(" and FOR_NAME='"+name+"'");
		}
		if(!"".equals(line)){
			sqlucomm.append(" and PRODUCTION_LINE='"+line+"'");
		}
		cro=this.getDao("KgDao").ExcuteQuery(sqlucomm.toString());
		return cro;
	}	
	
	//火运供方维护  参数：供方名称、产线、钢座架规格、车皮费单价、序号
	public CoreReturnObject add(ArrayList list){
		cro=new CoreReturnObject();
		sqlucomm=new StringBuffer();
		sqlucomm.append("select max(EGIS_ID) max from QCM_EGIS ");
		try {
			rs = this.getDao("KgDao").ExceuteQueryForResultSet(sqlucomm.toString());
			if (rs.next()) {
				max = rs.getInt("max");
				max++;
			}
		} catch (SQLException e1) {        
			e1.printStackTrace();
		}
		sqlucomm = new StringBuffer();
		sqlucomm.append("insert into QCM_EGIS(EGIS_ID,FOR_NAME,PRODUCTION_LINE,NORM,UNIT_PRICE,CREATE_DATE,FETTLE)"+
						"values("+max+",?,?,?,?,sysdate,1)");
		Object[] obj = new Object[]{list.get(0),list.get(1),list.get(2),list.get(3)};
		try {
			cro=this.getDao("KgDao").ExcuteNonQuery(sqlucomm.toString(),obj);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return cro;
	}
	
	//更新 参数：供方名称、产线、钢座架规格、车皮费单价、序号
	public CoreReturnObject Save(ArrayList BaseChem) {
 
			for (int i = 0; i < BaseChem.size(); i++) {
				ArrayList param= (ArrayList)BaseChem.get(i);
                
				  sqlucomm=new StringBuffer();
			sqlucomm.append("update QCM_EGIS "+
							"set FOR_NAME=?,PRODUCTION_LINE=?,NORM=?,UNIT_PRICE=?,"+
							"REVISE_DATE=sysdate "+
							" where EGIS_ID=?");
			Object[] obj=new Object[]{param.get(0),param.get(1),param.get(2),param.get(3),param.get(4)};
			try {
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlucomm.toString(),obj);
			} catch (SQLException e) {
			e.printStackTrace();
			}
			}
		return cro;
	}
	
	//删除
	public CoreReturnObject remove(String delete){
		sqlucomm.append("update QCM_EGIS SET fettle=0 where EGIS_ID="+delete+"");
		try {
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlucomm.toString(),null);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return cro;
	}
	
	

}