上链添加转义

ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/controller/DemoController.java

@@ -0,0 +1,44 @@
+package com.ruoyi.zhiyuanzhe.controller;
+
+import cn.hutool.json.JSONUtil;
+import com.ruoyi.common.core.controller.BaseController;
+import com.ruoyi.common.core.domain.AjaxResult;
+import com.ruoyi.zhiyuanzhe.domain.BDistributionRecords;
+import com.ruoyi.zhiyuanzhe.service.IBDistributionRecordsService;
+import com.ruoyi.zhiyuanzhe.utils.PushDataUtil;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+/**
+ * @author wu
+ * @since 2023/10/27 14:56
+ */
+@RestController
+@Api(tags = "测试数据上链")
+@RequestMapping("/zhiyuanzhe/demo")
+@Transactional(rollbackFor = Exception.class)
+public class DemoController extends BaseController {
+
+    @Resource
+    private IBDistributionRecordsService bDistributionRecordsService;
+
+    /**
+     * 测试数据上链
+     *
+     * @return 响应类
+     */
+    @PostMapping("/pushJson/{id}")
+    @ApiOperation(value = "测试数据上链")
+    public AjaxResult pushJson(@PathVariable("id") Long id) {
+        BDistributionRecords records = bDistributionRecordsService.selectBDistributionRecordsById(id);
+        String jsonStr = JSONUtil.toJsonStr(records);
+        return success(PushDataUtil.pushData(jsonStr));
+    }
+}

ruoyi-admin/src/main/java/com/ruoyi/zhiyuanzhe/utils/PushDataUtil.java

@@ -4,6 +4,7 @@ import cn.hutool.core.util.IdUtil;
 import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson2.JSONObject;
 import com.ruoyi.common.exception.ServiceException;
+import org.apache.commons.text.StringEscapeUtils;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -23,18 +24,19 @@ public class PushDataUtil {
      *
      * @param elementjsonstr 兑换记录json
      */
-    public static void pushData(String elementjsonstr) {
+    public static Map pushData(String elementjsonstr) {
         // 获取uuid
         String key = IdUtil.simpleUUID();
         Map<String, Object> param = new HashMap<>();
         param.put("key", key);
-        param.put("elementjsonstr", elementjsonstr);
+        param.put("elementjsonstr", StringEscapeUtils.escapeJson(elementjsonstr));
         String result = HttpUtil.post(pushUrl, param);
         Map map = JSONObject.parseObject(result, Map.class);
         System.err.println(map);
         Object code = map.get("code");
-        if (Integer.valueOf((String) code) != 200) {
+        if ((int) code != 200) {
             throw new ServiceException("数据传输失败");
         }
+        return map;
     }
 }

ruoyi-common/pom.xml

@@ -53,6 +53,13 @@
             <artifactId>commons-lang3</artifactId>
         </dependency>
 
+        <!-- apache commons-text-->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-text</artifactId>
+            <version>1.10.0</version>
+        </dependency>
+  
         <!-- JSON工具类 -->
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>