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