From 3e6e5a5300c8b41af08f51a3932b230f9fcb9935 Mon Sep 17 00:00:00 2001 From: feige <791364011@qq.com> Date: 星期五, 08 八月 2025 13:40:02 +0800 Subject: [PATCH] 增加了相关代码 --- archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java | 113 +++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 110 insertions(+), 3 deletions(-) diff --git a/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java b/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java index 09ee243..49a9bac 100644 --- a/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java +++ b/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java @@ -1,12 +1,23 @@ package com.ruoyi.service.impl; +import java.util.ArrayList; +import java.util.HashMap; import java.util.List; +import java.util.stream.Collectors; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; -import com.ruoyi.domain.ArchiveRecords; +import com.ruoyi.common.core.domain.AjaxResult; +import com.ruoyi.common.core.domain.entity.SysUser; +import com.ruoyi.common.utils.MapUtils; + +import com.ruoyi.common.utils.StringUtils; import com.ruoyi.domain.Archiverecordstouser; -import com.ruoyi.mapper.ArchiveRecordsMapper; +import com.ruoyi.mapper.ArchiverecordstouserMapper; import com.ruoyi.service.IArchiverecordstouserService; +import com.ruoyi.system.mapper.SysUserMapper; +import com.ruoyi.system.service.ISysUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; @@ -18,9 +29,80 @@ * @date 2025-07-20 */ @Service -public class ArchiverecordstouserServiceImpl extends ServiceImpl<ArchiveRecordsMapper, ArchiveRecords> implements IArchiverecordstouserService +public class ArchiverecordstouserServiceImpl extends ServiceImpl<ArchiverecordstouserMapper, Archiverecordstouser> implements IArchiverecordstouserService { + @Autowired + private SysUserMapper userMapper; + @Autowired + private ISysUserService iSysUserService; + private LambdaQueryWrapper<Archiverecordstouser> buildCondition(Archiverecordstouser archiverecordstouser) { + LambdaQueryWrapper<Archiverecordstouser> lqw = new LambdaQueryWrapper<>(); + lqw.eq(!StringUtils.isEmpty(archiverecordstouser.getArchiveRecordsId()),Archiverecordstouser::getArchiveRecordsId, archiverecordstouser.getArchiveRecordsId()); + //淇濆瓨鐩稿叧鐢ㄦ埛鐨剈serId + List<Long> arr = new ArrayList<>(); + List<SysUser> all = new ArrayList<>(); + + if(!StringUtils.isEmpty(archiverecordstouser.getUserName())||!StringUtils.isEmpty(archiverecordstouser.getPhonenumber())) + { + //鏍规嵁鐢ㄦ埛鍚嶆煡璇㈢敤鎴风浉鍏砳d + SysUser sysUser = new SysUser(); + sysUser.setUserName(archiverecordstouser.getUserName()); + sysUser.setPhonenumber(archiverecordstouser.getPhonenumber()); + all = userMapper.selectUserList(sysUser); + } + arr = all.stream().map(SysUser::getUserId).collect(Collectors.toList()); + lqw.in(!all.isEmpty(), Archiverecordstouser::getUserId, arr); + // System.out.println(archiverecordstouser.getSysUser().getUserName()+"098643"); + return lqw; + } + + + @Override + public int insertRecordToUsers(String recordId, Long[] userIds) { + // 鏂板鐢ㄦ埛涓庢鍗疯褰� + List<Archiverecordstouser> list = new ArrayList<Archiverecordstouser>(); + for (Long userId : userIds) + { + Archiverecordstouser ur = new Archiverecordstouser(); + ur.setArchiveRecordsId(recordId); + ur.setUserId(userId); + list.add(ur); + } + boolean res = this.saveBatch(list); + if(res) + return 1; + else + return 0; + // return userRoleMapper.batchUserRole(list); + } + + @Override + public AjaxResult selectDataList(Archiverecordstouser archiverecordstouser, Integer pageNum, Integer pageSize) { + System.out.println(archiverecordstouser.getArchiveRecordsId()); + System.out.println("sssssssssssssssssssssssss"); + LambdaQueryWrapper<Archiverecordstouser> lqw = buildCondition(archiverecordstouser); + + + Page<Archiverecordstouser> zfClanPage = new Page<>(pageNum, pageSize); + Page<Archiverecordstouser> pageResult = page(zfClanPage, lqw); + + List<Archiverecordstouser> beanRecords = pageResult.getRecords();//寰楀埌鏌ヨ鍑烘潵鐨勬暟鎹� + + + beanRecords.forEach(record -> { + if (record.getUserId() != null) { + SysUser user = userMapper.selectUserById(record.getUserId()); + record.setSysUser(user); // 鍋囪Archiverecordstouser涓湁setUser鏂规硶 + } + }); + // List<ArchiveRecords> beanRecords = list(lqw); + // log.info("浠庢暟鎹簱涓煡鍒扮殑涓�:{}", beanRecords); + // return markOwnData(familyId, fatherFaId, motherFaId, beanRecords); + HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords); + + + return AjaxResult.success(data); } /** * 鏌ヨ銆愯濉啓鍔熻兘鍚嶇О銆� @@ -94,4 +176,29 @@ { return 0; } + + @Override + public int deleteArchiverecordstouserByRecordId(String recordId, Long userId) { + + LambdaQueryWrapper<Archiverecordstouser> lqw = new LambdaQueryWrapper<>(); + lqw.eq(!StringUtils.isEmpty(recordId), Archiverecordstouser::getArchiveRecordsId, recordId) + .eq(userId!=null, Archiverecordstouser::getUserId, userId); + if(this.remove(lqw)) + return 1; + else + return 0; + } + + @Override + public int queryArchiverecordstouserByRecordId(String recordId, Long userId) { + LambdaQueryWrapper<Archiverecordstouser> lqw = new LambdaQueryWrapper<>(); + lqw.eq(!StringUtils.isEmpty(recordId), Archiverecordstouser::getArchiveRecordsId, recordId) + .eq(userId!=null, Archiverecordstouser::getUserId, userId); + + List<Archiverecordstouser> lis = list(lqw); + if(!lis.isEmpty()) + return 1; + else + return 0; + } } -- Gitblit v1.9.1