package xin.glue.nui.G.G02;

import java.math.BigDecimal;

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.PosRow;
import com.posdata.glue.dao.vo.PosRowSet;
import com.posdata.glue.msg.PosMessage;

/*
 * author:wangxiaoyan
 * Date:08-10-28
 * desc:接收CAS炉实绩的电文信息 更新CAS炉实绩表 TBG02_CAS_RESULT以后 相应的修改炼钢公共表 TBG02_CHARGE_COMM
 */
public class XinSaveCasProcChargeComm extends PosActivity 
{
	public String runActivity(PosContext context) 
	{
		try{
			PosMessage message = context.getMessage();
			
			//		从电文中获取的数据项
			String 	chargeNo = (String)message.get("CHARGE_NO");
			String 	planChargeNo = (String)message.get("PLAN_CHARGE_NO"); 
			String 	casNo = (String)message.get("CAS_NO"); 
			BigDecimal  arrvWgt = (BigDecimal)message.get("ARRV_WGT");  
			BigDecimal  casTreatWgt = (BigDecimal)message.get("CAS_TREAT_WGT"); 
			
			
	        int chLth = chargeNo.trim().length();
			
			if (chLth < 10   ) {
				
				logger.logInfo("XinSaveCasProcChargeComm  CHARGE_NO ERROR !!!!-->"+chargeNo     ); 	
				
			   return PosBizControlConstants.SUCCESS;
			}
			
			//		从炉次参数表 TBF01_SPEC_CHARGE 查询出来的数据项 用于插入 炉次参数表
			String lineProcCd = "";
			String prodnmCd = "";
			String stlGrd = "";
			String hcrClf = "";
			String castManaNo = "";
			BigDecimal castChargeSeq = null;
			BigDecimal castEdtChargeCnt = null;
			
			PosParameter param0 = new PosParameter();
		    PosParameter param1 = new PosParameter();
		    PosParameter param2 = new PosParameter();
		    
		    param2.setWhereClauseParameter(0, planChargeNo);
		    PosRowSet rowset2 = this.getDao("mesdao").find("NIG020410_02.select", param2);
		    if(rowset2.hasNext())
		    {
		    	PosRow row2 = rowset2.next();
		    	lineProcCd = (String)row2.getAttribute("LINE_PROC_CD");
		    	prodnmCd = (String)row2.getAttribute("PRODNM_CD");
		    	stlGrd = (String)row2.getAttribute("STL_GRD");
		    	hcrClf = (String)row2.getAttribute("HCR_CLF");
		    	castManaNo = (String)row2.getAttribute("CAST_MANA_NO");
		    	castChargeSeq = (BigDecimal)row2.getAttribute("CAST_CHARGE_SEQ");
		    	castEdtChargeCnt = (BigDecimal)row2.getAttribute("CAST_EDT_CHARGE_CNT");
		    }
		    
		    param0.setWhereClauseParameter(0, chargeNo);
		    PosRowSet rowset0 = this.getDao("mesdao").find("NIG020410_03.select", param0);
		    if(rowset0.hasNext())
		    {   
		    	PosRow rowsetROW   = rowset0.next();
	        	String currProgCd  = (String)rowsetROW.getAttribute("CUR_PROG_CD");
	        	String befProgCd   = (String)rowsetROW.getAttribute("BEF_PROG_CD");
	        	String CHARGE_STAT = (String)rowsetROW.getAttribute("CHARGE_STAT");
	        	if (CHARGE_STAT != null && CHARGE_STAT.equals("2")) {
	        	   
	        	  if (currProgCd == null) {
	        		  befProgCd  = "JBB"; 
	        		  currProgCd = "JCF"; 
	        	  } 
	        		
	        	  if (currProgCd != null && !(  currProgCd.equals("JLF") || currProgCd.equals("JRF") || currProgCd.equals("JJB"))) {
	        	      befProgCd  = currProgCd;    
	         	      currProgCd = "JCF"; 
	         			 
	         	   }	
	        		
		    	   param1.setWhereClauseParameter(0,casNo);  
		    	   param1.setWhereClauseParameter(1,befProgCd);
		    	   param1.setWhereClauseParameter(2,currProgCd);
		    	   param1.setWhereClauseParameter(3,arrvWgt);                                                 
		    	   param1.setWhereClauseParameter(4,casTreatWgt); 
		    	   param1.setWhereClauseParameter(5,casTreatWgt);
		    	   param1.setWhereClauseParameter(6,chargeNo);
	        	}
	        	
	        	
		    	this.getDao("mesdao").update("NIG020410_02.update",param1);
		    }
		    else
		    {
		    	param1.setValueParamter(0, chargeNo);
		    	param1.setValueParamter(1, planChargeNo);
		    	param1.setValueParamter(2, lineProcCd);
		    	param1.setValueParamter(3, prodnmCd);
		    	param1.setValueParamter(4, stlGrd);
		    	param1.setValueParamter(5, hcrClf);
		    	param1.setValueParamter(6, castManaNo);
		    	param1.setValueParamter(7, castChargeSeq);
		    	param1.setValueParamter(8, castEdtChargeCnt);
		    	param1.setValueParamter(9, casNo);
		    	param1.setValueParamter(10, arrvWgt);
		    	param1.setValueParamter(11, casTreatWgt);
		    	param1.setValueParamter(12, casTreatWgt);
		    	
		    	this.getDao("mesdao").insert("NIG020410_02.insert",param1);
		    }
		}catch(Exception ex){
			logger.logDebug("--------------------->" + ex);
			logger.logError("--------------------->" + ex);
		}
		
		return PosBizControlConstants.SUCCESS;
	}

}