接口平台

This commit is contained in:
lixuebo 2019-10-10 15:23:33 +08:00
parent 55c454b2f3
commit fbfb74b991
11 changed files with 96 additions and 14 deletions

View File

@ -4,12 +4,14 @@ import java.util.ArrayList;
import java.util.List;
import com.amarsoft.are.jbo.JBOTransaction;
import jbo.com.tenwa.entity.comm.flow.FLOW_BUSSINESS_OBJECT;
import com.amarsoft.are.ARE;
import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;
import com.amarsoft.are.jbo.JBOFactory;
import com.amarsoft.are.lang.DataElement;
import com.amarsoft.are.log.Log;
import com.amarsoft.awe.util.SqlObject;
import com.tenwa.reckon.bean.KnowingConfigBean;
@ -89,7 +91,13 @@ public class TbBeanTools {
TabCalBean tcb = new TabCalBean();
tcb = getTabInfo(calType);
tcb.setPlanCValue(plannumber);
String Condition_tb =tcb.getCondition_tb();
String PlanCName = tcb.getPlanCName();
BizObject condition = JBOFactory.getBizObjectManager( tcb.getCondition_tb(), tx ).createQuery( "select * from O where flowunid = :flowunid and "+tcb.getPlanCName()+"='"+plannumber+"'" ).setParameter( "flowunid", flowunid ).getSingleResult( false );
DataElement yearRate = condition.getAttribute("YEAR_RATE");
if(yearRate!=null) {
String str = condition.getAttribute("YEAR_RATE").toString();
}
tcb.setCondition(condition);
//ÉèÖÃÒÑÖª¹æÔò
BizObjectManager m2 = JBOFactory.getBizObjectManager( tcb.getRuleTb(), tx );

View File

@ -0,0 +1,5 @@
url=http://localhost:8080/platform/batch/kjflc/
FileToPush=pushToBatchDealAllTimer
AtTheEndOfContractPush=ContractFinishPushTimer
ContractLoanPush=loanPushTimer
PushApprovalOpinions=publicPushApproveTimer

View File

@ -6,11 +6,7 @@ import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import jbo.app.tenwa.customer.CUSTOMER_ACCOUNT;
import jbo.com.tenwa.lease.comm.LB_INSURANCE_INFO;
import jbo.sys.CODE_LIBRARY;
import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;
import com.amarsoft.are.jbo.JBOFactory;
@ -25,7 +21,7 @@ public class BankCardChangeReminderMessage extends BaseBussinessMessage{
public void loadMessageInfo()throws Exception{
String reminderDays = this.messageParam.get("reminderdays")==null?"0":this.messageParam.get("reminderdays");
Date currentTime = new Date();
Date currentTime = new Date();
SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
Calendar calendar = Calendar.getInstance();
calendar.setTime(currentTime);

View File

@ -7,7 +7,6 @@ import jbo.com.tenwa.entity.comm.message.BT_BUSSINESS_MESSAGE_CONFIG;
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;

View File

@ -2,10 +2,8 @@ package com.tenwa.comm.message.controller;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
import jbo.com.tenwa.entity.comm.message.BT_BUSSINESS_MESSAGE;
import jbo.com.tenwa.entity.comm.message.BT_BUSSINESS_MESSAGE_CONFIG;
import com.amarsoft.app.lc.util.DateAssistant;
import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;

View File

@ -6,12 +6,7 @@ import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import jbo.app.tenwa.customer.CUSTOMER_ACCOUNT;
import jbo.app.tenwa.doc.LB_DOC_CONTRACT_LIST;
import jbo.com.tenwa.lease.comm.LB_INSURANCE_INFO;
import jbo.sys.CODE_LIBRARY;
import com.amarsoft.are.jbo.BizObject;
import com.amarsoft.are.jbo.BizObjectManager;
import com.amarsoft.are.jbo.JBOFactory;
@ -57,5 +52,4 @@ public class CardChangeReminderMessage extends BaseBussinessMessage{
}
}
}
}

View File

@ -210,6 +210,7 @@ public class HttpClientSUtil {
Map<String,String> resultMap = new HashMap<String, String>();
resultMap.put("data",EntityUtils.toString(response.getEntity(),"UTF-8"));
resultMap.put("status",String.valueOf(response.getStatusLine().getStatusCode()));
System.err.println(resultMap);
return resultMap;
}
}

View File

@ -0,0 +1,20 @@
package com.tenwa.lease.app.quartzmession;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.tenwa.gps.HttpClientSUtil;
import com.tenwa.httpclient.resources.InterfacePlatformConfigure;
public class AtTheEndOfContractPush implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("AtTheEndOfContractPush"),null,null);
} catch (Exception e) {
e.printStackTrace();
}
}
}

View File

@ -0,0 +1,20 @@
package com.tenwa.lease.app.quartzmession;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.tenwa.gps.HttpClientSUtil;
import com.tenwa.httpclient.resources.InterfacePlatformConfigure;
public class ContractLoanPush implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("ContractLoanPush"),null,null);
} catch (Exception e) {
e.printStackTrace();
}
}
}

View File

@ -0,0 +1,21 @@
package com.tenwa.lease.app.quartzmession;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.tenwa.gps.HttpClientSUtil;
import com.tenwa.httpclient.resources.InterfacePlatformConfigure;
public class FileToPush implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("FileToPush"),null,null);
} catch (Exception e) {
e.printStackTrace();
}
}
}

View File

@ -0,0 +1,20 @@
package com.tenwa.lease.app.quartzmession;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.tenwa.gps.HttpClientSUtil;
import com.tenwa.httpclient.resources.InterfacePlatformConfigure;
public class PushApprovalOpinions implements Job {
@Override
public void execute(JobExecutionContext arg0) throws JobExecutionException {
try {
HttpClientSUtil.doGet(InterfacePlatformConfigure.get("url")+InterfacePlatformConfigure.get("PushApprovalOpinions"),null,null);
} catch (Exception e) {
e.printStackTrace();
}
}
}