Skip to content

Commit

Permalink
up
Browse files Browse the repository at this point in the history
  • Loading branch information
@youfanx
youfanx committed Nov 17, 2023
1 parent c080bf8 commit ddaa8a3
Show file tree
Hide file tree
Showing 2 changed files with 208 additions and 22 deletions.
124 changes: 106 additions & 18 deletions rxlib/src/main/java/org/rx/core/Sys.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -12,11 +12,14 @@
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.commons.collections4.IterableUtils;
import org.apache.commons.collections4.ListUtils;
import org.apache.commons.lang3.SystemUtils;
import org.rx.annotation.Subscribe;
import org.rx.bean.DynamicProxyBean;
import org.rx.bean.LogStrategy;
import org.rx.bean.ProceedEventArgs;
import org.rx.bean.Tuple;
import org.rx.codec.CodecUtil;
import org.rx.exception.InvalidException;
import org.rx.exception.TraceHandler;
Expand All @@ -32,13 +35,15 @@
import java.io.File;
import java.io.Serializable;
import java.lang.management.ManagementFactory;
import java.lang.reflect.Array;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.lang.reflect.Type;
import java.net.InetAddress;
import java.net.URI;
import java.util.*;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.function.Function;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
Expand Down Expand Up @@ -511,31 +516,114 @@ public static <T> T readJsonValue(@NonNull Map<String, ?> json, String path,
return (T) child;
}

