package xin.glue.ui.G.G02; import java.math.BigDecimal; import java.sql.CallableStatement; import java.sql.SQLException; import java.sql.Types; import com.posdata.glue.PosException; 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; import xin.glue.ui.common.PosDateFormat; /* * author:wangxiaoyan * Date:08-10-28 * desc: 钢水回送实绩 * DESC:090708 ADD 返送炉次计划自动下发 by sjw */ public class XinSaveReturnCharge extends PosActivity { public String runActivity(PosContext context) { PosParameter param = null; PosRow row = null; PosRowSet rowset = null; PosGenericDao dao = getDao("mesdao"); String[] MSG_CHRGE_NO = (String[])context.get("CHARGE_NO" ); String[] MSG_PLAN_CHARGE_NO = (String[])context.get("PLAN_CHARGE_NO" ); String[] MSG_RTN_CHARGE_OCR_PROC = (String[])context.get("RTN_CHARGE_OCR_PROC" ); String[] MSG_RTN_CHARGE_OCR_DTIME = (String[])context.get("RTN_CHARGE_OCR_DTIME" ); String[] MSG_RTN_CHARGE_WGT = (String[])context.get("RTN_CHARGE_WGT" ); String[] MSG_RTN_CHARGE_CAUSE_CD = (String[])context.get("RTN_CHARGE_CAUSE_CD" ); String P_NEW_CHARGE_MANA_NO = ""; String P_RTN_MSG = ""; String PGMID = ""; BigDecimal chgWgt = new BigDecimal(MSG_RTN_CHARGE_WGT[0]); logger.logInfo("XinSaveReturnCharge---> MSG_PLAN_CHARGE_NO:"+MSG_PLAN_CHARGE_NO ); param = new PosParameter(); String getPlanChargeNo = "select plan_charge_no from tbg02_charge_comm where charge_no = ?"; param.setWhereClauseParameter(0, MSG_CHRGE_NO[0]); rowset = dao.findByQueryStatement(getPlanChargeNo,param); if(rowset.hasNext()){ row = rowset.next(); MSG_PLAN_CHARGE_NO[0] = (String)row.getAttribute("PLAN_CHARGE_NO"); }else{ context.put("MESSAGES", " 无计划炉次号，操作失败! "); return PosBizControlConstants.SUCCESS; } /****************************炉次回送取消已编制的轧制计划*********************************************************/ /** * ADD:090717 * BY:SJW * DESC:如果编制了热送计划，则回送需要取消轧制计划 */ PosParameter param_hcr_mill_fl = new PosParameter(); param_hcr_mill_fl.setWhereClauseParameter(0, MSG_CHRGE_NO[0]); PosRowSet mill_fl_vo = getDao("mesdao").find("NIG020630_HCR_MILL_FL.select", param_hcr_mill_fl); mill_fl_vo.reset(); while (mill_fl_vo.hasNext() ) { PosRow mill_fl_row = mill_fl_vo.next(); String lv_slab_no = (String)mill_fl_row.getAttribute("SLAB_NO"); NIF024060_CALL(lv_slab_no,"XinSaveReturnCharge"); } /***********************************************************************************************************/ PosParameter param0 = new PosParameter(); PosParameter param1 = new PosParameter(); param1.setValueParamter(0,MSG_RTN_CHARGE_OCR_DTIME[0] ); param1.setValueParamter(1,MSG_RTN_CHARGE_CAUSE_CD[0] ); param1.setValueParamter(2,chgWgt ); param1.setValueParamter(3,MSG_RTN_CHARGE_OCR_PROC[0] ); param1.setValueParamter(4,MSG_CHRGE_NO[0] ); // 修改炉次公共表 this.getDao("mesdao").update("NIG020630_CHARGE_COM.update",param1); // Product control system table update // TBF01_SPEC_CHARGE,TBF01_CHARGE_IDX,TBF01_SPEC_SLAB,TBF01_SPEC_SLAB_D // if slab cutting result is existing then there are can not that's update param0.setWhereClauseParameter(0, MSG_PLAN_CHARGE_NO[0]); PosRowSet SpecChVo = getDao("mesdao").find("NIG020610_SLAB_SPEC.select", param0); while (SpecChVo.hasNext() ) { PosParameter paramA = new PosParameter(); paramA.setWhereClauseParameter(0, MSG_PLAN_CHARGE_NO[0]); PosRowSet SlabVo = getDao("mesdao").find("NIG020610_SLAB_COMM.select", paramA); if (!SlabVo.hasNext()) { PosRow SpecChROW = SpecChVo.next(); Number nSlabEdtSeq = (Number)SpecChROW.getAttribute("SLAB_EDT_SEQ"); String SlabManaNo = (String)SpecChROW.getAttribute("SLAB_MANA_NO"); PosParameter param2 = new PosParameter(); param2.setValueParamter(0, "C" ); param2.setValueParamter(1, SlabManaNo.substring(0,9) ); this.getDao("mesdao").update("NIG020610_SPEC_SLAB.update", param2); PosParameter param3 = new PosParameter(); param3.setValueParamter(0, "C" ); param3.setValueParamter(1, nSlabEdtSeq ); this.getDao("mesdao").update("NIG020610_SPEC_SLAB_D.update", param3); } } String CurProgCd = null; String BefProgCd = null; PosParameter param6 = new PosParameter(); param6.setWhereClauseParameter(0, MSG_CHRGE_NO[0]); PosRowSet chComVo = getDao("mesdao").find("NIG020630_CHARGE_COM.select", param6); if (chComVo.hasNext()) { PosRow chComROW = chComVo.next(); CurProgCd = (String)chComROW.getAttribute("CUR_PROG_CD"); BefProgCd = (String)chComROW.getAttribute("BEF_PROG_CD"); } PosParameter param4 = new PosParameter(); param4.setValueParamter(0, "C"); param4.setValueParamter(1, CurProgCd ); param4.setValueParamter(2, MSG_PLAN_CHARGE_NO[0] ); this.getDao("mesdao").update("NIG020610_SPEC_CHARGE.update", param4); PosParameter param5 = new PosParameter(); param5.setValueParamter(0, "C" ); param5.setValueParamter(1, MSG_PLAN_CHARGE_NO[0] ); this.getDao("mesdao").update("NIG020610_SPEC_CHARGE_IDX.update", param5); PosParameter param7= new PosParameter(); param7.setValueParamter(0, MSG_CHRGE_NO[0] ); this.getDao("mesdao").update("NIG020630_SLAB_COMM.update", param7); PGMID = "XinSaveReturnCharge"; // Progress system sub-service call SendProg_NIE012070( MSG_PLAN_CHARGE_NO[0],null,null,CurProgCd,BefProgCd,chgWgt,PGMID ); SendProg_NIE012080(); CallableStatement cStmt = null; try { cStmt = this.getDao("mesdao").getCallableStatement("CALL_RTN_CHARGE_AUTO"); cStmt.setString(1,MSG_PLAN_CHARGE_NO[0]); cStmt.registerOutParameter(2, Types.VARCHAR); cStmt.registerOutParameter(3, Types.VARCHAR); cStmt.execute(); P_NEW_CHARGE_MANA_NO = cStmt.getString(2); P_RTN_MSG = cStmt.getString(3); } catch (SQLException ex) { logger.logFatal("Can not execute PL/SQL",ex); throw new PosException("Can not execute PL/SQL >> " + P_RTN_MSG,ex); } finally { try { if(cStmt != null) { cStmt.close(); } } catch (SQLException ex) { logger.logFatal("Can not Close CallableStatement Query ID [callTest]",ex); } } if(P_RTN_MSG == null || "".equals(P_RTN_MSG)) { ; } else { throw new PosException(P_RTN_MSG); } PGMID = "CALL_RTN_CHARGE_AUTO"; SendProg_NIE012070(P_NEW_CHARGE_MANA_NO,null,null,"JBA","",chgWgt,PGMID ); SendProg_NIE012080(); context.put("MESSAGES", " 操作成功! "); return PosBizControlConstants.SUCCESS; } public PosContext SendProg_NIE012070(String MatNo,String sOrdNo,String sOrdSeq,String sCurProg,String sBefProg,BigDecimal wgt ,String V_PGM_ID ) { logger.logInfo("XinSaveCcmResult 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",sBefProg); message.setObject("PROG_CD",sCurProg); message.setObject("MAT_TYPE","CH"); message.setObject("MAT_NO",MatNo); message.setObject("WGT",wgt); message.setObject("PGMID",V_PGM_ID); message.setObject("REG_ID","LEVEL2"); context.setMessage(message); this.processComponent(PosConstants.CREATE_MESSAGE, context); String transactionCode = context.getMessage().getTC(); logger.logInfo("XinSaveCcmResult---> 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.logInfo("XinSaveCcmResult---> NIE012070 TC SendProgress end" ); return null; } public PosContext SendProg_NIE012080() { logger.logInfo("XinSaveCcmResult 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.logInfo("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); logger.logInfo("XinSaveChargeProc---> NIE012080 TC SendProgress end" ); return null; } public PosContext NIF024060_CALL(String V_SLAB_NO, String V_REG_ID) { PosContext context = new PosContext(); PosMessage message = new PosMESMessageImpl(); String TcId = "NIF024060"; message.setTCID(TcId); message.setObject("MSG_ID", TcId); message.setObject("TYPE", "M"); message.setObject("FROM" , V_SLAB_NO); message.setObject("TO" , V_SLAB_NO); message.setObject("REG_ID", V_REG_ID ); context.setMessage(message); message.setTCID(TcId); String SERVICE_POSTFIX = "-service"; context.put(PosBizControlConstants.SERVICE_NAME, TcId + SERVICE_POSTFIX); PosBizProvider.getController().doSubController(context, false); String SERVICE_ERR_MSG = (String) context.get("SERVICE_ERR_MSG"); if (SERVICE_ERR_MSG != null) { throw new PosException(SERVICE_ERR_MSG); } return context; } }