|
|
@@ -13,6 +13,7 @@ import com.fs.sop.mapper.SopUserLogsInfoMapper;
|
|
|
import com.fs.sop.mapper.SopUserLogsMapper;
|
|
|
import com.fs.sop.params.QwRatingConfig;
|
|
|
import com.fs.sop.service.IQwSopTempDayService;
|
|
|
+import com.fs.sop.service.ISopUserLogsInfoService;
|
|
|
import com.fs.sop.vo.QwRatingVO;
|
|
|
import com.fs.system.service.ISysConfigService;
|
|
|
import com.fs.voice.utils.StringUtil;
|
|
|
@@ -61,6 +62,9 @@ public class QwExternalContactRatingServiceImpl implements QwExternalContactRati
|
|
|
@Autowired
|
|
|
private QwExternalContactMapper qwExternalContactMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private ISopUserLogsInfoService iSopUserLogsInfoService;
|
|
|
+
|
|
|
@Autowired
|
|
|
private ExecutorService sopRatingExecutor; // 自定义线程池
|
|
|
|
|
|
@@ -247,6 +251,7 @@ public class QwExternalContactRatingServiceImpl implements QwExternalContactRati
|
|
|
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
|
|
|
try {
|
|
|
qwExternalContactMapper.batchUpdateQwExternalContact(batchList);
|
|
|
+ iSopUserLogsInfoService.batchUpdateSopUserLogsInfoByLevel(batchList);
|
|
|
log.info("成功更新评级数据,起始索引: {}, 数量: {}", finalI, batchList.size());
|
|
|
} catch (Exception e) {
|
|
|
log.error("批量更新异常,批次起始索引: {}", finalI, e);
|