From e6d788eef335aa02ac306e984c44affa68ab971c Mon Sep 17 00:00:00 2001
From: zhangherong <571457620@qq.com>
Date: 星期三, 30 七月 2025 20:45:03 +0800
Subject: [PATCH] art: 新增系统第三方集成调用日志表,切面服务实现

---
 src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java |   78 ++++++++++++++++++++++++++------------
 1 files changed, 53 insertions(+), 25 deletions(-)

diff --git a/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java b/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java
index 37f72de..f00f3a7 100644
--- a/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java
+++ b/src/main/java/org/jeecg/modules/system/service/impl/SysUserServiceImpl.java
@@ -7,6 +7,7 @@
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.catalina.User;
 import org.apache.commons.lang3.StringUtils;
 import org.jeecg.common.api.vo.Result;
 import org.jeecg.common.constant.CacheConstant;
@@ -20,7 +21,11 @@
 import org.jeecg.common.util.PasswordUtil;
 import org.jeecg.common.util.UUIDGenerator;
 import org.jeecg.common.util.oConvertUtils;
+import org.jeecg.modules.base.entity.UserFactory;
+import org.jeecg.modules.base.mapper.UserFactoryMapper;
 import org.jeecg.modules.base.service.BaseCommonService;
+import org.jeecg.modules.mdc.entity.MdcUserProduction;
+import org.jeecg.modules.mdc.mapper.MdcUserProductionMapper;
 import org.jeecg.modules.system.entity.*;
 import org.jeecg.modules.system.mapper.*;
 import org.jeecg.modules.system.model.SysUserSysDepartModel;
@@ -79,13 +84,11 @@
 	@Autowired
 	SysRoleIndexMapper sysRoleIndexMapper;
 	@Resource
+	UserFactoryMapper userFactoryMapper;
+	@Resource
 	MdcUserProductionMapper mdcUserProductionMapper;
 	@Resource
 	private ISysDictService sysDictService;
-	@Resource
-	private MdcProductionEquipmentMapper mdcProductionEquipmentMapper;
-	@Resource
-	private DncDevicePermissionMapper dncDevicePermissionMapper;
 
     @Override
     @CacheEvict(value = {CacheConstant.SYS_USERS_CACHE}, allEntries = true)
@@ -594,16 +597,16 @@
 			}
 		}
 		//step.5 淇濆瓨璁惧鏉冮檺
-		List<String> EquipmentIds= mdcProductionEquipmentMapper.selectList(new QueryWrapper<MdcProductionEquipment>().in("production_id",arr))
-				.stream().map(MdcProductionEquipment::getEquipmentId).collect(Collectors.toList());
-		if (oConvertUtils.isNotEmpty(EquipmentIds)) {
-			for (String equipmentId : EquipmentIds) {
-				DncDevicePermission dncDevicePermission=new DncDevicePermission();
-				dncDevicePermission.setDeviceId(equipmentId);
-				dncDevicePermission.setUserId(user.getId());
-				dncDevicePermissionMapper.insert(dncDevicePermission);
-			}
-		}
+//		List<String> EquipmentIds= mdcProductionEquipmentMapper.selectList(new QueryWrapper<MdcProductionEquipment>().in("production_id",arr))
+//				.stream().map(MdcProductionEquipment::getEquipmentId).collect(Collectors.toList());
+//		if (oConvertUtils.isNotEmpty(EquipmentIds)) {
+//			for (String equipmentId : EquipmentIds) {
+//				DncDevicePermission dncDevicePermission=new DncDevicePermission();
+//				dncDevicePermission.setDeviceId(equipmentId);
+//				dncDevicePermission.setUserId(user.getId());
+//				dncDevicePermissionMapper.insert(dncDevicePermission);
+//			}
+//		}
 	}
 
 	@Override
@@ -667,17 +670,17 @@
 		}
 		//step.5 淇敼璁惧鏉冮檺
 		//鍏堝垹鍚庡姞
-		dncDevicePermissionMapper.delete(new QueryWrapper<DncDevicePermission>().lambda().eq(DncDevicePermission::getUserId, user.getId()));
-		List<String> EquipmentIds= mdcProductionEquipmentMapper.selectList(new QueryWrapper<MdcProductionEquipment>().in("production_id",array))
-				.stream().map(MdcProductionEquipment::getEquipmentId).collect(Collectors.toList());
-		if (oConvertUtils.isNotEmpty(EquipmentIds)) {
-			for (String equipmentId : EquipmentIds) {
-				DncDevicePermission dncDevicePermission=new DncDevicePermission();
-				dncDevicePermission.setDeviceId(equipmentId);
-				dncDevicePermission.setUserId(user.getId());
-				dncDevicePermissionMapper.insert(dncDevicePermission);
-			}
-		}
+//		dncDevicePermissionMapper.delete(new QueryWrapper<DncDevicePermission>().lambda().eq(DncDevicePermission::getUserId, user.getId()));
+//		List<String> EquipmentIds= mdcProductionEquipmentMapper.selectList(new QueryWrapper<MdcProductionEquipment>().in("production_id",array))
+//				.stream().map(MdcProductionEquipment::getEquipmentId).collect(Collectors.toList());
+//		if (oConvertUtils.isNotEmpty(EquipmentIds)) {
+//			for (String equipmentId : EquipmentIds) {
+//				DncDevicePermission dncDevicePermission=new DncDevicePermission();
+//				dncDevicePermission.setDeviceId(equipmentId);
+//				dncDevicePermission.setUserId(user.getId());
+//				dncDevicePermissionMapper.insert(dncDevicePermission);
+//			}
+//		}
 		//step.6 淇敼鎵嬫満鍙峰拰閭
 		// 鏇存柊鎵嬫満鍙枫�侀偖绠辩┖瀛楃涓蹭负 null
 		userMapper.updateNullByEmptyString("email");
@@ -806,4 +809,29 @@
 						(existing, replacement) -> existing // 閲嶅閿鐞�
 				));
 	}
+
+
+	/**
+	 * 鏍规嵁鐝粍Id鏌ヨ
+	 * @param page
+	 * @param groupId 鐝粍id
+	 * @param username 鐢ㄦ埛璐︽埛鍚嶇О
+	 * @return
+	 */
+	@Override
+	public IPage<SysUser> getUserByGroupId(Page<SysUser> page, String groupId, String username) {
+		return userMapper.getUserByGroupId(page,groupId,username);
+	}
+
+	/**
+	 * 鏍规嵁浜х嚎Id鏌ヨ
+	 * @param page
+	 * @param factoryId 鐝粍id
+	 * @param username 鐢ㄦ埛璐︽埛鍚嶇О
+	 * @return
+	 */
+	@Override
+	public IPage<SysUser> getUserByFactoryId(Page<SysUser> page, String factoryId, String username) {
+		return userMapper.getUserByFactoryId(page,factoryId,username);
+	}
 }

--
Gitblit v1.9.3