hz/java-servers
1
0
Fork 0
mirror of https://codeup.aliyun.com/67762337eccfc218f6110e0e/per-boe/java-servers.git synced 2025-12-11 20:06:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

案例专家：修改批处理问题

Browse Source
This commit is contained in:
liu.zixi
2025-10-09 16:54:04 +08:00
parent ecf39fe624
commit 69a0866fc7
1 changed files with 4 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
servers/boe-server-all/src/main/java/com/xboe/module/boecase/task/CaseUploadTask.java
View File

@@ -6,13 +6,11 @@ import com.xboe.module.boecase.dao.CaseDocumentLogDao;
import com.xboe.module.boecase.dao.CasesDao; import com.xboe.module.boecase.dao.CasesDao;
import com.xboe.module.boecase.entity.CaseDocumentLog; import com.xboe.module.boecase.entity.CaseDocumentLog;
import com.xboe.module.boecase.entity.Cases; import com.xboe.module.boecase.entity.Cases;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.time.LocalDateTime; import java.time.LocalDateTime;
@@ -24,8 +22,6 @@ import java.util.List;
*/ */
@Component @Component
@Slf4j @Slf4j
@RestController
@RequestMapping("/xboe/m/boe/caseUpload")
public class CaseUploadTask { public class CaseUploadTask {
@Resource @Resource
@@ -42,7 +38,7 @@ public class CaseUploadTask {
private static final String CASE_UPLOAD_LAST_ID_KEY = "case:upload:last:id"; private static final String CASE_UPLOAD_LAST_ID_KEY = "case:upload:last:id";
@PostMapping("/execute") @XxlJob("oldDataUploadJob")
public void oldDataUploadJob() { public void oldDataUploadJob() {
try { try {
log.info("开始执行旧案例上传任务"); log.info("开始执行旧案例上传任务");
@@ -65,12 +61,12 @@ public class CaseUploadTask {
for (Cases cases : casesToProcess) { for (Cases cases : casesToProcess) {
caseIds.add(cases.getId()); caseIds.add(cases.getId());
} }
// 一次性查询所有相关案例的记录 // 一次性查询所有相关案例的记录
List<CaseDocumentLog> existingLogs = caseDocumentLogDao.getGenericDao() List<CaseDocumentLog> existingLogs = caseDocumentLogDao.getGenericDao()
.findList(CaseDocumentLog.class, .findList(CaseDocumentLog.class,
com.xboe.core.orm.FieldFilters.in("caseId", caseIds)); com.xboe.core.orm.FieldFilters.in("caseId", caseIds));
// 过滤出未在CaseDocumentLog中存在的案例 // 过滤出未在CaseDocumentLog中存在的案例
List<Cases> casesList = new ArrayList<>(); List<Cases> casesList = new ArrayList<>();
for (Cases cases : casesToProcess) { for (Cases cases : casesToProcess) {
@@ -106,15 +102,6 @@ public class CaseUploadTask {
} }
} }
/**
* 清除处理位置标记，使下次任务从头开始执行
*/
@PostMapping("/reset")
public void resetLastProcessedId() {
stringRedisTemplate.delete(CASE_UPLOAD_LAST_ID_KEY);
log.info("已清除上次处理位置标记");
}
/** /**
* 查询需要处理的案例数据 * 查询需要处理的案例数据
* *