XinYu_RZMES/.svn/pristine/53/53f5f732c71a5f86a61333bd74c85ba2a2ac6950.svn-base

package xin.glue.nui.G.G02;

import java.math.BigDecimal;


import xin.glue.ui.G.G01.XTBGCOMM;
import xin.glue.ui.G.G01.XTBGCreateMaterial;

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.PosGenericDao;
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 XinSaveChargeProc extends PosActivity 
{
	public String runActivity(PosContext context) 
	{
		
		PosGenericDao dao  = getDao("mesdao");
		PosParameter param;
		PosRowSet rowset;
		PosRow row;
		
		XTBGCOMM xtbgcom = new XTBGCOMM(dao);
        XTBGCreateMaterial xtbcm = new XTBGCreateMaterial(dao);
		
		PosMessage message = context.getMessage();
	     
		String 		mChargeNo 		= 		(String)message.get("CHARGE_NO");							// 炉次号
		String 		mPlanChargeNo 	= 		(String)message.get("PLAN_CHARGE_NO");						// 计划炉次号  
	 	String 		mProcCd 		= 		(String)message.get("TREAT_NO");							// 处理站号
	 	String 		mEventCd 		= 		(String)message.get("EVENT_CD"); 							// 工序号
		String 		mTreatDtime 	= 		(String)message.get("EVENT_DTIME");							// 钢水重量
		BigDecimal 	mEventQty 		= 		(BigDecimal)message.get("EVENT_WGT");						// 钢水重量
		BigDecimal 	mTreatTemp 		= 		(BigDecimal)message.get("EVENT_TEMP");						// 处理温度
		
		BigDecimal 	sCastChargeSeq 		= null;									//浇次内顺序
		BigDecimal 	sCastEdtChargeCnt 	= null;										//板坯去向
        BigDecimal 	sPrevChargeWgt 		= null;									//炉次重量	
		String		sStlGrd				= null; 
        String sBOF_STA_DTIME     		= null;
        String sBOF_END_DTIME     		= null;
        String sRH_STA_DTIME      		= null;
        String sRH_END_DTIME      		= null;
        String sLF_STA_DTIME      		= null;
        String sLF_END_DTIME      		= null;
        String sCAS_STA_DTIME     		= null;
        String sCAS_END_DTIME     		= null;
        String sLT_ARRV_DTIME     		= null;
        String sCASTING_STA_DTIME 		= null;
        String sCASTING_END_DTIME 		= null;
        String sCCM_DEP_DTIME  			= null;
        
        BigDecimal chargeWgt 			= null; 								//炉次重量
        BigDecimal tappingWgt 			= null;									//转炉出钢重量
        String befProgCd 			= null;									//前进程
        String progCd 				= null;									//当前进程
        String chargeStat			= null;
        BigDecimal ROW_BOF_TAPPING_WGT      = null;
        BigDecimal ROW_CHARGE_WGT 			= null;
    	
        if 		  (mEventCd.equals("B01")) {
        	if(sBOF_STA_DTIME == null ||sBOF_STA_DTIME.equals("")){
        		sBOF_STA_DTIME 		= mTreatDtime;
        	}
        	
        } else if (mEventCd.equals("B02")) {
        	if(sBOF_STA_DTIME == null ||sBOF_STA_DTIME.equals("")){
        		sBOF_STA_DTIME 		= mTreatDtime;
        	}
        } else if (mEventCd.equals("B03")) {
        	if(sBOF_STA_DTIME == null ||sBOF_STA_DTIME.equals("")){
        		sBOF_STA_DTIME 		= mTreatDtime;
        	}
        } else if (mEventCd.equals("B04")) {
        	sBOF_END_DTIME 		= mTreatDtime;
        	if(sBOF_STA_DTIME == null ||sBOF_STA_DTIME.equals("")){
        		sBOF_STA_DTIME 		= mTreatDtime;
        	}
        } else if (mEventCd.equals("R03")) {sRH_STA_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("R04")) {sRH_END_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("L02")) {sLF_STA_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("L03")) {sLF_END_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("C02")) {sCAS_STA_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("C03")) {sCAS_END_DTIME 		= mTreatDtime;
        } else if (mEventCd.equals("J01")) {sLT_ARRV_DTIME 		= mTreatDtime;sCASTING_END_DTIME 	= mTreatDtime;
        } else if (mEventCd.equals("J02")) {sCASTING_STA_DTIME 	= mTreatDtime;sCASTING_END_DTIME 	= mTreatDtime;
        } else if (mEventCd.equals("J03")) {sCASTING_END_DTIME 	= mTreatDtime;
        } else if (mEventCd.equals("J04")) {
        	sCCM_DEP_DTIME = mTreatDtime;sCASTING_END_DTIME 	= mTreatDtime;
        	PosParameter pram = new PosParameter();
        	pram.setWhereClauseParameter(0, sCCM_DEP_DTIME);
        	pram.setWhereClauseParameter(1,mChargeNo);
        	getDao("mesdao").update("NIG020200_LD_CCM_DEP_DTIME.update", pram);
        }
        
        
        //通过电文中接收的炉次号查询炉次参数表 TBF01_SPEC_CHARGE 取得的数据项 ，修改炼钢公共表 TBF02_CHARGE_COMM
        rowset = context.getRowSet("specCharge");
		if(rowset.hasNext()){
			row = rowset.next();
			sCastChargeSeq 		= (BigDecimal)row.getAttribute("CAST_CHARGE_SEQ");			//浇次内顺序
			sCastEdtChargeCnt 	= (BigDecimal)row.getAttribute("CAST_EDT_CHARGE_CNT");	//浇次内炉次数
			sPrevChargeWgt 		= (BigDecimal)row.getAttribute("PREV_CHARGE_WGT");
			sStlGrd				= (String)row.getAttribute("STL_GRD");
		}
		
		String sql = "select * from tbg02_charge_comm where CHARGE_NO = ?";
		param = new PosParameter();
        param.setWhereClauseParameter(0, mChargeNo);
        rowset = this.getDao("mesdao").findByQueryStatement(sql,param);
        if(!rowset.hasNext()){
        	xtbcm.CreateCharge("3"+mChargeNo.substring(1, 10));
        	xtbcm.CreateSlab("3"+mChargeNo.substring(1, 10));
        }else{
        	row =  rowset.next();
        	ROW_BOF_TAPPING_WGT       	= (BigDecimal)row.getAttribute("BOF_TAPPING_WGT");
        	ROW_CHARGE_WGT            	= (BigDecimal)row.getAttribute("CHARGE_WGT");
        	chargeStat 					= (String)row.getAttribute("CHARGE_STAT");
        	if (chargeWgt == null) 	{chargeWgt = ROW_CHARGE_WGT;}
        	if (tappingWgt == null) {tappingWgt = ROW_BOF_TAPPING_WGT;}	
        	if(chargeStat.equals("3")){
        		return PosBizControlConstants.SUCCESS;
        	}
        }
    
        if (mEventQty != null ) {chargeWgt = mEventQty;}
        if (mEventCd.equals("B04")) {tappingWgt = mEventQty;} 
        
        param = new PosParameter();
		param.setWhereClauseParameter(0,"3" + mChargeNo.substring(1,10));
		PosRowSet L2Send = dao.find("UIG020020_L2_SEND_CHARGE.select", param);
		if(!L2Send.hasNext()){
			context.put("MESSAGES", "指示没有下发2级，不能操作");
			return PosBizControlConstants.SUCCESS; 
		}
		
		//if( mEventCd.equals("J01") || mEventCd.equals("J02") || mEventCd.equals("J03") || mEventCd.equals("J04"))return PosBizControlConstants.SUCCESS;
        int chLth = mChargeNo.trim().length();
		if (chLth < 10   ) { 
			return PosBizControlConstants.SUCCESS;
		}   
	    
		
        
        //steel making progress table and Steel making tracking table update
		xtbgcom.steelEventUpt(mChargeNo, mProcCd, mEventCd, mTreatTemp, chargeWgt, mTreatDtime, "2", sStlGrd, sCastEdtChargeCnt, sCastChargeSeq);
        
        //td md update
        String TdNo  = null;
		String MdNo1 = null;
		String MdNo2 = null;
        if (mProcCd.substring(0,1).equals("J")) {
        	param = new PosParameter();
        	String sMC = mProcCd.substring(1,2);
        	param.setWhereClauseParameter(0, "2");
            param.setWhereClauseParameter(1, "2");
            param.setWhereClauseParameter(2, sMC);
            param.setWhereClauseParameter(3, sMC); 
        	PosRowSet TdMdVo =  this.getDao("mesdao").find("NIG020200_TD_MD.select", param);
        	if (TdMdVo.hasNext() ) {
        	   PosRow 	TdMdROW = TdMdVo.next();
        	   TdNo  =  (String)TdMdROW.getAttribute("TD_NO");
        	   MdNo1 =  (String)TdMdROW.getAttribute("MD_NO1");
        	   MdNo2 =  (String)TdMdROW.getAttribute("MD_NO2");
        	}
        }
        //Return Charge Search  for setting return charge and return weight to the new charge no   
        String RtnChNo = null;
        Number RtnChWgt = null;
        if (mEventCd.substring(0,1).equals("B")) {
           PosParameter paramB = new PosParameter();
   	       String sql1 = "select CHARGE_NO,RTN_CHARGE_WGT from tbg02_charge_comm where NEW_PLAN_CHARGE_NO = ?";
   	       paramB.setWhereClauseParameter(0, mPlanChargeNo);
           PosRowSet rtnChVO = this.getDao("mesdao").findByQueryStatement(sql1,paramB);
           if(rtnChVO.hasNext()) {
        	PosRow rtnChROW = rtnChVO.next();
        	RtnChNo = (String)rtnChROW.getAttribute("CHARGE_NO");
        	RtnChWgt = (Number)rtnChROW.getAttribute("RTN_CHARGE_WGT");
           }
        }

        //炉次事件实绩修改
    	param = new PosParameter();
    	param.setWhereClauseParameter(0,TdNo);						//中包号
    	param.setWhereClauseParameter(1,MdNo1);					 	//结晶器1
    	param.setWhereClauseParameter(2,MdNo2);						//结晶器2
    	param.setWhereClauseParameter(3,sBOF_STA_DTIME);
    	param.setWhereClauseParameter(4,sBOF_END_DTIME);
    	param.setWhereClauseParameter(5,sRH_STA_DTIME);
    	param.setWhereClauseParameter(6,sRH_END_DTIME);
    	param.setWhereClauseParameter(7,sCAS_STA_DTIME);
    	param.setWhereClauseParameter(8,sCAS_END_DTIME);
    	param.setWhereClauseParameter(9,sLF_STA_DTIME);
    	param.setWhereClauseParameter(10,sLF_END_DTIME);
    	param.setWhereClauseParameter(11,sLT_ARRV_DTIME);
    	param.setWhereClauseParameter(12,sCASTING_STA_DTIME);
    	param.setWhereClauseParameter(13,sCASTING_END_DTIME);
    	param.setWhereClauseParameter(14,RtnChNo);					//回送炉号
    	param.setWhereClauseParameter(15,RtnChWgt);					//回送重量
    	param.setWhereClauseParameter(16,chargeWgt);			//装入量
    	param.setWhereClauseParameter(17,tappingWgt);		//转炉出钢重量
    	param.setWhereClauseParameter(18,mChargeNo);
    	this.getDao("mesdao").update("UIG030010_TREAT_DTIME_UPT_01", param);
    	
       
        //炉次信息修改
        String PgmId = null;
		if(mEventCd.equals("J02")){
    	   PgmId = "XinCcmStart";
		}else{
    	   PgmId = mEventCd+"|SaveChrgProc";
		}
		if (mEventCd.substring(0,1).equals("L")){
         	progCd = "JLF";
        }else if (mEventCd.substring(0,1).equals("R")){
         	progCd = "JRF";
        }else if (mEventCd.substring(0,1).equals("V")){
         	progCd = "JVF";
        }else if (mEventCd.substring(0,1).equals("C")){
         	progCd = "JCF";
        }
    	if(mEventCd.substring(0,1).equals("B")||mEventCd.substring(0,1).equals("J")){
            if (mEventCd.substring(0,1).equals("B")){
               if (progCd == null  ||  progCd.equals("") || progCd.equals("JBB")){
            	   progCd = "JBB";
                   befProgCd = "JBA";
               }  
            }else{
            	if (progCd == null || progCd.equals("")){ 
            		progCd = "JJB";
            	}  
            }
        }
    	
    	//计划信息修改
        xtbgcom.specChargeProcUpt(mPlanChargeNo, "B", progCd);
        xtbgcom.specSlabProcUpt(mPlanChargeNo, "B");
    	
    	xtbgcom.chargeProcUpt(mChargeNo, "2", progCd, PgmId);
	    //MODIFY BY WXY 20111121 
        //SendProg_NIE012070( mPlanChargeNo,befProgCd,progCd,sPrevChargeWgt,PgmId);
        //SendProg_NIE012080();
        
        return PosBizControlConstants.SUCCESS;
	}
	public PosContext SendProg_NIE012070(String  ChargeNo ,String befProgCd,String ProgCD,Number prevChargeWgt,String PgmId)
	  {
		    logger.logDebug("XinSaveChargeProc SendProg_NIE012070 " ); 
		     
			PosContext context = new PosContext();
			PosMessage message = new PosMESMessageImpl();
			
		 
			String TcId = "NIE012070"; 
			 
			 
		        
			
			message.setTCID(TcId);
			message.setObject("MSG_ID",TcId);  
			message.setObject("BEF_ORD_NO",null);
			message.setObject("BEF_ORD_SEQ",null);
			message.setObject("ORD_NO",null);
			message.setObject("ORD_SEQ",null);
			message.setObject("BEF_PROG_CD",befProgCd);
			message.setObject("PROG_CD",ProgCD);
			message.setObject("MAT_TYPE","CH");
			message.setObject("MAT_NO",ChargeNo);
			message.setObject("WGT",prevChargeWgt);
			message.setObject("PGMID",PgmId);
			message.setObject("REG_ID","LEVEL2");
			 
			context.setMessage(message);
			this.processComponent(PosConstants.CREATE_MESSAGE, context);
			String transactionCode = context.getMessage().getTC();
			
			
			logger.logDebug("XinSaveChargeProc---> transactionCode:("+transactionCode+")"   ); 
			
			message.setTCID(TcId); 
		 	
			String serviceName = "NIE012070"; 
			
			String SERVICE_POSTFIX = "-service"; 
			
		 	 
			context.put(PosBizControlConstants.SERVICE_NAME, serviceName + SERVICE_POSTFIX);
			 
			
			context.setMessage(message);
			
			
			PosBizControlIF controller =  PosBizProvider.getController();
			
			controller.doSubController(context,false);
			 
			 
			logger.logDebug("XinSaveChargeProc---> NIE012070 TC  SendProgress end" ); 
			 
			
			return null; 
	  }
	public PosContext SendProg_NIE012080()
	  {
		    logger.logDebug("XinSaveChargeProc SendProg_NIE012080 " ); 
		       
			
			 
			PosContext context = new PosContext();
			PosMessage message = new PosMESMessageImpl();
			
		 
			String TcId = "NIE012080"; 
			 
			 
			
			message.setTCID(TcId);
			message.setObject("MSG_ID",TcId);  
			message.setObject("AA",null); 
			 
			context.setMessage(message);
			this.processComponent(PosConstants.CREATE_MESSAGE, context);
			String transactionCode = context.getMessage().getTC();
			
			
			logger.logDebug("XinSaveChargeProc---> transactionCode:("+transactionCode+")"   ); 
			
			message.setTCID(TcId); 
		 	
			String serviceName = "NIE012080"; 
			
			String SERVICE_POSTFIX = "-service"; 
			
		 	 
			context.put(PosBizControlConstants.SERVICE_NAME, serviceName + SERVICE_POSTFIX);
			 
			
			context.setMessage(message);
			
			
			PosBizControlIF controller =  PosBizProvider.getController();
			
			controller.doSubController(context,false);
			 
			String SERVICE_ERR_MSG = (String) context.get("SERVICE_ERR_MSG");
    		logger.logDebug("XinSaveChargeProc SERVICE_ERR_MSG:"+SERVICE_ERR_MSG ); 
		   
			 
			
			
			return null; 
	  }
}