XinYu_RZMES/.svn/pristine/36/36d06dfba857216e0dd176e51281e98dbbe20bfb.svn-base

package xin.glue.ui.H.H01;

/********
根据轧钢厂的要求，把能耗和停轧的相关数据录入到系统
TL 2009.10.12
 ************/

import com.posdata.glue.biz.activity.PosActivity;
import com.posdata.glue.biz.constants.PosBizControlConstants;
import com.posdata.glue.biz.control.PosBizControlIF;
import com.posdata.glue.biz.control.PosBizProvider;
import com.posdata.glue.component.PosConstants;
import com.posdata.glue.context.PosContext;
import com.posdata.glue.dao.vo.PosParameter;
import com.posdata.glue.dao.vo.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;
import com.posdata.glue.msg.PosMESMessageImpl;
import com.posdata.glue.msg.PosMessage;


public class saveNH extends PosActivity{
	public String runActivity(PosContext context)
	{
//		从页面获取参数数据，供更新页面使用
		//查询时间
		String[] searchTime = (String[])context.get("searchTime");
		//查询班组
		String[] searchGroup = (String[])context.get("searchGroup");
		//煤气吨能耗
		String[] MQ = (String[])context.get("MQ");
		//电吨能耗
		String[] DIAN = (String[])context.get("DIAN");
		//水吨能耗
		String[] SHUI = (String[])context.get("SHUI");
		//压缩空气
		String[] KQ = (String[])context.get("KQ");
		//辊耗
		String[] GH = (String[])context.get("GH");
		//停轧时间，机械
		String[] JIXIE = (String[])context.get("JIXIE");
		//停轧时间 电器
		String[] DQ = (String[])context.get("DQ");
		//轧钢
		String[] ZG = (String[])context.get("ZG");
		//换辊
		String[] HG = (String[])context.get("HG");
		//检修
		String[] JIANXIU = (String[])context.get("JIANXIU");
		//外部
		String[] WB = (String[])context.get("WB");
		//原成
		String[] YC = (String[])context.get("YC");
		//作业者 REG_ID
		String[] REG_ID = (String[])context.get("REG_ID");
		//作业者 日历时间
		String[] RL = (String[])context.get("RL");
		//作业者 停轧时间
		String[] TZ = (String[])context.get("TZ");
		
		
		
		//这里需要判断各个能耗和停轧时间在当天是否输入过。输入过的只能进行更新操作
		//煤气能耗 1
		if(MQ[0] != null){
			if(MQ[0].equals("")){
				MQ[0] = "0";
			}
			PosParameter param01 = new PosParameter();
			
			param01.setWhereClauseParameter(0, searchTime[0]);
			param01.setWhereClauseParameter(1, searchGroup[0]);
			param01.setWhereClauseParameter(2, "1");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param01);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param1 = new PosParameter();
				
				param1.setWhereClauseParameter(0, MQ[0]);
				param1.setWhereClauseParameter(1, REG_ID[0]);
				param1.setWhereClauseParameter(2, searchTime[0]);
				param1.setWhereClauseParameter(3, "1");
				param1.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param1); 
				
			}else{
				PosParameter param1 = new PosParameter();
				
				param1.setValueParamter(0, searchTime[0]);
				param1.setValueParamter(1, "1");
				param1.setValueParamter(2, searchGroup[0]);
				param1.setValueParamter(3, MQ[0]);
				param1.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param1);
			}
		}
		
		//电吨能耗 2
		if(DIAN[0] != null){
			if(DIAN[0].equals("")){
				DIAN[0] = "0";
			}
			PosParameter param02 = new PosParameter();
			
			param02.setWhereClauseParameter(0, searchTime[0]);
			param02.setWhereClauseParameter(1, searchGroup[0]);
			param02.setWhereClauseParameter(2, "2");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param02);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param2 = new PosParameter();
				
				param2.setWhereClauseParameter(0, DIAN[0]);
				param2.setWhereClauseParameter(1, REG_ID[0]);
				param2.setWhereClauseParameter(2, searchTime[0]);
				param2.setWhereClauseParameter(3, "2");
				param2.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param2); 
				
			}else{

				PosParameter param2 = new PosParameter();
				
				param2.setValueParamter(0, searchTime[0]);
				param2.setValueParamter(1, "2");
				param2.setValueParamter(2, searchGroup[0]);
				param2.setValueParamter(3, DIAN[0]);
				param2.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param2);
			}
		}
		
		//水吨能耗 3
		if(SHUI[0] != null){
			if(SHUI[0].equals("")){
				SHUI[0] = "0";
			}
			PosParameter param03 = new PosParameter();
			
			param03.setWhereClauseParameter(0, searchTime[0]);
			param03.setWhereClauseParameter(1, searchGroup[0]);
			param03.setWhereClauseParameter(2, "3");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param03);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param3 = new PosParameter();
				
				param3.setWhereClauseParameter(0, SHUI[0]);
				param3.setWhereClauseParameter(1, REG_ID[0]);
				param3.setWhereClauseParameter(2, searchTime[0]);
				param3.setWhereClauseParameter(3, "3");
				param3.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param3); 
				
			}else{
				PosParameter param3 = new PosParameter();
				
				param3.setValueParamter(0, searchTime[0]);
				param3.setValueParamter(1, "3");
				param3.setValueParamter(2, searchGroup[0]);
				param3.setValueParamter(3, SHUI[0]);
				param3.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param3);
			}
		}
		
		//压缩空气能耗 4
		if(KQ[0] != null){
			if(KQ[0].equals("")){
				KQ[0] = "0";
			}
			PosParameter param04 = new PosParameter();
			
			param04.setWhereClauseParameter(0, searchTime[0]);
			param04.setWhereClauseParameter(1, searchGroup[0]);
			param04.setWhereClauseParameter(2, "4");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param04);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param4 = new PosParameter();
				
				param4.setWhereClauseParameter(0, KQ[0]);
				param4.setWhereClauseParameter(1, REG_ID[0]);
				param4.setWhereClauseParameter(2, searchTime[0]);
				param4.setWhereClauseParameter(3, "4");
				param4.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param4); 
				
			}else{
				PosParameter param4 = new PosParameter();
				
				param4.setValueParamter(0, searchTime[0]);
				param4.setValueParamter(1, "4");
				param4.setValueParamter(2, searchGroup[0]);
				param4.setValueParamter(3, KQ[0]);
				param4.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param4);
			}
		}
		
		//辊耗的能耗 5
		if(GH[0] != null){
			if(GH[0].equals("")){
				GH[0] = "0";
			}
			PosParameter param05 = new PosParameter();
			
			param05.setWhereClauseParameter(0, searchTime[0]);
			param05.setWhereClauseParameter(1, searchGroup[0]);
			param05.setWhereClauseParameter(2, "5");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param05);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param5 = new PosParameter();
				
				param5.setWhereClauseParameter(0, GH[0]);
				param5.setWhereClauseParameter(1, REG_ID[0]);
				param5.setWhereClauseParameter(2, searchTime[0]);
				param5.setWhereClauseParameter(3, "5");
				param5.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param5); 
				
			}else{
				PosParameter param5 = new PosParameter();
				
				param5.setValueParamter(0, searchTime[0]);
				param5.setValueParamter(1, "5");
				param5.setValueParamter(2, searchGroup[0]);
				param5.setValueParamter(3, GH[0]);
				param5.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param5);
			}
		}
		
		//停轧时间 机械 6
		if(JIXIE[0] != null){
			if(JIXIE[0].equals("")){
				JIXIE[0] = "0";
			}
			PosParameter param06 = new PosParameter();
			
			param06.setWhereClauseParameter(0, searchTime[0]);
			param06.setWhereClauseParameter(1, searchGroup[0]);
			param06.setWhereClauseParameter(2, "6");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param06);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param6 = new PosParameter();
				
				param6.setWhereClauseParameter(0, JIXIE[0]);
				param6.setWhereClauseParameter(1, REG_ID[0]);
				param6.setWhereClauseParameter(2, searchTime[0]);
				param6.setWhereClauseParameter(3, "6");
				param6.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param6); 
				
			}else{
				PosParameter param6 = new PosParameter();
				
				param6.setValueParamter(0, searchTime[0]);
				param6.setValueParamter(1, "6");
				param6.setValueParamter(2, searchGroup[0]);
				param6.setValueParamter(3, JIXIE[0]);
				param6.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param6);
			}
		}
		
		//停轧时间 电器 7
		if(DQ[0] != null){
			if(DQ[0].equals("")){
				DQ[0] = "0";
			}
			PosParameter param07 = new PosParameter();
			
			param07.setWhereClauseParameter(0, searchTime[0]);
			param07.setWhereClauseParameter(1, searchGroup[0]);
			param07.setWhereClauseParameter(2, "7");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param07);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param7 = new PosParameter();
				
				param7.setWhereClauseParameter(0, DQ[0]);
				param7.setWhereClauseParameter(1, REG_ID[0]);
				param7.setWhereClauseParameter(2, searchTime[0]);
				param7.setWhereClauseParameter(3, "7");
				param7.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param7); 
				
			}else{
				PosParameter param7 = new PosParameter();
				
				param7.setValueParamter(0, searchTime[0]);
				param7.setValueParamter(1, "7");
				param7.setValueParamter(2, searchGroup[0]);
				param7.setValueParamter(3, DQ[0]);
				param7.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param7);
			}
		}
		
		//停轧时间 轧钢 8
		if(ZG[0] != null){
			if(ZG[0].equals("")){
				ZG[0] = "0";
			}
			PosParameter param08 = new PosParameter();
			
			param08.setWhereClauseParameter(0, searchTime[0]);
			param08.setWhereClauseParameter(1, searchGroup[0]);
			param08.setWhereClauseParameter(2, "8");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param08);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param8 = new PosParameter();
				
				param8.setWhereClauseParameter(0, ZG[0]);
				param8.setWhereClauseParameter(1, REG_ID[0]);
				param8.setWhereClauseParameter(2, searchTime[0]);
				param8.setWhereClauseParameter(3, "8");
				param8.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param8); 
				
			}else{
				PosParameter param8 = new PosParameter();
				
				param8.setValueParamter(0, searchTime[0]);
				param8.setValueParamter(1, "8");
				param8.setValueParamter(2, searchGroup[0]);
				param8.setValueParamter(3, ZG[0]);
				param8.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param8);
			}
		}
		
		//停轧时间 换辊 9
		if(HG[0] != null){
			if(HG[0].equals("")){
				HG[0] = "0";
			}
			PosParameter param09 = new PosParameter();
			
			param09.setWhereClauseParameter(0, searchTime[0]);
			param09.setWhereClauseParameter(1, searchGroup[0]);
			param09.setWhereClauseParameter(2, "9");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param09);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param9 = new PosParameter();
				
				param9.setWhereClauseParameter(0, HG[0]);
				param9.setWhereClauseParameter(1, REG_ID[0]);
				param9.setWhereClauseParameter(2, searchTime[0]);
				param9.setWhereClauseParameter(3, "9");
				param9.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param9); 
				
			}else{
				PosParameter param9 = new PosParameter();
				
				param9.setValueParamter(0, searchTime[0]);
				param9.setValueParamter(1, "9");
				param9.setValueParamter(2, searchGroup[0]);
				param9.setValueParamter(3, HG[0]);
				param9.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param9);
			}
		}
		
		//停轧时间 检修 10
		if(JIANXIU[0] != null){
			if(JIANXIU[0].equals("")){
				JIANXIU[0] = "0";
			}
			PosParameter param10 = new PosParameter();
			
			param10.setWhereClauseParameter(0, searchTime[0]);
			param10.setWhereClauseParameter(1, searchGroup[0]);
			param10.setWhereClauseParameter(2, "10");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param10);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param110 = new PosParameter();
				
				param110.setWhereClauseParameter(0, JIANXIU[0]);
				param110.setWhereClauseParameter(1, REG_ID[0]);
				param110.setWhereClauseParameter(2, searchTime[0]);
				param110.setWhereClauseParameter(3, "10");
				param110.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param110); 
				
			}else{
				PosParameter param110 = new PosParameter();
				
				param110.setValueParamter(0, searchTime[0]);
				param110.setValueParamter(1, "10");
				param110.setValueParamter(2, searchGroup[0]);
				param110.setValueParamter(3, JIANXIU[0]);
				param110.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param110);
			}
		}
		
		//停轧时间 外部 11
		if(WB[0] != null){
			if(WB[0].equals("")){
				WB[0] = "0";
			}
			PosParameter param11 = new PosParameter();
			
			param11.setWhereClauseParameter(0, searchTime[0]);
			param11.setWhereClauseParameter(1, searchGroup[0]);
			param11.setWhereClauseParameter(2, "11");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param11);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param111 = new PosParameter();
				
				param111.setWhereClauseParameter(0, WB[0]);
				param111.setWhereClauseParameter(1, REG_ID[0]);
				param111.setWhereClauseParameter(2, searchTime[0]);
				param111.setWhereClauseParameter(3, "11");
				param111.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param111); 
				
			}else{
				PosParameter param111 = new PosParameter();
				
				param111.setValueParamter(0, searchTime[0]);
				param111.setValueParamter(1, "11");
				param111.setValueParamter(2, searchGroup[0]);
				param111.setValueParamter(3, WB[0]);
				param111.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param111);
			}
		}
		
		//停轧时间 原成 12
		if(YC[0] != null){
			if(YC[0].equals("")){
				YC[0] = "0";
			}
			PosParameter param12 = new PosParameter();
			
			param12.setWhereClauseParameter(0, searchTime[0]);
			param12.setWhereClauseParameter(1, searchGroup[0]);
			param12.setWhereClauseParameter(2, "12");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param12);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param112 = new PosParameter();
				
				param112.setWhereClauseParameter(0, YC[0]);
				param112.setWhereClauseParameter(1, REG_ID[0]);
				param112.setWhereClauseParameter(2, searchTime[0]);
				param112.setWhereClauseParameter(3, "12");
				param112.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param112); 
				
			}else{
				PosParameter param112 = new PosParameter();
				
				param112.setValueParamter(0, searchTime[0]);
				param112.setValueParamter(1, "12");
				param112.setValueParamter(2, searchGroup[0]);
				param112.setValueParamter(3, YC[0]);
				param112.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param112);
			}
		}
		
		//日历时间 13
		if(RL[0] != null){
			if(RL[0].equals("")){
				RL[0] = "0";
			}
			PosParameter param13 = new PosParameter();
			
			param13.setWhereClauseParameter(0, searchTime[0]);
			param13.setWhereClauseParameter(1, searchGroup[0]);
			param13.setWhereClauseParameter(2, "13");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param13);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param113 = new PosParameter();
				
				param113.setWhereClauseParameter(0, RL[0]);
				param113.setWhereClauseParameter(1, REG_ID[0]);
				param113.setWhereClauseParameter(2, searchTime[0]);
				param113.setWhereClauseParameter(3, "13");
				param113.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param113); 
				
			}else{
				PosParameter param113 = new PosParameter();
				
				param113.setValueParamter(0, searchTime[0]);
				param113.setValueParamter(1, "13");
				param113.setValueParamter(2, searchGroup[0]);
				param113.setValueParamter(3, RL[0]);
				param113.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param113);
			}
		}
		
		//停轧时间 14
		if(TZ[0] != null){
			if(TZ[0].equals("")){
				TZ[0] = "0";
			}
			PosParameter param14 = new PosParameter();
			
			param14.setWhereClauseParameter(0, searchTime[0]);
			param14.setWhereClauseParameter(1, searchGroup[0]);
			param14.setWhereClauseParameter(2, "14");
			
			PosRowSet rows = getDao("mesdao").find("UIH010040_02.select", param14);
			
			//如果存在记录就更新操作，否则进行插入操作
			if(rows.hasNext()){
				PosParameter param114 = new PosParameter();
				
				param114.setWhereClauseParameter(0, TZ[0]);
				param114.setWhereClauseParameter(1, REG_ID[0]);
				param114.setWhereClauseParameter(2, searchTime[0]);
				param114.setWhereClauseParameter(3, "14");
				param114.setWhereClauseParameter(4, searchGroup[0]);
				
				getDao("mesdao").update("UIH010040_01.update", param114); 
				
			}else{
				PosParameter param114 = new PosParameter();
				
				param114.setValueParamter(0, searchTime[0]);
				param114.setValueParamter(1, "14");
				param114.setValueParamter(2, searchGroup[0]);
				param114.setValueParamter(3, TZ[0]);
				param114.setValueParamter(4, REG_ID[0]);
				
				getDao("mesdao").insert("UIH010040_01.insert", param114);
			}
		}
		return PosBizControlConstants.SUCCESS;
	}
}