|
@@ -0,0 +1,480 @@
|
|
|
|
+using System;
|
|
|
|
+using System.Collections;
|
|
|
|
+using System.Collections.Generic;
|
|
|
|
+using System.Diagnostics;
|
|
|
|
+using System.Globalization;
|
|
|
|
+using System.Linq;
|
|
|
|
+using System.Text;
|
|
|
|
+using System.Text.Json;
|
|
|
|
+using System.Text.RegularExpressions;
|
|
|
|
+using TEAMModelOS.SDK.Helper.Common.CollectionHelper;
|
|
|
|
+
|
|
|
|
+namespace TEAMModelOS.SDK.Helper.Common.JsonHelper.JsonPath
|
|
|
|
+{
|
|
|
|
+ /// <summary>
|
|
|
|
+ /// 语法文档 https://www.cnblogs.com/aoyihuashao/p/8665873.html
|
|
|
|
+ /// </summary>
|
|
|
|
+ /// <param name="script"></param>
|
|
|
|
+ /// <param name="value"></param>
|
|
|
|
+ /// <param name="context"></param>
|
|
|
|
+ /// <returns></returns>
|
|
|
|
+ public delegate object JsonPathScriptEvaluator(string script, object value, string context);
|
|
|
|
+ public delegate void JsonPathResultAccumulator(object value, string[] indicies);
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ [Serializable]
|
|
|
|
+ public sealed class JsonPathNode
|
|
|
|
+ {
|
|
|
|
+ private readonly object value;
|
|
|
|
+ private readonly string path;
|
|
|
|
+
|
|
|
|
+ public JsonPathNode(object value, string path)
|
|
|
|
+ {
|
|
|
|
+ if (path == null)
|
|
|
|
+ throw new ArgumentNullException("path");
|
|
|
|
+
|
|
|
|
+ if (path.Length == 0)
|
|
|
|
+ throw new ArgumentException("path");
|
|
|
|
+
|
|
|
|
+ this.value = value;
|
|
|
|
+ this.path = path;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public object Value
|
|
|
|
+ {
|
|
|
|
+ get { return value; }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public string Path
|
|
|
|
+ {
|
|
|
|
+ get { return path; }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public override string ToString()
|
|
|
|
+ {
|
|
|
|
+ return Path + " = " + Value;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static object[] ValuesFrom(ICollection nodes)
|
|
|
|
+ {
|
|
|
|
+ object[] values = new object[nodes != null ? nodes.Count : 0];
|
|
|
|
+
|
|
|
|
+ if (values.Length > 0)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(nodes != null);
|
|
|
|
+
|
|
|
|
+ int i = 0;
|
|
|
|
+ foreach (JsonPathNode node in nodes)
|
|
|
|
+ values[i++] = node.Value;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return values;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static string[] PathsFrom(ICollection nodes)
|
|
|
|
+ {
|
|
|
|
+ string[] paths = new string[nodes != null ? nodes.Count : 0];
|
|
|
|
+
|
|
|
|
+ if (paths.Length > 0)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(nodes != null);
|
|
|
|
+
|
|
|
|
+ int i = 0;
|
|
|
|
+ foreach (JsonPathNode node in nodes)
|
|
|
|
+ paths[i++] = node.Path;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return paths;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public sealed class JsonPathContext
|
|
|
|
+ {
|
|
|
|
+ public static readonly JsonPathContext Default = new JsonPathContext();
|
|
|
|
+
|
|
|
|
+ private JsonPathScriptEvaluator eval;
|
|
|
|
+ private IJsonPathValueSystem system;
|
|
|
|
+
|
|
|
|
+ public JsonPathScriptEvaluator ScriptEvaluator
|
|
|
|
+ {
|
|
|
|
+ get { return eval; }
|
|
|
|
+ set { eval = value; }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public IJsonPathValueSystem ValueSystem
|
|
|
|
+ {
|
|
|
|
+ get { return system; }
|
|
|
|
+ set { system = value; }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void SelectTo(object obj, string expr, JsonPathResultAccumulator output)
|
|
|
|
+ {
|
|
|
|
+ if (obj == null)
|
|
|
|
+ throw new ArgumentNullException("obj");
|
|
|
|
+
|
|
|
|
+ if (output == null)
|
|
|
|
+ throw new ArgumentNullException("output");
|
|
|
|
+
|
|
|
|
+ Interpreter i = new Interpreter(output, ValueSystem, ScriptEvaluator);
|
|
|
|
+
|
|
|
|
+ expr = Normalize(expr);
|
|
|
|
+
|
|
|
|
+ if (expr.Length >= 1 && expr[0] == '$') // ^\$:?
|
|
|
|
+ expr = expr.Substring(expr.Length >= 2 && expr[1] == ';' ? 2 : 1);
|
|
|
|
+
|
|
|
|
+ i.Trace(expr, obj, "$");
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public JsonPathNode[] SelectNodes(object obj, string expr)
|
|
|
|
+ {
|
|
|
|
+ ArrayList list = new ArrayList();
|
|
|
|
+ SelectNodesTo(obj, expr, list);
|
|
|
|
+ return (JsonPathNode[])list.ToArray(typeof(JsonPathNode));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public IList SelectNodesTo(object obj, string expr, IList output)
|
|
|
|
+ {
|
|
|
|
+ ListAccumulator accumulator = new ListAccumulator(output != null ? output : new ArrayList());
|
|
|
|
+ SelectTo(obj, expr, new JsonPathResultAccumulator(accumulator.Put));
|
|
|
|
+ return output;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private static Regex RegExp(string pattern)
|
|
|
|
+ {
|
|
|
|
+ return new Regex(pattern, RegexOptions.ECMAScript);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private static string Normalize(string expr)
|
|
|
|
+ {
|
|
|
|
+ NormalizationSwap swap = new NormalizationSwap();
|
|
|
|
+ expr = RegExp(@"[\['](\??\(.*?\))[\]']").Replace(expr, new MatchEvaluator(swap.Capture));
|
|
|
|
+ expr = RegExp(@"'?\.'?|\['?").Replace(expr, ";");
|
|
|
|
+ expr = RegExp(@";;;|;;").Replace(expr, ";..;");
|
|
|
|
+ expr = RegExp(@";$|'?\]|'$").Replace(expr, string.Empty);
|
|
|
|
+ expr = RegExp(@"#([0-9]+)").Replace(expr, new MatchEvaluator(swap.Yield));
|
|
|
|
+ return expr;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private sealed class NormalizationSwap
|
|
|
|
+ {
|
|
|
|
+ private readonly ArrayList subx = new ArrayList(4);
|
|
|
|
+
|
|
|
|
+ public string Capture(Match match)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(match != null);
|
|
|
|
+
|
|
|
|
+ int index = subx.Add(match.Groups[1].Value);
|
|
|
|
+ return "[#" + index.ToString(CultureInfo.InvariantCulture) + "]";
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public string Yield(Match match)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(match != null);
|
|
|
|
+
|
|
|
|
+ int index = int.Parse(match.Groups[1].Value, CultureInfo.InvariantCulture);
|
|
|
|
+ return (string)subx[index];
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public static string AsBracketNotation(string[] indicies)
|
|
|
|
+ {
|
|
|
|
+ if (indicies == null)
|
|
|
|
+ throw new ArgumentNullException("indicies");
|
|
|
|
+
|
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
|
+
|
|
|
|
+ foreach (string index in indicies)
|
|
|
|
+ {
|
|
|
|
+ if (sb.Length == 0)
|
|
|
|
+ {
|
|
|
|
+ sb.Append('$');
|
|
|
|
+ }
|
|
|
|
+ else
|
|
|
|
+ {
|
|
|
|
+ sb.Append('[');
|
|
|
|
+ if (RegExp(@"^[0-9*]+$").IsMatch(index))
|
|
|
|
+ sb.Append(index);
|
|
|
|
+ else
|
|
|
|
+ sb.Append('\'').Append(index).Append('\'');
|
|
|
|
+ sb.Append(']');
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return sb.ToString();
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private static int ParseInt(string s)
|
|
|
|
+ {
|
|
|
|
+ return ParseInt(s, 0);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private static int ParseInt(string str, int defaultValue)
|
|
|
|
+ {
|
|
|
|
+ if (str == null || str.Length == 0)
|
|
|
|
+ return defaultValue;
|
|
|
|
+
|
|
|
|
+ try
|
|
|
|
+ {
|
|
|
|
+ return int.Parse(str, NumberStyles.None, CultureInfo.InvariantCulture);
|
|
|
|
+ }
|
|
|
|
+ catch (FormatException)
|
|
|
|
+ {
|
|
|
|
+ return defaultValue;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private sealed class Interpreter
|
|
|
|
+ {
|
|
|
|
+ private readonly JsonPathResultAccumulator output;
|
|
|
|
+ private readonly JsonPathScriptEvaluator eval;
|
|
|
|
+ private readonly IJsonPathValueSystem system;
|
|
|
|
+
|
|
|
|
+ private static readonly IJsonPathValueSystem defaultValueSystem = new BasicValueSystem();
|
|
|
|
+
|
|
|
|
+ private static readonly char[] colon = new char[] { ':' };
|
|
|
|
+ private static readonly char[] semicolon = new char[] { ';' };
|
|
|
|
+
|
|
|
|
+ private delegate void WalkCallback(object member, string loc, string expr, object value, string path);
|
|
|
|
+
|
|
|
|
+ public Interpreter(JsonPathResultAccumulator output, IJsonPathValueSystem valueSystem, JsonPathScriptEvaluator eval)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(output != null);
|
|
|
|
+
|
|
|
|
+ this.output = output;
|
|
|
|
+ this.eval = eval != null ? eval : new JsonPathScriptEvaluator(NullEval);
|
|
|
|
+ this.system = valueSystem != null ? valueSystem : defaultValueSystem;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void Trace(string expr, object value, string path)
|
|
|
|
+ {
|
|
|
|
+ if (expr == null || expr.Length == 0)
|
|
|
|
+ {
|
|
|
|
+ Store(path, value);
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ int i = expr.IndexOf(';');
|
|
|
|
+ string atom = i >= 0 ? expr.Substring(0, i) : expr;
|
|
|
|
+ string tail = i >= 0 ? expr.Substring(i + 1) : string.Empty;
|
|
|
|
+ bool mb = system.HasMember(value, atom);
|
|
|
|
+ if (value != null && mb)
|
|
|
|
+ {
|
|
|
|
+ Trace(tail, Index(value, atom), path + ";" + atom);
|
|
|
|
+ }
|
|
|
|
+ else if (atom.Equals("*"))
|
|
|
|
+ {
|
|
|
|
+ Walk(atom, tail, value, path, new WalkCallback(WalkWild));
|
|
|
|
+ }
|
|
|
|
+ else if (atom.Equals(".."))
|
|
|
|
+ {
|
|
|
|
+ Trace(tail, value, path);
|
|
|
|
+ Walk(atom, tail, value, path, new WalkCallback(WalkTree));
|
|
|
|
+ }
|
|
|
|
+ else if (atom.Length > 2 && atom[0] == '(' && atom[atom.Length - 1] == ')') // [(exp)]
|
|
|
|
+ {
|
|
|
|
+ Trace(eval(atom, value, path.Substring(path.LastIndexOf(';') + 1)) + ";" + tail, value, path);
|
|
|
|
+ }
|
|
|
|
+ else if (atom.Length > 3 && atom[0] == '?' && atom[1] == '(' && atom[atom.Length - 1] == ')') // [?(exp)]
|
|
|
|
+ {
|
|
|
|
+ Walk(atom, tail, value, path, new WalkCallback(WalkFiltered));
|
|
|
|
+ }
|
|
|
|
+ else if (RegExp(@"^(-?[0-9]*):(-?[0-9]*):?([0-9]*)$").IsMatch(atom)) // [start:end:step] Phyton slice syntax
|
|
|
|
+ {
|
|
|
|
+ Slice(atom, tail, value, path);
|
|
|
|
+ }
|
|
|
|
+ else if (atom.IndexOf(',') >= 0) // [name1,name2,...]
|
|
|
|
+ {
|
|
|
|
+ foreach (string part in RegExp(@"'?,'?").Split(atom))
|
|
|
|
+ Trace(part + ";" + tail, value, path);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void Store(string path, object value)
|
|
|
|
+ {
|
|
|
|
+ if (path != null)
|
|
|
|
+ output(value, path.Split(semicolon));
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void Walk(string loc, string expr, object value, string path, WalkCallback callback)
|
|
|
|
+ {
|
|
|
|
+ if (system.IsPrimitive(value)) {
|
|
|
|
+
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
+ if (system.IsArray(value))
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+
|
|
|
|
+ if (value is JsonElement element)
|
|
|
|
+ {
|
|
|
|
+ IEnumerator enumerator = element.EnumerateArray().GetEnumerator();
|
|
|
|
+ int i = 0;
|
|
|
|
+ while (enumerator.MoveNext()) {
|
|
|
|
+ callback(i, loc, expr, value, path);
|
|
|
|
+ i += 1;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ else {
|
|
|
|
+ IList list = (IList)value;
|
|
|
|
+ for (int i = 0; i < list.Count; i++)
|
|
|
|
+ callback(i, loc, expr, value, path);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ }
|
|
|
|
+ else if (system.IsObject(value))
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+ IEnumerable mbs = system.GetMembers(value);
|
|
|
|
+
|
|
|
|
+ foreach (string key in mbs)
|
|
|
|
+ callback(key, loc, expr, value, path);
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void WalkWild(object member, string loc, string expr, object value, string path)
|
|
|
|
+ {
|
|
|
|
+ Trace(member + ";" + expr, value, path);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void WalkTree(object member, string loc, string expr, object value, string path)
|
|
|
|
+ {
|
|
|
|
+ object result = Index(value, member.ToString());
|
|
|
|
+ if (result != null && !system.IsPrimitive(result))
|
|
|
|
+ Trace("..;" + expr, result, path + ";" + member);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void WalkFiltered(object member, string loc, string expr, object value, string path)
|
|
|
|
+ {
|
|
|
|
+ object result = eval(RegExp(@"^\?\((.*?)\)$").Replace(loc, "$1"),
|
|
|
|
+ Index(value, member.ToString()), member.ToString());
|
|
|
|
+
|
|
|
|
+ if (Convert.ToBoolean(result, CultureInfo.InvariantCulture))
|
|
|
|
+ Trace(member + ";" + expr, value, path);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private void Slice(string loc, string expr, object value, string path)
|
|
|
|
+ {
|
|
|
|
+ IList list = value as IList;
|
|
|
|
+
|
|
|
|
+ if (list == null)
|
|
|
|
+ return;
|
|
|
|
+
|
|
|
|
+ int length = list.Count;
|
|
|
|
+ string[] parts = loc.Split(colon);
|
|
|
|
+ int start = ParseInt(parts[0]);
|
|
|
|
+ int end = ParseInt(parts[1], list.Count);
|
|
|
|
+ int step = parts.Length > 2 ? ParseInt(parts[2], 1) : 1;
|
|
|
|
+ start = (start < 0) ? Math.Max(0, start + length) : Math.Min(length, start);
|
|
|
|
+ end = (end < 0) ? Math.Max(0, end + length) : Math.Min(length, end);
|
|
|
|
+ for (int i = start; i < end; i += step)
|
|
|
|
+ Trace(i + ";" + expr, value, path);
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private object Index(object obj, string member)
|
|
|
|
+ {
|
|
|
|
+
|
|
|
|
+ object mbv = system.GetMemberValue(obj, member);
|
|
|
|
+
|
|
|
|
+ return mbv;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private static object NullEval(string expr, object value, string context)
|
|
|
|
+ {
|
|
|
|
+ //
|
|
|
|
+ // @ symbol in expr must be interpreted specially to resolve
|
|
|
|
+ // to value. In JavaScript, the implementation would look
|
|
|
|
+ // like:
|
|
|
|
+ //
|
|
|
|
+ // return obj && value && eval(expr.replace(/@/g, "value"));
|
|
|
|
+ //
|
|
|
|
+
|
|
|
|
+ return null;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private sealed class BasicValueSystem : IJsonPathValueSystem
|
|
|
|
+ {
|
|
|
|
+ public bool HasMember(object value, string member)
|
|
|
|
+ {
|
|
|
|
+ if (IsPrimitive(value))
|
|
|
|
+ return false;
|
|
|
|
+
|
|
|
|
+ IDictionary dict = value as IDictionary;
|
|
|
|
+ if (dict != null)
|
|
|
|
+ return dict.Contains(member);
|
|
|
|
+
|
|
|
|
+ IList list = value as IList;
|
|
|
|
+ if (list != null)
|
|
|
|
+ {
|
|
|
|
+ int index = ParseInt(member, -1);
|
|
|
|
+ return index >= 0 && index < list.Count;
|
|
|
|
+ }
|
|
|
|
+ object obj = value as object;
|
|
|
|
+ if (obj != null)
|
|
|
|
+ {
|
|
|
|
+ IDictionary<string,object> dis = obj.ToDictionary();
|
|
|
|
+
|
|
|
|
+ return dis.ContainsKey(member);
|
|
|
|
+ }
|
|
|
|
+ return false;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public object GetMemberValue(object value, string member)
|
|
|
|
+ {
|
|
|
|
+ if (IsPrimitive(value))
|
|
|
|
+ throw new ArgumentException("value");
|
|
|
|
+
|
|
|
|
+ IDictionary dict = value as IDictionary;
|
|
|
|
+ if (dict != null)
|
|
|
|
+ return dict[member];
|
|
|
|
+
|
|
|
|
+ IList list = (IList)value;
|
|
|
|
+ int index = ParseInt(member, -1);
|
|
|
|
+ if (index >= 0 && index < list.Count)
|
|
|
|
+ return list[index];
|
|
|
|
+
|
|
|
|
+ return null;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public IEnumerable GetMembers(object value)
|
|
|
|
+ {
|
|
|
|
+ return ((IDictionary)value).Keys;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public bool IsObject(object value)
|
|
|
|
+ {
|
|
|
|
+ return value is IDictionary;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public bool IsArray(object value)
|
|
|
|
+ {
|
|
|
|
+ return value is IList;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public bool IsPrimitive(object value)
|
|
|
|
+ {
|
|
|
|
+ if (value == null)
|
|
|
|
+ throw new ArgumentNullException("value");
|
|
|
|
+
|
|
|
|
+ return Type.GetTypeCode(value.GetType()) != TypeCode.Object;
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ private sealed class ListAccumulator
|
|
|
|
+ {
|
|
|
|
+ private readonly IList list;
|
|
|
|
+
|
|
|
|
+ public ListAccumulator(IList list)
|
|
|
|
+ {
|
|
|
|
+ Debug.Assert(list != null);
|
|
|
|
+
|
|
|
|
+ this.list = list;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ public void Put(object value, string[] indicies)
|
|
|
|
+ {
|
|
|
|
+ list.Add(new JsonPathNode(value, JsonPathContext.AsBracketNotation(indicies)));
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+ }
|
|
|
|
+}
|