助贷资金路由记录入库开发完成

src/main/java/com/quantgroup/asset/distribution/config/rabbitmq/ConsumerConfig.java

@@ -65,7 +65,8 @@ public class ConsumerConfig implements RabbitListenerConfigurer {
             log.info("助贷资金路由结果消息接收, 消息内容 : {} ",ms);
             JSONObject jo = JSONObject.parseObject(ms);
             String noticeType = jo.getString("noticeType");
-            if(FundingResult.FUAD_ASSIGN_FAIL.getText().equals(noticeType)
+            if(FundingResult.REJECT.getText().equals(noticeType)
+                    || FundingResult.CANCEL_LOAN.getText().equals(noticeType)
                     || FundingResult.FUAD_ASSIGN_SUCC.getText().equals(noticeType)){
                 String applyNo = jo.getJSONObject("data").getString("applyNo");
                 iAidFundRouteRecordService.fundingResultNotity(applyNo,FundingResult.getAuditResultByDesc(noticeType));

src/main/java/com/quantgroup/asset/distribution/enums/funding/FundingResult.java

@@ -20,6 +20,10 @@ public enum FundingResult{
 
     FUAD_ASSIGN_FAIL("FUAD_ASSIFN_FAIL", "分配资金方失败"),
 
+    CANCEL_LOAN("CANCEL_LOAN","关单"),//属于资方分配失败
+
+    REJECT("REJECT","分配资方失败"),
+
     FUND_FAIL("FUND_FAIL", "放款失败"),
 
     REPAYMENT("REPAYMENT", "还款成功");

src/main/java/com/quantgroup/asset/distribution/service/funding/IAidFundRouteRecordService.java

 package com.quantgroup.asset.distribution.service.funding;
 
 import com.quantgroup.asset.distribution.enums.funding.FundingResult;
+import com.quantgroup.asset.distribution.service.jpa.entity.AidLoanFundRouteRecord;
 
 /**
  * Created by renfeng on 2019/7/17.
@@ -16,9 +17,11 @@ public interface IAidFundRouteRecordService {
     void fundingResultNotity(String bizNo,FundingResult fundingResult);
 
 
-
-
-
+    /**
+     * 保存主贷资金路由记录
+     * @param aidLoanFundRouteRecord
+     */
+    void saveAidLoanFundRouteRecord(AidLoanFundRouteRecord aidLoanFundRouteRecord);
 
 
 

src/main/java/com/quantgroup/asset/distribution/service/funding/IAidFundRouteService.java

@@ -12,8 +12,9 @@ public interface IAidFundRouteService {
     /**
      * 助贷资金路由
      * @param assetForm
+     * @param userLoanType
      * @return
      */
-    GlobalResponse aidFundRoute(AssetForm assetForm);
+    GlobalResponse aidFundRoute(AssetForm assetForm,Integer userLoanType);
 
 }

src/main/java/com/quantgroup/asset/distribution/service/funding/impl/AidFundRouteRecordServiceImpl.java

@@ -4,10 +4,16 @@ import com.quantgroup.asset.distribution.enums.funding.FundingResult;
 import com.quantgroup.asset.distribution.service.funding.IAidFundRouteRecordService;
 import com.quantgroup.asset.distribution.service.jpa.entity.AidLoanFundRouteRecord;
 import com.quantgroup.asset.distribution.service.jpa.repository.IAidLoanFundRouteRecordRepository;
+import com.quantgroup.asset.distribution.service.redis.IRedisService;
+import com.quantgroup.asset.distribution.util.DateUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.util.concurrent.TimeUnit;
+
+import static com.quantgroup.asset.distribution.constant.RedisKeyConstants.AID_LOAN_COUNT_LIMIT_KEY;
+
 /**
  * Created by renfeng on 2019/7/19.
  */
@@ -21,6 +27,8 @@ public class AidFundRouteRecordServiceImpl implements IAidFundRouteRecordService
     @Autowired
     private IAidLoanFundRouteRecordRepository iAidLoanFundRouteRecordRepository;
 
+    @Autowired
+    private IRedisService<String> redisService;
 
     /**
      * 资金分配结果通知
@@ -37,7 +45,23 @@ public class AidFundRouteRecordServiceImpl implements IAidFundRouteRecordService
         if(aidLoanFundRouteRecord!=null){
             aidLoanFundRouteRecord.setAidFundRouteStatus(fundingResult==FundingResult.FUAD_ASSIGN_SUCC?2:3);
             iAidLoanFundRouteRecordRepository.save(aidLoanFundRouteRecord);
+
+            //助贷资金分配成功 累加一次  限制每天分配次数
+            if(aidLoanFundRouteRecord.getAidFundRouteStatus()==2)
+                redisService.setIncr(AID_LOAN_COUNT_LIMIT_KEY + DateUtil.getDay(), 1, 3, TimeUnit.DAYS);
         }
         log.info("更新助贷资金路由状态结束，bizNo : {} , fundingResult : {} ,是否命中 : {} ",bizNo,fundingResult,aidLoanFundRouteRecord!=null);
     }
+
+    /**
+     * 保存主贷资金路由记录
+     *
+     * @param aidLoanFundRouteRecord
+     */
+    @Override
+    public void saveAidLoanFundRouteRecord(AidLoanFundRouteRecord aidLoanFundRouteRecord) {
+        iAidLoanFundRouteRecordRepository.save(aidLoanFundRouteRecord);
+    }
+
+
 }

src/main/java/com/quantgroup/asset/distribution/service/funding/impl/AidFundRouteServiceImpl.java

@@ -2,9 +2,11 @@ package com.quantgroup.asset.distribution.service.funding.impl;
 
 import com.quantgroup.asset.distribution.model.form.AssetForm;
 import com.quantgroup.asset.distribution.model.response.GlobalResponse;
+import com.quantgroup.asset.distribution.service.funding.IAidFundRouteRecordService;
 import com.quantgroup.asset.distribution.service.funding.IAidFundRouteService;
 import com.quantgroup.asset.distribution.service.funding.IAidLoanFundConfigService;
 import com.quantgroup.asset.distribution.service.jpa.entity.AidLoanFundConfig;
+import com.quantgroup.asset.distribution.service.jpa.entity.AidLoanFundRouteRecord;
 import com.quantgroup.asset.distribution.service.redis.IRedisService;
 import com.quantgroup.asset.distribution.util.DateUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -31,7 +33,8 @@ public class AidFundRouteServiceImpl implements IAidFundRouteService {
 
     @Autowired
     private IAidLoanFundConfigService iAidLoanFundConfigService;
-
+    @Autowired
+    private IAidFundRouteRecordService iAidFundRouteRecordService;
     @Autowired
     private IRedisService<String> redisService;
 
@@ -39,10 +42,11 @@ public class AidFundRouteServiceImpl implements IAidFundRouteService {
      * 助贷资金路由
      *
      * @param assetForm
+     * @param userLoanType
      * @return
      */
     @Override
-    public GlobalResponse aidFundRoute(AssetForm assetForm) {
+    public GlobalResponse aidFundRoute(AssetForm assetForm,Integer userLoanType) {
 
         //第一步 查询所有助贷资金
         List<AidLoanFundConfig> aidLoanFundConfigList = iAidLoanFundConfigService.findAll();
@@ -68,6 +72,19 @@ public class AidFundRouteServiceImpl implements IAidFundRouteService {
         //第五步 开始路由
         if(CollectionUtils.isNotEmpty(aidLoanFundConfigList)){
             //TODO 未接到助贷资金  暂时不能进行开发
+
+
+            //保存主贷资金路由记录
+            AidLoanFundRouteRecord aidLoanFundRouteRecord = new AidLoanFundRouteRecord();
+            aidLoanFundRouteRecord.setAidFundRouteStatus(1);//1-未完成 2-成功 3-失败
+            aidLoanFundRouteRecord.setAssetNo(assetForm.getAssetNo());
+            aidLoanFundRouteRecord.setBizChannel(assetForm.getBizChannel());
+            aidLoanFundRouteRecord.setBizNo(assetForm.getBizNo());
+            aidLoanFundRouteRecord.setFinanceProductType(Integer.parseInt(assetForm.getBizType()));
+            aidLoanFundRouteRecord.setUserLoanType(userLoanType);
+//            aidLoanFundRouteRecord.setFundNo("");//TODO
+//            aidLoanFundRouteRecord.setFundId("");//TODO
+            iAidFundRouteRecordService.saveAidLoanFundRouteRecord(aidLoanFundRouteRecord);
         }
         return GlobalResponse.error("未匹配到助贷资金");
     }