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

反欺诈-反欺诈回调修改结果由projectNo改为flowunid

Browse Source
This commit is contained in:
zhanglei@ap-leasing.com.cn 2023-09-20 11:43:06 +08:00
parent c8b5bc3a36
commit 8e5feb570d
1 changed files with 25 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/com/ample/esb/controller/AfsResultServlet.java
View File

@ -10,7 +10,9 @@ import com.ample.esb.util.BaicPropertiesUtil;
import com.ample.esb.util.DateUtils;
import com.ample.esb.util.XstreamUtil;
import com.ample.sms.FileUtil;
import jbo.com.tenwa.lease.comm.LB_PROJECT_INFO_TEMP;
import jbo.oti.RC_SCORE_RESULT;
import org.apache.commons.collections.CollectionUtils;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
@ -20,6 +22,7 @@ import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.util.List;
public class AfsResultServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
@ -80,7 +83,8 @@ public class AfsResultServlet extends HttpServlet {
BizObject boRsr = null;
try {
bom = JBOFactory.getBizObjectManager(RC_SCORE_RESULT.CLASS_NAME);
boRsr = bom.createQuery("project_no=:projectNo").setParameter("projectNo",projectNo).getSingleResult(true);
String flowUnid = queryProjectTemp(projectNo);
boRsr = bom.createQuery("flow_no=:flow_no").setParameter("flow_no",flowUnid).getSingleResult(true);
boRsr.setAttributeValue("fraud_alert_code",fraudAlert);
boRsr.setAttributeValue("fraud_taken_code",actionTaken);
boRsr.setAttributeValue("update_time", DateUtils.dateTimeNowCore());
@ -104,6 +108,26 @@ public class AfsResultServlet extends HttpServlet {
return responseXml;
}
private String queryProjectTemp(String projectNo) throws JBOException {
String flowNo = null;
BizObjectManager lbProjectInfo = JBOFactory.getBizObjectManager(LB_PROJECT_INFO_TEMP.CLASS_NAME);// ÏîÄ¿ÐÅÏ¢
List<BizObject> lbProjectInfoBizObjectList = lbProjectInfo.createQuery("PROJECT_NO=:PROJECT_NO").setParameter("PROJECT_NO", projectNo).getResultList(false);
if(CollectionUtils.isNotEmpty(lbProjectInfoBizObjectList)){
for(BizObject lbProject : lbProjectInfoBizObjectList){
if(null == flowNo){
flowNo = lbProject.getAttribute("FLOWUNID").toString();
ARE.getLog().info("WriteScoreResultThread#saveUpdateScoreResult£ºflowNoTempLong=" + flowNo.substring(3));
}else {
String flowNoTemp = lbProject.getAttribute("FLOWUNID").toString();
ARE.getLog().info("WriteScoreResultThread#saveUpdateScoreResult£ºflowNoTemp=" + flowNo);
if(Long.parseLong(flowNo.substring(3)) < Long.parseLong(flowNoTemp.substring(3))){
flowNo = flowNoTemp;
}
}
}
}
return flowNo;
}
public void doGet(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
doPost(request, response);