package xin.glue.ui.H.H05;

import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRowSet;

/*
 * desc:
 * author:王小炎
 * date:2008-9-20
 */
public class PosSaveCraneOrder extends PosActivity
{
	public String runActivity(PosContext context)
	{
//		从页面获取参数数据，供更新页面使用
		String[] fromAddress = (String[])context.get("FROM_ADDR");
		String[] coilNo = (String[])context.get("COIL_NO");
		String[] craneNo = (String[])context.get("CR_NO");
		String[] toAddress = (String[])context.get("TO_ADDR");
		
		String ordStat = "1";
		
//		查询结果如果已经有值，则进行修改操作，否则插入
		String sql = "select * from TBH05_COIL_CRANE_ORDER where FROM_ADDR = ? and 	COIL_NO = ?" +
					"and 	CR_NO = ? and 	TO_ADDR = ? and 	ORD_STAT = ?";
		PosParameter param0 = new PosParameter();
		param0.setWhereClauseParameter(0,fromAddress[0] );
		param0.setWhereClauseParameter(1, coilNo[0]);
		param0.setWhereClauseParameter(2, craneNo[0]);
		param0.setWhereClauseParameter(3, toAddress[0]);
		param0.setWhereClauseParameter(4, ordStat);

		PosRowSet rowset0 = getDao("mesdao").findByQueryStatement(sql, param0);
		
		PosParameter param1 = new PosParameter();
		
		if(rowset0.hasNext())
		{
			param1.setWhereClauseParameter(0,craneNo[0]);
			param1.setWhereClauseParameter(1,coilNo[0]);
			param1.setWhereClauseParameter(2,fromAddress[0]);
			param1.setWhereClauseParameter(3,toAddress[0]);
			
			getDao("mesdao").update("UIH050020_01.update", param1);
		}
		else
		{
			param1.setValueParamter(0,(fromAddress[0]).substring(0, 2));
			param1.setValueParamter(1,craneNo[0]);
			param1.setValueParamter(2,coilNo[0]);
			param1.setValueParamter(3,fromAddress[0]);
			param1.setValueParamter(4,toAddress[0]);
			
			getDao("mesdao").insert("UIH050020_01.insert",param1);
		}
		return PosBizControlConstants.SUCCESS;
	}

}