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