From 8853292babb2ad94de4a3207966f1e83b767cd2d Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Sun, 17 Sep 2023 16:38:34 +0800
Subject: [PATCH] 新增流程节点进程查询接口
---
src/main/java/org/springblade/modules/dispatcher/service/impl/DispatcherServiceImpl.java | 57 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++-
1 files changed, 56 insertions(+), 1 deletions(-)
diff --git a/src/main/java/org/springblade/modules/dispatcher/service/impl/DispatcherServiceImpl.java b/src/main/java/org/springblade/modules/dispatcher/service/impl/DispatcherServiceImpl.java
index 41e85d9..6a6782d 100644
--- a/src/main/java/org/springblade/modules/dispatcher/service/impl/DispatcherServiceImpl.java
+++ b/src/main/java/org/springblade/modules/dispatcher/service/impl/DispatcherServiceImpl.java
@@ -16,13 +16,19 @@
*/
package org.springblade.modules.dispatcher.service.impl;
+import lombok.AllArgsConstructor;
import org.springblade.modules.dispatcher.entity.Dispatcher;
+import org.springblade.modules.dispatcher.vo.DispatcherUnitVO;
import org.springblade.modules.dispatcher.vo.DispatcherVO;
import org.springblade.modules.dispatcher.mapper.DispatcherMapper;
import org.springblade.modules.dispatcher.service.IDispatcherService;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springblade.modules.system.entity.User;
+import org.springblade.modules.system.service.IUserService;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.metadata.IPage;
+
+import java.util.List;
/**
* 服务实现类
@@ -31,11 +37,35 @@
* @since 2021-07-07
*/
@Service
+@AllArgsConstructor
public class DispatcherServiceImpl extends ServiceImpl<DispatcherMapper, Dispatcher> implements IDispatcherService {
+
+ private final IUserService userService;
@Override
public IPage<DispatcherVO> selectDispatcherPage(IPage<DispatcherVO> page, DispatcherVO dispatcher) {
- return page.setRecords(baseMapper.selectDispatcherPage(page, dispatcher));
+ List<DispatcherVO> dispatcherVOS = baseMapper.selectDispatcherPage(page, dispatcher);
+// if (dispatcherVOS.size()>0){
+// dispatcherVOS.forEach(dispatcherVO -> {
+// String userIds = dispatcherVO.getUserIds();
+// if (!userIds.isEmpty()){
+// String[] userIdArray = userIds.split(",");
+// if (userIdArray.length>0) {
+// StringBuilder builder = new StringBuilder();
+// //查询用户信息
+// for (String userId : userIdArray) {
+// User user = userService.getById(userId);
+// if (null != user) {
+// builder.append(user.getRealName()).append(",");
+// }
+// }
+// String s = builder.toString();
+// dispatcherVO.setSecurityName(s.substring(0,s.length()-1));
+// }
+// }
+// });
+// }
+ return page.setRecords(dispatcherVOS);
}
/**
@@ -47,4 +77,29 @@
public DispatcherVO getDispatcherInfo(Dispatcher dispatcher) {
return baseMapper.getDispatcherInfo(dispatcher);
}
+
+ /**
+ * 派遣记录条数
+ * @param dispatcherUnitVO1
+ * @return
+ */
+ @Override
+ public Integer getDispatcherCount(DispatcherUnitVO dispatcherUnitVO1) {
+ return baseMapper.getDispatcherCount(dispatcherUnitVO1);
+ }
+
+ /**
+ * 查询用的派遣信息
+ * @param userId 用户id
+ * @return
+ */
+ @Override
+ public DispatcherVO getDispatcherInfoByUserId(Long userId) {
+ return baseMapper.getDispatcherInfoByUserId(userId);
+ }
+
+ @Override
+ public void updateEndtime(String endTime, String disId) {
+ baseMapper.updateEndtime(endTime, disId);
+ }
}
--
Gitblit v1.9.3