bug处理

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

@@ -20,4 +20,10 @@ public class OrderChildLoanRetryRecordDaoImpl extends BaseDaoImpl<OrderChildLoan
     public List<OrderChildLoanRetryRecord> selectListByOwnerUserNoAndIdAsc(Long userNo) {
         return baseMapper.selectList(lQrWrapper().eq(OrderChildLoanRetryRecord::getOwnerUserNo, userNo).orderByAsc(OrderChildLoanRetryRecord::getId));
     }
+
+    @Override
+    public OrderChildLoanRetryRecord selectOneByOwnerIdAndDriverId(Integer ownerId, Integer driverId) {
+        return baseMapper.selectOne(lQrWrapper().eq(OrderChildLoanRetryRecord::getSettlementOwnerId, ownerId)
+                .eq(OrderChildLoanRetryRecord::getSettlementDriverId, driverId));
+    }
 }

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

@@ -14,4 +14,6 @@ import java.util.List;
 public interface OrderChildLoanRetryRecordDao extends BaseDao<OrderChildLoanRetryRecordMapper, OrderChildLoanRetryRecord, Integer> {
 
     List<OrderChildLoanRetryRecord> selectListByOwnerUserNoAndIdAsc(Long userNo);
+
+    OrderChildLoanRetryRecord selectOneByOwnerIdAndDriverId(Integer ownerId, Integer driverId);
 }

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

@@ -67,13 +67,19 @@ public class EventListenerComponent {
         log.info("当前货主结算信息{},车主结算信息：{}", JSONUtil.parse(settlementOwnerDetail), JSONUtil.parse(settlementDriverDetail));
         settlementOwnerDetailDao.updateInvoiceType(settlementOwnerDetail);
         settlementDriverDetailDao.updateInvoiceTypeAndPrepayFreightFlag(settlementDriverDetail);
+        Integer ownerId = settlementOwnerDetail.getId();
+        Integer driverId = settlementDriverDetail.getId();
+
+        OrderChildLoanRetryRecord record = orderChildLoanRetryRecordDao.selectOneByOwnerIdAndDriverId(ownerId, driverId);
+        if (record == null) {
+            OrderChildLoanRetryRecord entity = new OrderChildLoanRetryRecord();
+            entity.setSettlementOwnerId(ownerId);
+            entity.setSettlementDriverId(driverId);
+            entity.setOwnerUserNo(settlementOwnerDetail.getOwnerUserNo());
+            // 保存重试记录
+            orderChildLoanRetryRecordDao.saveEntity(entity);
+        }
 
-        OrderChildLoanRetryRecord entity = new OrderChildLoanRetryRecord();
-        entity.setSettlementOwnerId(settlementOwnerDetail.getId());
-        entity.setSettlementDriverId(settlementDriverDetail.getId());
-        entity.setOwnerUserNo(settlementOwnerDetail.getOwnerUserNo());
-        // 保存重试记录
-        orderChildLoanRetryRecordDao.saveEntity(entity);
     }
 
     @EventListener(classes = {OwnerRepaymentUpdateEvent.class})