71 lines
2.5 KiB
Java
71 lines
2.5 KiB
Java
package com.tenwa.lease.app.quartzmession;
|
|
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
|
|
import jbo.sys.LM_APPROVAL_OPINION_LOG;
|
|
|
|
import org.quartz.Job;
|
|
import org.quartz.JobExecutionContext;
|
|
import org.quartz.JobExecutionException;
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
import com.amarsoft.are.jbo.BizObject;
|
|
import com.amarsoft.are.jbo.BizObjectManager;
|
|
import com.amarsoft.are.jbo.JBOException;
|
|
import com.amarsoft.are.jbo.JBOFactory;
|
|
import com.amarsoft.are.jbo.JBOTransaction;
|
|
import com.tenwa.gps.HttpClientSUtil;
|
|
import com.tenwa.httpclient.resources.GPSConfigure;
|
|
/**
|
|
* 接口平台业务推送审批结果
|
|
* @author Administrator
|
|
*
|
|
*/
|
|
public class ApprovalOpinionPush implements Job {
|
|
private static String interfacePlatformUrl = GPSConfigure.get("TYuserAccount");
|
|
@Override
|
|
public void execute(JobExecutionContext arg0) throws JobExecutionException {
|
|
JBOTransaction tx = null;
|
|
try {
|
|
tx = JBOFactory.createJBOTransaction();
|
|
BizObjectManager laolBm = JBOFactory.getBizObjectManager(LM_APPROVAL_OPINION_LOG.CLASS_NAME,tx);
|
|
List<BizObject> laolBoList = laolBm.createQuery("PUSH_NUMBER<3 and PUSH_STATUS is null").getResultList(true);
|
|
for(BizObject laolBo:laolBoList){
|
|
Map<String,String> params = new HashMap<String,String>();
|
|
params.put("applicationNo",laolBo.getAttribute("APPLICATION_NO").toString());
|
|
params.put("flowunid",laolBo.getAttribute("FLOWUNID").toString());
|
|
params.put("processNode",laolBo.getAttribute("PROCESS_NODE").toString());
|
|
params.put("approveOpinion",laolBo.getAttribute("APPROVE_OPINION").toString());
|
|
params.put("approveStatus",laolBo.getAttribute("APPROVE_STATUS").toString());
|
|
params.put("approveTime",laolBo.getAttribute("APPROVE_ENDTIME").toString());
|
|
String jsonString = JSON.toJSONString(params);
|
|
|
|
Map<String,String> result = HttpClientSUtil.doPostJson(interfacePlatformUrl,jsonString);
|
|
String status = result.get("status");
|
|
String data = result.get("data");
|
|
if(!"200".equals(status)){
|
|
laolBo.setAttributeValue("PUSH_STATUS","PUSH");
|
|
}
|
|
laolBo.setAttributeValue("PUSH_NUMBER",Integer.valueOf(laolBo.getAttribute("APPROVE_OPINION").toString())+1);
|
|
laolBm.saveObject(laolBo);
|
|
}
|
|
|
|
} catch (Exception e) {
|
|
e.printStackTrace();
|
|
try {
|
|
tx.rollback();
|
|
} catch (JBOException e1) {
|
|
e1.printStackTrace();
|
|
}
|
|
}finally{
|
|
try {
|
|
tx.commit();
|
|
} catch (JBOException e1) {
|
|
e1.printStackTrace();
|
|
}
|
|
}
|
|
}
|
|
}
|