refactor(scheduled): 使用 User 和 UserInterior 替换 VUserInterior 及相关服务

- 替换用户信息查询由 vUserInteriorService 改为 userService 和 userInteriorService
- 改用 User 实体替代 VUserInterior 实体,简化用户信息获取逻辑
- 调整部门领导查询逻辑,改用 userInteriorService 查询部门id
- 更新各处用户姓名和部门领导获取方式,提高代码一致性和可维护性
- 移除对 IVUserInteriorService 的依赖,改为 IUserService 和 IUserInteriorService 注入
This commit is contained in:
funny 2026-05-08 15:28:56 +08:00
parent 4b46818041
commit 2544f8e589
1 changed files with 26 additions and 27 deletions

View File

@ -7,13 +7,15 @@ import com.nflg.wms.repository.entity.DictionaryItem;
import com.nflg.wms.repository.entity.QmsPdiDetectionRules; import com.nflg.wms.repository.entity.QmsPdiDetectionRules;
import com.nflg.wms.repository.entity.QmsPdiTaskRecord; import com.nflg.wms.repository.entity.QmsPdiTaskRecord;
import com.nflg.wms.repository.entity.QmsTodoItem; import com.nflg.wms.repository.entity.QmsTodoItem;
import com.nflg.wms.repository.entity.VUserInterior; import com.nflg.wms.repository.entity.User;
import com.nflg.wms.repository.entity.UserInterior;
import com.nflg.wms.repository.service.IDepartmentService; import com.nflg.wms.repository.service.IDepartmentService;
import com.nflg.wms.repository.service.IDictionaryItemService; import com.nflg.wms.repository.service.IDictionaryItemService;
import com.nflg.wms.repository.service.IQmsPdiDetectionRulesService; import com.nflg.wms.repository.service.IQmsPdiDetectionRulesService;
import com.nflg.wms.repository.service.IQmsPdiTaskRecordService; import com.nflg.wms.repository.service.IQmsPdiTaskRecordService;
import com.nflg.wms.repository.service.IQmsTodoItemService; import com.nflg.wms.repository.service.IQmsTodoItemService;
import com.nflg.wms.repository.service.IVUserInteriorService; import com.nflg.wms.repository.service.IUserInteriorService;
import com.nflg.wms.repository.service.IUserService;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import tech.powerjob.worker.core.processor.ProcessResult; import tech.powerjob.worker.core.processor.ProcessResult;
@ -40,7 +42,10 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
private IQmsPdiDetectionRulesService detectionRulesService; private IQmsPdiDetectionRulesService detectionRulesService;
@Resource @Resource
private IVUserInteriorService vUserInteriorService; private IUserService userService;
@Resource
private IUserInteriorService userInteriorService;
@Resource @Resource
private IDepartmentService departmentService; private IDepartmentService departmentService;
@ -108,17 +113,12 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
Long assistantId = task.getAssistantId(); Long assistantId = task.getAssistantId();
// 查询质检人信息 // 查询质检人信息
VUserInterior inspector = vUserInteriorService.lambdaQuery() User inspector = userService.getById(inspectorId);
.eq(VUserInterior::getUserId, inspectorId)
.one();
String inspectorName = inspector != null ? inspector.getUserName() : "未知"; String inspectorName = inspector != null ? inspector.getUserName() : "未知";
String assistantName = ""; String assistantName = "";
if (assistantId != null) { if (assistantId != null) {
VUserInterior assistant = vUserInteriorService.lambdaQuery() User assistant = userService.getById(assistantId);
.eq(VUserInterior::getUserId, assistantId)
.one();
assistantName = assistant != null ? assistant.getUserName() : "未知"; assistantName = assistant != null ? assistant.getUserName() : "未知";
} }
@ -128,20 +128,25 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
Set<Long> leaderIds = new HashSet<>(); Set<Long> leaderIds = new HashSet<>();
// 质检人的部门领导 // 质检人的部门领导
if (inspector != null && inspector.getDeptId() != null) { if (inspector != null) {
Department dept = departmentService.getById(inspector.getDeptId()); UserInterior inspectorInterior = userInteriorService.lambdaQuery()
.eq(UserInterior::getUserId, inspectorId)
.one();
if (inspectorInterior != null && inspectorInterior.getDeptId() != null) {
Department dept = departmentService.getById(inspectorInterior.getDeptId());
if (dept != null && dept.getHeadUserId() != null) { if (dept != null && dept.getHeadUserId() != null) {
leaderIds.add(dept.getHeadUserId()); leaderIds.add(dept.getHeadUserId());
} }
} }
}
// 帮办人的部门领导 // 帮办人的部门领导
if (assistantId != null) { if (assistantId != null) {
VUserInterior assistant = vUserInteriorService.lambdaQuery() UserInterior assistantInterior = userInteriorService.lambdaQuery()
.eq(VUserInterior::getUserId, assistantId) .eq(UserInterior::getUserId, assistantId)
.one(); .one();
if (assistant != null && assistant.getDeptId() != null) { if (assistantInterior != null && assistantInterior.getDeptId() != null) {
Department dept = departmentService.getById(assistant.getDeptId()); Department dept = departmentService.getById(assistantInterior.getDeptId());
if (dept != null && dept.getHeadUserId() != null) { if (dept != null && dept.getHeadUserId() != null) {
leaderIds.add(dept.getHeadUserId()); leaderIds.add(dept.getHeadUserId());
} }
@ -153,9 +158,7 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
task.getTaskNo(), inspectorName, assistantText); task.getTaskNo(), inspectorName, assistantText);
for (Long leaderId : leaderIds) { for (Long leaderId : leaderIds) {
VUserInterior leader = vUserInteriorService.lambdaQuery() User leader = userService.getById(leaderId);
.eq(VUserInterior::getUserId, leaderId)
.one();
QmsTodoItem todo = new QmsTodoItem() QmsTodoItem todo = new QmsTodoItem()
.setCode(task.getTaskNo()) .setCode(task.getTaskNo())
@ -196,9 +199,7 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
String messageContent = String.format("PDI检测任务[%s]将在%d小时内到期请尽快完成", String messageContent = String.format("PDI检测任务[%s]将在%d小时内到期请尽快完成",
task.getTaskNo(), remainingHours); task.getTaskNo(), remainingHours);
VUserInterior inspector = vUserInteriorService.lambdaQuery() User inspector = userService.getById(inspectorId);
.eq(VUserInterior::getUserId, inspectorId)
.one();
QmsTodoItem todoInspector = new QmsTodoItem() QmsTodoItem todoInspector = new QmsTodoItem()
.setCode(task.getTaskNo()) .setCode(task.getTaskNo())
@ -214,9 +215,7 @@ public class PdiTaskOverdueNotifyProcessor implements BasicProcessor {
// 给帮办人推送消息 // 给帮办人推送消息
if (assistantId != null) { if (assistantId != null) {
VUserInterior assistant = vUserInteriorService.lambdaQuery() User assistant = userService.getById(assistantId);
.eq(VUserInterior::getUserId, assistantId)
.one();
QmsTodoItem todoAssistant = new QmsTodoItem() QmsTodoItem todoAssistant = new QmsTodoItem()
.setCode(task.getTaskNo()) .setCode(task.getTaskNo())