XinYu_RZMES/.svn/pristine/08/08b7508baa23cf6a32cd688227e60e98b3759069.svn-base

package xin.glue.ui.G.G02;


import xin.glue.ui.common.component.PosSiteLog;

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;

/*
 * 生产计划 登录与查询
 * @author TangLiang 唐亮
 * @data 2008.11.7
 */

public class SavePRD_QTY extends PosActivity{
	public String runActivity(PosContext context)
	{
//		从页面获取数据供插入和更新使用
		//String[] status = (String[]) context.get("rowStuts");
		//日期
		String[] PRD_DD = (String[]) context.get("PRD_DD");
		//热轧材块数
		String[] PRD_HOT_COIL_CH_CNT = (String[]) context.get("PRD_HOT_COIL_CH_CNT");
		String[] PRD_HOT_COIL_CH_QTY = (String[]) context.get("PRD_HOT_COIL_CH_QTY");
		//厚板材块数
		String[] PRD_PLAT_CH_CNT = (String[]) context.get("PRD_PLAT_CH_CNT");
		String[] PRD_PLAT_CH_QTY = (String[]) context.get("PRD_PLAT_CH_QTY");
		//冷轧材块数
		String[] PRD_COLD_COIL_CH_CNT = (String[]) context.get("PRD_COLD_COIL_CH_CNT");
		String[] PRD_COLD_COIL_CH_QTY = (String[]) context.get("PRD_COLD_COIL_CH_QTY");
		String[] PRD_OUT_SLAB_CH_CNT = (String[]) context.get("PRD_OUT_SLAB_CH_CNT");
		String[] PRD_OUT_SLAB_CH_QTY = (String[]) context.get("PRD_OUT_SLAB_CH_QTY");
		//热轧材板坯数
		String[] PRD_HOT_COIL_SLAB_QTY = (String[]) context.get("PRD_HOT_COIL_SLAB_QTY");
		//厚板材板坯树
		String[] PRD_PLAT_SLAB_QTY = (String[]) context.get("PRD_PLAT_SLAB_QTY");
		//冷轧材板坯数
		String[] PRD_COLD_COIL_SLAB_QTY = (String[]) context.get("PRD_COLD_COIL_SLAB_QTY");
		String[] PRD_OUT_SLAB_SLAB_QTY = (String[]) context.get("PRD_OUT_SLAB_SLAB_QTY");
		String[] PRD_HOT_COIL_QTY = (String[]) context.get("PRD_HOT_COIL_QTY");
		String[] PRD_COIL_COIL_QTY = (String[]) context.get("PRD_COIL_COIL_QTY");
		//年月
		String[] PRD_YYYYMM = (String[]) context.get("PRD_YYYYMM");
		
		for(int i=0;i<PRD_DD.length;i++){
			
			PosParameter param0 = new PosParameter();
			//判断日期信息是否存在，如果存在的话使用更新，否则使用插入
			param0.setWhereClauseParameter(0, PRD_YYYYMM[i]);
			param0.setWhereClauseParameter(1, PRD_DD[i]);
			
			String sql = "select * from TBG02_SMS_DAILY_REPORT where SUBSTR(REP_DATE,1,6) = ? and SUBSTR(REP_DATE,7,2) = ?";
			
			PosRowSet rowset1 = getDao("mesdao").findByQueryStatement(sql, param0);
			
			if(rowset1.hasNext()){
				//更新
				PosParameter param1 = new PosParameter();
				param1.setWhereClauseParameter(0, PRD_HOT_COIL_CH_CNT[i]);
				param1.setWhereClauseParameter(1, PRD_HOT_COIL_CH_QTY[i]);
				param1.setWhereClauseParameter(2, PRD_PLAT_CH_CNT[i]);
				param1.setWhereClauseParameter(3, PRD_PLAT_CH_QTY[i]);
				param1.setWhereClauseParameter(4, PRD_COLD_COIL_CH_CNT[i]);
				param1.setWhereClauseParameter(5, PRD_COLD_COIL_CH_QTY[i]);
				param1.setWhereClauseParameter(6, PRD_OUT_SLAB_CH_CNT[i]);
				param1.setWhereClauseParameter(7, PRD_OUT_SLAB_CH_QTY[i]);
				param1.setWhereClauseParameter(8, PRD_HOT_COIL_SLAB_QTY[i]);
				param1.setWhereClauseParameter(9, PRD_PLAT_SLAB_QTY[i]);
				param1.setWhereClauseParameter(10,PRD_COLD_COIL_SLAB_QTY[i]);
				param1.setWhereClauseParameter(11,PRD_OUT_SLAB_SLAB_QTY[i]);
				param1.setWhereClauseParameter(12,PRD_HOT_COIL_QTY[i]);
				param1.setWhereClauseParameter(13,PRD_COIL_COIL_QTY[i]);
				param1.setWhereClauseParameter(14,PRD_DD[i]);
				param1.setWhereClauseParameter(15,PRD_YYYYMM[i]); 
				
				getDao("mesdao").update("UIG020200_01.update", param1);
				
//				打印日志 
				PosSiteLog.writeLog(context, getDao("mesdao"),"UIG020200_01.update", param1.getWhereClauseParamters());
				
			}else{
				//插入
				PosParameter param1 = new PosParameter();
				
				param1.setValueParamter(0, PRD_YYYYMM[i]);             
				param1.setValueParamter(1, PRD_DD[i]);                 
				param1.setValueParamter(2, PRD_HOT_COIL_CH_CNT[i]);    
				param1.setValueParamter(3, PRD_HOT_COIL_CH_QTY[i]);    
				param1.setValueParamter(4, PRD_PLAT_CH_CNT[i]);        
				param1.setValueParamter(5, PRD_PLAT_CH_QTY[i]);        
				param1.setValueParamter(6, PRD_COLD_COIL_CH_CNT[i]);   
				param1.setValueParamter(7, PRD_COLD_COIL_CH_QTY[i]);   
				param1.setValueParamter(8, PRD_OUT_SLAB_CH_CNT[i]);    
				param1.setValueParamter(9, PRD_OUT_SLAB_CH_QTY[i]);    
				param1.setValueParamter(10, PRD_HOT_COIL_SLAB_QTY[i]); 
				param1.setValueParamter(11, PRD_PLAT_SLAB_QTY[i]);     
				param1.setValueParamter(12, PRD_COLD_COIL_SLAB_QTY[i]);
				param1.setValueParamter(13, PRD_OUT_SLAB_SLAB_QTY[i]); 
				param1.setValueParamter(14, PRD_HOT_COIL_QTY[i]); 
				param1.setValueParamter(15, PRD_COIL_COIL_QTY[i]); 
 
				
				getDao("mesdao").insert("UIG020200_01.insert", param1);
				
//				打印日志 
				PosSiteLog.writeLog(context, getDao("mesdao"),"UIG020200_01.insert", param1.getValueParameters());
			}
		}
		
		return PosBizControlConstants.SUCCESS;
	}
}