String[] paths = Strings.split(path, ".");
if (paths.length == 0) {
return null;
Object cur = json;
int max = path.length() - 1;

AtomicInteger i = new AtomicInteger();
StringBuilder buf = new StringBuilder();
for (; i.get() <= max; i.incrementAndGet()) {
char c = path.charAt(i.get());
if (c != objKey && c != arrBeginKey) {
buf.append(c);
continue;
}

cur = visitJson(cur, path, i, c, buf, max, childSelect, throwOnEmptyChild);
buf.setLength(0);
}
if (!buf.isEmpty()) {
cur = visitJson(cur, path, i, objKey, buf, max, childSelect, throwOnEmptyChild);
}
return (T) cur;

int last = paths.length - 1;
Map<String, ?> tmp = json;
for (int i = 0; i < last; i++) {
child = tmp.get(paths[i]);
if (childSelect != null) {
child = childSelect.apply(child);
// String[] paths = Strings.split(path, ".");
// if (paths.length == 0) {
// return null;
// }
//
// int last = paths.length - 1;
// Map<String, ?> tmp = json;
// for (int i = 0; i < last; i++) {
// child = tmp.get(paths[i]);
// if (childSelect != null) {
// child = childSelect.apply(child);
// }
// if ((tmp = as(child, Map.class)) == null) {
// if (throwOnEmptyChild) {
// throw new InvalidException("Get empty sub object by path {}", paths[i]);
// }
// return null;
// }
// }
// child = tmp.get(paths[last]);
// if (child != null
// && childSelect != null && !Reflects.isBasicType(child.getClass())) {
// child = childSelect.apply(child);
// }
// return (T) child;
}

static final char objKey = '.', arrBeginKey = '[', arrEndKey = ']';

static Object visitJson(Object cur, String path, AtomicInteger i, char c, StringBuilder buf,
int max, BiFunc<Object, ?> childSelect, boolean throwOnEmptyChild) {
String visitor = buf.toString();
if (cur instanceof Map) {
Map<String, ?> obj = (Map<String, ?>) cur;
cur = obj.get(visitor);
} else {
try {
cur = Reflects.readField(cur, visitor);
} catch (Throwable e) {
throw new InvalidException("Object {} is not a map type or not found field with path {}", cur, visitor, e);
}
}

if (c == arrBeginKey) {
StringBuilder idxBuf = new StringBuilder();
for (i.incrementAndGet(); i.get() < path.length(); i.incrementAndGet()) {
char ic = path.charAt(i.get());
if (ic != arrEndKey) {
idxBuf.append(ic);
continue;
}
i.incrementAndGet();
break;
}
int idx;
try {
idx = Integer.parseInt(idxBuf.toString());
visitor = String.format("%s[%s]", visitor, idxBuf);
} catch (Throwable e) {
throw new InvalidException("Index {} is not a int type", idxBuf, e);
}
if ((tmp = as(child, Map.class)) == null) {
if (throwOnEmptyChild) {
throw new InvalidException("Get empty sub object by path {}", paths[i]);

if (cur instanceof Iterable) {
try {
cur = IterableUtils.get((Iterable<?>) cur, idx);
} catch (IndexOutOfBoundsException e) {
throw new InvalidException("Array {} is index out of bounds with path {}", cur, visitor, e);
}
} else if (cur != null && cur.getClass().isArray()) {
try {
cur = Array.get(cur, idx);
} catch (ArrayIndexOutOfBoundsException e) {
throw new InvalidException("Array {} is index out of bounds with path {}", cur, visitor, e);
}
return null;
} else {
throw new InvalidException("Object {} is not a array type with path {}", cur, visitor);
}
}
child = tmp.get(paths[last]);
if (child != null
&& childSelect != null && !Reflects.isBasicType(child.getClass())) {
child = childSelect.apply(child);
if (childSelect != null) {
cur = childSelect.apply(cur);
}
if (i.get() < max && cur == null) {
if (throwOnEmptyChild) {
throw new InvalidException("Get empty sub object by path {}", visitor);
}
return null;
}
return (T) child;
return cur;
}

//TypeReference
Expand Down
106 changes: 102 additions & 4 deletions rxlib/src/test/java/org/rx/util/TestUtil.java
View file
Original file line number Diff line number Diff line change
@@ -1,6 +1,8 @@
package org.rx.util;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.alibaba.fastjson2.JSONWriter;
import lombok.Data;
import lombok.SneakyThrows;
Expand All @@ -20,8 +22,8 @@
import java.util.Arrays;
import java.util.*;

import static org.rx.core.Sys.toJsonObject;
import static org.rx.core.Sys.toJsonString;
import static org.rx.core.Extends.eq;
import static org.rx.core.Sys.*;

@Slf4j
public class TestUtil extends AbstractTester {
Expand Down Expand Up @@ -270,9 +272,105 @@ public void other() {
String ce = "适用苹果ipad 10.2平板钢化膜9.7寸/air5全屏防爆膜2020/2021版高清贴膜10.9/11寸12.9寸护眼抗蓝紫光钢化膜";
System.out.println(Strings.subStringByByteLen(ce, 78));

String json = "{\"ctp\":\"pages/gold/item/pages/detail/index\",\"par\":\"\",\"ref\":\"pages/gold/item/pages/detail/index\",\"rpr\":\"\",\"seq\":2,\"vts\":110,\"pin\":\"jd_759f867040f60\",\"fst\":\"1577630901829\",\"pst\":\"1677280413\",\"vct\":\"1677479554\",\"jsver\":\"TR1.0.0\",\"net\":\"wifi\",\"lat\":\"\",\"lon\":\"\",\"speed\":\"\",\"accuracy\":\"\",\"pixelRatio\":\"1\",\"jdv\":\"1|weixin|t_335139774_xcx_1036_appfxxx|xcx|-|1677479554238\",\"customerInfo\":\"\",\"unpl\":\"\",\"scene\":1036,\"sdkver\":\"2.19.2\",\"ext\":{},\"eid\":\"W_jdgwxcx_productdetail_consultationiconexpo\",\"eparam\":\"{\\\"mainskuid\\\":100006612085}\",\"elevel\":\"\",\"page_id\":\"W_jdgwxcx_productdetail\",\"pname\":\"pages/gold/item/pages/detail/index\",\"pparam\":\"\",\"tar\":\"\",\"x\":0,\"y\":0,\"typ\":\"ep\"}";
Object v = Sys.readJsonValue(toJsonObject(json), "eparam.mainskuid", Sys::toJsonObject, true);
String json = "{\n" +
" \"data\": [\n" +
" {\n" +
" \"peoNo\": \"229527513620001\",\n" +
" \"skuAndSpus\": [\n" +
" {\n" +
" \"resSku\": {\n" +
" \"appId\": \"GJHY\",\n" +
" \"createBy\": \"linxi\",\n" +
" \"customData\": \"\",\n" +
" \"enable\": 1,\n" +
" \"extendMap\": {\n" +
" \"inquiryDuration\": 0.5,\n" +
" \"activityId\": 35497,\n" +
" \"itemId\": 22486569827767537,\n" +
" \"couponIds\": [\n" +
" 9169767537\n" +
" ]\n" +
" },\n" +
" \"gmtCreate\": \"2023-10-31 14:54:07\",\n" +
" \"gmtUpdate\": \"2023-10-31 14:54:07\",\n" +
" \"intro\": \"社医付费问诊场景\",\n" +
" \"name\": \"复诊续方\",\n" +
" \"peoId\": 1548942540449906736,\n" +
" \"price\": 0,\n" +
" \"priceTypeCode\": \"GJHIS\",\n" +
" \"providerId\": \"1548952654418411543\",\n" +
" \"skuCode\": \"22488697939067537\",\n" +
" \"skuId\": 1719246353046908962,\n" +
" \"spuId\": 1542023119361933110,\n" +
" \"status\": 0,\n" +
" \"stock\": 9999,\n" +
" \"updateBy\": \"linxi\",\n" +
" \"version\": 0\n" +
" },\n" +
" \"resSpu\": {\n" +
" \"appId\": \"GJHY\",\n" +
" \"createBy\": \"多牌照管理员\",\n" +
" \"enable\": 1,\n" +
" \"extendMap\": {\n" +
" \"goodsNo\": 8400003,\n" +
" \"inquiryType\": 0,\n" +
" \"pricingMethod\": \"platform\",\n" +
" \"responseTime\": 2880,\n" +
" \"listingPermission\": \"user\",\n" +
" \"price\": 0,\n" +
" \"showPriceSwitch\": true,\n" +
" \"minPrice\": 0,\n" +
" \"serviceDuration\": 2880,\n" +
" \"imUserPermission\": \"1\",\n" +
" \"maxPrice\": 0,\n" +
" \"iconUrl\": \"https://gj-prod-1256038144.cos.ap-beijing.myqcloud.com/common/1619404699492/video.png\",\n" +
" \"showUpLoSwitch\": true,\n" +
" \"showService\": true\n" +
" },\n" +
" \"gmtCreate\": \"2023-06-09 11:34:25\",\n" +
" \"gmtUpdate\": \"2023-11-09 15:07:46\",\n" +
" \"intro\": \"社医付费问诊场景\",\n" +
" \"name\": \"复诊续方\",\n" +
" \"serviceCode\": \"A006\",\n" +
" \"spuCategory\": \"1\",\n" +
" \"spuCategoryName\": \"图文问诊\",\n" +
" \"spuCode\": \"38792\",\n" +
" \"spuId\": 1542023119361933110,\n" +
" \"spuOrgCategory\": 1542348617615015958,\n" +
" \"status\": 0,\n" +
" \"updateBy\": \"卢昭\",\n" +
" \"version\": 0\n" +
" }\n" +
" }\n" +
" ]\n" +
" }\n" +
" ],\n" +
" \"status\": 0\n" +
" \"arr\": [0,1]" +
"}";
JSONObject jObj = toJsonObject(json);
Object v;
v = Sys.readJsonValue(jObj, "data", null, true);
System.out.println(v);
assert v instanceof JSONArray;

v = Sys.readJsonValue(jObj, "data[0].peoNo", null, true);
System.out.println(v);
assert eq(v, "229527513620001");

v = Sys.readJsonValue(jObj, "data[0].skuAndSpus", null, true);
System.out.println(v);
assert v instanceof JSONArray;

v = Sys.readJsonValue(jObj, "data[0].skuAndSpus[0].resSpu.createBy", null, true);
System.out.println(v);
assert eq(v, "多牌照管理员");

v = Sys.readJsonValue(jObj, "status", null, true);
System.out.println(v);
assert eq(v, 0);

v = Sys.readJsonValue(toJsonArray("[0,1]"),"[1]",null,true);
}

@Test
Expand Down

0 comments on commit ddaa8a3

Please sign in to comment.