XinYu_RZMES/.svn/pristine/fb/fb508928ab378a9d474bf5530d5558919fed90a5.svn-base

package xin.glue.nui.G.G02;

import java.math.BigDecimal;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

import xin.glue.ui.common.PosDateFormat;

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;
/**
 * 
 * @auth: wangxiaoyan
 * @date: 2008-12-25
 * @desc: KR实绩录入
 */
public class XinSaveKRResult extends PosActivity
{

    public XinSaveKRResult()
    {
    }

    public String runActivity(PosContext context)
    {
    	
        PosMessage message = context.getMessage();
        
        String RsvDate = (String)message.get("RSV_DATE");   
        
        String KrChrgeNo = (String)message.get("KR_CHARGE_NO"); 
        String ocrDtime = (String)message.get("OCR_DTIME");
        String krNo = (String)message.get("KR_NO");
        String ldNo = (String)message.get("LD_NO");
        String ldArrivDtime = (String)message.get("LD_ARRIV_DTIME");
        String staDtime = (String)message.get("STA_DTIME");
        String endDtime = (String)message.get("END_DTIME");
        String ldDepDtime = (String)message.get("LD_DEP_DTIME");
        BigDecimal ironRecvWgt = (BigDecimal)message.get("IRON_RECV_WGT");
        BigDecimal treatAftSWgt = (BigDecimal)message.get("TREAT_AFT_S_WGT");
        BigDecimal treatAftPWgt = (BigDecimal)message.get("TREAT_AFT_P_WGT");
        BigDecimal treatAftCWgt = (BigDecimal)message.get("TREAT_AFT_C_WGT");
        BigDecimal treatAftMnWgt = (BigDecimal)message.get("TREAT_AFT_MN_WGT");
        BigDecimal treatAftSiWgt = (BigDecimal)message.get("TREAT_AFT_SI_WGT");
        BigDecimal treatAftTiWgt = (BigDecimal)message.get("TREAT_AFT_TI_WGT");
        BigDecimal endTemp = (BigDecimal)message.get("END_TEMP");
        String befSlagRemoveYn = (String)message.get("BEF_SLAG_REMOVE_YN");
        String aftSlagRemoveYn = (String)message.get("AFT_SLAG_REMOVE_YN");
        BigDecimal mgoCalWgt = (BigDecimal)message.get("MGO_CAL_WGT");
        BigDecimal caoCalWgt = (BigDecimal)message.get("CAO_CAL_WGT");
        BigDecimal mgoWkerInputWgt = (BigDecimal)message.get("MGO_WKER_INPUT_WGT");
        BigDecimal caoWkerInputWgt = (BigDecimal)message.get("CAO_WKER_INPUT_WGT");
        BigDecimal mixTreatHour = (BigDecimal)message.get("MIX_TREAT_HOUR");
        String mixStaDtime = (String)message.get("MIX_STA_DTIME");
        String mixEndDtime = (String)message.get("MIX_END_DTIME");
        String befSlagRemoveStaDtime = (String)message.get("BEF_SLAG_REMOVE_STA_DTIME");
        String befSlagRemoveEndDtime = (String)message.get("BEF_SLAG_REMOVE_END_DTIME");
        BigDecimal befSlagRemoveHour = (BigDecimal)message.get("BEF_SLAG_REMOVE_HOUR");
        BigDecimal befSlagRemoveWgt = (BigDecimal)message.get("BEF_SLAG_REMOVE_WGT");
        String aftSlagRemoveStadtime = (String)message.get("AFT_SLAG_REMOVE_STA_DTIME");
        String aftSlagRemoveEndDtime = (String)message.get("AFT_SLAG_REMOVE_END_DTIME");
        BigDecimal aftSlagRemoveHour = (BigDecimal)message.get("AFT_SLAG_REMOVE_HOUR");
        BigDecimal aftSlagRemoveWgt = (BigDecimal)message.get("AFT_SLAG_REMOVE_WGT");
        
        String sShift = null;
		if ( RsvDate.equals("") || RsvDate == null  ) { 
		      DateFormat formatter =  new SimpleDateFormat("yyyyMMddHHmmss");
		      RsvDate = formatter.format(new Date());
		 }
        sShift = PosDateFormat.getShift(RsvDate);
        
//        获取工作组
        PosParameter paramA = new PosParameter();
        paramA.setWhereClauseParameter(0, RsvDate.substring(0,6));
        paramA.setWhereClauseParameter(1, RsvDate.substring(6,8));
        paramA.setWhereClauseParameter(2, sShift);
        paramA.setWhereClauseParameter(3, "S");
        PosRowSet groupVO = this.getDao("mesdao").find("NIG020210_SHIFT.select", paramA);
        
        String sGroup = null;
        if (groupVO.hasNext()){
        	PosRow groupROW = groupVO.next();
        	sGroup = (String)groupROW.getAttribute("GR_GROUP_CD");
        }
        
        
        PosParameter parm0 = new PosParameter();
        PosParameter parm1 = new PosParameter();
        parm0.setWhereClauseParameter(0, KrChrgeNo); 
        PosRowSet rowset0 = getDao("mesdao").find("NIG020100_01.select", parm0);
        if(rowset0.hasNext())
        {
        	parm1.setValueParamter(0, ocrDtime);
            parm1.setValueParamter(1, krNo);
            parm1.setValueParamter(2, ldNo);
            parm1.setValueParamter(3, ldArrivDtime);
            parm1.setValueParamter(4, staDtime);
            parm1.setValueParamter(5, endDtime);
            parm1.setValueParamter(6, ldDepDtime);
            parm1.setValueParamter(7, ironRecvWgt);
            parm1.setValueParamter(8, treatAftSWgt);
            parm1.setValueParamter(9, treatAftPWgt);
            parm1.setValueParamter(10, treatAftCWgt);
            parm1.setValueParamter(11, treatAftMnWgt);
            parm1.setValueParamter(12, treatAftSiWgt);
            parm1.setValueParamter(13, treatAftTiWgt);
            parm1.setValueParamter(14, endTemp); 
            parm1.setValueParamter(15, befSlagRemoveYn);
            parm1.setValueParamter(16, aftSlagRemoveYn); 
            parm1.setValueParamter(17, mgoCalWgt);
            parm1.setValueParamter(18, caoCalWgt);
            parm1.setValueParamter(19, mgoWkerInputWgt);
            parm1.setValueParamter(20, caoWkerInputWgt); 
            parm1.setValueParamter(21, mixTreatHour);
            parm1.setValueParamter(22, mixStaDtime);
            parm1.setValueParamter(23, mixEndDtime); 
            parm1.setValueParamter(24, befSlagRemoveStaDtime);
            parm1.setValueParamter(25, befSlagRemoveEndDtime);
            parm1.setValueParamter(26, befSlagRemoveHour);
            parm1.setValueParamter(27, befSlagRemoveWgt);
            parm1.setValueParamter(28, aftSlagRemoveStadtime);
            parm1.setValueParamter(29, aftSlagRemoveEndDtime);
            parm1.setValueParamter(30, aftSlagRemoveHour);
            parm1.setValueParamter(31, aftSlagRemoveWgt);
            parm1.setValueParamter(32, RsvDate.substring(0,8));
            parm1.setValueParamter(33, sShift);
            parm1.setValueParamter(34, sGroup);
            parm1.setValueParamter(35, KrChrgeNo); 
            getDao("mesdao").update("NIG020100_01.update", parm1);
        } else
        {
        	 parm1.setValueParamter(0, KrChrgeNo);                   
        	 parm1.setValueParamter(1, ocrDtime);                       
        	 parm1.setValueParamter(2, krNo);                           
        	 parm1.setValueParamter(3, ldNo);                           
        	 parm1.setValueParamter(4, ldArrivDtime);                   
        	 parm1.setValueParamter(5, staDtime);                       
        	 parm1.setValueParamter(6, endDtime);                       
        	 parm1.setValueParamter(7, ldDepDtime);                     
        	 parm1.setValueParamter(8, ironRecvWgt);                    
        	 parm1.setValueParamter(9, treatAftSWgt);                   
        	 parm1.setValueParamter(10, treatAftPWgt);                  
        	 parm1.setValueParamter(11, treatAftCWgt);                  
        	 parm1.setValueParamter(12, treatAftMnWgt);                 
        	 parm1.setValueParamter(13, treatAftSiWgt);                 
        	 parm1.setValueParamter(14, treatAftTiWgt);                 
        	 parm1.setValueParamter(15, endTemp);                       
        	 parm1.setValueParamter(16, befSlagRemoveYn);               
        	 parm1.setValueParamter(17, aftSlagRemoveYn);               
        	 parm1.setValueParamter(18, mgoCalWgt);                     
        	 parm1.setValueParamter(19, caoCalWgt);                     
        	 parm1.setValueParamter(20, mgoWkerInputWgt);               
        	 parm1.setValueParamter(21, caoWkerInputWgt);               
        	 parm1.setValueParamter(22, mixTreatHour);                  
        	 parm1.setValueParamter(23, mixStaDtime);                   
        	 parm1.setValueParamter(24, mixEndDtime);                   
        	 parm1.setValueParamter(25, befSlagRemoveStaDtime);         
        	 parm1.setValueParamter(26, befSlagRemoveEndDtime);         
        	 parm1.setValueParamter(27, befSlagRemoveHour);             
        	 parm1.setValueParamter(28, befSlagRemoveWgt);              
        	 parm1.setValueParamter(29, aftSlagRemoveStadtime);         
        	 parm1.setValueParamter(30, aftSlagRemoveEndDtime);         
        	 parm1.setValueParamter(31, aftSlagRemoveHour);             
        	 parm1.setValueParamter(32, aftSlagRemoveWgt);              
        	 parm1.setValueParamter(33, RsvDate.substring(0,8));        
        	 parm1.setValueParamter(34, sShift);                        
        	 parm1.setValueParamter(35, sGroup);                        
        	 parm1.setValueParamter(36, "1");                           
        	 getDao("mesdao").insert("NIG020100_01.insert", parm1);     

        }
        
//        下面代码更新工序 EVENT 的KR实绩  ，用来实时跟踪
         
        PosParameter parm2 = new PosParameter();
        parm2.setValueParamter(0, "K02"); 
        parm2.setValueParamter(1, ironRecvWgt);
        parm2.setValueParamter(2, endTemp);
        parm2.setValueParamter(3, endDtime);  
        parm2.setValueParamter(4, KrChrgeNo);  
        parm2.setValueParamter(5, krNo);
    	
    	this.getDao("mesdao").update("NIG020100_TRACK.update", parm2);
         
        return PosBizControlConstants.SUCCESS;
    }
}