使用json字符串插入节点或者覆盖节点

更新时间：2021年08月10日 16:10:01 作者：BugCounter

这篇文章主要介绍了使用json字符串插入节点或者覆盖节点的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

json字符串插入节点或者覆盖节点

jfdaJson是json字符串

JSONObject obj=JSONObject.parseObject(jfdaJson);
obj.put("dj",xydjDm);// 更新dj字段
obj.put("xydjMc",xydjMc);// 添加xydjMc字段
obj.toString();

json字符串转换成json增删查改节点

一、功能实现

1、节点树查询：

按ID查询树

2、节点新增：

http://host/tree_data/node/${treeId}
in: {node: {key: ..., ...}, parent: ${key}, sequ: ${sequ}}

3、节点修改

http://host/tree_data/node/${treeId}/${key}
in: {node: {key: ..., ...}}

4、节点删除

http://host/tree_data/node/${treeId}/${key}

二、数据表结构

CREATE TABLE `catagory_tree`  (
  `id` bigint(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '分类树名称：PRODUCT：产品分类  GOODS：商品分类',
  `json_tree` text CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL COMMENT '直接存储ANTD树表的数据结构',
  `modify_staff` varchar(32) CHARACTER SET utf8 COLLATE utf8_general_ci NOT NULL,
  `modify_time` datetime(0) NOT NULL,
  PRIMARY KEY (`id`) USING BTREE,
  INDEX `AK_uni_catagory_tree_name`(`name`) USING BTREE
) ENGINE = InnoDB AUTO_INCREMENT = 2 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Compact;

三、json字符串

[{
 "id": 1,
 "code": "FLOW_NODE_1",
 "name": "环节A",
 "children": [{
  "id": 2,
  "code": "RULE_NODE_1",
  "name": "规则A"
 }, {
  "id": 3,
  "code": "RULE_NODE_2",
  "name": "规则B"
 }, {
  "id": 4,
  "code": "PARALLEL_NODE_2",
  "name": "并行节点",
  "children": [{
   "id": 5,
   "code": "RULE_NODE_3",
   "name": "规则C1"
  }, {
   "id": 6,
   "code": "RULE_COLLECTION_1",
   "name": "规则集1",
   "children": [{
    "id": 7,
    "code": "RULE_NODE_4",
    "name": "规则C21"
   }, {
    "id": 8,
    "code": "RULE_NODE_5",
    "name": "规则C22"
   }]
  }]
 }, {
  "id": 9,
  "code": "MUTUAL_NODE_1",
  "name": "互斥节点",
  "children": [{
   "id": 10,
   "code": "RULE_NODE_6",
   "name": "规则D1"
  }, {
   "id": 11,
   "code": "RULE_NODE_7",
   "name": "规则D2"
  }]
 }]
}, {
 "id": 12,
 "code": "FLOW_NODE_2",
 "name": "环节B"
}]

四、pom文件依赖

<dependency>
     <groupId>com.alibaba</groupId>
     <artifactId>fastjson</artifactId>
     <version>1.2.49</version>
</dependency>

五、controller层

package cn.chinaunicom.srigz.goods.admin.controller;
import cn.chinaunicom.srigz.goods.admin.service.CatagoryTreeService;
import cn.chinaunicom.srigz.goods.admin.utils.ActionHelper;
import io.swagger.annotations.ApiOperation;
import io.swagger.annotations.ApiParam;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.Map;
@RestController
public class CatagoryTreeController {
    @Autowired
    private CatagoryTreeService catagoryTreeService;
    @ApiOperation(value="查询分类树信息", notes="输入分类树Id")
    @RequestMapping(value = "/api/v1/tree_data/node/{treeId}", method = RequestMethod.GET)
    public Map getOne(@ApiParam(required = true, value = "分类树ID") @PathVariable Integer treeId){
        return ActionHelper.responseOk(catagoryTreeService.getOne(treeId));
    }
    @ApiOperation(value="新建节点", notes="根据输入参数创建节点")
    @RequestMapping(value = "/tree_data/node/{treeId}", method = RequestMethod.POST)
    public Map addOne(@ApiParam(required = true, value = "分类树ID")@PathVariable Integer treeId,
                      @ApiParam(required = true, value = "节点信息、父类ID、数组位置") @RequestBody Map map){
        return ActionHelper.responseOk(catagoryTreeService.addOne(treeId,map));
    }
    @ApiOperation(value="更新节点信息", notes="更新节点信息")
    @RequestMapping(value = "/tree_data/node/{treeId}/{id}", method = RequestMethod.PATCH)
    public Map updateOne(@ApiParam(required = true, value = "分类树ID")@PathVariable Integer treeId,
                         @ApiParam(required = true, value = "节点ID")@PathVariable Integer id,
                         @ApiParam(required = true, value = "节点信息") @RequestBody Map map){
        return ActionHelper.responseOk(catagoryTreeService.updateOne(treeId,id,map));
    }
    @ApiOperation(value="删除节点详情", notes="删除节点详情")
    @RequestMapping(method = RequestMethod.DELETE,value = "/tree_data/node/{treeId}/{id}")
    public Map remove(@ApiParam(required = true, value = "分类树ID")@PathVariable Integer treeId,
                      @ApiParam(required = true, value = "节点ID")@PathVariable Integer id){
        return ActionHelper.responseOk(catagoryTreeService.remove(treeId,id));
    }
}

六、service层

JSONArray jsonArray = JSON.parseArray(jsonTree); //由json字符串变成json数组对象
jsonArray.toJSONString() //由json数组对象变成json字符串

package cn.chinaunicom.srigz.goods.admin.service;
import cn.chinaunicom.srigz.goods.admin.database.dao.CatagoryTreeRepository;
import cn.chinaunicom.srigz.goods.admin.database.model.CatagoryTree;
import cn.chinaunicom.srigz.goods.admin.utils.Recursive;
import cn.chinaunicom.srigz.goods.common.exception.AlreadyExistException;
import cn.chinaunicom.srigz.goods.common.exception.BadRequestException;
import cn.chinaunicom.srigz.goods.common.exception.NotFoundException;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.*;
@Service
public class CatagoryTreeService {
    @Autowired
    private CatagoryTreeRepository catagoryTreeRepository;
    /**
     * 查询单个分类树
     * @param treeId
     * @return
     */
    public JSON getOne(Integer treeId) {
        CatagoryTree catagoryTree = catagoryTreeRepository.findById(treeId.longValue()).get();
        return JSON.parseArray(catagoryTree.getJsonTree());
    }
    /**
     * 增加单个节点
     * @param treeId
     * @param map
     * @return
     */
    @Transactional
    public JSON addOne(Integer treeId, Map map) {
        CatagoryTree catagoryTree = catagoryTreeRepository.findById(treeId.longValue()).get();
        String jsonTree = catagoryTree.getJsonTree();
        JSONArray jsonArray = JSON.parseArray(jsonTree);
        Object parentId = map.get("parentId");
        Integer sequ = (Integer) map.get("sequ");
        if(sequ <= 0 ){
            throw new BadRequestException("数组位置不正确");
        }
        Map nodeMap = (Map) map.get("node");
        JSONObject node = new JSONObject(nodeMap);
        List list = new ArrayList();
        List keyList = Recursive.recursive(jsonArray,"id",list);
        for (Object key : keyList) {
            if (nodeMap.get("id").toString().equals(key.toString())) {
                throw new AlreadyExistException("节点ID为" + key);
            }
        }
        Recursive.addRecursive(jsonArray,node,sequ,"id",parentId);
        catagoryTree.setJsonTree(jsonArray.toJSONString());
        catagoryTreeRepository.save(catagoryTree);
        return jsonArray;
    }
    /**
     * 修改单个节点
     * @param treeId
     * @param id
     * @param map
     * @return
     */
    @Transactional
    public JSON updateOne(Integer treeId, Integer id, Map map) {
        CatagoryTree catagoryTree = catagoryTreeRepository.findById(treeId.longValue()).get();
        String jsonTree = catagoryTree.getJsonTree();
        JSONArray jsonArray = JSON.parseArray(jsonTree);
        List list = new ArrayList();
        List keyList = Recursive.recursive(jsonArray,"id",list);
        JSONObject node = new JSONObject(map);
        if (id.toString().equals(map.get("id").toString())) {
            for (Object key : keyList) {
                if (id.toString().equals(key.toString())) {
                    Recursive.updateRecursive(jsonArray,"id",id,node);
                    catagoryTree.setJsonTree(jsonArray.toJSONString());
                    catagoryTree.setModifyTime(new Date());
                    catagoryTreeRepository.save(catagoryTree);
                    return jsonArray;
                }
            }
        }else {
            throw new BadRequestException("id is not allowed to be modified");
        }
        throw new NotFoundException("节点ID为" + id);
    }
    /**
     * 删除节点以及子节点
     * @param treeId
     * @param id
     * @return
     */
    @Transactional
    public JSON remove(Integer treeId, Integer id) {
        CatagoryTree catagoryTree = catagoryTreeRepository.findById(treeId.longValue()).get();
        String jsonTree = catagoryTree.getJsonTree();
        JSONArray jsonArray = JSON.parseArray(jsonTree);
        List list = new ArrayList();
        List keyList = Recursive.recursive(jsonArray,"id",list);
        for (Object key : keyList) {
            if (id.toString().equals(key.toString())) {
                Recursive.removeRecursive(jsonArray,"id",id);
                catagoryTree.setJsonTree(jsonArray.toJSONString());
                catagoryTreeRepository.save(catagoryTree);
                return jsonArray;
            }
        }
        throw new NotFoundException("节点ID为" + id);
    }
}

七、把增删查改的递归方法写成工具类

package cn.chinaunicom.srigz.goods.admin.utils;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import java.util.List;
public class Recursive {
    /**
     * 递归取出所有Key对应的value值
     * @param jsonArray     需要查询的目标主体
     * @param key           需要查询的字段名key
     * @param list          存储value值
     * @return
     */
    public static List recursive(JSONArray jsonArray, String key, List list) {
        for (Object obj : jsonArray) {
            JSONObject jsonObject = (JSONObject) obj;
            JSONArray children = jsonObject.getJSONArray("children");
            if (children != null) {
                list.add(jsonObject.get(key));
                recursive(children,key,list);
            }else {
                list.add(jsonObject.get(key));
            }
        }
        return list;
    }
    /**
     * 增加节点
     * @param jsonArray     需要更新的目标主体
     * @param node          增加节点信息
     * @param sequ          数组的位置
     * @param key           目标主体中的字段名key
     * @param value         节点信息与key对应的value
     */
    public static void addRecursive(JSONArray jsonArray, JSONObject node, Integer sequ, String key, Object value) {
        for (Object obj : jsonArray) {
            JSONObject jsonObject = (JSONObject) obj;
            JSONArray children = jsonObject.getJSONArray("children");
            if (children != null) {
                if (value.toString().equals(jsonObject.get(key).toString())) {
                    if(sequ > children.size()){
                        children.add(children.size(), node);
                    }else{
                        children.add(sequ-1, node);
                    }
                    return;
                }
                addRecursive(children,node,sequ,key,value);
            } else {
                if (value.toString().equals(jsonObject.get(key).toString())) {
                    JSONArray array = new JSONArray();
                    array.add(node);
                    jsonObject.put("children", array);
                    return;
                }
            }
        }
    }
    /**
     * 根据条件更新节点
     * @param jsonArray 需要更新的目标主体
     * @param key       目标主体中的字段名key
     * @param value     更新节点信息与key对应的value
     * @param node      更新节点信息
     */
    public static void updateRecursive(JSONArray jsonArray, String key, Object value, JSONObject node) {
        for (int i = 0; i < jsonArray.size() ; i++) {
            JSONObject jsonObject = jsonArray.getJSONObject(i);
            JSONArray children = jsonObject.getJSONArray("children");
            if (value.toString().equals(jsonObject.get(key).toString())) {
                if(children != null){
                    node.put("children",children);
                }
                jsonArray.set(i,node);
                return;
            }else if(children != null){
                updateRecursive(children,key,value,node);
            }
        }
    }
    /**
     * 删除节点
     * @param jsonArray     需要更新的目标主体
     * @param key           目标主体中的字段名key
     * @param value         节点信息与key对应的value
     */
    public static void removeRecursive(JSONArray jsonArray,String key,Object value) {
        for (Object obj : jsonArray) {
            JSONObject jsonObject = (JSONObject) obj;
            if (value.toString().equals(jsonObject.get(key).toString())) {
                jsonArray.remove(jsonObject);
                return;
            }
            JSONArray children = jsonObject.getJSONArray("children");
            if (children != null) {
                removeRecursive(children,key,value);
            }
        }
    }
}

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

mybatis条件语句中带数组参数的处理
这篇文章主要介绍了mybatis条件语句中带数组参数的处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-09-09
SpringCloud Gateway动态转发后端服务实现过程讲解
这篇文章主要介绍了SpringCloud Gateway动态转发后端服务实现过程，简单的路由转发可以通过SpringCloudGateway的配置文件实现，在一些业务场景种，会需要动态替换路由配置中的后端服务地址，单纯靠配置文件无法满足这种需求
2023-03-03
java实现模拟USB接口的功能
本文主要介绍了java实现模拟USB接口的功能，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-07-07
Java中文件的操作与输入输出流举例详解
Java语言的输入输出功能是十分强大而灵活的,下面这篇文章主要给大家介绍了关于Java中文件的操作与输入输出流的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
2023-12-12
SpringBoot整合微信登录功能的实现方案
今天通过本文给大家分享微信登录与SpringBoot整合过程,微信扫描登录实现代码知道扫描后点击登录的全部过程，本文给大家介绍的非常详细，需要的朋友可以参考下
2021-10-10
java int转byte和long转byte的方法
下面小编就为大家带来一篇java int转byte和long转byte的方法。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2016-10-10
深入浅出讲解Java比较器及数学常用类
这篇文章主要介绍了深入浅出讲解Java比较器及数学常用类，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-09-09
JAVA多线程线程安全性基础
这篇文章主要介绍了如何测试Java类的线程安全性,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2021-08-08
使用jvisualvm配合Visual GC插件监控Java程序详细总结
本节将会介绍一下jvisualvm的特性及作用、各个功能是如何使用的、最后会介绍jvisualvm的插件Visual GC的安装及使用
2021-09-09
详解AOP与Filter拦截请求打印日志实用例子
这篇文章主要介绍了详解AOP与Filter拦截请求打印日志实用例子，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-09-09