527 lines
21 KiB
Java
527 lines
21 KiB
Java
package com.tenwa.sdk.controller;
|
|
|
|
import java.math.BigDecimal;
|
|
import java.text.SimpleDateFormat;
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.Date;
|
|
import java.util.HashMap;
|
|
import java.util.List;
|
|
import java.util.Map;
|
|
import java.util.UUID;
|
|
|
|
import com.amarsoft.are.jbo.BizObject;
|
|
import com.amarsoft.are.jbo.BizObjectManager;
|
|
import com.amarsoft.are.jbo.BizObjectQuery;
|
|
import com.amarsoft.are.jbo.JBOFactory;
|
|
import com.amarsoft.are.jbo.JBOTransaction;
|
|
import com.tenwa.flow.action.comm.BaseFlowStartAction;
|
|
import com.tenwa.sdk.VO.SDKDcPayReqxVO;
|
|
import com.tenwa.sdk.VO.SDKInfoVO;
|
|
import com.tenwa.sdk.VO.SDKPayCallBackVO;
|
|
import com.tenwa.sdk.VO.SDKPayCallDetail;
|
|
import com.tenwa.sdk.VO.SDKPayRqxVO;
|
|
import com.tenwa.sdk.VO.SDKToPayVO;
|
|
import com.tenwa.sdk.utils.HttpRequest;
|
|
import com.tenwa.sdk.utils.XMLStream;
|
|
import com.thoughtworks.xstream.XStream;
|
|
|
|
import jbo.app.tenwa.calc.LC_FUND_INCOME_TEMP;
|
|
import jbo.com.tenwa.entity.comm.own.OWN_ACCOUNT;
|
|
import jbo.com.tenwa.lease.comm.LC_FUND_INCOME_CALLBACK_DETAIL_TEMP;
|
|
import jbo.com.tenwa.lease.comm.LC_FUND_INCOME_CALLBACK_INFO_TEMP;
|
|
import jbo.com.tenwa.lease.comm.LC_FUND_INCOME_PAY_DETAIL_TEMP;
|
|
import jbo.com.tenwa.lease.comm.LC_FUND_INCOME_PAY_INFO_TEMP;
|
|
import jbo.sys.CODE_LIBRARY;
|
|
import net.sf.json.JSONObject;
|
|
|
|
public class CmbToPayController extends BaseFlowStartAction {
|
|
private String distributor_ids; //获取选择的 经销商ID
|
|
private String FLOWUNID ; //流程号
|
|
|
|
public String getFLOWUNID() {
|
|
return FLOWUNID;
|
|
}
|
|
|
|
public void setFLOWUNID(String fLOWUNID) {
|
|
FLOWUNID = fLOWUNID;
|
|
}
|
|
|
|
public String getDistributor_ids() {
|
|
return distributor_ids;
|
|
}
|
|
|
|
public void setDistributor_ids(String distributor_ids) {
|
|
this.distributor_ids = distributor_ids;
|
|
}
|
|
|
|
@SuppressWarnings({ "unchecked", "unused" })
|
|
public synchronized String action(JBOTransaction tx) throws Exception {
|
|
/*
|
|
* 定义返回参数
|
|
*/
|
|
Map<String,String> map = new HashMap<String,String>();
|
|
map.put("code", "0") ;
|
|
map.put("msg", "") ;
|
|
|
|
/*
|
|
* 基本参数检查######开始
|
|
*/
|
|
if(FLOWUNID==null || "".equals(FLOWUNID)) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "流程编号不能为空,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
List<String> distributor_id_list = java.util.Arrays.asList(distributor_ids.split("@"));
|
|
if(distributor_id_list==null || distributor_id_list.size()<=0) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "尚未选择经销商,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
/*
|
|
* 基本参数检查######开始
|
|
*/
|
|
|
|
/*
|
|
* 本方放款账户获取######开始
|
|
*/
|
|
BizObjectManager accountManager = JBOFactory.getBizObjectManager(OWN_ACCOUNT.CLASS_NAME);
|
|
List<BizObject> accountBoList = accountManager.createQuery("select o.id,o.acc_number,o.acc_bank,o.acc_name,o.branch_code,oi.OWN_NAME from o join jbo.com.tenwa.entity.comm.own.OWN_INFO oi on o.own_id = oi.OWN_NUMBER where o.money_type='01' and o.state_='0010' and acc_type='0010' and (account_type='out_account' or account_type='inAndOut_account') ").getResultList(false);
|
|
if( accountBoList==null ||accountBoList.size()==0) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "本方账户不存在,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
if( accountBoList!=null && accountBoList.size()>1 ) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "启用的汽车类放款账户只能同时存在一个,请在本方账户中检查！") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
BizObject accountBo = accountBoList.get(0);
|
|
/*
|
|
* 本方放款账户获取######结束
|
|
*/
|
|
|
|
|
|
/*
|
|
* 付款申请基础信息定义######开始
|
|
*/
|
|
|
|
|
|
String LGNNAM = accountBo.getAttribute("OWN_NAME").toString();
|
|
String FUNNAM = "DCPAYREQ";
|
|
int DATTYP = 2;
|
|
String BUSMOD = "00001"; //默认参数 请按照实际情况谨慎修改
|
|
String BUSCOD = "N02030"; //默认参数 请按照实际情况谨慎修改
|
|
String DBTBBK = accountBo.getAttribute("branch_code").toString();
|
|
String DBTACC = accountBo.getAttribute("acc_number").toString();
|
|
String STLCHN = "F"; //默认参数
|
|
String CCYNBR = "10"; //默认参数
|
|
String TRSTYP = "100001"; //默认参数
|
|
String RCVCHK = "1"; //默认参数
|
|
/*
|
|
* 付款申请基础信息定义######结束
|
|
*/
|
|
|
|
|
|
/*
|
|
* 获取常用代码并将codeno存为主键 方便下面代码调用######开始
|
|
*/
|
|
BizObjectManager code_library = JBOFactory.getBizObjectManager(CODE_LIBRARY.CLASS_NAME);
|
|
List<BizObject> bank_code_list = code_library.createQuery("select codeno,itemno,itemname from o where codeno in ('bank_reqsts','bank_rtnflg','FeeType')").getResultList(false);
|
|
Map<String,String> bank_reqsts = new HashMap<String,String>(); //业务请求状态
|
|
Map<String,String> bank_rtnflg = new HashMap<String,String>(); //业务处理结果
|
|
Map<String,String> fee_type = new HashMap<String,String>(); //费用类型
|
|
|
|
for(BizObject code_bo:bank_code_list) {
|
|
String itemno = code_bo.getAttribute("itemno").toString();
|
|
String itemname = code_bo.getAttribute("itemname").toString();
|
|
String codeno = code_bo.getAttribute("codeno").toString();
|
|
if("bank_reqsts".equals(codeno)) {
|
|
bank_reqsts.put(itemno, itemname);
|
|
}else if("bank_rtnflg".equals(codeno)) {
|
|
bank_rtnflg.put(itemno, itemname);
|
|
}else {
|
|
fee_type.put(itemno, itemname);
|
|
}
|
|
}
|
|
String[] bank_reqsts_array = {"AUT","NTE","WCF","BNK","FIN","ACK","APD","OPR"};
|
|
String[] bank_rtnflg_array = {"S","F","B","R","D","C","M","V","U","T"};
|
|
List<String> bank_reqsts_list = Arrays.asList(bank_reqsts_array);
|
|
List<String> bank_rtnflg_list = Arrays.asList(bank_rtnflg_array);
|
|
/*
|
|
* 获取常用代码并将codeno存为主键 方便下面代码调用######结束
|
|
*/
|
|
|
|
|
|
/*
|
|
*
|
|
*/
|
|
SDKToPayVO sDKToPayVO = new SDKToPayVO();
|
|
SDKInfoVO sDKInfoVO = new SDKInfoVO();
|
|
SDKPayRqxVO sDKPayRqxVO = new SDKPayRqxVO();
|
|
List<SDKDcPayReqxVO> sDKDcPayReqxVOList = new ArrayList<SDKDcPayReqxVO>();
|
|
|
|
sDKInfoVO.setLGNNAM(LGNNAM);
|
|
sDKInfoVO.setFUNNAM(FUNNAM);
|
|
sDKInfoVO.setDATTYP(DATTYP);
|
|
|
|
sDKPayRqxVO.setBUSCOD(BUSCOD);
|
|
sDKPayRqxVO.setBUSMOD(BUSMOD);
|
|
|
|
BizObjectManager pay_info_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_PAY_INFO_TEMP.CLASS_NAME);
|
|
BizObject pay_info_bo = pay_info_bom.newObject();
|
|
|
|
String CMB_PAY_NO = UUID.randomUUID().toString().replaceAll("-", "") ; // 付款流水号
|
|
pay_info_bo.setAttributeValue("ID", UUID.randomUUID().toString().replaceAll("-", ""));
|
|
pay_info_bo.setAttributeValue("FLOWUNID", FLOWUNID);
|
|
pay_info_bo.setAttributeValue("INFO_FUNNAM", FUNNAM);
|
|
pay_info_bo.setAttributeValue("INFO_DATTYP", DATTYP);
|
|
pay_info_bo.setAttributeValue("INFO_LGNNAM", LGNNAM);
|
|
pay_info_bo.setAttributeValue("SDKPAYRQX_BUSCOD", BUSCOD);
|
|
pay_info_bo.setAttributeValue("SDKPAYRQX_BUSMOD", BUSMOD);
|
|
this.initTabeUserInfo(pay_info_bo);
|
|
|
|
|
|
List<BizObject> pay_detail_list = null;// 声明 付款发起详情list
|
|
BizObjectManager bankBo = JBOFactory.getBizObjectManager(LC_FUND_INCOME_TEMP.CLASS_NAME);
|
|
BizObject infoOne = null ;
|
|
SDKDcPayReqxVO pay_detail = null ;
|
|
SimpleDateFormat df = new SimpleDateFormat("yyyyMMddHHmmss");
|
|
BizObjectManager pay_detail_bom = null ;
|
|
String error_msg_tips = ""; //定义错误信息 是否存在
|
|
String error_null_tips = ""; //定义错误信息 是否为空
|
|
|
|
|
|
if(distributor_id_list.size() > 30){ //招行文档规定 单次批量申请不能超过30条
|
|
map.put("code", "1") ;
|
|
map.put("msg", "单次处理不能超过30条,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
|
|
pay_detail_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_PAY_DETAIL_TEMP.CLASS_NAME);
|
|
BizObject pay_detail_bo = null;
|
|
|
|
BizObjectManager call_back_detail_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_CALLBACK_DETAIL_TEMP.CLASS_NAME);
|
|
BizObject call_back_detail_bo = null ;
|
|
|
|
tx.join(call_back_detail_bom);
|
|
|
|
pay_detail_list = new ArrayList<BizObject>();
|
|
|
|
String temp_str = UUID.randomUUID().toString().replaceAll("-", "").substring(0, 14) ;
|
|
String date = df.format(new Date());
|
|
BigDecimal all_money = new BigDecimal("0");
|
|
|
|
List<BizObject> income_all_list = bankBo.createQuery("select o.CMB_PAY_NO,o.FACT_MONEY,o.FLOWUNID,contract_info.CONTRACT_NO,distributor.distributor_id,distributor.acc_number,distributor.open_bank,distributor.account,distributor.district,distributor.provinceInfo from o join jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO contract_info on o.CONTRACT_ID = contract_info.id join jbo.app.tenwa.customer.DISTRIBUTOR_ACCOUNT distributor on contract_info.distributor_id = distributor.distributor_id and distributor.is_main='Y' where FLOWUNID=:FLOWUNID and o.PAY_TYPE = 'pay_type_out' ").setParameter("FLOWUNID", FLOWUNID).getResultList(false);
|
|
if(income_all_list==null) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "资金收付数据不存在,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
int index = 1 ;
|
|
for (String distributor_id : distributor_id_list) {
|
|
infoOne = null ;
|
|
BigDecimal distributor_all_money = new BigDecimal("0");
|
|
for(BizObject income_one : income_all_list) {
|
|
String income_one_distributor_id = income_one.getAttribute("distributor_id").toString();
|
|
if(distributor_id.equals(income_one_distributor_id)) {
|
|
BigDecimal income_one_fact_money = new BigDecimal(income_one.getAttribute("FACT_MONEY").toString());
|
|
distributor_all_money = distributor_all_money.add(income_one_fact_money);
|
|
infoOne = income_one ;
|
|
}
|
|
}
|
|
all_money=all_money.add(distributor_all_money);
|
|
if(infoOne==null) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "第["+index+"]笔数据不存在,请检查") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
|
|
String FLOWUNID = this.FLOWUNID ;
|
|
String DISTRIBUTOR_ID = infoOne.getAttribute("distributor_id").toString();
|
|
String CRTACC = infoOne.getAttribute("acc_number").toString();
|
|
String BANK_NAME = infoOne.getAttribute("open_bank").toString();
|
|
String CRTNAM = infoOne.getAttribute("account").toString();
|
|
String CRTPVC = infoOne.getAttribute("provinceInfo").toString();
|
|
String CRTCTY = infoOne.getAttribute("district").toString();
|
|
String NUSAGE = infoOne.getAttribute("memo").toString();
|
|
String CMB_PAY_NO_ONE = infoOne.getAttribute("CMB_PAY_NO").toString();
|
|
|
|
/*
|
|
* 检查当前付款信息是否存在######开始
|
|
*/
|
|
if(CMB_PAY_NO_ONE!=null && CMB_PAY_NO_ONE!="" && !"".equals(CMB_PAY_NO_ONE)) {
|
|
String temp_sql = "select * from o where FLOWUNID=:FLOWUNID and CMB_PAY_NO=:CMB_PAY_NO_ONE " ;
|
|
BizObjectQuery call_back_detail_boo= call_back_detail_bom.createQuery(temp_sql);
|
|
call_back_detail_boo.setParameter("FLOWUNID",FLOWUNID) ;
|
|
call_back_detail_boo.setParameter("CMB_PAY_NO_ONE",CMB_PAY_NO_ONE) ;
|
|
call_back_detail_bo = call_back_detail_boo.getSingleResult(false) ;
|
|
if(call_back_detail_bo!=null) {
|
|
String CALL_BACK_DETAIL_REQSTS = call_back_detail_bo.getAttribute("REQSTS").toString();
|
|
String CALL_BACK_DETAIL_RTNFLG = call_back_detail_bo.getAttribute("RTNFLG").toString();
|
|
if(bank_reqsts_list.contains(CALL_BACK_DETAIL_REQSTS)) {
|
|
error_msg_tips = error_msg_tips + "第["+index+"]笔付款申请已存在[请求状态:"+bank_reqsts.get(CALL_BACK_DETAIL_REQSTS)+"]" ;
|
|
if(CALL_BACK_DETAIL_RTNFLG!="" && CALL_BACK_DETAIL_RTNFLG!=null && !"".equals(CALL_BACK_DETAIL_RTNFLG)) {
|
|
error_msg_tips = error_msg_tips+"[处理结果:"+bank_rtnflg.get(CALL_BACK_DETAIL_RTNFLG)+"]";
|
|
}
|
|
error_msg_tips = error_msg_tips+",请检查\n";
|
|
}
|
|
}
|
|
}
|
|
/*
|
|
* 检查当前付款信息是否存在######结束
|
|
*/
|
|
|
|
int check=distributor_all_money.compareTo(BigDecimal.ZERO);
|
|
|
|
if( DISTRIBUTOR_ID==null || "".equals( DISTRIBUTOR_ID )
|
|
|| CRTACC==null || "".equals( CRTACC )
|
|
|| BANK_NAME==null || "".equals( BANK_NAME )
|
|
|| CRTNAM==null || "".equals( CRTNAM )
|
|
|| CRTPVC==null || "".equals( CRTPVC )
|
|
|| CRTCTY==null || "".equals( CRTCTY )
|
|
|| CRTPVC==null || "".equals( CRTPVC )
|
|
|| check==-1
|
|
|| CRTPVC==null || "".equals( CRTPVC )
|
|
){
|
|
error_null_tips = error_null_tips+ "第["+index+"]笔相关数据不存在,请检查\n" ;
|
|
}
|
|
|
|
if(CRTPVC!=null && !"".equals(CRTPVC)) {
|
|
if(CRTCTY.indexOf(CRTPVC)!=-1) {
|
|
CRTCTY = CRTCTY.substring(CRTPVC.length());
|
|
}
|
|
}
|
|
if("6225885910000108".equals(CRTACC)) {
|
|
CRTPVC="福建";
|
|
CRTCTY="福州";
|
|
}
|
|
if("6225880230001175".equals(CRTACC)) {
|
|
CRTPVC="重庆";
|
|
CRTCTY="重庆";
|
|
}
|
|
|
|
String YURREF_INDEX = index+"" ;
|
|
if(index<10) {
|
|
YURREF_INDEX = String.format("%02d", index);
|
|
}
|
|
|
|
String TRSAMT = distributor_all_money.toPlainString();
|
|
String YURREF = YURREF_INDEX + date+ temp_str;
|
|
String BNKFLG = checkCMB(BANK_NAME);
|
|
NUSAGE = "经销商["+CRTACC+"]发起申请";
|
|
String BUSNAR = "[实际付款][经销商:"+CRTACC+"][支付金额:"+TRSAMT+"]";
|
|
|
|
pay_detail = new SDKDcPayReqxVO();
|
|
pay_detail.setYURREF(YURREF);
|
|
pay_detail.setDBTACC(DBTACC);
|
|
pay_detail.setDBTBBK(DBTBBK);
|
|
pay_detail.setTRSAMT(TRSAMT);
|
|
pay_detail.setCCYNBR(CCYNBR);
|
|
pay_detail.setSTLCHN(STLCHN);
|
|
pay_detail.setNUSAGE(NUSAGE);
|
|
pay_detail.setBUSNAR(BUSNAR);
|
|
pay_detail.setCRTACC(CRTACC);
|
|
pay_detail.setCRTNAM(CRTNAM);
|
|
pay_detail.setBNKFLG(BNKFLG);
|
|
pay_detail.setTRSTYP(TRSTYP);
|
|
pay_detail.setRCVCHK(RCVCHK);
|
|
pay_detail.setCRTPVC(CRTPVC);
|
|
pay_detail.setCRTCTY(CRTCTY);
|
|
|
|
sDKDcPayReqxVOList.add(pay_detail);
|
|
|
|
pay_detail_bo = pay_detail_bom.newObject();
|
|
|
|
pay_detail_bo.setAttributeValue("ID", UUID.randomUUID().toString().replaceAll("-", ""));
|
|
pay_detail_bo.setAttributeValue("CMB_PAY_NO", CMB_PAY_NO);
|
|
pay_detail_bo.setAttributeValue("DISTRIBUTOR_ID", DISTRIBUTOR_ID);
|
|
pay_detail_bo.setAttributeValue("FLOWUNID", FLOWUNID);
|
|
pay_detail_bo.setAttributeValue("YURREF", YURREF);
|
|
pay_detail_bo.setAttributeValue("DBTACC", DBTACC);
|
|
pay_detail_bo.setAttributeValue("DBTBBK", DBTBBK);
|
|
pay_detail_bo.setAttributeValue("TRSAMT", TRSAMT);
|
|
pay_detail_bo.setAttributeValue("CCYNBR", CCYNBR);
|
|
pay_detail_bo.setAttributeValue("STLCHN", STLCHN);
|
|
pay_detail_bo.setAttributeValue("NUSAGE", NUSAGE);
|
|
pay_detail_bo.setAttributeValue("BUSNAR", BUSNAR);
|
|
pay_detail_bo.setAttributeValue("CRTACC", CRTACC);
|
|
pay_detail_bo.setAttributeValue("CRTNAM", CRTNAM);
|
|
pay_detail_bo.setAttributeValue("BNKFLG", BNKFLG);
|
|
pay_detail_bo.setAttributeValue("TRSTYP", TRSTYP);
|
|
pay_detail_bo.setAttributeValue("RCVCHK", RCVCHK);
|
|
pay_detail_bo.setAttributeValue("CRTPVC", CRTPVC);
|
|
pay_detail_bo.setAttributeValue("CRTCTY", CRTCTY);
|
|
this.initTabeUserInfo(pay_detail_bo);
|
|
pay_detail_list.add(pay_detail_bo);
|
|
++index;
|
|
}
|
|
|
|
|
|
if(!"".equals(error_msg_tips)) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", error_msg_tips) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
|
|
if(!"".equals(error_null_tips)) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", error_null_tips) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
|
|
sDKToPayVO.setINFO(sDKInfoVO);
|
|
sDKToPayVO.setSDKPAYRQX(sDKPayRqxVO);
|
|
if(sDKDcPayReqxVOList!=null && sDKDcPayReqxVOList.size()>0) {
|
|
sDKToPayVO.setDcPayReqxList(sDKDcPayReqxVOList);
|
|
}
|
|
|
|
XStream xStream = new XMLStream();
|
|
xStream.alias("DCPAYREQX", SDKDcPayReqxVO.class);
|
|
xStream.alias("CMBSDKPGK", SDKToPayVO.class);
|
|
String xmlStr = xStream.toXML(sDKToPayVO);
|
|
xmlStr = xmlStr.replace("<dcPayReqxList>", "").replace("</dcPayReqxList>", "").replace("<dcPayReqxList/>", "");
|
|
try {
|
|
System.out.println(xmlStr); //控制台打印请求的XML数据
|
|
//HttpRequest request = new HttpRequest("http://172.16.20.242:65188");
|
|
//HttpRequest request = new HttpRequest("http://192.168.13.162:65188");
|
|
//request.setTimeout(3000);
|
|
HttpRequest request = new HttpRequest();
|
|
String data = xmlStr;
|
|
SDKPayCallBackVO result = request.sendPayRequest(data);
|
|
if(result==null) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", "请求出错") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
|
|
|
|
if(result.getInfo().getSTATUS()==1) {
|
|
if("0".equals( result.getInfo().getRETCOD() )) {
|
|
pay_info_bo.setAttributeValue("FACT_MONEY",all_money.toPlainString());
|
|
pay_info_bo.setAttributeValue("CMB_PAY_NO",CMB_PAY_NO) ;
|
|
pay_info_bo.setAttributeValue("BANK_ID",accountBo.getAttribute("id").toString()) ;
|
|
tx.join(pay_info_bom);// 插入支付信息表
|
|
pay_info_bom.saveObject(pay_info_bo);
|
|
if(pay_detail_bom!=null) {
|
|
BizObjectManager income_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_TEMP.CLASS_NAME);
|
|
tx.join(pay_detail_bom);
|
|
tx.join(income_bom);
|
|
|
|
if(pay_detail_list!=null && pay_detail_list.size()>0)
|
|
for (BizObject pay_detail_one : pay_detail_list) {
|
|
BizObjectQuery income_boo= income_bom.createQuery("update o join jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO lcf on o.contract_id = lcf.id set o.CMB_PAY_NO=:CMB_PAY_NO where o.PAY_TYPE = 'pay_type_out' and FLOWUNID=:FLOWUNID and lcf.distributor_id=:DISTRIBUTOR_ID");
|
|
income_boo.setParameter("CMB_PAY_NO",CMB_PAY_NO) ;
|
|
income_boo.setParameter("FLOWUNID",pay_detail_one.getAttribute("FLOWUNID").toString()) ;
|
|
income_boo.setParameter("DISTRIBUTOR_ID",pay_detail_one.getAttribute("DISTRIBUTOR_ID").toString()) ;
|
|
income_boo.executeUpdate();//更新资金收付表
|
|
pay_detail_bom.saveObject(pay_detail_one); //插入支付详情表
|
|
}
|
|
}
|
|
|
|
BizObjectManager callback_info_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_CALLBACK_INFO_TEMP.CLASS_NAME) ;
|
|
BizObjectManager callback_detail_bom = null;
|
|
|
|
BizObject callback_info_bo = callback_info_bom.newObject();
|
|
BizObject callback_detail_bo = null;
|
|
|
|
tx.join(callback_info_bom);
|
|
callback_info_bo.setAttributeValue("ID", UUID.randomUUID().toString().replaceAll("-", ""));
|
|
callback_info_bo.setAttributeValue("CMB_PAY_NO",CMB_PAY_NO);
|
|
callback_info_bo.setAttributeValue("FLOWUNID",FLOWUNID);
|
|
callback_info_bo.setAttributeValue("INFO_FUNNAM",FUNNAM);
|
|
callback_info_bo.setAttributeValue("INFO_DATTYP",DATTYP);
|
|
callback_info_bo.setAttributeValue("INFO_RETCOD",result.getInfo().getRETCOD());
|
|
callback_info_bo.setAttributeValue("INFO_ERRMSG",result.getInfo().getERRMSG());
|
|
this.initTabeUserInfo(callback_info_bo);
|
|
callback_info_bom.saveObject(callback_info_bo); //插入支付回调信息表
|
|
|
|
List<SDKPayCallDetail> details = result.getDetails() ;
|
|
String error_info = "";
|
|
if(details!=null && details.size()>0) {
|
|
callback_detail_bom = JBOFactory.getBizObjectManager(LC_FUND_INCOME_CALLBACK_DETAIL_TEMP.CLASS_NAME) ;
|
|
tx.join(callback_detail_bom);
|
|
int call_index = 1 ;
|
|
for (SDKPayCallDetail detail : details) {
|
|
if (detail.getREQSTS().equals("FIN") && detail.getRTNFLG().equals("F")) {
|
|
error_info= error_info+"\n"+ "第["+call_index+"]笔数据 "+detail.getERRTXT() ;
|
|
}
|
|
callback_detail_bo = callback_detail_bom.newObject();
|
|
String DETAIL_YURREF = detail.getYURREF() ;
|
|
callback_detail_bo.setAttributeValue("ID", UUID.randomUUID().toString().replaceAll("-", ""));
|
|
callback_detail_bo.setAttributeValue("CMB_PAY_NO",CMB_PAY_NO);
|
|
callback_detail_bo.setAttributeValue("YURREF",DETAIL_YURREF);
|
|
callback_detail_bo.setAttributeValue("FLOWUNID",FLOWUNID);
|
|
callback_detail_bo.setAttributeValue("SQRNBR",detail.getSQRNBR());
|
|
callback_detail_bo.setAttributeValue("REQNBR",detail.getREQNBR());
|
|
callback_detail_bo.setAttributeValue("REQSTS",detail.getREQSTS());
|
|
callback_detail_bo.setAttributeValue("RTNFLG",detail.getRTNFLG());
|
|
callback_detail_bo.setAttributeValue("OPRSQN",detail.getOPRSQN());
|
|
callback_detail_bo.setAttributeValue("OPRALS",detail.getOPRALS());
|
|
callback_detail_bo.setAttributeValue("ERRCOD",detail.getERRCOD());
|
|
callback_detail_bo.setAttributeValue("ERRTXT",detail.getERRTXT());
|
|
|
|
if(pay_detail_list!=null && pay_detail_list.size()>0) {
|
|
for (BizObject pay_detail_one : pay_detail_list) {
|
|
if(DETAIL_YURREF.equals( pay_detail_one.getAttribute("YURREF").toString() )) {
|
|
callback_detail_bo.setAttributeValue("DISTRIBUTOR_ID",pay_detail_one.getAttribute("DISTRIBUTOR_ID").toString());
|
|
}
|
|
}
|
|
}
|
|
|
|
this.initTabeUserInfo(callback_detail_bo);
|
|
callback_detail_bom.saveObject(callback_detail_bo);//插入支付回调详情表
|
|
++call_index;
|
|
}
|
|
}
|
|
if(error_info==""){
|
|
map.put("code", "0") ;
|
|
map.put("msg", "受理成功,请耐心等待审核") ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}else {
|
|
map.put("code", "2") ;
|
|
map.put("msg", "部分发起申请失败,请检查"+error_info) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
}else {
|
|
map.put("code", "1") ;
|
|
map.put("msg", result.getInfo().getERRMSG()) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
}else {
|
|
map.put("code", "1") ;
|
|
map.put("msg", result.getInfo().getERRMSG()) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
} catch (Exception e) {
|
|
map.put("code", "1") ;
|
|
map.put("msg", e.getMessage()) ;
|
|
JSONObject jsonObj = JSONObject.fromObject(map);
|
|
return jsonObj.toString();
|
|
}
|
|
}
|
|
|
|
private String checkCMB(String str) {
|
|
if (str.indexOf("招行") != -1 || str.indexOf("招商银行") != -1) {
|
|
return "Y";
|
|
} else {
|
|
return "N";
|
|
}
|
|
}
|
|
}
|