Browse Source

增加解析收到的数据

刘立冬 1 month ago
parent
commit
ad0c1a8fff

+ 4 - 2
risk-control-server/src/main/java/com/tzld/piaoquan/risk/control/controller/ReceiveRiskInfoController.java

@@ -1,5 +1,6 @@
 package com.tzld.piaoquan.risk.control.controller;
 
+import com.alibaba.fastjson.JSON;
 import com.tzld.piaoquan.risk.control.common.annotation.UnAuth;
 import com.tzld.piaoquan.risk.control.common.base.CommonResponse;
 import com.tzld.piaoquan.risk.control.config.QywxConfig;
@@ -30,8 +31,9 @@ public class ReceiveRiskInfoController {
      */
     @UnAuth
     @PostMapping("/push/riskuser")
-    public CommonResponse<RiskUserDelResult> receiveRiskUser(@RequestBody RiskUserInfo userInfo) {
-        log.info("receiveRiskUser, userInfo: {}", userInfo);
+    public CommonResponse<RiskUserDelResult> receiveRiskUser(@RequestBody String rawJson) {
+        log.info("receiveRiskUser, raw json: {}", rawJson);
+        RiskUserInfo userInfo = JSON.parseObject(rawJson, RiskUserInfo.class); // 手动解析
         int ret =  riskUserHandleService.handleRiskUser(userInfo);
         // 创建数据对象并设置 is_del 值
         RiskUserDelResult result = new RiskUserDelResult();

+ 2 - 1
risk-control-server/src/test/java/com/tzld/piaoquan/risk/control/service/DemoServiceTest.java

@@ -20,7 +20,8 @@ public class DemoServiceTest extends BaseTest {
 
     @Test
     void test(){
-        String riskInfo = "{\"chat_id\":\"wrreQkBgAAqfC7PyfSzRwj2ailPbXImg\",\"group_name\":\"qqq\",\"corp_id\":\"ww84bf86fbc1f29e79\",\"admin_list\":[{\"userid\":\"woreQkBgAA0TWJDl2bJ-M5NIZtk3xohg\",\"nickname\":\"刘立冬3\"},{\"userid\":\"pony\",\"nickname\":\"我是张三\"}],\"external_id\":\"wmreQkBgAAXnVuQtd16o_TyiWMbj24vQ\",\"external_nickname\":\"ivy\",\"join_time\":1748189477,\"join_scene\":3,\"risk_level\":0}";
+//        String riskInfo = "{\"chat_id\":\"wrreQkBgAAqfC7PyfSzRwj2ailPbXImg\",\"group_name\":\"qqq\",\"corp_id\":\"ww84bf86fbc1f29e79\",\"admin_list\":[{\"userid\":\"woreQkBgAA0TWJDl2bJ-M5NIZtk3xohg\",\"nickname\":\"刘立冬3\"},{\"userid\":\"pony\",\"nickname\":\"我是张三\"}],\"external_id\":\"wmreQkBgAAXnVuQtd16o_TyiWMbj24vQ\",\"external_nickname\":\"ivy\",\"join_time\":1748189477,\"join_scene\":3,\"risk_level\":0}";
+        String riskInfo = "{\"admin_list\":[{\"nickname\":\"\",\"userid\":\"woreQkBgAA2FzlWY58zU8IWjfsgGO8_Q\"},{\"nickname\":\"\",\"userid\":\"woreQkBgAAGlRNZoCrJGIQsTEs7nXcdQ\"},{\"nickname\":\"\",\"userid\":\"woreQkBgAAJzhqfRbDSOnwnPwCepD9MA\"},{\"nickname\":\"刘老师\",\"userid\":\"woreQkBgAAXwOoWHoq0ZcdzQyFUThAUw\"}],\"chat_id\":\"wrreQkBgAArVD7HfifBbkQEdFkLp4E0g\",\"corp_id\":\"wpreQkBgAAWRroXvmkqvdAFp_E-FqqNA\",\"external_id\":\"wmreQkBgAA19k-PU5mfr-LWSqTiC9NRg\",\"external_nickname\":\"傘春龍\",\"group_name\":\"<中华养生长寿大典>课程C7\",\"join_scene\":0,\"join_time\":1748264037,\"risk_level\":0}";
         RiskUserInfo riskUser = JSON.parseObject(riskInfo, RiskUserInfo.class);
         System.out.println(riskUser);
         riskUserHandleService.handleRiskUser(riskUser);