增量A1报送显示资方名称

src/main/java/cn/quantgroup/report/domain/baihang/FundingCorpInfo.java

+package cn.quantgroup.report.domain.baihang;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serializable;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class FundingCorpInfo implements Serializable {
+    private static final long serialVersionUID = -1L;
+
+    private Long id;
+
+    private String name;
+
+    private String description;
+
+}

src/main/java/cn/quantgroup/report/mapper/baihang/ApplyLoanInfoMapper.java

@@ -2,6 +2,7 @@ package cn.quantgroup.report.mapper.baihang;
 
 import cn.quantgroup.report.domain.baihang.ApplyLoanInfoZhuDai;
 import cn.quantgroup.report.domain.baihang.BaiHangTimeRecord;
+import cn.quantgroup.report.domain.baihang.FundingCorpInfo;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
@@ -57,4 +58,6 @@ public interface ApplyLoanInfoMapper {
     List<ApplyLoanInfoZhuDai> findRealTimeApplyLoanZhuDaiLh(BaiHangTimeRecord timeRecord);
 
 
+    List<FundingCorpInfo> findFundingCorpInfo(List<Integer> list);
+
 }

src/main/java/cn/quantgroup/report/service/baihang/BaiHangFileReportService.java

@@ -34,6 +34,7 @@ import java.io.File;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
+import java.util.stream.Collectors;
 
 import static cn.quantgroup.report.error.QGExceptionType.COMMON_ILLEGAL_PARAM_TOAST;
 
@@ -683,4 +684,13 @@ public class BaiHangFileReportService {
         }
     }
 
+    public String getFundNameBySplitSymbol(List<Integer> fundingCorpIdList,String splitSymbol) {
+        StringBuffer fundNameBuffer = new StringBuffer();
+        List<FundingCorpInfo> fundingCorpInfoList = applyLoanInfoMapper.findFundingCorpInfo(fundingCorpIdList);
+        if (!CollectionUtils.isEmpty(fundingCorpInfoList)) {
+            fundNameBuffer.append(fundingCorpInfoList.stream().map(fundingCorpInfo -> fundingCorpInfo.getName()).collect(Collectors.joining(splitSymbol)));
+        }
+        return fundNameBuffer.toString();
+    }
+
 }

src/main/java/cn/quantgroup/report/service/baihang/BaiHangZhuDaiService.java

@@ -150,6 +150,8 @@ public class BaiHangZhuDaiService {
     private static final String rootTemplate = "%s \n %s \n %s";
     @Autowired
     public ApplyLoanInfoZhuDaiMapper applyLoanInfoZhuDaiMapper;
+    @Autowired
+    private BaiHangFileReportService baiHangFileReportService;
 
 
     @PostConstruct
@@ -246,10 +248,13 @@ public class BaiHangZhuDaiService {
             }
         }
         log.info("量化派助贷TO百行报送(A1)-贷款申请报送完成, 实际大小: {} , 报送成功大小: {} , 耗时: {} ", applyLoanInfos.size(), succ_atomicInteger.get(), (sendWatch.stop().elapsed(TimeUnit.MILLISECONDS) / 1000) + ".s");
-
-        String resMsgTemp = "申请报送(A1): 查询 %d条, 报送成功 %d条;";
+        List<Integer> fundingCorpIdList = new ArrayList<>(Arrays.asList(1080,100040,1030,100030));
+        String fundNames = baiHangFileReportService.getFundNameBySplitSymbol(fundingCorpIdList,",");
+        String resMsgTemp = "申请报送(A1): 查询 %d条, 报送成功 %d条, 报送资方: %s ";
         resMsgTemp += "[" + (applyLoanInfos.size() == succ_atomicInteger.get()) + "]";
-        return String.format(resMsgTemp, applyLoanInfos.size(), succ_atomicInteger.get());
+        String resMsg = String.format(resMsgTemp, applyLoanInfos.size(), succ_atomicInteger.get(), fundNames);
+        dingTalk.talkToLeader("Info","", resMsg);
+        return resMsg;
     }
 
 

src/main/resources/cn/quantgroup/report/mapper/baihang/ApplyLoanInfoMapper.xml

@@ -137,4 +137,13 @@
         else i.created_at end < #{endTime,jdbcType=VARCHAR};
     </select>
 
+    <select id="findFundingCorpInfo" parameterType="java.util.List" resultType="cn.quantgroup.report.domain.baihang.FundingCorpInfo">
+        select id,name,description
+        from xyqb.funding_corp
+        where id in
+        <foreach collection="list" item="id" index="index" open="(" close=")" separator=",">
+            #{id}
+        </foreach>
+    </select>
+
 </mapper>
\ No newline at end of file