From 8f2f6f16709ec27df9edf6d927a39af4ad877b6b Mon Sep 17 00:00:00 2001
From: fit2cloud-chenyw <yawen.chen@fit2cloud.com>
Date: Mon, 5 Jul 2021 18:18:06 +0800
Subject: [PATCH 1/2] =?UTF-8?q?feat:=20=E5=AE=8C=E5=96=84=E5=88=86?=
 =?UTF-8?q?=E4=BA=AB=E6=B6=88=E6=81=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../auth/service/impl/ShiroServiceImpl.java   |   4 +
 .../base/mapper/ext/ExtPanelShareMapper.java  |   2 +
 .../base/mapper/ext/ExtPanelShareMapper.xml   |   8 +
 .../controller/panel/api/ShareApi.java        |   5 +
 .../controller/panel/server/ShareServer.java  |   8 +
 .../request/panel/PanelShareFineDto.java      |  18 ++
 .../dataease/service/panel/ShareService.java  | 174 ++++++++++++++++++
 frontend/src/api/panel/share.js               |   9 +
 frontend/src/api/system/msg.js                |   2 +-
 .../src/components/Notification/index.vue     |  17 +-
 frontend/src/permission.js                    |   2 +-
 .../src/views/panel/GrantAuth/dept/index.vue  |   6 +
 frontend/src/views/panel/GrantAuth/index.vue  |  24 ++-
 .../src/views/panel/GrantAuth/role/index.vue  |   7 +
 .../src/views/panel/GrantAuth/user/index.vue  |   6 +
 .../src/views/system/datasource/DsTree.vue    |   4 +-
 16 files changed, 285 insertions(+), 11 deletions(-)
 create mode 100644 backend/src/main/java/io/dataease/controller/request/panel/PanelShareFineDto.java

