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

风控中台对接-评分卡推送结果，非本系统数据处理

Browse Source
This commit is contained in:
zhanglei 2023-09-13 15:46:12 +08:00
parent d52107085e
commit 5dd2284e31
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/com/ample/esb/server/WriteScoreResultThread.java
View File

@ -15,6 +15,7 @@ import jbo.com.tenwa.lease.comm.LB_PROJECT_INFO_TEMP;
import jbo.com.tenwa.lease.comm.LB_SMS_NOTICE_TASKS;
import jbo.oti.*;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.dom4j.DocumentException;
import java.text.SimpleDateFormat;
@ -79,11 +80,24 @@ public class WriteScoreResultThread extends Thread{
JSONObject baseInfoJson = resJson.getJSONObject("BASE_INFO");//申请号
String projectNo = baseInfoJson.getString("APPLICATION_NUMBER");//申请号
String tranNo = baseInfoJson.getString("TRAN_NO");//流水号
String flowNo = queryProjectTemp(projectNo);
ARE.getLog().info("WriteScoreResultThread#saveUpdateScoreResult：tranNo=" + tranNo);
// : 2023-8-24 解析结果
SimpleDateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); //日期格式
String date = sdf.format(new Date()); //将系统时间转换成上方指定类型
String flowNo = queryProjectTemp(projectNo);
if(StringUtils.isEmpty(flowNo)){
ARE.getLog().error("WriteScoreResultThread#saveUpdateScoreResult ---【查询流程编号为空，非本系统数据】-----------》：projectNo=" + projectNo + "---》：tranNo=" + tranNo);
// 更新回调接口执行状态
String callBackLogId = resStrJson.getString("callBackLogId");//处理日志logID
BizObjectManager rcCallbackLog = JBOFactory.getBizObjectManager(RC_CALLBACK_LOG.CLASS_NAME, tx);
BizObject rcCallbackLogBizObject = rcCallbackLog.createQuery("callback_id=:callback_id").setParameter("callback_id", callBackLogId).getSingleResult(true);
rcCallbackLogBizObject.setAttributeValue("handle_sts", "2");
rcCallbackLogBizObject.setAttributeValue("handle_value", "非本系统数据");
rcCallbackLogBizObject.setAttributeValue("update_time", date);
rcCallbackLog.saveObject(rcCallbackLogBizObject);
return;
}
ARE.getLog().info("WriteScoreResultThread#saveUpdateScoreResult：tranNo=" + tranNo);
// : 2023-8-24 解析结果
String resultId = UUIDUtil.getUUID();
JSONObject blazeResultJson = resJson.getJSONObject("BLAZERESULT");//评分结果项
String resultCode = blazeResultJson.getString("RESULT_CODE");// 评分结果状态 1000为成功，其他失败