处理接单bug

performance-web/src/main/java/com/clx/performance/dao/impl/loan/OwnerLoanAccountRunningWaterRecordDaoImpl.java

@@ -124,4 +124,9 @@ public class OwnerLoanAccountRunningWaterRecordDaoImpl extends BaseDaoImpl<Owner
                 .eq(OwnerLoanAccountRunningWaterRecord::getRunningWaterType, runningWaterType)
         );
     }
+
+    @Override
+    public List<OwnerLoanAccountRunningWaterRecord> selectLoanRunningWatterRecordByLoanNoForRepay(Long loanNo) {
+        return baseMapper.selectLoanRunningWatterRecordByLoanNoForRepay(loanNo);
+    }
 }

performance-web/src/main/java/com/clx/performance/dao/loan/OwnerLoanAccountRunningWaterRecordDao.java

@@ -35,4 +35,7 @@ public interface OwnerLoanAccountRunningWaterRecordDao extends BaseDao<OwnerLoan
 
     List<OwnerLoanAccountRunningWaterRecord> getListByChildNoAndRunningWaterType(List<String> childNoList, Integer runningWaterType);
 
+    //单独用,别复用
+    List<OwnerLoanAccountRunningWaterRecord> selectLoanRunningWatterRecordByLoanNoForRepay(Long loanNo);
+
 }

performance-web/src/main/java/com/clx/performance/event/EventListenerComponent.java

@@ -136,8 +136,8 @@ public class EventListenerComponent {
     public void listen(OwnerLoanFlagEvent event) {
         log.info("OwnerLoanFlagEvent事件执行");
         Long loanNo = event.getLoanNo();
-        List<OwnerLoanAccountRunningWaterRecord> records = ownerLoanAccountRunningWaterRecordDao.selectLoanRunningWatterRecord
-                (loanNo, OwnerLoanAccountRunningWaterRecordEnum.RunWaterType.APPROVE_CHILD_WRITE_OFF.getCode());
+        List<OwnerLoanAccountRunningWaterRecord> records = ownerLoanAccountRunningWaterRecordDao.selectLoanRunningWatterRecordByLoanNoForRepay
+                (loanNo);
 
         Map<String, List<OwnerLoanAccountRunningWaterRecord>> listMap = records.stream().collect(Collectors.groupingBy(OwnerLoanAccountRunningWaterRecord::getChildNo));
         List<String> childNoList = new LinkedList<>();

performance-web/src/main/java/com/clx/performance/mapper/loan/OwnerLoanAccountRunningWaterRecordMapper.java

@@ -10,6 +10,8 @@ import com.clx.performance.vo.pc.loan.carrier.OwnerLoanAccountRunningWaterRecord
 import org.apache.ibatis.annotations.Param;
 import org.apache.ibatis.annotations.SelectProvider;
 
+import java.util.List;
+
 /**
  * @author kavin
  * Date 2024-01-20
@@ -23,4 +25,6 @@ public interface OwnerLoanAccountRunningWaterRecordMapper extends BaseMapper<Own
     @SelectProvider(type = OwnerLoanAccountRunningWaterRecordSqlProvider.class, method = "pageByParam")
     IPage<OwnerLoanAccountRunningWaterRecordVO> pageByParam(@Param("page") Page<OwnerLoanAccountRunningWaterRecordVO> page, @Param("param") PageOwnerLoanAccountWaterRecordOfOwnerParam param);
 
+    @SelectProvider(type = OwnerLoanAccountRunningWaterRecordSqlProvider.class, method = "selectLoanRunningWatterRecordByLoanNoForRepay")
+    List<OwnerLoanAccountRunningWaterRecord> selectLoanRunningWatterRecordByLoanNoForRepay(@Param("loanNo")Long loanNo);
 }

performance-web/src/main/java/com/clx/performance/sqlProvider/loan/OwnerLoanAccountRunningWaterRecordSqlProvider.java

 package com.clx.performance.sqlProvider.loan;
 
+import cn.hutool.core.util.ObjectUtil;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.clx.performance.enums.loan.OwnerLoanAccountRunningWaterRecordEnum;
+import com.clx.performance.param.pc.PageOwnerCaseOutListParam;
 import com.clx.performance.param.pc.loan.carrier.PageOwnerLoanAccountWaterRecordOfOwnerParam;
 import com.clx.performance.vo.pc.loan.carrier.OwnerLoanAccountRunningWaterRecordVO;
 import org.apache.commons.lang3.StringUtils;
@@ -34,4 +37,18 @@ public class OwnerLoanAccountRunningWaterRecordSqlProvider {
         }}.toString();
     }
 
+    public String selectLoanRunningWatterRecordByLoanNoForRepay(@Param("loanNo") Long loanNo) {
+        String inSql ="(select distinct child_no from owner_loan_account_running_water_record where loan_no = #{loanNo} and running_water_type =" + OwnerLoanAccountRunningWaterRecordEnum.RunWaterType.APPROVE_CHILD_WRITE_OFF.getCode() + ")";
+
+        String sql = "select id, owner_user_no as ownerUserNo, owner_user_name as ownerUserName, mobile, " +
+                " running_water_no as runningWaterNo, loan_no as loanNo, child_no as childNo, " +
+                " running_water_type as runningWaterType, " +
+                " alteration_balance as alterationBalance, use_able_balance as useAbleBalance, frozen_balance as frozenBalance, account_balance as accountBalance, " +
+                " create_by as createBy, " +
+                " date_format(create_time, '%Y-%m-%d %H:%i:%s') as createTime, " +
+                " date_format(modified_time, '%Y-%m-%d %H:%i:%s') as modifiedTime  from  owner_loan_account_running_water_record where running_water_type = " + OwnerLoanAccountRunningWaterRecordEnum.RunWaterType.APPROVE_CHILD_WRITE_OFF.getCode()
+                +" and child_no in " + inSql;
+        return sql;
+    }
+
 }