From 5169eb66a3be9dc7be88aa9b78124fd2b11c73f4 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: Fri, 23 Aug 2024 11:25:45 +0800
Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../iot/vmp/gb28181/bean/GroupTree.java       |  2 +-
 .../gb28181/dao/CommonGBChannelMapper.java    |  2 +-
 .../iot/vmp/gb28181/dao/GroupMapper.java      |  9 +++------
 .../gb28181/dao/provider/ChannelProvider.java | 18 +++++++++++++++++
 .../service/impl/GbChannelServiceImpl.java    |  2 +-
 .../service/impl/GroupServiceImpl.java        |  4 ++--
 web_src/src/components/common/GroupTree.vue   | 20 +++++++------------
 web_src/src/components/group.vue              |  6 +++---
 web_src/src/components/region.vue             |  6 +++---
 9 files changed, 39 insertions(+), 30 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/bean/GroupTree.java b/src/main/java/com/genersoft/iot/vmp/gb28181/bean/GroupTree.java
index d11d345c..5265ada6 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/bean/GroupTree.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/bean/GroupTree.java
@@ -10,7 +10,7 @@ import lombok.Data;
 @Schema(description = "业务分组树")
 public class GroupTree extends Group{
 
-    @Schema(description = "树节点Id")
+    @Schema(description = "是否有子节点")
     private String treeId;
 
     @Schema(description = "是否有子节点")
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/CommonGBChannelMapper.java b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/CommonGBChannelMapper.java
index 2d887b90..0375fa24 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/CommonGBChannelMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/CommonGBChannelMapper.java
@@ -343,7 +343,7 @@ public interface CommonGBChannelMapper {
 
     @Select("<script>" +
             " select " +
-            "    concat('channel_', id) as tree_id," +
+            "    id," +
             "    coalesce(gb_device_id, device_id) as device_id," +
             "    coalesce(gb_name, name) as name, " +
             "    coalesce(gb_parent_id, parent_id) as parent_device_id, " +
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/GroupMapper.java b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/GroupMapper.java
index e639f0ac..f95d65f4 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/GroupMapper.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/GroupMapper.java
@@ -62,8 +62,7 @@ public interface GroupMapper {
 
     @Select(" <script>" +
             " SELECT " +
-            " *," +
-            " concat('group_', id) as tree_id," +
+            " * , " +
             " 0 as type," +
             " false as is_leaf" +
             " from wvp_common_group " +
@@ -76,8 +75,7 @@ public interface GroupMapper {
 
     @Select(" <script>" +
             " SELECT " +
-            " concat('group_', id) as tree_id," +
-            " *, " +
+            " * , " +
             " 0 as type," +
             " false as is_leaf" +
             " from wvp_common_group " +
@@ -90,7 +88,6 @@ public interface GroupMapper {
     @Select(" <script>" +
             " SELECT " +
             " *," +
-            " concat('group_', id) as tree_id," +
             " 0 as type," +
             " false as is_leaf" +
             " from wvp_common_group " +
@@ -119,7 +116,7 @@ public interface GroupMapper {
 
     @Update(" UPDATE wvp_common_group " +
             " SET parent_device_id=#{group.deviceId}, business_group = #{group.businessGroup}" +
-            " WHERE parentId = #{parentId}")
+            " WHERE parent_id = #{parentId}")
     int updateChild(@Param("parentId") Integer parentId, Group group);
 
     @Select(" <script>" +
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/provider/ChannelProvider.java b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/provider/ChannelProvider.java
index d163104e..993809e2 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/dao/provider/ChannelProvider.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/dao/provider/ChannelProvider.java
@@ -140,6 +140,24 @@ public class ChannelProvider {
     }
 
     public String queryByGbDeviceIds(Map<String, Object> params ){
+        StringBuilder sqlBuild = new StringBuilder();
+        sqlBuild.append(getBaseSelectSql());
+        sqlBuild.append("where device_db_id in ( ");
+
+        Collection<Integer> ids = (Collection<Integer>)params.get("deviceIds");
+        boolean first = true;
+        for (Integer id : ids) {
+            if (!first) {
+                sqlBuild.append(",");
+            }
+            sqlBuild.append(id);
+            first = false;
+        }
+        sqlBuild.append(" )");
+        return sqlBuild.toString() ;
+    }
+
+    public String queryByDeviceIds(Map<String, Object> params ){
         StringBuilder sqlBuild = new StringBuilder();
         sqlBuild.append(getBaseSelectSql());
         sqlBuild.append("where id in ( ");
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GbChannelServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GbChannelServiceImpl.java
index fc20d723..f01adbe3 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GbChannelServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GbChannelServiceImpl.java
@@ -618,7 +618,7 @@ public class GbChannelServiceImpl implements IGbChannelService {
 
     @Override
     public void deleteChannelToGroup(String parentId, String businessGroup, List<Integer> channelIds) {
-        List<CommonGBChannel> channelList = commonGBChannelMapper.queryByGbDeviceIds(channelIds);
+        List<CommonGBChannel> channelList = commonGBChannelMapper.queryByIds(channelIds);
         if (channelList.isEmpty()) {
             throw new ControllerException(ErrorCode.ERROR100.getCode(), "所有通道Id不存在");
         }
diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GroupServiceImpl.java b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GroupServiceImpl.java
index 611938b8..d410047b 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GroupServiceImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/service/impl/GroupServiceImpl.java
@@ -165,9 +165,9 @@ public class GroupServiceImpl implements IGroupService {
         }
         // 查询含有的通道
         Group parentGroup = groupManager.queryOne(parentId);
-        if (parentGroup != null && !parentGroup.getDeviceId().equals(parentGroup.getBusinessGroup())) {
+        if (parentGroup != null ) {
             List<GroupTree> groupTreesForChannel = commonGBChannelMapper.queryForGroupTreeByParentId(query, parentGroup.getDeviceId());
-            if (ObjectUtils.isEmpty(groupTreesForChannel)) {
+            if (!ObjectUtils.isEmpty(groupTreesForChannel)) {
                 groupTrees.addAll(groupTreesForChannel);
             }
         }
diff --git a/web_src/src/components/common/GroupTree.vue b/web_src/src/components/common/GroupTree.vue
index 9b822923..102f6f45 100755
--- a/web_src/src/components/common/GroupTree.vue
+++ b/web_src/src/components/common/GroupTree.vue
@@ -15,7 +15,7 @@
       <vue-easy-tree
         class="flow-tree"
         ref="veTree"
-        node-key="id"
+        node-key="deviceId"
         height="78vh"
         lazy
         style="padding: 2rem 0 2rem 0.5rem"
@@ -55,7 +55,6 @@ export default {
   data() {
     return {
       props: {
-        id: "treeId",
         label: "name",
       },
       showCode: false,
@@ -74,7 +73,7 @@ export default {
     loadNode: function (node, resolve) {
       if (node.level === 0) {
         resolve([{
-          id: "",
+          deviceId: "",
           name: "根资源组",
           isLeaf: false,
           type: 0
@@ -255,7 +254,7 @@ export default {
           method: 'post',
           url: `/api/common/channel/group/device/add`,
           data: {
-            parentId: node.data.id,
+            parentId: node.data.deviceId,
             businessGroup: node.data.businessGroup,
             deviceIds: deviceIds,
           }
@@ -322,8 +321,9 @@ export default {
         id: 0,
         name: "",
         deviceId: "",
-        parentDeviceId: node.level > 2 ? node.data.id:"",
-        businessGroup: node.level > 2 ? node.data.businessGroup: node.data.id,
+        parentDeviceId: node.level > 2 ? node.data.deviceId:"",
+        parentId: node.data.id,
+        businessGroup: node.level > 2 ? node.data.businessGroup: node.data.deviceId,
       },form => {
         node.loaded = false
         node.expand();
@@ -331,13 +331,7 @@ export default {
     },
     editGroup: function (id, node) {
       console.log(node)
-      this.$refs.groupEdit.openDialog({
-        id: node.data.dbId,
-        name: node.data.label,
-        deviceId: node.data.id,
-        parentDeviceId: node.data.parentDeviceId,
-        businessGroup: node.data.businessGroup,
-      },form => {
+      this.$refs.groupEdit.openDialog(node.data,form => {
         node.parent.loaded = false
         node.parent.expand();
       }, id);
diff --git a/web_src/src/components/group.vue b/web_src/src/components/group.vue
index 5e503546..abd0f34e 100755
--- a/web_src/src/components/group.vue
+++ b/web_src/src/components/group.vue
@@ -50,9 +50,9 @@
           <el-table-column label="类型" min-width="100">
             <template slot-scope="scope">
               <div slot="reference" class="name-wrapper">
-                <el-tag size="medium" v-if="scope.row.gbDeviceDbId">国标设备</el-tag>
-                <el-tag size="medium" v-if="scope.row.streamPushId">推流设备</el-tag>
-                <el-tag size="medium" v-if="scope.row.streamProxyId">拉流代理</el-tag>
+                <el-tag size="medium" effect="plain" v-if="scope.row.gbDeviceDbId">国标设备</el-tag>
+                <el-tag size="medium" effect="plain" type="success" v-if="scope.row.streamPushId">推流设备</el-tag>
+                <el-tag size="medium" effect="plain" type="warning" v-if="scope.row.streamProxyId">拉流代理</el-tag>
               </div>
             </template>
           </el-table-column>
diff --git a/web_src/src/components/region.vue b/web_src/src/components/region.vue
index 2eb68608..8029e2a2 100755
--- a/web_src/src/components/region.vue
+++ b/web_src/src/components/region.vue
@@ -50,9 +50,9 @@
           <el-table-column label="类型" min-width="100">
             <template slot-scope="scope">
               <div slot="reference" class="name-wrapper">
-                <el-tag size="medium" v-if="scope.row.gbDeviceDbId">国标设备</el-tag>
-                <el-tag size="medium" v-if="scope.row.streamPushId">推流设备</el-tag>
-                <el-tag size="medium" v-if="scope.row.streamProxyId">拉流代理</el-tag>
+                <el-tag size="medium" effect="plain" v-if="scope.row.gbDeviceDbId">国标设备</el-tag>
+                <el-tag size="medium" effect="plain" type="success" v-if="scope.row.streamPushId">推流设备</el-tag>
+                <el-tag size="medium" effect="plain" type="warning" v-if="scope.row.streamProxyId">拉流代理</el-tag>
               </div>
             </template>
           </el-table-column>