From e350e8132cdd5a63fd04e3f477b9237544d92455 Mon Sep 17 00:00:00 2001
From: river <1376754470@qq.com>
Date: Wed, 31 Mar 2021 15:53:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=A2=E6=88=B7=E7=AB=AF=E5=B0=8F=E7=A8=8B?=
 =?UTF-8?q?=E5=BA=8F=E6=9F=A5=E7=9C=8B=E7=94=B3=E8=AF=B7=E8=B4=B7=E6=AC=BE?=
 =?UTF-8?q?=E8=AF=A6=E6=83=85=E3=80=81PC=E7=AB=AF=E5=82=AC=E6=94=B6?=
 =?UTF-8?q?=E6=97=B6=E5=B1=95=E7=A4=BA=E7=9A=84=E8=AF=A6=E6=83=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../impl/CustomerAppletServiceImpl.java       | 12 ++++---
 .../service/impl/CustomerServiceImpl.java     | 35 ++++++++++---------
 .../guarantee/mapper/AlCollectionMapper.java  |  2 ++
 .../service/impl/AlCollectionServiceImpl.java | 12 +++++--
 .../mapper/guarantee/AlCollectionMapper.xml   | 13 ++++++-
 .../DgComplianceInvestigationMapper.xml       |  2 +-
 6 files changed, 52 insertions(+), 24 deletions(-)

diff --git a/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerAppletServiceImpl.java b/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerAppletServiceImpl.java
index 1963e266..b16700d4 100644
--- a/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerAppletServiceImpl.java
+++ b/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerAppletServiceImpl.java
@@ -426,20 +426,24 @@ public class CustomerAppletServiceImpl extends ServiceImpl<CustomerAppletDao, Cu
             ExceptionCast.cast(CrmsCode.CUSTOMER_APPLET_STATUS_IS_NULL);
         }
         switch (applyDetail.getAuditStatus()) {
-            case 1:
+            case 1: // 已受理
                 applyDetailResponse.setStatus(applyDetail.getAuditStatus());
                 break;
-            case 2:
+            case 2: // 审核中
                 applyDetailResponse.setStatus(applyDetail.getAuditStatus());
                 break;
-            case 3: // 拒绝
+            case 3: // 已拒绝
                 applyDetailResponse.setStatus(applyDetail.getAuditStatus());
                 applyDetailResponse.setRemark(applyDetail.getRemark());
                 break;
-            case 4: // 驳回
+            case 4: // 已驳回
                 applyDetailResponse.setStatus(applyDetail.getAuditStatus());
                 applyDetailResponse.setRemark(applyDetail.getRemark());
                 break;
+            case 5: // 已撤销
+                applyDetailResponse.setStatus(applyDetail.getAuditStatus());
+            case 6: // 草稿,正常不会出现这个状态,避免报错设置为已受理
+                applyDetailResponse.setStatus(1);
             default:
                 ExceptionCast.cast(CrmsCode.CUSTOMER_APPLET_STATUS_IS_NULL);
         }
diff --git a/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerServiceImpl.java b/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerServiceImpl.java
index 46e828bb..72644145 100644
--- a/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerServiceImpl.java
+++ b/dq-financial-crms/src/main/java/com/daqing/financial/crms/service/impl/CustomerServiceImpl.java
@@ -639,17 +639,19 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerDao, CustomerEntity
             List<CrmsCustomerRelated> relatedList = new ArrayList<>();
             List<Integer> intList = companyCustomerReq.getRelatedId();
 
-            for (int i = 0; i < intList.size(); i++) {
-                CrmsCustomerRelated crmsCustomerRelated = new CrmsCustomerRelated();
-                Integer integer = intList.get(i);
-                crmsCustomerRelated.setCustomerId(companyCustomerEntity.getId().intValue());//企业id
-                crmsCustomerRelated.setRelatedId(integer);//关联人/企业id
-                relatedList.add(crmsCustomerRelated);
+            if (null != intList && intList.size() != 0) {
+                for (int i = 0; i < intList.size(); i++) {
+                    CrmsCustomerRelated crmsCustomerRelated = new CrmsCustomerRelated();
+                    Integer integer = intList.get(i);
+                    crmsCustomerRelated.setCustomerId(companyCustomerEntity.getId().intValue());//企业id
+                    crmsCustomerRelated.setRelatedId(integer);//关联人/企业id
+                    relatedList.add(crmsCustomerRelated);
+                }
+                crmsCustomerRelatedService.insertCustomerRelated(relatedList);
             }
-            crmsCustomerRelatedService.insertCustomerRelated(relatedList);
         }
 
