罚息

src/main/java/com/jqtx/windows/job/SyncFaJob.java

@@ -65,12 +65,15 @@ public class SyncFaJob {
                 log.info("oss逾期数据:{}", stringObject);
                 //存储并去平账
                 List<FaModel> getlist = getlist(stringObject);
-                for (FaModel faModel : getlist) {
-                    //查询plan
-                    LoanPlanModel planModel = loanPlanComponent.getPlanNoByLoan(faModel.getLoanReqNo(), faModel.getTerm());
-                    planModel.setPlanFa(new BigDecimal(faModel.getOintAmt()));
-                    loanPlanComponent.updateByLoanPlanModel(planModel);
-                }
+                getlist.parallelStream().forEach(faModel -> {
+                    try {
+                        LoanPlanModel planModel = loanPlanComponent.getPlanNoByLoan(faModel.getLoanReqNo(), faModel.getTerm());
+                        planModel.setPlanFa(new BigDecimal(faModel.getOintAmt()));
+                        loanPlanComponent.updateByLoanPlanModel(planModel);
+                    } catch (Exception e) {
+                        log.error("同步浙农逾期数据,案件编号:{},期数：{},报错{}", faModel.getLoanReqNo(), faModel.getTerm(), e.getMessage(), e);
+                    }
+                });
                 FileUtil.del("/assurance_sftp.txt");
             } else {
                 log.info("浙农逾期文件不存在:{}", date);