Browse Source

指定字段查询

master
583641232@qq.com 1 year ago
parent
commit
204737d37f
  1. 2
      cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java
  2. 5
      cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java

2
cas-system/src/main/java/com/inscloudtech/datacenter/service/QueryCenterService.java

@ -602,7 +602,7 @@ public class QueryCenterService {
deleteRequest.setRefresh(true); deleteRequest.setRefresh(true);
BulkByScrollResponse response = restHighLevelClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT); BulkByScrollResponse response = restHighLevelClient.deleteByQuery(deleteRequest, RequestOptions.DEFAULT);
long deletedCount = response.getDeleted(); long deletedCount = response.getDeleted();
if(!unNeedDeleteMysql.contains(index)){
if(!unNeedDeleteMysql.contains(index) && StrUtil.isNotEmpty(query.getCaseId())){
this.deleteMysqlData(index,query.getCaseId()); this.deleteMysqlData(index,query.getCaseId());
} }

5
cas-system/src/main/java/com/inscloudtech/datacenter/service/impl/BankServiceImpl.java

@ -1552,7 +1552,10 @@ public class BankServiceImpl implements BankService {
// 等待任务完成 // 等待任务完成
sw.stop(); sw.stop();
sw.getTotalTimeSeconds(); sw.getTotalTimeSeconds();
log.error("流水导入结束耗时【"+sw.getTotalTimeSeconds()+"】秒");
long sizeInBytes = mf.getSize(); // 获取文件大小单位为字节
double sizeInMB = (double) sizeInBytes / (1024 * 1024); // 转换为兆字节
log.error("流水文件大小【{}】MB,导入结束耗时【{}】秒",sizeInMB,sw.getTotalTimeSeconds());
int total = execVo.getTotal(); int total = execVo.getTotal();
rollbackProcess(execVo.getErrorItem(),caseId); rollbackProcess(execVo.getErrorItem(),caseId);

Loading…
Cancel
Save