加日志

src/main/java/com/quantgroup/asset/distribution/controller/NewAssertController.java

@@ -35,6 +35,7 @@ public class NewAssertController {
         try {
             coreFilter.coreHandle(auditResponce);
         } catch (Exception e) {
+            log.info("assetsHandler | 有异常");
             return GlobalResponse.error(e.getMessage());
         }
         return GlobalResponse.create(AssetResponse.SUCCESS);

src/main/java/com/quantgroup/asset/distribution/service/newrule/CoreFilter.java

@@ -88,6 +88,7 @@ public class CoreFilter {
                 continue;
             }
             if (currentVerify(fundProduct,auditResponce,associationBean,channelRuleEntity)){
+                log.info("coreHandle | 所有规则校验通过");
                 financeProducts.add(build(auditResponce,fundProduct,channelRuleEntity));
             }
             routingRecordList.add(generateRouteRecord(channelRuleEntity));
@@ -97,6 +98,7 @@ public class CoreFilter {
         }
         FilterResult result = new FilterResult();
         result.setFinanceProducts(JSON.toJSONString(financeProducts));
+        log.info("coreHandle | 通知业务系统审核结果");
         Map<String,String> response = httpService.postHasResponse(auditResponce.getCallbackUrl(), result.get(auditResponce));
         if(MapUtils.isEmpty(response) || !(HttpStatus.OK.value() + "").equals(response.get("statusCode"))
                 || (!"success".equals(response.get("response")) && (!JSONObject.isValidObject(response.get("response"))
@@ -108,6 +110,7 @@ public class CoreFilter {
             log.error("通知业务系统审核结果失败 {}",JSON.toJSONString(auditResponce));
             throw new QGException(QGExceptionType.NOTIFY_BIZ_ERROR);
         } else {
+            log.info("coreHandle | 保存路由记录");
             RoutingRecordEntity routingRecordEntity = new RoutingRecordEntity();
             routingRecordEntity.setCreditNo(auditResponce.getBizNo());
             routingRecordEntity.setPhone(associationBean.getPhoneNo());
@@ -154,6 +157,7 @@ public class CoreFilter {
         WhiteListEntity whiteListEntity = whiteListRepository.getByPhoneEquals(associationBean.getPhoneNo());
         Boolean basicInfoVerify = basicInfoVerify(fundProduct,associationBean,auditResponce,channelRuleEntity);
         if (whiteListEntity != null && basicInfoVerify){
+            log.info("currentVerify | 走白名单");
             return Boolean.TRUE;
         }
         return specialInfoVerify(fundProduct, associationBean) && basicInfoVerify;
@@ -246,6 +250,7 @@ public class CoreFilter {
                 return Boolean.FALSE;
             }
         }
+        log.info("specialInfoVerify | 当前用户其他规则检验通过");
         return Boolean.TRUE;
     }