feat(*): bug修复

- bug修复

feat(*): bug修复
- bug修复
张志伟
1 parent 4763ee92
Showing 1 changed file with 7 additions and 1 deletions
fw-valhalla-service/src/main/java/cn/fw/valhalla/service/bus/ipt/CustomerInitClueBizService.kt
@@ -15,6 +15,7 @@ import cn.fw.valhalla.rpc.pstn.PstnRpcService
 import cn.fw.valhalla.service.data.CustomerInitClueCallLogService
 import cn.fw.valhalla.service.data.CustomerInitClueService
 import com.baomidou.mybatisplus.extension.kotlin.KtQueryWrapper
+import com.baomidou.mybatisplus.extension.kotlin.KtUpdateWrapper
 import kotlinx.coroutines.*
 import org.springframework.beans.factory.annotation.Value
 import org.springframework.data.redis.core.StringRedisTemplate
@@ -176,7 +177,12 @@ class CustomerInitClueBizService(
                     idStr = stringRedisTemplate.opsForSet().pop(key)
                 }
                 if (idList.isNotEmpty()) {
-                    customerInitClueService.removeByIds(idList)
+                    customerInitClueService.update(
+                        KtUpdateWrapper(CustomerInitClue::class.java)
+                            .set(CustomerInitClue::yn, false)
+                            .eq(CustomerInitClue::yn, true)
+                            .`in`(CustomerInitClue::id, idList)
+                    )
                 }
             }
         }