anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

接口平台推送

Browse Source
This commit is contained in:
lixuebo 2019-08-26 09:28:49 +08:00
parent b65ed34aee
commit 6672bb9cfe
1 changed files with 70 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

70
src_tenwa/com/tenwa/lease/app/quartzmession/ApprovalOpinionPush.java Normal file
View File

@ -0,0 +1,70 @@
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();
}
}
}
}