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/ProductPermissionServiceImpl.java |  150 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 150 insertions(+), 0 deletions(-)

diff --git a/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProductPermissionServiceImpl.java b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProductPermissionServiceImpl.java
new file mode 100644
index 0000000..add7b3d
--- /dev/null
+++ b/lxzn-module-dnc/src/main/java/org/jeecg/modules/dnc/service/impl/ProductPermissionServiceImpl.java
@@ -0,0 +1,150 @@
+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.jeecg.modules.dnc.entity.*;
+import org.jeecg.modules.dnc.exception.ExceptionCast;
+import org.jeecg.modules.dnc.mapper.ProductPermissionMapper;
+import org.jeecg.modules.dnc.response.CommonCode;
+import org.jeecg.modules.dnc.service.*;
+import org.jeecg.modules.dnc.ucenter.UserDepartExt;
+import org.jeecg.modules.dnc.utils.ValidateUtil;
+import org.jeecg.modules.system.entity.SysUser;
+import org.jeecg.modules.system.service.ISysUserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+
+@Service
+public class ProductPermissionServiceImpl extends ServiceImpl<ProductPermissionMapper, ProductPermission> implements IProductPermissionService {
+    @Autowired
+    private IComponentPermissionService componentPermissionService;
+    @Autowired
+    private IPartsPermissionService partsPermissionService;
+    @Resource
+    private IProcessSpecVersionPermissionService processSpecVersionPermissionService;
+    @Autowired
+    private IProcessStreamPermissionService processStreamPermissionService;
+    @Autowired
+    private IWorkStepPermissionService workStepPermissionService;
+    @Autowired
+    private ISysUserService sysUserService;
+    @Override
+    public ProductPermission getByProductIdAndUserId(String productId, String userId) {
+        if(!ValidateUtil.validateString(productId) || !ValidateUtil.validateString(userId))
+            return null;
+        List<ProductPermission> permissions = super.lambdaQuery().eq(ProductPermission::getProductId, productId).eq(ProductPermission::getUserId, userId).list();
+        if(permissions == null || permissions.isEmpty())
+            return null;
+        return permissions.get(0);
+    }
+
+    @Override
+    @Transactional(rollbackFor = {Exception.class})
+    public boolean deleteByProductId(String productId) {
+        if(!ValidateUtil.validateString(productId))
+            return false;
+        LambdaQueryWrapper<ProductPermission> lambdaQueryWrapper = Wrappers.lambdaQuery();
+        lambdaQueryWrapper.eq(ProductPermission::getProductId, productId);
+        return super.remove(lambdaQueryWrapper);
+    }
+
+    @Override
+    public List<UserDepartExt> getUserPermsByProductId(String productId) {
+        return super.getBaseMapper().getUserPermsByProductId(productId);
+    }
+
+    @Override
+    public List<SysUser> getUserNonPermsByProductId(String productId) {
+        return super.getBaseMapper().getUserNonPermsByProductId(productId);
+    }
+
+    @Override
+    public boolean removeByCollection(List<ProductPermission> permissionList) {
+        if(permissionList == null || permissionList.isEmpty())
+            return false;
+        if(permissionList.size() == 1) {
+            return super.removeById(permissionList.get(0).getId());
+        }
+        List<String> ids = new ArrayList<>();
+        permissionList.forEach(item -> {
+            ids.add(item.getId());
+        });
+        return super.removeByIds(ids);
+    }
+
+    @Override
+    public List<ProductPermission> getByProductId(String productId) {
+        List<ProductPermission> list = super.lambdaQuery().eq(ProductPermission::getProductId, productId).list();
+        if(list == null)
+            list = Collections.emptyList();
+        return list;
+    }
+
+    /**
+     * 鏂板鏉冮檺鏁版嵁
+     * @param id
+     * @param userId
+     * @param type
+     * @return
+     */
+    @Override
+    public boolean add(String id, String userId, String type) {
+        // 楠岃瘉鍙傛暟鏈夋晥鎬�
+        if (!ValidateUtil.validateString(userId) || !ValidateUtil.validateString(id) || !ValidateUtil.validateString(type)) {
+            return false;
+        }
+        // 鑾峰彇绠$悊鍛樼敤鎴�
+        SysUser adminUser = sysUserService.getUserByName("admin");
+        try {
+            boolean isAdmin = userId.equals(adminUser.getId());
+            savePermission(id, userId, type);
+            if (!isAdmin) {
+                savePermission(id, adminUser.getId(), type);
+            }
+            return true;
+        } catch (Exception e) {
+            ExceptionCast.cast(CommonCode.INVALID_PARAM);
+            return false;
+        }
+    }
+
+    private void savePermission(String id, String userId, String type) {
+        switch (type) {
+            case "1":
+                // 缁勪欢鏉冮檺
+                super.save(new ProductPermission(id, userId));
+                break;
+            case "2":
+                // 閮ㄤ欢鏉冮檺
+                componentPermissionService.save(new ComponentPermission(id, userId));
+                break;
+            case "3":
+                // 闆朵欢鏉冮檺
+                partsPermissionService.save(new PartsPermission(id, userId));
+                break;
+            case "4":
+                //宸ヨ壓瑙勭▼鐗堟湰鍙�
+                processSpecVersionPermissionService.save(new ProcessSpecVersionPermission(id, userId));
+                break;
+            case "5":
+                // 宸ュ簭鏉冮檺
+                processStreamPermissionService.save(new ProcessionPermission(id, userId));
+                break;
+            case "6":
+                // 宸ュ簭姝ラ鏉冮檺
+                workStepPermissionService.save(new WorkStepPermission(id, userId));
+                break;
+            default:
+                // 澶勭悊鏈煡绫诲瀷
+                throw new IllegalArgumentException("Unknown permission treeType: " + type);
+        }
+    }
+
+}

--
Gitblit v1.9.3