From 91eeb185de1e8ccc632d4fc1efeb0f9abf315050 Mon Sep 17 00:00:00 2001
From: 16639036659 <577530412@qq.com>
Date: 星期二, 02 七月 2024 09:18:23 +0800
Subject: [PATCH] 上报数据与拉去任务初步版本
---
src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java | 17 ++++++++++++++---
1 files changed, 14 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
index 7266c9b..2c77813 100644
--- a/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
+++ b/src/main/java/com/ruoyi/doublePrevention/scheduls/SearchReportDateSchedule.java
@@ -373,8 +373,17 @@
CJTaskFromWork.setCheckCycleUnit("年");
}
//获取用户信息
- User createUser = trUserService.getUserByLoginName(jobById.getCreateBy());
- User updateUser = trUserService.getUserByLoginName(jobById.getUpdateBy());
+ User createUser = new User();
+ User updateUser = new User();
+ createUser = trUserService.getUserByLoginName(jobById.getCreateBy());
+ if(ObjectUtils.isEmpty(createUser)){
+ createUser = trUserService.getUserByName(jobById.getCreateBy());
+ }
+
+ updateUser = trUserService.getUserByLoginName(jobById.getUpdateBy());
+ if(ObjectUtils.isEmpty(updateUser)){
+ updateUser = trUserService.getUserByName(jobById.getUpdateBy());
+ }
//封装上报昌吉州任务配置数据
CJTaskFromWork.setId(work.getJobUuid());
@@ -453,6 +462,7 @@
List<Long> taskIds = new ArrayList<>();
//获取上报数据对象
List<PreventCJReportCheckRecordFromTask> CJRecordFromTaskLists = new ArrayList<>();
+ int tag = 0;
// HandlerReportParam handlerReportParam = new HandlerReportParam();
// List<HandlerReportParam> handlerReportParamList = new ArrayList<>();
if (ObjectUtils.isNotEmpty(tasks)){
@@ -593,6 +603,7 @@
// preventRiskDangerCheckLogService.updateTaskReportStatus(handlerReportParam);
int i = 1;
taskIds.add(task.getId());
+ tag ++;
}
System.out.println("【##】5.数据封装完成...");
@@ -605,7 +616,7 @@
logger.info("【双重预防】排查任务记录CJ：数据处理...");
//设置原始数据状态
int taskUpdateResult = preventRiskDangerCheckLogService.updateTaskReportStatusByList(taskIds);
- if (taskUpdateResult < tasks.size()){
+ if (taskUpdateResult < taskIds.size()){
throw new AusinessException(E.ADD_FAIL.getCode(), "排查任务记录原始数据更新失败, 取消操作");
}
int result = CJTaskRecordService.insertRecordList(CJRecordFromTaskLists);
--
Gitblit v1.9.2