-        if (customer == true && company > 0) {
+        if (customer && company > 0) {
             return true;
         }
         return false;
@@ -696,17 +698,18 @@ public class CustomerServiceImpl extends ServiceImpl<CustomerDao, CustomerEntity
         List<CrmsCustomerRelated> relatedList = new ArrayList<>();
         List<Integer> intList = companyCustomerReq.getRelatedId();
 
-        for (int i = 0; i < intList.size(); i++) {
-            CrmsCustomerRelated crmsCustomerRelated = new CrmsCustomerRelated();
-            Integer integer = intList.get(i);
-            crmsCustomerRelated.setCustomerId(companyCustomerEntity.getCustomerId().intValue());//企业id  companyCustomerEntity.getId().intValue()
-            crmsCustomerRelated.setRelatedId(integer);//关联人/企业id
-            relatedList.add(crmsCustomerRelated);
+        if (null != intList && intList.size() != 0) {
+            for (int i = 0; i < intList.size(); i++) {
+                CrmsCustomerRelated crmsCustomerRelated = new CrmsCustomerRelated();
+                Integer integer = intList.get(i);
+                crmsCustomerRelated.setCustomerId(companyCustomerEntity.getCustomerId().intValue());//企业id  companyCustomerEntity.getId().intValue()
+                crmsCustomerRelated.setRelatedId(integer);//关联人/企业id
+                relatedList.add(crmsCustomerRelated);
+            }
         }
         if (relatedList.size() > 0) {
             crmsCustomerRelatedService.insertCustomerRelated(relatedList);
         }
-            return true;
-
+        return true;
     }
 }
