From e9f44dd851a8f0bf18c00e3e5c53a8f8de9a6b66 Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Fri, 25 Jul 2025 12:21:24 +0800 Subject: [PATCH 1/5] JacksonUtil --- pom.xml | 14 + .../com/ycwl/basic/utils/JacksonUtil.java | 277 ++++++++++++++++++ 2 files changed, 291 insertions(+) create mode 100644 src/main/java/com/ycwl/basic/utils/JacksonUtil.java diff --git a/pom.xml b/pom.xml index 641de13..c68ebd1 100644 --- a/pom.xml +++ b/pom.xml @@ -129,6 +129,20 @@ ${fastjson.version} + + + com.fasterxml.jackson.core + jackson-databind + + + com.fasterxml.jackson.core + jackson-core + + + com.fasterxml.jackson.core + jackson-annotations + + org.apache.commons diff --git a/src/main/java/com/ycwl/basic/utils/JacksonUtil.java b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java new file mode 100644 index 0000000..4d0d65c --- /dev/null +++ b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java @@ -0,0 +1,277 @@ +package com.ycwl.basic.utils; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import com.fasterxml.jackson.databind.type.CollectionType; +import com.fasterxml.jackson.databind.type.TypeFactory; + +import java.io.IOException; +import java.util.List; +import java.util.Map; + +/** + * Jackson JSON工具类 + * 提供简单易用的JSON序列化和反序列化功能 + */ +public class JacksonUtil { + + private static final ObjectMapper objectMapper = new ObjectMapper(); + + /** + * 对象转JSON字符串 + * @param obj 要转换的对象 + * @return JSON字符串 + */ + public static String toJson(Object obj) { + try { + return objectMapper.writeValueAsString(obj); + } catch (JsonProcessingException e) { + throw new RuntimeException("对象转JSON失败", e); + } + } + + /** + * JSON字符串转对象 + * @param json JSON字符串 + * @param clazz 目标类型 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T fromJson(String json, Class clazz) { + try { + return objectMapper.readValue(json, clazz); + } catch (IOException e) { + throw new RuntimeException("JSON转对象失败", e); + } + } + + /** + * JSON字符串转对象（支持复杂类型） + * @param json JSON字符串 + * @param typeReference 类型引用 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T fromJson(String json, TypeReference typeReference) { + try { + return objectMapper.readValue(json, typeReference); + } catch (IOException e) { + throw new RuntimeException("JSON转对象失败", e); + } + } + + /** + * JSON字符串转List + * @param json JSON字符串 + * @param elementClass 列表元素类型 + * @param 泛型类型 + * @return List对象 + */ + public static List fromJsonToList(String json, Class elementClass) { + try { + TypeFactory typeFactory = objectMapper.getTypeFactory(); + CollectionType listType = typeFactory.constructCollectionType(List.class, elementClass); + return objectMapper.readValue(json, listType); + } catch (IOException e) { + throw new RuntimeException("JSON转List失败", e); + } + } + + /** + * JSON字符串转Map + * @param json JSON字符串 + * @return Map对象 + */ + public static Map fromJsonToMap(String json) { + try { + return objectMapper.readValue(json, new TypeReference>() {}); + } catch (IOException e) { + throw new RuntimeException("JSON转Map失败", e); + } + } + + /** + * 获取JSON节点 + * @param json JSON字符串 + * @return JsonNode对象 + */ + public static JsonNode getJsonNode(String json) { + try { + return objectMapper.readTree(json); + } catch (IOException e) { + throw new RuntimeException("解析JSON失败", e); + } + } + + /** + * 从JSON中获取字符串值 + * @param json JSON字符串 + * @param path 路径（支持嵌套，如："user.name"） + * @return 字符串值 + */ + public static String getString(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isNull() ? node.asText() : null; + } + + /** + * 从JSON中获取整数值 + * @param json JSON字符串 + * @param path 路径 + * @return 整数值 + */ + public static Integer getInt(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isNull() ? node.asInt() : null; + } + + /** + * 从JSON中获取长整数值 + * @param json JSON字符串 + * @param path 路径 + * @return 长整数值 + */ + public static Long getLong(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isNull() ? node.asLong() : null; + } + + /** + * 从JSON中获取双精度浮点数值 + * @param json JSON字符串 + * @param path 路径 + * @return 双精度浮点数值 + */ + public static Double getDouble(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isNull() ? node.asDouble() : null; + } + + /** + * 从JSON中获取布尔值 + * @param json JSON字符串 + * @param path 路径 + * @return 布尔值 + */ + public static Boolean getBoolean(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isNull() ? node.asBoolean() : null; + } + + /** + * 从JSON中获取对象 + * @param json JSON字符串 + * @param path 路径 + * @param clazz 目标类型 + * @param 泛型类型 + * @return 对象 + */ + public static T getObject(String json, String path, Class clazz) { + JsonNode node = getValueByPath(json, path); + if (node != null && !node.isNull()) { + try { + return objectMapper.treeToValue(node, clazz); + } catch (JsonProcessingException e) { + throw new RuntimeException("JSON节点转对象失败", e); + } + } + return null; + } + + /** + * 从JSON中获取数组 + * @param json JSON字符串 + * @param path 路径 + * @param elementClass 数组元素类型 + * @param 泛型类型 + * @return List对象 + */ + public static List getArray(String json, String path, Class elementClass) { + JsonNode node = getValueByPath(json, path); + if (node != null && node.isArray()) { + try { + TypeFactory typeFactory = objectMapper.getTypeFactory(); + CollectionType listType = typeFactory.constructCollectionType(List.class, elementClass); + return objectMapper.treeToValue(node, listType); + } catch (JsonProcessingException e) { + throw new RuntimeException("JSON节点转数组失败", e); + } + } + return null; + } + + /** + * 检查JSON中是否存在指定路径 + * @param json JSON字符串 + * @param path 路径 + * @return 是否存在 + */ + public static boolean hasPath(String json, String path) { + JsonNode node = getValueByPath(json, path); + return node != null && !node.isMissingNode(); + } + + /** + * 根据路径获取JSON节点值 + * @param json JSON字符串 + * @param path 路径（支持嵌套，如："user.name"或"users[0].name"） + * @return JsonNode对象 + */ + private static JsonNode getValueByPath(String json, String path) { + try { + JsonNode rootNode = objectMapper.readTree(json); + String[] pathParts = path.split("\\."); + JsonNode currentNode = rootNode; + + for (String part : pathParts) { + if (currentNode == null || currentNode.isMissingNode()) { + return null; + } + + // 处理数组索引，如：users[0] + if (part.contains("[") && part.contains("]")) { + String fieldName = part.substring(0, part.indexOf("[")); + String indexStr = part.substring(part.indexOf("[") + 1, part.indexOf("]")); + int index = Integer.parseInt(indexStr); + + currentNode = currentNode.get(fieldName); + if (currentNode != null && currentNode.isArray() && index < currentNode.size()) { + currentNode = currentNode.get(index); + } else { + return null; + } + } else { + currentNode = currentNode.get(part); + } + } + + return currentNode; + } catch (Exception e) { + throw new RuntimeException("获取JSON路径值失败", e); + } + } + + /** + * 美化JSON字符串（格式化输出） + * @param json JSON字符串 + * @return 格式化后的JSON字符串 + */ + public static String prettyPrint(String json) { + try { + JsonNode node = objectMapper.readTree(json); + return objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(node); + } catch (IOException e) { + throw new RuntimeException("JSON格式化失败", e); + } + } + + /** + * 获取ObjectMapper实例（用于高级用法） + * @return ObjectMapper实例 + */ + public static ObjectMapper getObjectMapper() { + return objectMapper; + } +} \ No newline at end of file From 563d83f8490b178983f1b07ae15585543f23667e Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Sun, 27 Jul 2025 08:59:08 +0800 Subject: [PATCH 2/5] jackson --- pom.xml | 7 - .../aspectj/RequestParameterAspectj.java | 6 +- .../extern/LyCompatibleController.java | 6 +- .../basic/controller/viid/ViidController.java | 4 +- .../checker/helper/CommonDeviceChecker.java | 4 +- .../operator/AliOssStorageOperator.java | 4 +- .../operator/VptPassiveStorageOperator.java | 9 +- .../operator/WvpActiveStorageOperator.java | 50 ++-- .../operator/WvpPassiveStorageOperator.java | 9 +- .../pc/device/entity/DeviceConfigEntity.java | 7 +- .../faceDetectLog/entity/FaceDetectLog.java | 10 +- .../notify/adapters/WxMpSrvNotifyAdapter.java | 11 +- .../basic/pay/adapter/CongMingPayAdapter.java | 51 ++-- .../entity/ProfitSharingUser.java | 6 +- .../repository/ProfitSharingRepository.java | 6 +- .../basic/repository/DeviceRepository.java | 24 +- .../ycwl/basic/repository/FaceRepository.java | 6 +- .../basic/repository/OrderRepository.java | 16 +- .../basic/repository/PriceRepository.java | 10 +- .../repository/RenderWorkerRepository.java | 18 +- .../basic/repository/ScenicRepository.java | 18 +- .../basic/repository/TemplateRepository.java | 15 +- .../basic/repository/VideoRepository.java | 14 +- .../basic/repository/VideoTaskRepository.java | 18 +- .../mobile/impl/AppMemberServiceImpl.java | 4 +- .../mobile/impl/AppStatisticsServiceImpl.java | 13 +- .../service/mobile/impl/GoodsServiceImpl.java | 12 +- .../service/pc/impl/OrderServiceImpl.java | 5 +- .../service/pc/impl/ScenicServiceImpl.java | 12 +- .../task/impl/TaskFaceServiceImpl.java | 9 +- .../task/impl/TaskTaskServiceImpl.java | 28 ++- .../ycwl/basic/task/DynamicTaskGenerator.java | 4 +- .../java/com/ycwl/basic/task/N9eSyncTask.java | 36 +-- .../com/ycwl/basic/utils/JacksonUtil.java | 234 ++++++++++++++++++ .../java/com/ycwl/basic/utils/WxMpUtil.java | 51 ++-- 35 files changed, 482 insertions(+), 255 deletions(-) diff --git a/pom.xml b/pom.xml index c68ebd1..7dd39ed 100644 --- a/pom.xml +++ b/pom.xml @@ -20,7 +20,6 @@ 21 21 5.8.24 - 1.2.83 2.0.7 5.3.1 @@ -122,12 +121,6 @@ core 3.3.3 - - - com.alibaba - fastjson - ${fastjson.version} - diff --git a/src/main/java/com/ycwl/basic/aspectj/RequestParameterAspectj.java b/src/main/java/com/ycwl/basic/aspectj/RequestParameterAspectj.java index 1da21f2..a00b864 100644 --- a/src/main/java/com/ycwl/basic/aspectj/RequestParameterAspectj.java +++ b/src/main/java/com/ycwl/basic/aspectj/RequestParameterAspectj.java @@ -1,6 +1,6 @@ package com.ycwl.basic.aspectj; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.annotation.IgnoreLogReq; import org.aspectj.lang.ProceedingJoinPoint; import org.aspectj.lang.annotation.Around; @@ -67,10 +67,10 @@ public class RequestParameterAspectj { } if (parameterUrlMap.isEmpty()) { - LOGGER.info("当前请求的路径为-> {} 请求方式为-> {} 参数为-> {}", requestURI, method, JSON.toJSONString(parameterValueSet)); + LOGGER.info("当前请求的路径为-> {} 请求方式为-> {} 参数为-> {}", requestURI, method, JacksonUtil.toJSONString(parameterValueSet)); } else { LOGGER.info("当前请求的路径为-> {} 请求方式为-> {} 参数为-> {} 路径传参为-> {}", requestURI, method, - JSON.toJSONString(parameterValueSet), JSON.toJSONString(parameterUrlMap)); + JacksonUtil.toJSONString(parameterValueSet), JacksonUtil.toJSONString(parameterUrlMap)); } } return joinPoint.proceed(); diff --git a/src/main/java/com/ycwl/basic/controller/extern/LyCompatibleController.java b/src/main/java/com/ycwl/basic/controller/extern/LyCompatibleController.java index 1ffb44b..6b4f6b3 100644 --- a/src/main/java/com/ycwl/basic/controller/extern/LyCompatibleController.java +++ b/src/main/java/com/ycwl/basic/controller/extern/LyCompatibleController.java @@ -1,7 +1,7 @@ package com.ycwl.basic.controller.extern; import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.annotation.IgnoreToken; import com.ycwl.basic.mapper.FaceMapper; import com.ycwl.basic.mapper.MemberMapper; @@ -184,7 +184,7 @@ public class LyCompatibleController { } String openId = headersMap.get("client"); if (redisTemplate.hasKey("ly:"+openId)) { - return JSON.parseObject(redisTemplate.opsForValue().get("ly:"+openId), R.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get("ly:"+openId), R.class); } MemberRespVO member = memberMapper.getByOpenId(openId); if (member == null) { @@ -248,7 +248,7 @@ public class LyCompatibleController { .put("face_id", faceVO.getId().toString()) .put("newvideo", videoList) .put("newuservideo", userVideoList); - redisTemplate.opsForValue().set("ly:"+openId, JSON.toJSONString(response), 5, TimeUnit.SECONDS); + redisTemplate.opsForValue().set("ly:"+openId, JacksonUtil.toJSONString(response), 5, TimeUnit.SECONDS); log.info("> {}", response); return response; } diff --git a/src/main/java/com/ycwl/basic/controller/viid/ViidController.java b/src/main/java/com/ycwl/basic/controller/viid/ViidController.java index b05698c..9bda39d 100644 --- a/src/main/java/com/ycwl/basic/controller/viid/ViidController.java +++ b/src/main/java/com/ycwl/basic/controller/viid/ViidController.java @@ -3,7 +3,7 @@ package com.ycwl.basic.controller.viid; import cn.hutool.core.collection.CollUtil; import cn.hutool.core.thread.ThreadFactoryBuilder; import cn.hutool.core.util.ObjectUtil; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.annotation.IgnoreLogReq; import com.ycwl.basic.annotation.IgnoreToken; import com.ycwl.basic.facebody.adapter.IFaceBodyAdapter; @@ -377,7 +377,7 @@ public class ViidController { String _sourceUrl = scenicStorageAdapter.uploadFile(_finalFile, filename); scenicStorageAdapter.setAcl(StorageAcl.PUBLIC_READ, filename); source.setUrl(_sourceUrl); - source.setPosJson(JSON.toJSONString(facePosition)); + source.setPosJson(JacksonUtil.toJSONString(facePosition)); sourceMapper.add(source); } }); diff --git a/src/main/java/com/ycwl/basic/device/checker/helper/CommonDeviceChecker.java b/src/main/java/com/ycwl/basic/device/checker/helper/CommonDeviceChecker.java index b1a5658..54184a1 100644 --- a/src/main/java/com/ycwl/basic/device/checker/helper/CommonDeviceChecker.java +++ b/src/main/java/com/ycwl/basic/device/checker/helper/CommonDeviceChecker.java @@ -1,6 +1,6 @@ package com.ycwl.basic.device.checker.helper; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.model.pc.device.entity.DeviceConfigEntity; import com.ycwl.basic.model.pc.device.entity.DeviceEntity; import lombok.Setter; @@ -13,7 +13,7 @@ public abstract class CommonDeviceChecker { protected DeviceConfigEntity deviceConfig; public CommonDeviceChecker(String configJson) { - config = JSON.parseObject(configJson, getConfigClass()); + config = JacksonUtil.parseObject(configJson, getConfigClass()); } @SuppressWarnings("unchecked") diff --git a/src/main/java/com/ycwl/basic/device/operator/AliOssStorageOperator.java b/src/main/java/com/ycwl/basic/device/operator/AliOssStorageOperator.java index d3d71d9..f6a2f35 100644 --- a/src/main/java/com/ycwl/basic/device/operator/AliOssStorageOperator.java +++ b/src/main/java/com/ycwl/basic/device/operator/AliOssStorageOperator.java @@ -1,7 +1,7 @@ package com.ycwl.basic.device.operator; import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.device.entity.common.FileObject; import com.ycwl.basic.storage.StorageFactory; import com.ycwl.basic.storage.adapters.IStorageAdapter; @@ -28,7 +28,7 @@ public class AliOssStorageOperator extends ADeviceStorageOperator { @Override public void loadConfig(String configJson) { - AliOssStorageConfig config = JSON.parseObject(configJson, AliOssStorageConfig.class); + AliOssStorageConfig config = JacksonUtil.parseObject(configJson, AliOssStorageConfig.class); adapter = StorageFactory.get(StorageType.ALI_OSS, config); } diff --git a/src/main/java/com/ycwl/basic/device/operator/VptPassiveStorageOperator.java b/src/main/java/com/ycwl/basic/device/operator/VptPassiveStorageOperator.java index af69c23..83bb864 100644 --- a/src/main/java/com/ycwl/basic/device/operator/VptPassiveStorageOperator.java +++ b/src/main/java/com/ycwl/basic/device/operator/VptPassiveStorageOperator.java @@ -1,7 +1,6 @@ package com.ycwl.basic.device.operator; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.annotation.JSONField; +import com.ycwl.basic.utils.JacksonUtil; import com.fasterxml.jackson.annotation.JsonFormat; import com.ycwl.basic.device.entity.common.FileObject; import com.ycwl.basic.device.entity.vpt_passive.VptPassiveStorageConfig; @@ -29,10 +28,8 @@ public class VptPassiveStorageOperator extends ADeviceStorageOperator { public Long scenicId; public Long deviceId; public String deviceNo; - @JSONField(format = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date startTime; - @JSONField(format = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date endTime; } @@ -75,7 +72,7 @@ public class VptPassiveStorageOperator extends ADeviceStorageOperator { @Override public void loadConfig(String configJson) { - this.config = JSON.parseObject(configJson, VptPassiveStorageConfig.class); + this.config = JacksonUtil.parseObject(configJson, VptPassiveStorageConfig.class); } @Override @@ -94,7 +91,7 @@ public class VptPassiveStorageOperator extends ADeviceStorageOperator { if (redisTemplate == null) { taskList.add(task); } else { - redisTemplate.opsForValue().set(String.format(TASK_KEY, task.scenicId, task.deviceNo) + task.taskId, JSON.toJSONString(task), 10 * 60L, TimeUnit.SECONDS); + redisTemplate.opsForValue().set(String.format(TASK_KEY, task.scenicId, task.deviceNo) + task.taskId, JacksonUtil.toJSONString(task), 10 * 60L, TimeUnit.SECONDS); } log.info("任务{}获取视频开始！共{}", task.taskId, taskList.size()); Date taskStartTime = new Date(); diff --git a/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java b/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java index 1d86205..88b189e 100644 --- a/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java +++ b/src/main/java/com/ycwl/basic/device/operator/WvpActiveStorageOperator.java @@ -3,8 +3,8 @@ package com.ycwl.basic.device.operator; import cn.hutool.crypto.digest.MD5; import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; +import com.fasterxml.jackson.core.type.TypeReference; import com.ycwl.basic.device.entity.common.FileObject; import com.ycwl.basic.device.entity.wvp_active.WvpActiveStorageConfig; import com.ycwl.basic.storage.exceptions.StorageConfigException; @@ -30,7 +30,7 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator { @Override public void loadConfig(String configJson) { - this.config = JSON.parseObject(configJson, WvpActiveStorageConfig.class); + this.config = JacksonUtil.parseObject(configJson, WvpActiveStorageConfig.class); } @Override @@ -55,13 +55,14 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator { String password = MD5.create().digestHex(this.config.getLoginPassword()); params.put("password", password); String jsonResult = HttpUtil.get(url, params); - JSONObject result = JSON.parseObject(jsonResult); - if (result.getInteger("code") == 0) { - JSONObject data = result.getJSONObject("data"); - this.token = data.getString("accessToken"); + Map result = JacksonUtil.parseObject(jsonResult, Map.class); + Integer code = (Integer) result.get("code"); + if (code != null && code == 0) { + Map data = (Map) result.get("data"); + this.token = (String) data.get("accessToken"); return this.token; } else { - throw new StorageConfigException("获取token失败，原因为：" + result.getString("msg")); + throw new StorageConfigException("获取token失败，原因为：" + result.get("msg")); } } public List listDirByDtRange(Date startDate, Date endDate) { @@ -75,19 +76,23 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator { params.put("page", 1); params.put("count", 100); String jsonResult = HttpRequest.get(url).form(params).header("Access-Token", getToken()).execute().body(); - JSONObject result = JSON.parseObject(jsonResult); - if (result.getInteger("code") == 0) { - JSONObject data = result.getJSONObject("data"); - List recordList = data.getJSONArray("list").toJavaList(JSONObject.class); + Map result = JacksonUtil.parseObject(jsonResult, Map.class); + Integer code = (Integer) result.get("code"); + if (code != null && code == 0) { + Map data = (Map) result.get("data"); + List> recordList = JacksonUtil.parseObject(JacksonUtil.toJSONString(((Map) result.get("data")).get("list")), new TypeReference>>() {}); return recordList.stream() .map(record -> { FileObject object = new FileObject(); - object.setName(record.getString("id")); - object.setPath(record.getString("folder")); - object.setUrl(getUrlForDownload(record.getInteger("id"))); + object.setName((String) record.get("id")); + object.setPath((String) record.get("folder")); + Integer recordId = (Integer) record.get("id"); + object.setUrl(getUrlForDownload(recordId != null ? recordId : 0)); object.setNeedDownload(true); - object.setCreateTime(new Date(record.getLongValue("startTime"))); - object.setEndTime(new Date(record.getLongValue("endTime"))); + Number startTime = (Number) record.get("startTime"); + Number endTime = (Number) record.get("endTime"); + object.setCreateTime(new Date(startTime != null ? startTime.longValue() : 0)); + object.setEndTime(new Date(endTime != null ? endTime.longValue() : 0)); return object; }) .sorted(Comparator.comparing(FileObject::getCreateTime)) @@ -100,10 +105,11 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator { // assume path is recordId String url = this.config.getHost() + "/api/cloud/record/play/path?recordId=" + id; String jsonResult = HttpRequest.get(url).header("Access-Token", getToken()).execute().body(); - JSONObject result = JSON.parseObject(jsonResult); - if (result.getInteger("code") == 0) { - JSONObject data = result.getJSONObject("data"); - String httpPath = data.getString("httpPath"); + Map result = JacksonUtil.parseObject(jsonResult, Map.class); + Integer code = (Integer) result.get("code"); + if (code != null && code == 0) { + Map data = (Map) result.get("data"); + String httpPath = (String) data.get("httpPath"); if (StringUtils.isBlank(this.config.getZlmHost())) { return httpPath; } @@ -114,7 +120,7 @@ public class WvpActiveStorageOperator extends ADeviceStorageOperator { } return this.config.getZlmHost() + uri.getPath() + "?" + uri.getQuery(); } else { - throw new StorageUnsupportedException("获取播放地址失败，原因为：" + result.getString("msg")); + throw new StorageUnsupportedException("获取播放地址失败，原因为：" + result.get("msg")); } } diff --git a/src/main/java/com/ycwl/basic/device/operator/WvpPassiveStorageOperator.java b/src/main/java/com/ycwl/basic/device/operator/WvpPassiveStorageOperator.java index 11acdbc..cd3ad21 100644 --- a/src/main/java/com/ycwl/basic/device/operator/WvpPassiveStorageOperator.java +++ b/src/main/java/com/ycwl/basic/device/operator/WvpPassiveStorageOperator.java @@ -1,7 +1,6 @@ package com.ycwl.basic.device.operator; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.annotation.JSONField; +import com.ycwl.basic.utils.JacksonUtil; import com.fasterxml.jackson.annotation.JsonFormat; import com.ycwl.basic.device.entity.common.FileObject; import com.ycwl.basic.device.entity.wvp_passive.WvpPassiveStorageConfig; @@ -28,10 +27,8 @@ public class WvpPassiveStorageOperator extends ADeviceStorageOperator { public Long scenicId; public Long deviceId; public String deviceNo; - @JSONField(format = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date startTime; - @JSONField(format = "yyyy-MM-dd HH:mm:ss") @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss") public Date endTime; } @@ -72,7 +69,7 @@ public class WvpPassiveStorageOperator extends ADeviceStorageOperator { @Override public void loadConfig(String configJson) { - this.config = JSON.parseObject(configJson, WvpPassiveStorageConfig.class); + this.config = JacksonUtil.parseObject(configJson, WvpPassiveStorageConfig.class); } @Override @@ -91,7 +88,7 @@ public class WvpPassiveStorageOperator extends ADeviceStorageOperator { if (redisTemplate == null) { taskList.add(task); } else { - redisTemplate.opsForValue().set(String.format(TASK_KEY, task.scenicId, task.deviceNo) + task.taskId, JSON.toJSONString(task), 10 * 60L, TimeUnit.SECONDS); + redisTemplate.opsForValue().set(String.format(TASK_KEY, task.scenicId, task.deviceNo) + task.taskId, JacksonUtil.toJSONString(task), 10 * 60L, TimeUnit.SECONDS); } Date taskStartTime = new Date(); while (true) { diff --git a/src/main/java/com/ycwl/basic/model/pc/device/entity/DeviceConfigEntity.java b/src/main/java/com/ycwl/basic/model/pc/device/entity/DeviceConfigEntity.java index bd6b623..86578cd 100644 --- a/src/main/java/com/ycwl/basic/model/pc/device/entity/DeviceConfigEntity.java +++ b/src/main/java/com/ycwl/basic/model/pc/device/entity/DeviceConfigEntity.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.pc.device.entity; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; +import com.fasterxml.jackson.core.type.TypeReference; import com.baomidou.mybatisplus.annotation.TableName; import com.fasterxml.jackson.annotation.JsonFormat; import lombok.Data; @@ -73,10 +74,10 @@ public class DeviceConfigEntity { return Collections.singletonList(new DeviceCropConfig()); } if (StringUtils.startsWith(cropConfig, "{")) { - return Collections.singletonList(JSON.parseObject(cropConfig, DeviceCropConfig.class)); + return Collections.singletonList(JacksonUtil.parseObject(cropConfig, DeviceCropConfig.class)); } if (StringUtils.startsWith(cropConfig, "[")) { - return JSON.parseArray(cropConfig, DeviceCropConfig.class); + return JacksonUtil.parseObject(cropConfig, new TypeReference>() {}); } return Collections.singletonList(new DeviceCropConfig()); } diff --git a/src/main/java/com/ycwl/basic/model/pc/faceDetectLog/entity/FaceDetectLog.java b/src/main/java/com/ycwl/basic/model/pc/faceDetectLog/entity/FaceDetectLog.java index 24127d0..a53d509 100644 --- a/src/main/java/com/ycwl/basic/model/pc/faceDetectLog/entity/FaceDetectLog.java +++ b/src/main/java/com/ycwl/basic/model/pc/faceDetectLog/entity/FaceDetectLog.java @@ -1,7 +1,7 @@ package com.ycwl.basic.model.pc.faceDetectLog.entity; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; +import com.fasterxml.jackson.core.type.TypeReference; import com.aliyuncs.facebody.model.v20191230.SearchFaceRequest; import com.aliyuncs.facebody.model.v20191230.SearchFaceResponse; import com.baomidou.mybatisplus.annotation.IdType; @@ -54,7 +54,7 @@ public class FaceDetectLog { } public FaceDetectLog fillResponse(Object response) { - this.matchRawResult = JSONObject.toJSONString(response); + this.matchRawResult = JacksonUtil.toJSONString(response); return this; } @@ -62,14 +62,14 @@ public class FaceDetectLog { if (matchLocalRecord == null) { return null; } - return JSONArray.parseArray(matchLocalRecord, MatchLocalRecord.class); + return JacksonUtil.parseObject(matchLocalRecord, new TypeReference>() {}); } public void matchLocalRecord(List matchLocalRecord) { if (matchLocalRecord == null) { this.matchLocalRecord = null; } else { - this.matchLocalRecord = JSONArray.toJSONString(matchLocalRecord); + this.matchLocalRecord = JacksonUtil.toJSONString(matchLocalRecord); } } diff --git a/src/main/java/com/ycwl/basic/notify/adapters/WxMpSrvNotifyAdapter.java b/src/main/java/com/ycwl/basic/notify/adapters/WxMpSrvNotifyAdapter.java index 89a2494..c89a383 100644 --- a/src/main/java/com/ycwl/basic/notify/adapters/WxMpSrvNotifyAdapter.java +++ b/src/main/java/com/ycwl/basic/notify/adapters/WxMpSrvNotifyAdapter.java @@ -1,7 +1,7 @@ package com.ycwl.basic.notify.adapters; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.notify.entity.NotifyContent; import com.ycwl.basic.notify.entity.WxMpSrvConfig; @@ -45,15 +45,16 @@ public class WxMpSrvNotifyAdapter implements INotifyAdapter{ } String url = String.format(ACCESS_TOKEN_URL, config.getAppId(), config.getAppSecret()); String response = HttpUtil.get(url); - JSONObject jsonObject = JSONObject.parseObject(response); - ACCESS_TOKEN = jsonObject.getString("access_token"); - expireTime = new Date(System.currentTimeMillis() + jsonObject.getInteger("expires_in") * 1000); + Map jsonObject = JacksonUtil.parseObject(response, Map.class); + ACCESS_TOKEN = (String) jsonObject.get("access_token"); + Integer expiresIn = (Integer) jsonObject.get("expires_in"); + expireTime = new Date(System.currentTimeMillis() + (expiresIn != null ? expiresIn : 7200) * 1000); return ACCESS_TOKEN; } public void sendServiceNotification(Map params) { String url = String.format(SEND_TEMPLATE_MESSAGE_URL, getAccessToken()); - String response = HttpUtil.post(url, JSONObject.toJSONString(params)); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); System.out.println(response); } } diff --git a/src/main/java/com/ycwl/basic/pay/adapter/CongMingPayAdapter.java b/src/main/java/com/ycwl/basic/pay/adapter/CongMingPayAdapter.java index cf571ae..6295268 100644 --- a/src/main/java/com/ycwl/basic/pay/adapter/CongMingPayAdapter.java +++ b/src/main/java/com/ycwl/basic/pay/adapter/CongMingPayAdapter.java @@ -2,8 +2,7 @@ package com.ycwl.basic.pay.adapter; import cn.hutool.crypto.SecureUtil; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.pay.entity.CancelOrderRequest; import com.ycwl.basic.pay.entity.CongMingPayConfig; import com.ycwl.basic.pay.entity.CreateOrderRequest; @@ -78,17 +77,17 @@ public class CongMingPayAdapter implements IPayAdapter { params.put("s_source", "mini_app"); params.put("sign", parseSign(params, config.getApiKey())); System.out.println(url); - System.out.println(JSON.toJSONString(params)); - String response = HttpUtil.post(url, JSON.toJSONString(params)); - JSONObject json = JSONObject.parseObject(response); + System.out.println(JacksonUtil.toJSONString(params)); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); + Map json = JacksonUtil.parseObject(response, Map.class); System.out.println(json); - if (StringUtils.equals(json.getString("result_code"), "fail")) { - throw new PayException("查询异常！异常提示：" + json.getString("error_msg")); + if (StringUtils.equals((String) json.get("result_code"), "fail")) { + throw new PayException("查询异常！异常提示：" + json.get("error_msg")); } resp.setSkipPay(false); resp.setSuccess(true); - resp.setOrderNo(json.getString("order_id")); - resp.setExtData(json.toJavaObject(Map.class)); + resp.setOrderNo((String) json.get("order_id")); + resp.setExtData(JacksonUtil.toJavaObject(json, Map.class)); return resp; } @@ -134,24 +133,24 @@ public class CongMingPayAdapter implements IPayAdapter { params.put("shop_id", config.getShopId()); params.put("order_id", orderNo); params.put("sign", parseSign(params, config.getApiKey())); - String response = HttpUtil.post(url, JSON.toJSONString(params)); - JSONObject json = JSONObject.parseObject(response); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); + Map json = JacksonUtil.parseObject(response, Map.class); System.out.println(json); - if (StringUtils.equals(json.getString("result_code"), "fail")) { - throw new PayException("查询异常！异常提示：" + json.getString("error_msg")); + if (StringUtils.equals((String) json.get("result_code"), "fail")) { + throw new PayException("查询异常！异常提示：" + json.get("error_msg")); } resp.setOriginalResponse(json); resp.setValid(true); - resp.setOrderPriceInYuan(json.getBigDecimal("pay_ble")); - resp.setPayPriceInYuan(json.getBigDecimal("paid_out")); - resp.setOrderNo(json.getString("order_id")); - switch (json.getString("order_status")) { + resp.setOrderPriceInYuan((BigDecimal) json.get("pay_ble")); + resp.setPayPriceInYuan((BigDecimal) json.get("paid_out")); + resp.setOrderNo((String) json.get("order_id")); + switch ((String) json.get("order_status")) { case "2": resp.setState(PayResponse.PAY_STATE.NOT_PAY); break; case "1": resp.setState(PayResponse.PAY_STATE.SUCCESS); - resp.setPayTime(json.getString("time_end")); + resp.setPayTime((String) json.get("time_end")); break; case "0": resp.setState(PayResponse.PAY_STATE.FAIL); @@ -178,11 +177,11 @@ public class CongMingPayAdapter implements IPayAdapter { params.put("money", request.getRefundPriceInYuan().toString()); params.put("refund_order_id", request.getRefundNo()); params.put("sign", parseSign(params, config.getApiKey())); - String response = HttpUtil.post(url, JSON.toJSONString(params)); - JSONObject json = JSONObject.parseObject(response); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); + Map json = JacksonUtil.parseObject(response, Map.class); System.out.println(json); - if (StringUtils.equalsIgnoreCase(json.getString("result_code"), "fail")) { - throw new PayException("退款异常！异常提示：" + json.getString("error_msg")); + if (StringUtils.equalsIgnoreCase((String) json.get("result_code"), "fail")) { + throw new PayException("退款异常！异常提示：" + json.get("error_msg")); } return resp; } @@ -219,10 +218,10 @@ public class CongMingPayAdapter implements IPayAdapter { params.put("order_id", request.getOrderNo()); params.put("error_msg", request.getReason()); params.put("sign", parseSign(params, config.getApiKey())); - String response = HttpUtil.post(url, JSON.toJSONString(params)); - JSONObject json = JSONObject.parseObject(response); - if (StringUtils.equals(json.getString("result_code"), "fail")) { - throw new PayException("取消订单异常！异常提示：" + json.getString("error_msg")); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); + Map json = JacksonUtil.parseObject(response, Map.class); + if (StringUtils.equals((String) json.get("result_code"), "fail")) { + throw new PayException("取消订单异常！异常提示：" + json.get("error_msg")); } } diff --git a/src/main/java/com/ycwl/basic/profitsharing/entity/ProfitSharingUser.java b/src/main/java/com/ycwl/basic/profitsharing/entity/ProfitSharingUser.java index 2255cf2..7a426d9 100644 --- a/src/main/java/com/ycwl/basic/profitsharing/entity/ProfitSharingUser.java +++ b/src/main/java/com/ycwl/basic/profitsharing/entity/ProfitSharingUser.java @@ -1,6 +1,6 @@ package com.ycwl.basic.profitsharing.entity; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.profitsharing.enums.ProfitSharingWxPayType; import lombok.Data; @@ -29,10 +29,10 @@ public class ProfitSharingUser { private BigDecimal realRate; public void setWxPayConfig(String wxPayConfig) { - this.wxPayConfig = JSON.parseObject(wxPayConfig, Map.class); + this.wxPayConfig = JacksonUtil.parseObject(wxPayConfig, Map.class); } public String getWxPayConfig() { - return JSON.toJSONString(wxPayConfig); + return JacksonUtil.toJSONString(wxPayConfig); } } \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/profitsharing/repository/ProfitSharingRepository.java b/src/main/java/com/ycwl/basic/profitsharing/repository/ProfitSharingRepository.java index 75b741a..8f044f6 100644 --- a/src/main/java/com/ycwl/basic/profitsharing/repository/ProfitSharingRepository.java +++ b/src/main/java/com/ycwl/basic/profitsharing/repository/ProfitSharingRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.profitsharing.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.profitsharing.entity.ProfitSharingConfig; import com.ycwl.basic.profitsharing.mapper.ProfitSharingConfigMapper; import com.ycwl.basic.profitsharing.mapper.ProfitSharingUserMapper; @@ -20,12 +20,12 @@ public class ProfitSharingRepository { public ProfitSharingConfig getScenicConfig(Long id) { if (redisTemplate.hasKey(String.format(PROFIT_SHARING_SCENIC_CONFIG_CACHE_KEY, id))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(PROFIT_SHARING_SCENIC_CONFIG_CACHE_KEY, id)), ProfitSharingConfig.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(PROFIT_SHARING_SCENIC_CONFIG_CACHE_KEY, id)), ProfitSharingConfig.class); } ProfitSharingConfig scenicConfig = configMapper.findByScenicId(id); if (scenicConfig != null) { scenicConfig.setUsers(userMapper.findByConfigId(scenicConfig.getId())); - redisTemplate.opsForValue().set(String.format(PROFIT_SHARING_SCENIC_CONFIG_CACHE_KEY, id), JSONObject.toJSONString(scenicConfig)); + redisTemplate.opsForValue().set(String.format(PROFIT_SHARING_SCENIC_CONFIG_CACHE_KEY, id), JacksonUtil.toJSONString(scenicConfig)); } return scenicConfig; } diff --git a/src/main/java/com/ycwl/basic/repository/DeviceRepository.java b/src/main/java/com/ycwl/basic/repository/DeviceRepository.java index 4872ca0..210af67 100644 --- a/src/main/java/com/ycwl/basic/repository/DeviceRepository.java +++ b/src/main/java/com/ycwl/basic/repository/DeviceRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.DeviceMapper; import com.ycwl.basic.model.pc.device.entity.DeviceConfigEntity; import com.ycwl.basic.model.pc.device.entity.DeviceEntity; @@ -27,26 +27,26 @@ public class DeviceRepository { public DeviceEntity getDevice(Long deviceId) { if (redisTemplate.hasKey(String.format(DEVICE_CACHE_KEY, deviceId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CACHE_KEY, deviceId)), DeviceEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CACHE_KEY, deviceId)), DeviceEntity.class); } DeviceEntity device = deviceMapper.getByDeviceId(deviceId); if (null != device) { - redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceId), JSONObject.toJSONString(device), 3, TimeUnit.DAYS); + redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceId), JacksonUtil.toJSONString(device), 3, TimeUnit.DAYS); } return device; } public DeviceEntity getDeviceByDeviceNo(String deviceNo) { if (redisTemplate.hasKey(String.format(DEVICE_CACHE_KEY, deviceNo))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CACHE_KEY, deviceNo)), DeviceEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CACHE_KEY, deviceNo)), DeviceEntity.class); } DeviceEntity device = deviceMapper.getByDeviceNo(deviceNo); if (null == device) { device = deviceMapper.getByDeviceNo2(deviceNo); } if (null != device) { - redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), JSONObject.toJSONString(device), 3, TimeUnit.DAYS); - redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getId()), JSONObject.toJSONString(device), 3, TimeUnit.DAYS); + redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), JacksonUtil.toJSONString(device), 3, TimeUnit.DAYS); + redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getId()), JacksonUtil.toJSONString(device), 3, TimeUnit.DAYS); } else { redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, deviceNo), "null", 60L, TimeUnit.SECONDS); } @@ -55,7 +55,7 @@ public class DeviceRepository { public DeviceConfigEntity getDeviceConfig(Long deviceId) { if (redisTemplate.hasKey(String.format(DEVICE_CONFIG_CACHE_KEY, deviceId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CONFIG_CACHE_KEY, deviceId)), DeviceConfigEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_CONFIG_CACHE_KEY, deviceId)), DeviceConfigEntity.class); } DeviceConfigEntity deviceConfig = deviceMapper.getConfigByDeviceId(deviceId); if (null == deviceConfig) { @@ -64,7 +64,7 @@ public class DeviceRepository { deviceConfig.setDeviceId(deviceId); deviceMapper.addConfig(deviceConfig); } - redisTemplate.opsForValue().set(String.format(DEVICE_CONFIG_CACHE_KEY, deviceId), JSONObject.toJSONString(deviceConfig), 3, TimeUnit.DAYS); + redisTemplate.opsForValue().set(String.format(DEVICE_CONFIG_CACHE_KEY, deviceId), JacksonUtil.toJSONString(deviceConfig), 3, TimeUnit.DAYS); return deviceConfig; } @@ -111,22 +111,22 @@ public class DeviceRepository { device.setOnline(online); device.setKeepaliveAt(keepaliveAt); device.setIpAddr(ipAddr); - redisTemplate.opsForValue().set(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId), JSONObject.toJSONString(device), 3, TimeUnit.DAYS); + redisTemplate.opsForValue().set(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId), JacksonUtil.toJSONString(device), 3, TimeUnit.DAYS); // deviceMapper.updateOnlineStatus(deviceId, ipAddr, online, keepaliveAt); updateDeviceCache(device); } public DeviceEntity getOnlineStatus(Long deviceId) { if (redisTemplate.hasKey(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId)), DeviceEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(DEVICE_ONLINE_CACHE_KEY, deviceId)), DeviceEntity.class); } else { return null; } } private void updateDeviceCache(DeviceEntity device) { - redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getId()), JSONObject.toJSONString(device)); - redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getNo()), JSONObject.toJSONString(device)); + redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getId()), JacksonUtil.toJSONString(device)); + redisTemplate.opsForValue().set(String.format(DEVICE_CACHE_KEY, device.getNo()), JacksonUtil.toJSONString(device)); } public List getAllDeviceByScenicId(Long scenicId) { diff --git a/src/main/java/com/ycwl/basic/repository/FaceRepository.java b/src/main/java/com/ycwl/basic/repository/FaceRepository.java index ab7485b..19b8d8a 100644 --- a/src/main/java/com/ycwl/basic/repository/FaceRepository.java +++ b/src/main/java/com/ycwl/basic/repository/FaceRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.FaceMapper; import com.ycwl.basic.mapper.FaceSampleMapper; import com.ycwl.basic.model.pc.face.entity.FaceEntity; @@ -30,11 +30,11 @@ public class FaceRepository { public FaceEntity getFace(Long id) { if (redisTemplate.hasKey(String.format(FACE_CACHE_KEY, id))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(FACE_CACHE_KEY, id)), FaceEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(FACE_CACHE_KEY, id)), FaceEntity.class); } FaceEntity face = faceMapper.get(id); if (face != null) { - redisTemplate.opsForValue().set(String.format(FACE_CACHE_KEY, id), JSONObject.toJSONString(face), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(FACE_CACHE_KEY, id), JacksonUtil.toJSONString(face), 12, TimeUnit.HOURS); } return face; } diff --git a/src/main/java/com/ycwl/basic/repository/OrderRepository.java b/src/main/java/com/ycwl/basic/repository/OrderRepository.java index fb13797..f38c5bb 100644 --- a/src/main/java/com/ycwl/basic/repository/OrderRepository.java +++ b/src/main/java/com/ycwl/basic/repository/OrderRepository.java @@ -1,7 +1,7 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; +import com.ycwl.basic.utils.JacksonUtil; +import com.fasterxml.jackson.core.type.TypeReference; import com.ycwl.basic.mapper.OrderMapper; import com.ycwl.basic.model.pc.order.entity.OrderEntity; import com.ycwl.basic.model.pc.order.entity.OrderItemEntity; @@ -27,25 +27,25 @@ public class OrderRepository { public OrderEntity getOrder(Long orderId) { if (redisTemplate.hasKey(String.format(ORDER_CACHE_KEY, orderId))) { - return JSON.parseObject(redisTemplate.opsForValue().get(String.format(ORDER_CACHE_KEY, orderId)), OrderEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(ORDER_CACHE_KEY, orderId)), OrderEntity.class); } OrderEntity orderEntity = orderMapper.get(orderId); if (orderEntity != null) { - redisTemplate.opsForValue().set(String.format(ORDER_CACHE_KEY, orderId), JSON.toJSONString(orderEntity), 60, TimeUnit.SECONDS); + redisTemplate.opsForValue().set(String.format(ORDER_CACHE_KEY, orderId), JacksonUtil.toJSONString(orderEntity), 60, TimeUnit.SECONDS); } return orderEntity; } public List getOrderItems(Long orderId) { if (redisTemplate.hasKey(String.format(ORDER_ITEMS_CACHE_KEY, orderId))) { - return JSON.parseArray(redisTemplate.opsForValue().get(String.format(ORDER_ITEMS_CACHE_KEY, orderId)), Long.class) + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(ORDER_ITEMS_CACHE_KEY, orderId)), new TypeReference>() {}) .stream().map(this::getOrderItemByOrderItemId).collect(Collectors.toList()); } List orderItemEntities = orderMapper.listOrderItemByOrderId(orderId); if (orderItemEntities != null) { redisTemplate.opsForValue().set( String.format(ORDER_ITEMS_CACHE_KEY, orderId), - JSONArray.toJSONString(orderItemEntities.stream().map(OrderItemEntity::getId).collect(Collectors.toList())) + JacksonUtil.toJSONString(orderItemEntities.stream().map(OrderItemEntity::getId).collect(Collectors.toList())) ); } return orderItemEntities; @@ -53,11 +53,11 @@ public class OrderRepository { public OrderItemEntity getOrderItemByOrderItemId(Long orderItemId) { if (redisTemplate.hasKey(String.format(ORDER_ITEM_CACHE_KEY, orderItemId))) { - return JSON.parseObject(redisTemplate.opsForValue().get(String.format(ORDER_ITEM_CACHE_KEY, orderItemId)), OrderItemEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(ORDER_ITEM_CACHE_KEY, orderItemId)), OrderItemEntity.class); } OrderItemEntity orderItemEntity = orderMapper.getOrderItem(orderItemId); if (orderItemEntity != null) { - redisTemplate.opsForValue().set(String.format(ORDER_ITEM_CACHE_KEY, orderItemId), JSON.toJSONString(orderItemEntity)); + redisTemplate.opsForValue().set(String.format(ORDER_ITEM_CACHE_KEY, orderItemId), JacksonUtil.toJSONString(orderItemEntity)); } return orderItemEntity; } diff --git a/src/main/java/com/ycwl/basic/repository/PriceRepository.java b/src/main/java/com/ycwl/basic/repository/PriceRepository.java index 91a5792..441081b 100644 --- a/src/main/java/com/ycwl/basic/repository/PriceRepository.java +++ b/src/main/java/com/ycwl/basic/repository/PriceRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.PriceConfigMapper; import com.ycwl.basic.model.pc.price.entity.PriceConfigEntity; import org.springframework.beans.factory.annotation.Autowired; @@ -23,13 +23,13 @@ public class PriceRepository { String cacheKey = String.format(PRICE_SCENIC_TYPE_GOODS_CACHE, scenicId, type, goodsId); PriceConfigEntity priceConfigEntity = null; if (redisTemplate.hasKey(cacheKey)) { - priceConfigEntity = JSON.parseObject(redisTemplate.opsForValue().get(cacheKey), PriceConfigEntity.class); + priceConfigEntity = JacksonUtil.parseObject(redisTemplate.opsForValue().get(cacheKey), PriceConfigEntity.class); } if (priceConfigEntity == null) { priceConfigEntity = mapper.getPriceByScenicTypeGoods(scenicId, type, goodsId); if (priceConfigEntity != null) { - redisTemplate.opsForValue().set(cacheKey, JSON.toJSONString(priceConfigEntity), 12, TimeUnit.HOURS); - redisTemplate.opsForValue().set(String.format(PRICE_ID_CACHE, priceConfigEntity.getId()), JSON.toJSONString(priceConfigEntity), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(cacheKey, JacksonUtil.toJSONString(priceConfigEntity), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(PRICE_ID_CACHE, priceConfigEntity.getId()), JacksonUtil.toJSONString(priceConfigEntity), 12, TimeUnit.HOURS); } } return priceConfigEntity; @@ -39,7 +39,7 @@ public class PriceRepository { String cacheKey = String.format(PRICE_ID_CACHE, id); PriceConfigEntity priceConfigEntity = null; if (redisTemplate.hasKey(cacheKey)) { - priceConfigEntity = JSON.parseObject(redisTemplate.opsForValue().get(cacheKey), PriceConfigEntity.class); + priceConfigEntity = JacksonUtil.parseObject(redisTemplate.opsForValue().get(cacheKey), PriceConfigEntity.class); } return priceConfigEntity; } diff --git a/src/main/java/com/ycwl/basic/repository/RenderWorkerRepository.java b/src/main/java/com/ycwl/basic/repository/RenderWorkerRepository.java index 88099af..f58dff5 100644 --- a/src/main/java/com/ycwl/basic/repository/RenderWorkerRepository.java +++ b/src/main/java/com/ycwl/basic/repository/RenderWorkerRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.RenderWorkerMapper; import com.ycwl.basic.model.pc.renderWorker.entity.RenderWorkerEntity; import com.ycwl.basic.model.task.req.ClientStatusReqVo; @@ -25,12 +25,12 @@ public class RenderWorkerRepository { public RenderWorkerEntity getWorkerByAccessKey(String accessKey) { String key = String.format(RENDER_WORKER_CACHE_KEY, accessKey); if (redisTemplate.hasKey(key)) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(key), RenderWorkerEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(key), RenderWorkerEntity.class); } RenderWorkerEntity renderWorker = mapper.findByAccessKey(accessKey); if (renderWorker != null) { - redisTemplate.opsForValue().set(key, JSONObject.toJSONString(renderWorker), 1, TimeUnit.HOURS); - redisTemplate.opsForValue().set(String.format(RENDER_WORKER_CACHE_KEY, renderWorker.getId()), JSONObject.toJSONString(renderWorker), 1, TimeUnit.HOURS); + redisTemplate.opsForValue().set(key, JacksonUtil.toJSONString(renderWorker), 1, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(RENDER_WORKER_CACHE_KEY, renderWorker.getId()), JacksonUtil.toJSONString(renderWorker), 1, TimeUnit.HOURS); } return renderWorker; } @@ -38,12 +38,12 @@ public class RenderWorkerRepository { public RenderWorkerEntity getWorker(Long id) { String key = String.format(RENDER_WORKER_CACHE_KEY, id); if (redisTemplate.hasKey(key)) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(key), RenderWorkerEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(key), RenderWorkerEntity.class); } RenderWorkerEntity renderWorker = mapper.getById(id); if (renderWorker != null) { - redisTemplate.opsForValue().set(key, JSONObject.toJSONString(renderWorker), 1, TimeUnit.HOURS); - redisTemplate.opsForValue().set(String.format(RENDER_WORKER_CACHE_KEY, renderWorker.getAccessKey()), JSONObject.toJSONString(renderWorker), 1, TimeUnit.HOURS); + redisTemplate.opsForValue().set(key, JacksonUtil.toJSONString(renderWorker), 1, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(RENDER_WORKER_CACHE_KEY, renderWorker.getAccessKey()), JacksonUtil.toJSONString(renderWorker), 1, TimeUnit.HOURS); } return renderWorker; } @@ -69,14 +69,14 @@ public class RenderWorkerRepository { if (!redisTemplate.hasKey(key)) { mapper.updateHost(id, worker); } - redisTemplate.opsForValue().set(key, JSONObject.toJSONString(status), 1, TimeUnit.HOURS); + redisTemplate.opsForValue().set(key, JacksonUtil.toJSONString(status), 1, TimeUnit.HOURS); } public ClientStatusReqVo getWorkerHostStatus(Long id) { String key = String.format(RENDER_WORKER_STATUS_CACHE_KEY, id); if (redisTemplate.hasKey(key)) { String status = redisTemplate.opsForValue().get(key); - return JSONObject.parseObject(status, ClientStatusReqVo.class); + return JacksonUtil.parseObject(status, ClientStatusReqVo.class); } return null; } diff --git a/src/main/java/com/ycwl/basic/repository/ScenicRepository.java b/src/main/java/com/ycwl/basic/repository/ScenicRepository.java index b5500cd..4016eb2 100644 --- a/src/main/java/com/ycwl/basic/repository/ScenicRepository.java +++ b/src/main/java/com/ycwl/basic/repository/ScenicRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.MpConfigMapper; import com.ycwl.basic.mapper.MpNotifyConfigMapper; import com.ycwl.basic.mapper.ScenicMapper; @@ -34,41 +34,41 @@ public class ScenicRepository { public ScenicEntity getScenic(Long id) { if (redisTemplate.hasKey(String.format(SCENIC_CACHE_KEY, id))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_CACHE_KEY, id)), ScenicEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_CACHE_KEY, id)), ScenicEntity.class); } ScenicEntity scenic = scenicMapper.get(id); if (scenic != null) { - redisTemplate.opsForValue().set(String.format(SCENIC_CACHE_KEY, id), JSONObject.toJSONString(scenic)); + redisTemplate.opsForValue().set(String.format(SCENIC_CACHE_KEY, id), JacksonUtil.toJSONString(scenic)); } return scenic; } public ScenicConfigEntity getScenicConfig(Long scenicId) { if (redisTemplate.hasKey(String.format(SCENIC_CONFIG_CACHE_KEY, scenicId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_CONFIG_CACHE_KEY, scenicId)), ScenicConfigEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_CONFIG_CACHE_KEY, scenicId)), ScenicConfigEntity.class); } ScenicConfigEntity scenicConfig = scenicMapper.getConfig(scenicId); if (scenicConfig != null) { - redisTemplate.opsForValue().set(String.format(SCENIC_CONFIG_CACHE_KEY, scenicId), JSONObject.toJSONString(scenicConfig)); + redisTemplate.opsForValue().set(String.format(SCENIC_CONFIG_CACHE_KEY, scenicId), JacksonUtil.toJSONString(scenicConfig)); } return scenicConfig; } public MpConfigEntity getScenicMpConfig(Long scenicId) { if (redisTemplate.hasKey(String.format(SCENIC_MP_CACHE_KEY, scenicId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_MP_CACHE_KEY, scenicId)), MpConfigEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_MP_CACHE_KEY, scenicId)), MpConfigEntity.class); } ScenicEntity scenic = getScenic(scenicId); MpConfigEntity mpConfigEntity = mpConfigMapper.selectById(scenic.getMpId()); if (mpConfigEntity != null) { - redisTemplate.opsForValue().set(String.format(SCENIC_MP_CACHE_KEY, scenicId), JSONObject.toJSONString(mpConfigEntity)); + redisTemplate.opsForValue().set(String.format(SCENIC_MP_CACHE_KEY, scenicId), JacksonUtil.toJSONString(mpConfigEntity)); } return mpConfigEntity; } public ScenicMpNotifyVO getScenicMpNotifyConfig(Long scenicId) { if (redisTemplate.hasKey(String.format(SCENIC_MP_NOTIFY_CACHE_KEY, scenicId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_MP_NOTIFY_CACHE_KEY, scenicId)), ScenicMpNotifyVO.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(SCENIC_MP_NOTIFY_CACHE_KEY, scenicId)), ScenicMpNotifyVO.class); } MpConfigEntity mpConfig = getScenicMpConfig(scenicId); if (mpConfig == null) { @@ -93,7 +93,7 @@ public class ScenicRepository { break; } }); - redisTemplate.opsForValue().set(String.format(SCENIC_MP_NOTIFY_CACHE_KEY, scenicId), JSONObject.toJSONString(mpNotifyConfig)); + redisTemplate.opsForValue().set(String.format(SCENIC_MP_NOTIFY_CACHE_KEY, scenicId), JacksonUtil.toJSONString(mpNotifyConfig)); return mpNotifyConfig; } diff --git a/src/main/java/com/ycwl/basic/repository/TemplateRepository.java b/src/main/java/com/ycwl/basic/repository/TemplateRepository.java index 5663396..51aac2f 100644 --- a/src/main/java/com/ycwl/basic/repository/TemplateRepository.java +++ b/src/main/java/com/ycwl/basic/repository/TemplateRepository.java @@ -1,6 +1,7 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; +import com.fasterxml.jackson.core.type.TypeReference; import com.ycwl.basic.mapper.FaceMapper; import com.ycwl.basic.mapper.FaceSampleMapper; import com.ycwl.basic.mapper.TemplateMapper; @@ -56,10 +57,10 @@ public class TemplateRepository { public List getTemplateListByScenicId(Long scenicId) { List idList; if (redisTemplate.hasKey(String.format(TEMPLATE_ID_BY_SCENIC_ID_CACHE_KEY, scenicId))) { - idList = JSONObject.parseArray(redisTemplate.opsForValue().get(String.format(TEMPLATE_ID_BY_SCENIC_ID_CACHE_KEY, scenicId)), Long.class); + idList = JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(TEMPLATE_ID_BY_SCENIC_ID_CACHE_KEY, scenicId)), new TypeReference>() {}); } else { idList = templateMapper.listEnabledTemplateIdByScenicId(scenicId); - redisTemplate.opsForValue().set(String.format(TEMPLATE_ID_BY_SCENIC_ID_CACHE_KEY, scenicId), JSONObject.toJSONString(idList)); + redisTemplate.opsForValue().set(String.format(TEMPLATE_ID_BY_SCENIC_ID_CACHE_KEY, scenicId), JacksonUtil.toJSONString(idList)); } if (idList == null || idList.isEmpty()) { return Collections.emptyList(); @@ -78,7 +79,7 @@ public class TemplateRepository { public TemplateRespVO getTemplate(Long templateId) { if (redisTemplate.hasKey(String.format(TEMPLATE_CACHE_KEY, templateId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(TEMPLATE_CACHE_KEY, templateId)), TemplateRespVO.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(TEMPLATE_CACHE_KEY, templateId)), TemplateRespVO.class); } TemplateRespVO template = templateMapper.getById(templateId); if (template == null) { @@ -86,7 +87,7 @@ public class TemplateRepository { } if (null == template.getPid() || template.getPid() == 0) { template.setChildren(templateMapper.getByPid(templateId)); - redisTemplate.opsForValue().set(String.format(TEMPLATE_CACHE_KEY, templateId), JSONObject.toJSONString(template)); + redisTemplate.opsForValue().set(String.format(TEMPLATE_CACHE_KEY, templateId), JacksonUtil.toJSONString(template)); return template; } else { clearTemplateCache(templateId); @@ -99,7 +100,7 @@ public class TemplateRepository { return new TemplateConfigEntity(); } if (redisTemplate.hasKey(String.format(TEMPLATE_CONFIG_CACHE_KEY, templateId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(TEMPLATE_CONFIG_CACHE_KEY, templateId)), TemplateConfigEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(TEMPLATE_CONFIG_CACHE_KEY, templateId)), TemplateConfigEntity.class); } TemplateConfigEntity templateConfig = templateMapper.getConfig(templateId); if (templateConfig == null) { @@ -108,7 +109,7 @@ public class TemplateRepository { templateConfig.setTemplateId(templateId); templateMapper.addConfig(templateConfig); } - redisTemplate.opsForValue().set(String.format(TEMPLATE_CONFIG_CACHE_KEY, templateId), JSONObject.toJSONString(templateConfig)); + redisTemplate.opsForValue().set(String.format(TEMPLATE_CONFIG_CACHE_KEY, templateId), JacksonUtil.toJSONString(templateConfig)); return templateConfig; } diff --git a/src/main/java/com/ycwl/basic/repository/VideoRepository.java b/src/main/java/com/ycwl/basic/repository/VideoRepository.java index fca357d..6ea6edb 100644 --- a/src/main/java/com/ycwl/basic/repository/VideoRepository.java +++ b/src/main/java/com/ycwl/basic/repository/VideoRepository.java @@ -1,6 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSON; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.VideoMapper; import com.ycwl.basic.model.pc.video.entity.MemberVideoEntity; import com.ycwl.basic.model.pc.video.entity.VideoEntity; @@ -25,24 +25,24 @@ public class VideoRepository { public VideoEntity getVideo(Long videoId) { if (redisTemplate.hasKey(String.format(VIDEO_CACHE_KEY, videoId))) { - return JSON.parseObject(redisTemplate.opsForValue().get(String.format(VIDEO_CACHE_KEY, videoId)), VideoEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(VIDEO_CACHE_KEY, videoId)), VideoEntity.class); } VideoEntity video = videoMapper.getEntity(videoId); if (video != null) { - redisTemplate.opsForValue().set(String.format(VIDEO_CACHE_KEY, videoId), JSON.toJSONString(video), 12, TimeUnit.HOURS); - redisTemplate.opsForValue().set(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, video.getTaskId()), JSON.toJSONString(video), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(VIDEO_CACHE_KEY, videoId), JacksonUtil.toJSONString(video), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, video.getTaskId()), JacksonUtil.toJSONString(video), 12, TimeUnit.HOURS); } return video; } public VideoEntity getVideoByTaskId(Long taskId) { if (redisTemplate.hasKey(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, taskId))) { - return JSON.parseObject(redisTemplate.opsForValue().get(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, taskId)), VideoEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, taskId)), VideoEntity.class); } VideoEntity video = videoMapper.findByTaskId(taskId); if (video != null) { - redisTemplate.opsForValue().set(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, taskId), JSON.toJSONString(video), 12, TimeUnit.HOURS); - redisTemplate.opsForValue().set(String.format(VIDEO_CACHE_KEY, video.getId()), JSON.toJSONString(video), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(VIDEO_BY_TASK_ID_CACHE_KEY, taskId), JacksonUtil.toJSONString(video), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(VIDEO_CACHE_KEY, video.getId()), JacksonUtil.toJSONString(video), 12, TimeUnit.HOURS); } return video; } diff --git a/src/main/java/com/ycwl/basic/repository/VideoTaskRepository.java b/src/main/java/com/ycwl/basic/repository/VideoTaskRepository.java index 6257e8b..30e7a9e 100644 --- a/src/main/java/com/ycwl/basic/repository/VideoTaskRepository.java +++ b/src/main/java/com/ycwl/basic/repository/VideoTaskRepository.java @@ -1,8 +1,6 @@ package com.ycwl.basic.repository; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.mapper.TaskMapper; import com.ycwl.basic.mapper.VideoMapper; import com.ycwl.basic.model.pc.task.entity.TaskEntity; @@ -27,11 +25,11 @@ public class VideoTaskRepository { public TaskEntity getTaskById(Long taskId) { if (redisTemplate.hasKey(String.format(TASK_CACHE_KEY, taskId))) { - return JSONObject.parseObject(redisTemplate.opsForValue().get(String.format(TASK_CACHE_KEY, taskId)), TaskEntity.class); + return JacksonUtil.parseObject(redisTemplate.opsForValue().get(String.format(TASK_CACHE_KEY, taskId)), TaskEntity.class); } else { TaskEntity task = taskMapper.get(taskId); if (task != null && 1 == task.getStatus()) { - redisTemplate.opsForValue().set(String.format(TASK_CACHE_KEY, taskId), JSONObject.toJSONString(task), 12, TimeUnit.HOURS); + redisTemplate.opsForValue().set(String.format(TASK_CACHE_KEY, taskId), JacksonUtil.toJSONString(task), 12, TimeUnit.HOURS); } return task; } @@ -48,14 +46,14 @@ public class VideoTaskRepository { return null; } Date shotTime = taskRespVO.getCreateTime(); - JSONObject paramJson = JSON.parseObject(taskRespVO.getTaskParams()); + JacksonUtil.JSONObjectCompat paramJson = JacksonUtil.JSONObjectCompat.parseObject(taskRespVO.getTaskParams()); if (paramJson != null) { Optional any = paramJson.keySet().stream().filter(StringUtils::isNumeric).findAny(); if (any.isPresent()) { - JSONArray jsonArray = paramJson.getJSONArray(any.get()); - if (!jsonArray.isEmpty()) { - JSONObject jsonObject = jsonArray.getJSONObject(0); - if (jsonObject.containsKey("createTime")) { + var jsonArray = paramJson.getJSONArray(any.get()); + if (jsonArray != null && !jsonArray.isEmpty()) { + JacksonUtil.JSONObjectCompat jsonObject = jsonArray.get(0); + if (jsonObject.getLong("createTime") != null) { shotTime = new Date(jsonObject.getLong("createTime")); } } diff --git a/src/main/java/com/ycwl/basic/service/mobile/impl/AppMemberServiceImpl.java b/src/main/java/com/ycwl/basic/service/mobile/impl/AppMemberServiceImpl.java index bf30771..f66b2c4 100644 --- a/src/main/java/com/ycwl/basic/service/mobile/impl/AppMemberServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/mobile/impl/AppMemberServiceImpl.java @@ -1,7 +1,7 @@ package com.ycwl.basic.service.mobile.impl; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.constant.BaseContextHandler; import com.ycwl.basic.constant.NumberConstant; import com.ycwl.basic.enums.BizCodeEnum; @@ -61,7 +61,7 @@ public class AppMemberServiceImpl implements AppMemberService { if (StringUtils.isBlank(response)) { return null; } - return JSONObject.parseObject(response); + return JacksonUtil.parseObject(response, Map.class); } catch (Exception e) { log.error("getOpenId", e); throw new AppException(BizCodeEnum.SERVER_INTERNAL_ERROR); diff --git a/src/main/java/com/ycwl/basic/service/mobile/impl/AppStatisticsServiceImpl.java b/src/main/java/com/ycwl/basic/service/mobile/impl/AppStatisticsServiceImpl.java index 2e5dfed..696f8de 100644 --- a/src/main/java/com/ycwl/basic/service/mobile/impl/AppStatisticsServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/mobile/impl/AppStatisticsServiceImpl.java @@ -3,8 +3,7 @@ package com.ycwl.basic.service.mobile.impl; import cn.hutool.core.date.DateField; import cn.hutool.core.date.DateUnit; import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.enums.StatisticEnum; import com.ycwl.basic.mapper.StatisticsMapper; import com.ycwl.basic.model.jwt.JwtInfo; @@ -188,8 +187,8 @@ public class AppStatisticsServiceImpl implements AppStatisticsService { // 缓存 if (redisTemplate.hasKey(redisKey)) { String s = redisTemplate.opsForValue().get(redisKey); - JSONObject cacheObj = JSON.parseObject(s); - return ApiResponse.success(cacheObj.toJavaObject(AppStatisticsFunnelVO.class)); + Map cacheObj = JacksonUtil.parseObject(s, Map.class); + return ApiResponse.success(JacksonUtil.toJavaObject(cacheObj, AppStatisticsFunnelVO.class)); } } } @@ -202,8 +201,8 @@ public class AppStatisticsServiceImpl implements AppStatisticsService { // 缓存 if (redisTemplate.hasKey(redisKey)) { String s = redisTemplate.opsForValue().get(redisKey); - JSONObject cacheObj = JSON.parseObject(s); - return ApiResponse.success(cacheObj.toJavaObject(AppStatisticsFunnelVO.class)); + Map cacheObj = JacksonUtil.parseObject(s, Map.class); + return ApiResponse.success(JacksonUtil.toJavaObject(cacheObj, AppStatisticsFunnelVO.class)); } } } @@ -266,7 +265,7 @@ public class AppStatisticsServiceImpl implements AppStatisticsService { vo.setRefundOfOrderNum(refundOfOrderNum); vo.setRefundOfOrderAmount(refundOfOrderAmount.setScale(2, RoundingMode.HALF_UP)); statisticsMapper.insertStat(query.getScenicId(), new Date(), vo); - redisTemplate.opsForValue().set(redisKey, JSON.toJSONString(vo), 60, TimeUnit.SECONDS); + redisTemplate.opsForValue().set(redisKey, JacksonUtil.toJSONString(vo), 60, TimeUnit.SECONDS); return ApiResponse.success(vo); } finally { lock.unlock(); diff --git a/src/main/java/com/ycwl/basic/service/mobile/impl/GoodsServiceImpl.java b/src/main/java/com/ycwl/basic/service/mobile/impl/GoodsServiceImpl.java index f0732a2..2673034 100644 --- a/src/main/java/com/ycwl/basic/service/mobile/impl/GoodsServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/mobile/impl/GoodsServiceImpl.java @@ -3,9 +3,7 @@ package com.ycwl.basic.service.mobile.impl; import cn.hutool.core.date.DateUtil; import cn.hutool.extra.qrcode.QrCodeUtil; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.biz.CouponBiz; import com.ycwl.basic.biz.OrderBiz; import com.ycwl.basic.biz.TaskStatusBiz; @@ -287,7 +285,7 @@ public class GoodsServiceImpl implements GoodsService { if (task == null) { return ApiResponse.fail("该vlog不存在或已失效"); } - JSONObject paramJson = JSON.parseObject(task.getTaskParams()); + Map paramJson = JacksonUtil.parseObject(task.getTaskParams(), Map.class); AtomicInteger deviceCount = new AtomicInteger(); goodsDetailVO.setShotTime(taskTaskService.getTaskShotDate(task.getId())); if (paramJson == null) { @@ -297,7 +295,7 @@ public class GoodsServiceImpl implements GoodsService { paramJson.entrySet().stream() .filter(entry -> StringUtils.isNumeric(entry.getKey())) .forEach(entry -> { - JSONArray jsonArray = paramJson.getJSONArray(entry.getKey()); + List jsonArray = JacksonUtil.parseArray(JacksonUtil.toJSONString(entry.getValue()), Object.class); if (jsonArray != null && !jsonArray.isEmpty()) { for (Object ignored : jsonArray) { if (templatePlaceholder.contains(entry.getKey())) { @@ -565,7 +563,7 @@ public class GoodsServiceImpl implements GoodsService { IStorageAdapter adapter; if (scenicConfig != null && scenicConfig.getStoreType() != null) { adapter = StorageFactory.get(scenicConfig.getStoreType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); } else { adapter = StorageFactory.use("assets-ext"); } @@ -674,7 +672,7 @@ public class GoodsServiceImpl implements GoodsService { IStorageAdapter adapter; if (scenicConfig.getStoreType() != null) { adapter = StorageFactory.get(scenicConfig.getStoreType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); } else { adapter = StorageFactory.use("assets-ext"); } diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/OrderServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/OrderServiceImpl.java index 9709f33..537b973 100644 --- a/src/main/java/com/ycwl/basic/service/pc/impl/OrderServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/pc/impl/OrderServiceImpl.java @@ -1,7 +1,6 @@ package com.ycwl.basic.service.pc.impl; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.ycwl.basic.biz.CouponBiz; @@ -252,7 +251,7 @@ public class OrderServiceImpl implements OrderService { if (task.getTaskParams() == null) { deviceCount = 1; } else { - JSONObject paramJson = JSON.parseObject(task.getTaskParams()); + Map paramJson = JacksonUtil.parseObject(task.getTaskParams(), Map.class); List templatePlaceholder = templateRepository.getTemplatePlaceholder(task.getTemplateId()); deviceCount = paramJson.keySet().stream() .filter(StringUtils::isNumeric) diff --git a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java index bab0a73..5f5a6ca 100644 --- a/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/pc/impl/ScenicServiceImpl.java @@ -1,6 +1,6 @@ package com.ycwl.basic.service.pc.impl; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.ycwl.basic.facebody.FaceBodyFactory; @@ -233,7 +233,7 @@ public class ScenicServiceImpl implements ScenicService { if (scenicConfig != null && scenicConfig.getStoreType() != null) { try { adapter = StorageFactory.get(scenicConfig.getStoreType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getStoreConfigJson(), Map.class)); } catch (StorageUnsupportedException ignored) { return StorageFactory.use("video"); } @@ -252,7 +252,7 @@ public class ScenicServiceImpl implements ScenicService { if (scenicConfig != null && scenicConfig.getTmpStoreType() != null) { try { adapter = StorageFactory.get(scenicConfig.getTmpStoreType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getTmpStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getTmpStoreConfigJson(), Map.class)); } catch (StorageUnsupportedException ignored) { return getScenicStorageAdapter(scenicId); } @@ -271,7 +271,7 @@ public class ScenicServiceImpl implements ScenicService { if (scenicConfig != null && scenicConfig.getLocalStoreType() != null) { try { adapter = StorageFactory.get(scenicConfig.getLocalStoreType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getLocalStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getLocalStoreConfigJson(), Map.class)); } catch (StorageUnsupportedException ignored) { return getScenicStorageAdapter(scenicId); } @@ -290,7 +290,7 @@ public class ScenicServiceImpl implements ScenicService { ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); if (scenicConfig != null && scenicConfig.getFaceType() != null) { adapter = FaceBodyFactory.getAdapter(scenicConfig.getFaceType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); } else { adapter = FaceBodyFactory.use(); } @@ -306,7 +306,7 @@ public class ScenicServiceImpl implements ScenicService { ScenicConfigEntity scenicConfig = scenicRepository.getScenicConfig(scenicId); if (scenicConfig != null && scenicConfig.getPayType() != null) { adapter = PayFactory.getAdapter(scenicConfig.getPayType()); - adapter.loadConfig(JSONObject.parseObject(scenicConfig.getPayConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getPayConfigJson(), Map.class)); } else { adapter = PayFactory.use(); } diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskFaceServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskFaceServiceImpl.java index 70e6520..343ee0b 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskFaceServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskFaceServiceImpl.java @@ -1,8 +1,7 @@ package com.ycwl.basic.service.task.impl; import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.aliyuncs.facebody.model.v20191230.SearchFaceRequest; import com.ycwl.basic.biz.OrderBiz; import com.ycwl.basic.constant.FaceConstant; @@ -98,7 +97,7 @@ public class TaskFaceServiceImpl implements TaskFaceService { IFaceBodyAdapter faceBodyAdapter; if (scenicConfig != null && scenicConfig.getFaceType() != null) { faceBodyAdapter = FaceBodyFactory.getAdapter(scenicConfig.getFaceType()); - faceBodyAdapter.loadConfig(JSONObject.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); + faceBodyAdapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); } else { faceBodyAdapter = FaceBodyFactory.use(); } @@ -202,7 +201,7 @@ public class TaskFaceServiceImpl implements TaskFaceService { SearchFaceRespVo respVo = new SearchFaceRespVo(); List records = response.getResult(); respVo.setScore(response.getOriginalFaceScore()); - respVo.setSearchResultJson(JSON.toJSONString(records)); + respVo.setSearchResultJson(JacksonUtil.toJSONString(records)); logEntity.setMatchRawRecord(records); if (records.isEmpty()) { return respVo; @@ -265,7 +264,7 @@ public class TaskFaceServiceImpl implements TaskFaceService { record.setMatched(item.getScore() > _threshold); collect.add(record); } - logEntity.setMatchLocalRecord(JSONObject.toJSONString(collect)); + logEntity.setMatchLocalRecord(JacksonUtil.toJSONString(collect)); if (acceptFaceSampleIds.isEmpty()) { respVo.setFirstMatchRate(0f); respVo.setSampleListIds(Collections.emptyList()); diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index 993b060..1819842 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -1,9 +1,7 @@ package com.ycwl.basic.service.task.impl; import cn.hutool.core.date.DateUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.biz.OrderBiz; import com.ycwl.basic.biz.TaskStatusBiz; import com.ycwl.basic.biz.TemplateBiz; @@ -259,7 +257,7 @@ public class TaskTaskServiceImpl implements TaskService { TaskReqQuery taskReqQuery = new TaskReqQuery(); taskReqQuery.setFaceId(faceId); taskReqQuery.setTemplateId(templateId); - taskReqQuery.setTaskParams(JSON.toJSONString(sourcesMap)); + taskReqQuery.setTaskParams(JacksonUtil.toJSONString(sourcesMap)); List list = taskMapper.list(taskReqQuery); MemberVideoEntity memberVideoEntity = new MemberVideoEntity(); @@ -298,7 +296,7 @@ public class TaskTaskServiceImpl implements TaskService { } taskEntity.setWorkerId(null); taskEntity.setStatus(0); - taskEntity.setTaskParams(JSON.toJSONString(sourcesMap)); + taskEntity.setTaskParams(JacksonUtil.toJSONString(sourcesMap)); taskMapper.add(taskEntity); memberVideoEntity.setTaskId(taskEntity.getId()); } else { @@ -471,7 +469,7 @@ public class TaskTaskServiceImpl implements TaskService { TaskReqQuery taskReqQuery = new TaskReqQuery(); taskReqQuery.setFaceId(faceId); taskReqQuery.setTemplateId(templateId); - taskReqQuery.setTaskParams(JSON.toJSONString(sourcesMap)); + taskReqQuery.setTaskParams(JacksonUtil.toJSONString(sourcesMap)); List list = taskMapper.list(taskReqQuery); MemberVideoEntity memberVideoEntity = new MemberVideoEntity(); @@ -510,7 +508,7 @@ public class TaskTaskServiceImpl implements TaskService { } taskEntity.setWorkerId(null); taskEntity.setStatus(0); - taskEntity.setTaskParams(JSON.toJSONString(sourcesMap)); + taskEntity.setTaskParams(JacksonUtil.toJSONString(sourcesMap)); taskMapper.add(taskEntity); memberVideoEntity.setTaskId(taskEntity.getId()); } else { @@ -650,7 +648,7 @@ public class TaskTaskServiceImpl implements TaskService { IStorageAdapter adapter; try { adapter = StorageFactory.get(worker.getStoreType()); - adapter.loadConfig(JSONObject.parseObject(worker.getStoreConfigJson(), Map.class)); + adapter.loadConfig(JacksonUtil.parseObject(worker.getStoreConfigJson(), Map.class)); } catch (Exception e) { adapter = scenicService.getScenicStorageAdapter(task.getScenicId()); } @@ -677,15 +675,19 @@ public class TaskTaskServiceImpl implements TaskService { return null; } Date shotTime = taskRespVO.getCreateTime(); - JSONObject paramJson = JSON.parseObject(taskRespVO.getTaskParams()); + Map paramJson = JacksonUtil.parseObject(taskRespVO.getTaskParams(), Map.class); if (paramJson != null) { Optional any = paramJson.keySet().stream().filter(StringUtils::isNumeric).findAny(); if (any.isPresent()) { - JSONArray jsonArray = paramJson.getJSONArray(any.get()); - if (!jsonArray.isEmpty()) { - JSONObject jsonObject = jsonArray.getJSONObject(0); + @SuppressWarnings("unchecked") + List> jsonArray = (List>) paramJson.get(any.get()); + if (jsonArray != null && !jsonArray.isEmpty()) { + Map jsonObject = jsonArray.get(0); if (jsonObject.containsKey("createTime")) { - shotTime = new Date(jsonObject.getLong("createTime")); + Object createTimeObj = jsonObject.get("createTime"); + if (createTimeObj instanceof Number) { + shotTime = new Date(((Number) createTimeObj).longValue()); + } } } } diff --git a/src/main/java/com/ycwl/basic/task/DynamicTaskGenerator.java b/src/main/java/com/ycwl/basic/task/DynamicTaskGenerator.java index b24825c..bbe3d0b 100644 --- a/src/main/java/com/ycwl/basic/task/DynamicTaskGenerator.java +++ b/src/main/java/com/ycwl/basic/task/DynamicTaskGenerator.java @@ -1,6 +1,6 @@ package com.ycwl.basic.task; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import com.ycwl.basic.biz.TemplateBiz; import com.ycwl.basic.facebody.FaceBodyFactory; import com.ycwl.basic.facebody.adapter.AliFaceBodyAdapter; @@ -116,7 +116,7 @@ public class DynamicTaskGenerator { IFaceBodyAdapter faceBodyAdapter; if (scenicConfig.getFaceType() != null) { faceBodyAdapter = FaceBodyFactory.getAdapter(scenicConfig.getFaceType()); - faceBodyAdapter.loadConfig(JSONObject.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); + faceBodyAdapter.loadConfig(JacksonUtil.parseObject(scenicConfig.getFaceConfigJson(), Map.class)); } else { faceBodyAdapter = FaceBodyFactory.use(); } diff --git a/src/main/java/com/ycwl/basic/task/N9eSyncTask.java b/src/main/java/com/ycwl/basic/task/N9eSyncTask.java index ff15bb4..7c772a9 100644 --- a/src/main/java/com/ycwl/basic/task/N9eSyncTask.java +++ b/src/main/java/com/ycwl/basic/task/N9eSyncTask.java @@ -3,9 +3,7 @@ package com.ycwl.basic.task; import cn.hutool.core.codec.Base64; import cn.hutool.core.date.LocalDateTimeUtil; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSON; -import com.alibaba.fastjson.JSONArray; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -15,7 +13,7 @@ import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import cn.hutool.http.HttpResponse; -import java.util.Date; +import java.util.*; import java.util.concurrent.TimeUnit; @@ -32,12 +30,12 @@ public class N9eSyncTask { String auth = "Basic " + Base64.encode("user001:ccc26da7b9aba533cbb263a36c07dcc4"); // 构建请求体 - JSONObject requestBody = new JSONObject(); - JSONArray queries = new JSONArray(); - JSONObject query = new JSONObject(); + Map requestBody = new HashMap<>(); + List> queries = new ArrayList<>(); + Map query = new HashMap<>(); query.put("key", "group_ids"); query.put("op", "=="); - JSONArray values = new JSONArray(); + List values = new ArrayList<>(); values.add(4); query.put("values", values); queries.add(query); @@ -47,23 +45,27 @@ public class N9eSyncTask { HttpResponse response = HttpUtil.createPost("https://n9e.jerryyan.top/v1/n9e/target/list") .header("Authorization", auth) .header("Content-Type", "application/json") - .body(requestBody.toJSONString()) + .body(JacksonUtil.toJSONString(requestBody)) .execute(); - JSONObject respData = JSON.parseObject(response.body()); - if (StringUtils.isNotBlank(respData.getString("err"))) { + Map respData = JacksonUtil.parseObject(response.body(), Map.class); + String err = (String) respData.get("err"); + if (StringUtils.isNotBlank(err)) { log.warn("N9E信息获取失败"); return; } - JSONObject data = respData.getJSONObject("dat"); - if (data.getInteger("total") <= 0) { + @SuppressWarnings("unchecked") + Map data = (Map) respData.get("dat"); + Integer total = (Integer) data.get("total"); + if (total == null || total <= 0) { log.warn("N9E信息为空"); return; } - JSONArray list = data.getJSONArray("list"); + @SuppressWarnings("unchecked") + List> list = (List>) data.get("list"); list.forEach(item -> { - JSONObject itemObj = (JSONObject) item; - String ident = itemObj.getString("ident"); - Long updateAt = itemObj.getLong("update_at"); + String ident = (String) item.get("ident"); + Number updateAtNum = (Number) item.get("update_at"); + Long updateAt = updateAtNum != null ? updateAtNum.longValue() : 0L; redisTemplate.opsForValue().set("ext_device:online:" + ident, updateAt.toString(), 1, TimeUnit.DAYS); }); } diff --git a/src/main/java/com/ycwl/basic/utils/JacksonUtil.java b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java index 4d0d65c..722239f 100644 --- a/src/main/java/com/ycwl/basic/utils/JacksonUtil.java +++ b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java @@ -274,4 +274,238 @@ public class JacksonUtil { public static ObjectMapper getObjectMapper() { return objectMapper; } + + // ==== FastJSON 兼容性方法 ==== + + /** + * 兼容 FastJSON 的 JSON.toJSONString() 方法 + * @param obj 要转换的对象 + * @return JSON字符串 + */ + public static String toJSONString(Object obj) { + return toJson(obj); + } + + /** + * 兼容 FastJSON 的 JSON.parseObject() 方法 + * @param json JSON字符串 + * @param clazz 目标类型 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T parseObject(String json, Class clazz) { + return fromJson(json, clazz); + } + + /** + * 兼容 FastJSON 的 JSON.parseArray() 方法 + * @param json JSON字符串 + * @param clazz 数组元素类型 + * @param 泛型类型 + * @return List对象 + */ + public static List parseArray(String json, Class clazz) { + return fromJsonToList(json, clazz); + } + + /** + * 带TypeReference的parseObject方法，支持复杂泛型 + * @param json JSON字符串 + * @param typeReference 类型引用 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T parseObject(String json, TypeReference typeReference) { + return fromJson(json, typeReference); + } + + /** + * 将Map或其他对象转换为指定类型，兼容fastjson的toJavaObject方法 + * @param obj 源对象 + * @param clazz 目标类型 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T toJavaObject(Object obj, Class clazz) { + if (obj == null) { + return null; + } + try { + // 如果对象已经是目标类型，直接返回 + if (clazz.isInstance(obj)) { + return clazz.cast(obj); + } + // 先转为JSON字符串，再转为目标对象 + String json = toJson(obj); + return fromJson(json, clazz); + } catch (Exception e) { + throw new RuntimeException("对象转换失败", e); + } + } + + /** + * 兼容 FastJSON 的 JSONObject.parseObject() 方法 + * @param json JSON字符串 + * @param clazz 目标类型 + * @param 泛型类型 + * @return 转换后的对象 + */ + public static T parseObjectCompat(String json, Class clazz) { + return fromJson(json, clazz); + } + + /** + * 兼容 FastJSON 的 JSONObject.toJSONString() 方法 + * @param obj 要转换的对象 + * @return JSON字符串 + */ + public static String toJSONStringCompat(Object obj) { + return toJson(obj); + } + + /** + * 兼容 FastJSON 的 JSONObject.parseArray() 方法 + * @param json JSON字符串 + * @param clazz 数组元素类型 + * @param 泛型类型 + * @return List对象 + */ + public static List parseArrayCompat(String json, Class clazz) { + return fromJsonToList(json, clazz); + } + + /** + * 简单的JSON对象包装类，兼容部分JSONObject的用法 + */ + public static class JSONObjectCompat { + private final JsonNode node; + + private JSONObjectCompat(JsonNode node) { + this.node = node; + } + + /** + * 解析JSON字符串为JSONObjectCompat + * @param json JSON字符串 + * @return JSONObjectCompat对象 + */ + public static JSONObjectCompat parseObject(String json) { + return new JSONObjectCompat(getJsonNode(json)); + } + + /** + * 获取JSON数组 + * @param key 键名 + * @return JSON数组的List表示 + */ + public List getJSONArray(String key) { + JsonNode arrayNode = node.get(key); + if (arrayNode != null && arrayNode.isArray()) { + List result = new java.util.ArrayList<>(); + for (JsonNode item : arrayNode) { + result.add(new JSONObjectCompat(item)); + } + return result; + } + return null; + } + + /** + * 获取JSON对象 + * @param index 索引 + * @return JSONObjectCompat对象 + */ + public JSONObjectCompat getJSONObject(int index) { + if (node.isArray() && index < node.size()) { + return new JSONObjectCompat(node.get(index)); + } + return null; + } + + /** + * 获取字符串值 + * @param key 键名 + * @return 字符串值 + */ + public String getString(String key) { + JsonNode valueNode = node.get(key); + return valueNode != null && !valueNode.isNull() ? valueNode.asText() : null; + } + + /** + * 获取整数值 + * @param key 键名 + * @return 整数值 + */ + public Integer getInteger(String key) { + JsonNode valueNode = node.get(key); + return valueNode != null && !valueNode.isNull() ? valueNode.asInt() : null; + } + + /** + * 获取长整数值 + * @param key 键名 + * @return 长整数值 + */ + public Long getLong(String key) { + JsonNode valueNode = node.get(key); + return valueNode != null && !valueNode.isNull() ? valueNode.asLong() : null; + } + + /** + * 获取双精度浮点数值 + * @param key 键名 + * @return 双精度浮点数值 + */ + public Double getDouble(String key) { + JsonNode valueNode = node.get(key); + return valueNode != null && !valueNode.isNull() ? valueNode.asDouble() : null; + } + + /** + * 获取布尔值 + * @param key 键名 + * @return 布尔值 + */ + public Boolean getBoolean(String key) { + JsonNode valueNode = node.get(key); + return valueNode != null && !valueNode.isNull() ? valueNode.asBoolean() : null; + } + + /** + * 获取键集合 + * @return 键的Set集合 + */ + public java.util.Set keySet() { + if (node.isObject()) { + java.util.Set keys = new java.util.HashSet<>(); + node.fieldNames().forEachRemaining(keys::add); + return keys; + } + return java.util.Collections.emptySet(); + } + + /** + * 检查是否包含指定键 + * @param key 键名 + * @return 是否包含 + */ + public boolean containsKey(String key) { + return node.has(key); + } + + /** + * 转换为Java对象 + * @param clazz 目标类型 + * @param 泛型类型 + * @return Java对象 + */ + public T toJavaObject(Class clazz) { + try { + return objectMapper.treeToValue(node, clazz); + } catch (JsonProcessingException e) { + throw new RuntimeException("JSON节点转对象失败", e); + } + } + } } \ No newline at end of file diff --git a/src/main/java/com/ycwl/basic/utils/WxMpUtil.java b/src/main/java/com/ycwl/basic/utils/WxMpUtil.java index fe9f76c..4347889 100644 --- a/src/main/java/com/ycwl/basic/utils/WxMpUtil.java +++ b/src/main/java/com/ycwl/basic/utils/WxMpUtil.java @@ -2,7 +2,8 @@ package com.ycwl.basic.utils; import cn.hutool.http.HttpResponse; import cn.hutool.http.HttpUtil; -import com.alibaba.fastjson.JSONObject; +import com.ycwl.basic.utils.JacksonUtil; +import java.util.HashMap; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; @@ -37,22 +38,22 @@ public class WxMpUtil { String token; if (!System.getProperty("os.name").toLowerCase().startsWith("win")) { String url = String.format(STABLE_ACCESS_TOKEN_URL, appId, appSecret); - JSONObject params = new JSONObject(); + Map params = new HashMap<>(); params.put("grant_type", "client_credential"); params.put("appid", appId); params.put("secret", appSecret); params.put("force_refresh", false); - String response = HttpUtil.post(url, params.toJSONString()); - JSONObject jsonObject = JSONObject.parseObject(response); - token = jsonObject.getString("access_token"); - Date expireTime = new Date(System.currentTimeMillis() + jsonObject.getInteger("expires_in") * 1000 / 2); + String response = HttpUtil.post(url, JacksonUtil.toJSONString(params)); + Map jsonObject = JacksonUtil.parseObject(response, Map.class); + token = (String) jsonObject.get("access_token"); + Date expireTime = new Date(System.currentTimeMillis() + ((Integer) jsonObject.get("expires_in")) * 1000 / 2); expireTimes.put(appId, expireTime); } else { String url = String.format(ACCESS_TOKEN_URL, appId, appSecret); String response = HttpUtil.get(url); - JSONObject jsonObject = JSONObject.parseObject(response); - token = jsonObject.getString("access_token"); - Date expireTime = new Date(System.currentTimeMillis() + jsonObject.getInteger("expires_in") * 1000 / 2); + Map jsonObject = JacksonUtil.parseObject(response, Map.class); + token = (String) jsonObject.get("access_token"); + Date expireTime = new Date(System.currentTimeMillis() + ((Integer) jsonObject.get("expires_in")) * 1000 / 2); expireTimes.put(appId, expireTime); } return token; @@ -64,12 +65,12 @@ public class WxMpUtil { public static void generateWXAQRCode(String appId, String appSecret, String envVersion, String path, String filePath) throws Exception { String url = String.format(GET_WXA_CODE_URL, getAccessToken(appId, appSecret)); - JSONObject json = new JSONObject(); + Map json = new HashMap<>(); json.put("env_version", envVersion); json.put("path", path); json.put("width", 1000); - try (HttpResponse response = HttpUtil.createPost(url).body(json.toJSONString()).header("Content-Type", "application/json").execute()) { + try (HttpResponse response = HttpUtil.createPost(url).body(JacksonUtil.toJSONString(json)).header("Content-Type", "application/json").execute()) { if (response.getStatus() != 200) { throw new Exception("获取小程序二维码失败，原因为：" + response.body()); } @@ -86,12 +87,12 @@ public class WxMpUtil { public static void generateUnlimitedWXAQRCode(String appId, String appSecret, String path, String scene, File targetFile) throws Exception { String url = String.format(GET_WXA_CODE_UNLIMITED_URL, getAccessToken(appId, appSecret)); - JSONObject json = new JSONObject(); + Map json = new HashMap<>(); json.put("page", path); json.put("scene", scene); json.put("check_path", false); - try (HttpResponse response = HttpUtil.createPost(url).body(json.toJSONString()).header("Content-Type", "application/json").execute()) { + try (HttpResponse response = HttpUtil.createPost(url).body(JacksonUtil.toJSONString(json)).header("Content-Type", "application/json").execute()) { if (response.getStatus() != 200) { throw new Exception("获取小程序二维码失败，原因为：" + response.body()); } @@ -108,34 +109,34 @@ public class WxMpUtil { public static String generateUrlLink(String appId, String appSecret, String path, String query) throws Exception { String url = String.format(GET_URL_LICK_URL, getAccessToken(appId, appSecret)); - JSONObject json = new JSONObject(); + Map json = new HashMap<>(); json.put("path", path); json.put("query", query); - try (HttpResponse response = HttpUtil.createPost(url).body(json.toJSONString()).header("Content-Type", "application/json").execute()) { + try (HttpResponse response = HttpUtil.createPost(url).body(JacksonUtil.toJSONString(json)).header("Content-Type", "application/json").execute()) { String responseStr = response.body(); - JSONObject jsonObject = JSONObject.parseObject(responseStr); - if (jsonObject.getInteger("errcode") != 0) { - throw new Exception("获取url_link失败，原因为：" + jsonObject.getString("errmsg")); + Map jsonObject = JacksonUtil.parseObject(responseStr, Map.class); + if ((Integer) jsonObject.get("errcode") != 0) { + throw new Exception("获取url_link失败，原因为：" + (String) jsonObject.get("errmsg")); } - return jsonObject.getString("url_link"); + return (String) jsonObject.get("url_link"); } } public static String getUserPhone(String appId, String appSecret, String code) throws Exception { String url = String.format(GET_USER_PHONE_URL, getAccessToken(appId, appSecret)); - JSONObject json = new JSONObject(); + Map json = new HashMap<>(); json.put("code", code); - try (HttpResponse response = HttpUtil.createPost(url).body(json.toJSONString()).header("Content-Type", "application/json").execute()) { + try (HttpResponse response = HttpUtil.createPost(url).body(JacksonUtil.toJSONString(json)).header("Content-Type", "application/json").execute()) { String responseStr = response.body(); - JSONObject jsonObject = JSONObject.parseObject(responseStr); - if (jsonObject.getInteger("errcode") != 0) { - throw new Exception("获取用户手机号失败，原因为：" + jsonObject.getString("errmsg")); + Map jsonObject = JacksonUtil.parseObject(responseStr, Map.class); + if ((Integer) jsonObject.get("errcode") != 0) { + throw new Exception("获取用户手机号失败，原因为：" + (String) jsonObject.get("errmsg")); } - return jsonObject.getJSONObject("phone_info").getString("phoneNumber"); + return (String) ((Map) jsonObject.get("phone_info")).get("phoneNumber"); } } From f8de4abd099fcdd62d465023bfbd035d70853caf Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Sun, 27 Jul 2025 09:28:32 +0800 Subject: [PATCH 3/5] jackson --- .../ycwl/basic/model/mobile/goods/GoodsDetailVO.java | 3 +++ .../basic/model/mobile/goods/VideoGoodsDetailVO.java | 2 ++ .../basic/model/mobile/order/IsBuyBatchRespVO.java | 3 +++ .../com/ycwl/basic/model/mobile/order/IsBuyRespVO.java | 3 +++ .../mobile/statistic/resp/AppStatisticsFunnelVO.java | 10 ++++++++++ .../ycwl/basic/model/pc/order/entity/OrderEntity.java | 2 ++ .../ycwl/basic/model/pc/order/resp/OrderAppRespVO.java | 2 ++ .../ycwl/basic/model/pc/order/resp/OrderRespVO.java | 2 ++ .../ycwl/basic/model/pc/video/resp/VideoRespVO.java | 2 ++ .../basic/model/viid/entity/FacePositionObject.java | 3 +++ 10 files changed, 32 insertions(+) diff --git a/src/main/java/com/ycwl/basic/model/mobile/goods/GoodsDetailVO.java b/src/main/java/com/ycwl/basic/model/mobile/goods/GoodsDetailVO.java index 8910c04..cf64cbf 100644 --- a/src/main/java/com/ycwl/basic/model/mobile/goods/GoodsDetailVO.java +++ b/src/main/java/com/ycwl/basic/model/mobile/goods/GoodsDetailVO.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.mobile.goods; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Builder; import lombok.Data; import lombok.NoArgsConstructor; @@ -42,6 +43,8 @@ public class GoodsDetailVO { private Integer isFree; private Integer parts; private Integer sort; + + @JsonProperty("sourceType") public Integer getSourceType() { return goodsType; } diff --git a/src/main/java/com/ycwl/basic/model/mobile/goods/VideoGoodsDetailVO.java b/src/main/java/com/ycwl/basic/model/mobile/goods/VideoGoodsDetailVO.java index 14828f4..430035a 100644 --- a/src/main/java/com/ycwl/basic/model/mobile/goods/VideoGoodsDetailVO.java +++ b/src/main/java/com/ycwl/basic/model/mobile/goods/VideoGoodsDetailVO.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.mobile.goods; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -56,6 +57,7 @@ public class VideoGoodsDetailVO { private Integer width; private BigDecimal duration; + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyBatchRespVO.java b/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyBatchRespVO.java index 85357e1..01a8f65 100644 --- a/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyBatchRespVO.java +++ b/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyBatchRespVO.java @@ -1,5 +1,6 @@ package com.ycwl.basic.model.mobile.order; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -18,6 +19,7 @@ public class IsBuyBatchRespVO { private BigDecimal couponPrice = BigDecimal.ZERO; private BigDecimal slashPrice; + @JsonProperty("price") public BigDecimal getPrice() { if (origPrice == null) { return BigDecimal.ZERO; @@ -27,6 +29,7 @@ public class IsBuyBatchRespVO { } return origPrice.subtract(couponPrice); } + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyRespVO.java b/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyRespVO.java index 774afa0..d5cc576 100644 --- a/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyRespVO.java +++ b/src/main/java/com/ycwl/basic/model/mobile/order/IsBuyRespVO.java @@ -1,5 +1,6 @@ package com.ycwl.basic.model.mobile.order; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -17,6 +18,7 @@ public class IsBuyRespVO { private BigDecimal couponPrice = BigDecimal.ZERO; private BigDecimal slashPrice; + @JsonProperty("price") public BigDecimal getPrice() { if (origPrice == null) { return BigDecimal.ZERO; @@ -26,6 +28,7 @@ public class IsBuyRespVO { } return origPrice.subtract(couponPrice); } + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/mobile/statistic/resp/AppStatisticsFunnelVO.java b/src/main/java/com/ycwl/basic/model/mobile/statistic/resp/AppStatisticsFunnelVO.java index 444cb15..fbc49b0 100644 --- a/src/main/java/com/ycwl/basic/model/mobile/statistic/resp/AppStatisticsFunnelVO.java +++ b/src/main/java/com/ycwl/basic/model/mobile/statistic/resp/AppStatisticsFunnelVO.java @@ -1,5 +1,6 @@ package com.ycwl.basic.model.mobile.statistic.resp; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; import java.math.RoundingMode; @@ -45,11 +46,13 @@ public class AppStatisticsFunnelVO { private BigDecimal refundOfOrderAmount; // ro3 // 镜头检测游客数_扫码访问人数_转化率 + @JsonProperty("csom_scaom") public String getCsom_scaom() { return "-"; // TODO: REAL } // 扫码访问人数_上传头像人数_转化率 + @JsonProperty("scaom_ufom") public String getScaom_ufom() { if (uploadFaceOfMemberNum == 0 || scanCodeVisitorOfMemberNum == 0) { return "0.00"; @@ -60,6 +63,7 @@ public class AppStatisticsFunnelVO { .toString(); } // 上传头像人数_推送订阅人数_转化率 + @JsonProperty("ufom_pom") public String getUfom_pom() { if (pushOfMemberNum == 0 || uploadFaceOfMemberNum == 0) { return "0.00"; @@ -70,6 +74,7 @@ public class AppStatisticsFunnelVO { .toString(); } // 推送订阅人数_生成视频人数_转化率 + @JsonProperty("pom_cvom") public String getPom_cvom() { if (completeVideoOfMemberNum == 0 || pushOfMemberNum == 0) { return "0.00"; @@ -80,6 +85,7 @@ public class AppStatisticsFunnelVO { .toString(); } // 生成视频人数_预览视频人数_转化率 + @JsonProperty("cvom_pvom") public String getCvom_pvom() { if (previewVideoOfMemberNum == 0 || completeVideoOfMemberNum == 0) { return "0.00"; @@ -90,6 +96,7 @@ public class AppStatisticsFunnelVO { .toString(); } // 预览视频人数_点击购买人数_转化率 + @JsonProperty("pvom_cpom") public String getPvom_cpom() { if (clickOnPayOfMemberNum == 0 || previewVideoOfMemberNum == 0) { return "0.00"; @@ -100,6 +107,7 @@ public class AppStatisticsFunnelVO { .toString(); } // 点击购买人数_支付订单人数_转化率 + @JsonProperty("cpom_pom") public String getCpom_pom() { if (payOfMemberNum == 0 || clickOnPayOfMemberNum == 0) { return "0.00"; @@ -112,6 +120,7 @@ public class AppStatisticsFunnelVO { public BigDecimal payOfOrderAmount() { return payOfOrderAmount; } + @JsonProperty("payOfOrderAmount") public String getPayOfOrderAmount() { if (payOfOrderAmount == null) { return "0.00"; @@ -121,6 +130,7 @@ public class AppStatisticsFunnelVO { public BigDecimal refundOfOrderAmount() { return refundOfOrderAmount; } + @JsonProperty("refundOfOrderAmount") public String getRefundOfOrderAmount() { if (refundOfOrderAmount == null) { return "0.00"; diff --git a/src/main/java/com/ycwl/basic/model/pc/order/entity/OrderEntity.java b/src/main/java/com/ycwl/basic/model/pc/order/entity/OrderEntity.java index bedb909..374504d 100644 --- a/src/main/java/com/ycwl/basic/model/pc/order/entity/OrderEntity.java +++ b/src/main/java/com/ycwl/basic/model/pc/order/entity/OrderEntity.java @@ -2,6 +2,7 @@ package com.ycwl.basic.model.pc.order.entity; import com.baomidou.mybatisplus.annotation.TableId; import com.baomidou.mybatisplus.annotation.TableName; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -91,6 +92,7 @@ public class OrderEntity { */ private Date refundAt; + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderAppRespVO.java b/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderAppRespVO.java index 46eb1c3..9244e8e 100644 --- a/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderAppRespVO.java +++ b/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderAppRespVO.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.pc.order.resp; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -88,6 +89,7 @@ public class OrderAppRespVO { // 订单明细 private List orderItemList; + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderRespVO.java b/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderRespVO.java index 6c2df91..986af1f 100644 --- a/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderRespVO.java +++ b/src/main/java/com/ycwl/basic/model/pc/order/resp/OrderRespVO.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.pc.order.resp; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.annotation.JsonProperty; import com.ycwl.basic.model.mobile.goods.GoodsDetailVO; import com.ycwl.basic.model.pc.order.entity.OrderItemEntity; import lombok.Data; @@ -112,6 +113,7 @@ public class OrderRespVO { private String scenicName; private List goodsList; + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/pc/video/resp/VideoRespVO.java b/src/main/java/com/ycwl/basic/model/pc/video/resp/VideoRespVO.java index 77cd620..3a97fd8 100644 --- a/src/main/java/com/ycwl/basic/model/pc/video/resp/VideoRespVO.java +++ b/src/main/java/com/ycwl/basic/model/pc/video/resp/VideoRespVO.java @@ -1,6 +1,7 @@ package com.ycwl.basic.model.pc.video.resp; import com.fasterxml.jackson.annotation.JsonFormat; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; import java.math.BigDecimal; @@ -62,6 +63,7 @@ public class VideoRespVO { private Integer width; private BigDecimal duration; + @JsonProperty("discountPrice") public BigDecimal getDiscountPrice() { if (slashPrice == null) { return BigDecimal.ZERO; diff --git a/src/main/java/com/ycwl/basic/model/viid/entity/FacePositionObject.java b/src/main/java/com/ycwl/basic/model/viid/entity/FacePositionObject.java index 9e062a1..8543e95 100644 --- a/src/main/java/com/ycwl/basic/model/viid/entity/FacePositionObject.java +++ b/src/main/java/com/ycwl/basic/model/viid/entity/FacePositionObject.java @@ -1,5 +1,6 @@ package com.ycwl.basic.model.viid.entity; +import com.fasterxml.jackson.annotation.JsonProperty; import lombok.Data; @Data @@ -10,9 +11,11 @@ public class FacePositionObject { private Integer ltY; private Integer rbX; private Integer rbY; + @JsonProperty("width") public Integer getWidth(){ return rbX - ltX; } + @JsonProperty("height") public Integer getHeight(){ return rbY - ltY; } From 93c74e181a74f9536966ff6629e963d64bf8dcc1 Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Sun, 27 Jul 2025 19:06:34 +0800 Subject: [PATCH 4/5] 2 --- .../service/task/impl/TaskTaskServiceImpl.java | 5 ++++- .../basic/task/DownloadNotificationTasker.java | 14 ++++++++++++-- src/main/resources/mapper/StatisticsMapper.xml | 4 ++-- 3 files changed, 18 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java index 1819842..0bffb14 100644 --- a/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java +++ b/src/main/java/com/ycwl/basic/service/task/impl/TaskTaskServiceImpl.java @@ -234,11 +234,14 @@ public class TaskTaskServiceImpl implements TaskService { List videoSourceList = sourceMapper.listVideoByScenicFaceRelation(face.getScenicId(), faceId); Map> sourcesMap = videoSourceList.stream() .peek(item -> item.setUrl(item.getVideoUrl())) + .filter(item -> item.getDeviceId() != null) // 添加对 deviceId 为 null 的检查 .filter(item -> { DeviceEntity device = deviceRepository.getDevice(item.getDeviceId()); + if (device == null) { + return false; + } return Integer.valueOf(1).equals(device.getStatus()); }) - .filter(item -> item.getDeviceId() != null) // 添加对 deviceId 为 null 的检查 .collect(Collectors.groupingBy(item -> item.getDeviceId().toString())); if (sourcesMap.isEmpty()) { // 主动禁止没有视频源视频生成 diff --git a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java index 73d9244..8a9104e 100644 --- a/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java +++ b/src/main/java/com/ycwl/basic/task/DownloadNotificationTasker.java @@ -83,7 +83,17 @@ public class DownloadNotificationTasker { videoMap.put("value", title); dataParam.put("thing1", videoMap); Map remarkMap = new HashMap<>(); - remarkMap.put("value", "系统删除前，请下载好您的旅行视频"); + // 查询是否有优惠券可用，如果有，则显示优惠券配置的内容 + CouponQueryReq query = new CouponQueryReq(); + query.setScenicId(item.getScenicId()); + query.setType(2); + query.setStatus(1); + List coupons = couponMapper.selectByQuery(query); + if (coupons.isEmpty() || StringUtils.isBlank(coupons.getFirst().getBroadcast())) { + remarkMap.put("value", "系统删除前，请下载好您的旅行视频"); + } else { + remarkMap.put("value", coupons.getFirst().getBroadcast()); + } dataParam.put("thing3", remarkMap); params.put("data", dataParam); params.put("page", page); @@ -97,7 +107,7 @@ public class DownloadNotificationTasker { @Scheduled(cron = "0 0 20 * * *") public void sendExpireNotification() { log.info("开始执行定时任务"); - videoMapper.listRelationByCreateTime(new Date(System.currentTimeMillis() - 3 * 24 * 60 * 60 * 1000), new Date(System.currentTimeMillis() - 2 * 24 * 60 * 60 * 1000)) + videoMapper.listRelationByCreateTime(new Date(System.currentTimeMillis() - 2 * 24 * 60 * 60 * 1000), new Date(System.currentTimeMillis() - 24 * 60 * 60 * 1000)) .forEach(item -> { if (item.getIsBuy() == 1) { return; diff --git a/src/main/resources/mapper/StatisticsMapper.xml b/src/main/resources/mapper/StatisticsMapper.xml index 5c153df..e5b596f 100644 --- a/src/main/resources/mapper/StatisticsMapper.xml +++ b/src/main/resources/mapper/StatisticsMapper.xml @@ -65,8 +65,8 @@ FROM `t_stats_record` r left join `t_stats` s on r.trace_id=s.trace_id where r.trace_id in (select trace_id from `t_stats_record` where action = 'ENTER_SCENIC' and `identifier`=#{scenicId}) - and action = 'CLICK' - and identifier = 'BUY' + and action = 'PAYMENT' + and (identifier = 'PAY_REQ' or identifier = 'PAY_BATCH_REQ' or identifier = 'PAY_SOURCE_REQ' or identifier = 'PAY_BATCH_REQ') and s.create_time >= #{startTime} From 3cab5e531da5435c63f68134a7680f906ec996df Mon Sep 17 00:00:00 2001 From: Jerry Yan <792602257@qq.com> Date: Sun, 27 Jul 2025 19:34:04 +0800 Subject: [PATCH 5/5] fix --- src/main/java/com/ycwl/basic/utils/JacksonUtil.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/main/java/com/ycwl/basic/utils/JacksonUtil.java b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java index 722239f..923d9f2 100644 --- a/src/main/java/com/ycwl/basic/utils/JacksonUtil.java +++ b/src/main/java/com/ycwl/basic/utils/JacksonUtil.java @@ -2,6 +2,7 @@ package com.ycwl.basic.utils; import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.core.type.TypeReference; +import com.fasterxml.jackson.databind.DeserializationFeature; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.type.CollectionType; @@ -18,6 +19,9 @@ import java.util.Map; public class JacksonUtil { private static final ObjectMapper objectMapper = new ObjectMapper(); + static { + objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); + } /** * 对象转JSON字符串