op

src/main/java/cn/quantgroup/cashloanflowboss/spi/jolyne/JolyneServiceImpl.java

 package cn.quantgroup.cashloanflowboss.spi.jolyne;
 
+import cn.quantgroup.cashloanflowboss.spi.clf.model.LoanProgress;
 import cn.quantgroup.cashloanflowboss.spi.jolyne.model.JolyneDB;
+import cn.quantgroup.cashloanflowboss.spi.xyqb.entity.LoanApplicationHistory;
 import cn.quantgroup.cashloanflowboss.spi.xyqb.entity.WaitingFundingCorpOperatePeople;
 import cn.quantgroup.cashloanflowboss.spi.xyqb.service.XYQBCenterService;
 import com.google.common.collect.Lists;
@@ -55,9 +57,14 @@ public class JolyneServiceImpl implements JolyneService {
             } catch (InterruptedException e) {
                 e.printStackTrace();
             }
-            waitingFundingCorpOperatePeople = xyqbCenterService.findWaitingFundingCorpOperatePeopleByLoanId(loanId);
 
-            if (++ i > 10000) {
+            LoanApplicationHistory loanApplicationHistory = xyqbCenterService.findLoanApplicationHistoryById(loanId);
+            if (loanApplicationHistory != null && LoanProgress.WAITING_FUND.equals(loanApplicationHistory.getProgress())) {
+                // loan 状态是20 改变 waitingFundingCorpOperatePeople 创建时间
+                waitingFundingCorpOperatePeople = xyqbCenterService.findWaitingFundingCorpOperatePeopleByLoanId(loanId);
+                break;
+            }
+            if (++ i > 50000) {
                 return "fail";
             }
         }

src/main/java/cn/quantgroup/cashloanflowboss/spi/opapi/OPCenter.java

@@ -3,15 +3,22 @@ package cn.quantgroup.cashloanflowboss.spi.opapi;
 import org.springframework.cloud.netflix.feign.FeignClient;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 
 
 @Component
-@FeignClient(name = "OPCenterService", url = "${op.api-host}", fallback = OPCenter.Fallback.class)
+@FeignClient(name = "OPCenter", url = "${op.api-host}", fallback = OPCenter.Fallback.class)
 public interface OPCenter {
+
   @GetMapping(value = "/user/login")
   String getToken(@RequestParam("auth") String auth);
 
+
+  @PostMapping(value = "/clotho/funds/plan/loan/apply", consumes = "application/json")
+  String clothoFundsPlanLoanApply(@RequestBody String jsonData);
+
   @Component
   class Fallback implements OPCenter {
 
@@ -19,6 +26,11 @@ public interface OPCenter {
     public String getToken(String auth) {
       return null;
     }
+
+    @Override
+    public String clothoFundsPlanLoanApply(String jsonData) {
+      return null;
+    }
   }
 }
 

src/main/java/cn/quantgroup/cashloanflowboss/spi/opapi/service/OPCenterService.java

+package cn.quantgroup.cashloanflowboss.spi.opapi.service;
+
+/**
+ * function:
+ * date: 2019/10/25
+ *
+ * @author: suntao
+ */
+public interface OPCenterService {
+
+    String getToken(String auth);
+
+    String clothoFundsPlanLoanApply(Integer fundingCorpId);
+}

src/main/java/cn/quantgroup/cashloanflowboss/spi/opapi/service/OPCenterServiceImpl.java

+package cn.quantgroup.cashloanflowboss.spi.opapi.service;
+
+import cn.quantgroup.cashloanflowboss.spi.opapi.OPCenter;
+import cn.quantgroup.cashloanflowboss.utils.JSONTools;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * function:
+ * date: 2019/10/25
+ *
+ * @author: suntao
+ */
+@Service
+public class OPCenterServiceImpl implements OPCenterService {
+
+
+    @Autowired
+    private OPCenter opCenter;
+
+    @Override
+    public String getToken(String auth) {
+        return opCenter.getToken(auth);
+    }
+
+    @Override
+    public String clothoFundsPlanLoanApply(Integer fundingCorpId) {
+
+        Map<String, Object> param = new HashMap<>(4);
+        param.put("fundingCorpId", fundingCorpId);
+        param.put("amountLimit", 10000L);
+        param.put("peopleLimit", 1000L);
+        return opCenter.clothoFundsPlanLoanApply(JSONTools.serialize(param));
+    }
+}