diff --git a/backend/src/main/java/io/dataease/auth/service/impl/ShiroServiceImpl.java b/backend/src/main/java/io/dataease/auth/service/impl/ShiroServiceImpl.java
index ee7911dd2c..954a6f7266 100644
--- a/backend/src/main/java/io/dataease/auth/service/impl/ShiroServiceImpl.java
+++ b/backend/src/main/java/io/dataease/auth/service/impl/ShiroServiceImpl.java
@@ -46,6 +46,10 @@ public class ShiroServiceImpl implements ShiroService {
 
 
         filterChainDefinitionMap.put("/system/ui/**", ANON);
+        filterChainDefinitionMap.put("/**/*.js", ANON);
+        filterChainDefinitionMap.put("/**/*.css", ANON);
+        filterChainDefinitionMap.put("/**/*.map", ANON);
+        // filterChainDefinitionMap.put("/axios.map", ANON);
 
         filterChainDefinitionMap.put("/api/auth/login", ANON);
         filterChainDefinitionMap.put("/api/auth/logout", ANON);
diff --git a/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.java b/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.java
index 03f3aab385..12fa0e3264 100644
--- a/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.java
+++ b/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.java
@@ -12,6 +12,8 @@ public interface ExtPanelShareMapper {
 
     int batchInsert(@Param("shares") List<PanelShare> shares);
 
+    int batchDelete(@Param("shareIds") List<Long> shareIds);
+
     List<PanelSharePo> query(Map<String, Object> param);
 
     List<PanelShare> queryWithResource(GridExample example);
diff --git a/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.xml b/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.xml
index f288f31e74..c260a350ed 100644
--- a/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.xml
+++ b/backend/src/main/java/io/dataease/base/mapper/ext/ExtPanelShareMapper.xml
@@ -16,6 +16,14 @@
         </foreach>
     </insert>
 
+    <delete id="batchDelete" parameterType="java.lang.Long" >
+        delete from panel_share
+        where share_id in
+        <foreach collection="shareIds" item="shareId" open="(" separator="," close=")" >
+            #{shareId}
+        </foreach>
+    </delete>
+
     <select id="query" resultMap="treeNodeMap">
         select distinct s.panel_group_id as id, g.create_by as creator, g.name
         from panel_share s
diff --git a/backend/src/main/java/io/dataease/controller/panel/api/ShareApi.java b/backend/src/main/java/io/dataease/controller/panel/api/ShareApi.java
index 14cc345578..379c3174c4 100644
--- a/backend/src/main/java/io/dataease/controller/panel/api/ShareApi.java
+++ b/backend/src/main/java/io/dataease/controller/panel/api/ShareApi.java
@@ -1,6 +1,7 @@
 package io.dataease.controller.panel.api;
 
 import io.dataease.base.domain.PanelShare;
+import io.dataease.controller.request.panel.PanelShareFineDto;
 import io.dataease.controller.request.panel.PanelShareRequest;
 import io.dataease.controller.sys.base.BaseGridRequest;
 import io.dataease.dto.panel.PanelShareDto;
@@ -31,5 +32,9 @@ public interface ShareApi {
     @PostMapping("/queryWithResourceId")
     List<PanelShare> queryWithResourceId(BaseGridRequest request);
 
+
+    @ApiOperation("优化创建分享")
+    @PostMapping("/fineSave")
+    void fineSave(PanelShareFineDto panelShareFineDto);
     
 }
diff --git a/backend/src/main/java/io/dataease/controller/panel/server/ShareServer.java b/backend/src/main/java/io/dataease/controller/panel/server/ShareServer.java
index 1e5004197e..af2bacbd2a 100644
--- a/backend/src/main/java/io/dataease/controller/panel/server/ShareServer.java
+++ b/backend/src/main/java/io/dataease/controller/panel/server/ShareServer.java
@@ -2,6 +2,7 @@ package io.dataease.controller.panel.server;
 
 import io.dataease.base.domain.PanelShare;
 import io.dataease.controller.panel.api.ShareApi;
+import io.dataease.controller.request.panel.PanelShareFineDto;
 import io.dataease.controller.request.panel.PanelShareRequest;
 import io.dataease.controller.sys.base.BaseGridRequest;
 import io.dataease.dto.panel.PanelShareDto;
@@ -32,4 +33,11 @@ public class ShareServer implements ShareApi {
     public List<PanelShare> queryWithResourceId(@RequestBody BaseGridRequest request) {
         return shareService.queryWithResource(request);
     }
+
+    @Override
+    public void fineSave(@RequestBody PanelShareFineDto panelShareFineDto) {
+        shareService.fineSave(panelShareFineDto);
+    }
 }
+
+
diff --git a/backend/src/main/java/io/dataease/controller/request/panel/PanelShareFineDto.java b/backend/src/main/java/io/dataease/controller/request/panel/PanelShareFineDto.java
new file mode 100644
index 0000000000..76f3d8cc74
--- /dev/null
+++ b/backend/src/main/java/io/dataease/controller/request/panel/PanelShareFineDto.java
@@ -0,0 +1,18 @@
+package io.dataease.controller.request.panel;
+
+import io.dataease.commons.model.AuthURD;
+import lombok.Data;
+
+import java.io.Serializable;
+
+
+@Data
+public class PanelShareFineDto implements Serializable {
+
+
+    private static final long serialVersionUID = -792964171742204428L;
+
+    private  String resourceId;
+
+    private AuthURD authURD;
+}
diff --git a/backend/src/main/java/io/dataease/service/panel/ShareService.java b/backend/src/main/java/io/dataease/service/panel/ShareService.java
index c80551437c..0835808cf3 100644
--- a/backend/src/main/java/io/dataease/service/panel/ShareService.java
+++ b/backend/src/main/java/io/dataease/service/panel/ShareService.java
@@ -14,12 +14,15 @@ import io.dataease.commons.model.AuthURD;
 import io.dataease.commons.utils.AuthUtils;
 import io.dataease.commons.utils.BeanUtils;
 import io.dataease.commons.utils.CommonBeanFactory;
+import io.dataease.controller.request.panel.PanelShareFineDto;
 import io.dataease.controller.request.panel.PanelShareRequest;
 import io.dataease.controller.sys.base.BaseGridRequest;
 import io.dataease.dto.panel.PanelShareDto;
 import io.dataease.dto.panel.PanelSharePo;
 import io.dataease.service.message.DeMsgutil;
+import lombok.Data;
 import org.apache.commons.collections.CollectionUtils;
+import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -27,6 +30,7 @@ import org.springframework.transaction.annotation.Transactional;
 import javax.annotation.Resource;
 import java.util.*;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 
 @Service
@@ -41,6 +45,176 @@ public class ShareService {
     @Resource
     private ExtPanelShareMapper extPanelShareMapper;
 
+    /**
+     *  1.查询当前节点已经分享给了哪些目标
+     *  2.过滤出新增的目标
+     *  3.过滤出减少的目标
+     *  4.批量删除
+     *  5.批量新增
+     *  6.发送取消分享消息
+     *  7.发送新增分享消息
+     * @param panelShareFineDto
+     */
+    @Transactional
+    public void fineSave(PanelShareFineDto panelShareFineDto) {
+
+        List<PanelShare> addShares = new ArrayList<>();//新增的分享
+        List<Long> redShareIdLists = new ArrayList<>();//取消的分享
+
+        String panelGroupId = panelShareFineDto.getResourceId();
+        AuthURD authURD = panelShareFineDto.getAuthURD();
+        AuthURD sharedAuthURD = new AuthURD();
+        AuthURD addAuthURD = new AuthURD();
+
+
+
+        Map<Integer, List<Long>> authURDMap = new HashMap<>();
+        authURDMap.put(0, authURD.getUserIds());
+        authURDMap.put(1, authURD.getRoleIds());
+        authURDMap.put(2, authURD.getDeptIds());
+
+        PanelShareExample example = new PanelShareExample();
+        example.createCriteria().andPanelGroupIdEqualTo(panelGroupId);
+        List<PanelShare> panelShares = mapper.selectByExample(example);
+        /*if (CollectionUtils.isEmpty(panelShares)) {
+            return;
+        }*/
+        Map<Integer, List<TempShareNode>> typeSharedMap = panelShares.stream().map(this::convertNode).collect(Collectors.groupingBy(TempShareNode::getType));
+
+        for (Map.Entry<Integer, List<Long>> entry : authURDMap.entrySet()) {
+            Integer key = entry.getKey();
+            List<TempShareNode> shareNodes = null;
+            if (null == typeSharedMap || null == typeSharedMap.get(key)) {
+                shareNodes = new ArrayList<>();
+            }else{
+                shareNodes = typeSharedMap.get(key);
+            }
+
+            if (null != authURDMap.get(key)) {
+                Map<String, Object> dataMap = filterData(authURDMap.get(key), shareNodes);
+                List<Long> newIds = (List<Long>)dataMap.get("add");
+                for (int i = 0; i < newIds.size(); i++) {
+                    Long id = newIds.get(i);
+                    PanelShare share = new PanelShare();
+                    share.setCreateTime(System.currentTimeMillis());
+                    share.setPanelGroupId(panelGroupId);
+                    share.setTargetId(id);
+                    share.setType(key);
+                    addShares.add(share);
+                }
+                List<TempShareNode> redNodes = (List<TempShareNode>)dataMap.get("red");
+                List<Long> redIds = redNodes.stream().map(TempShareNode::getShareId).distinct().collect(Collectors.toList());
+
+                redShareIdLists.addAll(redIds);
+                buildRedAuthURD(key, redNodes.stream().map(TempShareNode::getTargetId).distinct().collect(Collectors.toList()) , sharedAuthURD);
+                buildRedAuthURD(key, newIds, addAuthURD);
+            }
+
+        }
+
+        if (CollectionUtils.isNotEmpty(redShareIdLists)){
+            extPanelShareMapper.batchDelete(redShareIdLists);
+        }
+
+        if (CollectionUtils.isNotEmpty(addShares)){
+            extPanelShareMapper.batchInsert(addShares);
+        }
+
+        // 以上是业务代码
+        // 下面是消息发送
+        Set<Long> addUserIdSet = AuthUtils.userIdsByURD(addAuthURD);
+        Set<Long> redUserIdSet = AuthUtils.userIdsByURD(sharedAuthURD);
+
+
+        PanelGroup panelGroup = panelGroupMapper.selectByPrimaryKey(panelGroupId);;
+        CurrentUserDto user = AuthUtils.getUser();
+        Gson gson = new Gson();
+        String msg = panelGroup.getName();
+
+
+        List<String> msgParam = new ArrayList<String>();
+        msgParam.add(panelGroupId);
+        addUserIdSet.forEach(userId -> {
+            if (!redUserIdSet.contains(userId)){
+                DeMsgutil.sendMsg(userId, 0, user.getNickName()+" 分享了仪表板【"+msg+"】，请查收!", gson.toJson(msgParam));
+            }
+        });
+
+        redUserIdSet.forEach(userId -> {
+            if (!addUserIdSet.contains(userId)){
+                DeMsgutil.sendMsg(userId, 0, user.getNickName()+" 取消分享了仪表板【"+msg+"】，请查收!", gson.toJson(msgParam));
+            }
+        });
+
+    }
+
+    private void buildRedAuthURD(Integer type, List<Long> redIds , AuthURD authURD) {
+        if (type == 0) {
+            authURD.setUserIds(redIds);
+        }
+        if (type == 1) {
+            authURD.setRoleIds(redIds);
+        }
+        if (type == 2) {
+            authURD.setDeptIds(redIds);
+        }
+    }
+
+    /**
+     *
+     * @param newTargets 新的分享目标
+     * @param shareNodes 已景分享目标
+     * @return
+     */
+    private Map<String, Object> filterData(List<Long> newTargets, List<TempShareNode> shareNodes) {
+
+        Map<String, Object> result = new HashMap<>();
+        /*if (null == newTargets) {
+            result.put("add", new ArrayList<>());
+            result.put("red", new ArrayList<>());
+            return result;
+        }*/
+        List<Long> newUserIds = new ArrayList<>();
+        for (int i = 0; i < newTargets.size(); i++) {
+            Long newTargetId = newTargets.get(i);
+            Boolean isNew = true;
+            for (int j = 0; j < shareNodes.size(); j++) {
+                TempShareNode shareNode = shareNodes.get(j);
+                Long sharedId = shareNode.getTargetId();
+                if (newTargetId == sharedId) {
+                    shareNode.setMatched(true); // 已分享 重新命中
+                    isNew = false;
+                }
+            }
+            if (isNew) {
+                // 获取新增的
+                newUserIds.add(newTargetId);
+            }
+        }
+        //获取需要取消分享的
+        List<TempShareNode> missNodes = shareNodes.stream().filter(item -> !item.getMatched()).collect(Collectors.toList());
+        result.put("add", newUserIds);
+        result.put("red", missNodes);
+        return result;
+    }
+
+    @Data
+    private class TempShareNode {
+        private Long shareId;
+        private Integer type;
+        private Long targetId;
+        private Boolean matched = false;
+
+        public boolean targetMatch(Long tid) {
+            return targetId == tid;
+        }
+    }
+
+    private TempShareNode convertNode(PanelShare panelShare) {
+        return BeanUtils.copyBean(new TempShareNode(), panelShare);
+    }
+
+
     @Transactional
     public void save(PanelShareRequest request){
         List<PanelGroup> panelGroups = queryGroup(request.getPanelIds());
diff --git a/frontend/src/api/panel/share.js b/frontend/src/api/panel/share.js
index d463ea3b99..61c808b476 100644
--- a/frontend/src/api/panel/share.js
+++ b/frontend/src/api/panel/share.js
@@ -27,3 +27,12 @@ export function loadTree(data) {
   })
 }
 
+export function fineSave(data) {
+  return request({
+    url: '/api/share/fineSave',
+    method: 'post',
+    loading: true,
+    data
+  })
+}
+
diff --git a/frontend/src/api/system/msg.js b/frontend/src/api/system/msg.js
index 6b4638fc7d..3b0ce0e055 100644
--- a/frontend/src/api/system/msg.js
+++ b/frontend/src/api/system/msg.js
@@ -4,7 +4,7 @@ export function query(pageIndex, pageSize, data) {
   return request({
     url: '/api/sys_msg/list/' + pageIndex + '/' + pageSize,
     method: 'post',
-    loading: true,
+    loading: false,
     data
   })
 }
diff --git a/frontend/src/components/Notification/index.vue b/frontend/src/components/Notification/index.vue
index f4ccc0e370..e250c84c83 100644
--- a/frontend/src/components/Notification/index.vue
+++ b/frontend/src/components/Notification/index.vue
@@ -73,7 +73,8 @@ export default {
         currentPage: 1,
         pageSize: 5,
         total: 0
-      }
+      },
+      timer: null
     }
   },
   computed: {
@@ -82,14 +83,20 @@ export default {
   created() {
     this.search()
     // 每30s定时刷新拉取消息
-    setInterval(() => {
+    this.timer = setInterval(() => {
       this.search()
     }, 30000)
   },
+  beforeDestroy() {
+    this.timer && clearInterval(this.timer)
+  },
+  destroyed() {
+    this.timer && clearInterval(this.timer)
+  },
   methods: {
-    handClick(lang) {
-      console.log(lang)
-    },
+    // handClick(lang) {
+    //   console.log(lang)
+    // },
     showDetail(row) {
       const param = { ...{ msgNotification: true, msgType: row.type, sourceParam: row.param }}
       this.visible = false
diff --git a/frontend/src/permission.js b/frontend/src/permission.js
index 4dd236cfc0..cf8fe899e3 100644
--- a/frontend/src/permission.js
+++ b/frontend/src/permission.js
@@ -76,7 +76,7 @@ export const loadMenus = (next, to) => {
   buildMenus().then(res => {
     const filterDatas = filterRouter(res.data)
     const asyncRouter = filterAsyncRouter(filterDatas)
-    addMsgMenu(asyncRouter)
+    // addMsgMenu(asyncRouter)
     asyncRouter.push({ path: '*', redirect: '/404', hidden: true })
     store.dispatch('permission/GenerateRoutes', asyncRouter).then(() => { // 存储路由
       router.addRoutes(asyncRouter)
diff --git a/frontend/src/views/panel/GrantAuth/dept/index.vue b/frontend/src/views/panel/GrantAuth/dept/index.vue
index fda8be7ebc..9f2cf29f6b 100644
--- a/frontend/src/views/panel/GrantAuth/dept/index.vue
+++ b/frontend/src/views/panel/GrantAuth/dept/index.vue
@@ -158,6 +158,12 @@ export default {
       return roots
     },
 
+    getSelected() {
+      return {
+        deptIds: this.$refs.table.store.states.selection.map(item => item.deptId)
+      }
+    },
+
     save(msg) {
       const rows = this.$refs.table.store.states.selection
       const request = this.buildRequest(rows)
diff --git a/frontend/src/views/panel/GrantAuth/index.vue b/frontend/src/views/panel/GrantAuth/index.vue
index 6b3134822d..8f7cb7f6c3 100644
--- a/frontend/src/views/panel/GrantAuth/index.vue
+++ b/frontend/src/views/panel/GrantAuth/index.vue
@@ -26,6 +26,7 @@
 import GrantDept from './dept'
 import GrantRole from './role'
 import GrantUser from './user'
+import { fineSave } from '@/api/panel/share'
 export default {
   name: 'GrantAuth',
   components: { GrantDept, GrantRole, GrantUser },
@@ -58,8 +59,27 @@ export default {
       this.showSearchInput = false
     },
     save() {
-      this.$refs[this.activeName].save(this.$t('commons.share_success'))
-      this.$emit('close-grant', 0)
+    //   this.$refs[this.activeName].save(this.$t('commons.share_success'))
+    //   this.$emit('close-grant', 0)
+      this.fineSave()
+    },
+    fineSave() {
+      let targetDto = {}
+      this.tabNames.forEach(tabName => {
+        if (this.$refs[tabName] && this.$refs[tabName].getSelected) {
+          const tempSelected = this.$refs[tabName].getSelected()
+          targetDto = Object.assign({}, targetDto, tempSelected)
+        }
+      })
+      const resourceId = this.resourceId
+      const param = {
+        resourceId,
+        authURD: targetDto
+      }
+      fineSave(param).then(res => {
+        this.$success(this.$t('commons.share_success'))
+        this.$emit('close-grant', 0)
+      })
     },
     cancel() {
       this.$refs[this.activeName].cancel()
diff --git a/frontend/src/views/panel/GrantAuth/role/index.vue b/frontend/src/views/panel/GrantAuth/role/index.vue
index 88714d865d..cdfe2eb018 100644
--- a/frontend/src/views/panel/GrantAuth/role/index.vue
+++ b/frontend/src/views/panel/GrantAuth/role/index.vue
@@ -78,6 +78,13 @@ export default {
         this.setCheckNodes()
       })
     },
+
+    getSelected() {
+      return {
+        roleIds: this.$refs.table.store.states.selection.map(item => item.roleId)
+      }
+    },
+
     save(msg) {
       const rows = this.$refs.table.store.states.selection
       const request = this.buildRequest(rows)
diff --git a/frontend/src/views/panel/GrantAuth/user/index.vue b/frontend/src/views/panel/GrantAuth/user/index.vue
index f83da1ddfb..7480a9ddf7 100644
--- a/frontend/src/views/panel/GrantAuth/user/index.vue
+++ b/frontend/src/views/panel/GrantAuth/user/index.vue
@@ -86,6 +86,12 @@ export default {
       })
     },
 
+    getSelected() {
+      return {
+        userIds: this.$refs.table.store.states.selection.map(item => item.userId)
+      }
+    },
+
     save(msg) {
       const rows = this.$refs.table.store.states.selection
       const request = this.buildRequest(rows)
diff --git a/frontend/src/views/system/datasource/DsTree.vue b/frontend/src/views/system/datasource/DsTree.vue
index 2f3681cf7e..8026935124 100644
--- a/frontend/src/views/system/datasource/DsTree.vue
+++ b/frontend/src/views/system/datasource/DsTree.vue
@@ -114,7 +114,7 @@ export default {
   },
   mounted() {
     this.queryTreeDatas()
-    console.log('permis:' + JSON.stringify(this.$store.getters.permissions))
+    // console.log('permis:' + JSON.stringify(this.$store.getters.permissions))
   },
   methods: {
     filterNode(value, data) {
@@ -154,7 +154,7 @@ export default {
         return 'MySQL'
       } else if (type === 'sqlServer') {
         return 'SQL Server'
-      }else if (type === 'oracle') {
+      } else if (type === 'oracle') {
         return 'Oracle'
       }
     },

From d8fd3cd3bac2a2ba302cfa3416c92a7a647e35f0 Mon Sep 17 00:00:00 2001
From: fit2cloud-chenyw <yawen.chen@fit2cloud.com>
Date: Tue, 6 Jul 2021 09:35:22 +0800
Subject: [PATCH 2/2] =?UTF-8?q?feat:=20=E5=88=A0=E9=99=A4unuserd=E5=BC=95?=
 =?UTF-8?q?=E5=85=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/io/dataease/service/panel/ShareService.java   | 2 --
 1 file changed, 2 deletions(-)

diff --git a/backend/src/main/java/io/dataease/service/panel/ShareService.java b/backend/src/main/java/io/dataease/service/panel/ShareService.java
index 0835808cf3..8165df9932 100644
--- a/backend/src/main/java/io/dataease/service/panel/ShareService.java
+++ b/backend/src/main/java/io/dataease/service/panel/ShareService.java
@@ -22,7 +22,6 @@ import io.dataease.dto.panel.PanelSharePo;
 import io.dataease.service.message.DeMsgutil;
 import lombok.Data;
 import org.apache.commons.collections.CollectionUtils;
-import org.apache.commons.lang3.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -30,7 +29,6 @@ import org.springframework.transaction.annotation.Transactional;
 import javax.annotation.Resource;
 import java.util.*;
 import java.util.stream.Collectors;
-import java.util.stream.Stream;
 
 
 @Service