\ No newline at end of file
diff --git a/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/AlCollectionMapper.java b/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/AlCollectionMapper.java
index 14436944..6fad01c4 100644
--- a/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/AlCollectionMapper.java
+++ b/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/mapper/AlCollectionMapper.java
@@ -34,6 +34,8 @@ public interface AlCollectionMapper extends BaseMapper<AlCollection> {
 
     OverdueDetailResponse getOverdueDetailByInsuranceId(Integer insuranceId);
 
+    Integer getCollectionCountByInsuranceId(Integer insuranceId);
+
     MoreOverdueDetailResponse moreOverdueDetail(Integer id);
 
     Integer getInsuranceIdById(Integer id);
diff --git a/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/AlCollectionServiceImpl.java b/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/AlCollectionServiceImpl.java
index c645edab..060061e1 100644
--- a/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/AlCollectionServiceImpl.java
+++ b/dq-financial-guarantee/src/main/java/com/daqing/financial/guarantee/service/impl/AlCollectionServiceImpl.java
@@ -143,6 +143,11 @@ public class AlCollectionServiceImpl extends ServiceImpl<AlCollectionMapper, AlC
         }
         OverdueDetailResponse overdueDetailResponse = this.getBaseMapper().getOverdueDetailByInsuranceId(insuranceId);
         if (null != overdueDetailResponse) {
+            // 催收次数
+            Integer numberOfCollection = this.getBaseMapper().getCollectionCountByInsuranceId(insuranceId);
+            if (null != numberOfCollection) {
+                overdueDetailResponse.setNumberOfCollection(numberOfCollection);
+            }
             // 逾期金额、逾期利息、其他费用、逾期次数
             Map<String, Object> map = this.getOverdueConditionByInsuranceId(insuranceId);
             if (null != map) {
@@ -346,6 +351,8 @@ public class AlCollectionServiceImpl extends ServiceImpl<AlCollectionMapper, AlC
         BigDecimal overdueInterest = new BigDecimal(0.00);
         // 其他费用
         BigDecimal otherExpenses = new BigDecimal(0.00);
+        // 返回数据集合
+        Map<String, Object> map = new HashMap<>();
         List<AlRepaymentEntry> alRepaymentList = alRepaymentEntryMapper.listAlRepaymentByInsuranceId(insuranceId);
         if (alRepaymentList != null && alRepaymentList.size() != 0) {
             for (AlRepaymentEntry alRepayment : alRepaymentList) {
@@ -353,9 +360,10 @@ public class AlCollectionServiceImpl extends ServiceImpl<AlCollectionMapper, AlC
                 overdueInterest = overdueInterest.add(alRepayment.getInterest() == null ? new BigDecimal(0.00) : alRepayment.getInterest());
                 otherExpenses = otherExpenses.add(alRepayment.getOtherExpenses() == null ? new BigDecimal(0.00) : alRepayment.getOtherExpenses());
             }
+            map.put("overduePeriods", alRepaymentList.size());
+        } else {
+            map.put("overduePeriods", 0);
         }
-        Map<String, Object> map = new HashMap<>();
-        map.put("overduePeriods", alRepaymentList.size());
         map.put("overdueAmount", overdueAmount);
         map.put("overdueInterest", overdueInterest);
         map.put("otherExpenses", otherExpenses);
diff --git a/dq-financial-guarantee/src/main/resources/mapper/guarantee/AlCollectionMapper.xml b/dq-financial-guarantee/src/main/resources/mapper/guarantee/AlCollectionMapper.xml
index a9a58a4a..29925712 100644
--- a/dq-financial-guarantee/src/main/resources/mapper/guarantee/AlCollectionMapper.xml
+++ b/dq-financial-guarantee/src/main/resources/mapper/guarantee/AlCollectionMapper.xml
@@ -40,12 +40,23 @@
                #{ac.collectionUser},#{ac.overduePeriods})
     </insert>
 
-    <select id="getOverdueDetailByInsuranceId" parameterType="integer" resultType="com.daqing.financial.guarantee.model.response.OverdueDetailResponse">
+    <!--<select id="getOverdueDetailByInsuranceId" parameterType="integer" resultType="com.daqing.financial.guarantee.model.response.OverdueDetailResponse">
        SELECT i.customer_name AS name,i.business_type AS type,i.business_code AS code,COUNT(c.id) AS number_of_collection
        FROM al_insurance_list AS i
        INNER JOIN al_collection AS c
        ON i.id = c.insurance_id
        WHERE i.id = #{insuranceId}
+    </select>-->
+
+    <!-- 催收时贷款记录 -->
+    <select id="getOverdueDetailByInsuranceId" parameterType="integer" resultType="com.daqing.financial.guarantee.model.response.OverdueDetailResponse">
+       SELECT customer_name AS name,business_type AS type,business_code AS code
+       FROM al_insurance_list WHERE i.id = #{insuranceId}
+    </select>
+
+    <!-- 根据保后id查询催收的次数 -->
+    <select id="getCollectionCountByInsuranceId" parameterType="integer" resultType="integer">
+        SELECT COUNT(id) FROM al_collection WHERE insurance_id = #{insuranceId}
     </select>
 
     <!-- 催收列表 -->
diff --git a/dq-financial-guarantee/src/main/resources/mapper/guarantee/DgComplianceInvestigationMapper.xml b/dq-financial-guarantee/src/main/resources/mapper/guarantee/DgComplianceInvestigationMapper.xml
index 055d77e7..1a40f3a3 100644
--- a/dq-financial-guarantee/src/main/resources/mapper/guarantee/DgComplianceInvestigationMapper.xml
+++ b/dq-financial-guarantee/src/main/resources/mapper/guarantee/DgComplianceInvestigationMapper.xml
@@ -195,7 +195,7 @@
     <select id="getAttacheAndABByBusinessId" parameterType="integer" resultType="com.daqing.framework.domain.guarantee.po.AttacheAndABUserIdPO">
         SELECT (SELECT id FROM dg_guarantee_assign_user WHERE business_id = #{businessId} AND role_id = 59) AS a_user_id,
                (SELECT id FROM dg_guarantee_assign_user WHERE business_id = #{businessId} AND role_id = 60) AS b_user_id,
-               a.id,m.id
+               a.emp_id AS asset_user_id,m.emp_id AS message_user_id
         FROM dg_assets_investigation AS a
         LEFT JOIN dg_message_investigation AS m
         ON a.business_id = m.business_id