From 19f5c982ea9ad8d7aad65b2c9a776b829992d2ca Mon Sep 17 00:00:00 2001
From: fei <791364011@qq.com>
Date: 星期二, 09 九月 2025 17:39:01 +0800
Subject: [PATCH] 新增了代码

---
 archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java |   84 +++++++++++++++++++++++++++++++++++++++++
 1 files changed, 83 insertions(+), 1 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 d7b7df3..f8ae642 100644
--- a/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java
+++ b/archiveManager/src/main/java/com/ruoyi/service/impl/ArchiverecordstouserServiceImpl.java
@@ -1,8 +1,10 @@
 package com.ruoyi.service.impl;
 
 import java.util.ArrayList;
+import java.util.Collections;
 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;
@@ -12,10 +14,13 @@
 import com.ruoyi.common.utils.MapUtils;
 
 import com.ruoyi.common.utils.StringUtils;
+import com.ruoyi.domain.ArchiveRecords;
 import com.ruoyi.domain.Archiverecordstouser;
+import com.ruoyi.domain.vo.RecordToUserCount;
 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;
 
@@ -31,17 +36,34 @@
 {
   @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)
         {
@@ -49,6 +71,7 @@
             ur.setArchiveRecordsId(recordId);
             ur.setUserId(userId);
             list.add(ur);
+            break;
         }
         boolean res =  this.saveBatch(list);
         if(res)
@@ -95,6 +118,14 @@
     public Archiverecordstouser selectArchiverecordstouserById(Long id)
     {
         return null;
+    }
+
+    @Override
+    public boolean selectArchiveRecordUsers(String recordId) {
+        LambdaQueryWrapper<Archiverecordstouser> lqw = new LambdaQueryWrapper<>();
+        lqw.eq(!StringUtils.isEmpty(recordId),Archiverecordstouser::getArchiveRecordsId, recordId);
+        List<Archiverecordstouser> lis = list(lqw);
+        return !lis.isEmpty();
     }
 
     @Override
@@ -157,4 +188,55 @@
     {
         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;
+    }
+
+    @Override
+    public AjaxResult countStatistic(String username, int pageNum, int pageSize) {
+        LambdaQueryWrapper<RecordToUserCount> lqw = new LambdaQueryWrapper<>();
+
+        if(username!=null)
+            lqw.like(!StringUtils.isEmpty(username), RecordToUserCount::getUserName, username);
+
+
+
+
+
+
+        Page<RecordToUserCount> page = new Page<>(pageNum, pageSize);
+
+        // 浣跨敤鑷畾涔夌殑鍒嗛〉鏌ヨ鏂规硶锛屽厛杩炴帴鍐嶅垎椤�
+        Page<RecordToUserCount> pageResult = this.baseMapper.selectRecordToUserPage(page, lqw);
+
+        List<RecordToUserCount> beanRecords = pageResult.getRecords();//寰楀埌鏌ヨ鍑烘潵鐨勬暟鎹�
+
+        HashMap<String, Object> data = MapUtils.getResult(pageResult, beanRecords);
+
+
+        return AjaxResult.success(data);
+
+    }
 }

--
Gitblit v1.9.1