package com.tenwa.flow; import jbo.app.WECHAT_ADVANCE_SETTLE; import jbo.app.WECHAT_BANKNUMBER_CHANGE; import jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO; import com.amarsoft.are.jbo.BizObject; import com.amarsoft.are.jbo.BizObjectManager; import com.amarsoft.are.jbo.JBOFactory; import com.amarsoft.awe.util.Transaction; import com.tenwa.flow.baseBussion.BaseBussiness; /* * 修改微信公众号提交修改信息状态 */ public class ChangeWechatSubmitFlow extends BaseBussiness{ @Override public Object run(Transaction Sqlca) throws Exception { this.initBussinessParam(Sqlca); String flowunid = this.getAttribute("ObjectNo").toString(); String flowName = this.getAttribute("FlowName").toString(); String ContractId = this.getAttribute("ContractId").toString(); BizObjectManager lciMange = JBOFactory.getBizObjectManager(LB_CONTRACT_INFO.CLASS_NAME,Sqlca); BizObject lci = lciMange.createQuery("id=:id").setParameter("id", ContractId).getSingleResult(false); String contractNo = lci.getAttribute("contract_no").toString(); if("扣款信息变更审核".equals(flowName)){ BizObjectManager wbcMange = JBOFactory.getBizObjectManager(WECHAT_BANKNUMBER_CHANGE.CLASS_NAME,Sqlca); BizObject wbc = wbcMange.createQuery("contract_no=:contractNo and STATUS='处理中' " ).setParameter("contractNo", contractNo).getSingleResult(true); if(wbc != null){ wbc.setAttributeValue("flowUnid", flowunid); wbc.setAttributeValue("flowStatus", "已提交"); wbcMange.saveObject(wbc); } }else if ("提前结清".equals(flowName)){ BizObjectManager wasMange = JBOFactory.getBizObjectManager(WECHAT_ADVANCE_SETTLE.CLASS_NAME,Sqlca); BizObject wbc = wasMange.createQuery("contract_no=:contractNo and (STATUS='处理中' or STATUS='已受理' ) " ).setParameter("contractNo", contractNo).getSingleResult(true); if(wbc != null){ wbc.setAttributeValue("flowUnid", flowunid); wbc.setAttributeValue("flowStatus", "已提交"); wasMange.saveObject(wbc); } } return "true"; } }