From 23855599412c4d61b38d78f0f3abd3430a48b5b1 Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期三, 25 六月 2025 11:51:38 +0800
Subject: [PATCH] Merge branch 'mdc_hyjs_master'
---
lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProcessSpecVersionDepartmentServiceImpl.java | 133 ++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 133 insertions(+), 0 deletions(-)
diff --git a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProcessSpecVersionDepartmentServiceImpl.java b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProcessSpecVersionDepartmentServiceImpl.java
new file mode 100644
index 0000000..041eafc
--- /dev/null
+++ b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProcessSpecVersionDepartmentServiceImpl.java
@@ -0,0 +1,133 @@
+package org.jeecg.modules.dnc.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.apache.commons.collections4.ListUtils;
+import org.jeecg.modules.dnc.entity.ProcessSpecVersionDepartment;
+import org.jeecg.modules.dnc.mapper.ProcessSpecVersionDepartmentMapper;
+import org.jeecg.modules.dnc.service.IProcessSpecVersionDepartmentService;
+import org.jeecg.modules.dnc.utils.ValidateUtil;
+import org.jeecg.modules.system.entity.MdcProduction;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Service
+public class ProcessSpecVersionDepartmentServiceImpl extends ServiceImpl<ProcessSpecVersionDepartmentMapper, ProcessSpecVersionDepartment> implements IProcessSpecVersionDepartmentService {
+
+ /**
+ * 鏍规嵁宸ヨ壓瑙勭▼鐗堟湰id鍒犻櫎閮ㄩ棬鏉冮檺
+ * @param psvId
+ * @return
+ */
+ @Override
+ public boolean deleteByPsvId(String psvId) {
+ if(!ValidateUtil.validateString(psvId))
+ return false;
+ LambdaQueryWrapper<ProcessSpecVersionDepartment> lambdaQueryWrapper = Wrappers.lambdaQuery();
+ lambdaQueryWrapper.eq(ProcessSpecVersionDepartment::getPsvId, psvId);
+ return super.remove(lambdaQueryWrapper);
+ }
+
+ /**
+ * 鑾峰彇宸插垎閰嶇殑閮ㄩ棬
+ * @param psvId
+ * @return
+ */
+ @Override
+ public List<MdcProduction> getDepartPermsByPsvId(String psvId){
+ return super.baseMapper.getDepartPermsByPsvId(psvId);
+ }
+
+ /**
+ * 鑾峰彇宸插垎閰嶇殑閮ㄩ棬
+ * @param psvId
+ * @return
+ */
+ @Override
+ public List<MdcProduction> getDepartNonPermsByPsvId(String psvId){
+ return super.baseMapper.getDepartNonPermsByPsvId(psvId);
+ }
+
+ /**
+ * 鏌ヨ閮ㄩ棬鏉冮檺
+ * @param psvId
+ * @param departId
+ * @return
+ */
+ @Override
+ public ProcessSpecVersionDepartment getByProcessSpecVersionIdAndDepartId(String psvId, String departId){
+ if(!ValidateUtil.validateString(psvId) || !ValidateUtil.validateString(psvId))
+ return null;
+ List<ProcessSpecVersionDepartment> list = super.lambdaQuery().eq(ProcessSpecVersionDepartment::getPsvId, psvId).eq(ProcessSpecVersionDepartment::getDepartId, departId).list();
+ if(list == null || list.isEmpty())
+ return null;
+ return list.get(0);
+ }
+
+ /**
+ * 绉婚櫎閮ㄩ棬鏉冮檺
+ * @param processSpecVersionDepartments
+ * @return
+ */
+ @Override
+ public boolean removeByCollection(List<ProcessSpecVersionDepartment> processSpecVersionDepartments){
+ if(processSpecVersionDepartments == null || processSpecVersionDepartments.isEmpty())
+ return false;
+ if(processSpecVersionDepartments.size() == 1)
+ return super.removeById(processSpecVersionDepartments.get(0).getId());
+ List<String> ids = new ArrayList<>();
+ processSpecVersionDepartments.forEach(item -> {
+ ids.add(item.getId());
+ });
+ if(ids.size() > 1000){
+ List<List<String>> idsArr = ListUtils.partition(ids, 1000);
+ for(List<String> arr : idsArr){
+ super.removeByIds(arr);
+ }
+ return true;
+ }else {
+ return super.removeByIds(ids);
+ }
+ }
+
+ /**
+ * 鏌ヨ涓�缁勯儴闂ㄦ潈闄�
+ * @param psvIds
+ * @param ids
+ * @return
+ */
+ @Override
+ public List<ProcessSpecVersionDepartment> getByPsvIdsAndDepartIds(List<String> psvIds, List<String> ids){
+ if(psvIds == null || psvIds.isEmpty() || ids == null || ids.isEmpty())
+ return null;
+ List<ProcessSpecVersionDepartment> total = new ArrayList<>();
+ List<List<String>> compListArr;
+ List<List<String>> departListArr;
+ if(psvIds.size() > 1000){
+ compListArr = ListUtils.partition(psvIds, 100);
+ }else {
+ compListArr = ListUtils.partition(psvIds, 1000);
+ }
+ if(ids.size() > 1000){
+ departListArr = ListUtils.partition(ids, 100);
+ }else {
+ departListArr = ListUtils.partition(ids, 1000);
+ }
+ for(List<String> compList : compListArr) {
+ for(List<String> departList : departListArr){
+ LambdaQueryWrapper<ProcessSpecVersionDepartment> queryWrapper = Wrappers.lambdaQuery();
+ queryWrapper.in(ProcessSpecVersionDepartment::getPsvId, compList);
+ queryWrapper.in(ProcessSpecVersionDepartment::getDepartId, departList);
+ List<ProcessSpecVersionDepartment> list = super.list(queryWrapper);
+ if(list != null && !list.isEmpty()){
+ total.addAll(list);
+ }
+ }
+ }
+ return total;
+ }
+}
--
Gitblit v1.9.3