package xin.glue.nui.H.H02; 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; public class InitRhfCharging extends PosActivity { public String runActivity(PosContext context) { // 获取从二级接收过来的数据 PosMessage message = context.getMessage(); String coilNo_L2 = (String)message.get("COIL_NO"); String slabNo = (String)message.get("SLAB_NO"); String rollUnit = (String)message.get("ROLL_UNIT"); String missnoClf = (String)message.get("MISSNO_CLF"); String missnoCauseCd = (String)message.get("MISSNO_CAUSE_CD"); String missnoOcrDtime = (String)message.get("MISSNO_OCR_DTIME"); String missnoEmpId = (String)message.get("MISSNO_EMP_ID"); //这里需要把真实钢卷号转换成计划钢卷号 // 这里需要进行卷号的转换,发给加热炉二级的变成了实际卷号。所以收到的电文也是实际卷号,转换成计划卷号就可以了。 // 计划钢卷号 String coilNo = null; // 在执行相应的程序,把数据写入表中 PosParameter paramAA = new PosParameter(); paramAA.setWhereClauseParameter(0, coilNo_L2); //这里是实际钢卷号 logger.logDebug("InitRhfCharging OLD_SAMPL_NO !!! "+coilNo_L2); PosRowSet CoilNoVo = getDao("mesdao").find("NIH020050_06.select", paramAA); // 查询出计划卷号的情况下,处理相应的业务类数据 if(CoilNoVo.hasNext()){ PosRow CoilNoRow = CoilNoVo.next(); coilNo = (String) CoilNoRow.getAttribute("COIL_NO"); //这里是计划钢卷号 logger.logDebug("InitRhfCharging COIL_NO !!! "+coilNo); context.put("coilNo", coilNo); context.put("slabNo", slabNo); context.put("rollUnit", rollUnit); context.put("missnoClf", missnoClf); context.put("missnoCauseCd", missnoCauseCd); context.put("missnoOcrDtime", missnoOcrDtime); context.put("missnoEmpId", missnoEmpId); }else{ logger.logDebug("InitRhfCharging OLD_SAMPL_NO转换失败 !!! "+coilNo); } return PosBizControlConstants.SUCCESS; } }