apzl_leasing/calc/com/tenwa/flow/ChangeWechatSubmitStatus.java
2019-11-14 15:48:52 +08:00

86 lines
3.9 KiB
Java

package com.tenwa.flow;
import java.text.SimpleDateFormat;
import java.util.Date;
import jbo.app.WECHAT_ADVANCE_SETTLE;
import jbo.app.WECHAT_BANKNUMBER_CHANGE;
import jbo.com.tenwa.entity.comm.message.BT_BUSSINESS_MESSAGE;
import jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO;
import jbo.sys.FLOW_OPINION;
import jbo.sys.FLOW_TASK;
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 ChangeWechatSubmitStatus 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();
BizObjectManager ftManage = JBOFactory.getBizObjectManager(FLOW_TASK.CLASS_NAME,Sqlca);
BizObjectManager foManager = JBOFactory.getBizObjectManager(FLOW_OPINION.CLASS_NAME,Sqlca);
BizObjectManager bumManager = JBOFactory.getBizObjectManager(BT_BUSSINESS_MESSAGE.CLASS_NAME,Sqlca);
Date date1 = new Date() ; //获取系统时间
SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); //日期格式
String date = sdf.format(date1); //将系统时间转换成上方指定类型
if("扣款信息变更审核".equals(flowName)){
BizObject ft = ftManage.createQuery(" objectno=:flowunid and phaseno='0010' ").setParameter("flowunid", flowunid).getSingleResult(false);
BizObject fo = foManager.createQuery(" SerialNo=:SerialNo ").setParameter("SerialNo", ft == null ? "" : ft.getAttribute("SerialNo").toString()).getSingleResult(false);
BizObjectManager wbcMange = JBOFactory.getBizObjectManager(WECHAT_BANKNUMBER_CHANGE.CLASS_NAME,Sqlca);
BizObject wbc = wbcMange.createQuery("flowUnid=:flowUnid " ).setParameter("flowUnid", flowunid).getSingleResult(true);
if(wbc != null){
wbc.setAttributeValue("STATUS", "通过");
wbc.setAttributeValue("flowStatus", "通过");
wbc.setAttributeValue("UPDATETIME", date);
wbc.setAttributeValue("opinions", fo == null ? "" : fo.getAttribute("phaseopinion"));
wbcMange.saveObject(wbc);
BizObject bum = bumManager.createQuery(" id=:id").setParameter("id", wbc.getAttribute("messgeId").toString()).getSingleResult(true);
if(bum != null ){
bum.setAttributeValue("message_status", "has_process");
bum.setAttributeValue("is_read", "has_read");
bum.setAttributeValue("finish_time", date);
bum.setAttributeValue("read_time", date);
bumManager.saveObject(bum);
}
}
}else if ("提前结清".equals(flowName)){
BizObject ft = ftManage.createQuery(" objectno=:flowunid and phaseno='0030' ").setParameter("flowunid", flowunid).getSingleResult(false);
BizObject fo = foManager.createQuery(" SerialNo=:SerialNo ").setParameter("SerialNo", ft == null ? "" : ft.getAttribute("SerialNo").toString()).getSingleResult(false);
BizObjectManager wasMange = JBOFactory.getBizObjectManager(WECHAT_ADVANCE_SETTLE.CLASS_NAME,Sqlca);
BizObject was = wasMange.createQuery(" flowUnid=:flowUnid " ).setParameter("flowUnid", flowunid).getSingleResult(true);
if(was != null){
was.setAttributeValue("STATUS", "通过");
was.setAttributeValue("flowStatus", "通过");
was.setAttributeValue("opinions", fo == null ? "" : fo.getAttribute("phaseopinion"));
was.setAttributeValue("UPDATETIME", date);
wasMange.saveObject(was);
BizObject bum = bumManager.createQuery(" id=:id").setParameter("id", was.getAttribute("messgeId").toString()).getSingleResult(true);
if(bum != null ){
bum.setAttributeValue("message_status", "has_process");
bum.setAttributeValue("is_read", "has_read");
bum.setAttributeValue("finish_time", date);
bum.setAttributeValue("read_time", date);
bumManager.saveObject(bum);
}
}
}
return "true";
}
}